/freebsd-13-stable/sys/dev/mlx5/mlx5_en/ |
H A D | mlx5_en_rx.c | 32 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 D | mlx5_en_dim.c | 63 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 D | mlx5_en_main.c | 49 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, ¶m->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 D | oce_queue.c | 58 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 D | oce_if.c | 166 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 D | kern_switch.c | 266 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 D | inherited_props.c | 268 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 D | ice_controlq.c | 46 (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 D | verbs.c | 324 " 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 D | t4.h | 355 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 D | dev.c | 300 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 D | qp.c | 88 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 D | ocs_hw_queues.c | 73 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 D | cfi_dev.c | 267 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 D | sysreg.h | 307 #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 D | t4.h | 367 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 D | qp.c | 114 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 D | qp.c | 61 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 D | mthca_qp.c | 210 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 D | qp.c | 63 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 D | Makefile | 15 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 D | ex_global.c | 158 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 D | mlx5fpga_conn.c | 110 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 D | qlnxr_cm.c | 130 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 D | mlx5_ib_qp.c | 105 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...] |