Reset ClockSkew on disconnect KIKIMR-14460

ref:c8c3ffe185bbaa21b2c319c1b7efc7ae0c402400

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 0abe9fe659..c7fca64c60 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 7fc00dbcc5..c7f3113b55 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;