diff options
author | krasnobaev <krasnobaev@yandex-team.ru> | 2022-02-10 16:50:19 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:19 +0300 |
commit | 57d5924cfae7600e91d372034c64914e0a0b6396 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/grpc/server | |
parent | 408b62b8b2bb0540f9251bb682b01b4d585d3754 (diff) | |
download | ydb-57d5924cfae7600e91d372034c64914e0a0b6396.tar.gz |
Restoring authorship annotation for <krasnobaev@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/grpc/server')
-rw-r--r-- | library/cpp/grpc/server/grpc_async_ctx_base.h | 8 | ||||
-rw-r--r-- | library/cpp/grpc/server/grpc_request.h | 8 | ||||
-rw-r--r-- | library/cpp/grpc/server/grpc_request_base.h | 10 | ||||
-rw-r--r-- | library/cpp/grpc/server/grpc_server.cpp | 4 | ||||
-rw-r--r-- | library/cpp/grpc/server/grpc_server.h | 16 |
5 files changed, 23 insertions, 23 deletions
diff --git a/library/cpp/grpc/server/grpc_async_ctx_base.h b/library/cpp/grpc/server/grpc_async_ctx_base.h index 8fbce61f94b..51356d4ce5a 100644 --- a/library/cpp/grpc/server/grpc_async_ctx_base.h +++ b/library/cpp/grpc/server/grpc_async_ctx_base.h @@ -69,10 +69,10 @@ public: return values; } - grpc_compression_level GetCompressionLevel() const { - return Context.compression_level(); - } - + grpc_compression_level GetCompressionLevel() const { + return Context.compression_level(); + } + void Shutdown() override { // Shutdown may only be called after request has started successfully if (Context.c_call()) diff --git a/library/cpp/grpc/server/grpc_request.h b/library/cpp/grpc/server/grpc_request.h index 345637e86d6..5bd8d3902b5 100644 --- a/library/cpp/grpc/server/grpc_request.h +++ b/library/cpp/grpc/server/grpc_request.h @@ -167,10 +167,10 @@ public: return TBaseAsyncContext<TService>::GetPeerMetaValues(key); } - grpc_compression_level GetCompressionLevel() const override { - return TBaseAsyncContext<TService>::GetCompressionLevel(); - } - + grpc_compression_level GetCompressionLevel() const override { + return TBaseAsyncContext<TService>::GetCompressionLevel(); + } + //! Get pointer to the request's message. const NProtoBuf::Message* GetRequest() const override { return Request_; diff --git a/library/cpp/grpc/server/grpc_request_base.h b/library/cpp/grpc/server/grpc_request_base.h index 5d5e11239e9..fcfce1c181a 100644 --- a/library/cpp/grpc/server/grpc_request_base.h +++ b/library/cpp/grpc/server/grpc_request_base.h @@ -3,8 +3,8 @@ #include <google/protobuf/message.h> #include <library/cpp/threading/future/future.h> -#include <grpc++/server_context.h> - +#include <grpc++/server_context.h> + namespace grpc { class ByteBuffer; } @@ -79,9 +79,9 @@ public: //! Returns peer optional metavalue virtual TVector<TStringBuf> GetPeerMetaValues(TStringBuf key) const = 0; - //! Returns request compression level - virtual grpc_compression_level GetCompressionLevel() const = 0; - + //! Returns request compression level + virtual grpc_compression_level GetCompressionLevel() const = 0; + //! Returns protobuf arena allocator associated with current request //! Lifetime of the arena is lifetime of the context virtual google::protobuf::Arena* GetArena() = 0; diff --git a/library/cpp/grpc/server/grpc_server.cpp b/library/cpp/grpc/server/grpc_server.cpp index 07dca78a376..7437b7a8f5e 100644 --- a/library/cpp/grpc/server/grpc_server.cpp +++ b/library/cpp/grpc/server/grpc_server.cpp @@ -142,8 +142,8 @@ void TGRpcServer::Start() { */ Cerr << "GRpc memory quota temporarily disabled due to issues with grpc quoter" << Endl; } - Options_.ServerBuilderMutator(builder); - builder.SetDefaultCompressionLevel(Options_.DefaultCompressionLevel); + Options_.ServerBuilderMutator(builder); + builder.SetDefaultCompressionLevel(Options_.DefaultCompressionLevel); Server_ = builder.BuildAndStart(); if (!Server_) { diff --git a/library/cpp/grpc/server/grpc_server.h b/library/cpp/grpc/server/grpc_server.h index a43cdef142a..d6814a90a0d 100644 --- a/library/cpp/grpc/server/grpc_server.h +++ b/library/cpp/grpc/server/grpc_server.h @@ -85,14 +85,14 @@ struct TServerOptions { //! GRPC auth DECLARE_FIELD(UseAuth, bool, false); - - //! Default compression level. Used when no compression options provided by client. - // Mapping to particular compression algorithm depends on client. - DECLARE_FIELD(DefaultCompressionLevel, grpc_compression_level, GRPC_COMPRESS_LEVEL_NONE); - - //! Custom configurator for ServerBuilder. - DECLARE_FIELD(ServerBuilderMutator, std::function<void(grpc::ServerBuilder&)>, [](grpc::ServerBuilder&){}); - + + //! Default compression level. Used when no compression options provided by client. + // Mapping to particular compression algorithm depends on client. + DECLARE_FIELD(DefaultCompressionLevel, grpc_compression_level, GRPC_COMPRESS_LEVEL_NONE); + + //! Custom configurator for ServerBuilder. + DECLARE_FIELD(ServerBuilderMutator, std::function<void(grpc::ServerBuilder&)>, [](grpc::ServerBuilder&){}); + DECLARE_FIELD(ExternalListener, IExternalListener::TPtr, nullptr); //! Logger which will be used to write logs about requests handling (iff appropriate log level is enabled). |