Skip to content

Commit 4e4dcfd

Browse files
authored
Fix error log level in InfoLogger (#278)
1 parent 5437c91 commit 4e4dcfd

File tree

4 files changed

+5
-5
lines changed

4 files changed

+5
-5
lines changed

src/MonLogger.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,9 +98,9 @@ class MonLogger
9898
context.setField(InfoLoggerContext::FieldName::System, "Monitoring");
9999
context.setField(InfoLoggerContext::FieldName::Facility, "Library");
100100
mStream.setContext(context);
101-
static InfoLogger::AutoMuteToken wToken({InfoLogger::Severity::Warning, InfoLogger::Level::Support, -1, nullptr, -1}, 2, 30);
101+
static InfoLogger::AutoMuteToken wToken({InfoLogger::Severity::Warning, InfoLogger::Level::Support, -1, nullptr, -1}, 2, 60);
102102

103-
mMute = (static_cast<int>(severity) < static_cast<int>(mLoggerSeverity)) ? true : false;
103+
mMute = (static_cast<int>(severity) >= static_cast<int>(mLoggerSeverity) || severity == Severity::Error) ? false : true;
104104
switch(severity) {
105105
case Severity::Warn: mStream << &wToken; break;
106106
default: mStream << static_cast<InfoLogger::Severity>(severity); break;

src/Transports/KafkaConsumer.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ KafkaConsumer::KafkaConsumer(const std::string& host, unsigned int port, const s
4343

4444
mConsumer = RdKafka::KafkaConsumer::create(conf.get(), errstr);
4545
if (!mConsumer) {
46-
MonLogger::Get(Severity::Warn) << "Could not initialize Kafka consumer" << MonLogger::End();
46+
MonLogger::Get(Severity::Error) << "Could not initialize Kafka consumer" << MonLogger::End();
4747
}
4848
if (mConsumer->subscribe({mTopic})) {
4949
MonLogger::Get(Severity::Warn) << "Failed to subscribe to topic" << MonLogger::End();

src/Transports/KafkaProducer.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ KafkaProducer::KafkaProducer(const std::string& host, unsigned int port, const s
3939

4040
mProducer = RdKafka::Producer::create(conf.get(), errstr);
4141
if (!mProducer) {
42-
MonLogger::Get(Severity::Warn) << "Could not initialize Kafka producer" << MonLogger::End();
42+
MonLogger::Get(Severity::Error) << "Could not initialize Kafka producer" << MonLogger::End();
4343
}
4444
MonLogger::Get(Severity::Info) << "Kafka transport initialized (" << host << ":" << port << "/" << mTopic << ")" << MonLogger::End();
4545
}

src/Transports/Unix.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ namespace transports
3131
Unix::Unix(const std::string& socketPath) : mSocket(mIoService), mEndpoint(socketPath)
3232
{
3333
if (!std::filesystem::exists(socketPath)) {
34-
MonLogger::Get(Severity::Warn) << "Unix socket path is invalid: " << socketPath << MonLogger::End();
34+
MonLogger::Get(Severity::Error) << "Unix socket path is invalid: " << socketPath << MonLogger::End();
3535
} else {
3636
mSocket.open();
3737
MonLogger::Get(Severity::Info) << "Unix socket transport initialized (" << socketPath << ")" << MonLogger::End();

0 commit comments

Comments
 (0)