/brz/remove-bazaar

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

« back to all changes in this revision

Viewing changes to bzrlib/bzrdir.py

  • Committer: John Arbash Meinel
  • Date: 2011-04-22 14:12:22 UTC
  • mfrom: (5809 +trunk)
  • mto: This revision was merged to the branch mainline in revision 5836.
  • Revision ID: john@arbash-meinel.com-20110422141222-nx2j0hbkihcb8j16
Merge newer bzr.dev and resolve conflicts.
Try to write some documentation about how the _dirblock_state works.
Fix up the tests so that they pass again.

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2006-2011 Canonical Ltd
 
2
#
 
3
# This program is free software; you can redistribute it and/or modify
 
4
# it under the terms of the GNU General Public License as published by
 
5
# the Free Software Foundation; either version 2 of the License, or
 
6
# (at your option) any later version.
 
7
#
 
8
# This program is distributed in the hope that it will be useful,
 
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
# GNU General Public License for more details.
 
12
#
 
13
# You should have received a copy of the GNU General Public License
 
14
# along with this program; if not, write to the Free Software
 
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
16
 
 
17
"""BzrDir logic. The BzrDir is the basic control directory used by bzr.
 
18
 
 
19
At format 7 this was split out into Branch, Repository and Checkout control
 
20
directories.
 
21
 
 
22
Note: This module has a lot of ``open`` functions/methods that return
 
23
references to in-memory objects. As a rule, there are no matching ``close``
 
24
methods. To free any associated resources, simply stop referencing the
 
25
objects returned.
 
26
"""
 
27
 
 
28
import sys
 
29
 
 
30
from bzrlib.lazy_import import lazy_import
 
31
lazy_import(globals(), """
 
32
import bzrlib
 
33
from bzrlib import (
 
34
    branch as _mod_branch,
 
35
    cleanup,
 
36
    config,
 
37
    controldir,
 
38
    errors,
 
39
    fetch,
 
40
    graph,
 
41
    lockable_files,
 
42
    lockdir,
 
43
    osutils,
 
44
    pyutils,
 
45
    remote,
 
46
    repository,
 
47
    revision as _mod_revision,
 
48
    transport as _mod_transport,
 
49
    ui,
 
50
    urlutils,
 
51
    win32utils,
 
52
    workingtree,
 
53
    workingtree_4,
 
54
    )
 
55
from bzrlib.repofmt import knitpack_repo
 
56
from bzrlib.transport import (
 
57
    do_catching_redirections,
 
58
    local,
 
59
    )
 
60
""")
 
61
 
 
62
from bzrlib.trace import (
 
63
    mutter,
 
64
    note,
 
65
    )
 
66
 
 
67
from bzrlib import (
 
68
    hooks,
 
69
    registry,
 
70
    )
 
71
from bzrlib.symbol_versioning import (
 
72
    deprecated_in,
 
73
    deprecated_method,
 
74
    )
 
75
 
 
76
 
 
77
class BzrDir(controldir.ControlDir):
 
78
    """A .bzr control diretory.
 
79
 
 
80
    BzrDir instances let you create or open any of the things that can be
 
81
    found within .bzr - checkouts, branches and repositories.
 
82
 
 
83
    :ivar transport:
 
84
        the transport which this bzr dir is rooted at (i.e. file:///.../.bzr/)
 
85
    :ivar root_transport:
 
86
        a transport connected to the directory this bzr was opened from
 
87
        (i.e. the parent directory holding the .bzr directory).
 
88
 
 
89
    Everything in the bzrdir should have the same file permissions.
 
90
 
 
91
    :cvar hooks: An instance of BzrDirHooks.
 
92
    """
 
93
 
 
94
    def break_lock(self):
 
95
        """Invoke break_lock on the first object in the bzrdir.
 
96
 
 
97
        If there is a tree, the tree is opened and break_lock() called.
 
98
        Otherwise, branch is tried, and finally repository.
 
99
        """
 
100
        # XXX: This seems more like a UI function than something that really
 
101
        # belongs in this class.
 
102
        try:
 
103
            thing_to_unlock = self.open_workingtree()
 
104
        except (errors.NotLocalUrl, errors.NoWorkingTree):
 
105
            try:
 
106
                thing_to_unlock = self.open_branch()
 
107
            except errors.NotBranchError:
 
108
                try:
 
109
                    thing_to_unlock = self.open_repository()
 
110
                except errors.NoRepositoryPresent:
 
111
                    return
 
112
        thing_to_unlock.break_lock()
 
113
 
 
114
    def check_conversion_target(self, target_format):
 
115
        """Check that a bzrdir as a whole can be converted to a new format."""
 
116
        # The only current restriction is that the repository content can be 
 
117
        # fetched compatibly with the target.
 
118
        target_repo_format = target_format.repository_format
 
119
        try:
 
120
            self.open_repository()._format.check_conversion_target(
 
121
                target_repo_format)
 
122
        except errors.NoRepositoryPresent:
 
123
            # No repo, no problem.
 
124
            pass
 
125
 
 
126
    def clone_on_transport(self, transport, revision_id=None,
 
127
        force_new_repo=False, preserve_stacking=False, stacked_on=None,
 
128
        create_prefix=False, use_existing_dir=True, no_tree=False):
 
129
        """Clone this bzrdir and its contents to transport verbatim.
 
130
 
 
131
        :param transport: The transport for the location to produce the clone
 
132
            at.  If the target directory does not exist, it will be created.
 
133
        :param revision_id: The tip revision-id to use for any branch or
 
134
            working tree.  If not None, then the clone operation may tune
 
135
            itself to download less data.
 
136
        :param force_new_repo: Do not use a shared repository for the target,
 
137
                               even if one is available.
 
138
        :param preserve_stacking: When cloning a stacked branch, stack the
 
139
            new branch on top of the other branch's stacked-on branch.
 
140
        :param create_prefix: Create any missing directories leading up to
 
141
            to_transport.
 
142
        :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
        """
 
145
        # Overview: put together a broad description of what we want to end up
 
146
        # with; then make as few api calls as possible to do it.
 
147
 
 
148
        # We may want to create a repo/branch/tree, if we do so what format
 
149
        # would we want for each:
 
150
        require_stacking = (stacked_on is not None)
 
151
        format = self.cloning_metadir(require_stacking)
 
152
 
 
153
        # Figure out what objects we want:
 
154
        try:
 
155
            local_repo = self.find_repository()
 
156
        except errors.NoRepositoryPresent:
 
157
            local_repo = None
 
158
        try:
 
159
            local_branch = self.open_branch()
 
160
        except errors.NotBranchError:
 
161
            local_branch = None
 
162
        else:
 
163
            # enable fallbacks when branch is not a branch reference
 
164
            if local_branch.repository.has_same_location(local_repo):
 
165
                local_repo = local_branch.repository
 
166
            if preserve_stacking:
 
167
                try:
 
168
                    stacked_on = local_branch.get_stacked_on_url()
 
169
                except (errors.UnstackableBranchFormat,
 
170
                        errors.UnstackableRepositoryFormat,
 
171
                        errors.NotStacked):
 
172
                    pass
 
173
        # Bug: We create a metadir without knowing if it can support stacking,
 
174
        # we should look up the policy needs first, or just use it as a hint,
 
175
        # or something.
 
176
        if local_repo:
 
177
            make_working_trees = local_repo.make_working_trees() and not no_tree
 
178
            want_shared = local_repo.is_shared()
 
179
            repo_format_name = format.repository_format.network_name()
 
180
        else:
 
181
            make_working_trees = False
 
182
            want_shared = False
 
183
            repo_format_name = None
 
184
 
 
185
        result_repo, result, require_stacking, repository_policy = \
 
186
            format.initialize_on_transport_ex(transport,
 
187
            use_existing_dir=use_existing_dir, create_prefix=create_prefix,
 
188
            force_new_repo=force_new_repo, stacked_on=stacked_on,
 
189
            stack_on_pwd=self.root_transport.base,
 
190
            repo_format_name=repo_format_name,
 
191
            make_working_trees=make_working_trees, shared_repo=want_shared)
 
192
        if repo_format_name:
 
193
            try:
 
194
                # If the result repository is in the same place as the
 
195
                # resulting bzr dir, it will have no content, further if the
 
196
                # result is not stacked then we know all content should be
 
197
                # copied, and finally if we are copying up to a specific
 
198
                # revision_id then we can use the pending-ancestry-result which
 
199
                # does not require traversing all of history to describe it.
 
200
                if (result_repo.user_url == result.user_url
 
201
                    and not require_stacking and
 
202
                    revision_id is not None):
 
203
                    fetch_spec = graph.PendingAncestryResult(
 
204
                        [revision_id], local_repo)
 
205
                    result_repo.fetch(local_repo, fetch_spec=fetch_spec)
 
206
                else:
 
207
                    result_repo.fetch(local_repo, revision_id=revision_id)
 
208
            finally:
 
209
                result_repo.unlock()
 
210
        else:
 
211
            if result_repo is not None:
 
212
                raise AssertionError('result_repo not None(%r)' % result_repo)
 
213
        # 1 if there is a branch present
 
214
        #   make sure its content is available in the target repository
 
215
        #   clone it.
 
216
        if local_branch is not None:
 
217
            result_branch = local_branch.clone(result, revision_id=revision_id,
 
218
                repository_policy=repository_policy)
 
219
        try:
 
220
            # Cheaper to check if the target is not local, than to try making
 
221
            # the tree and fail.
 
222
            result.root_transport.local_abspath('.')
 
223
            if result_repo is None or result_repo.make_working_trees():
 
224
                self.open_workingtree().clone(result)
 
225
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
226
            pass
 
227
        return result
 
228
 
 
229
    # TODO: This should be given a Transport, and should chdir up; otherwise
 
230
    # this will open a new connection.
 
231
    def _make_tail(self, url):
 
232
        t = _mod_transport.get_transport(url)
 
233
        t.ensure_base()
 
234
 
 
235
    @staticmethod
 
236
    def find_bzrdirs(transport, evaluate=None, list_current=None):
 
237
        """Find bzrdirs recursively from current location.
 
238
 
 
239
        This is intended primarily as a building block for more sophisticated
 
240
        functionality, like finding trees under a directory, or finding
 
241
        branches that use a given repository.
 
242
        :param evaluate: An optional callable that yields recurse, value,
 
243
            where recurse controls whether this bzrdir is recursed into
 
244
            and value is the value to yield.  By default, all bzrdirs
 
245
            are recursed into, and the return value is the bzrdir.
 
246
        :param list_current: if supplied, use this function to list the current
 
247
            directory, instead of Transport.list_dir
 
248
        :return: a generator of found bzrdirs, or whatever evaluate returns.
 
249
        """
 
250
        if list_current is None:
 
251
            def list_current(transport):
 
252
                return transport.list_dir('')
 
253
        if evaluate is None:
 
254
            def evaluate(bzrdir):
 
255
                return True, bzrdir
 
256
 
 
257
        pending = [transport]
 
258
        while len(pending) > 0:
 
259
            current_transport = pending.pop()
 
260
            recurse = True
 
261
            try:
 
262
                bzrdir = BzrDir.open_from_transport(current_transport)
 
263
            except (errors.NotBranchError, errors.PermissionDenied):
 
264
                pass
 
265
            else:
 
266
                recurse, value = evaluate(bzrdir)
 
267
                yield value
 
268
            try:
 
269
                subdirs = list_current(current_transport)
 
270
            except (errors.NoSuchFile, errors.PermissionDenied):
 
271
                continue
 
272
            if recurse:
 
273
                for subdir in sorted(subdirs, reverse=True):
 
274
                    pending.append(current_transport.clone(subdir))
 
275
 
 
276
    @staticmethod
 
277
    def find_branches(transport):
 
278
        """Find all branches under a transport.
 
279
 
 
280
        This will find all branches below the transport, including branches
 
281
        inside other branches.  Where possible, it will use
 
282
        Repository.find_branches.
 
283
 
 
284
        To list all the branches that use a particular Repository, see
 
285
        Repository.find_branches
 
286
        """
 
287
        def evaluate(bzrdir):
 
288
            try:
 
289
                repository = bzrdir.open_repository()
 
290
            except errors.NoRepositoryPresent:
 
291
                pass
 
292
            else:
 
293
                return False, ([], repository)
 
294
            return True, (bzrdir.list_branches(), None)
 
295
        ret = []
 
296
        for branches, repo in BzrDir.find_bzrdirs(transport,
 
297
                                                  evaluate=evaluate):
 
298
            if repo is not None:
 
299
                ret.extend(repo.find_branches())
 
300
            if branches is not None:
 
301
                ret.extend(branches)
 
302
        return ret
 
303
 
 
304
    @staticmethod
 
305
    def create_branch_and_repo(base, force_new_repo=False, format=None):
 
