~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/bzrdir.py

(jameinel) Bug #581311,
 treat WSAECONNABORTED as ConnectionReset. (John A Meinel)

Show diffs side-by-side

added added

removed removed

Lines of Context:
25
25
objects returned.
26
26
"""
27
27
 
 
28
# TODO: Move old formats into a plugin to make this file smaller.
 
29
 
 
30
import os
28
31
import sys
 
32
import warnings
29
33
 
30
34
from bzrlib.lazy_import import lazy_import
31
35
lazy_import(globals(), """
 
36
from stat import S_ISDIR
 
37
 
32
38
import bzrlib
33
39
from bzrlib import (
34
 
    branch as _mod_branch,
35
 
    cleanup,
 
40
    branch,
 
41
    config,
 
42
    controldir,
36
43
    errors,
37
 
    fetch,
38
44
    graph,
39
45
    lockable_files,
40
46
    lockdir,
43
49
    remote,
44
50
    repository,
45
51
    revision as _mod_revision,
46
 
    transport as _mod_transport,
47
52
    ui,
48
53
    urlutils,
 
54
    versionedfile,
49
55
    win32utils,
50
 
    workingtree_3,
 
56
    workingtree,
51
57
    workingtree_4,
52
 
    )
53
 
from bzrlib.repofmt import knitpack_repo
 
58
    xml4,
 
59
    xml5,
 
60
    )
 
61
from bzrlib.osutils import (
 
62
    sha_string,
 
63
    )
 
64
from bzrlib.push import (
 
65
    PushResult,
 
66
    )
 
67
from bzrlib.repofmt import pack_repo
 
68
from bzrlib.smart.client import _SmartClient
 
69
from bzrlib.store.versioned import WeaveStore
 
70
from bzrlib.transactions import WriteTransaction
54
71
from bzrlib.transport import (
55
72
    do_catching_redirections,
 
73
    get_transport,
56
74
    local,
57
75
    )
 
76
from bzrlib.weave import Weave
58
77
""")
59
78
 
60
79
from bzrlib.trace import (
61
80
    mutter,
62
81
    note,
 
82
    warning,
63
83
    )
64
84
 
65
85
from bzrlib import (
66
 
    config,
67
 
    controldir,
68
86
    hooks,
69
87
    registry,
 
88
    symbol_versioning,
70
89
    )
71
90
from bzrlib.symbol_versioning import (
72
91
    deprecated_in,
123
142
            # No repo, no problem.
124
143
            pass
125
144
 
 
145
    @staticmethod
 
146
    def _check_supported(format, allow_unsupported,
 
147
        recommend_upgrade=True,
 
148
        basedir=None):
 
149
        """Give an error or warning on old formats.
 
150
 
 
151
        :param format: may be any kind of format - workingtree, branch,
 
152
        or repository.
 
153
 
 
154
        :param allow_unsupported: If true, allow opening
 
155
        formats that are strongly deprecated, and which may
 
156
        have limited functionality.
 
157
 
 
158
        :param recommend_upgrade: If true (default), warn
 
159
        the user through the ui object that they may wish
 
160
        to upgrade the object.
 
161
        """
 
162
        # TODO: perhaps move this into a base Format class; it's not BzrDir
 
163
        # specific. mbp 20070323
 
164
        if not allow_unsupported and not format.is_supported():
 
165
            # see open_downlevel to open legacy branches.
 
166
            raise errors.UnsupportedFormatError(format=format)
 
167
        if recommend_upgrade \
 
168
            and getattr(format, 'upgrade_recommended', False):
 
169
            ui.ui_factory.recommend_upgrade(
 
170
                format.get_format_description(),
 
171
                basedir)
 
172
 
126
173
    def clone_on_transport(self, transport, revision_id=None,
127
174
        force_new_repo=False, preserve_stacking=False, stacked_on=None,
128
175
        create_prefix=False, use_existing_dir=True, no_tree=False):
140
187
        :param create_prefix: Create any missing directories leading up to
141
188
            to_transport.
142
189
        :param use_existing_dir: Use an existing directory if one exists.
143
 
        :param no_tree: If set to true prevents creation of a working tree.
144
190
        """
145
191
        # Overview: put together a broad description of what we want to end up
146
192
        # with; then make as few api calls as possible to do it.
229
275
    # TODO: This should be given a Transport, and should chdir up; otherwise
230
276
    # this will open a new connection.
231
277
    def _make_tail(self, url):
232
 
        t = _mod_transport.get_transport(url)
 
278
        t = get_transport(url)
233
279
        t.ensure_base()
234
280
 
235
281
    @staticmethod
239
285
        This is intended primarily as a building block for more sophisticated
240
286
        functionality, like finding trees under a directory, or finding
241
287
        branches that use a given repository.
242
 
 
243
288
        :param evaluate: An optional callable that yields recurse, value,
244
289
            where recurse controls whether this bzrdir is recursed into
245
290
            and value is the value to yield.  By default, all bzrdirs
389
434
        policy = self.determine_repository_policy(force_new_repo)
390
435
        return policy.acquire_repository()[0]
391
436
 
392
 
    def _find_source_repo(self, add_cleanup, source_branch):
393
 
        """Find the source branch and repo for a sprout operation.
394
 
        
395
 
        This is helper intended for use by _sprout.
396
 
 
397
 
        :returns: (source_branch, source_repository).  Either or both may be
398
 
            None.  If not None, they will be read-locked (and their unlock(s)
399
 
            scheduled via the add_cleanup param).
400
 
        """
401
 
        if source_branch is not None:
402
 
            add_cleanup(source_branch.lock_read().unlock)
403
 
            return source_branch, source_branch.repository
404
 
        try:
405
 
            source_branch = self.open_branch()
406
 
            source_repository = source_branch.repository
407
 
        except errors.NotBranchError:
408
 
            source_branch = None
409
 
            try:
410
 
                source_repository = self.open_repository()
411
 
            except errors.NoRepositoryPresent:
412
 
                source_repository = None
413
 
            else:
414
 
                add_cleanup(source_repository.lock_read().unlock)
415
 
        else:
416
 
            add_cleanup(source_branch.lock_read().unlock)
417
 
        return source_branch, source_repository
418
 
 
419
 
    def sprout(self, url, revision_id=None, force_new_repo=False,
420
 
               recurse='down', possible_transports=None,
421
 
               accelerator_tree=None, hardlink=False, stacked=False,
422
 
               source_branch=None, create_tree_if_local=True):
423
 
        """Create a copy of this controldir prepared for use as a new line of
424
 
        development.
425
 
 
426
 
        If url's last component does not exist, it will be created.
427
 
 
428
 
        Attributes related to the identity of the source branch like
429
 
        branch nickname will be cleaned, a working tree is created
430
 
        whether one existed before or not; and a local branch is always
431
 
        created.
432
 
 
433
 
        if revision_id is not None, then the clone operation may tune
434
 
            itself to download less data.
435
 
 
436
 
        :param accelerator_tree: A tree which can be used for retrieving file
437
 
            contents more quickly than the revision tree, i.e. a workingtree.
438
 
            The revision tree will be used for cases where accelerator_tree's
439
 
            content is different.
440
 
        :param hardlink: If true, hard-link files from accelerator_tree,
441
 
            where possible.
442
 
        :param stacked: If true, create a stacked branch referring to the
443
 
            location of this control directory.
444
 
        :param create_tree_if_local: If true, a working-tree will be created
445
 
            when working locally.
446
 
        """
447
 
        operation = cleanup.OperationWithCleanups(self._sprout)
448
 
        return operation.run(url, revision_id=revision_id,
449
 
            force_new_repo=force_new_repo, recurse=recurse,
450
 
            possible_transports=possible_transports,
451
 
            accelerator_tree=accelerator_tree, hardlink=hardlink,
452
 
            stacked=stacked, source_branch=source_branch,
453
 
            create_tree_if_local=create_tree_if_local)
454
 
 
455
 
    def _sprout(self, op, url, revision_id=None, force_new_repo=False,
456
 
               recurse='down', possible_transports=None,
457
 
               accelerator_tree=None, hardlink=False, stacked=False,
458
 
               source_branch=None, create_tree_if_local=True):
459
 
        add_cleanup = op.add_cleanup
460
 
        fetch_spec_factory = fetch.FetchSpecFactory()
461
 
        if revision_id is not None:
462
 
            fetch_spec_factory.add_revision_ids([revision_id])
463
 
            fetch_spec_factory.source_branch_stop_revision_id = revision_id
464
 
        target_transport = _mod_transport.get_transport(url,
465
 
            possible_transports)
466
 
        target_transport.ensure_base()
467
 
        cloning_format = self.cloning_metadir(stacked)
468
 
        # Create/update the result branch
469
 
        result = cloning_format.initialize_on_transport(target_transport)
470
 
        source_branch, source_repository = self._find_source_repo(
471
 
            add_cleanup, source_branch)
472
 
        fetch_spec_factory.source_branch = source_branch
473
 
        # if a stacked branch wasn't requested, we don't create one
474
 
        # even if the origin was stacked
475
 
        if stacked and source_branch is not None:
476
 
            stacked_branch_url = self.root_transport.base
477
 
        else:
478
 
            stacked_branch_url = None
479
 
        repository_policy = result.determine_repository_policy(
480
 
            force_new_repo, stacked_branch_url, require_stacking=stacked)
481
 
        result_repo, is_new_repo = repository_policy.acquire_repository()
482
 
        add_cleanup(result_repo.lock_write().unlock)
483
 
        fetch_spec_factory.source_repo = source_repository
484
 
        fetch_spec_factory.target_repo = result_repo
485
 
        if stacked or (len(result_repo._fallback_repositories) != 0):
486
 
            target_repo_kind = fetch.TargetRepoKinds.STACKED
487
 
        elif is_new_repo:
488
 
            target_repo_kind = fetch.TargetRepoKinds.EMPTY
489
 
        else:
490
 
            target_repo_kind = fetch.TargetRepoKinds.PREEXISTING
491
 
        fetch_spec_factory.target_repo_kind = target_repo_kind
492
 
        if source_repository is not None:
493
 
            fetch_spec = fetch_spec_factory.make_fetch_spec()
494
 
            result_repo.fetch(source_repository, fetch_spec=fetch_spec)
495
 
 
496
 
        if source_branch is None:
497
 
            # this is for sprouting a controldir without a branch; is that
498
 
            # actually useful?
499
 
            # Not especially, but it's part of the contract.
500
 
            result_branch = result.create_branch()
501
 
        else:
502
 
            result_branch = source_branch.sprout(result,
503
 
                revision_id=revision_id, repository_policy=repository_policy,
504
 
                repository=result_repo)
505
 
        mutter("created new branch %r" % (result_branch,))
506
 
 
507
 
        # Create/update the result working tree
508
 
        if (create_tree_if_local and
509
 
            isinstance(target_transport, local.LocalTransport) and
510
 
            (result_repo is None or result_repo.make_working_trees())):
511
 
            wt = result.create_workingtree(accelerator_tree=accelerator_tree,
512
 
                hardlink=hardlink, from_branch=result_branch)
513
 
            wt.lock_write()
514
 
            try:
515
 
                if wt.path2id('') is None:
516
 
                    try:
517
 
                        wt.set_root_id(self.open_workingtree.get_root_id())
518
 
                    except errors.NoWorkingTree:
519
 
                        pass
520
 
            finally:
521
 
                wt.unlock()
522
 
        else:
523
 
            wt = None
524
 
        if recurse == 'down':
525
 
            basis = None
526
 
            if wt is not None:
527
 
                basis = wt.basis_tree()
528
 
            elif result_branch is not None:
529
 
                basis = result_branch.basis_tree()
530
 
            elif source_branch is not None:
531
 
                basis = source_branch.basis_tree()
532
 
            if basis is not None:
533
 
                add_cleanup(basis.lock_read().unlock)
534
 
                subtrees = basis.iter_references()
535
 
            else:
536
 
                subtrees = []
537
 
            for path, file_id in subtrees:
538
 
                target = urlutils.join(url, urlutils.escape(path))
539
 
                sublocation = source_branch.reference_parent(file_id, path)
