Lines Matching defs:xqe
470 rpc_dg_xmitq_elt_p_t xqe = xq->rexmitq;
533 if (xqe == NULL && rexmiting)
535 xqe = xq->first_unsent;
544 if (xqe == NULL)
555 xqe->flags &= ~ RPC_C_DG_PF_NO_FACK;
562 xqe->flags |= RPC_C_DG_PF_NO_FACK;
570 * Mark xqe as part of the current congestion window.
573 xqe->in_cwindow = true;
575 rpc__dg_xmitq_elt_xmit(xqe, call, block);
579 xqe = xqe->next_rexmit;
584 xqe = xqe->next;
585 xq->first_unsent = xqe;
615 rpc_dg_xmitq_elt_p_t xqe;
638 xqe = xq->head;
640 if (xqe == NULL || ! rpc__clock_aged(xq->timestamp, xq->rexmit_timeout))
669 if (xqe != xq->first_unsent)
671 xq->rexmitq = xqe;
672 xqe->next_rexmit = NULL;
688 if (xqe->in_cwindow)
691 xqe->in_cwindow = false;
693 if (! RPC_DG_FLAG_IS_SET(xqe->flags, RPC_C_DG_PF_NO_FACK) ||
694 RPC_DG_FLAG_IS_SET(xqe->flags, RPC_C_DG_PF_LAST_FRAG))
704 xq->hdr.seq, xqe->fragnum, rpc__dg_act_seq_string(&xq->hdr)));