infiniband/core/mad_rmpp.c

279 		 struct ib_mad_recv_wc *mad_recv_wc)
289 					     mad_recv_wc->wc,
290 					     mad_recv_wc->recv_buf.grh,
303 	rmpp_recv->rmpp_wc = mad_recv_wc;
304 	rmpp_recv->cur_seg_buf = &mad_recv_wc->recv_buf;
310 	mad_hdr = &mad_recv_wc->recv_buf.mad->mad_hdr;
312 	rmpp_recv->src_qp = mad_recv_wc->wc->src_qp;
313 	rmpp_recv->slid = mad_recv_wc->wc->slid;
325 	       struct ib_mad_recv_wc *mad_recv_wc)
328 	struct ib_mad_hdr *mad_hdr = &mad_recv_wc->recv_buf.mad->mad_hdr;
332 		    rmpp_recv->src_qp == mad_recv_wc->wc->src_qp &&
333 		    rmpp_recv->slid == mad_recv_wc->wc->slid &&
344 		  struct ib_mad_recv_wc *mad_recv_wc)
350 	rmpp_recv = find_rmpp_recv(agent, mad_recv_wc);
462 	      struct ib_mad_recv_wc *mad_recv_wc)
470 	rmpp_recv = acquire_rmpp_recv(agent, mad_recv_wc);
474 	seg_num = get_seg_num(&mad_recv_wc->recv_buf);
484 		ack_recv(rmpp_recv, mad_recv_wc);
493 	list_add(&mad_recv_wc->recv_buf.list, &prev_buf->list);
495 		update_seg_num(rmpp_recv, &mad_recv_wc->recv_buf);
504 			ack_recv(rmpp_recv, mad_recv_wc);
515 drop1:	ib_free_recv_mad(mad_recv_wc);
521 	   struct ib_mad_recv_wc *mad_recv_wc)
526 	rmpp_recv = create_rmpp_recv(agent, mad_recv_wc);
528 		ib_free_recv_mad(mad_recv_wc);
537 		return continue_rmpp(agent, mad_recv_wc);
541 	if (get_last_flag(&mad_recv_wc->recv_buf)) {
552 		ack_recv(rmpp_recv, mad_recv_wc);
553 		mad_recv_wc = NULL;
556 	return mad_recv_wc;
590 		       struct ib_mad_recv_wc *mad_recv_wc, u8 rmpp_status)
597 	mad_send_wr = ib_find_send_mad(agent, mad_recv_wc);
630 			   struct ib_mad_recv_wc *mad_recv_wc, int newwin)
634 	rmpp_recv = find_rmpp_recv(agent, mad_recv_wc);
640 			     struct ib_mad_recv_wc *mad_recv_wc)
647 	rmpp_mad = (struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad;
649 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
650 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
657 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_W2S);
658 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_W2S);
663 	mad_send_wr = ib_find_send_mad(agent, mad_recv_wc);
666 			process_ds_ack(agent, mad_recv_wc, newwin);
673 		ack_ds_ack(agent, mad_recv_wc);
684 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_S2B);
685 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_S2B);
715 		ack_ds_ack(agent, mad_recv_wc);
735 		  struct ib_mad_recv_wc *mad_recv_wc)
740 	rmpp_hdr = &((struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad)->rmpp_hdr;
752 		return start_rmpp(agent, mad_recv_wc);
758 		return continue_rmpp(agent, mad_recv_wc);
761 	nack_recv(agent, mad_recv_wc, rmpp_status);
762 	ib_free_recv_mad(mad_recv_wc);
767 			      struct ib_mad_recv_wc *mad_recv_wc)
771 	rmpp_mad = (struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad;
774 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
775 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
777 		abort_send(agent, mad_recv_wc, rmpp_mad->rmpp_hdr.rmpp_status);
781 			       struct ib_mad_recv_wc *mad_recv_wc)
785 	rmpp_mad = (struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad;
789 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
790 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
792 		abort_send(agent, mad_recv_wc, rmpp_mad->rmpp_hdr.rmpp_status);
797 			struct ib_mad_recv_wc *mad_recv_wc)
801 	rmpp_mad = (struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad;
803 		return mad_recv_wc;
806 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_UNV);
807 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_UNV);
813 		return process_rmpp_data(agent, mad_recv_wc);
815 		process_rmpp_ack(agent, mad_recv_wc);
818 		process_rmpp_stop(agent, mad_recv_wc);
821 		process_rmpp_abort(agent, mad_recv_wc);
824 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BADT);
825 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BADT);
829 	ib_free_recv_mad(mad_recv_wc);