while True:
try:
with self.lock:
+ self.last_epoch = self.epoch
for i, direntry in enumerate(StatsVector(self, self.directory_vector, self.elementfmt)):
path_raw = direntry[2].find(b'\x00')
path = direntry[2][:path_raw].decode('ascii')
directory[path] = StatsEntry(direntry[0], direntry[1])
directory_by_idx[i] = path
- self.last_epoch = self.epoch
self.directory = directory
self.directory_by_idx = directory_by_idx
self.error_vectors = []
for threads in StatsVector(self, self.error_vector, 'P'):
self.error_vectors.append(StatsVector(self, threads[0], 'Q'))
- return
+ # Return statement must be outside the lock block to be sure
+ # lock.release is executed
+ return
except IOError:
if not blocking:
raise
if self.last_epoch != self.epoch:
self.refresh(blocking)
with self.lock:
- return self.directory[item].get_counter(self)
+ result = self.directory[item].get_counter(self)
+ # Return statement must be outside the lock block to be sure
+ # lock.release is executed
+ return result
except IOError:
if not blocking:
raise
if self.last_epoch != self.epoch:
self.refresh(blocking)
with self.lock:
- return sum(self.directory[name].get_counter(self))
+ result = sum(self.directory[name].get_counter(self))
+ # Return statement must be outside the lock block to be sure
+ # lock.release is executed
+ return result
except IOError:
if not blocking:
raise