mirror of
https://github.com/varun-r-mallya/py-libp2p.git
synced 2026-02-12 16:10:57 +00:00
fix: update logging messages
This commit is contained in:
@ -40,7 +40,7 @@ async def run(port: int) -> None:
|
|||||||
print(
|
print(
|
||||||
"Run this from the same folder in another console to "
|
"Run this from the same folder in another console to "
|
||||||
"start another peer on a different port:\n\n"
|
"start another peer on a different port:\n\n"
|
||||||
"python mdns-demo -p <ANOTHER_PORT>\n"
|
"mdns-demo -p <ANOTHER_PORT>\n"
|
||||||
)
|
)
|
||||||
print("Waiting for mDNS peer discovery events...\n")
|
print("Waiting for mDNS peer discovery events...\n")
|
||||||
|
|
||||||
|
|||||||
@ -60,7 +60,7 @@ class PeerBroadcaster:
|
|||||||
"""Register the peer's mDNS service on the network."""
|
"""Register the peer's mDNS service on the network."""
|
||||||
try:
|
try:
|
||||||
self.zeroconf.register_service(self.service_info)
|
self.zeroconf.register_service(self.service_info)
|
||||||
logger.debug("mDNS service registered: %s", self.service_name)
|
logger.debug(f"mDNS service registered: {self.service_name}")
|
||||||
except EventLoopBlocked as e:
|
except EventLoopBlocked as e:
|
||||||
logger.warning(
|
logger.warning(
|
||||||
"EventLoopBlocked while registering mDNS '%s': %s", self.service_name, e
|
"EventLoopBlocked while registering mDNS '%s': %s", self.service_name, e
|
||||||
@ -76,7 +76,7 @@ class PeerBroadcaster:
|
|||||||
"""Unregister the peer's mDNS service from the network."""
|
"""Unregister the peer's mDNS service from the network."""
|
||||||
try:
|
try:
|
||||||
self.zeroconf.unregister_service(self.service_info)
|
self.zeroconf.unregister_service(self.service_info)
|
||||||
logger.debug("mDNS service unregistered: %s", self.service_name)
|
logger.debug(f"mDNS service unregistered: {self.service_name}")
|
||||||
except EventLoopBlocked as e:
|
except EventLoopBlocked as e:
|
||||||
logger.warning(
|
logger.warning(
|
||||||
"EventLoopBlocked while unregistering mDNS '%s': %s",
|
"EventLoopBlocked while unregistering mDNS '%s': %s",
|
||||||
|
|||||||
@ -63,7 +63,7 @@ class PeerListener(ServiceListener):
|
|||||||
if peer_info:
|
if peer_info:
|
||||||
self.peerstore.clear_addrs(peer_info.peer_id)
|
self.peerstore.clear_addrs(peer_info.peer_id)
|
||||||
self.peerstore.add_addrs(peer_info.peer_id, peer_info.addrs, 10)
|
self.peerstore.add_addrs(peer_info.peer_id, peer_info.addrs, 10)
|
||||||
logger.debug("Updated Peer", peer_info.peer_id)
|
logger.debug(f"Updated Peer {peer_info.peer_id}")
|
||||||
|
|
||||||
def _extract_peer_info(self, info: ServiceInfo) -> PeerInfo | None:
|
def _extract_peer_info(self, info: ServiceInfo) -> PeerInfo | None:
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user