meta deadline exceeded (#10101)

Author: StekPerepolnen

ydb/mvp/core/core_ydb.cpp

@@ -1,5 +1,6 @@
 #include "core_ydb.h"
 #include "core_ydb_impl.h"
+#include "mvp_tokens.h"
 
 #include <ydb/library/actors/http/http_cache.h>
 
@@ -408,3 +409,10 @@ TString GetAuthHeaderValue(const TString& tokenName) {
     }
     return authHeaderValue;
 }
+
+void SetGrpcKeepAlive(NYdbGrpc::TGRpcClientConfig& config) {
+    config.IntChannelParams[GRPC_ARG_KEEPALIVE_TIME_MS] = 20000;
+    config.IntChannelParams[GRPC_ARG_KEEPALIVE_TIMEOUT_MS] = 10000;
+    config.IntChannelParams[GRPC_ARG_HTTP2_MAX_PINGS_WITHOUT_DATA] = 0;
+    config.IntChannelParams[GRPC_ARG_KEEPALIVE_PERMIT_WITHOUT_CALLS] = 1;
+}

ydb/mvp/core/core_ydb.h

@@ -16,7 +16,6 @@
 #include <util/generic/strbuf.h>
 #include <library/cpp/deprecated/atomic/atomic.h>
 #include "grpc_log.h"
-#include "mvp_tokens.h"
 
 template <typename T>
 class TAtomicSingleton {
@@ -142,6 +141,9 @@ struct TYdbUnitResources {
 
 extern TMap<std::pair<TStringBuf, TStringBuf>, TYdbUnitResources> DefaultUnitResources;
 
+TString GetAuthHeaderValue(const TString& tokenName);
+void SetGrpcKeepAlive(NYdbGrpc::TGRpcClientConfig& config);
+
 struct TYdbLocation {
     TString Name;
     TString Environment;
@@ -257,6 +259,7 @@ struct TYdbLocation {
             config.SslCredentials.pem_root_certs = certificate;
         }
         config.EnableSsl = ssl;
+        SetGrpcKeepAlive(config);
         return CreateGRpcServiceConnection<TGRpcService>(config);
     }
 
@@ -272,6 +275,7 @@ struct TYdbLocation {
         if (config.EnableSsl && CaCertificate) {
             config.SslCredentials.pem_root_certs = CaCertificate;
         }
+        SetGrpcKeepAlive(config);
         return CreateGRpcServiceConnection<TGRpcService>(config);
     }
 
@@ -350,5 +354,3 @@ struct TYdbLocation {
         return GRpcClientLow.GetRef();
     }
 };
-
-TString GetAuthHeaderValue(const TString& tokenName);

ydb/mvp/core/mvp_tokens.h

@@ -140,6 +140,7 @@ class TMvpTokenator : public NActors::TActorBootstrapped<TMvpTokenator> {
         NYdbGrpc::TGRpcClientConfig config;
         config.Locator = host;
         config.EnableSsl = (scheme == "grpcs");
+        SetGrpcKeepAlive(config);
         return std::unique_ptr<NMVP::TLoggedGrpcServiceConnection<TGRpcService>>(new NMVP::TLoggedGrpcServiceConnection<TGRpcService>(config, GRpcClientLow.CreateGRpcServiceConnection<TGRpcService>(config)));
     }
 

ydb/mvp/oidc_proxy/openid_connect.h

@@ -6,6 +6,7 @@
 #include <ydb/library/actors/core/event_local.h>
 #include <ydb/library/actors/http/http.h>
 #include <ydb/library/grpc/client/grpc_client_low.h>
+#include <ydb/mvp/core/core_ydb.h>
 #include "context.h"
 
 
@@ -60,6 +61,7 @@ std::unique_ptr<NYdbGrpc::TServiceConnection<TSessionService>> CreateGRpcService
     config.Locator = host;
     config.EnableSsl = (scheme == "grpcs");
     static NYdbGrpc::TGRpcClientLow client;
+    SetGrpcKeepAlive(config);
     return client.CreateGRpcServiceConnection<TSessionService>(config);
 }