RangeStreamer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,275 of 1,2750%148 of 1480%98982202202424
calculateRangesToFetchWithPreferredEndpoints(BiFunction, AbstractReplicationStrategy, ReplicaCollection, boolean, TokenMetadata, TokenMetadata, String, Collection)2980%440%2323555511
lambda$fetchAsync$8(String, InetAddressAndPort, Collection)1990%100%66313111
addRanges(String, ReplicaCollection)1480%200%1111202011
getOptimizedWorkMap(EndpointsByReplica, Collection, String)1350%120%77242411
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, IFailureDetector, boolean, int)750%40%33161611
useStrictSourcesForRanges(AbstractReplicationStrategy)680%140%88121211
validateRangeFetchMap(EndpointsByRange, Multimap, String)660%60%449911
convertPreferredEndpointsToWorkMap(EndpointsByReplica)630%80%55101011
calculateRangesToFetchWithPreferredEndpoints(ReplicaCollection, Keyspace, boolean)460%40%33101011
buildErrorMessage(Collection, ReplicaCollection)400%60%449911
lambda$fetchAsync$3(SystemKeyspace.AvailableRanges, RangeStreamer.FetchReplica)350%80%557711
lambda$static$0(Replica)230%80%554411
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, boolean, int)130%n/a112211
lambda$fetchAsync$9(String, Multimap)120%n/a113311
lambda$calculateRangesToFetchWithPreferredEndpoints$2(Replica, Replica)100%40%331111
fetchAsync()90%n/a112211
addSourceFilter(RangeStreamer.SourceFilter)60%n/a112211
lambda$calculateRangesToFetchWithPreferredEndpoints$1(BiFunction, InetAddressAndPort, EndpointsForRange)60%n/a111111
static {...}60%n/a112211
lambda$fetchAsync$6(RangeStreamer.FetchReplica)40%n/a111111
lambda$fetchAsync$4(RangeStreamer.FetchReplica)40%n/a111111
toFetch()30%n/a111111
lambda$fetchAsync$7(RangeStreamer.FetchReplica)30%n/a111111
lambda$fetchAsync$5(RangeStreamer.FetchReplica)30%n/a111111