open62541 1.4.15
Open source implementation of OPC UA
Loading...
Searching...
No Matches
Data Structures | Macros | Typedefs | Enumerations | Functions
ua_pubsub.h File Reference
#include <open62541/server.h>
#include <open62541/server_pubsub.h>
#include "open62541_queue.h"
#include "ziptree.h"
#include "ua_pubsub_networkmessage.h"

Go to the source code of this file.

Data Structures

struct  UA_PublishedDataSet
 
struct  UA_StandaloneSubscribedDataSet
 
struct  UA_PubSubConnection
 
struct  UA_DataSetWriterSample
 
struct  UA_DataSetWriter
 
struct  UA_WriterGroup
 
struct  UA_DataSetField
 
struct  UA_DataSetReader
 
struct  UA_ReaderGroup
 
struct  UA_TopicAssign
 
struct  UA_ReserveId
 
struct  UA_PubSubManager
 

Macros

#define UA_INTERNAL
 
#define UA_PUBSUB_MAXCHANNELS   8
 
#define UA_LOG_PDS_INTERNAL(LOGGER, LEVEL, PDS, MSG, ...)
 
#define UA_LOG_TRACE_DATASET(LOGGER, PDS, ...)    UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, TRACE, PDS, __VA_ARGS__, ""))
 
#define UA_LOG_DEBUG_DATASET(LOGGER, PDS, ...)    UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, DEBUG, PDS, __VA_ARGS__, ""))
 
#define UA_LOG_INFO_DATASET(LOGGER, PDS, ...)    UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, INFO, PDS, __VA_ARGS__, ""))
 
#define UA_LOG_WARNING_DATASET(LOGGER, PDS, ...)    UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, WARNING, PDS, __VA_ARGS__, ""))
 
#define UA_LOG_ERROR_DATASET(LOGGER, PDS, ...)    UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, ERROR, PDS, __VA_ARGS__, ""))
 
#define UA_LOG_FATAL_DATASET(LOGGER, PDS, ...)    UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, FATAL, PDS, __VA_ARGS__, ""))
 
#define UA_LOG_CONNECTION_INTERNAL(LOGGER, LEVEL, CONNECTION, MSG, ...)
 
#define UA_LOG_TRACE_CONNECTION(LOGGER, CONNECTION, ...)    UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, TRACE, CONNECTION, __VA_ARGS__, ""))
 
#define UA_LOG_DEBUG_CONNECTION(LOGGER, CONNECTION, ...)    UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, DEBUG, CONNECTION, __VA_ARGS__, ""))
 
#define UA_LOG_INFO_CONNECTION(LOGGER, CONNECTION, ...)    UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, INFO, CONNECTION, __VA_ARGS__, ""))
 
#define UA_LOG_WARNING_CONNECTION(LOGGER, CONNECTION, ...)    UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, WARNING, CONNECTION, __VA_ARGS__, ""))
 
#define UA_LOG_ERROR_CONNECTION(LOGGER, CONNECTION, ...)    UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, ERROR, CONNECTION, __VA_ARGS__, ""))
 
#define UA_LOG_FATAL_CONNECTION(LOGGER, CONNECTION, ...)    UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, FATAL, CONNECTION, __VA_ARGS__, ""))
 
#define UA_LOG_WRITER_INTERNAL(LOGGER, LEVEL, WRITER, MSG, ...)
 
#define UA_LOG_TRACE_WRITER(LOGGER, WRITER, ...)    UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, TRACE, WRITER, __VA_ARGS__, ""))
 
#define UA_LOG_DEBUG_WRITER(LOGGER, WRITER, ...)    UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, DEBUG, WRITER, __VA_ARGS__, ""))
 
#define UA_LOG_INFO_WRITER(LOGGER, WRITER, ...)    UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, INFO, WRITER, __VA_ARGS__, ""))
 
#define UA_LOG_WARNING_WRITER(LOGGER, WRITER, ...)    UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, WARNING, WRITER, __VA_ARGS__, ""))
 
#define UA_LOG_ERROR_WRITER(LOGGER, WRITER, ...)    UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, ERROR, WRITER, __VA_ARGS__, ""))
 
#define UA_LOG_FATAL_WRITER(LOGGER, WRITER, ...)    UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, FATAL, WRITER, __VA_ARGS__, ""))
 
#define UA_LOG_WRITERGROUP_INTERNAL(LOGGER, LEVEL, WRITERGROUP, MSG, ...)
 
#define UA_LOG_TRACE_WRITERGROUP(LOGGER, WRITERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, TRACE, WRITERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_DEBUG_WRITERGROUP(LOGGER, WRITERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, DEBUG, WRITERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_INFO_WRITERGROUP(LOGGER, WRITERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, INFO, WRITERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_WARNING_WRITERGROUP(LOGGER, WRITERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, WARNING, WRITERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_ERROR_WRITERGROUP(LOGGER, WRITERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, ERROR, WRITERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_FATAL_WRITERGROUP(LOGGER, WRITERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, FATAL, WRITERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_READER_INTERNAL(LOGGER, LEVEL, READER, MSG, ...)
 
#define UA_LOG_TRACE_READER(LOGGER, READER, ...)    UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, TRACE, READER, __VA_ARGS__, ""))
 
#define UA_LOG_DEBUG_READER(LOGGER, READER, ...)    UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, DEBUG, READER, __VA_ARGS__, ""))
 
#define UA_LOG_INFO_READER(LOGGER, READER, ...)    UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, INFO, READER, __VA_ARGS__, ""))
 
#define UA_LOG_WARNING_READER(LOGGER, READER, ...)    UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, WARNING, READER, __VA_ARGS__, ""))
 
#define UA_LOG_ERROR_READER(LOGGER, READER, ...)    UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, ERROR, READER, __VA_ARGS__, ""))
 
#define UA_LOG_FATAL_READER(LOGGER, READER, ...)    UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, FATAL, READER, __VA_ARGS__, ""))
 
#define UA_LOG_READERGROUP_INTERNAL(LOGGER, LEVEL, RG, MSG, ...)
 
#define UA_LOG_TRACE_READERGROUP(LOGGER, READERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, TRACE, READERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_DEBUG_READERGROUP(LOGGER, READERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, DEBUG, READERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_INFO_READERGROUP(LOGGER, READERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, INFO, READERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_WARNING_READERGROUP(LOGGER, READERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, WARNING, READERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_ERROR_READERGROUP(LOGGER, READERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, ERROR, READERGROUP, __VA_ARGS__, ""))
 
#define UA_LOG_FATAL_READERGROUP(LOGGER, READERGROUP, ...)    UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, FATAL, READERGROUP, __VA_ARGS__, ""))
 

Typedefs

typedef struct UA_WriterGroup UA_WriterGroup
 
typedef struct UA_ReaderGroup UA_ReaderGroup
 
typedef struct UA_SecurityGroup UA_SecurityGroup
 
typedef struct UA_PublishedDataSet UA_PublishedDataSet
 
typedef struct UA_StandaloneSubscribedDataSet UA_StandaloneSubscribedDataSet
 
typedef struct UA_PubSubConnection UA_PubSubConnection
 
typedef struct UA_DataSetWriterSample UA_DataSetWriterSample
 
typedef struct UA_DataSetWriter UA_DataSetWriter
 
typedef struct UA_DataSetField UA_DataSetField
 
typedef struct UA_DataSetReader UA_DataSetReader
 
typedef struct UA_TopicAssign UA_TopicAssign
 
typedef struct UA_ReserveId UA_ReserveId
 
typedef struct UA_PubSubManager UA_PubSubManager
 

Enumerations

enum  UA_ReserveIdType
 

Functions

UA_StatusCode UA_PublishedDataSetConfig_copy (const UA_PublishedDataSetConfig *src, UA_PublishedDataSetConfig *dst)
 
UA_PublishedDataSet * UA_PublishedDataSet_findPDSbyId (UA_Server *server, UA_NodeId identifier)
 
UA_PublishedDataSet * UA_PublishedDataSet_findPDSbyName (UA_Server *server, UA_String name)
 
UA_AddPublishedDataSetResult UA_PublishedDataSet_create (UA_Server *server, const UA_PublishedDataSetConfig *publishedDataSetConfig, UA_NodeId *pdsIdentifier)
 
void UA_PublishedDataSet_clear (UA_Server *server, UA_PublishedDataSet *publishedDataSet)
 
UA_StatusCode UA_PublishedDataSet_remove (UA_Server *server, UA_PublishedDataSet *publishedDataSet)
 
UA_StatusCode getPublishedDataSetConfig (UA_Server *server, const UA_NodeId pds, UA_PublishedDataSetConfig *config)
 
UA_StatusCode UA_StandaloneSubscribedDataSetConfig_copy (const UA_StandaloneSubscribedDataSetConfig *src, UA_StandaloneSubscribedDataSetConfig *dst)
 
UA_StandaloneSubscribedDataSet * UA_StandaloneSubscribedDataSet_findSDSbyId (UA_Server *server, UA_NodeId identifier)
 
UA_StandaloneSubscribedDataSet * UA_StandaloneSubscribedDataSet_findSDSbyName (UA_Server *server, UA_String identifier)
 
void UA_StandaloneSubscribedDataSet_clear (UA_Server *server, UA_StandaloneSubscribedDataSet *subscribedDataSet)
 
UA_StatusCode UA_PubSubConnectionConfig_copy (const UA_PubSubConnectionConfig *src, UA_PubSubConnectionConfig *dst)
 
UA_PubSubConnection * UA_PubSubConnection_findConnectionbyId (UA_Server *server, UA_NodeId connectionIdentifier)
 
UA_StatusCode UA_PubSubConnection_create (UA_Server *server, const UA_PubSubConnectionConfig *connectionConfig, UA_NodeId *connectionIdentifier)
 
void UA_PubSubConnectionConfig_clear (UA_PubSubConnectionConfig *connectionConfig)
 
void UA_PubSubConnection_delete (UA_Server *server, UA_PubSubConnection *c)
 
UA_StatusCode UA_PubSubConnection_connect (UA_Server *server, UA_PubSubConnection *c, UA_Boolean validate)
 
void UA_PubSubConnection_disconnect (UA_PubSubConnection *c)
 
UA_EventLoop * UA_PubSubConnection_getEL (UA_Server *server, UA_PubSubConnection *c)
 
UA_StatusCode UA_PubSubConnection_setPubSubState (UA_Server *server, UA_PubSubConnection *connection, UA_PubSubState state, UA_StatusCode cause)
 
UA_StatusCode UA_DataSetWriterConfig_copy (const UA_DataSetWriterConfig *src, UA_DataSetWriterConfig *dst)
 
UA_DataSetWriter * UA_DataSetWriter_findDSWbyId (UA_Server *server, UA_NodeId identifier)
 
UA_StatusCode UA_DataSetWriter_setPubSubState (UA_Server *server, UA_DataSetWriter *dataSetWriter, UA_PubSubState state, UA_StatusCode cause)
 
UA_StatusCode UA_DataSetWriter_generateDataSetMessage (UA_Server *server, UA_DataSetMessage *dataSetMessage, UA_DataSetWriter *dataSetWriter)
 
UA_StatusCode UA_DataSetWriter_prepareDataSet (UA_Server *server, UA_DataSetWriter *dsw, UA_DataSetMessage *dsm)
 
void UA_DataSetWriter_freezeConfiguration (UA_Server *server, UA_DataSetWriter *dsw)
 
void UA_DataSetWriter_unfreezeConfiguration (UA_Server *server, UA_DataSetWriter *dsw)
 
UA_StatusCode UA_DataSetWriter_create (UA_Server *server, const UA_NodeId writerGroup, const UA_NodeId dataSet, const UA_DataSetWriterConfig *dataSetWriterConfig, UA_NodeId *writerIdentifier)
 
UA_StatusCode UA_DataSetWriter_remove (UA_Server *server, UA_DataSetWriter *dataSetWriter)
 
UA_StatusCode UA_WriterGroup_create (UA_Server *server, const UA_NodeId connection, const UA_WriterGroupConfig *writerGroupConfig, UA_NodeId *writerGroupIdentifier)
 
UA_StatusCode UA_WriterGroup_remove (UA_Server *server, UA_WriterGroup *wg)
 
void UA_WriterGroup_disconnect (UA_WriterGroup *wg)
 
UA_StatusCode UA_WriterGroup_connect (UA_Server *server, UA_WriterGroup *wg, UA_Boolean validate)
 
UA_StatusCode setWriterGroupEncryptionKeys (UA_Server *server, const UA_NodeId writerGroup, UA_UInt32 securityTokenId, const UA_ByteString signingKey, const UA_ByteString encryptingKey, const UA_ByteString keyNonce)
 
UA_StatusCode UA_WriterGroupConfig_copy (const UA_WriterGroupConfig *src, UA_WriterGroupConfig *dst)
 
UA_WriterGroup * UA_WriterGroup_findWGbyId (UA_Server *server, UA_NodeId identifier)
 
UA_StatusCode UA_WriterGroup_freezeConfiguration (UA_Server *server, UA_WriterGroup *wg)
 
UA_StatusCode UA_WriterGroup_unfreezeConfiguration (UA_Server *server, UA_WriterGroup *wg)
 
UA_StatusCode UA_WriterGroup_setPubSubState (UA_Server *server, UA_WriterGroup *writerGroup, UA_PubSubState state, UA_StatusCode cause)
 
UA_StatusCode UA_WriterGroup_addPublishCallback (UA_Server *server, UA_WriterGroup *writerGroup)
 
void UA_WriterGroup_publishCallback (UA_Server *server, UA_WriterGroup *writerGroup)
 