540
 
                sublocation.bzrdir.sprout(target,
541
 
                    basis.get_reference_revision(file_id, path),
542
 
                    force_new_repo=force_new_repo, recurse=recurse,
543
 
                    stacked=stacked)
544
 
        return result
545
 
 
546
 
 
547
 
 
548
437
    @staticmethod
549
438
    def create_branch_convenience(base, force_new_repo=False,
550
439
                                  force_new_tree=None, format=None,
576
465
        """
577
466
        if force_new_tree:
578
467
            # check for non local urls
579
 
            t = _mod_transport.get_transport(base, possible_transports)
 
468
            t = get_transport(base, possible_transports)
580
469
            if not isinstance(t, local.LocalTransport):
581
470
                raise errors.NotLocalUrl(base)
582
471
        bzrdir = BzrDir.create(base, format, possible_transports)
604
493
        :param format: Override for the bzrdir format to create.
605
494
        :return: The WorkingTree object.
606
495
        """
607
 
        t = _mod_transport.get_transport(base)
 
496
        t = get_transport(base)
608
497
        if not isinstance(t, local.LocalTransport):
609
498
            raise errors.NotLocalUrl(base)
610
499
        bzrdir = BzrDir.create_branch_and_repo(base,
824
713
 
825
714
        :param _unsupported: a private parameter to the BzrDir class.
826
715
        """
827
 
        t = _mod_transport.get_transport(base, possible_transports)
 
716
        t = get_transport(base, possible_transports=possible_transports)
828
717
        return BzrDir.open_from_transport(t, _unsupported=_unsupported)
829
718
 
830
719
    @staticmethod
859
748
        except errors.TooManyRedirections:
860
749
            raise errors.NotBranchError(base)
861
750
 
862
 
        format.check_support_status(_unsupported)
 
751
        BzrDir._check_supported(format, _unsupported)
863
752
        return format.open(transport, _found=True)
864
753
 
865
754
    @staticmethod
867
756
        """Open an existing branch which contains url.
868
757
 
869
758
        :param url: url to search from.
870
 
 
871
759
        See open_containing_from_transport for more detail.
872
760
        """
873
 
        transport = _mod_transport.get_transport(url, possible_transports)
 
761
        transport = get_transport(url, possible_transports)
874
762
        return BzrDir.open_containing_from_transport(transport)
875
763
 
876
764
    @staticmethod
1032
920
        if cls is not BzrDir:
1033
921
            raise AssertionError("BzrDir.create always creates the"
1034
922
                "default format, not one of %r" % cls)
1035
 
        t = _mod_transport.get_transport(base, possible_transports)
 
923
        t = get_transport(base, possible_transports)
1036
924
        t.ensure_base()
1037
925
        if format is None:
1038
926
            format = controldir.ControlDirFormat.get_default_format()
1039
927
        return format.initialize_on_transport(t)
1040
928
 
1041
 
    def get_branch_transport(self, branch_format, name=None):
1042
 
        """Get the transport for use by branch format in this BzrDir.
1043
 
 
1044
 
        Note that bzr dirs that do not support format strings will raise
1045
 
        IncompatibleFormat if the branch format they are given has
1046
 
        a format string, and vice versa.
1047
 
 
1048
 
        If branch_format is None, the transport is returned with no
1049
 
        checking. If it is not None, then the returned transport is
1050
 
        guaranteed to point to an existing directory ready for use.
1051
 
        """
1052
 
        raise NotImplementedError(self.get_branch_transport)
1053
 
 
1054
 
    def get_repository_transport(self, repository_format):
1055
 
        """Get the transport for use by repository format in this BzrDir.
1056
 
 
1057
 
        Note that bzr dirs that do not support format strings will raise
1058
 
        IncompatibleFormat if the repository format they are given has
1059
 
        a format string, and vice versa.
1060
 
 
1061
 
        If repository_format is None, the transport is returned with no
1062
 
        checking. If it is not None, then the returned transport is
1063
 
        guaranteed to point to an existing directory ready for use.
1064
 
        """
1065
 
        raise NotImplementedError(self.get_repository_transport)
1066
 
 
1067
 
    def get_workingtree_transport(self, tree_format):
1068
 
        """Get the transport for use by workingtree format in this BzrDir.
1069
 
 
1070
 
        Note that bzr dirs that do not support format strings will raise
1071
 
        IncompatibleFormat if the workingtree format they are given has a
1072
 
        format string, and vice versa.
1073
 
 
1074
 
        If workingtree_format is None, the transport is returned with no
1075
 
        checking. If it is not None, then the returned transport is
1076
 
        guaranteed to point to an existing directory ready for use.
1077
 
        """
1078
 
        raise NotImplementedError(self.get_workingtree_transport)
1079
 
 
1080
929
 
1081
930
class BzrDirHooks(hooks.Hooks):
1082
931
    """Hooks for BzrDir operations."""
1083
932
 
1084
933
    def __init__(self):
1085
934
        """Create the default hooks."""
1086
 
        hooks.Hooks.__init__(self, "bzrlib.bzrdir", "BzrDir.hooks")
1087
 
        self.add_hook('pre_open',
 
935
        hooks.Hooks.__init__(self)
 
936
        self.create_hook(hooks.HookPoint('pre_open',
1088
937
            "Invoked before attempting to open a BzrDir with the transport "
1089
 
            "that the open will use.", (1, 14))
1090
 
        self.add_hook('post_repo_init',
 
938
            "that the open will use.", (1, 14), None))
 
939
        self.create_hook(hooks.HookPoint('post_repo_init',
1091
940
            "Invoked after a repository has been initialized. "
1092
941
            "post_repo_init is called with a "
1093
942
            "bzrlib.bzrdir.RepoInitHookParams.",
1094
 
            (2, 2))
 
943
            (2, 2), None))
1095
944
 
1096
945
# install the default hooks
1097
946
BzrDir.hooks = BzrDirHooks()
1098
947
 
1099
948
 
1100
949
class RepoInitHookParams(object):
1101
 
    """Object holding parameters passed to `*_repo_init` hooks.
 
950
    """Object holding parameters passed to *_repo_init hooks.
1102
951
 
1103
952
    There are 4 fields that hooks may wish to access:
1104
953
 
1133
982
                self.bzrdir)
1134
983
 
1135
984
 
 
985
class BzrDirPreSplitOut(BzrDir):
 
986
    """A common class for the all-in-one formats."""
 
987
 
 
988
    def __init__(self, _transport, _format):
 
989
        """See BzrDir.__init__."""
 
990
        super(BzrDirPreSplitOut, self).__init__(_transport, _format)
 
991
        self._control_files = lockable_files.LockableFiles(
 
992
                                            self.get_branch_transport(None),
 
993
                                            self._format._lock_file_name,
 
994
                                            self._format._lock_class)
 
995
 
 
996
    def break_lock(self):
 
997
        """Pre-splitout bzrdirs do not suffer from stale locks."""
 
998
        raise NotImplementedError(self.break_lock)
 
999
 
 
1000
    def cloning_metadir(self, require_stacking=False):
 
1001
        """Produce a metadir suitable for cloning with."""
 
1002
        if require_stacking:
 
1003
            return controldir.format_registry.make_bzrdir('1.6')
 
1004
        return self._format.__class__()
 
1005
 
 
1006
    def clone(self, url, revision_id=None, force_new_repo=False,
 
1007
              preserve_stacking=False):
 
1008
        """See BzrDir.clone().
 
1009
 
 
1010
        force_new_repo has no effect, since this family of formats always
 
1011
        require a new repository.
 
1012
        preserve_stacking has no effect, since no source branch using this
 
1013
        family of formats can be stacked, so there is no stacking to preserve.
 
1014
        """
 
1015
        self._make_tail(url)
 
1016
        result = self._format._initialize_for_clone(url)
 
1017
        self.open_repository().clone(result, revision_id=revision_id)
 
1018
        from_branch = self.open_branch()
 
1019
        from_branch.clone(result, revision_id=revision_id)
 
1020
        try:
 
1021
            tree = self.open_workingtree()
 
1022
        except errors.NotLocalUrl:
 
1023
            # make a new one, this format always has to have one.
 
1024
            result._init_workingtree()
 
1025
        else:
 
1026
            tree.clone(result)
 
1027
        return result
 
1028
 
 
1029
    def create_branch(self, name=None, repository=None):
 
1030
        """See BzrDir.create_branch."""
 
1031
        if repository is not None:
 
1032
            raise NotImplementedError(
 
1033
                "create_branch(repository=<not None>) on %r" % (self,))
 
1034
        return self._format.get_branch_format().initialize(self, name=name)
 
1035
 
 
1036
    def destroy_branch(self, name=None):
 
1037
        """See BzrDir.destroy_branch."""
 
1038
        raise errors.UnsupportedOperation(self.destroy_branch, self)
 
1039
 
 
1040
    def create_repository(self, shared=False):
 
1041
        """See BzrDir.create_repository."""
 
1042
        if shared:
 
1043
            raise errors.IncompatibleFormat('shared repository', self._format)
 
1044
        return self.open_repository()
 
1045
 
 
1046
    def destroy_repository(self):
 
1047
        """See BzrDir.destroy_repository."""
 
1048
        raise errors.UnsupportedOperation(self.destroy_repository, self)
 
1049
 
 
1050
    def create_workingtree(self, revision_id=None, from_branch=None,
 
1051
                           accelerator_tree=None, hardlink=False):
 
1052
        """See BzrDir.create_workingtree."""
 
1053
        # The workingtree is sometimes created when the bzrdir is created,
 
1054
        # but not when cloning.
 
1055
 
 
1056
        # this looks buggy but is not -really-
 
1057
        # because this format creates the workingtree when the bzrdir is
 
1058
        # created
 
1059
        # clone and sprout will have set the revision_id
 
1060
        # and that will have set it for us, its only
 
1061
        # specific uses of create_workingtree in isolation
 
1062
        # that can do wonky stuff here, and that only
 
1063
        # happens for creating checkouts, which cannot be
 
1064
        # done on this format anyway. So - acceptable wart.
 
1065
        if hardlink:
 
1066
            warning("can't support hardlinked working trees in %r"
 
1067
                % (self,))
 
1068
        try:
 
1069
            result = self.open_workingtree(recommend_upgrade=False)
 
1070
        except errors.NoSuchFile:
 
1071
            result = self._init_workingtree()
 
1072
        if revision_id is not None:
 
1073
            if revision_id == _mod_revision.NULL_REVISION:
 
1074
                result.set_parent_ids([])
 
1075
            else:
 
1076
                result.set_parent_ids([revision_id])
 
1077
        return result
 
1078
 
 
1079
    def _init_workingtree(self):
 
1080
        from bzrlib.workingtree import WorkingTreeFormat2
 
1081
        try:
 
1082
            return WorkingTreeFormat2().initialize(self)
 
1083
        except errors.NotLocalUrl:
 
1084
            # Even though we can't access the working tree, we need to
 
1085
            # create its control files.
 
1086
            return WorkingTreeFormat2()._stub_initialize_on_transport(
 
1087
                self.transport, self._control_files._file_mode)
 
1088
 
 
1089
    def destroy_workingtree(self):
 
1090
        """See BzrDir.destroy_workingtree."""
 
1091
        raise errors.UnsupportedOperation(self.destroy_workingtree, self)
 
1092
 
 
1093
    def destroy_workingtree_metadata(self):
 
1094
        """See BzrDir.destroy_workingtree_metadata."""
 
1095
        raise errors.UnsupportedOperation(self.destroy_workingtree_metadata,
 
1096
                                          self)
 
1097
 
 
1098
    def get_branch_transport(self, branch_format, name=None):
 
1099
        """See BzrDir.get_branch_transport()."""
 
1100
        if name is not None:
 
1101
            raise errors.NoColocatedBranchSupport(self)
 
1102
        if branch_format is None:
 
1103
            return self.transport
 
1104
        try:
 
1105
            branch_format.get_format_string()
 
1106
        except NotImplementedError:
 
1107
            return self.transport
 
1108
        raise errors.IncompatibleFormat(branch_format, self._format)
 
1109
 
 
1110
    def get_repository_transport(self, repository_format):
 
1111
        """See BzrDir.get_repository_transport()."""
 
1112
        if repository_format is None:
 
1113
            return self.transport
 
1114
        try:
 
1115
            repository_format.get_format_string()
 
1116
        except NotImplementedError:
 
1117
            return self.transport
 
1118
        raise errors.IncompatibleFormat(repository_format, self._format)
 
1119
 
 
1120
    def get_workingtree_transport(self, workingtree_format):
 
1121
        """See BzrDir.get_workingtree_transport()."""
 
1122
        if workingtree_format is None:
 
1123
            return self.transport
 
1124
        try:
 
1125
            workingtree_format.get_format_string()
 
1126
        except NotImplementedError:
 
1127
            return self.transport
 
1128
        raise errors.IncompatibleFormat(workingtree_format, self._format)
 
1129
 
 
1130
    def needs_format_conversion(self, format=None):
 
1131
        """See BzrDir.needs_format_conversion()."""
 
1132
        # if the format is not the same as the system default,
 
1133
        # an upgrade is needed.
 
1134
        if format is None:
 
1135
            symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
 
1136
                % 'needs_format_conversion(format=None)')
 
1137
            format = BzrDirFormat.get_default_format()
 
1138
        return not isinstance(self._format, format.__class__)
 
1139
 
 
1140
    def open_branch(self, name=None, unsupported=False,
 
1141
                    ignore_fallbacks=False):
 
1142
        """See BzrDir.open_branch."""
 
1143
        from bzrlib.branch import BzrBranchFormat4
 
1144
        format = BzrBranchFormat4()
 
1145
        self._check_supported(format, unsupported)
 
1146
        return format.open(self, name, _found=True)
 
1147
 
 
1148
    def sprout(self, url, revision_id=None, force_new_repo=False,
 
1149
               possible_transports=None, accelerator_tree=None,
 
1150
               hardlink=False, stacked=False, create_tree_if_local=True,
 
1151
               source_branch=None):
 
1152
        """See BzrDir.sprout()."""
 
1153
        if source_branch is not None:
 
1154
            my_branch = self.open_branch()
 
1155
            if source_branch.base != my_branch.base:
 
1156
                raise AssertionError(
 
1157
                    "source branch %r is not within %r with branch %r" %
 
1158
                    (source_branch, self, my_branch))
 
1159
        if stacked:
 
1160
            raise errors.UnstackableBranchFormat(
 
1161
                self._format, self.root_transport.base)
 
1162
        if not create_tree_if_local:
 
1163
            raise errors.MustHaveWorkingTree(
 
1164
                self._format, self.root_transport.base)
 
1165
        from bzrlib.workingtree import WorkingTreeFormat2
 
1166
        self._make_tail(url)
 
1167
        result = self._format._initialize_for_clone(url)
 
1168
        try:
 
1169
            self.open_repository().clone(result, revision_id=revision_id)
 
1170
        except errors.NoRepositoryPresent:
 
1171
            pass
 
1172
        try:
 
1173
            self.open_branch().sprout(result, revision_id=revision_id)
 
1174
        except errors.NotBranchError:
 
1175
            pass
 
1176
 
 
1177
        # we always want a working tree
 
1178
        WorkingTreeFormat2().initialize(result,
 
1179
                                        accelerator_tree=accelerator_tree,
 
1180
                                        hardlink=hardlink)
 
1181
        return result
 
1182
 
 
1183
 
 
1184
class BzrDir4(BzrDirPreSplitOut):
 
1185
    """A .bzr version 4 control object.
 
1186
 
 
1187
    This is a deprecated format and may be removed after sept 2006.
 
1188
    """
 
1189
 
 
1190
    def create_repository(self, shared=False):
 
1191
        """See BzrDir.create_repository."""
 
1192
        return self._format.repository_format.initialize(self, shared)
 
1193
 
 
1194
    def needs_format_conversion(self, format=None):
 
1195
        """Format 4 dirs are always in need of conversion."""
 
1196
        if format is None:
 
1197
            symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
 
1198
                % 'needs_format_conversion(format=None)')
 
1199
        return True
 
1200
 
 
1201
    def open_repository(self):
 
1202
        """See BzrDir.open_repository."""
 
1203
        from bzrlib.repofmt.weaverepo import RepositoryFormat4
 
1204
        return RepositoryFormat4().open(self, _found=True)
 
1205
 
 
1206
 
 
1207
class BzrDir5(BzrDirPreSplitOut):
 
1208
    """A .bzr version 5 control object.
 
1209
 
 
1210
    This is a deprecated format and may be removed after sept 2006.
 
1211
    """
 
1212
 
 
1213
    def has_workingtree(self):
 
1214
        """See BzrDir.has_workingtree."""
 
1215
        return True
 
1216
    
 
1217
    def open_repository(self):
 
1218
        """See BzrDir.open_repository."""
 
1219
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
 
1220
        return RepositoryFormat5().open(self, _found=True)
 
1221
 
 
1222
    def open_workingtree(self, _unsupported=False,
 
1223
            recommend_upgrade=True):
 
1224
        """See BzrDir.create_workingtree."""
 
1225
        from bzrlib.workingtree import WorkingTreeFormat2
 
1226
        wt_format = WorkingTreeFormat2()
 
1227
        # we don't warn here about upgrades; that ought to be handled for the
 
1228
        # bzrdir as a whole
 
1229
        return wt_format.open(self, _found=True)
 
1230
 
 
1231
 
 
1232
class BzrDir6(BzrDirPreSplitOut):
 
1233
    """A .bzr version 6 control object.
 
1234
 
 
1235
    This is a deprecated format and may be removed after sept 2006.
 
1236
    """
 
1237
 
 
1238
    def has_workingtree(self):
 
1239
        """See BzrDir.has_workingtree."""
 
1240
        return True
 
1241
    
 
1242
    def open_repository(self):
 
1243
        """See BzrDir.open_repository."""
 
1244
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
 
1245
        return RepositoryFormat6().open(self, _found=True)
 
1246
 
 
1247
    def open_workingtree(self, _unsupported=False,
 
1248
        recommend_upgrade=True):
 
1249
        """See BzrDir.create_workingtree."""
 
1250
        # we don't warn here about upgrades; that ought to be handled for the
 
1251
        # bzrdir as a whole
 
1252
        from bzrlib.workingtree import WorkingTreeFormat2
 
1253
        return WorkingTreeFormat2().open(self, _found=True)
 
1254
 
 
1255
 
1136
1256
class BzrDirMeta1(BzrDir):
1137
1257
    """A .bzr meta version 1 control object.
1138
1258
 
1255
1375
    def has_workingtree(self):
1256
1376
        """Tell if this bzrdir contains a working tree.
1257
1377
 
 
1378
        This will still raise an exception if the bzrdir has a workingtree that
 
1379
        is remote & inaccessible.
 
1380
 
1258
1381
        Note: if you're going to open the working tree, you should just go
1259
1382
        ahead and try, and not ask permission first.
1260
1383
        """
1261
1384
        from bzrlib.workingtree import WorkingTreeFormat
1262
1385
        try:
1263
 
            WorkingTreeFormat.find_format_string(self)
 
1386
            WorkingTreeFormat.find_format(self)
1264
1387
        except errors.NoWorkingTree:
1265
1388
            return False
1266
1389
        return True
1267
1390
 
1268
 
    def needs_format_conversion(self, format):
 
1391
    def needs_format_conversion(self, format=None):
1269
1392
        """See BzrDir.needs_format_conversion()."""
 
1393
        if format is None:
 
1394
            symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
 
1395
                % 'needs_format_conversion(format=None)')
 
1396
        if format is None:
 
1397
            format = BzrDirFormat.get_default_format()
1270
1398
        if not isinstance(self._format, format.__class__):
1271
1399
            # it is not a meta dir format, conversion is needed.
1272
1400
            return True
1297
1425
                    ignore_fallbacks=False):
1298
1426
        """See BzrDir.open_branch."""
1299
1427
        format = self.find_branch_format(name=name)
1300
 
        format.check_support_status(unsupported)
 
1428
        self._check_supported(format, unsupported)
1301
1429
        return format.open(self, name=name,
1302
1430
            _found=True, ignore_fallbacks=ignore_fallbacks)
1303
1431
 
1305
1433
        """See BzrDir.open_repository."""
1306
1434
        from bzrlib.repository import RepositoryFormat
1307
1435
        format = RepositoryFormat.find_format(self)
1308
 
        format.check_support_status(unsupported)
 
1436
        self._check_supported(format, unsupported)
1309
1437
        return format.open(self, _found=True)
1310
1438
 
1311
1439
    def open_workingtree(self, unsupported=False,
1313
1441
        """See BzrDir.open_workingtree."""
1314
1442
        from bzrlib.workingtree import WorkingTreeFormat
1315
1443
        format = WorkingTreeFormat.find_format(self)
1316
 
        format.check_support_status(unsupported, recommend_upgrade,
 
1444
        self._check_supported(format, unsupported,
 
1445
            recommend_upgrade,
1317
1446
            basedir=self.root_transport.base)
1318
1447
        return format.open(self, _found=True)
1319
1448
 
1324
1453
class BzrProber(controldir.Prober):
1325
1454
    """Prober for formats that use a .bzr/ control directory."""
1326
1455
 
1327
 
    formats = registry.FormatRegistry(controldir.network_format_registry)
 
1456
    _formats = {}
1328
1457
    """The known .bzr formats."""
1329
1458
 
1330
1459
    @classmethod
1331
 
    @deprecated_method(deprecated_in((2, 4, 0)))
1332
1460
    def register_bzrdir_format(klass, format):
1333
 
        klass.formats.register(format.get_format_string(), format)
 
1461
        klass._formats[format.get_format_string()] = format
1334
1462
 
1335
1463
    @classmethod
1336
 
    @deprecated_method(deprecated_in((2, 4, 0)))
1337
1464
    def unregister_bzrdir_format(klass, format):
1338
 
        klass.formats.remove(format.get_format_string())
 
1465
        del klass._formats[format.get_format_string()]
1339
1466
 
1340
1467
    @classmethod
1341
1468
    def probe_transport(klass, transport):
1345
1472
        except errors.NoSuchFile:
1346
1473
            raise errors.NotBranchError(path=transport.base)
1347
1474
        try:
1348
 
            return klass.formats.get(format_string)
 
1475
            return klass._formats[format_string]
1349
1476
        except KeyError:
1350
1477
            raise errors.UnknownFormatError(format=format_string, kind='bzrdir')
1351
1478
 
1352
 
    @classmethod
1353
 
    def known_formats(cls):
1354
 
        result = set()
1355
 
        for name, format in cls.formats.iteritems():
1356
 
            if callable(format):
1357
 
                format = format()
1358
 
            result.add(format)
1359
 
        return result
1360
 
 
1361
1479
 
1362
1480
controldir.ControlDirFormat.register_prober(BzrProber)
1363
1481
 
1387
1505
                    raise errors.NotBranchError(path=transport.base)
1388
1506
                if server_version != '2':
1389
1507
                    raise errors.NotBranchError(path=transport.base)
1390
 
            from bzrlib.remote import RemoteBzrDirFormat
1391
1508
            return RemoteBzrDirFormat()
1392
1509
 
1393
 
    @classmethod
1394
 
    def known_formats(cls):
1395
 
        from bzrlib.remote import RemoteBzrDirFormat
1396
 
        return set([RemoteBzrDirFormat()])
1397
 
 
1398
1510
 
1399
1511
class BzrDirFormat(controldir.ControlDirFormat):
1400
1512
    """ControlDirFormat base class for .bzr/ directories.
1413
1525
    # _lock_class must be set in subclasses to the lock type, typ.
1414
1526
    # TransportLock or LockDir
1415
1527
 
1416
 
    @classmethod
1417
 
    def get_format_string(cls):
 
1528
    def get_format_string(self):
1418
1529
        """Return the ASCII format string that identifies this format."""
1419
 
        raise NotImplementedError(cls.get_format_string)
 
1530
        raise NotImplementedError(self.get_format_string)
1420
1531
 
1421
1532
    def initialize_on_transport(self, transport):
1422
1533
        """Initialize a new bzrdir in the base directory of a Transport."""
1432
1543
            # metadir1
1433
1544
            if type(self) != BzrDirMetaFormat1:
1434
1545
                return self._initialize_on_transport_vfs(transport)
1435
 
            from bzrlib.remote import RemoteBzrDirFormat
1436
1546
            remote_format = RemoteBzrDirFormat()
1437
1547
            self._supply_sub_formats_to(remote_format)
1438
1548
            return remote_format.initialize_on_transport(transport)
1476
1586
            except errors.NoSmartMedium:
1477
1587
                pass
1478
1588
            else:
1479
 
                from bzrlib.remote import RemoteBzrDirFormat
1480
1589
                # TODO: lookup the local format from a server hint.
1481
1590
                remote_dir_format = RemoteBzrDirFormat()
1482
1591
                remote_dir_format._network_name = self.network_name()
1597
1706
        """
1598
1707
        raise NotImplementedError(self._open)
1599
1708
 
 
1709
    @classmethod
 
1710
    def register_format(klass, format):
 
1711
        BzrProber.register_bzrdir_format(format)
 
1712
        # bzr native formats have a network name of their format string.
 
1713
        controldir.network_format_registry.register(format.get_format_string(), format.__class__)
 
1714
        controldir.ControlDirFormat.register_format(format)
 
1715
 
1600
1716
    def _supply_sub_formats_to(self, other_format):
1601
1717
        """Give other_format the same values for sub formats as this has.
1602
1718
 
1609
1725
        :return: None.
1610
1726
        """
1611
1727
 
 
1728
    @classmethod
 
1729
    def unregister_format(klass, format):
 
1730
        BzrProber.unregister_bzrdir_format(format)
 
1731
        controldir.ControlDirFormat.unregister_format(format)
 
1732
        controldir.network_format_registry.remove(format.get_format_string())
 
1733
 
 
1734
 
 
1735
class BzrDirFormat4(BzrDirFormat):
 
1736
    """Bzr dir format 4.
 
1737
 
 
1738
    This format is a combined format for working tree, branch and repository.
 
1739
    It has:
 
1740
     - Format 1 working trees [always]
 
1741
     - Format 4 branches [always]
 
1742
     - Format 4 repositories [always]
 
1743
 
 
1744
    This format is deprecated: it indexes texts using a text it which is
 
1745
    removed in format 5; write support for this format has been removed.
 
1746
    """
 
1747
 
 
1748
    _lock_class = lockable_files.TransportLock
 
1749
 
 
1750
    def get_format_string(self):
 
1751
        """See BzrDirFormat.get_format_string()."""
 
1752
        return "Bazaar-NG branch, format 0.0.4\n"
 
1753
 
 
1754
    def get_format_description(self):
 
1755
        """See BzrDirFormat.get_format_description()."""
 
1756
        return "All-in-one format 4"
 
1757
 
 
1758
    def get_converter(self, format=None):
 
1759
        """See BzrDirFormat.get_converter()."""
 
1760
        # there is one and only one upgrade path here.
 
1761
        return ConvertBzrDir4To5()
 
1762
 
 
1763
    def initialize_on_transport(self, transport):
 
1764
        """Format 4 branches cannot be created."""
 
1765
        raise errors.UninitializableFormat(self)
 
1766
 
 
1767
    def is_supported(self):
 
1768
        """Format 4 is not supported.
 
1769
 
 
1770
        It is not supported because the model changed from 4 to 5 and the
 
1771
        conversion logic is expensive - so doing it on the fly was not
 
1772
        feasible.
 
1773
        """
 
1774
        return False
 
1775
 
 
1776
    def network_name(self):
 
1777
        return self.get_format_string()
 
1778
 
 
1779
    def _open(self, transport):
 
1780
        """See BzrDirFormat._open."""
 
1781
        return BzrDir4(transport, self)
 
1782
 
 
1783
    def __return_repository_format(self):
 
1784
        """Circular import protection."""
 
1785
        from bzrlib.repofmt.weaverepo import RepositoryFormat4
 
1786
        return RepositoryFormat4()
 
1787
    repository_format = property(__return_repository_format)
 
1788
 
 
1789
 
 
1790
class BzrDirFormatAllInOne(BzrDirFormat):
 
1791
    """Common class for formats before meta-dirs."""
 
1792
 
 
1793
    def initialize_on_transport_ex(self, transport, use_existing_dir=False,
 
1794
        create_prefix=False, force_new_repo=False, stacked_on=None,
 
1795
        stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
 
1796
        shared_repo=False):
 
1797
        """See BzrDirFormat.initialize_on_transport_ex."""
 
1798
        require_stacking = (stacked_on is not None)
 
1799
        # Format 5 cannot stack, but we've been asked to - actually init
 
1800
        # a Meta1Dir
 
1801
        if require_stacking:
 
1802
            format = BzrDirMetaFormat1()
 
1803
            return format.initialize_on_transport_ex(transport,
 
1804
                use_existing_dir=use_existing_dir, create_prefix=create_prefix,
 
1805
                force_new_repo=force_new_repo, stacked_on=stacked_on,
 
1806
                stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
 
1807
                make_working_trees=make_working_trees, shared_repo=shared_repo)
 
1808
        return BzrDirFormat.initialize_on_transport_ex(self, transport,
 
1809
            use_existing_dir=use_existing_dir, create_prefix=create_prefix,
 
1810
            force_new_repo=force_new_repo, stacked_on=stacked_on,
 
1811
            stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
 
1812
            make_working_trees=make_working_trees, shared_repo=shared_repo)
 
1813
 
 
1814
 
 
1815
class BzrDirFormat5(BzrDirFormatAllInOne):
 
1816
    """Bzr control format 5.
 
1817
 
 
1818
    This format is a combined format for working tree, branch and repository.
 
1819
    It has:
 
1820
     - Format 2 working trees [always]
 
1821
     - Format 4 branches [always]
 
1822
     - Format 5 repositories [always]
 
1823
       Unhashed stores in the repository.
 
1824
    """
 
1825
 
 
1826
    _lock_class = lockable_files.TransportLock
 
1827
 
 
1828
    def get_format_string(self):
 
1829
        """See BzrDirFormat.get_format_string()."""
 
1830
        return "Bazaar-NG branch, format 5\n"
 
1831
 
 
1832
    def get_branch_format(self):
 
1833
        from bzrlib import branch
 
1834
        return branch.BzrBranchFormat4()
 
1835
 
 
1836
    def get_format_description(self):
 
1837
        """See BzrDirFormat.get_format_description()."""
 
1838
        return "All-in-one format 5"
 
1839
 
 
1840
    def get_converter(self, format=None):
 
1841
        """See BzrDirFormat.get_converter()."""
 
1842
        # there is one and only one upgrade path here.
 
1843
        return ConvertBzrDir5To6()
 
1844
 
 
1845
    def _initialize_for_clone(self, url):
 
1846
        return self.initialize_on_transport(get_transport(url), _cloning=True)
 
1847
 
 
1848
    def initialize_on_transport(self, transport, _cloning=False):
 
1849
        """Format 5 dirs always have working tree, branch and repository.
 
1850
 
 
1851
        Except when they are being cloned.
 
1852
        """
 
1853
        from bzrlib.branch import BzrBranchFormat4
 
1854
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
 
1855
        result = (super(BzrDirFormat5, self).initialize_on_transport(transport))
 
1856
        RepositoryFormat5().initialize(result, _internal=True)
 
1857
        if not _cloning:
 
1858
            branch = BzrBranchFormat4().initialize(result)
 
1859
            result._init_workingtree()
 
1860
        return result
 
1861
 
 
1862
    def network_name(self):
 
1863
        return self.get_format_string()
 
1864
 
 
1865
    def _open(self, transport):
 
1866
        """See BzrDirFormat._open."""
 
1867
        return BzrDir5(transport, self)
 
1868
 
 
1869
    def __return_repository_format(self):
 
1870
        """Circular import protection."""
 
1871
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
 
1872
        return RepositoryFormat5()
 
1873
    repository_format = property(__return_repository_format)
 
1874
 
 
1875
 
 
1876
class BzrDirFormat6(BzrDirFormatAllInOne):
 
1877
    """Bzr control format 6.
 
1878
 
 
1879
    This format is a combined format for working tree, branch and repository.
 
1880
    It has:
 
1881
     - Format 2 working trees [always]
 
1882
     - Format 4 branches [always]
 
1883
     - Format 6 repositories [always]
 
1884
    """
 
1885
 
 
1886
    _lock_class = lockable_files.TransportLock
 
1887
 
 
1888
    def get_format_string(self):
 
1889
        """See BzrDirFormat.get_format_string()."""
 
1890
        return "Bazaar-NG branch, format 6\n"
 
1891
 
 
1892
    def get_format_description(self):
 
1893
        """See BzrDirFormat.get_format_description()."""
 
1894
        return "All-in-one format 6"
 
1895
 
 
1896
    def get_branch_format(self):
 
1897
        from bzrlib import branch
 
1898
        return branch.BzrBranchFormat4()
 
1899
 
 
1900
    def get_converter(self, format=None):
 
1901
        """See BzrDirFormat.get_converter()."""
 
1902
        # there is one and only one upgrade path here.
 
1903
        return ConvertBzrDir6ToMeta()
 
1904
 
 
1905
    def _initialize_for_clone(self, url):
 
1906
        return self.initialize_on_transport(get_transport(url), _cloning=True)
 
1907
 
 
1908
    def initialize_on_transport(self, transport, _cloning=False):
 
1909
        """Format 6 dirs always have working tree, branch and repository.
 
1910
 
 
1911
        Except when they are being cloned.
 
1912
        """
 
1913
        from bzrlib.branch import BzrBranchFormat4
 
1914
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
 
1915
        result = super(BzrDirFormat6, self).initialize_on_transport(transport)
 
1916
        RepositoryFormat6().initialize(result, _internal=True)
 
1917
        if not _cloning:
 
1918
            branch = BzrBranchFormat4().initialize(result)
 
1919
            result._init_workingtree()
 
1920
        return result
 
1921
 
 
1922
    def network_name(self):
 
1923
        return self.get_format_string()
 
1924
 
 
1925
    def _open(self, transport):
 
1926
        """See BzrDirFormat._open."""
 
1927
        return BzrDir6(transport, self)
 
1928
 
 
1929
    def __return_repository_format(self):
 
1930
        """Circular import protection."""
 
1931
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
 
1932
        return RepositoryFormat6()
 
1933
    repository_format = property(__return_repository_format)
 
1934
 
1612
1935
 
1613
1936
class BzrDirMetaFormat1(BzrDirFormat):
1614
1937
    """Bzr meta control format 1
1615
1938
 
1616
1939
    This is the first format with split out working tree, branch and repository
1617
1940
    disk storage.
1618
 
 
1619
1941
    It has:
1620
 
 
1621
 
    - Format 3 working trees [optional]
1622
 
    - Format 5 branches [optional]
1623
 
    - Format 7 repositories [optional]
 
1942
     - Format 3 working trees [optional]
 
1943
     - Format 5 branches [optional]
 
1944
     - Format 7 repositories [optional]
1624
1945
    """
1625
1946
 
1626
1947
    _lock_class = lockdir.LockDir
1627
1948
 
1628
 
    fixed_components = False
1629
 
 
1630
1949
    def __init__(self):
1631
1950
        self._workingtree_format = None
1632
1951
        self._branch_format = None
1646
1965
 
1647
1966
    def get_branch_format(self):
1648
1967
        if self._branch_format is None:
1649
 
            from bzrlib.branch import format_registry as branch_format_registry
1650
 
            self._branch_format = branch_format_registry.get_default()
 
1968
            from bzrlib.branch import BranchFormat
 
1969
            self._branch_format = BranchFormat.get_default_format()
1651
1970
        return self._branch_format
1652
1971
 
1653
1972
    def set_branch_format(self, format):
1708
2027
                    # stack_on is inaccessible, JFDI.
1709
2028
                    # TODO: bad monkey, hard-coded formats...
1710
2029
                    if self.repository_format.rich_root_data:
1711
 
                        new_repo_format = knitpack_repo.RepositoryFormatKnitPack5RichRoot()
 
2030
                        new_repo_format = pack_repo.RepositoryFormatKnitPack5RichRoot()
1712
2031
                    else:
1713
 
                        new_repo_format = knitpack_repo.RepositoryFormatKnitPack5()
 
2032
                        new_repo_format = pack_repo.RepositoryFormatKnitPack5()
1714
2033
            else:
1715
2034
                # If the target already supports stacking, then we know the
1716
2035
                # project is already able to use stacking, so auto-upgrade
1733
2052
            if target_branch is None:
1734
2053
                if do_upgrade:
1735
2054
                    # TODO: bad monkey, hard-coded formats...
1736
 
                    from bzrlib.branch import BzrBranchFormat7
1737
 
                    new_branch_format = BzrBranchFormat7()
 
2055
                    new_branch_format = branch.BzrBranchFormat7()
1738
2056
            else:
1739
2057
                new_branch_format = target_branch._format
1740
2058
                if not new_branch_format.supports_stacking():
1755
2073
            raise NotImplementedError(self.get_converter)
1756
2074
        return ConvertMetaToMeta(format)
1757
2075
 
1758
 
    @classmethod
1759
 
    def get_format_string(cls):
 
2076
    def get_format_string(self):
1760
2077
        """See BzrDirFormat.get_format_string()."""
1761
2078
        return "Bazaar-NG meta directory, format 1\n"
1762
2079
 
1780
2097
        """Circular import protection."""
1781
2098
        if self._repository_format:
1782
2099
            return self._repository_format
1783
 
        from bzrlib.repository import format_registry
1784
 
        return format_registry.get_default()
 
2100
        from bzrlib.repository import RepositoryFormat
 
2101
        return RepositoryFormat.get_default_format()
1785
2102
 
1786
2103
    def _set_repository_format(self, value):
1787
2104
        """Allow changing the repository format for metadir formats."""
1810
2127
 
1811
2128
    def __get_workingtree_format(self):
1812
2129
        if self._workingtree_format is None:
1813
 
            from bzrlib.workingtree import (
1814
 
                format_registry as wt_format_registry,
1815
 
                )
1816
 
            self._workingtree_format = wt_format_registry.get_default()
 
2130
            from bzrlib.workingtree import WorkingTreeFormat
 
2131
            self._workingtree_format = WorkingTreeFormat.get_default_format()
1817
2132
        return self._workingtree_format
1818
2133
 
1819
2134
    def __set_workingtree_format(self, wt_format):
1824
2139
 
1825
2140
 
1826
2141
# Register bzr formats
1827
 
BzrProber.formats.register(BzrDirMetaFormat1.get_format_string(),
1828
 
    BzrDirMetaFormat1)
1829
 
controldir.ControlDirFormat._default_format = BzrDirMetaFormat1()
1830
 
 
1831
 
 
1832
 
class ConvertMetaToMeta(controldir.Converter):
 
2142
BzrDirFormat.register_format(BzrDirFormat4())
 
2143
BzrDirFormat.register_format(BzrDirFormat5())
 
2144
BzrDirFormat.register_format(BzrDirFormat6())
 
2145
__default_format = BzrDirMetaFormat1()
 
2146
BzrDirFormat.register_format(__default_format)
 
2147
controldir.ControlDirFormat._default_format = __default_format
 
2148
 
 
2149
 
 
2150
class Converter(object):
 
2151
    """Converts a disk format object from one format to another."""
 
2152
 
 
2153
    def convert(self, to_convert, pb):
 
2154
        """Perform the conversion of to_convert, giving feedback via pb.
 
2155
 
 
2156
        :param to_convert: The disk object to convert.
 
2157
        :param pb: a progress bar to use for progress information.
 
2158
        """
 
2159
 
 
2160
    def step(self, message):
 
2161
        """Update the pb by a step."""
 
2162
        self.count +=1
 
2163
        self.pb.update(message, self.count, self.total)
 
2164
 
 
2165
 
 
2166
class ConvertBzrDir4To5(Converter):
 
2167
    """Converts format 4 bzr dirs to format 5."""
 
2168
 
 
2169
    def __init__(self):
 
2170
        super(ConvertBzrDir4To5, self).__init__()
 
2171
        self.converted_revs = set()
 
2172
        self.absent_revisions = set()
 
2173
        self.text_count = 0
 
2174
        self.revisions = {}
 
2175
 
 
2176
    def convert(self, to_convert, pb):
 
2177
        """See Converter.convert()."""
 
2178
        self.bzrdir = to_convert
 
2179
        if pb is not None:
 
2180
            warnings.warn("pb parameter to convert() is deprecated")
 
2181
        self.pb = ui.ui_factory.nested_progress_bar()
 
2182
        try:
 
2183
            ui.ui_factory.note('starting upgrade from format 4 to 5')
 
2184
            if isinstance(self.bzrdir.transport, local.LocalTransport):
 
2185
                self.bzrdir.get_workingtree_transport(None).delete('stat-cache')
 
2186
            self._convert_to_weaves()
 
2187
            return BzrDir.open(self.bzrdir.user_url)
 
2188
        finally:
 
2189
            self.pb.finished()
 
2190
 
 
2191
    def _convert_to_weaves(self):
 
2192
        ui.ui_factory.note('note: upgrade may be faster if all store files are ungzipped first')
 
2193
        try:
 
2194
            # TODO permissions
 
2195
            stat = self.bzrdir.transport.stat('weaves')
 
2196
            if not S_ISDIR(stat.st_mode):
 
2197
                self.bzrdir.transport.delete('weaves')
 
2198
                self.bzrdir.transport.mkdir('weaves')
 
2199
        except errors.NoSuchFile:
 
2200
            self.bzrdir.transport.mkdir('weaves')
 
2201
        # deliberately not a WeaveFile as we want to build it up slowly.
 
2202
        self.inv_weave = Weave('inventory')
 
2203
        # holds in-memory weaves for all files
 
2204
        self.text_weaves = {}
 
2205
        self.bzrdir.transport.delete('branch-format')
 
2206
        self.branch = self.bzrdir.open_branch()
 
2207
        self._convert_working_inv()
 
2208
        rev_history = self.branch.revision_history()
 
2209
        # to_read is a stack holding the revisions we still need to process;
 
2210
        # appending to it adds new highest-priority revisions
 
2211
        self.known_revisions = set(rev_history)
 
2212
        self.to_read = rev_history[-1:]
 
2213
        while self.to_read:
 
2214
            rev_id = self.to_read.pop()
 
2215
            if (rev_id not in self.revisions
 
2216
                and rev_id not in self.absent_revisions):
 
2217
                self._load_one_rev(rev_id)
 
2218
        self.pb.clear()
 
2219
        to_import = self._make_order()
 
2220
        for i, rev_id in enumerate(to_import):
 
2221
            self.pb.update('converting revision', i, len(to_import))
 
2222
            self._convert_one_rev(rev_id)
 
2223
        self.pb.clear()
 
2224
        self._write_all_weaves()
 
2225
        self._write_all_revs()
 
2226
        ui.ui_factory.note('upgraded to weaves:')
 
2227
        ui.ui_factory.note('  %6d revisions and inventories' % len(self.revisions))
 
2228
        ui.ui_factory.note('  %6d revisions not present' % len(self.absent_revisions))
 
2229
        ui.ui_factory.note('  %6d texts' % self.text_count)
 
2230
        self._cleanup_spare_files_after_format4()
 
2231
        self.branch._transport.put_bytes(
 
2232
            'branch-format',
 
2233
            BzrDirFormat5().get_format_string(),
 
2234
            mode=self.bzrdir._get_file_mode())
 
2235
 
 
2236
    def _cleanup_spare_files_after_format4(self):
 
2237
        # FIXME working tree upgrade foo.
 
2238
        for n in 'merged-patches', 'pending-merged-patches':
 
2239
            try:
 
2240
                ## assert os.path.getsize(p) == 0
 
2241
                self.bzrdir.transport.delete(n)
 
2242
            except errors.NoSuchFile:
 
2243
                pass
 
2244
        self.bzrdir.transport.delete_tree('inventory-store')
 
2245
        self.bzrdir.transport.delete_tree('text-store')
 
2246
 
 
2247
    def _convert_working_inv(self):
 
2248
        inv = xml4.serializer_v4.read_inventory(
 
2249
                self.branch._transport.get('inventory'))
 
2250
        new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv, working=True)
 
2251
        self.branch._transport.put_bytes('inventory', new_inv_xml,
 
2252
            mode=self.bzrdir._get_file_mode())
 
2253
 
 
2254
    def _write_all_weaves(self):
 
2255
        controlweaves = WeaveStore(self.bzrdir.transport, prefixed=False)
 
2256
        weave_transport = self.bzrdir.transport.clone('weaves')
 
2257
        weaves = WeaveStore(weave_transport, prefixed=False)
 
2258
        transaction = WriteTransaction()
 
2259
 
 
2260
        try:
 
2261
            i = 0
 
2262
            for file_id, file_weave in self.text_weaves.items():
 
2263
                self.pb.update('writing weave', i, len(self.text_weaves))
 
2264
                weaves._put_weave(file_id, file_weave, transaction)
 
2265
                i += 1
 
2266
            self.pb.update('inventory', 0, 1)
 
2267
            controlweaves._put_weave('inventory', self.inv_weave, transaction)
 
2268
            self.pb.update('inventory', 1, 1)
 
2269
        finally:
 
2270
            self.pb.clear()
 
2271
 
 
2272
    def _write_all_revs(self):
 
2273
        """Write all revisions out in new form."""
 
2274
        self.bzrdir.transport.delete_tree('revision-store')
 
2275
        self.bzrdir.transport.mkdir('revision-store')
 
2276
        revision_transport = self.bzrdir.transport.clone('revision-store')
 
2277
        # TODO permissions
 
2278
        from bzrlib.xml5 import serializer_v5
 
2279
        from bzrlib.repofmt.weaverepo import RevisionTextStore
 
2280
        revision_store = RevisionTextStore(revision_transport,
 
2281
            serializer_v5, False, versionedfile.PrefixMapper(),
 
2282
            lambda:True, lambda:True)
 
2283
        try:
 
2284
            for i, rev_id in enumerate(self.converted_revs):
 
2285
                self.pb.update('write revision', i, len(self.converted_revs))
 
2286
                text = serializer_v5.write_revision_to_string(
 
2287
                    self.revisions[rev_id])
 
2288
                key = (rev_id,)
 
2289
                revision_store.add_lines(key, None, osutils.split_lines(text))
 
2290
        finally:
 
2291
            self.pb.clear()
 
2292
 
 
2293
    def _load_one_rev(self, rev_id):
 
2294
        """Load a revision object into memory.
 
2295
 
 
2296
        Any parents not either loaded or abandoned get queued to be
 
2297
        loaded."""
 
2298
        self.pb.update('loading revision',
 
2299
                       len(self.revisions),
 
2300
                       len(self.known_revisions))
 
2301
        if not self.branch.repository.has_revision(rev_id):
 
2302
            self.pb.clear()
 
2303
            ui.ui_factory.note('revision {%s} not present in branch; '
 
2304
                         'will be converted as a ghost' %
 
2305
                         rev_id)
 
2306
            self.absent_revisions.add(rev_id)
 
2307
        else:
 
2308
            rev = self.branch.repository.get_revision(rev_id)
 
2309
            for parent_id in rev.parent_ids:
 
2310
                self.known_revisions.add(parent_id)
 
2311
                self.to_read.append(parent_id)
 
2312
            self.revisions[rev_id] = rev
 
2313
 
 
2314
    def _load_old_inventory(self, rev_id):
 
2315
        f = self.branch.repository.inventory_store.get(rev_id)
 
2316
        try:
 
2317
            old_inv_xml = f.read()
 
2318
        finally:
 
2319
            f.close()
 
2320
        inv = xml4.serializer_v4.read_inventory_from_string(old_inv_xml)
 
2321
        inv.revision_id = rev_id
 
2322
        rev = self.revisions[rev_id]
 
2323
        return inv
 
2324
 
 
2325
    def _load_updated_inventory(self, rev_id):
 
2326
        inv_xml = self.inv_weave.get_text(rev_id)
 
2327
        inv = xml5.serializer_v5.read_inventory_from_string(inv_xml, rev_id)
 
2328
        return inv
 
2329
 
 
2330
    def _convert_one_rev(self, rev_id):
 
2331
        """Convert revision and all referenced objects to new format."""
 
2332
        rev = self.revisions[rev_id]
 
2333
        inv = self._load_old_inventory(rev_id)
 
2334
        present_parents = [p for p in rev.parent_ids
 
2335
                           if p not in self.absent_revisions]
 
2336
        self._convert_revision_contents(rev, inv, present_parents)
 
2337
        self._store_new_inv(rev, inv, present_parents)
 
2338
        self.converted_revs.add(rev_id)
 
2339
 
 
2340
    def _store_new_inv(self, rev, inv, present_parents):
 
2341
        new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv)
 
