--- a/contrib/python-zstandard/c-ext/decompressionreader.c Tue Sep 25 20:55:03 2018 +0900
+++ b/contrib/python-zstandard/c-ext/decompressionreader.c Mon Oct 08 16:27:40 2018 -0700
@@ -47,10 +47,6 @@
return NULL;
}
- if (ensure_dctx(self->decompressor, 1)) {
- return NULL;
- }
-
self->entered = 1;
Py_INCREF(self);
@@ -98,15 +94,6 @@
Py_RETURN_NONE;
}
-static PyObject* reader_closed(ZstdDecompressionReader* self) {
- if (self->closed) {
- Py_RETURN_TRUE;
- }
- else {
- Py_RETURN_FALSE;
- }
-}
-
static PyObject* reader_flush(PyObject* self) {
Py_RETURN_NONE;
}
@@ -128,11 +115,6 @@
ZSTD_outBuffer output;
size_t zresult;
- if (!self->entered) {
- PyErr_SetString(ZstdError, "read() must be called from an active context manager");
- return NULL;
- }
-
if (self->closed) {
PyErr_SetString(PyExc_ValueError, "stream is closed");
return NULL;
@@ -281,11 +263,6 @@
unsigned long long readAmount = 0;
size_t defaultOutSize = ZSTD_DStreamOutSize();
- if (!self->entered) {
- PyErr_SetString(ZstdError, "seek() must be called from an active context manager");
- return NULL;
- }
-
if (self->closed) {
PyErr_SetString(PyExc_ValueError, "stream is closed");
return NULL;
@@ -384,8 +361,6 @@
PyDoc_STR("Exit a compression context") },
{ "close", (PyCFunction)reader_close, METH_NOARGS,
PyDoc_STR("Close the stream so it cannot perform any more operations") },
- { "closed", (PyCFunction)reader_closed, METH_NOARGS,
- PyDoc_STR("Whether stream is closed") },
{ "flush", (PyCFunction)reader_flush, METH_NOARGS, PyDoc_STR("no-ops") },
{ "isatty", (PyCFunction)reader_isatty, METH_NOARGS, PyDoc_STR("Returns False") },
{ "readable", (PyCFunction)reader_readable, METH_NOARGS,
@@ -407,6 +382,12 @@
{ NULL, NULL }
};
+static PyMemberDef reader_members[] = {
+ { "closed", T_BOOL, offsetof(ZstdDecompressionReader, closed),
+ READONLY, "whether stream is closed" },
+ { NULL }
+};
+
PyTypeObject ZstdDecompressionReaderType = {
PyVarObject_HEAD_INIT(NULL, 0)
"zstd.ZstdDecompressionReader", /* tp_name */
@@ -436,7 +417,7 @@
reader_iter, /* tp_iter */
reader_iternext, /* tp_iternext */
reader_methods, /* tp_methods */
- 0, /* tp_members */
+ reader_members, /* tp_members */
0, /* tp_getset */
0, /* tp_base */
0, /* tp_dict */