86
128
"""Return true if this bzrdir is one whose format we can convert from."""
131
def check_conversion_target(self, target_format):
132
"""Check that a bzrdir as a whole can be converted to a new format."""
133
# The only current restriction is that the repository content can be
134
# fetched compatibly with the target.
135
target_repo_format = target_format.repository_format
137
self.open_repository()._format.check_conversion_target(
139
except errors.NoRepositoryPresent:
140
# No repo, no problem.
90
def _check_supported(format, allow_unsupported):
91
"""Check whether format is a supported format.
93
If allow_unsupported is True, this is a no-op.
144
def _check_supported(format, allow_unsupported,
145
recommend_upgrade=True,
147
"""Give an error or warning on old formats.
149
:param format: may be any kind of format - workingtree, branch,
152
:param allow_unsupported: If true, allow opening
153
formats that are strongly deprecated, and which may
154
have limited functionality.
156
:param recommend_upgrade: If true (default), warn
157
the user through the ui object that they may wish
158
to upgrade the object.
160
# TODO: perhaps move this into a base Format class; it's not BzrDir
161
# specific. mbp 20070323
95
162
if not allow_unsupported and not format.is_supported():
96
163
# see open_downlevel to open legacy branches.
97
164
raise errors.UnsupportedFormatError(format=format)
165
if recommend_upgrade \
166
and getattr(format, 'upgrade_recommended', False):
167
ui.ui_factory.recommend_upgrade(
168
format.get_format_description(),
99
def clone(self, url, revision_id=None, basis=None, force_new_repo=False):
171
def clone(self, url, revision_id=None, force_new_repo=False,
172
preserve_stacking=False):
100
173
"""Clone this bzrdir and its contents to url verbatim.
102
If urls last component does not exist, it will be created.
104
if revision_id is not None, then the clone operation may tune
105
itself to download less data.
106
:param force_new_repo: Do not use a shared repository for the target
107
even if one is available.
110
basis_repo, basis_branch, basis_tree = self._get_basis_components(basis)
111
result = self._format.initialize(url)
175
:param url: The url create the clone at. If url's last component does
176
not exist, it will be created.
177
:param revision_id: The tip revision-id to use for any branch or
178
working tree. If not None, then the clone operation may tune
179
itself to download less data.
180
:param force_new_repo: Do not use a shared repository for the target
181
even if one is available.
182
:param preserve_stacking: When cloning a stacked branch, stack the
183
new branch on top of the other branch's stacked-on branch.
185
return self.clone_on_transport(get_transport(url),
186
revision_id=revision_id,
187
force_new_repo=force_new_repo,
188
preserve_stacking=preserve_stacking)
190
def clone_on_transport(self, transport, revision_id=None,
191
force_new_repo=False, preserve_stacking=False, stacked_on=None,
192
create_prefix=False, use_existing_dir=True):
193
"""Clone this bzrdir and its contents to transport verbatim.
195
:param transport: The transport for the location to produce the clone
196
at. If the target directory does not exist, it will be created.
197
:param revision_id: The tip revision-id to use for any branch or
198
working tree. If not None, then the clone operation may tune
199
itself to download less data.
200
:param force_new_repo: Do not use a shared repository for the target,
201
even if one is available.
202
:param preserve_stacking: When cloning a stacked branch, stack the
203
new branch on top of the other branch's stacked-on branch.
204
:param create_prefix: Create any missing directories leading up to
206
:param use_existing_dir: Use an existing directory if one exists.
208
# Overview: put together a broad description of what we want to end up
209
# with; then make as few api calls as possible to do it.
211
# We may want to create a repo/branch/tree, if we do so what format
212
# would we want for each:
213
require_stacking = (stacked_on is not None)
214
format = self.cloning_metadir(require_stacking)
216
# Figure out what objects we want:
113
218
local_repo = self.find_repository()
114
219
except errors.NoRepositoryPresent:
115
220
local_repo = None
222
local_branch = self.open_branch()
223
except errors.NotBranchError:
226
# enable fallbacks when branch is not a branch reference
227
if local_branch.repository.has_same_location(local_repo):
228
local_repo = local_branch.repository
229
if preserve_stacking:
231
stacked_on = local_branch.get_stacked_on_url()
232
except (errors.UnstackableBranchFormat,
233
errors.UnstackableRepositoryFormat,
236
# Bug: We create a metadir without knowing if it can support stacking,
237
# we should look up the policy needs first, or just use it as a hint,
117
# may need to copy content in
119
result_repo = local_repo.clone(
121
revision_id=revision_id,
123
result_repo.set_make_working_trees(local_repo.make_working_trees())
126
result_repo = result.find_repository()
127
# fetch content this dir needs.
129
# XXX FIXME RBC 20060214 need tests for this when the basis
131
result_repo.fetch(basis_repo, revision_id=revision_id)
240
make_working_trees = local_repo.make_working_trees()
241
want_shared = local_repo.is_shared()
242
repo_format_name = format.repository_format.network_name()
244
make_working_trees = False
246
repo_format_name = None
248
result_repo, result, require_stacking, repository_policy = \
249
format.initialize_on_transport_ex(transport,
250
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
251
force_new_repo=force_new_repo, stacked_on=stacked_on,
252
stack_on_pwd=self.root_transport.base,
253
repo_format_name=repo_format_name,
254
make_working_trees=make_working_trees, shared_repo=want_shared)
257
# If the result repository is in the same place as the
258
# resulting bzr dir, it will have no content, further if the
259
# result is not stacked then we know all content should be
260
# copied, and finally if we are copying up to a specific
261
# revision_id then we can use the pending-ancestry-result which
262
# does not require traversing all of history to describe it.
263
if (result_repo.bzrdir.root_transport.base ==
264
result.root_transport.base and not require_stacking and
265
revision_id is not None):
266
fetch_spec = graph.PendingAncestryResult(
267
[revision_id], local_repo)
268
result_repo.fetch(local_repo, fetch_spec=fetch_spec)
132
270
result_repo.fetch(local_repo, revision_id=revision_id)
133
except errors.NoRepositoryPresent:
134
# needed to make one anyway.
135
result_repo = local_repo.clone(
137
revision_id=revision_id,
139
result_repo.set_make_working_trees(local_repo.make_working_trees())
274
if result_repo is not None:
275
raise AssertionError('result_repo not None(%r)' % result_repo)
140
276
# 1 if there is a branch present
141
277
# make sure its content is available in the target repository
144
self.open_branch().clone(result, revision_id=revision_id)
145
except errors.NotBranchError:
148
self.open_workingtree().clone(result, basis=basis_tree)
279
if local_branch is not None:
280
result_branch = local_branch.clone(result, revision_id=revision_id,
281
repository_policy=repository_policy)
283
# Cheaper to check if the target is not local, than to try making
285
result.root_transport.local_abspath('.')
286
if result_repo is None or result_repo.make_working_trees():
287
self.open_workingtree().clone(result)
149
288
except (errors.NoWorkingTree, errors.NotLocalUrl):
153
def _get_basis_components(self, basis):
154
"""Retrieve the basis components that are available at basis."""
156
return None, None, None
158
basis_tree = basis.open_workingtree()
159
basis_branch = basis_tree.branch
160
basis_repo = basis_branch.repository
161
except (errors.NoWorkingTree, errors.NotLocalUrl):
164
basis_branch = basis.open_branch()
165
basis_repo = basis_branch.repository
166
except errors.NotBranchError:
169
basis_repo = basis.open_repository()
170
except errors.NoRepositoryPresent:
172
return basis_repo, basis_branch, basis_tree
174
292
# TODO: This should be given a Transport, and should chdir up; otherwise
175
293
# this will open a new connection.
176
294
def _make_tail(self, url):
177
head, tail = urlutils.split(url)
178
if tail and tail != '.':
179
t = bzrlib.transport.get_transport(head)
182
except errors.FileExists:
295
t = get_transport(url)
185
# TODO: Should take a Transport
187
def create(cls, base):
299
def create(cls, base, format=None, possible_transports=None):
188
300
"""Create a new BzrDir at the url 'base'.
190
This will call the current default formats initialize with base
191
as the only parameter.
193
If you need a specific format, consider creating an instance
194
of that and calling initialize().
302
:param format: If supplied, the format of branch to create. If not
303
supplied, the default is used.
304
:param possible_transports: If supplied, a list of transports that
305
can be reused to share a remote connection.
196
307
if cls is not BzrDir:
197
raise AssertionError("BzrDir.create always creates the default format, "
198
"not one of %r" % cls)
199
head, tail = urlutils.split(base)
200
if tail and tail != '.':
201
t = bzrlib.transport.get_transport(head)
204
except errors.FileExists:
206
return BzrDirFormat.get_default_format().initialize(safe_unicode(base))
308
raise AssertionError("BzrDir.create always creates the default"
309
" format, not one of %r" % cls)
310
t = get_transport(base, possible_transports)
313
format = BzrDirFormat.get_default_format()
314
return format.initialize_on_transport(t)
317
def find_bzrdirs(transport, evaluate=None, list_current=None):
318
"""Find bzrdirs recursively from current location.
320
This is intended primarily as a building block for more sophisticated
321
functionality, like finding trees under a directory, or finding
322
branches that use a given repository.
323
:param evaluate: An optional callable that yields recurse, value,
324
where recurse controls whether this bzrdir is recursed into
325
and value is the value to yield. By default, all bzrdirs
326
are recursed into, and the return value is the bzrdir.
327
:param list_current: if supplied, use this function to list the current
328
directory, instead of Transport.list_dir
329
:return: a generator of found bzrdirs, or whatever evaluate returns.
331
if list_current is None:
332
def list_current(transport):
333
return transport.list_dir('')
335
def evaluate(bzrdir):
338
pending = [transport]
339
while len(pending) > 0:
340
current_transport = pending.pop()
343
bzrdir = BzrDir.open_from_transport(current_transport)
344
except errors.NotBranchError:
347
recurse, value = evaluate(bzrdir)
350
subdirs = list_current(current_transport)
351
except errors.NoSuchFile:
354
for subdir in sorted(subdirs, reverse=True):
355
pending.append(current_transport.clone(subdir))
358
def find_branches(transport):
359
"""Find all branches under a transport.
361
This will find all branches below the transport, including branches
362
inside other branches. Where possible, it will use
363
Repository.find_branches.
365
To list all the branches that use a particular Repository, see
366
Repository.find_branches
368
def evaluate(bzrdir):
370
repository = bzrdir.open_repository()
371
except errors.NoRepositoryPresent:
374
return False, (None, repository)
376
branch = bzrdir.open_branch()
377
except errors.NotBranchError:
378
return True, (None, None)
380
return True, (branch, None)
382
for branch, repo in BzrDir.find_bzrdirs(transport, evaluate=evaluate):
384
branches.extend(repo.find_branches())
385
if branch is not None:
386
branches.append(branch)
389
def destroy_repository(self):
390
"""Destroy the repository in this BzrDir"""
391
raise NotImplementedError(self.destroy_repository)
208
393
def create_branch(self):
209
394
"""Create a branch in this BzrDir.
211
The bzrdirs format will control what branch format is created.
396
The bzrdir's format will control what branch format is created.
212
397
For more control see BranchFormatXX.create(a_bzrdir).
214
399
raise NotImplementedError(self.create_branch)
401
def destroy_branch(self):
402
"""Destroy the branch in this BzrDir"""
403
raise NotImplementedError(self.destroy_branch)
217
def create_branch_and_repo(base, force_new_repo=False):
406
def create_branch_and_repo(base, force_new_repo=False, format=None):
218
407
"""Create a new BzrDir, Branch and Repository at the url 'base'.
220
This will use the current default BzrDirFormat, and use whatever
409
This will use the current default BzrDirFormat unless one is
410
specified, and use whatever
221
411
repository format that that uses via bzrdir.create_branch and
222
412
create_repository. If a shared repository is available that is used
258
509
The created Branch object is returned.
259
510
If a working tree cannot be made due to base not being a file:// url,
260
no error is raised unless force_new_tree is True, in which case no
511
no error is raised unless force_new_tree is True, in which case no
261
512
data is created on disk and NotLocalUrl is raised.
263
514
:param base: The URL to create the branch at.
264
515
:param force_new_repo: If True a new repository is always created.
265
:param force_new_tree: If True or False force creation of a tree or
516
:param force_new_tree: If True or False force creation of a tree or
266
517
prevent such creation respectively.
267
:param format: Override for the for the bzrdir format to create
518
:param format: Override for the bzrdir format to create.
519
:param possible_transports: An optional reusable transports list.
269
521
if force_new_tree:
270
522
# check for non local urls
271
t = get_transport(safe_unicode(base))
272
if not isinstance(t, LocalTransport):
523
t = get_transport(base, possible_transports)
524
if not isinstance(t, local.LocalTransport):
273
525
raise errors.NotLocalUrl(base)
275
bzrdir = BzrDir.create(base)
277
bzrdir = format.initialize(base)
526
bzrdir = BzrDir.create(base, format, possible_transports)
278
527
repo = bzrdir._find_or_create_repository(force_new_repo)
279
528
result = bzrdir.create_branch()
280
if force_new_tree or (repo.make_working_trees() and
529
if force_new_tree or (repo.make_working_trees() and
281
530
force_new_tree is None):
283
532
bzrdir.create_workingtree()
284
533
except errors.NotLocalUrl:
289
def create_repository(base, shared=False):
290
"""Create a new BzrDir and Repository at the url 'base'.
292
This will use the current default BzrDirFormat, and use whatever
293
repository format that that uses for bzrdirformat.create_repository.
295
;param shared: Create a shared repository rather than a standalone
297
The Repository object is returned.
299
This must be overridden as an instance method in child classes, where
300
it should take no parameters and construct whatever repository format
301
that child class desires.
303
bzrdir = BzrDir.create(base)
304
return bzrdir.create_repository(shared)
307
def create_standalone_workingtree(base):
538
def create_standalone_workingtree(base, format=None):
308
539
"""Create a new BzrDir, WorkingTree, Branch and Repository at 'base'.
310
541
'base' must be a local path or a file:// url.
312
This will use the current default BzrDirFormat, and use whatever
543
This will use the current default BzrDirFormat unless one is
544
specified, and use whatever
313
545
repository format that that uses for bzrdirformat.create_workingtree,
314
546
create_branch and create_repository.
316
The WorkingTree object is returned.
548
:param format: Override for the bzrdir format to create.
549
:return: The WorkingTree object.
318
t = get_transport(safe_unicode(base))
319
if not isinstance(t, LocalTransport):
551
t = get_transport(base)
552
if not isinstance(t, local.LocalTransport):
320
553
raise errors.NotLocalUrl(base)
321
bzrdir = BzrDir.create_branch_and_repo(safe_unicode(base),
322
force_new_repo=True).bzrdir
554
bzrdir = BzrDir.create_branch_and_repo(base,
556
format=format).bzrdir
323
557
return bzrdir.create_workingtree()
325
def create_workingtree(self, revision_id=None):
559
def create_workingtree(self, revision_id=None, from_branch=None,
560
accelerator_tree=None, hardlink=False):
326
561
"""Create a working tree at this BzrDir.
328
revision_id: create it as of this revision id.
563
:param revision_id: create it as of this revision id.
564
:param from_branch: override bzrdir branch (for lightweight checkouts)
565
:param accelerator_tree: A tree which can be used for retrieving file
566
contents more quickly than the revision tree, i.e. a workingtree.
567
The revision tree will be used for cases where accelerator_tree's
568
content is different.
330
570
raise NotImplementedError(self.create_workingtree)
572
def backup_bzrdir(self):
573
"""Backup this bzr control directory.
575
:return: Tuple with old path name and new path name
577
pb = ui.ui_factory.nested_progress_bar()
579
# FIXME: bug 300001 -- the backup fails if the backup directory
580
# already exists, but it should instead either remove it or make
581
# a new backup directory.
583
# FIXME: bug 262450 -- the backup directory should have the same
584
# permissions as the .bzr directory (probably a bug in copy_tree)
585
old_path = self.root_transport.abspath('.bzr')
586
new_path = self.root_transport.abspath('backup.bzr')
587
pb.note('making backup of %s' % (old_path,))
588
pb.note(' to %s' % (new_path,))
589
self.root_transport.copy_tree('.bzr', 'backup.bzr')
590
return (old_path, new_path)
594
def retire_bzrdir(self, limit=10000):
595
"""Permanently disable the bzrdir.
597
This is done by renaming it to give the user some ability to recover
598
if there was a problem.
600
This will have horrible consequences if anyone has anything locked or
602
:param limit: number of times to retry
607
to_path = '.bzr.retired.%d' % i
608
self.root_transport.rename('.bzr', to_path)
609
note("renamed %s to %s"
610
% (self.root_transport.abspath('.bzr'), to_path))
612
except (errors.TransportError, IOError, errors.PathError):
619
def destroy_workingtree(self):
620
"""Destroy the working tree at this BzrDir.
622
Formats that do not support this may raise UnsupportedOperation.
624
raise NotImplementedError(self.destroy_workingtree)
626
def destroy_workingtree_metadata(self):
627
"""Destroy the control files for the working tree at this BzrDir.
629
The contents of working tree files are not affected.
630
Formats that do not support this may raise UnsupportedOperation.
632
raise NotImplementedError(self.destroy_workingtree_metadata)
634
def _find_containing(self, evaluate):
635
"""Find something in a containing control directory.
637
This method will scan containing control dirs, until it finds what
638
it is looking for, decides that it will never find it, or runs out
639
of containing control directories to check.
641
It is used to implement find_repository and
642
determine_repository_policy.
644
:param evaluate: A function returning (value, stop). If stop is True,
645
the value will be returned.
649
result, stop = evaluate(found_bzrdir)
652
next_transport = found_bzrdir.root_transport.clone('..')
653
if (found_bzrdir.root_transport.base == next_transport.base):
654
# top of the file system
656
# find the next containing bzrdir
658
found_bzrdir = BzrDir.open_containing_from_transport(
660
except errors.NotBranchError:
332
663
def find_repository(self):
333
"""Find the repository that should be used for a_bzrdir.
664
"""Find the repository that should be used.
335
666
This does not require a branch as we use it to find the repo for
336
667
new branches as well as to hook existing branches up to their
340
return self.open_repository()
341
except errors.NoRepositoryPresent:
343
next_transport = self.root_transport.clone('..')
345
# find the next containing bzrdir
347
found_bzrdir = BzrDir.open_containing_from_transport(
349
except errors.NotBranchError:
351
raise errors.NoRepositoryPresent(self)
670
def usable_repository(found_bzrdir):
352
671
# does it have a repository ?
354
673
repository = found_bzrdir.open_repository()
355
674
except errors.NoRepositoryPresent:
356
next_transport = found_bzrdir.root_transport.clone('..')
357
if (found_bzrdir.root_transport.base == next_transport.base):
358
# top of the file system
362
if ((found_bzrdir.root_transport.base ==
363
self.root_transport.base) or repository.is_shared()):
676
if found_bzrdir.root_transport.base == self.root_transport.base:
677
return repository, True
678
elif repository.is_shared():
679
return repository, True
366
raise errors.NoRepositoryPresent(self)
367
raise errors.NoRepositoryPresent(self)
683
found_repo = self._find_containing(usable_repository)
684
if found_repo is None:
685
raise errors.NoRepositoryPresent(self)
688
def get_branch_reference(self):
689
"""Return the referenced URL for the branch in this bzrdir.
691
:raises NotBranchError: If there is no Branch.
692
:return: The URL the branch in this bzrdir references if it is a
693
reference branch, or None for regular branches.
369
697
def get_branch_transport(self, branch_format):
370
698
"""Get the transport for use by branch format in this BzrDir.
452
833
def open_unsupported(base):
453
834
"""Open a branch which is not supported."""
454
835
return BzrDir.open(base, _unsupported=True)
457
def open(base, _unsupported=False):
458
"""Open an existing bzrdir, rooted at 'base' (url)
460
_unsupported is a private parameter to the BzrDir class.
462
t = get_transport(base)
463
mutter("trying to open %r with transport %r", base, t)
464
format = BzrDirFormat.find_format(t)
838
def open(base, _unsupported=False, possible_transports=None):
839
"""Open an existing bzrdir, rooted at 'base' (url).
841
:param _unsupported: a private parameter to the BzrDir class.
843
t = get_transport(base, possible_transports=possible_transports)
844
return BzrDir.open_from_transport(t, _unsupported=_unsupported)
847
def open_from_transport(transport, _unsupported=False,
848
_server_formats=True):
849
"""Open a bzrdir within a particular directory.
851
:param transport: Transport containing the bzrdir.
852
:param _unsupported: private.
854
for hook in BzrDir.hooks['pre_open']:
856
# Keep initial base since 'transport' may be modified while following
858
base = transport.base
859
def find_format(transport):
860
return transport, BzrDirFormat.find_format(
861
transport, _server_formats=_server_formats)
863
def redirected(transport, e, redirection_notice):
864
redirected_transport = transport._redirected_to(e.source, e.target)
865
if redirected_transport is None:
866
raise errors.NotBranchError(base)
867
note('%s is%s redirected to %s',
868
transport.base, e.permanently, redirected_transport.base)
869
return redirected_transport
872
transport, format = do_catching_redirections(find_format,
875
except errors.TooManyRedirections:
876
raise errors.NotBranchError(base)
465
878
BzrDir._check_supported(format, _unsupported)
466
return format.open(t, _found=True)
879
return format.open(transport, _found=True)
468
def open_branch(self, unsupported=False):
881
def open_branch(self, unsupported=False, ignore_fallbacks=False):
469
882
"""Open the branch object at this BzrDir if one is present.
471
884
If unsupported is True, then no longer supported branch formats can
474
887
TODO: static convenience version of this?
476
889
raise NotImplementedError(self.open_branch)
479
def open_containing(url):
892
def open_containing(url, possible_transports=None):
480
893
"""Open an existing branch which contains url.
482
895
:param url: url to search from.
483
896
See open_containing_from_transport for more detail.
485
return BzrDir.open_containing_from_transport(get_transport(url))
898
transport = get_transport(url, possible_transports)
899
return BzrDir.open_containing_from_transport(transport)
488
902
def open_containing_from_transport(a_transport):
489
"""Open an existing branch which contains a_transport.base
903
"""Open an existing branch which contains a_transport.base.
491
905
This probes for a branch at a_transport, and searches upwards from there.
493
907
Basically we keep looking up until we find the control directory or
494
908
run into the root. If there isn't one, raises NotBranchError.
495
If there is one and it is either an unrecognised format or an unsupported
909
If there is one and it is either an unrecognised format or an unsupported
496
910
format, UnknownFormatError or UnsupportedFormatError are raised.
497
911
If there is one, it is returned, along with the unused portion of url.
499
:return: The BzrDir that contains the path, and a Unicode path
913
:return: The BzrDir that contains the path, and a Unicode path
500
914
for the rest of the URL.
502
916
# this gets the normalised url back. I.e. '.' -> the full path.
503
917
url = a_transport.base
506
format = BzrDirFormat.find_format(a_transport)
507
BzrDir._check_supported(format, False)
508
return format.open(a_transport), urlutils.unescape(a_transport.relpath(url))
920
result = BzrDir.open_from_transport(a_transport)
921
return result, urlutils.unescape(a_transport.relpath(url))
509
922
except errors.NotBranchError, e:
510
## mutter('not a branch in: %r %s', a_transport.base, e)
512
new_t = a_transport.clone('..')
925
new_t = a_transport.clone('..')
926
except errors.InvalidURLJoin:
927
# reached the root, whatever that may be
928
raise errors.NotBranchError(path=url)
513
929
if new_t.base == a_transport.base:
514
930
# reached the root, whatever that may be
515
931
raise errors.NotBranchError(path=url)
516
932
a_transport = new_t
934
def _get_tree_branch(self):
935
"""Return the branch and tree, if any, for this bzrdir.
937
Return None for tree if not present or inaccessible.
938
Raise NotBranchError if no branch is present.
939
:return: (tree, branch)
942
tree = self.open_workingtree()
943
except (errors.NoWorkingTree, errors.NotLocalUrl):
945
branch = self.open_branch()
951
def open_tree_or_branch(klass, location):
952
"""Return the branch and working tree at a location.
954
If there is no tree at the location, tree will be None.
955
If there is no branch at the location, an exception will be
957
:return: (tree, branch)
959
bzrdir = klass.open(location)
960
return bzrdir._get_tree_branch()
963
def open_containing_tree_or_branch(klass, location):
964
"""Return the branch and working tree contained by a location.
966
Returns (tree, branch, relpath).
967
If there is no tree at containing the location, tree will be None.
968
If there is no branch containing the location, an exception will be
970
relpath is the portion of the path that is contained by the branch.
972
bzrdir, relpath = klass.open_containing(location)
973
tree, branch = bzrdir._get_tree_branch()
974
return tree, branch, relpath
977
def open_containing_tree_branch_or_repository(klass, location):
978
"""Return the working tree, branch and repo contained by a location.
980
Returns (tree, branch, repository, relpath).
981
If there is no tree containing the location, tree will be None.
982
If there is no branch containing the location, branch will be None.
983
If there is no repository containing the location, repository will be
985
relpath is the portion of the path that is contained by the innermost
988
If no tree, branch or repository is found, a NotBranchError is raised.
990
bzrdir, relpath = klass.open_containing(location)
992
tree, branch = bzrdir._get_tree_branch()
993
except errors.NotBranchError:
995
repo = bzrdir.find_repository()
996
return None, None, repo, relpath
997
except (errors.NoRepositoryPresent):
998
raise errors.NotBranchError(location)
999
return tree, branch, branch.repository, relpath
518
1001
def open_repository(self, _unsupported=False):
519
1002
"""Open the repository object at this BzrDir if one is present.
521
This will not follow the Branch object pointer - its strictly a direct
1004
This will not follow the Branch object pointer - it's strictly a direct
522
1005
open facility. Most client code should use open_branch().repository to
523
1006
get at a repository.
525
_unsupported is a private parameter, not part of the api.
1008
:param _unsupported: a private parameter, not part of the api.
526
1009
TODO: static convenience version of this?
528
1011
raise NotImplementedError(self.open_repository)
530
def open_workingtree(self, _unsupported=False):
1013
def open_workingtree(self, _unsupported=False,
1014
recommend_upgrade=True, from_branch=None):
531
1015
"""Open the workingtree object at this BzrDir if one is present.
533
TODO: static convenience version of this?
1017
:param recommend_upgrade: Optional keyword parameter, when True (the
1018
default), emit through the ui module a recommendation that the user
1019
upgrade the working tree when the workingtree being opened is old
1020
(but still fully supported).
1021
:param from_branch: override bzrdir branch (for lightweight checkouts)
535
1023
raise NotImplementedError(self.open_workingtree)
537
1025
def has_branch(self):
538
1026
"""Tell if this bzrdir contains a branch.
540
1028
Note: if you're going to open the branch, you should just go ahead
541
and try, and not ask permission first. (This method just opens the
542
branch and discards it, and that's somewhat expensive.)
1029
and try, and not ask permission first. (This method just opens the
1030
branch and discards it, and that's somewhat expensive.)
545
1033
self.open_branch()
577
1134
if revision_id is not None, then the clone operation may tune
578
1135
itself to download less data.
1136
:param accelerator_tree: A tree which can be used for retrieving file
1137
contents more quickly than the revision tree, i.e. a workingtree.
1138
The revision tree will be used for cases where accelerator_tree's
1139
content is different.
1140
:param hardlink: If true, hard-link files from accelerator_tree,
1142
:param stacked: If true, create a stacked branch referring to the
1143
location of this control directory.
1144
:param create_tree_if_local: If true, a working-tree will be created
1145
when working locally.
581
result = self._format.initialize(url)
582
basis_repo, basis_branch, basis_tree = self._get_basis_components(basis)
584
source_branch = self.open_branch()
1147
target_transport = get_transport(url, possible_transports)
1148
target_transport.ensure_base()
1149
cloning_format = self.cloning_metadir(stacked)
1150
# Create/update the result branch
1151
result = cloning_format.initialize_on_transport(target_transport)
1152
# if a stacked branch wasn't requested, we don't create one
1153
# even if the origin was stacked
1154
stacked_branch_url = None
1155
if source_branch is not None:
1157
stacked_branch_url = self.root_transport.base
585
1158
source_repository = source_branch.repository
1161
source_branch = self.open_branch()
1162
source_repository = source_branch.repository
1164
stacked_branch_url = self.root_transport.base
1165
except errors.NotBranchError:
1166
source_branch = None
1168
source_repository = self.open_repository()
1169
except errors.NoRepositoryPresent:
1170
source_repository = None
1171
repository_policy = result.determine_repository_policy(
1172
force_new_repo, stacked_branch_url, require_stacking=stacked)
1173
result_repo, is_new_repo = repository_policy.acquire_repository()
1174
if is_new_repo and revision_id is not None and not stacked:
1175
fetch_spec = graph.PendingAncestryResult(
1176
[revision_id], source_repository)
1179
if source_repository is not None:
1180
# Fetch while stacked to prevent unstacked fetch from
1182
if fetch_spec is None:
1183
result_repo.fetch(source_repository, revision_id=revision_id)
1185
result_repo.fetch(source_repository, fetch_spec=fetch_spec)
1187
if source_branch is None:
1188
# this is for sprouting a bzrdir without a branch; is that
1190
# Not especially, but it's part of the contract.
1191
result_branch = result.create_branch()
1193
result_branch = source_branch.sprout(result,
1194
revision_id=revision_id, repository_policy=repository_policy)
1195
mutter("created new branch %r" % (result_branch,))
1197
# Create/update the result working tree
1198
if (create_tree_if_local and
1199
isinstance(target_transport, local.LocalTransport) and
1200
(result_repo is None or result_repo.make_working_trees())):
1201
wt = result.create_workingtree(accelerator_tree=accelerator_tree,
1205
if wt.path2id('') is None:
1207
wt.set_root_id(self.open_workingtree.get_root_id())
1208
except errors.NoWorkingTree:
1214
if recurse == 'down':
1216
basis = wt.basis_tree()
1218
subtrees = basis.iter_references()
1219
elif result_branch is not None:
1220
basis = result_branch.basis_tree()
1222
subtrees = basis.iter_references()
1223
elif source_branch is not None:
1224
basis = source_branch.basis_tree()
1226
subtrees = basis.iter_references()
1231
for path, file_id in subtrees:
1232
target = urlutils.join(url, urlutils.escape(path))
1233
sublocation = source_branch.reference_parent(file_id, path)
1234
sublocation.bzrdir.sprout(target,
1235
basis.get_reference_revision(file_id, path),
1236
force_new_repo=force_new_repo, recurse=recurse,
1239
if basis is not None:
1243
def push_branch(self, source, revision_id=None, overwrite=False,
1244
remember=False, create_prefix=False):
1245
"""Push the source branch into this BzrDir."""
1247
# If we can open a branch, use its direct repository, otherwise see
1248
# if there is a repository without a branch.
1250
br_to = self.open_branch()
586
1251
except errors.NotBranchError:
589
source_repository = self.open_repository()
590
except errors.NoRepositoryPresent:
591
# copy the entire basis one if there is one
592
# but there is no repository.
593
source_repository = basis_repo
598
result_repo = result.find_repository()
599
except errors.NoRepositoryPresent:
601
if source_repository is None and result_repo is not None:
603
elif source_repository is None and result_repo is None:
604
# no repo available, make a new one
605
result.create_repository()
606
elif source_repository is not None and result_repo is None:
607
# have source, and want to make a new target repo
608
# we don't clone the repo because that preserves attributes
609
# like is_shared(), and we have not yet implemented a
610
# repository sprout().
611
result_repo = result.create_repository()
612
if result_repo is not None:
613
# fetch needed content into target.
615
# XXX FIXME RBC 20060214 need tests for this when the basis
617
result_repo.fetch(basis_repo, revision_id=revision_id)
618
result_repo.fetch(source_repository, revision_id=revision_id)
619
if source_branch is not None:
620
source_branch.sprout(result, revision_id=revision_id)
622
result.create_branch()
623
# TODO: jam 20060426 we probably need a test in here in the
624
# case that the newly sprouted branch is a remote one
625
if result_repo is None or result_repo.make_working_trees():
626
result.create_workingtree()
1252
# Didn't find a branch, can we find a repository?
1253
repository_to = self.find_repository()
1255
# Found a branch, so we must have found a repository
1256
repository_to = br_to.repository
1258
push_result = PushResult()
1259
push_result.source_branch = source
1261
# We have a repository but no branch, copy the revisions, and then
1263
repository_to.fetch(source.repository, revision_id=revision_id)
1264
br_to = source.clone(self, revision_id=revision_id)
1265
if source.get_push_location() is None or remember:
1266
source.set_push_location(br_to.base)
1267
push_result.stacked_on = None
1268
push_result.branch_push_result = None
1269
push_result.old_revno = None
1270
push_result.old_revid = _mod_revision.NULL_REVISION
1271
push_result.target_branch = br_to
1272
push_result.master_branch = None
1273
push_result.workingtree_updated = False
1275
# We have successfully opened the branch, remember if necessary:
1276
if source.get_push_location() is None or remember:
1277
source.set_push_location(br_to.base)
1279
tree_to = self.open_workingtree()
1280
except errors.NotLocalUrl:
1281
push_result.branch_push_result = source.push(br_to,
1282
overwrite, stop_revision=revision_id)
1283
push_result.workingtree_updated = False
1284
except errors.NoWorkingTree:
1285
push_result.branch_push_result = source.push(br_to,
1286
overwrite, stop_revision=revision_id)
1287
push_result.workingtree_updated = None # Not applicable
1289
tree_to.lock_write()
1291
push_result.branch_push_result = source.push(
1292
tree_to.branch, overwrite, stop_revision=revision_id)
1296
push_result.workingtree_updated = True
1297
push_result.old_revno = push_result.branch_push_result.old_revno
1298
push_result.old_revid = push_result.branch_push_result.old_revid
1299
push_result.target_branch = \
1300
push_result.branch_push_result.target_branch
1304
class BzrDirHooks(hooks.Hooks):
1305
"""Hooks for BzrDir operations."""
1308
"""Create the default hooks."""
1309
hooks.Hooks.__init__(self)
1310
self.create_hook(hooks.HookPoint('pre_open',
1311
"Invoked before attempting to open a BzrDir with the transport "
1312
"that the open will use.", (1, 14), None))
1314
# install the default hooks
1315
BzrDir.hooks = BzrDirHooks()
630
1318
class BzrDirPreSplitOut(BzrDir):
1000
1835
current default format. In the case of plugins we can/should provide
1001
1836
some means for them to extend the range of returnable converters.
1003
:param format: Optional format to override the default format of the
1838
:param format: Optional format to override the default format of the
1006
1841
raise NotImplementedError(self.get_converter)
1008
def initialize(self, url):
1843
def initialize(self, url, possible_transports=None):
1009
1844
"""Create a bzr control dir at this url and return an opened copy.
1846
While not deprecated, this method is very specific and its use will
1847
lead to many round trips to setup a working environment. See
1848
initialize_on_transport_ex for a [nearly] all-in-one method.
1011
1850
Subclasses should typically override initialize_on_transport
1012
1851
instead of this method.
1014
return self.initialize_on_transport(get_transport(url))
1853
return self.initialize_on_transport(get_transport(url,
1854
possible_transports))
1016
1856
def initialize_on_transport(self, transport):
1017
1857
"""Initialize a new bzrdir in the base directory of a Transport."""
1018
# Since we don't have a .bzr directory, inherit the
1859
# can we hand off the request to the smart server rather than using
1861
client_medium = transport.get_smart_medium()
1862
except errors.NoSmartMedium:
1863
return self._initialize_on_transport_vfs(transport)
1865
# Current RPC's only know how to create bzr metadir1 instances, so
1866
# we still delegate to vfs methods if the requested format is not a
1868
if type(self) != BzrDirMetaFormat1:
1869
return self._initialize_on_transport_vfs(transport)
1870
remote_format = RemoteBzrDirFormat()
1871
self._supply_sub_formats_to(remote_format)
1872
return remote_format.initialize_on_transport(transport)
1874
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
1875
create_prefix=False, force_new_repo=False, stacked_on=None,
1876
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
1877
shared_repo=False, vfs_only=False):
1878
"""Create this format on transport.
1880
The directory to initialize will be created.
1882
:param force_new_repo: Do not use a shared repository for the target,
1883
even if one is available.
1884
:param create_prefix: Create any missing directories leading up to
1886
:param use_existing_dir: Use an existing directory if one exists.
1887
:param stacked_on: A url to stack any created branch on, None to follow
1888
any target stacking policy.
1889
:param stack_on_pwd: If stack_on is relative, the location it is
1891
:param repo_format_name: If non-None, a repository will be
1892
made-or-found. Should none be found, or if force_new_repo is True
1893
the repo_format_name is used to select the format of repository to
1895
:param make_working_trees: Control the setting of make_working_trees
1896
for a new shared repository when one is made. None to use whatever
1897
default the format has.
1898
:param shared_repo: Control whether made repositories are shared or
1900
:param vfs_only: If True do not attempt to use a smart server
1901
:return: repo, bzrdir, require_stacking, repository_policy. repo is
1902
None if none was created or found, bzrdir is always valid.
1903
require_stacking is the result of examining the stacked_on
1904
parameter and any stacking policy found for the target.
1907
# Try to hand off to a smart server
1909
client_medium = transport.get_smart_medium()
1910
except errors.NoSmartMedium:
1913
# TODO: lookup the local format from a server hint.
1914
remote_dir_format = RemoteBzrDirFormat()
1915
remote_dir_format._network_name = self.network_name()
1916
self._supply_sub_formats_to(remote_dir_format)
1917
return remote_dir_format.initialize_on_transport_ex(transport,
1918
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
1919
force_new_repo=force_new_repo, stacked_on=stacked_on,
1920
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
1921
make_working_trees=make_working_trees, shared_repo=shared_repo)
1922
# XXX: Refactor the create_prefix/no_create_prefix code into a
1923
# common helper function
1924
# The destination may not exist - if so make it according to policy.
1925
def make_directory(transport):
1926
transport.mkdir('.')
1928
def redirected(transport, e, redirection_notice):
1929
note(redirection_notice)
1930
return transport._redirected_to(e.source, e.target)
1932
transport = do_catching_redirections(make_directory, transport,
1934
except errors.FileExists:
1935
if not use_existing_dir:
1937
except errors.NoSuchFile:
1938
if not create_prefix:
1940
transport.create_prefix()
1942
require_stacking = (stacked_on is not None)
1943
# Now the target directory exists, but doesn't have a .bzr
1944
# directory. So we need to create it, along with any work to create
1945
# all of the dependent branches, etc.
1947
result = self.initialize_on_transport(transport)
1948
if repo_format_name:
1950
# use a custom format
1951
result._format.repository_format = \
1952
repository.network_format_registry.get(repo_format_name)
1953
except AttributeError:
1954
# The format didn't permit it to be set.
1956
# A repository is desired, either in-place or shared.
1957
repository_policy = result.determine_repository_policy(
1958
force_new_repo, stacked_on, stack_on_pwd,
1959
require_stacking=require_stacking)
1960
result_repo, is_new_repo = repository_policy.acquire_repository(
1961
make_working_trees, shared_repo)
1962
if not require_stacking and repository_policy._require_stacking:
1963
require_stacking = True
1964
result._format.require_stacking()
1965
result_repo.lock_write()
1968
repository_policy = None
1969
return result_repo, result, require_stacking, repository_policy
1971
def _initialize_on_transport_vfs(self, transport):
1972
"""Initialize a new bzrdir using VFS calls.
1974
:param transport: The transport to create the .bzr directory in.
1977
# Since we are creating a .bzr directory, inherit the
1019
1978
# mode from the root directory
1020
temp_control = LockableFiles(transport, '', TransportLock)
1979
temp_control = lockable_files.LockableFiles(transport,
1980
'', lockable_files.TransportLock)
1021
1981
temp_control._transport.mkdir('.bzr',
1022
1982
# FIXME: RBC 20060121 don't peek under
1024
1984
mode=temp_control._dir_mode)
1985
if sys.platform == 'win32' and isinstance(transport, local.LocalTransport):
1986
win32utils.set_file_attr_hidden(transport._abspath('.bzr'))
1025
1987
file_mode = temp_control._file_mode
1026
1988
del temp_control
1027
mutter('created control directory in ' + transport.base)
1028
control = transport.clone('.bzr')
1029
utf8_files = [('README',
1030
"This is a Bazaar-NG control directory.\n"
1031
"Do not change any files in this directory.\n"),
1989
bzrdir_transport = transport.clone('.bzr')
1990
utf8_files = [('README',
1991
"This is a Bazaar control directory.\n"
1992
"Do not change any files in this directory.\n"
1993
"See http://bazaar-vcs.org/ for more information about Bazaar.\n"),
1032
1994
('branch-format', self.get_format_string()),
1034
1996
# NB: no need to escape relative paths that are url safe.
1035
control_files = LockableFiles(control, self._lock_file_name,
1997
control_files = lockable_files.LockableFiles(bzrdir_transport,
1998
self._lock_file_name, self._lock_class)
1037
1999
control_files.create_lock()
1038
2000
control_files.lock_write()
1040
for file, content in utf8_files:
1041
control_files.put_utf8(file, content)
2002
for (filename, content) in utf8_files:
2003
bzrdir_transport.put_bytes(filename, content,
1043
2006
control_files.unlock()
1044
2007
return self.open(transport, _found=True)
1810
3021
self.pb.note('starting repository conversion')
1811
3022
converter = CopyConverter(self.target_format.repository_format)
1812
3023
converter.convert(repo, pb)
3025
branch = self.bzrdir.open_branch()
3026
except errors.NotBranchError:
3029
# TODO: conversions of Branch and Tree should be done by
3030
# InterXFormat lookups/some sort of registry.
3031
# Avoid circular imports
3032
from bzrlib import branch as _mod_branch
3033
old = branch._format.__class__
3034
new = self.target_format.get_branch_format().__class__
3036
if (old == _mod_branch.BzrBranchFormat5 and
3037
new in (_mod_branch.BzrBranchFormat6,
3038
_mod_branch.BzrBranchFormat7,
3039
_mod_branch.BzrBranchFormat8)):
3040
branch_converter = _mod_branch.Converter5to6()
3041
elif (old == _mod_branch.BzrBranchFormat6 and
3042
new in (_mod_branch.BzrBranchFormat7,
3043
_mod_branch.BzrBranchFormat8)):
3044
branch_converter = _mod_branch.Converter6to7()
3045
elif (old == _mod_branch.BzrBranchFormat7 and
3046
new is _mod_branch.BzrBranchFormat8):
3047
branch_converter = _mod_branch.Converter7to8()
3049
raise errors.BadConversionTarget("No converter", new,
3051
branch_converter.convert(branch)
3052
branch = self.bzrdir.open_branch()
3053
old = branch._format.__class__
3055
tree = self.bzrdir.open_workingtree(recommend_upgrade=False)
3056
except (errors.NoWorkingTree, errors.NotLocalUrl):
3059
# TODO: conversions of Branch and Tree should be done by
3060
# InterXFormat lookups
3061
if (isinstance(tree, workingtree.WorkingTree3) and
3062
not isinstance(tree, workingtree_4.DirStateWorkingTree) and
3063
isinstance(self.target_format.workingtree_format,
3064
workingtree_4.DirStateWorkingTreeFormat)):
3065
workingtree_4.Converter3to4().convert(tree)
3066
if (isinstance(tree, workingtree_4.DirStateWorkingTree) and
3067
not isinstance(tree, workingtree_4.WorkingTree5) and
3068
isinstance(self.target_format.workingtree_format,
3069
workingtree_4.WorkingTreeFormat5)):
3070
workingtree_4.Converter4to5().convert(tree)
3071
if (isinstance(tree, workingtree_4.DirStateWorkingTree) and
3072
not isinstance(tree, workingtree_4.WorkingTree6) and
3073
isinstance(self.target_format.workingtree_format,
3074
workingtree_4.WorkingTreeFormat6)):
3075
workingtree_4.Converter4or5to6().convert(tree)
1813
3076
return to_convert
3079
# This is not in remote.py because it's relatively small, and needs to be
3080
# registered. Putting it in remote.py creates a circular import problem.
3081
# we can make it a lazy object if the control formats is turned into something
3083
class RemoteBzrDirFormat(BzrDirMetaFormat1):
3084
"""Format representing bzrdirs accessed via a smart server"""
3087
BzrDirMetaFormat1.__init__(self)
3088
self._network_name = None
3090
def get_format_description(self):
3091
return 'bzr remote bzrdir'
3093
def get_format_string(self):
3094
raise NotImplementedError(self.get_format_string)
3096
def network_name(self):
3097
if self._network_name:
3098
return self._network_name
3100
raise AssertionError("No network name set.")
3103
def probe_transport(klass, transport):
3104
"""Return a RemoteBzrDirFormat object if it looks possible."""
3106
medium = transport.get_smart_medium()
3107
except (NotImplementedError, AttributeError,
3108
errors.TransportNotPossible, errors.NoSmartMedium,
3109
errors.SmartProtocolError):
3110
# no smart server, so not a branch for this format type.
3111
raise errors.NotBranchError(path=transport.base)
3113
# Decline to open it if the server doesn't support our required
3114
# version (3) so that the VFS-based transport will do it.
3115
if medium.should_probe():
3117
server_version = medium.protocol_version()
3118
except errors.SmartProtocolError:
3119
# Apparently there's no usable smart server there, even though
3120
# the medium supports the smart protocol.
3121
raise errors.NotBranchError(path=transport.base)
3122
if server_version != '2':
3123
raise errors.NotBranchError(path=transport.base)
3126
def initialize_on_transport(self, transport):
3128
# hand off the request to the smart server
3129
client_medium = transport.get_smart_medium()
3130
except errors.NoSmartMedium:
3131
# TODO: lookup the local format from a server hint.
3132
local_dir_format = BzrDirMetaFormat1()
3133
return local_dir_format.initialize_on_transport(transport)
3134
client = _SmartClient(client_medium)
3135
path = client.remote_path_from_transport(transport)
3137
response = client.call('BzrDirFormat.initialize', path)
3138
except errors.ErrorFromSmartServer, err:
3139
remote._translate_error(err, path=path)
3140
if response[0] != 'ok':
3141
raise errors.SmartProtocolError('unexpected response code %s' % (response,))
3142
format = RemoteBzrDirFormat()
3143
self._supply_sub_formats_to(format)
3144
return remote.RemoteBzrDir(transport, format)
3146
def parse_NoneTrueFalse(self, arg):
3153
raise AssertionError("invalid arg %r" % arg)
3155
def _serialize_NoneTrueFalse(self, arg):
3162
def _serialize_NoneString(self, arg):
3165
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
3166
create_prefix=False, force_new_repo=False, stacked_on=None,
3167
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
3170
# hand off the request to the smart server
3171
client_medium = transport.get_smart_medium()
3172
except errors.NoSmartMedium:
3175
# Decline to open it if the server doesn't support our required
3176
# version (3) so that the VFS-based transport will do it.
3177
if client_medium.should_probe():
3179
server_version = client_medium.protocol_version()
3180
if server_version != '2':
3184
except errors.SmartProtocolError:
3185
# Apparently there's no usable smart server there, even though
3186
# the medium supports the smart protocol.
3191
client = _SmartClient(client_medium)
3192
path = client.remote_path_from_transport(transport)
3193
if client_medium._is_remote_before((1, 16)):
3196
# TODO: lookup the local format from a server hint.
3197
local_dir_format = BzrDirMetaFormat1()
3198
self._supply_sub_formats_to(local_dir_format)
3199
return local_dir_format.initialize_on_transport_ex(transport,
3200
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3201
force_new_repo=force_new_repo, stacked_on=stacked_on,
3202
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3203
make_working_trees=make_working_trees, shared_repo=shared_repo,
3205
return self._initialize_on_transport_ex_rpc(client, path, transport,
3206
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3207
stack_on_pwd, repo_format_name, make_working_trees, shared_repo)
3209
def _initialize_on_transport_ex_rpc(self, client, path, transport,
3210
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3211
stack_on_pwd, repo_format_name, make_working_trees, shared_repo):
3213
args.append(self._serialize_NoneTrueFalse(use_existing_dir))
3214
args.append(self._serialize_NoneTrueFalse(create_prefix))
3215
args.append(self._serialize_NoneTrueFalse(force_new_repo))
3216
args.append(self._serialize_NoneString(stacked_on))
3217
# stack_on_pwd is often/usually our transport
3220
stack_on_pwd = transport.relpath(stack_on_pwd)
3221
if not stack_on_pwd:
3223
except errors.PathNotChild:
3225
args.append(self._serialize_NoneString(stack_on_pwd))
3226
args.append(self._serialize_NoneString(repo_format_name))
3227
args.append(self._serialize_NoneTrueFalse(make_working_trees))
3228
args.append(self._serialize_NoneTrueFalse(shared_repo))
3229
if self._network_name is None:
3230
self._network_name = \
3231
BzrDirFormat.get_default_format().network_name()
3233
response = client.call('BzrDirFormat.initialize_ex_1.16',
3234
self.network_name(), path, *args)
3235
except errors.UnknownSmartMethod:
3236
client._medium._remember_remote_is_before((1,16))
3237
local_dir_format = BzrDirMetaFormat1()
3238
self._supply_sub_formats_to(local_dir_format)
3239
return local_dir_format.initialize_on_transport_ex(transport,
3240
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3241
force_new_repo=force_new_repo, stacked_on=stacked_on,
3242
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3243
make_working_trees=make_working_trees, shared_repo=shared_repo,
3245
except errors.ErrorFromSmartServer, err:
3246
remote._translate_error(err, path=path)
3247
repo_path = response[0]
3248
bzrdir_name = response[6]
3249
require_stacking = response[7]
3250
require_stacking = self.parse_NoneTrueFalse(require_stacking)
3251
format = RemoteBzrDirFormat()
3252
format._network_name = bzrdir_name
3253
self._supply_sub_formats_to(format)
3254
bzrdir = remote.RemoteBzrDir(transport, format, _client=client)
3256
repo_format = remote.response_tuple_to_repo_format(response[1:])
3257
if repo_path == '.':
3260
repo_bzrdir_format = RemoteBzrDirFormat()
3261
repo_bzrdir_format._network_name = response[5]
3262
repo_bzr = remote.RemoteBzrDir(transport.clone(repo_path),
3266
final_stack = response[8] or None
3267
final_stack_pwd = response[9] or None
3269
final_stack_pwd = urlutils.join(
3270
transport.base, final_stack_pwd)
3271
remote_repo = remote.RemoteRepository(repo_bzr, repo_format)
3272
if len(response) > 10:
3273
# Updated server verb that locks remotely.
3274
repo_lock_token = response[10] or None
3275
remote_repo.lock_write(repo_lock_token, _skip_rpc=True)
3277
remote_repo.dont_leave_lock_in_place()
3279
remote_repo.lock_write()
3280
policy = UseExistingRepository(remote_repo, final_stack,
3281
final_stack_pwd, require_stacking)
3282
policy.acquire_repository()
3286
bzrdir._format.set_branch_format(self.get_branch_format())
3287
if require_stacking:
3288
# The repo has already been created, but we need to make sure that
3289
# we'll make a stackable branch.
3290
bzrdir._format.require_stacking(_skip_repo=True)
3291
return remote_repo, bzrdir, require_stacking, policy
3293
def _open(self, transport):
3294
return remote.RemoteBzrDir(transport, self)
3296
def __eq__(self, other):
3297
if not isinstance(other, RemoteBzrDirFormat):
3299
return self.get_format_description() == other.get_format_description()
3301
def __return_repository_format(self):
3302
# Always return a RemoteRepositoryFormat object, but if a specific bzr
3303
# repository format has been asked for, tell the RemoteRepositoryFormat
3304
# that it should use that for init() etc.
3305
result = remote.RemoteRepositoryFormat()
3306
custom_format = getattr(self, '_repository_format', None)
3308
if isinstance(custom_format, remote.RemoteRepositoryFormat):
3309
return custom_format
3311
# We will use the custom format to create repositories over the
3312
# wire; expose its details like rich_root_data for code to
3314
result._custom_format = custom_format
3317
def get_branch_format(self):
3318
result = BzrDirMetaFormat1.get_branch_format(self)
3319
if not isinstance(result, remote.RemoteBranchFormat):
3320
new_result = remote.RemoteBranchFormat()
3321
new_result._custom_format = result
3323
self.set_branch_format(new_result)
3327
repository_format = property(__return_repository_format,
3328
BzrDirMetaFormat1._set_repository_format) #.im_func)
3331
BzrDirFormat.register_control_server_format(RemoteBzrDirFormat)
3334
class BzrDirFormatInfo(object):
3336
def __init__(self, native, deprecated, hidden, experimental):
3337
self.deprecated = deprecated
3338
self.native = native
3339
self.hidden = hidden
3340
self.experimental = experimental
3343
class BzrDirFormatRegistry(registry.Registry):
3344
"""Registry of user-selectable BzrDir subformats.
3346
Differs from BzrDirFormat._control_formats in that it provides sub-formats,
3347
e.g. BzrDirMeta1 with weave repository. Also, it's more user-oriented.
3351
"""Create a BzrDirFormatRegistry."""
3352
self._aliases = set()
3353
self._registration_order = list()
3354
super(BzrDirFormatRegistry, self).__init__()
3357
"""Return a set of the format names which are aliases."""
3358
return frozenset(self._aliases)
3360
def register_metadir(self, key,
3361
repository_format, help, native=True, deprecated=False,
3367
"""Register a metadir subformat.
3369
These all use a BzrDirMetaFormat1 bzrdir, but can be parameterized
3370
by the Repository/Branch/WorkingTreeformats.
3372
:param repository_format: The fully-qualified repository format class
3374
:param branch_format: Fully-qualified branch format class name as
3376
:param tree_format: Fully-qualified tree format class name as
3379
# This should be expanded to support setting WorkingTree and Branch
3380
# formats, once BzrDirMetaFormat1 supports that.
3381
def _load(full_name):
3382
mod_name, factory_name = full_name.rsplit('.', 1)
3384
mod = __import__(mod_name, globals(), locals(),
3386
except ImportError, e:
3387
raise ImportError('failed to load %s: %s' % (full_name, e))
3389
factory = getattr(mod, factory_name)
3390
except AttributeError:
3391
raise AttributeError('no factory %s in module %r'
3396
bd = BzrDirMetaFormat1()
3397
if branch_format is not None:
3398
bd.set_branch_format(_load(branch_format))
3399
if tree_format is not None:
3400
bd.workingtree_format = _load(tree_format)
3401
if repository_format is not None:
3402
bd.repository_format = _load(repository_format)
3404
self.register(key, helper, help, native, deprecated, hidden,
3405
experimental, alias)
3407
def register(self, key, factory, help, native=True, deprecated=False,
3408
hidden=False, experimental=False, alias=False):
3409
"""Register a BzrDirFormat factory.
3411
The factory must be a callable that takes one parameter: the key.
3412
It must produce an instance of the BzrDirFormat when called.
3414
This function mainly exists to prevent the info object from being
3417
registry.Registry.register(self, key, factory, help,
3418
BzrDirFormatInfo(native, deprecated, hidden, experimental))
3420
self._aliases.add(key)
3421
self._registration_order.append(key)
3423
def register_lazy(self, key, module_name, member_name, help, native=True,
3424
deprecated=False, hidden=False, experimental=False, alias=False):
3425
registry.Registry.register_lazy(self, key, module_name, member_name,
3426
help, BzrDirFormatInfo(native, deprecated, hidden, experimental))
3428
self._aliases.add(key)
3429
self._registration_order.append(key)
3431
def set_default(self, key):
3432
"""Set the 'default' key to be a clone of the supplied key.
3434
This method must be called once and only once.
3436
registry.Registry.register(self, 'default', self.get(key),
3437
self.get_help(key), info=self.get_info(key))
3438
self._aliases.add('default')
3440
def set_default_repository(self, key):
3441
"""Set the FormatRegistry default and Repository default.
3443
This is a transitional method while Repository.set_default_format
3446
if 'default' in self:
3447
self.remove('default')
3448
self.set_default(key)
3449
format = self.get('default')()
3451
def make_bzrdir(self, key):
3452
return self.get(key)()
3454
def help_topic(self, topic):
3456
default_realkey = None
3457
default_help = self.get_help('default')
3459
for key in self._registration_order:
3460
if key == 'default':
3462
help = self.get_help(key)
3463
if help == default_help:
3464
default_realkey = key
3466
help_pairs.append((key, help))
3468
def wrapped(key, help, info):
3470
help = '(native) ' + help
3471
return ':%s:\n%s\n\n' % (key,
3472
textwrap.fill(help, initial_indent=' ',
3473
subsequent_indent=' ',
3474
break_long_words=False))
3475
if default_realkey is not None:
3476
output += wrapped(default_realkey, '(default) %s' % default_help,
3477
self.get_info('default'))
3478
deprecated_pairs = []
3479
experimental_pairs = []
3480
for key, help in help_pairs:
3481
info = self.get_info(key)
3484
elif info.deprecated:
3485
deprecated_pairs.append((key, help))
3486
elif info.experimental:
3487
experimental_pairs.append((key, help))
3489
output += wrapped(key, help, info)
3490
output += "\nSee ``bzr help formats`` for more about storage formats."
3492
if len(experimental_pairs) > 0:
3493
other_output += "Experimental formats are shown below.\n\n"
3494
for key, help in experimental_pairs:
3495
info = self.get_info(key)
3496
other_output += wrapped(key, help, info)
3499
"No experimental formats are available.\n\n"
3500
if len(deprecated_pairs) > 0:
3501
other_output += "\nDeprecated formats are shown below.\n\n"
3502
for key, help in deprecated_pairs:
3503
info = self.get_info(key)
3504
other_output += wrapped(key, help, info)
3507
"\nNo deprecated formats are available.\n\n"
3509
"\nSee ``bzr help formats`` for more about storage formats."
3511
if topic == 'other-formats':
3517
class RepositoryAcquisitionPolicy(object):
3518
"""Abstract base class for repository acquisition policies.
3520
A repository acquisition policy decides how a BzrDir acquires a repository
3521
for a branch that is being created. The most basic policy decision is
3522
whether to create a new repository or use an existing one.
3524
def __init__(self, stack_on, stack_on_pwd, require_stacking):
3527
:param stack_on: A location to stack on
3528
:param stack_on_pwd: If stack_on is relative, the location it is
3530
:param require_stacking: If True, it is a failure to not stack.
3532
self._stack_on = stack_on
3533
self._stack_on_pwd = stack_on_pwd
3534
self._require_stacking = require_stacking
3536
def configure_branch(self, branch):
3537
"""Apply any configuration data from this policy to the branch.
3539
Default implementation sets repository stacking.
3541
if self._stack_on is None:
3543
if self._stack_on_pwd is None:
3544
stack_on = self._stack_on
3547
stack_on = urlutils.rebase_url(self._stack_on,
3549
branch.bzrdir.root_transport.base)
3550
except errors.InvalidRebaseURLs:
3551
stack_on = self._get_full_stack_on()
3553
branch.set_stacked_on_url(stack_on)
3554
except (errors.UnstackableBranchFormat,
3555
errors.UnstackableRepositoryFormat):
3556
if self._require_stacking:
3559
def requires_stacking(self):
3560
"""Return True if this policy requires stacking."""
3561
return self._stack_on is not None and self._require_stacking
3563
def _get_full_stack_on(self):
3564
"""Get a fully-qualified URL for the stack_on location."""
3565
if self._stack_on is None:
3567
if self._stack_on_pwd is None:
3568
return self._stack_on
3570
return urlutils.join(self._stack_on_pwd, self._stack_on)
3572
def _add_fallback(self, repository, possible_transports=None):
3573
"""Add a fallback to the supplied repository, if stacking is set."""
3574
stack_on = self._get_full_stack_on()
3575
if stack_on is None:
3578
stacked_dir = BzrDir.open(stack_on,
3579
possible_transports=possible_transports)
3580
except errors.JailBreak:
3581
# We keep the stacking details, but we are in the server code so
3582
# actually stacking is not needed.
3585
stacked_repo = stacked_dir.open_branch().repository
3586
except errors.NotBranchError:
3587
stacked_repo = stacked_dir.open_repository()
3589
repository.add_fallback_repository(stacked_repo)
3590
except errors.UnstackableRepositoryFormat:
3591
if self._require_stacking:
3594
self._require_stacking = True
3596
def acquire_repository(self, make_working_trees=None, shared=False):
3597
"""Acquire a repository for this bzrdir.
3599
Implementations may create a new repository or use a pre-exising
3601
:param make_working_trees: If creating a repository, set
3602
make_working_trees to this value (if non-None)
3603
:param shared: If creating a repository, make it shared if True
3604
:return: A repository, is_new_flag (True if the repository was
3607
raise NotImplemented(RepositoryAcquisitionPolicy.acquire_repository)
3610
class CreateRepository(RepositoryAcquisitionPolicy):
3611
"""A policy of creating a new repository"""
3613
def __init__(self, bzrdir, stack_on=None, stack_on_pwd=None,
3614
require_stacking=False):
3617
:param bzrdir: The bzrdir to create the repository on.
3618
:param stack_on: A location to stack on
3619
:param stack_on_pwd: If stack_on is relative, the location it is
3622
RepositoryAcquisitionPolicy.__init__(self, stack_on, stack_on_pwd,
3624
self._bzrdir = bzrdir
3626
def acquire_repository(self, make_working_trees=None, shared=False):
3627
"""Implementation of RepositoryAcquisitionPolicy.acquire_repository
3629
Creates the desired repository in the bzrdir we already have.
3631
stack_on = self._get_full_stack_on()
3633
format = self._bzrdir._format
3634
format.require_stacking(stack_on=stack_on,
3635
possible_transports=[self._bzrdir.root_transport])
3636
if not self._require_stacking:
3637
# We have picked up automatic stacking somewhere.
3638
note('Using default stacking branch %s at %s', self._stack_on,
3640
repository = self._bzrdir.create_repository(shared=shared)
3641
self._add_fallback(repository,
3642
possible_transports=[self._bzrdir.transport])
3643
if make_working_trees is not None:
3644
repository.set_make_working_trees(make_working_trees)
3645
return repository, True
3648
class UseExistingRepository(RepositoryAcquisitionPolicy):
3649
"""A policy of reusing an existing repository"""
3651
def __init__(self, repository, stack_on=None, stack_on_pwd=None,
3652
require_stacking=False):
3655
:param repository: The repository to use.
3656
:param stack_on: A location to stack on
3657
:param stack_on_pwd: If stack_on is relative, the location it is
3660
RepositoryAcquisitionPolicy.__init__(self, stack_on, stack_on_pwd,
3662
self._repository = repository
3664
def acquire_repository(self, make_working_trees=None, shared=False):
3665
"""Implementation of RepositoryAcquisitionPolicy.acquire_repository
3667
Returns an existing repository to use.
3669
self._add_fallback(self._repository,
3670
possible_transports=[self._repository.bzrdir.transport])
3671
return self._repository, False
3674
# Please register new formats after old formats so that formats
3675
# appear in chronological order and format descriptions can build
3677
format_registry = BzrDirFormatRegistry()
3678
# The pre-0.8 formats have their repository format network name registered in
3679
# repository.py. MetaDir formats have their repository format network name
3680
# inferred from their disk format string.
3681
format_registry.register('weave', BzrDirFormat6,
3682
'Pre-0.8 format. Slower than knit and does not'
3683
' support checkouts or shared repositories.',
3685
format_registry.register_metadir('metaweave',
3686
'bzrlib.repofmt.weaverepo.RepositoryFormat7',
3687
'Transitional format in 0.8. Slower than knit.',
3688
branch_format='bzrlib.branch.BzrBranchFormat5',
3689
tree_format='bzrlib.workingtree.WorkingTreeFormat3',
3691
format_registry.register_metadir('knit',
3692
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3693
'Format using knits. Recommended for interoperation with bzr <= 0.14.',
3694
branch_format='bzrlib.branch.BzrBranchFormat5',
3695
tree_format='bzrlib.workingtree.WorkingTreeFormat3',
3697
format_registry.register_metadir('dirstate',
3698
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3699
help='New in 0.15: Fast local operations. Compatible with bzr 0.8 and '
3700
'above when accessed over the network.',
3701
branch_format='bzrlib.branch.BzrBranchFormat5',
3702
# this uses bzrlib.workingtree.WorkingTreeFormat4 because importing
3703
# directly from workingtree_4 triggers a circular import.
3704
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3706
format_registry.register_metadir('dirstate-tags',
3707
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3708
help='New in 0.15: Fast local operations and improved scaling for '
3709
'network operations. Additionally adds support for tags.'
3710
' Incompatible with bzr < 0.15.',
3711
branch_format='bzrlib.branch.BzrBranchFormat6',
3712
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3714
format_registry.register_metadir('rich-root',
3715
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit4',
3716
help='New in 1.0. Better handling of tree roots. Incompatible with'
3718
branch_format='bzrlib.branch.BzrBranchFormat6',
3719
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3721
format_registry.register_metadir('dirstate-with-subtree',
3722
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit3',
3723
help='New in 0.15: Fast local operations and improved scaling for '
3724
'network operations. Additionally adds support for versioning nested '
3725
'bzr branches. Incompatible with bzr < 0.15.',
3726
branch_format='bzrlib.branch.BzrBranchFormat6',
3727
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3731
format_registry.register_metadir('pack-0.92',
3732
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack1',
3733
help='New in 0.92: Pack-based format with data compatible with '
3734
'dirstate-tags format repositories. Interoperates with '
3735
'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
3736
'Previously called knitpack-experimental. '
3737
'For more information, see '
3738
'http://doc.bazaar-vcs.org/latest/developers/packrepo.html.',
3739
branch_format='bzrlib.branch.BzrBranchFormat6',
3740
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3742
format_registry.register_metadir('pack-0.92-subtree',
3743
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack3',
3744
help='New in 0.92: Pack-based format with data compatible with '
3745
'dirstate-with-subtree format repositories. Interoperates with '
3746
'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
3747
'Previously called knitpack-experimental. '
3748
'For more information, see '
3749
'http://doc.bazaar-vcs.org/latest/developers/packrepo.html.',
3750
branch_format='bzrlib.branch.BzrBranchFormat6',
3751
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3755
format_registry.register_metadir('rich-root-pack',
3756
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack4',
3757
help='New in 1.0: A variant of pack-0.92 that supports rich-root data '
3758
'(needed for bzr-svn and bzr-git).',
3759
branch_format='bzrlib.branch.BzrBranchFormat6',
3760
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3762
format_registry.register_metadir('1.6',
3763
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5',
3764
help='A format that allows a branch to indicate that there is another '
3765
'(stacked) repository that should be used to access data that is '
3766
'not present locally.',
3767
branch_format='bzrlib.branch.BzrBranchFormat7',
3768
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3770
format_registry.register_metadir('1.6.1-rich-root',
3771
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5RichRoot',
3772
help='A variant of 1.6 that supports rich-root data '
3773
'(needed for bzr-svn and bzr-git).',
3774
branch_format='bzrlib.branch.BzrBranchFormat7',
3775
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3777
format_registry.register_metadir('1.9',
3778
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
3779
help='A repository format using B+tree indexes. These indexes '
3780
'are smaller in size, have smarter caching and provide faster '
3781
'performance for most operations.',
3782
branch_format='bzrlib.branch.BzrBranchFormat7',
3783
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3785
format_registry.register_metadir('1.9-rich-root',
3786
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
3787
help='A variant of 1.9 that supports rich-root data '
3788
'(needed for bzr-svn and bzr-git).',
3789
branch_format='bzrlib.branch.BzrBranchFormat7',
3790
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3792
format_registry.register_metadir('1.14',
3793
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
3794
help='A working-tree format that supports content filtering.',
3795
branch_format='bzrlib.branch.BzrBranchFormat7',
3796
tree_format='bzrlib.workingtree.WorkingTreeFormat5',
3798
format_registry.register_metadir('1.14-rich-root',
3799
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
3800
help='A variant of 1.14 that supports rich-root data '
3801
'(needed for bzr-svn and bzr-git).',
3802
branch_format='bzrlib.branch.BzrBranchFormat7',
3803
tree_format='bzrlib.workingtree.WorkingTreeFormat5',
3805
# The following un-numbered 'development' formats should always just be aliases.
3806
format_registry.register_metadir('development-rich-root',
3807
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
3808
help='Current development format. Supports rich roots. Can convert data '
3809
'to and from rich-root-pack (and anything compatible with '
3810
'rich-root-pack) format repositories. Repositories and branches in '
3811
'this format can only be read by bzr.dev. Please read '
3812
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3814
branch_format='bzrlib.branch.BzrBranchFormat7',
3815
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3819
format_registry.register_metadir('development-subtree',
3820
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment2Subtree',
3821
help='Current development format, subtree variant. Can convert data to and '
3822
'from pack-0.92-subtree (and anything compatible with '
3823
'pack-0.92-subtree) format repositories. Repositories and branches in '
3824
'this format can only be read by bzr.dev. Please read '
3825
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3827
branch_format='bzrlib.branch.BzrBranchFormat7',
3828
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3830
alias=False, # Restore to being an alias when an actual development subtree format is added
3831
# This current non-alias status is simply because we did not introduce a
3832
# chk based subtree format.
3835
# And the development formats above will have aliased one of the following:
3836
format_registry.register_metadir('development6-rich-root',
3837
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
3838
help='pack-1.9 with 255-way hashed CHK inv, group compress, rich roots '
3840
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3842
branch_format='bzrlib.branch.BzrBranchFormat7',
3843
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3848
format_registry.register_metadir('development7-rich-root',
3849
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK2',
3850
help='pack-1.9 with 255-way hashed CHK inv, bencode revision, group compress, '
3851
'rich roots. Please read '
3852
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3854
branch_format='bzrlib.branch.BzrBranchFormat7',
3855
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3860
format_registry.register_metadir('2a',
3861
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
3862
help='First format for bzr 2.0 series.\n'
3863
'Uses group-compress storage.\n'
3864
'Provides rich roots which are a one-way transition.\n',
3865
# 'storage in packs, 255-way hashed CHK inventory, bencode revision, group compress, '
3866
# 'rich roots. Supported by bzr 1.16 and later.',
3867
branch_format='bzrlib.branch.BzrBranchFormat7',
3868
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3872
# The following format should be an alias for the rich root equivalent
3873
# of the default format
3874
format_registry.register_metadir('default-rich-root',
3875
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
3876
branch_format='bzrlib.branch.BzrBranchFormat7',
3877
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3881
# The current format that is made on 'bzr init'.
3882
format_registry.set_default('2a')