| /art/runtime/ |
| oat_file_manager.cc | 20 #include <queue>
222 // They are sorted lexicographically. Thus, the priority-queue must be a min-queue.
292 // Populate the queue of dex file and class pairs with the loaded and unloaded dex files.
293 std::priority_queue<DexFileAndClassPair> queue; local
296 queue.emplace(dex_files_loaded[i], &loaded_types[i], /*from_loaded_oat*/true);
301 queue.emplace(dex_files_unloaded[i], &unloaded_types[i], /*from_loaded_oat*/false);
305 // Now drain the queue.
308 while (!queue.empty()) {
310 DexFileAndClassPair compare_pop(queue.top())
[all...] |
| /developers/build/prebuilts/gradle/MediaRouter/Application/src/main/java/com/example/android/mediarouter/player/ |
| SessionManager.java | 31 * SessionManager manages a media session as a queue. It supports common
89 // If queue is empty, don't forget to call onPlaylistReady()!
350 List<PlaylistItem> queue = local
368 queue.add(item);
372 mPlaylist = queue;
404 String result = "Media Queue: ";
|
| /developers/samples/android/media/MediaRouter/Application/src/main/java/com/example/android/mediarouter/player/ |
| SessionManager.java | 31 * SessionManager manages a media session as a queue. It supports common
89 // If queue is empty, don't forget to call onPlaylistReady()!
350 List<PlaylistItem> queue = local
368 queue.add(item);
372 mPlaylist = queue;
404 String result = "Media Queue: ";
|
| /development/samples/browseable/MediaRouter/src/com.example.android.mediarouter/player/ |
| SessionManager.java | 31 * SessionManager manages a media session as a queue. It supports common
89 // If queue is empty, don't forget to call onPlaylistReady()!
350 List<PlaylistItem> queue = local
368 queue.add(item);
372 mPlaylist = queue;
404 String result = "Media Queue: ";
|
| /external/compiler-rt/lib/tsan/rtl/ |
| tsan_libdispatch_mac.cc | 33 dispatch_queue_t queue; member in struct:__tsan::__anon17216
81 dispatch_queue_t queue,
86 new_context->queue = queue;
98 bool is_queue_serial = context->queue && IsQueueSerial(context->queue);
99 uptr sync_ptr = (uptr)context->queue ?: context->non_queue_sync_object;
201 dispatch_queue_t queue, dispatch_block_t block) {
202 SCOPED_TSAN_INTERCEPTOR(dispatch_after, when, queue, block);
207 AllocContext(thr, pc, queue, heap_block, &invoke_and_release_block)
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/api/ |
| vktApiDeviceInitializationTests.cpp | 421 const VkQueue queue = getDeviceQueue(deviceDriver, *device, queueFamilyIndex, queueIndex); local
423 VK_CHECK(deviceDriver.queueWaitIdle(queue));
479 const VkQueue queue = getDeviceQueue(deviceDriver, devices[deviceNdx], queueFamilyIndex, queueIndex); local
481 VK_CHECK(deviceDriver.queueWaitIdle(queue));
640 const VkQueue queue = getDeviceQueue(deviceDriver, *device, queueFamilyIndex, queueIndex); local
643 TCU_CHECK(!!queue);
645 result = deviceDriver.queueWaitIdle(queue);
723 const VkQueue queue = getDeviceQueue(vkd, *device, queueFamilyIndex, queueIndex); local
725 VK_CHECK(vkd.queueWaitIdle(queue));
[all...] |
| vktApiSmokeTests.cpp | 334 const VkQueue queue = context.getUniversalQueue(); local
897 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, *fence));
946 const VkQueue queue = context.getUniversalQueue(); local
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/draw/ |
| vktDrawNegativeViewportHeightTests.cpp | 246 const VkQueue queue = m_context.getUniversalQueue(); local
316 VK_CHECK(vk.queueSubmit(queue, 1, &submitInfo, *fence));
323 return m_colorTargetImage->readSurface(queue, m_context.getDefaultAllocator(), VK_IMAGE_LAYOUT_GENERAL, zeroOffset, WIDTH, HEIGHT, VK_IMAGE_ASPECT_COLOR_BIT);
|
| vktDrawShaderDrawParametersTests.cpp | 328 const vk::VkQueue queue = m_context.getUniversalQueue(); local
341 VK_CHECK(m_vk.queueSubmit(queue, 1, &submitInfo, DE_NULL));
342 VK_CHECK(m_vk.queueWaitIdle(queue));
|
| /external/deqp/external/vulkancts/modules/vulkan/dynamic_state/ |
| vktDynamicStateRSTests.cpp | 403 const vk::VkQueue queue = m_context.getUniversalQueue(); local
440 m_vk.queueSubmit(queue, 1, &submitInfo, DE_NULL);
444 VK_CHECK(m_vk.queueWaitIdle(queue));
470 const tcu::ConstPixelBufferAccess renderedFrame = m_colorTargetImage->readSurface(queue, m_context.getDefaultAllocator(),
510 const vk::VkQueue queue = m_context.getUniversalQueue(); local
546 m_vk.queueSubmit(queue, 1, &submitInfo, DE_NULL);
550 VK_CHECK(m_vk.queueWaitIdle(queue));
576 const tcu::ConstPixelBufferAccess renderedFrame = m_colorTargetImage->readSurface(queue, m_context.getDefaultAllocator(),
616 const vk::VkQueue queue = m_context.getUniversalQueue(); local
652 m_vk.queueSubmit(queue, 1, &submitInfo, DE_NULL)
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/image/ |
| vktImageMultisampleLoadStoreTests.cpp | 247 const VkQueue queue = context.getUniversalQueue(); local
363 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
402 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
431 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
|
| vktImageSizeTests.cpp | 287 const VkQueue queue = m_context.getUniversalQueue(); local
320 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
|
| /external/deqp/external/vulkancts/modules/vulkan/protected_memory/ |
| vktProtectedMemUtils.cpp | 125 // Get a universal protected queue family index
138 continue; // Skip the queue family index if it does not support the surface
144 TCU_THROW(NotSupportedError, "No matching universal protected queue found");
260 vk::VkQueue queue = local
267 if (queue == DE_NULL)
268 TCU_THROW(TestError, "Unable to get a protected queue");
270 return queue;
504 vk::VkQueue queue,
539 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, fence));
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| vktSynchronizationOperationMultiQueueTests.cpp | 21 * \brief Synchronization primitive tests with multi queue
86 std::vector<VkQueue> queue; member in struct:vkt::synchronization::__anon17959::MultiQueues::QueueData
114 static_cast<deUint32>(it->second.queue.size()), //deUint32 queueCount;
140 for (int queueNdx = 0; queueNdx < static_cast<int>(it->second.queue.size()); ++queueNdx)
141 m_deviceDriver->getDeviceQueue(*m_logicalDevice, it->first, queueNdx, &it->second.queue[queueNdx]);
149 dataToPush.queue.resize(count);
181 const int writeSize = static_cast<int>(write->second.queue.size());
182 const int readSize = static_cast<int>(read->second.queue.size());
187 if (write->second.queue[writeNdx] != read->second.queue[readNdx]
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/tessellation/ |
| vktTessellationGeometryGridRenderTests.cpp | 534 const VkQueue queue = m_context.getUniversalQueue(); local
623 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
|
| vktTessellationGeometryPassthroughTests.cpp | 425 const VkQueue queue = m_context.getUniversalQueue(); local
594 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
|
| vktTessellationShaderInputOutputTests.cpp | 76 const VkQueue queue = context.getUniversalQueue(); local
192 submitCommandsAndWait(vk, device, queue, *cmdBuffer);
|
| /external/deqp/external/vulkancts/modules/vulkan/ycbcr/ |
| vktYCbCrUtil.cpp | 325 const VkQueue queue = getDeviceQueue(vkd, device, queueFamilyNdx, 0u); local
442 VK_CHECK(vkd.queueSubmit(queue, 1u, &submitInfo, *fence));
456 const VkQueue queue = getDeviceQueue(vkd, device, queueFamilyNdx, 0u); local
549 VK_CHECK(vkd.queueSubmit(queue, 1u, &submitInfo, *fence));
563 const VkQueue queue = getDeviceQueue(vkd, device, queueFamilyNdx, 0u); local
685 VK_CHECK(vkd.queueSubmit(queue, 1u, &submitInfo, *fence));
701 const VkQueue queue = getDeviceQueue(vkd, device, queueFamilyNdx, 0u); local
762 VK_CHECK(vkd.queueSubmit(queue, 1u, &submitInfo, *fence));
[all...] |
| vktYCbCrViewTests.cpp | 325 const VkQueue queue = getDeviceQueue(vkd, device, queueFamilyNdx, 0u); local
369 VK_CHECK(vkd.queueSubmit(queue, 1u, &submitInfo, *fence));
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| ForwardingQueueTest.java | 31 import java.util.Queue;
43 private final Queue<T> backingQueue;
45 StandardImplForwardingQueue(Queue<T> backingQueue) {
49 @Override protected Queue<T> delegate() {
106 private Queue<String> forward;
107 private Queue<String> queue; field in class:ForwardingQueueTest
116 @Override protected Queue<String> create(String[] elements) {
137 queue = createProxyInstance(Queue.class)
[all...] |
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| Analyzer.java | 133 IntQueue queue = new IntQueue(); local
141 queue.add(iter.next());
142 while (!queue.isEmpty()) {
143 analyzeNextEntry(method, iter, queue, executor);
168 IntQueue queue, Executor executor) throws BadBytecode {
169 int pos = queue.take();
185 mergeTableSwitch(queue, pos, iter, frame);
187 mergeLookupSwitch(queue, pos, iter, frame);
189 mergeRet(queue, iter, pos, frame, subroutine);
195 mergeJsr(queue, frames[pos], subroutines[target], pos, lookAhead(iter, pos))
[all...] |
| /external/libevent/test/ |
| regress_thread.c | 55 #include "sys/queue.h"
403 struct event_base *queue; member in struct:deferred_test_data
428 event_deferred_cb_schedule_(data->queue, &data->cbs[i]);
470 deferred_data[i].queue = base;
|
| /external/mesa3d/src/vulkan/wsi/ |
| wsi_common_wayland.c | 487 struct wl_event_queue * queue; member in struct:wsi_wl_swapchain
536 chain->queue);
558 chain->queue);
587 chain->queue);
599 wl_proxy_set_queue((struct wl_proxy *)frame, chain->queue);
663 wl_proxy_set_queue((struct wl_proxy *)image->buffer, chain->queue);
740 chain->queue = NULL;
749 chain->queue = wl_display_create_queue(chain->display->display);
750 if (!chain->queue) {
|
| /external/syslinux/gpxe/src/net/ |
| tcp.c | 83 /** Transmit queue */
84 struct list_head queue; member in struct:tcp_connection
232 INIT_LIST_HEAD ( &tcp->queue );
285 list_for_each_entry_safe ( iobuf, tmp, &tcp->queue, list ) {
306 if ( list_empty ( &tcp->queue ) ) {
341 * Process TCP transmit queue
346 * @v remove Remove data from queue
350 * transmit queue. Data will be copied into the @c dest I/O buffer
352 * queue.
361 list_for_each_entry_safe ( iobuf, tmp, &tcp->queue, list )
[all...] |
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| adaptive_shared_batch_scheduler.h | 22 #include <queue>
55 // queue or batch size.
158 // Adds queue (and its callback) to be managed by this scheduler.
161 std::unique_ptr<BatchScheduler<TaskType>>* queue);
190 // Removes queue from scheduler.
191 void RemoveQueue(const internal::ASBSQueue<TaskType>* queue);
288 // size or if the current batch is full and this queue's number of outstanding
298 // Notifies queue that a batch is about to be scheduled; the queue should not
319 ASBSBatch(ASBSQueue<TaskType>* queue, int64 creation_time_micros
324 ASBSQueue<TaskType>* queue() const { return queue_; } function in class:tensorflow::serving::internal::ASBSBatch
[all...] |
