talksik/uWebSockets
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix "last" onData flag of HttpParser

Browse Source
This commit is contained in:
Alex Hultman
2019-01-08 06:34:59 +01:00
parent 614d02e462
commit d8aeb0d312
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/HttpParser.h
+3 -3
View File
@@ -162,7 +162,7 @@ private:
if (!CONSUME_MINIMALLY) { if (!CONSUME_MINIMALLY) {
int emittable = std::min(remainingStreamingBytes, length); int emittable = std::min(remainingStreamingBytes, length);
dataHandler(user, std::string_view(data, emittable), length == remainingStreamingBytes); dataHandler(user, std::string_view(data, emittable), emittable == remainingStreamingBytes);
remainingStreamingBytes -= emittable; remainingStreamingBytes -= emittable;
data += emittable; data += emittable;
@@ -189,7 +189,7 @@ public:
// this is exactly the same as below! // this is exactly the same as below!
if (remainingStreamingBytes >= length) { if (remainingStreamingBytes >= length) {
void *returnedUser = dataHandler(user, std::string_view(data, length), false); void *returnedUser = dataHandler(user, std::string_view(data, length), remainingStreamingBytes == length);
remainingStreamingBytes -= length; remainingStreamingBytes -= length;
return returnedUser; return returnedUser;
} else { } else {
@@ -229,7 +229,7 @@ public:
if (remainingStreamingBytes) { if (remainingStreamingBytes) {
// this is exactly the same as above! // this is exactly the same as above!
if (remainingStreamingBytes >= length) { if (remainingStreamingBytes >= length) {
void *returnedUser = dataHandler(user, std::string_view(data, length), false); void *returnedUser = dataHandler(user, std::string_view(data, length), remainingStreamingBytes == length);
remainingStreamingBytes -= length; remainingStreamingBytes -= length;
return returnedUser; return returnedUser;
} else { } else {