lock while reading map (#30)

dleviminzi · web-flow · commit 72fd4dc7f710 · 2025-03-05T11:54:52.000-05:00
diff --git a/pkg/client.go b/pkg/client.go
@@ -332,12 +332,13 @@ func (c *BlobCacheClient) manageLocalClientCache(ttl time.Duration, interval tim
 				now := time.Now()
 				stale := make([]string, 0)
 
+				c.mu.RLock()
 				for hash, entry := range c.localHostCache {
 					if now.Sub(entry.timestamp) > ttl {
 						stale = append(stale, hash)
 					}
 				}
-
+				c.mu.RUnlock()
 				c.mu.Lock()
 				for _, hash := range stale {
 					delete(c.localHostCache, hash)

Original file line number	Diff line number	Diff line change
`@@ -332,12 +332,13 @@ func (c *BlobCacheClient) manageLocalClientCache(ttl time.Duration, interval tim`
`332`	`332`	`now := time.Now()`
`333`	`333`	`stale := make([]string, 0)`
`334`	`334`
	`335`	`+ c.mu.RLock()`
`335`	`336`	`for hash, entry := range c.localHostCache {`
`336`	`337`	`if now.Sub(entry.timestamp) > ttl {`
`337`	`338`	`stale = append(stale, hash)`
`338`	`339`	`}`
`339`	`340`	`}`
`340`		`-`
	`341`	`+ c.mu.RUnlock()`
`341`	`342`	`c.mu.Lock()`
`342`	`343`	`for _, hash := range stale {`
`343`	`344`	`delete(c.localHostCache, hash)`