Lines Matching refs:Peer
38 from ..objects import peer
49 return [ peer.Peer.Unpack(p) for p in data ]
143 # Spawn one thread for each peer.
170 def _TalkToPeer(self, peer):
173 code = sock.connect_ex((peer.address, constants.PEER_PORT))
176 peer.runtime = None
178 packet = workpacket.WorkPacket(peer=peer, context=self.context,
191 # The peer is reporting an error.
193 print("\nPeer %s reports error: %s" % (peer.address, data[1]))
219 peer.runtime = time.time() - start_time
227 compression.Send([constants.UNRESPONSIVE_PEER, peer.address],
