Add IPv6 support to StatusServer and related classes. #119
1 changed files with 8 additions and 8 deletions
|
@ -244,8 +244,8 @@ class StatusServer:
|
||||||
self._protocols.append(proto)
|
self._protocols.append(proto)
|
||||||
|
|
||||||
async def stop(self):
|
async def stop(self):
|
||||||
for p in self._protocols:
|
for proto in self._protocols:
|
||||||
await p.close()
|
await proto.close()
|
||||||
self._protocols.clear()
|
self._protocols.clear()
|
||||||
|
|
||||||
@property
|
@property
|
||||||
|
@ -253,16 +253,16 @@ class StatusServer:
|
||||||
return self._protocols
|
return self._protocols
|
||||||
|
|
||||||
def set_unavailable(self):
|
def set_unavailable(self):
|
||||||
for p in self._protocols:
|
for proto in self._protocols:
|
||||||
p.set_unavailable()
|
proto.set_unavailable()
|
||||||
|
|
||||||
def set_available(self):
|
def set_available(self):
|
||||||
for p in self._protocols:
|
for proto in self._protocols:
|
||||||
p.set_available()
|
proto.set_available()
|
||||||
|
|
||||||
def set_height(self, height: int, tip: bytes):
|
def set_height(self, height: int, tip: bytes):
|
||||||
for p in self._protocols:
|
for proto in self._protocols:
|
||||||
p.set_height(height, tip)
|
proto.set_height(height, tip)
|
||||||
|
|
||||||
|
|
||||||
class SPVStatusClientProtocol(asyncio.DatagramProtocol):
|
class SPVStatusClientProtocol(asyncio.DatagramProtocol):
|
||||||
|
|
Loading…
Reference in a new issue