Lines Matching defs:ccall
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;
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->cbk_start = false;
952 RPC_DG_CALL_LOCK(&ccall->cbk_scall->c);
953 RPC_DG_CALL_REFERENCE(&ccall->cbk_scall->c);
954 ccall->cbk_scall->has_call_executor_ref = true;
956 RPC_DG_CALL_UNLOCK(&ccall->c);
959 rpc__dg_execute_call((dce_pointer_t) &ccall->cbk_scall->c, false);
962 RPC_DG_CALL_LOCK(&ccall->c);
1255 * Note that it is ok for a ccall to queue data before it has made
1580 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call;
1583 * All local detected cancels while dealing with a ccall are
1592 ccall->cancel.local_count++;
1593 rpc__dg_ccall_setup_cancel_tmo(ccall);
1596 ("(rpc__dg_call_local_cancel) ccall fwd [%s]\n",
1597 rpc__dg_act_seq_string(&ccall->c.xq.hdr)));
1599 rpc__dg_ccall_xmit_cancel_quit(ccall, ccall->cancel.local_count);
1672 * the normal ccall; forward the cancel to the server
1701 rpc_dg_ccall_p_t ccall = scall->cbk_ccall;
1704 RPC_DG_CALL_TRY_LOCK(&ccall->c, &b);
1708 ("(rpc__dg_call_local_cancel) cbk_scall can't get ccall lock [%s]\n",
1715 ccall->cancel.local_count++;
1716 rpc__dg_ccall_setup_cancel_tmo(ccall);
1719 ("(rpc__dg_call_local_cancel) cbk_scall ccall fwd [%s]\n",
1720 rpc__dg_act_seq_string(&ccall->c.xq.hdr)));
1722 rpc__dg_ccall_xmit_cancel_quit(ccall,
1723 ccall->cancel.local_count);
1724 RPC_DG_CALL_UNLOCK(&ccall->c);