don't try to announce the stream terminator
This commit is contained in:
parent
adb1291c09
commit
8af96a0c51
1 changed files with 1 additions and 1 deletions
|
@ -2953,7 +2953,7 @@ class Daemon(AuthJSONRPCServer):
|
||||||
if sd_hash:
|
if sd_hash:
|
||||||
stream_hash = yield self.storage.get_stream_hash_for_sd_hash(sd_hash)
|
stream_hash = yield self.storage.get_stream_hash_for_sd_hash(sd_hash)
|
||||||
blobs = yield self.storage.get_blobs_for_stream(stream_hash, only_completed=True)
|
blobs = yield self.storage.get_blobs_for_stream(stream_hash, only_completed=True)
|
||||||
blob_hashes.extend([blob.blob_hash for blob in blobs])
|
blob_hashes.extend([blob.blob_hash for blob in blobs if blob.blob_hash is not None])
|
||||||
else:
|
else:
|
||||||
raise Exception('single argument must be specified')
|
raise Exception('single argument must be specified')
|
||||||
yield self.session.blob_manager.immediate_announce(blob_hashes)
|
yield self.session.blob_manager.immediate_announce(blob_hashes)
|
||||||
|
|
Loading…
Add table
Reference in a new issue