mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-10 01:25:21 +00:00
41 lines
979 B
C++
41 lines
979 B
C++
#include "ExtendedLogChannel.h"
|
|
|
|
#include <sys/time.h>
|
|
#include <Common/CurrentThread.h>
|
|
#include <Common/Exception.h>
|
|
#include <base/getThreadId.h>
|
|
|
|
|
|
namespace DB
|
|
{
|
|
namespace ErrorCodes
|
|
{
|
|
extern const int CANNOT_GETTIMEOFDAY;
|
|
}
|
|
|
|
ExtendedLogMessage ExtendedLogMessage::getFrom(const Poco::Message & base)
|
|
{
|
|
ExtendedLogMessage msg_ext(base);
|
|
|
|
::timeval tv;
|
|
if (0 != gettimeofday(&tv, nullptr))
|
|
DB::throwFromErrno("Cannot gettimeofday", ErrorCodes::CANNOT_GETTIMEOFDAY);
|
|
|
|
msg_ext.time_seconds = static_cast<UInt32>(tv.tv_sec);
|
|
msg_ext.time_microseconds = static_cast<UInt32>(tv.tv_usec);
|
|
msg_ext.time_in_microseconds = static_cast<UInt64>((tv.tv_sec) * 1000000U + (tv.tv_usec));
|
|
|
|
if (current_thread)
|
|
{
|
|
auto query_id_ref = CurrentThread::getQueryId();
|
|
if (query_id_ref.size)
|
|
msg_ext.query_id.assign(query_id_ref.data, query_id_ref.size);
|
|
}
|
|
|
|
msg_ext.thread_id = getThreadId();
|
|
|
|
return msg_ext;
|
|
}
|
|
|
|
}
|