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

Improve concurrent message buffer access test to reproduce known issue

Browse Source
This commit is contained in:
Trustin Lee 2012-06-03 13:21:57 -07:00
parent 4d8e2198fa
commit f6e14b636f
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java
View File

@ -186,7 +186,7 @@ public class LocalTransportThreadModelTest {
}
@Test
public void testConcurrentMessageBufferAccess() throws Exception {
public void testConcurrentMessageBufferAccess() throws Throwable {
EventLoop l = new LocalEventLoop(4, new PrefixThreadFactory("l"));
EventExecutor e1 = new DefaultEventExecutor(4, new PrefixThreadFactory("e1"));
EventExecutor e2 = new DefaultEventExecutor(4, new PrefixThreadFactory("e2"));
@ -199,10 +199,22 @@ public class LocalTransportThreadModelTest {
l.register(ch).sync().channel().connect(ADDR).sync();
for (int i = 0; i < 10000; i ++) {
ch.pipeline().inboundMessageBuffer().add(Integer.valueOf(i));
final int COUNT = 10485760;
for (int i = 0; i < COUNT;) {
for (int j = 0; i < COUNT && j < COUNT / 8; j ++) {
ch.pipeline().inboundMessageBuffer().add(Integer.valueOf(i ++));
if (h1.exception.get() != null) {
throw h1.exception.get();
}
if (h2.exception.get() != null) {
throw h2.exception.get();
}
if (h3.exception.get() != null) {
throw h3.exception.get();
}
}
ch.pipeline().fireInboundBufferUpdated();
}
ch.pipeline().fireInboundBufferUpdated();
}
private static class ThreadNameAuditor extends ChannelHandlerAdapter<Object, Object> {