EpollSocketStringEchoBusyWaitTest Class — netty Architecture

Source Code

transport-native-epoll/src/test/java/io/netty/channel/epoll/EpollSocketStringEchoBusyWaitTest.java lines 36–101

public class EpollSocketStringEchoBusyWaitTest extends SocketStringEchoTest {

    private static EventLoopGroup EPOLL_LOOP;

    @BeforeAll
    public static void setup() throws Exception {
        EPOLL_LOOP = new MultiThreadIoEventLoopGroup(2, new DefaultThreadFactory("testsuite-epoll-busy-wait", true),
                EpollIoHandler.newFactory(1024, new SelectStrategyFactory() {
                    @Override
                    public SelectStrategy newSelectStrategy() {
                        return new SelectStrategy() {
                            @Override
                            public int calculateStrategy(IntSupplier selectSupplier, boolean hasTasks) {
                                return SelectStrategy.BUSY_WAIT;
                            }
                        };
                    }
                }));
    }

    @AfterAll
    public static void teardown() throws Exception {
        if (EPOLL_LOOP != null) {
            EPOLL_LOOP.shutdownGracefully();
        }
    }

    @Override
    protected List<TestsuitePermutation.BootstrapComboFactory<ServerBootstrap, Bootstrap>> newFactories() {
        List<BootstrapComboFactory<ServerBootstrap, Bootstrap>> list =
                new ArrayList<BootstrapComboFactory<ServerBootstrap, Bootstrap>>();
        final BootstrapFactory<ServerBootstrap> sbf = serverSocket();
        final BootstrapFactory<Bootstrap> cbf = clientSocket();
        list.add(new BootstrapComboFactory<ServerBootstrap, Bootstrap>() {
            @Override
            public ServerBootstrap newServerInstance() {
                return sbf.newInstance();
            }

            @Override
            public Bootstrap newClientInstance() {
                return cbf.newInstance();
            }
        });

        return list;
    }

    private static BootstrapFactory<ServerBootstrap> serverSocket() {
        return new BootstrapFactory<ServerBootstrap>() {
            @Override
            public ServerBootstrap newInstance() {
                return new ServerBootstrap().group(EPOLL_LOOP).channel(EpollServerSocketChannel.class);
            }
        };
    }

    private static BootstrapFactory<Bootstrap> clientSocket() {
        return new BootstrapFactory<Bootstrap>() {
            @Override
            public Bootstrap newInstance() {
                return new Bootstrap().group(EPOLL_LOOP).channel(EpollSocketChannel.class);
            }
        };
    }
}