Inheritance diagram for grpc::testing::GenericAsyncStreamingClient:

[legend]

Public Member Functions
	GenericAsyncStreamingClient (const ClientConfig &config)

	~GenericAsyncStreamingClient () override

Public Member Functions inherited from grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >
	AsyncClient (const ClientConfig &config, std::function< ClientRpcContext (grpc::GenericStub , std::function< gpr_timespec()> next_issue, const ByteBuffer &)> setup_ctx, std::function< std::unique_ptr< grpc::GenericStub >(std::shared_ptr< Channel >)> create_stub)

int	GetPollCount () override

std::function< gpr_timespec()>	NextIssuer (int thread_idx)

void	SetupLoadTest (const ClientConfig &config, size_t num_threads)

	~AsyncClient () override

Public Member Functions inherited from grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >
	ClientImpl (const ClientConfig &config, std::function< std::unique_ptr< grpc::GenericStub >(std::shared_ptr< Channel >)> create_stub)

const ByteBuffer *	request ()

void	WaitForChannelsToConnect ()

	~ClientImpl () override

Public Member Functions inherited from grpc::testing::Client
void	AwaitThreadsCompletion ()

	Client ()

double	GetLatencyCollectionIntervalInSeconds ()

bool	IsClosedLoop ()

ClientStats	Mark (bool reset)

gpr_timespec	NextIssueTime (int thread_idx)

bool	ThreadCompleted ()

virtual	~Client ()

Static Private Member Functions
static void	CheckDone (const grpc::Status &, ByteBuffer *)

static std::unique_ptr< grpc::GenericClientAsyncReaderWriter >	PrepareReq (grpc::GenericStub stub, grpc::ClientContext ctx, const std::string &method_name, CompletionQueue *cq)

static ClientRpcContext *	SetupCtx (grpc::GenericStub *stub, std::function< gpr_timespec()> next_issue, const ByteBuffer &req)

Additional Inherited Members
Public Attributes inherited from grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >
bool	closed_loop_

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::AsyncClient< grpc::GenericStub, ByteBuffer >
const int	num_async_threads_

Protected Attributes inherited from grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >
std::vector< ClientChannelInfo >	channels_

const int	cores_

std::function< std::unique_ptr< grpc::GenericStub >const std::shared_ptr< Channel > &)>	create_stub_

ByteBuffer	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 905 of file client_async.cc.

Constructor & Destructor Documentation

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

inlineexplicit

Definition at line 908 of file client_async.cc.

grpc::testing::GenericAsyncStreamingClient::~GenericAsyncStreamingClient ( )

inlineoverride

Definition at line 914 of file client_async.cc.

static void grpc::testing::GenericAsyncStreamingClient::CheckDone	(	const grpc::Status &	,
		ByteBuffer *
	)

inlinestaticprivate

Definition at line 917 of file client_async.cc.

static std::unique_ptr<grpc::GenericClientAsyncReaderWriter> grpc::testing::GenericAsyncStreamingClient::PrepareReq	(	grpc::GenericStub *	stub,
		grpc::ClientContext *	ctx,
		const std::string &	method_name,
		CompletionQueue *	cq
	)

inlinestaticprivate

Definition at line 918 of file client_async.cc.

static ClientRpcContext* grpc::testing::GenericAsyncStreamingClient::SetupCtx	(	grpc::GenericStub *	stub,
		std::function< gpr_timespec()>	next_issue,
		const ByteBuffer &	req
	)

inlinestaticprivate

Definition at line 924 of file client_async.cc.

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