#include <DBServer.h>

Граф наследования:uniset::DBServer:

Граф связей класса uniset::DBServer:

[см. легенду]

Открытые члены
	DBServer (uniset::ObjectId id, const std::string &prefix="db")

	DBServer (const std::string &prefix="db")

virtual uniset::SimpleInfo *	getInfo (const char *userparam="") override

Открытые члены унаследованные от uniset::UniSetObject
	UniSetObject (const std::string &name, const std::string &section)

	UniSetObject (uniset::ObjectId id)

virtual CORBA::Boolean	exist () override

virtual uniset::ObjectId	getId () override

const uniset::ObjectId	getId () const

std::string	getName () const

virtual uniset::ObjectType	getType () override

const std::string	getStrType ()

virtual uniset::SimpleInfo *	apiRequest (const char *query) override

virtual void	push (const uniset::TransportMessage &msg) override
	поместить сообщение в очередь

virtual void	pushMessage (const char *msg, ::CORBA::Long mtype, const ::uniset::Timespec &tm, const ::uniset::ProducerInfo &pi, ::CORBA::Long priority, ::CORBA::Long consumer) override
	поместить текстовое сообщение в очередь

virtual Poco::JSON::Object::Ptr	httpGet (const Poco::URI::QueryParameters &p) override

virtual Poco::JSON::Object::Ptr	httpHelp (const Poco::URI::QueryParameters &p) override

uniset::ObjectPtr	getRef () const

std::shared_ptr< UniSetObject >	get_ptr ()

virtual timeout_t	askTimer (uniset::TimerId timerid, timeout_t timeMS, clock_t ticks=-1, uniset::Message::Priority p=uniset::Message::High) override

Открытые члены унаследованные от uniset::LT_Object
timeout_t	checkTimers (UniSetObject *obj)

timeout_t	getTimeInterval (uniset::TimerId timerid) const

timeout_t	getTimeLeft (uniset::TimerId timerid) const

Открытые члены унаследованные от uniset::UHttp::IHttpRequest
virtual Poco::JSON::Object::Ptr	httpRequest (const std::string &req, const Poco::URI::QueryParameters &p)

Открытые статические члены
static std::string	help_print ()

Защищенные члены
virtual void	processingMessage (const uniset::VoidMessage *msg) override

virtual void	sysCommand (const uniset::SystemMessage *sm) override

virtual void	confirmInfo (const uniset::ConfirmMessage *cmsg)

virtual bool	activateObject () override
	Активизация объекта (переопределяется для необходимых действий после активизации)

virtual void	initDBServer ()

virtual std::string	getMonitInfo (const std::string &params)

Защищенные члены унаследованные от uniset::UniSetObject
virtual void	sensorInfo (const uniset::SensorMessage *sm)

virtual void	timerInfo (const uniset::TimerMessage *tm)

virtual void	onTextMessage (const uniset::TextMessage *tm)

VoidMessagePtr	receiveMessage ()

VoidMessagePtr	waitMessage (timeout_t msec=UniSetTimer::WaitUpTime)

void	termWaiting ()

size_t	countMessages ()

size_t	getCountOfLostMessages () const

virtual bool	deactivateObject ()
	Деактивация объекта (переопределяется для необходимых действий при завершении работы)

void	uterminate ()

void	thread (bool create)

void	offThread ()

void	onThread ()

virtual void	callback ()

void	setID (uniset::ObjectId id)

void	setThreadPriority (Poco::Thread::Priority p)

void	setMaxSizeOfMessageQueue (size_t s)

size_t	getMaxSizeOfMessageQueue () const

bool	isActive () const

void	setActive (bool set)

virtual Poco::JSON::Object::Ptr	httpGetMyInfo (Poco::JSON::Object::Ptr root)

Poco::JSON::Object::Ptr	request_configure (const std::string &req, const Poco::URI::QueryParameters &p)

Poco::JSON::Object::Ptr	request_configure_get (const std::string &req, const Poco::URI::QueryParameters &p)

Poco::JSON::Object::Ptr	request_configure_by_name (const std::string &name, const std::string &props)

Poco::JSON::Object::Ptr	request_params (const std::string &req, const Poco::URI::QueryParameters &p)

virtual Poco::JSON::Object::Ptr	request_params_get (const std::string &req, const Poco::URI::QueryParameters &p)

virtual Poco::JSON::Object::Ptr	request_params_set (const std::string &req, const Poco::URI::QueryParameters &p)

Защищенные члены унаследованные от uniset::LT_Object
virtual std::string	getTimerName (int id) const

TimersList	getTimersList () const

Защищенные данные
std::shared_ptr< LogAgregator >	loga

std::shared_ptr< DebugStream >	dblog

std::shared_ptr< LogServer >	logserv

std::string	logserv_host = {""}

int	logserv_port = {0}

const std::string	prefix = { "db" }

Защищенные данные унаследованные от uniset::UniSetObject
std::shared_ptr< UInterface >	ui

std::string	myname

std::weak_ptr< UniSetManager >	mymngr

Защищенные данные унаследованные от uniset::LT_Object
timeout_t	sleepTime

Дополнительные унаследованные члены
Защищенные типы унаследованные от uniset::LT_Object
typedef std::deque< TimerInfo >	TimersList

Подробное описание

Прототип реализации сервиса ведения БД Предназначен для работы с БД. Основная задача это - сохранение информации о датчиках, ведение журнала сообщений.

Сценарий работы

На узле, где ведётся БД запускается один экземпляр сервиса. Клиенты могут получить доступ, несколькими способами:

через NameService
при помощи UInterface::send()

Сервис является системным, поэтому его идентификатор можно получить при помощи uniset::Configuration::getDBServer() объекта uniset::conf.

Методы

◆ activateObject()

bool DBServer::activateObject ( )

overrideprotectedvirtual

Активизация объекта (переопределяется для необходимых действий после активизации)

Переопределяет метод предка uniset::UniSetObject.

◆ getInfo()

SimpleInfo * DBServer::getInfo ( const char * userparam = "" )

overridevirtual

Переопределяет метод предка uniset::UniSetObject.

◆ processingMessage()

void DBServer::processingMessage ( const uniset::VoidMessage * msg )

overrideprotectedvirtual

обработка приходящих сообщений

Переопределяет метод предка uniset::UniSetObject.

◆ sysCommand()

void DBServer::sysCommand ( const uniset::SystemMessage * sm )

overrideprotectedvirtual

Переопределяет метод предка uniset::UniSetObject.

Открытые члены

Открытые статические члены

Защищенные члены

Защищенные данные

Дополнительные унаследованные члены

Подробное описание

Методы

◆ activateObject()

◆ getInfo()

◆ processingMessage()

◆ sysCommand()