Searched defs:queues (Results 1 - 25 of 25) sorted by relevance

/external/autotest/server/cros/
H A Dqueue_barrier.py5 from multiprocessing import Queue, queues namespace
52 except queues.Empty:
72 except queues.Empty:
/external/ltp/testcases/kernel/syscalls/ipc/msgget/
H A Dmsgget03.c21 * 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 DListenerCallQueue.java51 /** 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__.py36 from tensorflow.contrib.slim.python.slim import queues namespace
/external/eigen/unsupported/test/
H A Dcxx11_eventcount.cpp77 // 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 Ddataset_data_provider_test.py24 from tensorflow.contrib.slim.python.slim import queues namespace
98 with queues.QueueRunners(sess):
122 with queues.QueueRunners(sess):
H A Dparallel_reader_test.py21 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 DHelpers.h71 inline VkResult get(VkPhysicalDevice phy, std::vector<VkQueueFamilyProperties> &queues) { argument
75 queues.resize(count);
76 vk::GetPhysicalDeviceQueueFamilyProperties(phy, &count, queues.data());
H A DShell.cpp180 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 DvktSynchronizationBasicSemaphoreTests.cpp121 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 DvktSynchronizationInternallySynchronizedObjectsTests.cpp77 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 DvktSynchronizationCrossInstanceSharingTests.cpp436 std::vector<vk::VkDeviceQueueCreateInfo> queues; local
451 queues.push_back(createInfo);
460 (deUint32)queues.size(),
461 &queues[0],
H A DvktSynchronizationWin32KeyedMutexTests.cpp192 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 Dvkjson.h86 std::vector<VkQueueFamilyProperties> queues; member in struct:VkJsonDevice
/external/tensorflow/tensorflow/core/kernels/data/
H A Dtensor_queue_dataset_op.cc200 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 DvktApiExternalMemoryTests.cpp316 const vk::VkDeviceQueueCreateInfo queues[] = local
334 DE_LENGTH_OF_ARRAY(queues),
335 queues,
H A DvktApiObjectManagementTests.cpp561 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 Dasequencer.h172 #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 Dcube.cpp684 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 Dcube.c1019 // 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 Dradv_private.h482 struct radv_queue *queues[RADV_MAX_QUEUE_FAMILIES]; member in struct:radv_device
/external/vulkan-validation-layers/layers/
H A Dcore_validation.cpp131 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 Dguava-20.0.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ...
/external/conscrypt/benchmark-android/
H A Dvogar.jarMETA-INF/ META-INF/MANIFEST.MF vogar/ vogar/TestProperties.class TestProperties.java package vogar ...
/external/dagger2/lib/
H A Dgoogle-java-format-0.1-20151017.042846-2.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/googlejavaformat/ com/google/googlejavaformat/CloseOp ...

Completed in 1122 milliseconds