UA_StatusCode UA_WriterGroup_updateConfig (UA_Server *server, UA_WriterGroup *wg, const UA_WriterGroupConfig *config)
 
UA_StatusCode UA_DataSetFieldConfig_copy (const UA_DataSetFieldConfig *src, UA_DataSetFieldConfig *dst)
 
UA_DataSetField * UA_DataSetField_findDSFbyId (UA_Server *server, UA_NodeId identifier)
 
UA_DataSetFieldResult UA_DataSetField_remove (UA_Server *server, UA_DataSetField *currentField)
 
UA_DataSetFieldResult UA_DataSetField_create (UA_Server *server, const UA_NodeId publishedDataSet, const UA_DataSetFieldConfig *fieldConfig, UA_NodeId *fieldIdentifier)
 
void UA_PubSubDataSetField_sampleValue (UA_Server *server, UA_DataSetField *field, UA_DataValue *value)
 
void UA_DataSetReader_process (UA_Server *server, UA_ReaderGroup *readerGroup, UA_DataSetReader *dataSetReader, UA_DataSetMessage *dataSetMsg)
 
UA_StatusCode UA_DataSetReader_checkIdentifier (UA_Server *server, UA_NetworkMessage *msg, UA_DataSetReader *reader, UA_ReaderGroupConfig readerGroupConfig)
 
UA_StatusCode UA_DataSetReader_create (UA_Server *server, UA_NodeId readerGroupIdentifier, const UA_DataSetReaderConfig *dataSetReaderConfig, UA_NodeId *readerIdentifier)
 
UA_StatusCode UA_DataSetReader_remove (UA_Server *server, UA_DataSetReader *dsr)
 
UA_StatusCode UA_TargetVariables_copy (const UA_TargetVariables *src, UA_TargetVariables *dst)
 
void UA_TargetVariables_clear (UA_TargetVariables *subscribedDataSetTarget)
 
UA_StatusCode UA_FieldTargetVariable_copy (const UA_FieldTargetVariable *src, UA_FieldTargetVariable *dst)
 
UA_StatusCode DataSetReader_createTargetVariables (UA_Server *server, UA_DataSetReader *dsr, size_t targetVariablesSize, const UA_FieldTargetVariable *targetVariables)
 
UA_StatusCode UA_DataSetReader_setPubSubState (UA_Server *server, UA_DataSetReader *dataSetReader, UA_PubSubState state, UA_StatusCode cause)
 
UA_StatusCode UA_ReaderGroup_create (UA_Server *server, UA_NodeId connectionId, const UA_ReaderGroupConfig *rgc, UA_NodeId *readerGroupId)
 
UA_StatusCode UA_ReaderGroup_remove (UA_Server *server, UA_ReaderGroup *rg)
 
UA_StatusCode UA_ReaderGroup_connect (UA_Server *server, UA_ReaderGroup *rg, UA_Boolean validate)
 
void UA_ReaderGroup_disconnect (UA_ReaderGroup *rg)
 
UA_StatusCode setReaderGroupEncryptionKeys (UA_Server *server, const UA_NodeId readerGroup, UA_UInt32 securityTokenId, const UA_ByteString signingKey, const UA_ByteString encryptingKey, const UA_ByteString keyNonce)
 
UA_StatusCode UA_ReaderGroupConfig_copy (const UA_ReaderGroupConfig *src, UA_ReaderGroupConfig *dst)
 
UA_ReaderGroup * UA_ReaderGroup_findRGbyId (UA_Server *server, UA_NodeId identifier)
 
UA_DataSetReader * UA_ReaderGroup_findDSRbyId (UA_Server *server, UA_NodeId identifier)
 
UA_StatusCode UA_ReaderGroup_freezeConfiguration (UA_Server *server, UA_ReaderGroup *rg)
 
UA_StatusCode UA_ReaderGroup_unfreezeConfiguration (UA_Server *server, UA_ReaderGroup *rg)
 
UA_StatusCode UA_ReaderGroup_setPubSubState (UA_Server *server, UA_ReaderGroup *readerGroup, UA_PubSubState state, UA_StatusCode cause)
 
UA_Boolean UA_ReaderGroup_decodeAndProcessRT (UA_Server *server, UA_ReaderGroup *readerGroup, UA_ByteString *buf)
 
UA_Boolean UA_ReaderGroup_process (UA_Server *server, UA_ReaderGroup *readerGroup, UA_NetworkMessage *nm)
 
UA_StatusCode decodeNetworkMessage (UA_Server *server, UA_ByteString *buffer, size_t *pos, UA_NetworkMessage *nm, UA_PubSubConnection *connection)
 
typedef ZIP_HEAD (UA_ReserveIdTree, UA_ReserveId) UA_ReserveIdTree
 
UA_StatusCode UA_PubSubManager_addPubSubTopicAssign (UA_Server *server, UA_ReaderGroup *readerGroup, UA_String topic)
 
UA_StatusCode UA_PubSubManager_reserveIds (UA_Server *server, UA_NodeId sessionId, UA_UInt16 numRegWriterGroupIds, UA_UInt16 numRegDataSetWriterIds, UA_String transportProfileUri, UA_UInt16 **writerGroupIds, UA_UInt16 **dataSetWriterIds)
 
void UA_PubSubManager_freeIds (UA_Server *server)
 
void UA_PubSubManager_init (UA_Server *server, UA_PubSubManager *pubSubManager)
 
void UA_PubSubManager_shutdown (UA_Server *server, UA_PubSubManager *pubSubManager)
 
void UA_PubSubManager_delete (UA_Server *server, UA_PubSubManager *pubSubManager)
 
void UA_PubSubManager_generateUniqueNodeId (UA_PubSubManager *psm, UA_NodeId *nodeId)
 
UA_Guid UA_PubSubManager_generateUniqueGuid (UA_Server *server)
 
UA_UInt32 UA_PubSubConfigurationVersionTimeDifference (void)
 

Macro Definition Documentation

◆ UA_INTERNAL

#define UA_INTERNAL

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/.

Copyright (c) 2017-2019 Fraunhofer IOSB (Author: Andreas Ebner) Copyright (c) 2019 Kalycito Infotech Private Limited Copyright (c) 2020 Yannick Wallerer, Siemens AG Copyright (c) 2020, 2022 Thomas Fischer, Siemens AG Copyright (c) 2021 Fraunhofer IOSB (Author: Jan Hermes) Copyright (c) 2022 Siemens AG (Author: Thomas Fischer) Copyright (c) 2022 Fraunhofer IOSB (Author: Noel Graf) Copyright (c) 2022 Linutronix GmbH (Author: Muddasir Shakil)

Definition at line 18 of file ua_pubsub.h.

◆ UA_LOG_CONNECTION_INTERNAL

