diff options
| author | heretic <[email protected]> | 2022-02-10 16:45:43 +0300 |
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:45:43 +0300 |
| commit | 397cbe258b9e064f49c4ca575279f02f39fef76e (patch) | |
| tree | a0b0eb3cca6a14e4e8ea715393637672fa651284 /contrib/libs/grpc/include/grpcpp/impl/codegen/async_generic_service.h | |
| parent | 43f5a35593ebc9f6bcea619bb170394ea7ae468e (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 1 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 | 70 |
1 files changed, 35 insertions, 35 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 a812b086a2a..3f2b8fc20a5 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 @@ -19,33 +19,33 @@ #ifndef GRPCPP_IMPL_CODEGEN_ASYNC_GENERIC_SERVICE_H #define GRPCPP_IMPL_CODEGEN_ASYNC_GENERIC_SERVICE_H -#include <grpc/impl/codegen/port_platform.h> - -#include <grpcpp/impl/codegen/async_stream.h> +#include <grpc/impl/codegen/port_platform.h> + +#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.h> #include <grpcpp/impl/codegen/server_callback_handlers.h> struct grpc_server; namespace grpc { -typedef ServerAsyncReaderWriter<ByteBuffer, ByteBuffer> +typedef ServerAsyncReaderWriter<ByteBuffer, ByteBuffer> GenericServerAsyncReaderWriter; -typedef ServerAsyncResponseWriter<ByteBuffer> GenericServerAsyncResponseWriter; -typedef ServerAsyncReader<ByteBuffer, ByteBuffer> GenericServerAsyncReader; -typedef ServerAsyncWriter<ByteBuffer> GenericServerAsyncWriter; +typedef ServerAsyncResponseWriter<ByteBuffer> GenericServerAsyncResponseWriter; +typedef ServerAsyncReader<ByteBuffer, ByteBuffer> GenericServerAsyncReader; +typedef ServerAsyncWriter<ByteBuffer> GenericServerAsyncWriter; -class GenericServerContext final : public ServerContext { +class GenericServerContext final : public ServerContext { public: - const TString& method() const { return method_; } - const TString& host() const { return host_; } + const TString& method() const { return method_; } + const TString& host() const { return host_; } private: - friend class ServerInterface; + friend class ServerInterface; - TString method_; - TString host_; + TString method_; + TString host_; }; // A generic service at the server side accepts all RPC methods and hosts. It is @@ -71,33 +71,33 @@ class AsyncGenericService final { void RequestCall(GenericServerContext* ctx, GenericServerAsyncReaderWriter* reader_writer, - ::grpc::CompletionQueue* call_cq, - ::grpc::ServerCompletionQueue* notification_cq, void* tag); + ::grpc::CompletionQueue* call_cq, + ::grpc::ServerCompletionQueue* notification_cq, void* tag); private: - friend class grpc::Server; - grpc::Server* server_; + friend class grpc::Server; + grpc::Server* server_; }; -#ifndef GRPC_CALLBACK_API_NONEXPERIMENTAL +#ifndef GRPC_CALLBACK_API_NONEXPERIMENTAL namespace experimental { -#endif +#endif /// \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>; +using ServerGenericBidiReactor = ServerBidiReactor<ByteBuffer, ByteBuffer>; -class GenericCallbackServerContext final : public grpc::CallbackServerContext { +class GenericCallbackServerContext final : public grpc::CallbackServerContext { public: - const TString& method() const { return method_; } - const TString& host() const { return host_; } + const TString& method() const { return method_; } + const TString& host() const { return host_; } private: - friend class ::grpc::Server; + friend class ::grpc::Server; - TString method_; - TString host_; + TString method_; + TString host_; }; /// \a CallbackGenericService is the base class for generic services implemented @@ -122,21 +122,21 @@ class CallbackGenericService { } private: - friend class grpc::Server; + friend class grpc::Server; - internal::CallbackBidiHandler<ByteBuffer, ByteBuffer>* Handler() { - return new internal::CallbackBidiHandler<ByteBuffer, ByteBuffer>( - [this](::grpc::CallbackServerContext* ctx) { + internal::CallbackBidiHandler<ByteBuffer, ByteBuffer>* Handler() { + return new internal::CallbackBidiHandler<ByteBuffer, ByteBuffer>( + [this](::grpc::CallbackServerContext* ctx) { return CreateReactor(static_cast<GenericCallbackServerContext*>(ctx)); }); } - grpc::Server* server_{nullptr}; + grpc::Server* server_{nullptr}; }; - -#ifndef GRPC_CALLBACK_API_NONEXPERIMENTAL + +#ifndef GRPC_CALLBACK_API_NONEXPERIMENTAL } // namespace experimental -#endif +#endif } // namespace grpc #endif // GRPCPP_IMPL_CODEGEN_ASYNC_GENERIC_SERVICE_H |
