This is an automated email from the ASF dual-hosted git repository.
markt pushed a commit to branch 9.0.x
in repository https://gitbox.apache.org/repos/asf/tomcat.git
commit 94b41fac58157a2ba258bac2668d8e5810edecd2
Author: Mark Thomas <ma...@apache.org>
AuthorDate: Mon Sep 30 11:49:48 2024 +0100
Refactor HTTP/2 trailer testing to create trailers separately
This will allow other requests to be multiplexed between the headers and
trailers of the stream using trailers.
---
test/org/apache/coyote/http2/Http2TestBase.java | 21 +++++++++++----------
.../apache/coyote/http2/TestAsyncReadListener.java | 3 ++-
.../apache/coyote/http2/TestCancelledUpload.java | 4 ++--
.../apache/coyote/http2/TestHttp2AccessLogs.java | 3 ++-
test/org/apache/coyote/http2/TestHttp2Limits.java | 4 ++--
.../apache/coyote/http2/TestHttp2Section_8_1.java | 6 +++---
test/org/apache/coyote/http2/TestHttpServlet.java | 2 +-
test/org/apache/coyote/http2/TestLargeUpload.java | 4 ++--
8 files changed, 25 insertions(+), 22 deletions(-)
diff --git a/test/org/apache/coyote/http2/Http2TestBase.java
b/test/org/apache/coyote/http2/Http2TestBase.java
index 42def01e9b..e5d4a4ee0d 100644
--- a/test/org/apache/coyote/http2/Http2TestBase.java
+++ b/test/org/apache/coyote/http2/Http2TestBase.java
@@ -346,7 +346,7 @@ public abstract class Http2TestBase extends TomcatBaseTest {
ByteBuffer dataPayload = ByteBuffer.allocate(128);
buildPostRequest(headersFrameHeader, headersPayload, useExpectation,
"application/x-www-form-urlencoded",
- contentLength, "/parameter", dataFrameHeader, dataPayload,
padding, null, null, streamId);
+ contentLength, "/parameter", dataFrameHeader, dataPayload,
padding, false, streamId);
writeFrame(headersFrameHeader, headersPayload);
if (body != null) {
dataPayload.put(body.getBytes(StandardCharsets.ISO_8859_1));
@@ -358,19 +358,18 @@ public abstract class Http2TestBase extends
TomcatBaseTest {
protected void buildPostRequest(byte[] headersFrameHeader, ByteBuffer
headersPayload, boolean useExpectation,
byte[] dataFrameHeader, ByteBuffer dataPayload, byte[] padding,
int streamId) {
buildPostRequest(headersFrameHeader, headersPayload, useExpectation,
dataFrameHeader, dataPayload, padding,
- null, null, streamId);
+ false, streamId);
}
protected void buildPostRequest(byte[] headersFrameHeader, ByteBuffer
headersPayload, boolean useExpectation,
- byte[] dataFrameHeader, ByteBuffer dataPayload, byte[] padding,
byte[] trailersFrameHeader,
- ByteBuffer trailersPayload, int streamId) {
+ byte[] dataFrameHeader, ByteBuffer dataPayload, byte[] padding,
boolean withTrailers, int streamId) {
buildPostRequest(headersFrameHeader, headersPayload, useExpectation,
null, -1, "/simple", dataFrameHeader,
- dataPayload, padding, trailersFrameHeader, trailersPayload,
streamId);
+ dataPayload, padding, withTrailers, streamId);
}
protected void buildPostRequest(byte[] headersFrameHeader, ByteBuffer
headersPayload, boolean useExpectation,
String contentType, long contentLength, String path, byte[]
dataFrameHeader, ByteBuffer dataPayload,
- byte[] padding, byte[] trailersFrameHeader, ByteBuffer
trailersPayload, int streamId) {
+ byte[] padding, boolean withTrailers, int streamId) {
MimeHeaders headers = new MimeHeaders();
headers.addValue(":method").setString("POST");
@@ -417,17 +416,19 @@ public abstract class Http2TestBase extends
TomcatBaseTest {
ByteUtil.setThreeBytes(dataFrameHeader, 0, dataPayload.limit());
// Data is type 0
// Flags: End of stream 1, Padding 8
- if (trailersPayload == null) {
- dataFrameHeader[4] = 0x01;
- } else {
+ if (withTrailers) {
dataFrameHeader[4] = 0x00;
+ } else {
+ dataFrameHeader[4] = 0x01;
}
if (padding != null) {
dataFrameHeader[4] += 0x08;
}
ByteUtil.set31Bits(dataFrameHeader, 5, streamId);
+ }
+
- // Trailers
+ protected void buildTrailerHeaders(byte[] trailersFrameHeader, ByteBuffer
trailersPayload, int streamId) {
if (trailersPayload != null) {
MimeHeaders trailerHeaders = new MimeHeaders();
trailerHeaders.addValue(TRAILER_HEADER_NAME).setString(TRAILER_HEADER_VALUE);
diff --git a/test/org/apache/coyote/http2/TestAsyncReadListener.java
b/test/org/apache/coyote/http2/TestAsyncReadListener.java
index a6f77f8e7e..2046b4621f 100644
--- a/test/org/apache/coyote/http2/TestAsyncReadListener.java
+++ b/test/org/apache/coyote/http2/TestAsyncReadListener.java
@@ -77,7 +77,8 @@ public class TestAsyncReadListener extends Http2TestBase {
buildPostRequest(headersFrameHeader, headersPayload, false, null, -1,
"/async", dataFrameHeader, dataPayload,
- null, trailerFrameHeader, trailerPayload, 3);
+ null, true, 3);
+ buildTrailerHeaders(trailerFrameHeader, trailerPayload, 3);
synchronized (asyncServlet) {
// Write the headers
diff --git a/test/org/apache/coyote/http2/TestCancelledUpload.java
b/test/org/apache/coyote/http2/TestCancelledUpload.java
index d759351e51..72e0b56e4b 100644
--- a/test/org/apache/coyote/http2/TestCancelledUpload.java
+++ b/test/org/apache/coyote/http2/TestCancelledUpload.java
@@ -49,8 +49,8 @@ public class TestCancelledUpload extends Http2TestBase {
byte[] trailerFrameHeader = new byte[9];
ByteBuffer trailerPayload = ByteBuffer.allocate(256);
- buildPostRequest(headersFrameHeader, headersPayload, false,
dataFrameHeader, dataPayload, null,
- trailerFrameHeader, trailerPayload, 3);
+ buildPostRequest(headersFrameHeader, headersPayload, false,
dataFrameHeader, dataPayload, null, true, 3);
+ buildTrailerHeaders(trailerFrameHeader, trailerPayload, 3);
// Write the headers
writeFrame(headersFrameHeader, headersPayload);
diff --git a/test/org/apache/coyote/http2/TestHttp2AccessLogs.java
b/test/org/apache/coyote/http2/TestHttp2AccessLogs.java
index 45897bf0a6..6f91844e63 100644
--- a/test/org/apache/coyote/http2/TestHttp2AccessLogs.java
+++ b/test/org/apache/coyote/http2/TestHttp2AccessLogs.java
@@ -92,7 +92,8 @@ public class TestHttp2AccessLogs extends Http2TestBase {
ByteBuffer trailerPayload = ByteBuffer.allocate(256);
buildPostRequest(headersFrameHeader, headersPayload, false, null, -1,
"/trailers", dataFrameHeader, dataPayload,
- null, trailerFrameHeader, trailerPayload, 3);
+ null, true, 3);
+ buildTrailerHeaders(trailerFrameHeader, trailerPayload, 3);
// Write the headers
writeFrame(headersFrameHeader, headersPayload);
diff --git a/test/org/apache/coyote/http2/TestHttp2Limits.java
b/test/org/apache/coyote/http2/TestHttp2Limits.java
index 7bb6d19043..ec80215543 100644
--- a/test/org/apache/coyote/http2/TestHttp2Limits.java
+++ b/test/org/apache/coyote/http2/TestHttp2Limits.java
@@ -498,8 +498,8 @@ public class TestHttp2Limits extends Http2TestBase {
byte[] trailerFrameHeader = new byte[9];
ByteBuffer trailerPayload = ByteBuffer.allocate(256);
- buildPostRequest(headersFrameHeader, headersPayload, false,
dataFrameHeader, dataPayload, null,
- trailerFrameHeader, trailerPayload, 3);
+ buildPostRequest(headersFrameHeader, headersPayload, false,
dataFrameHeader, dataPayload, null, true, 3);
+ buildTrailerHeaders(trailerFrameHeader, trailerPayload, 3);
// Write the headers
writeFrame(headersFrameHeader, headersPayload);
diff --git a/test/org/apache/coyote/http2/TestHttp2Section_8_1.java
b/test/org/apache/coyote/http2/TestHttp2Section_8_1.java
index 283fbe5cbf..28386ece2e 100644
--- a/test/org/apache/coyote/http2/TestHttp2Section_8_1.java
+++ b/test/org/apache/coyote/http2/TestHttp2Section_8_1.java
@@ -61,8 +61,8 @@ public class TestHttp2Section_8_1 extends Http2TestBase {
byte[] trailerFrameHeader = new byte[9];
ByteBuffer trailerPayload = ByteBuffer.allocate(256);
- buildPostRequest(headersFrameHeader, headersPayload, false,
dataFrameHeader, dataPayload, null,
- trailerFrameHeader, trailerPayload, 3);
+ buildPostRequest(headersFrameHeader, headersPayload, false,
dataFrameHeader, dataPayload, null, true, 3);
+ buildTrailerHeaders(trailerFrameHeader, trailerPayload, 3);
// Write the headers
writeFrame(headersFrameHeader, headersPayload);
@@ -136,7 +136,7 @@ public class TestHttp2Section_8_1 extends Http2TestBase {
ByteBuffer dataPayload = ByteBuffer.allocate(256);
buildPostRequest(headersFrameHeader, headersPayload, true, null, -1,
"/simple", dataFrameHeader, dataPayload,
- null, null, null, 3);
+ null, false, 3);
// Write the headers
writeFrame(headersFrameHeader, headersPayload);
diff --git a/test/org/apache/coyote/http2/TestHttpServlet.java
b/test/org/apache/coyote/http2/TestHttpServlet.java
index de3749cd48..0eaab65270 100644
--- a/test/org/apache/coyote/http2/TestHttpServlet.java
+++ b/test/org/apache/coyote/http2/TestHttpServlet.java
@@ -38,7 +38,7 @@ public class TestHttpServlet extends Http2TestBase {
ByteBuffer dataPayload = ByteBuffer.allocate(0);
buildPostRequest(headersFrameHeader, headersPayload, false, null, -1,
"/empty", dataFrameHeader, dataPayload,
- null, null, null, 3);
+ null, false, 3);
// Write the headers
writeFrame(headersFrameHeader, headersPayload);
diff --git a/test/org/apache/coyote/http2/TestLargeUpload.java
b/test/org/apache/coyote/http2/TestLargeUpload.java
index 6ca26178d4..ab04fa62b0 100644
--- a/test/org/apache/coyote/http2/TestLargeUpload.java
+++ b/test/org/apache/coyote/http2/TestLargeUpload.java
@@ -92,8 +92,8 @@ public class TestLargeUpload extends Http2TestBase {
byte[] trailerFrameHeader = new byte[9];
ByteBuffer trailerPayload = ByteBuffer.allocate(256);
- buildPostRequest(headersFrameHeader, headersPayload, false,
dataFrameHeader, dataPayload, null,
- trailerFrameHeader, trailerPayload, 3);
+ buildPostRequest(headersFrameHeader, headersPayload, false,
dataFrameHeader, dataPayload, null, true, 3);
+ buildTrailerHeaders(trailerFrameHeader, trailerPayload, 3);
// Write the headers
writeFrame(headersFrameHeader, headersPayload);
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
