We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7227479 commit 294889fCopy full SHA for 294889f
src/Monitoring.cxx
@@ -61,6 +61,10 @@ void Monitoring::flushBuffer()
61
return;
62
}
63
for (auto& [verbosity, buffer] : mStorage) {
64
+ if (buffer.empty()) {
65
+ MonLogger::Get() << "Not flushing empty buffer" << MonLogger::End();
66
+ continue;
67
+ }
68
for (auto& backend : mBackends) {
69
if (matchVerbosity(backend->getVerbosity(), static_cast<Verbosity>(verbosity))) {
70
backend->send(std::move(buffer));
@@ -132,9 +136,7 @@ Monitoring::~Monitoring()
132
136
mMonitorThread.join();
133
137
transmit(mProcessMonitor->makeLastMeasurementAndGetMetrics());
134
138
135
- if (mBuffering) {
- flushBuffer();
- }
139
+ flushBuffer();
140
141
142
void Monitoring::pushLoop()
0 commit comments