/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/bundle/serializer/v4.py

Merge bzr.dev r3466

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/bundle/serializer/v4.py
107
107
    @staticmethod
108
108
    def encode_name(content_kind, revision_id, file_id=None):
109
109
        """Encode semantic ids as a container name"""
110
 
        assert content_kind in ('revision', 'file', 'inventory', 'signature',
111
 
                                'info')
112
 
 
 
110
        if content_kind not in ('revision', 'file', 'inventory', 'signature',
 
111
                'info'):
 
112
            raise ValueError(content_kind)
113
113
        if content_kind == 'file':
114
 
            assert file_id is not None
 
114
            if file_id is None:
 
115
                raise AssertionError()
115
116
        else:
116
 
            assert file_id is None
 
117
            if file_id is not None:
 
118
                raise AssertionError()
117
119
        if content_kind == 'info':
118
 
            assert revision_id is None
119
 
        else:
120
 
            assert revision_id is not None
 
120
            if revision_id is not None:
 
121
                raise AssertionError()
 
122
        elif revision_id is None:
 
123
            raise AssertionError()
121
124
        names = [n.replace('/', '//') for n in
122
125
                 (content_kind, revision_id, file_id) if n is not None]
123
126
        return '/'.join(names)
327
330
                if revision_id in self.base_ancestry:
328
331
                    continue
329
332
                new_revision_ids.add(revision_id)
330
 
                pending.extend(vf.get_parents(revision_id))
 
333
                pending.extend(vf.get_parent_map([revision_id])[revision_id])
331
334
            yield vf, file_id, new_revision_ids
332
335
 
333
336
    def write_files(self):
376
379
        revision_ids = list(multiparent.topo_iter(vf, revision_ids))
377
380
        mpdiffs = vf.make_mpdiffs(revision_ids)
378
381
        sha1s = vf.get_sha1s(revision_ids)
 
382
        parent_map = vf.get_parent_map(revision_ids)
379
383
        for mpdiff, revision_id, sha1, in zip(mpdiffs, revision_ids, sha1s):
380
 
            parents = vf.get_parents(revision_id)
 
384
            parents = parent_map[revision_id]
381
385
            text = ''.join(mpdiff.to_patch())
382
386
            self.bundle.add_multiparent_record(text, sha1, parents, repo_kind,
383
387
                                               revision_id, file_id)
493
497
        for bytes, metadata, repo_kind, revision_id, file_id in\
494
498
            self._container.iter_records():
495
499
            if repo_kind == 'info':
496
 
                assert self._info is None
 
500
                if self._info is not None:
 
501
                    raise AssertionError()
497
502
                self._handle_info(metadata)
498
503
            if (repo_kind, file_id) != ('file', current_file):
499
504
                if len(pending_file_records) > 0:
587
592
    def _install_revision(self, revision_id, metadata, text):
588
593
        if self._repository.has_revision(revision_id):
589
594
            return
590
 
        self._repository._add_revision_text(revision_id, text)
 
595
        if self._info['serializer'] == self._repository._serializer.format_num:
 
596
            self._repository._add_revision_text(revision_id, text)
 
597
        else:
 
598
            revision = self._source_serializer.read_revision_from_string(text)
 
599
            self._repository.add_revision(revision.revision_id, revision)
591
600
 
592
601
    def _install_signature(self, revision_id, metadata, text):
593
602
        transaction = self._repository.get_transaction()