Package org.elasticsearch.transport

Class AbstractSimpleTransportTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.util.LuceneTestCase

org.elasticsearch.test.ESTestCase

org.elasticsearch.transport.AbstractSimpleTransportTestCase

public abstract class AbstractSimpleTransportTestCase
extends ESTestCase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractSimpleTransportTestCase.StringMessageRequest
static class	AbstractSimpleTransportTestCase.TestRequest
static class	AbstractSimpleTransportTestCase.Version0Request
static class	AbstractSimpleTransportTestCase.Version1Request

Nested classes/interfaces inherited from class org.elasticsearch.test.ESTestCase

ESTestCase.GeohashGenerator, ESTestCase.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 DiscoveryNode	nodeA
protected DiscoveryNode	nodeB
protected MockTransportService	serviceA
protected MockTransportService	serviceB
protected ThreadPool	threadPool
protected static Version	version0
protected static Version	version1

Fields inherited from class org.elasticsearch.test.ESTestCase

checkIndexFailed, deprecationLogger, failureAndSuccessEvents, logger

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
AbstractSimpleTransportTestCase()

Method Summary

Modifier and Type	Method	Description
void	assertNoPendingHandshakes(Transport transport)
void	assertNumHandshakes(long expected, Transport transport)
protected abstract MockTransportService	build(Settings settings, Version version, ClusterSettings clusterSettings, boolean doHandshake)
protected int	channelsPerNodeConnection()
protected abstract void	closeConnectionChannel(Transport transport, Transport.Connection connection)
void	setUp()
void	tearDown()
void	testAcceptedChannelCount()
void	testAdapterSendReceiveCallbacks()
void	testBlockingIncomingRequests()
void	testChannelCloseWhileConnecting()
void	testConcurrentDisconnectOnNonPublishedConnection()
void	testConcurrentSendRespondAndDisconnect()
void	testDisconnectListener()
void	testErrorMessage()
void	testHandlerIsInvokedOnConnectionClose()
void	testHandshakeUpdatesVersion()
void	testHandshakeWithIncompatVersion()
void	testHelloWorld()
void	testHelloWorldCompressed()
void	testHostOnMessages()
void	testLocalNodeConnection()
void	testMockFailToSendNoConnectRule()
void	testMockUnresponsiveRule()
void	testNotifyOnShutdown()
void	testProfileSettings()
void	testProfilesIncludesDefault()
void	testRegisterHandlerTwice()
void	testResponseHeadersArePreserved()
void	testSendRandomRequests()
void	testTcpHandshake()
void	testTcpHandshakeConnectionReset()
void	testTcpHandshakeTimeout()
void	testThreadContext()
void	testTimeoutPerConnection()
void	testTimeoutSendExceptionWithDelayedResponse()
void	testTimeoutSendExceptionWithNeverSendingBackResponse()
void	testTracerLog()
void	testTransportProfilesWithPortAndHost()
void	testTransportStats()
void	testTransportStatsWithException()
void	testVersionFrom0to0()
void	testVersionFrom0to1()
void	testVersionFrom1to0()
void	testVersionFrom1to1()
void	testVoidMessageCompressed()

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 org.elasticsearch.test.ESTestCase

