| /net/sunrpc/ |
| D | sched.c | 289 wait_queue_head_t *wq = bit_waitqueue(m, RPC_TASK_ACTIVE); in rpc_complete_task() local
296 spin_lock_irqsave(&wq->lock, flags); in rpc_complete_task()
299 if (waitqueue_active(wq)) in rpc_complete_task()
300 __wake_up_locked_key(wq, TASK_NORMAL, &k); in rpc_complete_task()
301 spin_unlock_irqrestore(&wq->lock, flags); in rpc_complete_task()
332 static void rpc_make_runnable(struct workqueue_struct *wq, in rpc_make_runnable() argument
342 queue_work(wq, &task->u.tk_work); in rpc_make_runnable()
418 static void __rpc_do_wake_up_task_on_wq(struct workqueue_struct *wq, in __rpc_do_wake_up_task_on_wq() argument
435 rpc_make_runnable(wq, task); in __rpc_do_wake_up_task_on_wq()
443 static void rpc_wake_up_task_on_wq_queue_locked(struct workqueue_struct *wq, in rpc_wake_up_task_on_wq_queue_locked() argument
[all …]
|
| D | xprtsock.c | 477 struct socket_wq *wq; in xs_nospace() local
480 wq = rcu_dereference(sk->sk_wq); in xs_nospace()
481 set_bit(SOCKWQ_ASYNC_NOSPACE, &wq->flags); in xs_nospace()
1630 struct socket_wq *wq; in xs_write_space() local
1640 wq = rcu_dereference(sk->sk_wq); in xs_write_space()
1641 if (!wq || test_and_clear_bit(SOCKWQ_ASYNC_NOSPACE, &wq->flags) == 0) in xs_write_space()
|
| /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 (skwq_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()
42 sock_wake_async(wq, SOCK_WAKE_SPACE, POLL_OUT); in sk_stream_write_space()
|
| D | sock.c | 2032 prepare_to_wait_exclusive(&sk->sk_lock.wq, &wait, in __lock_sock()
2040 finish_wait(&sk->sk_lock.wq, &wait); in __lock_sock()
2346 struct socket_wq *wq; in sock_def_wakeup() local
2349 wq = rcu_dereference(sk->sk_wq); in sock_def_wakeup()
2350 if (skwq_has_sleeper(wq)) in sock_def_wakeup()
2351 wake_up_interruptible_all(&wq->wait); in sock_def_wakeup()
2357 struct socket_wq *wq; in sock_def_error_report() local
2360 wq = rcu_dereference(sk->sk_wq); in sock_def_error_report()
2361 if (skwq_has_sleeper(wq)) in sock_def_error_report()
2362 wake_up_interruptible_poll(&wq->wait, POLLERR); in sock_def_error_report()
[all …]
|
| /net/ |
| D | socket.c | 248 struct socket_wq *wq; in sock_alloc_inode() local
253 wq = kmalloc(sizeof(*wq), GFP_KERNEL); in sock_alloc_inode()
254 if (!wq) { in sock_alloc_inode()
258 init_waitqueue_head(&wq->wait); in sock_alloc_inode()
259 wq->fasync_list = NULL; in sock_alloc_inode()
260 wq->flags = 0; in sock_alloc_inode()
261 RCU_INIT_POINTER(ei->socket.wq, wq); in sock_alloc_inode()
275 struct socket_wq *wq; in sock_destroy_inode() local
278 wq = rcu_dereference_protected(ei->socket.wq, 1); in sock_destroy_inode()
279 kfree_rcu(wq, rcu); in sock_destroy_inode()
[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 (skwq_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 (skwq_has_sleeper(wq)) in vcc_write_space()
121 wake_up_interruptible(&wq->wait); in vcc_write_space()
|
| /net/9p/ |
| D | trans_fd.c | 140 struct work_struct wq; member
455 m = container_of(work, struct p9_conn, wq); in p9_write_work()
514 schedule_work(&m->wq); in p9_write_work()
596 INIT_WORK(&m->wq, p9_write_work); in p9_conn_create()
648 schedule_work(&m->wq); in p9_poll_mux()
686 schedule_work(&m->wq); in p9_fd_request()
857 cancel_work_sync(&m->wq); in p9_conn_destroy()
|
| D | client.c | 271 if (!req->wq) { in p9_tag_alloc()
272 req->wq = kmalloc(sizeof(wait_queue_head_t), GFP_NOFS); in p9_tag_alloc()
273 if (!req->wq) in p9_tag_alloc()
275 init_waitqueue_head(req->wq); in p9_tag_alloc()
297 kfree(req->wq); in p9_tag_alloc()
299 req->wq = NULL; in p9_tag_alloc()
387 kfree(c->reqs[row][col].wq); in p9_tag_cleanup()
430 wake_up(req->wq); in p9_client_cb()
752 err = wait_event_killable(*req->wq, req->status >= REQ_STATUS_RCVD); in p9_client_rpc()
|
| D | trans_virtio.c | 493 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 (skwq_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 | 70 struct socket_wq *wq = rcu_dereference(sk->sk_wq); in rxrpc_write_space() local
72 if (skwq_has_sleeper(wq)) in rxrpc_write_space()
73 wake_up_interruptible(&wq->wait); in rxrpc_write_space()
|
| /net/tipc/ |
| D | socket.c | 1493 struct socket_wq *wq; in tipc_write_space() local
1496 wq = rcu_dereference(sk->sk_wq); in tipc_write_space()
1497 if (skwq_has_sleeper(wq)) in tipc_write_space()
1498 wake_up_interruptible_sync_poll(&wq->wait, POLLOUT | in tipc_write_space()
1510 struct socket_wq *wq; in tipc_data_ready() local
1513 wq = rcu_dereference(sk->sk_wq); in tipc_data_ready()
1514 if (skwq_has_sleeper(wq)) in tipc_data_ready()
1515 wake_up_interruptible_sync_poll(&wq->wait, POLLIN | in tipc_data_ready()
|
| /net/sunrpc/xprtrdma/ |
| D | verbs.c | 92 struct workqueue_struct *wq; in rpcrdma_destroy_wq() local
95 wq = rpcrdma_receive_wq; in rpcrdma_destroy_wq()
97 destroy_workqueue(wq); in rpcrdma_destroy_wq()
|
| /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 (skwq_has_sleeper(wq)) in iucv_sock_wake_msglim()
308 wake_up_interruptible_all(&wq->wait); in iucv_sock_wake_msglim()
|
| /net/sctp/ |
| D | socket.c | 7350 struct socket_wq *wq; in __sctp_write_space() local
7353 wq = rcu_dereference(sk->sk_wq); in __sctp_write_space()
7354 if (wq) { in __sctp_write_space()
7355 if (waitqueue_active(&wq->wait)) in __sctp_write_space()
7356 wake_up_interruptible(&wq->wait); in __sctp_write_space()
7363 sock_wake_async(wq, SOCK_WAKE_SPACE, POLL_OUT); in __sctp_write_space()
7525 struct socket_wq *wq; in sctp_data_ready() local
7528 wq = rcu_dereference(sk->sk_wq); in sctp_data_ready()
7529 if (skwq_has_sleeper(wq)) in sctp_data_ready()
7530 wake_up_interruptible_sync_poll(&wq->wait, POLLIN | in sctp_data_ready()
|
| /net/unix/ |
| D | af_unix.c | 449 struct socket_wq *wq; in unix_write_space() local
453 wq = rcu_dereference(sk->sk_wq); in unix_write_space()
454 if (skwq_has_sleeper(wq)) in unix_write_space()
455 wake_up_interruptible_sync_poll(&wq->wait, in unix_write_space()
|