287
244
repo_format_name=repo_format_name,
288
245
make_working_trees=make_working_trees, shared_repo=want_shared)
289
246
if repo_format_name:
291
# If the result repository is in the same place as the
292
# resulting bzr dir, it will have no content, further if the
293
# result is not stacked then we know all content should be
294
# copied, and finally if we are copying up to a specific
295
# revision_id then we can use the pending-ancestry-result which
296
# does not require traversing all of history to describe it.
297
if (result_repo.user_url == result.user_url
298
and not require_stacking and
299
revision_id is not None):
300
fetch_spec = graph.PendingAncestryResult(
301
[revision_id], local_repo)
302
result_repo.fetch(local_repo, fetch_spec=fetch_spec)
304
result_repo.fetch(local_repo, revision_id=revision_id)
247
# If the result repository is in the same place as the resulting
248
# bzr dir, it will have no content, further if the result is not stacked
249
# then we know all content should be copied, and finally if we are
250
# copying up to a specific revision_id then we can use the
251
# pending-ancestry-result which does not require traversing all of
252
# history to describe it.
253
if (result_repo.bzrdir.root_transport.base ==
254
result.root_transport.base and not require_stacking and
255
revision_id is not None):
256
fetch_spec = graph.PendingAncestryResult(
257
[revision_id], local_repo)
258
result_repo.fetch(local_repo, fetch_spec=fetch_spec)
260
result_repo.fetch(local_repo, revision_id=revision_id)
308
if result_repo is not None:
309
raise AssertionError('result_repo not None(%r)' % result_repo)
310
263
# 1 if there is a branch present
311
264
# make sure its content is available in the target repository
414
358
except errors.NoRepositoryPresent:
417
return False, ([], repository)
418
return True, (bzrdir.list_branches(), None)
420
for branches, repo in BzrDir.find_bzrdirs(transport,
361
return False, (None, repository)
363
branch = bzrdir.open_branch()
364
except errors.NotBranchError:
365
return True, (None, None)
367
return True, (branch, None)
369
for branch, repo in BzrDir.find_bzrdirs(transport, evaluate=evaluate):
422
370
if repo is not None:
423
ret.extend(repo.find_branches())
424
if branches is not None:
371
branches.extend(repo.find_branches())
372
if branch is not None:
373
branches.append(branch)
428
376
def destroy_repository(self):
429
377
"""Destroy the repository in this BzrDir"""
430
378
raise NotImplementedError(self.destroy_repository)
432
def create_branch(self, name=None):
380
def create_branch(self):
433
381
"""Create a branch in this BzrDir.
435
:param name: Name of the colocated branch to create, None for
438
383
The bzrdir's format will control what branch format is created.
439
384
For more control see BranchFormatXX.create(a_bzrdir).
441
386
raise NotImplementedError(self.create_branch)
443
def destroy_branch(self, name=None):
444
"""Destroy a branch in this BzrDir.
446
:param name: Name of the branch to destroy, None for the default
388
def destroy_branch(self):
389
"""Destroy the branch in this BzrDir"""
449
390
raise NotImplementedError(self.destroy_branch)
621
562
:return: Tuple with old path name and new path name
623
def name_gen(base='backup.bzr'):
625
name = "%s.~%d~" % (base, counter)
626
while self.root_transport.has(name):
628
name = "%s.~%d~" % (base, counter)
631
backup_dir=name_gen()
632
564
pb = ui.ui_factory.nested_progress_bar()
634
566
# FIXME: bug 300001 -- the backup fails if the backup directory
635
567
# already exists, but it should instead either remove it or make
636
568
# a new backup directory.
570
# FIXME: bug 262450 -- the backup directory should have the same
571
# permissions as the .bzr directory (probably a bug in copy_tree)
638
572
old_path = self.root_transport.abspath('.bzr')
639
new_path = self.root_transport.abspath(backup_dir)
640
ui.ui_factory.note('making backup of %s\n to %s' % (old_path, new_path,))
641
self.root_transport.copy_tree('.bzr', backup_dir)
573
new_path = self.root_transport.abspath('backup.bzr')
574
pb.note('making backup of %s' % (old_path,))
575
pb.note(' to %s' % (new_path,))
576
self.root_transport.copy_tree('.bzr', 'backup.bzr')
642
577
return (old_path, new_path)
1373
1297
self.create_hook(hooks.HookPoint('pre_open',
1374
1298
"Invoked before attempting to open a BzrDir with the transport "
1375
1299
"that the open will use.", (1, 14), None))
1376
self.create_hook(hooks.HookPoint('post_repo_init',
1377
"Invoked after a repository has been initialized. "
1378
"post_repo_init is called with a "
1379
"bzrlib.bzrdir.RepoInitHookParams.",
1382
1301
# install the default hooks
1383
1302
BzrDir.hooks = BzrDirHooks()
1386
class RepoInitHookParams(object):
1387
"""Object holding parameters passed to *_repo_init hooks.
1389
There are 4 fields that hooks may wish to access:
1391
:ivar repository: Repository created
1392
:ivar format: Repository format
1393
:ivar bzrdir: The bzrdir for the repository
1394
:ivar shared: The repository is shared
1397
def __init__(self, repository, format, a_bzrdir, shared):
1398
"""Create a group of RepoInitHook parameters.
1400
:param repository: Repository created
1401
:param format: Repository format
1402
:param bzrdir: The bzrdir for the repository
1403
:param shared: The repository is shared
1405
self.repository = repository
1406
self.format = format
1407
self.bzrdir = a_bzrdir
1408
self.shared = shared
1410
def __eq__(self, other):
1411
return self.__dict__ == other.__dict__
1415
return "<%s for %s>" % (self.__class__.__name__,
1418
return "<%s for %s>" % (self.__class__.__name__,
1422
1305
class BzrDirPreSplitOut(BzrDir):
1423
1306
"""A common class for the all-in-one formats."""
2038
1877
default the format has.
2039
1878
:param shared_repo: Control whether made repositories are shared or
2041
:param vfs_only: If True do not attempt to use a smart server
2042
1880
:return: repo, bzrdir, require_stacking, repository_policy. repo is
2043
1881
None if none was created or found, bzrdir is always valid.
2044
1882
require_stacking is the result of examining the stacked_on
2045
1883
parameter and any stacking policy found for the target.
2048
# Try to hand off to a smart server
2050
client_medium = transport.get_smart_medium()
2051
except errors.NoSmartMedium:
2054
# TODO: lookup the local format from a server hint.
2055
remote_dir_format = RemoteBzrDirFormat()
2056
remote_dir_format._network_name = self.network_name()
2057
self._supply_sub_formats_to(remote_dir_format)
2058
return remote_dir_format.initialize_on_transport_ex(transport,
2059
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
2060
force_new_repo=force_new_repo, stacked_on=stacked_on,
2061
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
2062
make_working_trees=make_working_trees, shared_repo=shared_repo)
2063
1885
# XXX: Refactor the create_prefix/no_create_prefix code into a
2064
1886
# common helper function
2065
1887
# The destination may not exist - if so make it according to policy.
2511
2332
def set_branch_format(self, format):
2512
2333
self._branch_format = format
2514
def require_stacking(self, stack_on=None, possible_transports=None,
2516
"""We have a request to stack, try to ensure the formats support it.
2518
:param stack_on: If supplied, it is the URL to a branch that we want to
2519
stack on. Check to see if that format supports stacking before
2522
# Stacking is desired. requested by the target, but does the place it
2523
# points at support stacking? If it doesn't then we should
2524
# not implicitly upgrade. We check this here.
2525
new_repo_format = None
2526
new_branch_format = None
2528
# a bit of state for get_target_branch so that we don't try to open it
2529
# 2 times, for both repo *and* branch
2530
target = [None, False, None] # target_branch, checked, upgrade anyway
2531
def get_target_branch():
2533
# We've checked, don't check again
2535
if stack_on is None:
2536
# No target format, that means we want to force upgrading
2537
target[:] = [None, True, True]
2540
target_dir = BzrDir.open(stack_on,
2541
possible_transports=possible_transports)
2542
except errors.NotBranchError:
2543
# Nothing there, don't change formats
2544
target[:] = [None, True, False]
2546
except errors.JailBreak:
2547
# JailBreak, JFDI and upgrade anyway
2548
target[:] = [None, True, True]
2551
target_branch = target_dir.open_branch()
2552
except errors.NotBranchError:
2553
# No branch, don't upgrade formats
2554
target[:] = [None, True, False]
2556
target[:] = [target_branch, True, False]
2559
if (not _skip_repo and
2560
not self.repository_format.supports_external_lookups):
2561
# We need to upgrade the Repository.
2562
target_branch, _, do_upgrade = get_target_branch()
2563
if target_branch is None:
2564
# We don't have a target branch, should we upgrade anyway?
2566
# stack_on is inaccessible, JFDI.
2567
# TODO: bad monkey, hard-coded formats...
2568
if self.repository_format.rich_root_data:
2569
new_repo_format = pack_repo.RepositoryFormatKnitPack5RichRoot()
2571
new_repo_format = pack_repo.RepositoryFormatKnitPack5()
2573
# If the target already supports stacking, then we know the
2574
# project is already able to use stacking, so auto-upgrade
2576
new_repo_format = target_branch.repository._format
2577
if not new_repo_format.supports_external_lookups:
2578
# target doesn't, source doesn't, so don't auto upgrade
2580
new_repo_format = None
2581
if new_repo_format is not None:
2582
self.repository_format = new_repo_format
2583
note('Source repository format does not support stacking,'
2584
' using format:\n %s',
2585
new_repo_format.get_format_description())
2335
def require_stacking(self):
2587
2336
if not self.get_branch_format().supports_stacking():
2588
# We just checked the repo, now lets check if we need to
2589
# upgrade the branch format
2590
target_branch, _, do_upgrade = get_target_branch()
2591
if target_branch is None:
2593
# TODO: bad monkey, hard-coded formats...
2594
new_branch_format = branch.BzrBranchFormat7()
2337
# We need to make a stacked branch, but the default format for the
2338
# target doesn't support stacking. So force a branch that *can*
2340
from bzrlib.branch import BzrBranchFormat7
2341
branch_format = BzrBranchFormat7()
2342
self.set_branch_format(branch_format)
2343
mutter("using %r for stacking" % (branch_format,))
2344
from bzrlib.repofmt import pack_repo
2345
if self.repository_format.rich_root_data:
2346
bzrdir_format_name = '1.6.1-rich-root'
2347
repo_format = pack_repo.RepositoryFormatKnitPack5RichRoot()
2596
new_branch_format = target_branch._format
2597
if not new_branch_format.supports_stacking():
2598
new_branch_format = None
2599
if new_branch_format is not None:
2600
# Does support stacking, use its format.
2601
self.set_branch_format(new_branch_format)
2602
note('Source branch format does not support stacking,'
2603
' using format:\n %s',
2604
new_branch_format.get_format_description())
2349
bzrdir_format_name = '1.6'
2350
repo_format = pack_repo.RepositoryFormatKnitPack5()
2351
note('Source format does not support stacking, using format:'
2353
bzrdir_format_name, repo_format.get_format_description())
2354
self.repository_format = repo_format
2606
2356
def get_converter(self, format=None):
2607
2357
"""See BzrDirFormat.get_converter()."""
3291
3013
return local_dir_format.initialize_on_transport(transport)
3292
3014
client = _SmartClient(client_medium)
3293
3015
path = client.remote_path_from_transport(transport)
3295
response = client.call('BzrDirFormat.initialize', path)
3296
except errors.ErrorFromSmartServer, err:
3297
remote._translate_error(err, path=path)
3016
response = client.call('BzrDirFormat.initialize', path)
3298
3017
if response[0] != 'ok':
3299
3018
raise errors.SmartProtocolError('unexpected response code %s' % (response,))
3300
3019
format = RemoteBzrDirFormat()
3301
3020
self._supply_sub_formats_to(format)
3302
3021
return remote.RemoteBzrDir(transport, format)
3304
def parse_NoneTrueFalse(self, arg):
3311
raise AssertionError("invalid arg %r" % arg)
3313
def _serialize_NoneTrueFalse(self, arg):
3320
def _serialize_NoneString(self, arg):
3323
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
3324
create_prefix=False, force_new_repo=False, stacked_on=None,
3325
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
3328
# hand off the request to the smart server
3329
client_medium = transport.get_smart_medium()
3330
except errors.NoSmartMedium:
3333
# Decline to open it if the server doesn't support our required
3334
# version (3) so that the VFS-based transport will do it.
3335
if client_medium.should_probe():
3337
server_version = client_medium.protocol_version()
3338
if server_version != '2':
3342
except errors.SmartProtocolError:
3343
# Apparently there's no usable smart server there, even though
3344
# the medium supports the smart protocol.
3349
client = _SmartClient(client_medium)
3350
path = client.remote_path_from_transport(transport)
3351
if client_medium._is_remote_before((1, 16)):
3354
# TODO: lookup the local format from a server hint.
3355
local_dir_format = BzrDirMetaFormat1()
3356
self._supply_sub_formats_to(local_dir_format)
3357
return local_dir_format.initialize_on_transport_ex(transport,
3358
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3359
force_new_repo=force_new_repo, stacked_on=stacked_on,
3360
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3361
make_working_trees=make_working_trees, shared_repo=shared_repo,
3363
return self._initialize_on_transport_ex_rpc(client, path, transport,
3364
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3365
stack_on_pwd, repo_format_name, make_working_trees, shared_repo)
3367
def _initialize_on_transport_ex_rpc(self, client, path, transport,
3368
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3369
stack_on_pwd, repo_format_name, make_working_trees, shared_repo):
3371
args.append(self._serialize_NoneTrueFalse(use_existing_dir))
3372
args.append(self._serialize_NoneTrueFalse(create_prefix))
3373
args.append(self._serialize_NoneTrueFalse(force_new_repo))
3374
args.append(self._serialize_NoneString(stacked_on))
3375
# stack_on_pwd is often/usually our transport
3378
stack_on_pwd = transport.relpath(stack_on_pwd)
3379
if not stack_on_pwd:
3381
except errors.PathNotChild:
3383
args.append(self._serialize_NoneString(stack_on_pwd))
3384
args.append(self._serialize_NoneString(repo_format_name))
3385
args.append(self._serialize_NoneTrueFalse(make_working_trees))
3386
args.append(self._serialize_NoneTrueFalse(shared_repo))
3387
request_network_name = self._network_name or \
3388
BzrDirFormat.get_default_format().network_name()
3390
response = client.call('BzrDirFormat.initialize_ex_1.16',
3391
request_network_name, path, *args)
3392
except errors.UnknownSmartMethod:
3393
client._medium._remember_remote_is_before((1,16))
3394
local_dir_format = BzrDirMetaFormat1()
3395
self._supply_sub_formats_to(local_dir_format)
3396
return local_dir_format.initialize_on_transport_ex(transport,
3397
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3398
force_new_repo=force_new_repo, stacked_on=stacked_on,
3399
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3400
make_working_trees=make_working_trees, shared_repo=shared_repo,
3402
except errors.ErrorFromSmartServer, err:
3403
remote._translate_error(err, path=path)
3404
repo_path = response[0]
3405
bzrdir_name = response[6]
3406
require_stacking = response[7]
3407
require_stacking = self.parse_NoneTrueFalse(require_stacking)
3408
format = RemoteBzrDirFormat()
3409
format._network_name = bzrdir_name
3410
self._supply_sub_formats_to(format)
3411
bzrdir = remote.RemoteBzrDir(transport, format, _client=client)
3413
repo_format = remote.response_tuple_to_repo_format(response[1:])
3414
if repo_path == '.':
3417
repo_bzrdir_format = RemoteBzrDirFormat()
3418
repo_bzrdir_format._network_name = response[5]
3419
repo_bzr = remote.RemoteBzrDir(transport.clone(repo_path),
3423
final_stack = response[8] or None
3424
final_stack_pwd = response[9] or None
3426
final_stack_pwd = urlutils.join(
3427
transport.base, final_stack_pwd)
3428
remote_repo = remote.RemoteRepository(repo_bzr, repo_format)
3429
if len(response) > 10:
3430
# Updated server verb that locks remotely.
3431
repo_lock_token = response[10] or None
3432
remote_repo.lock_write(repo_lock_token, _skip_rpc=True)
3434
remote_repo.dont_leave_lock_in_place()
3436
remote_repo.lock_write()
3437
policy = UseExistingRepository(remote_repo, final_stack,
3438
final_stack_pwd, require_stacking)
3439
policy.acquire_repository()
3443
bzrdir._format.set_branch_format(self.get_branch_format())
3444
if require_stacking:
3445
# The repo has already been created, but we need to make sure that
3446
# we'll make a stackable branch.
3447
bzrdir._format.require_stacking(_skip_repo=True)
3448
return remote_repo, bzrdir, require_stacking, policy
3450
3023
def _open(self, transport):
3451
3024
return remote.RemoteBzrDir(transport, self)
3788
3351
stack_on = self._get_full_stack_on()
3353
# Stacking is desired. requested by the target, but does the place it
3354
# points at support stacking? If it doesn't then we should
3355
# not implicitly upgrade. We check this here.
3790
3356
format = self._bzrdir._format
3791
format.require_stacking(stack_on=stack_on,
3792
possible_transports=[self._bzrdir.root_transport])
3357
if not (format.repository_format.supports_external_lookups
3358
and format.get_branch_format().supports_stacking()):
3359
# May need to upgrade - but only do if the target also
3360
# supports stacking. Note that this currently wastes
3361
# network round trips to check - but we only do this
3362
# when the source can't stack so it will fade away
3363
# as people do upgrade.
3365
target_dir = BzrDir.open(stack_on,
3366
possible_transports=[self._bzrdir.root_transport])
3367
except errors.NotBranchError:
3368
# Nothing there, don't change formats
3372
target_branch = target_dir.open_branch()
3373
except errors.NotBranchError:
3374
# No branch, don't change formats
3377
branch_format = target_branch._format
3378
repo_format = target_branch.repository._format
3379
if not (branch_format.supports_stacking()
3380
and repo_format.supports_external_lookups):
3381
# Doesn't stack itself, don't force an upgrade
3384
# Does support stacking, use its format.
3385
format.repository_format = repo_format
3386
format.set_branch_format(branch_format)
3387
note('Source format does not support stacking, '
3388
'using format: \'%s\'\n %s\n',
3389
branch_format.get_format_description(),
3390
repo_format.get_format_description())
3793
3391
if not self._require_stacking:
3794
3392
# We have picked up automatic stacking somewhere.
3795
3393
note('Using default stacking branch %s at %s', self._stack_on,
4003
3592
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
4004
3593
help='pack-1.9 with 255-way hashed CHK inv, group compress, rich roots '
4006
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
4008
branch_format='bzrlib.branch.BzrBranchFormat7',
4009
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4014
format_registry.register_metadir('development7-rich-root',
4015
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK2',
4016
help='pack-1.9 with 255-way hashed CHK inv, bencode revision, group compress, '
4017
'rich roots. Please read '
4018
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
4020
branch_format='bzrlib.branch.BzrBranchFormat7',
4021
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4026
format_registry.register_metadir('2a',
4027
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
4028
help='First format for bzr 2.0 series.\n'
4029
'Uses group-compress storage.\n'
4030
'Provides rich roots which are a one-way transition.\n',
4031
# 'storage in packs, 255-way hashed CHK inventory, bencode revision, group compress, '
4032
# 'rich roots. Supported by bzr 1.16 and later.',
4033
branch_format='bzrlib.branch.BzrBranchFormat7',
4034
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3595
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3597
branch_format='bzrlib.branch.BzrBranchFormat7',
3598
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4035
3600
experimental=True,
4038
3603
# The following format should be an alias for the rich root equivalent
4039
3604
# of the default format
4040
3605
format_registry.register_metadir('default-rich-root',
4041
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
4042
branch_format='bzrlib.branch.BzrBranchFormat7',
4043
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3606
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack4',
3607
help='Default format, rich root variant. (needed for bzr-svn and bzr-git).',
3608
branch_format='bzrlib.branch.BzrBranchFormat6',
3609
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
4048
3612
# The current format that is made on 'bzr init'.
4049
format_registry.set_default('2a')
3613
format_registry.set_default('pack-0.92')