grpc::testing::BidiClient Class Reference

#include <callback_streaming_ping_pong.h>

Inheritance diagram for grpc::testing::BidiClient:

Public Member Functions
void	Await ()
	BidiClient (benchmark::State *state, EchoTestService::Stub *stub, ClientContext *cli_ctx, EchoRequest *request, EchoResponse *response)
void	OnDone (const Status &s) override
void	OnReadDone (bool ok) override
void	OnWriteDone (bool ok) override
void	StartNewRpc ()
Public Member Functions inherited from grpc::ClientBidiReactor< EchoRequest, EchoResponse >
void	AddHold ()
void	AddMultipleHolds (int holds)
void	OnDone (const grpc::Status &) override
virtual void	OnReadInitialMetadataDone (bool)
virtual void	OnWritesDoneDone (bool)
void	RemoveHold ()
void	StartCall ()
void	StartRead (EchoResponse *resp)
void	StartWrite (const EchoRequest *req)
void	StartWrite (const EchoRequest *req, grpc::WriteOptions options)
void	StartWriteLast (const EchoRequest *req, grpc::WriteOptions options)
void	StartWritesDone ()

Private Member Functions
void	MaybeWrite ()

Private Attributes
ClientContext *	cli_ctx_
std::condition_variable	cv
bool	done = false
int	msgs_size_
int	msgs_to_send_
std::mutex	mu
EchoRequest *	request_
EchoResponse *	response_
benchmark::State *	state_
EchoTestService::Stub *	stub_
int	writes_complete_ {0}

Detailed Description

Definition at line 39 of file callback_streaming_ping_pong.h.

Constructor & Destructor Documentation

BidiClient()

grpc::testing::BidiClient::BidiClient ( benchmark::State *  state, EchoTestService::Stub *  stub, ClientContext *  cli_ctx, EchoRequest *  request, EchoResponse *  response  )

inline

Definition at line 43 of file callback_streaming_ping_pong.h.

Member Function Documentation

Await()

void grpc::testing::BidiClient::Await ( )

inline

Definition at line 95 of file callback_streaming_ping_pong.h.

MaybeWrite()

void grpc::testing::BidiClient::MaybeWrite ( )

inlineprivate

Definition at line 103 of file callback_streaming_ping_pong.h.

OnDone()

void grpc::testing::BidiClient::OnDone ( const Status &  s )

inlineoverride

Definition at line 73 of file callback_streaming_ping_pong.h.

OnReadDone()

void grpc::testing::BidiClient::OnReadDone ( bool  )

inlineoverridevirtual

Notifies the application that a StartRead operation completed.

Parameters

[in]

ok

Was it successful? If false, no new read/write operation will succeed, and any further Start* should not be called.

Reimplemented from grpc::ClientBidiReactor< EchoRequest, EchoResponse >.

Definition at line 56 of file callback_streaming_ping_pong.h.

OnWriteDone()

void grpc::testing::BidiClient::OnWriteDone ( bool  )

inlineoverridevirtual

Notifies the application that a StartWrite or StartWriteLast operation completed.

Parameters

[in]

ok

Was it successful? If false, no new read/write operation will succeed, and any further Start* should not be called.

Reimplemented from grpc::ClientBidiReactor< EchoRequest, EchoResponse >.

Definition at line 64 of file callback_streaming_ping_pong.h.

StartNewRpc()

void grpc::testing::BidiClient::StartNewRpc ( )

inline

Definition at line 86 of file callback_streaming_ping_pong.h.

Member Data Documentation

cli_ctx_

ClientContext* grpc::testing::BidiClient::cli_ctx_

private

Definition at line 113 of file callback_streaming_ping_pong.h.

cv

std::condition_variable grpc::testing::BidiClient::cv

private

Definition at line 120 of file callback_streaming_ping_pong.h.

done

bool grpc::testing::BidiClient::done = false

private

Definition at line 121 of file callback_streaming_ping_pong.h.

msgs_size_

int grpc::testing::BidiClient::msgs_size_

private

Definition at line 118 of file callback_streaming_ping_pong.h.

msgs_to_send_

int grpc::testing::BidiClient::msgs_to_send_

private

Definition at line 117 of file callback_streaming_ping_pong.h.

mu

std::mutex grpc::testing::BidiClient::mu

private

Definition at line 119 of file callback_streaming_ping_pong.h.

request_

EchoRequest* grpc::testing::BidiClient::request_

private

Definition at line 114 of file callback_streaming_ping_pong.h.

response_

EchoResponse* grpc::testing::BidiClient::response_

private

Definition at line 115 of file callback_streaming_ping_pong.h.

state_

benchmark::State* grpc::testing::BidiClient::state_

private

Definition at line 111 of file callback_streaming_ping_pong.h.

stub_

EchoTestService::Stub* grpc::testing::BidiClient::stub_

private

Definition at line 112 of file callback_streaming_ping_pong.h.

writes_complete_

int grpc::testing::BidiClient::writes_complete_ {0}

private

Definition at line 116 of file callback_streaming_ping_pong.h.

---

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

• callback_streaming_ping_pong.h