Lines Matching refs:cp
158 struct rds_conn_path *cp = arg->conn_path; in rds_tcp_data_recv() local
159 struct rds_tcp_connection *tc = cp->cp_transport_data; in rds_tcp_data_recv()
181 rds_inc_path_init(&tinc->ti_inc, cp, in rds_tcp_data_recv()
182 &cp->cp_conn->c_faddr); in rds_tcp_data_recv()
237 struct rds_connection *conn = cp->cp_conn; in rds_tcp_data_recv()
262 static int rds_tcp_read_sock(struct rds_conn_path *cp, gfp_t gfp) in rds_tcp_read_sock() argument
264 struct rds_tcp_connection *tc = cp->cp_transport_data; in rds_tcp_read_sock()
270 arg.conn_path = cp; in rds_tcp_read_sock()
290 int rds_tcp_recv_path(struct rds_conn_path *cp) in rds_tcp_recv_path() argument
292 struct rds_tcp_connection *tc = cp->cp_transport_data; in rds_tcp_recv_path()
297 cp->cp_index, tc, sock); in rds_tcp_recv_path()
300 ret = rds_tcp_read_sock(cp, GFP_KERNEL); in rds_tcp_recv_path()
309 struct rds_conn_path *cp; in rds_tcp_data_ready() local
315 cp = sk->sk_user_data; in rds_tcp_data_ready()
316 if (!cp) { /* check for teardown race */ in rds_tcp_data_ready()
321 tc = cp->cp_transport_data; in rds_tcp_data_ready()
325 if (rds_tcp_read_sock(cp, GFP_ATOMIC) == -ENOMEM) { in rds_tcp_data_ready()
327 if (!rds_destroy_pending(cp->cp_conn)) in rds_tcp_data_ready()
328 queue_delayed_work(rds_wq, &cp->cp_recv_w, 0); in rds_tcp_data_ready()