tAdd placeholder for signalling when server is stopped. - obelisk - Electrum server using libbitcoin as its backend
HTML git clone https://git.parazyd.org/obelisk
DIR Log
DIR Files
DIR Refs
DIR README
DIR LICENSE
---
DIR commit e0fd14b6b5a9282c25a2c790793f9e70b2844a33
DIR parent 614407fd1362c82a2af813a48ebbdecd4670838e
HTML Author: parazyd <parazyd@dyne.org>
Date: Fri, 9 Apr 2021 00:10:14 +0200
Add placeholder for signalling when server is stopped.
Diffstat:
M electrumobelisk/protocol.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
---
DIR diff --git a/electrumobelisk/protocol.py b/electrumobelisk/protocol.py
t@@ -54,6 +54,7 @@ class ElectrumProtocol(asyncio.Protocol): # pylint: disable=R0904,R0902
"""Class implementing the Electrum protocol, with async support"""
def __init__(self, log, chain, endpoints, server_cfg):
self.log = log
+ self.stopped = False
self.endpoints = endpoints
self.server_cfg = server_cfg
self.loop = asyncio.get_event_loop()
t@@ -115,11 +116,12 @@ class ElectrumProtocol(asyncio.Protocol): # pylint: disable=R0904,R0902
self.log.debug("ElectrumProtocol.stop()")
if self.bx:
await self.bx.stop()
+ self.stopped = True
async def recv(self, reader, writer):
"""Loop ran upon a connection which acts as a JSON-RPC handler"""
recv_buf = bytearray()
- while True:
+ while not self.stopped:
data = await reader.read(4096)
if not data or len(data) == 0:
self.log.debug("Received EOF, disconnect")