decodeBulkStringContent() — netty Function Reference

Architecture documentation for the decodeBulkStringContent() function in RedisDecoder.java from the netty codebase.

Function java Buffer Allocators calls 2 called by 2

Entity Profile

Buffer→ Allocators→ decodeBulkStringContent() — netty Function Reference

Dependency Diagram

graph TD
  4dcee4b2_7f61_d951_b580_50f0852e5732["decodeBulkStringContent()"]
  2421b439_cffa_67ca_b872_bb582dd0dbf2["RedisDecoder"]
  4dcee4b2_7f61_d951_b580_50f0852e5732 -->|defined in| 2421b439_cffa_67ca_b872_bb582dd0dbf2
  04cf8633_8ce7_e5aa_352b_1b23a309052f["decode()"]
  04cf8633_8ce7_e5aa_352b_1b23a309052f -->|calls| 4dcee4b2_7f61_d951_b580_50f0852e5732
  1d4f1b51_c148_ce38_593c_4e951cf4f9b6["decodeBulkString()"]
  1d4f1b51_c148_ce38_593c_4e951cf4f9b6 -->|calls| 4dcee4b2_7f61_d951_b580_50f0852e5732
  2960bd56_d12c_72f0_fad4_c3d3018db618["readEndOfLine()"]
  4dcee4b2_7f61_d951_b580_50f0852e5732 -->|calls| 2960bd56_d12c_72f0_fad4_c3d3018db618
  fe09be93_7a87_7d9a_a4e2_1f26488d2f56["resetDecoder()"]
  4dcee4b2_7f61_d951_b580_50f0852e5732 -->|calls| fe09be93_7a87_7d9a_a4e2_1f26488d2f56
  style 4dcee4b2_7f61_d951_b580_50f0852e5732 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-redis/src/main/java/io/netty/handler/codec/redis/RedisDecoder.java lines 223–244

    private boolean decodeBulkStringContent(ByteBuf in, List<Object> out) throws Exception {
        final int readableBytes = in.readableBytes();
        if (readableBytes == 0 || remainingBulkLength == 0 && readableBytes < RedisConstants.EOL_LENGTH) {
            return false;
        }

        // if this is last frame.
        if (readableBytes >= remainingBulkLength + RedisConstants.EOL_LENGTH) {
            ByteBuf content = in.readSlice(remainingBulkLength);
            readEndOfLine(in);
            // Only call retain after readEndOfLine(...) as the method may throw an exception.
            out.add(new DefaultLastBulkStringRedisContent(content.retain()));
            resetDecoder();
            return true;
        }

        // chunked write.
        int toRead = Math.min(remainingBulkLength, readableBytes);
        remainingBulkLength -= toRead;
        out.add(new DefaultBulkStringRedisContent(in.readSlice(toRead).retain()));
        return true;
    }