andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Test all supported SPDY session management

Browse Source
This commit is contained in:
Trustin Lee 2012-05-31 02:06:53 -07:00
parent a494f201fc
commit 197f31c90e
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
codec-http/src/test/java/io/netty/handler/codec/spdy/SpdySessionHandlerTest.java
View File

@ -15,6 +15,7 @@
*/ */
package io.netty.handler.codec.spdy; package io.netty.handler.codec.spdy;
import static io.netty.handler.codec.spdy.SpdyCodecUtil.*;
import io.netty.channel.ChannelInboundHandlerContext; import io.netty.channel.ChannelInboundHandlerContext;
import io.netty.channel.ChannelInboundMessageHandlerAdapter; import io.netty.channel.ChannelInboundMessageHandlerAdapter;
import io.netty.handler.codec.embedder.DecoderEmbedder; import io.netty.handler.codec.embedder.DecoderEmbedder;
@ -93,10 +94,10 @@ public class SpdySessionHandlerTest {
assertHeaderBlock(spdyHeadersFrame, headers); assertHeaderBlock(spdyHeadersFrame, headers);
} }
private void testSpdySessionHandler(boolean server) { private void testSpdySessionHandler(int version, boolean server) {
DecoderEmbedder<Object> sessionHandler = DecoderEmbedder<Object> sessionHandler =
new DecoderEmbedder<Object>( new DecoderEmbedder<Object>(
new SpdySessionHandler(3, server), new EchoHandler(closeSignal, server)); new SpdySessionHandler(version, server), new EchoHandler(closeSignal, server));
sessionHandler.pollAll(); sessionHandler.pollAll();
int localStreamID = server ? 1 : 2; int localStreamID = server ? 1 : 2;
@ -250,12 +251,16 @@ public class SpdySessionHandlerTest {
@Test @Test
public void testSpdyClientSessionHandler() { public void testSpdyClientSessionHandler() {
testSpdySessionHandler(false); for (int version = SPDY_MIN_VERSION; version <= SPDY_MAX_VERSION; version ++) {
testSpdySessionHandler(version, false);
}
} }
@Test @Test
public void testSpdyServerSessionHandler() { public void testSpdyServerSessionHandler() {
testSpdySessionHandler(true); for (int version = SPDY_MIN_VERSION; version <= SPDY_MAX_VERSION; version ++) {
testSpdySessionHandler(version, true);
}
} }
// Echo Handler opens 4 half-closed streams on session connection // Echo Handler opens 4 half-closed streams on session connection