Class JnaQuicheConnection

java.lang.Object

org.eclipse.jetty.quic.quiche.Quiche

org.eclipse.jetty.quic.quiche.jna.JnaQuicheConnection

public class JnaQuicheConnection
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 JnaQuicheConnection	connect(QuicheConfig quicheConfig, InetSocketAddress local, InetSocketAddress peer)
static JnaQuicheConnection	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)
void	enableQlog(String filename, String title, String desc)
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	isConnectionInEarlyData()
boolean	isDraining()
boolean	isStreamFinished(long streamId)
protected List<Long>	iterableStreamIds(boolean write)
int	maxLocalStreams()
static boolean	negotiate(Quiche.TokenMinter tokenMinter, ByteBuffer packetRead, ByteBuffer packetToSend)	Fully consumes the packetRead buffer.
long	nextTimeout()
void	onTimeout()
static byte	packetType(ByteBuffer packet)
static String	packetTypeAsString(ByteBuffer packet)
void	shutdownStream(long streamId, boolean writeSide, long error)
static JnaQuicheConnection	tryAccept(QuicheConfig quicheConfig, Quiche.TokenValidator tokenValidator, ByteBuffer packetRead, SocketAddress local, SocketAddress peer)	Fully consumes the packetRead buffer if the connection was accepted.
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 JnaQuicheConnection connect(QuicheConfig quicheConfig,
 InetSocketAddress local,
 InetSocketAddress peer)
                                   throws IOException

Throws:

IOException

connect

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

Throws:

IOException

packetTypeAsString

public static String packetTypeAsString(ByteBuffer packet)

packetType

public static byte packetType(ByteBuffer packet)

negotiate

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

Fully consumes the packetRead buffer.

Returns:

true if a negotiation packet was written to the packetToSend buffer, false if negotiation failed and the packetRead buffer can be dropped.

Throws:

IOException

tryAccept

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

Fully consumes the packetRead buffer if the connection was accepted.

Returns:

an established connection if accept succeeded, null if accept failed and negotiation should be tried.

Throws:

IOException

enableQlog

public void enableQlog(String filename,
 String title,
 String desc)
                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

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

isConnectionInEarlyData

public boolean isConnectionInEarlyData()

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