Package org.elasticsearch.transport

Class MockTcpTransport

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.transport.TcpTransport

org.elasticsearch.transport.MockTcpTransport

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, LifecycleComponent, Releasable, Transport

public class MockTcpTransport
extends TcpTransport

This is a socket based blocking TcpTransport implementation that is used for tests that need real networking. This implementation is a test only implementation that implements the networking layer in the worst possible way since it blocks and uses a thread per request model.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	MockTcpTransport.MockChannel

Nested classes/interfaces inherited from class org.elasticsearch.transport.TcpTransport

TcpTransport.HttpOnTransportException, TcpTransport.NodeChannels, TcpTransport.ProfileSettings, TcpTransport.ScheduledPing

Nested classes/interfaces inherited from interface org.elasticsearch.transport.Transport

Transport.Connection

Field Summary

Fields

Modifier and Type	Field	Description
static ConnectionProfile	LIGHT_PROFILE	A pre-built light connection profile that shares a single connection across all types.

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Fields inherited from class org.elasticsearch.transport.TcpTransport

BIND_HOST, BIND_HOST_PROFILE, compress, CONNECTIONS_PER_NODE_BULK, CONNECTIONS_PER_NODE_PING, CONNECTIONS_PER_NODE_RECOVERY, CONNECTIONS_PER_NODE_REG, CONNECTIONS_PER_NODE_STATE, DEFAULT_FEATURES_SETTING, DEFAULT_PROFILE, defaultConnectionProfile, FEATURE_PREFIX, HOST, networkService, PING_DATA_SIZE, PING_SCHEDULE, PORT, PORT_PROFILE, profileSettings, PUBLISH_HOST, PUBLISH_HOST_PROFILE, PUBLISH_PORT, PUBLISH_PORT_PROFILE, scheduledPing, TCP_CONNECT_TIMEOUT, TCP_KEEP_ALIVE, TCP_KEEP_ALIVE_PROFILE, TCP_NO_DELAY, TCP_NO_DELAY_PROFILE, TCP_RECEIVE_BUFFER_SIZE, TCP_RECEIVE_BUFFER_SIZE_PROFILE, TCP_REUSE_ADDRESS, TCP_REUSE_ADDRESS_PROFILE, TCP_SEND_BUFFER_SIZE, TCP_SEND_BUFFER_SIZE_PROFILE, threadPool, TRANSPORT_CLIENT_BOSS_THREAD_NAME_PREFIX, TRANSPORT_SERVER_WORKER_THREAD_NAME_PREFIX

Fields inherited from interface org.elasticsearch.transport.Transport

TRANSPORT_TCP_COMPRESS

Constructor Summary

Constructors

Constructor	Description
MockTcpTransport(Settings settings, ThreadPool threadPool, BigArrays bigArrays, CircuitBreakerService circuitBreakerService, NamedWriteableRegistry namedWriteableRegistry, NetworkService networkService)
MockTcpTransport(Settings settings, ThreadPool threadPool, BigArrays bigArrays, CircuitBreakerService circuitBreakerService, NamedWriteableRegistry namedWriteableRegistry, NetworkService networkService, Version mockVersion)

Method Summary

Modifier and Type	Method	Description
protected MockTcpTransport.MockChannel	bind(java.lang.String name, java.net.InetSocketAddress address)
protected void	doStart()
protected Version	getCurrentVersion()
protected MockTcpTransport.MockChannel	initiateChannel(DiscoveryNode node, TimeValue connectTimeout, ActionListener<java.lang.Void> connectListener)
protected ConnectionProfile	resolveConnectionProfile(ConnectionProfile connectionProfile)
protected void	stopInternal()

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.lease.Releasable

close

Methods inherited from class org.elasticsearch.transport.TcpTransport

addressesFromString, bindServer, bindToPort, boundAddress, canCompress, connectToNode, disconnectFromNode, doClose, doStop, ensureOpen, executeHandshake, getConnection, getInFlightRequestBreaker, getLocalAddresses, getProfileSettings, getStats, handleRequest, messageReceived, newRequestId, nodeConnected, onException, openConnection, profileBoundAddresses, resolvePublishPort, sendErrorResponse, sendResponse, serverAcceptedChannel, setTransportService, validateMessageHeader, validateRequest

Field Detail

LIGHT_PROFILE

public static final ConnectionProfile LIGHT_PROFILE

A pre-built light connection profile that shares a single connection across all types.

Constructor Detail

MockTcpTransport

public MockTcpTransport(Settings settings,
                        ThreadPool threadPool,
                        BigArrays bigArrays,
                        CircuitBreakerService circuitBreakerService,
                        NamedWriteableRegistry namedWriteableRegistry,
                        NetworkService networkService)

MockTcpTransport

public MockTcpTransport(Settings settings,
                        ThreadPool threadPool,
                        BigArrays bigArrays,
                        CircuitBreakerService circuitBreakerService,
                        NamedWriteableRegistry namedWriteableRegistry,
                        NetworkService networkService,
                        Version mockVersion)

Method Detail

bind

protected MockTcpTransport.MockChannel bind(java.lang.String name,
                                            java.net.InetSocketAddress address)
                                     throws java.io.IOException

Specified by:

bind in class TcpTransport

Throws:

java.io.IOException

initiateChannel

protected MockTcpTransport.MockChannel initiateChannel(DiscoveryNode node,
                                                       TimeValue connectTimeout,
                                                       ActionListener<java.lang.Void> connectListener)
                                                throws java.io.IOException

Specified by:

initiateChannel in class TcpTransport

Throws:

java.io.IOException

resolveConnectionProfile

protected ConnectionProfile resolveConnectionProfile(ConnectionProfile connectionProfile)

Overrides:

resolveConnectionProfile in class TcpTransport

doStart

protected void doStart()

Overrides:

doStart in class TcpTransport

stopInternal

protected void stopInternal()

Overrides:

stopInternal in class TcpTransport

getCurrentVersion

protected Version getCurrentVersion()

Overrides:

getCurrentVersion in class TcpTransport