aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/grpc
diff options
context:
space:
mode:
authorVitalii Gridnev <gridnevvvit@gmail.com>2022-02-10 16:47:23 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:23 +0300
commit30ed3937ab02d1b3c4dec4d93fb86c683217d9be (patch)
tree40cf6aa8b6b8223a09b185010d80f212e28b74f0 /library/cpp/grpc
parent64de01e9a049f96a9e2d43aff48d10621ab47d81 (diff)
downloadydb-30ed3937ab02d1b3c4dec4d93fb86c683217d9be.tar.gz
Restoring authorship annotation for Vitalii Gridnev <gridnevvvit@gmail.com>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/grpc')
-rw-r--r--library/cpp/grpc/server/grpc_server.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/library/cpp/grpc/server/grpc_server.cpp b/library/cpp/grpc/server/grpc_server.cpp
index 7437b7a8f5..a9c67cebda 100644
--- a/library/cpp/grpc/server/grpc_server.cpp
+++ b/library/cpp/grpc/server/grpc_server.cpp
@@ -133,14 +133,14 @@ void TGRpcServer::Start() {
}
if (Options_.GRpcMemoryQuotaBytes) {
- // See details KIKIMR-6932
+ // See details KIKIMR-6932
/*
grpc::ResourceQuota quota("memory_bound");
quota.Resize(Options_.GRpcMemoryQuotaBytes);
builder.SetResourceQuota(quota);
*/
- Cerr << "GRpc memory quota temporarily disabled due to issues with grpc quoter" << Endl;
+ Cerr << "GRpc memory quota temporarily disabled due to issues with grpc quoter" << Endl;
}
Options_.ServerBuilderMutator(builder);
builder.SetDefaultCompressionLevel(Options_.DefaultCompressionLevel);
@@ -191,7 +191,7 @@ void TGRpcServer::Stop() {
Server_->Shutdown(gpr_timespec{sec, nanosecOfSec, GPR_TIMESPAN});
}
- for (ui64 attempt = 0; ; ++attempt) {
+ for (ui64 attempt = 0; ; ++attempt) {
bool unsafe = false;
size_t infly = 0;
for (auto& service : Services_) {
@@ -201,13 +201,13 @@ void TGRpcServer::Stop() {
if (!unsafe && !infly)
break;
-
+
auto spent = (TInstant::Now() - now).SecondsFloat();
- if (attempt % 300 == 0) {
- // don't log too much
- Cerr << "GRpc shutdown warning: left infly: " << infly << ", spent: " << spent << " sec" << Endl;
- }
-
+ if (attempt % 300 == 0) {
+ // don't log too much
+ Cerr << "GRpc shutdown warning: left infly: " << infly << ", spent: " << spent << " sec" << Endl;
+ }
+
if (!unsafe && spent > Options_.GRpcShutdownDeadline.SecondsFloat())
break;
Sleep(TDuration::MilliSeconds(10));