IndexShard

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total7,090 of 7,0900%875 of 8750%6976971,3471,347256256
updateShardState(ShardRouting, long, BiConsumer, long, Set, IndexShardRoutingTable)4410%960%4949555511
IndexShard(ShardRouting, IndexSettings, ShardPath, Store, Supplier, IndexCache, MapperService, SimilarityService, EngineFactory, IndexEventListener, CheckedFunction, ThreadPool, BigArrays, Engine.Warmer, List, List, Runnable, RetentionLeaseSyncer, CircuitBreakerService, IndexStorePlugin.SnapshotCommitSupplier)4050%60%44777711
recoverLocallyUpToGlobalCheckpoint()2680%260%1414505011
startRecovery(RecoveryState, PeerRecoveryTargetService, PeerRecoveryTargetService.RecoveryListener, RepositoriesService, BiConsumer, IndicesService)2130%250%1515393911
doCheckIndex()1900%220%1212464611
resetEngineToGlobalCheckpoint()1540%120%77282811
index(Engine, Engine.Index)1480%60%44212111
applyDeleteOperation(Engine, long, long, long, String, String, VersionType, long, long, Engine.Operation.Origin)1320%120%77191911
innerOpenEngineAndTranslog(LongSupplier)1180%200%1111212111
ensureWriteAllowed(Engine.Operation.Origin)1100%260%1414141411
activateWithPrimaryContext(ReplicationTracker.PrimaryContext)1060%160%99111111
applyTranslogOperation(Engine, Translog.Operation, Engine.Operation.Origin)1050%60%55161611
applyIndexOperation(Engine, long, long, long, VersionType, long, long, long, boolean, Engine.Operation.Origin, SourceToParse)1040%80%55171711
maybeSyncGlobalCheckpoint(String)1000%280%1515181811
persistMetadata(ShardPath, IndexSettings, ShardRouting, ShardRouting, Logger)1000%200%1111171711
newEngineConfig(LongSupplier)970%40%33111111
innerAcquireReplicaOperationPermit(long, long, long, ActionListener, boolean, Consumer)950%160%99171711
recoverFromLocalShards(BiConsumer, List, ActionListener)940%160%99161611
assertSequenceNumbersInCommit()840%200%11118811
lambda$updateShardState$3(CountDownLatch, long, ShardRouting, ShardRouting, BiConsumer)840%80%55151511
runTranslogRecovery(Engine, Translog.Snapshot, Engine.Operation.Origin, Runnable)800%100%77171711
prepareIndex(MapperService, String, SourceToParse, long, long, long, VersionType, Engine.Operation.Origin, long, boolean, long, long)670%100%66131311
wrapSearcher(Engine.Searcher, ShardFieldUsageTracker.FieldUsageStatsTrackingSession, CheckedFunction)670%80%55141411
lambda$innerAcquireReplicaOperationPermit$29(long, long, long, ActionListener, Releasable)640%60%44171711
bumpPrimaryTerm(long, CheckedRunnable, ActionListener)630%160%998811
snapshotStoreMetadata()590%80%55131311
close(String, boolean)590%40%33111111
scheduledRefresh()580%160%99171711
verifyRelocatingState()570%60%447711
afterWriteOperation()570%100%66131311
markAsRecovering(String, RecoveryState)550%80%55111111
wrapSearcher(Engine.Searcher)540%100%66101011
storeStats()520%60%449911
restoreFromRepository(Repository, ActionListener)520%80%559911
postRecovery(String)510%40%33121211
resetRecoveryStage()510%100%666611
updateGlobalCheckpointOnReplica(long, String)510%120%777711
delete(Engine, Engine.Delete)490%20%22111111
getTimestampRange()480%80%55161611
addRetentionLease(String, long, String, ActionListener)460%60%449911
markSeqNoAsNoop(Engine, long, long, String, Engine.Operation.Origin)450%40%336611
handleRefreshException(Exception)450%140%88121211
upgrade(UpgradeRequest)430%40%33111111
preRecovery()420%60%446611
renewRetentionLease(String, long, String)420%60%448811
performRecoveryRestart()390%80%557711
onSettingsChanged()390%100%668811
relocated(String, BiConsumer, ActionListener)380%40%334411
openEngineAndSkipTranslogRecovery()370%40%336611
syncRetentionLeases()360%40%338811
minimumCompatibleVersion()350%80%556611
checkIdle(long)350%60%44101011
recoverFromStore(ActionListener)350%80%555511
maybeCheckIndex()350%40%339911
changeState(IndexShardState, String)330%40%336611
ensureSoftDeletesEnabled(String)320%40%335511
addPeerRecoveryRetentionLease(String, long, ActionListener)320%100%663311
runUnderPrimaryPermit(Runnable, Consumer, String, Object)320%40%335511
lambda$innerAcquireReplicaOperationPermit$30(long, long)320%20%229911
get(Engine.Get)310%40%336611
openEngineAndRecoverFromTranslog()310%n/a119911
acquirePrimaryOperationPermit(ActionListener, String, Object, boolean)310%40%334411
acquireAllPrimaryOperationsPermits(ActionListener, TimeValue)310%40%334411
addRefreshListener(Translog.Location, Consumer)310%40%339911
flush(FlushRequest)290%n/a118811
prepareForIndexRecovery()280%60%445511
forceMerge(ForceMergeRequest)270%20%227711
assertPrimaryMode()270%60%442211
afterCleanFiles(Runnable)270%40%338811
lambda$newEngineConfig$22(ElasticsearchDirectoryReader)270%100%665511
applyIndexOperationOnPrimary(long, VersionType, SourceToParse, long, long, long, boolean)260%40%332211
readAllowed()260%20%225511
asyncBlockOperations(ActionListener, long, TimeUnit)260%n/a118811
lambda$recoverLocallyUpToGlobalCheckpoint$8(Engine, Translog.Snapshot)260%n/a115511
applyDeleteOperationOnPrimary(long, String, String, VersionType, long, long)250%40%332211
refreshStats()250%n/a116611
acquireLastIndexCommit(boolean)240%40%334411
runAfterCleanFilesActions()240%20%226611
indexingStats(String[])230%20%227711
acquireSafeIndexCommit()230%40%334411
assertReplicationTarget()230%40%332211
removeRetentionLease(String, ActionListener)230%40%336611
awaitShardSearchActive(Consumer)220%20%226611
verifyNotClosed(Exception)210%40%337711
getReplicationGroup()210%40%335511
acquireIndexCommitForSnapshot()200%20%224411
loadGlobalCheckpointToReplicationTracker()200%n/a114411
executeRecovery(String, RecoveryState, PeerRecoveryTargetService.RecoveryListener, CheckedConsumer)200%n/a113311
lambda$wrapPrimaryOperationPermitListener$23(ActionListener, Releasable)200%20%225511
noOp(Engine, Engine.NoOp)190%20%224411
onNewEngine(Engine)190%40%333311
ignoreRecoveryAttempt()190%80%552211
buildRefreshListeners()190%n/a113311
lambda$openEngineAndRecoverFromTranslog$10(RecoveryState.Translog, Engine, Translog.Snapshot)190%n/a114411
getRetentionLeases(boolean)180%60%443311
checkIndex()180%20%227711
prepareDelete(String, String, Term, long, long, long, VersionType, Engine.Operation.Origin, long, long)170%n/a112211
verifyActive()170%20%224411
updateLocalCheckpointForShard(String, long)170%40%334411
updateGlobalCheckpointForShard(String, long)170%40%334411
isSearchIdle()170%20%221111
static {...}170%20%223311
refresh(String)160%20%225511
finalizeRecovery()160%n/a115511
updateRetentionLeasesOnReplica(RetentionLeases)160%40%334411
requirePrimaryTermUpdate(long, boolean)160%60%441111
lambda$wrapSearcher$7(DirectoryReader, Engine.Searcher, ShardFieldUsageTracker.FieldUsageStatsTrackingSession)160%n/a111111
applyIndexOperationOnReplica(long, long, long, long, boolean, SourceToParse)150%n/a111111
flushStats()150%n/a111111
turnOffTranslogRetention()150%n/a113311
markAllocationIdAsInSync(String, long)150%40%333311
getInSyncGlobalCheckpoints()150%40%333311
isRelocatedPrimary()150%40%332211
cloneLocalPeerRecoveryRetentionLease(String, ActionListener)150%40%332211
removePeerRecoveryRetentionLease(String, ActionListener)150%40%333311
applyDeleteOperationOnReplica(long, long, long, String, String)140%n/a112211
syncFlush(String, Engine.CommitId)140%n/a113311
acquireSearcher(String, Engine.SearcherScope)140%n/a114411
initiateTracking(String)140%40%333311
getPendingReplicationActions()140%40%333311
segmentStats(boolean, boolean)130%n/a113311
acquireSearcherSupplier(Engine.SearcherScope)130%n/a114411
getIndexBufferRAMBytesUsed()130%20%226611
addCleanFilesDependency()130%n/a113311
pendingInSync()130%40%332211
lambda$startRecovery$19(BiConsumer, List, Set, ActionListener)130%n/a112211
mergeStats()120%20%224411
getEngine()120%20%224411
acquireReplicaOperationPermit(long, long, long, ActionListener, String, Object)120%n/a112211
lambda$updateShardState$4(RetentionLeases, ShardRouting)120%40%331111
shouldPeriodicallyFlush()110%20%225511
shouldRollTranslogGeneration()110%20%225511
writeIndexingBuffer()110%n/a116611
acquireAllReplicaOperationsPermits(long, long, long, ActionListener, TimeValue)110%n/a112211
lambda$awaitShardSearchActive$33(Translog.Location, Consumer, Boolean)110%n/a113311
lambda$executeRecovery$21(PeerRecoveryTargetService.RecoveryListener, RecoveryState, Exception)110%n/a111111
getWritingBytes()100%20%224411
newChangesSnapshot(String, long, long, boolean)100%n/a111111
getSafeCommitInfo()100%20%222211
buildIndexAnalyzer(MapperService)100%20%223311
setRefreshPending(Engine)100%n/a113311
lambda$setRefreshPending$32(Translog.Location, Translog.Location)100%40%333311
lambda$new$0(RetentionLeaseSyncer, String, RetentionLeases, ActionListener)100%n/a111111
markSeqNoAsNoop(long, long, String)90%n/a111111
estimateNumberOfHistoryOperations(String, Engine.HistorySource, long)90%n/a111111
getHistoryOperations(String, Engine.HistorySource, long)90%n/a111111
hasCompleteHistoryOperations(String, Engine.HistorySource, long)90%n/a111111
loadRetentionLeases()90%n/a112211
persistRetentionLeases()90%n/a113311
createTranslogSyncProcessor(Logger, ThreadContext, Supplier)90%n/a111111
lambda$executeRecovery$20(PeerRecoveryTargetService.RecoveryListener, RecoveryState, Boolean)90%20%223311
lambda$ensurePeerRecoveryRetentionLeasesExist$16()90%n/a111111
lambda$maybeSyncGlobalCheckpoint$12(long, LongCursor)90%20%221111
getFailedDeleteResult(Exception, long)80%n/a111111
trimTranslog()80%n/a114411
getRetentionLeaseStats()80%n/a112211
sync(Translog.Location, Consumer)80%n/a113311
hasRefreshPending()80%20%221111
lambda$acquireAllReplicaOperationsPermits$28(TimeValue, ActionListener)80%n/a111111
lambda$acquireReplicaOperationPermit$27(String, Object, ActionListener)80%n/a111111
seqNoStats()70%n/a111111
completionStats(String[])70%n/a112211
markSearcherAccessed()70%n/a112211
trimOperationOfPreviousPrimaryTerms(long)70%n/a112211
applyTranslogOperation(Translog.Operation, Engine.Operation.Origin)70%n/a111111
addShardFailureCallback(Consumer)70%n/a112211
addGlobalCheckpointListener(long, GlobalCheckpointListeners.GlobalCheckpointListener, TimeValue)70%n/a112211
assertRetentionLeasesPersisted()70%n/a111111
ensurePeerRecoveryRetentionLeasesExist()70%n/a112211
acquirePrimaryOperationPermit(ActionListener, String, Object)70%n/a112211
lambda$resetEngineToGlobalCheckpoint$35(Engine, Translog.Snapshot)70%n/a111111
lambda$startRecovery$17(RepositoriesService, String, ActionListener)70%n/a111111
lambda$addCleanFilesDependency$13()70%20%223311
lambda$updateShardState$2(Engine, Translog.Snapshot)70%n/a111111
getFailedIndexResult(Exception, long)60%n/a111111
docStats()60%n/a112211
rollTranslogGeneration()60%n/a113311
failShard(String, Exception)60%n/a112211
activateThrottling()60%n/a114411
deactivateThrottling()60%n/a114411
sync()60%n/a113311
lambda$asyncBlockOperations$25(Releasable, ActionListener, Exception)60%n/a113311
lambda$asyncBlockOperations$24(Releasable, ActionListener, Releasable)60%n/a113311
lambda$ensurePeerRecoveryRetentionLeasesExist$15(Exception)60%n/a111111
getIndexSort()50%n/a111111
isSystem()50%n/a111111
searchStats(String[])50%n/a111111
fieldUsageStats(String[])50%n/a111111
fieldDataStats(String[])50%n/a111111
acquireSearcher(String)50%n/a111111
updateMaxUnsafeAutoIdTimestamp(long)50%n/a112211
isReadAllowed()50%n/a111111
acquireHistoryRetentionLock(Engine.HistorySource)50%n/a111111
segments(boolean)50%n/a111111
noopUpdate(String)50%n/a112211
getEngineOrNull()50%n/a111111
wrapPrimaryOperationPermitListener(ActionListener)50%n/a111111
advanceMaxSeqNoOfUpdatesOrDeletes(long)50%n/a112211
lambda$runUnderPrimaryPermit$26(Runnable, Releasable)50%n/a113311
lambda$startRecovery$18(Set, IndexShard)50%n/a111111
lambda$ensurePeerRecoveryRetentionLeasesExist$14(Void)50%n/a111111
getOperationPrimaryTerm()40%n/a111111
commitStats()40%n/a111111
getStats()40%n/a111111
warmerStats()40%n/a111111
translogStats()40%n/a111111
acquireSearcherSupplier()40%n/a111111
getMaxSeenAutoIdTimestamp()40%n/a111111
verifyNotClosed()40%n/a112211
isActive()40%n/a111111
getMinRetainedSeqNo()40%n/a111111
getHistoryUUID()40%n/a111111
getRetentionLeases()40%n/a111111
getLocalCheckpoint()40%n/a111111
getLastKnownGlobalCheckpoint()40%n/a111111
getLastSyncedGlobalCheckpoint()40%n/a111111
outstandingCleanFilesConditions()40%n/a111111
getPeerRecoveryRetentionLeases()40%n/a111111
getActiveOperationsCount()40%n/a111111
getActiveOperations()40%n/a111111
isSyncNeeded()40%n/a111111
getTranslogDurability()40%n/a111111
getLastSearcherAccess()40%n/a111111
getMaxSeqNoOfUpdatesOrDeletes()40%n/a111111
verifyShardBeforeIndexClosing()40%n/a112211
lambda$buildRefreshListeners$31()40%n/a111111
getGlobalCheckpointSyncer()0%n/a111111
getThreadPool()0%n/a111111
store()0%n/a111111
getService()0%n/a111111
shardBitsetFilterCache()0%n/a111111
mapperService()0%n/a111111
getSearchOperationListener()0%n/a111111
warmerService()0%n/a111111
requestCache()0%n/a111111
fieldData()0%n/a111111
getPendingPrimaryTerm()0%n/a111111
getShardUuid()0%n/a111111
getShardCreationTime()0%n/a111111
routingEntry()0%n/a111111
getQueryCachingPolicy()0%n/a111111
state()0%n/a111111
recoveryStats()0%n/a111111
recoveryState()0%n/a111111
shardPath()0%n/a111111
getIndexEventListener()0%n/a111111
useRetentionLeasesInPeerRecovery()0%n/a111111
getEngineFactory()0%n/a111111
getReplicationTracker()0%n/a111111
getRetentionLeaseSyncer()0%n/a111111
lambda$recoverFromLocalShards$11(List)0%n/a111111
lambda$recoverLocallyUpToGlobalCheckpoint$9(long)0%n/a111111
lambda$wrapSearcher$6(DirectoryReader)0%n/a111111
lambda$storeStats$5(long)0%n/a111111
lambda$resetEngineToGlobalCheckpoint$34()0%n/a111111
lambda$updateShardState$1()0%n/a111111