logging
This commit is contained in:
parent
ecb9909faa
commit
bc58add6de
4 changed files with 15 additions and 6 deletions
|
@ -941,6 +941,7 @@ class Wallet(object):
|
||||||
bid, certificate_id, claim_address, change_address)
|
bid, certificate_id, claim_address, change_address)
|
||||||
|
|
||||||
if not claim['success']:
|
if not claim['success']:
|
||||||
|
log.error(claim)
|
||||||
msg = 'Claim to name {} failed: {}'.format(name, claim['reason'])
|
msg = 'Claim to name {} failed: {}'.format(name, claim['reason'])
|
||||||
raise Exception(msg)
|
raise Exception(msg)
|
||||||
|
|
||||||
|
@ -1312,9 +1313,14 @@ class LBRYumWallet(Wallet):
|
||||||
return defer.succeed(True)
|
return defer.succeed(True)
|
||||||
|
|
||||||
def _check_large_wallet(self):
|
def _check_large_wallet(self):
|
||||||
if len(self.wallet.addresses(include_change=False)) > 1000:
|
addr_count = len(self.wallet.addresses(include_change=False))
|
||||||
log.warning(("Your wallet is excessively large, please follow instructions here: ",
|
if addr_count > 1000:
|
||||||
"https://github.com/lbryio/lbry/issues/437 to reduce your wallet size"))
|
log.warning("Your wallet is excessively large (%i addresses), "
|
||||||
|
"please follow instructions here: "
|
||||||
|
"https://github.com/lbryio/lbry/issues/437 to reduce your wallet size",
|
||||||
|
addr_count)
|
||||||
|
else:
|
||||||
|
log.info("Wallet has %i addresses", addr_count)
|
||||||
|
|
||||||
def _load_blockchain(self):
|
def _load_blockchain(self):
|
||||||
blockchain_caught_d = defer.Deferred()
|
blockchain_caught_d = defer.Deferred()
|
||||||
|
|
|
@ -154,7 +154,8 @@ class FullStreamProgressManager(StreamProgressManager):
|
||||||
d.addCallback(lambda _: check_if_finished())
|
d.addCallback(lambda _: check_if_finished())
|
||||||
|
|
||||||
def log_error(err):
|
def log_error(err):
|
||||||
log.warning("Error occurred in the output loop. Error: %s", err)
|
log.warning("Error outputting blob %s: %s", blobs[current_blob_num].blob_hash,
|
||||||
|
err.getErrorMessage())
|
||||||
if self.outputting_d is not None and not self.outputting_d.called:
|
if self.outputting_d is not None and not self.outputting_d.called:
|
||||||
self.outputting_d.callback(True)
|
self.outputting_d.callback(True)
|
||||||
self.outputting_d = None
|
self.outputting_d = None
|
||||||
|
|
|
@ -514,7 +514,7 @@ class Daemon(AuthJSONRPCServer):
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def _setup_lbry_file_manager(self):
|
def _setup_lbry_file_manager(self):
|
||||||
log.info('Starting to setup up file manager')
|
log.info('Starting the file manager')
|
||||||
self.startup_status = STARTUP_STAGES[3]
|
self.startup_status = STARTUP_STAGES[3]
|
||||||
self.stream_info_manager = DBEncryptedFileMetadataManager(self.db_dir)
|
self.stream_info_manager = DBEncryptedFileMetadataManager(self.db_dir)
|
||||||
self.lbry_file_manager = EncryptedFileManager(
|
self.lbry_file_manager = EncryptedFileManager(
|
||||||
|
@ -2041,6 +2041,8 @@ class Daemon(AuthJSONRPCServer):
|
||||||
'claim_address': claim_address,
|
'claim_address': claim_address,
|
||||||
'change_address': change_address,
|
'change_address': change_address,
|
||||||
'claim_dict': claim_dict,
|
'claim_dict': claim_dict,
|
||||||
|
'channel_id': channel_id,
|
||||||
|
'channel_name': channel_name
|
||||||
})
|
})
|
||||||
|
|
||||||
if channel_id:
|
if channel_id:
|
||||||
|
|
|
@ -27,7 +27,7 @@ def log_status(sd_hash, status):
|
||||||
status_string = "finished"
|
status_string = "finished"
|
||||||
else:
|
else:
|
||||||
status_string = "unknown"
|
status_string = "unknown"
|
||||||
log.info("stream %s is %s", short_hash(sd_hash), status_string)
|
log.debug("stream %s is %s", short_hash(sd_hash), status_string)
|
||||||
|
|
||||||
|
|
||||||
class ManagedEncryptedFileDownloader(EncryptedFileSaver):
|
class ManagedEncryptedFileDownloader(EncryptedFileSaver):
|
||||||
|
|
Loading…
Add table
Reference in a new issue