OpcUa::Internal::InternalSubscription Class Reference

#include <internal_subscription.h>

List of all members.

Public Member Functions
MonitoredItemCreateResult	CreateMonitoredItem (const MonitoredItemCreateRequest &request)
void	DataChangeCallback (const uint32_t &, const DataValue &value)
std::vector< StatusCode >	DeleteMonitoredItemsIds (const std::vector< uint32_t > &ids)
bool	EnqueueDataChange (uint32_t monitoreditemid, const DataValue &value)
bool	EnqueueEvent (uint32_t monitoreditemid, const Event &event)
bool	HasExpired ()
	InternalSubscription (SubscriptionServiceInternal &service, const SubscriptionData &data, const NodeId &SessionAuthenticationToken, std::function< void(PublishResult)> Callback, bool debug=false)
void	NewAcknowlegment (const SubscriptionAcknowledgement &ack)
RepublishResponse	Republish (const RepublishParameters &params)
void	Start ()
void	Stop ()
void	TriggerEvent (NodeId node, Event event)
	~InternalSubscription ()
Private Member Functions
void	DeleteAllMonitoredItems ()
bool	DeleteMonitoredDataChange (uint32_t handle)
bool	DeleteMonitoredEvent (uint32_t handle)
std::vector< Variant >	GetEventFields (const EventFilter &filter, const Event &event)
NotificationData	GetNotificationData ()
bool	HasPublishResult ()
std::vector< PublishResult >	PopPublishResult ()
void	PublishResults (const boost::system::error_code &error)
void	TriggerDataChangeEvent (MonitoredDataChange monitoreditems, ReadValueId attrval)
Private Attributes
Server::AddressSpace &	AddressSpace
std::function< void(PublishResult)>	Callback
const NodeId	CurrentSession
SubscriptionData	Data
boost::shared_mutex	DbMutex
bool	Debug = false
boost::asio::io_service &	io
uint32_t	KeepAliveCount = 0
uint32_t	LastMonitoredItemId = 100
uint32_t	LifeTimeCount
MonitoredDataChangeMap	MonitoredDataChanges
MonitoredEventsMap	MonitoredEvents
std::list< PublishResult >	NotAcknowledgedResults
uint32_t	NotificationSequence = 1
SubscriptionServiceInternal &	Service
bool	Startup = true
boost::asio::deadline_timer	Timer
bool	TimerStopped = false
std::list< TriggeredDataChange >	TriggeredDataChangeEvents
std::list< TriggeredEvent >	TriggeredEvents

---

Detailed Description

Definition at line 59 of file internal_subscription.h.

---

Constructor & Destructor Documentation

OpcUa::Internal::InternalSubscription::InternalSubscription	(	SubscriptionServiceInternal &	service,
		const SubscriptionData &	data,
		const NodeId &	SessionAuthenticationToken,
		std::function< void(PublishResult)>	Callback,
		bool	debug = false
	)

Definition at line 10 of file internal_subscription.cpp.

OpcUa::Internal::InternalSubscription::~InternalSubscription

(

)

Definition at line 29 of file internal_subscription.cpp.

---

Member Function Documentation

MonitoredItemCreateResult OpcUa::Internal::InternalSubscription::CreateMonitoredItem

(

const MonitoredItemCreateRequest &

request

)

Definition at line 208 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::DataChangeCallback	(	const uint32_t &	m_id,
		const DataValue &	value
	)

Definition at line 358 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::DeleteAllMonitoredItems

(

)

[private]

Definition at line 40 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::DeleteMonitoredDataChange

(

uint32_t

handle

)

[private]

Definition at line 302 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::DeleteMonitoredEvent

(

uint32_t

handle

)

[private]

Definition at line 332 of file internal_subscription.cpp.

std::vector< StatusCode > OpcUa::Internal::InternalSubscription::DeleteMonitoredItemsIds

(

const std::vector< uint32_t > &

ids

)

Definition at line 275 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::EnqueueDataChange	(	uint32_t	monitoreditemid,
		const DataValue &	value
	)

bool OpcUa::Internal::InternalSubscription::EnqueueEvent	(	uint32_t	monitoreditemid,
		const Event &	event
	)

Definition at line 391 of file internal_subscription.cpp.

