From ac82899e850dc5bfe52be73307c72117e5592e0f Mon Sep 17 00:00:00 2001 From: ZhangTao1596 Date: Wed, 19 Jan 2022 17:51:58 +0800 Subject: [PATCH] [#1088] writecache: Fix small flushed when persist Signed-off-by: ZhangTao1596 --- pkg/local_object_storage/writecache/persist.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/local_object_storage/writecache/persist.go b/pkg/local_object_storage/writecache/persist.go index 035e8e8dd..491d293fa 100644 --- a/pkg/local_object_storage/writecache/persist.go +++ b/pkg/local_object_storage/writecache/persist.go @@ -79,12 +79,14 @@ func (c *cache) persistSmallObjects(objs []objectInfo) { if err != nil { overflowIndex = 0 } else { - c.evictObjects(overflowIndex) + c.evictObjects(len(objs) - overflowIndex) } for i := 0; i < overflowIndex; i++ { storagelog.Write(c.log, storagelog.AddressField(objs[i].addr), storagelog.OpField("db PUT")) c.objCounters.IncDB() + } + for i := overflowIndex; i < len(objs); i++ { c.flushed.Add(objs[i].addr, true) }