Lines Matching defs:conn
137 static int rds_iw_recv_refill_one(struct rds_connection *conn,
141 struct rds_iw_connection *ic = conn->c_transport_data;
158 rds_inc_init(&recv->r_iwinc->ii_inc, conn, conn->c_faddr);
224 int rds_iw_recv_refill(struct rds_connection *conn, gfp_t kptr_gfp,
227 struct rds_iw_connection *ic = conn->c_transport_data;
234 while ((prefill || rds_conn_up(conn)) &&
244 ret = rds_iw_recv_refill_one(conn, recv, kptr_gfp, page_gfp);
255 rds_iw_conn_error(conn, "recv post on "
257 "reconnecting\n", &conn->c_faddr,
268 rds_iw_advertise_credits(conn, posted);
471 rds_iw_conn_error(ic->conn, "sending ack failed\n");
566 static void rds_iw_cong_recv(struct rds_connection *conn,
583 map = conn->c_fcong;
647 static void rds_iw_process_recv(struct rds_connection *conn,
651 struct rds_iw_connection *ic = conn->c_transport_data;
660 rds_iw_conn_error(conn, "incoming message "
664 &conn->c_faddr);
673 rds_iw_conn_error(conn, "incoming message "
676 &conn->c_faddr);
687 rds_iw_send_add_credits(conn, ihdr->h_credit);
725 rds_iw_conn_error(conn,
741 rds_iw_cong_recv(conn, iwinc);
743 rds_recv_incoming(conn, conn->c_faddr, conn->c_laddr,
773 struct rds_connection *conn = context;
774 struct rds_iw_connection *ic = conn->c_transport_data;
776 rdsdebug("conn %p cq %p\n", conn, cq);
786 struct rds_connection *conn = ic->conn;
805 if (rds_conn_up(conn) || rds_conn_connecting(conn)) {
808 rds_iw_process_recv(conn, recv, wc.byte_len, state);
810 rds_iw_conn_error(conn, "recv completion on "
812 "reconnecting\n", &conn->c_faddr,
824 struct rds_connection *conn = ic->conn;
834 rds_send_drop_acked(conn, state.ack_recv, NULL);
837 if (rds_conn_up(conn))
850 queue_delayed_work(rds_wq, &conn->c_recv_w, 0);
853 int rds_iw_recv(struct rds_connection *conn)
855 struct rds_iw_connection *ic = conn->c_transport_data;
858 rdsdebug("conn %p\n", conn);
865 if (rds_iw_recv_refill(conn, GFP_KERNEL, GFP_HIGHUSER, 0))
871 if (rds_conn_up(conn))