#include <open62541.hpp>

Inheritance diagram for protocol::opcua::Open62541:

Public Member Functions
	Open62541 ()

virtual	~Open62541 ()

virtual void	Connect (const std::string &device, const std::string &address)
	Establish the connection to the OPCUA server.

virtual void	Read (protocol::base::VectorVariant &params) override
	Performs a Read operation.

virtual void	Write (const protocol::base::VectorVariant &params) override
	Performs a Write operation.

virtual void	Rpc (const std::string &obj, const std::string &proc, const protocol::base::VectorVariant &params, protocol::base::Variant &result) override
	Executes a RPC.

UA_StatusCode	ResumeSubscriptions ()
	Resume subscriptions for all connections.

virtual void	StartMonitorItem (const std::string &item) override
	Start monitoring an attribute.

virtual void	StartMonitorItems (const std::vector< std::string > &item_vector) override
	Start monitoring a vector of attributes.

virtual void	StopMonitorItem (const std::string &item) override
	Stop monitoring an attribute.

virtual void	Disconnect ()
	Disconnects from the server.

virtual void	RegisterCB (protocol::base::Dispatcher< protocol::base::VectorVariant & > &dispatcher, protocol::base::Dispatcher<> &failure, protocol::base::Dispatcher<> &normal)
	Registers internal and external callbacks.

void	SetEndpoint (const std::string &endpoint)
	Set endpoint to the connection.

std::string	GetEndpoint () const
	Get endpoint of the connection.

virtual void	HandleDataChange (const std::shared_ptr< MonitoredItem > monitor_item, UA_DataValue *value)
	Handle data changes.

virtual void	HandleSessionChanges (bool status)
	Handle changes in the OPCUA session.

void	UpdateState (UA_SecureChannelState channel_state, UA_SessionState session_state, UA_StatusCode recovery_status)
	Update connection state.

Public Member Functions inherited from protocol::base::IComm
virtual void	Connect (const std::string &device, const std::string &address)=0

virtual void	Read (VectorVariant &params)=0

virtual void	Write (const VectorVariant &params)=0

virtual void	Rpc (const std::string &obj, const std::string &proc, const VectorVariant &params, Variant &result)=0

virtual void	Disconnect ()=0

virtual void	StartMonitorItem (const std::string &item)=0

virtual void	StartMonitorItems (const std::vector< std::string > &item_vector)=0

virtual void	StopMonitorItem (const std::string &item)=0

virtual void	RegisterCB (protocol::base::Dispatcher< protocol::base::VectorVariant & > &dispatcher, protocol::base::Dispatcher<> &failure, protocol::base::Dispatcher<> &normal)=0

virtual	~IComm ()

Public Member Functions inherited from protocol::opcua::IDataChangeHandler
virtual	~IDataChangeHandler ()
	~IDataChangeHandler

virtual void	HandleDataChange (const std::shared_ptr< MonitoredItem > monitor_item, UA_DataValue *value)=0
	HandleDataChanges.

Static Public Attributes
static std::map< std::string, std::shared_ptr< OpcuaConnection > >	m_connection_map

Detailed Description

The Open62541 class.

This class encapsulates the Open62541 OPCUA functions used by ICS FW devices. Each device shall create one instance of this class. If a device is running in the same server as another existing device, then this connection will be reused avoiding creating multiple connections for the same server.

Constructor & Destructor Documentation

◆ Open62541()

protocol::opcua::Open62541::Open62541 ( )

◆ ~Open62541()

protocol::opcua::Open62541::~Open62541 ( )

virtual

Member Function Documentation

◆ Connect()

void protocol::opcua::Open62541::Connect	(	const std::string &	device,
		const std::string &	address
	)

virtual

Establish the connection to the OPCUA server.

Parameters

device	Name of the device
address	Address of the OPCUA Server

Returns

Implements protocol::base::IComm.

◆ Disconnect()

void protocol::opcua::Open62541::Disconnect ( )

virtual

Disconnects from the server.

Returns

Exceptions

exceptions for error cases.

Implements protocol::base::IComm.

◆ GetEndpoint()

std::string protocol::opcua::Open62541::GetEndpoint ( ) const

Get endpoint of the connection.

◆ HandleDataChange()

void protocol::opcua::Open62541::HandleDataChange	(	const std::shared_ptr< MonitoredItem >	monitor_item,
		UA_DataValue *	value
	)

virtual

Handle data changes.

Parameters

monitored_item	Pointer to the monitored item generating the change.
value	Vector containing the values of the data changes.

Implements protocol::opcua::IDataChangeHandler.

◆ HandleSessionChanges()

