#include <subscription_service_internal.h>

Public Member Functions | |
| virtual std::vector < MonitoredItemCreateResult > | CreateMonitoredItems (const MonitoredItemsParameters ¶ms) |
| virtual SubscriptionData | CreateSubscription (const CreateSubscriptionRequest &request, std::function< void(PublishResult)> callback) |
| void | DeleteAllSubscriptions () |
| virtual std::vector< StatusCode > | DeleteMonitoredItems (const DeleteMonitoredItemsParameters ¶ms) |
| virtual std::vector< StatusCode > | DeleteSubscriptions (const std::vector< uint32_t > &subscriptions) |
| Server::AddressSpace & | GetAddressSpace () |
| boost::asio::io_service & | GetIOService () |
| bool | PopPublishRequest (NodeId node) |
| virtual void | Publish (const PublishRequest &request) |
| virtual RepublishResponse | Republish (const RepublishParameters &request) |
| SubscriptionServiceInternal (Server::AddressSpace::SharedPtr addressspace, boost::asio::io_service &io, bool debug) | |
| void | TriggerEvent (NodeId node, Event event) |
| ~SubscriptionServiceInternal () | |
Private Attributes | |
| Server::AddressSpace::SharedPtr | AddressSpace |
| boost::shared_mutex | DbMutex |
| bool | Debug |
| boost::asio::io_service & | io |
| uint32_t | LastSubscriptionId = 2 |
| std::map< NodeId, uint32_t > | PublishRequestQueues |
| SubscriptionsIdMap | SubscriptionsMap |
Definition at line 44 of file subscription_service_internal.h.
| OpcUa::Internal::SubscriptionServiceInternal::SubscriptionServiceInternal | ( | Server::AddressSpace::SharedPtr | addressspace, |
| boost::asio::io_service & | io, | ||
| bool | debug | ||
| ) |
Definition at line 20 of file subscription_service_internal.cpp.
Definition at line 27 of file subscription_service_internal.cpp.
| std::vector< MonitoredItemCreateResult > OpcUa::Internal::SubscriptionServiceInternal::CreateMonitoredItems | ( | const MonitoredItemsParameters & | params | ) | [virtual] |
Implements OpcUa::SubscriptionServices.
Definition at line 95 of file subscription_service_internal.cpp.
| SubscriptionData OpcUa::Internal::SubscriptionServiceInternal::CreateSubscription | ( | const CreateSubscriptionRequest & | request, |
| std::function< void(PublishResult)> | callback | ||
| ) | [virtual] |
Implements OpcUa::SubscriptionServices.
Definition at line 78 of file subscription_service_internal.cpp.
Definition at line 41 of file subscription_service_internal.cpp.
| std::vector< StatusCode > OpcUa::Internal::SubscriptionServiceInternal::DeleteMonitoredItems | ( | const DeleteMonitoredItemsParameters & | params | ) | [virtual] |
Implements OpcUa::SubscriptionServices.
Definition at line 122 of file subscription_service_internal.cpp.
| std::vector< StatusCode > OpcUa::Internal::SubscriptionServiceInternal::DeleteSubscriptions | ( | const std::vector< uint32_t > & | subscriptions | ) | [virtual] |
Implements OpcUa::SubscriptionServices.
Definition at line 54 of file subscription_service_internal.cpp.
Definition at line 31 of file subscription_service_internal.cpp.
| boost::asio::io_service & OpcUa::Internal::SubscriptionServiceInternal::GetIOService | ( | ) |
Definition at line 36 of file subscription_service_internal.cpp.
Definition at line 177 of file subscription_service_internal.cpp.
| void OpcUa::Internal::SubscriptionServiceInternal::Publish | ( | const PublishRequest & | request | ) | [virtual] |
Implements OpcUa::SubscriptionServices.
Definition at line 142 of file subscription_service_internal.cpp.
| RepublishResponse OpcUa::Internal::SubscriptionServiceInternal::Republish | ( | const RepublishParameters & | request | ) | [virtual] |
Implements OpcUa::SubscriptionServices.
Definition at line 162 of file subscription_service_internal.cpp.
| void OpcUa::Internal::SubscriptionServiceInternal::TriggerEvent | ( | NodeId | node, |
| Event | event | ||
| ) | [virtual] |
Implements OpcUa::Server::SubscriptionService.
Definition at line 204 of file subscription_service_internal.cpp.
Server::AddressSpace::SharedPtr OpcUa::Internal::SubscriptionServiceInternal::AddressSpace [private] |
Definition at line 66 of file subscription_service_internal.h.
boost::shared_mutex OpcUa::Internal::SubscriptionServiceInternal::DbMutex [mutable, private] |
Definition at line 68 of file subscription_service_internal.h.
bool OpcUa::Internal::SubscriptionServiceInternal::Debug [private] |
Definition at line 67 of file subscription_service_internal.h.
boost::asio::io_service& OpcUa::Internal::SubscriptionServiceInternal::io [private] |
Definition at line 65 of file subscription_service_internal.h.
uint32_t OpcUa::Internal::SubscriptionServiceInternal::LastSubscriptionId = 2 [private] |
Definition at line 70 of file subscription_service_internal.h.
std::map<NodeId, uint32_t> OpcUa::Internal::SubscriptionServiceInternal::PublishRequestQueues [private] |
Definition at line 71 of file subscription_service_internal.h.
Definition at line 69 of file subscription_service_internal.h.