Merge pull request #10327 from namreg/fix-grpcproxy-memory-leak
grpcproxy: fix memory leakrelease-3.4
commit
abb57363ba
|
@ -99,9 +99,12 @@ func (c *cache) Add(req *pb.RangeRequest, resp *pb.RangeResponse) {
|
||||||
iv = c.cachedRanges.Find(ivl)
|
iv = c.cachedRanges.Find(ivl)
|
||||||
|
|
||||||
if iv == nil {
|
if iv == nil {
|
||||||
c.cachedRanges.Insert(ivl, []string{key})
|
val := map[string]struct{}{key: {}}
|
||||||
|
c.cachedRanges.Insert(ivl, val)
|
||||||
} else {
|
} else {
|
||||||
iv.Val = append(iv.Val.([]string), key)
|
val := iv.Val.(map[string]struct{})
|
||||||
|
val[key] = struct{}{}
|
||||||
|
iv.Val = val
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -141,8 +144,8 @@ func (c *cache) Invalidate(key, endkey []byte) {
|
||||||
|
|
||||||
ivs = c.cachedRanges.Stab(ivl)
|
ivs = c.cachedRanges.Stab(ivl)
|
||||||
for _, iv := range ivs {
|
for _, iv := range ivs {
|
||||||
keys := iv.Val.([]string)
|
keys := iv.Val.(map[string]struct{})
|
||||||
for _, key := range keys {
|
for key := range keys {
|
||||||
c.lru.Remove(key)
|
c.lru.Remove(key)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue