readPlaintextData() — netty Function Reference

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

Function java Buffer Allocators calls 3 called by 1

Entity Profile

Buffer→ Allocators→ readPlaintextData() — netty Function Reference

Dependency Diagram

graph TD
  83be4cf0_d974_4b53_c0f0_3c2db0cacdb8["readPlaintextData()"]
  df1ad81e_e5bf_85e6_4418_db301b4c3e66["ReferenceCountedOpenSslEngine"]
  83be4cf0_d974_4b53_c0f0_3c2db0cacdb8 -->|defined in| df1ad81e_e5bf_85e6_4418_db301b4c3e66
  9f77679b_188a_ea47_0bb0_025af752e7f4["SSLEngineResult()"]
  9f77679b_188a_ea47_0bb0_025af752e7f4 -->|calls| 83be4cf0_d974_4b53_c0f0_3c2db0cacdb8
  5a654cb5_a186_f8ae_d05b_d708ac558525["bufferAddress()"]
  83be4cf0_d974_4b53_c0f0_3c2db0cacdb8 -->|calls| 5a654cb5_a186_f8ae_d05b_d708ac558525
  b7412f9d_ee29_b680_dad4_809824fc5c93["maxEncryptedPacketLength0()"]
  83be4cf0_d974_4b53_c0f0_3c2db0cacdb8 -->|calls| b7412f9d_ee29_b680_dad4_809824fc5c93
  62c22963_254e_558e_59f0_10304b0c83d2["release()"]
  83be4cf0_d974_4b53_c0f0_3c2db0cacdb8 -->|calls| 62c22963_254e_558e_59f0_10304b0c83d2
  style 83be4cf0_d974_4b53_c0f0_3c2db0cacdb8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/ssl/ReferenceCountedOpenSslEngine.java lines 677–702

    private int readPlaintextData(final ByteBuffer dst) throws SSLException {
        final int sslRead;
        final int pos = dst.position();
        if (dst.isDirect()) {
            sslRead = SSL.readFromSSL(ssl, bufferAddress(dst) + pos, dst.limit() - pos);
            if (sslRead > 0) {
                dst.position(pos + sslRead);
            }
        } else {
            final int limit = dst.limit();
            final int len = min(maxEncryptedPacketLength0(), limit - pos);
            final ByteBuf buf = alloc.directBuffer(len);
            try {
                sslRead = SSL.readFromSSL(ssl, memoryAddress(buf), len);
                if (sslRead > 0) {
                    dst.limit(pos + sslRead);
                    buf.getBytes(buf.readerIndex(), dst);
                    dst.limit(limit);
                }
            } finally {
                buf.release();
            }
        }

        return sslRead;
    }