Modifier and Type	Class and Description
private static class	HTTP2StreamEndPoint.WriteState

Modifier and Type	Field and Description
private final AtomicBoolean	closed
private Connection	connection
private final long	created
private final AtomicReference<Stream.Data>	data
private final AtomicBoolean	eof
private final AtomicReference<Throwable>	failure
private static final Logger	LOG
private final AtomicReference<Callback>	readCallback
private final HTTP2Stream	stream
private final AtomicReference<HTTP2StreamEndPoint.WriteState>	writeState

Access	Constructor and Description
public	HTTP2StreamEndPoint(HTTP2Stream stream)

Method Summary

Modifier and Type	Method and Description
public void	close(Throwable the reason for the close or null cause) Implements org.eclipse.jetty.io.EndPoint.close. Close any backing stream associated with the endpoint, passing a cause
private ByteBuffer	coalesce(ByteBuffer[] buffers)
public int	fill(ByteBuffer The buffer to fill. The position and limit are modified during the fill. After the operation, the position is unchanged and the limit is increased to reflect the new data filled. sink) Overrides default org.eclipse.jetty.io.EndPoint.fill. Fill the passed buffer with data from this endpoint.
private int	fillFromData(Stream.Data data, ByteBuffer sink)
public void	fillInterested(Callback the callback to call when an error occurs or we are readable. The callback may implement the `Invocable` interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays. callback) Implements org.eclipse.jetty.io.EndPoint.fillInterested. Requests callback methods to be invoked when a call to `fill(ByteBuffer)` would return data or EOF.
public boolean	flush(ByteBuffer... the buffers to flush buffers) Overrides default org.eclipse.jetty.io.EndPoint.flush. Flush data from the passed header/buffer to this endpoint.
public Connection	getConnection() Implements org.eclipse.jetty.io.EndPoint.getConnection.
public long	getCreatedTimeStamp() Implements org.eclipse.jetty.io.EndPoint.getCreatedTimeStamp.
public long	getIdleTimeout() Implements org.eclipse.jetty.io.EndPoint.getIdleTimeout. Get the max idle time in ms.
public InetSocketAddress	getLocalAddress() Implements org.eclipse.jetty.io.EndPoint.getLocalAddress.
public SocketAddress	getLocalSocketAddress() Overrides default org.eclipse.jetty.io.EndPoint.getLocalSocketAddress.
public InetSocketAddress	getRemoteAddress() Implements org.eclipse.jetty.io.EndPoint.getRemoteAddress.
public SocketAddress	getRemoteSocketAddress() Overrides default org.eclipse.jetty.io.EndPoint.getRemoteSocketAddress.
public Object	getTransport() Implements org.eclipse.jetty.io.EndPoint.getTransport.
public boolean	isFillInterested() Implements org.eclipse.jetty.io.EndPoint.isFillInterested.
public boolean	isInputShutdown() Implements org.eclipse.jetty.io.EndPoint.isInputShutdown. Test if the input is shutdown.
public boolean	isOpen() Implements org.eclipse.jetty.io.EndPoint.isOpen.
public boolean	isOutputShutdown() Implements org.eclipse.jetty.io.EndPoint.isOutputShutdown. Test if output is shutdown.
public void	onClose(Throwable The reason for the close, or null if a normal close. cause) Implements org.eclipse.jetty.io.EndPoint.onClose. Callback method invoked when this `EndPoint` is closed.
public void	onOpen() Implements org.eclipse.jetty.io.EndPoint.onOpen. Callback method invoked when this EndPoint is opened.
private void	oshutFailure(Throwable failure)
private void	oshutSuccess()
private void	process()
protected void	processDataAvailable()
protected void	processFailure(Throwable failure)
private long	remaining(ByteBuffer... buffers)
public void	setConnection(Connection the `Connection` associated with this EndPoint connection) Implements org.eclipse.jetty.io.EndPoint.setConnection.
public void	setIdleTimeout(long the idle timeout in MS. Timeout <= 0 implies an infinite timeout idleTimeout) Implements org.eclipse.jetty.io.EndPoint.setIdleTimeout. Set the idle timeout.
public void	shutdownOutput() Implements org.eclipse.jetty.io.EndPoint.shutdownOutput. Shutdown the output.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
public boolean	tryFillInterested(Callback the callback to call when an error occurs or we are readable. The callback may implement the `Invocable` interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays. callback) Implements org.eclipse.jetty.io.EndPoint.tryFillInterested. Requests callback methods to be invoked when a call to `fill(ByteBuffer)` would return data or EOF.
public void	upgrade(Connection the connection to upgrade to newConnection) Implements org.eclipse.jetty.io.EndPoint.upgrade. Upgrades this EndPoint from the current connection to the given new connection.
public void	write(Callback the callback to call when an error occurs or the write completed. The callback may implement the `Invocable` interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays. callback, ByteBuffer... one or more `ByteBuffer`s that will be flushed. buffers) Overrides default org.eclipse.jetty.io.EndPoint.write. Writes the given buffers via `flush(ByteBuffer...)` and invokes callback methods when either all the data has been flushed or an error occurs.
private void	writeFailure(Throwable failure, Callback callback)
private void	writeSuccess(Callback callback)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

