-__-
parent
93970e3ed4
commit
c90e1938ef
|
|
@ -337,25 +337,22 @@ async fn service_handler(name: &str, services: &Vec<Services>, tx: mpsc::Sender<
|
||||||
println!("Service {}:{} is unreachable for process {}", &serv.hostname, &serv.port, &name);
|
println!("Service {}:{} is unreachable for process {}", &serv.hostname, &serv.port, &name);
|
||||||
match serv.triggers.on_lost.as_str() {
|
match serv.triggers.on_lost.as_str() {
|
||||||
"stay" => {
|
"stay" => {
|
||||||
println!("1");
|
|
||||||
},
|
},
|
||||||
"stop" => {
|
"stop" => {
|
||||||
println!("2");
|
|
||||||
match looped_service_connecting(&name, serv).await {
|
match looped_service_connecting(&name, serv).await {
|
||||||
Ok(_) => {},
|
Ok(_) => {},
|
||||||
Err(_) => {
|
Err(_) => {
|
||||||
tx.send(5).await.unwrap();
|
tx.send(5).await.unwrap();
|
||||||
return;
|
break;
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hold" => {
|
"hold" => {
|
||||||
println!("3");
|
|
||||||
match looped_service_connecting(&name, serv).await {
|
match looped_service_connecting(&name, serv).await {
|
||||||
Ok(_) => {},
|
Ok(_) => {},
|
||||||
Err(_) => {
|
Err(_) => {
|
||||||
tx.send(6).await.unwrap();
|
tx.send(6).await.unwrap();
|
||||||
return;
|
break;
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue