summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
diff options
context:
space:
mode:
authorandrew-rykov <[email protected]>2023-10-30 20:07:43 +0300
committerandrew-rykov <[email protected]>2023-10-30 20:42:41 +0300
commit8ccc99f1093aa077b04d35edfed58e21a01f0dcd (patch)
tree690a5c47451f5dc79353770e510debc3bca2c9a9 /library/cpp/actors/interconnect/interconnect_tcp_session.cpp
parentf3fc65218eee3457eb087a9f6df33d5a797075c5 (diff)
KIKIMR-19066 added hc optimal clock skew calculation
Interconnect в режиме реального времени отправляет данные о разнице во времени (ClockSkew) между собой и каждым подключенным пиром на whiteboard. На whiteboard эта информация собирается за период в 15 секунд, и из всех значений выбирается максимальное. Этот максимальный ClockSkew затем используется в ответах на запросы healthcheck-а в течение следующих 15 секунд.
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_tcp_session.cpp')
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_session.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
index a7509fbc940..25c05898d2a 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
@@ -994,13 +994,15 @@ namespace NActors {
} while (false);
}
- callback(Proxy->Metrics->GetHumanFriendlyPeerHostName(),
+ callback({TlsActivationContext->ExecutorThread.ActorSystem,
+ Proxy->PeerNodeId,
+ Proxy->Metrics->GetHumanFriendlyPeerHostName(),
connected,
flagState == EFlag::GREEN,
flagState == EFlag::YELLOW,
flagState == EFlag::ORANGE,
flagState == EFlag::RED,
- TlsActivationContext->ExecutorThread.ActorSystem);
+ ReceiveContext->ClockSkew_us.load()});
}
if (connected) {