#define UA_LOG_CONNECTION_INTERNAL (   LOGGER,
  LEVEL,
  CONNECTION,
  MSG,
  ... 
)
Value:
if(UA_LOGLEVEL <= UA_LOGLEVEL_##LEVEL) { \
UA_String idStr = UA_STRING_NULL; \
if(CONNECTION) \
UA_NodeId_print(&(CONNECTION)->identifier, &idStr); \
UA_LOG_##LEVEL(LOGGER, UA_LOGCATEGORY_PUBSUB, \
"Connection %.*s\t| " MSG "%.0s", (int)idStr.length, \
(char*)idStr.data, __VA_ARGS__); \
UA_String_clear(&idStr); \
}
UA_LOGLEVEL
#define UA_LOGLEVEL
Select default architecture if none is selected.
Definition config.h:32
UA_LOGCATEGORY_PUBSUB
@ UA_LOGCATEGORY_PUBSUB
Definition log.h:40
UA_String
Definition types.h:119
UA_String::data
UA_Byte * data
Definition types.h:121
UA_String::length
size_t length
Definition types.h:120
UA_STRING_NULL
UA_EXPORT const UA_String UA_STRING_NULL

Definition at line 208 of file ua_pubsub.h.

◆ UA_LOG_DEBUG_CONNECTION

#define UA_LOG_DEBUG_CONNECTION (   LOGGER,
  CONNECTION,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, DEBUG, CONNECTION, __VA_ARGS__, ""))

Definition at line 221 of file ua_pubsub.h.

◆ UA_LOG_DEBUG_DATASET

#define UA_LOG_DEBUG_DATASET (   LOGGER,
  PDS,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, DEBUG, PDS, __VA_ARGS__, ""))

Definition at line 118 of file ua_pubsub.h.

◆ UA_LOG_DEBUG_READER

#define UA_LOG_DEBUG_READER (   LOGGER,
  READER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, DEBUG, READER, __VA_ARGS__, ""))

Definition at line 561 of file ua_pubsub.h.

◆ UA_LOG_DEBUG_READERGROUP

#define UA_LOG_DEBUG_READERGROUP (   LOGGER,
  READERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, DEBUG, READERGROUP, __VA_ARGS__, ""))

Definition at line 671 of file ua_pubsub.h.

◆ UA_LOG_DEBUG_WRITER

#define UA_LOG_DEBUG_WRITER (   LOGGER,
  WRITER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, DEBUG, WRITER, __VA_ARGS__, ""))

Definition at line 317 of file ua_pubsub.h.

◆ UA_LOG_DEBUG_WRITERGROUP

#define UA_LOG_DEBUG_WRITERGROUP (   LOGGER,
  WRITERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, DEBUG, WRITERGROUP, __VA_ARGS__, ""))

Definition at line 430 of file ua_pubsub.h.

◆ UA_LOG_ERROR_CONNECTION

#define UA_LOG_ERROR_CONNECTION (   LOGGER,
  CONNECTION,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, ERROR, CONNECTION, __VA_ARGS__, ""))

Definition at line 227 of file ua_pubsub.h.

◆ UA_LOG_ERROR_DATASET

#define UA_LOG_ERROR_DATASET (   LOGGER,
  PDS,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, ERROR, PDS, __VA_ARGS__, ""))

Definition at line 124 of file ua_pubsub.h.

◆ UA_LOG_ERROR_READER

#define UA_LOG_ERROR_READER (   LOGGER,
  READER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, ERROR, READER, __VA_ARGS__, ""))

Definition at line 567 of file ua_pubsub.h.

◆ UA_LOG_ERROR_READERGROUP

#define UA_LOG_ERROR_READERGROUP (   LOGGER,
  READERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, ERROR, READERGROUP, __VA_ARGS__, ""))

Definition at line 677 of file ua_pubsub.h.

◆ UA_LOG_ERROR_WRITER

#define UA_LOG_ERROR_WRITER (   LOGGER,
  WRITER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, ERROR, WRITER, __VA_ARGS__, ""))

Definition at line 323 of file ua_pubsub.h.

◆ UA_LOG_ERROR_WRITERGROUP

#define UA_LOG_ERROR_WRITERGROUP (   LOGGER,
  WRITERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, ERROR, WRITERGROUP, __VA_ARGS__, ""))

Definition at line 436 of file ua_pubsub.h.

◆ UA_LOG_FATAL_CONNECTION

#define UA_LOG_FATAL_CONNECTION (   LOGGER,
  CONNECTION,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, FATAL, CONNECTION, __VA_ARGS__, ""))

Definition at line 229 of file ua_pubsub.h.

◆ UA_LOG_FATAL_DATASET

#define UA_LOG_FATAL_DATASET (   LOGGER,
  PDS,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, FATAL, PDS, __VA_ARGS__, ""))

Definition at line 126 of file ua_pubsub.h.

◆ UA_LOG_FATAL_READER

#define UA_LOG_FATAL_READER (   LOGGER,
  READER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, FATAL, READER, __VA_ARGS__, ""))

Definition at line 569 of file ua_pubsub.h.

◆ UA_LOG_FATAL_READERGROUP

#define UA_LOG_FATAL_READERGROUP (   LOGGER,
  READERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, FATAL, READERGROUP, __VA_ARGS__, ""))

Definition at line 679 of file ua_pubsub.h.

◆ UA_LOG_FATAL_WRITER

#define UA_LOG_FATAL_WRITER (   LOGGER,
  WRITER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, FATAL, WRITER, __VA_ARGS__, ""))

Definition at line 325 of file ua_pubsub.h.

◆ UA_LOG_FATAL_WRITERGROUP

#define UA_LOG_FATAL_WRITERGROUP (   LOGGER,
  WRITERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, FATAL, WRITERGROUP, __VA_ARGS__, ""))

Definition at line 438 of file ua_pubsub.h.

◆ UA_LOG_INFO_CONNECTION

#define UA_LOG_INFO_CONNECTION (   LOGGER,
  CONNECTION,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, INFO, CONNECTION, __VA_ARGS__, ""))

Definition at line 223 of file ua_pubsub.h.

◆ UA_LOG_INFO_DATASET

#define UA_LOG_INFO_DATASET (   LOGGER,
  PDS,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, INFO, PDS, __VA_ARGS__, ""))

Definition at line 120 of file ua_pubsub.h.

◆ UA_LOG_INFO_READER

#define UA_LOG_INFO_READER (   LOGGER,
  READER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, INFO, READER, __VA_ARGS__, ""))

Definition at line 563 of file ua_pubsub.h.

◆ UA_LOG_INFO_READERGROUP

#define UA_LOG_INFO_READERGROUP (   LOGGER,
  READERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, INFO, READERGROUP, __VA_ARGS__, ""))

Definition at line 673 of file ua_pubsub.h.

◆ UA_LOG_INFO_WRITER

#define UA_LOG_INFO_WRITER (   LOGGER,
  WRITER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, INFO, WRITER, __VA_ARGS__, ""))

Definition at line 319 of file ua_pubsub.h.

◆ UA_LOG_INFO_WRITERGROUP

#define UA_LOG_INFO_WRITERGROUP (   LOGGER,
  WRITERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, INFO, WRITERGROUP, __VA_ARGS__, ""))

