Lines Matching refs:sk
51 struct rxrpc_sock *rx = rxrpc_sk(sock->sk); in rxrpc_recvmsg()
66 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT); in rxrpc_recvmsg()
69 lock_sock(&rx->sk); in rxrpc_recvmsg()
77 if (rx->sk.sk_state != RXRPC_SERVER_LISTENING) { in rxrpc_recvmsg()
78 release_sock(&rx->sk); in rxrpc_recvmsg()
86 skb = skb_peek(&rx->sk.sk_receive_queue); in rxrpc_recvmsg()
94 release_sock(&rx->sk); in rxrpc_recvmsg()
95 prepare_to_wait_exclusive(sk_sleep(&rx->sk), &wait, in rxrpc_recvmsg()
97 ret = sock_error(&rx->sk); in rxrpc_recvmsg()
101 if (skb_queue_empty(&rx->sk.sk_receive_queue)) { in rxrpc_recvmsg()
106 finish_wait(sk_sleep(&rx->sk), &wait); in rxrpc_recvmsg()
107 lock_sock(&rx->sk); in rxrpc_recvmsg()
124 if (skb_dequeue(&rx->sk.sk_receive_queue) != skb) in rxrpc_recvmsg()
135 release_sock(&rx->sk); in rxrpc_recvmsg()
153 sock_recv_timestamp(msg, &rx->sk, skb); in rxrpc_recvmsg()
215 if (skb_dequeue(&rx->sk.sk_receive_queue) != in rxrpc_recvmsg()
235 if (skb == (struct sk_buff *) &rx->sk.sk_receive_queue) in rxrpc_recvmsg()
241 if (skb_dequeue(&rx->sk.sk_receive_queue) != skb) in rxrpc_recvmsg()
249 release_sock(&rx->sk); in rxrpc_recvmsg()
268 if (skb_dequeue(&rx->sk.sk_receive_queue) != skb) in rxrpc_recvmsg()
320 if (skb_dequeue(&rx->sk.sk_receive_queue) != skb) in rxrpc_recvmsg()
326 release_sock(&rx->sk); in rxrpc_recvmsg()
335 release_sock(&rx->sk); in rxrpc_recvmsg()
345 finish_wait(sk_sleep(&rx->sk), &wait); in rxrpc_recvmsg()