open62541/src/server/ua_subscription_manager.h

#ifdef ENABLESUBSCRIPTIONS
#ifndef UA_SUBSCRIPTION_MANAGER_H_
#define UA_SUBSCRIPTION_MANAGER_H_

#include "ua_server.h"
#include "ua_types.h"
#include "queue.h"

typedef struct {
    UA_Int32 currentValue;
    UA_Int32 minValue;
    UA_Int32 maxValue;
} UA_Int32_BoundedValue;

typedef struct {
    UA_UInt32 currentValue;
    UA_UInt32 minValue;
    UA_UInt32 maxValue;
} UA_UInt32_BoundedValue;

typedef struct UA_MonitoredItem_s {
    UA_UInt32  ItemId;
    UA_UInt32  TimestampsToReturn;
    UA_UInt32  MonitoringMode;
    UA_NodeId  ItemNodeId;
    UA_UInt32  AttributeID;
    UA_UInt32  ClientHandle;
    UA_UInt32  SamplingInterval;
    UA_UInt32  QueueSize;
    UA_Boolean DiscardOldest;
    // FIXME: indexRange is ignored; array values default to element 0
    // FIXME: dataEncoding is hardcoded to UA binary
    LIST_ENTRY(UA_MonitoredItem_s) listEntry;
} UA_MonitoredItem;

typedef LIST_HEAD(UA_ListOfUAMonitoredItems_s, UA_MonitoredItem_s) UA_ListOfUAMonitoredItems;
typedef struct UA_Subscription_s {
    UA_UInt32_BoundedValue LifeTime;
    UA_UInt32_BoundedValue KeepAliveCount;
    UA_Int32   PublishingInterval;
    UA_Int32   SubscriptionID;
    UA_Int32   NotificationsPerPublish;
    UA_Boolean PublishingMode;
    UA_UInt32  Priority;
    LIST_ENTRY(UA_Subscription_s) listEntry;
    UA_ListOfUAMonitoredItems *MonitoredItems;
} UA_Subscription;

typedef LIST_HEAD(UA_ListOfUASubscriptions_s, UA_Subscription_s) UA_ListOfUASubscriptions;
typedef struct UA_SubscriptionManager_s {
    UA_Int32_BoundedValue  GlobalPublishingInterval;
    UA_UInt32_BoundedValue GlobalLifeTimeCount;
    UA_UInt32_BoundedValue GlobalKeepAliveCount;
    UA_Int32_BoundedValue  GlobalNotificationsPerPublish;
    UA_UInt32_BoundedValue GlobalSamplingInterval;
    UA_UInt32_BoundedValue GlobalQueueSize;
    UA_Int32 LastSessionID;
    UA_ListOfUASubscriptions *ServerSubscriptions;
} UA_SubscriptionManager;

void SubscriptionManager_init(UA_Server *server);
UA_Subscription *UA_Subscription_new(UA_Int32 SubscriptionID);
void SubscriptionManager_addSubscription(UA_SubscriptionManager *manager, UA_Subscription *subscription);
UA_Subscription *SubscriptionManager_getSubscriptionByID(UA_SubscriptionManager *manager, UA_Int32 SubscriptionID);
UA_Int32  SubscriptionManager_deleteSubscription(UA_SubscriptionManager *manager, UA_Int32 SubscriptionID);
UA_MonitoredItem *UA_MonitoredItem_new(void);

#endif  // ifndef... define UA_SUBSCRIPTION_MANAGER_H_
#endif  // ifdef EnableSubscriptions ...