202
156
format.get_format_description(),
205
def clone(self, url, revision_id=None, force_new_repo=False,
206
preserve_stacking=False):
159
def clone(self, url, revision_id=None, force_new_repo=False):
207
160
"""Clone this bzrdir and its contents to url verbatim.
209
:param url: The url create the clone at. If url's last component does
210
not exist, it will be created.
211
:param revision_id: The tip revision-id to use for any branch or
212
working tree. If not None, then the clone operation may tune
162
If url's last component does not exist, it will be created.
164
if revision_id is not None, then the clone operation may tune
213
165
itself to download less data.
214
:param force_new_repo: Do not use a shared repository for the target
166
:param force_new_repo: Do not use a shared repository for the target
215
167
even if one is available.
216
:param preserve_stacking: When cloning a stacked branch, stack the
217
new branch on top of the other branch's stacked-on branch.
219
169
return self.clone_on_transport(get_transport(url),
220
170
revision_id=revision_id,
221
force_new_repo=force_new_repo,
222
preserve_stacking=preserve_stacking)
171
force_new_repo=force_new_repo)
224
173
def clone_on_transport(self, transport, revision_id=None,
225
force_new_repo=False, preserve_stacking=False, stacked_on=None,
226
create_prefix=False, use_existing_dir=True):
174
force_new_repo=False):
227
175
"""Clone this bzrdir and its contents to transport verbatim.
229
:param transport: The transport for the location to produce the clone
230
at. If the target directory does not exist, it will be created.
231
:param revision_id: The tip revision-id to use for any branch or
232
working tree. If not None, then the clone operation may tune
177
If the target directory does not exist, it will be created.
179
if revision_id is not None, then the clone operation may tune
233
180
itself to download less data.
234
:param force_new_repo: Do not use a shared repository for the target,
181
:param force_new_repo: Do not use a shared repository for the target
235
182
even if one is available.
236
:param preserve_stacking: When cloning a stacked branch, stack the
237
new branch on top of the other branch's stacked-on branch.
238
:param create_prefix: Create any missing directories leading up to
240
:param use_existing_dir: Use an existing directory if one exists.
242
# Overview: put together a broad description of what we want to end up
243
# with; then make as few api calls as possible to do it.
245
# We may want to create a repo/branch/tree, if we do so what format
246
# would we want for each:
247
require_stacking = (stacked_on is not None)
248
format = self.cloning_metadir(require_stacking)
250
# Figure out what objects we want:
184
transport.ensure_base()
185
result = self.cloning_metadir().initialize_on_transport(transport)
186
repository_policy = None
252
188
local_repo = self.find_repository()
253
189
except errors.NoRepositoryPresent:
254
190
local_repo = None
256
local_branch = self.open_branch()
257
except errors.NotBranchError:
260
# enable fallbacks when branch is not a branch reference
261
if local_branch.repository.has_same_location(local_repo):
262
local_repo = local_branch.repository
263
if preserve_stacking:
265
stacked_on = local_branch.get_stacked_on_url()
266
except (errors.UnstackableBranchFormat,
267
errors.UnstackableRepositoryFormat,
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,
192
# may need to copy content in
193
repository_policy = result.determine_repository_policy(
274
195
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)
196
result_repo = repository_policy.acquire_repository(
197
make_working_trees, local_repo.is_shared())
198
result_repo.fetch(local_repo, revision_id=revision_id)
310
199
# 1 if there is a branch present
311
200
# make sure its content is available in the target repository
313
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():
203
local_branch = self.open_branch()
204
except errors.NotBranchError:
207
result_branch = local_branch.clone(result, revision_id=revision_id)
208
if repository_policy is not None:
209
repository_policy.configure_branch(result_branch)
211
result_repo = result.find_repository()
212
except errors.NoRepositoryPresent:
214
if result_repo is None or result_repo.make_working_trees():
321
216
self.open_workingtree().clone(result)
322
except (errors.NoWorkingTree, errors.NotLocalUrl):
217
except (errors.NoWorkingTree, errors.NotLocalUrl):
326
221
# TODO: This should be given a Transport, and should chdir up; otherwise
414
300
except errors.NoRepositoryPresent:
417
return False, ([], repository)
418
return True, (bzrdir.list_branches(), None)
420
for branches, repo in BzrDir.find_bzrdirs(transport,
303
return False, (None, repository)
305
branch = bzrdir.open_branch()
306
except errors.NotBranchError:
307
return True, (None, None)
309
return True, (branch, None)
311
for branch, repo in BzrDir.find_bzrdirs(transport, evaluate=evaluate):
422
312
if repo is not None:
423
ret.extend(repo.find_branches())
424
if branches is not None:
313
branches.extend(repo.find_branches())
314
if branch is not None:
315
branches.append(branch)
428
318
def destroy_repository(self):
429
319
"""Destroy the repository in this BzrDir"""
430
320
raise NotImplementedError(self.destroy_repository)
432
def create_branch(self, name=None):
322
def create_branch(self):
433
323
"""Create a branch in this BzrDir.
435
:param name: Name of the colocated branch to create, None for
438
325
The bzrdir's format will control what branch format is created.
439
326
For more control see BranchFormatXX.create(a_bzrdir).
441
328
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
330
def destroy_branch(self):
331
"""Destroy the branch in this BzrDir"""
449
332
raise NotImplementedError(self.destroy_branch)
469
352
bzrdir._find_or_create_repository(force_new_repo)
470
353
return bzrdir.create_branch()
472
def determine_repository_policy(self, force_new_repo=False, stack_on=None,
473
stack_on_pwd=None, require_stacking=False):
355
def determine_repository_policy(self, force_new_repo=False):
474
356
"""Return an object representing a policy to use.
476
This controls whether a new repository is created, and the format of
477
that repository, or some existing shared repository used instead.
479
If stack_on is supplied, will not seek a containing shared repo.
481
:param force_new_repo: If True, require a new repository to be created.
482
:param stack_on: If supplied, the location to stack on. If not
483
supplied, a default_stack_on location may be used.
484
:param stack_on_pwd: If stack_on is relative, the location it is
358
This controls whether a new repository is created, or a shared
359
repository used instead.
487
361
def repository_policy(found_bzrdir):
490
config = found_bzrdir.get_config()
492
stack_on = config.get_default_stack_on()
493
if stack_on is not None:
494
stack_on_pwd = found_bzrdir.user_url
496
363
# does it have a repository ?
498
365
repository = found_bzrdir.open_repository()
499
366
except errors.NoRepositoryPresent:
500
367
repository = None
502
if (found_bzrdir.user_url != self.user_url
503
and not repository.is_shared()):
504
# Don't look higher, can't use a higher shared repo.
369
if ((found_bzrdir.root_transport.base !=
370
self.root_transport.base) and not repository.is_shared()):
505
371
repository = None
510
375
return None, False
512
return UseExistingRepository(repository, stack_on,
513
stack_on_pwd, require_stacking=require_stacking), True
377
return UseExistingRepository(repository), True
515
return CreateRepository(self, stack_on, stack_on_pwd,
516
require_stacking=require_stacking), True
379
return CreateRepository(self), True
518
381
if not force_new_repo:
520
policy = self._find_containing(repository_policy)
521
if policy is not None:
525
return UseExistingRepository(self.open_repository(),
526
stack_on, stack_on_pwd,
527
require_stacking=require_stacking)
528
except errors.NoRepositoryPresent:
530
return CreateRepository(self, stack_on, stack_on_pwd,
531
require_stacking=require_stacking)
382
policy = self._find_containing(repository_policy)
383
if policy is not None:
385
return CreateRepository(self)
533
387
def _find_or_create_repository(self, force_new_repo):
534
388
"""Create a new repository if needed, returning the repository."""
535
389
policy = self.determine_repository_policy(force_new_repo)
536
return policy.acquire_repository()[0]
390
return policy.acquire_repository()
539
393
def create_branch_convenience(base, force_new_repo=False,
918
716
:param transport: Transport containing the bzrdir.
919
717
:param _unsupported: private.
921
for hook in BzrDir.hooks['pre_open']:
923
# Keep initial base since 'transport' may be modified while following
925
719
base = transport.base
926
721
def find_format(transport):
927
722
return transport, BzrDirFormat.find_format(
928
723
transport, _server_formats=_server_formats)
930
725
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)
726
qualified_source = e.get_source_url()
727
relpath = transport.relpath(qualified_source)
728
if not e.target.endswith(relpath):
729
# Not redirected to a branch-format, not a branch
730
raise errors.NotBranchError(path=e.target)
731
target = e.target[:-len(relpath)]
934
732
note('%s is%s redirected to %s',
935
transport.base, e.permanently, redirected_transport.base)
936
return redirected_transport
733
transport.base, e.permanently, target)
734
# Let's try with a new transport
735
# FIXME: If 'transport' has a qualifier, this should
736
# be applied again to the new transport *iff* the
737
# schemes used are the same. Uncomment this code
738
# once the function (and tests) exist.
740
#target = urlutils.copy_url_qualifiers(original, target)
741
return get_transport(target)
939
744
transport, format = do_catching_redirections(find_format,
1212
992
content is different.
1213
993
:param hardlink: If true, hard-link files from accelerator_tree,
1215
:param stacked: If true, create a stacked branch referring to the
1216
location of this control directory.
1217
:param create_tree_if_local: If true, a working-tree will be created
1218
when working locally.
1220
996
target_transport = get_transport(url, possible_transports)
1221
997
target_transport.ensure_base()
1222
cloning_format = self.cloning_metadir(stacked)
1223
# Create/update the result branch
998
cloning_format = self.cloning_metadir()
1224
999
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:
1230
stacked_branch_url = self.root_transport.base
1001
source_branch = self.open_branch()
1231
1002
source_repository = source_branch.repository
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
1244
repository_policy = result.determine_repository_policy(
1245
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)
1252
if source_repository is not None:
1253
# Fetch while stacked to prevent unstacked fetch from
1255
if fetch_spec is None:
1003
except errors.NotBranchError:
1004
source_branch = None
1006
source_repository = self.open_repository()
1007
except errors.NoRepositoryPresent:
1008
source_repository = None
1013
result_repo = result.find_repository()
1014
except errors.NoRepositoryPresent:
1016
if source_repository is None and result_repo is not None:
1018
elif source_repository is None and result_repo is None:
1019
# no repo available, make a new one
1020
result.create_repository()
1021
elif source_repository is not None and result_repo is None:
1022
# have source, and want to make a new target repo
1023
result_repo = source_repository.sprout(result,
1024
revision_id=revision_id)
1026
# fetch needed content into target.
1027
if source_repository is not None:
1029
# source_repository.copy_content_into(result_repo,
1030
# revision_id=revision_id)
1031
# so we can override the copy method
1256
1032
result_repo.fetch(source_repository, revision_id=revision_id)
1258
result_repo.fetch(source_repository, fetch_spec=fetch_spec)
1260
if source_branch is None:
1261
# this is for sprouting a bzrdir without a branch; is that
1263
# Not especially, but it's part of the contract.
1264
result_branch = result.create_branch()
1033
if source_branch is not None:
1034
source_branch.sprout(result, revision_id=revision_id)
1266
result_branch = source_branch.sprout(result,
1267
revision_id=revision_id, repository_policy=repository_policy)
1268
mutter("created new branch %r" % (result_branch,))
1270
# Create/update the result working tree
1271
if (create_tree_if_local and
1272
isinstance(target_transport, local.LocalTransport) and
1273
(result_repo is None or result_repo.make_working_trees())):
1036
result.create_branch()
1037
if isinstance(target_transport, LocalTransport) and (
1038
result_repo is None or result_repo.make_working_trees()):
1274
1039
wt = result.create_workingtree(accelerator_tree=accelerator_tree,
1275
1040
hardlink=hardlink)
1276
1041
wt.lock_write()
1306
1069
sublocation = source_branch.reference_parent(file_id, path)
1307
1070
sublocation.bzrdir.sprout(target,
1308
1071
basis.get_reference_revision(file_id, path),
1309
force_new_repo=force_new_repo, recurse=recurse,
1072
force_new_repo=force_new_repo, recurse=recurse)
1312
1074
if basis is not None:
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
1079
class BzrDirPreSplitOut(BzrDir):
1433
1080
"""A common class for the all-in-one formats."""
1444
1091
"""Pre-splitout bzrdirs do not suffer from stale locks."""
1445
1092
raise NotImplementedError(self.break_lock)
1447
def cloning_metadir(self, require_stacking=False):
1094
def cloning_metadir(self):
1448
1095
"""Produce a metadir suitable for cloning with."""
1449
if require_stacking:
1450
return format_registry.make_bzrdir('1.6')
1451
1096
return self._format.__class__()
1453
def clone(self, url, revision_id=None, force_new_repo=False,
1454
preserve_stacking=False):
1455
"""See BzrDir.clone().
1457
force_new_repo has no effect, since this family of formats always
1458
require a new repository.
1459
preserve_stacking has no effect, since no source branch using this
1460
family of formats can be stacked, so there is no stacking to preserve.
1098
def clone(self, url, revision_id=None, force_new_repo=False):
1099
"""See BzrDir.clone()."""
1100
from bzrlib.workingtree import WorkingTreeFormat2
1462
1101
self._make_tail(url)
1463
1102
result = self._format._initialize_for_clone(url)
1464
1103
self.open_repository().clone(result, revision_id=revision_id)
1465
1104
from_branch = self.open_branch()
1466
1105
from_branch.clone(result, revision_id=revision_id)
1468
tree = self.open_workingtree()
1107
self.open_workingtree().clone(result)
1469
1108
except errors.NotLocalUrl:
1470
1109
# make a new one, this format always has to have one.
1471
result._init_workingtree()
1111
WorkingTreeFormat2().initialize(result)
1112
except errors.NotLocalUrl:
1113
# but we cannot do it for remote trees.
1114
to_branch = result.open_branch()
1115
WorkingTreeFormat2()._stub_initialize_remote(to_branch)
1476
def create_branch(self, name=None):
1118
def create_branch(self):
1477
1119
"""See BzrDir.create_branch."""
1478
return self._format.get_branch_format().initialize(self, name=name)
1120
return self.open_branch()
1480
def destroy_branch(self, name=None):
1122
def destroy_branch(self):
1481
1123
"""See BzrDir.destroy_branch."""
1482
1124
raise errors.UnsupportedOperation(self.destroy_branch, self)
1576
1197
# if the format is not the same as the system default,
1577
1198
# an upgrade is needed.
1578
1199
if format is None:
1579
symbol_versioning.warn(symbol_versioning.deprecated_in((1, 13, 0))
1580
% 'needs_format_conversion(format=None)')
1581
1200
format = BzrDirFormat.get_default_format()
1582
1201
return not isinstance(self._format, format.__class__)
1584
def open_branch(self, name=None, unsupported=False,
1585
ignore_fallbacks=False):
1203
def open_branch(self, unsupported=False):
1586
1204
"""See BzrDir.open_branch."""
1587
1205
from bzrlib.branch import BzrBranchFormat4
1588
1206
format = BzrBranchFormat4()
1589
1207
self._check_supported(format, unsupported)
1590
return format.open(self, name, _found=True)
1208
return format.open(self, _found=True)
1592
1210
def sprout(self, url, revision_id=None, force_new_repo=False,
1593
1211
possible_transports=None, accelerator_tree=None,
1594
hardlink=False, stacked=False, create_tree_if_local=True,
1595
source_branch=None):
1596
1213
"""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
raise errors.UnstackableBranchFormat(
1605
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
1214
from bzrlib.workingtree import WorkingTreeFormat2
1610
1215
self._make_tail(url)
1611
1216
result = self._format._initialize_for_clone(url)
2007
1562
def initialize_on_transport(self, transport):
2008
1563
"""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
1564
# Since we don't have a .bzr directory, inherit the
2129
1565
# mode from the root directory
2130
1566
temp_control = lockable_files.LockableFiles(transport,
2131
1567
'', lockable_files.TransportLock)
2336
1742
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):
1745
class BzrDirFormat5(BzrDirFormat):
2365
1746
"""Bzr control format 5.
2367
1748
This format is a combined format for working tree, branch and repository.
2369
- Format 2 working trees [always]
2370
- Format 4 branches [always]
1750
- Format 2 working trees [always]
1751
- Format 4 branches [always]
2371
1752
- Format 5 repositories [always]
2372
1753
Unhashed stores in the repository.
2442
1822
"""See BzrDirFormat.get_format_description()."""
2443
1823
return "All-in-one format 6"
2445
def get_branch_format(self):
2446
from bzrlib import branch
2447
return branch.BzrBranchFormat4()
2449
1825
def get_converter(self, format=None):
2450
1826
"""See BzrDirFormat.get_converter()."""
2451
1827
# there is one and only one upgrade path here.
2452
1828
return ConvertBzrDir6ToMeta()
2454
1830
def _initialize_for_clone(self, url):
2455
1831
return self.initialize_on_transport(get_transport(url), _cloning=True)
2457
1833
def initialize_on_transport(self, transport, _cloning=False):
2458
1834
"""Format 6 dirs always have working tree, branch and repository.
2460
1836
Except when they are being cloned.
2462
1838
from bzrlib.branch import BzrBranchFormat4
2463
1839
from bzrlib.repofmt.weaverepo import RepositoryFormat6
1840
from bzrlib.workingtree import WorkingTreeFormat2
2464
1841
result = super(BzrDirFormat6, self).initialize_on_transport(transport)
2465
1842
RepositoryFormat6().initialize(result, _internal=True)
2466
1843
if not _cloning:
2467
1844
branch = BzrBranchFormat4().initialize(result)
2468
result._init_workingtree()
1846
WorkingTreeFormat2().initialize(result)
1847
except errors.NotLocalUrl:
1848
# Even though we can't access the working tree, we need to
1849
# create its control files.
1850
WorkingTreeFormat2()._stub_initialize_remote(branch)
2471
def network_name(self):
2472
return self.get_format_string()
2474
1853
def _open(self, transport):
2475
1854
"""See BzrDirFormat._open."""
2476
1855
return BzrDir6(transport, self)
2521
1899
def set_branch_format(self, format):
2522
1900
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
1902
def get_converter(self, format=None):
2617
1903
"""See BzrDirFormat.get_converter()."""
2618
1904
if format is None:
2630
1916
"""See BzrDirFormat.get_format_description()."""
2631
1917
return "Meta directory format 1"
2633
def network_name(self):
2634
return self.get_format_string()
2636
1919
def _open(self, transport):
2637
1920
"""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)
1921
return BzrDirMeta1(transport, self)
2645
1923
def __return_repository_format(self):
2646
1924
"""Circular import protection."""
2647
if self._repository_format:
1925
if getattr(self, '_repository_format', None):
2648
1926
return self._repository_format
2649
1927
from bzrlib.repository import RepositoryFormat
2650
1928
return RepositoryFormat.get_default_format()
2652
def _set_repository_format(self, value):
1930
def __set_repository_format(self, value):
2653
1931
"""Allow changing the repository format for metadir formats."""
2654
1932
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
1934
repository_format = property(__return_repository_format, __set_repository_format)
2677
1936
def __get_workingtree_format(self):
2678
1937
if self._workingtree_format is None:
3179
2425
if not isinstance(repo._format, self.target_format.repository_format.__class__):
3180
2426
from bzrlib.repository import CopyConverter
3181
ui.ui_factory.note('starting repository conversion')
2427
self.pb.note('starting repository conversion')
3182
2428
converter = CopyConverter(self.target_format.repository_format)
3183
2429
converter.convert(repo, pb)
3184
for branch in self.bzrdir.list_branches():
2431
branch = self.bzrdir.open_branch()
2432
except errors.NotBranchError:
3185
2435
# TODO: conversions of Branch and Tree should be done by
3186
# InterXFormat lookups/some sort of registry.
2436
# InterXFormat lookups
3187
2437
# Avoid circular imports
3188
2438
from bzrlib import branch as _mod_branch
3189
old = branch._format.__class__
3190
new = self.target_format.get_branch_format().__class__
3192
if (old == _mod_branch.BzrBranchFormat5 and
3193
new in (_mod_branch.BzrBranchFormat6,
3194
_mod_branch.BzrBranchFormat7,
3195
_mod_branch.BzrBranchFormat8)):
3196
branch_converter = _mod_branch.Converter5to6()
3197
elif (old == _mod_branch.BzrBranchFormat6 and
3198
new in (_mod_branch.BzrBranchFormat7,
3199
_mod_branch.BzrBranchFormat8)):
3200
branch_converter = _mod_branch.Converter6to7()
3201
elif (old == _mod_branch.BzrBranchFormat7 and
3202
new is _mod_branch.BzrBranchFormat8):
3203
branch_converter = _mod_branch.Converter7to8()
3205
raise errors.BadConversionTarget("No converter", new,
2439
if (branch._format.__class__ is _mod_branch.BzrBranchFormat5 and
2440
self.target_format.get_branch_format().__class__ is
2441
_mod_branch.BzrBranchFormat6):
2442
branch_converter = _mod_branch.Converter5to6()
3207
2443
branch_converter.convert(branch)
3208
branch = self.bzrdir.open_branch()
3209
old = branch._format.__class__
3211
2445
tree = self.bzrdir.open_workingtree(recommend_upgrade=False)
3212
2446
except (errors.NoWorkingTree, errors.NotLocalUrl):
3215
2449
# TODO: conversions of Branch and Tree should be done by
3216
2450
# InterXFormat lookups
3217
2451
if (isinstance(tree, workingtree.WorkingTree3) and
3218
not isinstance(tree, workingtree_4.DirStateWorkingTree) and
2452
not isinstance(tree, workingtree_4.WorkingTree4) and
3219
2453
isinstance(self.target_format.workingtree_format,
3220
workingtree_4.DirStateWorkingTreeFormat)):
2454
workingtree_4.WorkingTreeFormat4)):
3221
2455
workingtree_4.Converter3to4().convert(tree)
3222
if (isinstance(tree, workingtree_4.DirStateWorkingTree) and
3223
not isinstance(tree, workingtree_4.WorkingTree5) and
3224
isinstance(self.target_format.workingtree_format,
3225
workingtree_4.WorkingTreeFormat5)):
3226
workingtree_4.Converter4to5().convert(tree)
3227
if (isinstance(tree, workingtree_4.DirStateWorkingTree) and
3228
not isinstance(tree, workingtree_4.WorkingTree6) and
3229
isinstance(self.target_format.workingtree_format,
3230
workingtree_4.WorkingTreeFormat6)):
3231
workingtree_4.Converter4or5to6().convert(tree)
3233
2456
return to_convert
3236
# This is not in remote.py because it's relatively small, and needs to be
3237
# registered. Putting it in remote.py creates a circular import problem.
2459
# This is not in remote.py because it's small, and needs to be registered.
2460
# Putting it in remote.py creates a circular import problem.
3238
2461
# we can make it a lazy object if the control formats is turned into something
3239
2462
# like a registry.
3240
2463
class RemoteBzrDirFormat(BzrDirMetaFormat1):
3241
2464
"""Format representing bzrdirs accessed via a smart server"""
3244
BzrDirMetaFormat1.__init__(self)
3245
# XXX: It's a bit ugly that the network name is here, because we'd
3246
# like to believe that format objects are stateless or at least
3247
# immutable, However, we do at least avoid mutating the name after
3248
# it's returned. See <https://bugs.edge.launchpad.net/bzr/+bug/504102>
3249
self._network_name = None
3252
return "%s(_network_name=%r)" % (self.__class__.__name__,
3255
2466
def get_format_description(self):
3256
if self._network_name:
3257
real_format = network_format_registry.get(self._network_name)
3258
return 'Remote: ' + real_format.get_format_description()
3259
2467
return 'bzr remote bzrdir'
3261
def get_format_string(self):
3262
raise NotImplementedError(self.get_format_string)
3264
def network_name(self):
3265
if self._network_name:
3266
return self._network_name
3268
raise AssertionError("No network name set.")
3271
2470
def probe_transport(klass, transport):
3272
2471
"""Return a RemoteBzrDirFormat object if it looks possible."""
3301
2500
return local_dir_format.initialize_on_transport(transport)
3302
2501
client = _SmartClient(client_medium)
3303
2502
path = client.remote_path_from_transport(transport)
3305
response = client.call('BzrDirFormat.initialize', path)
3306
except errors.ErrorFromSmartServer, err:
3307
remote._translate_error(err, path=path)
2503
response = client.call('BzrDirFormat.initialize', path)
3308
2504
if response[0] != 'ok':
3309
2505
raise errors.SmartProtocolError('unexpected response code %s' % (response,))
3310
format = RemoteBzrDirFormat()
3311
self._supply_sub_formats_to(format)
3312
return remote.RemoteBzrDir(transport, format)
3314
def parse_NoneTrueFalse(self, arg):
3321
raise AssertionError("invalid arg %r" % arg)
3323
def _serialize_NoneTrueFalse(self, arg):
3330
def _serialize_NoneString(self, arg):
3333
def initialize_on_transport_ex(self, transport, use_existing_dir=False,
3334
create_prefix=False, force_new_repo=False, stacked_on=None,
3335
stack_on_pwd=None, repo_format_name=None, make_working_trees=None,
3338
# hand off the request to the smart server
3339
client_medium = transport.get_smart_medium()
3340
except errors.NoSmartMedium:
3343
# Decline to open it if the server doesn't support our required
3344
# version (3) so that the VFS-based transport will do it.
3345
if client_medium.should_probe():
3347
server_version = client_medium.protocol_version()
3348
if server_version != '2':
3352
except errors.SmartProtocolError:
3353
# Apparently there's no usable smart server there, even though
3354
# the medium supports the smart protocol.
3359
client = _SmartClient(client_medium)
3360
path = client.remote_path_from_transport(transport)
3361
if client_medium._is_remote_before((1, 16)):
3364
# TODO: lookup the local format from a server hint.
3365
local_dir_format = BzrDirMetaFormat1()
3366
self._supply_sub_formats_to(local_dir_format)
3367
return local_dir_format.initialize_on_transport_ex(transport,
3368
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3369
force_new_repo=force_new_repo, stacked_on=stacked_on,
3370
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3371
make_working_trees=make_working_trees, shared_repo=shared_repo,
3373
return self._initialize_on_transport_ex_rpc(client, path, transport,
3374
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3375
stack_on_pwd, repo_format_name, make_working_trees, shared_repo)
3377
def _initialize_on_transport_ex_rpc(self, client, path, transport,
3378
use_existing_dir, create_prefix, force_new_repo, stacked_on,
3379
stack_on_pwd, repo_format_name, make_working_trees, shared_repo):
3381
args.append(self._serialize_NoneTrueFalse(use_existing_dir))
3382
args.append(self._serialize_NoneTrueFalse(create_prefix))
3383
args.append(self._serialize_NoneTrueFalse(force_new_repo))
3384
args.append(self._serialize_NoneString(stacked_on))
3385
# stack_on_pwd is often/usually our transport
3388
stack_on_pwd = transport.relpath(stack_on_pwd)
3389
if not stack_on_pwd:
3391
except errors.PathNotChild:
3393
args.append(self._serialize_NoneString(stack_on_pwd))
3394
args.append(self._serialize_NoneString(repo_format_name))
3395
args.append(self._serialize_NoneTrueFalse(make_working_trees))
3396
args.append(self._serialize_NoneTrueFalse(shared_repo))
3397
request_network_name = self._network_name or \
3398
BzrDirFormat.get_default_format().network_name()
3400
response = client.call('BzrDirFormat.initialize_ex_1.16',
3401
request_network_name, path, *args)
3402
except errors.UnknownSmartMethod:
3403
client._medium._remember_remote_is_before((1,16))
3404
local_dir_format = BzrDirMetaFormat1()
3405
self._supply_sub_formats_to(local_dir_format)
3406
return local_dir_format.initialize_on_transport_ex(transport,
3407
use_existing_dir=use_existing_dir, create_prefix=create_prefix,
3408
force_new_repo=force_new_repo, stacked_on=stacked_on,
3409
stack_on_pwd=stack_on_pwd, repo_format_name=repo_format_name,
3410
make_working_trees=make_working_trees, shared_repo=shared_repo,
3412
except errors.ErrorFromSmartServer, err:
3413
remote._translate_error(err, path=path)
3414
repo_path = response[0]
3415
bzrdir_name = response[6]
3416
require_stacking = response[7]
3417
require_stacking = self.parse_NoneTrueFalse(require_stacking)
3418
format = RemoteBzrDirFormat()
3419
format._network_name = bzrdir_name
3420
self._supply_sub_formats_to(format)
3421
bzrdir = remote.RemoteBzrDir(transport, format, _client=client)
3423
repo_format = remote.response_tuple_to_repo_format(response[1:])
3424
if repo_path == '.':
3427
repo_bzrdir_format = RemoteBzrDirFormat()
3428
repo_bzrdir_format._network_name = response[5]
3429
repo_bzr = remote.RemoteBzrDir(transport.clone(repo_path),
3433
final_stack = response[8] or None
3434
final_stack_pwd = response[9] or None
3436
final_stack_pwd = urlutils.join(
3437
transport.base, final_stack_pwd)
3438
remote_repo = remote.RemoteRepository(repo_bzr, repo_format)
3439
if len(response) > 10:
3440
# Updated server verb that locks remotely.
3441
repo_lock_token = response[10] or None
3442
remote_repo.lock_write(repo_lock_token, _skip_rpc=True)
3444
remote_repo.dont_leave_lock_in_place()
3446
remote_repo.lock_write()
3447
policy = UseExistingRepository(remote_repo, final_stack,
3448
final_stack_pwd, require_stacking)
3449
policy.acquire_repository()
3453
bzrdir._format.set_branch_format(self.get_branch_format())
3454
if require_stacking:
3455
# The repo has already been created, but we need to make sure that
3456
# we'll make a stackable branch.
3457
bzrdir._format.require_stacking(_skip_repo=True)
3458
return remote_repo, bzrdir, require_stacking, policy
2506
return remote.RemoteBzrDir(transport)
3460
2508
def _open(self, transport):
3461
return remote.RemoteBzrDir(transport, self)
2509
return remote.RemoteBzrDir(transport)
3463
2511
def __eq__(self, other):
3464
2512
if not isinstance(other, RemoteBzrDirFormat):
3466
2514
return self.get_format_description() == other.get_format_description()
3468
def __return_repository_format(self):
3469
# Always return a RemoteRepositoryFormat object, but if a specific bzr
3470
# repository format has been asked for, tell the RemoteRepositoryFormat
3471
# that it should use that for init() etc.
3472
result = remote.RemoteRepositoryFormat()
3473
custom_format = getattr(self, '_repository_format', None)
3475
if isinstance(custom_format, remote.RemoteRepositoryFormat):
3476
return custom_format
3478
# We will use the custom format to create repositories over the
3479
# wire; expose its details like rich_root_data for code to
3481
result._custom_format = custom_format
3484
def get_branch_format(self):
3485
result = BzrDirMetaFormat1.get_branch_format(self)
3486
if not isinstance(result, remote.RemoteBranchFormat):
3487
new_result = remote.RemoteBranchFormat()
3488
new_result._custom_format = result
3490
self.set_branch_format(new_result)
3494
repository_format = property(__return_repository_format,
3495
BzrDirMetaFormat1._set_repository_format) #.im_func)
3498
2517
BzrDirFormat.register_control_server_format(RemoteBzrDirFormat)
3688
2694
for a branch that is being created. The most basic policy decision is
3689
2695
whether to create a new repository or use an existing one.
3691
def __init__(self, stack_on, stack_on_pwd, require_stacking):
3694
:param stack_on: A location to stack on
3695
:param stack_on_pwd: If stack_on is relative, the location it is
3697
:param require_stacking: If True, it is a failure to not stack.
3699
self._stack_on = stack_on
3700
self._stack_on_pwd = stack_on_pwd
3701
self._require_stacking = require_stacking
3703
2698
def configure_branch(self, branch):
3704
2699
"""Apply any configuration data from this policy to the branch.
3706
Default implementation sets repository stacking.
2701
Default implementation does nothing.
3708
if self._stack_on is None:
3710
if self._stack_on_pwd is None:
3711
stack_on = self._stack_on
3714
stack_on = urlutils.rebase_url(self._stack_on,
3717
except errors.InvalidRebaseURLs:
3718
stack_on = self._get_full_stack_on()
3720
branch.set_stacked_on_url(stack_on)
3721
except (errors.UnstackableBranchFormat,
3722
errors.UnstackableRepositoryFormat):
3723
if self._require_stacking:
3726
def requires_stacking(self):
3727
"""Return True if this policy requires stacking."""
3728
return self._stack_on is not None and self._require_stacking
3730
def _get_full_stack_on(self):
3731
"""Get a fully-qualified URL for the stack_on location."""
3732
if self._stack_on is None:
3734
if self._stack_on_pwd is None:
3735
return self._stack_on
3737
return urlutils.join(self._stack_on_pwd, self._stack_on)
3739
def _add_fallback(self, repository, possible_transports=None):
3740
"""Add a fallback to the supplied repository, if stacking is set."""
3741
stack_on = self._get_full_stack_on()
3742
if stack_on is None:
3745
stacked_dir = BzrDir.open(stack_on,
3746
possible_transports=possible_transports)
3747
except errors.JailBreak:
3748
# We keep the stacking details, but we are in the server code so
3749
# actually stacking is not needed.
3752
stacked_repo = stacked_dir.open_branch().repository
3753
except errors.NotBranchError:
3754
stacked_repo = stacked_dir.open_repository()
3756
repository.add_fallback_repository(stacked_repo)
3757
except errors.UnstackableRepositoryFormat:
3758
if self._require_stacking:
3761
self._require_stacking = True
3763
2705
def acquire_repository(self, make_working_trees=None, shared=False):
3764
2706
"""Acquire a repository for this bzrdir.
3796
2728
Creates the desired repository in the bzrdir we already have.
3798
stack_on = self._get_full_stack_on()
3800
format = self._bzrdir._format
3801
format.require_stacking(stack_on=stack_on,
3802
possible_transports=[self._bzrdir.root_transport])
3803
if not self._require_stacking:
3804
# We have picked up automatic stacking somewhere.
3805
note('Using default stacking branch %s at %s', self._stack_on,
3807
2730
repository = self._bzrdir.create_repository(shared=shared)
3808
self._add_fallback(repository,
3809
possible_transports=[self._bzrdir.transport])
3810
2731
if make_working_trees is not None:
3811
2732
repository.set_make_working_trees(make_working_trees)
3812
return repository, True
3815
2736
class UseExistingRepository(RepositoryAcquisitionPolicy):
3816
2737
"""A policy of reusing an existing repository"""
3818
def __init__(self, repository, stack_on=None, stack_on_pwd=None,
3819
require_stacking=False):
3822
:param repository: The repository to use.
3823
:param stack_on: A location to stack on
3824
:param stack_on_pwd: If stack_on is relative, the location it is
3827
RepositoryAcquisitionPolicy.__init__(self, stack_on, stack_on_pwd,
2739
def __init__(self, repository):
2740
RepositoryAcquisitionPolicy.__init__(self)
3829
2741
self._repository = repository
3831
2743
def acquire_repository(self, make_working_trees=None, shared=False):
3832
2744
"""Implementation of RepositoryAcquisitionPolicy.acquire_repository
3834
Returns an existing repository to use.
2746
Returns an existing repository to use
3836
self._add_fallback(self._repository,
3837
possible_transports=[self._repository.bzrdir.transport])
3838
return self._repository, False
3841
# Please register new formats after old formats so that formats
3842
# appear in chronological order and format descriptions can build
2748
return self._repository
3844
2751
format_registry = BzrDirFormatRegistry()
3845
# The pre-0.8 formats have their repository format network name registered in
3846
# repository.py. MetaDir formats have their repository format network name
3847
# inferred from their disk format string.
3848
2752
format_registry.register('weave', BzrDirFormat6,
3849
2753
'Pre-0.8 format. Slower than knit and does not'
3850
2754
' support checkouts or shared repositories.',
3852
2755
deprecated=True)
2756
format_registry.register_metadir('knit',
2757
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
2758
'Format using knits. Recommended for interoperation with bzr <= 0.14.',
2759
branch_format='bzrlib.branch.BzrBranchFormat5',
2760
tree_format='bzrlib.workingtree.WorkingTreeFormat3')
3853
2761
format_registry.register_metadir('metaweave',
3854
2762
'bzrlib.repofmt.weaverepo.RepositoryFormat7',
3855
2763
'Transitional format in 0.8. Slower than knit.',
3856
2764
branch_format='bzrlib.branch.BzrBranchFormat5',
3857
2765
tree_format='bzrlib.workingtree.WorkingTreeFormat3',
3860
format_registry.register_metadir('knit',
3861
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3862
'Format using knits. Recommended for interoperation with bzr <= 0.14.',
3863
branch_format='bzrlib.branch.BzrBranchFormat5',
3864
tree_format='bzrlib.workingtree.WorkingTreeFormat3',
3866
2766
deprecated=True)
3867
2767
format_registry.register_metadir('dirstate',
3868
2768
'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
3924
2825
format_registry.register_metadir('rich-root-pack',
3925
2826
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack4',
3926
help='New in 1.0: A variant of pack-0.92 that supports rich-root data '
3927
'(needed for bzr-svn and bzr-git).',
2827
help='New in 1.0: Pack-based format with data compatible with '
2828
'rich-root format repositories. Incompatible with'
3928
2830
branch_format='bzrlib.branch.BzrBranchFormat6',
3929
2831
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3932
format_registry.register_metadir('1.6',
3933
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5',
3934
help='A format that allows a branch to indicate that there is another '
3935
'(stacked) repository that should be used to access data that is '
3936
'not present locally.',
3937
branch_format='bzrlib.branch.BzrBranchFormat7',
3938
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3941
format_registry.register_metadir('1.6.1-rich-root',
3942
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack5RichRoot',
3943
help='A variant of 1.6 that supports rich-root data '
3944
'(needed for bzr-svn and bzr-git).',
3945
branch_format='bzrlib.branch.BzrBranchFormat7',
3946
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3949
format_registry.register_metadir('1.9',
3950
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
3951
help='A repository format using B+tree indexes. These indexes '
3952
'are smaller in size, have smarter caching and provide faster '
3953
'performance for most operations.',
3954
branch_format='bzrlib.branch.BzrBranchFormat7',
3955
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3958
format_registry.register_metadir('1.9-rich-root',
3959
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
3960
help='A variant of 1.9 that supports rich-root data '
3961
'(needed for bzr-svn and bzr-git).',
3962
branch_format='bzrlib.branch.BzrBranchFormat7',
3963
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3966
format_registry.register_metadir('1.14',
3967
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6',
3968
help='A working-tree format that supports content filtering.',
3969
branch_format='bzrlib.branch.BzrBranchFormat7',
3970
tree_format='bzrlib.workingtree.WorkingTreeFormat5',
3972
format_registry.register_metadir('1.14-rich-root',
3973
'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack6RichRoot',
3974
help='A variant of 1.14 that supports rich-root data '
3975
'(needed for bzr-svn and bzr-git).',
3976
branch_format='bzrlib.branch.BzrBranchFormat7',
3977
tree_format='bzrlib.workingtree.WorkingTreeFormat5',
3979
# The following un-numbered 'development' formats should always just be aliases.
3980
format_registry.register_metadir('development-rich-root',
3981
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
3982
help='Current development format. Supports rich roots. Can convert data '
3983
'to and from rich-root-pack (and anything compatible with '
3984
'rich-root-pack) format repositories. Repositories and branches in '
3985
'this format can only be read by bzr.dev. Please read '
3986
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
2833
# The following two formats should always just be aliases.
2834
format_registry.register_metadir('development',
2835
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment0',
2836
help='Current development format. Can convert data to and from pack-0.92 '
2837
'(and anything compatible with pack-0.92) format repositories. '
2838
'Repositories in this format can only be read by bzr.dev. '
2840
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
3988
branch_format='bzrlib.branch.BzrBranchFormat7',
3989
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2842
branch_format='bzrlib.branch.BzrBranchFormat6',
2843
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
3990
2844
experimental=True,
3994
2847
format_registry.register_metadir('development-subtree',
3995
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment2Subtree',
2848
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment0Subtree',
3996
2849
help='Current development format, subtree variant. Can convert data to and '
3997
'from pack-0.92-subtree (and anything compatible with '
3998
'pack-0.92-subtree) format repositories. Repositories and branches in '
3999
'this format can only be read by bzr.dev. Please read '
4000
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
4002
branch_format='bzrlib.branch.BzrBranchFormat7',
4003
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4006
alias=False, # Restore to being an alias when an actual development subtree format is added
4007
# This current non-alias status is simply because we did not introduce a
4008
# chk based subtree format.
4011
# And the development formats above will have aliased one of the following:
4012
format_registry.register_metadir('development6-rich-root',
4013
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK1',
4014
help='pack-1.9 with 255-way hashed CHK inv, group compress, rich roots '
4016
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
4018
branch_format='bzrlib.branch.BzrBranchFormat7',
4019
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4024
format_registry.register_metadir('development7-rich-root',
4025
'bzrlib.repofmt.groupcompress_repo.RepositoryFormatCHK2',
4026
help='pack-1.9 with 255-way hashed CHK inv, bencode revision, group compress, '
4027
'rich roots. Please read '
4028
'http://doc.bazaar.canonical.com/latest/developers/development-repo.html '
4030
branch_format='bzrlib.branch.BzrBranchFormat7',
4031
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4036
format_registry.register_metadir('2a',
4037
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
4038
help='First format for bzr 2.0 series.\n'
4039
'Uses group-compress storage.\n'
4040
'Provides rich roots which are a one-way transition.\n',
4041
# 'storage in packs, 255-way hashed CHK inventory, bencode revision, group compress, '
4042
# 'rich roots. Supported by bzr 1.16 and later.',
4043
branch_format='bzrlib.branch.BzrBranchFormat7',
4044
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
4048
# The following format should be an alias for the rich root equivalent
4049
# of the default format
4050
format_registry.register_metadir('default-rich-root',
4051
'bzrlib.repofmt.groupcompress_repo.RepositoryFormat2a',
4052
branch_format='bzrlib.branch.BzrBranchFormat7',
4053
tree_format='bzrlib.workingtree.WorkingTreeFormat6',
2850
'from pack-0.92 (and anything compatible with pack-0.92) format '
2851
'repositories. Repositories in this format can only be read by '
2852
'bzr.dev. Please read '
2853
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
2855
branch_format='bzrlib.branch.BzrBranchFormat6',
2856
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
4058
# The current format that is made on 'bzr init'.
4059
format_registry.set_default('2a')
2860
# And the development formats which the will have aliased one of follow:
2861
format_registry.register_metadir('development0',
2862
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment0',
2863
help='Trivial rename of pack-0.92 to provide a development format. '
2865
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
2867
branch_format='bzrlib.branch.BzrBranchFormat6',
2868
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2872
format_registry.register_metadir('development0-subtree',
2873
'bzrlib.repofmt.pack_repo.RepositoryFormatPackDevelopment0Subtree',
2874
help='Trivial rename of pack-0.92-subtree to provide a development format. '
2876
'http://doc.bazaar-vcs.org/latest/developers/development-repo.html '
2878
branch_format='bzrlib.branch.BzrBranchFormat6',
2879
tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2883
format_registry.set_default('pack-0.92')