AaronFiore/electrum
1
0
Fork 0
Code Activity

fix race in NetworkJobOnDefaultServer constructors

Browse Source
This commit is contained in:
ThomasV
2019-12-06 20:17:52 +01:00
parent 61aebd0f2d
commit 2e4cfd0744
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
electrum/lnverifier.py
View File

@@ -53,12 +53,12 @@ class LNChannelVerifier(NetworkJobOnDefaultServer):
# spread it over multiple servers. # spread it over multiple servers.
def __init__(self, network: 'Network', channel_db: 'ChannelDB'): def __init__(self, network: 'Network', channel_db: 'ChannelDB'):
NetworkJobOnDefaultServer.__init__(self, network)
self.channel_db = channel_db self.channel_db = channel_db
self.lock = threading.Lock() self.lock = threading.Lock()
self.unverified_channel_info = {} # type: Dict[ShortChannelID, dict] # scid -> msg_payload self.unverified_channel_info = {} # type: Dict[ShortChannelID, dict] # scid -> msg_payload
# channel announcements that seem to be invalid: # channel announcements that seem to be invalid:
self.blacklist = set() # type: Set[ShortChannelID] self.blacklist = set() # type: Set[ShortChannelID]
NetworkJobOnDefaultServer.__init__(self, network)
def _reset(self): def _reset(self):
super()._reset() super()._reset()

2
electrum/synchronizer.py
View File

@@ -60,8 +60,8 @@ class SynchronizerBase(NetworkJobOnDefaultServer):
""" """
def __init__(self, network: 'Network'): def __init__(self, network: 'Network'):
self.asyncio_loop = network.asyncio_loop self.asyncio_loop = network.asyncio_loop
NetworkJobOnDefaultServer.__init__(self, network)
self._reset_request_counters() self._reset_request_counters()
NetworkJobOnDefaultServer.__init__(self, network)
def _reset(self): def _reset(self):
super()._reset() super()._reset()