Debug in libpyfcgi.IoIn.read() method

read buffer was dropped

src/python_ioin.c

@@ -295,7 +295,7 @@ PyObject* pyfcgi_ioin_read(PyObject *self, PyObject **argv, Py_ssize_t argc)
 {
 	size_t left, sz, max;
 	long l;
-	int read_n, toread;
+	int read_n, toread, ret;
 	PyObject *res, *read_str;
 	char *buff;
 
@@ -333,26 +333,33 @@ PyObject* pyfcgi_ioin_read(PyObject *self, PyObject **argv, Py_ssize_t argc)
 	{
 		Py_RETURN_NONE;
 	}
+	Py_INCREF(res);
 	while((max && left) || !max)
 	{
 		toread = (max&&((size_t)read_n > left))?(int)left:read_n;
-		if(FCGX_GetStr(buff, toread, *((IoIn*)self)->in_stream) < toread)
-		{
-			((IoIn*)self)->eof = 1;
-			break;
-		}
+		ret = FCGX_GetStr(buff, toread, *((IoIn*)self)->in_stream);
+
 		sz = strlen(buff);
-		left -= sz;
-		if(!(read_str = IoIn__FromBuff(self)))
+		if(sz)
 		{
-			Py_RETURN_NONE;
+			left -= sz;
+			if(!(read_str = IoIn__FromBuff(self)))
+			{
+				Py_RETURN_NONE;
+			}
+			Py_INCREF(read_str);
+			if(!(res = IoIn__Concat(self, res, read_str)))
+			{
+				Py_RETURN_NONE;
+			}
+			Py_INCREF(res);
 		}
-		Py_INCREF(read_str);
-		if(!(res = IoIn__Concat(self, res, read_str)))
+
+		if( ret < toread)
 		{
-			Py_RETURN_NONE;
+			((IoIn*)self)->eof = 1;
+			break;
 		}
-		Py_INCREF(res);
 	}
 	Py_DECREF(res);
 	return res;