~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/osutils.py

[patch] Aaron Bentley: make revert work in a subdirectory.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Bazaar -- distributed version control
 
1
# Bazaar-NG -- distributed version control
2
2
#
3
3
# Copyright (C) 2005 by Canonical Ltd
4
4
#
16
16
# along with this program; if not, write to the Free Software
17
17
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
18
18
 
 
19
from shutil import copyfile
 
20
from stat import (S_ISREG, S_ISDIR, S_ISLNK, ST_MODE, ST_SIZE,
 
21
                  S_ISCHR, S_ISBLK, S_ISFIFO, S_ISSOCK)
19
22
from cStringIO import StringIO
20
23
import errno
21
 
from ntpath import (abspath as _nt_abspath,
22
 
                    join as _nt_join,
23
 
                    normpath as _nt_normpath,
24
 
                    realpath as _nt_realpath,
25
 
                    splitdrive as _nt_splitdrive,
26
 
                    )
27
24
import os
28
 
from os import listdir
29
 
import posixpath
30
25
import re
31
26
import sha
32
 
import shutil
33
 
from shutil import copyfile
34
 
import stat
35
 
from stat import (S_ISREG, S_ISDIR, S_ISLNK, ST_MODE, ST_SIZE,
36
 
                  S_ISCHR, S_ISBLK, S_ISFIFO, S_ISSOCK)
37
27
import string
38
28
import sys
39
29
import time
40
30
import types
41
31
import tempfile
42
 
import unicodedata
43
32
 
44
33
import bzrlib
45
34
from bzrlib.errors import (BzrError,
46
 
                           BzrBadParameterNotUnicode,
 
35
                           BzrBadParameter,
47
36
                           NoSuchFile,
48
37
                           PathNotChild,
49
 
                           IllegalPath,
50
38
                           )
51
 
from bzrlib.symbol_versioning import (deprecated_function, 
52
 
        zero_nine)
53
39
from bzrlib.trace import mutter
54
40
 
55
41
 
56
 
# On win32, O_BINARY is used to indicate the file should
57
 
# be opened in binary mode, rather than text mode.
58
 
# On other platforms, O_BINARY doesn't exist, because
59
 
# they always open in binary mode, so it is okay to
60
 
# OR with 0 on those platforms
61
 
O_BINARY = getattr(os, 'O_BINARY', 0)
62
 
 
63
 
 
64
42
def make_readonly(filename):
65
43
    """Make a filename read-only."""
66
44
    mod = os.stat(filename).st_mode
93
71
        return f
94
72
 
95
73
 
96
 
_directory_kind = 'directory'
97
 
 
98
 
_formats = {
99
 
    stat.S_IFDIR:_directory_kind,
100
 
    stat.S_IFCHR:'chardev',
101
 
    stat.S_IFBLK:'block',
102
 
    stat.S_IFREG:'file',
103
 
    stat.S_IFIFO:'fifo',
104
 
    stat.S_IFLNK:'symlink',
105
 
    stat.S_IFSOCK:'socket',
106
 
}
107
 
 
108
 
 
109
 
def file_kind_from_stat_mode(stat_mode, _formats=_formats, _unknown='unknown'):
110
 
    """Generate a file kind from a stat mode. This is used in walkdirs.
111
 
 
112
 
    Its performance is critical: Do not mutate without careful benchmarking.
113
 
    """
114
 
    try:
115
 
        return _formats[stat_mode & 0170000]
116
 
    except KeyError:
117
 
        return _unknown
118
 
 
119
 
 
120
 
def file_kind(f, _lstat=os.lstat, _mapper=file_kind_from_stat_mode):
121
 
    try:
122
 
        return _mapper(_lstat(f).st_mode)
123
 
    except OSError, e:
124
 
        if getattr(e, 'errno', None) == errno.ENOENT:
125
 
            raise bzrlib.errors.NoSuchFile(f)
126
 
        raise
127
 
 
128
 
 
129
 
def get_umask():
130
 
    """Return the current umask"""
131
 
    # Assume that people aren't messing with the umask while running
132
 
    # XXX: This is not thread safe, but there is no way to get the
133
 
    #      umask without setting it
134
 
    umask = os.umask(0)
135
 
    os.umask(umask)
136
 
    return umask
 
74
def file_kind(f):
 
75
    mode = os.lstat(f)[ST_MODE]
 
76
    if S_ISREG(mode):
 
77
        return 'file'
 
78
    elif S_ISDIR(mode):
 
79
        return 'directory'
 
80
    elif S_ISLNK(mode):
 
81
        return 'symlink'
 
82
    elif S_ISCHR(mode):
 
83
        return 'chardev'
 
84
    elif S_ISBLK(mode):
 
85
        return 'block'
 
86
    elif S_ISFIFO(mode):
 
87
        return 'fifo'
 
88
    elif S_ISSOCK(mode):
 
89
        return 'socket'
 
90
    else:
 
91
        return 'unknown'
137
92
 
138
93
 
139
94
def kind_marker(kind):
140
95
    if kind == 'file':
141
96
        return ''
142
 
    elif kind == _directory_kind:
 
97
    elif kind == 'directory':
143
98
        return '/'
144
99
    elif kind == 'symlink':
145
100
        return '@'
146
101
    else:
147
102
        raise BzrError('invalid file kind %r' % kind)
148
103
 
149
 
lexists = getattr(os.path, 'lexists', None)
150
 
if lexists is None:
151
 
    def lexists(f):
152
 
        try:
153
 
            if hasattr(os, 'lstat'):
154
 
                os.lstat(f)
155
 
            else:
156
 
                os.stat(f)
157
 
            return True
158
 
        except OSError,e:
159
 
            if e.errno == errno.ENOENT:
160
 
                return False;
161
 
            else:
162
 
                raise BzrError("lstat/stat of (%r): %r" % (f, e))
163
 
 
 
104
def lexists(f):
 
105
    if hasattr(os.path, 'lexists'):
 
106
        return os.path.lexists(f)
 
107
    try:
 
108
        if hasattr(os, 'lstat'):
 
109
            os.lstat(f)
 
110
        else:
 
111
            os.stat(f)
 
112
        return True
 
113
    except OSError,e:
 
114
        if e.errno == errno.ENOENT:
 
115
            return False;
 
116
        else:
 
117
            raise BzrError("lstat/stat of (%r): %r" % (f, e))
164
118
 
165
119
def fancy_rename(old, new, rename_func, unlink_func):
166
120
    """A fancy rename, when you don't have atomic rename.
175
129
    import random
176
130
    base = os.path.basename(new)
177
131
    dirname = os.path.dirname(new)
178
 
    tmp_name = u'tmp.%s.%.9f.%d.%s' % (base, time.time(), os.getpid(), rand_chars(10))
 
132
    tmp_name = u'tmp.%s.%.9f.%d.%d' % (base, time.time(), os.getpid(), random.randint(0, 0x7FFFFFFF))
179
133
    tmp_name = pathjoin(dirname, tmp_name)
180
134
 
181
135
    # Rename the file out of the way, but keep track if it didn't exist
216
170
            else:
217
171
                rename_func(tmp_name, new)
218
172
 
219
 
 
220
 
# In Python 2.4.2 and older, os.path.abspath and os.path.realpath
221
 
# choke on a Unicode string containing a relative path if
222
 
# os.getcwd() returns a non-sys.getdefaultencoding()-encoded
223
 
# string.
224
 
_fs_enc = sys.getfilesystemencoding()
225
 
def _posix_abspath(path):
226
 
    # jam 20060426 rather than encoding to fsencoding
227
 
    # copy posixpath.abspath, but use os.getcwdu instead
228
 
    if not posixpath.isabs(path):
229
 
        path = posixpath.join(getcwd(), path)
230
 
    return posixpath.normpath(path)
231
 
 
232
 
 
233
 
def _posix_realpath(path):
234
 
    return posixpath.realpath(path.encode(_fs_enc)).decode(_fs_enc)
235
 
 
236
 
 
237
 
def _win32_fixdrive(path):
238
 
    """Force drive letters to be consistent.
239
 
 
240
 
    win32 is inconsistent whether it returns lower or upper case
241
 
    and even if it was consistent the user might type the other
242
 
    so we force it to uppercase
243
 
    running python.exe under cmd.exe return capital C:\\
244
 
    running win32 python inside a cygwin shell returns lowercase c:\\
245
 
    """
246
 
    drive, path = _nt_splitdrive(path)
247
 
    return drive.upper() + path
248
 
 
249
 
 
250
 
def _win32_abspath(path):
251
 
    # Real _nt_abspath doesn't have a problem with a unicode cwd
252
 
    return _win32_fixdrive(_nt_abspath(unicode(path)).replace('\\', '/'))
253
 
 
254
 
 
255
 
def _win32_realpath(path):
256
 
    # Real _nt_realpath doesn't have a problem with a unicode cwd
257
 
    return _win32_fixdrive(_nt_realpath(unicode(path)).replace('\\', '/'))
258
 
 
259
 
 
260
 
def _win32_pathjoin(*args):
261
 
    return _nt_join(*args).replace('\\', '/')
262
 
 
263
 
 
264
 
def _win32_normpath(path):
265
 
    return _win32_fixdrive(_nt_normpath(unicode(path)).replace('\\', '/'))
266
 
 
267
 
 
268
 
def _win32_getcwd():
269
 
    return _win32_fixdrive(os.getcwdu().replace('\\', '/'))
270
 
 
271
 
 
272
 
def _win32_mkdtemp(*args, **kwargs):
273
 
    return _win32_fixdrive(tempfile.mkdtemp(*args, **kwargs).replace('\\', '/'))
274
 
 
275
 
 
276
 
def _win32_rename(old, new):
277
 
    """We expect to be able to atomically replace 'new' with old.
278
 
 
279
 
    On win32, if new exists, it must be moved out of the way first,
280
 
    and then deleted. 
281
 
    """
282
 
    try:
283
 
        fancy_rename(old, new, rename_func=os.rename, unlink_func=os.unlink)
284
 
    except OSError, e:
285
 
        if e.errno in (errno.EPERM, errno.EACCES, errno.EBUSY, errno.EINVAL):
286
 
            # If we try to rename a non-existant file onto cwd, we get 
287
 
            # EPERM or EACCES instead of ENOENT, this will raise ENOENT 
288
 
            # if the old path doesn't exist, sometimes we get EACCES
289
 
            # On Linux, we seem to get EBUSY, on Mac we get EINVAL
290
 
            os.lstat(old)
291
 
        raise
292
 
 
293
 
 
294
 
def _mac_getcwd():
295
 
    return unicodedata.normalize('NFKC', os.getcwdu())
296
 
 
297
 
 
298
 
# Default is to just use the python builtins, but these can be rebound on
299
 
# particular platforms.
300
 
abspath = _posix_abspath
301
 
realpath = _posix_realpath
 
173
# Default is to just use the python builtins
 
174
abspath = os.path.abspath
 
175
realpath = os.path.realpath
302
176
pathjoin = os.path.join
303
177
normpath = os.path.normpath
304
178
getcwd = os.getcwdu
306
180
rename = os.rename
307
181
dirname = os.path.dirname
308
182
basename = os.path.basename
309
 
rmtree = shutil.rmtree
310
 
 
311
 
MIN_ABS_PATHLENGTH = 1
312
 
 
 
183
 
 
184
if os.name == "posix":
 
185
    # In Python 2.4.2 and older, os.path.abspath and os.path.realpath
 
186
    # choke on a Unicode string containing a relative path if
 
187
    # os.getcwd() returns a non-sys.getdefaultencoding()-encoded
 
188
    # string.
 
189
    _fs_enc = sys.getfilesystemencoding()
 
190
    def abspath(path):
 
191
        return os.path.abspath(path.encode(_fs_enc)).decode(_fs_enc)
 
192
 
 
193
    def realpath(path):
 
194
        return os.path.realpath(path.encode(_fs_enc)).decode(_fs_enc)
313
195
 
314
196
if sys.platform == 'win32':
315
 
    abspath = _win32_abspath
316
 
    realpath = _win32_realpath
317
 
    pathjoin = _win32_pathjoin
318
 
    normpath = _win32_normpath
319
 
    getcwd = _win32_getcwd
320
 
    mkdtemp = _win32_mkdtemp
321
 
    rename = _win32_rename
322
 
 
323
 
    MIN_ABS_PATHLENGTH = 3
324
 
 
325
 
    def _win32_delete_readonly(function, path, excinfo):
326
 
        """Error handler for shutil.rmtree function [for win32]
327
 
        Helps to remove files and dirs marked as read-only.
328
 
        """
329
 
        type_, value = excinfo[:2]
330
 
        if function in (os.remove, os.rmdir) \
331
 
            and type_ == OSError \
332
 
            and value.errno == errno.EACCES:
333
 
            bzrlib.osutils.make_writable(path)
334
 
            function(path)
335
 
        else:
336
 
            raise
337
 
 
338
 
    def rmtree(path, ignore_errors=False, onerror=_win32_delete_readonly):
339
 
        """Replacer for shutil.rmtree: could remove readonly dirs/files"""
340
 
        return shutil.rmtree(path, ignore_errors, onerror)
341
 
elif sys.platform == 'darwin':
342
 
    getcwd = _mac_getcwd
343
 
 
344
 
 
345
 
def get_terminal_encoding():
346
 
    """Find the best encoding for printing to the screen.
347
 
 
348
 
    This attempts to check both sys.stdout and sys.stdin to see
349
 
    what encoding they are in, and if that fails it falls back to
350
 
    bzrlib.user_encoding.
351
 
    The problem is that on Windows, locale.getpreferredencoding()
352
 
    is not the same encoding as that used by the console:
353
 
    http://mail.python.org/pipermail/python-list/2003-May/162357.html
354
 
 
355
 
    On my standard US Windows XP, the preferred encoding is
356
 
    cp1252, but the console is cp437
357
 
    """
358
 
    output_encoding = getattr(sys.stdout, 'encoding', None)
359
 
    if not output_encoding:
360
 
        input_encoding = getattr(sys.stdin, 'encoding', None)
361
 
        if not input_encoding:
362
 
            output_encoding = bzrlib.user_encoding
363
 
            mutter('encoding stdout as bzrlib.user_encoding %r', output_encoding)
364
 
        else:
365
 
            output_encoding = input_encoding
366
 
            mutter('encoding stdout as sys.stdin encoding %r', output_encoding)
367
 
    else:
368
 
        mutter('encoding stdout as sys.stdout encoding %r', output_encoding)
369
 
    return output_encoding
 
197
    # We need to use the Unicode-aware os.path.abspath and
 
198
    # os.path.realpath on Windows systems.
 
199
    def abspath(path):
 
200
        return os.path.abspath(path).replace('\\', '/')
 
201
 
 
202
    def realpath(path):
 
203
        return os.path.realpath(path).replace('\\', '/')
 
204
 
 
205
    def pathjoin(*args):
 
206
        return os.path.join(*args).replace('\\', '/')
 
207
 
 
208
    def normpath(path):
 
209
        return os.path.normpath(path).replace('\\', '/')
 
210
 
 
211
    def getcwd():
 
212
        return os.getcwdu().replace('\\', '/')
 
213
 
 
214
    def mkdtemp(*args, **kwargs):
 
215
        return tempfile.mkdtemp(*args, **kwargs).replace('\\', '/')
 
216
 
 
217
    def rename(old, new):
 
218
        fancy_rename(old, new, rename_func=os.rename, unlink_func=os.unlink)
370
219
 
371
220
 
372
221
def normalizepath(f):
477
326
        return False
478
327
 
479
328
 
480
 
def is_inside_or_parent_of_any(dir_list, fname):
481
 
    """True if fname is a child or a parent of any of the given files."""
482
 
    for dirname in dir_list:
483
 
        if is_inside(dirname, fname) or is_inside(fname, dirname):
484
 
            return True
485
 
    else:
486
 
        return False
487
 
 
488
 
 
489
329
def pumpfile(fromfile, tofile):
490
330
    """Copy contents of one file to another."""
491
331
    BUFSIZE = 32768
496
336
        tofile.write(b)
497
337
 
498
338
 
499
 
def file_iterator(input_file, readsize=32768):
500
 
    while True:
501
 
        b = input_file.read(readsize)
502
 
        if len(b) == 0:
503
 
            break
504
 
        yield b
505
 
 
506
 
 
507
339
def sha_file(f):
508
340
    if hasattr(f, 'tell'):
509
341
        assert f.tell() == 0
601
433
    """Return size of given open file."""
602
434
    return os.fstat(f.fileno())[ST_SIZE]
603
435
 
604
 
 
605
436
# Define rand_bytes based on platform.
606
437
try:
607
438
    # Python 2.4 and later have os.urandom,
624
455
                n -= 1
625
456
            return s
626
457
 
627
 
 
628
 
ALNUM = '0123456789abcdefghijklmnopqrstuvwxyz'
629
 
def rand_chars(num):
630
 
    """Return a random string of num alphanumeric characters
631
 
    
632
 
    The result only contains lowercase chars because it may be used on 
633
 
    case-insensitive filesystems.
634
 
    """
635
 
    s = ''
636
 
    for raw_byte in rand_bytes(num):
637
 
        s += ALNUM[ord(raw_byte) % 36]
638
 
    return s
639
 
 
640
 
 
641
458
## TODO: We could later have path objects that remember their list
642
459
## decomposition (might be too tricksy though.)
643
460
 
681
498
    return pathjoin(*p)
682
499
 
683
500
 
684
 
@deprecated_function(zero_nine)
685
501
def appendpath(p1, p2):
686
502
    if p1 == '':
687
503
        return p2
691
507
 
692
508
def split_lines(s):
693
509
    """Split s into lines, but without removing the newline characters."""
694
 
    lines = s.split('\n')
695
 
    result = [line + '\n' for line in lines[:-1]]
696
 
    if lines[-1]:
697
 
        result.append(lines[-1])
698
 
    return result
 
510
    return StringIO(s).readlines()
699
511
 
700
512
 
701
513
def hardlinks_good():
714
526
            raise
715
527
        copyfile(src, dest)
716
528
 
717
 
def delete_any(full_path):
718
 
    """Delete a file or directory."""
719
 
    try:
720
 
        os.unlink(full_path)
721
 
    except OSError, e:
722
 
    # We may be renaming a dangling inventory id
723
 
        if e.errno not in (errno.EISDIR, errno.EACCES, errno.EPERM):
724
 
            raise
725
 
        os.rmdir(full_path)
726
 
 
727
529
 
728
530
def has_symlinks():
729
531
    if hasattr(os, 'symlink'):
758
560
 
759
561
    os.path.commonprefix (python2.4) has a bad bug that it works just
760
562
    on string prefixes, assuming that '/u' is a prefix of '/u2'.  This
761
 
    avoids that problem.
762
 
    """
763
 
 
764
 
    assert len(base) >= MIN_ABS_PATHLENGTH, ('Length of base must be equal or'
765
 
        ' exceed the platform minimum length (which is %d)' % 
766
 
        MIN_ABS_PATHLENGTH)
767
 
 
 
563
    avoids that problem."""
768
564
    rp = abspath(path)
769
565
 
770
566
    s = []
776
572
        if tail:
777
573
            s.insert(0, tail)
778
574
    else:
 
575
        # XXX This should raise a NotChildPath exception, as its not tied
 
576
        # to branch anymore.
779
577
        raise PathNotChild(rp, base)
780
578
 
781
579
    if s:
797
595
    try:
798
596
        return unicode_or_utf8_string.decode('utf8')
799
597
    except UnicodeDecodeError:
800
 
        raise BzrBadParameterNotUnicode(unicode_or_utf8_string)
801
 
 
802
 
 
803
 
_platform_normalizes_filenames = False
804
 
if sys.platform == 'darwin':
805
 
    _platform_normalizes_filenames = True
806
 
 
807
 
 
808
 
def normalizes_filenames():
809
 
    """Return True if this platform normalizes unicode filenames.
810
 
 
811
 
    Mac OSX does, Windows/Linux do not.
812
 
    """
813
 
    return _platform_normalizes_filenames
814
 
 
815
 
 
816
 
def _accessible_normalized_filename(path):
817
 
    """Get the unicode normalized path, and if you can access the file.
818
 
 
819
 
    On platforms where the system normalizes filenames (Mac OSX),
820
 
    you can access a file by any path which will normalize correctly.
821
 
    On platforms where the system does not normalize filenames 
822
 
    (Windows, Linux), you have to access a file by its exact path.
823
 
 
824
 
    Internally, bzr only supports NFC/NFKC normalization, since that is 
825
 
    the standard for XML documents.
826
 
 
827
 
    So return the normalized path, and a flag indicating if the file
828
 
    can be accessed by that path.
829
 
    """
830
 
 
831
 
    return unicodedata.normalize('NFKC', unicode(path)), True
832
 
 
833
 
 
834
 
def _inaccessible_normalized_filename(path):
835
 
    __doc__ = _accessible_normalized_filename.__doc__
836
 
 
837
 
    normalized = unicodedata.normalize('NFKC', unicode(path))
838
 
    return normalized, normalized == path
839
 
 
840
 
 
841
 
if _platform_normalizes_filenames:
842
 
    normalized_filename = _accessible_normalized_filename
843
 
else:
844
 
    normalized_filename = _inaccessible_normalized_filename
 
598
        raise BzrBadParameter(unicode_or_utf8_string)
845
599
 
846
600
 
847
601
def terminal_width():
848
602
    """Return estimated terminal width."""
849
 
    if sys.platform == 'win32':
850
 
        import bzrlib.win32console
851
 
        return bzrlib.win32console.get_console_size()[0]
852
 
    width = 0
 
603
 
 
604
    # TODO: Do something smart on Windows?
 
605
 
 
606
    # TODO: Is there anything that gets a better update when the window
 
607
    # is resized while the program is running? We could use the Python termcap
 
608
    # library.
853
609
    try:
854
 
        import struct, fcntl, termios
855
 
        s = struct.pack('HHHH', 0, 0, 0, 0)
856
 
        x = fcntl.ioctl(1, termios.TIOCGWINSZ, s)
857
 
        width = struct.unpack('HHHH', x)[1]
858
 
    except IOError:
859
 
        pass
860
 
    if width <= 0:
861
 
        try:
862
 
            width = int(os.environ['COLUMNS'])
863
 
        except:
864
 
            pass
865
 
    if width <= 0:
866
 
        width = 80
867
 
 
868
 
    return width
869
 
 
870
 
def supports_executable():
871
 
    return sys.platform != "win32"
872
 
 
873
 
 
874
 
_validWin32PathRE = re.compile(r'^([A-Za-z]:[/\\])?[^:<>*"?\|]*$')
875
 
 
876
 
 
877
 
def check_legal_path(path):
878
 
    """Check whether the supplied path is legal.  
879
 
    This is only required on Windows, so we don't test on other platforms
880
 
    right now.
881
 
    """
882
 
    if sys.platform != "win32":
883
 
        return
884
 
    if _validWin32PathRE.match(path) is None:
885
 
        raise IllegalPath(path)
886
 
 
887
 
 
888
 
def walkdirs(top, prefix=""):
889
 
    """Yield data about all the directories in a tree.
890
 
    
891
 
    This yields all the data about the contents of a directory at a time.
892
 
    After each directory has been yielded, if the caller has mutated the list
893
 
    to exclude some directories, they are then not descended into.
894
 
    
895
 
    The data yielded is of the form:
896
 
    ((directory-relpath, directory-path-from-top),
897
 
    [(relpath, basename, kind, lstat), ...]),
898
 
     - directory-relpath is the relative path of the directory being returned
899
 
       with respect to top. prefix is prepended to this.
900
 
     - directory-path-from-root is the path including top for this directory. 
901
 
       It is suitable for use with os functions.
902
 
     - relpath is the relative path within the subtree being walked.
903
 
     - basename is the basename of the path
904
 
     - kind is the kind of the file now. If unknown then the file is not
905
 
       present within the tree - but it may be recorded as versioned. See
906
 
       versioned_kind.
907
 
     - lstat is the stat data *if* the file was statted.
908
 
     - planned, not implemented: 
909
 
       path_from_tree_root is the path from the root of the tree.
910
 
 
911
 
    :param prefix: Prefix the relpaths that are yielded with 'prefix'. This 
912
 
        allows one to walk a subtree but get paths that are relative to a tree
913
 
        rooted higher up.
914
 
    :return: an iterator over the dirs.
915
 
    """
916
 
    #TODO there is a bit of a smell where the results of the directory-
917
 
    # summary in this, and the path from the root, may not agree 
918
 
    # depending on top and prefix - i.e. ./foo and foo as a pair leads to
919
 
    # potentially confusing output. We should make this more robust - but
920
 
    # not at a speed cost. RBC 20060731
921
 
    lstat = os.lstat
922
 
    pending = []
923
 
    _directory = _directory_kind
924
 
    _listdir = listdir
925
 
    pending = [(prefix, "", _directory, None, top)]
926
 
    while pending:
927
 
        dirblock = []
928
 
        currentdir = pending.pop()
929
 
        # 0 - relpath, 1- basename, 2- kind, 3- stat, 4-toppath
930
 
        top = currentdir[4]
931
 
        if currentdir[0]:
932
 
            relroot = currentdir[0] + '/'
933
 
        else:
934
 
            relroot = ""
935
 
        for name in sorted(_listdir(top)):
936
 
            abspath = top + '/' + name
937
 
            statvalue = lstat(abspath)
938
 
            dirblock.append((relroot + name, name,
939
 
                file_kind_from_stat_mode(statvalue.st_mode),
940
 
                statvalue, abspath))
941
 
        yield (currentdir[0], top), dirblock
942
 
        # push the user specified dirs from dirblock
943
 
        for dir in reversed(dirblock):
944
 
            if dir[2] == _directory:
945
 
                pending.append(dir)
946
 
 
947
 
 
948
 
def copy_tree(from_path, to_path, handlers={}):
949
 
    """Copy all of the entries in from_path into to_path.
950
 
 
951
 
    :param from_path: The base directory to copy. 
952
 
    :param to_path: The target directory. If it does not exist, it will
953
 
        be created.
954
 
    :param handlers: A dictionary of functions, which takes a source and
955
 
        destinations for files, directories, etc.
956
 
        It is keyed on the file kind, such as 'directory', 'symlink', or 'file'
957
 
        'file', 'directory', and 'symlink' should always exist.
958
 
        If they are missing, they will be replaced with 'os.mkdir()',
959
 
        'os.readlink() + os.symlink()', and 'shutil.copy2()', respectively.
960
 
    """
961
 
    # Now, just copy the existing cached tree to the new location
962
 
    # We use a cheap trick here.
963
 
    # Absolute paths are prefixed with the first parameter
964
 
    # relative paths are prefixed with the second.
965
 
    # So we can get both the source and target returned
966
 
    # without any extra work.
967
 
 
968
 
    def copy_dir(source, dest):
969
 
        os.mkdir(dest)
970
 
 
971
 
    def copy_link(source, dest):
972
 
        """Copy the contents of a symlink"""
973
 
        link_to = os.readlink(source)
974
 
        os.symlink(link_to, dest)
975
 
 
976
 
    real_handlers = {'file':shutil.copy2,
977
 
                     'symlink':copy_link,
978
 
                     'directory':copy_dir,
979
 
                    }
980
 
    real_handlers.update(handlers)
981
 
 
982
 
    if not os.path.exists(to_path):
983
 
        real_handlers['directory'](from_path, to_path)
984
 
 
985
 
    for dir_info, entries in walkdirs(from_path, prefix=to_path):
986
 
        for relpath, name, kind, st, abspath in entries:
987
 
            real_handlers[kind](abspath, relpath)
988
 
 
989
 
 
990
 
def path_prefix_key(path):
991
 
    """Generate a prefix-order path key for path.
992
 
 
993
 
    This can be used to sort paths in the same way that walkdirs does.
994
 
    """
995
 
    return (dirname(path) , path)
996
 
 
997
 
 
998
 
def compare_paths_prefix_order(path_a, path_b):
999
 
    """Compare path_a and path_b to generate the same order walkdirs uses."""
1000
 
    key_a = path_prefix_key(path_a)
1001
 
    key_b = path_prefix_key(path_b)
1002
 
    return cmp(key_a, key_b)
 
610
        return int(os.environ['COLUMNS'])
 
611
    except (IndexError, KeyError, ValueError):
 
612
        return 80