grpc::testing::WorkerServiceImpl Class Reference

Inheritance diagram for grpc::testing::WorkerServiceImpl:

Classes
class	InstanceGuard

Public Member Functions
Status	CoreCount (ServerContext *, const CoreRequest *, CoreResponse *resp) override
Status	QuitWorker (ServerContext *, const Void *, Void *) override
Status	RunClient (ServerContext *ctx, ServerReaderWriter< ClientStatus, ClientArgs > *stream) override
Status	RunServer (ServerContext *ctx, ServerReaderWriter< ServerStatus, ServerArgs > *stream) override
	WorkerServiceImpl (int server_port, QpsWorker *worker)

Private Member Functions
void	ReleaseInstance ()
Status	RunClientBody (ServerContext *, ServerReaderWriter< ClientStatus, ClientArgs > *stream)
Status	RunServerBody (ServerContext *, ServerReaderWriter< ServerStatus, ServerArgs > *stream)
bool	TryAcquireInstance ()

Private Attributes
bool	acquired_
std::mutex	mu_
int	server_port_
QpsWorker *	worker_

Detailed Description

Definition at line 103 of file qps_worker.cc.

Constructor & Destructor Documentation

WorkerServiceImpl()

grpc::testing::WorkerServiceImpl::WorkerServiceImpl ( int  server_port, QpsWorker *  worker  )

inline

Definition at line 105 of file qps_worker.cc.

Member Function Documentation

CoreCount()

Status grpc::testing::WorkerServiceImpl::CoreCount ( ServerContext *  , const CoreRequest *  , CoreResponse *  resp  )

inlineoverride

Definition at line 138 of file qps_worker.cc.

QuitWorker()

Status grpc::testing::WorkerServiceImpl::QuitWorker ( ServerContext *  , const Void *  , Void *    )

inlineoverride

Definition at line 144 of file qps_worker.cc.

ReleaseInstance()

void grpc::testing::WorkerServiceImpl::ReleaseInstance ( )

inlineprivate

Definition at line 180 of file qps_worker.cc.

RunClient()

Status grpc::testing::WorkerServiceImpl::RunClient ( ServerContext *  ctx, ServerReaderWriter< ClientStatus, ClientArgs > *  stream  )

inlineoverride

Definition at line 108 of file qps_worker.cc.

RunClientBody()

Status grpc::testing::WorkerServiceImpl::RunClientBody ( ServerContext *  , ServerReaderWriter< ClientStatus, ClientArgs > *  stream  )

inlineprivate

Definition at line 186 of file qps_worker.cc.

RunServer()

Status grpc::testing::WorkerServiceImpl::RunServer ( ServerContext *  ctx, ServerReaderWriter< ServerStatus, ServerArgs > *  stream  )

inlineoverride

Definition at line 123 of file qps_worker.cc.

RunServerBody()

Status grpc::testing::WorkerServiceImpl::RunServerBody ( ServerContext *  , ServerReaderWriter< ServerStatus, ServerArgs > *  stream  )

inlineprivate

Definition at line 226 of file qps_worker.cc.

TryAcquireInstance()

bool grpc::testing::WorkerServiceImpl::TryAcquireInstance ( )

inlineprivate

Definition at line 173 of file qps_worker.cc.

Member Data Documentation

acquired_

bool grpc::testing::WorkerServiceImpl::acquired_

private

Definition at line 272 of file qps_worker.cc.

mu_

std::mutex grpc::testing::WorkerServiceImpl::mu_

private

Definition at line 271 of file qps_worker.cc.

server_port_

int grpc::testing::WorkerServiceImpl::server_port_

private

Definition at line 273 of file qps_worker.cc.

worker_

QpsWorker* grpc::testing::WorkerServiceImpl::worker_

private

Definition at line 274 of file qps_worker.cc.

---

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

• qps_worker.cc