1 files changed, 10 insertions, 7 deletions
diff --git a/src/network/access/qhttpnetworkreply.cpp b/src/network/access/qhttpnetworkreply.cpp
index cd843ab..eb8ecb5 100644
--- a/src/network/access/qhttpnetworkreply.cpp
+++ b/src/network/access/qhttpnetworkreply.cpp
@@ -418,20 +418,26 @@ qint64 QHttpNetworkReplyPrivate::readStatus(QAbstractSocket *socket)
             }
             bool ok = parseStatus(fragment);
             state = ReadingHeaderState;
-            fragment.clear(); // next fragment
-
-            if (!ok)
+            fragment.clear();
+            if (!ok) {
                 return -1;
+            }
             break;
         } else {
             c = 0;
-            bytes += socket->read(&c, 1);
+            int haveRead = socket->read(&c, 1);
+            if (haveRead == -1)
+                return -1;
+            bytes += haveRead;
             fragment.append(c);
         }
 
         // is this a valid reply?
         if (fragment.length() >= 5 && !fragment.startsWith("HTTP/"))
+        {
+            fragment.clear();
             return -1;
+        }
 
     }
 
@@ -568,7 +574,6 @@ qint64 QHttpNetworkReplyPrivate::readBodyFast(QAbstractSocket *socket, QByteData
 
     if (contentRead + haveRead == bodyLength) {
         state = AllDoneState;
-        socket->readAll(); // Read the rest to clean (CRLF) ### will break pipelining
     }
 
     contentRead += haveRead;
@@ -588,8 +593,6 @@ qint64 QHttpNetworkReplyPrivate::readBody(QAbstractSocket *socket, QByteDataBuff
     } else {
         bytes += readReplyBodyRaw(socket, out, socket->bytesAvailable());
     }
-    if (state == AllDoneState)
-        socket->readAll(); // Read the rest to clean (CRLF) ### will break pipelining
     contentRead += bytes;
     return bytes;
 }