org.apache.hadoop.ipc

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total47,087 of 47,0870%2,554 of 2,5540%3,0803,08010,79010,7901,8001,800283283
TestRPC3,4300%1180%110110853853515111
TestIPC2,8660%700%109109691691747411
Server2,4850%2160%21121158558510310311
Server.Connection2,1210%2200%158158505505474711
TestFairCallQueue2,1070%260%5050357357373711
TestSaslRPC2,0450%480%7070425425454511
DecayRpcScheduler1,9010%1300%120120386386555511
Client.Connection1,6120%1900%121121383383262611
TestDecayRpcScheduler1,3970%280%3636252252222211
TestCallQueueManager1,0140%200%2525218218151511
CallQueueManager9330%420%5959175175383811
Client6840%600%6767169169373711
TestAsyncIPC5980%220%2525138138141411
TestProtoBufRpc5590%180%2424148148151511
Server.Responder5540%480%3434139139101011
RPC5350%360%4747119119292911
FairCallQueue5260%540%5353115115262611
Server.Listener5000%320%2626117117101011
MiniRPCBenchmark4670%340%2828122122111111
Server.RpcCall4640%200%2828111111181811
TestWeightedRoundRobinMultiplexer4470%40%101069698811
TestIPCServerResponder4230%100%121294947711
RPCCallBenchmark4140%300%25259292101011
RPCCallBenchmark.MyOptions4090%320%22221251256611
ProtobufRpcEngine2.Invoker4050%260%24248888111111
Server.ConnectionManager4050%440%39398585171711
ProtobufRpcEngine.Invoker4050%260%24248787111111
TestServer3940%40%111183839911
Client.ConnectionId3720%480%44446262202011
RPC.Server3500%320%26267272101011
RpcClientUtil3000%260%24246868111111
TestRpcBase.PBServerImpl2980%100%25258989202011
RetryCache2940%280%33338585191911
TestRpcWritable2870%80%101068686611
TestSocketFactory2860%60%121282829911
Server.Handler2760%240%151559593311
TestRpcBase2750%260%34347777212111
TestRetryCache2640%140%19195555121211
ProtocolSignature2640%180%25256565161611
Server.Call2580%160%47477878393911
WritableRpcEngine.Invocation2530%100%18185858131311
TestMRCJCSocketFactory2400%100%131375758811
TestProtoBufRpcServerHandoff2390%80%9955555511
WritableRpcEngine.Server.WritableRpcInvoker2280%200%121255552211
ProtobufRpcEngine2.Server.ProtoBufRpcInvoker2200%120%111152525511
TestReuseRpcConnections2130%80%111161617711
CallerContext.Builder2100%320%29294141131311
ProtocolMetaInfoServerSideTranslatorPB2010%160%121246464411
Server.Listener.Reader2000%160%141454546611
TestAsyncIPC.AsyncCaller1930%100%9942424411
DecayRpcScheduler.MetricsProxy1910%200%24245656141411
TestRPCCompatibility1870%120%111139395511
TestAsyncIPC.AsyncLimitlCaller1870%60%121243439911
TestRpcServerHandoff1830%80%101056566611
WeightedRoundRobinMultiplexer1820%100%121236367711
RetryCache.CacheEntry1660%180%21213030121211
TestCallerContext1660%n/a4442424411
FairCallQueue.MetricsProxy1610%100%141438389911
ProtobufRpcEngine21590%20%13132626121211
TestResponseBuffer1570%n/a3337373311
RefreshRegistry1570%80%121235358811
WritableRpcEngine.Server1560%120%121227276611
RPC.Builder1540%60%17174545141411
Client.IpcStreams1530%140%151540408811
ProtobufRpcEngine1460%n/a10102020101011
RemoteException1390%80%131331319911
MiniRPCBenchmark.MiniServer1380%100%111127276611
ProtobufRpcEngine.Server1370%40%6634344411
ProtocolProxy1360%120%101037374411
Client.Connection.new PrivilegedExceptionAction() {...}1340%120%8826262211
ClientCache1330%140%141429297711
TestRPCServerShutdown1290%100%9934344411
ProxyCombiner.CombinedProxyInvocationHandler1280%80%9928285511
CallerContext1260%160%18183131101011
WritableRpcEngine1240%40%12122222101011
ClientId1230%140%131327276611
ProcessingDetails1200%60%13132626101011
TestWeightedTimeCostProvider1160%n/a5528285511
ProtobufRpcEngine.Server.ProtobufRpcEngineCallbackImpl1080%n/a4423234411
ProtobufRpcEngine2.Server.ProtobufRpcEngineCallbackImpl1080%n/a4423234411
WeightedTimeCostProvider1080%140%121220204411
TestSaslRPC.TestPlainCallbacks.Server1060%100%7728282211
WritableRpcEngine.Invoker1050%100%9926264411
ProtobufWrapperLegacy1010%20%7729296611
TestRPC.Transactions990%20%3325252211
TestSaslRPC.new PrivilegedExceptionAction() {...}980%40%4419192211
TestSaslRPC.new PrivilegedExceptionAction() {...}980%100%7719192211
TestIPC.TestServer970%60%111126268811
TestShadedProtobufHelper970%20%11112727101011
Client.Connection.RpcRequestSender950%80%6621212211
Client.Call950%60%101031317711
TestSocketFactory.ServerRunnable920%20%7731316611
TestProtoBufRPCCompatibility910%20%3324242211
RpcClientUtil.ProtoSigCacheKey900%160%111119193311
TestRPCWaitForProxy900%100%101030305511
ExternalCall870%60%101031317711
RefreshResponse850%40%111120209911
TestRetryCache.TestServer840%80%7718183311
TestRpcBase.TestTokenIdentifier840%60%111122228811
ProxyCombiner810%40%4410102211
RpcWritable.Buffer800%20%101021219911
TestRpcServerHandoff.ServerForHandoffTest800%20%6622225511
TestRPC.new Runnable() {...}790%60%5512122211
TestFairCallQueue.Taker770%80%6622222211
ResponseBuffer.FramedBuffer760%n/a6615156611
Client.Connection.PingInputStream710%80%8820204411
DummySocketFactory.new Socket() {...}710%80%7712123311
TestIPC.NetworkTraces700%n/a1118181111
TestIdentityProviders680%n/a3320203311
Server.MetricsUpdateRunner670%40%4414142211
Client.new AsyncGet() {...}670%40%5511113311
TestProtoBufRpcServerHandoff.ClientInvocationCallable650%20%4415153311
TestCallQueueManager.Putter650%60%6619193311
TestRPC.MockOutputStream640%40%101021218811
TestProcessingDetails640%n/a3316163311
RpcWritable.ProtobufWrapper640%n/a4416164411
TestRPCCallBenchmark630%n/a22442211
ResponseBuffer620%20%101019199911
TestAsyncIPC.new Client() {...}610%n/a3313133311
TestCallQueueManager.Taker610%80%6618182211
ProtobufRpcEngine.RpcProtobufRequest610%60%8818185511
ProtobufRpcEngine2.RpcProtobufRequest610%60%8818185511
TestRPCWaitForProxy.RpcThread600%n/a3318183311
TestIPC.SerialCaller600%40%4417172211
TestIPCServerResponder.Caller600%20%3317172211
CallQueueManager.CallQueueOverflowException590%n/a33773311
TestFairCallQueue.Putter590%60%6617173311
ProcessingDetails.Timing570%n/a1110101111
TestSaslRPC.TestPlainCallbacks.Client570%60%5513132211
ProtobufRpcEngine2.Server570%20%5515154411
RpcWritable560%80%8812124411
TestIPC.new Runnable() {...}540%n/a2210102211
TestIPC.new Runnable() {...}530%20%3311112211
RPC.Server.ProtoNameVer520%100%8813133311
TestRPC.TestImpl510%20%12121616111111
TestRetryCacheMetrics500%n/a3317173311
Server.AuthProtocol490%40%5510103311
TestRpcBase.MockConnectionId490%40%5515153311
TestIPC.new Client() {...}480%n/a33993311
MiniRPCBenchmark.new PrivilegedExceptionAction() {...}470%n/a22882211
TestRpcServerHandoff.ClientCallable470%n/a2211112211
TestIPC.TestInvocationHandler470%20%7714146611
TestRPC.StoppedRpcEngine460%n/a55665511
TestIPC.new Runnable() {...}450%n/a2210102211
Server.ExceptionsHandler450%n/a5517175511
RPC.VersionMismatch430%n/a6610106611
RpcWritable.WritableWrapper420%n/a3310103311
TestIPCServerResponder.new Server() {...}420%20%33772211
TestIPC.TestServerQueue390%n/a2210102211
ProtobufHelper390%40%9910107711
TestRPC.SlowRPC390%n/a4413134411
TestProtoBufRpcServerHandoff.TestProtoBufRpcServerHandoffServer.new Thread() {...}360%n/a2210102211
TestSaslRPC.1.new Callable() {...}360%n/a22662211
RPC.RpcKind350%n/a22882211
TestIPC.new Thread() {...}320%20%3311112211
TestRpcBase.TestTokenSelector320%80%66992211
TestIPC.new Runnable() {...}310%n/a22552211
TestMultipleProtocolServer310%n/a4411114411
TestIPC.new Callable() {...}300%n/a22442211
DecayRpcScheduler.DecayTask300%20%3310102211
RetryCache.CacheEntryWithPayload290%n/a55995511
ProtobufRpcEngine2.Invoker.new AsyncGet() {...}0%n/a33333311
ProtobufRpcEngine.Invoker.new AsyncGet() {...}0%n/a33333311
TestRPCCompatibility.TestImpl00%n/a44994411
TestProtoBufRPCCompatibility.OldServerImpl0%n/a33993311
TestProtoBufRPCCompatibility.NewerServerImpl0%n/a33993311
TestSaslRPC.UseToken0%n/a11551111
TestIPC.new Supplier() {...}0%40%44222211
TestIPC.TestInvalidTokenHandler0%n/a33663311
TestIPCServerResponder.TestServer0%20%33882211
Server.FatalRpcServerException0%n/a55885511
TestIPCServerResponder.new Callable() {...}0%n/a22332211
TestIPCServerResponder.new Callable() {...}0%n/a22332211
Server.ConnectionManager.new TimerTask() {...}0%20%33772211
RpcScheduler0%n/a22552211
RPCCallBenchmark.new MultithreadedTestUtil.RepeatingTestThread() {...}0%n/a22442211
TestIPC.new Runnable() {...}0%n/a22442211
TestMiniRPCBenchmark0%n/a22662211
TestRPC.new Callable() {...}0%n/a22442211
DummySocketFactory0%60%6610103311
TestIPC.new Supplier() {...}0%20%33222211
TestIPC.new Supplier() {...}0%20%33222211
RPCCallBenchmark.new RPCCallBenchmark.RpcServiceWrapper() {...}0%n/a22662211
TestRPC.new PrivilegedAction() {...}0%n/a22662211
TestCallQueueManager.FakeCall0%n/a44994411
TestIPC.new Runnable() {...}0%n/a22772211
TestIPC.new Answer() {...}0%n/a22442211
TestIPC.new Runnable() {...}0%n/a22442211
TestRPC.new PrivilegedExceptionAction() {...}0%n/a22442211
TestAsyncIPC.new Runnable() {...}0%n/a22442211
TestProtoBufRpc.PBServer2ImplLegacy0%n/a44884411
TestProtoBufRpc.PBServer2Impl0%n/a44884411
MiniRPCBenchmark.new PrivilegedExceptionAction() {...}0%n/a22222211
TestProtoBufRPCCompatibility.NewServerImpl0%n/a33773311
TestProtoBufRpcServerHandoff.TestProtoBufRpcServerHandoffServer0%n/a22772211
TestSaslRPC.new PrivilegedExceptionAction() {...}0%n/a22222211
TestRPC.new InputStream() {...}0%n/a22662211
TestRPC.TestReaderException0%40%44442211
TestRPC.new Callable() {...}0%n/a22332211
TestRPC.StoppedInvocationHandler0%n/a44664411
TestRPC.TestClass0%n/a44444411
Server.RpcCall.ResponseParams0%n/a11551111
TestRPC.new Callable() {...}0%n/a22332211
TestRPCServerShutdown.new Callable() {...}0%n/a22332211
TestSaslRPC.AuthSaslPropertiesResolver0%n/a22442211
TestIPC.new Runnable() {...}0%n/a22332211
TestAsyncIPC.new Runnable() {...}0%n/a22332211
RPC.Server.ProtoClassProtoImpl0%n/a22662211
ProtobufRpcEngine2.Server.CallInfo0%n/a33663311
RPCCallBenchmark.new PrivilegedExceptionAction() {...}0%n/a22222211
TestRPC.new ExternalCall() {...}0%n/a33333311
TestServer.new Server() {...}0%n/a22222211
TestServer.new Server() {...}0%n/a22222211
UserIdentityProvider0%20%33552211
Client.Connection.new PrivilegedExceptionAction() {...}0%n/a22222211
TestSaslRPC.CustomSecurityInfo0%n/a33333311
TestFairCallQueue.new RpcMultiplexer() {...}0%n/a22222211
TestFairCallQueue.new RpcMultiplexer() {...}0%n/a22222211
TestFairCallQueue.new RpcMultiplexer() {...}0%n/a22222211
RpcServerException0%n/a44664411
TestRpcBase.TestTokenSecretManager0%n/a44444411
TestRPC.new PrivilegedExceptionAction() {...}0%n/a22222211
TestSaslRPC.CustomSecurityInfo.new KerberosInfo() {...}0%n/a44444411
TestIPC.new Runnable() {...}0%n/a22332211
TestIPC.new Runnable() {...}0%n/a22332211
DecayRpcScheduler.new Schedulable() {...}0%n/a33333311
CallQueueManager.CallQueueOverflowException.new RpcServerException() {...}0%n/a22222211
TestAsyncIPC.new Runnable() {...}0%n/a22332211
TestAsyncIPC.new Runnable() {...}0%n/a22332211
TestRPC.new Schedulable() {...}0%n/a33333311
TestCallQueueManager.ExceptionFakeCall0%n/a33443311
TestRPC.TestPolicyProvider0%n/a11111111
Server.new ThreadLocal() {...}0%n/a22222211
TestIPC.new Answer() {...}0%n/a22222211
TestRPC.new RpcServerException() {...}0%n/a22222211
TestRPC.new RpcServerException() {...}0%n/a22222211
TestDecayRpcScheduler.TestIdentityProvider0%20%22441111
TestIdentityProviders.FakeSchedulable0%n/a33663311
TestSaslRPC.CustomSecurityInfo.new TokenInfo() {...}0%n/a33333311
RPC.Server.VerProtocolImpl0%n/a11441111
RpcException0%n/a22442211
TestRPC.new PrivilegedExceptionAction() {...}0%n/a22222211
DefaultRpcScheduler0%n/a55665511
TestRPC.FakeRequestClass0%n/a33333311
TestIPC.CallInfo0%n/a11331111
ProtocolSignature.ProtocolSigFingerprint0%n/a11441111
Server.RpcKindMapValue0%n/a11441111
UnexpectedServerException0%n/a22442211
RpcClientException0%n/a22442211
RpcConstants0%n/a11331111
RpcNoSuchProtocolException0%n/a33443311
TestIPC.IOEOnWriteWritable0%n/a22442211
RetriableException0%n/a22442211
TestIPC.RTEOnReadWritable0%n/a22442211
TestIPC.IOEOnReadWritable0%n/a22442211
RpcNoSuchMethodException0%n/a33443311
TestIPC.RTEOnWriteWritable0%n/a22442211
TestSaslRPC.BadTokenSecretManager0%n/a22222211
TestIPC.MockSocket0%n/a22222211
MiniRPCBenchmark.TestDelegationTokenSelector0%n/a11221111
TestRPC.TestClass.new TestRPC.TestClass.AbstractEmbedded() {...}0%n/a11111111
ProtocolSignature.new WritableFactory() {...}0%n/a22222211
TestRPCCompatibility.TestImpl20%n/a33333311
TestRPCCompatibility.TestImpl10%n/a33333311
TestCallQueueManager.ExceptionFakeScheduler0%n/a11221111
TestRPC.TestClass.Embedded0%n/a11111111
Client.new ThreadLocal() {...}0%n/a22222211
DefaultCostProvider0%n/a33333311
TestRPC.TestClass.new Object() {...}0%n/a11111111
TestRPC.TestClass.AbstractEmbedded0%n/a11111111
RefreshRegistry.RegistryHolder0%n/a11111111
Schedulable0%n/a11111111
CallerContext.CurrentCallerContextHolder0%n/a11111111
StandbyException0%n/a11221111
AsyncCallLimitExceededException0%n/a11221111
IpcException0%n/a11221111
ObserverRetryOnActiveException0%n/a11221111
TestServer.TestException20%n/a11111111
TestServer.TestException10%n/a11111111
TestServer.TestException30%n/a11111111
TestSaslRPC.TestPlainCallbacks0%n/a11111111
TestDecayRpcScheduler.TestCostProvider0%n/a22222211
TestSocketFactory.DummySocketFactory0%n/a11111111
Created with JaCoCo 0.8.7.202105040129