#include <open62541.hpp>

Inheritance diagram for eso::uatools::protocol::opcua::Open62541:

Public Member Functions
	Open62541 (const std::optional< std::string > opcua_config_file=std::nullopt)
	Constructor.

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.

bool	IsServerReady (UA_Client *client)
	Check if server reports ready/running state.

Public Member Functions inherited from eso::uatools::protocol::base::IComm
virtual	~IComm ()=default

	IComm ()=default

	IComm (const IComm &)=delete

IComm &	operator= (const IComm &)=delete

	IComm (IComm &&)=delete

IComm &	operator= (IComm &&)=delete

virtual void	Connect (const ClientConfig &cfg)=0

virtual bool	IsConnected () const noexcept=0

virtual DataValue	Read (const std::string &node)=0

virtual std::vector< DataValue >	Read (const std::vector< std::string > &nodes)=0

virtual void	Write (const std::string &node, const Variant &value)=0

virtual std::vector< StatusCode >	Write (const std::vector< std::pair< std::string, Variant > > &writes)=0

virtual std::vector< Variant >	Call (const std::string &object, const std::string &method, const std::vector< Variant > &args)=0

virtual SubscriptionHandle	Subscribe (const std::string &node, DataCallback callback, const SubscriptionOpts &opts={})=0

virtual std::vector< SubscriptionHandle >	Subscribe (const std::vector< std::string > &nodes, DataCallback callback, const SubscriptionOpts &opts={})=0

virtual	~IComm ()

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

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()

eso::uatools::protocol::opcua::Open62541::Open62541 ( const std::optional< std::string > opcua_config_file = std::nullopt )

Constructor.

Parameters

opcua_config_file YAML file containing OPC UA properties

The OPCUA configuration file will be loaded and parsed invoking the Connect() method.

◆ ~Open62541()

eso::uatools::protocol::opcua::Open62541::~Open62541 ( )

virtual

Member Function Documentation

◆ Connect()

void eso::uatools::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
config	Config struct providing specific parameter settings (if needed)

Implements eso::uatools::protocol::base::IComm.

◆ Disconnect()

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

virtual

Disconnects from the server.

Returns

Exceptions

exceptions for error cases.

Implements eso::uatools::protocol::base::IComm.

◆ GetEndpoint()

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

Get endpoint of the connection.

◆ HandleDataChange()

void eso::uatools::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 eso::uatools::protocol::opcua::IDataChangeHandler.

◆ HandleSessionChanges()

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

virtual

Handle changes in the OPCUA session.

Parameters

status Status of the session.

◆ IsServerReady()

bool eso::uatools::protocol::opcua::Open62541::IsServerReady ( UA_Client * client )

Check if server reports ready/running state.

◆ Read()

void eso::uatools::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 eso::uatools::protocol::base::IComm.

◆ RegisterCB()

void eso::uatools::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 eso::uatools::protocol::base::IComm.

◆ ResumeSubscriptions()

UA_StatusCode eso::uatools::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 eso::uatools::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 eso::uatools::protocol::base::IComm.

◆ SetEndpoint()

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

Set endpoint to the connection.

◆ StartMonitorItem()

void eso::uatools::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 eso::uatools::protocol::base::IComm.

◆ StartMonitorItems()

void eso::uatools::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 eso::uatools::protocol::base::IComm.

◆ StopMonitorItem()

void eso::uatools::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 eso::uatools::protocol::base::IComm.

◆ UpdateState()

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

Update connection state.

◆ Write()

void eso::uatools::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 eso::uatools::protocol::base::IComm.

Member Data Documentation

◆ m_connection_map

std::map<std::string, std::shared_ptr<OpcuaConnection> > eso::uatools::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:

info/protocol_old/open62541/src/include/eso/uatools/protocol/open62541/open62541.hpp
info/protocol_old/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()

◆ IsServerReady()

◆ Read()

◆ RegisterCB()

◆ ResumeSubscriptions()

◆ Rpc()

◆ SetEndpoint()

◆ StartMonitorItem()

◆ StartMonitorItems()

◆ StopMonitorItem()

◆ UpdateState()

◆ Write()

Member Data Documentation

◆ m_connection_map