Merge pull request #26 from beam-cloud/np/fix-concurrent-map-iteration-and-write

fix: concurrent map iteration and map write panic

Author: nickpetrovic

pkg/client.go

@@ -330,15 +330,20 @@ func (c *BlobCacheClient) manageLocalClientCache(ttl time.Duration, interval tim
 			select {
 			case <-ticker.C:
 				now := time.Now()
+				stale := make([]string, 0)
 
 				for hash, entry := range c.localHostCache {
 					if now.Sub(entry.timestamp) > ttl {
-						c.mu.Lock()
-						delete(c.localHostCache, hash)
-						c.mu.Unlock()
+						stale = append(stale, hash)
 					}
 				}
 
+				c.mu.Lock()
+				for _, hash := range stale {
+					delete(c.localHostCache, hash)
+				}
+				c.mu.Unlock()
+
 			case <-c.ctx.Done():
 				return
 			}