| /third_party/grpc/src/python/grpcio_reflection/grpc_reflection/v1alpha/ |
| D | _base.py | 54 self._pool = _POOL if pool is None else pool
58 descriptor = self._pool.FindFileByName(filename)
66 descriptor = self._pool.FindFileContainingSymbol(
75 message_descriptor = self._pool.FindMessageTypeByName(
77 extension_descriptor = self._pool.FindExtensionByNumber(
79 descriptor = self._pool.FindFileContainingSymbol(
88 message_descriptor = self._pool.FindMessageTypeByName(
92 self._pool.FindAllExtensions(message_descriptor)))
|
| /third_party/grpc/src/python/grpcio_tests/tests/qps/ |
| D | benchmark_client.py | 105 self._pool = futures.ThreadPoolExecutor(
111 self._pool.submit(self._dispatch_request)
114 self._pool.shutdown(wait=True)
182 self._pool = futures.ThreadPoolExecutor(
198 self._pool.submit(stream.start)
203 self._pool.shutdown(wait=True)
213 self._pool = None
215 self._pool = futures.ThreadPoolExecutor(
221 if self._pool is None:
226 self._pool.submit(self._one_stream_streaming_rpc)
[all …]
|
| /third_party/python/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 …]
|
| /third_party/grpc/src/python/grpcio/grpc/framework/foundation/ |
| D | stream_util.py | 90 self._pool = pool
129 self._pool.submit(self._spin, self._sink, value, False)
137 self._pool.submit(self._spin, self._sink, _NO_VALUE, True)
147 self._pool.submit(self._spin, self._sink, value, True)
|
| /third_party/mesa3d/src/panfrost/vulkan/ |
| D | panvk_descriptor_set.c | 400 VkDescriptorPool _pool, in panvk_DestroyDescriptorPool() argument
404 VK_FROM_HANDLE(panvk_descriptor_pool, pool, _pool); in panvk_DestroyDescriptorPool()
412 VkDescriptorPool _pool, in panvk_ResetDescriptorPool() argument
415 VK_FROM_HANDLE(panvk_descriptor_pool, pool, _pool); in panvk_ResetDescriptorPool()
|
| D | panvk_query.c | 38 VkQueryPool _pool, in panvk_DestroyQueryPool() argument
|
| /third_party/mesa3d/src/gallium/frontends/lavapipe/ |
| D | lvp_query.c | 74 VkQueryPool _pool, in lvp_DestroyQueryPool() argument
78 LVP_FROM_HANDLE(lvp_query_pool, pool, _pool); in lvp_DestroyQueryPool()
|
| D | lvp_descriptor_set.c | 515 VkDescriptorPool _pool, in lvp_DestroyDescriptorPool() argument
519 LVP_FROM_HANDLE(lvp_descriptor_pool, pool, _pool); in lvp_DestroyDescriptorPool()
521 if (!_pool) in lvp_DestroyDescriptorPool()
531 VkDescriptorPool _pool, in lvp_ResetDescriptorPool() argument
535 LVP_FROM_HANDLE(lvp_descriptor_pool, pool, _pool); in lvp_ResetDescriptorPool()
|
| /third_party/flatbuffers/python/flatbuffers/ |
| D | flexbuffers.py | 950 self._pool = [] # sorted list of (data, offset) tuples
954 index = _BinarySearch(self._pool, do, lambda a, b: a[0] < b[0])
956 _, offset = self._pool[index]
958 self._pool.insert(index, do)
962 self._pool = []
966 return [data for data, _ in self._pool]
|
| /third_party/mesa3d/src/broadcom/vulkan/ |
| D | v3dv_descriptor_set.c | 492 VkDescriptorPool _pool, in v3dv_DestroyDescriptorPool() argument
496 V3DV_FROM_HANDLE(v3dv_descriptor_pool, pool, _pool); in v3dv_DestroyDescriptorPool()
|
| D | v3dv_meta_copy.c | 1486 const VkDescriptorPool _pool = cmd_buffer->meta.texel_buffer_copy.dspool; in create_texel_buffer_copy_descriptor_pool() local
1489 cmd_buffer, (uintptr_t) _pool, in create_texel_buffer_copy_descriptor_pool()
1493 v3dv_descriptor_pool_from_handle(_pool); in create_texel_buffer_copy_descriptor_pool()
3707 const VkDescriptorPool _pool = cmd_buffer->meta.blit.dspool; in create_blit_descriptor_pool() local
3710 cmd_buffer, (uintptr_t) _pool, in create_blit_descriptor_pool()
3714 v3dv_descriptor_pool_from_handle(_pool); in create_blit_descriptor_pool()
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/test/ |
| D | flutter_web_platform.dart | 454 final Pool _pool = Pool(8);
583 return await _pool.withResource<RunnerSuite>(() async {
|
| /third_party/mesa3d/src/freedreno/vulkan/ |
| D | tu_query.c | 347 VkQueryPool _pool, in tu_DestroyQueryPool() argument
351 TU_FROM_HANDLE(tu_query_pool, pool, _pool); in tu_DestroyQueryPool()
|
| D | tu_descriptor_set.c | 679 VkDescriptorPool _pool, in tu_DestroyDescriptorPool() argument
683 TU_FROM_HANDLE(tu_descriptor_pool, pool, _pool); in tu_DestroyDescriptorPool()
|
| /third_party/mesa3d/src/intel/vulkan/ |
| D | genX_query.c | 236 VkQueryPool _pool, in genX()
240 ANV_FROM_HANDLE(anv_query_pool, pool, _pool); in genX()
|
| D | anv_descriptor_set.c | 900 VkDescriptorPool _pool, in anv_DestroyDescriptorPool() argument
904 ANV_FROM_HANDLE(anv_descriptor_pool, pool, _pool); in anv_DestroyDescriptorPool()
|
| /third_party/mesa3d/src/amd/vulkan/ |
| D | radv_descriptor_set.c | 850 radv_DestroyDescriptorPool(VkDevice _device, VkDescriptorPool _pool, in radv_DestroyDescriptorPool() argument
854 RADV_FROM_HANDLE(radv_descriptor_pool, pool, _pool); in radv_DestroyDescriptorPool()
|
| D | radv_query.c | 980 radv_DestroyQueryPool(VkDevice _device, VkQueryPool _pool, const VkAllocationCallbacks *pAllocator) in radv_DestroyQueryPool() argument
983 RADV_FROM_HANDLE(radv_query_pool, pool, _pool); in radv_DestroyQueryPool()
|
| /third_party/python/Lib/test/ |
| D | _test_multiprocessing.py | 2553 self.assertEqual(3, len(p._pool))
2761 self.assertEqual(3, len(p._pool))
2762 origworkerpids = [w.pid for w in p._pool]
2776 while countdown and not all(w.is_alive() for w in p._pool):
2779 finalworkerpids = [w.pid for w in p._pool]
|
| /third_party/mindspore/mindspore/dataset/engine/ |
| D | datasets.py | 2274 for pool in self.process_pool._pool: # pylint: disable=W0212
2810 for pool in self.process_pool._pool: # pylint: disable=W0212
|
| /third_party/gstreamer/gstreamer/docs/random/old/ |
| D | ChangeLog.gstreamer | 42 * gst/gstbuffer.[ch]: Add functions gst_buffer[_pool]_get_type()
|