#include <internal_subscription.h>

Inheritance diagram for OpcUa::Internal::InternalSubscription:

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, const Common::Logger::SharedPtr &logger)

ModifySubscriptionResult	ModifySubscription (const ModifySubscriptionParameters &data)

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

boost::asio::io_service &	io

uint32_t	KeepAliveCount = 0

uint32_t	LastMonitoredItemId = 100

uint32_t	LifeTimeCount

Common::Logger::SharedPtr	Logger

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 60 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,
		const Common::Logger::SharedPtr &	logger
	)

Definition at line 10 of file internal_subscription.cpp.

OpcUa::Internal::InternalSubscription::~InternalSubscription ( )

Definition at line 31 of file internal_subscription.cpp.

Member Function Documentation

MonitoredItemCreateResult OpcUa::Internal::InternalSubscription::CreateMonitoredItem ( const MonitoredItemCreateRequest & request )

Definition at line 273 of file internal_subscription.cpp.

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

Definition at line 462 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::DeleteAllMonitoredItems ( )

private

Definition at line 44 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::DeleteMonitoredDataChange ( uint32_t handle )

private

Definition at line 386 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::DeleteMonitoredEvent ( uint32_t handle )

private

Definition at line 429 of file internal_subscription.cpp.

std::vector< StatusCode > OpcUa::Internal::InternalSubscription::DeleteMonitoredItemsIds ( const std::vector< uint32_t > & ids )

Definition at line 359 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 510 of file internal_subscription.cpp.

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

private

Definition at line 538 of file internal_subscription.cpp.

NotificationData OpcUa::Internal::InternalSubscription::GetNotificationData ( )

private

Definition at line 251 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::HasExpired ( )

Definition at line 60 of file internal_subscription.cpp.

bool OpcUa::Internal::InternalSubscription::HasPublishResult ( )

private

Definition at line 114 of file internal_subscription.cpp.

ModifySubscriptionResult OpcUa::Internal::InternalSubscription::ModifySubscription ( const ModifySubscriptionParameters & data )

Definition at line 221 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::NewAcknowlegment ( const SubscriptionAcknowledgement & ack )

Definition at line 265 of file internal_subscription.cpp.

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

private

Definition at line 136 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::PublishResults ( const boost::system::error_code & error )

private

Definition at line 72 of file internal_subscription.cpp.

RepublishResponse OpcUa::Internal::InternalSubscription::Republish ( const RepublishParameters & params )

Definition at line 200 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::Start ( )

Definition at line 24 of file internal_subscription.cpp.

void OpcUa::Internal::InternalSubscription::Stop ( )

Definition at line 37 of file internal_subscription.cpp.

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

private

Definition at line 340 of file internal_subscription.cpp.

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

Definition at line 493 of file internal_subscription.cpp.

Member Data Documentation

Server::AddressSpace& OpcUa::Internal::InternalSubscription::AddressSpace

private

Definition at line 92 of file internal_subscription.h.

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

private

Definition at line 96 of file internal_subscription.h.

const NodeId OpcUa::Internal::InternalSubscription::CurrentSession

private

Definition at line 95 of file internal_subscription.h.

SubscriptionData OpcUa::Internal::InternalSubscription::Data

private

Definition at line 94 of file internal_subscription.h.

boost::shared_mutex OpcUa::Internal::InternalSubscription::DbMutex

mutableprivate

Definition at line 93 of file internal_subscription.h.

boost::asio::io_service& OpcUa::Internal::InternalSubscription::io

private

Definition at line 107 of file internal_subscription.h.

uint32_t OpcUa::Internal::InternalSubscription::KeepAliveCount = 0

private

Definition at line 99 of file internal_subscription.h.

uint32_t OpcUa::Internal::InternalSubscription::LastMonitoredItemId = 100

private

Definition at line 101 of file internal_subscription.h.

uint32_t OpcUa::Internal::InternalSubscription::LifeTimeCount

private

Definition at line 110 of file internal_subscription.h.

Common::Logger::SharedPtr OpcUa::Internal::InternalSubscription::Logger

private

Definition at line 111 of file internal_subscription.h.

MonitoredDataChangeMap OpcUa::Internal::InternalSubscription::MonitoredDataChanges

private

Definition at line 102 of file internal_subscription.h.

MonitoredEventsMap OpcUa::Internal::InternalSubscription::MonitoredEvents

private

Definition at line 103 of file internal_subscription.h.

std::list<PublishResult> OpcUa::Internal::InternalSubscription::NotAcknowledgedResults

private

Definition at line 104 of file internal_subscription.h.

uint32_t OpcUa::Internal::InternalSubscription::NotificationSequence = 1

private

Definition at line 98 of file internal_subscription.h.

SubscriptionServiceInternal& OpcUa::Internal::InternalSubscription::Service

private

Definition at line 91 of file internal_subscription.h.

bool OpcUa::Internal::InternalSubscription::Startup = true

private

Definition at line 100 of file internal_subscription.h.

boost::asio::deadline_timer OpcUa::Internal::InternalSubscription::Timer

private

Definition at line 108 of file internal_subscription.h.

bool OpcUa::Internal::InternalSubscription::TimerStopped = false

private

Definition at line 109 of file internal_subscription.h.

std::list<TriggeredDataChange> OpcUa::Internal::InternalSubscription::TriggeredDataChangeEvents

private

Definition at line 105 of file internal_subscription.h.

std::list<TriggeredEvent> OpcUa::Internal::InternalSubscription::TriggeredEvents

private

Definition at line 106 of file internal_subscription.h.

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

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation