setUnwritable() — netty Function Reference

Architecture documentation for the setUnwritable() function in ChannelOutboundBuffer.java from the netty codebase.

Function java Buffer Telemetry calls 1 called by 1

Entity Profile

Buffer→ Telemetry→ setUnwritable() — netty Function Reference

Dependency Diagram

graph TD
  f76ba1c4_631e_5741_df8d_40ab464c2c2d["setUnwritable()"]
  509b1bc5_7cdc_9ee4_03d9_31eb2203d807["ChannelOutboundBuffer"]
  f76ba1c4_631e_5741_df8d_40ab464c2c2d -->|defined in| 509b1bc5_7cdc_9ee4_03d9_31eb2203d807
  edd2d6a1_6e66_f250_6201_d45b2f33f2fa["incrementPendingOutboundBytes()"]
  edd2d6a1_6e66_f250_6201_d45b2f33f2fa -->|calls| f76ba1c4_631e_5741_df8d_40ab464c2c2d
  9f76e4fc_265c_9f0c_23ed_b66d251214a9["fireChannelWritabilityChanged()"]
  f76ba1c4_631e_5741_df8d_40ab464c2c2d -->|calls| 9f76e4fc_265c_9f0c_23ed_b66d251214a9
  style f76ba1c4_631e_5741_df8d_40ab464c2c2d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java lines 631–642

    private void setUnwritable(boolean invokeLater) {
        for (;;) {
            final int oldValue = unwritable;
            final int newValue = oldValue | 1;
            if (UNWRITABLE_UPDATER.compareAndSet(this, oldValue, newValue)) {
                if (oldValue == 0) {
                    fireChannelWritabilityChanged(invokeLater);
                }
                break;
            }
        }
    }