Class ForeignQuicheConnection

java.lang.Object

org.eclipse.jetty.quic.quiche.Quiche

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

public class ForeignQuicheConnection
extends Quiche

Nested Class Summary

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

Quiche.CloseInfo, Quiche.TokenMinter, Quiche.TokenValidationException, Quiche.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, boolean[] last)
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)
Quiche.CloseInfo	getLocalCloseInfo()
String	getNegotiatedProtocol()
byte[]	getPeerCertificate()
Quiche.CloseInfo	getRemoteCloseInfo()
boolean	isConnectionClosed()
boolean	isConnectionEstablished()
boolean	isDraining()
boolean	isStreamFinished(long streamId)
protected List<Long>	iterableStreamIds(boolean write)
int	maxLocalStreams()
static boolean	negotiate(Quiche.TokenMinter tokenMinter, ByteBuffer packetRead, ByteBuffer packetToSend)
long	nextTimeout()
void	onTimeout()
void	shutdownStream(long streamId, boolean writeSide, long error)
static ForeignQuicheConnection	tryAccept(QuicheConfig quicheConfig, Quiche.TokenValidator tokenValidator, ByteBuffer packetRead, SocketAddress local, SocketAddress peer)
long	windowCapacity()
long	windowCapacity(long streamId)

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

feedClearBytesForStream, feedFinForStream, probeConnectionId, readableStreamIds, toInetSocketAddress, 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(Quiche.TokenMinter tokenMinter,
 ByteBuffer packetRead,
 ByteBuffer packetToSend)
                         throws IOException

Throws:

IOException

tryAccept

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

Throws:

IOException

getPeerCertificate

public byte[] getPeerCertificate()

Specified by:

getPeerCertificate in class Quiche

iterableStreamIds

protected List<Long> iterableStreamIds(boolean write)

Specified by:

iterableStreamIds in class Quiche

feedCipherBytes

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

Description copied from class: Quiche

Read the buffer of cipher text coming from the network.

Specified by:

feedCipherBytes in class Quiche

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: Quiche

Fill the given buffer with cipher text to be sent.

Specified by:

drainCipherBytes in class Quiche

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 Quiche

isConnectionEstablished

public boolean isConnectionEstablished()

Specified by:

isConnectionEstablished in class Quiche

nextTimeout

public long nextTimeout()

Specified by:

nextTimeout in class Quiche

onTimeout

public void onTimeout()

Specified by:

onTimeout in class Quiche

getNegotiatedProtocol

public String getNegotiatedProtocol()

Specified by:

getNegotiatedProtocol in class Quiche

close

public boolean close(long error,
 String reason)

Specified by:

close in class Quiche

dispose

public void dispose()

Specified by:

dispose in class Quiche

isDraining

public boolean isDraining()

Specified by:

isDraining in class Quiche

maxLocalStreams

public int maxLocalStreams()

Specified by:

maxLocalStreams in class Quiche

windowCapacity

public long windowCapacity()

Specified by:

windowCapacity in class Quiche

windowCapacity

public long windowCapacity(long streamId)
                    throws IOException

Specified by:

windowCapacity in class Quiche

Throws:

IOException

shutdownStream

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

Specified by:

shutdownStream in class Quiche

Throws:

IOException

feedClearBytesForStream

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

Specified by:

feedClearBytesForStream in class Quiche

Throws:

IOException

drainClearBytesForStream

public int drainClearBytesForStream(long streamId,
 ByteBuffer buffer,
 boolean[] last)
                             throws IOException

Specified by:

drainClearBytesForStream in class Quiche

Throws:

IOException

isStreamFinished

public boolean isStreamFinished(long streamId)

Specified by:

isStreamFinished in class Quiche

Parameters:

streamId - the stream id

Returns:

whether all the data has been read from the specified stream.

getRemoteCloseInfo

public Quiche.CloseInfo getRemoteCloseInfo()

Specified by:

getRemoteCloseInfo in class Quiche

getLocalCloseInfo

public Quiche.CloseInfo getLocalCloseInfo()

Specified by:

getLocalCloseInfo in class Quiche