grpc::testing::ClientRpcContextGenericStreamingImpl Class Reference

Inheritance diagram for grpc::testing::ClientRpcContextGenericStreamingImpl:

Public Member Functions
	ClientRpcContextGenericStreamingImpl (grpc::GenericStub *stub, const ByteBuffer &req, std::function< gpr_timespec()> next_issue, std::function< std::unique_ptr< grpc::GenericClientAsyncReaderWriter >(grpc::GenericStub *, grpc::ClientContext *, const std::string &method_name, CompletionQueue *)> prepare_req, std::function< void(grpc::Status, ByteBuffer *)> 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
	~ClientRpcContextGenericStreamingImpl () 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)

Private Attributes
std::unique_ptr< Alarm >	alarm_
std::function< void(grpc::Status, ByteBuffer *)>	callback_
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::GenericClientAsyncReaderWriter > grpc::GenericStub *, grpc::ClientContext *, const std::string &, CompletionQueue *)>	prepare_req_
ByteBuffer	req_
ByteBuffer	response_
double	start_
grpc::Status	status_
std::unique_ptr< grpc::GenericClientAsyncReaderWriter >	stream_
grpc::GenericStub *	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

Definition at line 771 of file client_async.cc.

Member Enumeration Documentation

State

enum grpc::testing::ClientRpcContextGenericStreamingImpl::State

private

Enumerator
INVALID
STREAM_IDLE
WAIT
READY_TO_WRITE
WRITE_DONE
READ_DONE
WRITES_DONE_DONE
FINISH_DONE

Definition at line 863 of file client_async.cc.

Constructor & Destructor Documentation

ClientRpcContextGenericStreamingImpl()

grpc::testing::ClientRpcContextGenericStreamingImpl::ClientRpcContextGenericStreamingImpl ( grpc::GenericStub *  stub, const ByteBuffer &  req, std::function< gpr_timespec()>  next_issue, std::function< std::unique_ptr< grpc::GenericClientAsyncReaderWriter >(grpc::GenericStub *, grpc::ClientContext *, const std::string &method_name, CompletionQueue *)>  prepare_req, std::function< void(grpc::Status, ByteBuffer *)>  on_done  )

inline

Definition at line 773 of file client_async.cc.

~ClientRpcContextGenericStreamingImpl()

grpc::testing::ClientRpcContextGenericStreamingImpl::~ClientRpcContextGenericStreamingImpl ( )

inlineoverride

Definition at line 790 of file client_async.cc.

Member Function Documentation

RunNextState()

bool grpc::testing::ClientRpcContextGenericStreamingImpl::RunNextState ( bool  ok, HistogramEntry *  entry  )

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 795 of file client_async.cc.

Start()

void grpc::testing::ClientRpcContextGenericStreamingImpl::Start ( CompletionQueue *  cq, const ClientConfig &  config  )

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 791 of file client_async.cc.

StartInternal()

void grpc::testing::ClientRpcContextGenericStreamingImpl::StartInternal ( CompletionQueue *  cq, int  messages_per_stream  )

inlineprivate

Definition at line 888 of file client_async.cc.

StartNewClone()

void grpc::testing::ClientRpcContextGenericStreamingImpl::StartNewClone ( CompletionQueue *  cq )

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 849 of file client_async.cc.

TryCancel()

void grpc::testing::ClientRpcContextGenericStreamingImpl::TryCancel ( )

inlineoverridevirtual

Implements grpc::testing::ClientRpcContext.

Definition at line 854 of file client_async.cc.

Member Data Documentation

alarm_

std::unique_ptr<Alarm> grpc::testing::ClientRpcContextGenericStreamingImpl::alarm_

private

Definition at line 860 of file client_async.cc.

callback_

std::function<void(grpc::Status, ByteBuffer*)> grpc::testing::ClientRpcContextGenericStreamingImpl::callback_

private

Definition at line 874 of file client_async.cc.

context_

grpc::ClientContext grpc::testing::ClientRpcContextGenericStreamingImpl::context_

private

Definition at line 857 of file client_async.cc.

cq_

CompletionQueue* grpc::testing::ClientRpcContextGenericStreamingImpl::cq_

private

Definition at line 859 of file client_async.cc.

messages_issued_

int grpc::testing::ClientRpcContextGenericStreamingImpl::messages_issued_

private

Definition at line 886 of file client_async.cc.

messages_per_stream_

int grpc::testing::ClientRpcContextGenericStreamingImpl::messages_per_stream_

private

Definition at line 885 of file client_async.cc.

next_issue_

std::function<gpr_timespec()> grpc::testing::ClientRpcContextGenericStreamingImpl::next_issue_

private

Definition at line 875 of file client_async.cc.

next_state_

State grpc::testing::ClientRpcContextGenericStreamingImpl::next_state_

private

Definition at line 873 of file client_async.cc.

prepare_req_

std::function<std::unique_ptr<grpc::GenericClientAsyncReaderWriter> grpc::GenericStub*, grpc::ClientContext*, const std::string&, CompletionQueue*)> grpc::testing::ClientRpcContextGenericStreamingImpl::prepare_req_

private

Definition at line 879 of file client_async.cc.

req_

ByteBuffer grpc::testing::ClientRpcContextGenericStreamingImpl::req_

private

Definition at line 861 of file client_async.cc.

response_

ByteBuffer grpc::testing::ClientRpcContextGenericStreamingImpl::response_

private

Definition at line 862 of file client_async.cc.

start_

double grpc::testing::ClientRpcContextGenericStreamingImpl::start_

private

Definition at line 881 of file client_async.cc.

status_

grpc::Status grpc::testing::ClientRpcContextGenericStreamingImpl::status_

private

Definition at line 880 of file client_async.cc.

stream_

std::unique_ptr<grpc::GenericClientAsyncReaderWriter> grpc::testing::ClientRpcContextGenericStreamingImpl::stream_

private

Definition at line 882 of file client_async.cc.

stub_

grpc::GenericStub* grpc::testing::ClientRpcContextGenericStreamingImpl::stub_

private

Definition at line 858 of file client_async.cc.

---

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

• client_async.cc