closed	back to summary
private final AtomicBoolean closed

connection	back to summary
private Connection connection

created	back to summary
private final long created

data	back to summary
private final AtomicReference<Stream.Data> data

eof	back to summary
private final AtomicBoolean eof

failure	back to summary
private final AtomicReference<Throwable> failure

LOG	back to summary
private static final Logger LOG

readCallback	back to summary
private final AtomicReference<Callback> readCallback

stream	back to summary
private final HTTP2Stream stream

writeState	back to summary
private final AtomicReference<HTTP2StreamEndPoint.WriteState> writeState

Constructor Detail

HTTP2StreamEndPoint	back to summary
public HTTP2StreamEndPoint(HTTP2Stream stream)

Method Detail

close	back to summary
public void close(Throwable cause) Implements org.eclipse.jetty.io.EndPoint.close. Doc from org.eclipse.jetty.io.EndPoint.close. Close any backing stream associated with the endpoint, passing a cause Parameters cause:Throwable the reason for the close or null Annotations @Override

back to summary

public void close(Throwable cause)

Implements org.eclipse.jetty.io.EndPoint.close.

Doc from org.eclipse.jetty.io.EndPoint.close.

Close any backing stream associated with the endpoint, passing a cause

Parameters

cause:Throwable: the reason for the close or null

Annotations

@Override

coalesce	back to summary
private ByteBuffer coalesce(ByteBuffer[] buffers)

fill back to summary

fill	back to summary
public int fill(ByteBuffer sink) throws IOException Overrides default org.eclipse.jetty.io.EndPoint.fill. Doc from org.eclipse.jetty.io.EndPoint.fill. Fill the passed buffer with data from this endpoint. The bytes are appended to any data already in the buffer by writing from the buffers limit up to it's capacity. The limit is updated to include the filled bytes. Parameters sink:ByteBuffer The buffer to fill. The position and limit are modified during the fill. After the operation, the position is unchanged and the limit is increased to reflect the new data filled. Returns:int an `int` value indicating the number of bytes filled or -1 if EOF is read or the input is shutdown. Annotations @Override Exceptions IOException: if the endpoint is closed.

public int fill(ByteBuffer sink) throws IOException

Overrides default org.eclipse.jetty.io.EndPoint.fill.

Doc from org.eclipse.jetty.io.EndPoint.fill.

Fill the passed buffer with data from this endpoint. The bytes are appended to any data already in the buffer by writing from the buffers limit up to it's capacity. The limit is updated to include the filled bytes.

Parameters

sink:ByteBuffer: The buffer to fill. The position and limit are modified during the fill. After the operation, the position is unchanged and the limit is increased to reflect the new data filled.

