~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transform.py

  • Committer: Robert Collins
  • Date: 2010-06-28 02:41:22 UTC
  • mto: This revision was merged to the branch mainline in revision 5324.
  • Revision ID: robertc@robertcollins.net-20100628024122-g951fzp74f3u6wst
Sanity check that new_trace_file in pop_log_file is valid, and also fix a test that monkey patched get_terminal_encoding.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006-2011 Canonical Ltd
 
1
# Copyright (C) 2006-2010 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
19
19
from stat import S_ISREG, S_IEXEC
20
20
import time
21
21
 
22
 
from bzrlib import (
23
 
    errors,
24
 
    lazy_import,
25
 
    registry,
26
 
    trace,
27
 
    tree,
28
 
    )
29
 
lazy_import.lazy_import(globals(), """
 
22
from bzrlib.lazy_import import lazy_import
 
23
lazy_import(globals(), """
30
24
from bzrlib import (
31
25
    annotate,
32
26
    bencode,
33
27
    bzrdir,
34
28
    commit,
35
 
    conflicts,
36
29
    delta,
37
30
    errors,
38
31
    inventory,
40
33
    osutils,
41
34
    revision as _mod_revision,
42
35
    ui,
43
 
    urlutils,
44
36
    )
45
37
""")
46
38
from bzrlib.errors import (DuplicateKey, MalformedTransform, NoSuchFile,
48
40
                           ExistingLimbo, ImmortalLimbo, NoFinalPath,
49
41
                           UnableCreateSymlink)
50
42
from bzrlib.filters import filtered_output_bytes, ContentFilterContext
 
43
from bzrlib.inventory import InventoryEntry
51
44
from bzrlib.osutils import (
52
45
    delete_any,
53
46
    file_kind,
54
47
    has_symlinks,
 
48
    lexists,
55
49
    pathjoin,
56
50
    sha_file,
57
51
    splitpath,
58
52
    supports_executable,
59
 
    )
 
53
)
60
54
from bzrlib.progress import ProgressPhase
61
55
from bzrlib.symbol_versioning import (
62
 
    deprecated_function,
63
 
    deprecated_in,
64
 
    deprecated_method,
65
 
    )
 
56
        deprecated_function,
 
57
        deprecated_in,
 
58
        )
 
59
from bzrlib.trace import mutter, warning
 
60
from bzrlib import tree
 
61
import bzrlib.ui
 
62
import bzrlib.urlutils as urlutils
66
63
 
67
64
 
68
65
ROOT_PARENT = "root-parent"
69
66
 
 
67
 
70
68
def unique_add(map, key, value):
71
69
    if key in map:
72
70
        raise DuplicateKey(key=key)
73
71
    map[key] = value
74
72
 
75
73
 
76
 
 
77
74
class _TransformResults(object):
78
75
    def __init__(self, modified_paths, rename_count):
79
76
        object.__init__(self)
103
100
        self._new_parent = {}
104
101
        # mapping of trans_id with new contents -> new file_kind
105
102
        self._new_contents = {}
106
 
        # mapping of trans_id => (sha1 of content, stat_value)
107
 
        self._observed_sha1s = {}
108
103
        # Set of trans_ids whose contents will be removed
109
104
        self._removed_contents = set()
110
105
        # Mapping of trans_id -> new execute-bit value
129
124
            self._new_root = self.trans_id_tree_file_id(root_id)
130
125
        else:
131
126
            self._new_root = None
132
 
        # Indicator of whether the transform has been applied
 
127
        # Indictor of whether the transform has been applied
133
128
        self._done = False
134
129
        # A progress bar
135
130
        self._pb = pb
138
133
        # A counter of how many files have been renamed
139
134
        self.rename_count = 0
140
135
 
141
 
    def __enter__(self):
142
 
        """Support Context Manager API."""
143
 
        return self
144
 
 
145
 
    def __exit__(self, exc_type, exc_val, exc_tb):
146
 
        """Support Context Manager API."""
147
 
        self.finalize()
148
 
 
149
136
    def finalize(self):
150
137
        """Release the working tree lock, if held.
151
138
 
226
213
        This means that the old root trans-id becomes obsolete, so it is
227
214
        recommended only to invoke this after the root trans-id has become
228
215
        irrelevant.
229
 
 
230
216
        """
231
217
        new_roots = [k for k, v in self._new_parent.iteritems() if v is
232
218
                     ROOT_PARENT]
233
219
        if len(new_roots) < 1:
234
 
            if self.final_kind(self.root) is None:
235
 
                self.cancel_deletion(self.root)
236
 
            if self.final_file_id(self.root) is None:
237
 
                self.version_file(self.tree_file_id(self.root),
238
 
                                     self.root)
239
220
            return
240
221
        if len(new_roots) != 1:
241
222
            raise ValueError('A tree cannot have two roots!')
259
240
        if (self.tree_file_id(self._new_root) is not None and
260
241
            self._new_root not in self._removed_id):
261
242
            self.unversion_file(self._new_root)
262
 
        if file_id is not None:
263
 
            self.version_file(file_id, self._new_root)
 
243
        self.version_file(file_id, self._new_root)
264
244
 
265
245
        # Now move children of new root into old root directory.
266
246
        # Ensure all children are registered with the transaction, but don't
335
315
 
336
316
    def delete_contents(self, trans_id):
337
317
        """Schedule the contents of a path entry for deletion"""
338
 
        kind = self.tree_kind(trans_id)
339
 
        if kind is not None:
340
 
            self._removed_contents.add(trans_id)
 
318
        # Ensure that the object exists in the WorkingTree, this will raise an
 
319
        # exception if there is a problem
 
320
        self.tree_kind(trans_id)
 
321
        self._removed_contents.add(trans_id)
341
322
 
342
323
    def cancel_deletion(self, trans_id):
343
324
        """Cancel a scheduled deletion"""
400
381
        return sorted(FinalPaths(self).get_paths(new_ids))
401
382
 
402
383
    def _inventory_altered(self):
403
 
        """Determine which trans_ids need new Inventory entries.
404
 
 
405
 
        An new entry is needed when anything that would be reflected by an
406
 
        inventory entry changes, including file name, file_id, parent file_id,
407
 
        file kind, and the execute bit.
408
 
 
409
 
        Some care is taken to return entries with real changes, not cases
410
 
        where the value is deleted and then restored to its original value,
411
 
        but some actually unchanged values may be returned.
412
 
 
413
 
        :returns: A list of (path, trans_id) for all items requiring an
414
 
            inventory change. Ordered by path.
415
 
        """
416
 
        changed_ids = set()
417
 
        # Find entries whose file_ids are new (or changed).
418
 
        new_file_id = set(t for t in self._new_id
419
 
                          if self._new_id[t] != self.tree_file_id(t))
420
 
        for id_set in [self._new_name, self._new_parent, new_file_id,
 
384
        """Get the trans_ids and paths of files needing new inv entries."""
 
385
        new_ids = set()
 
386
        for id_set in [self._new_name, self._new_parent, self._new_id,
421
387
                       self._new_executability]:
422
 
            changed_ids.update(id_set)
423
 
        # removing implies a kind change
 
388
            new_ids.update(id_set)
424
389
        changed_kind = set(self._removed_contents)
425
 
        # so does adding
426
390
        changed_kind.intersection_update(self._new_contents)
427
 
        # Ignore entries that are already known to have changed.
428
 
        changed_kind.difference_update(changed_ids)
429
 
        #  to keep only the truly changed ones
430
 
        changed_kind = (t for t in changed_kind
431
 
                        if self.tree_kind(t) != self.final_kind(t))
432
 
        # all kind changes will alter the inventory
433
 
        changed_ids.update(changed_kind)
434
 
        # To find entries with changed parent_ids, find parents which existed,
435
 
        # but changed file_id.
436
 
        changed_file_id = set(t for t in new_file_id if t in self._removed_id)
437
 
        # Now add all their children to the set.
438
 
        for parent_trans_id in new_file_id:
439
 
            changed_ids.update(self.iter_tree_children(parent_trans_id))
440
 
        return sorted(FinalPaths(self).get_paths(changed_ids))
 
391
        changed_kind.difference_update(new_ids)
 
392
        changed_kind = (t for t in changed_kind if self.tree_kind(t) !=
 
393
                        self.final_kind(t))
 
394
        new_ids.update(changed_kind)
 
395
        return sorted(FinalPaths(self).get_paths(new_ids))
441
396
 
442
397
    def final_kind(self, trans_id):
443
398
        """Determine the final file kind, after any changes applied.
444
399
 
445
 
        :return: None if the file does not exist/has no contents.  (It is
446
 
            conceivable that a path would be created without the corresponding
447
 
            contents insertion command)
 
400
        Raises NoSuchFile if the file does not exist/has no contents.
 
401
        (It is conceivable that a path would be created without the
 
402
        corresponding contents insertion command)
448
403
        """
449
404
        if trans_id in self._new_contents:
450
405
            return self._new_contents[trans_id]
451
406
        elif trans_id in self._removed_contents:
452
 
            return None
 
407
            raise NoSuchFile(None)
453
408
        else:
454
409
            return self.tree_kind(trans_id)
455
410
 
568
523
        for trans_id in self._removed_id:
569
524
            file_id = self.tree_file_id(trans_id)
570
525
            if file_id is not None:
571
 
                # XXX: This seems like something that should go via a different
572
 
                #      indirection.
573
526
                if self._tree.inventory[file_id].kind == 'directory':
574
527
                    parents.append(trans_id)
575
528
            elif self.tree_kind(trans_id) == 'directory':
579
532
            # ensure that all children are registered with the transaction
580
533
            list(self.iter_tree_children(parent_id))
581
534
 
582
 
    @deprecated_method(deprecated_in((2, 3, 0)))
583
535
    def has_named_child(self, by_parent, parent_id, name):
584
 
        return self._has_named_child(
585
 
            name, parent_id, known_children=by_parent.get(parent_id, []))
586
 
 
587
 
    def _has_named_child(self, name, parent_id, known_children):
588
 
        """Does a parent already have a name child.
589
 
 
590
 
        :param name: The searched for name.
591
 
 
592
 
        :param parent_id: The parent for which the check is made.
593
 
 
594
 
        :param known_children: The already known children. This should have
595
 
            been recently obtained from `self.by_parent.get(parent_id)`
596
 
            (or will be if None is passed).
597
 
        """
598
 
        if known_children is None:
599
 
            known_children = self.by_parent().get(parent_id, [])
600
 
        for child in known_children:
 
536
        try:
 
537
            children = by_parent[parent_id]
 
538
        except KeyError:
 
539
            children = []
 
540
        for child in children:
601
541
            if self.final_name(child) == name:
602
542
                return True
603
 
        parent_path = self._tree_id_paths.get(parent_id, None)
604
 
        if parent_path is None:
605
 
            # No parent... no children
 
543
        try:
 
544
            path = self._tree_id_paths[parent_id]
 
545
        except KeyError:
606
546
            return False
607
 
        child_path = joinpath(parent_path, name)
608
 
        child_id = self._tree_path_ids.get(child_path, None)
 
547
        childpath = joinpath(path, name)
 
548
        child_id = self._tree_path_ids.get(childpath)
609
549
        if child_id is None:
610
 
            # Not known by the tree transform yet, check the filesystem
611
 
            return osutils.lexists(self._tree.abspath(child_path))
 
550
            return lexists(self._tree.abspath(childpath))
612
551
        else:
613
 
            raise AssertionError('child_id is missing: %s, %s, %s'
614
 
                                 % (name, parent_id, child_id))
615
 
 
616
 
    def _available_backup_name(self, name, target_id):
617
 
        """Find an available backup name.
618
 
 
619
 
        :param name: The basename of the file.
620
 
 
621
 
        :param target_id: The directory trans_id where the backup should 
622
 
            be placed.
623
 
        """
624
 
        known_children = self.by_parent().get(target_id, [])
625
 
        return osutils.available_backup_name(
626
 
            name,
627
 
            lambda base: self._has_named_child(
628
 
                base, target_id, known_children))
 
552
            if self.final_parent(child_id) != parent_id:
 
553
                return False
 
554
            if child_id in self._removed_contents:
 
555
                # XXX What about dangling file-ids?
 
556
                return False
 
557
            else:
 
558
                return True
629
559
 
630
560
    def _parent_loops(self):
631
561
        """No entry should be its own ancestor"""
666
596
        """
667
597
        conflicts = []
668
598
        for trans_id in self._new_id.iterkeys():
669
 
            kind = self.final_kind(trans_id)
670
 
            if kind is None:
 
599
            try:
 
600
                kind = self.final_kind(trans_id)
 
601
            except NoSuchFile:
671
602
                conflicts.append(('versioning no contents', trans_id))
672
603
                continue
673
 
            if not inventory.InventoryEntry.versionable_kind(kind):
 
604
            if not InventoryEntry.versionable_kind(kind):
674
605
                conflicts.append(('versioning bad kind', trans_id, kind))
675
606
        return conflicts
676
607
 
687
618
            if self.final_file_id(trans_id) is None:
688
619
                conflicts.append(('unversioned executability', trans_id))
689
620
            else:
690
 
                if self.final_kind(trans_id) != "file":
 
621
                try:
 
622
                    non_file = self.final_kind(trans_id) != "file"
 
623
                except NoSuchFile:
 
624
                    non_file = True
 
625
                if non_file is True:
691
626
                    conflicts.append(('non-file executability', trans_id))
692
627
        return conflicts
693
628
 
695
630
        """Check for overwrites (not permitted on Win32)"""
696
631
        conflicts = []
697
632
        for trans_id in self._new_contents:
698
 
            if self.tree_kind(trans_id) is None:
 
633
            try:
 
634
                self.tree_kind(trans_id)
 
635
            except NoSuchFile:
699
636
                continue
700
637
            if trans_id not in self._removed_contents:
701
638
                conflicts.append(('overwrite', trans_id,
708
645
        if (self._new_name, self._new_parent) == ({}, {}):
709
646
            return conflicts
710
647
        for children in by_parent.itervalues():
711
 
            name_ids = []
712
 
            for child_tid in children:
713
 
                name = self.final_name(child_tid)
714
 
                if name is not None:
715
 
                    # Keep children only if they still exist in the end
716
 
                    if not self._case_sensitive_target:
717
 
                        name = name.lower()
718
 
                    name_ids.append((name, child_tid))
 
648
            name_ids = [(self.final_name(t), t) for t in children]
 
649
            if not self._case_sensitive_target:
 
650
                name_ids = [(n.lower(), t) for n, t in name_ids]
719
651
            name_ids.sort()
720
652
            last_name = None
721
653
            last_trans_id = None
722
654
            for name, trans_id in name_ids:
723
 
                kind = self.final_kind(trans_id)
 
655
                try:
 
656
                    kind = self.final_kind(trans_id)
 
657
                except NoSuchFile:
 
658
                    kind = None
724
659
                file_id = self.final_file_id(trans_id)
725
660
                if kind is None and file_id is None:
726
661
                    continue
745
680
        return conflicts
746
681
 
747
682
    def _parent_type_conflicts(self, by_parent):
748
 
        """Children must have a directory parent"""
 
683
        """parents must have directory 'contents'."""
749
684
        conflicts = []
750
685
        for parent_id, children in by_parent.iteritems():
751
686
            if parent_id is ROOT_PARENT:
752
687
                continue
753
 
            no_children = True
754
 
            for child_id in children:
755
 
                if self.final_kind(child_id) is not None:
756
 
                    no_children = False
757
 
                    break
758
 
            if no_children:
 
688
            if not self._any_contents(children):
759
689
                continue
760
 
            # There is at least a child, so we need an existing directory to
761
 
            # contain it.
762
 
            kind = self.final_kind(parent_id)
 
690
            for child in children:
 
691
                try:
 
692
                    self.final_kind(child)
 
693
                except NoSuchFile:
 
694
                    continue
 
695
            try:
 
696
                kind = self.final_kind(parent_id)
 
697
            except NoSuchFile:
 
698
                kind = None
763
699
            if kind is None:
764
 
                # The directory will be deleted
765
700
                conflicts.append(('missing parent', parent_id))
766
701
            elif kind != "directory":
767
 
                # Meh, we need a *directory* to put something in it
768
702
                conflicts.append(('non-directory parent', parent_id))
769
703
        return conflicts
770
704
 
 
705
    def _any_contents(self, trans_ids):
 
706
        """Return true if any of the trans_ids, will have contents."""
 
707
        for trans_id in trans_ids:
 
708
            try:
 
709
                kind = self.final_kind(trans_id)
 
710
            except NoSuchFile:
 
711
                continue
 
712
            return True
 
713
        return False
 
714
 
771
715
    def _set_executability(self, path, trans_id):
772
716
        """Set the executability of versioned files """
773
717
        if supports_executable():
795
739
        return trans_id
796
740
 
797
741
    def new_file(self, name, parent_id, contents, file_id=None,
798
 
                 executable=None, sha1=None):
 
742
                 executable=None):
799
743
        """Convenience method to create files.
800
744
 
801
745
        name is the name of the file to create.
808
752
        trans_id = self._new_entry(name, parent_id, file_id)
809
753
        # TODO: rather than scheduling a set_executable call,
810
754
        # have create_file create the file with the right mode.
811
 
        self.create_file(contents, trans_id, sha1=sha1)
 
755
        self.create_file(contents, trans_id)
812
756
        if executable is not None:
813
757
            self.set_executability(executable, trans_id)
814
758
        return trans_id
837
781
        self.create_symlink(target, trans_id)
838
782
        return trans_id
839
783
 
840
 
    def new_orphan(self, trans_id, parent_id):
841
 
        """Schedule an item to be orphaned.
842
 
 
843
 
        When a directory is about to be removed, its children, if they are not
844
 
        versioned are moved out of the way: they don't have a parent anymore.
845
 
 
846
 
        :param trans_id: The trans_id of the existing item.
847
 
        :param parent_id: The parent trans_id of the item.
848
 
        """
849
 
        raise NotImplementedError(self.new_orphan)
850
 
 
851
 
    def _get_potential_orphans(self, dir_id):
852
 
        """Find the potential orphans in a directory.
853
 
 
854
 
        A directory can't be safely deleted if there are versioned files in it.
855
 
        If all the contained files are unversioned then they can be orphaned.
856
 
 
857
 
        The 'None' return value means that the directory contains at least one
858
 
        versioned file and should not be deleted.
859
 
 
860
 
        :param dir_id: The directory trans id.
861
 
 
862
 
        :return: A list of the orphan trans ids or None if at least one
863
 
             versioned file is present.
864
 
        """
865
 
        orphans = []
866
 
        # Find the potential orphans, stop if one item should be kept
867
 
        for child_tid in self.by_parent()[dir_id]:
868
 
            if child_tid in self._removed_contents:
869
 
                # The child is removed as part of the transform. Since it was
870
 
                # versioned before, it's not an orphan
871
 
                continue
872
 
            elif self.final_file_id(child_tid) is None:
873
 
                # The child is not versioned
874
 
                orphans.append(child_tid)
875
 
            else:
876
 
                # We have a versioned file here, searching for orphans is
877
 
                # meaningless.
878
 
                orphans = None
879
 
                break
880
 
        return orphans
881
 
 
882
784
    def _affected_ids(self):
883
785
        """Return the set of transform ids affected by the transform"""
884
786
        trans_ids = set(self._removed_id)
943
845
        Return a (name, parent, kind, executable) tuple
944
846
        """
945
847
        to_name = self.final_name(to_trans_id)
946
 
        to_kind = self.final_kind(to_trans_id)
 
848
        try:
 
849
            to_kind = self.final_kind(to_trans_id)
 
850
        except NoSuchFile:
 
851
            to_kind = None
947
852
        to_parent = self.final_file_id(self.final_parent(to_trans_id))
948
853
        if to_trans_id in self._new_executability:
949
854
            to_executable = self._new_executability[to_trans_id]
1196
1101
        self._deletiondir = None
1197
1102
        # A mapping of transform ids to their limbo filename
1198
1103
        self._limbo_files = {}
1199
 
        self._possibly_stale_limbo_files = set()
1200
1104
        # A mapping of transform ids to a set of the transform ids of children
1201
1105
        # that their limbo directory has
1202
1106
        self._limbo_children = {}
1215
1119
        if self._tree is None:
1216
1120
            return
1217
1121
        try:
1218
 
            limbo_paths = self._limbo_files.values() + list(
1219
 
                self._possibly_stale_limbo_files)
1220
 
            limbo_paths = sorted(limbo_paths, reverse=True)
1221
 
            for path in limbo_paths:
1222
 
                try:
1223
 
                    delete_any(path)
1224
 
                except OSError, e:
1225
 
                    if e.errno != errno.ENOENT:
1226
 
                        raise
1227
 
                    # XXX: warn? perhaps we just got interrupted at an
1228
 
                    # inconvenient moment, but perhaps files are disappearing
1229
 
                    # from under us?
 
1122
            entries = [(self._limbo_name(t), t, k) for t, k in
 
1123
                       self._new_contents.iteritems()]
 
1124
            entries.sort(reverse=True)
 
1125
            for path, trans_id, kind in entries:
 
1126
                delete_any(path)
1230
1127
            try:
1231
1128
                delete_any(self._limbodir)
1232
1129
            except OSError:
1281
1178
        entries from _limbo_files, because they are now stale.
1282
1179
        """
1283
1180
        for trans_id in trans_ids:
1284
 
            old_path = self._limbo_files[trans_id]
1285
 
            self._possibly_stale_limbo_files.add(old_path)
1286
 
            del self._limbo_files[trans_id]
 
1181
            old_path = self._limbo_files.pop(trans_id)
1287
1182
            if trans_id not in self._new_contents:
1288
1183
                continue
1289
1184
            new_path = self._limbo_name(trans_id)
1290
 
            os.rename(old_path, new_path)
1291
 
            self._possibly_stale_limbo_files.remove(old_path)
 
1185
            osutils.rename(old_path, new_path)
1292
1186
            for descendant in self._limbo_descendants(trans_id):
1293
1187
                desc_path = self._limbo_files[descendant]
1294
1188
                desc_path = new_path + desc_path[len(old_path):]
1301
1195
            descendants.update(self._limbo_descendants(descendant))
1302
1196
        return descendants
1303
1197
 
1304
 
    def create_file(self, contents, trans_id, mode_id=None, sha1=None):
 
1198
    def create_file(self, contents, trans_id, mode_id=None):
1305
1199
        """Schedule creation of a new file.
1306
1200
 
1307
 
        :seealso: new_file.
1308
 
 
1309
 
        :param contents: an iterator of strings, all of which will be written
1310
 
            to the target destination.
1311
 
        :param trans_id: TreeTransform handle
1312
 
        :param mode_id: If not None, force the mode of the target file to match
1313
 
            the mode of the object referenced by mode_id.
1314
 
            Otherwise, we will try to preserve mode bits of an existing file.
1315
 
        :param sha1: If the sha1 of this content is already known, pass it in.
1316
 
            We can use it to prevent future sha1 computations.
 
1201
        See also new_file.
 
1202
 
 
1203
        Contents is an iterator of strings, all of which will be written
 
1204
        to the target destination.
 
1205
 
 
1206
        New file takes the permissions of any existing file with that id,
 
1207
        unless mode_id is specified.
1317
1208
        """
1318
1209
        name = self._limbo_name(trans_id)
1319
1210
        f = open(name, 'wb')
1320
1211
        try:
1321
 
            unique_add(self._new_contents, trans_id, 'file')
 
1212
            try:
 
1213
                unique_add(self._new_contents, trans_id, 'file')
 
1214
            except:
 
1215
                # Clean up the file, it never got registered so
 
1216
                # TreeTransform.finalize() won't clean it up.
 
1217
                f.close()
 
1218
                os.unlink(name)
 
1219
                raise
 
1220
 
1322
1221
            f.writelines(contents)
1323
1222
        finally:
1324
1223
            f.close()
1325
1224
        self._set_mtime(name)
1326
1225
        self._set_mode(trans_id, mode_id, S_ISREG)
1327
 
        # It is unfortunate we have to use lstat instead of fstat, but we just
1328
 
        # used utime and chmod on the file, so we need the accurate final
1329
 
        # details.
1330
 
        if sha1 is not None:
1331
 
            self._observed_sha1s[trans_id] = (sha1, osutils.lstat(name))
1332
1226
 
1333
1227
    def _read_file_chunks(self, trans_id):
1334
1228
        cur_file = open(self._limbo_name(trans_id), 'rb')
1393
1287
    def cancel_creation(self, trans_id):
1394
1288
        """Cancel the creation of new file contents."""
1395
1289
        del self._new_contents[trans_id]
1396
 
        if trans_id in self._observed_sha1s:
1397
 
            del self._observed_sha1s[trans_id]
1398
1290
        children = self._limbo_children.get(trans_id)
1399
1291
        # if this is a limbo directory with children, move them before removing
1400
1292
        # the directory
1404
1296
            del self._limbo_children_names[trans_id]
1405
1297
        delete_any(self._limbo_name(trans_id))
1406
1298
 
1407
 
    def new_orphan(self, trans_id, parent_id):
1408
 
        # FIXME: There is no tree config, so we use the branch one (it's weird
1409
 
        # to define it this way as orphaning can only occur in a working tree,
1410
 
        # but that's all we have (for now). It will find the option in
1411
 
        # locations.conf or bazaar.conf though) -- vila 20100916
1412
 
        conf = self._tree.branch.get_config()
1413
 
        conf_var_name = 'bzr.transform.orphan_policy'
1414
 
        orphan_policy = conf.get_user_option(conf_var_name)
1415
 
        default_policy = orphaning_registry.default_key
1416
 
        if orphan_policy is None:
1417
 
            orphan_policy = default_policy
1418
 
        if orphan_policy not in orphaning_registry:
1419
 
            trace.warning('%s (from %s) is not a known policy, defaulting '
1420
 
                'to %s' % (orphan_policy, conf_var_name, default_policy))
1421
 
            orphan_policy = default_policy
1422
 
        handle_orphan = orphaning_registry.get(orphan_policy)
1423
 
        handle_orphan(self, trans_id, parent_id)
1424
 
 
1425
 
 
1426
 
class OrphaningError(errors.BzrError):
1427
 
 
1428
 
    # Only bugs could lead to such exception being seen by the user
1429
 
    internal_error = True
1430
 
    _fmt = "Error while orphaning %s in %s directory"
1431
 
 
1432
 
    def __init__(self, orphan, parent):
1433
 
        errors.BzrError.__init__(self)
1434
 
        self.orphan = orphan
1435
 
        self.parent = parent
1436
 
 
1437
 
 
1438
 
class OrphaningForbidden(OrphaningError):
1439
 
 
1440
 
    _fmt = "Policy: %s doesn't allow creating orphans."
1441
 
 
1442
 
    def __init__(self, policy):
1443
 
        errors.BzrError.__init__(self)
1444
 
        self.policy = policy
1445
 
 
1446
 
 
1447
 
def move_orphan(tt, orphan_id, parent_id):
1448
 
    """See TreeTransformBase.new_orphan.
1449
 
 
1450
 
    This creates a new orphan in the `bzr-orphans` dir at the root of the
1451
 
    `TreeTransform`.
1452
 
 
1453
 
    :param tt: The TreeTransform orphaning `trans_id`.
1454
 
 
1455
 
    :param orphan_id: The trans id that should be orphaned.
1456
 
 
1457
 
    :param parent_id: The orphan parent trans id.
1458
 
    """
1459
 
    # Add the orphan dir if it doesn't exist
1460
 
    orphan_dir_basename = 'bzr-orphans'
1461
 
    od_id = tt.trans_id_tree_path(orphan_dir_basename)
1462
 
    if tt.final_kind(od_id) is None:
1463
 
        tt.create_directory(od_id)
1464
 
    parent_path = tt._tree_id_paths[parent_id]
1465
 
    # Find a name that doesn't exist yet in the orphan dir
1466
 
    actual_name = tt.final_name(orphan_id)
1467
 
    new_name = tt._available_backup_name(actual_name, od_id)
1468
 
    tt.adjust_path(new_name, od_id, orphan_id)
1469
 
    trace.warning('%s has been orphaned in %s'
1470
 
                  % (joinpath(parent_path, actual_name), orphan_dir_basename))
1471
 
 
1472
 
 
1473
 
def refuse_orphan(tt, orphan_id, parent_id):
1474
 
    """See TreeTransformBase.new_orphan.
1475
 
 
1476
 
    This refuses to create orphan, letting the caller handle the conflict.
1477
 
    """
1478
 
    raise OrphaningForbidden('never')
1479
 
 
1480
 
 
1481
 
orphaning_registry = registry.Registry()
1482
 
orphaning_registry.register(
1483
 
    'conflict', refuse_orphan,
1484
 
    'Leave orphans in place and create a conflict on the directory.')
1485
 
orphaning_registry.register(
1486
 
    'move', move_orphan,
1487
 
    'Move orphans into the bzr-orphans directory.')
1488
 
orphaning_registry._set_default_key('conflict')
1489
 
 
1490
1299
 
1491
1300
class TreeTransform(DiskTreeTransform):
1492
1301
    """Represent a tree transformation.
1610
1419
    def tree_kind(self, trans_id):
1611
1420
        """Determine the file kind in the working tree.
1612
1421
 
1613
 
        :returns: The file kind or None if the file does not exist
 
1422
        Raises NoSuchFile if the file does not exist
1614
1423
        """
1615
1424
        path = self._tree_id_paths.get(trans_id)
1616
1425
        if path is None:
1617
 
            return None
 
1426
            raise NoSuchFile(None)
1618
1427
        try:
1619
1428
            return file_kind(self._tree.abspath(path))
1620
 
        except errors.NoSuchFile:
1621
 
            return None
 
1429
        except OSError, e:
 
1430
            if e.errno != errno.ENOENT:
 
1431
                raise
 
1432
            else:
 
1433
                raise NoSuchFile(path)
1622
1434
 
1623
1435
    def _set_mode(self, trans_id, mode_id, typefunc):
1624
1436
        """Set the mode of new file contents.
1730
1542
        """
1731
1543
        if not no_conflicts:
1732
1544
            self._check_malformed()
1733
 
        child_pb = ui.ui_factory.nested_progress_bar()
 
1545
        child_pb = bzrlib.ui.ui_factory.nested_progress_bar()
1734
1546
        try:
1735
1547
            if precomputed_delta is None:
1736
1548
                child_pb.update('Apply phase', 0, 2)
1756
1568
        finally:
1757
1569
            child_pb.finished()
1758
1570
        self._tree.apply_inventory_delta(inventory_delta)
1759
 
        self._apply_observed_sha1s()
1760
1571
        self._done = True
1761
1572
        self.finalize()
1762
1573
        return _TransformResults(modified_paths, self.rename_count)
1764
1575
    def _generate_inventory_delta(self):
1765
1576
        """Generate an inventory delta for the current transform."""
1766
1577
        inventory_delta = []
1767
 
        child_pb = ui.ui_factory.nested_progress_bar()
 
1578
        child_pb = bzrlib.ui.ui_factory.nested_progress_bar()
1768
1579
        new_paths = self._inventory_altered()
1769
1580
        total_entries = len(new_paths) + len(self._removed_id)
1770
1581
        try:
1794
1605
                if file_id is None:
1795
1606
                    continue
1796
1607
                needs_entry = False
1797
 
                kind = self.final_kind(trans_id)
1798
 
                if kind is None:
 
1608
                try:
 
1609
                    kind = self.final_kind(trans_id)
 
1610
                except NoSuchFile:
1799
1611
                    kind = self._tree.stored_kind(file_id)
1800
1612
                parent_trans_id = self.final_parent(trans_id)
1801
1613
                parent_file_id = new_path_file_ids.get(parent_trans_id)
1832
1644
        """
1833
1645
        tree_paths = list(self._tree_path_ids.iteritems())
1834
1646
        tree_paths.sort(reverse=True)
1835
 
        child_pb = ui.ui_factory.nested_progress_bar()
 
1647
        child_pb = bzrlib.ui.ui_factory.nested_progress_bar()
1836
1648
        try:
1837
 
            for num, (path, trans_id) in enumerate(tree_paths):
1838
 
                # do not attempt to move root into a subdirectory of itself.
1839
 
                if path == '':
1840
 
                    continue
 
1649
            for num, data in enumerate(tree_paths):
 
1650
                path, trans_id = data
1841
1651
                child_pb.update('removing file', num, len(tree_paths))
1842
1652
                full_path = self._tree.abspath(path)
1843
1653
                if trans_id in self._removed_contents:
1869
1679
        modified_paths = []
1870
1680
        new_path_file_ids = dict((t, self.final_file_id(t)) for p, t in
1871
1681
                                 new_paths)
1872
 
        child_pb = ui.ui_factory.nested_progress_bar()
 
1682
        child_pb = bzrlib.ui.ui_factory.nested_progress_bar()
1873
1683
        try:
1874
1684
            for num, (path, trans_id) in enumerate(new_paths):
1875
1685
                if (num % 10) == 0:
1884
1694
                            raise
1885
1695
                    else:
1886
1696
                        self.rename_count += 1
1887
 
                    # TODO: if trans_id in self._observed_sha1s, we should
1888
 
                    #       re-stat the final target, since ctime will be
1889
 
                    #       updated by the change.
1890
1697
                if (trans_id in self._new_contents or
1891
1698
                    self.path_changed(trans_id)):
1892
1699
                    if trans_id in self._new_contents:
1893
1700
                        modified_paths.append(full_path)
1894
1701
                if trans_id in self._new_executability:
1895
1702
                    self._set_executability(path, trans_id)
1896
 
                if trans_id in self._observed_sha1s:
1897
 
                    o_sha1, o_st_val = self._observed_sha1s[trans_id]
1898
 
                    st = osutils.lstat(full_path)
1899
 
                    self._observed_sha1s[trans_id] = (o_sha1, st)
1900
1703
        finally:
1901
1704
            child_pb.finished()
1902
 
        for path, trans_id in new_paths:
1903
 
            # new_paths includes stuff like workingtree conflicts. Only the
1904
 
            # stuff in new_contents actually comes from limbo.
1905
 
            if trans_id in self._limbo_files:
1906
 
                del self._limbo_files[trans_id]
1907
1705
        self._new_contents.clear()
1908
1706
        return modified_paths
1909
1707
 
1910
 
    def _apply_observed_sha1s(self):
1911
 
        """After we have finished renaming everything, update observed sha1s
1912
 
 
1913
 
        This has to be done after self._tree.apply_inventory_delta, otherwise
1914
 
        it doesn't know anything about the files we are updating. Also, we want
1915
 
        to do this as late as possible, so that most entries end up cached.
1916
 
        """
1917
 
        # TODO: this doesn't update the stat information for directories. So
1918
 
        #       the first 'bzr status' will still need to rewrite
1919
 
        #       .bzr/checkout/dirstate. However, we at least don't need to
1920
 
        #       re-read all of the files.
1921
 
        # TODO: If the operation took a while, we could do a time.sleep(3) here
1922
 
        #       to allow the clock to tick over and ensure we won't have any
1923
 
        #       problems. (we could observe start time, and finish time, and if
1924
 
        #       it is less than eg 10% overhead, add a sleep call.)
1925
 
        paths = FinalPaths(self)
1926
 
        for trans_id, observed in self._observed_sha1s.iteritems():
1927
 
            path = paths.get_path(trans_id)
1928
 
            # We could get the file_id, but dirstate prefers to use the path
1929
 
            # anyway, and it is 'cheaper' to determine.
1930
 
            # file_id = self._new_id[trans_id]
1931
 
            self._tree._observed_sha1(None, path, observed)
1932
 
 
1933
1708
 
1934
1709
class TransformPreview(DiskTreeTransform):
1935
1710
    """A TreeTransform for generating preview trees.
1950
1725
    def tree_kind(self, trans_id):
1951
1726
        path = self._tree_id_paths.get(trans_id)
1952
1727
        if path is None:
1953
 
            return None
1954
 
        kind = self._tree.path_content_summary(path)[0]
1955
 
        if kind == 'missing':
1956
 
            kind = None
1957
 
        return kind
 
1728
            raise NoSuchFile(None)
 
1729
        file_id = self._tree.path2id(path)
 
1730
        return self._tree.kind(file_id)
1958
1731
 
1959
1732
    def _set_mode(self, trans_id, mode_id, typefunc):
1960
1733
        """Set the mode of new file contents.
1980
1753
            childpath = joinpath(path, child)
1981
1754
            yield self.trans_id_tree_path(childpath)
1982
1755
 
1983
 
    def new_orphan(self, trans_id, parent_id):
1984
 
        raise NotImplementedError(self.new_orphan)
1985
 
 
1986
 
 
1987
 
class _PreviewTree(tree.InventoryTree):
 
1756
 
 
1757
class _PreviewTree(tree.Tree):
1988
1758
    """Partial implementation of Tree to support show_diff_trees"""
1989
1759
 
1990
1760
    def __init__(self, transform):
2019
1789
                yield self._get_repository().revision_tree(revision_id)
2020
1790
 
2021
1791
    def _get_file_revision(self, file_id, vf, tree_revision):
2022
 
        parent_keys = [(file_id, t.get_file_revision(file_id)) for t in
 
1792
        parent_keys = [(file_id, self._file_revision(t, file_id)) for t in
2023
1793
                       self._iter_parent_trees()]
2024
1794
        vf.add_lines((file_id, tree_revision), parent_keys,
2025
1795
                     self.get_file_lines(file_id))
2029
1799
            vf.fallback_versionedfiles.append(base_vf)
2030
1800
        return tree_revision
2031
1801
 
2032
 
    def _stat_limbo_file(self, file_id=None, trans_id=None):
2033
 
        if trans_id is None:
2034
 
            trans_id = self._transform.trans_id_file_id(file_id)
 
1802
    def _stat_limbo_file(self, file_id):
 
1803
        trans_id = self._transform.trans_id_file_id(file_id)
2035
1804
        name = self._transform._limbo_name(trans_id)
2036
1805
        return os.lstat(name)
2037
1806
 
2160
1929
            if (specific_file_ids is not None
2161
1930
                and file_id not in specific_file_ids):
2162
1931
                continue
2163
 
            kind = self._transform.final_kind(trans_id)
2164
 
            if kind is None:
 
1932
            try:
 
1933
                kind = self._transform.final_kind(trans_id)
 
1934
            except NoSuchFile:
2165
1935
                kind = self._transform._tree.stored_kind(file_id)
2166
1936
            new_entry = inventory.make_entry(
2167
1937
                kind,
2252
2022
 
2253
2023
    def get_file_size(self, file_id):
2254
2024
        """See Tree.get_file_size"""
2255
 
        trans_id = self._transform.trans_id_file_id(file_id)
2256
 
        kind = self._transform.final_kind(trans_id)
2257
 
        if kind != 'file':
2258
 
            return None
2259
 
        if trans_id in self._transform._new_contents:
2260
 
            return self._stat_limbo_file(trans_id=trans_id).st_size
2261
2025
        if self.kind(file_id) == 'file':
2262
2026
            return self._transform._tree.get_file_size(file_id)
2263
2027
        else:
2291
2055
            except errors.NoSuchId:
2292
2056
                return False
2293
2057
 
2294
 
    def has_filename(self, path):
2295
 
        trans_id = self._path2trans_id(path)
2296
 
        if trans_id in self._transform._new_contents:
2297
 
            return True
2298
 
        elif trans_id in self._transform._removed_contents:
2299
 
            return False
2300
 
        else:
2301
 
            return self._transform._tree.has_filename(path)
2302
 
 
2303
2058
    def path_content_summary(self, path):
2304
2059
        trans_id = self._path2trans_id(path)
2305
2060
        tt = self._transform
2393
2148
                                   self.get_file(file_id).readlines(),
2394
2149
                                   default_revision)
2395
2150
 
2396
 
    def get_symlink_target(self, file_id, path=None):
 
2151
    def get_symlink_target(self, file_id):
2397
2152
        """See Tree.get_symlink_target"""
2398
2153
        if not self._content_change(file_id):
2399
2154
            return self._transform._tree.get_symlink_target(file_id)
2414
2169
                path_from_root = self._final_paths.get_path(child_id)
2415
2170
                basename = self._transform.final_name(child_id)
2416
2171
                file_id = self._transform.final_file_id(child_id)
2417
 
                kind  = self._transform.final_kind(child_id)
2418
 
                if kind is not None:
 
2172
                try:
 
2173
                    kind = self._transform.final_kind(child_id)
2419
2174
                    versioned_kind = kind
2420
 
                else:
 
2175
                except NoSuchFile:
2421
2176
                    kind = 'unknown'
2422
2177
                    versioned_kind = self._transform._tree.stored_kind(file_id)
2423
2178
                if versioned_kind == 'directory':
2537
2292
        if num > 0:  # more than just a root
2538
2293
            raise errors.WorkingTreeAlreadyPopulated(base=wt.basedir)
2539
2294
    file_trans_id = {}
2540
 
    top_pb = ui.ui_factory.nested_progress_bar()
 
2295
    top_pb = bzrlib.ui.ui_factory.nested_progress_bar()
2541
2296
    pp = ProgressPhase("Build phase", 2, top_pb)
2542
2297
    if tree.inventory.root is not None:
2543
2298
        # This is kind of a hack: we should be altering the root
2556
2311
        pp.next_phase()
2557
2312
        file_trans_id[wt.get_root_id()] = \
2558
2313
            tt.trans_id_tree_file_id(wt.get_root_id())
2559
 
        pb = ui.ui_factory.nested_progress_bar()
 
2314
        pb = bzrlib.ui.ui_factory.nested_progress_bar()
2560
2315
        try:
2561
2316
            deferred_contents = []
2562
2317
            num = 0
2609
2364
                    executable = tree.is_executable(file_id, tree_path)
2610
2365
                    if executable:
2611
2366
                        tt.set_executability(executable, trans_id)
2612
 
                    trans_data = (trans_id, tree_path, entry.text_sha1)
 
2367
                    trans_data = (trans_id, tree_path)
2613
2368
                    deferred_contents.append((file_id, trans_data))
2614
2369
                else:
2615
2370
                    file_trans_id[file_id] = new_by_entry(tt, entry, parent_id,
2631
2386
            precomputed_delta = None
2632
2387
        conflicts = cook_conflicts(raw_conflicts, tt)
2633
2388
        for conflict in conflicts:
2634
 
            trace.warning(unicode(conflict))
 
2389
            warning(conflict)
2635
2390
        try:
2636
2391
            wt.add_conflicts(conflicts)
2637
2392
        except errors.UnsupportedOperation:
2660
2415
        unchanged = dict(unchanged)
2661
2416
        new_desired_files = []
2662
2417
        count = 0
2663
 
        for file_id, (trans_id, tree_path, text_sha1) in desired_files:
 
2418
        for file_id, (trans_id, tree_path) in desired_files:
2664
2419
            accelerator_path = unchanged.get(file_id)
2665
2420
            if accelerator_path is None:
2666
 
                new_desired_files.append((file_id,
2667
 
                    (trans_id, tree_path, text_sha1)))
 
2421
                new_desired_files.append((file_id, (trans_id, tree_path)))
2668
2422
                continue
2669
2423
            pb.update('Adding file contents', count + offset, total)
2670
2424
            if hardlink:
2677
2431
                    contents = filtered_output_bytes(contents, filters,
2678
2432
                        ContentFilterContext(tree_path, tree))
2679
2433
                try:
2680
 
                    tt.create_file(contents, trans_id, sha1=text_sha1)
 
2434
                    tt.create_file(contents, trans_id)
2681
2435
                finally:
2682
2436
                    try:
2683
2437
                        contents.close()
2686
2440
                        pass
2687
2441
            count += 1
2688
2442
        offset += count
2689
 
    for count, ((trans_id, tree_path, text_sha1), contents) in enumerate(
 
2443
    for count, ((trans_id, tree_path), contents) in enumerate(
2690
2444
            tree.iter_files_bytes(new_desired_files)):
2691
2445
        if wt.supports_content_filtering():
2692
2446
            filters = wt._content_filter_stack(tree_path)
2693
2447
            contents = filtered_output_bytes(contents, filters,
2694
2448
                ContentFilterContext(tree_path, tree))
2695
 
        tt.create_file(contents, trans_id, sha1=text_sha1)
 
2449
        tt.create_file(contents, trans_id)
2696
2450
        pb.update('Adding file contents', count + offset, total)
2697
2451
 
2698
2452
 
2700
2454
    for child in tt.iter_tree_children(old_parent):
2701
2455
        tt.adjust_path(tt.final_name(child), new_parent, child)
2702
2456
 
2703
 
 
2704
2457
def _reparent_transform_children(tt, old_parent, new_parent):
2705
2458
    by_parent = tt.by_parent()
2706
2459
    for child in by_parent[old_parent]:
2707
2460
        tt.adjust_path(tt.final_name(child), new_parent, child)
2708
2461
    return by_parent[old_parent]
2709
2462
 
2710
 
 
2711
2463
def _content_match(tree, entry, file_id, kind, target_path):
2712
2464
    if entry.kind != kind:
2713
2465
        return False
2777
2529
        raise errors.BadFileKindError(name, kind)
2778
2530
 
2779
2531
 
 
2532
@deprecated_function(deprecated_in((1, 9, 0)))
 
2533
def create_by_entry(tt, entry, tree, trans_id, lines=None, mode_id=None):
 
2534
    """Create new file contents according to an inventory entry.
 
2535
 
 
2536
    DEPRECATED.  Use create_from_tree instead.
 
2537
    """
 
2538
    if entry.kind == "file":
 
2539
        if lines is None:
 
2540
            lines = tree.get_file(entry.file_id).readlines()
 
2541
        tt.create_file(lines, trans_id, mode_id=mode_id)
 
2542
    elif entry.kind == "symlink":
 
2543
        tt.create_symlink(tree.get_symlink_target(entry.file_id), trans_id)
 
2544
    elif entry.kind == "directory":
 
2545
        tt.create_directory(trans_id)
 
2546
 
 
2547
 
2780
2548
def create_from_tree(tt, trans_id, tree, file_id, bytes=None,
2781
2549
    filter_tree_path=None):
2782
2550
    """Create new file contents according to tree contents.
2813
2581
        tt.set_executability(entry.executable, trans_id)
2814
2582
 
2815
2583
 
2816
 
@deprecated_function(deprecated_in((2, 3, 0)))
2817
2584
def get_backup_name(entry, by_parent, parent_trans_id, tt):
2818
2585
    return _get_backup_name(entry.name, by_parent, parent_trans_id, tt)
2819
2586
 
2820
2587
 
2821
 
@deprecated_function(deprecated_in((2, 3, 0)))
2822
2588
def _get_backup_name(name, by_parent, parent_trans_id, tt):
2823
2589
    """Produce a backup-style name that appears to be available"""
2824
2590
    def name_gen():
2873
2639
                unversioned_filter=working_tree.is_ignored)
2874
2640
            delta.report_changes(tt.iter_changes(), change_reporter)
2875
2641
        for conflict in conflicts:
2876
 
            trace.warning(unicode(conflict))
 
2642
            warning(conflict)
2877
2643
        pp.next_phase()
2878
2644
        tt.apply()
2879
2645
        working_tree.set_merge_modified(merge_modified)
2887
2653
def _prepare_revert_transform(working_tree, target_tree, tt, filenames,
2888
2654
                              backups, pp, basis_tree=None,
2889
2655
                              merge_modified=None):
2890
 
    child_pb = ui.ui_factory.nested_progress_bar()
 
2656
    child_pb = bzrlib.ui.ui_factory.nested_progress_bar()
2891
2657
    try:
2892
2658
        if merge_modified is None:
2893
2659
            merge_modified = working_tree.merge_modified()
2896
2662
                                      merge_modified, basis_tree)
