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

simplify if statement in calcUsage()

Browse source
This commit is contained in:
Samir Patel 2021-05-25 22:42:18 -05:00 • committed by Samir Patel
parent e8b9fa0482
commit 42067237f7
1 changed files with 2 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
api.go
View file

@ -975,11 +975,7 @@ func (api *API) calculateUsage() {
api.usageCache.mu.Lock()
defer api.usageCache.mu.Unlock()
// if api.usageCache.lastUpdated.After(time.Now().Add(time.Minute * time.Duration(api.usageCache.refreshInterval) * -1)) {
if time.Since(api.usageCache.lastUpdated) < api.usageCache.refreshInterval {
fmt.Printf("RefreshRate, too soon: time: %v, current time: %v \n", api.usageCache.lastUpdated, time.Now())
return
} else {
if time.Since(api.usageCache.lastUpdated) > api.usageCache.refreshInterval {
fmt.Printf("RefreshRate, expired: time: %v, current time: %v \n", api.usageCache.lastUpdated, time.Now())
api.usageCache.data = make(map[string]NodeUsage)
@ -1022,10 +1018,7 @@ func (api *API) calculateUsage() {
LastUpdated: time.Now(),
}
api.usageCache.data[api.server.nodeID] = nodeUsage
}
api.usageCache.lastUpdated = time.Now()
}
// Periodically calculates disk usage
@ -1037,6 +1030,7 @@ func (api *API) RefreshUsageCache(refresh time.Duration) {
for {
api.calculateUsage()
api.requestUsageOfNodes()
api.usageCache.lastUpdated = time.Now()
time.Sleep(api.usageCache.refreshInterval)
}
}