This is an automated email from the git hooks/post-receive script. ebourg-guest pushed a commit to branch master in repository netty.
commit bec748fe3946ac22bf4eee43b6dfc6ad17055a8b Merge: 6c0c87f afd34f3 Author: Emmanuel Bourg <[email protected]> Date: Sat Sep 12 23:00:06 2015 +0200 Merge tag 'upstream/4.0.30' Upstream version 4.0.30 .fbprefs | 159 + .gitignore | 32 + .travis.yml | 12 + CONTRIBUTING.md | 46 + LICENSE.txt | 202 + NOTICE.txt | 143 + README.md | 26 + all/pom.xml | 521 ++ buffer/pom.xml | 38 + .../main/java/io/netty/buffer/AbstractByteBuf.java | 1185 ++++ .../io/netty/buffer/AbstractByteBufAllocator.java | 219 + .../io/netty/buffer/AbstractDerivedByteBuf.java | 80 + .../buffer/AbstractReferenceCountedByteBuf.java | 140 + .../io/netty/buffer/AdvancedLeakAwareByteBuf.java | 724 +++ buffer/src/main/java/io/netty/buffer/ByteBuf.java | 1895 ++++++ .../java/io/netty/buffer/ByteBufAllocator.java | 128 + .../main/java/io/netty/buffer/ByteBufHolder.java | 45 + .../java/io/netty/buffer/ByteBufInputStream.java | 257 + .../java/io/netty/buffer/ByteBufOutputStream.java | 146 + .../java/io/netty/buffer/ByteBufProcessor.java | 126 + .../src/main/java/io/netty/buffer/ByteBufUtil.java | 737 +++ .../java/io/netty/buffer/CompositeByteBuf.java | 1667 ++++++ .../java/io/netty/buffer/DefaultByteBufHolder.java | 85 + .../java/io/netty/buffer/DuplicatedByteBuf.java | 315 + .../main/java/io/netty/buffer/EmptyByteBuf.java | 870 +++ .../io/netty/buffer/FixedCompositeByteBuf.java | 572 ++ .../src/main/java/io/netty/buffer/PoolArena.java | 688 +++ .../main/java/io/netty/buffer/PoolArenaMetric.java | 130 + .../src/main/java/io/netty/buffer/PoolChunk.java | 443 ++ .../main/java/io/netty/buffer/PoolChunkList.java | 167 + .../java/io/netty/buffer/PoolChunkListMetric.java | 32 + .../main/java/io/netty/buffer/PoolChunkMetric.java | 37 + .../src/main/java/io/netty/buffer/PoolSubpage.java | 253 + .../java/io/netty/buffer/PoolSubpageMetric.java | 43 + .../main/java/io/netty/buffer/PoolThreadCache.java | 484 ++ .../main/java/io/netty/buffer/PooledByteBuf.java | 173 + .../io/netty/buffer/PooledByteBufAllocator.java | 426 ++ .../java/io/netty/buffer/PooledDirectByteBuf.java | 377 ++ .../io/netty/buffer/PooledDuplicatedByteBuf.java | 56 + .../java/io/netty/buffer/PooledHeapByteBuf.java | 308 + .../java/io/netty/buffer/PooledSlicedByteBuf.java | 56 + .../io/netty/buffer/PooledUnsafeDirectByteBuf.java | 397 ++ .../main/java/io/netty/buffer/ReadOnlyByteBuf.java | 317 + .../io/netty/buffer/ReadOnlyByteBufferBuf.java | 335 ++ .../netty/buffer/ReadOnlyUnsafeDirectByteBuf.java | 138 + .../io/netty/buffer/SimpleLeakAwareByteBuf.java | 79 + .../main/java/io/netty/buffer/SlicedByteBuf.java | 305 + .../main/java/io/netty/buffer/SwappedByteBuf.java | 852 +++ buffer/src/main/java/io/netty/buffer/Unpooled.java | 865 +++ .../io/netty/buffer/UnpooledByteBufAllocator.java | 62 + .../io/netty/buffer/UnpooledDirectByteBuf.java | 604 ++ .../java/io/netty/buffer/UnpooledHeapByteBuf.java | 449 ++ .../netty/buffer/UnpooledUnsafeDirectByteBuf.java | 525 ++ .../java/io/netty/buffer/UnreleasableByteBuf.java | 87 + .../netty/buffer/UnsafeDirectSwappedByteBuf.java | 186 + .../main/java/io/netty/buffer/WrappedByteBuf.java | 827 +++ .../main/java/io/netty/buffer/package-info.java | 128 + .../java/io/netty/buffer/AbstractByteBufTest.java | 2656 +++++++++ .../netty/buffer/AbstractCompositeByteBufTest.java | 941 +++ .../io/netty/buffer/AbstractPooledByteBufTest.java | 72 + .../buffer/BigEndianCompositeByteBufTest.java | 35 + .../netty/buffer/BigEndianDirectByteBufTest.java | 45 + .../io/netty/buffer/BigEndianHeapByteBufTest.java | 50 + .../buffer/BigEndianUnsafeDirectByteBufTest.java | 34 + .../io/netty/buffer/ByteBufDerivationTest.java | 217 + .../java/io/netty/buffer/ByteBufProcessorTest.java | 63 + .../java/io/netty/buffer/ByteBufStreamTest.java | 205 + .../test/java/io/netty/buffer/ByteBufUtilTest.java | 46 + .../java/io/netty/buffer/ConsolidationTest.java | 64 + .../java/io/netty/buffer/DuplicateByteBufTest.java | 57 + .../java/io/netty/buffer/EmptyByteBufTest.java | 71 + .../io/netty/buffer/FixedCompositeByteBufTest.java | 342 ++ .../buffer/LittleEndianCompositeByteBufTest.java | 26 + .../buffer/LittleEndianDirectByteBufTest.java | 45 + .../netty/buffer/LittleEndianHeapByteBufTest.java | 40 + .../LittleEndianUnsafeDirectByteBufTest.java | 33 + .../test/java/io/netty/buffer/PoolArenaTest.java | 35 + .../buffer/PooledBigEndianDirectByteBufTest.java | 33 + .../buffer/PooledBigEndianHeapByteBufTest.java | 27 + .../PooledLittleEndianDirectByteBufTest.java | 33 + .../buffer/PooledLittleEndianHeapByteBufTest.java | 33 + .../java/io/netty/buffer/ReadOnlyByteBufTest.java | 185 + .../io/netty/buffer/ReadOnlyByteBufferBufTest.java | 25 + .../buffer/ReadOnlyDirectByteBufferBufTest.java | 210 + .../ReadOnlyUnsafeDirectByteBufferBufTest.java | 39 + .../java/io/netty/buffer/SlicedByteBufTest.java | 117 + .../test/java/io/netty/buffer/UnpooledTest.java | 595 ++ .../io/netty/buffer/UnreleaseableByteBufTest.java | 41 + codec-haproxy/pom.xml | 39 + .../handler/codec/haproxy/HAProxyCommand.java | 70 + .../handler/codec/haproxy/HAProxyConstants.java | 60 + .../handler/codec/haproxy/HAProxyMessage.java | 429 ++ .../codec/haproxy/HAProxyMessageDecoder.java | 402 ++ .../codec/haproxy/HAProxyProtocolException.java | 52 + .../codec/haproxy/HAProxyProtocolVersion.java | 70 + .../codec/haproxy/HAProxyProxiedProtocol.java | 239 + .../netty/handler/codec/haproxy/package-info.java | 22 + .../codec/haproxy/HAProxyMessageDecoderTest.java | 949 +++ codec-http/pom.xml | 49 + .../handler/codec/http/ClientCookieEncoder.java | 59 + .../codec/http/ComposedLastHttpContent.java | 86 + .../java/io/netty/handler/codec/http/Cookie.java | 219 + .../io/netty/handler/codec/http/CookieDecoder.java | 374 ++ .../io/netty/handler/codec/http/CookieUtil.java | 104 + .../io/netty/handler/codec/http/DefaultCookie.java | 195 + .../handler/codec/http/DefaultFullHttpRequest.java | 125 + .../codec/http/DefaultFullHttpResponse.java | 121 + .../handler/codec/http/DefaultHttpContent.java | 85 + .../handler/codec/http/DefaultHttpHeaders.java | 498 ++ .../handler/codec/http/DefaultHttpMessage.java | 59 + .../handler/codec/http/DefaultHttpObject.java | 40 + .../handler/codec/http/DefaultHttpRequest.java | 95 + .../handler/codec/http/DefaultHttpResponse.java | 74 + .../handler/codec/http/DefaultLastHttpContent.java | 113 + .../netty/handler/codec/http/FullHttpMessage.java | 31 + .../netty/handler/codec/http/FullHttpRequest.java | 40 + .../netty/handler/codec/http/FullHttpResponse.java | 37 + .../netty/handler/codec/http/HttpChunkedInput.java | 99 + .../netty/handler/codec/http/HttpClientCodec.java | 224 + .../io/netty/handler/codec/http/HttpConstants.java | 77 + .../io/netty/handler/codec/http/HttpContent.java | 41 + .../handler/codec/http/HttpContentCompressor.java | 167 + .../handler/codec/http/HttpContentDecoder.java | 243 + .../codec/http/HttpContentDecompressor.java | 67 + .../handler/codec/http/HttpContentEncoder.java | 342 ++ .../handler/codec/http/HttpHeaderDateFormat.java | 101 + .../netty/handler/codec/http/HttpHeaderEntity.java | 78 + .../io/netty/handler/codec/http/HttpHeaders.java | 1683 ++++++ .../io/netty/handler/codec/http/HttpMessage.java | 45 + .../netty/handler/codec/http/HttpMessageUtil.java | 114 + .../io/netty/handler/codec/http/HttpMethod.java | 205 + .../io/netty/handler/codec/http/HttpObject.java | 31 + .../handler/codec/http/HttpObjectAggregator.java | 500 ++ .../handler/codec/http/HttpObjectDecoder.java | 808 +++ .../handler/codec/http/HttpObjectEncoder.java | 212 + .../io/netty/handler/codec/http/HttpRequest.java | 66 + .../handler/codec/http/HttpRequestDecoder.java | 96 + .../handler/codec/http/HttpRequestEncoder.java | 78 + .../io/netty/handler/codec/http/HttpResponse.java | 52 + .../handler/codec/http/HttpResponseDecoder.java | 127 + .../handler/codec/http/HttpResponseEncoder.java | 41 + .../handler/codec/http/HttpResponseStatus.java | 560 ++ .../netty/handler/codec/http/HttpServerCodec.java | 53 + .../io/netty/handler/codec/http/HttpVersion.java | 281 + .../netty/handler/codec/http/LastHttpContent.java | 103 + .../handler/codec/http/QueryStringDecoder.java | 385 ++ .../handler/codec/http/QueryStringEncoder.java | 132 + .../handler/codec/http/ServerCookieEncoder.java | 101 + .../codec/http/cookie/ClientCookieDecoder.java | 261 + .../codec/http/cookie/ClientCookieEncoder.java | 140 + .../io/netty/handler/codec/http/cookie/Cookie.java | 141 + .../handler/codec/http/cookie/CookieDecoder.java | 84 + .../handler/codec/http/cookie/CookieEncoder.java | 51 + .../codec/http/cookie/CookieHeaderNames.java | 34 + .../handler/codec/http/cookie/CookieUtil.java | 158 + .../handler/codec/http/cookie/DefaultCookie.java | 268 + .../codec/http/cookie/ServerCookieDecoder.java | 157 + .../codec/http/cookie/ServerCookieEncoder.java | 179 + .../handler/codec/http/cookie/package-info.java | 20 + .../netty/handler/codec/http/cors/CorsConfig.java | 575 ++ .../netty/handler/codec/http/cors/CorsHandler.java | 209 + .../handler/codec/http/cors/package-info.java | 20 + .../codec/http/multipart/AbstractDiskHttpData.java | 424 ++ .../codec/http/multipart/AbstractHttpData.java | 113 + .../http/multipart/AbstractMemoryHttpData.java | 257 + .../handler/codec/http/multipart/Attribute.java | 45 + .../http/multipart/CaseIgnoringComparator.java | 56 + .../http/multipart/DefaultHttpDataFactory.java | 195 + .../codec/http/multipart/DiskAttribute.java | 184 + .../codec/http/multipart/DiskFileUpload.java | 207 + .../handler/codec/http/multipart/FileUpload.java | 70 + .../handler/codec/http/multipart/HttpData.java | 191 + .../codec/http/multipart/HttpDataFactory.java | 66 + .../codec/http/multipart/HttpPostBodyUtil.java | 224 + .../multipart/HttpPostMultipartRequestDecoder.java | 1834 ++++++ .../http/multipart/HttpPostRequestDecoder.java | 393 ++ .../http/multipart/HttpPostRequestEncoder.java | 1234 ++++ .../multipart/HttpPostStandardRequestDecoder.java | 731 +++ .../codec/http/multipart/InterfaceHttpData.java | 38 + .../multipart/InterfaceHttpPostRequestDecoder.java | 139 + .../codec/http/multipart/InternalAttribute.java | 128 + .../codec/http/multipart/MemoryAttribute.java | 145 + .../codec/http/multipart/MemoryFileUpload.java | 174 + .../codec/http/multipart/MixedAttribute.java | 243 + .../codec/http/multipart/MixedFileUpload.java | 287 + .../handler/codec/http/multipart/package-info.java | 20 + .../io/netty/handler/codec/http/package-info.java | 20 + .../http/websocketx/BinaryWebSocketFrame.java | 78 + .../codec/http/websocketx/CloseWebSocketFrame.java | 162 + .../websocketx/ContinuationWebSocketFrame.java | 115 + .../codec/http/websocketx/PingWebSocketFrame.java | 78 + .../codec/http/websocketx/PongWebSocketFrame.java | 78 + .../codec/http/websocketx/TextWebSocketFrame.java | 118 + .../codec/http/websocketx/Utf8Validator.java | 104 + .../http/websocketx/WebSocket00FrameDecoder.java | 135 + .../http/websocketx/WebSocket00FrameEncoder.java | 101 + .../http/websocketx/WebSocket07FrameDecoder.java | 76 + .../http/websocketx/WebSocket07FrameEncoder.java | 73 + .../http/websocketx/WebSocket08FrameDecoder.java | 517 ++ .../http/websocketx/WebSocket08FrameEncoder.java | 234 + .../http/websocketx/WebSocket13FrameDecoder.java | 76 + .../http/websocketx/WebSocket13FrameEncoder.java | 73 + .../http/websocketx/WebSocketClientHandshaker.java | 408 ++ .../websocketx/WebSocketClientHandshaker00.java | 261 + .../websocketx/WebSocketClientHandshaker07.java | 201 + .../websocketx/WebSocketClientHandshaker08.java | 201 + .../websocketx/WebSocketClientHandshaker13.java | 211 + .../WebSocketClientHandshakerFactory.java | 96 + .../websocketx/WebSocketClientProtocolHandler.java | 154 + .../WebSocketClientProtocolHandshakeHandler.java | 68 + .../codec/http/websocketx/WebSocketFrame.java | 85 + .../http/websocketx/WebSocketFrameAggregator.java | 125 + .../http/websocketx/WebSocketFrameDecoder.java | 27 + .../http/websocketx/WebSocketFrameEncoder.java | 27 + .../websocketx/WebSocketHandshakeException.java | 32 + .../http/websocketx/WebSocketProtocolHandler.java | 44 + .../http/websocketx/WebSocketServerHandshaker.java | 386 ++ .../websocketx/WebSocketServerHandshaker00.java | 194 + .../websocketx/WebSocketServerHandshaker07.java | 143 + .../websocketx/WebSocketServerHandshaker08.java | 142 + .../websocketx/WebSocketServerHandshaker13.java | 140 + .../WebSocketServerHandshakerFactory.java | 139 + .../websocketx/WebSocketServerProtocolHandler.java | 151 + .../WebSocketServerProtocolHandshakeHandler.java | 106 + .../codec/http/websocketx/WebSocketUtil.java | 113 + .../codec/http/websocketx/WebSocketVersion.java | 73 + .../codec/http/websocketx/package-info.java | 39 + .../io/netty/handler/codec/rtsp/RtspHeaders.java | 388 ++ .../io/netty/handler/codec/rtsp/RtspMethods.java | 139 + .../handler/codec/rtsp/RtspObjectDecoder.java | 87 + .../handler/codec/rtsp/RtspObjectEncoder.java | 41 + .../handler/codec/rtsp/RtspRequestDecoder.java | 91 + .../handler/codec/rtsp/RtspRequestEncoder.java | 49 + .../handler/codec/rtsp/RtspResponseDecoder.java | 96 + .../handler/codec/rtsp/RtspResponseEncoder.java | 48 + .../handler/codec/rtsp/RtspResponseStatuses.java | 292 + .../io/netty/handler/codec/rtsp/RtspVersions.java | 51 + .../io/netty/handler/codec/rtsp/package-info.java | 21 + .../handler/codec/spdy/DefaultSpdyDataFrame.java | 141 + .../handler/codec/spdy/DefaultSpdyGoAwayFrame.java | 96 + .../handler/codec/spdy/DefaultSpdyHeaders.java | 379 ++ .../codec/spdy/DefaultSpdyHeadersFrame.java | 109 + .../handler/codec/spdy/DefaultSpdyPingFrame.java | 56 + .../codec/spdy/DefaultSpdyRstStreamFrame.java | 84 + .../codec/spdy/DefaultSpdySettingsFrame.java | 200 + .../handler/codec/spdy/DefaultSpdyStreamFrame.java | 60 + .../codec/spdy/DefaultSpdySynReplyFrame.java | 72 + .../codec/spdy/DefaultSpdySynStreamFrame.java | 132 + .../codec/spdy/DefaultSpdyWindowUpdateFrame.java | 82 + .../io/netty/handler/codec/spdy/SpdyCodecUtil.java | 331 ++ .../io/netty/handler/codec/spdy/SpdyDataFrame.java | 53 + .../io/netty/handler/codec/spdy/SpdyFrame.java | 23 + .../netty/handler/codec/spdy/SpdyFrameCodec.java | 382 ++ .../netty/handler/codec/spdy/SpdyFrameDecoder.java | 465 ++ .../codec/spdy/SpdyFrameDecoderDelegate.java | 99 + .../netty/handler/codec/spdy/SpdyFrameEncoder.java | 163 + .../netty/handler/codec/spdy/SpdyGoAwayFrame.java | 43 + .../handler/codec/spdy/SpdyHeaderBlockDecoder.java | 44 + .../handler/codec/spdy/SpdyHeaderBlockEncoder.java | 38 + .../codec/spdy/SpdyHeaderBlockJZlibEncoder.java | 156 + .../codec/spdy/SpdyHeaderBlockRawDecoder.java | 311 + .../codec/spdy/SpdyHeaderBlockRawEncoder.java | 91 + .../codec/spdy/SpdyHeaderBlockZlibDecoder.java | 125 + .../codec/spdy/SpdyHeaderBlockZlibEncoder.java | 114 + .../io/netty/handler/codec/spdy/SpdyHeaders.java | 413 ++ .../netty/handler/codec/spdy/SpdyHeadersFrame.java | 55 + .../io/netty/handler/codec/spdy/SpdyHttpCodec.java | 38 + .../netty/handler/codec/spdy/SpdyHttpDecoder.java | 404 ++ .../netty/handler/codec/spdy/SpdyHttpEncoder.java | 299 + .../netty/handler/codec/spdy/SpdyHttpHeaders.java | 143 + .../spdy/SpdyHttpResponseStreamIdHandler.java | 67 + .../handler/codec/spdy/SpdyOrHttpChooser.java | 174 + .../io/netty/handler/codec/spdy/SpdyPingFrame.java | 32 + .../handler/codec/spdy/SpdyProtocolException.java | 47 + .../handler/codec/spdy/SpdyRstStreamFrame.java | 38 + .../io/netty/handler/codec/spdy/SpdySession.java | 360 ++ .../handler/codec/spdy/SpdySessionHandler.java | 861 +++ .../handler/codec/spdy/SpdySessionStatus.java | 113 + .../handler/codec/spdy/SpdySettingsFrame.java | 107 + .../netty/handler/codec/spdy/SpdyStreamFrame.java | 43 + .../netty/handler/codec/spdy/SpdyStreamStatus.java | 187 + .../handler/codec/spdy/SpdySynReplyFrame.java | 31 + .../handler/codec/spdy/SpdySynStreamFrame.java | 65 + .../io/netty/handler/codec/spdy/SpdyVersion.java | 36 + .../handler/codec/spdy/SpdyWindowUpdateFrame.java | 43 + .../io/netty/handler/codec/spdy/package-info.java | 19 + .../handler/codec/http/DefaultHttpRequestTest.java | 47 + .../handler/codec/http/HttpChunkedInputTest.java | 123 + .../handler/codec/http/HttpClientCodecTest.java | 127 + .../codec/http/HttpContentCompressorTest.java | 311 + .../handler/codec/http/HttpContentDecoderTest.java | 512 ++ .../handler/codec/http/HttpContentEncoderTest.java | 357 ++ .../codec/http/HttpHeaderDateFormatTest.java | 67 + .../netty/handler/codec/http/HttpHeadersTest.java | 70 + .../handler/codec/http/HttpInvalidMessageTest.java | 118 + .../codec/http/HttpObjectAggregatorTest.java | 212 + .../handler/codec/http/HttpRequestDecoderTest.java | 178 + .../handler/codec/http/HttpRequestEncoderTest.java | 89 + .../codec/http/HttpResponseDecoderTest.java | 604 ++ .../codec/http/HttpResponseEncoderTest.java | 137 + .../handler/codec/http/HttpServerCodecTest.java | 124 + .../handler/codec/http/QueryStringDecoderTest.java | 285 + .../handler/codec/http/QueryStringEncoderTest.java | 62 + .../codec/http/cookie/ClientCookieDecoderTest.java | 287 + .../codec/http/cookie/ClientCookieEncoderTest.java | 52 + .../codec/http/cookie/ServerCookieDecoderTest.java | 185 + .../codec/http/cookie/ServerCookieEncoderTest.java | 63 + .../handler/codec/http/cors/CorsConfigTest.java | 132 + .../handler/codec/http/cors/CorsHandlerTest.java | 319 + .../http/multipart/AbstractMemoryHttpDataTest.java | 105 + .../http/multipart/HttpPostRequestDecoderTest.java | 350 ++ .../http/multipart/HttpPostRequestEncoderTest.java | 168 + .../websocketx/WebSocket00FrameEncoderTest.java | 44 + .../websocketx/WebSocket08EncoderDecoderTest.java | 152 + .../websocketx/WebSocketFrameAggregatorTest.java | 149 + .../websocketx/WebSocketHandshakeHandOverTest.java | 139 + .../http/websocketx/WebSocketRequestBuilder.java | 136 + .../WebSocketServerHandshaker00Test.java | 88 + .../WebSocketServerHandshaker08Test.java | 85 + .../WebSocketServerHandshaker13Test.java | 85 + .../WebSocketServerHandshakerFactoryTest.java | 52 + .../WebSocketServerProtocolHandlerTest.java | 174 + .../handler/codec/spdy/SpdyFrameDecoderTest.java | 1370 +++++ .../codec/spdy/SpdyHeaderBlockRawDecoderTest.java | 489 ++ .../codec/spdy/SpdyHeaderBlockZlibDecoderTest.java | 212 + .../handler/codec/spdy/SpdySessionHandlerTest.java | 389 ++ codec-http/src/test/resources/file-01.txt | 1 + codec-http/src/test/resources/file-02.txt | 1 + codec-socks/pom.xml | 44 + .../handler/codec/socks/SocksAddressType.java | 52 + .../handler/codec/socks/SocksAuthRequest.java | 83 + .../codec/socks/SocksAuthRequestDecoder.java | 81 + .../handler/codec/socks/SocksAuthResponse.java | 52 + .../codec/socks/SocksAuthResponseDecoder.java | 72 + .../netty/handler/codec/socks/SocksAuthScheme.java | 52 + .../netty/handler/codec/socks/SocksAuthStatus.java | 50 + .../netty/handler/codec/socks/SocksCmdRequest.java | 138 + .../codec/socks/SocksCmdRequestDecoder.java | 106 + .../handler/codec/socks/SocksCmdResponse.java | 177 + .../codec/socks/SocksCmdResponseDecoder.java | 105 + .../netty/handler/codec/socks/SocksCmdStatus.java | 57 + .../io/netty/handler/codec/socks/SocksCmdType.java | 52 + .../handler/codec/socks/SocksCommonUtils.java | 106 + .../handler/codec/socks/SocksInitRequest.java | 57 + .../codec/socks/SocksInitRequestDecoder.java | 78 + .../handler/codec/socks/SocksInitResponse.java | 51 + .../codec/socks/SocksInitResponseDecoder.java | 73 + .../io/netty/handler/codec/socks/SocksMessage.java | 62 + .../handler/codec/socks/SocksMessageEncoder.java | 46 + .../handler/codec/socks/SocksMessageType.java | 23 + .../handler/codec/socks/SocksProtocolVersion.java | 50 + .../io/netty/handler/codec/socks/SocksRequest.java | 46 + .../handler/codec/socks/SocksRequestType.java | 27 + .../netty/handler/codec/socks/SocksResponse.java | 46 + .../handler/codec/socks/SocksResponseType.java | 27 + .../codec/socks/SocksSubnegotiationVersion.java | 50 + .../handler/codec/socks/UnknownSocksRequest.java | 37 + .../handler/codec/socks/UnknownSocksResponse.java | 37 + .../io/netty/handler/codec/socks/package-info.java | 21 + .../codec/socks/SocksAuthRequestDecoderTest.java | 38 + .../handler/codec/socks/SocksAuthRequestTest.java | 81 + .../codec/socks/SocksAuthResponseDecoderTest.java | 45 + .../handler/codec/socks/SocksAuthResponseTest.java | 31 + .../codec/socks/SocksCmdRequestDecoderTest.java | 109 + .../handler/codec/socks/SocksCmdRequestTest.java | 91 + .../codec/socks/SocksCmdResponseDecoderTest.java | 84 + .../handler/codec/socks/SocksCmdResponseTest.java | 140 + .../handler/codec/socks/SocksCommonTestUtils.java | 36 + .../handler/codec/socks/SocksInitRequestTest.java | 30 + .../handler/codec/socks/SocksInitResponseTest.java | 30 + codec/pom.xml | 66 + .../io/netty/handler/codec/ByteToMessageCodec.java | 143 + .../netty/handler/codec/ByteToMessageDecoder.java | 404 ++ .../io/netty/handler/codec/CodecException.java | 51 + .../java/io/netty/handler/codec/CodecUtil.java | 32 + .../handler/codec/CorruptedFrameException.java | 52 + .../io/netty/handler/codec/DecoderException.java | 51 + .../java/io/netty/handler/codec/DecoderResult.java | 81 + .../handler/codec/DelimiterBasedFrameDecoder.java | 355 ++ .../java/io/netty/handler/codec/Delimiters.java | 49 + .../io/netty/handler/codec/EncoderException.java | 51 + .../handler/codec/FixedLengthFrameDecoder.java | 80 + .../codec/LengthFieldBasedFrameDecoder.java | 508 ++ .../netty/handler/codec/LengthFieldPrepender.java | 208 + .../netty/handler/codec/LineBasedFrameDecoder.java | 166 + .../netty/handler/codec/MessageToByteEncoder.java | 156 + .../netty/handler/codec/MessageToMessageCodec.java | 148 + .../handler/codec/MessageToMessageDecoder.java | 119 + .../handler/codec/MessageToMessageEncoder.java | 145 + .../codec/PrematureChannelClosureException.java | 54 + .../handler/codec/ProtocolDetectionResult.java | 80 + .../handler/codec/ProtocolDetectionState.java | 36 + .../io/netty/handler/codec/ReplayingDecoder.java | 428 ++ .../handler/codec/ReplayingDecoderByteBuf.java | 1006 ++++ .../netty/handler/codec/TooLongFrameException.java | 52 + .../codec/UnsupportedMessageTypeException.java | 63 + .../java/io/netty/handler/codec/base64/Base64.java | 303 + .../netty/handler/codec/base64/Base64Decoder.java | 66 + .../netty/handler/codec/base64/Base64Dialect.java | 207 + .../netty/handler/codec/base64/Base64Encoder.java | 69 + .../netty/handler/codec/base64/package-info.java | 23 + .../handler/codec/bytes/ByteArrayDecoder.java | 60 + .../handler/codec/bytes/ByteArrayEncoder.java | 59 + .../io/netty/handler/codec/bytes/package-info.java | 21 + .../codec/compression/CompressionException.java | 53 + .../io/netty/handler/codec/compression/Crc32c.java | 126 + .../codec/compression/DecompressionException.java | 53 + .../handler/codec/compression/JZlibDecoder.java | 174 + .../handler/codec/compression/JZlibEncoder.java | 410 ++ .../handler/codec/compression/JdkZlibDecoder.java | 393 ++ .../handler/codec/compression/JdkZlibEncoder.java | 325 + .../io/netty/handler/codec/compression/Snappy.java | 674 +++ .../codec/compression/SnappyFramedDecoder.java | 211 + .../codec/compression/SnappyFramedEncoder.java | 124 + .../codec/compression/ZlibCodecFactory.java | 128 + .../handler/codec/compression/ZlibDecoder.java | 31 + .../handler/codec/compression/ZlibEncoder.java | 53 + .../netty/handler/codec/compression/ZlibUtil.java | 85 + .../handler/codec/compression/ZlibWrapper.java | 40 + .../handler/codec/compression/package-info.java | 24 + .../codec/marshalling/ChannelBufferByteInput.java | 79 + .../codec/marshalling/ChannelBufferByteOutput.java | 71 + .../marshalling/CompatibleMarshallingDecoder.java | 109 + .../marshalling/CompatibleMarshallingEncoder.java | 59 + .../ContextBoundUnmarshallerProvider.java | 54 + .../marshalling/DefaultMarshallerProvider.java | 49 + .../marshalling/DefaultUnmarshallerProvider.java | 50 + .../codec/marshalling/LimitingByteInput.java | 105 + .../codec/marshalling/MarshallerProvider.java | 31 + .../codec/marshalling/MarshallingDecoder.java | 87 + .../codec/marshalling/MarshallingEncoder.java | 65 + .../marshalling/ThreadLocalMarshallerProvider.java | 56 + .../ThreadLocalUnmarshallerProvider.java | 57 + .../codec/marshalling/UnmarshallerProvider.java | 32 + .../handler/codec/marshalling/package-info.java | 21 + .../java/io/netty/handler/codec/package-info.java | 22 + .../handler/codec/protobuf/ProtobufDecoder.java | 131 + .../handler/codec/protobuf/ProtobufEncoder.java | 73 + .../protobuf/ProtobufVarint32FrameDecoder.java | 77 + .../ProtobufVarint32LengthFieldPrepender.java | 56 + .../netty/handler/codec/protobuf/package-info.java | 23 + .../codec/serialization/CachingClassResolver.java | 46 + .../serialization/ClassLoaderClassResolver.java | 35 + .../handler/codec/serialization/ClassResolver.java | 25 + .../codec/serialization/ClassResolvers.java | 104 + .../serialization/CompactObjectInputStream.java | 75 + .../serialization/CompactObjectOutputStream.java | 49 + .../serialization/CompatibleObjectEncoder.java | 103 + .../handler/codec/serialization/ObjectDecoder.java | 84 + .../serialization/ObjectDecoderInputStream.java | 243 + .../handler/codec/serialization/ObjectEncoder.java | 55 + .../serialization/ObjectEncoderOutputStream.java | 178 + .../handler/codec/serialization/ReferenceMap.java | 102 + .../codec/serialization/SoftReferenceMap.java | 33 + .../codec/serialization/WeakReferenceMap.java | 33 + .../handler/codec/serialization/package-info.java | 22 + .../netty/handler/codec/string/StringDecoder.java | 81 + .../netty/handler/codec/string/StringEncoder.java | 82 + .../netty/handler/codec/string/package-info.java | 21 + .../handler/codec/ByteToMessageCodecTest.java | 62 + .../handler/codec/ByteToMessageDecoderTest.java | 163 + .../codec/DelimiterBasedFrameDecoderTest.java | 93 + .../codec/LengthFieldBasedFrameDecoderTest.java | 85 + .../handler/codec/LineBasedFrameDecoderTest.java | 105 + .../handler/codec/MessageToMessageEncoderTest.java | 40 + .../handler/codec/ReplayingDecoderByteBufTest.java | 101 + .../netty/handler/codec/ReplayingDecoderTest.java | 222 + .../handler/codec/bytes/ByteArrayDecoderTest.java | 58 + .../handler/codec/bytes/ByteArrayEncoderTest.java | 67 + .../netty/handler/codec/compression/JZlibTest.java | 29 + .../handler/codec/compression/JdkZlibTest.java | 38 + .../codec/compression/SnappyFramedDecoderTest.java | 159 + .../codec/compression/SnappyFramedEncoderTest.java | 151 + .../codec/compression/SnappyIntegrationTest.java | 173 + .../handler/codec/compression/SnappyTest.java | 198 + .../handler/codec/compression/ZlibCrossTest1.java | 29 + .../handler/codec/compression/ZlibCrossTest2.java | 37 + .../netty/handler/codec/compression/ZlibTest.java | 359 ++ .../frame/DelimiterBasedFrameDecoderTest.java | 71 + .../frame/LengthFieldBasedFrameDecoderTest.java | 71 + .../codec/frame/LengthFieldPrependerTest.java | 96 + .../io/netty/handler/codec/frame/package-info.java | 20 + .../AbstractCompatibleMarshallingDecoderTest.java | 133 + .../AbstractCompatibleMarshallingEncoderTest.java | 78 + .../RiverCompatibleMarshallingDecoderTest.java | 37 + .../RiverCompatibleMarshallingEncoderTest.java | 37 + ...ntextBoundCompatibleMarshallingDecoderTest.java | 28 + .../RiverContextBoundMarshallingDecoderTest.java | 28 + .../marshalling/RiverMarshallingDecoderTest.java | 51 + .../marshalling/RiverMarshallingEncoderTest.java | 34 + ...hreadLocalCompatibleMarshallingDecoderTest.java | 28 + ...hreadLocalCompatibleMarshallingEncoderTest.java | 25 + .../RiverThreadLocalMarshallingDecoderTest.java | 28 + .../RiverThreadLocalMarshallingEncoderTest.java | 25 + .../SerialCompatibleMarshallingDecoderTest.java | 37 + .../SerialCompatibleMarshallingEncoderTest.java | 37 + ...ntextBoundCompatibleMarshallingDecoderTest.java | 28 + .../SerialContextBoundMarshallingDecoderTest.java | 28 + .../marshalling/SerialMarshallingDecoderTest.java | 51 + .../marshalling/SerialMarshallingEncoderTest.java | 34 + ...hreadLocalCompatibleMarshallingDecoderTest.java | 28 + ...hreadLocalCompatibleMarshallingEncoderTest.java | 25 + .../SerialThreadLocalMarshallingDecoderTest.java | 28 + .../SerialThreadLocalMarshallingEncoderTest.java | 25 + .../protobuf/ProtobufVarint32FrameDecoderTest.java | 66 + .../ProtobufVarint32LengthFieldPrependerTest.java | 55 + .../CompactObjectSerializationTest.java | 36 + .../handler/codec/string/StringEncoderTest.java | 39 + common/pom.xml | 59 + .../io/netty/util/AbstractReferenceCounted.java | 134 + common/src/main/java/io/netty/util/Attribute.java | 73 + .../src/main/java/io/netty/util/AttributeKey.java | 85 + .../src/main/java/io/netty/util/AttributeMap.java | 29 + .../src/main/java/io/netty/util/CharsetUtil.java | 117 + .../java/io/netty/util/DefaultAttributeMap.java | 184 + .../main/java/io/netty/util/DomainNameMapping.java | 144 + .../main/java/io/netty/util/HashedWheelTimer.java | 740 +++ .../netty/util/IllegalReferenceCountException.java | 48 + common/src/main/java/io/netty/util/Mapping.java | 27 + common/src/main/java/io/netty/util/NetUtil.java | 1020 ++++ common/src/main/java/io/netty/util/Recycler.java | 399 ++ .../java/io/netty/util/ReferenceCountUtil.java | 161 + .../main/java/io/netty/util/ReferenceCounted.java | 63 + .../src/main/java/io/netty/util/ResourceLeak.java | 32 + .../java/io/netty/util/ResourceLeakDetector.java | 390 ++ .../java/io/netty/util/ResourceLeakException.java | 71 + common/src/main/java/io/netty/util/Signal.java | 77 + .../java/io/netty/util/ThreadDeathWatcher.java | 241 + common/src/main/java/io/netty/util/Timeout.java | 54 + common/src/main/java/io/netty/util/Timer.java | 46 + common/src/main/java/io/netty/util/TimerTask.java | 33 + common/src/main/java/io/netty/util/UniqueName.java | 119 + common/src/main/java/io/netty/util/Version.java | 203 + .../io/netty/util/collection/IntObjectHashMap.java | 552 ++ .../io/netty/util/collection/IntObjectMap.java | 123 + .../io/netty/util/collection/package-info.java | 20 + .../util/concurrent/AbstractEventExecutor.java | 157 + .../concurrent/AbstractEventExecutorGroup.java | 116 + .../io/netty/util/concurrent/AbstractFuture.java | 51 + .../concurrent/AbstractScheduledEventExecutor.java | 214 + .../concurrent/BlockingOperationException.java | 41 + .../io/netty/util/concurrent/CompleteFuture.java | 147 + .../util/concurrent/DefaultEventExecutor.java | 45 + .../util/concurrent/DefaultEventExecutorGroup.java | 48 + .../util/concurrent/DefaultFutureListeners.java | 86 + .../util/concurrent/DefaultProgressivePromise.java | 130 + .../io/netty/util/concurrent/DefaultPromise.java | 876 +++ .../util/concurrent/DefaultThreadFactory.java | 143 + .../io/netty/util/concurrent/EventExecutor.java | 72 + .../netty/util/concurrent/EventExecutorGroup.java | 112 + .../io/netty/util/concurrent/FailedFuture.java | 69 + .../io/netty/util/concurrent/FastThreadLocal.java | 244 + .../util/concurrent/FastThreadLocalThread.java | 72 + .../main/java/io/netty/util/concurrent/Future.java | 169 + .../io/netty/util/concurrent/FutureListener.java | 28 + .../util/concurrent/GenericFutureListener.java | 32 + .../GenericProgressiveFutureListener.java | 28 + .../netty/util/concurrent/GlobalEventExecutor.java | 275 + .../util/concurrent/ImmediateEventExecutor.java | 121 + .../netty/util/concurrent/ImmediateExecutor.java | 37 + .../concurrent/MultithreadEventExecutorGroup.java | 233 + .../netty/util/concurrent/ProgressiveFuture.java | 47 + .../netty/util/concurrent/ProgressivePromise.java | 65 + .../java/io/netty/util/concurrent/Promise.java | 90 + .../netty/util/concurrent/PromiseAggregator.java | 112 + .../io/netty/util/concurrent/PromiseNotifier.java | 70 + .../java/io/netty/util/concurrent/PromiseTask.java | 137 + .../io/netty/util/concurrent/ScheduledFuture.java | 23 + .../netty/util/concurrent/ScheduledFutureTask.java | 175 + .../util/concurrent/SingleThreadEventExecutor.java | 720 +++ .../io/netty/util/concurrent/SucceededFuture.java | 50 + .../io/netty/util/concurrent/package-info.java | 20 + .../util/internal/AppendableCharSequence.java | 141 + .../main/java/io/netty/util/internal/Cleaner0.java | 74 + .../internal/ConcurrentCircularArrayQueue.java | 207 + .../java/io/netty/util/internal/ConcurrentSet.java | 65 + .../java/io/netty/util/internal/EmptyArrays.java | 44 + .../java/io/netty/util/internal/IntegerHolder.java | 21 + .../util/internal/InternalThreadLocalMap.java | 310 + .../JavassistTypeParameterMatcherGenerator.java | 99 + .../java/io/netty/util/internal/LongCounter.java | 26 + .../io/netty/util/internal/MpscArrayQueue.java | 331 ++ .../io/netty/util/internal/MpscLinkedQueue.java | 381 ++ .../util/internal/MpscLinkedQueueHeadRef.java | 54 + .../netty/util/internal/MpscLinkedQueueNode.java | 65 + .../netty/util/internal/MpscLinkedQueuePad0.java | 22 + .../netty/util/internal/MpscLinkedQueuePad1.java | 25 + .../util/internal/MpscLinkedQueueTailRef.java | 54 + .../netty/util/internal/NativeLibraryLoader.java | 228 + .../util/internal/NoOpTypeParameterMatcher.java | 24 + .../java/io/netty/util/internal/ObjectUtil.java | 35 + .../java/io/netty/util/internal/OneTimeTask.java | 32 + .../java/io/netty/util/internal/PendingWrite.java | 97 + .../io/netty/util/internal/PlatformDependent.java | 915 +++ .../io/netty/util/internal/PlatformDependent0.java | 383 ++ .../io/netty/util/internal/ReadOnlyIterator.java | 45 + .../netty/util/internal/RecyclableArrayList.java | 132 + .../internal/RecyclableMpscLinkedQueueNode.java | 45 + .../java/io/netty/util/internal/StringUtil.java | 320 + .../io/netty/util/internal/SystemPropertyUtil.java | 223 + .../io/netty/util/internal/ThreadLocalRandom.java | 336 ++ .../netty/util/internal/TypeParameterMatcher.java | 176 + .../internal/UnpaddedInternalThreadLocalMap.java | 57 + .../internal/UnsafeAtomicIntegerFieldUpdater.java | 61 + .../internal/UnsafeAtomicLongFieldUpdater.java | 61 + .../UnsafeAtomicReferenceFieldUpdater.java | 62 + .../util/internal/chmv8/ConcurrentHashMapV8.java | 6205 ++++++++++++++++++++ .../util/internal/chmv8/CountedCompleter.java | 769 +++ .../io/netty/util/internal/chmv8/ForkJoinPool.java | 3359 +++++++++++ .../io/netty/util/internal/chmv8/ForkJoinTask.java | 1560 +++++ .../util/internal/chmv8/ForkJoinWorkerThread.java | 140 + .../io/netty/util/internal/chmv8/LongAdderV8.java | 225 + .../io/netty/util/internal/chmv8/Striped64.java | 351 ++ .../internal/logging/AbstractInternalLogger.java | 190 + .../netty/util/internal/logging/CommonsLogger.java | 564 ++ .../internal/logging/CommonsLoggerFactory.java | 37 + .../util/internal/logging/FormattingTuple.java | 88 + .../util/internal/logging/InternalLogLevel.java | 42 + .../util/internal/logging/InternalLogger.java | 444 ++ .../internal/logging/InternalLoggerFactory.java | 91 + .../io/netty/util/internal/logging/JdkLogger.java | 647 ++ .../util/internal/logging/JdkLoggerFactory.java | 32 + .../netty/util/internal/logging/Log4JLogger.java | 597 ++ .../util/internal/logging/Log4JLoggerFactory.java | 31 + .../util/internal/logging/MessageFormatter.java | 428 ++ .../netty/util/internal/logging/Slf4JLogger.java | 183 + .../util/internal/logging/Slf4JLoggerFactory.java | 69 + .../netty/util/internal/logging/package-info.java | 20 + .../java/io/netty/util/internal/package-info.java | 21 + .../src/main/java/io/netty/util/package-info.java | 20 + .../test/java/io/netty/util/AttributeKeyTest.java | 59 + .../io/netty/util/DefaultAttributeMapTest.java | 99 + .../java/io/netty/util/HashedWheelTimerTest.java | 157 + .../src/test/java/io/netty/util/NetUtilTest.java | 520 ++ .../src/test/java/io/netty/util/RecyclerTest.java | 176 + .../java/io/netty/util/ThreadDeathWatcherTest.java | 116 + .../test/java/io/netty/util/UniqueNameTest.java | 122 + .../util/collection/IntObjectHashMapTest.java | 420 ++ .../netty/util/concurrent/DefaultPromiseTest.java | 199 + .../netty/util/concurrent/FastThreadLocalTest.java | 78 + .../util/concurrent/GlobalEventExecutorTest.java | 112 + .../util/concurrent/PromiseAggregatorTest.java | 132 + .../netty/util/concurrent/PromiseNotifierTest.java | 90 + .../util/internal/AppendableCharSequenceTest.java | 101 + .../io/netty/util/internal/StringUtilTest.java | 107 + .../netty/util/internal/ThreadLocalRandomTest.java | 37 + .../util/internal/TypeParameterMatcherTest.java | 144 + .../internal/logging/CommonsLoggerFactoryTest.java | 30 + .../util/internal/logging/CommonsLoggerTest.java | 221 + .../logging/InternalLoggerFactoryTest.java | 214 + .../internal/logging/JdkLoggerFactoryTest.java | 30 + .../internal/logging/Log4JLoggerFactoryTest.java | 30 + .../internal/logging/Slf4JLoggerFactoryTest.java | 30 + .../util/internal/logging/Slf4JLoggerTest.java | 236 + example/.gitignore | 7 + example/pom.xml | 126 + .../io/netty/example/discard/DiscardClient.java | 75 + .../example/discard/DiscardClientHandler.java | 79 + .../io/netty/example/discard/DiscardServer.java | 80 + .../example/discard/DiscardServerHandler.java | 37 + .../java/io/netty/example/echo/EchoClient.java | 83 + .../io/netty/example/echo/EchoClientHandler.java | 63 + .../java/io/netty/example/echo/EchoServer.java | 83 + .../io/netty/example/echo/EchoServerHandler.java | 44 + .../netty/example/factorial/BigIntegerDecoder.java | 63 + .../netty/example/factorial/FactorialClient.java | 68 + .../example/factorial/FactorialClientHandler.java | 110 + .../factorial/FactorialClientInitializer.java | 55 + .../netty/example/factorial/FactorialServer.java | 62 + .../example/factorial/FactorialServerHandler.java | 53 + .../factorial/FactorialServerInitializer.java | 57 + .../io/netty/example/factorial/NumberEncoder.java | 50 + .../java/io/netty/example/file/FileServer.java | 93 + .../io/netty/example/file/FileServerHandler.java | 73 + .../io/netty/example/http/cors/HttpCorsServer.java | 104 + .../http/cors/HttpCorsServerInitializer.java | 95 + .../netty/example/http/cors/OkResponseHandler.java | 37 + .../example/http/file/HttpStaticFileServer.java | 66 + .../http/file/HttpStaticFileServerHandler.java | 392 ++ .../http/file/HttpStaticFileServerInitializer.java | 45 + .../http/helloworld/HttpHelloWorldServer.java | 71 + .../helloworld/HttpHelloWorldServerHandler.java | 67 + .../HttpHelloWorldServerInitializer.java | 41 + .../netty/example/http/snoop/HttpSnoopClient.java | 107 + .../example/http/snoop/HttpSnoopClientHandler.java | 71 + .../http/snoop/HttpSnoopClientInitializer.java | 52 + .../netty/example/http/snoop/HttpSnoopServer.java | 69 + .../example/http/snoop/HttpSnoopServerHandler.java | 195 + .../http/snoop/HttpSnoopServerInitializer.java | 47 + .../example/http/upload/HttpUploadClient.java | 896 +++ .../http/upload/HttpUploadClientHandler.java | 79 + .../http/upload/HttpUploadClientIntializer.java | 52 + .../example/http/upload/HttpUploadServer.java | 67 + .../http/upload/HttpUploadServerHandler.java | 423 ++ .../http/upload/HttpUploadServerInitializer.java | 50 + .../benchmarkserver/WebSocketServer.java | 71 + .../WebSocketServerBenchmarkPage.java | 191 + .../benchmarkserver/WebSocketServerHandler.java | 161 + .../WebSocketServerInitializer.java | 45 + .../websocketx/benchmarkserver/package-info.java | 27 + .../http/websocketx/client/WebSocketClient.java | 144 + .../websocketx/client/WebSocketClientHandler.java | 118 + .../http/websocketx/server/WebSocketServer.java | 83 + .../websocketx/server/WebSocketServerHandler.java | 159 + .../server/WebSocketServerIndexPage.java | 79 + .../server/WebSocketServerInitializer.java | 45 + .../http/websocketx/server/package-info.java | 26 + .../java/io/netty/example/localecho/LocalEcho.java | 108 + .../example/localecho/LocalEchoClientHandler.java | 34 + .../example/localecho/LocalEchoServerHandler.java | 39 + .../netty/example/objectecho/ObjectEchoClient.java | 78 + .../objectecho/ObjectEchoClientHandler.java | 65 + .../netty/example/objectecho/ObjectEchoServer.java | 81 + .../objectecho/ObjectEchoServerHandler.java | 43 + .../portunification/PortUnificationServer.java | 68 + .../PortUnificationServerHandler.java | 144 + .../java/io/netty/example/proxy/HexDumpProxy.java | 51 + .../example/proxy/HexDumpProxyBackendHandler.java | 63 + .../example/proxy/HexDumpProxyFrontendHandler.java | 103 + .../example/proxy/HexDumpProxyInitializer.java | 39 + .../netty/example/qotm/QuoteOfTheMomentClient.java | 67 + .../qotm/QuoteOfTheMomentClientHandler.java | 39 + .../netty/example/qotm/QuoteOfTheMomentServer.java | 48 + .../qotm/QuoteOfTheMomentServerHandler.java | 65 + .../java/io/netty/example/rxtx/RxtxClient.java | 61 + .../io/netty/example/rxtx/RxtxClientHandler.java | 37 + .../java/io/netty/example/sctp/SctpEchoClient.java | 68 + .../netty/example/sctp/SctpEchoClientHandler.java | 64 + .../java/io/netty/example/sctp/SctpEchoServer.java | 66 + .../netty/example/sctp/SctpEchoServerHandler.java | 44 + .../multihoming/SctpMultiHomingEchoClient.java | 87 + .../multihoming/SctpMultiHomingEchoServer.java | 83 + .../netty/example/securechat/SecureChatClient.java | 84 + .../securechat/SecureChatClientHandler.java | 36 + .../securechat/SecureChatClientInitializer.java | 57 + .../netty/example/securechat/SecureChatServer.java | 56 + .../securechat/SecureChatServerHandler.java | 79 + .../securechat/SecureChatServerInitializer.java | 57 + .../example/socksproxy/DirectClientHandler.java | 41 + .../io/netty/example/socksproxy/RelayHandler.java | 58 + .../io/netty/example/socksproxy/SocksServer.java | 44 + .../socksproxy/SocksServerConnectHandler.java | 90 + .../example/socksproxy/SocksServerHandler.java | 75 + .../example/socksproxy/SocksServerInitializer.java | 36 + .../netty/example/socksproxy/SocksServerUtils.java | 34 + .../spdy/client/HttpResponseClientHandler.java | 87 + .../io/netty/example/spdy/client/SpdyClient.java | 103 + .../example/spdy/client/SpdyClientInitializer.java | 54 + .../spdy/client/SpdyClientStreamIdHandler.java | 47 + .../netty/example/spdy/client/SpdyFrameLogger.java | 79 + .../io/netty/example/spdy/client/package-info.java | 45 + .../example/spdy/server/SpdyOrHttpHandler.java | 74 + .../io/netty/example/spdy/server/SpdyServer.java | 93 + .../example/spdy/server/SpdyServerHandler.java | 75 + .../example/spdy/server/SpdyServerInitializer.java | 41 + .../io/netty/example/spdy/server/package-info.java | 40 + .../java/io/netty/example/telnet/TelnetClient.java | 88 + .../netty/example/telnet/TelnetClientHandler.java | 38 + .../example/telnet/TelnetClientInitializer.java | 59 + .../java/io/netty/example/telnet/TelnetServer.java | 61 + .../netty/example/telnet/TelnetServerHandler.java | 76 + .../example/telnet/TelnetServerInitializer.java | 60 + .../example/udt/echo/bytes/ByteEchoClient.java | 71 + .../udt/echo/bytes/ByteEchoClientHandler.java | 64 + .../example/udt/echo/bytes/ByteEchoServer.java | 72 + .../udt/echo/bytes/ByteEchoServerHandler.java | 49 + .../netty/example/udt/echo/bytes/package-info.java | 21 + .../example/udt/echo/message/MsgEchoClient.java | 75 + .../udt/echo/message/MsgEchoClientHandler.java | 64 + .../example/udt/echo/message/MsgEchoServer.java | 74 + .../udt/echo/message/MsgEchoServerHandler.java | 49 + .../example/udt/echo/message/package-info.java | 21 + .../io/netty/example/udt/echo/package-info.java | 21 + .../netty/example/udt/echo/rendezvous/Config.java | 32 + .../udt/echo/rendezvous/MsgEchoPeerBase.java | 76 + .../udt/echo/rendezvous/MsgEchoPeerHandler.java | 64 + .../udt/echo/rendezvous/MsgEchoPeerOne.java | 38 + .../udt/echo/rendezvous/MsgEchoPeerTwo.java | 38 + .../example/udt/echo/rendezvous/package-info.java | 21 + .../udt/echo/rendezvousBytes/ByteEchoPeerBase.java | 74 + .../echo/rendezvousBytes/ByteEchoPeerHandler.java | 62 + .../udt/echo/rendezvousBytes/ByteEchoPeerOne.java | 44 + .../udt/echo/rendezvousBytes/ByteEchoPeerTwo.java | 44 + .../udt/echo/rendezvousBytes/package-info.java | 21 + .../java/io/netty/example/udt/package-info.java | 21 + .../java/io/netty/example/uptime/UptimeClient.java | 78 + .../netty/example/uptime/UptimeClientHandler.java | 96 + .../netty/example/worldclock/WorldClockClient.java | 79 + .../worldclock/WorldClockClientHandler.java | 106 + .../worldclock/WorldClockClientInitializer.java | 50 + .../example/worldclock/WorldClockProtocol.java | 3302 +++++++++++ .../example/worldclock/WorldClockProtocol.proto | 73 + .../netty/example/worldclock/WorldClockServer.java | 62 + .../worldclock/WorldClockServerHandler.java | 72 + .../worldclock/WorldClockServerInitializer.java | 50 + example/src/main/resources/cors/cors.html | 42 + example/src/main/resources/cors/css/cors.css | 4 + example/src/main/resources/logback.xml | 11 + handler/pom.xml | 82 + .../java/io/netty/handler/logging/LogLevel.java | 36 + .../io/netty/handler/logging/LoggingHandler.java | 327 ++ .../io/netty/handler/logging/package-info.java | 20 + .../handler/ssl/ApplicationProtocolAccessor.java | 30 + .../handler/ssl/ApplicationProtocolConfig.java | 145 + .../handler/ssl/ApplicationProtocolNames.java | 59 + .../ssl/ApplicationProtocolNegotiationHandler.java | 125 + .../handler/ssl/ApplicationProtocolNegotiator.java | 34 + .../netty/handler/ssl/ApplicationProtocolUtil.java | 77 + .../io/netty/handler/ssl/CipherSuiteConverter.java | 415 ++ .../io/netty/handler/ssl/CipherSuiteFilter.java | 34 + .../handler/ssl/IdentityCipherSuiteFilter.java | 47 + .../ssl/JdkAlpnApplicationProtocolNegotiator.java | 120 + .../io/netty/handler/ssl/JdkAlpnSslEngine.java | 124 + .../ssl/JdkApplicationProtocolNegotiator.java | 134 + .../ssl/JdkBaseApplicationProtocolNegotiator.java | 208 + .../JdkDefaultApplicationProtocolNegotiator.java | 60 + .../ssl/JdkNpnApplicationProtocolNegotiator.java | 120 + .../java/io/netty/handler/ssl/JdkNpnSslEngine.java | 122 + .../io/netty/handler/ssl/JdkSslClientContext.java | 261 + .../java/io/netty/handler/ssl/JdkSslContext.java | 325 + .../java/io/netty/handler/ssl/JdkSslEngine.java | 204 + .../io/netty/handler/ssl/JdkSslServerContext.java | 235 + .../java/io/netty/handler/ssl/JdkSslSession.java | 152 + .../netty/handler/ssl/NotSslRecordException.java | 48 + .../main/java/io/netty/handler/ssl/OpenSsl.java | 194 + .../ssl/OpenSslApplicationProtocolNegotiator.java | 37 + .../io/netty/handler/ssl/OpenSslClientContext.java | 305 + .../java/io/netty/handler/ssl/OpenSslContext.java | 461 ++ ...penSslDefaultApplicationProtocolNegotiator.java | 50 + .../java/io/netty/handler/ssl/OpenSslEngine.java | 1624 +++++ .../io/netty/handler/ssl/OpenSslEngineMap.java | 42 + .../handler/ssl/OpenSslJavaxX509Certificate.java | 134 + .../OpenSslNpnApplicationProtocolNegotiator.java | 59 + .../io/netty/handler/ssl/OpenSslServerContext.java | 418 ++ .../handler/ssl/OpenSslServerSessionContext.java | 79 + .../netty/handler/ssl/OpenSslSessionContext.java | 90 + .../io/netty/handler/ssl/OpenSslSessionStats.java | 122 + .../netty/handler/ssl/OpenSslX509Certificate.java | 189 + .../main/java/io/netty/handler/ssl/PemReader.java | 144 + .../main/java/io/netty/handler/ssl/SniHandler.java | 185 + .../java/io/netty/handler/ssl/SslConstants.java | 45 + .../main/java/io/netty/handler/ssl/SslContext.java | 965 +++ .../io/netty/handler/ssl/SslContextBuilder.java | 228 + .../main/java/io/netty/handler/ssl/SslHandler.java | 1527 +++++ .../handler/ssl/SslHandshakeCompletionEvent.java | 67 + .../io/netty/handler/ssl/SslParametersUtils.java | 35 + .../java/io/netty/handler/ssl/SslProvider.java | 31 + .../handler/ssl/SupportedCipherSuiteFilter.java | 59 + .../java/io/netty/handler/ssl/package-info.java | 21 + .../util/BouncyCastleSelfSignedCertGenerator.java | 61 + .../ssl/util/FingerprintTrustManagerFactory.java | 209 + .../ssl/util/InsecureTrustManagerFactory.java | 73 + .../ssl/util/OpenJdkSelfSignedCertGenerator.java | 81 + .../handler/ssl/util/SelfSignedCertificate.java | 207 + .../ssl/util/SimpleTrustManagerFactory.java | 134 + .../ssl/util/ThreadLocalInsecureRandom.java | 100 + .../io/netty/handler/ssl/util/package-info.java | 20 + .../java/io/netty/handler/stream/ChunkedFile.java | 164 + .../java/io/netty/handler/stream/ChunkedInput.java | 50 + .../io/netty/handler/stream/ChunkedNioFile.java | 175 + .../io/netty/handler/stream/ChunkedNioStream.java | 131 + .../io/netty/handler/stream/ChunkedStream.java | 129 + .../netty/handler/stream/ChunkedWriteHandler.java | 379 ++ .../java/io/netty/handler/stream/package-info.java | 22 + .../java/io/netty/handler/timeout/IdleState.java | 37 + .../io/netty/handler/timeout/IdleStateEvent.java | 52 + .../io/netty/handler/timeout/IdleStateHandler.java | 466 ++ .../handler/timeout/ReadTimeoutException.java | 29 + .../netty/handler/timeout/ReadTimeoutHandler.java | 234 + .../io/netty/handler/timeout/TimeoutException.java | 34 + .../handler/timeout/WriteTimeoutException.java | 29 + .../netty/handler/timeout/WriteTimeoutHandler.java | 149 + .../io/netty/handler/timeout/package-info.java | 21 + .../traffic/AbstractTrafficShapingHandler.java | 653 ++ .../traffic/ChannelTrafficShapingHandler.java | 231 + .../traffic/GlobalChannelTrafficCounter.java | 129 + .../GlobalChannelTrafficShapingHandler.java | 775 +++ .../traffic/GlobalTrafficShapingHandler.java | 394 ++ .../io/netty/handler/traffic/TrafficCounter.java | 624 ++ .../io/netty/handler/traffic/package-info.java | 57 + .../handler/ssl/CipherSuiteConverterTest.java | 327 ++ .../io/netty/handler/ssl/JdkSslEngineTest.java | 349 ++ .../netty/handler/ssl/JdkSslServerContextTest.java | 50 + .../io/netty/handler/ssl/OpenSslEngineTest.java | 49 + .../java/io/netty/handler/ssl/SSLEngineTest.java | 290 + .../java/io/netty/handler/ssl/SniHandlerTest.java | 117 + .../java/io/netty/handler/ssl/SslHandlerTest.java | 66 + .../handler/stream/ChunkedWriteHandlerTest.java | 212 + .../test/resources/io/netty/handler/ssl/test.crt | 19 + .../test/resources/io/netty/handler/ssl/test2.crt | 18 + .../io/netty/handler/ssl/test2_encrypted.pem | 29 + .../io/netty/handler/ssl/test2_unencrypted.pem | 28 + .../io/netty/handler/ssl/test_encrypted.pem | 29 + .../io/netty/handler/ssl/test_unencrypted.pem | 24 + license/LICENSE.abstractnodequeue.txt | 15 + license/LICENSE.base64.txt | 26 + license/LICENSE.bouncycastle.txt | 23 + license/LICENSE.caliper.txt | 202 + license/LICENSE.commons-logging.txt | 177 + license/LICENSE.jboss-marshalling.txt | 504 ++ license/LICENSE.jctools.txt | 177 + license/LICENSE.jsr166y.txt | 26 + license/LICENSE.jzlib.txt | 26 + license/LICENSE.log4j.txt | 177 + license/LICENSE.protobuf.txt | 33 + license/LICENSE.slf4j.txt | 23 + license/LICENSE.snappy.txt | 28 + license/LICENSE.webbit.txt | 37 + microbench/README.md | 4 + microbench/pom.xml | 84 + .../buffer/ByteBufAllocatorBenchmark.java | 108 + .../microbench/buffer/ByteBufUtilBenchmark.java | 168 + .../microbench/buffer/SwappedByteBufBenchmark.java | 80 + .../concurrent/FastThreadLocalBenchmark.java | 77 + .../http/HttpRequestDecoderBenchmark.java | 111 + .../internal/RecyclableArrayListBenchmark.java | 40 + .../microbench/util/AbstractMicrobenchmark.java | 123 + microbench/src/test/resources/logback.xml | 5 + pom.xml | 1494 +++++ run-example.sh | 95 + tarball/assembly.xml | 51 + tarball/pom.xml | 194 + testsuite-osgi/pom.xml | 161 + .../java/io/netty/osgitests/OsgiBundleTest.java | 108 + .../test/java/io/netty/osgitests/package-info.java | 20 + testsuite/.gitignore | 6 + testsuite/pom.xml | 156 + .../transport/AbstractComboTestsuiteTest.java | 76 + .../testsuite/transport/AbstractTestsuiteTest.java | 71 + .../testsuite/transport/TestsuitePermutation.java | 45 + .../io/netty/testsuite/transport/package-info.java | 20 + .../testsuite/transport/sctp/AbstractSctpTest.java | 51 + .../testsuite/transport/sctp/SctpEchoTest.java | 185 + .../transport/sctp/SctpTestPermutation.java | 130 + .../testsuite/transport/sctp/package-info.java | 20 + .../transport/socket/AbstractClientSocketTest.java | 54 + .../transport/socket/AbstractDatagramTest.java | 56 + .../transport/socket/AbstractServerSocketTest.java | 55 + .../transport/socket/AbstractSocketTest.java | 58 + .../transport/socket/DatagramMulticastTest.java | 122 + .../transport/socket/DatagramUnicastTest.java | 196 + .../transport/socket/ServerSocketSuspendTest.java | 109 + .../transport/socket/SocketAutoReadTest.java | 201 + .../transport/socket/SocketBufReleaseTest.java | 115 + .../transport/socket/SocketCancelWriteTest.java | 122 + .../socket/SocketConnectionAttemptTest.java | 160 + .../testsuite/transport/socket/SocketEchoTest.java | 275 + .../transport/socket/SocketFileRegionTest.java | 232 + .../socket/SocketFixedLengthEchoTest.java | 196 + .../transport/socket/SocketGatheringWriteTest.java | 223 + .../transport/socket/SocketObjectEchoTest.java | 201 + .../socket/SocketShutdownOutputByPeerTest.java | 142 + .../socket/SocketShutdownOutputBySelfTest.java | 93 + .../transport/socket/SocketSpdyEchoTest.java | 315 + .../socket/SocketSslClientRenegotiateTest.java | 234 + .../transport/socket/SocketSslEchoTest.java | 547 ++ .../transport/socket/SocketSslGreetingTest.java | 213 + .../transport/socket/SocketStartTlsTest.java | 332 ++ .../transport/socket/SocketStringEchoTest.java | 202 + .../transport/socket/SocketTestPermutation.java | 171 + .../socket/TrafficShapingHandlerTest.java | 547 ++ .../socket/WriteBeforeRegisteredTest.java | 52 + .../testsuite/transport/socket/package-info.java | 20 + .../udt/UDTClientServerConnectionTest.java | 388 ++ .../testsuite/transport/udt/package-info.java | 21 + .../java/io/netty/testsuite/util/TestUtils.java | 357 ++ .../java/io/netty/testsuite/util/package-info.java | 20 + .../websockets/autobahn/AutobahnServer.java | 65 + .../websockets/autobahn/AutobahnServerHandler.java | 149 + .../autobahn/AutobahnServerInitializer.java | 33 + .../websockets/autobahn/package-info.java | 64 + transport-native-epoll/README.md | 3 + transport-native-epoll/pom.xml | 214 + .../src/main/c/exception_helper.h | 23 + .../src/main/c/io_netty_channel_epoll_Native.c | 1679 ++++++ .../src/main/c/io_netty_channel_epoll_Native.h | 129 + .../main/c/io_netty_channel_unix_FileDescriptor.c | 40 + .../main/c/io_netty_channel_unix_FileDescriptor.h | 19 + .../netty/channel/epoll/AbstractEpollChannel.java | 342 ++ .../channel/epoll/AbstractEpollServerChannel.java | 145 + .../channel/epoll/AbstractEpollStreamChannel.java | 1093 ++++ .../main/java/io/netty/channel/epoll/Epoll.java | 90 + .../io/netty/channel/epoll/EpollChannelConfig.java | 167 + .../io/netty/channel/epoll/EpollChannelOption.java | 40 + .../netty/channel/epoll/EpollDatagramChannel.java | 624 ++ .../channel/epoll/EpollDatagramChannelConfig.java | 311 + .../channel/epoll/EpollDomainSocketChannel.java | 202 + .../epoll/EpollDomainSocketChannelConfig.java | 140 + .../io/netty/channel/epoll/EpollEventArray.java | 104 + .../io/netty/channel/epoll/EpollEventLoop.java | 381 ++ .../netty/channel/epoll/EpollEventLoopGroup.java | 78 + .../java/io/netty/channel/epoll/EpollMode.java | 36 + .../channel/epoll/EpollServerChannelConfig.java | 165 + .../epoll/EpollServerDomainSocketChannel.java | 97 + .../channel/epoll/EpollServerSocketChannel.java | 92 + .../epoll/EpollServerSocketChannelConfig.java | 160 + .../io/netty/channel/epoll/EpollSocketChannel.java | 206 + .../channel/epoll/EpollSocketChannelConfig.java | 376 ++ .../java/io/netty/channel/epoll/EpollTcpInfo.java | 193 + .../main/java/io/netty/channel/epoll/IovArray.java | 223 + .../netty/channel/epoll/IovArrayThreadLocal.java | 61 + .../main/java/io/netty/channel/epoll/Native.java | 711 +++ .../channel/epoll/NativeDatagramPacketArray.java | 158 + .../java/io/netty/channel/epoll/package-info.java | 21 + .../io/netty/channel/unix/DomainSocketAddress.java | 67 + .../io/netty/channel/unix/DomainSocketChannel.java | 31 + .../channel/unix/DomainSocketChannelConfig.java | 73 + .../netty/channel/unix/DomainSocketReadMode.java | 32 + .../java/io/netty/channel/unix/FileDescriptor.java | 109 + .../channel/unix/ServerDomainSocketChannel.java | 30 + .../java/io/netty/channel/unix/UnixChannel.java | 28 + .../java/io/netty/channel/unix/package-info.java | 20 + .../channel/epoll/EpollDatagramUnicastTest.java | 29 + .../channel/epoll/EpollDomainSocketEchoTest.java | 35 + .../channel/epoll/EpollDomainSocketFdTest.java | 105 + .../epoll/EpollDomainSocketFileRegionTest.java | 35 + .../EpollDomainSocketFixedLengthEchoTest.java | 37 + .../epoll/EpollDomainSocketGatheringWriteTest.java | 37 + .../epoll/EpollDomainSocketObjectEchoTest.java | 36 + .../epoll/EpollDomainSocketSslEchoTest.java | 47 + .../epoll/EpollDomainSocketSslGreetingTest.java | 42 + .../epoll/EpollDomainSocketStartTlsTest.java | 42 + .../epoll/EpollDomainSocketStringEchoTest.java | 36 + .../io/netty/channel/epoll/EpollReuseAddrTest.java | 237 + .../epoll/EpollSocketChannelConfigTest.java | 113 + .../channel/epoll/EpollSocketChannelTest.java | 101 + .../epoll/EpollSocketConnectionAttemptTest.java | 29 + .../netty/channel/epoll/EpollSocketEchoTest.java | 31 + .../channel/epoll/EpollSocketFileRegionTest.java | 31 + .../epoll/EpollSocketFixedLengthEchoTest.java | 31 + .../epoll/EpollSocketGatheringWriteTest.java | 31 + .../channel/epoll/EpollSocketObjectEchoTest.java | 31 + .../channel/epoll/EpollSocketSslEchoTest.java | 41 + .../channel/epoll/EpollSocketSslGreetingTest.java | 36 + .../channel/epoll/EpollSocketStartTlsTest.java | 36 + .../channel/epoll/EpollSocketStringEchoTest.java | 31 + .../channel/epoll/EpollSocketTestPermutation.java | 169 + .../io/netty/channel/epoll/EpollSpliceTest.java | 321 + .../java/io/netty/channel/epoll/EpollTest.java | 27 + .../java/io/netty/channel/epoll/NativeTest.java | 49 + transport-rxtx/pom.xml | 50 + .../channel/rxtx/DefaultRxtxChannelConfig.java | 260 + .../java/io/netty/channel/rxtx/RxtxChannel.java | 174 + .../io/netty/channel/rxtx/RxtxChannelConfig.java | 302 + .../io/netty/channel/rxtx/RxtxChannelOption.java | 55 + .../io/netty/channel/rxtx/RxtxDeviceAddress.java | 45 + .../java/io/netty/channel/rxtx/package-info.java | 20 + transport-sctp/pom.xml | 64 + .../sun/nio/sctp/AbstractNotificationHandler.java | 43 + .../main/java/com/sun/nio/sctp/Association.java | 22 + .../nio/sctp/AssociationChangeNotification.java | 22 + .../main/java/com/sun/nio/sctp/HandlerResult.java | 20 + .../main/java/com/sun/nio/sctp/MessageInfo.java | 38 + .../main/java/com/sun/nio/sctp/Notification.java | 20 + .../java/com/sun/nio/sctp/NotificationHandler.java | 19 + .../nio/sctp/PeerAddressChangeNotification.java | 22 + .../main/java/com/sun/nio/sctp/SctpChannel.java | 58 + .../java/com/sun/nio/sctp/SctpServerChannel.java | 51 + .../java/com/sun/nio/sctp/SctpSocketOption.java | 21 + .../sun/nio/sctp/SctpStandardSocketOptions.java | 52 + .../com/sun/nio/sctp/SendFailedNotification.java | 22 + .../com/sun/nio/sctp/ShutdownNotification.java | 22 + .../sctp/UnsupportedOperatingSystemException.java | 40 + .../main/java/com/sun/nio/sctp/package-info.java | 22 + .../channel/sctp/DefaultSctpChannelConfig.java | 234 + .../sctp/DefaultSctpServerChannelConfig.java | 218 + .../java/io/netty/channel/sctp/SctpChannel.java | 114 + .../io/netty/channel/sctp/SctpChannelConfig.java | 129 + .../io/netty/channel/sctp/SctpChannelOption.java | 51 + .../java/io/netty/channel/sctp/SctpMessage.java | 197 + .../channel/sctp/SctpNotificationHandler.java | 73 + .../io/netty/channel/sctp/SctpServerChannel.java | 87 + .../channel/sctp/SctpServerChannelConfig.java | 124 + .../io/netty/channel/sctp/nio/NioSctpChannel.java | 407 ++ .../channel/sctp/nio/NioSctpServerChannel.java | 239 + .../io/netty/channel/sctp/nio/package-info.java | 21 + .../io/netty/channel/sctp/oio/OioSctpChannel.java | 475 ++ .../channel/sctp/oio/OioSctpServerChannel.java | 308 + .../io/netty/channel/sctp/oio/package-info.java | 21 + .../java/io/netty/channel/sctp/package-info.java | 20 + .../codec/sctp/SctpInboundByteStreamHandler.java | 64 + .../codec/sctp/SctpMessageCompletionHandler.java | 74 + .../codec/sctp/SctpMessageToMessageDecoder.java | 39 + .../codec/sctp/SctpOutboundByteStreamHandler.java | 58 + .../io/netty/handler/codec/sctp/package-info.java | 20 + transport-udt/.gitignore | 7 + transport-udt/pom.xml | 82 + .../netty/channel/udt/DefaultUdtChannelConfig.java | 295 + .../channel/udt/DefaultUdtServerChannelConfig.java | 198 + .../main/java/io/netty/channel/udt/UdtChannel.java | 41 + .../io/netty/channel/udt/UdtChannelConfig.java | 184 + .../io/netty/channel/udt/UdtChannelOption.java | 54 + .../main/java/io/netty/channel/udt/UdtMessage.java | 55 + .../io/netty/channel/udt/UdtServerChannel.java | 28 + .../netty/channel/udt/UdtServerChannelConfig.java | 102 + .../channel/udt/nio/NioUdtAcceptorChannel.java | 158 + .../channel/udt/nio/NioUdtByteAcceptorChannel.java | 35 + .../udt/nio/NioUdtByteConnectorChannel.java | 188 + .../udt/nio/NioUdtByteRendezvousChannel.java | 29 + .../udt/nio/NioUdtMessageAcceptorChannel.java | 35 + .../udt/nio/NioUdtMessageConnectorChannel.java | 244 + .../udt/nio/NioUdtMessageRendezvousChannel.java | 33 + .../io/netty/channel/udt/nio/NioUdtProvider.java | 245 + .../io/netty/channel/udt/nio/package-info.java | 22 + .../java/io/netty/channel/udt/package-info.java | 22 + .../java/io/netty/test/udt/bench/BenchXfer.java | 50 + .../java/io/netty/test/udt/bench/package-info.java | 21 + .../io/netty/test/udt/bench/xfer/TcpNative.java | 66 + .../io/netty/test/udt/bench/xfer/UdtNative.java | 271 + .../io/netty/test/udt/bench/xfer/UdtNetty.java | 135 + .../io/netty/test/udt/bench/xfer/package-info.java | 21 + .../io/netty/test/udt/nio/AbstractUdtTest.java | 37 + .../udt/nio/NioUdtByteAcceptorChannelTest.java | 33 + .../udt/nio/NioUdtByteConnectorChannelTest.java | 33 + .../udt/nio/NioUdtByteRendezvousChannelTest.java | 121 + .../udt/nio/NioUdtMessageAcceptorChannelTest.java | 33 + .../udt/nio/NioUdtMessageConnectorChannelTest.java | 33 + .../nio/NioUdtMessageRendezvousChannelTest.java | 120 + .../io/netty/test/udt/nio/NioUdtProviderTest.java | 74 + .../java/io/netty/test/udt/nio/package-info.java | 21 + .../java/io/netty/test/udt/util/CaliperBench.java | 99 + .../io/netty/test/udt/util/CaliperMeasure.java | 215 + .../java/io/netty/test/udt/util/CaliperRunner.java | 239 + .../io/netty/test/udt/util/CustomReporter.java | 250 + .../io/netty/test/udt/util/EchoByteHandler.java | 81 + .../io/netty/test/udt/util/EchoMessageHandler.java | 77 + .../io/netty/test/udt/util/TrafficControl.java | 79 + .../test/java/io/netty/test/udt/util/UnitHelp.java | 276 + .../java/io/netty/test/udt/util/package-info.java | 21 + transport/pom.xml | 39 + .../java/io/netty/bootstrap/AbstractBootstrap.java | 487 ++ .../main/java/io/netty/bootstrap/Bootstrap.java | 245 + .../java/io/netty/bootstrap/ChannelFactory.java | 29 + .../java/io/netty/bootstrap/ServerBootstrap.java | 334 ++ .../main/java/io/netty/bootstrap/package-info.java | 21 + .../java/io/netty/channel/AbstractChannel.java | 959 +++ .../channel/AbstractChannelHandlerContext.java | 969 +++ .../io/netty/channel/AbstractServerChannel.java | 85 + .../channel/AdaptiveRecvByteBufAllocator.java | 182 + .../java/io/netty/channel/AddressedEnvelope.java | 44 + .../src/main/java/io/netty/channel/Channel.java | 520 ++ .../main/java/io/netty/channel/ChannelConfig.java | 252 + .../io/netty/channel/ChannelDuplexHandler.java | 119 + .../java/io/netty/channel/ChannelException.java | 51 + .../netty/channel/ChannelFlushPromiseNotifier.java | 275 + .../main/java/io/netty/channel/ChannelFuture.java | 196 + .../io/netty/channel/ChannelFutureListener.java | 75 + .../main/java/io/netty/channel/ChannelHandler.java | 214 + .../io/netty/channel/ChannelHandlerAdapter.java | 81 + .../io/netty/channel/ChannelHandlerContext.java | 495 ++ .../io/netty/channel/ChannelInboundHandler.java | 74 + .../channel/ChannelInboundHandlerAdapter.java | 133 + .../java/io/netty/channel/ChannelInitializer.java | 88 + .../java/io/netty/channel/ChannelMetadata.java | 46 + .../main/java/io/netty/channel/ChannelOption.java | 148 + .../io/netty/channel/ChannelOutboundBuffer.java | 831 +++ .../io/netty/channel/ChannelOutboundHandler.java | 99 + .../channel/ChannelOutboundHandlerAdapter.java | 117 + .../java/io/netty/channel/ChannelPipeline.java | 879 +++ .../io/netty/channel/ChannelPipelineException.java | 52 + .../io/netty/channel/ChannelProgressiveFuture.java | 49 + .../channel/ChannelProgressiveFutureListener.java | 28 + .../netty/channel/ChannelProgressivePromise.java | 62 + .../main/java/io/netty/channel/ChannelPromise.java | 63 + .../io/netty/channel/ChannelPromiseAggregator.java | 34 + .../io/netty/channel/ChannelPromiseNotifier.java | 35 + .../channel/CombinedChannelDuplexHandler.java | 204 + .../io/netty/channel/CompleteChannelFuture.java | 107 + .../io/netty/channel/ConnectTimeoutException.java | 33 + .../io/netty/channel/DefaultAddressedEnvelope.java | 115 + .../io/netty/channel/DefaultChannelConfig.java | 360 ++ .../channel/DefaultChannelHandlerContext.java | 45 + .../io/netty/channel/DefaultChannelPipeline.java | 1135 ++++ .../channel/DefaultChannelProgressivePromise.java | 169 + .../io/netty/channel/DefaultChannelPromise.java | 160 + .../java/io/netty/channel/DefaultFileRegion.java | 163 + .../netty/channel/DefaultMessageSizeEstimator.java | 72 + .../src/main/java/io/netty/channel/EventLoop.java | 30 + .../java/io/netty/channel/EventLoopException.java | 41 + .../main/java/io/netty/channel/EventLoopGroup.java | 43 + .../java/io/netty/channel/FailedChannelFuture.java | 65 + .../src/main/java/io/netty/channel/FileRegion.java | 83 + .../netty/channel/FixedRecvByteBufAllocator.java | 69 + .../io/netty/channel/MessageSizeEstimator.java | 39 + .../netty/channel/MultithreadEventLoopGroup.java | 71 + .../java/io/netty/channel/PendingWriteQueue.java | 304 + .../io/netty/channel/RecvByteBufAllocator.java | 54 + .../main/java/io/netty/channel/ServerChannel.java | 27 + .../netty/channel/SimpleChannelInboundHandler.java | 129 + .../io/netty/channel/SingleThreadEventLoop.java | 73 + .../io/netty/channel/SucceededChannelFuture.java | 45 + .../netty/channel/ThreadPerChannelEventLoop.java | 81 + .../channel/ThreadPerChannelEventLoopGroup.java | 295 + .../java/io/netty/channel/VoidChannelPromise.java | 205 + .../io/netty/channel/embedded/EmbeddedChannel.java | 393 ++ .../netty/channel/embedded/EmbeddedEventLoop.java | 143 + .../channel/embedded/EmbeddedSocketAddress.java | 27 + .../io/netty/channel/embedded/package-info.java | 22 + .../java/io/netty/channel/group/ChannelGroup.java | 236 + .../netty/channel/group/ChannelGroupException.java | 52 + .../io/netty/channel/group/ChannelGroupFuture.java | 175 + .../channel/group/ChannelGroupFutureListener.java | 28 + .../io/netty/channel/group/ChannelMatcher.java | 32 + .../io/netty/channel/group/ChannelMatchers.java | 169 + .../io/netty/channel/group/CombinedIterator.java | 76 + .../netty/channel/group/DefaultChannelGroup.java | 389 ++ .../channel/group/DefaultChannelGroupFuture.java | 264 + .../java/io/netty/channel/group/package-info.java | 21 + .../java/io/netty/channel/local/LocalAddress.java | 94 + .../java/io/netty/channel/local/LocalChannel.java | 379 ++ .../netty/channel/local/LocalChannelRegistry.java | 62 + .../io/netty/channel/local/LocalEventLoop.java | 42 + .../netty/channel/local/LocalEventLoopGroup.java | 59 + .../io/netty/channel/local/LocalServerChannel.java | 165 + .../java/io/netty/channel/local/package-info.java | 21 + .../netty/channel/nio/AbstractNioByteChannel.java | 351 ++ .../io/netty/channel/nio/AbstractNioChannel.java | 472 ++ .../channel/nio/AbstractNioMessageChannel.java | 188 + .../java/io/netty/channel/nio/NioEventLoop.java | 692 +++ .../io/netty/channel/nio/NioEventLoopGroup.java | 89 + .../main/java/io/netty/channel/nio/NioTask.java | 41 + .../netty/channel/nio/SelectedSelectionKeySet.java | 110 + .../java/io/netty/channel/nio/package-info.java | 21 + .../netty/channel/oio/AbstractOioByteChannel.java | 261 + .../io/netty/channel/oio/AbstractOioChannel.java | 113 + .../channel/oio/AbstractOioMessageChannel.java | 106 + .../io/netty/channel/oio/OioByteStreamChannel.java | 168 + .../io/netty/channel/oio/OioEventLoopGroup.java | 69 + .../java/io/netty/channel/oio/package-info.java | 21 + .../main/java/io/netty/channel/package-info.java | 22 + .../channel/pool/AbstractChannelPoolHandler.java | 44 + .../netty/channel/pool/AbstractChannelPoolMap.java | 100 + .../netty/channel/pool/ChannelHealthChecker.java | 47 + .../java/io/netty/channel/pool/ChannelPool.java | 56 + .../io/netty/channel/pool/ChannelPoolHandler.java | 48 + .../java/io/netty/channel/pool/ChannelPoolMap.java | 39 + .../io/netty/channel/pool/FixedChannelPool.java | 382 ++ .../io/netty/channel/pool/SimpleChannelPool.java | 278 + .../java/io/netty/channel/pool/package-info.java | 20 + .../channel/socket/ChannelInputShutdownEvent.java | 36 + .../io/netty/channel/socket/DatagramChannel.java | 165 + .../channel/socket/DatagramChannelConfig.java | 182 + .../io/netty/channel/socket/DatagramPacket.java | 66 + .../socket/DefaultDatagramChannelConfig.java | 421 ++ .../socket/DefaultServerSocketChannelConfig.java | 201 + .../channel/socket/DefaultSocketChannelConfig.java | 341 ++ .../channel/socket/InternetProtocolFamily.java | 24 + .../netty/channel/socket/ServerSocketChannel.java | 32 + .../channel/socket/ServerSocketChannelConfig.java | 107 + .../io/netty/channel/socket/SocketChannel.java | 62 + .../netty/channel/socket/SocketChannelConfig.java | 183 + .../channel/socket/nio/NioDatagramChannel.java | 589 ++ .../socket/nio/NioDatagramChannelConfig.java | 199 + .../channel/socket/nio/NioServerSocketChannel.java | 197 + .../netty/channel/socket/nio/NioSocketChannel.java | 353 ++ .../socket/nio/ProtocolFamilyConverter.java | 45 + .../io/netty/channel/socket/nio/package-info.java | 21 + .../oio/DefaultOioServerSocketChannelConfig.java | 183 + .../socket/oio/DefaultOioSocketChannelConfig.java | 211 + .../channel/socket/oio/OioDatagramChannel.java | 435 ++ .../channel/socket/oio/OioServerSocketChannel.java | 202 + .../socket/oio/OioServerSocketChannelConfig.java | 95 + .../netty/channel/socket/oio/OioSocketChannel.java | 240 + .../channel/socket/oio/OioSocketChannelConfig.java | 110 + .../io/netty/channel/socket/oio/package-info.java | 21 + .../java/io/netty/channel/socket/package-info.java | 20 + .../java/io/netty/bootstrap/BootstrapTest.java | 239 + .../io/netty/bootstrap/ServerBootstrapTest.java | 62 + .../java/io/netty/channel/AbstractChannelTest.java | 168 + .../io/netty/channel/AbstractEventLoopTest.java | 72 + .../java/io/netty/channel/BaseChannelTest.java | 90 + .../java/io/netty/channel/ChannelOptionTest.java | 64 + .../netty/channel/ChannelOutboundBufferTest.java | 364 ++ .../netty/channel/CompleteChannelFutureTest.java | 88 + .../netty/channel/DefaultChannelPipelineTest.java | 673 +++ .../io/netty/channel/FailedChannelFutureTest.java | 38 + .../test/java/io/netty/channel/LoggingHandler.java | 171 + .../io/netty/channel/PendingWriteQueueTest.java | 288 + .../io/netty/channel/ReentrantChannelTest.java | 285 + .../netty/channel/SingleThreadEventLoopTest.java | 502 ++ .../netty/channel/SucceededChannelFutureTest.java | 32 + .../ThreadPerChannelEventLoopGroupTest.java | 114 + .../channel/embedded/EmbeddedChannelTest.java | 137 + .../channel/group/DefaultChannnelGroupTest.java | 60 + .../io/netty/channel/local/LocalChannelTest.java | 289 + .../local/LocalTransportThreadModelTest.java | 589 ++ .../local/LocalTransportThreadModelTest2.java | 121 + .../local/LocalTransportThreadModelTest3.java | 327 ++ .../netty/channel/nio/NioDatagramChannelTest.java | 64 + .../io/netty/channel/nio/NioEventLoopTest.java | 34 + .../io/netty/channel/nio/NioSocketChannelTest.java | 144 + .../io/netty/channel/oio/OioEventLoopTest.java | 115 + .../channel/pool/AbstractChannelPoolMapTest.java | 75 + .../channel/pool/CountingChannelPoolHandler.java | 53 + .../netty/channel/pool/FixedChannelPoolTest.java | 233 + .../netty/channel/pool/SimpleChannelPoolTest.java | 145 + 1296 files changed, 216111 insertions(+) -- Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/pkg-java/netty.git _______________________________________________ pkg-java-commits mailing list [email protected] http://lists.alioth.debian.org/cgi-bin/mailman/listinfo/pkg-java-commits
