ua_server.h 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843
  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_types_generated_handling.h"
  24. #include "ua_nodeids.h"
  25. #include "ua_log.h"
  26. #include "ua_job.h"
  27. #include "ua_connection.h"
  28. /**
  29. * Server
  30. * ======
  31. *
  32. * Network Layer
  33. * -------------
  34. * Interface to the binary network layers. The functions in the network layer
  35. * are never called in parallel but only sequentially from the server's main
  36. * loop. So the network layer does not need to be thread-safe. */
  37. struct UA_ServerNetworkLayer;
  38. typedef struct UA_ServerNetworkLayer UA_ServerNetworkLayer;
  39. struct UA_ServerNetworkLayer {
  40. void *handle; // pointer to internal data
  41. UA_String discoveryUrl;
  42. /* Starts listening on the the networklayer.
  43. *
  44. * @param nl The network layer
  45. * @param logger The logger
  46. * @return Returns UA_STATUSCODE_GOOD or an error code. */
  47. UA_StatusCode (*start)(UA_ServerNetworkLayer *nl, UA_Logger logger);
  48. /* Gets called from the main server loop and returns the jobs (accumulated
  49. * messages and close events) for dispatch.
  50. *
  51. * @param nl The network layer
  52. * @param jobs When the returned integer is >0, *jobs points to an array of
  53. * UA_Job of the returned size.
  54. * @param timeout The timeout during which an event must arrive in
  55. * microseconds
  56. * @return The size of the jobs array. If the result is negative,
  57. * an error has occurred. */
  58. size_t (*getJobs)(UA_ServerNetworkLayer *nl, UA_Job **jobs, UA_UInt16 timeout);
  59. /* Closes the network connection and returns all the jobs that need to be
  60. * finished before the network layer can be safely deleted.
  61. *
  62. * @param nl The network layer
  63. * @param jobs When the returned integer is >0, jobs points to an array of
  64. * UA_Job of the returned size.
  65. * @return The size of the jobs array. If the result is negative,
  66. * an error has occurred. */
  67. size_t (*stop)(UA_ServerNetworkLayer *nl, UA_Job **jobs);
  68. /** Deletes the network content. Call only after stopping. */
  69. void (*deleteMembers)(UA_ServerNetworkLayer *nl);
  70. };
  71. /**
  72. * Server Configuration
  73. * --------------------
  74. * The following structure is passed to a new server for configuration. */
  75. typedef struct {
  76. UA_String username;
  77. UA_String password;
  78. } UA_UsernamePasswordLogin;
  79. typedef struct {
  80. UA_UInt32 min;
  81. UA_UInt32 max;
  82. } UA_UInt32Range;
  83. typedef struct {
  84. UA_Double min;
  85. UA_Double max;
  86. } UA_DoubleRange;
  87. typedef struct {
  88. UA_UInt16 nThreads; /* only if multithreading is enabled */
  89. UA_Logger logger;
  90. /* Server Description */
  91. UA_BuildInfo buildInfo;
  92. UA_ApplicationDescription applicationDescription;
  93. UA_ByteString serverCertificate;
  94. /* Networking */
  95. size_t networkLayersSize;
  96. UA_ServerNetworkLayer *networkLayers;
  97. /* Login */
  98. UA_Boolean enableAnonymousLogin;
  99. UA_Boolean enableUsernamePasswordLogin;
  100. size_t usernamePasswordLoginsSize;
  101. UA_UsernamePasswordLogin* usernamePasswordLogins;
  102. /* Limits for SecureChannels */
  103. UA_UInt16 maxSecureChannels;
  104. UA_UInt32 maxSecurityTokenLifetime; /* in ms */
  105. /* Limits for Sessions */
  106. UA_UInt16 maxSessions;
  107. UA_Double maxSessionTimeout; /* in ms */
  108. /* Limits for Subscriptions */
  109. UA_DoubleRange publishingIntervalLimits;
  110. UA_UInt32Range lifeTimeCountLimits;
  111. UA_UInt32Range keepAliveCountLimits;
  112. UA_UInt32 maxNotificationsPerPublish;
  113. /* Limits for MonitoredItems */
  114. UA_DoubleRange samplingIntervalLimits;
  115. UA_UInt32Range queueSizeLimits;
  116. } UA_ServerConfig;
  117. /* Add a new namespace to the server. Returns the index of the new namespace */
  118. UA_UInt16 UA_EXPORT UA_Server_addNamespace(UA_Server *server, const char* name);
  119. /**
  120. * Server Lifecycle
  121. * ---------------- */
  122. UA_Server UA_EXPORT * UA_Server_new(const UA_ServerConfig config);
  123. void UA_EXPORT UA_Server_delete(UA_Server *server);
  124. /* Runs the main loop of the server. In each iteration, this calls into the
  125. * networklayers to see if jobs have arrived and checks if repeated jobs need to
  126. * be triggered.
  127. *
  128. * @param server The server object.
  129. * @param running The loop is run as long as *running is true.
  130. * Otherwise, the server shuts down.
  131. * @return Returns the statuscode of the UA_Server_run_shutdown method */
  132. UA_StatusCode UA_EXPORT
  133. UA_Server_run(UA_Server *server, volatile UA_Boolean *running);
  134. /* The prologue part of UA_Server_run (no need to use if you call
  135. * UA_Server_run) */
  136. UA_StatusCode UA_EXPORT UA_Server_run_startup(UA_Server *server);
  137. /* Executes a single iteration of the server's main loop.
  138. *
  139. * @param server The server object.
  140. * @param waitInternal Should we wait for messages in the networklayer?
  141. * Otherwise, the timouts for the networklayers are set to zero.
  142. * The default max wait time is 50millisec.
  143. * @return Returns how long we can wait until the next scheduled
  144. * job (in millisec) */
  145. UA_UInt16 UA_EXPORT
  146. UA_Server_run_iterate(UA_Server *server, UA_Boolean waitInternal);
  147. /* The epilogue part of UA_Server_run (no need to use if you call
  148. * UA_Server_run) */
  149. UA_StatusCode UA_EXPORT UA_Server_run_shutdown(UA_Server *server);
  150. /**
  151. * Repeated jobs
  152. * ------------- */
  153. /* Add a job for cyclic repetition to the server.
  154. *
  155. * @param server The server object.
  156. * @param job The job that shall be added.
  157. * @param interval The job shall be repeatedly executed with the given interval
  158. * (in ms). The interval must be larger than 5ms. The first execution
  159. * occurs at now() + interval at the latest.
  160. * @param jobId Set to the guid of the repeated job. This can be used to cancel
  161. * the job later on. If the pointer is null, the guid is not set.
  162. * @return Upon success, UA_STATUSCODE_GOOD is returned.
  163. * An error code otherwise. */
  164. UA_StatusCode UA_EXPORT
  165. UA_Server_addRepeatedJob(UA_Server *server, UA_Job job,
  166. UA_UInt32 interval, UA_Guid *jobId);
  167. /* Remove repeated job. The entry will be removed asynchronously during the next
  168. * iteration of the server main loop.
  169. *
  170. * @param server The server object.
  171. * @param jobId The id of the job that shall be removed.
  172. * @return Upon sucess, UA_STATUSCODE_GOOD is returned.
  173. * An error code otherwise. */
  174. UA_StatusCode UA_EXPORT
  175. UA_Server_removeRepeatedJob(UA_Server *server, UA_Guid jobId);
  176. /**
  177. * Reading and Writing Node Attributes
  178. * -----------------------------------
  179. * The functions for reading and writing node attributes call the regular read
  180. * and write service in the background that are also used over the network.
  181. *
  182. * The following attributes cannot be read, since the local "admin" user always
  183. * has full rights.
  184. *
  185. * - UserWriteMask
  186. * - UserAccessLevel
  187. * - UserExecutable */
  188. /* Read an attribute of a node. The specialized functions below provide a more
  189. * concise syntax.
  190. *
  191. * @param server The server object.
  192. * @param item ReadValueIds contain the NodeId of the target node, the id of the
  193. * attribute to read and (optionally) an index range to read parts
  194. * of an array only. See the section on NumericRange for the format
  195. * used for array ranges.
  196. * @param timestamps Which timestamps to return for the attribute.
  197. * @return Returns a DataValue that contains either an error code, or a variant
  198. * with the attribute value and the timestamps. */
  199. UA_DataValue UA_EXPORT
  200. UA_Server_read(UA_Server *server, const UA_ReadValueId *item,
  201. UA_TimestampsToReturn timestamps);
  202. /* Don't use this function. There are typed versions for every supported
  203. * attribute. */
  204. UA_StatusCode UA_EXPORT
  205. __UA_Server_read(UA_Server *server, const UA_NodeId *nodeId,
  206. UA_AttributeId attributeId, void *v);
  207. static UA_INLINE UA_StatusCode
  208. UA_Server_readNodeId(UA_Server *server, const UA_NodeId nodeId,
  209. UA_NodeId *outNodeId) {
  210. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_NODEID, outNodeId);
  211. }
  212. static UA_INLINE UA_StatusCode
  213. UA_Server_readNodeClass(UA_Server *server, const UA_NodeId nodeId,
  214. UA_NodeClass *outNodeClass) {
  215. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_NODECLASS,
  216. outNodeClass);
  217. }
  218. static UA_INLINE UA_StatusCode
  219. UA_Server_readBrowseName(UA_Server *server, const UA_NodeId nodeId,
  220. UA_QualifiedName *outBrowseName) {
  221. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_BROWSENAME,
  222. outBrowseName);
  223. }
  224. static UA_INLINE UA_StatusCode
  225. UA_Server_readDisplayName(UA_Server *server, const UA_NodeId nodeId,
  226. UA_LocalizedText *outDisplayName) {
  227. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_DISPLAYNAME,
  228. outDisplayName);
  229. }
  230. static UA_INLINE UA_StatusCode
  231. UA_Server_readDescription(UA_Server *server, const UA_NodeId nodeId,
  232. UA_LocalizedText *outDescription) {
  233. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_DESCRIPTION,
  234. outDescription);
  235. }
  236. static UA_INLINE UA_StatusCode
  237. UA_Server_readWriteMask(UA_Server *server, const UA_NodeId nodeId,
  238. UA_UInt32 *outWriteMask) {
  239. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_WRITEMASK,
  240. outWriteMask);
  241. }
  242. static UA_INLINE UA_StatusCode
  243. UA_Server_readIsAbstract(UA_Server *server, const UA_NodeId nodeId,
  244. UA_Boolean *outIsAbstract) {
  245. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_ISABSTRACT,
  246. outIsAbstract);
  247. }
  248. static UA_INLINE UA_StatusCode
  249. UA_Server_readSymmetric(UA_Server *server, const UA_NodeId nodeId,
  250. UA_Boolean *outSymmetric) {
  251. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_SYMMETRIC,
  252. outSymmetric);
  253. }
  254. static UA_INLINE UA_StatusCode
  255. UA_Server_readInverseName(UA_Server *server, const UA_NodeId nodeId,
  256. UA_LocalizedText *outInverseName) {
  257. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_INVERSENAME,
  258. outInverseName);
  259. }
  260. static UA_INLINE UA_StatusCode
  261. UA_Server_readContainsNoLoop(UA_Server *server, const UA_NodeId nodeId,
  262. UA_Boolean *outContainsNoLoops) {
  263. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_CONTAINSNOLOOPS,
  264. outContainsNoLoops);
  265. }
  266. static UA_INLINE UA_StatusCode
  267. UA_Server_readEventNotifier(UA_Server *server, const UA_NodeId nodeId,
  268. UA_Byte *outEventNotifier) {
  269. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_EVENTNOTIFIER,
  270. outEventNotifier);
  271. }
  272. static UA_INLINE UA_StatusCode
  273. UA_Server_readValue(UA_Server *server, const UA_NodeId nodeId,
  274. UA_Variant *outValue) {
  275. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_VALUE, outValue);
  276. }
  277. static UA_INLINE UA_StatusCode
  278. UA_Server_readDataType(UA_Server *server, const UA_NodeId nodeId,
  279. UA_NodeId *outDataType) {
  280. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_DATATYPE,
  281. outDataType);
  282. }
  283. static UA_INLINE UA_StatusCode
  284. UA_Server_readValueRank(UA_Server *server, const UA_NodeId nodeId,
  285. UA_Int32 *outValueRank) {
  286. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_VALUERANK,
  287. outValueRank);
  288. }
  289. /* Returns a variant with an int32 array */
  290. static UA_INLINE UA_StatusCode
  291. UA_Server_readArrayDimensions(UA_Server *server, const UA_NodeId nodeId,
  292. UA_Variant *outArrayDimensions) {
  293. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_ARRAYDIMENSIONS,
  294. outArrayDimensions);
  295. }
  296. static UA_INLINE UA_StatusCode
  297. UA_Server_readAccessLevel(UA_Server *server, const UA_NodeId nodeId,
  298. UA_UInt32 *outAccessLevel) {
  299. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_ACCESSLEVEL,
  300. outAccessLevel);
  301. }
  302. static UA_INLINE UA_StatusCode
  303. UA_Server_readMinimumSamplingInterval(UA_Server *server, const UA_NodeId nodeId,
  304. UA_Double *outMinimumSamplingInterval) {
  305. return __UA_Server_read(server, &nodeId,
  306. UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL,
  307. outMinimumSamplingInterval);
  308. }
  309. static UA_INLINE UA_StatusCode
  310. UA_Server_readHistorizing(UA_Server *server, const UA_NodeId nodeId,
  311. UA_Boolean *outHistorizing) {
  312. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_HISTORIZING,
  313. outHistorizing);
  314. }
  315. static UA_INLINE UA_StatusCode
  316. UA_Server_readExecutable(UA_Server *server, const UA_NodeId nodeId,
  317. UA_Boolean *outExecutable) {
  318. return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_EXECUTABLE,
  319. outExecutable);
  320. }
  321. /**
  322. * The following node attributes cannot be changed once a node has been created:
  323. *
  324. * - NodeClass
  325. * - NodeId
  326. * - Symmetric
  327. * - ContainsNoLoop
  328. *
  329. * The following attributes cannot be written from the server, as they are
  330. * specific to the different users:
  331. *
  332. * - UserWriteMask
  333. * - UserAccessLevel
  334. * - UserExecutable
  335. *
  336. * The following attributes are currently taken from the value variant and not
  337. * stored separately in the nodes:
  338. *
  339. * - DataType
  340. * - ValueRank
  341. * - ArrayDimensions
  342. *
  343. * Historizing is currently unsupported */
  344. /* Overwrite an attribute of a node. The specialized functions below provide a
  345. * more concise syntax.
  346. *
  347. * @param server The server object.
  348. * @param value WriteValues contain the NodeId of the target node, the id of the
  349. * attribute to overwritten, the actual value and (optionally) an
  350. * index range to replace parts of an array only. of an array only.
  351. * See the section on NumericRange for the format used for array
  352. * ranges.
  353. * @return Returns a status code. */
  354. UA_StatusCode UA_EXPORT
  355. UA_Server_write(UA_Server *server, const UA_WriteValue *value);
  356. /* Don't use this function. There are typed versions with no additional
  357. * overhead. */
  358. UA_StatusCode UA_EXPORT
  359. __UA_Server_write(UA_Server *server, const UA_NodeId *nodeId,
  360. const UA_AttributeId attributeId,
  361. const UA_DataType *type, const void *value);
  362. static UA_INLINE UA_StatusCode
  363. UA_Server_writeBrowseName(UA_Server *server, const UA_NodeId nodeId,
  364. const UA_QualifiedName browseName) {
  365. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_BROWSENAME,
  366. &UA_TYPES[UA_TYPES_QUALIFIEDNAME], &browseName);
  367. }
  368. static UA_INLINE UA_StatusCode
  369. UA_Server_writeDisplayName(UA_Server *server, const UA_NodeId nodeId,
  370. const UA_LocalizedText displayName) {
  371. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_DISPLAYNAME,
  372. &UA_TYPES[UA_TYPES_LOCALIZEDTEXT], &displayName);
  373. }
  374. static UA_INLINE UA_StatusCode
  375. UA_Server_writeDescription(UA_Server *server, const UA_NodeId nodeId,
  376. const UA_LocalizedText description) {
  377. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_DESCRIPTION,
  378. &UA_TYPES[UA_TYPES_LOCALIZEDTEXT], &description);
  379. }
  380. static UA_INLINE UA_StatusCode
  381. UA_Server_writeWriteMask(UA_Server *server, const UA_NodeId nodeId,
  382. const UA_UInt32 writeMask) {
  383. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_WRITEMASK,
  384. &UA_TYPES[UA_TYPES_UINT32], &writeMask);
  385. }
  386. static UA_INLINE UA_StatusCode
  387. UA_Server_writeIsAbstract(UA_Server *server, const UA_NodeId nodeId,
  388. const UA_Boolean isAbstract) {
  389. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_ISABSTRACT,
  390. &UA_TYPES[UA_TYPES_BOOLEAN], &isAbstract);
  391. }
  392. static UA_INLINE UA_StatusCode
  393. UA_Server_writeInverseName(UA_Server *server, const UA_NodeId nodeId,
  394. const UA_LocalizedText inverseName) {
  395. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_INVERSENAME,
  396. &UA_TYPES[UA_TYPES_LOCALIZEDTEXT], &inverseName);
  397. }
  398. static UA_INLINE UA_StatusCode
  399. UA_Server_writeEventNotifier(UA_Server *server, const UA_NodeId nodeId,
  400. const UA_Byte eventNotifier) {
  401. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_EVENTNOTIFIER,
  402. &UA_TYPES[UA_TYPES_BYTE], &eventNotifier);
  403. }
  404. static UA_INLINE UA_StatusCode
  405. UA_Server_writeValue(UA_Server *server, const UA_NodeId nodeId,
  406. const UA_Variant value) {
  407. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_VALUE,
  408. &UA_TYPES[UA_TYPES_VARIANT], &value);
  409. }
  410. static UA_INLINE UA_StatusCode
  411. UA_Server_writeAccessLevel(UA_Server *server, const UA_NodeId nodeId,
  412. const UA_UInt32 accessLevel) {
  413. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_ACCESSLEVEL,
  414. &UA_TYPES[UA_TYPES_UINT32], &accessLevel);
  415. }
  416. static UA_INLINE UA_StatusCode
  417. UA_Server_writeMinimumSamplingInterval(UA_Server *server, const UA_NodeId nodeId,
  418. const UA_Double miniumSamplingInterval) {
  419. return __UA_Server_write(server, &nodeId,
  420. UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL,
  421. &UA_TYPES[UA_TYPES_DOUBLE],
  422. &miniumSamplingInterval);
  423. }
  424. static UA_INLINE UA_StatusCode
  425. UA_Server_writeExecutable(UA_Server *server, const UA_NodeId nodeId,
  426. const UA_Boolean executable) {
  427. return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_EXECUTABLE,
  428. &UA_TYPES[UA_TYPES_BOOLEAN], &executable); }
  429. /**
  430. * Browsing
  431. * -------- */
  432. UA_BrowseResult UA_EXPORT
  433. UA_Server_browse(UA_Server *server, UA_UInt32 maxrefs,
  434. const UA_BrowseDescription *descr);
  435. UA_BrowseResult UA_EXPORT
  436. UA_Server_browseNext(UA_Server *server, UA_Boolean releaseContinuationPoint,
  437. const UA_ByteString *continuationPoint);
  438. #ifndef HAVE_NODEITER_CALLBACK
  439. #define HAVE_NODEITER_CALLBACK
  440. /* Iterate over all nodes referenced by parentNodeId by calling the callback
  441. * function for each child node (in ifdef because GCC/CLANG handle include order
  442. * differently) */
  443. typedef UA_StatusCode
  444. (*UA_NodeIteratorCallback)(UA_NodeId childId, UA_Boolean isInverse,
  445. UA_NodeId referenceTypeId, void *handle);
  446. #endif
  447. UA_StatusCode UA_EXPORT
  448. UA_Server_forEachChildNodeCall(UA_Server *server, UA_NodeId parentNodeId,
  449. UA_NodeIteratorCallback callback, void *handle);
  450. /**
  451. * Method Call
  452. * ----------- */
  453. #ifdef UA_ENABLE_METHODCALLS
  454. UA_CallMethodResult UA_EXPORT
  455. UA_Server_call(UA_Server *server, const UA_CallMethodRequest *request);
  456. #endif
  457. /**
  458. * Node Management
  459. * ---------------
  460. *
  461. * Callback Mechanisms
  462. * ^^^^^^^^^^^^^^^^^^^
  463. * There are four mechanisms for callbacks from the node-based information model
  464. * into userspace:
  465. *
  466. * - Datasources for variable nodes, where the variable content is managed
  467. * externally
  468. * - Value-callbacks for variable nodes, where userspace is notified when a
  469. * read/write occurs
  470. * - Object lifecycle management, where a user-defined constructor and
  471. * destructor is added to an object type
  472. * - Method callbacks, where a user-defined method is exposed in the information
  473. * model
  474. *
  475. * Data Source Callback
  476. * ~~~~~~~~~~~~~~~~~~~~
  477. *
  478. * The server has a unique way of dealing with the content of variables. Instead
  479. * of storing a variant attached to the variable node, the node can point to a
  480. * function with a local data provider. Whenever the value attribute is read,
  481. * the function will be called and asked to provide a UA_DataValue return value
  482. * that contains the value content and additional timestamps.
  483. *
  484. * It is expected that the read callback is implemented. The write callback can
  485. * be set to a null-pointer. */
  486. typedef struct {
  487. void *handle; /* A custom pointer to reuse the same datasource functions for
  488. multiple sources */
  489. /* Copies the data from the source into the provided value.
  490. *
  491. * @param handle An optional pointer to user-defined data for the
  492. * specific data source
  493. * @param nodeid Id of the read node
  494. * @param includeSourceTimeStamp If true, then the datasource is expected to
  495. * set the source timestamp in the returned value
  496. * @param range If not null, then the datasource shall return only a
  497. * selection of the (nonscalar) data. Set
  498. * UA_STATUSCODE_BADINDEXRANGEINVALID in the value if this does not
  499. * apply.
  500. * @param value The (non-null) DataValue that is returned to the client. The
  501. * data source sets the read data, the result status and optionally a
  502. * sourcetimestamp.
  503. * @return Returns a status code for logging. Error codes intended for the
  504. * original caller are set in the value. If an error is returned,
  505. * then no releasing of the value is done. */
  506. UA_StatusCode (*read)(void *handle, const UA_NodeId nodeid,
  507. UA_Boolean includeSourceTimeStamp,
  508. const UA_NumericRange *range, UA_DataValue *value);
  509. /* Write into a data source. The write member of UA_DataSource can be empty
  510. * if the operation is unsupported.
  511. *
  512. * @param handle An optional pointer to user-defined data for the
  513. * specific data source
  514. * @param nodeid Id of the node being written to
  515. * @param data The data to be written into the data source
  516. * @param range An optional data range. If the data source is scalar or does
  517. * not support writing of ranges, then an error code is returned.
  518. * @return Returns a status code that is returned to the user
  519. */
  520. UA_StatusCode (*write)(void *handle, const UA_NodeId nodeid,
  521. const UA_Variant *data, const UA_NumericRange *range);
  522. } UA_DataSource;
  523. UA_StatusCode UA_EXPORT
  524. UA_Server_setVariableNode_dataSource(UA_Server *server, const UA_NodeId nodeId,
  525. const UA_DataSource dataSource);
  526. /**
  527. * Value Callback
  528. * ~~~~~~~~~~~~~~
  529. * Value Callbacks can be attached to variable and variable type nodes. If
  530. * not-null, they are called before reading and after writing respectively. */
  531. typedef struct {
  532. void *handle;
  533. void (*onRead)(void *handle, const UA_NodeId nodeid,
  534. const UA_Variant *data, const UA_NumericRange *range);
  535. void (*onWrite)(void *handle, const UA_NodeId nodeid,
  536. const UA_Variant *data, const UA_NumericRange *range);
  537. } UA_ValueCallback;
  538. UA_StatusCode UA_EXPORT
  539. UA_Server_setVariableNode_valueCallback(UA_Server *server, const UA_NodeId nodeId,
  540. const UA_ValueCallback callback);
  541. /**
  542. * Object Lifecycle Management Callbacks
  543. * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  544. * Lifecycle management adds constructor and destructor callbacks to
  545. * object types. */
  546. typedef struct {
  547. /* Returns the instance handle that is then attached to the node */
  548. void * (*constructor)(const UA_NodeId instance);
  549. void (*destructor)(const UA_NodeId instance, void *instanceHandle);
  550. } UA_ObjectLifecycleManagement;
  551. UA_StatusCode UA_EXPORT
  552. UA_Server_setObjectTypeNode_lifecycleManagement(UA_Server *server,
  553. UA_NodeId nodeId,
  554. UA_ObjectLifecycleManagement olm);
  555. /**
  556. * Method Callbacks
  557. * ~~~~~~~~~~~~~~~~ */
  558. typedef UA_StatusCode
  559. (*UA_MethodCallback)(void *methodHandle, const UA_NodeId objectId,
  560. size_t inputSize, const UA_Variant *input,
  561. size_t outputSize, UA_Variant *output);
  562. #ifdef UA_ENABLE_METHODCALLS
  563. UA_StatusCode UA_EXPORT
  564. UA_Server_setMethodNode_callback(UA_Server *server, const UA_NodeId methodNodeId,
  565. UA_MethodCallback method, void *handle);
  566. #endif
  567. /**
  568. * .. _addnodes:
  569. *
  570. * Node Addition and Deletion
  571. * ^^^^^^^^^^^^^^^^^^^^^^^^^^
  572. *
  573. * When creating dynamic node instances at runtime, chances are that you will
  574. * not care about the specific NodeId of the new node, as long as you can
  575. * reference it later. When passing numeric NodeIds with a numeric identifier 0,
  576. * the stack evaluates this as "select a randome free NodeId in that namespace".
  577. * To find out which NodeId was actually assigned to the new node, you may pass
  578. * a pointer `outNewNodeId`, which will (after a successfull node insertion)
  579. * contain the nodeId of the new node. You may also pass NULL pointer if this
  580. * result is not relevant. The namespace index for nodes you create should never
  581. * be 0, as that index is reserved for OPC UA's self-description (namespace 0). */
  582. /* The instantiation callback is used to track the addition of new nodes. It is
  583. * also called for all sub-nodes contained in an object or variable type node
  584. * that is instantiated. */
  585. typedef struct {
  586. UA_StatusCode (*method)(const UA_NodeId objectId,
  587. const UA_NodeId typeDefinitionId, void *handle);
  588. void *handle;
  589. } UA_InstantiationCallback;
  590. /* Don't use this function. There are typed versions as inline functions. */
  591. UA_StatusCode UA_EXPORT
  592. __UA_Server_addNode(UA_Server *server, const UA_NodeClass nodeClass,
  593. const UA_NodeId requestedNewNodeId,
  594. const UA_NodeId parentNodeId,
  595. const UA_NodeId referenceTypeId,
  596. const UA_QualifiedName browseName,
  597. const UA_NodeId typeDefinition,
  598. const UA_NodeAttributes *attr,
  599. const UA_DataType *attributeType,
  600. UA_InstantiationCallback *instantiationCallback,
  601. UA_NodeId *outNewNodeId);
  602. static UA_INLINE UA_StatusCode
  603. UA_Server_addVariableNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
  604. const UA_NodeId parentNodeId,
  605. const UA_NodeId referenceTypeId,
  606. const UA_QualifiedName browseName,
  607. const UA_NodeId typeDefinition,
  608. const UA_VariableAttributes attr,
  609. UA_InstantiationCallback *instantiationCallback,
  610. UA_NodeId *outNewNodeId) {
  611. return __UA_Server_addNode(server, UA_NODECLASS_VARIABLE, requestedNewNodeId,
  612. parentNodeId, referenceTypeId, browseName,
  613. typeDefinition, (const UA_NodeAttributes*)&attr,
  614. &UA_TYPES[UA_TYPES_VARIABLEATTRIBUTES],
  615. instantiationCallback, outNewNodeId);
  616. }
  617. static UA_INLINE UA_StatusCode
  618. UA_Server_addVariableTypeNode(UA_Server *server,
  619. const UA_NodeId requestedNewNodeId,
  620. const UA_NodeId parentNodeId,
  621. const UA_NodeId referenceTypeId,
  622. const UA_QualifiedName browseName,
  623. const UA_VariableTypeAttributes attr,
  624. UA_InstantiationCallback *instantiationCallback,
  625. UA_NodeId *outNewNodeId) {
  626. return __UA_Server_addNode(server, UA_NODECLASS_VARIABLETYPE,
  627. requestedNewNodeId, parentNodeId, referenceTypeId,
  628. browseName, UA_NODEID_NULL,
  629. (const UA_NodeAttributes*)&attr,
  630. &UA_TYPES[UA_TYPES_VARIABLETYPEATTRIBUTES],
  631. instantiationCallback, outNewNodeId);
  632. }
  633. static UA_INLINE UA_StatusCode
  634. UA_Server_addObjectNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
  635. const UA_NodeId parentNodeId,
  636. const UA_NodeId referenceTypeId,
  637. const UA_QualifiedName browseName,
  638. const UA_NodeId typeDefinition,
  639. const UA_ObjectAttributes attr,
  640. UA_InstantiationCallback *instantiationCallback,
  641. UA_NodeId *outNewNodeId) {
  642. return __UA_Server_addNode(server, UA_NODECLASS_OBJECT, requestedNewNodeId,
  643. parentNodeId, referenceTypeId, browseName,
  644. typeDefinition, (const UA_NodeAttributes*)&attr,
  645. &UA_TYPES[UA_TYPES_OBJECTATTRIBUTES],
  646. instantiationCallback, outNewNodeId);
  647. }
  648. static UA_INLINE UA_StatusCode
  649. UA_Server_addObjectTypeNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
  650. const UA_NodeId parentNodeId,
  651. const UA_NodeId referenceTypeId,
  652. const UA_QualifiedName browseName,
  653. const UA_ObjectTypeAttributes attr,
  654. UA_InstantiationCallback *instantiationCallback,
  655. UA_NodeId *outNewNodeId) {
  656. return __UA_Server_addNode(server, UA_NODECLASS_OBJECTTYPE, requestedNewNodeId,
  657. parentNodeId, referenceTypeId, browseName,
  658. UA_NODEID_NULL, (const UA_NodeAttributes*)&attr,
  659. &UA_TYPES[UA_TYPES_OBJECTTYPEATTRIBUTES],
  660. instantiationCallback, outNewNodeId);
  661. }
  662. static UA_INLINE UA_StatusCode
  663. UA_Server_addViewNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
  664. const UA_NodeId parentNodeId,
  665. const UA_NodeId referenceTypeId,
  666. const UA_QualifiedName browseName,
  667. const UA_ViewAttributes attr,
  668. UA_InstantiationCallback *instantiationCallback,
  669. UA_NodeId *outNewNodeId) {
  670. return __UA_Server_addNode(server, UA_NODECLASS_VIEW, requestedNewNodeId,
  671. parentNodeId, referenceTypeId, browseName,
  672. UA_NODEID_NULL, (const UA_NodeAttributes*)&attr,
  673. &UA_TYPES[UA_TYPES_VIEWATTRIBUTES],
  674. instantiationCallback, outNewNodeId);
  675. }
  676. static UA_INLINE UA_StatusCode
  677. UA_Server_addReferenceTypeNode(UA_Server *server,
  678. const UA_NodeId requestedNewNodeId,
  679. const UA_NodeId parentNodeId,
  680. const UA_NodeId referenceTypeId,
  681. const UA_QualifiedName browseName,
  682. const UA_ReferenceTypeAttributes attr,
  683. UA_InstantiationCallback *instantiationCallback,
  684. UA_NodeId *outNewNodeId) {
  685. return __UA_Server_addNode(server, UA_NODECLASS_REFERENCETYPE,
  686. requestedNewNodeId, parentNodeId, referenceTypeId,
  687. browseName, UA_NODEID_NULL,
  688. (const UA_NodeAttributes*)&attr,
  689. &UA_TYPES[UA_TYPES_REFERENCETYPEATTRIBUTES],
  690. instantiationCallback, outNewNodeId);
  691. }
  692. static UA_INLINE UA_StatusCode
  693. UA_Server_addDataTypeNode(UA_Server *server,
  694. const UA_NodeId requestedNewNodeId,
  695. const UA_NodeId parentNodeId,
  696. const UA_NodeId referenceTypeId,
  697. const UA_QualifiedName browseName,
  698. const UA_DataTypeAttributes attr,
  699. UA_InstantiationCallback *instantiationCallback,
  700. UA_NodeId *outNewNodeId) {
  701. return __UA_Server_addNode(server, UA_NODECLASS_DATATYPE, requestedNewNodeId,
  702. parentNodeId, referenceTypeId, browseName,
  703. UA_NODEID_NULL, (const UA_NodeAttributes*)&attr,
  704. &UA_TYPES[UA_TYPES_DATATYPEATTRIBUTES],
  705. instantiationCallback, outNewNodeId);
  706. }
  707. UA_StatusCode UA_EXPORT
  708. UA_Server_addDataSourceVariableNode(UA_Server *server,
  709. const UA_NodeId requestedNewNodeId,
  710. const UA_NodeId parentNodeId,
  711. const UA_NodeId referenceTypeId,
  712. const UA_QualifiedName browseName,
  713. const UA_NodeId typeDefinition,
  714. const UA_VariableAttributes attr,
  715. const UA_DataSource dataSource,
  716. UA_NodeId *outNewNodeId);
  717. #ifdef UA_ENABLE_METHODCALLS
  718. UA_StatusCode UA_EXPORT
  719. UA_Server_addMethodNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
  720. const UA_NodeId parentNodeId,
  721. const UA_NodeId referenceTypeId,
  722. const UA_QualifiedName browseName,
  723. const UA_MethodAttributes attr,
  724. UA_MethodCallback method, void *handle,
  725. size_t inputArgumentsSize,
  726. const UA_Argument* inputArguments,
  727. size_t outputArgumentsSize,
  728. const UA_Argument* outputArguments,
  729. UA_NodeId *outNewNodeId);
  730. #endif
  731. UA_StatusCode UA_EXPORT
  732. UA_Server_deleteNode(UA_Server *server, const UA_NodeId nodeId,
  733. UA_Boolean deleteReferences);
  734. /**
  735. * Reference Management
  736. * -------------------- */
  737. UA_StatusCode UA_EXPORT
  738. UA_Server_addReference(UA_Server *server, const UA_NodeId sourceId,
  739. const UA_NodeId refTypeId,
  740. const UA_ExpandedNodeId targetId, UA_Boolean isForward);
  741. UA_StatusCode UA_EXPORT
  742. UA_Server_deleteReference(UA_Server *server, const UA_NodeId sourceNodeId,
  743. const UA_NodeId referenceTypeId, UA_Boolean isForward,
  744. const UA_ExpandedNodeId targetNodeId,
  745. UA_Boolean deleteBidirectional);
  746. #ifdef __cplusplus
  747. }
  748. #endif
  749. #endif /* UA_SERVER_H_ */