incompleteWrite() — netty Function Reference

Architecture documentation for the incompleteWrite() function in AbstractNioByteChannel.java from the netty codebase.

Function java Buffer Telemetry calls 2 called by 2

Entity Profile

Buffer→ Telemetry→ incompleteWrite() — netty Function Reference

Dependency Diagram

graph TD
  46da3fe7_43e8_758e_f039_58b516d9c088["incompleteWrite()"]
  81dd42bf_4dab_740c_6405_14423e9ad1f8["AbstractNioByteChannel"]
  46da3fe7_43e8_758e_f039_58b516d9c088 -->|defined in| 81dd42bf_4dab_740c_6405_14423e9ad1f8
  254496f6_25fc_84de_730e_8f3b0842a4b3["doWrite0()"]
  254496f6_25fc_84de_730e_8f3b0842a4b3 -->|calls| 46da3fe7_43e8_758e_f039_58b516d9c088
  a28491f1_6177_d155_eb85_0f25c627fb66["doWrite()"]
  a28491f1_6177_d155_eb85_0f25c627fb66 -->|calls| 46da3fe7_43e8_758e_f039_58b516d9c088
  a60141c3_7318_47c8_4803_42326e72fc35["setOpWrite()"]
  46da3fe7_43e8_758e_f039_58b516d9c088 -->|calls| a60141c3_7318_47c8_4803_42326e72fc35
  d90218d8_6da4_9b59_fb11_460b955cc09a["clearOpWrite()"]
  46da3fe7_43e8_758e_f039_58b516d9c088 -->|calls| d90218d8_6da4_9b59_fb11_460b955cc09a
  style 46da3fe7_43e8_758e_f039_58b516d9c088 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/nio/AbstractNioByteChannel.java lines 299–313

    protected final void incompleteWrite(boolean setOpWrite) {
        // Did not write completely.
        if (setOpWrite) {
            setOpWrite();
        } else {
            // It is possible that we have set the write OP, woken up by NIO because the socket is writable, and then
            // use our write quantum. In this case we no longer want to set the write OP because the socket is still
            // writable (as far as we know). We will find out next time we attempt to write if the socket is writable
            // and set the write OP if necessary.
            clearOpWrite();

            // Schedule flush again later so other tasks can be picked up in the meantime
            eventLoop().execute(flushTask);
        }
    }