256
256
to_sf.insert_record_stream(filter_absent(from_sf.get_record_stream(
257
257
[(rev_id,) for rev_id in revs],
258
258
self.to_repository._fetch_order,
260
# Bug #261339, some knit repositories accidentally had deltas in their
261
# revision stream, when you weren't ever supposed to have deltas.
262
# So we now *force* fulltext copying for signatures and revisions
259
not self.to_repository._fetch_uses_deltas)))
263
260
self._fetch_just_revision_texts(revs)
265
262
def _fetch_just_revision_texts(self, version_ids):
266
263
to_rf = self.to_repository.revisions
267
264
from_rf = self.from_repository.revisions
265
# If a revision has a delta, this is actually expanded inside the
266
# insert_record_stream code now, which is an alternate fix for
268
268
to_rf.insert_record_stream(from_rf.get_record_stream(
269
269
[(rev_id,) for rev_id in version_ids],
270
270
self.to_repository._fetch_order,
272
# Bug #261339, some knit repositories accidentally had deltas in their
273
# revision stream, when you weren't ever supposed to have deltas.
274
# So we now *force* fulltext copying for signatures and revisions
271
not self.to_repository._fetch_uses_deltas))
276
273
def _generate_root_texts(self, revs):
277
274
"""This will be called by __fetch between fetching weave texts and