Definition at line 432 of file ua_pubsub.h.

◆ UA_LOG_PDS_INTERNAL

#define UA_LOG_PDS_INTERNAL (   LOGGER,
  LEVEL,
  PDS,
  MSG,
  ... 
)
Value:
if(UA_LOGLEVEL <= UA_LOGLEVEL_##LEVEL) { \
UA_String idStr = UA_STRING_NULL; \
if(PDS) \
UA_NodeId_print(&(PDS)->identifier, &idStr); \
UA_LOG_##LEVEL(LOGGER, UA_LOGCATEGORY_PUBSUB, \
"DataSet %.*s\t| " MSG "%.0s", (int)idStr.length, \
(char*)idStr.data, __VA_ARGS__); \
UA_String_clear(&idStr); \
}

Definition at line 105 of file ua_pubsub.h.

◆ UA_LOG_READER_INTERNAL

#define UA_LOG_READER_INTERNAL (   LOGGER,
  LEVEL,
  READER,
  MSG,
  ... 
)
Value:
if(UA_LOGLEVEL <= UA_LOGLEVEL_##LEVEL) { \
UA_String idStr = UA_STRING_NULL; \
UA_String groupIdStr = UA_STRING_NULL; \
if(READER) { \
UA_NodeId_print(&(READER)->identifier, &idStr); \
UA_NodeId_print(&(READER)->linkedReaderGroup, &groupIdStr); \
} \
UA_LOG_##LEVEL(LOGGER, UA_LOGCATEGORY_PUBSUB, \
"ReaderGroup %.*s\t| Reader %.*s\t| " MSG "%.0s", \
(int)groupIdStr.length, (char*)groupIdStr.data, \
(int)idStr.length, (char*)idStr.data, \
__VA_ARGS__); \
UA_String_clear(&idStr); \
UA_String_clear(&groupIdStr); \
}

Definition at line 542 of file ua_pubsub.h.

◆ UA_LOG_READERGROUP_INTERNAL

#define UA_LOG_READERGROUP_INTERNAL (   LOGGER,
  LEVEL,
  RG,
  MSG,
  ... 
)
Value:
if(UA_LOGLEVEL <= UA_LOGLEVEL_##LEVEL) { \
UA_String idStr = UA_STRING_NULL; \
if(RG) \
UA_NodeId_print(&(RG)->identifier, &idStr); \
UA_LOG_##LEVEL(LOGGER, UA_LOGCATEGORY_PUBSUB, \
"ReaderGroup %.*s\t| " MSG "%.0s", (int)idStr.length, \
(char*)idStr.data, __VA_ARGS__); \
UA_String_clear(&idStr); \
}

Definition at line 658 of file ua_pubsub.h.

◆ UA_LOG_TRACE_CONNECTION

#define UA_LOG_TRACE_CONNECTION (   LOGGER,
  CONNECTION,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, TRACE, CONNECTION, __VA_ARGS__, ""))

Definition at line 219 of file ua_pubsub.h.

◆ UA_LOG_TRACE_DATASET

#define UA_LOG_TRACE_DATASET (   LOGGER,
  PDS,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, TRACE, PDS, __VA_ARGS__, ""))

Definition at line 116 of file ua_pubsub.h.

◆ UA_LOG_TRACE_READER

#define UA_LOG_TRACE_READER (   LOGGER,
  READER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, TRACE, READER, __VA_ARGS__, ""))

Definition at line 559 of file ua_pubsub.h.

◆ UA_LOG_TRACE_READERGROUP

#define UA_LOG_TRACE_READERGROUP (   LOGGER,
  READERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, TRACE, READERGROUP, __VA_ARGS__, ""))

Definition at line 669 of file ua_pubsub.h.

◆ UA_LOG_TRACE_WRITER

#define UA_LOG_TRACE_WRITER (   LOGGER,
  WRITER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, TRACE, WRITER, __VA_ARGS__, ""))

Definition at line 315 of file ua_pubsub.h.

◆ UA_LOG_TRACE_WRITERGROUP

#define UA_LOG_TRACE_WRITERGROUP (   LOGGER,
  WRITERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, TRACE, WRITERGROUP, __VA_ARGS__, ""))

Definition at line 428 of file ua_pubsub.h.

◆ UA_LOG_WARNING_CONNECTION

#define UA_LOG_WARNING_CONNECTION (   LOGGER,
  CONNECTION,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_CONNECTION_INTERNAL(LOGGER, WARNING, CONNECTION, __VA_ARGS__, ""))

Definition at line 225 of file ua_pubsub.h.

◆ UA_LOG_WARNING_DATASET

#define UA_LOG_WARNING_DATASET (   LOGGER,
  PDS,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_PDS_INTERNAL(LOGGER, WARNING, PDS, __VA_ARGS__, ""))

Definition at line 122 of file ua_pubsub.h.

◆ UA_LOG_WARNING_READER

#define UA_LOG_WARNING_READER (   LOGGER,
  READER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READER_INTERNAL(LOGGER, WARNING, READER, __VA_ARGS__, ""))

Definition at line 565 of file ua_pubsub.h.

◆ UA_LOG_WARNING_READERGROUP

#define UA_LOG_WARNING_READERGROUP (   LOGGER,
  READERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_READERGROUP_INTERNAL(LOGGER, WARNING, READERGROUP, __VA_ARGS__, ""))

Definition at line 675 of file ua_pubsub.h.

◆ UA_LOG_WARNING_WRITER

#define UA_LOG_WARNING_WRITER (   LOGGER,
  WRITER,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITER_INTERNAL(LOGGER, WARNING, WRITER, __VA_ARGS__, ""))

Definition at line 321 of file ua_pubsub.h.

◆ UA_LOG_WARNING_WRITERGROUP

#define UA_LOG_WARNING_WRITERGROUP (   LOGGER,
  WRITERGROUP,
  ... 
)     UA_MACRO_EXPAND(UA_LOG_WRITERGROUP_INTERNAL(LOGGER, WARNING, WRITERGROUP, __VA_ARGS__, ""))

Definition at line 434 of file ua_pubsub.h.

◆ UA_LOG_WRITER_INTERNAL

#define UA_LOG_WRITER_INTERNAL (   LOGGER,
  LEVEL,
  WRITER,
  MSG,
  ... 
)
Value:
if(UA_LOGLEVEL <= UA_LOGLEVEL_##LEVEL) { \
UA_String idStr = UA_STRING_NULL; \
UA_String groupIdStr = UA_STRING_NULL; \
if(WRITER) { \
UA_NodeId_print(&(WRITER)->identifier, &idStr); \
UA_NodeId_print(&(WRITER)->linkedWriterGroup, &groupIdStr); \
} \
UA_LOG_##LEVEL(LOGGER, UA_LOGCATEGORY_PUBSUB, \
"WriterGroup %.*s\t| Writer %.*s\t| " MSG "%.0s", \
(int)groupIdStr.length, (char*)groupIdStr.data, \
(int)idStr.length, (char*)idStr.data, \
__VA_ARGS__); \
UA_String_clear(&idStr); \
UA_String_clear(&groupIdStr); \
}

