/freebsd-9.3-release/cddl/contrib/opensolaris/tools/ctf/cvt/ |
H A D | ctfmerge.c | 286 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 D | workqueue.h | 109 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 D | oce_queue.c | 49 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 D | oce_if.c | 142 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 D | oce_sysctl.c | 893 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 D | oce_if.h | 207 #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 D | iw_cxgb_hal.c | 295 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 D | iw_cxgb_qp.c | 282 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 D | iw_cxgb_cq.c | 93 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 D | iw_cxgb_hal.h | 144 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 D | iw_cxgb_ev.c | 102 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 D | iw_cxgb_provider.c | 741 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 D | cq.c | 195 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 D | qp.c | 105 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 D | cq.c | 295 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 D | qp.c | 86 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 D | radeon_sa.c | 61 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 D | tst.badfreopen.ksh | 30 $dtrace -wq -o $tmpfile -s /dev/stdin 2> $errfile <<EOF
|
H A D | tst.freopen.ksh | 30 $dtrace -wq -o $tmpfile -s /dev/stdin $tmpfile <<EOF
|
/freebsd-9.3-release/sys/dev/drm/ |
H A D | via_dmablit.h | 77 struct task wq; member in struct:_drm_via_blitq
|
/freebsd-9.3-release/sys/ofed/drivers/infiniband/hw/mthca/ |
H A D | mthca_cq.c | 488 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 D | cq.c | 563 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 D | netconfig | 52 (ifconfig -g wlan | egrep -wq $IF) && continue
|
/freebsd-9.3-release/sys/ofed/drivers/infiniband/core/ |
H A D | mad_priv.h | 212 struct workqueue_struct *wq; member in struct:ib_mad_port_private
|
/freebsd-9.3-release/contrib/tcsh/ |
H A D | tw.parse.c | 604 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 &&
|