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

Public Member Functions
	ClientRpcContextStreamingFromClientImpl (BenchmarkService::Stub stub, const RequestType &req, std::function< gpr_timespec()> next_issue, std::function< std::unique_ptr< grpc::ClientAsyncWriter< RequestType >>(BenchmarkService::Stub , grpc::ClientContext , ResponseType , 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

	~ClientRpcContextStreamingFromClientImpl () 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 }

Private Member Functions
void	StartInternal (CompletionQueue *cq)

Private Attributes
std::unique_ptr< Alarm >	alarm_

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

grpc::ClientContext	context_

CompletionQueue *	cq_

std::function< gpr_timespec()>	next_issue_

State	next_state_

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

const RequestType &	req_

ResponseType	response_

double	start_

grpc::Status	status_

std::unique_ptr< grpc::ClientAsyncWriter< RequestType > >	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::ClientRpcContextStreamingFromClientImpl< RequestType, ResponseType >

Definition at line 524 of file client_async.cc.

Member Enumeration Documentation

◆ State

template<class RequestType , class ResponseType >

enum grpc::testing::ClientRpcContextStreamingFromClientImpl::State

private

Enumerator
INVALID
STREAM_IDLE
WAIT
READY_TO_WRITE
WRITE_DONE

Definition at line 598 of file client_async.cc.

Constructor & Destructor Documentation

◆ ClientRpcContextStreamingFromClientImpl()

template<class RequestType , class ResponseType >

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

inline

Definition at line 526 of file client_async.cc.

◆ ~ClientRpcContextStreamingFromClientImpl()

template<class RequestType , class ResponseType >

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

inlineoverride

Definition at line 543 of file client_async.cc.

Member Function Documentation

◆ RunNextState()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 548 of file client_async.cc.

◆ Start()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 544 of file client_async.cc.

◆ StartInternal()

template<class RequestType , class ResponseType >

void grpc::testing::ClientRpcContextStreamingFromClientImpl< RequestType, ResponseType >::StartInternal ( CompletionQueue * cq )

inlineprivate

Definition at line 616 of file client_async.cc.

◆ StartNewClone()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 584 of file client_async.cc.

◆ TryCancel()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 589 of file client_async.cc.

Member Data Documentation

◆ alarm_

template<class RequestType , class ResponseType >

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

private

Definition at line 595 of file client_async.cc.

◆ callback_

template<class RequestType , class ResponseType >

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

private

Definition at line 606 of file client_async.cc.

◆ context_

template<class RequestType , class ResponseType >

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

private

Definition at line 592 of file client_async.cc.

◆ cq_

template<class RequestType , class ResponseType >

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

private

Definition at line 594 of file client_async.cc.

◆ next_issue_

template<class RequestType , class ResponseType >

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

private

Definition at line 607 of file client_async.cc.

◆ next_state_

template<class RequestType , class ResponseType >

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

private

Definition at line 605 of file client_async.cc.

◆ prepare_req_

template<class RequestType , class ResponseType >

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

private

Definition at line 611 of file client_async.cc.

◆ req_

template<class RequestType , class ResponseType >

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

private

Definition at line 596 of file client_async.cc.

◆ response_

template<class RequestType , class ResponseType >

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

private

Definition at line 597 of file client_async.cc.

◆ start_

template<class RequestType , class ResponseType >

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

private

Definition at line 613 of file client_async.cc.

◆ status_

template<class RequestType , class ResponseType >

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

private

Definition at line 612 of file client_async.cc.

◆ stream_

template<class RequestType , class ResponseType >

std::unique_ptr<grpc::ClientAsyncWriter<RequestType> > grpc::testing::ClientRpcContextStreamingFromClientImpl< RequestType, ResponseType >::stream_

private

Definition at line 614 of file client_async.cc.

◆ stub_

template<class RequestType , class ResponseType >

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

private

Definition at line 593 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::ClientRpcContextStreamingFromClientImpl< RequestType, ResponseType >

Member Enumeration Documentation

◆ State

Constructor & Destructor Documentation

◆ ClientRpcContextStreamingFromClientImpl()

◆ ~ClientRpcContextStreamingFromClientImpl()

Member Function Documentation

◆ RunNextState()

◆ Start()

◆ StartInternal()

◆ StartNewClone()

◆ TryCancel()

Member Data Documentation

◆ alarm_

◆ callback_

◆ context_

◆ cq_

◆ next_issue_

◆ next_state_

◆ prepare_req_

◆ req_

◆ response_

◆ start_

◆ status_

◆ stream_

◆ stub_

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