From 19583277965d2b75febda1992240838a42024d29 Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Wed, 28 Feb 2018 14:49:17 -0500 Subject: [PATCH] comments and logging --- lbrynet/database/storage.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/lbrynet/database/storage.py b/lbrynet/database/storage.py index 2715aa9cf..9905e0197 100644 --- a/lbrynet/database/storage.py +++ b/lbrynet/database/storage.py @@ -565,13 +565,19 @@ class SQLiteStorage(object): "inner join content_claim c3 ON claim.claim_outpoint=c3.claim_outpoint " "where c3.stream_hash=?", existing_file_stream_hash ) - if not known_claim_id: + if not known_claim_id: # this is a claim matching one of our files that has + # no associated claim yet log.info("discovered content claim %s for stream %s", claim_id, existing_file_stream_hash) yield self.save_content_claim(existing_file_stream_hash, outpoint) elif known_claim_id and known_claim_id == claim_id: - if known_outpoint != outpoint: + if known_outpoint != outpoint: # this is an update for one of our files log.info("updating content claim %s for stream %s", claim_id, existing_file_stream_hash) yield self.save_content_claim(existing_file_stream_hash, outpoint) + else: # we're up to date already + pass + else: # this is a claim containing a clone of a file that we have + log.warning("claim %s contains the same stream as the one already downloaded from claim %s", + claim_id, known_claim_id) def get_stream_hashes_for_claim_id(self, claim_id): return self.run_and_return_list(