EpollDomainSocketShutdownOutputByPeerTest Class — netty Architecture

Source Code

transport-native-epoll/src/test/java/io/netty/channel/epoll/EpollDomainSocketShutdownOutputByPeerTest.java lines 30–71

public class EpollDomainSocketShutdownOutputByPeerTest extends AbstractSocketShutdownOutputByPeerTest<LinuxSocket> {

    @Override
    protected List<BootstrapFactory<ServerBootstrap>> newFactories() {
        return EpollSocketTestPermutation.INSTANCE.serverDomainSocket();
    }

    @Override
    protected SocketAddress newSocketAddress() {
        return EpollSocketTestPermutation.newDomainSocketAddress();
    }

    @Override
    protected void shutdownOutput(LinuxSocket s) throws IOException {
        s.shutdown(false, true);
    }

    @Override
    protected void connect(LinuxSocket s, SocketAddress address) throws IOException {
        s.connect(address);
    }

    @Override
    protected void close(LinuxSocket s) throws IOException {
        s.close();
    }

    @Override
    protected void write(LinuxSocket s, int data) throws IOException {
        CleanableDirectBuffer cleanableDirectBuffer = Buffer.allocateDirectBufferWithNativeOrder(4);
        final ByteBuffer buf = cleanableDirectBuffer.buffer();
        buf.putInt(data);
        buf.flip();
        s.send(buf, buf.position(), buf.limit());
        cleanableDirectBuffer.clean();
    }

    @Override
    protected LinuxSocket newSocket() {
        return LinuxSocket.newSocketDomain();
    }
}