2897
2663
    finally:
2898
2664
        child_pb.finished()
2899
 
    child_pb = ui.ui_factory.nested_progress_bar()
 
2665
    child_pb = bzrlib.ui.ui_factory.nested_progress_bar()
2900
2666
    try:
2901
2667
        raw_conflicts = resolve_conflicts(tt, child_pb,
2902
2668
            lambda t, c: conflict_pass(t, c, target_tree))
2910
2676
                 backups, merge_modified, basis_tree=None):
2911
2677
    if basis_tree is not None:
2912
2678
        basis_tree.lock_read()
2913
 
    # We ask the working_tree for its changes relative to the target, rather
2914
 
    # than the target changes relative to the working tree. Because WT4 has an
2915
 
    # optimizer to compare itself to a target, but no optimizer for the
2916
 
    # reverse.
2917
 
    change_list = working_tree.iter_changes(target_tree,
 
2679
    change_list = target_tree.iter_changes(working_tree,
2918
2680
        specific_files=specific_files, pb=pb)
2919
2681
    if target_tree.get_root_id() is None:
2920
2682
        skip_root = True
2924
2686
        deferred_files = []
2925
2687
        for id_num, (file_id, path, changed_content, versioned, parent, name,
2926
2688
                kind, executable) in enumerate(change_list):
2927
 
            target_path, wt_path = path
2928
 
            target_versioned, wt_versioned = versioned
2929
 
            target_parent, wt_parent = parent
2930
 
            target_name, wt_name = name
2931
 
            target_kind, wt_kind = kind
2932
 
            target_executable, wt_executable = executable
2933
 
            if skip_root and wt_parent is None:
 
2689
            if skip_root and file_id[0] is not None and parent[0] is None:
2934
2690
                continue
2935
2691
            trans_id = tt.trans_id_file_id(file_id)
2936
2692
            mode_id = None
2937
2693
            if changed_content:
2938
2694
                keep_content = False
2939
 
                if wt_kind == 'file' and (backups or target_kind is None):
 
2695
                if kind[0] == 'file' and (backups or kind[1] is None):
2940
2696
                    wt_sha1 = working_tree.get_file_sha1(file_id)
2941
2697
                    if merge_modified.get(file_id) != wt_sha1:
2942
2698
                        # acquire the basis tree lazily to prevent the
2945
2701
                        if basis_tree is None:
2946
2702
                            basis_tree = working_tree.basis_tree()
2947
2703
                            basis_tree.lock_read()
2948
 
                        if basis_tree.has_id(file_id):
 
2704
                        if file_id in basis_tree:
2949
2705
                            if wt_sha1 != basis_tree.get_file_sha1(file_id):
2950
2706
                                keep_content = True
2951
 
                        elif target_kind is None and not target_versioned:
 
2707
                        elif kind[1] is None and not versioned[1]:
2952
2708
                            keep_content = True
2953
 
                if wt_kind is not None:
 
2709
                if kind[0] is not None:
2954
2710
                    if not keep_content:
2955
2711
                        tt.delete_contents(trans_id)
2956
 
                    elif target_kind is not None:
2957
 
                        parent_trans_id = tt.trans_id_file_id(wt_parent)
2958
 
                        backup_name = tt._available_backup_name(
2959
 
                            wt_name, parent_trans_id)
 
2712
                    elif kind[1] is not None:
 
2713
                        parent_trans_id = tt.trans_id_file_id(parent[0])
 
2714
                        by_parent = tt.by_parent()
 
2715
                        backup_name = _get_backup_name(name[0], by_parent,
 
2716
                                                       parent_trans_id, tt)
2960
2717
                        tt.adjust_path(backup_name, parent_trans_id, trans_id)
2961
 
                        new_trans_id = tt.create_path(wt_name, parent_trans_id)
2962
 
                        if wt_versioned and target_versioned:
 
2718
                        new_trans_id = tt.create_path(name[0], parent_trans_id)
 
2719
                        if versioned == (True, True):
2963
2720
                            tt.unversion_file(trans_id)
2964
2721
                            tt.version_file(file_id, new_trans_id)
2965
2722
                        # New contents should have the same unix perms as old
2966
2723
                        # contents
2967
2724
                        mode_id = trans_id
2968
2725
                        trans_id = new_trans_id
2969
 
                if target_kind in ('directory', 'tree-reference'):
 
2726
                if kind[1] in ('directory', 'tree-reference'):
2970
2727
                    tt.create_directory(trans_id)
2971
 
                    if target_kind == 'tree-reference':
 
2728
                    if kind[1] == 'tree-reference':
2972
2729
                        revision = target_tree.get_reference_revision(file_id,
2973
 
                                                                      target_path)
 
2730
                                                                      path[1])
