mirror of
https://github.com/open62541/open62541.git
synced 2026-10-18 21:52:55 +08:00
Selva Suba Jenifer Joseph
43574aa883
- Check identifiers to direct DataSetMessage to desired DataSetReader
- PublisherId
- WriterGroupId
- DataSetWriterId
Change-Id: Ibfa48d45833a6629134f89648b675441a32f39b9
287 lines
11 KiB
C
287 lines
11 KiB
C
/* This work is licensed under a Creative Commons CCZero 1.0 Universal License.
|
|
* See http://creativecommons.org/publicdomain/zero/1.0/ for more information.
|
|
*
|
|
* Copyright (c) 2019 Kalycito Infotech Private Limited
|
|
*/
|
|
|
|
/**
|
|
* IMPORTANT ANNOUNCEMENT
|
|
* The PubSub Subscriber API is currently not finished. This example can be used
|
|
* to receive and display values that are published by tutorial_pubsub_publish
|
|
* example in the TargetVariables of Subscriber Information Model .
|
|
*/
|
|
#include <open62541/plugin/log_stdout.h>
|
|
#include <open62541/plugin/pubsub_udp.h>
|
|
#include <open62541/server.h>
|
|
#include <open62541/server_config_default.h>
|
|
#include <open62541/types_generated.h>
|
|
|
|
#include "ua_pubsub.h"
|
|
|
|
#ifdef UA_ENABLE_PUBSUB_ETH_UADP
|
|
#include <open62541/plugin/pubsub_ethernet.h>
|
|
#endif
|
|
|
|
#include <stdio.h>
|
|
#include <signal.h>
|
|
#include <stdlib.h>
|
|
|
|
UA_NodeId connectionIdentifier;
|
|
UA_NodeId readerGroupIdentifier;
|
|
UA_NodeId readerIdentifier;
|
|
|
|
UA_DataSetReaderConfig readerConfig;
|
|
|
|
static void fillTestDataSetMetaData(UA_DataSetMetaDataType *pMetaData);
|
|
|
|
/* Add new connection to the server */
|
|
static UA_StatusCode
|
|
addPubSubConnection(UA_Server *server, UA_String *transportProfile,
|
|
UA_NetworkAddressUrlDataType *networkAddressUrl) {
|
|
if((server == NULL) || (transportProfile == NULL) ||
|
|
(networkAddressUrl == NULL)) {
|
|
return UA_STATUSCODE_BADINTERNALERROR;
|
|
}
|
|
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
/* Configuration creation for the connection */
|
|
UA_PubSubConnectionConfig connectionConfig;
|
|
memset (&connectionConfig, 0, sizeof(UA_PubSubConnectionConfig));
|
|
connectionConfig.name = UA_STRING("UDPMC Connection 1");
|
|
connectionConfig.transportProfileUri = *transportProfile;
|
|
connectionConfig.enabled = UA_TRUE;
|
|
UA_Variant_setScalar(&connectionConfig.address, networkAddressUrl,
|
|
&UA_TYPES[UA_TYPES_NETWORKADDRESSURLDATATYPE]);
|
|
connectionConfig.publisherId.numeric = UA_UInt32_random ();
|
|
retval |= UA_Server_addPubSubConnection (server, &connectionConfig, &connectionIdentifier);
|
|
if (retval != UA_STATUSCODE_GOOD) {
|
|
return retval;
|
|
}
|
|
retval |= UA_PubSubConnection_regist(server, &connectionIdentifier);
|
|
return retval;
|
|
}
|
|
|
|
/* Add ReaderGroup to the created connection */
|
|
static UA_StatusCode
|
|
addReaderGroup(UA_Server *server) {
|
|
if(server == NULL) {
|
|
return UA_STATUSCODE_BADINTERNALERROR;
|
|
}
|
|
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
UA_ReaderGroupConfig readerGroupConfig;
|
|
memset (&readerGroupConfig, 0, sizeof(UA_ReaderGroupConfig));
|
|
readerGroupConfig.name = UA_STRING("ReaderGroup1");
|
|
retval |= UA_Server_addReaderGroup(server, connectionIdentifier, &readerGroupConfig,
|
|
&readerGroupIdentifier);
|
|
return retval;
|
|
}
|
|
|
|
/* Add DataSetReader to the ReaderGroup */
|
|
static UA_StatusCode
|
|
addDataSetReader(UA_Server *server) {
|
|
if(server == NULL) {
|
|
return UA_STATUSCODE_BADINTERNALERROR;
|
|
}
|
|
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
memset (&readerConfig, 0, sizeof(UA_DataSetReaderConfig));
|
|
readerConfig.name = UA_STRING("DataSet Reader 1");
|
|
/* Parameters to filter which DataSetMessage has to be processed
|
|
* by the DataSetReader */
|
|
/* The following parameters are used to show that the data published by
|
|
* tutorial_pubsub_publish.c is being subscribed and is being updated in
|
|
* the information model */
|
|
UA_UInt16 publisherIdentifier = 2234;
|
|
readerConfig.publisherId.type = &UA_TYPES[UA_TYPES_UINT16];
|
|
readerConfig.publisherId.data = &publisherIdentifier;
|
|
readerConfig.writerGroupId = 100;
|
|
readerConfig.dataSetWriterId = 62541;
|
|
|
|
/* Setting up Meta data configuration in DataSetReader */
|
|
fillTestDataSetMetaData(&readerConfig.dataSetMetaData);
|
|
retval |= UA_Server_addDataSetReader(server, readerGroupIdentifier, &readerConfig,
|
|
&readerIdentifier);
|
|
return retval;
|
|
}
|
|
|
|
/* Set SubscribedDataSet type to TargetVariables data type
|
|
* Add subscribedvariables to the DataSetReader */
|
|
static UA_StatusCode
|
|
addSubscribedVariables (UA_Server *server, UA_NodeId dataSetReaderId) {
|
|
if(server == NULL) {
|
|
return UA_STATUSCODE_BADINTERNALERROR;
|
|
}
|
|
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
UA_NodeId folderId;
|
|
UA_String folderName = readerConfig.dataSetMetaData.name;
|
|
UA_ObjectAttributes oAttr = UA_ObjectAttributes_default;
|
|
UA_QualifiedName folderBrowseName;
|
|
if(folderName.length > 0) {
|
|
oAttr.displayName.locale = UA_STRING ("en-US");
|
|
oAttr.displayName.text = folderName;
|
|
folderBrowseName.namespaceIndex = 1;
|
|
folderBrowseName.name = folderName;
|
|
}
|
|
else {
|
|
oAttr.displayName = UA_LOCALIZEDTEXT ("en-US", "Subscribed Variables");
|
|
folderBrowseName = UA_QUALIFIEDNAME (1, "Subscribed Variables");
|
|
}
|
|
|
|
UA_Server_addObjectNode (server, UA_NODEID_NULL,
|
|
UA_NODEID_NUMERIC (0, UA_NS0ID_OBJECTSFOLDER),
|
|
UA_NODEID_NUMERIC (0, UA_NS0ID_ORGANIZES),
|
|
folderBrowseName, UA_NODEID_NUMERIC (0,
|
|
UA_NS0ID_BASEOBJECTTYPE), oAttr, NULL, &folderId);
|
|
|
|
retval |= UA_Server_DataSetReader_addTargetVariables (server, &folderId,
|
|
dataSetReaderId,
|
|
UA_PUBSUB_SDS_TARGET);
|
|
UA_free(readerConfig.dataSetMetaData.fields);
|
|
return retval;
|
|
}
|
|
|
|
/* Define MetaData for TargetVariables */
|
|
static void fillTestDataSetMetaData(UA_DataSetMetaDataType *pMetaData) {
|
|
if(pMetaData == NULL) {
|
|
return;
|
|
}
|
|
|
|
UA_DataSetMetaDataType_init (pMetaData);
|
|
pMetaData->name = UA_STRING ("DataSet 1");
|
|
|
|
/* Static definition of number of fields size to 4 to create four different
|
|
* targetVariables of distinct datatype
|
|
* Currently the publisher sends only DateTime data type */
|
|
pMetaData->fieldsSize = 4;
|
|
pMetaData->fields = (UA_FieldMetaData*)UA_Array_new (pMetaData->fieldsSize,
|
|
&UA_TYPES[UA_TYPES_FIELDMETADATA]);
|
|
|
|
/* DateTime DataType */
|
|
UA_FieldMetaData_init (&pMetaData->fields[0]);
|
|
UA_NodeId_copy (&UA_TYPES[UA_TYPES_DATETIME].typeId,
|
|
&pMetaData->fields[0].dataType);
|
|
pMetaData->fields[0].builtInType = UA_NS0ID_DATETIME;
|
|
pMetaData->fields[0].name = UA_STRING ("DateTime");
|
|
pMetaData->fields[0].valueRank = -1; /* scalar */
|
|
|
|
/* Int32 DataType */
|
|
UA_FieldMetaData_init (&pMetaData->fields[1]);
|
|
UA_NodeId_copy(&UA_TYPES[UA_TYPES_INT32].typeId,
|
|
&pMetaData->fields[1].dataType);
|
|
pMetaData->fields[1].builtInType = UA_NS0ID_INT32;
|
|
pMetaData->fields[1].name = UA_STRING ("Int32");
|
|
pMetaData->fields[1].valueRank = -1; /* scalar */
|
|
|
|
/* Int64 DataType */
|
|
UA_FieldMetaData_init (&pMetaData->fields[2]);
|
|
UA_NodeId_copy(&UA_TYPES[UA_TYPES_INT64].typeId,
|
|
&pMetaData->fields[2].dataType);
|
|
pMetaData->fields[2].builtInType = UA_NS0ID_INT64;
|
|
pMetaData->fields[2].name = UA_STRING ("Int64");
|
|
pMetaData->fields[2].valueRank = -1; /* scalar */
|
|
|
|
/* Boolean DataType */
|
|
UA_FieldMetaData_init (&pMetaData->fields[3]);
|
|
UA_NodeId_copy (&UA_TYPES[UA_TYPES_BOOLEAN].typeId,
|
|
&pMetaData->fields[3].dataType);
|
|
pMetaData->fields[3].builtInType = UA_NS0ID_BOOLEAN;
|
|
pMetaData->fields[3].name = UA_STRING ("BoolToggle");
|
|
pMetaData->fields[3].valueRank = -1; /* scalar */
|
|
}
|
|
|
|
UA_Boolean running = true;
|
|
static void stopHandler(int sign) {
|
|
UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_SERVER, "received ctrl-c");
|
|
running = false;
|
|
}
|
|
|
|
static int
|
|
run(UA_String *transportProfile, UA_NetworkAddressUrlDataType *networkAddressUrl) {
|
|
signal(SIGINT, stopHandler);
|
|
signal(SIGTERM, stopHandler);
|
|
/* Return value initialized to Status Good */
|
|
UA_StatusCode retval = UA_STATUSCODE_GOOD;
|
|
UA_Server *server = UA_Server_new();
|
|
UA_ServerConfig *config = UA_Server_getConfig(server);
|
|
UA_ServerConfig_setMinimal(config, 4801, NULL);
|
|
|
|
/* Add the PubSub network layer implementation to the server config.
|
|
* The TransportLayer is acting as factory to create new connections
|
|
* on runtime. Details about the PubSubTransportLayer can be found inside the
|
|
* tutorial_pubsub_connection */
|
|
config->pubsubTransportLayers = (UA_PubSubTransportLayer *)
|
|
UA_calloc(2, sizeof(UA_PubSubTransportLayer));
|
|
if(!config->pubsubTransportLayers) {
|
|
UA_Server_delete(server);
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
config->pubsubTransportLayers[0] = UA_PubSubTransportLayerUDPMP();
|
|
config->pubsubTransportLayersSize++;
|
|
#ifdef UA_ENABLE_PUBSUB_ETH_UADP
|
|
config->pubsubTransportLayers[1] = UA_PubSubTransportLayerEthernet();
|
|
config->pubsubTransportLayersSize++;
|
|
#endif
|
|
|
|
/* API calls */
|
|
/* Add PubSubConnection */
|
|
retval |= addPubSubConnection(server, transportProfile, networkAddressUrl);
|
|
if (retval != UA_STATUSCODE_GOOD)
|
|
return EXIT_FAILURE;
|
|
|
|
/* Add ReaderGroup to the created PubSubConnection */
|
|
retval |= addReaderGroup(server);
|
|
if (retval != UA_STATUSCODE_GOOD)
|
|
return EXIT_FAILURE;
|
|
|
|
/* Add DataSetReader to the created ReaderGroup */
|
|
retval |= addDataSetReader(server);
|
|
if (retval != UA_STATUSCODE_GOOD)
|
|
return EXIT_FAILURE;
|
|
|
|
/* Add SubscribedVariables to the created DataSetReader */
|
|
retval |= addSubscribedVariables(server, readerIdentifier);
|
|
if (retval != UA_STATUSCODE_GOOD)
|
|
return EXIT_FAILURE;
|
|
|
|
retval = UA_Server_run(server, &running);
|
|
UA_Server_delete(server);
|
|
return retval == UA_STATUSCODE_GOOD ? EXIT_SUCCESS : EXIT_FAILURE;
|
|
}
|
|
|
|
static void
|
|
usage(char *progname) {
|
|
printf("usage: %s <uri> [device]\n", progname);
|
|
}
|
|
|
|
int main(int argc, char **argv) {
|
|
UA_String transportProfile = UA_STRING("http://opcfoundation.org/UA-Profile/Transport/pubsub-udp-uadp");
|
|
UA_NetworkAddressUrlDataType networkAddressUrl = {UA_STRING_NULL , UA_STRING("opc.udp://224.0.0.22:4840/")};
|
|
if(argc > 1) {
|
|
if(strcmp(argv[1], "-h") == 0) {
|
|
usage(argv[0]);
|
|
return EXIT_SUCCESS;
|
|
} else if(strncmp(argv[1], "opc.udp://", 10) == 0) {
|
|
networkAddressUrl.url = UA_STRING(argv[1]);
|
|
} else if(strncmp(argv[1], "opc.eth://", 10) == 0) {
|
|
transportProfile =
|
|
UA_STRING("http://opcfoundation.org/UA-Profile/Transport/pubsub-eth-uadp");
|
|
if(argc < 3) {
|
|
printf("Error: UADP/ETH needs an interface name\n");
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
networkAddressUrl.networkInterface = UA_STRING(argv[2]);
|
|
networkAddressUrl.url = UA_STRING(argv[1]);
|
|
} else {
|
|
printf ("Error: unknown URI\n");
|
|
return EXIT_FAILURE;
|
|
}
|
|
}
|
|
|
|
return run(&transportProfile, &networkAddressUrl);
|
|
}
|
|
|