diff options
| author | dvshkurko <[email protected]> | 2022-02-10 16:45:52 +0300 |
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:45:52 +0300 |
| commit | c768a99151e47c3a4bb7b92c514d256abd301c4d (patch) | |
| tree | 1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /contrib/libs/grpc/include/grpcpp/impl/codegen/async_generic_service.h | |
| parent | 321ee9bce31ec6e238be26dbcbe539cffa2c3309 (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'contrib/libs/grpc/include/grpcpp/impl/codegen/async_generic_service.h')
| -rw-r--r-- | contrib/libs/grpc/include/grpcpp/impl/codegen/async_generic_service.h | 84 |
1 files changed, 42 insertions, 42 deletions
diff --git a/contrib/libs/grpc/include/grpcpp/impl/codegen/async_generic_service.h b/contrib/libs/grpc/include/grpcpp/impl/codegen/async_generic_service.h index 48f3eea31d1..a812b086a2a 100644 --- a/contrib/libs/grpc/include/grpcpp/impl/codegen/async_generic_service.h +++ b/contrib/libs/grpc/include/grpcpp/impl/codegen/async_generic_service.h @@ -24,7 +24,7 @@ #include <grpcpp/impl/codegen/async_stream.h> #include <grpcpp/impl/codegen/byte_buffer.h> #include <grpcpp/impl/codegen/server_callback.h> -#include <grpcpp/impl/codegen/server_callback_handlers.h> +#include <grpcpp/impl/codegen/server_callback_handlers.h> struct grpc_server; @@ -80,62 +80,62 @@ class AsyncGenericService final { }; #ifndef GRPC_CALLBACK_API_NONEXPERIMENTAL -namespace experimental { +namespace experimental { #endif - -/// \a ServerGenericBidiReactor is the reactor class for bidi streaming RPCs -/// invoked on a CallbackGenericService. It is just a ServerBidi reactor with -/// ByteBuffer arguments. + +/// \a ServerGenericBidiReactor is the reactor class for bidi streaming RPCs +/// invoked on a CallbackGenericService. It is just a ServerBidi reactor with +/// ByteBuffer arguments. using ServerGenericBidiReactor = ServerBidiReactor<ByteBuffer, ByteBuffer>; - + class GenericCallbackServerContext final : public grpc::CallbackServerContext { - public: + public: const TString& method() const { return method_; } const TString& host() const { return host_; } - - private: + + private: friend class ::grpc::Server; - + TString method_; TString host_; -}; - -/// \a CallbackGenericService is the base class for generic services implemented -/// using the callback API and registered through the ServerBuilder using -/// RegisterCallbackGenericService. -class CallbackGenericService { - public: - CallbackGenericService() {} - virtual ~CallbackGenericService() {} - - /// The "method handler" for the generic API. This function should be - /// overridden to provide a ServerGenericBidiReactor that implements the - /// application-level interface for this RPC. Unimplemented by default. - virtual ServerGenericBidiReactor* CreateReactor( - GenericCallbackServerContext* /*ctx*/) { - class Reactor : public ServerGenericBidiReactor { - public: - Reactor() { this->Finish(Status(StatusCode::UNIMPLEMENTED, "")); } - void OnDone() override { delete this; } - }; - return new Reactor; - } - - private: +}; + +/// \a CallbackGenericService is the base class for generic services implemented +/// using the callback API and registered through the ServerBuilder using +/// RegisterCallbackGenericService. +class CallbackGenericService { + public: + CallbackGenericService() {} + virtual ~CallbackGenericService() {} + + /// The "method handler" for the generic API. This function should be + /// overridden to provide a ServerGenericBidiReactor that implements the + /// application-level interface for this RPC. Unimplemented by default. + virtual ServerGenericBidiReactor* CreateReactor( + GenericCallbackServerContext* /*ctx*/) { + class Reactor : public ServerGenericBidiReactor { + public: + Reactor() { this->Finish(Status(StatusCode::UNIMPLEMENTED, "")); } + void OnDone() override { delete this; } + }; + return new Reactor; + } + + private: friend class grpc::Server; - + internal::CallbackBidiHandler<ByteBuffer, ByteBuffer>* Handler() { return new internal::CallbackBidiHandler<ByteBuffer, ByteBuffer>( [this](::grpc::CallbackServerContext* ctx) { - return CreateReactor(static_cast<GenericCallbackServerContext*>(ctx)); - }); - } - + return CreateReactor(static_cast<GenericCallbackServerContext*>(ctx)); + }); + } + grpc::Server* server_{nullptr}; -}; +}; #ifndef GRPC_CALLBACK_API_NONEXPERIMENTAL -} // namespace experimental +} // namespace experimental #endif } // namespace grpc |