after, afterIfFailed, afterIfSuccessful, assertAllIndicesRemovedAndDeletionCompleted, assertArrayEquals, assertBusy, assertBusy, assertEquals, assertEqualsWithErrorMessageFromXContent, assertPathHasBeenCleared, assertSettingDeprecationsAndWarnings, assertSettingDeprecationsAndWarnings, assertWarnings, awaitBusy, awaitBusy, before, between, buildNewFakeTransportAddress, checkStaticState, copyStreamable, copyWriteable, copyWriteable, createParser, createParser, createParser, createParser, createParser, createTestAnalysis, createTestAnalysis, createTestAnalysis, enableWarningsCheck, ensureAllSearchContextsReleased, ensureCheckIndexPassed, frequently, generateRandomStringArray, generateRandomStringArray, getBwcIndicesPath, getDataPath, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, iterations, maybeSet, mockScript, newNodeEnvironment, newNodeEnvironment, newTestIndicesModule, newTestScriptModule, randomAlphaOfLength, randomAlphaOfLengthBetween, randomBoolean, randomByte, randomByteArrayOfLength, randomDateTimeZone, randomDouble, randomDoubleBetween, randomFloat, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomGeohash, randomInt, randomInt, randomIntBetween, randomLong, randomLongBetween, randomNonNegativeLong, randomPositiveTimeValue, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomValueOtherThan, randomValueOtherThanMany, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, scaledRandomIntBetween, setContentType, setFileSystem, settings, setUseNio, shuffleMap, shuffleXContent, shuffleXContent, spinForAtLeastNMilliseconds, spinForAtLeastOneMillisecond, terminate, terminate, tmpPaths, toShuffledXContent, toShuffledXContent, writableRegistry, xContentRegistry

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

addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertFieldInfosEquals, assertFieldsEquals, assertFieldStatisticsEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, asSet, assumeFalse, assumeNoException, assumeTrue, assumeWorkingMMapOnWindows, atLeast, atLeast, closeAfterSuite, closeAfterTest, collate, createTempDir, createTempDir, createTempFile, createTempFile, dumpArray, dumpIterator, expectThrows, expectThrows, getBaseTempDirForTestClass, getDataInputStream, getOnlyLeafReader, getTestClass, getTestName, hasWorkingMMapOnWindows, isTestThread, localeForLanguageTag, maybeChangeLiveIndexWriterConfig, maybeWrapReader, newAlcoholicMergePolicy, newAlcoholicMergePolicy, newDirectory, newDirectory, newDirectory, newDirectory, newDirectory, newField, newField, newFSDirectory, newFSDirectory, newIndexWriterConfig, newIndexWriterConfig, newIndexWriterConfig, newIOContext, newIOContext, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newMaybeVirusCheckingDirectory, newMaybeVirusCheckingFSDirectory, newMergePolicy, newMergePolicy, newMockDirectory, newMockDirectory, newMockDirectory, newMockFSDirectory, newMockFSDirectory, 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 java.lang.Object

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

Field Detail

threadPool

protected ThreadPool threadPool

version0

protected static final Version version0

nodeA

protected volatile DiscoveryNode nodeA

serviceA

protected volatile MockTransportService serviceA

version1

protected static final Version version1

nodeB

protected volatile DiscoveryNode nodeB

serviceB

protected volatile MockTransportService serviceB

Constructor Detail

AbstractSimpleTransportTestCase

public AbstractSimpleTransportTestCase()

Method Detail

build

protected abstract MockTransportService build(Settings settings,
                                              Version version,
                                              ClusterSettings clusterSettings,
                                              boolean doHandshake)

channelsPerNodeConnection

protected int channelsPerNodeConnection()

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

assertNumHandshakes

public void assertNumHandshakes(long expected,
                                Transport transport)

assertNoPendingHandshakes

public void assertNoPendingHandshakes(Transport transport)

testHelloWorld

public void testHelloWorld()

testThreadContext

public void testThreadContext()
                       throws java.util.concurrent.ExecutionException,
                              java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

testLocalNodeConnection

public void testLocalNodeConnection()
                             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testAdapterSendReceiveCallbacks

public void testAdapterSendReceiveCallbacks()
                                     throws java.lang.Exception

Throws:

java.lang.Exception

testVoidMessageCompressed

public void testVoidMessageCompressed()

testHelloWorldCompressed

public void testHelloWorldCompressed()

testErrorMessage

public void testErrorMessage()

testDisconnectListener

public void testDisconnectListener()
                            throws java.lang.Exception

Throws:

java.lang.Exception

testConcurrentSendRespondAndDisconnect

public void testConcurrentSendRespondAndDisconnect()
                                            throws java.util.concurrent.BrokenBarrierException,
                                                   java.lang.InterruptedException

