BlobStoreRepository

Source file "org/elasticsearch/repositories/blobstore/BlobStoreRepository.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total6,367 of 6,3670%486 of 4860%4334331,2471,247190190
snapshotShard(SnapshotShardContext)5310%460%242411911911
lambda$cloneShardSnapshot$5(IndexId, int, ShardGeneration, SnapshotId, SnapshotId, RepositoryShardId)2080%180%1010444411
updateState(ClusterState)1970%340%1818353511
doGetRepositoryData(ActionListener)1950%220%1212484811
verify(String, DiscoveryNode)1570%40%33292911
static {...}1490%20%22212111
BlobStoreRepository(RepositoryMetadata, boolean, NamedXContentRegistry, ClusterService, BigArrays, RecoverySettings)1270%n/a11252511
getRepositoryData(ActionListener)1210%220%1212242411
deleteFromShardSnapshotMeta(Set, IndexId, int, Collection, BlobContainer, Set, BlobStoreIndexShardSnapshots, long)1200%80%55222211
writeUpdatedShardMetaDataAndComputeDeletes(Collection, RepositoryData, boolean, ActionListener)1180%60%44282811
updateRepositoryGenerationsIfNecessary(ClusterState, long, long)1130%160%99212111
lambda$finalizeSnapshot$48(FinalizeSnapshotContext, boolean, SnapshotInfo, SnapshotId, ShardGenerations, long, Version, boolean, Consumer, Collection, Executor, RepositoryData)1100%60%44212111
writeIndexGen(RepositoryData, long, Version, Function, ActionListener)1080%60%44161611
lambda$getOneSnapshotInfo$51(GetSnapshotInfoContext, BlockingQueue, SnapshotId)1070%140%88262611
lambda$writeIndexGen$66(StepListener, Version, long, ActionListener, Function, RepositoryData)1060%40%33141411
restoreShard(Store, SnapshotId, IndexId, ShardId, RecoveryState, ActionListener)1030%80%55161611
lambda$staleRootBlobs$37(Set, RepositoryData, String)900%220%1212141411
safeRepositoryData(long, Map)840%100%66141411
cleanup(long, Version, ActionListener)810%60%44212111
finalizeSnapshot(FinalizeSnapshotContext)780%40%33151511
snapshotFile(BlobStoreIndexShardSnapshot.FileInfo, IndexId, ShardId, SnapshotId, IndexShardSnapshotStatus, Store)760%20%22181811
ensureSafeGenerationExists(long, Consumer)750%60%44161611
doDeleteShardSnapshots(Collection, long, Map, Map, RepositoryData, Version, ActionListener)730%20%22131311
lambda$snapshotShard$77(IndexShardSnapshotStatus, IndexCommit, ShardId, SnapshotId, List, BlobContainer, Runnable, ShardGeneration, SnapshotShardContext, Collection)730%n/a11212111
cleanupStaleBlobs(Collection, Map, Map, RepositoryData, ActionListener)680%40%33121211
cacheRepositoryData(RepositoryData, Version)680%120%77101011
getRepositoryData(long)670%60%44121211
initializeRepoGenerationTracking(ActionListener)640%40%33191911
assertFileContentsMatchHash(IndexShardSnapshotStatus, BlobStoreIndexShardSnapshot.FileInfo, Store)600%100%66111111
blobStore()540%60%44171711
cleanupStaleRootFiles(long, Collection, List)530%60%44161611
cleanupStaleIndices(Map, Set)530%40%33121211
lambda$finalizeSnapshot$46(Metadata, IndexId, boolean, RepositoryData, Map, Map, SnapshotId)530%40%33151511
startVerification()520%20%22101011
buildBlobStoreIndexShardSnapshots(Set, BlobContainer)520%40%33111111
buildBlobStoreIndexShardSnapshots(Set, BlobContainer, ShardGeneration)470%40%337711
awaitIdle()460%80%55111111
markRepoCorrupted(long, Exception, ActionListener)460%80%555511
lambda$doDeleteShardSnapshots$11(RepositoryData, Collection, long, Version, StepListener, ActionListener, Collection)460%20%229911
initializeSnapshot(SnapshotId, List, Metadata)450%20%228811
lambda$writeIndexGen$63(RepositoryData, StepListener, ActionListener)450%20%22111111
doStart()440%80%556611
lambda$snapshotShard$76(BlobContainer, long, BlobStoreIndexShardSnapshots, ShardId, SnapshotId, ShardGeneration, List)440%n/a11101011
blobContainer()430%60%44121211
loadShardSnapshot(BlobContainer, SnapshotId)430%n/a117711
lambda$writeUpdatedShardMetaDataAndComputeDeletes$26(ActionListener, Executor, IndexId, boolean, RepositoryData, Set, Collection, Collection)430%40%339911
getRepoMetadata(ClusterState)410%60%446611
writeShardIndexBlobAtomic(BlobContainer, long, BlobStoreIndexShardSnapshots)410%40%335511
lambda$unusedBlobs$87(Set, BlobStoreIndexShardSnapshots, String)400%140%887711
latestGeneration(Collection)390%40%33111111
lambda$doDeleteShardSnapshots$16(ActionListener, Collection, Map, Map, RepositoryData, RepositoryData)390%n/a118811
canUpdateInPlace(Settings, Set)380%20%229911
cloneShardSnapshot(SnapshotId, SnapshotId, RepositoryShardId, ShardGeneration, ActionListener)370%20%228811
lambda$finalizeSnapshot$44(SnapshotInfo, RepositoryData, SnapshotId, ShardGenerations, Map, Map, long, Version, FinalizeSnapshotContext, boolean, Consumer, Collection)360%n/a119911
endVerification(String)350%20%227711
getSnapshotGlobalMetadata(SnapshotId)340%n/a115511
lambda$restoreShard$80(ShardId)340%60%448811
lambda$restoreShard$81(BlobContainer, SnapshotId, ShardId, RecoveryState, Executor, Store, ActionListener)330%n/a115511
cleanupOldShardGens(RepositoryData, RepositoryData)320%n/a11101011
assertSnapshotOrGenericThread()320%80%555511
executeOneFileSnapshot(Store, SnapshotId, IndexId, IndexShardSnapshotStatus, BlockingQueue, Executor, ActionListener)300%20%226611
resolveFilesToDelete(RepositoryData, Collection, Collection)290%n/a117711
incrementStoreRef(Store, IndexShardSnapshotStatus, ShardId)290%60%446611
lambda$cleanupStaleRootFiles$38(long, SnapshotId)290%n/a113311
getSnapshotInfo(GetSnapshotInfoContext)280%20%225511
deleteSnapshots(Collection, long, Version, ActionListener)270%20%224411
getSnapshotIndexMetaData(RepositoryData, SnapshotId, IndexId)270%n/a116611
lambda$initializeRepoGenerationTracking$55(Consumer, RepositoryData)270%n/a112211
lambda$initializeRepoGenerationTracking$54(Exception)270%n/a118811
maybeWriteIndexLatest(long)260%20%227711
asyncCleanupUnlinkedShardLevelBlobs(RepositoryData, Collection, Collection, ActionListener)250%20%226611
lambda$doDeleteShardSnapshots$13(ActionListener, Collection, Map, Map, RepositoryData, StepListener, RepositoryData)250%n/a116611
doClose()240%20%229911
readLastWriterInfo()230%40%334411
getShardSnapshotStatus(SnapshotId, IndexId, ShardId)230%n/a118811
lambda$writeShardIndexBlobAtomic$85(long, BlobContainer)230%n/a111111
lambda$executeOneFileSnapshot$78(Store, IndexShardSnapshotStatus, ShardId, BlobStoreIndexShardSnapshot.FileInfo, IndexId, SnapshotId, BlockingQueue, Executor, ActionListener)230%n/a114411
previousWriterMessage(Tuple)220%20%225511
updateRepositoryData(RepositoryData, Version, long)220%40%335511
getBlobStoreIndexShardSnapshots(IndexId, int, ShardGeneration)220%20%225511
lambda$snapshotFile$89(String, BlobContainer)220%n/a111111
lambda$snapshotShard$71(BlobStoreIndexShardSnapshots, String)220%40%335511
lambda$writeAtomic$69(String, BlobContainer)220%n/a111111
lambda$cleanupOldShardGens$49(List, IndexId, int, Integer, ShardGeneration)220%n/a112211
lambda$cleanupStaleBlobs$34(RepositoryData, Collection, List, Map)220%n/a112211
lambda$writeUpdatedShardMetaDataAndComputeDeletes$24(BlobContainer, String, IndexId)220%n/a115511
lambda$executeConsistentStateUpdate$4(Function, String, RepositoryMetadata, Consumer, RepositoryData)220%n/a113311
toString()210%n/a111111
lambda$cleanupStaleBlobs$32(ActionListener, Collection)210%20%226611
staleRootBlobs(RepositoryData, Set)190%n/a113311
getOneSnapshotInfo(BlockingQueue, GetSnapshotInfoContext)180%20%225511
getRateLimiter(Settings, Setting)180%20%224411
corruptedStateException(Exception, Tuple)180%n/a113311
lambda$restoreShard$79(ShardId, SnapshotId, ActionListener, Exception)180%n/a111111
lambda$asyncCleanupUnlinkedShardLevelBlobs$19(Iterator, Collection, ActionListener)180%n/a117711
deleteFromContainer(BlobContainer, Iterator)170%20%225511
failStoreIfCorrupted(Store, Exception)170%20%227711
lambda$writeIndexGen$61(Map, GetSnapshotInfoContext, SnapshotInfo)170%n/a116611
lambda$buildBlobStoreIndexShardSnapshots$88(String)160%60%441111
lambda$resolveFilesToDelete$30(Map.Entry)160%n/a112211
lambda$resolveFilesToDelete$28(BlobStoreRepository.ShardSnapshotMetaDeleteResult)160%n/a112211
bestGeneration(Collection)150%n/a116611
stats()150%20%224411
executeConsistentStateUpdate(Function, String, Consumer)140%n/a113311
maybeRateLimitRestores(InputStream, RateLimitingInputStream.Listener)140%n/a113311
lambda$resolveFilesToDelete$31(String, int, String)140%40%332211
writeAtomic(BlobContainer, String, CheckedConsumer, boolean)130%n/a113311
shardContainer(IndexId, int)120%n/a111111
lambda$writeIndexGen$64(ActionListener, RepositoryData, StepListener, Long)120%n/a111111
lambda$finalizeSnapshot$43(boolean, RepositoryData, FinalizeSnapshotContext, SnapshotInfo, RepositoryData)120%20%224411
lambda$finalizeSnapshot$42(FinalizeSnapshotContext, SnapshotId, Exception)120%n/a112211
lambda$resolveFilesToDelete$29(String, String)110%n/a111111
cleanupUnlinkedRootAndIndicesBlobs(Collection, Map, Map, RepositoryData, ActionListener)100%n/a112211
latestIndexBlobId()100%n/a115511
maybeRateLimitRestores(InputStream)100%n/a111111
maybeRateLimitSnapshots(InputStream)100%n/a111111
unusedBlobs(Set, Set, BlobStoreIndexShardSnapshots)100%n/a113311
lambda$writeIndexGen$65(RepositoryData, Version, OutputStream)100%n/a113311
lambda$cacheRepositoryData$59(RepositoryData, RepositoryData)100%20%223311
lambda$finalizeSnapshot$47(SnapshotInfo, SnapshotId)100%n/a111111
lambda$finalizeSnapshot$45(Metadata, SnapshotId)100%n/a111111
lambda$cleanup$36(Map, Map, RepositoryData, ActionListener, RepositoryData)100%n/a113311
getSegmentInfoFileCount(List)90%n/a111111
indexContainer(IndexId)90%n/a111111
testBlobPrefix(String)90%n/a111111
fileQueueListener(BlockingQueue, int, ActionListener)90%n/a111111
lambda$cleanupStaleIndices$41(String)90%n/a112211
lambda$cleanupStaleRootFiles$40(List)90%n/a112211
lambda$resolveFilesToDelete$27(String, String)90%n/a111111
notStartedException()80%n/a111111
readSnapshotIndexLatestBlob()80%n/a111111
listBlobsToGetLatestIndexId()80%n/a111111
lambda$writeShardIndexBlobAtomic$86(BlobStoreIndexShardSnapshots, String, OutputStream)80%n/a111111
lambda$cleanupOldShardGens$50(List, int, IndexId, Map)80%n/a111111
lambda$cleanupStaleRootFiles$39(Set, String)80%20%221111
lambda$writeUpdatedShardMetaDataAndComputeDeletes$23(String, IndexId)80%n/a112211
lambda$writeUpdatedShardMetaDataAndComputeDeletes$21(Collection, SnapshotId)80%20%221111
lambda$writeUpdatedShardMetaDataAndComputeDeletes$20(Collection)80%n/a111111
lambda$canUpdateInPlace$7(Settings, Settings, String)80%n/a111111
maybeRateLimit(InputStream, Supplier, RateLimitingInputStream.Listener)70%n/a111111
lambda$snapshotShard$75(SnapshotId, ShardId)70%n/a111111
lambda$maybeWriteIndexLatest$68()70%n/a112211
lambda$doGetRepositoryData$58(ActionListener, RepositoryException, Tuple, Void)70%n/a111111
lambda$getRepositoryData$53(Executor, RepositoryMetadata, ActionListener)70%n/a111111
lambda$doDeleteShardSnapshots$15(RepositoryData, Collection, ActionListener, Collection)70%n/a111111
shardContainer(IndexId, ShardId)60%n/a111111
maybeRateLimitSnapshots(InputStream, RateLimitingInputStream.Listener)60%n/a111111
lambda$fileQueueListener$82(BlockingQueue, ActionListener, Exception)60%n/a113311
lambda$snapshotShard$74(String)60%n/a111111
lambda$snapshotShard$70(SnapshotId, SnapshotFiles)60%n/a111111
lambda$writeIndexGen$62(StepListener, RepositoryData, Map)60%n/a111111
lambda$cleanupStaleBlobs$33(Map, String)60%n/a111111
lambda$writeUpdatedShardMetaDataAndComputeDeletes$22(RepositoryData, IndexId, SnapshotId)60%n/a111111
lambda$asyncCleanupUnlinkedShardLevelBlobs$18(Collection)60%n/a111111
getBlobContainer()50%n/a111111
getBlobStore()50%n/a111111
indicesPath()50%n/a111111
lambda$maybeWriteIndexLatest$67(long, OutputStream)50%n/a111111
lambda$cleanupStaleBlobs$35(Map, Set)50%n/a111111
lambda$bestGeneration$9(String, RepositoryOperation)50%n/a111111
lambda$getSegmentInfoFileCount$6(BlobStoreIndexShardSnapshot.FileInfo)50%n/a111111
getSnapshotThrottleTimeInNanos()0%n/a111111
getRestoreThrottleTimeInNanos()0%n/a111111
lambda$snapshotShard$73(String)0%n/a111111
lambda$doGetRepositoryData$56(long, long)0%n/a111111
lambda$getRepositoryData$52(RepositoryData, RepositoryMetadata, ActionListener)0%n/a111111
lambda$doDeleteShardSnapshots$14(ActionListener, RepositoryData)0%n/a111111
lambda$doDeleteShardSnapshots$12(ActionListener, RepositoryData)0%n/a111111
lambda$safeRepositoryData$10(long, long)0%n/a111111
lambda$updateState$8(long, long)0%n/a111111
threadPool()0%n/a111111
isCompress()0%n/a111111
getMetadata()0%n/a111111
isReadOnly()0%n/a111111
supportURLRepo()0%n/a111111
getReadBufferSizeInBytes()0%n/a111111
lambda$maybeRateLimitSnapshots$84()0%n/a111111
lambda$maybeRateLimitRestores$83()0%n/a111111
lambda$writeUpdatedShardMetaDataAndComputeDeletes$25(Integer)0%n/a111111
lambda$static$3(String, XContentParser)0%n/a111111
lambda$static$2(String, XContentParser)0%n/a111111
lambda$static$1(String, XContentParser)0%n/a111111
lambda$static$0(String, XContentParser)0%n/a111111
chunkSize()0%n/a111111
hasAtomicOverwrites()0%n/a111111
lambda$writeIndexGen$60()0%n/a111111
lambda$doGetRepositoryData$57(RepositoryData, Void)0%n/a111111
lambda$cleanupUnlinkedRootAndIndicesBlobs$17(DeleteResult)0%n/a111111
doStop()0%n/a111111
lambda$snapshotShard$72()0%n/a111111