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

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

bool	RunNextState (bool, HistogramEntry *entry) override

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

void	StartNewClone (CompletionQueue *cq) override

void	TryCancel () override

	~ClientRpcContextUnaryImpl () override

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

virtual	~ClientRpcContext ()

Private Types
enum	State { INVALID, READY, RESP_DONE }

Private Member Functions
void	StartInternal (CompletionQueue *cq)

Private Attributes
std::unique_ptr< Alarm >	alarm_

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

grpc::ClientContext	context_

CompletionQueue *	cq_

std::function< gpr_timespec()>	next_issue_

State	next_state_

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

const RequestType &	req_

ResponseType	response_

std::unique_ptr< grpc::ClientAsyncResponseReader< ResponseType > >	response_reader_

double	start_

grpc::Status	status_

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

Definition at line 66 of file client_async.cc.

Member Enumeration Documentation

◆ State

template<class RequestType , class ResponseType >

enum grpc::testing::ClientRpcContextUnaryImpl::State

private

Enumerator
INVALID
READY
RESP_DONE

Definition at line 127 of file client_async.cc.

Constructor & Destructor Documentation

◆ ClientRpcContextUnaryImpl()

template<class RequestType , class ResponseType >

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

inline

Definition at line 68 of file client_async.cc.

◆ ~ClientRpcContextUnaryImpl()

template<class RequestType , class ResponseType >

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

inlineoverride

Definition at line 86 of file client_async.cc.

Member Function Documentation

◆ RunNextState()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 91 of file client_async.cc.

◆ Start()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 87 of file client_async.cc.

◆ StartInternal()

template<class RequestType , class ResponseType >

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

inlineprivate

Definition at line 140 of file client_async.cc.

◆ StartNewClone()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 113 of file client_async.cc.

◆ TryCancel()

template<class RequestType , class ResponseType >

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

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 118 of file client_async.cc.

Member Data Documentation

◆ alarm_

template<class RequestType , class ResponseType >

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

private

Definition at line 124 of file client_async.cc.

◆ callback_

template<class RequestType , class ResponseType >

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

private

Definition at line 129 of file client_async.cc.

◆ context_

template<class RequestType , class ResponseType >

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

private

Definition at line 121 of file client_async.cc.

◆ cq_

template<class RequestType , class ResponseType >

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

private

Definition at line 123 of file client_async.cc.

◆ next_issue_

template<class RequestType , class ResponseType >

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

private

Definition at line 130 of file client_async.cc.

◆ next_state_

template<class RequestType , class ResponseType >

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

private

Definition at line 128 of file client_async.cc.

◆ prepare_req_

template<class RequestType , class ResponseType >

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

private

Definition at line 134 of file client_async.cc.

◆ req_

template<class RequestType , class ResponseType >

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

private

Definition at line 125 of file client_async.cc.

◆ response_

template<class RequestType , class ResponseType >

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

private

Definition at line 126 of file client_async.cc.

◆ response_reader_

template<class RequestType , class ResponseType >

std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType> > grpc::testing::ClientRpcContextUnaryImpl< RequestType, ResponseType >::response_reader_

private

Definition at line 138 of file client_async.cc.

◆ start_

template<class RequestType , class ResponseType >

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

private

Definition at line 136 of file client_async.cc.

◆ status_

template<class RequestType , class ResponseType >

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

private

Definition at line 135 of file client_async.cc.

◆ stub_

template<class RequestType , class ResponseType >

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

private

Definition at line 122 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::ClientRpcContextUnaryImpl< RequestType, ResponseType >

Member Enumeration Documentation

◆ State

Constructor & Destructor Documentation

◆ ClientRpcContextUnaryImpl()

◆ ~ClientRpcContextUnaryImpl()

Member Function Documentation

◆ RunNextState()

◆ Start()

◆ StartInternal()

◆ StartNewClone()

◆ TryCancel()

Member Data Documentation

◆ alarm_

◆ callback_

◆ context_

◆ cq_

◆ next_issue_

◆ next_state_

◆ prepare_req_

◆ req_

◆ response_

◆ response_reader_

◆ start_

◆ status_

◆ stub_

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