From 20a4323fa2c6d2d7bbafca5c267cc9a2931f1a4c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Florian=20L=C3=BCke?= Date: Tue, 11 Jul 2023 20:30:46 +0200 Subject: [PATCH] make sure the last output message is sent --- external/mesytec-mvlc | 2 +- src/mvlc_nng_replay.cc | 17 +++++++++++++++++ 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/external/mesytec-mvlc b/external/mesytec-mvlc index c04c211..8edc589 160000 --- a/external/mesytec-mvlc +++ b/external/mesytec-mvlc @@ -1 +1 @@ -Subproject commit c04c2114583d3f067e4f95036c3d2b805a423073 +Subproject commit 8edc5890087e9794175013fbc5658c95fe0624b3 diff --git a/src/mvlc_nng_replay.cc b/src/mvlc_nng_replay.cc index 3bd679b..93561d7 100644 --- a/src/mvlc_nng_replay.cc +++ b/src/mvlc_nng_replay.cc @@ -554,6 +554,23 @@ void listfile_parser_nng( } } + if (parserContext.outputMessage) + { + const auto msgSize = nng_msg_len(parserContext.outputMessage); + + if (auto res = send_message_retry(outputSocket, parserContext.outputMessage, 0, "listfile_parser_nng")) + { + nng_msg_free(parserContext.outputMessage); + parserContext.outputMessage = nullptr; + spdlog::error("listfile_parser_nng: send_message_retry: {}:", nng_strerror(res)); + } + + parserContext.outputMessage = nullptr; + + spdlog::debug("listfile_parser_nng: sent message {} of size {}", + outputMessageNumber, msgSize); + } + if (inputMsg) { nng_msg_free(inputMsg);