2974
2731
                        tt.set_tree_reference(revision, trans_id)
2975
 
                elif target_kind == 'symlink':
 
2732
                elif kind[1] == 'symlink':
2976
2733
                    tt.create_symlink(target_tree.get_symlink_target(file_id),
2977
2734
                                      trans_id)
2978
 
                elif target_kind == 'file':
 
2735
                elif kind[1] == 'file':
2979
2736
                    deferred_files.append((file_id, (trans_id, mode_id)))
2980
2737
                    if basis_tree is None:
2981
2738
                        basis_tree = working_tree.basis_tree()
2982
2739
                        basis_tree.lock_read()
2983
2740
                    new_sha1 = target_tree.get_file_sha1(file_id)
2984
 
                    if (basis_tree.has_id(file_id) and
2985
 
                        new_sha1 == basis_tree.get_file_sha1(file_id)):
 
2741
                    if (file_id in basis_tree and new_sha1 ==
 
2742
                        basis_tree.get_file_sha1(file_id)):
2986
2743
                        if file_id in merge_modified:
2987
2744
                            del merge_modified[file_id]
2988
2745
                    else:
2989
2746
                        merge_modified[file_id] = new_sha1
2990
2747
 
2991
2748
                    # preserve the execute bit when backing up
2992
 
                    if keep_content and wt_executable == target_executable:
