12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058 |
- /* This Source Code Form is subject to the terms of the Mozilla Public
- * License, v. 2.0. If a copy of the MPL was not distributed with this
- * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
- #ifndef UA_SERVER_H_
- #define UA_SERVER_H_
- #ifdef __cplusplus
- extern "C" {
- #endif
- #include "ua_types.h"
- #include "ua_types_generated.h"
- #include "ua_types_generated_handling.h"
- struct UA_ServerConfig;
- typedef struct UA_ServerConfig UA_ServerConfig;
- struct UA_Server;
- typedef struct UA_Server UA_Server;
- /**
- * .. _server:
- *
- * Server
- * ======
- *
- * .. include:: server_config.rst
- *
- * .. _server-lifecycle:
- *
- * Server Lifecycle
- * ---------------- */
- UA_Server UA_EXPORT * UA_Server_new(const UA_ServerConfig *config);
- void UA_EXPORT UA_Server_delete(UA_Server *server);
- /* Runs the main loop of the server. In each iteration, this calls into the
- * networklayers to see if messages have arrived.
- *
- * @param server The server object.
- * @param running The loop is run as long as *running is true.
- * Otherwise, the server shuts down.
- * @return Returns the statuscode of the UA_Server_run_shutdown method */
- UA_StatusCode UA_EXPORT
- UA_Server_run(UA_Server *server, volatile UA_Boolean *running);
- /* The prologue part of UA_Server_run (no need to use if you call
- * UA_Server_run) */
- UA_StatusCode UA_EXPORT
- UA_Server_run_startup(UA_Server *server);
- /* Executes a single iteration of the server's main loop.
- *
- * @param server The server object.
- * @param waitInternal Should we wait for messages in the networklayer?
- * Otherwise, the timouts for the networklayers are set to zero.
- * The default max wait time is 50millisec.
- * @return Returns how long we can wait until the next scheduled
- * callback (in ms) */
- UA_UInt16 UA_EXPORT
- UA_Server_run_iterate(UA_Server *server, UA_Boolean waitInternal);
- /* The epilogue part of UA_Server_run (no need to use if you call
- * UA_Server_run) */
- UA_StatusCode UA_EXPORT
- UA_Server_run_shutdown(UA_Server *server);
- /**
- * Repeated Callbacks
- * ------------------ */
- typedef void (*UA_ServerCallback)(UA_Server *server, void *data);
- /* Add a callback for cyclic repetition to the server.
- *
- * @param server The server object.
- * @param callback The callback that shall be added.
- * @param interval The callback shall be repeatedly executed with the given interval
- * (in ms). The interval must be larger than 5ms. The first execution
- * occurs at now() + interval at the latest.
- * @param callbackId Set to the identifier of the repeated callback . This can be used to cancel
- * the callback later on. If the pointer is null, the identifier is not set.
- * @return Upon success, UA_STATUSCODE_GOOD is returned.
- * An error code otherwise. */
- UA_StatusCode UA_EXPORT
- UA_Server_addRepeatedCallback(UA_Server *server, UA_ServerCallback callback,
- void *data, UA_UInt32 interval, UA_UInt64 *callbackId);
- UA_StatusCode UA_EXPORT
- UA_Server_changeRepeatedCallbackInterval(UA_Server *server, UA_UInt64 callbackId,
- UA_UInt32 interval);
- /* Remove a repeated callback.
- *
- * @param server The server object.
- * @param callbackId The id of the callback that shall be removed.
- * @return Upon success, UA_STATUSCODE_GOOD is returned.
- * An error code otherwise. */
- UA_StatusCode UA_EXPORT
- UA_Server_removeRepeatedCallback(UA_Server *server, UA_UInt64 callbackId);
- /**
- * Reading and Writing Node Attributes
- * -----------------------------------
- * The functions for reading and writing node attributes call the regular read
- * and write service in the background that are also used over the network.
- *
- * The following attributes cannot be read, since the local "admin" user always
- * has full rights.
- *
- * - UserWriteMask
- * - UserAccessLevel
- * - UserExecutable */
- /* Read an attribute of a node. The specialized functions below provide a more
- * concise syntax.
- *
- * @param server The server object.
- * @param item ReadValueIds contain the NodeId of the target node, the id of the
- * attribute to read and (optionally) an index range to read parts
- * of an array only. See the section on NumericRange for the format
- * used for array ranges.
- * @param timestamps Which timestamps to return for the attribute.
- * @return Returns a DataValue that contains either an error code, or a variant
- * with the attribute value and the timestamps. */
- UA_DataValue UA_EXPORT
- UA_Server_read(UA_Server *server, const UA_ReadValueId *item,
- UA_TimestampsToReturn timestamps);
-
- /* Don't use this function. There are typed versions for every supported
- * attribute. */
- UA_StatusCode UA_EXPORT
- __UA_Server_read(UA_Server *server, const UA_NodeId *nodeId,
- UA_AttributeId attributeId, void *v);
- static UA_INLINE UA_StatusCode
- UA_Server_readNodeId(UA_Server *server, const UA_NodeId nodeId,
- UA_NodeId *outNodeId) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_NODEID, outNodeId);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readNodeClass(UA_Server *server, const UA_NodeId nodeId,
- UA_NodeClass *outNodeClass) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_NODECLASS,
- outNodeClass);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readBrowseName(UA_Server *server, const UA_NodeId nodeId,
- UA_QualifiedName *outBrowseName) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_BROWSENAME,
- outBrowseName);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readDisplayName(UA_Server *server, const UA_NodeId nodeId,
- UA_LocalizedText *outDisplayName) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_DISPLAYNAME,
- outDisplayName);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readDescription(UA_Server *server, const UA_NodeId nodeId,
- UA_LocalizedText *outDescription) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_DESCRIPTION,
- outDescription);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readWriteMask(UA_Server *server, const UA_NodeId nodeId,
- UA_UInt32 *outWriteMask) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_WRITEMASK,
- outWriteMask);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readIsAbstract(UA_Server *server, const UA_NodeId nodeId,
- UA_Boolean *outIsAbstract) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_ISABSTRACT,
- outIsAbstract);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readSymmetric(UA_Server *server, const UA_NodeId nodeId,
- UA_Boolean *outSymmetric) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_SYMMETRIC,
- outSymmetric);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readInverseName(UA_Server *server, const UA_NodeId nodeId,
- UA_LocalizedText *outInverseName) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_INVERSENAME,
- outInverseName);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readContainsNoLoop(UA_Server *server, const UA_NodeId nodeId,
- UA_Boolean *outContainsNoLoops) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_CONTAINSNOLOOPS,
- outContainsNoLoops);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readEventNotifier(UA_Server *server, const UA_NodeId nodeId,
- UA_Byte *outEventNotifier) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_EVENTNOTIFIER,
- outEventNotifier);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readValue(UA_Server *server, const UA_NodeId nodeId,
- UA_Variant *outValue) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_VALUE, outValue);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readDataType(UA_Server *server, const UA_NodeId nodeId,
- UA_NodeId *outDataType) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_DATATYPE,
- outDataType);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readValueRank(UA_Server *server, const UA_NodeId nodeId,
- UA_Int32 *outValueRank) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_VALUERANK,
- outValueRank);
- }
- /* Returns a variant with an int32 array */
- static UA_INLINE UA_StatusCode
- UA_Server_readArrayDimensions(UA_Server *server, const UA_NodeId nodeId,
- UA_Variant *outArrayDimensions) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_ARRAYDIMENSIONS,
- outArrayDimensions);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readAccessLevel(UA_Server *server, const UA_NodeId nodeId,
- UA_Byte *outAccessLevel) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_ACCESSLEVEL,
- outAccessLevel);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readMinimumSamplingInterval(UA_Server *server, const UA_NodeId nodeId,
- UA_Double *outMinimumSamplingInterval) {
- return __UA_Server_read(server, &nodeId,
- UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL,
- outMinimumSamplingInterval);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readHistorizing(UA_Server *server, const UA_NodeId nodeId,
- UA_Boolean *outHistorizing) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_HISTORIZING,
- outHistorizing);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_readExecutable(UA_Server *server, const UA_NodeId nodeId,
- UA_Boolean *outExecutable) {
- return __UA_Server_read(server, &nodeId, UA_ATTRIBUTEID_EXECUTABLE,
- outExecutable);
- }
- /**
- * The following node attributes cannot be changed once a node has been created:
- *
- * - NodeClass
- * - NodeId
- * - Symmetric
- * - ContainsNoLoop
- *
- * The following attributes cannot be written from the server, as they are
- * specific to the different users and set by the access control callback:
- *
- * - UserWriteMask
- * - UserAccessLevel
- * - UserExecutable
- *
- * Historizing is currently unsupported */
- /* Overwrite an attribute of a node. The specialized functions below provide a
- * more concise syntax.
- *
- * @param server The server object.
- * @param value WriteValues contain the NodeId of the target node, the id of the
- * attribute to overwritten, the actual value and (optionally) an
- * index range to replace parts of an array only. of an array only.
- * See the section on NumericRange for the format used for array
- * ranges.
- * @return Returns a status code. */
- UA_StatusCode UA_EXPORT
- UA_Server_write(UA_Server *server, const UA_WriteValue *value);
- /* Don't use this function. There are typed versions with no additional
- * overhead. */
- UA_StatusCode UA_EXPORT
- __UA_Server_write(UA_Server *server, const UA_NodeId *nodeId,
- const UA_AttributeId attributeId,
- const UA_DataType *attr_type, const void *attr);
- static UA_INLINE UA_StatusCode
- UA_Server_writeBrowseName(UA_Server *server, const UA_NodeId nodeId,
- const UA_QualifiedName browseName) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_BROWSENAME,
- &UA_TYPES[UA_TYPES_QUALIFIEDNAME], &browseName);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeDisplayName(UA_Server *server, const UA_NodeId nodeId,
- const UA_LocalizedText displayName) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_DISPLAYNAME,
- &UA_TYPES[UA_TYPES_LOCALIZEDTEXT], &displayName);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeDescription(UA_Server *server, const UA_NodeId nodeId,
- const UA_LocalizedText description) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_DESCRIPTION,
- &UA_TYPES[UA_TYPES_LOCALIZEDTEXT], &description);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeWriteMask(UA_Server *server, const UA_NodeId nodeId,
- const UA_UInt32 writeMask) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_WRITEMASK,
- &UA_TYPES[UA_TYPES_UINT32], &writeMask);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeIsAbstract(UA_Server *server, const UA_NodeId nodeId,
- const UA_Boolean isAbstract) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_ISABSTRACT,
- &UA_TYPES[UA_TYPES_BOOLEAN], &isAbstract);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeInverseName(UA_Server *server, const UA_NodeId nodeId,
- const UA_LocalizedText inverseName) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_INVERSENAME,
- &UA_TYPES[UA_TYPES_LOCALIZEDTEXT], &inverseName);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeEventNotifier(UA_Server *server, const UA_NodeId nodeId,
- const UA_Byte eventNotifier) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_EVENTNOTIFIER,
- &UA_TYPES[UA_TYPES_BYTE], &eventNotifier);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeValue(UA_Server *server, const UA_NodeId nodeId,
- const UA_Variant value) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_VALUE,
- &UA_TYPES[UA_TYPES_VARIANT], &value);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeDataType(UA_Server *server, const UA_NodeId nodeId,
- const UA_NodeId dataType) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_DATATYPE,
- &UA_TYPES[UA_TYPES_NODEID], &dataType);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeValueRank(UA_Server *server, const UA_NodeId nodeId,
- const UA_Int32 valueRank) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_VALUERANK,
- &UA_TYPES[UA_TYPES_INT32], &valueRank);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeArrayDimensions(UA_Server *server, const UA_NodeId nodeId,
- const UA_Variant arrayDimensions) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_VALUE,
- &UA_TYPES[UA_TYPES_VARIANT], &arrayDimensions);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeAccessLevel(UA_Server *server, const UA_NodeId nodeId,
- const UA_Byte accessLevel) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_ACCESSLEVEL,
- &UA_TYPES[UA_TYPES_BYTE], &accessLevel);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeMinimumSamplingInterval(UA_Server *server, const UA_NodeId nodeId,
- const UA_Double miniumSamplingInterval) {
- return __UA_Server_write(server, &nodeId,
- UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL,
- &UA_TYPES[UA_TYPES_DOUBLE],
- &miniumSamplingInterval);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_writeExecutable(UA_Server *server, const UA_NodeId nodeId,
- const UA_Boolean executable) {
- return __UA_Server_write(server, &nodeId, UA_ATTRIBUTEID_EXECUTABLE,
- &UA_TYPES[UA_TYPES_BOOLEAN], &executable); }
- /**
- * Browsing
- * -------- */
- UA_BrowseResult UA_EXPORT
- UA_Server_browse(UA_Server *server, UA_UInt32 maxrefs,
- const UA_BrowseDescription *descr);
- UA_BrowseResult UA_EXPORT
- UA_Server_browseNext(UA_Server *server, UA_Boolean releaseContinuationPoint,
- const UA_ByteString *continuationPoint);
- UA_BrowsePathResult UA_EXPORT
- UA_Server_translateBrowsePathToNodeIds(UA_Server *server,
- const UA_BrowsePath *browsePath);
- #ifndef HAVE_NODEITER_CALLBACK
- #define HAVE_NODEITER_CALLBACK
- /* Iterate over all nodes referenced by parentNodeId by calling the callback
- * function for each child node (in ifdef because GCC/CLANG handle include order
- * differently) */
- typedef UA_StatusCode
- (*UA_NodeIteratorCallback)(UA_NodeId childId, UA_Boolean isInverse,
- UA_NodeId referenceTypeId, void *handle);
- #endif
- UA_StatusCode UA_EXPORT
- UA_Server_forEachChildNodeCall(UA_Server *server, UA_NodeId parentNodeId,
- UA_NodeIteratorCallback callback, void *handle);
- #ifdef UA_ENABLE_DISCOVERY
- /**
- * Discovery
- * --------- */
- /* Register the given server instance at the discovery server.
- * This should be called periodically.
- * The semaphoreFilePath is optional. If the given file is deleted,
- * the server will automatically be unregistered. This could be
- * for example a pid file which is deleted if the server crashes.
- *
- * When the server shuts down you need to call unregister.
- *
- * @param server
- * @param discoveryServerUrl if set to NULL, the default value
- * 'opc.tcp://localhost:4840' will be used
- * @param semaphoreFilePath optional parameter pointing to semaphore file. */
- UA_StatusCode UA_EXPORT
- UA_Server_register_discovery(UA_Server *server, const char* discoveryServerUrl,
- const char* semaphoreFilePath);
- /* Unregister the given server instance from the discovery server.
- * This should only be called when the server is shutting down.
- * @param server
- * @param discoveryServerUrl if set to NULL, the default value
- * 'opc.tcp://localhost:4840' will be used */
- UA_StatusCode UA_EXPORT
- UA_Server_unregister_discovery(UA_Server *server, const char* discoveryServerUrl);
- /* Adds a periodic callback to register the server with the LDS (local discovery server)
- * periodically. The interval between each register call is given as second parameter.
- * It should be 10 minutes by default (= 10*60*1000).
- *
- * The delayFirstRegisterMs parameter indicates the delay for the first register call.
- * If it is 0, the first register call will be after intervalMs milliseconds,
- * otherwise the server's first register will be after delayFirstRegisterMs.
- *
- * When you manually unregister the server, you also need to cancel the
- * periodic callback, otherwise it will be automatically be registered again.
- *
- * If you call this method multiple times for the same discoveryServerUrl, the older
- * periodic callback will be removed.
- *
- * @param server
- * @param discoveryServerUrl if set to NULL, the default value
- * 'opc.tcp://localhost:4840' will be used
- * @param intervalMs
- * @param delayFirstRegisterMs
- * @param periodicCallbackId */
- UA_StatusCode UA_EXPORT
- UA_Server_addPeriodicServerRegisterCallback(UA_Server *server, const char* discoveryServerUrl,
- UA_UInt32 intervalMs,
- UA_UInt32 delayFirstRegisterMs,
- UA_UInt64 *periodicCallbackId);
- /* Callback for RegisterServer. Data is passed from the register call */
- typedef void (*UA_Server_registerServerCallback)(const UA_RegisteredServer *registeredServer,
- void* data);
- /* Set the callback which is called if another server registeres or unregisters
- * with this instance. If called multiple times, previous data will be
- * overwritten.
- *
- * @param server
- * @param cb the callback
- * @param data data passed to the callback
- * @return UA_STATUSCODE_SUCCESS on success */
- void UA_EXPORT
- UA_Server_setRegisterServerCallback(UA_Server *server, UA_Server_registerServerCallback cb,
- void* data);
- #ifdef UA_ENABLE_DISCOVERY_MULTICAST
- /* Callback for server detected through mDNS. Data is passed from the register
- * call
- *
- * @param isServerAnnounce indicates if the server has just been detected. If
- * set to false, this means the server is shutting down.
- * @param isTxtReceived indicates if we already received the corresponding TXT
- * record with the path and caps data */
- typedef void (*UA_Server_serverOnNetworkCallback)(const UA_ServerOnNetwork *serverOnNetwork,
- UA_Boolean isServerAnnounce,
- UA_Boolean isTxtReceived, void* data);
- /* Set the callback which is called if another server is found through mDNS or
- * deleted. It will be called for any mDNS message from the remote server, thus
- * it may be called multiple times for the same instance. Also the SRV and TXT
- * records may arrive later, therefore for the first call the server
- * capabilities may not be set yet. If called multiple times, previous data will
- * be overwritten.
- *
- * @param server
- * @param cb the callback
- * @param data data passed to the callback
- * @return UA_STATUSCODE_SUCCESS on success */
- void UA_EXPORT
- UA_Server_setServerOnNetworkCallback(UA_Server *server,
- UA_Server_serverOnNetworkCallback cb,
- void* data);
- #endif /* UA_ENABLE_DISCOVERY_MULTICAST */
- #endif /* UA_ENABLE_DISCOVERY */
- /**
- * Information Model Callbacks
- * ---------------------------
- *
- * There are three places where a callback from an information model to
- * user-defined code can happen.
- *
- * - Custom node constructors and destructors
- * - Linking VariableNodes with an external data source
- * - MethodNode callbacks
- *
- * .. _node-lifecycle:
- *
- * Node Lifecycle: Constructors, Destructors and Node Contexts
- * ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
- *
- * To finalize the instantiation of a node, a (user-defined) constructor
- * callback is executed. There can be both a global constructor for all nodes
- * and node-type constructor specific to the TypeDefinition of the new node
- * (attached to an ObjectTypeNode or VariableTypeNode).
- *
- * In the hierarchy of ObjectTypes and VariableTypes, only the constructor of
- * the (lowest) type defined for the new node is executed. Note that every
- * Object and Variable can have only one ``isTypeOf`` reference. But type-nodes
- * can technically have several ``hasSubType`` references to implement multiple
- * inheritance. Issues of (multiple) inheritance in the constructor need to be
- * solved by the user.
- *
- * When a node is destroyed, the node-type destructor is called before the
- * global destructor. So the overall node lifecycle is as follows:
- *
- * 1. Global Constructor (set in the server config)
- * 2. Node-Type Constructor (for VariableType or ObjectTypes)
- * 3. (Usage-period of the Node)
- * 4. Node-Type Destructor
- * 5. Global Destructor
- *
- * The constructor and destructor callbacks can be set to ``NULL`` and are not
- * used in that case. If the node-type constructor fails, the global destructor
- * will be called before removing the node. The destructors are assumed to never
- * fail.
- *
- * Every node carries a user-context and a constructor-context pointer. The
- * user-context is used to attach custom data to a node. But the (user-defined)
- * constructors and destructors may replace the user-context pointer if they
- * wish to do so. The initial value for the constructor-context is ``NULL``.
- * When the ``AddNodes`` service is used over the network, the user-context
- * pointer of the new node is also initially set to ``NULL``. */
- /* To be set in the server config. */
- typedef struct {
- /* Can be NULL. May replace the nodeContext */
- UA_StatusCode (*constructor)(UA_Server *server,
- const UA_NodeId *sessionId, void *sessionContext,
- const UA_NodeId *nodeId, void **nodeContext);
- /* Can be NULL. The context cannot be replaced since the node is destroyed
- * immediately afterwards anyway. */
- void (*destructor)(UA_Server *server,
- const UA_NodeId *sessionId, void *sessionContext,
- const UA_NodeId *nodeId, void *nodeContext);
- } UA_GlobalNodeLifecycle;
- typedef struct {
- /* Can be NULL. May replace the nodeContext */
- UA_StatusCode (*constructor)(UA_Server *server,
- const UA_NodeId *sessionId, void *sessionContext,
- const UA_NodeId *typeNodeId, void *typeNodeContext,
- const UA_NodeId *nodeId, void **nodeContext);
- /* Can be NULL. May replace the nodeContext. */
- void (*destructor)(UA_Server *server,
- const UA_NodeId *sessionId, void *sessionContext,
- const UA_NodeId *typeNodeId, void *typeNodeContext,
- const UA_NodeId *nodeId, void **nodeContext);
- } UA_NodeTypeLifecycle;
- UA_StatusCode UA_EXPORT
- UA_Server_setNodeTypeLifecycle(UA_Server *server, UA_NodeId nodeId,
- UA_NodeTypeLifecycle lifecycle);
- UA_StatusCode UA_EXPORT
- UA_Server_getNodeContext(UA_Server *server, UA_NodeId nodeId,
- void **nodeContext);
- /* Careful! The user has to ensure that the destructor callbacks still work. */
- UA_StatusCode UA_EXPORT
- UA_Server_setNodeContext(UA_Server *server, UA_NodeId nodeId,
- void *nodeContext);
- /**
- * .. _datasource:
- *
- * Data Source Callback
- * ^^^^^^^^^^^^^^^^^^^^
- *
- * The server has a unique way of dealing with the content of variables. Instead
- * of storing a variant attached to the variable node, the node can point to a
- * function with a local data provider. Whenever the value attribute is read,
- * the function will be called and asked to provide a UA_DataValue return value
- * that contains the value content and additional timestamps.
- *
- * It is expected that the read callback is implemented. The write callback can
- * be set to a null-pointer. */
- typedef struct {
- /* Copies the data from the source into the provided value.
- *
- * !! ZERO-COPY OPERATIONS POSSIBLE !!
- * It is not required to return a copy of the actual content data. You can
- * return a pointer to memory owned by the user. Memory can be reused
- * between read callbacks of a DataSource, as the result is already encoded
- * on the network buffer between each read operation.
- *
- * To use zero-copy reads, set the value of the `value->value` Variant
- * without copying, e.g. with `UA_Variant_setScalar`. Then, also set
- * `value->value.storageType` to `UA_VARIANT_DATA_NODELETE` to prevent the
- * memory being cleaned up. Don't forget to also set `value->hasValue` to
- * true to indicate the presence of a value.
- *
- * @param handle An optional pointer to user-defined data for the
- * specific data source
- * @param nodeid Id of the read node
- * @param includeSourceTimeStamp If true, then the datasource is expected to
- * set the source timestamp in the returned value
- * @param range If not null, then the datasource shall return only a
- * selection of the (nonscalar) data. Set
- * UA_STATUSCODE_BADINDEXRANGEINVALID in the value if this does not
- * apply.
- * @param value The (non-null) DataValue that is returned to the client. The
- * data source sets the read data, the result status and optionally a
- * sourcetimestamp.
- * @return Returns a status code for logging. Error codes intended for the
- * original caller are set in the value. If an error is returned,
- * then no releasing of the value is done. */
- UA_StatusCode (*read)(UA_Server *server, const UA_NodeId *sessionId,
- void *sessionContext, const UA_NodeId *nodeId,
- void *nodeContext, UA_Boolean includeSourceTimeStamp,
- const UA_NumericRange *range, UA_DataValue *value);
- /* Write into a data source. This method pointer can be NULL if the
- * operation is unsupported.
- *
- * @param handle An optional pointer to user-defined data for the
- * specific data source
- * @param nodeid Id of the node being written to
- * @param data The data to be written into the data source
- * @param range An optional data range. If the data source is scalar or does
- * not support writing of ranges, then an error code is returned.
- * @return Returns a status code that is returned to the user */
- UA_StatusCode (*write)(UA_Server *server, const UA_NodeId *sessionId,
- void *sessionContext, const UA_NodeId *nodeId,
- void *nodeContext, const UA_NumericRange *range,
- const UA_DataValue *value);
- } UA_DataSource;
- UA_StatusCode UA_EXPORT
- UA_Server_setVariableNode_dataSource(UA_Server *server, const UA_NodeId nodeId,
- const UA_DataSource dataSource);
- /**
- * .. _value-callback:
- *
- * Value Callback
- * ^^^^^^^^^^^^^^
- * Value Callbacks can be attached to variable and variable type nodes. If
- * not ``NULL``, they are called before reading and after writing respectively. */
- typedef struct {
- /* Called before the value attribute is read. It is possible to write into the
- * value attribute during onRead (using the write service). The node is
- * re-opened afterwards so that changes are considered in the following read
- * operation.
- *
- * @param handle Points to user-provided data for the callback.
- * @param nodeid The identifier of the node.
- * @param data Points to the current node value.
- * @param range Points to the numeric range the client wants to read from
- * (or NULL). */
- void (*onRead)(UA_Server *server, const UA_NodeId *sessionId,
- void *sessionContext, const UA_NodeId *nodeid,
- void *nodeContext, const UA_NumericRange *range,
- const UA_DataValue *value);
- /* Called after writing the value attribute. The node is re-opened after
- * writing so that the new value is visible in the callback.
- *
- * @param server The server executing the callback
- * @sessionId The identifier of the session
- * @sessionContext Additional data attached to the session
- * in the access control layer
- * @param nodeid The identifier of the node.
- * @param nodeUserContext Additional data attached to the node by
- * the user.
- * @param nodeConstructorContext Additional data attached to the node
- * by the type constructor(s).
- * @param range Points to the numeric range the client wants to write to (or
- * NULL). */
- void (*onWrite)(UA_Server *server, const UA_NodeId *sessionId,
- void *sessionContext, const UA_NodeId *nodeId,
- void *nodeContext, const UA_NumericRange *range,
- const UA_DataValue *data);
- } UA_ValueCallback;
- UA_StatusCode UA_EXPORT
- UA_Server_setVariableNode_valueCallback(UA_Server *server,
- const UA_NodeId nodeId,
- const UA_ValueCallback callback);
- /**
- * Method Callbacks
- * ^^^^^^^^^^^^^^^^
- * Method callbacks are set to `NULL` (not executable) when a method node is added
- * over the network. In theory, it is possible to add a callback via
- * ``UA_Server_setMethodNode_callback`` within the global constructor when adding
- * methods over the network is really wanted. */
- typedef UA_StatusCode
- (*UA_MethodCallback)(UA_Server *server, const UA_NodeId *sessionId,
- void *sessionContext, const UA_NodeId *methodId,
- void *methodContext, const UA_NodeId *objectId,
- void *objectContext, size_t inputSize,
- const UA_Variant *input, size_t outputSize,
- UA_Variant *output);
- #ifdef UA_ENABLE_METHODCALLS
- UA_StatusCode UA_EXPORT
- UA_Server_setMethodNode_callback(UA_Server *server,
- const UA_NodeId methodNodeId,
- UA_MethodCallback methodCallback);
- UA_CallMethodResult UA_EXPORT
- UA_Server_call(UA_Server *server, const UA_CallMethodRequest *request);
- #endif
- /**
- * .. _addnodes:
- *
- * Node Addition and Deletion
- * --------------------------
- * When creating dynamic node instances at runtime, chances are that you will
- * not care about the specific NodeId of the new node, as long as you can
- * reference it later. When passing numeric NodeIds with a numeric identifier 0,
- * the stack evaluates this as "select a random unassigned numeric NodeId in
- * that namespace". To find out which NodeId was actually assigned to the new
- * node, you may pass a pointer `outNewNodeId`, which will (after a successful
- * node insertion) contain the nodeId of the new node. You may also pass a
- * ``NULL`` pointer if this result is not needed.
- *
- * See the Section :ref:`node-lifecycle` on constructors and on attaching
- * user-defined data to nodes.
- *
- * The methods for node addition and deletion take mostly const arguments that
- * are not modified. When creating a node, a deep copy of the node identifier,
- * node attributes, etc. is created. Therefore, it is possible to call for
- * example ``UA_Server_addVariablenode`` with a value attribute (a
- * :ref:`variant`) pointing to a memory location on the stack. If you need
- * changes to a variable value to manifest at a specific memory location, please
- * use a :ref:`datasource` or a :ref:`value-callback`. */
- /* Protect against redundant definitions for server/client */
- #ifndef UA_DEFAULT_ATTRIBUTES_DEFINED
- #define UA_DEFAULT_ATTRIBUTES_DEFINED
- /* The default for variables is "BaseDataType" for the datatype, -2 for the
- * valuerank and a read-accesslevel. */
- UA_EXPORT extern const UA_VariableAttributes UA_VariableAttributes_default;
- UA_EXPORT extern const UA_VariableTypeAttributes UA_VariableTypeAttributes_default;
- /* Methods are executable by default */
- UA_EXPORT extern const UA_MethodAttributes UA_MethodAttributes_default;
- /* The remaining attribute definitions are currently all zeroed out */
- UA_EXPORT extern const UA_ObjectAttributes UA_ObjectAttributes_default;
- UA_EXPORT extern const UA_ObjectTypeAttributes UA_ObjectTypeAttributes_default;
- UA_EXPORT extern const UA_ReferenceTypeAttributes UA_ReferenceTypeAttributes_default;
- UA_EXPORT extern const UA_DataTypeAttributes UA_DataTypeAttributes_default;
- UA_EXPORT extern const UA_ViewAttributes UA_ViewAttributes_default;
- #endif
- /* Don't use this function. There are typed versions as inline functions. */
- UA_StatusCode UA_EXPORT
- __UA_Server_addNode(UA_Server *server, const UA_NodeClass nodeClass,
- const UA_NodeId *requestedNewNodeId,
- const UA_NodeId *parentNodeId,
- const UA_NodeId *referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_NodeId *typeDefinition,
- const UA_NodeAttributes *attr,
- const UA_DataType *attributeType,
- void *nodeContext, UA_NodeId *outNewNodeId);
- static UA_INLINE UA_StatusCode
- UA_Server_addVariableNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_NodeId typeDefinition,
- const UA_VariableAttributes attr,
- void *nodeContext, UA_NodeId *outNewNodeId) {
- return __UA_Server_addNode(server, UA_NODECLASS_VARIABLE, &requestedNewNodeId,
- &parentNodeId, &referenceTypeId, browseName,
- &typeDefinition, (const UA_NodeAttributes*)&attr,
- &UA_TYPES[UA_TYPES_VARIABLEATTRIBUTES],
- nodeContext, outNewNodeId);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_addVariableTypeNode(UA_Server *server,
- const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_NodeId typeDefinition,
- const UA_VariableTypeAttributes attr,
- void *nodeContext, UA_NodeId *outNewNodeId) {
- return __UA_Server_addNode(server, UA_NODECLASS_VARIABLETYPE,
- &requestedNewNodeId, &parentNodeId, &referenceTypeId,
- browseName, &typeDefinition,
- (const UA_NodeAttributes*)&attr,
- &UA_TYPES[UA_TYPES_VARIABLETYPEATTRIBUTES],
- nodeContext, outNewNodeId);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_addObjectNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_NodeId typeDefinition,
- const UA_ObjectAttributes attr,
- void *nodeContext, UA_NodeId *outNewNodeId) {
- return __UA_Server_addNode(server, UA_NODECLASS_OBJECT, &requestedNewNodeId,
- &parentNodeId, &referenceTypeId, browseName,
- &typeDefinition, (const UA_NodeAttributes*)&attr,
- &UA_TYPES[UA_TYPES_OBJECTATTRIBUTES],
- nodeContext, outNewNodeId);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_addObjectTypeNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_ObjectTypeAttributes attr,
- void *nodeContext, UA_NodeId *outNewNodeId) {
- return __UA_Server_addNode(server, UA_NODECLASS_OBJECTTYPE, &requestedNewNodeId,
- &parentNodeId, &referenceTypeId, browseName,
- &UA_NODEID_NULL, (const UA_NodeAttributes*)&attr,
- &UA_TYPES[UA_TYPES_OBJECTTYPEATTRIBUTES],
- nodeContext, outNewNodeId);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_addViewNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_ViewAttributes attr,
- void *nodeContext, UA_NodeId *outNewNodeId) {
- return __UA_Server_addNode(server, UA_NODECLASS_VIEW, &requestedNewNodeId,
- &parentNodeId, &referenceTypeId, browseName,
- &UA_NODEID_NULL, (const UA_NodeAttributes*)&attr,
- &UA_TYPES[UA_TYPES_VIEWATTRIBUTES],
- nodeContext, outNewNodeId);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_addReferenceTypeNode(UA_Server *server,
- const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_ReferenceTypeAttributes attr,
- void *nodeContext, UA_NodeId *outNewNodeId) {
- return __UA_Server_addNode(server, UA_NODECLASS_REFERENCETYPE,
- &requestedNewNodeId, &parentNodeId, &referenceTypeId,
- browseName, &UA_NODEID_NULL,
- (const UA_NodeAttributes*)&attr,
- &UA_TYPES[UA_TYPES_REFERENCETYPEATTRIBUTES],
- nodeContext, outNewNodeId);
- }
- static UA_INLINE UA_StatusCode
- UA_Server_addDataTypeNode(UA_Server *server,
- const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_DataTypeAttributes attr,
- void *nodeContext, UA_NodeId *outNewNodeId) {
- return __UA_Server_addNode(server, UA_NODECLASS_DATATYPE, &requestedNewNodeId,
- &parentNodeId, &referenceTypeId, browseName,
- &UA_NODEID_NULL, (const UA_NodeAttributes*)&attr,
- &UA_TYPES[UA_TYPES_DATATYPEATTRIBUTES],
- nodeContext, outNewNodeId);
- }
- UA_StatusCode UA_EXPORT
- UA_Server_addDataSourceVariableNode(UA_Server *server,
- const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_NodeId typeDefinition,
- const UA_VariableAttributes attr,
- const UA_DataSource dataSource,
- void *nodeContext, UA_NodeId *outNewNodeId);
- UA_StatusCode UA_EXPORT
- UA_Server_addMethodNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_QualifiedName browseName,
- const UA_MethodAttributes attr, UA_MethodCallback method,
- size_t inputArgumentsSize, const UA_Argument* inputArguments,
- size_t outputArgumentsSize, const UA_Argument* outputArguments,
- void *nodeContext, UA_NodeId *outNewNodeId);
- /**
- * The method pair UA_Server_addNode_begin and _finish splits the AddNodes
- * service in two parts. This is useful if the node shall be modified before
- * finish the instantiation. For example to add children with specific NodeIds.
- * Otherwise, mandatory children (e.g. of an ObjectType) are added with
- * pseudo-random unique NodeIds. Existing children are detected during the
- * _finish part via their matching BrowseName.
- *
- * The _begin method prepares the node and adds it to the nodestore. It may copy
- * some unassigned attributes from the TypeDefinition node internally. The
- * _finish method adds the references to the parent (and the TypeDefinition if
- * applicable), copies mandatory children, performs type-checking of variables
- * and calls the node constructor(s) at the end. The _finish method may remove
- * the node if it encounters an error. */
- /* The ``attr`` argument must have a type according to the NodeClass.
- * ``VariableAttributes`` for variables, ``ObjectAttributes`` for objects, and
- * so on. Missing attributes are taken from the TypeDefinition node if
- * applicable. */
- UA_StatusCode UA_EXPORT
- UA_Server_addNode_begin(UA_Server *server, const UA_NodeClass nodeClass,
- const UA_NodeId requestedNewNodeId,
- const UA_QualifiedName browseName,
- const UA_NodeId typeDefinition,
- const void *attr, const UA_DataType *attributeType,
- void *nodeContext, UA_NodeId *outNewNodeId);
- UA_StatusCode UA_EXPORT
- UA_Server_addNode_finish(UA_Server *server, const UA_NodeId nodeId,
- const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId,
- const UA_NodeId typeDefinitionId);
- /* Deletes a node and optionally all references leading to the node. */
- UA_StatusCode UA_EXPORT
- UA_Server_deleteNode(UA_Server *server, const UA_NodeId nodeId,
- UA_Boolean deleteReferences);
- /**
- * Reference Management
- * -------------------- */
- UA_StatusCode UA_EXPORT
- UA_Server_addReference(UA_Server *server, const UA_NodeId sourceId,
- const UA_NodeId refTypeId,
- const UA_ExpandedNodeId targetId, UA_Boolean isForward);
- UA_StatusCode UA_EXPORT
- UA_Server_deleteReference(UA_Server *server, const UA_NodeId sourceNodeId,
- const UA_NodeId referenceTypeId, UA_Boolean isForward,
- const UA_ExpandedNodeId targetNodeId,
- UA_Boolean deleteBidirectional);
- /**
- * Utility Functions
- * ----------------- */
- /* Add a new namespace to the server. Returns the index of the new namespace */
- UA_UInt16 UA_EXPORT UA_Server_addNamespace(UA_Server *server, const char* name);
- /**
- * Deprecated Server API
- * ---------------------
- * This file contains outdated API definitions that are kept for backwards
- * compatibility. Please switch to the new API, as the following definitions
- * will be removed eventually.
- *
- * UA_Job API
- * ^^^^^^^^^^
- * UA_Job was replaced since it unnecessarily exposed server internals to the
- * end-user. Please use plain UA_ServerCallbacks instead. The following UA_Job
- * definition contains just the fraction of the original struct that was useful
- * to end-users. */
- typedef enum {
- UA_JOBTYPE_METHODCALL
- } UA_JobType;
- typedef struct {
- UA_JobType type;
- union {
- struct {
- void *data;
- UA_ServerCallback method;
- } methodCall;
- } job;
- } UA_Job;
- UA_DEPRECATED static UA_INLINE UA_StatusCode
- UA_Server_addRepeatedJob(UA_Server *server, UA_Job job,
- UA_UInt32 interval, UA_Guid *jobId) {
- return UA_Server_addRepeatedCallback(server, job.job.methodCall.method,
- job.job.methodCall.data, interval,
- (UA_UInt64*)(uintptr_t)jobId);
- }
- UA_DEPRECATED static UA_INLINE UA_StatusCode
- UA_Server_removeRepeatedJob(UA_Server *server, UA_Guid jobId) {
- return UA_Server_removeRepeatedCallback(server,
- *(UA_UInt64*)(uintptr_t)&jobId);
- }
- #ifdef __cplusplus
- }
- #endif
- #endif /* UA_SERVER_H_ */
|