Skip to content

Commit

Permalink
bpo-31718: Fix io.IncrementalNewlineDecoder SystemErrors and segfaults (
Browse files Browse the repository at this point in the history
python#18640)

Co-authored-by: Oren Milman <orenmn@gmail.com>
Co-authored-by: Kumar Aditya <59607654+kumaraditya303@users.noreply.github.com>
  • Loading branch information
3 people committed Nov 28, 2022
1 parent 492dc02 commit 53eef27
Show file tree
Hide file tree
Showing 3 changed files with 32 additions and 9 deletions.
10 changes: 9 additions & 1 deletion Lib/test/test_io.py
Expand Up @@ -3945,7 +3945,15 @@ def test_translate(self):
self.assertEqual(decoder.decode(b"\r\r\n"), "\r\r\n")

class CIncrementalNewlineDecoderTest(IncrementalNewlineDecoderTest):
pass
@support.cpython_only
def test_uninitialized(self):
uninitialized = self.IncrementalNewlineDecoder.__new__(
self.IncrementalNewlineDecoder)
self.assertRaises(ValueError, uninitialized.decode, b'bar')
self.assertRaises(ValueError, uninitialized.getstate)
self.assertRaises(ValueError, uninitialized.setstate, (b'foo', 0))
self.assertRaises(ValueError, uninitialized.reset)


class PyIncrementalNewlineDecoderTest(IncrementalNewlineDecoderTest):
pass
Expand Down
@@ -0,0 +1,3 @@
Raise :exc:`ValueError` instead of :exc:`SystemError` when methods of
uninitialized :class:`io.IncrementalNewlineDecoder` objects are called.
Patch by Oren Milman.
28 changes: 20 additions & 8 deletions Modules/_io/textio.c
Expand Up @@ -231,15 +231,16 @@ _io_IncrementalNewlineDecoder___init___impl(nldecoder_object *self,
PyObject *errors)
/*[clinic end generated code: output=fbd04d443e764ec2 input=89db6b19c6b126bf]*/
{
self->decoder = Py_NewRef(decoder);

if (errors == NULL) {
self->errors = Py_NewRef(&_Py_ID(strict));
errors = Py_NewRef(&_Py_ID(strict));
}
else {
self->errors = Py_NewRef(errors);
errors = Py_NewRef(errors);
}

Py_XSETREF(self->errors, errors);
Py_XSETREF(self->decoder, Py_NewRef(decoder));
self->translate = translate ? 1 : 0;
self->seennl = 0;
self->pendingcr = 0;
Expand Down Expand Up @@ -274,6 +275,13 @@ check_decoded(PyObject *decoded)
return 0;
}

#define CHECK_INITIALIZED_DECODER(self) \
if (self->errors == NULL) { \
PyErr_SetString(PyExc_ValueError, \
"IncrementalNewlineDecoder.__init__() not called"); \
return NULL; \
}

#define SEEN_CR 1
#define SEEN_LF 2
#define SEEN_CRLF 4
Expand All @@ -287,11 +295,7 @@ _PyIncrementalNewlineDecoder_decode(PyObject *myself,
Py_ssize_t output_len;
nldecoder_object *self = (nldecoder_object *) myself;

if (self->decoder == NULL) {
PyErr_SetString(PyExc_ValueError,
"IncrementalNewlineDecoder.__init__ not called");
return NULL;
}
CHECK_INITIALIZED_DECODER(self);

/* decode input (with the eventual \r from a previous pass) */
if (self->decoder != Py_None) {
Expand Down Expand Up @@ -502,6 +506,8 @@ _io_IncrementalNewlineDecoder_getstate_impl(nldecoder_object *self)
PyObject *buffer;
unsigned long long flag;

CHECK_INITIALIZED_DECODER(self);

if (self->decoder != Py_None) {
PyObject *state = PyObject_CallMethodNoArgs(self->decoder,
&_Py_ID(getstate));
Expand Down Expand Up @@ -546,6 +552,8 @@ _io_IncrementalNewlineDecoder_setstate(nldecoder_object *self,
PyObject *buffer;
unsigned long long flag;

CHECK_INITIALIZED_DECODER(self);

if (!PyTuple_Check(state)) {
PyErr_SetString(PyExc_TypeError, "state argument must be a tuple");
return NULL;
Expand Down Expand Up @@ -576,6 +584,8 @@ static PyObject *
_io_IncrementalNewlineDecoder_reset_impl(nldecoder_object *self)
/*[clinic end generated code: output=32fa40c7462aa8ff input=728678ddaea776df]*/
{
CHECK_INITIALIZED_DECODER(self);

self->seennl = 0;
self->pendingcr = 0;
if (self->decoder != Py_None)
Expand All @@ -587,6 +597,8 @@ _io_IncrementalNewlineDecoder_reset_impl(nldecoder_object *self)
static PyObject *
incrementalnewlinedecoder_newlines_get(nldecoder_object *self, void *context)
{
CHECK_INITIALIZED_DECODER(self);

switch (self->seennl) {
case SEEN_CR:
return PyUnicode_FromString("\r");
Expand Down

0 comments on commit 53eef27

Please sign in to comment.