mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-30 05:30:51 +00:00
526afd44ed
Among other things, it is used to filter logs, which are being written even after the global server context is deinitialized, so we can't keep masker there.
39 lines
1.1 KiB
C++
39 lines
1.1 KiB
C++
#pragma once
|
|
#include <atomic>
|
|
#include <vector>
|
|
#include <Poco/AutoPtr.h>
|
|
#include <Poco/Channel.h>
|
|
#include "ExtendedLogChannel.h"
|
|
#include <Interpreters/TextLog.h>
|
|
|
|
|
|
namespace DB
|
|
{
|
|
/// Works as Poco::SplitterChannel, but performs additional work:
|
|
/// passes logs to Client via TCP interface
|
|
/// tries to use extended logging interface of child for more comprehensive logging
|
|
class OwnSplitChannel : public Poco::Channel
|
|
{
|
|
public:
|
|
/// Makes an extended message from msg and passes it to the client logs queue and child (if possible)
|
|
void log(const Poco::Message & msg) override;
|
|
/// Adds a child channel
|
|
void addChannel(Poco::AutoPtr<Poco::Channel> channel);
|
|
|
|
void addTextLog(std::shared_ptr<DB::TextLog> log);
|
|
|
|
private:
|
|
void logSplit(const Poco::Message & msg);
|
|
|
|
using ChannelPtr = Poco::AutoPtr<Poco::Channel>;
|
|
/// Handler and its pointer casted to extended interface
|
|
using ExtendedChannelPtrPair = std::pair<ChannelPtr, ExtendedLogChannel *>;
|
|
std::vector<ExtendedChannelPtrPair> channels;
|
|
|
|
std::mutex text_log_mutex;
|
|
|
|
std::weak_ptr<DB::TextLog> text_log;
|
|
};
|
|
|
|
}
|