Class ForeignQuicheConnection

java.lang.Object

org.eclipse.jetty.quic.quiche.QuicheConnection

org.eclipse.jetty.quic.quiche.foreign.ForeignQuicheConnection

public class ForeignQuicheConnection
extends QuicheConnection

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.quic.quiche.QuicheConnection

QuicheConnection.CloseInfo, QuicheConnection.TokenMinter, QuicheConnection.TokenValidationException, QuicheConnection.TokenValidator

Method Summary

Modifier and Type	Method	Description
boolean	close(long error, String reason)
static ForeignQuicheConnection	connect(QuicheConfig quicheConfig, InetSocketAddress local, InetSocketAddress peer)
static ForeignQuicheConnection	connect(QuicheConfig quicheConfig, InetSocketAddress local, InetSocketAddress peer, int connectionIdLength)
void	dispose()
int	drainCipherBytes(ByteBuffer buffer)	Fill the given buffer with cipher text to be sent.
int	drainClearBytesForStream(long streamId, ByteBuffer buffer)
int	feedCipherBytes(ByteBuffer buffer, SocketAddress local, SocketAddress peer)	Read the buffer of cipher text coming from the network.
int	feedClearBytesForStream(long streamId, ByteBuffer buffer, boolean last)
static byte[]	fromPacket(ByteBuffer packet)
QuicheConnection.CloseInfo	getLocalCloseInfo()
String	getNegotiatedProtocol()
byte[]	getPeerCertificate()
QuicheConnection.CloseInfo	getRemoteCloseInfo()
boolean	isConnectionClosed()
boolean	isConnectionEstablished()
boolean	isDraining()
boolean	isStreamFinished(long streamId)
protected List<Long>	iterableStreamIds(boolean write)
int	maxLocalStreams()
static boolean	negotiate(QuicheConnection.TokenMinter tokenMinter, ByteBuffer packetRead, ByteBuffer packetToSend)
long	nextTimeout()
void	onTimeout()
void	shutdownStream(long streamId, boolean writeSide, long error)
static ForeignQuicheConnection	tryAccept(QuicheConfig quicheConfig, QuicheConnection.TokenValidator tokenValidator, ByteBuffer packetRead, SocketAddress local, SocketAddress peer)
long	windowCapacity()
long	windowCapacity(long streamId)

Methods inherited from class org.eclipse.jetty.quic.quiche.QuicheConnection

feedClearBytesForStream, feedFinForStream, readableStreamIds, writableStreamIds

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

fromPacket

public static byte[] fromPacket(ByteBuffer packet)

connect

public static ForeignQuicheConnection connect(QuicheConfig quicheConfig,
 InetSocketAddress local,
 InetSocketAddress peer)
                                       throws IOException

Throws:

IOException

connect

public static ForeignQuicheConnection connect(QuicheConfig quicheConfig,
 InetSocketAddress local,
 InetSocketAddress peer,
 int connectionIdLength)
                                       throws IOException

Throws:

IOException

negotiate

public static boolean negotiate(QuicheConnection.TokenMinter tokenMinter,
 ByteBuffer packetRead,
 ByteBuffer packetToSend)
                         throws IOException

Throws:

IOException

tryAccept

public static ForeignQuicheConnection tryAccept(QuicheConfig quicheConfig,
 QuicheConnection.TokenValidator tokenValidator,
 ByteBuffer packetRead,
 SocketAddress local,
 SocketAddress peer)
                                         throws IOException

Throws:

IOException

getPeerCertificate

public byte[] getPeerCertificate()

Specified by:

getPeerCertificate in class QuicheConnection

iterableStreamIds

protected List<Long> iterableStreamIds(boolean write)

Specified by:

iterableStreamIds in class QuicheConnection

feedCipherBytes

public int feedCipherBytes(ByteBuffer buffer,
 SocketAddress local,
 SocketAddress peer)
                    throws IOException

Description copied from class: QuicheConnection

Read the buffer of cipher text coming from the network.

Specified by:

feedCipherBytes in class QuicheConnection

Parameters:

buffer - the buffer to read.

local - the local address on which the buffer was received.

peer - the address of the peer from which the buffer was received.

Returns:

how many bytes were consumed.

Throws:

IOException

drainCipherBytes

public int drainCipherBytes(ByteBuffer buffer)
                     throws IOException

Description copied from class: QuicheConnection

Fill the given buffer with cipher text to be sent.

Specified by:

drainCipherBytes in class QuicheConnection

Parameters:

buffer - the buffer to fill.

Returns:

how many bytes were added to the buffer.

Throws:

IOException

isConnectionClosed

public boolean isConnectionClosed()

Specified by:

isConnectionClosed in class QuicheConnection

isConnectionEstablished

public boolean isConnectionEstablished()

Specified by:

isConnectionEstablished in class QuicheConnection

nextTimeout

public long nextTimeout()

Specified by:

nextTimeout in class QuicheConnection

onTimeout

public void onTimeout()

Specified by:

onTimeout in class QuicheConnection

getNegotiatedProtocol

public String getNegotiatedProtocol()

Specified by:

getNegotiatedProtocol in class QuicheConnection

close

public boolean close(long error,
 String reason)

Specified by:

close in class QuicheConnection

dispose

public void dispose()

Specified by:

dispose in class QuicheConnection

isDraining

public boolean isDraining()

Specified by:

isDraining in class QuicheConnection

maxLocalStreams

public int maxLocalStreams()

Specified by:

maxLocalStreams in class QuicheConnection

windowCapacity

public long windowCapacity()

Specified by:

windowCapacity in class QuicheConnection

windowCapacity

public long windowCapacity(long streamId)
                    throws IOException

Specified by:

windowCapacity in class QuicheConnection

Throws:

IOException

shutdownStream

public void shutdownStream(long streamId,
 boolean writeSide,
 long error)
                    throws IOException

Specified by:

shutdownStream in class QuicheConnection

Throws:

IOException

feedClearBytesForStream

public int feedClearBytesForStream(long streamId,
 ByteBuffer buffer,
 boolean last)
                            throws IOException

Specified by:

feedClearBytesForStream in class QuicheConnection

Throws:

IOException

drainClearBytesForStream

public int drainClearBytesForStream(long streamId,
 ByteBuffer buffer)
                             throws IOException

Specified by:

drainClearBytesForStream in class QuicheConnection

Throws:

IOException

isStreamFinished

public boolean isStreamFinished(long streamId)

Specified by:

isStreamFinished in class QuicheConnection

getRemoteCloseInfo

public QuicheConnection.CloseInfo getRemoteCloseInfo()

Specified by:

getRemoteCloseInfo in class QuicheConnection

getLocalCloseInfo

public QuicheConnection.CloseInfo getLocalCloseInfo()

Specified by:

getLocalCloseInfo in class QuicheConnection