306
        """Create a new BzrDir, Branch and Repository at the url 'base'.
 
307
 
 
308
        This will use the current default BzrDirFormat unless one is
 
309
        specified, and use whatever
 
310
        repository format that that uses via bzrdir.create_branch and
 
311
        create_repository. If a shared repository is available that is used
 
312
        preferentially.
 
313
 
 
314
        The created Branch object is returned.
 
315
 
 
316
        :param base: The URL to create the branch at.
 
317
        :param force_new_repo: If True a new repository is always created.
 
318
        :param format: If supplied, the format of branch to create.  If not
 
319
            supplied, the default is used.
 
320
        """
 
321
        bzrdir = BzrDir.create(base, format)
 
322
        bzrdir._find_or_create_repository(force_new_repo)
 
323
        return bzrdir.create_branch()
 
324
 
 
325
    def determine_repository_policy(self, force_new_repo=False, stack_on=None,
 
326
                                    stack_on_pwd=None, require_stacking=False):
 
327
        """Return an object representing a policy to use.
 
328
 
 
329
        This controls whether a new repository is created, and the format of
 
330
        that repository, or some existing shared repository used instead.
 
331
 
 
332
        If stack_on is supplied, will not seek a containing shared repo.
 
333
 
 
334
        :param force_new_repo: If True, require a new repository to be created.
 
335
        :param stack_on: If supplied, the location to stack on.  If not
 
336
            supplied, a default_stack_on location may be used.
 
337
        :param stack_on_pwd: If stack_on is relative, the location it is
 
338
            relative to.
 
339
        """
 
340
        def repository_policy(found_bzrdir):
 
341
            stack_on = None
 
342
            stack_on_pwd = None
 
343
            config = found_bzrdir.get_config()
 
344
            stop = False
 
345
            stack_on = config.get_default_stack_on()
 
346
            if stack_on is not None:
 
347
                stack_on_pwd = found_bzrdir.user_url
 
348
                stop = True
 
349
            # does it have a repository ?
 
350
            try:
 
351
                repository = found_bzrdir.open_repository()
 
352
            except errors.NoRepositoryPresent:
 
353
                repository = None
 
354
            else:
 
355
                if (found_bzrdir.user_url != self.user_url 
 
356
                    and not repository.is_shared()):
 
357
                    # Don't look higher, can't use a higher shared repo.
 
358
                    repository = None
 
359
                    stop = True
 
360
                else:
 
361
                    stop = True
 
362
            if not stop:
 
363
                return None, False
 
364
            if repository:
 
365
                return UseExistingRepository(repository, stack_on,
 
366
                    stack_on_pwd, require_stacking=require_stacking), True
 
367
            else:
 
368
                return CreateRepository(self, stack_on, stack_on_pwd,
 
369
                    require_stacking=require_stacking), True
 
370
 
 
371
        if not force_new_repo:
 
372
            if stack_on is None:
 
373
                policy = self._find_containing(repository_policy)
 
374
                if policy is not None:
 
375
                    return policy
 
376
            else:
 
377
                try:
 
378
                    return UseExistingRepository(self.open_repository(),
 
379
                        stack_on, stack_on_pwd,
 
380
                        require_stacking=require_stacking)
 
381
                except errors.NoRepositoryPresent:
 
382
                    pass
 
383
        return CreateRepository(self, stack_on, stack_on_pwd,
 
384
                                require_stacking=require_stacking)
 
385
 
 
386
    def _find_or_create_repository(self, force_new_repo):
 
387
        """Create a new repository if needed, returning the repository."""
 
388
        policy = self.determine_repository_policy(force_new_repo)
 
389
        return policy.acquire_repository()[0]
 
390
 
 
391
    def _find_source_repo(self, add_cleanup, source_branch):
 
392
        """Find the source branch and repo for a sprout operation.
 
393
        
 
394
        This is helper intended for use by _sprout.
 
395
 
 
396
        :returns: (source_branch, source_repository).  Either or both may be
 
397
            None.  If not None, they will be read-locked (and their unlock(s)
 
398
            scheduled via the add_cleanup param).
 
399
        """
 
400
        if source_branch is not None:
 
401
            add_cleanup(source_branch.lock_read().unlock)
 
402
            return source_branch, source_branch.repository
 
403
        try:
 
404
            source_branch = self.open_branch()
 
405
            source_repository = source_branch.repository
 
406
        except errors.NotBranchError:
 
407
            source_branch = None
 
408
            try:
 
409
                source_repository = self.open_repository()
 
410
            except errors.NoRepositoryPresent:
 
411
                source_repository = None
 
412
            else:
 
413
                add_cleanup(source_repository.lock_read().unlock)
 
414
        else:
 
415
            add_cleanup(source_branch.lock_read().unlock)
 
416
        return source_branch, source_repository
 
417
 
 
418
    def sprout(self, url, revision_id=None, force_new_repo=False,
 
419
               recurse='down', possible_transports=None,
 
420
               accelerator_tree=None, hardlink=False, stacked=False,
 
421
               source_branch=None, create_tree_if_local=True):
 
422
        """Create a copy of this controldir prepared for use as a new line of
 
423
        development.
 
424
 
 
425
        If url's last component does not exist, it will be created.
 
426
 
 
427
        Attributes related to the identity of the source branch like
 
428
        branch nickname will be cleaned, a working tree is created
 
429
        whether one existed before or not; and a local branch is always
 
430
        created.
 
431
 
 
432
        if revision_id is not None, then the clone operation may tune
 
433
            itself to download less data.
 
434
        :param accelerator_tree: A tree which can be used for retrieving file
 
435
            contents more quickly than the revision tree, i.e. a workingtree.
 
436
            The revision tree will be used for cases where accelerator_tree's
 
437
            content is different.
 
438
        :param hardlink: If true, hard-link files from accelerator_tree,
 
439
            where possible.
 
440
        :param stacked: If true, create a stacked branch referring to the
 
441
            location of this control directory.
 
442
        :param create_tree_if_local: If true, a working-tree will be created
 
443
            when working locally.
 
444
        """
 
445
        operation = cleanup.OperationWithCleanups(self._sprout)
 
446
        return operation.run(url, revision_id=revision_id,
 
447
            force_new_repo=force_new_repo, recurse=recurse,
 
448
            possible_transports=possible_transports,
 
449
            accelerator_tree=accelerator_tree, hardlink=hardlink,
 
450
            stacked=stacked, source_branch=source_branch,
 
451
            create_tree_if_local=create_tree_if_local)
 
452
 
 
453
    def _sprout(self, op, url, revision_id=None, force_new_repo=False,
 
454
               recurse='down', possible_transports=None,
 
455
               accelerator_tree=None, hardlink=False, stacked=False,
 
456
               source_branch=None, create_tree_if_local=True):
 
457
        add_cleanup = op.add_cleanup
 
458
        fetch_spec_factory = fetch.FetchSpecFactory()
 
459
        if revision_id is not None:
 
460
            fetch_spec_factory.add_revision_ids([revision_id])
 
461
            fetch_spec_factory.source_branch_stop_revision_id = revision_id
 
462
        target_transport = _mod_transport.get_transport(url,
 
463
            possible_transports)
 
464
        target_transport.ensure_base()
 
465
        cloning_format = self.cloning_metadir(stacked)
 
466
        # Create/update the result branch
 
467
        result = cloning_format.initialize_on_transport(target_transport)
 
468
        source_branch, source_repository = self._find_source_repo(
 
469
            add_cleanup, source_branch)
 
470
        fetch_spec_factory.source_branch = source_branch
 
471
        # if a stacked branch wasn't requested, we don't create one
 
472
        # even if the origin was stacked
 
473
        if stacked and source_branch is not None:
 
474
            stacked_branch_url = self.root_transport.base
 
475
        else:
 
476
            stacked_branch_url = None
 
477
        repository_policy = result.determine_repository_policy(
 
478
            force_new_repo, stacked_branch_url, require_stacking=stacked)
 
479
        result_repo, is_new_repo = repository_policy.acquire_repository()
 
480
        add_cleanup(result_repo.lock_write().unlock)
 
481
        fetch_spec_factory.source_repo = source_repository
 
482
        fetch_spec_factory.target_repo = result_repo
 
483
        if stacked or (len(result_repo._fallback_repositories) != 0):
 
484
            target_repo_kind = fetch.TargetRepoKinds.STACKED
 
485
        elif is_new_repo:
 
486
            target_repo_kind = fetch.TargetRepoKinds.EMPTY
 
487
        else:
 
488
            target_repo_kind = fetch.TargetRepoKinds.PREEXISTING
 
489
        fetch_spec_factory.target_repo_kind = target_repo_kind
 
490
        if source_repository is not None:
 
491
            fetch_spec = fetch_spec_factory.make_fetch_spec()
 
492
            result_repo.fetch(source_repository, fetch_spec=fetch_spec)
 
493
 
 
494
        if source_branch is None:
 
495
            # this is for sprouting a controldir without a branch; is that
 
496
            # actually useful?
 
497
            # Not especially, but it's part of the contract.
 
498
            result_branch = result.create_branch()
 
499
        else:
 
500
            result_branch = source_branch.sprout(result,
 
501
                revision_id=revision_id, repository_policy=repository_policy,
 
502
                repository=result_repo)
 
503
        mutter("created new branch %r" % (result_branch,))
 
504
 
 
505
        # Create/update the result working tree
 
506
        if (create_tree_if_local and
 
507
            isinstance(target_transport, local.LocalTransport) and
 
508
            (result_repo is None or result_repo.make_working_trees())):
 
509
            wt = result.create_workingtree(accelerator_tree=accelerator_tree,
 
510
                hardlink=hardlink, from_branch=result_branch)
 
511
            wt.lock_write()
 
512
            try:
 
513
                if wt.path2id('') is None:
 
514
                    try:
 
515
                        wt.set_root_id(self.open_workingtree.get_root_id())
 
516
                    except errors.NoWorkingTree:
 
517
                        pass
 
518
            finally:
 
519
                wt.unlock()
 
520
        else:
 
521
            wt = None
 
522
        if recurse == 'down':
 
523
            basis = None
 
524
            if wt is not None:
 
525
                basis = wt.basis_tree()
 
526
            elif result_branch is not None:
 
527
                basis = result_branch.basis_tree()
 
528
            elif source_branch is not None:
 
529
                basis = source_branch.basis_tree()
 
530
            if basis is not None:
 
531
                add_cleanup(basis.lock_read().unlock)
 
532
                subtrees = basis.iter_references()
 
533
            else:
 
534
                subtrees = []
 
535
            for path, file_id in subtrees:
 
536
                target = urlutils.join(url, urlutils.escape(path))
 
537
                sublocation = source_branch.reference_parent(file_id, path)
 
538
                sublocation.bzrdir.sprout(target,
 
539
                    basis.get_reference_revision(file_id, path),
 
540
                    force_new_repo=force_new_repo, recurse=recurse,
 
541
                    stacked=stacked)
 
542
        return result
 
543
 
 
544
 
 
545
 
 
546
    @staticmethod
 
547
    def create_branch_convenience(base, force_new_repo=False,
 
548
                                  force_new_tree=None, format=None,
 
549
                                  possible_transports=None):
 
550
        """Create a new BzrDir, Branch and Repository at the url 'base'.
 
551
 
 
552
        This is a convenience function - it will use an existing repository
 
553
        if possible, can be told explicitly whether to create a working tree or
 
554
        not.
 
555
 
 
556
        This will use the current default BzrDirFormat unless one is
 
557
        specified, and use whatever
 
558
        repository format that that uses via bzrdir.create_branch and
 
559
        create_repository. If a shared repository is available that is used
 
560
        preferentially. Whatever repository is used, its tree creation policy
 
561
        is followed.
 
562
 
 
563
        The created Branch object is returned.
 
564
        If a working tree cannot be made due to base not being a file:// url,
 
565
        no error is raised unless force_new_tree is True, in which case no
 
566
        data is created on disk and NotLocalUrl is raised.
 
567
 
 
568
        :param base: The URL to create the branch at.
 
569
        :param force_new_repo: If True a new repository is always created.
 
570
        :param force_new_tree: If True or False force creation of a tree or
 
571
                               prevent such creation respectively.
 
572
        :param format: Override for the bzrdir format to create.
 
573
        :param possible_transports: An optional reusable transports list.
 
574
        """
 
575
        if force_new_tree:
 
576
            # check for non local urls
 
577
            t = _mod_transport.get_transport(base, possible_transports)
 
578
            if not isinstance(t, local.LocalTransport):
 
579
                raise errors.NotLocalUrl(base)
 
580
        bzrdir = BzrDir.create(base, format, possible_transports)
 
581
        repo = bzrdir._find_or_create_repository(force_new_repo)
 
