Add AIO transport to the test suite
This commit is contained in:
parent
127e9c1d1e
commit
3e2953cf92
@ -17,7 +17,11 @@ package io.netty.testsuite.transport.socket;
|
|||||||
|
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.bootstrap.ServerBootstrap;
|
import io.netty.bootstrap.ServerBootstrap;
|
||||||
|
import io.netty.channel.EventLoop;
|
||||||
import io.netty.channel.socket.InternetProtocolFamily;
|
import io.netty.channel.socket.InternetProtocolFamily;
|
||||||
|
import io.netty.channel.socket.aio.AioEventLoop;
|
||||||
|
import io.netty.channel.socket.aio.AioServerSocketChannel;
|
||||||
|
import io.netty.channel.socket.aio.AioSocketChannel;
|
||||||
import io.netty.channel.socket.nio.NioDatagramChannel;
|
import io.netty.channel.socket.nio.NioDatagramChannel;
|
||||||
import io.netty.channel.socket.nio.NioEventLoop;
|
import io.netty.channel.socket.nio.NioEventLoop;
|
||||||
import io.netty.channel.socket.nio.NioServerSocketChannel;
|
import io.netty.channel.socket.nio.NioServerSocketChannel;
|
||||||
@ -48,6 +52,15 @@ final class SocketTestPermutation {
|
|||||||
channel(new NioServerSocketChannel());
|
channel(new NioServerSocketChannel());
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
sbfs.add(new Factory<ServerBootstrap>() {
|
||||||
|
@Override
|
||||||
|
public ServerBootstrap newInstance() {
|
||||||
|
EventLoop loop = new AioEventLoop();
|
||||||
|
return new ServerBootstrap().
|
||||||
|
eventLoop(loop, loop).
|
||||||
|
channel(new AioServerSocketChannel());
|
||||||
|
}
|
||||||
|
});
|
||||||
sbfs.add(new Factory<ServerBootstrap>() {
|
sbfs.add(new Factory<ServerBootstrap>() {
|
||||||
@Override
|
@Override
|
||||||
public ServerBootstrap newInstance() {
|
public ServerBootstrap newInstance() {
|
||||||
@ -66,6 +79,12 @@ final class SocketTestPermutation {
|
|||||||
return new Bootstrap().eventLoop(new NioEventLoop()).channel(new NioSocketChannel());
|
return new Bootstrap().eventLoop(new NioEventLoop()).channel(new NioSocketChannel());
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
cbfs.add(new Factory<Bootstrap>() {
|
||||||
|
@Override
|
||||||
|
public Bootstrap newInstance() {
|
||||||
|
return new Bootstrap().eventLoop(new AioEventLoop()).channel(new AioSocketChannel());
|
||||||
|
}
|
||||||
|
});
|
||||||
cbfs.add(new Factory<Bootstrap>() {
|
cbfs.add(new Factory<Bootstrap>() {
|
||||||
@Override
|
@Override
|
||||||
public Bootstrap newInstance() {
|
public Bootstrap newInstance() {
|
||||||
|
Loading…
Reference in New Issue
Block a user