Package org.opensearch.repositories.blobstore

Class AbstractBlobContainerRetriesTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.util.LuceneTestCase

org.opensearch.test.OpenSearchTestCase

org.opensearch.repositories.blobstore.AbstractBlobContainerRetriesTestCase

public abstract class AbstractBlobContainerRetriesTestCase
extends OpenSearchTestCase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractBlobContainerRetriesTestCase.ZeroInputStream	A resettable InputStream that only serves zeros.

Nested classes/interfaces inherited from class org.opensearch.test.OpenSearchTestCase

OpenSearchTestCase.GeohashGenerator, OpenSearchTestCase.TestAnalysis

Nested classes/interfaces inherited from class org.apache.lucene.util.LuceneTestCase

org.apache.lucene.util.LuceneTestCase.AwaitsFix, org.apache.lucene.util.LuceneTestCase.BadApple, org.apache.lucene.util.LuceneTestCase.Monster, org.apache.lucene.util.LuceneTestCase.Nightly, org.apache.lucene.util.LuceneTestCase.Slow, org.apache.lucene.util.LuceneTestCase.SuppressCodecs, org.apache.lucene.util.LuceneTestCase.SuppressFileSystems, org.apache.lucene.util.LuceneTestCase.SuppressFsync, org.apache.lucene.util.LuceneTestCase.SuppressReproduceLine, org.apache.lucene.util.LuceneTestCase.SuppressSysoutChecks, org.apache.lucene.util.LuceneTestCase.SuppressTempFileChecks, org.apache.lucene.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.util.LuceneTestCase.Weekly

Field Summary

Fields

Modifier and Type	Field	Description
protected com.sun.net.httpserver.HttpServer	httpServer

Fields inherited from class org.opensearch.test.OpenSearchTestCase

checkIndexFailures, DEFAULT_NAMED_WRITABLE_REGISTRY, DEFAULT_TEST_WORKER_ID, failureAndSuccessEvents, FIPS_SYSPROP, JAVA_TIMEZONE_IDS, JAVA_ZONE_IDS, JODA_TIMEZONE_IDS, logger, TEST_WORKER_SYS_PROPERTY, TEST_WORKER_VM_ID

Fields inherited from class org.apache.lucene.util.LuceneTestCase

assertsAreEnabled, classRules, DEFAULT_LINE_DOCS_FILE, INFOSTREAM, JENKINS_LARGE_LINE_DOCS_FILE, LEAVE_TEMPORARY, MAYBE_CACHE_POLICY, RANDOM_MULTIPLIER, ruleChain, suiteFailureMarker, SYSPROP_AWAITSFIX, SYSPROP_BADAPPLES, SYSPROP_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, SYSPROP_SLOW, SYSPROP_WEEKLY, TEST_ASSERTS_ENABLED, TEST_AWAITSFIX, TEST_BADAPPLES, TEST_CODEC, TEST_DIRECTORY, TEST_DOCVALUESFORMAT, TEST_LINE_DOCS_FILE, TEST_MONSTER, TEST_NIGHTLY, TEST_POSTINGSFORMAT, TEST_SLOW, TEST_THROTTLING, TEST_WEEKLY, VERBOSE

Constructor Summary

Constructors

Constructor	Description
AbstractBlobContainerRetriesTestCase()

Method Summary

Modifier and Type	Method	Description
protected abstract java.lang.String	bytesContentType()
protected abstract org.opensearch.common.blobstore.BlobContainer	createBlobContainer(java.lang.Integer maxRetries, org.opensearch.common.unit.TimeValue readTimeout, java.lang.Boolean disableChunkedEncoding, org.opensearch.common.unit.ByteSizeValue bufferSize)
protected abstract java.lang.String	downloadStorageEndpoint(java.lang.String blob)
protected static org.opensearch.common.collect.Tuple<java.lang.Long,java.lang.Long>	getRange(com.sun.net.httpserver.HttpExchange exchange)
protected static java.util.Optional<java.lang.Integer>	getRangeEnd(com.sun.net.httpserver.HttpExchange exchange)
protected static int	getRangeStart(com.sun.net.httpserver.HttpExchange exchange)
protected static byte[]	randomBlobContent()
protected static byte[]	randomBlobContent(int minSize)
protected void	sendIncompleteContent(com.sun.net.httpserver.HttpExchange exchange, byte[] bytes)
void	setUp()
void	tearDown()
void	testReadBlobWithNoHttpResponse()
void	testReadBlobWithPrematureConnectionClose()
void	testReadBlobWithReadTimeouts()
void	testReadBlobWithRetries()
void	testReadNonexistentBlobThrowsNoSuchFileException()
void	testReadRangeBlobWithRetries()
protected abstract java.lang.Class<? extends java.lang.Exception>	unresponsiveExceptionType()

Methods inherited from class org.opensearch.test.OpenSearchTestCase

