| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| D | vktSynchronizationBasicSemaphoreTests.cpp | 174 Queues queues[COUNT] = in basicMultiQueueCase() local
197 if (NO_MATCH_FOUND == queues[FIRST].queueFamilyIndex) in basicMultiQueueCase()
198 queues[FIRST].queueFamilyIndex = queueNdx; in basicMultiQueueCase()
200 if (queues[FIRST].queueFamilyIndex != queueNdx || queueFamilyProperties[queueNdx].queueCount > 1u) in basicMultiQueueCase()
202 queues[SECOND].queueFamilyIndex = queueNdx; in basicMultiQueueCase()
207 …if (queues[FIRST].queueFamilyIndex == NO_MATCH_FOUND || queues[SECOND].queueFamilyIndex == NO_MATC… in basicMultiQueueCase()
218 queueInfo.queueFamilyIndex = queues[queueNdx].queueFamilyIndex; in basicMultiQueueCase()
219 …queueInfo.queueCount = (queues[FIRST].queueFamilyIndex == queues[SECOND].queueFamilyIndex) ? 2 : … in basicMultiQueueCase()
224 if (queues[FIRST].queueFamilyIndex == queues[SECOND].queueFamilyIndex) in basicMultiQueueCase()
238 …deviceInfo.queueCreateInfoCount = (queues[FIRST].queueFamilyIndex == queues[SECOND].queueFamilyIn… in basicMultiQueueCase()
[all …]
|
| D | vktSynchronizationInternallySynchronizedObjectsTests.cpp | 80 vector<VkQueue> queues; member
93 temp.queues.resize(count); in addQueueFamilyIndex()
121 for (int queueNdx = 0; queueNdx < static_cast<int>(queue.queues.size()); ++queueNdx) in getFreeQueue()
128 returnQueues = queue.queues[queueNdx]; in getFreeQueue()
198 MultiQueues& queues = *moveQueues; in createQueues() local
211 …queues.addQueueFamilyIndex(queuePropertiesNdx, queueFamilyProperties[queuePropertiesNdx].queueCoun… in createQueues()
215 if (queues.countQueueFamilyIndex() == 0) in createQueues()
223 …for (int queueFamilyIndexNdx = 0; queueFamilyIndexNdx < static_cast<int>(queues.countQueueFamilyIn… in createQueues()
225 if (queues.getQueues(queueFamilyIndexNdx).queues.size() > maxQueueCount) in createQueues()
226 maxQueueCount = static_cast<unsigned int>(queues.getQueues(queueFamilyIndexNdx).queues.size()); in createQueues()
[all …]
|
| /external/ltp/testcases/kernel/syscalls/ipc/msgget/ |
| D | msgget03.c | 36 static int *queues; variable
61 queues = SAFE_MALLOC(maxmsgs * sizeof(int)); in setup()
64 queues[num] = -1; in setup()
68 queues[num] = res; in setup()
79 if (!queues) in cleanup()
83 if (queues[num] != -1) in cleanup()
84 SAFE_MSGCTL(queues[num], IPC_RMID, NULL); in cleanup()
87 free(queues); in cleanup()
|
| /external/swiftshader/src/Vulkan/ |
| D | VkDevice.cpp | 27 : physicalDevice(info->pPhysicalDevice), queues(reinterpret_cast<Queue*>(mem)) in Device()
43 …new (&queues[queueID]) Queue(queueCreateInfo.queueFamilyIndex, queueCreateInfo.pQueuePriorities[j]… in Device()
63 queues[i].destroy(); in destroy()
66 vk::deallocate(queues, pAllocator); in destroy()
84 return queues[queueIndex]; in getQueue()
96 queues[i].waitIdle(); in waitIdle()
|
| /external/tensorflow/tensorflow/python/estimator/inputs/queues/ |
| D | __init__.py | 26 from tensorflow_estimator.python.estimator.inputs import queues
30 queues.__all__ = [s for s in dir(queues) if not s.startswith('__')]
32 from tensorflow_estimator.python.estimator.inputs.queues import *
|
| D | feeding_queue_runner.py | 26 from tensorflow_estimator.python.estimator.inputs.queues import feeding_queue_runner
34 from tensorflow_estimator.python.estimator.inputs.queues.feeding_queue_runner import *
|
| D | feeding_functions.py | 26 from tensorflow_estimator.python.estimator.inputs.queues import feeding_functions
34 from tensorflow_estimator.python.estimator.inputs.queues.feeding_functions import *
|
| /external/eigen/unsupported/test/ |
| D | cxx11_eventcount.cpp | 88 TestQueue queues[kQueues]; in test_stress_eventcount() local
92 producers.emplace_back(new std::thread([&ec, &queues]() { in test_stress_eventcount()
96 if (queues[idx].Push()) { in test_stress_eventcount()
108 consumers.emplace_back(new std::thread([&ec, &queues, &waiters, i]() { in test_stress_eventcount()
113 if (queues[idx].Pop()) continue; in test_stress_eventcount()
118 if (!queues[q].Empty()) { in test_stress_eventcount()
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_flounder_lte_LRX16F_3.10.40/events/mac80211/drv_flush/ |
| D | format | 11 field:u32 queues; offset:44; size:4; signed:0;
13 print fmt: "%s queues:0x%x drop:%d", REC->wiphy_name, REC->queues, REC->drop
|
| /external/autotest/server/cros/ |
| D | queue_barrier.py | 5 from multiprocessing import Queue, queues
52 except queues.Empty:
72 except queues.Empty:
|
| /external/u-boot/tools/ |
| D | genboardscfg.py | 220 def read_queues(queues, params_list): argument
222 for q in queues:
243 queues = []
252 queues.append(q)
260 read_queues(queues, params_list)
270 read_queues(queues, params_list)
|
| /external/iptables/extensions/ |
| D | libxt_NFQUEUE.man | 17 This specifies a range of queues to use. Packets are then balanced across the given queues.
19 queues x, x+1, .. x+n and use "\-\-queue\-balance \fIx\fP\fB:\fP\fIx+n\fP".
32 the queues. The idea is that you can improve performance if there's a queue
|
| /external/u-boot/drivers/nvme/ |
| D | nvme.c | 215 return nvme_submit_sync_cmd(dev->queues[NVME_ADMIN_Q], cmd, in nvme_submit_admin_cmd()
245 dev->queues[qid] = nvmeq; in nvme_alloc_queue()
308 struct nvme_queue *nvmeq = dev->queues[i]; in nvme_free_queues()
310 dev->queues[i] = NULL; in nvme_free_queues()
356 nvmeq = dev->queues[NVME_ADMIN_Q]; in nvme_configure_admin_queue()
384 nvme_init_queue(dev->queues[NVME_ADMIN_Q], 0); in nvme_configure_admin_queue()
550 if (nvme_create_queue(dev->queues[i], i)) in nvme_create_io_queues()
718 status = nvme_submit_sync_cmd(dev->queues[NVME_IO_Q], in nvme_blk_rw()
784 ndev->queues = malloc(NVME_Q_NUM * sizeof(struct nvme_queue *)); in nvme_probe()
785 if (!ndev->queues) { in nvme_probe()
[all …]
|
| /external/autotest/client/site_tests/security_SysVIPC/ |
| D | security_SysVIPC.py | 103 queues = utils.system_output('ipcs -q | grep ^0', ignore_status=True)
104 if queues:
107 logging.error(queues)
|
| /external/python/cpython3/Lib/asyncio/ |
| D | __init__.py | 15 from .queues import *
32 queues.__all__ +
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio.rst | 28 database connection libraries, distributed task queues, etc.
42 * distribute tasks via :ref:`queues <asyncio-queues>`;
|
| D | datatypes.rst | 8 types such as dates and times, fixed-type arrays, heap queues, synchronized
9 queues, and sets.
|
| /external/tensorflow/tensorflow/contrib/slim/python/slim/data/ |
| D | dataset_data_provider_test.py | 24 from tensorflow.contrib.slim.python.slim import queues
98 with queues.QueueRunners(sess):
122 with queues.QueueRunners(sess):
|
| /external/python/cpython2/Doc/library/ |
| D | datatypes.rst | 9 types such as dates and times, fixed-type arrays, heap queues, synchronized
10 queues, and sets.
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | shared_batch_scheduler_test.cc | 377 std::vector<std::unique_ptr<BatchScheduler<FakeTask>>> queues(2); in TEST() local
379 scheduler->AddQueue(queue_options, queue_0_callback, &queues[0])); in TEST()
381 scheduler->AddQueue(queue_options, queue_1_callback, &queues[1])); in TEST()
385 TF_ASSERT_OK(ScheduleTask(10, queues[0].get())); in TEST()
390 TF_ASSERT_OK(ScheduleTask(10, queues[0].get())); in TEST()
391 TF_ASSERT_OK(ScheduleTask(10, queues[0].get())); in TEST()
396 TF_ASSERT_OK(ScheduleTask(1, queues[1].get())); in TEST()
|
| /external/bcc/tools/ |
| D | cpuunclaimed_example.txt | 4 This tool samples the length of the CPU run queues and determine when there are
10 Sampling run queues... Output every 1 seconds. Hit Ctrl-C to end.
44 Sampling run queues... Output every 1 seconds. Hit Ctrl-C to end.
64 Sampling run queues... Output every 1 seconds. Hit Ctrl-C to end.
281 Sampling run queues... Output every 1 seconds. Hit Ctrl-C to end.
307 Sample CPU run queues and calculate unclaimed idle CPU
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ListenerCallQueue.java | 52 void enqueueOn(Iterable<ListenerCallQueue<L>> queues) { in enqueueOn() argument
53 for (ListenerCallQueue<L> queue : queues) { in enqueueOn()
|
| /external/tensorflow/tensorflow/contrib/slim/ |
| D | BUILD | 119 name = "queues",
120 srcs = ["python/slim/queues.py"],
139 ":queues",
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | __init__.py | 217 from multiprocessing.queues import Queue
224 from multiprocessing.queues import JoinableQueue
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | context.py | 101 from .queues import Queue
106 from .queues import JoinableQueue
111 from .queues import SimpleQueue
|