From b5a0fd285fc37b6d90e7e3f2a3dbf08690e218ae Mon Sep 17 00:00:00 2001 From: Janos Guljas Date: Wed, 19 Dec 2018 14:34:37 +0100 Subject: [PATCH] swarm/storage/localstore: add triggerGarbageCollection function --- swarm/storage/localstore/gc.go | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/swarm/storage/localstore/gc.go b/swarm/storage/localstore/gc.go index cd1cd072de..1f1b774ff8 100644 --- a/swarm/storage/localstore/gc.go +++ b/swarm/storage/localstore/gc.go @@ -55,10 +55,7 @@ func (db *DB) collectGarbageWorker() { } // check if another gc run is needed if !done { - select { - case db.collectGarbageTrigger <- struct{}{}: - default: - } + db.triggerGarbageCollection() } if testHookCollectGarbage != nil { @@ -131,10 +128,16 @@ func (db *DB) incGCSize(count int64) { default: } if new >= db.capacity { - select { - case db.collectGarbageTrigger <- struct{}{}: - default: - } + db.triggerGarbageCollection() + } +} + +// triggerGarbageCollection signals collectGarbageWorker +// to call collectGarbage. +func (db *DB) triggerGarbageCollection() { + select { + case db.collectGarbageTrigger <- struct{}{}: + default: } }