Package org.elasticsearch.http

Class AbstractHttpServerTransport

java.lang.Object

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.http.AbstractHttpServerTransport

All Implemented Interfaces:

Closeable, AutoCloseable, LifecycleComponent, org.elasticsearch.core.Releasable, HttpServerTransport, ReportingService<HttpInfo>

public abstract class AbstractHttpServerTransport
extends AbstractLifecycleComponent
implements HttpServerTransport

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.http.HttpServerTransport

HttpServerTransport.Dispatcher

Nested classes/interfaces inherited from interface org.elasticsearch.node.ReportingService

ReportingService.Info

Field Summary

Fields

Modifier and Type	Field	Description
protected BigArrays	bigArrays
protected CorsHandler	corsHandler
protected HttpServerTransport.Dispatcher	dispatcher
HttpHandlingSettings	handlingSettings
protected long	lastClientStatsPruneTime
protected ByteSizeValue	maxContentLength
protected NetworkService	networkService
protected PortsRange	port
protected Settings	settings
protected ThreadPool	threadPool

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

lifecycle

Fields inherited from interface org.elasticsearch.http.HttpServerTransport

HTTP_SERVER_WORKER_THREAD_NAME_PREFIX

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractHttpServerTransport(Settings settings, NetworkService networkService, BigArrays bigArrays, ThreadPool threadPool, org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry, HttpServerTransport.Dispatcher dispatcher, ClusterSettings clusterSettings)

Method Summary

Modifier and Type	Method	Description
protected abstract HttpServerChannel	bind(InetSocketAddress hostAddress)
protected void	bindServer()
BoundTransportAddress	boundAddress()
protected void	doClose()
protected void	doStop()
void	incomingRequest(HttpRequest httpRequest, HttpChannel httpChannel)	This method handles an incoming http request.
HttpInfo	info()
void	onException(HttpChannel channel, Exception e)
protected void	onServerException(HttpServerChannel channel, Exception e)
protected void	serverAcceptedChannel(HttpChannel httpChannel)
HttpStats	stats()
protected abstract void	stopInternal()	Called to tear down internal resources

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

addLifecycleListener, close, doStart, 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.component.LifecycleComponent

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from interface org.elasticsearch.core.Releasable

close

Field Details

settings

protected final Settings settings

handlingSettings

public final HttpHandlingSettings handlingSettings

networkService

protected final NetworkService networkService

bigArrays

protected final BigArrays bigArrays

threadPool

protected final ThreadPool threadPool

dispatcher

protected final HttpServerTransport.Dispatcher dispatcher

corsHandler

protected final CorsHandler corsHandler

port

protected final PortsRange port

maxContentLength

protected final ByteSizeValue maxContentLength

lastClientStatsPruneTime

protected volatile long lastClientStatsPruneTime

Constructor Details

AbstractHttpServerTransport

protected AbstractHttpServerTransport(Settings settings,
 NetworkService networkService,
 BigArrays bigArrays,
 ThreadPool threadPool,
 org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry,
 HttpServerTransport.Dispatcher dispatcher,
 ClusterSettings clusterSettings)

Method Details

boundAddress

public BoundTransportAddress boundAddress()

Specified by:

boundAddress in interface HttpServerTransport

info

public HttpInfo info()

Specified by:

info in interface HttpServerTransport

Specified by:

info in interface ReportingService<HttpInfo>

stats

public HttpStats stats()

Specified by:

stats in interface HttpServerTransport

bindServer

protected void bindServer()

bind

protected abstract HttpServerChannel bind(InetSocketAddress hostAddress)
                                   throws Exception

Throws:

Exception

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()

Specified by:

doClose in class AbstractLifecycleComponent

stopInternal

protected abstract void stopInternal()

Called to tear down internal resources

onException

public void onException(HttpChannel channel,
 Exception e)

onServerException

protected void onServerException(HttpServerChannel channel,
 Exception e)

serverAcceptedChannel

protected void serverAcceptedChannel(HttpChannel httpChannel)

incomingRequest

public void incomingRequest(HttpRequest httpRequest,
 HttpChannel httpChannel)

This method handles an incoming http request.

Parameters:

httpRequest - that is incoming

httpChannel - that received the http request