+++ /dev/null
-/*\r
- An implementation of Buffered I/O as defined by PEP 3116 - "New I/O"\r
- \r
- Classes defined here: BufferedIOBase, BufferedReader, BufferedWriter,\r
- BufferedRandom.\r
- \r
- Written by Amaury Forgeot d'Arc and Antoine Pitrou\r
-*/\r
-\r
-#define PY_SSIZE_T_CLEAN\r
-#include "Python.h"\r
-#include "structmember.h"\r
-#include "pythread.h"\r
-#include "_iomodule.h"\r
-\r
-/*\r
- * BufferedIOBase class, inherits from IOBase.\r
- */\r
-PyDoc_STRVAR(bufferediobase_doc,\r
- "Base class for buffered IO objects.\n"\r
- "\n"\r
- "The main difference with RawIOBase is that the read() method\n"\r
- "supports omitting the size argument, and does not have a default\n"\r
- "implementation that defers to readinto().\n"\r
- "\n"\r
- "In addition, read(), readinto() and write() may raise\n"\r
- "BlockingIOError if the underlying raw stream is in non-blocking\n"\r
- "mode and not ready; unlike their raw counterparts, they will never\n"\r
- "return None.\n"\r
- "\n"\r
- "A typical implementation should not inherit from a RawIOBase\n"\r
- "implementation, but wrap one.\n"\r
- );\r
-\r
-static PyObject *\r
-bufferediobase_readinto(PyObject *self, PyObject *args)\r
-{\r
- Py_buffer buf;\r
- Py_ssize_t len;\r
- PyObject *data;\r
-\r
- if (!PyArg_ParseTuple(args, "w*:readinto", &buf)) {\r
- return NULL;\r
- }\r
-\r
- data = PyObject_CallMethod(self, "read", "n", buf.len);\r
- if (data == NULL)\r
- goto error;\r
-\r
- if (!PyBytes_Check(data)) {\r
- Py_DECREF(data);\r
- PyErr_SetString(PyExc_TypeError, "read() should return bytes");\r
- goto error;\r
- }\r
-\r
- len = Py_SIZE(data);\r
- memcpy(buf.buf, PyBytes_AS_STRING(data), len);\r
-\r
- PyBuffer_Release(&buf);\r
- Py_DECREF(data);\r
-\r
- return PyLong_FromSsize_t(len);\r
-\r
- error:\r
- PyBuffer_Release(&buf);\r
- return NULL;\r
-}\r
-\r
-static PyObject *\r
-bufferediobase_unsupported(const char *message)\r
-{\r
- PyErr_SetString(_PyIO_unsupported_operation, message);\r
- return NULL;\r
-}\r
-\r
-PyDoc_STRVAR(bufferediobase_detach_doc,\r
- "Disconnect this buffer from its underlying raw stream and return it.\n"\r
- "\n"\r
- "After the raw stream has been detached, the buffer is in an unusable\n"\r
- "state.\n");\r
-\r
-static PyObject *\r
-bufferediobase_detach(PyObject *self)\r
-{\r
- return bufferediobase_unsupported("detach");\r
-}\r
-\r
-PyDoc_STRVAR(bufferediobase_read_doc,\r
- "Read and return up to n bytes.\n"\r
- "\n"\r
- "If the argument is omitted, None, or negative, reads and\n"\r
- "returns all data until EOF.\n"\r
- "\n"\r
- "If the argument is positive, and the underlying raw stream is\n"\r
- "not 'interactive', multiple raw reads may be issued to satisfy\n"\r
- "the byte count (unless EOF is reached first). But for\n"\r
- "interactive raw streams (as well as sockets and pipes), at most\n"\r
- "one raw read will be issued, and a short result does not imply\n"\r
- "that EOF is imminent.\n"\r
- "\n"\r
- "Returns an empty bytes object on EOF.\n"\r
- "\n"\r
- "Returns None if the underlying raw stream was open in non-blocking\n"\r
- "mode and no data is available at the moment.\n");\r
-\r
-static PyObject *\r
-bufferediobase_read(PyObject *self, PyObject *args)\r
-{\r
- return bufferediobase_unsupported("read");\r
-}\r
-\r
-PyDoc_STRVAR(bufferediobase_read1_doc,\r
- "Read and return up to n bytes, with at most one read() call\n"\r
- "to the underlying raw stream. A short result does not imply\n"\r
- "that EOF is imminent.\n"\r
- "\n"\r
- "Returns an empty bytes object on EOF.\n");\r
-\r
-static PyObject *\r
-bufferediobase_read1(PyObject *self, PyObject *args)\r
-{\r
- return bufferediobase_unsupported("read1");\r
-}\r
-\r
-PyDoc_STRVAR(bufferediobase_write_doc,\r
- "Write the given buffer to the IO stream.\n"\r
- "\n"\r
- "Returns the number of bytes written, which is never less than\n"\r
- "len(b).\n"\r
- "\n"\r
- "Raises BlockingIOError if the buffer is full and the\n"\r
- "underlying raw stream cannot accept more data at the moment.\n");\r
-\r
-static PyObject *\r
-bufferediobase_write(PyObject *self, PyObject *args)\r
-{\r
- return bufferediobase_unsupported("write");\r
-}\r
-\r
-\r
-static PyMethodDef bufferediobase_methods[] = {\r
- {"detach", (PyCFunction)bufferediobase_detach, METH_NOARGS, bufferediobase_detach_doc},\r
- {"read", bufferediobase_read, METH_VARARGS, bufferediobase_read_doc},\r
- {"read1", bufferediobase_read1, METH_VARARGS, bufferediobase_read1_doc},\r
- {"readinto", bufferediobase_readinto, METH_VARARGS, NULL},\r
- {"write", bufferediobase_write, METH_VARARGS, bufferediobase_write_doc},\r
- {NULL, NULL}\r
-};\r
-\r
-PyTypeObject PyBufferedIOBase_Type = {\r
- PyVarObject_HEAD_INIT(NULL, 0)\r
- "_io._BufferedIOBase", /*tp_name*/\r
- 0, /*tp_basicsize*/\r
- 0, /*tp_itemsize*/\r
- 0, /*tp_dealloc*/\r
- 0, /*tp_print*/\r
- 0, /*tp_getattr*/\r
- 0, /*tp_setattr*/\r
- 0, /*tp_compare */\r
- 0, /*tp_repr*/\r
- 0, /*tp_as_number*/\r
- 0, /*tp_as_sequence*/\r
- 0, /*tp_as_mapping*/\r
- 0, /*tp_hash */\r
- 0, /*tp_call*/\r
- 0, /*tp_str*/\r
- 0, /*tp_getattro*/\r
- 0, /*tp_setattro*/\r
- 0, /*tp_as_buffer*/\r
- Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE, /*tp_flags*/\r
- bufferediobase_doc, /* tp_doc */\r
- 0, /* tp_traverse */\r
- 0, /* tp_clear */\r
- 0, /* tp_richcompare */\r
- 0, /* tp_weaklistoffset */\r
- 0, /* tp_iter */\r
- 0, /* tp_iternext */\r
- bufferediobase_methods, /* tp_methods */\r
- 0, /* tp_members */\r
- 0, /* tp_getset */\r
- &PyIOBase_Type, /* tp_base */\r
- 0, /* tp_dict */\r
- 0, /* tp_descr_get */\r
- 0, /* tp_descr_set */\r
- 0, /* tp_dictoffset */\r
- 0, /* tp_init */\r
- 0, /* tp_alloc */\r
- 0, /* tp_new */\r
-};\r
-\r
-\r
-typedef struct {\r
- PyObject_HEAD\r
-\r
- PyObject *raw;\r
- int ok; /* Initialized? */\r
- int detached;\r
- int readable;\r
- int writable;\r
- \r
- /* True if this is a vanilla Buffered object (rather than a user derived\r
- class) *and* the raw stream is a vanilla FileIO object. */\r
- int fast_closed_checks;\r
-\r
- /* Absolute position inside the raw stream (-1 if unknown). */\r
- Py_off_t abs_pos;\r
-\r
- /* A static buffer of size `buffer_size` */\r
- char *buffer;\r
- /* Current logical position in the buffer. */\r
- Py_off_t pos;\r
- /* Position of the raw stream in the buffer. */\r
- Py_off_t raw_pos;\r
-\r
- /* Just after the last buffered byte in the buffer, or -1 if the buffer\r
- isn't ready for reading. */\r
- Py_off_t read_end;\r
-\r
- /* Just after the last byte actually written */\r
- Py_off_t write_pos;\r
- /* Just after the last byte waiting to be written, or -1 if the buffer\r
- isn't ready for writing. */\r
- Py_off_t write_end;\r
-\r
-#ifdef WITH_THREAD\r
- PyThread_type_lock lock;\r
- volatile long owner;\r
-#endif\r
-\r
- Py_ssize_t buffer_size;\r
- Py_ssize_t buffer_mask;\r
-\r
- PyObject *dict;\r
- PyObject *weakreflist;\r
-} buffered;\r
-\r
-/*\r
- Implementation notes:\r
- \r
- * BufferedReader, BufferedWriter and BufferedRandom try to share most\r
- methods (this is helped by the members `readable` and `writable`, which\r
- are initialized in the respective constructors)\r
- * They also share a single buffer for reading and writing. This enables\r
- interleaved reads and writes without flushing. It also makes the logic\r
- a bit trickier to get right.\r
- * The absolute position of the raw stream is cached, if possible, in the\r
- `abs_pos` member. It must be updated every time an operation is done\r
- on the raw stream. If not sure, it can be reinitialized by calling\r
- _buffered_raw_tell(), which queries the raw stream (_buffered_raw_seek()\r
- also does it). To read it, use RAW_TELL().\r
- * Three helpers, _bufferedreader_raw_read, _bufferedwriter_raw_write and\r
- _bufferedwriter_flush_unlocked do a lot of useful housekeeping.\r
-\r
- NOTE: we should try to maintain block alignment of reads and writes to the\r
- raw stream (according to the buffer size), but for now it is only done\r
- in read() and friends.\r
- \r
-*/\r
-\r
-/* These macros protect the buffered object against concurrent operations. */\r
-\r
-#ifdef WITH_THREAD\r
-\r
-static int\r
-_enter_buffered_busy(buffered *self)\r
-{\r
- if (self->owner == PyThread_get_thread_ident()) {\r
- PyObject *r = PyObject_Repr((PyObject *) self);\r
- if (r != NULL) {\r
- PyErr_Format(PyExc_RuntimeError,\r
- "reentrant call inside %s",\r
- PyString_AS_STRING(r));\r
- Py_DECREF(r);\r
- }\r
- return 0;\r
- }\r
- Py_BEGIN_ALLOW_THREADS\r
- PyThread_acquire_lock(self->lock, 1);\r
- Py_END_ALLOW_THREADS\r
- return 1;\r
-}\r
-\r
-#define ENTER_BUFFERED(self) \\r
- ( (PyThread_acquire_lock(self->lock, 0) ? \\r
- 1 : _enter_buffered_busy(self)) \\r
- && (self->owner = PyThread_get_thread_ident(), 1) )\r
-\r
-#define LEAVE_BUFFERED(self) \\r
- do { \\r
- self->owner = 0; \\r
- PyThread_release_lock(self->lock); \\r
- } while(0);\r
-\r
-#else\r
-#define ENTER_BUFFERED(self) 1\r
-#define LEAVE_BUFFERED(self)\r
-#endif\r
-\r
-#define CHECK_INITIALIZED(self) \\r
- if (self->ok <= 0) { \\r
- if (self->detached) { \\r
- PyErr_SetString(PyExc_ValueError, \\r
- "raw stream has been detached"); \\r
- } else { \\r
- PyErr_SetString(PyExc_ValueError, \\r
- "I/O operation on uninitialized object"); \\r
- } \\r
- return NULL; \\r
- }\r
-\r
-#define CHECK_INITIALIZED_INT(self) \\r
- if (self->ok <= 0) { \\r
- if (self->detached) { \\r
- PyErr_SetString(PyExc_ValueError, \\r
- "raw stream has been detached"); \\r
- } else { \\r
- PyErr_SetString(PyExc_ValueError, \\r
- "I/O operation on uninitialized object"); \\r
- } \\r
- return -1; \\r
- }\r
-\r
-#define IS_CLOSED(self) \\r
- (self->fast_closed_checks \\r
- ? _PyFileIO_closed(self->raw) \\r
- : buffered_closed(self))\r
-\r
-#define CHECK_CLOSED(self, error_msg) \\r
- if (IS_CLOSED(self)) { \\r
- PyErr_SetString(PyExc_ValueError, error_msg); \\r
- return NULL; \\r
- }\r
-\r
-\r
-#define VALID_READ_BUFFER(self) \\r
- (self->readable && self->read_end != -1)\r
-\r
-#define VALID_WRITE_BUFFER(self) \\r
- (self->writable && self->write_end != -1)\r
-\r
-#define ADJUST_POSITION(self, _new_pos) \\r
- do { \\r
- self->pos = _new_pos; \\r
- if (VALID_READ_BUFFER(self) && self->read_end < self->pos) \\r
- self->read_end = self->pos; \\r
- } while(0)\r
-\r
-#define READAHEAD(self) \\r
- ((self->readable && VALID_READ_BUFFER(self)) \\r
- ? (self->read_end - self->pos) : 0)\r
-\r
-#define RAW_OFFSET(self) \\r
- (((VALID_READ_BUFFER(self) || VALID_WRITE_BUFFER(self)) \\r
- && self->raw_pos >= 0) ? self->raw_pos - self->pos : 0)\r
-\r
-#define RAW_TELL(self) \\r
- (self->abs_pos != -1 ? self->abs_pos : _buffered_raw_tell(self))\r
-\r
-#define MINUS_LAST_BLOCK(self, size) \\r
- (self->buffer_mask ? \\r
- (size & ~self->buffer_mask) : \\r
- (self->buffer_size * (size / self->buffer_size)))\r
-\r
-\r
-static void\r
-buffered_dealloc(buffered *self)\r
-{\r
- if (self->ok && _PyIOBase_finalize((PyObject *) self) < 0)\r
- return;\r
- _PyObject_GC_UNTRACK(self);\r
- self->ok = 0;\r
- if (self->weakreflist != NULL)\r
- PyObject_ClearWeakRefs((PyObject *)self);\r
- Py_CLEAR(self->raw);\r
- if (self->buffer) {\r
- PyMem_Free(self->buffer);\r
- self->buffer = NULL;\r
- }\r
-#ifdef WITH_THREAD\r
- if (self->lock) {\r
- PyThread_free_lock(self->lock);\r
- self->lock = NULL;\r
- }\r
-#endif\r
- Py_CLEAR(self->dict);\r
- Py_TYPE(self)->tp_free((PyObject *)self);\r
-}\r
-\r
-static PyObject *\r
-buffered_sizeof(buffered *self, void *unused)\r
-{\r
- Py_ssize_t res;\r
-\r
- res = sizeof(buffered);\r
- if (self->buffer)\r
- res += self->buffer_size;\r
- return PyLong_FromSsize_t(res);\r
-}\r
-\r
-static int\r
-buffered_traverse(buffered *self, visitproc visit, void *arg)\r
-{\r
- Py_VISIT(self->raw);\r
- Py_VISIT(self->dict);\r
- return 0;\r
-}\r
-\r
-static int\r
-buffered_clear(buffered *self)\r
-{\r
- if (self->ok && _PyIOBase_finalize((PyObject *) self) < 0)\r
- return -1;\r
- self->ok = 0;\r
- Py_CLEAR(self->raw);\r
- Py_CLEAR(self->dict);\r
- return 0;\r
-}\r
-\r
-/*\r
- * _BufferedIOMixin methods\r
- * This is not a class, just a collection of methods that will be reused\r
- * by BufferedReader and BufferedWriter\r
- */\r
-\r
-/* Flush and close */\r
-\r
-static PyObject *\r
-buffered_simple_flush(buffered *self, PyObject *args)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_CallMethodObjArgs(self->raw, _PyIO_str_flush, NULL);\r
-}\r
-\r
-static int\r
-buffered_closed(buffered *self)\r
-{\r
- int closed;\r
- PyObject *res;\r
- CHECK_INITIALIZED_INT(self)\r
- res = PyObject_GetAttr(self->raw, _PyIO_str_closed);\r
- if (res == NULL)\r
- return -1;\r
- closed = PyObject_IsTrue(res);\r
- Py_DECREF(res);\r
- return closed;\r
-}\r
-\r
-static PyObject *\r
-buffered_closed_get(buffered *self, void *context)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_GetAttr(self->raw, _PyIO_str_closed);\r
-}\r
-\r
-static PyObject *\r
-buffered_close(buffered *self, PyObject *args)\r
-{\r
- PyObject *res = NULL, *exc = NULL, *val, *tb;\r
- int r;\r
-\r
- CHECK_INITIALIZED(self)\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
-\r
- r = buffered_closed(self);\r
- if (r < 0)\r
- goto end;\r
- if (r > 0) {\r
- res = Py_None;\r
- Py_INCREF(res);\r
- goto end;\r
- }\r
- /* flush() will most probably re-take the lock, so drop it first */\r
- LEAVE_BUFFERED(self)\r
- res = PyObject_CallMethodObjArgs((PyObject *)self, _PyIO_str_flush, NULL);\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
- if (res == NULL)\r
- PyErr_Fetch(&exc, &val, &tb);\r
- else\r
- Py_DECREF(res);\r
-\r
- res = PyObject_CallMethodObjArgs(self->raw, _PyIO_str_close, NULL);\r
-\r
- if (exc != NULL) {\r
- _PyErr_ReplaceException(exc, val, tb);\r
- Py_CLEAR(res);\r
- }\r
-\r
-end:\r
- LEAVE_BUFFERED(self)\r
- return res;\r
-}\r
-\r
-/* detach */\r
-\r
-static PyObject *\r
-buffered_detach(buffered *self, PyObject *args)\r
-{\r
- PyObject *raw, *res;\r
- CHECK_INITIALIZED(self)\r
- res = PyObject_CallMethodObjArgs((PyObject *)self, _PyIO_str_flush, NULL);\r
- if (res == NULL)\r
- return NULL;\r
- Py_DECREF(res);\r
- raw = self->raw;\r
- self->raw = NULL;\r
- self->detached = 1;\r
- self->ok = 0;\r
- return raw;\r
-}\r
-\r
-/* Inquiries */\r
-\r
-static PyObject *\r
-buffered_seekable(buffered *self, PyObject *args)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_CallMethodObjArgs(self->raw, _PyIO_str_seekable, NULL);\r
-}\r
-\r
-static PyObject *\r
-buffered_readable(buffered *self, PyObject *args)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_CallMethodObjArgs(self->raw, _PyIO_str_readable, NULL);\r
-}\r
-\r
-static PyObject *\r
-buffered_writable(buffered *self, PyObject *args)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_CallMethodObjArgs(self->raw, _PyIO_str_writable, NULL);\r
-}\r
-\r
-static PyObject *\r
-buffered_name_get(buffered *self, void *context)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_GetAttrString(self->raw, "name");\r
-}\r
-\r
-static PyObject *\r
-buffered_mode_get(buffered *self, void *context)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_GetAttrString(self->raw, "mode");\r
-}\r
-\r
-/* Lower-level APIs */\r
-\r
-static PyObject *\r
-buffered_fileno(buffered *self, PyObject *args)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_CallMethodObjArgs(self->raw, _PyIO_str_fileno, NULL);\r
-}\r
-\r
-static PyObject *\r
-buffered_isatty(buffered *self, PyObject *args)\r
-{\r
- CHECK_INITIALIZED(self)\r
- return PyObject_CallMethodObjArgs(self->raw, _PyIO_str_isatty, NULL);\r
-}\r
-\r
-\r
-/* Forward decls */\r
-static PyObject *\r
-_bufferedwriter_flush_unlocked(buffered *);\r
-static Py_ssize_t\r
-_bufferedreader_fill_buffer(buffered *self);\r
-static void\r
-_bufferedreader_reset_buf(buffered *self);\r
-static void\r
-_bufferedwriter_reset_buf(buffered *self);\r
-static PyObject *\r
-_bufferedreader_peek_unlocked(buffered *self, Py_ssize_t);\r
-static PyObject *\r
-_bufferedreader_read_all(buffered *self);\r
-static PyObject *\r
-_bufferedreader_read_fast(buffered *self, Py_ssize_t);\r
-static PyObject *\r
-_bufferedreader_read_generic(buffered *self, Py_ssize_t);\r
-\r
-\r
-/*\r
- * Helpers\r
- */\r
-\r
-/* Sets the current error to BlockingIOError */\r
-static void\r
-_set_BlockingIOError(char *msg, Py_ssize_t written)\r
-{\r
- PyObject *err;\r
- err = PyObject_CallFunction(PyExc_BlockingIOError, "isn",\r
- errno, msg, written);\r
- if (err)\r
- PyErr_SetObject(PyExc_BlockingIOError, err);\r
- Py_XDECREF(err);\r
-}\r
-\r
-/* Returns the address of the `written` member if a BlockingIOError was\r
- raised, NULL otherwise. The error is always re-raised. */\r
-static Py_ssize_t *\r
-_buffered_check_blocking_error(void)\r
-{\r
- PyObject *t, *v, *tb;\r
- PyBlockingIOErrorObject *err;\r
-\r
- PyErr_Fetch(&t, &v, &tb);\r
- if (v == NULL || !PyErr_GivenExceptionMatches(v, PyExc_BlockingIOError)) {\r
- PyErr_Restore(t, v, tb);\r
- return NULL;\r
- }\r
- err = (PyBlockingIOErrorObject *) v;\r
- /* TODO: sanity check (err->written >= 0) */\r
- PyErr_Restore(t, v, tb);\r
- return &err->written;\r
-}\r
-\r
-static Py_off_t\r
-_buffered_raw_tell(buffered *self)\r
-{\r
- Py_off_t n;\r
- PyObject *res;\r
- res = PyObject_CallMethodObjArgs(self->raw, _PyIO_str_tell, NULL);\r
- if (res == NULL)\r
- return -1;\r
- n = PyNumber_AsOff_t(res, PyExc_ValueError);\r
- Py_DECREF(res);\r
- if (n < 0) {\r
- if (!PyErr_Occurred())\r
- PyErr_Format(PyExc_IOError,\r
- "Raw stream returned invalid position %" PY_PRIdOFF,\r
- (PY_OFF_T_COMPAT)n);\r
- return -1;\r
- }\r
- self->abs_pos = n;\r
- return n;\r
-}\r
-\r
-static Py_off_t\r
-_buffered_raw_seek(buffered *self, Py_off_t target, int whence)\r
-{\r
- PyObject *res, *posobj, *whenceobj;\r
- Py_off_t n;\r
-\r
- posobj = PyLong_FromOff_t(target);\r
- if (posobj == NULL)\r
- return -1;\r
- whenceobj = PyLong_FromLong(whence);\r
- if (whenceobj == NULL) {\r
- Py_DECREF(posobj);\r
- return -1;\r
- }\r
- res = PyObject_CallMethodObjArgs(self->raw, _PyIO_str_seek,\r
- posobj, whenceobj, NULL);\r
- Py_DECREF(posobj);\r
- Py_DECREF(whenceobj);\r
- if (res == NULL)\r
- return -1;\r
- n = PyNumber_AsOff_t(res, PyExc_ValueError);\r
- Py_DECREF(res);\r
- if (n < 0) {\r
- if (!PyErr_Occurred())\r
- PyErr_Format(PyExc_IOError,\r
- "Raw stream returned invalid position %" PY_PRIdOFF,\r
- (PY_OFF_T_COMPAT)n);\r
- return -1;\r
- }\r
- self->abs_pos = n;\r
- return n;\r
-}\r
-\r
-static int\r
-_buffered_init(buffered *self)\r
-{\r
- Py_ssize_t n;\r
- if (self->buffer_size <= 0) {\r
- PyErr_SetString(PyExc_ValueError,\r
- "buffer size must be strictly positive");\r
- return -1;\r
- }\r
- if (self->buffer)\r
- PyMem_Free(self->buffer);\r
- self->buffer = PyMem_Malloc(self->buffer_size);\r
- if (self->buffer == NULL) {\r
- PyErr_NoMemory();\r
- return -1;\r
- }\r
-#ifdef WITH_THREAD\r
- if (self->lock)\r
- PyThread_free_lock(self->lock);\r
- self->lock = PyThread_allocate_lock();\r
- if (self->lock == NULL) {\r
- PyErr_SetString(PyExc_RuntimeError, "can't allocate read lock");\r
- return -1;\r
- }\r
- self->owner = 0;\r
-#endif\r
- /* Find out whether buffer_size is a power of 2 */\r
- /* XXX is this optimization useful? */\r
- for (n = self->buffer_size - 1; n & 1; n >>= 1)\r
- ;\r
- if (n == 0)\r
- self->buffer_mask = self->buffer_size - 1;\r
- else\r
- self->buffer_mask = 0;\r
- if (_buffered_raw_tell(self) == -1)\r
- PyErr_Clear();\r
- return 0;\r
-}\r
-\r
-/* Return 1 if an EnvironmentError with errno == EINTR is set (and then\r
- clears the error indicator), 0 otherwise.\r
- Should only be called when PyErr_Occurred() is true.\r
-*/\r
-int\r
-_PyIO_trap_eintr(void)\r
-{\r
- static PyObject *eintr_int = NULL;\r
- PyObject *typ, *val, *tb;\r
- PyEnvironmentErrorObject *env_err;\r
-\r
- if (eintr_int == NULL) {\r
- eintr_int = PyLong_FromLong(EINTR);\r
- assert(eintr_int != NULL);\r
- }\r
- if (!PyErr_ExceptionMatches(PyExc_EnvironmentError))\r
- return 0;\r
- PyErr_Fetch(&typ, &val, &tb);\r
- PyErr_NormalizeException(&typ, &val, &tb);\r
- env_err = (PyEnvironmentErrorObject *) val;\r
- assert(env_err != NULL);\r
- if (env_err->myerrno != NULL &&\r
- PyObject_RichCompareBool(env_err->myerrno, eintr_int, Py_EQ) > 0) {\r
- Py_DECREF(typ);\r
- Py_DECREF(val);\r
- Py_XDECREF(tb);\r
- return 1;\r
- }\r
- /* This silences any error set by PyObject_RichCompareBool() */\r
- PyErr_Restore(typ, val, tb);\r
- return 0;\r
-}\r
-\r
-/*\r
- * Shared methods and wrappers\r
- */\r
-\r
-static PyObject *\r
-buffered_flush_and_rewind_unlocked(buffered *self)\r
-{\r
- PyObject *res;\r
-\r
- res = _bufferedwriter_flush_unlocked(self);\r
- if (res == NULL)\r
- return NULL;\r
- Py_DECREF(res);\r
-\r
- if (self->readable) {\r
- /* Rewind the raw stream so that its position corresponds to\r
- the current logical position. */\r
- Py_off_t n;\r
- n = _buffered_raw_seek(self, -RAW_OFFSET(self), 1);\r
- _bufferedreader_reset_buf(self);\r
- if (n == -1)\r
- return NULL;\r
- }\r
- Py_RETURN_NONE;\r
-}\r
-\r
-static PyObject *\r
-buffered_flush(buffered *self, PyObject *args)\r
-{\r
- PyObject *res;\r
-\r
- CHECK_INITIALIZED(self)\r
- CHECK_CLOSED(self, "flush of closed file")\r
-\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
- res = buffered_flush_and_rewind_unlocked(self);\r
- LEAVE_BUFFERED(self)\r
-\r
- return res;\r
-}\r
-\r
-static PyObject *\r
-buffered_peek(buffered *self, PyObject *args)\r
-{\r
- Py_ssize_t n = 0;\r
- PyObject *res = NULL;\r
-\r
- CHECK_INITIALIZED(self)\r
- if (!PyArg_ParseTuple(args, "|n:peek", &n)) {\r
- return NULL;\r
- }\r
-\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
-\r
- if (self->writable) {\r
- res = buffered_flush_and_rewind_unlocked(self);\r
- if (res == NULL)\r
- goto end;\r
- Py_CLEAR(res);\r
- }\r
- res = _bufferedreader_peek_unlocked(self, n);\r
-\r
-end:\r
- LEAVE_BUFFERED(self)\r
- return res;\r
-}\r
-\r
-static PyObject *\r
-buffered_read(buffered *self, PyObject *args)\r
-{\r
- Py_ssize_t n = -1;\r
- PyObject *res;\r
-\r
- CHECK_INITIALIZED(self)\r
- if (!PyArg_ParseTuple(args, "|O&:read", &_PyIO_ConvertSsize_t, &n)) {\r
- return NULL;\r
- }\r
- if (n < -1) {\r
- PyErr_SetString(PyExc_ValueError,\r
- "read length must be positive or -1");\r
- return NULL;\r
- }\r
-\r
- CHECK_CLOSED(self, "read of closed file")\r
-\r
- if (n == -1) {\r
- /* The number of bytes is unspecified, read until the end of stream */\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
- res = _bufferedreader_read_all(self);\r
- }\r
- else {\r
- res = _bufferedreader_read_fast(self, n);\r
- if (res != Py_None)\r
- return res;\r
- Py_DECREF(res);\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
- res = _bufferedreader_read_generic(self, n);\r
- }\r
-\r
- LEAVE_BUFFERED(self)\r
- return res;\r
-}\r
-\r
-static PyObject *\r
-buffered_read1(buffered *self, PyObject *args)\r
-{\r
- Py_ssize_t n, have, r;\r
- PyObject *res = NULL;\r
-\r
- CHECK_INITIALIZED(self)\r
- if (!PyArg_ParseTuple(args, "n:read1", &n)) {\r
- return NULL;\r
- }\r
-\r
- if (n < 0) {\r
- PyErr_SetString(PyExc_ValueError,\r
- "read length must be positive");\r
- return NULL;\r
- }\r
- if (n == 0)\r
- return PyBytes_FromStringAndSize(NULL, 0);\r
-\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
- \r
- /* Return up to n bytes. If at least one byte is buffered, we\r
- only return buffered bytes. Otherwise, we do one raw read. */\r
-\r
- /* XXX: this mimicks the io.py implementation but is probably wrong.\r
- If we need to read from the raw stream, then we could actually read\r
- all `n` bytes asked by the caller (and possibly more, so as to fill\r
- our buffer for the next reads). */\r
-\r
- have = Py_SAFE_DOWNCAST(READAHEAD(self), Py_off_t, Py_ssize_t);\r
- if (have > 0) {\r
- if (n > have)\r
- n = have;\r
- res = PyBytes_FromStringAndSize(self->buffer + self->pos, n);\r
- if (res == NULL)\r
- goto end;\r
- self->pos += n;\r
- goto end;\r
- }\r
-\r
- if (self->writable) {\r
- res = buffered_flush_and_rewind_unlocked(self);\r
- if (res == NULL)\r
- goto end;\r
- Py_DECREF(res);\r
- }\r
-\r
- /* Fill the buffer from the raw stream, and copy it to the result. */\r
- _bufferedreader_reset_buf(self);\r
- r = _bufferedreader_fill_buffer(self);\r
- if (r == -1)\r
- goto end;\r
- if (r == -2)\r
- r = 0;\r
- if (n > r)\r
- n = r;\r
- res = PyBytes_FromStringAndSize(self->buffer, n);\r
- if (res == NULL)\r
- goto end;\r
- self->pos = n;\r
-\r
-end:\r
- LEAVE_BUFFERED(self)\r
- return res;\r
-}\r
-\r
-static PyObject *\r
-buffered_readinto(buffered *self, PyObject *args)\r
-{\r
- CHECK_INITIALIZED(self)\r
- \r
- /* TODO: use raw.readinto() (or a direct copy from our buffer) instead! */\r
- return bufferediobase_readinto((PyObject *)self, args);\r
-}\r
-\r
-static PyObject *\r
-_buffered_readline(buffered *self, Py_ssize_t limit)\r
-{\r
- PyObject *res = NULL;\r
- PyObject *chunks = NULL;\r
- Py_ssize_t n, written = 0;\r
- const char *start, *s, *end;\r
-\r
- CHECK_CLOSED(self, "readline of closed file")\r
-\r
- /* First, try to find a line in the buffer. This can run unlocked because\r
- the calls to the C API are simple enough that they can't trigger\r
- any thread switch. */\r
- n = Py_SAFE_DOWNCAST(READAHEAD(self), Py_off_t, Py_ssize_t);\r
- if (limit >= 0 && n > limit)\r
- n = limit;\r
- start = self->buffer + self->pos;\r
- s = memchr(start, '\n', n);\r
- if (s != NULL) {\r
- res = PyBytes_FromStringAndSize(start, s - start + 1);\r
- if (res != NULL)\r
- self->pos += s - start + 1;\r
- goto end_unlocked;\r
- }\r
- if (n == limit) {\r
- res = PyBytes_FromStringAndSize(start, n);\r
- if (res != NULL)\r
- self->pos += n;\r
- goto end_unlocked;\r
- }\r
-\r
- if (!ENTER_BUFFERED(self))\r
- goto end_unlocked;\r
-\r
- /* Now we try to get some more from the raw stream */\r
- chunks = PyList_New(0);\r
- if (chunks == NULL)\r
- goto end;\r
- if (n > 0) {\r
- res = PyBytes_FromStringAndSize(start, n);\r
- if (res == NULL)\r
- goto end;\r
- if (PyList_Append(chunks, res) < 0) {\r
- Py_CLEAR(res);\r
- goto end;\r
- }\r
- Py_CLEAR(res);\r
- written += n;\r
- self->pos += n;\r
- if (limit >= 0)\r
- limit -= n;\r
- }\r
- if (self->writable) {\r
- PyObject *r = buffered_flush_and_rewind_unlocked(self);\r
- if (r == NULL)\r
- goto end;\r
- Py_DECREF(r);\r
- }\r
-\r
- for (;;) {\r
- _bufferedreader_reset_buf(self);\r
- n = _bufferedreader_fill_buffer(self);\r
- if (n == -1)\r
- goto end;\r
- if (n <= 0)\r
- break;\r
- if (limit >= 0 && n > limit)\r
- n = limit;\r
- start = self->buffer;\r
- end = start + n;\r
- s = start;\r
- while (s < end) {\r
- if (*s++ == '\n') {\r
- res = PyBytes_FromStringAndSize(start, s - start);\r
- if (res == NULL)\r
- goto end;\r
- self->pos = s - start;\r
- goto found;\r
- }\r
- }\r
- res = PyBytes_FromStringAndSize(start, n);\r
- if (res == NULL)\r
- goto end;\r
- if (n == limit) {\r
- self->pos = n;\r
- break;\r
- }\r
- if (PyList_Append(chunks, res) < 0) {\r
- Py_CLEAR(res);\r
- goto end;\r
- }\r
- Py_CLEAR(res);\r
- written += n;\r
- if (limit >= 0)\r
- limit -= n;\r
- }\r
-found:\r
- if (res != NULL && PyList_Append(chunks, res) < 0) {\r
- Py_CLEAR(res);\r
- goto end;\r
- }\r
- Py_CLEAR(res);\r
- res = _PyBytes_Join(_PyIO_empty_bytes, chunks);\r
-\r
-end:\r
- LEAVE_BUFFERED(self)\r
-end_unlocked:\r
- Py_XDECREF(chunks);\r
- return res;\r
-}\r
-\r
-static PyObject *\r
-buffered_readline(buffered *self, PyObject *args)\r
-{\r
- Py_ssize_t limit = -1;\r
-\r
- CHECK_INITIALIZED(self)\r
- if (!PyArg_ParseTuple(args, "|O&:readline", &_PyIO_ConvertSsize_t, &limit))\r
- return NULL;\r
- return _buffered_readline(self, limit);\r
-}\r
-\r
-\r
-static PyObject *\r
-buffered_tell(buffered *self, PyObject *args)\r
-{\r
- Py_off_t pos;\r
-\r
- CHECK_INITIALIZED(self)\r
- pos = _buffered_raw_tell(self);\r
- if (pos == -1)\r
- return NULL;\r
- pos -= RAW_OFFSET(self);\r
- /* TODO: sanity check (pos >= 0) */\r
- return PyLong_FromOff_t(pos);\r
-}\r
-\r
-static PyObject *\r
-buffered_seek(buffered *self, PyObject *args)\r
-{\r
- Py_off_t target, n;\r
- int whence = 0;\r
- PyObject *targetobj, *res = NULL;\r
-\r
- CHECK_INITIALIZED(self)\r
- if (!PyArg_ParseTuple(args, "O|i:seek", &targetobj, &whence)) {\r
- return NULL;\r
- }\r
- if (whence < 0 || whence > 2) {\r
- PyErr_Format(PyExc_ValueError,\r
- "whence must be between 0 and 2, not %d", whence);\r
- return NULL;\r
- }\r
-\r
- CHECK_CLOSED(self, "seek of closed file")\r
-\r
- target = PyNumber_AsOff_t(targetobj, PyExc_ValueError);\r
- if (target == -1 && PyErr_Occurred())\r
- return NULL;\r
-\r
- if (whence != 2 && self->readable) {\r
- Py_off_t current, avail;\r
- /* Check if seeking leaves us inside the current buffer,\r
- so as to return quickly if possible. Also, we needn't take the\r
- lock in this fast path.\r
- Don't know how to do that when whence == 2, though. */\r
- /* NOTE: RAW_TELL() can release the GIL but the object is in a stable\r
- state at this point. */\r
- current = RAW_TELL(self);\r
- avail = READAHEAD(self);\r
- if (avail > 0) {\r
- Py_off_t offset;\r
- if (whence == 0)\r
- offset = target - (current - RAW_OFFSET(self));\r
- else\r
- offset = target;\r
- if (offset >= -self->pos && offset <= avail) {\r
- self->pos += offset;\r
- return PyLong_FromOff_t(current - avail + offset);\r
- }\r
- }\r
- }\r
-\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
-\r
- /* Fallback: invoke raw seek() method and clear buffer */\r
- if (self->writable) {\r
- res = _bufferedwriter_flush_unlocked(self);\r
- if (res == NULL)\r
- goto end;\r
- Py_CLEAR(res);\r
- _bufferedwriter_reset_buf(self);\r
- }\r
-\r
- /* TODO: align on block boundary and read buffer if needed? */\r
- if (whence == 1)\r
- target -= RAW_OFFSET(self);\r
- n = _buffered_raw_seek(self, target, whence);\r
- if (n == -1)\r
- goto end;\r
- self->raw_pos = -1;\r
- res = PyLong_FromOff_t(n);\r
- if (res != NULL && self->readable)\r
- _bufferedreader_reset_buf(self);\r
-\r
-end:\r
- LEAVE_BUFFERED(self)\r
- return res;\r
-}\r
-\r
-static PyObject *\r
-buffered_truncate(buffered *self, PyObject *args)\r
-{\r
- PyObject *pos = Py_None;\r
- PyObject *res = NULL;\r
-\r
- CHECK_INITIALIZED(self)\r
- if (!PyArg_ParseTuple(args, "|O:truncate", &pos)) {\r
- return NULL;\r
- }\r
-\r
- if (!ENTER_BUFFERED(self))\r
- return NULL;\r
-\r
- if (self->writable) {\r
- res = buffered_flush_and_rewind_unlocked(self);\r
- if (res == NULL)\r
- goto end;\r
- Py_CLEAR(res);\r
- }\r
- res = PyObject_CallMethodObjArgs(self->raw, _PyIO_str_truncate, pos, NULL);\r
- if (res == NULL)\r
- goto end;\r
- /* Reset cached position */\r
- if (_buffered_raw_tell(self) == -1)\r
- PyErr_Clear();\r
-\r
-end:\r
- LEAVE_BUFFERED(self)\r
- return res;\r
-}\r
-\r
-static PyObject *\r
-buffered_iternext(buffered *self)\r
-{\r
- PyObject *line;\r
- PyTypeObject *tp;\r
-\r
- CHECK_INITIALIZED(self);\r
-\r
- tp = Py_TYPE(self);\r
- if (tp == &PyBufferedReader_Type ||\r
- tp == &PyBufferedRandom_Type) {\r
- /* Skip method call overhead for speed */\r
- line = _buffered_readline(self, -1);\r
- }\r
- else {\r
- line = PyObject_CallMethodObjArgs((PyObject *)self,\r
- _PyIO_str_readline, NULL);\r
- if (line && !PyBytes_Check(line)) {\r
- PyErr_Format(PyExc_IOError,\r
- "readline() should have returned a bytes object, "\r
- "not '%.200s'", Py_TYPE(line)->tp_name);\r
- Py_DECREF(line);\r
- return NULL;\r
- }\r
- }\r
-\r
- if (line == NULL)\r
- return NULL;\r
-\r
- if (PyBytes_GET_SIZE(line) == 0) {\r
- /* Reached EOF or would have blocked */\r
- Py_DECREF(line);\r
- return NULL;\r
- }\r
-\r
- return line;\r
-}\r
-\r
-static PyObject *\r
-buffered_repr(buffered *self)\r
-{\r
- PyObject *nameobj, *res;\r
-\r
- nameobj = PyObject_GetAttrString((PyObject *) self, "name");\r
- if (nameobj == NULL) {\r
- if (PyErr_ExceptionMatches(PyExc_Exception))\r
- PyErr_Clear();\r
- else\r
- return NULL;\r
- res = PyString_FromFormat("<%s>", Py_TYPE(self)->tp_name);\r
- }\r
- else {\r
- PyObject *repr = PyObject_Repr(nameobj);\r
- Py_DECREF(nameobj);\r
- if (repr == NULL)\r
- return NULL;\r
- res = PyString_FromFormat("<%s name=%s>",\r
- Py_TYPE(self)->tp_name,\r
- PyString_AS_STRING(repr));\r
- Py_DECREF(repr);\r
- }\r
- return res;\r
-}\r
-\r
-/*\r
- * class BufferedReader\r
- */\r
-\r
-PyDoc_STRVAR(bufferedreader_doc,\r
- "Create a new buffered reader using the given readable raw IO object.");\r
-\r
-static void _bufferedreader_reset_buf(buffered *self)\r
-{\r
- self->read_end = -1;\r
-}\r
-\r
-static int\r
-bufferedreader_init(buffered *self, PyObject *args, PyObject *kwds)\r
-{\r
- char *kwlist[] = {"raw", "buffer_size", NULL};\r
- Py_ssize_t buffer_size = DEFAULT_BUFFER_SIZE;\r
- PyObject *raw;\r
-\r
- self->ok = 0;\r
- self->detached = 0;\r
-\r
- if (!PyArg_ParseTupleAndKeywords(args, kwds, "O|n:BufferedReader", kwlist,\r
- &raw, &buffer_size)) {\r
- return -1;\r
- }\r
-\r
- if (_PyIOBase_check_readable(raw, Py_True) == NULL)\r
- return -1;\r
-\r
- Py_CLEAR(self->raw);\r
- Py_INCREF(raw);\r
- self->raw = raw;\r
- self->buffer_size = buffer_size;\r
- self->readable = 1;\r
- self->writable = 0;\r
-\r
- if (_buffered_init(self) < 0)\r
- return -1;\r
- _bufferedreader_reset_buf(self);\r
-\r
- self->fast_closed_checks = (Py_TYPE(self) == &PyBufferedReader_Type &&\r
- Py_TYPE(raw) == &PyFileIO_Type);\r
-\r
- self->ok = 1;\r
- return 0;\r
-}\r
-\r
-static Py_ssize_t\r
-_bufferedreader_raw_read(buffered *self, char *start, Py_ssize_t len)\r
-{\r
- Py_buffer buf;\r
- PyObject *memobj, *res;\r
- Py_ssize_t n;\r
- /* NOTE: the buffer needn't be released as its object is NULL. */\r
- if (PyBuffer_FillInfo(&buf, NULL, start, len, 0, PyBUF_CONTIG) == -1)\r
- return -1;\r
- memobj = PyMemoryView_FromBuffer(&buf);\r
- if (memobj == NULL)\r
- return -1;\r
- /* NOTE: PyErr_SetFromErrno() calls PyErr_CheckSignals() when EINTR\r
- occurs so we needn't do it ourselves.\r
- We then retry reading, ignoring the signal if no handler has\r
- raised (see issue #10956).\r
- */\r
- do {\r
- res = PyObject_CallMethodObjArgs(self->raw, _PyIO_str_readinto, memobj, NULL);\r
- } while (res == NULL && _PyIO_trap_eintr());\r
- Py_DECREF(memobj);\r
- if (res == NULL)\r
- return -1;\r
- if (res == Py_None) {\r
- /* Non-blocking stream would have blocked. Special return code! */\r
- Py_DECREF(res);\r
- return -2;\r
- }\r
- n = PyNumber_AsSsize_t(res, PyExc_ValueError);\r
- Py_DECREF(res);\r
- if (n < 0 || n > len) {\r
- PyErr_Format(PyExc_IOError,\r
- "raw readinto() returned invalid length %zd "\r
- "(should have been between 0 and %zd)", n, len);\r
- return -1;\r
- }\r
- if (n > 0 && self->abs_pos != -1)\r
- self->abs_pos += n;\r
- return n;\r
-}\r
-\r
-static Py_ssize_t\r
-_bufferedreader_fill_buffer(buffered *self)\r
-{\r
- Py_ssize_t start, len, n;\r
- if (VALID_READ_BUFFER(self))\r
- start = Py_SAFE_DOWNCAST(self->read_end, Py_off_t, Py_ssize_t);\r
- else\r
- start = 0;\r
- len = self->buffer_size - start;\r
- n = _bufferedreader_raw_read(self, self->buffer + start, len);\r
- if (n <= 0)\r
- return n;\r
- self->read_end = start + n;\r
- self->raw_pos = start + n;\r
- return n;\r
-}\r
-\r
-static PyObject *\r
-_bufferedreader_read_all(buffered *self)\r
-{\r
- Py_ssize_t current_size;\r
- PyObject *res, *data = NULL;\r
- PyObject *chunks = PyList_New(0);\r
-\r
- if (chunks == NULL)\r
- return NULL;\r
-\r
- /* First copy what we have in the current buffer. */\r
- current_size = Py_SAFE_DOWNCAST(READAHEAD(self), Py_off_t, Py_ssize_t);\r
- if (current_size) {\r
- data = PyBytes_FromStringAndSize(\r
- self->buffer + self->pos, current_size);\r
- if (data == NULL) {\r
- Py_DECREF(chunks);\r
- return NULL;\r
- }\r
- self->pos += current_size;\r
- }\r
- /* We're going past the buffer's bounds, flush it */\r
- if (self->writable) {\r
- res = buffered_flush_and_rewind_unlocked(self);\r
- if (res == NULL) {\r
- Py_DECREF(chunks);\r
- return NULL;\r
- }\r
- Py_CLEAR(res);\r
- }\r
- _bufferedreader_reset_buf(self);\r
- while (1) {\r
- if (data) {\r
- if (PyList_Append(chunks, data) < 0) {\r
- Py_DECREF(data);\r
- Py_DECREF(chunks);\r
- return NULL;\r
- }\r
- Py_DECREF(data);\r
- }\r
-\r
- /* Read until EOF or until read() would block. */\r
- data = PyObject_CallMethodObjArgs(self->raw, _PyIO_str_read, NULL);\r
- if (data == NULL) {\r
- Py_DECREF(chunks);\r
- return NULL;\r
- }\r
- if (data != Py_None && !PyBytes_Check(data)) {\r
- Py_DECREF(data);\r
- Py_DECREF(chunks);\r
- PyErr_SetString(PyExc_TypeError, "read() should return bytes");\r
- return NULL;\r
- }\r
- if (data == Py_None || PyBytes_GET_SIZE(data) == 0) {\r
- if (current_size == 0) {\r
- Py_DECREF(chunks);\r
- return data;\r
- }\r
- else {\r
- res = _PyBytes_Join(_PyIO_empty_bytes, chunks);\r
- Py_DECREF(data);\r
- Py_DECREF(chunks);\r
- return res;\r
- }\r
- }\r
- current_size += PyBytes_GET_SIZE(data);\r
- if (self->abs_pos != -1)\r
- self->abs_pos += PyBytes_GET_SIZE(data);\r
- }\r
-}\r
-\r
-/* Read n bytes from the buffer if it can, otherwise return None.\r
- This function is simple enough that it can run unlocked. */\r
-static PyObject *\r
-_bufferedreader_read_fast(buffered *self, Py_ssize_t n)\r
-{\r
- Py_ssize_t current_size;\r
-\r
- current_size = Py_SAFE_DOWNCAST(READAHEAD(self), Py_off_t, Py_ssize_t);\r
- if (n <= current_size) {\r
- /* Fast path: the data to read is fully buffered. */\r
- PyObject *res = PyBytes_FromStringAndSize(self->buffer + self->pos, n);\r
- if (res != NULL)\r
- self->pos += n;\r
- return res;\r
- }\r
- Py_RETURN_NONE;\r
-}\r
-\r
-/* Generic read function: read from the stream until enough bytes are read,\r
- * or until an EOF occurs or until read() would block.\r
- */\r
-static PyObject *\r
-_bufferedreader_read_generic(buffered *self, Py_ssize_t n)\r
-{\r
- PyObject *res = NULL;\r
- Py_ssize_t current_size, remaining, written;\r
- char *out;\r
-\r
- current_size = Py_SAFE_DOWNCAST(READAHEAD(self), Py_off_t, Py_ssize_t);\r
- if (n <= current_size)\r
- return _bufferedreader_read_fast(self, n);\r
-\r
- res = PyBytes_FromStringAndSize(NULL, n);\r
- if (res == NULL)\r
- goto error;\r
- out = PyBytes_AS_STRING(res);\r
- remaining = n;\r
- written = 0;\r
- if (current_size > 0) {\r
- memcpy(out, self->buffer + self->pos, current_size);\r
- remaining -= current_size;\r
- written += current_size;\r
- self->pos += current_size;\r
- }\r
- /* Flush the write buffer if necessary */\r
- if (self->writable) {\r
- PyObject *r = buffered_flush_and_rewind_unlocked(self);\r
- if (r == NULL)\r
- goto error;\r
- Py_DECREF(r);\r
- }\r
- _bufferedreader_reset_buf(self);\r
- while (remaining > 0) {\r
- /* We want to read a whole block at the end into buffer.\r
- If we had readv() we could do this in one pass. */\r
- Py_ssize_t r = MINUS_LAST_BLOCK(self, remaining);\r
- if (r == 0)\r
- break;\r
- r = _bufferedreader_raw_read(self, out + written, r);\r
- if (r == -1)\r
- goto error;\r
- if (r == 0 || r == -2) {\r
- /* EOF occurred or read() would block. */\r
- if (r == 0 || written > 0) {\r
- if (_PyBytes_Resize(&res, written))\r
- goto error;\r
- return res;\r
- }\r
- Py_DECREF(res);\r
- Py_INCREF(Py_None);\r
- return Py_None;\r
- }\r
- remaining -= r;\r
- written += r;\r
- }\r
- assert(remaining <= self->buffer_size);\r
- self->pos = 0;\r
- self->raw_pos = 0;\r
- self->read_end = 0;\r
- /* NOTE: when the read is satisfied, we avoid issuing any additional\r
- reads, which could block indefinitely (e.g. on a socket).\r
- See issue #9550. */\r
- while (remaining > 0 && self->read_end < self->buffer_size) {\r
- Py_ssize_t r = _bufferedreader_fill_buffer(self);\r
- if (r == -1)\r
- goto error;\r
- if (r == 0 || r == -2) {\r
- /* EOF occurred or read() would block. */\r
- if (r == 0 || written > 0) {\r
- if (_PyBytes_Resize(&res, written))\r
- goto error;\r
- return res;\r
- }\r
- Py_DECREF(res);\r
- Py_INCREF(Py_None);\r
- return Py_None;\r
- }\r
- if (remaining > r) {\r
- memcpy(out + written, self->buffer + self->pos, r);\r
- written += r;\r
- self->pos += r;\r
- remaining -= r;\r
- }\r
- else if (remaining > 0) {\r
- memcpy(out + written, self->buffer + self->pos, remaining);\r
- written += remaining;\r
- self->pos += remaining;\r
- remaining = 0;\r
- }\r
- if (remaining == 0)\r
- break;\r
- }\r
-\r
- return res;\r
-\r
-error:\r
- Py_XDECREF(res);\r
- return NULL;\r
-}\r
-\r
-static PyObject *\r
-_bufferedreader_peek_unlocked(buffered *self, Py_ssize_t n)\r
-{\r
- Py_ssize_t have, r;\r
-\r
- have = Py_SAFE_DOWNCAST(READAHEAD(self), Py_off_t, Py_ssize_t);\r
- /* Constraints:\r
- 1. we don't want to advance the file position.\r
- 2. we don't want to lose block alignment, so we can't shift the buffer\r
- to make some place.\r
- Therefore, we either return `have` bytes (if > 0), or a full buffer.\r
- */\r
- if (have > 0) {\r
- return PyBytes_FromStringAndSize(self->buffer + self->pos, have);\r
- }\r
-\r
- /* Fill the buffer from the raw stream, and copy it to the result. */\r
- _bufferedreader_reset_buf(self);\r
- r = _bufferedreader_fill_buffer(self);\r
- if (r == -1)\r
- return NULL;\r
- if (r == -2)\r
- r = 0;\r
- self->pos = 0;\r
- return PyBytes_FromStringAndSize(self->buffer, r);\r
-}\r
-\r
-static PyMethodDef bufferedreader_methods[] = {\r
- /* BufferedIOMixin methods */\r
- {"detach", (PyCFunction)buffered_detach, METH_NOARGS},\r
- {"flush", (PyCFunction)buffered_simple_flush, METH_NOARGS},\r
- {"close", (PyCFunction)buffered_close, METH_NOARGS},\r
- {"seekable", (PyCFunction)buffered_seekable, METH_NOARGS},\r
- {"readable", (PyCFunction)buffered_readable, METH_NOARGS},\r
- {"writable", (PyCFunction)buffered_writable, METH_NOARGS},\r
- {"fileno", (PyCFunction)buffered_fileno, METH_NOARGS},\r
- {"isatty", (PyCFunction)buffered_isatty, METH_NOARGS},\r
-\r
- {"read", (PyCFunction)buffered_read, METH_VARARGS},\r
- {"peek", (PyCFunction)buffered_peek, METH_VARARGS},\r
- {"read1", (PyCFunction)buffered_read1, METH_VARARGS},\r
- {"readline", (PyCFunction)buffered_readline, METH_VARARGS},\r
- {"seek", (PyCFunction)buffered_seek, METH_VARARGS},\r
- {"tell", (PyCFunction)buffered_tell, METH_NOARGS},\r
- {"truncate", (PyCFunction)buffered_truncate, METH_VARARGS},\r
- {"__sizeof__", (PyCFunction)buffered_sizeof, METH_NOARGS},\r
- {NULL, NULL}\r
-};\r
-\r
-static PyMemberDef bufferedreader_members[] = {\r
- {"raw", T_OBJECT, offsetof(buffered, raw), READONLY},\r
- {NULL}\r
-};\r
-\r
-static PyGetSetDef bufferedreader_getset[] = {\r
- {"closed", (getter)buffered_closed_get, NULL, NULL},\r
- {"name", (getter)buffered_name_get, NULL, NULL},\r
- {"mode", (getter)buffered_mode_get, NULL, NULL},\r
- {NULL}\r
-};\r
-\r
-\r
-PyTypeObject PyBufferedReader_Type = {\r
- PyVarObject_HEAD_INIT(NULL, 0)\r
- "_io.BufferedReader", /*tp_name*/\r
- sizeof(buffered), /*tp_basicsize*/\r
- 0, /*tp_itemsize*/\r
- (destructor)buffered_dealloc, /*tp_dealloc*/\r
- 0, /*tp_print*/\r
- 0, /*tp_getattr*/\r
- 0, /*tp_setattr*/\r
- 0, /*tp_compare */\r
- (reprfunc)buffered_repr, /*tp_repr*/\r
- 0, /*tp_as_number*/\r
- 0, /*tp_as_sequence*/\r
- 0, /*tp_as_mapping*/\r
- 0, /*tp_hash */\r
- 0, /*tp_call*/\r
- 0, /*tp_str*/\r
- 0, /*tp_getattro*/\r
- 0, /*tp_setattro*/\r
- 0, /*tp_as_buffer*/\r
- Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE\r
- | Py_TPFLAGS_HAVE_GC, /*tp_flags*/\r
- bufferedreader_doc, /* tp_doc */\r
- (traverseproc)buffered_traverse, /* tp_traverse */\r
- (inquiry)buffered_clear, /* tp_clear */\r
- 0, /* tp_richcompare */\r
- offsetof(buffered, weakreflist), /*tp_weaklistoffset*/\r
- 0, /* tp_iter */\r
- (iternextfunc)buffered_iternext, /* tp_iternext */\r
- bufferedreader_methods, /* tp_methods */\r
- bufferedreader_members, /* tp_members */\r
- bufferedreader_getset, /* tp_getset */\r
- 0, /* tp_base */\r
- 0, /* tp_dict */\r
- 0, /* tp_descr_get */\r
- 0, /* tp_descr_set */\r
- offsetof(buffered, dict), /* tp_dictoffset */\r
- (initproc)bufferedreader_init, /* tp_init */\r
- 0, /* tp_alloc */\r
- PyType_GenericNew, /* tp_new */\r
-};\r
-\f\r
-\r
-\r
-static int\r
-complain_about_max_buffer_size(void)\r
-{\r
- if (PyErr_WarnEx(PyExc_DeprecationWarning,\r
- "max_buffer_size is deprecated", 1) < 0)\r
- return 0;\r
- return 1;\r
-}\r
-\r
-/*\r
- * class BufferedWriter\r
- */\r
-PyDoc_STRVAR(bufferedwriter_doc,\r
- "A buffer for a writeable sequential RawIO object.\n"\r
- "\n"\r
- "The constructor creates a BufferedWriter for the given writeable raw\n"\r
- "stream. If the buffer_size is not given, it defaults to\n"\r
- "DEFAULT_BUFFER_SIZE. max_buffer_size isn't used anymore.\n"\r
- );\r
-\r
-static void\r
-_bufferedwriter_reset_buf(buffered *self)\r
-{\r
- self->write_pos = 0;\r
- self->write_end = -1;\r
-}\r
-\r
-static int\r
-bufferedwriter_init(buffered *self, PyObject *args, PyObject *kwds)\r
-{\r
- /* TODO: properly deprecate max_buffer_size */\r
- char *kwlist[] = {"raw", "buffer_size", "max_buffer_size", NULL};\r
- Py_ssize_t buffer_size = DEFAULT_BUFFER_SIZE;\r
- Py_ssize_t max_buffer_size = -234;\r
- PyObject *raw;\r
-\r
- self->ok = 0;\r
- self->detached = 0;\r
-\r
- if (!PyArg_ParseTupleAndKeywords(args, kwds, "O|nn:BufferedWriter", kwlist,\r
- &raw, &buffer_size, &max_buffer_size)) {\r
- return -1;\r
- }\r
-\r
- if (max_buffer_size != -234 && !complain_about_max_buffer_size())\r
- return -1;\r
-\r
- if (_PyIOBase_check_writable(raw, Py_True) == NULL)\r
- return -1;\r
-\r
- Py_CLEAR(self->raw);\r
- Py_INCREF(raw);\r
- self->raw = raw;\r
- self->readable = 0;\r
- self->writable = 1;\r
-\r
- self->buffer_size = buffer_size;\r
- if (_buffered_init(self) < 0)\r
- return -1;\r
- _bufferedwriter_reset_buf(self);\r
- self->pos = 0;\r
-\r
- self->fast_closed_checks = (Py_TYPE(self) == &PyBufferedWriter_Type &&\r
- Py_TYPE(raw) == &PyFileIO_Type);\r
-\r
- self->ok = 1;\r
- return 0;\r
-}\r
-\r
-static Py_ssize_t\r
-_bufferedwriter_raw_write(buffered *self, char *start, Py_ssize_t len)\r
-{\r
- Py_buffer buf;\r
- PyObject *memobj, *res;\r
- Py_ssize_t n;\r
- int errnum;\r
- /* NOTE: the buffer needn't be released as its object is NULL. */\r
- if (PyBuffer_FillInfo(&buf, NULL, start, len, 1, PyBUF_CONTIG_RO) == -1)\r
- return -1;\r
- memobj = PyMemoryView_FromBuffer(&buf);\r
- if (memobj == NULL)\r
- return -1;\r
- /* NOTE: PyErr_SetFromErrno() calls PyErr_CheckSignals() when EINTR\r
- occurs so we needn't do it ourselves.\r
- We then retry writing, ignoring the signal if no handler has\r
- raised (see issue #10956).\r
- */\r
- do {\r
- errno = 0;\r
- res = PyObject_CallMethodObjArgs(self->raw, _PyIO_str_write, memobj, NULL);\r
- errnum = errno;\r
- } while (res == NULL && _PyIO_trap_eintr());\r
- Py_DECREF(memobj);\r
- if (res == NULL)\r
- return -1;\r
- if (res == Py_None) {\r
- /* Non-blocking stream would have blocked. Special return code!\r
- Being paranoid we reset errno in case it is changed by code\r
- triggered by a decref. errno is used by _set_BlockingIOError(). */\r
- Py_DECREF(res);\r
- errno = errnum;\r
- return -2;\r
- }\r
- n = PyNumber_AsSsize_t(res, PyExc_ValueError);\r
- Py_DECREF(res);\r
- if (n < 0 || n > len) {\r
- PyErr_Format(PyExc_IOError,\r
- "raw write() returned invalid length %zd "\r
- "(should have been between 0 and %zd)", n, len);\r
- return -1;\r
- }\r
- if (n > 0 && self->abs_pos != -1)\r
- self->abs_pos += n;\r
- return n;\r
-}\r
-\r
-/* `restore_pos` is 1 if we need to restore the raw stream position at\r
- the end, 0 otherwise. */\r
-static PyObject *\r
-_bufferedwriter_flush_unlocked(buffered *self)\r
-{\r
- Py_ssize_t written = 0;\r
- Py_off_t n, rewind;\r
-\r
- if (!VALID_WRITE_BUFFER(self) || self->write_pos == self->write_end)\r
- goto end;\r
- /* First, rewind */\r
- rewind = RAW_OFFSET(self) + (self->pos - self->write_pos);\r
- if (rewind != 0) {\r
- n = _buffered_raw_seek(self, -rewind, 1);\r
- if (n < 0) {\r
- goto error;\r
- }\r
- self->raw_pos -= rewind;\r
- }\r
- while (self->write_pos < self->write_end) {\r
- n = _bufferedwriter_raw_write(self,\r
- self->buffer + self->write_pos,\r
- Py_SAFE_DOWNCAST(self->write_end - self->write_pos,\r
- Py_off_t, Py_ssize_t));\r
- if (n == -1) {\r
- goto error;\r
- }\r
- else if (n == -2) {\r
- _set_BlockingIOError("write could not complete without blocking",\r
- 0);\r
- goto error;\r
- }\r
- self->write_pos += n;\r
- self->raw_pos = self->write_pos;\r
- written += Py_SAFE_DOWNCAST(n, Py_off_t, Py_ssize_t);\r
- /* Partial writes can return successfully when interrupted by a\r
- signal (see write(2)). We must run signal handlers before\r
- blocking another time, possibly indefinitely. */\r
- if (PyErr_CheckSignals() < 0)\r
- goto error;\r
- }\r
-\r
- _bufferedwriter_reset_buf(self);\r
-\r
-end:\r
- Py_RETURN_NONE;\r
-\r
-error:\r
- return NULL;\r
-}\r
-\r
-static PyObject *\r
-bufferedwriter_write(buffered *self, PyObject *args)\r
-{\r
- PyObject *res = NULL;\r
- Py_buffer buf;\r
- Py_ssize_t written, avail, remaining;\r
- Py_off_t offset;\r
-\r
- CHECK_INITIALIZED(self)\r
- if (!PyArg_ParseTuple(args, "s*:write", &buf)) {\r
- return NULL;\r
- }\r
-\r
- if (IS_CLOSED(self)) {\r
- PyErr_SetString(PyExc_ValueError, "write to closed file");\r
- PyBuffer_Release(&buf);\r
- return NULL;\r
- }\r
-\r
- if (!ENTER_BUFFERED(self)) {\r
- PyBuffer_Release(&buf);\r
- return NULL;\r
- }\r
-\r
- /* Fast path: the data to write can be fully buffered. */\r
- if (!VALID_READ_BUFFER(self) && !VALID_WRITE_BUFFER(self)) {\r
- self->pos = 0;\r
- self->raw_pos = 0;\r
- }\r
- avail = Py_SAFE_DOWNCAST(self->buffer_size - self->pos, Py_off_t, Py_ssize_t);\r
- if (buf.len <= avail) {\r
- memcpy(self->buffer + self->pos, buf.buf, buf.len);\r
- if (!VALID_WRITE_BUFFER(self) || self->write_pos > self->pos) {\r
- self->write_pos = self->pos;\r
- }\r
- ADJUST_POSITION(self, self->pos + buf.len);\r
- if (self->pos > self->write_end)\r
- self->write_end = self->pos;\r
- written = buf.len;\r
- goto end;\r
- }\r
-\r
- /* First write the current buffer */\r
- res = _bufferedwriter_flush_unlocked(self);\r
- if (res == NULL) {\r
- Py_ssize_t *w = _buffered_check_blocking_error();\r
- if (w == NULL)\r
- goto error;\r
- if (self->readable)\r
- _bufferedreader_reset_buf(self);\r
- /* Make some place by shifting the buffer. */\r
- assert(VALID_WRITE_BUFFER(self));\r
- memmove(self->buffer, self->buffer + self->write_pos,\r
- Py_SAFE_DOWNCAST(self->write_end - self->write_pos,\r
- Py_off_t, Py_ssize_t));\r
- self->write_end -= self->write_pos;\r
- self->raw_pos -= self->write_pos;\r
- self->pos -= self->write_pos;\r
- self->write_pos = 0;\r
- avail = Py_SAFE_DOWNCAST(self->buffer_size - self->write_end,\r
- Py_off_t, Py_ssize_t);\r
- if (buf.len <= avail) {\r
- /* Everything can be buffered */\r
- PyErr_Clear();\r
- memcpy(self->buffer + self->write_end, buf.buf, buf.len);\r
- self->write_end += buf.len;\r
- self->pos += buf.len;\r
- written = buf.len;\r
- goto end;\r
- }\r
- /* Buffer as much as possible. */\r
- memcpy(self->buffer + self->write_end, buf.buf, avail);\r
- self->write_end += avail;\r
- self->pos += avail;\r
- /* XXX Modifying the existing exception e using the pointer w\r
- will change e.characters_written but not e.args[2].\r
- Therefore we just replace with a new error. */\r
- _set_BlockingIOError("write could not complete without blocking",\r
- avail);\r
- goto error;\r
- }\r
- Py_CLEAR(res);\r
-\r
- /* Adjust the raw stream position if it is away from the logical stream\r
- position. This happens if the read buffer has been filled but not\r
- modified (and therefore _bufferedwriter_flush_unlocked() didn't rewind\r
- the raw stream by itself).\r
- Fixes issue #6629.\r
- */\r
- offset = RAW_OFFSET(self);\r
- if (offset != 0) {\r
- if (_buffered_raw_seek(self, -offset, 1) < 0)\r
- goto error;\r
- self->raw_pos -= offset;\r
- }\r
-\r
- /* Then write buf itself. At this point the buffer has been emptied. */\r
- remaining = buf.len;\r
- written = 0;\r
- while (remaining > self->buffer_size) {\r
- Py_ssize_t n = _bufferedwriter_raw_write(\r
- self, (char *) buf.buf + written, buf.len - written);\r
- if (n == -1) {\r
- goto error;\r
- } else if (n == -2) {\r
- /* Write failed because raw file is non-blocking */\r
- if (remaining > self->buffer_size) {\r
- /* Can't buffer everything, still buffer as much as possible */\r
- memcpy(self->buffer,\r
- (char *) buf.buf + written, self->buffer_size);\r
- self->raw_pos = 0;\r
- ADJUST_POSITION(self, self->buffer_size);\r
- self->write_end = self->buffer_size;\r
- written += self->buffer_size;\r
- _set_BlockingIOError("write could not complete without "\r
- "blocking", written);\r
- goto error;\r
- }\r
- PyErr_Clear();\r
- break;\r
- }\r
- written += n;\r
- remaining -= n;\r
- /* Partial writes can return successfully when interrupted by a\r
- signal (see write(2)). We must run signal handlers before\r
- blocking another time, possibly indefinitely. */\r
- if (PyErr_CheckSignals() < 0)\r
- goto error;\r
- }\r
- if (self->readable)\r
- _bufferedreader_reset_buf(self);\r
- if (remaining > 0) {\r
- memcpy(self->buffer, (char *) buf.buf + written, remaining);\r
- written += remaining;\r
- }\r
- self->write_pos = 0;\r
- /* TODO: sanity check (remaining >= 0) */\r
- self->write_end = remaining;\r
- ADJUST_POSITION(self, remaining);\r
- self->raw_pos = 0;\r
-\r
-end:\r
- res = PyLong_FromSsize_t(written);\r
-\r
-error:\r
- LEAVE_BUFFERED(self)\r
- PyBuffer_Release(&buf);\r
- return res;\r
-}\r
-\r
-static PyMethodDef bufferedwriter_methods[] = {\r
- /* BufferedIOMixin methods */\r
- {"close", (PyCFunction)buffered_close, METH_NOARGS},\r
- {"detach", (PyCFunction)buffered_detach, METH_NOARGS},\r
- {"seekable", (PyCFunction)buffered_seekable, METH_NOARGS},\r
- {"readable", (PyCFunction)buffered_readable, METH_NOARGS},\r
- {"writable", (PyCFunction)buffered_writable, METH_NOARGS},\r
- {"fileno", (PyCFunction)buffered_fileno, METH_NOARGS},\r
- {"isatty", (PyCFunction)buffered_isatty, METH_NOARGS},\r
-\r
- {"write", (PyCFunction)bufferedwriter_write, METH_VARARGS},\r
- {"truncate", (PyCFunction)buffered_truncate, METH_VARARGS},\r
- {"flush", (PyCFunction)buffered_flush, METH_NOARGS},\r
- {"seek", (PyCFunction)buffered_seek, METH_VARARGS},\r
- {"tell", (PyCFunction)buffered_tell, METH_NOARGS},\r
- {"__sizeof__", (PyCFunction)buffered_sizeof, METH_NOARGS},\r
- {NULL, NULL}\r
-};\r
-\r
-static PyMemberDef bufferedwriter_members[] = {\r
- {"raw", T_OBJECT, offsetof(buffered, raw), READONLY},\r
- {NULL}\r
-};\r
-\r
-static PyGetSetDef bufferedwriter_getset[] = {\r
- {"closed", (getter)buffered_closed_get, NULL, NULL},\r
- {"name", (getter)buffered_name_get, NULL, NULL},\r
- {"mode", (getter)buffered_mode_get, NULL, NULL},\r
- {NULL}\r
-};\r
-\r
-\r
-PyTypeObject PyBufferedWriter_Type = {\r
- PyVarObject_HEAD_INIT(NULL, 0)\r
- "_io.BufferedWriter", /*tp_name*/\r
- sizeof(buffered), /*tp_basicsize*/\r
- 0, /*tp_itemsize*/\r
- (destructor)buffered_dealloc, /*tp_dealloc*/\r
- 0, /*tp_print*/\r
- 0, /*tp_getattr*/\r
- 0, /*tp_setattr*/\r
- 0, /*tp_compare */\r
- (reprfunc)buffered_repr, /*tp_repr*/\r
- 0, /*tp_as_number*/\r
- 0, /*tp_as_sequence*/\r
- 0, /*tp_as_mapping*/\r
- 0, /*tp_hash */\r
- 0, /*tp_call*/\r
- 0, /*tp_str*/\r
- 0, /*tp_getattro*/\r
- 0, /*tp_setattro*/\r
- 0, /*tp_as_buffer*/\r
- Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE\r
- | Py_TPFLAGS_HAVE_GC, /*tp_flags*/\r
- bufferedwriter_doc, /* tp_doc */\r
- (traverseproc)buffered_traverse, /* tp_traverse */\r
- (inquiry)buffered_clear, /* tp_clear */\r
- 0, /* tp_richcompare */\r
- offsetof(buffered, weakreflist), /*tp_weaklistoffset*/\r
- 0, /* tp_iter */\r
- 0, /* tp_iternext */\r
- bufferedwriter_methods, /* tp_methods */\r
- bufferedwriter_members, /* tp_members */\r
- bufferedwriter_getset, /* tp_getset */\r
- 0, /* tp_base */\r
- 0, /* tp_dict */\r
- 0, /* tp_descr_get */\r
- 0, /* tp_descr_set */\r
- offsetof(buffered, dict), /* tp_dictoffset */\r
- (initproc)bufferedwriter_init, /* tp_init */\r
- 0, /* tp_alloc */\r
- PyType_GenericNew, /* tp_new */\r
-};\r
-\f\r
-\r
-\r
-/*\r
- * BufferedRWPair\r
- */\r
-\r
-PyDoc_STRVAR(bufferedrwpair_doc,\r
- "A buffered reader and writer object together.\n"\r
- "\n"\r
- "A buffered reader object and buffered writer object put together to\n"\r
- "form a sequential IO object that can read and write. This is typically\n"\r
- "used with a socket or two-way pipe.\n"\r
- "\n"\r
- "reader and writer are RawIOBase objects that are readable and\n"\r
- "writeable respectively. If the buffer_size is omitted it defaults to\n"\r
- "DEFAULT_BUFFER_SIZE.\n"\r
- );\r
-\r
-/* XXX The usefulness of this (compared to having two separate IO objects) is\r
- * questionable.\r
- */\r
-\r
-typedef struct {\r
- PyObject_HEAD\r
- buffered *reader;\r
- buffered *writer;\r
- PyObject *dict;\r
- PyObject *weakreflist;\r
-} rwpair;\r
-\r
-static int\r
-bufferedrwpair_init(rwpair *self, PyObject *args, PyObject *kwds)\r
-{\r
- PyObject *reader, *writer;\r
- Py_ssize_t buffer_size = DEFAULT_BUFFER_SIZE;\r
- Py_ssize_t max_buffer_size = -234;\r
-\r
- if (!PyArg_ParseTuple(args, "OO|nn:BufferedRWPair", &reader, &writer,\r
- &buffer_size, &max_buffer_size)) {\r
- return -1;\r
- }\r
-\r
- if (max_buffer_size != -234 && !complain_about_max_buffer_size())\r
- return -1;\r
-\r
- if (_PyIOBase_check_readable(reader, Py_True) == NULL)\r
- return -1;\r
- if (_PyIOBase_check_writable(writer, Py_True) == NULL)\r
- return -1;\r
-\r
- self->reader = (buffered *) PyObject_CallFunction(\r
- (PyObject *) &PyBufferedReader_Type, "On", reader, buffer_size);\r
- if (self->reader == NULL)\r
- return -1;\r
-\r
- self->writer = (buffered *) PyObject_CallFunction(\r
- (PyObject *) &PyBufferedWriter_Type, "On", writer, buffer_size);\r
- if (self->writer == NULL) {\r
- Py_CLEAR(self->reader);\r
- return -1;\r
- }\r
-\r
- return 0;\r
-}\r
-\r
-static int\r
-bufferedrwpair_traverse(rwpair *self, visitproc visit, void *arg)\r
-{\r
- Py_VISIT(self->dict);\r
- return 0;\r
-}\r
-\r
-static int\r
-bufferedrwpair_clear(rwpair *self)\r
-{\r
- Py_CLEAR(self->reader);\r
- Py_CLEAR(self->writer);\r
- Py_CLEAR(self->dict);\r
- return 0;\r
-}\r
-\r
-static void\r
-bufferedrwpair_dealloc(rwpair *self)\r
-{\r
- _PyObject_GC_UNTRACK(self);\r
- if (self->weakreflist != NULL)\r
- PyObject_ClearWeakRefs((PyObject *)self);\r
- Py_CLEAR(self->reader);\r
- Py_CLEAR(self->writer);\r
- Py_CLEAR(self->dict);\r
- Py_TYPE(self)->tp_free((PyObject *) self);\r
-}\r
-\r
-static PyObject *\r
-_forward_call(buffered *self, const char *name, PyObject *args)\r
-{\r
- PyObject *func, *ret;\r
- if (self == NULL) {\r
- PyErr_SetString(PyExc_ValueError,\r
- "I/O operation on uninitialized object");\r
- return NULL;\r
- }\r
-\r
- func = PyObject_GetAttrString((PyObject *)self, name);\r
- if (func == NULL) {\r
- PyErr_SetString(PyExc_AttributeError, name);\r
- return NULL;\r
- }\r
-\r
- ret = PyObject_CallObject(func, args);\r
- Py_DECREF(func);\r
- return ret;\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_read(rwpair *self, PyObject *args)\r
-{\r
- return _forward_call(self->reader, "read", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_peek(rwpair *self, PyObject *args)\r
-{\r
- return _forward_call(self->reader, "peek", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_read1(rwpair *self, PyObject *args)\r
-{\r
- return _forward_call(self->reader, "read1", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_readinto(rwpair *self, PyObject *args)\r
-{\r
- return _forward_call(self->reader, "readinto", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_write(rwpair *self, PyObject *args)\r
-{\r
- return _forward_call(self->writer, "write", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_flush(rwpair *self, PyObject *args)\r
-{\r
- return _forward_call(self->writer, "flush", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_readable(rwpair *self, PyObject *args)\r
-{\r
- return _forward_call(self->reader, "readable", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_writable(rwpair *self, PyObject *args)\r
-{\r
- return _forward_call(self->writer, "writable", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_close(rwpair *self, PyObject *args)\r
-{\r
- PyObject *exc = NULL, *val, *tb;\r
- PyObject *ret = _forward_call(self->writer, "close", args);\r
- if (ret == NULL)\r
- PyErr_Fetch(&exc, &val, &tb);\r
- else\r
- Py_DECREF(ret);\r
- ret = _forward_call(self->reader, "close", args);\r
- if (exc != NULL) {\r
- if (ret != NULL) {\r
- Py_CLEAR(ret);\r
- PyErr_Restore(exc, val, tb);\r
- }\r
- else {\r
- Py_DECREF(exc);\r
- Py_XDECREF(val);\r
- Py_XDECREF(tb);\r
- }\r
- }\r
- return ret;\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_isatty(rwpair *self, PyObject *args)\r
-{\r
- PyObject *ret = _forward_call(self->writer, "isatty", args);\r
-\r
- if (ret != Py_False) {\r
- /* either True or exception */\r
- return ret;\r
- }\r
- Py_DECREF(ret);\r
-\r
- return _forward_call(self->reader, "isatty", args);\r
-}\r
-\r
-static PyObject *\r
-bufferedrwpair_closed_get(rwpair *self, void *context)\r
-{\r
- if (self->writer == NULL) {\r
- PyErr_SetString(PyExc_RuntimeError,\r
- "the BufferedRWPair object is being garbage-collected");\r
- return NULL;\r
- }\r
- return PyObject_GetAttr((PyObject *) self->writer, _PyIO_str_closed);\r
-}\r
-\r
-static PyMethodDef bufferedrwpair_methods[] = {\r
- {"read", (PyCFunction)bufferedrwpair_read, METH_VARARGS},\r
- {"peek", (PyCFunction)bufferedrwpair_peek, METH_VARARGS},\r
- {"read1", (PyCFunction)bufferedrwpair_read1, METH_VARARGS},\r
- {"readinto", (PyCFunction)bufferedrwpair_readinto, METH_VARARGS},\r
-\r
- {"write", (PyCFunction)bufferedrwpair_write, METH_VARARGS},\r
- {"flush", (PyCFunction)bufferedrwpair_flush, METH_NOARGS},\r
-\r
- {"readable", (PyCFunction)bufferedrwpair_readable, METH_NOARGS},\r
- {"writable", (PyCFunction)bufferedrwpair_writable, METH_NOARGS},\r
-\r
- {"close", (PyCFunction)bufferedrwpair_close, METH_NOARGS},\r
- {"isatty", (PyCFunction)bufferedrwpair_isatty, METH_NOARGS},\r
-\r
- {NULL, NULL}\r
-};\r
-\r
-static PyGetSetDef bufferedrwpair_getset[] = {\r
- {"closed", (getter)bufferedrwpair_closed_get, NULL, NULL},\r
- {NULL}\r
-};\r
-\r
-PyTypeObject PyBufferedRWPair_Type = {\r
- PyVarObject_HEAD_INIT(NULL, 0)\r
- "_io.BufferedRWPair", /*tp_name*/\r
- sizeof(rwpair), /*tp_basicsize*/\r
- 0, /*tp_itemsize*/\r
- (destructor)bufferedrwpair_dealloc, /*tp_dealloc*/\r
- 0, /*tp_print*/\r
- 0, /*tp_getattr*/\r
- 0, /*tp_setattr*/\r
- 0, /*tp_compare */\r
- 0, /*tp_repr*/\r
- 0, /*tp_as_number*/\r
- 0, /*tp_as_sequence*/\r
- 0, /*tp_as_mapping*/\r
- 0, /*tp_hash */\r
- 0, /*tp_call*/\r
- 0, /*tp_str*/\r
- 0, /*tp_getattro*/\r
- 0, /*tp_setattro*/\r
- 0, /*tp_as_buffer*/\r
- Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE\r
- | Py_TPFLAGS_HAVE_GC, /* tp_flags */\r
- bufferedrwpair_doc, /* tp_doc */\r
- (traverseproc)bufferedrwpair_traverse, /* tp_traverse */\r
- (inquiry)bufferedrwpair_clear, /* tp_clear */\r
- 0, /* tp_richcompare */\r
- offsetof(rwpair, weakreflist), /*tp_weaklistoffset*/\r
- 0, /* tp_iter */\r
- 0, /* tp_iternext */\r
- bufferedrwpair_methods, /* tp_methods */\r
- 0, /* tp_members */\r
- bufferedrwpair_getset, /* tp_getset */\r
- 0, /* tp_base */\r
- 0, /* tp_dict */\r
- 0, /* tp_descr_get */\r
- 0, /* tp_descr_set */\r
- offsetof(rwpair, dict), /* tp_dictoffset */\r
- (initproc)bufferedrwpair_init, /* tp_init */\r
- 0, /* tp_alloc */\r
- PyType_GenericNew, /* tp_new */\r
-};\r
-\f\r
-\r
-\r
-/*\r
- * BufferedRandom\r
- */\r
-\r
-PyDoc_STRVAR(bufferedrandom_doc,\r
- "A buffered interface to random access streams.\n"\r
- "\n"\r
- "The constructor creates a reader and writer for a seekable stream,\n"\r
- "raw, given in the first argument. If the buffer_size is omitted it\n"\r
- "defaults to DEFAULT_BUFFER_SIZE. max_buffer_size isn't used anymore.\n"\r
- );\r
-\r
-static int\r
-bufferedrandom_init(buffered *self, PyObject *args, PyObject *kwds)\r
-{\r
- char *kwlist[] = {"raw", "buffer_size", "max_buffer_size", NULL};\r
- Py_ssize_t buffer_size = DEFAULT_BUFFER_SIZE;\r
- Py_ssize_t max_buffer_size = -234;\r
- PyObject *raw;\r
-\r
- self->ok = 0;\r
- self->detached = 0;\r
-\r
- if (!PyArg_ParseTupleAndKeywords(args, kwds, "O|nn:BufferedRandom", kwlist,\r
- &raw, &buffer_size, &max_buffer_size)) {\r
- return -1;\r
- }\r
-\r
- if (max_buffer_size != -234 && !complain_about_max_buffer_size())\r
- return -1;\r
-\r
- if (_PyIOBase_check_seekable(raw, Py_True) == NULL)\r
- return -1;\r
- if (_PyIOBase_check_readable(raw, Py_True) == NULL)\r
- return -1;\r
- if (_PyIOBase_check_writable(raw, Py_True) == NULL)\r
- return -1;\r
-\r
- Py_CLEAR(self->raw);\r
- Py_INCREF(raw);\r
- self->raw = raw;\r
- self->buffer_size = buffer_size;\r
- self->readable = 1;\r
- self->writable = 1;\r
-\r
- if (_buffered_init(self) < 0)\r
- return -1;\r
- _bufferedreader_reset_buf(self);\r
- _bufferedwriter_reset_buf(self);\r
- self->pos = 0;\r
-\r
- self->fast_closed_checks = (Py_TYPE(self) == &PyBufferedRandom_Type &&\r
- Py_TYPE(raw) == &PyFileIO_Type);\r
-\r
- self->ok = 1;\r
- return 0;\r
-}\r
-\r
-static PyMethodDef bufferedrandom_methods[] = {\r
- /* BufferedIOMixin methods */\r
- {"close", (PyCFunction)buffered_close, METH_NOARGS},\r
- {"detach", (PyCFunction)buffered_detach, METH_NOARGS},\r
- {"seekable", (PyCFunction)buffered_seekable, METH_NOARGS},\r
- {"readable", (PyCFunction)buffered_readable, METH_NOARGS},\r
- {"writable", (PyCFunction)buffered_writable, METH_NOARGS},\r
- {"fileno", (PyCFunction)buffered_fileno, METH_NOARGS},\r
- {"isatty", (PyCFunction)buffered_isatty, METH_NOARGS},\r
-\r
- {"flush", (PyCFunction)buffered_flush, METH_NOARGS},\r
-\r
- {"seek", (PyCFunction)buffered_seek, METH_VARARGS},\r
- {"tell", (PyCFunction)buffered_tell, METH_NOARGS},\r
- {"truncate", (PyCFunction)buffered_truncate, METH_VARARGS},\r
- {"read", (PyCFunction)buffered_read, METH_VARARGS},\r
- {"read1", (PyCFunction)buffered_read1, METH_VARARGS},\r
- {"readinto", (PyCFunction)buffered_readinto, METH_VARARGS},\r
- {"readline", (PyCFunction)buffered_readline, METH_VARARGS},\r
- {"peek", (PyCFunction)buffered_peek, METH_VARARGS},\r
- {"write", (PyCFunction)bufferedwriter_write, METH_VARARGS},\r
- {"__sizeof__", (PyCFunction)buffered_sizeof, METH_NOARGS},\r
- {NULL, NULL}\r
-};\r
-\r
-static PyMemberDef bufferedrandom_members[] = {\r
- {"raw", T_OBJECT, offsetof(buffered, raw), READONLY},\r
- {NULL}\r
-};\r
-\r
-static PyGetSetDef bufferedrandom_getset[] = {\r
- {"closed", (getter)buffered_closed_get, NULL, NULL},\r
- {"name", (getter)buffered_name_get, NULL, NULL},\r
- {"mode", (getter)buffered_mode_get, NULL, NULL},\r
- {NULL}\r
-};\r
-\r
-\r
-PyTypeObject PyBufferedRandom_Type = {\r
- PyVarObject_HEAD_INIT(NULL, 0)\r
- "_io.BufferedRandom", /*tp_name*/\r
- sizeof(buffered), /*tp_basicsize*/\r
- 0, /*tp_itemsize*/\r
- (destructor)buffered_dealloc, /*tp_dealloc*/\r
- 0, /*tp_print*/\r
- 0, /*tp_getattr*/\r
- 0, /*tp_setattr*/\r
- 0, /*tp_compare */\r
- (reprfunc)buffered_repr, /*tp_repr*/\r
- 0, /*tp_as_number*/\r
- 0, /*tp_as_sequence*/\r
- 0, /*tp_as_mapping*/\r
- 0, /*tp_hash */\r
- 0, /*tp_call*/\r
- 0, /*tp_str*/\r
- 0, /*tp_getattro*/\r
- 0, /*tp_setattro*/\r
- 0, /*tp_as_buffer*/\r
- Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE\r
- | Py_TPFLAGS_HAVE_GC, /*tp_flags*/\r
- bufferedrandom_doc, /* tp_doc */\r
- (traverseproc)buffered_traverse, /* tp_traverse */\r
- (inquiry)buffered_clear, /* tp_clear */\r
- 0, /* tp_richcompare */\r
- offsetof(buffered, weakreflist), /*tp_weaklistoffset*/\r
- 0, /* tp_iter */\r
- (iternextfunc)buffered_iternext, /* tp_iternext */\r
- bufferedrandom_methods, /* tp_methods */\r
- bufferedrandom_members, /* tp_members */\r
- bufferedrandom_getset, /* tp_getset */\r
- 0, /* tp_base */\r
- 0, /*tp_dict*/\r
- 0, /* tp_descr_get */\r
- 0, /* tp_descr_set */\r
- offsetof(buffered, dict), /*tp_dictoffset*/\r
- (initproc)bufferedrandom_init, /* tp_init */\r
- 0, /* tp_alloc */\r
- PyType_GenericNew, /* tp_new */\r
-};\r
-\r
projects / mirror_edk2.git / blobdiff