mirror of
https://github.com/LBRYFoundation/LBRY-Vault.git
synced 2025-08-30 17:01:34 +00:00
follow-up dd0be1541e
This commit is contained in:
parent
2a604b1676
commit
5377eb907c
2 changed files with 3 additions and 3 deletions
|
@ -387,7 +387,7 @@ class ChannelDB(SqlDB):
|
||||||
# the update may be categorized as deprecated because of caching
|
# the update may be categorized as deprecated because of caching
|
||||||
categorized_chan_upds = self.add_channel_updates([payload], verify=False)
|
categorized_chan_upds = self.add_channel_updates([payload], verify=False)
|
||||||
|
|
||||||
def handle_error_code_from_failed_htlc(self, code, data, sender_idx, route):
|
def handle_error_code_from_failed_htlc(self, code, data, sender_idx, route, peer):
|
||||||
# handle some specific error codes
|
# handle some specific error codes
|
||||||
failure_codes = {
|
failure_codes = {
|
||||||
OnionFailureCode.TEMPORARY_CHANNEL_FAILURE: 0,
|
OnionFailureCode.TEMPORARY_CHANNEL_FAILURE: 0,
|
||||||
|
@ -414,7 +414,7 @@ class ChannelDB(SqlDB):
|
||||||
blacklist = False
|
blacklist = False
|
||||||
if categorized_chan_upds.good:
|
if categorized_chan_upds.good:
|
||||||
self.logger.info("applied channel update on our db")
|
self.logger.info("applied channel update on our db")
|
||||||
#self.maybe_save_remote_update(payload)
|
peer.maybe_save_remote_update(payload)
|
||||||
elif categorized_chan_upds.orphaned:
|
elif categorized_chan_upds.orphaned:
|
||||||
# maybe it is a private channel (and data in invoice was outdated)
|
# maybe it is a private channel (and data in invoice was outdated)
|
||||||
self.logger.info("maybe channel update is for private channel?")
|
self.logger.info("maybe channel update is for private channel?")
|
||||||
|
|
|
@ -891,7 +891,7 @@ class LNWallet(LNWorker):
|
||||||
code, data = failure_msg.code, failure_msg.data
|
code, data = failure_msg.code, failure_msg.data
|
||||||
self.logger.info(f"UPDATE_FAIL_HTLC {repr(code)} {data}")
|
self.logger.info(f"UPDATE_FAIL_HTLC {repr(code)} {data}")
|
||||||
self.logger.info(f"error reported by {bh2u(route[sender_idx].node_id)}")
|
self.logger.info(f"error reported by {bh2u(route[sender_idx].node_id)}")
|
||||||
self.channel_db.handle_error_code_from_failed_htlc(code, data, sender_idx, route)
|
self.channel_db.handle_error_code_from_failed_htlc(code, data, sender_idx, route, peer)
|
||||||
return success, preimage, failure_node_id, failure_msg
|
return success, preimage, failure_node_id, failure_msg
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
|
|
Loading…
Add table
Reference in a new issue