after, afterIfFailed, afterIfSuccessful, allowedWarnings, assertArrayEquals, assertBusy, assertBusy, assertEquals, assertSettingDeprecationsAndWarnings, assertSettingDeprecationsAndWarnings, assertWarnings, assertWarnings, before, between, buildEnvSettings, buildNewFakeTransportAddress, checkStaticState, clearAdditionalRoles, copyInstance, copyNamedWriteable, copyNamedWriteable, copyWriteable, copyWriteable, createDefaultIndexAnalyzers, createParser, createParser, createParser, createParser, createParser, createParser, createTestAnalysis, createTestAnalysis, createTestAnalysis, enableJodaDeprecationWarningsCheck, enableWarningsCheck, ensureAllSearchContextsReleased, ensureCheckIndexPassed, ensureSupportedLocale, frequently, generateRandomStringArray, generateRandomStringArray, getBasePort, getDataPath, getPortRange, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, inFipsJvm, iterations, maybeSet, mockScript, newNodeEnvironment, newNodeEnvironment, randomAlphaOfLength, randomAlphaOfLengthBetween, randomArray, randomArray, randomBigInteger, randomBoolean, randomByte, randomByteArrayOfLength, randomDateFormatterPattern, randomDateTimeZone, randomDouble, randomDoubleBetween, randomFloat, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomGeohash, randomInt, randomInt, randomIntBetween, randomIp, randomList, randomList, randomLong, randomLongBetween, randomNonNegativeLong, randomPositiveTimeValue, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomValueOtherThan, randomValueOtherThanMany, randomZone, removeHeaderWarningAppender, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, scaledRandomIntBetween, setContentType, setFileSystem, setHeaderWarningAppender, settings, shuffleMap, shuffleXContent, shuffleXContent, spinForAtLeastNMilliseconds, spinForAtLeastOneMillisecond, terminate, terminate, tmpPaths, toShuffledXContent, waitUntil, waitUntil, writableRegistry, xContentRegistry

Methods inherited from class org.apache.lucene.util.LuceneTestCase

addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertFieldInfosEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, asSet, assumeFalse, assumeNoException, assumeTrue, assumeWorkingMMapOnWindows, atLeast, atLeast, callStackContains, callStackContains, callStackContainsAnyOf, closeAfterSuite, closeAfterTest, collate, createTempDir, createTempDir, createTempFile, createTempFile, dumpArray, dumpIterator, ensureSaneIWCOnNightly, expectThrows, expectThrows, expectThrows, expectThrowsAnyOf, expectThrowsAnyOf, getBaseTempDirForTestClass, getDataInputStream, getOnlyLeafReader, getTestClass, getTestName, hasWorkingMMapOnWindows, isTestThread, localeForLanguageTag, maybeChangeLiveIndexWriterConfig, maybeWrapReader, newAlcoholicMergePolicy, newAlcoholicMergePolicy, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newDirectory, newDirectory, newDirectory, newDirectory, newDirectory, newField, newField, newFSDirectory, newFSDirectory, newIndexWriterConfig, newIndexWriterConfig, newIndexWriterConfig, newIOContext, newIOContext, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newMaybeVirusCheckingDirectory, newMaybeVirusCheckingFSDirectory, newMergePolicy, newMergePolicy, newMergePolicy, newMockDirectory, newMockDirectory, newMockDirectory, newMockFSDirectory, newMockFSDirectory, newSearcher, newSearcher, newSearcher, newSearcher, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, rarely, rarely, replaceMaxFailureRule, resetDefaultQueryCache, restoreCPUCoreCount, restoreIndexWriterMaxDocs, restoreSpins, runWithRestrictedPermissions, setIndexWriterMaxDocs, setupCPUCoreCount, setupSpins, slowFileExists, usually, usually, wrapReader

Methods inherited from class org.junit.Assert

assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertThat, assertThat, assertTrue, assertTrue, fail, fail

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

httpServer

protected com.sun.net.httpserver.HttpServer httpServer

Constructor Details

AbstractBlobContainerRetriesTestCase

public AbstractBlobContainerRetriesTestCase()

Method Details

setUp

public void setUp() throws java.lang.Exception

Overrides:

setUp in class org.apache.lucene.util.LuceneTestCase

Throws:

java.lang.Exception

tearDown

public void tearDown() throws java.lang.Exception

Overrides:

tearDown in class org.apache.lucene.util.LuceneTestCase

Throws:

java.lang.Exception

downloadStorageEndpoint

protected abstract java.lang.String downloadStorageEndpoint(java.lang.String blob)

bytesContentType

protected abstract java.lang.String bytesContentType()

unresponsiveExceptionType

protected abstract java.lang.Class<? extends java.lang.Exception> unresponsiveExceptionType()

createBlobContainer

protected abstract org.opensearch.common.blobstore.BlobContainer createBlobContainer(@Nullable java.lang.Integer maxRetries, @Nullable org.opensearch.common.unit.TimeValue readTimeout, @Nullable java.lang.Boolean disableChunkedEncoding, @Nullable org.opensearch.common.unit.ByteSizeValue bufferSize)

testReadNonexistentBlobThrowsNoSuchFileException

public void testReadNonexistentBlobThrowsNoSuchFileException()

testReadBlobWithRetries

public void testReadBlobWithRetries() throws java.lang.Exception

Throws:

java.lang.Exception

testReadRangeBlobWithRetries

public void testReadRangeBlobWithRetries() throws java.lang.Exception

Throws:

java.lang.Exception

testReadBlobWithReadTimeouts

public void testReadBlobWithReadTimeouts()

testReadBlobWithNoHttpResponse

public void testReadBlobWithNoHttpResponse()

testReadBlobWithPrematureConnectionClose

public void testReadBlobWithPrematureConnectionClose()

randomBlobContent

protected static byte[] randomBlobContent()

randomBlobContent

protected static byte[] randomBlobContent(int minSize)

getRange

protected static org.opensearch.common.collect.Tuple<java.lang.Long,java.lang.Long> getRange(com.sun.net.httpserver.HttpExchange exchange)

getRangeStart

protected static int getRangeStart(com.sun.net.httpserver.HttpExchange exchange)

getRangeEnd

protected static java.util.Optional<java.lang.Integer> getRangeEnd(com.sun.net.httpserver.HttpExchange exchange)

sendIncompleteContent

protected void sendIncompleteContent(com.sun.net.httpserver.HttpExchange exchange, byte[] bytes) throws java.io.IOException

Throws:

java.io.IOException