137 static int rds_iw_recv_refill_one(struct rds_connection *conn,  in rds_iw_recv_refill_one()  argument
141 	struct rds_iw_connection *ic = conn->c_transport_data;  in rds_iw_recv_refill_one()
158 		rds_inc_init(&recv->r_iwinc->ii_inc, conn, conn->c_faddr);  in rds_iw_recv_refill_one()
224 int rds_iw_recv_refill(struct rds_connection *conn, gfp_t kptr_gfp,  in rds_iw_recv_refill()  argument
227 	struct rds_iw_connection *ic = conn->c_transport_data;  in rds_iw_recv_refill()
234 	while ((prefill || rds_conn_up(conn)) &&  in rds_iw_recv_refill()
244 		ret = rds_iw_recv_refill_one(conn, recv, kptr_gfp, page_gfp);  in rds_iw_recv_refill()
256 			rds_iw_conn_error(conn, "recv post on "  in rds_iw_recv_refill()
258 			       "reconnecting\n", &conn->c_faddr,  in rds_iw_recv_refill()
269 		rds_iw_advertise_credits(conn, posted);  in rds_iw_recv_refill()
458 		rds_iw_conn_error(ic->conn, "sending ack failed\n");  in rds_iw_send_ack()
553 static void rds_iw_cong_recv(struct rds_connection *conn,  in rds_iw_cong_recv()  argument
570 	map = conn->c_fcong;  in rds_iw_cong_recv()
634 static void rds_iw_process_recv(struct rds_connection *conn,  in rds_iw_process_recv()  argument
638 	struct rds_iw_connection *ic = conn->c_transport_data;  in rds_iw_process_recv()
648 		rds_iw_conn_error(conn, "incoming message "  in rds_iw_process_recv()
652 		       &conn->c_faddr);  in rds_iw_process_recv()
661 		rds_iw_conn_error(conn, "incoming message "  in rds_iw_process_recv()
664 		       &conn->c_faddr);  in rds_iw_process_recv()
675 		rds_iw_send_add_credits(conn, ihdr->h_credit);  in rds_iw_process_recv()
723 			rds_iw_conn_error(conn,  in rds_iw_process_recv()
739 			rds_iw_cong_recv(conn, iwinc);  in rds_iw_process_recv()
741 			rds_recv_incoming(conn, conn->c_faddr, conn->c_laddr,  in rds_iw_process_recv()
770 	struct rds_connection *conn = context;  in rds_iw_recv_cq_comp_handler()  local
771 	struct rds_iw_connection *ic = conn->c_transport_data;  in rds_iw_recv_cq_comp_handler()
773 	rdsdebug("conn %p cq %p\n", conn, cq);  in rds_iw_recv_cq_comp_handler()
783 	struct rds_connection *conn = ic->conn;  in rds_poll_cq()  local
802 		if (rds_conn_up(conn) || rds_conn_connecting(conn)) {  in rds_poll_cq()
805 				rds_iw_process_recv(conn, recv, wc.byte_len, state);  in rds_poll_cq()
807 				rds_iw_conn_error(conn, "recv completion on "  in rds_poll_cq()
809 				       "reconnecting\n", &conn->c_faddr,  in rds_poll_cq()
821 	struct rds_connection *conn = ic->conn;  in rds_iw_recv_tasklet_fn()  local
831 		rds_send_drop_acked(conn, state.ack_recv, NULL);  in rds_iw_recv_tasklet_fn()
834 	if (rds_conn_up(conn))  in rds_iw_recv_tasklet_fn()
847 		queue_delayed_work(rds_wq, &conn->c_recv_w, 0);  in rds_iw_recv_tasklet_fn()
850 int rds_iw_recv(struct rds_connection *conn)  in rds_iw_recv()  argument
852 	struct rds_iw_connection *ic = conn->c_transport_data;  in rds_iw_recv()
855 	rdsdebug("conn %p\n", conn);  in rds_iw_recv()
862 	if (rds_iw_recv_refill(conn, GFP_KERNEL, GFP_HIGHUSER, 0))  in rds_iw_recv()
868 	if (rds_conn_up(conn))  in rds_iw_recv()