~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/osutils.py

  • Committer: Vincent Ladeuil
  • Date: 2011-06-10 08:11:44 UTC
  • mto: (5954.2.5 merge-into-empty-fixups)
  • mto: This revision was merged to the branch mainline in revision 5967.
  • Revision ID: v.ladeuil+lp@free.fr-20110610081144-9g1gppbjok4z8mxf
Nitpicks.

Show diffs side-by-side

added added

removed removed

Lines of Context:
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
16
 
17
 
from __future__ import absolute_import
18
 
 
19
17
import errno
20
18
import os
21
19
import re
28
26
lazy_import(globals(), """
29
27
from datetime import datetime
30
28
import getpass
31
 
import locale
32
29
import ntpath
33
30
import posixpath
34
 
import select
35
31
# We need to import both shutil and rmtree as we export the later on posix
36
32
# and need the former on windows
37
33
import shutil
46
42
 
47
43
from bzrlib import (
48
44
    cache_utf8,
49
 
    config,
50
45
    errors,
51
46
    trace,
52
47
    win32utils,
53
48
    )
54
 
from bzrlib.i18n import gettext
55
49
""")
56
50
 
57
51
from bzrlib.symbol_versioning import (
58
 
    DEPRECATED_PARAMETER,
59
52
    deprecated_function,
60
53
    deprecated_in,
61
 
    deprecated_passed,
62
 
    warn as warn_deprecated,
63
54
    )
64
55
 
65
56
from hashlib import (
69
60
 
70
61
 
71
62
import bzrlib
72
 
from bzrlib import symbol_versioning, _fs_enc
 
63
from bzrlib import symbol_versioning
73
64
 
74
65
 
75
66
# Cross platform wall-clock time functionality with decent resolution.
97
88
        user_encoding = get_user_encoding()
98
89
        return [a.decode(user_encoding) for a in sys.argv[1:]]
99
90
    except UnicodeDecodeError:
100
 
        raise errors.BzrError(gettext("Parameter {0!r} encoding is unsupported by {1} "
101
 
            "application locale.").format(a, user_encoding))
 
91
        raise errors.BzrError("Parameter %r encoding is unsupported by %s "
 
92
            "application locale." % (a, user_encoding))
102
93
 
103
94
 
104
95
def make_readonly(filename):
106
97
    mod = os.lstat(filename).st_mode
107
98
    if not stat.S_ISLNK(mod):
108
99
        mod = mod & 0777555
109
 
        chmod_if_possible(filename, mod)
 
100
        os.chmod(filename, mod)
110
101
 
111
102
 
112
103
def make_writable(filename):
113
104
    mod = os.lstat(filename).st_mode
114
105
    if not stat.S_ISLNK(mod):
115
106
        mod = mod | 0200
116
 
        chmod_if_possible(filename, mod)
117
 
 
118
 
 
119
 
def chmod_if_possible(filename, mode):
120
 
    # Set file mode if that can be safely done.
121
 
    # Sometimes even on unix the filesystem won't allow it - see
122
 
    # https://bugs.launchpad.net/bzr/+bug/606537
123
 
    try:
124
 
        # It is probably faster to just do the chmod, rather than
125
 
        # doing a stat, and then trying to compare
126
 
        os.chmod(filename, mode)
127
 
    except (IOError, OSError),e:
128
 
        # Permission/access denied seems to commonly happen on smbfs; there's
129
 
        # probably no point warning about it.
130
 
        # <https://bugs.launchpad.net/bzr/+bug/606537>
131
 
        if getattr(e, 'errno') in (errno.EPERM, errno.EACCES):
132
 
            trace.mutter("ignore error on chmod of %r: %r" % (
133
 
                filename, e))
134
 
            return
135
 
        raise
 
107
        os.chmod(filename, mod)
136
108
 
137
109
 
138
110
def minimum_path_selection(paths):
217
189
            if e.errno == errno.ENOENT:
218
190
                return False;
219
191
            else:
220
 
                raise errors.BzrError(gettext("lstat/stat of ({0!r}): {1!r}").format(f, e))
 
192
                raise errors.BzrError("lstat/stat of (%r): %r" % (f, e))
221
193
 
222
194
 
223
195
def fancy_rename(old, new, rename_func, unlink_func):
299
271
# choke on a Unicode string containing a relative path if
300
272
# os.getcwd() returns a non-sys.getdefaultencoding()-encoded
301
273
# string.
 
274
_fs_enc = sys.getfilesystemencoding() or 'utf-8'
302
275
def _posix_abspath(path):
303
276
    # jam 20060426 rather than encoding to fsencoding
304
277
    # copy posixpath.abspath, but use os.getcwdu instead
305
278
    if not posixpath.isabs(path):
306
279
        path = posixpath.join(getcwd(), path)
307
 
    return _posix_normpath(path)
 
280
    return posixpath.normpath(path)
308
281
 
309
282
 
310
283
def _posix_realpath(path):
311
284
    return posixpath.realpath(path.encode(_fs_enc)).decode(_fs_enc)
312
285
 
313
286
 
314
 
def _posix_normpath(path):
315
 
    path = posixpath.normpath(path)
316
 
    # Bug 861008: posixpath.normpath() returns a path normalized according to
317
 
    # the POSIX standard, which stipulates (for compatibility reasons) that two
318
 
    # leading slashes must not be simplified to one, and only if there are 3 or
319
 
    # more should they be simplified as one. So we treat the leading 2 slashes
320
 
    # as a special case here by simply removing the first slash, as we consider
321
 
    # that breaking POSIX compatibility for this obscure feature is acceptable.
322
 
    # This is not a paranoid precaution, as we notably get paths like this when
323
 
    # the repo is hosted at the root of the filesystem, i.e. in "/".    
324
 
    if path.startswith('//'):
325
 
        path = path[1:]
326
 
    return path
327
 
 
328
 
 
329
 
def _posix_path_from_environ(key):
330
 
    """Get unicode path from `key` in environment or None if not present
331
 
 
332
 
    Note that posix systems use arbitrary byte strings for filesystem objects,
333
 
    so a path that raises BadFilenameEncoding here may still be accessible.
334
 
    """
335
 
    val = os.environ.get(key, None)
336
 
    if val is None:
337
 
        return val
338
 
    try:
339
 
        return val.decode(_fs_enc)
340
 
    except UnicodeDecodeError:
341
 
        # GZ 2011-12-12:Ideally want to include `key` in the exception message
342
 
        raise errors.BadFilenameEncoding(val, _fs_enc)
343
 
 
344
 
 
345
 
def _posix_get_home_dir():
346
 
    """Get the home directory of the current user as a unicode path"""
347
 
    path = posixpath.expanduser("~")
348
 
    try:
349
 
        return path.decode(_fs_enc)
350
 
    except UnicodeDecodeError:
351
 
        raise errors.BadFilenameEncoding(path, _fs_enc)
352
 
 
353
 
 
354
 
def _posix_getuser_unicode():
355
 
    """Get username from environment or password database as unicode"""
356
 
    name = getpass.getuser()
357
 
    user_encoding = get_user_encoding()
358
 
    try:
359
 
        return name.decode(user_encoding)
360
 
    except UnicodeDecodeError:
361
 
        raise errors.BzrError("Encoding of username %r is unsupported by %s "
362
 
            "application locale." % (name, user_encoding))
363
 
 
364
 
 
365
287
def _win32_fixdrive(path):
366
288
    """Force drive letters to be consistent.
367
289
 
450
372
    return unicodedata.normalize('NFC', os.getcwdu())
451
373
 
452
374
 
453
 
def _rename_wrap_exception(rename_func):
454
 
    """Adds extra information to any exceptions that come from rename().
455
 
 
456
 
    The exception has an updated message and 'old_filename' and 'new_filename'
457
 
    attributes.
458
 
    """
459
 
 
460
 
    def _rename_wrapper(old, new):
461
 
        try:
462
 
            rename_func(old, new)
463
 
        except OSError, e:
464
 
            detailed_error = OSError(e.errno, e.strerror +
465
 
                                " [occurred when renaming '%s' to '%s']" %
466
 
                                (old, new))
467
 
            detailed_error.old_filename = old
468
 
            detailed_error.new_filename = new
469
 
            raise detailed_error
470
 
 
471
 
    return _rename_wrapper
472
 
 
473
 
# Default rename wraps os.rename()
474
 
rename = _rename_wrap_exception(os.rename)
475
 
 
476
375
# Default is to just use the python builtins, but these can be rebound on
477
376
# particular platforms.
478
377
abspath = _posix_abspath
479
378
realpath = _posix_realpath
480
379
pathjoin = os.path.join
481
 
normpath = _posix_normpath
482
 
path_from_environ = _posix_path_from_environ
483
 
_get_home_dir = _posix_get_home_dir
484
 
getuser_unicode = _posix_getuser_unicode
 
380
normpath = os.path.normpath
485
381
getcwd = os.getcwdu
 
382
rename = os.rename
486
383
dirname = os.path.dirname
487
384
basename = os.path.basename
488
385
split = os.path.split
510
407
    normpath = _win32_normpath
511
408
    getcwd = _win32_getcwd
512
409
    mkdtemp = _win32_mkdtemp
513
 
    rename = _rename_wrap_exception(_win32_rename)
 
410
    rename = _win32_rename
514
411
    try:
515
412
        from bzrlib import _walkdirs_win32
516
413
    except ImportError:
542
439
    f = win32utils.get_unicode_argv     # special function or None
543
440
    if f is not None:
544
441
        get_unicode_argv = f
545
 
    path_from_environ = win32utils.get_environ_unicode
546
 
    _get_home_dir = win32utils.get_home_location
547
 
    getuser_unicode = win32utils.get_user_name
548
442
 
549
443
elif sys.platform == 'darwin':
550
444
    getcwd = _mac_getcwd
982
876
    return os.fstat(f.fileno())[stat.ST_SIZE]
983
877
 
984
878
 
985
 
# Alias os.urandom to support platforms (which?) without /dev/urandom and 
986
 
# override if it doesn't work. Avoid checking on windows where there is
987
 
# significant initialisation cost that can be avoided for some bzr calls.
988
 
 
989
 
rand_bytes = os.urandom
990
 
 
991
 
if rand_bytes.__module__ != "nt":
 
879
# Define rand_bytes based on platform.
 
880
try:
 
881
    # Python 2.4 and later have os.urandom,
 
882
    # but it doesn't work on some arches
 
883
    os.urandom(1)
 
884
    rand_bytes = os.urandom
 
885
except (NotImplementedError, AttributeError):
 
886
    # If python doesn't have os.urandom, or it doesn't work,
 
887
    # then try to first pull random data from /dev/urandom
992
888
    try:
993
 
        rand_bytes(1)
994
 
    except NotImplementedError:
 
889
        rand_bytes = file('/dev/urandom', 'rb').read
 
890
    # Otherwise, use this hack as a last resort
 
891
    except (IOError, OSError):
995
892
        # not well seeded, but better than nothing
996
893
        def rand_bytes(n):
997
894
            import random
1027
924
    rps = []
1028
925
    for f in ps:
1029
926
        if f == '..':
1030
 
            raise errors.BzrError(gettext("sorry, %r not allowed in path") % f)
 
927
            raise errors.BzrError("sorry, %r not allowed in path" % f)
1031
928
        elif (f == '.') or (f == ''):
1032
929
            pass
1033
930
        else:
1038
935
def joinpath(p):
1039
936
    for f in p:
1040
937
        if (f == '..') or (f is None) or (f == ''):
1041
 
            raise errors.BzrError(gettext("sorry, %r not allowed in path") % f)
 
938
            raise errors.BzrError("sorry, %r not allowed in path" % f)
1042
939
    return pathjoin(*p)
1043
940
 
1044
941
 
1088
985
def report_extension_load_failures():
1089
986
    if not _extension_load_failures:
1090
987
        return
1091
 
    if config.GlobalStack().get('ignore_missing_extensions'):
 
988
    from bzrlib.config import GlobalConfig
 
989
    if GlobalConfig().get_user_option_as_bool('ignore_missing_extensions'):
1092
990
        return
1093
991
    # the warnings framework should by default show this only once
1094
992
    from bzrlib.trace import warning
1256
1154
 
1257
1155
    if len(base) < MIN_ABS_PATHLENGTH:
1258
1156
        # must have space for e.g. a drive letter
1259
 
        raise ValueError(gettext('%r is too short to calculate a relative path')
 
1157
        raise ValueError('%r is too short to calculate a relative path'
1260
1158
            % (base,))
1261
1159
 
1262
1160
    rp = abspath(path)
1837
1735
    """
1838
1736
    global _selected_dir_reader
1839
1737
    if _selected_dir_reader is None:
 
1738
        fs_encoding = _fs_enc.upper()
1840
1739
        if sys.platform == "win32" and win32utils.winver == 'Windows NT':
1841
1740
            # Win98 doesn't have unicode apis like FindFirstFileW
1842
1741
            # TODO: We possibly could support Win98 by falling back to the
1848
1747
                _selected_dir_reader = Win32ReadDir()
1849
1748
            except ImportError:
1850
1749
                pass
1851
 
        elif _fs_enc in ('utf-8', 'ascii'):
 
1750
        elif fs_encoding in ('UTF-8', 'US-ASCII', 'ANSI_X3.4-1968'):
 
1751
            # ANSI_X3.4-1968 is a form of ASCII
1852
1752
            try:
1853
1753
                from bzrlib._readdir_pyx import UTF8DirReader
1854
1754
                _selected_dir_reader = UTF8DirReader()
2013
1913
_cached_user_encoding = None
2014
1914
 
2015
1915
 
2016
 
def get_user_encoding(use_cache=DEPRECATED_PARAMETER):
 
1916
def get_user_encoding(use_cache=True):
2017
1917
    """Find out what the preferred user encoding is.
2018
1918
 
2019
1919
    This is generally the encoding that is used for command line parameters
2020
1920
    and file contents. This may be different from the terminal encoding
2021
1921
    or the filesystem encoding.
2022
1922
 
 
1923
    :param  use_cache:  Enable cache for detected encoding.
 
1924
                        (This parameter is turned on by default,
 
1925
                        and required only for selftesting)
 
1926
 
2023
1927
    :return: A string defining the preferred user encoding
2024
1928
    """
2025
1929
    global _cached_user_encoding
2026
 
    if deprecated_passed(use_cache):
2027
 
        warn_deprecated("use_cache should only have been used for tests",
2028
 
            DeprecationWarning, stacklevel=2) 
2029
 
    if _cached_user_encoding is not None:
 
1930
    if _cached_user_encoding is not None and use_cache:
2030
1931
        return _cached_user_encoding
2031
1932
 
2032
 
    if os.name == 'posix' and getattr(locale, 'CODESET', None) is not None:
2033
 
        # Use the existing locale settings and call nl_langinfo directly
2034
 
        # rather than going through getpreferredencoding. This avoids
2035
 
        # <http://bugs.python.org/issue6202> on OSX Python 2.6 and the
2036
 
        # possibility of the setlocale call throwing an error.
2037
 
        user_encoding = locale.nl_langinfo(locale.CODESET)
 
1933
    if sys.platform == 'darwin':
 
1934
        # python locale.getpreferredencoding() always return
 
1935
        # 'mac-roman' on darwin. That's a lie.
 
1936
        sys.platform = 'posix'
 
1937
        try:
 
1938
            if os.environ.get('LANG', None) is None:
 
1939
                # If LANG is not set, we end up with 'ascii', which is bad
 
1940
                # ('mac-roman' is more than ascii), so we set a default which
 
1941
                # will give us UTF-8 (which appears to work in all cases on
 
1942
                # OSX). Users are still free to override LANG of course, as
 
1943
                # long as it give us something meaningful. This work-around
 
1944
                # *may* not be needed with python 3k and/or OSX 10.5, but will
 
1945
                # work with them too -- vila 20080908
 
1946
                os.environ['LANG'] = 'en_US.UTF-8'
 
1947
            import locale
 
1948
        finally:
 
1949
            sys.platform = 'darwin'
2038
1950
    else:
2039
 
        # GZ 2011-12-19: On windows could call GetACP directly instead.
2040
 
        user_encoding = locale.getpreferredencoding(False)
 
1951
        import locale
2041
1952
 
2042
1953
    try:
2043
 
        user_encoding = codecs.lookup(user_encoding).name
2044
 
    except LookupError:
2045
 
        if user_encoding not in ("", "cp0"):
 
1954
        user_encoding = locale.getpreferredencoding()
 
1955
    except locale.Error, e:
 
1956
        sys.stderr.write('bzr: warning: %s\n'
 
1957
                         '  Could not determine what text encoding to use.\n'
 
1958
                         '  This error usually means your Python interpreter\n'
 
1959
                         '  doesn\'t support the locale set by $LANG (%s)\n'
 
1960
                         "  Continuing with ascii encoding.\n"
 
1961
                         % (e, os.environ.get('LANG')))
 
1962
        user_encoding = 'ascii'
 
1963
 
 
1964
    # Windows returns 'cp0' to indicate there is no code page. So we'll just
 
1965
    # treat that as ASCII, and not support printing unicode characters to the
 
1966
    # console.
 
1967
    #
 
1968
    # For python scripts run under vim, we get '', so also treat that as ASCII
 
1969
    if user_encoding in (None, 'cp0', ''):
 
1970
        user_encoding = 'ascii'
 
1971
    else:
 
1972
        # check encoding
 
1973
        try:
 
1974
            codecs.lookup(user_encoding)
 
1975
        except LookupError:
2046
1976
            sys.stderr.write('bzr: warning:'
2047
1977
                             ' unknown encoding %s.'
2048
1978
                             ' Continuing with ascii encoding.\n'
2049
1979
                             % user_encoding
2050
1980
                            )
2051
 
        user_encoding = 'ascii'
2052
 
    else:
2053
 
        # Get 'ascii' when setlocale has not been called or LANG=C or unset.
2054
 
        if user_encoding == 'ascii':
2055
 
            if sys.platform == 'darwin':
2056
 
                # OSX is special-cased in Python to have a UTF-8 filesystem
2057
 
                # encoding and previously had LANG set here if not present.
2058
 
                user_encoding = 'utf-8'
2059
 
            # GZ 2011-12-19: Maybe UTF-8 should be the default in this case
2060
 
            #                for some other posix platforms as well.
2061
 
 
2062
 
    _cached_user_encoding = user_encoding
 
1981
            user_encoding = 'ascii'
 
1982
 
 
1983
    if use_cache:
 
1984
        _cached_user_encoding = user_encoding
 
1985
 
2063
1986
    return user_encoding
2064
1987
 
2065
1988
 
2074
1997
    behaves inconsistently on different platforms.
2075
1998
    """
2076
1999
    if sys.platform == "win32":
 
2000
        import win32utils
2077
2001
        return win32utils.get_host_name()
2078
2002
    else:
2079
2003
        import socket
2086
2010
# data at once.
2087
2011
MAX_SOCKET_CHUNK = 64 * 1024
2088
2012
 
2089
 
_end_of_stream_errors = [errno.ECONNRESET, errno.EPIPE, errno.EINVAL]
 
2013
_end_of_stream_errors = [errno.ECONNRESET]
2090
2014
for _eno in ['WSAECONNRESET', 'WSAECONNABORTED']:
2091
2015
    _eno = getattr(errno, _eno, None)
2092
2016
    if _eno is not None:
2158
2082
    while sent_total < byte_count:
2159
2083
        try:
2160
2084
            sent = sock.send(buffer(bytes, sent_total, MAX_SOCKET_CHUNK))
2161
 
        except (socket.error, IOError), e:
2162
 
            if e.args[0] in _end_of_stream_errors:
2163
 
                raise errors.ConnectionReset(
2164
 
                    "Error trying to write to socket", e)
 
2085
        except socket.error, e:
2165
2086
            if e.args[0] != errno.EINTR:
2166
2087
                raise
2167
2088
        else:
2168
 
            if sent == 0:
2169
 
                raise errors.ConnectionReset('Sending to %s returned 0 bytes'
2170
 
                                             % (sock,))
2171
2089
            sent_total += sent
2172
 
            if report_activity is not None:
2173
 
                report_activity(sent, 'write')
 
2090
            report_activity(sent, 'write')
2174
2091
 
2175
2092
 
2176
2093
def connect_socket(address):
2261
2178
    return file_kind_from_stat_mode(mode)
2262
2179
file_kind_from_stat_mode = file_kind_from_stat_mode_thunk
2263
2180
 
2264
 
def file_stat(f, _lstat=os.lstat):
 
2181
 
 
2182
def file_kind(f, _lstat=os.lstat):
2265
2183
    try:
2266
 
        # XXX cache?
2267
 
        return _lstat(f)
 
2184
        return file_kind_from_stat_mode(_lstat(f).st_mode)
2268
2185
    except OSError, e:
2269
2186
        if getattr(e, 'errno', None) in (errno.ENOENT, errno.ENOTDIR):
2270
2187
            raise errors.NoSuchFile(f)
2271
2188
        raise
2272
2189
 
2273
 
def file_kind(f, _lstat=os.lstat):
2274
 
    stat_value = file_stat(f, _lstat)
2275
 
    return file_kind_from_stat_mode(stat_value.st_mode)
2276
2190
 
2277
2191
def until_no_eintr(f, *a, **kw):
2278
2192
    """Run f(*a, **kw), retrying if an EINTR error occurs.
2322
2236
 
2323
2237
 
2324
2238
if sys.platform == "win32":
 
2239
    import msvcrt
2325
2240
    def getchar():
2326
 
        import msvcrt
2327
2241
        return msvcrt.getch()
2328
2242
else:
 
2243
    import tty
 
2244
    import termios
2329
2245
    def getchar():
2330
 
        import tty
2331
 
        import termios
2332
2246
        fd = sys.stdin.fileno()
2333
2247
        settings = termios.tcgetattr(fd)
2334
2248
        try:
2338
2252
            termios.tcsetattr(fd, termios.TCSADRAIN, settings)
2339
2253
        return ch
2340
2254
 
2341
 
if sys.platform.startswith('linux'):
 
2255
if sys.platform == 'linux2':
2342
2256
    def _local_concurrency():
2343
2257
        try:
2344
2258
            return os.sysconf('SC_NPROCESSORS_ONLN')
2383
2297
    if concurrency is None:
2384
2298
        try:
2385
2299
            import multiprocessing
2386
 
            concurrency = multiprocessing.cpu_count()
2387
 
        except (ImportError, NotImplementedError):
 
2300
        except ImportError:
2388
2301
            # multiprocessing is only available on Python >= 2.6
2389
 
            # and multiprocessing.cpu_count() isn't implemented on all
2390
 
            # platforms
2391
2302
            try:
2392
2303
                concurrency = _local_concurrency()
2393
2304
            except (OSError, IOError):
2394
2305
                pass
 
2306
        else:
 
2307
            concurrency = multiprocessing.cpu_count()
2395
2308
    try:
2396
2309
        concurrency = int(concurrency)
2397
2310
    except (TypeError, ValueError):
2459
2372
    open_file = open
2460
2373
 
2461
2374
 
 
2375
def getuser_unicode():
 
2376
    """Return the username as unicode.
 
2377
    """
 
2378
    try:
 
2379
        user_encoding = get_user_encoding()
 
2380
        username = getpass.getuser().decode(user_encoding)
 
2381
    except UnicodeDecodeError:
 
2382
        raise errors.BzrError("Can't decode username as %s." % \
 
2383
                user_encoding)
 
2384
    return username
 
2385
 
 
2386
 
2462
2387
def available_backup_name(base, exists):
2463
2388
    """Find a non-existing backup file name.
2464
2389
 
2502
2427
    :param name: The base name of the executable.
2503
2428
    :return: The path to the executable found or None.
2504
2429
    """
 
2430
    path = os.environ.get('PATH')
 
2431
    if path is None:
 
2432
        return None
 
2433
    path = path.split(os.pathsep)
2505
2434
    if sys.platform == 'win32':
2506
2435
        exts = os.environ.get('PATHEXT', '').split(os.pathsep)
2507
2436
        exts = [ext.lower() for ext in exts]
2513
2442
            exts = [ext]
2514
2443
    else:
2515
2444
        exts = ['']
2516
 
    path = os.environ.get('PATH')
2517
 
    if path is not None:
2518
 
        path = path.split(os.pathsep)
2519
 
        for ext in exts:
2520
 
            for d in path:
2521
 
                f = os.path.join(d, name) + ext
2522
 
                if os.access(f, os.X_OK):
2523
 
                    return f
2524
 
    if sys.platform == 'win32':
2525
 
        app_path = win32utils.get_app_path(name)
2526
 
        if app_path != name:
2527
 
            return app_path
 
2445
    for ext in exts:
 
2446
        for d in path:
 
2447
            f = os.path.join(d, name) + ext
 
2448
            if os.access(f, os.X_OK):
 
2449
                return f
2528
2450
    return None
2529
 
 
2530
 
 
2531
 
def _posix_is_local_pid_dead(pid):
2532
 
    """True if pid doesn't correspond to live process on this machine"""
2533
 
    try:
2534
 
        # Special meaning of unix kill: just check if it's there.
2535
 
        os.kill(pid, 0)
2536
 
    except OSError, e:
2537
 
        if e.errno == errno.ESRCH:
2538
 
            # On this machine, and really not found: as sure as we can be
2539
 
            # that it's dead.
2540
 
            return True
2541
 
        elif e.errno == errno.EPERM:
2542
 
            # exists, though not ours
2543
 
            return False
2544
 
        else:
2545
 
            mutter("os.kill(%d, 0) failed: %s" % (pid, e))
2546
 
            # Don't really know.
2547
 
            return False
2548
 
    else:
2549
 
        # Exists and our process: not dead.
2550
 
        return False
2551
 
 
2552
 
if sys.platform == "win32":
2553
 
    is_local_pid_dead = win32utils.is_local_pid_dead
2554
 
else:
2555
 
    is_local_pid_dead = _posix_is_local_pid_dead
2556
 
 
2557
 
_maybe_ignored = ['EAGAIN', 'EINTR', 'ENOTSUP', 'EOPNOTSUPP', 'EACCES']
2558
 
_fdatasync_ignored = [getattr(errno, name) for name in _maybe_ignored
2559
 
                      if getattr(errno, name, None) is not None]
2560
 
 
2561
 
 
2562
 
def fdatasync(fileno):
2563
 
    """Flush file contents to disk if possible.
2564
 
    
2565
 
    :param fileno: Integer OS file handle.
2566
 
    :raises TransportNotPossible: If flushing to disk is not possible.
2567
 
    """
2568
 
    fn = getattr(os, 'fdatasync', getattr(os, 'fsync', None))
2569
 
    if fn is not None:
2570
 
        try:
2571
 
            fn(fileno)
2572
 
        except IOError, e:
2573
 
            # See bug #1075108, on some platforms fdatasync exists, but can
2574
 
            # raise ENOTSUP. However, we are calling fdatasync to be helpful
2575
 
            # and reduce the chance of corruption-on-powerloss situations. It
2576
 
            # is not a mandatory call, so it is ok to suppress failures.
2577
 
            trace.mutter("ignoring error calling fdatasync: %s" % (e,))
2578
 
            if getattr(e, 'errno', None) not in _fdatasync_ignored:
2579
 
                raise
2580
 
 
2581
 
 
2582
 
def ensure_empty_directory_exists(path, exception_class):
2583
 
    """Make sure a local directory exists and is empty.
2584
 
    
2585
 
    If it does not exist, it is created.  If it exists and is not empty, an
2586
 
    instance of exception_class is raised.
2587
 
    """
2588
 
    try:
2589
 
        os.mkdir(path)
2590
 
    except OSError, e:
2591
 
        if e.errno != errno.EEXIST:
2592
 
            raise
2593
 
        if os.listdir(path) != []:
2594
 
            raise exception_class(path)
2595
 
 
2596
 
 
2597
 
def is_environment_error(evalue):
2598
 
    """True if exception instance is due to a process environment issue
2599
 
 
2600
 
    This includes OSError and IOError, but also other errors that come from
2601
 
    the operating system or core libraries but are not subclasses of those.
2602
 
    """
2603
 
    if isinstance(evalue, (EnvironmentError, select.error)):
2604
 
        return True
2605
 
    if sys.platform == "win32" and win32utils._is_pywintypes_error(evalue):
2606
 
        return True
2607
 
    return False