|
@@ -1448,13 +1448,12 @@ class LoggedIO:
|
|
|
|
|
|
def cleanup(self, transaction_id):
|
|
|
"""Delete segment files left by aborted transactions"""
|
|
|
+ self.close_segment()
|
|
|
self.segment = transaction_id + 1
|
|
|
count = 0
|
|
|
for segment, filename in self.segment_iterator(reverse=True):
|
|
|
if segment > transaction_id:
|
|
|
- if segment in self.fds:
|
|
|
- del self.fds[segment]
|
|
|
- safe_unlink(filename)
|
|
|
+ self.delete_segment(segment)
|
|
|
count += 1
|
|
|
else:
|
|
|
break
|