forwardAllWithCloseNotify() — netty Function Reference

Architecture documentation for the forwardAllWithCloseNotify() function in CloseNotifyTest.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 1

Entity Profile

Buffer→ Allocators→ forwardAllWithCloseNotify() — netty Function Reference

Dependency Diagram

graph TD
  aaff46e6_d1c4_937c_05e7_56dcbca48920["forwardAllWithCloseNotify()"]
  91635dfc_456c_fec9_4413_a1ee45d49032["CloseNotifyTest"]
  aaff46e6_d1c4_937c_05e7_56dcbca48920 -->|defined in| 91635dfc_456c_fec9_4413_a1ee45d49032
  c8dc5de5_36bd_d22b_8ec3_7c93cc9586c8["eventsOrder()"]
  c8dc5de5_36bd_d22b_8ec3_7c93cc9586c8 -->|calls| aaff46e6_d1c4_937c_05e7_56dcbca48920
  3b5ef0d4_0faf_0554_a2cf_8eddf09ebf76["assertCloseNotify()"]
  aaff46e6_d1c4_937c_05e7_56dcbca48920 -->|calls| 3b5ef0d4_0faf_0554_a2cf_8eddf09ebf76
  style aaff46e6_d1c4_937c_05e7_56dcbca48920 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/ssl/CloseNotifyTest.java lines 193–205

    private static void forwardAllWithCloseNotify(EmbeddedChannel from, EmbeddedChannel to) {
        ByteBuf cumulation = EMPTY_BUFFER;
        ByteBuf in, closeNotify = null;
        while ((in = from.readOutbound()) != null) {
            if (closeNotify != null) {
                closeNotify.release();
            }
            closeNotify = in.duplicate();
            cumulation = MERGE_CUMULATOR.cumulate(ALLOC, cumulation, in.retain());
        }
        assertCloseNotify(closeNotify);
        to.writeInbound(cumulation);
    }