StreamWriter: Fix sendint proper ACK at the end of data colection

2026-04-15 12:01:05 +02:00
parent b9e7a79541
commit 1ea5de347d
1 changed files with 2 additions and 3 deletions
@@ -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,