rq
#define CLNT_CONTROL(cl,rq,in) ((*(cl)->cl_ops->cl_control)(cl,rq,in))
#define clnt_control(cl,rq,in) ((*(cl)->cl_ops->cl_control)(cl,rq,in))
#define SVC_CONTROL(xprt, rq, in) \
(*(xprt)->xp_ops2->xp_control)((xprt), (rq), (in))
svc_dg_control(SVCXPRT *xprt, const u_int rq, void *in)
svc_raw_control(SVCXPRT *xprt, const u_int rq, void *in)
svc_vc_control(SVCXPRT *xprt, const u_int rq, void *in)
svc_vc_rendezvous_control(SVCXPRT *xprt, const u_int rq, void *in)
switch (rq) {
rquota_to_quotavals(const struct rquota *rq,
blocks->qv_hardlimit = rq_scalelimit(rq->rq_bhardlimit, rq->rq_bsize);
blocks->qv_softlimit = rq_scalelimit(rq->rq_bsoftlimit, rq->rq_bsize);
blocks->qv_usage = rq_scale(rq->rq_curblocks, rq->rq_bsize);
blocks->qv_expiretime = rq->rq_btimeleft + now.tv_sec;
files->qv_hardlimit = rq_plainlimit(rq->rq_fhardlimit);
files->qv_softlimit = rq_plainlimit(rq->rq_fsoftlimit);
files->qv_usage = rq->rq_curfiles;
files->qv_expiretime = rq->rq_ftimeleft + now.tv_sec;
struct rquota *rq)
rq->rq_active = TRUE;
rq->rq_bsize = DEV_BSIZE;
rq->rq_bhardlimit = limit_to_rquota(blocks->qv_hardlimit);
rq->rq_bsoftlimit = limit_to_rquota(blocks->qv_softlimit);
rq->rq_curblocks = blocks->qv_usage;
rq->rq_btimeleft = time_to_rquota(blocks->qv_expiretime, now.tv_sec);
rq->rq_fhardlimit = limit_to_rquota(files->qv_hardlimit);
rq->rq_fsoftlimit = limit_to_rquota(files->qv_softlimit);
rq->rq_curfiles = files->qv_usage;
rq->rq_ftimeleft = time_to_rquota(files->qv_expiretime, now.tv_sec);
xdc_rqinit(struct xd_iorq *rq, struct xdc_softc *xdc, struct xd_softc *xd,
rq->xdc = xdc;
rq->xd = xd;
rq->ttl = XDC_MAXTTL + 10;
rq->mode = md;
rq->tries = rq->errno = rq->lasterror = 0;
rq->blockno = blk;
rq->sectcnt = cnt;
rq->dbuf = rq->dbufbase = db;
rq->buf = bp;
xyc_rqinit(struct xy_iorq *rq, struct xyc_softc *xyc, struct xy_softc *xy,
rq->xyc = xyc;
rq->xy = xy;
rq->ttl = XYC_MAXTTL + 10;
rq->mode = md;
rq->tries = rq->errno = rq->lasterror = 0;
rq->blockno = blk;
rq->sectcnt = cnt;
rq->dbuf = rq->dbufbase = db;
rq->buf = bp;
int errno, rq, comm, errs;
for (rq = 0; rq < XYC_MAXIOPB; rq++) {
iorq = xycsc->xy_chain[rq];
pc->rq[0].rq_addr_hi = 0x0;
pc->rq[0].rq_addr_lo = sc->replymap->dm_segs[0].ds_addr;
} __packed rq[4];
sns_gid_ft_req_t *rq = &un._x;
ISP_MEMZERO(rq, SNS_GID_FT_REQ_SIZE);
rq->snscb_rblen = GIDLEN >> 1;
rq->snscb_addr[RQRSP_ADDR0015] = DMA_WD0(fcp->isp_scdma + IGPOFF);
rq->snscb_addr[RQRSP_ADDR1631] = DMA_WD1(fcp->isp_scdma + IGPOFF);
rq->snscb_addr[RQRSP_ADDR3247] = DMA_WD2(fcp->isp_scdma + IGPOFF);
rq->snscb_addr[RQRSP_ADDR4863] = DMA_WD3(fcp->isp_scdma + IGPOFF);
rq->snscb_sblen = 6;
rq->snscb_cmd = SNS_GID_FT;
rq->snscb_mword_div_2 = NGENT;
rq->snscb_fc4_type = FC4_SCSI;
isp_put_gid_ft_request(isp, rq, fcp->isp_scratch);
STAILQ_HEAD(, fw_xfer) rq;
STAILQ_INIT(&d->rq);
xfer = STAILQ_FIRST(&d->rq);
STAILQ_REMOVE_HEAD(&d->rq, link);
STAILQ_INSERT_TAIL(&d->rq, xfer, link);
STAILQ_INSERT_TAIL(&d->rq, xfer, link);
struct fw_xferq *rq;
rq = &dbch->xferq;
if (rq->buf == NULL && (dbch->xferq.flag & FWXFERQ_EXTBUF) == 0) {
dsiz[0] = rq->psize;
dsiz[db_tr->dbcnt] = rq->psize;
if (rq->buf != NULL) {
db_tr->buf = fwdma_v_addr(rq->buf, poffset);
dbuf[db_tr->dbcnt] = fwdma_bus_addr(rq->buf, poffset);
if (rq->flag & FWXFERQ_STREAM)
if (rq->flag & FWXFERQ_STREAM)
int rq, sba, fw, rate;
rq = AGP_MODE_GET_RQ(mode);
if (AGP_MODE_GET_RQ(tstatus) < rq)
rq = AGP_MODE_GET_RQ(tstatus);
if (AGP_MODE_GET_RQ(mstatus) < rq)
rq = AGP_MODE_GET_RQ(mstatus);
command = AGP_MODE_SET_RQ(0, rq);
int rq, sba, fw, rate, arqsz, cal;
rq = AGP_MODE_GET_RQ(mode);
if (AGP_MODE_GET_RQ(tstatus) < rq)
rq = AGP_MODE_GET_RQ(tstatus);
if (AGP_MODE_GET_RQ(mstatus) < rq)
rq = AGP_MODE_GET_RQ(mstatus);
command = AGP_MODE_SET_RQ(0, rq);
void t3_rx_eth_lro(adapter_t *adap, struct sge_rspq *rq, struct mbuf *m,
void t3_rx_eth(struct adapter *adap, struct sge_rspq *rq, struct mbuf *m, int ethpad);
t3_rx_eth_lro(adapter_t *adap, struct sge_rspq *rq, struct mbuf *m,
struct sge_qset *qs = rspq_to_qset(rq);
t3_rx_eth(adap, rq, m, ethpad);
t3_rx_eth(struct adapter *adap, struct sge_rspq *rq, struct mbuf *m, int ethpad)
process_responses_gts(adapter_t *adap, struct sge_rspq *rq)
work = process_responses(adap, rspq_to_qset(rq), -1);
if (cxgb_debug && (rq->next_holdoff != last_holdoff)) {
printf("next_holdoff=%d\n", rq->next_holdoff);
last_holdoff = rq->next_holdoff;
t3_write_reg(adap, A_SG_GTS, V_RSPQ(rq->cntxt_id) |
V_NEWTIMER(rq->next_holdoff) | V_NEWINDEX(rq->cidx));
struct mcx_rq_ctx rq;
if (mcx_query_rq(sc, &q->q_rx, &u.rq) != 0) {
kstat_kv_u64(kvs++) = bemtoh32(&u.rq.rq_wq.wq_sw_counter);
kstat_kv_u64(kvs++) = bemtoh32(&u.rq.rq_wq.wq_hw_counter);
switch ((bemtoh32(&u.rq.rq_flags) & MCX_RQ_CTX_STATE_MASK) >>
ispreq_t *rq = arg;
hidx = isp_handle_index(isp, rq->req_handle);
if (rq->req_header.rqs_entry_type == RQSTYPE_T2RQS) {
rq->req_header.rqs_entry_type = RQSTYPE_T3RQS;
} else if (rq->req_header.rqs_entry_type == RQSTYPE_REQUEST) {
rq->req_header.rqs_entry_type = RQSTYPE_A64;
if (isp_send_cmd(isp, rq, dm_segs, nsegs, xs->datalen, ddir)
struct twa_request *rq;
TAILQ_FOREACH(rq, &sc->twa_busy, tr_link) {
if (tr->tr_request_id == rq->tr_request_id) {
} else if (tr->bp == rq->bp && tr->bp != 0) {
union twa_response_queue rq;
rq.value = twa_inl(sc, TWA_RESPONSE_QUEUE_OFFSET);
tr = sc->sc_twa_request + rq.u.response_id;
ispreq_t *rq = arg;
hidx = isp_handle_index(isp, rq->req_handle);
if (isp_send_cmd(isp, rq, dm_segs, nsegs, xs->datalen, ddir) != CMD_QUEUED) {
struct rq *rqp;
SIMPLEQ_FOREACH(rqp, &sc->sc_rqh, rq) {
struct rq rq;
rq.idata = idata;
rq.odata = odata;
rq.len = olen / sizeof(struct zyd_pair);
SIMPLEQ_INSERT_TAIL(&sc->sc_rqh, &rq, rq);
SIMPLEQ_REMOVE(&sc->sc_rqh, &rq, rq, rq);
SIMPLEQ_ENTRY(rq) rq;
SIMPLEQ_HEAD(rqh, rq) sc_rqh;
xdc_rqinit(struct xd_iorq *rq, struct xdc_softc *xdc, struct xd_softc *xd, int md, u_long blk, int cnt, void *db, struct buf *bp)
rq->xdc = xdc;
rq->xd = xd;
rq->ttl = XDC_MAXTTL + 10;
rq->mode = md;
rq->tries = rq->errnum = rq->lasterror = 0;
rq->blockno = blk;
rq->sectcnt = cnt;
rq->dbuf = db;
rq->buf = bp;
xyc_rqinit(struct xy_iorq *rq, struct xyc_softc *xyc, struct xy_softc *xy, int md, u_long blk, int cnt, void *db, struct buf *bp)
rq->xyc = xyc;
rq->xy = xy;
rq->ttl = XYC_MAXTTL + 10;
rq->mode = md;
rq->tries = rq->errnum = rq->lasterror = 0;
rq->blockno = blk;
rq->sectcnt = cnt;
rq->dbuf = db;
rq->buf = bp;
int errnum, rq, comm, errs;
for (rq = 0; rq < XYC_MAXIOPB; rq++) {
iorq = xycsc->xy_chain[rq];
ptrace_startstop(struct proc *t, struct lwp **lt, int rq, void *addr,
DPRINTF(("%s: lwp=%d request=%d\n", __func__, (*lt)->l_lid, rq));
if (rq == PT_SUSPEND)
ptrace_regs(struct lwp *l, struct lwp **lt, int rq, struct ptrace_methods *ptm,
int dir = ptrace_uio_dir(rq);
DPRINTF(("%s: lwp=%d request=%d\n", __func__, l->l_lid, rq));
switch (rq) {
struct ieee1394_reassq *rq;
for (rq = LIST_FIRST(&ic->ic_reassq); ; rq = LIST_NEXT(rq, rq_node)) {
if (rq == NULL) {
rq = malloc(sizeof(*rq), M_FTABLE, M_NOWAIT);
if (rq == NULL) {
rq->fr_id = id;
LIST_INIT(&rq->rq_pkt);
LIST_INSERT_HEAD(&ic->ic_reassq, rq, rq_node);
if (rq->fr_id == id)
for (rp = LIST_FIRST(&rq->rq_pkt); rp != NULL; rp = nrp) {
for (rp = LIST_FIRST(&rq->rq_pkt); rp != NULL;
LIST_INSERT_HEAD(&rq->rq_pkt, trp, rp_next);
struct ieee1394_reassq *rq;
while ((rq = LIST_FIRST(&ic->ic_reassq)) != NULL) {
LIST_REMOVE(rq, rq_node);
while ((rp = LIST_FIRST(&rq->rq_pkt)) != NULL) {
free(rq, M_FTABLE);
struct ieee1394_reassq *rq;
for (rq = LIST_FIRST(&ic->ic_reassq); rq != NULL;
rq = LIST_NEXT(rq, rq_node)) {
for (rp = LIST_FIRST(&rq->rq_pkt); rp != NULL; rp = nrp) {
struct lua_require rq;
ATF_REQUIRE_ERRNO(EACCES, ioctl(fd, LUAREQUIRE, &rq) == -1);