Lines Matching defs:rqe
119 rpc_dg_recvq_elt_p_t /*rqe*/
124 rpc_dg_recvq_elt_p_t /*rqe*/
129 rpc_dg_recvq_elt_p_t /*rqe*/
133 rpc_dg_recvq_elt_p_t /*rqe*/,
141 rpc_dg_recvq_elt_p_t /*rqe*/,
150 rpc_dg_recvq_elt_p_t /*rqe*/
161 rpc_dg_recvq_elt_p_t /*rqe*/,
168 rpc_dg_recvq_elt_p_t /*rqe*/,
175 rpc_dg_recvq_elt_p_t /*rqe*/,
182 rpc_dg_recvq_elt_p_t /*rqe*/,
189 rpc_dg_recvq_elt_p_t /*rqe*/,
196 rpc_dg_recvq_elt_p_t /*rqe*/,
300 * swapping into "rqe->hdr" and set "rqe->hdrp" to point to that.
305 rpc_dg_recvq_elt_p_t rqe
308 rpc_dg_pkt_hdr_p_t shdr = (rpc_dg_pkt_hdr_p_t) &rqe->pkt->hdr;
309 rpc_dg_pkt_hdr_p_t dhdr = &rqe->hdr;
355 rqe->hdrp = &rqe->hdr;
364 rpc_dg_recvq_elt_p_t rqe
369 rqe->hdrp = &rqe->hdr;
408 rpc_dg_recvq_elt_p_t rqe,
413 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
416 st_all = ((rpc_dg_epkt_body_p_t) &rqe->pkt->body)->st;
453 rpc_dg_recvq_elt_p_t /*rqe*/
509 rpc_dg_recvq_elt_p_t rqe
521 convq.head = rqe;
523 convq.tail->next = rqe;
524 convq.tail = rqe;
525 rqe->next = NULL;
527 if (convq.head == rqe)
590 rpc_dg_recvq_elt_p_t rqe;
604 rqe = convq.head;
620 (void) handle_conv_int(rqe->sock, rqe);
625 rpc__dg_pkt_free_rqe(rqe, NULL);
649 rpc_dg_recvq_elt_p_t rqe;
694 * drop all rqe's in the conv queue
696 while ((rqe = convq.head))
699 rpc__dg_pkt_free_rqe (rqe, NULL);
980 rpc_dg_recvq_elt_p_t rqe,
986 rpc_dg_raw_pkt_p_t rawpkt = rqe->pkt;
1028 rpc_dg_recvq_elt_p_t rqe,
1034 rpc_dg_raw_pkt_p_t rawpkt = rqe->pkt;
1094 rpc_dg_recvq_elt_p_t rqe,
1100 rpc_dg_raw_pkt_p_t rawpkt = rqe->pkt;
1138 rpc_dg_recvq_elt_p_t rqe,
1144 rpc_dg_pkt_hdr_p_t rqst_hdrp = rqe->hdrp;
1145 rpc_dg_raw_pkt_p_t rawpkt = rqe->pkt;
1284 INTERNAL void conv_stub_who_are_you_auth_more(rqe, resp_hdrp, clt_actid,
1286 rpc_dg_recvq_elt_p_t rqe;
1291 rpc_dg_pkt_hdr_p_t rqst_hdrp = rqe->hdrp;
1292 rpc_dg_raw_pkt_p_t rawpkt = rqe->pkt;
1402 rpc_dg_recvq_elt_p_t rqe
1406 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
1407 rpc_dg_raw_pkt_p_t rawpkt = rqe->pkt;
1474 rpc_dg_recvq_elt_p_t rqe
1486 rqe->from.rpc_protseq_id = sp->pseq_id;
1487 rqe->from.len = sizeof rqe->from.sa;
1489 iov[0].iov_base = (byte_p_t) rqe->pkt;
1490 iov[0].iov_len = sizeof(*rqe->pkt);
1492 for (i = 1, tmp = rqe->more_data; tmp != NULL; i++, tmp = tmp->more_data)
1503 (rpc_addr_p_t)(&rqe->from),
1523 rqe->frag_len = recv_len;
1524 for (cc = recv_len, tmp = rqe, num_rqes = 0;
1543 rqe->frag_len = 0;
1551 if (rqe->from.len <= 0 || rqe->from.len > sizeof rqe->from.sa)
1554 rqe->frag_len = 0;
1562 if ((rqe->pkt->hdr.hdr[0] & RPC_C_DG_VERS_MASK) != RPC_C_DG_PROTO_VERS)
1564 RPC_DBG_GPRINTF(("(recv_pkt) Bad RPC version (%u)\n", rqe->pkt->hdr.hdr[0]));
1565 rqe->frag_len = 0;
1574 * fields in the header. (Note that "swab_hdr" updates "rqe->hdrp".
1585 rqe->hdrp = (rpc_dg_pkt_hdr_p_t) &rqe->pkt->hdr;
1587 if (NDR_DREP_INT_REP(rqe->hdrp->drep) != ndr_g_local_drep.int_rep)
1589 swab_hdr(rqe);
1591 else if (rqe->hdrp->server_boot == 0)
1593 rqe->hdr = *rqe->hdrp;
1594 rqe->hdrp = &rqe->hdr;
1604 unpack_hdr(rqe);
1608 ptype = RPC_DG_HDR_INQ_PTYPE(rqe->hdrp);
1613 rqe->frag_len = 0;
1614 rqe->hdrp = NULL;
1625 fwd = RPC_DG_HDR_FLAG_IS_SET(rqe->hdrp, RPC_C_DG_PF_FORWARDED);
1647 rqe->hdrp->flags &= ~RPC_C_DG_PF_FORWARDED;
1648 rqe->hdrp->flags2 &= ~RPC_C_DG_PF2_FORWARDED_2;
1652 else if (RPC_DG_HDR_FLAG2_IS_SET(rqe->hdrp, RPC_C_DG_PF2_FORWARDED_2))
1663 rpc_dg_fpkt_p_t fpkt = (rpc_dg_fpkt_p_t) rqe->pkt;
1664 struct sockaddr *sp = (struct sockaddr *) &rqe->from.sa;
1674 rqe->from.len = fpkt->fhdr.len;
1676 rqe->hdrp->drep[0] = fpkt->fhdr.drep[0];
1677 rqe->hdrp->drep[1] = fpkt->fhdr.drep[1];
1678 rqe->hdrp->drep[2] = fpkt->fhdr.drep[2];
1679 fwd_len = rqe->pkt_len -
1681 rqe->frag_len -= sizeof(rpc_dg_fpkt_hdr_t);
1682 rqe->pkt_len -= sizeof(rpc_dg_fpkt_hdr_t);
1686 rqe->pkt->body.args[i] = fpkt->body.args[i];
1697 rqe->pkt->hdr.hdr[RPC_C_DG_RPHO_FLAGS] &= ~RPC_C_DG_PF_FORWARDED;
1701 if (! fwd && (unsigned32)recv_len < (rqe->hdrp->len + RPC_C_DG_RAW_PKT_HDR_SIZE))
1704 recv_len, (unsigned long)rqe->hdrp->len + RPC_C_DG_RAW_PKT_HDR_SIZE));
1705 rqe->frag_len = 0;
1706 rqe->hdrp = NULL;
1724 INTERNAL unsigned32 recv_pkt_private(sp, rqe)
1726 rpc_dg_recvq_elt_p_t rqe;
1770 recv_flag = recv_pkt(sp, rqe);
1868 rpc_dg_recvq_elt_p_t rqe,
1875 rpc_dg_fackpkt_body_p_t bodyp = (rpc_dg_fackpkt_body_p_t) &rqe->pkt->body;
1895 if (NDR_DREP_INT_REP(rqe->hdrp->drep) != ndr_g_local_drep.int_rep)
1932 selack_fragnum = rqe->hdrp->fragnum + 1;
1935 if (NDR_DREP_INT_REP(rqe->hdrp->drep) != ndr_g_local_drep.int_rep)
2029 if (RPC_DG_FRAGNUM_IS_LT(xq_curr->fragnum, rqe->hdrp->fragnum))
2119 rpc_dg_recvq_elt_p_t rqe,
2131 rpc_dg_fackpkt_body_p_t bodyp = (rpc_dg_fackpkt_body_p_t) &rqe->pkt->body;
2150 if (NDR_DREP_INT_REP(rqe->hdrp->drep) != ndr_g_local_drep.int_rep)
2190 if (rqe->hdrp->len > 12)
2192 do_selective_ack( rqe, call, window_incr, rexmit_cnt, curr_serial);
2274 rpc_dg_recvq_elt_p_t rqe
2277 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
2304 rpc__dg_sct_inq_scall(scte, &scall, rqe);
2359 else if (rpc__dg_do_common_response(sp, rqe, ccall))
2375 * is specified (initialize rqe's having an unspecified time so that
2376 * subsequent transmits using this rqe have a valid boot time). (Note
2383 if (! rpc__dg_svr_chk_and_set_sboot(rqe, sp))
2389 rpc__dg_fack_common(sp, rqe, call, &sent_data);
2421 rpc_dg_recvq_elt_p_t rqe,
2435 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
2438 rpc_dg_fackpkt_body_p_t bodyp = (rpc_dg_fackpkt_body_p_t) &rqe->pkt->body;
2499 ((rpc_dg_fackpkt_body_p_t) &rqe->pkt->body)->serial_num;
2508 && RPC_DG_FRAGNUM_IS_LTE(xq->head->fragnum, rqe->hdrp->fragnum); )
2557 do_fack_body(rqe, call, &window_incr, &rexmit_cnt, curr_serial);
2662 rqe->hdrp->fragnum, xq->cwindow_size, xq->blast_size,
2711 rpc_dg_recvq_elt_p_t /*rqe*/
2717 rpc_dg_recvq_elt_p_t rqe ATTRIBUTE_UNUSED
2721 (unsigned int) RPC_DG_HDR_INQ_PTYPE(rqe->hdrp)));
2735 rpc_dg_recvq_elt_p_t /*rqe*/
2741 rpc_dg_recvq_elt_p_t rqe
2744 rpc_dg_pkt_hdr_p_t hdrp = rqe->hdrp;
2786 unsigned32 temp_ret = rpc__dg_fwd_pkt(sp, rqe);
2825 (rpc_addr_p_t) &rqe->from, rqe->hdrp, RPC_C_DG_PT_REJECT,
2852 (rpc_addr_p_t) &rqe->from, rqe->hdrp, RPC_C_DG_PT_REJECT,
2874 ptype = RPC_DG_HDR_INQ_PTYPE(rqe->hdrp);
2876 UUID_EQ(rqe->hdrp->actuid, sp->ccall->c.call_actid, &st))
2878 rdflags = rpc__dg_do_response(sp, rqe, sp->ccall);
2906 * the appropriate response to the server and free the rqe.
2929 drop = ! rpc__dg_svr_chk_and_set_sboot (rqe, sp);
2932 drop = rpc__dg_handle_conv(sp->sock, rqe);
2945 return (drop ? RPC_C_DG_RDF_FREE_RQE : 0 /* DON'T free the rqe */);
2991 rpc__dg_sct_inq_scall(scte, &scall, rqe);
3056 if (ptype != RPC_C_DG_PT_NOCALL && rqe->hdrp->seq >= call->call_seq)
3085 case RPC_C_DG_PT_FACK: rdflags = do_fack(sp, rqe); break;
3086 case RPC_C_DG_PT_REQUEST: rdflags = rpc__dg_do_request(sp, rqe); break;
3091 case RPC_C_DG_PT_PING: rdflags = rpc__dg_do_ping(sp, rqe, scall); break;
3092 case RPC_C_DG_PT_ACK: rdflags = rpc__dg_do_ack(sp, rqe, scall); break;
3093 case RPC_C_DG_PT_QUIT: rdflags = rpc__dg_do_quit(sp, rqe, scall); break;
3098 case RPC_C_DG_PT_RESPONSE: rdflags = rpc__dg_do_response(sp, rqe, ccall); break;
3099 case RPC_C_DG_PT_FAULT: rdflags = rpc__dg_do_fault(sp, rqe, ccall); break;
3100 case RPC_C_DG_PT_WORKING: rdflags = rpc__dg_do_working(sp, rqe, ccall); break;
3101 case RPC_C_DG_PT_NOCALL: rdflags = rpc__dg_do_nocall(sp, rqe, ccall); break;
3102 case RPC_C_DG_PT_REJECT: rdflags = rpc__dg_do_reject(sp, rqe, ccall); break;
3103 case RPC_C_DG_PT_QUACK: rdflags = rpc__dg_do_quack(sp, rqe, ccall); break;
3108 default: rdflags = do_bad_pkt(sp, rqe); break;
3149 rpc_dg_recvq_elt_p_t rqe;
3185 rqe = saved_rqe_list;
3191 * 1) no reservation (using the private xqe/rqe pair),
3209 rqe = sp->rqe_list;
3232 rqe = rpc__dg_pkt_alloc_rqe(sp->ccall);
3233 rqe->more_data = *rqe_list;
3234 *rqe_list = rqe;
3238 assert(rqe == *rqe_list);
3241 * There should always be an available rqe thanks to rationing AND
3247 if (rqe == NULL)
3259 (in_listener_thread ? recv_pkt(sp, rqe) :
3260 recv_pkt_private(sp, rqe))) == 0)
3267 RPC_DG_HDR_FLAG_IS_SET(rqe->hdrp, RPC_C_DG_PF_FRAG) &&
3268 RPC_DG_HDR_FLAG_IS_SET(rqe->hdrp, RPC_C_DG_PF_NO_FACK) &&
3269 ! RPC_DG_HDR_FLAG_IS_SET(rqe->hdrp, RPC_C_DG_PF_LAST_FRAG);
3273 * just free the rqe. Otherwise, call "recv_dispatch and use
3280 rqe->next = NULL;
3281 rqe->frag_len = 0;
3282 rqe->hdrp = NULL;
3289 * Remove rqe from the cache.
3299 rdflags = recv_dispatch(sp, rqe);
3330 * Return rqe to the cache.
3332 tmp = rqe;
3339 *rqe_list = rqe;