diff --git a/metanode/partition_fsmop_inode.go b/metanode/partition_fsmop_inode.go index bbc5df2e5..eab9dd31d 100644 --- a/metanode/partition_fsmop_inode.go +++ b/metanode/partition_fsmop_inode.go @@ -1153,9 +1153,13 @@ func (mp *metaPartition) internalDeleteInodeMigrationExtentKey(inoParam *Inode) return } ino := item.(*Inode) + ino.Lock() + defer ino.Unlock() ino.HybridCouldExtentsMigration.storageClass = proto.StorageClass_Unspecified ino.HybridCouldExtentsMigration.expiredTime = 0 ino.HybridCouldExtentsMigration.sortedEks = nil + // reset DeleteMigrationExtentKeyFlag for future deletion of inode + ino.Flag ^= DeleteMigrationExtentKeyFlag log.LogDebugf("internalDeleteInodeMigrationExtentKey: partitionID(%v) inode(%v)", mp.config.PartitionId, inoParam.Inode) return