equal
deleted
inserted
replaced
393 hooks processes) accessing data before a transaction is finalized. |
393 hooks processes) accessing data before a transaction is finalized. |
394 |
394 |
395 ``concurrencychecker`` will be passed to the revlog init function, see |
395 ``concurrencychecker`` will be passed to the revlog init function, see |
396 the documentation there. |
396 the documentation there. |
397 """ |
397 """ |
398 |
|
399 revlog.revlog.__init__( |
398 revlog.revlog.__init__( |
400 self, |
399 self, |
401 opener, |
400 opener, |
402 target=(revlog_constants.KIND_CHANGELOG, None), |
401 target=(revlog_constants.KIND_CHANGELOG, None), |
403 radix=b'00changelog', |
402 radix=b'00changelog', |
482 self._enforceinlinesize(tr) |
481 self._enforceinlinesize(tr) |
483 |
482 |
484 def _writepending(self, tr): |
483 def _writepending(self, tr): |
485 """create a file containing the unfinalized state for |
484 """create a file containing the unfinalized state for |
486 pretxnchangegroup""" |
485 pretxnchangegroup""" |
|
486 if self._docket: |
|
487 return self._docket.write(tr, pending=True) |
487 if self._delaybuf: |
488 if self._delaybuf: |
488 # make a temporary copy of the index |
489 # make a temporary copy of the index |
489 fp1 = self._realopener(self._indexfile) |
490 fp1 = self._realopener(self._indexfile) |
490 pendingfilename = self._indexfile + b".a" |
491 pendingfilename = self._indexfile + b".a" |
491 # register as a temp file to ensure cleanup on failure |
492 # register as a temp file to ensure cleanup on failure |