Top Description Fields Constructors Methods
org.eclipse.jetty.quic.common

public Class QuicStreamEndPoint

extends AbstractEndPoint
Class Inheritance
Imports
java.io.IOException, java.net.SocketAddress, java.nio.ByteBuffer, java.util.List, java.util.stream.IntStream, org.eclipse.jetty.io.AbstractEndPoint, .Connection, .EndPoint, .FillInterest, .WriteFlusher, org.eclipse.jetty.util.BufferUtil, .Callback, org.eclipse.jetty.util.thread.Scheduler, org.slf4j.Logger, .LoggerFactory

An EndPoint implementation on top of a QUIC stream.

The correspondent Connection associated to this QuicStreamEndPoint parses and generates the protocol specific bytes transported by QUIC.

Field Summary

Modifier and TypeField and Description
private static final ByteBuffer
LAST_FLAG

private static final Logger
LOG

Hides org.eclipse.jetty.io.AbstractEndPoint.LOG.

private final QuicSession
session

private final long
streamId

Constructor Summary

AccessConstructor and Description
public
QuicStreamEndPoint(Scheduler scheduler, QuicSession session, long streamId)

Method Summary

Modifier and TypeMethod and Description
public void
close(long error, Throwable failure)

public void
closed(Throwable failure)

public int
fill(ByteBuffer buffer)

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

Fill the passed buffer with data from this endpoint.

public void
fillInterested(Callback callback)

Overrides org.eclipse.jetty.io.AbstractEndPoint.fillInterested.

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

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

Flush data from the passed header/buffer to this endpoint.

public SocketAddress
getLocalSocketAddress()

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

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.getLocalSocketAddress.

public QuicSession
getQuicSession()

public SocketAddress
getRemoteSocketAddress()

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

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.getRemoteSocketAddress.

public long
getStreamId()

public Object
getTransport()

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

public boolean
isStreamFinished()

protected void
needsFillInterest()

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.needsFillInterest.

public void
onClose(Throwable failure)

Overrides org.eclipse.jetty.io.AbstractEndPoint.onClose.

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

Callback method invoked when this EndPoint is closed.

protected void
onIncompleteFlush()

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.onIncompleteFlush.

public boolean
onReadable()

Returns: whether this endPoint is interested in reads

public void
onWritable()

public void
opened()

public void
shutdownInput(long error)

public void
shutdownOutput(long error)

public String
toString()

Overrides org.eclipse.jetty.io.AbstractEndPoint.toString.

Returns a string representation of the object.

public boolean
tryFillInterested(Callback callback)

Overrides org.eclipse.jetty.io.AbstractEndPoint.tryFillInterested.

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
write(Callback callback, List<ByteBuffer> buffers, boolean last)

Inherited from org.eclipse.jetty.io.AbstractEndPoint:
closeclosedoClosedoShutdownInputdoShutdownOutputgetConnectiongetCreatedTimeStampgetFillInterestgetLocalAddressgetRemoteAddressgetWriteFlusherisFillInterestedisInputShutdownisOpenisOutputShutdownonCloseonIdleExpiredonOpenresetsetConnectionshutdownInputshutdownOutputtoConnectionStringtoEndPointStringupgradewrite

Field Detail

LAST_FLAGback to summary
private static final ByteBuffer LAST_FLAG
LOGback to summary
private static final Logger LOG

Hides org.eclipse.jetty.io.AbstractEndPoint.LOG.

sessionback to summary
private final QuicSession session
streamIdback to summary
private final long streamId

Constructor Detail

QuicStreamEndPointback to summary
public QuicStreamEndPoint(Scheduler scheduler, QuicSession session, long streamId)

Method Detail

closeback to summary
public void close(long error, Throwable failure)
closedback to summary
public void closed(Throwable failure)
fillback to summary
public int fill(ByteBuffer buffer) 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.

Annotations
@Override
Exceptions
IOException:
if the endpoint is closed.
fillInterestedback to summary
public void fillInterested(Callback callback)

Overrides org.eclipse.jetty.io.AbstractEndPoint.fillInterested.

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.

Annotations
@Override
flushback 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.

Annotations
@Override
Exceptions
IOException:
If the endpoint is closed or output is shutdown.
getLocalSocketAddressback to summary
public SocketAddress getLocalSocketAddress()

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

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.getLocalSocketAddress.

Annotations
@Override
getQuicSessionback to summary
public QuicSession getQuicSession()
getRemoteSocketAddressback to summary
public SocketAddress getRemoteSocketAddress()

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

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.getRemoteSocketAddress.

Annotations
@Override
getStreamIdback to summary
public long getStreamId()
getTransportback to summary
public Object getTransport()

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

Annotations
@Override
isStreamFinishedback to summary
public boolean isStreamFinished()
needsFillInterestback to summary
protected void needsFillInterest()

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.needsFillInterest.

Annotations
@Override
onCloseback to summary
public void onClose(Throwable failure)

Overrides org.eclipse.jetty.io.AbstractEndPoint.onClose.

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

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

Callback method invoked when this EndPoint is closed.

Annotations
@Override
onIncompleteFlushback to summary
protected void onIncompleteFlush()

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.onIncompleteFlush.

Annotations
@Override
onReadableback to summary
public boolean onReadable()
Returns:boolean

whether this endPoint is interested in reads

onWritableback to summary
public void onWritable()
openedback to summary
public void opened()
shutdownInputback to summary
public void shutdownInput(long error)
shutdownOutputback to summary
public void shutdownOutput(long error)
toStringback to summary
public String toString()

Overrides org.eclipse.jetty.io.AbstractEndPoint.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
tryFillInterestedback to summary
public boolean tryFillInterested(Callback callback)

Overrides org.eclipse.jetty.io.AbstractEndPoint.tryFillInterested.

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.

Annotations
@Override
writeback to summary
public void write(Callback callback, List<ByteBuffer> buffers, boolean last)