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);