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

more end2end tests 

Signed-off-by: Ludovic Orban <lorban@bitronix.be>
This commit is contained in:
Ludovic Orban 2021-03-24 14:21:43 +01:00 committed by Simone Bordet
parent a12a2f34e5
commit b151957a5b
1 changed files with 78 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

87
jetty-http3/http3-client/src/test/java/org/eclipse/jetty/http3/client/End2EndClientTest.java
View File

@ -15,7 +15,11 @@ package org.eclipse.jetty.http3.client;
import java.io.IOException; import java.io.IOException;
import java.io.PrintWriter; import java.io.PrintWriter;
import javax.servlet.ServletException; import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
@ -38,6 +42,7 @@ import static org.hamcrest.core.Is.is;
public class End2EndClientTest public class End2EndClientTest
{ {
private Server server; private Server server;
private HttpClient client;
@BeforeEach @BeforeEach
public void setUp() throws Exception public void setUp() throws Exception
@ -55,7 +60,7 @@ public class End2EndClientTest
server.setHandler(new AbstractHandler() server.setHandler(new AbstractHandler()
{ {
@Override @Override
public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException
{ {
baseRequest.setHandled(true); baseRequest.setHandled(true);
PrintWriter writer = response.getWriter(); PrintWriter writer = response.getWriter();
@ -68,21 +73,28 @@ public class End2EndClientTest
}); });
server.start(); server.start();
HttpClientTransportOverQuic transport = new HttpClientTransportOverQuic();
client = new HttpClient(transport);
client.start();
} }
@AfterEach @AfterEach
public void tearDown() throws Exception public void tearDown() throws Exception
{ {
server.stop(); try
{
server.stop();
}
finally
{
client.stop();
}
} }
@Test @Test
public void simple() throws Exception public void simple() throws Exception
{ {
HttpClientTransportOverQuic transport = new HttpClientTransportOverQuic();
HttpClient client = new HttpClient(transport);
client.start();
ContentResponse response = client.GET("https://localhost:8443/"); ContentResponse response = client.GET("https://localhost:8443/");
int status = response.getStatus(); int status = response.getStatus();
String contentAsString = response.getContentAsString(); String contentAsString = response.getContentAsString();
@ -91,8 +103,6 @@ public class End2EndClientTest
System.out.println(contentAsString); System.out.println(contentAsString);
System.out.println("=========="); System.out.println("==========");
client.stop();
assertThat(status, is(200)); assertThat(status, is(200));
assertThat(contentAsString, is("<html>\n" + assertThat(contentAsString, is("<html>\n" +
"\t<body>\n" + "\t<body>\n" +
@ -100,4 +110,63 @@ public class End2EndClientTest
"\t</body>\n" + "\t</body>\n" +
"</html>\n")); "</html>\n"));
} }
@Test
public void multiple() throws Exception
{
for (int i = 0; i < 1000; i++)
{
ContentResponse response = client.GET("https://localhost:8443/");
int status = response.getStatus();
String contentAsString = response.getContentAsString();
assertThat(status, is(200));
assertThat(contentAsString, is("<html>\n" +
"\t<body>\n" +
"\t\tRequest served\n" +
"\t</body>\n" +
"</html>\n"));
}
}
@Test
public void multiThreaded() throws Exception
{
ExecutorService executor = Executors.newFixedThreadPool(2);
try
{
List<Future<?>> futures = new ArrayList<>();
for (int i = 0; i < 1000; i++)
{
futures.add(executor.submit(() ->
{
try
{
ContentResponse response = client.GET("https://localhost:8443/");
int status = response.getStatus();
String contentAsString = response.getContentAsString();
assertThat(status, is(200));
assertThat(contentAsString, is("<html>\n" +
"\t<body>\n" +
"\t\tRequest served\n" +
"\t</body>\n" +
"</html>\n"));
}
catch (Exception e)
{
throw new RuntimeException(e);
}
}));
}
for (Future<?> future : futures)
{
future.get();
}
}
finally
{
executor.shutdownNow();
}
}
} }