#include <activityUpdateOldb.hpp>

Inheritance diagram for rad::ActivityUpdateOldb:

Public Member Functions
	ActivityUpdateOldb (const std::string &id, const std::string &logger_name, rad::DoubleMap< rad::cii::OldbType > &oldb_map, std::chrono::seconds conn_timeout, std::chrono::milliseconds period)

virtual	~ActivityUpdateOldb ()

rad::cii::OldbAdapter &	GetOldbAdapter ()

void	SetOldbPrefix (const std::string &prefix)

void	Run () override

	ActivityUpdateOldb (const ActivityUpdateOldb &)=delete

ActivityUpdateOldb &	operator= (const ActivityUpdateOldb &)=delete
	Disable copy constructor. More...

Public Member Functions inherited from rad::ThreadActivity
	ThreadActivity (const ThreadActivity &)=delete

ThreadActivity &	operator= (const ThreadActivity &)=delete

pthread_t	GetNativeHandle () const override

bool	IsThreadJoined () const override

std::string	GetName ()

int	SetName (const std::string &name)

	ThreadBaseActivity (ThreadBaseActivity const &)=delete

Public Member Functions inherited from rad::ThreadBaseActivity
	ThreadBaseActivity (ThreadBaseActivity const &)=delete

void	start (scxml4cpp::Context *c) override

void	stop (scxml4cpp::Context *c) override

bool	IsStopRequested () const

Public Member Functions inherited from scxml4cpp::Activity
	Activity (const std::string &id)

virtual	~Activity ()

std::string	getId () const

void	setId (const std::string &id)

Additional Inherited Members
Protected Member Functions inherited from rad::ThreadActivity
void	StartThread () override

void	JoinThread () override

Detailed Description

This activity class implement a thread that can be used to write to the OLDB periodically attributes and associated values.

The attributes and values are taken from an object of type rad::DoubleMap<rad::cii::OldbType> which is shared between this class (the consumer) and the data producer(s).

The attributes and values are written to the OLDB via a rad::cii::OldbAdapter class.

The period of the activity and the connection timeout to write to the OLDB are configurable.

Constructor & Destructor Documentation

◆ ActivityUpdateOldb() [1/2]

rad::ActivityUpdateOldb::ActivityUpdateOldb	(	const std::string &	id,
		const std::string &	logger_name,
		rad::DoubleMap< rad::cii::OldbType > &	oldb_map,
		std::chrono::seconds	conn_timeout,
		std::chrono::milliseconds	period
	)

Constructor for the ActivityUpdateOldb class.

Parameters

id	Activity identifier.
logger_name	Name of the logger to be used by the class.
sm	Reference to the SM adapter that can be used to inject events.
oldb_map	Reference to the attributes/values to be written.
conn_timeout	Timeout when connecting to the OLDB.
period	Minimum period between two consecutive updates of the OLDB.

◆ ~ActivityUpdateOldb()

rad::ActivityUpdateOldb::~ActivityUpdateOldb ( )

virtual

◆ ActivityUpdateOldb() [2/2]

rad::ActivityUpdateOldb::ActivityUpdateOldb ( const ActivityUpdateOldb & )

delete

Member Function Documentation

◆ GetOldbAdapter()

rad::cii::OldbAdapter & rad::ActivityUpdateOldb::GetOldbAdapter ( )

Returns: Reference to the adapter object used to write to the OLDB.

◆ operator=()

ActivityUpdateOldb& rad::ActivityUpdateOldb::operator= ( const ActivityUpdateOldb & )

delete

Disable copy constructor.

◆ Run()

void rad::ActivityUpdateOldb::Run ( )

overridevirtual

Method implementing the thread which writes periodically to the OLDB the attributes and values taken from the rad::DoubleMap<rad::cii::OldbType> shared object.

Implements rad::ThreadActivity.

◆ SetOldbPrefix()

void rad::ActivityUpdateOldb::SetOldbPrefix ( const std::string & prefix )

This method allows to set a prefix to be added to all the keys before writing to the OLDB.