Minor bug fixes

This commit is contained in:
2023-11-09 12:11:08 +01:00
parent 47103c9950
commit 1f248b61a5
3 changed files with 12 additions and 6 deletions

View File

@@ -38,10 +38,14 @@ let failed = 0;
const sendTimer = new NanoTimer();
function startInterval(session, sessionLogger) {
if (!options.messagecount > 0) {
sessionLogger.info("No messages to send");
return;
}
sendTimer.setInterval(
async () => {
if (sent >= options.messagecount) {
logger.info(`Finished sending messages success:${success}, failed:${failed}, idling...`);
sessionLogger.info(`Finished sending messages success:${success}, failed:${failed}, idling...`);
sendTimer.clearInterval();
} else if (inFlight < options.window) {
sessionLogger.info(`Sending message ${sent + 1}/${options.messagecount}`);