testCompress0() — netty Function Reference

Architecture documentation for the testCompress0() function in ZlibTest.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 2

Entity Profile

Buffer→ Allocators→ testCompress0() — netty Function Reference

Dependency Diagram

graph TD
  9dc264cb_0953_efd8_30d0_ff4d823d2756["testCompress0()"]
  7036d690_c470_1931_3ca2_5fffb656bebb["ZlibTest"]
  9dc264cb_0953_efd8_30d0_ff4d823d2756 -->|defined in| 7036d690_c470_1931_3ca2_5fffb656bebb
  b023fcda_0473_29df_baf0_dfe51cb70d3c["testCompressSmall()"]
  b023fcda_0473_29df_baf0_dfe51cb70d3c -->|calls| 9dc264cb_0953_efd8_30d0_ff4d823d2756
  c6ad729e_c0ad_fe32_83e3_3b6b2bf98e32["testCompressLarge()"]
  c6ad729e_c0ad_fe32_83e3_3b6b2bf98e32 -->|calls| 9dc264cb_0953_efd8_30d0_ff4d823d2756
  4ce8bff0_577d_fb67_462a_3c492abedec9["dispose()"]
  9dc264cb_0953_efd8_30d0_ff4d823d2756 -->|calls| 4ce8bff0_577d_fb67_462a_3c492abedec9
  style 9dc264cb_0953_efd8_30d0_ff4d823d2756 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-compression/src/test/java/io/netty/handler/codec/compression/ZlibTest.java lines 180–232

    private void testCompress0(ZlibWrapper encoderWrapper, ZlibWrapper decoderWrapper, ByteBuf data) throws Exception {
        EmbeddedChannel chEncoder = new EmbeddedChannel(createEncoder(encoderWrapper));
        EmbeddedChannel chDecoderZlib = new EmbeddedChannel(createDecoder(decoderWrapper));

        try {
            chEncoder.writeOutbound(data.retain());
            chEncoder.flush();
            data.resetReaderIndex();

            for (;;) {
                ByteBuf deflatedData = chEncoder.readOutbound();
                if (deflatedData == null) {
                    break;
                }
                chDecoderZlib.writeInbound(deflatedData);
            }

            byte[] decompressed = new byte[data.readableBytes()];
            int offset = 0;
            for (;;) {
                ByteBuf buf = chDecoderZlib.readInbound();
                if (buf == null) {
                    break;
                }
                int length = buf.readableBytes();
                buf.readBytes(decompressed, offset, length);
                offset += length;
                buf.release();
                if (offset == decompressed.length) {
                    break;
                }
            }
            assertEquals(data, Unpooled.wrappedBuffer(decompressed));
            assertNull(chDecoderZlib.readInbound());

            // Closing an encoder channel will generate a footer.
            assertTrue(chEncoder.finish());
            for (;;) {
                Object msg = chEncoder.readOutbound();
                if (msg == null) {
                    break;
                }
                ReferenceCountUtil.release(msg);
            }
            // But, the footer will be decoded into nothing. It's only for validation.
            assertFalse(chDecoderZlib.finish());

            data.release();
        } finally {
            dispose(chEncoder);
            dispose(chDecoderZlib);
        }
    }