2993
 
                        tt.set_executability(target_executable, trans_id)
2994
 
                elif target_kind is not None:
2995
 
                    raise AssertionError(target_kind)
2996
 
            if not wt_versioned and target_versioned:
 
2749
                    if keep_content and executable[0] == executable[1]:
 
2750
                        tt.set_executability(executable[1], trans_id)
 
2751
                elif kind[1] is not None:
 
2752
                    raise AssertionError(kind[1])
 
2753
            if versioned == (False, True):
2997
2754
                tt.version_file(file_id, trans_id)
2998
 
            if wt_versioned and not target_versioned:
 
2755
            if versioned == (True, False):
2999
2756
                tt.unversion_file(trans_id)
3000
 
            if (target_name is not None and
3001
 
                (wt_name != target_name or wt_parent != target_parent)):
3002
 
                if target_name == '' and target_parent is None:
 
2757
            if (name[1] is not None and
 
2758
                (name[0] != name[1] or parent[0] != parent[1])):
 
2759
                if name[1] == '' and parent[1] is None:
3003
2760
                    parent_trans = ROOT_PARENT
3004
2761
                else:
3005
 
                    parent_trans = tt.trans_id_file_id(target_parent)
3006
 
                if wt_parent is None and wt_versioned:
3007
 
                    tt.adjust_root_path(target_name, parent_trans)
 
