diff --git a/testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketShutdownOutputByPeerTest.java b/testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketShutdownOutputByPeerTest.java index 7baf1e6676..98ebc1b8f1 100644 --- a/testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketShutdownOutputByPeerTest.java +++ b/testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketShutdownOutputByPeerTest.java @@ -20,7 +20,7 @@ import io.netty.bootstrap.ServerBootstrap; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundByteHandlerAdapter; -import io.netty.channel.ChannelInputShutdownEvent; +import io.netty.channel.socket.ChannelInputShutdownEvent; import io.netty.channel.ChannelOption; import io.netty.channel.socket.SocketChannel; diff --git a/transport/src/main/java/io/netty/channel/ChannelInputShutdownEvent.java b/transport/src/main/java/io/netty/channel/socket/ChannelInputShutdownEvent.java similarity index 64% rename from transport/src/main/java/io/netty/channel/ChannelInputShutdownEvent.java rename to transport/src/main/java/io/netty/channel/socket/ChannelInputShutdownEvent.java index 06f213811b..9d98ab16e1 100644 --- a/transport/src/main/java/io/netty/channel/ChannelInputShutdownEvent.java +++ b/transport/src/main/java/io/netty/channel/socket/ChannelInputShutdownEvent.java @@ -13,10 +13,22 @@ * License for the specific language governing permissions and limitations * under the License. */ -package io.netty.channel; +package io.netty.channel.socket; +import io.netty.channel.ChannelHandlerContext; +import io.netty.channel.ChannelStateHandler; + +/** + * Special event which will be fired and passed to the + * {@link ChannelStateHandler#userEventTriggered(ChannelHandlerContext, Object)} methods once the input of + * a {@link SocketChannel} was shutdown and the {@link SocketChannelConfig#isAllowHalfClosure()} method returns + * {@code true}. + */ public final class ChannelInputShutdownEvent { + /** + * Instance to use + */ public static final ChannelInputShutdownEvent INSTANCE = new ChannelInputShutdownEvent(); private ChannelInputShutdownEvent() { } diff --git a/transport/src/main/java/io/netty/channel/socket/SocketChannelConfig.java b/transport/src/main/java/io/netty/channel/socket/SocketChannelConfig.java index 0522980c22..cec4db31c7 100644 --- a/transport/src/main/java/io/netty/channel/socket/SocketChannelConfig.java +++ b/transport/src/main/java/io/netty/channel/socket/SocketChannelConfig.java @@ -19,7 +19,6 @@ import io.netty.buffer.ByteBufAllocator; import io.netty.channel.ChannelConfig; import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandlerContext; -import io.netty.channel.ChannelInputShutdownEvent; import java.net.Socket; import java.net.StandardSocketOptions; diff --git a/transport/src/main/java/io/netty/channel/socket/aio/AioSocketChannel.java b/transport/src/main/java/io/netty/channel/socket/aio/AioSocketChannel.java index e19c99714a..9c396e4aee 100755 --- a/transport/src/main/java/io/netty/channel/socket/aio/AioSocketChannel.java +++ b/transport/src/main/java/io/netty/channel/socket/aio/AioSocketChannel.java @@ -20,7 +20,7 @@ import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelException; import io.netty.channel.ChannelFlushFutureNotifier; import io.netty.channel.ChannelFuture; -import io.netty.channel.ChannelInputShutdownEvent; +import io.netty.channel.socket.ChannelInputShutdownEvent; import io.netty.channel.ChannelMetadata; import io.netty.channel.ChannelPipeline; import io.netty.channel.EventLoop; diff --git a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioByteChannel.java b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioByteChannel.java index f6023f1514..031b517aaf 100755 --- a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioByteChannel.java +++ b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioByteChannel.java @@ -18,7 +18,7 @@ package io.netty.channel.socket.nio; import io.netty.buffer.ByteBuf; import io.netty.channel.Channel; import io.netty.channel.ChannelFuture; -import io.netty.channel.ChannelInputShutdownEvent; +import io.netty.channel.socket.ChannelInputShutdownEvent; import io.netty.channel.ChannelOption; import io.netty.channel.ChannelPipeline; import io.netty.channel.FileRegion; diff --git a/transport/src/main/java/io/netty/channel/socket/oio/AbstractOioByteChannel.java b/transport/src/main/java/io/netty/channel/socket/oio/AbstractOioByteChannel.java index 4f9b0ac18c..91ab8c01d8 100755 --- a/transport/src/main/java/io/netty/channel/socket/oio/AbstractOioByteChannel.java +++ b/transport/src/main/java/io/netty/channel/socket/oio/AbstractOioByteChannel.java @@ -17,7 +17,7 @@ package io.netty.channel.socket.oio; import io.netty.buffer.ByteBuf; import io.netty.channel.Channel; -import io.netty.channel.ChannelInputShutdownEvent; +import io.netty.channel.socket.ChannelInputShutdownEvent; import io.netty.channel.ChannelOption; import io.netty.channel.ChannelPipeline;