Home
last modified time | relevance | path

Searched refs:_pool (Results 1 – 25 of 29) sorted by relevance

12

/external/grpc-grpc/src/python/grpcio_reflection/grpc_reflection/v1alpha/
Dreflection.py55 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/
Dvideo_capture_linux.cc56 _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()
Dvideo_capture_linux.h61 Buffer* _pool; variable
/external/grpc-grpc/src/python/grpcio/grpc/
D_auth.py45 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/
Dpool.py187 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/
Dbenchmark_client.py101 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/
Dssh_multiplex.py143 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/
DEvolution.java37 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/
Dstream_util.py91 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/
Dmp_pool.py246 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/
Dpool.py160 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/
DTestObjectIdDeserialization.java158 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/
Dlvp_descriptor_set.c470 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()
Dlvp_query.c71 VkQueryPool _pool, in lvp_DestroyQueryPool() argument
75 LVP_FROM_HANDLE(lvp_query_pool, pool, _pool); in lvp_DestroyQueryPool()
/external/pigweed/pw_tokenizer/
Ddatabase.gni96 pool("$target_name._pool") {
102 pool = ":$target_name._pool"
/external/tinyxml2/
Dtinyxml2.h209 _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/
Dvolatile.py666 self._pool = pool
668 r = random.choice(self._pool)
/external/mesa3d/src/freedreno/vulkan/
Dtu_query.c198 VkQueryPool _pool, in tu_DestroyQueryPool() argument
202 TU_FROM_HANDLE(tu_query_pool, pool, _pool); in tu_DestroyQueryPool()
Dtu_descriptor_set.c608 VkDescriptorPool _pool, in tu_DestroyDescriptorPool() argument
612 TU_FROM_HANDLE(tu_descriptor_pool, pool, _pool); in tu_DestroyDescriptorPool()
/external/tensorflow/tensorflow/python/distribute/
Dcross_device_ops.py1072 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/
Dv3dv_descriptor_set.c508 VkDescriptorPool _pool, in v3dv_DestroyDescriptorPool() argument
512 V3DV_FROM_HANDLE(v3dv_descriptor_pool, pool, _pool); in v3dv_DestroyDescriptorPool()
/external/mesa3d/src/intel/vulkan/
DgenX_query.c212 VkQueryPool _pool, in genX()
216 ANV_FROM_HANDLE(anv_query_pool, pool, _pool); in genX()
/external/python/cpython2/Lib/test/
Dtest_multiprocessing.py1299 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/
Dradv_descriptor_set.c771 VkDescriptorPool _pool, in radv_DestroyDescriptorPool() argument
775 RADV_FROM_HANDLE(radv_descriptor_pool, pool, _pool); in radv_DestroyDescriptorPool()
/external/tensorflow/tensorflow/python/keras/engine/
Dtraining_utils_v1.py361 self._pool = get_copy_pool()
400 self._pool.apply_async(

12