123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127 |
- #ifndef _XOPEN_SOURCE
- # define _XOPEN_SOURCE 600
- #endif
- #ifndef _DEFAULT_SOURCE
- # define _DEFAULT_SOURCE
- #endif
- #ifndef _BSD_SOURCE
- # define _BSD_SOURCE
- #endif
- #include "open62541.h"
- #include <signal.h>
- #ifdef _WIN32
- # include <windows.h>
- # define UA_sleep_ms(X) Sleep(X)
- #else
- # include <unistd.h>
- # define UA_sleep_ms(X) usleep(X * 1000)
- #endif
- UA_Boolean running = true;
- UA_Logger logger = UA_Log_Stdout;
- static void stopHandler(int sign) {
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "Received Ctrl-C");
- running = 0;
- }
- static void
- handler_currentTimeChanged(UA_UInt32 monId, UA_DataValue *value, void *context) {
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "currentTime has changed!");
- if (UA_Variant_hasScalarType(&value->value, &UA_TYPES[UA_TYPES_DATETIME])) {
- UA_DateTime raw_date = *(UA_DateTime *) value->value.data;
- UA_DateTimeStruct dts = UA_DateTime_toStruct(raw_date);
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "date is: %02u-%02u-%04u %02u:%02u:%02u.%03u",
- dts.day, dts.month, dts.year, dts.hour, dts.min, dts.sec, dts.milliSec);
- }
- }
- static void
- stateCallback (UA_Client *client, UA_ClientState clientState){
- switch (clientState){
- case UA_CLIENTSTATE_DISCONNECTED:
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "The client is disconnected");
- break;
- case UA_CLIENTSTATE_CONNECTED:
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "A TCP connection to the server is open");
- break;
- case UA_CLIENTSTATE_SECURECHANNEL:
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "A SecureChannel to the server is open");
- break;
- case UA_CLIENTSTATE_SESSION:{
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "A session with the server is open");
-
-
- UA_UInt32 subId = 0;
- UA_Client_Subscriptions_new(client, UA_SubscriptionSettings_default, &subId);
- if(subId)
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "Create subscription succeeded, id %u", subId);
- else
- return;
-
- UA_UInt32 monId = 0;
- UA_NodeId monitorThis = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_CURRENTTIME);
- UA_Client_Subscriptions_addMonitoredItem(client, subId, monitorThis, UA_ATTRIBUTEID_VALUE,
- &handler_currentTimeChanged, NULL, &monId, 250);
- if (monId)
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "Monitoring UA_NS0ID_SERVER_SERVERSTATUS_CURRENTTIME', id %u", subId);
- }
- break;
- case UA_CLIENTSTATE_SESSION_RENEWED:
- UA_LOG_INFO(logger, UA_LOGCATEGORY_USERLAND, "A session with the server is open (renewed)");
-
- break;
- }
- return;
- }
- int main(void) {
- signal(SIGINT, stopHandler);
- UA_ClientConfig config = UA_ClientConfig_default;
-
- config.stateCallback = stateCallback;
- UA_Client *client = UA_Client_new(config);
-
- while (running) {
-
-
-
- UA_StatusCode retval = UA_Client_connect(client, "opc.tcp://localhost:4840");
- if (retval != UA_STATUSCODE_GOOD) {
- UA_LOG_ERROR(logger, UA_LOGCATEGORY_USERLAND, "Not connected. Retrying to connect in 1 second");
-
-
- UA_sleep_ms(1000);
- continue;
- }
- UA_Client_Subscriptions_manuallySendPublishRequest(client);
- UA_sleep_ms(1000);
- };
-
- UA_Client_delete(client);
- return UA_STATUSCODE_GOOD;
- }
|