AbstractSimpleTransportTestCase.java |  | 0% |  | 0% | 409 | 409 | 1,547 | 1,547 | 331 | 331 | 57 | 57 |
TransportService.java |  | 0% |  | 0% | 266 | 266 | 550 | 550 | 166 | 166 | 18 | 18 |
TcpTransport.java |  | 0% |  | 0% | 200 | 200 | 458 | 458 | 96 | 96 | 6 | 6 |
SniffConnectionStrategy.java |  | 0% |  | 0% | 129 | 129 | 241 | 241 | 75 | 75 | 7 | 7 |
RemoteClusterService.java |  | 0% |  | 0% | 76 | 76 | 193 | 193 | 47 | 47 | 4 | 4 |
RemoteConnectionStrategy.java |  | 0% |  | 0% | 84 | 84 | 189 | 189 | 48 | 48 | 7 | 7 |
InboundHandler.java |  | 0% |  | 0% | 58 | 58 | 170 | 170 | 23 | 23 | 2 | 2 |
TransportSettings.java |  | 0% |  | 0% | 21 | 21 | 113 | 113 | 20 | 20 | 1 | 1 |
ProxyConnectionStrategy.java |  | 0% |  | 0% | 69 | 69 | 126 | 126 | 42 | 42 | 3 | 3 |
ConnectionProfile.java |  | 0% |  | 0% | 58 | 58 | 130 | 130 | 27 | 27 | 3 | 3 |
ReuseBuffersLZ4BlockOutputStream.java |  | 0% |  | 0% | 49 | 49 | 121 | 121 | 21 | 21 | 2 | 2 |
Lz4TransportDecompressor.java |  | 0% |  | 0% | 49 | 49 | 143 | 143 | 12 | 12 | 2 | 2 |
InboundAggregator.java |  | 0% |  | 0% | 78 | 78 | 125 | 125 | 25 | 25 | 2 | 2 |
ClusterConnectionManager.java |  | 0% |  | 0% | 54 | 54 | 116 | 116 | 27 | 27 | 2 | 2 |
InboundPipeline.java |  | 0% |  | 0% | 50 | 50 | 90 | 90 | 12 | 12 | 1 | 1 |
NettyAllocator.java |  | 0% |  | 0% | 62 | 62 | 99 | 99 | 35 | 35 | 2 | 2 |
OutboundHandler.java |  | 0% |  | 0% | 27 | 27 | 86 | 86 | 20 | 20 | 2 | 2 |
InboundDecoder.java |  | 0% |  | 0% | 40 | 40 | 109 | 109 | 14 | 14 | 1 | 1 |
LeakTracker.java |  | 0% |  | 0% | 39 | 39 | 106 | 106 | 15 | 15 | 3 | 3 |
TransportActionProxy.java |  | 0% |  | 0% | 40 | 40 | 78 | 78 | 28 | 28 | 6 | 6 |
TransportHandshaker.java |  | 0% |  | 0% | 40 | 40 | 87 | 87 | 23 | 23 | 4 | 4 |
TransportLogger.java |  | 0% |  | 0% | 25 | 25 | 90 | 90 | 8 | 8 | 1 | 1 |
RemoteConnectionInfo.java |  | 0% |  | 0% | 26 | 26 | 83 | 83 | 13 | 13 | 1 | 1 |
OutboundMessage.java |  | 0% |  | 0% | 28 | 28 | 76 | 76 | 13 | 13 | 3 | 3 |
TransportKeepAlive.java |  | 0% |  | 0% | 32 | 32 | 75 | 75 | 23 | 23 | 3 | 3 |
CopyBytesSocketChannel.java |  | 0% |  | 0% | 31 | 31 | 82 | 82 | 16 | 16 | 2 | 2 |
RemoteConnectionManager.java |  | 0% |  | 0% | 40 | 40 | 73 | 73 | 30 | 30 | 3 | 3 |
DeflateTransportDecompressor.java |  | 0% |  | 0% | 27 | 27 | 65 | 65 | 7 | 7 | 1 | 1 |
TransportInfo.java |  | 0% |  | 0% | 23 | 23 | 58 | 58 | 12 | 12 | 2 | 2 |
RemoteClusterConnection.java |  | 0% |  | 0% | 23 | 23 | 56 | 56 | 22 | 22 | 2 | 2 |
RemoteClusterAware.java |  | 0% |  | 0% | 17 | 17 | 32 | 32 | 9 | 9 | 1 | 1 |
Transport.java |  | 0% |  | 0% | 29 | 29 | 48 | 48 | 21 | 21 | 5 | 5 |
Header.java |  | 0% |  | 0% | 27 | 27 | 39 | 39 | 19 | 19 | 1 | 1 |
TransportStats.java |  | 0% |  | 0% | 17 | 17 | 46 | 46 | 15 | 15 | 2 | 2 |
InboundMessage.java |  | 0% |  | 0% | 23 | 23 | 46 | 46 | 14 | 14 | 1 | 1 |
Compression.java |  | 0% |  | 0% | 14 | 14 | 34 | 34 | 7 | 7 | 3 | 3 |
SharedGroupFactory.java |  | 0% |  | 0% | 17 | 17 | 39 | 39 | 12 | 12 | 3 | 3 |
Netty4Plugin.java |  | 0% |  | 0% | 13 | 13 | 18 | 18 | 9 | 9 | 1 | 1 |
Transports.java |  | 0% |  | 0% | 17 | 17 | 19 | 19 | 5 | 5 | 1 | 1 |
RequestHandlerRegistry.java |  | 0% |  | 0% | 13 | 13 | 28 | 28 | 11 | 11 | 1 | 1 |
TcpTransportChannel.java |  | 0% |  | 0% | 14 | 14 | 29 | 29 | 9 | 9 | 1 | 1 |
FakeTcpChannel.java |  | 0% |  | 0% | 19 | 19 | 36 | 36 | 18 | 18 | 1 | 1 |
PlainTransportFuture.java |  | 0% |  | 0% | 10 | 10 | 32 | 32 | 8 | 8 | 1 | 1 |
ActionTransportException.java |  | 0% |  | 0% | 11 | 11 | 28 | 28 | 7 | 7 | 1 | 1 |
TcpHeader.java |  | 0% |  | 0% | 10 | 10 | 17 | 17 | 4 | 4 | 1 | 1 |
ConnectionManager.java |  | 0% |  | 0% | 11 | 11 | 22 | 22 | 7 | 7 | 1 | 1 |
RemoteClusterAwareClient.java |  | 0% |  | 0% | 6 | 6 | 18 | 18 | 5 | 5 | 1 | 1 |
TransportDecompressor.java |  | 0% |  | 0% | 6 | 6 | 15 | 15 | 2 | 2 | 1 | 1 |
TransportRequestOptions.java |  | 0% |  | 0% | 9 | 9 | 17 | 17 | 7 | 7 | 2 | 2 |
NetworkMessage.java |  | 0% |  | 0% | 13 | 13 | 17 | 17 | 9 | 9 | 1 | 1 |
TransportStatus.java |  | 0% |  | 0% | 14 | 14 | 15 | 15 | 10 | 10 | 1 | 1 |
MockTransportClient.java |  | 0% |  | 0% | 9 | 9 | 18 | 18 | 6 | 6 | 1 | 1 |
ConnectTransportException.java | | 0% |  | 0% | 9 | 9 | 16 | 16 | 7 | 7 | 1 | 1 |
TestProfiles.java | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 | 1 | 1 |
BytesTransportRequest.java | | 0% | | n/a | 9 | 9 | 20 | 20 | 9 | 9 | 1 | 1 |
TransportResponseHandler.java | | 0% | | n/a | 9 | 9 | 11 | 11 | 9 | 9 | 3 | 3 |
TransportRequest.java | | 0% | | n/a | 9 | 9 | 16 | 16 | 9 | 9 | 2 | 2 |
StatsTracker.java | | 0% | | n/a | 9 | 9 | 15 | 15 | 9 | 9 | 1 | 1 |
NettyByteBufSizer.java | | 0% |  | 0% | 6 | 6 | 10 | 10 | 2 | 2 | 1 | 1 |
NotSerializableTransportException.java | | 0% |  | 0% | 5 | 5 | 11 | 11 | 4 | 4 | 1 | 1 |
TaskTransportChannel.java | | 0% | | n/a | 7 | 7 | 14 | 14 | 7 | 7 | 1 | 1 |
CopyBytesServerSocketChannel.java | | 0% |  | 0% | 4 | 4 | 14 | 14 | 3 | 3 | 1 | 1 |
ActionNotFoundTransportException.java | | 0% | | n/a | 4 | 4 | 10 | 10 | 4 | 4 | 1 | 1 |
TransportChannel.java | | 0% | | n/a | 4 | 4 | 8 | 8 | 4 | 4 | 1 | 1 |
TestTransportChannels.java | | 0% | | n/a | 3 | 3 | 3 | 3 | 3 | 3 | 1 | 1 |
CloseableConnection.java | | 0% | | n/a | 4 | 4 | 7 | 7 | 4 | 4 | 1 | 1 |
TestRequest.java | | 0% | | n/a | 3 | 3 | 9 | 9 | 3 | 3 | 1 | 1 |
TransportException.java | | 0% | | n/a | 4 | 4 | 8 | 8 | 4 | 4 | 1 | 1 |
SendRequestTransportException.java | | 0% |  | 0% | 4 | 4 | 4 | 4 | 2 | 2 | 1 | 1 |
RemoteTransportException.java | | 0% | | n/a | 4 | 4 | 7 | 7 | 4 | 4 | 1 | 1 |
TestTransportChannel.java | | 0% | | n/a | 5 | 5 | 9 | 9 | 5 | 5 | 1 | 1 |
NoSeedNodeLeftException.java | | 0% | | n/a | 2 | 2 | 4 | 4 | 2 | 2 | 1 | 1 |
EmptyTransportResponseHandler.java | | 0% | | n/a | 6 | 6 | 8 | 8 | 6 | 6 | 1 | 1 |
NoSuchRemoteClusterException.java | | 0% | | n/a | 2 | 2 | 4 | 4 | 2 | 2 | 1 | 1 |
TestResponse.java | | 0% | | n/a | 3 | 3 | 8 | 8 | 3 | 3 | 1 | 1 |
TransportMessage.java | | 0% | | n/a | 7 | 7 | 8 | 8 | 7 | 7 | 1 | 1 |
TransportResponse.java | | 0% | | n/a | 6 | 6 | 8 | 8 | 6 | 6 | 2 | 2 |
ReceiveTimeoutTransportException.java | | 0% | | n/a | 3 | 3 | 5 | 5 | 3 | 3 | 1 | 1 |
TcpChannel.java | | 0% | | n/a | 3 | 3 | 6 | 6 | 3 | 3 | 1 | 1 |
NodeDisconnectedException.java | | 0% | | n/a | 3 | 3 | 5 | 5 | 3 | 3 | 1 | 1 |
TransportMessageListener.java | | 0% | | n/a | 7 | 7 | 6 | 6 | 7 | 7 | 2 | 2 |
BindTransportException.java | | 0% | | n/a | 3 | 3 | 6 | 6 | 3 | 3 | 1 | 1 |
NodeNotConnectedException.java | | 0% | | n/a | 2 | 2 | 4 | 4 | 2 | 2 | 1 | 1 |
Netty4NioSocketChannel.java | | 0% | | n/a | 3 | 3 | 5 | 5 | 3 | 3 | 1 | 1 |
ResponseHandlerFailureTransportException.java | | 0% | | n/a | 3 | 3 | 5 | 5 | 3 | 3 | 1 | 1 |
TransportSerializationException.java | | 0% | | n/a | 2 | 2 | 4 | 4 | 2 | 2 | 1 | 1 |
FutureTransportResponseHandler.java | | 0% | | n/a | 4 | 4 | 4 | 4 | 4 | 4 | 1 | 1 |
TransportNotReadyException.java | | 0% | | n/a | 2 | 2 | 3 | 3 | 2 | 2 | 1 | 1 |
TransportInterceptor.java | | 0% | | n/a | 2 | 2 | 2 | 2 | 2 | 2 | 1 | 1 |
TransportConnectionListener.java | | 0% | | n/a | 4 | 4 | 4 | 4 | 4 | 4 | 1 | 1 |
RawIndexingDataTransportRequest.java | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |