Package org.elasticsearch.transport
Class AbstractSimpleTransportTestCase
java.lang.Object
org.junit.Assert
org.apache.lucene.tests.util.LuceneTestCase
org.elasticsearch.test.ESTestCase
org.elasticsearch.transport.AbstractSimpleTransportTestCase
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic classstatic classstatic classNested classes/interfaces inherited from class org.elasticsearch.test.ESTestCase
ESTestCase.DeprecationWarning, ESTestCase.GeohashGenerator, ESTestCase.TestAnalysis, ESTestCase.WithoutSecurityManagerNested classes/interfaces inherited from class org.apache.lucene.tests.util.LuceneTestCase
org.apache.lucene.tests.util.LuceneTestCase.AwaitsFix, org.apache.lucene.tests.util.LuceneTestCase.Concurrency, org.apache.lucene.tests.util.LuceneTestCase.Monster, org.apache.lucene.tests.util.LuceneTestCase.Nightly, org.apache.lucene.tests.util.LuceneTestCase.SuppressCodecs, org.apache.lucene.tests.util.LuceneTestCase.SuppressFileSystems, org.apache.lucene.tests.util.LuceneTestCase.SuppressFsync, org.apache.lucene.tests.util.LuceneTestCase.SuppressReproduceLine, org.apache.lucene.tests.util.LuceneTestCase.SuppressSysoutChecks, org.apache.lucene.tests.util.LuceneTestCase.SuppressTempFileChecks, org.apache.lucene.tests.util.LuceneTestCase.ThrowingConsumer<T>, org.apache.lucene.tests.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.tests.util.LuceneTestCase.Weekly -
Field Summary
FieldsModifier and TypeFieldDescriptionprotected ClusterSettingsprotected static final NetworkServiceprotected DiscoveryNodeprotected DiscoveryNodeprotected MockTransportServiceprotected MockTransportServiceprotected ThreadPoolprotected static final TransportVersionprotected static final TransportVersionprotected static final VersionInformationprotected static final VersionInformationFields inherited from class org.elasticsearch.test.ESTestCase
checkIndexFailures, DEFAULT_TEST_WORKER_ID, failureAndSuccessEvents, FIPS_SYSPROP, JAVA_TIMEZONE_IDS, JAVA_ZONE_IDS, logger, MIN_PRIVATE_PORT, SAFE_AWAIT_TIMEOUT, TEST_REQUEST_TIMEOUT, TEST_WORKER_SYS_PROPERTY, TEST_WORKER_VM_ID, UNSIGNED_LONG_MAXFields inherited from class org.apache.lucene.tests.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_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, SYSPROP_WEEKLY, TEST_ASSERTS_ENABLED, TEST_AWAITSFIX, TEST_CODEC, TEST_DIRECTORY, TEST_DOCVALUESFORMAT, TEST_LINE_DOCS_FILE, TEST_MONSTER, TEST_NIGHTLY, TEST_POSTINGSFORMAT, TEST_THROTTLING, TEST_WEEKLY, VERBOSE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidassertNoPendingHandshakes(Transport transport) static voidassertNumHandshakes(long expected, Transport transport) protected abstract Transportbuild(Settings settings, TransportVersion version, ClusterSettings clusterSettings, boolean doHandshake) protected MockTransportServicebuildService(String name, VersionInformation version, TransportVersion transportVersion, ClusterSettings clusterSettings, Settings settings) protected MockTransportServicebuildService(String name, VersionInformation version, TransportVersion transportVersion, ClusterSettings clusterSettings, Settings settings, boolean acceptRequests, boolean doHandshake) protected MockTransportServicebuildService(String name, VersionInformation version, TransportVersion transportVersion, Settings settings) protected intstatic voidconnectToNode(TransportService service, DiscoveryNode node) Connect to the specified node with the default connection profilestatic voidconnectToNode(TransportService service, DiscoveryNode node, ConnectionProfile connectionProfile) Connect to the specified node with the given connection profilestatic ConnectTransportExceptionconnectToNodeExpectFailure(TransportService service, DiscoveryNode node, ConnectionProfile connectionProfile) Attempt to connect to the specified node, but assert that this fails and return the resulting exception.protected Set<TcpChannel> getAcceptedChannels(TcpTransport transport) protected InetSocketAddressstatic Transport.ConnectionopenConnection(TransportService service, DiscoveryNode node, ConnectionProfile connectionProfile) Establishes and returns a new connection to the given node from the givenTransportService.static ConnectTransportExceptionopenConnectionExpectFailure(TransportService service, DiscoveryNode node, ConnectionProfile connectionProfile) Attempt to connect to the specified node, but assert that this fails and return the resulting exception.voidsetUp()static <T extends TransportResponse>
Future<T> submitRequest(TransportService transportService, DiscoveryNode node, String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler) static <T extends TransportResponse>
Future<T> submitRequest(TransportService transportService, DiscoveryNode node, String action, TransportRequest request, TransportResponseHandler<T> handler) voidtearDown()voidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidMethods inherited from class org.elasticsearch.test.ESTestCase
after, afterIfFailed, afterIfSuccessful, allBreakersMemoryReleased, asInstanceOf, assertArrayEquals, assertBusy, assertBusy, assertCriticalWarnings, assertEquals, assertLeakDetected, assertSettingDeprecationsAndWarnings, assertThat, assertThat, assertWarnings, assertWarnings, before, between, buildEnvSettings, buildNewFakeTransportAddress, captureLoggingLevel, checkStaticState, compatibleMediaType, copyInstance, copyNamedWriteable, copyNamedWriteable, copyWriteable, copyWriteable, createDefaultIndexAnalyzers, createParser, createParser, createParser, createParser, createParser, createParser, createParserWithCompatibilityFor, createTestAnalysis, createTestAnalysis, createTestAnalysis, createThreadPool, enableBigArraysReleasedCheck, enableWarningsCheck, ensureAllContextsReleased, ensureAllSearchContextsReleased, ensureCheckIndexPassed, ensureNoWarnings, ensureSupportedLocale, expectThrows, expectThrows, fail, fail, filteredWarnings, flushThreadPoolExecutor, frequently, generateRandomStringArray, generateRandomStringArray, getDataPath, getPortRange, getResourceDataPath, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, getWorkerBasePort, indexSettings, indexSettings, inFipsJvm, initTestSeed, isTurkishLocale, iterations, maybeRestoreClassSecurityManager, maybeSet, maybeStashClassSecurityManager, mockScript, newEnvironment, newEnvironment, newLimitedBreaker, newNodeEnvironment, newNodeEnvironment, newSearcher, newSearcher, newSearcher, newSearcher, parserConfig, randomAlphanumericOfLength, randomAlphaOfLength, randomAlphaOfLengthBetween, randomAlphaOfLengthOrNull, randomArray, randomArray, randomBigInteger, randomBoolean, randomByte, randomByteArrayOfLength, randomByteBetween, randomBytesBetween, randomByteSizeValue, randomBytesReference, randomCompatibleMediaType, randomDateFormatterPattern, randomDouble, randomDoubleBetween, randomDoubles, randomDoubles, randomExecutor, randomFloat, randomFloatBetween, randomFloatOrNull, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomGeohash, randomIdentifier, randomInstantBetween, randomInt, randomInt, randomIntBetween, randomIntOrNull, randomInts, randomInts, randomIp, randomList, randomList, randomLong, randomLongBetween, randomLongOrNull, randomLongs, randomLongs, randomMap, randomMillisUpToYear9999, randomNegativeInt, randomNegativeLong, randomNonEmptySubsetOf, randomNonNegativeByte, randomNonNegativeInt, randomNonNegativeIntOrNull, randomNonNegativeLong, randomNonNegativeLongOrNull, randomOptionalBoolean, randomPositiveTimeValue, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomSecretKey, randomSecureStringOfLength, randomSet, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomUnsignedLongBetween, randomUUID, randomValueOtherThan, randomValueOtherThanMany, randomVendorType, randomZone, removeHeaderWarningAppender, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, restoreLoggingLevel, runInParallel, safeAcquire, safeAcquire, safeAwait, safeAwait, safeAwait, safeAwait, safeAwait, safeAwait, safeAwaitAndUnwrapFailure, safeAwaitFailure, safeAwaitFailure, safeAwaitFailure, safeAwaitFailure, safeExecute, safeGet, safeGet, safeGet, safeSleep, safeSleep, scaledRandomIntBetween, secureRandom, secureRandom, secureRandomFips, secureRandomFips, secureRandomNonFips, secureRandomNonFips, setContentType, setFileSystem, setHeaderWarningAppender, settings, shuffledList, shuffleMap, shuffleXContent, shuffleXContent, skipTestWaitingForLuceneFix, spinForAtLeastNMilliseconds, spinForAtLeastOneMillisecond, startInParallel, terminate, terminate, tmpPaths, toShuffledXContent, toShuffledXContent, waitUntil, waitUntil, writableRegistry, xContentRegistryMethods inherited from class org.apache.lucene.tests.util.LuceneTestCase
addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertDoubleUlpEquals, assertFieldInfosEquals, assertFloatUlpEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, asSet, assumeFalse, assumeNoException, assumeTrue, atLeast, atLeast, callStackContains, callStackContains, callStackContainsAnyOf, closeAfterSuite, closeAfterTest, collate, createTempDir, createTempDir, createTempFile, createTempFile, dumpArray, dumpIterator, ensureSaneIWCOnNightly, expectThrows, expectThrows, expectThrows, expectThrowsAnyOf, expectThrowsAnyOf, getDataInputStream, getJvmForkArguments, getOnlyLeafReader, getTestClass, getTestName, 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, newSnapshotIndexWriterConfig, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, randomVectorFormat, rarely, rarely, replaceMaxFailureRule, resetDefaultQueryCache, restoreCPUCoreCount, restoreIndexWriterMaxDocs, runWithRestrictedPermissions, setIndexWriterMaxDocs, setupCPUCoreCount, setUpExecutorService, shutdownExecutorService, slowFileExists, usually, usually, wrapReaderMethods 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, assertThrows, assertThrows, assertTrue, assertTrue, fail, fail
-
Field Details
-
IGNORE_DESERIALIZATION_ERRORS_SETTING
-
threadPool
-
version0
-
transportVersion0
-
nodeA
-
serviceA
-
clusterSettingsA
-
version1
-
transportVersion1
-
nodeB
-
serviceB
-
networkService
-
-
Constructor Details
-
AbstractSimpleTransportTestCase
public AbstractSimpleTransportTestCase()
-
-
Method Details
-
build
protected abstract Transport build(Settings settings, TransportVersion version, ClusterSettings clusterSettings, boolean doHandshake) -
channelsPerNodeConnection
protected int channelsPerNodeConnection() -
getSupportedSettings
-
setUp
- Overrides:
setUpin classorg.apache.lucene.tests.util.LuceneTestCase- Throws:
Exception
-
buildService
protected MockTransportService buildService(String name, VersionInformation version, TransportVersion transportVersion, @Nullable ClusterSettings clusterSettings, Settings settings, boolean acceptRequests, boolean doHandshake) -
buildService
protected MockTransportService buildService(String name, VersionInformation version, TransportVersion transportVersion, Settings settings) -
buildService
protected MockTransportService buildService(String name, VersionInformation version, TransportVersion transportVersion, ClusterSettings clusterSettings, Settings settings) -
tearDown
- Overrides:
tearDownin classorg.apache.lucene.tests.util.LuceneTestCase- Throws:
Exception
-
assertNumHandshakes
-
assertNoPendingHandshakes
-
testHelloWorld
public void testHelloWorld() -
testThreadContext
-
testLocalNodeConnection
- Throws:
InterruptedException
-
testMessageListeners
- Throws:
Exception
-
testVoidMessageCompressed
- Throws:
Exception
-
testHelloWorldCompressed
- Throws:
Exception
-
testIndexingDataCompression
- Throws:
Exception
-
testErrorMessage
- Throws:
InterruptedException
-
testExceptionOnConnect
public void testExceptionOnConnect() -
testDisconnectListener
- Throws:
Exception
-
testConcurrentSendRespondAndDisconnect
public void testConcurrentSendRespondAndDisconnect() throws BrokenBarrierException, InterruptedException -
testNotifyOnShutdown
- Throws:
Exception
-
testTimeoutSendExceptionWithNeverSendingBackResponse
- Throws:
Exception
-
testTimeoutSendExceptionWithDelayedResponse
- Throws:
Exception
-
testTracerLog
- Throws:
Exception
-
testVersionFrom0to1
- Throws:
Exception
-
testVersionFrom1to0
- Throws:
Exception
-
testVersionFrom1to1
- Throws:
Exception
-
testVersionFrom0to0
- Throws:
Exception
-
testMockFailToSendNoConnectRule
- Throws:
Exception
-
testMockUnresponsiveRule
- Throws:
InterruptedException
-
testHostOnMessages
- Throws:
InterruptedException
-
testRejectEarlyIncomingRequests
- Throws:
Exception
-
testSendRandomRequests
- Throws:
InterruptedException
-
testRegisterHandlerTwice
public void testRegisterHandlerTwice() -
testHandshakeWithIncompatVersion
public void testHandshakeWithIncompatVersion() -
testHandshakeUpdatesVersion
- Throws:
IOException
-
testKeepAlivePings
- Throws:
Exception
-
testTcpHandshake
public void testTcpHandshake() -
testTcpHandshakeTimeout
- Throws:
IOException
-
testTcpHandshakeConnectionReset
- Throws:
IOExceptionInterruptedException
-
testResponseHeadersArePreserved
- Throws:
InterruptedException
-
testHandlerIsInvokedOnConnectionClose
- Throws:
IOExceptionInterruptedException
-
testConcurrentDisconnectOnNonPublishedConnection
public void testConcurrentDisconnectOnNonPublishedConnection() throws IOException, InterruptedException- Throws:
IOExceptionInterruptedException
-
testTransportStats
- Throws:
Exception
-
testAcceptedChannelCount
- Throws:
Exception
-
testTransportStatsWithException
- Throws:
Exception
-
testTransportProfilesWithPortAndHost
public void testTransportProfilesWithPortAndHost() -
testProfileSettings
public void testProfileSettings() -
testProfilesIncludesDefault
public void testProfilesIncludesDefault() -
testChannelCloseWhileConnecting
public void testChannelCloseWhileConnecting() -
testFailToSendTransportException
- Throws:
InterruptedException
-
testFailToSendIllegalStateException
- Throws:
InterruptedException
-
testChannelToString
public void testChannelToString() -
testActionStats
- Throws:
Exception
-
testWatchdogLogging
public void testWatchdogLogging() -
getLocalEphemeral
- Throws:
UnknownHostException
-
getAcceptedChannels
-
connectToNode
public static void connectToNode(TransportService service, DiscoveryNode node) throws ConnectTransportException Connect to the specified node with the default connection profile- Parameters:
service- service to connect fromnode- the node to connect to- Throws:
ConnectTransportException
-
connectToNode
public static void connectToNode(TransportService service, DiscoveryNode node, ConnectionProfile connectionProfile) Connect to the specified node with the given connection profile- Parameters:
service- service to connect fromnode- the node to connect toconnectionProfile- the connection profile to use when connecting to this node
-
connectToNodeExpectFailure
public static ConnectTransportException connectToNodeExpectFailure(TransportService service, DiscoveryNode node, ConnectionProfile connectionProfile) Attempt to connect to the specified node, but assert that this fails and return the resulting exception. -
openConnection
public static Transport.Connection openConnection(TransportService service, DiscoveryNode node, ConnectionProfile connectionProfile) Establishes and returns a new connection to the given node from the givenTransportService.- Parameters:
service- service to connect fromnode- the node to connect toconnectionProfile- the connection profile to use
-
openConnectionExpectFailure
public static ConnectTransportException openConnectionExpectFailure(TransportService service, DiscoveryNode node, ConnectionProfile connectionProfile) Attempt to connect to the specified node, but assert that this fails and return the resulting exception. -
submitRequest
public static <T extends TransportResponse> Future<T> submitRequest(TransportService transportService, DiscoveryNode node, String action, TransportRequest request, TransportResponseHandler<T> handler) throws TransportException - Throws:
TransportException
-
submitRequest
public static <T extends TransportResponse> Future<T> submitRequest(TransportService transportService, DiscoveryNode node, String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler) throws TransportException - Throws:
TransportException
-