| /net/core/ |
| H A D | stream.c | 31 struct socket_wq *wq; local
37 wq = rcu_dereference(sk->sk_wq);
38 if (wq_has_sleeper(wq))
39 wake_up_interruptible_poll(&wq->wait, POLLOUT |
41 if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN))
|
| H A D | sock.c | 1873 prepare_to_wait_exclusive(&sk->sk_lock.wq, &wait,
1881 finish_wait(&sk->sk_lock.wq, &wait);
2170 struct socket_wq *wq; local
2173 wq = rcu_dereference(sk->sk_wq);
2174 if (wq_has_sleeper(wq))
2175 wake_up_interruptible_all(&wq->wait);
2181 struct socket_wq *wq; local
2184 wq = rcu_dereference(sk->sk_wq);
2185 if (wq_has_sleeper(wq))
2186 wake_up_interruptible_poll(&wq
2193 struct socket_wq *wq; local
2206 struct socket_wq *wq; local
[all...] |
| /net/dccp/ |
| H A D | output.c | 200 struct socket_wq *wq; local
203 wq = rcu_dereference(sk->sk_wq);
204 if (wq_has_sleeper(wq))
205 wake_up_interruptible(&wq->wait);
|
| /net/nfc/hci/ |
| H A D | hci.h | 39 wait_queue_head_t *wq; member in struct:hcp_exec_waiter
|
| /net/rxrpc/ |
| H A D | af_rxrpc.c | 68 struct socket_wq *wq = rcu_dereference(sk->sk_wq); local
70 if (wq_has_sleeper(wq))
71 wake_up_interruptible(&wq->wait);
|
| /net/atm/ |
| H A D | common.c | 95 struct socket_wq *wq; local
98 wq = rcu_dereference(sk->sk_wq);
99 if (wq_has_sleeper(wq))
100 wake_up(&wq->wait);
114 struct socket_wq *wq; local
119 wq = rcu_dereference(sk->sk_wq);
120 if (wq_has_sleeper(wq))
121 wake_up_interruptible(&wq->wait);
|
| /net/9p/ |
| H A D | trans_fd.c | 121 * @wq: current write work
144 struct work_struct wq; member in struct:p9_conn
451 m = container_of(work, struct p9_conn, wq);
510 schedule_work(&m->wq);
592 INIT_WORK(&m->wq, p9_write_work);
644 schedule_work(&m->wq);
682 schedule_work(&m->wq);
852 cancel_work_sync(&m->wq);
|
| /net/sunrpc/ |
| H A D | sched.c | 289 wait_queue_head_t *wq = bit_waitqueue(m, RPC_TASK_ACTIVE); local
296 spin_lock_irqsave(&wq->lock, flags);
299 if (waitqueue_active(wq))
300 __wake_up_locked_key(wq, TASK_NORMAL, &k);
301 spin_unlock_irqrestore(&wq->lock, flags);
309 * to enforce taking of the wq->lock and hence avoid races with
1066 struct workqueue_struct *wq; local
1072 wq = alloc_workqueue("rpciod", WQ_MEM_RECLAIM, 1);
1073 rpciod_workqueue = wq;
1079 struct workqueue_struct *wq local
[all...] |
| H A D | svcsock.c | 408 wait_queue_head_t *wq = sk_sleep(sk); local
417 if (wq && waitqueue_active(wq))
418 wake_up_interruptible(wq);
427 wait_queue_head_t *wq = sk_sleep(sk); local
435 if (wq && waitqueue_active(wq)) {
438 wake_up_interruptible(wq);
766 wait_queue_head_t *wq; local
789 wq
800 wait_queue_head_t *wq = sk_sleep(sk); local
818 wait_queue_head_t *wq = sk_sleep(sk); local
1584 wait_queue_head_t *wq; local
[all...] |
| /net/iucv/ |
| H A D | af_iucv.c | 303 struct socket_wq *wq; local
306 wq = rcu_dereference(sk->sk_wq);
307 if (wq_has_sleeper(wq))
308 wake_up_interruptible_all(&wq->wait);
|
| /net/tipc/ |
| H A D | link.c | 355 struct sk_buff_head *wq = &link->waiting_sks; local
359 for (buf = skb_peek(wq); buf; buf = skb_peek(wq)) {
363 __skb_queue_tail(&link->owner->waiting_sks, __skb_dequeue(wq));
|
| H A D | socket.c | 1527 struct socket_wq *wq; local
1530 wq = rcu_dereference(sk->sk_wq);
1531 if (wq_has_sleeper(wq))
1532 wake_up_interruptible_sync_poll(&wq->wait, POLLOUT |
1544 struct socket_wq *wq; local
1547 wq = rcu_dereference(sk->sk_wq);
1548 if (wq_has_sleeper(wq))
1549 wake_up_interruptible_sync_poll(&wq->wait, POLLIN |
|
| /net/unix/ |
| H A D | af_unix.c | 326 struct socket_wq *wq; local
330 wq = rcu_dereference(sk->sk_wq);
331 if (wq_has_sleeper(wq))
332 wake_up_interruptible_sync_poll(&wq->wait,
|
| /net/sctp/ |
| H A D | socket.c | 6811 wait_queue_head_t *wq = sk_sleep(sk); local
6813 if (wq && waitqueue_active(wq))
6814 wake_up_interruptible(wq);
6981 struct socket_wq *wq; local
6984 wq = rcu_dereference(sk->sk_wq);
6985 if (wq_has_sleeper(wq))
6986 wake_up_interruptible_sync_poll(&wq->wait, POLLIN |
|
| /net/ |
| H A D | socket.c | 252 struct socket_wq *wq; local
257 wq = kmalloc(sizeof(*wq), GFP_KERNEL);
258 if (!wq) {
262 init_waitqueue_head(&wq->wait);
263 wq->fasync_list = NULL;
264 RCU_INIT_POINTER(ei->socket.wq, wq);
278 struct socket_wq *wq; local
281 wq
1199 struct socket_wq *wq; local
1221 struct socket_wq *wq; local
[all...] |