Lines Matching defs:xqe
267 rpc_dg_xmitq_elt_p_t xqe,
274 rpc_dg_xmitq_elt_p_t last_xqe = xqe;
312 xq->hdr.fragnum = xqe->fragnum;
313 xq->hdr.flags = xq->base_flags | xqe->flags;
315 xq->hdr.len = xqe->frag_len;
323 xqe->serial_num = xq->next_serial_num++;
324 xq->hdr.serial_hi = (xqe->serial_num & 0xFF00) >> 8;
325 xq->hdr.serial_lo = xqe->serial_num & 0xFF;;
358 if (xq->push && xqe == xq->tail &&
363 * If this is the call's final xqe (fragmented or not) or we're
398 iov[1].iov_base = (byte_p_t) xqe->body;
399 iov[1].iov_len = xqe->body_len;
401 if (xqe->body_len != 0)
417 assert(xqe->frag_len == 0 ||
418 (unsigned32)sendcc == (xqe->frag_len + RPC_C_DG_RAW_PKT_HDR_SIZE));
420 xqe->frag_len = xq->hdr.len = sendcc - RPC_C_DG_RAW_PKT_HDR_SIZE;
425 (unsigned long)call->xq.hdr.seq, xqe->fragnum,
426 xqe->serial_num, (unsigned long)xq->hdr.len,
447 (*auth_epv->pre_send) (key_info, xqe, &xq->hdr, iov, iovlen, cksum, &st);
633 rpc_dg_xmitq_elt_p_t xqe = xq->head;
635 xq->head = xqe->next;
636 rpc__dg_pkt_free_xqe(xqe, call);
660 rpc_dg_xmitq_elt_p_t xqe = xq->part_xqe;
664 rpc_dg_xmitq_elt_p_t last_xqe = xqe;
670 if (xqe == NULL)
685 xqe->frag_len = frag_length;
687 xqe->next = NULL;
688 xqe->fragnum = xq->next_fragnum++;
689 xqe->flags = 0;
692 * Add the partial xqe to the queue.
697 xq->head = xq->tail = xq->first_unsent = xqe;
701 xq->tail->next = xqe;
702 xq->tail = xqe;
704 xq->first_unsent = xqe;
720 if (xqe->fragnum == 0 && ! xq->push)
765 last_xqe->body_len += (frag_length - xqe->frag_len);
766 xqe->frag_len = frag_length;
780 (*auth_epv->encrypt) (key_info, xqe, st);
804 rpc_dg_xmitq_elt_p_t xqe, tail = NULL;
820 for (xqe = xq->head; xqe != NULL && xqe != xq->first_unsent;
821 xqe = xqe->next)
831 if (xqe->in_cwindow)
833 xqe->in_cwindow = false;
835 if (! RPC_DG_FLAG_IS_SET(xqe->flags, RPC_C_DG_PF_NO_FACK) ||
836 RPC_DG_FLAG_IS_SET(xqe->flags, RPC_C_DG_PF_LAST_FRAG))
842 xq->rexmitq = xqe;
844 tail->next_rexmit = xqe;
846 xqe->next_rexmit = NULL;
847 tail = xqe;