Reset bad TestNode edit
This commit is contained in:
committed by
Greg Fitzgerald
parent
c7ce454188
commit
45b2549fa9
15
src/crdt.rs
15
src/crdt.rs
@ -785,17 +785,10 @@ pub struct TestNode {
|
||||
impl TestNode {
|
||||
pub fn new() -> TestNode {
|
||||
let transaction = 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 = UdpSocket::bind("0.0.0.0:0").unwrap();
|
||||
let replicate = UdpSocket::bind("0.0.0.0:0").unwrap();
|
||||
let requests = UdpSocket::bind("0.0.0.0:0").unwrap();
|
||||
let repair = UdpSocket::bind("0.0.0.0:0").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();
|
||||
|
Reference in New Issue
Block a user