net/rds/ib_send.c

246 	struct rds_connection *conn = ic->conn;
298 	if (test_and_clear_bit(RDS_LL_SEND_FULL, &conn->c_flags) ||
299 	    test_bit(0, &conn->c_map_queued))
300 		queue_delayed_work(rds_wq, &conn->c_send_w, 0);
303 	if (wc->status != IB_WC_SUCCESS && rds_conn_up(conn)) {
304 		rds_ib_conn_error(conn, "send completion on <%pI6c,%pI6c,%d> had status %u (%s), vendor err 0x%x, disconnecting and reconnecting\n",
305 				  &conn->c_laddr, &conn->c_faddr,
306 				  conn->c_tos, wc->status,
379 		struct rds_connection *conn = ic->i_cm_id->context;
382 		set_bit(RDS_LL_SEND_FULL, &conn->c_flags);
408 void rds_ib_send_add_credits(struct rds_connection *conn, unsigned int credits)
410 	struct rds_ib_connection *ic = conn->c_transport_data;
418 			test_bit(RDS_LL_SEND_FULL, &conn->c_flags) ? ", ll_send_full" : "");
421 	if (test_and_clear_bit(RDS_LL_SEND_FULL, &conn->c_flags))
422 		queue_delayed_work(rds_wq, &conn->c_send_w, 0);
429 void rds_ib_advertise_credits(struct rds_connection *conn, unsigned int posted)
431 	struct rds_ib_connection *ic = conn->c_transport_data;
484 int rds_ib_xmit(struct rds_connection *conn, struct rds_message *rm,
487 	struct rds_ib_connection *ic = conn->c_transport_data;
510 	if (conn->c_loopback
512 		rds_cong_map_updated(conn->c_fcong, ~(u64) 0);
526 		set_bit(RDS_LL_SEND_FULL, &conn->c_flags);
541 			set_bit(RDS_LL_SEND_FULL, &conn->c_flags);
730 		rds_ib_send_add_credits(conn, credit_alloc - i);
743 		       "returned %d\n", &conn->c_faddr, ret);
751 		rds_ib_conn_error(ic->conn, "ib_post_send failed\n");
766 int rds_ib_xmit_atomic(struct rds_connection *conn, struct rm_atomic_op *op)
768 	struct rds_ib_connection *ic = conn->c_transport_data;
837 		       "returned %d\n", &conn->c_faddr, ret);
852 int rds_ib_xmit_rdma(struct rds_connection *conn, struct rm_rdma_op *op)
854 	struct rds_ib_connection *ic = conn->c_transport_data;
993 		       "returned %d\n", &conn->c_faddr, ret);
1011 	struct rds_connection *conn = cp->cp_conn;
1012 	struct rds_ib_connection *ic = conn->c_transport_data;