Lines Matching defs:rqe
101 rpc_dg_recvq_elt_p_t /*rqe*/,
106 rpc_dg_recvq_elt_p_t /*rqe*/,
123 rpc_dg_recvq_elt_p_t rqe,
128 rqe->hdrp->server_boot != ccall->c.call_server_boot)
131 rpc__dg_act_seq_string(rqe->hdrp)));
155 rpc_dg_recvq_elt_p_t rqe,
159 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
204 rpc__dg_xmit_hdr_only_pkt(sp->sock, (rpc_addr_p_t) &rqe->from,
205 rqe->hdrp, RPC_C_DG_PT_ACK);
209 rpc__dg_pkt_name(ptype), rpc__dg_act_seq_string(rqe->hdrp)));
225 rpc__dg_pkt_name(ptype), rpc__dg_act_seq_string(rqe->hdrp)));
240 if (! chk_sboot(rqe, ccall))
289 rpc__naf_addr_overcopy((rpc_addr_p_t) &rqe->from, &ccall->c.addr, &st);
336 rpc_dg_recvq_elt_p_t rqe,
346 if (! rpc__dg_do_common_response(sp, rqe, ccall))
350 rpc__dg_act_seq_string(rqe->hdrp)));
384 rpc__dg_get_epkt_body_st(rqe, &ccall->reject_status);
416 rpc_dg_recvq_elt_p_t rqe,
425 if (! rpc__dg_do_common_response(sp, rqe, ccall))
429 rpc__dg_act_seq_string(rqe->hdrp)));
450 ccall->fault_rqe = rqe;
453 return (0 /* DON'T free the rqe */);
465 rpc_dg_recvq_elt_p_t rqe,
477 if (! rpc__dg_do_common_response(sp, rqe, ccall))
503 drop = ! rpc__dg_call_recvq_insert(&ccall->c, rqe, &rqe_wake_thread);
507 * rqe's to warrant wakeing up the client then do so.
526 return (RPC_C_DG_RDF_YIELD /* and DON'T free the rqe */);
528 return (0 /* DON'T free the rqe */);
540 rpc_dg_recvq_elt_p_t /*rqe*/
546 rpc_dg_recvq_elt_p_t rqe ATTRIBUTE_UNUSED
586 rpc__dg_act_seq_string(rqe->hdrp)));
601 rpc_dg_recvq_elt_p_t rqe,
613 if (! rpc__dg_do_common_response(sp, rqe, ccall))
635 ping_later(ccall, rqe);
652 rpc_dg_recvq_elt_p_t rqe,
668 || RPC_DG_SEQ_IS_LT(rqe->hdrp->seq, ccall->c.call_seq)
674 rpc__dg_act_seq_string(rqe->hdrp)));
680 if (! chk_sboot(rqe, ccall))
701 rpc__dg_act_seq_string(rqe->hdrp)));
715 if (rqe->hdrp->len > 0)
725 rpc__dg_act_seq_string(rqe->hdrp)));
727 rpc__dg_fack_common(sp, rqe, &ccall->c, &sent_data);
741 ping_later(ccall, rqe);
782 xq->blast_size, rpc__dg_act_seq_string(rqe->hdrp)));
796 rpc_dg_recvq_elt_p_t rqe,
805 rpc_dg_quackpkt_body_p_t bodyp = (rpc_dg_quackpkt_body_p_t) &rqe->pkt->body;
814 rpc__dg_act_seq_string(rqe->hdrp)));
826 if (NDR_DREP_INT_REP(rqe->hdrp->drep) != ndr_g_local_drep.int_rep)
857 rpc__dg_act_seq_string(rqe->hdrp)));
881 rpc_dg_recvq_elt_p_t rqe,
889 if (! rpc__dg_do_common_response(sp, rqe, ccall))
894 rqe->hdrp->len != 0 ? "cancel" : "orphan",
895 rpc__dg_act_seq_string(rqe->hdrp)));
903 if (rqe->hdrp->len != 0)
905 do_quack_body(rqe, ccall);
920 rpc__dg_act_seq_string(rqe->hdrp)));