Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	QuicConnection.FillableCallback
private class	QuicConnection.Flusher
private class	QuicConnection.QuicProducer

Field Summary

Modifier and Type	Field and Description
private final ByteBufferPool	bufferPool
private final AtomicBoolean	closed
private final Callback	fillableCallback
private final QuicConnection.Flusher	flusher
private final List<QuicSession.Listener>	listeners
private static final Logger	LOG Hides org.eclipse.jetty.io.AbstractConnection.LOG.
private int	outputBufferSize
private final Scheduler	scheduler
private final ConcurrentMap<QuicheConnectionId, QuicSession>	sessions
private final AdaptiveExecutionStrategy	strategy
private boolean	useInputDirectByteBuffers
private boolean	useOutputDirectByteBuffers

Access	Constructor and Description
protected	QuicConnection(Executor executor, Scheduler scheduler, ByteBufferPool bufferPool, EndPoint endPoint)

Method Summary

Modifier and Type	Method and Description
public void	addEventListener(EventListener listener) Overrides org.eclipse.jetty.io.AbstractConnection.addEventListener. Implements org.eclipse.jetty.io.Connection.addEventListener. Adds a listener of connection events.
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 abstract QuicSession	createSession(SocketAddress remoteAddress, ByteBuffer cipherBuffer)
public void	fillInterested() Overrides org.eclipse.jetty.io.AbstractConnection.fillInterested. Utility method to be called to register read interest.
public ByteBufferPool	getByteBufferPool()
public DatagramChannelEndPoint	getEndPoint() Overrides org.eclipse.jetty.io.AbstractConnection.getEndPoint. Implements org.eclipse.jetty.io.Connection.getEndPoint.
public int	getOutputBufferSize()
public Collection<QuicSession>	getQuicSessions()
public Scheduler	getScheduler()
public boolean	isUseInputDirectByteBuffers()
public boolean	isUseOutputDirectByteBuffers()
public void	onClose(Throwable cause) Overrides org.eclipse.jetty.io.AbstractConnection.onClose. Implements org.eclipse.jetty.io.Connection.onClose. Callback method invoked when this connection is closed.
protected void	onFailure(Throwable failure)
public void	onFillable() Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable. Callback method invoked when the endpoint is ready to be read.
public abstract boolean	onIdleExpired(TimeoutException timeoutException) Redeclares org.eclipse.jetty.io.Connection.onIdleExpired. Overrides org.eclipse.jetty.io.AbstractConnection.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	outwardClose(QuicSession session, Throwable failure)
private Runnable	process(QuicSession session, SocketAddress remoteAddress, ByteBuffer cipherBuffer)
private Runnable	receiveAndProcess()
public void	removeEventListener(EventListener listener) Overrides org.eclipse.jetty.io.AbstractConnection.removeEventListener. Implements org.eclipse.jetty.io.Connection.removeEventListener. Removes a listener of connection events.
public void	setOutputBufferSize(int outputBufferSize)
public void	setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)
public void	setUseOutputDirectByteBuffers(boolean useOutputDirectByteBuffers)
public void	write(Callback callback, SocketAddress remoteAddress, ByteBuffer... buffers)

Inherited from org.eclipse.jetty.io.AbstractConnection:: failedCallback getBytesIn getBytesOut getCreatedTimeStamp getExecutor getInputBufferSize getInvocationType getMessagesIn getMessagesOut isFillInterested onFillInterestedFailed onReadTimeout setInputBufferSize toConnectionString toString tryFillInterested

Field Detail

bufferPool	back to summary
private final ByteBufferPool bufferPool

closed	back to summary
private final AtomicBoolean closed

fillableCallback	back to summary
private final Callback fillableCallback

flusher	back to summary
private final QuicConnection.Flusher flusher

listeners	back to summary
private final List<QuicSession.Listener> listeners

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

outputBufferSize	back to summary
private int outputBufferSize

scheduler	back to summary
private final Scheduler scheduler

sessions	back to summary
private final ConcurrentMap<QuicheConnectionId, QuicSession> sessions

strategy	back to summary
private final AdaptiveExecutionStrategy strategy

useInputDirectByteBuffers	back to summary
private boolean useInputDirectByteBuffers

useOutputDirectByteBuffers	back to summary
private boolean useOutputDirectByteBuffers

QuicConnection	back to summary
protected QuicConnection(Executor executor, Scheduler scheduler, ByteBufferPool bufferPool, EndPoint endPoint)

Method Detail

addEventListener	back to summary
public void addEventListener(EventListener listener) Overrides org.eclipse.jetty.io.AbstractConnection.addEventListener. Implements org.eclipse.jetty.io.Connection.addEventListener. Doc from org.eclipse.jetty.io.Connection.addEventListener. Adds a listener of connection events. Annotations @Override

addEventListener

back to summary

public void addEventListener(EventListener listener)

