Searched refs:wq (Results 1 - 25 of 39) sorted by relevance

12

/freebsd-9.3-release/cddl/contrib/opensolaris/tools/ctf/cvt/
H A Dctfmerge.c286 finalize_phase_one(workqueue_t *wq) argument
302 for (startslot = -1, i = 0; i < wq->wq_nwipslots; i++) {
303 if (wq->wq_wip[i].wip_batchid == wq->wq_lastdonebatch + 1) {
311 for (i = startslot; i < startslot + wq->wq_nwipslots; i++) {
312 int slotnum = i % wq->wq_nwipslots;
313 wip_t *wipslot = &wq->wq_wip[slotnum];
322 fifo_add(wq->wq_donequeue, wipslot->wip_td);
323 wq->wq_wip[slotnum].wip_td = NULL;
327 wq
334 init_phase_two(workqueue_t *wq) argument
362 wip_save_work(workqueue_t *wq, wip_t *slot, int slotnum) argument
400 worker_runphase1(workqueue_t *wq) argument
447 worker_runphase2(workqueue_t *wq) argument
518 worker_thread(workqueue_t *wq) argument
552 workqueue_t *wq = arg; local
633 wq_init(workqueue_t *wq, int nfiles) argument
694 start_threads(workqueue_t *wq) argument
723 join_threads(workqueue_t *wq) argument
748 static workqueue_t wq; variable
[all...]
/freebsd-9.3-release/sys/ofed/include/linux/
H A Dworkqueue.h109 queue_delayed_work(struct workqueue_struct *wq, struct delayed_work *work, argument
115 work->work.taskqueue = wq->taskqueue;
127 struct workqueue_struct *wq; local
129 wq = kmalloc(sizeof(*wq), M_WAITOK);
130 wq->taskqueue = taskqueue_create((name), M_WAITOK,
131 taskqueue_thread_enqueue, &wq->taskqueue);
132 taskqueue_start_threads(&wq->taskqueue, cpus, PWAIT, "%s", name);
134 return (wq);
145 destroy_workqueue(struct workqueue_struct *wq) argument
[all...]
/freebsd-9.3-release/sys/dev/oce/
H A Doce_queue.c49 static int oce_wq_create(struct oce_wq *wq, struct oce_eq *eq);
50 static void oce_wq_free(struct oce_wq *wq);
51 static void oce_wq_del(struct oce_wq *wq);
90 struct oce_wq *wq; local
95 for_all_wq_queues(sc, wq, i) {
96 sc->wq[i] = oce_wq_init(sc, sc->tx_ring_size,
98 if (!sc->wq[i])
131 for_all_wq_queues(sc, wq, i) {
132 rc = oce_wq_create(wq, sc->eq[i]);
135 wq
168 struct oce_wq *wq; local
207 struct oce_wq *wq; local
281 oce_wq_free(struct oce_wq *wq) argument
318 oce_wq_create(struct oce_wq *wq, struct oce_eq *eq) argument
365 oce_wq_del(struct oce_wq *wq) argument
970 oce_start_wq(struct oce_wq *wq) argument
1072 oce_drain_wq_cq(struct oce_wq *wq) argument
[all...]
H A Doce_if.c142 static void oce_tx_restart(POCE_SOFTC sc, struct oce_wq *wq);
143 static void oce_tx_complete(struct oce_wq *wq, uint32_t wqe_idx,
146 struct oce_wq *wq);
561 struct oce_wq *wq = NULL; local
571 wq = sc->wq[queue_index];
573 LOCK(&wq->tx_lock);
574 status = oce_multiq_transmit(ifp, m, wq);
575 UNLOCK(&wq->tx_lock);
590 while ((m = buf_ring_dequeue_sc(sc->wq[
871 struct oce_wq *wq = sc->wq[wq_index]; local
1031 oce_tx_complete(struct oce_wq *wq, uint32_t wqe_idx, uint32_t status) argument
1059 oce_tx_restart(POCE_SOFTC sc, struct oce_wq *wq) argument
1147 struct oce_wq *wq = arg; local
1212 struct oce_wq *wq = (struct oce_wq *)arg; local
1247 oce_multiq_transmit(struct ifnet *ifp, struct mbuf *m, struct oce_wq *wq) argument
2055 struct oce_wq *wq; local
2116 struct oce_wq *wq; local
[all...]
H A Doce_sysctl.c893 CTLFLAG_RD, &sc->wq[i]->tx_stats.tx_pkts,
896 CTLFLAG_RD, &sc->wq[i]->tx_stats.tx_bytes,
899 CTLFLAG_RD, &sc->wq[i]->tx_stats.tx_reqs, 0,
902 CTLFLAG_RD, &sc->wq[i]->tx_stats.tx_stops, 0,
905 CTLFLAG_RD, &sc->wq[i]->tx_stats.tx_wrbs, 0,
908 CTLFLAG_RD, &sc->wq[i]->tx_stats.tx_compl, 0,
912 &sc->wq[i]->tx_stats.ipv6_ext_hdr_tx_drop, 0,
1096 CTLFLAG_RD, &sc->wq[i]->tx_stats.tx_pkts,
1099 CTLFLAG_RD, &sc->wq[i]->tx_stats.tx_bytes,
1102 CTLFLAG_RD, &sc->wq[
[all...]
H A Doce_if.h207 #define for_all_wq_queues(sc, wq, i) \
208 for (i = 0, wq = sc->wq[0]; i < sc->nwqs; i++, wq = sc->wq[i])
840 struct oce_wq *wq[OCE_MAX_WQ]; /* TX work queues */ member in struct:oce_softc
966 int oce_start_wq(struct oce_wq *wq);
976 void oce_drain_wq_cq(struct oce_wq *wq);
1046 int oce_mbox_create_wq(struct oce_wq *wq);
/freebsd-9.3-release/sys/dev/cxgb/ulp/iw_cxgb/
H A Diw_cxgb_hal.c295 struct t3_wq *wq, struct cxio_ucontext *uctx)
297 int depth = 1UL << wq->size_log2;
298 int rqsize = 1UL << wq->rq_size_log2;
300 wq->qpid = get_qpid(rdev_p, uctx);
301 if (!wq->qpid)
304 wq->rq = malloc(depth * sizeof(struct t3_swrq), M_DEVBUF, M_NOWAIT|M_ZERO);
305 if (!wq->rq)
308 wq->rq_addr = cxio_hal_rqtpool_alloc(rdev_p, rqsize);
309 if (!wq->rq_addr)
312 wq
294 cxio_create_qp(struct cxio_rdev *rdev_p, u32 kernel_domain, struct t3_wq *wq, struct cxio_ucontext *uctx) argument
362 cxio_destroy_qp(struct cxio_rdev *rdev_p, struct t3_wq *wq, struct cxio_ucontext *uctx) argument
383 insert_recv_cqe(struct t3_wq *wq, struct t3_cq *cq) argument
402 cxio_flush_rq(struct t3_wq *wq, struct t3_cq *cq, int count) argument
421 insert_sq_cqe(struct t3_wq *wq, struct t3_cq *cq, struct t3_swsq *sqp) argument
443 cxio_flush_sq(struct t3_wq *wq, struct t3_cq *cq, int count) argument
482 cqe_completes_wr(struct t3_cqe *cqe, struct t3_wq *wq) argument
501 cxio_count_scqes(struct t3_cq *cq, struct t3_wq *wq, int *count) argument
519 cxio_count_rcqes(struct t3_cq *cq, struct t3_wq *wq, int *count) argument
1077 flush_completed_wrs(struct t3_wq *wq, struct t3_cq *cq) argument
1107 create_read_req_cqe(struct t3_wq *wq, struct t3_cqe *hw_cqe, struct t3_cqe *read_cqe) argument
1122 advance_oldest_read(struct t3_wq *wq) argument
1154 cxio_poll_cq(struct t3_wq *wq, struct t3_cq *cq, struct t3_cqe *cqe, u8 *cqe_flushed, u64 *cookie, u32 *credit) argument
[all...]
H A Diw_cxgb_qp.c282 qhp->wq.rq[Q_PTR2IDX(qhp->wq.rq_wptr,
283 qhp->wq.rq_size_log2)].wr_id = wr->wr_id;
284 qhp->wq.rq[Q_PTR2IDX(qhp->wq.rq_wptr,
285 qhp->wq.rq_size_log2)].pbl_addr = 0;
346 qhp->wq.rq[Q_PTR2IDX(qhp->wq.rq_wptr,
347 qhp->wq.rq_size_log2)].wr_id = wr->wr_id;
348 qhp->wq
[all...]
H A Diw_cxgb_cq.c93 struct t3_wq *wq; local
106 wq = NULL;
109 wq = &(qhp->wq);
111 ret = cxio_poll_cq(wq, &(chp->cq), &cqe, &cqe_flushed, &cookie,
225 if (wq)
H A Diw_cxgb_hal.h144 int cxio_create_qp(struct cxio_rdev *rdev, u32 kernel_domain, struct t3_wq *wq,
146 int cxio_destroy_qp(struct cxio_rdev *rdev, struct t3_wq *wq,
168 int cxio_flush_rq(struct t3_wq *wq, struct t3_cq *cq, int count);
169 int cxio_flush_sq(struct t3_wq *wq, struct t3_cq *cq, int count);
170 void cxio_count_rcqes(struct t3_cq *cq, struct t3_wq *wq, int *count);
171 void cxio_count_scqes(struct t3_cq *cq, struct t3_wq *wq, int *count);
173 int cxio_poll_cq(struct t3_wq *wq, struct t3_cq *cq, struct t3_cqe *cqe,
H A Diw_cxgb_ev.c102 qhp->attr.state, qhp->wq.qpid, CQE_STATUS(rsp_msg->cqe));
171 __FUNCTION__, qhp->wq.qpid, qhp->ep);
175 qhp->wq.qpid);
251 CQE_STATUS(rsp_msg->cqe), qhp->wq.qpid);
H A Diw_cxgb_provider.c741 remove_handle(rhp, &rhp->qpidr, qhp->wq.qpid);
750 cxio_destroy_qp(&rhp->rdev, &qhp->wq,
754 ib_qp, qhp->wq.qpid, qhp);
809 qhp->wq.size_log2 = ilog2(wqsize);
810 qhp->wq.rq_size_log2 = ilog2(rqsize);
811 qhp->wq.sq_size_log2 = ilog2(sqsize);
813 if (cxio_create_qp(&rhp->rdev, !udata, &qhp->wq,
849 if (insert_handle(rhp, &rhp->qpidr, qhp, qhp->wq.qpid)) {
850 cxio_destroy_qp(&rhp->rdev, &qhp->wq,
873 uresp.qpid = qhp->wq
[all...]
/freebsd-9.3-release/contrib/ofed/libmlx4/src/
H A Dcq.c195 struct mlx4_wq *wq; local
250 wq = &(*cur_qp)->sq;
252 wq->tail += (uint16_t) (wqe_index - (uint16_t) wq->tail);
253 wc->wr_id = wq->wrid[wq->tail & (wq->wqe_cnt - 1)];
254 ++wq->tail;
265 wq = &(*cur_qp)->rq;
266 wc->wr_id = wq
[all...]
H A Dqp.c105 static int wq_overflow(struct mlx4_wq *wq, int nreq, struct mlx4_cq *cq) argument
109 cur = wq->head - wq->tail;
110 if (cur + nreq < wq->max_post)
114 cur = wq->head - wq->tail;
117 return cur + nreq >= wq->max_post;
/freebsd-9.3-release/contrib/ofed/libmthca/src/
H A Dcq.c295 struct mthca_wq *wq; local
340 wq = &(*cur_qp)->sq;
341 wqe_index = ((ntohl(cqe->wqe) - (*cur_qp)->send_wqe_offset) >> wq->wqe_shift);
346 wq = NULL;
352 wq = &(*cur_qp)->rq;
354 wqe_index = wqe >> wq->wqe_shift;
362 wqe_index = wq->max - 1;
366 if (wq) {
367 if (wq->last_comp < wqe_index)
368 wq
[all...]
H A Dqp.c86 static inline int wq_overflow(struct mthca_wq *wq, int nreq, struct mthca_cq *cq) argument
90 cur = wq->head - wq->tail;
91 if (cur + nreq < wq->max)
95 cur = wq->head - wq->tail;
98 return cur + nreq >= wq->max;
/freebsd-9.3-release/sys/dev/drm2/radeon/
H A Dradeon_sa.c61 cv_init(&sa_manager->wq, "drm__radeon_sa_manager__wq");
98 cv_destroy(&sa_manager->wq);
364 r = -cv_wait_sig(&sa_manager->wq,
402 cv_broadcast(&sa_manager->wq);
413 spin_lock(&sa_manager->wq.lock);
428 spin_unlock(&sa_manager->wq.lock);
/freebsd-9.3-release/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/funcs/
H A Dtst.badfreopen.ksh30 $dtrace -wq -o $tmpfile -s /dev/stdin 2> $errfile <<EOF
H A Dtst.freopen.ksh30 $dtrace -wq -o $tmpfile -s /dev/stdin $tmpfile <<EOF
/freebsd-9.3-release/sys/dev/drm/
H A Dvia_dmablit.h77 struct task wq; member in struct:_drm_via_blitq
/freebsd-9.3-release/sys/ofed/drivers/infiniband/hw/mthca/
H A Dmthca_cq.c488 struct mthca_wq *wq; local
538 wq = &(*cur_qp)->sq;
540 >> wq->wqe_shift);
545 wq = NULL;
551 wq = &(*cur_qp)->rq;
553 wqe_index = wqe >> wq->wqe_shift;
560 wqe_index = wq->max - 1;
564 if (wq) {
565 if (wq->last_comp < wqe_index)
566 wq
[all...]
/freebsd-9.3-release/sys/ofed/drivers/infiniband/hw/mlx4/
H A Dcq.c563 struct mlx4_ib_wq *wq; local
649 wq = &(*cur_qp)->sq;
652 wq->tail += (u16) (wqe_ctr - (u16) wq->tail);
654 wc->wr_id = wq->wrid[wq->tail & (wq->wqe_cnt - 1)];
655 ++wq->tail;
666 wq = &(*cur_qp)->rq;
667 wc->wr_id = wq
[all...]
/freebsd-9.3-release/usr.sbin/bsdinstall/scripts/
H A Dnetconfig52 (ifconfig -g wlan | egrep -wq $IF) && continue
/freebsd-9.3-release/sys/ofed/drivers/infiniband/core/
H A Dmad_priv.h212 struct workqueue_struct *wq; member in struct:ib_mad_port_private
/freebsd-9.3-release/contrib/tcsh/
H A Dtw.parse.c604 Char w, wq; local
620 wq = w & QUOTE;
624 wq = QUOTE; /* quotes are always quoted */
626 if (!wq && qu && tricky(w) && !(qu == '\"' && tricky_dq(w))) {
653 else if (wq && qu == '\"' && tricky_dq(w)) {
659 } else if (wq &&

Completed in 150 milliseconds

12