infiniband/core/mad_rmpp.c

60 	int seg_num;
124 	rmpp_recv->last_ack = rmpp_recv->seg_num;
125 	ack->rmpp_hdr.seg_num = cpu_to_be32(rmpp_recv->seg_num);
194 	rmpp_mad->rmpp_hdr.seg_num = 0;
231 	rmpp_mad->rmpp_hdr.seg_num = 0;
304 	rmpp_recv->seg_num = 1;
382 	return be32_to_cpu(rmpp_mad->rmpp_hdr.seg_num);
400 						 int seg_num)
407 		if (seg_num > cur_seg_num)
409 		if (seg_num == cur_seg_num)
420 	while (new_buf && (get_seg_num(new_buf) == rmpp_recv->seg_num + 1)) {
422 		rmpp_recv->seg_num++;
449 	return hdr_size + rmpp_recv->seg_num * data_size - pad;
457 	if (rmpp_recv->seg_num > 1)
475 	int seg_num;
482 	seg_num = get_seg_num(&mad_recv_wc->recv_buf);
486 	    (seg_num > rmpp_recv->newwin))
489 	if ((seg_num <= rmpp_recv->last_ack) ||
496 	prev_buf = find_seg_location(&rmpp_recv->rmpp_wc->rmpp_list, seg_num);
509 		} else if (rmpp_recv->seg_num == rmpp_recv->newwin) {
575 	rmpp_mad->rmpp_hdr.seg_num = cpu_to_be32(++mad_send_wr->seg_num);
577 	if (mad_send_wr->seg_num == 1) {
584 	if (mad_send_wr->seg_num == mad_send_wr->send_buf.seg_count) {
627 				   int seg_num)
631 	wr->last_ack = seg_num;
634 		if (wr->last_ack_seg->num == seg_num)
654 	int seg_num, newwin, ret;
663 	seg_num = be32_to_cpu(rmpp_mad->rmpp_hdr.seg_num);
665 	if (newwin < seg_num) {
674 		if (!seg_num)
690 	if (seg_num > mad_send_wr->send_buf.seg_count ||
691 	    seg_num > mad_send_wr->newwin) {
698 	if (newwin < mad_send_wr->newwin || seg_num < mad_send_wr->last_ack)
701 	if (seg_num > mad_send_wr->last_ack) {
702 		adjust_last_ack(mad_send_wr, seg_num);
727 		   mad_send_wr->seg_num < mad_send_wr->newwin &&
728 		   mad_send_wr->seg_num < mad_send_wr->send_buf.seg_count) {
756 	if (rmpp_hdr->seg_num == cpu_to_be32(1)) {
886 		mad_send_wr->seg_num = 1;
927 	if (mad_send_wr->seg_num == mad_send_wr->newwin ||
928 	    mad_send_wr->seg_num == mad_send_wr->send_buf.seg_count)
952 	mad_send_wr->seg_num = mad_send_wr->last_ack;