grpcproxy: invalidate cache on comparison range

etcd-io · Jun 15, 2017 · 6c40d98 · 6c40d98
1 parent df88096
commit 6c40d98
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 {