Lines Matching defs:rqe
107 rpc_dg_recvq_elt_p_t /*rqe*/
112 rpc_dg_recvq_elt_p_t /*rqe*/,
118 rpc_dg_recvq_elt_p_t /*rqe*/
147 rpc_dg_recvq_elt_p_t rqe)
149 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
204 (rpc_addr_p_t) &rqe->from,
234 fwd_reject(sp, rqe);
238 fwd_forward(sp, rqe, fwd_addr);
242 fwd_delayed(sp, rqe);
260 rpc_dg_recvq_elt_p_t rqe)
265 rpc__dg_pkt_name(RPC_DG_HDR_INQ_PTYPE(rqe->hdrp)),
266 rpc__dg_act_seq_string(rqe->hdrp)));
268 if (! RPC_DG_HDR_FLAG_IS_SET(rqe->hdrp, RPC_C_DG_PF_BROADCAST))
271 sp->sock, (rpc_addr_p_t) &rqe->from, rqe->hdrp, RPC_C_DG_PT_REJECT,
285 rpc_dg_recvq_elt_p_t rqe,
288 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
289 rpc_dg_raw_pkt_hdr_p_t rhdrp = &rqe->pkt->hdr;
305 fhdr.len = rqe->from.len;
307 /*b_c_o_p_y((byte_p_t) &rqe->from.sa, (byte_p_t) &fhdr.addr, fhdr.len);*/
308 memmove((byte_p_t)&fhdr.addr, (byte_p_t)&rqe->from.sa, fhdr.len) ;
366 if (rqe->pkt_len + sizeof(rpc_dg_fpkt_hdr_t) <= RPC_C_DG_INITIAL_MAX_PKT_SIZE)
368 iov[2].iov_base = ((byte_p_t) rqe->pkt) + RPC_C_DG_RAW_PKT_HDR_SIZE;
369 iov[2].iov_len = rqe->pkt_len - RPC_C_DG_RAW_PKT_HDR_SIZE;
400 iov[1].iov_base = ((byte_p_t) rqe->pkt) + RPC_C_DG_RAW_PKT_HDR_SIZE;
401 iov[1].iov_len = rqe->pkt_len - RPC_C_DG_RAW_PKT_HDR_SIZE;
421 rpc_dg_recvq_elt_p_t rqe;
449 rpc_dg_recvq_elt_p_t rqe)
460 new_pkt->rqe = rqe;
489 rpc_dg_recvq_elt_p_t rqe = (rpc_dg_recvq_elt_p_t)-1;
502 hdrp = ep->rqe->hdrp;
506 rqe = ep->rqe;
538 rpc__dg_pkt_name(RPC_DG_HDR_INQ_PTYPE(rqe->hdrp)),
539 rpc__dg_act_seq_string(rqe->hdrp)));
543 fwd_reject(sp, rqe);
547 fwd_forward(sp, rqe, fwd_addr);
555 if (rqe == (rpc_dg_recvq_elt_p_t)-1) {
556 fprintf(stderr, "%s: bad rqe: aborting\n", __PRETTY_FUNCTION__);
559 rpc__dg_pkt_free_rqe(rqe, NULL);