AsyncClient(const ClientConfig &config, std::function< ClientRpcContext *(StubType *, std::function< gpr_timespec()> next_issue, const RequestType &)> setup_ctx, std::function< std::unique_ptr< StubType >(std::shared_ptr< Channel >)> create_stub) | grpc::testing::AsyncClient< StubType, RequestType > | inline |
AwaitThreadsCompletion() | grpc::testing::Client | inline |
channels_ | grpc::testing::ClientImpl< StubType, RequestType > | protected |
cli_cqs_ | grpc::testing::AsyncClient< StubType, RequestType > | private |
Client() | grpc::testing::Client | inline |
ClientImpl(const ClientConfig &config, std::function< std::unique_ptr< StubType >(std::shared_ptr< Channel >)> create_stub) | grpc::testing::ClientImpl< StubType, RequestType > | inline |
closed_loop_ | grpc::testing::AsyncClient< StubType, RequestType > | |
CompleteThread() | grpc::testing::Client | inlineprotected |
cores_ | grpc::testing::ClientImpl< StubType, RequestType > | protected |
cq_ | grpc::testing::AsyncClient< StubType, RequestType > | private |
create_stub_ | grpc::testing::ClientImpl< StubType, RequestType > | protected |
DestroyMultithreading() final | grpc::testing::AsyncClient< StubType, RequestType > | inlineprivatevirtual |
EndThreads() | grpc::testing::Client | inlineprotected |
GetLatencyCollectionIntervalInSeconds() | grpc::testing::Client | inline |
GetPollCount() override | grpc::testing::AsyncClient< StubType, RequestType > | inlinevirtual |
interarrival_timer_ | grpc::testing::Client | protected |
IsClosedLoop() | grpc::testing::Client | inline |
last_reset_poll_count_ | grpc::testing::Client | protected |
Mark(bool reset) | grpc::testing::Client | inline |
MaybeStartRequests() | grpc::testing::Client | inlineprotected |
median_latency_collection_interval_seconds_ | grpc::testing::Client | protected |
next_issuers_ | grpc::testing::AsyncClient< StubType, RequestType > | private |
next_time_ | grpc::testing::Client | protected |
NextIssuer(int thread_idx) | grpc::testing::AsyncClient< StubType, RequestType > | inline |
grpc::testing::ClientImpl::NextIssuer(int thread_idx) | grpc::testing::Client | inlineprotected |
NextIssueTime(int thread_idx) | grpc::testing::Client | inline |
num_async_threads_ | grpc::testing::AsyncClient< StubType, RequestType > | protected |
NumThreads(const ClientConfig &config) | grpc::testing::AsyncClient< StubType, RequestType > | inlineprivate |
ProcessTag(size_t thread_idx, void *tag) | grpc::testing::AsyncClient< StubType, RequestType > | inlineprivate |
request() | grpc::testing::ClientImpl< StubType, RequestType > | inline |
request_ | grpc::testing::ClientImpl< StubType, RequestType > | protected |
SetupLoadTest(const ClientConfig &config, size_t num_threads) | grpc::testing::AsyncClient< StubType, RequestType > | inline |
grpc::testing::ClientImpl::SetupLoadTest(const ClientConfig &config, size_t num_threads) | grpc::testing::Client | inlineprotected |
shutdown_state_ | grpc::testing::AsyncClient< StubType, RequestType > | private |
start_requests_ | grpc::testing::Client | protected |
started_requests_ | grpc::testing::Client | protected |
StartThreads(size_t num_threads) | grpc::testing::Client | inlineprotected |
thread_completion_mu_ | grpc::testing::Client | protected |
thread_pool_done_ | grpc::testing::Client | protected |
ThreadCompleted() | grpc::testing::Client | inline |
ThreadFunc(size_t thread_idx, Client::Thread *t) final | grpc::testing::AsyncClient< StubType, RequestType > | inlineprivatevirtual |
threads_ | grpc::testing::Client | protected |
threads_complete_ | grpc::testing::Client | protected |
threads_remaining_ | grpc::testing::Client | protected |
timer_ | grpc::testing::Client | protected |
WaitForChannelsToConnect() | grpc::testing::ClientImpl< StubType, RequestType > | inline |
~AsyncClient() override | grpc::testing::AsyncClient< StubType, RequestType > | inline |
~Client() | grpc::testing::Client | inlinevirtual |
~ClientImpl() override | grpc::testing::ClientImpl< StubType, RequestType > | inline |