| 438 | |
| 439 | # Peer |
| 440 | def peerPing(self, peer_ip, peer_port=None): |
| 441 | if not peer_port: |
| 442 | peer_port = 15441 |
| 443 | logging.info("Opening a simple connection server") |
| 444 | global file_server |
| 445 | from Connection import ConnectionServer |
| 446 | file_server = ConnectionServer("127.0.0.1", 1234) |
| 447 | file_server.start(check_connections=False) |
| 448 | from Crypt import CryptConnection |
| 449 | CryptConnection.manager.loadCerts() |
| 450 | |
| 451 | from Peer import Peer |
| 452 | logging.info("Pinging 5 times peer: %s:%s..." % (peer_ip, int(peer_port))) |
| 453 | s = time.time() |
| 454 | peer = Peer(peer_ip, peer_port) |
| 455 | peer.connect() |
| 456 | |
| 457 | if not peer.connection: |
| 458 | print("Error: Can't connect to peer (connection error: %s)" % peer.connection_error) |
| 459 | return False |
| 460 | if "shared_ciphers" in dir(peer.connection.sock): |
| 461 | print("Shared ciphers:", peer.connection.sock.shared_ciphers()) |
| 462 | if "cipher" in dir(peer.connection.sock): |
| 463 | print("Cipher:", peer.connection.sock.cipher()[0]) |
| 464 | if "version" in dir(peer.connection.sock): |
| 465 | print("TLS version:", peer.connection.sock.version()) |
| 466 | print("Connection time: %.3fs (connection error: %s)" % (time.time() - s, peer.connection_error)) |
| 467 | |
| 468 | for i in range(5): |
| 469 | ping_delay = peer.ping() |
| 470 | print("Response time: %.3fs" % ping_delay) |
| 471 | time.sleep(1) |
| 472 | peer.remove() |
| 473 | print("Reconnect test...") |
| 474 | peer = Peer(peer_ip, peer_port) |
| 475 | for i in range(5): |
| 476 | ping_delay = peer.ping() |
| 477 | print("Response time: %.3fs" % ping_delay) |
| 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") |