diff options
author | alexvru <alexvru@ydb.tech> | 2023-04-28 16:50:08 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2023-04-28 16:50:08 +0300 |
commit | 96420874808e5be85bdbe54cdbe3138ed81a8974 (patch) | |
tree | d9e1dfbadbdbb5f1b884cc20a636538a3f5a14f6 | |
parent | 3ceaa4dbb53b14736831edeb57fb670a2f0180da (diff) | |
download | ydb-96420874808e5be85bdbe54cdbe3138ed81a8974.tar.gz |
Disable by default syncer job timeout
-rw-r--r-- | ydb/core/blobstorage/vdisk/common/vdisk_config.cpp | 2 | ||||
-rw-r--r-- | ydb/core/blobstorage/vdisk/syncer/syncer_job_actor.cpp | 4 |
2 files changed, 4 insertions, 2 deletions
diff --git a/ydb/core/blobstorage/vdisk/common/vdisk_config.cpp b/ydb/core/blobstorage/vdisk/common/vdisk_config.cpp index 47c169ad88a..b62819d4170 100644 --- a/ydb/core/blobstorage/vdisk/common/vdisk_config.cpp +++ b/ydb/core/blobstorage/vdisk/common/vdisk_config.cpp @@ -49,7 +49,7 @@ namespace NKikimr { RecoveryLogCutterRegularDuration = TDuration::Seconds(30); AdvanceEntryPointTimeout = TDuration::Seconds(10); // 10 seconds (FIXME: use feedback from PDisk) SyncTimeInterval = TDuration::Seconds(3); // 3 seconds - SyncJobTimeout = TDuration::Minutes(30); // 30 minutes + SyncJobTimeout = TDuration::Max(); // disabled SyncerRLDRetryTimeout = TDuration::Seconds(1); AnubisTimeout = TDuration::Minutes(60); RunSyncer = true; diff --git a/ydb/core/blobstorage/vdisk/syncer/syncer_job_actor.cpp b/ydb/core/blobstorage/vdisk/syncer/syncer_job_actor.cpp index c1a1629bf11..5b74997e947 100644 --- a/ydb/core/blobstorage/vdisk/syncer/syncer_job_actor.cpp +++ b/ydb/core/blobstorage/vdisk/syncer/syncer_job_actor.cpp @@ -125,7 +125,9 @@ namespace NKikimr { void Bootstrap(const TActorContext &ctx) { // don't run sync job for too long - ctx.Schedule(SyncerCtx->Config->SyncJobTimeout, new TEvents::TEvWakeup()); + if (const auto timeout = SyncerCtx->Config->SyncJobTimeout; timeout != TDuration::Max()) { + ctx.Schedule(timeout, new TEvents::TEvWakeup()); + } // initiate requests TSjOutcome outcome = Task->NextRequest(); |