Searched refs:xqe (Results 1 - 9 of 9) sorted by relevance

/macosx-10.10.1/dcerpc-61/dcerpc/ncklib/
H A Ddgxq.c267 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 (fragmente
265 rpc__dg_xmitq_elt_xmit( rpc_dg_xmitq_elt_p_t xqe, rpc_dg_call_p_t call, boolean32 block ) argument
633 rpc_dg_xmitq_elt_p_t xqe = xq->head; local
660 rpc_dg_xmitq_elt_p_t xqe = xq->part_xqe; local
804 rpc_dg_xmitq_elt_p_t xqe, tail = NULL; local
[all...]
H A Ddgsoc.c172 if ((*sp)->xqe != NULL)
173 RPC_MEM_FREE((*sp)->xqe, RPC_C_MEM_DG_PKT_POOL_ELT);
393 * For private sockets, allocate an xqe/rqe pair. These packets
406 eltp->xqe = &pkt->u.xqe.xqe;
407 eltp->xqe->body = &pkt->u.xqe.pkt;
408 eltp->xqe->next = NULL;
409 eltp->xqe
[all...]
H A Ddgpkt.c598 * maximum of what we need for either an xqe or an rqe.
636 rpc_dg_xmitq_elt_p_t xqe = NULL; local
644 * a private xqe that can be used.
648 if (call->sock_ref->xqe != NULL)
650 xqe = call->sock_ref->xqe;
651 call->sock_ref->xqe = NULL;
653 xqe->next = NULL;
654 xqe->more_data = NULL;
655 xqe
1105 rpc__dg_pkt_free_xqe( rpc_dg_xmitq_elt_p_t xqe, rpc_dg_call_p_t call ) argument
[all...]
H A Ddgpkt.h117 * Define the maximum number of packet's (used for both xqe's and rqe's)
160 * the pool contains both xqe's and rqe's, we need a third, neutral pointer
168 rpc_dg_xmitq_elt_t xqe; member in struct:rpc_dg_pkt_pool_elt_t::__anon8033::__anon8034
170 } xqe; /* for handling xqe's */ member in union:rpc_dg_pkt_pool_elt_t::__anon8033
188 * - counters of the number of currently active xqe's/rqe's
190 * are working) and xqe allocation attempts that had to block.
H A Ddgcall.c470 rpc_dg_xmitq_elt_p_t xqe = xq->rexmitq; local
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
615 rpc_dg_xmitq_elt_p_t xqe; local
[all...]
H A Ddg.c212 rpc_dg_xmitq_elt_p_t xqe = NULL; local
282 xqe = xq->part_xqe;
283 frag_length = xqe->body_len + RPC_C_DG_RAW_PKT_HDR_SIZE;
284 while (xqe->more_data)
286 xqe = xqe->more_data;
287 frag_length += xqe->body_len;
326 assert(xqe != NULL);
327 alloc_pkt = (xqe->body_len == body_size) &&
362 xqe
[all...]
H A Ddgsoc.h158 * The xqe and rqe pointers are only used by private sockets. They
172 rpc_dg_xmitq_elt_p_t xqe; member in struct:rpc_dg_sock_pool_elt_t
H A Dnoauthdg.c122 rpc_dg_xmitq_elt_p_t xqe,
119 rpc__noauth_dg_encrypt( rpc_auth_info_p_t info, rpc_dg_xmitq_elt_p_t xqe, unsigned32 *st ) argument
H A Ddglsn.c268 #define TRACK_CURRENT_BLAST(xq, xqe, curr_ser, window_incr, lost) \
270 if ((xqe)->serial_num == (curr_ser) + 1) \
272 if (! RPC_DG_FLAG_IS_SET((xqe)->flags, RPC_C_DG_PF_NO_FACK) && \
273 (xqe)->serial_num != (xq)->last_fack_serial) \
277 curr_ser = (xqe)->serial_num; \
279 else if (RPC_DG_SERIAL_IS_LT(curr_ser, (xqe)->serial_num) && \
280 RPC_DG_SERIAL_IS_LTE((xqe)->serial_num, (xq)->last_fack_serial)) \
283 (! RPC_DG_FLAG_IS_SET((xqe)->flags, RPC_C_DG_PF_NO_FACK) && \
284 (xqe)->serial_num != (xq)->last_fack_serial)) \
288 curr_ser = (xqe)
[all...]

Completed in 114 milliseconds