Класс uniset::UWebSocketGate

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

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

Классы
class	UWebSocket
class	UWebSocketGuard
class	UWebSocketGateRequestHandlerFactory

Открытые члены
	UWebSocketGate (uniset::ObjectId id, xmlNode *cnode, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="-ws")
std::shared_ptr< DebugStream >	log ()
std::shared_ptr< uniset::LogAgregator >	logAgregator () noexcept
virtual void	handleRequest (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp) override
void	onWebSocketSession (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp)
Poco::JSON::Object::Ptr	httpStatus ()
Poco::JSON::Object::Ptr	httpList ()
Poco::JSON::Object::Ptr	httpHelpApi ()
Открытые члены унаследованные от 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	httpRequest (const UHttp::HttpRequestContext &ctx) 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::EventLoopServer
bool	evIsActive () const noexcept

Открытые статические члены
static std::shared_ptr< UWebSocketGate >	init_wsgate (int argc, const char *const *argv, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="ws-")
static void	help_print ()
static Poco::JSON::Object::Ptr	error_to_json (std::string_view err)
static void	fill_error_json (Poco::JSON::Object::Ptr &p, std::string_view err)

Защищенные члены
virtual bool	activateObject () override
	Активизация объекта (переопределяется для необходимых действий после активизации).
virtual bool	deactivateObject () override
	Деактивация объекта (переопределяется для необходимых действий при завершении работы).
virtual void	sysCommand (const uniset::SystemMessage *sm) override
void	run (bool async)
virtual void	evfinish () override
virtual void	evprepare () override
void	onCheckBuffer (ev::timer &t, int revents)
void	onActivate (ev::async &watcher, int revents)
void	onCommand (ev::async &watcher, int revents)
void	httpWebSocketPage (std::ostream &out, Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp)
void	httpWebSocketConnectPage (std::ostream &out, Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp, const std::string &params)
std::shared_ptr< UWebSocket >	newWebSocket (Poco::Net::HTTPServerRequest *req, Poco::Net::HTTPServerResponse *resp, const Poco::URI::QueryParameters &qp)
void	delWebSocket (std::shared_ptr< UWebSocket > &ws)
Poco::JSON::Object::Ptr	respError (Poco::Net::HTTPServerResponse &resp, Poco::Net::HTTPResponse::HTTPStatus s, const std::string &message)
void	makeResponseAccessHeader (Poco::Net::HTTPServerResponse &resp)
void	terminate ()
void	checkMessages (ev::timer &t, int revents)
virtual void	sensorInfo (const uniset::SensorMessage *sm) override
virtual uniset::SimpleInfo *	getInfo (const char *userparam=0) override
Защищенные члены унаследованные от uniset::UniSetObject
virtual void	processingMessage (const uniset::VoidMessage *msg)
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
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
Защищенные члены унаследованные от uniset::EventLoopServer
bool	async_evrun (size_t waitRunningTimeout_msec=60000)
void	evstop ()
bool	evrun ()

Защищенные данные
ev::async	wsactivate
std::shared_ptr< ev::async >	wscmd
ev::timer	iocheck
double	check_sec = { 0.05 }
int	maxMessagesProcessing = { 200 }
std::shared_ptr< DebugStream >	mylog
std::shared_ptr< uniset::LogAgregator >	loga
std::shared_ptr< SMInterface >	shm
std::unique_ptr< uniset::RunLock >	runlock
std::shared_ptr< uniset::LogServer >	logserv
std::string	logserv_host = {""}
int	logserv_port = { 0 }
std::shared_ptr< Poco::Net::HTTPServer >	httpserv
std::string	httpHost = { "" }
int	httpPort = { 0 }
std::string	httpCORS_allow = { "*" }
double	wsHeartbeatTime_sec = { 3.0 }
double	wsSendTime_sec = { 0.2 }
size_t	wsMaxSend = { 5000 }
size_t	wsMaxCmd = { 200 }
double	wsPongTimeout_sec = { 5.0 }
double	wsMaxLifetime_sec = { 0 }
int	jpoolCapacity = { 200 }
int	jpoolPeakCapacity = { 5000 }
std::list< std::shared_ptr< UWebSocket > >	wsocks
uniset::uniset_rwmutex	wsocksMutex
size_t	maxwsocks = { 50 }
Защищенные данные унаследованные от uniset::UniSetObject
std::shared_ptr< UInterface >	ui
std::string	myname
std::weak_ptr< UniSetManager >	mymngr
Защищенные данные унаследованные от uniset::LT_Object
timeout_t	sleepTime
Защищенные данные унаследованные от uniset::EventLoopServer
ev::dynamic_loop	loop

Друзья
class	UWebSocketGuard

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

Методы

activateObject()

bool UWebSocketGate::activateObject ( )

overrideprotectedvirtual

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

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

deactivateObject()

bool UWebSocketGate::deactivateObject ( )

overrideprotectedvirtual

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

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

evfinish()

void UWebSocketGate::evfinish ( )

overrideprotectedvirtual

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

evprepare()

void UWebSocketGate::evprepare ( )

overrideprotectedvirtual

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

getInfo()

uniset::SimpleInfo * UWebSocketGate::getInfo ( const char * userparam = 0 )

overrideprotectedvirtual

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

help_print()

void UWebSocketGate::help_print ( )

static

глобальная функция для вывода help-а

init_wsgate()

std::shared_ptr< UWebSocketGate > UWebSocketGate::init_wsgate ( int argc, const char *const * argv, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > & ic = nullptr, const std::string & prefix = "ws-" )

static

глобальная функция для инициализации объекта

sensorInfo()

void UWebSocketGate::sensorInfo ( const uniset::SensorMessage * sm )

overrideprotectedvirtual

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

sysCommand()

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

overrideprotectedvirtual

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