diff options
Diffstat (limited to 'src/network.rs')
| -rw-r--r-- | src/network.rs | 38 |
1 files changed, 33 insertions, 5 deletions
diff --git a/src/network.rs b/src/network.rs index f9b6355..753f743 100644 --- a/src/network.rs +++ b/src/network.rs @@ -107,10 +107,11 @@ impl Network { let peer = Arc::new(Mutex::new(Peer::new(this.clone(), stream))); if let Some(parent) = this.upgrade() { - let mut net = parent + let mut parent = parent .lock() .await; - net.peers + parent + .peers .push(Arc::clone(&peer)); } @@ -130,10 +131,29 @@ impl Network { .clone(); spawn(async move { if let Some(parent) = this.upgrade() { - let mut net = parent + let mut parent = parent + .lock() + .await; + parent + .try_peer() + .await; + } + }); + + self.get_idb() + } + + pub fn get_idb(&self) { + let this = self + .this + .clone(); + spawn(async move { + if let Some(parent) = this.upgrade() { + let mut parent = parent .lock() .await; - net.try_peer() + parent + .broadcast(Request::Ibd(None)) .await; } }); @@ -177,7 +197,15 @@ impl Peer { } } - async fn start(&mut self) {} + async fn start(&mut self) { + let mut sink = self + .sink + .lock() + .await; + let _ = sink + .send(Request::Ibd(None)) + .await; + } async fn read_loop(parent: Weak<Mutex<Network>>, mut stream: SplitStream<Framed<TokioFramed<TcpStream, LengthDelimitedCodec>, Request, Request, Json<Request, Request>>>) { loop { |