| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | EvictingQueueTest.java | 44 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
|
| D | MinMaxPriorityQueueTest.java | 53 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/libnl/lib/netfilter/ |
| D | queue_obj.c | 33 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 …]
|
| D | queue.c | 111 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/webrtc/webrtc/common_audio/ |
| D | swap_queue_unittest.cc | 46 SwapQueue<std::vector<int>> queue(2, i); in TEST() local
59 SwapQueue<int> queue(2); in TEST() local
81 SwapQueue<int> queue(2); in TEST() local
90 SwapQueue<int> queue(2); in TEST() local
114 queue(2, template_element); in TEST() local
126 SwapQueue<std::vector<int>, LengthVerifierFunctor> queue(2, template_element, in TEST() local
140 SwapQueue<int, decltype(minus_2_verifier)> queue(2, minus_2_verifier); in TEST() local
154 queue(2, template_element); in TEST() local
164 queue(2, template_element); in TEST() local
180 SwapQueue<std::vector<int16_t>> queue(kQueueSize, in TEST() local
[all …]
|
| /external/mesa3d/src/gallium/auxiliary/util/ |
| D | u_queue.c | 66 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list()
76 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list()
113 struct util_queue *queue; member
119 struct util_queue *queue = ((struct thread_input*)input)->queue; in PIPE_THREAD_ROUTINE() local
175 util_queue_init(struct util_queue *queue, in util_queue_init()
242 util_queue_killall_and_wait(struct util_queue *queue) in util_queue_killall_and_wait()
258 util_queue_destroy(struct util_queue *queue) in util_queue_destroy()
288 util_queue_add_job(struct util_queue *queue, in util_queue_add_job()
|
| /external/squashfs-tools/squashfs-tools/ |
| D | caches-queues-lists.c | 41 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 …]
|
| D | caches-queues-lists.h | 131 struct queue { struct
143 * struct describing seq_queues used to pass data between the read argument
|
| /external/volley/src/test/java/com/android/volley/ |
| D | RequestQueueIntegrationTest.java | 87 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestProcessedInCorrectOrder() local
119 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 3, mDelivery); in add_dedupeByCacheKey() local
144 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestFinishedListenerCanceled() local
160 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestFinishedListenerSuccess() local
176 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestFinishedListenerError() local
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/impl/ |
| D | select_reactor.hpp | 25 void select_reactor::add_timer_queue(timer_queue<Time_Traits>& queue) in add_timer_queue()
32 void select_reactor::remove_timer_queue(timer_queue<Time_Traits>& queue) in remove_timer_queue()
38 void select_reactor::schedule_timer(timer_queue<Time_Traits>& queue, in schedule_timer()
57 std::size_t select_reactor::cancel_timer(timer_queue<Time_Traits>& queue, in cancel_timer()
|
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_scene_queue.c | 62 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/ |
| D | ListenerCallQueueTest.java | 43 ListenerCallQueue<Object> queue = in testAddAndExecute() local
58 ListenerCallQueue<Object> queue = in testAddAndExecute_withExceptions() local
78 ListenerCallQueue<Object> queue = in testAddAndExecute_multithreaded() local
100 ListenerCallQueue<Object> queue = in testAddAndExecute_multithreaded_withThrowingRunnable() local
|
| /external/mesa3d/src/vulkan/wsi/ |
| D | wsi_common_queue.h | 38 wsi_queue_init(struct wsi_queue *queue, int length) in wsi_queue_init()
82 wsi_queue_destroy(struct wsi_queue *queue) in wsi_queue_destroy()
90 wsi_queue_push(struct wsi_queue *queue, uint32_t index) in wsi_queue_push()
109 wsi_queue_pull(struct wsi_queue *queue, uint32_t *index, uint64_t timeout) in wsi_queue_pull()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | queue_ops.cc | 35 QueueInterface* queue; in ComputeAsync() local
83 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
135 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
185 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
238 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
324 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
388 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
413 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
434 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
|
| D | queue_op.h | 57 Status VerifyResource(QueueInterface* queue) override { in VerifyResource()
68 Status CreateTypedQueue(TypedQueue* queue, QueueInterface** ret) { in CreateTypedQueue()
|
| /external/v8/benchmarks/ |
| D | richards.js | 126 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/guava/guava/src/com/google/common/collect/ |
| D | Queues.java | 98 ConcurrentLinkedQueue<E> queue = new ConcurrentLinkedQueue<E>(); in newConcurrentLinkedQueue() local
170 LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<E>(); in newLinkedBlockingQueue() local
202 PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<E>(); in newPriorityBlockingQueue() local
232 PriorityQueue<E> queue = new PriorityQueue<E>(); in newPriorityQueue() local
363 public static <E> Queue<E> synchronizedQueue(Queue<E> queue) { in synchronizedQueue()
|
| /external/guava/guava/src/com/google/common/base/internal/ |
| D | Finalizer.java | 70 ReferenceQueue<Object> queue, in startFinalizer()
104 private final ReferenceQueue<Object> queue; field in Finalizer
112 ReferenceQueue<Object> queue, in Finalizer()
|
| /external/mesa3d/src/util/ |
| D | u_vector.h | 58 u_vector_length(struct u_vector *queue) in u_vector_length()
79 u_vector_finish(struct u_vector *queue) in u_vector_finish()
84 #define u_vector_foreach(elem, queue) \ argument
|
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| D | Analyzer.java | 133 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/libchrome/base/threading/ |
| D | thread_collision_warner_unittest.cc | 152 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {} in TEST()
165 NonThreadSafeQueue queue(local_reporter); in TEST() local
209 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {} in TEST()
222 NonThreadSafeQueue queue(local_reporter); in TEST() local
268 QueueUser(NonThreadSafeQueue* queue, base::Lock* lock) in TEST()
288 NonThreadSafeQueue queue(local_reporter); in TEST() local
341 QueueUser(NonThreadSafeQueue* queue, base::Lock* lock) in TEST()
365 NonThreadSafeQueue queue(local_reporter); in TEST() local
|
| /external/syslinux/gpxe/src/drivers/net/ath5k/ |
| D | ath5k_dma.c | 127 int ath5k_hw_start_tx_dma(struct ath5k_hw *ah, unsigned int queue) in ath5k_hw_start_tx_dma()
167 int ath5k_hw_stop_tx_dma(struct ath5k_hw *ah, unsigned int queue) in ath5k_hw_stop_tx_dma()
261 u32 ath5k_hw_get_txdp(struct ath5k_hw *ah, unsigned int queue) in ath5k_hw_get_txdp()
292 int ath5k_hw_set_txdp(struct ath5k_hw *ah, unsigned int queue, u32 phys_addr) in ath5k_hw_set_txdp()
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MonitorBenchmark.java | 37 private BlockingQueue<String> queue; field in MonitorBenchmark
57 BlockingQueue<String> queue = this.queue; in addsAndRemoves() local
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_close/ |
| D | 2-1.c | 97 mqd_t queue; in parent_process() local
157 mqd_t queue; in child_process() local
206 mqd_t queue; in open_queue() local
|
| /external/autotest/scheduler/ |
| D | thread_lib_unittest.py | 82 def waiting_func(queue): argument
88 def exception_func(queue): argument
|