From 8e7b8af180dc3153df3e5fa4c21e1fb5c1e8dd4b Mon Sep 17 00:00:00 2001 From: Jack Date: Thu, 18 Aug 2016 06:23:27 -0400 Subject: [PATCH] call blob_completed when is_validated is true --- lbrynet/reflector/server/server.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/lbrynet/reflector/server/server.py b/lbrynet/reflector/server/server.py index 7ea759f97..1728a8ed1 100644 --- a/lbrynet/reflector/server/server.py +++ b/lbrynet/reflector/server/server.py @@ -85,11 +85,12 @@ class ReflectorServer(Protocol): def determine_blob_needed(self, blob): if blob.is_validated(): - return {'send_blob': False} + d = self.blob_manager.blob_completed(blob) + d.addCallback(lambda _: {'send_blob': False}) + return d else: self.incoming_blob = blob self.blob_finished_d, self.blob_write, self.cancel_write = blob.open_for_writing(self.peer) - self.blob_finished_d.addCallback(lambda _: self.blob_manager.blob_completed(blob)) return {'send_blob': True} def close_blob(self):