main
This commit is contained in:
parent
878d88836d
commit
125f23792f
@ -10,7 +10,7 @@ use tokio::sync::oneshot;
|
|||||||
async fn main() {
|
async fn main() {
|
||||||
let _guard = log::init_log();
|
let _guard = log::init_log();
|
||||||
|
|
||||||
// let (tx, rx) = oneshot::channel();
|
let (tx, rx) = oneshot::channel();
|
||||||
let _ = run_sdlan(
|
let _ = run_sdlan(
|
||||||
CommandLine {
|
CommandLine {
|
||||||
sn: "39.98.184.67:1265".to_owned(),
|
sn: "39.98.184.67:1265".to_owned(),
|
||||||
@ -24,9 +24,10 @@ async fn main() {
|
|||||||
tos: 0,
|
tos: 0,
|
||||||
token: "".to_owned(),
|
token: "".to_owned(),
|
||||||
allow_p2p: true,
|
allow_p2p: true,
|
||||||
},
|
}, tx,
|
||||||
).await;
|
).await;
|
||||||
|
|
||||||
|
rx.await;
|
||||||
|
|
||||||
let edge = get_edge();
|
let edge = get_edge();
|
||||||
edge.start("0".to_owned()).await;
|
edge.start("0".to_owned()).await;
|
||||||
|
|||||||
@ -22,7 +22,7 @@ use sdlan_sn_rs::{
|
|||||||
|
|
||||||
pub async fn run_sdlan(
|
pub async fn run_sdlan(
|
||||||
args: CommandLine,
|
args: CommandLine,
|
||||||
// sender: tokio::sync::oneshot::Sender<bool>,
|
sender: tokio::sync::oneshot::Sender<bool>,
|
||||||
// start_stop_sender: Sender<String>,
|
// start_stop_sender: Sender<String>,
|
||||||
// start_stop_receiver: Receiver<String>,
|
// start_stop_receiver: Receiver<String>,
|
||||||
) -> Result<()> {
|
) -> 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 {
|
if let Err(e) = init_edge(&args.token, node_conf, args.tos, start_stop_sender).await {
|
||||||
panic!("failed to init edge: {:?}", e);
|
panic!("failed to init edge: {:?}", e);
|
||||||
}
|
}
|
||||||
// let _ = sender.send(true);
|
let _ = sender.send(true);
|
||||||
debug!("edge inited");
|
debug!("edge inited");
|
||||||
|
|
||||||
let cancel = CancellationToken::new();
|
let cancel = CancellationToken::new();
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user