125 static void rds_tcp_cong_recv(struct rds_connection *conn,  in rds_tcp_cong_recv()  argument
141 	map = conn->c_fcong;  in rds_tcp_cong_recv()
170 	struct rds_connection *conn;  member
178 	struct rds_connection *conn = arg->conn;  in rds_tcp_data_recv()  local
179 	struct rds_tcp_connection *tc = conn->c_transport_data;  in rds_tcp_data_recv()
201 			rds_inc_init(&tinc->ti_inc, conn, conn->c_faddr);  in rds_tcp_data_recv()
253 				rds_tcp_cong_recv(conn, tinc);  in rds_tcp_data_recv()
255 				rds_recv_incoming(conn, conn->c_faddr,  in rds_tcp_data_recv()
256 						  conn->c_laddr, &tinc->ti_inc,  in rds_tcp_data_recv()
274 static int rds_tcp_read_sock(struct rds_connection *conn, gfp_t gfp)  in rds_tcp_read_sock()  argument
276 	struct rds_tcp_connection *tc = conn->c_transport_data;  in rds_tcp_read_sock()
282 	arg.conn = conn;  in rds_tcp_read_sock()
302 int rds_tcp_recv(struct rds_connection *conn)  in rds_tcp_recv()  argument
304 	struct rds_tcp_connection *tc = conn->c_transport_data;  in rds_tcp_recv()
308 	rdsdebug("recv worker conn %p tc %p sock %p\n", conn, tc, sock);  in rds_tcp_recv()
311 	ret = rds_tcp_read_sock(conn, GFP_KERNEL);  in rds_tcp_recv()
320 	struct rds_connection *conn;  in rds_tcp_data_ready()  local
326 	conn = sk->sk_user_data;  in rds_tcp_data_ready()
327 	if (!conn) { /* check for teardown race */  in rds_tcp_data_ready()
332 	tc = conn->c_transport_data;  in rds_tcp_data_ready()
336 	if (rds_tcp_read_sock(conn, GFP_ATOMIC) == -ENOMEM)  in rds_tcp_data_ready()
337 		queue_delayed_work(rds_wq, &conn->c_recv_w, 0);  in rds_tcp_data_ready()