Returns:int

an int value indicating the number of bytes filled or -1 if EOF is read or the input is shutdown.

Annotations

@Override

Exceptions

IOException:: if the endpoint is closed.

fillFromData	back to summary
private int fillFromData(Stream.Data data, ByteBuffer sink)

fillInterested back to summary

fillInterested	back to summary
public void fillInterested(Callback callback) throws ReadPendingException Implements org.eclipse.jetty.io.EndPoint.fillInterested. Doc from org.eclipse.jetty.io.EndPoint.fillInterested. Requests callback methods to be invoked when a call to `fill(ByteBuffer)` would return data or EOF. Parameters callback:Callback the callback to call when an error occurs or we are readable. The callback may implement the `Invocable` interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays. Annotations @Override Exceptions ReadPendingException: if another read operation is concurrent.

public void fillInterested(Callback callback) throws ReadPendingException

Implements org.eclipse.jetty.io.EndPoint.fillInterested.

Doc from org.eclipse.jetty.io.EndPoint.fillInterested.

Requests callback methods to be invoked when a call to fill(ByteBuffer) would return data or EOF.

Parameters

callback:Callback: the callback to call when an error occurs or we are readable. The callback may implement the Invocable interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays.

Annotations

@Override

Exceptions

ReadPendingException:: if another read operation is concurrent.

flush	back to summary
public boolean flush(ByteBuffer... buffers) throws IOException Overrides default org.eclipse.jetty.io.EndPoint.flush. Doc from org.eclipse.jetty.io.EndPoint.flush. Flush data from the passed header/buffer to this endpoint. As many bytes as can be consumed are taken from the header/buffer position up until the buffer limit. The header/buffers position is updated to indicate how many bytes have been consumed. Parameters buffers:ByteBuffer[] the buffers to flush Returns:boolean True IFF all the buffers have been consumed and the endpoint has flushed the data to its destination (ie is not buffering any data). Annotations @Override Exceptions IOException: If the endpoint is closed or output is shutdown.

flush

back to summary

public boolean flush(ByteBuffer... buffers) throws IOException

Overrides default org.eclipse.jetty.io.EndPoint.flush.

Doc from org.eclipse.jetty.io.EndPoint.flush.

Flush data from the passed header/buffer to this endpoint. As many bytes as can be consumed are taken from the header/buffer position up until the buffer limit. The header/buffers position is updated to indicate how many bytes have been consumed.

Parameters

buffers:ByteBuffer[]: the buffers to flush

Returns:boolean

True IFF all the buffers have been consumed and the endpoint has flushed the data to its destination (ie is not buffering any data).

Annotations

@Override

Exceptions

IOException:: If the endpoint is closed or output is shutdown.

getConnection back to summary

getConnection	back to summary
public Connection getConnection() Implements org.eclipse.jetty.io.EndPoint.getConnection. Returns:Connection Doc from org.eclipse.jetty.io.EndPoint.getConnection. the `Connection` associated with this EndPoint Annotations @Override

public Connection getConnection()

Implements org.eclipse.jetty.io.EndPoint.getConnection.

Returns:Connection

Doc from org.eclipse.jetty.io.EndPoint.getConnection.

the Connection associated with this EndPoint

Annotations

@Override

getCreatedTimeStamp	back to summary
public long getCreatedTimeStamp() Implements org.eclipse.jetty.io.EndPoint.getCreatedTimeStamp. Returns:long Doc from org.eclipse.jetty.io.EndPoint.getCreatedTimeStamp. the epoch time in milliseconds when this EndPoint was created Annotations @Override

getCreatedTimeStamp

back to summary

public long getCreatedTimeStamp()

Implements org.eclipse.jetty.io.EndPoint.getCreatedTimeStamp.

Returns:long

Doc from org.eclipse.jetty.io.EndPoint.getCreatedTimeStamp.

the epoch time in milliseconds when this EndPoint was created

