292
233
# TODO: This should be given a Transport, and should chdir up; otherwise
293
234
# this will open a new connection.
294
235
def _make_tail(self, url):
295
t = get_transport(url)
299
def create(cls, base, format=None, possible_transports=None):
300
"""Create a new BzrDir at the url 'base'.
302
:param format: If supplied, the format of branch to create. If not
303
supplied, the default is used.
304
:param possible_transports: If supplied, a list of transports that
305
can be reused to share a remote connection.
307
if cls is not BzrDir:
308
raise AssertionError("BzrDir.create always creates the default"
309
" format, not one of %r" % cls)
310
t = get_transport(base, possible_transports)
313
format = BzrDirFormat.get_default_format()
314
return format.initialize_on_transport(t)
317
def find_bzrdirs(transport, evaluate=None, list_current=None):
318
"""Find bzrdirs recursively from current location.
320
This is intended primarily as a building block for more sophisticated
321
functionality, like finding trees under a directory, or finding
322
branches that use a given repository.
323
:param evaluate: An optional callable that yields recurse, value,
324
where recurse controls whether this bzrdir is recursed into
325
and value is the value to yield. By default, all bzrdirs
326
are recursed into, and the return value is the bzrdir.
327
:param list_current: if supplied, use this function to list the current
328
directory, instead of Transport.list_dir
329
:return: a generator of found bzrdirs, or whatever evaluate returns.
331
if list_current is None:
332
def list_current(transport):
333
return transport.list_dir('')
335
def evaluate(bzrdir):
338
pending = [transport]
339
while len(pending) > 0:
340
current_transport = pending.pop()
343
bzrdir = BzrDir.open_from_transport(current_transport)
344
except errors.NotBranchError:
347
recurse, value = evaluate(bzrdir)
350
subdirs = list_current(current_transport)
351
except errors.NoSuchFile:
354
for subdir in sorted(subdirs, reverse=True):
355
pending.append(current_transport.clone(subdir))
358
def find_branches(transport):
359
"""Find all branches under a transport.
361
This will find all branches below the transport, including branches
362
inside other branches. Where possible, it will use
363
Repository.find_branches.
365
To list all the branches that use a particular Repository, see
366
Repository.find_branches
368
def evaluate(bzrdir):
370
repository = bzrdir.open_repository()
371
except errors.NoRepositoryPresent:
374
return False, (None, repository)
376
branch = bzrdir.open_branch()
377
except errors.NotBranchError:
378
return True, (None, None)
380
return True, (branch, None)
382
for branch, repo in BzrDir.find_bzrdirs(transport, evaluate=evaluate):
384
branches.extend(repo.find_branches())
385
if branch is not None:
386
branches.append(branch)
389
def destroy_repository(self):
390
"""Destroy the repository in this BzrDir"""
391
raise NotImplementedError(self.destroy_repository)
393
def create_branch(self):
394
"""Create a branch in this BzrDir.
396
The bzrdir's format will control what branch format is created.
397
For more control see BranchFormatXX.create(a_bzrdir).
399
raise NotImplementedError(self.create_branch)
401
def destroy_branch(self):
402
"""Destroy the branch in this BzrDir"""
403
raise NotImplementedError(self.destroy_branch)
406
def create_branch_and_repo(base, force_new_repo=False, format=None):
407
"""Create a new BzrDir, Branch and Repository at the url 'base'.
409
This will use the current default BzrDirFormat unless one is
410
specified, and use whatever
411
repository format that that uses via bzrdir.create_branch and
412
create_repository. If a shared repository is available that is used
415
The created Branch object is returned.
417
:param base: The URL to create the branch at.
418
:param force_new_repo: If True a new repository is always created.
419
:param format: If supplied, the format of branch to create. If not
420
supplied, the default is used.
422
bzrdir = BzrDir.create(base, format)
423
bzrdir._find_or_create_repository(force_new_repo)
424
return bzrdir.create_branch()
236
t = _mod_transport.get_transport(url)
426
239
def determine_repository_policy(self, force_new_repo=False, stack_on=None,
427
240
stack_on_pwd=None, require_stacking=False):
489
302
policy = self.determine_repository_policy(force_new_repo)
490
303
return policy.acquire_repository()[0]
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.
305
def _find_source_repo(self, add_cleanup, source_branch):
306
"""Find the source branch and repo for a sprout operation.
308
This is helper intended for use by _sprout.
310
:returns: (source_branch, source_repository). Either or both may be
311
None. If not None, they will be read-locked (and their unlock(s)
312
scheduled via the add_cleanup param).
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):
314
if source_branch is not None:
315
add_cleanup(source_branch.lock_read().unlock)
316
return source_branch, source_branch.repository
318
source_branch = self.open_branch()
319
source_repository = source_branch.repository
320
except errors.NotBranchError:
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)
323
source_repository = self.open_repository()
324
except errors.NoRepositoryPresent:
325
source_repository = None
327
add_cleanup(source_repository.lock_read().unlock)
329
add_cleanup(source_branch.lock_read().unlock)
330
return source_branch, source_repository
332
def sprout(self, url, revision_id=None, force_new_repo=False,
333
recurse='down', possible_transports=None,
334
accelerator_tree=None, hardlink=False, stacked=False,
335
source_branch=None, create_tree_if_local=True):
336
"""Create a copy of this controldir prepared for use as a new line of
339
If url's last component does not exist, it will be created.
341
Attributes related to the identity of the source branch like
342
branch nickname will be cleaned, a working tree is created
343
whether one existed before or not; and a local branch is always
346
if revision_id is not None, then the clone operation may tune
347
itself to download less data.
565
349
:param accelerator_tree: A tree which can be used for retrieving file
566
350
contents more quickly than the revision tree, i.e. a workingtree.
567
351
The revision tree will be used for cases where accelerator_tree's
568
352
content is different.
570
raise NotImplementedError(self.create_workingtree)
353
:param hardlink: If true, hard-link files from accelerator_tree,
355
:param stacked: If true, create a stacked branch referring to the
356
location of this control directory.
357
:param create_tree_if_local: If true, a working-tree will be created
358
when working locally.
359
:return: The created control directory
361
operation = cleanup.OperationWithCleanups(self._sprout)
362
return operation.run(url, revision_id=revision_id,
363
force_new_repo=force_new_repo, recurse=recurse,
364
possible_transports=possible_transports,
365
accelerator_tree=accelerator_tree, hardlink=hardlink,
366
stacked=stacked, source_branch=source_branch,
367
create_tree_if_local=create_tree_if_local)
369
def _sprout(self, op, url, revision_id=None, force_new_repo=False,
370
recurse='down', possible_transports=None,
371
accelerator_tree=None, hardlink=False, stacked=False,
372
source_branch=None, create_tree_if_local=True):
373
add_cleanup = op.add_cleanup
374
fetch_spec_factory = fetch.FetchSpecFactory()
375
if revision_id is not None:
376
fetch_spec_factory.add_revision_ids([revision_id])
377
fetch_spec_factory.source_branch_stop_revision_id = revision_id
378
if possible_transports is None:
379
possible_transports = []
381
possible_transports = list(possible_transports) + [
383
target_transport = _mod_transport.get_transport(url,
385
target_transport.ensure_base()
386
cloning_format = self.cloning_metadir(stacked)
387
# Create/update the result branch
389
result = controldir.ControlDir.open_from_transport(target_transport)
390
except errors.NotBranchError:
391
result = cloning_format.initialize_on_transport(target_transport)
392
source_branch, source_repository = self._find_source_repo(
393
add_cleanup, source_branch)
394
fetch_spec_factory.source_branch = source_branch
395
# if a stacked branch wasn't requested, we don't create one
396
# even if the origin was stacked
397
if stacked and source_branch is not None:
398
stacked_branch_url = self.root_transport.base
400
stacked_branch_url = None
401
repository_policy = result.determine_repository_policy(
402
force_new_repo, stacked_branch_url, require_stacking=stacked)
403
result_repo, is_new_repo = repository_policy.acquire_repository(
404
possible_transports=possible_transports)
405
add_cleanup(result_repo.lock_write().unlock)
406
fetch_spec_factory.source_repo = source_repository
407
fetch_spec_factory.target_repo = result_repo
408
if stacked or (len(result_repo._fallback_repositories) != 0):
409
target_repo_kind = fetch.TargetRepoKinds.STACKED
411
target_repo_kind = fetch.TargetRepoKinds.EMPTY
413
target_repo_kind = fetch.TargetRepoKinds.PREEXISTING
414
fetch_spec_factory.target_repo_kind = target_repo_kind
415
if source_repository is not None:
416
fetch_spec = fetch_spec_factory.make_fetch_spec()
417
result_repo.fetch(source_repository, fetch_spec=fetch_spec)
419
if source_branch is None:
420
# this is for sprouting a controldir without a branch; is that
422
# Not especially, but it's part of the contract.
423
result_branch = result.create_branch()
425
result_branch = source_branch.sprout(result,
426
revision_id=revision_id, repository_policy=repository_policy,
427
repository=result_repo)
428
mutter("created new branch %r" % (result_branch,))
430
# Create/update the result working tree
431
if (create_tree_if_local and not result.has_workingtree() and
432
isinstance(target_transport, local.LocalTransport) and
433
(result_repo is None or result_repo.make_working_trees())):
434
wt = result.create_workingtree(accelerator_tree=accelerator_tree,
435
hardlink=hardlink, from_branch=result_branch)
438
if wt.path2id('') is None:
440
wt.set_root_id(self.open_workingtree.get_root_id())
441
except errors.NoWorkingTree:
447
if recurse == 'down':
450
basis = wt.basis_tree()
451
elif result_branch is not None:
452
basis = result_branch.basis_tree()
453
elif source_branch is not None:
454
basis = source_branch.basis_tree()
455
if basis is not None:
456
add_cleanup(basis.lock_read().unlock)
457
subtrees = basis.iter_references()
460
for path, file_id in subtrees:
461
target = urlutils.join(url, urlutils.escape(path))
462
sublocation = source_branch.reference_parent(file_id, path)
463
sublocation.bzrdir.sprout(target,
464
basis.get_reference_revision(file_id, path),
465
force_new_repo=force_new_repo, recurse=recurse,
469
def _available_backup_name(self, base):
470
"""Find a non-existing backup file name based on base.
472
See bzrlib.osutils.available_backup_name about race conditions.
474
return osutils.available_backup_name(base, self.root_transport.has)
572
476
def backup_bzrdir(self):
573
477
"""Backup this bzr control directory.
575
479
:return: Tuple with old path name and new path name
577
482
pb = ui.ui_factory.nested_progress_bar()
579
# FIXME: bug 300001 -- the backup fails if the backup directory
580
# already exists, but it should instead either remove it or make
581
# a new backup directory.
583
# FIXME: bug 262450 -- the backup directory should have the same
584
# permissions as the .bzr directory (probably a bug in copy_tree)
585
484
old_path = self.root_transport.abspath('.bzr')
586
new_path = self.root_transport.abspath('backup.bzr')
587
ui.ui_factory.note('making backup of %s\n to %s' % (old_path, new_path,))
588
self.root_transport.copy_tree('.bzr', 'backup.bzr')
485
backup_dir = self._available_backup_name('backup.bzr')
486
new_path = self.root_transport.abspath(backup_dir)
487
ui.ui_factory.note(gettext('making backup of {0}\n to {1}').format(
488
urlutils.unescape_for_display(old_path, 'utf-8'),
489
urlutils.unescape_for_display(new_path, 'utf-8')))
490
self.root_transport.copy_tree('.bzr', backup_dir)
589
491
return (old_path, new_path)
817
664
# add new tests for it to the appropriate place.
818
665
return filename == '.bzr' or filename.startswith('.bzr/')
820
def needs_format_conversion(self, format=None):
821
"""Return true if this bzrdir needs convert_format run on it.
823
For instance, if the repository format is out of date but the
824
branch and working tree are not, this should return True.
826
:param format: Optional parameter indicating a specific desired
827
format we plan to arrive at.
829
raise NotImplementedError(self.needs_format_conversion)
832
def open_unsupported(base):
833
"""Open a branch which is not supported."""
834
return BzrDir.open(base, _unsupported=True)
837
def open(base, _unsupported=False, possible_transports=None):
838
"""Open an existing bzrdir, rooted at 'base' (url).
840
:param _unsupported: a private parameter to the BzrDir class.
842
t = get_transport(base, possible_transports=possible_transports)
843
return BzrDir.open_from_transport(t, _unsupported=_unsupported)
846
def open_from_transport(transport, _unsupported=False,
847
_server_formats=True):
848
"""Open a bzrdir within a particular directory.
850
:param transport: Transport containing the bzrdir.
851
:param _unsupported: private.
853
for hook in BzrDir.hooks['pre_open']:
855
# Keep initial base since 'transport' may be modified while following
857
base = transport.base
858
def find_format(transport):
859
return transport, BzrDirFormat.find_format(
860
transport, _server_formats=_server_formats)
862
def redirected(transport, e, redirection_notice):
863
redirected_transport = transport._redirected_to(e.source, e.target)
864
if redirected_transport is None:
865
raise errors.NotBranchError(base)
866
note('%s is%s redirected to %s',
867
transport.base, e.permanently, redirected_transport.base)
868
return redirected_transport
871
transport, format = do_catching_redirections(find_format,
874
except errors.TooManyRedirections:
875
raise errors.NotBranchError(base)
877
BzrDir._check_supported(format, _unsupported)
878
return format.open(transport, _found=True)
880
def open_branch(self, unsupported=False, ignore_fallbacks=False):
881
"""Open the branch object at this BzrDir if one is present.
883
If unsupported is True, then no longer supported branch formats can
886
TODO: static convenience version of this?
888
raise NotImplementedError(self.open_branch)
891
def open_containing(url, possible_transports=None):
892
"""Open an existing branch which contains url.
894
:param url: url to search from.
895
See open_containing_from_transport for more detail.
897
transport = get_transport(url, possible_transports)
898
return BzrDir.open_containing_from_transport(transport)
901
def open_containing_from_transport(a_transport):
902
"""Open an existing branch which contains a_transport.base.
904
This probes for a branch at a_transport, and searches upwards from there.
906
Basically we keep looking up until we find the control directory or
907
run into the root. If there isn't one, raises NotBranchError.
908
If there is one and it is either an unrecognised format or an unsupported
909
format, UnknownFormatError or UnsupportedFormatError are raised.
910
If there is one, it is returned, along with the unused portion of url.
912
:return: The BzrDir that contains the path, and a Unicode path
913
for the rest of the URL.
915
# this gets the normalised url back. I.e. '.' -> the full path.
916
url = a_transport.base
919
result = BzrDir.open_from_transport(a_transport)
920
return result, urlutils.unescape(a_transport.relpath(url))
921
except errors.NotBranchError, e:
924
new_t = a_transport.clone('..')
925
except errors.InvalidURLJoin:
926
# reached the root, whatever that may be
927
raise errors.NotBranchError(path=url)
928
if new_t.base == a_transport.base:
929
# reached the root, whatever that may be
930
raise errors.NotBranchError(path=url)
933
def _get_tree_branch(self):
934
"""Return the branch and tree, if any, for this bzrdir.
936
Return None for tree if not present or inaccessible.
937
Raise NotBranchError if no branch is present.
938
:return: (tree, branch)
941
tree = self.open_workingtree()
942
except (errors.NoWorkingTree, errors.NotLocalUrl):
944
branch = self.open_branch()
950
def open_tree_or_branch(klass, location):
951
"""Return the branch and working tree at a location.
953
If there is no tree at the location, tree will be None.
954
If there is no branch at the location, an exception will be
956
:return: (tree, branch)
958
bzrdir = klass.open(location)
959
return bzrdir._get_tree_branch()
962
def open_containing_tree_or_branch(klass, location):
963
"""Return the branch and working tree contained by a location.
965
Returns (tree, branch, relpath).
966
If there is no tree at containing the location, tree will be None.
967
If there is no branch containing the location, an exception will be
969
relpath is the portion of the path that is contained by the branch.
971
bzrdir, relpath = klass.open_containing(location)
972
tree, branch = bzrdir._get_tree_branch()
973
return tree, branch, relpath
976
def open_containing_tree_branch_or_repository(klass, location):
977
"""Return the working tree, branch and repo contained by a location.
979
Returns (tree, branch, repository, relpath).
980
If there is no tree containing the location, tree will be None.
981
If there is no branch containing the location, branch will be None.
982
If there is no repository containing the location, repository will be
984
relpath is the portion of the path that is contained by the innermost
987
If no tree, branch or repository is found, a NotBranchError is raised.
989
bzrdir, relpath = klass.open_containing(location)
991
tree, branch = bzrdir._get_tree_branch()
992
except errors.NotBranchError:
994
repo = bzrdir.find_repository()
995
return None, None, repo, relpath
996
except (errors.NoRepositoryPresent):
997
raise errors.NotBranchError(location)
998
return tree, branch, branch.repository, relpath
1000
def open_repository(self, _unsupported=False):
1001
"""Open the repository object at this BzrDir if one is present.
1003
This will not follow the Branch object pointer - it's strictly a direct
1004
open facility. Most client code should use open_branch().repository to
1005
get at a repository.
1007
:param _unsupported: a private parameter, not part of the api.
1008
TODO: static convenience version of this?
1010
raise NotImplementedError(self.open_repository)
1012
def open_workingtree(self, _unsupported=False,
1013
recommend_upgrade=True, from_branch=None):
1014
"""Open the workingtree object at this BzrDir if one is present.
1016
:param recommend_upgrade: Optional keyword parameter, when True (the
1017
default), emit through the ui module a recommendation that the user
1018
upgrade the working tree when the workingtree being opened is old
1019
(but still fully supported).
1020
:param from_branch: override bzrdir branch (for lightweight checkouts)
1022
raise NotImplementedError(self.open_workingtree)
1024
def has_branch(self):
1025
"""Tell if this bzrdir contains a branch.
1027
Note: if you're going to open the branch, you should just go ahead
1028
and try, and not ask permission first. (This method just opens the
1029
branch and discards it, and that's somewhat expensive.)
1034
except errors.NotBranchError:
1037
def has_workingtree(self):
1038
"""Tell if this bzrdir contains a working tree.
1040
This will still raise an exception if the bzrdir has a workingtree that
1041
is remote & inaccessible.
1043
Note: if you're going to open the working tree, you should just go ahead
1044
and try, and not ask permission first. (This method just opens the
1045
workingtree and discards it, and that's somewhat expensive.)
1048
self.open_workingtree(recommend_upgrade=False)
1050
except errors.NoWorkingTree:
1053
667
def _cloning_metadir(self):
1054
668
"""Produce a metadir suitable for cloning with.
1113
727
format.require_stacking()
1116
def checkout_metadir(self):
1117
return self.cloning_metadir()
1119
def sprout(self, url, revision_id=None, force_new_repo=False,
1120
recurse='down', possible_transports=None,
1121
accelerator_tree=None, hardlink=False, stacked=False,
1122
source_branch=None, create_tree_if_local=True):
1123
"""Create a copy of this bzrdir prepared for use as a new line of
1126
If url's last component does not exist, it will be created.
1128
Attributes related to the identity of the source branch like
1129
branch nickname will be cleaned, a working tree is created
1130
whether one existed before or not; and a local branch is always
1133
if revision_id is not None, then the clone operation may tune
1134
itself to download less data.
1135
:param accelerator_tree: A tree which can be used for retrieving file
1136
contents more quickly than the revision tree, i.e. a workingtree.
1137
The revision tree will be used for cases where accelerator_tree's
1138
content is different.
1139
:param hardlink: If true, hard-link files from accelerator_tree,
1141
:param stacked: If true, create a stacked branch referring to the
1142
location of this control directory.
1143
:param create_tree_if_local: If true, a working-tree will be created
1144
when working locally.
1146
target_transport = get_transport(url, possible_transports)
1147
target_transport.ensure_base()
1148
cloning_format = self.cloning_metadir(stacked)
1149
# Create/update the result branch
1150
result = cloning_format.initialize_on_transport(target_transport)
1151
# if a stacked branch wasn't requested, we don't create one
1152
# even if the origin was stacked
1153
stacked_branch_url = None
1154
if source_branch is not None:
1156
stacked_branch_url = self.root_transport.base
1157
source_repository = source_branch.repository
1160
source_branch = self.open_branch()
1161
source_repository = source_branch.repository
1163
stacked_branch_url = self.root_transport.base
1164
except errors.NotBranchError:
1165
source_branch = None
1167
source_repository = self.open_repository()
1168
except errors.NoRepositoryPresent:
1169
source_repository = None
1170
repository_policy = result.determine_repository_policy(
1171
force_new_repo, stacked_branch_url, require_stacking=stacked)
1172
result_repo, is_new_repo = repository_policy.acquire_repository()
1173
if is_new_repo and revision_id is not None and not stacked:
1174
fetch_spec = graph.PendingAncestryResult(
1175
[revision_id], source_repository)
1178
if source_repository is not None:
1179
# Fetch while stacked to prevent unstacked fetch from
1181
if fetch_spec is None:
1182
result_repo.fetch(source_repository, revision_id=revision_id)
1184
result_repo.fetch(source_repository, fetch_spec=fetch_spec)
1186
if source_branch is None:
1187
# this is for sprouting a bzrdir without a branch; is that
1189
# Not especially, but it's part of the contract.
1190
result_branch = result.create_branch()
1192
result_branch = source_branch.sprout(result,
1193
revision_id=revision_id, repository_policy=repository_policy)
1194
mutter("created new branch %r" % (result_branch,))
1196
# Create/update the result working tree
1197
if (create_tree_if_local and
1198
isinstance(target_transport, local.LocalTransport) and
1199
(result_repo is None or result_repo.make_working_trees())):
1200
wt = result.create_workingtree(accelerator_tree=accelerator_tree,
1204
if wt.path2id('') is None:
1206
wt.set_root_id(self.open_workingtree.get_root_id())
1207
except errors.NoWorkingTree:
1213
if recurse == 'down':
1215
basis = wt.basis_tree()
1217
subtrees = basis.iter_references()
1218
elif result_branch is not None:
1219
basis = result_branch.basis_tree()
1221
subtrees = basis.iter_references()
1222
elif source_branch is not None:
1223
basis = source_branch.basis_tree()
1225
subtrees = basis.iter_references()
1230
for path, file_id in subtrees:
1231
target = urlutils.join(url, urlutils.escape(path))
1232
sublocation = source_branch.reference_parent(file_id, path)
1233
sublocation.bzrdir.sprout(target,
1234
basis.get_reference_revision(file_id, path),
1235
force_new_repo=force_new_repo, recurse=recurse,
1238
if basis is not None:
1242
def push_branch(self, source, revision_id=None, overwrite=False,
1243
remember=False, create_prefix=False):
1244
"""Push the source branch into this BzrDir."""
1246
# If we can open a branch, use its direct repository, otherwise see
1247
# if there is a repository without a branch.
1249
br_to = self.open_branch()
1250
except errors.NotBranchError:
1251
# Didn't find a branch, can we find a repository?
1252
repository_to = self.find_repository()
1254
# Found a branch, so we must have found a repository
1255
repository_to = br_to.repository
1257
push_result = PushResult()
1258
push_result.source_branch = source
1260
# We have a repository but no branch, copy the revisions, and then
1262
repository_to.fetch(source.repository, revision_id=revision_id)
1263
br_to = source.clone(self, revision_id=revision_id)
1264
if source.get_push_location() is None or remember:
1265
source.set_push_location(br_to.base)
1266
push_result.stacked_on = None
1267
push_result.branch_push_result = None
1268
push_result.old_revno = None
1269
push_result.old_revid = _mod_revision.NULL_REVISION
1270
push_result.target_branch = br_to
1271
push_result.master_branch = None
1272
push_result.workingtree_updated = False
1274
# We have successfully opened the branch, remember if necessary:
1275
if source.get_push_location() is None or remember:
1276
source.set_push_location(br_to.base)
1278
tree_to = self.open_workingtree()
1279
except errors.NotLocalUrl:
1280
push_result.branch_push_result = source.push(br_to,
1281
overwrite, stop_revision=revision_id)
1282
push_result.workingtree_updated = False
1283
except errors.NoWorkingTree:
1284
push_result.branch_push_result = source.push(br_to,
1285
overwrite, stop_revision=revision_id)
1286
push_result.workingtree_updated = None # Not applicable
1288
tree_to.lock_write()
1290
push_result.branch_push_result = source.push(
1291
tree_to.branch, overwrite, stop_revision=revision_id)
1295
push_result.workingtree_updated = True
1296
push_result.old_revno = push_result.branch_push_result.old_revno
1297
push_result.old_revid = push_result.branch_push_result.old_revid
1298
push_result.target_branch = \
1299
push_result.branch_push_result.target_branch
1303
class BzrDirHooks(hooks.Hooks):
1304
"""Hooks for BzrDir operations."""
1307
"""Create the default hooks."""
1308
hooks.Hooks.__init__(self)
1309
self.create_hook(hooks.HookPoint('pre_open',
1310
"Invoked before attempting to open a BzrDir with the transport "
1311
"that the open will use.", (1, 14), None))
1313
# install the default hooks
1314
BzrDir.hooks = BzrDirHooks()
1317
class BzrDirPreSplitOut(BzrDir):
1318
"""A common class for the all-in-one formats."""
1320
def __init__(self, _transport, _format):
1321
"""See BzrDir.__init__."""
1322
super(BzrDirPreSplitOut, self).__init__(_transport, _format)
1323
self._control_files = lockable_files.LockableFiles(
1324
self.get_branch_transport(None),
1325
self._format._lock_file_name,
1326
self._format._lock_class)
1328
def break_lock(self):
1329
"""Pre-splitout bzrdirs do not suffer from stale locks."""
1330
raise NotImplementedError(self.break_lock)
1332
def cloning_metadir(self, require_stacking=False):
1333
"""Produce a metadir suitable for cloning with."""
1334
if require_stacking:
1335
return format_registry.make_bzrdir('1.6')
1336
return self._format.__class__()
1338
def clone(self, url, revision_id=None, force_new_repo=False,
1339
preserve_stacking=False):
1340
"""See BzrDir.clone().
1342
force_new_repo has no effect, since this family of formats always
1343
require a new repository.
1344
preserve_stacking has no effect, since no source branch using this
1345
family of formats can be stacked, so there is no stacking to preserve.
1347
self._make_tail(url)
1348
result = self._format._initialize_for_clone(url)
1349
self.open_repository().clone(result, revision_id=revision_id)
1350
from_branch = self.open_branch()
1351
from_branch.clone(result, revision_id=revision_id)
1353
tree = self.open_workingtree()
1354
except errors.NotLocalUrl:
1355
# make a new one, this format always has to have one.
1356
result._init_workingtree()
1361
def create_branch(self):
1362
"""See BzrDir.create_branch."""
1363
return self._format.get_branch_format().initialize(self)
1365
def destroy_branch(self):
1366
"""See BzrDir.destroy_branch."""
1367
raise errors.UnsupportedOperation(self.destroy_branch, self)
1369
def create_repository(self, shared=False):
1370
"""See BzrDir.create_repository."""
1372
raise errors.IncompatibleFormat('shared repository', self._format)
1373
return self.open_repository()
1375
def destroy_repository(self):
1376
"""See BzrDir.destroy_repository."""
1377
raise errors.UnsupportedOperation(self.destroy_repository, self)
1379
def create_workingtree(self, revision_id=None, from_branch=None,
1380
accelerator_tree=None, hardlink=False):
1381
"""See BzrDir.create_workingtree."""
1382
# The workingtree is sometimes created when the bzrdir is created,
1383
# but not when cloning.
1385
# this looks buggy but is not -really-
1386
# because this format creates the workingtree when the bzrdir is
1388
# clone and sprout will have set the revision_id
1389
# and that will have set it for us, its only
1390
# specific uses of create_workingtree in isolation
1391
# that can do wonky stuff here, and that only
1392
# happens for creating checkouts, which cannot be
1393
# done on this format anyway. So - acceptable wart.
1395
warning("can't support hardlinked working trees in %r"
1398
result = self.open_workingtree(recommend_upgrade=False)
1399
except errors.NoSuchFile:
1400
result = self._init_workingtree()
1401
if revision_id is not None:
1402
if revision_id == _mod_revision.NULL_REVISION:
1403
result.set_parent_ids([])
1405
result.set_parent_ids([revision_id])
1408
def _init_workingtree(self):
1409
from bzrlib.workingtree import WorkingTreeFormat2
1411
return WorkingTreeFormat2().initialize(self)
1412
except errors.NotLocalUrl:
1413
# Even though we can't access the working tree, we need to
1414
# create its control files.
1415
return WorkingTreeFormat2()._stub_initialize_on_transport(
1416
self.transport, self._control_files._file_mode)
1418
def destroy_workingtree(self):
1419
"""See BzrDir.destroy_workingtree."""
1420
raise errors.UnsupportedOperation(self.destroy_workingtree, self)
1422
def destroy_workingtree_metadata(self):
1423
"""See BzrDir.destroy_workingtree_metadata."""
1424
raise errors.UnsupportedOperation(self.destroy_workingtree_metadata,
1427
def get_branch_transport(self, branch_format):
1428
"""See BzrDir.get_branch_transport()."""
1429
if branch_format is None:
1430
return self.transport
1432
branch_format.get_format_string()
1433
except NotImplementedError:
1434
return self.transport
1435
raise errors.IncompatibleFormat(branch_format, self._format)
730
def get_branch_transport(self, branch_format, name=None):
731
"""Get the transport for use by branch format in this BzrDir.
733
Note that bzr dirs that do not support format strings will raise
734
IncompatibleFormat if the branch format they are given has
735
a format string, and vice versa.
737
If branch_format is None, the transport is returned with no
738
checking. If it is not None, then the returned transport is
739
guaranteed to point to an existing directory ready for use.
741
raise NotImplementedError(self.get_branch_transport)
1437
743
def get_repository_transport(self, repository_format):
1438
"""See BzrDir.get_repository_transport()."""
1439
if repository_format is None:
1440
return self.transport
1442
repository_format.get_format_string()
1443
except NotImplementedError:
1444
return self.transport
1445
raise errors.IncompatibleFormat(repository_format, self._format)
1447
def get_workingtree_transport(self, workingtree_format):
1448
"""See BzrDir.get_workingtree_transport()."""
1449
if workingtree_format is None:
1450
return self.transport
1452
workingtree_format.get_format_string()
1453
except NotImplementedError:
1454
return self.transport
1455
raise errors.IncompatibleFormat(workingtree_format, self._format)
1457
def needs_format_conversion(self, format=None):
1458
"""See BzrDir.needs_format_conversion()."""
1459
# if the format is not the same as the system default,
1460
# an upgrade is needed.
1462
symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
1463
% 'needs_format_conversion(format=None)')
1464
format = BzrDirFormat.get_default_format()
1465
return not isinstance(self._format, format.__class__)
1467
def open_branch(self, unsupported=False, ignore_fallbacks=False):
1468
"""See BzrDir.open_branch."""
1469
from bzrlib.branch import BzrBranchFormat4
1470
format = BzrBranchFormat4()
1471
self._check_supported(format, unsupported)
1472
return format.open(self, _found=True)
1474
def sprout(self, url, revision_id=None, force_new_repo=False,
1475
possible_transports=None, accelerator_tree=None,
1476
hardlink=False, stacked=False, create_tree_if_local=True,
1477
source_branch=None):
1478
"""See BzrDir.sprout()."""
1479
if source_branch is not None:
1480
my_branch = self.open_branch()
1481
if source_branch.base != my_branch.base:
1482
raise AssertionError(
1483
"source branch %r is not within %r with branch %r" %
1484
(source_branch, self, my_branch))
1486
raise errors.UnstackableBranchFormat(
1487
self._format, self.root_transport.base)
1488
if not create_tree_if_local:
1489
raise errors.MustHaveWorkingTree(
1490
self._format, self.root_transport.base)
1491
from bzrlib.workingtree import WorkingTreeFormat2
1492
self._make_tail(url)
1493
result = self._format._initialize_for_clone(url)
1495
self.open_repository().clone(result, revision_id=revision_id)
1496
except errors.NoRepositoryPresent:
1499
self.open_branch().sprout(result, revision_id=revision_id)
1500
except errors.NotBranchError:
1503
# we always want a working tree
1504
WorkingTreeFormat2().initialize(result,
1505
accelerator_tree=accelerator_tree,
1510
class BzrDir4(BzrDirPreSplitOut):
1511
"""A .bzr version 4 control object.
1513
This is a deprecated format and may be removed after sept 2006.
1516
def create_repository(self, shared=False):
1517
"""See BzrDir.create_repository."""
1518
return self._format.repository_format.initialize(self, shared)
1520
def needs_format_conversion(self, format=None):
1521
"""Format 4 dirs are always in need of conversion."""
1523
symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
1524
% 'needs_format_conversion(format=None)')
1527
def open_repository(self):
1528
"""See BzrDir.open_repository."""
1529
from bzrlib.repofmt.weaverepo import RepositoryFormat4
1530
return RepositoryFormat4().open(self, _found=True)
1533
class BzrDir5(BzrDirPreSplitOut):
1534
"""A .bzr version 5 control object.
1536
This is a deprecated format and may be removed after sept 2006.
1539
def has_workingtree(self):
1540
"""See BzrDir.has_workingtree."""
1543
def open_repository(self):
1544
"""See BzrDir.open_repository."""
1545
from bzrlib.repofmt.weaverepo import RepositoryFormat5
1546
return RepositoryFormat5().open(self, _found=True)
1548
def open_workingtree(self, _unsupported=False,
1549
recommend_upgrade=True):
1550
"""See BzrDir.create_workingtree."""
1551
from bzrlib.workingtree import WorkingTreeFormat2
1552
wt_format = WorkingTreeFormat2()
1553
# we don't warn here about upgrades; that ought to be handled for the
1555
return wt_format.open(self, _found=True)
1558
class BzrDir6(BzrDirPreSplitOut):
1559
"""A .bzr version 6 control object.
1561
This is a deprecated format and may be removed after sept 2006.
1564
def has_workingtree(self):
1565
"""See BzrDir.has_workingtree."""
1568
def open_repository(self):
1569
"""See BzrDir.open_repository."""
1570
from bzrlib.repofmt.weaverepo import RepositoryFormat6
1571
return RepositoryFormat6().open(self, _found=True)
1573
def open_workingtree(self, _unsupported=False,
1574
recommend_upgrade=True):
1575
"""See BzrDir.create_workingtree."""
1576
# we don't warn here about upgrades; that ought to be handled for the
1578
from bzrlib.workingtree import WorkingTreeFormat2
1579
return WorkingTreeFormat2().open(self, _found=True)
744
"""Get the transport for use by repository format in this BzrDir.
746
Note that bzr dirs that do not support format strings will raise
747
IncompatibleFormat if the repository format they are given has
748
a format string, and vice versa.
750
If repository_format is None, the transport is returned with no
751
checking. If it is not None, then the returned transport is
752
guaranteed to point to an existing directory ready for use.
754
raise NotImplementedError(self.get_repository_transport)
756
def get_workingtree_transport(self, tree_format):
757
"""Get the transport for use by workingtree format in this BzrDir.
759
Note that bzr dirs that do not support format strings will raise
760
IncompatibleFormat if the workingtree format they are given has a
761
format string, and vice versa.
763
If workingtree_format is None, the transport is returned with no
764
checking. If it is not None, then the returned transport is
765
guaranteed to point to an existing directory ready for use.
767
raise NotImplementedError(self.get_workingtree_transport)
770
def create(cls, base, format=None, possible_transports=None):
771
"""Create a new BzrDir at the url 'base'.
773
:param format: If supplied, the format of branch to create. If not
774
supplied, the default is used.
775
:param possible_transports: If supplied, a list of transports that
776
can be reused to share a remote connection.
778
if cls is not BzrDir:
779
raise AssertionError("BzrDir.create always creates the "
780
"default format, not one of %r" % cls)
781
return controldir.ControlDir.create(base, format=format,
782
possible_transports=possible_transports)
785
return "<%s at %r>" % (self.__class__.__name__, self.user_url)
787
def update_feature_flags(self, updated_flags):
788
"""Update the features required by this bzrdir.
790
:param updated_flags: Dictionary mapping feature names to necessities
791
A necessity can be None to indicate the feature should be removed
793
self.control_files.lock_write()
795
self._format._update_feature_flags(updated_flags)
796
self.transport.put_bytes('branch-format', self._format.as_string())
798
self.control_files.unlock()
1582
801
class BzrDirMeta1(BzrDir):
1768
1098
return config.TransportConfig(self.transport, 'control.conf')
1771
class BzrDirFormat(object):
1772
"""An encapsulation of the initialization and open routines for a format.
1774
Formats provide three things:
1775
* An initialization routine,
1101
class BzrFormat(object):
1102
"""Base class for all formats of things living in metadirs.
1104
This class manages the format string that is stored in the 'format'
1105
or 'branch-format' file.
1107
All classes for (branch-, repository-, workingtree-) formats that
1108
live in meta directories and have their own 'format' file
1109
(i.e. different from .bzr/branch-format) derive from this class,
1110
as well as the relevant base class for their kind
1111
(BranchFormat, WorkingTreeFormat, RepositoryFormat).
1113
Each format is identified by a "format" or "branch-format" file with a
1114
single line containing the base format name and then an optional list of
1117
Feature flags are supported as of bzr 2.5. Setting feature flags on formats
1118
will render them inaccessible to older versions of bzr.
1120
:ivar features: Dictionary mapping feature names to their necessity
1123
_present_features = set()
1129
def register_feature(cls, name):
1130
"""Register a feature as being present.
1132
:param name: Name of the feature
1135
raise ValueError("spaces are not allowed in feature names")
1136
if name in cls._present_features:
1137
raise errors.FeatureAlreadyRegistered(name)
1138
cls._present_features.add(name)
1141
def unregister_feature(cls, name):
1142
"""Unregister a feature."""
1143
cls._present_features.remove(name)
1145
def check_support_status(self, allow_unsupported, recommend_upgrade=True,
1147
for name, necessity in self.features.iteritems():
1148
if name in self._present_features:
1150
if necessity == "optional":
1151
mutter("ignoring optional missing feature %s", name)
1153
elif necessity == "required":
1154
raise errors.MissingFeature(name)
1156
mutter("treating unknown necessity as require for %s",
1158
raise errors.MissingFeature(name)
1161
def get_format_string(cls):
1162
"""Return the ASCII format string that identifies this format."""
1163
raise NotImplementedError(cls.get_format_string)
1166
def from_string(cls, text):
1167
format_string = cls.get_format_string()
1168
if not text.startswith(format_string):
1169
raise AssertionError("Invalid format header %r for %r" % (text, cls))
1170
lines = text[len(format_string):].splitlines()
1172
for lineno, line in enumerate(lines):
1174
(necessity, feature) = line.split(" ", 1)
1176
raise errors.ParseFormatError(format=cls, lineno=lineno+2,
1177
line=line, text=text)
1178
ret.features[feature] = necessity
1181
def as_string(self):
1182
"""Return the string representation of this format.
1184
lines = [self.get_format_string()]
1185
lines.extend([("%s %s\n" % (item[1], item[0])) for item in
1186
self.features.iteritems()])
1187
return "".join(lines)
1190
def _find_format(klass, registry, kind, format_string):
1192
first_line = format_string[:format_string.index("\n")+1]
1194
first_line = format_string
1196
cls = registry.get(first_line)
1198
raise errors.UnknownFormatError(format=first_line, kind=kind)
1199
return cls.from_string(format_string)
1201
def network_name(self):
1202
"""A simple byte string uniquely identifying this format for RPC calls.
1204
Metadir branch formats use their format string.
1206
return self.as_string()
1208
def __eq__(self, other):
1209
return (self.__class__ is other.__class__ and
1210
self.features == other.features)
1212
def _update_feature_flags(self, updated_flags):
1213
"""Update the feature flags in this format.
1215
:param updated_flags: Updated feature flags
1217
for name, necessity in updated_flags.iteritems():
1218
if necessity is None:
1220
del self.features[name]
1224
self.features[name] = necessity
1227
class BzrProber(controldir.Prober):
1228
"""Prober for formats that use a .bzr/ control directory."""
1230
formats = registry.FormatRegistry(controldir.network_format_registry)
1231
"""The known .bzr formats."""
1234
def probe_transport(klass, transport):
1235
"""Return the .bzrdir style format present in a directory."""
1237
format_string = transport.get_bytes(".bzr/branch-format")
1238
except errors.NoSuchFile:
1239
raise errors.NotBranchError(path=transport.base)
1241
first_line = format_string[:format_string.index("\n")+1]
1243
first_line = format_string
1245
cls = klass.formats.get(first_line)
1247
raise errors.UnknownFormatError(format=first_line, kind='bzrdir')
1248
return cls.from_string(format_string)
1251
def known_formats(cls):
1253
for name, format in cls.formats.iteritems():
1254
if callable(format):
1260
controldir.ControlDirFormat.register_prober(BzrProber)
1263
class RemoteBzrProber(controldir.Prober):
1264
"""Prober for remote servers that provide a Bazaar smart server."""
1267
def probe_transport(klass, transport):
1268
"""Return a RemoteBzrDirFormat object if it looks possible."""
1270
medium = transport.get_smart_medium()
1271
except (NotImplementedError, AttributeError,
1272
errors.TransportNotPossible, errors.NoSmartMedium,
1273
errors.SmartProtocolError):
1274
# no smart server, so not a branch for this format type.
1275
raise errors.NotBranchError(path=transport.base)
1277
# Decline to open it if the server doesn't support our required
1278
# version (3) so that the VFS-based transport will do it.
1279
if medium.should_probe():
1281
server_version = medium.protocol_version()
1282
except errors.SmartProtocolError:
1283
# Apparently there's no usable smart server there, even though
1284
# the medium supports the smart protocol.
1285
raise errors.NotBranchError(path=transport.base)
1286
if server_version != '2':
1287
raise errors.NotBranchError(path=transport.base)
1288
from bzrlib.remote import RemoteBzrDirFormat
1289
return RemoteBzrDirFormat()
1292
def known_formats(cls):
1293
from bzrlib.remote import RemoteBzrDirFormat
1294
return set([RemoteBzrDirFormat()])
1297
class BzrDirFormat(BzrFormat, controldir.ControlDirFormat):
1298
"""ControlDirFormat base class for .bzr/ directories.
1779
1300
Formats are placed in a dict by their format string for reference
1780
1301
during bzrdir opening. These should be subclasses of BzrDirFormat
2143
1504
compatible with whatever sub formats are supported by self.
2148
def unregister_format(klass, format):
2149
del klass._formats[format.get_format_string()]
2152
def unregister_control_format(klass, format):
2153
klass._control_formats.remove(format)
2156
class BzrDirFormat4(BzrDirFormat):
2157
"""Bzr dir format 4.
2159
This format is a combined format for working tree, branch and repository.
2161
- Format 1 working trees [always]
2162
- Format 4 branches [always]
2163
- Format 4 repositories [always]
2165
This format is deprecated: it indexes texts using a text it which is
2166
removed in format 5; write support for this format has been removed.
2169
_lock_class = lockable_files.TransportLock
2171
def get_format_string(self):
2172
"""See BzrDirFormat.get_format_string()."""
2173
return "Bazaar-NG branch, format 0.0.4\n"
2175
def get_format_description(self):
2176
"""See BzrDirFormat.get_format_description()."""
2177
return "All-in-one format 4"
2179
def get_converter(self, format=None):
2180
"""See BzrDirFormat.get_converter()."""
2181
# there is one and only one upgrade path here.
2182
return ConvertBzrDir4To5()
2184
def initialize_on_transport(self, transport):
2185
"""Format 4 branches cannot be created."""
2186
raise errors.UninitializableFormat(self)
2188
def is_supported(self):
2189
"""Format 4 is not supported.
2191
It is not supported because the model changed from 4 to 5 and the
2192
conversion logic is expensive - so doing it on the fly was not
2197
def network_name(self):
2198
return self.get_format_string()
2200
def _open(self, transport):
2201
"""See BzrDirFormat._open."""
2202
return BzrDir4(transport, self)
2204
def __return_repository_format(self):
2205
"""Circular import protection."""
2206
from bzrlib.repofmt.weaverepo import RepositoryFormat4
2207
return RepositoryFormat4()
2208
repository_format = property(__return_repository_format)
2211
class BzrDirFormatAllInOne(BzrDirFormat):
2212
"""Common class for formats before meta-dirs."""
2214
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
2215
create_prefix=False, force_new_repo=False, stacked_on=None,
2216
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
2218
"""See BzrDirFormat.initialize_on_transport_ex."""
2219
require_stacking = (stacked_on is not None)
2220
# Format 5 cannot stack, but we've been asked to - actually init
2222
if require_stacking:
2223
format = BzrDirMetaFormat1()
2224
return format.initialize_on_transport_ex(transport,
2225
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
2226
force_new_repo=force_new_repo, stacked_on=stacked_on,
2227
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
2228
make_working_trees=make_working_trees, shared_repo=shared_repo)
2229
return BzrDirFormat.initialize_on_transport_ex(self, transport,
2230
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
2231
force_new_repo=force_new_repo, stacked_on=stacked_on,
2232
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
2233
make_working_trees=make_working_trees, shared_repo=shared_repo)
2236
class BzrDirFormat5(BzrDirFormatAllInOne):
2237
"""Bzr control format 5.
2239
This format is a combined format for working tree, branch and repository.
2241
- Format 2 working trees [always]
2242
- Format 4 branches [always]
2243
- Format 5 repositories [always]
2244
Unhashed stores in the repository.
2247
_lock_class = lockable_files.TransportLock
2249
def get_format_string(self):
2250
"""See BzrDirFormat.get_format_string()."""
2251
return "Bazaar-NG branch, format 5\n"
2253
def get_branch_format(self):
2254
from bzrlib import branch
2255
return branch.BzrBranchFormat4()
2257
def get_format_description(self):
2258
"""See BzrDirFormat.get_format_description()."""
2259
return "All-in-one format 5"
2261
def get_converter(self, format=None):
2262
"""See BzrDirFormat.get_converter()."""
2263
# there is one and only one upgrade path here.
2264
return ConvertBzrDir5To6()
2266
def _initialize_for_clone(self, url):
2267
return self.initialize_on_transport(get_transport(url), _cloning=True)
2269
def initialize_on_transport(self, transport, _cloning=False):
2270
"""Format 5 dirs always have working tree, branch and repository.
2272
Except when they are being cloned.
2274
from bzrlib.branch import BzrBranchFormat4
2275
from bzrlib.repofmt.weaverepo import RepositoryFormat5
2276
result = (super(BzrDirFormat5, self).initialize_on_transport(transport))
2277
RepositoryFormat5().initialize(result, _internal=True)
2279
branch = BzrBranchFormat4().initialize(result)
2280
result._init_workingtree()
2283
def network_name(self):
2284
return self.get_format_string()
2286
def _open(self, transport):
2287
"""See BzrDirFormat._open."""
2288
return BzrDir5(transport, self)
2290
def __return_repository_format(self):
2291
"""Circular import protection."""
2292
from bzrlib.repofmt.weaverepo import RepositoryFormat5
2293
return RepositoryFormat5()
2294
repository_format = property(__return_repository_format)
2297
class BzrDirFormat6(BzrDirFormatAllInOne):
2298
"""Bzr control format 6.
2300
This format is a combined format for working tree, branch and repository.
2302
- Format 2 working trees [always]
2303
- Format 4 branches [always]
2304
- Format 6 repositories [always]
2307
_lock_class = lockable_files.TransportLock
2309
def get_format_string(self):
2310
"""See BzrDirFormat.get_format_string()."""
2311
return "Bazaar-NG branch, format 6\n"
2313
def get_format_description(self):
2314
"""See BzrDirFormat.get_format_description()."""
2315
return "All-in-one format 6"
2317
def get_branch_format(self):
2318
from bzrlib import branch
2319
return branch.BzrBranchFormat4()
2321
def get_converter(self, format=None):
2322
"""See BzrDirFormat.get_converter()."""
2323
# there is one and only one upgrade path here.
2324
return ConvertBzrDir6ToMeta()
2326
def _initialize_for_clone(self, url):
2327
return self.initialize_on_transport(get_transport(url), _cloning=True)
2329
def initialize_on_transport(self, transport, _cloning=False):
2330
"""Format 6 dirs always have working tree, branch and repository.
2332
Except when they are being cloned.
2334
from bzrlib.branch import BzrBranchFormat4
2335
from bzrlib.repofmt.weaverepo import RepositoryFormat6
2336
result = super(BzrDirFormat6, self).initialize_on_transport(transport)
2337
RepositoryFormat6().initialize(result, _internal=True)
2339
branch = BzrBranchFormat4().initialize(result)
2340
result._init_workingtree()
2343
def network_name(self):
2344
return self.get_format_string()
2346
def _open(self, transport):
2347
"""See BzrDirFormat._open."""
2348
return BzrDir6(transport, self)
2350
def __return_repository_format(self):
2351
"""Circular import protection."""
2352
from bzrlib.repofmt.weaverepo import RepositoryFormat6
2353
return RepositoryFormat6()
2354
repository_format = property(__return_repository_format)
1507
other_format.features = dict(self.features)
1509
def supports_transport(self, transport):
1510
# bzr formats can be opened over all known transports
1513
def check_support_status(self, allow_unsupported, recommend_upgrade=True,
1515
controldir.ControlDirFormat.check_support_status(self,
1516
allow_unsupported=allow_unsupported, recommend_upgrade=recommend_upgrade,
1518
BzrFormat.check_support_status(self, allow_unsupported=allow_unsupported,
1519
recommend_upgrade=recommend_upgrade, basedir=basedir)
2357
1522
class BzrDirMetaFormat1(BzrDirFormat):
2549
1729
def __get_workingtree_format(self):
2550
1730
if self._workingtree_format is None:
2551
from bzrlib.workingtree import WorkingTreeFormat
2552
self._workingtree_format = WorkingTreeFormat.get_default_format()
1731
from bzrlib.workingtree import (
1732
format_registry as wt_format_registry,
1734
self._workingtree_format = wt_format_registry.get_default()
2553
1735
return self._workingtree_format
2555
1737
def __set_workingtree_format(self, wt_format):
2556
1738
self._workingtree_format = wt_format
1741
return "<%r>" % (self.__class__.__name__,)
2558
1743
workingtree_format = property(__get_workingtree_format,
2559
1744
__set_workingtree_format)
2562
network_format_registry = registry.FormatRegistry()
2563
"""Registry of formats indexed by their network name.
2565
The network name for a BzrDirFormat is an identifier that can be used when
2566
referring to formats with smart server operations. See
2567
BzrDirFormat.network_name() for more detail.
2571
# Register bzr control format
2572
BzrDirFormat.register_control_format(BzrDirFormat)
2574
1747
# Register bzr formats
2575
BzrDirFormat.register_format(BzrDirFormat4())
2576
BzrDirFormat.register_format(BzrDirFormat5())
2577
BzrDirFormat.register_format(BzrDirFormat6())
2578
__default_format = BzrDirMetaFormat1()
2579
BzrDirFormat.register_format(__default_format)
2580
BzrDirFormat._default_format = __default_format
2583
class Converter(object):
2584
"""Converts a disk format object from one format to another."""
2586
def convert(self, to_convert, pb):
2587
"""Perform the conversion of to_convert, giving feedback via pb.
2589
:param to_convert: The disk object to convert.
2590
:param pb: a progress bar to use for progress information.
2593
def step(self, message):
2594
"""Update the pb by a step."""
2596
self.pb.update(message, self.count, self.total)
2599
class ConvertBzrDir4To5(Converter):
2600
"""Converts format 4 bzr dirs to format 5."""
2603
super(ConvertBzrDir4To5, self).__init__()
2604
self.converted_revs = set()
2605
self.absent_revisions = set()
2609
def convert(self, to_convert, pb):
2610
"""See Converter.convert()."""
2611
self.bzrdir = to_convert
2613
ui.ui_factory.note('starting upgrade from format 4 to 5')
2614
if isinstance(self.bzrdir.transport, local.LocalTransport):
2615
self.bzrdir.get_workingtree_transport(None).delete('stat-cache')
2616
self._convert_to_weaves()
2617
return BzrDir.open(self.bzrdir.root_transport.base)
2619
def _convert_to_weaves(self):
2620
ui.ui_factory.note('note: upgrade may be faster if all store files are ungzipped first')
2623
stat = self.bzrdir.transport.stat('weaves')
2624
if not S_ISDIR(stat.st_mode):
2625
self.bzrdir.transport.delete('weaves')
2626
self.bzrdir.transport.mkdir('weaves')
2627
except errors.NoSuchFile:
2628
self.bzrdir.transport.mkdir('weaves')
2629
# deliberately not a WeaveFile as we want to build it up slowly.
2630
self.inv_weave = Weave('inventory')
2631
# holds in-memory weaves for all files
2632
self.text_weaves = {}
2633
self.bzrdir.transport.delete('branch-format')
2634
self.branch = self.bzrdir.open_branch()
2635
self._convert_working_inv()
2636
rev_history = self.branch.revision_history()
2637
# to_read is a stack holding the revisions we still need to process;
2638
# appending to it adds new highest-priority revisions
2639
self.known_revisions = set(rev_history)
2640
self.to_read = rev_history[-1:]
2642
rev_id = self.to_read.pop()
2643
if (rev_id not in self.revisions
2644
and rev_id not in self.absent_revisions):
2645
self._load_one_rev(rev_id)
2647
to_import = self._make_order()
2648
for i, rev_id in enumerate(to_import):
2649
self.pb.update('converting revision', i, len(to_import))
2650
self._convert_one_rev(rev_id)
2652
self._write_all_weaves()
2653
self._write_all_revs()
2654
ui.ui_factory.note('upgraded to weaves:')
2655
ui.ui_factory.note(' %6d revisions and inventories' % len(self.revisions))
2656
ui.ui_factory.note(' %6d revisions not present' % len(self.absent_revisions))
2657
ui.ui_factory.note(' %6d texts' % self.text_count)
2658
self._cleanup_spare_files_after_format4()
2659
self.branch._transport.put_bytes(
2661
BzrDirFormat5().get_format_string(),
2662
mode=self.bzrdir._get_file_mode())
2664
def _cleanup_spare_files_after_format4(self):
2665
# FIXME working tree upgrade foo.
2666
for n in 'merged-patches', 'pending-merged-patches':
2668
## assert os.path.getsize(p) == 0
2669
self.bzrdir.transport.delete(n)
2670
except errors.NoSuchFile:
2672
self.bzrdir.transport.delete_tree('inventory-store')
2673
self.bzrdir.transport.delete_tree('text-store')
2675
def _convert_working_inv(self):
2676
inv = xml4.serializer_v4.read_inventory(
2677
self.branch._transport.get('inventory'))
2678
new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv, working=True)
2679
self.branch._transport.put_bytes('inventory', new_inv_xml,
2680
mode=self.bzrdir._get_file_mode())
2682
def _write_all_weaves(self):
2683
controlweaves = WeaveStore(self.bzrdir.transport, prefixed=False)
2684
weave_transport = self.bzrdir.transport.clone('weaves')
2685
weaves = WeaveStore(weave_transport, prefixed=False)
2686
transaction = WriteTransaction()
2690
for file_id, file_weave in self.text_weaves.items():
2691
self.pb.update('writing weave', i, len(self.text_weaves))
2692
weaves._put_weave(file_id, file_weave, transaction)
2694
self.pb.update('inventory', 0, 1)
2695
controlweaves._put_weave('inventory', self.inv_weave, transaction)
2696
self.pb.update('inventory', 1, 1)
2700
def _write_all_revs(self):
2701
"""Write all revisions out in new form."""
2702
self.bzrdir.transport.delete_tree('revision-store')
2703
self.bzrdir.transport.mkdir('revision-store')
2704
revision_transport = self.bzrdir.transport.clone('revision-store')
2706
from bzrlib.xml5 import serializer_v5
2707
from bzrlib.repofmt.weaverepo import RevisionTextStore
2708
revision_store = RevisionTextStore(revision_transport,
2709
serializer_v5, False, versionedfile.PrefixMapper(),
2710
lambda:True, lambda:True)
2712
for i, rev_id in enumerate(self.converted_revs):
2713
self.pb.update('write revision', i, len(self.converted_revs))
2714
text = serializer_v5.write_revision_to_string(
2715
self.revisions[rev_id])
2717
revision_store.add_lines(key, None, osutils.split_lines(text))
2721
def _load_one_rev(self, rev_id):
2722
"""Load a revision object into memory.
2724
Any parents not either loaded or abandoned get queued to be
2726
self.pb.update('loading revision',
2727
len(self.revisions),
2728
len(self.known_revisions))
2729
if not self.branch.repository.has_revision(rev_id):
2731
ui.ui_factory.note('revision {%s} not present in branch; '
2732
'will be converted as a ghost' %
2734
self.absent_revisions.add(rev_id)
2736
rev = self.branch.repository.get_revision(rev_id)
2737
for parent_id in rev.parent_ids:
2738
self.known_revisions.add(parent_id)
2739
self.to_read.append(parent_id)
2740
self.revisions[rev_id] = rev
2742
def _load_old_inventory(self, rev_id):
2743
old_inv_xml = self.branch.repository.inventory_store.get(rev_id).read()
2744
inv = xml4.serializer_v4.read_inventory_from_string(old_inv_xml)
2745
inv.revision_id = rev_id
2746
rev = self.revisions[rev_id]
2749
def _load_updated_inventory(self, rev_id):
2750
inv_xml = self.inv_weave.get_text(rev_id)
2751
inv = xml5.serializer_v5.read_inventory_from_string(inv_xml, rev_id)
2754
def _convert_one_rev(self, rev_id):
2755
"""Convert revision and all referenced objects to new format."""
2756
rev = self.revisions[rev_id]
2757
inv = self._load_old_inventory(rev_id)
2758
present_parents = [p for p in rev.parent_ids
2759
if p not in self.absent_revisions]
2760
self._convert_revision_contents(rev, inv, present_parents)
2761
self._store_new_inv(rev, inv, present_parents)
2762
self.converted_revs.add(rev_id)
2764
def _store_new_inv(self, rev, inv, present_parents):
2765
new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv)
2766
new_inv_sha1 = sha_string(new_inv_xml)
2767
self.inv_weave.add_lines(rev.revision_id,
2769
new_inv_xml.splitlines(True))
2770
rev.inventory_sha1 = new_inv_sha1
2772
def _convert_revision_contents(self, rev, inv, present_parents):
2773
"""Convert all the files within a revision.
2775
Also upgrade the inventory to refer to the text revision ids."""
2776
rev_id = rev.revision_id
2777
mutter('converting texts of revision {%s}',
2779
parent_invs = map(self._load_updated_inventory, present_parents)
2780
entries = inv.iter_entries()
2782
for path, ie in entries:
2783
self._convert_file_version(rev, ie, parent_invs)
2785
def _convert_file_version(self, rev, ie, parent_invs):
2786
"""Convert one version of one file.
2788
The file needs to be added into the weave if it is a merge
2789
of >=2 parents or if it's changed from its parent.
2791
file_id = ie.file_id
2792
rev_id = rev.revision_id
2793
w = self.text_weaves.get(file_id)
2796
self.text_weaves[file_id] = w
2797
text_changed = False
2798
parent_candiate_entries = ie.parent_candidates(parent_invs)
2799
heads = graph.Graph(self).heads(parent_candiate_entries.keys())
2800
# XXX: Note that this is unordered - and this is tolerable because
2801
# the previous code was also unordered.
2802
previous_entries = dict((head, parent_candiate_entries[head]) for head
2804
self.snapshot_ie(previous_entries, ie, w, rev_id)
2807
def get_parent_map(self, revision_ids):
2808
"""See graph.StackedParentsProvider.get_parent_map"""
2809
return dict((revision_id, self.revisions[revision_id])
2810
for revision_id in revision_ids
2811
if revision_id in self.revisions)
2813
def snapshot_ie(self, previous_revisions, ie, w, rev_id):
2814
# TODO: convert this logic, which is ~= snapshot to
2815
# a call to:. This needs the path figured out. rather than a work_tree
2816
# a v4 revision_tree can be given, or something that looks enough like
2817
# one to give the file content to the entry if it needs it.
2818
# and we need something that looks like a weave store for snapshot to
2820
#ie.snapshot(rev, PATH, previous_revisions, REVISION_TREE, InMemoryWeaveStore(self.text_weaves))
2821
if len(previous_revisions) == 1:
2822
previous_ie = previous_revisions.values()[0]
2823
if ie._unchanged(previous_ie):
2824
ie.revision = previous_ie.revision
2827
text = self.branch.repository._text_store.get(ie.text_id)
2828
file_lines = text.readlines()
2829
w.add_lines(rev_id, previous_revisions, file_lines)
2830
self.text_count += 1
2832
w.add_lines(rev_id, previous_revisions, [])
2833
ie.revision = rev_id
2835
def _make_order(self):
2836
"""Return a suitable order for importing revisions.
2838
The order must be such that an revision is imported after all
2839
its (present) parents.
2841
todo = set(self.revisions.keys())
2842
done = self.absent_revisions.copy()
2845
# scan through looking for a revision whose parents
2847
for rev_id in sorted(list(todo)):
2848
rev = self.revisions[rev_id]
2849
parent_ids = set(rev.parent_ids)
2850
if parent_ids.issubset(done):
2851
# can take this one now
2852
order.append(rev_id)
2858
class ConvertBzrDir5To6(Converter):
2859
"""Converts format 5 bzr dirs to format 6."""
2861
def convert(self, to_convert, pb):
2862
"""See Converter.convert()."""
2863
self.bzrdir = to_convert
2865
ui.ui_factory.note('starting upgrade from format 5 to 6')
2866
self._convert_to_prefixed()
2867
return BzrDir.open(self.bzrdir.root_transport.base)
2869
def _convert_to_prefixed(self):
2870
from bzrlib.store import TransportStore
2871
self.bzrdir.transport.delete('branch-format')
2872
for store_name in ["weaves", "revision-store"]:
2873
ui.ui_factory.note("adding prefixes to %s" % store_name)
2874
store_transport = self.bzrdir.transport.clone(store_name)
2875
store = TransportStore(store_transport, prefixed=True)
2876
for urlfilename in store_transport.list_dir('.'):
2877
filename = urlutils.unescape(urlfilename)
2878
if (filename.endswith(".weave") or
2879
filename.endswith(".gz") or
2880
filename.endswith(".sig")):
2881
file_id, suffix = os.path.splitext(filename)
2885
new_name = store._mapper.map((file_id,)) + suffix
2886
# FIXME keep track of the dirs made RBC 20060121
2888
store_transport.move(filename, new_name)
2889
except errors.NoSuchFile: # catches missing dirs strangely enough
2890
store_transport.mkdir(osutils.dirname(new_name))
2891
store_transport.move(filename, new_name)
2892
self.bzrdir.transport.put_bytes(
2894
BzrDirFormat6().get_format_string(),
2895
mode=self.bzrdir._get_file_mode())
2898
class ConvertBzrDir6ToMeta(Converter):
2899
"""Converts format 6 bzr dirs to metadirs."""
2901
def convert(self, to_convert, pb):
2902
"""See Converter.convert()."""
2903
from bzrlib.repofmt.weaverepo import RepositoryFormat7
2904
from bzrlib.branch import BzrBranchFormat5
2905
self.bzrdir = to_convert
2908
self.total = 20 # the steps we know about
2909
self.garbage_inventories = []
2910
self.dir_mode = self.bzrdir._get_dir_mode()
2911
self.file_mode = self.bzrdir._get_file_mode()
2913
ui.ui_factory.note('starting upgrade from format 6 to metadir')
2914
self.bzrdir.transport.put_bytes(
2916
"Converting to format 6",
2917
mode=self.file_mode)
2918
# its faster to move specific files around than to open and use the apis...
2919
# first off, nuke ancestry.weave, it was never used.
2921
self.step('Removing ancestry.weave')
2922
self.bzrdir.transport.delete('ancestry.weave')
2923
except errors.NoSuchFile:
2925
# find out whats there
2926
self.step('Finding branch files')
2927
last_revision = self.bzrdir.open_branch().last_revision()
2928
bzrcontents = self.bzrdir.transport.list_dir('.')
2929
for name in bzrcontents:
2930
if name.startswith('basis-inventory.'):
2931
self.garbage_inventories.append(name)
2932
# create new directories for repository, working tree and branch
2933
repository_names = [('inventory.weave', True),
2934
('revision-store', True),
2936
self.step('Upgrading repository ')
2937
self.bzrdir.transport.mkdir('repository', mode=self.dir_mode)
2938
self.make_lock('repository')
2939
# we hard code the formats here because we are converting into
2940
# the meta format. The meta format upgrader can take this to a
2941
# future format within each component.
2942
self.put_format('repository', RepositoryFormat7())
2943
for entry in repository_names:
2944
self.move_entry('repository', entry)
2946
self.step('Upgrading branch ')
2947
self.bzrdir.transport.mkdir('branch', mode=self.dir_mode)
2948
self.make_lock('branch')
2949
self.put_format('branch', BzrBranchFormat5())
2950
branch_files = [('revision-history', True),
2951
('branch-name', True),
2953
for entry in branch_files:
2954
self.move_entry('branch', entry)
2956
checkout_files = [('pending-merges', True),
2957
('inventory', True),
2958
('stat-cache', False)]
2959
# If a mandatory checkout file is not present, the branch does not have
2960
# a functional checkout. Do not create a checkout in the converted
2962
for name, mandatory in checkout_files:
2963
if mandatory and name not in bzrcontents:
2964
has_checkout = False
2968
if not has_checkout:
2969
ui.ui_factory.note('No working tree.')
2970
# If some checkout files are there, we may as well get rid of them.
2971
for name, mandatory in checkout_files:
2972
if name in bzrcontents:
2973
self.bzrdir.transport.delete(name)
2975
from bzrlib.workingtree import WorkingTreeFormat3
2976
self.step('Upgrading working tree')
2977
self.bzrdir.transport.mkdir('checkout', mode=self.dir_mode)
2978
self.make_lock('checkout')
2980
'checkout', WorkingTreeFormat3())
2981
self.bzrdir.transport.delete_multi(
2982
self.garbage_inventories, self.pb)
2983
for entry in checkout_files:
2984
self.move_entry('checkout', entry)
2985
if last_revision is not None:
2986
self.bzrdir.transport.put_bytes(
2987
'checkout/last-revision', last_revision)
2988
self.bzrdir.transport.put_bytes(
2990
BzrDirMetaFormat1().get_format_string(),
2991
mode=self.file_mode)
2992
return BzrDir.open(self.bzrdir.root_transport.base)
2994
def make_lock(self, name):
2995
"""Make a lock for the new control dir name."""
2996
self.step('Make %s lock' % name)
2997
ld = lockdir.LockDir(self.bzrdir.transport,
2999
file_modebits=self.file_mode,
3000
dir_modebits=self.dir_mode)
3003
def move_entry(self, new_dir, entry):
3004
"""Move then entry name into new_dir."""
3006
mandatory = entry[1]
3007
self.step('Moving %s' % name)
3009
self.bzrdir.transport.move(name, '%s/%s' % (new_dir, name))
3010
except errors.NoSuchFile:
3014
def put_format(self, dirname, format):
3015
self.bzrdir.transport.put_bytes('%s/format' % dirname,
3016
format.get_format_string(),
3020
class ConvertMetaToMeta(Converter):
1748
BzrProber.formats.register(BzrDirMetaFormat1.get_format_string(),
1750
controldir.ControlDirFormat._default_format = BzrDirMetaFormat1()
1753
class BzrDirMetaFormat1Colo(BzrDirMetaFormat1):
1754
"""BzrDirMeta1 format with support for colocated branches."""
1756
colocated_branches = True
1759
def get_format_string(cls):
1760
"""See BzrDirFormat.get_format_string()."""
1761
return "Bazaar meta directory, format 1 (with colocated branches)\n"
1763
def get_format_description(self):
1764
"""See BzrDirFormat.get_format_description()."""
1765
return "Meta directory format 1 with support for colocated branches"
1767
def _open(self, transport):
1768
"""See BzrDirFormat._open."""
1769
# Create a new format instance because otherwise initialisation of new
1770
# metadirs share the global default format object leading to alias
1772
format = BzrDirMetaFormat1Colo()
1773
self._supply_sub_formats_to(format)
1774
return BzrDirMeta1(transport, format)
1777
BzrProber.formats.register(BzrDirMetaFormat1Colo.get_format_string(),
1778
BzrDirMetaFormat1Colo)
1781
class ConvertMetaToMeta(controldir.Converter):
3021
1782
"""Converts the components of metadirs."""
3023
1784
def __init__(self, target_format):
3096
1852
isinstance(self.target_format.workingtree_format,
3097
1853
workingtree_4.WorkingTreeFormat6)):
3098
1854
workingtree_4.Converter4or5to6().convert(tree)
3099
1856
return to_convert
3102
# This is not in remote.py because it's relatively small, and needs to be
3103
# registered. Putting it in remote.py creates a circular import problem.
3104
# we can make it a lazy object if the control formats is turned into something
3106
class RemoteBzrDirFormat(BzrDirMetaFormat1):
3107
"""Format representing bzrdirs accessed via a smart server"""
3110
BzrDirMetaFormat1.__init__(self)
3111
# XXX: It's a bit ugly that the network name is here, because we'd
3112
# like to believe that format objects are stateless or at least
3113
# immutable, However, we do at least avoid mutating the name after
3114
# it's returned. See <https://bugs.edge.launchpad.net/bzr/+bug/504102>
3115
self._network_name = None
3118
return "%s(_network_name=%r)" % (self.__class__.__name__,
3121
def get_format_description(self):
3122
if self._network_name:
3123
real_format = network_format_registry.get(self._network_name)
3124
return 'Remote: ' + real_format.get_format_description()
3125
return 'bzr remote bzrdir'
3127
def get_format_string(self):
3128
raise NotImplementedError(self.get_format_string)
3130
def network_name(self):
3131
if self._network_name:
3132
return self._network_name
3134
raise AssertionError("No network name set.")
3137
def probe_transport(klass, transport):
3138
"""Return a RemoteBzrDirFormat object if it looks possible."""
3140
medium = transport.get_smart_medium()
3141
except (NotImplementedError, AttributeError,
3142
errors.TransportNotPossible, errors.NoSmartMedium,
3143
errors.SmartProtocolError):
3144
# no smart server, so not a branch for this format type.
3145
raise errors.NotBranchError(path=transport.base)
3147
# Decline to open it if the server doesn't support our required
3148
# version (3) so that the VFS-based transport will do it.
3149
if medium.should_probe():
3151
server_version = medium.protocol_version()
3152
except errors.SmartProtocolError:
3153
# Apparently there's no usable smart server there, even though
3154
# the medium supports the smart protocol.
3155
raise errors.NotBranchError(path=transport.base)
3156
if server_version != '2':
3157
raise errors.NotBranchError(path=transport.base)
3160
def initialize_on_transport(self, transport):
3162
# hand off the request to the smart server
3163
client_medium = transport.get_smart_medium()
3164
except errors.NoSmartMedium:
3165
# TODO: lookup the local format from a server hint.
3166
local_dir_format = BzrDirMetaFormat1()
3167
return local_dir_format.initialize_on_transport(transport)
3168
client = _SmartClient(client_medium)
3169
path = client.remote_path_from_transport(transport)
3171
response = client.call('BzrDirFormat.initialize', path)
3172
except errors.ErrorFromSmartServer, err:
3173
remote._translate_error(err, path=path)
3174
if response[0] != 'ok':
3175
raise errors.SmartProtocolError('unexpected response code %s' % (response,))
3176
format = RemoteBzrDirFormat()
3177
self._supply_sub_formats_to(format)
3178
return remote.RemoteBzrDir(transport, format)
3180
def parse_NoneTrueFalse(self, arg):
3187
raise AssertionError("invalid arg %r" % arg)
3189
def _serialize_NoneTrueFalse(self, arg):
3196
def _serialize_NoneString(self, arg):
3199
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
3200
create_prefix=False, force_new_repo=False, stacked_on=None,
3201
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
3204
# hand off the request to the smart server
3205
client_medium = transport.get_smart_medium()
3206
except errors.NoSmartMedium:
3209
# Decline to open it if the server doesn't support our required
3210
# version (3) so that the VFS-based transport will do it.
3211
if client_medium.should_probe():
3213
server_version = client_medium.protocol_version()
3214
if server_version != '2':
3218
except errors.SmartProtocolError:
3219
# Apparently there's no usable smart server there, even though
3220
# the medium supports the smart protocol.
3225
client = _SmartClient(client_medium)
3226
path = client.remote_path_from_transport(transport)
3227
if client_medium._is_remote_before((1, 16)):
3230
# TODO: lookup the local format from a server hint.
3231
local_dir_format = BzrDirMetaFormat1()
3232
self._supply_sub_formats_to(local_dir_format)
3233
return local_dir_format.initialize_on_transport_ex(transport,
3234
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3235
force_new_repo=force_new_repo, stacked_on=stacked_on,
3236
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3237
make_working_trees=make_working_trees, shared_repo=shared_repo,
3239
return self._initialize_on_transport_ex_rpc(client, path, transport,
3240
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3241
stack_on_pwd, repo_format_name, make_working_trees, shared_repo)
3243
def _initialize_on_transport_ex_rpc(self, client, path, transport,
3244
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3245
stack_on_pwd, repo_format_name, make_working_trees, shared_repo):
3247
args.append(self._serialize_NoneTrueFalse(use_existing_dir))
3248
args.append(self._serialize_NoneTrueFalse(create_prefix))
3249
args.append(self._serialize_NoneTrueFalse(force_new_repo))
3250
args.append(self._serialize_NoneString(stacked_on))
3251
# stack_on_pwd is often/usually our transport
3254
stack_on_pwd = transport.relpath(stack_on_pwd)
3255
if not stack_on_pwd:
3257
except errors.PathNotChild:
3259
args.append(self._serialize_NoneString(stack_on_pwd))
3260
args.append(self._serialize_NoneString(repo_format_name))
3261
args.append(self._serialize_NoneTrueFalse(make_working_trees))
3262
args.append(self._serialize_NoneTrueFalse(shared_repo))
3263
request_network_name = self._network_name or \
3264
BzrDirFormat.get_default_format().network_name()
3266
response = client.call('BzrDirFormat.initialize_ex_1.16',
3267
request_network_name, path, *args)
3268
except errors.UnknownSmartMethod:
3269
client._medium._remember_remote_is_before((1,16))
3270
local_dir_format = BzrDirMetaFormat1()
3271
self._supply_sub_formats_to(local_dir_format)
3272
return local_dir_format.initialize_on_transport_ex(transport,
3273
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3274
force_new_repo=force_new_repo, stacked_on=stacked_on,
3275
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3276
make_working_trees=make_working_trees, shared_repo=shared_repo,
3278
except errors.ErrorFromSmartServer, err:
3279
remote._translate_error(err, path=path)
3280
repo_path = response[0]
3281
bzrdir_name = response[6]
3282
require_stacking = response[7]
3283
require_stacking = self.parse_NoneTrueFalse(require_stacking)
3284
format = RemoteBzrDirFormat()
3285
format._network_name = bzrdir_name
3286
self._supply_sub_formats_to(format)
3287
bzrdir = remote.RemoteBzrDir(transport, format, _client=client)
3289
repo_format = remote.response_tuple_to_repo_format(response[1:])
3290
if repo_path == '.':
3293
repo_bzrdir_format = RemoteBzrDirFormat()
3294
repo_bzrdir_format._network_name = response[5]
3295
repo_bzr = remote.RemoteBzrDir(transport.clone(repo_path),
3299
final_stack = response[8] or None
3300
final_stack_pwd = response[9] or None
3302
final_stack_pwd = urlutils.join(
3303
transport.base, final_stack_pwd)
3304
remote_repo = remote.RemoteRepository(repo_bzr, repo_format)
3305
if len(response) > 10:
3306
# Updated server verb that locks remotely.
3307
repo_lock_token = response[10] or None
3308
remote_repo.lock_write(repo_lock_token, _skip_rpc=True)
3310
remote_repo.dont_leave_lock_in_place()
3312
remote_repo.lock_write()
3313
policy = UseExistingRepository(remote_repo, final_stack,
3314
final_stack_pwd, require_stacking)
3315
policy.acquire_repository()
3319
bzrdir._format.set_branch_format(self.get_branch_format())
3320
if require_stacking:
3321
# The repo has already been created, but we need to make sure that
3322
# we'll make a stackable branch.
3323
bzrdir._format.require_stacking(_skip_repo=True)
3324
return remote_repo, bzrdir, require_stacking, policy
3326
def _open(self, transport):
3327
return remote.RemoteBzrDir(transport, self)
3329
def __eq__(self, other):
3330
if not isinstance(other, RemoteBzrDirFormat):
3332
return self.get_format_description() == other.get_format_description()
3334
def __return_repository_format(self):
3335
# Always return a RemoteRepositoryFormat object, but if a specific bzr
3336
# repository format has been asked for, tell the RemoteRepositoryFormat
3337
# that it should use that for init() etc.
3338
result = remote.RemoteRepositoryFormat()
3339
custom_format = getattr(self, '_repository_format', None)
3341
if isinstance(custom_format, remote.RemoteRepositoryFormat):
3342
return custom_format
3344
# We will use the custom format to create repositories over the
3345
# wire; expose its details like rich_root_data for code to
3347
result._custom_format = custom_format
3350
def get_branch_format(self):
3351
result = BzrDirMetaFormat1.get_branch_format(self)
3352
if not isinstance(result, remote.RemoteBranchFormat):
3353
new_result = remote.RemoteBranchFormat()
3354
new_result._custom_format = result
3356
self.set_branch_format(new_result)
3360
repository_format = property(__return_repository_format,
3361
BzrDirMetaFormat1._set_repository_format) #.im_func)
3364
BzrDirFormat.register_control_server_format(RemoteBzrDirFormat)
3367
class BzrDirFormatInfo(object):
3369
def __init__(self, native, deprecated, hidden, experimental):
3370
self.deprecated = deprecated
3371
self.native = native
3372
self.hidden = hidden
3373
self.experimental = experimental
3376
class BzrDirFormatRegistry(registry.Registry):
3377
"""Registry of user-selectable BzrDir subformats.
3379
Differs from BzrDirFormat._control_formats in that it provides sub-formats,
3380
e.g. BzrDirMeta1 with weave repository. Also, it's more user-oriented.
3384
"""Create a BzrDirFormatRegistry."""
3385
self._aliases = set()
3386
self._registration_order = list()
3387
super(BzrDirFormatRegistry, self).__init__()
3390
"""Return a set of the format names which are aliases."""
3391
return frozenset(self._aliases)
3393
def register_metadir(self, key,
3394
repository_format, help, native=True, deprecated=False,
3400
"""Register a metadir subformat.
3402
These all use a BzrDirMetaFormat1 bzrdir, but can be parameterized
3403
by the Repository/Branch/WorkingTreeformats.
3405
:param repository_format: The fully-qualified repository format class
3407
:param branch_format: Fully-qualified branch format class name as
3409
:param tree_format: Fully-qualified tree format class name as
3412
# This should be expanded to support setting WorkingTree and Branch
3413
# formats, once BzrDirMetaFormat1 supports that.
3414
def _load(full_name):
3415
mod_name, factory_name = full_name.rsplit('.', 1)
3417
mod = __import__(mod_name, globals(), locals(),
3419
except ImportError, e:
3420
raise ImportError('failed to load %s: %s' % (full_name, e))
3422
factory = getattr(mod, factory_name)
3423
except AttributeError:
3424
raise AttributeError('no factory %s in module %r'
3429
bd = BzrDirMetaFormat1()
3430
if branch_format is not None:
3431
bd.set_branch_format(_load(branch_format))
3432
if tree_format is not None:
3433
bd.workingtree_format = _load(tree_format)
3434
if repository_format is not None:
3435
bd.repository_format = _load(repository_format)
3437
self.register(key, helper, help, native, deprecated, hidden,
3438
experimental, alias)
3440
def register(self, key, factory, help, native=True, deprecated=False,
3441
hidden=False, experimental=False, alias=False):
3442
"""Register a BzrDirFormat factory.
3444
The factory must be a callable that takes one parameter: the key.
3445
It must produce an instance of the BzrDirFormat when called.
3447
This function mainly exists to prevent the info object from being
3450
registry.Registry.register(self, key, factory, help,
3451
BzrDirFormatInfo(native, deprecated, hidden, experimental))
3453
self._aliases.add(key)
3454
self._registration_order.append(key)
3456
def register_lazy(self, key, module_name, member_name, help, native=True,
3457
deprecated=False, hidden=False, experimental=False, alias=False):
3458
registry.Registry.register_lazy(self, key, module_name, member_name,
3459
help, BzrDirFormatInfo(native, deprecated, hidden, experimental))
3461
self._aliases.add(key)
3462
self._registration_order.append(key)
3464
def set_default(self, key):
3465
"""Set the 'default' key to be a clone of the supplied key.
3467
This method must be called once and only once.
3469
registry.Registry.register(self, 'default', self.get(key),
3470
self.get_help(key), info=self.get_info(key))
3471
self._aliases.add('default')
3473
def set_default_repository(self, key):
3474
"""Set the FormatRegistry default and Repository default.
3476
This is a transitional method while Repository.set_default_format
3479
if 'default' in self:
3480
self.remove('default')
3481
self.set_default(key)
3482
format = self.get('default')()
3484
def make_bzrdir(self, key):
3485
return self.get(key)()
3487
def help_topic(self, topic):
3489
default_realkey = None
3490
default_help = self.get_help('default')
3492
for key in self._registration_order:
3493
if key == 'default':
3495
help = self.get_help(key)
3496
if help == default_help:
3497
default_realkey = key
3499
help_pairs.append((key, help))
3501
def wrapped(key, help, info):
3503
help = '(native) ' + help
3504
return ':%s:\n%s\n\n' % (key,
3505
textwrap.fill(help, initial_indent=' ',
3506
subsequent_indent=' ',
3507
break_long_words=False))
3508
if default_realkey is not None:
3509
output += wrapped(default_realkey, '(default) %s' % default_help,
3510
self.get_info('default'))
3511
deprecated_pairs = []
3512
experimental_pairs = []
3513
for key, help in help_pairs:
3514
info = self.get_info(key)
3517
elif info.deprecated:
3518
deprecated_pairs.append((key, help))
3519
elif info.experimental:
3520
experimental_pairs.append((key, help))
3522
output += wrapped(key, help, info)
3523
output += "\nSee :doc:`formats-help` for more about storage formats."
3525
if len(experimental_pairs) > 0:
3526
other_output += "Experimental formats are shown below.\n\n"
3527
for key, help in experimental_pairs:
3528
info = self.get_info(key)
3529
other_output += wrapped(key, help, info)
3532
"No experimental formats are available.\n\n"
3533
if len(deprecated_pairs) > 0:
3534
other_output += "\nDeprecated formats are shown below.\n\n"
3535
for key, help in deprecated_pairs:
3536
info = self.get_info(key)
3537
other_output += wrapped(key, help, info)
3540
"\nNo deprecated formats are available.\n\n"
3542
"\nSee :doc:`formats-help` for more about storage formats."
3544
if topic == 'other-formats':
1859
class ConvertMetaToColo(controldir.Converter):
1860
"""Add colocated branch support."""
1862
def __init__(self, target_format):
1863
"""Create a converter.that upgrades a metadir to the colo format.
1865
:param target_format: The final metadir format that is desired.
1867
self.target_format = target_format
1869
def convert(self, to_convert, pb):
1870
"""See Converter.convert()."""
1871
to_convert.transport.put_bytes('branch-format',
1872
self.target_format.as_string())
1873
return BzrDir.open_from_transport(to_convert.root_transport)
1876
class ConvertMetaToColo(controldir.Converter):
1877
"""Convert a 'development-colo' bzrdir to a '2a' bzrdir."""
1879
def __init__(self, target_format):
1880
"""Create a converter that converts a 'development-colo' metadir
1883
:param target_format: The final metadir format that is desired.
1885
self.target_format = target_format
1887
def convert(self, to_convert, pb):
1888
"""See Converter.convert()."""
1889
to_convert.transport.put_bytes('branch-format',
1890
self.target_format.as_string())
1891
return BzrDir.open_from_transport(to_convert.root_transport)
1894
controldir.ControlDirFormat.register_server_prober(RemoteBzrProber)
3550
1897
class RepositoryAcquisitionPolicy(object):
3694
2049
require_stacking)
3695
2050
self._repository = repository
3697
def acquire_repository(self, make_working_trees=None, shared=False):
2052
def acquire_repository(self, make_working_trees=None, shared=False,
2053
possible_transports=None):
3698
2054
"""Implementation of RepositoryAcquisitionPolicy.acquire_repository
3700
2056
Returns an existing repository to use.
2058
if possible_transports is None:
2059
possible_transports = []
2061
possible_transports = list(possible_transports)
2062
possible_transports.append(self._repository.bzrdir.transport)
3702
2063
self._add_fallback(self._repository,
3703
possible_transports=[self._repository.bzrdir.transport])
2064
possible_transports=possible_transports)
3704
2065
return self._repository, False
3707
# Please register new formats after old formats so that formats
3708
# appear in chronological order and format descriptions can build
3710
format_registry = BzrDirFormatRegistry()
3711
# The pre-0.8 formats have their repository format network name registered in
3712
# repository.py. MetaDir formats have their repository format network name
3713
# inferred from their disk format string.
3714
format_registry.register('weave', BzrDirFormat6,
3715
'Pre-0.8 format. Slower than knit and does not'
3716
' support checkouts or shared repositories.',
3718
format_registry.register_metadir('metaweave',
3719
'bzrlib.repofmt.weaverepo.RepositoryFormat7',
3720
'Transitional format in 0.8. Slower than knit.',
3721
branch_format='bzrlib.branch.BzrBranchFormat5',
3722
tree_format='bzrlib.workingtree.WorkingTreeFormat3',
3724
format_registry.register_metadir('knit',
2068
def register_metadir(registry, key,
2069
repository_format, help, native=True, deprecated=False,
2074
alias=False, bzrdir_format=None):
2075
"""Register a metadir subformat.
2077
These all use a meta bzrdir, but can be parameterized by the
2078
Repository/Branch/WorkingTreeformats.
2080
:param repository_format: The fully-qualified repository format class
2082
:param branch_format: Fully-qualified branch format class name as
2084
:param tree_format: Fully-qualified tree format class name as
2087
if bzrdir_format is None:
2088
bzrdir_format = BzrDirMetaFormat1
2089
# This should be expanded to support setting WorkingTree and Branch
2090
# formats, once the API supports that.
2091
def _load(full_name):
2092
mod_name, factory_name = full_name.rsplit('.', 1)
2094
factory = pyutils.get_named_object(mod_name, factory_name)
2095
except ImportError, e:
2096
raise ImportError('failed to load %s: %s' % (full_name, e))
2097
except AttributeError:
2098
raise AttributeError('no factory %s in module %r'
2099
% (full_name, sys.modules[mod_name]))
2103
bd = bzrdir_format()
2104
if branch_format is not None:
2105
bd.set_branch_format(_load(branch_format))
2106
if tree_format is not None:
2107
bd.workingtree_format = _load(tree_format)
2108
if repository_format is not None:
2109
bd.repository_format = _load(repository_format)
2111
registry.register(key, helper, help, native, deprecated, hidden,
2112
experimental, alias)
2114
register_metadir(controldir.format_registry, 'knit',
3725
2115
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3726
2116
'Format using knits. Recommended for interoperation with bzr <= 0.14.',
3727
branch_format='bzrlib.branch.BzrBranchFormat5',
3728
tree_format='bzrlib.workingtree.WorkingTreeFormat3',
3730
format_registry.register_metadir('dirstate',
3731
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3732
help='New in 0.15: Fast local operations. Compatible with bzr 0.8 and '
3733
'above when accessed over the network.',
3734
branch_format='bzrlib.branch.BzrBranchFormat5',
3735
# this uses bzrlib.workingtree.WorkingTreeFormat4 because importing
3736
# directly from workingtree_4 triggers a circular import.
3737
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3739
format_registry.register_metadir('dirstate-tags',
3740
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3741
help='New in 0.15: Fast local operations and improved scaling for '
3742
'network operations. Additionally adds support for tags.'
3743
' Incompatible with bzr < 0.15.',
2117
branch_format='bzrlib.branchfmt.fullhistory.BzrBranchFormat5',
2118
tree_format='bzrlib.workingtree_3.WorkingTreeFormat3',
2121
register_metadir(controldir.format_registry, 'dirstate',
2122
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
2123
help='Format using dirstate for working trees. '
2124
'Compatible with bzr 0.8 and '
2125
'above when accessed over the network. Introduced in bzr 0.15.',
2126
branch_format='bzrlib.branchfmt.fullhistory.BzrBranchFormat5',
2127
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
2130
register_metadir(controldir.format_registry, 'dirstate-tags',
2131
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
2132
help='Variant of dirstate with support for tags. '
2133
'Introduced in bzr 0.15.',
3744
2134
branch_format='bzrlib.branch.BzrBranchFormat6',
3745
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2135
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
3746
2137
deprecated=True)
3747
format_registry.register_metadir('rich-root',
2138
register_metadir(controldir.format_registry, 'rich-root',
3748
2139
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit4',
3749
help='New in 1.0. Better handling of tree roots. Incompatible with'
2140
help='Variant of dirstate with better handling of tree roots. '
2141
'Introduced in bzr 1.0',
3751
2142
branch_format='bzrlib.branch.BzrBranchFormat6',
3752
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2143
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
3753
2145
deprecated=True)
3754
format_registry.register_metadir('dirstate-with-subtree',
2146
register_metadir(controldir.format_registry, 'dirstate-with-subtree',
3755
2147
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit3',
3756
help='New in 0.15: Fast local operations and improved scaling for '
3757
'network operations. Additionally adds support for versioning nested '
3758
'bzr branches. Incompatible with bzr < 0.15.',
3759
branch_format='bzrlib.branch.BzrBranchFormat6',
3760
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3764
format_registry.register_metadir('pack-0.92',
3765
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack1',
3766
help='New in 0.92: Pack-based format with data compatible with '
3767
'dirstate-tags format repositories. Interoperates with '
3768
'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
3769
'Previously called knitpack-experimental. '
3770
'For more information, see '
3771
'http://doc.bazaar-vcs.org/latest/developers/packrepo.html.',
3772
branch_format='bzrlib.branch.BzrBranchFormat6',
3773
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3775
format_registry.register_metadir('pack-0.92-subtree',
3776
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack3',
3777
help='New in 0.92: Pack-based format with data compatible with '
3778
'dirstate-with-subtree format repositories. Interoperates with '
3779
'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
3780
'Previously called knitpack-experimental. '
3781
'For more information, see '
3782
'http://doc.bazaar-vcs.org/latest/developers/packrepo.html.',
3783
branch_format='bzrlib.branch.BzrBranchFormat6',
3784
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3788
format_registry.register_metadir('rich-root-pack',
3789
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack4',
3790
help='New in 1.0: A variant of pack-0.92 that supports rich-root data '
3791
'(needed for bzr-svn and bzr-git).',
3792
branch_format='bzrlib.branch.BzrBranchFormat6',
3793
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3795
format_registry.register_metadir('1.6',
3796
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5',
2148
help='Variant of dirstate with support for nested trees. '
2149
'Introduced in 0.15.',
2150
branch_format='bzrlib.branch.BzrBranchFormat6',
2151
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
2155
register_metadir(controldir.format_registry, 'pack-0.92',
2156
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack1',
2157
help='Pack-based format used in 1.x series. Introduced in 0.92. '
2158
'Interoperates with bzr repositories before 0.92 but cannot be '
2159
'read by bzr < 0.92. '
2161
branch_format='bzrlib.branch.BzrBranchFormat6',
2162
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
2165
register_metadir(controldir.format_registry, 'pack-0.92-subtree',
2166
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack3',
2167
help='Pack-based format used in 1.x series, with subtree support. '
2168
'Introduced in 0.92. Interoperates with '
2169
'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
2171
branch_format='bzrlib.branch.BzrBranchFormat6',
2172
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
2177
register_metadir(controldir.format_registry, 'rich-root-pack',
2178
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack4',
2179
help='A variant of pack-0.92 that supports rich-root data '
2180
'(needed for bzr-svn and bzr-git). Introduced in 1.0.',
2181
branch_format='bzrlib.branch.BzrBranchFormat6',
2182
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
2186
register_metadir(controldir.format_registry, '1.6',
2187
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack5',
3797
2188
help='A format that allows a branch to indicate that there is another '
3798
2189
'(stacked) repository that should be used to access data that is '
3799
2190
'not present locally.',
3800
2191
branch_format='bzrlib.branch.BzrBranchFormat7',
3801
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2192
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
3803
format_registry.register_metadir('1.6.1-rich-root',
3804
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5RichRoot',
2196
register_metadir(controldir.format_registry, '1.6.1-rich-root',
2197
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack5RichRoot',
3805
2198
help='A variant of 1.6 that supports rich-root data '
3806
2199
'(needed for bzr-svn and bzr-git).',
3807
2200
branch_format='bzrlib.branch.BzrBranchFormat7',
3808
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2201
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
3810
format_registry.register_metadir('1.9',
3811
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
2205
register_metadir(controldir.format_registry, '1.9',
2206
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6',
3812
2207
help='A repository format using B+tree indexes. These indexes '
3813
2208
'are smaller in size, have smarter caching and provide faster '
3814
2209
'performance for most operations.',
3815
2210
branch_format='bzrlib.branch.BzrBranchFormat7',
3816
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2211
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
3818
format_registry.register_metadir('1.9-rich-root',
3819
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
2215
register_metadir(controldir.format_registry, '1.9-rich-root',
2216
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6RichRoot',
3820
2217
help='A variant of 1.9 that supports rich-root data '
3821
2218
'(needed for bzr-svn and bzr-git).',
3822
2219
branch_format='bzrlib.branch.BzrBranchFormat7',
3823
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2220
tree_format='bzrlib.workingtree_4.WorkingTreeFormat4',
3825
format_registry.register_metadir('1.14',
3826
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
2224
register_metadir(controldir.format_registry, '1.14',
2225
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6',
3827
2226
help='A working-tree format that supports content filtering.',
3828
2227
branch_format='bzrlib.branch.BzrBranchFormat7',
3829
tree_format='bzrlib.workingtree.WorkingTreeFormat5',
2228
tree_format='bzrlib.workingtree_4.WorkingTreeFormat5',
3831
format_registry.register_metadir('1.14-rich-root',
3832
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
2232
register_metadir(controldir.format_registry, '1.14-rich-root',
2233
'bzrlib.repofmt.knitpack_repo.RepositoryFormatKnitPack6RichRoot',
3833
2234
help='A variant of 1.14 that supports rich-root data '
3834
2235
'(needed for bzr-svn and bzr-git).',
3835
2236
branch_format='bzrlib.branch.BzrBranchFormat7',
3836
tree_format='bzrlib.workingtree.WorkingTreeFormat5',
2237
tree_format='bzrlib.workingtree_4.WorkingTreeFormat5',
3838
2241
# The following un-numbered 'development' formats should always just be aliases.
3839
format_registry.register_metadir('development-rich-root',
3840
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
3841
help='Current development format. Supports rich roots. Can convert data '
3842
'to and from rich-root-pack (and anything compatible with '
3843
'rich-root-pack) format repositories. Repositories and branches in '
3844
'this format can only be read by bzr.dev. Please read '
3845
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3847
branch_format='bzrlib.branch.BzrBranchFormat7',
3848
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3852
format_registry.register_metadir('development-subtree',
3853
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment2Subtree',
2242
register_metadir(controldir.format_registry, 'development-subtree',
2243
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2aSubtree',
3854
2244
help='Current development format, subtree variant. Can convert data to and '
3855
2245
'from pack-0.92-subtree (and anything compatible with '
3856
2246
'pack-0.92-subtree) format repositories. Repositories and branches in '
3857
2247
'this format can only be read by bzr.dev. Please read '
3858
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
2248
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
3860
2250
branch_format='bzrlib.branch.BzrBranchFormat7',
3861
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2251
tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
3862
2252
experimental=True,
3863
2254
alias=False, # Restore to being an alias when an actual development subtree format is added
3864
2255
# This current non-alias status is simply because we did not introduce a
3865
2256
# chk based subtree format.
2258
register_metadir(controldir.format_registry, 'development5-subtree',
2259
'bzrlib.repofmt.knitpack_repo.RepositoryFormatPackDevelopment2Subtree',
2260
help='Development format, subtree variant. Can convert data to and '
2261
'from pack-0.92-subtree (and anything compatible with '
2262
'pack-0.92-subtree) format repositories. Repositories and branches in '
2263
'this format can only be read by bzr.dev. Please read '
2264
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
2266
branch_format='bzrlib.branch.BzrBranchFormat7',
2267
tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
2273
register_metadir(controldir.format_registry, 'development-colo',
2274
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
2275
help='The 2a format with experimental support for colocated branches.\n',
2276
branch_format='bzrlib.branch.BzrBranchFormat7',
2277
tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
2279
bzrdir_format=BzrDirMetaFormat1Colo,
3868
2283
# And the development formats above will have aliased one of the following:
3869
format_registry.register_metadir('development6-rich-root',
3870
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
3871
help='pack-1.9 with 255-way hashed CHK inv, group compress, rich roots '
3873
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3875
branch_format='bzrlib.branch.BzrBranchFormat7',
3876
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3881
format_registry.register_metadir('development7-rich-root',
3882
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK2',
3883
help='pack-1.9 with 255-way hashed CHK inv, bencode revision, group compress, '
3884
'rich roots. Please read '
3885
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3887
branch_format='bzrlib.branch.BzrBranchFormat7',
3888
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3893
format_registry.register_metadir('2a',
2285
# Finally, the current format.
2286
register_metadir(controldir.format_registry, '2a',
3894
2287
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
3895
help='First format for bzr 2.0 series.\n'
2288
help='Format for the bzr 2.0 series.\n'
3896
2289
'Uses group-compress storage.\n'
3897
2290
'Provides rich roots which are a one-way transition.\n',
3898
2291
# 'storage in packs, 255-way hashed CHK inventory, bencode revision, group compress, '
3899
2292
# 'rich roots. Supported by bzr 1.16 and later.',
3900
2293
branch_format='bzrlib.branch.BzrBranchFormat7',
3901
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2294
tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
3905
2298
# The following format should be an alias for the rich root equivalent
3906
2299
# of the default format
3907
format_registry.register_metadir('default-rich-root',
2300
register_metadir(controldir.format_registry, 'default-rich-root',
3908
2301
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
3909
2302
branch_format='bzrlib.branch.BzrBranchFormat7',
3910
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2303
tree_format='bzrlib.workingtree_4.WorkingTreeFormat6',
3912
2306
help='Same as 2a.')
3914
2308
# The current format that is made on 'bzr init'.
3915
format_registry.set_default('2a')
2309
format_name = config.GlobalStack().get('default_format')
2310
controldir.format_registry.set_default(format_name)
2312
# XXX 2010-08-20 JRV: There is still a lot of code relying on
2313
# bzrlib.bzrdir.format_registry existing. When BzrDir.create/BzrDir.open/etc
2314
# get changed to ControlDir.create/ControlDir.open/etc this should be removed.
2315
format_registry = controldir.format_registry
added
removed
bzrlib/bzrdir.py
