net/rds/recv.c

88 static void rds_recv_rcvbuf_delta(struct rds_sock *rs, struct sock *sk,
288 	struct sock *sk;
373 	sk = rds_rs_to_sk(rs);
377 	if (!sock_flag(sk, SOCK_DEAD)) {
380 		rds_recv_rcvbuf_delta(rs, sk, inc->i_conn->c_lcong,
383 		if (sock_flag(sk, SOCK_RCVTSTAMP))
388 		__rds_wake_sk_sleep(sk);
425 	struct sock *sk = rds_rs_to_sk(rs);
435 			rds_recv_rcvbuf_delta(rs, sk, inc->i_conn->c_lcong,
641 	struct sock *sk = sock->sk;
642 	struct rds_sock *rs = rds_sk_to_rs(sk);
650 	timeo = sock_rcvtimeo(sk, nonblock);
657 		return sock_recv_errqueue(sk, msg, size, SOL_IP, IP_RECVERR);
679 			timeo = wait_event_interruptible_timeout(*sk_sleep(sk),
762 	struct sock *sk = rds_rs_to_sk(rs);
769 		rds_recv_rcvbuf_delta(rs, sk, inc->i_conn->c_lcong,