Searched refs:wait (Results 1 - 25 of 81) sorted by relevance

1234

/net/core/
H A Dstream.c19 #include <linux/wait.h>
39 wake_up_interruptible_poll(&wq->wait, POLLOUT |
50 * @sk: sock to wait on
51 * @timeo_p: for how long to wait
58 DEFINE_WAIT(wait);
72 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE);
78 finish_wait(sk_sleep(sk), &wait); local
98 DEFINE_WAIT(wait);
101 prepare_to_wait(sk_sleep(sk), &wait, local
107 finish_wait(sk_sleep(sk), &wait); local
130 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
161 finish_wait(sk_sleep(sk), &wait); local
[all...]
H A Ddatagram.c70 static int receiver_wake_function(wait_queue_t *wait, unsigned int mode, int sync, argument
80 return autoremove_wake_function(wait, mode, sync, key);
89 DEFINE_WAIT_FUNC(wait, receiver_wake_function);
91 prepare_to_wait_exclusive(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
120 finish_wait(sk_sleep(sk), &wait); local
216 /* User doesn't want to wait */
834 * @wait: poll table
845 poll_table *wait)
850 sock_poll_wait(file, sk_sleep(sk), wait);
844 datagram_poll(struct file *file, struct socket *sock, poll_table *wait) argument
/net/atm/
H A Dsvc.c12 #include <linux/wait.h>
47 DEFINE_WAIT(wait);
55 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); local
60 finish_wait(sk_sleep(sk), &wait); local
97 DEFINE_WAIT(wait);
131 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); local
136 finish_wait(sk_sleep(sk), &wait); local
153 DEFINE_WAIT(wait);
213 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
217 prepare_to_wait(sk_sleep(sk), &wait, local
236 prepare_to_wait(sk_sleep(sk), &wait, local
243 prepare_to_wait(sk_sleep(sk), &wait, local
254 finish_wait(sk_sleep(sk), &wait); local
302 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); local
307 finish_wait(sk_sleep(sk), &wait); local
342 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
362 prepare_to_wait(sk_sleep(sk), &wait, local
365 finish_wait(sk_sleep(sk), &wait); local
439 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); local
446 finish_wait(sk_sleep(sk), &wait); local
543 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
548 finish_wait(sk_sleep(sk), &wait); local
566 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
571 finish_wait(sk_sleep(sk), &wait); local
[all...]
H A Dcommon.h20 unsigned int vcc_poll(struct file *file, struct socket *sock, poll_table *wait);
H A Dsignaling.c10 #include <linux/wait.h>
35 DECLARE_WAITQUEUE(wait, current);
37 add_wait_queue(&sigd_sleep, &wait);
44 remove_wait_queue(&sigd_sleep, &wait);
H A Dcommon.c100 wake_up(&wq->wait);
121 wake_up_interruptible(&wq->wait);
576 DEFINE_WAIT(wait);
616 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
635 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
637 finish_wait(sk_sleep(sk), &wait); local
656 unsigned int vcc_poll(struct file *file, struct socket *sock, poll_table *wait) argument
662 sock_poll_wait(file, sk_sleep(sk), wait);
/net/vmw_vsock/
H A Dvmci_transport.h80 struct vmci_transport_waiting_info wait; member in union:vmci_transport_packet::__anon175
138 struct vmci_transport_waiting_info *wait);
140 struct vmci_transport_waiting_info *wait);
H A Daf_vsock.c96 #include <linux/wait.h>
112 /* The default peer timeout indicates how long we will wait for a peer response
840 poll_table *wait)
849 poll_wait(file, sk_sleep(sk), wait);
1121 DEFINE_WAIT(wait);
1140 * will be set to zero also). Otherwise, we will either wait
1184 * enter the connected state. Here we wait for the connection to be
1188 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
1219 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
1229 finish_wait(sk_sleep(sk), &wait); local
839 vsock_poll(struct file *file, struct socket *sock, poll_table *wait) argument
1268 prepare_to_wait(sk_sleep(listener), &wait, TASK_INTERRUPTIBLE); local
1284 prepare_to_wait(sk_sleep(listener), &wait, TASK_INTERRUPTIBLE); local
1317 finish_wait(sk_sleep(listener), &wait); local
1592 prepare_to_wait(sk_sleep(sk), &wait, local
1639 finish_wait(sk_sleep(sk), &wait); local
1789 prepare_to_wait(sk_sleep(sk), &wait, local
1822 finish_wait(sk_sleep(sk), &wait); local
[all...]
H A Dvmci_transport.c34 #include <linux/wait.h>
88 /* The default peer timeout indicates how long we will wait for a peer response
141 struct vmci_transport_waiting_info *wait,
187 memcpy(&pkt->u.wait, wait, sizeof(pkt->u.wait));
214 struct vmci_transport_waiting_info *wait,
221 vmci_transport_packet_init(pkt, src, dst, type, size, mode, wait,
235 struct vmci_transport_waiting_info *wait,
247 size, mode, wait,
135 vmci_transport_packet_init(struct vmci_transport_packet *pkt, struct sockaddr_vm *src, struct sockaddr_vm *dst, u8 type, u64 size, u64 mode, struct vmci_transport_waiting_info *wait, u16 proto, struct vmci_handle handle) argument
208 __vmci_transport_send_control_pkt(struct vmci_transport_packet *pkt, struct sockaddr_vm *src, struct sockaddr_vm *dst, enum vmci_transport_packet_type type, u64 size, u64 mode, struct vmci_transport_waiting_info *wait, u16 proto, struct vmci_handle handle, bool convert_error) argument
231 vmci_transport_reply_control_pkt_fast(struct vmci_transport_packet *pkt, enum vmci_transport_packet_type type, u64 size, u64 mode, struct vmci_transport_waiting_info *wait, struct vmci_handle handle) argument
254 vmci_transport_send_control_pkt_bh(struct sockaddr_vm *src, struct sockaddr_vm *dst, enum vmci_transport_packet_type type, u64 size, u64 mode, struct vmci_transport_waiting_info *wait, struct vmci_handle handle) argument
276 vmci_transport_send_control_pkt(struct sock *sk, enum vmci_transport_packet_type type, u64 size, u64 mode, struct vmci_transport_waiting_info *wait, u16 proto, struct vmci_handle handle) argument
422 vmci_transport_send_waiting_write(struct sock *sk, struct vmci_transport_waiting_info *wait) argument
431 vmci_transport_send_waiting_read(struct sock *sk, struct vmci_transport_waiting_info *wait) argument
[all...]
/net/dccp/
H A Dprobe.c49 wait_queue_head_t wait; member in struct:__anon36
72 wake_up(&dccpw.wait);
134 error = wait_event_interruptible(dccpw.wait,
159 init_waitqueue_head(&dccpw.wait);
/net/bluetooth/
H A Daf_bluetooth.c286 DECLARE_WAITQUEUE(wait, current);
288 add_wait_queue(sk_sleep(sk), &wait); local
309 remove_wait_queue(sk_sleep(sk), &wait); local
435 poll_table *wait)
442 poll_wait(file, sk_sleep(sk), wait);
528 DECLARE_WAITQUEUE(wait, current);
533 add_wait_queue(sk_sleep(sk), &wait); local
556 remove_wait_queue(sk_sleep(sk), &wait); local
564 DECLARE_WAITQUEUE(wait, current);
572 add_wait_queue(sk_sleep(sk), &wait); local
434 bt_sock_poll(struct file *file, struct socket *sock, poll_table *wait) argument
595 remove_wait_queue(sk_sleep(sk), &wait); local
[all...]
/net/bluetooth/cmtp/
H A Dcapi.c37 #include <linux/wait.h>
212 wake_up_interruptible(&session->wait);
224 wake_up_interruptible(&session->wait);
238 wake_up_interruptible(&session->wait);
389 DECLARE_WAITQUEUE(wait, current);
423 add_wait_queue(&session->wait, &wait);
448 remove_wait_queue(&session->wait, &wait);
474 wait_event_interruptible_timeout(session->wait,
[all...]
H A Dcmtp.h87 wait_queue_head_t wait; member in struct:cmtp_session
H A Dcore.c283 wait_queue_t wait; local
289 init_waitqueue_entry(&wait, current);
290 add_wait_queue(sk_sleep(sk), &wait); local
312 remove_wait_queue(sk_sleep(sk), &wait); local
361 init_waitqueue_head(&session->wait);
/net/ipv4/
H A Dtcp_probe.c78 wait_queue_head_t wait; member in struct:__anon55
162 wake_up(&tcp_probe.wait);
215 error = wait_event_interruptible(tcp_probe.wait,
265 init_waitqueue_head(&tcp_probe.wait);
/net/netlink/
H A Daf_netlink.h36 wait_queue_head_t wait; member in struct:netlink_sock
/net/sctp/
H A Dprobe.c67 wait_queue_head_t wait; member in struct:__anon162
82 wake_up(&sctpw.wait);
109 error = wait_event_interruptible(sctpw.wait,
211 init_waitqueue_head(&sctpw.wait);
/net/caif/
H A Dcaif_socket.c16 #include <linux/wait.h>
314 DEFINE_WAIT(wait);
318 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
340 finish_wait(sk_sleep(sk), &wait); local
465 * Copied from sock.c:sock_wait_for_wmem, but change to wait for
472 DEFINE_WAIT(wait);
484 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
496 finish_wait(sk_sleep(sk), &wait); local
938 struct socket *sock, poll_table *wait)
944 sock_poll_wait(file, sk_sleep(sk), wait);
937 caif_poll(struct file *file, struct socket *sock, poll_table *wait) argument
[all...]
/net/llc/
H A Daf_llc.c535 DEFINE_WAIT(wait);
539 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
550 finish_wait(sk_sleep(sk), &wait); local
556 DEFINE_WAIT(wait);
559 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
565 finish_wait(sk_sleep(sk), &wait); local
571 DEFINE_WAIT(wait);
576 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
591 finish_wait(sk_sleep(sk), &wait); local
661 /* wait fo
[all...]
/net/rxrpc/
H A Dar-recvmsg.c57 DEFINE_WAIT(wait);
93 /* wait for a message to turn up */
95 prepare_to_wait_exclusive(sk_sleep(&rx->sk), &wait,
106 finish_wait(sk_sleep(&rx->sk), &wait);
118 /* make sure we wait for the state to be updated in this call */
345 finish_wait(sk_sleep(&rx->sk), &wait);
/net/nfc/
H A Dllcp_sock.c30 DECLARE_WAITQUEUE(wait, current);
35 add_wait_queue(sk_sleep(sk), &wait); local
60 remove_wait_queue(sk_sleep(sk), &wait); local
445 DECLARE_WAITQUEUE(wait, current);
462 add_wait_queue_exclusive(sk_sleep(sk), &wait); local
481 remove_wait_queue(sk_sleep(sk), &wait); local
544 poll_table *wait)
551 sock_poll_wait(file, sk_sleep(sk), wait);
543 llcp_sock_poll(struct file *file, struct socket *sock, poll_table *wait) argument
/net/decnet/
H A Daf_decnet.c823 DEFINE_WAIT(wait);
833 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
851 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
853 finish_wait(sk_sleep(sk), &wait); local
865 DEFINE_WAIT(wait);
874 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE);
892 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
894 finish_wait(sk_sleep(sk), &wait); local
1039 DEFINE_WAIT(wait);
1043 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBL local
1063 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
1065 finish_wait(sk_sleep(sk), &wait); local
1208 dn_poll(struct file *file, struct socket *sock, poll_table *wait) argument
1749 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
1753 finish_wait(sk_sleep(sk), &wait); local
2007 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
2012 finish_wait(sk_sleep(sk), &wait); local
[all...]
/net/rds/
H A Dib_rdma.c585 DEFINE_WAIT(wait);
590 finish_wait(&pool->flush_wait, &wait);
594 prepare_to_wait(&pool->flush_wait, &wait,
602 finish_wait(&pool->flush_wait, &wait);
606 finish_wait(&pool->flush_wait, &wait);
660 * This is pretty unlikely, but just in case wait for an llist grace period
/net/tipc/
H A Dsocket.c72 * @conn_timeout: the time we can wait for an unresponded setup request
623 * @wait: ???
660 poll_table *wait)
666 sock_poll_wait(file, sk_sleep(sk), wait);
697 * @timeo: timeout to wait for wakeup
858 DEFINE_WAIT(wait);
872 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE);
874 finish_wait(sk_sleep(sk), &wait); local
1010 DEFINE_WAIT(wait);
1026 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBL
659 tipc_poll(struct file *file, struct socket *sock, poll_table *wait) argument
1031 finish_wait(sk_sleep(sk), &wait); local
1281 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); local
1301 finish_wait(sk_sleep(sk), &wait); local
1819 finish_wait(sk_sleep(sk), &wait); local
1942 prepare_to_wait_exclusive(sk_sleep(sk), &wait, local
1962 finish_wait(sk_sleep(sk), &wait); local
[all...]
/net/9p/
H A Dtrans_fd.c98 wait_queue_t wait; member in struct:p9_poll_wait
180 remove_wait_queue(pwait->wait_addr, &pwait->wait);
521 static int p9_pollwake(wait_queue_t *wait, unsigned int mode, int sync, void *key) argument
524 container_of(wait, struct p9_poll_wait, wait);
538 * p9_pollwait - add poll task to the wait queue
543 * called by files poll operation to add v9fs-poll task to files wait queue
567 init_waitqueue_func_entry(&pwait->wait, p9_pollwake);
568 add_wait_queue(wait_address, &pwait->wait);

Completed in 232 milliseconds

1234