Definition at line 298 of file ua_pubsub.h.

◆ UA_LOG_WRITERGROUP_INTERNAL

#define UA_LOG_WRITERGROUP_INTERNAL (   LOGGER,
  LEVEL,
  WRITERGROUP,
  MSG,
  ... 
)
Value:
if(UA_LOGLEVEL <= UA_LOGLEVEL_##LEVEL) { \
UA_String idStr = UA_STRING_NULL; \
if(WRITERGROUP) \
UA_NodeId_print(&(WRITERGROUP)->identifier, &idStr); \
UA_LOG_##LEVEL(LOGGER, UA_LOGCATEGORY_PUBSUB, \
"WriterGroup %.*s\t| " MSG "%.0s", \
(int)idStr.length, (char*)idStr.data, \
__VA_ARGS__); \
UA_String_clear(&idStr); \
}

Definition at line 416 of file ua_pubsub.h.

◆ UA_PUBSUB_MAXCHANNELS

#define UA_PUBSUB_MAXCHANNELS   8

Max number of underlying for sending and receiving.

Definition at line 35 of file ua_pubsub.h.

Typedef Documentation

◆ UA_DataSetField

typedef struct UA_DataSetField UA_DataSetField

DataSetField

◆ UA_DataSetReader

typedef struct UA_DataSetReader UA_DataSetReader

DataSetReader

DataSetReader Type definition

◆ UA_DataSetWriter

typedef struct UA_DataSetWriter UA_DataSetWriter

◆ UA_DataSetWriterSample

typedef struct UA_DataSetWriterSample UA_DataSetWriterSample

DataSetWriter

◆ UA_PublishedDataSet

typedef struct UA_PublishedDataSet UA_PublishedDataSet

PublishedDataSet

◆ UA_PubSubConnection

typedef struct UA_PubSubConnection UA_PubSubConnection

Connection

◆ UA_PubSubManager

typedef struct UA_PubSubManager UA_PubSubManager

◆ UA_ReaderGroup

typedef struct UA_ReaderGroup UA_ReaderGroup

Definition at line 41 of file ua_pubsub.h.

◆ UA_ReserveId

typedef struct UA_ReserveId UA_ReserveId

◆ UA_SecurityGroup

typedef struct UA_SecurityGroup UA_SecurityGroup

Definition at line 44 of file ua_pubsub.h.

◆ UA_StandaloneSubscribedDataSet

typedef struct UA_StandaloneSubscribedDataSet UA_StandaloneSubscribedDataSet

◆ UA_TopicAssign

typedef struct UA_TopicAssign UA_TopicAssign

PubSub Manager.

◆ UA_WriterGroup

typedef struct UA_WriterGroup UA_WriterGroup

Definition at line 38 of file ua_pubsub.h.

Enumeration Type Documentation

◆ UA_ReserveIdType

enum UA_ReserveIdType
Enumerator
UA_WRITER_GROUP 
UA_DATA_SET_WRITER 

Definition at line 752 of file ua_pubsub.h.

Function Documentation

◆ DataSetReader_createTargetVariables()

UA_StatusCode DataSetReader_createTargetVariables ( UA_Server *  server,
UA_DataSetReader *  dsr,
size_t  targetVariablesSize,
const UA_FieldTargetVariable *  targetVariables 
)

◆ decodeNetworkMessage()

UA_StatusCode decodeNetworkMessage ( UA_Server *  server,
UA_ByteString *  buffer,
size_t *  pos,
UA_NetworkMessage *  nm,
UA_PubSubConnection *  connection 
)

Reading Message handling

Takes a value (and not a pointer) to the buffer. The original buffer is const. Internally we may adjust the length during decryption.

◆ getPublishedDataSetConfig()

UA_StatusCode getPublishedDataSetConfig ( UA_Server *  server,
const UA_NodeId  pds,
UA_PublishedDataSetConfig *  config 
)

◆ setReaderGroupEncryptionKeys()

UA_StatusCode setReaderGroupEncryptionKeys ( UA_Server *  server,
const UA_NodeId  readerGroup,
UA_UInt32  securityTokenId,
const UA_ByteString  signingKey,
const UA_ByteString  encryptingKey,
const UA_ByteString  keyNonce 
)

◆ setWriterGroupEncryptionKeys()

UA_StatusCode setWriterGroupEncryptionKeys ( UA_Server *  server,
const UA_NodeId  writerGroup,
UA_UInt32  securityTokenId,
const UA_ByteString  signingKey,
const UA_ByteString  encryptingKey,
const UA_ByteString  keyNonce 
)

◆ UA_DataSetField_create()

UA_DataSetFieldResult UA_DataSetField_create ( UA_Server *  server,
const UA_NodeId  publishedDataSet,
const UA_DataSetFieldConfig *  fieldConfig,
UA_NodeId *  fieldIdentifier 
)

◆ UA_DataSetField_findDSFbyId()

UA_DataSetField * UA_DataSetField_findDSFbyId ( UA_Server *  server,
UA_NodeId  identifier 
)

◆ UA_DataSetField_remove()

UA_DataSetFieldResult UA_DataSetField_remove ( UA_Server *  server,
UA_DataSetField *  currentField 
)

◆ UA_DataSetFieldConfig_copy()

UA_StatusCode UA_DataSetFieldConfig_copy ( const UA_DataSetFieldConfig *  src,
UA_DataSetFieldConfig *  dst 
)

◆ UA_DataSetReader_checkIdentifier()

UA_StatusCode UA_DataSetReader_checkIdentifier ( UA_Server *  server,
UA_NetworkMessage *  msg,
UA_DataSetReader *  reader,
UA_ReaderGroupConfig  readerGroupConfig 
)

◆ UA_DataSetReader_create()

UA_StatusCode UA_DataSetReader_create ( UA_Server *  server,
UA_NodeId  readerGroupIdentifier,
const UA_DataSetReaderConfig *  dataSetReaderConfig,
UA_NodeId *  readerIdentifier 
)

◆ UA_DataSetReader_process()

void UA_DataSetReader_process ( UA_Server *  server,
UA_ReaderGroup *  readerGroup,
UA_DataSetReader *  dataSetReader,
UA_DataSetMessage *  dataSetMsg 
)

Process Network Message using DataSetReader.

◆ UA_DataSetReader_remove()

UA_StatusCode UA_DataSetReader_remove ( UA_Server *  server,
UA_DataSetReader *  dsr 
)

◆ UA_DataSetReader_setPubSubState()

UA_StatusCode UA_DataSetReader_setPubSubState ( UA_Server *  server,
UA_DataSetReader *  dataSetReader,
UA_PubSubState  state,
UA_StatusCode  cause 
)

◆ UA_DataSetWriter_create()

