| /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/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/mesa3d/src/util/ |
| D | u_queue.c | 69 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list()
79 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list()
229 struct util_queue *queue; member
236 struct util_queue *queue = ((struct thread_input*)input)->queue; in util_queue_thread_func() local
294 util_queue_init(struct util_queue *queue, in util_queue_init()
379 util_queue_killall_and_wait(struct util_queue *queue) in util_queue_killall_and_wait()
395 util_queue_destroy(struct util_queue *queue) in util_queue_destroy()
409 util_queue_add_job(struct util_queue *queue, in util_queue_add_job()
488 util_queue_drop_job(struct util_queue *queue, struct util_queue_fence *fence) in util_queue_drop_job()
527 util_queue_finish(struct util_queue *queue) in util_queue_finish()
[all …]
|
| D | u_vector.h | 57 u_vector_length(struct u_vector *queue) in u_vector_length()
78 u_vector_finish(struct u_vector *queue) in u_vector_finish()
83 #define u_vector_foreach(elem, queue) \ argument
|
| /external/volley/src/test/java/com/android/volley/ |
| D | RequestQueueTest.java | 53 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 0, mDelivery); in cancelAll_onlyCorrectTag() local
80 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 0, mDelivery); in add_notifiesListener() local
93 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 0, mDelivery); in finish_notifiesListener() local
107 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 0, mDelivery); in sendRequestEvent_notifiesListener() local
121 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 0, mDelivery); in removeRequestEventListener_removesListener() local
|
| D | RequestQueueIntegrationTest.java | 89 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestProcessedInCorrectOrder() local
124 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 3, mDelivery); in add_dedupeByCacheKey() local
152 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestFinishedListenerCanceled() local
169 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestFinishedListenerSuccess() local
186 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestFinishedListenerError() local
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | queue_op.cc | 45 Status QueueOp::VerifyResource(QueueInterface* queue) { in VerifyResource()
54 QueueInterface* queue; in ComputeAsync() local
88 void EnqueueOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
129 void EnqueueManyOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
166 void DequeueOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
209 void DequeueManyOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
282 void DequeueUpToOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
333 void QueueCloseOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
347 void QueueSizeOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
358 void QueueIsClosedOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync()
|
| /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/libchrome/base/task/sequence_manager/ |
| D | task_queue_selector.cc | 59 void TaskQueueSelector::AddQueue(internal::TaskQueueImpl* queue) { in AddQueue()
65 void TaskQueueSelector::RemoveQueue(internal::TaskQueueImpl* queue) { in RemoveQueue()
72 void TaskQueueSelector::EnableQueue(internal::TaskQueueImpl* queue) { in EnableQueue()
80 void TaskQueueSelector::DisableQueue(internal::TaskQueueImpl* queue) { in DisableQueue()
86 void TaskQueueSelector::SetQueuePriority(internal::TaskQueueImpl* queue, in SetQueuePriority()
115 internal::TaskQueueImpl* queue, in AddQueue()
128 internal::TaskQueueImpl* queue, in ChangeSetIndex()
143 internal::TaskQueueImpl* queue) { in RemoveQueue()
|
| D | time_domain.cc | 44 void TimeDomain::UnregisterQueue(internal::TaskQueueImpl* queue) { in UnregisterQueue()
52 internal::TaskQueueImpl* queue, in SetNextWakeUpForQueue()
107 internal::TaskQueueImpl* queue = delayed_wake_up_queue_.Min().queue; in WakeUpReadyDelayedQueues() local
|
| /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/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/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | WriteQueueTest.java | 114 WriteQueue queue = new WriteQueue(channel); in singleWriteShouldWork() local
123 WriteQueue queue = new WriteQueue(channel); in multipleWritesShouldBeBatched() local
135 WriteQueue queue = new WriteQueue(channel); in maxWritesBeforeFlushShouldBeEnforced() local
148 final WriteQueue queue = new WriteQueue(channel); in concurrentWriteAndFlush() 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/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/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/perfetto/src/base/ |
| D | circular_queue_unittest.cc | 28 CircularQueue<int> queue(/*initial_capacity=*/1); in TEST() local
92 CircularQueue<uint64_t> queue; in TEST() local
105 CircularQueue<int> queue; in TEST() local
140 CircularQueue<size_t> queue(capacity); in TEST() local
222 CircularQueue<Checker> queue(/*initial_capacity=*/2); in TEST() local
241 CircularQueue<Checker> queue(/*initial_capacity=*/1); in TEST() local
|
| /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/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | TrafficControlProxy.java | 139 private final MessageQueue queue; field in TrafficControlProxy.Reader
141 Reader(MessageQueue queue) { in Reader()
162 private final MessageQueue queue; field in TrafficControlProxy.Writer
164 Writer(MessageQueue queue) { in Writer()
189 BlockingQueue<Message> queue = new DelayQueue<Message>(); field in TrafficControlProxy.MessageQueue
|