Core :: Server 12.0.6 · org.eclipse.jetty.server.internal.HttpConnection

Modifier and Type	Class and Description
private class	HttpConnection.DemandContentCallback
protected class	HttpConnection.HttpStreamOverHTTP1
protected class	HttpConnection.RequestHandler
private class	HttpConnection.SendCallback
private class	HttpConnection.TunnelSupportOverHTTP1

Modifier and Type	Field and Description
private static final AtomicLong	__connectionIdGenerator
private static final ThreadLocal<HttpConnection>	__currentConnection
private final Attributes.Lazy	_attributes
private final ByteBufferPool	_bufferPool
private final HttpConnection.DemandContentCallback	_demandContentCallback
private final HttpGenerator	_generator
private final AtomicBoolean	_handling
private final HttpFields.Mutable	_headerBuilder
private final HttpChannel	_httpChannel
private final long	_id
private Runnable	_onRequest
private final HttpParser	_parser
private final HttpConnection.RequestHandler	_requestHandler
private long	_requests
private volatile RetainableByteBuffer	_retainableByteBuffer
private final HttpConnection.SendCallback	_sendCallback
private final AtomicReference<HttpConnection.HttpStreamOverHTTP1>	_stream
private final AtomicLong	_streamIdGenerator
private HttpFields.Mutable	_trailers
private final TunnelSupport	_tunnelSupport
private boolean	_useInputDirectByteBuffers
private boolean	_useOutputDirectByteBuffers
private final LongAdder	bytesIn
private final LongAdder	bytesOut
private static final Logger	LOG Hides org.eclipse.jetty.io.AbstractConnection.LOG.
private static final HttpField	PREAMBLE_UPGRADE_H2C

Access	Constructor and Description
public	HttpConnection(HttpConfiguration configuration, Connector connector, EndPoint endPoint, boolean recordComplianceViolations) Deprecated for removal since 12.0.6. use `HttpConnection(HttpConfiguration, Connector, EndPoint)` instead.
public	HttpConnection(HttpConfiguration configuration, Connector connector, EndPoint endPoint)

Method Summary

Modifier and Type	Method and Description
public void	asyncReadFillInterested()
public void	clearAttributes() Overrides default org.eclipse.jetty.util.Attributes.clearAttributes. Clear all attribute names
private int	fillRequestBuffer()
public Object	getAttribute(String the attribute to get name) Implements org.eclipse.jetty.util.Attributes.getAttribute. Get an attribute
public Set<String>	getAttributeNameSet() Implements org.eclipse.jetty.util.Attributes.getAttributeNameSet. Get the immutable set of attribute names.
public long	getBytesIn() Overrides org.eclipse.jetty.io.AbstractConnection.getBytesIn. Implements org.eclipse.jetty.io.Connection.getBytesIn.
public long	getBytesOut() Overrides org.eclipse.jetty.io.AbstractConnection.getBytesOut. Implements org.eclipse.jetty.io.Connection.getBytesOut.
public static HttpConnection	Returns: the current HttpConnection or null getCurrentConnection() Get the current connection that this thread is dispatched to.
public HttpGenerator	getGenerator()
public HttpChannel	getHttpChannel()
public HttpVersion	getHttpVersion() Implements org.eclipse.jetty.server.ConnectionMetaData.getHttpVersion.
public String	getId() Implements org.eclipse.jetty.server.ConnectionMetaData.getId.
public Invocable.InvocationType	getInvocationType() Overrides org.eclipse.jetty.io.AbstractConnection.getInvocationType. Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType.
public long	getMessagesIn() Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesIn. Implements org.eclipse.jetty.io.Connection.getMessagesIn.
public long	getMessagesOut() Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesOut. Implements org.eclipse.jetty.io.Connection.getMessagesOut.
public HttpParser	getParser()
public String	getProtocol() Implements org.eclipse.jetty.server.ConnectionMetaData.getProtocol.
private ByteBuffer	getRequestBuffer()
public Server	getServer()
public boolean	isPersistent() Implements org.eclipse.jetty.server.ConnectionMetaData.isPersistent.
public boolean	isRecordHttpComplianceViolations() Deprecated for removal since 12.0.6. No replacement, no longer used within `HttpConnection`, will be removed in Jetty 12.1.0
public boolean	isRequestBufferEmpty()
public boolean	isUseInputDirectByteBuffers()
public boolean	isUseOutputDirectByteBuffers()
protected HttpChannel	newHttpChannel(Server server, HttpConfiguration configuration)
protected HttpGenerator	newHttpGenerator()
protected HttpParser	newHttpParser(HttpCompliance compliance)
protected HttpConnection.HttpStreamOverHTTP1	newHttpStream(String method, String uri, HttpVersion version)
protected HttpConnection.RequestHandler	newRequestHandler()
public void	onClose(Throwable The cause of the close or null for a normal close cause) Overrides org.eclipse.jetty.io.AbstractConnection.onClose. Implements org.eclipse.jetty.io.Connection.onClose. Callback method invoked when this connection is closed.
public void	onFillable() Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable. Callback method invoked when the endpoint is ready to be read.
protected void	onFillInterestedFailed(Throwable the exception that caused the failure cause) Overrides org.eclipse.jetty.io.AbstractConnection.onFillInterestedFailed. Callback method invoked when the endpoint failed to be ready to be read.
public void	onFlushed(long the number of bytes flushed bytes) Implements org.eclipse.jetty.io.WriteFlusher.Listener.onFlushed. Invoked when a `WriteFlusher` flushed bytes in a non-blocking way, as part of a - possibly larger - write.
public boolean	onIdleExpired(TimeoutException timeout) Overrides org.eclipse.jetty.io.AbstractConnection.onIdleExpired. Implements org.eclipse.jetty.io.Connection.onIdleExpired. Callback method invoked upon an idle timeout event.
public void	onOpen() Overrides org.eclipse.jetty.io.AbstractConnection.onOpen. Implements org.eclipse.jetty.io.Connection.onOpen. Callback method invoked when this connection is opened.
public ByteBuffer	onUpgradeFrom() Implements org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom. Invoked during an `upgrade` to produce a buffer containing bytes that have not been consumed by this connection, and that must be consumed by the upgrade-to connection.
public void	onUpgradeTo(ByteBuffer a non-null buffer of unconsumed bytes received from the upgrade-from connection. The buffer does not belong to any pool and should be discarded after having consumed its bytes. buffer) Implements org.eclipse.jetty.io.Connection.UpgradeTo.onUpgradeTo. Invoked during an `upgrade` to receive a buffer containing bytes that have not been consumed by the upgrade-from connection, and that must be consumed by this connection.
pack-priv void	parseAndFillForContent() Parse and fill data, looking for content.
private boolean	parseRequestBuffer()
pack-priv void	releaseRequestBuffer()
public Object	removeAttribute(String the attribute to remove name) Implements org.eclipse.jetty.util.Attributes.removeAttribute. Remove an attribute
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public Object	setAttribute(String the attribute to set name, Object the value to set. A null value is equivalent to removing the attribute. attribute) Implements org.eclipse.jetty.util.Attributes.setAttribute. Set an attribute
protected static HttpConnection	setCurrentConnection(HttpConnection connection)
public void	setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)
public void	setUseOutputDirectByteBuffers(boolean useOutputDirectByteBuffers)
public String	toConnectionString() Overrides org.eclipse.jetty.io.AbstractConnection.toConnectionString.
private boolean	upgrade(HttpConnection.HttpStreamOverHTTP1 stream)

Inherited from org.eclipse.jetty.server.AbstractMetaDataConnection:: getConnection getConnector getHttpConfiguration getLocalSocketAddress getRemoteSocketAddress

public Class HttpConnection

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary