flush0() — netty Function Reference

Architecture documentation for the flush0() function in AbstractChannel.java from the netty codebase.

Function java Buffer Search calls 2 called by 3

Entity Profile

Buffer→ Search→ flush0() — netty Function Reference

Dependency Diagram

graph TD
  ae5386b7_9fd3_54fd_2f3c_29a33b11e74f["flush0()"]
  330d05c9_85ca_2e57_92f5_e996fb442b81["AbstractUnsafe"]
  ae5386b7_9fd3_54fd_2f3c_29a33b11e74f -->|defined in| 330d05c9_85ca_2e57_92f5_e996fb442b81
  ab3014f1_ecc6_2385_572a_896945c2111a["write()"]
  ab3014f1_ecc6_2385_572a_896945c2111a -->|calls| ae5386b7_9fd3_54fd_2f3c_29a33b11e74f
  adc3d999_d62f_cced_c9c8_f297fb052141["flush()"]
  adc3d999_d62f_cced_c9c8_f297fb052141 -->|calls| ae5386b7_9fd3_54fd_2f3c_29a33b11e74f
  7304e576_dd6e_3305_cf0d_edd0fc40c205["handleWriteError()"]
  7304e576_dd6e_3305_cf0d_edd0fc40c205 -->|calls| ae5386b7_9fd3_54fd_2f3c_29a33b11e74f
  9ea78e3c_2f67_b531_e6cb_054a15e00227["doWrite()"]
  ae5386b7_9fd3_54fd_2f3c_29a33b11e74f -->|calls| 9ea78e3c_2f67_b531_e6cb_054a15e00227
  7304e576_dd6e_3305_cf0d_edd0fc40c205["handleWriteError()"]
  ae5386b7_9fd3_54fd_2f3c_29a33b11e74f -->|calls| 7304e576_dd6e_3305_cf0d_edd0fc40c205
  style ae5386b7_9fd3_54fd_2f3c_29a33b11e74f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/AbstractChannel.java lines 761–800

        @SuppressWarnings("deprecation")
        protected void flush0() {
            if (inFlush0) {
                // Avoid re-entrance
                return;
            }

            final ChannelOutboundBuffer outboundBuffer = this.outboundBuffer;
            if (outboundBuffer == null || outboundBuffer.isEmpty()) {
                return;
            }

            inFlush0 = true;

            // Mark all pending write requests as failure if the channel is inactive.
            if (!isActive()) {
                try {
                    // Check if we need to generate the exception at all.
                    if (!outboundBuffer.isEmpty()) {
                        if (isOpen()) {
                            outboundBuffer.failFlushed(new NotYetConnectedException(), true);
                        } else {
                            // Do not trigger channelWritabilityChanged because the channel is closed already.
                            outboundBuffer.failFlushed(newClosedChannelException(initialCloseCause, "flush0()"), false);
                        }
                    }
                } finally {
                    inFlush0 = false;
                }
                return;
            }

            try {
                doWrite(outboundBuffer);
            } catch (Throwable t) {
                handleWriteError(t);
            } finally {
                inFlush0 = false;
            }
        }