|
@@ -5,24 +5,27 @@
|
|
#include "ua_server_internal.h"
|
|
#include "ua_server_internal.h"
|
|
#include "ua_services.h"
|
|
#include "ua_services.h"
|
|
|
|
|
|
|
|
+#if defined(UA_ENABLE_DISCOVERY) && defined(UA_ENABLE_DISCOVERY_MULTICAST)
|
|
|
|
+# include "ua_mdns_internal.h"
|
|
|
|
+#endif
|
|
|
|
|
|
-#ifdef UA_ENABLE_DISCOVERY
|
|
|
|
- #ifdef _MSC_VER
|
|
|
|
- #ifndef UNDER_CE
|
|
|
|
- # include <io.h> //access
|
|
|
|
- # define access _access
|
|
|
|
- #endif
|
|
|
|
- #else
|
|
|
|
- # include <unistd.h> //access
|
|
|
|
- #endif
|
|
|
|
|
|
+#ifdef _MSC_VER
|
|
|
|
+# ifndef UNDER_CE
|
|
|
|
+# include <io.h> //access
|
|
|
|
+# define access _access
|
|
|
|
+# endif
|
|
|
|
+#else
|
|
|
|
+# include <unistd.h> //access
|
|
#endif
|
|
#endif
|
|
|
|
|
|
#ifdef UA_ENABLE_DISCOVERY
|
|
#ifdef UA_ENABLE_DISCOVERY
|
|
-static UA_StatusCode copyRegisteredServerToApplicationDescription(const UA_FindServersRequest *request, UA_ApplicationDescription *target, const UA_RegisteredServer* registeredServer) {
|
|
|
|
|
|
+static UA_StatusCode
|
|
|
|
+setApplicationDescriptionFromRegisteredServer(const UA_FindServersRequest *request,
|
|
|
|
+ UA_ApplicationDescription *target,
|
|
|
|
+ const UA_RegisteredServer *registeredServer) {
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
|
|
|
|
UA_ApplicationDescription_init(target);
|
|
UA_ApplicationDescription_init(target);
|
|
-
|
|
|
|
retval |= UA_String_copy(®isteredServer->serverUri, &target->applicationUri);
|
|
retval |= UA_String_copy(®isteredServer->serverUri, &target->applicationUri);
|
|
retval |= UA_String_copy(®isteredServer->productUri, &target->productUri);
|
|
retval |= UA_String_copy(®isteredServer->productUri, &target->productUri);
|
|
|
|
|
|
@@ -32,13 +35,20 @@ static UA_StatusCode copyRegisteredServerToApplicationDescription(const UA_FindS
|
|
for (size_t i =0; i<request->localeIdsSize && !appNameFound; i++) {
|
|
for (size_t i =0; i<request->localeIdsSize && !appNameFound; i++) {
|
|
for (size_t j =0; j<registeredServer->serverNamesSize; j++) {
|
|
for (size_t j =0; j<registeredServer->serverNamesSize; j++) {
|
|
if (UA_String_equal(&request->localeIds[i], ®isteredServer->serverNames[j].locale)) {
|
|
if (UA_String_equal(&request->localeIds[i], ®isteredServer->serverNames[j].locale)) {
|
|
- retval |= UA_LocalizedText_copy(®isteredServer->serverNames[j], &target->applicationName);
|
|
|
|
|
|
+ retval |= UA_LocalizedText_copy(®isteredServer->serverNames[j],
|
|
|
|
+ &target->applicationName);
|
|
appNameFound = UA_TRUE;
|
|
appNameFound = UA_TRUE;
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- } else if (registeredServer->serverNamesSize){
|
|
|
|
|
|
+
|
|
|
|
+ // server does not have the requested local, therefore we can select the
|
|
|
|
+ // most suitable one
|
|
|
|
+ if(!appNameFound && registeredServer->serverNamesSize)
|
|
|
|
+ retval |= UA_LocalizedText_copy(®isteredServer->serverNames[0],
|
|
|
|
+ &target->applicationName);
|
|
|
|
+ } else if (registeredServer->serverNamesSize) {
|
|
// just take the first name
|
|
// just take the first name
|
|
retval |= UA_LocalizedText_copy(®isteredServer->serverNames[0], &target->applicationName);
|
|
retval |= UA_LocalizedText_copy(®isteredServer->serverNames[0], &target->applicationName);
|
|
}
|
|
}
|
|
@@ -48,48 +58,83 @@ static UA_StatusCode copyRegisteredServerToApplicationDescription(const UA_FindS
|
|
// TODO where do we get the discoveryProfileUri for application data?
|
|
// TODO where do we get the discoveryProfileUri for application data?
|
|
|
|
|
|
target->discoveryUrlsSize = registeredServer->discoveryUrlsSize;
|
|
target->discoveryUrlsSize = registeredServer->discoveryUrlsSize;
|
|
- if (registeredServer->discoveryUrlsSize) {
|
|
|
|
- target->discoveryUrls = (UA_String *)UA_malloc(sizeof(UA_String) * registeredServer->discoveryUrlsSize);
|
|
|
|
- if (!target->discoveryUrls) {
|
|
|
|
|
|
+ if(registeredServer->discoveryUrlsSize) {
|
|
|
|
+ size_t duSize = sizeof(UA_String) * registeredServer->discoveryUrlsSize;
|
|
|
|
+ target->discoveryUrls = (UA_String *)UA_malloc(duSize);
|
|
|
|
+ if(!target->discoveryUrls)
|
|
return UA_STATUSCODE_BADOUTOFMEMORY;
|
|
return UA_STATUSCODE_BADOUTOFMEMORY;
|
|
- }
|
|
|
|
- for (size_t i = 0; i<registeredServer->discoveryUrlsSize; i++) {
|
|
|
|
|
|
+ for(size_t i = 0; i<registeredServer->discoveryUrlsSize; i++)
|
|
retval |= UA_String_copy(®isteredServer->discoveryUrls[i], &target->discoveryUrls[i]);
|
|
retval |= UA_String_copy(®isteredServer->discoveryUrls[i], &target->discoveryUrls[i]);
|
|
- }
|
|
|
|
}
|
|
}
|
|
|
|
|
|
return retval;
|
|
return retval;
|
|
}
|
|
}
|
|
#endif
|
|
#endif
|
|
|
|
|
|
|
|
+static UA_StatusCode
|
|
|
|
+setApplicationDescriptionFromServer(UA_ApplicationDescription *target, const UA_Server *server) {
|
|
|
|
+ /* Copy ApplicationDescription from the config */
|
|
|
|
+
|
|
|
|
+ UA_StatusCode result = UA_ApplicationDescription_copy(&server->config.applicationDescription,
|
|
|
|
+ target);
|
|
|
|
+ if(result != UA_STATUSCODE_GOOD) {
|
|
|
|
+ return result;
|
|
|
|
+ }
|
|
|
|
+ // UaExpert does not list DiscoveryServer, thus set it to Server
|
|
|
|
+ // See http://forum.unified-automation.com/topic1987.html
|
|
|
|
+ if (target->applicationType == UA_APPLICATIONTYPE_DISCOVERYSERVER)
|
|
|
|
+ target->applicationType = UA_APPLICATIONTYPE_SERVER;
|
|
|
|
+
|
|
|
|
+ /* add the discoveryUrls from the networklayers */
|
|
|
|
+ size_t discSize = sizeof(UA_String) * (target->discoveryUrlsSize + server->config.networkLayersSize);
|
|
|
|
+ UA_String* disc = (UA_String *)UA_realloc(target->discoveryUrls, discSize);
|
|
|
|
+ if(!disc) {
|
|
|
|
+ return UA_STATUSCODE_BADOUTOFMEMORY;
|
|
|
|
+ }
|
|
|
|
+ size_t existing = target->discoveryUrlsSize;
|
|
|
|
+ target->discoveryUrls = disc;
|
|
|
|
+ target->discoveryUrlsSize += server->config.networkLayersSize;
|
|
|
|
+
|
|
|
|
+ // TODO: Add nl only if discoveryUrl not already present
|
|
|
|
+ for (size_t i = 0; i < server->config.networkLayersSize; i++) {
|
|
|
|
+ UA_ServerNetworkLayer* nl = &server->config.networkLayers[i];
|
|
|
|
+ UA_String_copy(&nl->discoveryUrl, &target->discoveryUrls[existing + i]);
|
|
|
|
+ }
|
|
|
|
+ return UA_STATUSCODE_GOOD;
|
|
|
|
+}
|
|
|
|
+
|
|
void Service_FindServers(UA_Server *server, UA_Session *session,
|
|
void Service_FindServers(UA_Server *server, UA_Session *session,
|
|
- const UA_FindServersRequest *request, UA_FindServersResponse *response) {
|
|
|
|
- UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing FindServersRequest");
|
|
|
|
|
|
+ const UA_FindServersRequest *request,
|
|
|
|
+ UA_FindServersResponse *response) {
|
|
|
|
+ UA_LOG_DEBUG_SESSION(server->config.logger, session,
|
|
|
|
+ "Processing FindServersRequest");
|
|
|
|
|
|
size_t foundServersSize = 0;
|
|
size_t foundServersSize = 0;
|
|
UA_ApplicationDescription *foundServers = NULL;
|
|
UA_ApplicationDescription *foundServers = NULL;
|
|
|
|
|
|
UA_Boolean addSelf = UA_FALSE;
|
|
UA_Boolean addSelf = UA_FALSE;
|
|
- // temporarily store all the pointers which we found to avoid reiterating through the list
|
|
|
|
|
|
+ // temporarily store all the pointers which we found to avoid reiterating
|
|
|
|
+ // through the list
|
|
UA_RegisteredServer **foundServerFilteredPointer = NULL;
|
|
UA_RegisteredServer **foundServerFilteredPointer = NULL;
|
|
|
|
|
|
#ifdef UA_ENABLE_DISCOVERY
|
|
#ifdef UA_ENABLE_DISCOVERY
|
|
// check if client only requested a specific set of servers
|
|
// check if client only requested a specific set of servers
|
|
if (request->serverUrisSize) {
|
|
if (request->serverUrisSize) {
|
|
-
|
|
|
|
- foundServerFilteredPointer = (UA_RegisteredServer **)UA_malloc(sizeof(UA_RegisteredServer*) * server->registeredServersSize);
|
|
|
|
|
|
+ size_t fsfpSize = sizeof(UA_RegisteredServer*) * server->registeredServersSize;
|
|
|
|
+ foundServerFilteredPointer = (UA_RegisteredServer **)UA_malloc(fsfpSize);
|
|
if(!foundServerFilteredPointer) {
|
|
if(!foundServerFilteredPointer) {
|
|
response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
- for (size_t i=0; i<request->serverUrisSize; i++) {
|
|
|
|
- if (!addSelf && UA_String_equal(&request->serverUris[i], &server->config.applicationDescription.applicationUri)) {
|
|
|
|
|
|
+ for(size_t i = 0; i < request->serverUrisSize; i++) {
|
|
|
|
+ if(!addSelf && UA_String_equal(&request->serverUris[i],
|
|
|
|
+ &server->config.applicationDescription.applicationUri)) {
|
|
addSelf = UA_TRUE;
|
|
addSelf = UA_TRUE;
|
|
} else {
|
|
} else {
|
|
registeredServer_list_entry* current;
|
|
registeredServer_list_entry* current;
|
|
LIST_FOREACH(current, &server->registeredServers, pointers) {
|
|
LIST_FOREACH(current, &server->registeredServers, pointers) {
|
|
- if (UA_String_equal(¤t->registeredServer.serverUri, &request->serverUris[i])) {
|
|
|
|
|
|
+ if(UA_String_equal(¤t->registeredServer.serverUri, &request->serverUris[i])) {
|
|
foundServerFilteredPointer[foundServersSize++] = ¤t->registeredServer;
|
|
foundServerFilteredPointer[foundServersSize++] = ¤t->registeredServer;
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
@@ -97,19 +142,19 @@ void Service_FindServers(UA_Server *server, UA_Session *session,
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- if (addSelf)
|
|
|
|
|
|
+ if(addSelf)
|
|
foundServersSize++;
|
|
foundServersSize++;
|
|
|
|
|
|
} else {
|
|
} else {
|
|
addSelf = true;
|
|
addSelf = true;
|
|
-
|
|
|
|
// self + registered servers
|
|
// self + registered servers
|
|
foundServersSize = 1 + server->registeredServersSize;
|
|
foundServersSize = 1 + server->registeredServersSize;
|
|
}
|
|
}
|
|
#else
|
|
#else
|
|
- if (request->serverUrisSize) {
|
|
|
|
- for (size_t i=0; i<request->serverUrisSize; i++) {
|
|
|
|
- if (UA_String_equal(&request->serverUris[i], &server->config.applicationDescription.applicationUri)) {
|
|
|
|
|
|
+ if(request->serverUrisSize) {
|
|
|
|
+ for(size_t i = 0; i < request->serverUrisSize; i++) {
|
|
|
|
+ if(UA_String_equal(&request->serverUris[i],
|
|
|
|
+ &server->config.applicationDescription.applicationUri)) {
|
|
addSelf = UA_TRUE;
|
|
addSelf = UA_TRUE;
|
|
foundServersSize = 1;
|
|
foundServersSize = 1;
|
|
break;
|
|
break;
|
|
@@ -122,61 +167,40 @@ void Service_FindServers(UA_Server *server, UA_Session *session,
|
|
#endif
|
|
#endif
|
|
|
|
|
|
if(foundServersSize) {
|
|
if(foundServersSize) {
|
|
- foundServers = (UA_ApplicationDescription *)UA_malloc(sizeof(UA_ApplicationDescription) * foundServersSize);
|
|
|
|
- if (!foundServers) {
|
|
|
|
- if (foundServerFilteredPointer)
|
|
|
|
|
|
+ size_t fsSize = sizeof(UA_ApplicationDescription) * foundServersSize;
|
|
|
|
+ foundServers = (UA_ApplicationDescription *)UA_malloc(fsSize);
|
|
|
|
+ if(!foundServers) {
|
|
|
|
+ if(foundServerFilteredPointer)
|
|
UA_free(foundServerFilteredPointer);
|
|
UA_free(foundServerFilteredPointer);
|
|
response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
- /* copy ApplicationDescription from the config */
|
|
|
|
if(addSelf) {
|
|
if(addSelf) {
|
|
- response->responseHeader.serviceResult |=
|
|
|
|
- UA_ApplicationDescription_copy(&server->config.applicationDescription, &foundServers[0]);
|
|
|
|
- if (response->responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
|
|
|
|
- UA_free(foundServers);
|
|
|
|
- if (foundServerFilteredPointer)
|
|
|
|
- UA_free(foundServerFilteredPointer);
|
|
|
|
- return;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- /* add the discoveryUrls from the networklayers */
|
|
|
|
- UA_String* disc = (UA_String *)UA_realloc(foundServers[0].discoveryUrls,
|
|
|
|
- sizeof(UA_String) * (foundServers[0].discoveryUrlsSize +
|
|
|
|
- server->config.networkLayersSize));
|
|
|
|
- if(!disc) {
|
|
|
|
- response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
|
|
|
|
+ response->responseHeader.serviceResult = setApplicationDescriptionFromServer(&foundServers[0], server);
|
|
|
|
+ if(response->responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
|
|
UA_free(foundServers);
|
|
UA_free(foundServers);
|
|
if (foundServerFilteredPointer)
|
|
if (foundServerFilteredPointer)
|
|
UA_free(foundServerFilteredPointer);
|
|
UA_free(foundServerFilteredPointer);
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
- size_t existing = foundServers[0].discoveryUrlsSize;
|
|
|
|
- foundServers[0].discoveryUrls = disc;
|
|
|
|
- foundServers[0].discoveryUrlsSize += server->config.networkLayersSize;
|
|
|
|
-
|
|
|
|
- // TODO: Add nl only if discoveryUrl not already present
|
|
|
|
- for (size_t i = 0; i < server->config.networkLayersSize; i++) {
|
|
|
|
- UA_ServerNetworkLayer* nl = &server->config.networkLayers[i];
|
|
|
|
- UA_String_copy(&nl->discoveryUrl, &foundServers[0].discoveryUrls[existing + i]);
|
|
|
|
- }
|
|
|
|
}
|
|
}
|
|
-#ifdef UA_ENABLE_DISCOVERY
|
|
|
|
|
|
|
|
|
|
+#ifdef UA_ENABLE_DISCOVERY
|
|
size_t currentIndex = 0;
|
|
size_t currentIndex = 0;
|
|
if (addSelf)
|
|
if (addSelf)
|
|
currentIndex++;
|
|
currentIndex++;
|
|
|
|
|
|
// add all the registered servers to the list
|
|
// add all the registered servers to the list
|
|
- if(foundServerFilteredPointer) {
|
|
|
|
|
|
+
|
|
|
|
+ if (foundServerFilteredPointer) {
|
|
// use filtered list because client only requested specific uris
|
|
// use filtered list because client only requested specific uris
|
|
// -1 because foundServersSize also includes this self server
|
|
// -1 because foundServersSize also includes this self server
|
|
size_t iterCount = addSelf ? foundServersSize - 1 : foundServersSize;
|
|
size_t iterCount = addSelf ? foundServersSize - 1 : foundServersSize;
|
|
- for(size_t i = 0; i < iterCount; i++) {
|
|
|
|
|
|
+ for (size_t i = 0; i < iterCount; i++) {
|
|
response->responseHeader.serviceResult =
|
|
response->responseHeader.serviceResult =
|
|
- copyRegisteredServerToApplicationDescription(request, &foundServers[currentIndex++],
|
|
|
|
- foundServerFilteredPointer[i]);
|
|
|
|
|
|
+ setApplicationDescriptionFromRegisteredServer(request, &foundServers[currentIndex++],
|
|
|
|
+ foundServerFilteredPointer[i]);
|
|
if (response->responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
|
|
if (response->responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
|
|
UA_free(foundServers);
|
|
UA_free(foundServers);
|
|
UA_free(foundServerFilteredPointer);
|
|
UA_free(foundServerFilteredPointer);
|
|
@@ -189,8 +213,8 @@ void Service_FindServers(UA_Server *server, UA_Session *session,
|
|
registeredServer_list_entry* current;
|
|
registeredServer_list_entry* current;
|
|
LIST_FOREACH(current, &server->registeredServers, pointers) {
|
|
LIST_FOREACH(current, &server->registeredServers, pointers) {
|
|
response->responseHeader.serviceResult =
|
|
response->responseHeader.serviceResult =
|
|
- copyRegisteredServerToApplicationDescription(request, &foundServers[currentIndex++],
|
|
|
|
- ¤t->registeredServer);
|
|
|
|
|
|
+ setApplicationDescriptionFromRegisteredServer(request, &foundServers[currentIndex++],
|
|
|
|
+ ¤t->registeredServer);
|
|
if (response->responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
|
|
if (response->responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
|
|
UA_free(foundServers);
|
|
UA_free(foundServers);
|
|
return;
|
|
return;
|
|
@@ -207,24 +231,24 @@ void Service_FindServers(UA_Server *server, UA_Session *session,
|
|
response->serversSize = foundServersSize;
|
|
response->serversSize = foundServersSize;
|
|
}
|
|
}
|
|
|
|
|
|
-void Service_GetEndpoints(UA_Server *server, UA_Session *session, const UA_GetEndpointsRequest *request,
|
|
|
|
|
|
+void Service_GetEndpoints(UA_Server *server, UA_Session *session,
|
|
|
|
+ const UA_GetEndpointsRequest *request,
|
|
UA_GetEndpointsResponse *response) {
|
|
UA_GetEndpointsResponse *response) {
|
|
/* If the client expects to see a specific endpointurl, mirror it back. If
|
|
/* If the client expects to see a specific endpointurl, mirror it back. If
|
|
not, clone the endpoints with the discovery url of all networklayers. */
|
|
not, clone the endpoints with the discovery url of all networklayers. */
|
|
const UA_String *endpointUrl = &request->endpointUrl;
|
|
const UA_String *endpointUrl = &request->endpointUrl;
|
|
if(endpointUrl->length > 0) {
|
|
if(endpointUrl->length > 0) {
|
|
- UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing GetEndpointsRequest with endpointUrl " \
|
|
|
|
|
|
+ UA_LOG_DEBUG_SESSION(server->config.logger, session,
|
|
|
|
+ "Processing GetEndpointsRequest with endpointUrl "
|
|
UA_PRINTF_STRING_FORMAT, UA_PRINTF_STRING_DATA(*endpointUrl));
|
|
UA_PRINTF_STRING_FORMAT, UA_PRINTF_STRING_DATA(*endpointUrl));
|
|
} else {
|
|
} else {
|
|
- UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing GetEndpointsRequest with an empty endpointUrl");
|
|
|
|
|
|
+ UA_LOG_DEBUG_SESSION(server->config.logger, session,
|
|
|
|
+ "Processing GetEndpointsRequest with an empty endpointUrl");
|
|
}
|
|
}
|
|
|
|
|
|
/* test if the supported binary profile shall be returned */
|
|
/* test if the supported binary profile shall be returned */
|
|
-#ifdef NO_ALLOCA
|
|
|
|
- UA_Boolean relevant_endpoints[server->endpointDescriptionsSize];
|
|
|
|
-#else
|
|
|
|
- UA_Boolean *relevant_endpoints = (UA_Boolean *)UA_alloca(sizeof(UA_Boolean) * server->endpointDescriptionsSize);
|
|
|
|
-#endif
|
|
|
|
|
|
+ size_t reSize = sizeof(UA_Boolean) * server->endpointDescriptionsSize;
|
|
|
|
+ UA_Boolean *relevant_endpoints = (UA_Boolean *)UA_alloca(reSize);
|
|
memset(relevant_endpoints, 0, sizeof(UA_Boolean) * server->endpointDescriptionsSize);
|
|
memset(relevant_endpoints, 0, sizeof(UA_Boolean) * server->endpointDescriptionsSize);
|
|
size_t relevant_count = 0;
|
|
size_t relevant_count = 0;
|
|
if(request->profileUrisSize == 0) {
|
|
if(request->profileUrisSize == 0) {
|
|
@@ -234,7 +258,8 @@ void Service_GetEndpoints(UA_Server *server, UA_Session *session, const UA_GetEn
|
|
} else {
|
|
} else {
|
|
for(size_t j = 0; j < server->endpointDescriptionsSize; ++j) {
|
|
for(size_t j = 0; j < server->endpointDescriptionsSize; ++j) {
|
|
for(size_t i = 0; i < request->profileUrisSize; ++i) {
|
|
for(size_t i = 0; i < request->profileUrisSize; ++i) {
|
|
- if(!UA_String_equal(&request->profileUris[i], &server->endpointDescriptions[j].transportProfileUri))
|
|
|
|
|
|
+ if(!UA_String_equal(&request->profileUris[i],
|
|
|
|
+ &server->endpointDescriptions[j].transportProfileUri))
|
|
continue;
|
|
continue;
|
|
relevant_endpoints[j] = true;
|
|
relevant_endpoints[j] = true;
|
|
++relevant_count;
|
|
++relevant_count;
|
|
@@ -256,7 +281,9 @@ void Service_GetEndpoints(UA_Server *server, UA_Session *session, const UA_GetEn
|
|
nl_endpointurl = true;
|
|
nl_endpointurl = true;
|
|
}
|
|
}
|
|
|
|
|
|
- response->endpoints = (UA_EndpointDescription *)UA_Array_new(relevant_count * clone_times, &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION]);
|
|
|
|
|
|
+ response->endpoints =
|
|
|
|
+ (UA_EndpointDescription*)UA_Array_new(relevant_count * clone_times,
|
|
|
|
+ &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION]);
|
|
if(!response->endpoints) {
|
|
if(!response->endpoints) {
|
|
response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
return;
|
|
return;
|
|
@@ -279,7 +306,8 @@ void Service_GetEndpoints(UA_Server *server, UA_Session *session, const UA_GetEn
|
|
|
|
|
|
if(retval != UA_STATUSCODE_GOOD) {
|
|
if(retval != UA_STATUSCODE_GOOD) {
|
|
response->responseHeader.serviceResult = retval;
|
|
response->responseHeader.serviceResult = retval;
|
|
- UA_Array_delete(response->endpoints, response->endpointsSize, &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION]);
|
|
|
|
|
|
+ UA_Array_delete(response->endpoints, response->endpointsSize,
|
|
|
|
+ &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION]);
|
|
response->endpoints = NULL;
|
|
response->endpoints = NULL;
|
|
response->endpointsSize = 0;
|
|
response->endpointsSize = 0;
|
|
return;
|
|
return;
|
|
@@ -287,32 +315,114 @@ void Service_GetEndpoints(UA_Server *server, UA_Session *session, const UA_GetEn
|
|
}
|
|
}
|
|
|
|
|
|
#ifdef UA_ENABLE_DISCOVERY
|
|
#ifdef UA_ENABLE_DISCOVERY
|
|
-void Service_RegisterServer(UA_Server *server, UA_Session *session,
|
|
|
|
- const UA_RegisterServerRequest *request, UA_RegisterServerResponse *response) {
|
|
|
|
- UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing RegisterServerRequest");
|
|
|
|
|
|
|
|
|
|
+static void
|
|
|
|
+process_RegisterServer(UA_Server *server, UA_Session *session,
|
|
|
|
+ const UA_RequestHeader* requestHeader,
|
|
|
|
+ const UA_RegisteredServer *requestServer,
|
|
|
|
+ const size_t requestDiscoveryConfigurationSize,
|
|
|
|
+ const UA_ExtensionObject *requestDiscoveryConfiguration,
|
|
|
|
+ UA_ResponseHeader* responseHeader,
|
|
|
|
+ size_t *responseConfigurationResultsSize,
|
|
|
|
+ UA_StatusCode **responseConfigurationResults,
|
|
|
|
+ size_t *responseDiagnosticInfosSize,
|
|
|
|
+ UA_DiagnosticInfo *responseDiagnosticInfos) {
|
|
|
|
+ /* Find the server from the request in the registered list */
|
|
|
|
+ registeredServer_list_entry* current;
|
|
registeredServer_list_entry *registeredServer_entry = NULL;
|
|
registeredServer_list_entry *registeredServer_entry = NULL;
|
|
|
|
+ LIST_FOREACH(current, &server->registeredServers, pointers) {
|
|
|
|
+ if (UA_String_equal(¤t->registeredServer.serverUri, &requestServer->serverUri)) {
|
|
|
|
+ registeredServer_entry = current;
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
|
|
- {
|
|
|
|
- // find the server from the request in the registered list
|
|
|
|
- registeredServer_list_entry* current;
|
|
|
|
- LIST_FOREACH(current, &server->registeredServers, pointers) {
|
|
|
|
- if (UA_String_equal(¤t->registeredServer.serverUri, &request->server.serverUri)) {
|
|
|
|
- registeredServer_entry = current;
|
|
|
|
- break;
|
|
|
|
|
|
+ UA_MdnsDiscoveryConfiguration *mdnsConfig = NULL;
|
|
|
|
+
|
|
|
|
+ const UA_String* mdnsServerName = NULL;
|
|
|
|
+ if(requestDiscoveryConfigurationSize) {
|
|
|
|
+ *responseConfigurationResultsSize = requestDiscoveryConfigurationSize;
|
|
|
|
+ *responseConfigurationResults =
|
|
|
|
+ (UA_StatusCode *)UA_Array_new(requestDiscoveryConfigurationSize,
|
|
|
|
+ &UA_TYPES[UA_TYPES_STATUSCODE]);
|
|
|
|
+ for(size_t i =0; i<requestDiscoveryConfigurationSize; i++) {
|
|
|
|
+ const UA_ExtensionObject *object = &requestDiscoveryConfiguration[i];
|
|
|
|
+ if(!mdnsConfig && (object->encoding == UA_EXTENSIONOBJECT_DECODED ||
|
|
|
|
+ object->encoding == UA_EXTENSIONOBJECT_DECODED_NODELETE) &&
|
|
|
|
+ (object->content.decoded.type == &UA_TYPES[UA_TYPES_MDNSDISCOVERYCONFIGURATION])) {
|
|
|
|
+ mdnsConfig = (UA_MdnsDiscoveryConfiguration *)object->content.decoded.data;
|
|
|
|
+ mdnsServerName = &mdnsConfig->mdnsServerName;
|
|
|
|
+ *responseConfigurationResults[i] = UA_STATUSCODE_GOOD;
|
|
|
|
+ } else {
|
|
|
|
+ *responseConfigurationResults[i] = UA_STATUSCODE_BADNOTSUPPORTED;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- if (!request->server.isOnline) {
|
|
|
|
|
|
+ if(!mdnsServerName && requestServer->serverNamesSize)
|
|
|
|
+ mdnsServerName = &requestServer->serverNames[0].text;
|
|
|
|
+
|
|
|
|
+ if(!mdnsServerName) {
|
|
|
|
+ responseHeader->serviceResult = UA_STATUSCODE_BADSERVERNAMEMISSING;
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if(requestServer->discoveryUrlsSize == 0) {
|
|
|
|
+ responseHeader->serviceResult = UA_STATUSCODE_BADDISCOVERYURLMISSING;
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if(requestServer->semaphoreFilePath.length) {
|
|
|
|
+#ifdef UA_ENABLE_DISCOVERY_SEMAPHORE
|
|
|
|
+ // todo: malloc may fail: return a statuscode
|
|
|
|
+ char* filePath = (char *)UA_malloc(sizeof(char)*requestServer->semaphoreFilePath.length+1);
|
|
|
|
+ memcpy(filePath, requestServer->semaphoreFilePath.data, requestServer->semaphoreFilePath.length );
|
|
|
|
+ filePath[requestServer->semaphoreFilePath.length] = '\0';
|
|
|
|
+ if(access( filePath, 0 ) == -1) {
|
|
|
|
+ responseHeader->serviceResult = UA_STATUSCODE_BADSEMPAHOREFILEMISSING;
|
|
|
|
+ free(filePath);
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+ free(filePath);
|
|
|
|
+#else
|
|
|
|
+ UA_LOG_WARNING(server->config.logger, UA_LOGCATEGORY_CLIENT,
|
|
|
|
+ "Ignoring semaphore file path. open62541 not compiled with UA_ENABLE_DISCOVERY_SEMAPHORE=ON");
|
|
|
|
+#endif
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+#ifdef UA_ENABLE_DISCOVERY_MULTICAST
|
|
|
|
+ if(server->config.applicationDescription.applicationType == UA_APPLICATIONTYPE_DISCOVERYSERVER) {
|
|
|
|
+ // todo: malloc may fail: return a statuscode
|
|
|
|
+ char* mdnsServer = (char *)UA_malloc(sizeof(char) * mdnsServerName->length + 1);
|
|
|
|
+ memcpy(mdnsServer, mdnsServerName->data, mdnsServerName->length);
|
|
|
|
+ mdnsServer[mdnsServerName->length] = '\0';
|
|
|
|
+
|
|
|
|
+ for(size_t i = 0; i < requestServer->discoveryUrlsSize; i++) {
|
|
|
|
+ /* create TXT if is online and first index, delete TXT if is offline and last index */
|
|
|
|
+ UA_Boolean updateTxt = (requestServer->isOnline && i==0) ||
|
|
|
|
+ (!requestServer->isOnline && i==requestServer->discoveryUrlsSize);
|
|
|
|
+ UA_Discovery_update_MdnsForDiscoveryUrl(server, mdnsServer, mdnsConfig,
|
|
|
|
+ requestServer->discoveryUrls[i],
|
|
|
|
+ requestServer->isOnline, updateTxt);
|
|
|
|
+ }
|
|
|
|
+ free(mdnsServer);
|
|
|
|
+ }
|
|
|
|
+#endif
|
|
|
|
+
|
|
|
|
+ if(!requestServer->isOnline) {
|
|
// server is shutting down. Remove it from the registered servers list
|
|
// server is shutting down. Remove it from the registered servers list
|
|
- if (!registeredServer_entry) {
|
|
|
|
|
|
+ if(!registeredServer_entry) {
|
|
// server not found, show warning
|
|
// server not found, show warning
|
|
- UA_LOG_WARNING_SESSION(server->config.logger, session, "Could not unregister server %.*s. Not registered.", (int)request->server.serverUri.length, request->server.serverUri.data);
|
|
|
|
- response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTFOUND;
|
|
|
|
|
|
+ UA_LOG_WARNING_SESSION(server->config.logger, session,
|
|
|
|
+ "Could not unregister server %.*s. Not registered.",
|
|
|
|
+ (int)requestServer->serverUri.length, requestServer->serverUri.data);
|
|
|
|
+ responseHeader->serviceResult = UA_STATUSCODE_BADNOTFOUND;
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ if(server->registerServerCallback)
|
|
|
|
+ server->registerServerCallback(requestServer, server->registerServerCallbackData);
|
|
|
|
+
|
|
// server found, remove from list
|
|
// server found, remove from list
|
|
LIST_REMOVE(registeredServer_entry, pointers);
|
|
LIST_REMOVE(registeredServer_entry, pointers);
|
|
UA_RegisteredServer_deleteMembers(®isteredServer_entry->registeredServer);
|
|
UA_RegisteredServer_deleteMembers(®isteredServer_entry->registeredServer);
|
|
@@ -323,21 +433,20 @@ void Service_RegisterServer(UA_Server *server, UA_Session *session,
|
|
server->registeredServersSize = uatomic_add_return(&server->registeredServersSize, -1);
|
|
server->registeredServersSize = uatomic_add_return(&server->registeredServersSize, -1);
|
|
UA_Server_delayedFree(server, registeredServer_entry);
|
|
UA_Server_delayedFree(server, registeredServer_entry);
|
|
#endif
|
|
#endif
|
|
- response->responseHeader.serviceResult = UA_STATUSCODE_GOOD;
|
|
|
|
|
|
+ responseHeader->serviceResult = UA_STATUSCODE_GOOD;
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
if (!registeredServer_entry) {
|
|
if (!registeredServer_entry) {
|
|
// server not yet registered, register it by adding it to the list
|
|
// server not yet registered, register it by adding it to the list
|
|
|
|
+ UA_LOG_DEBUG_SESSION(server->config.logger, session, "Registering new server: %.*s",
|
|
|
|
+ (int)requestServer->serverUri.length, requestServer->serverUri.data);
|
|
|
|
|
|
-
|
|
|
|
- UA_LOG_DEBUG_SESSION(server->config.logger, session, "Registering new server: %.*s", (int)request->server.serverUri.length, request->server.serverUri.data);
|
|
|
|
-
|
|
|
|
- registeredServer_entry = (registeredServer_list_entry *)UA_malloc(sizeof(registeredServer_list_entry));
|
|
|
|
|
|
+ registeredServer_entry =
|
|
|
|
+ (registeredServer_list_entry *)UA_malloc(sizeof(registeredServer_list_entry));
|
|
if(!registeredServer_entry) {
|
|
if(!registeredServer_entry) {
|
|
- response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
|
|
|
|
+ responseHeader->serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -348,65 +457,88 @@ void Service_RegisterServer(UA_Server *server, UA_Session *session,
|
|
server->registeredServersSize = uatomic_add_return(&server->registeredServersSize, 1);
|
|
server->registeredServersSize = uatomic_add_return(&server->registeredServersSize, 1);
|
|
#endif
|
|
#endif
|
|
|
|
|
|
|
|
+ if(server->registerServerCallback)
|
|
|
|
+ server->registerServerCallback(requestServer, server->registerServerCallbackData);
|
|
} else {
|
|
} else {
|
|
UA_RegisteredServer_deleteMembers(®isteredServer_entry->registeredServer);
|
|
UA_RegisteredServer_deleteMembers(®isteredServer_entry->registeredServer);
|
|
}
|
|
}
|
|
|
|
|
|
// copy the data from the request into the list
|
|
// copy the data from the request into the list
|
|
- UA_RegisteredServer_copy(&request->server, ®isteredServer_entry->registeredServer);
|
|
|
|
|
|
+ UA_RegisteredServer_copy(requestServer, ®isteredServer_entry->registeredServer);
|
|
registeredServer_entry->lastSeen = UA_DateTime_nowMonotonic();
|
|
registeredServer_entry->lastSeen = UA_DateTime_nowMonotonic();
|
|
|
|
+ responseHeader->serviceResult = retval;
|
|
|
|
+}
|
|
|
|
|
|
- response->responseHeader.serviceResult = retval;
|
|
|
|
|
|
+void Service_RegisterServer(UA_Server *server, UA_Session *session,
|
|
|
|
+ const UA_RegisterServerRequest *request,
|
|
|
|
+ UA_RegisterServerResponse *response) {
|
|
|
|
+ UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing RegisterServerRequest");
|
|
|
|
+ process_RegisterServer(server, session, &request->requestHeader, &request->server, 0,
|
|
|
|
+ NULL, &response->responseHeader, 0, NULL, 0, NULL);
|
|
}
|
|
}
|
|
|
|
|
|
-/**
|
|
|
|
- * Cleanup server registration:
|
|
|
|
- * If the semaphore file path is set, then it just checks the existence of the file.
|
|
|
|
- * When it is deleted, the registration is removed.
|
|
|
|
- * If there is no semaphore file, then the registration will be removed if it is older than 60 minutes.
|
|
|
|
- */
|
|
|
|
-void UA_Discovery_cleanupTimedOut(UA_Server *server, UA_DateTime nowMonotonic) {
|
|
|
|
|
|
+void Service_RegisterServer2(UA_Server *server, UA_Session *session,
|
|
|
|
+ const UA_RegisterServer2Request *request,
|
|
|
|
+ UA_RegisterServer2Response *response) {
|
|
|
|
+ UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing RegisterServer2Request");
|
|
|
|
+ process_RegisterServer(server, session, &request->requestHeader, &request->server,
|
|
|
|
+ request->discoveryConfigurationSize, request->discoveryConfiguration,
|
|
|
|
+ &response->responseHeader, &response->configurationResultsSize,
|
|
|
|
+ &response->configurationResults, &response->diagnosticInfosSize,
|
|
|
|
+ response->diagnosticInfos);
|
|
|
|
+}
|
|
|
|
|
|
|
|
+/* Cleanup server registration: If the semaphore file path is set, then it just
|
|
|
|
+ * checks the existence of the file. When it is deleted, the registration is
|
|
|
|
+ * removed. If there is no semaphore file, then the registration will be removed
|
|
|
|
+ * if it is older than 60 minutes. */
|
|
|
|
+void UA_Discovery_cleanupTimedOut(UA_Server *server, UA_DateTime nowMonotonic) {
|
|
UA_DateTime timedOut = nowMonotonic;
|
|
UA_DateTime timedOut = nowMonotonic;
|
|
- // registration is timed out if lastSeen is older than 60 minutes (default value, can be modified by user).
|
|
|
|
- if (server->config.discoveryCleanupTimeout) {
|
|
|
|
|
|
+ // registration is timed out if lastSeen is older than 60 minutes (default
|
|
|
|
+ // value, can be modified by user).
|
|
|
|
+ if(server->config.discoveryCleanupTimeout)
|
|
timedOut -= server->config.discoveryCleanupTimeout*UA_SEC_TO_DATETIME;
|
|
timedOut -= server->config.discoveryCleanupTimeout*UA_SEC_TO_DATETIME;
|
|
- }
|
|
|
|
|
|
|
|
registeredServer_list_entry* current, *temp;
|
|
registeredServer_list_entry* current, *temp;
|
|
LIST_FOREACH_SAFE(current, &server->registeredServers, pointers, temp) {
|
|
LIST_FOREACH_SAFE(current, &server->registeredServers, pointers, temp) {
|
|
-
|
|
|
|
UA_Boolean semaphoreDeleted = UA_FALSE;
|
|
UA_Boolean semaphoreDeleted = UA_FALSE;
|
|
|
|
|
|
- if (current->registeredServer.semaphoreFilePath.length) {
|
|
|
|
- char* filePath = (char *)malloc(sizeof(char)*current->registeredServer.semaphoreFilePath.length+1);
|
|
|
|
- memcpy( filePath, current->registeredServer.semaphoreFilePath.data, current->registeredServer.semaphoreFilePath.length );
|
|
|
|
|
|
+#ifdef UA_ENABLE_DISCOVERY_SEMAPHORE
|
|
|
|
+ if(current->registeredServer.semaphoreFilePath.length) {
|
|
|
|
+ size_t fpSize = sizeof(char)*current->registeredServer.semaphoreFilePath.length+1;
|
|
|
|
+ // todo: malloc may fail: return a statuscode
|
|
|
|
+ char* filePath = (char *)UA_malloc(fpSize);
|
|
|
|
+ memcpy(filePath, current->registeredServer.semaphoreFilePath.data,
|
|
|
|
+ current->registeredServer.semaphoreFilePath.length );
|
|
filePath[current->registeredServer.semaphoreFilePath.length] = '\0';
|
|
filePath[current->registeredServer.semaphoreFilePath.length] = '\0';
|
|
#ifdef UNDER_CE
|
|
#ifdef UNDER_CE
|
|
FILE *fp = fopen(filePath,"rb");
|
|
FILE *fp = fopen(filePath,"rb");
|
|
semaphoreDeleted = (fp==NULL);
|
|
semaphoreDeleted = (fp==NULL);
|
|
- if (fp)
|
|
|
|
|
|
+ if(fp)
|
|
fclose(fp);
|
|
fclose(fp);
|
|
#else
|
|
#else
|
|
- semaphoreDeleted = access( filePath, 0 ) == -1;
|
|
|
|
|
|
+ semaphoreDeleted = access( filePath, 0 ) == -1;
|
|
#endif
|
|
#endif
|
|
- free(filePath);
|
|
|
|
|
|
+ free(filePath);
|
|
}
|
|
}
|
|
|
|
+#endif
|
|
|
|
|
|
- if (semaphoreDeleted || (server->config.discoveryCleanupTimeout && current->lastSeen < timedOut)) {
|
|
|
|
- if (semaphoreDeleted) {
|
|
|
|
|
|
+ if(semaphoreDeleted || (server->config.discoveryCleanupTimeout &&
|
|
|
|
+ current->lastSeen < timedOut)) {
|
|
|
|
+ if(semaphoreDeleted) {
|
|
UA_LOG_INFO(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
UA_LOG_INFO(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
- "Registration of server with URI %.*s is removed because the semaphore file '%.*s' was deleted.",
|
|
|
|
- (int)current->registeredServer.serverUri.length, current->registeredServer.serverUri.data,
|
|
|
|
- (int)current->registeredServer.semaphoreFilePath.length, current->registeredServer.semaphoreFilePath.data);
|
|
|
|
|
|
+ "Registration of server with URI %.*s is removed because "
|
|
|
|
+ "the semaphore file '%.*s' was deleted.",
|
|
|
|
+ (int)current->registeredServer.serverUri.length,
|
|
|
|
+ current->registeredServer.serverUri.data,
|
|
|
|
+ (int)current->registeredServer.semaphoreFilePath.length,
|
|
|
|
+ current->registeredServer.semaphoreFilePath.data);
|
|
} else {
|
|
} else {
|
|
// cppcheck-suppress unreadVariable
|
|
// cppcheck-suppress unreadVariable
|
|
- UA_String lastStr = UA_DateTime_toString(current->lastSeen);
|
|
|
|
UA_LOG_INFO(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
UA_LOG_INFO(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
- "Registration of server with URI %.*s has timed out and is removed. Last seen: %.*s",
|
|
|
|
- (int)current->registeredServer.serverUri.length, current->registeredServer.serverUri.data,
|
|
|
|
- (int)lastStr.length, lastStr.data);
|
|
|
|
- UA_free(lastStr.data);
|
|
|
|
|
|
+ "Registration of server with URI %.*s has timed out and is removed.",
|
|
|
|
+ (int)current->registeredServer.serverUri.length,
|
|
|
|
+ current->registeredServer.serverUri.data);
|
|
}
|
|
}
|
|
LIST_REMOVE(current, pointers);
|
|
LIST_REMOVE(current, pointers);
|
|
UA_RegisteredServer_deleteMembers(¤t->registeredServer);
|
|
UA_RegisteredServer_deleteMembers(¤t->registeredServer);
|
|
@@ -417,9 +549,167 @@ void UA_Discovery_cleanupTimedOut(UA_Server *server, UA_DateTime nowMonotonic) {
|
|
server->registeredServersSize = uatomic_add_return(&server->registeredServersSize, -1);
|
|
server->registeredServersSize = uatomic_add_return(&server->registeredServersSize, -1);
|
|
UA_Server_delayedFree(server, current);
|
|
UA_Server_delayedFree(server, current);
|
|
#endif
|
|
#endif
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+struct PeriodicServerRegisterJob {
|
|
|
|
+ UA_UInt32 default_interval;
|
|
|
|
+ UA_Guid job_id;
|
|
|
|
+ UA_Job *job;
|
|
|
|
+ UA_UInt32 this_interval;
|
|
|
|
+ const char* discovery_server_url;
|
|
|
|
+};
|
|
|
|
+
|
|
|
|
+/* Called by the UA_Server job. The OPC UA specification says:
|
|
|
|
+ *
|
|
|
|
+ * > If an error occurs during registration (e.g. the Discovery Server is not running) then the Server
|
|
|
|
+ * > must periodically re-attempt registration. The frequency of these attempts should start at 1 second
|
|
|
|
+ * > but gradually increase until the registration frequency is the same as what it would be if not
|
|
|
|
+ * > errors occurred. The recommended approach would double the period each attempt until reaching the maximum.
|
|
|
|
+ *
|
|
|
|
+ * We will do so by using the additional data parameter which holds information
|
|
|
|
+ * if the next interval is default or if it is a repeaded call. */
|
|
|
|
+static void
|
|
|
|
+periodicServerRegister(UA_Server *server, void *data) {
|
|
|
|
+ if(!data) {
|
|
|
|
+ UA_LOG_ERROR(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
|
|
+ "Data parameter must be not NULL for periodic server register");
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
|
|
|
|
+ struct PeriodicServerRegisterJob *retryJob = (struct PeriodicServerRegisterJob *)data;
|
|
|
|
+ if(retryJob->job != NULL) {
|
|
|
|
+ // remove the retry job because we don't want to fire it again.
|
|
|
|
+ UA_Server_removeRepeatedJob(server, retryJob->job_id);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ // fixme: remove magic urls
|
|
|
|
+ const char * server_url;
|
|
|
|
+ if(retryJob->discovery_server_url != NULL)
|
|
|
|
+ server_url = retryJob->discovery_server_url;
|
|
|
|
+ else
|
|
|
|
+ server_url = "opc.tcp://localhost:4840";
|
|
|
|
+ UA_StatusCode retval = UA_Server_register_discovery(server, server_url, NULL);
|
|
|
|
+
|
|
|
|
+ // You can also use a semaphore file. That file must exist. When the file is
|
|
|
|
+ // deleted, the server is automatically unregistered. The semaphore file has
|
|
|
|
+ // to be accessible by the discovery server
|
|
|
|
+ //
|
|
|
|
+ // UA_StatusCode retval = UA_Server_register_discovery(server,
|
|
|
|
+ // "opc.tcp://localhost:4840", "/path/to/some/file");
|
|
|
|
+ if(retval != UA_STATUSCODE_GOOD) {
|
|
|
|
+ UA_LOG_ERROR(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
|
|
+ "Could not register server with discovery server. "
|
|
|
|
+ "Is the discovery server started? StatusCode %s", UA_StatusCode_name(retval));
|
|
|
|
+
|
|
|
|
+ // first retry in 1 second
|
|
|
|
+ UA_UInt32 nextInterval = 1;
|
|
|
|
+
|
|
|
|
+ if (retryJob->job != NULL)
|
|
|
|
+ // double the interval for the next retry
|
|
|
|
+ nextInterval = retryJob->this_interval*2;
|
|
|
|
+
|
|
|
|
+ // as long as next retry is smaller than default interval, retry
|
|
|
|
+ if (nextInterval < retryJob->default_interval) {
|
|
|
|
+ UA_LOG_INFO(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
|
|
+ "Retrying registration in %d seconds", nextInterval);
|
|
|
|
+ // todo: malloc may fail: return a statuscode
|
|
|
|
+ struct PeriodicServerRegisterJob *newRetryJob =
|
|
|
|
+ (struct PeriodicServerRegisterJob *)UA_malloc(sizeof(struct PeriodicServerRegisterJob));
|
|
|
|
+ newRetryJob->job = (UA_Job *)UA_malloc(sizeof(UA_Job));
|
|
|
|
+ newRetryJob->default_interval = retryJob->default_interval;
|
|
|
|
+ newRetryJob->this_interval = nextInterval;
|
|
|
|
+ newRetryJob->discovery_server_url = retryJob->discovery_server_url;
|
|
|
|
+
|
|
|
|
+ newRetryJob->job->type = UA_JOBTYPE_METHODCALL;
|
|
|
|
+ newRetryJob->job->job.methodCall.method = periodicServerRegister;
|
|
|
|
+ newRetryJob->job->job.methodCall.data = newRetryJob;
|
|
|
|
+
|
|
|
|
+ UA_Server_addRepeatedJob(server, *newRetryJob->job,
|
|
|
|
+ nextInterval*1000, &newRetryJob->job_id);
|
|
}
|
|
}
|
|
|
|
+ } else {
|
|
|
|
+ UA_LOG_DEBUG(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
|
|
+ "Server successfully registered. Next periodical register will be in %d seconds",
|
|
|
|
+ (int)(retryJob->default_interval/1000));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if(retryJob->job) {
|
|
|
|
+ UA_free(retryJob->job);
|
|
|
|
+ UA_free(retryJob);
|
|
}
|
|
}
|
|
|
|
+
|
|
}
|
|
}
|
|
|
|
|
|
-#endif
|
|
|
|
|
|
+UA_StatusCode
|
|
|
|
+UA_Server_addPeriodicServerRegisterJob(UA_Server *server,
|
|
|
|
+ const char* discoveryServerUrl,
|
|
|
|
+ const UA_UInt32 intervalMs,
|
|
|
|
+ const UA_UInt32 delayFirstRegisterMs,
|
|
|
|
+ UA_Guid* periodicJobId) {
|
|
|
|
+ if(server->periodicServerRegisterJob != NULL)
|
|
|
|
+ return UA_STATUSCODE_BADINTERNALERROR;
|
|
|
|
+
|
|
|
|
+ // registering the server should be done periodically. Approx. every 10
|
|
|
|
+ // minutes. The first call will be in 10 Minutes.
|
|
|
|
+ UA_Job job;
|
|
|
|
+ job.type = UA_JOBTYPE_METHODCALL;
|
|
|
|
+ job.job.methodCall.method = periodicServerRegister;
|
|
|
|
+ job.job.methodCall.data = NULL;
|
|
|
|
+
|
|
|
|
+ server->periodicServerRegisterJob =
|
|
|
|
+ (struct PeriodicServerRegisterJob *)UA_malloc(sizeof(struct PeriodicServerRegisterJob));
|
|
|
|
+ server->periodicServerRegisterJob->job = NULL;
|
|
|
|
+ server->periodicServerRegisterJob->this_interval = 0;
|
|
|
|
+ server->periodicServerRegisterJob->default_interval = intervalMs;
|
|
|
|
+ server->periodicServerRegisterJob->discovery_server_url = discoveryServerUrl;
|
|
|
|
+ job.job.methodCall.data = server->periodicServerRegisterJob;
|
|
|
|
+
|
|
|
|
+ UA_StatusCode retval =
|
|
|
|
+ UA_Server_addRepeatedJob(server, job,
|
|
|
|
+ intervalMs, &server->periodicServerRegisterJob->job_id);
|
|
|
|
+ if(retval != UA_STATUSCODE_GOOD) {
|
|
|
|
+ UA_LOG_ERROR(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
|
|
+ "Could not create periodic job for server register. "
|
|
|
|
+ "StatusCode %s", UA_StatusCode_name(retval));
|
|
|
|
+ return retval;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if(periodicJobId)
|
|
|
|
+ UA_Guid_copy(&server->periodicServerRegisterJob->job_id, periodicJobId);
|
|
|
|
+
|
|
|
|
+ if(delayFirstRegisterMs > 0) {
|
|
|
|
+ // Register the server with the discovery server.
|
|
|
|
+ // Delay this first registration until the server is fully initialized
|
|
|
|
+ // will be freed in the callback
|
|
|
|
+ // todo: malloc may fail: return a statuscode
|
|
|
|
+ struct PeriodicServerRegisterJob *newRetryJob =
|
|
|
|
+ (struct PeriodicServerRegisterJob *)UA_malloc(sizeof(struct PeriodicServerRegisterJob));
|
|
|
|
+ newRetryJob->job = (UA_Job*)UA_malloc(sizeof(UA_Job));
|
|
|
|
+ newRetryJob->this_interval = 1;
|
|
|
|
+ newRetryJob->default_interval = intervalMs;
|
|
|
|
+ newRetryJob->job->type = UA_JOBTYPE_METHODCALL;
|
|
|
|
+ newRetryJob->job->job.methodCall.method = periodicServerRegister;
|
|
|
|
+ newRetryJob->job->job.methodCall.data = newRetryJob;
|
|
|
|
+ newRetryJob->discovery_server_url = discoveryServerUrl;
|
|
|
|
+ retval = UA_Server_addRepeatedJob(server, *newRetryJob->job,
|
|
|
|
+ delayFirstRegisterMs, &newRetryJob->job_id);
|
|
|
|
+ if (retval != UA_STATUSCODE_GOOD) {
|
|
|
|
+ UA_LOG_ERROR(server->config.logger, UA_LOGCATEGORY_SERVER,
|
|
|
|
+ "Could not create first job for server register. "
|
|
|
|
+ "StatusCode %s", UA_StatusCode_name(retval));
|
|
|
|
+ return retval;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ return UA_STATUSCODE_GOOD;
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+void
|
|
|
|
+UA_Server_setRegisterServerCallback(UA_Server *server, UA_Server_registerServerCallback cb,
|
|
|
|
+ void* data) {
|
|
|
|
+ server->registerServerCallback = cb;
|
|
|
|
+ server->registerServerCallbackData = data;
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+#endif // UA_ENABLE_DISCOVERY
|