/freebsd-current/sys/sys/ |
H A D | lockf.h | 38 #include <sys/queue.h> 103 * pending lock that is older in the queue - this helps to ensure
|
/freebsd-current/include/ |
H A D | mpool.h | 35 #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 D | proc.h | 39 #include <sys/queue.h>
|
/freebsd-current/sys/dev/mmc/host/ |
H A D | dwmmc_hisi.c | 32 #include <sys/queue.h>
|
H A D | dwmmc_altera.c | 31 #include <sys/queue.h>
|
/freebsd-current/usr.sbin/jail/ |
H A D | jailp.h | 32 #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 D | IntervalPartition.cpp | 18 #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 D | asan_mac.cpp | 125 // 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 D | cxa_thread_atexit_impl.c | 31 #include <sys/queue.h>
|
/freebsd-current/libexec/atrun/ |
H A D | atrun.c | 127 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 D | tr_concat.c | 211 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 D | tr_raid0.c | 192 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 D | main.c | 534 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 D | xive.c | 186 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 D | nscd.c | 148 * 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 D | dummynet.sh | 186 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 D | t4.h | 171 #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 D | qp.c | 112 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 D | tx.c | 181 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 D | cmds.c | 411 * 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 D | kern_lock.c | 268 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 D | phyp_vscsi.c | 82 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 D | xgbe-dev.c | 1738 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 D | qp.c | 52 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 D | GDBRemoteCommunication.h | 17 #include <queue> 185 std::deque<std::string>& queue,
|