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

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

	~ClientRpcContextStreamingFromServerImpl () override

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

virtual	~ClientRpcContext ()

Private Types
enum	State { INVALID, STREAM_IDLE, READ_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::ClientAsyncReader< ResponseType > > BenchmarkService::Stub , grpc::ClientContext , const RequestType &, CompletionQueue *)>	prepare_req_

const RequestType &	req_

ResponseType	response_

double	start_

grpc::Status	status_

std::unique_ptr< grpc::ClientAsyncReader< 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::ClientRpcContextStreamingFromServerImpl< RequestType, ResponseType >

Definition at line 656 of file client_async.cc.

Member Enumeration Documentation

◆ State

template<class RequestType , class ResponseType >

enum grpc::testing::ClientRpcContextStreamingFromServerImpl::State

private

Enumerator
INVALID
STREAM_IDLE
READ_DONE

Definition at line 719 of file client_async.cc.

Constructor & Destructor Documentation

◆ ClientRpcContextStreamingFromServerImpl()

template<class RequestType , class ResponseType >

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

inline

Definition at line 658 of file client_async.cc.

◆ ~ClientRpcContextStreamingFromServerImpl()

template<class RequestType , class ResponseType >

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

inlineoverride

Definition at line 675 of file client_async.cc.

Member Function Documentation

◆ RunNextState()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 680 of file client_async.cc.

◆ Start()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 676 of file client_async.cc.

◆ StartInternal()

template<class RequestType , class ResponseType >

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

inlineprivate

Definition at line 731 of file client_async.cc.

◆ StartNewClone()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 705 of file client_async.cc.

◆ TryCancel()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 710 of file client_async.cc.

Member Data Documentation

◆ alarm_

template<class RequestType , class ResponseType >

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

private

Definition at line 716 of file client_async.cc.

◆ callback_

template<class RequestType , class ResponseType >

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

private

Definition at line 721 of file client_async.cc.

◆ context_

template<class RequestType , class ResponseType >

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

private

Definition at line 713 of file client_async.cc.

◆ cq_

template<class RequestType , class ResponseType >

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

private

Definition at line 715 of file client_async.cc.

◆ next_issue_

template<class RequestType , class ResponseType >

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

private

Definition at line 722 of file client_async.cc.

◆ next_state_

template<class RequestType , class ResponseType >

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

private

Definition at line 720 of file client_async.cc.

◆ prepare_req_

template<class RequestType , class ResponseType >

std::function<std::unique_ptr<grpc::ClientAsyncReader<ResponseType> > BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&, CompletionQueue*)> grpc::testing::ClientRpcContextStreamingFromServerImpl< RequestType, ResponseType >::prepare_req_

private

Definition at line 726 of file client_async.cc.

◆ req_

template<class RequestType , class ResponseType >

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

private

Definition at line 717 of file client_async.cc.

◆ response_

template<class RequestType , class ResponseType >

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

private

Definition at line 718 of file client_async.cc.

◆ start_

template<class RequestType , class ResponseType >

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

private

Definition at line 728 of file client_async.cc.

◆ status_

template<class RequestType , class ResponseType >

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

private

Definition at line 727 of file client_async.cc.

◆ stream_

template<class RequestType , class ResponseType >

std::unique_ptr<grpc::ClientAsyncReader<ResponseType> > grpc::testing::ClientRpcContextStreamingFromServerImpl< RequestType, ResponseType >::stream_

private

Definition at line 729 of file client_async.cc.

◆ stub_

template<class RequestType , class ResponseType >

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

private

Definition at line 714 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::ClientRpcContextStreamingFromServerImpl< RequestType, ResponseType >

Member Enumeration Documentation

◆ State

Constructor & Destructor Documentation

◆ ClientRpcContextStreamingFromServerImpl()

◆ ~ClientRpcContextStreamingFromServerImpl()

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::ClientRpcContextStreamingFromServerImpl< RequestType, ResponseType >