taskError() — netty Function Reference

Architecture documentation for the taskError() function in SslHandler.java from the netty codebase.

Function java Buffer Allocators calls 6 called by 1

Entity Profile

Buffer→ Allocators→ taskError() — netty Function Reference

Dependency Diagram

graph TD
  8cae5f97_939d_55fc_31c2_c6131add51c2["taskError()"]
  4971d882_98ff_3ffd_f66b_31ea649497b3["SslTasksRunner"]
  8cae5f97_939d_55fc_31c2_c6131add51c2 -->|defined in| 4971d882_98ff_3ffd_f66b_31ea649497b3
  3767fed6_8ef0_e61c_ca65_bd1e0902b8bb["resumeOnEventExecutor()"]
  3767fed6_8ef0_e61c_ca65_bd1e0902b8bb -->|calls| 8cae5f97_939d_55fc_31c2_c6131add51c2
  51b61e7d_0f6d_53c7_ed6a_56a55b2ed5a7["unwrap()"]
  8cae5f97_939d_55fc_31c2_c6131add51c2 -->|calls| 51b61e7d_0f6d_53c7_ed6a_56a55b2ed5a7
  6aaf84ff_874c_1428_d191_d32a98e4c16e["decode()"]
  8cae5f97_939d_55fc_31c2_c6131add51c2 -->|calls| 6aaf84ff_874c_1428_d191_d32a98e4c16e
  1807eec1_6f0b_edf4_8d02_a6d15d3c18c1["handleUnwrapThrowable()"]
  8cae5f97_939d_55fc_31c2_c6131add51c2 -->|calls| 1807eec1_6f0b_edf4_8d02_a6d15d3c18c1
  6f2ad3ca_d892_92d8_e5db_c67eb1473ab2["safeExceptionCaught()"]
  8cae5f97_939d_55fc_31c2_c6131add51c2 -->|calls| 6f2ad3ca_d892_92d8_e5db_c67eb1473ab2
  23ca304b_58b0_41b7_c5ca_0810728d5ede["setHandshakeFailure()"]
  8cae5f97_939d_55fc_31c2_c6131add51c2 -->|calls| 23ca304b_58b0_41b7_c5ca_0810728d5ede
  97e069a2_d061_156b_5f87_33bbcfd62f59["forceFlush()"]
  8cae5f97_939d_55fc_31c2_c6131add51c2 -->|calls| 97e069a2_d061_156b_5f87_33bbcfd62f59
  style 8cae5f97_939d_55fc_31c2_c6131add51c2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/ssl/SslHandler.java lines 1785–1800

        private void taskError(Throwable e) {
            if (inUnwrap) {
                // As the error happened while the task was scheduled as part of unwrap(...) we also need to ensure
                // we fire it through the pipeline as inbound error to be consistent with what we do in decode(...).
                //
                // This will also ensure we fail the handshake future and flush all produced data.
                try {
                    handleUnwrapThrowable(ctx, e);
                } catch (Throwable cause) {
                    safeExceptionCaught(cause);
                }
            } else {
                setHandshakeFailure(ctx, e);
                forceFlush(ctx);
            }
        }