Searched refs:recv_thread (Results 1 – 11 of 11) sorted by relevance
| /external/liburing/test/ |
| D | recv-msgall.c | 227 pthread_t recv_thread; in test() local
235 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
243 pthread_join(recv_thread, &retval); in test()
|
| D | send_recv.c | 255 pthread_t recv_thread; in test() local
269 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
278 pthread_join(recv_thread, &retval); in test()
|
| D | recv-msgall-stream.c | 344 pthread_t recv_thread; in test() local
357 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
365 pthread_join(recv_thread, &retval); in test()
|
| D | poll-link.c | 74 static void *recv_thread(void *arg) in recv_thread() function
185 pthread_create(&t1, NULL, recv_thread, &d); in test_poll_timeout()
|
| D | send_recvmsg.c | 318 pthread_t recv_thread; in test() local
337 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
346 pthread_join(recv_thread, &retval); in test()
|
| D | socket.c | 343 pthread_t recv_thread; in test() local
355 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
364 pthread_join(recv_thread, &retval); in test()
|
| D | accept-link.c | 80 static void *recv_thread(void *arg) in recv_thread() function
222 pthread_create(&t1, NULL, recv_thread, &d); in test_accept_timeout()
|
| D | recvsend_bundle.c | 574 pthread_t recv_thread; in test() local
595 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
605 pthread_join(recv_thread, &retval); in test()
612 pthread_join(recv_thread, &retval); in test()
|
| D | recvsend_bundle-inc.c | 511 pthread_t recv_thread; in test() local
528 ret = pthread_create(&recv_thread, NULL, recv_fn, &rd); in test()
541 pthread_join(recv_thread, &retval); in test()
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | shm_vios.rs | 153 recv_thread: Mutex<Option<WorkerThread<Result<()>>>>, field
250 recv_thread: Mutex::new(None), in try_new()
292 if self.recv_thread.lock().is_some() { in start_bg_thread()
301 let mut opt = self.recv_thread.lock(); in start_bg_thread()
323 if let Some(recv_thread) = self.recv_thread.lock().take() { in stop_bg_thread()
324 recv_thread.stop()?; in stop_bg_thread()
|
| /external/rust/android-crates-io/crates/tokio/src/sync/ |
| D | watch.rs | 1419 let recv_thread = thread::spawn(move || { in watch_spurious_wakeup() localVariable
1427 let mut recv = recv_thread.join().unwrap(); in watch_spurious_wakeup()
1457 let recv_thread = thread::spawn(move || { in watch_borrow() localVariable
1465 let recv = recv_thread.join().unwrap(); in watch_borrow()
|