Annotations

@Override

getIdleTimeout	back to summary
public long getIdleTimeout() Implements org.eclipse.jetty.io.EndPoint.getIdleTimeout. Doc from org.eclipse.jetty.io.EndPoint.getIdleTimeout. Get the max idle time in ms. The max idle time is the time the endpoint can be idle before extraordinary handling takes place. Returns:long the max idle time in ms or if ms <= 0 implies an infinite timeout Annotations @Override

getIdleTimeout

back to summary

public long getIdleTimeout()

Implements org.eclipse.jetty.io.EndPoint.getIdleTimeout.

Doc from org.eclipse.jetty.io.EndPoint.getIdleTimeout.

Get the max idle time in ms.

The max idle time is the time the endpoint can be idle before extraordinary handling takes place.

Returns:long

the max idle time in ms or if ms <= 0 implies an infinite timeout

Annotations

@Override

getLocalAddress back to summary

getLocalAddress	back to summary
public InetSocketAddress getLocalAddress() Implements org.eclipse.jetty.io.EndPoint.getLocalAddress. Returns:InetSocketAddress Doc from org.eclipse.jetty.io.EndPoint.getLocalAddress. The local InetSocketAddress to which this `EndPoint` is bound, or `null` if this `EndPoint` is not bound to a Socket address. Annotations @Override

public InetSocketAddress getLocalAddress()

Implements org.eclipse.jetty.io.EndPoint.getLocalAddress.

Returns:InetSocketAddress

Doc from org.eclipse.jetty.io.EndPoint.getLocalAddress.

The local InetSocketAddress to which this EndPoint is bound, or null if this EndPoint is not bound to a Socket address.

Annotations

@Override

getLocalSocketAddress back to summary

getLocalSocketAddress	back to summary
public SocketAddress getLocalSocketAddress() Overrides default org.eclipse.jetty.io.EndPoint.getLocalSocketAddress. Returns:SocketAddress Doc from org.eclipse.jetty.io.EndPoint.getLocalSocketAddress. the local SocketAddress to which this `EndPoint` is bound or `null` if this `EndPoint` is not bound to a Socket address. Annotations @Override

public SocketAddress getLocalSocketAddress()

Overrides default org.eclipse.jetty.io.EndPoint.getLocalSocketAddress.

Returns:SocketAddress

Doc from org.eclipse.jetty.io.EndPoint.getLocalSocketAddress.

the local SocketAddress to which this EndPoint is bound or null if this EndPoint is not bound to a Socket address.

Annotations

@Override

getRemoteAddress back to summary

getRemoteAddress	back to summary
public InetSocketAddress getRemoteAddress() Implements org.eclipse.jetty.io.EndPoint.getRemoteAddress. Returns:InetSocketAddress Doc from org.eclipse.jetty.io.EndPoint.getRemoteAddress. The remote InetSocketAddress to which this `EndPoint` is connected, or `null` if this `EndPoint` is not connected to a Socket address. Annotations @Override

public InetSocketAddress getRemoteAddress()

Implements org.eclipse.jetty.io.EndPoint.getRemoteAddress.

Returns:InetSocketAddress

Doc from org.eclipse.jetty.io.EndPoint.getRemoteAddress.

The remote InetSocketAddress to which this EndPoint is connected, or null if this EndPoint is not connected to a Socket address.

Annotations

@Override

getRemoteSocketAddress back to summary

getRemoteSocketAddress	back to summary
public SocketAddress getRemoteSocketAddress() Overrides default org.eclipse.jetty.io.EndPoint.getRemoteSocketAddress. Returns:SocketAddress Doc from org.eclipse.jetty.io.EndPoint.getRemoteSocketAddress. The remote SocketAddress to which this `EndPoint` is connected, or `null` if this `EndPoint` is not connected to a Socket address. Annotations @Override

public SocketAddress getRemoteSocketAddress()

Overrides default org.eclipse.jetty.io.EndPoint.getRemoteSocketAddress.