UA_StatusCode UA_DataSetWriter_create ( UA_Server *  server,
const UA_NodeId  writerGroup,
const UA_NodeId  dataSet,
const UA_DataSetWriterConfig *  dataSetWriterConfig,
UA_NodeId *  writerIdentifier 
)

◆ UA_DataSetWriter_findDSWbyId()

UA_DataSetWriter * UA_DataSetWriter_findDSWbyId ( UA_Server *  server,
UA_NodeId  identifier 
)

◆ UA_DataSetWriter_freezeConfiguration()

void UA_DataSetWriter_freezeConfiguration ( UA_Server *  server,
UA_DataSetWriter *  dsw 
)

◆ UA_DataSetWriter_generateDataSetMessage()

UA_StatusCode UA_DataSetWriter_generateDataSetMessage ( UA_Server *  server,
UA_DataSetMessage *  dataSetMessage,
UA_DataSetWriter *  dataSetWriter 
)

◆ UA_DataSetWriter_prepareDataSet()

UA_StatusCode UA_DataSetWriter_prepareDataSet ( UA_Server *  server,
UA_DataSetWriter *  dsw,
UA_DataSetMessage *  dsm 
)

◆ UA_DataSetWriter_remove()

UA_StatusCode UA_DataSetWriter_remove ( UA_Server *  server,
UA_DataSetWriter *  dataSetWriter 
)

◆ UA_DataSetWriter_setPubSubState()

UA_StatusCode UA_DataSetWriter_setPubSubState ( UA_Server *  server,
UA_DataSetWriter *  dataSetWriter,
UA_PubSubState  state,
UA_StatusCode  cause 
)

◆ UA_DataSetWriter_unfreezeConfiguration()

void UA_DataSetWriter_unfreezeConfiguration ( UA_Server *  server,
UA_DataSetWriter *  dsw 
)

◆ UA_DataSetWriterConfig_copy()

UA_StatusCode UA_DataSetWriterConfig_copy ( const UA_DataSetWriterConfig *  src,
UA_DataSetWriterConfig *  dst 
)

◆ UA_FieldTargetVariable_copy()

UA_StatusCode UA_FieldTargetVariable_copy ( const UA_FieldTargetVariable *  src,
UA_FieldTargetVariable *  dst 
)

Copy the configuration of Field Target Variables.

◆ UA_PublishedDataSet_clear()

void UA_PublishedDataSet_clear ( UA_Server *  server,
UA_PublishedDataSet *  publishedDataSet 
)

◆ UA_PublishedDataSet_create()

UA_AddPublishedDataSetResult UA_PublishedDataSet_create ( UA_Server *  server,
const UA_PublishedDataSetConfig *  publishedDataSetConfig,
UA_NodeId *  pdsIdentifier 
)

◆ UA_PublishedDataSet_findPDSbyId()

UA_PublishedDataSet * UA_PublishedDataSet_findPDSbyId ( UA_Server *  server,
UA_NodeId  identifier 
)

◆ UA_PublishedDataSet_findPDSbyName()

UA_PublishedDataSet * UA_PublishedDataSet_findPDSbyName ( UA_Server *  server,
UA_String  name 
)

◆ UA_PublishedDataSet_remove()

UA_StatusCode UA_PublishedDataSet_remove ( UA_Server *  server,
UA_PublishedDataSet *  publishedDataSet 
)

◆ UA_PublishedDataSetConfig_copy()

UA_StatusCode UA_PublishedDataSetConfig_copy ( const UA_PublishedDataSetConfig *  src,
UA_PublishedDataSetConfig *  dst 
)

◆ UA_PubSubConfigurationVersionTimeDifference()

UA_UInt32 UA_PubSubConfigurationVersionTimeDifference ( void  )

◆ UA_PubSubConnection_connect()

UA_StatusCode UA_PubSubConnection_connect ( UA_Server *  server,
UA_PubSubConnection *  c,
UA_Boolean  validate 
)

◆ UA_PubSubConnection_create()

UA_StatusCode UA_PubSubConnection_create ( UA_Server *  server,
const UA_PubSubConnectionConfig *  connectionConfig,
UA_NodeId *  connectionIdentifier 
)

◆ UA_PubSubConnection_delete()

void UA_PubSubConnection_delete ( UA_Server *  server,
UA_PubSubConnection *  c 
)

◆ UA_PubSubConnection_disconnect()

void UA_PubSubConnection_disconnect ( UA_PubSubConnection *  c)

◆ UA_PubSubConnection_findConnectionbyId()

UA_PubSubConnection * UA_PubSubConnection_findConnectionbyId ( UA_Server *  server,
UA_NodeId  connectionIdentifier 
)

◆ UA_PubSubConnection_getEL()

UA_EventLoop * UA_PubSubConnection_getEL ( UA_Server *  server,
UA_PubSubConnection *  c 
)

Returns either the eventloop configured in the connection or, in its absence, for the server.

◆ UA_PubSubConnection_setPubSubState()

UA_StatusCode UA_PubSubConnection_setPubSubState ( UA_Server *  server,
UA_PubSubConnection *  connection,
UA_PubSubState  state,
UA_StatusCode  cause 
)

◆ UA_PubSubConnectionConfig_clear()

void UA_PubSubConnectionConfig_clear ( UA_PubSubConnectionConfig *  connectionConfig)

◆ UA_PubSubConnectionConfig_copy()

UA_StatusCode UA_PubSubConnectionConfig_copy ( const UA_PubSubConnectionConfig *  src,
UA_PubSubConnectionConfig *  dst 
)

◆ UA_PubSubDataSetField_sampleValue()

void UA_PubSubDataSetField_sampleValue ( UA_Server *  server,
UA_DataSetField *  field,
UA_DataValue *  value 
)

◆ UA_PubSubManager_addPubSubTopicAssign()

UA_StatusCode UA_PubSubManager_addPubSubTopicAssign ( UA_Server *  server,
UA_ReaderGroup *  readerGroup,
UA_String  topic 
)

◆ UA_PubSubManager_delete()

void UA_PubSubManager_delete ( UA_Server *  server,
UA_PubSubManager *  pubSubManager 
)

◆ UA_PubSubManager_freeIds()

void UA_PubSubManager_freeIds ( UA_Server *  server)

◆ UA_PubSubManager_generateUniqueGuid()

UA_Guid UA_PubSubManager_generateUniqueGuid ( UA_Server *  server)

◆ UA_PubSubManager_generateUniqueNodeId()

void UA_PubSubManager_generateUniqueNodeId ( UA_PubSubManager *  psm,
UA_NodeId *  nodeId 
)

◆ UA_PubSubManager_init()

void UA_PubSubManager_init ( UA_Server *  server,
UA_PubSubManager *  pubSubManager 
)

◆ UA_PubSubManager_reserveIds()

