temp fix: do not schedule counters dump

fix fix

quick fix for mirrorer only

another fix

2 files changed, 7 insertions, 9 deletions

diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.cpp b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.cpp
index 85c6e87589..1bdb5307ad 100644
--- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.cpp
+++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.cpp
@@ -178,7 +178,7 @@ void TReadSession::ProceedWithoutClusterDiscovery() {
         clusterSessionInfo.Topics = Settings.Topics_;
         CreateClusterSessionsImpl(deferred);
     }
-    ScheduleDumpCountersToLog();
+    // ScheduleDumpCountersToLog();
 }
 
 void TReadSession::CreateClusterSessionsImpl(TDeferredActions<true>& deferred) {
@@ -320,7 +320,7 @@ void TReadSession::OnClusterDiscovery(const TStatus& status, const Ydb::PersQueu
 
         CreateClusterSessionsImpl(deferred);
     }
-    ScheduleDumpCountersToLog();
+    // ScheduleDumpCountersToLog();
 }
 
 void TReadSession::RestartClusterDiscoveryImpl(TDuration delay, TDeferredActions<true>& deferred) {
@@ -604,7 +604,7 @@ void TReadSession::DumpCountersToLog(size_t timeNumber) {
 
 #undef C
 
-    ScheduleDumpCountersToLog(timeNumber + 1);
+    // ScheduleDumpCountersToLog(timeNumber + 1);
 }
 
 void TReadSession::ScheduleDumpCountersToLog(size_t timeNumber) {
diff --git a/ydb/public/sdk/cpp/client/ydb_topic/impl/read_session.cpp b/ydb/public/sdk/cpp/client/ydb_topic/impl/read_session.cpp
index f3ac5aab2e..fb34090739 100644
--- a/ydb/public/sdk/cpp/client/ydb_topic/impl/read_session.cpp
+++ b/ydb/public/sdk/cpp/client/ydb_topic/impl/read_session.cpp
@@ -60,7 +60,7 @@ void TReadSession::Start() {
         Topics = Settings.Topics_;
         CreateClusterSessionsImpl(deferred);
     }
-    ScheduleDumpCountersToLog();
+    // ScheduleDumpCountersToLog();
 }
 
 void TReadSession::CreateClusterSessionsImpl(NPersQueue::TDeferredActions<false>& deferred) {
@@ -390,7 +390,7 @@ void TReadSession::DumpCountersToLog(size_t timeNumber) {
 
 #undef C
 
-    ScheduleDumpCountersToLog(timeNumber + 1);
+    // ScheduleDumpCountersToLog(timeNumber + 1);
 }
 
 void TReadSession::ScheduleDumpCountersToLog(size_t timeNumber) {
@@ -400,11 +400,9 @@ void TReadSession::ScheduleDumpCountersToLog(size_t timeNumber) {
         }
         DumpCountersContext = Connections->CreateContext();
         if (DumpCountersContext) {
-            auto callback = [self = weak_from_this(), timeNumber](bool ok) {
+            auto callback = [self = shared_from_this(), timeNumber](bool ok) {
                 if (ok) {
-                    if (auto sharedSelf = self.lock()) {
-                        sharedSelf->DumpCountersToLog(timeNumber);
-                    }
+                    self->DumpCountersToLog(timeNumber);
                 }
             };
             Connections->ScheduleCallback(TDuration::Seconds(1),