net/rds/tcp_recv.c

160 	struct rds_tcp_connection *tc = cp->cp_transport_data;
161 	struct rds_tcp_incoming *tinc = tc->t_tinc;
165 	rdsdebug("tcp data tc %p skb %p offset %u len %zu\n", tc, skb, offset,
180 			tc->t_tinc = tinc;
194 		if (left && tc->t_tinc_hdr_rem) {
195 			to_copy = min(tc->t_tinc_hdr_rem, left);
201 						tc->t_tinc_hdr_rem,
203 			tc->t_tinc_hdr_rem -= to_copy;
207 			if (tc->t_tinc_hdr_rem == 0) {
209 				tc->t_tinc_data_rem =
216 		if (left && tc->t_tinc_data_rem) {
217 			to_copy = min(tc->t_tinc_data_rem, left);
232 			tc->t_tinc_data_rem -= to_copy;
237 		if (tc->t_tinc_hdr_rem == 0 && tc->t_tinc_data_rem == 0) {
248 			tc->t_tinc_hdr_rem = sizeof(struct rds_header);
249 			tc->t_tinc_data_rem = 0;
250 			tc->t_tinc = NULL;
258 		 skb_queue_len(&tc->t_sock->sk->sk_receive_queue));
265 	struct rds_tcp_connection *tc = cp->cp_transport_data;
266 	struct socket *sock = tc->t_sock;
278 	rdsdebug("tcp_read_sock for tc %p gfp 0x%x returned %d\n", tc, gfp,
293 	struct rds_tcp_connection *tc = cp->cp_transport_data;
294 	struct socket *sock = tc->t_sock;
297 	rdsdebug("recv worker path [%d] tc %p sock %p\n",
298 		 cp->cp_index, tc, sock);
311 	struct rds_tcp_connection *tc;
323 	tc = cp->cp_transport_data;
324 	ready = tc->t_orig_data_ready;