| /net/sunrpc/ |
| D | sched.c | 297 wait_queue_head_t *wq = bit_waitqueue(m, RPC_TASK_ACTIVE); in rpc_complete_task() local
304 spin_lock_irqsave(&wq->lock, flags); in rpc_complete_task()
307 if (waitqueue_active(wq)) in rpc_complete_task()
308 __wake_up_locked_key(wq, TASK_NORMAL, &k); in rpc_complete_task()
309 spin_unlock_irqrestore(&wq->lock, flags); in rpc_complete_task()
340 static void rpc_make_runnable(struct workqueue_struct *wq, in rpc_make_runnable() argument
350 queue_work(wq, &task->u.tk_work); in rpc_make_runnable()
485 static void __rpc_do_wake_up_task_on_wq(struct workqueue_struct *wq, in __rpc_do_wake_up_task_on_wq() argument
499 rpc_make_runnable(wq, task); in __rpc_do_wake_up_task_on_wq()
506 rpc_wake_up_task_on_wq_queue_action_locked(struct workqueue_struct *wq, in rpc_wake_up_task_on_wq_queue_action_locked() argument
[all …]
|
| D | xprtsock.c | 782 struct socket_wq *wq; in xs_nospace() local
785 wq = rcu_dereference(sk->sk_wq); in xs_nospace()
786 set_bit(SOCKWQ_ASYNC_NOSPACE, &wq->flags); in xs_nospace()
1514 struct socket_wq *wq; in xs_write_space() local
1526 wq = rcu_dereference(sk->sk_wq); in xs_write_space()
1527 if (!wq || test_and_clear_bit(SOCKWQ_ASYNC_NOSPACE, &wq->flags) == 0) in xs_write_space()
|
| /net/core/ |
| D | stream.c | 33 struct socket_wq *wq; in sk_stream_write_space() local
39 wq = rcu_dereference(sk->sk_wq); in sk_stream_write_space()
40 if (skwq_has_sleeper(wq)) in sk_stream_write_space()
41 wake_up_interruptible_poll(&wq->wait, EPOLLOUT | in sk_stream_write_space()
43 if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN)) in sk_stream_write_space()
44 sock_wake_async(wq, SOCK_WAKE_SPACE, POLL_OUT); in sk_stream_write_space()
|
| D | sock.c | 2692 prepare_to_wait_exclusive(&sk->sk_lock.wq, &wait, in __lock_sock()
2700 finish_wait(&sk->sk_lock.wq, &wait); in __lock_sock()
3059 struct socket_wq *wq; in sock_def_wakeup() local
3062 wq = rcu_dereference(sk->sk_wq); in sock_def_wakeup()
3063 if (skwq_has_sleeper(wq)) in sock_def_wakeup()
3064 wake_up_interruptible_all(&wq->wait); in sock_def_wakeup()
3070 struct socket_wq *wq; in sock_def_error_report() local
3073 wq = rcu_dereference(sk->sk_wq); in sock_def_error_report()
3074 if (skwq_has_sleeper(wq)) in sock_def_error_report()
3075 wake_up_interruptible_poll(&wq->wait, EPOLLERR); in sock_def_error_report()
[all …]
|
| D | page_pool.c | 695 static void page_pool_release_retry(struct work_struct *wq) in page_pool_release_retry() argument
697 struct delayed_work *dwq = to_delayed_work(wq); in page_pool_release_retry()
|
| /net/smc/ |
| D | smc_tx.c | 45 struct socket_wq *wq; in smc_tx_write_space() local
53 wq = rcu_dereference(sk->sk_wq); in smc_tx_write_space()
54 if (skwq_has_sleeper(wq)) in smc_tx_write_space()
55 wake_up_interruptible_poll(&wq->wait, in smc_tx_write_space()
58 if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN)) in smc_tx_write_space()
59 sock_wake_async(wq, SOCK_WAKE_SPACE, POLL_OUT); in smc_tx_write_space()
|
| D | smc_rx.c | 31 struct socket_wq *wq; in smc_rx_wake_up() local
36 wq = rcu_dereference(sk->sk_wq); in smc_rx_wake_up()
37 if (skwq_has_sleeper(wq)) in smc_rx_wake_up()
38 wake_up_interruptible_sync_poll(&wq->wait, EPOLLIN | EPOLLPRI | in smc_rx_wake_up()
|
| D | af_smc.c | 564 struct socket_wq *wq; in smc_fback_wakeup_waitqueue() local
567 wq = rcu_dereference(smc->sk.sk_wq); in smc_fback_wakeup_waitqueue()
568 if (!skwq_has_sleeper(wq)) in smc_fback_wakeup_waitqueue()
574 wake_up_interruptible_all(&wq->wait); in smc_fback_wakeup_waitqueue()
579 wake_up_interruptible_sync_poll(&wq->wait, flags); in smc_fback_wakeup_waitqueue()
582 wake_up_interruptible_poll(&wq->wait, flags); in smc_fback_wakeup_waitqueue()
601 struct socket_wq *wq; in smc_fback_forward_wakeup() local
606 wq = rcu_dereference(clcsk->sk_wq); in smc_fback_forward_wakeup()
607 if (!wq) in smc_fback_forward_wakeup()
679 smc->clcsock->wq.fasync_list = in smc_switch_to_fallback()
[all …]
|
| /net/atm/ |
| D | common.c | 91 struct socket_wq *wq; in vcc_def_wakeup() local
94 wq = rcu_dereference(sk->sk_wq); in vcc_def_wakeup()
95 if (skwq_has_sleeper(wq)) in vcc_def_wakeup()
96 wake_up(&wq->wait); in vcc_def_wakeup()
110 struct socket_wq *wq; in vcc_write_space() local
115 wq = rcu_dereference(sk->sk_wq); in vcc_write_space()
116 if (skwq_has_sleeper(wq)) in vcc_write_space()
117 wake_up_interruptible(&wq->wait); in vcc_write_space()
|
| /net/9p/ |
| D | trans_fd.c | 134 struct work_struct wq; member
455 m = container_of(work, struct p9_conn, wq); in p9_write_work()
519 schedule_work(&m->wq); in p9_write_work()
602 INIT_WORK(&m->wq, p9_write_work); in p9_conn_create()
653 schedule_work(&m->wq); in p9_poll_mux()
691 schedule_work(&m->wq); in p9_fd_request()
916 cancel_work_sync(&m->wq); in p9_conn_destroy()
|
| D | trans_xen.c | 69 wait_queue_head_t wq; member
161 while (wait_event_killable(ring->wq, in p9_xen_request()
272 wake_up_interruptible(&ring->wq); in xen_9pfs_front_event_handler()
349 init_waitqueue_head(&ring->wq); in xen_9pfs_front_alloc_dataring()
|
| D | trans_virtio.c | 505 err = wait_event_killable(req->wq, req->status >= REQ_STATUS_RCVD); in p9_virtio_zc_request()
|
| D | client.c | 289 init_waitqueue_head(&req->wq); in p9_tag_alloc()
431 wake_up(&req->wq); in p9_client_cb()
762 err = wait_event_killable(req->wq, req->status >= REQ_STATUS_RCVD); in p9_client_rpc()
|
| /net/dccp/ |
| D | output.c | 199 struct socket_wq *wq; in dccp_write_space() local
202 wq = rcu_dereference(sk->sk_wq); in dccp_write_space()
203 if (skwq_has_sleeper(wq)) in dccp_write_space()
204 wake_up_interruptible(&wq->wait); in dccp_write_space()
|
| /net/ |
| D | socket.c | 306 init_waitqueue_head(&ei->socket.wq.wait); in sock_alloc_inode()
307 ei->socket.wq.fasync_list = NULL; in sock_alloc_inode()
308 ei->socket.wq.flags = 0; in sock_alloc_inode()
657 if (sock->wq.fasync_list) in __sock_release()
1355 struct socket_wq *wq = &sock->wq; in sock_fasync() local
1361 fasync_helper(fd, filp, on, &wq->fasync_list); in sock_fasync()
1363 if (!wq->fasync_list) in sock_fasync()
1374 int sock_wake_async(struct socket_wq *wq, int how, int band) in sock_wake_async() argument
1376 if (!wq || !wq->fasync_list) in sock_wake_async()
1381 if (test_bit(SOCKWQ_ASYNC_WAITDATA, &wq->flags)) in sock_wake_async()
[all …]
|
| /net/tipc/ |
| D | crypto.c | 212 struct workqueue_struct *wq; member
1422 if (queue_delayed_work(tx->wq, &rx->work, delay)) in tipc_crypto_key_synch()
1483 c->wq = alloc_ordered_workqueue("tipc_crypto", 0); in tipc_crypto_start()
1484 if (!c->wq) { in tipc_crypto_start()
1493 if (c->wq) in tipc_crypto_start()
1494 destroy_workqueue(c->wq); in tipc_crypto_start()
1536 destroy_workqueue(c->wq); in tipc_crypto_stop()
2344 if (likely(skey && queue_delayed_work(tx->wq, &rx->work, 0))) in tipc_crypto_key_rcv()
2405 if (resched && queue_delayed_work(tx->wq, &rx->work, delay)) in tipc_crypto_work_rx()
2433 queue_delayed_work(tx->wq, &tx->work, msecs_to_jiffies(delay)); in tipc_crypto_rekeying_sched()
|
| D | socket.c | 2115 struct socket_wq *wq; in tipc_write_space() local
2118 wq = rcu_dereference(sk->sk_wq); in tipc_write_space()
2119 if (skwq_has_sleeper(wq)) in tipc_write_space()
2120 wake_up_interruptible_sync_poll(&wq->wait, EPOLLOUT | in tipc_write_space()
2131 struct socket_wq *wq; in tipc_data_ready() local
2134 wq = rcu_dereference(sk->sk_wq); in tipc_data_ready()
2135 if (skwq_has_sleeper(wq)) in tipc_data_ready()
2136 wake_up_interruptible_sync_poll(&wq->wait, EPOLLIN | in tipc_data_ready()
|
| /net/nfc/hci/ |
| D | command.c | 52 wake_up(hcp_ew->wq); in nfc_hci_execute_cb()
61 hcp_ew.wq = &ew_wq; in nfc_hci_execute_cmd()
|
| D | hci.h | 27 wait_queue_head_t *wq; member
|
| /net/rxrpc/ |
| D | af_rxrpc.c | 64 struct socket_wq *wq = rcu_dereference(sk->sk_wq); in rxrpc_write_space() local
66 if (skwq_has_sleeper(wq)) in rxrpc_write_space()
67 wake_up_interruptible(&wq->wait); in rxrpc_write_space()
|
| /net/mptcp/ |
| D | subflow.c | 1638 struct socket_wq *wq; in __subflow_state_change() local
1641 wq = rcu_dereference(sk->sk_wq); in __subflow_state_change()
1642 if (skwq_has_sleeper(wq)) in __subflow_state_change()
1643 wake_up_interruptible_all(&wq->wait); in __subflow_state_change()
|
| D | protocol.c | 3142 rcu_assign_pointer(sk->sk_wq, &parent->wq); in mptcp_sock_graft()
|
| /net/iucv/ |
| D | af_iucv.c | 180 struct socket_wq *wq; in iucv_sock_wake_msglim() local
183 wq = rcu_dereference(sk->sk_wq); in iucv_sock_wake_msglim()
184 if (skwq_has_sleeper(wq)) in iucv_sock_wake_msglim()
185 wake_up_interruptible_all(&wq->wait); in iucv_sock_wake_msglim()
|
| /net/sctp/ |
| D | socket.c | 9087 struct socket_wq *wq; in __sctp_write_space() local
9090 wq = rcu_dereference(sk->sk_wq); in __sctp_write_space()
9091 if (wq) { in __sctp_write_space()
9092 if (waitqueue_active(&wq->wait)) in __sctp_write_space()
9093 wake_up_interruptible(&wq->wait); in __sctp_write_space()
9100 sock_wake_async(wq, SOCK_WAKE_SPACE, POLL_OUT); in __sctp_write_space()
9279 struct socket_wq *wq; in sctp_data_ready() local
9282 wq = rcu_dereference(sk->sk_wq); in sctp_data_ready()
9283 if (skwq_has_sleeper(wq)) in sctp_data_ready()
9284 wake_up_interruptible_sync_poll(&wq->wait, EPOLLIN | in sctp_data_ready()
|
| /net/unix/ |
| D | af_unix.c | 466 struct socket_wq *wq; in unix_write_space() local
470 wq = rcu_dereference(sk->sk_wq); in unix_write_space()
471 if (skwq_has_sleeper(wq)) in unix_write_space()
472 wake_up_interruptible_sync_poll(&wq->wait, in unix_write_space()
|