Public Member Functions | Protected Member Functions | Private Member Functions | List of all members
grpc::testing::CallbackUnaryClient Class Referencefinal
Inheritance diagram for grpc::testing::CallbackUnaryClient:
Inheritance graph
[legend]

Public Member Functions

 CallbackUnaryClient (const ClientConfig &config)
 
 ~CallbackUnaryClient () override
 
- Public Member Functions inherited from grpc::testing::CallbackClient
 CallbackClient (const ClientConfig &config)
 
gpr_timespec NextRPCIssueTime ()
 
void NotifyMainThreadOfThreadCompletion ()
 
 ~CallbackClient () override
 
- Public Member Functions inherited from grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest >
 ClientImpl (const ClientConfig &config, std::function< std::unique_ptr< BenchmarkService::Stub >(std::shared_ptr< Channel >)> create_stub)
 
const SimpleRequest * request ()
 
void WaitForChannelsToConnect ()
 
 ~ClientImpl () override
 
- Public Member Functions inherited from grpc::testing::Client
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
 
- Protected Member Functions inherited from grpc::testing::CallbackClient
void ThreadFunc (size_t thread_idx, Thread *t) override
 
- Protected Member Functions inherited from grpc::testing::Client
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)
 

Additional Inherited Members

- Protected Attributes inherited from grpc::testing::CallbackClient
std::vector< std::unique_ptr< CallbackClientRpcContext > > ctx_
 
size_t num_threads_
 
size_t rpcs_done_
 
std::condition_variable shutdown_cv_
 
std::mutex shutdown_mu_
 
size_t total_outstanding_rpcs_
 
- Protected Attributes inherited from grpc::testing::ClientImpl< BenchmarkService::Stub, SimpleRequest >
std::vector< ClientChannelInfo > channels_
 
const int cores_
 
std::function< std::unique_ptr< BenchmarkService::Stub >const std::shared_ptr< Channel > &)> create_stub_
 
SimpleRequest request_
 
- Protected Attributes inherited from grpc::testing::Client
bool closed_loop_
 
InterarrivalTimer interarrival_timer_
 
int last_reset_poll_count_
 
double median_latency_collection_interval_seconds_
 
std::vector< gpr_timespecnext_time_
 
gpr_event start_requests_
 
bool started_requests_
 
std::mutex thread_completion_mu_
 
gpr_atm thread_pool_done_
 
std::vector< std::unique_ptr< Thread > > threads_
 
std::condition_variable threads_complete_
 
size_t threads_remaining_
 
std::unique_ptr< UsageTimertimer_
 

Detailed Description

Definition at line 145 of file test/cpp/qps/client_callback.cc.

Constructor & Destructor Documentation

◆ CallbackUnaryClient()

grpc::testing::CallbackUnaryClient::CallbackUnaryClient ( const ClientConfig &  config)
inlineexplicit

Definition at line 147 of file test/cpp/qps/client_callback.cc.

◆ ~CallbackUnaryClient()

grpc::testing::CallbackUnaryClient::~CallbackUnaryClient ( )
inlineoverride

Definition at line 157 of file test/cpp/qps/client_callback.cc.

Member Function Documentation

◆ InitThreadFuncImpl()

void grpc::testing::CallbackUnaryClient::InitThreadFuncImpl ( size_t  )
inlineoverrideprotectedvirtual

Implements grpc::testing::CallbackClient.

Definition at line 168 of file test/cpp/qps/client_callback.cc.

◆ IssueUnaryCallbackRpc()

void grpc::testing::CallbackUnaryClient::IssueUnaryCallbackRpc ( Thread t,
size_t  vector_idx 
)
inlineprivate

Definition at line 188 of file test/cpp/qps/client_callback.cc.

◆ ScheduleRpc()

void grpc::testing::CallbackUnaryClient::ScheduleRpc ( Thread t,
size_t  vector_idx 
)
inlineprivate

Definition at line 171 of file test/cpp/qps/client_callback.cc.

◆ ThreadFuncImpl()

bool grpc::testing::CallbackUnaryClient::ThreadFuncImpl ( Thread t,
size_t  thread_idx 
)
inlineoverrideprotectedvirtual

Implements grpc::testing::CallbackClient.

Definition at line 160 of file test/cpp/qps/client_callback.cc.


The documentation for this class was generated from the following file:


grpc
Author(s):
autogenerated on Fri May 16 2025 03:03:33