ReplicationTracker

Source file "org/elasticsearch/index/seqno/ReplicationTracker.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,462 of 3,4620%652 of 6520%4054055215217979
invariant()5390%1300%6666383811
updateFromMaster(long, Set, IndexShardRoutingTable)2080%360%1919353511
markAllocationIdAsInSync(String, long)1950%400%2121242411
ReplicationTracker(ShardId, String, IndexSettings, long, long, LongConsumer, LongSupplier, BiConsumer, Supplier, Consumer)1410%200%1111272711
addPeerRecoveryRetentionLeaseForSolePrimary()1340%240%1313161611
renewPeerRecoveryRetentionLeases()1300%260%1414181811
startRelocationHandoff(String)1130%240%1313131311
activateWithPrimaryContext(ReplicationTracker.PrimaryContext)1120%200%1111191911
getRetentionLeases(boolean)1110%120%77212111
activatePrimaryMode(long)1030%240%1313111111
renewRetentionLease(String, long, String)950%120%77161611
updateLocalCheckpoint(String, long)900%260%1414191911
createMissingPeerRecoveryRetentionLeases(ActionListener)870%80%55212111
innerAddRetentionLease(String, long, String)830%100%66111111
updateGlobalCheckpointForShard(String, long)780%260%1414121211
removeRetentionLease(String, ActionListener)670%60%44131311
updateGlobalCheckpointOnPrimary()630%100%668811
persistRetentionLeases(Path)590%20%22131311
completeRelocationHandoff()590%200%1111101011
updateLocalCheckpoint(String, ReplicationTracker.CheckpointState, long)560%60%448811
initiateTracking(String)550%180%1010101011
updateGlobalCheckpointOnReplica(long, String)530%140%889911
cloneRetentionLease(String, String, ActionListener)520%60%44111111
lambda$getRetentionLeases$0(Set, boolean, long, long, long, RetentionLease)500%100%66101011
lambda$renewPeerRecoveryRetentionLeases$4(long, ShardRouting)490%120%776611
computeGlobalCheckpoint(Set, Collection, long)450%120%77111111
calculateReplicationGroup()410%20%226611
abortRelocationHandoff()400%160%996611
loadRetentionLeases(Path)380%60%447711
getInSyncGlobalCheckpoints()360%80%559911
getMasterUpdateOperationFromCurrentState()310%40%336611
addRetentionLease(String, long, String, ActionListener)260%n/a117711
inSyncCheckpointStates(Map, ToLongFunction, Function)210%20%228811
assertRetentionLeasesPersisted(Path)200%40%332211
updateReplicationGroupAndNotify()200%40%335511
getMinimumReasonableRetainedSeqNo()190%n/a112211
lambda$addPeerRecoveryRetentionLeaseForSolePrimary$14(ShardRouting)190%40%332211
updateRetentionLeasesOnReplica(RetentionLeases)180%60%444411
pendingInSync()170%60%442211
lambda$updateFromMaster$15(String)160%40%331111
getTrackedLocalCheckpointForShard(String)150%40%332211
ReplicationTracker(ShardId, String, IndexSettings, long, long, LongConsumer, LongSupplier, BiConsumer, Supplier)130%n/a112211
setHasAllPeerRecoveryRetentionLeases()130%40%333311
getReplicationGroup()120%40%332211
lambda$getMasterUpdateOperationFromCurrentState$20(Set, Map.Entry)120%20%223311
lambda$updateFromMaster$16(Set, Set, String)120%40%331111
lambda$getInSyncGlobalCheckpoints$6(ObjectLongMap, Map.Entry)110%n/a111111
addPeerRecoveryRetentionLease(String, long, ActionListener)100%n/a111111
cloneLocalPeerRecoveryRetentionLease(String, ActionListener)100%n/a113311
getPeerRecoveryRetentionLeases()100%n/a113311
getPeerRecoveryRetentionLeaseId(String)90%n/a111111
lambda$updateFromMaster$17(String)90%20%221111
lambda$invariant$8(ReplicationTracker.CheckpointState)90%20%221111
lambda$invariant$7(ReplicationTracker.CheckpointState)90%20%221111
lambda$removeRetentionLease$2(String, RetentionLease)90%20%221111
lambda$renewRetentionLease$1(String, RetentionLease)90%20%221111
lambda$inSyncCheckpointStates$10(long)80%20%221111
static {...}80%20%221111
lambda$completeRelocationHandoff$18(String, ReplicationTracker.CheckpointState)70%n/a113311
removePeerRecoveryRetentionLease(String, ActionListener)60%n/a112211
lambda$getMasterUpdateOperationFromCurrentState$21(long, Set, IndexShardRoutingTable)60%n/a111111
lambda$createMissingPeerRecoveryRetentionLeases$19(ActionListener, Collection)60%n/a113311
lambda$calculateReplicationGroup$13(Map.Entry)50%n/a111111
lambda$calculateReplicationGroup$12(Map.Entry)50%n/a111111
lambda$getInSyncGlobalCheckpoints$5(Map.Entry)50%n/a111111
lambda$getPeerRecoveryRetentionLeases$3(RetentionLease)50%n/a111111
getRetentionLeases()0%n/a111111
getPeerRecoveryRetentionLeaseId(ShardRouting)0%n/a111111
setOperationPrimaryTerm(long)0%n/a112211
isPrimaryMode()0%n/a111111
getOperationPrimaryTerm()0%n/a111111
isRelocated()0%n/a111111
getGlobalCheckpoint()0%n/a111111
getAsLong()0%n/a111111
hasAllPeerRecoveryRetentionLeases()0%n/a111111
notifyAllWaiters()0%n/a112211
waitForLocalCheckpointToAdvance()0%n/a112211
lambda$inSyncCheckpointStates$9(ReplicationTracker.CheckpointState)0%n/a111111
lambda$new$11(ReplicationGroup)0%n/a111111