equal
deleted
inserted
replaced
660 d += readexactly(self._fh, n - len(d)) |
660 d += readexactly(self._fh, n - len(d)) |
661 return d |
661 return d |
662 return readexactly(self._fh, n) |
662 return readexactly(self._fh, n) |
663 |
663 |
664 |
664 |
665 def _revisiondeltatochunks(delta, headerfn): |
665 def _revisiondeltatochunks(repo, delta, headerfn): |
666 """Serialize a revisiondelta to changegroup chunks.""" |
666 """Serialize a revisiondelta to changegroup chunks.""" |
667 |
667 |
668 # The captured revision delta may be encoded as a delta against |
668 # The captured revision delta may be encoded as a delta against |
669 # a base revision or as a full revision. The changegroup format |
669 # a base revision or as a full revision. The changegroup format |
670 # requires that everything on the wire be deltas. So for full |
670 # requires that everything on the wire be deltas. So for full |
1063 clnodes, |
1063 clnodes, |
1064 generate=changelog, |
1064 generate=changelog, |
1065 sidedata_helpers=sidedata_helpers, |
1065 sidedata_helpers=sidedata_helpers, |
1066 ) |
1066 ) |
1067 for delta in deltas: |
1067 for delta in deltas: |
1068 for chunk in _revisiondeltatochunks(delta, self._builddeltaheader): |
1068 for chunk in _revisiondeltatochunks( |
|
1069 self._repo, delta, self._builddeltaheader |
|
1070 ): |
1069 size += len(chunk) |
1071 size += len(chunk) |
1070 yield chunk |
1072 yield chunk |
1071 |
1073 |
1072 close = closechunk() |
1074 close = closechunk() |
1073 size += len(close) |
1075 size += len(close) |
1119 chunk = _fileheader(tree) |
1121 chunk = _fileheader(tree) |
1120 size += len(chunk) |
1122 size += len(chunk) |
1121 yield chunk |
1123 yield chunk |
1122 |
1124 |
1123 for delta in deltas: |
1125 for delta in deltas: |
1124 chunks = _revisiondeltatochunks(delta, self._builddeltaheader) |
1126 chunks = _revisiondeltatochunks( |
|
1127 self._repo, delta, self._builddeltaheader |
|
1128 ) |
1125 for chunk in chunks: |
1129 for chunk in chunks: |
1126 size += len(chunk) |
1130 size += len(chunk) |
1127 yield chunk |
1131 yield chunk |
1128 |
1132 |
1129 close = closechunk() |
1133 close = closechunk() |
1158 h = _fileheader(path) |
1162 h = _fileheader(path) |
1159 size = len(h) |
1163 size = len(h) |
1160 yield h |
1164 yield h |
1161 |
1165 |
1162 for delta in deltas: |
1166 for delta in deltas: |
1163 chunks = _revisiondeltatochunks(delta, self._builddeltaheader) |
1167 chunks = _revisiondeltatochunks( |
|
1168 self._repo, delta, self._builddeltaheader |
|
1169 ) |
1164 for chunk in chunks: |
1170 for chunk in chunks: |
1165 size += len(chunk) |
1171 size += len(chunk) |
1166 yield chunk |
1172 yield chunk |
1167 |
1173 |
1168 close = closechunk() |
1174 close = closechunk() |