SctpMessageCompletionHandlerTest Class — netty Architecture

Source Code

transport-sctp/src/test/java/io/netty/handler/codec/sctp/SctpMessageCompletionHandlerTest.java lines 32–126

public class SctpMessageCompletionHandlerTest {

    @Test
    public void testFragmentsReleased() {
        EmbeddedChannel channel = new EmbeddedChannel(new SctpMessageCompletionHandler());
        ByteBuf buffer = Unpooled.wrappedBuffer(new byte[] { 1, 2, 3, 4 });
        ByteBuf buffer2 = Unpooled.wrappedBuffer(new byte[] { 1, 2, 3, 4 });
        SctpMessage message = new SctpMessage(new TestMessageInfo(false, 1), buffer);
        assertFalse(channel.writeInbound(message));
        assertEquals(1, buffer.refCnt());
        SctpMessage message2 = new SctpMessage(new TestMessageInfo(false, 2), buffer2);
        assertFalse(channel.writeInbound(message2));
        assertEquals(1, buffer2.refCnt());
        assertFalse(channel.finish());
        assertEquals(0, buffer.refCnt());
        assertEquals(0, buffer2.refCnt());
    }

    @SuppressForbidden(reason = "test-only")
    private final class TestMessageInfo extends MessageInfo {

        private final boolean complete;
        private final int streamNumber;

        TestMessageInfo(boolean complete, int streamNumber) {
            this.complete = complete;
            this.streamNumber = streamNumber;
        }

        @Override
        public SocketAddress address() {
            return null;
        }

        @Override
        public Association association() {
            return null;
        }

        @Override
        public int bytes() {
            return 0;
        }

        @Override
        public boolean isComplete() {
            return complete;
        }

        @Override
        public MessageInfo complete(boolean b) {
            throw new UnsupportedOperationException();
        }

        @Override
        public boolean isUnordered() {
            return false;
        }

        @Override
        public MessageInfo unordered(boolean b) {
            throw new UnsupportedOperationException();
        }

        @Override
        public int payloadProtocolID() {
            return 0;
        }

        @Override
        public MessageInfo payloadProtocolID(int i) {
            throw new UnsupportedOperationException();
        }

        @Override
        public int streamNumber() {
            return streamNumber;
        }

        @Override
        public MessageInfo streamNumber(int i) {