130
130
return list(self.get_branches().values())
132
def branch_names(self):
133
"""List all branch names in this control directory.
135
:return: List of branch names
138
self.get_branch_reference()
139
except (errors.NotBranchError, errors.NoRepositoryPresent):
144
132
def get_branches(self):
145
133
"""Get all branches in this control directory, as a dictionary.
412
400
raise NotImplementedError(self.sprout)
414
402
def push_branch(self, source, revision_id=None, overwrite=False,
415
remember=False, create_prefix=False, lossy=False,
403
remember=False, create_prefix=False, lossy=False):
417
404
"""Push the source branch into this ControlDir."""
419
406
# If we can open a branch, use its direct repository, otherwise see
438
425
revision_id = source.last_revision()
439
426
repository_to.fetch(source.repository, revision_id=revision_id)
440
br_to = source.sprout(
441
self, revision_id=revision_id, lossy=lossy,
442
tag_selector=tag_selector)
427
br_to = source.sprout(self, revision_id=revision_id, lossy=lossy)
443
428
if source.get_push_location() is None or remember:
444
429
# FIXME: Should be done only if we succeed ? -- vila 2012-01-18
445
430
source.set_push_location(br_to.base)
459
444
tree_to = self.open_workingtree()
460
445
except errors.NotLocalUrl:
461
push_result.branch_push_result = source.push(
462
br_to, overwrite, stop_revision=revision_id, lossy=lossy,
463
tag_selector=tag_selector)
446
push_result.branch_push_result = source.push(br_to,
447
overwrite, stop_revision=revision_id, lossy=lossy)
464
448
push_result.workingtree_updated = False
465
449
except errors.NoWorkingTree:
466
push_result.branch_push_result = source.push(
467
br_to, overwrite, stop_revision=revision_id, lossy=lossy,
468
tag_selector=tag_selector)
450
push_result.branch_push_result = source.push(br_to,
451
overwrite, stop_revision=revision_id, lossy=lossy)
469
452
push_result.workingtree_updated = None # Not applicable
471
454
with tree_to.lock_write():
472
455
push_result.branch_push_result = source.push(
473
456
tree_to.branch, overwrite, stop_revision=revision_id,
474
lossy=lossy, tag_selector=tag_selector)
476
459
push_result.workingtree_updated = True
477
460
push_result.old_revno = push_result.branch_push_result.old_revno
510
493
raise NotImplementedError(self.check_conversion_target)
512
495
def clone(self, url, revision_id=None, force_new_repo=False,
513
preserve_stacking=False, tag_selector=None):
496
preserve_stacking=False):
514
497
"""Clone this controldir and its contents to url verbatim.
516
499
:param url: The url create the clone at. If url's last component does
526
509
return self.clone_on_transport(_mod_transport.get_transport(url),
527
510
revision_id=revision_id,
528
511
force_new_repo=force_new_repo,
529
preserve_stacking=preserve_stacking,
530
tag_selector=tag_selector)
512
preserve_stacking=preserve_stacking)
532
514
def clone_on_transport(self, transport, revision_id=None,
533
515
force_new_repo=False, preserve_stacking=False, stacked_on=None,
534
create_prefix=False, use_existing_dir=True, no_tree=False,
516
create_prefix=False, use_existing_dir=True, no_tree=False):
536
517
"""Clone this controldir and its contents to transport verbatim.
538
519
:param transport: The transport for the location to produce the clone
582
563
controldir = klass.open_from_transport(current_transport)
583
except (errors.NotBranchError, errors.PermissionDenied,
584
errors.UnknownFormatError):
564
except (errors.NotBranchError, errors.PermissionDenied):
587
567
recurse, value = evaluate(controldir)
808
788
a_transport = new_t
811
def open_tree_or_branch(klass, location, name=None):
791
def open_tree_or_branch(klass, location):
812
792
"""Return the branch and working tree at a location.
814
794
If there is no tree at the location, tree will be None.
817
797
:return: (tree, branch)
819
799
controldir = klass.open(location)
820
return controldir._get_tree_branch(name=name)
800
return controldir._get_tree_branch()
823
803
def open_containing_tree_or_branch(klass, location,
1047
1027
_default_format = None
1048
1028
"""The default format used for new control directories."""
1030
_server_probers = []
1031
"""The registered server format probers, e.g. RemoteBzrProber.
1033
This is a list of Prober-derived classes.
1051
1037
"""The registered format probers, e.g. BzrProber.
1138
1124
klass._probers.remove(prober)
1127
def register_server_prober(klass, prober):
1128
"""Register a control format prober for client-server environments.
1130
These probers will be used before ones registered with
1131
register_prober. This gives implementations that decide to the
1132
chance to grab it before anything looks at the contents of the format
1135
klass._server_probers.append(prober)
1140
1137
def __str__(self):
1141
1138
# Trim the newline
1142
1139
return self.get_format_description().rstrip()
1145
1142
def all_probers(klass):
1146
return klass._probers
1143
return klass._server_probers + klass._probers
1149
1146
def known_formats(klass):
1158
1155
def find_format(klass, transport, probers=None):
1159
1156
"""Return the format present at transport."""
1160
1157
if probers is None:
1162
klass.all_probers(),
1163
key=lambda prober: prober.priority(transport))
1158
probers = klass.all_probers()
1164
1159
for prober_kls in probers:
1165
1160
prober = prober_kls()
1280
1275
probers that detect .bzr/ directories and Bazaar smart servers,
1283
Probers should be registered using the register_prober methods on
1278
Probers should be registered using the register_server_prober or
1279
register_prober methods on ControlDirFormat.
1287
1282
def probe_transport(self, transport):
1306
1301
raise NotImplementedError(klass.known_formats)
1309
def priority(klass, transport):
1310
"""Priority of this prober.
1312
A lower value means the prober gets checked first.
1316
-10: This is a "server" prober
1318
10: This is a regular file-based prober
1319
100: This is a prober for an unsupported format
1324
1304
class ControlDirFormatInfo(object):
added
removed
breezy/controldir.py
