Inheritance diagram for grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >:

Public Member Functions
	ClientRpcContextStreamingPingPongImpl (BenchmarkService::Stub stub, const RequestType &req, std::function< gpr_timespec()> next_issue, std::function< std::unique_ptr< grpc::ClientAsyncReaderWriter< RequestType, ResponseType >>(BenchmarkService::Stub , grpc::ClientContext , CompletionQueue )> prepare_req, std::function< void(grpc::Status, ResponseType *)> on_done)

bool	RunNextState (bool ok, HistogramEntry *entry) override

void	Start (CompletionQueue *cq, const ClientConfig &config) override

void	StartNewClone (CompletionQueue *cq) override

void	TryCancel () override

	~ClientRpcContextStreamingPingPongImpl () override

Public Member Functions inherited from grpc::testing::ClientRpcContext
	ClientRpcContext ()

virtual	~ClientRpcContext ()

Private Types
enum	State { INVALID, STREAM_IDLE, WAIT, READY_TO_WRITE, WRITE_DONE, READ_DONE, WRITES_DONE_DONE, FINISH_DONE }

Private Member Functions
void	StartInternal (CompletionQueue *cq, int messages_per_stream, bool coalesce)

Private Attributes
std::unique_ptr< Alarm >	alarm_

std::function< void(grpc::Status, ResponseType *)>	callback_

bool	coalesce_

grpc::ClientContext	context_

CompletionQueue *	cq_

int	messages_issued_

int	messages_per_stream_

std::function< gpr_timespec()>	next_issue_

State	next_state_

std::function< std::unique_ptr< grpc::ClientAsyncReaderWriter< RequestType, ResponseType > > BenchmarkService::Stub , grpc::ClientContext , CompletionQueue *)>	prepare_req_

const RequestType &	req_

ResponseType	response_

double	start_

grpc::Status	status_

std::unique_ptr< grpc::ClientAsyncReaderWriter< RequestType, ResponseType > >	stream_

BenchmarkService::Stub *	stub_

Additional Inherited Members
Static Public Member Functions inherited from grpc::testing::ClientRpcContext
static ClientRpcContext *	detag (void *t)

static void *	tag (ClientRpcContext *c)

Detailed Description

template<class RequestType, class ResponseType>
class grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >

Definition at line 338 of file client_async.cc.

Member Enumeration Documentation

◆ State

template<class RequestType , class ResponseType >

enum grpc::testing::ClientRpcContextStreamingPingPongImpl::State

private

Enumerator
INVALID
STREAM_IDLE
WAIT
READY_TO_WRITE
WRITE_DONE
READ_DONE
WRITES_DONE_DONE
FINISH_DONE

Definition at line 442 of file client_async.cc.

Constructor & Destructor Documentation

◆ ClientRpcContextStreamingPingPongImpl()

template<class RequestType , class ResponseType >

grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::ClientRpcContextStreamingPingPongImpl	(	BenchmarkService::Stub *	stub,
		const RequestType &	req,
		std::function< gpr_timespec()>	next_issue,
		std::function< std::unique_ptr< grpc::ClientAsyncReaderWriter< RequestType, ResponseType >>(BenchmarkService::Stub , grpc::ClientContext , CompletionQueue *)>	prepare_req,
		std::function< void(grpc::Status, ResponseType *)>	on_done
	)

inline

Definition at line 340 of file client_async.cc.

◆ ~ClientRpcContextStreamingPingPongImpl()

template<class RequestType , class ResponseType >

grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::~ClientRpcContextStreamingPingPongImpl ( )

inlineoverride

Definition at line 358 of file client_async.cc.

Member Function Documentation

◆ RunNextState()

template<class RequestType , class ResponseType >

bool grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::RunNextState	(	bool	ok,
		HistogramEntry *	entry
	)

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 362 of file client_async.cc.

◆ Start()

template<class RequestType , class ResponseType >

void grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::Start	(	CompletionQueue *	cq,
		const ClientConfig &	config
	)

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 359 of file client_async.cc.

◆ StartInternal()

template<class RequestType , class ResponseType >

void grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::StartInternal	(	CompletionQueue *	cq,
		int	messages_per_stream,
		bool	coalesce
	)

inlineprivate

Definition at line 470 of file client_async.cc.

◆ StartNewClone()

template<class RequestType , class ResponseType >

void grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::StartNewClone ( CompletionQueue * cq )

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 428 of file client_async.cc.

◆ TryCancel()

template<class RequestType , class ResponseType >

void grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::TryCancel ( )

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 433 of file client_async.cc.

Member Data Documentation

◆ alarm_

template<class RequestType , class ResponseType >

std::unique_ptr<Alarm> grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::alarm_

private

Definition at line 439 of file client_async.cc.

◆ callback_

template<class RequestType , class ResponseType >

std::function<void(grpc::Status, ResponseType*)> grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::callback_

private

Definition at line 453 of file client_async.cc.

◆ coalesce_

template<class RequestType , class ResponseType >

bool grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::coalesce_

private

Definition at line 468 of file client_async.cc.

◆ context_

template<class RequestType , class ResponseType >

grpc::ClientContext grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::context_

private

Definition at line 436 of file client_async.cc.

◆ cq_

template<class RequestType , class ResponseType >

CompletionQueue* grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::cq_

private

Definition at line 438 of file client_async.cc.

◆ messages_issued_

template<class RequestType , class ResponseType >

int grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::messages_issued_

private

Definition at line 466 of file client_async.cc.

◆ messages_per_stream_

template<class RequestType , class ResponseType >

int grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::messages_per_stream_

private

Definition at line 465 of file client_async.cc.

◆ next_issue_

template<class RequestType , class ResponseType >

std::function<gpr_timespec()> grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::next_issue_

private

Definition at line 454 of file client_async.cc.

◆ next_state_

template<class RequestType , class ResponseType >

State grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::next_state_

private

Definition at line 452 of file client_async.cc.

◆ prepare_req_

template<class RequestType , class ResponseType >

std::function< std::unique_ptr<grpc::ClientAsyncReaderWriter<RequestType, ResponseType> > BenchmarkService::Stub*, grpc::ClientContext*, CompletionQueue*)> grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::prepare_req_

private

Definition at line 458 of file client_async.cc.

◆ req_

template<class RequestType , class ResponseType >

const RequestType& grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::req_

private

Definition at line 440 of file client_async.cc.

◆ response_

template<class RequestType , class ResponseType >

ResponseType grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::response_

private

Definition at line 441 of file client_async.cc.

◆ start_

template<class RequestType , class ResponseType >

double grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::start_

private

Definition at line 460 of file client_async.cc.

◆ status_

template<class RequestType , class ResponseType >

grpc::Status grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::status_

private

Definition at line 459 of file client_async.cc.

◆ stream_

template<class RequestType , class ResponseType >

std::unique_ptr<grpc::ClientAsyncReaderWriter<RequestType, ResponseType> > grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::stream_

private

Definition at line 462 of file client_async.cc.

◆ stub_

template<class RequestType , class ResponseType >

BenchmarkService::Stub* grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >::stub_

private

Definition at line 437 of file client_async.cc.

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

client_async.cc

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

template<class RequestType, class ResponseType> class grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >

Member Enumeration Documentation

◆ State

Constructor & Destructor Documentation

◆ ClientRpcContextStreamingPingPongImpl()

◆ ~ClientRpcContextStreamingPingPongImpl()

Member Function Documentation

◆ RunNextState()

◆ Start()

◆ StartInternal()

◆ StartNewClone()

◆ TryCancel()

Member Data Documentation

◆ alarm_

◆ callback_

◆ coalesce_

◆ context_

◆ cq_

◆ messages_issued_

◆ messages_per_stream_

◆ next_issue_

◆ next_state_

◆ prepare_req_

◆ req_

◆ response_

◆ start_

◆ status_

◆ stream_

◆ stub_

template<class RequestType, class ResponseType>
class grpc::testing::ClientRpcContextStreamingPingPongImpl< RequestType, ResponseType >