Searched refs:rq (Results 1 - 25 of 123) sorted by relevance

12345

/freebsd-13-stable/sys/dev/mlx5/mlx5_en/
H A Dmlx5_en_rx.c32 mlx5e_alloc_rx_wqe(struct mlx5e_rq *rq, argument
42 if (rq->mbuf[ix].mbuf != NULL)
53 for (i = 1; i < rq->nsegs; i++) {
54 if (mb_head->m_pkthdr.len >= rq->wqe_sz)
71 err = -bus_dmamap_load_mbuf_sg(rq->dma_tag, rq->mbuf[ix].dma_map,
76 bus_dmamap_unload(rq->dma_tag, rq->mbuf[ix].dma_map);
87 for (; i < rq->nsegs; i++) {
92 rq
105 mlx5e_post_rx_wqes(struct mlx5e_rq *rq) argument
242 mlx5e_build_rx_mbuf(struct mlx5_cqe64 *cqe, struct mlx5e_rq *rq, struct mbuf *mb, u32 cqe_bcnt) argument
422 mlx5e_poll_rx_cq(struct mlx5e_rq *rq, int budget) argument
542 struct mlx5e_rq *rq = container_of(mcq, struct mlx5e_rq, cq.mcq); local
[all...]
H A Dmlx5_en_dim.c63 struct mlx5e_rq *rq = container_of(dim, struct mlx5e_rq, dim); local
64 struct mlx5e_channel *c = container_of(rq, struct mlx5e_channel, rq);
70 mtx_lock(&rq->mtx);
74 mtx_unlock(&rq->mtx);
90 mlx5_core_modify_cq_moderation(c->priv->mdev, &rq->cq.mcq,
H A Dmlx5_en_main.c49 struct mlx5e_rq_param rq; member in struct:mlx5e_channel_param
887 struct mlx5e_rq *rq = &pch->rq; local
888 struct mlx5e_rq_stats *rq_stats = &pch->rq.stats;
891 rq_stats->sw_lro_queued = rq->lro.lro_queued;
892 rq_stats->sw_lro_flushed = rq->lro.lro_flushed;
1258 struct mlx5e_rq *rq)
1287 &rq->dma_tag)))
1290 err = mlx5_wq_ll_create(mdev, &param->wq, rqc_wq, &rq->wq,
1291 &rq
1256 mlx5e_create_rq(struct mlx5e_channel *c, struct mlx5e_rq_param *param, struct mlx5e_rq *rq) argument
1366 mlx5e_destroy_rq(struct mlx5e_rq *rq) argument
1391 mlx5e_enable_rq(struct mlx5e_rq *rq, struct mlx5e_rq_param *param) argument
1434 mlx5e_modify_rq(struct mlx5e_rq *rq, int curr_state, int next_state) argument
1464 mlx5e_disable_rq(struct mlx5e_rq *rq) argument
1474 mlx5e_wait_for_min_rx_wqes(struct mlx5e_rq *rq) argument
1491 mlx5e_open_rq(struct mlx5e_channel *c, struct mlx5e_rq_param *param, struct mlx5e_rq *rq) argument
1522 mlx5e_close_rq(struct mlx5e_rq *rq) argument
1533 mlx5e_close_rq_wait(struct mlx5e_rq *rq) argument
2543 mlx5e_refresh_rq_params(struct mlx5e_priv *priv, struct mlx5e_rq *rq) argument
3847 struct mlx5e_rq *rq = &ch->rq; local
3883 struct mlx5e_rq *rq = &ch->rq; local
[all...]
/freebsd-13-stable/sys/dev/oce/
H A Doce_queue.c58 static int oce_rq_create(struct oce_rq *rq, uint32_t if_id, struct oce_eq *eq);
59 static void oce_rq_free(struct oce_rq *rq);
60 static void oce_rq_del(struct oce_rq *rq);
91 struct oce_rq *rq; local
103 for_all_rq_queues(sc, rq, i) {
104 sc->rq[i] = oce_rq_init(sc, sc->rx_ring_size, sc->rq_frag_size,
107 if (!sc->rq[i])
140 for_all_rq_queues(sc, rq, i) {
141 rc = oce_rq_create(rq, sc->if_id,
145 rq
168 struct oce_rq *rq; local
392 struct oce_rq *rq; local
453 oce_rq_free(struct oce_rq *rq) argument
488 oce_rq_create(struct oce_rq *rq, uint32_t if_id, struct oce_eq *eq) argument
521 oce_rq_del(struct oce_rq *rq) argument
912 oce_start_rq(struct oce_rq *rq) argument
1068 oce_drain_rq_cq(struct oce_rq *rq) argument
1092 oce_free_posted_rxbuf(struct oce_rq *rq) argument
1112 oce_rx_cq_clean_hwlro(struct oce_rq *rq) argument
1189 oce_rx_cq_clean(struct oce_rq *rq) argument
1239 struct oce_rq *rq; local
1282 struct oce_rq *rq; local
[all...]
H A Doce_if.c166 static void oce_rx(struct oce_rq *rq, struct oce_nic_rx_cqe *cqe);
167 static void oce_check_rx_bufs(POCE_SOFTC sc, uint32_t num_cqes, struct oce_rq *rq);
170 static void oce_rx_lro(struct oce_rq *rq, struct nic_hwlro_singleton_cqe *cqe, struct nic_hwlro_cqe_part2 *cqe2);
171 static void oce_rx_mbuf_chain(struct oce_rq *rq, struct oce_common_cqe_info *cqe_info, struct mbuf **m);
1515 oce_rx_mbuf_chain(struct oce_rq *rq, struct oce_common_cqe_info *cqe_info, struct mbuf **m) argument
1517 POCE_SOFTC sc = (POCE_SOFTC) rq->parent;
1524 if (rq->ring->cidx == rq->ring->pidx) {
1529 pd = &rq->pckts[rq
1580 oce_rx_lro(struct oce_rq *rq, struct nic_hwlro_singleton_cqe *cqe, struct nic_hwlro_cqe_part2 *cqe2) argument
1661 oce_rx(struct oce_rq *rq, struct oce_nic_rx_cqe *cqe) argument
1759 oce_discard_rx_comp(struct oce_rq *rq, int num_frags) argument
1820 oce_rx_flush_lro(struct oce_rq *rq) argument
1868 oce_alloc_rx_bufs(struct oce_rq *rq, int count) argument
1950 oce_check_rx_bufs(POCE_SOFTC sc, uint32_t num_cqes, struct oce_rq *rq) argument
1969 struct oce_rq *rq = (struct oce_rq *)arg; local
2042 struct oce_rq *rq = (struct oce_rq *)arg; local
2310 struct oce_rq *rq; local
2514 struct oce_rq *rq; local
2561 struct oce_rq *rq; local
[all...]
/freebsd-13-stable/sys/kern/
H A Dkern_switch.c266 runq_init(struct runq *rq) argument
270 bzero(rq, sizeof *rq);
272 TAILQ_INIT(&rq->rq_queues[i]);
280 runq_clrbit(struct runq *rq, int pri) argument
284 rqb = &rq->rq_status;
297 runq_findbit(struct runq *rq) argument
303 rqb = &rq->rq_status;
316 runq_findbit_from(struct runq *rq, u_char pri) argument
326 rqb = &rq
352 runq_setbit(struct runq *rq, int pri) argument
369 runq_add(struct runq *rq, struct thread *td, int flags) argument
388 runq_add_pri(struct runq *rq, struct thread *td, u_char pri, int flags) argument
410 runq_check(struct runq *rq) argument
431 runq_choose_fuzz(struct runq *rq, int fuzz) argument
473 runq_choose(struct runq *rq) argument
493 runq_choose_from(struct runq *rq, u_char idx) argument
518 runq_remove(struct runq *rq, struct thread *td) argument
525 runq_remove_idx(struct runq *rq, struct thread *td, u_char *idx) argument
[all...]
/freebsd-13-stable/contrib/subversion/subversion/libsvn_ra_serf/
H A Dinherited_props.c268 iprop_rq_info_t *rq = apr_pcalloc(scratch_pool, sizeof(*rq));
272 rq->relpath = relpath;
273 rq->props = apr_hash_make(scratch_pool);
275 SVN_ERR(svn_ra_serf__get_stable_url(&rq->urlpath, NULL, session,
283 &rq->handler, session,
284 rq->urlpath,
287 rq->props,
291 rq->handler->no_fail_on_http_failure_status = TRUE;
293 svn_ra_serf__request_create(rq
266 iprop_rq_info_t *rq = apr_pcalloc(scratch_pool, sizeof(*rq)); local
304 iprop_rq_info_t *rq = APR_ARRAY_IDX(rq_info, i, iprop_rq_info_t *); local
320 iprop_rq_info_t *rq = APR_ARRAY_IDX(rq_info, i, iprop_rq_info_t *); local
[all...]
/freebsd-13-stable/sys/dev/ice/
H A Dice_controlq.c46 (qinfo)->rq.head = prefix##_ARQH; \
47 (qinfo)->rq.tail = prefix##_ARQT; \
48 (qinfo)->rq.len = prefix##_ARQLEN; \
49 (qinfo)->rq.bah = prefix##_ARQBAH; \
50 (qinfo)->rq.bal = prefix##_ARQBAL; \
51 (qinfo)->rq.len_mask = prefix##_ARQLEN_ARQLEN_M; \
52 (qinfo)->rq.len_ena_mask = prefix##_ARQLEN_ARQENABLE_M; \
53 (qinfo)->rq.len_crit_mask = prefix##_ARQLEN_ARQCRIT_M; \
54 (qinfo)->rq.head_mask = prefix##_ARQH_ARQH_M; \
137 cq->rq
[all...]
/freebsd-13-stable/contrib/ofed/libcxgb4/
H A Dverbs.c324 " rqid 0x%x rq key %" PRIx64 " rq db/gts key %" PRIx64
336 qhp->wq.rq.msn = 1;
337 qhp->wq.rq.qid = resp.rqid;
338 qhp->wq.rq.size = resp.rq_size;
339 qhp->wq.rq.memsize = resp.rq_memsize;
358 qhp->wq.rq.udb = dbva;
359 qhp->wq.rq.queue = mmap(NULL, qhp->wq.rq.memsize,
362 if (qhp->wq.rq
[all...]
H A Dt4.h355 struct t4_rq rq; member in struct:t4_wq
365 return wq->rq.in_use;
370 return wq->rq.in_use == 0;
375 return wq->rq.in_use == (wq->rq.size - 1);
380 return wq->rq.size - 1 - wq->rq.in_use;
385 wq->rq.in_use++;
386 if (++wq->rq.pidx == wq->rq
[all...]
H A Ddev.c300 qhp->wq.rq.qid,
301 qhp->wq.rq.queue,
302 qhp->wq.rq.sw_rq,
303 qhp->wq.rq.cidx,
304 qhp->wq.rq.pidx,
305 qhp->wq.rq.in_use,
306 qhp->wq.rq.size);
343 cidx = qhp->wq.rq.cidx;
344 pidx = qhp->wq.rq.pidx;
348 swrqe = &qhp->wq.rq
[all...]
H A Dqp.c88 dst = &wq->rq.queue->flits[wq->rq.wq_pidx *
92 end = (uintptr_t)&wq->rq.queue[wq->rq.size];
99 memcpy(wq->rq.queue, src + len, total - len);
457 qhp->wq.rq.sw_rq[qhp->wq.rq.pidx].wr_id = wr->wr_id;
461 wqe->recv.wrid = qhp->wq.rq.pidx;
467 (unsigned long long) wr->wr_id, qhp->wq.rq.pidx);
478 ring_kernel_db(qhp, qhp->wq.rq
[all...]
/freebsd-13-stable/sys/dev/ocs_fc/
H A Docs_hw_queues.c73 hw_rq_t *rq = NULL; local
238 rq = hw_new_rq(cq, len, hw->ulp_start + qt->ulp);
239 if (rq == NULL) {
243 rq->filter_mask = qt->filter_mask;
298 rq = hw_new_rq(cq, mrq.rq_cfg[i].len, mrq.rq_cfg[i].ulp);
299 if (rq == NULL) {
303 rq->filter_mask = mrq.rq_cfg[i].filter_mask;
583 * Allocate an RQ object, which encapsulates 2 SLI queues (for rq pair)
595 hw_rq_t *rq = ocs_malloc(hw->os, sizeof(*rq), OCS_M_ZER local
677 hw_rq_t *rq = NULL; local
866 hw_del_rq(hw_rq_t *rq) argument
899 hw_rq_t *rq; local
2054 hw_rq_t *rq = hw->hw_rq[hw->hw_rq_lookup[rqindex]]; local
2102 hw_rq_t *rq = hw->hw_rq[hw_rq_index]; local
[all...]
/freebsd-13-stable/sys/dev/cfi/
H A Dcfi_dev.c267 struct cfiocqry *rq; local
281 rq = (struct cfiocqry *)data;
282 if (rq->offset >= sc->sc_size / sc->sc_width)
284 if (rq->offset > ULONG_MAX - rq->count ||
285 rq->offset + rq->count > sc->sc_size / sc->sc_width)
288 while (!error && rq->count--) {
289 val = cfi_read_qry(sc, rq->offset++);
290 error = copyout(&val, rq
[all...]
/freebsd-13-stable/sys/arm/include/
H A Dsysreg.h307 #define CP15_CNTPCT(rq, rr) p15, 0, rq, rr, c14 /* Physical Count Register */
308 #define CP15_CNTVCT(rq, rr) p15, 1, rq, rr, c14 /* Virtual Count Register */
309 #define CP15_CNTP_CVAL(rq, rr) p15, 2, rq, rr, c14 /* PL1 Physical Timer Compare Value Register */
310 #define CP15_CNTV_CVAL(rq, rr) p15, 3, rq, rr, c14 /* Virtual Timer Compare Value Register */
311 #define CP15_CNTVOFF(rq, rr) p15, 4, rq, r
[all...]
/freebsd-13-stable/sys/dev/cxgbe/iw_cxgbe/
H A Dt4.h367 struct t4_rq rq; member in struct:t4_wq
374 return wq->rq.in_use;
379 return wq->rq.in_use == 0;
384 return wq->rq.in_use == (wq->rq.size - 1);
389 return wq->rq.size - 1 - wq->rq.in_use;
394 wq->rq.in_use++;
395 if (++wq->rq.pidx == wq->rq
[all...]
H A Dqp.c114 wq->rq.memsize, wq->rq.queue,
115 dma_unmap_addr(&wq->rq, mapping));
119 c4iw_rqtpool_free(rdev, wq->rq.rqt_hwaddr, wq->rq.rqt_size);
120 kfree(wq->rq.sw_rq);
122 c4iw_put_qpid(rdev, wq->rq.qid, uctx);
147 wq->rq.qid = c4iw_get_qpid(rdev, uctx);
148 if (!wq->rq.qid) {
161 wq->rq
[all...]
/freebsd-13-stable/contrib/ofed/libmlx4/
H A Dqp.c61 return qp->buf.buf + qp->rq.offset + (n << qp->rq.wqe_shift);
88 qp->rq.head = 0;
89 qp->rq.tail = 0;
522 pthread_spin_lock(&qp->rq.lock);
526 ind = qp->rq.head & (qp->rq.wqe_cnt - 1);
529 if (wq_overflow(&qp->rq, nreq, to_mcq(ibqp->recv_cq))) {
535 if (wr->num_sge > qp->rq.max_gs) {
546 if (i < qp->rq
[all...]
/freebsd-13-stable/sys/dev/mthca/
H A Dmthca_qp.c210 return qp->queue.direct.buf + (n << qp->rq.wqe_shift);
212 return qp->queue.page_list[(n << qp->rq.wqe_shift) >> PAGE_SHIFT].buf +
213 ((n << qp->rq.wqe_shift) & (PAGE_SIZE - 1));
499 qp_attr->cap.max_recv_wr = qp->rq.max;
501 qp_attr->cap.max_recv_sge = qp->rq.max_gs;
598 if (qp->rq.max)
599 qp_context->rq_size_stride = ilog2(qp->rq.max) << 3;
600 qp_context->rq_size_stride |= qp->rq.wqe_shift - 4;
761 qp_context->rcv_db_index = cpu_to_be32(qp->rq.db_index);
827 mthca_wq_reset(&qp->rq);
[all...]
/freebsd-13-stable/contrib/ofed/libmlx5/
H A Dqp.c63 return qp->buf.buf + qp->rq.offset + (n << qp->rq.wqe_shift);
68 return rwq->pbuff + (n << rwq->rq.wqe_shift);
96 int max = 1 << (qp->rq.wqe_shift - 4);
160 rwq->rq.head = 0;
161 rwq->rq.tail = 0;
168 qp->rq.head = 0;
169 qp->rq.tail = 0;
1072 mlx5_spin_lock(&rwq->rq.lock);
1074 ind = rwq->rq
[all...]
/freebsd-13-stable/lib/libsmb/
H A DMakefile15 SRCS= rcfile.c ctx.c cfopt.c subr.c nls.c rap.c mbuf.c rq.c file.c \
/freebsd-13-stable/contrib/nvi/ex/
H A Dex_global.c158 TAILQ_INIT(ecp->rq);
227 if ((rp = TAILQ_LAST(ecp->rq, _rh)) != NULL &&
238 TAILQ_INSERT_TAIL(ecp->rq, rp, q);
266 TAILQ_FOREACH_SAFE(rp, ecp->rq, q, nrp) {
294 TAILQ_REMOVE(ecp->rq, rp, q);
302 TAILQ_INSERT_AFTER(ecp->rq, rp, nrp, q);
/freebsd-13-stable/sys/dev/mlx5/mlx5_fpga/
H A Dmlx5fpga_conn.c110 if (unlikely(conn->qp.rq.pc - conn->qp.rq.cc >= conn->qp.rq.size)) {
115 ix = conn->qp.rq.pc & (conn->qp.rq.size - 1);
116 data = mlx5_wq_cyc_get_wqe(&conn->qp.wq.rq, ix);
121 conn->qp.rq.pc++;
122 conn->qp.rq.bufs[ix] = buf;
126 *conn->qp.wq.rq.db = cpu_to_be32(conn->qp.rq
[all...]
/freebsd-13-stable/sys/dev/qlnx/qlnxr/
H A Dqlnxr_cm.c130 qp->rqe_wr_id[qp->rq.gsi_cons].rc =
132 qp->rqe_wr_id[qp->rq.gsi_cons].vlan_id = data->vlan;
134 qp->rqe_wr_id[qp->rq.gsi_cons].sg_list[0].length =
136 *((u32 *)&qp->rqe_wr_id[qp->rq.gsi_cons].smac[0]) =
138 *((u16 *)&qp->rqe_wr_id[qp->rq.gsi_cons].smac[4]) =
141 qlnxr_inc_sw_gsi_cons(&qp->rq);
416 qp->rq.max_wr = attrs->cap.max_recv_wr;
419 qp->rqe_wr_id = kzalloc(qp->rq.max_wr * sizeof(*qp->rqe_wr_id),
803 memset(&qp->rqe_wr_id[qp->rq.prod], 0,
804 sizeof(qp->rqe_wr_id[qp->rq
[all...]
/freebsd-13-stable/sys/dev/mlx5/mlx5_ib/
H A Dmlx5_ib_qp.c105 return get_wqe(qp, qp->rq.offset + (n << qp->rq.wqe_shift));
136 struct mlx5_ib_wq *wq = send ? &qp->sq : &qp->rq;
243 qp->rq.max_gs = 0;
244 qp->rq.wqe_cnt = 0;
245 qp->rq.wqe_shift = 0;
250 qp->rq.wqe_cnt = ucmd->rq_wqe_count;
251 qp->rq.wqe_shift = ucmd->rq_wqe_shift;
252 qp->rq.max_gs = (1 << qp->rq
1151 create_raw_packet_qp_rq(struct mlx5_ib_dev *dev, struct mlx5_ib_rq *rq, void *qpin) argument
1203 destroy_raw_packet_qp_rq(struct mlx5_ib_dev *dev, struct mlx5_ib_rq *rq) argument
1209 create_raw_packet_qp_tir(struct mlx5_ib_dev *dev, struct mlx5_ib_rq *rq, u32 tdn) argument
1234 destroy_raw_packet_qp_tir(struct mlx5_ib_dev *dev, struct mlx5_ib_rq *rq) argument
1246 struct mlx5_ib_rq *rq = &raw_packet_qp->rq; local
1300 struct mlx5_ib_rq *rq = &raw_packet_qp->rq; local
1317 struct mlx5_ib_rq *rq = &raw_packet_qp->rq; local
2441 modify_raw_packet_qp_rq(struct mlx5_ib_dev *dev, struct mlx5_ib_rq *rq, int new_state, const struct mlx5_modify_raw_qp_param *raw_qp_param) argument
2517 struct mlx5_ib_rq *rq = &raw_packet_qp->rq; local
4290 query_raw_packet_qp_rq_state(struct mlx5_ib_dev *dev, struct mlx5_ib_rq *rq, u8 *rq_state) argument
4368 struct mlx5_ib_rq *rq = &raw_packet_qp->rq; local
[all...]

Completed in 291 milliseconds

12345