Pārlūkot izejas kodu

etcdserver: support lease txn comparison

Anthony Romano 8 gadi atpakaļ
vecāks
revīzija
ec4ca4408f
1 mainītis faili ar 5 papildinājumiem un 0 dzēšanām
  1. 5 0
      etcdserver/apply.go

+ 5 - 0
etcdserver/apply.go

@@ -473,6 +473,11 @@ func compareKV(c *pb.Compare, ckv mvccpb.KeyValue) bool {
 			rev = tv.Version
 		}
 		result = compareInt64(ckv.Version, rev)
+	case pb.Compare_LEASE:
+		if tv, _ := c.TargetUnion.(*pb.Compare_Lease); tv != nil {
+			rev = tv.Lease
+		}
+		result = compareInt64(ckv.Lease, rev)
 	}
 	switch c.Result {
 	case pb.Compare_EQUAL: