diff options
author | andrew-rykov <[email protected]> | 2023-10-30 20:07:43 +0300 |
---|---|---|
committer | andrew-rykov <[email protected]> | 2023-10-30 20:42:41 +0300 |
commit | 8ccc99f1093aa077b04d35edfed58e21a01f0dcd (patch) | |
tree | 690a5c47451f5dc79353770e510debc3bca2c9a9 /library/cpp/actors/interconnect/interconnect_tcp_session.cpp | |
parent | f3fc65218eee3457eb087a9f6df33d5a797075c5 (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.cpp | 6 |
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) { |