Reset ClockSkew on disconnect KIKIMR-14460

REVIEW: 2366331

REVIEW: 2367535
x-ydb-stable-ref: 810fd3595838f974804bd23f35865eb0fbc9108e

2 files changed, 6 insertions, 0 deletions

diff --git a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
index 0abe9fe6598..c7fca64c600 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
@@ -430,6 +430,11 @@ namespace NActors {
         Socket.Reset();
     }
 
+    void TInputSessionTCP::PassAway() {
+        Metrics->SetClockSkewMicrosec(0);
+        TActorBootstrapped::PassAway();
+    }
+
     void TInputSessionTCP::HandleCheckDeadPeer() {
         const TInstant now = TActivationContext::Now();
         if (now >= LastReceiveTimestamp + DeadPeerTimeout) {
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.h b/library/cpp/actors/interconnect/interconnect_tcp_session.h
index 7fc00dbcc5a..c7f3113b55a 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_session.h
+++ b/library/cpp/actors/interconnect/interconnect_tcp_session.h
@@ -255,6 +255,7 @@ namespace NActors {
 
         void ReestablishConnection(TDisconnectReason reason);
         void DestroySession(TDisconnectReason reason);
+        void PassAway() override;
 
         TDeque<TIntrusivePtr<TRopeAlignedBuffer>> Buffers;