Returns:SocketAddress

Doc from org.eclipse.jetty.io.EndPoint.getRemoteSocketAddress.

The remote SocketAddress to which this EndPoint is connected, or null if this EndPoint is not connected to a Socket address.

Annotations

@Override

getTransport	back to summary
public Object getTransport() Implements org.eclipse.jetty.io.EndPoint.getTransport. Returns:Object Doc from org.eclipse.jetty.io.EndPoint.getTransport. The underlying transport object (socket, channel, etc.) Annotations @Override

getTransport

back to summary

public Object getTransport()

Implements org.eclipse.jetty.io.EndPoint.getTransport.

Returns:Object

Doc from org.eclipse.jetty.io.EndPoint.getTransport.

The underlying transport object (socket, channel, etc.)

Annotations

@Override

isFillInterested back to summary

isFillInterested	back to summary
public boolean isFillInterested() Implements org.eclipse.jetty.io.EndPoint.isFillInterested. Returns:boolean Doc from org.eclipse.jetty.io.EndPoint.isFillInterested. whether `fillInterested(Callback)` has been called, but `fill(ByteBuffer)` has not yet been called Annotations @Override

public boolean isFillInterested()

Implements org.eclipse.jetty.io.EndPoint.isFillInterested.

Returns:boolean

Doc from org.eclipse.jetty.io.EndPoint.isFillInterested.

whether fillInterested(Callback) has been called, but fill(ByteBuffer) has not yet been called

Annotations

@Override

isInputShutdown back to summary

isInputShutdown	back to summary
public boolean isInputShutdown() Implements org.eclipse.jetty.io.EndPoint.isInputShutdown. Doc from org.eclipse.jetty.io.EndPoint.isInputShutdown. Test if the input is shutdown. The input is shutdown if an EOF has been read while doing a `fill(ByteBuffer)`. Once the input is shutdown, all calls to `fill(ByteBuffer)` will return -1, until such time as the end point is close, when they will return `EofException`. Returns:boolean True if the input is shutdown or the endpoint is closed. Annotations @Override

public boolean isInputShutdown()

Implements org.eclipse.jetty.io.EndPoint.isInputShutdown.

Doc from org.eclipse.jetty.io.EndPoint.isInputShutdown.

Test if the input is shutdown. The input is shutdown if an EOF has been read while doing a fill(ByteBuffer). Once the input is shutdown, all calls to fill(ByteBuffer) will return -1, until such time as the end point is close, when they will return EofException.

Returns:boolean

True if the input is shutdown or the endpoint is closed.

Annotations

@Override

isOpen	back to summary
public boolean isOpen() Implements org.eclipse.jetty.io.EndPoint.isOpen. Returns:boolean Doc from org.eclipse.jetty.io.EndPoint.isOpen. whether this EndPoint is open Annotations @Override

isOpen

back to summary

public boolean isOpen()

Implements org.eclipse.jetty.io.EndPoint.isOpen.

Returns:boolean

Doc from org.eclipse.jetty.io.EndPoint.isOpen.

whether this EndPoint is open

Annotations

@Override

isOutputShutdown back to summary

isOutputShutdown	back to summary
public boolean isOutputShutdown() Implements org.eclipse.jetty.io.EndPoint.isOutputShutdown. Doc from org.eclipse.jetty.io.EndPoint.isOutputShutdown. Test if output is shutdown. The output is shutdown by a call to `shutdownOutput()` or `close()`. Returns:boolean true if the output is shutdown or the endpoint is closed. Annotations @Override

public boolean isOutputShutdown()

Implements org.eclipse.jetty.io.EndPoint.isOutputShutdown.

Doc from org.eclipse.jetty.io.EndPoint.isOutputShutdown.

Test if output is shutdown. The output is shutdown by a call to shutdownOutput() or close().

Returns:boolean

true if the output is shutdown or the endpoint is closed.

Annotations

@Override

