Closing inactive channel early

Author: dlarge

src/main/java/com/emc/mongoose/storage/driver/coop/netty/NettyStorageDriverBase.java

@@ -600,7 +600,6 @@ public void complete(final Channel channel, final O op) {
 			if (channel != null) {
 				connPool.release(channel);
 			}
-
 			channel.attr(ATTR_KEY_RELEASED).set(true);
 		}
 		handleCompleted(op);

src/main/java/com/emc/mongoose/storage/driver/coop/netty/ResponseHandlerBase.java

@@ -3,6 +3,8 @@
 import com.emc.mongoose.base.item.op.Operation;
 import com.emc.mongoose.base.item.Item;
 import com.emc.mongoose.base.logging.LogUtil;
+import com.emc.mongoose.base.logging.Loggers;
+
 import static com.emc.mongoose.base.Constants.KEY_CLASS_NAME;
 import static com.emc.mongoose.base.Exceptions.throwUncheckedIfInterrupted;
 import static com.emc.mongoose.base.item.op.Operation.Status.INTERRUPTED;
@@ -87,4 +89,11 @@ public final void userEventTriggered(final ChannelHandlerContext ctx, final Obje
 			throw new SocketTimeoutException();
 		}
 	}
+
+	@Override
+	public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+		ctx.fireChannelInactive();
+		Loggers.ERR.debug("Detected inactive channel, closing");
+		ctx.channel().close();
+	}
 }