UA_StatusCode UA_PubSubManager_reserveIds ( UA_Server *  server,
UA_NodeId  sessionId,
UA_UInt16  numRegWriterGroupIds,
UA_UInt16  numRegDataSetWriterIds,
UA_String  transportProfileUri,
UA_UInt16 **  writerGroupIds,
UA_UInt16 **  dataSetWriterIds 
)

◆ UA_PubSubManager_shutdown()

void UA_PubSubManager_shutdown ( UA_Server *  server,
UA_PubSubManager *  pubSubManager 
)

◆ UA_ReaderGroup_connect()

UA_StatusCode UA_ReaderGroup_connect ( UA_Server *  server,
UA_ReaderGroup *  rg,
UA_Boolean  validate 
)

◆ UA_ReaderGroup_create()

UA_StatusCode UA_ReaderGroup_create ( UA_Server *  server,
UA_NodeId  connectionId,
const UA_ReaderGroupConfig *  rgc,
UA_NodeId *  readerGroupId 
)

◆ UA_ReaderGroup_decodeAndProcessRT()

UA_Boolean UA_ReaderGroup_decodeAndProcessRT ( UA_Server *  server,
UA_ReaderGroup *  readerGroup,
UA_ByteString *  buf 
)

◆ UA_ReaderGroup_disconnect()

void UA_ReaderGroup_disconnect ( UA_ReaderGroup *  rg)

◆ UA_ReaderGroup_findDSRbyId()

UA_DataSetReader * UA_ReaderGroup_findDSRbyId ( UA_Server *  server,
UA_NodeId  identifier 
)

◆ UA_ReaderGroup_findRGbyId()

UA_ReaderGroup * UA_ReaderGroup_findRGbyId ( UA_Server *  server,
UA_NodeId  identifier 
)

Prototypes for internal util functions - some functions maybe removed later (currently moved from public to internal)

◆ UA_ReaderGroup_freezeConfiguration()

UA_StatusCode UA_ReaderGroup_freezeConfiguration ( UA_Server *  server,
UA_ReaderGroup *  rg 
)

◆ UA_ReaderGroup_process()

UA_Boolean UA_ReaderGroup_process ( UA_Server *  server,
UA_ReaderGroup *  readerGroup,
UA_NetworkMessage *  nm 
)

◆ UA_ReaderGroup_remove()

UA_StatusCode UA_ReaderGroup_remove ( UA_Server *  server,
UA_ReaderGroup *  rg 
)

◆ UA_ReaderGroup_setPubSubState()

UA_StatusCode UA_ReaderGroup_setPubSubState ( UA_Server *  server,
UA_ReaderGroup *  readerGroup,
UA_PubSubState  state,
UA_StatusCode  cause 
)

◆ UA_ReaderGroup_unfreezeConfiguration()

UA_StatusCode UA_ReaderGroup_unfreezeConfiguration ( UA_Server *  server,
UA_ReaderGroup *  rg 
)

◆ UA_ReaderGroupConfig_copy()

UA_StatusCode UA_ReaderGroupConfig_copy ( const UA_ReaderGroupConfig *  src,
UA_ReaderGroupConfig *  dst 
)

◆ UA_StandaloneSubscribedDataSet_clear()

void UA_StandaloneSubscribedDataSet_clear ( UA_Server *  server,
UA_StandaloneSubscribedDataSet *  subscribedDataSet 
)

◆ UA_StandaloneSubscribedDataSet_findSDSbyId()

UA_StandaloneSubscribedDataSet * UA_StandaloneSubscribedDataSet_findSDSbyId ( UA_Server *  server,
UA_NodeId  identifier 
)

◆ UA_StandaloneSubscribedDataSet_findSDSbyName()

UA_StandaloneSubscribedDataSet * UA_StandaloneSubscribedDataSet_findSDSbyName ( UA_Server *  server,
UA_String  identifier 
)

◆ UA_StandaloneSubscribedDataSetConfig_copy()

UA_StatusCode UA_StandaloneSubscribedDataSetConfig_copy ( const UA_StandaloneSubscribedDataSetConfig *  src,
UA_StandaloneSubscribedDataSetConfig *  dst 
)

◆ UA_TargetVariables_clear()

void UA_TargetVariables_clear ( UA_TargetVariables *  subscribedDataSetTarget)

Clear the Target Variables configuration.

◆ UA_TargetVariables_copy()

UA_StatusCode UA_TargetVariables_copy ( const UA_TargetVariables *  src,
UA_TargetVariables *  dst 
)

Copy the configuration of Target Variables.

◆ UA_WriterGroup_addPublishCallback()

UA_StatusCode UA_WriterGroup_addPublishCallback ( UA_Server *  server,
UA_WriterGroup *  writerGroup 
)

◆ UA_WriterGroup_connect()

UA_StatusCode UA_WriterGroup_connect ( UA_Server *  server,
UA_WriterGroup *  wg,
UA_Boolean  validate 
)

◆ UA_WriterGroup_create()

UA_StatusCode UA_WriterGroup_create ( UA_Server *  server,
const UA_NodeId  connection,
const UA_WriterGroupConfig *  writerGroupConfig,
UA_NodeId *  writerGroupIdentifier 
)

◆ UA_WriterGroup_disconnect()

void UA_WriterGroup_disconnect ( UA_WriterGroup *  wg)

◆ UA_WriterGroup_findWGbyId()

UA_WriterGroup * UA_WriterGroup_findWGbyId ( UA_Server *  server,
UA_NodeId  identifier 
)

◆ UA_WriterGroup_freezeConfiguration()

UA_StatusCode UA_WriterGroup_freezeConfiguration ( UA_Server *  server,
UA_WriterGroup *  wg 
)

◆ UA_WriterGroup_publishCallback()

void UA_WriterGroup_publishCallback ( UA_Server *  server,
UA_WriterGroup *  writerGroup 
)

◆ UA_WriterGroup_remove()

UA_StatusCode UA_WriterGroup_remove ( UA_Server *  server,
UA_WriterGroup *  wg 
)

◆ UA_WriterGroup_setPubSubState()

UA_StatusCode UA_WriterGroup_setPubSubState ( UA_Server *  server,
UA_WriterGroup *  writerGroup,
UA_PubSubState  state,
UA_StatusCode  cause 
)

◆ UA_WriterGroup_unfreezeConfiguration()

UA_StatusCode UA_WriterGroup_unfreezeConfiguration ( UA_Server *  server,
UA_WriterGroup *  wg 
)

◆ UA_WriterGroup_updateConfig()

UA_StatusCode UA_WriterGroup_updateConfig ( UA_Server *  server,
UA_WriterGroup *  wg,
const UA_WriterGroupConfig *  config 
)

◆ UA_WriterGroupConfig_copy()

UA_StatusCode UA_WriterGroupConfig_copy ( const UA_WriterGroupConfig *  src,
UA_WriterGroupConfig *  dst 
)

◆ ZIP_HEAD()

typedef ZIP_HEAD ( UA_ReserveIdTree  ,
UA_ReserveId   
)
Generated by doxygen 1.9.8