105 static void rds_tcp_cong_recv(struct rds_connection *conn,  in rds_tcp_cong_recv()  argument
121 	map = conn->c_fcong;  in rds_tcp_cong_recv()
150 	struct rds_connection *conn;  member
158 	struct rds_connection *conn = arg->conn;  in rds_tcp_data_recv()  local
159 	struct rds_tcp_connection *tc = conn->c_transport_data;  in rds_tcp_data_recv()
181 			rds_inc_init(&tinc->ti_inc, conn, conn->c_faddr);  in rds_tcp_data_recv()
240 				rds_tcp_cong_recv(conn, tinc);  in rds_tcp_data_recv()
242 				rds_recv_incoming(conn, conn->c_faddr,  in rds_tcp_data_recv()
243 						  conn->c_laddr, &tinc->ti_inc,  in rds_tcp_data_recv()
261 static int rds_tcp_read_sock(struct rds_connection *conn, gfp_t gfp)  in rds_tcp_read_sock()  argument
263 	struct rds_tcp_connection *tc = conn->c_transport_data;  in rds_tcp_read_sock()
269 	arg.conn = conn;  in rds_tcp_read_sock()
289 int rds_tcp_recv(struct rds_connection *conn)  in rds_tcp_recv()  argument
291 	struct rds_tcp_connection *tc = conn->c_transport_data;  in rds_tcp_recv()
295 	rdsdebug("recv worker conn %p tc %p sock %p\n", conn, tc, sock);  in rds_tcp_recv()
298 	ret = rds_tcp_read_sock(conn, GFP_KERNEL);  in rds_tcp_recv()
307 	struct rds_connection *conn;  in rds_tcp_data_ready()  local
313 	conn = sk->sk_user_data;  in rds_tcp_data_ready()
314 	if (!conn) { /* check for teardown race */  in rds_tcp_data_ready()
319 	tc = conn->c_transport_data;  in rds_tcp_data_ready()
323 	if (rds_tcp_read_sock(conn, GFP_ATOMIC) == -ENOMEM)  in rds_tcp_data_ready()
324 		queue_delayed_work(rds_wq, &conn->c_recv_w, 0);  in rds_tcp_data_ready()