| /net/core/ |
| D | stream.c | 31 struct socket_wq *wq; in sk_stream_write_space() local
37 wq = rcu_dereference(sk->sk_wq); in sk_stream_write_space()
38 if (wq_has_sleeper(wq)) in sk_stream_write_space()
39 wake_up_interruptible_poll(&wq->wait, POLLOUT | in sk_stream_write_space()
41 if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN)) in sk_stream_write_space()
|
| D | sock.c | 1904 prepare_to_wait_exclusive(&sk->sk_lock.wq, &wait, in __lock_sock()
1912 finish_wait(&sk->sk_lock.wq, &wait); in __lock_sock()
2201 struct socket_wq *wq; in sock_def_wakeup() local
2204 wq = rcu_dereference(sk->sk_wq); in sock_def_wakeup()
2205 if (wq_has_sleeper(wq)) in sock_def_wakeup()
2206 wake_up_interruptible_all(&wq->wait); in sock_def_wakeup()
2212 struct socket_wq *wq; in sock_def_error_report() local
2215 wq = rcu_dereference(sk->sk_wq); in sock_def_error_report()
2216 if (wq_has_sleeper(wq)) in sock_def_error_report()
2217 wake_up_interruptible_poll(&wq->wait, POLLERR); in sock_def_error_report()
[all …]
|
| /net/sunrpc/ |
| D | svcsock.c | 408 wait_queue_head_t *wq = sk_sleep(sk); in svc_udp_data_ready() local
417 if (wq && waitqueue_active(wq)) in svc_udp_data_ready()
418 wake_up_interruptible(wq); in svc_udp_data_ready()
427 wait_queue_head_t *wq = sk_sleep(sk); in svc_write_space() local
435 if (wq && waitqueue_active(wq)) { in svc_write_space()
438 wake_up_interruptible(wq); in svc_write_space()
766 wait_queue_head_t *wq; in svc_tcp_listen_data_ready() local
789 wq = sk_sleep(sk); in svc_tcp_listen_data_ready()
790 if (wq && waitqueue_active(wq)) in svc_tcp_listen_data_ready()
791 wake_up_interruptible_all(wq); in svc_tcp_listen_data_ready()
[all …]
|
| D | sched.c | 288 wait_queue_head_t *wq = bit_waitqueue(m, RPC_TASK_ACTIVE); in rpc_complete_task() local
295 spin_lock_irqsave(&wq->lock, flags); in rpc_complete_task()
298 if (waitqueue_active(wq)) in rpc_complete_task()
299 __wake_up_locked_key(wq, TASK_NORMAL, &k); in rpc_complete_task()
300 spin_unlock_irqrestore(&wq->lock, flags); in rpc_complete_task()
1065 struct workqueue_struct *wq; in rpciod_start() local
1071 wq = alloc_workqueue("rpciod", WQ_MEM_RECLAIM, 1); in rpciod_start()
1072 rpciod_workqueue = wq; in rpciod_start()
1078 struct workqueue_struct *wq = NULL; in rpciod_stop() local
1084 wq = rpciod_workqueue; in rpciod_stop()
[all …]
|
| /net/ |
| D | socket.c | 252 struct socket_wq *wq; in sock_alloc_inode() local
257 wq = kmalloc(sizeof(*wq), GFP_KERNEL); in sock_alloc_inode()
258 if (!wq) { in sock_alloc_inode()
262 init_waitqueue_head(&wq->wait); in sock_alloc_inode()
263 wq->fasync_list = NULL; in sock_alloc_inode()
264 RCU_INIT_POINTER(ei->socket.wq, wq); in sock_alloc_inode()
278 struct socket_wq *wq; in sock_destroy_inode() local
281 wq = rcu_dereference_protected(ei->socket.wq, 1); in sock_destroy_inode()
282 kfree_rcu(wq, rcu); in sock_destroy_inode()
612 if (rcu_dereference_protected(sock->wq, 1)->fasync_list) in sock_release()
[all …]
|
| /net/atm/ |
| D | common.c | 95 struct socket_wq *wq; in vcc_def_wakeup() local
98 wq = rcu_dereference(sk->sk_wq); in vcc_def_wakeup()
99 if (wq_has_sleeper(wq)) in vcc_def_wakeup()
100 wake_up(&wq->wait); in vcc_def_wakeup()
114 struct socket_wq *wq; in vcc_write_space() local
119 wq = rcu_dereference(sk->sk_wq); in vcc_write_space()
120 if (wq_has_sleeper(wq)) in vcc_write_space()
121 wake_up_interruptible(&wq->wait); in vcc_write_space()
|
| /net/9p/ |
| D | trans_fd.c | 144 struct work_struct wq; member
451 m = container_of(work, struct p9_conn, wq); in p9_write_work()
510 schedule_work(&m->wq); in p9_write_work()
592 INIT_WORK(&m->wq, p9_write_work); in p9_conn_create()
644 schedule_work(&m->wq); in p9_poll_mux()
682 schedule_work(&m->wq); in p9_fd_request()
852 cancel_work_sync(&m->wq); in p9_conn_destroy()
|
| D | client.c | 270 if (!req->wq) { in p9_tag_alloc()
271 req->wq = kmalloc(sizeof(wait_queue_head_t), GFP_NOFS); in p9_tag_alloc()
272 if (!req->wq) in p9_tag_alloc()
274 init_waitqueue_head(req->wq); in p9_tag_alloc()
296 kfree(req->wq); in p9_tag_alloc()
298 req->wq = NULL; in p9_tag_alloc()
386 kfree(c->reqs[row][col].wq); in p9_tag_cleanup()
429 wake_up(req->wq); in p9_client_cb()
756 err = wait_event_killable(*req->wq, req->status >= REQ_STATUS_RCVD); in p9_client_rpc()
|
| D | trans_virtio.c | 475 err = wait_event_killable(*req->wq, req->status >= REQ_STATUS_RCVD); in p9_virtio_zc_request()
|
| /net/dccp/ |
| D | output.c | 200 struct socket_wq *wq; in dccp_write_space() local
203 wq = rcu_dereference(sk->sk_wq); in dccp_write_space()
204 if (wq_has_sleeper(wq)) in dccp_write_space()
205 wake_up_interruptible(&wq->wait); in dccp_write_space()
|
| /net/nfc/hci/ |
| D | command.c | 64 wake_up(hcp_ew->wq); in nfc_hci_execute_cb()
73 hcp_ew.wq = &ew_wq; in nfc_hci_execute_cmd()
|
| D | hci.h | 39 wait_queue_head_t *wq; member
|
| /net/rxrpc/ |
| D | af_rxrpc.c | 68 struct socket_wq *wq = rcu_dereference(sk->sk_wq); in rxrpc_write_space() local
70 if (wq_has_sleeper(wq)) in rxrpc_write_space()
71 wake_up_interruptible(&wq->wait); in rxrpc_write_space()
|
| /net/tipc/ |
| D | socket.c | 1527 struct socket_wq *wq; in tipc_write_space() local
1530 wq = rcu_dereference(sk->sk_wq); in tipc_write_space()
1531 if (wq_has_sleeper(wq)) in tipc_write_space()
1532 wake_up_interruptible_sync_poll(&wq->wait, POLLOUT | in tipc_write_space()
1544 struct socket_wq *wq; in tipc_data_ready() local
1547 wq = rcu_dereference(sk->sk_wq); in tipc_data_ready()
1548 if (wq_has_sleeper(wq)) in tipc_data_ready()
1549 wake_up_interruptible_sync_poll(&wq->wait, POLLIN | in tipc_data_ready()
|
| D | link.c | 355 struct sk_buff_head *wq = &link->waiting_sks; in link_prepare_wakeup() local
359 for (buf = skb_peek(wq); buf; buf = skb_peek(wq)) { in link_prepare_wakeup()
363 __skb_queue_tail(&link->owner->waiting_sks, __skb_dequeue(wq)); in link_prepare_wakeup()
|
| /net/iucv/ |
| D | af_iucv.c | 303 struct socket_wq *wq; in iucv_sock_wake_msglim() local
306 wq = rcu_dereference(sk->sk_wq); in iucv_sock_wake_msglim()
307 if (wq_has_sleeper(wq)) in iucv_sock_wake_msglim()
308 wake_up_interruptible_all(&wq->wait); in iucv_sock_wake_msglim()
|
| /net/unix/ |
| D | af_unix.c | 438 struct socket_wq *wq; in unix_write_space() local
442 wq = rcu_dereference(sk->sk_wq); in unix_write_space()
443 if (wq_has_sleeper(wq)) in unix_write_space()
444 wake_up_interruptible_sync_poll(&wq->wait, in unix_write_space()
|
| /net/sctp/ |
| D | socket.c | 6875 wait_queue_head_t *wq = sk_sleep(sk); in __sctp_write_space() local
6877 if (wq && waitqueue_active(wq)) in __sctp_write_space()
6878 wake_up_interruptible(wq); in __sctp_write_space()
7051 struct socket_wq *wq; in sctp_data_ready() local
7054 wq = rcu_dereference(sk->sk_wq); in sctp_data_ready()
7055 if (wq_has_sleeper(wq)) in sctp_data_ready()
7056 wake_up_interruptible_sync_poll(&wq->wait, POLLIN | in sctp_data_ready()
|