~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/bzrdir.py

  • Committer: Wouter van Heyst
  • Date: 2012-01-25 21:13:15 UTC
  • mto: (6437.3.27 2.5)
  • mto: This revision was merged to the branch mainline in revision 6451.
  • Revision ID: larstiq@larstiq.dyndns.org-20120125211315-ch74doua37bqet0i
mechanically replace file().write() pattern with a with-keyword version

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