Searched refs:queue (Results 226 - 250 of 1686) sorted by relevance

1234567891011>>

/freebsd-current/sys/sys/
H A Dlockf.h38 #include <sys/queue.h>
103 * pending lock that is older in the queue - this helps to ensure
/freebsd-current/include/
H A Dmpool.h35 #include <sys/queue.h>
49 TAILQ_ENTRY(_bkt) hq; /* hash queue */
50 TAILQ_ENTRY(_bkt) q; /* lru queue */
61 TAILQ_HEAD(_lqh, _bkt) lqh; /* lru queue head */
62 /* hash queue array */
/freebsd-current/sys/amd64/include/
H A Dproc.h39 #include <sys/queue.h>
/freebsd-current/sys/dev/mmc/host/
H A Ddwmmc_hisi.c32 #include <sys/queue.h>
H A Ddwmmc_altera.c31 #include <sys/queue.h>
/freebsd-current/usr.sbin/jail/
H A Djailp.h32 #include <sys/queue.h>
69 #define JF_FROM_RUNQ 0x0800 /* Has already been on the run queue */
179 struct cfjails *queue; member in struct:cfjail
240 extern void requeue(struct cfjail *j, struct cfjails *queue);
241 extern void requeue_head(struct cfjail *j, struct cfjails *queue);
/freebsd-current/contrib/llvm-project/clang/lib/Analysis/
H A DIntervalPartition.cpp18 #include <queue>
50 std::queue<const Node *> Worklist;
107 std::queue<const Node *> &Successors,
156 std::queue<const Node *> Successors;
/freebsd-current/contrib/llvm-project/compiler-rt/lib/asan/
H A Dasan_mac.cpp125 // http://libdispatch.macosforge.org/trac/browser/trunk/src/queue.c
252 void dispatch_after(dispatch_time_t when, dispatch_queue_t queue,
257 dispatch_mach_t dispatch_mach_create(const char *label, dispatch_queue_t queue,
285 dispatch_time_t when, dispatch_queue_t queue, void(^work)(void)) {
288 REAL(dispatch_after)(when, queue, asan_block);
284 INTERCEPTOR(void, dispatch_after, dispatch_time_t when, dispatch_queue_t queue, void(^work)(void)) argument
/freebsd-current/lib/libc/stdlib/
H A Dcxa_thread_atexit_impl.c31 #include <sys/queue.h>
/freebsd-current/libexec/atrun/
H A Datrun.c127 int queue; local
299 queue = *filename;
303 nice(tolower(queue) - 'a');
309 * set based on the queue file name according to the tradition.
438 * be executed and or deleted. The queue is coded into the first byte of
452 char queue; local
541 if (sscanf(dirent->d_name,"%c%5lx%8lx",&queue,&jobno,&ctm) != 3)
547 if (isupper(queue) && (strcmp(batch_name,dirent->d_name) > 0)) {
556 if (islower(queue))
/freebsd-current/sys/geom/raid/
H A Dtr_concat.c211 struct bio_queue_head queue; local
244 bioq_init(&queue);
263 bioq_insert_tail(&queue, cbp);
271 while ((cbp = bioq_takefirst(&queue)) != NULL) {
278 while ((cbp = bioq_takefirst(&queue)) != NULL)
H A Dtr_raid0.c192 struct bio_queue_head queue; local
225 bioq_init(&queue);
243 bioq_insert_tail(&queue, cbp);
253 while ((cbp = bioq_takefirst(&queue)) != NULL) {
260 while ((cbp = bioq_takefirst(&queue)) != NULL)
/freebsd-current/sys/contrib/dev/mediatek/mt76/mt7603/
H A Dmain.c534 unsigned int link_id, u16 queue,
542 queue = dev->mphy.q_tx[queue]->hw_idx;
552 val = mt76_rr(dev, MT_WMM_TXOP(queue));
553 val &= ~(MT_WMM_TXOP_MASK << MT_WMM_TXOP_SHIFT(queue));
554 val |= params->txop << MT_WMM_TXOP_SHIFT(queue);
555 mt76_wr(dev, MT_WMM_TXOP(queue), val);
558 val &= ~(MT_WMM_AIFSN_MASK << MT_WMM_AIFSN_SHIFT(queue));
559 val |= params->aifs << MT_WMM_AIFSN_SHIFT(queue);
563 val &= ~(MT_WMM_CWMIN_MASK << MT_WMM_CWMIN_SHIFT(queue));
533 mt7603_conf_tx(struct ieee80211_hw *hw, struct ieee80211_vif *vif, unsigned int link_id, u16 queue, const struct ieee80211_tx_queue_params *params) argument
[all...]
/freebsd-current/sys/powerpc/powernv/
H A Dxive.c186 struct xive_queue queue; /* We only use a single queue for now. */ member in struct:xive_cpu
251 * XIVE. The XIVE writes into the queue with an alternating polarity bit, which
252 * flips when the queue wraps.
374 /* Allocate the queue page and populate the queue state data. */
375 xive_cpud->queue.q_page = contigmalloc(PAGE_SIZE, M_XIVE,
377 xive_cpud->queue.q_size = 1 << PAGE_SHIFT;
378 xive_cpud->queue.q_mask =
379 ((xive_cpud->queue
[all...]
/freebsd-current/usr.sbin/nscd/
H A Dnscd.c148 * Socket and kqueues are prepared here. We have one global queue for both
199 retval->queue = kqueue();
200 assert(retval->queue != -1);
205 kevent(retval->queue, &eventlist, 1, NULL, 0, &timeout);
216 close(env->queue);
264 res = kevent(env->queue, eventlist, 2, NULL, 0, &timeout);
290 nevents = kevent(env->queue, eventlist, 1, NULL, 0, &kevent_timeout);
457 kevent(env->queue, eventlist, 2, NULL, 0, &kevent_timeout);
497 nevents = kevent(env->queue, NULL, 0, eventlist,
515 kevent(s_runtime_env->queue, eventlis
[all...]
/freebsd-current/tests/sys/netpfil/common/
H A Ddummynet.sh186 jexec alcatraz dnctl pipe 1 config bw 10Mb queue 100 droptail
188 jexec alcatraz dnctl queue 1 config pipe 1 droptail
192 "ipfw add 1000 queue 1 ip from any to any" \
237 jexec ${j}b dnctl pipe 1 config bw 10Mb queue 100 delay 500 droptail
239 jexec ${j}b dnctl queue 1 config pipe 1 droptail
260 atf_set descr 'Basic queue test'
293 jexec alcatraz dnctl queue 100 config sched 1 weight 99 mask all
294 jexec alcatraz dnctl queue 200 config sched 1 weight 1 mask all
298 "ipfw add 1000 queue 100 tcp from 192.0.2.2 to any out" \
299 "ipfw add 1001 queue 20
[all...]
/freebsd-current/sys/dev/cxgbe/iw_cxgbe/
H A Dt4.h171 #define T4_ERR_DDP_QUEUE_NUM 0x17 /* invalid ddp queue number */
313 union t4_wr *queue; member in struct:t4_sq
339 union t4_recv_wr *queue; member in struct:t4_rq
407 return wq->rq.queue[wq->rq.size].status.host_wq_pidx;
457 return wq->sq.queue[wq->sq.size].status.host_wq_pidx;
485 /* Flush host queue memory writes. */
510 /* Flush host queue memory writes. */
532 return wq->rq.queue[wq->rq.size].status.qp_err;
537 wq->rq.queue[wq->rq.size].status.qp_err = 1;
545 struct t4_cqe *queue; member in struct:t4_cq
[all...]
H A Dqp.c112 wq->rq.memsize, wq->rq.queue,
115 wq->sq.memsize, wq->sq.queue,
178 wq->sq.queue = dma_alloc_coherent(rhp->ibdev.dma_device, wq->sq.memsize,
180 if (!wq->sq.queue) {
184 wq->sq.phys_addr = vtophys(wq->sq.queue);
186 memset(wq->sq.queue, 0, wq->sq.memsize);
188 wq->rq.queue = dma_alloc_coherent(rhp->ibdev.dma_device,
190 if (!wq->rq.queue) {
194 wq->rq.phys_addr = vtophys(wq->rq.queue);
196 memset(wq->rq.queue,
[all...]
/freebsd-current/sys/contrib/dev/rtw88/
H A Dtx.c181 if (skb_queue_len(&tx_report->queue) == 0)
187 skb_queue_purge(&tx_report->queue);
193 qlen = skb_queue_len(&tx_report->queue);
195 skb_queue_purge(&tx_report->queue);
199 * XXX while there could be a new enqueue in the queue
221 __skb_queue_tail(&tx_report->queue, skb);
263 skb_queue_walk_safe(&tx_report->queue, cur, tmp) {
266 __skb_unlink(cur, &tx_report->queue);
764 enum rtw_tx_queue_type queue; local
767 queue
[all...]
/freebsd-current/usr.sbin/lpr/lpc/
H A Dcmds.c411 * for this queue, or there is one running but *it* could not
610 /* init some fields before 'clean' is called for each queue */
649 struct dirent **queue; local
672 nitems = scandir(pp->spool_dir, &queue, doselect, sortq);
697 cp = queue[i]->d_name;
704 cp = queue[i]->d_name;
719 cp1 = queue[i + 1]->d_name;
857 * Enable queuing to the printer (allow lpr to add new jobs to the queue).
917 * will not process them as printer-queue names).
965 * a second or so before trying to restart the queue
1128 struct jobqueue **queue; variable in typeref:struct:jobqueue
[all...]
/freebsd-current/sys/kern/
H A Dkern_lock.c268 const char *wmesg, int pri, int timo, int queue)
280 (queue == SQ_EXCLUSIVE_QUEUE) ? "exclusive" : "shared");
284 if (queue == SQ_EXCLUSIVE_QUEUE && (flags & LK_SLEEPFAIL) != 0) {
290 SLEEPQ_INTERRUPTIBLE : 0), queue);
317 int queue, wakeup_swapper; local
338 * If interruptible sleeps left the exclusive queue empty
340 * queue by giving them precedence and cleaning up the
353 queue = SQ_EXCLUSIVE_QUEUE;
361 "%s: %p waking up threads on the exclusive queue",
366 queue
267 sleeplk(struct lock *lk, u_int flags, struct lock_object *ilk, const char *wmesg, int pri, int timo, int queue) argument
1123 int queue; local
1311 int error, ipri, itimo, queue, wakeup_swapper; local
[all...]
/freebsd-current/sys/powerpc/pseries/
H A Dphyp_vscsi.c82 TAILQ_ENTRY(vscsi_xfer) queue;
265 MALLOC_DEFINE(M_VSCSI, "vscsi", "CAM device queue for VSCSI");
322 TAILQ_INSERT_TAIL(&sc->free_xferq, &sc->loginxp, queue);
350 TAILQ_INSERT_TAIL(&sc->free_xferq, xp, queue);
471 panic("SCSI queue flooded");
473 TAILQ_REMOVE(&sc->free_xferq, xp, queue);
474 TAILQ_INSERT_TAIL(&sc->active_xferq, xp, queue);
501 panic("SCSI queue flooded");
503 TAILQ_REMOVE(&sc->free_xferq, xp, queue);
504 TAILQ_INSERT_TAIL(&sc->active_xferq, xp, queue);
[all...]
/freebsd-current/sys/dev/axgbe/
H A Dxgbe-dev.c1738 unsigned int queue, unsigned int q_fifo_size)
1744 axgbe_printf(1, "%s: queue %d q_fifo_size %d frame_fifo_size 0x%x\n",
1745 __func__, queue, q_fifo_size, frame_fifo_size);
1756 pdata->rx_rfa[queue] = 0;
1757 pdata->rx_rfd[queue] = 0;
1763 pdata->rx_rfa[queue] = 0; /* Full - 1024 bytes */
1764 pdata->rx_rfd[queue] = 1; /* Full - 1536 bytes */
1770 pdata->rx_rfa[queue] = 2; /* Full - 2048 bytes */
1771 pdata->rx_rfd[queue] = 5; /* Full - 3584 bytes */
1791 pdata->rx_rfa[queue]
1737 xgbe_queue_flow_control_threshold(struct xgbe_prv_data *pdata, unsigned int queue, unsigned int q_fifo_size) argument
1953 unsigned int qptc, qptc_extra, queue; local
2466 xgbe_txq_prepare_tx_stop(struct xgbe_prv_data *pdata, unsigned int queue) argument
2491 xgbe_prepare_tx_stop(struct xgbe_prv_data *pdata, unsigned int queue) argument
2580 xgbe_prepare_rx_stop(struct xgbe_prv_data *pdata, unsigned int queue) argument
[all...]
/freebsd-current/contrib/ofed/libcxgb4/
H A Dqp.c52 dst = &wq->sq.queue->flits[wq->sq.wq_pidx *
65 same sq.queue memory twice in this loop */
67 end = (uintptr_t)&wq->sq.queue[wq->sq.size];
74 memcpy(wq->sq.queue, src + len, total - len);
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);
410 qhp->wq.sq.queue[qhp->wq.sq.size].status.host_wq_pidx = \
479 qhp->wq.rq.queue[qhp->wq.rq.size].status.host_wq_pidx = \
/freebsd-current/contrib/llvm-project/lldb/source/Plugins/Process/gdb-remote/
H A DGDBRemoteCommunication.h17 #include <queue>
185 std::deque<std::string>& queue,

Completed in 625 milliseconds

1234567891011>>