equal
deleted
inserted
replaced
479 fp.write(b"".join(self._delaybuf)) |
479 fp.write(b"".join(self._delaybuf)) |
480 fp.close() |
480 fp.close() |
481 self._delaybuf = None |
481 self._delaybuf = None |
482 self._divert = False |
482 self._divert = False |
483 # split when we're done |
483 # split when we're done |
484 self._enforceinlinesize(tr) |
484 self._enforceinlinesize(tr, side_write=False) |
485 |
485 |
486 def _writepending(self, tr): |
486 def _writepending(self, tr): |
487 """create a file containing the unfinalized state for |
487 """create a file containing the unfinalized state for |
488 pretxnchangegroup""" |
488 pretxnchangegroup""" |
489 if self._docket: |
489 if self._docket: |
510 if self._divert: |
510 if self._divert: |
511 return True |
511 return True |
512 |
512 |
513 return False |
513 return False |
514 |
514 |
515 def _enforceinlinesize(self, tr): |
515 def _enforceinlinesize(self, tr, side_write=True): |
516 if not self._delayed: |
516 if not self._delayed: |
517 revlog.revlog._enforceinlinesize(self, tr) |
517 revlog.revlog._enforceinlinesize(self, tr, side_write=side_write) |
518 |
518 |
519 def read(self, nodeorrev): |
519 def read(self, nodeorrev): |
520 """Obtain data from a parsed changelog revision. |
520 """Obtain data from a parsed changelog revision. |
521 |
521 |
522 Returns a 6-tuple of: |
522 Returns a 6-tuple of: |