321
489
policy = self.determine_repository_policy(force_new_repo)
322
490
return policy.acquire_repository()[0]
324
def _find_source_repo(self, exit_stack, source_branch):
325
"""Find the source branch and repo for a sprout operation.
327
This is helper intended for use by _sprout.
329
:returns: (source_branch, source_repository). Either or both may be
330
None. If not None, they will be read-locked (and their unlock(s)
331
scheduled via the exit_stack param).
493
def create_branch_convenience(base, force_new_repo=False,
494
force_new_tree=None, format=None,
495
possible_transports=None):
496
"""Create a new BzrDir, Branch and Repository at the url 'base'.
498
This is a convenience function - it will use an existing repository
499
if possible, can be told explicitly whether to create a working tree or
502
This will use the current default BzrDirFormat unless one is
503
specified, and use whatever
504
repository format that that uses via bzrdir.create_branch and
505
create_repository. If a shared repository is available that is used
506
preferentially. Whatever repository is used, its tree creation policy
509
The created Branch object is returned.
510
If a working tree cannot be made due to base not being a file:// url,
511
no error is raised unless force_new_tree is True, in which case no
512
data is created on disk and NotLocalUrl is raised.
514
:param base: The URL to create the branch at.
515
:param force_new_repo: If True a new repository is always created.
516
:param force_new_tree: If True or False force creation of a tree or
517
prevent such creation respectively.
518
:param format: Override for the bzrdir format to create.
519
:param possible_transports: An optional reusable transports list.
333
if source_branch is not None:
334
exit_stack.enter_context(source_branch.lock_read())
335
return source_branch, source_branch.repository
337
source_branch = self.open_branch()
338
source_repository = source_branch.repository
339
except errors.NotBranchError:
522
# check for non local urls
523
t = get_transport(base, possible_transports)
524
if not isinstance(t, local.LocalTransport):
525
raise errors.NotLocalUrl(base)
526
bzrdir = BzrDir.create(base, format, possible_transports)
527
repo = bzrdir._find_or_create_repository(force_new_repo)
528
result = bzrdir.create_branch()
529
if force_new_tree or (repo.make_working_trees() and
530
force_new_tree is None):
342
source_repository = self.open_repository()
343
except errors.NoRepositoryPresent:
344
source_repository = None
346
exit_stack.enter_context(source_repository.lock_read())
348
exit_stack.enter_context(source_branch.lock_read())
349
return source_branch, source_repository
351
def sprout(self, url, revision_id=None, force_new_repo=False,
352
recurse='down', possible_transports=None,
353
accelerator_tree=None, hardlink=False, stacked=False,
354
source_branch=None, create_tree_if_local=True,
356
"""Create a copy of this controldir prepared for use as a new line of
359
If url's last component does not exist, it will be created.
361
Attributes related to the identity of the source branch like
362
branch nickname will be cleaned, a working tree is created
363
whether one existed before or not; and a local branch is always
366
if revision_id is not None, then the clone operation may tune
367
itself to download less data.
532
bzrdir.create_workingtree()
533
except errors.NotLocalUrl:
538
def create_standalone_workingtree(base, format=None):
539
"""Create a new BzrDir, WorkingTree, Branch and Repository at 'base'.
541
'base' must be a local path or a file:// url.
543
This will use the current default BzrDirFormat unless one is
544
specified, and use whatever
545
repository format that that uses for bzrdirformat.create_workingtree,
546
create_branch and create_repository.
548
:param format: Override for the bzrdir format to create.
549
:return: The WorkingTree object.
551
t = get_transport(base)
552
if not isinstance(t, local.LocalTransport):
553
raise errors.NotLocalUrl(base)
554
bzrdir = BzrDir.create_branch_and_repo(base,
556
format=format).bzrdir
557
return bzrdir.create_workingtree()
559
def create_workingtree(self, revision_id=None, from_branch=None,
560
accelerator_tree=None, hardlink=False):
561
"""Create a working tree at this BzrDir.
563
:param revision_id: create it as of this revision id.
564
:param from_branch: override bzrdir branch (for lightweight checkouts)
369
565
:param accelerator_tree: A tree which can be used for retrieving file
370
566
contents more quickly than the revision tree, i.e. a workingtree.
371
567
The revision tree will be used for cases where accelerator_tree's
372
568
content is different.
373
:param hardlink: If true, hard-link files from accelerator_tree,
375
:param stacked: If true, create a stacked branch referring to the
376
location of this control directory.
377
:param create_tree_if_local: If true, a working-tree will be created
378
when working locally.
379
:return: The created control directory
381
with contextlib.ExitStack() as stack:
382
fetch_spec_factory = fetch.FetchSpecFactory()
383
if revision_id is not None:
384
fetch_spec_factory.add_revision_ids([revision_id])
385
fetch_spec_factory.source_branch_stop_revision_id = revision_id
386
if possible_transports is None:
387
possible_transports = []
389
possible_transports = list(possible_transports) + [
391
target_transport = _mod_transport.get_transport(url,
393
target_transport.ensure_base()
394
cloning_format = self.cloning_metadir(stacked)
395
# Create/update the result branch
397
result = controldir.ControlDir.open_from_transport(
399
except errors.NotBranchError:
400
result = cloning_format.initialize_on_transport(target_transport)
401
source_branch, source_repository = self._find_source_repo(
402
stack, source_branch)
403
fetch_spec_factory.source_branch = source_branch
404
# if a stacked branch wasn't requested, we don't create one
405
# even if the origin was stacked
406
if stacked and source_branch is not None:
407
stacked_branch_url = self.root_transport.base
409
stacked_branch_url = None
410
repository_policy = result.determine_repository_policy(
411
force_new_repo, stacked_branch_url, require_stacking=stacked)
412
result_repo, is_new_repo = repository_policy.acquire_repository(
413
possible_transports=possible_transports)
414
stack.enter_context(result_repo.lock_write())
415
fetch_spec_factory.source_repo = source_repository
416
fetch_spec_factory.target_repo = result_repo
417
if stacked or (len(result_repo._fallback_repositories) != 0):
418
target_repo_kind = fetch.TargetRepoKinds.STACKED
420
target_repo_kind = fetch.TargetRepoKinds.EMPTY
422
target_repo_kind = fetch.TargetRepoKinds.PREEXISTING
423
fetch_spec_factory.target_repo_kind = target_repo_kind
424
if source_repository is not None:
425
fetch_spec = fetch_spec_factory.make_fetch_spec()
426
result_repo.fetch(source_repository, fetch_spec=fetch_spec)
428
if source_branch is None:
429
# this is for sprouting a controldir without a branch; is that
431
# Not especially, but it's part of the contract.
432
result_branch = result.create_branch()
433
if revision_id is not None:
434
result_branch.generate_revision_history(revision_id)
436
result_branch = source_branch.sprout(
437
result, revision_id=revision_id,
438
repository_policy=repository_policy, repository=result_repo)
439
mutter("created new branch %r" % (result_branch,))
441
# Create/update the result working tree
442
if (create_tree_if_local and not result.has_workingtree()
443
and isinstance(target_transport, local.LocalTransport)
444
and (result_repo is None or result_repo.make_working_trees())
445
and result.open_branch(
447
possible_transports=possible_transports).name == result_branch.name):
448
wt = result.create_workingtree(
449
accelerator_tree=accelerator_tree, hardlink=hardlink,
450
from_branch=result_branch)
451
with wt.lock_write():
452
if not wt.is_versioned(''):
454
wt.set_root_id(self.open_workingtree.path2id(''))
455
except errors.NoWorkingTree:
459
if recurse == 'down':
463
basis = tree.basis_tree()
464
stack.enter_context(basis.lock_read())
465
elif result_branch is not None:
466
basis = tree = result_branch.basis_tree()
467
elif source_branch is not None:
468
basis = tree = source_branch.basis_tree()
470
stack.enter_context(tree.lock_read())
471
subtrees = tree.iter_references()
474
for path in subtrees:
475
target = urlutils.join(url, urlutils.escape(path))
476
sublocation = tree.reference_parent(
477
path, branch=result_branch,
478
possible_transports=possible_transports)
479
if sublocation is None:
481
'Ignoring nested tree %s, parent location unknown.',
484
sublocation.controldir.sprout(
485
target, basis.get_reference_revision(path),
486
force_new_repo=force_new_repo, recurse=recurse,
490
def _available_backup_name(self, base):
491
"""Find a non-existing backup file name based on base.
493
See breezy.osutils.available_backup_name about race conditions.
495
return osutils.available_backup_name(base, self.root_transport.has)
570
raise NotImplementedError(self.create_workingtree)
497
572
def backup_bzrdir(self):
498
573
"""Backup this bzr control directory.
500
575
:return: Tuple with old path name and new path name
503
with ui.ui_factory.nested_progress_bar():
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)
504
585
old_path = self.root_transport.abspath('.bzr')
505
backup_dir = self._available_backup_name('backup.bzr')
506
new_path = self.root_transport.abspath(backup_dir)
508
gettext('making backup of {0}\n to {1}').format(
509
urlutils.unescape_for_display(old_path, 'utf-8'),
510
urlutils.unescape_for_display(new_path, 'utf-8')))
511
self.root_transport.copy_tree('.bzr', backup_dir)
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')
512
590
return (old_path, new_path)
514
594
def retire_bzrdir(self, limit=10000):
515
595
"""Permanently disable the bzrdir.
652
795
:param _transport: the transport this dir is based at.
654
797
self._format = _format
655
# these are also under the more standard names of
656
# control_transport and user_transport
657
798
self.transport = _transport.clone('.bzr')
658
799
self.root_transport = _transport
659
800
self._mode_check_done = False
662
def user_transport(self):
663
return self.root_transport
666
def control_transport(self):
667
return self.transport
802
def is_control_filename(self, filename):
803
"""True if filename is the name of a path which is reserved for bzrdir's.
805
:param filename: A filename within the root transport of this bzrdir.
807
This is true IF and ONLY IF the filename is part of the namespace reserved
808
for bzr control dirs. Currently this is the '.bzr' directory in the root
809
of the root_transport. it is expected that plugins will need to extend
810
this in the future - for instance to make bzr talk with svn working
813
# this might be better on the BzrDirFormat class because it refers to
814
# all the possible bzrdir disk formats.
815
# This method is tested via the workingtree is_control_filename tests-
816
# it was extracted from WorkingTree.is_control_filename. If the method's
817
# contract is extended beyond the current trivial implementation, please
818
# add new tests for it to the appropriate place.
819
return filename == '.bzr' or filename.startswith('.bzr/')
821
def needs_format_conversion(self, format=None):
822
"""Return true if this bzrdir needs convert_format run on it.
824
For instance, if the repository format is out of date but the
825
branch and working tree are not, this should return True.
827
:param format: Optional parameter indicating a specific desired
828
format we plan to arrive at.
830
raise NotImplementedError(self.needs_format_conversion)
833
def open_unsupported(base):
834
"""Open a branch which is not supported."""
835
return BzrDir.open(base, _unsupported=True)
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)
878
BzrDir._check_supported(format, _unsupported)
879
return format.open(transport, _found=True)
881
def open_branch(self, unsupported=False, ignore_fallbacks=False):
882
"""Open the branch object at this BzrDir if one is present.
884
If unsupported is True, then no longer supported branch formats can
887
TODO: static convenience version of this?
889
raise NotImplementedError(self.open_branch)
892
def open_containing(url, possible_transports=None):
893
"""Open an existing branch which contains url.
895
:param url: url to search from.
896
See open_containing_from_transport for more detail.
898
transport = get_transport(url, possible_transports)
899
return BzrDir.open_containing_from_transport(transport)
902
def open_containing_from_transport(a_transport):
903
"""Open an existing branch which contains a_transport.base.
905
This probes for a branch at a_transport, and searches upwards from there.
907
Basically we keep looking up until we find the control directory or
908
run into the root. If there isn't one, raises NotBranchError.
909
If there is one and it is either an unrecognised format or an unsupported
910
format, UnknownFormatError or UnsupportedFormatError are raised.
911
If there is one, it is returned, along with the unused portion of url.
913
:return: The BzrDir that contains the path, and a Unicode path
914
for the rest of the URL.
916
# this gets the normalised url back. I.e. '.' -> the full path.
917
url = a_transport.base
920
result = BzrDir.open_from_transport(a_transport)
921
return result, urlutils.unescape(a_transport.relpath(url))
922
except errors.NotBranchError, e:
925
new_t = a_transport.clone('..')
926
except errors.InvalidURLJoin:
927
# reached the root, whatever that may be
928
raise errors.NotBranchError(path=url)
929
if new_t.base == a_transport.base:
930
# reached the root, whatever that may be
931
raise errors.NotBranchError(path=url)
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
1001
def open_repository(self, _unsupported=False):
1002
"""Open the repository object at this BzrDir if one is present.
1004
This will not follow the Branch object pointer - it's strictly a direct
1005
open facility. Most client code should use open_branch().repository to
1006
get at a repository.
1008
:param _unsupported: a private parameter, not part of the api.
1009
TODO: static convenience version of this?
1011
raise NotImplementedError(self.open_repository)
1013
def open_workingtree(self, _unsupported=False,
1014
recommend_upgrade=True, from_branch=None):
1015
"""Open the workingtree object at this BzrDir if one is present.
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)
1023
raise NotImplementedError(self.open_workingtree)
1025
def has_branch(self):
1026
"""Tell if this bzrdir contains a branch.
1028
Note: if you're going to open the branch, you should just go ahead
1029
and try, and not ask permission first. (This method just opens the
1030
branch and discards it, and that's somewhat expensive.)
1035
except errors.NotBranchError:
1038
def has_workingtree(self):
1039
"""Tell if this bzrdir contains a working tree.
1041
This will still raise an exception if the bzrdir has a workingtree that
1042
is remote & inaccessible.
1044
Note: if you're going to open the working tree, you should just go ahead
1045
and try, and not ask permission first. (This method just opens the
1046
workingtree and discards it, and that's somewhat expensive.)
1049
self.open_workingtree(recommend_upgrade=False)
1051
except errors.NoWorkingTree:
669
1054
def _cloning_metadir(self):
670
1055
"""Produce a metadir suitable for cloning with.
723
1109
# We have a repository, so set a working tree? (Why? This seems to
724
1110
# contradict the stated return value in the docstring).
726
repository._format._matchingcontroldir.workingtree_format)
1111
tree_format = repository._format._matchingbzrdir.workingtree_format
727
1112
format.workingtree_format = tree_format.__class__()
728
1113
if require_stacking:
729
1114
format.require_stacking()
732
def get_branch_transport(self, branch_format, name=None):
733
"""Get the transport for use by branch format in this BzrDir.
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.
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.
743
raise NotImplementedError(self.get_branch_transport)
1117
def checkout_metadir(self):
1118
return self.cloning_metadir()
1120
def sprout(self, url, revision_id=None, force_new_repo=False,
1121
recurse='down', possible_transports=None,
1122
accelerator_tree=None, hardlink=False, stacked=False,
1123
source_branch=None, create_tree_if_local=True):
1124
"""Create a copy of this bzrdir prepared for use as a new line of
1127
If url's last component does not exist, it will be created.
1129
Attributes related to the identity of the source branch like
1130
branch nickname will be cleaned, a working tree is created
1131
whether one existed before or not; and a local branch is always
1134
if revision_id is not None, then the clone operation may tune
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.
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
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()
1251
except errors.NotBranchError:
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()
1318
class BzrDirPreSplitOut(BzrDir):
1319
"""A common class for the all-in-one formats."""
1321
def __init__(self, _transport, _format):
1322
"""See BzrDir.__init__."""
1323
super(BzrDirPreSplitOut, self).__init__(_transport, _format)
1324
self._control_files = lockable_files.LockableFiles(
1325
self.get_branch_transport(None),
1326
self._format._lock_file_name,
1327
self._format._lock_class)
1329
def break_lock(self):
1330
"""Pre-splitout bzrdirs do not suffer from stale locks."""
1331
raise NotImplementedError(self.break_lock)
1333
def cloning_metadir(self, require_stacking=False):
1334
"""Produce a metadir suitable for cloning with."""
1335
if require_stacking:
1336
return format_registry.make_bzrdir('1.6')
1337
return self._format.__class__()
1339
def clone(self, url, revision_id=None, force_new_repo=False,
1340
preserve_stacking=False):
1341
"""See BzrDir.clone().
1343
force_new_repo has no effect, since this family of formats always
1344
require a new repository.
1345
preserve_stacking has no effect, since no source branch using this
1346
family of formats can be stacked, so there is no stacking to preserve.
1348
self._make_tail(url)
1349
result = self._format._initialize_for_clone(url)
1350
self.open_repository().clone(result, revision_id=revision_id)
1351
from_branch = self.open_branch()
1352
from_branch.clone(result, revision_id=revision_id)
1354
tree = self.open_workingtree()
1355
except errors.NotLocalUrl:
1356
# make a new one, this format always has to have one.
1357
result._init_workingtree()
1362
def create_branch(self):
1363
"""See BzrDir.create_branch."""
1364
return self._format.get_branch_format().initialize(self)
1366
def destroy_branch(self):
1367
"""See BzrDir.destroy_branch."""
1368
raise errors.UnsupportedOperation(self.destroy_branch, self)
1370
def create_repository(self, shared=False):
1371
"""See BzrDir.create_repository."""
1373
raise errors.IncompatibleFormat('shared repository', self._format)
1374
return self.open_repository()
1376
def destroy_repository(self):
1377
"""See BzrDir.destroy_repository."""
1378
raise errors.UnsupportedOperation(self.destroy_repository, self)
1380
def create_workingtree(self, revision_id=None, from_branch=None,
1381
accelerator_tree=None, hardlink=False):
1382
"""See BzrDir.create_workingtree."""
1383
# The workingtree is sometimes created when the bzrdir is created,
1384
# but not when cloning.
1386
# this looks buggy but is not -really-
1387
# because this format creates the workingtree when the bzrdir is
1389
# clone and sprout will have set the revision_id
1390
# and that will have set it for us, its only
1391
# specific uses of create_workingtree in isolation
1392
# that can do wonky stuff here, and that only
1393
# happens for creating checkouts, which cannot be
1394
# done on this format anyway. So - acceptable wart.
1396
warning("can't support hardlinked working trees in %r"
1399
result = self.open_workingtree(recommend_upgrade=False)
1400
except errors.NoSuchFile:
1401
result = self._init_workingtree()
1402
if revision_id is not None:
1403
if revision_id == _mod_revision.NULL_REVISION:
1404
result.set_parent_ids([])
1406
result.set_parent_ids([revision_id])
1409
def _init_workingtree(self):
1410
from bzrlib.workingtree import WorkingTreeFormat2
1412
return WorkingTreeFormat2().initialize(self)
1413
except errors.NotLocalUrl:
1414
# Even though we can't access the working tree, we need to
1415
# create its control files.
1416
return WorkingTreeFormat2()._stub_initialize_on_transport(
1417
self.transport, self._control_files._file_mode)
1419
def destroy_workingtree(self):
1420
"""See BzrDir.destroy_workingtree."""
1421
raise errors.UnsupportedOperation(self.destroy_workingtree, self)
1423
def destroy_workingtree_metadata(self):
1424
"""See BzrDir.destroy_workingtree_metadata."""
1425
raise errors.UnsupportedOperation(self.destroy_workingtree_metadata,
1428
def get_branch_transport(self, branch_format):
1429
"""See BzrDir.get_branch_transport()."""
1430
if branch_format is None:
1431
return self.transport
1433
branch_format.get_format_string()
1434
except NotImplementedError:
1435
return self.transport
1436
raise errors.IncompatibleFormat(branch_format, self._format)
745
1438
def get_repository_transport(self, repository_format):
746
"""Get the transport for use by repository format in this BzrDir.
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.
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.
756
raise NotImplementedError(self.get_repository_transport)
758
def get_workingtree_transport(self, tree_format):
759
"""Get the transport for use by workingtree format in this BzrDir.
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.
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.
769
raise NotImplementedError(self.get_workingtree_transport)
772
def create(cls, base, format=None, possible_transports=None):
773
"""Create a new BzrDir at the url 'base'.
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.
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(
784
base, format=format, possible_transports=possible_transports)
787
return "<%s at %r>" % (self.__class__.__name__, self.user_url)
789
def update_feature_flags(self, updated_flags):
790
"""Update the features required by this bzrdir.
792
:param updated_flags: Dictionary mapping feature names to necessities
793
A necessity can be None to indicate the feature should be removed
795
self.control_files.lock_write()
797
self._format._update_feature_flags(updated_flags)
798
self.transport.put_bytes('branch-format', self._format.as_string())
800
self.control_files.unlock()
1439
"""See BzrDir.get_repository_transport()."""
1440
if repository_format is None:
1441
return self.transport
1443
repository_format.get_format_string()
1444
except NotImplementedError:
1445
return self.transport
1446
raise errors.IncompatibleFormat(repository_format, self._format)
1448
def get_workingtree_transport(self, workingtree_format):
1449
"""See BzrDir.get_workingtree_transport()."""
1450
if workingtree_format is None:
1451
return self.transport
1453
workingtree_format.get_format_string()
1454
except NotImplementedError:
1455
return self.transport
1456
raise errors.IncompatibleFormat(workingtree_format, self._format)
1458
def needs_format_conversion(self, format=None):
1459
"""See BzrDir.needs_format_conversion()."""
1460
# if the format is not the same as the system default,
1461
# an upgrade is needed.
1463
symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
1464
% 'needs_format_conversion(format=None)')
1465
format = BzrDirFormat.get_default_format()
1466
return not isinstance(self._format, format.__class__)
1468
def open_branch(self, unsupported=False, ignore_fallbacks=False):
1469
"""See BzrDir.open_branch."""
1470
from bzrlib.branch import BzrBranchFormat4
1471
format = BzrBranchFormat4()
1472
self._check_supported(format, unsupported)
1473
return format.open(self, _found=True)
1475
def sprout(self, url, revision_id=None, force_new_repo=False,
1476
possible_transports=None, accelerator_tree=None,
1477
hardlink=False, stacked=False, create_tree_if_local=True,
1478
source_branch=None):
1479
"""See BzrDir.sprout()."""
1480
if source_branch is not None:
1481
my_branch = self.open_branch()
1482
if source_branch.base != my_branch.base:
1483
raise AssertionError(
1484
"source branch %r is not within %r with branch %r" %
1485
(source_branch, self, my_branch))
1487
raise errors.UnstackableBranchFormat(
1488
self._format, self.root_transport.base)
1489
if not create_tree_if_local:
1490
raise errors.MustHaveWorkingTree(
1491
self._format, self.root_transport.base)
1492
from bzrlib.workingtree import WorkingTreeFormat2
1493
self._make_tail(url)
1494
result = self._format._initialize_for_clone(url)
1496
self.open_repository().clone(result, revision_id=revision_id)
1497
except errors.NoRepositoryPresent:
1500
self.open_branch().sprout(result, revision_id=revision_id)
1501
except errors.NotBranchError:
1504
# we always want a working tree
1505
WorkingTreeFormat2().initialize(result,
1506
accelerator_tree=accelerator_tree,
1511
class BzrDir4(BzrDirPreSplitOut):
1512
"""A .bzr version 4 control object.
1514
This is a deprecated format and may be removed after sept 2006.
1517
def create_repository(self, shared=False):
1518
"""See BzrDir.create_repository."""
1519
return self._format.repository_format.initialize(self, shared)
1521
def needs_format_conversion(self, format=None):
1522
"""Format 4 dirs are always in need of conversion."""
1524
symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
1525
% 'needs_format_conversion(format=None)')
1528
def open_repository(self):
1529
"""See BzrDir.open_repository."""
1530
from bzrlib.repofmt.weaverepo import RepositoryFormat4
1531
return RepositoryFormat4().open(self, _found=True)
1534
class BzrDir5(BzrDirPreSplitOut):
1535
"""A .bzr version 5 control object.
1537
This is a deprecated format and may be removed after sept 2006.
1540
def open_repository(self):
1541
"""See BzrDir.open_repository."""
1542
from bzrlib.repofmt.weaverepo import RepositoryFormat5
1543
return RepositoryFormat5().open(self, _found=True)
1545
def open_workingtree(self, _unsupported=False,
1546
recommend_upgrade=True):
1547
"""See BzrDir.create_workingtree."""
1548
from bzrlib.workingtree import WorkingTreeFormat2
1549
wt_format = WorkingTreeFormat2()
1550
# we don't warn here about upgrades; that ought to be handled for the
1552
return wt_format.open(self, _found=True)
1555
class BzrDir6(BzrDirPreSplitOut):
1556
"""A .bzr version 6 control object.
1558
This is a deprecated format and may be removed after sept 2006.
1561
def open_repository(self):
1562
"""See BzrDir.open_repository."""
1563
from bzrlib.repofmt.weaverepo import RepositoryFormat6
1564
return RepositoryFormat6().open(self, _found=True)
1566
def open_workingtree(self, _unsupported=False,
1567
recommend_upgrade=True):
1568
"""See BzrDir.create_workingtree."""
1569
# we don't warn here about upgrades; that ought to be handled for the
1571
from bzrlib.workingtree import WorkingTreeFormat2
1572
return WorkingTreeFormat2().open(self, _found=True)
803
1575
class BzrDirMeta1(BzrDir):
1087
def open_branch(self, name=None, unsupported=False,
1088
ignore_fallbacks=False, possible_transports=None):
1089
"""See ControlDir.open_branch."""
1091
name = self._get_selected_branch()
1092
format = self.find_branch_format(name=name)
1093
format.check_support_status(unsupported)
1094
if possible_transports is None:
1095
possible_transports = []
1097
possible_transports = list(possible_transports)
1098
possible_transports.append(self.root_transport)
1099
return format.open(self, name=name,
1100
_found=True, ignore_fallbacks=ignore_fallbacks,
1101
possible_transports=possible_transports)
1721
def open_branch(self, unsupported=False, ignore_fallbacks=False):
1722
"""See BzrDir.open_branch."""
1723
format = self.find_branch_format()
1724
self._check_supported(format, unsupported)
1725
return format.open(self, _found=True, ignore_fallbacks=ignore_fallbacks)
1103
1727
def open_repository(self, unsupported=False):
1104
1728
"""See BzrDir.open_repository."""
1105
from .repository import RepositoryFormatMetaDir
1106
format = RepositoryFormatMetaDir.find_format(self)
1107
format.check_support_status(unsupported)
1729
from bzrlib.repository import RepositoryFormat
1730
format = RepositoryFormat.find_format(self)
1731
self._check_supported(format, unsupported)
1108
1732
return format.open(self, _found=True)
1110
1734
def open_workingtree(self, unsupported=False,
1111
recommend_upgrade=True):
1735
recommend_upgrade=True):
1112
1736
"""See BzrDir.open_workingtree."""
1113
from .workingtree import WorkingTreeFormatMetaDir
1114
format = WorkingTreeFormatMetaDir.find_format(self)
1115
format.check_support_status(unsupported, recommend_upgrade,
1116
basedir=self.root_transport.base)
1737
from bzrlib.workingtree import WorkingTreeFormat
1738
format = WorkingTreeFormat.find_format(self)
1739
self._check_supported(format, unsupported,
1741
basedir=self.root_transport.base)
1117
1742
return format.open(self, _found=True)
1119
1744
def _get_config(self):
1120
1745
return config.TransportConfig(self.transport, 'control.conf')
1123
class BzrFormat(object):
1124
"""Base class for all formats of things living in metadirs.
1126
This class manages the format string that is stored in the 'format'
1127
or 'branch-format' file.
1129
All classes for (branch-, repository-, workingtree-) formats that
1130
live in meta directories and have their own 'format' file
1131
(i.e. different from .bzr/branch-format) derive from this class,
1132
as well as the relevant base class for their kind
1133
(BranchFormat, WorkingTreeFormat, RepositoryFormat).
1135
Each format is identified by a "format" or "branch-format" file with a
1136
single line containing the base format name and then an optional list of
1139
Feature flags are supported as of bzr 2.5. Setting feature flags on formats
1140
will render them inaccessible to older versions of bzr.
1142
:ivar features: Dictionary mapping feature names to their necessity
1145
_present_features = set()
1151
def register_feature(cls, name):
1152
"""Register a feature as being present.
1154
:param name: Name of the feature
1157
raise ValueError("spaces are not allowed in feature names")
1158
if name in cls._present_features:
1159
raise FeatureAlreadyRegistered(name)
1160
cls._present_features.add(name)
1163
def unregister_feature(cls, name):
1164
"""Unregister a feature."""
1165
cls._present_features.remove(name)
1167
def check_support_status(self, allow_unsupported, recommend_upgrade=True,
1169
for name, necessity in self.features.items():
1170
if name in self._present_features:
1172
if necessity == b"optional":
1173
mutter("ignoring optional missing feature %s", name)
1175
elif necessity == b"required":
1176
raise MissingFeature(name)
1178
mutter("treating unknown necessity as require for %s",
1180
raise MissingFeature(name)
1183
def get_format_string(cls):
1184
"""Return the ASCII format string that identifies this format."""
1185
raise NotImplementedError(cls.get_format_string)
1188
def from_string(cls, text):
1189
format_string = cls.get_format_string()
1190
if not text.startswith(format_string):
1191
raise AssertionError(
1192
"Invalid format header %r for %r" % (text, cls))
1193
lines = text[len(format_string):].splitlines()
1195
for lineno, line in enumerate(lines):
1197
(necessity, feature) = line.split(b" ", 1)
1199
raise errors.ParseFormatError(format=cls, lineno=lineno + 2,
1200
line=line, text=text)
1201
ret.features[feature] = necessity
1204
def as_string(self):
1205
"""Return the string representation of this format.
1207
lines = [self.get_format_string()]
1208
lines.extend([(item[1] + b" " + item[0] + b"\n")
1209
for item in sorted(self.features.items())])
1210
return b"".join(lines)
1213
def _find_format(klass, registry, kind, format_string):
1215
first_line = format_string[:format_string.index(b"\n") + 1]
1217
first_line = format_string
1219
cls = registry.get(first_line)
1221
raise errors.UnknownFormatError(format=first_line, kind=kind)
1222
return cls.from_string(format_string)
1224
def network_name(self):
1225
"""A simple byte string uniquely identifying this format for RPC calls.
1227
Metadir branch formats use their format string.
1229
return self.as_string()
1231
def __eq__(self, other):
1232
return (self.__class__ is other.__class__
1233
and self.features == other.features)
1235
def _update_feature_flags(self, updated_flags):
1236
"""Update the feature flags in this format.
1238
:param updated_flags: Updated feature flags
1240
for name, necessity in updated_flags.items():
1241
if necessity is None:
1243
del self.features[name]
1247
self.features[name] = necessity
1250
class BzrDirFormat(BzrFormat, controldir.ControlDirFormat):
1251
"""ControlDirFormat base class for .bzr/ directories.
1748
class BzrDirFormat(object):
1749
"""An encapsulation of the initialization and open routines for a format.
1751
Formats provide three things:
1752
* An initialization routine,
1253
1756
Formats are placed in a dict by their format string for reference
1254
1757
during bzrdir opening. These should be subclasses of BzrDirFormat
1461
2120
compatible with whatever sub formats are supported by self.
1464
other_format.features = dict(self.features)
1466
def supports_transport(self, transport):
1467
# bzr formats can be opened over all known transports
1470
def check_support_status(self, allow_unsupported, recommend_upgrade=True,
1472
controldir.ControlDirFormat.check_support_status(self,
1473
allow_unsupported=allow_unsupported, recommend_upgrade=recommend_upgrade,
1475
BzrFormat.check_support_status(self, allow_unsupported=allow_unsupported,
1476
recommend_upgrade=recommend_upgrade, basedir=basedir)
1479
def is_control_filename(klass, filename):
1480
"""True if filename is the name of a path which is reserved for bzrdir's.
1482
:param filename: A filename within the root transport of this bzrdir.
1484
This is true IF and ONLY IF the filename is part of the namespace
1485
reserved for bzr control dirs. Currently this is the '.bzr' directory
1486
in the root of the root_transport.
1488
# this might be better on the BzrDirFormat class because it refers to
1489
# all the possible bzrdir disk formats.
1490
# This method is tested via the workingtree is_control_filename tests-
1491
# it was extracted from WorkingTree.is_control_filename. If the
1492
# method's contract is extended beyond the current trivial
1493
# implementation, please add new tests for it to the appropriate place.
1494
return filename == '.bzr' or filename.startswith('.bzr/')
1497
def get_default_format(klass):
1498
"""Return the current default format."""
1499
return controldir.format_registry.get('bzr')()
2125
def unregister_format(klass, format):
2126
del klass._formats[format.get_format_string()]
2129
def unregister_control_format(klass, format):
2130
klass._control_formats.remove(format)
2133
class BzrDirFormat4(BzrDirFormat):
2134
"""Bzr dir format 4.
2136
This format is a combined format for working tree, branch and repository.
2138
- Format 1 working trees [always]
2139
- Format 4 branches [always]
2140
- Format 4 repositories [always]
2142
This format is deprecated: it indexes texts using a text it which is
2143
removed in format 5; write support for this format has been removed.
2146
_lock_class = lockable_files.TransportLock
2148
def get_format_string(self):
2149
"""See BzrDirFormat.get_format_string()."""
2150
return "Bazaar-NG branch, format 0.0.4\n"
2152
def get_format_description(self):
2153
"""See BzrDirFormat.get_format_description()."""
2154
return "All-in-one format 4"
2156
def get_converter(self, format=None):
2157
"""See BzrDirFormat.get_converter()."""
2158
# there is one and only one upgrade path here.
2159
return ConvertBzrDir4To5()
2161
def initialize_on_transport(self, transport):
2162
"""Format 4 branches cannot be created."""
2163
raise errors.UninitializableFormat(self)
2165
def is_supported(self):
2166
"""Format 4 is not supported.
2168
It is not supported because the model changed from 4 to 5 and the
2169
conversion logic is expensive - so doing it on the fly was not
2174
def network_name(self):
2175
return self.get_format_string()
2177
def _open(self, transport):
2178
"""See BzrDirFormat._open."""
2179
return BzrDir4(transport, self)
2181
def __return_repository_format(self):
2182
"""Circular import protection."""
2183
from bzrlib.repofmt.weaverepo import RepositoryFormat4
2184
return RepositoryFormat4()
2185
repository_format = property(__return_repository_format)
2188
class BzrDirFormatAllInOne(BzrDirFormat):
2189
"""Common class for formats before meta-dirs."""
2191
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
2192
create_prefix=False, force_new_repo=False, stacked_on=None,
2193
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
2195
"""See BzrDirFormat.initialize_on_transport_ex."""
2196
require_stacking = (stacked_on is not None)
2197
# Format 5 cannot stack, but we've been asked to - actually init
2199
if require_stacking:
2200
format = BzrDirMetaFormat1()
2201
return format.initialize_on_transport_ex(transport,
2202
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
2203
force_new_repo=force_new_repo, stacked_on=stacked_on,
2204
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
2205
make_working_trees=make_working_trees, shared_repo=shared_repo)
2206
return BzrDirFormat.initialize_on_transport_ex(self, transport,
2207
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
2208
force_new_repo=force_new_repo, stacked_on=stacked_on,
2209
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
2210
make_working_trees=make_working_trees, shared_repo=shared_repo)
2213
class BzrDirFormat5(BzrDirFormatAllInOne):
2214
"""Bzr control format 5.
2216
This format is a combined format for working tree, branch and repository.
2218
- Format 2 working trees [always]
2219
- Format 4 branches [always]
2220
- Format 5 repositories [always]
2221
Unhashed stores in the repository.
2224
_lock_class = lockable_files.TransportLock
2226
def get_format_string(self):
2227
"""See BzrDirFormat.get_format_string()."""
2228
return "Bazaar-NG branch, format 5\n"
2230
def get_branch_format(self):
2231
from bzrlib import branch
2232
return branch.BzrBranchFormat4()
2234
def get_format_description(self):
2235
"""See BzrDirFormat.get_format_description()."""
2236
return "All-in-one format 5"
2238
def get_converter(self, format=None):
2239
"""See BzrDirFormat.get_converter()."""
2240
# there is one and only one upgrade path here.
2241
return ConvertBzrDir5To6()
2243
def _initialize_for_clone(self, url):
2244
return self.initialize_on_transport(get_transport(url), _cloning=True)
2246
def initialize_on_transport(self, transport, _cloning=False):
2247
"""Format 5 dirs always have working tree, branch and repository.
2249
Except when they are being cloned.
2251
from bzrlib.branch import BzrBranchFormat4
2252
from bzrlib.repofmt.weaverepo import RepositoryFormat5
2253
result = (super(BzrDirFormat5, self).initialize_on_transport(transport))
2254
RepositoryFormat5().initialize(result, _internal=True)
2256
branch = BzrBranchFormat4().initialize(result)
2257
result._init_workingtree()
2260
def network_name(self):
2261
return self.get_format_string()
2263
def _open(self, transport):
2264
"""See BzrDirFormat._open."""
2265
return BzrDir5(transport, self)
2267
def __return_repository_format(self):
2268
"""Circular import protection."""
2269
from bzrlib.repofmt.weaverepo import RepositoryFormat5
2270
return RepositoryFormat5()
2271
repository_format = property(__return_repository_format)
2274
class BzrDirFormat6(BzrDirFormatAllInOne):
2275
"""Bzr control format 6.
2277
This format is a combined format for working tree, branch and repository.
2279
- Format 2 working trees [always]
2280
- Format 4 branches [always]
2281
- Format 6 repositories [always]
2284
_lock_class = lockable_files.TransportLock
2286
def get_format_string(self):
2287
"""See BzrDirFormat.get_format_string()."""
2288
return "Bazaar-NG branch, format 6\n"
2290
def get_format_description(self):
2291
"""See BzrDirFormat.get_format_description()."""
2292
return "All-in-one format 6"
2294
def get_branch_format(self):
2295
from bzrlib import branch
2296
return branch.BzrBranchFormat4()
2298
def get_converter(self, format=None):
2299
"""See BzrDirFormat.get_converter()."""
2300
# there is one and only one upgrade path here.
2301
return ConvertBzrDir6ToMeta()
2303
def _initialize_for_clone(self, url):
2304
return self.initialize_on_transport(get_transport(url), _cloning=True)
2306
def initialize_on_transport(self, transport, _cloning=False):
2307
"""Format 6 dirs always have working tree, branch and repository.
2309
Except when they are being cloned.
2311
from bzrlib.branch import BzrBranchFormat4
2312
from bzrlib.repofmt.weaverepo import RepositoryFormat6
2313
result = super(BzrDirFormat6, self).initialize_on_transport(transport)
2314
RepositoryFormat6().initialize(result, _internal=True)
2316
branch = BzrBranchFormat4().initialize(result)
2317
result._init_workingtree()
2320
def network_name(self):
2321
return self.get_format_string()
2323
def _open(self, transport):
2324
"""See BzrDirFormat._open."""
2325
return BzrDir6(transport, self)
2327
def __return_repository_format(self):
2328
"""Circular import protection."""
2329
from bzrlib.repofmt.weaverepo import RepositoryFormat6
2330
return RepositoryFormat6()
2331
repository_format = property(__return_repository_format)
1502
2334
class BzrDirMetaFormat1(BzrDirFormat):
1710
2526
def __get_workingtree_format(self):
1711
2527
if self._workingtree_format is None:
1712
from .workingtree import (
1713
format_registry as wt_format_registry,
1715
self._workingtree_format = wt_format_registry.get_default()
2528
from bzrlib.workingtree import WorkingTreeFormat
2529
self._workingtree_format = WorkingTreeFormat.get_default_format()
1716
2530
return self._workingtree_format
1718
2532
def __set_workingtree_format(self, wt_format):
1719
2533
self._workingtree_format = wt_format
1722
return "<%r>" % (self.__class__.__name__,)
1724
2535
workingtree_format = property(__get_workingtree_format,
1725
2536
__set_workingtree_format)
1728
class BzrDirMetaFormat1Colo(BzrDirMetaFormat1):
1729
"""BzrDirMeta1 format with support for colocated branches."""
1731
colocated_branches = True
1734
def get_format_string(cls):
1735
"""See BzrDirFormat.get_format_string()."""
1736
return b"Bazaar meta directory, format 1 (with colocated branches)\n"
1738
def get_format_description(self):
1739
"""See BzrDirFormat.get_format_description()."""
1740
return "Meta directory format 1 with support for colocated branches"
1742
def _open(self, transport):
1743
"""See BzrDirFormat._open."""
1744
# Create a new format instance because otherwise initialisation of new
1745
# metadirs share the global default format object leading to alias
1747
format = BzrDirMetaFormat1Colo()
1748
self._supply_sub_formats_to(format)
1749
return BzrDirMeta1(transport, format)
1752
class ConvertMetaToMeta(controldir.Converter):
2539
network_format_registry = registry.FormatRegistry()
2540
"""Registry of formats indexed by their network name.
2542
The network name for a BzrDirFormat is an identifier that can be used when
2543
referring to formats with smart server operations. See
2544
BzrDirFormat.network_name() for more detail.
2548
# Register bzr control format
2549
BzrDirFormat.register_control_format(BzrDirFormat)
2551
# Register bzr formats
2552
BzrDirFormat.register_format(BzrDirFormat4())
2553
BzrDirFormat.register_format(BzrDirFormat5())
2554
BzrDirFormat.register_format(BzrDirFormat6())
2555
__default_format = BzrDirMetaFormat1()
2556
BzrDirFormat.register_format(__default_format)
2557
BzrDirFormat._default_format = __default_format
2560
class Converter(object):
2561
"""Converts a disk format object from one format to another."""
2563
def convert(self, to_convert, pb):
2564
"""Perform the conversion of to_convert, giving feedback via pb.
2566
:param to_convert: The disk object to convert.
2567
:param pb: a progress bar to use for progress information.
2570
def step(self, message):
2571
"""Update the pb by a step."""
2573
self.pb.update(message, self.count, self.total)
2576
class ConvertBzrDir4To5(Converter):
2577
"""Converts format 4 bzr dirs to format 5."""
2580
super(ConvertBzrDir4To5, self).__init__()
2581
self.converted_revs = set()
2582
self.absent_revisions = set()
2586
def convert(self, to_convert, pb):
2587
"""See Converter.convert()."""
2588
self.bzrdir = to_convert
2590
self.pb.note('starting upgrade from format 4 to 5')
2591
if isinstance(self.bzrdir.transport, local.LocalTransport):
2592
self.bzrdir.get_workingtree_transport(None).delete('stat-cache')
2593
self._convert_to_weaves()
2594
return BzrDir.open(self.bzrdir.root_transport.base)
2596
def _convert_to_weaves(self):
2597
self.pb.note('note: upgrade may be faster if all store files are ungzipped first')
2600
stat = self.bzrdir.transport.stat('weaves')
2601
if not S_ISDIR(stat.st_mode):
2602
self.bzrdir.transport.delete('weaves')
2603
self.bzrdir.transport.mkdir('weaves')
2604
except errors.NoSuchFile:
2605
self.bzrdir.transport.mkdir('weaves')
2606
# deliberately not a WeaveFile as we want to build it up slowly.
2607
self.inv_weave = Weave('inventory')
2608
# holds in-memory weaves for all files
2609
self.text_weaves = {}
2610
self.bzrdir.transport.delete('branch-format')
2611
self.branch = self.bzrdir.open_branch()
2612
self._convert_working_inv()
2613
rev_history = self.branch.revision_history()
2614
# to_read is a stack holding the revisions we still need to process;
2615
# appending to it adds new highest-priority revisions
2616
self.known_revisions = set(rev_history)
2617
self.to_read = rev_history[-1:]
2619
rev_id = self.to_read.pop()
2620
if (rev_id not in self.revisions
2621
and rev_id not in self.absent_revisions):
2622
self._load_one_rev(rev_id)
2624
to_import = self._make_order()
2625
for i, rev_id in enumerate(to_import):
2626
self.pb.update('converting revision', i, len(to_import))
2627
self._convert_one_rev(rev_id)
2629
self._write_all_weaves()
2630
self._write_all_revs()
2631
self.pb.note('upgraded to weaves:')
2632
self.pb.note(' %6d revisions and inventories', len(self.revisions))
2633
self.pb.note(' %6d revisions not present', len(self.absent_revisions))
2634
self.pb.note(' %6d texts', self.text_count)
2635
self._cleanup_spare_files_after_format4()
2636
self.branch._transport.put_bytes(
2638
BzrDirFormat5().get_format_string(),
2639
mode=self.bzrdir._get_file_mode())
2641
def _cleanup_spare_files_after_format4(self):
2642
# FIXME working tree upgrade foo.
2643
for n in 'merged-patches', 'pending-merged-patches':
2645
## assert os.path.getsize(p) == 0
2646
self.bzrdir.transport.delete(n)
2647
except errors.NoSuchFile:
2649
self.bzrdir.transport.delete_tree('inventory-store')
2650
self.bzrdir.transport.delete_tree('text-store')
2652
def _convert_working_inv(self):
2653
inv = xml4.serializer_v4.read_inventory(
2654
self.branch._transport.get('inventory'))
2655
new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv, working=True)
2656
self.branch._transport.put_bytes('inventory', new_inv_xml,
2657
mode=self.bzrdir._get_file_mode())
2659
def _write_all_weaves(self):
2660
controlweaves = WeaveStore(self.bzrdir.transport, prefixed=False)
2661
weave_transport = self.bzrdir.transport.clone('weaves')
2662
weaves = WeaveStore(weave_transport, prefixed=False)
2663
transaction = WriteTransaction()
2667
for file_id, file_weave in self.text_weaves.items():
2668
self.pb.update('writing weave', i, len(self.text_weaves))
2669
weaves._put_weave(file_id, file_weave, transaction)
2671
self.pb.update('inventory', 0, 1)
2672
controlweaves._put_weave('inventory', self.inv_weave, transaction)
2673
self.pb.update('inventory', 1, 1)
2677
def _write_all_revs(self):
2678
"""Write all revisions out in new form."""
2679
self.bzrdir.transport.delete_tree('revision-store')
2680
self.bzrdir.transport.mkdir('revision-store')
2681
revision_transport = self.bzrdir.transport.clone('revision-store')
2683
from bzrlib.xml5 import serializer_v5
2684
from bzrlib.repofmt.weaverepo import RevisionTextStore
2685
revision_store = RevisionTextStore(revision_transport,
2686
serializer_v5, False, versionedfile.PrefixMapper(),
2687
lambda:True, lambda:True)
2689
for i, rev_id in enumerate(self.converted_revs):
2690
self.pb.update('write revision', i, len(self.converted_revs))
2691
text = serializer_v5.write_revision_to_string(
2692
self.revisions[rev_id])
2694
revision_store.add_lines(key, None, osutils.split_lines(text))
2698
def _load_one_rev(self, rev_id):
2699
"""Load a revision object into memory.
2701
Any parents not either loaded or abandoned get queued to be
2703
self.pb.update('loading revision',
2704
len(self.revisions),
2705
len(self.known_revisions))
2706
if not self.branch.repository.has_revision(rev_id):
2708
self.pb.note('revision {%s} not present in branch; '
2709
'will be converted as a ghost',
2711
self.absent_revisions.add(rev_id)
2713
rev = self.branch.repository.get_revision(rev_id)
2714
for parent_id in rev.parent_ids:
2715
self.known_revisions.add(parent_id)
2716
self.to_read.append(parent_id)
2717
self.revisions[rev_id] = rev
2719
def _load_old_inventory(self, rev_id):
2720
old_inv_xml = self.branch.repository.inventory_store.get(rev_id).read()
2721
inv = xml4.serializer_v4.read_inventory_from_string(old_inv_xml)
2722
inv.revision_id = rev_id
2723
rev = self.revisions[rev_id]
2726
def _load_updated_inventory(self, rev_id):
2727
inv_xml = self.inv_weave.get_text(rev_id)
2728
inv = xml5.serializer_v5.read_inventory_from_string(inv_xml, rev_id)
2731
def _convert_one_rev(self, rev_id):
2732
"""Convert revision and all referenced objects to new format."""
2733
rev = self.revisions[rev_id]
2734
inv = self._load_old_inventory(rev_id)
2735
present_parents = [p for p in rev.parent_ids
2736
if p not in self.absent_revisions]
2737
self._convert_revision_contents(rev, inv, present_parents)
2738
self._store_new_inv(rev, inv, present_parents)
2739
self.converted_revs.add(rev_id)
2741
def _store_new_inv(self, rev, inv, present_parents):
2742
new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv)
2743
new_inv_sha1 = sha_string(new_inv_xml)
2744
self.inv_weave.add_lines(rev.revision_id,
2746
new_inv_xml.splitlines(True))
2747
rev.inventory_sha1 = new_inv_sha1
2749
def _convert_revision_contents(self, rev, inv, present_parents):
2750
"""Convert all the files within a revision.
2752
Also upgrade the inventory to refer to the text revision ids."""
2753
rev_id = rev.revision_id
2754
mutter('converting texts of revision {%s}',
2756
parent_invs = map(self._load_updated_inventory, present_parents)
2757
entries = inv.iter_entries()
2759
for path, ie in entries:
2760
self._convert_file_version(rev, ie, parent_invs)
2762
def _convert_file_version(self, rev, ie, parent_invs):
2763
"""Convert one version of one file.
2765
The file needs to be added into the weave if it is a merge
2766
of >=2 parents or if it's changed from its parent.
2768
file_id = ie.file_id
2769
rev_id = rev.revision_id
2770
w = self.text_weaves.get(file_id)
2773
self.text_weaves[file_id] = w
2774
text_changed = False
2775
parent_candiate_entries = ie.parent_candidates(parent_invs)
2776
heads = graph.Graph(self).heads(parent_candiate_entries.keys())
2777
# XXX: Note that this is unordered - and this is tolerable because
2778
# the previous code was also unordered.
2779
previous_entries = dict((head, parent_candiate_entries[head]) for head
2781
self.snapshot_ie(previous_entries, ie, w, rev_id)
2784
def get_parent_map(self, revision_ids):
2785
"""See graph.StackedParentsProvider.get_parent_map"""
2786
return dict((revision_id, self.revisions[revision_id])
2787
for revision_id in revision_ids
2788
if revision_id in self.revisions)
2790
def snapshot_ie(self, previous_revisions, ie, w, rev_id):
2791
# TODO: convert this logic, which is ~= snapshot to
2792
# a call to:. This needs the path figured out. rather than a work_tree
2793
# a v4 revision_tree can be given, or something that looks enough like
2794
# one to give the file content to the entry if it needs it.
2795
# and we need something that looks like a weave store for snapshot to
2797
#ie.snapshot(rev, PATH, previous_revisions, REVISION_TREE, InMemoryWeaveStore(self.text_weaves))
2798
if len(previous_revisions) == 1:
2799
previous_ie = previous_revisions.values()[0]
2800
if ie._unchanged(previous_ie):
2801
ie.revision = previous_ie.revision
2804
text = self.branch.repository._text_store.get(ie.text_id)
2805
file_lines = text.readlines()
2806
w.add_lines(rev_id, previous_revisions, file_lines)
2807
self.text_count += 1
2809
w.add_lines(rev_id, previous_revisions, [])
2810
ie.revision = rev_id
2812
def _make_order(self):
2813
"""Return a suitable order for importing revisions.
2815
The order must be such that an revision is imported after all
2816
its (present) parents.
2818
todo = set(self.revisions.keys())
2819
done = self.absent_revisions.copy()
2822
# scan through looking for a revision whose parents
2824
for rev_id in sorted(list(todo)):
2825
rev = self.revisions[rev_id]
2826
parent_ids = set(rev.parent_ids)
2827
if parent_ids.issubset(done):
2828
# can take this one now
2829
order.append(rev_id)
2835
class ConvertBzrDir5To6(Converter):
2836
"""Converts format 5 bzr dirs to format 6."""
2838
def convert(self, to_convert, pb):
2839
"""See Converter.convert()."""
2840
self.bzrdir = to_convert
2842
self.pb.note('starting upgrade from format 5 to 6')
2843
self._convert_to_prefixed()
2844
return BzrDir.open(self.bzrdir.root_transport.base)
2846
def _convert_to_prefixed(self):
2847
from bzrlib.store import TransportStore
2848
self.bzrdir.transport.delete('branch-format')
2849
for store_name in ["weaves", "revision-store"]:
2850
self.pb.note("adding prefixes to %s" % store_name)
2851
store_transport = self.bzrdir.transport.clone(store_name)
2852
store = TransportStore(store_transport, prefixed=True)
2853
for urlfilename in store_transport.list_dir('.'):
2854
filename = urlutils.unescape(urlfilename)
2855
if (filename.endswith(".weave") or
2856
filename.endswith(".gz") or
2857
filename.endswith(".sig")):
2858
file_id, suffix = os.path.splitext(filename)
2862
new_name = store._mapper.map((file_id,)) + suffix
2863
# FIXME keep track of the dirs made RBC 20060121
2865
store_transport.move(filename, new_name)
2866
except errors.NoSuchFile: # catches missing dirs strangely enough
2867
store_transport.mkdir(osutils.dirname(new_name))
2868
store_transport.move(filename, new_name)
2869
self.bzrdir.transport.put_bytes(
2871
BzrDirFormat6().get_format_string(),
2872
mode=self.bzrdir._get_file_mode())
2875
class ConvertBzrDir6ToMeta(Converter):
2876
"""Converts format 6 bzr dirs to metadirs."""
2878
def convert(self, to_convert, pb):
2879
"""See Converter.convert()."""
2880
from bzrlib.repofmt.weaverepo import RepositoryFormat7
2881
from bzrlib.branch import BzrBranchFormat5
2882
self.bzrdir = to_convert
2885
self.total = 20 # the steps we know about
2886
self.garbage_inventories = []
2887
self.dir_mode = self.bzrdir._get_dir_mode()
2888
self.file_mode = self.bzrdir._get_file_mode()
2890
self.pb.note('starting upgrade from format 6 to metadir')
2891
self.bzrdir.transport.put_bytes(
2893
"Converting to format 6",
2894
mode=self.file_mode)
2895
# its faster to move specific files around than to open and use the apis...
2896
# first off, nuke ancestry.weave, it was never used.
2898
self.step('Removing ancestry.weave')
2899
self.bzrdir.transport.delete('ancestry.weave')
2900
except errors.NoSuchFile:
2902
# find out whats there
2903
self.step('Finding branch files')
2904
last_revision = self.bzrdir.open_branch().last_revision()
2905
bzrcontents = self.bzrdir.transport.list_dir('.')
2906
for name in bzrcontents:
2907
if name.startswith('basis-inventory.'):
2908
self.garbage_inventories.append(name)
2909
# create new directories for repository, working tree and branch
2910
repository_names = [('inventory.weave', True),
2911
('revision-store', True),
2913
self.step('Upgrading repository ')
2914
self.bzrdir.transport.mkdir('repository', mode=self.dir_mode)
2915
self.make_lock('repository')
2916
# we hard code the formats here because we are converting into
2917
# the meta format. The meta format upgrader can take this to a
2918
# future format within each component.
2919
self.put_format('repository', RepositoryFormat7())
2920
for entry in repository_names:
2921
self.move_entry('repository', entry)
2923
self.step('Upgrading branch ')
2924
self.bzrdir.transport.mkdir('branch', mode=self.dir_mode)
2925
self.make_lock('branch')
2926
self.put_format('branch', BzrBranchFormat5())
2927
branch_files = [('revision-history', True),
2928
('branch-name', True),
2930
for entry in branch_files:
2931
self.move_entry('branch', entry)
2933
checkout_files = [('pending-merges', True),
2934
('inventory', True),
2935
('stat-cache', False)]
2936
# If a mandatory checkout file is not present, the branch does not have
2937
# a functional checkout. Do not create a checkout in the converted
2939
for name, mandatory in checkout_files:
2940
if mandatory and name not in bzrcontents:
2941
has_checkout = False
2945
if not has_checkout:
2946
self.pb.note('No working tree.')
2947
# If some checkout files are there, we may as well get rid of them.
2948
for name, mandatory in checkout_files:
2949
if name in bzrcontents:
2950
self.bzrdir.transport.delete(name)
2952
from bzrlib.workingtree import WorkingTreeFormat3
2953
self.step('Upgrading working tree')
2954
self.bzrdir.transport.mkdir('checkout', mode=self.dir_mode)
2955
self.make_lock('checkout')
2957
'checkout', WorkingTreeFormat3())
2958
self.bzrdir.transport.delete_multi(
2959
self.garbage_inventories, self.pb)
2960
for entry in checkout_files:
2961
self.move_entry('checkout', entry)
2962
if last_revision is not None:
2963
self.bzrdir.transport.put_bytes(
2964
'checkout/last-revision', last_revision)
2965
self.bzrdir.transport.put_bytes(
2967
BzrDirMetaFormat1().get_format_string(),
2968
mode=self.file_mode)
2969
return BzrDir.open(self.bzrdir.root_transport.base)
2971
def make_lock(self, name):
2972
"""Make a lock for the new control dir name."""
2973
self.step('Make %s lock' % name)
2974
ld = lockdir.LockDir(self.bzrdir.transport,
2976
file_modebits=self.file_mode,
2977
dir_modebits=self.dir_mode)
2980
def move_entry(self, new_dir, entry):
2981
"""Move then entry name into new_dir."""
2983
mandatory = entry[1]
2984
self.step('Moving %s' % name)
2986
self.bzrdir.transport.move(name, '%s/%s' % (new_dir, name))
2987
except errors.NoSuchFile:
2991
def put_format(self, dirname, format):
2992
self.bzrdir.transport.put_bytes('%s/format' % dirname,
2993
format.get_format_string(),
2997
class ConvertMetaToMeta(Converter):
1753
2998
"""Converts the components of metadirs."""
1755
3000
def __init__(self, target_format):
1762
3007
def convert(self, to_convert, pb):
1763
3008
"""See Converter.convert()."""
1764
self.controldir = to_convert
1765
with ui.ui_factory.nested_progress_bar() as self.pb:
1768
self.step('checking repository format')
1770
repo = self.controldir.open_repository()
1771
except errors.NoRepositoryPresent:
1774
repo_fmt = self.target_format.repository_format
1775
if not isinstance(repo._format, repo_fmt.__class__):
1776
from ..repository import CopyConverter
1777
ui.ui_factory.note(gettext('starting repository conversion'))
1778
if not repo_fmt.supports_overriding_transport:
1779
raise AssertionError(
1780
"Repository in metadir does not support "
1781
"overriding transport")
1782
converter = CopyConverter(self.target_format.repository_format)
1783
converter.convert(repo, pb)
1784
for branch in self.controldir.list_branches():
1785
# TODO: conversions of Branch and Tree should be done by
1786
# InterXFormat lookups/some sort of registry.
1787
# Avoid circular imports
3009
self.bzrdir = to_convert
3013
self.step('checking repository format')
3015
repo = self.bzrdir.open_repository()
3016
except errors.NoRepositoryPresent:
3019
if not isinstance(repo._format, self.target_format.repository_format.__class__):
3020
from bzrlib.repository import CopyConverter
3021
self.pb.note('starting repository conversion')
3022
converter = CopyConverter(self.target_format.repository_format)
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()
1788
3053
old = branch._format.__class__
1789
new = self.target_format.get_branch_format().__class__
1791
if (old == fullhistorybranch.BzrBranchFormat5
1792
and new in (_mod_bzrbranch.BzrBranchFormat6,
1793
_mod_bzrbranch.BzrBranchFormat7,
1794
_mod_bzrbranch.BzrBranchFormat8)):
1795
branch_converter = _mod_bzrbranch.Converter5to6()
1796
elif (old == _mod_bzrbranch.BzrBranchFormat6
1797
and new in (_mod_bzrbranch.BzrBranchFormat7,
1798
_mod_bzrbranch.BzrBranchFormat8)):
1799
branch_converter = _mod_bzrbranch.Converter6to7()
1800
elif (old == _mod_bzrbranch.BzrBranchFormat7
1801
and new is _mod_bzrbranch.BzrBranchFormat8):
1802
branch_converter = _mod_bzrbranch.Converter7to8()
1804
raise errors.BadConversionTarget("No converter", new,
1806
branch_converter.convert(branch)
1807
branch = self.controldir.open_branch()
1808
old = branch._format.__class__
1810
tree = self.controldir.open_workingtree(recommend_upgrade=False)
1811
except (errors.NoWorkingTree, errors.NotLocalUrl):
1814
# TODO: conversions of Branch and Tree should be done by
1815
# InterXFormat lookups
1816
if (isinstance(tree, workingtree_3.WorkingTree3)
1817
and not isinstance(tree, workingtree_4.DirStateWorkingTree)
1818
and isinstance(self.target_format.workingtree_format,
1819
workingtree_4.DirStateWorkingTreeFormat)):
1820
workingtree_4.Converter3to4().convert(tree)
1821
if (isinstance(tree, workingtree_4.DirStateWorkingTree)
1822
and not isinstance(tree, workingtree_4.WorkingTree5)
1823
and isinstance(self.target_format.workingtree_format,
1824
workingtree_4.WorkingTreeFormat5)):
1825
workingtree_4.Converter4to5().convert(tree)
1826
if (isinstance(tree, workingtree_4.DirStateWorkingTree)
1827
and not isinstance(tree, workingtree_4.WorkingTree6)
1828
and isinstance(self.target_format.workingtree_format,
1829
workingtree_4.WorkingTreeFormat6)):
1830
workingtree_4.Converter4or5to6().convert(tree)
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)
1831
3076
return to_convert
1834
class ConvertMetaToColo(controldir.Converter):
1835
"""Add colocated branch support."""
1837
def __init__(self, target_format):
1838
"""Create a converter.that upgrades a metadir to the colo format.
1840
:param target_format: The final metadir format that is desired.
1842
self.target_format = target_format
1844
def convert(self, to_convert, pb):
1845
"""See Converter.convert()."""
1846
to_convert.transport.put_bytes('branch-format',
1847
self.target_format.as_string())
1848
return BzrDir.open_from_transport(to_convert.root_transport)
1851
class ConvertMetaToColo(controldir.Converter):
1852
"""Convert a 'development-colo' bzrdir to a '2a' bzrdir."""
1854
def __init__(self, target_format):
1855
"""Create a converter that converts a 'development-colo' metadir
1858
:param target_format: The final metadir format that is desired.
1860
self.target_format = target_format
1862
def convert(self, to_convert, pb):
1863
"""See Converter.convert()."""
1864
to_convert.transport.put_bytes('branch-format',
1865
self.target_format.as_string())
1866
return BzrDir.open_from_transport(to_convert.root_transport)
1869
class CreateRepository(controldir.RepositoryAcquisitionPolicy):
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):
1870
3611
"""A policy of creating a new repository"""
1872
def __init__(self, controldir, stack_on=None, stack_on_pwd=None,
3613
def __init__(self, bzrdir, stack_on=None, stack_on_pwd=None,
1873
3614
require_stacking=False):
1876
:param controldir: The controldir to create the repository on.
3617
:param bzrdir: The bzrdir to create the repository on.
1877
3618
:param stack_on: A location to stack on
1878
3619
:param stack_on_pwd: If stack_on is relative, the location it is
1881
super(CreateRepository, self).__init__(
1882
stack_on, stack_on_pwd, require_stacking)
1883
self._controldir = controldir
3622
RepositoryAcquisitionPolicy.__init__(self, stack_on, stack_on_pwd,
3624
self._bzrdir = bzrdir
1885
def acquire_repository(self, make_working_trees=None, shared=False,
1886
possible_transports=None):
3626
def acquire_repository(self, make_working_trees=None, shared=False):
1887
3627
"""Implementation of RepositoryAcquisitionPolicy.acquire_repository
1889
Creates the desired repository in the controldir we already have.
3629
Creates the desired repository in the bzrdir we already have.
1891
if possible_transports is None:
1892
possible_transports = []
1894
possible_transports = list(possible_transports)
1895
possible_transports.append(self._controldir.root_transport)
1896
3631
stack_on = self._get_full_stack_on()
1898
format = self._controldir._format
3633
format = self._bzrdir._format
1899
3634
format.require_stacking(stack_on=stack_on,
1900
possible_transports=possible_transports)
3635
possible_transports=[self._bzrdir.root_transport])
1901
3636
if not self._require_stacking:
1902
3637
# We have picked up automatic stacking somewhere.
1903
note(gettext('Using default stacking branch {0} at {1}').format(
1904
self._stack_on, self._stack_on_pwd))
1905
repository = self._controldir.create_repository(shared=shared)
3638
note('Using default stacking branch %s at %s', self._stack_on,
3640
repository = self._bzrdir.create_repository(shared=shared)
1906
3641
self._add_fallback(repository,
1907
possible_transports=possible_transports)
3642
possible_transports=[self._bzrdir.transport])
1908
3643
if make_working_trees is not None:
1909
3644
repository.set_make_working_trees(make_working_trees)
1910
3645
return repository, True
1913
class UseExistingRepository(controldir.RepositoryAcquisitionPolicy):
3648
class UseExistingRepository(RepositoryAcquisitionPolicy):
1914
3649
"""A policy of reusing an existing repository"""
1916
3651
def __init__(self, repository, stack_on=None, stack_on_pwd=None,
1922
3657
:param stack_on_pwd: If stack_on is relative, the location it is
1925
super(UseExistingRepository, self).__init__(
1926
stack_on, stack_on_pwd, require_stacking)
3660
RepositoryAcquisitionPolicy.__init__(self, stack_on, stack_on_pwd,
1927
3662
self._repository = repository
1929
def acquire_repository(self, make_working_trees=None, shared=False,
1930
possible_transports=None):
3664
def acquire_repository(self, make_working_trees=None, shared=False):
1931
3665
"""Implementation of RepositoryAcquisitionPolicy.acquire_repository
1933
3667
Returns an existing repository to use.
1935
if possible_transports is None:
1936
possible_transports = []
1938
possible_transports = list(possible_transports)
1939
possible_transports.append(self._repository.controldir.transport)
1940
3669
self._add_fallback(self._repository,
1941
possible_transports=possible_transports)
3670
possible_transports=[self._repository.bzrdir.transport])
1942
3671
return self._repository, False
1945
controldir.ControlDirFormat._default_format = BzrDirMetaFormat1()
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')