blob: 9f9044860fb918e92cc6900708c54cfba934c256 [file] [log] [blame]
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001/* Author: Daniel Stutzbach */
2
3#define PY_SSIZE_T_CLEAN
4#include "Python.h"
Andrew M. Kuchling4b81bc72010-02-22 23:12:00 +00005#ifdef HAVE_SYS_TYPES_H
Christian Heimes7f39c9f2008-01-25 12:18:43 +00006#include <sys/types.h>
Andrew M. Kuchling4b81bc72010-02-22 23:12:00 +00007#endif
8#ifdef HAVE_SYS_STAT_H
Christian Heimes7f39c9f2008-01-25 12:18:43 +00009#include <sys/stat.h>
Andrew M. Kuchling4b81bc72010-02-22 23:12:00 +000010#endif
11#ifdef HAVE_FCNTL_H
Christian Heimes7f39c9f2008-01-25 12:18:43 +000012#include <fcntl.h>
Andrew M. Kuchling4b81bc72010-02-22 23:12:00 +000013#endif
Christian Heimes7f39c9f2008-01-25 12:18:43 +000014#include <stddef.h> /* For offsetof */
Antoine Pitrou19690592009-06-12 20:14:08 +000015#include "_iomodule.h"
Christian Heimes7f39c9f2008-01-25 12:18:43 +000016
17/*
18 * Known likely problems:
19 *
20 * - Files larger then 2**32-1
21 * - Files with unicode filenames
22 * - Passing numbers greater than 2**32-1 when an integer is expected
23 * - Making it work on Windows and other oddball platforms
24 *
25 * To Do:
26 *
27 * - autoconfify header file inclusion
28 */
29
30#ifdef MS_WINDOWS
31/* can simulate truncate with Win32 API functions; see file_truncate */
32#define HAVE_FTRUNCATE
33#define WIN32_LEAN_AND_MEAN
34#include <windows.h>
35#endif
36
Antoine Pitrou19690592009-06-12 20:14:08 +000037#if BUFSIZ < (8*1024)
38#define SMALLCHUNK (8*1024)
39#elif (BUFSIZ >= (2 << 25))
40#error "unreasonable BUFSIZ > 64MB defined"
41#else
42#define SMALLCHUNK BUFSIZ
43#endif
44
45#if SIZEOF_INT < 4
46#define BIGCHUNK (512 * 32)
47#else
48#define BIGCHUNK (512 * 1024)
49#endif
50
Christian Heimes7f39c9f2008-01-25 12:18:43 +000051typedef struct {
Antoine Pitroub26dc462010-05-05 16:27:30 +000052 PyObject_HEAD
53 int fd;
54 unsigned int readable : 1;
55 unsigned int writable : 1;
56 signed int seekable : 2; /* -1 means unknown */
57 unsigned int closefd : 1;
58 PyObject *weakreflist;
59 PyObject *dict;
Antoine Pitrou19690592009-06-12 20:14:08 +000060} fileio;
Christian Heimes7f39c9f2008-01-25 12:18:43 +000061
62PyTypeObject PyFileIO_Type;
63
64#define PyFileIO_Check(op) (PyObject_TypeCheck((op), &PyFileIO_Type))
65
Antoine Pitrou19690592009-06-12 20:14:08 +000066int
67_PyFileIO_closed(PyObject *self)
68{
Antoine Pitroub26dc462010-05-05 16:27:30 +000069 return ((fileio *)self)->fd < 0;
Antoine Pitrou19690592009-06-12 20:14:08 +000070}
71
Antoine Pitroue741cc62009-01-21 00:45:36 +000072static PyObject *
73portable_lseek(int fd, PyObject *posobj, int whence);
74
Antoine Pitrou19690592009-06-12 20:14:08 +000075static PyObject *portable_lseek(int fd, PyObject *posobj, int whence);
76
77/* Returns 0 on success, -1 with exception set on failure. */
Christian Heimes7f39c9f2008-01-25 12:18:43 +000078static int
Antoine Pitrou19690592009-06-12 20:14:08 +000079internal_close(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +000080{
Antoine Pitroub26dc462010-05-05 16:27:30 +000081 int err = 0;
82 int save_errno = 0;
83 if (self->fd >= 0) {
84 int fd = self->fd;
85 self->fd = -1;
86 /* fd is accessible and someone else may have closed it */
87 if (_PyVerify_fd(fd)) {
88 Py_BEGIN_ALLOW_THREADS
89 err = close(fd);
90 if (err < 0)
91 save_errno = errno;
92 Py_END_ALLOW_THREADS
93 } else {
94 save_errno = errno;
95 err = -1;
96 }
97 }
98 if (err < 0) {
99 errno = save_errno;
100 PyErr_SetFromErrno(PyExc_IOError);
101 return -1;
102 }
103 return 0;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000104}
105
106static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000107fileio_close(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000108{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000109 if (!self->closefd) {
110 self->fd = -1;
111 Py_RETURN_NONE;
112 }
113 errno = internal_close(self);
114 if (errno < 0)
115 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000116
Antoine Pitroub26dc462010-05-05 16:27:30 +0000117 return PyObject_CallMethod((PyObject*)&PyRawIOBase_Type,
118 "close", "O", self);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000119}
120
121static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000122fileio_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000123{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000124 fileio *self;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000125
Antoine Pitroub26dc462010-05-05 16:27:30 +0000126 assert(type != NULL && type->tp_alloc != NULL);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000127
Antoine Pitroub26dc462010-05-05 16:27:30 +0000128 self = (fileio *) type->tp_alloc(type, 0);
129 if (self != NULL) {
130 self->fd = -1;
131 self->readable = 0;
132 self->writable = 0;
133 self->seekable = -1;
134 self->closefd = 1;
135 self->weakreflist = NULL;
136 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000137
Antoine Pitroub26dc462010-05-05 16:27:30 +0000138 return (PyObject *) self;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000139}
140
141/* On Unix, open will succeed for directories.
142 In Python, there should be no file objects referring to
143 directories, so we need a check. */
144
145static int
Antoine Pitrou19690592009-06-12 20:14:08 +0000146dircheck(fileio* self, const char *name)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000147{
148#if defined(HAVE_FSTAT) && defined(S_IFDIR) && defined(EISDIR)
Antoine Pitroub26dc462010-05-05 16:27:30 +0000149 struct stat buf;
150 if (self->fd < 0)
151 return 0;
152 if (fstat(self->fd, &buf) == 0 && S_ISDIR(buf.st_mode)) {
153 char *msg = strerror(EISDIR);
154 PyObject *exc;
155 if (internal_close(self))
156 return -1;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000157
Antoine Pitroub26dc462010-05-05 16:27:30 +0000158 exc = PyObject_CallFunction(PyExc_IOError, "(iss)",
159 EISDIR, msg, name);
160 PyErr_SetObject(PyExc_IOError, exc);
161 Py_XDECREF(exc);
162 return -1;
163 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000164#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000165 return 0;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000166}
167
Benjamin Peterson5848d1f2009-01-19 00:08:08 +0000168static int
169check_fd(int fd)
170{
171#if defined(HAVE_FSTAT)
Antoine Pitroub26dc462010-05-05 16:27:30 +0000172 struct stat buf;
173 if (!_PyVerify_fd(fd) || (fstat(fd, &buf) < 0 && errno == EBADF)) {
174 PyObject *exc;
175 char *msg = strerror(EBADF);
176 exc = PyObject_CallFunction(PyExc_OSError, "(is)",
177 EBADF, msg);
178 PyErr_SetObject(PyExc_OSError, exc);
179 Py_XDECREF(exc);
180 return -1;
181 }
Benjamin Peterson5848d1f2009-01-19 00:08:08 +0000182#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000183 return 0;
Benjamin Peterson5848d1f2009-01-19 00:08:08 +0000184}
185
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000186
187static int
188fileio_init(PyObject *oself, PyObject *args, PyObject *kwds)
189{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000190 fileio *self = (fileio *) oself;
191 static char *kwlist[] = {"file", "mode", "closefd", NULL};
192 const char *name = NULL;
193 PyObject *nameobj, *stringobj = NULL;
194 char *mode = "r";
195 char *s;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000196#ifdef MS_WINDOWS
Antoine Pitroub26dc462010-05-05 16:27:30 +0000197 Py_UNICODE *widename = NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000198#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000199 int ret = 0;
200 int rwa = 0, plus = 0, append = 0;
201 int flags = 0;
202 int fd = -1;
203 int closefd = 1;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000204
Antoine Pitroub26dc462010-05-05 16:27:30 +0000205 assert(PyFileIO_Check(oself));
206 if (self->fd >= 0) {
207 /* Have to close the existing file first. */
208 if (internal_close(self) < 0)
209 return -1;
210 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000211
Antoine Pitroub26dc462010-05-05 16:27:30 +0000212 if (!PyArg_ParseTupleAndKeywords(args, kwds, "O|si:fileio",
213 kwlist, &nameobj, &mode, &closefd))
214 return -1;
Antoine Pitrou19690592009-06-12 20:14:08 +0000215
Antoine Pitroub26dc462010-05-05 16:27:30 +0000216 if (PyFloat_Check(nameobj)) {
217 PyErr_SetString(PyExc_TypeError,
218 "integer argument expected, got float");
219 return -1;
220 }
Antoine Pitrou19690592009-06-12 20:14:08 +0000221
Antoine Pitroub26dc462010-05-05 16:27:30 +0000222 fd = PyLong_AsLong(nameobj);
223 if (fd < 0) {
224 if (!PyErr_Occurred()) {
225 PyErr_SetString(PyExc_ValueError,
226 "Negative filedescriptor");
227 return -1;
228 }
229 PyErr_Clear();
230 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000231
Hirokazu Yamamotob24bb272009-05-17 02:52:09 +0000232#ifdef MS_WINDOWS
Antoine Pitroub26dc462010-05-05 16:27:30 +0000233 if (PyUnicode_Check(nameobj))
234 widename = PyUnicode_AS_UNICODE(nameobj);
235 if (widename == NULL)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000236#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000237 if (fd < 0)
238 {
239 if (PyBytes_Check(nameobj) || PyByteArray_Check(nameobj)) {
240 Py_ssize_t namelen;
241 if (PyObject_AsCharBuffer(nameobj, &name, &namelen) < 0)
242 return -1;
243 }
244 else {
245 PyObject *u = PyUnicode_FromObject(nameobj);
Antoine Pitrou19690592009-06-12 20:14:08 +0000246
Antoine Pitroub26dc462010-05-05 16:27:30 +0000247 if (u == NULL)
248 return -1;
Antoine Pitrou19690592009-06-12 20:14:08 +0000249
Antoine Pitroub26dc462010-05-05 16:27:30 +0000250 stringobj = PyUnicode_AsEncodedString(
251 u, Py_FileSystemDefaultEncoding, NULL);
252 Py_DECREF(u);
253 if (stringobj == NULL)
254 return -1;
255 if (!PyBytes_Check(stringobj)) {
256 PyErr_SetString(PyExc_TypeError,
257 "encoder failed to return bytes");
258 goto error;
259 }
260 name = PyBytes_AS_STRING(stringobj);
261 }
262 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000263
Antoine Pitroub26dc462010-05-05 16:27:30 +0000264 s = mode;
265 while (*s) {
266 switch (*s++) {
267 case 'r':
268 if (rwa) {
269 bad_mode:
270 PyErr_SetString(PyExc_ValueError,
Georg Brandl10603802010-11-26 08:10:41 +0000271 "Must have exactly one of read/write/append "
272 "mode and at most one plus");
Antoine Pitroub26dc462010-05-05 16:27:30 +0000273 goto error;
274 }
275 rwa = 1;
276 self->readable = 1;
277 break;
278 case 'w':
279 if (rwa)
280 goto bad_mode;
281 rwa = 1;
282 self->writable = 1;
283 flags |= O_CREAT | O_TRUNC;
284 break;
285 case 'a':
286 if (rwa)
287 goto bad_mode;
288 rwa = 1;
289 self->writable = 1;
290 flags |= O_CREAT;
291 append = 1;
292 break;
293 case 'b':
294 break;
295 case '+':
296 if (plus)
297 goto bad_mode;
298 self->readable = self->writable = 1;
299 plus = 1;
300 break;
301 default:
302 PyErr_Format(PyExc_ValueError,
303 "invalid mode: %.200s", mode);
304 goto error;
305 }
306 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000307
Antoine Pitroub26dc462010-05-05 16:27:30 +0000308 if (!rwa)
309 goto bad_mode;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000310
Antoine Pitroub26dc462010-05-05 16:27:30 +0000311 if (self->readable && self->writable)
312 flags |= O_RDWR;
313 else if (self->readable)
314 flags |= O_RDONLY;
315 else
316 flags |= O_WRONLY;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000317
318#ifdef O_BINARY
Antoine Pitroub26dc462010-05-05 16:27:30 +0000319 flags |= O_BINARY;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000320#endif
321
322#ifdef O_APPEND
Antoine Pitroub26dc462010-05-05 16:27:30 +0000323 if (append)
324 flags |= O_APPEND;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000325#endif
326
Antoine Pitroub26dc462010-05-05 16:27:30 +0000327 if (fd >= 0) {
328 if (check_fd(fd))
329 goto error;
330 self->fd = fd;
331 self->closefd = closefd;
332 }
333 else {
334 self->closefd = 1;
335 if (!closefd) {
336 PyErr_SetString(PyExc_ValueError,
337 "Cannot use closefd=False with file name");
338 goto error;
339 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000340
Antoine Pitroub26dc462010-05-05 16:27:30 +0000341 Py_BEGIN_ALLOW_THREADS
342 errno = 0;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000343#ifdef MS_WINDOWS
Antoine Pitroub26dc462010-05-05 16:27:30 +0000344 if (widename != NULL)
345 self->fd = _wopen(widename, flags, 0666);
346 else
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000347#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000348 self->fd = open(name, flags, 0666);
349 Py_END_ALLOW_THREADS
350 if (self->fd < 0) {
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000351#ifdef MS_WINDOWS
Antoine Pitroub26dc462010-05-05 16:27:30 +0000352 if (widename != NULL)
353 PyErr_SetFromErrnoWithUnicodeFilename(PyExc_IOError, widename);
354 else
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000355#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000356 PyErr_SetFromErrnoWithFilename(PyExc_IOError, name);
357 goto error;
358 }
359 if(dircheck(self, name) < 0)
360 goto error;
361 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000362
Antoine Pitroub26dc462010-05-05 16:27:30 +0000363 if (PyObject_SetAttrString((PyObject *)self, "name", nameobj) < 0)
364 goto error;
Antoine Pitrou19690592009-06-12 20:14:08 +0000365
Antoine Pitroub26dc462010-05-05 16:27:30 +0000366 if (append) {
367 /* For consistent behaviour, we explicitly seek to the
368 end of file (otherwise, it might be done only on the
369 first write()). */
370 PyObject *pos = portable_lseek(self->fd, NULL, 2);
Antoine Pitrou594a0462010-10-31 13:05:48 +0000371 if (pos == NULL) {
372 if (closefd) {
373 close(self->fd);
374 self->fd = -1;
375 }
Antoine Pitroub26dc462010-05-05 16:27:30 +0000376 goto error;
Antoine Pitrou594a0462010-10-31 13:05:48 +0000377 }
Antoine Pitroub26dc462010-05-05 16:27:30 +0000378 Py_DECREF(pos);
379 }
Antoine Pitroue741cc62009-01-21 00:45:36 +0000380
Antoine Pitroub26dc462010-05-05 16:27:30 +0000381 goto done;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000382
383 error:
Antoine Pitroub26dc462010-05-05 16:27:30 +0000384 ret = -1;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000385
386 done:
Antoine Pitroub26dc462010-05-05 16:27:30 +0000387 Py_CLEAR(stringobj);
388 return ret;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000389}
390
Antoine Pitrou19690592009-06-12 20:14:08 +0000391static int
392fileio_traverse(fileio *self, visitproc visit, void *arg)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000393{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000394 Py_VISIT(self->dict);
395 return 0;
Antoine Pitrou19690592009-06-12 20:14:08 +0000396}
397
398static int
399fileio_clear(fileio *self)
400{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000401 Py_CLEAR(self->dict);
402 return 0;
Antoine Pitrou19690592009-06-12 20:14:08 +0000403}
404
405static void
406fileio_dealloc(fileio *self)
407{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000408 if (_PyIOBase_finalize((PyObject *) self) < 0)
409 return;
410 _PyObject_GC_UNTRACK(self);
411 if (self->weakreflist != NULL)
412 PyObject_ClearWeakRefs((PyObject *) self);
413 Py_CLEAR(self->dict);
414 Py_TYPE(self)->tp_free((PyObject *)self);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000415}
416
417static PyObject *
418err_closed(void)
419{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000420 PyErr_SetString(PyExc_ValueError, "I/O operation on closed file");
421 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000422}
423
424static PyObject *
425err_mode(char *action)
426{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000427 PyErr_Format(PyExc_ValueError, "File not open for %s", action);
428 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000429}
430
431static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000432fileio_fileno(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000433{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000434 if (self->fd < 0)
435 return err_closed();
436 return PyInt_FromLong((long) self->fd);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000437}
438
439static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000440fileio_readable(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000441{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000442 if (self->fd < 0)
443 return err_closed();
444 return PyBool_FromLong((long) self->readable);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000445}
446
447static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000448fileio_writable(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000449{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000450 if (self->fd < 0)
451 return err_closed();
452 return PyBool_FromLong((long) self->writable);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000453}
454
455static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000456fileio_seekable(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000457{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000458 if (self->fd < 0)
459 return err_closed();
460 if (self->seekable < 0) {
461 PyObject *pos = portable_lseek(self->fd, NULL, SEEK_CUR);
462 if (pos == NULL) {
463 PyErr_Clear();
464 self->seekable = 0;
465 } else {
466 Py_DECREF(pos);
467 self->seekable = 1;
468 }
469 }
470 return PyBool_FromLong((long) self->seekable);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000471}
472
473static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000474fileio_readinto(fileio *self, PyObject *args)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000475{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000476 Py_buffer pbuf;
Victor Stinner59729ff2011-07-05 11:28:19 +0200477 Py_ssize_t n, len;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000478
Antoine Pitroub26dc462010-05-05 16:27:30 +0000479 if (self->fd < 0)
480 return err_closed();
481 if (!self->readable)
482 return err_mode("reading");
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000483
Antoine Pitroub26dc462010-05-05 16:27:30 +0000484 if (!PyArg_ParseTuple(args, "w*", &pbuf))
485 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000486
Antoine Pitroub26dc462010-05-05 16:27:30 +0000487 if (_PyVerify_fd(self->fd)) {
Victor Stinner59729ff2011-07-05 11:28:19 +0200488 len = pbuf.len;
Antoine Pitroub26dc462010-05-05 16:27:30 +0000489 Py_BEGIN_ALLOW_THREADS
490 errno = 0;
Victor Stinner59729ff2011-07-05 11:28:19 +0200491#if defined(MS_WIN64) || defined(MS_WINDOWS)
492 if (len > INT_MAX)
493 len = INT_MAX;
494 n = read(self->fd, pbuf.buf, (int)len);
495#else
496 n = read(self->fd, pbuf.buf, len);
497#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000498 Py_END_ALLOW_THREADS
499 } else
500 n = -1;
501 PyBuffer_Release(&pbuf);
502 if (n < 0) {
503 if (errno == EAGAIN)
504 Py_RETURN_NONE;
505 PyErr_SetFromErrno(PyExc_IOError);
506 return NULL;
507 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000508
Antoine Pitroub26dc462010-05-05 16:27:30 +0000509 return PyLong_FromSsize_t(n);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000510}
511
Antoine Pitrou19690592009-06-12 20:14:08 +0000512static size_t
513new_buffersize(fileio *self, size_t currentsize)
514{
515#ifdef HAVE_FSTAT
Antoine Pitroub26dc462010-05-05 16:27:30 +0000516 off_t pos, end;
517 struct stat st;
518 if (fstat(self->fd, &st) == 0) {
519 end = st.st_size;
520 pos = lseek(self->fd, 0L, SEEK_CUR);
521 /* Files claiming a size smaller than SMALLCHUNK may
522 actually be streaming pseudo-files. In this case, we
523 apply the more aggressive algorithm below.
524 */
525 if (end >= SMALLCHUNK && end >= pos && pos >= 0) {
526 /* Add 1 so if the file were to grow we'd notice. */
527 return currentsize + end - pos + 1;
528 }
529 }
Antoine Pitrou19690592009-06-12 20:14:08 +0000530#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000531 if (currentsize > SMALLCHUNK) {
532 /* Keep doubling until we reach BIGCHUNK;
533 then keep adding BIGCHUNK. */
534 if (currentsize <= BIGCHUNK)
535 return currentsize + currentsize;
536 else
537 return currentsize + BIGCHUNK;
538 }
539 return currentsize + SMALLCHUNK;
Antoine Pitrou19690592009-06-12 20:14:08 +0000540}
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000541
542static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000543fileio_readall(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000544{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000545 PyObject *result;
546 Py_ssize_t total = 0;
547 int n;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000548
Victor Stinner5100a402011-05-25 22:15:36 +0200549 if (self->fd < 0)
550 return err_closed();
Antoine Pitroub26dc462010-05-05 16:27:30 +0000551 if (!_PyVerify_fd(self->fd))
552 return PyErr_SetFromErrno(PyExc_IOError);
Antoine Pitrou19690592009-06-12 20:14:08 +0000553
Antoine Pitroub26dc462010-05-05 16:27:30 +0000554 result = PyBytes_FromStringAndSize(NULL, SMALLCHUNK);
555 if (result == NULL)
556 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000557
Antoine Pitroub26dc462010-05-05 16:27:30 +0000558 while (1) {
559 size_t newsize = new_buffersize(self, total);
560 if (newsize > PY_SSIZE_T_MAX || newsize <= 0) {
561 PyErr_SetString(PyExc_OverflowError,
562 "unbounded read returned more bytes "
563 "than a Python string can hold ");
564 Py_DECREF(result);
565 return NULL;
566 }
Antoine Pitrou19690592009-06-12 20:14:08 +0000567
Antoine Pitroub26dc462010-05-05 16:27:30 +0000568 if (PyBytes_GET_SIZE(result) < (Py_ssize_t)newsize) {
569 if (_PyBytes_Resize(&result, newsize) < 0) {
570 if (total == 0) {
571 Py_DECREF(result);
572 return NULL;
573 }
574 PyErr_Clear();
575 break;
576 }
577 }
578 Py_BEGIN_ALLOW_THREADS
579 errno = 0;
580 n = read(self->fd,
581 PyBytes_AS_STRING(result) + total,
582 newsize - total);
583 Py_END_ALLOW_THREADS
584 if (n == 0)
585 break;
586 if (n < 0) {
587 if (total > 0)
588 break;
589 if (errno == EAGAIN) {
590 Py_DECREF(result);
591 Py_RETURN_NONE;
592 }
593 Py_DECREF(result);
594 PyErr_SetFromErrno(PyExc_IOError);
595 return NULL;
596 }
597 total += n;
598 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000599
Antoine Pitroub26dc462010-05-05 16:27:30 +0000600 if (PyBytes_GET_SIZE(result) > total) {
601 if (_PyBytes_Resize(&result, total) < 0) {
602 /* This should never happen, but just in case */
603 Py_DECREF(result);
604 return NULL;
605 }
606 }
607 return result;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000608}
609
610static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000611fileio_read(fileio *self, PyObject *args)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000612{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000613 char *ptr;
614 Py_ssize_t n;
615 Py_ssize_t size = -1;
616 PyObject *bytes;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000617
Antoine Pitroub26dc462010-05-05 16:27:30 +0000618 if (self->fd < 0)
619 return err_closed();
620 if (!self->readable)
621 return err_mode("reading");
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000622
Antoine Pitroub26dc462010-05-05 16:27:30 +0000623 if (!PyArg_ParseTuple(args, "|O&", &_PyIO_ConvertSsize_t, &size))
624 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000625
Antoine Pitroub26dc462010-05-05 16:27:30 +0000626 if (size < 0) {
627 return fileio_readall(self);
628 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000629
Victor Stinner59729ff2011-07-05 11:28:19 +0200630#if defined(MS_WIN64) || defined(MS_WINDOWS)
631 if (size > INT_MAX)
632 size = INT_MAX;
633#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000634 bytes = PyBytes_FromStringAndSize(NULL, size);
635 if (bytes == NULL)
636 return NULL;
637 ptr = PyBytes_AS_STRING(bytes);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000638
Antoine Pitroub26dc462010-05-05 16:27:30 +0000639 if (_PyVerify_fd(self->fd)) {
640 Py_BEGIN_ALLOW_THREADS
641 errno = 0;
Victor Stinner59729ff2011-07-05 11:28:19 +0200642#if defined(MS_WIN64) || defined(MS_WINDOWS)
643 n = read(self->fd, ptr, (int)size);
644#else
Antoine Pitroub26dc462010-05-05 16:27:30 +0000645 n = read(self->fd, ptr, size);
Victor Stinner59729ff2011-07-05 11:28:19 +0200646#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000647 Py_END_ALLOW_THREADS
648 } else
649 n = -1;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000650
Antoine Pitroub26dc462010-05-05 16:27:30 +0000651 if (n < 0) {
652 Py_DECREF(bytes);
653 if (errno == EAGAIN)
654 Py_RETURN_NONE;
655 PyErr_SetFromErrno(PyExc_IOError);
656 return NULL;
657 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000658
Antoine Pitroub26dc462010-05-05 16:27:30 +0000659 if (n != size) {
660 if (_PyBytes_Resize(&bytes, n) < 0) {
661 Py_DECREF(bytes);
662 return NULL;
663 }
664 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000665
Antoine Pitroub26dc462010-05-05 16:27:30 +0000666 return (PyObject *) bytes;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000667}
668
669static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000670fileio_write(fileio *self, PyObject *args)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000671{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000672 Py_buffer pbuf;
Victor Stinner59729ff2011-07-05 11:28:19 +0200673 Py_ssize_t n, len;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000674
Antoine Pitroub26dc462010-05-05 16:27:30 +0000675 if (self->fd < 0)
676 return err_closed();
677 if (!self->writable)
678 return err_mode("writing");
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000679
Antoine Pitroub26dc462010-05-05 16:27:30 +0000680 if (!PyArg_ParseTuple(args, "s*", &pbuf))
681 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000682
Antoine Pitroub26dc462010-05-05 16:27:30 +0000683 if (_PyVerify_fd(self->fd)) {
684 Py_BEGIN_ALLOW_THREADS
685 errno = 0;
Victor Stinner59729ff2011-07-05 11:28:19 +0200686 len = pbuf.len;
687#if defined(MS_WIN64) || defined(MS_WINDOWS)
688 if (len > INT_MAX)
689 len = INT_MAX;
690 n = write(self->fd, pbuf.buf, (int)len);
691#else
692 n = write(self->fd, pbuf.buf, len);
693#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000694 Py_END_ALLOW_THREADS
695 } else
696 n = -1;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000697
Antoine Pitroub26dc462010-05-05 16:27:30 +0000698 PyBuffer_Release(&pbuf);
Martin v. Löwisf91d46a2008-08-12 14:49:50 +0000699
Antoine Pitroub26dc462010-05-05 16:27:30 +0000700 if (n < 0) {
701 if (errno == EAGAIN)
702 Py_RETURN_NONE;
703 PyErr_SetFromErrno(PyExc_IOError);
704 return NULL;
705 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000706
Antoine Pitroub26dc462010-05-05 16:27:30 +0000707 return PyLong_FromSsize_t(n);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000708}
709
710/* XXX Windows support below is likely incomplete */
711
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000712/* Cribbed from posix_lseek() */
713static PyObject *
714portable_lseek(int fd, PyObject *posobj, int whence)
715{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000716 Py_off_t pos, res;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000717
718#ifdef SEEK_SET
Antoine Pitroub26dc462010-05-05 16:27:30 +0000719 /* Turn 0, 1, 2 into SEEK_{SET,CUR,END} */
720 switch (whence) {
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000721#if SEEK_SET != 0
Antoine Pitroub26dc462010-05-05 16:27:30 +0000722 case 0: whence = SEEK_SET; break;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000723#endif
724#if SEEK_CUR != 1
Antoine Pitroub26dc462010-05-05 16:27:30 +0000725 case 1: whence = SEEK_CUR; break;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000726#endif
Benjamin Peterson8024cec2009-01-20 14:31:08 +0000727#if SEEK_END != 2
Antoine Pitroub26dc462010-05-05 16:27:30 +0000728 case 2: whence = SEEK_END; break;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000729#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000730 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000731#endif /* SEEK_SET */
732
Antoine Pitroub26dc462010-05-05 16:27:30 +0000733 if (posobj == NULL)
734 pos = 0;
735 else {
736 if(PyFloat_Check(posobj)) {
737 PyErr_SetString(PyExc_TypeError, "an integer is required");
738 return NULL;
739 }
Alexandre Vassalotti1aed6242008-05-09 21:49:43 +0000740#if defined(HAVE_LARGEFILE_SUPPORT)
Antoine Pitroub26dc462010-05-05 16:27:30 +0000741 pos = PyLong_AsLongLong(posobj);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000742#else
Antoine Pitroub26dc462010-05-05 16:27:30 +0000743 pos = PyLong_AsLong(posobj);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000744#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000745 if (PyErr_Occurred())
746 return NULL;
747 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000748
Antoine Pitroub26dc462010-05-05 16:27:30 +0000749 if (_PyVerify_fd(fd)) {
750 Py_BEGIN_ALLOW_THREADS
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000751#if defined(MS_WIN64) || defined(MS_WINDOWS)
Antoine Pitroub26dc462010-05-05 16:27:30 +0000752 res = _lseeki64(fd, pos, whence);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000753#else
Antoine Pitroub26dc462010-05-05 16:27:30 +0000754 res = lseek(fd, pos, whence);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000755#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000756 Py_END_ALLOW_THREADS
757 } else
758 res = -1;
759 if (res < 0)
760 return PyErr_SetFromErrno(PyExc_IOError);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000761
Alexandre Vassalotti1aed6242008-05-09 21:49:43 +0000762#if defined(HAVE_LARGEFILE_SUPPORT)
Antoine Pitroub26dc462010-05-05 16:27:30 +0000763 return PyLong_FromLongLong(res);
Alexandre Vassalotti1aed6242008-05-09 21:49:43 +0000764#else
Antoine Pitroub26dc462010-05-05 16:27:30 +0000765 return PyLong_FromLong(res);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000766#endif
767}
768
769static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000770fileio_seek(fileio *self, PyObject *args)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000771{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000772 PyObject *posobj;
773 int whence = 0;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000774
Antoine Pitroub26dc462010-05-05 16:27:30 +0000775 if (self->fd < 0)
776 return err_closed();
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000777
Antoine Pitroub26dc462010-05-05 16:27:30 +0000778 if (!PyArg_ParseTuple(args, "O|i", &posobj, &whence))
779 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000780
Antoine Pitroub26dc462010-05-05 16:27:30 +0000781 return portable_lseek(self->fd, posobj, whence);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000782}
783
784static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000785fileio_tell(fileio *self, PyObject *args)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000786{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000787 if (self->fd < 0)
788 return err_closed();
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000789
Antoine Pitroub26dc462010-05-05 16:27:30 +0000790 return portable_lseek(self->fd, NULL, 1);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000791}
792
793#ifdef HAVE_FTRUNCATE
794static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000795fileio_truncate(fileio *self, PyObject *args)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000796{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000797 PyObject *posobj = NULL; /* the new size wanted by the user */
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000798#ifndef MS_WINDOWS
Antoine Pitroub26dc462010-05-05 16:27:30 +0000799 Py_off_t pos;
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000800#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000801 int ret;
802 int fd;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000803
Antoine Pitroub26dc462010-05-05 16:27:30 +0000804 fd = self->fd;
805 if (fd < 0)
806 return err_closed();
807 if (!self->writable)
808 return err_mode("writing");
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000809
Antoine Pitroub26dc462010-05-05 16:27:30 +0000810 if (!PyArg_ParseTuple(args, "|O", &posobj))
811 return NULL;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000812
Antoine Pitroub26dc462010-05-05 16:27:30 +0000813 if (posobj == Py_None || posobj == NULL) {
814 /* Get the current position. */
815 posobj = portable_lseek(fd, NULL, 1);
816 if (posobj == NULL)
817 return NULL;
818 }
819 else {
820 Py_INCREF(posobj);
821 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000822
823#ifdef MS_WINDOWS
Antoine Pitroub26dc462010-05-05 16:27:30 +0000824 /* MS _chsize doesn't work if newsize doesn't fit in 32 bits,
825 so don't even try using it. */
826 {
827 PyObject *oldposobj, *tempposobj;
828 HANDLE hFile;
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000829
Antoine Pitroub26dc462010-05-05 16:27:30 +0000830 /* we save the file pointer position */
831 oldposobj = portable_lseek(fd, NULL, 1);
832 if (oldposobj == NULL) {
833 Py_DECREF(posobj);
834 return NULL;
835 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000836
Antoine Pitroub26dc462010-05-05 16:27:30 +0000837 /* we then move to the truncation position */
838 tempposobj = portable_lseek(fd, posobj, 0);
839 if (tempposobj == NULL) {
840 Py_DECREF(oldposobj);
841 Py_DECREF(posobj);
842 return NULL;
843 }
844 Py_DECREF(tempposobj);
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000845
Antoine Pitroub26dc462010-05-05 16:27:30 +0000846 /* Truncate. Note that this may grow the file! */
847 Py_BEGIN_ALLOW_THREADS
848 errno = 0;
849 hFile = (HANDLE)_get_osfhandle(fd);
850 ret = hFile == (HANDLE)-1; /* testing for INVALID_HANDLE value */
851 if (ret == 0) {
852 ret = SetEndOfFile(hFile) == 0;
853 if (ret)
854 errno = EACCES;
855 }
856 Py_END_ALLOW_THREADS
857
858 /* we restore the file pointer position in any case */
859 tempposobj = portable_lseek(fd, oldposobj, 0);
860 Py_DECREF(oldposobj);
861 if (tempposobj == NULL) {
862 Py_DECREF(posobj);
863 return NULL;
864 }
865 Py_DECREF(tempposobj);
866 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000867#else
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000868
869#if defined(HAVE_LARGEFILE_SUPPORT)
Antoine Pitroub26dc462010-05-05 16:27:30 +0000870 pos = PyLong_AsLongLong(posobj);
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000871#else
Antoine Pitroub26dc462010-05-05 16:27:30 +0000872 pos = PyLong_AsLong(posobj);
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000873#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +0000874 if (PyErr_Occurred()){
875 Py_DECREF(posobj);
876 return NULL;
877 }
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000878
Antoine Pitroub26dc462010-05-05 16:27:30 +0000879 Py_BEGIN_ALLOW_THREADS
880 errno = 0;
881 ret = ftruncate(fd, pos);
882 Py_END_ALLOW_THREADS
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000883
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000884#endif /* !MS_WINDOWS */
885
Antoine Pitroub26dc462010-05-05 16:27:30 +0000886 if (ret != 0) {
887 Py_DECREF(posobj);
888 PyErr_SetFromErrno(PyExc_IOError);
889 return NULL;
890 }
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000891
Antoine Pitroub26dc462010-05-05 16:27:30 +0000892 return posobj;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000893}
Antoine Pitrouf3fa0742010-01-31 22:26:04 +0000894#endif /* HAVE_FTRUNCATE */
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000895
896static char *
Antoine Pitrou19690592009-06-12 20:14:08 +0000897mode_string(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000898{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000899 if (self->readable) {
900 if (self->writable)
901 return "rb+";
902 else
903 return "rb";
904 }
905 else
906 return "wb";
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000907}
908
909static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000910fileio_repr(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000911{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000912 PyObject *nameobj, *res;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000913
Antoine Pitroub26dc462010-05-05 16:27:30 +0000914 if (self->fd < 0)
915 return PyString_FromFormat("<_io.FileIO [closed]>");
Antoine Pitrou19690592009-06-12 20:14:08 +0000916
Antoine Pitroub26dc462010-05-05 16:27:30 +0000917 nameobj = PyObject_GetAttrString((PyObject *) self, "name");
918 if (nameobj == NULL) {
919 if (PyErr_ExceptionMatches(PyExc_AttributeError))
920 PyErr_Clear();
921 else
922 return NULL;
923 res = PyString_FromFormat("<_io.FileIO fd=%d mode='%s'>",
924 self->fd, mode_string(self));
925 }
926 else {
927 PyObject *repr = PyObject_Repr(nameobj);
928 Py_DECREF(nameobj);
929 if (repr == NULL)
930 return NULL;
931 res = PyString_FromFormat("<_io.FileIO name=%s mode='%s'>",
932 PyString_AS_STRING(repr),
933 mode_string(self));
934 Py_DECREF(repr);
935 }
936 return res;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000937}
938
939static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +0000940fileio_isatty(fileio *self)
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000941{
Antoine Pitroub26dc462010-05-05 16:27:30 +0000942 long res;
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000943
Antoine Pitroub26dc462010-05-05 16:27:30 +0000944 if (self->fd < 0)
945 return err_closed();
946 Py_BEGIN_ALLOW_THREADS
947 res = isatty(self->fd);
948 Py_END_ALLOW_THREADS
949 return PyBool_FromLong(res);
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000950}
951
952
953PyDoc_STRVAR(fileio_doc,
954"file(name: str[, mode: str]) -> file IO object\n"
955"\n"
956"Open a file. The mode can be 'r', 'w' or 'a' for reading (default),\n"
Antoine Pitroub26dc462010-05-05 16:27:30 +0000957"writing or appending. The file will be created if it doesn't exist\n"
Christian Heimes7f39c9f2008-01-25 12:18:43 +0000958"when opened for writing or appending; it will be truncated when\n"
959"opened for writing. Add a '+' to the mode to allow simultaneous\n"
960"reading and writing.");
961
962PyDoc_STRVAR(read_doc,
963"read(size: int) -> bytes. read at most size bytes, returned as bytes.\n"
964"\n"
965"Only makes one system call, so less data may be returned than requested\n"
966"In non-blocking mode, returns None if no data is available.\n"
967"On end-of-file, returns ''.");
968
969PyDoc_STRVAR(readall_doc,
970"readall() -> bytes. read all data from the file, returned as bytes.\n"
971"\n"
972"In non-blocking mode, returns as much as is immediately available,\n"
973"or None if no data is available. On end-of-file, returns ''.");
974
975PyDoc_STRVAR(write_doc,
976"write(b: bytes) -> int. Write bytes b to file, return number written.\n"
977"\n"
978"Only makes one system call, so not all of the data may be written.\n"
979"The number of bytes actually written is returned.");
980
981PyDoc_STRVAR(fileno_doc,
982"fileno() -> int. \"file descriptor\".\n"
983"\n"
984"This is needed for lower-level file interfaces, such the fcntl module.");
985
986PyDoc_STRVAR(seek_doc,
987"seek(offset: int[, whence: int]) -> None. Move to new file position.\n"
988"\n"
989"Argument offset is a byte count. Optional argument whence defaults to\n"
990"0 (offset from start of file, offset should be >= 0); other values are 1\n"
991"(move relative to current position, positive or negative), and 2 (move\n"
992"relative to end of file, usually negative, although many platforms allow\n"
993"seeking beyond the end of a file)."
994"\n"
995"Note that not all file objects are seekable.");
996
997#ifdef HAVE_FTRUNCATE
998PyDoc_STRVAR(truncate_doc,
Antoine Pitroub26dc462010-05-05 16:27:30 +0000999"truncate([size: int]) -> None. Truncate the file to at most size bytes.\n"
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001000"\n"
Alexandre Vassalotti1aed6242008-05-09 21:49:43 +00001001"Size defaults to the current file position, as returned by tell()."
1002"The current file position is changed to the value of size.");
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001003#endif
1004
1005PyDoc_STRVAR(tell_doc,
Antoine Pitroub26dc462010-05-05 16:27:30 +00001006"tell() -> int. Current file position");
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001007
1008PyDoc_STRVAR(readinto_doc,
Antoine Pitrou19690592009-06-12 20:14:08 +00001009"readinto() -> Same as RawIOBase.readinto().");
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001010
1011PyDoc_STRVAR(close_doc,
1012"close() -> None. Close the file.\n"
1013"\n"
1014"A closed file cannot be used for further I/O operations. close() may be\n"
1015"called more than once without error. Changes the fileno to -1.");
1016
1017PyDoc_STRVAR(isatty_doc,
1018"isatty() -> bool. True if the file is connected to a tty device.");
1019
1020PyDoc_STRVAR(seekable_doc,
1021"seekable() -> bool. True if file supports random-access.");
1022
1023PyDoc_STRVAR(readable_doc,
1024"readable() -> bool. True if file was opened in a read mode.");
1025
1026PyDoc_STRVAR(writable_doc,
1027"writable() -> bool. True if file was opened in a write mode.");
1028
1029static PyMethodDef fileio_methods[] = {
Antoine Pitroub26dc462010-05-05 16:27:30 +00001030 {"read", (PyCFunction)fileio_read, METH_VARARGS, read_doc},
1031 {"readall", (PyCFunction)fileio_readall, METH_NOARGS, readall_doc},
1032 {"readinto", (PyCFunction)fileio_readinto, METH_VARARGS, readinto_doc},
1033 {"write", (PyCFunction)fileio_write, METH_VARARGS, write_doc},
1034 {"seek", (PyCFunction)fileio_seek, METH_VARARGS, seek_doc},
1035 {"tell", (PyCFunction)fileio_tell, METH_VARARGS, tell_doc},
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001036#ifdef HAVE_FTRUNCATE
Antoine Pitroub26dc462010-05-05 16:27:30 +00001037 {"truncate", (PyCFunction)fileio_truncate, METH_VARARGS, truncate_doc},
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001038#endif
Antoine Pitroub26dc462010-05-05 16:27:30 +00001039 {"close", (PyCFunction)fileio_close, METH_NOARGS, close_doc},
1040 {"seekable", (PyCFunction)fileio_seekable, METH_NOARGS, seekable_doc},
1041 {"readable", (PyCFunction)fileio_readable, METH_NOARGS, readable_doc},
1042 {"writable", (PyCFunction)fileio_writable, METH_NOARGS, writable_doc},
1043 {"fileno", (PyCFunction)fileio_fileno, METH_NOARGS, fileno_doc},
1044 {"isatty", (PyCFunction)fileio_isatty, METH_NOARGS, isatty_doc},
1045 {NULL, NULL} /* sentinel */
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001046};
1047
1048/* 'closed' and 'mode' are attributes for backwards compatibility reasons. */
1049
1050static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +00001051get_closed(fileio *self, void *closure)
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001052{
Antoine Pitroub26dc462010-05-05 16:27:30 +00001053 return PyBool_FromLong((long)(self->fd < 0));
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001054}
1055
1056static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +00001057get_closefd(fileio *self, void *closure)
Amaury Forgeot d'Arc32265652008-11-20 23:34:31 +00001058{
Antoine Pitroub26dc462010-05-05 16:27:30 +00001059 return PyBool_FromLong((long)(self->closefd));
Amaury Forgeot d'Arc32265652008-11-20 23:34:31 +00001060}
1061
1062static PyObject *
Antoine Pitrou19690592009-06-12 20:14:08 +00001063get_mode(fileio *self, void *closure)
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001064{
Antoine Pitroub26dc462010-05-05 16:27:30 +00001065 return PyUnicode_FromString(mode_string(self));
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001066}
1067
1068static PyGetSetDef fileio_getsetlist[] = {
Antoine Pitroub26dc462010-05-05 16:27:30 +00001069 {"closed", (getter)get_closed, NULL, "True if the file is closed"},
1070 {"closefd", (getter)get_closefd, NULL,
1071 "True if the file descriptor will be closed"},
1072 {"mode", (getter)get_mode, NULL, "String giving the file mode"},
1073 {NULL},
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001074};
1075
1076PyTypeObject PyFileIO_Type = {
Antoine Pitroub26dc462010-05-05 16:27:30 +00001077 PyVarObject_HEAD_INIT(NULL, 0)
1078 "_io.FileIO",
1079 sizeof(fileio),
1080 0,
1081 (destructor)fileio_dealloc, /* tp_dealloc */
1082 0, /* tp_print */
1083 0, /* tp_getattr */
1084 0, /* tp_setattr */
1085 0, /* tp_reserved */
1086 (reprfunc)fileio_repr, /* tp_repr */
1087 0, /* tp_as_number */
1088 0, /* tp_as_sequence */
1089 0, /* tp_as_mapping */
1090 0, /* tp_hash */
1091 0, /* tp_call */
1092 0, /* tp_str */
1093 PyObject_GenericGetAttr, /* tp_getattro */
1094 0, /* tp_setattro */
1095 0, /* tp_as_buffer */
1096 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE
1097 | Py_TPFLAGS_HAVE_GC, /* tp_flags */
1098 fileio_doc, /* tp_doc */
1099 (traverseproc)fileio_traverse, /* tp_traverse */
1100 (inquiry)fileio_clear, /* tp_clear */
1101 0, /* tp_richcompare */
1102 offsetof(fileio, weakreflist), /* tp_weaklistoffset */
1103 0, /* tp_iter */
1104 0, /* tp_iternext */
1105 fileio_methods, /* tp_methods */
1106 0, /* tp_members */
1107 fileio_getsetlist, /* tp_getset */
1108 0, /* tp_base */
1109 0, /* tp_dict */
1110 0, /* tp_descr_get */
1111 0, /* tp_descr_set */
1112 offsetof(fileio, dict), /* tp_dictoffset */
1113 fileio_init, /* tp_init */
1114 PyType_GenericAlloc, /* tp_alloc */
1115 fileio_new, /* tp_new */
1116 PyObject_GC_Del, /* tp_free */
Christian Heimes7f39c9f2008-01-25 12:18:43 +00001117};