| /external/mesa3d/src/util/ |
| D | u_queue.c | 35 static void util_queue_killall_and_wait(struct util_queue *queue);
69 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list() argument
74 LIST_ADD(&queue->head, &queue_list); in add_to_atexit_list()
79 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list() argument
85 if (iter == 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
241 if (queue->name) { in util_queue_thread_func()
243 util_snprintf(name, sizeof(name), "%s:%i", queue->name, thread_index); in util_queue_thread_func()
250 mtx_lock(&queue->lock); in util_queue_thread_func()
[all …]
|
| D | u_vector.h | 52 int u_vector_init(struct u_vector *queue, uint32_t element_size, uint32_t size);
53 void *u_vector_add(struct u_vector *queue);
54 void *u_vector_remove(struct u_vector *queue);
57 u_vector_length(struct u_vector *queue) in u_vector_length() argument
59 return (queue->head - queue->tail) / queue->element_size; in u_vector_length()
78 u_vector_finish(struct u_vector *queue) in u_vector_finish() argument
80 free(queue->data); in u_vector_finish()
83 #define u_vector_foreach(elem, queue) \ argument
84 STATIC_ASSERT(__builtin_types_compatible_p(__typeof__(queue), struct u_vector *)); \
85 for (uint32_t __u_vector_offset = (queue)->tail; \
[all …]
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | EvictingQueueTest.java | 44 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
45 assertEquals(0, queue.size()); in testCreateWithZeroSize()
47 assertTrue(queue.add("hi")); in testCreateWithZeroSize()
48 assertEquals(0, queue.size()); in testCreateWithZeroSize()
50 assertTrue(queue.offer("hi")); in testCreateWithZeroSize()
51 assertEquals(0, queue.size()); in testCreateWithZeroSize()
53 assertFalse(queue.remove("hi")); in testCreateWithZeroSize()
54 assertEquals(0, queue.size()); in testCreateWithZeroSize()
57 queue.element(); in testCreateWithZeroSize()
61 assertNull(queue.peek()); in testCreateWithZeroSize()
[all …]
|
| /external/libchrome/base/synchronization/ |
| D | condition_variable_unittest.cc | 259 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F() local
266 base::AutoLock auto_lock(*queue.lock()); in TEST_F()
267 while (!queue.EveryIdWasAllocated()) in TEST_F()
268 queue.all_threads_have_ids()->Wait(); in TEST_F()
273 queue.SpinUntilAllThreadsAreWaiting(); in TEST_F()
277 base::AutoLock auto_lock(*queue.lock()); in TEST_F()
278 EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments()); in TEST_F()
279 EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks()); in TEST_F()
280 EXPECT_EQ(0, queue.task_count()); in TEST_F()
281 EXPECT_EQ(0, queue.GetMaxCompletionsByWorkerThread()); in TEST_F()
[all …]
|
| /external/squashfs-tools/squashfs-tools/ |
| D | caches-queues-lists.c | 39 struct queue *queue_init(int size) in queue_init()
41 struct queue *queue = malloc(sizeof(struct queue)); in queue_init() local
43 if(queue == NULL) in queue_init()
50 queue->data = malloc(sizeof(void *) * (size + 1)); in queue_init()
51 if(queue->data == NULL) in queue_init()
54 queue->size = size + 1; in queue_init()
55 queue->readp = queue->writep = 0; in queue_init()
56 pthread_mutex_init(&queue->mutex, NULL); in queue_init()
57 pthread_cond_init(&queue->empty, NULL); in queue_init()
58 pthread_cond_init(&queue->full, NULL); in queue_init()
[all …]
|
| /external/perfetto/src/base/ |
| D | circular_queue_unittest.cc | 28 CircularQueue<int> queue(/*initial_capacity=*/1); in TEST() local
29 ASSERT_EQ(queue.size(), 0u); in TEST()
30 queue.emplace_back(101); in TEST()
31 ASSERT_EQ(queue.size(), 1u); in TEST()
32 queue.emplace_back(102); in TEST()
33 queue.emplace_back(103); in TEST()
34 queue.emplace_back(104); in TEST()
35 ASSERT_EQ(queue.size(), 4u); in TEST()
37 auto it = queue.begin(); in TEST()
42 ASSERT_EQ(it, queue.end()); in TEST()
[all …]
|
| /external/antlr/runtime/ObjC/Framework/test/runtime/misc/ |
| D | FastQueueTest.m | 18 FastQueue *queue = [[FastQueue newFastQueue] retain];
19 STAssertNotNil(queue, @"Queue was not created and was nil");
20 [queue release];
25 FastQueue *queue = [[FastQueue newFastQueue] retain];
26 STAssertNotNil(queue, @"Queue was not created and was nil");
27 [queue addObject:@"My String"];
28 …STAssertTrue([[queue objectAtIndex:0] isKindOfClass:[NSString class]], @"First object is not a NSS…
29 STAssertEquals([queue objectAtIndex:0], @"My String", @"Object at index zero is invalid");
30 STAssertTrue([queue size] == 1, @"Queue is the wrong size: %d", [queue size]);
31 [queue release];
[all …]
|
| /external/libnl/lib/netfilter/ |
| D | queue_obj.c | 33 struct nfnl_queue *queue = (struct nfnl_queue *) a; in nfnl_queue_dump() local
38 if (queue->ce_mask & QUEUE_ATTR_GROUP) in nfnl_queue_dump()
39 nl_dump(p, "group=%u ", queue->queue_group); in nfnl_queue_dump()
41 if (queue->ce_mask & QUEUE_ATTR_MAXLEN) in nfnl_queue_dump()
42 nl_dump(p, "maxlen=%u ", queue->queue_maxlen); in nfnl_queue_dump()
44 if (queue->ce_mask & QUEUE_ATTR_COPY_MODE) in nfnl_queue_dump()
46 nfnl_queue_copy_mode2str(queue->queue_copy_mode, in nfnl_queue_dump()
49 if (queue->ce_mask & QUEUE_ATTR_COPY_RANGE) in nfnl_queue_dump()
50 nl_dump(p, "copy_range=%u ", queue->queue_copy_range); in nfnl_queue_dump()
83 void nfnl_queue_get(struct nfnl_queue *queue) in nfnl_queue_get() argument
[all …]
|
| D | queue.c | 111 static int nfnl_queue_build_request(const struct nfnl_queue *queue, in nfnl_queue_build_request() argument
116 if (!nfnl_queue_test_group(queue)) in nfnl_queue_build_request()
120 0, nfnl_queue_get_group(queue)); in nfnl_queue_build_request()
124 if (nfnl_queue_test_maxlen(queue) && in nfnl_queue_build_request()
126 htonl(nfnl_queue_get_maxlen(queue))) < 0) in nfnl_queue_build_request()
132 if (nfnl_queue_test_copy_mode(queue)) { in nfnl_queue_build_request()
135 switch (nfnl_queue_get_copy_mode(queue)) { in nfnl_queue_build_request()
146 params.copy_range = htonl(nfnl_queue_get_copy_range(queue)); in nfnl_queue_build_request()
160 int nfnl_queue_build_create_request(const struct nfnl_queue *queue, in nfnl_queue_build_create_request() argument
166 if ((err = nfnl_queue_build_request(queue, result)) < 0) in nfnl_queue_build_create_request()
[all …]
|
| /external/webrtc/webrtc/common_audio/ |
| D | swap_queue_unittest.cc | 46 SwapQueue<std::vector<int>> queue(2, i); in TEST() local
48 EXPECT_TRUE(queue.Insert(&i)); in TEST()
50 EXPECT_TRUE(queue.Insert(&i)); in TEST()
52 EXPECT_TRUE(queue.Remove(&i)); in TEST()
54 EXPECT_TRUE(queue.Remove(&i)); in TEST()
59 SwapQueue<int> queue(2); in TEST() local
63 EXPECT_TRUE(queue.Insert(&i)); in TEST()
65 EXPECT_TRUE(queue.Insert(&i)); in TEST()
70 EXPECT_FALSE(queue.Insert(&i)); in TEST()
74 EXPECT_TRUE(queue.Remove(&i)); in TEST()
[all …]
|
| /external/iptables/extensions/ |
| D | libxt_NFQUEUE.t | 3 -j NFQUEUE --queue-num 0;=;OK
4 -j NFQUEUE --queue-num 65535;=;OK
5 -j NFQUEUE --queue-num 65536;;FAIL
6 -j NFQUEUE --queue-num -1;;FAIL
8 # ERROR: cannot load: iptables -A INPUT -j NFQUEUE --queue-balance 0:65535
9 # -j NFQUEUE --queue-balance 0:65535;=;OK
10 -j NFQUEUE --queue-balance 0:65536;;FAIL
11 -j NFQUEUE --queue-balance -1:65535;;FAIL
12 -j NFQUEUE --queue-num 10 --queue-bypass;=;OK
13 -j NFQUEUE --queue-balance 0:6 --queue-cpu-fanout --queue-bypass;-j NFQUEUE --queue-balance 0:6 --q…
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ListenerCallQueueTest.java | 43 ListenerCallQueue<Object> queue = in testAddAndExecute() local
47 queue.add(incrementingCallback(counter, 1)); in testAddAndExecute()
48 queue.add(incrementingCallback(counter, 2)); in testAddAndExecute()
49 queue.add(incrementingCallback(counter, 3)); in testAddAndExecute()
50 queue.add(incrementingCallback(counter, 4)); in testAddAndExecute()
52 queue.execute(); in testAddAndExecute()
58 ListenerCallQueue<Object> queue = in testAddAndExecute_withExceptions() local
62 queue.add(incrementingCallback(counter, 1)); in testAddAndExecute_withExceptions()
63 queue.add(THROWING_CALLBACK); in testAddAndExecute_withExceptions()
64 queue.add(incrementingCallback(counter, 2)); in testAddAndExecute_withExceptions()
[all …]
|
| /external/v8/benchmarks/ |
| D | richards.js | 51 var queue = new Packet(null, ID_WORKER, KIND_WORK);
52 queue = new Packet(queue, ID_WORKER, KIND_WORK);
53 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
55 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
58 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
60 queue = new Packet(null, ID_DEVICE_B, KIND_DEVICE);
61 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
62 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
[all …]
|
| /external/mesa3d/src/vulkan/wsi/ |
| D | wsi_common_queue.h | 38 wsi_queue_init(struct wsi_queue *queue, int length) in wsi_queue_init() argument
46 ret = u_vector_init(&queue->vector, sizeof(uint32_t), in wsi_queue_init()
60 ret = pthread_cond_init(&queue->cond, &condattr); in wsi_queue_init()
64 ret = pthread_mutex_init(&queue->mutex, NULL); in wsi_queue_init()
72 pthread_cond_destroy(&queue->cond); in wsi_queue_init()
76 u_vector_finish(&queue->vector); in wsi_queue_init()
82 wsi_queue_destroy(struct wsi_queue *queue) in wsi_queue_destroy() argument
84 u_vector_finish(&queue->vector); in wsi_queue_destroy()
85 pthread_mutex_destroy(&queue->mutex); in wsi_queue_destroy()
86 pthread_cond_destroy(&queue->cond); in wsi_queue_destroy()
[all …]
|
| /external/libchrome/base/task/sequence_manager/ |
| D | task_queue_selector.cc | 59 void TaskQueueSelector::AddQueue(internal::TaskQueueImpl* queue) { in AddQueue() argument
61 DCHECK(queue->IsQueueEnabled()); in AddQueue()
62 prioritizing_selector_.AddQueue(queue, TaskQueue::kNormalPriority); in AddQueue()
65 void TaskQueueSelector::RemoveQueue(internal::TaskQueueImpl* queue) { in RemoveQueue() argument
67 if (queue->IsQueueEnabled()) { in RemoveQueue()
68 prioritizing_selector_.RemoveQueue(queue); in RemoveQueue()
72 void TaskQueueSelector::EnableQueue(internal::TaskQueueImpl* queue) { in EnableQueue() argument
74 DCHECK(queue->IsQueueEnabled()); in EnableQueue()
75 prioritizing_selector_.AddQueue(queue, queue->GetQueuePriority()); in EnableQueue()
77 task_queue_selector_observer_->OnTaskQueueEnabled(queue); in EnableQueue()
[all …]
|
| /external/mesa3d/src/gallium/drivers/svga/ |
| D | svga_state_tss.c | 82 struct bind_queue *queue) in emit_tex_binding_unit() argument
130 queue->bind[queue->bind_count].unit = unit; in emit_tex_binding_unit()
131 queue->bind[queue->bind_count].view = view; in emit_tex_binding_unit()
132 queue->bind_count++; in emit_tex_binding_unit()
150 struct bind_queue queue; in update_tss_binding() local
155 queue.bind_count = 0; in update_tss_binding()
163 &queue); in update_tss_binding()
176 &queue); in update_tss_binding()
181 if (queue.bind_count) { in update_tss_binding()
185 queue.bind_count) != PIPE_OK) in update_tss_binding()
[all …]
|
| /external/volley/src/test/java/com/android/volley/ |
| D | RequestQueueIntegrationTest.java | 89 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestProcessedInCorrectOrder() local
90 queue.addRequestFinishedListener(mMockListener); in add_requestProcessedInCorrectOrder()
91 queue.add(lowerPriorityReq); in add_requestProcessedInCorrectOrder()
92 queue.add(higherPriorityReq); in add_requestProcessedInCorrectOrder()
93 queue.start(); in add_requestProcessedInCorrectOrder()
101 queue.stop(); in add_requestProcessedInCorrectOrder()
124 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 3, mDelivery); in add_dedupeByCacheKey() local
125 queue.addRequestFinishedListener(mMockListener); in add_dedupeByCacheKey()
126 queue.add(req1); in add_dedupeByCacheKey()
127 queue.add(req2); in add_dedupeByCacheKey()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | queue_op.cc | 45 Status QueueOp::VerifyResource(QueueInterface* queue) { in VerifyResource() argument
46 return queue->MatchesNodeDef(def()); in VerifyResource()
54 QueueInterface* queue; in ComputeAsync() local
57 ctx, LookupResource(ctx, HandleFromInput(ctx, 0), &queue), callback); in ComputeAsync()
59 OP_REQUIRES_OK_ASYNC(ctx, GetResourceFromContext(ctx, "handle", &queue), in ComputeAsync()
62 ComputeAsync(ctx, queue, [callback, queue]() { in ComputeAsync()
63 queue->Unref(); in ComputeAsync()
88 void EnqueueOp::ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync() argument
96 for (DataType dt : queue->component_dtypes()) { in ComputeAsync()
109 OP_REQUIRES_OK_ASYNC(ctx, queue->ValidateTuple(tuple), callback); in ComputeAsync()
[all …]
|
| /external/tensorflow/tensorflow/lite/experimental/micro/examples/micro_speech/ |
| D | recognize_commands_test.cc | 27 PreviousResultsQueue queue(error_reporter); in TF_LITE_MICRO_TEST() local
28 TF_LITE_MICRO_EXPECT_EQ(0, queue.size()); in TF_LITE_MICRO_TEST()
31 queue.push_back({0, scores_a}); in TF_LITE_MICRO_TEST()
32 TF_LITE_MICRO_EXPECT_EQ(1, queue.size()); in TF_LITE_MICRO_TEST()
33 TF_LITE_MICRO_EXPECT_EQ(0, queue.front().time_); in TF_LITE_MICRO_TEST()
34 TF_LITE_MICRO_EXPECT_EQ(0, queue.back().time_); in TF_LITE_MICRO_TEST()
37 queue.push_back({1, scores_b}); in TF_LITE_MICRO_TEST()
38 TF_LITE_MICRO_EXPECT_EQ(2, queue.size()); in TF_LITE_MICRO_TEST()
39 TF_LITE_MICRO_EXPECT_EQ(0, queue.front().time_); in TF_LITE_MICRO_TEST()
40 TF_LITE_MICRO_EXPECT_EQ(1, queue.back().time_); in TF_LITE_MICRO_TEST()
[all …]
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-queue.rst | 10 :mod:`queue` module. Although asyncio queues are not thread-safe,
14 use :func:`asyncio.wait_for` function to do queue operations with a
24 A first in, first out (FIFO) queue.
26 If *maxsize* is less than or equal to zero, the queue size is
28 ``await put()`` blocks when the queue reaches *maxsize*
31 Unlike the standard library threading :mod:`queue`, the size of
32 the queue is always known and can be returned by calling the
39 Number of items allowed in the queue.
43 Return ``True`` if the queue is empty, ``False`` otherwise.
47 Return ``True`` if there are :attr:`maxsize` items in the queue.
[all …]
|
| /external/tensorflow/tensorflow/contrib/coder/kernels/ |
| D | pmf_to_cdf_op.cc | 153 std::vector<PenaltyItem> queue; in PerShard() local
154 queue.reserve(cdf.size()); in PerShard()
156 queue.emplace_back(&cdf[i], pmf[i]); in PerShard()
159 std::sort(queue.begin(), queue.end()); in PerShard()
161 queue[0].Decrease(); in PerShard()
165 std::next(queue.begin()), queue.end(), in PerShard()
166 [&queue](const PenaltyItem& rhs) { return queue[0] < rhs; }); in PerShard()
167 std::rotate(queue.begin(), std::next(queue.begin()), iter); in PerShard()
170 std::vector<GainItem> queue; in PerShard() local
171 queue.reserve(cdf.size()); in PerShard()
[all …]
|
| /external/perfetto/src/trace_processor/ |
| D | trace_sorter.cc | 95 auto& queue = queues_[i]; in SortAndExtractEventsBeyondWindow() local
96 if (queue.events_.empty()) in SortAndExtractEventsBeyondWindow()
98 PERFETTO_DCHECK(queue.min_ts_ >= global_min_ts_); in SortAndExtractEventsBeyondWindow()
99 PERFETTO_DCHECK(queue.max_ts_ <= global_max_ts_); in SortAndExtractEventsBeyondWindow()
100 if (queue.min_ts_ < min_queue_ts[0]) { in SortAndExtractEventsBeyondWindow()
102 min_queue_ts[0] = queue.min_ts_; in SortAndExtractEventsBeyondWindow()
105 } else if (queue.min_ts_ < min_queue_ts[1]) { in SortAndExtractEventsBeyondWindow()
106 min_queue_ts[1] = queue.min_ts_; in SortAndExtractEventsBeyondWindow()
115 Queue& queue = queues_[min_queue_idx]; in SortAndExtractEventsBeyondWindow() local
116 auto& events = queue.events_; in SortAndExtractEventsBeyondWindow()
[all …]
|
| /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
63 if (!queue) in lp_scene_queue_create()
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE * in lp_scene_queue_create()
68 if (queue->ring == NULL) in lp_scene_queue_create()
71 return queue; in lp_scene_queue_create()
74 FREE(queue); in lp_scene_queue_create()
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy() argument
83 util_ringbuffer_destroy(queue->ring); in lp_scene_queue_destroy()
84 FREE(queue); in lp_scene_queue_destroy()
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue() argument
[all …]
|
| /external/wayland/tests/ |
| D | queue-test.c | 111 struct wl_event_queue *queue; in client_test_multiple_queues() local
119 queue = wl_display_create_queue(state.display); in client_test_multiple_queues()
120 assert(queue); in client_test_multiple_queues()
126 wl_proxy_set_queue((struct wl_proxy *) callback1, queue); in client_test_multiple_queues()
131 wl_proxy_set_queue((struct wl_proxy *) state.callback2, queue); in client_test_multiple_queues()
136 ret = wl_display_dispatch_queue(state.display, queue); in client_test_multiple_queues()
138 wl_event_queue_destroy(queue); in client_test_multiple_queues()
160 struct wl_event_queue *queue; in client_test_queue_roundtrip() local
170 queue = wl_display_create_queue(display); in client_test_queue_roundtrip()
171 assert(queue); in client_test_queue_roundtrip()
[all …]
|
| /external/libcxx/include/ |
| D | queue | 2 //===--------------------------- queue ------------------------------------===//
15 queue synopsis
21 class queue
34 queue() = default;
35 ~queue() = default;
37 queue(const queue& q) = default;
38 queue(queue&& q) = default;
40 queue& operator=(const queue& q) = default;
41 queue& operator=(queue&& q) = default;
43 explicit queue(const container_type& c);
[all …]
|