582
        result = bzrdir.create_branch()
 
583
        if force_new_tree or (repo.make_working_trees() and
 
584
                              force_new_tree is None):
 
585
            try:
 
586
                bzrdir.create_workingtree()
 
587
            except errors.NotLocalUrl:
 
588
                pass
 
589
        return result
 
590
 
 
591
    @staticmethod
 
592
    def create_standalone_workingtree(base, format=None):
 
593
        """Create a new BzrDir, WorkingTree, Branch and Repository at 'base'.
 
594
 
 
595
        'base' must be a local path or a file:// url.
 
596
 
 
597
        This will use the current default BzrDirFormat unless one is
 
598
        specified, and use whatever
 
599
        repository format that that uses for bzrdirformat.create_workingtree,
 
600
        create_branch and create_repository.
 
601
 
 
602
        :param format: Override for the bzrdir format to create.
 
603
        :return: The WorkingTree object.
 
604
        """
 
605
        t = _mod_transport.get_transport(base)
 
606
        if not isinstance(t, local.LocalTransport):
 
607
            raise errors.NotLocalUrl(base)
 
608
        bzrdir = BzrDir.create_branch_and_repo(base,
 
609
                                               force_new_repo=True,
 
610
                                               format=format).bzrdir
 
611
        return bzrdir.create_workingtree()
 
612
 
 
613
    @deprecated_method(deprecated_in((2, 3, 0)))
 
614
    def generate_backup_name(self, base):
 
615
        return self._available_backup_name(base)
 
616
 
 
617
    def _available_backup_name(self, base):
 
618
        """Find a non-existing backup file name based on base.
 
619
 
 
620
        See bzrlib.osutils.available_backup_name about race conditions.
 
621
        """
 
622
        return osutils.available_backup_name(base, self.root_transport.has)
 
623
 
 
624
    def backup_bzrdir(self):
 
625
        """Backup this bzr control directory.
 
626
 
 
627
        :return: Tuple with old path name and new path name
 
628
        """
 
629
 
 
630
        pb = ui.ui_factory.nested_progress_bar()
 
631
        try:
 
632
            old_path = self.root_transport.abspath('.bzr')
 
633
            backup_dir = self._available_backup_name('backup.bzr')
 
634
            new_path = self.root_transport.abspath(backup_dir)
 
635
            ui.ui_factory.note('making backup of %s\n  to %s'
 
636
                               % (old_path, new_path,))
 
637
            self.root_transport.copy_tree('.bzr', backup_dir)
 
638
            return (old_path, new_path)
 
639
        finally:
 
640
            pb.finished()
 
641
 
 
642
    def retire_bzrdir(self, limit=10000):
 
643
        """Permanently disable the bzrdir.
 
644
 
 
645
        This is done by renaming it to give the user some ability to recover
 
646
        if there was a problem.
 
647
 
 
648
        This will have horrible consequences if anyone has anything locked or
 
649
        in use.
 
650
        :param limit: number of times to retry
 
651
        """
 
652
        i  = 0
 
653
        while True:
 
654
            try:
 
655
                to_path = '.bzr.retired.%d' % i
 
656
                self.root_transport.rename('.bzr', to_path)
 
657
                note("renamed %s to %s"
 
658
                    % (self.root_transport.abspath('.bzr'), to_path))
 
659
                return
 
660
            except (errors.TransportError, IOError, errors.PathError):
 
661
                i += 1
 
662
                if i > limit:
 
663
                    raise
 
664
                else:
 
665
                    pass
 
666
 
 
667
    def _find_containing(self, evaluate):
 
668
        """Find something in a containing control directory.
 
669
 
 
670
        This method will scan containing control dirs, until it finds what
 
671
        it is looking for, decides that it will never find it, or runs out
 
672
        of containing control directories to check.
 
673
 
 
674
        It is used to implement find_repository and
 
675
        determine_repository_policy.
 
676
 
 
677
        :param evaluate: A function returning (value, stop).  If stop is True,
 
678
            the value will be returned.
 
679
        """
 
680
        found_bzrdir = self
 
681
        while True:
 
682
            result, stop = evaluate(found_bzrdir)
 
683
            if stop:
 
684
                return result
 
685
            next_transport = found_bzrdir.root_transport.clone('..')
 
686
            if (found_bzrdir.user_url == next_transport.base):
 
687
                # top of the file system
 
688
                return None
 
689
            # find the next containing bzrdir
 
690
            try:
 
691
                found_bzrdir = BzrDir.open_containing_from_transport(
 
692
                    next_transport)[0]
 
693
            except errors.NotBranchError:
 
694
                return None
 
695
 
 
696
    def find_repository(self):
 
697
        """Find the repository that should be used.
 
698
 
 
699
        This does not require a branch as we use it to find the repo for
 
700
        new branches as well as to hook existing branches up to their
 
701
        repository.
 
702
        """
 
703
        def usable_repository(found_bzrdir):
 
704
            # does it have a repository ?
 
705
            try:
 
706
                repository = found_bzrdir.open_repository()
 
707
            except errors.NoRepositoryPresent:
 
708
                return None, False
 
709
            if found_bzrdir.user_url == self.user_url:
 
710
                return repository, True
 
711
            elif repository.is_shared():
 
712
                return repository, True
 
713
            else:
 
714
                return None, True
 
715
 
 
716
        found_repo = self._find_containing(usable_repository)
 
717
        if found_repo is None:
 
718
            raise errors.NoRepositoryPresent(self)
 
719
        return found_repo
 
720
 
 
721
    def _find_creation_modes(self):
 
722
        """Determine the appropriate modes for files and directories.
 
723
 
 
724
        They're always set to be consistent with the base directory,
 
725
        assuming that this transport allows setting modes.
 
726
        """
 
727
        # TODO: Do we need or want an option (maybe a config setting) to turn
 
728
        # this off or override it for particular locations? -- mbp 20080512
 
729
        if self._mode_check_done:
 
730
            return
 
731
        self._mode_check_done = True
 
732
        try:
 
733
            st = self.transport.stat('.')
 
734
        except errors.TransportNotPossible:
 
735
            self._dir_mode = None
 
736
            self._file_mode = None
 
737
        else:
 
738
            # Check the directory mode, but also make sure the created
 
739
            # directories and files are read-write for this user. This is
 
740
            # mostly a workaround for filesystems which lie about being able to
 
741
            # write to a directory (cygwin & win32)
 
742
            if (st.st_mode & 07777 == 00000):
 
743
                # FTP allows stat but does not return dir/file modes
 
744
                self._dir_mode = None
 
745
                self._file_mode = None
 
746
            else:
 
747
                self._dir_mode = (st.st_mode & 07777) | 00700
 
748
                # Remove the sticky and execute bits for files
 
749
                self._file_mode = self._dir_mode & ~07111
 
750
 
 
751
    def _get_file_mode(self):
 
752
        """Return Unix mode for newly created files, or None.
 
753
        """
 
754
        if not self._mode_check_done:
 
755
            self._find_creation_modes()
 
756
        return self._file_mode
 
757
 
 
758
    def _get_dir_mode(self):
 
759
        """Return Unix mode for newly created directories, or None.
 
760
        """
 
761
        if not self._mode_check_done:
 
762
            self._find_creation_modes()
 
763
        return self._dir_mode
 
764
 
 
765
    def get_config(self):
 
766
        """Get configuration for this BzrDir."""
 
767
        return config.BzrDirConfig(self)
 
768
 
 
769
    def _get_config(self):
 
770
        """By default, no configuration is available."""
 
771
        return None
 
772
 
 
773
    def __init__(self, _transport, _format):
 
774
        """Initialize a Bzr control dir object.
 
775
 
 
776
        Only really common logic should reside here, concrete classes should be
 
777
        made with varying behaviours.
 
778
 
 
779
        :param _format: the format that is creating this BzrDir instance.
 
780
        :param _transport: the transport this dir is based at.
 
781
        """
 
782
        self._format = _format
 
783
        # these are also under the more standard names of 
 
784
        # control_transport and user_transport
 
785
        self.transport = _transport.clone('.bzr')
 
786
        self.root_transport = _transport
 
787
        self._mode_check_done = False
 
788
 
 
789
    @property 
 
790
    def user_transport(self):
 
791
        return self.root_transport
 
792
 
 
793
    @property
 
794
    def control_transport(self):
 
795
        return self.transport
 
796
 
 
797
    def is_control_filename(self, filename):
 
798
        """True if filename is the name of a path which is reserved for bzrdir's.
 
799
 
 
800
        :param filename: A filename within the root transport of this bzrdir.
 
801
 
 
802
        This is true IF and ONLY IF the filename is part of the namespace reserved
 
803
        for bzr control dirs. Currently this is the '.bzr' directory in the root
 
804
        of the root_transport. 
 
805
        """
 
806
        # this might be better on the BzrDirFormat class because it refers to
 
807
        # all the possible bzrdir disk formats.
 
808
        # This method is tested via the workingtree is_control_filename tests-
 
809
        # it was extracted from WorkingTree.is_control_filename. If the method's
 
810
        # contract is extended beyond the current trivial implementation, please
 
811
        # add new tests for it to the appropriate place.
 
812
        return filename == '.bzr' or filename.startswith('.bzr/')
 
813
 
 
814
    @staticmethod
 
815
    def open_unsupported(base):
 
816
        """Open a branch which is not supported."""
 
817
        return BzrDir.open(base, _unsupported=True)
 
818
 
 
819
    @staticmethod
 
820
    def open(base, _unsupported=False, possible_transports=None):
 
821
        """Open an existing bzrdir, rooted at 'base' (url).
 
822
 
 
823
        :param _unsupported: a private parameter to the BzrDir class.
 
824
        """
 
825
        t = _mod_transport.get_transport(base, possible_transports)
 
826
        return BzrDir.open_from_transport(t, _unsupported=_unsupported)
 
827
 
 
828
    @staticmethod
 
829
    def open_from_transport(transport, _unsupported=False,
 
830
                            _server_formats=True):
 
831
        """Open a bzrdir within a particular directory.
 
832
 
 
833
        :param transport: Transport containing the bzrdir.
 
834
        :param _unsupported: private.
 
835
        """
 
836
        for hook in BzrDir.hooks['pre_open']:
 
837
            hook(transport)
 
838
        # Keep initial base since 'transport' may be modified while following
 
839
        # the redirections.
 
840
        base = transport.base
 
841
        def find_format(transport):
 
842
            return transport, controldir.ControlDirFormat.find_format(
 
843
                transport, _server_formats=_server_formats)
 
844
 
 
845
        def redirected(transport, e, redirection_notice):
 
846
            redirected_transport = transport._redirected_to(e.source, e.target)
 
847
            if redirected_transport is None:
 
848
                raise errors.NotBranchError(base)
 
849
            note('%s is%s redirected to %s',
 
850
                 transport.base, e.permanently, redirected_transport.base)
 
851
            return redirected_transport
 
852
 
 
853
        try:
 
854
            transport, format = do_catching_redirections(find_format,
 
855
                                                         transport,
 
856
                                                         redirected)
 
857
        except errors.TooManyRedirections:
 
858
            raise errors.NotBranchError(base)
 
859
 
 
860
        format.check_support_status(_unsupported)
 
861
        return format.open(transport, _found=True)
 
862
 
 
863
    @staticmethod
 
864
    def open_containing(url, possible_transports=None):
 
865
        """Open an existing branch which contains url.
 
866
 
 
867
        :param url: url to search from.
 
868
        See open_containing_from_transport for more detail.
 
869
        """
 
870
        transport = _mod_transport.get_transport(url, possible_transports)
 
871
        return BzrDir.open_containing_from_transport(transport)
 
872
 
 
873
    @staticmethod
 
874
    def open_containing_from_transport(a_transport):
 
875
        """Open an existing branch which contains a_transport.base.
 
876
 
 
877
        This probes for a branch at a_transport, and searches upwards from there.
 
878
 
 
879
        Basically we keep looking up until we find the control directory or
 
880
        run into the root.  If there isn't one, raises NotBranchError.
 
881
        If there is one and it is either an unrecognised format or an unsupported
 
882
        format, UnknownFormatError or UnsupportedFormatError are raised.
 
883
        If there is one, it is returned, along with the unused portion of url.
 
884
 
 
885
        :return: The BzrDir that contains the path, and a Unicode path
 
886
                for the rest of the URL.
 
887
        """
 
888
        # this gets the normalised url back. I.e. '.' -> the full path.
 
889
        url = a_transport.base
 
890
        while True:
 
891
            try:
 
892
                result = BzrDir.open_from_transport(a_transport)
 
893
                return result, urlutils.unescape(a_transport.relpath(url))
 
894
            except errors.NotBranchError, e:
 
895
                pass
 
896
            try:
 
897
                new_t = a_transport.clone('..')
 
898
            except errors.InvalidURLJoin:
 
899
                # reached the root, whatever that may be
 
900
                raise errors.NotBranchError(path=url)
 
901
            if new_t.base == a_transport.base:
 
902
                # reached the root, whatever that may be
 
903
                raise errors.NotBranchError(path=url)
 
904
            a_transport = new_t
 
905
 
 
906
    @classmethod
 
907
    def open_tree_or_branch(klass, location):
 
908
        """Return the branch and working tree at a location.
 
909
 
 
910
        If there is no tree at the location, tree will be None.
 
911
        If there is no branch at the location, an exception will be
 
912
        raised
 
913
        :return: (tree, branch)
 
914
        """
 
915
        bzrdir = klass.open(location)
 
916
        return bzrdir._get_tree_branch()
 
917
 
 
918
    @classmethod
 
919
    def open_containing_tree_or_branch(klass, location):
 
920
        """Return the branch and working tree contained by a location.
 
921
 
 
922
        Returns (tree, branch, relpath).
 
923
        If there is no tree at containing the location, tree will be None.
 
924
        If there is no branch containing the location, an exception will be
 
925
        raised
 
926
        relpath is the portion of the path that is contained by the branch.
 
927
        """
 
928
        bzrdir, relpath = klass.open_containing(location)
 
929
        tree, branch = bzrdir._get_tree_branch()
 
930
        return tree, branch, relpath
 
931
 
 
932
    @classmethod
 
933
    def open_containing_tree_branch_or_repository(klass, location):
 
934
        """Return the working tree, branch and repo contained by a location.
 
935
 
 
936
        Returns (tree, branch, repository, relpath).
 
937
        If there is no tree containing the location, tree will be None.
 
938
        If there is no branch containing the location, branch will be None.
 
939
        If there is no repository containing the location, repository will be
 
940
        None.
 
941
        relpath is the portion of the path that is contained by the innermost
 
942
        BzrDir.
 
943
 
 
944
        If no tree, branch or repository is found, a NotBranchError is raised.
 
945
        """
 
946
        bzrdir, relpath = klass.open_containing(location)
 
947
        try:
 
948
            tree, branch = bzrdir._get_tree_branch()
 
949
        except errors.NotBranchError:
 
950
            try:
 
951
                repo = bzrdir.find_repository()
 
952
                return None, None, repo, relpath
 
953
            except (errors.NoRepositoryPresent):
 
954
                raise errors.NotBranchError(location)
 
955
        return tree, branch, branch.repository, relpath
 
956
 
 
957
    def _cloning_metadir(self):
 
958
        """Produce a metadir suitable for cloning with.
 
959
 
 
960
        :returns: (destination_bzrdir_format, source_repository)
 
961
        """
 
962
        result_format = self._format.__class__()
 
963
        try:
 
964
            try:
 
965
                branch = self.open_branch(ignore_fallbacks=True)
 
966
                source_repository = branch.repository
 
967
                result_format._branch_format = branch._format
 
968
            except errors.NotBranchError:
 
969
                source_branch = None
 
970
                source_repository = self.open_repository()
 
971
        except errors.NoRepositoryPresent:
 
972
            source_repository = None
 
973
        else:
 
974
            # XXX TODO: This isinstance is here because we have not implemented
 
975
            # the fix recommended in bug # 103195 - to delegate this choice the
 
976
            # repository itself.
 
977
            repo_format = source_repository._format
 
978
            if isinstance(repo_format, remote.RemoteRepositoryFormat):
 
979
                source_repository._ensure_real()
 
980
                repo_format = source_repository._real_repository._format
 
981
            result_format.repository_format = repo_format
 
982
        try:
 
983
            # TODO: Couldn't we just probe for the format in these cases,
 
984
            # rather than opening the whole tree?  It would be a little
 
985
            # faster. mbp 20070401
 
986
            tree = self.open_workingtree(recommend_upgrade=False)
 
987
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
988
            result_format.workingtree_format = None
 
989
        else:
 
990
            result_format.workingtree_format = tree._format.__class__()
 
991
        return result_format, source_repository
 
992
 
 
993
    def cloning_metadir(self, require_stacking=False):
 
994
        """Produce a metadir suitable for cloning or sprouting with.
 
995
 
 
996
        These operations may produce workingtrees (yes, even though they're
 
997
        "cloning" something that doesn't have a tree), so a viable workingtree
 
998
        format must be selected.
 
999
 
 
1000
        :require_stacking: If True, non-stackable formats will be upgraded
 
1001
            to similar stackable formats.
 
1002
        :returns: a BzrDirFormat with all component formats either set
 
1003
            appropriately or set to None if that component should not be
 
1004
            created.
 
1005
        """
 
1006
        format, repository = self._cloning_metadir()
 
1007
        if format._workingtree_format is None:
 
1008
            # No tree in self.
 
1009
            if repository is None:
 
1010
                # No repository either
 
1011
                return format
 
1012
            # We have a repository, so set a working tree? (Why? This seems to
 
1013
            # contradict the stated return value in the docstring).
 
1014
            tree_format = repository._format._matchingbzrdir.workingtree_format
 
1015
            format.workingtree_format = tree_format.__class__()
 
1016
        if require_stacking:
 
1017
            format.require_stacking()
 
1018
        return format
 
1019
 
 
1020
    @classmethod
 
1021
    def create(cls, base, format=None, possible_transports=None):
 
1022
        """Create a new BzrDir at the url 'base'.
 
1023
 
 
1024
        :param format: If supplied, the format of branch to create.  If not
 
1025
            supplied, the default is used.
 
1026
        :param possible_transports: If supplied, a list of transports that
 
1027
            can be reused to share a remote connection.
 
1028
        """
 
1029
        if cls is not BzrDir:
 
1030
            raise AssertionError("BzrDir.create always creates the"
 
1031
                "default format, not one of %r" % cls)
 
1032
        t = _mod_transport.get_transport(base, possible_transports)
 
1033
        t.ensure_base()
 
1034
        if format is None:
 
1035
            format = controldir.ControlDirFormat.get_default_format()
 
1036
        return format.initialize_on_transport(t)
 
1037
 
 
1038
    def get_branch_transport(self, branch_format, name=None):
 
1039
        """Get the transport for use by branch format in this BzrDir.
 
1040
 
 
1041
        Note that bzr dirs that do not support format strings will raise
 
1042
        IncompatibleFormat if the branch format they are given has
 
1043
        a format string, and vice versa.
 
1044
 
 
1045
        If branch_format is None, the transport is returned with no
 
1046
        checking. If it is not None, then the returned transport is
 
1047
        guaranteed to point to an existing directory ready for use.
 
1048
        """
 
1049
        raise NotImplementedError(self.get_branch_transport)
 
1050
 
 
1051
    def get_repository_transport(self, repository_format):
 
1052
        """Get the transport for use by repository format in this BzrDir.
 
1053
 
 
1054
        Note that bzr dirs that do not support format strings will raise
 
1055
        IncompatibleFormat if the repository format they are given has
 
1056
        a format string, and vice versa.
 
1057
 
 
1058
        If repository_format is None, the transport is returned with no
 
1059
        checking. If it is not None, then the returned transport is
 
1060
        guaranteed to point to an existing directory ready for use.
 
1061
        """
 
1062
        raise NotImplementedError(self.get_repository_transport)
 
1063
 
 
1064
    def get_workingtree_transport(self, tree_format):
 
1065
        """Get the transport for use by workingtree format in this BzrDir.
 
1066
 
 
1067
        Note that bzr dirs that do not support format strings will raise
 
1068
        IncompatibleFormat if the workingtree format they are given has a
 
1069
        format string, and vice versa.
 
1070
 
 
1071
        If workingtree_format is None, the transport is returned with no
 
1072
        checking. If it is not None, then the returned transport is
 
1073
        guaranteed to point to an existing directory ready for use.
 
1074
        """
 
1075
        raise NotImplementedError(self.get_workingtree_transport)
 
1076
 
 
1077
 
 
1078
class BzrDirHooks(hooks.Hooks):
 
1079
    """Hooks for BzrDir operations."""
 
1080
 
 
1081
    def __init__(self):
 
1082
        """Create the default hooks."""
 
1083
        hooks.Hooks.__init__(self, "bzrlib.bzrdir", "BzrDir.hooks")
 
1084
        self.add_hook('pre_open',
 
1085
            "Invoked before attempting to open a BzrDir with the transport "
 
1086
            "that the open will use.", (1, 14))
 
1087
        self.add_hook('post_repo_init',
 
1088
            "Invoked after a repository has been initialized. "
 
1089
            "post_repo_init is called with a "
 
1090
            "bzrlib.bzrdir.RepoInitHookParams.",
 
1091
            (2, 2))
 
1092
 
 
1093
# install the default hooks
 
1094
BzrDir.hooks = BzrDirHooks()
 
1095
 
 
1096
 
 
1097
class RepoInitHookParams(object):
 
1098
    """Object holding parameters passed to *_repo_init hooks.
 
1099
 
 
1100
    There are 4 fields that hooks may wish to access:
 
1101
 
 
1102
    :ivar repository: Repository created
 
1103
    :ivar format: Repository format
 
1104
    :ivar bzrdir: The bzrdir for the repository
 
1105
    :ivar shared: The repository is shared
 
1106
    """
 
1107
 
 
1108
    def __init__(self, repository, format, a_bzrdir, shared):
 
1109
        """Create a group of RepoInitHook parameters.
 
1110
 
 
1111
        :param repository: Repository created
 
1112
        :param format: Repository format
 
1113
        :param bzrdir: The bzrdir for the repository
 
1114
        :param shared: The repository is shared
 
1115
        """
 
1116
        self.repository = repository
 
1117
        self.format = format
 
1118
        self.bzrdir = a_bzrdir
 
1119
        self.shared = shared
 
1120
 
 
1121
    def __eq__(self, other):
 
1122
        return self.__dict__ == other.__dict__
 
1123
 
 
1124
    def __repr__(self):
 
1125
        if self.repository:
 
1126
            return "<%s for %s>" % (self.__class__.__name__,
 
1127
                self.repository)
 
1128
        else:
 
1129
            return "<%s for %s>" % (self.__class__.__name__,
 
1130
                self.bzrdir)
 
1131
 
 
1132
 
 
1133
class BzrDirMeta1(BzrDir):
 
1134
    """A .bzr meta version 1 control object.
 
1135
 
 
1136
    This is the first control object where the
 
1137
    individual aspects are really split out: there are separate repository,
 
1138
    workingtree and branch subdirectories and any subset of the three can be
 
1139
    present within a BzrDir.
 
1140
    """
 
1141
 
 
1142
    def can_convert_format(self):
 
1143
        """See BzrDir.can_convert_format()."""
 
1144
        return True
 
1145
 
 
1146
    def create_branch(self, name=None, repository=None):
 
1147
        """See BzrDir.create_branch."""
 
1148
        return self._format.get_branch_format().initialize(self, name=name,
 
1149
                repository=repository)
 
1150
 
 
1151
    def destroy_branch(self, name=None):
 
1152
        """See BzrDir.create_branch."""
 
1153
        if name is not None:
 
1154
            raise errors.NoColocatedBranchSupport(self)
 
1155
        self.transport.delete_tree('branch')
 
1156
 
 
1157
    def create_repository(self, shared=False):
 
1158
        """See BzrDir.create_repository."""
 
1159
        return self._format.repository_format.initialize(self, shared)
 
1160
 
 
1161
    def destroy_repository(self):
 
1162
        """See BzrDir.destroy_repository."""
 
1163
        self.transport.delete_tree('repository')
 
1164
 
 
1165
    def create_workingtree(self, revision_id=None, from_branch=None,
 
1166
                           accelerator_tree=None, hardlink=False):
 
1167
        """See BzrDir.create_workingtree."""
 
1168
        return self._format.workingtree_format.initialize(
 
1169
            self, revision_id, from_branch=from_branch,
 
1170
            accelerator_tree=accelerator_tree, hardlink=hardlink)
 
1171
 
 
1172
    def destroy_workingtree(self):
 
1173
        """See BzrDir.destroy_workingtree."""
 
1174
        wt = self.open_workingtree(recommend_upgrade=False)
 
1175
        repository = wt.branch.repository
 
1176
        empty = repository.revision_tree(_mod_revision.NULL_REVISION)
 
1177
        # We ignore the conflicts returned by wt.revert since we're about to
 
1178
        # delete the wt metadata anyway, all that should be left here are
 
1179
        # detritus. But see bug #634470 about subtree .bzr dirs.
 
1180
        conflicts = wt.revert(old_tree=empty)
 
1181
        self.destroy_workingtree_metadata()
 
1182
 
 
1183
    def destroy_workingtree_metadata(self):
 
1184
        self.transport.delete_tree('checkout')
 
1185
 
 
1186
    def find_branch_format(self, name=None):
 
1187
        """Find the branch 'format' for this bzrdir.
 
1188
 
 
1189
        This might be a synthetic object for e.g. RemoteBranch and SVN.
 
1190
        """
 
1191
        from bzrlib.branch import BranchFormat
 
1192
        return BranchFormat.find_format(self, name=name)
 
1193
 
 
1194
    def _get_mkdir_mode(self):
 
1195
        """Figure out the mode to use when creating a bzrdir subdir."""
 
1196
        temp_control = lockable_files.LockableFiles(self.transport, '',
 
1197
                                     lockable_files.TransportLock)
 
1198
        return temp_control._dir_mode
 
1199
 
 
1200
    def get_branch_reference(self, name=None):
 
1201
        """See BzrDir.get_branch_reference()."""
 
1202
        from bzrlib.branch import BranchFormat
 
1203
        format = BranchFormat.find_format(self, name=name)
 
1204
        return format.get_reference(self, name=name)
 
1205
 
 
1206
    def get_branch_transport(self, branch_format, name=None):
 
1207
        """See BzrDir.get_branch_transport()."""
 
1208
        if name is not None:
 
1209
            raise errors.NoColocatedBranchSupport(self)
 
1210
        # XXX: this shouldn't implicitly create the directory if it's just
 
1211
        # promising to get a transport -- mbp 20090727
 
1212
        if branch_format is None:
 
1213
            return self.transport.clone('branch')
 
1214
        try:
 
1215
            branch_format.get_format_string()
 
1216
        except NotImplementedError:
 
1217
            raise errors.IncompatibleFormat(branch_format, self._format)
 
1218
        try:
 
1219
            self.transport.mkdir('branch', mode=self._get_mkdir_mode())
 
1220
        except errors.FileExists:
 
1221
            pass
 
1222
        return self.transport.clone('branch')
 
1223
 
 
1224
    def get_repository_transport(self, repository_format):
 
1225
        """See BzrDir.get_repository_transport()."""
 
1226
        if repository_format is None:
 
1227
            return self.transport.clone('repository')
 
1228
        try:
 
1229
            repository_format.get_format_string()
 
1230
        except NotImplementedError:
 
1231
            raise errors.IncompatibleFormat(repository_format, self._format)
 
1232
        try:
 
1233
            self.transport.mkdir('repository', mode=self._get_mkdir_mode())
 
1234
        except errors.FileExists:
 
1235
            pass
 
1236
        return self.transport.clone('repository')
 
1237
 
 
1238
    def get_workingtree_transport(self, workingtree_format):
 
1239
        """See BzrDir.get_workingtree_transport()."""
 
1240
        if workingtree_format is None:
 
1241
            return self.transport.clone('checkout')
 
1242
        try:
 
1243
            workingtree_format.get_format_string()
 
1244
        except NotImplementedError:
 
1245
            raise errors.IncompatibleFormat(workingtree_format, self._format)
 
1246
        try:
 
1247
            self.transport.mkdir('checkout', mode=self._get_mkdir_mode())
 
1248
        except errors.FileExists:
 
1249
            pass
 
1250
        return self.transport.clone('checkout')
 
1251
 
 
1252
    def has_workingtree(self):
 
1253
        """Tell if this bzrdir contains a working tree.
 
1254
 
 
1255
        This will still raise an exception if the bzrdir has a workingtree that
 
1256
        is remote & inaccessible.
 
1257
 
 
1258
        Note: if you're going to open the working tree, you should just go
 
1259
        ahead and try, and not ask permission first.
 
1260
        """
 
1261
        from bzrlib.workingtree import WorkingTreeFormat
 
1262
        try:
 
1263
            WorkingTreeFormat.find_format(self)
 
1264
        except errors.NoWorkingTree:
 
1265
            return False
 
1266
        return True
 
1267
 
 
1268
    def needs_format_conversion(self, format):
 
1269
        """See BzrDir.needs_format_conversion()."""
 
1270
        if not isinstance(self._format, format.__class__):
 
1271
            # it is not a meta dir format, conversion is needed.
 
1272
            return True
 
1273
        # we might want to push this down to the repository?
 
1274
        try:
 
1275
            if not isinstance(self.open_repository()._format,
 
1276
                              format.repository_format.__class__):
 
1277
                # the repository needs an upgrade.
 
1278
                return True
 
1279
        except errors.NoRepositoryPresent:
 
1280
            pass
 
1281
        for branch in self.list_branches():
 
1282
            if not isinstance(branch._format,
 
1283
                              format.get_branch_format().__class__):
 
1284
                # the branch needs an upgrade.
 
1285
                return True
 
1286
        try:
 
1287
            my_wt = self.open_workingtree(recommend_upgrade=False)
 
1288
            if not isinstance(my_wt._format,
 
1289
                              format.workingtree_format.__class__):
 
1290
                # the workingtree needs an upgrade.
 
1291
                return True
 
1292
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
1293
            pass
 
1294
        return False
 
1295
 
 
1296
    def open_branch(self, name=None, unsupported=False,
 
1297
                    ignore_fallbacks=False):
 
1298
        """See BzrDir.open_branch."""
 
1299
        format = self.find_branch_format(name=name)
 
1300
        format.check_support_status(unsupported)
 
1301
        return format.open(self, name=name,
 
1302
            _found=True, ignore_fallbacks=ignore_fallbacks)
 
1303
 
 
1304
    def open_repository(self, unsupported=False):
 
1305
        """See BzrDir.open_repository."""
 
1306
        from bzrlib.repository import RepositoryFormat
 
1307
        format = RepositoryFormat.find_format(self)
 
1308
        format.check_support_status(unsupported)
 
1309
        return format.open(self, _found=True)
 
1310
 
 
1311
    def open_workingtree(self, unsupported=False,
 
1312
            recommend_upgrade=True):
 
1313
        """See BzrDir.open_workingtree."""
 
1314
        from bzrlib.workingtree import WorkingTreeFormat
 
1315
        format = WorkingTreeFormat.find_format(self)
 
1316
        format.check_support_status(unsupported, recommend_upgrade,
 
1317
            basedir=self.root_transport.base)
 
1318
        return format.open(self, _found=True)
 
1319
 
 
1320
    def _get_config(self):
 
1321
        return config.TransportConfig(self.transport, 'control.conf')
 
1322
 
 
1323
 
 
1324
class BzrProber(controldir.Prober):
 
1325
    """Prober for formats that use a .bzr/ control directory."""
 
1326
 
 
1327
    formats = registry.FormatRegistry(controldir.network_format_registry)
 
1328
    """The known .bzr formats."""
 
1329
 
 
1330
    @classmethod
 
1331
    @deprecated_method(deprecated_in((2, 4, 0)))
 
1332
    def register_bzrdir_format(klass, format):
 
1333
        klass.formats.register(format.get_format_string(), format)
 
1334
 
 
1335
    @classmethod
 
1336
    @deprecated_method(deprecated_in((2, 4, 0)))
 
1337
    def unregister_bzrdir_format(klass, format):
 
1338
        klass.formats.remove(format.get_format_string())
 
1339
 
 
1340
    @classmethod
 
1341
    def probe_transport(klass, transport):
 
1342
        """Return the .bzrdir style format present in a directory."""
 
1343
        try:
 
1344
            format_string = transport.get_bytes(".bzr/branch-format")
 
1345
        except errors.NoSuchFile:
 
1346
            raise errors.NotBranchError(path=transport.base)
 
1347
        try:
 
1348
            return klass.formats.get(format_string)
 
1349
        except KeyError:
 
1350
            raise errors.UnknownFormatError(format=format_string, kind='bzrdir')
 
1351
 
 
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
 
 
1362
controldir.ControlDirFormat.register_prober(BzrProber)
 
1363
 
 
1364
 
 
1365
class RemoteBzrProber(controldir.Prober):
 
1366
    """Prober for remote servers that provide a Bazaar smart server."""
 
1367
 
 
1368
    @classmethod
 
1369
    def probe_transport(klass, transport):
 
1370
        """Return a RemoteBzrDirFormat object if it looks possible."""
 
1371
        try:
 
1372
            medium = transport.get_smart_medium()
 
1373
        except (NotImplementedError, AttributeError,
 
1374
                errors.TransportNotPossible, errors.NoSmartMedium,
 
1375
                errors.SmartProtocolError):
 
1376
            # no smart server, so not a branch for this format type.
 
1377
            raise errors.NotBranchError(path=transport.base)
 
1378
        else:
 
1379
            # Decline to open it if the server doesn't support our required
 
1380
            # version (3) so that the VFS-based transport will do it.
 
1381
            if medium.should_probe():
 
1382
                try:
 
1383
                    server_version = medium.protocol_version()
 
1384
                except errors.SmartProtocolError:
 
1385
                    # Apparently there's no usable smart server there, even though
 
1386
                    # the medium supports the smart protocol.
 
1387
                    raise errors.NotBranchError(path=transport.base)
 
1388
                if server_version != '2':
 
1389
                    raise errors.NotBranchError(path=transport.base)
 
1390
            from bzrlib.remote import RemoteBzrDirFormat
 
1391
            return RemoteBzrDirFormat()
 
1392
 
 
1393
    @classmethod
 
1394
    def known_formats(cls):
 
1395
        from bzrlib.remote import RemoteBzrDirFormat
 
1396
        return set([RemoteBzrDirFormat()])
 
1397
 
 
1398
 
 
1399
class BzrDirFormat(controldir.ControlDirFormat):
 
1400
    """ControlDirFormat base class for .bzr/ directories.
 
1401
 
 
1402
    Formats are placed in a dict by their format string for reference
 
1403
    during bzrdir opening. These should be subclasses of BzrDirFormat
 
1404
    for consistency.
 
1405
 
 
1406
    Once a format is deprecated, just deprecate the initialize and open
 
1407
    methods on the format class. Do not deprecate the object, as the
 
1408
    object will be created every system load.
 
1409
    """
 
1410
 
 
1411
    _lock_file_name = 'branch-lock'
 
1412
 
 
1413
    # _lock_class must be set in subclasses to the lock type, typ.
 
1414
    # TransportLock or LockDir
 
1415
 
 
1416
    @classmethod
 
1417
    def get_format_string(cls):
 
1418
        """Return the ASCII format string that identifies this format."""
 
1419
        raise NotImplementedError(self.get_format_string)
 
1420
 
 
1421
    def initialize_on_transport(self, transport):
 
1422
        """Initialize a new bzrdir in the base directory of a Transport."""
 
1423
        try:
 
1424
            # can we hand off the request to the smart server rather than using
 
1425
            # vfs calls?
 
1426
            client_medium = transport.get_smart_medium()
 
1427
        except errors.NoSmartMedium:
 
1428
            return self._initialize_on_transport_vfs(transport)
 
1429
        else:
 
1430
            # Current RPC's only know how to create bzr metadir1 instances, so
 
1431
            # we still delegate to vfs methods if the requested format is not a
 
1432
            # metadir1
 
1433
            if type(self) != BzrDirMetaFormat1:
 
1434
                return self._initialize_on_transport_vfs(transport)
 
1435
            from bzrlib.remote import RemoteBzrDirFormat
 
1436
            remote_format = RemoteBzrDirFormat()
 
1437
            self._supply_sub_formats_to(remote_format)
 
1438
            return remote_format.initialize_on_transport(transport)
 
1439
 
 
1440
    def initialize_on_transport_ex(self, transport, use_existing_dir=False,
 
1441
        create_prefix=False, force_new_repo=False, stacked_on=None,
 
1442
        stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
 
1443
        shared_repo=False, vfs_only=False):
 
1444
        """Create this format on transport.
 
1445
 
 
1446
        The directory to initialize will be created.
 
1447
 
 
1448
        :param force_new_repo: Do not use a shared repository for the target,
 
1449
                               even if one is available.
 
1450
        :param create_prefix: Create any missing directories leading up to
 
1451
            to_transport.
 
1452
        :param use_existing_dir: Use an existing directory if one exists.
 
1453
        :param stacked_on: A url to stack any created branch on, None to follow
 
1454
            any target stacking policy.
 
1455
        :param stack_on_pwd: If stack_on is relative, the location it is
 
1456
            relative to.
 
1457
        :param repo_format_name: If non-None, a repository will be
 
1458
            made-or-found. Should none be found, or if force_new_repo is True
 
1459
            the repo_format_name is used to select the format of repository to
 
1460
            create.
 
1461
        :param make_working_trees: Control the setting of make_working_trees
 
1462
            for a new shared repository when one is made. None to use whatever
 
1463
            default the format has.
 
1464
        :param shared_repo: Control whether made repositories are shared or
 
1465
            not.
 
1466
        :param vfs_only: If True do not attempt to use a smart server
 
1467
        :return: repo, bzrdir, require_stacking, repository_policy. repo is
 
1468
            None if none was created or found, bzrdir is always valid.
 
1469
            require_stacking is the result of examining the stacked_on
 
1470
            parameter and any stacking policy found for the target.
 
1471
        """
 
