From 42ccdf31c797855af6e36fa2e057ef26e843792d Mon Sep 17 00:00:00 2001 From: priyanjaligupta <168761763+priyanjaligupta@users.noreply.github.com> Date: Mon, 6 May 2024 21:40:17 +0530 Subject: [PATCH] bug fix Delete keys locally if _copyOption is set to false. (#352) Co-authored-by: Arvind Chandavarapu Co-authored-by: vazois <96085550+vazois@users.noreply.github.com> --- libs/cluster/Server/Migration/MigrateSessionSlots.cs | 2 +- libs/cluster/Server/Migration/MigrationDriver.cs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/libs/cluster/Server/Migration/MigrateSessionSlots.cs b/libs/cluster/Server/Migration/MigrateSessionSlots.cs index 1089a2de2..33020408a 100644 --- a/libs/cluster/Server/Migration/MigrateSessionSlots.cs +++ b/libs/cluster/Server/Migration/MigrateSessionSlots.cs @@ -56,7 +56,7 @@ private bool MigrateSlotsDataDriver() /// public void DeleteKeysInSlot() { - if (!_copyOption) + if (_copyOption) return; ClusterManager.DeleteKeysInSlotsFromMainStore(localServerSession.BasicGarnetApi, _sslots); diff --git a/libs/cluster/Server/Migration/MigrationDriver.cs b/libs/cluster/Server/Migration/MigrationDriver.cs index e84e6e3af..a243a9611 100644 --- a/libs/cluster/Server/Migration/MigrationDriver.cs +++ b/libs/cluster/Server/Migration/MigrationDriver.cs @@ -29,8 +29,8 @@ public bool TryStartMigrationTask(out ReadOnlySpan errorMessage) return false; } - // Delete keys locally if option enabled - if (_copyOption) + // Delete keys locally if _copyOption is set to false. + if (!_copyOption) DeleteKeys(_keysWithSize); Status = MigrateState.SUCCESS; }