RedisMessage() — netty Function Reference

Architecture documentation for the RedisMessage() function in RedisArrayAggregator.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ RedisMessage() — netty Function Reference

Dependency Diagram

graph TD
  36052a91_1ebd_bdfa_c856_32922cf0b94b["RedisMessage()"]
  012bd3a5_4e03_f9eb_6cc8_66f49859fdf6["RedisArrayAggregator"]
  36052a91_1ebd_bdfa_c856_32922cf0b94b -->|defined in| 012bd3a5_4e03_f9eb_6cc8_66f49859fdf6
  1c6d4545_6b8e_14fe_7412_cefb3d84eabb["AggregateState()"]
  36052a91_1ebd_bdfa_c856_32922cf0b94b -->|calls| 1c6d4545_6b8e_14fe_7412_cefb3d84eabb
  style 36052a91_1ebd_bdfa_c856_32922cf0b94b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-redis/src/main/java/io/netty/handler/codec/redis/RedisArrayAggregator.java lines 70–87

    private RedisMessage decodeRedisArrayHeader(ArrayHeaderRedisMessage header) {
        if (header.isNull()) {
            return ArrayRedisMessage.NULL_INSTANCE;
        } else if (header.length() == 0L) {
            return ArrayRedisMessage.EMPTY_INSTANCE;
        } else if (header.length() > 0L) {
            // Currently, this codec doesn't support `long` length for arrays because Java's List.size() is int.
            if (header.length() > Integer.MAX_VALUE) {
                throw new CodecException("this codec doesn't support longer length than " + Integer.MAX_VALUE);
            }

            // start aggregating array
            depths.push(new AggregateState((int) header.length()));
            return null;
        } else {
            throw new CodecException("bad length: " + header.length());
        }
    }