--- a/contrib/python-zstandard/c-ext/decompressobj.c Thu Apr 04 15:24:03 2019 -0700
+++ b/contrib/python-zstandard/c-ext/decompressobj.c Thu Apr 04 17:34:43 2019 -0700
@@ -75,7 +75,7 @@
while (1) {
Py_BEGIN_ALLOW_THREADS
- zresult = ZSTD_decompress_generic(self->decompressor->dctx, &output, &input);
+ zresult = ZSTD_decompressStream(self->decompressor->dctx, &output, &input);
Py_END_ALLOW_THREADS
if (ZSTD_isError(zresult)) {
@@ -130,9 +130,26 @@
return result;
}
+static PyObject* DecompressionObj_flush(ZstdDecompressionObj* self, PyObject* args, PyObject* kwargs) {
+ static char* kwlist[] = {
+ "length",
+ NULL
+ };
+
+ PyObject* length = NULL;
+
+ if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|O:flush", kwlist, &length)) {
+ return NULL;
+ }
+
+ Py_RETURN_NONE;
+}
+
static PyMethodDef DecompressionObj_methods[] = {
{ "decompress", (PyCFunction)DecompressionObj_decompress,
METH_VARARGS | METH_KEYWORDS, PyDoc_STR("decompress data") },
+ { "flush", (PyCFunction)DecompressionObj_flush,
+ METH_VARARGS | METH_KEYWORDS, PyDoc_STR("no-op") },
{ NULL, NULL }
};