From aeb2dc03aa76dd695d4a46765e202dabed221842 Mon Sep 17 00:00:00 2001 From: Anthony Romano Date: Mon, 5 Jun 2017 15:18:33 -0700 Subject: [PATCH] grpcproxy: invalidate cache on comparison range --- proxy/grpcproxy/kv.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/proxy/grpcproxy/kv.go b/proxy/grpcproxy/kv.go index 65f850ed4..c68f1b1c5 100644 --- a/proxy/grpcproxy/kv.go +++ b/proxy/grpcproxy/kv.go @@ -123,7 +123,7 @@ func (p *kvProxy) Txn(ctx context.Context, r *pb.TxnRequest) (*pb.TxnResponse, e } // txn may claim an outdated key is updated; be safe and invalidate for _, cmp := range r.Compare { - p.cache.Invalidate(cmp.Key, nil) + p.cache.Invalidate(cmp.Key, cmp.RangeEnd) } // update any fetched keys if resp.Succeeded {