Represents an established stateful connection with a remote peer for a specific QUIC connection ID.

Differently from QuicSession, which is created during the initial phases of connection establishment and it is not specific to a protocol, ProtocolSession is created only when the connection is established, and it is protocol specific, depending on the protocol negotiated during the connection establishment.

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static interface	ProtocolSession.Factory A factory for protocol specific instances of `ProtocolSession`.
private class	ProtocolSession.StreamsProducer

Modifier and Type	Field and Description
private static final Logger	LOG Hides org.eclipse.jetty.util.component.ContainerLifeCycle.LOG.
private final ProtocolSession.StreamsProducer	producer
private final QuicSession	session
private final AdaptiveExecutionStrategy	strategy

Constructor Summary

Access	Constructor and Description
public	ProtocolSession(QuicSession session)

Method Summary

Modifier and Type	Method and Description
public long	getIdleTimeout()
public int	getMaxLocalStreams()
public QuicStreamEndPoint	getOrCreateStreamEndPoint(long streamId, Consumer<QuicStreamEndPoint> consumer)
public abstract Runnable	getProducerTask()
public QuicSession	getQuicSession()
public QuicStreamEndPoint	getStreamEndPoint(long streamId)
public void	inwardClose(long error, String reason)
public void	offer(Runnable task, boolean dispatch)
protected abstract void	onClose(long error, String reason)
protected void	onFailure(long error, String reason, Throwable failure)
protected boolean	onIdleTimeout()
protected abstract boolean	onReadable(long readableStreamId)
protected void	onWritable(long writableStreamId)
public void	openProtocolEndPoint(QuicStreamEndPoint endPoint)
public void	outwardClose(long error, String reason)
protected boolean	processReadableStreams()
protected void	processWritableStreams()
protected void	produce()
public CompletableFuture<Void>	shutdown()
public String	toString() Overrides org.eclipse.jetty.util.component.AbstractLifeCycle.toString. Returns a string representation of the object.

Field Detail

LOG	back to summary
private static final Logger LOG Hides org.eclipse.jetty.util.component.ContainerLifeCycle.LOG.

producer	back to summary
private final ProtocolSession.StreamsProducer producer

session	back to summary
private final QuicSession session

strategy	back to summary
private final AdaptiveExecutionStrategy strategy

Constructor Detail

ProtocolSession	back to summary
public ProtocolSession(QuicSession session)

Method Detail

getIdleTimeout	back to summary
public long getIdleTimeout()

getMaxLocalStreams	back to summary
public int getMaxLocalStreams()

getOrCreateStreamEndPoint	back to summary
public QuicStreamEndPoint getOrCreateStreamEndPoint(long streamId, Consumer<QuicStreamEndPoint> consumer)

getProducerTask	back to summary
public abstract Runnable getProducerTask()

getQuicSession	back to summary
public QuicSession getQuicSession()

getStreamEndPoint	back to summary
public QuicStreamEndPoint getStreamEndPoint(long streamId)

inwardClose	back to summary
public void inwardClose(long error, String reason)

offer	back to summary
public void offer(Runnable task, boolean dispatch)

onClose	back to summary
protected abstract void onClose(long error, String reason)

onFailure	back to summary
protected void onFailure(long error, String reason, Throwable failure)

onIdleTimeout	back to summary
protected boolean onIdleTimeout()

onReadable	back to summary
protected abstract boolean onReadable(long readableStreamId)

onWritable	back to summary
protected void onWritable(long writableStreamId)

openProtocolEndPoint	back to summary
public void openProtocolEndPoint(QuicStreamEndPoint endPoint)

outwardClose	back to summary
public void outwardClose(long error, String reason)

processReadableStreams	back to summary
protected boolean processReadableStreams()

processWritableStreams	back to summary
protected void processWritableStreams()

produce	back to summary
protected void produce()

shutdown	back to summary
public CompletableFuture<Void> shutdown()

toString back to summary

toString	back to summary
public String toString() Overrides org.eclipse.jetty.util.component.AbstractLifeCycle.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. Annotations @Override

public String toString()

Overrides org.eclipse.jetty.util.component.AbstractLifeCycle.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.

Annotations

@Override

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

public Interface ProtocolSession.Factory

A factory for protocol specific instances of ProtocolSession.

Method Summary

Modifier and Type	Method and Description
public ProtocolSession	newProtocolSession(QuicSession quicSession, Map<String, Object> context)

Method Detail

newProtocolSession	back to summary
public ProtocolSession newProtocolSession(QuicSession quicSession, Map<String, Object> context)

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

private Class ProtocolSession.StreamsProducer

Class Inheritance

extends Object
implements Producer

java.lang.Object
org.eclipse.jetty.quic.common.ProtocolSession.StreamsProducer

All Implemented Interfaces

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

Field Summary

Modifier and Type	Field and Description
private final AutoLock	lock
private final Queue<Runnable>	tasks

Constructor Summary

Access	Constructor and Description
private	StreamsProducer()

Method Summary

Modifier and Type	Method and Description
public void	offer(Runnable task)
private Runnable	poll()
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

Field Detail

lock	back to summary
private final AutoLock lock

tasks	back to summary
private final Queue<Runnable> tasks

Constructor Detail

StreamsProducer	back to summary
private StreamsProducer()

Method Detail

offer	back to summary
public void offer(Runnable task)

poll	back to summary
private Runnable poll()

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

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 ProtocolSession

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface ProtocolSession.Factory

Method Summary

Method Detail

private Class ProtocolSession.StreamsProducer

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail