Vert.x 4.5.13 · io.vertx.core.http.impl.Http1xServerConnection

This class is optimised for performance when used on the same event loop. However it can be used safely from other threads.

The internal state is protected using the synchronized keyword. If always used on the same event loop, then we benefit from biased locking which makes the overhead of synchronized near zero.

The connection maintains two fields for tracking requests:

requestInProgress is the request currently receiving messages, the field is set when a HttpRequest message is received and unset when LastHttpContent is received. Intermediate HttpContent messages are processed by the request.
responseInProgress is the request for which the response is currently being sent. This field is set when it is null and the requestInProgress field if set, or when there is a pipelined request waiting its turn for writing the response

When a request is received, it is also the current response if there is no response in progress, otherwise it is queued and will become the response in progress when the current response in progress ends.

Field Summary

Modifier and Type	Field and Description
private boolean	channelPaused
pack-priv final boolean	handle100ContinueAutomatically
private Handler<HttpServerRequest>	invalidRequestHandler
private boolean	keepAlive
private static final Logger	log Hides io.vertx.core.net.impl.ConnectionBase.log.
pack-priv final HttpServerMetrics<R, W, S>	metrics
pack-priv final HttpServerOptions	options
private boolean	requestFailed
private Handler<HttpServerRequest>	requestHandler
private Http1xServerRequest	requestInProgress
private Http1xServerRequest	responseInProgress
private final String	serverOrigin
private final SslChannelProvider	sslChannelProvider
private final Supplier<ContextInternal>	streamContextSupplier
private final TracingPolicy	tracingPolicy
private boolean	writable

Inherited from io.vertx.core.http.impl.Http1xConnectionBase:: webSocket

Constructor Summary

Access	Constructor and Description
public	Http1xServerConnection(Supplier<ContextInternal> streamContextSupplier, SslChannelProvider sslChannelProvider, HttpServerOptions options, ChannelHandlerContext chctx, ContextInternal context, String serverOrigin, HttpServerMetrics<R, W, S> metrics)

Method Summary

Modifier and Type	Method and Description
private WebSocketServerHandshaker	createHandshaker(Http1xServerRequest request)
pack-priv void	createWebSocket(Http1xServerRequest request, PromiseInternal<ServerWebSocket> promise)
public void	doPause() Overrides io.vertx.core.net.impl.ConnectionBase.doPause.
public void	doResume() Overrides io.vertx.core.net.impl.ConnectionBase.doResume.
private void	enqueueRequest(Http1xServerRequest req)
private void	flushAndClose()
pack-priv String	getServerOrigin()
protected void	handleClosed() Overrides io.vertx.core.net.impl.ConnectionBase.handleClosed.
private void	handleError(HttpObject obj)
public void	handleException(Throwable t) Overrides io.vertx.core.http.impl.Http1xConnectionBase.handleException.
public void	handleInterestedOpsChanged() Implements abstract io.vertx.core.net.impl.ConnectionBase.handleInterestedOpsChanged.
public void	handleMessage(Object msg) Overrides io.vertx.core.net.impl.ConnectionBase.handleMessage.
private void	handleNext(Http1xServerRequest next)
private void	handleOther(Object msg)
public HttpServerConnection	handler(Handler<HttpServerRequest> handler) Implements io.vertx.core.http.impl.HttpServerConnection.handler.
public HttpServerConnection	invalidRequestHandler(Handler<HttpServerRequest> handler) Implements io.vertx.core.http.impl.HttpServerConnection.invalidRequestHandler.
public HttpServerMetrics<R, W, S>	metrics() Implements abstract io.vertx.core.net.impl.ConnectionBase.metrics.
public void	netSocket(Handler<AsyncResult<NetSocket>> handler)
public Future<NetSocket>	netSocket()
pack-priv void	netSocket(Promise<NetSocket> promise)
private void	onContent(Object msg)
private void	onEnd()
private void	reportResponseComplete()
pack-priv void	responseComplete()
protected boolean	supportsFileRegion() Overrides io.vertx.core.net.impl.ConnectionBase.supportsFileRegion.
pack-priv TracingPolicy	tracingPolicy()
pack-priv Vertx	vertx()
pack-priv void	write100Continue()
pack-priv void	write103EarlyHints(HttpHeaders headers, PromiseInternal<Void> promise)

Inherited from io.vertx.core.http.impl.Http1xConnectionBase:: close closeHandler exceptionHandler goAway goAwayHandler handleWsFrame ping ping pingHandler remoteSettings remoteSettingsHandler settings shutdown shutdownHandler sizeof updateSettings updateSettings

Field Detail

channelPaused	back to summary
private boolean channelPaused

handle100ContinueAutomatically	back to summary
pack-priv final boolean handle100ContinueAutomatically

invalidRequestHandler	back to summary
private Handler<HttpServerRequest> invalidRequestHandler

keepAlive	back to summary
private boolean keepAlive

log	back to summary
private static final Logger log Hides io.vertx.core.net.impl.ConnectionBase.log.

metrics	back to summary
pack-priv final HttpServerMetrics<R, W, S> metrics

options	back to summary
pack-priv final HttpServerOptions options

requestFailed	back to summary
private boolean requestFailed

requestHandler	back to summary
private Handler<HttpServerRequest> requestHandler

requestInProgress	back to summary
private Http1xServerRequest requestInProgress

