UniSet 2.32.1
Классы | Открытые члены | Открытые статические члены | Защищенные члены | Защищенные данные | Друзья | Полный список членов класса
Класс uniset::UWebSocketGate
Граф наследования:uniset::UWebSocketGate:
Inheritance graph
[см. легенду]
Граф связей класса uniset::UWebSocketGate:
Collaboration graph
[см. легенду]

Классы

class  UWebSocket
 
class  UWebSocketGateRequestHandlerFactory
 
class  UWebSocketGuard
 

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

 UWebSocketGate (uniset::ObjectId id, xmlNode *cnode, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="-ws")
 
std::shared_ptr< DebugStreamlog ()
 
std::shared_ptr< uniset::LogAgregatorlogAgregator () noexcept
 
virtual void handleRequest (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp) override
 
void onWebSocketSession (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp)
 
- Открытые члены унаследованные от 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::SimpleInfoapiRequest (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< UniSetObjectget_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)
 
- Открытые члены унаследованные от uniset::EventLoopServer
bool evIsActive () const noexcept
 

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

static std::shared_ptr< UWebSocketGateinit_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< UWebSocketnewWebSocket (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::SimpleInfogetInfo (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< DebugStreammylog
 
std::shared_ptr< uniset::LogAgregatorloga
 
std::shared_ptr< SMInterfaceshm
 
std::unique_ptr< uniset::RunLockrunlock
 
std::shared_ptr< uniset::LogServerlogserv
 
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 }
 
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< UInterfaceui
 
std::string myname
 
std::weak_ptr< UniSetManagermymngr
 
- Защищенные данные унаследованные от uniset::LT_Object
timeout_t sleepTime
 
- Защищенные данные унаследованные от uniset::EventLoopServer
ev::dynamic_loop loop
 

Друзья

class UWebSocketGuard
 

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

- Защищенные типы унаследованные от uniset::LT_Object
typedef std::deque< TimerInfoTimersList
 

Методы

◆ 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.