From 1ea5de347d2e01f9d840510a2187573a89210bd8 Mon Sep 17 00:00:00 2001 From: Filip Leonarski Date: Wed, 15 Apr 2026 12:01:05 +0200 Subject: [PATCH] StreamWriter: Fix sendint proper ACK at the end of data colection --- writer/StreamWriter.cpp | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/writer/StreamWriter.cpp b/writer/StreamWriter.cpp index 0c152554..247aab01 100644 --- a/writer/StreamWriter.cpp +++ b/writer/StreamWriter.cpp @@ -164,12 +164,11 @@ void StreamWriter::ProcessEndMessage() { err = e.what(); } } - bool error_state = (state == StreamWriterState::Error); FinalizeDataCollection(); - // Notifications happen only when handling END message - // No end message ==> no need to ACK + const bool error_state = (state == StreamWriterState::Error); + NotifyReceiverOnFinalizedWrite(writer_notification_zmq_addr); NotifyTcpAck(TCPFrameType::END, !error_state, error_state, error_state ? TCPAckCode::EndFailed : TCPAckCode::None,