Lines Matching refs:ccall
156 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call;
158 if (ccall->cancel.timeout_time > 0)
839 rpc_dg_ccall_p_t ccall;
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->c, xmit_data, st);
863 RPC_DG_CALL_UNLOCK(&ccall->c);
868 rpc__dg_call_xmitq_push(&ccall->c, st);
871 RPC_DG_CALL_UNLOCK(&ccall->c);
880 if (ccall->c.xq.base_flags & RPC_C_DG_PF_MAYBE)
885 ccall->c.rq.all_pkts_recvd = true;
889 RPC_DG_PING_INFO_INIT(&ccall->ping);
890 RPC_DG_CALL_SET_STATE(&ccall->c, rpc_e_dg_cs_recv);
892 rpc__dg_call_receive_int(&ccall->c, recv_data, st);
916 h = (rpc_dg_binding_client_p_t) ccall->h;
917 if (! h->c.c.bound_server_instance && ccall->server_bound)
925 RPC_DG_CALL_UNLOCK(&ccall->c);
927 RPC_DG_CALL_LOCK(&ccall->c);
930 h->server_boot = ccall->c.call_server_boot;
931 rpc__naf_addr_overcopy(ccall->c.addr, &h->c.c.rpc_addr, &tst);
942 RPC_DG_CALL_UNLOCK(&ccall->c);
1000 rpc_dg_ccall_p_t ccall;
1004 ccall = (rpc_dg_ccall_p_t) call_;
1005 assert(RPC_DG_CALL_IS_CLIENT(&ccall->c));
1006 if (ccall->fault_rqe == NULL)
1011 rqe = ccall->fault_rqe;
1015 RPC_DG_CALL_LOCK(&ccall->c);
1026 key_info = ccall->c.key_info;
1033 rpc_dg_auth_epv_p_t auth_epv = ccall->c.auth_epv;
1130 rpc__dg_pkt_free_rqe(last_rqe->more_data, &ccall->c);
1150 rpc__dg_pkt_free_rqe(rqe, &ccall->c);
1151 ccall->fault_rqe = NULL; /* we no longer own the rqe */
1152 RPC_DG_CALL_UNLOCK(&ccall->c);
1165 ccall->fault_rqe = rqe->more_data;
1166 ccall->fault_rqe->next = rqe->next; /* should be NULL */
1170 ccall->fault_rqe = NULL;
1176 RPC_DG_CALL_UNLOCK(&ccall->c);
1255 rpc_dg_ccall_p_t ccall = (rpc_dg_ccall_p_t) call_;
1256 rpc_dg_xmitq_p_t xq = &ccall->c.xq;
1261 RPC_DG_CALL_LOCK(&ccall->c);
1267 if (ccall->c.call_server_boot == 0 &&
1278 switch ((int)ccall->reject_status)
1310 RPC_DG_CALL_UNLOCK(&ccall->c);