mirror/groupcache
1
0
Fork 0
mirror of https://github.com/mailgun/groupcache.git synced 2024-09-28 23:00:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

set cache locally if owner is not reachable

Browse Source
This commit is contained in:
Harshavardhana 2023-10-17 23:20:51 -07:00
parent cc3d361eb2
commit ceebf94ab0
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
groupcache.go
View File

@ -243,7 +243,6 @@ func (g *Group) Get(ctx context.Context, key string, dest Sink) error {
return errors.New("groupcache: nil dest Sink")
}
value, cacheHit := g.lookupCache(key)
if cacheHit {
g.Stats.CacheHits.Add(1)
return setSinkView(dest, value)
@ -276,6 +275,8 @@ func (g *Group) Set(ctx context.Context, key string, value []byte, expire time.T
owner, ok := g.peers.PickPeer(key)
if ok {
if err := g.setFromPeer(ctx, owner, key, value, expire); err != nil {
// In-case of peer failure, set it locally.
g.localSet(key, value, expire, &g.mainCache)
return nil, err
}
// TODO(thrawn01): Not sure if this is useful outside of tests...
@ -283,10 +284,9 @@ func (g *Group) Set(ctx context.Context, key string, value []byte, expire time.T
if hotCache {
g.localSet(key, value, expire, &g.hotCache)
}
return nil, nil
} else {
g.localSet(key, value, expire, &g.mainCache)
}
// We own this key
g.localSet(key, value, expire, &g.mainCache)
return nil, nil
})
return err