From 5f5949cf2fa0bc70712fb6262ca3c81355e4d837 Mon Sep 17 00:00:00 2001 From: yukun Date: Mon, 25 Oct 2021 20:30:48 +0800 Subject: [PATCH] [skip ci]Remove unused code (#10597) Signed-off-by: fishpenguin --- .../util/rocksmq/server/rocksmq/rocksmq_retention.go | 9 --------- 1 file changed, 9 deletions(-) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go index 1ab8239711..628494609b 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go @@ -312,15 +312,6 @@ func (ri *retentionInfo) retention() error { } } ri.mutex.RUnlock() - // ri.lastRetentionTime.Range(func(k, v interface{}) bool { - // if v.(int64)+checkTime < timeNow { - // err := ri.newExpiredCleanUp(k.(string)) - // if err != nil { - // log.Warn("Retention expired clean failed", zap.Any("error", err)) - // } - // } - // return true - // }) } } }