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

[#937] Add test for ServerBootstrap.bindAsync(..)

Browse Source
This commit is contained in:
Norman Maurer 2013-01-16 08:27:44 +01:00
parent cb3c74ea2f
commit bc64c18827
3 changed files with 127 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
src/test/java/org/jboss/netty/bootstrap/BootstrapTest.java
View File

@ -39,7 +39,7 @@ import org.junit.Test;
public class BootstrapTest {
@Test(expected = IllegalStateException.class)
public void shouldNotReturnNullFactory() {
new Bootstrap().getFactory();
newBootstrap().getFactory();
}
@Test(expected = IllegalStateException.class)
@ -49,7 +49,7 @@ public class BootstrapTest {
@Test
public void shouldNotAllowFactoryToChangeMoreThanOnce() {
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
ChannelFactory f = createMock(ChannelFactory.class);
b.setFactory(f);
assertSame(f, b.getFactory());
@ -65,22 +65,22 @@ public class BootstrapTest {
@Test(expected = NullPointerException.class)
public void shouldNotAllowNullFactory() {
new Bootstrap().setFactory(null);
newBootstrap().setFactory(null);
}
@Test
public void shouldHaveNonNullInitialPipeline() {
assertNotNull(new Bootstrap().getPipeline());
assertNotNull(newBootstrap().getPipeline());
}
@Test(expected = NullPointerException.class)
public void shouldNotAllowNullPipeline() {
new Bootstrap().setPipeline(null);
newBootstrap().setPipeline(null);
}
@Test(expected = NullPointerException.class)
public void shouldNotAllowNullPipelineMap() {
new Bootstrap().setPipelineAsMap(null);
newBootstrap().setPipelineAsMap(null);
}
@Test
@ -90,7 +90,7 @@ public class BootstrapTest {
@Test
public void shouldUpdatePipelineFactoryIfPipelineIsSet() {
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
ChannelPipelineFactory oldPipelineFactory = b.getPipelineFactory();
b.setPipeline(createMock(ChannelPipeline.class));
assertNotSame(oldPipelineFactory, b.getPipelineFactory());
@ -99,7 +99,7 @@ public class BootstrapTest {
@Test(expected = IllegalStateException.class)
public void shouldNotReturnPipelineWhenPipelineFactoryIsSetByUser() {
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
b.setPipelineFactory(createMock(ChannelPipelineFactory.class));
b.getPipeline();
b.releaseExternalResources();
@ -107,7 +107,7 @@ public class BootstrapTest {
@Test(expected = IllegalStateException.class)
public void shouldNotReturnPipelineMapWhenPipelineFactoryIsSetByUser() {
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
b.setPipelineFactory(createMock(ChannelPipelineFactory.class));
b.getPipelineAsMap();
b.releaseExternalResources();
@ -115,17 +115,17 @@ public class BootstrapTest {
@Test(expected = NullPointerException.class)
public void shouldNotAllowNullPipelineFactory() {
new Bootstrap().setPipelineFactory(null);
newBootstrap().setPipelineFactory(null);
}
@Test
public void shouldHaveInitialEmptyPipelineMap() {
assertTrue(new Bootstrap().getPipelineAsMap().isEmpty());
assertTrue(newBootstrap().getPipelineAsMap().isEmpty());
}
@Test
public void shouldReturnOrderedPipelineMap() {
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
ChannelPipeline p = b.getPipeline();
p.addLast("a", new DummyHandler());
p.addLast("b", new DummyHandler());
@ -160,7 +160,7 @@ public class BootstrapTest {
m.put("c", new DummyHandler());
m.put("d", new DummyHandler());
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
b.setPipelineAsMap(m);
b.releaseExternalResources();
}
@ -173,7 +173,7 @@ public class BootstrapTest {
m.put("c", new DummyHandler());
m.put("d", new DummyHandler());
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
b.setPipelineAsMap(m);
ChannelPipeline p = b.getPipeline();
@ -202,12 +202,12 @@ public class BootstrapTest {
@Test
public void shouldHaveInitialEmptyOptionMap() {
assertTrue(new Bootstrap().getOptions().isEmpty());
assertTrue(newBootstrap().getOptions().isEmpty());
}
@Test
public void shouldUpdateOptionMapAsRequested1() {
Bootstrap b = new Bootstrap();
Bootstrap b =new Bootstrap();
b.setOption("s", "x");
b.setOption("b", true);
b.setOption("i", 42);
@ -222,7 +222,7 @@ public class BootstrapTest {
@Test
public void shouldUpdateOptionMapAsRequested2() {
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
Map<String, Object> o1 = new HashMap<String, Object>();
o1.put("s", "x");
o1.put("b", true);
@ -242,7 +242,7 @@ public class BootstrapTest {
@Test
public void shouldRemoveOptionIfValueIsNull() {
Bootstrap b = new Bootstrap();
Bootstrap b = newBootstrap();
b.setOption("s", "x");
assertEquals("x", b.getOption("s"));
@ -255,16 +255,20 @@ public class BootstrapTest {
@Test(expected = NullPointerException.class)
public void shouldNotAllowNullOptionKeyOnGet() {
new Bootstrap().getOption(null);
newBootstrap().getOption(null);
}
@Test(expected = NullPointerException.class)
public void shouldNotAllowNullOptionKeyOnSet() {
new Bootstrap().setOption(null, "x");
newBootstrap().setOption(null, "x");
}
@Test(expected = NullPointerException.class)
public void shouldNotAllowNullOptionMap() {
new Bootstrap().setOptions(null);
newBootstrap().setOptions(null);
}
protected Bootstrap newBootstrap() {
return new Bootstrap();
}
}

24
src/test/java/org/jboss/netty/bootstrap/ClientBootstrapTest.java Normal file
View File

@ -0,0 +1,24 @@
/*
* Copyright 2013 The Netty Project
*
* The Netty Project licenses this file to you under the Apache License,
* version 2.0 (the "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
* License for the specific language governing permissions and limitations
* under the License.
*/
package org.jboss.netty.bootstrap;
public class ClientBootstrapTest extends BootstrapTest {
@Override
protected ClientBootstrap newBootstrap() {
return new ClientBootstrap();
}
}

78
src/test/java/org/jboss/netty/bootstrap/ServerBootstrapTest.java Normal file
View File

@ -0,0 +1,78 @@
/*
* Copyright 2013 The Netty Project
*
* The Netty Project licenses this file to you under the Apache License,
* version 2.0 (the "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
* License for the specific language governing permissions and limitations
* under the License.
*/
package org.jboss.netty.bootstrap;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelFactory;
import org.jboss.netty.channel.ChannelFuture;
import org.jboss.netty.channel.ServerChannelFactory;
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
import org.junit.Test;
import java.net.InetSocketAddress;
import static org.easymock.EasyMock.createMock;
import static org.junit.Assert.assertSame;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
public class ServerBootstrapTest extends BootstrapTest {
@Override
protected ServerBootstrap newBootstrap() {
return new ServerBootstrap();
}
@Test(expected = IllegalArgumentException.class)
public void shouldOnlyAllowServerChannelFactory() {
ServerBootstrap bootstrap = newBootstrap();
bootstrap.setFactory(createMock(ChannelFactory.class));
}
@Test
@Override
public void shouldNotAllowFactoryToChangeMoreThanOnce() {
Bootstrap b = newBootstrap();
ChannelFactory f = createMock(ServerChannelFactory.class);
b.setFactory(f);
assertSame(f, b.getFactory());
try {
b.setFactory(createMock(ServerChannelFactory.class));
fail();
} catch (IllegalStateException e) {
// Success.
}
b.releaseExternalResources();
}
@Test
public void testBindAsync() {
ServerBootstrap bootstrap = newBootstrap();
bootstrap.setFactory(new NioServerSocketChannelFactory());
ChannelFuture future = bootstrap.bindAsync(new InetSocketAddress(0));
future.awaitUninterruptibly();
assertTrue(future.isSuccess());
future.getChannel().close().awaitUninterruptibly();
}
@Test
public void testBind() {
ServerBootstrap bootstrap = newBootstrap();
bootstrap.setFactory(new NioServerSocketChannelFactory());
Channel channel = bootstrap.bind(new InetSocketAddress(0));
channel.close().awaitUninterruptibly();
}
}