1472
        if not vfs_only:
 
1473
            # Try to hand off to a smart server 
 
1474
            try:
 
1475
                client_medium = transport.get_smart_medium()
 
1476
            except errors.NoSmartMedium:
 
1477
                pass
 
1478
            else:
 
1479
                from bzrlib.remote import RemoteBzrDirFormat
 
1480
                # TODO: lookup the local format from a server hint.
 
1481
                remote_dir_format = RemoteBzrDirFormat()
 
1482
                remote_dir_format._network_name = self.network_name()
 
1483
                self._supply_sub_formats_to(remote_dir_format)
 
1484
                return remote_dir_format.initialize_on_transport_ex(transport,
 
1485
                    use_existing_dir=use_existing_dir, create_prefix=create_prefix,
 
1486
                    force_new_repo=force_new_repo, stacked_on=stacked_on,
 
1487
                    stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
 
1488
                    make_working_trees=make_working_trees, shared_repo=shared_repo)
 
1489
        # XXX: Refactor the create_prefix/no_create_prefix code into a
 
1490
        #      common helper function
 
1491
        # The destination may not exist - if so make it according to policy.
 
1492
        def make_directory(transport):
 
1493
            transport.mkdir('.')
 
1494
            return transport
 
1495
        def redirected(transport, e, redirection_notice):
 
1496
            note(redirection_notice)
 
1497
            return transport._redirected_to(e.source, e.target)
 
1498
        try:
 
1499
            transport = do_catching_redirections(make_directory, transport,
 
1500
                redirected)
 
1501
        except errors.FileExists:
 
1502
            if not use_existing_dir:
 
1503
                raise
 
1504
        except errors.NoSuchFile:
 
1505
            if not create_prefix:
 
1506
                raise
 
1507
            transport.create_prefix()
 
1508
 
 
1509
        require_stacking = (stacked_on is not None)
 
1510
        # Now the target directory exists, but doesn't have a .bzr
 
1511
        # directory. So we need to create it, along with any work to create
 
1512
        # all of the dependent branches, etc.
 
1513
 
 
1514
        result = self.initialize_on_transport(transport)
 
1515
        if repo_format_name:
 
1516
            try:
 
1517
                # use a custom format
 
1518
                result._format.repository_format = \
 
1519
                    repository.network_format_registry.get(repo_format_name)
 
1520
            except AttributeError:
 
1521
                # The format didn't permit it to be set.
 
1522
                pass
 
1523
            # A repository is desired, either in-place or shared.
 
1524
            repository_policy = result.determine_repository_policy(
 
1525
                force_new_repo, stacked_on, stack_on_pwd,
 
1526
                require_stacking=require_stacking)
 
1527
            result_repo, is_new_repo = repository_policy.acquire_repository(
 
1528
                make_working_trees, shared_repo)
 
1529
            if not require_stacking and repository_policy._require_stacking:
 
1530
                require_stacking = True
 
1531
                result._format.require_stacking()
 
1532
            result_repo.lock_write()
 
1533
        else:
 
1534
            result_repo = None
 
1535
            repository_policy = None
 
1536
        return result_repo, result, require_stacking, repository_policy
 
1537
 
 
1538
    def _initialize_on_transport_vfs(self, transport):
 
1539
        """Initialize a new bzrdir using VFS calls.
 
1540
 
 
1541
        :param transport: The transport to create the .bzr directory in.
 
1542
        :return: A
 
1543
        """
 
1544
        # Since we are creating a .bzr directory, inherit the
 
1545
        # mode from the root directory
 
1546
        temp_control = lockable_files.LockableFiles(transport,
 
1547
                            '', lockable_files.TransportLock)
 
1548
        temp_control._transport.mkdir('.bzr',
 
1549
                                      # FIXME: RBC 20060121 don't peek under
 
1550
                                      # the covers
 
1551
                                      mode=temp_control._dir_mode)
 
1552
        if sys.platform == 'win32' and isinstance(transport, local.LocalTransport):
 
1553
            win32utils.set_file_attr_hidden(transport._abspath('.bzr'))
 
1554
        file_mode = temp_control._file_mode
 
1555
        del temp_control
 
1556
        bzrdir_transport = transport.clone('.bzr')
 
1557
        utf8_files = [('README',
 
1558
                       "This is a Bazaar control directory.\n"
 
1559
                       "Do not change any files in this directory.\n"
 
1560
                       "See http://bazaar.canonical.com/ for more information about Bazaar.\n"),
 
1561
                      ('branch-format', self.get_format_string()),
 
1562
                      ]
 
1563
        # NB: no need to escape relative paths that are url safe.
 
1564
        control_files = lockable_files.LockableFiles(bzrdir_transport,
 
1565
            self._lock_file_name, self._lock_class)
 
1566
        control_files.create_lock()
 
1567
        control_files.lock_write()
 
1568
        try:
 
1569
            for (filename, content) in utf8_files:
 
1570
                bzrdir_transport.put_bytes(filename, content,
 
1571
                    mode=file_mode)
 
1572
        finally:
 
1573
            control_files.unlock()
 
1574
        return self.open(transport, _found=True)
 
1575
 
 
1576
    def open(self, transport, _found=False):
 
1577
        """Return an instance of this format for the dir transport points at.
 
1578
 
 
1579
        _found is a private parameter, do not use it.
 
1580
        """
 
1581
        if not _found:
 
1582
            found_format = controldir.ControlDirFormat.find_format(transport)
 
1583
            if not isinstance(found_format, self.__class__):
 
1584
                raise AssertionError("%s was asked to open %s, but it seems to need "
 
1585
                        "format %s"
 
1586
                        % (self, transport, found_format))
 
1587
            # Allow subclasses - use the found format.
 
1588
            self._supply_sub_formats_to(found_format)
 
1589
            return found_format._open(transport)
 
1590
        return self._open(transport)
 
1591
 
 
1592
    def _open(self, transport):
 
1593
        """Template method helper for opening BzrDirectories.
 
1594
 
 
1595
        This performs the actual open and any additional logic or parameter
 
1596
        passing.
 
1597
        """
 
1598
        raise NotImplementedError(self._open)
 
1599
 
 
1600
    def _supply_sub_formats_to(self, other_format):
 
1601
        """Give other_format the same values for sub formats as this has.
 
1602
 
 
1603
        This method is expected to be used when parameterising a
 
1604
        RemoteBzrDirFormat instance with the parameters from a
 
1605
        BzrDirMetaFormat1 instance.
 
1606
 
 
1607
        :param other_format: other_format is a format which should be
 
1608
            compatible with whatever sub formats are supported by self.
 
1609
        :return: None.
 
1610
        """
 
1611
 
 
1612
 
 
1613
class BzrDirMetaFormat1(BzrDirFormat):
 
1614
    """Bzr meta control format 1
 
1615
 
 
1616
    This is the first format with split out working tree, branch and repository
 
1617
    disk storage.
 
1618
    It has:
 
1619
     - Format 3 working trees [optional]
 
1620
     - Format 5 branches [optional]
 
1621
     - Format 7 repositories [optional]
 
1622
    """
 
1623
 
 
1624
    _lock_class = lockdir.LockDir
 
1625
 
 
1626
    fixed_components = False
 
1627
 
 
1628
    def __init__(self):
 
1629
        self._workingtree_format = None
 
1630
        self._branch_format = None
 
1631
        self._repository_format = None
 
1632
 
 
1633
    def __eq__(self, other):
 
1634
        if other.__class__ is not self.__class__:
 
1635
            return False
 
1636
        if other.repository_format != self.repository_format:
 
1637
            return False
 
1638
        if other.workingtree_format != self.workingtree_format:
 
1639
            return False
 
1640
        return True
 
1641
 
 
1642
    def __ne__(self, other):
 
1643
        return not self == other
 
1644
 
 
1645
    def get_branch_format(self):
 
1646
        if self._branch_format is None:
 
1647
            from bzrlib.branch import format_registry as branch_format_registry
 
1648
            self._branch_format = branch_format_registry.get_default()
 
1649
        return self._branch_format
 
1650
 
 
1651
    def set_branch_format(self, format):
 
1652
        self._branch_format = format
 
1653
 
 
1654
    def require_stacking(self, stack_on=None, possible_transports=None,
 
1655
            _skip_repo=False):
 
1656
        """We have a request to stack, try to ensure the formats support it.
 
1657
 
 
1658
        :param stack_on: If supplied, it is the URL to a branch that we want to
 
1659
            stack on. Check to see if that format supports stacking before
 
1660
            forcing an upgrade.
 
1661
        """
 
1662
        # Stacking is desired. requested by the target, but does the place it
 
1663
        # points at support stacking? If it doesn't then we should
 
1664
        # not implicitly upgrade. We check this here.
 
1665
        new_repo_format = None
 
1666
        new_branch_format = None
 
1667
 
 
1668
        # a bit of state for get_target_branch so that we don't try to open it
 
1669
        # 2 times, for both repo *and* branch
 
1670
        target = [None, False, None] # target_branch, checked, upgrade anyway
 
1671
        def get_target_branch():
 
1672
            if target[1]:
 
1673
                # We've checked, don't check again
 
1674
                return target
 
1675
            if stack_on is None:
 
1676
                # No target format, that means we want to force upgrading
 
1677
                target[:] = [None, True, True]
 
1678
                return target
 
1679
            try:
 
1680
                target_dir = BzrDir.open(stack_on,
 
1681
                    possible_transports=possible_transports)
 
1682
            except errors.NotBranchError:
 
1683
                # Nothing there, don't change formats
 
1684
                target[:] = [None, True, False]
 
1685
                return target
 
1686
            except errors.JailBreak:
 
1687
                # JailBreak, JFDI and upgrade anyway
 
1688
                target[:] = [None, True, True]
 
1689
                return target
 
1690
            try:
 
1691
                target_branch = target_dir.open_branch()
 
1692
            except errors.NotBranchError:
 
1693
                # No branch, don't upgrade formats
 
1694
                target[:] = [None, True, False]
 
1695
                return target
 
1696
            target[:] = [target_branch, True, False]
 
1697
            return target
 
1698
 
 
1699
        if (not _skip_repo and
 
1700
                 not self.repository_format.supports_external_lookups):
 
1701
            # We need to upgrade the Repository.
 
1702
            target_branch, _, do_upgrade = get_target_branch()
 
1703
            if target_branch is None:
 
1704
                # We don't have a target branch, should we upgrade anyway?
 
1705
                if do_upgrade:
 
1706
                    # stack_on is inaccessible, JFDI.
 
1707
                    # TODO: bad monkey, hard-coded formats...
 
1708
                    if self.repository_format.rich_root_data:
 
1709
                        new_repo_format = knitpack_repo.RepositoryFormatKnitPack5RichRoot()
 
1710
                    else:
 
1711
                        new_repo_format = knitpack_repo.RepositoryFormatKnitPack5()
 
1712
            else:
 
1713
                # If the target already supports stacking, then we know the
 
1714
                # project is already able to use stacking, so auto-upgrade
 
1715
                # for them
 
1716
                new_repo_format = target_branch.repository._format
 
1717
                if not new_repo_format.supports_external_lookups:
 
1718
                    # target doesn't, source doesn't, so don't auto upgrade
 
1719
                    # repo
 
1720
                    new_repo_format = None
 
1721
            if new_repo_format is not None:
 
1722
                self.repository_format = new_repo_format
 
1723
                note('Source repository format does not support stacking,'
 
1724
                     ' using format:\n  %s',
 
1725
                     new_repo_format.get_format_description())
 
1726
 
 
1727
        if not self.get_branch_format().supports_stacking():
 
1728
            # We just checked the repo, now lets check if we need to
 
1729
            # upgrade the branch format
 
1730
            target_branch, _, do_upgrade = get_target_branch()
 
1731
            if target_branch is None:
 
1732
                if do_upgrade:
 
1733
                    # TODO: bad monkey, hard-coded formats...
 
1734
                    from bzrlib.branch import BzrBranchFormat7
 
1735
                    new_branch_format = BzrBranchFormat7()
 
1736
            else:
 
1737
                new_branch_format = target_branch._format
 
1738
                if not new_branch_format.supports_stacking():
 
1739
                    new_branch_format = None
 
1740
            if new_branch_format is not None:
 
1741
                # Does support stacking, use its format.
 
1742
                self.set_branch_format(new_branch_format)
 
1743
                note('Source branch format does not support stacking,'
 
1744
                     ' using format:\n  %s',
 
1745
                     new_branch_format.get_format_description())
 