void protocol::opcua::Open62541::HandleSessionChanges ( bool status )

virtual

Handle changes in the OPCUA session.

Parameters

status Status of the session.

◆ Read()

void protocol::opcua::Open62541::Read ( protocol::base::VectorVariant & params )

overridevirtual

Performs a Read operation.

Parameters

params Vector of attributes to be read.

Returns

Exceptions

exceptions for error cases.

Implements protocol::base::IComm.

◆ RegisterCB()

void protocol::opcua::Open62541::RegisterCB	(	protocol::base::Dispatcher< protocol::base::VectorVariant & > &	dispatcher,
		protocol::base::Dispatcher<> &	failure,
		protocol::base::Dispatcher<> &	normal
	)

virtual

Registers internal and external callbacks.

Parameters

dispatcher	Vector of device callbacks.
failure	Callback for session problems.
normal	Callback for session recovery.

Exceptions

exceptions for error cases.

Implements protocol::base::IComm.

◆ ResumeSubscriptions()

UA_StatusCode protocol::opcua::Open62541::ResumeSubscriptions ( )

Resume subscriptions for all connections.

This method shall be called only to recover subscriptions after loosing the session, e.g. for a connection lost.

◆ Rpc()

void protocol::opcua::Open62541::Rpc	(	const std::string &	obj,
		const std::string &	proc,
		const protocol::base::VectorVariant &	params,
		protocol::base::Variant &	result
	)

overridevirtual

Executes a RPC.

Parameters

obj	of attributes to write.
proc	Vector of attributes to write.
params	Vector of pameters to the RPC to be executed.
result	resulting value given by the RPC.

Returns

Exceptions

exceptions for error cases.

Implements protocol::base::IComm.

◆ SetEndpoint()

void protocol::opcua::Open62541::SetEndpoint ( const std::string & endpoint )

Set endpoint to the connection.

◆ StartMonitorItem()

void protocol::opcua::Open62541::StartMonitorItem ( const std::string & item )

overridevirtual

Start monitoring an attribute.

Parameters

item	Attribute to be monitored.

Returns

The format expected is <namespace, name> e.g. 4, PLC1.Lamp1.stat.nState

The above means, the library only supports string based names.

Exceptions

exceptions for error cases.

Implements protocol::base::IComm.

◆ StartMonitorItems()

void protocol::opcua::Open62541::StartMonitorItems ( const std::vector< std::string > & item_vector )

overridevirtual

Start monitoring a vector of attributes.

Parameters

item_vector Vector of attributes to be monitored.

Returns

Each attribute in the vector is expected to have the format <namespace, name> e.g. 4, PLC1.Lamp1.stat.nState

The above means, the library only supports string based names.

Exceptions

exceptions for error cases.

Implements protocol::base::IComm.

◆ StopMonitorItem()

void protocol::opcua::Open62541::StopMonitorItem ( const std::string & item )

overridevirtual

Stop monitoring an attribute.

Parameters

item	Attribute to be removed.

Returns

Exceptions

exceptions for error cases.

Implements protocol::base::IComm.

◆ UpdateState()

void protocol::opcua::Open62541::UpdateState	(	UA_SecureChannelState	channel_state,
		UA_SessionState	session_state,
		UA_StatusCode	recovery_status
	)

Update connection state.

◆ Write()

void protocol::opcua::Open62541::Write ( const protocol::base::VectorVariant & params )

overridevirtual

Performs a Write operation.

Parameters

params Vector of attributes to write.

Returns

Exceptions

exceptions for error cases.

Implements protocol::base::IComm.

Member Data Documentation

◆ m_connection_map

std::map<std::string, std::shared_ptr<OpcuaConnection> > protocol::opcua::Open62541::m_connection_map

inlinestatic

static map of connections. Multiples objects of this class may share the same connection. This is a typical case when several controllers are handled by one PLC.

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

protocol/open62541/src/include/ifw/core/protocol/open62541/open62541.hpp
protocol/open62541/src/open62541.cpp

Public Member Functions

Static Public Attributes

Detailed Description

Constructor & Destructor Documentation

◆ Open62541()

◆ ~Open62541()

Member Function Documentation

◆ Connect()

◆ Disconnect()

◆ GetEndpoint()

◆ HandleDataChange()

◆ HandleSessionChanges()

◆ Read()

◆ RegisterCB()

◆ ResumeSubscriptions()

◆ Rpc()

◆ SetEndpoint()

◆ StartMonitorItem()

◆ StartMonitorItems()

◆ StopMonitorItem()

◆ UpdateState()

◆ Write()

Member Data Documentation

◆ m_connection_map