Browse Source

lease: fix restore

Xiang Li 10 years ago
parent
commit
e925a359a2
1 changed files with 2 additions and 2 deletions
  1. 2 2
      lease/lessor.go

+ 2 - 2
lease/lessor.go

@@ -380,10 +380,10 @@ func (le *lessor) initAndRecover() {
 		le.leaseMap[ID] = &Lease{
 		le.leaseMap[ID] = &Lease{
 			ID:  ID,
 			ID:  ID,
 			TTL: lpb.TTL,
 			TTL: lpb.TTL,
-
 			// itemSet will be filled in when recover key-value pairs
 			// itemSet will be filled in when recover key-value pairs
 			// set expiry to forever, refresh when promoted
 			// set expiry to forever, refresh when promoted
-			expiry: forever,
+			itemSet: make(map[LeaseItem]struct{}),
+			expiry:  forever,
 		}
 		}
 	}
 	}
 	tx.Unlock()
 	tx.Unlock()