equal
deleted
inserted
replaced
367 self._docket.write(tr) |
367 self._docket.write(tr) |
368 self._v2_delayed = False |
368 self._v2_delayed = False |
369 else: |
369 else: |
370 new_index_file = self._inner.finalize_pending() |
370 new_index_file = self._inner.finalize_pending() |
371 self._indexfile = new_index_file |
371 self._indexfile = new_index_file |
372 # split when we're done |
372 if self._inline: |
373 self._enforceinlinesize(tr, side_write=False) |
373 msg = 'changelog should not be inline at that point' |
|
374 raise error.ProgrammingError(msg) |
374 |
375 |
375 def _writepending(self, tr): |
376 def _writepending(self, tr): |
376 """create a file containing the unfinalized state for |
377 """create a file containing the unfinalized state for |
377 pretxnchangegroup""" |
378 pretxnchangegroup""" |
378 assert not self._inner.is_open |
379 assert not self._inner.is_open |