[netty] 12/18: Merge tag 'upstream/4.0.30'
Emmanuel Bourg
ebourg-guest at moszumanska.debian.org
Sat Sep 12 22:20:30 UTC 2015
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 <ebourg at apache.org>
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
More information about the pkg-java-commits
mailing list