Edit TestNode port logic to be consistent with new_leader (fixes hanging test_send_airdrop)

This commit is contained in:
Tyera Eulberg 2018-06-21 23:10:45 -06:00 committed by Greg Fitzgerald
parent f6bcadb79d
commit 90628f3c8d
1 changed files with 12 additions and 5 deletions

View File

@ -784,14 +784,21 @@ pub struct TestNode {
impl TestNode {
pub fn new() -> TestNode {
let gossip = UdpSocket::bind("0.0.0.0:0").unwrap();
let gossip_send = UdpSocket::bind("0.0.0.0:0").unwrap();
let requests = UdpSocket::bind("0.0.0.0:0").unwrap();
let transaction = UdpSocket::bind("0.0.0.0:0").unwrap();
let replicate = UdpSocket::bind("0.0.0.0:0").unwrap();
let mut addr = transaction.local_addr().unwrap();
let port = addr.port();
addr.set_port(port + 1);
let gossip = UdpSocket::bind(addr.clone()).unwrap();
addr.set_port(port + 2);
let replicate = UdpSocket::bind(addr.clone()).unwrap();
addr.set_port(port + 3);
let requests = UdpSocket::bind(addr.clone()).unwrap();
addr.set_port(port + 4);
let repair = UdpSocket::bind(addr.clone()).unwrap();
let gossip_send = UdpSocket::bind("0.0.0.0:0").unwrap();
let respond = UdpSocket::bind("0.0.0.0:0").unwrap();
let broadcast = UdpSocket::bind("0.0.0.0:0").unwrap();
let repair = UdpSocket::bind("0.0.0.0:0").unwrap();
let retransmit = UdpSocket::bind("0.0.0.0:0").unwrap();
let pubkey = KeyPair::new().pubkey();
let data = ReplicatedData::new(