blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

NodeServices: de-pub, remove dead code

This commit is contained in:
Michael Vines 2019-02-06 20:45:26 -08:00
parent c87e035302
commit f0843fc5f1
1 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/fullnode.rs
View File

@ -29,11 +29,11 @@ use std::thread::{spawn, Result};
use std::time::{Duration, Instant}; use std::time::{Duration, Instant};
pub type TvuRotationSender = Sender<TvuReturnType>; pub type TvuRotationSender = Sender<TvuReturnType>;
pub type TvuRotationReceiver = Receiver<TvuReturnType>;
pub type TpuRotationSender = Sender<TpuReturnType>; pub type TpuRotationSender = Sender<TpuReturnType>;
pub type TpuRotationReceiver = Receiver<TpuReturnType>; type TvuRotationReceiver = Receiver<TvuReturnType>;
type TpuRotationReceiver = Receiver<TpuReturnType>;
pub struct NodeServices { struct NodeServices {
tpu: Tpu, tpu: Tpu,
tvu: Tvu, tvu: Tvu,
} }
@ -43,18 +43,14 @@ impl NodeServices {
NodeServices { tpu, tvu } NodeServices { tpu, tvu }
} }
pub fn join(self) -> Result<()> { fn join(self) -> Result<()> {
self.tpu.join()?; self.tpu.join()?;
//tvu will never stop unless exit is signaled //tvu will never stop unless exit is signaled
self.tvu.join()?; self.tvu.join()?;
Ok(()) Ok(())
} }
pub fn is_exited(&self) -> bool { fn exit(&self) {
self.tpu.is_exited() && self.tvu.is_exited()
}
pub fn exit(&self) {
self.tpu.exit(); self.tpu.exit();
self.tvu.exit(); self.tvu.exit();
} }