onClose back to summary

onClose	back to summary
public void onClose(Throwable cause) Implements org.eclipse.jetty.io.EndPoint.onClose. Doc from org.eclipse.jetty.io.EndPoint.onClose. Callback method invoked when this `EndPoint` is closed. Parameters cause:Throwable The reason for the close, or null if a normal close. Annotations @Override

public void onClose(Throwable cause)

Implements org.eclipse.jetty.io.EndPoint.onClose.

Doc from org.eclipse.jetty.io.EndPoint.onClose.

Callback method invoked when this EndPoint is closed.

Parameters

cause:Throwable: The reason for the close, or null if a normal close.

Annotations

@Override

onOpen	back to summary
public void onOpen() Implements org.eclipse.jetty.io.EndPoint.onOpen. Doc from org.eclipse.jetty.io.EndPoint.onOpen. Callback method invoked when this EndPoint is opened. Annotations @Override

onOpen

back to summary

public void onOpen()

Implements org.eclipse.jetty.io.EndPoint.onOpen.

Doc from org.eclipse.jetty.io.EndPoint.onOpen.

Callback method invoked when this EndPoint is opened.

Annotations

@Override

oshutFailure	back to summary
private void oshutFailure(Throwable failure)

oshutSuccess	back to summary
private void oshutSuccess()

process	back to summary
private void process()

processDataAvailable	back to summary
protected void processDataAvailable()

processFailure	back to summary
protected void processFailure(Throwable failure)

remaining	back to summary
private long remaining(ByteBuffer... buffers)

setConnection back to summary

setConnection	back to summary
public void setConnection(Connection connection) Implements org.eclipse.jetty.io.EndPoint.setConnection. Parameters connection:Connection Doc from org.eclipse.jetty.io.EndPoint.setConnection. the `Connection` associated with this EndPoint Annotations @Override

public void setConnection(Connection connection)

Implements org.eclipse.jetty.io.EndPoint.setConnection.

Parameters

connection:Connection

Doc from org.eclipse.jetty.io.EndPoint.setConnection.

the Connection associated with this EndPoint

Annotations

@Override

setIdleTimeout	back to summary
public void setIdleTimeout(long idleTimeout) Implements org.eclipse.jetty.io.EndPoint.setIdleTimeout. Doc from org.eclipse.jetty.io.EndPoint.setIdleTimeout. Set the idle timeout. Parameters idleTimeout:long the idle timeout in MS. Timeout <= 0 implies an infinite timeout Annotations @Override

setIdleTimeout

back to summary

public void setIdleTimeout(long idleTimeout)

Implements org.eclipse.jetty.io.EndPoint.setIdleTimeout.

Doc from org.eclipse.jetty.io.EndPoint.setIdleTimeout.

Set the idle timeout.

Parameters

idleTimeout:long: the idle timeout in MS. Timeout <= 0 implies an infinite timeout

Annotations

@Override

shutdownOutput back to summary

shutdownOutput	back to summary
public void shutdownOutput() Implements org.eclipse.jetty.io.EndPoint.shutdownOutput. Doc from org.eclipse.jetty.io.EndPoint.shutdownOutput. Shutdown the output. This call indicates that no more data will be sent on this endpoint that that the remote end should read an EOF once all previously sent data has been consumed. Shutdown may be done either at the TCP/IP level, as a protocol exchange (Eg TLS close handshake) or both. If the endpoint has `isInputShutdown()` true, then this call has the same effect as `close()`. Annotations @Override

public void shutdownOutput()

Implements org.eclipse.jetty.io.EndPoint.shutdownOutput.

Doc from org.eclipse.jetty.io.EndPoint.shutdownOutput.

Shutdown the output.

This call indicates that no more data will be sent on this endpoint that that the remote end should read an EOF once all previously sent data has been consumed. Shutdown may be done either at the TCP/IP level, as a protocol exchange (Eg TLS close handshake) or both.

