ua_client_highlevel.c 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661
  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. *
  5. * Copyright 2015-2017 (c) Fraunhofer IOSB (Author: Julius Pfrommer)
  6. * Copyright 2015 (c) Oleksiy Vasylyev
  7. * Copyright 2017 (c) Florian Palm
  8. * Copyright 2016 (c) Chris Iatrou
  9. * Copyright 2017 (c) Stefan Profanter, fortiss GmbH
  10. */
  11. #include "ua_client.h"
  12. #include "ua_client_internal.h"
  13. #include "ua_client_highlevel.h"
  14. #include "ua_client_highlevel_async.h"
  15. #include "ua_util.h"
  16. UA_StatusCode
  17. UA_Client_NamespaceGetIndex(UA_Client *client, UA_String *namespaceUri,
  18. UA_UInt16 *namespaceIndex) {
  19. UA_ReadRequest request;
  20. UA_ReadRequest_init(&request);
  21. UA_ReadValueId id;
  22. UA_ReadValueId_init(&id);
  23. id.attributeId = UA_ATTRIBUTEID_VALUE;
  24. id.nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_NAMESPACEARRAY);
  25. request.nodesToRead = &id;
  26. request.nodesToReadSize = 1;
  27. UA_ReadResponse response = UA_Client_Service_read(client, request);
  28. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  29. if(response.responseHeader.serviceResult != UA_STATUSCODE_GOOD)
  30. retval = response.responseHeader.serviceResult;
  31. else if(response.resultsSize != 1 || !response.results[0].hasValue)
  32. retval = UA_STATUSCODE_BADNODEATTRIBUTESINVALID;
  33. else if(response.results[0].value.type != &UA_TYPES[UA_TYPES_STRING])
  34. retval = UA_STATUSCODE_BADTYPEMISMATCH;
  35. if(retval != UA_STATUSCODE_GOOD) {
  36. UA_ReadResponse_deleteMembers(&response);
  37. return retval;
  38. }
  39. retval = UA_STATUSCODE_BADNOTFOUND;
  40. UA_String *ns = (UA_String *)response.results[0].value.data;
  41. for(size_t i = 0; i < response.results[0].value.arrayLength; ++i) {
  42. if(UA_String_equal(namespaceUri, &ns[i])) {
  43. *namespaceIndex = (UA_UInt16)i;
  44. retval = UA_STATUSCODE_GOOD;
  45. break;
  46. }
  47. }
  48. UA_ReadResponse_deleteMembers(&response);
  49. return retval;
  50. }
  51. UA_StatusCode
  52. UA_Client_forEachChildNodeCall(UA_Client *client, UA_NodeId parentNodeId,
  53. UA_NodeIteratorCallback callback, void *handle) {
  54. UA_BrowseRequest bReq;
  55. UA_BrowseRequest_init(&bReq);
  56. bReq.requestedMaxReferencesPerNode = 0;
  57. bReq.nodesToBrowse = UA_BrowseDescription_new();
  58. bReq.nodesToBrowseSize = 1;
  59. UA_NodeId_copy(&parentNodeId, &bReq.nodesToBrowse[0].nodeId);
  60. bReq.nodesToBrowse[0].resultMask = UA_BROWSERESULTMASK_ALL; //return everything
  61. bReq.nodesToBrowse[0].browseDirection = UA_BROWSEDIRECTION_BOTH;
  62. UA_BrowseResponse bResp = UA_Client_Service_browse(client, bReq);
  63. UA_StatusCode retval = bResp.responseHeader.serviceResult;
  64. if(retval == UA_STATUSCODE_GOOD) {
  65. for(size_t i = 0; i < bResp.resultsSize; ++i) {
  66. for(size_t j = 0; j < bResp.results[i].referencesSize; ++j) {
  67. UA_ReferenceDescription *ref = &bResp.results[i].references[j];
  68. retval |= callback(ref->nodeId.nodeId, !ref->isForward,
  69. ref->referenceTypeId, handle);
  70. }
  71. }
  72. }
  73. UA_BrowseRequest_deleteMembers(&bReq);
  74. UA_BrowseResponse_deleteMembers(&bResp);
  75. return retval;
  76. }
  77. /*******************/
  78. /* Node Management */
  79. /*******************/
  80. UA_StatusCode
  81. UA_Client_addReference(UA_Client *client, const UA_NodeId sourceNodeId,
  82. const UA_NodeId referenceTypeId, UA_Boolean isForward,
  83. const UA_String targetServerUri,
  84. const UA_ExpandedNodeId targetNodeId,
  85. UA_NodeClass targetNodeClass) {
  86. UA_AddReferencesItem item;
  87. UA_AddReferencesItem_init(&item);
  88. item.sourceNodeId = sourceNodeId;
  89. item.referenceTypeId = referenceTypeId;
  90. item.isForward = isForward;
  91. item.targetServerUri = targetServerUri;
  92. item.targetNodeId = targetNodeId;
  93. item.targetNodeClass = targetNodeClass;
  94. UA_AddReferencesRequest request;
  95. UA_AddReferencesRequest_init(&request);
  96. request.referencesToAdd = &item;
  97. request.referencesToAddSize = 1;
  98. UA_AddReferencesResponse response = UA_Client_Service_addReferences(client, request);
  99. UA_StatusCode retval = response.responseHeader.serviceResult;
  100. if(retval != UA_STATUSCODE_GOOD) {
  101. UA_AddReferencesResponse_deleteMembers(&response);
  102. return retval;
  103. }
  104. if(response.resultsSize != 1) {
  105. UA_AddReferencesResponse_deleteMembers(&response);
  106. return UA_STATUSCODE_BADUNEXPECTEDERROR;
  107. }
  108. retval = response.results[0];
  109. UA_AddReferencesResponse_deleteMembers(&response);
  110. return retval;
  111. }
  112. UA_StatusCode
  113. UA_Client_deleteReference(UA_Client *client, const UA_NodeId sourceNodeId,
  114. const UA_NodeId referenceTypeId, UA_Boolean isForward,
  115. const UA_ExpandedNodeId targetNodeId,
  116. UA_Boolean deleteBidirectional) {
  117. UA_DeleteReferencesItem item;
  118. UA_DeleteReferencesItem_init(&item);
  119. item.sourceNodeId = sourceNodeId;
  120. item.referenceTypeId = referenceTypeId;
  121. item.isForward = isForward;
  122. item.targetNodeId = targetNodeId;
  123. item.deleteBidirectional = deleteBidirectional;
  124. UA_DeleteReferencesRequest request;
  125. UA_DeleteReferencesRequest_init(&request);
  126. request.referencesToDelete = &item;
  127. request.referencesToDeleteSize = 1;
  128. UA_DeleteReferencesResponse response = UA_Client_Service_deleteReferences(client, request);
  129. UA_StatusCode retval = response.responseHeader.serviceResult;
  130. if(retval != UA_STATUSCODE_GOOD) {
  131. UA_DeleteReferencesResponse_deleteMembers(&response);
  132. return retval;
  133. }
  134. if(response.resultsSize != 1) {
  135. UA_DeleteReferencesResponse_deleteMembers(&response);
  136. return UA_STATUSCODE_BADUNEXPECTEDERROR;
  137. }
  138. retval = response.results[0];
  139. UA_DeleteReferencesResponse_deleteMembers(&response);
  140. return retval;
  141. }
  142. UA_StatusCode
  143. UA_Client_deleteNode(UA_Client *client, const UA_NodeId nodeId,
  144. UA_Boolean deleteTargetReferences) {
  145. UA_DeleteNodesItem item;
  146. UA_DeleteNodesItem_init(&item);
  147. item.nodeId = nodeId;
  148. item.deleteTargetReferences = deleteTargetReferences;
  149. UA_DeleteNodesRequest request;
  150. UA_DeleteNodesRequest_init(&request);
  151. request.nodesToDelete = &item;
  152. request.nodesToDeleteSize = 1;
  153. UA_DeleteNodesResponse response = UA_Client_Service_deleteNodes(client, request);
  154. UA_StatusCode retval = response.responseHeader.serviceResult;
  155. if(retval != UA_STATUSCODE_GOOD) {
  156. UA_DeleteNodesResponse_deleteMembers(&response);
  157. return retval;
  158. }
  159. if(response.resultsSize != 1) {
  160. UA_DeleteNodesResponse_deleteMembers(&response);
  161. return UA_STATUSCODE_BADUNEXPECTEDERROR;
  162. }
  163. retval = response.results[0];
  164. UA_DeleteNodesResponse_deleteMembers(&response);
  165. return retval;
  166. }
  167. UA_StatusCode
  168. __UA_Client_addNode(UA_Client *client, const UA_NodeClass nodeClass,
  169. const UA_NodeId requestedNewNodeId, const UA_NodeId parentNodeId,
  170. const UA_NodeId referenceTypeId, const UA_QualifiedName browseName,
  171. const UA_NodeId typeDefinition, const UA_NodeAttributes *attr,
  172. const UA_DataType *attributeType, UA_NodeId *outNewNodeId) {
  173. UA_AddNodesRequest request;
  174. UA_AddNodesRequest_init(&request);
  175. UA_AddNodesItem item;
  176. UA_AddNodesItem_init(&item);
  177. item.parentNodeId.nodeId = parentNodeId;
  178. item.referenceTypeId = referenceTypeId;
  179. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  180. item.browseName = browseName;
  181. item.nodeClass = nodeClass;
  182. item.typeDefinition.nodeId = typeDefinition;
  183. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  184. item.nodeAttributes.content.decoded.type = attributeType;
  185. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)attr; // hack. is not written into.
  186. request.nodesToAdd = &item;
  187. request.nodesToAddSize = 1;
  188. UA_AddNodesResponse response = UA_Client_Service_addNodes(client, request);
  189. UA_StatusCode retval = response.responseHeader.serviceResult;
  190. if(retval != UA_STATUSCODE_GOOD) {
  191. UA_AddNodesResponse_deleteMembers(&response);
  192. return retval;
  193. }
  194. if(response.resultsSize != 1) {
  195. UA_AddNodesResponse_deleteMembers(&response);
  196. return UA_STATUSCODE_BADUNEXPECTEDERROR;
  197. }
  198. /* Move the id of the created node */
  199. retval = response.results[0].statusCode;
  200. if(retval == UA_STATUSCODE_GOOD && outNewNodeId) {
  201. *outNewNodeId = response.results[0].addedNodeId;
  202. UA_NodeId_init(&response.results[0].addedNodeId);
  203. }
  204. UA_AddNodesResponse_deleteMembers(&response);
  205. return retval;
  206. }
  207. /********/
  208. /* Call */
  209. /********/
  210. #ifdef UA_ENABLE_METHODCALLS
  211. UA_StatusCode
  212. UA_Client_call(UA_Client *client, const UA_NodeId objectId,
  213. const UA_NodeId methodId, size_t inputSize,
  214. const UA_Variant *input, size_t *outputSize,
  215. UA_Variant **output) {
  216. /* Set up the request */
  217. UA_CallRequest request;
  218. UA_CallRequest_init(&request);
  219. UA_CallMethodRequest item;
  220. UA_CallMethodRequest_init(&item);
  221. item.methodId = methodId;
  222. item.objectId = objectId;
  223. item.inputArguments = (UA_Variant *)(void*)(uintptr_t)input; // cast const...
  224. item.inputArgumentsSize = inputSize;
  225. request.methodsToCall = &item;
  226. request.methodsToCallSize = 1;
  227. /* Call the service */
  228. UA_CallResponse response = UA_Client_Service_call(client, request);
  229. UA_StatusCode retval = response.responseHeader.serviceResult;
  230. if(retval == UA_STATUSCODE_GOOD) {
  231. if(response.resultsSize == 1)
  232. retval = response.results[0].statusCode;
  233. else
  234. retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
  235. }
  236. if(retval != UA_STATUSCODE_GOOD) {
  237. UA_CallResponse_deleteMembers(&response);
  238. return retval;
  239. }
  240. /* Move the output arguments */
  241. if(output != NULL && outputSize != NULL) {
  242. *output = response.results[0].outputArguments;
  243. *outputSize = response.results[0].outputArgumentsSize;
  244. response.results[0].outputArguments = NULL;
  245. response.results[0].outputArgumentsSize = 0;
  246. }
  247. UA_CallResponse_deleteMembers(&response);
  248. return retval;
  249. }
  250. #endif
  251. /********************/
  252. /* Write Attributes */
  253. /********************/
  254. UA_StatusCode
  255. __UA_Client_writeAttribute(UA_Client *client, const UA_NodeId *nodeId,
  256. UA_AttributeId attributeId, const void *in,
  257. const UA_DataType *inDataType) {
  258. if(!in)
  259. return UA_STATUSCODE_BADTYPEMISMATCH;
  260. UA_WriteValue wValue;
  261. UA_WriteValue_init(&wValue);
  262. wValue.nodeId = *nodeId;
  263. wValue.attributeId = attributeId;
  264. if(attributeId == UA_ATTRIBUTEID_VALUE)
  265. wValue.value.value = *(const UA_Variant*)in;
  266. else
  267. /* hack. is never written into. */
  268. UA_Variant_setScalar(&wValue.value.value, (void*)(uintptr_t)in, inDataType);
  269. wValue.value.hasValue = true;
  270. UA_WriteRequest wReq;
  271. UA_WriteRequest_init(&wReq);
  272. wReq.nodesToWrite = &wValue;
  273. wReq.nodesToWriteSize = 1;
  274. UA_WriteResponse wResp = UA_Client_Service_write(client, wReq);
  275. UA_StatusCode retval = wResp.responseHeader.serviceResult;
  276. if(retval == UA_STATUSCODE_GOOD) {
  277. if(wResp.resultsSize == 1)
  278. retval = wResp.results[0];
  279. else
  280. retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
  281. }
  282. UA_WriteResponse_deleteMembers(&wResp);
  283. return retval;
  284. }
  285. UA_StatusCode
  286. UA_Client_writeArrayDimensionsAttribute(UA_Client *client, const UA_NodeId nodeId,
  287. size_t newArrayDimensionsSize,
  288. const UA_UInt32 *newArrayDimensions) {
  289. if(!newArrayDimensions)
  290. return UA_STATUSCODE_BADTYPEMISMATCH;
  291. UA_WriteValue wValue;
  292. UA_WriteValue_init(&wValue);
  293. wValue.nodeId = nodeId;
  294. wValue.attributeId = UA_ATTRIBUTEID_ARRAYDIMENSIONS;
  295. UA_Variant_setArray(&wValue.value.value, (void*)(uintptr_t)newArrayDimensions,
  296. newArrayDimensionsSize, &UA_TYPES[UA_TYPES_UINT32]);
  297. wValue.value.hasValue = true;
  298. UA_WriteRequest wReq;
  299. UA_WriteRequest_init(&wReq);
  300. wReq.nodesToWrite = &wValue;
  301. wReq.nodesToWriteSize = 1;
  302. UA_WriteResponse wResp = UA_Client_Service_write(client, wReq);
  303. UA_StatusCode retval = wResp.responseHeader.serviceResult;
  304. if(retval == UA_STATUSCODE_GOOD) {
  305. if(wResp.resultsSize == 1)
  306. retval = wResp.results[0];
  307. else
  308. retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
  309. }
  310. UA_WriteResponse_deleteMembers(&wResp);
  311. return retval;
  312. }
  313. /*******************/
  314. /* Read Attributes */
  315. /*******************/
  316. UA_StatusCode
  317. __UA_Client_readAttribute(UA_Client *client, const UA_NodeId *nodeId,
  318. UA_AttributeId attributeId, void *out,
  319. const UA_DataType *outDataType) {
  320. UA_ReadValueId item;
  321. UA_ReadValueId_init(&item);
  322. item.nodeId = *nodeId;
  323. item.attributeId = attributeId;
  324. UA_ReadRequest request;
  325. UA_ReadRequest_init(&request);
  326. request.nodesToRead = &item;
  327. request.nodesToReadSize = 1;
  328. UA_ReadResponse response = UA_Client_Service_read(client, request);
  329. UA_StatusCode retval = response.responseHeader.serviceResult;
  330. if(retval == UA_STATUSCODE_GOOD) {
  331. if(response.resultsSize == 1)
  332. retval = response.results[0].status;
  333. else
  334. retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
  335. }
  336. if(retval != UA_STATUSCODE_GOOD) {
  337. UA_ReadResponse_deleteMembers(&response);
  338. return retval;
  339. }
  340. /* Set the StatusCode */
  341. UA_DataValue *res = response.results;
  342. if(res->hasStatus)
  343. retval = res->status;
  344. /* Return early of no value is given */
  345. if(!res->hasValue) {
  346. if(retval == UA_STATUSCODE_GOOD)
  347. retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
  348. UA_ReadResponse_deleteMembers(&response);
  349. return retval;
  350. }
  351. /* Copy value into out */
  352. if(attributeId == UA_ATTRIBUTEID_VALUE) {
  353. memcpy(out, &res->value, sizeof(UA_Variant));
  354. UA_Variant_init(&res->value);
  355. } else if(attributeId == UA_ATTRIBUTEID_NODECLASS) {
  356. memcpy(out, (UA_NodeClass*)res->value.data, sizeof(UA_NodeClass));
  357. } else if(UA_Variant_isScalar(&res->value) &&
  358. res->value.type == outDataType) {
  359. memcpy(out, res->value.data, res->value.type->memSize);
  360. UA_free(res->value.data);
  361. res->value.data = NULL;
  362. } else {
  363. retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
  364. }
  365. UA_ReadResponse_deleteMembers(&response);
  366. return retval;
  367. }
  368. static UA_StatusCode
  369. processReadArrayDimensionsResult(UA_ReadResponse *response,
  370. UA_UInt32 **outArrayDimensions,
  371. size_t *outArrayDimensionsSize) {
  372. UA_StatusCode retval = response->responseHeader.serviceResult;
  373. if(retval != UA_STATUSCODE_GOOD)
  374. return retval;
  375. if(response->resultsSize != 1)
  376. return UA_STATUSCODE_BADUNEXPECTEDERROR;
  377. retval = response->results[0].status;
  378. if(retval != UA_STATUSCODE_GOOD)
  379. return retval;
  380. UA_DataValue *res = &response->results[0];
  381. if(!res->hasValue ||
  382. UA_Variant_isScalar(&res->value) ||
  383. res->value.type != &UA_TYPES[UA_TYPES_UINT32])
  384. return UA_STATUSCODE_BADUNEXPECTEDERROR;
  385. /* Move results */
  386. *outArrayDimensions = (UA_UInt32*)res->value.data;
  387. *outArrayDimensionsSize = res->value.arrayLength;
  388. res->value.data = NULL;
  389. res->value.arrayLength = 0;
  390. return UA_STATUSCODE_GOOD;
  391. }
  392. UA_StatusCode
  393. UA_Client_readArrayDimensionsAttribute(UA_Client *client, const UA_NodeId nodeId,
  394. size_t *outArrayDimensionsSize,
  395. UA_UInt32 **outArrayDimensions) {
  396. UA_ReadValueId item;
  397. UA_ReadValueId_init(&item);
  398. item.nodeId = nodeId;
  399. item.attributeId = UA_ATTRIBUTEID_ARRAYDIMENSIONS;
  400. UA_ReadRequest request;
  401. UA_ReadRequest_init(&request);
  402. request.nodesToRead = &item;
  403. request.nodesToReadSize = 1;
  404. UA_ReadResponse response = UA_Client_Service_read(client, request);
  405. UA_StatusCode retval = processReadArrayDimensionsResult(&response, outArrayDimensions,
  406. outArrayDimensionsSize);
  407. UA_ReadResponse_deleteMembers(&response);
  408. return retval;
  409. }
  410. /*Async Functions*/
  411. /*highlevel callbacks
  412. * used to hide response handling details*/
  413. static
  414. void ValueAttributeRead(UA_Client *client, void *userdata, UA_UInt32 requestId,
  415. void *response) {
  416. if (response == NULL) {
  417. return;
  418. }
  419. CustomCallback *cc;
  420. LIST_FOREACH(cc, &client->customCallbacks, pointers)
  421. {
  422. if (cc->callbackId == requestId)
  423. break;
  424. }
  425. if (!cc)
  426. return;
  427. UA_ReadResponse rr = *(UA_ReadResponse *) response;
  428. if (rr.results[0].status != UA_STATUSCODE_GOOD)
  429. UA_ReadResponse_deleteMembers((UA_ReadResponse*) response);
  430. UA_Variant out;
  431. UA_Variant_init(&out);
  432. UA_DataValue *res = rr.results;
  433. if (!res->hasValue) {
  434. return;
  435. }
  436. /*__UA_Client_readAttribute*/
  437. memcpy(&out, &res->value, sizeof(UA_Variant));
  438. /* Copy value into out */
  439. if (cc->attributeId == UA_ATTRIBUTEID_VALUE) {
  440. memcpy(&out, &res->value, sizeof(UA_Variant));
  441. UA_Variant_init(&res->value);
  442. } else if (cc->attributeId == UA_ATTRIBUTEID_NODECLASS) {
  443. memcpy(&out, (UA_NodeClass*) res->value.data, sizeof(UA_NodeClass));
  444. } else if (UA_Variant_isScalar(&res->value)
  445. && res->value.type == cc->outDataType) {
  446. memcpy(&out, res->value.data, res->value.type->memSize);
  447. UA_free(res->value.data);
  448. res->value.data = NULL;
  449. }
  450. //use callbackId to find the right custom callback
  451. cc->callback(client, userdata, requestId, &out);
  452. LIST_REMOVE(cc, pointers);
  453. UA_free(cc);
  454. UA_ReadResponse_deleteMembers((UA_ReadResponse*) response);
  455. UA_Variant_deleteMembers(&out);
  456. }
  457. /*Read Attributes*/
  458. UA_StatusCode __UA_Client_readAttribute_async(UA_Client *client,
  459. const UA_NodeId *nodeId, UA_AttributeId attributeId,
  460. const UA_DataType *outDataType, UA_ClientAsyncServiceCallback callback,
  461. void *userdata, UA_UInt32 *reqId) {
  462. UA_ReadValueId item;
  463. UA_ReadValueId_init(&item);
  464. item.nodeId = *nodeId;
  465. item.attributeId = attributeId;
  466. UA_ReadRequest request;
  467. UA_ReadRequest_init(&request);
  468. request.nodesToRead = &item;
  469. request.nodesToReadSize = 1;
  470. __UA_Client_AsyncService(client, &request, &UA_TYPES[UA_TYPES_READREQUEST],
  471. ValueAttributeRead, &UA_TYPES[UA_TYPES_READRESPONSE], userdata,
  472. reqId);
  473. CustomCallback *cc = (CustomCallback*) UA_malloc(sizeof(CustomCallback));
  474. if (!cc)
  475. return UA_STATUSCODE_BADOUTOFMEMORY;
  476. cc->callback = callback;
  477. cc->callbackId = *reqId;
  478. cc->attributeId = attributeId;
  479. cc->outDataType = outDataType;
  480. LIST_INSERT_HEAD(&client->customCallbacks, cc, pointers);
  481. return UA_STATUSCODE_GOOD;
  482. }
  483. /*Write Attributes*/
  484. UA_StatusCode __UA_Client_writeAttribute_async(UA_Client *client,
  485. const UA_NodeId *nodeId, UA_AttributeId attributeId, const void *in,
  486. const UA_DataType *inDataType, UA_ClientAsyncServiceCallback callback,
  487. void *userdata, UA_UInt32 *reqId) {
  488. if (!in)
  489. return UA_STATUSCODE_BADTYPEMISMATCH;
  490. UA_WriteValue wValue;
  491. UA_WriteValue_init(&wValue);
  492. wValue.nodeId = *nodeId;
  493. wValue.attributeId = attributeId;
  494. if (attributeId == UA_ATTRIBUTEID_VALUE)
  495. wValue.value.value = *(const UA_Variant*) in;
  496. else
  497. /* hack. is never written into. */
  498. UA_Variant_setScalar(&wValue.value.value, (void*) (uintptr_t) in,
  499. inDataType);
  500. wValue.value.hasValue = true;
  501. UA_WriteRequest wReq;
  502. UA_WriteRequest_init(&wReq);
  503. wReq.nodesToWrite = &wValue;
  504. wReq.nodesToWriteSize = 1;
  505. return __UA_Client_AsyncService(client, &wReq,
  506. &UA_TYPES[UA_TYPES_WRITEREQUEST], callback,
  507. &UA_TYPES[UA_TYPES_WRITERESPONSE], userdata, reqId);
  508. }
  509. /*Node Management*/
  510. UA_StatusCode UA_EXPORT
  511. __UA_Client_addNode_async(UA_Client *client, const UA_NodeClass nodeClass,
  512. const UA_NodeId requestedNewNodeId, const UA_NodeId parentNodeId,
  513. const UA_NodeId referenceTypeId, const UA_QualifiedName browseName,
  514. const UA_NodeId typeDefinition, const UA_NodeAttributes *attr,
  515. const UA_DataType *attributeType, UA_NodeId *outNewNodeId,
  516. UA_ClientAsyncServiceCallback callback, void *userdata,
  517. UA_UInt32 *reqId) {
  518. UA_AddNodesRequest request;
  519. UA_AddNodesRequest_init(&request);
  520. UA_AddNodesItem item;
  521. UA_AddNodesItem_init(&item);
  522. item.parentNodeId.nodeId = parentNodeId;
  523. item.referenceTypeId = referenceTypeId;
  524. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  525. item.browseName = browseName;
  526. item.nodeClass = nodeClass;
  527. item.typeDefinition.nodeId = typeDefinition;
  528. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  529. item.nodeAttributes.content.decoded.type = attributeType;
  530. item.nodeAttributes.content.decoded.data = (void*) (uintptr_t) attr; // hack. is not written into.
  531. request.nodesToAdd = &item;
  532. request.nodesToAddSize = 1;
  533. return __UA_Client_AsyncService(client, &request,
  534. &UA_TYPES[UA_TYPES_ADDNODESREQUEST], callback,
  535. &UA_TYPES[UA_TYPES_ADDNODESRESPONSE], userdata, reqId);
  536. }
  537. /*Misc Highlevel Functions*/
  538. UA_StatusCode __UA_Client_call_async(UA_Client *client,
  539. const UA_NodeId objectId, const UA_NodeId methodId, size_t inputSize,
  540. const UA_Variant *input, UA_ClientAsyncServiceCallback callback,
  541. void *userdata, UA_UInt32 *reqId) {
  542. UA_CallRequest request;
  543. UA_CallRequest_init(&request);
  544. UA_CallMethodRequest item;
  545. UA_CallMethodRequest_init(&item);
  546. item.methodId = methodId;
  547. item.objectId = objectId;
  548. item.inputArguments = (UA_Variant *) (void*) (uintptr_t) input; // cast const...
  549. item.inputArgumentsSize = inputSize;
  550. request.methodsToCall = &item;
  551. request.methodsToCallSize = 1;
  552. return __UA_Client_AsyncService(client, &request,
  553. &UA_TYPES[UA_TYPES_CALLREQUEST], callback,
  554. &UA_TYPES[UA_TYPES_CALLRESPONSE], userdata, reqId);
  555. }
  556. UA_StatusCode __UA_Client_translateBrowsePathsToNodeIds_async(UA_Client *client,
  557. char *paths[], UA_UInt32 ids[], size_t pathSize,
  558. UA_ClientAsyncServiceCallback callback, void *userdata,
  559. UA_UInt32 *reqId) {
  560. UA_BrowsePath browsePath;
  561. UA_BrowsePath_init(&browsePath);
  562. browsePath.startingNode = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER);
  563. browsePath.relativePath.elements = (UA_RelativePathElement*) UA_Array_new(
  564. pathSize, &UA_TYPES[UA_TYPES_RELATIVEPATHELEMENT]);
  565. if (!browsePath.relativePath.elements)
  566. return UA_STATUSCODE_BADOUTOFMEMORY;
  567. browsePath.relativePath.elementsSize = pathSize;
  568. UA_TranslateBrowsePathsToNodeIdsRequest request;
  569. UA_TranslateBrowsePathsToNodeIdsRequest_init(&request);
  570. request.browsePaths = &browsePath;
  571. request.browsePathsSize = 1;
  572. UA_StatusCode retval = __UA_Client_AsyncService(client, &request,
  573. &UA_TYPES[UA_TYPES_TRANSLATEBROWSEPATHSTONODEIDSREQUEST], callback,
  574. &UA_TYPES[UA_TYPES_TRANSLATEBROWSEPATHSTONODEIDSRESPONSE], userdata,
  575. reqId);
  576. if (retval != UA_STATUSCODE_GOOD) {
  577. UA_Array_delete(browsePath.relativePath.elements,
  578. browsePath.relativePath.elementsSize,
  579. &UA_TYPES[UA_TYPES_RELATIVEPATHELEMENT]);
  580. return retval;
  581. }
  582. UA_BrowsePath_deleteMembers(&browsePath);
  583. return retval;
  584. }