59
51
conflicts as _mod_conflicts,
67
60
revision as _mod_revision,
81
from bzrlib.transport import get_transport
83
from bzrlib.workingtree_4 import WorkingTreeFormat4, WorkingTreeFormat5
70
from bzrlib.workingtree_4 import (
86
77
from bzrlib import symbol_versioning
87
78
from bzrlib.decorators import needs_read_lock, needs_write_lock
88
from bzrlib.inventory import InventoryEntry, Inventory, ROOT_ID, TreeReference
79
from bzrlib.lock import LogicalLockResult
89
80
from bzrlib.lockable_files import LockableFiles
90
81
from bzrlib.lockdir import LockDir
91
82
import bzrlib.mutabletree
92
83
from bzrlib.mutabletree import needs_tree_write_lock
93
84
from bzrlib import osutils
94
85
from bzrlib.osutils import (
106
95
from bzrlib.filters import filtered_input_file
107
96
from bzrlib.trace import mutter, note
108
97
from bzrlib.transport.local import LocalTransport
109
from bzrlib.progress import DummyProgress, ProgressPhase
110
from bzrlib.revision import NULL_REVISION, CURRENT_REVISION
98
from bzrlib.revision import CURRENT_REVISION
111
99
from bzrlib.rio import RioReader, rio_file, Stanza
112
from bzrlib.symbol_versioning import (deprecated_passed,
115
DEPRECATED_PARAMETER,
100
from bzrlib.symbol_versioning import (
102
DEPRECATED_PARAMETER,
119
106
MERGE_MODIFIED_HEADER_1 = "BZR merge-modified list format 1"
107
# TODO: Modifying the conflict objects or their type is currently nearly
108
# impossible as there is no clear relationship between the working tree format
109
# and the conflict list file format.
120
110
CONFLICT_HEADER_1 = "BZR conflict list format 1"
122
112
ERROR_PATH_NOT_FOUND = 3 # WindowsError errno code, equivalent to ENOENT
443
455
def get_file_with_stat(self, file_id, path=None, filtered=True,
444
456
_fstat=os.fstat):
445
"""See MutableTree.get_file_with_stat."""
457
"""See Tree.get_file_with_stat."""
447
459
path = self.id2path(file_id)
448
460
file_obj = self.get_file_byname(path, filtered=False)
449
461
stat_value = _fstat(file_obj.fileno())
450
if self.supports_content_filtering() and filtered:
462
if filtered and self.supports_content_filtering():
451
463
filters = self._content_filter_stack(path)
452
464
file_obj = filtered_input_file(file_obj, filters)
453
465
return (file_obj, stat_value)
455
467
def get_file_text(self, file_id, path=None, filtered=True):
456
return self.get_file(file_id, path=path, filtered=filtered).read()
468
my_file = self.get_file(file_id, path=path, filtered=filtered)
470
return my_file.read()
458
474
def get_file_byname(self, filename, filtered=True):
459
475
path = self.abspath(filename)
460
476
f = file(path, 'rb')
461
if self.supports_content_filtering() and filtered:
477
if filtered and self.supports_content_filtering():
462
478
filters = self._content_filter_stack(filename)
463
479
return filtered_input_file(f, filters)
483
499
incorrectly attributed to CURRENT_REVISION (but after committing, the
484
500
attribution will be correct).
486
basis = self.basis_tree()
489
changes = self.iter_changes(basis, True, [self.id2path(file_id)],
490
require_versioned=True).next()
491
changed_content, kind = changes[2], changes[6]
492
if not changed_content:
493
return basis.annotate_iter(file_id)
497
if kind[0] != 'file':
500
old_lines = list(basis.annotate_iter(file_id))
502
for tree in self.branch.repository.revision_trees(
503
self.get_parent_ids()[1:]):
504
if file_id not in tree:
506
old.append(list(tree.annotate_iter(file_id)))
507
return annotate.reannotate(old, self.get_file(file_id).readlines(),
502
maybe_file_parent_keys = []
503
for parent_id in self.get_parent_ids():
505
parent_tree = self.revision_tree(parent_id)
506
except errors.NoSuchRevisionInTree:
507
parent_tree = self.branch.repository.revision_tree(parent_id)
508
parent_tree.lock_read()
510
if file_id not in parent_tree:
512
ie = parent_tree.inventory[file_id]
513
if ie.kind != 'file':
514
# Note: this is slightly unnecessary, because symlinks and
515
# directories have a "text" which is the empty text, and we
516
# know that won't mess up annotations. But it seems cleaner
518
parent_text_key = (file_id, ie.revision)
519
if parent_text_key not in maybe_file_parent_keys:
520
maybe_file_parent_keys.append(parent_text_key)
523
graph = _mod_graph.Graph(self.branch.repository.texts)
524
heads = graph.heads(maybe_file_parent_keys)
525
file_parent_keys = []
526
for key in maybe_file_parent_keys:
528
file_parent_keys.append(key)
530
# Now we have the parents of this content
531
annotator = self.branch.repository.texts.get_annotator()
532
text = self.get_file_text(file_id)
533
this_key =(file_id, default_revision)
534
annotator.add_special_text(this_key, file_parent_keys, text)
535
annotations = [(key[-1], line)
536
for key, line in annotator.annotate_flat(this_key)]
512
539
def _get_ancestors(self, default_revision):
513
540
ancestors = set([default_revision])
745
774
kind = 'tree-reference'
746
775
return kind, None, None, None
747
776
elif kind == 'symlink':
748
return ('symlink', None, None,
749
os.readlink(abspath.encode(osutils._fs_enc)
750
).decode(osutils._fs_enc))
777
target = osutils.readlink(abspath)
778
return ('symlink', None, None, target)
752
780
return (kind, None, None, None)
782
def _file_content_summary(self, path, stat_result):
783
size = stat_result.st_size
784
executable = self._is_executable_from_path_and_stat(path, stat_result)
785
# try for a stat cache lookup
786
return ('file', size, executable, self._sha_from_stat(
754
789
def _check_parents_for_ghosts(self, revision_ids, allow_leftmost_as_ghost):
755
790
"""Common ghost checking functionality from set_parent_*.
886
921
branch.last_revision().
888
923
from bzrlib.merge import Merger, Merge3Merger
889
pb = bzrlib.ui.ui_factory.nested_progress_bar()
891
merger = Merger(self.branch, this_tree=self, pb=pb)
892
merger.pp = ProgressPhase("Merge phase", 5, pb)
893
merger.pp.next_phase()
894
# check that there are no
896
merger.check_basis(check_clean=True, require_commits=False)
897
if to_revision is None:
898
to_revision = _mod_revision.ensure_null(branch.last_revision())
899
merger.other_rev_id = to_revision
900
if _mod_revision.is_null(merger.other_rev_id):
901
raise errors.NoCommits(branch)
902
self.branch.fetch(branch, last_revision=merger.other_rev_id)
903
merger.other_basis = merger.other_rev_id
904
merger.other_tree = self.branch.repository.revision_tree(
906
merger.other_branch = branch
907
merger.pp.next_phase()
908
if from_revision is None:
911
merger.set_base_revision(from_revision, branch)
912
if merger.base_rev_id == merger.other_rev_id:
913
raise errors.PointlessMerge
914
merger.backup_files = False
915
if merge_type is None:
916
merger.merge_type = Merge3Merger
918
merger.merge_type = merge_type
919
merger.set_interesting_files(None)
920
merger.show_base = False
921
merger.reprocess = False
922
conflicts = merger.do_merge()
924
merger = Merger(self.branch, this_tree=self)
925
# check that there are no local alterations
926
if not force and self.has_changes():
927
raise errors.UncommittedChanges(self)
928
if to_revision is None:
929
to_revision = _mod_revision.ensure_null(branch.last_revision())
930
merger.other_rev_id = to_revision
931
if _mod_revision.is_null(merger.other_rev_id):
932
raise errors.NoCommits(branch)
933
self.branch.fetch(branch, last_revision=merger.other_rev_id)
934
merger.other_basis = merger.other_rev_id
935
merger.other_tree = self.branch.repository.revision_tree(
937
merger.other_branch = branch
938
if from_revision is None:
941
merger.set_base_revision(from_revision, branch)
942
if merger.base_rev_id == merger.other_rev_id:
943
raise errors.PointlessMerge
944
merger.backup_files = False
945
if merge_type is None:
946
merger.merge_type = Merge3Merger
948
merger.merge_type = merge_type
949
merger.set_interesting_files(None)
950
merger.show_base = False
951
merger.reprocess = False
952
conflicts = merger.do_merge()
1073
1103
tree_transport = self.bzrdir.root_transport.clone(sub_path)
1074
1104
if tree_transport.base != branch_transport.base:
1075
1105
tree_bzrdir = format.initialize_on_transport(tree_transport)
1076
branch.BranchReferenceFormat().initialize(tree_bzrdir, new_branch)
1106
branch.BranchReferenceFormat().initialize(tree_bzrdir,
1107
target_branch=new_branch)
1078
1109
tree_bzrdir = branch_bzrdir
1079
wt = tree_bzrdir.create_workingtree(NULL_REVISION)
1110
wt = tree_bzrdir.create_workingtree(_mod_revision.NULL_REVISION)
1080
1111
wt.set_parent_ids(self.get_parent_ids())
1081
1112
my_inv = self.inventory
1082
child_inv = Inventory(root_id=None)
1113
child_inv = inventory.Inventory(root_id=None)
1083
1114
new_root = my_inv[file_id]
1084
1115
my_inv.remove_recursive_id(file_id)
1085
1116
new_root.parent_id = None
1110
1141
def _kind(self, relpath):
1111
1142
return osutils.file_kind(self.abspath(relpath))
1113
def list_files(self, include_root=False):
1114
"""Recursively list all files as (path, class, kind, id, entry).
1144
def list_files(self, include_root=False, from_dir=None, recursive=True):
1145
"""List all files as (path, class, kind, id, entry).
1116
1147
Lists, but does not descend into unversioned directories.
1118
1148
This does not include files that have been deleted in this
1149
tree. Skips the control directory.
1121
Skips the control directory.
1151
:param include_root: if True, return an entry for the root
1152
:param from_dir: start from this directory or None for the root
1153
:param recursive: whether to recurse into subdirectories or not
1123
1155
# list_files is an iterator, so @needs_read_lock doesn't work properly
1124
1156
# with it. So callers should be careful to always read_lock the tree.
1139
1171
fk_entries = {'directory':TreeDirectory, 'file':TreeFile, 'symlink':TreeLink}
1141
1173
# directory file_id, relative path, absolute path, reverse sorted children
1142
children = os.listdir(self.basedir)
1174
if from_dir is not None:
1175
from_dir_id = inv.path2id(from_dir)
1176
if from_dir_id is None:
1177
# Directory not versioned
1179
from_dir_abspath = pathjoin(self.basedir, from_dir)
1181
from_dir_id = inv.root.file_id
1182
from_dir_abspath = self.basedir
1183
children = os.listdir(from_dir_abspath)
1143
1184
children.sort()
1144
1185
# jam 20060527 The kernel sized tree seems equivalent whether we
1145
1186
# use a deque and popleft to keep them sorted, or if we use a plain
1146
1187
# list and just reverse() them.
1147
1188
children = collections.deque(children)
1148
stack = [(inv.root.file_id, u'', self.basedir, children)]
1189
stack = [(from_dir_id, u'', from_dir_abspath, children)]
1150
1191
from_dir_id, from_dir_relpath, from_dir_abspath, children = stack[-1]
1209
1250
if fk != 'directory':
1212
# But do this child first
1213
new_children = os.listdir(fap)
1215
new_children = collections.deque(new_children)
1216
stack.append((f_ie.file_id, fp, fap, new_children))
1217
# Break out of inner loop,
1218
# so that we start outer loop with child
1253
# But do this child first if recursing down
1255
new_children = os.listdir(fap)
1257
new_children = collections.deque(new_children)
1258
stack.append((f_ie.file_id, fp, fap, new_children))
1259
# Break out of inner loop,
1260
# so that we start outer loop with child
1221
1263
# if we finished all children, pop it off the stack
1457
1500
from_tail = splitpath(from_rel)[-1]
1458
1501
from_id = inv.path2id(from_rel)
1459
1502
if from_id is None:
1460
raise errors.BzrRenameFailedError(from_rel,to_rel,
1461
errors.NotVersionedError(path=str(from_rel)))
1462
from_entry = inv[from_id]
1503
# if file is missing in the inventory maybe it's in the basis_tree
1504
basis_tree = self.branch.basis_tree()
1505
from_id = basis_tree.path2id(from_rel)
1507
raise errors.BzrRenameFailedError(from_rel,to_rel,
1508
errors.NotVersionedError(path=str(from_rel)))
1509
# put entry back in the inventory so we can rename it
1510
from_entry = basis_tree.inventory[from_id].copy()
1513
from_entry = inv[from_id]
1463
1514
from_parent_id = from_entry.parent_id
1464
1515
to_dir, to_tail = os.path.split(to_rel)
1465
1516
to_dir_id = inv.path2id(to_dir)
1556
1608
@needs_write_lock
1557
1609
def pull(self, source, overwrite=False, stop_revision=None,
1558
change_reporter=None, possible_transports=None):
1559
top_pb = bzrlib.ui.ui_factory.nested_progress_bar()
1610
change_reporter=None, possible_transports=None, local=False):
1560
1611
source.lock_read()
1562
pp = ProgressPhase("Pull phase", 2, top_pb)
1564
1613
old_revision_info = self.branch.last_revision_info()
1565
1614
basis_tree = self.basis_tree()
1566
1615
count = self.branch.pull(source, overwrite, stop_revision,
1567
possible_transports=possible_transports)
1616
possible_transports=possible_transports,
1568
1618
new_revision_info = self.branch.last_revision_info()
1569
1619
if new_revision_info != old_revision_info:
1571
1620
repository = self.branch.repository
1572
pb = bzrlib.ui.ui_factory.nested_progress_bar()
1573
1621
basis_tree.lock_read()
1575
1623
new_basis_tree = self.branch.basis_tree()
1756
1805
raise errors.ObjectNotLocked(self)
1758
1807
def lock_read(self):
1759
"""See Branch.lock_read, and WorkingTree.unlock."""
1808
"""Lock the tree for reading.
1810
This also locks the branch, and can be unlocked via self.unlock().
1812
:return: A bzrlib.lock.LogicalLockResult.
1760
1814
if not self.is_locked():
1761
1815
self._reset_data()
1762
1816
self.branch.lock_read()
1764
return self._control_files.lock_read()
1818
self._control_files.lock_read()
1819
return LogicalLockResult(self.unlock)
1766
1821
self.branch.unlock()
1769
1824
def lock_tree_write(self):
1770
"""See MutableTree.lock_tree_write, and WorkingTree.unlock."""
1825
"""See MutableTree.lock_tree_write, and WorkingTree.unlock.
1827
:return: A bzrlib.lock.LogicalLockResult.
1771
1829
if not self.is_locked():
1772
1830
self._reset_data()
1773
1831
self.branch.lock_read()
1775
return self._control_files.lock_write()
1833
self._control_files.lock_write()
1834
return LogicalLockResult(self.unlock)
1777
1836
self.branch.unlock()
1780
1839
def lock_write(self):
1781
"""See MutableTree.lock_write, and WorkingTree.unlock."""
1840
"""See MutableTree.lock_write, and WorkingTree.unlock.
1842
:return: A bzrlib.lock.LogicalLockResult.
1782
1844
if not self.is_locked():
1783
1845
self._reset_data()
1784
1846
self.branch.lock_write()
1786
return self._control_files.lock_write()
1848
self._control_files.lock_write()
1849
return LogicalLockResult(self.unlock)
1788
1851
self.branch.unlock()
2191
2275
# We MUST save it even if an error occurs, because otherwise the users
2192
2276
# local work is unreferenced and will appear to have been lost.
2196
2280
last_rev = self.get_parent_ids()[0]
2197
2281
except IndexError:
2198
2282
last_rev = _mod_revision.NULL_REVISION
2199
if last_rev != _mod_revision.ensure_null(self.branch.last_revision()):
2200
# merge tree state up to new branch tip.
2283
if revision is None:
2284
revision = self.branch.last_revision()
2286
old_tip = old_tip or _mod_revision.NULL_REVISION
2288
if not _mod_revision.is_null(old_tip) and old_tip != last_rev:
2289
# the branch we are bound to was updated
2290
# merge those changes in first
2291
base_tree = self.basis_tree()
2292
other_tree = self.branch.repository.revision_tree(old_tip)
2293
nb_conflicts = merge.merge_inner(self.branch, other_tree,
2294
base_tree, this_tree=self,
2295
change_reporter=change_reporter)
2297
self.add_parent_tree((old_tip, other_tree))
2298
trace.note('Rerun update after fixing the conflicts.')
2301
if last_rev != _mod_revision.ensure_null(revision):
2302
# the working tree is up to date with the branch
2303
# we can merge the specified revision from master
2304
to_tree = self.branch.repository.revision_tree(revision)
2305
to_root_id = to_tree.get_root_id()
2201
2307
basis = self.basis_tree()
2202
2308
basis.lock_read()
2204
to_tree = self.branch.basis_tree()
2205
if basis.inventory.root is None:
2206
self.set_root_id(to_tree.get_root_id())
2310
if (basis.inventory.root is None
2311
or basis.inventory.root.file_id != to_root_id):
2312
self.set_root_id(to_root_id)
2208
result += merge.merge_inner(
2213
change_reporter=change_reporter)
2317
# determine the branch point
2318
graph = self.branch.repository.get_graph()
2319
base_rev_id = graph.find_unique_lca(self.branch.last_revision(),
2321
base_tree = self.branch.repository.revision_tree(base_rev_id)
2323
nb_conflicts = merge.merge_inner(self.branch, to_tree, base_tree,
2325
change_reporter=change_reporter)
2326
self.set_last_revision(revision)
2216
2327
# TODO - dedup parents list with things merged by pull ?
2217
2328
# reuse the tree we've updated to to set the basis:
2218
parent_trees = [(self.branch.last_revision(), to_tree)]
2329
parent_trees = [(revision, to_tree)]
2219
2330
merges = self.get_parent_ids()[1:]
2220
2331
# Ideally we ask the tree for the trees here, that way the working
2221
# tree can decide whether to give us teh entire tree or give us a
2332
# tree can decide whether to give us the entire tree or give us a
2222
2333
# lazy initialised tree. dirstate for instance will have the trees
2223
2334
# in ram already, whereas a last-revision + basis-inventory tree
2224
2335
# will not, but also does not need them when setting parents.
2225
2336
for parent in merges:
2226
2337
parent_trees.append(
2227
2338
(parent, self.branch.repository.revision_tree(parent)))
2228
if (old_tip is not None and not _mod_revision.is_null(old_tip)):
2339
if not _mod_revision.is_null(old_tip):
2229
2340
parent_trees.append(
2230
2341
(old_tip, self.branch.repository.revision_tree(old_tip)))
2231
2342
self.set_parent_trees(parent_trees)
2232
2343
last_rev = parent_trees[0][0]
2234
# the working tree had the same last-revision as the master
2235
# branch did. We may still have pivot local work from the local
2236
# branch into old_tip:
2237
if (old_tip is not None and not _mod_revision.is_null(old_tip)):
2238
self.add_parent_tree_id(old_tip)
2239
if (old_tip is not None and not _mod_revision.is_null(old_tip)
2240
and old_tip != last_rev):
2241
# our last revision was not the prior branch last revision
2242
# and we have converted that last revision to a pending merge.
2243
# base is somewhere between the branch tip now
2244
# and the now pending merge
2246
# Since we just modified the working tree and inventory, flush out
2247
# the current state, before we modify it again.
2248
# TODO: jam 20070214 WorkingTree3 doesn't require this, dirstate
2249
# requires it only because TreeTransform directly munges the
2250
# inventory and calls tree._write_inventory(). Ultimately we
2251
# should be able to remove this extra flush.
2253
graph = self.branch.repository.get_graph()
2254
base_rev_id = graph.find_unique_lca(self.branch.last_revision(),
2256
base_tree = self.branch.repository.revision_tree(base_rev_id)
2257
other_tree = self.branch.repository.revision_tree(old_tip)
2258
result += merge.merge_inner(
2263
change_reporter=change_reporter)
2266
2346
def _write_hashcache_if_dirty(self):
2267
2347
"""Write out the hashcache if it is dirty."""