Lines Matching defs:rqe
121 rpc_dg_recvq_elt_p_t /*rqe*/,
129 #define RPC_DG_IS_ORPHAN_QUIT(rqe) ((rqe)->hdrp->len == 0)
157 rpc_dg_recvq_elt_p_t rqe,
161 if (rqe->hdrp->server_boot == 0)
163 rqe->hdrp->server_boot = rpc_g_dg_server_boot_time;
168 if (rqe->hdrp->server_boot == rpc_g_dg_server_boot_time)
174 rpc__dg_act_seq_string(rqe->hdrp)));
175 rpc__dg_xmit_error_body_pkt((sp)->sock, (rpc_addr_p_t) &rqe->from,
176 rqe->hdrp, RPC_C_DG_PT_REJECT, nca_s_wrong_boot_time);
253 rpc_dg_recvq_elt_p_t rqe,
261 rpc_dg_quitpkt_body_p_t bodyp = (rpc_dg_quitpkt_body_p_t) &rqe->pkt->body;
270 rpc__dg_act_seq_string(rqe->hdrp)));
280 if (NDR_DREP_INT_REP(rqe->hdrp->drep) != ndr_g_local_drep.int_rep)
302 if (rqe->hdrp->seq > scall->c.call_seq)
313 rpc__dg_act_seq_string(rqe->hdrp)));
346 rpc__dg_act_seq_string(rqe->hdrp)));
375 rpc__dg_act_seq_string(rqe->hdrp)));
404 rpc_dg_recvq_elt_p_t rqe,
408 if (! rpc__dg_svr_chk_and_set_sboot(rqe, sp))
419 if (scall == NULL || RPC_DG_SEQ_IS_LT(rqe->hdrp->seq, scall->c.call_seq))
423 rpc__dg_act_seq_string(rqe->hdrp)));
430 if (! RPC_DG_IS_ORPHAN_QUIT(rqe))
432 do_quit_body(rqe, scall);
443 rpc__dg_act_seq_string(rqe->hdrp)));
444 rpc__dg_xmit_hdr_only_pkt(sp->sock, (rpc_addr_p_t) &rqe->from, rqe->hdrp,
453 if (rqe->hdrp->seq > scall->c.call_seq)
474 rpc__dg_act_seq_string(rqe->hdrp)));
502 rpc_dg_recvq_elt_p_t rqe,
506 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
509 if (! rpc__dg_svr_chk_and_set_sboot(rqe, sp))
572 rpc_dg_recvq_elt_p_t /*rqe*/,
579 rpc_dg_recvq_elt_p_t rqe,
585 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
606 rpc__dg_xmit_hdr_only_pkt(sp->sock, (rpc_addr_p_t) &rqe->from, rqe->hdrp,
626 rpc__dg_call_xmit_fack(&scall->c, rqe, true);
672 rpc__dg_xmit_hdr_only_pkt(sp->sock, (rpc_addr_p_t) &rqe->from, rqe->hdrp,
689 rpc__dg_xmit_hdr_only_pkt(sp->sock, (rpc_addr_p_t) &rqe->from, rqe->hdrp,
719 rpc_dg_recvq_elt_p_t rqe,
723 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
727 if (! rpc__dg_svr_chk_and_set_sboot(rqe, sp))
742 rpc__dg_xmit_hdr_only_pkt(sp->sock, (rpc_addr_p_t) &rqe->from, rqe->hdrp,
766 rpc__dg_xmit_hdr_only_pkt(sp->sock, (rpc_addr_p_t) &rqe->from, rqe->hdrp,
779 ping_common(sp, rqe, scall);
818 rpc_dg_recvq_elt_p_t /*rqe*/
825 rpc_dg_recvq_elt_p_t rqe
828 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
1050 rpc_dg_recvq_elt_p_t /*rqe*/,
1057 rpc_dg_recvq_elt_p_t rqe,
1063 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
1112 rqe))
1124 rpc__dg_ccall_lsct_new_call(ccall, sp, rqe, &scall);
1132 ping_common(sp, rqe, scall);
1136 rpc__dg_xmit_error_body_pkt(sp->sock, (rpc_addr_p_t) &rqe->from,
1191 rpc_dg_recvq_elt_p_t rqe
1198 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
1204 client_needs_sboot = (rqe->hdrp->server_boot == 0);
1206 if (! rpc__dg_svr_chk_and_set_sboot(rqe, sp))
1220 drop = (do_cbk_request(sp, rqe, &scall) == false);
1234 rpc__dg_handle_convc(rqe);
1250 rpc__dg_sct_inq_scall(scte, &scall, rqe);
1259 rqe))
1278 rpc__dg_sct_new_call(scte, sp, rqe, &scall);
1286 ping_common(sp, rqe, scall);
1290 rpc__dg_xmit_error_body_pkt(sp->sock, (rpc_addr_p_t) &rqe->from,
1344 * address and drep from the first rqe into the current one, free
1345 * the first rqe, and proceed as if none of this nightmare had
1350 && ! RPC_DG_HDR_FLAG_IS_SET(rqe->hdrp, RPC_C_DG_PF_FORWARDED)
1351 && UUID_EQ(rqe->hdrp->actuid, scall->fwd2_rqe->hdrp->actuid, &st)
1352 && rqe->hdrp->seq == scall->fwd2_rqe->hdrp->seq
1353 && rqe->hdrp->fragnum == scall->fwd2_rqe->hdrp->fragnum)
1356 struct sockaddr *sp = (struct sockaddr *) &rqe->from.sa;
1358 rqe->from.len = fpkt->fhdr.len;
1360 rpc__naf_addr_overcopy((rpc_addr_p_t) &rqe->from, &scall->c.addr, &st);
1362 rqe->hdrp->drep[0] = fpkt->fhdr.drep[0];
1363 rqe->hdrp->drep[1] = fpkt->fhdr.drep[1];
1364 rqe->hdrp->drep[2] = fpkt->fhdr.drep[2];
1372 * this rqe away for now and return. (Note that single packet forwards
1380 scall->fwd2_rqe = rqe;
1382 return (0 /* DON'T free the rqe */);
1549 drop = ! rpc__dg_call_recvq_insert(&scall->c, rqe, &rqe_wake_thread);
1579 return (RPC_C_DG_RDF_YIELD /* and DON'T free the rqe */);