From a7620012fa738d2e28832988d463a9998def13b9 Mon Sep 17 00:00:00 2001 From: Samir Patel Date: Fri, 28 May 2021 13:18:15 -0500 Subject: [PATCH] adjust locking --- api.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/api.go b/api.go index b87da538c..b9e10f405 100644 --- a/api.go +++ b/api.go @@ -976,9 +976,9 @@ func (api *API) requestUsageOfNodes() { api.server.logger.Infof("couldn't collect disk usage from %s: %s", node.URI, err) } - // api.usageCache.muRead.Lock() + api.usageCache.muWrite.Lock() api.usageCache.data[node.ID] = nodeUsage[node.ID] - // api.usageCache.muRead.Unlock() + api.usageCache.muWrite.Unlock() } } @@ -987,10 +987,8 @@ func (api *API) calculateUsage() { api.usageCache.muWrite.Lock() defer api.usageCache.muWrite.Unlock() api.server.wg.Add(1) - // api.usageCache.muRead.Lock() - lastUpdated := api.usageCache.lastUpdated - // api.usageCache.muRead.Unlock() + lastUpdated := api.usageCache.lastUpdated if time.Since(lastUpdated) > api.usageCache.refreshInterval { indexDetails, nodeMetadataBytes, err := api.holder.Txf().IndexUsageDetails() if err != nil {