equal
deleted
inserted
replaced
2226 tr.addabort(callback_id, abort_callback) |
2226 tr.addabort(callback_id, abort_callback) |
2227 |
2227 |
2228 new_dfh = self._datafp(b'w+') |
2228 new_dfh = self._datafp(b'w+') |
2229 new_dfh.truncate(0) # drop any potentially existing data |
2229 new_dfh.truncate(0) # drop any potentially existing data |
2230 try: |
2230 try: |
2231 with self._indexfp() as read_ifh: |
2231 with self.reading(): |
2232 for r in self: |
2232 for r in self: |
2233 new_dfh.write(self._getsegmentforrevs(r, r, df=read_ifh)[1]) |
2233 new_dfh.write(self._getsegmentforrevs(r, r)[1]) |
2234 new_dfh.flush() |
2234 new_dfh.flush() |
2235 |
2235 |
2236 if side_write: |
2236 if side_write: |
2237 self._indexfile = new_index_file_path |
2237 self._indexfile = new_index_file_path |
2238 with self.__index_new_fp() as fp: |
2238 with self.__index_new_fp() as fp: |