AsyncClient(const ClientConfig &config, std::function< ClientRpcContext *(BenchmarkService::Stub *, std::function< gpr_timespec()> next_issue, const SimpleRequest &)> setup_ctx, std::function< std::unique_ptr< BenchmarkService::Stub >(std::shared_ptr< Channel >)> create_stub) | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | inline |
AsyncStreamingFromServerClient(const ClientConfig &config) | grpc::testing::AsyncStreamingFromServerClient | inlineexplicit |
AwaitThreadsCompletion() | grpc::testing::Client | inline |
channels_ | grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest > | protected |
CheckDone(const grpc::Status &, SimpleResponse *) | grpc::testing::AsyncStreamingFromServerClient | inlineprivatestatic |
cli_cqs_ | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | private |
Client() | grpc::testing::Client | inline |
ClientImpl(const ClientConfig &config, std::function< std::unique_ptr< BenchmarkService::Stub >(std::shared_ptr< Channel >)> create_stub) | grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest > | inline |
closed_loop_ | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | |
CompleteThread() | grpc::testing::Client | inlineprotected |
cores_ | grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest > | protected |
cq_ | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | private |
create_stub_ | grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest > | protected |
DestroyMultithreading() final | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | inlineprivatevirtual |
EndThreads() | grpc::testing::Client | inlineprotected |
GetLatencyCollectionIntervalInSeconds() | grpc::testing::Client | inline |
GetPollCount() override | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | 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< BenchmarkService::Stub, SimpleRequest > | private |
next_time_ | grpc::testing::Client | protected |
NextIssuer(int thread_idx) | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | inline |
ClientImpl< BenchmarkService::Stub, SimpleRequest >::NextIssuer(int thread_idx) | grpc::testing::Client | inlineprotected |
NextIssueTime(int thread_idx) | grpc::testing::Client | inline |
num_async_threads_ | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | protected |
NumThreads(const ClientConfig &config) | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | inlineprivate |
PrepareReq(BenchmarkService::Stub *stub, grpc::ClientContext *ctx, const SimpleRequest &req, CompletionQueue *cq) | grpc::testing::AsyncStreamingFromServerClient | inlineprivatestatic |
ProcessTag(size_t thread_idx, void *tag) | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | inlineprivate |
request() | grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest > | inline |
request_ | grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest > | protected |
SetupCtx(BenchmarkService::Stub *stub, std::function< gpr_timespec()> next_issue, const SimpleRequest &req) | grpc::testing::AsyncStreamingFromServerClient | inlineprivatestatic |
SetupLoadTest(const ClientConfig &config, size_t num_threads) | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | inline |
ClientImpl< BenchmarkService::Stub, SimpleRequest >::SetupLoadTest(const ClientConfig &config, size_t num_threads) | grpc::testing::Client | inlineprotected |
shutdown_state_ | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | 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< BenchmarkService::Stub, SimpleRequest > | 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< BenchmarkService::Stub, SimpleRequest > | inline |
~AsyncClient() override | grpc::testing::AsyncClient< BenchmarkService::Stub, SimpleRequest > | inline |
~AsyncStreamingFromServerClient() override | grpc::testing::AsyncStreamingFromServerClient | inline |
~Client() | grpc::testing::Client | inlinevirtual |
~ClientImpl() override | grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest > | inline |