24
# the opaque C library DIR type.
24
cdef extern from "python-compat.h":
25
28
cdef extern from 'errno.h':
33
char *strerror(int errno)
34
# not necessarily a real variable, but this should be close enough
30
char *strerror(int errno)
37
cdef extern from 'unistd.h':
39
char *getcwd(char *, int size)
41
cdef extern from 'stdlib.h':
32
46
cdef extern from 'sys/types.h':
33
47
ctypedef long ssize_t
34
48
ctypedef unsigned long size_t
50
ctypedef unsigned long ino_t
51
ctypedef unsigned long long off_t
54
cdef extern from 'sys/stat.h':
62
int lstat(char *path, stat *buf)
67
int S_ISFIFO(int mode)
69
int S_ISSOCK(int mode)
72
cdef extern from 'Python.h':
73
char * PyString_AS_STRING(object)
74
ctypedef int Py_ssize_t # Required for older pyrex versions
75
ctypedef struct PyObject:
77
Py_ssize_t PyString_Size(object s)
78
object PyList_GetItem(object lst, Py_ssize_t index)
79
void *PyList_GetItem_object_void "PyList_GET_ITEM" (object lst, int index)
80
int PyList_Append(object lst, object item) except -1
81
void *PyTuple_GetItem_void_void "PyTuple_GET_ITEM" (void* tpl, int index)
82
int PyTuple_SetItem(void *, Py_ssize_t pos, object item) except -1
83
int PyTuple_SetItem_obj "PyTuple_SetItem" (void *, Py_ssize_t pos, PyObject * item) except -1
84
void Py_INCREF(object o)
85
void Py_DECREF(object o)
86
void PyString_Concat(PyObject **string, object newpart)
36
89
cdef extern from 'dirent.h':
44
90
ctypedef struct dirent:
46
# this will fail to compile if d_type is not defined.
47
# if this module fails to compile, use the .py version.
93
# the opaque C library DIR type.
50
94
ctypedef struct DIR
51
95
# should be DIR *, pyrex barfs.
52
96
DIR * opendir(char * name)
61
105
_symlink = 'symlink'
62
106
_socket = 'socket'
63
107
_unknown = 'unknown'
67
110
# add a typedef struct dirent dirent to workaround pyrex
68
111
cdef extern from 'readdir.h':
116
"""Represent a 'stat' result."""
122
return self._st.st_dev
126
return self._st.st_ino
130
return self._st.st_mode
134
return self._st.st_ctime
138
return self._st.st_mtime
142
return self._st.st_size
145
"""Repr is the same as a Stat object.
147
(mode, ino, dev, nlink, uid, gid, size, None(atime), mtime, ctime)
149
return repr((self.st_mode, 0, 0, 0, 0, 0, self.st_size, None,
150
self._mtime, self._ctime))
153
from bzrlib import osutils
156
cdef class UTF8DirReader:
157
"""A dir reader for utf8 file systems."""
159
cdef readonly object _safe_utf8
160
cdef _directory, _chardev, _block, _file, _fifo, _symlink
161
cdef _socket, _unknown
164
self._safe_utf8 = osutils.safe_utf8
165
self._directory = _directory
166
self._chardev = _chardev
170
self._symlink = _symlink
171
self._socket = _socket
172
self._unknown = _unknown
174
def kind_from_mode(self, int mode):
175
"""Get the kind of a path from a mode status."""
176
return self._kind_from_mode(mode)
178
cdef _kind_from_mode(self, int mode):
179
# Files and directories are the most common - check them first.
183
return self._directory
196
def top_prefix_to_starting_dir(self, top, prefix=""):
197
"""See DirReader.top_prefix_to_starting_dir."""
198
return (self._safe_utf8(prefix), None, None, None,
199
self._safe_utf8(top))
201
def read_dir(self, prefix, top):
202
"""Read a single directory from a utf8 file system.
204
All paths in and out are utf8.
206
This sub-function is called when we know the filesystem is already in utf8
207
encoding. So we don't need to transcode filenames.
209
See DirReader.read_dir for details.
211
#cdef char *_prefix = prefix
212
#cdef char *_top = top
213
# Use C accelerated directory listing.
219
cdef PyObject * new_val_obj
221
if PyString_Size(prefix):
222
relprefix = prefix + '/'
225
top_slash = top + '/'
227
# read_dir supplies in should-stat order.
228
# for _, name in sorted(_listdir(top)):
229
result = _read_dir(top)
232
for index from 0 <= index < length:
233
atuple = PyList_GetItem_object_void(result, index)
234
name = <object>PyTuple_GetItem_void_void(atuple, 1)
235
# We have a tuple with (inode, name, None, statvalue, None)
237
# inode -> path_from_top
238
# direct concat - faster than operator +.
239
new_val_obj = <PyObject *>relprefix
241
PyString_Concat(&new_val_obj, name)
242
if NULL == new_val_obj:
243
# PyString_Concat will have setup an exception, but how to get
245
raise Exception("failed to strcat")
246
PyTuple_SetItem_obj(atuple, 0, new_val_obj)
248
newval = self._kind_from_mode(
249
(<_Stat>PyTuple_GetItem_void_void(atuple, 3)).st_mode)
251
PyTuple_SetItem(atuple, 2, newval)
252
# 2nd None -> abspath # for all - the caller may need to stat files
254
# direct concat - faster than operator +.
255
new_val_obj = <PyObject *>top_slash
257
PyString_Concat(&new_val_obj, name)
258
if NULL == new_val_obj:
259
# PyString_Concat will have setup an exception, but how to get
261
raise Exception("failed to strcat")
262
PyTuple_SetItem_obj(atuple, 4, new_val_obj)
266
cdef _read_dir(path):
72
267
"""Like os.listdir, this reads the contents of a directory.
74
269
:param path: the directory to list.
75
:return: a list of (sort_key, basename) tuples.
270
:return: a list of single-owner (the list) tuples ready for editing into
271
the result tuples walkdirs needs to yield. They contain (inode, name,
272
None, statvalue, None).
78
275
# currently this needs a fixup - the C code says 'dirent' but should say
80
277
cdef dirent * entry
81
278
cdef dirent sentinel
83
the_dir = opendir(path)
285
cwd = getcwd(NULL, 0)
286
if -1 == chdir(path):
287
raise OSError(errno, strerror(errno))
288
the_dir = opendir(".")
84
289
if NULL == the_dir:
85
290
raise OSError(errno, strerror(errno))
89
294
while entry != NULL:
90
entry = readdir(the_dir)
295
# Unlike most libc functions, readdir needs errno set to 0
296
# beforehand so that eof can be distinguished from errors. See
297
# <https://bugs.launchpad.net/bzr/+bug/279381>
300
entry = readdir(the_dir)
301
if entry == NULL and (errno == EAGAIN or errno == EINTR):
95
elif errno != ENOTDIR and errno != ENOENT and errno != 0:
307
if errno == ENOTDIR or errno == 0:
96
308
# We see ENOTDIR at the end of a normal directory.
97
309
# As ENOTDIR for read_dir(file) is triggered on opendir,
98
310
# we consider ENOTDIR to be 'no error'.
99
# ENOENT is listed as 'invalid position in the dir stream' for
100
# readdir. We swallow this for now and just keep reading.
101
313
raise OSError(errno, strerror(errno))
105
314
name = entry.d_name
106
if not (name[0] == dot and (
315
if not (name[0] == c"." and (
107
316
(name[1] == 0) or
108
(name[1] == dot and name[2] == 0))
317
(name[1] == c"." and name[2] == 0))
110
result.append((entry.d_ino, entry.d_name))
320
stat_result = lstat(entry.d_name, &statvalue._st)
323
raise OSError(errno, strerror(errno))
327
# We append a 5-tuple that can be modified in-place by the C
329
# inode to sort on (to replace with top_path)
331
# kind (None, to set)
332
# statvalue (to keep)
333
# abspath (None, to set)
334
PyList_Append(result, (entry.d_ino, entry.d_name, None,
339
raise OSError(errno, strerror(errno))
112
341
if -1 == closedir(the_dir):
113
342
raise OSError(errno, strerror(errno))
added
removed
bzrlib/_readdir_pyx.pyx