Throws:

java.util.concurrent.BrokenBarrierException

java.lang.InterruptedException

testNotifyOnShutdown

public void testNotifyOnShutdown()
                          throws java.lang.Exception

Throws:

java.lang.Exception

testTimeoutSendExceptionWithNeverSendingBackResponse

public void testTimeoutSendExceptionWithNeverSendingBackResponse()
                                                          throws java.lang.Exception

Throws:

java.lang.Exception

testTimeoutSendExceptionWithDelayedResponse

public void testTimeoutSendExceptionWithDelayedResponse()
                                                 throws java.lang.Exception

Throws:

java.lang.Exception

testTracerLog

public void testTracerLog()
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testVersionFrom0to1

public void testVersionFrom0to1()
                         throws java.lang.Exception

Throws:

java.lang.Exception

testVersionFrom1to0

public void testVersionFrom1to0()
                         throws java.lang.Exception

Throws:

java.lang.Exception

testVersionFrom1to1

public void testVersionFrom1to1()
                         throws java.lang.Exception

Throws:

java.lang.Exception

testVersionFrom0to0

public void testVersionFrom0to0()
                         throws java.lang.Exception

Throws:

java.lang.Exception

testMockFailToSendNoConnectRule

public void testMockFailToSendNoConnectRule()
                                     throws java.lang.Exception

Throws:

java.lang.Exception

testMockUnresponsiveRule

public void testMockUnresponsiveRule()
                              throws java.io.IOException

Throws:

java.io.IOException

testHostOnMessages

public void testHostOnMessages()
                        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testBlockingIncomingRequests

public void testBlockingIncomingRequests()
                                  throws java.lang.Exception

Throws:

java.lang.Exception

testSendRandomRequests

public void testSendRandomRequests()
                            throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testRegisterHandlerTwice

public void testRegisterHandlerTwice()

testTimeoutPerConnection

public void testTimeoutPerConnection()
                              throws java.io.IOException

Throws:

java.io.IOException

testHandshakeWithIncompatVersion

public void testHandshakeWithIncompatVersion()

testHandshakeUpdatesVersion

public void testHandshakeUpdatesVersion()
                                 throws java.io.IOException

Throws:

java.io.IOException

testTcpHandshake

public void testTcpHandshake()
                      throws java.io.IOException,
                             java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testTcpHandshakeTimeout

public void testTcpHandshakeTimeout()
                             throws java.io.IOException

Throws:

java.io.IOException

testTcpHandshakeConnectionReset

public void testTcpHandshakeConnectionReset()
                                     throws java.io.IOException,
                                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testResponseHeadersArePreserved

public void testResponseHeadersArePreserved()
                                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testHandlerIsInvokedOnConnectionClose

public void testHandlerIsInvokedOnConnectionClose()
                                           throws java.io.IOException,
                                                  java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testConcurrentDisconnectOnNonPublishedConnection

public void testConcurrentDisconnectOnNonPublishedConnection()
                                                      throws java.io.IOException,
                                                             java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testTransportStats

public void testTransportStats()
                        throws java.lang.Exception

Throws:

java.lang.Exception

testAcceptedChannelCount

public void testAcceptedChannelCount()
                              throws java.lang.Exception

Throws:

java.lang.Exception

testTransportStatsWithException

public void testTransportStatsWithException()
                                     throws java.lang.Exception

Throws:

java.lang.Exception

testTransportProfilesWithPortAndHost

public void testTransportProfilesWithPortAndHost()

testProfileSettings

public void testProfileSettings()

testProfilesIncludesDefault

public void testProfilesIncludesDefault()

testChannelCloseWhileConnecting

public void testChannelCloseWhileConnecting()
                                     throws java.io.IOException

Throws:

java.io.IOException

closeConnectionChannel

protected abstract void closeConnectionChannel(Transport transport,
                                               Transport.Connection connection)
                                        throws java.io.IOException

Throws:

java.io.IOException