|
|
|
|
@ -23,6 +23,7 @@ import java.util.concurrent.atomic.AtomicLong;
@@ -23,6 +23,7 @@ import java.util.concurrent.atomic.AtomicLong;
|
|
|
|
|
|
|
|
|
|
import javax.net.ssl.SSLSession; |
|
|
|
|
|
|
|
|
|
import io.netty.channel.Channel; |
|
|
|
|
import io.netty.handler.codec.http.HttpHeaderNames; |
|
|
|
|
import io.netty.handler.codec.http.cookie.Cookie; |
|
|
|
|
import io.netty.handler.ssl.SslHandler; |
|
|
|
|
@ -160,7 +161,11 @@ class ReactorServerHttpRequest extends AbstractServerHttpRequest {
@@ -160,7 +161,11 @@ class ReactorServerHttpRequest extends AbstractServerHttpRequest {
|
|
|
|
|
@Override |
|
|
|
|
@Nullable |
|
|
|
|
protected SslInfo initSslInfo() { |
|
|
|
|
SslHandler sslHandler = ((Connection) this.request).channel().pipeline().get(SslHandler.class); |
|
|
|
|
Channel channel = ((Connection) this.request).channel(); |
|
|
|
|
SslHandler sslHandler = channel.pipeline().get(SslHandler.class); |
|
|
|
|
if (sslHandler == null && channel.parent() != null) { // HTTP/2
|
|
|
|
|
sslHandler = channel.parent().pipeline().get(SslHandler.class); |
|
|
|
|
} |
|
|
|
|
if (sslHandler != null) { |
|
|
|
|
SSLSession session = sslHandler.engine().getSession(); |
|
|
|
|
return new DefaultSslInfo(session); |
|
|
|
|
|