You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by fr...@apache.org on 2017/10/26 14:17:01 UTC
svn commit: r1813406 -
/jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java
Author: frm
Date: Thu Oct 26 14:17:01 2017
New Revision: 1813406
URL: http://svn.apache.org/viewvc?rev=1813406&view=rev
Log:
OAK-6829 - Let ForwardHandler react to channel active/inactive events
Modified:
jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java
Modified: jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java?rev=1813406&r1=1813405&r2=1813406&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java (original)
+++ jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java Thu Oct 26 14:17:01 2017
@@ -62,7 +62,7 @@ class ForwardHandler extends ChannelInbo
}
@Override
- public void channelRegistered(final ChannelHandlerContext ctx) throws Exception {
+ public void channelActive(ChannelHandlerContext ctx) throws Exception {
group = new NioEventLoopGroup(0, r -> {
return new Thread(r, String.format("forward-handler-%d", threadNumber.getAndIncrement()));
});
@@ -93,7 +93,7 @@ class ForwardHandler extends ChannelInbo
}
@Override
- public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
+ public void channelInactive(ChannelHandlerContext ctx) throws Exception {
if (remote.close().awaitUninterruptibly(1, TimeUnit.SECONDS)) {
log.debug("Connection to remote host closed");
} else {