mirror/groupcache
1
0
Fork 0
mirror of https://github.com/mailgun/groupcache.git synced 2024-10-01 12:22:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove now inits peers if needed

Browse Source
This commit is contained in:
Derrick J. Wippler 2019-05-23 12:40:01 -05:00
parent 82209d3632
commit 2ce33c3fea
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
groupcache.go
View File

@ -241,6 +241,8 @@ func (g *Group) Get(ctx Context, key string, dest Sink) error {
// Remove clears the key from our cache then forwards the remove // Remove clears the key from our cache then forwards the remove
// request to all peers. // request to all peers.
func (g *Group) Remove(ctx Context, key string) error { func (g *Group) Remove(ctx Context, key string) error {
g.peersOnce.Do(g.initPeers)
_, err := g.removeGroup.Do(key, func() (interface{}, error) { _, err := g.removeGroup.Do(key, func() (interface{}, error) {
// Remove from key owner first // Remove from key owner first