|
virtual void | evfinish () override |
|
virtual void | evprepare () override |
|
void | onCheckBuffer (ev::timer &t, int revents) |
|
void | onActivate (ev::async &watcher, int revents) |
|
void | addLog (Log *log, const std::string &txt) |
|
void | log2File (Log *log, const std::string &txt) |
|
size_t | getCountOfRecords (const std::string &logname="") |
|
size_t | getFirstOfOldRecord (size_t maxnum) |
|
Poco::JSON::Object::Ptr | respError (Poco::Net::HTTPServerResponse &resp, Poco::Net::HTTPResponse::HTTPStatus s, const std::string &message) |
|
Poco::JSON::Object::Ptr | httpGetRequest (const std::string &cmd, const Poco::URI::QueryParameters &p) |
|
Poco::JSON::Object::Ptr | httpGetList (const Poco::URI::QueryParameters &p) |
|
Poco::JSON::Object::Ptr | httpGetLogs (const Poco::URI::QueryParameters &p) |
|
Poco::JSON::Object::Ptr | httpGetCount (const Poco::URI::QueryParameters &p) |
|
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 &logname) |
|
std::shared_ptr< LogWebSocket > | newWebSocket (Poco::Net::HTTPServerRequest *req, Poco::Net::HTTPServerResponse *resp, const std::string &logname) |
|
void | delWebSocket (std::shared_ptr< LogWebSocket > &ws) |
|
void | flushBuffer () |
|
void | rotateDB () |
|
void | onTerminate (ev::sig &evsig, int revents) |
|
bool | async_evrun (size_t waitRunningTimeout_msec=60000) |
|
void | evstop () |
|
bool | evrun () |
|
|
std::string | myname |
|
std::unique_ptr< SQLiteInterface > | db |
|
std::string | tmsFormat = { "localtime" } |
|
bool | activate = { false } |
|
QueryBuffer | qbuf |
|
size_t | qbufSize = { 1000 } |
|
ev::timer | flushBufferTimer |
|
double | tmFlushBuffer_sec = { 1.0 } |
|
size_t | maxdbRecords = { 200 * 1000 } |
|
size_t | numOverflow = { 0 } |
|
ev::sig | sigTERM |
|
ev::sig | sigQUIT |
|
ev::sig | sigINT |
|
ev::async | wsactivate |
|
std::vector< std::shared_ptr< Log > > | logservers |
|
std::shared_ptr< DebugStream > | dblog |
|
std::shared_ptr< Poco::Net::HTTPServer > | httpserv |
|
std::string | httpHost = { "" } |
|
int | httpPort = { 0 } |
|
std::string | httpCORS_allow = { "*" } |
|
std::string | httpReplyAddr = { "" } |
|
double | wsHeartbeatTime_sec = { 3.0 } |
|
double | wsSendTime_sec = { 0.5 } |
|
size_t | wsMaxSend = { 200 } |
|
std::string | fgColor = { "#c4c4c4" } |
|
std::string | bgColor = { "#111111" } |
|
std::string | bgColorTitle = { "green" } |
|
std::string | fgColorTitle = { "#ececec" } |
|
std::list< std::shared_ptr< LogWebSocket > > | wsocks |
|
uniset::uniset_rwmutex | wsocksMutex |
|
size_t | maxwsocks = { 50 } |
|
ev::dynamic_loop | loop |
|