2342
        new_inv_sha1 = sha_string(new_inv_xml)
 
2343
        self.inv_weave.add_lines(rev.revision_id,
 
2344
                                 present_parents,
 
2345
                                 new_inv_xml.splitlines(True))
 
2346
        rev.inventory_sha1 = new_inv_sha1
 
2347
 
 
2348
    def _convert_revision_contents(self, rev, inv, present_parents):
 
2349
        """Convert all the files within a revision.
 
2350
 
 
2351
        Also upgrade the inventory to refer to the text revision ids."""
 
2352
        rev_id = rev.revision_id
 
2353
        mutter('converting texts of revision {%s}',
 
2354
               rev_id)
 
2355
        parent_invs = map(self._load_updated_inventory, present_parents)
 
2356
        entries = inv.iter_entries()
 
2357
        entries.next()
 
2358
        for path, ie in entries:
 
2359
            self._convert_file_version(rev, ie, parent_invs)
 
2360
 
 
2361
    def _convert_file_version(self, rev, ie, parent_invs):
 
2362
        """Convert one version of one file.
 
2363
 
 
2364
        The file needs to be added into the weave if it is a merge
 
2365
        of >=2 parents or if it's changed from its parent.
 
2366
        """
 
2367
        file_id = ie.file_id
 
2368
        rev_id = rev.revision_id
 
2369
        w = self.text_weaves.get(file_id)
 
2370
        if w is None:
 
2371
            w = Weave(file_id)
 
2372
            self.text_weaves[file_id] = w
 
2373
        text_changed = False
 
2374
        parent_candiate_entries = ie.parent_candidates(parent_invs)
 
2375
        heads = graph.Graph(self).heads(parent_candiate_entries.keys())
 
2376
        # XXX: Note that this is unordered - and this is tolerable because
 
2377
        # the previous code was also unordered.
 
2378
        previous_entries = dict((head, parent_candiate_entries[head]) for head
 
2379
            in heads)
 
2380
        self.snapshot_ie(previous_entries, ie, w, rev_id)
 
2381
 
 
2382
    def get_parent_map(self, revision_ids):
 
2383
        """See graph.StackedParentsProvider.get_parent_map"""
 
2384
        return dict((revision_id, self.revisions[revision_id])
 
2385
                    for revision_id in revision_ids
 
2386
                     if revision_id in self.revisions)
 
2387
 
 
2388
    def snapshot_ie(self, previous_revisions, ie, w, rev_id):
 
2389
        # TODO: convert this logic, which is ~= snapshot to
 
2390
        # a call to:. This needs the path figured out. rather than a work_tree
 
2391
        # a v4 revision_tree can be given, or something that looks enough like
 
