Searched refs:recv_thread (Results 1 – 6 of 6) sorted by relevance
| /external/rust/crates/tokio/src/sync/ |
| D | watch.rs | 683 let recv_thread = thread::spawn(move || { in watch_spurious_wakeup() localVariable
691 let mut recv = recv_thread.join().unwrap(); in watch_spurious_wakeup()
721 let recv_thread = thread::spawn(move || { in watch_borrow() localVariable
729 let recv = recv_thread.join().unwrap(); in watch_borrow()
|
| /external/liburing/test/ |
| D | send_recv.c | 240 pthread_t recv_thread; in test() local
252 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
261 pthread_join(recv_thread, &retval); in test()
|
| D | send_recvmsg.c | 284 pthread_t recv_thread; in test() local
298 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
307 pthread_join(recv_thread, &retval); in test()
|
| D | poll-link.c | 71 void *recv_thread(void *arg) in recv_thread() function
191 pthread_create(&t1, NULL, recv_thread, &d); in test_poll_timeout()
|
| D | accept-link.c | 77 void *recv_thread(void *arg) in recv_thread() function
218 pthread_create(&t1, NULL, recv_thread, &d); in test_accept_timeout()
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | shm_vios.rs | 128 recv_thread: Mutex<Option<JoinHandle<Result<()>>>>, field
223 recv_thread: Mutex::new(None), in try_new()
264 if self.recv_thread.lock().is_some() { in start_bg_thread()
274 let mut opt = self.recv_thread.lock(); in start_bg_thread()
297 if self.recv_thread.lock().is_none() { in stop_bg_thread()
304 if let Some(handle) = self.recv_thread.lock().take() { in stop_bg_thread()
|