If the endpoint has isInputShutdown() true, then this call has the same effect as close().

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Returns:String a string representation of the object Annotations @Override

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

tryFillInterested back to summary

tryFillInterested	back to summary
public boolean tryFillInterested(Callback callback) Implements org.eclipse.jetty.io.EndPoint.tryFillInterested. Doc from org.eclipse.jetty.io.EndPoint.tryFillInterested. Requests callback methods to be invoked when a call to `fill(ByteBuffer)` would return data or EOF. Parameters callback:Callback the callback to call when an error occurs or we are readable. The callback may implement the `Invocable` interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays. Returns:boolean true if set Annotations @Override

public boolean tryFillInterested(Callback callback)

Implements org.eclipse.jetty.io.EndPoint.tryFillInterested.

Doc from org.eclipse.jetty.io.EndPoint.tryFillInterested.

Requests callback methods to be invoked when a call to fill(ByteBuffer) would return data or EOF.

Parameters

callback:Callback: the callback to call when an error occurs or we are readable. The callback may implement the Invocable interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays.

Returns:boolean

true if set

Annotations

@Override

upgrade back to summary

upgrade	back to summary
public void upgrade(Connection newConnection) Implements org.eclipse.jetty.io.EndPoint.upgrade. Doc from org.eclipse.jetty.io.EndPoint.upgrade. Upgrades this EndPoint from the current connection to the given new connection. Closes the current connection, links this EndPoint to the new connection and then opens the new connection. If the current connection is an instance of `Connection.UpgradeFrom` then a buffer of unconsumed bytes is requested. If the buffer of unconsumed bytes is non-null and non-empty, then the new connection is tested: if it is an instance of `Connection.UpgradeTo`, then the unconsumed buffer is passed to the new connection; otherwise, an exception is thrown since there are unconsumed bytes that cannot be consumed by the new connection. Parameters newConnection:Connection the connection to upgrade to Annotations @Override

public void upgrade(Connection newConnection)

Implements org.eclipse.jetty.io.EndPoint.upgrade.

Doc from org.eclipse.jetty.io.EndPoint.upgrade.

Upgrades this EndPoint from the current connection to the given new connection.

Closes the current connection, links this EndPoint to the new connection and then opens the new connection.

If the current connection is an instance of Connection.UpgradeFrom then a buffer of unconsumed bytes is requested. If the buffer of unconsumed bytes is non-null and non-empty, then the new connection is tested: if it is an instance of Connection.UpgradeTo, then the unconsumed buffer is passed to the new connection; otherwise, an exception is thrown since there are unconsumed bytes that cannot be consumed by the new connection.

Parameters

newConnection:Connection: the connection to upgrade to

Annotations

@Override

write back to summary

write	back to summary
public void write(Callback callback, ByteBuffer... buffers) throws WritePendingException Overrides default org.eclipse.jetty.io.EndPoint.write. Doc from org.eclipse.jetty.io.EndPoint.write. Writes the given buffers via `flush(ByteBuffer...)` and invokes callback methods when either all the data has been flushed or an error occurs. Parameters callback:Callback the callback to call when an error occurs or the write completed. The callback may implement the `Invocable` interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays. buffers:ByteBuffer[] one or more `ByteBuffer`s that will be flushed. Annotations @Override Exceptions WritePendingException: if another write operation is concurrent.

public void write(Callback callback, ByteBuffer... buffers) throws WritePendingException

Overrides default org.eclipse.jetty.io.EndPoint.write.

Doc from org.eclipse.jetty.io.EndPoint.write.

Writes the given buffers via flush(ByteBuffer...) and invokes callback methods when either all the data has been flushed or an error occurs.

Parameters

callback:Callback: the callback to call when an error occurs or the write completed. The callback may implement the Invocable interface to self declare its blocking status. Non-blocking callbacks may be called more efficiently without dispatch delays.
buffers:ByteBuffer[]: one or more ByteBuffers that will be flushed.

Annotations

