Lines Matching refs:conn

265 	rds_inc_init(&ibinc->ii_inc, ic->conn, ic->conn->c_faddr);  in rds_ib_refill_one_inc()
299 static int rds_ib_recv_refill_one(struct rds_connection *conn, in rds_ib_recv_refill_one() argument
302 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_recv_refill_one()
357 void rds_ib_recv_refill(struct rds_connection *conn, int prefill) in rds_ib_recv_refill() argument
359 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_recv_refill()
366 while ((prefill || rds_conn_up(conn)) && in rds_ib_recv_refill()
375 ret = rds_ib_recv_refill_one(conn, recv, prefill); in rds_ib_recv_refill()
389 rds_ib_conn_error(conn, "recv post on " in rds_ib_recv_refill()
391 "reconnecting\n", &conn->c_faddr, in rds_ib_recv_refill()
401 rds_ib_advertise_credits(conn, posted); in rds_ib_recv_refill()
627 rds_ib_conn_error(ic->conn, "sending ack failed\n"); in rds_ib_send_ack()
722 static void rds_ib_cong_recv(struct rds_connection *conn, in rds_ib_cong_recv() argument
739 map = conn->c_fcong; in rds_ib_cong_recv()
803 static void rds_ib_process_recv(struct rds_connection *conn, in rds_ib_process_recv() argument
807 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_process_recv()
817 rds_ib_conn_error(conn, "incoming message " in rds_ib_process_recv()
821 &conn->c_faddr); in rds_ib_process_recv()
830 rds_ib_conn_error(conn, "incoming message " in rds_ib_process_recv()
833 &conn->c_faddr); in rds_ib_process_recv()
844 rds_ib_send_add_credits(conn, ihdr->h_credit); in rds_ib_process_recv()
892 rds_ib_conn_error(conn, in rds_ib_process_recv()
908 rds_ib_cong_recv(conn, ibinc); in rds_ib_process_recv()
910 rds_recv_incoming(conn, conn->c_faddr, conn->c_laddr, in rds_ib_process_recv()
939 struct rds_connection *conn = context; in rds_ib_recv_cq_comp_handler() local
940 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_recv_cq_comp_handler()
942 rdsdebug("conn %p cq %p\n", conn, cq); in rds_ib_recv_cq_comp_handler()
952 struct rds_connection *conn = ic->conn; in rds_poll_cq() local
973 rds_ib_process_recv(conn, recv, wc.byte_len, state); in rds_poll_cq()
976 if (rds_conn_up(conn) || rds_conn_connecting(conn)) in rds_poll_cq()
977 rds_ib_conn_error(conn, "recv completion on %pI4 had " in rds_poll_cq()
979 "reconnecting\n", &conn->c_faddr, in rds_poll_cq()
996 struct rds_connection *conn = ic->conn; in rds_ib_recv_tasklet_fn() local
1006 rds_send_drop_acked(conn, state.ack_recv, NULL); in rds_ib_recv_tasklet_fn()
1009 if (rds_conn_up(conn)) in rds_ib_recv_tasklet_fn()
1019 rds_ib_recv_refill(conn, 0); in rds_ib_recv_tasklet_fn()
1022 int rds_ib_recv(struct rds_connection *conn) in rds_ib_recv() argument
1024 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_recv()
1027 rdsdebug("conn %p\n", conn); in rds_ib_recv()
1028 if (rds_conn_up(conn)) in rds_ib_recv()