grpc::testing::SynchronousStreamingClient< StreamType > Class Template Reference

Inheritance diagram for grpc::testing::SynchronousStreamingClient< StreamType >:

Classes
struct	Bool

Public Member Functions
	SynchronousStreamingClient (const ClientConfig &config)
	~SynchronousStreamingClient () override
Public Member Functions inherited from grpc::testing::SynchronousClient
virtual bool	InitThreadFuncImpl (size_t thread_idx)=0
	SynchronousClient (const ClientConfig &config)
void	ThreadFunc (size_t thread_idx, Thread *t) override
virtual bool	ThreadFuncImpl (HistogramEntry *entry, size_t thread_idx)=0
	~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 ()

Protected Member Functions
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
std::vector< grpc::ClientContext >	context_
std::vector< int >	messages_issued_
const int	messages_per_stream_
std::vector< Bool >	shutdown_
std::vector< std::unique_ptr< StreamType > >	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_

Private Member Functions
void	DestroyMultithreading () final

Detailed Description

template<class StreamType>
class grpc::testing::SynchronousStreamingClient< StreamType >

Definition at line 144 of file client_sync.cc.

Constructor & Destructor Documentation

SynchronousStreamingClient()

template<class StreamType >

grpc::testing::SynchronousStreamingClient< StreamType >::SynchronousStreamingClient ( const ClientConfig &  config )

inlineexplicit

Definition at line 146 of file client_sync.cc.

~SynchronousStreamingClient()

template<class StreamType >

grpc::testing::SynchronousStreamingClient< StreamType >::~SynchronousStreamingClient ( )

inlineoverride

Definition at line 156 of file client_sync.cc.

Member Function Documentation

CleanupAllStreams()

template<class StreamType >

void grpc::testing::SynchronousStreamingClient< StreamType >::CleanupAllStreams ( const std::function< void(size_t)> &  cleaner )

inlineprotected

Definition at line 194 of file client_sync.cc.

DestroyMultithreading()

template<class StreamType >

void grpc::testing::SynchronousStreamingClient< StreamType >::DestroyMultithreading ( )

inlinefinalprivatevirtual

Implements grpc::testing::Client.

Definition at line 211 of file client_sync.cc.

FinishStream()

template<class StreamType >

void grpc::testing::SynchronousStreamingClient< StreamType >::FinishStream ( HistogramEntry *  entry, size_t  thread_idx  )

inlineprotected

Definition at line 177 of file client_sync.cc.

Member Data Documentation

context_

template<class StreamType >

std::vector<grpc::ClientContext> grpc::testing::SynchronousStreamingClient< StreamType >::context_

protected

Definition at line 164 of file client_sync.cc.

messages_issued_

template<class StreamType >

std::vector<int> grpc::testing::SynchronousStreamingClient< StreamType >::messages_issued_

protected

Definition at line 175 of file client_sync.cc.

messages_per_stream_

template<class StreamType >

const int grpc::testing::SynchronousStreamingClient< StreamType >::messages_per_stream_

protected

Definition at line 174 of file client_sync.cc.

shutdown_

template<class StreamType >

std::vector<Bool> grpc::testing::SynchronousStreamingClient< StreamType >::shutdown_

protected

Definition at line 173 of file client_sync.cc.

stream_

template<class StreamType >

std::vector<std::unique_ptr<StreamType> > grpc::testing::SynchronousStreamingClient< StreamType >::stream_

protected

Definition at line 165 of file client_sync.cc.

stream_mu_

template<class StreamType >

std::vector<std::mutex> grpc::testing::SynchronousStreamingClient< StreamType >::stream_mu_

protected

Definition at line 167 of file client_sync.cc.

---

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

• client_sync.cc