#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.