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

12

/freebsd-10.0-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-10.0-release/sys/dev/cxgbe/iw_cxgbe/
H A Dt4.h345 static inline int t4_rqes_posted(struct t4_wq *wq) argument
347 return wq->rq.in_use;
350 static inline int t4_rq_empty(struct t4_wq *wq) argument
352 return wq->rq.in_use == 0;
355 static inline int t4_rq_full(struct t4_wq *wq) argument
357 return wq->rq.in_use == (wq->rq.size - 1);
360 static inline u32 t4_rq_avail(struct t4_wq *wq) argument
362 return wq->rq.size - 1 - wq
365 t4_rq_produce(struct t4_wq *wq, u8 len16) argument
375 t4_rq_consume(struct t4_wq *wq) argument
383 t4_rq_host_wq_pidx(struct t4_wq *wq) argument
388 t4_rq_wq_size(struct t4_wq *wq) argument
393 t4_sq_empty(struct t4_wq *wq) argument
398 t4_sq_full(struct t4_wq *wq) argument
403 t4_sq_avail(struct t4_wq *wq) argument
408 t4_sq_produce(struct t4_wq *wq, u8 len16) argument
418 t4_sq_consume(struct t4_wq *wq) argument
425 t4_sq_host_wq_pidx(struct t4_wq *wq) argument
430 t4_sq_wq_size(struct t4_wq *wq) argument
435 t4_ring_sq_db(struct t4_wq *wq, u16 inc) argument
441 t4_ring_rq_db(struct t4_wq *wq, u16 inc) argument
447 t4_wq_in_error(struct t4_wq *wq) argument
452 t4_set_wq_in_error(struct t4_wq *wq) argument
457 t4_disable_wq_db(struct t4_wq *wq) argument
462 t4_enable_wq_db(struct t4_wq *wq) argument
467 t4_wq_db_enabled(struct t4_wq *wq) argument
[all...]
H A Dcq.c197 static void insert_recv_cqe(struct t4_wq *wq, struct t4_cq *cq) argument
201 CTR5(KTR_IW_CXGBE, "%s wq %p cq %p sw_cidx %u sw_pidx %u", __func__, wq,
208 V_CQE_QPID(wq->sq.qid));
214 int c4iw_flush_rq(struct t4_wq *wq, struct t4_cq *cq, int count) argument
217 int in_use = wq->rq.in_use - count;
220 CTR5(KTR_IW_CXGBE, "%s wq %p cq %p rq.in_use %u skip count %u",
221 __func__, wq, cq, wq->rq.in_use, count);
223 insert_recv_cqe(wq, c
229 insert_sq_cqe(struct t4_wq *wq, struct t4_cq *cq, struct t4_swsqe *swcqe) argument
248 c4iw_flush_sq(struct t4_wq *wq, struct t4_cq *cq, int count) argument
288 cqe_completes_wr(struct t4_cqe *cqe, struct t4_wq *wq) argument
304 c4iw_count_scqes(struct t4_cq *cq, struct t4_wq *wq, int *count) argument
323 c4iw_count_rcqes(struct t4_cq *cq, struct t4_wq *wq, int *count) argument
342 flush_completed_wrs(struct t4_wq *wq, struct t4_cq *cq) argument
374 create_read_req_cqe(struct t4_wq *wq, struct t4_cqe *hw_cqe, struct t4_cqe *read_cqe) argument
389 advance_oldest_read(struct t4_wq *wq) argument
423 poll_cq(struct t4_wq *wq, struct t4_cq *cq, struct t4_cqe *cqe, u8 *cqe_flushed, u64 *cookie, u32 *credit) argument
595 struct t4_wq *wq; local
[all...]
H A Dqp.c108 static int destroy_qp(struct c4iw_rdev *rdev, struct t4_wq *wq, argument
115 contigfree(wq->rq.queue, wq->rq.memsize, M_DEVBUF);
116 dealloc_sq(rdev, &wq->sq);
117 c4iw_rqtpool_free(rdev, wq->rq.rqt_hwaddr, wq->rq.rqt_size);
118 kfree(wq->rq.sw_rq);
119 kfree(wq->sq.sw_sq);
120 c4iw_put_qpid(rdev, wq->rq.qid, uctx);
121 c4iw_put_qpid(rdev, wq
125 create_qp(struct c4iw_rdev *rdev, struct t4_wq *wq, struct t4_cq *rcq, struct t4_cq *scq, struct c4iw_dev_ucontext *uctx) argument
[all...]
H A Dev.c55 qhp->attr.state, qhp->wq.sq.qid, CQE_STATUS(err_cqe));
178 CQE_STATUS(err_cqe), qhp->wq.sq.qid);
/freebsd-10.0-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
128 wq.taskqueue = taskqueue_thread;
129 return queue_delayed_work(&wq, dwork, delay);
135 struct workqueue_struct *wq; local
137 wq = kmalloc(sizeof(*wq), M_WAITOK);
138 wq->taskqueue = taskqueue_create((name), M_WAITOK,
139 taskqueue_thread_enqueue, &wq
153 destroy_workqueue(struct workqueue_struct *wq) argument
[all...]
/freebsd-10.0-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);
562 struct oce_wq *wq = NULL; local
572 wq = sc->wq[queue_index];
574 LOCK(&wq->tx_lock);
575 status = oce_multiq_transmit(ifp, m, wq);
576 UNLOCK(&wq->tx_lock);
591 while ((m = buf_ring_dequeue_sc(sc->wq[
861 struct oce_wq *wq = sc->wq[wq_index]; local
1021 oce_tx_complete(struct oce_wq *wq, uint32_t wqe_idx, uint32_t status) argument
1049 oce_tx_restart(POCE_SOFTC sc, struct oce_wq *wq) argument
1137 struct oce_wq *wq = arg; local
1202 struct oce_wq *wq = (struct oce_wq *)arg; local
1249 oce_multiq_transmit(struct ifnet *ifp, struct mbuf *m, struct oce_wq *wq) argument
2057 struct oce_wq *wq; local
2118 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...]
/freebsd-10.0-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.c742 remove_handle(rhp, &rhp->qpidr, qhp->wq.qpid);
751 cxio_destroy_qp(&rhp->rdev, &qhp->wq,
755 ib_qp, qhp->wq.qpid, qhp);
810 qhp->wq.size_log2 = ilog2(wqsize);
811 qhp->wq.rq_size_log2 = ilog2(rqsize);
812 qhp->wq.sq_size_log2 = ilog2(sqsize);
814 if (cxio_create_qp(&rhp->rdev, !udata, &qhp->wq,
850 if (insert_handle(rhp, &rhp->qpidr, qhp, qhp->wq.qpid)) {
851 cxio_destroy_qp(&rhp->rdev, &qhp->wq,
874 uresp.qpid = qhp->wq
[all...]
/freebsd-10.0-release/sys/dev/hyperv/vmbus/
H A Dhv_channel_mgmt.c96 if (w->wq->work_sema != NULL) {
97 sema_wait(w->wq->work_sema);
102 if (w->wq->work_sema != NULL) {
103 sema_post(w->wq->work_sema);
115 struct hv_work_queue* wq; local
117 wq = malloc(sizeof(struct hv_work_queue), M_DEVBUF, M_NOWAIT | M_ZERO);
118 KASSERT(wq != NULL, ("Error VMBUS: Failed to allocate work_queue\n"));
119 if (wq == NULL)
140 wq->work_sema = &hv_vmbus_g_connection.control_sema;
151 wq
175 hv_work_queue_close(struct hv_work_queue *wq) argument
190 hv_queue_work_item( struct hv_work_queue *wq, void (*callback)(void *), void *context) argument
[all...]
/freebsd-10.0-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...]
/freebsd-10.0-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...]
/freebsd-10.0-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-10.0-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-10.0-release/sys/dev/drm/
H A Dvia_dmablit.h77 struct task wq; member in struct:_drm_via_blitq
/freebsd-10.0-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-10.0-release/sys/ofed/drivers/infiniband/hw/mlx4/
H A Dcq.c608 struct mlx4_ib_wq *wq; local
679 wq = &(*cur_qp)->sq;
682 wq->tail += (u16) (wqe_ctr - (u16) wq->tail);
684 wc->wr_id = wq->wrid[wq->tail & (wq->wqe_cnt - 1)];
685 ++wq->tail;
692 wq = &(*cur_qp)->rq;
693 tail = wq
[all...]
/freebsd-10.0-release/usr.sbin/bsdinstall/scripts/
H A Dnetconfig52 (ifconfig -g wlan | egrep -wq $IF) && continue

Completed in 363 milliseconds

12