aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorqieqieplus <admin@qieqie.me>2021-01-05 19:36:40 +0800
committerGitHub <noreply@github.com>2021-01-05 19:36:40 +0800
commitb2e50f602f23f919b6837b1207056cf1ebc7fc94 (patch)
treedf0d4e94406c4ae9e012a87a946038098933cae6
parentbbae13e41581d8fa9dca2e5df7823d15ce94afe9 (diff)
downloadseaweedfs-b2e50f602f23f919b6837b1207056cf1ebc7fc94.tar.xz
seaweedfs-b2e50f602f23f919b6837b1207056cf1ebc7fc94.zip
fix time comparison
-rw-r--r--weed/filer/rocksdb/rocksdb_ttl.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filer/rocksdb/rocksdb_ttl.go b/weed/filer/rocksdb/rocksdb_ttl.go
index 1fc239c0c..98918b5d7 100644
--- a/weed/filer/rocksdb/rocksdb_ttl.go
+++ b/weed/filer/rocksdb/rocksdb_ttl.go
@@ -29,7 +29,7 @@ func (t *TTLFilter) Filter(level int, key, val []byte) (remove bool, newVal []by
entry := filer.Entry{}
if err := entry.DecodeAttributesAndChunks(val); err == nil {
if entry.TtlSec == 0 ||
- entry.Crtime.Add(time.Duration(entry.TtlSec)*time.Second).Before(time.Now()) {
+ entry.Crtime.Add(time.Duration(entry.TtlSec)*time.Second).After(time.Now()) {
return false, val
}
}