Home
last modified time | relevance | path

Searched refs:wait (Results 1 – 25 of 80) 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.c73 static int receiver_wake_function(wait_queue_entry_t *wait, unsigned int mode, int sync, in receiver_wake_function() argument
81 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()
814 poll_table *wait) in datagram_poll() argument
820 sock_poll_wait(file, sock, wait); in datagram_poll()
/net/atm/
Dsvc.c53 DEFINE_WAIT(wait); in svc_disconnect()
61 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); in svc_disconnect()
66 finish_wait(sk_sleep(sk), &wait); in svc_disconnect()
103 DEFINE_WAIT(wait); in svc_bind()
137 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); in svc_bind()
142 finish_wait(sk_sleep(sk), &wait); in svc_bind()
159 DEFINE_WAIT(wait); in svc_connect()
219 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in svc_connect()
223 prepare_to_wait(sk_sleep(sk), &wait, in svc_connect()
242 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/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/vmw_vsock/
Daf_vsock.c1023 poll_table *wait) in vsock_poll() argument
1032 poll_wait(file, sk_sleep(sk), wait); in vsock_poll()
1358 DEFINE_WAIT(wait); in vsock_connect()
1434 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vsock_connect()
1477 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in vsock_connect()
1489 finish_wait(sk_sleep(sk), &wait); in vsock_connect()
1503 DEFINE_WAIT(wait); in vsock_accept()
1524 prepare_to_wait(sk_sleep(listener), &wait, TASK_INTERRUPTIBLE); in vsock_accept()
1530 finish_wait(sk_sleep(listener), &wait); in vsock_accept()
1541 prepare_to_wait(sk_sleep(listener), &wait, TASK_INTERRUPTIBLE); in vsock_accept()
[all …]
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()
Dvmci_transport.h72 struct vmci_transport_waiting_info wait; member
126 struct vmci_transport_waiting_info *wait);
128 struct vmci_transport_waiting_info *wait);
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
198 vmci_transport_packet_init(pkt, src, dst, type, size, mode, wait, in __vmci_transport_send_control_pkt()
212 struct vmci_transport_waiting_info *wait, in vmci_transport_reply_control_pkt_fast() 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()
258 struct vmci_transport_waiting_info *wait, in vmci_transport_alloc_send_control_pkt() argument
270 mode, wait, proto, handle, in vmci_transport_alloc_send_control_pkt()
[all …]
/net/bluetooth/
Daf_bluetooth.c355 DECLARE_WAITQUEUE(wait, current); in bt_sock_data_wait()
357 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_data_wait()
378 remove_wait_queue(sk_sleep(sk), &wait); in bt_sock_data_wait()
504 poll_table *wait) in bt_sock_poll() argument
509 poll_wait(file, sk_sleep(sk), wait); in bt_sock_poll()
588 DECLARE_WAITQUEUE(wait, current); in bt_sock_wait_state()
593 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_state()
616 remove_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_state()
624 DECLARE_WAITQUEUE(wait, current); in bt_sock_wait_ready()
632 add_wait_queue(sk_sleep(sk), &wait); in bt_sock_wait_ready()
[all …]
/net/ipv4/
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/
Dunix_bpf.c18 DEFINE_WAIT_FUNC(wait, woken_wake_function); in unix_msg_wait_data()
28 add_wait_queue(sk_sleep(sk), &wait); in unix_msg_wait_data()
32 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in unix_msg_wait_data()
37 remove_wait_queue(sk_sleep(sk), &wait); in unix_msg_wait_data()
/net/llc/
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()
610 READ_ONCE(sk->sk_state) != TCP_SYN_SENT, &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()
[all …]
/net/can/
Disotp.c167 wait_queue_head_t wait; member
380 wake_up_interruptible(&so->wait); in isotp_rcv_fc()
437 wake_up_interruptible(&so->wait); in isotp_rcv_fc()
870 wake_up_interruptible(&so->wait); in isotp_rcv_echo()
914 wake_up_interruptible(&so->wait); in isotp_tx_timer_handler()
960 err = wait_event_interruptible(so->wait, so->tx.state == ISOTP_IDLE); in isotp_sendmsg()
1102 err = wait_event_interruptible(so->wait, so->tx.state == ISOTP_IDLE); in isotp_sendmsg()
1121 wake_up_interruptible(&so->wait); in isotp_sendmsg()
1183 while (wait_event_interruptible(so->wait, so->tx.state == ISOTP_IDLE) == 0 && in isotp_release()
1642 init_waitqueue_head(&so->wait); in isotp_init()
[all …]
/net/smc/
Dsmc_rx.c43 wake_up_interruptible_sync_poll(&wq->wait, EPOLLIN | EPOLLPRI | in smc_rx_wake_up()
258 DEFINE_WAIT_FUNC(wait, woken_wake_function); in smc_rx_wait()
268 add_wait_queue(sk_sleep(sk), &wait); in smc_rx_wait()
275 &wait); in smc_rx_wait()
276 remove_wait_queue(sk_sleep(sk), &wait); in smc_rx_wait()
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()
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/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()
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/caif/
Dcaif_socket.c306 DEFINE_WAIT(wait); in caif_stream_data_wait()
310 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in caif_stream_data_wait()
332 finish_wait(sk_sleep(sk), &wait); in caif_stream_data_wait()
463 DEFINE_WAIT(wait); in caif_wait_for_flow_on()
475 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in caif_wait_for_flow_on()
487 finish_wait(sk_sleep(sk), &wait); in caif_wait_for_flow_on()
930 struct socket *sock, poll_table *wait) in caif_poll() argument
936 sock_poll_wait(file, sock, wait); in caif_poll()
/net/rds/
Dib_rdma.c358 DEFINE_WAIT(wait); in rds_ib_flush_mr_pool()
363 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
367 prepare_to_wait(&pool->flush_wait, &wait, in rds_ib_flush_mr_pool()
375 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
379 finish_wait(&pool->flush_wait, &wait); in rds_ib_flush_mr_pool()
/net/qrtr/
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/rxrpc/
Drecvmsg.c289 DEFINE_WAIT(wait); in rxrpc_recvmsg()
319 prepare_to_wait_exclusive(sk_sleep(&rx->sk), &wait, in rxrpc_recvmsg()
331 finish_wait(sk_sleep(&rx->sk), &wait); in rxrpc_recvmsg()
464 finish_wait(sk_sleep(&rx->sk), &wait); in rxrpc_recvmsg()
/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/9p/
Dtrans_fd.c84 wait_queue_entry_t wait; member
167 remove_wait_queue(pwait->wait_addr, &pwait->wait); in p9_mux_poll_stop()
527 static int p9_pollwake(wait_queue_entry_t *wait, unsigned int mode, int sync, void *key) in p9_pollwake() argument
530 container_of(wait, struct p9_poll_wait, wait); in p9_pollwake()
573 init_waitqueue_func_entry(&pwait->wait, p9_pollwake); in p9_pollwait()
574 add_wait_queue(wait_address, &pwait->wait); in p9_pollwait()

1234