Commit 3fda7a8e authored by Ivan Tyagov's avatar Ivan Tyagov

Move to proper place.

parent ab3176a3
...@@ -235,3 +235,20 @@ static void fillTestDataSetMetaData(UA_DataSetMetaDataType *pMetaData) { ...@@ -235,3 +235,20 @@ static void fillTestDataSetMetaData(UA_DataSetMetaDataType *pMetaData) {
pMetaData->fields[1].name = UA_STRING ("ID (subscribed)"); pMetaData->fields[1].name = UA_STRING ("ID (subscribed)");
pMetaData->fields[1].valueRank = -1; /* scalar */ pMetaData->fields[1].valueRank = -1; /* scalar */
} }
static int enableSubscribeToHeartBeat(UA_Server *erver, UA_ServerConfig *config){
// enable subscribe to keep-alive messages
UA_ServerConfig_addPubSubTransportLayer(config, UA_PubSubTransportLayerUDPMP());
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/")};
addPubSubConnectionXXX(server, &transportProfile, &networkAddressUrl);
/* Add ReaderGroup to the created PubSubConnection */
addReaderGroup(server);
/* Add DataSetReader to the created ReaderGroup */
addDataSetReader(server);
/* Add SubscribedVariables to the created DataSetReader */
addSubscribedVariables(server, readerIdentifier);
}
...@@ -257,34 +257,13 @@ int main(int argc, char **argv) ...@@ -257,34 +257,13 @@ int main(int argc, char **argv)
} }
#endif #endif
// enable publish keep-alive // enable publish keep-alive messages
if (arguments.heart_beat) { if (arguments.heart_beat) {
enablePublishHeartBeat(server, config); enablePublishHeartBeat(server, config);
} }
// enable subscribe to keep-alive messages // enable subscribe to keep-alive messages
UA_ServerConfig_addPubSubTransportLayer(config, UA_PubSubTransportLayerUDPMP()); enableSubscribeToHeartBeat(server, config);
UA_StatusCode return_value = UA_STATUSCODE_GOOD;
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/")};
return_value |= addPubSubConnectionXXX(server, &transportProfile, &networkAddressUrl);
if ( return_value!= UA_STATUSCODE_GOOD)
return EXIT_FAILURE;
/* Add ReaderGroup to the created PubSubConnection */
return_value |= addReaderGroup(server);
if (return_value!= UA_STATUSCODE_GOOD)
return EXIT_FAILURE;
/* Add DataSetReader to the created ReaderGroup */
return_value |= addDataSetReader(server);
if (return_value != UA_STATUSCODE_GOOD)
return EXIT_FAILURE;
/* Add SubscribedVariables to the created DataSetReader */
return_value |= addSubscribedVariables(server, readerIdentifier);
if (return_value != UA_STATUSCODE_GOOD)
return EXIT_FAILURE;
// run server // run server
UA_StatusCode retval = UA_Server_run(server, &running); UA_StatusCode retval = UA_Server_run(server, &running);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment