~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transform.py

  • Committer: Gordon Tyler
  • Date: 2010-02-02 06:30:43 UTC
  • mto: (5037.3.1 integration)
  • mto: This revision was merged to the branch mainline in revision 5046.
  • Revision ID: gordon@doxxx.net-20100202063043-3ygr1114d25m3f7m
Added cmdline.split function, which replaces commands.shlex_split_unicode.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006, 2007, 2008 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
17
17
import os
18
18
import errno
19
19
from stat import S_ISREG, S_IEXEC
 
20
import time
20
21
 
21
22
from bzrlib.lazy_import import lazy_import
22
23
lazy_import(globals(), """
23
24
from bzrlib import (
24
25
    annotate,
 
26
    bencode,
25
27
    bzrdir,
26
28
    delta,
27
29
    errors,
30
32
    osutils,
31
33
    revision as _mod_revision,
32
34
    )
33
 
from bzrlib.util import bencode
34
35
""")
35
36
from bzrlib.errors import (DuplicateKey, MalformedTransform, NoSuchFile,
36
37
                           ReusingTransform, NotVersionedError, CantMoveRoot,
76
77
 
77
78
 
78
79
class TreeTransformBase(object):
79
 
    """The base class for TreeTransform and TreeTransformBase"""
 
80
    """The base class for TreeTransform and its kin."""
80
81
 
81
 
    def __init__(self, tree, limbodir, pb=DummyProgress(),
 
82
    def __init__(self, tree, pb=DummyProgress(),
82
83
                 case_sensitive=True):
83
84
        """Constructor.
84
85
 
85
86
        :param tree: The tree that will be transformed, but not necessarily
86
87
            the output tree.
87
 
        :param limbodir: A directory where new files can be stored until
88
 
            they are installed in their proper places
89
 
        :param pb: A ProgressBar indicating how much progress is being made
 
88
        :param pb: A ProgressTask indicating how much progress is being made
90
89
        :param case_sensitive: If True, the target of the transform is
91
90
            case sensitive, not just case preserving.
92
91
        """
93
92
        object.__init__(self)
94
93
        self._tree = tree
95
 
        self._limbodir = limbodir
96
 
        self._deletiondir = None
97
94
        self._id_number = 0
98
95
        # mapping of trans_id -> new basename
99
96
        self._new_name = {}
101
98
        self._new_parent = {}
102
99
        # mapping of trans_id with new contents -> new file_kind
103
100
        self._new_contents = {}
104
 
        # A mapping of transform ids to their limbo filename
105
 
        self._limbo_files = {}
106
 
        # A mapping of transform ids to a set of the transform ids of children
107
 
        # that their limbo directory has
108
 
        self._limbo_children = {}
109
 
        # Map transform ids to maps of child filename to child transform id
110
 
        self._limbo_children_names = {}
111
 
        # List of transform ids that need to be renamed from limbo into place
112
 
        self._needs_rename = set()
113
101
        # Set of trans_ids whose contents will be removed
114
102
        self._removed_contents = set()
115
103
        # Mapping of trans_id -> new execute-bit value
128
116
        self._tree_path_ids = {}
129
117
        # Mapping trans_id -> path in old tree
130
118
        self._tree_id_paths = {}
131
 
        # Cache of realpath results, to speed up canonical_path
132
 
        self._realpaths = {}
133
 
        # Cache of relpath results, to speed up canonical_path
134
 
        self._relpaths = {}
135
119
        # The trans_id that will be used as the tree root
136
120
        root_id = tree.get_root_id()
137
121
        if root_id is not None:
147
131
        # A counter of how many files have been renamed
148
132
        self.rename_count = 0
149
133
 
 
134
    def finalize(self):
 
135
        """Release the working tree lock, if held.
 
136
 
 
137
        This is required if apply has not been invoked, but can be invoked
 
138
        even after apply.
 
139
        """
 
140
        if self._tree is None:
 
141
            return
 
142
        self._tree.unlock()
 
143
        self._tree = None
 
144
 
150
145
    def __get_root(self):
151
146
        return self._new_root
152
147
 
153
148
    root = property(__get_root)
154
149
 
155
 
    def finalize(self):
156
 
        """Release the working tree lock, if held, clean up limbo dir.
157
 
 
158
 
        This is required if apply has not been invoked, but can be invoked
159
 
        even after apply.
160
 
        """
161
 
        if self._tree is None:
162
 
            return
163
 
        try:
164
 
            entries = [(self._limbo_name(t), t, k) for t, k in
165
 
                       self._new_contents.iteritems()]
166
 
            entries.sort(reverse=True)
167
 
            for path, trans_id, kind in entries:
168
 
                if kind == "directory":
169
 
                    os.rmdir(path)
170
 
                else:
171
 
                    os.unlink(path)
172
 
            try:
173
 
                os.rmdir(self._limbodir)
174
 
            except OSError:
175
 
                # We don't especially care *why* the dir is immortal.
176
 
                raise ImmortalLimbo(self._limbodir)
177
 
            try:
178
 
                if self._deletiondir is not None:
179
 
                    os.rmdir(self._deletiondir)
180
 
            except OSError:
181
 
                raise errors.ImmortalPendingDeletion(self._deletiondir)
182
 
        finally:
183
 
            self._tree.unlock()
184
 
            self._tree = None
185
 
 
186
150
    def _assign_id(self):
187
151
        """Produce a new tranform id"""
188
152
        new_id = "new-%s" % self._id_number
198
162
 
199
163
    def adjust_path(self, name, parent, trans_id):
200
164
        """Change the path that is assigned to a transaction id."""
 
165
        if parent is None:
 
166
            raise ValueError("Parent trans-id may not be None")
201
167
        if trans_id == self._new_root:
202
168
            raise CantMoveRoot
203
 
        previous_parent = self._new_parent.get(trans_id)
204
 
        previous_name = self._new_name.get(trans_id)
205
169
        self._new_name[trans_id] = name
206
170
        self._new_parent[trans_id] = parent
207
 
        if parent == ROOT_PARENT:
208
 
            if self._new_root is not None:
209
 
                raise ValueError("Cannot have multiple roots.")
210
 
            self._new_root = trans_id
211
 
        if (trans_id in self._limbo_files and
212
 
            trans_id not in self._needs_rename):
213
 
            self._rename_in_limbo([trans_id])
214
 
            self._limbo_children[previous_parent].remove(trans_id)
215
 
            del self._limbo_children_names[previous_parent][previous_name]
216
 
 
217
 
    def _rename_in_limbo(self, trans_ids):
218
 
        """Fix limbo names so that the right final path is produced.
219
 
 
220
 
        This means we outsmarted ourselves-- we tried to avoid renaming
221
 
        these files later by creating them with their final names in their
222
 
        final parents.  But now the previous name or parent is no longer
223
 
        suitable, so we have to rename them.
224
 
 
225
 
        Even for trans_ids that have no new contents, we must remove their
226
 
        entries from _limbo_files, because they are now stale.
227
 
        """
228
 
        for trans_id in trans_ids:
229
 
            old_path = self._limbo_files.pop(trans_id)
230
 
            if trans_id not in self._new_contents:
231
 
                continue
232
 
            new_path = self._limbo_name(trans_id)
233
 
            os.rename(old_path, new_path)
234
171
 
235
172
    def adjust_root_path(self, name, parent):
236
173
        """Emulate moving the root by moving all children, instead.
264
201
        self.version_file(old_root_file_id, old_root)
265
202
        self.unversion_file(self._new_root)
266
203
 
 
204
    def fixup_new_roots(self):
 
205
        """Reinterpret requests to change the root directory
 
206
 
 
207
        Instead of creating a root directory, or moving an existing directory,
 
208
        all the attributes and children of the new root are applied to the
 
209
        existing root directory.
 
210
 
 
211
        This means that the old root trans-id becomes obsolete, so it is
 
212
        recommended only to invoke this after the root trans-id has become
 
213
        irrelevant.
 
214
        """
 
215
        new_roots = [k for k, v in self._new_parent.iteritems() if v is
 
216
                     ROOT_PARENT]
 
217
        if len(new_roots) < 1:
 
218
            return
 
219
        if len(new_roots) != 1:
 
220
            raise ValueError('A tree cannot have two roots!')
 
221
        if self._new_root is None:
 
222
            self._new_root = new_roots[0]
 
223
            return
 
224
        old_new_root = new_roots[0]
 
225
        # TODO: What to do if a old_new_root is present, but self._new_root is
 
226
        #       not listed as being removed? This code explicitly unversions
 
227
        #       the old root and versions it with the new file_id. Though that
 
228
        #       seems like an incomplete delta
 
229
 
 
230
        # unversion the new root's directory.
 
231
        file_id = self.final_file_id(old_new_root)
 
232
        if old_new_root in self._new_id:
 
233
            self.cancel_versioning(old_new_root)
 
234
        else:
 
235
            self.unversion_file(old_new_root)
 
236
        # if, at this stage, root still has an old file_id, zap it so we can
 
237
        # stick a new one in.
 
238
        if (self.tree_file_id(self._new_root) is not None and
 
239
            self._new_root not in self._removed_id):
 
240
            self.unversion_file(self._new_root)
 
241
        self.version_file(file_id, self._new_root)
 
242
 
 
243
        # Now move children of new root into old root directory.
 
244
        # Ensure all children are registered with the transaction, but don't
 
245
        # use directly-- some tree children have new parents
 
246
        list(self.iter_tree_children(old_new_root))
 
247
        # Move all children of new root into old root directory.
 
248
        for child in self.by_parent().get(old_new_root, []):
 
249
            self.adjust_path(self.final_name(child), self._new_root, child)
 
250
 
 
251
        # Ensure old_new_root has no directory.
 
252
        if old_new_root in self._new_contents:
 
253
            self.cancel_creation(old_new_root)
 
254
        else:
 
255
            self.delete_contents(old_new_root)
 
256
 
 
257
        # prevent deletion of root directory.
 
258
        if self._new_root in self._removed_contents:
 
259
            self.cancel_deletion(self._new_root)
 
260
 
 
261
        # destroy path info for old_new_root.
 
262
        del self._new_parent[old_new_root]
 
263
        del self._new_name[old_new_root]
 
264
 
267
265
    def trans_id_tree_file_id(self, inventory_id):
268
266
        """Determine the transaction id of a working tree file.
269
267
 
298
296
            else:
299
297
                return self.trans_id_tree_file_id(file_id)
300
298
 
301
 
    def canonical_path(self, path):
302
 
        """Get the canonical tree-relative path"""
303
 
        # don't follow final symlinks
304
 
        abs = self._tree.abspath(path)
305
 
        if abs in self._relpaths:
306
 
            return self._relpaths[abs]
307
 
        dirname, basename = os.path.split(abs)
308
 
        if dirname not in self._realpaths:
309
 
            self._realpaths[dirname] = os.path.realpath(dirname)
310
 
        dirname = self._realpaths[dirname]
311
 
        abs = pathjoin(dirname, basename)
312
 
        if dirname in self._relpaths:
313
 
            relpath = pathjoin(self._relpaths[dirname], basename)
314
 
            relpath = relpath.rstrip('/\\')
315
 
        else:
316
 
            relpath = self._tree.relpath(abs)
317
 
        self._relpaths[abs] = relpath
318
 
        return relpath
319
 
 
320
299
    def trans_id_tree_path(self, path):
321
300
        """Determine (and maybe set) the transaction ID for a tree path."""
322
301
        path = self.canonical_path(path)
332
311
            return ROOT_PARENT
333
312
        return self.trans_id_tree_path(os.path.dirname(path))
334
313
 
335
 
    def create_file(self, contents, trans_id, mode_id=None):
336
 
        """Schedule creation of a new file.
337
 
 
338
 
        See also new_file.
339
 
 
340
 
        Contents is an iterator of strings, all of which will be written
341
 
        to the target destination.
342
 
 
343
 
        New file takes the permissions of any existing file with that id,
344
 
        unless mode_id is specified.
345
 
        """
346
 
        name = self._limbo_name(trans_id)
347
 
        f = open(name, 'wb')
348
 
        try:
349
 
            try:
350
 
                unique_add(self._new_contents, trans_id, 'file')
351
 
            except:
352
 
                # Clean up the file, it never got registered so
353
 
                # TreeTransform.finalize() won't clean it up.
354
 
                f.close()
355
 
                os.unlink(name)
356
 
                raise
357
 
 
358
 
            f.writelines(contents)
359
 
        finally:
360
 
            f.close()
361
 
        self._set_mode(trans_id, mode_id, S_ISREG)
362
 
 
363
 
    def _set_mode(self, trans_id, mode_id, typefunc):
364
 
        """Set the mode of new file contents.
365
 
        The mode_id is the existing file to get the mode from (often the same
366
 
        as trans_id).  The operation is only performed if there's a mode match
367
 
        according to typefunc.
368
 
        """
369
 
        if mode_id is None:
370
 
            mode_id = trans_id
371
 
        try:
372
 
            old_path = self._tree_id_paths[mode_id]
373
 
        except KeyError:
374
 
            return
375
 
        try:
376
 
            mode = os.stat(self._tree.abspath(old_path)).st_mode
377
 
        except OSError, e:
378
 
            if e.errno in (errno.ENOENT, errno.ENOTDIR):
379
 
                # Either old_path doesn't exist, or the parent of the
380
 
                # target is not a directory (but will be one eventually)
381
 
                # Either way, we know it doesn't exist *right now*
382
 
                # See also bug #248448
383
 
                return
384
 
            else:
385
 
                raise
386
 
        if typefunc(mode):
387
 
            os.chmod(self._limbo_name(trans_id), mode)
388
 
 
389
 
    def create_hardlink(self, path, trans_id):
390
 
        """Schedule creation of a hard link"""
391
 
        name = self._limbo_name(trans_id)
392
 
        try:
393
 
            os.link(path, name)
394
 
        except OSError, e:
395
 
            if e.errno != errno.EPERM:
396
 
                raise
397
 
            raise errors.HardLinkNotSupported(path)
398
 
        try:
399
 
            unique_add(self._new_contents, trans_id, 'file')
400
 
        except:
401
 
            # Clean up the file, it never got registered so
402
 
            # TreeTransform.finalize() won't clean it up.
403
 
            os.unlink(name)
404
 
            raise
405
 
 
406
 
    def create_directory(self, trans_id):
407
 
        """Schedule creation of a new directory.
408
 
 
409
 
        See also new_directory.
410
 
        """
411
 
        os.mkdir(self._limbo_name(trans_id))
412
 
        unique_add(self._new_contents, trans_id, 'directory')
413
 
 
414
 
    def create_symlink(self, target, trans_id):
415
 
        """Schedule creation of a new symbolic link.
416
 
 
417
 
        target is a bytestring.
418
 
        See also new_symlink.
419
 
        """
420
 
        if has_symlinks():
421
 
            os.symlink(target, self._limbo_name(trans_id))
422
 
            unique_add(self._new_contents, trans_id, 'symlink')
423
 
        else:
424
 
            try:
425
 
                path = FinalPaths(self).get_path(trans_id)
426
 
            except KeyError:
427
 
                path = None
428
 
            raise UnableCreateSymlink(path=path)
429
 
 
430
 
    def cancel_creation(self, trans_id):
431
 
        """Cancel the creation of new file contents."""
432
 
        del self._new_contents[trans_id]
433
 
        children = self._limbo_children.get(trans_id)
434
 
        # if this is a limbo directory with children, move them before removing
435
 
        # the directory
436
 
        if children is not None:
437
 
            self._rename_in_limbo(children)
438
 
            del self._limbo_children[trans_id]
439
 
            del self._limbo_children_names[trans_id]
440
 
        delete_any(self._limbo_name(trans_id))
441
 
 
442
314
    def delete_contents(self, trans_id):
443
315
        """Schedule the contents of a path entry for deletion"""
 
316
        # Ensure that the object exists in the WorkingTree, this will raise an
 
317
        # exception if there is a problem
444
318
        self.tree_kind(trans_id)
445
319
        self._removed_contents.add(trans_id)
446
320
 
518
392
        new_ids.update(changed_kind)
519
393
        return sorted(FinalPaths(self).get_paths(new_ids))
520
394
 
521
 
    def tree_kind(self, trans_id):
522
 
        """Determine the file kind in the working tree.
523
 
 
524
 
        Raises NoSuchFile if the file does not exist
525
 
        """
526
 
        path = self._tree_id_paths.get(trans_id)
527
 
        if path is None:
528
 
            raise NoSuchFile(None)
529
 
        try:
530
 
            return file_kind(self._tree.abspath(path))
531
 
        except OSError, e:
532
 
            if e.errno != errno.ENOENT:
533
 
                raise
534
 
            else:
535
 
                raise NoSuchFile(path)
536
 
 
537
395
    def final_kind(self, trans_id):
538
396
        """Determine the final file kind, after any changes applied.
539
397
 
646
504
        conflicts.extend(self._overwrite_conflicts())
647
505
        return conflicts
648
506
 
 
507
    def _check_malformed(self):
 
508
        conflicts = self.find_conflicts()
 
509
        if len(conflicts) != 0:
 
510
            raise MalformedTransform(conflicts=conflicts)
 
511
 
649
512
    def _add_tree_children(self):
650
513
        """Add all the children of all active parents to the known paths.
651
514
 
667
530
            # ensure that all children are registered with the transaction
668
531
            list(self.iter_tree_children(parent_id))
669
532
 
670
 
    def iter_tree_children(self, parent_id):
671
 
        """Iterate through the entry's tree children, if any"""
672
 
        try:
673
 
            path = self._tree_id_paths[parent_id]
674
 
        except KeyError:
675
 
            return
676
 
        try:
677
 
            children = os.listdir(self._tree.abspath(path))
678
 
        except OSError, e:
679
 
            if not (osutils._is_error_enotdir(e)
680
 
                    or e.errno in (errno.ENOENT, errno.ESRCH)):
681
 
                raise
682
 
            return
683
 
 
684
 
        for child in children:
685
 
            childpath = joinpath(path, child)
686
 
            if self._tree.is_control_filename(childpath):
687
 
                continue
688
 
            yield self.trans_id_tree_path(childpath)
689
 
 
690
533
    def has_named_child(self, by_parent, parent_id, name):
691
534
        try:
692
535
            children = by_parent[parent_id]
867
710
            return True
868
711
        return False
869
712
 
870
 
    def _limbo_name(self, trans_id):
871
 
        """Generate the limbo name of a file"""
872
 
        limbo_name = self._limbo_files.get(trans_id)
873
 
        if limbo_name is not None:
874
 
            return limbo_name
875
 
        parent = self._new_parent.get(trans_id)
876
 
        # if the parent directory is already in limbo (e.g. when building a
877
 
        # tree), choose a limbo name inside the parent, to reduce further
878
 
        # renames.
879
 
        use_direct_path = False
880
 
        if self._new_contents.get(parent) == 'directory':
881
 
            filename = self._new_name.get(trans_id)
882
 
            if filename is not None:
883
 
                if parent not in self._limbo_children:
884
 
                    self._limbo_children[parent] = set()
885
 
                    self._limbo_children_names[parent] = {}
886
 
                    use_direct_path = True
887
 
                # the direct path can only be used if no other file has
888
 
                # already taken this pathname, i.e. if the name is unused, or
889
 
                # if it is already associated with this trans_id.
890
 
                elif self._case_sensitive_target:
891
 
                    if (self._limbo_children_names[parent].get(filename)
892
 
                        in (trans_id, None)):
893
 
                        use_direct_path = True
894
 
                else:
895
 
                    for l_filename, l_trans_id in\
896
 
                        self._limbo_children_names[parent].iteritems():
897
 
                        if l_trans_id == trans_id:
898
 
                            continue
899
 
                        if l_filename.lower() == filename.lower():
900
 
                            break
901
 
                    else:
902
 
                        use_direct_path = True
903
 
 
904
 
        if use_direct_path:
905
 
            limbo_name = pathjoin(self._limbo_files[parent], filename)
906
 
            self._limbo_children[parent].add(trans_id)
907
 
            self._limbo_children_names[parent][filename] = trans_id
908
 
        else:
909
 
            limbo_name = pathjoin(self._limbodir, trans_id)
910
 
            self._needs_rename.add(trans_id)
911
 
        self._limbo_files[trans_id] = limbo_name
912
 
        return limbo_name
913
 
 
914
713
    def _set_executability(self, path, trans_id):
915
714
        """Set the executability of versioned files """
916
715
        if supports_executable():
1122
921
    def get_preview_tree(self):
1123
922
        """Return a tree representing the result of the transform.
1124
923
 
1125
 
        This tree only supports the subset of Tree functionality required
1126
 
        by show_diff_trees.  It must only be compared to tt._tree.
 
924
        The tree is a snapshot, and altering the TreeTransform will invalidate
 
925
        it.
1127
926
        """
1128
927
        return _PreviewTree(self)
1129
928
 
 
929
    def commit(self, branch, message, merge_parents=None, strict=False):
 
930
        """Commit the result of this TreeTransform to a branch.
 
931
 
 
932
        :param branch: The branch to commit to.
 
933
        :param message: The message to attach to the commit.
 
934
        :param merge_parents: Additional parents specified by pending merges.
 
935
        :return: The revision_id of the revision committed.
 
936
        """
 
937
        self._check_malformed()
 
938
        if strict:
 
939
            unversioned = set(self._new_contents).difference(set(self._new_id))
 
940
            for trans_id in unversioned:
 
941
                if self.final_file_id(trans_id) is None:
 
942
                    raise errors.StrictCommitFailed()
 
943
 
 
944
        revno, last_rev_id = branch.last_revision_info()
 
945
        if last_rev_id == _mod_revision.NULL_REVISION:
 
946
            if merge_parents is not None:
 
947
                raise ValueError('Cannot supply merge parents for first'
 
948
                                 ' commit.')
 
949
            parent_ids = []
 
950
        else:
 
951
            parent_ids = [last_rev_id]
 
952
            if merge_parents is not None:
 
953
                parent_ids.extend(merge_parents)
 
954
        if self._tree.get_revision_id() != last_rev_id:
 
955
            raise ValueError('TreeTransform not based on branch basis: %s' %
 
956
                             self._tree.get_revision_id())
 
957
        builder = branch.get_commit_builder(parent_ids)
 
958
        preview = self.get_preview_tree()
 
959
        list(builder.record_iter_changes(preview, last_rev_id,
 
960
                                         self.iter_changes()))
 
961
        builder.finish_inventory()
 
962
        revision_id = builder.commit(message)
 
963
        branch.set_last_revision_info(revno + 1, revision_id)
 
964
        return revision_id
 
965
 
1130
966
    def _text_parent(self, trans_id):
1131
967
        file_id = self.tree_file_id(trans_id)
1132
968
        try:
1176
1012
                                      (('attribs',),))
1177
1013
        for trans_id, kind in self._new_contents.items():
1178
1014
            if kind == 'file':
1179
 
                cur_file = open(self._limbo_name(trans_id), 'rb')
1180
 
                try:
1181
 
                    lines = osutils.chunks_to_lines(cur_file.readlines())
1182
 
                finally:
1183
 
                    cur_file.close()
 
1015
                lines = osutils.chunks_to_lines(
 
1016
                    self._read_file_chunks(trans_id))
1184
1017
                parents = self._get_parents_lines(trans_id)
1185
1018
                mpdiff = multiparent.MultiParent.from_lines(lines, parents)
1186
1019
                content = ''.join(mpdiff.to_patch())
1187
1020
            if kind == 'directory':
1188
1021
                content = ''
1189
1022
            if kind == 'symlink':
1190
 
                content = os.readlink(self._limbo_name(trans_id))
 
1023
                content = self._read_symlink_target(trans_id)
1191
1024
            yield serializer.bytes_record(content, ((trans_id, kind),))
1192
1025
 
1193
 
 
1194
1026
    def deserialize(self, records):
1195
1027
        """Deserialize a stored TreeTransform.
1196
1028
 
1227
1059
                self.create_symlink(content.decode('utf-8'), trans_id)
1228
1060
 
1229
1061
 
1230
 
class TreeTransform(TreeTransformBase):
 
1062
class DiskTreeTransform(TreeTransformBase):
 
1063
    """Tree transform storing its contents on disk."""
 
1064
 
 
1065
    def __init__(self, tree, limbodir, pb=DummyProgress(),
 
1066
                 case_sensitive=True):
 
1067
        """Constructor.
 
1068
        :param tree: The tree that will be transformed, but not necessarily
 
1069
            the output tree.
 
1070
        :param limbodir: A directory where new files can be stored until
 
1071
            they are installed in their proper places
 
1072
        :param pb: A ProgressBar indicating how much progress is being made
 
1073
        :param case_sensitive: If True, the target of the transform is
 
1074
            case sensitive, not just case preserving.
 
1075
        """
 
1076
        TreeTransformBase.__init__(self, tree, pb, case_sensitive)
 
1077
        self._limbodir = limbodir
 
1078
        self._deletiondir = None
 
1079
        # A mapping of transform ids to their limbo filename
 
1080
        self._limbo_files = {}
 
1081
        # A mapping of transform ids to a set of the transform ids of children
 
1082
        # that their limbo directory has
 
1083
        self._limbo_children = {}
 
1084
        # Map transform ids to maps of child filename to child transform id
 
1085
        self._limbo_children_names = {}
 
1086
        # List of transform ids that need to be renamed from limbo into place
 
1087
        self._needs_rename = set()
 
1088
        self._creation_mtime = None
 
1089
 
 
1090
    def finalize(self):
 
1091
        """Release the working tree lock, if held, clean up limbo dir.
 
1092
 
 
1093
        This is required if apply has not been invoked, but can be invoked
 
1094
        even after apply.
 
1095
        """
 
1096
        if self._tree is None:
 
1097
            return
 
1098
        try:
 
1099
            entries = [(self._limbo_name(t), t, k) for t, k in
 
1100
                       self._new_contents.iteritems()]
 
1101
            entries.sort(reverse=True)
 
1102
            for path, trans_id, kind in entries:
 
1103
                delete_any(path)
 
1104
            try:
 
1105
                delete_any(self._limbodir)
 
1106
            except OSError:
 
1107
                # We don't especially care *why* the dir is immortal.
 
1108
                raise ImmortalLimbo(self._limbodir)
 
1109
            try:
 
1110
                if self._deletiondir is not None:
 
1111
                    delete_any(self._deletiondir)
 
1112
            except OSError:
 
1113
                raise errors.ImmortalPendingDeletion(self._deletiondir)
 
1114
        finally:
 
1115
            TreeTransformBase.finalize(self)
 
1116
 
 
1117
    def _limbo_name(self, trans_id):
 
1118
        """Generate the limbo name of a file"""
 
1119
        limbo_name = self._limbo_files.get(trans_id)
 
1120
        if limbo_name is None:
 
1121
            limbo_name = self._generate_limbo_path(trans_id)
 
1122
            self._limbo_files[trans_id] = limbo_name
 
1123
        return limbo_name
 
1124
 
 
1125
    def _generate_limbo_path(self, trans_id):
 
1126
        """Generate a limbo path using the trans_id as the relative path.
 
1127
 
 
1128
        This is suitable as a fallback, and when the transform should not be
 
1129
        sensitive to the path encoding of the limbo directory.
 
1130
        """
 
1131
        self._needs_rename.add(trans_id)
 
1132
        return pathjoin(self._limbodir, trans_id)
 
1133
 
 
1134
    def adjust_path(self, name, parent, trans_id):
 
1135
        previous_parent = self._new_parent.get(trans_id)
 
1136
        previous_name = self._new_name.get(trans_id)
 
1137
        TreeTransformBase.adjust_path(self, name, parent, trans_id)
 
1138
        if (trans_id in self._limbo_files and
 
1139
            trans_id not in self._needs_rename):
 
1140
            self._rename_in_limbo([trans_id])
 
1141
            if previous_parent != parent:
 
1142
                self._limbo_children[previous_parent].remove(trans_id)
 
1143
            if previous_parent != parent or previous_name != name:
 
1144
                del self._limbo_children_names[previous_parent][previous_name]
 
1145
 
 
1146
    def _rename_in_limbo(self, trans_ids):
 
1147
        """Fix limbo names so that the right final path is produced.
 
1148
 
 
1149
        This means we outsmarted ourselves-- we tried to avoid renaming
 
1150
        these files later by creating them with their final names in their
 
1151
        final parents.  But now the previous name or parent is no longer
 
1152
        suitable, so we have to rename them.
 
1153
 
 
1154
        Even for trans_ids that have no new contents, we must remove their
 
1155
        entries from _limbo_files, because they are now stale.
 
1156
        """
 
1157
        for trans_id in trans_ids:
 
1158
            old_path = self._limbo_files.pop(trans_id)
 
1159
            if trans_id not in self._new_contents:
 
1160
                continue
 
1161
            new_path = self._limbo_name(trans_id)
 
1162
            os.rename(old_path, new_path)
 
1163
            for descendant in self._limbo_descendants(trans_id):
 
1164
                desc_path = self._limbo_files[descendant]
 
1165
                desc_path = new_path + desc_path[len(old_path):]
 
1166
                self._limbo_files[descendant] = desc_path
 
1167
 
 
1168
    def _limbo_descendants(self, trans_id):
 
1169
        """Return the set of trans_ids whose limbo paths descend from this."""
 
1170
        descendants = set(self._limbo_children.get(trans_id, []))
 
1171
        for descendant in list(descendants):
 
1172
            descendants.update(self._limbo_descendants(descendant))
 
1173
        return descendants
 
1174
 
 
1175
    def create_file(self, contents, trans_id, mode_id=None):
 
1176
        """Schedule creation of a new file.
 
1177
 
 
1178
        See also new_file.
 
1179
 
 
1180
        Contents is an iterator of strings, all of which will be written
 
1181
        to the target destination.
 
1182
 
 
1183
        New file takes the permissions of any existing file with that id,
 
1184
        unless mode_id is specified.
 
1185
        """
 
1186
        name = self._limbo_name(trans_id)
 
1187
        f = open(name, 'wb')
 
1188
        try:
 
1189
            try:
 
1190
                unique_add(self._new_contents, trans_id, 'file')
 
1191
            except:
 
1192
                # Clean up the file, it never got registered so
 
1193
                # TreeTransform.finalize() won't clean it up.
 
1194
                f.close()
 
1195
                os.unlink(name)
 
1196
                raise
 
1197
 
 
1198
            f.writelines(contents)
 
1199
        finally:
 
1200
            f.close()
 
1201
        self._set_mtime(name)
 
1202
        self._set_mode(trans_id, mode_id, S_ISREG)
 
1203
 
 
1204
    def _read_file_chunks(self, trans_id):
 
1205
        cur_file = open(self._limbo_name(trans_id), 'rb')
 
1206
        try:
 
1207
            return cur_file.readlines()
 
1208
        finally:
 
1209
            cur_file.close()
 
1210
 
 
1211
    def _read_symlink_target(self, trans_id):
 
1212
        return os.readlink(self._limbo_name(trans_id))
 
1213
 
 
1214
    def _set_mtime(self, path):
 
1215
        """All files that are created get the same mtime.
 
1216
 
 
1217
        This time is set by the first object to be created.
 
1218
        """
 
1219
        if self._creation_mtime is None:
 
1220
            self._creation_mtime = time.time()
 
1221
        os.utime(path, (self._creation_mtime, self._creation_mtime))
 
1222
 
 
1223
    def create_hardlink(self, path, trans_id):
 
1224
        """Schedule creation of a hard link"""
 
1225
        name = self._limbo_name(trans_id)
 
1226
        try:
 
1227
            os.link(path, name)
 
1228
        except OSError, e:
 
1229
            if e.errno != errno.EPERM:
 
1230
                raise
 
1231
            raise errors.HardLinkNotSupported(path)
 
1232
        try:
 
1233
            unique_add(self._new_contents, trans_id, 'file')
 
1234
        except:
 
1235
            # Clean up the file, it never got registered so
 
1236
            # TreeTransform.finalize() won't clean it up.
 
1237
            os.unlink(name)
 
1238
            raise
 
1239
 
 
1240
    def create_directory(self, trans_id):
 
1241
        """Schedule creation of a new directory.
 
1242
 
 
1243
        See also new_directory.
 
1244
        """
 
1245
        os.mkdir(self._limbo_name(trans_id))
 
1246
        unique_add(self._new_contents, trans_id, 'directory')
 
1247
 
 
1248
    def create_symlink(self, target, trans_id):
 
1249
        """Schedule creation of a new symbolic link.
 
1250
 
 
1251
        target is a bytestring.
 
1252
        See also new_symlink.
 
1253
        """
 
1254
        if has_symlinks():
 
1255
            os.symlink(target, self._limbo_name(trans_id))
 
1256
            unique_add(self._new_contents, trans_id, 'symlink')
 
1257
        else:
 
1258
            try:
 
1259
                path = FinalPaths(self).get_path(trans_id)
 
1260
            except KeyError:
 
1261
                path = None
 
1262
            raise UnableCreateSymlink(path=path)
 
1263
 
 
1264
    def cancel_creation(self, trans_id):
 
1265
        """Cancel the creation of new file contents."""
 
1266
        del self._new_contents[trans_id]
 
1267
        children = self._limbo_children.get(trans_id)
 
1268
        # if this is a limbo directory with children, move them before removing
 
1269
        # the directory
 
1270
        if children is not None:
 
1271
            self._rename_in_limbo(children)
 
1272
            del self._limbo_children[trans_id]
 
1273
            del self._limbo_children_names[trans_id]
 
1274
        delete_any(self._limbo_name(trans_id))
 
1275
 
 
1276
 
 
1277
class TreeTransform(DiskTreeTransform):
1231
1278
    """Represent a tree transformation.
1232
1279
 
1233
1280
    This object is designed to support incremental generation of the transform,
1319
1366
            tree.unlock()
1320
1367
            raise
1321
1368
 
1322
 
        TreeTransformBase.__init__(self, tree, limbodir, pb,
 
1369
        # Cache of realpath results, to speed up canonical_path
 
1370
        self._realpaths = {}
 
1371
        # Cache of relpath results, to speed up canonical_path
 
1372
        self._relpaths = {}
 
1373
        DiskTreeTransform.__init__(self, tree, limbodir, pb,
1323
1374
                                   tree.case_sensitive)
1324
1375
        self._deletiondir = deletiondir
1325
1376
 
 
1377
    def canonical_path(self, path):
 
1378
        """Get the canonical tree-relative path"""
 
1379
        # don't follow final symlinks
 
1380
        abs = self._tree.abspath(path)
 
1381
        if abs in self._relpaths:
 
1382
            return self._relpaths[abs]
 
1383
        dirname, basename = os.path.split(abs)
 
1384
        if dirname not in self._realpaths:
 
1385
            self._realpaths[dirname] = os.path.realpath(dirname)
 
1386
        dirname = self._realpaths[dirname]
 
1387
        abs = pathjoin(dirname, basename)
 
1388
        if dirname in self._relpaths:
 
1389
            relpath = pathjoin(self._relpaths[dirname], basename)
 
1390
            relpath = relpath.rstrip('/\\')
 
1391
        else:
 
1392
            relpath = self._tree.relpath(abs)
 
1393
        self._relpaths[abs] = relpath
 
1394
        return relpath
 
1395
 
 
1396
    def tree_kind(self, trans_id):
 
1397
        """Determine the file kind in the working tree.
 
1398
 
 
1399
        Raises NoSuchFile if the file does not exist
 
1400
        """
 
1401
        path = self._tree_id_paths.get(trans_id)
 
1402
        if path is None:
 
1403
            raise NoSuchFile(None)
 
1404
        try:
 
1405
            return file_kind(self._tree.abspath(path))
 
1406
        except OSError, e:
 
1407
            if e.errno != errno.ENOENT:
 
1408
                raise
 
1409
            else:
 
1410
                raise NoSuchFile(path)
 
1411
 
 
1412
    def _set_mode(self, trans_id, mode_id, typefunc):
 
1413
        """Set the mode of new file contents.
 
1414
        The mode_id is the existing file to get the mode from (often the same
 
1415
        as trans_id).  The operation is only performed if there's a mode match
 
1416
        according to typefunc.
 
1417
        """
 
1418
        if mode_id is None:
 
1419
            mode_id = trans_id
 
1420
        try:
 
1421
            old_path = self._tree_id_paths[mode_id]
 
1422
        except KeyError:
 
1423
            return
 
1424
        try:
 
1425
            mode = os.stat(self._tree.abspath(old_path)).st_mode
 
1426
        except OSError, e:
 
1427
            if e.errno in (errno.ENOENT, errno.ENOTDIR):
 
1428
                # Either old_path doesn't exist, or the parent of the
 
1429
                # target is not a directory (but will be one eventually)
 
1430
                # Either way, we know it doesn't exist *right now*
 
1431
                # See also bug #248448
 
1432
                return
 
1433
            else:
 
1434
                raise
 
1435
        if typefunc(mode):
 
1436
            os.chmod(self._limbo_name(trans_id), mode)
 
1437
 
 
1438
    def iter_tree_children(self, parent_id):
 
1439
        """Iterate through the entry's tree children, if any"""
 
1440
        try:
 
1441
            path = self._tree_id_paths[parent_id]
 
1442
        except KeyError:
 
1443
            return
 
1444
        try:
 
1445
            children = os.listdir(self._tree.abspath(path))
 
1446
        except OSError, e:
 
1447
            if not (osutils._is_error_enotdir(e)
 
1448
                    or e.errno in (errno.ENOENT, errno.ESRCH)):
 
1449
                raise
 
1450
            return
 
1451
 
 
1452
        for child in children:
 
1453
            childpath = joinpath(path, child)
 
1454
            if self._tree.is_control_filename(childpath):
 
1455
                continue
 
1456
            yield self.trans_id_tree_path(childpath)
 
1457
 
 
1458
    def _generate_limbo_path(self, trans_id):
 
1459
        """Generate a limbo path using the final path if possible.
 
1460
 
 
1461
        This optimizes the performance of applying the tree transform by
 
1462
        avoiding renames.  These renames can be avoided only when the parent
 
1463
        directory is already scheduled for creation.
 
1464
 
 
1465
        If the final path cannot be used, falls back to using the trans_id as
 
1466
        the relpath.
 
1467
        """
 
1468
        parent = self._new_parent.get(trans_id)
 
1469
        # if the parent directory is already in limbo (e.g. when building a
 
1470
        # tree), choose a limbo name inside the parent, to reduce further
 
1471
        # renames.
 
1472
        use_direct_path = False
 
1473
        if self._new_contents.get(parent) == 'directory':
 
1474
            filename = self._new_name.get(trans_id)
 
1475
            if filename is not None:
 
1476
                if parent not in self._limbo_children:
 
1477
                    self._limbo_children[parent] = set()
 
1478
                    self._limbo_children_names[parent] = {}
 
1479
                    use_direct_path = True
 
1480
                # the direct path can only be used if no other file has
 
1481
                # already taken this pathname, i.e. if the name is unused, or
 
1482
                # if it is already associated with this trans_id.
 
1483
                elif self._case_sensitive_target:
 
1484
                    if (self._limbo_children_names[parent].get(filename)
 
1485
                        in (trans_id, None)):
 
1486
                        use_direct_path = True
 
1487
                else:
 
1488
                    for l_filename, l_trans_id in\
 
1489
                        self._limbo_children_names[parent].iteritems():
 
1490
                        if l_trans_id == trans_id:
 
1491
                            continue
 
1492
                        if l_filename.lower() == filename.lower():
 
1493
                            break
 
1494
                    else:
 
1495
                        use_direct_path = True
 
1496
 
 
1497
        if not use_direct_path:
 
1498
            return DiskTreeTransform._generate_limbo_path(self, trans_id)
 
1499
 
 
1500
        limbo_name = pathjoin(self._limbo_files[parent], filename)
 
1501
        self._limbo_children[parent].add(trans_id)
 
1502
        self._limbo_children_names[parent][filename] = trans_id
 
1503
        return limbo_name
 
1504
 
 
1505
 
1326
1506
    def apply(self, no_conflicts=False, precomputed_delta=None, _mover=None):
1327
1507
        """Apply all changes to the inventory and filesystem.
1328
1508
 
1338
1518
        :param _mover: Supply an alternate FileMover, for testing
1339
1519
        """
1340
1520
        if not no_conflicts:
1341
 
            conflicts = self.find_conflicts()
1342
 
            if len(conflicts) != 0:
1343
 
                raise MalformedTransform(conflicts=conflicts)
 
1521
            self._check_malformed()
1344
1522
        child_pb = bzrlib.ui.ui_factory.nested_progress_bar()
1345
1523
        try:
1346
1524
            if precomputed_delta is None:
1450
1628
                child_pb.update('removing file', num, len(tree_paths))
1451
1629
                full_path = self._tree.abspath(path)
1452
1630
                if trans_id in self._removed_contents:
1453
 
                    mover.pre_delete(full_path, os.path.join(self._deletiondir,
1454
 
                                     trans_id))
1455
 
                elif trans_id in self._new_name or trans_id in \
1456
 
                    self._new_parent:
 
1631
                    delete_path = os.path.join(self._deletiondir, trans_id)
 
1632
                    mover.pre_delete(full_path, delete_path)
 
1633
                elif (trans_id in self._new_name
 
1634
                      or trans_id in self._new_parent):
1457
1635
                    try:
1458
1636
                        mover.rename(full_path, self._limbo_name(trans_id))
1459
1637
                    except OSError, e:
1505
1683
        return modified_paths
1506
1684
 
1507
1685
 
1508
 
class TransformPreview(TreeTransformBase):
 
1686
class TransformPreview(DiskTreeTransform):
1509
1687
    """A TreeTransform for generating preview trees.
1510
1688
 
1511
1689
    Unlike TreeTransform, this version works when the input tree is a
1516
1694
    def __init__(self, tree, pb=DummyProgress(), case_sensitive=True):
1517
1695
        tree.lock_read()
1518
1696
        limbodir = osutils.mkdtemp(prefix='bzr-limbo-')
1519
 
        TreeTransformBase.__init__(self, tree, limbodir, pb, case_sensitive)
 
1697
        DiskTreeTransform.__init__(self, tree, limbodir, pb, case_sensitive)
1520
1698
 
1521
1699
    def canonical_path(self, path):
1522
1700
        return path
1564
1742
        self._all_children_cache = {}
1565
1743
        self._path2trans_id_cache = {}
1566
1744
        self._final_name_cache = {}
1567
 
 
1568
 
    def _changes(self, file_id):
1569
 
        for changes in self._transform.iter_changes():
1570
 
            if changes[0] == file_id:
1571
 
                return changes
 
1745
        self._iter_changes_cache = dict((c[0], c) for c in
 
1746
                                        self._transform.iter_changes())
1572
1747
 
1573
1748
    def _content_change(self, file_id):
1574
1749
        """Return True if the content of this file changed"""
1575
 
        changes = self._changes(file_id)
 
1750
        changes = self._iter_changes_cache.get(file_id)
1576
1751
        # changes[2] is true if the file content changed.  See
1577
1752
        # InterTree.iter_changes.
1578
1753
        return (changes is not None and changes[2])
1647
1822
    def __iter__(self):
1648
1823
        return iter(self.all_file_ids())
1649
1824
 
1650
 
    def has_id(self, file_id):
 
1825
    def _has_id(self, file_id, fallback_check):
1651
1826
        if file_id in self._transform._r_new_id:
1652
1827
            return True
1653
1828
        elif file_id in set([self._transform.tree_file_id(trans_id) for
1654
1829
            trans_id in self._transform._removed_id]):
1655
1830
            return False
1656
1831
        else:
1657
 
            return self._transform._tree.has_id(file_id)
 
1832
            return fallback_check(file_id)
 
1833
 
 
1834
    def has_id(self, file_id):
 
1835
        return self._has_id(file_id, self._transform._tree.has_id)
 
1836
 
 
1837
    def has_or_had_id(self, file_id):
 
1838
        return self._has_id(file_id, self._transform._tree.has_or_had_id)
1658
1839
 
1659
1840
    def _path2trans_id(self, path):
1660
1841
        # We must not use None here, because that is a valid value to store.
1713
1894
            if self._transform.final_file_id(trans_id) is None:
1714
1895
                yield self._final_paths._determine_path(trans_id)
1715
1896
 
1716
 
    def _make_inv_entries(self, ordered_entries, specific_file_ids):
 
1897
    def _make_inv_entries(self, ordered_entries, specific_file_ids=None,
 
1898
        yield_parents=False):
1717
1899
        for trans_id, parent_file_id in ordered_entries:
1718
1900
            file_id = self._transform.final_file_id(trans_id)
1719
1901
            if file_id is None:
1745
1927
                ordered_ids.append((trans_id, parent_file_id))
1746
1928
        return ordered_ids
1747
1929
 
1748
 
    def iter_entries_by_dir(self, specific_file_ids=None):
 
1930
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
1749
1931
        # This may not be a maximally efficient implementation, but it is
1750
1932
        # reasonably straightforward.  An implementation that grafts the
1751
1933
        # TreeTransform changes onto the tree's iter_entries_by_dir results
1753
1935
        # position.
1754
1936
        ordered_ids = self._list_files_by_dir()
1755
1937
        for entry, trans_id in self._make_inv_entries(ordered_ids,
1756
 
                                                      specific_file_ids):
1757
 
            yield unicode(self._final_paths.get_path(trans_id)), entry
1758
 
 
1759
 
    def list_files(self, include_root=False):
1760
 
        """See Tree.list_files."""
 
1938
            specific_file_ids, yield_parents=yield_parents):
 
1939
            yield unicode(self._final_paths.get_path(trans_id)), entry
 
1940
 
 
1941
    def _iter_entries_for_dir(self, dir_path):
 
1942
        """Return path, entry for items in a directory without recursing down."""
 
1943
        dir_file_id = self.path2id(dir_path)
 
1944
        ordered_ids = []
 
1945
        for file_id in self.iter_children(dir_file_id):
 
1946
            trans_id = self._transform.trans_id_file_id(file_id)
 
1947
            ordered_ids.append((trans_id, file_id))
 
1948
        for entry, trans_id in self._make_inv_entries(ordered_ids):
 
1949
            yield unicode(self._final_paths.get_path(trans_id)), entry
 
1950
 
 
1951
    def list_files(self, include_root=False, from_dir=None, recursive=True):
 
1952
        """See WorkingTree.list_files."""
1761
1953
        # XXX This should behave like WorkingTree.list_files, but is really
1762
1954
        # more like RevisionTree.list_files.
1763
 
        for path, entry in self.iter_entries_by_dir():
1764
 
            if entry.name == '' and not include_root:
1765
 
                continue
1766
 
            yield path, 'V', entry.kind, entry.file_id, entry
 
1955
        if recursive:
 
1956
            prefix = None
 
1957
            if from_dir:
 
1958
                prefix = from_dir + '/'
 
1959
            entries = self.iter_entries_by_dir()
 
1960
            for path, entry in entries:
 
1961
                if entry.name == '' and not include_root:
 
1962
                    continue
 
1963
                if prefix:
 
1964
                    if not path.startswith(prefix):
 
1965
                        continue
 
1966
                    path = path[len(prefix):]
 
1967
                yield path, 'V', entry.kind, entry.file_id, entry
 
1968
        else:
 
1969
            if from_dir is None and include_root is True:
 
1970
                root_entry = inventory.make_entry('directory', '',
 
1971
                    ROOT_PARENT, self.get_root_id())
 
1972
                yield '', 'V', 'directory', root_entry.file_id, root_entry
 
1973
            entries = self._iter_entries_for_dir(from_dir or '')
 
1974
            for path, entry in entries:
 
1975
                yield path, 'V', entry.kind, entry.file_id, entry
1767
1976
 
1768
1977
    def kind(self, file_id):
1769
1978
        trans_id = self._transform.trans_id_file_id(file_id)
1779
1988
    def get_file_mtime(self, file_id, path=None):
1780
1989
        """See Tree.get_file_mtime"""
1781
1990
        if not self._content_change(file_id):
1782
 
            return self._transform._tree.get_file_mtime(file_id, path)
 
1991
            return self._transform._tree.get_file_mtime(file_id)
1783
1992
        return self._stat_limbo_file(file_id).st_mtime
1784
1993
 
1785
1994
    def _file_size(self, entry, stat_value):
1839
2048
                statval = os.lstat(limbo_name)
1840
2049
                size = statval.st_size
1841
2050
                if not supports_executable():
1842
 
                    executable = None
 
2051
                    executable = False
1843
2052
                else:
1844
2053
                    executable = statval.st_mode & S_IEXEC
1845
2054
            else:
1847
2056
                executable = None
1848
2057
            if kind == 'symlink':
1849
2058
                link_or_sha1 = os.readlink(limbo_name).decode(osutils._fs_enc)
1850
 
        if supports_executable():
1851
 
            executable = tt._new_executability.get(trans_id, executable)
 
2059
        executable = tt._new_executability.get(trans_id, executable)
1852
2060
        return kind, size, executable, link_or_sha1
1853
2061
 
1854
2062
    def iter_changes(self, from_tree, include_unchanged=False,
1880
2088
        name = self._transform._limbo_name(trans_id)
1881
2089
        return open(name, 'rb')
1882
2090
 
 
2091
    def get_file_with_stat(self, file_id, path=None):
 
2092
        return self.get_file(file_id, path), None
 
2093
 
1883
2094
    def annotate_iter(self, file_id,
1884
2095
                      default_revision=_mod_revision.CURRENT_REVISION):
1885
 
        changes = self._changes(file_id)
 
2096
        changes = self._iter_changes_cache.get(file_id)
1886
2097
        if changes is None:
1887
2098
            get_old = True
1888
2099
        else:
1900
2111
            return old_annotation
1901
2112
        if not changed_content:
1902
2113
            return old_annotation
 
2114
        # TODO: This is doing something similar to what WT.annotate_iter is
 
2115
        #       doing, however it fails slightly because it doesn't know what
 
2116
        #       the *other* revision_id is, so it doesn't know how to give the
 
2117
        #       other as the origin for some lines, they all get
 
2118
        #       'default_revision'
 
2119
        #       It would be nice to be able to use the new Annotator based
 
2120
        #       approach, as well.
1903
2121
        return annotate.reannotate([old_annotation],
1904
2122
                                   self.get_file(file_id).readlines(),
1905
2123
                                   default_revision)
1910
2128
            return self._transform._tree.get_symlink_target(file_id)
1911
2129
        trans_id = self._transform.trans_id_file_id(file_id)
1912
2130
        name = self._transform._limbo_name(trans_id)
1913
 
        return os.readlink(name)
 
2131
        return osutils.readlink(name)
1914
2132
 
1915
2133
    def walkdirs(self, prefix=''):
1916
2134
        pending = [self._transform.root]
1971
2189
        self.transform = transform
1972
2190
 
1973
2191
    def _determine_path(self, trans_id):
1974
 
        if trans_id == self.transform.root:
 
2192
        if (trans_id == self.transform.root or trans_id == ROOT_PARENT):
1975
2193
            return ""
1976
2194
        name = self.transform.final_name(trans_id)
1977
2195
        parent_id = self.transform.final_parent(trans_id)
2152
2370
def _create_files(tt, tree, desired_files, pb, offset, accelerator_tree,
2153
2371
                  hardlink):
2154
2372
    total = len(desired_files) + offset
 
2373
    wt = tt._tree
2155
2374
    if accelerator_tree is None:
2156
2375
        new_desired_files = desired_files
2157
2376
    else:
2158
2377
        iter = accelerator_tree.iter_changes(tree, include_unchanged=True)
2159
 
        unchanged = dict((f, p[1]) for (f, p, c, v, d, n, k, e)
2160
 
                         in iter if not (c or e[0] != e[1]))
 
2378
        unchanged = [(f, p[1]) for (f, p, c, v, d, n, k, e)
 
2379
                     in iter if not (c or e[0] != e[1])]
 
2380
        if accelerator_tree.supports_content_filtering():
 
2381
            unchanged = [(f, p) for (f, p) in unchanged
 
2382
                         if not accelerator_tree.iter_search_rules([p]).next()]
 
2383
        unchanged = dict(unchanged)
2161
2384
        new_desired_files = []
2162
2385
        count = 0
2163
2386
        for file_id, (trans_id, tree_path) in desired_files:
2171
2394
                                   trans_id)
2172
2395
            else:
2173
2396
                contents = accelerator_tree.get_file(file_id, accelerator_path)
2174
 
                if tree.supports_content_filtering():
2175
 
                    filters = tree._content_filter_stack(tree_path)
 
2397
                if wt.supports_content_filtering():
 
2398
                    filters = wt._content_filter_stack(tree_path)
2176
2399
                    contents = filtered_output_bytes(contents, filters,
2177
2400
                        ContentFilterContext(tree_path, tree))
2178
2401
                try:
2187
2410
        offset += count
2188
2411
    for count, ((trans_id, tree_path), contents) in enumerate(
2189
2412
            tree.iter_files_bytes(new_desired_files)):
2190
 
        if tree.supports_content_filtering():
2191
 
            filters = tree._content_filter_stack(tree_path)
 
2413
        if wt.supports_content_filtering():
 
2414
            filters = wt._content_filter_stack(tree_path)
2192
2415
            contents = filtered_output_bytes(contents, filters,
2193
2416
                ContentFilterContext(tree_path, tree))
2194
2417
        tt.create_file(contents, trans_id)
2286
2509
        tt.create_directory(trans_id)
2287
2510
 
2288
2511
 
2289
 
def create_from_tree(tt, trans_id, tree, file_id, bytes=None):
2290
 
    """Create new file contents according to tree contents."""
 
2512
def create_from_tree(tt, trans_id, tree, file_id, bytes=None,
 
2513
    filter_tree_path=None):
 
2514
    """Create new file contents according to tree contents.
 
2515
    
 
2516
    :param filter_tree_path: the tree path to use to lookup
 
2517
      content filters to apply to the bytes output in the working tree.
 
2518
      This only applies if the working tree supports content filtering.
 
2519
    """
2291
2520
    kind = tree.kind(file_id)
2292
2521
    if kind == 'directory':
2293
2522
        tt.create_directory(trans_id)
2298
2527
                bytes = tree_file.readlines()
2299
2528
            finally:
2300
2529
                tree_file.close()
 
2530
        wt = tt._tree
 
2531
        if wt.supports_content_filtering() and filter_tree_path is not None:
 
2532
            filters = wt._content_filter_stack(filter_tree_path)
 
2533
            bytes = filtered_output_bytes(bytes, filters,
 
2534
                ContentFilterContext(filter_tree_path, tree))
2301
2535
        tt.create_file(bytes, trans_id)
2302
2536
    elif kind == "symlink":
2303
2537
        tt.create_symlink(tree.get_symlink_target(file_id), trans_id)
2491
2725
                    parent_trans = ROOT_PARENT
2492
2726
                else:
2493
2727
                    parent_trans = tt.trans_id_file_id(parent[1])
2494
 
                tt.adjust_path(name[1], parent_trans, trans_id)
 
2728
                if parent[0] is None and versioned[0]:
 
2729
                    tt.adjust_root_path(name[1], parent_trans)
 
2730
                else:
 
2731
                    tt.adjust_path(name[1], parent_trans, trans_id)
2495
2732
            if executable[0] != executable[1] and kind[1] == "file":
2496
2733
                tt.set_executability(executable[1], trans_id)
2497
 
        for (trans_id, mode_id), bytes in target_tree.iter_files_bytes(
2498
 
            deferred_files):
2499
 
            tt.create_file(bytes, trans_id, mode_id)
 
2734
        if working_tree.supports_content_filtering():
 
2735
            for index, ((trans_id, mode_id), bytes) in enumerate(
 
2736
                target_tree.iter_files_bytes(deferred_files)):
 
2737
                file_id = deferred_files[index][0]
 
2738
                # We're reverting a tree to the target tree so using the
 
2739
                # target tree to find the file path seems the best choice
 
2740
                # here IMO - Ian C 27/Oct/2009
 
2741
                filter_tree_path = target_tree.id2path(file_id)
 
2742
                filters = working_tree._content_filter_stack(filter_tree_path)
 
2743
                bytes = filtered_output_bytes(bytes, filters,
 
2744
                    ContentFilterContext(filter_tree_path, working_tree))
 
2745
                tt.create_file(bytes, trans_id, mode_id)
 
2746
        else:
 
2747
            for (trans_id, mode_id), bytes in target_tree.iter_files_bytes(
 
2748
                deferred_files):
 
2749
                tt.create_file(bytes, trans_id, mode_id)
 
2750
        tt.fixup_new_roots()
2500
2751
    finally:
2501
2752
        if basis_tree is not None:
2502
2753
            basis_tree.unlock()