This is an automated email from the ASF dual-hosted git repository. reschke pushed a change to branch OAK-11267 in repository https://gitbox.apache.org/repos/asf/jackrabbit-oak.git
from d9ed807a55 OAK-11267: integrate https://github.com/seropian/jackrabbit-oak/commit/613e8d5a4e6c932c3f1f3fad5563785bc62c5559.diff add 6ed4cce2f2 Upgrade azure sdk 12 (#2514) No new revisions were added by this update. Summary of changes: RELEASE-NOTES.txt | 101 ++-- oak-api/pom.xml | 2 +- oak-auth-external/pom.xml | 2 +- oak-auth-ldap/pom.xml | 2 +- oak-authorization-cug/pom.xml | 2 +- oak-authorization-principalbased/pom.xml | 2 +- oak-benchmarks-elastic/pom.xml | 2 +- oak-benchmarks-lucene/pom.xml | 2 +- oak-benchmarks/pom.xml | 4 +- oak-blob-cloud-azure/pom.xml | 2 +- oak-blob-cloud/pom.xml | 2 +- .../jackrabbit/oak/blob/cloud/s3/S3Backend.java | 2 +- oak-blob-plugins/pom.xml | 2 +- .../plugins/blob/MarkSweepGarbageCollector.java | 4 - .../oak/plugins/blob/UploadStagingCache.java | 21 +- .../blob/datastore/SharedDataStoreUtils.java | 26 +- .../blob/migration/DepthFirstNodeIterator.java | 2 +- .../plugins/blob/AbstractDataStoreCacheTest.java | 4 +- .../plugins/blob/CompositeDataStoreCacheTest.java | 20 +- .../jackrabbit/oak/plugins/blob/FileCacheTest.java | 40 +- .../oak/plugins/blob/UploadStagingCacheTest.java | 134 ++--- .../oak/plugins/blob/datastore/FSBackendIT.java | 28 +- oak-blob/pom.xml | 2 +- .../jackrabbit/oak/spi/blob/MemoryBlobStore.java | 2 +- .../jackrabbit/oak/spi/blob/split/BlobIdSet.java | 17 +- .../oak/spi/blob/split/BlobIdSetTest.java | 237 ++++++++ oak-commons/pom.xml | 15 +- .../oak/commons/collections/AbstractIterator.java | 95 ++++ .../oak/commons/collections}/BloomFilter.java | 62 +- .../oak/commons/collections/HashUtils.java | 21 +- .../oak/commons/collections}/HyperLogLog.java | 4 +- .../oak/commons/collections/IterableUtils.java | 2 - .../oak/commons/collections/package-info.java | 2 +- .../oak/commons/concurrent/package-info.java | 2 +- .../internal/concurrent/DirectExecutor.java | 21 +- .../commons/internal/concurrent/ForkJoinUtils.java | 185 ++++++ .../internal/concurrent/FutureConverter.java | 179 ++++++ .../commons/internal/concurrent/FutureUtils.java | 83 +++ .../commons/internal/concurrent}/package-info.java | 4 +- .../oak/commons/internal/function/Suppliers.java | 61 ++ .../{log => internal/function}/package-info.java | 10 +- .../oak/commons/internal/graph/Traverser.java | 267 +++++++++ .../oak/commons/internal/graph}/package-info.java | 4 +- .../oak/commons/io/BurnOnCloseFileIterator.java | 2 +- .../oak/commons/io/FileLineDifferenceIterator.java | 2 +- .../oak/commons/io/FileTreeTraverser.java | 16 +- .../commons/collections/AbstractIteratorTest.java | 69 +++ .../oak/commons/collections}/BloomFilterTest.java | 92 ++- .../oak/commons/collections}/HyperLogLogTest.java | 39 +- .../internal/concurrent/DirectExecutorTest.java | 38 +- .../internal/concurrent/ForkJoinUtilsTest.java | 180 ++++++ .../internal/concurrent/FutureConverterTest.java | 348 ++++++++++++ .../internal/concurrent/FutureUtilsTest.java | 215 +++++++ .../commons/internal/function/SuppliersTest.java | 107 ++++ .../oak/commons/internal/graph/TraverserTest.java | 630 +++++++++++++++++++++ oak-core-spi/pom.xml | 2 +- .../org/apache/jackrabbit/oak/cache/CacheTest.java | 8 +- .../oak/commons/jmx/ManagementOperationTest.java | 4 +- oak-core/pom.xml | 13 +- .../jackrabbit/oak/core/SecureNodeBuilder.java | 8 +- .../atomic/AtomicCounterEditorProvider.java | 5 +- .../jackrabbit/oak/plugins/index/ConfigHelper.java | 6 + .../index/importer/ClusterNodeStoreLock.java | 10 +- .../index/property/PropertyIndexEditor.java | 2 +- .../index/property/jmx/PropertyIndexStats.java | 21 +- .../plugins/index/reference/ReferenceEditor.java | 3 +- .../org/apache/jackrabbit/oak/query/QueryImpl.java | 2 +- .../jackrabbit/oak/query/UnionQueryImpl.java | 2 +- .../apache/jackrabbit/oak/builtin_nodetypes.cnd | 2 +- .../strategy/ContentMirrorStoreStrategyTest.java | 2 +- .../strategy/UniqueEntryStoreStrategyTest.java | 2 +- .../jackrabbit/oak/query/AbstractQueryTest.java | 19 +- .../oak/plugins/nodetype/write/oak3725-1.cnd | 2 +- .../oak/plugins/nodetype/write/oak3725-2.cnd | 2 +- .../oak/plugins/nodetype/write/oak4567.cnd | 2 +- oak-doc-railroad-macro/pom.xml | 2 +- oak-doc/pom.xml | 2 +- oak-doc/src/site/markdown/differences.md | 7 +- oak-doc/src/site/markdown/query/lucene.md | 5 +- .../src/site/markdown/query/oak-run-indexing.md | 2 +- .../site/markdown/query/query-troubleshooting.md | 3 +- oak-examples/pom.xml | 2 +- oak-examples/standalone/pom.xml | 11 +- oak-examples/webapp/pom.xml | 4 +- oak-exercise/pom.xml | 2 +- oak-http/pom.xml | 2 +- oak-it-osgi/pom.xml | 3 +- ...e.jackrabbit.oak.jcr.osgi.RepositoryManager.cfg | 30 +- .../jackrabbit/oak/osgi/TikaExtractionOsgiIT.java | 23 +- .../org/apache/jackrabbit/oak/osgi/test2.txt | 4 + oak-it-osgi/src/test/resources/versions.properties | 1 + oak-it/pom.xml | 13 +- oak-jackrabbit-api/pom.xml | 2 +- oak-jcr/pom.xml | 4 +- .../jackrabbit/oak/jcr/xml/ImporterImpl.java | 8 +- .../oak/jcr/xml/SysViewImportHandler.java | 28 +- .../jackrabbit/oak/jcr/AtomicCounterClusterIT.java | 43 +- .../apache/jackrabbit/oak/jcr/AtomicCounterIT.java | 38 +- .../jackrabbit/oak/jcr/ConcurrentReadIT.java | 54 +- .../oak/jcr/cluster/NonLocalObservationIT.java | 4 +- .../jackrabbit/oak/jcr/random/RandomOpCompare.java | 2 - .../apache/jackrabbit/oak/jcr/xml/ImportTest.java | 241 ++++++++ oak-lucene/pom.xml | 4 +- .../index/lucene/IndexAugmentorFactory.java | 11 +- .../oak/plugins/index/lucene/LuceneIndex.java | 2 +- .../plugins/index/lucene/LuceneIndexMBeanImpl.java | 19 +- .../plugins/index/lucene/LucenePropertyIndex.java | 11 +- .../index/lucene/NodeStateAnalyzerFactory.java | 7 +- .../index/lucene/directory/IndexRootDirectory.java | 5 +- .../index/lucene/hybrid/NRTIndexFactory.java | 6 +- .../lucene/property/HybridPropertyIndexInfo.java | 16 +- .../index/lucene/util/LuceneIndexHelper.java | 5 +- .../StatisticalSortedSetDocValuesFacetCounts.java | 2 +- .../plugins/index/lucene/util/TapeSampling.java | 2 +- .../index/lucene/writer/IndexWriterPool.java | 11 +- .../ActiveDeletedBlobCollectorMBeanImplTest.java | 7 +- .../index/lucene/IndexCopierCleanupTest.java | 4 +- .../oak/plugins/index/lucene/IndexCopierTest.java | 36 +- .../plugins/index/lucene/IndexNodeManagerTest.java | 4 +- .../oak/plugins/index/lucene/LuceneIndexTest.java | 6 +- .../ConcurrentCopyOnReadDirectoryTest.java | 4 +- .../lucene/directory/CopyOnReadDirectoryTest.java | 4 +- .../index/lucene/hybrid/DelayedFacetReadTest.java | 4 +- .../index/lucene/hybrid/DocumentQueueTest.java | 16 +- .../index/lucene/hybrid/FacetCacheTest.java | 4 +- .../index/lucene/hybrid/HybridIndexClusterIT.java | 4 +- .../index/lucene/hybrid/HybridIndexTest.java | 4 +- .../lucene/hybrid/LocalIndexWriterFactoryTest.java | 6 +- .../index/lucene/hybrid/ManyFacetsTest.java | 4 +- ...eadedOldLuceneFacetProviderReadFailureTest.java | 4 +- .../index/lucene/hybrid/NRTIndexFactoryTest.java | 4 +- .../plugins/index/lucene/hybrid/NRTIndexTest.java | 4 +- .../index/lucene/hybrid/ReaderRefCountIT.java | 6 +- .../index/lucene/property/RecursiveDeleteTest.java | 14 +- .../index/lucene/util/TapeSamplingTest.java | 2 +- oak-parent/pom.xml | 25 +- oak-pojosr/pom.xml | 4 +- .../oak/run/osgi/OakOSGiRepositoryFactory.java | 10 +- .../oak/run/osgi/RunnableJobTracker.java | 5 +- .../jackrabbit/oak/run/osgi/SpringBootSupport.java | 2 +- oak-query-spi/pom.xml | 2 +- oak-run-commons/pom.xml | 13 +- .../oak/fixture/CompositeStoreFixture.java | 4 +- .../jackrabbit/oak/index/IndexerMetrics.java | 8 +- .../jackrabbit/oak/index/OutOfBandIndexerBase.java | 30 +- .../apache/jackrabbit/oak/index/ThreadMonitor.java | 242 ++++++++ .../indexer/document/DocumentStoreIndexerBase.java | 8 +- .../indexer/document/NodeStateEntryTraverser.java | 7 +- .../document/flatfile/ChildNodeStateProvider.java | 2 +- .../flatfile/FlatFileNodeStoreBuilder.java | 6 +- .../indexer/document/flatfile/FlatFileStore.java | 2 +- .../document/flatfile/FlatFileStoreIterator.java | 2 +- .../flatfile/analysis/modules/BinaryId.java | 18 +- .../analysis/modules/DistinctBinarySize.java | 4 +- .../modules/DistinctBinarySizeHistogram.java | 2 +- .../flatfile/analysis/modules/PropertyStats.java | 4 +- .../flatfile/analysis/utils/TopKValues.java | 3 +- .../flatfile/pipelined/PipelinedMergeSortTask.java | 3 - .../pipelined/PipelinedMongoDownloadTask.java | 104 ++-- .../flatfile/pipelined/PipelinedSortBatchTask.java | 3 - .../flatfile/pipelined/PipelinedStrategy.java | 17 +- .../flatfile/pipelined/PipelinedTransformTask.java | 3 - .../pipelined/PipelinedTreeStoreStrategy.java | 12 +- .../document/flatfile/pipelined/ThreadMonitor.java | 134 ----- .../index/indexer/document/tree/Prefetcher.java | 6 +- .../document/mongo/MongoDocumentTraverser.java | 4 +- .../oak/run/cli/DocumentFixtureProvider.java | 10 +- .../jackrabbit/oak/index/ThreadMonitorTest.java | 132 +++++ .../flatfile/analysis/modules/BinarySizeTest.java | 10 + .../analysis/modules/PropertyStatsTest.java | 2 +- .../analysis/utils/CountMinSketchTest.java | 5 +- ...gLogTest.java => HyperLogLog3Linear64Test.java} | 39 +- .../flatfile/analysis/utils/TopKValuesTest.java | 10 +- .../flatfile/pipelined/MongoTestBackend.java | 6 +- .../flatfile/pipelined/PipelineITUtil.java | 4 +- .../pipelined/PipelinedMongoDownloadTaskTest.java | 6 +- .../PipelinedMongoServerSelectorTest.java | 8 +- oak-run-elastic/pom.xml | 3 +- oak-run/pom.xml | 4 +- .../oak/plugins/tika/BinaryResourceProvider.java | 4 +- .../tika/CSVFileBinaryResourceProvider.java | 4 +- .../oak/plugins/tika/CSVFileGenerator.java | 2 +- .../tika/NodeStoreBinaryResourceProvider.java | 19 +- .../jackrabbit/oak/run/DataStoreCheckCommand.java | 16 +- .../org/apache/jackrabbit/oak/run/Downloader.java | 7 +- .../jackrabbit/oak/run/RevisionsCommand.java | 9 + .../jackrabbit/oak/run/UnlockUpgradeCommand.java | 11 +- .../java/org/apache/jackrabbit/oak/run/Utils.java | 16 +- .../oak/index/DocumentStoreIndexerIT.java | 6 +- .../jackrabbit/oak/index/IncrementalStoreTest.java | 6 +- .../oak/plugins/document/RevisionsCommandTest.java | 19 + .../oak/plugins/tika/BinaryStatsTest.java | 2 +- .../tika/CSVFileBinaryResourceProviderTest.java | 18 +- .../tika/NodeStoreBinaryResourceProviderTest.java | 3 +- .../oak/plugins/tika/TextPopulatorTest.java | 10 +- oak-search-elastic/pom.xml | 2 +- .../index/elastic/ElasticIndexProviderService.java | 28 +- .../index/elastic/ElasticIndexStatistics.java | 7 +- .../plugins/index/elastic/query/ElasticIndex.java | 15 +- .../index/elastic/query/ElasticIndexProvider.java | 32 +- .../index/elastic/query/ElasticRequestHandler.java | 6 +- .../query/async/ElasticResultRowAsyncIterator.java | 166 ++++-- .../query/async/facets/ElasticFacetProvider.java | 12 +- .../facets/ElasticSecureFacetAsyncProvider.java | 74 ++- .../ElasticStatisticalFacetAsyncProvider.java | 230 +++++--- .../index/elastic/ElasticAbstractQueryTest.java | 18 +- .../index/elastic/ElasticFullTextAnalyzerTest.java | 19 - .../elastic/ElasticIndexProviderServiceTest.java | 25 +- .../ElasticReliabilitySlowReaderQueryTest.java | 110 ++++ .../ElasticReliabilitySyncIndexingTest.java | 46 +- oak-search/pom.xml | 2 +- .../plugins/index/search/util/TapeSampling.java | 2 +- .../oak/plugins/index/FacetCommonTest.java | 91 ++- .../plugins/index/FullTextAnalyzerCommonTest.java | 24 + .../index/search/util/TapeSamplingTest.java | 2 +- oak-security-spi/pom.xml | 7 +- .../credentials/SimpleCredentialsSupport.java | 12 +- .../security/privilege/PrivilegeBitsProvider.java | 4 +- .../user/action/ClearMembershipActionTest.java | 1 - oak-segment-aws/pom.xml | 2 +- .../segment/aws/tool/AwsSegmentStoreMigrator.java | 19 +- .../oak/segment/aws/tool/SegmentCopyTestBase.java | 9 +- oak-segment-azure/pom.xml | 5 +- .../oak/segment/azure/AzureArchiveManager.java | 83 ++- .../oak/segment/azure/AzureJournalFile.java | 14 +- .../oak/segment/azure/AzurePersistence.java | 9 +- .../oak/segment/azure/AzurePersistenceManager.java | 2 +- .../segment/azure/AzureSegmentArchiveReader.java | 12 +- .../segment/azure/AzureSegmentArchiveWriter.java | 11 +- .../oak/segment/azure/AzureUtilities.java | 42 +- .../oak/segment/azure/tool/SegmentCopy.java | 2 +- .../segment/azure/tool/SegmentStoreMigrator.java | 33 +- .../segment/azure/v8/AzureArchiveManagerV8.java | 59 +- .../oak/segment/azure/v8/AzurePersistenceV8.java | 3 +- .../azure/v8/AzureSegmentArchiveWriterV8.java | 12 +- .../oak/segment/azure/v8/AzureUtilitiesV8.java | 6 +- .../AzureArchiveManagerIgnoreSamePrefixTest.java | 211 +++++++ .../oak/segment/azure/AzureArchiveManagerTest.java | 64 ++- .../oak/segment/azure/AzureJournalFileTest.java | 15 +- .../azure/AzureSegmentArchiveWriterTest.java | 31 +- .../oak/segment/azure/AzureTarWriterTest.java | 8 + .../oak/segment/azure/AzureUtilitiesTest.java | 79 +++ .../segment/azure/tool/SegmentCopyTestBase.java | 11 +- .../azure/v8/AzureArchiveManagerV8Test.java | 68 ++- .../azure/v8/AzureSegmentArchiveWriterV8Test.java | 20 + .../oak/segment/azure/v8/AzureTarWriterV8Test.java | 17 + .../split/AzureOnTarBaseSplitPersistenceTest.java | 200 +++++++ oak-segment-remote/pom.xml | 2 +- .../remote/AbstractRemoteSegmentArchiveReader.java | 25 +- .../oak/segment/remote/RemoteUtilities.java | 19 + .../oak/segment/remote/WriteAccessController.java | 10 + .../oak/segment/remote/package-info.java | 2 +- .../oak/segment/remote/RemoteUtilitiesTest.java | 66 ++- .../segment/remote/WriteAccessControllerTest.java | 9 + oak-segment-tar/pom.xml | 2 +- .../oak/segment/ImmutableRecordNumbers.java | 2 +- .../oak/segment/MutableRecordNumbers.java | 2 +- .../jackrabbit/oak/segment/SegmentNodeState.java | 2 +- .../jackrabbit/oak/segment/SegmentReferences.java | 2 +- .../jackrabbit/oak/segment/WriterCacheManager.java | 2 +- .../jackrabbit/oak/segment/file/JournalReader.java | 2 +- .../oak/segment/file/tar/GraphLoader.java | 116 ---- .../oak/segment/file/tar/SegmentGraph.java | 243 ++++++++ .../oak/segment/file/tar/SegmentTarReader.java | 36 +- .../oak/segment/file/tar/TarConstants.java | 19 - .../jackrabbit/oak/segment/file/tar/TarFiles.java | 68 ++- .../jackrabbit/oak/segment/file/tar/TarReader.java | 106 +--- .../jackrabbit/oak/segment/file/tar/TarWriter.java | 72 +-- .../spi/persistence/SegmentArchiveManager.java | 12 + .../spi/persistence/SegmentArchiveReader.java | 17 +- .../CachingSegmentArchiveReader.java | 11 +- .../persistence/persistentcache/package-info.java | 2 +- .../split/SplitSegmentArchiveManager.java | 31 +- .../split/UnclosedSegmentArchiveReader.java | 8 +- .../spi/persistence/split/package-info.java | 2 +- .../segment/standby/codec/ChunkedBlobStream.java | 6 +- .../standby/codec/GetSegmentResponseEncoder.java | 6 +- .../oak/segment/standby/codec/HashUtils.java | 56 ++ .../oak/segment/standby/codec/ResponseDecoder.java | 10 +- .../oak/segment/file/TarRevisionsTest.java | 53 +- .../oak/segment/file/tar/TarFileTest.java | 8 +- .../persistence/split/SplitPersistenceTest.java | 261 +++++++++ .../testutils/NodeStoreTestHarness.java | 285 ++++++++++ .../testutils/PersistenceDecorator.java | 73 +++ .../testutils/SegmentArchiveManagerDecorator.java | 107 ++++ .../oak/segment/standby/StandbyTestUtils.java | 12 +- .../oak/segment/standby/codec/HashUtilsTest.java | 128 +++++ .../segment/standby/codec/ResponseDecoderTest.java | 2 +- oak-shaded-guava/pom.xml | 6 +- oak-store-composite/pom.xml | 9 +- .../oak/composite/CompositeNodeBuilder.java | 20 +- .../oak/composite/CompositeNodeState.java | 21 +- .../oak/composite/it/CompositeTestSupport.java | 4 +- oak-store-document/pom.xml | 8 +- .../oak/plugins/document/BatchCommit.java | 14 +- .../plugins/document/BlobReferenceIterator.java | 2 +- .../oak/plugins/document/Configuration.java | 92 ++- .../oak/plugins/document/DocumentNodeState.java | 14 +- .../plugins/document/DocumentNodeStoreBuilder.java | 24 +- .../plugins/document/DocumentNodeStoreService.java | 38 +- .../DocumentNodeStoreServiceConfiguration.java | 92 ++- .../oak/plugins/document/FullGCMode.java | 6 + .../oak/plugins/document/FullGCStatsCollector.java | 5 + .../plugins/document/FullGCStatsCollectorImpl.java | 9 + .../oak/plugins/document/JournalEntry.java | 2 +- .../oak/plugins/document/NodeDocument.java | 27 +- .../oak/plugins/document/PropertyHistory.java | 2 +- .../oak/plugins/document/RevisionVector.java | 2 +- .../oak/plugins/document/SplitOperations.java | 3 +- .../plugins/document/VersionGarbageCollector.java | 29 +- .../document/cache/CacheChangesTracker.java | 44 +- .../oak/plugins/document/mongo/MongoBlobStore.java | 6 +- .../plugins/document/mongo/MongoDBConnection.java | 34 +- .../mongo/MongoDocumentNodeStoreBuilderBase.java | 165 +++++- .../plugins/document/mongo/MongoDocumentStore.java | 74 ++- .../document/mongo/MongoDocumentStoreMetrics.java | 12 +- .../MongoDocumentStoreThrottlingFactorUpdater.java | 101 ++++ .../mongo/MongoFullGcNodeBinSumBsonSize.java | 2 +- .../document/mongo/MongoSessionFactory.java | 46 +- .../oak/plugins/document/mongo/MongoStatus.java | 2 +- .../document/mongo/MongoThrottlerFactory.java | 39 ++ .../document/mongo/MongoVersionGCSupport.java | 44 +- .../plugins/document/mongo/ReplicaSetStatus.java | 4 +- .../oak/plugins/document/mongo/RevisionEntry.java | 6 - .../oak/plugins/document/rdb/RDBBlobStore.java | 2 +- .../document/rdb/RDBDocumentNodeStoreBuilder.java | 2 +- .../plugins/document/rdb/RDBVersionGCSupport.java | 2 +- .../oak/plugins/document/util/MongoConnection.java | 184 ++++-- .../oak/plugins/document/util/Utils.java | 2 +- .../oak/fixture/DocumentMongoFixture.java | 15 +- .../document/AbstractMongoConnectionTest.java | 2 +- .../plugins/document/BasicDocumentStoreTest.java | 7 +- .../oak/plugins/document/BlobThroughPutTest.java | 23 +- .../oak/plugins/document/BranchCommitGCTest.java | 41 +- .../oak/plugins/document/CacheConsistencyTest.java | 2 +- .../oak/plugins/document/ClusterInfoTest.java | 4 +- .../document/ConcurrentPrefetchAndUpdateIT.java | 2 +- .../plugins/document/DocumentMKBuilderTest.java | 2 +- .../DocumentNodeStoreServiceConfigurationTest.java | 105 ++++ .../document/DocumentNodeStoreServiceTest.java | 21 - .../oak/plugins/document/FullGCHelper.java | 1 + .../document/FullGCStatsCollectorImplTest.java | 10 + .../oak/plugins/document/MongoDbTest.java | 5 +- .../oak/plugins/document/MongoUtils.java | 24 +- .../oak/plugins/document/NodeDocumentTest.java | 69 +++ .../oak/plugins/document/VersionGCTest.java | 10 + .../document/VersionGarbageCollectorIT.java | 313 +++++++++- .../bundlor/BundlingConfigHandlerTest.java | 4 +- .../cache/CacheChangesTrackerConcurrencyTest.java | 215 +++++++ .../document/mongo/AcquireRecoveryLockTest.java | 2 +- .../document/mongo/ClusterConflictTest.java | 2 +- .../mongo/MongoConnectionPoolSettingsTest.java | 195 +++++++ .../document/mongo/MongoConnectionTest.java | 76 ++- .../plugins/document/mongo/MongoDBConfigTest.java | 10 +- .../mongo/MongoDocumentNodeStoreBuilderTest.java | 16 + .../mongo/MongoDocumentStoreTestHelper.java | 2 +- ...goDocumentStoreThrottlingFactorUpdaterTest.java | 127 +++++ .../mongo/MongoFullGcNodeBinSumBsonSizeTest.java | 14 +- .../plugins/document/mongo/MongoStatusTest.java | 15 +- .../plugins/document/mongo/MongoTestClient.java | 169 +++++- .../document/mongo/MongoTestCollection.java | 164 +++--- .../plugins/document/mongo/MongoTestDatabase.java | 19 +- .../document/mongo/MongoThrottlerFactoryTest.java | 34 ++ .../oak/plugins/document/mongo/MongoUtilsTest.java | 2 +- .../document/mongo/MongodProcessFactory.java | 7 +- .../mongo/ReplicaSetDefaultWriteConcernIT.java | 26 + .../document/mongo/ReplicaSetResilienceIT.java | 28 +- .../document/mongo/ReplicaSetStatusTest.java | 2 +- .../oak/plugins/document/mongo/RetryReadIT.java | 2 +- .../document/prefetch/CountingMongoDatabase.java | 17 +- oak-store-spi/pom.xml | 2 +- oak-upgrade/pom.xml | 4 +- .../oak/upgrade/cli/node/MongoFactory.java | 11 +- .../cli/container/MongoNodeStoreContainer.java | 26 +- pom.xml | 2 +- 375 files changed, 9922 insertions(+), 2404 deletions(-) create mode 100644 oak-blob/src/test/java/org/apache/jackrabbit/oak/spi/blob/split/BlobIdSetTest.java create mode 100644 oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/collections/AbstractIterator.java rename {oak-run-commons/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/flatfile/analysis/utils => oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/collections}/BloomFilter.java (70%) rename oak-run-commons/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/flatfile/analysis/utils/Hash.java => oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/collections/HashUtils.java (83%) rename {oak-run-commons/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/flatfile/analysis/utils => oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/collections}/HyperLogLog.java (97%) copy oak-store-spi/src/test/java/org/apache/jackrabbit/oak/fixture/MemoryFixture.java => oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/internal/concurrent/DirectExecutor.java (71%) create mode 100644 oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/internal/concurrent/ForkJoinUtils.java create mode 100644 oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/internal/concurrent/FutureConverter.java create mode 100644 oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/internal/concurrent/FutureUtils.java copy {oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/util => oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/internal/concurrent}/package-info.java (92%) create mode 100644 oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/internal/function/Suppliers.java copy oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/{log => internal/function}/package-info.java (86%) create mode 100644 oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/internal/graph/Traverser.java copy {oak-segment-remote/src/main/java/org/apache/jackrabbit/oak/segment/remote/queue => oak-commons/src/main/java/org/apache/jackrabbit/oak/commons/internal/graph}/package-info.java (87%) create mode 100644 oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/collections/AbstractIteratorTest.java rename {oak-run-commons/src/test/java/org/apache/jackrabbit/oak/index/indexer/document/flatfile/analysis/utils => oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/collections}/BloomFilterTest.java (61%) copy {oak-run-commons/src/test/java/org/apache/jackrabbit/oak/index/indexer/document/flatfile/analysis/utils => oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/collections}/HyperLogLogTest.java (84%) copy oak-store-composite/src/test/java/org/apache/jackrabbit/oak/composite/StringCacheTest.java => oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/internal/concurrent/DirectExecutorTest.java (56%) create mode 100644 oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/internal/concurrent/ForkJoinUtilsTest.java create mode 100644 oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/internal/concurrent/FutureConverterTest.java create mode 100644 oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/internal/concurrent/FutureUtilsTest.java create mode 100644 oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/internal/function/SuppliersTest.java create mode 100644 oak-commons/src/test/java/org/apache/jackrabbit/oak/commons/internal/graph/TraverserTest.java create mode 100644 oak-it-osgi/src/test/resources/org/apache/jackrabbit/oak/osgi/test2.txt create mode 100644 oak-run-commons/src/main/java/org/apache/jackrabbit/oak/index/ThreadMonitor.java delete mode 100644 oak-run-commons/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/flatfile/pipelined/ThreadMonitor.java create mode 100644 oak-run-commons/src/test/java/org/apache/jackrabbit/oak/index/ThreadMonitorTest.java rename oak-run-commons/src/test/java/org/apache/jackrabbit/oak/index/indexer/document/flatfile/analysis/utils/{HyperLogLogTest.java => HyperLogLog3Linear64Test.java} (83%) create mode 100644 oak-search-elastic/src/test/java/org/apache/jackrabbit/oak/plugins/index/elastic/ElasticReliabilitySlowReaderQueryTest.java create mode 100644 oak-segment-azure/src/test/java/org/apache/jackrabbit/oak/segment/azure/AzureArchiveManagerIgnoreSamePrefixTest.java create mode 100644 oak-segment-azure/src/test/java/org/apache/jackrabbit/oak/segment/azure/AzureUtilitiesTest.java create mode 100644 oak-segment-azure/src/test/java/org/apache/jackrabbit/oak/segment/spi/persistence/split/AzureOnTarBaseSplitPersistenceTest.java delete mode 100644 oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/file/tar/GraphLoader.java create mode 100644 oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/file/tar/SegmentGraph.java create mode 100644 oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/codec/HashUtils.java create mode 100644 oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/spi/persistence/split/SplitPersistenceTest.java create mode 100644 oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/spi/persistence/testutils/NodeStoreTestHarness.java create mode 100644 oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/spi/persistence/testutils/PersistenceDecorator.java create mode 100644 oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/spi/persistence/testutils/SegmentArchiveManagerDecorator.java create mode 100644 oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/codec/HashUtilsTest.java create mode 100644 oak-store-document/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStoreThrottlingFactorUpdater.java create mode 100644 oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/cache/CacheChangesTrackerConcurrencyTest.java create mode 100644 oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoConnectionPoolSettingsTest.java create mode 100644 oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStoreThrottlingFactorUpdaterTest.java