grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl Class Reference

Inheritance diagram for grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl:

Public Member Functions
void	Reset () override
bool	RunNextState (bool ok) override
	ServerRpcContextStreamingImpl (std::function< void(ServerContextType *, grpc::ServerAsyncReaderWriter< ResponseType, RequestType > *, void *)> request_method, std::function< grpc::Status(RequestType *, ResponseType *)> invoke_method)
	~ServerRpcContextStreamingImpl () override
Public Member Functions inherited from grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContext
void	lock ()
	ServerRpcContext ()
void	unlock ()
virtual	~ServerRpcContext ()

Private Member Functions
bool	finish_done (bool)
bool	read_done (bool ok)
bool	request_done (bool ok)
bool	write_done (bool ok)

Private Attributes
std::function< grpc::Status(RequestType *, ResponseType *)>	invoke_method_
bool(ServerRpcContextStreamingImpl::*	next_state_ )(bool)
RequestType	req_
std::function< void(ServerContextType *, grpc::ServerAsyncReaderWriter< ResponseType, RequestType > *, void *)>	request_method_
ResponseType	response_
std::unique_ptr< ServerContextType >	srv_ctx_
grpc::ServerAsyncReaderWriter< ResponseType, RequestType >	stream_

Detailed Description

template<class RequestType, class ResponseType, class ServiceType, class ServerContextType>
class grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl

Definition at line 309 of file server_async.cc.

Constructor & Destructor Documentation

ServerRpcContextStreamingImpl()

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::ServerRpcContextStreamingImpl ( std::function< void(ServerContextType *, grpc::ServerAsyncReaderWriter< ResponseType, RequestType > *, void *)>  request_method, std::function< grpc::Status(RequestType *, ResponseType *)>  invoke_method  )

inline

Definition at line 311 of file server_async.cc.

~ServerRpcContextStreamingImpl()

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::~ServerRpcContextStreamingImpl ( )

inlineoverride

Definition at line 324 of file server_async.cc.

Member Function Documentation

finish_done()

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

bool grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::finish_done ( bool  )

inlineprivate

Definition at line 373 of file server_async.cc.

read_done()

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

bool grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::read_done ( bool  ok )

inlineprivate

Definition at line 347 of file server_async.cc.

request_done()

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

bool grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::request_done ( bool  ok )

inlineprivate

Definition at line 338 of file server_async.cc.

Reset()

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

void grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::Reset ( )

inlineoverridevirtual

Implements grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContext.

Definition at line 326 of file server_async.cc.

RunNextState()

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

bool grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::RunNextState ( bool  ok )

inlineoverridevirtual

Implements grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContext.

Definition at line 325 of file server_async.cc.

write_done()

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

bool grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::write_done ( bool  ok )

inlineprivate

Definition at line 362 of file server_async.cc.

Member Data Documentation

invoke_method_

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

std::function<grpc::Status(RequestType*, ResponseType*)> grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::invoke_method_

private

Definition at line 383 of file server_async.cc.

next_state_

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

bool(ServerRpcContextStreamingImpl::* grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::next_state_) (bool)

private

Definition at line 378 of file server_async.cc.

req_

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

RequestType grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::req_

private

Definition at line 376 of file server_async.cc.

request_method_

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

std::function<void( ServerContextType*, grpc::ServerAsyncReaderWriter<ResponseType, RequestType>*, void*)> grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::request_method_

private

Definition at line 382 of file server_async.cc.

response_

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

ResponseType grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::response_

private

Definition at line 377 of file server_async.cc.

srv_ctx_

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

std::unique_ptr<ServerContextType> grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::srv_ctx_

private

Definition at line 375 of file server_async.cc.

stream_

template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >

grpc::ServerAsyncReaderWriter<ResponseType, RequestType> grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >::ServerRpcContextStreamingImpl::stream_

private

Definition at line 384 of file server_async.cc.

---

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

• server_async.cc