/external/autotest/server/cros/ |
H A D | queue_barrier.py | 5 from multiprocessing import Queue, queues namespace 52 except queues.Empty: 72 except queues.Empty:
|
/external/ltp/testcases/kernel/syscalls/ipc/msgget/ |
H A D | msgget03.c | 21 * message queues. 36 static int *queues; variable 61 queues = SAFE_MALLOC(maxmsgs * sizeof(int)); 64 queues[num] = -1; 68 queues[num] = res; 71 tst_res(TINFO, "The maximum number of message queues (%d) reached", 79 if (!queues) 83 if (queues[num] != -1) 84 SAFE_MSGCTL(queues[num], IPC_RMID, NULL); 87 free(queues); [all...] |
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | ListenerCallQueue.java | 51 /** Helper method to add this callback to all the queues. */ 52 void enqueueOn(Iterable<ListenerCallQueue<L>> queues) { argument 53 for (ListenerCallQueue<L> queue : queues) {
|
/external/tensorflow/tensorflow/contrib/slim/ |
H A D | __init__.py | 36 from tensorflow.contrib.slim.python.slim import queues namespace
|
/external/eigen/unsupported/test/ |
H A D | cxx11_eventcount.cpp | 77 // fake queues. Ensure that it does not crash, consumers don't deadlock and 88 TestQueue queues[kQueues]; local 92 producers.emplace_back(new std::thread([&ec, &queues]() { 96 if (queues[idx].Push()) { 108 consumers.emplace_back(new std::thread([&ec, &queues, &waiters, i]() { 113 if (queues[idx].Pop()) continue; 118 if (!queues[q].Empty()) {
|
/external/tensorflow/tensorflow/contrib/slim/python/slim/data/ |
H A D | dataset_data_provider_test.py | 24 from tensorflow.contrib.slim.python.slim import queues namespace 98 with queues.QueueRunners(sess): 122 with queues.QueueRunners(sess):
|
H A D | parallel_reader_test.py | 21 from tensorflow.contrib.slim.python.slim import queues namespace 201 with queues.QueueRunners(sess): 218 with queues.QueueRunners(sess):
|
/external/vulkan-validation-layers/demos/smoke/ |
H A D | Helpers.h | 71 inline VkResult get(VkPhysicalDevice phy, std::vector<VkQueueFamilyProperties> &queues) { argument 75 queues.resize(count); 76 vk::GetPhysicalDeviceQueueFamilyProperties(phy, &count, queues.data());
|
H A D | Shell.cpp | 180 std::vector<VkQueueFamilyProperties> queues; local 181 vk::get(phy, queues); 184 for (uint32_t i = 0; i < queues.size(); i++) { 185 const VkQueueFamilyProperties &q = queues[i]; 187 // requires only GRAPHICS for game queues
|
/external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
H A D | vktSynchronizationBasicSemaphoreTests.cpp | 121 Queues queues[COUNT] = local 144 if (NO_MATCH_FOUND == queues[FIRST].queueFamilyIndex) 145 queues[FIRST].queueFamilyIndex = queueNdx; 147 if (queues[FIRST].queueFamilyIndex != queueNdx || queueFamilyProperties[queueNdx].queueCount > 1u) 149 queues[SECOND].queueFamilyIndex = queueNdx; 154 if (queues[FIRST].queueFamilyIndex == NO_MATCH_FOUND || queues[SECOND].queueFamilyIndex == NO_MATCH_FOUND) 165 queueInfo.queueFamilyIndex = queues[queueNdx].queueFamilyIndex; 166 queueInfo.queueCount = (queues[FIRST].queueFamilyIndex == queues[SECON [all...] |
H A D | vktSynchronizationInternallySynchronizedObjectsTests.cpp | 77 vector<VkQueue> queues; member in struct:vkt::synchronization::__anon4591::MultiQueues::QueueType 90 temp.queues.resize(count); 118 for (int queueNdx = 0; queueNdx < static_cast<int>(queue.queues.size()); ++queueNdx) 125 returnQueues = queue.queues[queueNdx]; 195 MultiQueues& queues = *moveQueues; local 208 queues.addQueueFamilyIndex(queuePropertiesNdx, queueFamilyProperties[queuePropertiesNdx].queueCount); 212 if (queues.countQueueFamilyIndex() == 0) 220 for (int queueFamilyIndexNdx = 0; queueFamilyIndexNdx < static_cast<int>(queues.countQueueFamilyIndex()); ++queueFamilyIndexNdx) 222 if (queues.getQueues(queueFamilyIndexNdx).queues 321 executeComputePipeline(const Context& context, const VkPipeline& pipeline, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const deUint32& shadersExecutions) argument 395 executeGraphicPipeline(const Context& context, const VkPipeline& pipeline, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const VkRenderPass& renderPass, const deUint32 shadersExecutions) argument 496 ThreadGroupThread(const Context& context, VkPipelineCache pipelineCache, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const vector<deUint32>& shadersExecutions) argument 597 CreateComputeThread(const Context& context, VkPipelineCache pipelineCache, vector<VkComputePipelineCreateInfo>& pipelineInfo, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const vector<deUint32>& shadersExecutions) argument 627 CreateGraphicThread(const Context& context, VkPipelineCache pipelineCache, vector<VkGraphicsPipelineCreateInfo>& pipelineInfo, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const VkRenderPass& renderPass, const vector<deUint32>& shadersExecutions) argument 670 MovePtr<MultiQueues> queues = createQueues(m_context, VK_QUEUE_COMPUTE_BIT); local 781 MovePtr<MultiQueues> queues = createQueues (m_context, VK_QUEUE_GRAPHICS_BIT); local [all...] |
H A D | vktSynchronizationCrossInstanceSharingTests.cpp | 436 std::vector<vk::VkDeviceQueueCreateInfo> queues; local 451 queues.push_back(createInfo); 460 (deUint32)queues.size(), 461 &queues[0],
|
H A D | vktSynchronizationWin32KeyedMutexTests.cpp | 192 std::vector<vk::VkDeviceQueueCreateInfo> queues; local 207 queues.push_back(createInfo); 216 (deUint32)queues.size(), 217 &queues[0],
|
/external/vulkan-validation-layers/libs/vkjson/ |
H A D | vkjson.h | 86 std::vector<VkQueueFamilyProperties> queues; member in struct:VkJsonDevice
|
/external/tensorflow/tensorflow/core/kernels/data/ |
H A D | tensor_queue_dataset_op.cc | 200 auto queues = queues_t.flat<Variant>(); variable 201 Variant& queue_inserter = queues(0); 207 queues(b) = queues(0);
|
/external/deqp/external/vulkancts/modules/vulkan/api/ |
H A D | vktApiExternalMemoryTests.cpp | 316 const vk::VkDeviceQueueCreateInfo queues[] = local 334 DE_LENGTH_OF_ARRAY(queues), 335 queues,
|
H A D | vktApiObjectManagementTests.cpp | 561 const VkDeviceQueueCreateInfo queues[] = local 577 DE_LENGTH_OF_ARRAY(queues), 578 queues, 665 const VkDeviceQueueCreateInfo queues[] = local 690 DE_LENGTH_OF_ARRAY(queues), 691 queues,
|
/external/kernel-headers/original/uapi/sound/ |
H A D | asequencer.h | 172 #define SNDRV_SEQ_ADDRESS_BROADCAST 255 /* send event to all queues/clients/ports/channels */ 313 int queues; /* maximum queues count */ member in struct:snd_seq_system_info 318 int cur_queues; /* current queues */ 381 #define SNDRV_SEQ_REMOVE_INPUT (1<<0) /* Flush input queues */ 382 #define SNDRV_SEQ_REMOVE_OUTPUT (1<<1) /* Flush output queues */ 483 unsigned locked:1; /* timing queue locked for other queues */
|
/external/vulkan-validation-layers/demos/ |
H A D | cube.cpp | 684 vk::DeviceQueueCreateInfo queues[2]; local 685 queues[0].setQueueFamilyIndex(graphics_queue_family_index); 686 queues[0].setQueueCount(1); 687 queues[0].setPQueuePriorities(priorities); 691 .setPQueueCreateInfos(queues) 699 queues[1].setQueueFamilyIndex(present_queue_family_index); 700 queues[1].setQueueCount(1); 701 queues[1].setPQueuePriorities(priorities); 757 // If we are using separate queues, change image ownership to the 774 // If we are using separate queues w [all...] |
H A D | cube.c | 1019 // If we are using separate queues, change image ownership to the 1035 // If we are using separate queues we have to wait for image ownership, 3417 VkDeviceQueueCreateInfo queues[2]; local 3418 queues[0].sType = VK_STRUCTURE_TYPE_DEVICE_QUEUE_CREATE_INFO; 3419 queues[0].pNext = NULL; 3420 queues[0].queueFamilyIndex = demo->graphics_queue_family_index; 3421 queues[0].queueCount = 1; 3422 queues[0].pQueuePriorities = queue_priorities; 3423 queues[0].flags = 0; 3429 .pQueueCreateInfos = queues, [all...] |
/external/mesa3d/src/amd/vulkan/ |
H A D | radv_private.h | 482 struct radv_queue *queues[RADV_MAX_QUEUE_FAMILIES]; member in struct:radv_device
|
/external/vulkan-validation-layers/layers/ |
H A D | core_validation.cpp | 131 unordered_set<VkQueue> queues; // All queues under given device member in struct:core_validation::layer_data 2524 // Roll other queues forward to the highest seq we saw a wait for 3251 auto result = dev_data->queues.emplace(queue); 9626 // Host setting event is visible to all queues immediately so update stageMask for any queue that's seen this event
|
/external/annotation-tools/annotation-file-utilities/lib/ |
H A D | guava-20.0.jar | META-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ... |
/external/conscrypt/benchmark-android/ |
H A D | vogar.jar | META-INF/ META-INF/MANIFEST.MF vogar/ vogar/TestProperties.class TestProperties.java package vogar ... |
/external/dagger2/lib/ |
H A D | google-java-format-0.1-20151017.042846-2.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/googlejavaformat/ com/google/googlejavaformat/CloseOp ... |