Commit 4213866b authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Send stream-finish flag once on calling side.

parent 64cfecbb
Pipeline #12947 passed with stage
in 55 seconds
...@@ -174,7 +174,7 @@ class Streamer: ...@@ -174,7 +174,7 @@ class Streamer:
if not self.stream_finished: if not self.stream_finished:
stream_info = self.receiver.get_stream_info() stream_info = self.receiver.get_stream_info()
self.worker.stream_finished(stream_info) self.worker.stream_finished(stream_info)
self.stream_finished = True self.stream_finished = True
left_msgs = len(self.receiver.get_unacknowledged_messages()) left_msgs = len(self.receiver.get_unacknowledged_messages())
log.info("Number of unacknowledged messages = %s", left_msgs) log.info("Number of unacknowledged messages = %s", left_msgs)
if left_msgs == 0 or self.receiver.n_resend_nacs == 0: if left_msgs == 0 or self.receiver.n_resend_nacs == 0:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment