26#ifdef UA_ENABLE_PUBSUB
109#ifdef UA_ENABLE_PUBSUB_DELTAFRAMES
110typedef struct UA_DataSetWriterSample {
113} UA_DataSetWriterSample;
125#ifdef UA_ENABLE_PUBSUB_DELTAFRAMES
127 size_t lastSamplesCount;
128 UA_DataSetWriterSample *lastSamples;
173#ifdef UA_ENABLE_PUBSUB_ENCRYPTION
176 void *securityPolicyContext;
229#ifdef UA_ENABLE_PUBSUB_MONITORING
266#ifdef UA_ENABLE_PUBSUB_MONITORING
269UA_DataSetReader_checkMessageReceiveTimeout(
UA_Server *server,
275UA_DataSetReader_handleMessageReceiveTimeout(
UA_Server *server,
276 void *dataSetReader);
307#ifdef UA_ENABLE_PUBSUB_ENCRYPTION
310 void *securityPolicyContext;
357#ifdef UA_ENABLE_PUBSUB_ENCRYPTION
362 void *channelContext, UA_PubSubSecurityPolicy *securityPolicy);
#define _UA_BEGIN_DECLS
#undef UA_DEBUG_DUMP_PKGS
static UA_LogCategory const char * msg
UA_PubSubComponentEnumType
This Source Code Form is subject to the terms of the Mozilla Public License, v.
UA_Boolean configurationFrozen
UA_NodeId publishedDataSet
UA_Boolean sampleCallbackIsRegistered
TAILQ_ENTRY(UA_DataSetField) listEntry
UA_DataSetFieldConfig config
UA_UInt64 sampleCallbackId
UA_FieldMetaData fieldMetaData
Parameters for PubSub DataSetReader Configuration.
UA_NodeId linkedReaderGroup
LIST_ENTRY(UA_DataSetReader) listEntry
UA_DataSetReaderConfig config
UA_Boolean configurationFrozen
UA_NetworkMessageOffsetBuffer bufferedMessage
UA_PubSubComponentEnumType componentType
UA_Boolean configurationFrozen
UA_NodeId connectedDataSet
UA_ConfigurationVersionDataType connectedDataSetVersion
LIST_ENTRY(UA_DataSetWriter) listEntry
UA_UInt16 actualDataSetMessageSequenceCount
UA_NodeId linkedWriterGroup
UA_DataSetWriterConfig config
UA_PubSubComponentEnumType componentType
Interface structure between network plugin and internal implementation.
UA_PubSubConnectionConfig * config
UA_UInt16 configurationFreezeCounter
LIST_HEAD(UA_ListOfPubSubReaderGroup, UA_ReaderGroup) readerGroups
LIST_HEAD(UA_ListOfWriterGroup, UA_WriterGroup) writerGroups
UA_PubSubChannel * channel
TAILQ_ENTRY(UA_PubSubConnection) listEntry
UA_Boolean configurationFrozen
UA_PubSubComponentEnumType componentType
Configuration structure for PublishedDataSet.
UA_Boolean configurationFrozen
UA_UInt16 configurationFreezeCounter
UA_DataSetMetaDataType dataSetMetaData
TAILQ_ENTRY(UA_PublishedDataSet) listEntry
UA_PublishedDataSetConfig config
UA_UInt16 promotedFieldsCount
TAILQ_HEAD(UA_ListOfDataSetField, UA_DataSetField) fields
ReaderGroup configuration.
UA_Boolean configurationFrozen
UA_PubSubComponentEnumType componentType
UA_ReaderGroupConfig config
UA_UInt64 subscribeCallbackId
LIST_HEAD(UA_ListOfPubSubDataSetReader, UA_DataSetReader) readers
LIST_ENTRY(UA_ReaderGroup) listEntry
UA_NodeId linkedConnection
LIST_HEAD(UA_ListOfDataSetWriter, UA_DataSetWriter) writers
UA_WriterGroupConfig config
UA_Boolean publishCallbackIsRegistered
UA_NetworkMessageOffsetBuffer bufferedMessage
UA_Boolean configurationFrozen
UA_UInt64 publishCallbackId
UA_PubSubConnection * linkedConnection
LIST_ENTRY(UA_WriterGroup) listEntry
UA_PubSubComponentEnumType componentType
_UA_BEGIN_DECLS typedef bool UA_Boolean
This Source Code Form is subject to the terms of the Mozilla Public License, v.
UA_StatusCode UA_FieldTargetVariable_copy(const UA_FieldTargetVariable *src, UA_FieldTargetVariable *dst)
Copy the configuration of Field Target Variables.
void UA_PubSubConnectionConfig_clear(UA_PubSubConnectionConfig *connectionConfig)
UA_StatusCode UA_WriterGroup_setPubSubState(UA_Server *server, UA_PubSubState state, UA_WriterGroup *writerGroup)
UA_StatusCode UA_PublishedDataSetConfig_copy(const UA_PublishedDataSetConfig *src, UA_PublishedDataSetConfig *dst)
UA_StatusCode UA_DataSetReaderConfig_copy(const UA_DataSetReaderConfig *src, UA_DataSetReaderConfig *dst)
Copy the configuration of DataSetReader.
UA_PubSubConnection * UA_PubSubConnection_findConnectionbyId(UA_Server *server, UA_NodeId connectionIdentifier)
UA_StatusCode UA_DataSetWriter_remove(UA_Server *server, UA_WriterGroup *linkedWriterGroup, UA_DataSetWriter *dataSetWriter)
UA_StatusCode UA_WriterGroupConfig_copy(const UA_WriterGroupConfig *src, UA_WriterGroupConfig *dst)
void UA_PublishedDataSet_clear(UA_Server *server, UA_PublishedDataSet *publishedDataSet)
UA_PublishedDataSet * UA_PublishedDataSet_findPDSbyId(UA_Server *server, UA_NodeId identifier)
void UA_ReaderGroup_removeSubscribeCallback(UA_Server *server, UA_ReaderGroup *readerGroup)
UA_ReaderGroup * UA_ReaderGroup_findRGbyId(UA_Server *server, UA_NodeId identifier)
Prototypes for internal util functions - some functions maybe removed later (currently moved from pub...
void UA_ReaderGroup_subscribeCallback(UA_Server *server, UA_ReaderGroup *readerGroup)
void UA_DataSetReaderConfig_clear(UA_DataSetReaderConfig *cfg)
Clear the configuration of a DataSetReader.
UA_StatusCode UA_PubSubConnection_regist(UA_Server *server, UA_NodeId *connectionIdentifier)
Register channel for given connectionIdentifier.
struct UA_DataSetField UA_DataSetField
DataSetField
UA_StatusCode UA_DataSetReader_generateDataSetMessage(UA_Server *server, UA_DataSetMessage *dataSetMessage, UA_DataSetReader *dataSetReader)
UA_StatusCode UA_DataSetFieldConfig_copy(const UA_DataSetFieldConfig *src, UA_DataSetFieldConfig *dst)
struct UA_PublishedDataSet UA_PublishedDataSet
PublishedDataSet
UA_StatusCode decodeNetworkMessage(UA_Server *server, UA_ByteString *buffer, size_t *pos, UA_NetworkMessage *nm, UA_PubSubConnection *connection)
Reading Message handling
UA_StatusCode UA_DataSetReader_generateNetworkMessage(UA_PubSubConnection *pubSubConnection, UA_DataSetReader *dataSetReader, UA_DataSetMessage *dsm, UA_UInt16 *writerId, UA_Byte dsmCount, UA_NetworkMessage *nm)
UA_StatusCode UA_WriterGroup_addPublishCallback(UA_Server *server, UA_WriterGroup *writerGroup)
PublishValues handling
struct UA_DataSetReader UA_DataSetReader
DataSetReader
void UA_TargetVariables_clear(UA_TargetVariables *subscribedDataSetTarget)
Clear the Target Variables configuration.
UA_StatusCode UA_DataSetWriter_generateDataSetMessage(UA_Server *server, UA_DataSetMessage *dataSetMessage, UA_DataSetWriter *dataSetWriter)
UA_StatusCode UA_Server_processNetworkMessage(UA_Server *server, UA_PubSubConnection *connection, UA_NetworkMessage *msg)
Process Network Message for a ReaderGroup.
UA_StatusCode UA_TargetVariables_copy(const UA_TargetVariables *src, UA_TargetVariables *dst)
Copy the configuration of Target Variables.
UA_DataSetField * UA_DataSetField_findDSFbyId(UA_Server *server, UA_NodeId identifier)
void UA_DataSetReader_process(UA_Server *server, UA_ReaderGroup *readerGroup, UA_DataSetReader *dataSetReader, UA_DataSetMessage *dataSetMsg)
Process Network Message using DataSetReader.
UA_StatusCode UA_ReaderGroupConfig_copy(const UA_ReaderGroupConfig *src, UA_ReaderGroupConfig *dst)
UA_StatusCode UA_DataSetWriter_setPubSubState(UA_Server *server, UA_PubSubState state, UA_DataSetWriter *dataSetWriter)
struct UA_PubSubConnection UA_PubSubConnection
Connection
UA_DataSetWriter * UA_DataSetWriter_findDSWbyId(UA_Server *server, UA_NodeId identifier)
void UA_WriterGroup_publishCallback(UA_Server *server, UA_WriterGroup *writerGroup)
struct UA_DataSetWriter UA_DataSetWriter
DataSetWriter
UA_WriterGroup * UA_WriterGroup_findWGbyId(UA_Server *server, UA_NodeId identifier)
UA_StatusCode UA_ReaderGroup_addSubscribeCallback(UA_Server *server, UA_ReaderGroup *readerGroup)
SubscribeValues handling
void UA_PubSubConnection_clear(UA_Server *server, UA_PubSubConnection *connection)
UA_StatusCode UA_DataSetWriterConfig_copy(const UA_DataSetWriterConfig *src, UA_DataSetWriterConfig *dst)
UA_DataSetReader * UA_ReaderGroup_findDSRbyId(UA_Server *server, UA_NodeId identifier)
UA_StatusCode UA_DataSetReader_setPubSubState(UA_Server *server, UA_PubSubState state, UA_DataSetReader *dataSetReader)
UA_StatusCode UA_PubSubConnectionConfig_copy(const UA_PubSubConnectionConfig *src, UA_PubSubConnectionConfig *dst)
UA_StatusCode UA_ReaderGroup_setPubSubState(UA_Server *server, UA_PubSubState state, UA_ReaderGroup *readerGroup)
UA_StatusCode receiveBufferedNetworkMessage(UA_Server *server, UA_ReaderGroup *readerGroup, UA_PubSubConnection *connection)
void(* UA_ServerCallback)(UA_Server *server, void *data)