1746
 
 
1747
    def get_converter(self, format=None):
 
1748
        """See BzrDirFormat.get_converter()."""
 
1749
        if format is None:
 
1750
            format = BzrDirFormat.get_default_format()
 
1751
        if not isinstance(self, format.__class__):
 
1752
            # converting away from metadir is not implemented
 
1753
            raise NotImplementedError(self.get_converter)
 
1754
        return ConvertMetaToMeta(format)
 
1755
 
 
1756
    @classmethod
 
1757
    def get_format_string(cls):
 
1758
        """See BzrDirFormat.get_format_string()."""
 
1759
        return "Bazaar-NG meta directory, format 1\n"
 
1760
 
 
1761
    def get_format_description(self):
 
1762
        """See BzrDirFormat.get_format_description()."""
 
1763
        return "Meta directory format 1"
 
1764
 
 
1765
    def network_name(self):
 
1766
        return self.get_format_string()
 
1767
 
 
1768
    def _open(self, transport):
 
1769
        """See BzrDirFormat._open."""
 
1770
        # Create a new format instance because otherwise initialisation of new
 
1771
        # metadirs share the global default format object leading to alias
 
1772
        # problems.
 
1773
        format = BzrDirMetaFormat1()
 
1774
        self._supply_sub_formats_to(format)
 
1775
        return BzrDirMeta1(transport, format)
 
1776
 
 
1777
    def __return_repository_format(self):
 
1778
        """Circular import protection."""
 
1779
        if self._repository_format:
 
1780
            return self._repository_format
 
1781
        from bzrlib.repository import format_registry
 
1782
        return format_registry.get_default()
 
1783
 
 
1784
    def _set_repository_format(self, value):
 
1785
        """Allow changing the repository format for metadir formats."""
 
1786
        self._repository_format = value
 
1787
 
 
1788
    repository_format = property(__return_repository_format,
 
1789
        _set_repository_format)
 
1790
 
 
1791
    def _supply_sub_formats_to(self, other_format):
 
1792
        """Give other_format the same values for sub formats as this has.
 
1793
 
 
1794
        This method is expected to be used when parameterising a
 
1795
        RemoteBzrDirFormat instance with the parameters from a
 
1796
        BzrDirMetaFormat1 instance.
 
1797
 
 
1798
        :param other_format: other_format is a format which should be
 
1799
            compatible with whatever sub formats are supported by self.
 
1800
        :return: None.
 
1801
        """
 
1802
        if getattr(self, '_repository_format', None) is not None:
 
1803
            other_format.repository_format = self.repository_format
 
1804
        if self._branch_format is not None:
 
1805
            other_format._branch_format = self._branch_format
 
1806
        if self._workingtree_format is not None:
 
1807
            other_format.workingtree_format = self.workingtree_format
 
1808
 
 
1809
    def __get_workingtree_format(self):
 
1810
        if self._workingtree_format is None:
 
1811
            from bzrlib.workingtree import (
 
1812
                format_registry as wt_format_registry,
 
1813
                )
 
1814
            self._workingtree_format = wt_format_registry.get_default()
 
1815
        return self._workingtree_format
 
1816
 
 
1817
    def __set_workingtree_format(self, wt_format):
 
1818
        self._workingtree_format = wt_format
 
1819
 
 
1820
    workingtree_format = property(__get_workingtree_format,
 
1821
                                  __set_workingtree_format)
 
1822
 
 
1823
 
 
1824
# Register bzr formats
 
1825
BzrProber.formats.register(BzrDirMetaFormat1.get_format_string(),
 
1826
    BzrDirMetaFormat1)
 
1827
controldir.ControlDirFormat._default_format = BzrDirMetaFormat1()
 
1828
 
 
1829
 
 
1830
class ConvertMetaToMeta(controldir.Converter):
 
1831
    """Converts the components of metadirs."""
 
1832
 
 
1833
    def __init__(self, target_format):
 
1834
        """Create a metadir to metadir converter.
 
1835
 
 
1836
        :param target_format: The final metadir format that is desired.
 
1837
        """
 
1838
        self.target_format = target_format
 
1839
 
 
1840
    def convert(self, to_convert, pb):
 
1841
        """See Converter.convert()."""
 
1842
        self.bzrdir = to_convert
 
1843
        self.pb = ui.ui_factory.nested_progress_bar()
 
1844
        self.count = 0
 
1845
        self.total = 1
 
1846
        self.step('checking repository format')
 
1847
        try:
 
1848
            repo = self.bzrdir.open_repository()
 
1849
        except errors.NoRepositoryPresent:
 
1850
            pass
 
1851
        else:
 
1852
            if not isinstance(repo._format, self.target_format.repository_format.__class__):
 
1853
                from bzrlib.repository import CopyConverter
 
1854
                ui.ui_factory.note('starting repository conversion')
 
1855
                converter = CopyConverter(self.target_format.repository_format)
 
1856
                converter.convert(repo, pb)
 
1857
        for branch in self.bzrdir.list_branches():
 
1858
            # TODO: conversions of Branch and Tree should be done by
 
1859
            # InterXFormat lookups/some sort of registry.
 
1860
            # Avoid circular imports
 
1861
            old = branch._format.__class__
 
1862
            new = self.target_format.get_branch_format().__class__
 
1863
            while old != new:
 
1864
                if (old == _mod_branch.BzrBranchFormat5 and
 
1865
                    new in (_mod_branch.BzrBranchFormat6,
 
1866
                        _mod_branch.BzrBranchFormat7,
 
1867
                        _mod_branch.BzrBranchFormat8)):
 
1868
                    branch_converter = _mod_branch.Converter5to6()
 
1869
                elif (old == _mod_branch.BzrBranchFormat6 and
 
1870
                    new in (_mod_branch.BzrBranchFormat7,
 
1871
                            _mod_branch.BzrBranchFormat8)):
 
1872
                    branch_converter = _mod_branch.Converter6to7()
 
1873
                elif (old == _mod_branch.BzrBranchFormat7 and
 
1874
                      new is _mod_branch.BzrBranchFormat8):
 
1875
                    branch_converter = _mod_branch.Converter7to8()
 
1876
                else:
 
1877
                    raise errors.BadConversionTarget("No converter", new,
 
1878
                        branch._format)
 
1879
                branch_converter.convert(branch)
 
1880
                branch = self.bzrdir.open_branch()
 
1881
                old = branch._format.__class__
 
1882
        try:
 
1883
            tree = self.bzrdir.open_workingtree(recommend_upgrade=False)
 
1884
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
1885
            pass
 
1886
        else:
 
1887
            # TODO: conversions of Branch and Tree should be done by
 
1888
            # InterXFormat lookups
 
1889
            if (isinstance(tree, workingtree.WorkingTree3) and
 
1890
                not isinstance(tree, workingtree_4.DirStateWorkingTree) and
 
1891
                isinstance(self.target_format.workingtree_format,
 
1892
                    workingtree_4.DirStateWorkingTreeFormat)):
 
1893
                workingtree_4.Converter3to4().convert(tree)
 
1894
            if (isinstance(tree, workingtree_4.DirStateWorkingTree) and
 
1895
                not isinstance(tree, workingtree_4.WorkingTree5) and
 
1896
                isinstance(self.target_format.workingtree_format,
 
1897
                    workingtree_4.WorkingTreeFormat5)):
 
1898
                workingtree_4.Converter4to5().convert(tree)
 
1899
            if (isinstance(tree, workingtree_4.DirStateWorkingTree) and
 
1900
                not isinstance(tree, workingtree_4.WorkingTree6) and
 
1901
                isinstance(self.target_format.workingtree_format,
 
1902
                    workingtree_4.WorkingTreeFormat6)):
 
1903
                workingtree_4.Converter4or5to6().convert(tree)
 
1904
        self.pb.finished()
 
1905
        return to_convert
 
1906
 
 
1907
 
 
1908
controldir.ControlDirFormat.register_server_prober(RemoteBzrProber)
 
1909
 
 
1910
 
 
1911
class RepositoryAcquisitionPolicy(object):
 
1912
    """Abstract base class for repository acquisition policies.
 
1913
 
 
1914
    A repository acquisition policy decides how a BzrDir acquires a repository
 
1915
    for a branch that is being created.  The most basic policy decision is
 
1916
    whether to create a new repository or use an existing one.
 
1917
    """
 
1918
    def __init__(self, stack_on, stack_on_pwd, require_stacking):
 
1919
        """Constructor.
 
1920
 
 
1921
        :param stack_on: A location to stack on
 
1922
        :param stack_on_pwd: If stack_on is relative, the location it is
 
1923
            relative to.
 
1924
        :param require_stacking: If True, it is a failure to not stack.
 
1925
        """
 
1926
        self._stack_on = stack_on
 
1927
        self._stack_on_pwd = stack_on_pwd
 
1928
        self._require_stacking = require_stacking
 
1929
 
 
1930
    def configure_branch(self, branch):
 
1931
        """Apply any configuration data from this policy to the branch.
 
1932
 
 
1933
        Default implementation sets repository stacking.
 
1934
        """
 
1935
        if self._stack_on is None:
 
1936
            return
 
1937
        if self._stack_on_pwd is None:
 
1938
            stack_on = self._stack_on
 
1939
        else:
 
1940
            try:
 
1941
                stack_on = urlutils.rebase_url(self._stack_on,
 
1942
                    self._stack_on_pwd,
 
1943
                    branch.user_url)
 
1944
            except errors.InvalidRebaseURLs:
 
1945
                stack_on = self._get_full_stack_on()
 
1946
        try:
 
1947
            branch.set_stacked_on_url(stack_on)
 
1948
        except (errors.UnstackableBranchFormat,
 
1949
                errors.UnstackableRepositoryFormat):
 
1950
            if self._require_stacking:
 
1951
                raise
 
1952
 
 
1953
    def requires_stacking(self):
 
1954
        """Return True if this policy requires stacking."""
 
1955
        return self._stack_on is not None and self._require_stacking
 
1956
 
 
1957
    def _get_full_stack_on(self):
 
1958
        """Get a fully-qualified URL for the stack_on location."""
 
1959
        if self._stack_on is None:
 
1960
            return None
 
1961
        if self._stack_on_pwd is None:
 
1962
            return self._stack_on
 
1963
        else:
 
1964
            return urlutils.join(self._stack_on_pwd, self._stack_on)
 
1965
 
 
1966
    def _add_fallback(self, repository, possible_transports=None):
 
1967
        """Add a fallback to the supplied repository, if stacking is set."""
 
1968
        stack_on = self._get_full_stack_on()
 
1969
        if stack_on is None:
 
1970
            return
 
1971
        try:
 
1972
            stacked_dir = BzrDir.open(stack_on,
 
1973
                                      possible_transports=possible_transports)
 
1974
        except errors.JailBreak:
 
1975
            # We keep the stacking details, but we are in the server code so
 
1976
            # actually stacking is not needed.
 
1977
            return
 
1978
        try:
 
1979
            stacked_repo = stacked_dir.open_branch().repository
 
1980
        except errors.NotBranchError:
 
1981
            stacked_repo = stacked_dir.open_repository()
 
1982
        try:
 
1983
            repository.add_fallback_repository(stacked_repo)
 
1984
        except errors.UnstackableRepositoryFormat:
 
1985
            if self._require_stacking:
 
1986
                raise
 
1987
        else:
 
1988
            self._require_stacking = True
 
1989
 
 
1990
    def acquire_repository(self, make_working_trees=None, shared=False):
 
1991
        """Acquire a repository for this bzrdir.
 
1992
 
 
1993
        Implementations may create a new repository or use a pre-exising
 
1994
        repository.
 
1995
        :param make_working_trees: If creating a repository, set
 
1996
            make_working_trees to this value (if non-None)
 
1997
        :param shared: If creating a repository, make it shared if True
 
1998
        :return: A repository, is_new_flag (True if the repository was
 
1999
            created).
 
2000
        """
 
2001
        raise NotImplemented(RepositoryAcquisitionPolicy.acquire_repository)
 
2002
 
 
2003
 
 
2004
class CreateRepository(RepositoryAcquisitionPolicy):
 
2005
    """A policy of creating a new repository"""
 
2006
 
 
2007
    def __init__(self, bzrdir, stack_on=None, stack_on_pwd=None,
 
2008
                 require_stacking=False):
 
2009
        """
 
2010
        Constructor.
 
2011
        :param bzrdir: The bzrdir to create the repository on.
 
2012
        :param stack_on: A location to stack on
 
2013
        :param stack_on_pwd: If stack_on is relative, the location it is
 
2014
            relative to.
 
2015
        """
 
2016
        RepositoryAcquisitionPolicy.__init__(self, stack_on, stack_on_pwd,
 
2017
                                             require_stacking)
 
