ua_services_discovery.c 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. #include "ua_server_internal.h"
  2. #include "ua_services.h"
  3. #include "ua_util.h"
  4. void Service_FindServers(UA_Server *server, UA_Session *session,
  5. const UA_FindServersRequest *request, UA_FindServersResponse *response) {
  6. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing FindServersRequest");
  7. /* copy ApplicationDescription from the config */
  8. UA_ApplicationDescription *descr = UA_malloc(sizeof(UA_ApplicationDescription));
  9. if(!descr) {
  10. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  11. return;
  12. }
  13. response->responseHeader.serviceResult =
  14. UA_ApplicationDescription_copy(&server->config.applicationDescription, descr);
  15. if(response->responseHeader.serviceResult != UA_STATUSCODE_GOOD) {
  16. UA_free(descr);
  17. return;
  18. }
  19. /* add the discoveryUrls from the networklayers */
  20. UA_String *disc = UA_realloc(descr->discoveryUrls, sizeof(UA_String) *
  21. (descr->discoveryUrlsSize + server->config.networkLayersSize));
  22. if(!disc) {
  23. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  24. UA_ApplicationDescription_delete(descr);
  25. return;
  26. }
  27. size_t existing = descr->discoveryUrlsSize;
  28. descr->discoveryUrls = disc;
  29. descr->discoveryUrlsSize += server->config.networkLayersSize;
  30. // TODO: Add nl only if discoveryUrl not already present
  31. for(size_t i = 0; i < server->config.networkLayersSize; i++) {
  32. UA_ServerNetworkLayer *nl = &server->config.networkLayers[i];
  33. UA_String_copy(&nl->discoveryUrl, &descr->discoveryUrls[existing + i]);
  34. }
  35. response->servers = descr;
  36. response->serversSize = 1;
  37. }
  38. void Service_GetEndpoints(UA_Server *server, UA_Session *session, const UA_GetEndpointsRequest *request,
  39. UA_GetEndpointsResponse *response) {
  40. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing GetEndpointsRequest");
  41. /* Test if one of the networklayers exposes the discoveryUrl of the requested endpoint */
  42. /* Disabled, servers in a virtualbox don't know their external hostname */
  43. /* UA_Boolean foundUri = false; */
  44. /* for(size_t i = 0; i < server->config.networkLayersSize; i++) { */
  45. /* if(UA_String_equal(&request->endpointUrl, &server->config.networkLayers[i].discoveryUrl)) { */
  46. /* foundUri = true; */
  47. /* break; */
  48. /* } */
  49. /* } */
  50. /* if(!foundUri) { */
  51. /* response->endpointsSize = 0; */
  52. /* return; */
  53. /* } */
  54. /* test if the supported binary profile shall be returned */
  55. #ifdef NO_ALLOCA
  56. UA_Boolean relevant_endpoints[server->endpointDescriptionsSize];
  57. #else
  58. UA_Boolean *relevant_endpoints = UA_alloca(sizeof(UA_Byte) * server->endpointDescriptionsSize);
  59. #endif
  60. size_t relevant_count = 0;
  61. for(size_t j = 0; j < server->endpointDescriptionsSize; j++) {
  62. relevant_endpoints[j] = false;
  63. if(request->profileUrisSize == 0) {
  64. relevant_endpoints[j] = true;
  65. relevant_count++;
  66. continue;
  67. }
  68. for(size_t i = 0; i < request->profileUrisSize; i++) {
  69. if(UA_String_equal(&request->profileUris[i], &server->endpointDescriptions->transportProfileUri)) {
  70. relevant_endpoints[j] = true;
  71. relevant_count++;
  72. break;
  73. }
  74. }
  75. }
  76. if(relevant_count == 0) {
  77. response->endpointsSize = 0;
  78. return;
  79. }
  80. response->endpoints = UA_malloc(sizeof(UA_EndpointDescription) * relevant_count);
  81. if(!response->endpoints) {
  82. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  83. return;
  84. }
  85. size_t k = 0;
  86. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  87. for(size_t j = 0; j < server->endpointDescriptionsSize && retval == UA_STATUSCODE_GOOD; j++) {
  88. if(!relevant_endpoints[j])
  89. continue;
  90. retval = UA_EndpointDescription_copy(&server->endpointDescriptions[j], &response->endpoints[k]);
  91. if(retval != UA_STATUSCODE_GOOD)
  92. break;
  93. UA_String_deleteMembers(&response->endpoints[k].endpointUrl);
  94. retval = UA_String_copy(&request->endpointUrl, &response->endpoints[k].endpointUrl);
  95. k++;
  96. }
  97. if(retval != UA_STATUSCODE_GOOD) {
  98. response->responseHeader.serviceResult = retval;
  99. UA_Array_delete(response->endpoints, --k, &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION]);
  100. return;
  101. }
  102. response->endpointsSize = relevant_count;
  103. }