|
@@ -287,7 +287,9 @@ void UA_ReaderGroup_subscribeCallback(UA_Server *server, UA_ReaderGroup *readerG
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
- connection->channel->receive(connection->channel, &buffer, NULL, 1000);
|
|
|
|
|
|
+ // TFR: changed the timeout from 1000 (1ms) to 1 (1us).
|
|
|
|
+ // TFR: blocking the OPC UA Server to wait for a UDP PubSub message reduces performance and should be avoided
|
|
|
|
+ connection->channel->receive(connection->channel, &buffer, NULL, 1);
|
|
if(buffer.length > 0) {
|
|
if(buffer.length > 0) {
|
|
UA_LOG_INFO(&server->config.logger, UA_LOGCATEGORY_USERLAND, "Message received:");
|
|
UA_LOG_INFO(&server->config.logger, UA_LOGCATEGORY_USERLAND, "Message received:");
|
|
UA_NetworkMessage currentNetworkMessage;
|
|
UA_NetworkMessage currentNetworkMessage;
|