UniSet 2.32.1
|
Классы | |
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< 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) |
![]() | |
UniSetObject (const std::string &name, const std::string §ion) | |
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 |
![]() | |
timeout_t | checkTimers (UniSetObject *obj) |
timeout_t | getTimeInterval (uniset::TimerId timerid) const |
timeout_t | getTimeLeft (uniset::TimerId timerid) const |
![]() | |
virtual Poco::JSON::Object::Ptr | httpRequest (const std::string &req, const Poco::URI::QueryParameters &p) |
![]() | |
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 ¶ms) |
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 |
![]() | |
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) |
![]() | |
virtual std::string | getTimerName (int id) const |
TimersList | getTimersList () const |
![]() | |
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 } |
int | jpoolCapacity = { 200 } |
int | jpoolPeakCapacity = { 5000 } |
std::list< std::shared_ptr< UWebSocket > > | wsocks |
uniset::uniset_rwmutex | wsocksMutex |
size_t | maxwsocks = { 50 } |
![]() | |
std::shared_ptr< UInterface > | ui |
std::string | myname |
std::weak_ptr< UniSetManager > | mymngr |
![]() | |
timeout_t | sleepTime |
![]() | |
ev::dynamic_loop | loop |
Друзья | |
class | UWebSocketGuard |
Дополнительные унаследованные члены | |
![]() | |
typedef std::deque< TimerInfo > | TimersList |
|
overrideprotectedvirtual |
Активизация объекта (переопределяется для необходимых действий после активизации)
Переопределяет метод предка uniset::UniSetObject.
|
overrideprotectedvirtual |
Деактивация объекта (переопределяется для необходимых действий при завершении работы)
Переопределяет метод предка uniset::UniSetObject.
|
overrideprotectedvirtual |
Переопределяет метод предка uniset::EventLoopServer.
|
overrideprotectedvirtual |
Переопределяет метод предка uniset::EventLoopServer.
|
overrideprotectedvirtual |
Переопределяет метод предка uniset::UniSetObject.
|
static |
глобальная функция для вывода help-а
|
static |
глобальная функция для инициализации объекта
|
overrideprotectedvirtual |
Переопределяет метод предка uniset::UniSetObject.
|
overrideprotectedvirtual |
Переопределяет метод предка uniset::UniSetObject.