std::vector< Variant > OpcUa::Internal::InternalSubscription::GetEventFields	(	const EventFilter &	filter,
		const Event &	event
	)		[private]

Definition at line 418 of file internal_subscription.cpp.

NotificationData OpcUa::Internal::InternalSubscription::GetNotificationData

(

)

[private]

Definition at line 188 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::HasExpired

(

)

Definition at line 54 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::HasPublishResult

(

)

[private]

Definition at line 101 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::NewAcknowlegment

(

const SubscriptionAcknowledgement &

ack

)

Definition at line 200 of file internal_subscription.cpp.

std::vector< PublishResult > OpcUa::Internal::InternalSubscription::PopPublishResult

(

)

[private]

Definition at line 119 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::PublishResults

(

const boost::system::error_code &

error

)

[private]

Definition at line 64 of file internal_subscription.cpp.

RepublishResponse OpcUa::Internal::InternalSubscription::Republish

(

const RepublishParameters &

params

)

Definition at line 170 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::Start

(

)

Definition at line 23 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::Stop

(

)

Definition at line 34 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::TriggerDataChangeEvent	(	MonitoredDataChange	monitoreditems,
		ReadValueId	attrval
	)		[private]

Definition at line 261 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::TriggerEvent	(	NodeId	node,
		Event	event
	)

Definition at line 377 of file internal_subscription.cpp.

---

Member Data Documentation

Server::AddressSpace& OpcUa::Internal::InternalSubscription::AddressSpace [private]

Definition at line 90 of file internal_subscription.h.

std::function<void (PublishResult)> OpcUa::Internal::InternalSubscription::Callback [private]

Definition at line 94 of file internal_subscription.h.

const NodeId OpcUa::Internal::InternalSubscription::CurrentSession [private]

Definition at line 93 of file internal_subscription.h.

SubscriptionData OpcUa::Internal::InternalSubscription::Data [private]

Definition at line 92 of file internal_subscription.h.

boost::shared_mutex OpcUa::Internal::InternalSubscription::DbMutex [mutable, private]

Definition at line 91 of file internal_subscription.h.

bool OpcUa::Internal::InternalSubscription::Debug = false [private]

Definition at line 109 of file internal_subscription.h.

boost::asio::io_service& OpcUa::Internal::InternalSubscription::io [private]

Definition at line 105 of file internal_subscription.h.

uint32_t OpcUa::Internal::InternalSubscription::KeepAliveCount = 0 [private]

Definition at line 97 of file internal_subscription.h.

uint32_t OpcUa::Internal::InternalSubscription::LastMonitoredItemId = 100 [private]

Definition at line 99 of file internal_subscription.h.

uint32_t OpcUa::Internal::InternalSubscription::LifeTimeCount [private]

Definition at line 108 of file internal_subscription.h.

MonitoredDataChangeMap OpcUa::Internal::InternalSubscription::MonitoredDataChanges [private]

Definition at line 100 of file internal_subscription.h.

MonitoredEventsMap OpcUa::Internal::InternalSubscription::MonitoredEvents [private]

Definition at line 101 of file internal_subscription.h.

std::list<PublishResult> OpcUa::Internal::InternalSubscription::NotAcknowledgedResults [private]

Definition at line 102 of file internal_subscription.h.

uint32_t OpcUa::Internal::InternalSubscription::NotificationSequence = 1 [private]

Definition at line 96 of file internal_subscription.h.

SubscriptionServiceInternal& OpcUa::Internal::InternalSubscription::Service [private]

Definition at line 89 of file internal_subscription.h.

bool OpcUa::Internal::InternalSubscription::Startup = true [private]

Definition at line 98 of file internal_subscription.h.

boost::asio::deadline_timer OpcUa::Internal::InternalSubscription::Timer [private]

Definition at line 106 of file internal_subscription.h.

bool OpcUa::Internal::InternalSubscription::TimerStopped = false [private]

Definition at line 107 of file internal_subscription.h.

std::list<TriggeredDataChange> OpcUa::Internal::InternalSubscription::TriggeredDataChangeEvents [private]

Definition at line 103 of file internal_subscription.h.

std::list<TriggeredEvent> OpcUa::Internal::InternalSubscription::TriggeredEvents [private]

Definition at line 104 of file internal_subscription.h.

---

The documentation for this class was generated from the following files:

• internal_subscription.h
• internal_subscription.cpp