| /external/ltp/testcases/kernel/syscalls/ipc/msgget/ |
| 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/swiftshader/src/Vulkan/ |
| VkDevice.hpp | 50 Queue* queues = nullptr; member in class:vk::Device
|
| /external/eigen/unsupported/test/ |
| 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()) {
|
| /art/tools/ahat/src/main/com/android/ahat/heapdump/ |
| AhatInstance.java | 717 EnumMap<Reachability, Queue<Reference>> queues = new EnumMap<>(Reachability.class); local
719 queues.put(reachability, new ArrayDeque<Reference>());
723 queues.get(Reachability.STRONG).add(ref);
727 Queue<Reference> queue = queues.get(reachability);
742 queues.get(childRef.reachability).add(childRef);
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| vktSynchronizationBasicSemaphoreTests.cpp | 158 struct Queues
174 Queues queues[COUNT] = local
197 if (NO_MATCH_FOUND == queues[FIRST].queueFamilyIndex)
198 queues[FIRST].queueFamilyIndex = queueNdx;
200 if (queues[FIRST].queueFamilyIndex != queueNdx || queueFamilyProperties[queueNdx].queueCount > 1u)
202 queues[SECOND].queueFamilyIndex = queueNdx;
207 if (queues[FIRST].queueFamilyIndex == NO_MATCH_FOUND || queues[SECOND].queueFamilyIndex == NO_MATCH_FOUND)
208 TCU_THROW(NotSupportedError, "Queues couldn't be created")
[all...] |
| vktSynchronizationCrossInstanceSharingTests.cpp | 447 std::vector<vk::VkDeviceQueueCreateInfo> queues; local
462 queues.push_back(createInfo);
471 (deUint32)queues.size(),
472 &queues[0],
[all...] |
| vktSynchronizationInternallySynchronizedObjectsTests.cpp | 80 vector<VkQueue> queues; member in struct:vkt::synchronization::__anon19237::MultiQueues::QueueType
82 } Queues;
88 Queues temp;
93 temp.queues.resize(count);
99 map<deUint32,Queues>::iterator it = m_queues.begin();
109 Queues & getQueues (const int index)
111 map<deUint32,Queues>::iterator it = m_queues.begin();
120 Queues& queue = m_queues[getQueueFamilyIndex(queueFamilyIndexNdx)];
121 for (int queueNdx = 0; queueNdx < static_cast<int>(queue.queues.size()); ++queueNdx)
128 returnQueues = queue.queues[queueNdx]
198 MultiQueues& queues = *moveQueues; local
621 MovePtr<MultiQueues> queues = createQueues(m_context, VK_QUEUE_COMPUTE_BIT); local
732 MovePtr<MultiQueues> queues = createQueues (m_context, VK_QUEUE_GRAPHICS_BIT); local
[all...] |
| vktSynchronizationWin32KeyedMutexTests.cpp | 195 std::vector<vk::VkDeviceQueueCreateInfo> queues; local
210 queues.push_back(createInfo);
219 (deUint32)queues.size(),
220 &queues[0],
[all...] |
| /frameworks/av/media/codec2/sfplugin/ |
| C2OMXNode.cpp | 65 auto it = jobs->queues.try_emplace(comp, comp, systemTime()).first;
79 for (auto it = jobs->queues.begin(); it != jobs->queues.end(); ) {
88 it = jobs->queues.erase(it);
113 it = jobs->queues.upper_bound(comp);
158 std::owner_less<std::weak_ptr<Codec2Client::Component>>> queues; member in struct:android::C2OMXNode::QueueThread::Jobs
|
| /external/libchrome/base/task/sequence_manager/ |
| sequence_manager_impl.cc | 263 // We push them back onto the *front* of their original work queues,
340 // Note because we don't delete queues while nested, it's perfectly OK to
378 // If the selector has non-empty queues we trivially know there is immediate
637 std::vector<std::unique_ptr<internal::TaskQueueImpl>> queues = local
639 for (std::unique_ptr<internal::TaskQueueImpl>& queue : queues) {
|
| /external/vulkan-validation-layers/layers/ |
| core_validation.h | 170 std::unordered_set<VkQueue> queues; // All queues under given device member in class:CoreChecks
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/api/ |
| vktApiExternalMemoryTests.cpp | 306 const vk::VkDeviceQueueCreateInfo queues[] = local
324 DE_LENGTH_OF_ARRAY(queues),
325 queues,
[all...] |
| vktApiObjectManagementTests.cpp | 569 const VkDeviceQueueCreateInfo queues[] = local
585 DE_LENGTH_OF_ARRAY(queues),
586 queues,
673 const VkDeviceQueueCreateInfo queues[] = local
698 DE_LENGTH_OF_ARRAY(queues),
699 queues,
[all...] |
| /bionic/libc/kernel/uapi/sound/ |
| asequencer.h | 193 int queues; member in struct:snd_seq_system_info
|
| /external/kernel-headers/original/uapi/sound/ |
| 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 */
|
| /cts/tools/cts-device-info/src/com/android/cts/deviceinfo/ |
| VulkanDeviceInfo.java | 256 private static final String KEY_QUEUES = "queues";
623 JSONArray queues = device.getJSONArray(KEY_QUEUES); local
[all...] |
| /external/u-boot/drivers/nvme/ |
| nvme.h | 608 struct nvme_queue **queues; member in struct:nvme_dev
|
| /external/mesa3d/src/amd/vulkan/ |
| radv_private.h | 591 struct radv_queue *queues[RADV_MAX_QUEUE_FAMILIES]; member in struct:radv_device
[all...] |
| /external/dagger2/lib/ |
| google-java-format-0.1-20151017.042846-2.jar | |
| /external/guice/lib/ |
| guava-19.0.jar | |
