Home
last modified time | relevance | path

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

1234

/net/core/
Dstream.c41 wake_up_interruptible_poll(&wq->wait, EPOLLOUT | in sk_stream_write_space()
58 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_connect()
73 add_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_connect()
78 ~(TCPF_ESTABLISHED | TCPF_CLOSE_WAIT)), &wait); in sk_stream_wait_connect()
79 remove_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_connect()
99 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_close()
101 add_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_close()
104 if (sk_wait_event(sk, &timeout, !sk_stream_closing(sk), &wait)) in sk_stream_wait_close()
108 remove_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_close()
123 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_memory()
[all …]
Ddatagram.c74 static int receiver_wake_function(wait_queue_entry_t *wait, unsigned int mode, int sync, in receiver_wake_function() argument
82 return autoremove_wake_function(wait, mode, sync, key); in receiver_wake_function()
91 DEFINE_WAIT_FUNC(wait, receiver_wake_function); in __skb_wait_for_more_packets()
93 prepare_to_wait_exclusive(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in __skb_wait_for_more_packets()
122 finish_wait(sk_sleep(sk), &wait); in __skb_wait_for_more_packets()
761 poll_table *wait) in datagram_poll() argument
766 sock_poll_wait(file, sock, wait); in datagram_poll()
/net/atm/
Dsvc.c48 DEFINE_WAIT(wait); in svc_disconnect()
56 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); in svc_disconnect()
61 finish_wait(sk_sleep(sk), &wait); in svc_disconnect()
98 DEFINE_WAIT(wait); in svc_bind()
132 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); in svc_bind()
137 finish_wait(sk_sleep(sk), &wait); in svc_bind()
154 DEFINE_WAIT(wait); in svc_connect()
214 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in svc_connect()
218 prepare_to_wait(sk_sleep(sk), &wait, in svc_connect()
237 prepare_to_wait(sk_sleep(sk), &wait, in svc_connect()
[all …]
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()
651 __poll_t vcc_poll(struct file *file, struct socket *sock, poll_table *wait) in vcc_poll() argument
657 sock_poll_wait(file, sock, wait); in vcc_poll()
/net/vmw_vsock/
Daf_vsock.c838 poll_table *wait) in vsock_poll() argument
847 poll_wait(file, sk_sleep(sk), wait); in vsock_poll()
1130 DEFINE_WAIT(wait); in vsock_stream_connect()
1197 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vsock_stream_connect()
1232 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vsock_stream_connect()
1244 finish_wait(sk_sleep(sk), &wait); in vsock_stream_connect()
1258 DEFINE_WAIT(wait); in vsock_accept()
1279 prepare_to_wait(sk_sleep(listener), &wait, TASK_INTERRUPTIBLE); in vsock_accept()
1285 finish_wait(sk_sleep(listener), &wait); in vsock_accept()
1296 prepare_to_wait(sk_sleep(listener), &wait, TASK_INTERRUPTIBLE); in vsock_accept()
[all …]
Dvmci_transport.h72 struct vmci_transport_waiting_info wait; member
132 struct vmci_transport_waiting_info *wait);
134 struct vmci_transport_waiting_info *wait);
Dvmci_transport.c124 struct vmci_transport_waiting_info *wait, in vmci_transport_packet_init() argument
170 memcpy(&pkt->u.wait, wait, sizeof(pkt->u.wait)); in vmci_transport_packet_init()
197 struct vmci_transport_waiting_info *wait, in __vmci_transport_send_control_pkt() argument
204 vmci_transport_packet_init(pkt, src, dst, type, size, mode, wait, in __vmci_transport_send_control_pkt()
218 struct vmci_transport_waiting_info *wait, in vmci_transport_reply_control_pkt_fast() argument
230 size, mode, wait, in vmci_transport_reply_control_pkt_fast()
242 struct vmci_transport_waiting_info *wait, in vmci_transport_send_control_pkt_bh() argument
253 size, mode, wait, in vmci_transport_send_control_pkt_bh()
264 struct vmci_transport_waiting_info *wait, in vmci_transport_alloc_send_control_pkt() argument
276 mode, wait, proto, handle, in vmci_transport_alloc_send_control_pkt()
[all …]
/net/bluetooth/cmtp/
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()
381 DECLARE_WAITQUEUE(wait, current); in cmtp_register_appl()
415 add_wait_queue(&session->wait, &wait); in cmtp_register_appl()
440 remove_wait_queue(&session->wait, &wait); in cmtp_register_appl()
466 wait_event_interruptible_timeout(session->wait, in cmtp_release_appl()
536 ret = wait_event_interruptible_timeout(session->wait, in cmtp_attach_device()
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/bluetooth/
Daf_bluetooth.c302 DECLARE_WAITQUEUE(wait, current); in bt_sock_data_wait()
304 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_data_wait()
325 remove_wait_queue(sk_sleep(sk), &wait); in bt_sock_data_wait()
451 poll_table *wait) in bt_sock_poll() argument
458 poll_wait(file, sk_sleep(sk), wait); in bt_sock_poll()
536 DECLARE_WAITQUEUE(wait, current); in bt_sock_wait_state()
541 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_state()
564 remove_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_state()
572 DECLARE_WAITQUEUE(wait, current); in bt_sock_wait_ready()
580 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_ready()
[all …]
/net/decnet/
Daf_decnet.c818 DEFINE_WAIT(wait); in dn_confirm_accept()
828 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_confirm_accept()
846 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_confirm_accept()
848 finish_wait(sk_sleep(sk), &wait); in dn_confirm_accept()
860 DEFINE_WAIT(wait); in dn_wait_run()
869 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_wait_run()
887 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_wait_run()
889 finish_wait(sk_sleep(sk), &wait); in dn_wait_run()
1034 DEFINE_WAIT(wait); in dn_wait_for_connect()
1038 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_wait_for_connect()
[all …]
/net/llc/
Daf_llc.c553 DEFINE_WAIT_FUNC(wait, woken_wake_function); in llc_ui_wait_for_disc()
556 add_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_disc()
558 if (sk_wait_event(sk, &timeout, sk->sk_state == TCP_CLOSE, &wait)) in llc_ui_wait_for_disc()
568 remove_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_disc()
574 DEFINE_WAIT_FUNC(wait, woken_wake_function); in llc_ui_wait_for_conn()
576 add_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_conn()
578 if (sk_wait_event(sk, &timeout, sk->sk_state != TCP_SYN_SENT, &wait)) in llc_ui_wait_for_conn()
583 remove_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_conn()
589 DEFINE_WAIT_FUNC(wait, woken_wake_function); in llc_ui_wait_for_busy_core()
593 add_wait_queue(sk_sleep(sk), &wait); in llc_ui_wait_for_busy_core()
[all …]
/net/smc/
Dsmc_rx.c37 wake_up_interruptible_sync_poll(&wq->wait, EPOLLIN | EPOLLPRI | in smc_rx_wake_up()
202 DEFINE_WAIT_FUNC(wait, woken_wake_function); in smc_rx_wait()
210 add_wait_queue(sk_sleep(sk), &wait); in smc_rx_wait()
215 &wait); in smc_rx_wait()
216 remove_wait_queue(sk_sleep(sk), &wait); in smc_rx_wait()
Dsmc_close.c52 DEFINE_WAIT_FUNC(wait, woken_wake_function); in smc_close_stream_wait()
62 add_wait_queue(sk_sleep(sk), &wait); in smc_close_stream_wait()
70 &wait); in smc_close_stream_wait()
74 remove_wait_queue(sk_sleep(sk), &wait); in smc_close_stream_wait()
Dsmc_tx.c52 wake_up_interruptible_poll(&wq->wait, in smc_tx_write_space()
76 DEFINE_WAIT_FUNC(wait, woken_wake_function); in smc_tx_wait()
84 add_wait_queue(sk_sleep(sk), &wait); in smc_tx_wait()
117 &wait); in smc_tx_wait()
119 remove_wait_queue(sk_sleep(sk), &wait); in smc_tx_wait()
/net/nfc/
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()
441 DECLARE_WAITQUEUE(wait, current); in llcp_sock_accept()
458 add_wait_queue_exclusive(sk_sleep(sk), &wait); in llcp_sock_accept()
477 remove_wait_queue(sk_sleep(sk), &wait); in llcp_sock_accept()
545 poll_table *wait) in llcp_sock_poll() argument
552 sock_poll_wait(file, sock, wait); in llcp_sock_poll()
/net/rds/
Dib_rdma.c348 DEFINE_WAIT(wait); in rds_ib_flush_mr_pool()
353 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
357 prepare_to_wait(&pool->flush_wait, &wait, in rds_ib_flush_mr_pool()
365 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
369 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
/net/caif/
Dcaif_socket.c311 DEFINE_WAIT(wait); in caif_stream_data_wait()
315 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in caif_stream_data_wait()
337 finish_wait(sk_sleep(sk), &wait); in caif_stream_data_wait()
468 DEFINE_WAIT(wait); in caif_wait_for_flow_on()
480 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in caif_wait_for_flow_on()
492 finish_wait(sk_sleep(sk), &wait); in caif_wait_for_flow_on()
938 struct socket *sock, poll_table *wait) in caif_poll() argument
944 sock_poll_wait(file, sock, wait); in caif_poll()
/net/qrtr/
Dtun.c98 static __poll_t qrtr_tun_poll(struct file *filp, poll_table *wait) in qrtr_tun_poll() argument
103 poll_wait(filp, &tun->readq, wait); in qrtr_tun_poll()
/net/9p/
Dtrans_fd.c87 wait_queue_entry_t wait; member
166 remove_wait_queue(pwait->wait_addr, &pwait->wait); in p9_mux_poll_stop()
518 static int p9_pollwake(wait_queue_entry_t *wait, unsigned int mode, int sync, void *key) in p9_pollwake() argument
521 container_of(wait, struct p9_poll_wait, wait); in p9_pollwake()
564 init_waitqueue_func_entry(&pwait->wait, p9_pollwake); in p9_pollwait()
565 add_wait_queue(wait_address, &pwait->wait); in p9_pollwait()
/net/phonet/
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()
331 poll_table *wait) in pn_socket_poll() argument
337 poll_wait(file, sk_sleep(sk), wait); in pn_socket_poll()
/net/batman-adv/
Dlog.c164 static __poll_t batadv_log_poll(struct file *file, poll_table *wait) in batadv_log_poll() argument
169 poll_wait(file, &debug_log->queue_wait, wait); in batadv_log_poll()
/net/dccp/
Doutput.c202 wake_up_interruptible(&wq->wait); in dccp_write_space()
219 DEFINE_WAIT(wait); in dccp_wait_for_ccid()
222 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dccp_wait_for_ccid()
230 finish_wait(sk_sleep(sk), &wait); in dccp_wait_for_ccid()
/net/bluetooth/bnep/
Dcore.c484 DEFINE_WAIT_FUNC(wait, woken_wake_function); in bnep_session()
490 add_wait_queue(sk_sleep(sk), &wait); in bnep_session()
516 wait_woken(&wait, TASK_INTERRUPTIBLE, MAX_SCHEDULE_TIMEOUT); in bnep_session()
518 remove_wait_queue(sk_sleep(sk), &wait); in bnep_session()
/net/netlink/
Daf_netlink.c358 wake_up_interruptible(&nlk->wait); in netlink_rcv_wake()
428 DECLARE_WAITQUEUE(wait, current); in netlink_table_grab()
430 add_wait_queue_exclusive(&nl_table_wait, &wait); in netlink_table_grab()
441 remove_wait_queue(&nl_table_wait, &wait); in netlink_table_grab()
645 init_waitqueue_head(&nlk->wait); in __netlink_create()
764 wake_up_interruptible_all(&nlk->wait); in netlink_release()
1211 DECLARE_WAITQUEUE(wait, current); in netlink_attachskb()
1221 add_wait_queue(&nlk->wait, &wait); in netlink_attachskb()
1229 remove_wait_queue(&nlk->wait, &wait); in netlink_attachskb()
1679 wake_up_interruptible(&nlk->wait); in netlink_setsockopt()

1234