ua_services_view.c 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674
  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. /* Tests if the node is relevant to the browse request and shall be returned. If
  35. so, it is retrieved from the Nodestore. If not, null is returned. */
  36. static const UA_Node *
  37. returnRelevantNode(UA_Server *server, const UA_BrowseDescription *descr, UA_Boolean return_all,
  38. const UA_ReferenceNode *reference, const UA_NodeId *relevant, size_t relevant_count,
  39. UA_Boolean *isExternal) {
  40. /* reference in the right direction? */
  41. if(reference->isInverse && descr->browseDirection == UA_BROWSEDIRECTION_FORWARD)
  42. return NULL;
  43. if(!reference->isInverse && descr->browseDirection == UA_BROWSEDIRECTION_INVERSE)
  44. return NULL;
  45. /* is the reference part of the hierarchy of references we look for? */
  46. if(!return_all) {
  47. UA_Boolean is_relevant = false;
  48. for(size_t i = 0; i < relevant_count; ++i) {
  49. if(UA_NodeId_equal(&reference->referenceTypeId, &relevant[i])) {
  50. is_relevant = true;
  51. break;
  52. }
  53. }
  54. if(!is_relevant)
  55. return NULL;
  56. }
  57. /* return from the internal nodestore */
  58. const UA_Node *node = UA_NodeStore_get(server->nodestore, &reference->targetId.nodeId);
  59. if(node && descr->nodeClassMask != 0 && (node->nodeClass & descr->nodeClassMask) == 0)
  60. return NULL;
  61. *isExternal = false;
  62. return node;
  63. }
  64. static void removeCp(struct ContinuationPointEntry *cp, UA_Session* session) {
  65. LIST_REMOVE(cp, pointers);
  66. UA_ByteString_deleteMembers(&cp->identifier);
  67. UA_BrowseDescription_deleteMembers(&cp->browseDescription);
  68. UA_free(cp);
  69. ++session->availableContinuationPoints;
  70. }
  71. /* Results for a single browsedescription. This is the inner loop for both
  72. * Browse and BrowseNext
  73. *
  74. * @param session Session to save continuationpoints
  75. * @param ns The nodstore where the to-be-browsed node can be found
  76. * @param cp If cp is not null, we continue from here If cp is null, we can add
  77. * a new continuation point if possible and necessary.
  78. * @param descr If no cp is set, we take the browsedescription from there
  79. * @param maxrefs The maximum number of references the client has requested. If 0,
  80. * all matching references are returned at once.
  81. * @param result The entry in the request */
  82. void
  83. Service_Browse_single(UA_Server *server, UA_Session *session,
  84. struct ContinuationPointEntry *cp, const UA_BrowseDescription *descr,
  85. UA_UInt32 maxrefs, UA_BrowseResult *result) {
  86. size_t referencesCount = 0;
  87. size_t referencesIndex = 0;
  88. /* set the browsedescription if a cp is given */
  89. UA_UInt32 continuationIndex = 0;
  90. if(cp) {
  91. descr = &cp->browseDescription;
  92. maxrefs = cp->maxReferences;
  93. continuationIndex = cp->continuationIndex;
  94. }
  95. /* is the browsedirection valid? */
  96. if(descr->browseDirection != UA_BROWSEDIRECTION_BOTH &&
  97. descr->browseDirection != UA_BROWSEDIRECTION_FORWARD &&
  98. descr->browseDirection != UA_BROWSEDIRECTION_INVERSE) {
  99. result->statusCode = UA_STATUSCODE_BADBROWSEDIRECTIONINVALID;
  100. return;
  101. }
  102. /* get the references that match the browsedescription */
  103. size_t relevant_refs_size = 0;
  104. UA_NodeId *relevant_refs = NULL;
  105. UA_Boolean all_refs = UA_NodeId_isNull(&descr->referenceTypeId);
  106. if(!all_refs) {
  107. const UA_Node *rootRef = UA_NodeStore_get(server->nodestore, &descr->referenceTypeId);
  108. if(!rootRef || rootRef->nodeClass != UA_NODECLASS_REFERENCETYPE) {
  109. result->statusCode = UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  110. return;
  111. }
  112. if(descr->includeSubtypes) {
  113. result->statusCode = getTypeHierarchy(server->nodestore, rootRef, false,
  114. &relevant_refs, &relevant_refs_size);
  115. if(result->statusCode != UA_STATUSCODE_GOOD)
  116. return;
  117. } else {
  118. relevant_refs = (UA_NodeId*)(uintptr_t)&descr->referenceTypeId;
  119. relevant_refs_size = 1;
  120. }
  121. }
  122. /* get the node */
  123. const UA_Node *node = UA_NodeStore_get(server->nodestore, &descr->nodeId);
  124. if(!node) {
  125. result->statusCode = UA_STATUSCODE_BADNODEIDUNKNOWN;
  126. if(!all_refs && descr->includeSubtypes)
  127. UA_Array_delete(relevant_refs, relevant_refs_size, &UA_TYPES[UA_TYPES_NODEID]);
  128. return;
  129. }
  130. /* if the node has no references, just return */
  131. if(node->referencesSize == 0) {
  132. result->referencesSize = 0;
  133. if(!all_refs && descr->includeSubtypes)
  134. UA_Array_delete(relevant_refs, relevant_refs_size, &UA_TYPES[UA_TYPES_NODEID]);
  135. return;
  136. }
  137. /* how many references can we return at most? */
  138. size_t real_maxrefs = maxrefs;
  139. if(real_maxrefs == 0)
  140. real_maxrefs = node->referencesSize;
  141. else if(real_maxrefs > node->referencesSize)
  142. real_maxrefs = node->referencesSize;
  143. result->references = UA_Array_new(real_maxrefs, &UA_TYPES[UA_TYPES_REFERENCEDESCRIPTION]);
  144. if(!result->references) {
  145. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  146. goto cleanup;
  147. }
  148. /* loop over the node's references */
  149. size_t skipped = 0;
  150. UA_Boolean isExternal = false;
  151. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  152. for(; referencesIndex < node->referencesSize && referencesCount < real_maxrefs; ++referencesIndex) {
  153. isExternal = false;
  154. const UA_Node *current =
  155. returnRelevantNode(server, descr, all_refs, &node->references[referencesIndex],
  156. relevant_refs, relevant_refs_size, &isExternal);
  157. if(!current)
  158. continue;
  159. if(skipped < continuationIndex) {
  160. ++skipped;
  161. } else {
  162. retval |= fillReferenceDescription(server->nodestore, current,
  163. &node->references[referencesIndex],
  164. descr->resultMask,
  165. &result->references[referencesCount]);
  166. ++referencesCount;
  167. }
  168. }
  169. result->referencesSize = referencesCount;
  170. if(referencesCount == 0) {
  171. UA_free(result->references);
  172. result->references = NULL;
  173. result->referencesSize = 0;
  174. }
  175. if(retval != UA_STATUSCODE_GOOD) {
  176. UA_Array_delete(result->references, result->referencesSize,
  177. &UA_TYPES[UA_TYPES_REFERENCEDESCRIPTION]);
  178. result->references = NULL;
  179. result->referencesSize = 0;
  180. result->statusCode = retval;
  181. }
  182. cleanup:
  183. if(!all_refs && descr->includeSubtypes)
  184. UA_Array_delete(relevant_refs, relevant_refs_size, &UA_TYPES[UA_TYPES_NODEID]);
  185. if(result->statusCode != UA_STATUSCODE_GOOD)
  186. return;
  187. /* create, update, delete continuation points */
  188. if(cp) {
  189. if(referencesIndex == node->referencesSize) {
  190. /* all done, remove a finished continuationPoint */
  191. removeCp(cp, session);
  192. } else {
  193. /* update the cp and return the cp identifier */
  194. cp->continuationIndex += (UA_UInt32)referencesCount;
  195. UA_ByteString_copy(&cp->identifier, &result->continuationPoint);
  196. }
  197. } else if(maxrefs != 0 && referencesCount >= maxrefs) {
  198. /* create a cp */
  199. if(session->availableContinuationPoints <= 0 ||
  200. !(cp = UA_malloc(sizeof(struct ContinuationPointEntry)))) {
  201. result->statusCode = UA_STATUSCODE_BADNOCONTINUATIONPOINTS;
  202. return;
  203. }
  204. UA_BrowseDescription_copy(descr, &cp->browseDescription);
  205. cp->maxReferences = maxrefs;
  206. cp->continuationIndex = (UA_UInt32)referencesCount;
  207. UA_Guid *ident = UA_Guid_new();
  208. *ident = UA_Guid_random();
  209. cp->identifier.data = (UA_Byte*)ident;
  210. cp->identifier.length = sizeof(UA_Guid);
  211. UA_ByteString_copy(&cp->identifier, &result->continuationPoint);
  212. /* store the cp */
  213. LIST_INSERT_HEAD(&session->continuationPoints, cp, pointers);
  214. --session->availableContinuationPoints;
  215. }
  216. }
  217. void Service_Browse(UA_Server *server, UA_Session *session, const UA_BrowseRequest *request,
  218. UA_BrowseResponse *response) {
  219. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing BrowseRequest");
  220. if(!UA_NodeId_isNull(&request->view.viewId)) {
  221. response->responseHeader.serviceResult = UA_STATUSCODE_BADVIEWIDUNKNOWN;
  222. return;
  223. }
  224. if(request->nodesToBrowseSize <= 0) {
  225. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  226. return;
  227. }
  228. size_t size = request->nodesToBrowseSize;
  229. response->results = UA_Array_new(size, &UA_TYPES[UA_TYPES_BROWSERESULT]);
  230. if(!response->results) {
  231. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  232. return;
  233. }
  234. response->resultsSize = size;
  235. for(size_t i = 0; i < size; ++i) {
  236. Service_Browse_single(server, session, NULL, &request->nodesToBrowse[i],
  237. request->requestedMaxReferencesPerNode, &response->results[i]);
  238. }
  239. }
  240. UA_BrowseResult
  241. UA_Server_browse(UA_Server *server, UA_UInt32 maxrefs, const UA_BrowseDescription *descr) {
  242. UA_BrowseResult result;
  243. UA_BrowseResult_init(&result);
  244. UA_RCU_LOCK();
  245. Service_Browse_single(server, &adminSession, NULL, descr, maxrefs, &result);
  246. UA_RCU_UNLOCK();
  247. return result;
  248. }
  249. static void
  250. UA_Server_browseNext_single(UA_Server *server, UA_Session *session, UA_Boolean releaseContinuationPoint,
  251. const UA_ByteString *continuationPoint, UA_BrowseResult *result) {
  252. result->statusCode = UA_STATUSCODE_BADCONTINUATIONPOINTINVALID;
  253. struct ContinuationPointEntry *cp, *temp;
  254. LIST_FOREACH_SAFE(cp, &session->continuationPoints, pointers, temp) {
  255. if(UA_ByteString_equal(&cp->identifier, continuationPoint)) {
  256. result->statusCode = UA_STATUSCODE_GOOD;
  257. if(!releaseContinuationPoint)
  258. Service_Browse_single(server, session, cp, NULL, 0, result);
  259. else
  260. removeCp(cp, session);
  261. break;
  262. }
  263. }
  264. }
  265. void Service_BrowseNext(UA_Server *server, UA_Session *session, const UA_BrowseNextRequest *request,
  266. UA_BrowseNextResponse *response) {
  267. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing BrowseNextRequest");
  268. if(request->continuationPointsSize <= 0) {
  269. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  270. return;
  271. }
  272. size_t size = request->continuationPointsSize;
  273. response->results = UA_Array_new(size, &UA_TYPES[UA_TYPES_BROWSERESULT]);
  274. if(!response->results) {
  275. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  276. return;
  277. }
  278. response->resultsSize = size;
  279. for(size_t i = 0; i < size; ++i)
  280. UA_Server_browseNext_single(server, session, request->releaseContinuationPoints,
  281. &request->continuationPoints[i], &response->results[i]);
  282. }
  283. UA_BrowseResult
  284. UA_Server_browseNext(UA_Server *server, UA_Boolean releaseContinuationPoint,
  285. const UA_ByteString *continuationPoint) {
  286. UA_BrowseResult result;
  287. UA_BrowseResult_init(&result);
  288. UA_RCU_LOCK();
  289. UA_Server_browseNext_single(server, &adminSession, releaseContinuationPoint,
  290. continuationPoint, &result);
  291. UA_RCU_UNLOCK();
  292. return result;
  293. }
  294. /***********************/
  295. /* TranslateBrowsePath */
  296. /***********************/
  297. static void
  298. walkBrowsePathElementNodeReference(UA_BrowsePathResult *result, size_t *targetsSize,
  299. UA_NodeId **next, size_t *nextSize, size_t *nextCount,
  300. UA_UInt32 elemDepth, UA_Boolean inverse, UA_Boolean all_refs,
  301. const UA_NodeId *reftypes, size_t reftypes_count,
  302. const UA_ReferenceNode *reference) {
  303. /* Does the direction of the reference match? */
  304. if(reference->isInverse != inverse)
  305. return;
  306. /* Is the node relevant? */
  307. if(!all_refs) {
  308. UA_Boolean match = false;
  309. for(size_t j = 0; j < reftypes_count; ++j) {
  310. if(UA_NodeId_equal(&reference->referenceTypeId, &reftypes[j])) {
  311. match = true;
  312. break;
  313. }
  314. }
  315. if(!match)
  316. return;
  317. }
  318. /* Does the reference point to an external server? Then add to the
  319. * targets with the right path "depth" */
  320. if(reference->targetId.serverIndex != 0) {
  321. UA_BrowsePathTarget *tempTargets =
  322. UA_realloc(result->targets, sizeof(UA_BrowsePathTarget) * (*targetsSize) * 2);
  323. if(!tempTargets) {
  324. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  325. return;
  326. }
  327. result->targets = tempTargets;
  328. (*targetsSize) *= 2;
  329. result->statusCode = UA_ExpandedNodeId_copy(&reference->targetId,
  330. &result->targets[result->targetsSize].targetId);
  331. result->targets[result->targetsSize].remainingPathIndex = elemDepth;
  332. return;
  333. }
  334. /* Add the node to the next array for the following path element */
  335. if(*nextSize <= *nextCount) {
  336. UA_NodeId *tempNext = UA_realloc(*next, sizeof(UA_NodeId) * (*nextSize) * 2);
  337. if(!tempNext) {
  338. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  339. return;
  340. }
  341. *next = tempNext;
  342. (*nextSize) *= 2;
  343. }
  344. result->statusCode = UA_NodeId_copy(&reference->targetId.nodeId,
  345. &(*next)[*nextCount]);
  346. ++(*nextCount);
  347. }
  348. static void
  349. walkBrowsePathElement(UA_Server *server, UA_Session *session,
  350. UA_BrowsePathResult *result, size_t *targetsSize,
  351. const UA_RelativePathElement *elem, UA_UInt32 elemDepth,
  352. const UA_QualifiedName *targetName,
  353. const UA_NodeId *current, const size_t currentCount,
  354. UA_NodeId **next, size_t *nextSize, size_t *nextCount) {
  355. /* Get the full list of relevant referencetypes for this path element */
  356. UA_NodeId *reftypes = NULL;
  357. size_t reftypes_count = 1; // all_refs or no subtypes => 1
  358. UA_Boolean all_refs = false;
  359. if(UA_NodeId_isNull(&elem->referenceTypeId)) {
  360. all_refs = true;
  361. } else if(!elem->includeSubtypes) {
  362. reftypes = (UA_NodeId*)(uintptr_t)&elem->referenceTypeId; // ptr magic due to const cast
  363. } else {
  364. const UA_Node *rootRef = UA_NodeStore_get(server->nodestore, &elem->referenceTypeId);
  365. if(!rootRef || rootRef->nodeClass != UA_NODECLASS_REFERENCETYPE)
  366. return;
  367. UA_StatusCode retval =
  368. getTypeHierarchy(server->nodestore, rootRef, false, &reftypes, &reftypes_count);
  369. if(retval != UA_STATUSCODE_GOOD)
  370. return;
  371. }
  372. /* Iterate over all nodes at the current depth-level */
  373. for(size_t i = 0; i < currentCount; ++i) {
  374. /* Get the node */
  375. const UA_Node *node = UA_NodeStore_get(server->nodestore, &current[i]);
  376. if(!node) {
  377. /* If we cannot find the node at depth 0, the starting node does not exist */
  378. if(elemDepth == 0)
  379. result->statusCode = UA_STATUSCODE_BADNODEIDUNKNOWN;
  380. continue;
  381. }
  382. /* Test whether the current node has the target name required in the
  383. * previous path element */
  384. if(targetName && (targetName->namespaceIndex != node->browseName.namespaceIndex ||
  385. !UA_String_equal(&targetName->name, &node->browseName.name)))
  386. continue;
  387. /* Walk over the references in the node */
  388. /* Loop over the nodes references */
  389. for(size_t r = 0; r < node->referencesSize &&
  390. result->statusCode == UA_STATUSCODE_GOOD; ++r) {
  391. UA_ReferenceNode *reference = &node->references[r];
  392. walkBrowsePathElementNodeReference(result, targetsSize, next, nextSize, nextCount,
  393. elemDepth, elem->isInverse, all_refs,
  394. reftypes, reftypes_count, reference);
  395. }
  396. }
  397. if(!all_refs && elem->includeSubtypes)
  398. UA_Array_delete(reftypes, reftypes_count, &UA_TYPES[UA_TYPES_NODEID]);
  399. }
  400. /* This assumes that result->targets has enough room for all currentCount elements */
  401. static void
  402. addBrowsePathTargets(UA_Server *server, UA_Session *session, UA_BrowsePathResult *result,
  403. const UA_QualifiedName *targetName, UA_NodeId *current, size_t currentCount) {
  404. for(size_t i = 0; i < currentCount; i++) {
  405. /* Get the node */
  406. const UA_Node *node = UA_NodeStore_get(server->nodestore, &current[i]);
  407. if(!node) {
  408. UA_NodeId_deleteMembers(&current[i]);
  409. continue;
  410. }
  411. /* Test whether the current node has the target name required in the
  412. * previous path element */
  413. if(targetName->namespaceIndex != node->browseName.namespaceIndex ||
  414. !UA_String_equal(&targetName->name, &node->browseName.name)) {
  415. UA_NodeId_deleteMembers(&current[i]);
  416. continue;
  417. }
  418. /* Move the nodeid to the target array */
  419. UA_BrowsePathTarget_init(&result->targets[result->targetsSize]);
  420. result->targets[result->targetsSize].targetId.nodeId = current[i];
  421. result->targets[result->targetsSize].remainingPathIndex = UA_UINT32_MAX;
  422. ++result->targetsSize;
  423. }
  424. }
  425. static void
  426. walkBrowsePath(UA_Server *server, UA_Session *session, const UA_BrowsePath *path,
  427. UA_BrowsePathResult *result, size_t targetsSize,
  428. UA_NodeId **current, size_t *currentSize, size_t *currentCount,
  429. UA_NodeId **next, size_t *nextSize, size_t *nextCount) {
  430. UA_assert(*currentCount == 1);
  431. UA_assert(*nextCount == 0);
  432. /* Points to the targetName of the _previous_ path element */
  433. const UA_QualifiedName *targetName = NULL;
  434. /* Iterate over path elements */
  435. UA_assert(path->relativePath.elementsSize > 0);
  436. for(UA_UInt32 i = 0; i < path->relativePath.elementsSize; ++i) {
  437. walkBrowsePathElement(server, session, result, &targetsSize,
  438. &path->relativePath.elements[i], i, targetName,
  439. *current, *currentCount, next, nextSize, nextCount);
  440. /* Clean members of current */
  441. for(size_t j = 0; j < *currentCount; j++)
  442. UA_NodeId_deleteMembers(&(*current)[j]);
  443. *currentCount = 0;
  444. /* When no targets are left or an error occurred. None of next's
  445. * elements will be copied to result->targets */
  446. if(*nextCount == 0 || result->statusCode != UA_STATUSCODE_GOOD) {
  447. UA_assert(*currentCount == 0);
  448. UA_assert(*nextCount == 0);
  449. return;
  450. }
  451. /* Exchange current and next for the next depth */
  452. size_t tSize = *currentSize; size_t tCount = *currentCount; UA_NodeId *tT = *current;
  453. *currentSize = *nextSize; *currentCount = *nextCount; *current = *next;
  454. *nextSize = tSize; *nextCount = tCount; *next = tT;
  455. /* Store the target name of the previous path element */
  456. targetName = &path->relativePath.elements[i].targetName;
  457. }
  458. UA_assert(targetName != NULL);
  459. UA_assert(*nextCount == 0);
  460. /* After the last BrowsePathElement, move members from current to the
  461. * result targets */
  462. /* Realloc if more space is needed */
  463. if(targetsSize < result->targetsSize + (*currentCount)) {
  464. UA_BrowsePathTarget *newTargets =
  465. (UA_BrowsePathTarget*)UA_realloc(result->targets, sizeof(UA_BrowsePathTarget) *
  466. (result->targetsSize + (*currentCount)));
  467. if(!newTargets) {
  468. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  469. for(size_t i = 0; i < *currentCount; ++i)
  470. UA_NodeId_deleteMembers(&(*current)[i]);
  471. *currentCount = 0;
  472. return;
  473. }
  474. result->targets = newTargets;
  475. }
  476. /* Move the elements of current to the targets */
  477. addBrowsePathTargets(server, session, result, targetName, *current, *currentCount);
  478. *currentCount = 0;
  479. }
  480. static void
  481. translateBrowsePathToNodeIds(UA_Server *server, UA_Session *session,
  482. const UA_BrowsePath *path, UA_BrowsePathResult *result) {
  483. if(path->relativePath.elementsSize <= 0) {
  484. result->statusCode = UA_STATUSCODE_BADNOTHINGTODO;
  485. return;
  486. }
  487. /* RelativePath elements must not have an empty targetName */
  488. for(size_t i = 0; i < path->relativePath.elementsSize; ++i) {
  489. if(UA_QualifiedName_isNull(&path->relativePath.elements[i].targetName)) {
  490. result->statusCode = UA_STATUSCODE_BADBROWSENAMEINVALID;
  491. return;
  492. }
  493. }
  494. /* Allocate memory for the targets */
  495. size_t targetsSize = 10; /* When to realloc; the member count is stored in
  496. * result->targetsSize */
  497. result->targets = (UA_BrowsePathTarget*)UA_malloc(sizeof(UA_BrowsePathTarget) * targetsSize);
  498. if(!result->targets) {
  499. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  500. return;
  501. }
  502. /* Allocate memory for two temporary arrays. One with the results for the
  503. * previous depth of the path. The other for the new results at the current
  504. * depth. The two arrays alternate as we descend down the tree. */
  505. size_t currentSize = 10; /* When to realloc */
  506. size_t currentCount = 0; /* Current elements */
  507. UA_NodeId *current = (UA_NodeId*)UA_malloc(sizeof(UA_NodeId) * currentSize);
  508. if(!current) {
  509. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  510. UA_free(result->targets);
  511. return;
  512. }
  513. size_t nextSize = 10; /* When to realloc */
  514. size_t nextCount = 0; /* Current elements */
  515. UA_NodeId *next = (UA_NodeId*)UA_malloc(sizeof(UA_NodeId) * nextSize);
  516. if(!next) {
  517. result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  518. UA_free(result->targets);
  519. UA_free(current);
  520. return;
  521. }
  522. /* Copy the starting node into current */
  523. result->statusCode = UA_NodeId_copy(&path->startingNode, &current[0]);
  524. if(result->statusCode != UA_STATUSCODE_GOOD) {
  525. UA_free(result->targets);
  526. UA_free(current);
  527. UA_free(next);
  528. return;
  529. }
  530. currentCount = 1;
  531. /* Walk the path elements */
  532. walkBrowsePath(server, session, path, result, targetsSize,
  533. &current, &currentSize, &currentCount,
  534. &next, &nextSize, &nextCount);
  535. UA_assert(currentCount == 0);
  536. UA_assert(nextCount == 0);
  537. /* No results => BadNoMatch status code */
  538. if(result->targetsSize == 0 && result->statusCode == UA_STATUSCODE_GOOD)
  539. result->statusCode = UA_STATUSCODE_BADNOMATCH;
  540. /* Clean up the temporary arrays and the targets */
  541. UA_free(current);
  542. UA_free(next);
  543. if(result->statusCode != UA_STATUSCODE_GOOD) {
  544. for(size_t i = 0; i < result->targetsSize; ++i)
  545. UA_BrowsePathTarget_deleteMembers(&result->targets[i]);
  546. UA_free(result->targets);
  547. result->targets = NULL;
  548. result->targetsSize = 0;
  549. }
  550. }
  551. UA_BrowsePathResult
  552. UA_Server_translateBrowsePathToNodeIds(UA_Server *server,
  553. const UA_BrowsePath *browsePath) {
  554. UA_BrowsePathResult result;
  555. UA_BrowsePathResult_init(&result);
  556. UA_RCU_LOCK();
  557. translateBrowsePathToNodeIds(server, &adminSession, browsePath, &result);
  558. UA_RCU_UNLOCK();
  559. return result;
  560. }
  561. void Service_TranslateBrowsePathsToNodeIds(UA_Server *server, UA_Session *session,
  562. const UA_TranslateBrowsePathsToNodeIdsRequest *request,
  563. UA_TranslateBrowsePathsToNodeIdsResponse *response) {
  564. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing TranslateBrowsePathsToNodeIdsRequest");
  565. if(request->browsePathsSize <= 0) {
  566. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  567. return;
  568. }
  569. size_t size = request->browsePathsSize;
  570. response->results = UA_Array_new(size, &UA_TYPES[UA_TYPES_BROWSEPATHRESULT]);
  571. if(!response->results) {
  572. response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
  573. return;
  574. }
  575. response->resultsSize = size;
  576. for(size_t i = 0; i < size; ++i)
  577. translateBrowsePathToNodeIds(server, session, &request->browsePaths[i],
  578. &response->results[i]);
  579. }
  580. void Service_RegisterNodes(UA_Server *server, UA_Session *session, const UA_RegisterNodesRequest *request,
  581. UA_RegisterNodesResponse *response) {
  582. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing RegisterNodesRequest");
  583. //TODO: hang the nodeids to the session if really needed
  584. response->responseHeader.timestamp = UA_DateTime_now();
  585. if(request->nodesToRegisterSize <= 0)
  586. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  587. else {
  588. response->responseHeader.serviceResult =
  589. UA_Array_copy(request->nodesToRegister, request->nodesToRegisterSize,
  590. (void**)&response->registeredNodeIds, &UA_TYPES[UA_TYPES_NODEID]);
  591. if(response->responseHeader.serviceResult == UA_STATUSCODE_GOOD)
  592. response->registeredNodeIdsSize = request->nodesToRegisterSize;
  593. }
  594. }
  595. void Service_UnregisterNodes(UA_Server *server, UA_Session *session, const UA_UnregisterNodesRequest *request,
  596. UA_UnregisterNodesResponse *response) {
  597. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing UnRegisterNodesRequest");
  598. //TODO: remove the nodeids from the session if really needed
  599. response->responseHeader.timestamp = UA_DateTime_now();
  600. if(request->nodesToUnregisterSize==0)
  601. response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
  602. }