grpc::testing::CallbackStreamingPingPongReactor Class Reference

Inheritance diagram for grpc::testing::CallbackStreamingPingPongReactor:

Public Member Functions
	CallbackStreamingPingPongReactor (CallbackStreamingPingPongClient *client, std::unique_ptr< CallbackClientRpcContext > ctx)
void	OnDone (const Status &s) override
void	OnReadDone (bool ok) override
void	OnWriteDone (bool ok) override
void	ScheduleRpc ()
void	set_thread_ptr (Client::Thread *ptr)
void	StartNewRpc ()
Public Member Functions inherited from grpc::ClientBidiReactor< SimpleRequest, SimpleResponse >
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 (SimpleResponse *resp)
void	StartWrite (const SimpleRequest *req)
void	StartWrite (const SimpleRequest *req, grpc::WriteOptions options)
void	StartWriteLast (const SimpleRequest *req, grpc::WriteOptions options)
void	StartWritesDone ()

Public Attributes
CallbackStreamingPingPongClient *	client_
std::unique_ptr< CallbackClientRpcContext >	ctx_
int	messages_issued_
Client::Thread *	thread_ptr_
double	write_time_
std::atomic_flag	writes_done_started_

Detailed Description

Definition at line 253 of file test/cpp/qps/client_callback.cc.

Constructor & Destructor Documentation

CallbackStreamingPingPongReactor()

grpc::testing::CallbackStreamingPingPongReactor::CallbackStreamingPingPongReactor ( CallbackStreamingPingPongClient *  client, std::unique_ptr< CallbackClientRpcContext >  ctx  )

inline

Definition at line 256 of file test/cpp/qps/client_callback.cc.

Member Function Documentation

OnDone()

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

inlineoverride

Definition at line 308 of file test/cpp/qps/client_callback.cc.

OnReadDone()

void grpc::testing::CallbackStreamingPingPongReactor::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< SimpleRequest, SimpleResponse >.

Definition at line 280 of file test/cpp/qps/client_callback.cc.

OnWriteDone()

void grpc::testing::CallbackStreamingPingPongReactor::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< SimpleRequest, SimpleResponse >.

Definition at line 269 of file test/cpp/qps/client_callback.cc.

ScheduleRpc()

void grpc::testing::CallbackStreamingPingPongReactor::ScheduleRpc ( )

inline

Definition at line 317 of file test/cpp/qps/client_callback.cc.

set_thread_ptr()

void grpc::testing::CallbackStreamingPingPongReactor::set_thread_ptr ( Client::Thread *  ptr )

inline

Definition at line 332 of file test/cpp/qps/client_callback.cc.

StartNewRpc()

void grpc::testing::CallbackStreamingPingPongReactor::StartNewRpc ( )

inline

Definition at line 261 of file test/cpp/qps/client_callback.cc.

Member Data Documentation

client_

CallbackStreamingPingPongClient* grpc::testing::CallbackStreamingPingPongReactor::client_

Definition at line 334 of file test/cpp/qps/client_callback.cc.

ctx_

std::unique_ptr<CallbackClientRpcContext> grpc::testing::CallbackStreamingPingPongReactor::ctx_

Definition at line 335 of file test/cpp/qps/client_callback.cc.

messages_issued_

int grpc::testing::CallbackStreamingPingPongReactor::messages_issued_

Definition at line 339 of file test/cpp/qps/client_callback.cc.

thread_ptr_

Client::Thread* grpc::testing::CallbackStreamingPingPongReactor::thread_ptr_

Definition at line 337 of file test/cpp/qps/client_callback.cc.

write_time_

double grpc::testing::CallbackStreamingPingPongReactor::write_time_

Definition at line 338 of file test/cpp/qps/client_callback.cc.

writes_done_started_

std::atomic_flag grpc::testing::CallbackStreamingPingPongReactor::writes_done_started_

Definition at line 336 of file test/cpp/qps/client_callback.cc.

---

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

• test/cpp/qps/client_callback.cc