org.apache.hadoop.ipc

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total45,005 of 45,0050%2,572 of 2,5720%3,1153,11510,87510,8751,8261,826284284
TestRPC3,2630%1180%111111844844525211
TestIPC2,7980%700%111111691691767611
Server2,3140%2160%21121158758710310311
TestFairCallQueue2,0520%260%5050359359373711
TestSaslRPC2,0360%480%7171444444464611
Server.Connection1,9780%2220%159159505505474711
DecayRpcScheduler1,7160%1300%120120386386555511
Client.Connection1,4550%1900%121121379379262611
TestDecayRpcScheduler1,3630%280%3838254254242411
TestCallQueueManager1,0000%200%2525218218151511
CallQueueManager7960%420%5959175175383811
Client6870%640%7575178178434311
TestAsyncIPC6730%240%2929160160171711
TestProtoBufRpc6000%180%2525155155161611
FairCallQueue5170%540%5353115115262611
Server.Responder5110%480%3434139139101011
RPC4820%360%4747119119292911
TestWeightedRoundRobinMultiplexer4650%40%13137575111111
Server.Listener4510%320%2626117117101011
MiniRPCBenchmark4480%340%2828122122111111
Server.RpcCall4290%200%2929113113191911
TestIPCServerResponder4000%100%121294947711
Server.ConnectionManager3990%440%39398484171711
TestServer3800%40%111183839911
RPCCallBenchmark.MyOptions3710%320%22221251256611
RPCCallBenchmark3640%300%25259191101011
Client.ConnectionId3580%480%44446262202011
ProtobufRpcEngine2.Invoker3300%260%24248888111111
ProtobufRpcEngine.Invoker3300%260%24248787111111
RPC.Server3120%320%26267272101011
TestRpcBase.PBServerImpl2970%100%25258989202011
RpcClientUtil2860%260%24246868111111
TestSocketFactory2860%60%121282829911
RetryCache2800%280%33338383191911
TestRpcBase2750%260%34347777212111
TestProtoBufRpcServerHandoff2730%80%101066666611
TestRpcWritable2640%80%101068686611
ProtocolSignature2640%180%25256565161611
Server.Call2620%160%48488181404011
TestRetryCache2520%140%19195555121211
Server.Handler2460%240%151559593311
WritableRpcEngine.Invocation2350%100%18185858131311
TestMRCJCSocketFactory2330%100%131375758811
TestReuseRpcConnections2100%80%111161617711
ProtocolMetaInfoServerSideTranslatorPB2010%160%121246464411
CallerContext.Builder1970%320%29294141131311
WritableRpcEngine.Server.WritableRpcInvoker1960%200%121254542211
ProtobufRpcEngine2.Server.ProtoBufRpcInvoker1940%120%111152525511
TestAsyncIPC.AsyncLimitlCaller1870%60%121243439911
TestRPCCompatibility1830%120%111139395511
TestRpcServerHandoff1830%80%101056566611
DecayRpcScheduler.MetricsProxy1790%200%24245656141411
Server.Listener.Reader1760%160%141453536611
TestAsyncIPC.AsyncCaller1750%120%101042424411
TestCallerContext1670%n/a5544445511
ProtobufRpcEngine21590%20%13132626121211
RetryCache.CacheEntry1560%180%21213030121211
RPC.Builder1540%60%17174545141411
Client.IpcStreams1530%140%151540408811
WeightedRoundRobinMultiplexer1530%100%121236367711
ProtobufRpcEngine1460%n/a10102020101011
WritableRpcEngine.Server1430%120%121227276611
FairCallQueue.MetricsProxy1430%100%141438389911
ProtocolProxy1360%120%101037374411
TestResponseBuffer1350%n/a3337373311
RemoteException1290%80%131331319911
RefreshRegistry1280%80%121235358811
ProtobufRpcEngine.Server1260%40%6634344411
Client.Connection.new PrivilegedExceptionAction() {...}1260%120%8824242211
MiniRPCBenchmark.MiniServer1260%100%111127276611
TestRPCServerShutdown1240%100%9933334411
ClientId1230%140%131327276611
TestWeightedTimeCostProvider1220%n/a6630306611
ProcessingDetails1200%60%13132626101011
WritableRpcEngine1190%40%12122222101011
TestAsyncIPC.AsyncCompletableFutureCaller1170%60%6626263311
CallerContext1150%160%18183131101011
ClientCache1130%140%141429297711
ProxyCombiner.CombinedProxyInvocationHandler1100%80%9928285511
ProtobufRpcEngine.Server.ProtobufRpcEngineCallbackImpl1060%n/a4423234411
TestSaslRPC.TestPlainCallbacks.Server1060%100%7728282211
ProtobufRpcEngine2.Server.ProtobufRpcEngineCallbackImpl1060%n/a4423234411
WeightedTimeCostProvider1010%140%121220204411
ProtobufWrapperLegacy1010%20%7729296611
TestSaslRPC.new PrivilegedExceptionAction() {...}980%100%7719192211
TestIPC.TestServer970%60%111126268811
TestShadedProtobufHelper970%20%11112727101011
WritableRpcEngine.Invoker960%100%9926264411
Client.Connection.RpcRequestSender950%80%6621212211
TestProtoBufRPCCompatibility920%20%3324242211
Client.Call910%60%9929296611
RpcClientUtil.ProtoSigCacheKey900%160%111119193311
TestRPC.Transactions890%20%3325252211
TestRPCWaitForProxy880%100%101030305511
ExternalCall870%60%101031317711
TestSocketFactory.ServerRunnable860%20%7731316611
TestSaslRPC.new PrivilegedExceptionAction() {...}850%40%4419192211
TestRpcBase.TestTokenIdentifier840%60%111122228811
RpcWritable.Buffer800%20%101021219911
TestRpcServerHandoff.ServerForHandoffTest800%20%6622225511
TestRetryCache.TestServer780%80%7718183311
TestFairCallQueue.Taker770%80%6622222211
ResponseBuffer.FramedBuffer760%n/a6615156611
ProxyCombiner730%40%4410102211
TestRPC.new Runnable() {...}730%60%5512122211
Client.Connection.PingInputStream710%80%8819194411
DummySocketFactory.new Socket() {...}710%80%7712123311
TestIPC.NetworkTraces700%n/a1118181111
TestIdentityProviders680%n/a3320203311
Server.MetricsUpdateRunner650%40%4414142211
TestCallQueueManager.Putter650%60%6619193311
RefreshResponse640%40%111120209911
TestRPC.MockOutputStream640%40%101021218811
TestProcessingDetails640%n/a3316163311
RpcWritable.ProtobufWrapper640%n/a4416164411
ResponseBuffer620%20%101019199911
TestRPCCallBenchmark620%n/a22442211
TestCallQueueManager.Taker610%80%6618182211
TestRPCWaitForProxy.RpcThread600%n/a3317173311
TestIPCServerResponder.Caller600%20%3317172211
TestFairCallQueue.Putter590%60%6617173311
TestAsyncIPC.new Client() {...}590%n/a3313133311
ProcessingDetails.Timing570%n/a1110101111
TestSaslRPC.TestPlainCallbacks.Client570%60%5513132211
ProtobufRpcEngine2.Server570%20%5515154411
TestIPC.new Runnable() {...}540%n/a2210102211
TestIPC.SerialCaller540%40%4417172211
ProtobufRpcEngine.RpcProtobufRequest540%60%8818185511
ProtobufRpcEngine2.RpcProtobufRequest540%60%8818185511
TestIPC.new Runnable() {...}530%20%3311112211
RPC.Server.ProtoNameVer520%100%8813133311
TestRPC.TestImpl510%20%12121616111111
RpcWritable510%80%8812124411
TestRetryCacheMetrics500%n/a3317173311
Server.AuthProtocol490%40%5510103311
TestRpcBase.MockConnectionId490%40%5515153311
CallQueueManager.CallQueueOverflowException470%n/a33773311
TestRpcServerHandoff.ClientCallable470%n/a2211112211
TestIPC.TestInvocationHandler470%20%7714146611
TestProtoBufRpcServerHandoff.ClientInvocationCallable460%20%4415153311
MiniRPCBenchmark.new PrivilegedExceptionAction() {...}460%n/a22772211
TestIPC.new Runnable() {...}450%n/a2210102211
TestRPC.StoppedRpcEngine450%n/a55665511
Server.ExceptionsHandler450%n/a5517175511
TestIPC.new Client() {...}440%n/a33993311
Client.new AsyncGet() {...}430%60%6610103311
RpcWritable.WritableWrapper420%n/a3310103311
TestIPCServerResponder.new Server() {...}420%20%33772211
TestIPC.TestServerQueue390%n/a2210102211
ProtobufHelper390%40%9910107711
TestProtoBufRpcServerHandoff.TestProtoBufRpcServerHandoffServer.new Thread() {...}360%n/a2210102211
RPC.RpcKind350%n/a22882211
TestRPC.SlowRPC340%n/a4413134411
TestIPC.new Thread() {...}320%20%3311112211
TestRpcBase.TestTokenSelector320%80%66992211
TestIPC.new Runnable() {...}310%n/a22552211
TestMultipleProtocolServer310%n/a4411114411
TestIPC.new Callable() {...}300%n/a22332211
DecayRpcScheduler.DecayTask300%20%3310102211
TestSaslRPC.1.new Callable() {...}300%n/a22662211
RPC.VersionMismatch290%n/a6610106611
RetryCache.CacheEntryWithPayload290%n/a55995511
ProtobufRpcEngine2.Invoker.new AsyncGet() {...}280%n/a33333311
ProtobufRpcEngine.Invoker.new AsyncGet() {...}280%n/a33333311
TestRPCCompatibility.TestImpl0280%n/a44994411
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
TestProtoBufRPCCompatibility.OldServerImpl0%n/a33993311
TestProtoBufRPCCompatibility.NewerServerImpl0%n/a33993311
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
TestRPC.new PrivilegedExceptionAction() {...}0%n/a22442211
TestProtoBufRpc.PBServer2ImplLegacy0%n/a44884411
TestProtoBufRpc.PBServer2Impl0%n/a44884411
MiniRPCBenchmark.new PrivilegedExceptionAction() {...}0%n/a22222211
TestIPC.new Runnable() {...}0%n/a22442211
TestProtoBufRpcServerHandoff.TestProtoBufRpcServerHandoffServer0%n/a22772211
TestProtoBufRPCCompatibility.NewServerImpl0%n/a33773311
TestIPC.new Runnable() {...}0%n/a22442211
TestSaslRPC.new PrivilegedExceptionAction() {...}0%n/a22222211
TestRPC.new InputStream() {...}0%n/a22662211
TestAsyncIPC.new Runnable() {...}0%n/a22442211
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
DecayRpcScheduler.new Schedulable() {...}0%n/a33333311
CallQueueManager.CallQueueOverflowException.new RpcServerException() {...}0%n/a22222211
TestRPC.new Schedulable() {...}0%n/a33333311
TestCallQueueManager.ExceptionFakeCall0%n/a33443311
TestRPC.TestPolicyProvider0%n/a11111111
Server.new ThreadLocal() {...}0%n/a22222211
TestIPC.new Runnable() {...}0%n/a22332211
TestIPC.new Runnable() {...}0%n/a22332211
TestIPC.new Answer() {...}0%n/a22222211
TestAsyncIPC.new Runnable() {...}0%n/a22332211
TestAsyncIPC.new Runnable() {...}0%n/a22332211
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