From b13aa8f172343ae1db14df16df8b8fa5ba8ff18f Mon Sep 17 00:00:00 2001 From: vyzo Date: Tue, 1 Feb 2022 11:30:21 +0200 Subject: [PATCH] unblock waitForSync on close --- blockstore/splitstore/splitstore.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/blockstore/splitstore/splitstore.go b/blockstore/splitstore/splitstore.go index 75d54533e..6a65e01df 100644 --- a/blockstore/splitstore/splitstore.go +++ b/blockstore/splitstore/splitstore.go @@ -665,6 +665,11 @@ func (s *SplitStore) Close() error { } if atomic.LoadInt32(&s.compacting) == 1 { + s.txnSyncMx.Lock() + s.txnSync = true + s.txnSyncCond.Broadcast() + s.txnSyncMx.Unlock() + log.Warn("close with ongoing compaction in progress; waiting for it to finish...") for atomic.LoadInt32(&s.compacting) == 1 { time.Sleep(time.Second)