Public Member Functions | |
CallbackUnaryClient (const ClientConfig &config) | |
~CallbackUnaryClient () override | |
![]() | |
CallbackClient (const ClientConfig &config) | |
gpr_timespec | NextRPCIssueTime () |
void | NotifyMainThreadOfThreadCompletion () |
~CallbackClient () override | |
![]() | |
ClientImpl (const ClientConfig &config, std::function< std::unique_ptr< BenchmarkService::Stub >(std::shared_ptr< Channel >)> create_stub) | |
const SimpleRequest * | request () |
void | WaitForChannelsToConnect () |
~ClientImpl () override | |
![]() | |
void | AwaitThreadsCompletion () |
Client () | |
double | GetLatencyCollectionIntervalInSeconds () |
virtual int | GetPollCount () |
bool | IsClosedLoop () |
ClientStats | Mark (bool reset) |
gpr_timespec | NextIssueTime (int thread_idx) |
bool | ThreadCompleted () |
virtual | ~Client () |
Protected Member Functions | |
void | InitThreadFuncImpl (size_t) override |
bool | ThreadFuncImpl (Thread *t, size_t thread_idx) override |
![]() | |
void | ThreadFunc (size_t thread_idx, Thread *t) override |
![]() | |
void | CompleteThread () |
void | EndThreads () |
void | MaybeStartRequests () |
std::function< gpr_timespec()> | NextIssuer (int thread_idx) |
void | SetupLoadTest (const ClientConfig &config, size_t num_threads) |
void | StartThreads (size_t num_threads) |
Private Member Functions | |
void | IssueUnaryCallbackRpc (Thread *t, size_t vector_idx) |
void | ScheduleRpc (Thread *t, size_t vector_idx) |
Definition at line 145 of file test/cpp/qps/client_callback.cc.
|
inlineexplicit |
Definition at line 147 of file test/cpp/qps/client_callback.cc.
|
inlineoverride |
Definition at line 157 of file test/cpp/qps/client_callback.cc.
|
inlineoverrideprotectedvirtual |
Implements grpc::testing::CallbackClient.
Definition at line 168 of file test/cpp/qps/client_callback.cc.
|
inlineprivate |
Definition at line 188 of file test/cpp/qps/client_callback.cc.
|
inlineprivate |
Definition at line 171 of file test/cpp/qps/client_callback.cc.
|
inlineoverrideprotectedvirtual |
Implements grpc::testing::CallbackClient.
Definition at line 160 of file test/cpp/qps/client_callback.cc.