2392
        # one to give the file content to the entry if it needs it.
 
2393
        # and we need something that looks like a weave store for snapshot to
 
2394
        # save against.
 
2395
        #ie.snapshot(rev, PATH, previous_revisions, REVISION_TREE, InMemoryWeaveStore(self.text_weaves))
 
2396
        if len(previous_revisions) == 1:
 
2397
            previous_ie = previous_revisions.values()[0]
 
2398
            if ie._unchanged(previous_ie):
 
2399
                ie.revision = previous_ie.revision
 
2400
                return
 
2401
        if ie.has_text():
 
2402
            f = self.branch.repository._text_store.get(ie.text_id)
 
2403
            try:
 
2404
                file_lines = f.readlines()
 
2405
            finally:
 
2406
                f.close()
 
2407
            w.add_lines(rev_id, previous_revisions, file_lines)
 
2408
            self.text_count += 1
 
2409
        else:
 
2410
            w.add_lines(rev_id, previous_revisions, [])
 
2411
        ie.revision = rev_id
 
2412
 
 
2413
    def _make_order(self):
 
2414
        """Return a suitable order for importing revisions.
 
2415
 
 
2416
        The order must be such that an revision is imported after all
 
2417
        its (present) parents.
 
2418
        """
 
2419
        todo = set(self.revisions.keys())
 
2420
        done = self.absent_revisions.copy()
 
2421
        order = []
 
2422
        while todo:
 
2423
            # scan through looking for a revision whose parents
 
2424
            # are all done
 
2425
            for rev_id in sorted(list(todo)):
 
2426
                rev = self.revisions[rev_id]
 
2427
                parent_ids = set(rev.parent_ids)
 
2428
                if parent_ids.issubset(done):
 
2429
                    # can take this one now
 
2430
                    order.append(rev_id)
 
2431
                    todo.remove(rev_id)
 
2432
                    done.add(rev_id)
 
2433
        return order
 
2434
 
 
2435
 
 
2436
class ConvertBzrDir5To6(Converter):
 
2437
    """Converts format 5 bzr dirs to format 6."""
 
2438
 
 
2439
    def convert(self, to_convert, pb):
 
2440
        """See Converter.convert()."""
 
2441
        self.bzrdir = to_convert
 
2442
        pb = ui.ui_factory.nested_progress_bar()
 
2443
        try:
 
2444
            ui.ui_factory.note('starting upgrade from format 5 to 6')
 
2445
            self._convert_to_prefixed()
 
2446
            return BzrDir.open(self.bzrdir.user_url)
 
2447
        finally:
 
2448
            pb.finished()
 
2449
 
 
2450
    def _convert_to_prefixed(self):
 
2451
        from bzrlib.store import TransportStore
 
2452
        self.bzrdir.transport.delete('branch-format')
 
2453
        for store_name in ["weaves", "revision-store"]:
 
2454
            ui.ui_factory.note("adding prefixes to %s" % store_name)
 
2455
            store_transport = self.bzrdir.transport.clone(store_name)
 
2456
            store = TransportStore(store_transport, prefixed=True)
 
2457
            for urlfilename in store_transport.list_dir('.'):
 
2458
                filename = urlutils.unescape(urlfilename)
 
2459
                if (filename.endswith(".weave") or
 
2460
                    filename.endswith(".gz") or
 
2461
                    filename.endswith(".sig")):
 
2462
                    file_id, suffix = os.path.splitext(filename)
 
2463
                else:
 
2464
                    file_id = filename
 
2465
                    suffix = ''
 
2466
                new_name = store._mapper.map((file_id,)) + suffix
 
2467
                # FIXME keep track of the dirs made RBC 20060121
 
2468
                try:
 
2469
                    store_transport.move(filename, new_name)
 
2470
                except errors.NoSuchFile: # catches missing dirs strangely enough
 
2471
                    store_transport.mkdir(osutils.dirname(new_name))
 
2472
                    store_transport.move(filename, new_name)
 
2473
        self.bzrdir.transport.put_bytes(
 
2474
            'branch-format',
 
2475
            BzrDirFormat6().get_format_string(),
 
2476
            mode=self.bzrdir._get_file_mode())
 
2477
 
 
2478
 
 
2479
class ConvertBzrDir6ToMeta(Converter):
 
2480
    """Converts format 6 bzr dirs to metadirs."""
 
2481
 
 
2482
    def convert(self, to_convert, pb):
 
2483
        """See Converter.convert()."""
 
2484
        from bzrlib.repofmt.weaverepo import RepositoryFormat7
 
2485
        from bzrlib.branch import BzrBranchFormat5
 
2486
        self.bzrdir = to_convert
 
2487
        self.pb = ui.ui_factory.nested_progress_bar()
 
2488
        self.count = 0
 
2489
        self.total = 20 # the steps we know about
 
2490
        self.garbage_inventories = []
 
2491
        self.dir_mode = self.bzrdir._get_dir_mode()
 
2492
        self.file_mode = self.bzrdir._get_file_mode()
 
2493
 
 
2494
        ui.ui_factory.note('starting upgrade from format 6 to metadir')
 
2495
        self.bzrdir.transport.put_bytes(
 
2496
                'branch-format',
 
2497
                "Converting to format 6",
 
2498
                mode=self.file_mode)
 
2499
        # its faster to move specific files around than to open and use the apis...
 
2500
        # first off, nuke ancestry.weave, it was never used.
 
2501
        try:
 
2502
            self.step('Removing ancestry.weave')
 
2503
            self.bzrdir.transport.delete('ancestry.weave')
 
2504
        except errors.NoSuchFile:
 
2505
            pass
 
2506
        # find out whats there
 
2507
        self.step('Finding branch files')
 
2508
        last_revision = self.bzrdir.open_branch().last_revision()
 
2509
        bzrcontents = self.bzrdir.transport.list_dir('.')
 
2510
        for name in bzrcontents:
 
2511
            if name.startswith('basis-inventory.'):
 
2512
                self.garbage_inventories.append(name)
 
2513
        # create new directories for repository, working tree and branch
 
2514
        repository_names = [('inventory.weave', True),
 
2515
                            ('revision-store', True),
 
2516
                            ('weaves', True)]
 
2517
        self.step('Upgrading repository  ')
 
2518
        self.bzrdir.transport.mkdir('repository', mode=self.dir_mode)
 
2519
        self.make_lock('repository')
 
2520
        # we hard code the formats here because we are converting into
 
2521
        # the meta format. The meta format upgrader can take this to a
 
2522
        # future format within each component.
 
2523
        self.put_format('repository', RepositoryFormat7())
 
2524
        for entry in repository_names:
 
2525
            self.move_entry('repository', entry)
 
2526
 
 
2527
        self.step('Upgrading branch      ')
 
2528
        self.bzrdir.transport.mkdir('branch', mode=self.dir_mode)
 
2529
        self.make_lock('branch')
 
2530
        self.put_format('branch', BzrBranchFormat5())
 
2531
        branch_files = [('revision-history', True),
 
2532
                        ('branch-name', True),
 
2533
                        ('parent', False)]
 
2534
        for entry in branch_files:
 
2535
            self.move_entry('branch', entry)
 
2536
 
 
2537
        checkout_files = [('pending-merges', True),
 
2538
                          ('inventory', True),
 
2539
                          ('stat-cache', False)]
 
2540
        # If a mandatory checkout file is not present, the branch does not have
 
2541
        # a functional checkout. Do not create a checkout in the converted
 
2542
        # branch.
 
2543
        for name, mandatory in checkout_files:
 
2544
            if mandatory and name not in bzrcontents:
 
2545
                has_checkout = False
 
2546
                break
 
2547
        else:
 
2548
            has_checkout = True
 
2549
        if not has_checkout:
 
2550
            ui.ui_factory.note('No working tree.')
 
2551
            # If some checkout files are there, we may as well get rid of them.
 
2552
            for name, mandatory in checkout_files:
 
2553
                if name in bzrcontents:
 
2554
                    self.bzrdir.transport.delete(name)
 
2555
        else:
 
2556
            from bzrlib.workingtree import WorkingTreeFormat3
 
2557
            self.step('Upgrading working tree')
 
2558
            self.bzrdir.transport.mkdir('checkout', mode=self.dir_mode)
 
2559
            self.make_lock('checkout')
 
2560
            self.put_format(
 
2561
                'checkout', WorkingTreeFormat3())
 
2562
            self.bzrdir.transport.delete_multi(
 
2563
                self.garbage_inventories, self.pb)
 
2564
            for entry in checkout_files:
 
2565
                self.move_entry('checkout', entry)
 
2566
            if last_revision is not None:
 
2567
                self.bzrdir.transport.put_bytes(
 
2568
                    'checkout/last-revision', last_revision)
 
2569
        self.bzrdir.transport.put_bytes(
 
2570
            'branch-format',
 
2571
            BzrDirMetaFormat1().get_format_string(),
 
2572
            mode=self.file_mode)
 
2573
        self.pb.finished()
 
2574
        return BzrDir.open(self.bzrdir.user_url)
 
