| /external/crosvm/devices/src/virtio/ |
| D | virtio_pci_common_config.rs | 51 queues: &mut [QueueConfig], in read()
60 let v = self.read_common_config_word(offset, queues); in read()
79 queues: &mut [QueueConfig], in write()
88 queues, in write()
93 queues, in write()
99 queues, in write()
123 fn read_common_config_word(&self, offset: u64, queues: &[QueueConfig]) -> u16 { in read_common_config_word()
126 0x12 => queues.len() as u16, // num_queues in read_common_config_word()
128 0x18 => self.with_queue(queues, |q| q.size()).unwrap_or(0), in read_common_config_word()
129 0x1a => self.with_queue(queues, |q| q.vector()).unwrap_or(0), in read_common_config_word()
[all …]
|
| D | console.rs | 92 queues: BTreeMap<usize, Queue>, in activate()
94 for (idx, queue) in queues.into_iter() { in activate()
110 let mut queues = BTreeMap::new(); in virtio_sleep() localVariable
117 queues.insert(idx, queue); in virtio_sleep()
121 if !queues.is_empty() { in virtio_sleep()
122 Ok(Some(queues)) in virtio_sleep()
132 if let Some((_mem, _interrupt, queues)) = queues_state { in virtio_wake()
133 for (idx, queue) in queues.into_iter() { in virtio_wake()
|
| D | virtio_device.rs | 137 queues: BTreeMap<usize, Queue>, in activate()
296 let mut queues = BTreeMap::new(); localVariable
304 queues.insert(i, queue);
306 queues
323 let queues = create_queues( localVariable
334 .activate(mem.clone(), interrupt.clone(), queues)
351 let queues = create_queues( localVariable
362 .activate(mem.clone(), interrupt.clone(), queues)
|
| /external/python/cpython3/Lib/test/test_interpreters/ |
| D | test_queues.py | 12 from test.support.interpreters import queues, _crossinterp
43 importlib.reload(queues)
49 with self.assertRaises(queues.QueueNotFoundError):
51 with self.assertRaises(queues.QueueNotFoundError):
94 with self.assertRaises(queues.QueueError):
102 queue = queues.create()
106 queue = queues.create(3)
110 queue = queues.create(100)
114 queue = queues.create(0)
118 queue = queues.create(-10)
[all …]
|
| /external/OpenCL-CTS/test_conformance/SVM/ |
| D | test_migrate.cpp | 88 clCommandQueueWrapper queues[MAXQ]; in test_svm_migrate() local
93 …error = create_cl_objects(deviceID, &sources[0], &context, &program, &queues[0], &num_devices, CL_… in test_svm_migrate()
102 error = clGetCommandQueueInfo(queues[0], CL_QUEUE_DEVICE, sizeof(did), (void *)&did, NULL); in test_svm_migrate()
106 error = clGetCommandQueueInfo(queues[0], CL_QUEUE_PROPERTIES, sizeof(cqp), &cqp, NULL); in test_svm_migrate()
110 queues[1] = clCreateCommandQueueWithProperties(context, did, qp, &error); in test_svm_migrate()
156 …error = clEnqueueSVMMemFill(queues[0], (void *)asvm, patt, sizeof(patt), global_size*sizeof(cl_uin… in test_svm_migrate()
159 …error = clEnqueueSVMMemFill(queues[0], (void *)bsvm, patt, sizeof(patt), global_size*sizeof(cl_uin… in test_svm_migrate()
162 …error = clEnqueueSVMMemFill(queues[0], (void *)csvm, patt, sizeof(patt), global_size*sizeof(cl_uin… in test_svm_migrate()
169 …error = clEnqueueSVMMigrateMem(queues[1], 3, (const void**)ptrs, NULL, CL_MIGRATE_MEM_OBJECT_CONTE… in test_svm_migrate()
177 …error = clEnqueueSVMMigrateMem(queues[0], 3, (const void**)ptrs, szs, CL_MIGRATE_MEM_OBJECT_HOST, … in test_svm_migrate()
[all …]
|
| D | test_set_kernel_exec_info_svm_ptrs.cpp | 51 clCommandQueueWrapper queues[MAXQ]; in test_svm_set_kernel_exec_info_svm_ptrs() local
54 …jects(deviceID, &set_kernel_exec_info_svm_ptrs_kernel[0], &c, &program, &queues[0], &num_devices, … in test_svm_set_kernel_exec_info_svm_ptrs()
83 …clEnqueueMapBuffer(queues[0], ba, CL_TRUE, CL_MAP_READ | CL_MAP_WRITE, 0, size, 0, NULL, NULL, &er… in test_svm_set_kernel_exec_info_svm_ptrs()
85 …clEnqueueMapBuffer(queues[0], bb, CL_TRUE, CL_MAP_READ | CL_MAP_WRITE, 0, size, 0, NULL, NULL, &er… in test_svm_set_kernel_exec_info_svm_ptrs()
87 …clEnqueueMapBuffer(queues[0], bc, CL_TRUE, CL_MAP_READ | CL_MAP_WRITE, 0, size, 0, NULL, NULL, &er… in test_svm_set_kernel_exec_info_svm_ptrs()
89 …clEnqueueMapBuffer(queues[0], bBuf, CL_TRUE, CL_MAP_READ | CL_MAP_WRITE, 0, sizeof(BufPtrs), 0, NU… in test_svm_set_kernel_exec_info_svm_ptrs()
98 error = clEnqueueUnmapMemObject(queues[0], ba, pA, 0, NULL, NULL); in test_svm_set_kernel_exec_info_svm_ptrs()
100 error = clEnqueueUnmapMemObject(queues[0], bb, pB, 0, NULL, NULL); in test_svm_set_kernel_exec_info_svm_ptrs()
102 error = clEnqueueUnmapMemObject(queues[0], bc, pC, 0, NULL, NULL); in test_svm_set_kernel_exec_info_svm_ptrs()
104 error = clEnqueueUnmapMemObject(queues[0], bBuf, pBuf, 0, NULL, NULL); in test_svm_set_kernel_exec_info_svm_ptrs()
[all …]
|
| D | test_fine_grain_memory_consistency.cpp | 68 int launch_kernels_and_verify(clContextWrapper &context, clCommandQueueWrapper* queues, clKernelWra… in launch_kernels_and_verify() argument
93 err = clEnqueueNDRangeKernel(queues[d], kernel, 1, NULL, &num_pixels, 0, 0, NULL, &done); in launch_kernels_and_verify()
96 for(cl_uint d=0; d<num_devices; d++) clFlush(queues[d]); in launch_kernels_and_verify()
103 for(cl_uint d=0; d<num_devices; d++) clFinish(queues[d]); in launch_kernels_and_verify()
145 clCommandQueueWrapper queues[MAXQ]; in test_svm_fine_grain_memory_consistency() local
158 …err = create_cl_objects(deviceID, (const char**)source, &context, &program, &queues[0], &num_devic… in test_svm_fine_grain_memory_consistency()
168 result = launch_kernels_and_verify(context, queues, kernel, num_devices, numBins, num_pixels); in test_svm_fine_grain_memory_consistency()
172 result = launch_kernels_and_verify(context, queues, kernel, num_devices, numBins, num_pixels); in test_svm_fine_grain_memory_consistency()
176 result = launch_kernels_and_verify(context, queues, kernel, num_devices, numBins, num_pixels); in test_svm_fine_grain_memory_consistency()
|
| D | test_byte_granularity.cpp | 57 clCommandQueueWrapper queues[MAXQ]; in test_svm_byte_granularity() local
62 …err = create_cl_objects(deviceID, &byte_manipulation_kernels[0], &context, &program, &queues[0], &… in test_svm_byte_granularity()
94 err = clEnqueueNDRangeKernel(queues[d], k1, 1, NULL, &element_num, NULL, 0, NULL, NULL); in test_svm_byte_granularity()
98 for(cl_uint d=0; d < num_devices; d++) clFlush(queues[d]); in test_svm_byte_granularity()
103 for(cl_uint id = 0; id < num_devices; id++) clFinish(queues[id]); in test_svm_byte_granularity()
118 …err = clEnqueueNDRangeKernel(queues[id], k2, 1, NULL, &adjusted_num_elements, NULL, 0, NULL, NULL); in test_svm_byte_granularity()
122 for(cl_uint id = 0; id < num_devices; id++) clFinish(queues[id]); in test_svm_byte_granularity()
|
| D | test_allocate_shared_buffer.cpp | 50 clCommandQueueWrapper queues[MAXQ]; in test_svm_allocate_shared_buffer() local
57 …err = create_cl_objects(deviceID, NULL, &context, &program, &queues[0], &num_devices, CL_DEVICE_SV… in test_svm_allocate_shared_buffer()
92 …pBufData2 = (cl_char*) clEnqueueMapBuffer(queues[0], buf, CL_TRUE, flags, 0, size, 0, NULL,NULL, &… in test_svm_allocate_shared_buffer()
100 err = clEnqueueUnmapMemObject(queues[0], buf, pBufData2, 0, NULL, NULL); in test_svm_allocate_shared_buffer()
102 err = clFinish(queues[0]); in test_svm_allocate_shared_buffer()
|
| /external/python/cpython3/Modules/ |
| D | _interpqueuesmodule.c | 846 _queues_init(_queues *queues, PyThread_type_lock mutex) in _queues_init() argument
849 assert(queues->mutex == NULL); in _queues_init()
850 *queues = (_queues){ in _queues_init()
859 _queues_fini(_queues *queues, PyThread_type_lock *p_mutex) in _queues_fini() argument
861 PyThread_type_lock mutex = queues->mutex; in _queues_fini()
865 if (queues->count > 0) { in _queues_fini()
866 assert(queues->head != NULL); in _queues_fini()
867 _queuerefs_clear(queues->head); in _queues_fini()
869 *queues = (_queues){0}; in _queues_fini()
876 _queues_next_id(_queues *queues) // needs lock in _queues_next_id() argument
[all …]
|
| /external/rust/android-crates-io/crates/virtio-drivers/src/transport/ |
| D | fake.rs | 48 self.state.lock().unwrap().queues[queue as usize] in notify()
78 state.queues[queue as usize].size = size; in queue_set()
79 state.queues[queue as usize].descriptors = descriptors; in queue_set()
80 state.queues[queue as usize].driver_area = driver_area; in queue_set()
81 state.queues[queue as usize].device_area = device_area; in queue_set()
86 state.queues[queue as usize].size = 0; in queue_unset()
87 state.queues[queue as usize].descriptors = 0; in queue_unset()
88 state.queues[queue as usize].driver_area = 0; in queue_unset()
89 state.queues[queue as usize].device_area = 0; in queue_unset()
93 self.state.lock().unwrap().queues[queue as usize].descriptors != 0 in queue_used()
[all …]
|
| /external/rust/android-crates-io/crates/virtio-drivers-and-devices/src/transport/ |
| D | fake.rs | 48 self.state.lock().unwrap().queues[queue as usize] in notify()
78 state.queues[queue as usize].size = size; in queue_set()
79 state.queues[queue as usize].descriptors = descriptors; in queue_set()
80 state.queues[queue as usize].driver_area = driver_area; in queue_set()
81 state.queues[queue as usize].device_area = device_area; in queue_set()
86 state.queues[queue as usize].size = 0; in queue_unset()
87 state.queues[queue as usize].descriptors = 0; in queue_unset()
88 state.queues[queue as usize].driver_area = 0; in queue_unset()
89 state.queues[queue as usize].device_area = 0; in queue_unset()
93 self.state.lock().unwrap().queues[queue as usize].descriptors != 0 in queue_used()
[all …]
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| D | vktSynchronizationInternallySynchronizedObjectsTests.cpp | 104 vector<VkQueue> queues; member
117 temp.queues.resize(count); in addQueueFamilyIndex()
148 for (int queueNdx = 0; queueNdx < static_cast<int>(queue.queues.size()); ++queueNdx) in getFreeQueue()
155 returnQueues = queue.queues[queueNdx]; in getFreeQueue()
216 MultiQueues &queues) in createAllocator() argument
218 const DeviceInterface &deviceInterface = queues.getDeviceInterface(); in createAllocator()
219 const VkDevice device = queues.getDevice(); in createAllocator()
248 MultiQueues &queues = *moveQueues; in createQueues() local
261 …queues.addQueueFamilyIndex(queuePropertiesNdx, queueFamilyProperties[queuePropertiesNdx].queueCoun… in createQueues()
265 if (queues.countQueueFamilyIndex() == 0) in createQueues()
[all …]
|
| /external/OpenCL-CTS/test_conformance/buffers/ |
| D | test_buffer_migrate.cpp | 51 static cl_int migrateMemObject(enum migrations migrate, cl_command_queue *queues, cl_mem *mem_objec… in migrateMemObject() argument
74 …if ((err = clEnqueueMigrateMemObjects(queues[j], 1, (const cl_mem *)(&mem_objects[i]), flags[i], 0… in migrateMemObject()
81 static cl_int restoreBuffer(cl_command_queue *queues, cl_mem *buffers, cl_uint num_devices, cl_mem_… in restoreBuffer() argument
90 …if ((err = clEnqueueWriteBuffer(queues[i], buffers[i], CL_TRUE, 0, sizeof(cl_uint)*BUFFER_SIZE, bu… in restoreBuffer()
110 cl_command_queue *queues; in test_buffer_migrate() local
131 queues = (cl_command_queue *)malloc(max_sub_devices * sizeof(cl_command_queue)); in test_buffer_migrate()
139 if ((devices == NULL) || (queues == NULL) || in test_buffer_migrate()
149 queues [i] = NULL; in test_buffer_migrate()
207 if ((queues[i] = clCreateCommandQueue(ctx, devices[i], 0, &err)) == NULL) { in test_buffer_migrate()
217 queues[0] = queue; in test_buffer_migrate()
[all …]
|
| D | test_image_migrate.cpp | 61 static cl_int migrateMemObject(enum migrations migrate, cl_command_queue *queues, cl_mem *mem_objec… in migrateMemObject() argument
85 if ((err = clEnqueueMigrateMemObjects(queues[j], 1, (const cl_mem *)(&mem_objects[i]), in migrateMemObject()
93 static cl_int restoreImage(cl_command_queue *queues, cl_mem *mem_objects, cl_uint num_devices, in restoreImage() argument
106 if ((err = clEnqueueWriteImage(queues[i], mem_objects[i], CL_TRUE, in restoreImage()
127 cl_command_queue *queues; in test_image_migrate() local
158 queues = (cl_command_queue *)malloc(max_sub_devices * sizeof(cl_command_queue)); in test_image_migrate()
166 if ((devices == NULL) || (queues == NULL) || in test_image_migrate()
176 queues [i] = NULL; in test_image_migrate()
239 if ((queues[i] = clCreateCommandQueue(ctx, devices[i], 0, &err)) == NULL) { in test_image_migrate()
249 queues[0] = queue; in test_image_migrate()
[all …]
|
| /external/OpenCL-CTS/test_conformance/events/ |
| D | test_event_dependencies.cpp | 61 queues[2]; // Not a wrapper so we don't autorelease if they are the same in test_event_enqueue_wait_for_events_run_test() local
178 queues[0] = queueWrappers[0]; in test_event_enqueue_wait_for_events_run_test()
179 queues[1] = queueWrappers[1]; in test_event_enqueue_wait_for_events_run_test()
190 queues[0] = queueWrappers[0]; in test_event_enqueue_wait_for_events_run_test()
191 queues[1] = (cl_command_queue)queues[0]; in test_event_enqueue_wait_for_events_run_test()
206 clEnqueueWriteBuffer(queues[0], data, CL_TRUE, 0, in test_event_enqueue_wait_for_events_run_test()
254 error = clEnqueueWriteBuffer(queues[0], data, CL_FALSE, 0, in test_event_enqueue_wait_for_events_run_test()
265 error = clEnqueueBarrierWithWaitList(queues[queue_to_use], 1, in test_event_enqueue_wait_for_events_run_test()
272 clEnqueueBarrierWithWaitList(queues[queue_to_use], 0, NULL, NULL); in test_event_enqueue_wait_for_events_run_test()
295 queues[queue_to_use], kernel1[loop_count], 1, NULL, threads, in test_event_enqueue_wait_for_events_run_test()
[all …]
|
| /external/ltp/testcases/kernel/syscalls/ipc/shmget/ |
| D | shmget03.c | 24 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()
|
| /external/ltp/testcases/kernel/syscalls/ipc/msgget/ |
| D | msgget03.c | 25 static int *queues; variable
47 queues = SAFE_MALLOC((maxmsgs - used_cnt) * sizeof(int)); in setup()
53 queues[queue_cnt++] = res; in setup()
64 if (!queues) in cleanup()
68 SAFE_MSGCTL(queues[num], IPC_RMID, NULL); in cleanup()
70 free(queues); in cleanup()
|
| /external/tensorflow/tensorflow/python/estimator/inputs/queues/ |
| D | __init__.py | 22 from tensorflow_estimator.python.estimator.inputs import queues
26 queues.__all__ = [s for s in dir(queues) if not s.startswith('__')]
28 from tensorflow_estimator.python.estimator.inputs.queues import *
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | mod.rs | 124 mut queues: BTreeMap<usize, Queue>, in activate()
129 if queues.len() != 4 { in activate()
132 queues.len(), in activate()
135 let control_queue = queues.remove(&0).unwrap(); in activate()
136 let event_queue = queues.remove(&1).unwrap(); in activate()
137 let tx_queue = queues.remove(&2).unwrap(); in activate()
138 let rx_queue = queues.remove(&3).unwrap(); in activate()
221 let queues = vec![ctrl_queue, event_queue, tx_queue, rx_queue]; in virtio_sleep() localVariable
222 return Ok(Some(BTreeMap::from_iter(queues.into_iter().enumerate()))); in virtio_sleep()
233 Some((mem, interrupt, queues)) => { in virtio_wake()
[all …]
|
| /external/crosvm/devices/src/virtio/vhost/ |
| D | vsock.rs | 177 mut queues: BTreeMap<usize, Queue>, in activate()
179 if queues.len() != NUM_QUEUES { in activate()
183 queues.len() in activate()
194 let mut event_queue = queues.remove(&2).unwrap(); in activate()
222 queues, in activate()
258 for (pos, _) in worker.queues.iter() { in reset()
295 let mut queues: BTreeMap<usize, Queue> = worker.queues; in virtio_sleep() localVariable
297 for (pos, _) in queues.iter() { in virtio_sleep()
306 queues.insert( in virtio_sleep()
310 return Ok(Some(BTreeMap::from_iter(queues))); in virtio_sleep()
[all …]
|
| /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/ublksrv/tests/generic/ |
| D | 003 | 37 local queues=1
40 [ ${type} == "loop" ] && queues=2
46 export T_TYPE_PARAMS="-t $type -q $queues -g $NEED_GET_DATA -d 127 --host $NBDSRV"
48 export T_TYPE_PARAMS="-t $type -q $queues -g $NEED_GET_DATA -f $file"
|
| /external/google-cloud-java/java-tasks/proto-google-cloud-tasks-v2/src/main/proto/google/cloud/tasks/v2/ |
| D | cloudtasks.proto | 43 // Lists queues.
48 get: "/v2/{parent=projects/*/locations/*}/queues"
56 get: "/v2/{name=projects/*/locations/*/queues/*}"
68 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
75 post: "/v2/{parent=projects/*/locations/*}/queues"
91 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
98 patch: "/v2/{queue.name=projects/*/locations/*/queues/*}"
112 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
119 delete: "/v2/{name=projects/*/locations/*/queues/*}"
132 post: "/v2/{name=projects/*/locations/*/queues/*}:purge"
[all …]
|
| /external/googleapis/google/cloud/tasks/v2/ |
| D | cloudtasks.proto | 43 // Lists queues.
48 get: "/v2/{parent=projects/*/locations/*}/queues"
56 get: "/v2/{name=projects/*/locations/*/queues/*}"
68 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
75 post: "/v2/{parent=projects/*/locations/*}/queues"
91 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
98 patch: "/v2/{queue.name=projects/*/locations/*/queues/*}"
112 // using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
119 delete: "/v2/{name=projects/*/locations/*/queues/*}"
132 post: "/v2/{name=projects/*/locations/*/queues/*}:purge"
[all …]
|