Reorder to reflect dependencies
This commit is contained in:
parent
ef6bd7e3b8
commit
2a268aa528
14
src/rpu.rs
14
src/rpu.rs
|
@ -47,14 +47,11 @@ impl Rpu {
|
||||||
exit: Arc<AtomicBool>,
|
exit: Arc<AtomicBool>,
|
||||||
writer: W,
|
writer: W,
|
||||||
) -> Result<Vec<JoinHandle<()>>> {
|
) -> Result<Vec<JoinHandle<()>>> {
|
||||||
let crdt = Arc::new(RwLock::new(Crdt::new(me)));
|
|
||||||
let t_gossip = Crdt::gossip(crdt.clone(), exit.clone());
|
|
||||||
let window = streamer::default_window();
|
|
||||||
let t_listen = Crdt::listen(crdt.clone(), window.clone(), gossip, exit.clone());
|
|
||||||
|
|
||||||
// make sure we are on the same interface
|
// make sure we are on the same interface
|
||||||
let mut local = requests_socket.local_addr()?;
|
let mut local = requests_socket.local_addr()?;
|
||||||
local.set_port(0);
|
local.set_port(0);
|
||||||
|
let broadcast_socket = UdpSocket::bind(local)?;
|
||||||
|
let respond_socket = UdpSocket::bind(local.clone())?;
|
||||||
|
|
||||||
let packet_recycler = packet::PacketRecycler::default();
|
let packet_recycler = packet::PacketRecycler::default();
|
||||||
let (packet_sender, packet_receiver) = channel();
|
let (packet_sender, packet_receiver) = channel();
|
||||||
|
@ -91,7 +88,11 @@ impl Rpu {
|
||||||
record_stage.entry_receiver,
|
record_stage.entry_receiver,
|
||||||
);
|
);
|
||||||
|
|
||||||
let broadcast_socket = UdpSocket::bind(local)?;
|
let crdt = Arc::new(RwLock::new(Crdt::new(me)));
|
||||||
|
let t_gossip = Crdt::gossip(crdt.clone(), exit.clone());
|
||||||
|
let window = streamer::default_window();
|
||||||
|
let t_listen = Crdt::listen(crdt.clone(), window.clone(), gossip, exit.clone());
|
||||||
|
|
||||||
let t_broadcast = streamer::broadcaster(
|
let t_broadcast = streamer::broadcaster(
|
||||||
broadcast_socket,
|
broadcast_socket,
|
||||||
exit.clone(),
|
exit.clone(),
|
||||||
|
@ -101,7 +102,6 @@ impl Rpu {
|
||||||
write_stage.blob_receiver,
|
write_stage.blob_receiver,
|
||||||
);
|
);
|
||||||
|
|
||||||
let respond_socket = UdpSocket::bind(local.clone())?;
|
|
||||||
let t_responder = streamer::responder(
|
let t_responder = streamer::responder(
|
||||||
respond_socket,
|
respond_socket,
|
||||||
exit.clone(),
|
exit.clone(),
|
||||||
|
|
12
src/tpu.rs
12
src/tpu.rs
|
@ -46,14 +46,10 @@ impl Tpu {
|
||||||
exit: Arc<AtomicBool>,
|
exit: Arc<AtomicBool>,
|
||||||
writer: W,
|
writer: W,
|
||||||
) -> Result<Vec<JoinHandle<()>>> {
|
) -> Result<Vec<JoinHandle<()>>> {
|
||||||
let crdt = Arc::new(RwLock::new(Crdt::new(me)));
|
|
||||||
let t_gossip = Crdt::gossip(crdt.clone(), exit.clone());
|
|
||||||
let window = streamer::default_window();
|
|
||||||
let t_listen = Crdt::listen(crdt.clone(), window.clone(), gossip, exit.clone());
|
|
||||||
|
|
||||||
// make sure we are on the same interface
|
// make sure we are on the same interface
|
||||||
let mut local = requests_socket.local_addr()?;
|
let mut local = requests_socket.local_addr()?;
|
||||||
local.set_port(0);
|
local.set_port(0);
|
||||||
|
let broadcast_socket = UdpSocket::bind(local)?;
|
||||||
|
|
||||||
let packet_recycler = packet::PacketRecycler::default();
|
let packet_recycler = packet::PacketRecycler::default();
|
||||||
let (packet_sender, packet_receiver) = channel();
|
let (packet_sender, packet_receiver) = channel();
|
||||||
|
@ -88,7 +84,11 @@ impl Tpu {
|
||||||
record_stage.entry_receiver,
|
record_stage.entry_receiver,
|
||||||
);
|
);
|
||||||
|
|
||||||
let broadcast_socket = UdpSocket::bind(local)?;
|
let crdt = Arc::new(RwLock::new(Crdt::new(me)));
|
||||||
|
let t_gossip = Crdt::gossip(crdt.clone(), exit.clone());
|
||||||
|
let window = streamer::default_window();
|
||||||
|
let t_listen = Crdt::listen(crdt.clone(), window.clone(), gossip, exit.clone());
|
||||||
|
|
||||||
let t_broadcast = streamer::broadcaster(
|
let t_broadcast = streamer::broadcaster(
|
||||||
broadcast_socket,
|
broadcast_socket,
|
||||||
exit.clone(),
|
exit.clone(),
|
||||||
|
|
Loading…
Reference in New Issue