LBRYCommunity/aioupnp
1
0
Fork 0
Code Issues 7 Pull requests 1 Projects Releases 1 Packages Wiki Activity

logging

Browse source
This commit is contained in:
Jack Robison 2018-10-08 17:44:02 -04:00
parent c0ef4337fa
commit e6fbab30aa
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
aioupnp/protocols/ssdp.py
View file

@ -31,6 +31,7 @@ class SSDPProtocol(MulticastProtocol):
SSDPDatagram._M_SEARCH, host="{}:{}".format(SSDP_IP_ADDRESS, SSDP_PORT), st=service, man=SSDP_DISCOVER, SSDPDatagram._M_SEARCH, host="{}:{}".format(SSDP_IP_ADDRESS, SSDP_PORT), st=service, man=SSDP_DISCOVER,
mx=1 mx=1
) )
log.debug("sending packet to %s:%i: %s", address, SSDP_PORT, packet)
self.transport.sendto(packet.encode().encode(), (address, SSDP_PORT)) self.transport.sendto(packet.encode().encode(), (address, SSDP_PORT))
f: Future = Future() f: Future = Future()
self.discover_callbacks[(address, service)] = f self.discover_callbacks[(address, service)] = f
@ -41,15 +42,15 @@ class SSDPProtocol(MulticastProtocol):
return return
try: try:
packet = SSDPDatagram.decode(data) packet = SSDPDatagram.decode(data)
log.debug("decoded %s from %s:%i:\n%s", packet.get_friendly_name(), addr[0], addr[1], packet.encode()) log.debug("decoded packet from %s:%i: %s", addr[0], addr[1], packet)
except UPnPError as err: except UPnPError as err:
log.error("failed to decode SSDP packet from %s:%i: %s\npacket: %s", addr[0], addr[1], err, log.error("failed to decode SSDP packet from %s:%i (%s): %s", addr[0], addr[1], err,
binascii.hexlify(data)) binascii.hexlify(data))
return return
if packet._packet_type == packet._OK: if packet._packet_type == packet._OK:
log.debug("%s:%i sent us an OK", addr[0], addr[1])
if (addr[0], packet.st) in self.discover_callbacks: if (addr[0], packet.st) in self.discover_callbacks:
log.debug("%s:%i replied to our m-search", addr[0], addr[1])
if packet.st not in map(lambda p: p['st'], self.replies): if packet.st not in map(lambda p: p['st'], self.replies):
self.replies.append(packet) self.replies.append(packet)
ok_fut: Future = self.discover_callbacks.pop((addr[0], packet.st)) ok_fut: Future = self.discover_callbacks.pop((addr[0], packet.st))