Searched refs:rqe (Results 1 - 16 of 16) sorted by relevance

/macosx-10.9.5/dcerpc-58/dcerpc/ncklib/
H A Ddgrq.h126 * 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 Ddgfwd.c107 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 Ddgslsn.c121 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 Ddgclsn.c101 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 Ddglsn.c119 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 Ddgrq.c177 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 Ddg.c509 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 Ddgsoc.c174 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 Ddgpkt.c598 * 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 Ddgcall.c142 * 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 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
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 Ddgexec.c253 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 Ddgsct.c161 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 Ddgscall.c146 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 Ddgsoc.h158 * 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 Ddgccall.c228 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

Completed in 111 milliseconds