KQueueDomainSocketShutdownOutputByPeerTest Class — netty Architecture

Source Code

transport-native-kqueue/src/test/java/io/netty/channel/kqueue/KQueueDomainSocketShutdownOutputByPeerTest.java lines 29–70

public class KQueueDomainSocketShutdownOutputByPeerTest extends AbstractSocketShutdownOutputByPeerTest<BsdSocket> {

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

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

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

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

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

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

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