| /toolchain/binutils/binutils-2.27/gold/ |
| workqueue.cc | 148 // Add a task to the end of a specific queue, or put it on the list
152 Workqueue::add_to_queue(Task_list* queue, Task* t, bool front)
168 queue->push_front(t);
170 queue->push_back(t);
176 // Add a task to the queue.
179 Workqueue::queue(Task* t) function in class:gold::Workqueue
184 // Queue a task which should run soon.
193 // Queue a task which should run next.
370 // 1) If T is not runnable, queue it on the appropriate token.
443 // them to the run queue and signal any other threads. This must b
[all...] |
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
| Engine.java | 95 MessageQueue queue = Looper.myQueue(); local
96 queue.addIdleHandler(new RefQueueIdleHandler(activeResources, resourceReferenceQueue));
275 private final ReferenceQueue<EngineResource<?>> queue; field in class:Engine.RefQueueIdleHandler
278 ReferenceQueue<EngineResource<?>> queue) {
280 this.queue = queue;
285 ResourceWeakReference ref = (ResourceWeakReference) queue.poll();
|
| /external/mp4parser/isoparser/src/main/java/com/googlecode/mp4parser/authoring/tracks/ |
| AACTrackImpl.java | 109 LinkedList<Integer> queue = new LinkedList<Integer>(); local
113 queue.add(size);
114 while (queue.size() > packetsPerSecond) {
115 queue.pop();
117 if (queue.size() == (int) packetsPerSecond) {
119 for (int j = 0 ; j < queue.size(); j++) {
120 currSize += queue.get(j);
122 double currBitrate = 8.0 * currSize / queue.size() * packetsPerSecond;
|
| /frameworks/support/media/api21/android/support/v4/media/session/ |
| MediaSessionCompatApi21.java | 127 ArrayList<MediaSession.QueueItem> queue = new ArrayList<MediaSession.QueueItem>(); local
129 queue.add((MediaSession.QueueItem) itemObj);
131 ((MediaSession) sessionObj).setQueue(queue);
|
| /external/guice/core/test/com/google/inject/ |
| MethodInterceptionTest.java | 37 import java.util.Queue;
332 final Queue<Runnable> queue = Lists.newLinkedList(); local
335 bindInterceptor(Matchers.any(), Matchers.any(), new CallLaterInterceptor(queue));
342 assertEquals(1, queue.size());
344 queue.remove().run();
349 private final Queue<Runnable> queue; field in class:MethodInterceptionTest.CallLaterInterceptor
351 public CallLaterInterceptor(Queue<Runnable> queue) {
[all...] |
| /cts/tests/autofillservice/src/android/autofillservice/cts/ |
| GridActivity.java | 137 final BlockingQueue<String> queue = new LinkedBlockingQueue<>(1); local
138 onCell(row, column, (c) -> queue.offer(c.getText().toString()));
139 final String text = queue.poll(100, TimeUnit.MILLISECONDS);
|
| /cts/tests/tests/graphics/jni/ |
| VulkanPreTransformTestHelpers.h | 41 VkQueue queue() const { return mQueue; } function in class:DeviceInfo
|
| VulkanTestHelpers.h | 29 // Provides basic set-up of a Vulkan device and queue.
36 VkQueue queue() { return mQueue; } function in class:VkInit
|
| /development/samples/USB/MissileLauncher/src/com/android/missilelauncher/ |
| MissileLauncherActivity.java | 222 // queue a request on the interrupt endpoint
223 request.queue(buffer, 1);
|
| /external/annotation-tools/asmx/src/org/objectweb/asm/tree/analysis/ |
| Analyzer.java | 69 private int[] queue; field in class:Analyzer
106 queue = new int[n];
156 int insn = queue[--top];
371 queue[top++] = insn;
413 queue[top++] = insn;
|
| /external/deqp/external/vulkancts/framework/vulkan/ |
| vkQueryUtil.cpp | 130 TCU_FAIL("Returned queue family count changes between queries");
432 VkQueue queue; local
434 vkd.getDeviceQueue(device, queueFamilyIndex, queueIndex, &queue);
436 return queue;
441 VkQueue queue; local
443 vkd.getDeviceQueue2(device, queueInfo, &queue);
445 return queue;
|
| /external/deqp/external/vulkancts/modules/vulkan/api/ |
| vktApiFillBufferTests.cpp | 140 const VkQueue queue = m_context.getUniversalQueue(); local
182 VK_CHECK(vk.queueSubmit(queue, 1, &submitInfo, *m_fence));
305 const VkQueue queue = m_context.getUniversalQueue(); local
347 VK_CHECK(vk.queueSubmit(queue, 1, &submitInfo, *m_fence));
|
| /external/deqp/external/vulkancts/modules/vulkan/draw/ |
| vktDrawIndirectTest.cpp | 220 const vk::VkQueue queue = m_context.getUniversalQueue(); local
422 VK_CHECK(m_vk.queueSubmit(queue, 1, &submitInfo, DE_NULL));
424 VK_CHECK(m_vk.queueWaitIdle(queue));
454 const tcu::ConstPixelBufferAccess renderedFrame = m_colorTargetImage->readSurface(queue, m_context.getDefaultAllocator(),
483 const vk::VkQueue queue = m_context.getUniversalQueue(); local
687 VK_CHECK(m_vk.queueSubmit(queue, 1, &submitInfo, DE_NULL));
689 VK_CHECK(m_vk.queueWaitIdle(queue));
692 VK_CHECK(m_vk.queueWaitIdle(queue));
722 const tcu::ConstPixelBufferAccess renderedFrame = m_colorTargetImage->readSurface(queue, m_context.getDefaultAllocator(),
|
| /external/deqp/external/vulkancts/modules/vulkan/pipeline/ |
| vktPipelineMultisampleBaseResolve.cpp | 48 const VkQueue queue = m_context.getUniversalQueue(); local
526 submitCommandsAndWait(deviceInterface, device, queue, *commandBuffer);
|
| /external/deqp/external/vulkancts/modules/vulkan/protected_memory/ |
| vktProtectedMemBlitImageTests.cpp | 122 const vk::VkQueue queue = ctx.getQueue(); local
334 VK_CHECK(queueSubmit(ctx, PROTECTION_ENABLED, queue, *cmdBuffer, *fence, ~0ull));
|
| vktProtectedMemBufferValidator.hpp | 181 const vk::VkQueue queue = ctx.getQueue(); local
281 VK_CHECK(queueSubmit(ctx, PROTECTION_ENABLED, queue, *resetCmdBuffer, *fence, ~0ull));
299 queueSubmitResult = queueSubmit(ctx, PROTECTION_ENABLED, queue, *cmdBuffer, *fence, oneSec);
|
| vktProtectedMemCopyBufferToImageTests.cpp | 123 const vk::VkQueue queue = ctx.getQueue(); local
303 VK_CHECK(queueSubmit(ctx, PROTECTION_ENABLED, queue, *cmdBuffer, *fence, ~0ull));
|
| vktProtectedMemCopyImageTests.cpp | 122 const vk::VkQueue queue = ctx.getQueue(); local
330 VK_CHECK(queueSubmit(ctx, PROTECTION_ENABLED, queue, *cmdBuffer, *fence, ~0ull));
|
| vktProtectedMemCopyImageToBufferTests.cpp | 125 const vk::VkQueue queue = ctx.getQueue(); local
320 VK_CHECK(queueSubmit(ctx, PROTECTION_ENABLED, queue, *cmdBuffer, *fence, ~0ull));
|
| vktProtectedMemFillUpdateCopyBufferTests.cpp | 146 const vk::VkQueue queue = ctx.getQueue(); local
360 VK_CHECK(queueSubmit(ctx, PROTECTION_ENABLED, queue, *cmdBuffer, *fence, ~0ull));
|
| /external/deqp/external/vulkancts/modules/vulkan/sparse_resources/ |
| vktSparseResourcesQueueBindSparseTests.cpp | 21 * \brief Queue bind sparse tests
71 const Queue* queue; member in struct:vkt::sparse::__anon17909::QueueSubmission
76 QueueSubmission makeSubmissionRegular (const Queue* queue,
98 submission.queue = queue;
104 QueueSubmission makeSubmissionSparse (const Queue* queue,
128 submission.queue = queue
178 const Queue* queue = &getQueue((VkQueueFlags)0, queueNdx); local
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| vktSynchronizationOperationSingleQueueTests.cpp | 21 * \brief Synchronization primitive tests with single queue
80 const VkQueue queue = m_context.getUniversalQueue(); local
109 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
135 const VkQueue queue = m_context.getUniversalQueue(); local
163 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
190 const VkQueue queue = m_context.getUniversalQueue(); local
244 VK_CHECK(vk.queueSubmit(queue, 2u, submitInfo, DE_NULL));
245 VK_CHECK(vk.queueWaitIdle(queue));
272 const VkQueue queue = m_context.getUniversalQueue(); local
293 submitCommandsAndWait(vk, device, queue, cmdBuffers[WRITE])
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/tessellation/ |
| vktTessellationCommonEdgeTests.cpp | 247 const VkQueue queue = context.getUniversalQueue(); local
446 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
|
| vktTessellationGeometryPointSizeTests.cpp | 309 const VkQueue queue = context.getUniversalQueue(); local
409 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
|
| vktTessellationMiscDrawTests.cpp | 131 const VkQueue queue = context.getUniversalQueue(); local
297 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
|
