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

12345

/freebsd-10-stable/sys/dev/mlx5/mlx5_en/
H A Dmlx5_en_rx.c32 mlx5e_alloc_rx_wqe(struct mlx5e_rq *rq, argument
35 bus_dma_segment_t segs[rq->nsegs];
43 if (rq->mbuf[ix].mbuf != NULL)
47 mb = m_getjcl(M_NOWAIT, MT_DATA, M_PKTHDR, rq->wqe_sz);
51 mb->m_pkthdr.len = mb->m_len = rq->wqe_sz;
61 for (i = 1; i < rq->nsegs; i++) {
62 if (mb_head->m_pkthdr.len >= rq->wqe_sz)
79 err = -bus_dmamap_load_mbuf_sg(rq->dma_tag, rq->mbuf[ix].dma_map,
84 bus_dmamap_unload(rq
117 mlx5e_post_rx_wqes(struct mlx5e_rq *rq) argument
223 mlx5e_build_rx_mbuf(struct mlx5_cqe64 *cqe, struct mlx5e_rq *rq, struct mbuf *mb, u32 cqe_bcnt) argument
386 mlx5e_poll_rx_cq(struct mlx5e_rq *rq, int budget) argument
482 struct mlx5e_rq *rq = container_of(mcq, struct mlx5e_rq, cq.mcq); local
[all...]
H A Dmlx5_en_main.c40 struct mlx5e_rq_param rq; member in struct:mlx5e_channel_param
423 struct mlx5e_rq *rq = &priv->channel[i]->rq; local
425 rq_stats = &priv->channel[i]->rq.stats;
428 rq_stats->sw_lro_queued = rq->lro.lro_queued;
429 rq_stats->sw_lro_flushed = rq->lro.lro_flushed;
649 struct mlx5e_rq *rq)
678 &rq->dma_tag)))
681 err = mlx5_wq_ll_create(mdev, &param->wq, rqc_wq, &rq->wq,
682 &rq
647 mlx5e_create_rq(struct mlx5e_channel *c, struct mlx5e_rq_param *param, struct mlx5e_rq *rq) argument
750 mlx5e_destroy_rq(struct mlx5e_rq *rq) argument
779 mlx5e_enable_rq(struct mlx5e_rq *rq, struct mlx5e_rq_param *param) argument
822 mlx5e_modify_rq(struct mlx5e_rq *rq, int curr_state, int next_state) argument
852 mlx5e_disable_rq(struct mlx5e_rq *rq) argument
862 mlx5e_wait_for_min_rx_wqes(struct mlx5e_rq *rq) argument
879 mlx5e_open_rq(struct mlx5e_channel *c, struct mlx5e_rq_param *param, struct mlx5e_rq *rq) argument
910 mlx5e_close_rq(struct mlx5e_rq *rq) argument
923 mlx5e_close_rq_wait(struct mlx5e_rq *rq) argument
1914 mlx5e_refresh_rq_params(struct mlx5e_priv *priv, struct mlx5e_rq *rq) argument
[all...]
/freebsd-10-stable/sys/dev/oce/
H A Doce_queue.c56 static int oce_rq_create(struct oce_rq *rq, uint32_t if_id, struct oce_eq *eq);
57 static void oce_rq_free(struct oce_rq *rq);
58 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])
139 for_all_rq_queues(sc, rq, i) {
140 rc = oce_rq_create(rq, sc->if_id,
144 rq
169 struct oce_rq *rq; local
404 struct oce_rq *rq; local
472 oce_rq_free(struct oce_rq *rq) argument
510 oce_rq_create(struct oce_rq *rq, uint32_t if_id, struct oce_eq *eq) argument
546 oce_rq_del(struct oce_rq *rq) argument
952 oce_start_rq(struct oce_rq *rq) argument
1120 oce_drain_rq_cq(struct oce_rq *rq) argument
1145 oce_free_posted_rxbuf(struct oce_rq *rq) argument
1174 struct oce_rq *rq; local
1204 struct oce_rq *rq; local
[all...]
H A Doce_if.c149 static void oce_discard_rx_comp(struct oce_rq *rq, struct oce_nic_rx_cqe *cqe);
152 static void oce_rx(struct oce_rq *rq, uint32_t rqe_idx,
176 static void oce_rx_flush_lro(struct oce_rq *rq);
1295 oce_rx(struct oce_rq *rq, uint32_t rqe_idx, struct oce_nic_rx_cqe *cqe) argument
1299 POCE_SOFTC sc = (POCE_SOFTC) rq->parent;
1307 oce_discard_rx_comp(rq, cqe);
1320 if (rq->packets_out == rq->packets_in) {
1324 out = rq->packets_out + 1;
1327 pd = &rq
1433 oce_discard_rx_comp(struct oce_rq *rq, struct oce_nic_rx_cqe *cqe) argument
1497 oce_rx_flush_lro(struct oce_rq *rq) argument
1551 oce_alloc_rx_bufs(struct oce_rq *rq, int count) argument
1622 struct oce_rq *rq = (struct oce_rq *)arg; local
2053 struct oce_rq *rq; local
2114 struct oce_rq *rq; local
[all...]
/freebsd-10-stable/contrib/top/
H A Dtop.xs32 .ds rq \&"
34 .if t .ds rq ''
58 remainder of this document, an \*(lqintelligent\*(rq terminal is one that
60 Conversely, a \*(lqdumb\*(rq terminal is one that does not support such
75 flag is passed it toggles between \*(lqraw cpu\*(rq mode
76 and \*(lqweighted cpu\*(rq mode, showing the \*(lqCPU\*(rq or
77 the \*(lqWCPU\*(rq column respectively.
90 Use \*(lqbatch\*(rq mode. In this mode, all input from the terminal is
99 Use \*(lqinteractive\*(rq mod
[all...]
/freebsd-10-stable/sys/kern/
H A Dkern_switch.c250 runq_init(struct runq *rq) argument
254 bzero(rq, sizeof *rq);
256 TAILQ_INIT(&rq->rq_queues[i]);
264 runq_clrbit(struct runq *rq, int pri) argument
268 rqb = &rq->rq_status;
281 runq_findbit(struct runq *rq) argument
287 rqb = &rq->rq_status;
300 runq_findbit_from(struct runq *rq, u_char pri) argument
310 rqb = &rq
336 runq_setbit(struct runq *rq, int pri) argument
353 runq_add(struct runq *rq, struct thread *td, int flags) argument
372 runq_add_pri(struct runq *rq, struct thread *td, u_char pri, int flags) argument
394 runq_check(struct runq *rq) argument
415 runq_choose_fuzz(struct runq *rq, int fuzz) argument
457 runq_choose(struct runq *rq) argument
477 runq_choose_from(struct runq *rq, u_char idx) argument
502 runq_remove(struct runq *rq, struct thread *td) argument
509 runq_remove_idx(struct runq *rq, struct thread *td, u_char *idx) argument
[all...]
/freebsd-10-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-10-stable/contrib/ofed/libmthca/src/
H A Dqp.c63 return qp->buf.buf + (n << qp->rq.wqe_shift);
79 qp->rq.next_ind = 0;
80 qp->rq.last_comp = qp->rq.max - 1;
81 qp->rq.head = 0;
82 qp->rq.tail = 0;
83 qp->rq.last = get_recv_wqe(qp, qp->rq.max - 1);
283 qp->wrid[ind + qp->rq.max] = wr->wr_id;
348 pthread_spin_lock(&qp->rq
[all...]
/freebsd-10-stable/contrib/ofed/libcxgb4/src/
H A Dverbs.c326 " rqid 0x%x rq key %" PRIx64 " rq db/gts key %" PRIx64
338 qhp->wq.rq.msn = 1;
339 qhp->wq.rq.qid = resp.rqid;
340 qhp->wq.rq.size = resp.rq_size;
341 qhp->wq.rq.memsize = resp.rq_memsize;
360 qhp->wq.rq.udb = dbva;
361 qhp->wq.rq.queue = mmap(NULL, qhp->wq.rq.memsize,
364 if (qhp->wq.rq
[all...]
H A Dt4.h367 struct t4_rq rq; member in struct:t4_wq
383 return wq->rq.in_use;
388 return wq->rq.in_use == 0;
393 return wq->rq.in_use == (wq->rq.size - 1);
398 return wq->rq.size - 1 - wq->rq.in_use;
403 wq->rq.in_use++;
404 if (++wq->rq.pidx == wq->rq
[all...]
H A Ddev.c279 qhp->wq.rq.qid,
280 qhp->wq.rq.queue,
281 qhp->wq.rq.sw_rq,
282 qhp->wq.rq.cidx,
283 qhp->wq.rq.pidx,
284 qhp->wq.rq.in_use,
285 qhp->wq.rq.size);
322 cidx = qhp->wq.rq.cidx;
323 pidx = qhp->wq.rq.pidx;
327 swrqe = &qhp->wq.rq
[all...]
H A Dqp.c81 dst = &wq->rq.queue->flits[wq->rq.wq_pidx *
85 end = (uintptr_t)&wq->rq.queue[wq->rq.size];
92 memcpy(wq->rq.queue, src + len, total - len);
452 qhp->wq.rq.sw_rq[qhp->wq.rq.pidx].wr_id = wr->wr_id;
456 wqe->recv.wrid = qhp->wq.rq.pidx;
462 (unsigned long long) wr->wr_id, qhp->wq.rq.pidx);
472 qhp->wq.rq
[all...]
/freebsd-10-stable/contrib/ofed/libmlx4/src/
H A Dqp.c60 return qp->buf.buf + qp->rq.offset + (n << qp->rq.wqe_shift);
87 qp->rq.head = 0;
88 qp->rq.tail = 0;
455 pthread_spin_lock(&qp->rq.lock);
459 ind = qp->rq.head & (qp->rq.wqe_cnt - 1);
462 if (wq_overflow(&qp->rq, nreq, to_mcq(qp->ibv_qp.recv_cq))) {
468 if (wr->num_sge > qp->rq.max_gs) {
479 if (i < qp->rq
[all...]
/freebsd-10-stable/sys/dev/cxgbe/iw_cxgbe/
H A Dt4.h336 struct t4_rq rq; member in struct:t4_wq
344 return wq->rq.in_use;
349 return wq->rq.in_use == 0;
354 return wq->rq.in_use == (wq->rq.size - 1);
359 return wq->rq.size - 1 - wq->rq.in_use;
364 wq->rq.in_use++;
365 if (++wq->rq.pidx == wq->rq
[all...]
H A Dqp.c112 contigfree(wq->rq.queue, wq->rq.memsize, M_DEVBUF);
114 c4iw_rqtpool_free(rdev, wq->rq.rqt_hwaddr, wq->rq.rqt_size);
115 kfree(wq->rq.sw_rq);
117 c4iw_put_qpid(rdev, wq->rq.qid, uctx);
141 wq->rq.qid = c4iw_get_qpid(rdev, uctx);
142 if (!wq->rq.qid)
151 wq->rq.sw_rq = kzalloc(wq->rq
[all...]
/freebsd-10-stable/lib/libsmb/
H A DMakefile13 SRCS= rcfile.c ctx.c cfopt.c subr.c nls.c rap.c mbuf.c rq.c file.c \
/freebsd-10-stable/sys/dev/cfi/
H A Dcfi_dev.c264 struct cfiocqry *rq; local
278 rq = (struct cfiocqry *)data;
279 if (rq->offset >= sc->sc_size / sc->sc_width)
281 if (rq->offset + rq->count > sc->sc_size / sc->sc_width)
284 while (!error && rq->count--) {
285 val = cfi_read_qry(sc, rq->offset++);
286 error = copyout(&val, rq->buffer++, 1);
/freebsd-10-stable/sys/ofed/drivers/infiniband/hw/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));
506 qp_attr->cap.max_recv_wr = qp->rq.max;
508 qp_attr->cap.max_recv_sge = qp->rq.max_gs;
605 if (qp->rq.max)
606 qp_context->rq_size_stride = ilog2(qp->rq.max) << 3;
607 qp_context->rq_size_stride |= qp->rq.wqe_shift - 4;
768 qp_context->rcv_db_index = cpu_to_be32(qp->rq.db_index);
837 mthca_wq_reset(&qp->rq);
[all...]
/freebsd-10-stable/contrib/nvi/ex/
H A Dex_global.c161 TAILQ_INIT(ecp->rq);
230 if ((rp = TAILQ_LAST(ecp->rq, _rh)) != NULL &&
241 TAILQ_INSERT_TAIL(ecp->rq, rp, q);
269 TAILQ_FOREACH_SAFE(rp, ecp->rq, q, nrp) {
297 TAILQ_REMOVE(ecp->rq, rp, q);
305 TAILQ_INSERT_AFTER(ecp->rq, rp, nrp, q);
H A Dex_at.c86 TAILQ_INIT(ecp->rq);
96 TAILQ_INSERT_HEAD(ecp->rq, rp, q);
/freebsd-10-stable/contrib/groff/font/devdvi/
H A DTBI249 rq 650696,728178,0,83248 2 0042
H A DTI250 rq 539432,728178,0,72994 2 0042
/freebsd-10-stable/sys/dev/agp/
H A Dagp.c324 int rq, sba, fw, rate, arqsz, cal; local
330 rq = AGP_MODE_GET_RQ(mode);
331 if (AGP_MODE_GET_RQ(tstatus) < rq)
332 rq = AGP_MODE_GET_RQ(tstatus);
333 if (AGP_MODE_GET_RQ(mstatus) < rq)
334 rq = AGP_MODE_GET_RQ(mstatus);
341 if (AGP_MODE_GET_ARQSZ(tstatus) > rq)
342 rq = AGP_MODE_GET_ARQSZ(tstatus);
343 if (AGP_MODE_GET_ARQSZ(mstatus) > rq)
344 rq
393 int rq, sba, fw, rate; local
[all...]
/freebsd-10-stable/sys/rpc/
H A Dsvc.h277 #define svc_getrpccaller(rq) \
278 ((rq)->rq_addr ? (rq)->rq_addr : \
279 (struct sockaddr *) &(rq)->rq_xprt->xp_rtaddr)
443 #define SVC_CONTROL(xprt, rq, in) \
444 (*(xprt)->xp_ops->xp_control)((xprt), (rq), (in))
478 #define SVC_CONTROL(xprt, rq, in) \
479 (*(xprt)->xp_ops2->xp_control)((xprt), (rq), (in))
/freebsd-10-stable/contrib/smbfs/lib/smb/
H A DMakefile12 SRCS= rcfile.c ctx.c cfopt.c subr.c nls.c rap.c mbuf.c rq.c file.c \

Completed in 154 milliseconds

12345