Searched refs:ccall (Results 1 - 17 of 17) sorted by relevance

/macosx-10.10.1/dcerpc-61/dcerpc/ncklib/
H A Ddgccall.h105 * to get rid of the ccall use rpc__dg_ccall_free_prep() instead.
108 #define RPC_DG_CCALL_SET_STATE_IDLE(ccall) { \
109 if ((ccall)->c.state == rpc_e_dg_cs_final) \
110 rpc__dg_ccall_ack(ccall); \
111 rpc__dg_ccallt_remove(ccall); \
112 if (! (ccall)->c.is_cbk)\
113 RPC_DG_CCT_RELEASE(&(ccall)->ccte_ref); \
114 RPC_DG_CALL_SET_STATE(&(ccall)->c, rpc_e_dg_cs_idle); \
124 #define RPC_DG_CCALL_RELEASE(ccall) { \
125 RPC_DG_CALL_LOCK_ASSERT(&(*(ccall))
[all...]
H A Ddgccall.c109 * ccall specific com_timeout controllable parameters...
120 rpc_dg_ccall_p_t /*ccall*/,
144 INTERNAL void xmit_ping ( rpc_dg_ccall_p_t /*ccall*/);
146 INTERNAL void xmit_orphan_quit ( rpc_dg_ccall_p_t /*ccall*/);
148 INTERNAL void recv_state_timer (rpc_dg_ccall_p_t /*ccall*/);
150 INTERNAL void ccall_orphan_timer (rpc_dg_ccall_p_t /*ccall*/);
152 INTERNAL void ccall_cancel_timer (rpc_dg_ccall_p_t /*ccall*/);
154 INTERNAL void ccall_uncache (rpc_dg_ccall_p_t /*ccall*/);
165 rpc_dg_ccall_p_t /*ccall*/,
171 rpc_dg_ccall_p_t /*ccall*/
188 rpc__dg_ccall_lsct_inq_scall( rpc_dg_ccall_p_t ccall, rpc_dg_scall_p_t *scallp ) argument
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
268 ccall_common_init( rpc_dg_binding_client_p_t h, rpc_dg_ccall_p_t ccall, unsigned32 options, rpc_if_rep_p_t ifspec, unsigned32 opnum, unsigned32 *st ) argument
494 rpc_dg_ccall_p_t ccall; local
724 rpc_dg_ccall_p_t ccall; local
937 ccall_initial_cancel_setup( rpc_dg_ccall_p_t ccall, unsigned32 cancel_cnt, rpc_clock_t cancel_timeout_time ) argument
1015 rpc_dg_ccall_p_t ccall; local
1239 rpc_dg_ccall_p_t ccall; local
1577 rpc__dg_ccall_xmit_cancel_quit( rpc_dg_ccall_p_t ccall, unsigned32 cancel_id ) argument
2013 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) p; local
[all...]
H A Ddgclsn.c102 rpc_dg_ccall_p_t /*ccall*/
107 rpc_dg_ccall_p_t /*ccall*/
124 rpc_dg_ccall_p_t ccall
127 if (ccall->c.call_server_boot != 0 &&
128 rqe->hdrp->server_boot != ccall->c.call_server_boot)
132 rpc__dg_call_signal_failure(&ccall->c, rpc_s_wrong_boot_time);
156 rpc_dg_ccall_p_t ccall
194 if (ccall == NULL
195 || RPC_DG_SEQ_IS_LT(hdrp->seq, ccall->c.call_seq)
196 || (ptype == RPC_C_DG_PT_FAULT && ccall
543 ping_later( rpc_dg_ccall_p_t ccall, rpc_dg_recvq_elt_p_t rqe ATTRIBUTE_UNUSED ) argument
[all...]
H A Ddgccallt.c108 rpc_dg_ccall_p_t ccall
111 unsigned16 probe = ccall->c.actid_hash % RPC_DG_CCALLT_SIZE;
115 ccall->c.next = (rpc_dg_call_p_t) rpc_g_dg_ccallt[probe];
116 rpc_g_dg_ccallt[probe] = ccall;
117 RPC_DG_CALL_REFERENCE(&ccall->c);
130 rpc_dg_ccall_p_t ccall
133 unsigned16 probe = ccall->c.actid_hash % RPC_DG_CCALLT_SIZE;
137 RPC_DG_CALL_LOCK_ASSERT(&ccall->c);
138 assert(ccall->c.refcnt > 1);
148 if (scan_ccall == ccall) {
181 rpc_dg_ccall_p_t ccall; local
[all...]
H A Dconv.c107 rpc_dg_ccall_p_t * /*ccall*/,
126 rpc_dg_ccall_p_t *ccall,
134 *ccall = rpc__dg_ccallt_lookup(actuid, RPC_C_DG_NO_HINT);
137 * No ccall entry will exist if an old duplicate WAY callback request
138 * is received. If there is no ccall entry corresponding to the
144 if (*ccall == NULL)
155 if ((*ccall)->c.call_server_boot == 0)
157 (*ccall)->c.call_server_boot = boot_time;
171 if ((*ccall)->c.call_server_boot != boot_time)
174 RPC_DG_CCALL_RELEASE(ccall);
122 conv_common( idl_uuid_t *actuid, unsigned32 boot_time, rpc_dg_ccall_p_t *ccall, unsigned32 *st ) argument
203 rpc_dg_ccall_p_t ccall; local
262 rpc_dg_ccall_p_t ccall; local
299 rpc_dg_ccall_p_t ccall; local
403 rpc_dg_ccall_p_t ccall; local
[all...]
H A Ddgcct.c149 rpc_dg_ccall_p_t /*ccall*/,
176 rpc_dg_ccall_p_t ccall,
180 ccall->ccte_ref.ccte = ccte;
181 ccall->ccte_ref.gc_count = rpc_g_dg_cct.gc_count;
185 ccall->c.actid_hash = ccte->actid_hash;
186 ccall->c.auth_epv = ccte->auth_epv;
187 ccall->c.call_actid = ccte->actid;
188 ccall->c.call_ahint = RPC_C_DG_NO_HINT;
196 if (ccall->c.key_info != NULL)
198 RPC_DG_KEY_RELEASE(ccall
174 update_ccall_from_ccte( rpc_dg_ccall_p_t ccall, rpc_dg_cct_elt_p_t ccte ) argument
[all...]
H A Ddg.c156 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call; local
158 if (ccall->cancel.timeout_time > 0)
839 rpc_dg_ccall_p_t ccall; local
842 ccall = (rpc_dg_ccall_p_t) call_;
843 assert(RPC_DG_CALL_IS_CLIENT(&ccall->c));
845 assert(ccall->c.state == rpc_e_dg_cs_init || ccall->c.state == rpc_e_dg_cs_xmit);
847 RPC_DG_CALL_LOCK(&ccall->c);
857 if (ccall->c.state == rpc_e_dg_cs_init || xmit_data->num_elt > 0)
859 rpc__dg_call_transmit_int(&ccall
1000 rpc_dg_ccall_p_t ccall; local
1255 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call_; local
[all...]
H A Ddghnd.c116 if (h->ccall == NULL)
119 RPC_DG_CALL_LOCK(&h->ccall->c);
120 rpc__dg_ccall_free_prep(h->ccall);
121 RPC_DG_CCALL_RELEASE(&h->ccall);
180 h->ccall = NULL;
391 h->ccall = NULL;
H A Ddgscall.c256 rpc_dg_ccall_p_t ccall = scall->cbk_ccall; local
258 assert(ccall->cbk_scall == scall);
261 * Acquire the callback ccall lock. Note the locking hierarchy
265 RPC_DG_CALL_TRY_LOCK(&ccall->c, &b);
274 ccall->cbk_start = false;
278 RPC_DG_SCALL_RELEASE_NO_UNLOCK(&ccall->cbk_scall);
289 * to the client, free up the cached *server side* callback ccall
295 rpc_dg_ccall_p_t ccall = scall->cbk_ccall; local
297 assert(ccall->cbk_scall == scall);
300 * Acquire the callback ccall loc
962 rpc__dg_scall_cbk_alloc( rpc_dg_ccall_p_t ccall, rpc_dg_sock_pool_elt_p_t sp, rpc_dg_recvq_elt_p_t rqe ) argument
[all...]
H A Ddglsn.c1729 rpc_dg_ccall_p_t ccall = sp->ccall; local
1739 if (ccall->cbk_scall != NULL
1740 && ccall->cbk_scall->has_call_executor_ref == true)
1741 call = (rpc_dg_call_p_t) ccall->cbk_scall;
1743 call = (rpc_dg_call_p_t) ccall;
1827 ccall->cancel.local_count++;
1828 ccall->cancel.server_is_accepting = false;
2316 rpc_dg_ccall_p_t ccall; local
2328 ccall
2401 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call; local
2747 rpc_dg_ccall_p_t ccall; local
[all...]
H A Ddgcall.c219 * The ccall with the private socket may not have the reservation
233 * The ccall with the private socket has no reservation.
771 * level call handle type specific (i.e. ccall, scall) free routines.
856 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call; local
890 if ((! is_server && ! ccall->cbk_start) || is_server)
902 rpc__dg_network_select_dispatch(ccall->c.sock_ref->sock,
903 (dce_pointer_t) ccall->c.sock_ref, (boolean32) true, st);
945 if (ccall->cbk_start)
949 assert(ccall->cbk_scall != NULL);
950 ccall
1580 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call; local
1701 rpc_dg_ccall_p_t ccall = scall->cbk_ccall; local
[all...]
H A Ddgslsn.c151 * the ccall information the client server boot time processing will
1062 rpc_dg_ccall_p_t ccall; local
1084 ccall = rpc__dg_ccallt_lookup(&hdrp->actuid, hdrp->ahint);
1086 if (ccall == NULL)
1098 ccall->c.last_rcv_timestamp = rpc__clock_stamp();
1103 rpc__dg_ccall_lsct_inq_scall(ccall, &scall);
1110 switch (do_request_common(ccall->c.high_seq,
1124 rpc__dg_ccall_lsct_new_call(ccall, sp, rqe, &scall);
1156 RPC_DG_CCALL_RELEASE(&ccall);
1409 rpc_dg_ccall_p_t ccall; local
[all...]
H A Ddgsoc.h175 rpc_dg_ccall_p_t ccall; /* only valid if is_private */ member in struct:rpc_dg_sock_pool_elt_t
H A Ddgsoc.c177 rpc__dg_pkt_free_rqe((*sp)->rqe_list, (rpc_dg_call_p_t)(*sp)->ccall);
445 eltp->ccall = NULL;
715 (*sp)->ccall = NULL;
H A Ddgpkt.c811 PRIVATE rpc_dg_recvq_elt_p_t rpc__dg_pkt_alloc_rqe(ccall)
812 rpc_dg_ccall_p_t ccall;
822 if (ccall != NULL)
824 if (ccall->c.sock_ref->rqe_available == true)
826 rqe = ccall->c.sock_ref->rqe;
827 ccall->c.sock_ref->rqe_available = false;
842 else if (ccall->c.n_resvs == 0)
851 * Note: The ccall hasn't advertised larger fragment size than the
854 rpc__dg_pkt_adjust_reservation(&ccall->c, 1, true);
1263 * made for the original scall/ccall
[all...]
H A Ddgxq.c203 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call; local
207 sp = ccall->c.sock_ref;
222 ccall->h->c.c.rpc_addr->rpc_protseq_id,
H A Ddg.h1628 struct rpc_dg_ccall_t *cbk_ccall; /* -> callback paired ccall */
1679 * Callback SCALLs linger around for a while (cached on the paired ccall)
1736 * ccall / scall pairs depends on which side of the wire you're on (which
1740 * a ccall and need to get the associated is_cbk scall. In the original
1742 * the associated is_cbk ccall. See the above for a visual description.
1745 * ccall, is_cbk scall
1746 * scall, is_cbk ccall
1957 rpc_dg_ccall_p_t ccall; member in struct:rpc_dg_binding_client_t

Completed in 147 milliseconds