2762
                    parent_trans = tt.trans_id_file_id(parent[1])
 
2763
                if parent[0] is None and versioned[0]:
 
2764
                    tt.adjust_root_path(name[1], parent_trans)
3008
2765
                else:
3009
 
                    tt.adjust_path(target_name, parent_trans, trans_id)
3010
 
            if wt_executable != target_executable and target_kind == "file":
3011
 
                tt.set_executability(target_executable, trans_id)
 
2766
                    tt.adjust_path(name[1], parent_trans, trans_id)
 
2767
            if executable[0] != executable[1] and kind[1] == "file":
 
2768
                tt.set_executability(executable[1], trans_id)
3012
2769
        if working_tree.supports_content_filtering():
3013
2770
            for index, ((trans_id, mode_id), bytes) in enumerate(
3014
2771
                target_tree.iter_files_bytes(deferred_files)):
3085
2842
 
3086
2843
        elif c_type == 'missing parent':
3087
2844
            trans_id = conflict[1]
3088
 
            if trans_id in tt._removed_contents:
3089
 
                cancel_deletion = True
3090
 
                orphans = tt._get_potential_orphans(trans_id)
3091
 
                if orphans:
3092
 
                    cancel_deletion = False
3093
 
                    # All children are orphans
3094
 
                    for o in orphans:
