/macosx-10.10.1/dcerpc-61/dcerpc/ncklib/ |
H A D | dgccall.h | 105 * 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 D | dgccall.c | 109 * 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 D | dgclsn.c | 102 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 D | dgccallt.c | 108 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 D | conv.c | 107 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 D | dgcct.c | 149 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 D | dg.c | 156 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 D | dghnd.c | 116 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 D | dgscall.c | 256 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 D | dglsn.c | 1729 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 D | dgcall.c | 219 * 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 D | dgslsn.c | 151 * 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 D | dgsoc.h | 175 rpc_dg_ccall_p_t ccall; /* only valid if is_private */ member in struct:rpc_dg_sock_pool_elt_t
|
H A D | dgsoc.c | 177 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 D | dgpkt.c | 811 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 D | dgxq.c | 203 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 D | dg.h | 1628 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
|