123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137 |
- /* This Source Code Form is subject to the terms of the Mozilla Public
- * License, v. 2.0. If a copy of the MPL was not distributed with this
- * file, You can obtain one at http://mozilla.org/MPL/2.0/.
- *
- * Copyright 2017 (c) Fraunhofer IOSB (Author: Julius Pfrommer)
- * Copyright 2017 (c) Mark Giraud, Fraunhofer IOSB
- * Copyright 2017 (c) Stefan Profanter, fortiss GmbH
- */
- #include "ua_client.h"
- #include "ua_client_internal.h"
- UA_StatusCode
- UA_Client_getEndpoints(UA_Client *client, const char *serverUrl,
- size_t* endpointDescriptionsSize,
- UA_EndpointDescription** endpointDescriptions) {
- UA_Boolean connected = (client->state > UA_CLIENTSTATE_DISCONNECTED);
- /* Client is already connected to a different server */
- if(connected && strncmp((const char*)client->endpointUrl.data, serverUrl,
- client->endpointUrl.length) != 0) {
- return UA_STATUSCODE_BADINVALIDARGUMENT;
- }
- UA_StatusCode retval;
- if(!connected) {
- retval = UA_Client_connectInternal(client, serverUrl, UA_FALSE, UA_FALSE);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- }
- retval = UA_Client_getEndpointsInternal(client, endpointDescriptionsSize, endpointDescriptions);
- if(!connected)
- UA_Client_disconnect(client);
- return retval;
- }
- UA_StatusCode
- UA_Client_findServers(UA_Client *client, const char *serverUrl,
- size_t serverUrisSize, UA_String *serverUris,
- size_t localeIdsSize, UA_String *localeIds,
- size_t *registeredServersSize,
- UA_ApplicationDescription **registeredServers) {
- UA_Boolean connected = (client->state > UA_CLIENTSTATE_DISCONNECTED);
- /* Client is already connected to a different server */
- if(connected && strncmp((const char*)client->endpointUrl.data, serverUrl,
- client->endpointUrl.length) != 0) {
- return UA_STATUSCODE_BADINVALIDARGUMENT;
- }
- if(!connected) {
- UA_StatusCode retval = UA_Client_connectInternal(client, serverUrl, UA_TRUE, UA_FALSE);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- }
- /* Prepare the request */
- UA_FindServersRequest request;
- UA_FindServersRequest_init(&request);
- request.serverUrisSize = serverUrisSize;
- request.serverUris = serverUris;
- request.localeIdsSize = localeIdsSize;
- request.localeIds = localeIds;
- /* Send the request */
- UA_FindServersResponse response;
- __UA_Client_Service(client, &request, &UA_TYPES[UA_TYPES_FINDSERVERSREQUEST],
- &response, &UA_TYPES[UA_TYPES_FINDSERVERSRESPONSE]);
- /* Process the response */
- UA_StatusCode retval = response.responseHeader.serviceResult;
- if(retval == UA_STATUSCODE_GOOD) {
- *registeredServersSize = response.serversSize;
- *registeredServers = response.servers;
- response.serversSize = 0;
- response.servers = NULL;
- } else {
- *registeredServersSize = 0;
- *registeredServers = NULL;
- }
- /* Clean up */
- UA_FindServersResponse_deleteMembers(&response);
- if(!connected)
- UA_Client_disconnect(client);
- return retval;
- }
- UA_StatusCode
- UA_Client_findServersOnNetwork(UA_Client *client, const char *serverUrl,
- UA_UInt32 startingRecordId, UA_UInt32 maxRecordsToReturn,
- size_t serverCapabilityFilterSize, UA_String *serverCapabilityFilter,
- size_t *serverOnNetworkSize, UA_ServerOnNetwork **serverOnNetwork) {
- UA_Boolean connected = (client->state > UA_CLIENTSTATE_DISCONNECTED);
- /* Client is already connected to a different server */
- if(connected && strncmp((const char*)client->endpointUrl.data, serverUrl,
- client->endpointUrl.length) != 0) {
- return UA_STATUSCODE_BADINVALIDARGUMENT;
- }
- if(!connected) {
- UA_StatusCode retval = UA_Client_connectInternal(client, serverUrl, UA_TRUE, UA_FALSE);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- }
- /* Prepare the request */
- UA_FindServersOnNetworkRequest request;
- UA_FindServersOnNetworkRequest_init(&request);
- request.startingRecordId = startingRecordId;
- request.maxRecordsToReturn = maxRecordsToReturn;
- request.serverCapabilityFilterSize = serverCapabilityFilterSize;
- request.serverCapabilityFilter = serverCapabilityFilter;
- /* Send the request */
- UA_FindServersOnNetworkResponse response;
- __UA_Client_Service(client, &request, &UA_TYPES[UA_TYPES_FINDSERVERSONNETWORKREQUEST],
- &response, &UA_TYPES[UA_TYPES_FINDSERVERSONNETWORKRESPONSE]);
- /* Process the response */
- UA_StatusCode retval = response.responseHeader.serviceResult;
- if(retval == UA_STATUSCODE_GOOD) {
- *serverOnNetworkSize = response.serversSize;
- *serverOnNetwork = response.servers;
- response.serversSize = 0;
- response.servers = NULL;
- } else {
- *serverOnNetworkSize = 0;
- *serverOnNetwork = NULL;
- }
- /* Clean up */
- UA_FindServersOnNetworkResponse_deleteMembers(&response);
- if(!connected)
- UA_Client_disconnect(client);
- return retval;
- }
|