ua_services_view.c 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616
  1. /* This Source Code Form is subject to the terms of the Mozilla Public
  2. * License, v. 2.0. If a copy of the MPL was not distributed with this
  3. * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
  4. #include "ua_server_internal.h"
  5. #include "ua_services.h"
  6. static UA_StatusCode
  7. fillReferenceDescription(UA_NodeStore *ns, const UA_Node *curr, UA_ReferenceNode *ref,
  8. UA_UInt32 mask, UA_ReferenceDescription *descr) {
  9. UA_ReferenceDescription_init(descr);
  10. UA_StatusCode retval = UA_NodeId_copy(&curr->nodeId, &descr->nodeId.nodeId);
  11. if(mask & UA_BROWSERESULTMASK_REFERENCETYPEID)
  12. retval |= UA_NodeId_copy(&ref->referenceTypeId, &descr->referenceTypeId);
  13. if(mask & UA_BROWSERESULTMASK_ISFORWARD)
  14. descr->isForward = !ref->isInverse;
  15. if(mask & UA_BROWSERESULTMASK_NODECLASS)
  16. retval |= UA_NodeClass_copy(&curr->nodeClass, &descr->nodeClass);
  17. if(mask & UA_BROWSERESULTMASK_BROWSENAME)
  18. retval |= UA_QualifiedName_copy(&curr->browseName, &descr->browseName);
  19. if(mask & UA_BROWSERESULTMASK_DISPLAYNAME)
  20. retval |= UA_LocalizedText_copy(&curr->displayName, &descr->displayName);
  21. if(mask & UA_BROWSERESULTMASK_TYPEDEFINITION){
  22. if(curr->nodeClass == UA_NODECLASS_OBJECT || curr->nodeClass == UA_NODECLASS_VARIABLE) {
  23. for(size_t i = 0; i < curr->referencesSize; ++i) {
  24. UA_ReferenceNode *refnode = &curr->references[i];
  25. if(refnode->referenceTypeId.identifier.numeric == UA_NS0ID_HASTYPEDEFINITION) {
  26. retval |= UA_ExpandedNodeId_copy(&refnode->targetId, &descr->typeDefinition);
  27. break;
  28. }
  29. }
  30. }
  31. }
  32. return retval;
  33. }
  34. #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
  35. static const UA_Node *
  36. returnRelevantNodeExternal(UA_ExternalNodeStore *ens, const UA_BrowseDescription *descr,
  37. const UA_ReferenceNode *reference) {
  38. /* prepare a read request in the external nodestore */
  39. UA_ReadValueId *readValueIds = UA_Array_new(6,&UA_TYPES[UA_TYPES_READVALUEID]);
  40. UA_UInt32 *indices = UA_Array_new(6,&UA_TYPES[UA_TYPES_UINT32]);
  41. UA_UInt32 indicesSize = 6;
  42. UA_DataValue *readNodesResults = UA_Array_new(6,&UA_TYPES[UA_TYPES_DATAVALUE]);
  43. UA_DiagnosticInfo *diagnosticInfos = UA_Array_new(6,&UA_TYPES[UA_TYPES_DIAGNOSTICINFO]);
  44. for(UA_UInt32 i = 0; i < 6; ++i) {
  45. readValueIds[i].nodeId = reference->targetId.nodeId;
  46. indices[i] = i;
  47. }
  48. readValueIds[0].attributeId = UA_ATTRIBUTEID_NODECLASS;
  49. readValueIds[1].attributeId = UA_ATTRIBUTEID_BROWSENAME;
  50. readValueIds[2].attributeId = UA_ATTRIBUTEID_DISPLAYNAME;
  51. readValueIds[3].attributeId = UA_ATTRIBUTEID_DESCRIPTION;
  52. readValueIds[4].attributeId = UA_ATTRIBUTEID_WRITEMASK;
  53. readValueIds[5].attributeId = UA_ATTRIBUTEID_USERWRITEMASK;
  54. ens->readNodes(ens->ensHandle, NULL, readValueIds, indices,
  55. indicesSize, readNodesResults, false, diagnosticInfos);
  56. /* create and fill a dummy nodeStructure */
  57. UA_Node *node = (UA_Node*) UA_NodeStore_newObjectNode();
  58. UA_NodeId_copy(&(reference->targetId.nodeId), &(node->nodeId));
  59. if(readNodesResults[0].status == UA_STATUSCODE_GOOD)
  60. UA_NodeClass_copy((UA_NodeClass*)readNodesResults[0].value.data, &(node->nodeClass));
  61. if(readNodesResults[1].status == UA_STATUSCODE_GOOD)
  62. UA_QualifiedName_copy((UA_QualifiedName*)readNodesResults[1].value.data, &(node->browseName));
  63. if(readNodesResults[2].status == UA_STATUSCODE_GOOD)
  64. UA_LocalizedText_copy((UA_LocalizedText*)readNodesResults[2].value.data, &(node->displayName));
  65. if(readNodesResults[3].status == UA_STATUSCODE_GOOD)
  66. UA_LocalizedText_copy((UA_LocalizedText*)readNodesResults[3].value.data, &(node->description));
  67. if(readNodesResults[4].status == UA_STATUSCODE_GOOD)
  68. UA_UInt32_copy((UA_UInt32*)readNodesResults[4].value.data, &(node->writeMask));
  69. if(readNodesResults[5].status == UA_STATUSCODE_GOOD)
  70. UA_UInt32_copy((UA_UInt32*)readNodesResults[5].value.data, &(node->userWriteMask));
  71. UA_Array_delete(readValueIds,6, &UA_TYPES[UA_TYPES_READVALUEID]);
  72. UA_Array_delete(indices,6, &UA_TYPES[UA_TYPES_UINT32]);
  73. UA_Array_delete(readNodesResults,6, &UA_TYPES[UA_TYPES_DATAVALUE]);
  74. UA_Array_delete(diagnosticInfos,6, &UA_TYPES[UA_TYPES_DIAGNOSTICINFO]);
  75. if(node && descr->nodeClassMask != 0 && (node->nodeClass & descr->nodeClassMask) == 0) {
  76. UA_NodeStore_deleteNode(node);
  77. return NULL;
  78. }
  79. return node;
  80. }
  81. #endif
  82. /* Tests if the node is relevant to the browse request and shall be returned. If
  83. so, it is retrieved from the Nodestore. If not, null is returned. */
  84. static const UA_Node *
  85. returnRelevantNode(UA_Server *server, const UA_BrowseDescription *descr, UA_Boolean return_all,
  86. const UA_ReferenceNode *reference, const UA_NodeId *relevant, size_t relevant_count,
  87. UA_Boolean *isExternal) {
  88. /* reference in the right direction? */
  89. if(reference->isInverse && descr->browseDirection == UA_BROWSEDIRECTION_FORWARD)
  90. return NULL;
  91. if(!reference->isInverse && descr->browseDirection == UA_BROWSEDIRECTION_INVERSE)
  92. return NULL;
  93. /* is the reference part of the hierarchy of references we look for? */
  94. if(!return_all) {
  95. UA_Boolean is_relevant = false;
  96. for(size_t i = 0; i < relevant_count; ++i) {
  97. if(UA_NodeId_equal(&reference->referenceTypeId, &relevant[i])) {
  98. is_relevant = true;
  99. break;
  100. }
  101. }
  102. if(!is_relevant)
  103. return NULL;
  104. }
  105. #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
  106. /* return the node from an external namespace*/
  107. for(size_t nsIndex = 0; nsIndex < server->externalNamespacesSize; ++nsIndex) {
  108. if(reference->targetId.nodeId.namespaceIndex != server->externalNamespaces[nsIndex].index)
  109. continue;
  110. *isExternal = true;
  111. return returnRelevantNodeExternal(&server->externalNamespaces[nsIndex].externalNodeStore,
  112. descr, reference);
  113. }
  114. #endif
  115. /* return from the internal nodestore */
  116. const UA_Node *node = UA_NodeStore_get(server->nodestore, &reference->targetId.nodeId);
  117. if(node && descr->nodeClassMask != 0 && (node->nodeClass & descr->nodeClassMask) == 0)
  118. return NULL;
  119. *isExternal = false;
  120. return node;
  121. }
  122. static void removeCp(struct ContinuationPointEntry *cp, UA_Session* session) {
  123. LIST_REMOVE(cp, pointers);
  124. UA_ByteString_deleteMembers(&cp->identifier);
  125. UA_BrowseDescription_deleteMembers(&cp->browseDescription);
  126. UA_free(cp);
  127. ++session->availableContinuationPoints;
  128. }
  129. /* Results for a single browsedescription. This is the inner loop for both
  130. * Browse and BrowseNext
  131. *
  132. * @param session Session to save continuationpoints
  133. * @param ns The nodstore where the to-be-browsed node can be found
  134. * @param cp If cp is not null, we continue from here If cp is null, we can add
  135. * a new continuation point if possible and necessary.
  136. * @param descr If no cp is set, we take the browsedescription from there
  137. * @param maxrefs The maximum number of references the client has requested. If 0,
  138. * all matching references are returned at once.
  139. * @param result The entry in the request */
  140. void
  141. Service_Browse_single(UA_Server *server, UA_Session *session,
  142. struct ContinuationPointEntry *cp, const UA_BrowseDescription *descr,
  143. UA_UInt32 maxrefs, UA_BrowseResult *result) {
  144. /* TODO: Split this function and remove goto */
  145. size_t referencesCount = 0;
  146. size_t referencesIndex = 0;
  147. /* set the browsedescription if a cp is given */
  148. UA_UInt32 continuationIndex = 0;
  149. if(cp) {
  150. descr = &cp->browseDescription;
  151. maxrefs = cp->maxReferences;
  152. continuationIndex = cp->continuationIndex;
  153. }
  154. /* is the browsedirection valid? */
  155. if(descr->browseDirection != UA_BROWSEDIRECTION_BOTH &&
  156. descr->browseDirection != UA_BROWSEDIRECTION_FORWARD &&
  157. descr->browseDirection != UA_BROWSEDIRECTION_INVERSE) {
  158. result->statusCode = UA_STATUSCODE_BADBROWSEDIRECTIONINVALID;
  159. return;
  160. }
  161. /* get the references that match the browsedescription */
  162. size_t relevant_refs_size = 0;
  163. UA_NodeId *relevant_refs = NULL;
  164. UA_Boolean all_refs = UA_NodeId_isNull(&descr->referenceTypeId);
  165. if(!all_refs) {
  166. const UA_Node *rootRef = UA_NodeStore_get(server->nodestore, &descr->referenceTypeId);
  167. if(!rootRef || rootRef->nodeClass != UA_NODECLASS_REFERENCETYPE) {
  168. result->statusCode = UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  169. return;
  170. }
  171. if(descr->includeSubtypes) {
  172. result->statusCode = getTypeHierarchy(server->nodestore, rootRef, false,
  173. &relevant_refs, &relevant_refs_size);
  174. if(result->statusCode != UA_STATUSCODE_GOOD)
  175. return;
  176. } else {
  177. relevant_refs = (UA_NodeId*)(uintptr_t)&descr->referenceTypeId;
  178. relevant_refs_size = 1;
  179. }
  180. }
  181. /* get the node */
  182. const UA_Node *node = UA_NodeStore_get(server->nodestore, &descr->nodeId);
  183. if(!node) {
  184. result->statusCode = UA_STATUSCODE_BADNODEIDUNKNOWN;
  185. if(!all_refs && descr->includeSubtypes)
  186. UA_Array_delete(relevant_refs, relevant_refs_size, &UA_TYPES[UA_TYPES_NODEID]);
  187. return;
  188. }
  189. /* if the node has no references, just return */
  190. if(node->referencesSize == 0) {
  191. result->referencesSize = 0;
  192. if(!all_refs && descr->includeSubtypes)
  193. UA_Array_delete(relevant_refs, relevant_refs_size, &UA_TYPES[UA_TYPES_NODEID]);
  194. return;
  195. }
  196. /* Forward declare for goto */
  197. size_t skipped = 0;
  198. UA_Boolean isExternal = false;
  199. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  200. /* how many references can we return at most? */
  201. size_t real_maxrefs = maxrefs;
  202. if(real_maxrefs == 0)
  203. real_maxrefs = node->referencesSize;
  204. else if(real_maxrefs > node->referencesSize)
  205. real_maxrefs = node->referencesSize;
  206. result->references = (UA_ReferenceDescription *)UA_Array_new(real_maxrefs, &UA_TYPES[UA_TYPES_REFERENCEDESCRIPTION]);
  207. if(!result->references) {
  208. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  209. goto cleanup;
  210. }
  211. /* loop over the node's references */
  212. for(; referencesIndex < node->referencesSize && referencesCount < real_maxrefs; ++referencesIndex) {
  213. isExternal = false;
  214. const UA_Node *current =
  215. returnRelevantNode(server, descr, all_refs, &node->references[referencesIndex],
  216. relevant_refs, relevant_refs_size, &isExternal);
  217. if(!current)
  218. continue;
  219. if(skipped < continuationIndex) {
  220. ++skipped;
  221. } else {
  222. retval |= fillReferenceDescription(server->nodestore, current,
  223. &node->references[referencesIndex],
  224. descr->resultMask,
  225. &result->references[referencesCount]);
  226. ++referencesCount;
  227. }
  228. }
  229. result->referencesSize = referencesCount;
  230. if(referencesCount == 0) {
  231. UA_free(result->references);
  232. result->references = NULL;
  233. result->referencesSize = 0;
  234. }
  235. if(retval != UA_STATUSCODE_GOOD) {
  236. UA_Array_delete(result->references, result->referencesSize,
  237. &UA_TYPES[UA_TYPES_REFERENCEDESCRIPTION]);
  238. result->references = NULL;
  239. result->referencesSize = 0;
  240. result->statusCode = retval;
  241. }
  242. cleanup:
  243. if(!all_refs && descr->includeSubtypes)
  244. UA_Array_delete(relevant_refs, relevant_refs_size, &UA_TYPES[UA_TYPES_NODEID]);
  245. if(result->statusCode != UA_STATUSCODE_GOOD)
  246. return;
  247. /* create, update, delete continuation points */
  248. if(cp) {
  249. if(referencesIndex == node->referencesSize) {
  250. /* all done, remove a finished continuationPoint */
  251. removeCp(cp, session);
  252. } else {
  253. /* update the cp and return the cp identifier */
  254. cp->continuationIndex += (UA_UInt32)referencesCount;
  255. UA_ByteString_copy(&cp->identifier, &result->continuationPoint);
  256. }
  257. } else if(maxrefs != 0 && referencesCount >= maxrefs) {
  258. /* create a cp */
  259. if(session->availableContinuationPoints <= 0 ||
  260. !(cp = (struct ContinuationPointEntry *)UA_malloc(sizeof(struct ContinuationPointEntry)))) {
  261. result->statusCode = UA_STATUSCODE_BADNOCONTINUATIONPOINTS;
  262. return;
  263. }
  264. UA_BrowseDescription_copy(descr, &cp->browseDescription);
  265. cp->maxReferences = maxrefs;
  266. cp->continuationIndex = (UA_UInt32)referencesCount;
  267. UA_Guid *ident = UA_Guid_new();
  268. *ident = UA_Guid_random();
  269. cp->identifier.data = (UA_Byte*)ident;
  270. cp->identifier.length = sizeof(UA_Guid);
  271. UA_ByteString_copy(&cp->identifier, &result->continuationPoint);
  272. /* store the cp */
  273. LIST_INSERT_HEAD(&session->continuationPoints, cp, pointers);
  274. --session->availableContinuationPoints;
  275. }
  276. }
  277. void Service_Browse(UA_Server *server, UA_Session *session, const UA_BrowseRequest *request,
  278. UA_BrowseResponse *response) {
  279. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing BrowseRequest");
  280. if(!UA_NodeId_isNull(&request->view.viewId)) {
  281. response->responseHeader.serviceResult = UA_STATUSCODE_BADVIEWIDUNKNOWN;
  282. return;
  283. }
  284. if(request->nodesToBrowseSize <= 0) {
  285. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  286. return;
  287. }
  288. size_t size = request->nodesToBrowseSize;
  289. response->results = (UA_BrowseResult *)UA_Array_new(size, &UA_TYPES[UA_TYPES_BROWSERESULT]);
  290. if(!response->results) {
  291. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  292. return;
  293. }
  294. response->resultsSize = size;
  295. #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
  296. #ifdef NO_ALLOCA
  297. UA_Boolean isExternal[size];
  298. UA_UInt32 indices[size];
  299. #else
  300. UA_Boolean *isExternal = UA_alloca(sizeof(UA_Boolean) * size);
  301. UA_UInt32 *indices = UA_alloca(sizeof(UA_UInt32) * size);
  302. #endif /*NO_ALLOCA */
  303. memset(isExternal, false, sizeof(UA_Boolean) * size);
  304. for(size_t j = 0; j < server->externalNamespacesSize; ++j) {
  305. size_t indexSize = 0;
  306. for(size_t i = 0; i < size; ++i) {
  307. if(request->nodesToBrowse[i].nodeId.namespaceIndex != server->externalNamespaces[j].index)
  308. continue;
  309. isExternal[i] = true;
  310. indices[indexSize] = (UA_UInt32)i;
  311. ++indexSize;
  312. }
  313. if(indexSize == 0)
  314. continue;
  315. UA_ExternalNodeStore *ens = &server->externalNamespaces[j].externalNodeStore;
  316. ens->browseNodes(ens->ensHandle, &request->requestHeader, request->nodesToBrowse, indices,
  317. (UA_UInt32)indexSize, request->requestedMaxReferencesPerNode,
  318. response->results, response->diagnosticInfos);
  319. }
  320. #endif
  321. for(size_t i = 0; i < size; ++i) {
  322. #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
  323. if(!isExternal[i])
  324. #endif
  325. Service_Browse_single(server, session, NULL, &request->nodesToBrowse[i],
  326. request->requestedMaxReferencesPerNode, &response->results[i]);
  327. }
  328. }
  329. UA_BrowseResult
  330. UA_Server_browse(UA_Server *server, UA_UInt32 maxrefs, const UA_BrowseDescription *descr) {
  331. UA_BrowseResult result;
  332. UA_BrowseResult_init(&result);
  333. UA_RCU_LOCK();
  334. Service_Browse_single(server, &adminSession, NULL, descr, maxrefs, &result);
  335. UA_RCU_UNLOCK();
  336. return result;
  337. }
  338. static void
  339. UA_Server_browseNext_single(UA_Server *server, UA_Session *session, UA_Boolean releaseContinuationPoint,
  340. const UA_ByteString *continuationPoint, UA_BrowseResult *result) {
  341. result->statusCode = UA_STATUSCODE_BADCONTINUATIONPOINTINVALID;
  342. struct ContinuationPointEntry *cp, *temp;
  343. LIST_FOREACH_SAFE(cp, &session->continuationPoints, pointers, temp) {
  344. if(UA_ByteString_equal(&cp->identifier, continuationPoint)) {
  345. result->statusCode = UA_STATUSCODE_GOOD;
  346. if(!releaseContinuationPoint)
  347. Service_Browse_single(server, session, cp, NULL, 0, result);
  348. else
  349. removeCp(cp, session);
  350. break;
  351. }
  352. }
  353. }
  354. void Service_BrowseNext(UA_Server *server, UA_Session *session, const UA_BrowseNextRequest *request,
  355. UA_BrowseNextResponse *response) {
  356. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing BrowseNextRequest");
  357. if(request->continuationPointsSize <= 0) {
  358. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  359. return;
  360. }
  361. size_t size = request->continuationPointsSize;
  362. response->results = (UA_BrowseResult *)UA_Array_new(size, &UA_TYPES[UA_TYPES_BROWSERESULT]);
  363. if(!response->results) {
  364. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  365. return;
  366. }
  367. response->resultsSize = size;
  368. for(size_t i = 0; i < size; ++i)
  369. UA_Server_browseNext_single(server, session, request->releaseContinuationPoints,
  370. &request->continuationPoints[i], &response->results[i]);
  371. }
  372. UA_BrowseResult
  373. UA_Server_browseNext(UA_Server *server, UA_Boolean releaseContinuationPoint,
  374. const UA_ByteString *continuationPoint) {
  375. UA_BrowseResult result;
  376. UA_BrowseResult_init(&result);
  377. UA_RCU_LOCK();
  378. UA_Server_browseNext_single(server, &adminSession, releaseContinuationPoint,
  379. continuationPoint, &result);
  380. UA_RCU_UNLOCK();
  381. return result;
  382. }
  383. /***********************/
  384. /* TranslateBrowsePath */
  385. /***********************/
  386. static UA_StatusCode
  387. walkBrowsePath(UA_Server *server, UA_Session *session, const UA_Node *node, const UA_RelativePath *path,
  388. size_t pathindex, UA_BrowsePathTarget **targets, size_t *targets_size,
  389. size_t *target_count) {
  390. const UA_RelativePathElement *elem = &path->elements[pathindex];
  391. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  392. UA_NodeId *reftypes = NULL;
  393. size_t reftypes_count = 1; // all_refs or no subtypes => 1
  394. UA_Boolean all_refs = false;
  395. if(UA_NodeId_isNull(&elem->referenceTypeId)) {
  396. all_refs = true;
  397. } else if(!elem->includeSubtypes) {
  398. reftypes = (UA_NodeId*)(uintptr_t)&elem->referenceTypeId; // ptr magic due to const cast
  399. } else {
  400. const UA_Node *rootRef = UA_NodeStore_get(server->nodestore, &elem->referenceTypeId);
  401. if(!rootRef || rootRef->nodeClass != UA_NODECLASS_REFERENCETYPE)
  402. return UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  403. retval = getTypeHierarchy(server->nodestore, rootRef, false, &reftypes, &reftypes_count);
  404. if(retval != UA_STATUSCODE_GOOD)
  405. return retval;
  406. }
  407. for(size_t i = 0; i < node->referencesSize && retval == UA_STATUSCODE_GOOD; ++i) {
  408. UA_Boolean match = all_refs;
  409. for(size_t j = 0; j < reftypes_count && !match; ++j) {
  410. if(node->references[i].isInverse == elem->isInverse &&
  411. UA_NodeId_equal(&node->references[i].referenceTypeId, &reftypes[j]))
  412. match = true;
  413. }
  414. if(!match)
  415. continue;
  416. // get the node, todo: expandednodeid
  417. const UA_Node *next = UA_NodeStore_get(server->nodestore, &node->references[i].targetId.nodeId);
  418. if(!next)
  419. continue;
  420. // test the browsename
  421. if(elem->targetName.namespaceIndex != next->browseName.namespaceIndex ||
  422. !UA_String_equal(&elem->targetName.name, &next->browseName.name)) {
  423. continue;
  424. }
  425. if(pathindex + 1 < path->elementsSize) {
  426. // recursion if the path is longer
  427. retval = walkBrowsePath(server, session, next, path, pathindex + 1,
  428. targets, targets_size, target_count);
  429. } else {
  430. // add the browsetarget
  431. if(*target_count >= *targets_size) {
  432. UA_BrowsePathTarget *newtargets;
  433. newtargets = (UA_BrowsePathTarget *)UA_realloc(targets, sizeof(UA_BrowsePathTarget) * (*targets_size) * 2);
  434. if(!newtargets) {
  435. retval = UA_STATUSCODE_BADOUTOFMEMORY;
  436. break;
  437. }
  438. *targets = newtargets;
  439. *targets_size *= 2;
  440. }
  441. UA_BrowsePathTarget *res = *targets;
  442. UA_ExpandedNodeId_init(&res[*target_count].targetId);
  443. retval = UA_NodeId_copy(&next->nodeId, &res[*target_count].targetId.nodeId);
  444. if(retval != UA_STATUSCODE_GOOD)
  445. break;
  446. res[*target_count].remainingPathIndex = UA_UINT32_MAX;
  447. *target_count += 1;
  448. }
  449. }
  450. if(!all_refs && elem->includeSubtypes)
  451. UA_Array_delete(reftypes, reftypes_count, &UA_TYPES[UA_TYPES_NODEID]);
  452. return retval;
  453. }
  454. void Service_TranslateBrowsePathsToNodeIds_single(UA_Server *server, UA_Session *session,
  455. const UA_BrowsePath *path, UA_BrowsePathResult *result) {
  456. if(path->relativePath.elementsSize <= 0) {
  457. result->statusCode = UA_STATUSCODE_BADNOTHINGTODO;
  458. return;
  459. }
  460. //relativePath elements should not have an empty targetName
  461. for(size_t i=0;i<path->relativePath.elementsSize;++i){
  462. UA_QualifiedName *qname = &(path->relativePath.elements[i].targetName);
  463. if(UA_QualifiedName_isNull(qname)){
  464. result->statusCode = UA_STATUSCODE_BADBROWSENAMEINVALID;
  465. return;
  466. }
  467. }
  468. size_t arraySize = 10;
  469. result->targets = (UA_BrowsePathTarget *)UA_malloc(sizeof(UA_BrowsePathTarget) * arraySize);
  470. if(!result->targets) {
  471. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  472. return;
  473. }
  474. result->targetsSize = 0;
  475. const UA_Node *firstNode = UA_NodeStore_get(server->nodestore, &path->startingNode);
  476. if(!firstNode) {
  477. result->statusCode = UA_STATUSCODE_BADNODEIDUNKNOWN;
  478. UA_free(result->targets);
  479. result->targets = NULL;
  480. return;
  481. }
  482. result->statusCode = walkBrowsePath(server, session, firstNode, &path->relativePath, 0,
  483. &result->targets, &arraySize, &result->targetsSize);
  484. if(result->targetsSize == 0 && result->statusCode == UA_STATUSCODE_GOOD)
  485. result->statusCode = UA_STATUSCODE_BADNOMATCH;
  486. if(result->statusCode != UA_STATUSCODE_GOOD) {
  487. UA_Array_delete(result->targets, result->targetsSize, &UA_TYPES[UA_TYPES_BROWSEPATHTARGET]);
  488. result->targets = NULL;
  489. result->targetsSize = 0;
  490. }
  491. }
  492. void Service_TranslateBrowsePathsToNodeIds(UA_Server *server, UA_Session *session,
  493. const UA_TranslateBrowsePathsToNodeIdsRequest *request,
  494. UA_TranslateBrowsePathsToNodeIdsResponse *response) {
  495. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing TranslateBrowsePathsToNodeIdsRequest");
  496. if(request->browsePathsSize <= 0) {
  497. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  498. return;
  499. }
  500. size_t size = request->browsePathsSize;
  501. response->results = (UA_BrowsePathResult *)UA_Array_new(size, &UA_TYPES[UA_TYPES_BROWSEPATHRESULT]);
  502. if(!response->results) {
  503. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  504. return;
  505. }
  506. #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
  507. #ifdef NO_ALLOCA
  508. UA_Boolean isExternal[size];
  509. UA_UInt32 indices[size];
  510. #else
  511. UA_Boolean *isExternal = UA_alloca(sizeof(UA_Boolean) * size);
  512. UA_UInt32 *indices = UA_alloca(sizeof(UA_UInt32) * size);
  513. #endif /* NO_ALLOCA */
  514. memset(isExternal, false, sizeof(UA_Boolean) * size);
  515. for(size_t j = 0; j < server->externalNamespacesSize; ++j) {
  516. size_t indexSize = 0;
  517. for(size_t i = 0;i < size;++i) {
  518. if(request->browsePaths[i].startingNode.namespaceIndex != server->externalNamespaces[j].index)
  519. continue;
  520. isExternal[i] = true;
  521. indices[indexSize] = (UA_UInt32)i;
  522. ++indexSize;
  523. }
  524. if(indexSize == 0)
  525. continue;
  526. UA_ExternalNodeStore *ens = &server->externalNamespaces[j].externalNodeStore;
  527. ens->translateBrowsePathsToNodeIds(ens->ensHandle, &request->requestHeader, request->browsePaths,
  528. indices, (UA_UInt32)indexSize, response->results,
  529. response->diagnosticInfos);
  530. }
  531. #endif
  532. response->resultsSize = size;
  533. for(size_t i = 0; i < size; ++i) {
  534. #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
  535. if(!isExternal[i])
  536. #endif
  537. Service_TranslateBrowsePathsToNodeIds_single(server, session, &request->browsePaths[i],
  538. &response->results[i]);
  539. }
  540. }
  541. void Service_RegisterNodes(UA_Server *server, UA_Session *session, const UA_RegisterNodesRequest *request,
  542. UA_RegisterNodesResponse *response) {
  543. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing RegisterNodesRequest");
  544. //TODO: hang the nodeids to the session if really needed
  545. response->responseHeader.timestamp = UA_DateTime_now();
  546. if(request->nodesToRegisterSize <= 0)
  547. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  548. else {
  549. response->responseHeader.serviceResult =
  550. UA_Array_copy(request->nodesToRegister, request->nodesToRegisterSize,
  551. (void**)&response->registeredNodeIds, &UA_TYPES[UA_TYPES_NODEID]);
  552. if(response->responseHeader.serviceResult == UA_STATUSCODE_GOOD)
  553. response->registeredNodeIdsSize = request->nodesToRegisterSize;
  554. }
  555. }
  556. void Service_UnregisterNodes(UA_Server *server, UA_Session *session, const UA_UnregisterNodesRequest *request,
  557. UA_UnregisterNodesResponse *response) {
  558. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing UnRegisterNodesRequest");
  559. //TODO: remove the nodeids from the session if really needed
  560. response->responseHeader.timestamp = UA_DateTime_now();
  561. if(request->nodesToUnregisterSize==0)
  562. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  563. }