267
209
errors.UnstackableRepositoryFormat,
268
210
errors.NotStacked):
270
# Bug: We create a metadir without knowing if it can support stacking,
271
# we should look up the policy needs first, or just use it as a hint,
214
# may need to copy content in
215
repository_policy = result.determine_repository_policy(
216
force_new_repo, stacked_on, self.root_transport.base,
217
require_stacking=require_stacking)
274
218
make_working_trees = local_repo.make_working_trees()
275
want_shared = local_repo.is_shared()
276
repo_format_name = format.repository_format.network_name()
278
make_working_trees = False
280
repo_format_name = None
282
result_repo, result, require_stacking, repository_policy = \
283
format.initialize_on_transport_ex(transport,
284
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
285
force_new_repo=force_new_repo, stacked_on=stacked_on,
286
stack_on_pwd=self.root_transport.base,
287
repo_format_name=repo_format_name,
288
make_working_trees=make_working_trees, shared_repo=want_shared)
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)
308
if result_repo is not None:
309
raise AssertionError('result_repo not None(%r)' % result_repo)
219
result_repo = repository_policy.acquire_repository(
220
make_working_trees, local_repo.is_shared())
221
result_repo.fetch(local_repo, revision_id=revision_id)
310
224
# 1 if there is a branch present
311
225
# make sure its content is available in the target repository
313
227
if local_branch is not None:
314
result_branch = local_branch.clone(result, revision_id=revision_id,
315
repository_policy=repository_policy)
317
# Cheaper to check if the target is not local, than to try making
319
result.root_transport.local_abspath('.')
320
if result_repo is None or result_repo.make_working_trees():
228
result_branch = local_branch.clone(result, revision_id=revision_id)
229
if repository_policy is not None:
230
repository_policy.configure_branch(result_branch)
231
if result_repo is None or result_repo.make_working_trees():
321
233
self.open_workingtree().clone(result)
322
except (errors.NoWorkingTree, errors.NotLocalUrl):
234
except (errors.NoWorkingTree, errors.NotLocalUrl):
326
238
# TODO: This should be given a Transport, and should chdir up; otherwise
414
317
except errors.NoRepositoryPresent:
417
return False, ([], repository)
418
return True, (bzrdir.list_branches(), None)
420
for branches, repo in BzrDir.find_bzrdirs(transport,
320
return False, (None, repository)
322
branch = bzrdir.open_branch()
323
except errors.NotBranchError:
324
return True, (None, None)
326
return True, (branch, None)
328
for branch, repo in BzrDir.find_bzrdirs(transport, evaluate=evaluate):
422
329
if repo is not None:
423
ret.extend(repo.find_branches())
424
if branches is not None:
330
branches.extend(repo.find_branches())
331
if branch is not None:
332
branches.append(branch)
428
335
def destroy_repository(self):
429
336
"""Destroy the repository in this BzrDir"""
430
337
raise NotImplementedError(self.destroy_repository)
432
def create_branch(self, name=None):
339
def create_branch(self):
433
340
"""Create a branch in this BzrDir.
435
:param name: Name of the colocated branch to create, None for
438
342
The bzrdir's format will control what branch format is created.
439
343
For more control see BranchFormatXX.create(a_bzrdir).
441
345
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
347
def destroy_branch(self):
348
"""Destroy the branch in this BzrDir"""
449
349
raise NotImplementedError(self.destroy_branch)
918
773
:param transport: Transport containing the bzrdir.
919
774
:param _unsupported: private.
921
for hook in BzrDir.hooks['pre_open']:
923
# Keep initial base since 'transport' may be modified while following
925
776
base = transport.base
926
778
def find_format(transport):
927
779
return transport, BzrDirFormat.find_format(
928
780
transport, _server_formats=_server_formats)
930
782
def redirected(transport, e, redirection_notice):
931
redirected_transport = transport._redirected_to(e.source, e.target)
932
if redirected_transport is None:
933
raise errors.NotBranchError(base)
783
qualified_source = e.get_source_url()
784
relpath = transport.relpath(qualified_source)
785
if not e.target.endswith(relpath):
786
# Not redirected to a branch-format, not a branch
787
raise errors.NotBranchError(path=e.target)
788
target = e.target[:-len(relpath)]
934
789
note('%s is%s redirected to %s',
935
transport.base, e.permanently, redirected_transport.base)
936
return redirected_transport
790
transport.base, e.permanently, target)
791
# Let's try with a new transport
792
# FIXME: If 'transport' has a qualifier, this should
793
# be applied again to the new transport *iff* the
794
# schemes used are the same. Uncomment this code
795
# once the function (and tests) exist.
797
#target = urlutils.copy_url_qualifiers(original, target)
798
return get_transport(target)
939
801
transport, format = do_catching_redirections(find_format,
1214
1082
where possible.
1215
1083
:param stacked: If true, create a stacked branch referring to the
1216
1084
location of this control directory.
1217
:param create_tree_if_local: If true, a working-tree will be created
1218
when working locally.
1220
1086
target_transport = get_transport(url, possible_transports)
1221
1087
target_transport.ensure_base()
1222
1088
cloning_format = self.cloning_metadir(stacked)
1223
1089
# Create/update the result branch
1224
1090
result = cloning_format.initialize_on_transport(target_transport)
1225
# if a stacked branch wasn't requested, we don't create one
1226
# even if the origin was stacked
1227
stacked_branch_url = None
1228
if source_branch is not None:
1092
source_branch = self.open_branch()
1093
source_repository = source_branch.repository
1230
1095
stacked_branch_url = self.root_transport.base
1231
source_repository = source_branch.repository
1097
# if a stacked branch wasn't requested, we don't create one
1098
# even if the origin was stacked
1099
stacked_branch_url = None
1100
except errors.NotBranchError:
1101
source_branch = None
1234
source_branch = self.open_branch()
1235
source_repository = source_branch.repository
1237
stacked_branch_url = self.root_transport.base
1238
except errors.NotBranchError:
1239
source_branch = None
1241
source_repository = self.open_repository()
1242
except errors.NoRepositoryPresent:
1243
source_repository = None
1103
source_repository = self.open_repository()
1104
except errors.NoRepositoryPresent:
1105
source_repository = None
1106
stacked_branch_url = None
1244
1107
repository_policy = result.determine_repository_policy(
1245
1108
force_new_repo, stacked_branch_url, require_stacking=stacked)
1246
result_repo, is_new_repo = repository_policy.acquire_repository()
1247
if is_new_repo and revision_id is not None and not stacked:
1248
fetch_spec = graph.PendingAncestryResult(
1249
[revision_id], source_repository)
1109
result_repo = repository_policy.acquire_repository()
1252
1110
if source_repository is not None:
1253
1111
# Fetch while stacked to prevent unstacked fetch from
1254
1112
# Branch.sprout.
1255
if fetch_spec is None:
1256
result_repo.fetch(source_repository, revision_id=revision_id)
1258
result_repo.fetch(source_repository, fetch_spec=fetch_spec)
1113
result_repo.fetch(source_repository, revision_id=revision_id)
1260
1115
if source_branch is None:
1261
1116
# this is for sprouting a bzrdir without a branch; is that
1316
def push_branch(self, source, revision_id=None, overwrite=False,
1317
remember=False, create_prefix=False):
1318
"""Push the source branch into this BzrDir."""
1320
# If we can open a branch, use its direct repository, otherwise see
1321
# if there is a repository without a branch.
1323
br_to = self.open_branch()
1324
except errors.NotBranchError:
1325
# Didn't find a branch, can we find a repository?
1326
repository_to = self.find_repository()
1328
# Found a branch, so we must have found a repository
1329
repository_to = br_to.repository
1331
push_result = PushResult()
1332
push_result.source_branch = source
1334
# We have a repository but no branch, copy the revisions, and then
1336
repository_to.fetch(source.repository, revision_id=revision_id)
1337
br_to = source.clone(self, revision_id=revision_id)
1338
if source.get_push_location() is None or remember:
1339
source.set_push_location(br_to.base)
1340
push_result.stacked_on = None
1341
push_result.branch_push_result = None
1342
push_result.old_revno = None
1343
push_result.old_revid = _mod_revision.NULL_REVISION
1344
push_result.target_branch = br_to
1345
push_result.master_branch = None
1346
push_result.workingtree_updated = False
1348
# We have successfully opened the branch, remember if necessary:
1349
if source.get_push_location() is None or remember:
1350
source.set_push_location(br_to.base)
1352
tree_to = self.open_workingtree()
1353
except errors.NotLocalUrl:
1354
push_result.branch_push_result = source.push(br_to,
1355
overwrite, stop_revision=revision_id)
1356
push_result.workingtree_updated = False
1357
except errors.NoWorkingTree:
1358
push_result.branch_push_result = source.push(br_to,
1359
overwrite, stop_revision=revision_id)
1360
push_result.workingtree_updated = None # Not applicable
1362
tree_to.lock_write()
1364
push_result.branch_push_result = source.push(
1365
tree_to.branch, overwrite, stop_revision=revision_id)
1369
push_result.workingtree_updated = True
1370
push_result.old_revno = push_result.branch_push_result.old_revno
1371
push_result.old_revid = push_result.branch_push_result.old_revid
1372
push_result.target_branch = \
1373
push_result.branch_push_result.target_branch
1377
class BzrDirHooks(hooks.Hooks):
1378
"""Hooks for BzrDir operations."""
1381
"""Create the default hooks."""
1382
hooks.Hooks.__init__(self)
1383
self.create_hook(hooks.HookPoint('pre_open',
1384
"Invoked before attempting to open a BzrDir with the transport "
1385
"that the open will use.", (1, 14), None))
1386
self.create_hook(hooks.HookPoint('post_repo_init',
1387
"Invoked after a repository has been initialized. "
1388
"post_repo_init is called with a "
1389
"bzrlib.bzrdir.RepoInitHookParams.",
1392
# install the default hooks
1393
BzrDir.hooks = BzrDirHooks()
1396
class RepoInitHookParams(object):
1397
"""Object holding parameters passed to *_repo_init hooks.
1399
There are 4 fields that hooks may wish to access:
1401
:ivar repository: Repository created
1402
:ivar format: Repository format
1403
:ivar bzrdir: The bzrdir for the repository
1404
:ivar shared: The repository is shared
1407
def __init__(self, repository, format, a_bzrdir, shared):
1408
"""Create a group of RepoInitHook parameters.
1410
:param repository: Repository created
1411
:param format: Repository format
1412
:param bzrdir: The bzrdir for the repository
1413
:param shared: The repository is shared
1415
self.repository = repository
1416
self.format = format
1417
self.bzrdir = a_bzrdir
1418
self.shared = shared
1420
def __eq__(self, other):
1421
return self.__dict__ == other.__dict__
1425
return "<%s for %s>" % (self.__class__.__name__,
1428
return "<%s for %s>" % (self.__class__.__name__,
1432
1179
class BzrDirPreSplitOut(BzrDir):
1433
1180
"""A common class for the all-in-one formats."""
1576
1318
# if the format is not the same as the system default,
1577
1319
# an upgrade is needed.
1578
1320
if format is None:
1579
symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
1580
% 'needs_format_conversion(format=None)')
1581
1321
format = BzrDirFormat.get_default_format()
1582
1322
return not isinstance(self._format, format.__class__)
1584
def open_branch(self, name=None, unsupported=False,
1585
ignore_fallbacks=False):
1324
def open_branch(self, unsupported=False):
1586
1325
"""See BzrDir.open_branch."""
1587
1326
from bzrlib.branch import BzrBranchFormat4
1588
1327
format = BzrBranchFormat4()
1589
1328
self._check_supported(format, unsupported)
1590
return format.open(self, name, _found=True)
1329
return format.open(self, _found=True)
1592
1331
def sprout(self, url, revision_id=None, force_new_repo=False,
1593
1332
possible_transports=None, accelerator_tree=None,
1594
hardlink=False, stacked=False, create_tree_if_local=True,
1595
source_branch=None):
1333
hardlink=False, stacked=False):
1596
1334
"""See BzrDir.sprout()."""
1597
if source_branch is not None:
1598
my_branch = self.open_branch()
1599
if source_branch.base != my_branch.base:
1600
raise AssertionError(
1601
"source branch %r is not within %r with branch %r" %
1602
(source_branch, self, my_branch))
1604
1336
raise errors.UnstackableBranchFormat(
1605
1337
self._format, self.root_transport.base)
1606
if not create_tree_if_local:
1607
raise errors.MustHaveWorkingTree(
1608
self._format, self.root_transport.base)
1609
1338
from bzrlib.workingtree import WorkingTreeFormat2
1610
1339
self._make_tail(url)
1611
1340
result = self._format._initialize_for_clone(url)
2007
1689
def initialize_on_transport(self, transport):
2008
1690
"""Initialize a new bzrdir in the base directory of a Transport."""
2010
# can we hand off the request to the smart server rather than using
2012
client_medium = transport.get_smart_medium()
2013
except errors.NoSmartMedium:
2014
return self._initialize_on_transport_vfs(transport)
2016
# Current RPC's only know how to create bzr metadir1 instances, so
2017
# we still delegate to vfs methods if the requested format is not a
2019
if type(self) != BzrDirMetaFormat1:
2020
return self._initialize_on_transport_vfs(transport)
2021
remote_format = RemoteBzrDirFormat()
2022
self._supply_sub_formats_to(remote_format)
2023
return remote_format.initialize_on_transport(transport)
2025
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
2026
create_prefix=False, force_new_repo=False, stacked_on=None,
2027
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
2028
shared_repo=False, vfs_only=False):
2029
"""Create this format on transport.
2031
The directory to initialize will be created.
2033
:param force_new_repo: Do not use a shared repository for the target,
2034
even if one is available.
2035
:param create_prefix: Create any missing directories leading up to
2037
:param use_existing_dir: Use an existing directory if one exists.
2038
:param stacked_on: A url to stack any created branch on, None to follow
2039
any target stacking policy.
2040
:param stack_on_pwd: If stack_on is relative, the location it is
2042
:param repo_format_name: If non-None, a repository will be
2043
made-or-found. Should none be found, or if force_new_repo is True
2044
the repo_format_name is used to select the format of repository to
2046
:param make_working_trees: Control the setting of make_working_trees
2047
for a new shared repository when one is made. None to use whatever
2048
default the format has.
2049
:param shared_repo: Control whether made repositories are shared or
2051
:param vfs_only: If True do not attempt to use a smart server
2052
:return: repo, bzrdir, require_stacking, repository_policy. repo is
2053
None if none was created or found, bzrdir is always valid.
2054
require_stacking is the result of examining the stacked_on
2055
parameter and any stacking policy found for the target.
2058
# Try to hand off to a smart server
2060
client_medium = transport.get_smart_medium()
2061
except errors.NoSmartMedium:
2064
# TODO: lookup the local format from a server hint.
2065
remote_dir_format = RemoteBzrDirFormat()
2066
remote_dir_format._network_name = self.network_name()
2067
self._supply_sub_formats_to(remote_dir_format)
2068
return remote_dir_format.initialize_on_transport_ex(transport,
2069
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
2070
force_new_repo=force_new_repo, stacked_on=stacked_on,
2071
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
2072
make_working_trees=make_working_trees, shared_repo=shared_repo)
2073
# XXX: Refactor the create_prefix/no_create_prefix code into a
2074
# common helper function
2075
# The destination may not exist - if so make it according to policy.
2076
def make_directory(transport):
2077
transport.mkdir('.')
2079
def redirected(transport, e, redirection_notice):
2080
note(redirection_notice)
2081
return transport._redirected_to(e.source, e.target)
2083
transport = do_catching_redirections(make_directory, transport,
2085
except errors.FileExists:
2086
if not use_existing_dir:
2088
except errors.NoSuchFile:
2089
if not create_prefix:
2091
transport.create_prefix()
2093
require_stacking = (stacked_on is not None)
2094
# Now the target directory exists, but doesn't have a .bzr
2095
# directory. So we need to create it, along with any work to create
2096
# all of the dependent branches, etc.
2098
result = self.initialize_on_transport(transport)
2099
if repo_format_name:
2101
# use a custom format
2102
result._format.repository_format = \
2103
repository.network_format_registry.get(repo_format_name)
2104
except AttributeError:
2105
# The format didn't permit it to be set.
2107
# A repository is desired, either in-place or shared.
2108
repository_policy = result.determine_repository_policy(
2109
force_new_repo, stacked_on, stack_on_pwd,
2110
require_stacking=require_stacking)
2111
result_repo, is_new_repo = repository_policy.acquire_repository(
2112
make_working_trees, shared_repo)
2113
if not require_stacking and repository_policy._require_stacking:
2114
require_stacking = True
2115
result._format.require_stacking()
2116
result_repo.lock_write()
2119
repository_policy = None
2120
return result_repo, result, require_stacking, repository_policy
2122
def _initialize_on_transport_vfs(self, transport):
2123
"""Initialize a new bzrdir using VFS calls.
2125
:param transport: The transport to create the .bzr directory in.
2128
# Since we are creating a .bzr directory, inherit the
1691
# Since we don't have a .bzr directory, inherit the
2129
1692
# mode from the root directory
2130
1693
temp_control = lockable_files.LockableFiles(transport,
2131
1694
'', lockable_files.TransportLock)
2336
1869
repository_format = property(__return_repository_format)
2339
class BzrDirFormatAllInOne(BzrDirFormat):
2340
"""Common class for formats before meta-dirs."""
2342
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
2343
create_prefix=False, force_new_repo=False, stacked_on=None,
2344
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
2346
"""See BzrDirFormat.initialize_on_transport_ex."""
2347
require_stacking = (stacked_on is not None)
2348
# Format 5 cannot stack, but we've been asked to - actually init
2350
if require_stacking:
2351
format = BzrDirMetaFormat1()
2352
return format.initialize_on_transport_ex(transport,
2353
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
2354
force_new_repo=force_new_repo, stacked_on=stacked_on,
2355
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
2356
make_working_trees=make_working_trees, shared_repo=shared_repo)
2357
return BzrDirFormat.initialize_on_transport_ex(self, transport,
2358
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
2359
force_new_repo=force_new_repo, stacked_on=stacked_on,
2360
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
2361
make_working_trees=make_working_trees, shared_repo=shared_repo)
2364
class BzrDirFormat5(BzrDirFormatAllInOne):
1872
class BzrDirFormat5(BzrDirFormat):
2365
1873
"""Bzr control format 5.
2367
1875
This format is a combined format for working tree, branch and repository.
2369
- Format 2 working trees [always]
2370
- Format 4 branches [always]
1877
- Format 2 working trees [always]
1878
- Format 4 branches [always]
2371
1879
- Format 5 repositories [always]
2372
1880
Unhashed stores in the repository.
2521
2022
def set_branch_format(self, format):
2522
2023
self._branch_format = format
2524
def require_stacking(self, stack_on=None, possible_transports=None,
2526
"""We have a request to stack, try to ensure the formats support it.
2528
:param stack_on: If supplied, it is the URL to a branch that we want to
2529
stack on. Check to see if that format supports stacking before
2532
# Stacking is desired. requested by the target, but does the place it
2533
# points at support stacking? If it doesn't then we should
2534
# not implicitly upgrade. We check this here.
2535
new_repo_format = None
2536
new_branch_format = None
2538
# a bit of state for get_target_branch so that we don't try to open it
2539
# 2 times, for both repo *and* branch
2540
target = [None, False, None] # target_branch, checked, upgrade anyway
2541
def get_target_branch():
2543
# We've checked, don't check again
2545
if stack_on is None:
2546
# No target format, that means we want to force upgrading
2547
target[:] = [None, True, True]
2550
target_dir = BzrDir.open(stack_on,
2551
possible_transports=possible_transports)
2552
except errors.NotBranchError:
2553
# Nothing there, don't change formats
2554
target[:] = [None, True, False]
2556
except errors.JailBreak:
2557
# JailBreak, JFDI and upgrade anyway
2558
target[:] = [None, True, True]
2561
target_branch = target_dir.open_branch()
2562
except errors.NotBranchError:
2563
# No branch, don't upgrade formats
2564
target[:] = [None, True, False]
2566
target[:] = [target_branch, True, False]
2569
if (not _skip_repo and
2570
not self.repository_format.supports_external_lookups):
2571
# We need to upgrade the Repository.
2572
target_branch, _, do_upgrade = get_target_branch()
2573
if target_branch is None:
2574
# We don't have a target branch, should we upgrade anyway?
2576
# stack_on is inaccessible, JFDI.
2577
# TODO: bad monkey, hard-coded formats...
2578
if self.repository_format.rich_root_data:
2579
new_repo_format = pack_repo.RepositoryFormatKnitPack5RichRoot()
2581
new_repo_format = pack_repo.RepositoryFormatKnitPack5()
2583
# If the target already supports stacking, then we know the
2584
# project is already able to use stacking, so auto-upgrade
2586
new_repo_format = target_branch.repository._format
2587
if not new_repo_format.supports_external_lookups:
2588
# target doesn't, source doesn't, so don't auto upgrade
2590
new_repo_format = None
2591
if new_repo_format is not None:
2592
self.repository_format = new_repo_format
2593
note('Source repository format does not support stacking,'
2594
' using format:\n %s',
2595
new_repo_format.get_format_description())
2597
if not self.get_branch_format().supports_stacking():
2598
# We just checked the repo, now lets check if we need to
2599
# upgrade the branch format
2600
target_branch, _, do_upgrade = get_target_branch()
2601
if target_branch is None:
2603
# TODO: bad monkey, hard-coded formats...
2604
new_branch_format = branch.BzrBranchFormat7()
2606
new_branch_format = target_branch._format
2607
if not new_branch_format.supports_stacking():
2608
new_branch_format = None
2609
if new_branch_format is not None:
2610
# Does support stacking, use its format.
2611
self.set_branch_format(new_branch_format)
2612
note('Source branch format does not support stacking,'
2613
' using format:\n %s',
2614
new_branch_format.get_format_description())
2616
2025
def get_converter(self, format=None):
2617
2026
"""See BzrDirFormat.get_converter()."""
2618
2027
if format is None:
2630
2039
"""See BzrDirFormat.get_format_description()."""
2631
2040
return "Meta directory format 1"
2633
def network_name(self):
2634
return self.get_format_string()
2636
2042
def _open(self, transport):
2637
2043
"""See BzrDirFormat._open."""
2638
# Create a new format instance because otherwise initialisation of new
2639
# metadirs share the global default format object leading to alias
2641
format = BzrDirMetaFormat1()
2642
self._supply_sub_formats_to(format)
2643
return BzrDirMeta1(transport, format)
2044
return BzrDirMeta1(transport, self)
2645
2046
def __return_repository_format(self):
2646
2047
"""Circular import protection."""
2647
if self._repository_format:
2048
if getattr(self, '_repository_format', None):
2648
2049
return self._repository_format
2649
2050
from bzrlib.repository import RepositoryFormat
2650
2051
return RepositoryFormat.get_default_format()
2652
def _set_repository_format(self, value):
2053
def __set_repository_format(self, value):
2653
2054
"""Allow changing the repository format for metadir formats."""
2654
2055
self._repository_format = value
2656
repository_format = property(__return_repository_format,
2657
_set_repository_format)
2659
def _supply_sub_formats_to(self, other_format):
2660
"""Give other_format the same values for sub formats as this has.
2662
This method is expected to be used when parameterising a
2663
RemoteBzrDirFormat instance with the parameters from a
2664
BzrDirMetaFormat1 instance.
2666
:param other_format: other_format is a format which should be
2667
compatible with whatever sub formats are supported by self.
2670
if getattr(self, '_repository_format', None) is not None:
2671
other_format.repository_format = self.repository_format
2672
if self._branch_format is not None:
2673
other_format._branch_format = self._branch_format
2674
if self._workingtree_format is not None:
2675
other_format.workingtree_format = self.workingtree_format
2057
repository_format = property(__return_repository_format, __set_repository_format)
2677
2059
def __get_workingtree_format(self):
2678
2060
if self._workingtree_format is None:
3222
2582
# TODO: conversions of Branch and Tree should be done by
3223
2583
# InterXFormat lookups
3224
2584
if (isinstance(tree, workingtree.WorkingTree3) and
3225
not isinstance(tree, workingtree_4.DirStateWorkingTree) and
2585
not isinstance(tree, workingtree_4.WorkingTree4) and
3226
2586
isinstance(self.target_format.workingtree_format,
3227
workingtree_4.DirStateWorkingTreeFormat)):
2587
workingtree_4.WorkingTreeFormat4)):
3228
2588
workingtree_4.Converter3to4().convert(tree)
3229
if (isinstance(tree, workingtree_4.DirStateWorkingTree) and
3230
not isinstance(tree, workingtree_4.WorkingTree5) and
3231
isinstance(self.target_format.workingtree_format,
3232
workingtree_4.WorkingTreeFormat5)):
3233
workingtree_4.Converter4to5().convert(tree)
3234
if (isinstance(tree, workingtree_4.DirStateWorkingTree) and
3235
not isinstance(tree, workingtree_4.WorkingTree6) and
3236
isinstance(self.target_format.workingtree_format,
3237
workingtree_4.WorkingTreeFormat6)):
3238
workingtree_4.Converter4or5to6().convert(tree)
3240
2589
return to_convert
3243
# This is not in remote.py because it's relatively small, and needs to be
3244
# registered. Putting it in remote.py creates a circular import problem.
2592
# This is not in remote.py because it's small, and needs to be registered.
2593
# Putting it in remote.py creates a circular import problem.
3245
2594
# we can make it a lazy object if the control formats is turned into something
3246
2595
# like a registry.
3247
2596
class RemoteBzrDirFormat(BzrDirMetaFormat1):
3248
2597
"""Format representing bzrdirs accessed via a smart server"""
3251
BzrDirMetaFormat1.__init__(self)
3252
# XXX: It's a bit ugly that the network name is here, because we'd
3253
# like to believe that format objects are stateless or at least
3254
# immutable, However, we do at least avoid mutating the name after
3255
# it's returned. See <https://bugs.launchpad.net/bzr/+bug/504102>
3256
self._network_name = None
3259
return "%s(_network_name=%r)" % (self.__class__.__name__,
3262
2599
def get_format_description(self):
3263
if self._network_name:
3264
real_format = network_format_registry.get(self._network_name)
3265
return 'Remote: ' + real_format.get_format_description()
3266
2600
return 'bzr remote bzrdir'
3268
def get_format_string(self):
3269
raise NotImplementedError(self.get_format_string)
3271
def network_name(self):
3272
if self._network_name:
3273
return self._network_name
3275
raise AssertionError("No network name set.")
3278
2603
def probe_transport(klass, transport):
3279
2604
"""Return a RemoteBzrDirFormat object if it looks possible."""
3308
2633
return local_dir_format.initialize_on_transport(transport)
3309
2634
client = _SmartClient(client_medium)
3310
2635
path = client.remote_path_from_transport(transport)
3312
response = client.call('BzrDirFormat.initialize', path)
3313
except errors.ErrorFromSmartServer, err:
3314
remote._translate_error(err, path=path)
2636
response = client.call('BzrDirFormat.initialize', path)
3315
2637
if response[0] != 'ok':
3316
2638
raise errors.SmartProtocolError('unexpected response code %s' % (response,))
3317
format = RemoteBzrDirFormat()
3318
self._supply_sub_formats_to(format)
3319
return remote.RemoteBzrDir(transport, format)
3321
def parse_NoneTrueFalse(self, arg):
3328
raise AssertionError("invalid arg %r" % arg)
3330
def _serialize_NoneTrueFalse(self, arg):
3337
def _serialize_NoneString(self, arg):
3340
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
3341
create_prefix=False, force_new_repo=False, stacked_on=None,
3342
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
3345
# hand off the request to the smart server
3346
client_medium = transport.get_smart_medium()
3347
except errors.NoSmartMedium:
3350
# Decline to open it if the server doesn't support our required
3351
# version (3) so that the VFS-based transport will do it.
3352
if client_medium.should_probe():
3354
server_version = client_medium.protocol_version()
3355
if server_version != '2':
3359
except errors.SmartProtocolError:
3360
# Apparently there's no usable smart server there, even though
3361
# the medium supports the smart protocol.
3366
client = _SmartClient(client_medium)
3367
path = client.remote_path_from_transport(transport)
3368
if client_medium._is_remote_before((1, 16)):
3371
# TODO: lookup the local format from a server hint.
3372
local_dir_format = BzrDirMetaFormat1()
3373
self._supply_sub_formats_to(local_dir_format)
3374
return local_dir_format.initialize_on_transport_ex(transport,
3375
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3376
force_new_repo=force_new_repo, stacked_on=stacked_on,
3377
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3378
make_working_trees=make_working_trees, shared_repo=shared_repo,
3380
return self._initialize_on_transport_ex_rpc(client, path, transport,
3381
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3382
stack_on_pwd, repo_format_name, make_working_trees, shared_repo)
3384
def _initialize_on_transport_ex_rpc(self, client, path, transport,
3385
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3386
stack_on_pwd, repo_format_name, make_working_trees, shared_repo):
3388
args.append(self._serialize_NoneTrueFalse(use_existing_dir))
3389
args.append(self._serialize_NoneTrueFalse(create_prefix))
3390
args.append(self._serialize_NoneTrueFalse(force_new_repo))
3391
args.append(self._serialize_NoneString(stacked_on))
3392
# stack_on_pwd is often/usually our transport
3395
stack_on_pwd = transport.relpath(stack_on_pwd)
3396
if not stack_on_pwd:
3398
except errors.PathNotChild:
3400
args.append(self._serialize_NoneString(stack_on_pwd))
3401
args.append(self._serialize_NoneString(repo_format_name))
3402
args.append(self._serialize_NoneTrueFalse(make_working_trees))
3403
args.append(self._serialize_NoneTrueFalse(shared_repo))
3404
request_network_name = self._network_name or \
3405
BzrDirFormat.get_default_format().network_name()
3407
response = client.call('BzrDirFormat.initialize_ex_1.16',
3408
request_network_name, path, *args)
3409
except errors.UnknownSmartMethod:
3410
client._medium._remember_remote_is_before((1,16))
3411
local_dir_format = BzrDirMetaFormat1()
3412
self._supply_sub_formats_to(local_dir_format)
3413
return local_dir_format.initialize_on_transport_ex(transport,
3414
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3415
force_new_repo=force_new_repo, stacked_on=stacked_on,
3416
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3417
make_working_trees=make_working_trees, shared_repo=shared_repo,
3419
except errors.ErrorFromSmartServer, err:
3420
remote._translate_error(err, path=path)
3421
repo_path = response[0]
3422
bzrdir_name = response[6]
3423
require_stacking = response[7]
3424
require_stacking = self.parse_NoneTrueFalse(require_stacking)
3425
format = RemoteBzrDirFormat()
3426
format._network_name = bzrdir_name
3427
self._supply_sub_formats_to(format)
3428
bzrdir = remote.RemoteBzrDir(transport, format, _client=client)
3430
repo_format = remote.response_tuple_to_repo_format(response[1:])
3431
if repo_path == '.':
3434
repo_bzrdir_format = RemoteBzrDirFormat()
3435
repo_bzrdir_format._network_name = response[5]
3436
repo_bzr = remote.RemoteBzrDir(transport.clone(repo_path),
3440
final_stack = response[8] or None
3441
final_stack_pwd = response[9] or None
3443
final_stack_pwd = urlutils.join(
3444
transport.base, final_stack_pwd)
3445
remote_repo = remote.RemoteRepository(repo_bzr, repo_format)
3446
if len(response) > 10:
3447
# Updated server verb that locks remotely.
3448
repo_lock_token = response[10] or None
3449
remote_repo.lock_write(repo_lock_token, _skip_rpc=True)
3451
remote_repo.dont_leave_lock_in_place()
3453
remote_repo.lock_write()
3454
policy = UseExistingRepository(remote_repo, final_stack,
3455
final_stack_pwd, require_stacking)
3456
policy.acquire_repository()
3460
bzrdir._format.set_branch_format(self.get_branch_format())
3461
if require_stacking:
3462
# The repo has already been created, but we need to make sure that
3463
# we'll make a stackable branch.
3464
bzrdir._format.require_stacking(_skip_repo=True)
3465
return remote_repo, bzrdir, require_stacking, policy
2639
return remote.RemoteBzrDir(transport)
3467
2641
def _open(self, transport):
3468
return remote.RemoteBzrDir(transport, self)
2642
return remote.RemoteBzrDir(transport)
3470
2644
def __eq__(self, other):
3471
2645
if not isinstance(other, RemoteBzrDirFormat):
3473
2647
return self.get_format_description() == other.get_format_description()
3475
def __return_repository_format(self):
3476
# Always return a RemoteRepositoryFormat object, but if a specific bzr
3477
# repository format has been asked for, tell the RemoteRepositoryFormat
3478
# that it should use that for init() etc.
3479
result = remote.RemoteRepositoryFormat()
3480
custom_format = getattr(self, '_repository_format', None)
3482
if isinstance(custom_format, remote.RemoteRepositoryFormat):
3483
return custom_format
3485
# We will use the custom format to create repositories over the
3486
# wire; expose its details like rich_root_data for code to
3488
result._custom_format = custom_format
3491
def get_branch_format(self):
3492
result = BzrDirMetaFormat1.get_branch_format(self)
3493
if not isinstance(result, remote.RemoteBranchFormat):
3494
new_result = remote.RemoteBranchFormat()
3495
new_result._custom_format = result
3497
self.set_branch_format(new_result)
3501
repository_format = property(__return_repository_format,
3502
BzrDirMetaFormat1._set_repository_format) #.im_func)
3505
2650
BzrDirFormat.register_control_server_format(RemoteBzrDirFormat)
3838
2946
def acquire_repository(self, make_working_trees=None, shared=False):
3839
2947
"""Implementation of RepositoryAcquisitionPolicy.acquire_repository
3841
Returns an existing repository to use.
2949
Returns an existing repository to use
3843
self._add_fallback(self._repository,
3844
possible_transports=[self._repository.bzrdir.transport])
3845
return self._repository, False
3848
# Please register new formats after old formats so that formats
3849
# appear in chronological order and format descriptions can build
2951
self._add_fallback(self._repository)
2952
return self._repository
3851
2955
format_registry = BzrDirFormatRegistry()
3852
# The pre-0.8 formats have their repository format network name registered in
3853
# repository.py. MetaDir formats have their repository format network name
3854
# inferred from their disk format string.
3855
2956
format_registry.register('weave', BzrDirFormat6,
3856
2957
'Pre-0.8 format. Slower than knit and does not'
3857
2958
' support checkouts or shared repositories.',
3859
2959
deprecated=True)
2960
format_registry.register_metadir('knit',
2961
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
2962
'Format using knits. Recommended for interoperation with bzr <= 0.14.',
2963
branch_format='bzrlib.branch.BzrBranchFormat5',
2964
tree_format='bzrlib.workingtree.WorkingTreeFormat3')
3860
2965
format_registry.register_metadir('metaweave',
3861
2966
'bzrlib.repofmt.weaverepo.RepositoryFormat7',
3862
2967
'Transitional format in 0.8. Slower than knit.',
3863
2968
branch_format='bzrlib.branch.BzrBranchFormat5',
3864
2969
tree_format='bzrlib.workingtree.WorkingTreeFormat3',
3867
format_registry.register_metadir('knit',
3868
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3869
'Format using knits. Recommended for interoperation with bzr <= 0.14.',
3870
branch_format='bzrlib.branch.BzrBranchFormat5',
3871
tree_format='bzrlib.workingtree.WorkingTreeFormat3',
3873
2970
deprecated=True)
3874
2971
format_registry.register_metadir('dirstate',
3875
2972
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3931
3029
format_registry.register_metadir('rich-root-pack',
3932
3030
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack4',
3933
help='New in 1.0: A variant of pack-0.92 that supports rich-root data '
3934
'(needed for bzr-svn and bzr-git).',
3031
help='New in 1.0: Pack-based format with data compatible with '
3032
'rich-root format repositories. Incompatible with'
3935
3034
branch_format='bzrlib.branch.BzrBranchFormat6',
3936
3035
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3939
3037
format_registry.register_metadir('1.6',
3940
3038
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5',
3941
help='A format that allows a branch to indicate that there is another '
3942
'(stacked) repository that should be used to access data that is '
3943
'not present locally.',
3039
help='A branch and pack based repository that supports stacking. ',
3944
3040
branch_format='bzrlib.branch.BzrBranchFormat7',
3945
3041
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3948
3043
format_registry.register_metadir('1.6.1-rich-root',
3949
3044
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5RichRoot',
3950
help='A variant of 1.6 that supports rich-root data '
3951
'(needed for bzr-svn and bzr-git).',
3952
branch_format='bzrlib.branch.BzrBranchFormat7',
3953
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3956
format_registry.register_metadir('1.9',
3957
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
3958
help='A repository format using B+tree indexes. These indexes '
3959
'are smaller in size, have smarter caching and provide faster '
3960
'performance for most operations.',
3961
branch_format='bzrlib.branch.BzrBranchFormat7',
3962
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3965
format_registry.register_metadir('1.9-rich-root',
3966
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
3967
help='A variant of 1.9 that supports rich-root data '
3968
'(needed for bzr-svn and bzr-git).',
3969
branch_format='bzrlib.branch.BzrBranchFormat7',
3970
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3973
format_registry.register_metadir('1.14',
3974
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
3975
help='A working-tree format that supports content filtering.',
3976
branch_format='bzrlib.branch.BzrBranchFormat7',
3977
tree_format='bzrlib.workingtree.WorkingTreeFormat5',
3979
format_registry.register_metadir('1.14-rich-root',
3980
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
3981
help='A variant of 1.14 that supports rich-root data '
3982
'(needed for bzr-svn and bzr-git).',
3983
branch_format='bzrlib.branch.BzrBranchFormat7',
3984
tree_format='bzrlib.workingtree.WorkingTreeFormat5',
3986
# The following un-numbered 'development' formats should always just be aliases.
3987
format_registry.register_metadir('development-rich-root',
3988
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
3989
help='Current development format. Supports rich roots. Can convert data '
3990
'to and from rich-root-pack (and anything compatible with '
3991
'rich-root-pack) format repositories. Repositories and branches in '
3992
'this format can only be read by bzr.dev. Please read '
3993
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
3045
help='A branch and pack based repository that supports stacking '
3046
'and rich root data (needed for bzr-svn). ',
3047
branch_format='bzrlib.branch.BzrBranchFormat7',
3048
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3050
# The following two formats should always just be aliases.
3051
format_registry.register_metadir('development',
3052
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment2',
3053
help='Current development format. Can convert data to and from pack-0.92 '
3054
'(and anything compatible with pack-0.92) format repositories. '
3055
'Repositories and branches in this format can only be read by bzr.dev. '
3057
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3995
3059
branch_format='bzrlib.branch.BzrBranchFormat7',
3996
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3060
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3997
3061
experimental=True,
4001
3064
format_registry.register_metadir('development-subtree',
4002
3065
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment2Subtree',
4004
3067
'from pack-0.92-subtree (and anything compatible with '
4005
3068
'pack-0.92-subtree) format repositories. Repositories and branches in '
4006
3069
'this format can only be read by bzr.dev. Please read '
4007
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
3070
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
4009
3072
branch_format='bzrlib.branch.BzrBranchFormat7',
4010
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3073
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
4011
3074
experimental=True,
4013
alias=False, # Restore to being an alias when an actual development subtree format is added
4014
# This current non-alias status is simply because we did not introduce a
4015
# chk based subtree format.
4018
3077
# And the development formats above will have aliased one of the following:
4019
format_registry.register_metadir('development6-rich-root',
4020
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
4021
help='pack-1.9 with 255-way hashed CHK inv, group compress, rich roots '
4023
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
4025
branch_format='bzrlib.branch.BzrBranchFormat7',
4026
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4031
format_registry.register_metadir('development7-rich-root',
4032
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK2',
4033
help='pack-1.9 with 255-way hashed CHK inv, bencode revision, group compress, '
4034
'rich roots. Please read '
4035
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
4037
branch_format='bzrlib.branch.BzrBranchFormat7',
4038
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4043
format_registry.register_metadir('2a',
4044
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
4045
help='First format for bzr 2.0 series.\n'
4046
'Uses group-compress storage.\n'
4047
'Provides rich roots which are a one-way transition.\n',
4048
# 'storage in packs, 255-way hashed CHK inventory, bencode revision, group compress, '
4049
# 'rich roots. Supported by bzr 1.16 and later.',
4050
branch_format='bzrlib.branch.BzrBranchFormat7',
4051
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4055
# The following format should be an alias for the rich root equivalent
4056
# of the default format
4057
format_registry.register_metadir('default-rich-root',
4058
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
4059
branch_format='bzrlib.branch.BzrBranchFormat7',
4060
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
3078
format_registry.register_metadir('development2',
3079
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment2',
3080
help='1.6.1 with B+Tree based index. '
3082
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3084
branch_format='bzrlib.branch.BzrBranchFormat7',
3085
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3089
format_registry.register_metadir('development2-subtree',
3090
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment2Subtree',
3091
help='1.6.1-subtree with B+Tree based index. '
3093
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3095
branch_format='bzrlib.branch.BzrBranchFormat7',
3096
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
4065
3100
# The current format that is made on 'bzr init'.
4066
format_registry.set_default('2a')
3101
format_registry.set_default('pack-0.92')