← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/repofmt/weaverepo.py

  • Committer: John Arbash Meinel
  • Date: 2009-02-23 15:29:35 UTC
  • mfrom: (3943.7.7 bzr.code_style_cleanup)
  • mto: This revision was merged to the branch mainline in revision 4033.
  • Revision ID: john@arbash-meinel.com-20090223152935-oel9m92mwcc6nb4h
Merge the removal of all trailing whitespace, and resolve conflicts.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/repofmt/weaverepo.py
82
82
 
83
83
        def get_store(name, compressed=True, prefixed=False):
84
84
            # FIXME: This approach of assuming stores are all entirely compressed
85
 
            # or entirely uncompressed is tidy, but breaks upgrade from 
86
 
            # some existing branches where there's a mixture; we probably 
 
85
            # or entirely uncompressed is tidy, but breaks upgrade from
 
86
            # some existing branches where there's a mixture; we probably
87
87
            # still want the option to look for both.
88
88
            relpath = self._escape(name)
89
89
            store = TextStore(a_bzrdir.transport.clone(relpath),
95
95
        # not broken out yet because the controlweaves|inventory_store
96
96
        # and texts bits are still different.
97
97
        if isinstance(_format, RepositoryFormat4):
98
 
            # cannot remove these - there is still no consistent api 
 
98
            # cannot remove these - there is still no consistent api
99
99
            # which allows access to this old info.
100
100
            self.inventory_store = get_store('inventory-store')
101
101
            self._text_store = get_store('text-store')
112
112
 
113
113
    @needs_read_lock
114
114
    def _all_revision_ids(self):
115
 
        """Returns a list of all the revision ids in the repository. 
 
115
        """Returns a list of all the revision ids in the repository.
116
116
 
117
 
        These are in as much topological order as the underlying store can 
 
117
        These are in as much topological order as the underlying store can
118
118
        present: for weaves ghosts may lead to a lack of correctness until
119
119
        the reweave updates the parents list.
120
120
        """
207
207
 
208
208
    @needs_read_lock
209
209
    def _all_revision_ids(self):
210
 
        """Returns a list of all the revision ids in the repository. 
 
210
        """Returns a list of all the revision ids in the repository.
211
211
 
212
 
        These are in as much topological order as the underlying store can 
 
212
        These are in as much topological order as the underlying store can
213
213
        present: for weaves ghosts may lead to a lack of correctness until
214
214
        the reweave updates the parents list.
215
215
        """
279
279
        if not _internal:
280
280
            # always initialized when the bzrdir is.
281
281
            return self.open(a_bzrdir, _found=True)
282
 
        
 
282
 
283
283
        # Create an empty weave
284
284
        sio = StringIO()
285
285
        weavefile.write_weave_v5(weave.Weave(), sio)
286
286
        empty_weave = sio.getvalue()
287
287
 
288
288
        mutter('creating repository in %s.', a_bzrdir.transport.base)
289
 
        
 
289
 
290
290
        # FIXME: RBC 20060125 don't peek under the covers
291
291
        # NB: no need to escape relative paths that are url safe.
292
292
        control_files = lockable_files.LockableFiles(a_bzrdir.transport,
352
352
        """Format 4 is not supported.
353
353
 
354
354
        It is not supported because the model changed from 4 to 5 and the
355
 
        conversion logic is expensive - so doing it on the fly was not 
 
355
        conversion logic is expensive - so doing it on the fly was not
356
356
        feasible.
357
357
        """
358
358
        return False
539
539
 
540
540
        mutter('creating repository in %s.', a_bzrdir.transport.base)
541
541
        dirs = ['revision-store', 'weaves']
542
 
        files = [('inventory.weave', StringIO(empty_weave)), 
 
542
        files = [('inventory.weave', StringIO(empty_weave)),
543
543
                 ]
544
544
        utf8_files = [('format', self.get_format_string())]
545
 
 
 
545
 
546
546
        self._upload_blank_content(a_bzrdir, dirs, files, utf8_files, shared)
547
547
        return self.open(a_bzrdir=a_bzrdir, _found=True)
548
548
 
549
549
    def open(self, a_bzrdir, _found=False, _override_transport=None):
550
550
        """See RepositoryFormat.open().
551
 
        
 
551
 
552
552
        :param _override_transport: INTERNAL USE ONLY. Allows opening the
553
553
                                    repository at a slightly different url
554
554
                                    than normal. I.e. during 'upgrade'.
675
675
                continue
676
676
            result[key] = parents
677
677
        return result
678
 
    
 
678
 
679
679
    def get_record_stream(self, keys, sort_order, include_delta_closure):
680
680
        for key in keys:
681
681
            text, parents = self._load_text_parents(key)
715
715
                continue
716
716
            result[key] = None
717
717
        return result
718
 
    
 
718
 
719
719
    def get_record_stream(self, keys, sort_order, include_delta_closure):
720
720
        for key in keys:
721
721
            text = self._load_text(key)