Class HTTP2Connection

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.http2.HTTP2Connection

All Implemented Interfaces:

Closeable, AutoCloseable, Parser.Listener, Connection, Connection.UpgradeTo

public class HTTP2Connection
extends AbstractConnection
implements Parser.Listener, Connection.UpgradeTo

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	HTTP2Connection.HTTP2Producer

Nested classes/interfaces inherited from class AbstractConnection

AbstractConnection.NonBlocking

Nested classes/interfaces inherited from interface Connection

Connection.Listener, Connection.Tunnel, Connection.UpgradeFrom, Connection.UpgradeTo

Nested classes/interfaces inherited from interface Parser.Listener

Parser.Listener.Wrapper

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	HTTP2Connection(ByteBufferPool bufferPool, Executor executor, EndPoint endPoint, HTTP2Session session, int bufferSize)
protected	HTTP2Connection(ByteBufferPool bufferPool, Executor executor, EndPoint endPoint, HTTP2Session session, int bufferSize, int minBufferSpace)

Method Summary

Modifier and Type	Method	Description
void	close()	Performs a logical close of this connection.
protected void	dispatch()
long	getBytesIn()
long	getBytesOut()
long	getMessagesIn()
long	getMessagesOut()
HTTP2Session	getSession()
boolean	isUseInputDirectByteBuffers()
boolean	isUseOutputDirectByteBuffers()
void	offerTask(Runnable task, boolean dispatch)
void	onClose(Throwable cause)	Callback method invoked when this connection is closed.
void	onConnectionFailure(int error, String reason)
void	onData(DataFrame frame)
void	onFillable()	Callback method invoked when the endpoint is ready to be read.
void	onGoAway(GoAwayFrame frame)
void	onHeaders(HeadersFrame frame)
boolean	onIdleExpired(TimeoutException timeoutException)	Callback method invoked upon an idle timeout event.
void	onOpen()	Callback method invoked when this connection is opened.
void	onPing(PingFrame frame)
void	onPriority(PriorityFrame frame)
void	onPushPromise(PushPromiseFrame frame)
void	onReset(ResetFrame frame)
void	onSettings(SettingsFrame frame)
void	onStreamFailure(int streamId, int error, String reason)
void	onUpgradeTo(ByteBuffer buffer)	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.
void	onWindowUpdate(WindowUpdateFrame frame)
protected void	produce()
void	setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)
void	setUseOutputDirectByteBuffers(boolean useOutputDirectByteBuffers)
String	toConnectionString()

Methods inherited from class AbstractConnection

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

Methods inherited from class Object

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

Constructor Details

HTTP2Connection

protected HTTP2Connection(ByteBufferPool bufferPool,
 Executor executor,
 EndPoint endPoint,
 HTTP2Session session,
 int bufferSize)

HTTP2Connection

protected HTTP2Connection(ByteBufferPool bufferPool,
 Executor executor,
 EndPoint endPoint,
 HTTP2Session session,
 int bufferSize,
 int minBufferSpace)

Method Details

getMessagesIn

public long getMessagesIn()

Specified by:

getMessagesIn in interface Connection

Overrides:

getMessagesIn in class AbstractConnection

getMessagesOut

public long getMessagesOut()

Specified by:

getMessagesOut in interface Connection

Overrides:

getMessagesOut in class AbstractConnection

getBytesIn

public long getBytesIn()

Specified by:

getBytesIn in interface Connection

Overrides:

getBytesIn in class AbstractConnection

getBytesOut

public long getBytesOut()

Specified by:

getBytesOut in interface Connection

Overrides:

getBytesOut in class AbstractConnection

getSession

public HTTP2Session getSession()

onUpgradeTo

public void onUpgradeTo(ByteBuffer buffer)

Description copied from interface: Connection.UpgradeTo

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.

Specified by:

onUpgradeTo in interface Connection.UpgradeTo

Parameters:

buffer - 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.

isUseInputDirectByteBuffers

public boolean isUseInputDirectByteBuffers()

setUseInputDirectByteBuffers

public void setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)

isUseOutputDirectByteBuffers

public boolean isUseOutputDirectByteBuffers()

setUseOutputDirectByteBuffers

public void setUseOutputDirectByteBuffers(boolean useOutputDirectByteBuffers)

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 AbstractConnection

onClose

public void onClose(Throwable cause)

Description copied from interface: Connection

Callback method invoked when this connection is closed.

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

Specified by:

onClose in interface Connection

Overrides:

onClose in class AbstractConnection

Parameters:

cause - The cause of the close or null for a normal close

onFillable

public void onFillable()

Description copied from class: AbstractConnection

Callback method invoked when the endpoint is ready to be read.

Specified by:

onFillable in class AbstractConnection

See Also:

• AbstractConnection.fillInterested(Callback)

onIdleExpired

public boolean onIdleExpired(TimeoutException timeoutException)

Description copied from interface: Connection

Callback method invoked upon an idle timeout event.

Implementations of this method may return true to indicate that the idle timeout handling should proceed normally, typically failing the EndPoint and causing it to be closed.

When false is returned, the handling of the idle timeout event is halted immediately and the EndPoint left in the state it was before the idle timeout event.

Specified by:

onIdleExpired in interface Connection

Overrides:

onIdleExpired in class AbstractConnection

Returns:

true to let the EndPoint handle the idle timeout, false to tell the EndPoint to halt the handling of the idle timeout.

offerTask

public void offerTask(Runnable task,
 boolean dispatch)

Parameters:

task - The task to offer to the connection.

dispatch - true to dispatch the task, false to produce in the calling thread. Callers from application threads should use true, otherwise they may be arbitrarily delayed. Callers from I/O threads should use false to avoid thread hops.

produce

protected void produce()

dispatch

protected void dispatch()

close

public void close()

Description copied from interface: Connection

Performs a logical close of this connection.

For simple connections, this may just mean to delegate the close to the associated EndPoint but, for example, SSL connections should write the SSL close message before closing the associated EndPoint.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Connection

Overrides:

close in class AbstractConnection

onHeaders

public void onHeaders(HeadersFrame frame)

Specified by:

onHeaders in interface Parser.Listener

onData

public void onData(DataFrame frame)

Specified by:

onData in interface Parser.Listener

onPriority

public void onPriority(PriorityFrame frame)

Specified by:

onPriority in interface Parser.Listener

onReset

public void onReset(ResetFrame frame)

Specified by:

onReset in interface Parser.Listener

onSettings

public void onSettings(SettingsFrame frame)

Specified by:

onSettings in interface Parser.Listener

onPushPromise

public void onPushPromise(PushPromiseFrame frame)

Specified by:

onPushPromise in interface Parser.Listener

onPing

public void onPing(PingFrame frame)

Specified by:

onPing in interface Parser.Listener

onGoAway

public void onGoAway(GoAwayFrame frame)

Specified by:

onGoAway in interface Parser.Listener

onWindowUpdate

public void onWindowUpdate(WindowUpdateFrame frame)

Specified by:

onWindowUpdate in interface Parser.Listener

onStreamFailure

public void onStreamFailure(int streamId,
 int error,
 String reason)

Specified by:

onStreamFailure in interface Parser.Listener

onConnectionFailure

public void onConnectionFailure(int error,
 String reason)

Specified by:

onConnectionFailure in interface Parser.Listener

toConnectionString

public String toConnectionString()

Overrides:

toConnectionString in class AbstractConnection