Server listening (#516)
* + server_listening Event in Controller (to know when server has fully started)
This commit is contained in:
parent
f8ebcf35b4
commit
71b3d30842
@ -102,6 +102,9 @@ class Controller(ServerBase):
|
|||||||
self.mempool = MemPool(self.bp, self)
|
self.mempool = MemPool(self.bp, self)
|
||||||
self.peer_mgr = PeerManager(env, self)
|
self.peer_mgr = PeerManager(env, self)
|
||||||
|
|
||||||
|
# Event triggered when electrumx is listening for incoming requests.
|
||||||
|
self.server_listening = asyncio.Event()
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def short_version(cls):
|
def short_version(cls):
|
||||||
'''Return e.g. "1.2" for ElectrumX 1.2'''
|
'''Return e.g. "1.2" for ElectrumX 1.2'''
|
||||||
@ -292,6 +295,7 @@ class Controller(ServerBase):
|
|||||||
sslc = ssl.SSLContext(ssl.PROTOCOL_TLS)
|
sslc = ssl.SSLContext(ssl.PROTOCOL_TLS)
|
||||||
sslc.load_cert_chain(env.ssl_certfile, keyfile=env.ssl_keyfile)
|
sslc.load_cert_chain(env.ssl_certfile, keyfile=env.ssl_keyfile)
|
||||||
await self.start_server('SSL', host, env.ssl_port, ssl=sslc)
|
await self.start_server('SSL', host, env.ssl_port, ssl=sslc)
|
||||||
|
self.server_listening.set()
|
||||||
|
|
||||||
def notify_sessions(self, touched):
|
def notify_sessions(self, touched):
|
||||||
'''Notify sessions about height changes and touched addresses.'''
|
'''Notify sessions about height changes and touched addresses.'''
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user