3095
 
                        try:
3096
 
                            tt.new_orphan(o, trans_id)
3097
 
                        except OrphaningError:
3098
 
                            # Something bad happened so we cancel the directory
3099
 
                            # deletion which will leave it in place with a
3100
 
                            # conflict. The user can deal with it from there.
3101
 
                            # Note that this also catch the case where we don't
3102
 
                            # want to create orphans and leave the directory in
3103
 
                            # place.
3104
 
                            cancel_deletion = True
3105
 
                            break
3106
 
                if cancel_deletion:
3107
 
                    # Cancel the directory deletion
3108
 
                    tt.cancel_deletion(trans_id)
3109
 
                    new_conflicts.add(('deleting parent', 'Not deleting',
3110
 
                                       trans_id))
3111
 
            else:
 
2845
            try:
 
2846
                tt.cancel_deletion(trans_id)
 
2847
                new_conflicts.add(('deleting parent', 'Not deleting',
 
2848
                                   trans_id))
 
2849
            except KeyError:
3112
2850
                create = True
3113
2851
                try:
3114
2852
                    tt.final_name(trans_id)
3117
2855
                        file_id = tt.final_file_id(trans_id)
3118
2856
                        if file_id is None:
3119
2857
                            file_id = tt.inactive_file_id(trans_id)
