Searched refs:xqe (Results 1 - 9 of 9) sorted by relevance
/macosx-10.10.1/dcerpc-61/dcerpc/ncklib/ |
H A D | dgxq.c | 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 (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 D | dgsoc.c | 172 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 D | dgpkt.c | 598 * 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 D | dgpkt.h | 117 * 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 D | dgcall.c | 470 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 D | dg.c | 212 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 D | dgsoc.h | 158 * 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 D | noauthdg.c | 122 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 D | dglsn.c | 268 #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 125 milliseconds