diff options
author | HimbeerserverDE <himbeerserverde@gmail.com> | 2022-11-11 17:19:41 +0100 |
---|---|---|
committer | HimbeerserverDE <himbeerserverde@gmail.com> | 2022-11-11 17:19:41 +0100 |
commit | 5089a2eb093d9c67b3261d54811e598696c6eb88 (patch) | |
tree | ff7be5e5e1477962d44f6281153e9b9a4e02727d | |
parent | c2ccb18465a5fe57d4058c249f208ac9ee618d06 (diff) |
use unreachable! macro
-rw-r--r-- | src/main.rs | 96 |
1 files changed, 48 insertions, 48 deletions
diff --git a/src/main.rs b/src/main.rs index 35a89cf..73952e1 100644 --- a/src/main.rs +++ b/src/main.rs @@ -162,28 +162,28 @@ fn main() -> Result<()> { let ipv4_1 = ipv4.clone(); let ipv4_2 = ipv4.clone(); - thread::spawn(move || { - loop { - match push_addr4(ipv4_1.clone(), &rx) { - Ok(_) => { /* unreachable */ } - Err(e) => eprintln!("failed to push ipv4 address: {}", e), + thread::spawn(move || loop { + match push_addr4(ipv4_1.clone(), &rx) { + Ok(_) => { + unreachable!() } - - let secs = ipv4_1.retry.unwrap_or(ipv4_1.interval); - thread::sleep(Duration::from_secs(secs)); + Err(e) => eprintln!("failed to push ipv4 address: {}", e), } + + let secs = ipv4_1.retry.unwrap_or(ipv4_1.interval); + thread::sleep(Duration::from_secs(secs)); }); - thread::spawn(move || { - loop { - match monitor_addr4(ipv4_2.clone(), tx.clone()) { - Ok(_) => { /* unreachable */ } - Err(e) => eprintln!("failed to monitor ipv4 address: {}", e), + thread::spawn(move || loop { + match monitor_addr4(ipv4_2.clone(), tx.clone()) { + Ok(_) => { + unreachable!() } - - let secs = ipv4_2.retry.unwrap_or(ipv4_2.interval); - thread::sleep(Duration::from_secs(secs)); + Err(e) => eprintln!("failed to monitor ipv4 address: {}", e), } + + let secs = ipv4_2.retry.unwrap_or(ipv4_2.interval); + thread::sleep(Duration::from_secs(secs)); }); } @@ -193,28 +193,28 @@ fn main() -> Result<()> { let ipv6_1 = ipv6.clone(); let ipv6_2 = ipv6.clone(); - thread::spawn(move || { - loop { - match push_addr6(ipv6_1.clone(), &rx) { - Ok(_) => { /* unreachable */ } - Err(e) => eprintln!("failed to push ipv6 address: {}", e), + thread::spawn(move || loop { + match push_addr6(ipv6_1.clone(), &rx) { + Ok(_) => { + unreachable!() } - - let secs = ipv6_1.retry.unwrap_or(ipv6_1.interval); - thread::sleep(Duration::from_secs(secs)); + Err(e) => eprintln!("failed to push ipv6 address: {}", e), } + + let secs = ipv6_1.retry.unwrap_or(ipv6_1.interval); + thread::sleep(Duration::from_secs(secs)); }); - thread::spawn(move || { - loop { - match monitor_addr6(ipv6_2.clone(), tx.clone()) { - Ok(_) => { /* unreachable */ } - Err(e) => eprintln!("failed to monitor ipv6 address: {}", e), + thread::spawn(move || loop { + match monitor_addr6(ipv6_2.clone(), tx.clone()) { + Ok(_) => { + unreachable!() } - - let secs = ipv6_2.retry.unwrap_or(ipv6_2.interval); - thread::sleep(Duration::from_secs(secs)); + Err(e) => eprintln!("failed to monitor ipv6 address: {}", e), } + + let secs = ipv6_2.retry.unwrap_or(ipv6_2.interval); + thread::sleep(Duration::from_secs(secs)); }); } @@ -224,28 +224,28 @@ fn main() -> Result<()> { let net6_1 = net6.clone(); let net6_2 = net6.clone(); - thread::spawn(move || { - loop { - match push_net6(net6_1.clone(), &rx) { - Ok(_) => { /* unreachable */ } - Err(e) => eprintln!("failed to push ipv6 prefix: {}", e), + thread::spawn(move || loop { + match push_net6(net6_1.clone(), &rx) { + Ok(_) => { + unreachable!() } - - let secs = net6_1.retry.unwrap_or(net6_1.interval); - thread::sleep(Duration::from_secs(secs)); + Err(e) => eprintln!("failed to push ipv6 prefix: {}", e), } + + let secs = net6_1.retry.unwrap_or(net6_1.interval); + thread::sleep(Duration::from_secs(secs)); }); - thread::spawn(move || { - loop { - match monitor_net6(net6_2.clone(), tx.clone()) { - Ok(_) => { /* unreachable */ } - Err(e) => eprintln!("failed to monitor ipv6 prefix: {}", e), + thread::spawn(move || loop { + match monitor_net6(net6_2.clone(), tx.clone()) { + Ok(_) => { + unreachable!() } - - let secs = net6_2.retry.unwrap_or(net6_2.interval); - thread::sleep(Duration::from_secs(secs)); + Err(e) => eprintln!("failed to monitor ipv6 prefix: {}", e), } + + let secs = net6_2.retry.unwrap_or(net6_2.interval); + thread::sleep(Duration::from_secs(secs)); }); } |