Package org.eclipse.jetty.http2.server.internal

Class HTTP2ServerConnection

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.http2.HTTP2Connection

org.eclipse.jetty.http2.server.internal.HTTP2ServerConnection

All Implemented Interfaces:

Closeable, AutoCloseable, Parser.Listener, ServerParser.Listener, Connection, Connection.UpgradeTo, ConnectionMetaData, Attributes, Invocable

public class HTTP2ServerConnection
extends HTTP2Connection
implements ConnectionMetaData, ServerParser.Listener

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.http2.HTTP2Connection

HTTP2Connection.HTTP2Producer

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.Attributes

Attributes.Layer, Attributes.Lazy, Attributes.Mapped, Attributes.Synthetic

Nested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection

Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo

Nested classes/interfaces inherited from interface org.eclipse.jetty.server.ConnectionMetaData

ConnectionMetaData.Wrapper

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable

Invocable.Callable, Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task

Nested classes/interfaces inherited from interface org.eclipse.jetty.http2.parser.Parser.Listener

Parser.Listener.Wrapper

Nested classes/interfaces inherited from interface org.eclipse.jetty.http2.parser.ServerParser.Listener

ServerParser.Listener.Wrapper

Field Summary

Fields inherited from interface org.eclipse.jetty.util.Attributes

NULL

Fields inherited from interface org.eclipse.jetty.util.thread.Invocable

__nonBlocking, NOOP

Constructor Summary

Constructors

Constructor	Description
HTTP2ServerConnection(Connector connector, EndPoint endPoint, HttpConfiguration httpConfig, HTTP2ServerSession session, int inputBufferSize, ServerSessionListener listener)

Method Summary

Modifier and Type	Method	Description
void	clearAttributes()	Clear all attribute names
Object	getAttribute(String name)	Get an attribute
Set<String>	getAttributeNameSet()	Get the immutable set of attribute names.
Connection	getConnection()
Connector	getConnector()
HttpConfiguration	getHttpConfiguration()
HttpVersion	getHttpVersion()
String	getId()
SocketAddress	getLocalSocketAddress()
String	getProtocol()
SocketAddress	getRemoteSocketAddress()
HTTP2ServerSession	getSession()
boolean	isPersistent()
boolean	isPushSupported()
boolean	isRecycleHttpChannels()
void	onDataAvailable(Stream stream)
void	onNewStream(HTTP2Stream stream, HeadersFrame frame)
void	onOpen()	Callback method invoked when this connection is opened.
void	onPreface()
void	onSessionFailure(Throwable failure, Callback callback)
boolean	onSessionTimeout(Throwable failure)
void	onStreamFailure(Stream stream, Throwable failure, Callback callback)
void	onStreamTimeout(Stream stream, TimeoutException timeout, Promise<Boolean> promise)
void	onTrailers(Stream stream, HeadersFrame frame)
void	push(HTTP2Stream stream, MetaData.Request request)
Object	removeAttribute(String name)	Remove an attribute
Object	setAttribute(String name, Object attribute)	Set an attribute
void	setRecycleHttpChannels(boolean recycleHttpChannels)
boolean	upgrade(MetaData.Request request, HttpFields.Mutable responseFields)

Methods inherited from class org.eclipse.jetty.http2.HTTP2Connection

close, dispatch, getBytesIn, getBytesOut, getMessagesIn, getMessagesOut, isUseInputDirectByteBuffers, isUseOutputDirectByteBuffers, offerTask, onClose, onConnectionFailure, onData, onFillable, onGoAway, onHeaders, onIdleExpired, onPing, onPriority, onPushPromise, onReset, onSettings, onStreamFailure, onUpgradeTo, onWindowUpdate, produce, setUseInputDirectByteBuffers, setUseOutputDirectByteBuffers

Methods inherited from class org.eclipse.jetty.io.AbstractConnection

addEventListener, failedCallback, fillInterested, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getInvocationType, isFillInterested, onFillInterestedFailed, onReadTimeout, removeEventListener, setInputBufferSize, toConnectionString, toString, tryFillInterested

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.Attributes

asAttributeMap, equals, hashCode

Methods inherited from interface org.eclipse.jetty.server.ConnectionMetaData

getServerAuthority, isSecure

Methods inherited from interface org.eclipse.jetty.http2.parser.Parser.Listener

onConnectionFailure, onData, onGoAway, onHeaders, onPing, onPriority, onPushPromise, onReset, onSettings, onStreamFailure, onWindowUpdate

Constructor Details

HTTP2ServerConnection

public HTTP2ServerConnection(Connector connector,
 EndPoint endPoint,
 HttpConfiguration httpConfig,
 HTTP2ServerSession session,
 int inputBufferSize,
 ServerSessionListener listener)

Method Details

isRecycleHttpChannels

public boolean isRecycleHttpChannels()

setRecycleHttpChannels

public void setRecycleHttpChannels(boolean recycleHttpChannels)

getSession

public HTTP2ServerSession getSession()

Overrides:

getSession in class HTTP2Connection

onOpen

public void onOpen()

Description copied from interface: Connection

Callback method invoked when this connection is opened.

Creators of the connection implementation are responsible for calling this method.

Specified by:

onOpen in interface Connection

Overrides:

onOpen in class HTTP2Connection

onPreface

public void onPreface()

Specified by:

onPreface in interface ServerParser.Listener

onNewStream

public void onNewStream(HTTP2Stream stream,
 HeadersFrame frame)

onDataAvailable

public void onDataAvailable(Stream stream)

onTrailers

public void onTrailers(Stream stream,
 HeadersFrame frame)

onStreamTimeout

public void onStreamTimeout(Stream stream,
 TimeoutException timeout,
 Promise<Boolean> promise)

onStreamFailure

public void onStreamFailure(Stream stream,
 Throwable failure,
 Callback callback)

onSessionTimeout

public boolean onSessionTimeout(Throwable failure)

onSessionFailure

public void onSessionFailure(Throwable failure,
 Callback callback)

push

public void push(HTTP2Stream stream,
 MetaData.Request request)

upgrade

public boolean upgrade(MetaData.Request request,
 HttpFields.Mutable responseFields)

getId

public String getId()

Specified by:

getId in interface ConnectionMetaData

Returns:

a unique (within the lifetime of the JVM) identifier string for the network connection to the JVM

getHttpConfiguration

public HttpConfiguration getHttpConfiguration()

Specified by:

getHttpConfiguration in interface ConnectionMetaData

getHttpVersion

public HttpVersion getHttpVersion()

Specified by:

getHttpVersion in interface ConnectionMetaData

getProtocol

public String getProtocol()

Specified by:

getProtocol in interface ConnectionMetaData

getConnection

public Connection getConnection()

Specified by:

getConnection in interface ConnectionMetaData

getConnector

public Connector getConnector()

Specified by:

getConnector in interface ConnectionMetaData

isPersistent

public boolean isPersistent()

Specified by:

isPersistent in interface ConnectionMetaData

isPushSupported

public boolean isPushSupported()

Specified by:

isPushSupported in interface ConnectionMetaData

Returns:

whether the functionality of pushing resources is supported

getRemoteSocketAddress

public SocketAddress getRemoteSocketAddress()

Specified by:

getRemoteSocketAddress in interface ConnectionMetaData

Returns:

The address of the remote end of this connection. By default, this is the first hop of the underlying network connection, but it may be wrapped to represent a more remote end point.

getLocalSocketAddress

public SocketAddress getLocalSocketAddress()

Specified by:

getLocalSocketAddress in interface ConnectionMetaData

Returns:

The address of the local end of this connection. By default, this is the address of the underlying network connection, but it may be wrapped if the deployment wishes to hide all local details.

getAttribute

public Object getAttribute(String name)

Description copied from interface: Attributes

Get an attribute

Specified by:

getAttribute in interface Attributes

Parameters:

name - the attribute to get

Returns:

the value of the attribute, or null if no such attribute exists

setAttribute

public Object setAttribute(String name,
 Object attribute)

Description copied from interface: Attributes

Set an attribute

Specified by:

setAttribute in interface Attributes

Parameters:

name - the attribute to set

attribute - the value to set. A null value is equivalent to removing the attribute.

Returns:

the previous value of the attribute if set, else null

removeAttribute

public Object removeAttribute(String name)

Description copied from interface: Attributes

Remove an attribute

Specified by:

removeAttribute in interface Attributes

Parameters:

name - the attribute to remove

Returns:

the value of the attribute if removed, else null

getAttributeNameSet

public Set<String> getAttributeNameSet()

Description copied from interface: Attributes

Get the immutable set of attribute names.

Specified by:

getAttributeNameSet in interface Attributes

Returns:

Set of attribute names, or an empty set if there are no attributes.

clearAttributes

public void clearAttributes()

Description copied from interface: Attributes

Clear all attribute names

Specified by:

clearAttributes in interface Attributes