ua_services_view.c 28 KB

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