diff options
Diffstat (limited to 'net')
-rw-r--r-- | net/atm/common.c | 4 | ||||
-rw-r--r-- | net/core/sock.c | 8 | ||||
-rw-r--r-- | net/core/stream.c | 2 | ||||
-rw-r--r-- | net/dccp/output.c | 2 | ||||
-rw-r--r-- | net/iucv/af_iucv.c | 2 | ||||
-rw-r--r-- | net/rxrpc/af_rxrpc.c | 2 | ||||
-rw-r--r-- | net/sctp/socket.c | 2 | ||||
-rw-r--r-- | net/tipc/socket.c | 4 | ||||
-rw-r--r-- | net/unix/af_unix.c | 2 |
9 files changed, 14 insertions, 14 deletions
diff --git a/net/atm/common.c b/net/atm/common.c index 49a872db7e42..6dc12305799e 100644 --- a/net/atm/common.c +++ b/net/atm/common.c | |||
@@ -96,7 +96,7 @@ static void vcc_def_wakeup(struct sock *sk) | |||
96 | 96 | ||
97 | rcu_read_lock(); | 97 | rcu_read_lock(); |
98 | wq = rcu_dereference(sk->sk_wq); | 98 | wq = rcu_dereference(sk->sk_wq); |
99 | if (wq_has_sleeper(wq)) | 99 | if (skwq_has_sleeper(wq)) |
100 | wake_up(&wq->wait); | 100 | wake_up(&wq->wait); |
101 | rcu_read_unlock(); | 101 | rcu_read_unlock(); |
102 | } | 102 | } |
@@ -117,7 +117,7 @@ static void vcc_write_space(struct sock *sk) | |||
117 | 117 | ||
118 | if (vcc_writable(sk)) { | 118 | if (vcc_writable(sk)) { |
119 | wq = rcu_dereference(sk->sk_wq); | 119 | wq = rcu_dereference(sk->sk_wq); |
120 | if (wq_has_sleeper(wq)) | 120 | if (skwq_has_sleeper(wq)) |
121 | wake_up_interruptible(&wq->wait); | 121 | wake_up_interruptible(&wq->wait); |
122 | 122 | ||
123 | sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT); | 123 | sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT); |
diff --git a/net/core/sock.c b/net/core/sock.c index 1e4dd54bfb5a..2769bd3a4d7c 100644 --- a/net/core/sock.c +++ b/net/core/sock.c | |||
@@ -2283,7 +2283,7 @@ static void sock_def_wakeup(struct sock *sk) | |||
2283 | 2283 | ||
2284 | rcu_read_lock(); | 2284 | rcu_read_lock(); |
2285 | wq = rcu_dereference(sk->sk_wq); | 2285 | wq = rcu_dereference(sk->sk_wq); |
2286 | if (wq_has_sleeper(wq)) | 2286 | if (skwq_has_sleeper(wq)) |
2287 | wake_up_interruptible_all(&wq->wait); | 2287 | wake_up_interruptible_all(&wq->wait); |
2288 | rcu_read_unlock(); | 2288 | rcu_read_unlock(); |
2289 | } | 2289 | } |
@@ -2294,7 +2294,7 @@ static void sock_def_error_report(struct sock *sk) | |||
2294 | 2294 | ||
2295 | rcu_read_lock(); | 2295 | rcu_read_lock(); |
2296 | wq = rcu_dereference(sk->sk_wq); | 2296 | wq = rcu_dereference(sk->sk_wq); |
2297 | if (wq_has_sleeper(wq)) | 2297 | if (skwq_has_sleeper(wq)) |
2298 | wake_up_interruptible_poll(&wq->wait, POLLERR); | 2298 | wake_up_interruptible_poll(&wq->wait, POLLERR); |
2299 | sk_wake_async(sk, SOCK_WAKE_IO, POLL_ERR); | 2299 | sk_wake_async(sk, SOCK_WAKE_IO, POLL_ERR); |
2300 | rcu_read_unlock(); | 2300 | rcu_read_unlock(); |
@@ -2306,7 +2306,7 @@ static void sock_def_readable(struct sock *sk) | |||
2306 | 2306 | ||
2307 | rcu_read_lock(); | 2307 | rcu_read_lock(); |
2308 | wq = rcu_dereference(sk->sk_wq); | 2308 | wq = rcu_dereference(sk->sk_wq); |
2309 | if (wq_has_sleeper(wq)) | 2309 | if (skwq_has_sleeper(wq)) |
2310 | wake_up_interruptible_sync_poll(&wq->wait, POLLIN | POLLPRI | | 2310 | wake_up_interruptible_sync_poll(&wq->wait, POLLIN | POLLPRI | |
2311 | POLLRDNORM | POLLRDBAND); | 2311 | POLLRDNORM | POLLRDBAND); |
2312 | sk_wake_async(sk, SOCK_WAKE_WAITD, POLL_IN); | 2312 | sk_wake_async(sk, SOCK_WAKE_WAITD, POLL_IN); |
@@ -2324,7 +2324,7 @@ static void sock_def_write_space(struct sock *sk) | |||
2324 | */ | 2324 | */ |
2325 | if ((atomic_read(&sk->sk_wmem_alloc) << 1) <= sk->sk_sndbuf) { | 2325 | if ((atomic_read(&sk->sk_wmem_alloc) << 1) <= sk->sk_sndbuf) { |
2326 | wq = rcu_dereference(sk->sk_wq); | 2326 | wq = rcu_dereference(sk->sk_wq); |
2327 | if (wq_has_sleeper(wq)) | 2327 | if (skwq_has_sleeper(wq)) |
2328 | wake_up_interruptible_sync_poll(&wq->wait, POLLOUT | | 2328 | wake_up_interruptible_sync_poll(&wq->wait, POLLOUT | |
2329 | POLLWRNORM | POLLWRBAND); | 2329 | POLLWRNORM | POLLWRBAND); |
2330 | 2330 | ||
diff --git a/net/core/stream.c b/net/core/stream.c index d70f77a0c889..8ff9d63b4265 100644 --- a/net/core/stream.c +++ b/net/core/stream.c | |||
@@ -35,7 +35,7 @@ void sk_stream_write_space(struct sock *sk) | |||
35 | 35 | ||
36 | rcu_read_lock(); | 36 | rcu_read_lock(); |
37 | wq = rcu_dereference(sk->sk_wq); | 37 | wq = rcu_dereference(sk->sk_wq); |
38 | if (wq_has_sleeper(wq)) | 38 | if (skwq_has_sleeper(wq)) |
39 | wake_up_interruptible_poll(&wq->wait, POLLOUT | | 39 | wake_up_interruptible_poll(&wq->wait, POLLOUT | |
40 | POLLWRNORM | POLLWRBAND); | 40 | POLLWRNORM | POLLWRBAND); |
41 | if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN)) | 41 | if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN)) |
diff --git a/net/dccp/output.c b/net/dccp/output.c index 4ce912e691d0..b66c84db0766 100644 --- a/net/dccp/output.c +++ b/net/dccp/output.c | |||
@@ -201,7 +201,7 @@ void dccp_write_space(struct sock *sk) | |||
201 | 201 | ||
202 | rcu_read_lock(); | 202 | rcu_read_lock(); |
203 | wq = rcu_dereference(sk->sk_wq); | 203 | wq = rcu_dereference(sk->sk_wq); |
204 | if (wq_has_sleeper(wq)) | 204 | if (skwq_has_sleeper(wq)) |
205 | wake_up_interruptible(&wq->wait); | 205 | wake_up_interruptible(&wq->wait); |
206 | /* Should agree with poll, otherwise some programs break */ | 206 | /* Should agree with poll, otherwise some programs break */ |
207 | if (sock_writeable(sk)) | 207 | if (sock_writeable(sk)) |
diff --git a/net/iucv/af_iucv.c b/net/iucv/af_iucv.c index fcb2752419c6..4f0aa91470c6 100644 --- a/net/iucv/af_iucv.c +++ b/net/iucv/af_iucv.c | |||
@@ -303,7 +303,7 @@ static void iucv_sock_wake_msglim(struct sock *sk) | |||
303 | 303 | ||
304 | rcu_read_lock(); | 304 | rcu_read_lock(); |
305 | wq = rcu_dereference(sk->sk_wq); | 305 | wq = rcu_dereference(sk->sk_wq); |
306 | if (wq_has_sleeper(wq)) | 306 | if (skwq_has_sleeper(wq)) |
307 | wake_up_interruptible_all(&wq->wait); | 307 | wake_up_interruptible_all(&wq->wait); |
308 | sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT); | 308 | sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT); |
309 | rcu_read_unlock(); | 309 | rcu_read_unlock(); |
diff --git a/net/rxrpc/af_rxrpc.c b/net/rxrpc/af_rxrpc.c index 1f8a144a5dc2..7e2d1057d8bc 100644 --- a/net/rxrpc/af_rxrpc.c +++ b/net/rxrpc/af_rxrpc.c | |||
@@ -67,7 +67,7 @@ static void rxrpc_write_space(struct sock *sk) | |||
67 | if (rxrpc_writable(sk)) { | 67 | if (rxrpc_writable(sk)) { |
68 | struct socket_wq *wq = rcu_dereference(sk->sk_wq); | 68 | struct socket_wq *wq = rcu_dereference(sk->sk_wq); |
69 | 69 | ||
70 | if (wq_has_sleeper(wq)) | 70 | if (skwq_has_sleeper(wq)) |
71 | wake_up_interruptible(&wq->wait); | 71 | wake_up_interruptible(&wq->wait); |
72 | sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT); | 72 | sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT); |
73 | } | 73 | } |
diff --git a/net/sctp/socket.c b/net/sctp/socket.c index 897c01c029ca..ec10b66354b8 100644 --- a/net/sctp/socket.c +++ b/net/sctp/socket.c | |||
@@ -6978,7 +6978,7 @@ void sctp_data_ready(struct sock *sk) | |||
6978 | 6978 | ||
6979 | rcu_read_lock(); | 6979 | rcu_read_lock(); |
6980 | wq = rcu_dereference(sk->sk_wq); | 6980 | wq = rcu_dereference(sk->sk_wq); |
6981 | if (wq_has_sleeper(wq)) | 6981 | if (skwq_has_sleeper(wq)) |
6982 | wake_up_interruptible_sync_poll(&wq->wait, POLLIN | | 6982 | wake_up_interruptible_sync_poll(&wq->wait, POLLIN | |
6983 | POLLRDNORM | POLLRDBAND); | 6983 | POLLRDNORM | POLLRDBAND); |
6984 | sk_wake_async(sk, SOCK_WAKE_WAITD, POLL_IN); | 6984 | sk_wake_async(sk, SOCK_WAKE_WAITD, POLL_IN); |
diff --git a/net/tipc/socket.c b/net/tipc/socket.c index 552dbaba9cf3..525acf6dd1c6 100644 --- a/net/tipc/socket.c +++ b/net/tipc/socket.c | |||
@@ -1492,7 +1492,7 @@ static void tipc_write_space(struct sock *sk) | |||
1492 | 1492 | ||
1493 | rcu_read_lock(); | 1493 | rcu_read_lock(); |
1494 | wq = rcu_dereference(sk->sk_wq); | 1494 | wq = rcu_dereference(sk->sk_wq); |
1495 | if (wq_has_sleeper(wq)) | 1495 | if (skwq_has_sleeper(wq)) |
1496 | wake_up_interruptible_sync_poll(&wq->wait, POLLOUT | | 1496 | wake_up_interruptible_sync_poll(&wq->wait, POLLOUT | |
1497 | POLLWRNORM | POLLWRBAND); | 1497 | POLLWRNORM | POLLWRBAND); |
1498 | rcu_read_unlock(); | 1498 | rcu_read_unlock(); |
@@ -1509,7 +1509,7 @@ static void tipc_data_ready(struct sock *sk) | |||
1509 | 1509 | ||
1510 | rcu_read_lock(); | 1510 | rcu_read_lock(); |
1511 | wq = rcu_dereference(sk->sk_wq); | 1511 | wq = rcu_dereference(sk->sk_wq); |
1512 | if (wq_has_sleeper(wq)) | 1512 | if (skwq_has_sleeper(wq)) |
1513 | wake_up_interruptible_sync_poll(&wq->wait, POLLIN | | 1513 | wake_up_interruptible_sync_poll(&wq->wait, POLLIN | |
1514 | POLLRDNORM | POLLRDBAND); | 1514 | POLLRDNORM | POLLRDBAND); |
1515 | rcu_read_unlock(); | 1515 | rcu_read_unlock(); |
diff --git a/net/unix/af_unix.c b/net/unix/af_unix.c index 955ec152cb71..efb706e1d1c0 100644 --- a/net/unix/af_unix.c +++ b/net/unix/af_unix.c | |||
@@ -339,7 +339,7 @@ static void unix_write_space(struct sock *sk) | |||
339 | rcu_read_lock(); | 339 | rcu_read_lock(); |
340 | if (unix_writable(sk)) { | 340 | if (unix_writable(sk)) { |
341 | wq = rcu_dereference(sk->sk_wq); | 341 | wq = rcu_dereference(sk->sk_wq); |
342 | if (wq_has_sleeper(wq)) | 342 | if (skwq_has_sleeper(wq)) |
343 | wake_up_interruptible_sync_poll(&wq->wait, | 343 | wake_up_interruptible_sync_poll(&wq->wait, |
344 | POLLOUT | POLLWRNORM | POLLWRBAND); | 344 | POLLOUT | POLLWRNORM | POLLWRBAND); |
345 | sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT); | 345 | sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT); |