runAndResetNeedTask() — netty Function Reference

Architecture documentation for the runAndResetNeedTask() function in ReferenceCountedOpenSslEngine.java from the netty codebase.

Function java Buffer Allocators calls 3 called by 2

Entity Profile

Buffer→ Allocators→ runAndResetNeedTask() — netty Function Reference

Dependency Diagram

graph TD
  37991072_601c_2454_d68c_ade81585d80b["runAndResetNeedTask()"]
  df1ad81e_e5bf_85e6_4418_db301b4c3e66["ReferenceCountedOpenSslEngine"]
  37991072_601c_2454_d68c_ade81585d80b -->|defined in| df1ad81e_e5bf_85e6_4418_db301b4c3e66
  e03643cf_2cc0_b8e3_9c4e_9952056e8476["Runnable()"]
  e03643cf_2cc0_b8e3_9c4e_9952056e8476 -->|calls| 37991072_601c_2454_d68c_ade81585d80b
  95ae4cb4_5bf5_b0cb_5de8_5e089df71a1a["run()"]
  95ae4cb4_5bf5_b0cb_5de8_5e089df71a1a -->|calls| 37991072_601c_2454_d68c_ade81585d80b
  c4b3e9d1_8ba5_707f_4649_4d5a628a2433["shutdown()"]
  37991072_601c_2454_d68c_ade81585d80b -->|calls| c4b3e9d1_8ba5_707f_4649_4d5a628a2433
  95ae4cb4_5bf5_b0cb_5de8_5e089df71a1a["run()"]
  37991072_601c_2454_d68c_ade81585d80b -->|calls| 95ae4cb4_5bf5_b0cb_5de8_5e089df71a1a
  3ddadf00_257d_ea94_ec2c_9afd83ac4524["getHandshakeStatus()"]
  37991072_601c_2454_d68c_ade81585d80b -->|calls| 3ddadf00_257d_ea94_ec2c_9afd83ac4524
  style 37991072_601c_2454_d68c_ade81585d80b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/ssl/ReferenceCountedOpenSslEngine.java lines 1543–1566

    private void runAndResetNeedTask(Runnable task) {
        // We need to synchronize on the ReferenceCountedOpenSslEngine, we are sure the SSL object
        // will not be freed by the user calling for example shutdown() concurrently.
        synchronized (ReferenceCountedOpenSslEngine.this) {
            try {
                if (destroyed) {
                    // The engine was destroyed in the meantime, just return.
                    return;
                }
                task.run();
                if (handshakeState != HandshakeState.FINISHED && !destroyed) {
                    // Call SSL.doHandshake(...) If the handshake was not finished yet. This might be needed
                    // to fill the application buffer and so have getHandshakeStatus() return the right value
                    // in this case.
                    if (SSL.doHandshake(ssl) <= 0) {
                        SSL.clearError();
                    }
                }
            } finally {
                // The task was run, reset needTask to false so getHandshakeStatus() returns the correct value.
                needTask = false;
            }
        }
    }