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()
473 		rds_iw_conn_error(ic->conn, "sending ack failed\n");  in rds_iw_send_ack()
568 static void rds_iw_cong_recv(struct rds_connection *conn,  in rds_iw_cong_recv()  argument
585 	map = conn->c_fcong;  in rds_iw_cong_recv()
649 static void rds_iw_process_recv(struct rds_connection *conn,  in rds_iw_process_recv()  argument
653 	struct rds_iw_connection *ic = conn->c_transport_data;  in rds_iw_process_recv()
663 		rds_iw_conn_error(conn, "incoming message "  in rds_iw_process_recv()
667 		       &conn->c_faddr);  in rds_iw_process_recv()
676 		rds_iw_conn_error(conn, "incoming message "  in rds_iw_process_recv()
679 		       &conn->c_faddr);  in rds_iw_process_recv()
690 		rds_iw_send_add_credits(conn, ihdr->h_credit);  in rds_iw_process_recv()
738 			rds_iw_conn_error(conn,  in rds_iw_process_recv()
754 			rds_iw_cong_recv(conn, iwinc);  in rds_iw_process_recv()
756 			rds_recv_incoming(conn, conn->c_faddr, conn->c_laddr,  in rds_iw_process_recv()
785 	struct rds_connection *conn = context;  in rds_iw_recv_cq_comp_handler()  local
786 	struct rds_iw_connection *ic = conn->c_transport_data;  in rds_iw_recv_cq_comp_handler()
788 	rdsdebug("conn %p cq %p\n", conn, cq);  in rds_iw_recv_cq_comp_handler()
798 	struct rds_connection *conn = ic->conn;  in rds_poll_cq()  local
817 		if (rds_conn_up(conn) || rds_conn_connecting(conn)) {  in rds_poll_cq()
820 				rds_iw_process_recv(conn, recv, wc.byte_len, state);  in rds_poll_cq()
822 				rds_iw_conn_error(conn, "recv completion on "  in rds_poll_cq()
824 				       "reconnecting\n", &conn->c_faddr,  in rds_poll_cq()
836 	struct rds_connection *conn = ic->conn;  in rds_iw_recv_tasklet_fn()  local
846 		rds_send_drop_acked(conn, state.ack_recv, NULL);  in rds_iw_recv_tasklet_fn()
849 	if (rds_conn_up(conn))  in rds_iw_recv_tasklet_fn()
862 		queue_delayed_work(rds_wq, &conn->c_recv_w, 0);  in rds_iw_recv_tasklet_fn()
865 int rds_iw_recv(struct rds_connection *conn)  in rds_iw_recv()  argument
867 	struct rds_iw_connection *ic = conn->c_transport_data;  in rds_iw_recv()
870 	rdsdebug("conn %p\n", conn);  in rds_iw_recv()
877 	if (rds_iw_recv_refill(conn, GFP_KERNEL, GFP_HIGHUSER, 0))  in rds_iw_recv()
883 	if (rds_conn_up(conn))  in rds_iw_recv()