Home
last modified time | relevance | path

Searched refs:wait (Results 1 – 25 of 77) sorted by relevance

1234

/net/core/
A Dstream.c45 wake_up_interruptible_poll(&wq->wait, EPOLLOUT | in sk_stream_write_space()
62 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_connect()
77 add_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_connect()
83 remove_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_connect()
103 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_close()
105 add_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_close()
112 remove_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_close()
127 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_memory()
132 add_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_memory()
152 &wait); in sk_stream_wait_memory()
[all …]
A Ddatagram.c76 static int receiver_wake_function(wait_queue_entry_t *wait, unsigned int mode, int sync, in receiver_wake_function() argument
84 return autoremove_wake_function(wait, mode, sync, key); in receiver_wake_function()
94 DEFINE_WAIT_FUNC(wait, receiver_wake_function); in __skb_wait_for_more_packets()
96 prepare_to_wait_exclusive(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in __skb_wait_for_more_packets()
125 finish_wait(sk_sleep(sk), &wait); in __skb_wait_for_more_packets()
923 poll_table *wait) in datagram_poll() argument
929 sock_poll_wait(file, sock, wait); in datagram_poll()
/net/atm/
A Dsvc.c53 DEFINE_WAIT(wait); in svc_disconnect()
66 finish_wait(sk_sleep(sk), &wait); in svc_disconnect()
103 DEFINE_WAIT(wait); in svc_bind()
142 finish_wait(sk_sleep(sk), &wait); in svc_bind()
159 DEFINE_WAIT(wait); in svc_connect()
289 DEFINE_WAIT(wait); in svc_listen()
313 finish_wait(sk_sleep(sk), &wait); in svc_listen()
347 DEFINE_WAIT(wait); in svc_accept()
440 DEFINE_WAIT(wait); in svc_change_qos()
534 DEFINE_WAIT(wait); in svc_addparty()
[all …]
A Dcommon.c96 wake_up(&wq->wait); in vcc_def_wakeup()
117 wake_up_interruptible(&wq->wait); in vcc_write_space()
571 DEFINE_WAIT(wait); in vcc_sendmsg()
603 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vcc_sendmsg()
622 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vcc_sendmsg()
624 finish_wait(sk_sleep(sk), &wait); in vcc_sendmsg()
652 __poll_t vcc_poll(struct file *file, struct socket *sock, poll_table *wait) in vcc_poll() argument
658 sock_poll_wait(file, sock, wait); in vcc_poll()
/net/bluetooth/cmtp/
A Dcapi.c210 wake_up_interruptible(&session->wait); in cmtp_recv_interopmsg()
222 wake_up_interruptible(&session->wait); in cmtp_recv_interopmsg()
236 wake_up_interruptible(&session->wait); in cmtp_recv_interopmsg()
365 DECLARE_WAITQUEUE(wait, current); in cmtp_register_appl()
399 add_wait_queue(&session->wait, &wait); in cmtp_register_appl()
424 remove_wait_queue(&session->wait, &wait); in cmtp_register_appl()
450 wait_event_interruptible_timeout(session->wait, in cmtp_release_appl()
520 ret = wait_event_interruptible_timeout(session->wait, in cmtp_attach_device()
A Dcore.c283 DEFINE_WAIT_FUNC(wait, woken_wake_function); in cmtp_session()
289 add_wait_queue(sk_sleep(sk), &wait); in cmtp_session()
310 wait_woken(&wait, TASK_INTERRUPTIBLE, MAX_SCHEDULE_TIMEOUT); in cmtp_session()
312 remove_wait_queue(sk_sleep(sk), &wait); in cmtp_session()
368 init_waitqueue_head(&session->wait); in cmtp_add_connection()
/net/vmw_vsock/
A Daf_vsock.c1068 add_wait_queue(sk_sleep(sk), &wait); in vsock_linger()
1075 remove_wait_queue(sk_sleep(sk), &wait); in vsock_linger()
1131 poll_table *wait) in vsock_poll() argument
1140 poll_wait(file, sk_sleep(sk), wait); in vsock_poll()
1545 DEFINE_WAIT(wait); in vsock_connect()
1696 finish_wait(sk_sleep(sk), &wait); in vsock_connect()
1710 DEFINE_WAIT(wait); in vsock_accept()
2083 add_wait_queue(sk_sleep(sk), &wait); in vsock_connectible_sendmsg()
2231 finish_wait(sk_sleep(sk), wait); in vsock_connectible_wait_data()
2257 DEFINE_WAIT(wait); in __vsock_stream_recvmsg()
[all …]
A Dvsock_bpf.c41 DEFINE_WAIT_FUNC(wait, woken_wake_function); in vsock_msg_wait_data()
49 add_wait_queue(sk_sleep(sk), &wait); in vsock_msg_wait_data()
53 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in vsock_msg_wait_data()
57 remove_wait_queue(sk_sleep(sk), &wait); in vsock_msg_wait_data()
A Dvmci_transport.h72 struct vmci_transport_waiting_info wait; member
126 struct vmci_transport_waiting_info *wait);
128 struct vmci_transport_waiting_info *wait);
A Dvmci_transport.c118 struct vmci_transport_waiting_info *wait, in vmci_transport_packet_init() argument
164 memcpy(&pkt->u.wait, wait, sizeof(pkt->u.wait)); in vmci_transport_packet_init()
191 struct vmci_transport_waiting_info *wait, in __vmci_transport_send_control_pkt() argument
224 size, mode, wait, in vmci_transport_reply_control_pkt_fast()
236 struct vmci_transport_waiting_info *wait, in vmci_transport_send_control_pkt_bh() argument
247 size, mode, wait, in vmci_transport_send_control_pkt_bh()
270 mode, wait, proto, handle, in vmci_transport_alloc_send_control_pkt()
282 struct vmci_transport_waiting_info *wait, in vmci_transport_send_control_pkt() argument
299 wait, proto, handle); in vmci_transport_send_control_pkt()
437 0, 0, wait, VSOCK_PROTO_INVALID, in vmci_transport_send_waiting_write()
[all …]
/net/bluetooth/
A Daf_bluetooth.c387 DECLARE_WAITQUEUE(wait, current); in bt_sock_data_wait()
389 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_data_wait()
410 remove_wait_queue(sk_sleep(sk), &wait); in bt_sock_data_wait()
536 poll_table *wait) in bt_sock_poll() argument
541 poll_wait(file, sk_sleep(sk), wait); in bt_sock_poll()
704 DECLARE_WAITQUEUE(wait, current); in bt_sock_wait_state()
709 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_state()
732 remove_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_state()
740 DECLARE_WAITQUEUE(wait, current); in bt_sock_wait_ready()
748 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_ready()
[all …]
/net/ipv4/
A Dudp_bpf.c41 DEFINE_WAIT_FUNC(wait, woken_wake_function); in udp_msg_wait_data()
50 add_wait_queue(sk_sleep(sk), &wait); in udp_msg_wait_data()
54 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in udp_msg_wait_data()
58 remove_wait_queue(sk_sleep(sk), &wait); in udp_msg_wait_data()
/net/unix/
A Dunix_bpf.c19 DEFINE_WAIT_FUNC(wait, woken_wake_function); in unix_msg_wait_data()
29 add_wait_queue(sk_sleep(sk), &wait); in unix_msg_wait_data()
33 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in unix_msg_wait_data()
38 remove_wait_queue(sk_sleep(sk), &wait); in unix_msg_wait_data()
/net/llc/
A Daf_llc.c583 DEFINE_WAIT_FUNC(wait, woken_wake_function); in llc_ui_wait_for_disc()
586 add_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_disc()
589 READ_ONCE(sk->sk_state) == TCP_CLOSE, &wait)) in llc_ui_wait_for_disc()
599 remove_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_disc()
605 DEFINE_WAIT_FUNC(wait, woken_wake_function); in llc_ui_wait_for_conn()
607 add_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_conn()
615 remove_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_conn()
621 DEFINE_WAIT_FUNC(wait, woken_wake_function); in llc_ui_wait_for_busy_core()
625 add_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_busy_core()
632 !llc->p_flag), &wait)) in llc_ui_wait_for_busy_core()
[all …]
/net/can/
A Disotp.c168 wait_queue_head_t wait; member
382 wake_up_interruptible(&so->wait); in isotp_rcv_fc()
440 wake_up_interruptible(&so->wait); in isotp_rcv_fc()
873 wake_up_interruptible(&so->wait); in isotp_rcv_echo()
917 wake_up_interruptible(&so->wait); in isotp_tx_timer_handler()
963 err = wait_event_interruptible(so->wait, so->tx.state == ISOTP_IDLE); in isotp_sendmsg()
1105 err = wait_event_interruptible(so->wait, so->tx.state == ISOTP_IDLE); in isotp_sendmsg()
1124 wake_up_interruptible(&so->wait); in isotp_sendmsg()
1644 init_waitqueue_head(&so->wait); in isotp_init()
1659 __poll_t mask = datagram_poll(file, sock, wait); in isotp_poll()
[all …]
/net/smc/
A Dsmc_rx.c43 wake_up_interruptible_sync_poll(&wq->wait, EPOLLIN | EPOLLPRI | in smc_rx_wake_up()
259 DEFINE_WAIT_FUNC(wait, woken_wake_function); in smc_rx_wait()
269 add_wait_queue(sk_sleep(sk), &wait); in smc_rx_wait()
276 &wait); in smc_rx_wait()
277 remove_wait_queue(sk_sleep(sk), &wait); in smc_rx_wait()
A Dsmc_close.c51 DEFINE_WAIT_FUNC(wait, woken_wake_function); in smc_close_stream_wait()
64 add_wait_queue(sk_sleep(sk), &wait); in smc_close_stream_wait()
73 &wait); in smc_close_stream_wait()
77 remove_wait_queue(sk_sleep(sk), &wait); in smc_close_stream_wait()
A Dsmc_tx.c55 wake_up_interruptible_poll(&wq->wait, in smc_tx_write_space()
79 DEFINE_WAIT_FUNC(wait, woken_wake_function); in smc_tx_wait()
87 add_wait_queue(sk_sleep(sk), &wait); in smc_tx_wait()
121 &wait); in smc_tx_wait()
123 remove_wait_queue(sk_sleep(sk), &wait); in smc_tx_wait()
/net/caif/
A Dcaif_socket.c307 DEFINE_WAIT(wait); in caif_stream_data_wait()
311 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in caif_stream_data_wait()
333 finish_wait(sk_sleep(sk), &wait); in caif_stream_data_wait()
464 DEFINE_WAIT(wait); in caif_wait_for_flow_on()
476 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in caif_wait_for_flow_on()
488 finish_wait(sk_sleep(sk), &wait); in caif_wait_for_flow_on()
931 struct socket *sock, poll_table *wait) in caif_poll() argument
937 sock_poll_wait(file, sock, wait); in caif_poll()
/net/nfc/
A Dllcp_sock.c19 DECLARE_WAITQUEUE(wait, current); in sock_wait_state()
24 add_wait_queue(sk_sleep(sk), &wait); in sock_wait_state()
49 remove_wait_queue(sk_sleep(sk), &wait); in sock_wait_state()
452 DECLARE_WAITQUEUE(wait, current); in llcp_sock_accept()
469 add_wait_queue_exclusive(sk_sleep(sk), &wait); in llcp_sock_accept()
488 remove_wait_queue(sk_sleep(sk), &wait); in llcp_sock_accept()
556 poll_table *wait) in llcp_sock_poll() argument
563 sock_poll_wait(file, sock, wait); in llcp_sock_poll()
/net/rds/
A Dib_rdma.c354 DEFINE_WAIT(wait); in rds_ib_flush_mr_pool()
359 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
363 prepare_to_wait(&pool->flush_wait, &wait, in rds_ib_flush_mr_pool()
371 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
375 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
/net/qrtr/
A Dtun.c114 static __poll_t qrtr_tun_poll(struct file *filp, poll_table *wait) in qrtr_tun_poll() argument
119 poll_wait(filp, &tun->readq, wait); in qrtr_tun_poll()
/net/phonet/
A Dsocket.c263 DEFINE_WAIT(wait); in pn_socket_connect()
274 prepare_to_wait_exclusive(sk_sleep(sk), &wait, in pn_socket_connect()
279 finish_wait(sk_sleep(sk), &wait); in pn_socket_connect()
330 poll_table *wait) in pn_socket_poll() argument
336 poll_wait(file, sk_sleep(sk), wait); in pn_socket_poll()
/net/9p/
A Dtrans_fd.c85 wait_queue_entry_t wait; member
167 remove_wait_queue(pwait->wait_addr, &pwait->wait); in p9_mux_poll_stop()
528 static int p9_pollwake(wait_queue_entry_t *wait, unsigned int mode, int sync, void *key) in p9_pollwake() argument
531 container_of(wait, struct p9_poll_wait, wait); in p9_pollwake()
574 init_waitqueue_func_entry(&pwait->wait, p9_pollwake); in p9_pollwait()
575 add_wait_queue(wait_address, &pwait->wait); in p9_pollwait()
/net/bluetooth/bnep/
A Dcore.c485 DEFINE_WAIT_FUNC(wait, woken_wake_function); in bnep_session()
491 add_wait_queue(sk_sleep(sk), &wait); in bnep_session()
517 wait_woken(&wait, TASK_INTERRUPTIBLE, MAX_SCHEDULE_TIMEOUT); in bnep_session()
519 remove_wait_queue(sk_sleep(sk), &wait); in bnep_session()

Completed in 57 milliseconds

1234