Skip to content

Commit 6573769

Browse files
authored
[dbnode] Only extend reverse index retention up (#2745)
1 parent 0a74633 commit 6573769

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

src/dbnode/storage/index.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2181,7 +2181,9 @@ func (i *nsIndex) SetExtendedRetentionPeriod(period time.Duration) {
21812181
i.state.Lock()
21822182
defer i.state.Unlock()
21832183

2184-
i.extendedRetentionPeriod = period
2184+
if period > i.extendedRetentionPeriod {
2185+
i.extendedRetentionPeriod = period
2186+
}
21852187
}
21862188

21872189
func (i *nsIndex) effectiveRetentionPeriodWithLock() time.Duration {

src/dbnode/storage/index_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -391,9 +391,9 @@ func TestNamespaceIndexSetExtendedRetentionPeriod(t *testing.T) {
391391
idx.SetExtendedRetentionPeriod(longerRetention)
392392
assert.Equal(t, longerRetention, idx.effectiveRetentionPeriodWithLock())
393393

394-
shorterRetention := originalRetention - time.Minute
394+
shorterRetention := longerRetention - time.Second
395395
idx.SetExtendedRetentionPeriod(shorterRetention)
396-
assert.Equal(t, originalRetention, idx.effectiveRetentionPeriodWithLock())
396+
assert.Equal(t, longerRetention, idx.effectiveRetentionPeriodWithLock())
397397
}
398398

399399
func verifyFlushForShards(

0 commit comments

Comments
 (0)