Overrides org.eclipse.jetty.io.AbstractConnection.addEventListener.

Implements org.eclipse.jetty.io.Connection.addEventListener.

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

Adds a listener of connection events.

Annotations

@Override

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

createSession	back to summary
protected abstract QuicSession createSession(SocketAddress remoteAddress, ByteBuffer cipherBuffer) throws IOException

fillInterested back to summary

fillInterested	back to summary
public void fillInterested() Overrides org.eclipse.jetty.io.AbstractConnection.fillInterested. Doc from org.eclipse.jetty.io.AbstractConnection.fillInterested. Utility method to be called to register read interest. After a call to this method, `onFillable()` or `onFillInterestedFailed(Throwable)` will be called back as appropriate. Annotations @Override

public void fillInterested()

Overrides org.eclipse.jetty.io.AbstractConnection.fillInterested.

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

Utility method to be called to register read interest.

After a call to this method, onFillable() or onFillInterestedFailed(Throwable) will be called back as appropriate.

Annotations

@Override

getByteBufferPool	back to summary
public ByteBufferPool getByteBufferPool()

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

getEndPoint

back to summary

public DatagramChannelEndPoint getEndPoint()

Overrides org.eclipse.jetty.io.AbstractConnection.getEndPoint.

Implements org.eclipse.jetty.io.Connection.getEndPoint.

Annotations

@Override

getOutputBufferSize	back to summary
public int getOutputBufferSize()

getQuicSessions	back to summary
public Collection<QuicSession> getQuicSessions()

getScheduler	back to summary
public Scheduler getScheduler()

isUseInputDirectByteBuffers	back to summary
public boolean isUseInputDirectByteBuffers()

isUseOutputDirectByteBuffers	back to summary
public boolean isUseOutputDirectByteBuffers()

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

Annotations

@Override

onFailure	back to summary
protected void onFailure(Throwable failure)

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

onIdleExpired	back to summary
public abstract boolean onIdleExpired(TimeoutException timeoutException) Redeclares org.eclipse.jetty.io.Connection.onIdleExpired. Overrides org.eclipse.jetty.io.AbstractConnection.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. Annotations @Override

onIdleExpired

back to summary

public abstract boolean onIdleExpired(TimeoutException timeoutException)

Redeclares org.eclipse.jetty.io.Connection.onIdleExpired.

Overrides org.eclipse.jetty.io.AbstractConnection.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.

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

outwardClose	back to summary
public void outwardClose(QuicSession session, Throwable failure)

process	back to summary
private Runnable process(QuicSession session, SocketAddress remoteAddress, ByteBuffer cipherBuffer)

receiveAndProcess	back to summary
private Runnable receiveAndProcess()

removeEventListener	back to summary
public void removeEventListener(EventListener listener) Overrides org.eclipse.jetty.io.AbstractConnection.removeEventListener. Implements org.eclipse.jetty.io.Connection.removeEventListener. Doc from org.eclipse.jetty.io.Connection.removeEventListener. Removes a listener of connection events. Annotations @Override

removeEventListener

back to summary

public void removeEventListener(EventListener listener)

Overrides org.eclipse.jetty.io.AbstractConnection.removeEventListener.

Implements org.eclipse.jetty.io.Connection.removeEventListener.

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

Removes a listener of connection events.

Annotations

@Override

setOutputBufferSize	back to summary
public void setOutputBufferSize(int outputBufferSize)

setUseInputDirectByteBuffers	back to summary
public void setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers)

setUseOutputDirectByteBuffers	back to summary
public void setUseOutputDirectByteBuffers(boolean useOutputDirectByteBuffers)

write	back to summary
public void write(Callback callback, SocketAddress remoteAddress, ByteBuffer... buffers)

org.eclipse.jetty.quic.common back to summary

private Class QuicConnection.FillableCallback

Class Inheritance

extends Object
implements Callback

java.lang.Object
org.eclipse.jetty.quic.common.QuicConnection.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 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. Annotations @Override

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.

Annotations

@Override

getInvocationType	back to summary
public Invocable.InvocationType getInvocationType() Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType. Annotations @Override

getInvocationType

back to summary

public Invocable.InvocationType getInvocationType()

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

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

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.quic.common back to summary

private Class QuicConnection.Flusher

Class Inheritance

extends IteratingCallback

java.lang.Object
org.eclipse.jetty.util.IteratingCallback
org.eclipse.jetty.quic.common.QuicConnection.Flusher

Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	QuicConnection.Flusher.Entry

Field Summary

Modifier and Type	Field and Description
private QuicConnection.Flusher.Entry	entry
private final AutoLock	lock
private final ArrayDeque<QuicConnection.Flusher.Entry>	queue

Constructor Summary

Access	Constructor and Description
private	Flusher()

Method Summary

