class FixLeases(object):
- cache = {}
-
def __init__(self, path):
self.path = path
- self._leases = self.cache[self.path] = self._parse()
+ self._leases = self._parse()
def __iter__(self):
return iter(self._leases)
def _parse(self):
log.info("Reading fix leases from %s" % self.path)
- leases = []
now = datetime.datetime.utcnow()
+ leases = []
+
with open(self.path) as f:
for line in f.readlines():
line = line.rstrip()
})
leases.append(l)
- # Try finding any deleted leases
- for lease in self.cache.get(self.path, []):
- if lease in leases:
- continue
-
- # Free the deleted lease
- lease.free()
- leases.append(lease)
-
return leases