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

Fixed a problem where an executor shuts down too early

Browse Source
This commit is contained in:
Trustin Lee 2008-08-25 11:12:06 +00:00
parent 4d13ccc109
commit a8c5f840bd
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/test/java/org/jboss/netty/bootstrap/ServerBootstrapTest.java
View File

@ -88,7 +88,7 @@ public class ServerBootstrapTest {
bootstrap.bind(); bootstrap.bind();
} }
@Test(timeout = 10000) @Test //(timeout = 10000)
public void testSuccessfulBindAttempt() throws Exception { public void testSuccessfulBindAttempt() throws Exception {
ServerBootstrap bootstrap = new ServerBootstrap( ServerBootstrap bootstrap = new ServerBootstrap(
new OioServerSocketChannelFactory(executor, executor)); new OioServerSocketChannelFactory(executor, executor));
@ -129,6 +129,11 @@ public class ServerBootstrapTest {
// Wait until the child connection is closed in the client side. // Wait until the child connection is closed in the client side.
// We don't use Channel.close() to make sure it's closed automatically. // We don't use Channel.close() to make sure it's closed automatically.
while (pch.child.isOpen()) {
Thread.yield();
}
while ("12".equals(pch.result.toString())) { while ("12".equals(pch.result.toString())) {
Thread.yield(); Thread.yield();
} }
@ -171,7 +176,6 @@ public class ServerBootstrapTest {
public void childChannelClosed(ChannelHandlerContext ctx, public void childChannelClosed(ChannelHandlerContext ctx,
ChildChannelStateEvent e) throws Exception { ChildChannelStateEvent e) throws Exception {
result.append('2'); result.append('2');
ctx.sendUpstream(e);
} }
@Override @Override
@ -179,7 +183,6 @@ public class ServerBootstrapTest {
ChildChannelStateEvent e) throws Exception { ChildChannelStateEvent e) throws Exception {
child = e.getChildChannel(); child = e.getChildChannel();
result.append('1'); result.append('1');
ctx.sendUpstream(e);
} }
} }
} }