Inheritance diagram for grpc::testing::CallbackStreamingPingPongClientImpl:

[legend]

Public Member Functions
	CallbackStreamingPingPongClientImpl (const ClientConfig &config)

void	InitThreadFuncImpl (size_t) override

bool	ThreadFuncImpl (Client::Thread *t, size_t thread_idx) override

	~CallbackStreamingPingPongClientImpl () override

Public Member Functions inherited from grpc::testing::CallbackStreamingPingPongClient
	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 ()

Private Attributes
std::vector< std::unique_ptr< CallbackStreamingPingPongReactor > >	reactor_

Additional Inherited Members
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)

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_