From 01b5a21ebd8371bc59e1fc5c864b07ed76dd08ec Mon Sep 17 00:00:00 2001 From: cheetah Date: Tue, 4 Jul 2023 02:51:09 -0500 Subject: [PATCH] adjusted something --- storageserver/storageserver.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/storageserver/storageserver.go b/storageserver/storageserver.go index 3f3aaf7..72c78ed 100644 --- a/storageserver/storageserver.go +++ b/storageserver/storageserver.go @@ -389,6 +389,7 @@ func (p *PoolMaster) ScanForLocalPools() (err error) { return err } p.CurrentPool[string(workerBytes)] = restoredPool + fmt.Println(string(workerBytes)) } } } @@ -778,7 +779,6 @@ func (p *PoolMaster) FetchLoadWORM(chunkID string, fileID string, writer io.Writ } fmt.Printf("extracted and key = %s\n", loadedWormPool.PoolID) p.WORMPools[loadedWormPool.PoolID] = &loadedWormPool - fmt.Println(p.WORMPools) return loadedWormPool.Fetch(fileID, writer) //return nil } @@ -798,7 +798,7 @@ func (p *PoolMaster) CleanWORMTemp() (err error) { return nil } func (p *PoolMaster) PackFullPools() (err error) { - if len(poolMaster.FullPools) > 0 { + if len(poolMaster.FullPools) >= 16 { poolMaster.lock.Lock() fmt.Printf("Aquiring WORMLock for Regular FullPool Pack\n") //poolMaster.WORMLock.Lock() @@ -807,7 +807,7 @@ func (p *PoolMaster) PackFullPools() (err error) { var deletedPools []string var poolChannelCounter = 0 for _, fullPool := range poolMaster.FullPools { - if time.Since(fullPool.LastTouchy).Minutes() < 1 { + if time.Since(fullPool.LastTouchy).Minutes() < 5 { continue } // start parallel