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

disable autoFragment for WebSocketStatsTest 

Signed-off-by: Lachlan Roberts <lachlan@webtide.com>
This commit is contained in:
Lachlan Roberts 2020-08-19 09:32:54 +10:00
parent 931e10458a
commit 7d6f692721
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
jetty-websocket/websocket-jetty-tests/src/test/java/org/eclipse/jetty/websocket/tests/WebSocketStatsTest.java
View File

@ -42,7 +42,6 @@ import org.eclipse.jetty.websocket.core.internal.WebSocketConnection;
import org.eclipse.jetty.websocket.server.config.JettyWebSocketServletContainerInitializer; import org.eclipse.jetty.websocket.server.config.JettyWebSocketServletContainerInitializer;
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.MatcherAssert.assertThat;
@ -80,13 +79,17 @@ public class WebSocketStatsTest
server.addConnector(connector); server.addConnector(connector);
ServletContextHandler contextHandler = new ServletContextHandler(ServletContextHandler.SESSIONS); ServletContextHandler contextHandler = new ServletContextHandler(ServletContextHandler.SESSIONS);
server.setHandler(contextHandler);
contextHandler.setContextPath("/"); contextHandler.setContextPath("/");
JettyWebSocketServletContainerInitializer.configure(contextHandler, (context, container) -> JettyWebSocketServletContainerInitializer.configure(contextHandler, (context, container) ->
container.addMapping("/", EchoSocket.class)); {
server.setHandler(contextHandler); container.setAutoFragment(false);
container.addMapping("/", EchoSocket.class);
});
JettyWebSocketServletContainerInitializer.configure(contextHandler, null); JettyWebSocketServletContainerInitializer.configure(contextHandler, null);
client = new WebSocketClient(); client = new WebSocketClient();
client.setAutoFragment(false);
// Setup JMX. // Setup JMX.
MBeanContainer mbeanContainer = new MBeanContainer(ManagementFactory.getPlatformMBeanServer()); MBeanContainer mbeanContainer = new MBeanContainer(ManagementFactory.getPlatformMBeanServer());
@ -111,7 +114,6 @@ public class WebSocketStatsTest
return headerBuffer.remaining() + frame.getPayloadLength(); return headerBuffer.remaining() + frame.getPayloadLength();
} }
@Disabled("off by 2 some of the time for large num of messages")
@Test @Test
public void echoStatsTest() throws Exception public void echoStatsTest() throws Exception
{ {