grpc::testing::CallbackStreamingPingPongClient Class Reference

Inheritance diagram for grpc::testing::CallbackStreamingPingPongClient:

Public Member Functions
	CallbackStreamingPingPongClient (const ClientConfig &config)
	~CallbackStreamingPingPongClient () override
Public Member Functions inherited from grpc::testing::CallbackStreamingClient
void	AddHistogramEntry (double start, bool ok, Thread *thread_ptr)
	CallbackStreamingClient (const ClientConfig &config)
int	messages_per_stream ()
	~CallbackStreamingClient () 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 ()

Additional Inherited Members
Protected Member Functions inherited from grpc::testing::CallbackClient
virtual void	InitThreadFuncImpl (size_t thread_idx)=0
void	ThreadFunc (size_t thread_idx, Thread *t) override
virtual bool	ThreadFuncImpl (Thread *t, size_t thread_idx)=0
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)
Protected Attributes inherited from grpc::testing::CallbackStreamingClient
const int	messages_per_stream_
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_timespec >	next_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< UsageTimer >	timer_

Detailed Description

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

Constructor & Destructor Documentation

CallbackStreamingPingPongClient()

grpc::testing::CallbackStreamingPingPongClient::CallbackStreamingPingPongClient ( const ClientConfig &  config )

inlineexplicit

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

~CallbackStreamingPingPongClient()

grpc::testing::CallbackStreamingPingPongClient::~CallbackStreamingPingPongClient ( )

inlineoverride

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

---

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

• test/cpp/qps/client_callback.cc