+
+fn start_check_alive_thread() -> Arc<Mutex<std::result::Result<(), CheckError>>> {
+ let check_alive_error_mutex: Arc<Mutex<std::result::Result<(), CheckError>>> =
+ Arc::new(Mutex::new(Ok(())));
+ let check_alive_error_mutex_copy = check_alive_error_mutex.clone();
+
+ let _thread_check_alive_handle = thread::spawn(move || {
+ let socket = UdpSocket::bind("0.0.0.0:8739").unwrap();
+ socket.set_read_timeout(Some(PING_TIMEOUT)).unwrap();
+
+ let mut buffer = [0u8; 8];
+
+ loop {
+ match socket.recv_from(&mut buffer) {
+ Ok((size, src)) => {
+ let mut check_alive_error = check_alive_error_mutex.lock().unwrap();
+ if size == 8 {
+ *check_alive_error = Ok(());
+ socket.send_to(&buffer, &src).unwrap();
+ } else {
+ *check_alive_error = Err(CheckError::CheckAlive);
+ }
+ }
+ Err(_error) => {
+ let mut check_alive_error = check_alive_error_mutex.lock().unwrap();
+ *check_alive_error = Err(CheckError::CheckAlive);
+ }
+ }
+ }
+ });
+
+ check_alive_error_mutex_copy
+}