ua_server_addressspace.c 50 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205
  1. #include "ua_server.h"
  2. #include "ua_server_internal.h"
  3. #define UA_SERVER_DELETENODEALIAS(TYPE) \
  4. UA_StatusCode UA_Server_delete##TYPE##Node(UA_Server *server, UA_NodeId nodeId) { \
  5. return UA_Server_deleteNode(server, nodeId); \
  6. }
  7. UA_StatusCode
  8. UA_Server_deleteNode(UA_Server *server, UA_NodeId nodeId) {
  9. union nodeUnion {
  10. const UA_Node *delNodeConst;
  11. UA_Node *delNode;
  12. } ptrs;
  13. ptrs.delNodeConst = UA_NodeStore_get(server->nodestore, &nodeId);
  14. if (!ptrs.delNodeConst)
  15. return UA_STATUSCODE_BADNODEIDINVALID;
  16. UA_NodeStore_release(ptrs.delNodeConst);
  17. // Remove the node from the hashmap/slot
  18. UA_NodeStore_remove(server->nodestore, &nodeId);
  19. /*
  20. * FIXME: Delete unreachable child nodes???
  21. */
  22. return UA_STATUSCODE_GOOD;
  23. }
  24. UA_SERVER_DELETENODEALIAS(Object)
  25. UA_SERVER_DELETENODEALIAS(Variable)
  26. UA_SERVER_DELETENODEALIAS(ReferenceType)
  27. UA_SERVER_DELETENODEALIAS(View)
  28. UA_SERVER_DELETENODEALIAS(VariableType)
  29. UA_SERVER_DELETENODEALIAS(DataType)
  30. #ifdef ENABLE_METHODCALLS
  31. UA_SERVER_DELETENODEALIAS(Method)
  32. #endif
  33. UA_StatusCode UA_Server_getNodeCopy(UA_Server *server, UA_NodeId nodeId, void **copyInto) {
  34. const UA_Node *node = UA_NodeStore_get(server->nodestore, &nodeId);
  35. UA_Node **copy = (UA_Node **) copyInto;
  36. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  37. if (!node)
  38. return UA_STATUSCODE_BADNODEIDINVALID;
  39. switch(node->nodeClass) {
  40. case UA_NODECLASS_DATATYPE:
  41. *copy = (UA_Node *) UA_VariableNode_new();
  42. retval |= UA_DataTypeNode_copy((const UA_DataTypeNode *) node, (UA_DataTypeNode *) *copy);
  43. break;
  44. case UA_NODECLASS_METHOD:
  45. *copy = (UA_Node *) UA_MethodNode_new();
  46. retval |= UA_MethodNode_copy((const UA_MethodNode *) node, (UA_MethodNode *) *copy);
  47. break;
  48. case UA_NODECLASS_OBJECT:
  49. *copy = (UA_Node *) UA_ObjectNode_new();
  50. retval |= UA_ObjectNode_copy((const UA_ObjectNode *) node, (UA_ObjectNode *) *copy);
  51. break;
  52. case UA_NODECLASS_OBJECTTYPE:
  53. *copy = (UA_Node *) UA_ObjectTypeNode_new();
  54. retval |= UA_ObjectTypeNode_copy((const UA_ObjectTypeNode *) node, (UA_ObjectTypeNode *) *copy);
  55. break;
  56. case UA_NODECLASS_REFERENCETYPE:
  57. *copy = (UA_Node *) UA_ReferenceTypeNode_new();
  58. retval |= UA_ReferenceTypeNode_copy((const UA_ReferenceTypeNode *) node, (UA_ReferenceTypeNode *) *copy);
  59. break;
  60. case UA_NODECLASS_VARIABLE:
  61. *copy = (UA_Node *) UA_VariableNode_new();
  62. retval |= UA_VariableNode_copy((const UA_VariableNode *) node, (UA_VariableNode *) *copy);
  63. break;
  64. case UA_NODECLASS_VARIABLETYPE:
  65. *copy = (UA_Node *) UA_VariableTypeNode_new();
  66. retval |= UA_VariableTypeNode_copy((const UA_VariableTypeNode *) node, (UA_VariableTypeNode *) *copy);
  67. break;
  68. case UA_NODECLASS_VIEW:
  69. *copy = (UA_Node *) UA_ViewNode_new();
  70. retval |= UA_ViewNode_copy((const UA_ViewNode *) node, (UA_ViewNode *) *copy);
  71. break;
  72. default:
  73. break;
  74. }
  75. UA_NodeStore_release(node);
  76. return retval;
  77. }
  78. UA_StatusCode UA_Server_deleteNodeCopy(UA_Server *server, void **nodeptr) {
  79. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  80. UA_Node **node = (UA_Node **) nodeptr;
  81. if (!(*node))
  82. return UA_STATUSCODE_BADNODEIDINVALID;
  83. switch((*node)->nodeClass) {
  84. case UA_NODECLASS_DATATYPE:
  85. UA_DataTypeNode_delete((UA_DataTypeNode *) *node);
  86. break;
  87. case UA_NODECLASS_METHOD:
  88. UA_MethodNode_delete((UA_MethodNode *) *node);
  89. break;
  90. case UA_NODECLASS_OBJECT:
  91. UA_ObjectNode_delete((UA_ObjectNode *) *node);
  92. break;
  93. case UA_NODECLASS_OBJECTTYPE:
  94. UA_ObjectTypeNode_delete((UA_ObjectTypeNode *) *node);
  95. break;
  96. case UA_NODECLASS_REFERENCETYPE:
  97. UA_ReferenceTypeNode_delete((UA_ReferenceTypeNode *) *node);
  98. break;
  99. case UA_NODECLASS_VARIABLE:
  100. UA_VariableNode_delete((UA_VariableNode *) *node);
  101. break;
  102. case UA_NODECLASS_VARIABLETYPE:
  103. UA_VariableTypeNode_delete((UA_VariableTypeNode *) *node);
  104. break;
  105. case UA_NODECLASS_VIEW:
  106. UA_ViewNode_delete((UA_ViewNode *) *node);
  107. break;
  108. default:
  109. break;
  110. }
  111. return retval;
  112. }
  113. UA_StatusCode
  114. UA_Server_forEachChildNodeCall(UA_Server *server, UA_NodeId parentNodeId, UA_NodeIteratorCallback callback, void *handle) {
  115. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  116. const UA_Node *parent = UA_NodeStore_get(server->nodestore, &parentNodeId);
  117. if (!parent)
  118. return UA_STATUSCODE_BADNODEIDINVALID;
  119. for(int i=0; i<parent->referencesSize; i++) {
  120. UA_ReferenceNode *ref = &parent->references[i];
  121. retval |= callback(ref->targetId.nodeId, ref->isInverse, ref->referenceTypeId, handle);
  122. }
  123. UA_NodeStore_release(parent);
  124. return retval;
  125. }
  126. UA_StatusCode
  127. UA_Server_addVariableNode(UA_Server *server, UA_NodeId nodeId, const UA_QualifiedName browseName,
  128. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  129. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  130. UA_Variant *value, UA_NodeId *createdNodeId) {
  131. UA_VariableNode *node = UA_VariableNode_new();
  132. UA_StatusCode retval;
  133. node->value.variant = *value; // copy content
  134. UA_NodeId_copy(&nodeId, &node->nodeId);
  135. UA_QualifiedName_copy(&browseName, &node->browseName);
  136. UA_LocalizedText_copy(&displayName, &node->displayName);
  137. UA_LocalizedText_copy(&description, &node->description);
  138. node->writeMask = writeMask;
  139. node->userWriteMask = userWriteMask;
  140. UA_ExpandedNodeId parentId;
  141. UA_ExpandedNodeId_init(&parentId);
  142. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  143. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  144. parentId, referenceTypeId);
  145. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  146. UA_EXPANDEDNODEID_NUMERIC(0, value->type->typeId.identifier.numeric));
  147. if(res.statusCode != UA_STATUSCODE_GOOD) {
  148. UA_Variant_init(&node->value.variant);
  149. UA_VariableNode_delete(node);
  150. } else
  151. UA_free(value);
  152. retval = res.statusCode;
  153. if (createdNodeId != UA_NULL)
  154. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  155. UA_AddNodesResult_deleteMembers(&res);
  156. return retval ;
  157. }
  158. UA_StatusCode
  159. UA_Server_addObjectNode(UA_Server *server, UA_NodeId nodeId, const UA_QualifiedName browseName,
  160. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  161. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask,
  162. UA_UInt32 writeMask, const UA_ExpandedNodeId typeDefinition, UA_NodeId *createdNodeId) {
  163. UA_ObjectNode *node = UA_ObjectNode_new();
  164. UA_StatusCode retval;
  165. UA_NodeId_copy(&nodeId, &node->nodeId);
  166. UA_QualifiedName_copy(&browseName, &node->browseName);
  167. UA_LocalizedText_copy(&displayName, &node->displayName);
  168. UA_LocalizedText_copy(&description, &node->description);
  169. node->writeMask = writeMask;
  170. node->userWriteMask = userWriteMask;
  171. UA_ExpandedNodeId parentId; // we need an expandednodeid
  172. UA_ExpandedNodeId_init(&parentId);
  173. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  174. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  175. parentId, referenceTypeId);
  176. if(res.statusCode != UA_STATUSCODE_GOOD)
  177. UA_ObjectNode_delete(node);
  178. retval = res.statusCode;
  179. if (createdNodeId != UA_NULL)
  180. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  181. UA_AddNodesResult_deleteMembers(&res);
  182. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  183. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  184. }
  185. return retval;
  186. }
  187. UA_StatusCode
  188. UA_Server_addDataSourceVariableNode(UA_Server *server, UA_DataSource dataSource,
  189. const UA_QualifiedName browseName, UA_NodeId nodeId,
  190. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  191. UA_NodeId *createdNodeId) {
  192. UA_VariableNode *node = UA_VariableNode_new();
  193. UA_StatusCode retval;
  194. node->valueSource = UA_VALUESOURCE_DATASOURCE;
  195. node->value.dataSource = dataSource;
  196. UA_NodeId_copy(&nodeId, &node->nodeId);
  197. UA_QualifiedName_copy(&browseName, &node->browseName);
  198. UA_String_copy(&browseName.name, &node->displayName.text);
  199. UA_ExpandedNodeId parentId; // dummy exapndednodeid
  200. UA_ExpandedNodeId_init(&parentId);
  201. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  202. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  203. parentId, referenceTypeId);
  204. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  205. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE));
  206. if(res.statusCode != UA_STATUSCODE_GOOD)
  207. UA_VariableNode_delete(node);
  208. retval = res.statusCode;
  209. if (createdNodeId != UA_NULL)
  210. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  211. UA_AddNodesResult_deleteMembers(&res);
  212. return retval;
  213. }
  214. UA_StatusCode
  215. UA_Server_addVariableTypeNode(UA_Server *server, UA_NodeId nodeId, const UA_QualifiedName browseName,
  216. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  217. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  218. UA_Variant *value, UA_Int32 valueRank, UA_Boolean isAbstract, UA_NodeId *createdNodeId) {
  219. UA_VariableTypeNode *node = UA_VariableTypeNode_new();
  220. UA_StatusCode retval;
  221. node->value.variant = *value; // copy content
  222. UA_NodeId_copy(&nodeId, &node->nodeId);
  223. UA_QualifiedName_copy(&browseName, &node->browseName);
  224. UA_LocalizedText_copy(&displayName, &node->displayName);
  225. UA_LocalizedText_copy(&description, &node->description);
  226. node->writeMask = writeMask;
  227. node->userWriteMask = userWriteMask;
  228. UA_ExpandedNodeId parentId;
  229. UA_ExpandedNodeId_init(&parentId);
  230. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  231. node->isAbstract = isAbstract;
  232. node->valueRank = valueRank;
  233. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  234. parentId, referenceTypeId);
  235. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  236. UA_EXPANDEDNODEID_NUMERIC(0, value->type->typeId.identifier.numeric));
  237. if(res.statusCode != UA_STATUSCODE_GOOD) {
  238. UA_Variant_init(&node->value.variant);
  239. UA_VariableTypeNode_delete(node);
  240. } else
  241. UA_free(value);
  242. retval = res.statusCode;
  243. if (createdNodeId != UA_NULL)
  244. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  245. UA_AddNodesResult_deleteMembers(&res);
  246. return retval ;
  247. }
  248. UA_StatusCode
  249. UA_Server_addDataTypeNode(UA_Server *server, UA_NodeId nodeId, const UA_QualifiedName browseName,
  250. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  251. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  252. UA_ExpandedNodeId typeDefinition, UA_Boolean isAbstract, UA_NodeId *createdNodeId) {
  253. UA_DataTypeNode *node = UA_DataTypeNode_new();
  254. UA_StatusCode retval;
  255. UA_NodeId_copy(&nodeId, &node->nodeId);
  256. UA_QualifiedName_copy(&browseName, &node->browseName);
  257. UA_LocalizedText_copy(&displayName, &node->displayName);
  258. UA_LocalizedText_copy(&description, &node->description);
  259. node->writeMask = writeMask;
  260. node->userWriteMask = userWriteMask;
  261. UA_ExpandedNodeId parentId; // we need an expandednodeid
  262. UA_ExpandedNodeId_init(&parentId);
  263. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  264. node->isAbstract = isAbstract;
  265. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  266. parentId, referenceTypeId);
  267. if(res.statusCode != UA_STATUSCODE_GOOD)
  268. UA_DataTypeNode_delete(node);
  269. retval = res.statusCode;
  270. if (createdNodeId != UA_NULL)
  271. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  272. UA_AddNodesResult_deleteMembers(&res);
  273. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  274. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  275. }
  276. return retval;
  277. }
  278. UA_StatusCode
  279. UA_Server_addViewNode(UA_Server *server, UA_NodeId nodeId, const UA_QualifiedName browseName,
  280. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  281. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  282. UA_ExpandedNodeId typeDefinition, UA_NodeId *createdNodeId) {
  283. UA_ViewNode *node = UA_ViewNode_new();
  284. UA_StatusCode retval;
  285. UA_NodeId_copy(&nodeId, &node->nodeId);
  286. UA_QualifiedName_copy(&browseName, &node->browseName);
  287. UA_LocalizedText_copy(&displayName, &node->displayName);
  288. UA_LocalizedText_copy(&description, &node->description);
  289. node->writeMask = writeMask;
  290. node->userWriteMask = userWriteMask;
  291. UA_ExpandedNodeId parentId; // we need an expandednodeid
  292. UA_ExpandedNodeId_init(&parentId);
  293. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  294. node->containsNoLoops = UA_TRUE;
  295. node->eventNotifier = 0;
  296. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  297. parentId, referenceTypeId);
  298. if(res.statusCode != UA_STATUSCODE_GOOD)
  299. UA_ViewNode_delete(node);
  300. retval = res.statusCode;
  301. if (createdNodeId != UA_NULL)
  302. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  303. UA_AddNodesResult_deleteMembers(&res);
  304. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  305. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  306. }
  307. return retval;
  308. }
  309. UA_StatusCode UA_Server_addReferenceTypeNode (UA_Server *server, UA_NodeId nodeId, UA_QualifiedName browseName,
  310. UA_LocalizedText displayName, UA_LocalizedText description, UA_NodeId parentNodeId,
  311. UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  312. UA_ExpandedNodeId typeDefinition, UA_LocalizedText inverseName,
  313. UA_NodeId *createdNodeId ){
  314. UA_ReferenceTypeNode *node = UA_ReferenceTypeNode_new();
  315. UA_StatusCode retval;
  316. UA_NodeId_copy(&nodeId, &node->nodeId);
  317. UA_QualifiedName_copy(&browseName, &node->browseName);
  318. UA_LocalizedText_copy(&displayName, &node->displayName);
  319. UA_LocalizedText_copy(&description, &node->description);
  320. node->writeMask = writeMask;
  321. node->userWriteMask = userWriteMask;
  322. UA_ExpandedNodeId parentId; // we need an expandednodeid
  323. UA_ExpandedNodeId_init(&parentId);
  324. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  325. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  326. parentId, referenceTypeId);
  327. if(res.statusCode != UA_STATUSCODE_GOOD)
  328. UA_ReferenceTypeNode_delete(node);
  329. retval = res.statusCode;
  330. if (createdNodeId != UA_NULL)
  331. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  332. UA_AddNodesResult_deleteMembers(&res);
  333. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  334. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  335. }
  336. return retval;
  337. }
  338. UA_StatusCode UA_Server_addObjectTypeNode ( UA_Server *server, UA_NodeId nodeId, UA_QualifiedName browseName,
  339. UA_LocalizedText displayName, UA_LocalizedText description, UA_NodeId parentNodeId,
  340. UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  341. UA_ExpandedNodeId typeDefinition, UA_Boolean isAbstract,
  342. UA_NodeId *createdNodeId ){
  343. UA_ObjectTypeNode *node = UA_ObjectTypeNode_new();
  344. UA_StatusCode retval;
  345. UA_NodeId_copy(&nodeId, &node->nodeId);
  346. UA_QualifiedName_copy(&browseName, &node->browseName);
  347. UA_LocalizedText_copy(&displayName, &node->displayName);
  348. UA_LocalizedText_copy(&description, &node->description);
  349. node->writeMask = writeMask;
  350. node->userWriteMask = userWriteMask;
  351. UA_ExpandedNodeId parentId; // we need an expandednodeid
  352. UA_ExpandedNodeId_init(&parentId);
  353. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  354. node->isAbstract = isAbstract;
  355. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  356. parentId, referenceTypeId);
  357. if(res.statusCode != UA_STATUSCODE_GOOD)
  358. UA_ObjectTypeNode_delete(node);
  359. retval = res.statusCode;
  360. if (createdNodeId != UA_NULL)
  361. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  362. UA_AddNodesResult_deleteMembers(&res);
  363. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  364. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  365. }
  366. return retval;
  367. }
  368. /* Userspace Version of addOneWayReferenceWithSession*/
  369. UA_StatusCode
  370. UA_Server_AddMonodirectionalReference(UA_Server *server, UA_NodeId sourceNodeId, UA_ExpandedNodeId targetNodeId,
  371. UA_NodeId referenceTypeId, UA_Boolean isforward) {
  372. UA_AddReferencesItem ref;
  373. UA_AddReferencesItem_init(&ref);
  374. UA_StatusCode retval = UA_NodeId_copy(&sourceNodeId, &ref.sourceNodeId);
  375. retval |= UA_ExpandedNodeId_copy(&targetNodeId, &ref.targetNodeId);
  376. retval |= UA_NodeId_copy(&referenceTypeId, &ref.referenceTypeId);
  377. if(retval != UA_STATUSCODE_GOOD)
  378. goto cleanup;
  379. const UA_Node *target = UA_NodeStore_get(server->nodestore, &ref.targetNodeId.nodeId);
  380. if(!target) {
  381. retval = UA_STATUSCODE_BADNODEIDINVALID;
  382. goto cleanup;
  383. }
  384. if(isforward == UA_TRUE)
  385. ref.isForward = UA_TRUE;
  386. ref.targetNodeClass = target->nodeClass;
  387. UA_NodeStore_release(target);
  388. retval = addOneWayReferenceWithSession(server, (UA_Session *) UA_NULL, &ref);
  389. cleanup:
  390. UA_AddReferencesItem_deleteMembers(&ref);
  391. return retval;
  392. }
  393. /* Adds a one-way reference to the local nodestore */
  394. UA_StatusCode
  395. addOneWayReferenceWithSession(UA_Server *server, UA_Session *session, const UA_AddReferencesItem *item) {
  396. const UA_Node *node = UA_NodeStore_get(server->nodestore, &item->sourceNodeId);
  397. if(!node)
  398. return UA_STATUSCODE_BADINTERNALERROR;
  399. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  400. #ifndef UA_MULTITHREADING
  401. size_t i = node->referencesSize;
  402. if(node->referencesSize < 0)
  403. i = 0;
  404. size_t refssize = (i+1) | 3; // so the realloc is not necessary every time
  405. UA_ReferenceNode *new_refs = UA_realloc(node->references, sizeof(UA_ReferenceNode) * refssize);
  406. if(!new_refs)
  407. retval = UA_STATUSCODE_BADOUTOFMEMORY;
  408. else {
  409. UA_ReferenceNode_init(&new_refs[i]);
  410. retval = UA_NodeId_copy(&item->referenceTypeId, &new_refs[i].referenceTypeId);
  411. new_refs[i].isInverse = !item->isForward;
  412. retval |= UA_ExpandedNodeId_copy(&item->targetNodeId, &new_refs[i].targetId);
  413. /* hack. be careful! possible only in the single-threaded case. */
  414. UA_Node *mutable_node = (UA_Node*)(uintptr_t)node;
  415. mutable_node->references = new_refs;
  416. if(retval != UA_STATUSCODE_GOOD) {
  417. UA_NodeId_deleteMembers(&new_refs[node->referencesSize].referenceTypeId);
  418. UA_ExpandedNodeId_deleteMembers(&new_refs[node->referencesSize].targetId);
  419. } else
  420. mutable_node->referencesSize = i+1;
  421. }
  422. UA_NodeStore_release(node);
  423. return retval;
  424. #else
  425. UA_Node *newNode = UA_NULL;
  426. void (*deleteNode)(UA_Node*) = UA_NULL;
  427. switch(node->nodeClass) {
  428. case UA_NODECLASS_OBJECT:
  429. newNode = (UA_Node*)UA_ObjectNode_new();
  430. UA_ObjectNode_copy((const UA_ObjectNode*)node, (UA_ObjectNode*)newNode);
  431. deleteNode = (void (*)(UA_Node*))UA_ObjectNode_delete;
  432. break;
  433. case UA_NODECLASS_VARIABLE:
  434. newNode = (UA_Node*)UA_VariableNode_new();
  435. UA_VariableNode_copy((const UA_VariableNode*)node, (UA_VariableNode*)newNode);
  436. deleteNode = (void (*)(UA_Node*))UA_VariableNode_delete;
  437. break;
  438. case UA_NODECLASS_METHOD:
  439. newNode = (UA_Node*)UA_MethodNode_new();
  440. UA_MethodNode_copy((const UA_MethodNode*)node, (UA_MethodNode*)newNode);
  441. deleteNode = (void (*)(UA_Node*))UA_MethodNode_delete;
  442. break;
  443. case UA_NODECLASS_OBJECTTYPE:
  444. newNode = (UA_Node*)UA_ObjectTypeNode_new();
  445. UA_ObjectTypeNode_copy((const UA_ObjectTypeNode*)node, (UA_ObjectTypeNode*)newNode);
  446. deleteNode = (void (*)(UA_Node*))UA_ObjectTypeNode_delete;
  447. break;
  448. case UA_NODECLASS_VARIABLETYPE:
  449. newNode = (UA_Node*)UA_VariableTypeNode_new();
  450. UA_VariableTypeNode_copy((const UA_VariableTypeNode*)node, (UA_VariableTypeNode*)newNode);
  451. deleteNode = (void (*)(UA_Node*))UA_VariableTypeNode_delete;
  452. break;
  453. case UA_NODECLASS_REFERENCETYPE:
  454. newNode = (UA_Node*)UA_ReferenceTypeNode_new();
  455. UA_ReferenceTypeNode_copy((const UA_ReferenceTypeNode*)node, (UA_ReferenceTypeNode*)newNode);
  456. deleteNode = (void (*)(UA_Node*))UA_ReferenceTypeNode_delete;
  457. break;
  458. case UA_NODECLASS_DATATYPE:
  459. newNode = (UA_Node*)UA_DataTypeNode_new();
  460. UA_DataTypeNode_copy((const UA_DataTypeNode*)node, (UA_DataTypeNode*)newNode);
  461. deleteNode = (void (*)(UA_Node*))UA_DataTypeNode_delete;
  462. break;
  463. case UA_NODECLASS_VIEW:
  464. newNode = (UA_Node*)UA_ViewNode_new();
  465. UA_ViewNode_copy((const UA_ViewNode*)node, (UA_ViewNode*)newNode);
  466. deleteNode = (void (*)(UA_Node*))UA_ViewNode_delete;
  467. break;
  468. default:
  469. return UA_STATUSCODE_BADINTERNALERROR;
  470. }
  471. UA_Int32 count = node->referencesSize;
  472. if(count < 0)
  473. count = 0;
  474. UA_ReferenceNode *old_refs = newNode->references;
  475. UA_ReferenceNode *new_refs = UA_malloc(sizeof(UA_ReferenceNode)*(count+1));
  476. if(!new_refs) {
  477. deleteNode(newNode);
  478. UA_NodeStore_release(node);
  479. return UA_STATUSCODE_BADOUTOFMEMORY;
  480. }
  481. // insert the new reference
  482. UA_memcpy(new_refs, old_refs, sizeof(UA_ReferenceNode)*count);
  483. UA_ReferenceNode_init(&new_refs[count]);
  484. retval = UA_NodeId_copy(&item->referenceTypeId, &new_refs[count].referenceTypeId);
  485. new_refs[count].isInverse = !item->isForward;
  486. retval |= UA_ExpandedNodeId_copy(&item->targetNodeId, &new_refs[count].targetId);
  487. if(retval != UA_STATUSCODE_GOOD) {
  488. UA_Array_delete(new_refs, &UA_TYPES[UA_TYPES_REFERENCENODE], ++count);
  489. newNode->references = UA_NULL;
  490. newNode->referencesSize = 0;
  491. deleteNode(newNode);
  492. UA_NodeStore_release(node);
  493. return UA_STATUSCODE_BADOUTOFMEMORY;
  494. }
  495. UA_free(old_refs);
  496. newNode->references = new_refs;
  497. newNode->referencesSize = ++count;
  498. retval = UA_NodeStore_replace(server->nodestore, node, newNode, UA_NULL);
  499. UA_NodeStore_release(node);
  500. if(retval == UA_STATUSCODE_BADINTERNALERROR) {
  501. /* presumably because the node was replaced and an old version was updated at the same time.
  502. just try again */
  503. deleteNode(newNode);
  504. return addOneWayReferenceWithSession(server, session, item);
  505. }
  506. return retval;
  507. #endif
  508. }
  509. UA_StatusCode deleteOneWayReferenceWithSession(UA_Server *server, UA_Session *session, const UA_DeleteReferencesItem *item) {
  510. UA_Node *node = UA_NULL;
  511. UA_StatusCode retval = UA_Server_getNodeCopy(server, item->sourceNodeId, (void *) &node);
  512. if (!node)
  513. return retval;
  514. // Copy all that do not target the targetNode in a new array
  515. UA_ReferenceNode *newRefs = (UA_ReferenceNode*) UA_malloc(sizeof(UA_ReferenceNode) * node->referencesSize);
  516. UA_UInt32 newRefCount = 0;
  517. for(int refn = 0; refn < node->referencesSize; refn++) {
  518. // Completely different target node:
  519. if (!UA_NodeId_equal(&item->targetNodeId.nodeId, &node->references[refn].targetId.nodeId)) {
  520. UA_ReferenceNode_copy(&node->references[refn], &newRefs[newRefCount]);
  521. newRefCount++;
  522. }
  523. else {
  524. // Correct target node, wrong referenceType
  525. if (!UA_NodeId_equal(&item->referenceTypeId, &node->references[refn].referenceTypeId)) {
  526. UA_ReferenceNode_copy(&node->references[refn], &newRefs[newRefCount]);
  527. newRefCount++;
  528. }
  529. else {
  530. // Correct target, correct referenceType, wrong direction
  531. // FIXME: Check semantics of deleteBidirectional: does it mean we delete any forward or inverse refs
  532. // in this node (assumed here) OR does it mean we remove Invers refs from target node??
  533. if (item->deleteBidirectional == UA_FALSE && (item->isForward != node->references[refn].isInverse)) {
  534. UA_ReferenceNode_copy(&node->references[refn], &newRefs[newRefCount]);
  535. newRefCount++;
  536. }
  537. // else... everything matches, don't copy this node into the new reference array.
  538. }
  539. }
  540. }
  541. // Reallocate
  542. UA_ReferenceNode *tmp = UA_realloc(newRefs, sizeof(UA_ReferenceNode) * newRefCount);
  543. if (!tmp) {
  544. if (newRefCount > 0)
  545. UA_free(newRefs); //realloc with zero size is equal to free!
  546. UA_Server_deleteNodeCopy(server, (void *) &node);
  547. return UA_STATUSCODE_BADOUTOFMEMORY;
  548. }
  549. newRefs = tmp;
  550. // Swap old references in node for new ones, then free old array
  551. tmp = node->references;
  552. node->referencesSize = newRefCount;
  553. node->references = newRefs;
  554. if (tmp)
  555. UA_free(tmp);
  556. const UA_Node *inserted;
  557. retval |= UA_NodeStore_replace(server->nodestore, (const UA_Node *) node, node, &inserted);
  558. return retval;
  559. }
  560. /* userland version of addReferenceWithSession */
  561. UA_StatusCode UA_Server_addReference(UA_Server *server, const UA_NodeId sourceId, const UA_NodeId refTypeId,
  562. const UA_ExpandedNodeId targetId) {
  563. UA_AddReferencesItem item;
  564. UA_AddReferencesItem_init(&item);
  565. item.sourceNodeId = sourceId;
  566. item.referenceTypeId = refTypeId;
  567. item.isForward = UA_TRUE;
  568. item.targetNodeId = targetId;
  569. return UA_Server_addReferenceWithSession(server, &adminSession, &item);
  570. }
  571. UA_StatusCode UA_Server_addReferenceWithSession(UA_Server *server, UA_Session *session,
  572. const UA_AddReferencesItem *item) {
  573. if(item->targetServerUri.length > 0)
  574. return UA_STATUSCODE_BADNOTIMPLEMENTED; // currently no expandednodeids are allowed
  575. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  576. #ifdef UA_EXTERNAL_NAMESPACES
  577. UA_ExternalNodeStore *ensFirst = UA_NULL;
  578. UA_ExternalNodeStore *ensSecond = UA_NULL;
  579. for(size_t j = 0;j<server->externalNamespacesSize && (!ensFirst || !ensSecond);j++) {
  580. if(item->sourceNodeId.namespaceIndex == server->externalNamespaces[j].index)
  581. ensFirst = &server->externalNamespaces[j].externalNodeStore;
  582. if(item->targetNodeId.nodeId.namespaceIndex == server->externalNamespaces[j].index)
  583. ensSecond = &server->externalNamespaces[j].externalNodeStore;
  584. }
  585. if(ensFirst) {
  586. // todo: use external nodestore
  587. } else
  588. #endif
  589. retval = addOneWayReferenceWithSession(server, session, item);
  590. if(retval)
  591. return retval;
  592. UA_AddReferencesItem secondItem;
  593. secondItem = *item;
  594. secondItem.targetNodeId.nodeId = item->sourceNodeId;
  595. secondItem.sourceNodeId = item->targetNodeId.nodeId;
  596. secondItem.isForward = !item->isForward;
  597. #ifdef UA_EXTERNAL_NAMESPACES
  598. if(ensSecond) {
  599. // todo: use external nodestore
  600. } else
  601. #endif
  602. retval = addOneWayReferenceWithSession (server, session, &secondItem);
  603. // todo: remove reference if the second direction failed
  604. return retval;
  605. }
  606. /* userland version of addNodeWithSession */
  607. UA_AddNodesResult
  608. UA_Server_addNode(UA_Server *server, UA_Node *node, const UA_ExpandedNodeId parentNodeId,
  609. const UA_NodeId referenceTypeId) {
  610. return UA_Server_addNodeWithSession(server, &adminSession, node, parentNodeId, referenceTypeId);
  611. }
  612. UA_AddNodesResult
  613. UA_Server_addNodeWithSession(UA_Server *server, UA_Session *session, UA_Node *node,
  614. const UA_ExpandedNodeId parentNodeId, const UA_NodeId referenceTypeId) {
  615. UA_AddNodesResult result;
  616. UA_AddNodesResult_init(&result);
  617. if(node->nodeId.namespaceIndex >= server->namespacesSize) {
  618. result.statusCode = UA_STATUSCODE_BADNODEIDINVALID;
  619. return result;
  620. }
  621. const UA_Node *parent = UA_NodeStore_get(server->nodestore, &parentNodeId.nodeId);
  622. if(!parent) {
  623. result.statusCode = UA_STATUSCODE_BADPARENTNODEIDINVALID;
  624. return result;
  625. }
  626. const UA_ReferenceTypeNode *referenceType =
  627. (const UA_ReferenceTypeNode *)UA_NodeStore_get(server->nodestore, &referenceTypeId);
  628. if(!referenceType) {
  629. result.statusCode = UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  630. goto ret;
  631. }
  632. if(referenceType->nodeClass != UA_NODECLASS_REFERENCETYPE) {
  633. result.statusCode = UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  634. goto ret2;
  635. }
  636. if(referenceType->isAbstract == UA_TRUE) {
  637. result.statusCode = UA_STATUSCODE_BADREFERENCENOTALLOWED;
  638. goto ret2;
  639. }
  640. // todo: test if the referencetype is hierarchical
  641. //FIXME: a bit dirty workaround of preserving namespace
  642. //namespace index is assumed to be valid
  643. const UA_Node *managed = UA_NULL;
  644. UA_NodeId tempNodeid;
  645. UA_NodeId_init(&tempNodeid);
  646. UA_NodeId_copy(&node->nodeId, &tempNodeid);
  647. tempNodeid.namespaceIndex = 0;
  648. if(UA_NodeId_isNull(&tempNodeid)) {
  649. if(UA_NodeStore_insert(server->nodestore, node, &managed) != UA_STATUSCODE_GOOD) {
  650. result.statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  651. goto ret2;
  652. }
  653. result.addedNodeId = managed->nodeId; // cannot fail as unique nodeids are numeric
  654. } else {
  655. if(UA_NodeId_copy(&node->nodeId, &result.addedNodeId) != UA_STATUSCODE_GOOD) {
  656. result.statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  657. goto ret2;
  658. }
  659. if(UA_NodeStore_insert(server->nodestore, node, &managed) != UA_STATUSCODE_GOOD) {
  660. result.statusCode = UA_STATUSCODE_BADNODEIDEXISTS; // todo: differentiate out of memory
  661. UA_NodeId_deleteMembers(&result.addedNodeId);
  662. goto ret2;
  663. }
  664. }
  665. // reference back to the parent
  666. UA_AddReferencesItem item;
  667. UA_AddReferencesItem_init(&item);
  668. item.sourceNodeId = managed->nodeId;
  669. item.referenceTypeId = referenceType->nodeId;
  670. item.isForward = UA_FALSE;
  671. item.targetNodeId.nodeId = parent->nodeId;
  672. UA_Server_addReferenceWithSession(server, session, &item);
  673. // todo: error handling. remove new node from nodestore
  674. UA_NodeStore_release(managed);
  675. ret2:
  676. UA_NodeId_deleteMembers(&tempNodeid);
  677. UA_NodeStore_release((const UA_Node*)referenceType);
  678. ret:
  679. UA_NodeStore_release(parent);
  680. return result;
  681. }
  682. #ifdef ENABLE_METHODCALLS
  683. UA_StatusCode
  684. UA_Server_addMethodNode(UA_Server* server, UA_NodeId nodeId, const UA_QualifiedName browseName,
  685. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  686. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  687. UA_MethodCallback method, UA_Int32 inputArgumentsSize, const UA_Argument* inputArguments,
  688. UA_Int32 outputArgumentsSize, const UA_Argument* outputArguments,
  689. UA_NodeId* createdNodeId) {
  690. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  691. UA_MethodNode *newMethod = UA_MethodNode_new();
  692. UA_NodeId_copy(&nodeId, &newMethod->nodeId);
  693. UA_QualifiedName_copy(&browseName, &newMethod->browseName);
  694. UA_LocalizedText_copy(&displayName, &newMethod->displayName);
  695. UA_LocalizedText_copy(&description, &newMethod->description);
  696. newMethod->writeMask = writeMask;
  697. newMethod->userWriteMask = userWriteMask;
  698. newMethod->attachedMethod = method;
  699. newMethod->executable = UA_TRUE;
  700. newMethod->userExecutable = UA_TRUE;
  701. UA_ExpandedNodeId parentExpandedNodeId;
  702. UA_ExpandedNodeId_init(&parentExpandedNodeId);
  703. UA_NodeId_copy(&parentNodeId, &parentExpandedNodeId.nodeId);
  704. UA_AddNodesResult addRes = UA_Server_addNode(server, (UA_Node*)newMethod, parentExpandedNodeId, referenceTypeId);
  705. retval |= addRes.statusCode;
  706. if(retval!= UA_STATUSCODE_GOOD) {
  707. UA_MethodNode_delete(newMethod);
  708. return retval;
  709. }
  710. UA_ExpandedNodeId methodExpandedNodeId;
  711. UA_ExpandedNodeId_init(&methodExpandedNodeId);
  712. UA_NodeId_copy(&addRes.addedNodeId, &methodExpandedNodeId.nodeId);
  713. if (createdNodeId != UA_NULL)
  714. UA_NodeId_copy(&addRes.addedNodeId, createdNodeId);
  715. /* Only proceed with creating in/outputArguments if the method and both arguments are not
  716. * UA_NULL; otherwise this is a pretty strong indicator that this node was generated,
  717. * in which case these arguments will be created later and individually.
  718. */
  719. if (method == UA_NULL && inputArguments == UA_NULL && outputArguments == UA_NULL && inputArgumentsSize == 0 && outputArgumentsSize == 0)
  720. return retval;
  721. /* create InputArguments */
  722. UA_NodeId argId = UA_NODEID_NUMERIC(nodeId.namespaceIndex, 0);
  723. UA_VariableNode *inputArgumentsVariableNode = UA_VariableNode_new();
  724. retval |= UA_NodeId_copy(&argId, &inputArgumentsVariableNode->nodeId);
  725. inputArgumentsVariableNode->browseName = UA_QUALIFIEDNAME_ALLOC(0,"InputArguments");
  726. inputArgumentsVariableNode->displayName = UA_LOCALIZEDTEXT_ALLOC("en_US", "InputArguments");
  727. inputArgumentsVariableNode->description = UA_LOCALIZEDTEXT_ALLOC("en_US", "InputArguments");
  728. inputArgumentsVariableNode->valueRank = 1;
  729. UA_Variant_setArrayCopy(&inputArgumentsVariableNode->value.variant, inputArguments,
  730. inputArgumentsSize, &UA_TYPES[UA_TYPES_ARGUMENT]);
  731. addRes = UA_Server_addNode(server, (UA_Node*)inputArgumentsVariableNode, methodExpandedNodeId,
  732. UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY));
  733. if(addRes.statusCode != UA_STATUSCODE_GOOD) {
  734. UA_ExpandedNodeId_deleteMembers(&methodExpandedNodeId);
  735. // TODO Remove node
  736. return addRes.statusCode;
  737. }
  738. if (createdNodeId != UA_NULL)
  739. UA_NodeId_copy(&addRes.addedNodeId, createdNodeId);
  740. /* create OutputArguments */
  741. argId = UA_NODEID_NUMERIC(nodeId.namespaceIndex, 0);
  742. UA_VariableNode *outputArgumentsVariableNode = UA_VariableNode_new();
  743. retval |= UA_NodeId_copy(&argId, &outputArgumentsVariableNode->nodeId);
  744. outputArgumentsVariableNode->browseName = UA_QUALIFIEDNAME_ALLOC(0,"OutputArguments");
  745. outputArgumentsVariableNode->displayName = UA_LOCALIZEDTEXT_ALLOC("en_US", "OutputArguments");
  746. outputArgumentsVariableNode->description = UA_LOCALIZEDTEXT_ALLOC("en_US", "OutputArguments");
  747. outputArgumentsVariableNode->valueRank = 1;
  748. UA_Variant_setArrayCopy(&outputArgumentsVariableNode->value.variant, outputArguments,
  749. outputArgumentsSize, &UA_TYPES[UA_TYPES_ARGUMENT]);
  750. addRes = UA_Server_addNode(server, (UA_Node*)outputArgumentsVariableNode, methodExpandedNodeId,
  751. UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY));
  752. UA_ExpandedNodeId_deleteMembers(&methodExpandedNodeId);
  753. if(addRes.statusCode != UA_STATUSCODE_GOOD)
  754. // TODO Remove node
  755. retval = addRes.statusCode;
  756. return retval;
  757. }
  758. #endif
  759. #define SETATTRIBUTE_ASSERTNODECLASS(CLASS) { \
  760. if ((anyTypeNode.node->nodeClass & ( CLASS )) == 0) { \
  761. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node); \
  762. return UA_STATUSCODE_BADNODECLASSINVALID; \
  763. } \
  764. }
  765. #define SETATTRIBUTE_ASSERTTYPECORRECT(TYPE) { \
  766. UA_NodeId expectedType = UA_NODEID_NUMERIC(0, UA_NS0ID_##TYPE); \
  767. if (!UA_NodeId_equal(&dataType->typeId, &expectedType)) { \
  768. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node); \
  769. return UA_STATUSCODE_BADTYPEMISMATCH; \
  770. } \
  771. }\
  772. UA_StatusCode UA_Server_setAttributeValue(UA_Server *server, UA_NodeId nodeId, UA_AttributeId attributeId, void *value) {
  773. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  774. if (!value)
  775. return UA_STATUSCODE_BADNOTHINGTODO;
  776. union {
  777. UA_Node *node;
  778. UA_ObjectNode *oObj;
  779. UA_ObjectTypeNode *otObj;
  780. UA_VariableNode *vObj;
  781. UA_VariableTypeNode *vtObj;
  782. UA_ReferenceTypeNode *rtObj;
  783. UA_MethodNode *mObj;
  784. UA_DataTypeNode *dtObj;
  785. UA_ViewNode *vwObj;
  786. } anyTypeNode;
  787. retval = UA_Server_getNodeCopy(server, nodeId, (void **) &anyTypeNode.node);
  788. if (retval)
  789. return retval;
  790. UA_UInt32 *nInt;
  791. UA_Boolean *nBool;
  792. UA_Byte *nByte;
  793. UA_Variant *nVariant;
  794. UA_Double *nDouble;
  795. switch(attributeId) {
  796. case UA_ATTRIBUTEID_NODEID:
  797. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  798. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  799. break;
  800. case UA_ATTRIBUTEID_NODECLASS:
  801. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  802. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  803. break;
  804. case UA_ATTRIBUTEID_BROWSENAME:
  805. UA_QualifiedName_deleteMembers(&anyTypeNode.node->browseName);
  806. UA_QualifiedName_copy((UA_QualifiedName *) value, &anyTypeNode.node->browseName);
  807. break;
  808. case UA_ATTRIBUTEID_DISPLAYNAME:
  809. UA_LocalizedText_deleteMembers(&anyTypeNode.node->displayName);
  810. UA_LocalizedText_copy((UA_LocalizedText *) value, &anyTypeNode.node->displayName);
  811. break;
  812. case UA_ATTRIBUTEID_DESCRIPTION:
  813. UA_LocalizedText_deleteMembers(&anyTypeNode.node->description);
  814. UA_LocalizedText_copy((UA_LocalizedText *) value, &anyTypeNode.node->description);
  815. break;
  816. case UA_ATTRIBUTEID_WRITEMASK:
  817. nInt = (UA_UInt32*) value;
  818. anyTypeNode.node->writeMask = *nInt;
  819. break;
  820. case UA_ATTRIBUTEID_USERWRITEMASK:
  821. nInt = (UA_UInt32*) value;
  822. anyTypeNode.node->userWriteMask = *nInt;
  823. break;
  824. case UA_ATTRIBUTEID_ISABSTRACT:
  825. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_OBJECTTYPE | UA_NODECLASS_REFERENCETYPE | UA_NODECLASS_VARIABLETYPE | UA_NODECLASS_DATATYPE)
  826. nBool = (UA_Boolean *) value;
  827. switch(anyTypeNode.node->nodeClass) {
  828. case UA_NODECLASS_OBJECTTYPE:
  829. anyTypeNode.otObj->isAbstract = *nBool;
  830. break;
  831. case UA_NODECLASS_REFERENCETYPE:
  832. anyTypeNode.rtObj->isAbstract = *nBool;
  833. break;
  834. case UA_NODECLASS_VARIABLETYPE:
  835. anyTypeNode.vtObj->isAbstract = *nBool;
  836. break;
  837. case UA_NODECLASS_DATATYPE:
  838. anyTypeNode.dtObj->isAbstract = *nBool;
  839. break;
  840. default:
  841. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  842. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  843. break;
  844. }
  845. break;
  846. case UA_ATTRIBUTEID_SYMMETRIC:
  847. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_REFERENCETYPE)
  848. nBool = (UA_Boolean *) value;
  849. anyTypeNode.rtObj->symmetric = *nBool;
  850. break;
  851. case UA_ATTRIBUTEID_INVERSENAME:
  852. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_REFERENCETYPE)
  853. UA_LocalizedText_deleteMembers(&anyTypeNode.rtObj->inverseName);
  854. UA_LocalizedText_copy((UA_LocalizedText *) value, &anyTypeNode.rtObj->inverseName);
  855. break;
  856. case UA_ATTRIBUTEID_CONTAINSNOLOOPS:
  857. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VIEW)
  858. nBool = (UA_Boolean *) value;
  859. anyTypeNode.vwObj->containsNoLoops = *nBool;
  860. break;
  861. case UA_ATTRIBUTEID_EVENTNOTIFIER:
  862. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VIEW | UA_NODECLASS_OBJECT)
  863. nByte = (UA_Byte *) value;
  864. switch(anyTypeNode.node->nodeClass) {
  865. case UA_NODECLASS_VIEW:
  866. anyTypeNode.vwObj->eventNotifier = *nByte;
  867. break;
  868. case UA_NODECLASS_OBJECT:
  869. anyTypeNode.oObj->eventNotifier = *nByte;
  870. break;
  871. default:
  872. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  873. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  874. break;
  875. }
  876. break;
  877. case UA_ATTRIBUTEID_VALUE:
  878. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE)
  879. if(anyTypeNode.vObj->valueSource == UA_VALUESOURCE_DATASOURCE) {
  880. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  881. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  882. }
  883. nVariant = value;
  884. UA_Variant_deleteMembers(&anyTypeNode.vObj->value.variant);
  885. UA_Variant_copy(nVariant, &anyTypeNode.vObj->value.variant);
  886. break;
  887. case UA_ATTRIBUTEID_DATATYPE:
  888. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  889. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  890. break;
  891. case UA_ATTRIBUTEID_VALUERANK:
  892. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  893. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  894. break;
  895. case UA_ATTRIBUTEID_ARRAYDIMENSIONS:
  896. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  897. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  898. break;
  899. case UA_ATTRIBUTEID_ACCESSLEVEL:
  900. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  901. nByte = (UA_Byte*) value;
  902. anyTypeNode.vObj->accessLevel = *nByte;
  903. break;
  904. case UA_ATTRIBUTEID_USERACCESSLEVEL:
  905. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  906. nByte = (UA_Byte*) value;
  907. anyTypeNode.vObj->userAccessLevel = *nByte;
  908. break;
  909. case UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL:
  910. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  911. nDouble = (UA_Double *) value;
  912. anyTypeNode.vObj->minimumSamplingInterval = *nDouble;
  913. break;
  914. case UA_ATTRIBUTEID_HISTORIZING:
  915. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  916. nBool = (UA_Boolean *) value;
  917. anyTypeNode.vObj->historizing= *nBool;
  918. break;
  919. case UA_ATTRIBUTEID_EXECUTABLE:
  920. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_METHOD)
  921. nBool = (UA_Boolean *) value;
  922. anyTypeNode.mObj->executable= *nBool;
  923. break;
  924. case UA_ATTRIBUTEID_USEREXECUTABLE:
  925. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_METHOD)
  926. nBool = (UA_Boolean *) value;
  927. anyTypeNode.mObj->userExecutable= *nBool;
  928. break;
  929. default:
  930. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  931. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  932. break;
  933. }
  934. const UA_Node *oldNode = UA_NodeStore_get(server->nodestore, &nodeId);
  935. const UA_Node **inserted = UA_NULL;
  936. retval |= UA_NodeStore_replace(server->nodestore, oldNode, anyTypeNode.node, inserted);
  937. UA_NodeStore_release(oldNode);
  938. // Node Copy deleted by nodeEntryFromNode() during nodestore_replace()!
  939. //UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  940. return retval;
  941. }
  942. #define SERVER_GETATTRIBUTE_COPYTYPEVALUE(TYPE, SRC) \
  943. *value = (void *) UA_##TYPE##_new(); \
  944. UA_##TYPE##_copy( SRC, (UA_##TYPE *) *value ); \
  945. UA_StatusCode UA_Server_getAttributeValue(UA_Server *server, UA_NodeId nodeId, UA_AttributeId attributeId, void **value) {
  946. union {
  947. UA_Node *node;
  948. UA_ObjectNode *oObj;
  949. UA_ObjectTypeNode *otObj;
  950. UA_VariableNode *vObj;
  951. UA_VariableTypeNode *vtObj;
  952. UA_ReferenceTypeNode *rtObj;
  953. UA_MethodNode *mObj;
  954. UA_DataTypeNode *dtObj;
  955. UA_ViewNode *vwObj;
  956. } anyTypeNode;
  957. UA_StatusCode retval = UA_Server_getNodeCopy(server, nodeId, (void **) &anyTypeNode.node);
  958. if (retval != UA_STATUSCODE_GOOD)
  959. return retval;
  960. switch(attributeId) {
  961. case UA_ATTRIBUTEID_NODEID:
  962. SERVER_GETATTRIBUTE_COPYTYPEVALUE(NodeId, &anyTypeNode.node->nodeId);
  963. break;
  964. case UA_ATTRIBUTEID_NODECLASS:
  965. SERVER_GETATTRIBUTE_COPYTYPEVALUE(NodeClass, &anyTypeNode.node->nodeClass);
  966. break;
  967. case UA_ATTRIBUTEID_BROWSENAME:
  968. SERVER_GETATTRIBUTE_COPYTYPEVALUE(QualifiedName, &anyTypeNode.node->browseName);
  969. break;
  970. case UA_ATTRIBUTEID_DISPLAYNAME:
  971. SERVER_GETATTRIBUTE_COPYTYPEVALUE(LocalizedText, &anyTypeNode.node->displayName);
  972. break;
  973. case UA_ATTRIBUTEID_DESCRIPTION:
  974. SERVER_GETATTRIBUTE_COPYTYPEVALUE(LocalizedText, &anyTypeNode.node->description);
  975. break;
  976. case UA_ATTRIBUTEID_WRITEMASK:
  977. SERVER_GETATTRIBUTE_COPYTYPEVALUE(UInt32, &anyTypeNode.node->writeMask);
  978. break;
  979. case UA_ATTRIBUTEID_USERWRITEMASK:
  980. SERVER_GETATTRIBUTE_COPYTYPEVALUE(UInt32, &anyTypeNode.node->userWriteMask);
  981. break;
  982. case UA_ATTRIBUTEID_ISABSTRACT:
  983. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_OBJECTTYPE | UA_NODECLASS_REFERENCETYPE | UA_NODECLASS_VARIABLETYPE | UA_NODECLASS_DATATYPE)
  984. switch(anyTypeNode.node->nodeClass) {
  985. case UA_NODECLASS_OBJECTTYPE:
  986. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.otObj->isAbstract);
  987. break;
  988. case UA_NODECLASS_REFERENCETYPE:
  989. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.rtObj->isAbstract);
  990. break;
  991. case UA_NODECLASS_VARIABLETYPE:
  992. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.vtObj->isAbstract);
  993. break;
  994. case UA_NODECLASS_DATATYPE:
  995. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.dtObj->isAbstract);
  996. break;
  997. default:
  998. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  999. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1000. break;
  1001. }
  1002. break;
  1003. case UA_ATTRIBUTEID_SYMMETRIC:
  1004. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_REFERENCETYPE)
  1005. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.rtObj->symmetric);
  1006. break;
  1007. case UA_ATTRIBUTEID_INVERSENAME:
  1008. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_REFERENCETYPE)
  1009. SERVER_GETATTRIBUTE_COPYTYPEVALUE(LocalizedText, &anyTypeNode.rtObj->inverseName);
  1010. break;
  1011. case UA_ATTRIBUTEID_CONTAINSNOLOOPS:
  1012. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VIEW)
  1013. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.vwObj->containsNoLoops);
  1014. break;
  1015. case UA_ATTRIBUTEID_EVENTNOTIFIER:
  1016. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VIEW | UA_NODECLASS_OBJECT)
  1017. switch(anyTypeNode.node->nodeClass) {
  1018. case UA_NODECLASS_VIEW:
  1019. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Byte, &anyTypeNode.vwObj->eventNotifier);
  1020. break;
  1021. case UA_NODECLASS_OBJECT:
  1022. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Byte, &anyTypeNode.oObj->eventNotifier);
  1023. break;
  1024. default:
  1025. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1026. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1027. break;
  1028. }
  1029. break;
  1030. case UA_ATTRIBUTEID_VALUE:
  1031. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE)
  1032. switch(anyTypeNode.node->nodeClass) {
  1033. case UA_NODECLASS_VARIABLE:
  1034. *value = UA_Variant_new();
  1035. if(anyTypeNode.vObj->valueSource == UA_VALUESOURCE_VARIANT) {
  1036. retval |= UA_Variant_copy(&anyTypeNode.vObj->value.variant, *value);
  1037. } else {
  1038. UA_DataValue ds;
  1039. UA_DataValue_init(&ds);
  1040. retval |= anyTypeNode.vObj->value.dataSource.read(anyTypeNode.vObj->value.dataSource.handle, UA_FALSE, UA_NULL, &ds);
  1041. UA_Variant_copy(&ds.value, *value);
  1042. }
  1043. break;
  1044. case UA_NODECLASS_VARIABLETYPE:
  1045. // Note: Precicely the same as variableNode above!
  1046. *value = UA_Variant_new();
  1047. if(anyTypeNode.vtObj->valueSource == UA_VALUESOURCE_VARIANT) {
  1048. retval |= UA_Variant_copy(&anyTypeNode.vtObj->value.variant, *value);
  1049. } else {
  1050. UA_DataValue ds;
  1051. UA_DataValue_init(&ds);
  1052. retval |= anyTypeNode.vtObj->value.dataSource.read(anyTypeNode.vtObj->value.dataSource.handle, UA_FALSE, UA_NULL, &ds);
  1053. UA_Variant_copy(&ds.value, *value);
  1054. }
  1055. break;
  1056. default:
  1057. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1058. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1059. }
  1060. break;
  1061. case UA_ATTRIBUTEID_DATATYPE:
  1062. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1063. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1064. break;
  1065. case UA_ATTRIBUTEID_VALUERANK:
  1066. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1067. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1068. break;
  1069. case UA_ATTRIBUTEID_ARRAYDIMENSIONS:
  1070. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1071. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1072. break;
  1073. case UA_ATTRIBUTEID_ACCESSLEVEL:
  1074. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  1075. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Byte, &anyTypeNode.vObj->accessLevel);
  1076. break;
  1077. case UA_ATTRIBUTEID_USERACCESSLEVEL:
  1078. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  1079. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Byte, &anyTypeNode.vObj->userAccessLevel);
  1080. break;
  1081. case UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL:
  1082. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  1083. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Double, &anyTypeNode.vObj->minimumSamplingInterval);
  1084. break;
  1085. case UA_ATTRIBUTEID_HISTORIZING:
  1086. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  1087. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.vObj->historizing);
  1088. break;
  1089. case UA_ATTRIBUTEID_EXECUTABLE:
  1090. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_METHOD)
  1091. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.mObj->executable);
  1092. break;
  1093. case UA_ATTRIBUTEID_USEREXECUTABLE:
  1094. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_METHOD)
  1095. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.mObj->userExecutable);
  1096. break;
  1097. default:
  1098. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1099. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1100. break;
  1101. }
  1102. return retval;
  1103. }