ActiveRepairService

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total451 of 1,66072%57 of 15964%60154983701874
repairPaxosForTopologyChange(String, Collection, String)948948%6857%58102701
getRepairStats(List, String)560%60%44131311
cleanupPending(List, String, boolean)530%60%44131311
getPendingStats(List, String)520%60%44131311
getNeighbors(String, Iterable, Range, Collection, Collection)3416182%62278%61563801
validation(UUID)220%40%335511
prepareForRepair(TimeUUID, InetAddressAndPort, Set, RepairOption, boolean, List)1913887%41071%3832301
stop()140%20%225511
setRepairSessionSpaceInMiB(int)110%n/a115511
validations()110%n/a111111
submitRepairSession(TimeUUID, CommonRange, String, RepairParallelism, boolean, boolean, PreviewKind, boolean, boolean, boolean, ExecutorPlus, String[])96387%3770%3631501
clearLocalRepairState()90%n/a113311
terminateSessions()81768%1150%122601
lambda$repairPaxosForTopologyChange$6(Set, Replica)80%20%221111
cleanUp(TimeUUID, Set)64888%2466%2421301
coordinator(TimeUUID)60%n/a111111
coordinators()50%n/a111111
participates()50%n/a111111
registerParentRepairSession(TimeUUID, InetAddressAndPort, List, Collection, boolean, long, boolean, PreviewKind)44491%2675%250801
register(ParticipateState)42686%1150%121701
lambda$validations$7(ParticipateState)40%n/a111111
setRepairSessionSpaceInMegabytes(int)30%n/a112211
setRepairSessionSpaceInMebibytes(int)30%n/a112211
setUseOffheapMerkleTrees(boolean)30%n/a112211
setRepairPendingCompactionRejectThreshold(int)30%n/a112211
setPaxosRepairParallelism(int)30%n/a112211
initializeExecutor(int, Config.RepairCommandPoolFullStrategy)22191%1150%120801
ActiveRepairService(SharedContext)87100%n/a0102601
handleMessage(Message)61100%3872%3701801
lambda$removeParentRepairSession$4(TimeUUID, ActiveRepairService.ParentRepairSession, String)52100%4100%0301101
abort(Predicate, String)41100%6100%040901
verifyCompactionsPendingThreshold(TimeUUID, PreviewKind)36100%2100%020701
removeParentRepairSession(TimeUUID)28100%4100%030701
start()22100%n/a010301
registerOnFdAndGossip(Future)20100%n/a010401
lambda$prepareForRepair$2(AsyncPromise, TimeUUID)18100%1375%130601
sendPrepareWithRetries(TimeUUID, AtomicInteger, Set, AsyncPromise, InetAddressAndPort, RepairMessage)17100%n/a010201
convict(InetAddressAndPort, double)17100%4100%030401
getRepairedAt(RepairOption, boolean)15100%1583%140301
getParentRepairSession(TimeUUID)15100%2100%020401
failRepairException(TimeUUID, String)13100%n/a010301
getSessions(boolean, String)11100%n/a010201
participateFailed(TimeUUID, String)11100%2100%020401
shutdownNowAndWait(long, TimeUnit)11100%n/a010201
lambda$getNeighbors$1(Replica)11100%2100%020101
failSession(String, boolean)10100%n/a010301
recordRepairStatus(int, ActiveRepairService.ParentRepairStatus, List)9100%n/a010201
lambda$submitRepairSession$0(RepairSession)9100%n/a010301
register(CoordinatorState)8100%n/a010201
static {...}7100%n/a010401
getRepairStatus(Integer)6100%n/a010101
participate(TimeUUID)6100%n/a010101
failRepair(TimeUUID, String)5100%n/a010101
onRemove(InetAddressAndPort)5100%n/a010201
onRestart(InetAddressAndPort, EndpointState)5100%n/a010201
lambda$convict$5(InetAddressAndPort, ActiveRepairService.ParentRepairSession)5100%n/a010101
ActiveRepairService()4100%n/a010201
parentRepairSessionsCount()4100%n/a010101
parentRepairSessionCount()4100%n/a010101
sessionCount()4100%n/a010101
lambda$removeParentRepairSession$3(ColumnFamilyStore)4100%n/a010101
instance()2100%n/a010101
repairCommandExecutor()2100%n/a010101
getRepairSessionSpaceInMegabytes()2100%n/a010101
getRepairSessionSpaceInMebibytes()2100%n/a010101
getRepairSessionSpaceInMiB()2100%n/a010101
getUseOffheapMerkleTrees()2100%n/a010101
getRepairPendingCompactionRejectThreshold()2100%n/a010101
getPaxosRepairParallelism()2100%n/a010101
onJoin(InetAddressAndPort, EndpointState)100%n/a010101
beforeChange(InetAddressAndPort, EndpointState, ApplicationState, VersionedValue)100%n/a010101
onChange(InetAddressAndPort, ApplicationState, VersionedValue)100%n/a010101
onAlive(InetAddressAndPort, EndpointState)100%n/a010101
onDead(InetAddressAndPort, EndpointState)100%n/a010101