Skip to content

Commit a7aa0cc

Browse files
committed
revert out-of-scope changes
1 parent 411abfe commit a7aa0cc

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

tests/connection/connection.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
1-
from yaqd_core import IsDaemon
1+
from yaqd_core import Base
22

33

4-
class ConnectionTest(IsDaemon):
4+
class ConnectionTest(Base):
55
_kind = "connection-test"
66

77
def echo(self, s: str):

yaqd-core/yaqd_core/_protocol.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@ def __init__(self, daemon, *args, **kwargs):
1717

1818
def connection_lost(self, exc):
1919
peername = self.transport.get_extra_info("peername")
20-
self.logger.info(f"Connection lost from {peername}")
20+
self.logger.info(f"Connection lost from {peername} to {self._daemon.name}")
2121
self.task.cancel()
2222
self._daemon._connection_lost(peername)
2323

2424
def connection_made(self, transport):
2525
"""Process an incomming connection."""
2626
peername = transport.get_extra_info("peername")
27-
self.logger.info(f"Connection made from {peername}")
27+
self.logger.info(f"Connection made from {peername} to {self._daemon.name}")
2828
self.transport = transport
2929
self.unpacker = avrorpc.Unpacker(self._avro_protocol)
3030
self._daemon._connection_made(peername)

0 commit comments

Comments
 (0)