decodeBulkString() — netty Function Reference

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

Function java Buffer Allocators calls 3 called by 1

Entity Profile

Buffer→ Allocators→ decodeBulkString() — netty Function Reference

Dependency Diagram

graph TD
  1d4f1b51_c148_ce38_593c_4e951cf4f9b6["decodeBulkString()"]
  2421b439_cffa_67ca_b872_bb582dd0dbf2["RedisDecoder"]
  1d4f1b51_c148_ce38_593c_4e951cf4f9b6 -->|defined in| 2421b439_cffa_67ca_b872_bb582dd0dbf2
  6d8b9b4b_2072_a961_76cb_8954875e821b["decodeLength()"]
  6d8b9b4b_2072_a961_76cb_8954875e821b -->|calls| 1d4f1b51_c148_ce38_593c_4e951cf4f9b6
  fe09be93_7a87_7d9a_a4e2_1f26488d2f56["resetDecoder()"]
  1d4f1b51_c148_ce38_593c_4e951cf4f9b6 -->|calls| fe09be93_7a87_7d9a_a4e2_1f26488d2f56
  ac6bea2c_1fc9_64fa_127b_cc90adfb0557["decodeBulkStringEndOfLine()"]
  1d4f1b51_c148_ce38_593c_4e951cf4f9b6 -->|calls| ac6bea2c_1fc9_64fa_127b_cc90adfb0557
  4dcee4b2_7f61_d951_b580_50f0852e5732["decodeBulkStringContent()"]
  1d4f1b51_c148_ce38_593c_4e951cf4f9b6 -->|calls| 4dcee4b2_7f61_d951_b580_50f0852e5732
  style 1d4f1b51_c148_ce38_593c_4e951cf4f9b6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-redis/src/main/java/io/netty/handler/codec/redis/RedisDecoder.java lines 195–209

    private boolean decodeBulkString(ByteBuf in, List<Object> out) throws Exception {
        switch (remainingBulkLength) {
        case RedisConstants.NULL_VALUE: // $-1\r\n
            out.add(FullBulkStringRedisMessage.NULL_INSTANCE);
            resetDecoder();
            return true;
        case 0:
            state = State.DECODE_BULK_STRING_EOL;
            return decodeBulkStringEndOfLine(in, out);
        default: // expectedBulkLength is always positive.
            out.add(new BulkStringHeaderRedisMessage(remainingBulkLength));
            state = State.DECODE_BULK_STRING_CONTENT;
            return decodeBulkStringContent(in, out);
        }
    }