3120
 
                        _, entry = path_tree.iter_entries_by_dir(
3121
 
                            [file_id]).next()
 
2858
                        entry = path_tree.inventory[file_id]
3122
2859
                        # special-case the other tree root (move its
3123
2860
                        # children to current root)
3124
2861
                        if entry.parent_id is None:
3139
2876
        elif c_type == 'unversioned parent':
3140
2877
            file_id = tt.inactive_file_id(conflict[1])
3141
2878
            # special-case the other tree root (move its children instead)
3142
 
            if path_tree and path_tree.has_id(file_id):
3143
 
                if path_tree.path2id('') == file_id:
3144
 
                    # This is the root entry, skip it
 
2879
            if path_tree and file_id in path_tree:
 
2880
                if path_tree.inventory[file_id].parent_id is None:
3145
2881
                    continue
3146
2882
            tt.version_file(file_id, conflict[1])
3147
2883
            new_conflicts.add((c_type, 'Versioned directory', conflict[1]))
3163
2899
 
3164
2900
def cook_conflicts(raw_conflicts, tt):
3165
2901
    """Generate a list of cooked conflicts, sorted by file path"""
 
2902
    from bzrlib.conflicts import Conflict
3166
2903
    conflict_iter = iter_cook_conflicts(raw_conflicts, tt)
