Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Issue #6728 - QUIC and HTTP/3 

- Fixed computation of the last flag.

Signed-off-by: Simone Bordet <simone.bordet@gmail.com>
This commit is contained in:
Simone Bordet 2021-09-29 22:24:52 +02:00
parent 06ffd014f9
commit d3cc08c30c
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
jetty-http3/http3-common/src/main/java/org/eclipse/jetty/http3/internal/parser/HeadersBodyParser.java
View File

@ -99,7 +99,11 @@ public class HeadersBodyParser extends BodyParser
byteBuffers.clear();
}
return decode(encoded) ? Result.WHOLE_FRAME : Result.NO_FRAME;
// If the buffer contains another frame that
// needs to be parsed, then it's not the last frame.
boolean last = isLast.getAsBoolean() && !buffer.hasRemaining();
return decode(encoded, last) ? Result.WHOLE_FRAME : Result.NO_FRAME;
}
}
default:
@ -111,11 +115,11 @@ public class HeadersBodyParser extends BodyParser
return Result.NO_FRAME;
}
private boolean decode(ByteBuffer encoded)
private boolean decode(ByteBuffer encoded, boolean last)
{
try
{
return decoder.decode(streamId, encoded, (streamId, metaData) -> onHeaders(metaData));
return decoder.decode(streamId, encoded, (streamId, metaData) -> onHeaders(metaData, last));
}
catch (QpackException.StreamException x)
{
@ -138,9 +142,9 @@ public class HeadersBodyParser extends BodyParser
return false;
}
private void onHeaders(MetaData metaData)
private void onHeaders(MetaData metaData, boolean last)
{
HeadersFrame frame = new HeadersFrame(metaData, isLast.getAsBoolean());
HeadersFrame frame = new HeadersFrame(metaData, last);
reset();
notifyHeaders(frame);
}