Home
last modified time | relevance | path

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

123

/third_party/ltp/testcases/kernel/syscalls/ipc/shmget/
H A Dshmget03.c24 static int *queues; variable
44 queues = SAFE_MALLOC((maxshms - used_cnt) * sizeof(int)); in setup()
50 queues[queue_cnt++] = res; in setup()
60 if (!queues) in cleanup()
64 SAFE_SHMCTL(queues[num], IPC_RMID, NULL); in cleanup()
66 free(queues); in cleanup()
/third_party/ltp/testcases/kernel/syscalls/ipc/msgget/
H A Dmsgget03.c11 * ENOSPC - All possible message queues have been taken (MSGMNI)
25 static int *queues; variable
41 tst_res(TINFO, "Current environment %d message queues are already in use", in setup()
47 queues = SAFE_MALLOC((maxmsgs - used_cnt) * sizeof(int)); in setup()
53 queues[queue_cnt++] = res; in setup()
56 tst_res(TINFO, "The maximum number of message queues (%d) reached", in setup()
64 if (!queues) in cleanup()
68 SAFE_MSGCTL(queues[num], IPC_RMID, NULL); in cleanup()
70 free(queues); in cleanup()
/third_party/vk-gl-cts/external/vulkancts/modules/vulkan/synchronization/
H A DvktSynchronizationInternallySynchronizedObjectsTests.cpp105 vector<VkQueue> queues; member
118 temp.queues.resize(count); in addQueueFamilyIndex()
147 for (int queueNdx = 0; queueNdx < static_cast<int>(queue.queues.size()); ++queueNdx) in getFreeQueue()
154 returnQueues = queue.queues[queueNdx]; in getFreeQueue()
238 MultiQueues& queues = *moveQueues; in createQueues() local
251 queues.addQueueFamilyIndex(queuePropertiesNdx, queueFamilyProperties[queuePropertiesNdx].queueCount); in createQueues()
255 if (queues.countQueueFamilyIndex() == 0) in createQueues()
263 for (int queueFamilyIndexNdx = 0; queueFamilyIndexNdx < static_cast<int>(queues.countQueueFamilyIndex()); ++queueFamilyIndexNdx) in createQueues()
265 if (queues.getQueues(queueFamilyIndexNdx).queues in createQueues()
356 executeComputePipeline(const Context& context, const VkPipeline& pipeline, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const deUint32& shadersExecutions) executeComputePipeline() argument
430 executeGraphicPipeline(const Context& context, const VkPipeline& pipeline, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const VkRenderPass& renderPass, const deUint32 shadersExecutions) executeGraphicPipeline() argument
526 ThreadGroupThread(const Context& context, VkPipelineCache pipelineCache, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const vector<deUint32>& shadersExecutions) ThreadGroupThread() argument
648 CreateComputeThread(const Context& context, VkPipelineCache pipelineCache, vector<VkComputePipelineCreateInfo>& pipelineInfo, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const vector<deUint32>& shadersExecutions) CreateComputeThread() argument
687 CreateGraphicThread(const Context& context, VkPipelineCache pipelineCache, vector<VkGraphicsPipelineCreateInfo>& pipelineInfo, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const VkRenderPass& renderPass, const vector<deUint32>& shadersExecutions) CreateGraphicThread() argument
744 MovePtr<MultiQueues> queues = createQueues(m_context, VK_QUEUE_COMPUTE_BIT, instance, instanceDriver); iterate() local
872 MovePtr<MultiQueues> queues = createQueues(m_context, VK_QUEUE_GRAPHICS_BIT, instance, instanceDriver); iterate() local
[all...]
H A DvktSynchronizationBasicSemaphoreTests.cpp525 Queues queues[COUNT] = in basicMultiQueueCase() local
588 if (NO_MATCH_FOUND == queues[FIRST].queueFamilyIndex) in basicMultiQueueCase()
589 queues[FIRST].queueFamilyIndex = queueNdx; in basicMultiQueueCase()
591 if (queues[FIRST].queueFamilyIndex != queueNdx || queueFamilyProperties[queueNdx].queueCount > 1u) in basicMultiQueueCase()
593 queues[SECOND].queueFamilyIndex = queueNdx; in basicMultiQueueCase()
598 if (queues[FIRST].queueFamilyIndex == NO_MATCH_FOUND || queues[SECOND].queueFamilyIndex == NO_MATCH_FOUND) in basicMultiQueueCase()
609 queueInfo.queueFamilyIndex = queues[queueNdx].queueFamilyIndex; in basicMultiQueueCase()
610 queueInfo.queueCount = (queues[FIRST].queueFamilyIndex == queues[SECON in basicMultiQueueCase()
[all...]
/third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/synchronization/
H A DvktSynchronizationInternallySynchronizedObjectsTests.cpp105 vector<VkQueue> queues; member
118 temp.queues.resize(count); in addQueueFamilyIndex()
147 for (int queueNdx = 0; queueNdx < static_cast<int>(queue.queues.size()); ++queueNdx) in getFreeQueue()
154 returnQueues = queue.queues[queueNdx]; in getFreeQueue()
238 MultiQueues& queues = *moveQueues; in createQueues() local
251 queues.addQueueFamilyIndex(queuePropertiesNdx, queueFamilyProperties[queuePropertiesNdx].queueCount); in createQueues()
255 if (queues.countQueueFamilyIndex() == 0) in createQueues()
263 for (int queueFamilyIndexNdx = 0; queueFamilyIndexNdx < static_cast<int>(queues.countQueueFamilyIndex()); ++queueFamilyIndexNdx) in createQueues()
265 if (queues.getQueues(queueFamilyIndexNdx).queues in createQueues()
356 executeComputePipeline(const Context& context, const VkPipeline& pipeline, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const deUint32& shadersExecutions) executeComputePipeline() argument
430 executeGraphicPipeline(const Context& context, const VkPipeline& pipeline, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const VkRenderPass& renderPass, const deUint32 shadersExecutions) executeGraphicPipeline() argument
526 ThreadGroupThread(const Context& context, VkPipelineCache pipelineCache, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const vector<deUint32>& shadersExecutions) ThreadGroupThread() argument
648 CreateComputeThread(const Context& context, VkPipelineCache pipelineCache, vector<VkComputePipelineCreateInfo>& pipelineInfo, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const vector<deUint32>& shadersExecutions) CreateComputeThread() argument
687 CreateGraphicThread(const Context& context, VkPipelineCache pipelineCache, vector<VkGraphicsPipelineCreateInfo>& pipelineInfo, const VkPipelineLayout& pipelineLayout, const VkDescriptorSetLayout& descriptorSetLayout, MultiQueues& queues, const VkRenderPass& renderPass, const vector<deUint32>& shadersExecutions) CreateGraphicThread() argument
744 MovePtr<MultiQueues> queues = createQueues(m_context, VK_QUEUE_COMPUTE_BIT, instance, instanceDriver); iterate() local
872 MovePtr<MultiQueues> queues = createQueues(m_context, VK_QUEUE_GRAPHICS_BIT, instance, instanceDriver); iterate() local
[all...]
H A DvktSynchronizationBasicSemaphoreTests.cpp445 Queues queues[COUNT] = in basicMultiQueueCase() local
508 if (NO_MATCH_FOUND == queues[FIRST].queueFamilyIndex) in basicMultiQueueCase()
509 queues[FIRST].queueFamilyIndex = queueNdx; in basicMultiQueueCase()
511 if (queues[FIRST].queueFamilyIndex != queueNdx || queueFamilyProperties[queueNdx].queueCount > 1u) in basicMultiQueueCase()
513 queues[SECOND].queueFamilyIndex = queueNdx; in basicMultiQueueCase()
518 if (queues[FIRST].queueFamilyIndex == NO_MATCH_FOUND || queues[SECOND].queueFamilyIndex == NO_MATCH_FOUND) in basicMultiQueueCase()
529 queueInfo.queueFamilyIndex = queues[queueNdx].queueFamilyIndex; in basicMultiQueueCase()
530 queueInfo.queueCount = (queues[FIRST].queueFamilyIndex == queues[SECON in basicMultiQueueCase()
[all...]
/third_party/vk-gl-cts/external/vulkan-docs/src/scripts/
H A Dvaliditygenerator.py1071 def conditionallyRemoveQueueType(self, queues, queuetype, condition):
1073 if queuetype in queues and condition:
1074 queues.remove(queuetype)
1078 queues = cmd.get('queues')
1079 if queues is None:
1081 queues = queues.split(',')
1084 self.conditionallyRemoveQueueType(queues, 'sparse_binding', self.conventions.xml_api_name == "vulkansc")
1085 self.conditionallyRemoveQueueType(queues, 'decod
[all...]
/third_party/mesa3d/src/virtio/vulkan/
H A Dvn_device.c86 struct vn_queue *queues = in vn_device_init_queues() local
87 vk_zalloc(alloc, sizeof(*queues) * count, VN_DEFAULT_ALIGN, in vn_device_init_queues()
89 if (!queues) in vn_device_init_queues()
99 result = vn_queue_init(dev, &queues[count], queue_info, j); in vn_device_init_queues()
102 vn_queue_fini(&queues[k]); in vn_device_init_queues()
103 vk_free(alloc, queues); in vn_device_init_queues()
112 dev->queues = queues; in vn_device_init_queues()
478 vn_queue_fini(&dev->queues[i]); in vn_DestroyDevice()
491 /* We must emit vkDestroyDevice before freeing dev->queues in vn_DestroyDevice()
[all...]
H A Dvn_device.h27 /* unique queue family indices in which to create the device queues */
43 struct vn_queue *queues; member
/third_party/python/Lib/asyncio/
H A D__init__.py16 from .queues import *
33 queues.__all__ +
/third_party/node/deps/npm/node_modules/@npmcli/arborist/lib/arborist/
H A Drebuild.js31 #queues
140 this.#queues = {
197 // now sort into the queues for the 4 things we have to do
209 this.#queues[key].push(node)
283 const queue = this.#queues[event]
365 const queue = this.#queues.bin
/third_party/mesa3d/src/intel/ds/
H A Dintel_driver_ds.cc199 u_vector_foreach(queue, &device->queues) { in send_descriptors()
231 u_vector_foreach(queue, &device->queues) { in send_descriptors()
532 u_vector_init(&device->queues, 4, sizeof(struct intel_ds_queue)); in intel_ds_device_init()
539 u_vector_finish(&device->queues);
548 (struct intel_ds_queue *) u_vector_add(&device->queues);
554 queue->queue_id = u_vector_length(&device->queues) - 1;
/third_party/skia/third_party/externals/swiftshader/src/Vulkan/
H A DVkDevice.cpp120 , queues(reinterpret_cast<Queue *>(mem)) in Device()
138 new(&queues[queueID]) Queue(this, scheduler.get());
192 queues[i].~Queue(); in destroy()
195 vk::freeHostMemory(queues, pAllocator); in destroy()
225 return queues[queueIndex]; in getQueue()
349 queues[i].waitIdle(); in waitIdle()
/third_party/mesa3d/src/freedreno/vulkan/
H A Dtu_perfetto.cc102 for (unsigned i = 0; i < ARRAY_SIZE(queues); i++) { in send_descriptors()
105 desc->set_name(queues[i].name); in send_descriptors()
106 desc->set_description(queues[i].desc); in send_descriptors()
H A Dtu_perfetto.h63 } queues[] = { variable
/third_party/mesa3d/src/imagination/vulkan/
H A Dpvr_queue.c116 /* Check requested queue families and queues */ in pvr_queues_create()
124 device->queues = vk_alloc(&device->vk.alloc, in pvr_queues_create()
125 queue_create->queueCount * sizeof(*device->queues), in pvr_queues_create()
128 if (!device->queues) in pvr_queues_create()
134 result = pvr_queue_init(device, &device->queues[i], queue_create, i); in pvr_queues_create()
165 pvr_queue_finish(&device->queues[q_idx]); in pvr_queues_destroy()
167 vk_free(&device->vk.alloc, device->queues); in pvr_queues_destroy()
/third_party/mesa3d/src/vulkan/runtime/
H A Dvk_queue.h48 /* Link in vk_device::queues */
195 list_for_each_entry(struct vk_queue, queue, &(device)->queues, link)
198 list_for_each_entry_safe(struct vk_queue, queue, &(device)->queues, link)
/third_party/vk-gl-cts/external/vulkancts/modules/vulkan/video/
H A DvktVideoTestUtils.cpp605 std::vector<VkQueueFamilyProperties2> queues(count); in getSupportedCodecs()
608 for (std::vector<VkQueueFamilyProperties2>::size_type i = 0; i < queues.size(); i++) in getSupportedCodecs()
610 queues[i].sType = VK_STRUCTURE_TYPE_QUEUE_FAMILY_PROPERTIES_2; in getSupportedCodecs()
612 queues[i].pNext = &videoQueues[i]; in getSupportedCodecs()
616 vkif.getPhysicalDeviceQueueFamilyProperties2(devCtx.phys, &count, queues.data()); in getSupportedCodecs()
619 TCU_CHECK(selectedVideoQueueFamily < queues.size()); in getSupportedCodecs()
621 const VkQueueFamilyProperties2 &q = queues[selectedVideoQueueFamily]; in getSupportedCodecs()
625 // The video queues may or may not support queryResultStatus in getSupportedCodecs()
/third_party/python/Lib/multiprocessing/
H A Dcontext.py102 from .queues import Queue
107 from .queues import JoinableQueue
112 from .queues import SimpleQueue
/third_party/skia/third_party/externals/imgui/examples/example_sdl_vulkan/
H A Dmain.cpp140 VkQueueFamilyProperties* queues = (VkQueueFamilyProperties*)malloc(sizeof(VkQueueFamilyProperties) * count); in SetupVulkan() local
141 vkGetPhysicalDeviceQueueFamilyProperties(g_PhysicalDevice, &count, queues); in SetupVulkan()
143 if (queues[i].queueFlags & VK_QUEUE_GRAPHICS_BIT) in SetupVulkan()
148 free(queues); in SetupVulkan()
/third_party/skia/third_party/externals/imgui/examples/example_glfw_vulkan/
H A Dmain.cpp148 VkQueueFamilyProperties* queues = (VkQueueFamilyProperties*)malloc(sizeof(VkQueueFamilyProperties) * count); in SetupVulkan() local
149 vkGetPhysicalDeviceQueueFamilyProperties(g_PhysicalDevice, &count, queues); in SetupVulkan()
151 if (queues[i].queueFlags & VK_QUEUE_GRAPHICS_BIT) in SetupVulkan()
156 free(queues); in SetupVulkan()
/third_party/mesa3d/src/panfrost/vulkan/
H A Dpanvk_device.c1015 device->queues[qfi] = in panvk_CreateDevice()
1019 if (!device->queues[qfi]) { in panvk_CreateDevice()
1024 memset(device->queues[qfi], 0, in panvk_CreateDevice()
1030 result = panvk_queue_init(device, &device->queues[qfi][q], q, in panvk_CreateDevice()
1043 panvk_queue_finish(&device->queues[i][q]); in panvk_CreateDevice()
1045 vk_object_free(&device->vk, NULL, device->queues[i]); in panvk_CreateDevice()
1062 panvk_queue_finish(&device->queues[i][q]); in panvk_DestroyDevice()
1064 vk_object_free(&device->vk, NULL, device->queues[i]); in panvk_DestroyDevice()
/third_party/mesa3d/src/gallium/drivers/freedreno/
H A Dfreedreno_perfetto.h79 } queues[] = { variable
H A Dfreedreno_perfetto.cc109 for (unsigned i = 0; i < ARRAY_SIZE(queues); i++) { in send_descriptors()
112 desc->set_name(queues[i].name); in send_descriptors()
113 desc->set_description(queues[i].desc); in send_descriptors()
/third_party/ffmpeg/libavutil/
H A Dvulkan.c409 e->queues = av_mallocz(qf->nb_queues * sizeof(*e->queues)); in FN_CREATING()
410 if (!e->queues) in FN_CREATING()
437 FFVkQueueCtx *q = &e->queues[i]; in FN_CREATING()
449 FFVkQueueCtx *q = &e->queues[e->qf->cur_queue]; in ff_vk_discard_exec_deps()
467 FFVkQueueCtx *q = &e->queues[e->qf->cur_queue]; in ff_vk_start_exec_recording()
514 FFVkQueueCtx *q = &e->queues[e->qf->cur_queue]; in ff_vk_add_exec_dep()
594 FFVkQueueCtx *q = &e->queues[e->qf->cur_queue]; in ff_vk_submit_exec_queue()
643 FFVkQueueCtx *q = &e->queues[e->qf->cur_queue]; in ff_vk_add_dep_exec_ctx()
1085 /* If a set has never been updated, update all queues' set in ff_vk_update_descriptor_set()
[all...]

Completed in 21 milliseconds

123