2575
 
 
2576
    def make_lock(self, name):
 
2577
        """Make a lock for the new control dir name."""
 
2578
        self.step('Make %s lock' % name)
 
2579
        ld = lockdir.LockDir(self.bzrdir.transport,
 
2580
                             '%s/lock' % name,
 
2581
                             file_modebits=self.file_mode,
 
2582
                             dir_modebits=self.dir_mode)
 
2583
        ld.create()
 
2584
 
 
2585
    def move_entry(self, new_dir, entry):
 
2586
        """Move then entry name into new_dir."""
 
2587
        name = entry[0]
 
2588
        mandatory = entry[1]
 
2589
        self.step('Moving %s' % name)
 
2590
        try:
 
2591
            self.bzrdir.transport.move(name, '%s/%s' % (new_dir, name))
 
2592
        except errors.NoSuchFile:
 
2593
            if mandatory:
 
2594
                raise
 
2595
 
 
2596
    def put_format(self, dirname, format):
 
2597
        self.bzrdir.transport.put_bytes('%s/format' % dirname,
 
2598
            format.get_format_string(),
 
2599
            self.file_mode)
 
2600
 
 
2601
 
 
2602
class ConvertMetaToMeta(Converter):
1833
2603
    """Converts the components of metadirs."""
1834
2604
 
1835
2605
    def __init__(self, target_format):
1860
2630
            # TODO: conversions of Branch and Tree should be done by
1861
2631
            # InterXFormat lookups/some sort of registry.
1862
2632
            # Avoid circular imports
 
2633
            from bzrlib import branch as _mod_branch
1863
2634
            old = branch._format.__class__
1864
2635
            new = self.target_format.get_branch_format().__class__
1865
2636
            while old != new:
1888
2659
        else:
1889
2660
            # TODO: conversions of Branch and Tree should be done by
1890
2661
            # InterXFormat lookups