3167
 
    return sorted(conflict_iter, key=conflicts.Conflict.sort_key)
 
2904
    return sorted(conflict_iter, key=Conflict.sort_key)
3168
2905
 
3169
2906
 
3170
2907
def iter_cook_conflicts(raw_conflicts, tt):
 
2908
    from bzrlib.conflicts import Conflict
3171
2909
    fp = FinalPaths(tt)
3172
2910
    for conflict in raw_conflicts:
3173
2911
        c_type = conflict[0]
3175
2913
        modified_path = fp.get_path(conflict[2])
3176
2914
        modified_id = tt.final_file_id(conflict[2])
3177
2915
        if len(conflict) == 3:
3178
 
            yield conflicts.Conflict.factory(
3179
 
                c_type, action=action, path=modified_path, file_id=modified_id)
 
2916
            yield Conflict.factory(c_type, action=action, path=modified_path,
 
2917
                                     file_id=modified_id)
3180
2918
 
3181
2919
        else:
3182
2920
            conflicting_path = fp.get_path(conflict[3])
3183
2921
            conflicting_id = tt.final_file_id(conflict[3])
3184
 
            yield conflicts.Conflict.factory(
3185
 
                c_type, action=action, path=modified_path,
3186
 
                file_id=modified_id,
3187
 
                conflict_path=conflicting_path,
3188
 
                conflict_file_id=conflicting_id)
 
2922
            yield Conflict.factory(c_type, action=action, path=modified_path,
 
2923
                                   file_id=modified_id,
 
2924
                                   conflict_path=conflicting_path,
 
2925
                                   conflict_file_id=conflicting_id)
3189
2926
 
3190
2927
 
3191
2928
class _FileMover(object):
3198
2935
    def rename(self, from_, to):
3199
2936
        """Rename a file from one path to another."""
3200
2937
        try:
3201
 
            os.rename(from_, to)
3202
 
        except OSError, e:
 
2938
            osutils.rename(from_, to)
 
2939
        except (IOError, OSError), e:
3203
2940
            if e.errno in (errno.EEXIST, errno.ENOTEMPTY):
3204
2941
                raise errors.FileExists(to, str(e))
3205
2942
            # normal OSError doesn't include filenames so it's hard to see where
3221
2958
        """Reverse all renames that have been performed"""
3222
2959
        for from_, to in reversed(self.past_renames):
3223
2960
            try:
3224
 
                os.rename(to, from_)
3225
 
            except OSError, e:
3226
 
                raise errors.TransformRenameFailed(to, from_, str(e), e.errno)
 
2961
                osutils.rename(to, from_)
 
2962
            except (OSError, IOError), e:
 
2963
                raise errors.TransformRenameFailed(to, from_, str(e), e.errno)                
3227
2964
        # after rollback, don't reuse _FileMover
3228
2965
        past_renames = None
3229
2966
        pending_deletions = None