Modifier and Type	Method and Description
public void	failed(Throwable x) Overrides org.eclipse.jetty.util.IteratingCallback.failed. Overrides default org.eclipse.jetty.util.Callback.failed. Method to invoke when the asynchronous sub-task fails, or to fail the overall asynchronous task and therefore terminate the iteration.
public Invocable.InvocationType	getInvocationType() Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType.
public void	offer(Callback callback, SocketAddress address, ByteBuffer[] buffers)
protected void	onCompleteFailure(Throwable cause) Overrides org.eclipse.jetty.util.IteratingCallback.onCompleteFailure. Invoked when the overall task has completed with a failure.
protected IteratingCallback.Action	process() Implements abstract org.eclipse.jetty.util.IteratingCallback.process. Method called by `iterate()` to process the asynchronous sub-task.
public void	succeeded() Overrides org.eclipse.jetty.util.IteratingCallback.succeeded. Overrides default org.eclipse.jetty.util.Callback.succeeded. Method to invoke when the asynchronous sub-task succeeds.

Inherited from org.eclipse.jetty.util.IteratingCallback:: abort close isAborted isClosed isFailed isSucceeded iterate onCompleteSuccess reset toString

Field Detail

entry	back to summary
private QuicConnection.Flusher.Entry entry

lock	back to summary
private final AutoLock lock

queue	back to summary
private final ArrayDeque<QuicConnection.Flusher.Entry> queue

Constructor Detail

Flusher	back to summary
private Flusher()

Method Detail

failed back to summary

public void failed(Throwable x)

Overrides org.eclipse.jetty.util.IteratingCallback.failed.

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

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

Method to invoke when the asynchronous sub-task fails, or to fail the overall asynchronous task and therefore terminate the iteration.

Subclasses that override this method must always remember to call super.failed(Throwable).

Eventually, onCompleteFailure(Throwable) is called, either by the caller thread or by the processing thread.

Annotations

@Override

getInvocationType

back to summary

public Invocable.InvocationType getInvocationType()

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

Annotations

@Override

offer	back to summary
public void offer(Callback callback, SocketAddress address, ByteBuffer[] buffers)

onCompleteFailure

back to summary

protected void onCompleteFailure(Throwable cause)

Overrides org.eclipse.jetty.util.IteratingCallback.onCompleteFailure.

Doc from org.eclipse.jetty.util.IteratingCallback.onCompleteFailure.

Invoked when the overall task has completed with a failure.

Annotations

@Override

process back to summary

protected IteratingCallback.Action process()

Implements abstract org.eclipse.jetty.util.IteratingCallback.process.

Doc from org.eclipse.jetty.util.IteratingCallback.process.

Method called by iterate() to process the asynchronous sub-task.

Implementations must initiate the asynchronous execution of the sub-task (if any) and return an appropriate action:

Action#IDLE when no sub tasks are available for execution but the overall job is not completed yet
Action#SCHEDULED when the sub task asynchronous execution has been started
Action#SUCCEEDED when the overall job is completed

Annotations

@Override

succeeded back to summary

public void succeeded()

Overrides org.eclipse.jetty.util.IteratingCallback.succeeded.

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

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

Method to invoke when the asynchronous sub-task succeeds.

Subclasses that override this method must always remember to call super.succeeded().

Annotations

@Override

org.eclipse.jetty.quic.common back to summary

private Class QuicConnection.Flusher.Entry

Class Inheritance

extends Object

java.lang.Object
org.eclipse.jetty.quic.common.QuicConnection.Flusher.Entry

Field Summary

Modifier and Type	Field and Description
private final SocketAddress	address
private final ByteBuffer[]	buffers
private final Callback	callback

Constructor Summary

Access	Constructor and Description
private	Entry(Callback callback, SocketAddress address, ByteBuffer[] buffers)

Method Summary

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

Field Detail

address	back to summary
private final SocketAddress address

buffers	back to summary
private final ByteBuffer[] buffers

callback	back to summary
private final Callback callback

Constructor Detail

Entry	back to summary
private Entry(Callback callback, SocketAddress address, ByteBuffer[] buffers)

org.eclipse.jetty.quic.common back to summary

private Class QuicConnection.QuicProducer

Class Inheritance

extends Object
implements Producer

java.lang.Object
org.eclipse.jetty.quic.common.QuicConnection.QuicProducer

All Implemented Interfaces

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

Constructor Summary

Access	Constructor and Description
private	QuicProducer()

Method Summary

Modifier and Type	Method and Description
public Runnable	produce() Implements org.eclipse.jetty.util.thread.ExecutionStrategy.Producer.produce. Produces a task to be executed.

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

Constructor Detail

QuicProducer	back to summary
private QuicProducer()

Method Detail

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.

Annotations

@Override

public abstract Class QuicConnection

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class QuicConnection.FillableCallback

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private Class QuicConnection.Flusher

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class QuicConnection.Flusher.Entry

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

private Class QuicConnection.QuicProducer

Constructor Summary

Method Summary

Constructor Detail

Method Detail