Inheritance diagram for grpc::testing::SynchronousStreamingPingPongClient:

[legend]

Public Member Functions
	SynchronousStreamingPingPongClient (const ClientConfig &config)

	~SynchronousStreamingPingPongClient () override

Public Member Functions inherited from grpc::testing::SynchronousStreamingClient< grpc::ClientReaderWriter< SimpleRequest, SimpleResponse > >
	SynchronousStreamingClient (const ClientConfig &config)

	~SynchronousStreamingClient () override

Public Member Functions inherited from grpc::testing::SynchronousClient
	SynchronousClient (const ClientConfig &config)

void	ThreadFunc (size_t thread_idx, Thread *t) override

	~SynchronousClient () 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 Member Functions
bool	InitThreadFuncImpl (size_t thread_idx) override

bool	ThreadFuncImpl (HistogramEntry *entry, size_t thread_idx) override

Additional Inherited Members
Protected Member Functions inherited from grpc::testing::SynchronousStreamingClient< grpc::ClientReaderWriter< SimpleRequest, SimpleResponse > >
void	CleanupAllStreams (const std::function< void(size_t)> &cleaner)

void	FinishStream (HistogramEntry *entry, size_t thread_idx)

Protected Member Functions inherited from grpc::testing::SynchronousClient
bool	WaitToIssue (int thread_idx)

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::SynchronousStreamingClient< grpc::ClientReaderWriter< SimpleRequest, SimpleResponse > >
std::vector< grpc::ClientContext >	context_

std::vector< int >	messages_issued_

const int	messages_per_stream_

std::vector< Bool >	shutdown_

std::vector< std::unique_ptr< grpc::ClientReaderWriter< SimpleRequest, SimpleResponse > > >	stream_

std::vector< std::mutex >	stream_mu_

Protected Attributes inherited from grpc::testing::SynchronousClient
size_t	num_threads_

std::vector< SimpleResponse >	responses_

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 218 of file client_sync.cc.

Constructor & Destructor Documentation

◆ SynchronousStreamingPingPongClient()

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

inlineexplicit

Definition at line 222 of file client_sync.cc.

◆ ~SynchronousStreamingPingPongClient()

grpc::testing::SynchronousStreamingPingPongClient::~SynchronousStreamingPingPongClient ( )

inlineoverride

Definition at line 224 of file client_sync.cc.

Member Function Documentation

◆ InitThreadFuncImpl()

bool grpc::testing::SynchronousStreamingPingPongClient::InitThreadFuncImpl ( size_t thread_idx )

inlineoverrideprivatevirtual

Implements grpc::testing::SynchronousClient.

Definition at line 230 of file client_sync.cc.

◆ ThreadFuncImpl()

bool grpc::testing::SynchronousStreamingPingPongClient::ThreadFuncImpl	(	HistogramEntry *	entry,
		size_t	thread_idx
	)

inlineoverrideprivatevirtual

Implements grpc::testing::SynchronousClient.

Definition at line 242 of file client_sync.cc.

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

client_sync.cc

Public Member Functions

Private Member Functions