set fully reflected if the server indicates it had all of the stream

2019-01-30 14:58:26 -05:00 · 2019-01-30 14:58:26 -05:00 · 05915c540a
commit 05915c540a
parent 6aef6a80b7
1 changed files with 3 additions and 0 deletions
--- a/lbrynet/stream/managed_stream.py
+++ b/lbrynet/stream/managed_stream.py
@ -176,6 +176,9 @@ class ManagedStream:
            sent_sd, needed = await protocol.send_descriptor()
            if sent_sd:
                sent.append(self.sd_hash)
+            if not sent_sd and not needed:
+                if not self.fully_reflected.is_set():
+                    self.fully_reflected.set()
        except (asyncio.CancelledError, asyncio.TimeoutError, ValueError):
            if protocol.transport:
                protocol.transport.close()