#include <LogDB.h>

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

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

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

Классы
class	Log

class	LogDBRequestHandlerFactory

class	LogWebSocket

class	LogWebSocketGuard

Открытые члены
	LogDB (const std::string &name, int argc, const char const argv, const std::string &prefix)

std::shared_ptr< DebugStream >	log ()

void	run (bool async)

virtual void	handleRequest (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp) override

void	onWebSocketSession (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp)

void	handleOverload (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp)

Открытые члены унаследованные от uniset::EventLoopServer
bool	evIsActive () const noexcept

Открытые статические члены
static std::shared_ptr< LogDB >	init_logdb (int argc, const char const argv, const std::string &prefix="logdb-")

static void	help_print ()

Защищенные типы
typedef std::queue< std::string >	QueryBuffer

Защищенные члены
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 (Poco::Net::HTTPServerResponse &resp, const std::string &cmd, const Poco::URI::QueryParameters &p)

Poco::JSON::Object::Ptr	httpGetList (Poco::Net::HTTPServerResponse &resp, const Poco::URI::QueryParameters &p)

Poco::JSON::Object::Ptr	httpGetLogs (Poco::Net::HTTPServerResponse &resp, const Poco::URI::QueryParameters &p)

Poco::JSON::Object::Ptr	httpGetCount (Poco::Net::HTTPServerResponse &resp, const Poco::URI::QueryParameters &p)

Poco::JSON::Object::Ptr	httpGetStatus (Poco::Net::HTTPServerResponse &resp, const Poco::URI::QueryParameters &p)

Poco::JSON::Object::Ptr	httpDownload (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp, const Poco::URI::QueryParameters &p)

Poco::JSON::Object::Ptr	httpLogControl (std::ostream &out, Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp, const std::string &logname, const Poco::URI::QueryParameters &params)

void	httpWebSocketPage (std::ostream &out, Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp, const Poco::URI::QueryParameters &p)

void	httpWebSocketConnectPage (Poco::Net::HTTPServerRequest &req, Poco::Net::HTTPServerResponse &resp, const std::string &logname, const Poco::URI::QueryParameters &p)

bool	supportsGzip (Poco::Net::HTTPServerRequest &request)

std::shared_ptr< LogWebSocket >	newWebSocket (Poco::Net::HTTPServerRequest req, Poco::Net::HTTPServerResponse resp, const std::string &logname, const Poco::URI::QueryParameters &p)

void	delWebSocket (std::shared_ptr< LogWebSocket > &ws)

void	flushBuffer ()

void	rotateDB ()

void	onTerminate (ev::sig &evsig, int revents)

Защищенные члены унаследованные от uniset::EventLoopServer
bool	async_evrun (size_t waitRunningTimeout_msec=60000)

void	evstop ()

bool	evrun ()

Защищенные статические члены
static std::string	qEscapeString (const std::string &s)

static std::string	qLast (const std::string &p)

static std::string	qDate (const std::string &p, const char sep='-')

Защищенные данные
std::string	myname

std::unique_ptr< SQLiteInterface >	db

std::string	dbfile

std::string	tmsFormat = { "localtime" }

bool	activate = { false }

std::chrono::steady_clock::time_point	startTime

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::shared_ptr< uniset::LogServer >	logserv

std::string	logserv_host = {""}

int	logserv_port = {0}

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 = { "" }

std::string	httpJsonContentType = {"text/json; charset=UTF-8" }

std::string	httpHtmlContentType = {"text/html; charset=UTF-8" }

std::string	utf8Code = "UTF-8"

std::atomic< size_t >	httpActiveRequests {0}

size_t	httpMaxThreads = { 0 }

size_t	httpMaxQueued = { 0 }

size_t	httpMaxRequests = { 10 }

double	wsHeartbeatTime_sec = { 3.0 }

double	wsSendTime_sec = { 0.5 }

size_t	wsMaxSend = { 200 }

double	wsBackpressureTime_sec = { 15.0 }

size_t	wsQueueBytesLimit = { 2 * 1024 * 1024 }

size_t	wsFrameBytesLimit = { 64 * 1024 }

bool	httpEnabledLogControl = { false }

bool	httpEnabledDownload = { false }

double	wsPongTimeout_sec = { 10.0 }

double	wsMaxLifetime_sec = { 0 }

std::string	wsPageTemplate = ""

std::list< std::shared_ptr< LogWebSocket > >	wsocks

uniset::uniset_rwmutex	wsocksMutex

size_t	maxwsocks = { 50 }

Защищенные данные унаследованные от uniset::EventLoopServer
ev::dynamic_loop	loop

Статические защищенные данные
static constexpr size_t	reservedForMonitoring = 2

Друзья
class	LogWebSocketGuard

class	LogDBOverloadRequestHandler

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

Реализация LogDB.

См. также: База логов (LogDB)

Методы

◆ evfinish()

void LogDB::evfinish ( )

overrideprotectedvirtual

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

◆ evprepare()

void LogDB::evprepare ( )

overrideprotectedvirtual

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

◆ help_print()

void LogDB::help_print ( )

static

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

◆ httpGetList()

Poco::JSON::Object::Ptr LogDB::httpGetList	(	Poco::Net::HTTPServerResponse &	resp,
		const Poco::URI::QueryParameters &	p
	)

protected

◆ init_logdb()

std::shared_ptr< LogDB > LogDB::init_logdb	(	int	argc,
		const char const	argv,
		const std::string &	prefix = `"logdb-"`
	)

static

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

Данные класса

◆ tmsFormat

std::string uniset::LogDB::tmsFormat = { "localtime" }

protected

формат возвращаемого времени

Классы

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

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

Защищенные типы

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

Защищенные статические члены

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

Статические защищенные данные

Друзья