else:
rest = b""
if rest:
- log.warning(
+ log.info(
"%d bytes in buffer on close: %s", len(rest), rest[:64].hex()
)
if isinstance(elem, bytes):
msgs.append((when, self.addr, elem))
else:
- log.warning(
+ log.info(
"%s from fd %d (IMEI %s)",
elem,
self.sock.fileno(),
zpub.send(
Bcast(
proto=proto,
+ pmod=pmod.PMODNAME,
imei=imei,
when=when,
peeraddr=peeraddr,
Bcast(
is_incoming=False,
proto=rpmod.proto_of_message(zmsg.packet),
- when=zmsg.when,
+ pmod=pmod.PMODNAME,
imei=zmsg.imei,
+ when=zmsg.when,
packet=zmsg.packet,
).packed
)