Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	HTTP2Connection.FillableCallback
protected class	HTTP2Connection.HTTP2Producer
private class	HTTP2Connection.NetworkBuffer
private static class	HTTP2Connection.StreamData

Field Summary

Modifier and Type	Field and Description
private final ByteBufferPool	bufferPool
private final int	bufferSize
private final AtomicLong	bytesIn
private final AutoLock	lock
private static final Logger	LOG Hides org.eclipse.jetty.io.AbstractConnection.LOG.
private final HTTP2Connection.HTTP2Producer	producer
private final HTTP2Session	session
private final ExecutionStrategy	strategy
private final Queue<Runnable>	tasks
private boolean	useInputDirectByteBuffers
private boolean	useOutputDirectByteBuffers

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
public void	close() Overrides org.eclipse.jetty.io.AbstractConnection.close. Implements org.eclipse.jetty.io.Connection.close. Performs a logical close of this connection.
protected void	dispatch()
private int	fill(EndPoint endPoint, ByteBuffer buffer)
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 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 HTTP2Session	getSession()
public boolean	isUseInputDirectByteBuffers()
public boolean	isUseOutputDirectByteBuffers()
protected void	offerTask(Runnable task, boolean dispatch)
private void	offerTask(Runnable task)
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	onConnectionFailure(int error, String reason) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onConnectionFailure.
public void	onData(DataFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onData.
public void	onFillable() Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable. Callback method invoked when the endpoint is 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 void	onGoAway(GoAwayFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onGoAway.
public void	onHeaders(HeadersFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onHeaders.
public boolean	onIdleExpired(TimeoutException timeoutException) 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 void	onPing(PingFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPing.
public void	onPriority(PriorityFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPriority.
public void	onPushPromise(PushPromiseFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPushPromise.
public void	onReset(ResetFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onReset.
public void	onSettings(SettingsFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onSettings.
public void	onStreamFailure(int streamId, int error, String reason) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onStreamFailure.
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.
public void	onWindowUpdate(WindowUpdateFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onWindowUpdate.
private Runnable	pollTask()
protected void	produce()
public void	setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)
public void	setUseOutputDirectByteBuffers(boolean useOutputDirectByteBuffers)

Inherited from org.eclipse.jetty.io.AbstractConnection:: addEventListener failedCallback fillInterested getCreatedTimeStamp getEndPoint getExecutor getInputBufferSize getInvocationType isFillInterested onFillInterestedFailed onReadTimeout removeEventListener setInputBufferSize toConnectionString toString tryFillInterested

Field Detail

bufferPool	back to summary
private final ByteBufferPool bufferPool

bufferSize	back to summary
private final int bufferSize

bytesIn	back to summary
private final AtomicLong bytesIn

lock	back to summary
private final AutoLock lock

LOG	back to summary
private static final Logger LOG Hides org.eclipse.jetty.io.AbstractConnection.LOG.

producer	back to summary
private final HTTP2Connection.HTTP2Producer producer

session	back to summary
private final HTTP2Session session

strategy	back to summary
private final ExecutionStrategy strategy

tasks	back to summary
private final Queue<Runnable> tasks

useInputDirectByteBuffers	back to summary
private boolean useInputDirectByteBuffers

useOutputDirectByteBuffers	back to summary
private boolean useOutputDirectByteBuffers

Constructor Detail

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

Method Detail

close back to summary

close	back to summary
public void close() Overrides org.eclipse.jetty.io.AbstractConnection.close. Implements org.eclipse.jetty.io.Connection.close. Doc from org.eclipse.jetty.io.Connection.close. 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`. Annotations @Override

public void close()

Overrides org.eclipse.jetty.io.AbstractConnection.close.

Implements org.eclipse.jetty.io.Connection.close.

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

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.

Annotations

@Override

dispatch	back to summary
protected void dispatch()

fill	back to summary
private int fill(EndPoint endPoint, ByteBuffer buffer)

getBytesIn	back to summary
public long getBytesIn() Overrides org.eclipse.jetty.io.AbstractConnection.getBytesIn. Implements org.eclipse.jetty.io.Connection.getBytesIn. Annotations @Override

getBytesIn

back to summary

public long getBytesIn()

Overrides org.eclipse.jetty.io.AbstractConnection.getBytesIn.

Implements org.eclipse.jetty.io.Connection.getBytesIn.

Annotations

@Override

getBytesOut	back to summary
public long getBytesOut() Overrides org.eclipse.jetty.io.AbstractConnection.getBytesOut. Implements org.eclipse.jetty.io.Connection.getBytesOut. Annotations @Override

getBytesOut

back to summary

public long getBytesOut()

Overrides org.eclipse.jetty.io.AbstractConnection.getBytesOut.

Implements org.eclipse.jetty.io.Connection.getBytesOut.

Annotations

@Override

getMessagesIn	back to summary
public long getMessagesIn() Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesIn. Implements org.eclipse.jetty.io.Connection.getMessagesIn. Annotations @Override

getMessagesIn

back to summary

public long getMessagesIn()

Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesIn.

Implements org.eclipse.jetty.io.Connection.getMessagesIn.

Annotations

@Override

getMessagesOut	back to summary
public long getMessagesOut() Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesOut. Implements org.eclipse.jetty.io.Connection.getMessagesOut. Annotations @Override

getMessagesOut

back to summary

public long getMessagesOut()

Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesOut.

Implements org.eclipse.jetty.io.Connection.getMessagesOut.

Annotations

@Override

getSession	back to summary
public HTTP2Session getSession()

isUseInputDirectByteBuffers	back to summary
public boolean isUseInputDirectByteBuffers()

isUseOutputDirectByteBuffers	back to summary
public boolean isUseOutputDirectByteBuffers()

offerTask	back to summary
protected void offerTask(Runnable task, boolean dispatch)

offerTask	back to summary
private void offerTask(Runnable task)

onClose	back to summary
public void onClose(Throwable cause) Overrides org.eclipse.jetty.io.AbstractConnection.onClose. Implements org.eclipse.jetty.io.Connection.onClose. Doc from org.eclipse.jetty.io.Connection.onClose. Callback method invoked when this connection is closed. Creators of the connection implementation are responsible for calling this method. Parameters cause:Throwable The cause of the close or null for a normal close Annotations @Override

onClose

back to summary

public void onClose(Throwable cause)

Overrides org.eclipse.jetty.io.AbstractConnection.onClose.

Implements org.eclipse.jetty.io.Connection.onClose.

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

Callback method invoked when this connection is closed.

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

Parameters

cause:Throwable: The cause of the close or null for a normal close

Annotations

@Override

onConnectionFailure	back to summary
public void onConnectionFailure(int error, String reason) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onConnectionFailure. Annotations @Override

onConnectionFailure

back to summary

public void onConnectionFailure(int error, String reason)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onConnectionFailure.

Annotations

@Override

onData	back to summary
public void onData(DataFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onData. Annotations @Override

onData

back to summary

public void onData(DataFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onData.

Annotations

@Override

onFillable	back to summary
public void onFillable() Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable. Doc from org.eclipse.jetty.io.AbstractConnection.onFillable. Callback method invoked when the endpoint is ready to be read. Annotations @Override

onFillable

back to summary

public void onFillable()

Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable.

Doc from org.eclipse.jetty.io.AbstractConnection.onFillable.

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

Annotations

@Override

onFlushed back to summary

onFlushed	back to summary
public void onFlushed(long bytes) throws IOException Implements org.eclipse.jetty.io.WriteFlusher.Listener.onFlushed. Doc from 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. This method may be invoked multiple times, for example when writing a large buffer: a first flush of bytes, then the connection became TCP congested, and a subsequent flush of bytes when the connection became writable again. This method is never invoked concurrently, but may be invoked by different threads, so implementations may not rely on thread-local variables. Implementations may throw an `IOException` to signal that the write should fail, for example if the implementation enforces a minimum data rate. Parameters bytes:long the number of bytes flushed Annotations @Override Exceptions IOException: if the write should fail

public void onFlushed(long bytes) throws IOException

Implements org.eclipse.jetty.io.WriteFlusher.Listener.onFlushed.

Doc from 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.

This method may be invoked multiple times, for example when writing a large buffer: a first flush of bytes, then the connection became TCP congested, and a subsequent flush of bytes when the connection became writable again.

This method is never invoked concurrently, but may be invoked by different threads, so implementations may not rely on thread-local variables.

Implementations may throw an IOException to signal that the write should fail, for example if the implementation enforces a minimum data rate.

Parameters

bytes:long: the number of bytes flushed

Annotations

@Override

Exceptions

IOException:: if the write should fail

onGoAway	back to summary
public void onGoAway(GoAwayFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onGoAway. Annotations @Override

onGoAway

back to summary

public void onGoAway(GoAwayFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onGoAway.

Annotations

@Override

onHeaders	back to summary
public void onHeaders(HeadersFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onHeaders. Annotations @Override

onHeaders

back to summary

public void onHeaders(HeadersFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onHeaders.

Annotations

@Override

onIdleExpired	back to summary
public boolean onIdleExpired(TimeoutException timeoutException) Overrides org.eclipse.jetty.io.AbstractConnection.onIdleExpired. Implements org.eclipse.jetty.io.Connection.onIdleExpired. Doc from org.eclipse.jetty.io.Connection.onIdleExpired. 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. Returns:boolean true to let the EndPoint handle the idle timeout, false to tell the EndPoint to halt the handling of the idle timeout. Annotations @Override

onIdleExpired

back to summary

public boolean onIdleExpired(TimeoutException timeoutException)

Overrides org.eclipse.jetty.io.AbstractConnection.onIdleExpired.

Implements org.eclipse.jetty.io.Connection.onIdleExpired.

Doc from org.eclipse.jetty.io.Connection.onIdleExpired.

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.

Returns:boolean

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

Annotations

@Override

onOpen	back to summary
public void onOpen() Overrides org.eclipse.jetty.io.AbstractConnection.onOpen. Implements org.eclipse.jetty.io.Connection.onOpen. Doc from org.eclipse.jetty.io.Connection.onOpen. Callback method invoked when this connection is opened. Creators of the connection implementation are responsible for calling this method. Annotations @Override

onOpen

back to summary

public void onOpen()

Overrides org.eclipse.jetty.io.AbstractConnection.onOpen.

Implements org.eclipse.jetty.io.Connection.onOpen.

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

Callback method invoked when this connection is opened.

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

Annotations

@Override

onPing	back to summary
public void onPing(PingFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPing. Annotations @Override

onPing

back to summary

public void onPing(PingFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPing.

Annotations

@Override

onPriority	back to summary
public void onPriority(PriorityFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPriority. Annotations @Override

onPriority

back to summary

public void onPriority(PriorityFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPriority.

Annotations

@Override

onPushPromise	back to summary
public void onPushPromise(PushPromiseFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPushPromise. Annotations @Override

onPushPromise

back to summary

public void onPushPromise(PushPromiseFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onPushPromise.

Annotations

@Override

onReset	back to summary
public void onReset(ResetFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onReset. Annotations @Override

onReset

back to summary

public void onReset(ResetFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onReset.

Annotations

@Override

onSettings	back to summary
public void onSettings(SettingsFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onSettings. Annotations @Override

onSettings

back to summary

public void onSettings(SettingsFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onSettings.

Annotations

@Override

onStreamFailure	back to summary
public void onStreamFailure(int streamId, int error, String reason) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onStreamFailure. Annotations @Override

onStreamFailure

back to summary

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

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onStreamFailure.

Annotations

@Override

onUpgradeTo back to summary

onUpgradeTo	back to summary
public void onUpgradeTo(ByteBuffer buffer) Implements org.eclipse.jetty.io.Connection.UpgradeTo.onUpgradeTo. Doc from 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. Parameters buffer: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. Annotations @Override

public void onUpgradeTo(ByteBuffer buffer)

Implements org.eclipse.jetty.io.Connection.UpgradeTo.onUpgradeTo.

Doc from 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.

Parameters

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

Annotations

@Override

onWindowUpdate	back to summary
public void onWindowUpdate(WindowUpdateFrame frame) Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onWindowUpdate. Annotations @Override

onWindowUpdate

back to summary

public void onWindowUpdate(WindowUpdateFrame frame)

Overrides default org.eclipse.jetty.http2.parser.Parser.Listener.onWindowUpdate.

Annotations

@Override

pollTask	back to summary
private Runnable pollTask()

produce	back to summary
protected void produce()

setUseInputDirectByteBuffers	back to summary
public void setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)

setUseOutputDirectByteBuffers	back to summary
public void setUseOutputDirectByteBuffers(boolean useOutputDirectByteBuffers)

org.eclipse.jetty.http2 back to summary

private Class HTTP2Connection.FillableCallback

Class Inheritance

extends Object
implements Callback

java.lang.Object
org.eclipse.jetty.http2.HTTP2Connection.FillableCallback

All Implemented Interfaces

org.eclipse.jetty.util.Callback, org.eclipse.jetty.util.thread.Invocable

Constructor Summary

Access	Constructor and Description
private	FillableCallback()

Method Summary

Modifier and Type	Method and Description
public void	failed(Throwable the reason for the operation failure x) Overrides default org.eclipse.jetty.util.Callback.failed. Callback invoked when the operation fails.
public Invocable.InvocationType	getInvocationType() Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType.
public void	succeeded() Overrides default org.eclipse.jetty.util.Callback.succeeded. Callback invoked when the operation completes.

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

Constructor Detail

FillableCallback	back to summary
private FillableCallback()

Method Detail

failed

back to summary

public void failed(Throwable x)

Overrides default org.eclipse.jetty.util.Callback.failed.

Doc from org.eclipse.jetty.util.Callback.failed.

Callback invoked when the operation fails.

Parameters

x:Throwable: the reason for the operation failure

Annotations

@Override

getInvocationType

back to summary

public Invocable.InvocationType getInvocationType()

Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType.

Returns:Invocable.InvocationType

Doc from org.eclipse.jetty.util.thread.Invocable.getInvocationType.

The InvocationType of this object

Annotations

@Override

succeeded

back to summary

public void succeeded()

Overrides default org.eclipse.jetty.util.Callback.succeeded.

Doc from org.eclipse.jetty.util.Callback.succeeded.

Callback invoked when the operation completes.

Annotations

@Override

org.eclipse.jetty.http2 back to summary

protected Class HTTP2Connection.HTTP2Producer

Class Inheritance

extends Object
implements Producer

java.lang.Object
org.eclipse.jetty.http2.HTTP2Connection.HTTP2Producer

All Implemented Interfaces

org.eclipse.jetty.util.thread.ExecutionStrategy.Producer

Field Summary

Modifier and Type	Field and Description
private boolean	failed
private final Callback	fillableCallback
private HTTP2Connection.NetworkBuffer	networkBuffer
private boolean	shutdown

Constructor Summary

Access	Constructor and Description
protected	HTTP2Producer()

Method Summary

Modifier and Type	Method and Description
private void	acquireNetworkBuffer()
public Runnable	produce() Implements org.eclipse.jetty.util.thread.ExecutionStrategy.Producer.produce. Produces a task to be executed.
private void	reacquireNetworkBuffer()
private void	releaseNetworkBuffer()
private void	setInputBuffer(ByteBuffer byteBuffer)
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

failed	back to summary
private boolean failed

fillableCallback	back to summary
private final Callback fillableCallback

networkBuffer	back to summary
private HTTP2Connection.NetworkBuffer networkBuffer

shutdown	back to summary
private boolean shutdown

Constructor Detail

HTTP2Producer	back to summary
protected HTTP2Producer()

Method Detail

acquireNetworkBuffer	back to summary
private void acquireNetworkBuffer()

produce

back to summary

public Runnable produce()

Implements org.eclipse.jetty.util.thread.ExecutionStrategy.Producer.produce.

Doc from org.eclipse.jetty.util.thread.ExecutionStrategy.Producer.produce.

Produces a task to be executed.

Returns:Runnable

a task to executed or null if there are no more tasks to execute

Annotations

@Override

reacquireNetworkBuffer	back to summary
private void reacquireNetworkBuffer()

releaseNetworkBuffer	back to summary
private void releaseNetworkBuffer()

setInputBuffer	back to summary
private void setInputBuffer(ByteBuffer byteBuffer)

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 Class HTTP2Connection.NetworkBuffer

Class Inheritance

extends Object
implements Retainable

java.lang.Object
org.eclipse.jetty.http2.HTTP2Connection.NetworkBuffer

All Implemented Interfaces

org.eclipse.jetty.io.Retainable

Field Summary

Modifier and Type	Field and Description
private final RetainableByteBuffer	delegate

Constructor Summary

Access	Constructor and Description
private	NetworkBuffer()

Method Summary

Modifier and Type	Method and Description
public boolean	canRetain() Overrides default org.eclipse.jetty.io.Retainable.canRetain. Returns whether this resource is referenced counted by calls to `retain()` and `release()`.
public ByteBuffer	getBuffer()
public boolean	hasRemaining()
public boolean	isRetained()
private void	put(ByteBuffer source)
public boolean	release() Overrides default org.eclipse.jetty.io.Retainable.release. Releases this resource, potentially decrementing a reference count (if any).
public void	retain() Overrides default org.eclipse.jetty.io.Retainable.retain. Retains this resource, potentially incrementing a reference count if there are resources that will be released.

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

Field Detail

delegate	back to summary
private final RetainableByteBuffer delegate

Constructor Detail

NetworkBuffer	back to summary
private NetworkBuffer()

Method Detail

canRetain back to summary

public boolean canRetain()

Overrides default org.eclipse.jetty.io.Retainable.canRetain.

Doc from org.eclipse.jetty.io.Retainable.canRetain.

Returns whether this resource is referenced counted by calls to retain() and release().

Implementations may decide that special resources are not not referenced counted (for example, static constants) so calling retain() is a no-operation, and calling release() on those special resources is a no-operation that always returns true.

Returns:boolean

true if calls to retain() are reference counted.

Annotations

@Override

getBuffer	back to summary
public ByteBuffer getBuffer()

hasRemaining	back to summary
public boolean hasRemaining()

isRetained	back to summary
public boolean isRetained()

put	back to summary
private void put(ByteBuffer source)

release back to summary

public boolean release()

Overrides default org.eclipse.jetty.io.Retainable.release.

Doc from org.eclipse.jetty.io.Retainable.release.

Releases this resource, potentially decrementing a reference count (if any).

Returns:boolean

true when the reference count goes to zero or if there was no reference count, false otherwise.

Annotations

@Override

retain

back to summary

public void retain()

Overrides default org.eclipse.jetty.io.Retainable.retain.

Doc from org.eclipse.jetty.io.Retainable.retain.

Retains this resource, potentially incrementing a reference count if there are resources that will be released.

Annotations

@Override

org.eclipse.jetty.http2 back to summary

private Class HTTP2Connection.StreamData

Class Inheritance

extends Data

java.lang.Object
org.eclipse.jetty.http2.api.Stream.Data
org.eclipse.jetty.http2.HTTP2Connection.StreamData

Field Summary

Modifier and Type	Field and Description
private final Retainable	retainable

Constructor Summary

Access	Constructor and Description
private	StreamData(DataFrame frame, Retainable retainable)

Method Summary

Modifier and Type	Method and Description
public boolean	canRetain() Overrides default org.eclipse.jetty.io.Retainable.canRetain. Returns whether this resource is referenced counted by calls to `retain()` and `release()`.
public boolean	release() Overrides default org.eclipse.jetty.io.Retainable.release. Releases this resource, potentially decrementing a reference count (if any).
public void	retain() Overrides default org.eclipse.jetty.io.Retainable.retain. Retains this resource, potentially incrementing a reference count if there are resources that will be released.