← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/repofmt/weaverepo.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2010-09-01 08:02:42 UTC
  • mfrom: (5390.3.3 faster-revert-593560)
  • Revision ID: pqm@pqm.ubuntu.com-20100901080242-esg62ody4frwmy66
(spiv) Avoid repeatedly calling self.target.all_file_ids() in
 InterTree.iter_changes. (Andrew Bennetts)

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/repofmt/weaverepo.py
1
 
# Copyright (C) 2005, 2006, 2007, 2008 Canonical Ltd
 
1
# Copyright (C) 2007-2010 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
28
28
lazy_import(globals(), """
29
29
from bzrlib import (
30
30
    xml5,
 
31
    graph as _mod_graph,
31
32
    )
32
33
""")
33
34
from bzrlib import (
38
39
    lockdir,
39
40
    osutils,
40
41
    revision as _mod_revision,
 
42
    trace,
41
43
    urlutils,
42
44
    versionedfile,
43
45
    weave,
52
54
    RepositoryFormat,
53
55
    )
54
56
from bzrlib.store.text import TextStore
55
 
from bzrlib.trace import mutter
56
57
from bzrlib.tuned_gzip import GzipFile, bytes_to_gzip
57
58
from bzrlib.versionedfile import (
58
59
    AbsentContentFactory,
105
106
    def _all_possible_ids(self):
106
107
        """Return all the possible revisions that we could find."""
107
108
        if 'evil' in debug.debug_flags:
108
 
            mutter_callsite(3, "_all_possible_ids scales with size of history.")
 
109
            trace.mutter_callsite(
 
110
                3, "_all_possible_ids scales with size of history.")
109
111
        return [key[-1] for key in self.inventories.keys()]
110
112
 
111
113
    @needs_read_lock
175
177
        :param new_value: True to restore the default, False to disable making
176
178
                          working trees.
177
179
        """
178
 
        raise errors.RepositoryUpgradeRequired(self.bzrdir.root_transport.base)
 
180
        raise errors.RepositoryUpgradeRequired(self.user_url)
179
181
 
180
182
    def make_working_trees(self):
181
183
        """Returns the policy for making working trees on new branches."""
198
200
    def _all_possible_ids(self):
199
201
        """Return all the possible revisions that we could find."""
200
202
        if 'evil' in debug.debug_flags:
201
 
            mutter_callsite(3, "_all_possible_ids scales with size of history.")
 
203
            trace.mutter_callsite(
 
204
                3, "_all_possible_ids scales with size of history.")
202
205
        return [key[-1] for key in self.inventories.keys()]
203
206
 
204
207
    @needs_read_lock
285
288
        weavefile.write_weave_v5(weave.Weave(), sio)
286
289
        empty_weave = sio.getvalue()
287
290
 
288
 
        mutter('creating repository in %s.', a_bzrdir.transport.base)
 
291
        trace.mutter('creating repository in %s.', a_bzrdir.transport.base)
289
292
 
290
293
        # FIXME: RBC 20060125 don't peek under the covers
291
294
        # NB: no need to escape relative paths that are url safe.
301
304
                mode=a_bzrdir._get_file_mode())
302
305
        finally:
303
306
            control_files.unlock()
304
 
        return self.open(a_bzrdir, _found=True)
 
307
        repository = self.open(a_bzrdir, _found=True)
 
308
        self._run_post_repo_init_hooks(repository, a_bzrdir, shared)
 
309
        return repository
305
310
 
306
311
    def open(self, a_bzrdir, _found=False):
307
312
        """See RepositoryFormat.open()."""
319
324
        result.chk_bytes = None
320
325
        return result
321
326
 
322
 
    def check_conversion_target(self, target_format):
323
 
        pass
324
 
 
325
327
 
326
328
class RepositoryFormat4(PreSplitOutRepositoryFormat):
327
329
    """Bzr repository format 4.
494
496
        """See RepositoryFormat.get_format_description()."""
495
497
        return "Weave repository format 7"
496
498
 
497
 
    def check_conversion_target(self, target_format):
498
 
        pass
499
 
 
500
499
    def _get_inventories(self, repo_transport, repo, name='inventory'):
501
500
        mapper = versionedfile.ConstantMapper(name)
502
501
        return versionedfile.ThunkedVersionedFiles(repo_transport,
529
528
        weavefile.write_weave_v5(weave.Weave(), sio)
530
529
        empty_weave = sio.getvalue()
531
530
 
532
 
        mutter('creating repository in %s.', a_bzrdir.transport.base)
 
531
        trace.mutter('creating repository in %s.', a_bzrdir.transport.base)
533
532
        dirs = ['revision-store', 'weaves']
534
533
        files = [('inventory.weave', StringIO(empty_weave)),
535
534
                 ]
669
668
            result[key] = parents
670
669
        return result
671
670
 
 
671
    def get_known_graph_ancestry(self, keys):
 
672
        """Get a KnownGraph instance with the ancestry of keys."""
 
673
        keys = self.keys()
 
674
        parent_map = self.get_parent_map(keys)
 
675
        kg = _mod_graph.KnownGraph(parent_map)
 
676
        return kg
 
677
 
672
678
    def get_record_stream(self, keys, sort_order, include_delta_closure):
673
679
        for key in keys:
674
680
            text, parents = self._load_text_parents(key)
686
692
            path, ext = os.path.splitext(relpath)
687
693
            if ext == '.gz':
688
694
                relpath = path
689
 
            if '.sig' not in relpath:
 
695
            if not relpath.endswith('.sig'):
690
696
                relpaths.add(relpath)
691
697
        paths = list(relpaths)
692
698
        return set([self._mapper.unmap(path) for path in paths])