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

Simplify ServerSocketSuspendTest

Browse Source
This commit is contained in:
Trustin Lee 2012-08-29 13:15:24 +09:00
parent dca860e0d5
commit 47f26d219d
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
testsuite/src/test/java/io/netty/testsuite/transport/socket/ServerSocketSuspendTest.java
View File

@ -22,9 +22,7 @@ import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundByteHandlerAdapter; import io.netty.channel.ChannelInboundByteHandlerAdapter;
import io.netty.channel.ChannelOption; import io.netty.channel.ChannelOption;
import io.netty.util.NetworkConstants;
import java.net.InetSocketAddress;
import java.net.Socket; import java.net.Socket;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
@ -58,8 +56,9 @@ public class ServerSocketSuspendTest extends AbstractServerSocketTest {
try { try {
long startTime = System.nanoTime(); long startTime = System.nanoTime();
for (int i = 0; i < NUM_CHANNELS; i ++) { for (int i = 0; i < NUM_CHANNELS; i ++) {
sockets.add(new Socket( Socket s = new Socket();
NetworkConstants.LOCALHOST, ((InetSocketAddress) sc.localAddress()).getPort())); s.connect(addr, 10000);
sockets.add(s);
} }
sc.pipeline().firstContext().readable(true); sc.pipeline().firstContext().readable(true);
@ -76,8 +75,9 @@ public class ServerSocketSuspendTest extends AbstractServerSocketTest {
try { try {
long startTime = System.nanoTime(); long startTime = System.nanoTime();
for (int i = 0; i < NUM_CHANNELS; i ++) { for (int i = 0; i < NUM_CHANNELS; i ++) {
sockets.add(new Socket( Socket s = new Socket();
NetworkConstants.LOCALHOST, ((InetSocketAddress) sc.localAddress()).getPort())); s.connect(addr, 10000);
sockets.add(s);
} }
long endTime = System.nanoTime(); long endTime = System.nanoTime();