1891
 
            if (isinstance(tree, workingtree_3.WorkingTree3) and
 
2662
            if (isinstance(tree, workingtree.WorkingTree3) and
1892
2663
                not isinstance(tree, workingtree_4.DirStateWorkingTree) and
1893
2664
                isinstance(self.target_format.workingtree_format,
1894
2665
                    workingtree_4.DirStateWorkingTreeFormat)):
1907
2678
        return to_convert
1908
2679
 
1909
2680
 
 
2681
# This is not in remote.py because it's relatively small, and needs to be
 
2682
# registered. Putting it in remote.py creates a circular import problem.
 
2683
# we can make it a lazy object if the control formats is turned into something
 
2684
# like a registry.
 
2685
class RemoteBzrDirFormat(BzrDirMetaFormat1):
 
2686
    """Format representing bzrdirs accessed via a smart server"""
 
2687
 
 
2688
    supports_workingtrees = False
 
2689
 
 
2690
    def __init__(self):
 
2691
        BzrDirMetaFormat1.__init__(self)
 
2692
        # XXX: It's a bit ugly that the network name is here, because we'd
 
2693
        # like to believe that format objects are stateless or at least
 
2694
        # immutable,  However, we do at least avoid mutating the name after
 
2695
        # it's returned.  See <https://bugs.launchpad.net/bzr/+bug/504102>
 
2696
        self._network_name = None
 
2697
 
 
2698
    def __repr__(self):
 
2699
        return "%s(_network_name=%r)" % (self.__class__.__name__,
 
2700
            self._network_name)
 
2701
 
 
2702
    def get_format_description(self):
 
2703
        if self._network_name:
 
2704
            real_format = controldir.network_format_registry.get(self._network_name)
 
2705
            return 'Remote: ' + real_format.get_format_description()
 
2706
        return 'bzr remote bzrdir'
 
2707
 
 
2708
    def get_format_string(self):
 
2709
        raise NotImplementedError(self.get_format_string)
 
2710
 
 
2711
    def network_name(self):
 
2712
        if self._network_name:
 
2713
            return self._network_name
 
2714
        else:
 
2715
            raise AssertionError("No network name set.")
 
2716
 
 
2717
    def initialize_on_transport(self, transport):
 
2718
        try:
 
2719
            # hand off the request to the smart server
 
2720
            client_medium = transport.get_smart_medium()
 
2721
        except errors.NoSmartMedium:
 
2722
            # TODO: lookup the local format from a server hint.
 
2723
            local_dir_format = BzrDirMetaFormat1()
 
2724
            return local_dir_format.initialize_on_transport(transport)
 
2725
        client = _SmartClient(client_medium)
 
2726
        path = client.remote_path_from_transport(transport)
 
2727
        try:
 
2728
            response = client.call('BzrDirFormat.initialize', path)
 
2729
        except errors.ErrorFromSmartServer, err:
 
2730
            remote._translate_error(err, path=path)
 
2731
        if response[0] != 'ok':
 
2732
            raise errors.SmartProtocolError('unexpected response code %s' % (response,))
 
2733
        format = RemoteBzrDirFormat()
 
2734
        self._supply_sub_formats_to(format)
 
2735
        return remote.RemoteBzrDir(transport, format)
 
2736
 
 
2737
    def parse_NoneTrueFalse(self, arg):
 
2738
        if not arg:
 
2739
            return None
 
2740
        if arg == 'False':
 
2741
            return False
 
2742
        if arg == 'True':
 
2743
            return True
 
2744
        raise AssertionError("invalid arg %r" % arg)
 
2745
 
 
2746
    def _serialize_NoneTrueFalse(self, arg):
 
2747
        if arg is False:
 
2748
            return 'False'
 
2749
        if arg:
 
2750
            return 'True'
 
2751
        return ''
 
2752
 
 
2753
    def _serialize_NoneString(self, arg):
 
2754
        return arg or ''
 
2755
 
 
2756
    def initialize_on_transport_ex(self, transport, use_existing_dir=False,
 
2757
        create_prefix=False, force_new_repo=False, stacked_on=None,
 
2758
        stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
 
2759
        shared_repo=False):
 
2760
        try:
 
2761
            # hand off the request to the smart server
 
2762
            client_medium = transport.get_smart_medium()
 
2763
        except errors.NoSmartMedium:
 
2764
            do_vfs = True
 
2765
        else:
 
2766
            # Decline to open it if the server doesn't support our required
 
2767
            # version (3) so that the VFS-based transport will do it.
 
2768
            if client_medium.should_probe():
 
2769
                try:
 
2770
                    server_version = client_medium.protocol_version()
 
2771
                    if server_version != '2':
 
2772
                        do_vfs = True
 
2773
                    else:
 
2774
                        do_vfs = False
 
2775
                except errors.SmartProtocolError:
 
2776
                    # Apparently there's no usable smart server there, even though
 
2777
                    # the medium supports the smart protocol.
 
2778
                    do_vfs = True
 
2779
            else:
 
2780
                do_vfs = False
 
2781
        if not do_vfs:
 
2782
            client = _SmartClient(client_medium)
 
2783
            path = client.remote_path_from_transport(transport)
 
2784
            if client_medium._is_remote_before((1, 16)):
 
2785
                do_vfs = True
 
2786
        if do_vfs:
 
2787
            # TODO: lookup the local format from a server hint.
 
2788
            local_dir_format = BzrDirMetaFormat1()
 
2789
            self._supply_sub_formats_to(local_dir_format)
 
2790
            return local_dir_format.initialize_on_transport_ex(transport,
 
2791
                use_existing_dir=use_existing_dir, create_prefix=create_prefix,
 
2792
                force_new_repo=force_new_repo, stacked_on=stacked_on,
 
2793
                stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
 
2794
                make_working_trees=make_working_trees, shared_repo=shared_repo,
 
2795
                vfs_only=True)
 
2796
        return self._initialize_on_transport_ex_rpc(client, path, transport,
 
2797
            use_existing_dir, create_prefix, force_new_repo, stacked_on,
 
2798
            stack_on_pwd, repo_format_name, make_working_trees, shared_repo)
 
2799
 
 
2800
    def _initialize_on_transport_ex_rpc(self, client, path, transport,
 
2801
        use_existing_dir, create_prefix, force_new_repo, stacked_on,
 
2802
        stack_on_pwd, repo_format_name, make_working_trees, shared_repo):
 
2803
        args = []
 
2804
        args.append(self._serialize_NoneTrueFalse(use_existing_dir))
 
2805
        args.append(self._serialize_NoneTrueFalse(create_prefix))
 
2806
        args.append(self._serialize_NoneTrueFalse(force_new_repo))
 
2807
        args.append(self._serialize_NoneString(stacked_on))
 
2808
        # stack_on_pwd is often/usually our transport
 
2809
        if stack_on_pwd:
 
2810
            try:
 
2811
                stack_on_pwd = transport.relpath(stack_on_pwd)
 
2812
                if not stack_on_pwd:
 
2813
                    stack_on_pwd = '.'
 
2814
            except errors.PathNotChild:
 
2815
                pass
 
2816
        args.append(self._serialize_NoneString(stack_on_pwd))
 
2817
        args.append(self._serialize_NoneString(repo_format_name))
 
2818
        args.append(self._serialize_NoneTrueFalse(make_working_trees))
 
2819
        args.append(self._serialize_NoneTrueFalse(shared_repo))
 
2820
        request_network_name = self._network_name or \
 
2821
            BzrDirFormat.get_default_format().network_name()
 
2822
        try:
 
2823
            response = client.call('BzrDirFormat.initialize_ex_1.16',
 
2824
                request_network_name, path, *args)
 
2825
        except errors.UnknownSmartMethod:
 
2826
            client._medium._remember_remote_is_before((1,16))
 
2827
            local_dir_format = BzrDirMetaFormat1()
 
2828
            self._supply_sub_formats_to(local_dir_format)
 
2829
            return local_dir_format.initialize_on_transport_ex(transport,
 
2830
                use_existing_dir=use_existing_dir, create_prefix=create_prefix,
 
2831
                force_new_repo=force_new_repo, stacked_on=stacked_on,
 
2832
                stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
 
2833
                make_working_trees=make_working_trees, shared_repo=shared_repo,
 
2834
                vfs_only=True)
 
2835
        except errors.ErrorFromSmartServer, err:
 
2836
            remote._translate_error(err, path=path)
 
2837
        repo_path = response[0]
 
2838
        bzrdir_name = response[6]
 
2839
        require_stacking = response[7]
 
2840
        require_stacking = self.parse_NoneTrueFalse(require_stacking)
 
2841
        format = RemoteBzrDirFormat()
 
2842
        format._network_name = bzrdir_name
 
2843
        self._supply_sub_formats_to(format)
 
2844
        bzrdir = remote.RemoteBzrDir(transport, format, _client=client)
 
2845
        if repo_path:
 
2846
            repo_format = remote.response_tuple_to_repo_format(response[1:])
 
2847
            if repo_path == '.':
 
2848
                repo_path = ''
 
2849
            if repo_path:
 
2850
                repo_bzrdir_format = RemoteBzrDirFormat()
 
2851
                repo_bzrdir_format._network_name = response[5]
 
2852
                repo_bzr = remote.RemoteBzrDir(transport.clone(repo_path),
 
2853
                    repo_bzrdir_format)
 
2854
            else:
 
2855
                repo_bzr = bzrdir
 
2856
            final_stack = response[8] or None
 
2857
            final_stack_pwd = response[9] or None
 
2858
            if final_stack_pwd:
 
2859
                final_stack_pwd = urlutils.join(
 
2860
                    transport.base, final_stack_pwd)
 
2861
            remote_repo = remote.RemoteRepository(repo_bzr, repo_format)
 
2862
            if len(response) > 10:
 
2863
                # Updated server verb that locks remotely.
 
2864
                repo_lock_token = response[10] or None
 
2865
                remote_repo.lock_write(repo_lock_token, _skip_rpc=True)
 
2866
                if repo_lock_token:
 
2867
                    remote_repo.dont_leave_lock_in_place()
 
2868
            else:
 
2869
                remote_repo.lock_write()
 
2870
            policy = UseExistingRepository(remote_repo, final_stack,
 
2871
                final_stack_pwd, require_stacking)
 
2872
            policy.acquire_repository()
 
2873
        else:
 
2874
            remote_repo = None
 
2875
            policy = None
 
2876
        bzrdir._format.set_branch_format(self.get_branch_format())
 
2877
        if require_stacking:
 
2878
            # The repo has already been created, but we need to make sure that
 
2879
            # we'll make a stackable branch.
 
2880
            bzrdir._format.require_stacking(_skip_repo=True)
 
2881
        return remote_repo, bzrdir, require_stacking, policy
 
2882
 
 
2883
    def _open(self, transport):
 
2884
        return remote.RemoteBzrDir(transport, self)
 
2885
 
 
2886
    def __eq__(self, other):
 
2887
        if not isinstance(other, RemoteBzrDirFormat):
 
2888
            return False
 
2889
        return self.get_format_description() == other.get_format_description()
 
2890
 
 
2891
    def __return_repository_format(self):
 
2892
        # Always return a RemoteRepositoryFormat object, but if a specific bzr
 
2893
        # repository format has been asked for, tell the RemoteRepositoryFormat
 
2894
        # that it should use that for init() etc.
 
2895
        result = remote.RemoteRepositoryFormat()
 
2896
        custom_format = getattr(self, '_repository_format', None)
 
2897
        if custom_format:
 
2898
            if isinstance(custom_format, remote.RemoteRepositoryFormat):
 
2899
                return custom_format
 
2900
            else:
 
2901
                # We will use the custom format to create repositories over the
 
2902
                # wire; expose its details like rich_root_data for code to
 
2903
                # query
 
2904
                result._custom_format = custom_format
 
2905
        return result
 
2906
 
 
2907
    def get_branch_format(self):
 
2908
        result = BzrDirMetaFormat1.get_branch_format(self)
 
2909
        if not isinstance(result, remote.RemoteBranchFormat):
 
2910
            new_result = remote.RemoteBranchFormat()
 
2911
            new_result._custom_format = result
 
2912
            # cache the result
 
2913
            self.set_branch_format(new_result)
 
2914
            result = new_result
 
2915
        return result
 
2916
 
 
2917
    repository_format = property(__return_repository_format,
 
2918
        BzrDirMetaFormat1._set_repository_format) #.im_func)
 
2919
 
 
2920
 
1910
2921
controldir.ControlDirFormat.register_server_prober(RemoteBzrProber)
1911
2922
 
1912
2923
 
1994
3005
 
1995
3006
        Implementations may create a new repository or use a pre-exising
1996
3007
        repository.
1997
 
 
1998
3008
        :param make_working_trees: If creating a repository, set
1999
3009
            make_working_trees to this value (if non-None)
2000
3010
        :param shared: If creating a repository, make it shared if True
2009
3019
 
2010
3020
    def __init__(self, bzrdir, stack_on=None, stack_on_pwd=None,
2011
3021
                 require_stacking=False):
2012
 
        """Constructor.
2013
 
 
 
3022
        """
 
3023
        Constructor.
2014
3024
        :param bzrdir: The bzrdir to create the repository on.
2015
3025
        :param stack_on: A location to stack on
2016
3026
        :param stack_on_pwd: If stack_on is relative, the location it is
2112
3122
    registry.register(key, helper, help, native, deprecated, hidden,
2113
3123
        experimental, alias)
2114
3124
 
 
3125
# The pre-0.8 formats have their repository format network name registered in
 
3126
# repository.py. MetaDir formats have their repository format network name
 
3127
# inferred from their disk format string.
 
3128
controldir.format_registry.register('weave', BzrDirFormat6,
 
3129
    'Pre-0.8 format.  Slower than knit and does not'
 
3130
    ' support checkouts or shared repositories.',
 
3131
    hidden=True,
 
3132
    deprecated=True)
 
3133
register_metadir(controldir.format_registry, 'metaweave',
 
3134
    'bzrlib.repofmt.weaverepo.RepositoryFormat7',
 
3135
    'Transitional format in 0.8.  Slower than knit.',
 
3136
    branch_format='bzrlib.branch.BzrBranchFormat5',
 
3137
    tree_format='bzrlib.workingtree.WorkingTreeFormat3',
 
3138
    hidden=True,
 
3139
    deprecated=True)
2115
3140
register_metadir(controldir.format_registry, 'knit',
2116
3141
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
2117
3142
    'Format using knits.  Recommended for interoperation with bzr <= 0.14.',
2118
3143
    branch_format='bzrlib.branch.BzrBranchFormat5',
2119
 
    tree_format='bzrlib.workingtree_3.WorkingTreeFormat3',
 
3144
    tree_format='bzrlib.workingtree.WorkingTreeFormat3',
2120
3145
    hidden=True,
2121
3146
    deprecated=True)
2122
3147
register_metadir(controldir.format_registry, 'dirstate',
2124
3149
    help='New in 0.15: Fast local operations. Compatible with bzr 0.8 and '
2125
3150
        'above when accessed over the network.',
2126
3151
    branch_format='bzrlib.branch.BzrBranchFormat5',
2127
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3152
    # this uses bzrlib.workingtree.WorkingTreeFormat4 because importing
 
3153
    # directly from workingtree_4 triggers a circular import.
 
3154
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2128
3155
    hidden=True,
2129
3156
    deprecated=True)
2130
3157
register_metadir(controldir.format_registry, 'dirstate-tags',
2133
3160
        'network operations. Additionally adds support for tags.'
2134
3161
        ' Incompatible with bzr < 0.15.',
2135
3162
    branch_format='bzrlib.branch.BzrBranchFormat6',
2136
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3163
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2137
3164
    hidden=True,
2138
3165
    deprecated=True)
2139
3166
register_metadir(controldir.format_registry, 'rich-root',
2141
3168
    help='New in 1.0.  Better handling of tree roots.  Incompatible with'
2142
3169
        ' bzr < 1.0.',
2143
3170
    branch_format='bzrlib.branch.BzrBranchFormat6',
2144
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3171
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2145
3172
    hidden=True,
2146
3173
    deprecated=True)
2147
3174
register_metadir(controldir.format_registry, 'dirstate-with-subtree',
2150
3177
        'network operations. Additionally adds support for versioning nested '
2151
3178
        'bzr branches. Incompatible with bzr < 0.15.',
2152
3179
    branch_format='bzrlib.branch.BzrBranchFormat6',
2153
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3180
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2154
3181
    experimental=True,
2155
3182
    hidden=True,
2156
3183
    )
2157
3184
register_metadir(controldir.format_registry, 'pack-0.92',
2158
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack1',
 
3185
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack1',
2159
3186
    help='New in 0.92: Pack-based format with data compatible with '
2160
3187
        'dirstate-tags format repositories. Interoperates with '
2161
3188
        'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
2162
3189
        ,
2163
3190
    branch_format='bzrlib.branch.BzrBranchFormat6',
2164
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3191
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2165
3192
    )
2166
3193
register_metadir(controldir.format_registry, 'pack-0.92-subtree',
2167
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack3',
 
3194
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack3',
2168
3195
    help='New in 0.92: Pack-based format with data compatible with '
2169
3196
        'dirstate-with-subtree format repositories. Interoperates with '
2170
3197
        'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
2171
3198
        ,
2172
3199
    branch_format='bzrlib.branch.BzrBranchFormat6',
2173
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3200
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2174
3201
    hidden=True,
2175
3202
    experimental=True,
2176
3203
    )
2177
3204
register_metadir(controldir.format_registry, 'rich-root-pack',
2178
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack4',
 
3205
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack4',
2179
3206
    help='New in 1.0: A variant of pack-0.92 that supports rich-root data '
2180
3207
         '(needed for bzr-svn and bzr-git).',
2181
3208
    branch_format='bzrlib.branch.BzrBranchFormat6',
2182
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3209
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2183
3210
    hidden=True,
2184
3211
    )
2185
3212
register_metadir(controldir.format_registry, '1.6',
2186
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack5',
 
3213
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5',
2187
3214
    help='A format that allows a branch to indicate that there is another '
2188
3215
         '(stacked) repository that should be used to access data that is '
2189
3216
         'not present locally.',
2190
3217
    branch_format='bzrlib.branch.BzrBranchFormat7',
2191
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3218
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2192
3219
    hidden=True,
2193
3220
    )
2194
3221
register_metadir(controldir.format_registry, '1.6.1-rich-root',
2195
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack5RichRoot',
 
3222
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5RichRoot',
2196
3223
    help='A variant of 1.6 that supports rich-root data '
2197
3224
         '(needed for bzr-svn and bzr-git).',
2198
3225
    branch_format='bzrlib.branch.BzrBranchFormat7',
2199
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3226
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2200
3227
    hidden=True,
2201
3228
    )
2202
3229
register_metadir(controldir.format_registry, '1.9',
2203
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6',
 
3230
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
2204
3231
    help='A repository format using B+tree indexes. These indexes '
2205
3232
         'are smaller in size, have smarter caching and provide faster '
2206
3233
         'performance for most operations.',
2207
3234
    branch_format='bzrlib.branch.BzrBranchFormat7',
2208
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3235
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2209
3236
    hidden=True,
2210
3237
    )
2211
3238
register_metadir(controldir.format_registry, '1.9-rich-root',
2212
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6RichRoot',
 
3239
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
2213
3240
    help='A variant of 1.9 that supports rich-root data '
2214
3241
         '(needed for bzr-svn and bzr-git).',
2215
3242
    branch_format='bzrlib.branch.BzrBranchFormat7',
2216
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
 
3243
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2217
3244
    hidden=True,
2218
3245
    )
2219
3246
register_metadir(controldir.format_registry, '1.14',
2220
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6',
 
3247
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
2221
3248
    help='A working-tree format that supports content filtering.',
2222
3249
    branch_format='bzrlib.branch.BzrBranchFormat7',
2223
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat5',
 
3250
    tree_format='bzrlib.workingtree.WorkingTreeFormat5',
2224
3251
    )
2225
3252
register_metadir(controldir.format_registry, '1.14-rich-root',
2226
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6RichRoot',
 
3253
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
2227
3254
    help='A variant of 1.14 that supports rich-root data '
2228
3255
         '(needed for bzr-svn and bzr-git).',
2229
3256
    branch_format='bzrlib.branch.BzrBranchFormat7',
2230
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat5',
 
3257
    tree_format='bzrlib.workingtree.WorkingTreeFormat5',
2231
3258
    )
2232
3259
# The following un-numbered 'development' formats should always just be aliases.
2233
3260
register_metadir(controldir.format_registry, 'development-subtree',
2239
3266
        'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
2240
3267
        'before use.',
2241
3268
    branch_format='bzrlib.branch.BzrBranchFormat7',
2242
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
 
3269
    tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2243
3270
    experimental=True,
2244
3271
    hidden=True,
2245
3272
    alias=False, # Restore to being an alias when an actual development subtree format is added
2247
3274
                 # chk based subtree format.
2248
3275
    )
2249
3276
register_metadir(controldir.format_registry, 'development5-subtree',
2250
 
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatPackDevelopment2Subtree',
 
3277
    'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment2Subtree',
2251
3278
    help='Development format, subtree variant. Can convert data to and '
2252
3279
        'from pack-0.92-subtree (and anything compatible with '
2253
3280
        'pack-0.92-subtree) format repositories. Repositories and branches in '
2255
3282
        'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
2256
3283
        'before use.',
2257
3284
    branch_format='bzrlib.branch.BzrBranchFormat7',
2258
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
 
3285
    tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2259
3286
    experimental=True,
2260
3287
    hidden=True,
2261
3288
    alias=False,
2272
3299
        # 'storage in packs, 255-way hashed CHK inventory, bencode revision, group compress, '
2273
3300
        # 'rich roots. Supported by bzr 1.16 and later.',
2274
3301
    branch_format='bzrlib.branch.BzrBranchFormat7',
2275
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
 
3302
    tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2276
3303
    experimental=False,
2277
3304
    )
2278
3305
 
2281
3308
register_metadir(controldir.format_registry, 'default-rich-root',
2282
3309
    'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
2283
3310
    branch_format='bzrlib.branch.BzrBranchFormat7',
2284
 
    tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
 
3311
    tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2285
3312
    alias=True,
2286
3313
    hidden=True,
2287
3314
    help='Same as 2a.')