Class JnaQuicheConnection

java.lang.Object

org.eclipse.jetty.quic.quiche.QuicheConnection

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

public class JnaQuicheConnection
extends QuicheConnection

Nested Class Summary

Nested classes/interfaces inherited from class QuicheConnection

QuicheConnection.CloseInfo, QuicheConnection.TokenMinter, QuicheConnection.TokenValidationException, QuicheConnection.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)
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)
QuicheConnection.CloseInfo	getLocalCloseInfo()
String	getNegotiatedProtocol()
byte[]	getPeerCertificate()
QuicheConnection.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(QuicheConnection.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, QuicheConnection.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 QuicheConnection

feedClearBytesForStream, feedFinForStream, readableStreamIds, writableStreamIds

Methods inherited from class 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(QuicheConnection.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,
 QuicheConnection.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 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

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

isConnectionInEarlyData

public boolean isConnectionInEarlyData()

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