Home
last modified time | relevance | path

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

123

/net/atm/
Dsvc.c47 DEFINE_WAIT(wait); in svc_disconnect()
55 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); in svc_disconnect()
60 finish_wait(sk_sleep(sk), &wait); in svc_disconnect()
97 DEFINE_WAIT(wait); in svc_bind()
131 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); in svc_bind()
136 finish_wait(sk_sleep(sk), &wait); in svc_bind()
153 DEFINE_WAIT(wait); in svc_connect()
213 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in svc_connect()
217 prepare_to_wait(sk_sleep(sk), &wait, in svc_connect()
236 prepare_to_wait(sk_sleep(sk), &wait, in svc_connect()
[all …]
Dcommon.c100 wake_up(&wq->wait); in vcc_def_wakeup()
121 wake_up_interruptible(&wq->wait); in vcc_write_space()
576 DEFINE_WAIT(wait); in vcc_sendmsg()
616 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vcc_sendmsg()
635 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vcc_sendmsg()
637 finish_wait(sk_sleep(sk), &wait); in vcc_sendmsg()
656 unsigned int vcc_poll(struct file *file, struct socket *sock, poll_table *wait) in vcc_poll() argument
662 sock_poll_wait(file, sk_sleep(sk), wait); in vcc_poll()
Dsignaling.c35 DECLARE_WAITQUEUE(wait, current); in sigd_put_skb()
37 add_wait_queue(&sigd_sleep, &wait); in sigd_put_skb()
44 remove_wait_queue(&sigd_sleep, &wait); in sigd_put_skb()
/net/core/
Dstream.c39 wake_up_interruptible_poll(&wq->wait, POLLOUT | in sk_stream_write_space()
58 DEFINE_WAIT(wait); in sk_stream_wait_connect()
72 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in sk_stream_wait_connect()
78 finish_wait(sk_sleep(sk), &wait); in sk_stream_wait_connect()
98 DEFINE_WAIT(wait); in sk_stream_wait_close()
101 prepare_to_wait(sk_sleep(sk), &wait, in sk_stream_wait_close()
107 finish_wait(sk_sleep(sk), &wait); in sk_stream_wait_close()
122 DEFINE_WAIT(wait); in sk_stream_wait_memory()
130 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in sk_stream_wait_memory()
161 finish_wait(sk_sleep(sk), &wait); in sk_stream_wait_memory()
Ddatagram.c70 static int receiver_wake_function(wait_queue_t *wait, unsigned int mode, int sync, in receiver_wake_function() argument
80 return autoremove_wake_function(wait, mode, sync, key); in receiver_wake_function()
89 DEFINE_WAIT_FUNC(wait, receiver_wake_function); in wait_for_more_packets()
91 prepare_to_wait_exclusive(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in wait_for_more_packets()
120 finish_wait(sk_sleep(sk), &wait); in wait_for_more_packets()
884 poll_table *wait) in datagram_poll() argument
889 sock_poll_wait(file, sk_sleep(sk), wait); in datagram_poll()
/net/bluetooth/
Daf_bluetooth.c286 DECLARE_WAITQUEUE(wait, current); in bt_sock_data_wait()
288 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_data_wait()
309 remove_wait_queue(sk_sleep(sk), &wait); in bt_sock_data_wait()
435 poll_table *wait) in bt_sock_poll() argument
442 poll_wait(file, sk_sleep(sk), wait); in bt_sock_poll()
528 DECLARE_WAITQUEUE(wait, current); in bt_sock_wait_state()
533 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_state()
556 remove_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_state()
564 DECLARE_WAITQUEUE(wait, current); in bt_sock_wait_ready()
572 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_ready()
[all …]
/net/bluetooth/cmtp/
Dcapi.c212 wake_up_interruptible(&session->wait); in cmtp_recv_interopmsg()
224 wake_up_interruptible(&session->wait); in cmtp_recv_interopmsg()
238 wake_up_interruptible(&session->wait); in cmtp_recv_interopmsg()
389 DECLARE_WAITQUEUE(wait, current); in cmtp_register_appl()
423 add_wait_queue(&session->wait, &wait); in cmtp_register_appl()
448 remove_wait_queue(&session->wait, &wait); in cmtp_register_appl()
474 wait_event_interruptible_timeout(session->wait, in cmtp_release_appl()
559 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()
309 wait_woken(&wait, TASK_INTERRUPTIBLE, MAX_SCHEDULE_TIMEOUT); in cmtp_session()
311 remove_wait_queue(sk_sleep(sk), &wait); in cmtp_session()
363 init_waitqueue_head(&session->wait); in cmtp_add_connection()
/net/vmw_vsock/
Dvmci_transport.h80 struct vmci_transport_waiting_info wait; member
138 struct vmci_transport_waiting_info *wait);
140 struct vmci_transport_waiting_info *wait);
Daf_vsock.c840 poll_table *wait) in vsock_poll() argument
849 poll_wait(file, sk_sleep(sk), wait); in vsock_poll()
1121 DEFINE_WAIT(wait); in vsock_stream_connect()
1188 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vsock_stream_connect()
1219 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vsock_stream_connect()
1229 finish_wait(sk_sleep(sk), &wait); in vsock_stream_connect()
1247 DEFINE_WAIT(wait); in vsock_accept()
1268 prepare_to_wait(sk_sleep(listener), &wait, TASK_INTERRUPTIBLE); in vsock_accept()
1284 prepare_to_wait(sk_sleep(listener), &wait, TASK_INTERRUPTIBLE); in vsock_accept()
1317 finish_wait(sk_sleep(listener), &wait); in vsock_accept()
[all …]
Dvmci_transport.c141 struct vmci_transport_waiting_info *wait, in vmci_transport_packet_init() argument
187 memcpy(&pkt->u.wait, wait, sizeof(pkt->u.wait)); in vmci_transport_packet_init()
214 struct vmci_transport_waiting_info *wait, in __vmci_transport_send_control_pkt() argument
221 vmci_transport_packet_init(pkt, src, dst, type, size, mode, wait, in __vmci_transport_send_control_pkt()
235 struct vmci_transport_waiting_info *wait, in vmci_transport_reply_control_pkt_fast() argument
247 size, mode, wait, in vmci_transport_reply_control_pkt_fast()
259 struct vmci_transport_waiting_info *wait, in vmci_transport_send_control_pkt_bh() argument
270 size, mode, wait, in vmci_transport_send_control_pkt_bh()
280 struct vmci_transport_waiting_info *wait, in vmci_transport_send_control_pkt() argument
302 mode, wait, proto, handle, in vmci_transport_send_control_pkt()
[all …]
/net/dccp/
Dprobe.c49 wait_queue_head_t wait; member
72 wake_up(&dccpw.wait); in printl()
134 error = wait_event_interruptible(dccpw.wait, in dccpprobe_read()
159 init_waitqueue_head(&dccpw.wait); in dccpprobe_init()
Doutput.c205 wake_up_interruptible(&wq->wait); in dccp_write_space()
222 DEFINE_WAIT(wait); in dccp_wait_for_ccid()
225 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dccp_wait_for_ccid()
233 finish_wait(sk_sleep(sk), &wait); in dccp_wait_for_ccid()
/net/sctp/
Dprobe.c67 wait_queue_head_t wait; member
82 wake_up(&sctpw.wait); in printl()
109 error = wait_event_interruptible(sctpw.wait, in sctpprobe_read()
211 init_waitqueue_head(&sctpw.wait); in sctpprobe_init()
/net/decnet/
Daf_decnet.c826 DEFINE_WAIT(wait); in dn_confirm_accept()
836 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_confirm_accept()
854 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_confirm_accept()
856 finish_wait(sk_sleep(sk), &wait); in dn_confirm_accept()
868 DEFINE_WAIT(wait); in dn_wait_run()
877 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_wait_run()
895 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_wait_run()
897 finish_wait(sk_sleep(sk), &wait); in dn_wait_run()
1042 DEFINE_WAIT(wait); in dn_wait_for_connect()
1046 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in dn_wait_for_connect()
[all …]
/net/ipv4/
Dtcp_probe.c78 wait_queue_head_t wait; member
162 wake_up(&tcp_probe.wait); in jtcp_rcv_established()
215 error = wait_event_interruptible(tcp_probe.wait, in tcpprobe_read()
265 init_waitqueue_head(&tcp_probe.wait); in tcpprobe_init()
/net/tipc/
Dsocket.c660 poll_table *wait) in tipc_poll() argument
666 sock_poll_wait(file, sk_sleep(sk), wait); in tipc_poll()
858 DEFINE_WAIT(wait); in tipc_wait_for_sndmsg()
872 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in tipc_wait_for_sndmsg()
874 finish_wait(sk_sleep(sk), &wait); in tipc_wait_for_sndmsg()
1010 DEFINE_WAIT(wait); in tipc_wait_for_sndpkt()
1026 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in tipc_wait_for_sndpkt()
1031 finish_wait(sk_sleep(sk), &wait); in tipc_wait_for_sndpkt()
1276 DEFINE_WAIT(wait); in tipc_wait_for_rcvmsg()
1281 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in tipc_wait_for_rcvmsg()
[all …]
/net/rxrpc/
Dar-recvmsg.c57 DEFINE_WAIT(wait); in rxrpc_recvmsg()
95 prepare_to_wait_exclusive(sk_sleep(&rx->sk), &wait, in rxrpc_recvmsg()
106 finish_wait(sk_sleep(&rx->sk), &wait); in rxrpc_recvmsg()
345 finish_wait(sk_sleep(&rx->sk), &wait); in rxrpc_recvmsg()
/net/irda/irnet/
Dirnet_ppp.c284 DECLARE_WAITQUEUE(wait, current); in irnet_ctrl_read()
307 add_wait_queue(&irnet_events.rwait, &wait); in irnet_ctrl_read()
325 remove_wait_queue(&irnet_events.rwait, &wait); in irnet_ctrl_read()
424 poll_table * wait) in irnet_ctrl_poll() argument
430 poll_wait(file, &irnet_events.rwait, wait); in irnet_ctrl_poll()
612 poll_table * wait) in dev_irnet_poll() argument
625 mask |= irnet_ctrl_poll(ap, file, wait); in dev_irnet_poll()
/net/nfc/
Dllcp_sock.c30 DECLARE_WAITQUEUE(wait, current); in sock_wait_state()
35 add_wait_queue(sk_sleep(sk), &wait); in sock_wait_state()
60 remove_wait_queue(sk_sleep(sk), &wait); in sock_wait_state()
447 DECLARE_WAITQUEUE(wait, current); in llcp_sock_accept()
464 add_wait_queue_exclusive(sk_sleep(sk), &wait); in llcp_sock_accept()
483 remove_wait_queue(sk_sleep(sk), &wait); in llcp_sock_accept()
546 poll_table *wait) in llcp_sock_poll() argument
553 sock_poll_wait(file, sk_sleep(sk), wait); in llcp_sock_poll()
/net/llc/
Daf_llc.c535 DEFINE_WAIT(wait); in llc_ui_wait_for_disc()
539 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in llc_ui_wait_for_disc()
550 finish_wait(sk_sleep(sk), &wait); in llc_ui_wait_for_disc()
556 DEFINE_WAIT(wait); in llc_ui_wait_for_conn()
559 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in llc_ui_wait_for_conn()
565 finish_wait(sk_sleep(sk), &wait); in llc_ui_wait_for_conn()
571 DEFINE_WAIT(wait); in llc_ui_wait_for_busy_core()
576 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in llc_ui_wait_for_busy_core()
591 finish_wait(sk_sleep(sk), &wait); in llc_ui_wait_for_busy_core()
/net/caif/
Dcaif_socket.c314 DEFINE_WAIT(wait); in caif_stream_data_wait()
318 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in caif_stream_data_wait()
340 finish_wait(sk_sleep(sk), &wait); in caif_stream_data_wait()
472 DEFINE_WAIT(wait); in caif_wait_for_flow_on()
484 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in caif_wait_for_flow_on()
496 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, sk_sleep(sk), wait); in caif_poll()
/net/9p/
Dtrans_fd.c98 wait_queue_t wait; member
180 remove_wait_queue(pwait->wait_addr, &pwait->wait); in p9_mux_poll_stop()
521 static int p9_pollwake(wait_queue_t *wait, unsigned int mode, int sync, void *key) in p9_pollwake() argument
524 container_of(wait, struct p9_poll_wait, wait); in p9_pollwake()
567 init_waitqueue_func_entry(&pwait->wait, p9_pollwake); in p9_pollwait()
568 add_wait_queue(wait_address, &pwait->wait); in p9_pollwait()
/net/rds/
Dib_rdma.c585 DEFINE_WAIT(wait); in rds_ib_flush_mr_pool()
590 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
594 prepare_to_wait(&pool->flush_wait, &wait, in rds_ib_flush_mr_pool()
602 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
606 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
/net/phonet/
Dsocket.c272 DEFINE_WAIT(wait); in pn_socket_connect()
283 prepare_to_wait_exclusive(sk_sleep(sk), &wait, in pn_socket_connect()
288 finish_wait(sk_sleep(sk), &wait); in pn_socket_connect()
341 poll_table *wait) in pn_socket_poll() argument
347 poll_wait(file, sk_sleep(sk), wait); in pn_socket_poll()

123