setHandshakeSuccess() — netty Function Reference

Source Code

handler/src/main/java/io/netty/handler/ssl/SslHandler.java lines 1990–2024

    private boolean setHandshakeSuccess() throws SSLException {
        // Our control flow may invoke this method multiple times for a single FINISHED event. For example
        // wrapNonAppData may drain pendingUnencryptedWrites in wrap which transitions to handshake from FINISHED to
        // NOT_HANDSHAKING which invokes setHandshakeSuccess, and then wrapNonAppData also directly invokes this method.
        final SSLSession session = engine.getSession();
        if (resumptionController != null && !handshakePromise.isDone()) {
            try {
                if (resumptionController.validateResumeIfNeeded(engine) && logger.isDebugEnabled()) {
                    logger.debug("{} Resumed and reauthenticated session", ctx.channel());
                }
            } catch (CertificateException e) {
                SSLHandshakeException exception = new SSLHandshakeException(e.getMessage());
                exception.initCause(e);
                throw exception;
            }
        }
        final boolean notified = !handshakePromise.isDone() && handshakePromise.trySuccess(ctx.channel());
        if (notified) {
            if (logger.isDebugEnabled()) {
                logger.debug(
                        "{} HANDSHAKEN: protocol:{} cipher suite:{}",
                        ctx.channel(),
                        session.getProtocol(),
                        session.getCipherSuite());
            }
            ctx.fireUserEventTriggered(SslHandshakeCompletionEvent.SUCCESS);
        }
        if (isStateSet(STATE_READ_DURING_HANDSHAKE)) {
            clearState(STATE_READ_DURING_HANDSHAKE);
            if (!ctx.channel().config().isAutoRead()) {
                ctx.read();
            }
        }
        return notified;
    }