Skip to content

Commit e4cd16c

Browse files
committed
break log pipeline earlier
1 parent 99c3dbb commit e4cd16c

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

src/Common/LoggingFormatStringHelpers.cpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,14 @@ LogSeriesLimiter::LogSeriesLimiter(LoggerPtr logger_, size_t allowed_count_, tim
150150
++total_count;
151151
}
152152

153+
LogSeriesLimiter * LogSeriesLimiter::getChannel()
154+
{
155+
if (!accepted)
156+
return nullptr;
157+
158+
return this;
159+
}
160+
153161
void LogSeriesLimiter::log(Poco::Message & message)
154162
{
155163
std::string_view pattern = message.getFormatString();

src/Common/LoggingFormatStringHelpers.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -281,9 +281,9 @@ class LogSeriesLimiter
281281

282282
LogSeriesLimiter * operator->() { return this; }
283283
bool is(Poco::Message::Priority priority) { return logger->is(priority); }
284-
LogSeriesLimiter * getChannel() {return this; }
285284
const String & name() const { return logger->name(); }
286285

286+
LogSeriesLimiter * getChannel();
287287
void log(Poco::Message & message);
288288

289289
LoggerPtr getLogger() { return logger; }

0 commit comments

Comments
 (0)