Home
last modified time | relevance | path

Searched full:queue (Results 1 – 25 of 2944) sorted by relevance

12345678910>>...118

/freebsd/sys/contrib/vchiq/interface/vchiq_arm/
H A Dvchiq_util.c41 int vchiu_queue_init(VCHIU_QUEUE_T *queue, int size) in vchiu_queue_init() argument
45 queue->size = size; in vchiu_queue_init()
46 queue->read = 0; in vchiu_queue_init()
47 queue->write = 0; in vchiu_queue_init()
48 queue->initialized = 1; in vchiu_queue_init()
50 _sema_init(&queue->pop, 0); in vchiu_queue_init()
51 _sema_init(&queue->push, 0); in vchiu_queue_init()
53 queue->storage = kzalloc(size * sizeof(VCHIQ_HEADER_T *), GFP_KERNEL); in vchiu_queue_init()
54 if (queue->storage == NULL) { in vchiu_queue_init()
55 vchiu_queue_delete(queue); in vchiu_queue_init()
[all …]
/freebsd/sys/kern/
H A Dsubr_taskqueue.c107 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init() argument
112 callout_init_mtx(&timeout_task->c, &queue->tq_mutex, in _timeout_task_init()
114 timeout_task->q = queue; in _timeout_task_init()
127 task_get_busy(struct taskqueue *queue, struct task *task) in task_get_busy() argument
131 TQ_ASSERT_LOCKED(queue); in task_get_busy()
132 LIST_FOREACH(tb, &queue->tq_active, tb_link) { in task_get_busy()
144 struct taskqueue *queue; in _taskqueue_create() local
151 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO); in _taskqueue_create()
152 if (queue == NULL) { in _taskqueue_create()
159 STAILQ_INIT(&queue->tq_queue); in _taskqueue_create()
[all …]
H A Dsubr_gtaskqueue.c51 static int task_is_running(struct gtaskqueue *queue, struct gtask *gtask);
52 static void gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask);
127 struct gtaskqueue *queue; in _gtaskqueue_create() local
136 queue = malloc(sizeof(struct gtaskqueue), M_GTASKQUEUE, mflags | M_ZERO); in _gtaskqueue_create()
137 if (!queue) { in _gtaskqueue_create()
142 STAILQ_INIT(&queue->tq_queue); in _gtaskqueue_create()
143 LIST_INIT(&queue->tq_active); in _gtaskqueue_create()
144 queue->tq_enqueue = enqueue; in _gtaskqueue_create()
145 queue->tq_context = context; in _gtaskqueue_create()
146 queue->tq_name = tq_name; in _gtaskqueue_create()
[all …]
/freebsd/share/man/man3/
H A DMakefile24 queue.3 \
199 MLINKS+= queue.3 LIST_CLASS_ENTRY.3 \
200 queue.3 LIST_CLASS_HEAD.3 \
201 queue.3 LIST_EMPTY.3 \
202 queue.3 LIST_ENTRY.3 \
203 queue.3 LIST_FIRST.3 \
204 queue.3 LIST_FOREACH.3 \
205 queue.3 LIST_FOREACH_FROM.3 \
206 queue.3 LIST_FOREACH_FROM_SAFE.3 \
207 queue.3 LIST_FOREACH_SAFE.3 \
[all …]
H A Dqueue.3260 or for implementing a LIFO queue.
291 or for implementing a FIFO queue.
430 A singly-linked tail queue should be used if this macro is needed in
598 A singly-linked tail queue is headed by a structure defined by the
602 one to the first element in the tail queue and the other to
603 the last element in the tail queue.
607 New elements can be added to the tail queue after an existing element,
608 at the head of the tail queue, or at the end of the tail queue.
620 is the type of the elements to be linked into the tail queue.
621 A pointer to the head of the tail queue can later be declared as:
[all …]
/freebsd/usr.bin/posixmqcontrol/
H A Dposixmqcontrol.136 .Fl q Ar queue
44 .Fl q Ar queue
47 .Fl q Ar queue
50 .Fl q Ar queue
53 .Fl q Ar queue
59 command allows separating POSIX message queue administration from application
61 Defining and adjusting queue attributes can be done without touching
63 It allows creating queues, inspecting queue metadata, altering group and user
64 access to queues, dumping queue contents, and unlinking queues.
68 The maximum message size, maximum queue size, and current queue size are
[all …]
/freebsd/share/examples/pf/
H A Dfaq-example39 # enable queueing on the external interface to queue packets going out
11 # each queue can be controlled. the max outgoing bandwidth is 1.5Mbps.
13 altq on fxp0 cbq bandwidth 1.5Mb queue { std_ext, www_ext, boss_ext }
16 # std_ext - the standard queue. also the default queue for
18 # www_ext - container queue for WWW server queues. limit to
24 queue std_ext bandwidth 500Kb cbq(default borrow)
25 queue www_ext bandwidth 500Kb { www_ext_http, www_ext_misc }
26 queue www_ext_http bandwidth 50% priority 3 cbq(red borrow)
27 queue www_ext_misc bandwidth 50% priority 1 cbq(borrow)
28 queue boss_ext bandwidth 500Kb priority 3 cbq(borrow)
[all …]
H A Dfaq-example212 # ACK queue.
14 altq on fxp0 priq bandwidth 610Kb queue { std_out, ssh_im_out, dns_out, \
18 # std_out - the standard queue. any filter rule below that does not
19 # explicitly specify a queue will have its traffic added
20 # to this queue.
25 queue std_out priq(default)
26 queue ssh_im_out priority 4 priq(red)
27 queue dns_out priority 5
28 queue tcp_ack_out priority 6
34 altq on dc0 cbq bandwidth 2Mb queue { std_in, ssh_im_in, dns_in, bob_in }
[all …]
H A Dqueue22 # advanced queue example.
9 altq on $ext_if cbq bandwidth 5Mb queue { std, http, mail, ssh }
11 queue std bandwidth 10% cbq(default)
12 queue http bandwidth 60% priority 2 cbq(borrow red) { employees, developers }
13 queue developers bandwidth 75% cbq(borrow)
14 queue employees bandwidth 15%
15 queue mail bandwidth 10% priority 0 cbq(borrow ecn)
16 queue ssh bandwidth 20% cbq(borrow) { ssh_interactive, ssh_bulk }
17 queue ssh_interactive bandwidth 25% priority 7
18 queue ssh_bulk bandwidth 75% priority 0
[all …]
/freebsd/sys/cam/
H A Dcam_queue.c2 * CAM request queue management functions.
42 static MALLOC_DEFINE(M_CAMQ, "CAM queue", "CAM queue buffers");
43 static MALLOC_DEFINE(M_CAMDEVQ, "CAM dev queue", "CAM dev queue buffers");
44 static MALLOC_DEFINE(M_CAMCCBQ, "CAM ccb queue", "CAM ccb queue buffers");
73 * obtained a camq structure. The XPT should ensure that the queue
77 camq_fini(struct camq *queue) in camq_fini() argument
79 if (queue->queue_array != NULL) { in camq_fini()
80 free(queue->queue_array, M_CAMQ); in camq_fini()
85 camq_resize(struct camq *queue, int new_size) in camq_resize() argument
89 KASSERT(new_size >= queue->entries, ("camq_resize: " in camq_resize()
[all …]
H A Dcam_queue.h2 * CAM request queue management definitions.
38 #include <sys/queue.h>
42 * This structure implements a heap based priority queue. The queue
61 struct camq queue; member
102 * Resize a cam queue
104 uint32_t camq_resize(struct camq *queue, int new_size);
114 void camq_fini(struct camq *queue);
117 * cam_queue_insert: Given a CAM queue with at least one open spot,
120 void camq_insert(struct camq *queue, cam_pinfo *new_entry);
123 * camq_remove: Remove and arbitrary entry from the queue maintaining
[all …]
/freebsd/contrib/llvm-project/lldb/include/lldb/Target/
H A DQueue.h1 //===-- Queue.h ------------------------------------------------*- C++ -*-===//
22 // Queue:
23 // This class represents a libdispatch aka Grand Central Dispatch queue in the
28 // pthreads to execute the work items for the queues. A serial queue will be
30 // any work). A concurrent queue may be associated with multiple threads.
32 class Queue : public std::enable_shared_from_this<Queue> {
34 Queue(lldb::ProcessSP process_sp, lldb::queue_id_t queue_id,
37 ~Queue();
39 /// Get the QueueID for this Queue
41 /// A 64-bit ID number that uniquely identifies a queue at this particular
[all …]
/freebsd/sys/contrib/device-tree/Bindings/net/
H A Dintel,ixp4xx-hss.yaml15 Processing Engine) and the IXP4xx Queue Manager to process
35 intel,queue-chl-rxtrig:
39 - description: phandle to the RX trigger queue on the NPE
40 - description: the queue instance number
41 description: phandle to the RX trigger queue on the NPE
43 intel,queue-chl-txready:
47 - description: phandle to the TX ready queue on the NPE
48 - description: the queue instance number
49 description: phandle to the TX ready queue on the NPE
51 intel,queue-pkt-rx:
[all …]
/freebsd/contrib/googletest/googletest/samples/
H A Dsample3-inl.h37 // Queue is a simple queue implemented as a singled-linked list.
41 class Queue; variable
43 // QueueNode is a node in a Queue, which consists of an element of
47 friend class Queue<E>;
53 // Gets the next node in the queue.
72 class Queue {
74 // Creates an empty queue.
75 Queue() : head_(nullptr), last_(nullptr), size_(0) {} in Queue() function
77 // D'tor. Clears the queue.
78 ~Queue() { Clear(); } in ~Queue()
[all …]
/freebsd/share/man/man9/
H A Dsleepqueue.955 …eepq_add "const void *wchan" "struct lock_object *lock" "const char *wmesg" "int flags" "int queue"
59 .Fn sleepq_broadcast "const void *wchan" "int flags" "int pri" "int queue"
71 .Fn sleepq_signal "const void *wchan" "int flags" "int pri" "int queue"
78 .Fn sleepq_sleepcnt "const void *wchan" "int queue"
92 Each queue is associated with a specific wait channel when it is active,
93 and only one queue may be associated with a wait channel at any given point
97 An active queue holds a list of threads that are blocked on the associated
100 sleep queue.
101 When a thread blocks on a wait channel it donates its inactive sleep queue
104 the wait channel that it was blocked on gives it an inactive sleep queue for
[all …]
H A Dtaskqueue.947 STAILQ_ENTRY(task) ta_link; /* link for queue */
49 u_short ta_priority; /* priority of task in queue */
80 .Fn taskqueue_set_callback "struct taskqueue *queue" "enum taskqueue_callback_type cb_type" "taskqu…
82 .Fn taskqueue_free "struct taskqueue *queue"
84 .Fn taskqueue_enqueue "struct taskqueue *queue" "struct task *task"
86 .Fn taskqueue_enqueue_flags "struct taskqueue *queue" "struct task *task" "int flags"
88 .Fn taskqueue_enqueue_timeout "struct taskqueue *queue" "struct timeout_task *timeout_task" "int ti…
90 .Fn taskqueue_enqueue_timeout_sbt "struct taskqueue *queue" "struct timeout_task *timeout_task" "sb…
92 .Fn taskqueue_cancel "struct taskqueue *queue" "struct task *task" "u_int *pendp"
94 .Fn taskqueue_cancel_timeout "struct taskqueue *queue" "struct timeout_task *timeout_task" "u_int *…
[all …]
H A Daltq.974 The output queue macros are used to abstract queue operations and not to
75 touch the internal fields of the output queue structure.
88 to the queue
110 dequeues a packet from the queue.
120 since a non-empty queue could return
125 returns the next packet without removing it from the queue.
126 The caller must hold the queue mutex when calling
133 variants (if available) always assume that the caller holds the queue mutex.
140 discards all the packets in the queue.
141 The purge operation is needed since a non-work conserving queue cannot be
[all …]
/freebsd/contrib/dma/
H A Dspool.c58 * 'Q'id files (queue):
67 * Each queue file needs to have a corresponding data file.
70 * Queue ids are unique, formed from the inode of the data file
75 newspoolf(struct queue *queue) in newspoolf() argument
93 queue->tmpf = strdup(fn); in newspoolf()
94 if (queue->tmpf == NULL) in newspoolf()
98 * Assign queue id in newspoolf()
102 if (asprintf(&queue->id, "%"PRIxMAX, (uintmax_t)st.st_ino) < 0) in newspoolf()
105 queue->mailf = fdopen(fd, "r+"); in newspoolf()
106 if (queue->mailf == NULL) in newspoolf()
[all …]
H A Ddma.c40 #include <sys/queue.h>
99 set_from(struct queue *queue, const char *osender) in set_from() argument
133 queue->sender = sender; in set_from()
157 do_alias(struct queue *queue, const char *addr) in do_alias() argument
167 if (add_recp(queue, sit->str, EXPAND_ADDR) != 0) in do_alias()
177 add_recp(struct queue *queue, const char *str, int expand) in add_recp() argument
191 it->sender = queue->sender; in add_recp()
198 LIST_FOREACH(tit, &queue->queue, next) { in add_recp()
206 LIST_INSERT_HEAD(&queue->queue, it, next); in add_recp()
215 aliased = do_alias(queue, it->addr); in add_recp()
[all …]
/freebsd/contrib/ntp/ntpd/
H A Dntp_prio_q.c3 * This file contains the priority queue implementation used by the
18 /* Priority Queue
20 * Define a priority queue in which the relative priority of the elements
24 queue *debug_create_priority_queue( in debug_create_priority_queue()
32 queue *my_queue; in debug_create_priority_queue()
35 my_queue = emalloc(sizeof(queue)); in debug_create_priority_queue()
38 my_queue = debug_erealloc(NULL, sizeof(queue), sourcefile, line_num); in debug_create_priority_queue()
48 /* Define a function to "destroy" a priority queue, freeing-up
53 queue *my_queue in destroy_queue()
58 /* Empty out the queue elements if they are not already empty */ in destroy_queue()
[all …]
/freebsd/sys/contrib/device-tree/Bindings/soc/ti/
H A Dkeystone-navigator-qmss.txt1 * Texas Instruments Keystone Navigator Queue Management SubSystem driver
3 The QMSS (Queue Manager Sub System) found on Keystone SOCs is one of
5 multi-core Navigator. QMSS consist of queue managers, packed-data structure
8 The Queue Manager is a hardware module that is responsible for accelerating
15 queue pool management (allocation, push, pop and notify) and descriptor
23 - queue-range : <start number> total range of queue numbers for the device.
29 - qmgrs : child node describing the individual queue managers on the
32 -- managed-queues : the actual queues managed by each queue manager
33 instance, specified as <"base queue #" "# of queues">.
37 - Queue Peek region.
[all …]
/freebsd/contrib/llvm-project/libcxx/include/
H A Dqueue14 queue synopsis
20 class queue
33 queue() = default;
34 ~queue() = default;
36 queue(const queue& q) = default;
37 queue(queue&& q) = default;
39 queue& operator=(const queue& q) = default;
40 queue& operator=(queue&& q) = default;
42 explicit queue(const container_type& c);
43 explicit queue(container_type&& c)
[all …]
/freebsd/sys/contrib/dev/iwlwifi/mvm/
H A Dsta.c306 static int iwl_mvm_invalidate_sta_queue(struct iwl_mvm *mvm, int queue, in iwl_mvm_invalidate_sta_queue() argument
319 sta_id = mvm->queue_info[queue].ra_sta_id; in iwl_mvm_invalidate_sta_queue()
347 /* Notify FW of queue removal from the STA queues */ in iwl_mvm_invalidate_sta_queue()
357 int queue = *queueptr; in iwl_mvm_disable_txq() local
359 .scd_queue = queue, in iwl_mvm_disable_txq()
387 iwl_trans_txq_free(mvm->trans, queue); in iwl_mvm_disable_txq()
393 if (WARN_ON(mvm->queue_info[queue].tid_bitmap == 0)) in iwl_mvm_disable_txq()
396 mvm->queue_info[queue].tid_bitmap &= ~BIT(tid); in iwl_mvm_disable_txq()
398 cmd.action = mvm->queue_info[queue].tid_bitmap ? in iwl_mvm_disable_txq()
401 mvm->queue_info[queue] in iwl_mvm_disable_txq()
447 iwl_mvm_get_queue_agg_tids(struct iwl_mvm * mvm,int queue) iwl_mvm_get_queue_agg_tids() argument
487 iwl_mvm_remove_sta_queue_marking(struct iwl_mvm * mvm,int queue) iwl_mvm_remove_sta_queue_marking() argument
550 iwl_mvm_free_inactive_queue(struct iwl_mvm * mvm,int queue,struct ieee80211_sta * old_sta,u8 new_sta_id) iwl_mvm_free_inactive_queue() argument
600 int queue = 0; iwl_mvm_get_shared_queue() local
666 iwl_mvm_reconfig_scd(struct iwl_mvm * mvm,int queue,int fifo,int sta_id,int tid,int frame_limit,u16 ssn) iwl_mvm_reconfig_scd() argument
704 iwl_mvm_redirect_queue(struct iwl_mvm * mvm,int queue,int tid,int ac,int ssn,unsigned int wdg_timeout,bool force,struct iwl_mvm_txq * txq) iwl_mvm_redirect_queue() argument
852 int queue, size; iwl_mvm_tvqm_enable_txq() local
921 int queue = -1; iwl_mvm_sta_alloc_queue_tvqm() local
948 iwl_mvm_update_txq_mapping(struct iwl_mvm * mvm,struct ieee80211_sta * sta,int queue,u8 sta_id,u8 tid) iwl_mvm_update_txq_mapping() argument
991 iwl_mvm_enable_txq(struct iwl_mvm * mvm,struct ieee80211_sta * sta,int queue,u16 ssn,const struct iwl_trans_txq_scd_cfg * cfg,unsigned int wdg_timeout) iwl_mvm_enable_txq() argument
1025 iwl_mvm_change_queue_tid(struct iwl_mvm * mvm,int queue) iwl_mvm_change_queue_tid() argument
1062 iwl_mvm_unshare_queue(struct iwl_mvm * mvm,int queue) iwl_mvm_unshare_queue() argument
1149 iwl_mvm_remove_inactive_tids(struct iwl_mvm * mvm,struct iwl_mvm_sta * mvmsta,int queue,unsigned long tid_bitmap,unsigned long * unshare_queues,unsigned long * changetid_queues) iwl_mvm_remove_inactive_tids() argument
1351 int queue = -1; iwl_mvm_sta_alloc_queue() local
1565 int queue; iwl_mvm_reserve_sta_stream() local
2174 iwl_mvm_enable_aux_snif_queue(struct iwl_mvm * mvm,u16 queue,u8 sta_id,u8 fifo) iwl_mvm_enable_aux_snif_queue() argument
2206 iwl_mvm_add_int_sta_with_queue(struct iwl_mvm * mvm,int macidx,int maccolor,u8 * addr,struct iwl_mvm_int_sta * sta,u16 * queue,int fifo) iwl_mvm_add_int_sta_with_queue() argument
2339 int queue; iwl_mvm_send_add_bcast_sta() local
2415 u16 *queueptr, queue; iwl_mvm_free_bcast_sta_queues() local
2592 int queue = iwl_mvm_tvqm_enable_txq(mvm, NULL, msta->sta_id, iwl_mvm_add_mcast_sta() local
3026 iwl_mvm_sta_tx_agg(struct iwl_mvm * mvm,struct ieee80211_sta * sta,int tid,u8 queue,bool start) iwl_mvm_sta_tx_agg() argument
3208 int queue, ret; iwl_mvm_sta_tx_agg_oper() local
4318 u16 queue; iwl_mvm_add_pasn_sta() local
[all...]
/freebsd/contrib/sendmail/contrib/
H A Dqtool.825 moves the queue files used by sendmail between queues. It uses the same
28 However, it should not be used when queue groups have been configured
29 to move queue files into directories to which they do not belong according
30 to the queue group selections made in the sendmail.cf file.
31 Unless you are absolutely sure you do not interfere with the queue group
32 selection mechanism, do not move queue files around.
36 will move any queue files as specified by \fIsource\fP into
38 queue control file, a queue file id, or a queue directory.
59 Evaluate \fIperl_expression\fP for each queue file as specified
61 queue file is moved. See below for more detail on \fIperl_expression\fP.
[all …]
/freebsd/contrib/llvm-project/lldb/source/Target/
H A DQueue.cpp1 //===-- Queue.cpp ---------------------------------------------------------===//
9 #include "lldb/Target/Queue.h"
18 Queue::Queue(ProcessSP process_sp, lldb::queue_id_t queue_id, in Queue() function in Queue
30 Queue::~Queue() = default;
32 queue_id_t Queue::GetID() { return m_queue_id; } in GetID()
34 const char *Queue::GetName() { in GetName()
38 uint32_t Queue::GetIndexID() { return m_queue_id; } in GetIndexID()
40 std::vector<lldb::ThreadSP> Queue::GetThreads() { in GetThreads()
53 void Queue::SetNumRunningWorkItems(uint32_t count) { in SetNumRunningWorkItems()
57 uint32_t Queue::GetNumRunningWorkItems() const { in GetNumRunningWorkItems()
[all …]

12345678910>>...118