encodeHeaders() — netty Function Reference

Architecture documentation for the encodeHeaders() function in StompSubframeEncoder.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 2

Entity Profile

Buffer→ Allocators→ encodeHeaders() — netty Function Reference

Dependency Diagram

graph TD
  24221f37_d904_c246_ea24_6ac0a19ecb27["encodeHeaders()"]
  453c4953_0f2f_6759_71f5_48a24c8c51c0["StompSubframeEncoder"]
  24221f37_d904_c246_ea24_6ac0a19ecb27 -->|defined in| 453c4953_0f2f_6759_71f5_48a24c8c51c0
  4300cd27_b0e3_023a_2081_dbc750ab030a["encode()"]
  4300cd27_b0e3_023a_2081_dbc750ab030a -->|calls| 24221f37_d904_c246_ea24_6ac0a19ecb27
  54149930_1362_82ca_47cf_8b8c00eead94["ByteBuf()"]
  54149930_1362_82ca_47cf_8b8c00eead94 -->|calls| 24221f37_d904_c246_ea24_6ac0a19ecb27
  aab7d673_d0f1_5ff0_6f7d_923fbc02d7c7["shouldEscape()"]
  24221f37_d904_c246_ea24_6ac0a19ecb27 -->|calls| aab7d673_d0f1_5ff0_6f7d_923fbc02d7c7
  style 24221f37_d904_c246_ea24_6ac0a19ecb27 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-stomp/src/main/java/io/netty/handler/codec/stomp/StompSubframeEncoder.java lines 174–201

    private static void encodeHeaders(StompHeadersSubframe frame, ByteBuf buf) {
        StompCommand command = frame.command();
        ByteBufUtil.writeUtf8(buf, command.toString());
        buf.writeByte(StompConstants.LF);

        boolean shouldEscape = shouldEscape(command);
        LinkedHashMap<CharSequence, CharSequence> cache = ESCAPE_HEADER_KEY_CACHE.get();
        for (Entry<CharSequence, CharSequence> entry : frame.headers()) {
            CharSequence headerKey = entry.getKey();
            if (shouldEscape) {
                CharSequence cachedHeaderKey = cache.get(headerKey);
                if (cachedHeaderKey == null) {
                    cachedHeaderKey = escape(headerKey);
                    cache.put(headerKey, cachedHeaderKey);
                }
                headerKey = cachedHeaderKey;
            }

            ByteBufUtil.writeUtf8(buf, headerKey);
            buf.writeByte(StompConstants.COLON);

            CharSequence headerValue = shouldEscape? escape(entry.getValue()) : entry.getValue();
            ByteBufUtil.writeUtf8(buf, headerValue);
            buf.writeByte(StompConstants.LF);
        }

        buf.writeByte(StompConstants.LF);
    }