Lines Matching defs:conn
125 static void rds_tcp_cong_recv(struct rds_connection *conn,
141 map = conn->c_fcong;
170 struct rds_connection *conn;
179 struct rds_connection *conn = arg->conn;
180 struct rds_tcp_connection *tc = conn->c_transport_data;
202 rds_inc_init(&tinc->ti_inc, conn, conn->c_faddr);
250 rds_tcp_cong_recv(conn, tinc);
252 rds_recv_incoming(conn, conn->c_faddr,
253 conn->c_laddr, &tinc->ti_inc,
271 int rds_tcp_read_sock(struct rds_connection *conn, gfp_t gfp, enum km_type km)
273 struct rds_tcp_connection *tc = conn->c_transport_data;
279 arg.conn = conn;
300 int rds_tcp_recv(struct rds_connection *conn)
302 struct rds_tcp_connection *tc = conn->c_transport_data;
306 rdsdebug("recv worker conn %p tc %p sock %p\n", conn, tc, sock);
309 ret = rds_tcp_read_sock(conn, GFP_KERNEL, KM_USER0);
318 struct rds_connection *conn;
324 conn = sk->sk_user_data;
325 if (conn == NULL) { /* check for teardown race */
330 tc = conn->c_transport_data;
334 if (rds_tcp_read_sock(conn, GFP_ATOMIC, KM_SOFTIRQ0) == -ENOMEM)
335 queue_delayed_work(rds_wq, &conn->c_recv_w, 0);