Compare commits

..

No commits in common. "5764d7f9c06ae34538d685da87c366631462a8f2" and "a7b5d505335cd9c6dd02ca07c80bc4cc1b321f32" have entirely different histories.

3 changed files with 12 additions and 10 deletions

View file

@ -61,6 +61,9 @@ struct ObjectPath
objectName = components.back();
components.pop_back();
}
spdlog::debug("ObjectPath: objectName={}, components={}", objectName,
fmt::join(components, ", "));
}
};

View file

@ -344,6 +344,10 @@ struct NngPairStrategy: public ProcessingStrategy
}
report();
spdlog::debug("NngPairStrategy: producerTx: {:.2f} MiB, {} messages",
producerTx.bytes / (1024.0 * 1024), producerTx.messages);
spdlog::debug("NngPairStrategy: consumerRx: {:.2f} MiB, {} messages",
consumerRx.bytes / (1024.0 * 1024), consumerRx.messages);
}
void run(ListfileContext &listfileContext, ParserContext &parserContext) override
@ -362,11 +366,6 @@ struct NngPairStrategy: public ProcessingStrategy
if (producerThread.joinable())
producerThread.join();
spdlog::debug("NngPairStrategy: producerTx: {:.2f} MiB, {} messages",
producerTx.bytes / (1024.0 * 1024), producerTx.messages);
spdlog::debug("NngPairStrategy: consumerRx: {:.2f} MiB, {} messages",
consumerRx.bytes / (1024.0 * 1024), consumerRx.messages);
}
};