2018
        self._bzrdir = bzrdir
 
2019
 
 
2020
    def acquire_repository(self, make_working_trees=None, shared=False):
 
2021
        """Implementation of RepositoryAcquisitionPolicy.acquire_repository
 
2022
 
 
2023
        Creates the desired repository in the bzrdir we already have.
 
2024
        """
 
2025
        stack_on = self._get_full_stack_on()
 
2026
        if stack_on:
 
2027
            format = self._bzrdir._format
 
2028
            format.require_stacking(stack_on=stack_on,
 
2029
                                    possible_transports=[self._bzrdir.root_transport])
 
2030
            if not self._require_stacking:
 
2031
                # We have picked up automatic stacking somewhere.
 
2032
                note('Using default stacking branch %s at %s', self._stack_on,
 
2033
                    self._stack_on_pwd)
 
2034
        repository = self._bzrdir.create_repository(shared=shared)
 
2035
        self._add_fallback(repository,
 
2036
                           possible_transports=[self._bzrdir.transport])
 
2037
        if make_working_trees is not None:
 
2038
            repository.set_make_working_trees(make_working_trees)
 
2039
        return repository, True
 
2040
 
 
2041
 
 
2042
class UseExistingRepository(RepositoryAcquisitionPolicy):
 
2043
    """A policy of reusing an existing repository"""
 
2044
 
 
2045
    def __init__(self, repository, stack_on=None, stack_on_pwd=None,
 
2046
                 require_stacking=False):
 
2047
        """Constructor.
 
2048
 
 
2049
        :param repository: The repository to use.
 
2050
        :param stack_on: A location to stack on
 
2051
        :param stack_on_pwd: If stack_on is relative, the location it is
 
2052
            relative to.
 
2053
        """
 
2054
        RepositoryAcquisitionPolicy.__init__(self, stack_on, stack_on_pwd,
 
2055
                                             require_stacking)
 
2056
        self._repository = repository
 
2057
 
 
2058
    def acquire_repository(self, make_working_trees=None, shared=False):
 
2059
        """Implementation of RepositoryAcquisitionPolicy.acquire_repository
 
2060
 
 
2061
        Returns an existing repository to use.
 
2062
        """
 
2063
        self._add_fallback(self._repository,
 
2064
                       possible_transports=[self._repository.bzrdir.transport])
 
2065
        return self._repository, False
 
2066
 
 
2067
 
 
2068
def register_metadir(registry, key,
 
2069
         repository_format, help, native=True, deprecated=False,
 
2070
         branch_format=None,
 
2071
         tree_format=None,
 
2072
         hidden=False,
 
2073
         experimental=False,
 
2074
         alias=False):
 
2075
    """Register a metadir subformat.
 
2076
 
 
2077
    These all use a BzrDirMetaFormat1 bzrdir, but can be parameterized
 
2078
    by the Repository/Branch/WorkingTreeformats.
 
2079
 
 
2080
    :param repository_format: The fully-qualified repository format class
 
2081
        name as a string.
 
2082
    :param branch_format: Fully-qualified branch format class name as
 
2083
        a string.
 
2084
    :param tree_format: Fully-qualified tree format class name as
 
2085
        a string.
 
2086
    """
 
2087
    # This should be expanded to support setting WorkingTree and Branch
 
2088
    # formats, once BzrDirMetaFormat1 supports that.
 
2089
    def _load(full_name):
 
2090
        mod_name, factory_name = full_name.rsplit('.', 1)
 
2091
        try:
 
2092
            factory = pyutils.get_named_object(mod_name, factory_name)
 
2093
        except ImportError, e:
 
2094
            raise ImportError('failed to load %s: %s' % (full_name, e))
 
2095
        except AttributeError:
 
2096
            raise AttributeError('no factory %s in module %r'
 
2097
                % (full_name, sys.modules[mod_name]))
 
2098
        return factory()
 
2099
 
 
2100
    def helper():
 
2101
        bd = BzrDirMetaFormat1()
 
2102
        if branch_format is not None:
 
2103
            bd.set_branch_format(_load(branch_format))
 
2104
        if tree_format is not None:
 
2105
            bd.workingtree_format = _load(tree_format)
 
2106
        if repository_format is not None:
 
2107
            bd.repository_format = _load(repository_format)
 
2108
        return bd
 
2109
    registry.register(key, helper, help, native, deprecated, hidden,
 
2110
        experimental, alias)
 
2111
 
 
2112
register_metadir(controldir.format_registry, 'knit',
 
2113
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
 
2114
    'Format using knits.  Recommended for interoperation with bzr <= 0.14.',
 
2115
    branch_format='bzrlib.branch.BzrBranchFormat5',
 
2116
    tree_format='bzrlib.workingtree.WorkingTreeFormat3',
 
2117
    hidden=True,
 
2118
    deprecated=True)
 
2119
register_metadir(controldir.format_registry, 'dirstate',
 
2120
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
 
2121
    help='New in 0.15: Fast local operations. Compatible with bzr 0.8 and '
 
2122
        'above when accessed over the network.',
 
2123
    branch_format='bzrlib.branch.BzrBranchFormat5',
 
2124
    # this uses bzrlib.workingtree.WorkingTreeFormat4 because importing
 
2125
    # directly from workingtree_4 triggers a circular import.
 
2126
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2127
    hidden=True,
 
2128
    deprecated=True)
 
2129
register_metadir(controldir.format_registry, 'dirstate-tags',
 
2130
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
 
2131
    help='New in 0.15: Fast local operations and improved scaling for '
 
2132
        'network operations. Additionally adds support for tags.'
 
2133
        ' Incompatible with bzr < 0.15.',
 
2134
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2135
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2136
    hidden=True,
 
2137
    deprecated=True)
 
2138
register_metadir(controldir.format_registry, 'rich-root',
 
2139
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit4',
 
2140
    help='New in 1.0.  Better handling of tree roots.  Incompatible with'
 
2141
        ' bzr < 1.0.',
 
2142
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2143
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2144
    hidden=True,
 
2145
    deprecated=True)
 
2146
register_metadir(controldir.format_registry, 'dirstate-with-subtree',
 
2147
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit3',
 
2148
    help='New in 0.15: Fast local operations and improved scaling for '
 
2149
        'network operations. Additionally adds support for versioning nested '
 
2150
        'bzr branches. Incompatible with bzr < 0.15.',
 
2151
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2152
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2153
    experimental=True,
 
2154
    hidden=True,
 
2155
    )
 
2156
register_metadir(controldir.format_registry, 'pack-0.92',
 
2157
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack1',
 
2158
    help='New in 0.92: Pack-based format with data compatible with '
 
2159
        'dirstate-tags format repositories. Interoperates with '
 
2160
        'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
 
2161
        ,
 
2162
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2163
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2164
    )
 
2165
register_metadir(controldir.format_registry, 'pack-0.92-subtree',
 
2166
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack3',
 
2167
    help='New in 0.92: Pack-based format with data compatible with '
 
2168
        'dirstate-with-subtree format repositories. Interoperates with '
 
2169
        'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
 
2170
        ,
 
2171
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2172
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2173
    hidden=True,
 
2174
    experimental=True,
 
2175
    )
 
2176
register_metadir(controldir.format_registry, 'rich-root-pack',
 
2177
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack4',
 
2178
    help='New in 1.0: A variant of pack-0.92 that supports rich-root data '
 
2179
         '(needed for bzr-svn and bzr-git).',
 
2180
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2181
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2182
    hidden=True,
 
2183
    )
 
2184
register_metadir(controldir.format_registry, '1.6',
 
2185
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack5',
 
2186
    help='A format that allows a branch to indicate that there is another '
 
2187
         '(stacked) repository that should be used to access data that is '
 
2188
         'not present locally.',
 
2189
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2190
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2191
    hidden=True,
 
2192
    )
 
2193
register_metadir(controldir.format_registry, '1.6.1-rich-root',
 
2194
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack5RichRoot',
 
2195
    help='A variant of 1.6 that supports rich-root data '
 
2196
         '(needed for bzr-svn and bzr-git).',
 
2197
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2198
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2199
    hidden=True,
 
2200
    )
 
2201
register_metadir(controldir.format_registry, '1.9',
 
2202
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6',
 
2203
    help='A repository format using B+tree indexes. These indexes '
 
2204
         'are smaller in size, have smarter caching and provide faster '
 
2205
         'performance for most operations.',
 
2206
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2207
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2208
    hidden=True,
 
2209
    )
 
2210
register_metadir(controldir.format_registry, '1.9-rich-root',
 
2211
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6RichRoot',
 
2212
    help='A variant of 1.9 that supports rich-root data '
 
2213
         '(needed for bzr-svn and bzr-git).',
 
2214
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2215
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2216
    hidden=True,
 
2217
    )
 
2218
register_metadir(controldir.format_registry, '1.14',
 
2219
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6',
 
2220
    help='A working-tree format that supports content filtering.',
 
2221
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2222
    tree_format='bzrlib.workingtree.WorkingTreeFormat5',
 
2223
    )
 
2224
register_metadir(controldir.format_registry, '1.14-rich-root',
 
2225
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6RichRoot',
 
2226
    help='A variant of 1.14 that supports rich-root data '
 
2227
         '(needed for bzr-svn and bzr-git).',
 
2228
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2229
    tree_format='bzrlib.workingtree.WorkingTreeFormat5',
 
2230
    )
 
2231
# The following un-numbered 'development' formats should always just be aliases.
 
2232
register_metadir(controldir.format_registry, 'development-subtree',
 
2233
    'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2aSubtree',
 
2234
    help='Current development format, subtree variant. Can convert data to and '
 
2235
        'from pack-0.92-subtree (and anything compatible with '
 
2236
        'pack-0.92-subtree) format repositories. Repositories and branches in '
 
2237
        'this format can only be read by bzr.dev. Please read '
 
2238
        'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
 
2239
        'before use.',
 
2240
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2241
    tree_format='bzrlib.workingtree.WorkingTreeFormat6',
 
2242
    experimental=True,
 
2243
    hidden=True,
 
2244
    alias=False, # Restore to being an alias when an actual development subtree format is added
 
2245
                 # This current non-alias status is simply because we did not introduce a
 
2246
                 # chk based subtree format.
 
2247
    )
 
2248
register_metadir(controldir.format_registry, 'development5-subtree',
 
2249
    'bzrlib.repofmt.knitpack_repo.RepositoryFormatPackDevelopment2Subtree',
 
2250
    help='Development format, subtree variant. Can convert data to and '
 
2251
        'from pack-0.92-subtree (and anything compatible with '
 
2252
        'pack-0.92-subtree) format repositories. Repositories and branches in '
 
2253
        'this format can only be read by bzr.dev. Please read '
 
2254
        'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
 
2255
        'before use.',
 
2256
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2257
    tree_format='bzrlib.workingtree.WorkingTreeFormat6',
 
2258
    experimental=True,
 
2259
    hidden=True,
 
2260
    alias=False,
 
2261
    )
 
2262
 
 
2263
# And the development formats above will have aliased one of the following:
 
2264
 
 
2265
# Finally, the current format.
 
2266
register_metadir(controldir.format_registry, '2a',
 
2267
    'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
 
2268
    help='First format for bzr 2.0 series.\n'
 
2269
        'Uses group-compress storage.\n'
 
2270
        'Provides rich roots which are a one-way transition.\n',
 
2271
        # 'storage in packs, 255-way hashed CHK inventory, bencode revision, group compress, '
 
2272
        # 'rich roots. Supported by bzr 1.16 and later.',
 
2273
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2274
    tree_format='bzrlib.workingtree.WorkingTreeFormat6',
 
2275
    experimental=False,
 
2276
    )
 
2277
 
 
2278
# The following format should be an alias for the rich root equivalent 
 
2279
# of the default format
 
2280
register_metadir(controldir.format_registry, 'default-rich-root',
 
2281
    'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
 
2282
    branch_format='bzrlib.branch.BzrBranchFormat7',
 
2283
    tree_format='bzrlib.workingtree.WorkingTreeFormat6',
 
2284
    alias=True,
 
2285
    hidden=True,
 
2286
    help='Same as 2a.')
 
2287
 
 
2288
# The current format that is made on 'bzr init'.
 
2289
format_name = config.GlobalConfig().get_user_option('default_format')
 
2290
if format_name is None:
 
2291
    controldir.format_registry.set_default('2a')
 
2292
else:
 
2293
    controldir.format_registry.set_default(format_name)
 
2294
 
 
2295
# XXX 2010-08-20 JRV: There is still a lot of code relying on
 
2296
# bzrlib.bzrdir.format_registry existing. When BzrDir.create/BzrDir.open/etc
 
2297
# get changed to ControlDir.create/ControlDir.open/etc this should be removed.
 
2298
format_registry = controldir.format_registry