- imei, msg = clients.recv(sk)
- zpub.send(Bcast(imei, msg).as_bytes)
- if msg is None or isinstance(msg, HIBERNATION):
- log.debug("HIBERNATION from fd %d", sk)
- tostop.append(sk)
+ for imei, msg in clients.recv(sk):
+ zpub.send(Bcast(imei, msg).as_bytes)
+ if msg is None or isinstance(msg, HIBERNATION):
+ log.debug("HIBERNATION from fd %d", sk)
+ tostop.append(sk)