Home
last modified time | relevance | path

Searched refs:maximum_concurrent_rpcs (Results 1 – 7 of 7) sorted by relevance

/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/aio/
H A D_server.py45 maximum_concurrent_rpcs: Optional[int],
66 maximum_concurrent_rpcs,
197 maximum_concurrent_rpcs: Optional[int] = None,
229 maximum_concurrent_rpcs,
/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/
H A D_server.py1083 maximum_concurrent_rpcs: Optional[int]
1097 maximum_concurrent_rpcs: Optional[int],
1108 self.maximum_concurrent_rpcs = maximum_concurrent_rpcs
1179 state.maximum_concurrent_rpcs is not None
1180 and state.active_rpc_count >= state.maximum_concurrent_rpcs
1306 maximum_concurrent_rpcs: Optional[int],
1319 maximum_concurrent_rpcs,
1371 maximum_concurrent_rpcs: Optional[int],
1381 maximum_concurrent_rpcs,
H A D__init__.py2172 maximum_concurrent_rpcs=None, argument
2209 maximum_concurrent_rpcs,
/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/
H A Dserver.pyx.pxi862 def __cinit__(self, int maximum_concurrent_rpcs): argument
863 if maximum_concurrent_rpcs <= 0:
864 raise ValueError("maximum_concurrent_rpcs should be a postive integer")
865 self._maximum_concurrent_rpcs = maximum_concurrent_rpcs
887 options, maximum_concurrent_rpcs): argument
919 if maximum_concurrent_rpcs is not None:
920 self._limiter = _ConcurrentRpcLimiter(maximum_concurrent_rpcs)
/aosp_15_r20/external/grpc-grpc/examples/python/cancellation/
H A Dserver.py97 futures.ThreadPoolExecutor(max_workers=1), maximum_concurrent_rpcs=1
/aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
H A D_resource_exhausted_test.py141 maximum_concurrent_rpcs=test_constants.THREAD_CONCURRENCY,
/aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests_aio/unit/
H A Dserver_test.py577 server = aio.server(maximum_concurrent_rpcs=_MAXIMUM_CONCURRENT_RPCS)