/external/grpc-grpc/src/python/grpcio_reflection/grpc_reflection/v1alpha/ |
D | reflection.py | 55 self._pool = _POOL if pool is None else pool 59 descriptor = self._pool.FindFileByName(filename) 67 descriptor = self._pool.FindFileContainingSymbol( 76 message_descriptor = self._pool.FindMessageTypeByName( 78 extension_descriptor = self._pool.FindExtensionByNumber( 80 descriptor = self._pool.FindFileContainingSymbol( 89 message_descriptor = self._pool.FindMessageTypeByName( 94 for extension in self._pool.FindAllExtensions(
|
/external/webrtc/modules/video_capture/linux/ |
D | video_capture_linux.cc | 56 _pool(NULL) {} in VideoCaptureModuleV4L2() 308 _pool = new Buffer[rbuffer.count]; in AllocateVideoBuffers() 321 _pool[i].start = mmap(NULL, buffer.length, PROT_READ | PROT_WRITE, in AllocateVideoBuffers() 324 if (MAP_FAILED == _pool[i].start) { in AllocateVideoBuffers() 326 munmap(_pool[j].start, _pool[j].length); in AllocateVideoBuffers() 330 _pool[i].length = buffer.length; in AllocateVideoBuffers() 342 munmap(_pool[i].start, _pool[i].length); in DeAllocateVideoBuffers() 344 delete[] _pool; in DeAllocateVideoBuffers() 415 IncomingFrame((unsigned char*)_pool[buf.index].start, buf.bytesused, in CaptureProcess()
|
D | video_capture_linux.h | 61 Buffer* _pool; variable
|
/external/grpc-grpc/src/python/grpcio/grpc/ |
D | _auth.py | 45 self._pool = futures.ThreadPoolExecutor(max_workers=1) 55 future = self._pool.submit( 61 future = self._pool.submit(self._credentials.get_access_token) 65 self._pool.shutdown(wait=False)
|
/external/python/cpython3/Lib/multiprocessing/ |
D | pool.py | 187 self._pool = [] 214 for p in self._pool: 217 for p in self._pool: 226 self._processes, self._pool, self._inqueue, self._outqueue, 238 self._pool, self._cache) 254 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool, 305 self._pool, self._inqueue, 478 chunksize, extra = divmod(len(iterable), len(self._pool) * 4) 665 for p in self._pool: 745 self._pool = pool [all …]
|
/external/grpc-grpc/src/python/grpcio_tests/tests/qps/ |
D | benchmark_client.py | 101 self._pool = futures.ThreadPoolExecutor( 107 self._pool.submit(self._dispatch_request) 110 self._pool.shutdown(wait=True) 178 self._pool = futures.ThreadPoolExecutor( 194 self._pool.submit(stream.start) 199 self._pool.shutdown(wait=True)
|
/external/autotest/server/hosts/ |
D | ssh_multiplex.py | 143 self._pool = {} 163 conn = self._pool.get(key) 166 self._pool[key] = conn 171 for ssh in six.itervalues(self._pool):
|
/external/javassist/sample/evolve/ |
D | Evolution.java | 37 public void start(ClassPool _pool) throws NotFoundException { in start() argument 38 pool = _pool; in start() 42 trapMethod = _pool.getMethod("sample.evolve.Sample", "make"); in start() 45 public void onLoad(ClassPool _pool, String classname) in onLoad() argument 53 CtClass clazz = _pool.get(classname); in onLoad()
|
/external/grpc-grpc/src/python/grpcio/grpc/framework/foundation/ |
D | stream_util.py | 91 self._pool = pool 130 self._pool.submit(self._spin, self._sink, value, False) 138 self._pool.submit(self._spin, self._sink, _NO_VALUE, True) 148 self._pool.submit(self._spin, self._sink, value, True)
|
/external/python/cpython2/Doc/includes/ |
D | mp_pool.py | 246 for worker in pool._pool: 255 for worker in pool._pool: 273 for worker in pool._pool: 286 processes = pool._pool
|
/external/python/cpython2/Lib/multiprocessing/ |
D | pool.py | 160 self._pool = [] 175 self._pool, self._cache) 191 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool, 202 for i in reversed(range(len(self._pool))): 203 worker = self._pool[i] 209 del self._pool[i] 216 for i in range(self._processes - len(self._pool)): 222 self._pool.append(w) 309 chunksize, extra = divmod(len(iterable), len(self._pool) * 4) 478 for p in self._pool:
|
/external/jackson-databind/src/test/java/com/fasterxml/jackson/databind/objectid/ |
D | TestObjectIdDeserialization.java | 158 private Map<Object,WithCustomResolution> _pool; field in TestObjectIdDeserialization.PoolResolver 161 public PoolResolver(Map<Object,WithCustomResolution> pool){ _pool = pool; } in PoolResolver() 167 public Object resolveId(IdKey id){ return _pool.get(id.key); } in resolveId() 172 return resolverType.getClass() == getClass() && _pool != null && !_pool.isEmpty(); in canUseFor()
|
/external/mesa3d/src/gallium/frontends/lavapipe/ |
D | lvp_descriptor_set.c | 470 VkDescriptorPool _pool, in lvp_DestroyDescriptorPool() argument 474 LVP_FROM_HANDLE(lvp_descriptor_pool, pool, _pool); in lvp_DestroyDescriptorPool() 476 if (!_pool) in lvp_DestroyDescriptorPool() 486 VkDescriptorPool _pool, in lvp_ResetDescriptorPool() argument 490 LVP_FROM_HANDLE(lvp_descriptor_pool, pool, _pool); in lvp_ResetDescriptorPool()
|
D | lvp_query.c | 71 VkQueryPool _pool, in lvp_DestroyQueryPool() argument 75 LVP_FROM_HANDLE(lvp_query_pool, pool, _pool); in lvp_DestroyQueryPool()
|
/external/pigweed/pw_tokenizer/ |
D | database.gni | 96 pool("$target_name._pool") { 102 pool = ":$target_name._pool"
|
/external/tinyxml2/ |
D | tinyxml2.h | 209 _mem( _pool ), in DynArray() 216 if ( _mem != _pool ) { in ~DynArray() 310 if ( _mem != _pool ) { in EnsureCapacity() 319 T _pool[INITIAL_SIZE]; variable
|
/external/scapy/scapy/ |
D | volatile.py | 666 self._pool = pool 668 r = random.choice(self._pool)
|
/external/mesa3d/src/freedreno/vulkan/ |
D | tu_query.c | 198 VkQueryPool _pool, in tu_DestroyQueryPool() argument 202 TU_FROM_HANDLE(tu_query_pool, pool, _pool); in tu_DestroyQueryPool()
|
D | tu_descriptor_set.c | 608 VkDescriptorPool _pool, in tu_DestroyDescriptorPool() argument 612 TU_FROM_HANDLE(tu_descriptor_pool, pool, _pool); in tu_DestroyDescriptorPool()
|
/external/tensorflow/tensorflow/python/distribute/ |
D | cross_device_ops.py | 1072 self._pool = multiprocessing.pool.ThreadPool(len(self._devices)) 1238 outputs_by_device = self._pool.map(thread_fn, list(range(num_devices)))
|
/external/mesa3d/src/broadcom/vulkan/ |
D | v3dv_descriptor_set.c | 508 VkDescriptorPool _pool, in v3dv_DestroyDescriptorPool() argument 512 V3DV_FROM_HANDLE(v3dv_descriptor_pool, pool, _pool); in v3dv_DestroyDescriptorPool()
|
/external/mesa3d/src/intel/vulkan/ |
D | genX_query.c | 212 VkQueryPool _pool, in genX() 216 ANV_FROM_HANDLE(anv_query_pool, pool, _pool); in genX()
|
/external/python/cpython2/Lib/test/ |
D | test_multiprocessing.py | 1299 self.assertEqual(3, len(p._pool)) 1363 self.assertEqual(3, len(p._pool)) 1364 origworkerpids = [w.pid for w in p._pool] 1378 while countdown and not all(w.is_alive() for w in p._pool): 1381 finalworkerpids = [w.pid for w in p._pool]
|
/external/mesa3d/src/amd/vulkan/ |
D | radv_descriptor_set.c | 771 VkDescriptorPool _pool, in radv_DestroyDescriptorPool() argument 775 RADV_FROM_HANDLE(radv_descriptor_pool, pool, _pool); in radv_DestroyDescriptorPool()
|
/external/tensorflow/tensorflow/python/keras/engine/ |
D | training_utils_v1.py | 361 self._pool = get_copy_pool() 400 self._pool.apply_async(
|