Lines Matching refs:ccall
1729 rpc_dg_ccall_p_t ccall = sp->ccall;
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;
2328 ccall = rpc__dg_ccallt_lookup(&hdrp->actuid, RPC_C_DG_NO_HINT);
2329 if (ccall == NULL)
2342 if (ccall->cbk_scall != NULL && !ccall->c.is_cbk &&
2343 hdrp->seq == ccall->cbk_scall->c.call_seq)
2345 call = &ccall->cbk_scall->c;
2355 RPC_DG_CCALL_RELEASE(&ccall);
2359 else if (rpc__dg_do_common_response(sp, rqe, ccall))
2361 call = &ccall->c;
2365 RPC_DG_CCALL_RELEASE(&ccall);
2401 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call;
2402 RPC_DG_CCALL_RELEASE(&ccall);
2747 rpc_dg_ccall_p_t ccall;
2876 UUID_EQ(rqe->hdrp->actuid, sp->ccall->c.call_actid, &st))
2878 rdflags = rpc__dg_do_response(sp, rqe, sp->ccall);
2889 if (sp->ccall->cbk_scall != NULL
2890 && sp->ccall->cbk_scall->has_call_executor_ref == true)
2891 locked_call = (rpc_dg_call_p_t) sp->ccall->cbk_scall;
2893 locked_call = (rpc_dg_call_p_t) sp->ccall;
2948 ccall = NULL;
2998 ccall = scall->cbk_ccall;
2999 RPC_DG_CALL_LOCK(&ccall->c);
3000 RPC_DG_CALL_REFERENCE(&ccall->c);
3008 ccall = rpc__dg_ccallt_lookup(&hdrp->actuid, RPC_C_DG_NO_HINT);
3009 if (ccall != NULL)
3017 rpc__dg_ccall_lsct_inq_scall(ccall, &scall);
3021 RPC_DG_CCALL_RELEASE(&ccall);
3027 assert((scall == NULL) || (ccall == NULL));
3039 assert(ccall != NULL);
3040 call = &ccall->c;
3098 case RPC_C_DG_PT_RESPONSE: rdflags = rpc__dg_do_response(sp, rqe, ccall); break;
3099 case RPC_C_DG_PT_FAULT: rdflags = rpc__dg_do_fault(sp, rqe, ccall); break;
3100 case RPC_C_DG_PT_WORKING: rdflags = rpc__dg_do_working(sp, rqe, ccall); break;
3101 case RPC_C_DG_PT_NOCALL: rdflags = rpc__dg_do_nocall(sp, rqe, ccall); break;
3102 case RPC_C_DG_PT_REJECT: rdflags = rpc__dg_do_reject(sp, rqe, ccall); break;
3103 case RPC_C_DG_PT_QUACK: rdflags = rpc__dg_do_quack(sp, rqe, ccall); break;
3115 else if (ccall != NULL)
3117 RPC_DG_CCALL_RELEASE(&ccall);
3200 n_pkts = sp->ccall->c.n_resvs;
3232 rqe = rpc__dg_pkt_alloc_rqe(sp->ccall);