grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove Netty test that fails with upstream

This commit is contained in:
Carl Mastrangelo 2015-09-23 13:47:33 -07:00
parent 9e690f8ddf
commit bfd74506fe
1 changed files with 0 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java
View File

@ -39,8 +39,6 @@ import static io.grpc.netty.Utils.HTTP_METHOD;
import static io.grpc.netty.Utils.TE_HEADER; import static io.grpc.netty.Utils.TE_HEADER;
import static io.grpc.netty.Utils.TE_TRAILERS; import static io.grpc.netty.Utils.TE_TRAILERS;
import static io.netty.handler.codec.http2.Http2CodecUtil.DEFAULT_WINDOW_SIZE; import static io.netty.handler.codec.http2.Http2CodecUtil.DEFAULT_WINDOW_SIZE;
import static io.netty.handler.codec.http2.Http2CodecUtil.toByteBuf;
import static io.netty.handler.codec.http2.Http2Exception.connectionError;
import static org.junit.Assert.assertArrayEquals; import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertFalse;
@ -221,23 +219,6 @@ public class NettyServerHandlerTest extends NettyHandlerTestBase<NettyServerHand
assertEquals(Code.UNKNOWN, captor.getValue().getCode()); assertEquals(Code.UNKNOWN, captor.getValue().getCode());
} }
@Test
public void connectionErrorShouldCloseChannel() throws Exception {
createStream();
// Read a bad frame to trigger the exception.
channelRead(badFrame());
// Verify the expected GO_AWAY frame was written.
Exception e = connectionError(Http2Error.PROTOCOL_ERROR,
"Frame length 0 incorrect size for ping.");
verifyWrite().writeGoAway(eq(ctx()), eq(STREAM_ID), eq(Http2Error.FRAME_SIZE_ERROR.code()),
eq(toByteBuf(ctx(), e)), any(ChannelPromise.class));
// Verify that the context was closed.
assertFalse(channel().isOpen());
}
@Test @Test
public void closeShouldCloseChannel() throws Exception { public void closeShouldCloseChannel() throws Exception {
handler().close(ctx(), newPromise()); handler().close(ctx(), newPromise());