Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 25 of 114) sorted by relevance

12345

/external/libnl/lib/netfilter/
Dqueue_obj.c33 struct nfnl_queue *queue = (struct nfnl_queue *) a; in nfnl_queue_dump() local
83 void nfnl_queue_get(struct nfnl_queue *queue) in nfnl_queue_get()
88 void nfnl_queue_put(struct nfnl_queue *queue) in nfnl_queue_put()
100 void nfnl_queue_set_group(struct nfnl_queue *queue, uint16_t group) in nfnl_queue_set_group()
106 int nfnl_queue_test_group(const struct nfnl_queue *queue) in nfnl_queue_test_group()
111 uint16_t nfnl_queue_get_group(const struct nfnl_queue *queue) in nfnl_queue_get_group()
116 void nfnl_queue_set_maxlen(struct nfnl_queue *queue, uint32_t maxlen) in nfnl_queue_set_maxlen()
122 int nfnl_queue_test_maxlen(const struct nfnl_queue *queue) in nfnl_queue_test_maxlen()
127 uint32_t nfnl_queue_get_maxlen(const struct nfnl_queue *queue) in nfnl_queue_get_maxlen()
132 void nfnl_queue_set_copy_mode(struct nfnl_queue *queue, enum nfnl_queue_copy_mode mode) in nfnl_queue_set_copy_mode()
[all …]
Dqueue.c111 static int nfnl_queue_build_request(const struct nfnl_queue *queue, in nfnl_queue_build_request()
160 int nfnl_queue_build_create_request(const struct nfnl_queue *queue, in nfnl_queue_build_create_request()
182 int nfnl_queue_create(struct nl_sock *nlh, const struct nfnl_queue *queue) in nfnl_queue_create()
193 int nfnl_queue_build_change_request(const struct nfnl_queue *queue, in nfnl_queue_build_change_request()
199 int nfnl_queue_change(struct nl_sock *nlh, const struct nfnl_queue *queue) in nfnl_queue_change()
210 int nfnl_queue_build_delete_request(const struct nfnl_queue *queue, in nfnl_queue_build_delete_request()
220 int nfnl_queue_delete(struct nl_sock *nlh, const struct nfnl_queue *queue) in nfnl_queue_delete()
/external/guava/guava-tests/test/com/google/common/collect/
DEvictingQueueTest.java44 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
70 EvictingQueue<String> queue = EvictingQueue.create(0); in testRemainingCapacity_maxSize0() local
75 EvictingQueue<String> queue = EvictingQueue.create(1); in testRemainingCapacity_maxSize1() local
82 EvictingQueue<String> queue = EvictingQueue.create(3); in testRemainingCapacity_maxSize3() local
93 EvictingQueue<String> queue = EvictingQueue.create(1); in testEvictingAfterOne() local
115 EvictingQueue<String> queue = EvictingQueue.create(3); in testEvictingAfterThree() local
139 EvictingQueue<String> queue = EvictingQueue.create(3); in testAddAll() local
164 EvictingQueue<String> queue = EvictingQueue.create(5); in testNullPointerExceptions() local
DMinMaxPriorityQueueTest.java53 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_simple() local
61 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_comparator() local
70 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize() local
79 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize_comparator() local
89 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_maximumSize() local
98 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_comparator_maximumSize() local
108 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize_maximumSize() local
121 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_withContents() local
130 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_comparator_withContents() local
140 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize_withContents() local
[all …]
/external/openfst/src/include/fst/script/
Dshortest-path.h72 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
79 delete queue; in ShortestPath() local
84 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
91 delete queue; in ShortestPath() local
96 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
103 delete queue; in ShortestPath() local
108 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
115 delete queue; in ShortestPath() local
120 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
127 delete queue; in ShortestPath() local
[all …]
Drmepsilon.h84 FifoQueue<StateId> queue; in RmEpsilonHelper() local
92 LifoQueue<StateId> queue; in RmEpsilonHelper() local
109 StateOrderQueue<StateId> queue; in RmEpsilonHelper() local
/external/squashfs-tools/squashfs-tools/
Dcaches-queues-lists.c41 struct queue *queue = malloc(sizeof(struct queue)); in queue_init() local
64 void queue_put(struct queue *queue, void *data) in queue_put()
81 void *queue_get(struct queue *queue) in queue_get()
100 int queue_empty(struct queue *queue) in queue_empty()
115 void queue_flush(struct queue *queue) in queue_flush()
126 void dump_queue(struct queue *queue) in dump_queue()
156 struct seq_queue *queue = malloc(sizeof(struct seq_queue)); in seq_queue_init() local
169 void seq_queue_put(struct seq_queue *queue, struct file_buffer *entry) in seq_queue_put()
188 struct file_buffer *seq_queue_get(struct seq_queue *queue) in seq_queue_get()
233 void seq_queue_flush(struct seq_queue *queue) in seq_queue_flush()
[all …]
Dcaches-queues-lists.h131 struct queue { struct
143 * struct describing seq_queues used to pass data between the read argument
Dunsquashfs.h153 struct queue { struct
154 int size;
155 int readp;
156 int writep;
157 pthread_mutex_t mutex;
158 pthread_cond_t empty;
159 pthread_cond_t full;
160 void **data;
/external/mesa3d/src/gallium/drivers/llvmpipe/
Dlp_scene_queue.c62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); in lp_scene_queue_create() local
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy()
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue()
110 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene) in lp_scene_enqueue()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DListenerCallQueueTest.java41 ListenerCallQueue<Object> queue = in testAddAndExecute() local
56 ListenerCallQueue<Object> queue = in testAddAndExecute_withExceptions() local
76 ListenerCallQueue<Object> queue = in testAddAndExecute_multithreaded() local
98 ListenerCallQueue<Object> queue = in testAddAndExecute_multithreaded_withThrowingRunnable() local
/external/guava/guava/src/com/google/common/collect/
DQueues.java69 ConcurrentLinkedQueue<E> queue = new ConcurrentLinkedQueue<E>(); in newConcurrentLinkedQueue() local
104 LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<E>(); in newLinkedBlockingQueue() local
136 PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<E>(); in newPriorityBlockingQueue() local
166 PriorityQueue<E> queue = new PriorityQueue<E>(); in newPriorityQueue() local
298 public static <E> Queue<E> synchronizedQueue(Queue<E> queue) { in synchronizedQueue()
/external/v8/benchmarks/
Drichards.js126 Scheduler.prototype.addIdleTask = function (id, priority, queue, count) { argument
136 Scheduler.prototype.addWorkerTask = function (id, priority, queue) { argument
146 Scheduler.prototype.addHandlerTask = function (id, priority, queue) { argument
156 Scheduler.prototype.addDeviceTask = function (id, priority, queue) { argument
167 Scheduler.prototype.addRunningTask = function (id, priority, queue, task) { argument
179 Scheduler.prototype.addTask = function (id, priority, queue, task) { argument
241 Scheduler.prototype.queue = function (packet) { method in Scheduler
260 function TaskControlBlock(link, id, priority, queue, task) { argument
527 Packet.prototype.addTo = function (queue) { argument
/external/v8/src/libplatform/
Dtask-queue-unittest.cc26 explicit TaskQueueThread(TaskQueue* queue) in TaskQueueThread()
39 TaskQueue queue; in TEST() local
49 TaskQueue queue; in TEST() local
/external/javassist/src/main/javassist/bytecode/analysis/
DAnalyzer.java133 IntQueue queue = new IntQueue(); in analyze() local
168 IntQueue queue, Executor executor) throws BadBytecode { in analyzeNextEntry()
276 private void merge(IntQueue queue, Frame frame, int target) { in merge()
292 private void mergeExceptionHandlers(IntQueue queue, MethodInfo method, int pos, Frame frame) { in mergeExceptionHandlers()
306 …private void mergeJsr(IntQueue queue, Frame frame, Subroutine sub, int pos, int next) throws BadBy… in mergeJsr()
347 …private void mergeLookupSwitch(IntQueue queue, int pos, CodeIterator iter, Frame frame) throws Bad… in mergeLookupSwitch()
361 …private void mergeRet(IntQueue queue, CodeIterator iter, int pos, Frame frame, Subroutine subrouti… in mergeRet()
400 …private void mergeTableSwitch(IntQueue queue, int pos, CodeIterator iter, Frame frame) throws BadB… in mergeTableSwitch()
/external/guava/guava/src/com/google/common/base/internal/
DFinalizer.java70 ReferenceQueue<Object> queue, in startFinalizer()
104 private final ReferenceQueue<Object> queue; field in Finalizer
112 ReferenceQueue<Object> queue, in Finalizer()
/external/dhcpcd/
Deloop.c54 int queue; member
113 add_q_timeout_tv(int queue, in add_q_timeout_tv()
174 add_q_timeout_sec(int queue, time_t when, void (*callback)(void *), void *arg) in add_q_timeout_sec()
187 v_delete_q_timeouts(int queue, void *arg, void (*callback)(void *), va_list v) in v_delete_q_timeouts()
217 delete_q_timeouts(int queue, void *arg, void (*callback)(void *), ...) in delete_q_timeouts()
227 delete_q_timeout(int queue, void (*callback)(void *), void *arg) in delete_q_timeout()
/external/doclava/src/com/google/doclava/
DMethodInfo.java47 private static void addInterfaces(ArrayList<ClassInfo> ifaces, ArrayList<ClassInfo> queue) { in addInterfaces()
52 addInterfaces(i.interfaces(), queue); in addInterfaces() local
67 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); in findOverriddenMethod() local
68 addInterfaces(containingClass().interfaces(), queue); in findOverriddenMethod() local
80 private static void addRealInterfaces(ArrayList<ClassInfo> ifaces, ArrayList<ClassInfo> queue) { in addRealInterfaces()
88 addInterfaces(i.realInterfaces(), queue); in addRealInterfaces() local
101 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); in findRealOverriddenMethod() local
106 addInterfaces(containingClass().realInterfaces(), queue); in findRealOverriddenMethod() local
134 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); in findSuperclassImplementation() local
139 addInterfaces(containingClass().realInterfaces(), queue); in findSuperclassImplementation() local
[all …]
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DMonitorBenchmark.java37 private BlockingQueue<String> queue; field in MonitorBenchmark
57 BlockingQueue<String> queue = this.queue; in addsAndRemoves() local
/external/jetty/src/java/org/eclipse/jetty/server/
DAsyncNCSARequestLog.java47 public AsyncNCSARequestLog(BlockingQueue<String> queue) in AsyncNCSARequestLog()
57 public AsyncNCSARequestLog(String filename,BlockingQueue<String> queue) in AsyncNCSARequestLog()
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/
DICUNotifier.java118 private final List<EventListener[]> queue = new ArrayList<EventListener[]>(); field in ICUNotifier.NotifyThread
127 public void queue(EventListener[] list) { in queue() method in ICUNotifier.NotifyThread
/external/deqp/framework/platform/android/
DtcuAndroidNativeActivity.cpp84 static void onInputQueueCreatedCallback (ANativeActivity* activity, AInputQueue* queue) in onInputQueueCreatedCallback()
89 static void onInputQueueDestroyedCallback (ANativeActivity* activity, AInputQueue* queue) in onInputQueueDestroyedCallback()
193 void NativeActivity::onInputQueueCreated (AInputQueue* queue) in onInputQueueCreated()
198 void NativeActivity::onInputQueueDestroyed (AInputQueue* queue) in onInputQueueDestroyed()
/external/libnl/src/
Dnf-queue.c26 struct nfnl_queue *queue; in alloc_queue() local
87 struct nfnl_queue *queue; in main() local
/external/mesa3d/src/gallium/drivers/svga/
Dsvga_state_tss.c77 struct bind_queue queue; in update_tss_binding() local
187 struct bind_queue queue; in svga_reemit_tss_bindings() local
294 struct ts_queue queue; in update_tss() local
/external/guava/guava/src/com/google/common/util/concurrent/
DUninterruptibles.java216 public static <E> E takeUninterruptibly(BlockingQueue<E> queue) { in takeUninterruptibly()
242 public static <E> void putUninterruptibly(BlockingQueue<E> queue, E element) { in putUninterruptibly()

12345