Lines Matching refs:ccall
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->fault_rqe != NULL)
197 || (ptype == RPC_C_DG_PT_WORKING && ccall->c.state != rpc_e_dg_cs_recv))
213 RPC_DG_CALL_LOCK_ASSERT(&ccall->c);
220 if (ccall->c.state == rpc_e_dg_cs_orphan
237 if (ccall->c.rq.all_pkts_recvd)
240 if (! chk_sboot(rqe, ccall))
256 if (! ccall->response_info_updated)
258 ccall->response_info_updated = true;
259 ccall->c.call_ahint = hdrp->ahint;
260 ccall->c.call_ihint = hdrp->ihint;
262 ccall->c.com_timeout_knob = MAX(ccall->c.com_timeout_knob,
275 if (RPC_DG_SEQ_IS_LT(ccall->c.high_seq,hdrp->seq))
276 ccall->c.high_seq = hdrp->seq;
285 if (! ccall->server_bound)
287 ccall->server_bound = true;
288 ccall->c.call_server_boot = hdrp->server_boot;
289 rpc__naf_addr_overcopy((rpc_addr_p_t) &rqe->from, &ccall->c.addr, &st);
291 if ((ccall->c.xq.base_flags & RPC_C_DG_PF_BROADCAST) != 0)
293 RPC_DG_CALL_SET_MAX_FRAG_SIZE(&ccall->c, &st);
297 ccall->c.xq.max_frag_size,
298 ccall->c.rq.window_size);
301 ccall->c.rq.window_size, sp->rcvbuf, ccall->c.xq.max_frag_size));
314 if (!ccall->cancel.server_had_pending)
319 ccall->cancel.server_had_pending = true;
337 rpc_dg_ccall_p_t ccall
346 if (! rpc__dg_do_common_response(sp, rqe, ccall))
352 RPC_DG_CALL_LOCK_ASSERT(&ccall->c);
358 if (ccall->c.state == rpc_e_dg_cs_orphan)
360 ccall->quit.quack_rcvd = true;
361 rpc__dg_call_signal(&ccall->c);
370 if (ccall->c.xq.head != NULL)
371 rpc__dg_xmitq_free(&ccall->c.xq, &ccall->c);
377 ccall->c.rq.all_pkts_recvd = true;
384 rpc__dg_get_epkt_body_st(rqe, &ccall->reject_status);
386 switch ((int)ccall->reject_status)
399 rpc__dg_call_signal_failure(&ccall->c, mst);
417 rpc_dg_ccall_p_t ccall
425 if (! rpc__dg_do_common_response(sp, rqe, ccall))
431 RPC_DG_CALL_LOCK_ASSERT(&ccall->c);
437 if (ccall->c.state == rpc_e_dg_cs_orphan)
439 ccall->quit.quack_rcvd = true;
440 rpc__dg_call_signal(&ccall->c);
448 ccall->c.rq.all_pkts_recvd = true;
450 ccall->fault_rqe = rqe;
451 rpc__dg_call_signal_failure(&ccall->c, rpc_s_call_faulted);
466 rpc_dg_ccall_p_t ccall
477 if (! rpc__dg_do_common_response(sp, rqe, ccall))
480 RPC_DG_CALL_LOCK_ASSERT(&ccall->c);
482 xq = &ccall->c.xq;
490 rpc__dg_xmitq_free(xq, &ccall->c);
496 RPC_DG_PING_INFO_INIT(&ccall->ping);
503 drop = ! rpc__dg_call_recvq_insert(&ccall->c, rqe, &rqe_wake_thread);
512 rpc__dg_call_signal(&ccall->c);
534 * Schedule a ping to happen later for the specified ccall. This routine is
539 rpc_dg_ccall_p_t /*ccall*/,
545 rpc_dg_ccall_p_t ccall,
552 ping = &ccall->ping;
572 duration = now - ccall->c.start_time;
602 rpc_dg_ccall_p_t ccall
613 if (! rpc__dg_do_common_response(sp, rqe, ccall))
616 RPC_DG_CALL_LOCK_ASSERT(&ccall->c);
618 xq = &ccall->c.xq;
632 rpc__dg_xmitq_free(xq, &ccall->c);
635 ping_later(ccall, rqe);
653 rpc_dg_ccall_p_t ccall
667 if (ccall == NULL
668 || RPC_DG_SEQ_IS_LT(rqe->hdrp->seq, ccall->c.call_seq)
669 || ccall->c.state != rpc_e_dg_cs_recv
670 || ccall->c.status != rpc_s_ok)
678 RPC_DG_CALL_LOCK_ASSERT(&ccall->c);
680 if (! chk_sboot(rqe, ccall))
685 xq = &ccall->c.xq;
691 if (ccall->c.state == rpc_e_dg_cs_orphan)
693 ccall->quit.quack_rcvd = true;
694 rpc__dg_call_signal(&ccall->c);
709 RPC_DG_PING_INFO_INIT(&ccall->ping);
727 rpc__dg_fack_common(sp, rqe, &ccall->c, &sent_data);
741 ping_later(ccall, rqe);
762 && (ccall->c.xq.base_flags & RPC_C_DG_PF_IDEMPOTENT))
764 ccall->cancel.server_count = 0;
765 ccall->cancel.server_is_accepting = true;
766 ccall->cancel.server_had_pending = false;
767 /* Retain *current* ccall->cancel.local_count */
778 rpc__dg_xmitq_restart(&ccall->c);
797 rpc_dg_ccall_p_t ccall
853 if (cancel_id < ccall->cancel.server_count)
861 ccall->cancel.server_count = cancel_id;
862 ccall->cancel.server_is_accepting = server_is_accepting;
882 rpc_dg_ccall_p_t ccall
889 if (! rpc__dg_do_common_response(sp, rqe, ccall))
897 RPC_DG_CALL_LOCK_ASSERT(&ccall->c);
905 do_quack_body(rqe, ccall);
915 if (ccall->c.state != rpc_e_dg_cs_orphan)
919 rpc__dg_call_state_name(ccall->c.state),
921 rpc__dg_call_signal_failure(&ccall->c, rpc_s_call_cancelled);
931 ccall->quit.quack_rcvd = true;
932 rpc__dg_call_signal(&ccall->c);