Lines Matching defs:conn
137 static int rds_ib_recv_refill_one(struct rds_connection *conn,
141 struct rds_ib_connection *ic = conn->c_transport_data;
158 rds_inc_init(&recv->r_ibinc->ii_inc, conn, conn->c_faddr);
224 int rds_ib_recv_refill(struct rds_connection *conn, gfp_t kptr_gfp,
227 struct rds_ib_connection *ic = conn->c_transport_data;
234 while ((prefill || rds_conn_up(conn)) &&
244 ret = rds_ib_recv_refill_one(conn, recv, kptr_gfp, page_gfp);
255 rds_ib_conn_error(conn, "recv post on "
257 "reconnecting\n", &conn->c_faddr,
268 rds_ib_advertise_credits(conn, posted);
471 rds_ib_conn_error(ic->conn, "sending ack failed\n");
558 static struct rds_header *rds_ib_get_header(struct rds_connection *conn,
562 struct rds_ib_connection *ic = conn->c_transport_data;
576 if (conn->c_version > RDS_PROTOCOL_3_0 || data_len == RDS_FRAG_SIZE)
607 static void rds_ib_cong_recv(struct rds_connection *conn,
624 map = conn->c_fcong;
688 static void rds_ib_process_recv(struct rds_connection *conn,
692 struct rds_ib_connection *ic = conn->c_transport_data;
701 rds_ib_conn_error(conn, "incoming message "
705 &conn->c_faddr);
710 ihdr = rds_ib_get_header(conn, recv, data_len);
714 rds_ib_conn_error(conn, "incoming message "
717 &conn->c_faddr);
728 rds_ib_send_add_credits(conn, ihdr->h_credit);
766 rds_ib_conn_error(conn,
782 rds_ib_cong_recv(conn, ibinc);
784 rds_recv_incoming(conn, conn->c_faddr, conn->c_laddr,
814 struct rds_connection *conn = context;
815 struct rds_ib_connection *ic = conn->c_transport_data;
817 rdsdebug("conn %p cq %p\n", conn, cq);
827 struct rds_connection *conn = ic->conn;
846 if (rds_conn_up(conn) || rds_conn_connecting(conn)) {
849 rds_ib_process_recv(conn, recv, wc.byte_len, state);
851 rds_ib_conn_error(conn, "recv completion on "
853 "reconnecting\n", &conn->c_faddr,
865 struct rds_connection *conn = ic->conn;
875 rds_send_drop_acked(conn, state.ack_recv, NULL);
878 if (rds_conn_up(conn))
891 queue_delayed_work(rds_wq, &conn->c_recv_w, 0);
894 int rds_ib_recv(struct rds_connection *conn)
896 struct rds_ib_connection *ic = conn->c_transport_data;
899 rdsdebug("conn %p\n", conn);
906 if (rds_ib_recv_refill(conn, GFP_KERNEL, GFP_HIGHUSER, 0))
912 if (rds_conn_up(conn))