greenplumn CLogger 代码
文件路径：/src/backend/gporca/libgpos/src/error/CLogger.cpp
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2010 Greenplum, Inc.
/
/ @filename:
/ CLogger.cpp
/
/ @doc:
/ Partial implementation of interface class for logging
/---------------------------------------------------------------------------
#include "gpos/error/CLogger.h"
#include "gpos/common/clibwrapper.h"
#include "gpos/common/syslibwrapper.h"
#include "gpos/error/CLoggerStream.h"
#include "gpos/error/CLoggerSyslog.h"
#include "gpos/error/CMessageRepository.h"
#include "gpos/io/ioutils.h"
#include "gpos/string/CWStringConst.h"
using namespace gpos;
/---------------------------------------------------------------------------
/ @function:
/ CLogger::CLogger
/
/ @doc:
/ Ctor
/
/---------------------------------------------------------------------------
CLogger::CLogger(ErrorInfoLevel info_level)
: ILogger(),
m_entry_wrapper(m_entry, GPOS_ARRAY_SIZE(m_entry)),
m_msg_wrapper(m_msg, GPOS_ARRAY_SIZE(m_msg)),
m_info_level(info_level)
{
}
/---------------------------------------------------------------------------
/ @function:
/ CLogger::~CLogger
/
/ @doc:
/ Dtor
/
/---------------------------------------------------------------------------
CLogger::~CLogger() = default;
/---------------------------------------------------------------------------
/ @function:
/ CLogger::Log
/
/ @doc:
/ Log message
/
/---------------------------------------------------------------------------
void
CLogger::Log(const WCHAR *msg, ULONG severity, const CHAR *filename, ULONG line)
{
/ format log message
Format(msg, severity, filename, line);
for (ULONG i = 0; i < GPOS_LOG_WRITE_RETRIES; i++)
{
GPOS_CHECK_ABORT;
BOOL pending_exceptions = ITask::Self()->HasPendingExceptions();
/ logging is exercised in catch blocks so it cannot throw;
/ the only propagated exception is Abort;
GPOS_TRY
{
/ write message to log
Write(m_entry_wrapper.GetBuffer(), severity);
return;
}
GPOS_CATCH_EX(ex)
{
/ propagate assert failures
if (GPOS_MATCH_EX(ex, CException::ExmaSystem,
CException::ExmiAssert))
{
GPOS_RETHROW(ex);
}
/ ignore anything else but aborts
if (GPOS_MATCH_EX(ex, CException::ExmaSystem,
CException::ExmiAbort))
{
/ reset any currently handled exception
GPOS_RESET_EX;
GPOS_ABORT;
}
if (!pending_exceptions)
{
GPOS_RESET_EX;
}
}
GPOS_CATCH_END;
}
/ alert admin for logging failure
ReportFailure();
}
/---------------------------------------------------------------------------
/ @function:
/ CLogger::Format
/
/ @doc:
/ Format log message
/
/---------------------------------------------------------------------------
void
CLogger::Format(const WCHAR *msg, ULONG severity,
const CHAR *, / filename
ULONG / line
)
{
m_entry_wrapper.Reset();
m_msg_wrapper.Reset();
CWStringConst strc(msg);
if (ILogger::EeilMsgHeader <= InfoLevel())
{
/ LOG ENTRY FORMAT: [date],[thread id],[severity],[message],
const CHAR *sev = CException::m_severity[severity];
m_msg_wrapper.Append(&strc);
AppendDate();
/ append thread id and severity
m_entry_wrapper.AppendFormat(GPOS_WSZ_LIT(",THD%03d,%s,\"%ls\",\n"),
0, /thread id
sev, m_msg_wrapper.GetBuffer());
}
else
{
m_entry_wrapper.Append(&strc);
}
}
/---------------------------------------------------------------------------
/ @function:
/ CLogger::AppendDate
/
/ @doc:
/ Add date to message
/
/---------------------------------------------------------------------------
void
CLogger::AppendDate()
{
TIMEVAL tv;
TIME tm;
/ get local time
syslib::GetTimeOfDay(&tv, nullptr /*timezone*/);
TIME *t GPOS_ASSERTS_ONLY = clib::Localtime_r(&tv.tv_sec, &tm);
GPOS_ASSERT(nullptr != t && "Failed to get local time");
/ format: YYYY-MM-DD HH-MM-SS-UUUUUU TZ
m_entry_wrapper.AppendFormat(
GPOS_WSZ_LIT("%04d-%02d-%02d %02d:%02d:%02d:%06d %s"),
tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min,
tm.tm_sec, tv.tv_usec, tm.tm_zone);
}
/---------------------------------------------------------------------------
/ @function:
/ CLogger::AppendDate
/
/ @doc:
/ Report logging failure
/
/---------------------------------------------------------------------------
void
CLogger::ReportFailure()
{
/ check if errno was set
if (0 < errno)
{
/ get error description
clib::Strerror_r(errno, m_retrieved_msg,
GPOS_ARRAY_SIZE(m_retrieved_msg));
m_retrieved_msg[GPOS_ARRAY_SIZE(m_retrieved_msg) - 1] = '\0';
m_entry_wrapper.Reset();
m_entry_wrapper.AppendFormat(GPOS_WSZ_LIT("%s\n"), m_retrieved_msg);
CLoggerSyslog::Alert(m_entry_wrapper.GetBuffer());
return;
}
/ send generic failure message
CLoggerSyslog::Alert(GPOS_WSZ_LIT(
"Log write failure, check disc space and filesystem integrity"));
}
/ EOF
相关信息
相关文章
greenplumn CAutoExceptionStack 源码
greenplumn CErrorHandlerStandard 源码