Inheritance diagram for grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >:
Classes | |
| struct | PerThreadShutdownState |
| class | ServerRpcContext |
| class | ServerRpcContextStreamingFromClientImpl |
| class | ServerRpcContextStreamingFromServerImpl |
| class | ServerRpcContextStreamingImpl |
| class | ServerRpcContextUnaryImpl |
Public Member Functions | |
| AsyncQpsServerTest (const ServerConfig &config, std::function< void(ServerBuilder *, ServiceType *)> register_service, std::function< void(ServiceType *, ServerContextType *, RequestType *, ServerAsyncResponseWriter< ResponseType > *, CompletionQueue *, ServerCompletionQueue *, void *)> request_unary_function, std::function< void(ServiceType *, ServerContextType *, ServerAsyncReaderWriter< ResponseType, RequestType > *, CompletionQueue *, ServerCompletionQueue *, void *)> request_streaming_function, std::function< void(ServiceType *, ServerContextType *, ServerAsyncReader< ResponseType, RequestType > *, CompletionQueue *, ServerCompletionQueue *, void *)> request_streaming_from_client_function, std::function< void(ServiceType *, ServerContextType *, RequestType *, ServerAsyncWriter< ResponseType > *, CompletionQueue *, ServerCompletionQueue *, void *)> request_streaming_from_server_function, std::function< void(ServiceType *, ServerContextType *, ServerAsyncReaderWriter< ResponseType, RequestType > *, CompletionQueue *, ServerCompletionQueue *, void *)> request_streaming_both_ways_function, std::function< grpc::Status(const PayloadConfig &, RequestType *, ResponseType *)> process_rpc) | |
| int | GetPollCount () override |
| std::shared_ptr< Channel > | InProcessChannel (const ChannelArguments &args) override |
| ~AsyncQpsServerTest () override | |
 Public Member Functions inherited from grpc::testing::Server | |
| int | cores () const |
| ServerStats | Mark (bool reset) |
| int | port () const |
| Server (const ServerConfig &config) | |
| virtual | ~Server () |
Private Member Functions | |
| void | ThreadFunc (int thread_idx) |
Static Private Member Functions | |
| static ServerRpcContext * | detag (void *tag) |
| static void * | tag (ServerRpcContext *func) |
Private Attributes | |
| ServiceType | async_service_ |
| std::vector< std::unique_ptr< ServerRpcContext > > | contexts_ |
| std::vector< int > | cq_ |
| std::unique_ptr< grpc::Server > | server_ |
| std::vector< std::unique_ptr< PerThreadShutdownState > > | shutdown_state_ |
| std::vector< std::unique_ptr< grpc::ServerCompletionQueue > > | srv_cqs_ |
| std::vector< std::thread > | threads_ |
Additional Inherited Members | |
| Static Public Member Functions inherited from grpc::testing::Server | |
| static std::shared_ptr< ServerCredentials > | CreateServerCredentials (const ServerConfig &config) |
| static bool | SetPayload (PayloadType type, int size, Payload *payload) |
| Static Protected Member Functions inherited from grpc::testing::Server | |
| static void | ApplyConfigToBuilder (const ServerConfig &config, ServerBuilder *builder) |
Detailed Description
template<class RequestType, class ResponseType, class ServiceType, class ServerContextType>
class grpc::testing::AsyncQpsServerTest< RequestType, ResponseType, ServiceType, ServerContextType >
Definition at line 49 of file server_async.cc.
Constructor & Destructor Documentation
◆ AsyncQpsServerTest()
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
inline |
Definition at line 51 of file server_async.cc.
◆ ~AsyncQpsServerTest()
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
inlineoverride |
Definition at line 169 of file server_async.cc.
Member Function Documentation
◆ detag()
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
inlinestaticprivate |
Definition at line 249 of file server_async.cc.
◆ GetPollCount()
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
inlineoverridevirtual |
Reimplemented from grpc::testing::Server.
Definition at line 192 of file server_async.cc.
◆ InProcessChannel()
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
inlineoverridevirtual |
Implements grpc::testing::Server.
Definition at line 200 of file server_async.cc.
◆ tag()
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
inlinestaticprivate |
Definition at line 248 of file server_async.cc.
◆ ThreadFunc()
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
inlineprivate |
Definition at line 206 of file server_async.cc.
Member Data Documentation
◆ async_service_
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
private |
Definition at line 527 of file server_async.cc.
◆ contexts_
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
private |
Definition at line 528 of file server_async.cc.
◆ cq_
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
private |
Definition at line 526 of file server_async.cc.
◆ server_
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
private |
Definition at line 524 of file server_async.cc.
◆ shutdown_state_
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
private |
Definition at line 536 of file server_async.cc.
◆ srv_cqs_
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
private |
Definition at line 525 of file server_async.cc.
◆ threads_
template<class RequestType , class ResponseType , class ServiceType , class ServerContextType >
|
private |
Definition at line 523 of file server_async.cc.
The documentation for this class was generated from the following file: