mana auto replay: report nng perf after the producer thread terminated
This commit is contained in:
parent
a7b5d50533
commit
2ce5bdc0bc
1 changed files with 5 additions and 4 deletions
|
@ -344,10 +344,6 @@ 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
|
||||
|
@ -366,6 +362,11 @@ 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);
|
||||
}
|
||||
};
|
||||
|
||||
|
|
Loading…
Reference in a new issue