infiniband/core/mad_rmpp.c

281 		 struct ib_mad_recv_wc *mad_recv_wc)
291 					     mad_recv_wc->wc,
292 					     mad_recv_wc->recv_buf.grh,
305 	rmpp_recv->rmpp_wc = mad_recv_wc;
306 	rmpp_recv->cur_seg_buf = &mad_recv_wc->recv_buf;
312 	mad_hdr = &mad_recv_wc->recv_buf.mad->mad_hdr;
314 	rmpp_recv->src_qp = mad_recv_wc->wc->src_qp;
315 	rmpp_recv->slid = mad_recv_wc->wc->slid;
327 	       struct ib_mad_recv_wc *mad_recv_wc)
330 	struct ib_mad_hdr *mad_hdr = &mad_recv_wc->recv_buf.mad->mad_hdr;
334 		    rmpp_recv->src_qp == mad_recv_wc->wc->src_qp &&
335 		    rmpp_recv->slid == mad_recv_wc->wc->slid &&
346 		  struct ib_mad_recv_wc *mad_recv_wc)
352 	rmpp_recv = find_rmpp_recv(agent, mad_recv_wc);
464 	      struct ib_mad_recv_wc *mad_recv_wc)
472 	rmpp_recv = acquire_rmpp_recv(agent, mad_recv_wc);
476 	seg_num = get_seg_num(&mad_recv_wc->recv_buf);
486 		ack_recv(rmpp_recv, mad_recv_wc);
495 	list_add(&mad_recv_wc->recv_buf.list, &prev_buf->list);
497 		update_seg_num(rmpp_recv, &mad_recv_wc->recv_buf);
506 			ack_recv(rmpp_recv, mad_recv_wc);
517 drop1:	ib_free_recv_mad(mad_recv_wc);
523 	   struct ib_mad_recv_wc *mad_recv_wc)
528 	rmpp_recv = create_rmpp_recv(agent, mad_recv_wc);
530 		ib_free_recv_mad(mad_recv_wc);
539 		return continue_rmpp(agent, mad_recv_wc);
543 	if (get_last_flag(&mad_recv_wc->recv_buf)) {
554 		ack_recv(rmpp_recv, mad_recv_wc);
555 		mad_recv_wc = NULL;
558 	return mad_recv_wc;
592 		       struct ib_mad_recv_wc *mad_recv_wc, u8 rmpp_status)
599 	mad_send_wr = ib_find_send_mad(agent, mad_recv_wc);
632 			   struct ib_mad_recv_wc *mad_recv_wc, int newwin)
636 	rmpp_recv = find_rmpp_recv(agent, mad_recv_wc);
642 			     struct ib_mad_recv_wc *mad_recv_wc)
649 	rmpp_mad = (struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad;
651 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
652 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
659 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_W2S);
660 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_W2S);
665 	mad_send_wr = ib_find_send_mad(agent, mad_recv_wc);
668 			process_ds_ack(agent, mad_recv_wc, newwin);
675 		ack_ds_ack(agent, mad_recv_wc);
686 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_S2B);
687 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_S2B);
717 		ack_ds_ack(agent, mad_recv_wc);
737 		  struct ib_mad_recv_wc *mad_recv_wc)
742 	rmpp_hdr = &((struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad)->rmpp_hdr;
754 		return start_rmpp(agent, mad_recv_wc);
760 		return continue_rmpp(agent, mad_recv_wc);
763 	nack_recv(agent, mad_recv_wc, rmpp_status);
764 	ib_free_recv_mad(mad_recv_wc);
769 			      struct ib_mad_recv_wc *mad_recv_wc)
773 	rmpp_mad = (struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad;
776 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
777 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
779 		abort_send(agent, mad_recv_wc, rmpp_mad->rmpp_hdr.rmpp_status);
783 			       struct ib_mad_recv_wc *mad_recv_wc)
787 	rmpp_mad = (struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad;
791 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
792 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS);
794 		abort_send(agent, mad_recv_wc, rmpp_mad->rmpp_hdr.rmpp_status);
799 			struct ib_mad_recv_wc *mad_recv_wc)
803 	rmpp_mad = (struct ib_rmpp_mad *)mad_recv_wc->recv_buf.mad;
805 		return mad_recv_wc;
808 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_UNV);
809 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_UNV);
815 		return process_rmpp_data(agent, mad_recv_wc);
817 		process_rmpp_ack(agent, mad_recv_wc);
820 		process_rmpp_stop(agent, mad_recv_wc);
823 		process_rmpp_abort(agent, mad_recv_wc);
826 		abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BADT);
827 		nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BADT);
831 	ib_free_recv_mad(mad_recv_wc);