diff --git a/src/bin/sdlan/main.rs b/src/bin/sdlan/main.rs index 8792478..2fb3345 100644 --- a/src/bin/sdlan/main.rs +++ b/src/bin/sdlan/main.rs @@ -10,7 +10,7 @@ use tokio::sync::oneshot; async fn main() { let _guard = log::init_log(); - // let (tx, rx) = oneshot::channel(); + let (tx, rx) = oneshot::channel(); let _ = run_sdlan( CommandLine { sn: "39.98.184.67:1265".to_owned(), @@ -24,9 +24,10 @@ async fn main() { tos: 0, token: "".to_owned(), allow_p2p: true, - }, + }, tx, ).await; + rx.await; let edge = get_edge(); edge.start("0".to_owned()).await; diff --git a/src/lib.rs b/src/lib.rs index f97280f..653eb0d 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -22,7 +22,7 @@ use sdlan_sn_rs::{ pub async fn run_sdlan( args: CommandLine, - // sender: tokio::sync::oneshot::Sender, + sender: tokio::sync::oneshot::Sender, // start_stop_sender: Sender, // start_stop_receiver: Receiver, ) -> Result<()> { @@ -33,7 +33,7 @@ pub async fn run_sdlan( if let Err(e) = init_edge(&args.token, node_conf, args.tos, start_stop_sender).await { panic!("failed to init edge: {:?}", e); } - // let _ = sender.send(true); + let _ = sender.send(true); debug!("edge inited"); let cancel = CancellationToken::new();