Browse Source

Reset ClockSkew on disconnect KIKIMR-14460

ref:c8c3ffe185bbaa21b2c319c1b7efc7ae0c402400
Alexander Rutkovsky 3 years ago
parent
commit
7ce58bf82a

+ 5 - 0
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) {

+ 1 - 0
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;