Javadoc fixes
This commit is contained in:
parent
e5319b6600
commit
fb6ce4989a
@ -277,6 +277,10 @@ public class SslHandler
|
|||||||
return engine;
|
return engine;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Starts the SSL / TLS handshake and returns a {@link ChannelFuture} that will
|
||||||
|
* get notified once the handshake completes.
|
||||||
|
*/
|
||||||
public ChannelFuture handshake() {
|
public ChannelFuture handshake() {
|
||||||
return handshake(ctx.newFuture());
|
return handshake(ctx.newFuture());
|
||||||
}
|
}
|
||||||
@ -340,6 +344,11 @@ public class SslHandler
|
|||||||
return close(ctx.newFuture());
|
return close(ctx.newFuture());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* See {@link #close()}
|
||||||
|
|
||||||
|
*/
|
||||||
public ChannelFuture close(final ChannelFuture future) {
|
public ChannelFuture close(final ChannelFuture future) {
|
||||||
final ChannelHandlerContext ctx = this.ctx;
|
final ChannelHandlerContext ctx = this.ctx;
|
||||||
ctx.executor().execute(new Runnable() {
|
ctx.executor().execute(new Runnable() {
|
||||||
@ -856,6 +865,9 @@ public class SslHandler
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Notify all the handshake futures about the successfully handshake
|
||||||
|
*/
|
||||||
private void setHandshakeSuccess() {
|
private void setHandshakeSuccess() {
|
||||||
for (;;) {
|
for (;;) {
|
||||||
ChannelFuture f = handshakeFutures.poll();
|
ChannelFuture f = handshakeFutures.poll();
|
||||||
@ -866,6 +878,9 @@ public class SslHandler
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Notify all the handshake futures about the failure during the handshake.
|
||||||
|
*/
|
||||||
private void setHandshakeFailure(Throwable cause) {
|
private void setHandshakeFailure(Throwable cause) {
|
||||||
// Release all resources such as internal buffers that SSLEngine
|
// Release all resources such as internal buffers that SSLEngine
|
||||||
// is managing.
|
// is managing.
|
||||||
@ -967,7 +982,7 @@ public class SslHandler
|
|||||||
@Override
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
logger.warn(
|
logger.warn(
|
||||||
ctx.channel() + " last lssssswrite attempt timed out." +
|
ctx.channel() + " last write attempt timed out." +
|
||||||
" Force-closing the connection.");
|
" Force-closing the connection.");
|
||||||
ctx.close(closeFuture);
|
ctx.close(closeFuture);
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user