AaronFiore/electrum
1
0
Fork 0
Code Activity

daemon: (trivial) subservices log when they start listening

Browse Source
This commit is contained in:
SomberNight
2021-11-15 17:43:34 +01:00
parent 2f2821f9ee
commit 62e1d8ed78
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
electrum/daemon.py
View File

@@ -277,6 +277,7 @@ class CommandsServer(AuthenticatedServer):
raise Exception(f"impossible socktype ({self.socktype!r})") raise Exception(f"impossible socktype ({self.socktype!r})")
os.write(self.fd, bytes(repr((self.socktype, addr, time.time())), 'utf8')) os.write(self.fd, bytes(repr((self.socktype, addr, time.time())), 'utf8'))
os.close(self.fd) os.close(self.fd)
self.logger.info(f"now running and listening. socktype={self.socktype}, addr={addr}")
async def ping(self): async def ping(self):
return True return True
@@ -337,6 +338,7 @@ class WatchTowerServer(AuthenticatedServer):
await self.runner.setup() await self.runner.setup()
site = web.TCPSite(self.runner, host=str(self.addr.host), port=self.addr.port, ssl_context=self.config.get_ssl_context()) site = web.TCPSite(self.runner, host=str(self.addr.host), port=self.addr.port, ssl_context=self.config.get_ssl_context())
await site.start() await site.start()
self.logger.info(f"now running and listening. addr={self.addr}")
async def get_ctn(self, *args): async def get_ctn(self, *args):
return await self.lnwatcher.get_ctn(*args) return await self.lnwatcher.get_ctn(*args)
@@ -379,6 +381,7 @@ class PayServer(Logger):
await runner.setup() await runner.setup()
site = web.TCPSite(runner, host=str(self.addr.host), port=self.addr.port, ssl_context=self.config.get_ssl_context()) site = web.TCPSite(runner, host=str(self.addr.host), port=self.addr.port, ssl_context=self.config.get_ssl_context())
await site.start() await site.start()
self.logger.info(f"now running and listening. addr={self.addr}")
async def create_request(self, request): async def create_request(self, request):
params = await request.post() params = await request.post()