RangeStreamer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total231 of 1,27581%40 of 14872%359829220224
calculateRangesToFetchWithPreferredEndpoints(BiFunction, AbstractReplicationStrategy, ReplicaCollection, boolean, TokenMetadata, TokenMetadata, String, Collection)6423478%103477%923105501
addRanges(String, ReplicaCollection)608859%81260%61172001
getOptimizedWorkMap(EndpointsByReplica, Collection, String)2610980%21083%2722401
lambda$static$0(Replica)230%80%554411
lambda$fetchAsync$8(String, InetAddressAndPort, Collection)2017989%2880%2613101
validateRangeFetchMap(EndpointsByRange, Multimap, String)184872%2466%243901
convertPreferredEndpointsToWorkMap(EndpointsByReplica)85587%2675%2501001
calculateRangesToFetchWithPreferredEndpoints(ReplicaCollection, Keyspace, boolean)54189%1375%1311001
lambda$fetchAsync$3(SystemKeyspace.AvailableRanges, RangeStreamer.FetchReplica)33291%3562%351701
lambda$fetchAsync$7(RangeStreamer.FetchReplica)30%n/a111111
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, IFailureDetector, boolean, int)7498%1375%1301601
useStrictSourcesForRanges(AbstractReplicationStrategy)68100%14100%0801201
buildErrorMessage(Collection, ReplicaCollection)40100%1583%140901
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, boolean, int)13100%n/a010201
lambda$fetchAsync$9(String, Multimap)12100%n/a010301
lambda$calculateRangesToFetchWithPreferredEndpoints$2(Replica, Replica)10100%4100%030101
fetchAsync()9100%n/a010201
addSourceFilter(RangeStreamer.SourceFilter)6100%n/a010201
lambda$calculateRangesToFetchWithPreferredEndpoints$1(BiFunction, InetAddressAndPort, EndpointsForRange)6100%n/a010101
static {...}6100%n/a010201
lambda$fetchAsync$6(RangeStreamer.FetchReplica)4100%n/a010101
lambda$fetchAsync$4(RangeStreamer.FetchReplica)4100%n/a010101
toFetch()3100%n/a010101
lambda$fetchAsync$5(RangeStreamer.FetchReplica)3100%n/a010101