| 478 | time.sleep(1) |
| 479 | |
| 480 | def peerGetFile(self, peer_ip, peer_port, site, filename, benchmark=False): |
| 481 | logging.info("Opening a simple connection server") |
| 482 | global file_server |
| 483 | from Connection import ConnectionServer |
| 484 | file_server = ConnectionServer("127.0.0.1", 1234) |
| 485 | file_server.start(check_connections=False) |
| 486 | from Crypt import CryptConnection |
| 487 | CryptConnection.manager.loadCerts() |
| 488 | |
| 489 | from Peer import Peer |
| 490 | logging.info("Getting %s/%s from peer: %s:%s..." % (site, filename, peer_ip, peer_port)) |
| 491 | peer = Peer(peer_ip, peer_port) |
| 492 | s = time.time() |
| 493 | if benchmark: |
| 494 | for i in range(10): |
| 495 | peer.getFile(site, filename), |
| 496 | print("Response time: %.3fs" % (time.time() - s)) |
| 497 | input("Check memory") |
| 498 | else: |
| 499 | print(peer.getFile(site, filename).read()) |
| 500 | |
| 501 | def peerCmd(self, peer_ip, peer_port, cmd, parameters): |
| 502 | logging.info("Opening a simple connection server") |