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