ua_server.h 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627
  1. /*
  2. * Copyright (C) 2014 the contributors as stated in the AUTHORS file
  3. *
  4. * This file is part of open62541. open62541 is free software: you can
  5. * redistribute it and/or modify it under the terms of the GNU Lesser General
  6. * Public License, version 3 (as published by the Free Software Foundation) with
  7. * a static linking exception as stated in the LICENSE file provided with
  8. * open62541.
  9. *
  10. * open62541 is distributed in the hope that it will be useful, but WITHOUT ANY
  11. * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
  12. * A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
  13. * details.
  14. */
  15. #ifndef UA_SERVER_H_
  16. #define UA_SERVER_H_
  17. #ifdef __cplusplus
  18. extern "C" {
  19. #endif
  20. #include "ua_config.h"
  21. #include "ua_types.h"
  22. #include "ua_types_generated.h"
  23. #include "ua_nodeids.h"
  24. #include "ua_log.h"
  25. #include "ua_job.h"
  26. #include "ua_connection.h"
  27. /**
  28. * @defgroup server Server
  29. *
  30. * @{
  31. */
  32. typedef struct UA_ServerConfig {
  33. UA_Boolean Login_enableAnonymous;
  34. UA_Boolean Login_enableUsernamePassword;
  35. char** Login_usernames;
  36. char** Login_passwords;
  37. UA_UInt32 Login_loginsCount;
  38. char* Application_applicationURI;
  39. char* Application_applicationName;
  40. } UA_ServerConfig;
  41. extern UA_EXPORT const UA_ServerConfig UA_ServerConfig_standard;
  42. UA_Server UA_EXPORT * UA_Server_new(UA_ServerConfig config);
  43. void UA_EXPORT UA_Server_setServerCertificate(UA_Server *server, UA_ByteString certificate);
  44. void UA_EXPORT UA_Server_delete(UA_Server *server);
  45. /** Sets the logger used by the server */
  46. void UA_EXPORT UA_Server_setLogger(UA_Server *server, UA_Logger logger);
  47. UA_Logger UA_EXPORT UA_Server_getLogger(UA_Server *server);
  48. /**
  49. * Runs the main loop of the server. In each iteration, this calls into the networklayers to see if
  50. * jobs have arrived and checks if repeated jobs need to be triggered.
  51. *
  52. * @param server The server object
  53. *
  54. * @param nThreads The number of worker threads. Is ignored if MULTITHREADING is not activated.
  55. *
  56. * @param running Points to a boolean value on the heap. When running is set to false, the worker
  57. * threads and the main loop close and the server is shut down.
  58. *
  59. * @return Indicates whether the server shut down cleanly
  60. *
  61. */
  62. UA_StatusCode UA_EXPORT UA_Server_run(UA_Server *server, UA_UInt16 nThreads, UA_Boolean *running);
  63. /* The prologue part of UA_Server_run (no need to use if you call UA_Server_run) */
  64. UA_StatusCode UA_EXPORT UA_Server_run_startup(UA_Server *server, UA_UInt16 nThreads, UA_Boolean *running);
  65. /* The epilogue part of UA_Server_run (no need to use if you call UA_Server_run) */
  66. UA_StatusCode UA_EXPORT UA_Server_run_shutdown(UA_Server *server, UA_UInt16 nThreads);
  67. /* One iteration of UA_Server_run (no need to use if you call UA_Server_run) */
  68. UA_StatusCode UA_EXPORT UA_Server_run_mainloop(UA_Server *server, UA_Boolean *running);
  69. /**
  70. * Datasources are the interface to local data providers. It is expected that
  71. * the read and release callbacks are implemented. The write callback can be set
  72. * to null.
  73. */
  74. typedef struct {
  75. void *handle; ///> A custom pointer to reuse the same datasource functions for multiple sources
  76. /**
  77. * Copies the data from the source into the provided value.
  78. *
  79. * @param handle An optional pointer to user-defined data for the specific data source
  80. * @param nodeid Id of the read node
  81. * @param includeSourceTimeStamp If true, then the datasource is expected to set the source
  82. * timestamp in the returned value
  83. * @param range If not null, then the datasource shall return only a selection of the (nonscalar)
  84. * data. Set UA_STATUSCODE_BADINDEXRANGEINVALID in the value if this does not apply.
  85. * @param value The (non-null) DataValue that is returned to the client. The data source sets the
  86. * read data, the result status and optionally a sourcetimestamp.
  87. * @return Returns a status code for logging. Error codes intended for the original caller are set
  88. * in the value. If an error is returned, then no releasing of the value is done.
  89. */
  90. UA_StatusCode (*read)(void *handle, const UA_NodeId nodeid, UA_Boolean includeSourceTimeStamp,
  91. const UA_NumericRange *range, UA_DataValue *value);
  92. /**
  93. * Write into a data source. The write member of UA_DataSource can be empty if the operation
  94. * is unsupported.
  95. *
  96. * @param handle An optional pointer to user-defined data for the specific data source
  97. * @param nodeid Id of the node being written to
  98. * @param data The data to be written into the data source
  99. * @param range An optional data range. If the data source is scalar or does not support writing
  100. * of ranges, then an error code is returned.
  101. * @return Returns a status code that is returned to the user
  102. */
  103. UA_StatusCode (*write)(void *handle, const UA_NodeId nodeid, const UA_Variant *data, const UA_NumericRange *range);
  104. } UA_DataSource;
  105. /* Value Callbacks can be attach to value and value type nodes. If not-null, they are called before
  106. reading and after writing respectively */
  107. typedef struct {
  108. void *handle;
  109. void (*onRead)(void *handle, const UA_NodeId nodeid, const UA_Variant *data, const UA_NumericRange *range);
  110. void (*onWrite)(void *handle, const UA_NodeId nodeid, const UA_Variant *data, const UA_NumericRange *range);
  111. } UA_ValueCallback;
  112. /** @brief Add a new namespace to the server. Returns the index of the new namespace */
  113. UA_UInt16 UA_EXPORT UA_Server_addNamespace(UA_Server *server, const char* name);
  114. /** Add a reference to the server's address space */
  115. UA_StatusCode UA_EXPORT UA_Server_addReference(UA_Server *server, const UA_NodeId sourceId,
  116. const UA_NodeId refTypeId, const UA_ExpandedNodeId targetId);
  117. /** Deletes a node from the nodestore.
  118. *
  119. * @param server The server object
  120. * @param nodeId ID of the node to be deleted
  121. * @return Return UA_STATUSCODE_GOOD if the node was deleted or an appropriate errorcode if the node was not found
  122. * or cannot be deleted.
  123. */
  124. UA_StatusCode UA_EXPORT
  125. UA_Server_deleteNode(UA_Server *server, UA_NodeId nodeId);
  126. #define UA_SERVER_DELETENODEALIAS_DECL(TYPE) \
  127. UA_StatusCode UA_EXPORT UA_Server_delete##TYPE##Node(UA_Server *server, UA_NodeId nodeId);
  128. UA_SERVER_DELETENODEALIAS_DECL(Object)
  129. UA_SERVER_DELETENODEALIAS_DECL(Variable)
  130. UA_SERVER_DELETENODEALIAS_DECL(ReferenceType)
  131. UA_SERVER_DELETENODEALIAS_DECL(View)
  132. UA_SERVER_DELETENODEALIAS_DECL(VariableType)
  133. UA_SERVER_DELETENODEALIAS_DECL(DataType)
  134. #ifdef ENABLE_METHODCALLS
  135. UA_SERVER_DELETENODEALIAS_DECL(Method)
  136. #endif
  137. /** Deletes a copied instance of a node by deallocating it and all its attributes. This assumes that the node was
  138. * priorly copied using getNodeCopy. To delete nodes that are located in the nodestore, use UA_Server_deleteNode()
  139. * instead.
  140. *
  141. * @param server The server object
  142. * @param node A copy of any node-type struct created with getNodeCopy; must *not* be managed by the nodestore.
  143. *
  144. * @return Return UA_STATUSCODE_GOOD if the node was deleted or an appropriate errorcode if the node was not found
  145. * or cannot be deleted.
  146. */
  147. UA_StatusCode UA_EXPORT
  148. UA_Server_deleteNodeCopy(UA_Server *server, void **node);
  149. /** Creates a deep copy of a node located in the nodestore and returns it to the userspace. Note that any manipulation
  150. * of this copied node is not reflected by the server, but otherwise not accessible attributes of the node's struct
  151. * can be examined in bulk. node->nodeClass can be used to cast the node to a specific node type. Use
  152. * UA_Server_deleteNodeCopy() to deallocate this node.
  153. *
  154. * @param server The server object
  155. * @param nodeId ID of the node copy to be copied
  156. * @param copyInto Pointer to a NULL pointer that will hold the copy of the node on a successfull return.
  157. *
  158. * @return Return UA_STATUSCODE_GOOD if the node was copied or an appropriate errorcode if the node was not found
  159. * or cannot be copied.
  160. */
  161. UA_StatusCode UA_EXPORT
  162. UA_Server_getNodeCopy(UA_Server *server, UA_NodeId nodeId, void **copyInto);
  163. /** A new variable Node with a value passed in variant.
  164. *
  165. * @param server The server object
  166. * @param nodeId The requested nodeId of the new node. Use the numeric id with i=0 to get a new ID from the server.
  167. * @param browseName The qualified name of this node
  168. * @param displayName The localized text shown when displaying the node
  169. * @param description The localized human readable description
  170. * @param userWriteMask Bitmask defining the user write permissions
  171. * @param writeMask Bitmask defining the write permissions
  172. * @param parentNodeId The node under which this node exists ("parent")
  173. * @param referenceTypeId Reference type used by the parent to reference this node
  174. * @param value A variant containing the value to be assigned to this node.
  175. * @param createdNodeId Pointer to a NULL pointer that will hold the copy of the nodeId on a successfull return.
  176. *
  177. * @return Return UA_STATUSCODE_GOOD if the node was created or an appropriate error code if not.
  178. */
  179. UA_StatusCode UA_EXPORT
  180. UA_Server_addVariableNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  181. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  182. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  183. UA_Variant *value,
  184. UA_NodeId *createdNodeId);
  185. // Missing: eventNotifier
  186. UA_StatusCode UA_EXPORT
  187. UA_Server_addObjectNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  188. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  189. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  190. const UA_ExpandedNodeId typeDefinition,
  191. UA_NodeId *createdNodeId);
  192. // Missing: isAbstract, symmetric
  193. UA_StatusCode UA_EXPORT
  194. UA_Server_addReferenceTypeNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  195. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  196. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  197. const UA_ExpandedNodeId typeDefinition,
  198. const UA_LocalizedText inverseName,
  199. UA_NodeId *createdNodeId );
  200. UA_StatusCode UA_EXPORT
  201. UA_Server_addObjectTypeNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  202. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  203. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  204. const UA_ExpandedNodeId typeDefinition,
  205. const UA_Boolean isAbstract,
  206. UA_NodeId *createdNodeId );
  207. UA_StatusCode UA_EXPORT
  208. UA_Server_addVariableTypeNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  209. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  210. const UA_NodeId parentNodeId,
  211. const UA_NodeId referenceTypeId,
  212. UA_Variant *value,
  213. const UA_Int32 valueRank,
  214. const UA_Boolean isAbstract,
  215. UA_NodeId *createdNodeId);
  216. UA_StatusCode UA_EXPORT
  217. UA_Server_addDataTypeNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  218. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  219. const UA_NodeId parentNodeId,
  220. const UA_NodeId referenceTypeId,
  221. const UA_ExpandedNodeId typeDefinition,
  222. const UA_Boolean isAbstract,
  223. UA_NodeId *createdNodeId);
  224. UA_StatusCode UA_EXPORT
  225. UA_Server_addViewNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  226. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  227. const UA_NodeId parentNodeId,
  228. const UA_NodeId referenceTypeId,
  229. const UA_ExpandedNodeId typeDefinition,
  230. UA_NodeId *createdNodeId);
  231. UA_StatusCode UA_EXPORT
  232. UA_Server_addDataSourceVariableNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  233. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  234. const UA_NodeId parentNodeId,
  235. const UA_NodeId referenceTypeId,
  236. const UA_DataSource dataSource,
  237. UA_NodeId *createdNodeId);
  238. /* --------------------- */
  239. UA_StatusCode UA_EXPORT
  240. UA_Server_addMonodirectionalReference(UA_Server *server, UA_NodeId sourceNodeId,
  241. UA_ExpandedNodeId targetNodeId, UA_NodeId referenceTypeId,
  242. UA_Boolean isforward);
  243. #ifdef ENABLE_METHODCALLS
  244. typedef UA_StatusCode (*UA_MethodCallback)(const UA_NodeId objectId, const UA_Variant *input,
  245. UA_Variant *output, void *handle);
  246. /** Creates a serverside method including input- and output variable descriptions
  247. *
  248. * @param server The server object.
  249. *
  250. * @param browseName BrowseName to be used for the new method.
  251. *
  252. * @param nodeId Requested NodeId for the new method. If a numeric ID with i=0 is used, the server will assign a random unused id.
  253. *
  254. * @param parentNodeId Parent node containing this method. Note that an ObjectNode needs to reference the method with hasProperty in order for the method to be callable.
  255. *
  256. * @param referenceTypeId Reference type ID to be used by the parent to reference the new method.
  257. *
  258. * @param method Userspace Method/Function of type UA_MethodCallback to be called when a client invokes the method using the Call Service Set.
  259. *
  260. * @param inputArgumentsSize Number of input arguments expected to be passed by a calling client.
  261. *
  262. * @param inputArguments Description of input arguments expected to be passed by a calling client.
  263. *
  264. * @param outputArgumentsSize Description of output arguments expected to be passed by a calling client.
  265. *
  266. * @param outputArguments Description of output arguments expected to be passed by a calling client.
  267. *
  268. * @param createdNodeId Actual nodeId of the new method node if UA_StatusCode indicates success. Can be used to determine the random unique ID assigned by the server if i=0 was passed as a nodeId.
  269. *
  270. */
  271. UA_StatusCode UA_EXPORT
  272. UA_Server_addMethodNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  273. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  274. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  275. UA_MethodCallback method, void *handle, UA_Int32 inputArgumentsSize, const UA_Argument *inputArguments,
  276. UA_Int32 outputArgumentsSize, const UA_Argument *outputArguments,
  277. UA_NodeId *createdNodeId);
  278. #endif
  279. #ifndef _HAVE_UA_NODEITERATORCALLBACK_D
  280. #define _HAVE_UA_NODEITERATORCALLBACK_D
  281. typedef UA_StatusCode (*UA_NodeIteratorCallback)(UA_NodeId childId, UA_Boolean isInverse, UA_NodeId referenceTypeId, void *handle);
  282. #endif
  283. /** Iterate over all nodes referenced by parentNodeId by calling the callback function for each child node
  284. *
  285. * @param server The server object.
  286. *
  287. * @param parentNodeId The NodeId of the parent whose references are to be iterated over
  288. *
  289. * @param callback The function of type UA_NodeIteratorCallback to be called for each referenced child
  290. *
  291. * @return Upon success, UA_STATUSCODE_GOOD is returned. An error code otherwise.
  292. */
  293. UA_StatusCode UA_EXPORT UA_Server_forEachChildNodeCall(UA_Server *server, UA_NodeId parentNodeId, UA_NodeIteratorCallback callback, void *handle);
  294. UA_StatusCode UA_EXPORT UA_Server_setAttributeValue(UA_Server *server, UA_NodeId nodeId, UA_AttributeId attributeId, void *value);
  295. // Attribute specific macros for setAttribute_are defined in ua_server_addressspace.c
  296. #define UA_Server_setAttribute_nodeId(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_NODEID, (UA_NodeId *) VALUE);
  297. #define UA_Server_setAttribute_nodeClass(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_NODECLASS, (UA_NodeClass *) VALUE);
  298. #define UA_Server_setAttribute_browseName(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_BROWSENAME, (UA_QualifiedName *) VALUE);
  299. #define UA_Server_setAttribute_displayName(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_DISPLAYNAME, (UA_LocalizedText *) VALUE);
  300. #define UA_Server_setAttribute_description(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_DESCRIPTION, (UA_LocalizedText *) VALUE);
  301. #define UA_Server_setAttribute_writeMask(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_WRITEMASK, (UA_UInt32 *) VALUE);
  302. #define UA_Server_setAttribute_userWriteMask(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_USERWRITEMASK, (UA_UInt32 *) VALUE);
  303. #define UA_Server_setAttribute_isAbstract(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_ISABSTRACT, (UA_Boolean *) VALUE);
  304. #define UA_Server_setAttribute_symmetric(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_SYMMETRIC, (UA_Boolean *) VALUE);
  305. #define UA_Server_setAttribute_inverseName(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_INVERSENAME, (UA_LocalizedText *) VALUE);
  306. #define UA_Server_setAttribute_containsNoLoops(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_CONTAINSNOLOOPS, (UA_Boolean *) VALUE);
  307. #define UA_Server_setAttribute_eventNotifier(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_EVENTNOTIFIER, (UA_Byte *) VALUE);
  308. #define UA_Server_setAttribute_value(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_VALUE, (UA_Variant *) VALUE);
  309. #define UA_Server_setAttribute_dataType(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_DATATYPE, (UA_NodeId *) VALUE);
  310. #define UA_Server_setAttribute_valueRank(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_VALUERANK, (UA_Int32 *) VALUE);
  311. #define UA_Server_setAttribute_arrayDimensions(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_ARRAYDIMENSIONS, (UA_Int32 *) VALUE);
  312. #define UA_Server_setAttribute_accessLevel(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_ACCESSLEVEL, (UA_UInt32 *) VALUE);
  313. #define UA_Server_setAttribute_userAccessLevel(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_USERACCESSLEVEL, (UA_UInt32 *) VALUE);
  314. #define UA_Server_setAttribute_minimumSamplingInterval(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL, (UA_Double *) VALUE);
  315. #define UA_Server_setAttribute_historizing(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_HISTORIZING, (UA_Boolean *) VALUE);
  316. #define UA_Server_setAttribute_executable(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_EXECUTABLE, (UA_Boolean *) VALUE);
  317. #define UA_Server_setAttribute_userExecutable(SERVER, NODEID, VALUE) UA_Server_setAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_USEREXECUTABLE, (UA_Boolean *) VALUE);
  318. #ifdef ENABLE_METHODCALLS
  319. UA_StatusCode UA_EXPORT
  320. UA_Server_setAttribute_method(UA_Server *server, UA_NodeId methodNodeId, UA_MethodCallback method, void *handle);
  321. #endif
  322. UA_StatusCode UA_EXPORT
  323. UA_Server_setAttribute_DataSource(UA_Server *server, UA_NodeId nodeId, UA_DataSource value);
  324. /* Succeeds only if the node contains a variant value */
  325. UA_StatusCode UA_EXPORT
  326. UA_Server_setAttribute_valueCallback(UA_Server *server, UA_NodeId nodeId, UA_ValueCallback callback);
  327. UA_StatusCode UA_EXPORT
  328. UA_Server_getAttributeValue(UA_Server *server, UA_NodeId nodeId, UA_AttributeId attributeId, void **value);
  329. #define UA_Server_getAttribute_nodeId(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_NODEID, (UA_NodeId **) VALUE);
  330. #define UA_Server_getAttribute_nodeClass(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_NODECLASS, (UA_NodeClass **) VALUE);
  331. #define UA_Server_getAttribute_browseName(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_BROWSENAME, (UA_QualifiedName **) VALUE);
  332. #define UA_Server_getAttribute_displayName(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_DISPLAYNAME, (UA_LocalizedText **) VALUE);
  333. #define UA_Server_getAttribute_description(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_DESCRIPTION, (UA_LocalizedText **) VALUE);
  334. #define UA_Server_getAttribute_writeMask(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_WRITEMASK, (UA_UInt32 **) VALUE);
  335. #define UA_Server_getAttribute_userWriteMask(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_USERWRITEMASK, (UA_UInt32 **) VALUE);
  336. #define UA_Server_getAttribute_isAbstract(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_ISABSTRACT, (UA_Boolean **) VALUE);
  337. #define UA_Server_getAttribute_symmetric(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_SYMMETRIC, (UA_Boolean **) VALUE);
  338. #define UA_Server_getAttribute_inverseName(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_INVERSENAME, (UA_LocalizedText **) VALUE);
  339. #define UA_Server_getAttribute_containsNoLoops(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_CONTAINSNOLOOPS, (UA_Boolean **) VALUE);
  340. #define UA_Server_getAttribute_eventNotifier(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_EVENTNOTIFIER, (UA_Byte **) VALUE);
  341. #define UA_Server_getAttribute_value(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_VALUE, (UA_Variant **) VALUE);
  342. #define UA_Server_getAttribute_dataType(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_DATATYPE, (UA_NodeId **) VALUE);
  343. #define UA_Server_getAttribute_valueRank(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_VALUERANK, (UA_Int32 **) VALUE);
  344. #define UA_Server_getAttribute_arrayDimensions(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_ARRAYDIMENSIONS, (UA_Int32 **) VALUE);
  345. #define UA_Server_getAttribute_accessLevel(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_ACCESSLEVEL, (UA_UInt32 **) VALUE);
  346. #define UA_Server_getAttribute_userAccessLevel(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_USERACCESSLEVEL, (UA_UInt32 **) VALUE);
  347. #define UA_Server_getAttribute_minimumSamplingInterval(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL, (UA_Double **) VALUE);
  348. #define UA_Server_getAttribute_historizing(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_HISTORIZING, (UA_Boolean **) VALUE);
  349. #define UA_Server_getAttribute_executable(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_EXECUTABLE, (UA_Boolean **) VALUE);
  350. #define UA_Server_getAttribute_userExecutable(SERVER, NODEID, VALUE) UA_Server_getAttributeValue(SERVER, NODEID, UA_ATTRIBUTEID_USEREXECUTABLE, (UA_Boolean **) VALUE);
  351. #ifdef ENABLE_METHODCALLS
  352. UA_StatusCode UA_EXPORT
  353. UA_Server_getAttribute_method(UA_Server *server, UA_NodeId methodNodeId, UA_MethodCallback *method);
  354. #endif
  355. UA_StatusCode UA_EXPORT
  356. UA_Server_getAttribute_DataSource(UA_Server *server, UA_NodeId nodeId, UA_DataSource **value);
  357. /**
  358. * @param server The server object.
  359. *
  360. * @param job Pointer to the job that shall be added. The pointer is not freed but copied to an
  361. * internal representation.
  362. *
  363. * @param interval The job shall be repeatedly executed with the given interval (in ms). The
  364. * interval must be larger than 5ms. The first execution occurs at now() + interval at the
  365. * latest.
  366. *
  367. * @param jobId Set to the guid of the repeated job. This can be used to cancel the job later on. If
  368. * the pointer is null, the guid is not set.
  369. *
  370. * @return Upon success, UA_STATUSCODE_GOOD is returned. An error code otherwise.
  371. */
  372. UA_StatusCode UA_EXPORT UA_Server_addRepeatedJob(UA_Server *server, UA_Job job, UA_UInt32 interval,
  373. UA_Guid *jobId);
  374. /**
  375. * Remove repeated job. The entry will be removed asynchronously during the next iteration of the
  376. * server main loop.
  377. *
  378. * @param server The server object.
  379. *
  380. * @param jobId The id of the job that shall be removed.
  381. *
  382. * @return Upon sucess, UA_STATUSCODE_GOOD is returned. An error code otherwise.
  383. */
  384. UA_StatusCode UA_EXPORT UA_Server_removeRepeatedJob(UA_Server *server, UA_Guid jobId);
  385. /**
  386. * Interface to the binary network layers. This structure is returned from the
  387. * function that initializes the network layer. The layer is already bound to a
  388. * specific port and listening. The functions in the structure are never called
  389. * in parallel but only sequentially from the server's main loop. So the network
  390. * layer does not need to be thread-safe.
  391. */
  392. typedef struct UA_ServerNetworkLayer {
  393. UA_String discoveryUrl;
  394. UA_Logger logger; ///< Set during _start
  395. /**
  396. * Starts listening on the the networklayer.
  397. *
  398. * @param nl The network layer
  399. * @param logger The logger
  400. * @return Returns UA_STATUSCODE_GOOD or an error code.
  401. */
  402. UA_StatusCode (*start)(struct UA_ServerNetworkLayer *nl, UA_Logger logger);
  403. /**
  404. * Gets called from the main server loop and returns the jobs (accumulated messages and close
  405. * events) for dispatch.
  406. *
  407. * @param nl The network layer
  408. * @param jobs When the returned integer is >0, *jobs points to an array of UA_Job of the
  409. * returned size.
  410. * @param timeout The timeout during which an event must arrive in microseconds
  411. * @return The size of the jobs array. If the result is negative, an error has occurred.
  412. */
  413. size_t (*getJobs)(struct UA_ServerNetworkLayer *nl, UA_Job **jobs, UA_UInt16 timeout);
  414. /**
  415. * Closes the network connection and returns all the jobs that need to be finished before the
  416. * network layer can be safely deleted.
  417. *
  418. * @param nl The network layer
  419. * @param jobs When the returned integer is >0, jobs points to an array of UA_Job of the
  420. * returned size.
  421. * @return The size of the jobs array. If the result is negative, an error has occurred.
  422. */
  423. size_t (*stop)(struct UA_ServerNetworkLayer *nl, UA_Job **jobs);
  424. /** Deletes the network layer. Call only after a successful shutdown. */
  425. void (*deleteMembers)(struct UA_ServerNetworkLayer *nl);
  426. } UA_ServerNetworkLayer;
  427. /**
  428. * Adds a network layer to the server. The network layer is destroyed together
  429. * with the server. Do not use it after adding it as it might be moved around on
  430. * the heap.
  431. */
  432. void UA_EXPORT UA_Server_addNetworkLayer(UA_Server *server, UA_ServerNetworkLayer *networkLayer);
  433. /** @} */
  434. #ifndef __cplusplus /* the external nodestore does not work with c++ so far */
  435. /**
  436. * @ingroup nodestore
  437. *
  438. * @defgroup external_nodestore External Nodestore
  439. *
  440. * @brief An external application that manages its own data and data model
  441. *
  442. * To plug in outside data sources, one can use
  443. *
  444. * - VariableNodes with a data source (functions that are called for read and write access)
  445. * - An external nodestore that is mapped to specific namespaces
  446. *
  447. * If no external nodestore is defined for a nodeid, it is always looked up in
  448. * the "local" nodestore of open62541. Namespace Zero is always in the local
  449. * nodestore.
  450. *
  451. * @{
  452. */
  453. typedef UA_Int32 (*UA_ExternalNodeStore_addNodes)
  454. (void *ensHandle, const UA_RequestHeader *requestHeader, UA_AddNodesItem *nodesToAdd, UA_UInt32 *indices,
  455. UA_UInt32 indicesSize, UA_AddNodesResult* addNodesResults, UA_DiagnosticInfo *diagnosticInfos);
  456. typedef UA_Int32 (*UA_ExternalNodeStore_addReferences)
  457. (void *ensHandle, const UA_RequestHeader *requestHeader, UA_AddReferencesItem* referencesToAdd,
  458. UA_UInt32 *indices,UA_UInt32 indicesSize, UA_StatusCode *addReferencesResults,
  459. UA_DiagnosticInfo *diagnosticInfos);
  460. typedef UA_Int32 (*UA_ExternalNodeStore_deleteNodes)
  461. (void *ensHandle, const UA_RequestHeader *requestHeader, UA_DeleteNodesItem *nodesToDelete, UA_UInt32 *indices,
  462. UA_UInt32 indicesSize, UA_StatusCode *deleteNodesResults, UA_DiagnosticInfo *diagnosticInfos);
  463. typedef UA_Int32 (*UA_ExternalNodeStore_deleteReferences)
  464. (void *ensHandle, const UA_RequestHeader *requestHeader, UA_DeleteReferencesItem *referenceToDelete,
  465. UA_UInt32 *indices, UA_UInt32 indicesSize, UA_StatusCode deleteReferencesresults,
  466. UA_DiagnosticInfo *diagnosticInfos);
  467. typedef UA_Int32 (*UA_ExternalNodeStore_readNodes)
  468. (void *ensHandle, const UA_RequestHeader *requestHeader, UA_ReadValueId *readValueIds, UA_UInt32 *indices,
  469. UA_UInt32 indicesSize,UA_DataValue *readNodesResults, UA_Boolean timeStampToReturn,
  470. UA_DiagnosticInfo *diagnosticInfos);
  471. typedef UA_Int32 (*UA_ExternalNodeStore_writeNodes)
  472. (void *ensHandle, const UA_RequestHeader *requestHeader, UA_WriteValue *writeValues, UA_UInt32 *indices,
  473. UA_UInt32 indicesSize, UA_StatusCode *writeNodesResults, UA_DiagnosticInfo *diagnosticInfo);
  474. typedef UA_Int32 (*UA_ExternalNodeStore_browseNodes)
  475. (void *ensHandle, const UA_RequestHeader *requestHeader, UA_BrowseDescription *browseDescriptions,
  476. UA_UInt32 *indices, UA_UInt32 indicesSize, UA_UInt32 requestedMaxReferencesPerNode,
  477. UA_BrowseResult *browseResults, UA_DiagnosticInfo *diagnosticInfos);
  478. typedef UA_Int32 (*UA_ExternalNodeStore_translateBrowsePathsToNodeIds)
  479. (void *ensHandle, const UA_RequestHeader *requestHeader, UA_BrowsePath *browsePath, UA_UInt32 *indices,
  480. UA_UInt32 indicesSize, UA_BrowsePathResult *browsePathResults, UA_DiagnosticInfo *diagnosticInfos);
  481. typedef UA_Int32 (*UA_ExternalNodeStore_delete)(void *ensHandle);
  482. typedef struct UA_ExternalNodeStore {
  483. void *ensHandle;
  484. UA_ExternalNodeStore_addNodes addNodes;
  485. UA_ExternalNodeStore_deleteNodes deleteNodes;
  486. UA_ExternalNodeStore_writeNodes writeNodes;
  487. UA_ExternalNodeStore_readNodes readNodes;
  488. UA_ExternalNodeStore_browseNodes browseNodes;
  489. UA_ExternalNodeStore_translateBrowsePathsToNodeIds translateBrowsePathsToNodeIds;
  490. UA_ExternalNodeStore_addReferences addReferences;
  491. UA_ExternalNodeStore_deleteReferences deleteReferences;
  492. UA_ExternalNodeStore_delete destroy;
  493. } UA_ExternalNodeStore;
  494. #ifdef UA_EXTERNAL_NAMESPACES
  495. UA_StatusCode UA_EXPORT
  496. UA_Server_addExternalNamespace(UA_Server *server, UA_UInt16 namespaceIndex, const UA_String *url, UA_ExternalNodeStore *nodeStore);
  497. #endif /* UA_EXTERNAL_NAMESPACES*/
  498. /** @} */
  499. #endif /* external nodestore */
  500. #ifndef _HAVE_UA_INSTANTIONCALLBACK_D
  501. #define _HAVE_UA_INSTANTIONCALLBACK_D
  502. typedef UA_StatusCode (*UA_InstantiationCallback)(UA_NodeId objectId, UA_NodeId definitionId, void *handle);
  503. #endif
  504. typedef struct arrayOfNodeIds_s {
  505. UA_Int32 size;
  506. UA_NodeId *ids;
  507. } arrayOfNodeIds;
  508. UA_StatusCode UA_EXPORT
  509. UA_Server_appendInstanceOfSupertype(UA_Server *server, UA_NodeId nodeId, UA_NodeId appendToNodeId,
  510. arrayOfNodeIds *subtypeRefs, arrayOfNodeIds *componentRefs,
  511. UA_InstantiationCallback callback, arrayOfNodeIds *instantiatedTypes,
  512. void *handle);
  513. void UA_EXPORT
  514. UA_Server_addInstanceOf_instatiateChildNode(UA_Server *server,
  515. arrayOfNodeIds *subtypeRefs, arrayOfNodeIds *componentRefs, arrayOfNodeIds *typedefRefs,
  516. UA_NodeId objectRoot, UA_InstantiationCallback callback, void *typeDefNode,
  517. UA_Boolean instantiateObjects, arrayOfNodeIds *instantiatedTypes, void *handle);
  518. UA_StatusCode UA_EXPORT
  519. UA_Server_addInstanceOf(UA_Server *server, UA_NodeId nodeId, const UA_QualifiedName browseName,
  520. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  521. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  522. const UA_ExpandedNodeId typeDefinition, UA_InstantiationCallback callback, void *handle,
  523. UA_NodeId *createdNodeId);
  524. #ifdef __cplusplus
  525. } // extern "C"
  526. #endif
  527. #endif /* UA_SERVER_H_ */