responseInProgress	back to summary
private Http1xServerRequest responseInProgress

serverOrigin	back to summary
private final String serverOrigin

sslChannelProvider	back to summary
private final SslChannelProvider sslChannelProvider

streamContextSupplier	back to summary
private final Supplier<ContextInternal> streamContextSupplier

tracingPolicy	back to summary
private final TracingPolicy tracingPolicy

writable	back to summary
private boolean writable

Constructor Detail

Http1xServerConnection	back to summary
public Http1xServerConnection(Supplier<ContextInternal> streamContextSupplier, SslChannelProvider sslChannelProvider, HttpServerOptions options, ChannelHandlerContext chctx, ContextInternal context, String serverOrigin, HttpServerMetrics<R, W, S> metrics)

Method Detail

createHandshaker	back to summary
private WebSocketServerHandshaker createHandshaker(Http1xServerRequest request) throws WebSocketHandshakeException

createWebSocket	back to summary
pack-priv void createWebSocket(Http1xServerRequest request, PromiseInternal<ServerWebSocket> promise)

doPause	back to summary
public void doPause() Overrides io.vertx.core.net.impl.ConnectionBase.doPause. Annotations @Override

doPause

back to summary

public void doPause()

Overrides io.vertx.core.net.impl.ConnectionBase.doPause.

Annotations

@Override

doResume	back to summary
public void doResume() Overrides io.vertx.core.net.impl.ConnectionBase.doResume. Annotations @Override

doResume

back to summary

public void doResume()

Overrides io.vertx.core.net.impl.ConnectionBase.doResume.

Annotations

@Override

enqueueRequest	back to summary
private void enqueueRequest(Http1xServerRequest req)

flushAndClose	back to summary
private void flushAndClose()

getServerOrigin	back to summary
pack-priv String getServerOrigin()

handleClosed	back to summary
protected void handleClosed() Overrides io.vertx.core.net.impl.ConnectionBase.handleClosed.

handleError	back to summary
private void handleError(HttpObject obj)

handleException	back to summary
public void handleException(Throwable t) Overrides io.vertx.core.http.impl.Http1xConnectionBase.handleException. Annotations @Override

handleException

back to summary

public void handleException(Throwable t)

Overrides io.vertx.core.http.impl.Http1xConnectionBase.handleException.

Annotations

@Override

handleInterestedOpsChanged	back to summary
public void handleInterestedOpsChanged() Implements abstract io.vertx.core.net.impl.ConnectionBase.handleInterestedOpsChanged. Annotations @Override

handleInterestedOpsChanged

back to summary

public void handleInterestedOpsChanged()

Implements abstract io.vertx.core.net.impl.ConnectionBase.handleInterestedOpsChanged.

Annotations

@Override

handleMessage	back to summary
public void handleMessage(Object msg) Overrides io.vertx.core.net.impl.ConnectionBase.handleMessage.

handleNext	back to summary
private void handleNext(Http1xServerRequest next)

handleOther	back to summary
private void handleOther(Object msg)

handler	back to summary
public HttpServerConnection handler(Handler<HttpServerRequest> handler) Implements io.vertx.core.http.impl.HttpServerConnection.handler. Annotations @Override

handler

back to summary

public HttpServerConnection handler(Handler<HttpServerRequest> handler)

Implements io.vertx.core.http.impl.HttpServerConnection.handler.

Annotations

@Override

invalidRequestHandler	back to summary
public HttpServerConnection invalidRequestHandler(Handler<HttpServerRequest> handler) Implements io.vertx.core.http.impl.HttpServerConnection.invalidRequestHandler. Annotations @Override

invalidRequestHandler

back to summary

public HttpServerConnection invalidRequestHandler(Handler<HttpServerRequest> handler)

Implements io.vertx.core.http.impl.HttpServerConnection.invalidRequestHandler.

Annotations

@Override

metrics	back to summary
public HttpServerMetrics<R, W, S> metrics() Implements abstract io.vertx.core.net.impl.ConnectionBase.metrics. Annotations @Override

metrics

back to summary

public HttpServerMetrics<R, W, S> metrics()

Implements abstract io.vertx.core.net.impl.ConnectionBase.metrics.

Annotations

@Override

netSocket	back to summary
public void netSocket(Handler<AsyncResult<NetSocket>> handler)

netSocket	back to summary
public Future<NetSocket> netSocket()

netSocket	back to summary
pack-priv void netSocket(Promise<NetSocket> promise)

onContent	back to summary
private void onContent(Object msg)

onEnd	back to summary
private void onEnd()

reportResponseComplete	back to summary
private void reportResponseComplete()

responseComplete	back to summary
pack-priv void responseComplete()

supportsFileRegion	back to summary
protected boolean supportsFileRegion() Overrides io.vertx.core.net.impl.ConnectionBase.supportsFileRegion. Annotations @Override

supportsFileRegion

back to summary

protected boolean supportsFileRegion()

Overrides io.vertx.core.net.impl.ConnectionBase.supportsFileRegion.

Annotations

@Override

tracingPolicy	back to summary
pack-priv TracingPolicy tracingPolicy()

vertx	back to summary
pack-priv Vertx vertx()

write100Continue	back to summary
pack-priv void write100Continue()

write103EarlyHints	back to summary
pack-priv void write103EarlyHints(HttpHeaders headers, PromiseInternal<Void> promise)

public Class Http1xServerConnection

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail