aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/grpc/server
diff options
context:
space:
mode:
authorkrasnobaev <krasnobaev@yandex-team.ru>2022-02-10 16:50:19 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:19 +0300
commit57d5924cfae7600e91d372034c64914e0a0b6396 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/grpc/server
parent408b62b8b2bb0540f9251bb682b01b4d585d3754 (diff)
downloadydb-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.h8
-rw-r--r--library/cpp/grpc/server/grpc_request.h8
-rw-r--r--library/cpp/grpc/server/grpc_request_base.h10
-rw-r--r--library/cpp/grpc/server/grpc_server.cpp4
-rw-r--r--library/cpp/grpc/server/grpc_server.h16
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).