@Override

Exceptions

WritePendingException:: if another write operation is concurrent.

writeFailure	back to summary
private void writeFailure(Throwable failure, Callback callback)

writeSuccess	back to summary
private void writeSuccess(Callback callback)

org.eclipse.jetty.http2 back to summary

private Class HTTP2StreamEndPoint.WriteState

Class Inheritance

extends Object

java.lang.Object
org.eclipse.jetty.http2.HTTP2StreamEndPoint.WriteState

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static enum	HTTP2StreamEndPoint.WriteState.State

Field Summary

Modifier and Type	Field and Description
private final Throwable	failure
public static final HTTP2StreamEndPoint.WriteState	IDLE
public static final HTTP2StreamEndPoint.WriteState	OSHUT
public static final HTTP2StreamEndPoint.WriteState	OSHUTTING
public static final HTTP2StreamEndPoint.WriteState	PENDING
private final HTTP2StreamEndPoint.WriteState.State	state

Constructor Summary

Access	Constructor and Description
private	WriteState(HTTP2StreamEndPoint.WriteState.State state)
private	WriteState(HTTP2StreamEndPoint.WriteState.State state, Throwable failure)

Method Summary

Modifier and Type	Method and Description
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

failure	back to summary
private final Throwable failure

IDLE	back to summary
public static final HTTP2StreamEndPoint.WriteState IDLE

OSHUT	back to summary
public static final HTTP2StreamEndPoint.WriteState OSHUT

OSHUTTING	back to summary
public static final HTTP2StreamEndPoint.WriteState OSHUTTING

PENDING	back to summary
public static final HTTP2StreamEndPoint.WriteState PENDING

state	back to summary
private final HTTP2StreamEndPoint.WriteState.State state

Constructor Detail

WriteState	back to summary
private WriteState(HTTP2StreamEndPoint.WriteState.State state)

WriteState	back to summary
private WriteState(HTTP2StreamEndPoint.WriteState.State state, Throwable failure)

Method Detail

toString back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

org.eclipse.jetty.http2 back to summary

private final Enum HTTP2StreamEndPoint.WriteState.State

Class Inheritance

extends Enum<HTTP2StreamEndPoint.WriteState.State>

java.lang.Object
java.lang.Enum
org.eclipse.jetty.http2.HTTP2StreamEndPoint.WriteState.State

Field Summary

Modifier and Type	Field and Description
public static final HTTP2StreamEndPoint.WriteState.State	FAILED
public static final HTTP2StreamEndPoint.WriteState.State	IDLE
public static final HTTP2StreamEndPoint.WriteState.State	OSHUT
public static final HTTP2StreamEndPoint.WriteState.State	OSHUTTING
public static final HTTP2StreamEndPoint.WriteState.State	PENDING

Constructor Summary

Access	Constructor and Description
private	State()

Method Summary

Modifier and Type	Method and Description
public static HTTP2StreamEndPoint.WriteState.State	valueOf(String name)
public static HTTP2StreamEndPoint.WriteState.State[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

FAILED	back to summary
public static final HTTP2StreamEndPoint.WriteState.State FAILED

IDLE	back to summary
public static final HTTP2StreamEndPoint.WriteState.State IDLE

OSHUT	back to summary
public static final HTTP2StreamEndPoint.WriteState.State OSHUT

OSHUTTING	back to summary
public static final HTTP2StreamEndPoint.WriteState.State OSHUTTING

PENDING	back to summary
public static final HTTP2StreamEndPoint.WriteState.State PENDING

Constructor Detail

State	back to summary
private State()

Method Detail

valueOf	back to summary
public static HTTP2StreamEndPoint.WriteState.State valueOf(String name)

values	back to summary
public static HTTP2StreamEndPoint.WriteState.State[] values()

public abstract Class HTTP2StreamEndPoint

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class HTTP2StreamEndPoint.WriteState

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Enum HTTP2StreamEndPoint.WriteState.State

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail