scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-11 23:31:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

adjust locking

Browse source
This commit is contained in:
Samir Patel 2021-05-28 13:18:15 -05:00 • committed by Samir Patel
parent 4b7e0e9194
commit a7620012fa
1 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
api.go
View file

@ -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 {