From 5934002b57a43d8196eff28f861bdfc16bf6ae3f Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Fri, 23 Feb 2024 00:53:28 +0200 Subject: [PATCH] lib/mergeset: run `go fmt` after bace9a25011d9175f9fa6861e129f8ed8f9e0521 --- lib/mergeset/table.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/mergeset/table.go b/lib/mergeset/table.go index dfe028749b..b76a244e4b 100644 --- a/lib/mergeset/table.go +++ b/lib/mergeset/table.go @@ -158,7 +158,7 @@ type rawItemsShards struct { shards []rawItemsShard ibsToFlushLock sync.Mutex - ibsToFlush []*inmemoryBlock + ibsToFlush []*inmemoryBlock } // The number of shards for rawItems per table. @@ -203,7 +203,7 @@ func (riss *rawItemsShards) addIbsToFlush(tb *Table, ibsToFlush []*inmemoryBlock riss.updateFlushDeadline() } riss.ibsToFlush = append(riss.ibsToFlush, ibsToFlush...) - if len(riss.ibsToFlush) >= maxBlocksPerShard * cgroup.AvailableCPUs() { + if len(riss.ibsToFlush) >= maxBlocksPerShard*cgroup.AvailableCPUs() { ibsToMerge = ibsToFlush riss.ibsToFlush = nil }