/macosx-10.9.5/dcerpc-58/dcerpc/ncklib/ |
H A D | dgrq.h | 126 * field of iovector elements points to an "rpc_dg_recvq_elt_t" (rqe). 130 #define RPC_DG_RECVQ_IOVECTOR_SETUP(data, rqe) { \ 132 (data)->buff_addr = (byte_p_t) (rqe); \ 133 (data)->buff_len = sizeof *(rqe); \ 134 (data)->data_addr = (byte_p_t) &(rqe)->pkt->body; \ 135 (data)->data_len = ((rqe)->hdrp != NULL) ? \ 136 MIN((rqe)->hdrp->len, \ 137 (rqe)->pkt_len - RPC_C_DG_RAW_PKT_HDR_SIZE) : \ 138 (rqe)->pkt_len; \
|
H A D | dgfwd.c | 107 rpc_dg_recvq_elt_p_t /*rqe*/ 112 rpc_dg_recvq_elt_p_t /*rqe*/, 118 rpc_dg_recvq_elt_p_t /*rqe*/ 147 rpc_dg_recvq_elt_p_t rqe) 149 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp; 204 (rpc_addr_p_t) &rqe->from, 234 fwd_reject(sp, rqe); 238 fwd_forward(sp, rqe, fwd_addr); 242 fwd_delayed(sp, rqe); 260 rpc_dg_recvq_elt_p_t rqe) 145 rpc__dg_fwd_pkt( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe) argument 258 fwd_reject( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe) argument 283 fwd_forward( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_addr_p_t fwd_addr) argument 421 rpc_dg_recvq_elt_p_t rqe; member in struct:pkt_list_element 447 fwd_delayed( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe) argument 489 rpc_dg_recvq_elt_p_t rqe = (rpc_dg_recvq_elt_p_t)-1; local [all...] |
H A D | dgslsn.c | 121 rpc_dg_recvq_elt_p_t /*rqe*/, 129 #define RPC_DG_IS_ORPHAN_QUIT(rqe) ((rqe)->hdrp->len == 0) 157 rpc_dg_recvq_elt_p_t rqe, 161 if (rqe->hdrp->server_boot == 0) 163 rqe->hdrp->server_boot = rpc_g_dg_server_boot_time; 168 if (rqe->hdrp->server_boot == rpc_g_dg_server_boot_time) 174 rpc__dg_act_seq_string(rqe->hdrp))); 175 rpc__dg_xmit_error_body_pkt((sp)->sock, (rpc_addr_p_t) &rqe->from, 176 rqe 155 rpc__dg_svr_chk_and_set_sboot( rpc_dg_recvq_elt_p_t rqe, rpc_dg_sock_pool_elt_p_t sp ) argument 251 do_quit_body( rpc_dg_recvq_elt_p_t rqe, rpc_dg_scall_p_t scall ) argument 401 rpc__dg_do_quit( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_scall_p_t scall ) argument 499 rpc__dg_do_ack( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_scall_p_t scall ) argument 576 ping_common( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_scall_p_t scall ) argument 716 rpc__dg_do_ping( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_scall_p_t scall ) argument 1054 do_cbk_request( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_scall_p_t *scallp ) argument [all...] |
H A D | dgclsn.c | 101 rpc_dg_recvq_elt_p_t /*rqe*/, 106 rpc_dg_recvq_elt_p_t /*rqe*/, 123 rpc_dg_recvq_elt_p_t rqe, 128 rqe->hdrp->server_boot != ccall->c.call_server_boot) 131 rpc__dg_act_seq_string(rqe->hdrp))); 155 rpc_dg_recvq_elt_p_t rqe, 159 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp; 204 rpc__dg_xmit_hdr_only_pkt(sp->sock, (rpc_addr_p_t) &rqe->from, 205 rqe->hdrp, RPC_C_DG_PT_ACK); 209 rpc__dg_pkt_name(ptype), rpc__dg_act_seq_string(rqe 121 chk_sboot( rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument 152 rpc__dg_do_common_response( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument 333 rpc__dg_do_reject( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument 413 rpc__dg_do_fault( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument 462 rpc__dg_do_response( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument 598 rpc__dg_do_working( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument 649 rpc__dg_do_nocall( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument 794 do_quack_body( rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument 878 rpc__dg_do_quack( rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe, rpc_dg_ccall_p_t ccall ) argument [all...] |
H A D | dglsn.c | 119 rpc_dg_recvq_elt_p_t /*rqe*/ 124 rpc_dg_recvq_elt_p_t /*rqe*/ 129 rpc_dg_recvq_elt_p_t /*rqe*/ 133 rpc_dg_recvq_elt_p_t /*rqe*/, 141 rpc_dg_recvq_elt_p_t /*rqe*/, 150 rpc_dg_recvq_elt_p_t /*rqe*/ 161 rpc_dg_recvq_elt_p_t /*rqe*/, 168 rpc_dg_recvq_elt_p_t /*rqe*/, 175 rpc_dg_recvq_elt_p_t /*rqe*/, 182 rpc_dg_recvq_elt_p_t /*rqe*/, 406 rpc__dg_get_epkt_body_st( rpc_dg_recvq_elt_p_t rqe, unsigned32 *st ) argument 590 rpc_dg_recvq_elt_p_t rqe; local 649 rpc_dg_recvq_elt_p_t rqe; local 978 conv_stub_who_are_you( rpc_dg_recvq_elt_p_t rqe, rpc_dg_pkt_hdr_p_t resp_hdrp, uuid_p_t clt_actid, unsigned32 clt_boot ) argument 1026 conv_stub_who_are_you2( rpc_dg_recvq_elt_p_t rqe, rpc_dg_pkt_hdr_p_t resp_hdrp, uuid_p_t clt_actid, unsigned32 clt_boot ) argument 1092 conv_stub_are_you_there( rpc_dg_recvq_elt_p_t rqe, rpc_dg_pkt_hdr_p_t resp_hdrp, uuid_p_t clt_actid, unsigned32 clt_boot ) argument 1136 conv_stub_who_are_you_auth( rpc_dg_recvq_elt_p_t rqe, rpc_dg_pkt_hdr_p_t resp_hdrp, uuid_p_t clt_actid, unsigned32 clt_boot ) argument 1866 do_selective_ack( rpc_dg_recvq_elt_p_t rqe, rpc_dg_call_p_t call, unsigned32 *window_incr, unsigned32 *rexmit_cnt, unsigned32 serial_cnt ) argument 2117 do_fack_body( rpc_dg_recvq_elt_p_t rqe, rpc_dg_call_p_t call, unsigned32 *window_incr, unsigned32 *rexmit_cnt, unsigned32 curr_serial ) argument 2418 rpc__dg_fack_common( rpc_dg_sock_pool_elt_p_t sp ATTRIBUTE_UNUSED, rpc_dg_recvq_elt_p_t rqe, rpc_dg_call_p_t call, boolean *sent_data ) argument 3149 rpc_dg_recvq_elt_p_t rqe; local [all...] |
H A D | dgrq.c | 177 rpc_dg_recvq_elt_p_t rqe = rq->head; local 179 rq->head = rqe->next; 180 rpc__dg_pkt_free_rqe(rqe, NULL);
|
H A D | dg.c | 509 rpc_dg_recvq_elt_p_t rqe; local 556 rqe = rq->head; 561 if (key_info != NULL && rqe->hdrp != NULL) 569 rpc_dg_recvq_elt_p_t last_rqe = rqe; 581 raw_bodysize = ((rqe->hdrp->len + blocksize - 1) 593 > rqe->frag_len) || 594 (rqe->hdrp->auth_proto != auth_epv->auth_proto)) 614 ((rqe == last_rqe) ? 620 * or the *real* last rqe has auth trailer only. 626 if (rqe 896 rpc_dg_recvq_elt_p_t rqe = local 1002 rpc_dg_recvq_elt_p_t rqe; local [all...] |
H A D | dgsoc.c | 174 if ((*sp)->rqe != NULL) 175 RPC_MEM_FREE((*sp)->rqe, RPC_C_MEM_DG_PKT_POOL_ELT); 393 * For private sockets, allocate an xqe/rqe pair. These packets 420 eltp->rqe = &pkt->u.rqe.rqe; 421 eltp->rqe->pkt_real = &pkt->u.rqe.pkt; 422 eltp->rqe->pkt = (rpc_dg_raw_pkt_p_t) RPC_DG_ALIGN_8(eltp->rqe [all...] |
H A D | dgpkt.c | 598 * maximum of what we need for either an xqe or an rqe. 806 * In the case of private sockets, the private rqe is always available 815 rpc_dg_recvq_elt_p_t rqe; local 820 * a private rqe that can be used. 826 rqe = ccall->c.sock_ref->rqe; 829 rqe->next = NULL; 830 rqe->more_data = NULL; 831 rqe->frag_len = 0; 832 rqe 1179 rpc__dg_pkt_free_rqe( rpc_dg_recvq_elt_p_t rqe, rpc_dg_call_p_t call ) argument [all...] |
H A D | dgcall.c | 142 * rqe parameter. 148 rpc_dg_recvq_elt_p_t rqe, 246 if (rqe != NULL) 248 if (rqe->hdrp == NULL) 252 (rqe->hdrp->serial_hi << 8) | rqe->hdrp->serial_lo; 1152 rpc_dg_recvq_elt_p_t rqe, 1158 unsigned16 fragnum = rqe->hdrp->fragnum; 1160 unsigned16 curr_serial = (rqe->hdrp->serial_hi << 8) | rqe 145 rpc__dg_call_xmit_fack( rpc_dg_call_p_t call, rpc_dg_recvq_elt_p_t rqe, boolean32 is_nocall ) argument 1149 rpc__dg_call_recvq_insert( rpc_dg_call_p_t call, rpc_dg_recvq_elt_p_t rqe, boolean *wake_thread ) 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 172 rpc_dg_recvq_elt_t rqe; member in struct:rpc_dg_pkt_pool_elt_t::__anon8252::__anon8254 177 } rqe; /* for handling rqe's */ member in union:rpc_dg_pkt_pool_elt_t::__anon8252 188 * - counters of the number of currently active xqe's/rqe's 189 * and failed rqe allocations (this should always be 0 if things
|
H A D | dgexec.c | 253 rpc_dg_recvq_elt_p_t rqe; local 490 * We don't own the rqe. It's still on recvq. 501 rqe = RPC_DG_RECVQ_ELT_FROM_IOVECTOR_ELT(&iove); 502 assert(rqe != NULL && rqe->hdrp != NULL); 503 hdrp = rqe->hdrp; 770 if (rqe->hdrp == NULL || rqe->frag_len != rqe->pkt_len) 783 raw_bodysize = ((rqe [all...] |
H A D | dgsct.c | 161 rpc_dg_recvq_elt_p_t rqe 164 unsigned32 cur_rqe_seq = rqe->hdrp->seq; 256 rpc_dg_recvq_elt_p_t rqe, 260 boolean maybe = RPC_DG_HDR_FLAG_IS_SET(rqe->hdrp, RPC_C_DG_PF_MAYBE); 261 unsigned32 cur_rqe_seq = rqe->hdrp->seq; 303 rpc__dg_scall_reinit(*scallp, si, rqe); 307 *scallp = rpc__dg_scall_alloc(scte, si, rqe); 252 rpc__dg_sct_new_call( rpc_dg_sct_elt_p_t scte, rpc_dg_sock_pool_elt_p_t si, rpc_dg_recvq_elt_p_t rqe, rpc_dg_scall_p_t *scallp ) argument
|
H A D | dgscall.c | 146 rpc_dg_recvq_elt_p_t /*rqe*/ 691 rpc_dg_recvq_elt_p_t rqe 694 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp; 696 boolean maybe = RPC_DG_HDR_FLAG_IS_SET(rqe->hdrp, RPC_C_DG_PF_MAYBE); 733 || rqe->from.rpc_protseq_id != scall->c.addr->rpc_protseq_id) 738 rpc__naf_addr_overcopy((rpc_addr_p_t) &rqe->from, &scall->c.addr, &st); 755 rpc__naf_addr_overcopy((rpc_addr_p_t) &rqe->from, &scall->c.addr, &st); 904 rpc_dg_recvq_elt_p_t rqe 947 rpc__dg_scall_reinit(scall, sp, rqe); 966 rpc_dg_recvq_elt_p_t rqe [all...] |
H A D | dgsoc.h | 158 * The xqe and rqe pointers are only used by private sockets. They 171 rpc_dg_recvq_elt_p_t rqe; member in struct:rpc_dg_sock_pool_elt_t
|
H A D | dgccall.c | 228 rpc_dg_recvq_elt_p_t rqe, 238 rpc__dg_scall_reinit(*scallp, si, rqe); 240 *scallp = rpc__dg_scall_cbk_alloc(ccall, si, rqe); 244 if (RPC_DG_SEQ_IS_LT(rqe->hdrp->seq, ccall->c.high_seq)) 258 ccall->c.high_seq = rqe->hdrp->seq; 224 rpc__dg_ccall_lsct_new_call( rpc_dg_ccall_p_t ccall, rpc_dg_sock_pool_elt_p_t si, rpc_dg_recvq_elt_p_t rqe, rpc_dg_scall_p_t *scallp ) argument
|