Safe Haskell	Safe-Inferred
Language	Haskell2010

Network.QUIC.Internal

Contents

Types
Encode
Decode
Frame
Header
Token
Types
Misc
Reass
Table

Synopsis

data Hooks = Hooks {
- onCloseCompleted :: IO ()
- onPlainCreated :: EncryptionLevel -> Plain -> Plain
- onTransportParametersCreated :: Parameters -> Parameters
- onTLSExtensionCreated :: [ExtensionRaw] -> [ExtensionRaw]
- onTLSHandshakeCreated :: [(EncryptionLevel, CryptoData)] -> ([(EncryptionLevel, CryptoData)], Bool)
- onResetStreamReceived :: Stream -> ApplicationProtocolError -> IO ()
- onServerReady :: IO ()
}
defaultHooks :: Hooks
data ClientConfig = ClientConfig {
- ccVersion :: Version
- ccVersions :: [Version]
- ccCiphers :: [Cipher]
- ccGroups :: [Group]
- ccParameters :: Parameters
- ccKeyLog :: String -> IO ()
- ccQLog :: Maybe FilePath
- ccCredentials :: Credentials
- ccHooks :: Hooks
- ccTlsHooks :: ClientHooks
- ccUse0RTT :: Bool
- ccServerName :: HostName
- ccPortName :: ServiceName
- ccALPN :: Version -> IO (Maybe [ByteString])
- ccValidate :: Bool
- ccResumption :: ResumptionInfo
- ccPacketSize :: Maybe Int
- ccDebugLog :: Bool
- ccAutoMigration :: Bool
}
defaultClientConfig :: ClientConfig
data ServerConfig = ServerConfig {
- scVersions :: [Version]
- scCiphers :: [Cipher]
- scGroups :: [Group]
- scParameters :: Parameters
- scKeyLog :: String -> IO ()
- scQLog :: Maybe FilePath
- scCredentials :: Credentials
- scHooks :: Hooks
- scTlsHooks :: ServerHooks
- scUse0RTT :: Bool
- scAddresses :: [(IP, PortNumber)]
- scALPN :: Maybe (Version -> [ByteString] -> IO ByteString)
- scRequireRetry :: Bool
- scSessionManager :: SessionManager
- scDebugLog :: Maybe FilePath
- scTicketLifetime :: Int
}
defaultServerConfig :: ServerConfig
nextPacketNumber :: Connection -> IO PacketNumber
setPeerPacketNumber :: Connection -> PacketNumber -> IO ()
getPeerPacketNumber :: Connection -> IO PacketNumber
setEncryptionLevel :: Connection -> EncryptionLevel -> IO ()
waitEncryptionLevel :: Connection -> EncryptionLevel -> IO ()
putOffCrypto :: Connection -> EncryptionLevel -> ReceivedPacket -> IO ()
getCipher :: Connection -> EncryptionLevel -> IO Cipher
setCipher :: Connection -> EncryptionLevel -> Cipher -> IO ()
getTLSMode :: Connection -> IO HandshakeMode13
getApplicationProtocol :: Connection -> IO (Maybe NegotiatedProtocol)
setNegotiated :: Connection -> HandshakeMode13 -> Maybe NegotiatedProtocol -> ApplicationSecretInfo -> IO ()
dropSecrets :: Connection -> EncryptionLevel -> IO ()
initializeCoder :: Connection -> EncryptionLevel -> TrafficSecrets a -> IO ()
initializeCoder1RTT :: Connection -> TrafficSecrets ApplicationSecret -> IO ()
updateCoder1RTT :: Connection -> Bool -> IO ()
getCoder :: Connection -> EncryptionLevel -> Bool -> IO Coder
getProtector :: Connection -> EncryptionLevel -> IO Protector
getCurrentKeyPhase :: Connection -> IO (Bool, PacketNumber)
setCurrentKeyPhase :: Connection -> Bool -> PacketNumber -> IO ()
getMyCID :: Connection -> IO CID
getMyCIDs :: Connection -> IO [CID]
getPeerCID :: Connection -> IO CID
isMyCID :: Connection -> CID -> IO Bool
myCIDsInclude :: Connection -> CID -> IO (Maybe Int)
shouldUpdateMyCID :: Connection -> Int -> IO Bool
shouldUpdatePeerCID :: Connection -> IO Bool
resetPeerCID :: Connection -> CID -> IO ()
getNewMyCID :: Connection -> IO CIDInfo
getMyCIDSeqNum :: Connection -> IO Int
setMyCID :: Connection -> CID -> IO ()
setPeerCIDAndRetireCIDs :: Connection -> Int -> IO [Int]
retirePeerCID :: Connection -> Int -> IO ()
retireMyCID :: Connection -> Int -> IO (Maybe CIDInfo)
addPeerCID :: Connection -> CIDInfo -> IO Bool
waitPeerCID :: Connection -> IO CIDInfo
choosePeerCIDForPrivacy :: Connection -> IO ()
setPeerStatelessResetToken :: Connection -> StatelessResetToken -> IO ()
isStatelessRestTokenValid :: Connection -> CID -> StatelessResetToken -> IO Bool
setMigrationStarted :: Connection -> IO ()
isPathValidating :: Connection -> IO Bool
checkResponse :: Connection -> PathData -> IO ()
validatePath :: Connection -> Maybe CIDInfo -> IO ()
setVersionInfo :: Connection -> VersionInfo -> IO ()
getVersionInfo :: Connection -> IO VersionInfo
setVersion :: Connection -> Version -> IO ()
getVersion :: Connection -> IO Version
getOriginalVersion :: Connection -> Version
getSocket :: Connection -> IO UDPSocket
setSocket :: Connection -> UDPSocket -> IO UDPSocket
clearSocket :: Connection -> IO UDPSocket
getPeerAuthCIDs :: Connection -> IO AuthCIDs
setPeerAuthCIDs :: Connection -> (AuthCIDs -> AuthCIDs) -> IO ()
getClientDstCID :: Connection -> IO CID
getMyParameters :: Connection -> Parameters
getPeerParameters :: Connection -> IO Parameters
setPeerParameters :: Connection -> Parameters -> IO ()
delayedAck :: Connection -> IO ()
resetDealyedAck :: Connection -> IO ()
setMaxPacketSize :: Connection -> Int -> IO ()
addReader :: Connection -> ThreadId -> IO ()
killReaders :: Connection -> IO ()
addResource :: Connection -> IO () -> IO ()
freeResources :: Connection -> IO ()
readMinIdleTimeout :: Connection -> IO Microseconds
setMinIdleTimeout :: Connection -> Microseconds -> IO ()
sendFrames :: Connection -> EncryptionLevel -> [Frame] -> IO ()
sendFramesLim :: Connection -> EncryptionLevel -> [Frame] -> IO ()
closeConnection :: TransportError -> ReasonPhrase -> IO ()
abortConnection :: Connection -> ApplicationProtocolError -> ReasonPhrase -> IO ()
setConnection0RTTReady :: Connection -> IO ()
isConnection1RTTReady :: Connection -> IO Bool
setConnection1RTTReady :: Connection -> IO ()
isConnectionEstablished :: Connector a => a -> IO Bool
setConnectionEstablished :: Connection -> IO ()
wait0RTTReady :: Connection -> IO ()
wait1RTTReady :: Connection -> IO ()
waitEstablished :: Connection -> IO ()
readConnectionFlowTx :: Connection -> STM TxFlow
addTxData :: Connection -> Int -> STM ()
setTxMaxData :: Connection -> Int -> IO ()
getRxMaxData :: Connection -> IO Int
updateFlowRx :: Connection -> Int -> IO (Maybe Int)
checkRxMaxData :: Connection -> Int -> IO Bool
addTxBytes :: Connection -> Int -> IO ()
getTxBytes :: Connection -> IO Int
addRxBytes :: Connection -> Int -> IO ()
getRxBytes :: Connection -> IO Int
setAddressValidated :: Connection -> IO ()
waitAntiAmplificationFree :: Connection -> Int -> IO ()
checkAntiAmplificationFree :: Connection -> Int -> IO Bool
getMyStreamId :: Connection -> IO Int
possibleMyStreams :: Connection -> IO Int
waitMyNewStreamId :: Connection -> IO StreamId
waitMyNewUniStreamId :: Connection -> IO StreamId
setTxMaxStreams :: Connection -> Int -> IO ()
setTxUniMaxStreams :: Connection -> Int -> IO ()
checkRxMaxStreams :: Connection -> StreamId -> IO Bool
updatePeerStreamId :: Connection -> StreamId -> IO ()
checkStreamIdRoom :: Connection -> Direction -> IO (Maybe Int)
createStream :: Connection -> StreamId -> IO Stream
findStream :: Connection -> StreamId -> IO (Maybe Stream)
addStream :: Connection -> StreamId -> IO Stream
delStream :: Connection -> Stream -> IO ()
initialRxMaxStreamData :: Connection -> StreamId -> Int
setupCryptoStreams :: Connection -> IO ()
clearCryptoStream :: Connection -> EncryptionLevel -> IO ()
getCryptoStream :: Connection -> EncryptionLevel -> IO (Maybe Stream)
takeInput :: Connection -> IO Input
putInput :: Connection -> Input -> IO ()
takeCrypto :: Connection -> IO Crypto
putCrypto :: Connection -> Crypto -> IO ()
takeOutputSTM :: Connection -> STM Output
tryTakeOutput :: Connection -> IO (Maybe Output)
tryPeekOutput :: Connection -> IO (Maybe Output)
putOutput :: Connection -> Output -> IO ()
outputLimit :: Int
putOutputLim :: Connection -> Output -> IO ()
takeOutput1STM :: Connection -> STM Output
takeSendStreamQ :: Connection -> IO TxStreamData
takeSendStreamQSTM :: Connection -> STM TxStreamData
tryPeekSendStreamQ :: Connection -> IO (Maybe TxStreamData)
putSendStreamQ :: Connection -> TxStreamData -> IO ()
readMigrationQ :: Connection -> IO ReceivedPacket
writeMigrationQ :: Connection -> ReceivedPacket -> IO ()
setToken :: Connection -> Token -> IO ()
getToken :: Connection -> IO Token
getResumptionInfo :: Connection -> IO ResumptionInfo
setRetried :: Connection -> Bool -> IO ()
getRetried :: Connection -> IO Bool
setIncompatibleVN :: Connection -> Bool -> IO ()
getIncompatibleVN :: Connection -> IO Bool
setResumptionSession :: Connection -> SessionEstablish
setNewToken :: Connection -> Token -> IO ()
setRegister :: Connection -> (CID -> Connection -> IO ()) -> (CID -> IO ()) -> IO ()
getRegister :: Connection -> IO (CID -> Connection -> IO ())
getUnregister :: Connection -> IO (CID -> IO ())
setTokenManager :: Connection -> TokenManager -> IO ()
getTokenManager :: Connection -> IO TokenManager
setBaseThreadId :: Connection -> ThreadId -> IO ()
getBaseThreadId :: Connection -> IO ThreadId
setCertificateChain :: Connection -> Maybe CertificateChain -> IO ()
getCertificateChain :: Connection -> IO (Maybe CertificateChain)
timeout :: Microseconds -> String -> IO a -> IO (Maybe a)
fire :: Connection -> Microseconds -> TimeoutCallback -> IO ()
cfire :: Connection -> Microseconds -> TimeoutCallback -> IO (IO ())
delay :: Microseconds -> IO ()
dummySecrets :: TrafficSecrets a
data RoleInfo
- = ClientInfo {
  - clientInitialToken :: Token
  - resumptionInfo :: ResumptionInfo
  - incompatibleVN :: Bool
  }
- | ServerInfo {
  - tokenManager :: ~TokenManager
  - registerCID :: CID -> Connection -> IO ()
  - unregisterCID :: CID -> IO ()
  - askRetry :: Bool
  - baseThreadId :: ~ThreadId
  - certChain :: Maybe CertificateChain
  }
defaultClientRoleInfo :: RoleInfo
defaultServerRoleInfo :: RoleInfo
data CIDDB = CIDDB {
- usedCIDInfo :: CIDInfo
- cidInfos :: IntMap CIDInfo
- revInfos :: Map CID Int
- nextSeqNum :: Int
- triggeredByMe :: Bool
}
newCIDDB :: CID -> CIDDB
data MigrationState
- = NonMigration
- | MigrationStarted
- | SendChallenge PathData
- | RecvResponse
data Coder = Coder {
- encrypt :: Buffer -> PlainText -> AssDat -> PacketNumber -> IO Int
- decrypt :: Buffer -> CipherText -> AssDat -> PacketNumber -> IO Int
- supplement :: Maybe Supplement
}
initialCoder :: Coder
data Coder1RTT = Coder1RTT {
- coder1RTT :: Coder
- secretN :: TrafficSecrets ApplicationSecret
}
initialCoder1RTT :: Coder1RTT
data Protector = Protector {
- setSample :: Buffer -> IO ()
- getMask :: IO Buffer
- unprotect :: Sample -> Mask
}
initialProtector :: Protector
data Negotiated = Negotiated {
- tlsHandshakeMode :: HandshakeMode13
- applicationProtocol :: Maybe NegotiatedProtocol
- applicationSecretInfo :: ApplicationSecretInfo
}
initialNegotiated :: Negotiated
newtype StreamIdBase = StreamIdBase {
- fromStreamIdBase :: Int
}
data Concurrency = Concurrency {
- currentStream :: StreamId
- maxStreams :: StreamIdBase
}
newConcurrency :: Role -> Direction -> Int -> Concurrency
type Send = Buffer -> Int -> IO ()
type Recv = IO ReceivedPacket
data Connection = Connection {
- connState :: ConnState
- connDebugLog :: DebugLogger
- connQLog :: QLogger
- connHooks :: Hooks
- connSend :: ~Send
- connRecv :: ~Recv
- connRecvQ :: RecvQ
- udpSocket :: ~(IORef UDPSocket)
- readers :: IORef (IO ())
- mainThreadId :: ThreadId
- controlRate :: Rate
- roleInfo :: IORef RoleInfo
- quicVersionInfo :: IORef VersionInfo
- origVersionInfo :: VersionInfo
- myParameters :: Parameters
- myCIDDB :: IORef CIDDB
- peerParameters :: IORef Parameters
- peerCIDDB :: TVar CIDDB
- inputQ :: InputQ
- cryptoQ :: CryptoQ
- outputQ :: OutputQ
- outputQLim :: OutputQLim
- migrationQ :: MigrationQ
- shared :: Shared
- delayedAckCount :: IORef Int
- delayedAckCancel :: IORef (IO ())
- peerPacketNumber :: IORef PacketNumber
- streamTable :: IORef StreamTable
- myStreamId :: TVar Concurrency
- myUniStreamId :: TVar Concurrency
- peerStreamId :: IORef Concurrency
- peerUniStreamId :: IORef Concurrency
- flowTx :: TVar TxFlow
- flowRx :: IORef RxFlow
- migrationState :: TVar MigrationState
- minIdleTimeout :: IORef Microseconds
- bytesTx :: TVar Int
- bytesRx :: TVar Int
- addressValidated :: TVar Bool
- pendingQ :: Array EncryptionLevel (TVar [ReceivedPacket])
- ciphers :: IOArray EncryptionLevel Cipher
- coders :: IOArray EncryptionLevel Coder
- coders1RTT :: IOArray Bool Coder1RTT
- protectors :: IOArray EncryptionLevel Protector
- currentKeyPhase :: IORef (Bool, PacketNumber)
- negotiated :: IORef Negotiated
- connMyAuthCIDs :: IORef AuthCIDs
- connPeerAuthCIDs :: IORef AuthCIDs
- connResources :: IORef (IO ())
- encodeBuf :: Buffer
- encryptRes :: SizedBuffer
- decryptBuf :: Buffer
- connLDCC :: LDCC
}
setDead :: Connection -> IO ()
makePendingQ :: IO (Array EncryptionLevel (TVar [ReceivedPacket]))
newConnection :: Role -> Parameters -> VersionInfo -> AuthCIDs -> AuthCIDs -> DebugLogger -> QLogger -> Hooks -> IORef UDPSocket -> RecvQ -> Send -> Recv -> IO Connection
defaultTrafficSecrets :: (ClientTrafficSecret a, ServerTrafficSecret a)
clientConnection :: ClientConfig -> VersionInfo -> AuthCIDs -> AuthCIDs -> DebugLogger -> QLogger -> Hooks -> IORef UDPSocket -> RecvQ -> Send -> Recv -> IO Connection
serverConnection :: ServerConfig -> VersionInfo -> AuthCIDs -> AuthCIDs -> DebugLogger -> QLogger -> Hooks -> IORef UDPSocket -> RecvQ -> Send -> Recv -> IO Connection
newtype Input = InpStream Stream
data Crypto = InpHandshake EncryptionLevel ByteString
data Output
- = OutControl EncryptionLevel [Frame] (IO ())
- | OutHandshake [(EncryptionLevel, ByteString)]
- | OutRetrans PlainPacket
type InputQ = TQueue Input
type CryptoQ = TQueue Crypto
type OutputQ = TQueue Output
type OutputQLim = TBQueue Output
type MigrationQ = TQueue ReceivedPacket
type SendStreamQ = TQueue TxStreamData
data Shared = Shared {
- sharedCloseSent :: IORef Bool
- sharedCloseReceived :: IORef Bool
- shared1RTTReady :: IORef Bool
- sharedSendStreamQ :: SendStreamQ
}
newShared :: IO Shared
class Connector a where
- getRole :: a -> Role
- getEncryptionLevel :: a -> IO EncryptionLevel
- getMaxPacketSize :: a -> IO Int
- getConnectionState :: a -> IO ConnectionState
- getPacketNumber :: a -> IO PacketNumber
- getAlive :: a -> IO Bool
data ConnState = ConnState {
- role :: Role
- connectionState :: TVar ConnectionState
- packetNumber :: IORef PacketNumber
- encryptionLevel :: TVar EncryptionLevel
- maxPacketSize :: IORef Int
- connectionAlive :: IORef Bool
}
newConnState :: Role -> IO ConnState
data Role
- = Client
- | Server
isClient :: Connector a => a -> Bool
isServer :: Connector a => a -> Bool
data ConnectionState
- = Handshaking
- | ReadyFor0RTT
- | ReadyFor1RTT
- | Established
isConnectionEstablished :: Connector a => a -> IO Bool
data FusionContext
fusionNewContext :: IO FusionContext
fusionSetup :: Cipher -> FusionContext -> Key -> IV -> IO ()
fusionEncrypt :: FusionContext -> Supplement -> Buffer -> PlainText -> AssDat -> PacketNumber -> IO Int
fusionDecrypt :: FusionContext -> Buffer -> CipherText -> AssDat -> PacketNumber -> IO Int
data Supplement
fusionSetupSupplement :: Cipher -> Key -> IO Supplement
fusionSetSample :: Supplement -> Buffer -> IO ()
fusionGetMask :: Supplement -> IO Buffer
isFusionAvailable :: IO Bool
niteEncrypt :: Cipher -> Key -> IV -> PlainText -> AssDat -> PacketNumber -> Maybe (CipherText, CipherText)
niteEncrypt' :: Cipher -> Key -> Nonce -> PlainText -> AssDat -> Maybe (CipherText, CipherText)
niteDecrypt :: Cipher -> Key -> IV -> CipherText -> AssDat -> PacketNumber -> Maybe PlainText
niteDecrypt' :: Cipher -> Key -> Nonce -> CipherText -> AssDat -> Maybe PlainText
protectionMask :: Cipher -> Key -> Sample -> Mask
aes128gcmEncrypt :: Key -> Nonce -> PlainText -> AssDat -> Maybe (CipherText, CipherText)
makeNonce :: IV -> ByteString -> Nonce
makeNiteEncrypt :: Cipher -> Key -> IV -> NiteEncrypt
makeNiteDecrypt :: Cipher -> Key -> IV -> NiteDecrypt
makeNiteProtector :: Cipher -> Key -> IO (Buffer -> IO (), IO Buffer)
type PlainText = ByteString
type CipherText = ByteString
newtype Key = Key ByteString
newtype IV = IV ByteString
data CID
newtype Secret = Secret ByteString
newtype AssDat = AssDat ByteString
newtype Sample = Sample ByteString
newtype Mask = Mask ByteString
newtype Nonce = Nonce ByteString
type Salt = ByteString
newtype Label = Label ByteString
data Cipher
data InitialSecret
type TrafficSecrets a = (ClientTrafficSecret a, ServerTrafficSecret a)
newtype ClientTrafficSecret a = ClientTrafficSecret ByteString
newtype ServerTrafficSecret a = ServerTrafficSecret ByteString
defaultCipher :: Cipher
initialSecrets :: Version -> CID -> TrafficSecrets InitialSecret
clientInitialSecret :: Version -> CID -> ClientTrafficSecret InitialSecret
serverInitialSecret :: Version -> CID -> ServerTrafficSecret InitialSecret
aeadKey :: Version -> Cipher -> Secret -> Key
initialVector :: Version -> Cipher -> Secret -> IV
nextSecret :: Version -> Cipher -> Secret -> Secret
headerProtectionKey :: Version -> Cipher -> Secret -> Key
tagLength :: Cipher -> Int
sampleLength :: Cipher -> Int
bsXOR :: ByteString -> ByteString -> ByteString
calculateIntegrityTag :: Version -> CID -> ByteString -> ByteString
data Builder
type DebugLogger = Builder -> IO ()
bhow :: Show a => a -> Builder
stdoutLogger :: DebugLogger
dirDebugLogger :: Maybe FilePath -> CID -> IO (DebugLogger, IO ())
encodeVersionNegotiationPacket :: VersionNegotiationPacket -> IO ByteString
encodeRetryPacket :: RetryPacket -> IO ByteString
encodePlainPacket :: Connection -> SizedBuffer -> PlainPacket -> Maybe Int -> IO (Int, Int)
decodePacket :: ByteString -> IO (PacketI, ByteString)
decodePackets :: ByteString -> IO [PacketI]
decodeCryptPackets :: ByteString -> IO [(CryptPacket, EncryptionLevel, Int)]
decryptCrypt :: Connection -> Crypt -> EncryptionLevel -> IO (Maybe Plain)
decodeStatelessResetToken :: ByteString -> Maybe StatelessResetToken
encodeFrames :: [Frame] -> IO ByteString
decodeFramesBuffer :: Buffer -> BufferSize -> IO (Maybe [Frame])
decodeFramesBS :: ByteString -> IO (Maybe [Frame])
countZero :: Ptr Word8 -> Ptr Word8 -> IO Int
isLong :: Word8 -> Bool
isShort :: Flags Protected -> Bool
protectFlags :: Flags Raw -> Word8 -> Flags Protected
unprotectFlags :: Flags Protected -> Word8 -> Flags Raw
encodeLongHeaderFlags :: Version -> LongHeaderPacketType -> Flags Raw -> Flags Raw -> Bool -> IO (Flags Raw)
encodeShortHeaderFlags :: Flags Raw -> Flags Raw -> Bool -> Bool -> IO (Flags Raw)
decodeLongHeaderPacketType :: Version -> Flags Protected -> LongHeaderPacketType
encodePktNumLength :: Int -> Flags Raw
decodePktNumLength :: Flags Raw -> Int
versionNegotiationPacketType :: IO (Flags Raw)
retryPacketType :: Version -> IO (Flags Raw)
data CryptoToken = CryptoToken {
- tokenQUICVersion :: Version
- tokenLifeTime :: Word32
- tokenCreatedTime :: TimeMicrosecond
- tokenCIDs :: Maybe (CID, CID, CID)
}
isRetryToken :: CryptoToken -> Bool
generateToken :: Version -> Int -> IO CryptoToken
generateRetryToken :: Version -> Int -> CID -> CID -> CID -> IO CryptoToken
encryptToken :: TokenManager -> CryptoToken -> IO Token
decryptToken :: TokenManager -> Token -> IO (Maybe CryptoToken)
data Parameters = Parameters {
- originalDestinationConnectionId :: Maybe CID
- maxIdleTimeout :: Milliseconds
- statelessResetToken :: Maybe StatelessResetToken
- maxUdpPayloadSize :: Int
- initialMaxData :: Int
- initialMaxStreamDataBidiLocal :: Int
- initialMaxStreamDataBidiRemote :: Int
- initialMaxStreamDataUni :: Int
- initialMaxStreamsBidi :: Int
- initialMaxStreamsUni :: Int
- ackDelayExponent :: Int
- maxAckDelay :: Milliseconds
- disableActiveMigration :: Bool
- preferredAddress :: Maybe ByteString
- activeConnectionIdLimit :: Int
- initialSourceConnectionId :: Maybe CID
- retrySourceConnectionId :: Maybe CID
- grease :: Maybe ByteString
- greaseQuicBit :: Bool
- versionInformation :: Maybe VersionInfo
}
defaultParameters :: Parameters
baseParameters :: Parameters
encodeParameters :: Parameters -> ByteString
decodeParameters :: ByteString -> Maybe Parameters
data AuthCIDs = AuthCIDs {
- initSrcCID :: Maybe CID
- origDstCID :: Maybe CID
- retrySrcCID :: Maybe CID
}
defaultAuthCIDs :: AuthCIDs
setCIDsToParameters :: AuthCIDs -> Parameters -> Parameters
getCIDsToParameters :: Parameters -> AuthCIDs
type QLogger = QlogMsg -> IO ()
newQlogger :: TimeMicrosecond -> ByteString -> CID -> FastLogger -> IO QLogger
class Qlog a where
- qlog :: a -> LogStr
class KeepQlog a where
- keepQlog :: a -> QLogger
data QlogMsg
- = QRecvInitial
- | QSentRetry
- | QSent LogStr TimeMicrosecond
- | QReceived LogStr TimeMicrosecond
- | QDropped LogStr TimeMicrosecond
- | QMetricsUpdated LogStr TimeMicrosecond
- | QPacketLost LogStr TimeMicrosecond
- | QCongestionStateUpdated LogStr TimeMicrosecond
- | QLossTimerUpdated LogStr TimeMicrosecond
- | QDebug LogStr TimeMicrosecond
- | QParamsSet LogStr TimeMicrosecond
- | QCIDUpdate LogStr TimeMicrosecond
qlogReceived :: (KeepQlog q, Qlog a) => q -> a -> TimeMicrosecond -> IO ()
qlogDropped :: (KeepQlog q, Qlog a) => q -> a -> IO ()
qlogRecvInitial :: KeepQlog q => q -> IO ()
qlogSentRetry :: KeepQlog q => q -> IO ()
qlogParamsSet :: KeepQlog q => q -> (Parameters, String) -> IO ()
qlogDebug :: KeepQlog q => q -> Debug -> IO ()
qlogCIDUpdate :: KeepQlog q => q -> LR -> IO ()
newtype Debug = Debug LogStr
data LR
- = Local CID
- | Remote CID
packetType :: Header -> LogStr
sw :: Show a => a -> LogStr
data Stream
streamId :: Stream -> StreamId
streamConnection :: Stream -> Connection
newStream :: Connection -> Int -> Int -> StreamId -> IO Stream
data TxStreamData = TxStreamData Stream [StreamData] Length Fin
data StreamState = StreamState {
- streamOffset :: Offset
- streamFin :: Fin
}
data RecvStreamQ = RecvStreamQ {
- recvStreamQ :: TQueue ByteString
- pendingData :: IORef (Maybe ByteString)
- endOfStream :: IORef Bool
}
data RxStreamData = RxStreamData {
- rxstrmData :: StreamData
- rxstrmOff :: Offset
- rxstrmLen :: Length
- rxstrmFin :: Fin
}
type Length = Int
syncFinTx :: Stream -> IO ()
waitFinTx :: Stream -> IO ()
getTxStreamOffset :: Stream -> Int -> IO Offset
isTxStreamClosed :: Stream -> IO Bool
setTxStreamClosed :: Stream -> IO ()
getRxStreamOffset :: Stream -> Int -> IO Offset
isRxStreamClosed :: Stream -> IO Bool
setRxStreamClosed :: Stream -> IO ()
readStreamFlowTx :: Stream -> STM TxFlow
addTxStreamData :: Stream -> Int -> STM ()
setTxMaxStreamData :: Stream -> Int -> IO ()
getRxMaxStreamData :: Stream -> IO Int
updateStreamFlowRx :: Stream -> Int -> IO (Maybe Int)
takeRecvStreamQwithSize :: Stream -> Int -> IO ByteString
putRxStreamData :: Stream -> RxStreamData -> IO FlowCntl
data FlowCntl
- = OverLimit
- | Duplicated
- | Reassembled
tryReassemble :: Stream -> RxStreamData -> (StreamData -> IO ()) -> IO () -> IO Bool
data StreamTable
emptyStreamTable :: StreamTable
lookupStream :: StreamId -> StreamTable -> Maybe Stream
insertStream :: StreamId -> Stream -> StreamTable -> StreamTable
deleteStream :: StreamId -> StreamTable -> StreamTable
insertCryptoStreams :: Connection -> StreamTable -> IO StreamTable
deleteCryptoStream :: EncryptionLevel -> StreamTable -> StreamTable
lookupCryptoStream :: EncryptionLevel -> StreamTable -> Maybe Stream
clientHandshaker :: QUICCallbacks -> ClientConfig -> Version -> AuthCIDs -> SessionEstablish -> Bool -> IO ()
serverHandshaker :: QUICCallbacks -> ServerConfig -> Version -> IO Parameters -> IO ()
type Bytes = ShortByteString
type Close = IO ()
data Direction
- = Unidirectional
- | Bidirectional
data SizedBuffer = SizedBuffer Buffer BufferSize
type PacketNumber = Int
type Range = Int
type Gap = Int
data AckInfo = AckInfo PacketNumber Range [(Gap, Range)]
ackInfo0 :: AckInfo
toAckInfo :: [PacketNumber] -> AckInfo
fromAckInfo :: AckInfo -> [PacketNumber]
fromAckInfoWithMin :: AckInfo -> PacketNumber -> [PacketNumber]
fromAckInfoToPred :: AckInfo -> PacketNumber -> Bool
newtype PeerPacketNumbers = PeerPacketNumbers IntSet
emptyPeerPacketNumbers :: PeerPacketNumbers
newtype CID = CID Bytes
myCIDLength :: Int
newCID :: IO CID
fromCID :: CID -> ByteString
toCID :: ByteString -> CID
makeCID :: ShortByteString -> CID
unpackCID :: CID -> (ShortByteString, Word8)
newtype StatelessResetToken = StatelessResetToken Bytes
newStatelessResetToken :: IO StatelessResetToken
newtype PathData = PathData Bytes
newPathData :: IO PathData
data CIDInfo = CIDInfo {
- cidInfoSeq :: Int
- cidInfoCID :: CID
- cidInfoSRT :: StatelessResetToken
}
maximumUdpPayloadSize :: Int
defaultQUICPacketSize :: Int
defaultQUICPacketSizeForIPv4 :: Int
defaultQUICPacketSizeForIPv6 :: Int
maximumQUICHeaderSize :: Int
idleTimeout :: Microseconds
newtype TransportError = TransportError Int
pattern NoError :: TransportError
pattern InternalError :: TransportError
pattern ConnectionRefused :: TransportError
pattern FlowControlError :: TransportError
pattern StreamLimitError :: TransportError
pattern StreamStateError :: TransportError
pattern FinalSizeError :: TransportError
pattern FrameEncodingError :: TransportError
pattern TransportParameterError :: TransportError
pattern ConnectionIdLimitError :: TransportError
pattern ProtocolViolation :: TransportError
pattern InvalidToken :: TransportError
pattern ApplicationError :: TransportError
pattern CryptoBufferExceeded :: TransportError
pattern KeyUpdateError :: TransportError
pattern AeadLimitReached :: TransportError
pattern NoViablePath :: TransportError
pattern VersionNegotiationError :: TransportError
cryptoError :: AlertDescription -> TransportError
newtype ApplicationProtocolError = ApplicationProtocolError Int
data QUICException
- = ConnectionIsClosed
- | TransportErrorIsReceived TransportError ReasonPhrase
- | TransportErrorIsSent TransportError ReasonPhrase
- | ApplicationProtocolErrorIsReceived ApplicationProtocolError ReasonPhrase
- | ApplicationProtocolErrorIsSent ApplicationProtocolError ReasonPhrase
- | ConnectionIsTimeout String
- | ConnectionIsReset
- | StreamIsClosed
- | HandshakeFailed AlertDescription
- | VersionIsUnknown Word32
- | NoVersionIsSpecified
- | VersionNegotiationFailed
- | BadThingHappen SomeException
data InternalControl
- = MustNotReached
- | ExitConnection
- | WrongTransportParameter
- | WrongVersionInformation
- | BreakForever
newtype NextVersion = NextVersion VersionInfo
data Abort
- = Abort ApplicationProtocolError ReasonPhrase
- | VerNego VersionInfo
type FrameType = Int
data Direction
- = Unidirectional
- | Bidirectional
type ReasonPhrase = ShortByteString
type SeqNum = Int
data Frame
- = Padding Int
- | Ping
- | Ack AckInfo Delay
- | ResetStream StreamId ApplicationProtocolError Int
- | StopSending StreamId ApplicationProtocolError
- | CryptoF Offset CryptoData
- | NewToken Token
- | StreamF StreamId Offset [StreamData] Fin
- | MaxData Int
- | MaxStreamData StreamId Int
- | MaxStreams Direction Int
- | DataBlocked Int
- | StreamDataBlocked StreamId Int
- | StreamsBlocked Direction Int
- | NewConnectionID CIDInfo SeqNum
- | RetireConnectionID SeqNum
- | PathChallenge PathData
- | PathResponse PathData
- | ConnectionClose TransportError FrameType ReasonPhrase
- | ConnectionCloseApp ApplicationProtocolError ReasonPhrase
- | HandshakeDone
- | UnknownFrame Int
type StreamId = Int
isClientInitiatedBidirectional :: StreamId -> Bool
isServerInitiatedBidirectional :: StreamId -> Bool
isClientInitiatedUnidirectional :: StreamId -> Bool
isServerInitiatedUnidirectional :: StreamId -> Bool
isClientInitiated :: StreamId -> Bool
isServerInitiated :: StreamId -> Bool
isBidirectional :: StreamId -> Bool
isUnidirectional :: StreamId -> Bool
type Delay = Milliseconds
type Fin = Bool
type CryptoData = ByteString
type StreamData = ByteString
type Token = ByteString
emptyToken :: Token
ackEliciting :: Frame -> Bool
pathValidating :: Frame -> Bool
inFlight :: Frame -> Bool
rateControled :: Frame -> Bool
encodeInt :: Int64 -> ByteString
encodeInt8 :: Int64 -> ByteString
encodeInt' :: WriteBuffer -> Int64 -> IO ()
encodeInt'2 :: WriteBuffer -> Int64 -> IO ()
encodeInt'4 :: WriteBuffer -> Int64 -> IO ()
decodeInt :: ByteString -> Int64
decodeInt' :: ReadBuffer -> IO Int64
newtype Version = Version Word32
pattern Negotiation :: Version
pattern Version1 :: Version
pattern Version2 :: Version
pattern Draft29 :: Version
pattern GreasingVersion :: Version
pattern GreasingVersion2 :: Version
isGreasingVersion :: Version -> Bool
data VersionInfo = VersionInfo {
- chosenVersion :: Version
- otherVersions :: [Version]
}
brokenVersionInfo :: VersionInfo
extensionIDForTtransportParameter :: Version -> ExtensionID
data PacketI
- = PacketIV VersionNegotiationPacket
- | PacketIR RetryPacket
- | PacketIC CryptPacket EncryptionLevel Int
- | PacketIB BrokenPacket
data PacketO
- = PacketOV VersionNegotiationPacket
- | PacketOR RetryPacket
- | PacketOP PlainPacket
data VersionNegotiationPacket = VersionNegotiationPacket CID CID [Version]
data RetryPacket = RetryPacket Version CID CID Token (Either CID (ByteString, ByteString))
data BrokenPacket = BrokenPacket
data Header
- = Initial Version CID CID Token
- | RTT0 Version CID CID
- | Handshake Version CID CID
- | Short CID
headerMyCID :: Header -> CID
headerPeerCID :: Header -> CID
data PlainPacket = PlainPacket Header Plain
data CryptPacket = CryptPacket Header Crypt
data Plain = Plain {
- plainFlags :: Flags Raw
- plainPacketNumber :: PacketNumber
- plainFrames :: [Frame]
- plainMarks :: Int
}
defaultPlainMarks :: Int
setIllegalReservedBits :: Int -> Int
setUnknownFrame :: Int -> Int
setNoFrames :: Int -> Int
setNoPaddings :: Int -> Int
set4bytesPN :: Int -> Int
isIllegalReservedBits :: Int -> Bool
isUnknownFrame :: Int -> Bool
isNoFrames :: Int -> Bool
isNoPaddings :: Int -> Bool
is4bytesPN :: Int -> Bool
data MigrationInfo = MigrationInfo ListenSocket ClientSockAddr CID
data Crypt = Crypt {
- cryptPktNumOffset :: Int
- cryptPacket :: ByteString
- cryptMarks :: Int
- cryptMigraionInfo :: Maybe MigrationInfo
}
isCryptDelayed :: Crypt -> Bool
setCryptDelayed :: Crypt -> Crypt
data StatelessReset = StatelessReset
data ReceivedPacket = ReceivedPacket {
- rpCryptPacket :: CryptPacket
- rpTimeRecevied :: TimeMicrosecond
- rpReceivedBytes :: Int
- rpEncryptionLevel :: EncryptionLevel
}
mkReceivedPacket :: CryptPacket -> TimeMicrosecond -> Int -> EncryptionLevel -> ReceivedPacket
data LongHeaderPacketType
- = InitialPacketType
- | RTT0PacketType
- | HandshakePacketType
- | RetryPacketType
data EncryptionLevel
- = InitialLevel
- | RTT0Level
- | HandshakeLevel
- | RTT1Level
packetEncryptionLevel :: Header -> EncryptionLevel
newtype Flags a = Flags Word8
data Protected
data Raw
type EncodedPacketNumber = Word32
newtype RecvQ = RecvQ (TQueue ReceivedPacket)
newRecvQ :: IO RecvQ
readRecvQ :: RecvQ -> IO ReceivedPacket
writeRecvQ :: RecvQ -> ReceivedPacket -> IO ()
prependRecvQ :: RecvQ -> ReceivedPacket -> STM ()
type SessionEstablish = SessionID -> SessionData -> IO (Maybe Ticket)
data ResumptionInfo = ResumptionInfo {
- resumptionVersion :: Version
- resumptionSession :: Maybe (SessionID, SessionData)
- resumptionToken :: Token
- resumptionRetry :: Bool
}
defaultResumptionInfo :: ResumptionInfo
is0RTTPossible :: ResumptionInfo -> Bool
isResumptionPossible :: ResumptionInfo -> Bool
get0RTTCipher :: ResumptionInfo -> Maybe CipherID
newtype Milliseconds = Milliseconds Int64
newtype Microseconds = Microseconds Int
milliToMicro :: Milliseconds -> Microseconds
microToMilli :: Microseconds -> Milliseconds
type TimeMicrosecond = UnixTime
timeMicrosecond0 :: UnixTime
getTimeMicrosecond :: IO TimeMicrosecond
getElapsedTimeMicrosecond :: TimeMicrosecond -> IO Microseconds
elapsedTimeMicrosecond :: UnixTime -> UnixTime -> Microseconds
getTimeoutInMicrosecond :: TimeMicrosecond -> IO Microseconds
getPastTimeMicrosecond :: Microseconds -> IO TimeMicrosecond
getFutureTimeMicrosecond :: Microseconds -> IO TimeMicrosecond
addMicroseconds :: TimeMicrosecond -> Microseconds -> TimeMicrosecond
fromRight :: b -> Either a b -> b
dec16 :: ByteString -> ByteString
enc16 :: ByteString -> ByteString
dec16s :: ShortByteString -> ShortByteString
enc16s :: ShortByteString -> ShortByteString
shortToString :: ShortByteString -> String
getRandomOneByte :: IO Word8
getRandomBytes :: Int -> IO ShortByteString
totalLen :: [ByteString] -> Int
sum' :: (Functor f, Foldable f) => f Int -> Int
withByteString :: ByteString -> (Ptr Word8 -> IO a) -> IO a
shortpack :: String -> ShortByteString
ignore :: SomeException -> IO ()
checkWindowOpenSTM :: LDCC -> Int -> STM ()
takePingSTM :: LDCC -> STM EncryptionLevel
speedup :: LDCC -> EncryptionLevel -> LogStr -> IO ()
resender :: LDCC -> IO ()
onPacketSent :: LDCC -> SentPacket -> IO ()
onPacketReceived :: LDCC -> EncryptionLevel -> PacketNumber -> IO ()
onAckReceived :: LDCC -> EncryptionLevel -> AckInfo -> Microseconds -> IO ()
onPacketNumberSpaceDiscarded :: LDCC -> EncryptionLevel -> IO ()
setInitialCongestionWindow :: LDCC -> Int -> IO ()
getPreviousRTT1PPNs :: LDCC -> IO PeerPacketNumbers
setPreviousRTT1PPNs :: LDCC -> PeerPacketNumbers -> IO ()
getSpeedingUp :: LDCC -> IO Bool
getPacketNumberSpaceDiscarded :: LDCC -> EncryptionLevel -> IO Bool
getAndSetPacketNumberSpaceDiscarded :: LDCC -> EncryptionLevel -> IO Bool
setMaxAckDaley :: LDCC -> Microseconds -> IO ()
getPeerPacketNumbers :: LDCC -> EncryptionLevel -> IO PeerPacketNumbers
fromPeerPacketNumbers :: PeerPacketNumbers -> [PacketNumber]
nullPeerPacketNumbers :: PeerPacketNumbers -> Bool
findDuration :: Seq SentPacket -> PacketNumber -> Maybe UnixDiffTime
getPTO :: LDCC -> IO Microseconds
releaseByRetry :: LDCC -> IO (Seq PlainPacket)
releaseOldest :: LDCC -> EncryptionLevel -> IO (Maybe SentPacket)
beforeAntiAmp :: LDCC -> IO ()
ldccTimer :: LDCC -> IO ()
data SentPacket
spPlainPacket :: SentPacket -> PlainPacket
spTimeSent :: SentPacket -> TimeMicrosecond
spSentBytes :: SentPacket -> Int
spEncryptionLevel :: SentPacket -> EncryptionLevel
spPacketNumber :: SentPacket -> PacketNumber
spPeerPacketNumbers :: SentPacket -> PeerPacketNumbers
spAckEliciting :: SentPacket -> Bool
mkSentPacket :: PacketNumber -> EncryptionLevel -> PlainPacket -> PeerPacketNumbers -> Bool -> SentPacket
fixSentPacket :: SentPacket -> Int -> Int -> SentPacket
data LDCC
newLDCC :: ConnState -> QLogger -> (PlainPacket -> IO ()) -> IO LDCC
qlogSent :: (KeepQlog q, Qlog pkt) => q -> pkt -> TimeMicrosecond -> IO ()
data ConnectionControl
- = ChangeServerCID
- | ChangeClientCID
- | NATRebinding
- | ActiveMigration
controlConnection :: Connection -> ConnectionControl -> IO Bool
windowsThreadBlockHack :: IO a -> IO a

Documentation

data Hooks Source #

Hooks.

Constructors

Hooks
Fields onCloseCompleted :: IO () onPlainCreated :: EncryptionLevel -> Plain -> Plain onTransportParametersCreated :: Parameters -> Parameters onTLSExtensionCreated :: [ExtensionRaw] -> [ExtensionRaw] onTLSHandshakeCreated :: [(EncryptionLevel, CryptoData)] -> ([(EncryptionLevel, CryptoData)], Bool) onResetStreamReceived :: Stream -> ApplicationProtocolError -> IO () onServerReady :: IO ()

defaultHooks :: Hooks Source #

Default hooks.

data ClientConfig Source #

Client configuration.

Constructors

ClientConfig

Fields

ccVersion :: Version
The version to start with.
ccVersions :: [Version]
Compatible versions with ccVersion in the preferred order.
ccCiphers :: [Cipher]
Cipher candidates defined in TLS 1.3.
ccGroups :: [Group]
Key exchange group candidates defined in TLS 1.3.
ccParameters :: Parameters
ccKeyLog :: String -> IO ()
ccQLog :: Maybe FilePath
ccCredentials :: Credentials
TLS credentials.
ccHooks :: Hooks
ccTlsHooks :: ClientHooks
ccUse0RTT :: Bool
Use 0-RTT on the 2nd connection if possible. client original
ccServerName :: HostName
Used to create a socket and SNI for TLS.
ccPortName :: ServiceName
Used to create a socket.
ccALPN :: Version -> IO (Maybe [ByteString])
An ALPN provider.
ccValidate :: Bool
Authenticating a server based on its certificate.
ccResumption :: ResumptionInfo
Use resumption on the 2nd connection if possible.
ccPacketSize :: Maybe Int
QUIC packet size (UDP payload size)
ccDebugLog :: Bool
ccAutoMigration :: Bool
If True, use a unconnected socket for auto migration. Otherwise, use a connected socket.

defaultClientConfig :: ClientConfig Source #

The default value for client configuration.

data ServerConfig Source #

Server configuration.

Constructors

ServerConfig

Fields

scVersions :: [Version]
Fully-Deployed Versions in the preferred order.
scCiphers :: [Cipher]
Cipher candidates defined in TLS 1.3.
scGroups :: [Group]
Key exchange group candidates defined in TLS 1.3.
scParameters :: Parameters
scKeyLog :: String -> IO ()
scQLog :: Maybe FilePath
scCredentials :: Credentials
Server certificate information.
scHooks :: Hooks
scTlsHooks :: ServerHooks
scUse0RTT :: Bool
Use 0-RTT on the 2nd connection if possible. server original
scAddresses :: [(IP, PortNumber)]
Server addresses assigned to used network interfaces.
scALPN :: Maybe (Version -> [ByteString] -> IO ByteString)
ALPN handler.
scRequireRetry :: Bool
Requiring QUIC retry.
scSessionManager :: SessionManager
A session manager of TLS 1.3.
scDebugLog :: Maybe FilePath
scTicketLifetime :: Int
A lifetime (in seconds) for TLS session ticket and QUIC token.

defaultServerConfig :: ServerConfig Source #

The default value for server configuration.

nextPacketNumber :: Connection -> IO PacketNumber Source #

setPeerPacketNumber :: Connection -> PacketNumber -> IO () Source #

getPeerPacketNumber :: Connection -> IO PacketNumber Source #

setEncryptionLevel :: Connection -> EncryptionLevel -> IO () Source #

waitEncryptionLevel :: Connection -> EncryptionLevel -> IO () Source #

putOffCrypto :: Connection -> EncryptionLevel -> ReceivedPacket -> IO () Source #

getCipher :: Connection -> EncryptionLevel -> IO Cipher Source #

setCipher :: Connection -> EncryptionLevel -> Cipher -> IO () Source #

getTLSMode :: Connection -> IO HandshakeMode13 Source #

getApplicationProtocol :: Connection -> IO (Maybe NegotiatedProtocol) Source #

setNegotiated :: Connection -> HandshakeMode13 -> Maybe NegotiatedProtocol -> ApplicationSecretInfo -> IO () Source #

dropSecrets :: Connection -> EncryptionLevel -> IO () Source #

initializeCoder :: Connection -> EncryptionLevel -> TrafficSecrets a -> IO () Source #

initializeCoder1RTT :: Connection -> TrafficSecrets ApplicationSecret -> IO () Source #

updateCoder1RTT :: Connection -> Bool -> IO () Source #

getCoder :: Connection -> EncryptionLevel -> Bool -> IO Coder Source #

getProtector :: Connection -> EncryptionLevel -> IO Protector Source #

getCurrentKeyPhase :: Connection -> IO (Bool, PacketNumber) Source #

setCurrentKeyPhase :: Connection -> Bool -> PacketNumber -> IO () Source #

getMyCID :: Connection -> IO CID Source #

getMyCIDs :: Connection -> IO [CID] Source #

getPeerCID :: Connection -> IO CID Source #

isMyCID :: Connection -> CID -> IO Bool Source #

myCIDsInclude :: Connection -> CID -> IO (Maybe Int) Source #

shouldUpdateMyCID :: Connection -> Int -> IO Bool Source #

shouldUpdatePeerCID :: Connection -> IO Bool Source #

resetPeerCID :: Connection -> CID -> IO () Source #

Reseting to Initial CID in the client side.

getNewMyCID :: Connection -> IO CIDInfo Source #

Sending NewConnectionID

getMyCIDSeqNum :: Connection -> IO Int Source #

setMyCID :: Connection -> CID -> IO () Source #

Peer starts using a new CID.

setPeerCIDAndRetireCIDs :: Connection -> Int -> IO [Int] Source #

Receiving NewConnectionID

retirePeerCID :: Connection -> Int -> IO () Source #

After sending RetireConnectionID

retireMyCID :: Connection -> Int -> IO (Maybe CIDInfo) Source #

Receiving RetireConnectionID

addPeerCID :: Connection -> CIDInfo -> IO Bool Source #

Receiving NewConnectionID

waitPeerCID :: Connection -> IO CIDInfo Source #

Only for the internal "migration" API

choosePeerCIDForPrivacy :: Connection -> IO () Source #

Automatic CID update

setPeerStatelessResetToken :: Connection -> StatelessResetToken -> IO () Source #

isStatelessRestTokenValid :: Connection -> CID -> StatelessResetToken -> IO Bool Source #

setMigrationStarted :: Connection -> IO () Source #

isPathValidating :: Connection -> IO Bool Source #

checkResponse :: Connection -> PathData -> IO () Source #

validatePath :: Connection -> Maybe CIDInfo -> IO () Source #

setVersionInfo :: Connection -> VersionInfo -> IO () Source #

getVersionInfo :: Connection -> IO VersionInfo Source #

setVersion :: Connection -> Version -> IO () Source #

getVersion :: Connection -> IO Version Source #

getOriginalVersion :: Connection -> Version Source #

getSocket :: Connection -> IO UDPSocket Source #

setSocket :: Connection -> UDPSocket -> IO UDPSocket Source #

clearSocket :: Connection -> IO UDPSocket Source #

getPeerAuthCIDs :: Connection -> IO AuthCIDs Source #

setPeerAuthCIDs :: Connection -> (AuthCIDs -> AuthCIDs) -> IO () Source #

getClientDstCID :: Connection -> IO CID Source #

getMyParameters :: Connection -> Parameters Source #

getPeerParameters :: Connection -> IO Parameters Source #

setPeerParameters :: Connection -> Parameters -> IO () Source #

delayedAck :: Connection -> IO () Source #

resetDealyedAck :: Connection -> IO () Source #

setMaxPacketSize :: Connection -> Int -> IO () Source #

addReader :: Connection -> ThreadId -> IO () Source #

killReaders :: Connection -> IO () Source #

addResource :: Connection -> IO () -> IO () Source #

freeResources :: Connection -> IO () Source #

readMinIdleTimeout :: Connection -> IO Microseconds Source #

setMinIdleTimeout :: Connection -> Microseconds -> IO () Source #

sendFrames :: Connection -> EncryptionLevel -> [Frame] -> IO () Source #

sendFramesLim :: Connection -> EncryptionLevel -> [Frame] -> IO () Source #

closeConnection :: TransportError -> ReasonPhrase -> IO () Source #

Closing a connection with/without a transport error. Internal threads should use this.

abortConnection :: Connection -> ApplicationProtocolError -> ReasonPhrase -> IO () Source #

Closing a connection with an application protocol error.

setConnection0RTTReady :: Connection -> IO () Source #

isConnection1RTTReady :: Connection -> IO Bool Source #

setConnection1RTTReady :: Connection -> IO () Source #

isConnectionEstablished :: Connector a => a -> IO Bool Source #

setConnectionEstablished :: Connection -> IO () Source #

wait0RTTReady :: Connection -> IO () Source #

Waiting until 0-RTT data can be sent.

wait1RTTReady :: Connection -> IO () Source #

Waiting until 1-RTT data can be sent.

waitEstablished :: Connection -> IO () Source #

For clients, waiting until HANDSHAKE_DONE is received. For servers, waiting until a TLS stack reports that the handshake is complete.

readConnectionFlowTx :: Connection -> STM TxFlow Source #

addTxData :: Connection -> Int -> STM () Source #

setTxMaxData :: Connection -> Int -> IO () Source #

getRxMaxData :: Connection -> IO Int Source #

updateFlowRx :: Connection -> Int -> IO (Maybe Int) Source #

checkRxMaxData :: Connection -> Int -> IO Bool Source #

addTxBytes :: Connection -> Int -> IO () Source #

getTxBytes :: Connection -> IO Int Source #

addRxBytes :: Connection -> Int -> IO () Source #

getRxBytes :: Connection -> IO Int Source #

setAddressValidated :: Connection -> IO () Source #

waitAntiAmplificationFree :: Connection -> Int -> IO () Source #

checkAntiAmplificationFree :: Connection -> Int -> IO Bool Source #

getMyStreamId :: Connection -> IO Int Source #

possibleMyStreams :: Connection -> IO Int Source #

waitMyNewStreamId :: Connection -> IO StreamId Source #

waitMyNewUniStreamId :: Connection -> IO StreamId Source #

setTxMaxStreams :: Connection -> Int -> IO () Source #

setTxUniMaxStreams :: Connection -> Int -> IO () Source #

checkRxMaxStreams :: Connection -> StreamId -> IO Bool Source #

updatePeerStreamId :: Connection -> StreamId -> IO () Source #

checkStreamIdRoom :: Connection -> Direction -> IO (Maybe Int) Source #

createStream :: Connection -> StreamId -> IO Stream Source #

findStream :: Connection -> StreamId -> IO (Maybe Stream) Source #

addStream :: Connection -> StreamId -> IO Stream Source #

delStream :: Connection -> Stream -> IO () Source #

initialRxMaxStreamData :: Connection -> StreamId -> Int Source #

setupCryptoStreams :: Connection -> IO () Source #

clearCryptoStream :: Connection -> EncryptionLevel -> IO () Source #

getCryptoStream :: Connection -> EncryptionLevel -> IO (Maybe Stream) Source #

takeInput :: Connection -> IO Input Source #

putInput :: Connection -> Input -> IO () Source #

takeCrypto :: Connection -> IO Crypto Source #

putCrypto :: Connection -> Crypto -> IO () Source #

takeOutputSTM :: Connection -> STM Output Source #

tryTakeOutput :: Connection -> IO (Maybe Output) Source #

tryPeekOutput :: Connection -> IO (Maybe Output) Source #

putOutput :: Connection -> Output -> IO () Source #

outputLimit :: Int Source #

putOutputLim :: Connection -> Output -> IO () Source #

takeOutput1STM :: Connection -> STM Output Source #

takeSendStreamQ :: Connection -> IO TxStreamData Source #

takeSendStreamQSTM :: Connection -> STM TxStreamData Source #

tryPeekSendStreamQ :: Connection -> IO (Maybe TxStreamData) Source #

putSendStreamQ :: Connection -> TxStreamData -> IO () Source #

readMigrationQ :: Connection -> IO ReceivedPacket Source #

writeMigrationQ :: Connection -> ReceivedPacket -> IO () Source #

setToken :: Connection -> Token -> IO () Source #

getToken :: Connection -> IO Token Source #

getResumptionInfo :: Connection -> IO ResumptionInfo Source #

Getting information about resumption.

setRetried :: Connection -> Bool -> IO () Source #

getRetried :: Connection -> IO Bool Source #

setIncompatibleVN :: Connection -> Bool -> IO () Source #

getIncompatibleVN :: Connection -> IO Bool Source #

setResumptionSession :: Connection -> SessionEstablish Source #

setNewToken :: Connection -> Token -> IO () Source #

setRegister :: Connection -> (CID -> Connection -> IO ()) -> (CID -> IO ()) -> IO () Source #

getRegister :: Connection -> IO (CID -> Connection -> IO ()) Source #

getUnregister :: Connection -> IO (CID -> IO ()) Source #

setTokenManager :: Connection -> TokenManager -> IO () Source #

getTokenManager :: Connection -> IO TokenManager Source #

setBaseThreadId :: Connection -> ThreadId -> IO () Source #

getBaseThreadId :: Connection -> IO ThreadId Source #

setCertificateChain :: Connection -> Maybe CertificateChain -> IO () Source #

getCertificateChain :: Connection -> IO (Maybe CertificateChain) Source #

timeout :: Microseconds -> String -> IO a -> IO (Maybe a) Source #

fire :: Connection -> Microseconds -> TimeoutCallback -> IO () Source #

cfire :: Connection -> Microseconds -> TimeoutCallback -> IO (IO ()) Source #

delay :: Microseconds -> IO () Source #

dummySecrets :: TrafficSecrets a Source #

data RoleInfo Source #

Constructors

ClientInfo
Fields clientInitialToken :: Token resumptionInfo :: ResumptionInfo incompatibleVN :: Bool
ServerInfo
Fields tokenManager :: ~TokenManager registerCID :: CID -> Connection -> IO () unregisterCID :: CID -> IO () askRetry :: Bool baseThreadId :: ~ThreadId certChain :: Maybe CertificateChain

defaultClientRoleInfo :: RoleInfo Source #

defaultServerRoleInfo :: RoleInfo Source #

data CIDDB Source #

Constructors

CIDDB
Fields usedCIDInfo :: CIDInfo cidInfos :: IntMap CIDInfo revInfos :: Map CID Int nextSeqNum :: Int triggeredByMe :: Bool

Instances

Instances details

Show CIDDB Source #
Instance details Defined in Network.QUIC.Connection.Types Methods showsPrec :: Int -> CIDDB -> ShowS # show :: CIDDB -> String # showList :: [CIDDB] -> ShowS #

newCIDDB :: CID -> CIDDB Source #

data MigrationState Source #

Constructors

NonMigration
MigrationStarted
SendChallenge PathData
RecvResponse

Instances

Instances details

Show MigrationState Source #
Instance details Defined in Network.QUIC.Connection.Types Methods showsPrec :: Int -> MigrationState -> ShowS # show :: MigrationState -> String # showList :: [MigrationState] -> ShowS #
Eq MigrationState Source #
Instance details Defined in Network.QUIC.Connection.Types Methods (==) :: MigrationState -> MigrationState -> Bool # (/=) :: MigrationState -> MigrationState -> Bool #

data Coder Source #

Constructors

Coder
Fields encrypt :: Buffer -> PlainText -> AssDat -> PacketNumber -> IO Int decrypt :: Buffer -> CipherText -> AssDat -> PacketNumber -> IO Int supplement :: Maybe Supplement

initialCoder :: Coder Source #

data Coder1RTT Source #

Constructors

Coder1RTT
Fields coder1RTT :: Coder secretN :: TrafficSecrets ApplicationSecret

initialCoder1RTT :: Coder1RTT Source #

data Protector Source #

Constructors

Protector
Fields setSample :: Buffer -> IO () getMask :: IO Buffer unprotect :: Sample -> Mask

initialProtector :: Protector Source #

data Negotiated Source #

Constructors

Negotiated
Fields tlsHandshakeMode :: HandshakeMode13 applicationProtocol :: Maybe NegotiatedProtocol applicationSecretInfo :: ApplicationSecretInfo

initialNegotiated :: Negotiated Source #

newtype StreamIdBase Source #

Constructors

StreamIdBase
Fields fromStreamIdBase :: Int

Instances

Instances details

Show StreamIdBase Source #
Instance details Defined in Network.QUIC.Connection.Types Methods showsPrec :: Int -> StreamIdBase -> ShowS # show :: StreamIdBase -> String # showList :: [StreamIdBase] -> ShowS #
Eq StreamIdBase Source #
Instance details Defined in Network.QUIC.Connection.Types Methods (==) :: StreamIdBase -> StreamIdBase -> Bool # (/=) :: StreamIdBase -> StreamIdBase -> Bool #

data Concurrency Source #

Constructors

Concurrency
Fields currentStream :: StreamId maxStreams :: StreamIdBase

Instances

Instances details

Show Concurrency Source #
Instance details Defined in Network.QUIC.Connection.Types Methods showsPrec :: Int -> Concurrency -> ShowS # show :: Concurrency -> String # showList :: [Concurrency] -> ShowS #

newConcurrency :: Role -> Direction -> Int -> Concurrency Source #

type Send = Buffer -> Int -> IO () Source #

type Recv = IO ReceivedPacket Source #

data Connection Source #

A quic connection to carry multiple streams.

Constructors

Connection

Fields

connState :: ConnState
connDebugLog :: DebugLogger
A logger for debugging.
connQLog :: QLogger
connHooks :: Hooks
connSend :: ~Send
connRecv :: ~Recv
connRecvQ :: RecvQ
udpSocket :: ~(IORef UDPSocket)
readers :: IORef (IO ())
mainThreadId :: ThreadId
controlRate :: Rate
roleInfo :: IORef RoleInfo
quicVersionInfo :: IORef VersionInfo
origVersionInfo :: VersionInfo
myParameters :: Parameters
myCIDDB :: IORef CIDDB
peerParameters :: IORef Parameters
peerCIDDB :: TVar CIDDB
inputQ :: InputQ
cryptoQ :: CryptoQ
outputQ :: OutputQ
outputQLim :: OutputQLim
migrationQ :: MigrationQ
shared :: Shared
delayedAckCount :: IORef Int
delayedAckCancel :: IORef (IO ())
peerPacketNumber :: IORef PacketNumber
streamTable :: IORef StreamTable
myStreamId :: TVar Concurrency
myUniStreamId :: TVar Concurrency
peerStreamId :: IORef Concurrency
peerUniStreamId :: IORef Concurrency
flowTx :: TVar TxFlow
flowRx :: IORef RxFlow
migrationState :: TVar MigrationState
minIdleTimeout :: IORef Microseconds
bytesTx :: TVar Int
bytesRx :: TVar Int
addressValidated :: TVar Bool
pendingQ :: Array EncryptionLevel (TVar [ReceivedPacket])
ciphers :: IOArray EncryptionLevel Cipher
coders :: IOArray EncryptionLevel Coder
coders1RTT :: IOArray Bool Coder1RTT
protectors :: IOArray EncryptionLevel Protector
currentKeyPhase :: IORef (Bool, PacketNumber)
negotiated :: IORef Negotiated
connMyAuthCIDs :: IORef AuthCIDs
connPeerAuthCIDs :: IORef AuthCIDs
connResources :: IORef (IO ())
encodeBuf :: Buffer
encryptRes :: SizedBuffer
decryptBuf :: Buffer
connLDCC :: LDCC

Instances

Instances details

Connector Connection Source #
Instance details Defined in Network.QUIC.Connection.Types Methods getRole :: Connection -> Role Source # getEncryptionLevel :: Connection -> IO EncryptionLevel Source # getMaxPacketSize :: Connection -> IO Int Source # getConnectionState :: Connection -> IO ConnectionState Source # getPacketNumber :: Connection -> IO PacketNumber Source # getAlive :: Connection -> IO Bool Source #
KeepQlog Connection Source #
Instance details Defined in Network.QUIC.Connection.Types Methods keepQlog :: Connection -> QLogger Source #

setDead :: Connection -> IO () Source #

makePendingQ :: IO (Array EncryptionLevel (TVar [ReceivedPacket])) Source #

newConnection :: Role -> Parameters -> VersionInfo -> AuthCIDs -> AuthCIDs -> DebugLogger -> QLogger -> Hooks -> IORef UDPSocket -> RecvQ -> Send -> Recv -> IO Connection Source #

defaultTrafficSecrets :: (ClientTrafficSecret a, ServerTrafficSecret a) Source #

clientConnection :: ClientConfig -> VersionInfo -> AuthCIDs -> AuthCIDs -> DebugLogger -> QLogger -> Hooks -> IORef UDPSocket -> RecvQ -> Send -> Recv -> IO Connection Source #

serverConnection :: ServerConfig -> VersionInfo -> AuthCIDs -> AuthCIDs -> DebugLogger -> QLogger -> Hooks -> IORef UDPSocket -> RecvQ -> Send -> Recv -> IO Connection Source #

newtype Input Source #

Constructors

InpStream Stream

Instances

Instances details

Show Input Source #
Instance details Defined in Network.QUIC.Connection.Types Methods showsPrec :: Int -> Input -> ShowS # show :: Input -> String # showList :: [Input] -> ShowS #

data Crypto Source #

Constructors

InpHandshake EncryptionLevel ByteString

Instances

Instances details

Show Crypto Source #
Instance details Defined in Network.QUIC.Connection.Types Methods showsPrec :: Int -> Crypto -> ShowS # show :: Crypto -> String # showList :: [Crypto] -> ShowS #

data Output Source #

Constructors

OutControl EncryptionLevel [Frame] (IO ())
OutHandshake [(EncryptionLevel, ByteString)]
OutRetrans PlainPacket

type InputQ = TQueue Input Source #

type CryptoQ = TQueue Crypto Source #

type OutputQ = TQueue Output Source #

type OutputQLim = TBQueue Output Source #

type MigrationQ = TQueue ReceivedPacket Source #

type SendStreamQ = TQueue TxStreamData Source #

data Shared Source #

Constructors

Shared
Fields sharedCloseSent :: IORef Bool sharedCloseReceived :: IORef Bool shared1RTTReady :: IORef Bool sharedSendStreamQ :: SendStreamQ

newShared :: IO Shared Source #

class Connector a where Source #

Methods

getRole :: a -> Role Source #

getEncryptionLevel :: a -> IO EncryptionLevel Source #

getMaxPacketSize :: a -> IO Int Source #

getConnectionState :: a -> IO ConnectionState Source #

getPacketNumber :: a -> IO PacketNumber Source #

getAlive :: a -> IO Bool Source #

Instances

Instances details

Connector Connection Source #
Instance details Defined in Network.QUIC.Connection.Types Methods getRole :: Connection -> Role Source # getEncryptionLevel :: Connection -> IO EncryptionLevel Source # getMaxPacketSize :: Connection -> IO Int Source # getConnectionState :: Connection -> IO ConnectionState Source # getPacketNumber :: Connection -> IO PacketNumber Source # getAlive :: Connection -> IO Bool Source #
Connector LDCC Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods getRole :: LDCC -> Role Source # getEncryptionLevel :: LDCC -> IO EncryptionLevel Source # getMaxPacketSize :: LDCC -> IO Int Source # getConnectionState :: LDCC -> IO ConnectionState Source # getPacketNumber :: LDCC -> IO PacketNumber Source # getAlive :: LDCC -> IO Bool Source #

data ConnState Source #

Constructors

ConnState
Fields role :: Role connectionState :: TVar ConnectionState packetNumber :: IORef PacketNumber encryptionLevel :: TVar EncryptionLevel maxPacketSize :: IORef Int connectionAlive :: IORef Bool

newConnState :: Role -> IO ConnState Source #

data Role Source #

Constructors

Client
Server

Instances

Instances details

Show Role Source #
Instance details Defined in Network.QUIC.Connector Methods showsPrec :: Int -> Role -> ShowS # show :: Role -> String # showList :: [Role] -> ShowS #
Eq Role Source #
Instance details Defined in Network.QUIC.Connector Methods (==) :: Role -> Role -> Bool # (/=) :: Role -> Role -> Bool #

isClient :: Connector a => a -> Bool Source #

isServer :: Connector a => a -> Bool Source #

data ConnectionState Source #

Constructors

Handshaking
ReadyFor0RTT
ReadyFor1RTT
Established

Instances

Instances details

Show ConnectionState Source #
Instance details Defined in Network.QUIC.Connector Methods showsPrec :: Int -> ConnectionState -> ShowS # show :: ConnectionState -> String # showList :: [ConnectionState] -> ShowS #
Eq ConnectionState Source #
Instance details Defined in Network.QUIC.Connector Methods (==) :: ConnectionState -> ConnectionState -> Bool # (/=) :: ConnectionState -> ConnectionState -> Bool #
Ord ConnectionState Source #
Instance details Defined in Network.QUIC.Connector Methods compare :: ConnectionState -> ConnectionState -> Ordering # (<) :: ConnectionState -> ConnectionState -> Bool # (<=) :: ConnectionState -> ConnectionState -> Bool # (>) :: ConnectionState -> ConnectionState -> Bool # (>=) :: ConnectionState -> ConnectionState -> Bool # max :: ConnectionState -> ConnectionState -> ConnectionState # min :: ConnectionState -> ConnectionState -> ConnectionState #

isConnectionEstablished :: Connector a => a -> IO Bool Source #

data FusionContext Source #

fusionNewContext :: IO FusionContext Source #

fusionSetup :: Cipher -> FusionContext -> Key -> IV -> IO () Source #

fusionEncrypt :: FusionContext -> Supplement -> Buffer -> PlainText -> AssDat -> PacketNumber -> IO Int Source #

fusionDecrypt :: FusionContext -> Buffer -> CipherText -> AssDat -> PacketNumber -> IO Int Source #

data Supplement Source #

fusionSetupSupplement :: Cipher -> Key -> IO Supplement Source #

fusionSetSample :: Supplement -> Buffer -> IO () Source #

fusionGetMask :: Supplement -> IO Buffer Source #

isFusionAvailable :: IO Bool Source #

niteEncrypt :: Cipher -> Key -> IV -> PlainText -> AssDat -> PacketNumber -> Maybe (CipherText, CipherText) Source #

niteEncrypt' :: Cipher -> Key -> Nonce -> PlainText -> AssDat -> Maybe (CipherText, CipherText) Source #

niteDecrypt :: Cipher -> Key -> IV -> CipherText -> AssDat -> PacketNumber -> Maybe PlainText Source #

niteDecrypt' :: Cipher -> Key -> Nonce -> CipherText -> AssDat -> Maybe PlainText Source #

protectionMask :: Cipher -> Key -> Sample -> Mask Source #

aes128gcmEncrypt :: Key -> Nonce -> PlainText -> AssDat -> Maybe (CipherText, CipherText) Source #

makeNonce :: IV -> ByteString -> Nonce Source #

makeNiteEncrypt :: Cipher -> Key -> IV -> NiteEncrypt Source #

makeNiteDecrypt :: Cipher -> Key -> IV -> NiteDecrypt Source #

makeNiteProtector :: Cipher -> Key -> IO (Buffer -> IO (), IO Buffer) Source #

Types

type PlainText = ByteString Source #

type CipherText = ByteString Source #

newtype Key Source #

Constructors

Key ByteString

Instances

Instances details

Show Key Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods showsPrec :: Int -> Key -> ShowS # show :: Key -> String # showList :: [Key] -> ShowS #
Eq Key Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods (==) :: Key -> Key -> Bool # (/=) :: Key -> Key -> Bool #

newtype IV Source #

Constructors

IV ByteString

Instances

Instances details

Show IV Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods showsPrec :: Int -> IV -> ShowS # show :: IV -> String # showList :: [IV] -> ShowS #
Eq IV Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods (==) :: IV -> IV -> Bool # (/=) :: IV -> IV -> Bool #

data CID Source #

A type for conneciton ID.

Instances

Instances details

Generic CID Source #
Instance details Defined in Network.QUIC.Types.CID Associated Types type Rep CID :: Type -> Type # Methods from :: CID -> Rep CID x # to :: Rep CID x -> CID #
Show CID Source #
Instance details Defined in Network.QUIC.Types.CID Methods showsPrec :: Int -> CID -> ShowS # show :: CID -> String # showList :: [CID] -> ShowS #
Eq CID Source #
Instance details Defined in Network.QUIC.Types.CID Methods (==) :: CID -> CID -> Bool # (/=) :: CID -> CID -> Bool #
Ord CID Source #
Instance details Defined in Network.QUIC.Types.CID Methods compare :: CID -> CID -> Ordering # (<) :: CID -> CID -> Bool # (<=) :: CID -> CID -> Bool # (>) :: CID -> CID -> Bool # (>=) :: CID -> CID -> Bool # max :: CID -> CID -> CID # min :: CID -> CID -> CID #
Serialise CID Source #
Instance details Defined in Network.QUIC.Types.CID Methods encode :: CID -> Encoding # decode :: Decoder s CID # encodeList :: [CID] -> Encoding # decodeList :: Decoder s [CID] #
type Rep CID Source #
Instance details Defined in Network.QUIC.Types.CID type Rep CID = D1 ('MetaData "CID" "Network.QUIC.Types.CID" "quic-0.1.20-4xBoOzsr86T1PD98iEWMzj" 'True) (C1 ('MetaCons "CID" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bytes)))

newtype Secret Source #

Constructors

Secret ByteString

Instances

Instances details

Show Secret Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods showsPrec :: Int -> Secret -> ShowS # show :: Secret -> String # showList :: [Secret] -> ShowS #
Eq Secret Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods (==) :: Secret -> Secret -> Bool # (/=) :: Secret -> Secret -> Bool #

newtype AssDat Source #

Constructors

AssDat ByteString

Instances

Instances details

Show AssDat Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods showsPrec :: Int -> AssDat -> ShowS # show :: AssDat -> String # showList :: [AssDat] -> ShowS #
Eq AssDat Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods (==) :: AssDat -> AssDat -> Bool # (/=) :: AssDat -> AssDat -> Bool #

newtype Sample Source #

Constructors

Sample ByteString

Instances

Instances details

Show Sample Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods showsPrec :: Int -> Sample -> ShowS # show :: Sample -> String # showList :: [Sample] -> ShowS #
Eq Sample Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods (==) :: Sample -> Sample -> Bool # (/=) :: Sample -> Sample -> Bool #

newtype Mask Source #

Constructors

Mask ByteString

Instances

Instances details

Show Mask Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods showsPrec :: Int -> Mask -> ShowS # show :: Mask -> String # showList :: [Mask] -> ShowS #
Eq Mask Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods (==) :: Mask -> Mask -> Bool # (/=) :: Mask -> Mask -> Bool #

newtype Nonce Source #

Constructors

Nonce ByteString

Instances

Instances details

Show Nonce Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods showsPrec :: Int -> Nonce -> ShowS # show :: Nonce -> String # showList :: [Nonce] -> ShowS #
Eq Nonce Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods (==) :: Nonce -> Nonce -> Bool # (/=) :: Nonce -> Nonce -> Bool #

type Salt = ByteString Source #

newtype Label Source #

Constructors

Label ByteString

Instances

Instances details

Show Label Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods showsPrec :: Int -> Label -> ShowS # show :: Label -> String # showList :: [Label] -> ShowS #
Eq Label Source #
Instance details Defined in Network.QUIC.Crypto.Types Methods (==) :: Label -> Label -> Bool # (/=) :: Label -> Label -> Bool #

data Cipher #

Cipher algorithm

Instances

Instances details

Show Cipher
Instance details Defined in Network.TLS.Cipher Methods showsPrec :: Int -> Cipher -> ShowS # show :: Cipher -> String # showList :: [Cipher] -> ShowS #
Eq Cipher
Instance details Defined in Network.TLS.Cipher Methods (==) :: Cipher -> Cipher -> Bool # (/=) :: Cipher -> Cipher -> Bool #

data InitialSecret Source #

type TrafficSecrets a = (ClientTrafficSecret a, ServerTrafficSecret a) #

Hold both client and server traffic secrets at the same step.

newtype ClientTrafficSecret a #

A client traffic secret, typed with a parameter indicating a step in the TLS key schedule.

Constructors

ClientTrafficSecret ByteString

Instances

Instances details

Show (ClientTrafficSecret a)
Instance details Defined in Network.TLS.Types Methods showsPrec :: Int -> ClientTrafficSecret a -> ShowS # show :: ClientTrafficSecret a -> String # showList :: [ClientTrafficSecret a] -> ShowS #

newtype ServerTrafficSecret a #

A server traffic secret, typed with a parameter indicating a step in the TLS key schedule.

Constructors

ServerTrafficSecret ByteString

Instances

Instances details

Show (ServerTrafficSecret a)
Instance details Defined in Network.TLS.Types Methods showsPrec :: Int -> ServerTrafficSecret a -> ShowS # show :: ServerTrafficSecret a -> String # showList :: [ServerTrafficSecret a] -> ShowS #

defaultCipher :: Cipher Source #

initialSecrets :: Version -> CID -> TrafficSecrets InitialSecret Source #

clientInitialSecret :: Version -> CID -> ClientTrafficSecret InitialSecret Source #

serverInitialSecret :: Version -> CID -> ServerTrafficSecret InitialSecret Source #

aeadKey :: Version -> Cipher -> Secret -> Key Source #

initialVector :: Version -> Cipher -> Secret -> IV Source #

nextSecret :: Version -> Cipher -> Secret -> Secret Source #

headerProtectionKey :: Version -> Cipher -> Secret -> Key Source #

tagLength :: Cipher -> Int Source #

sampleLength :: Cipher -> Int Source #

bsXOR :: ByteString -> ByteString -> ByteString Source #

calculateIntegrityTag :: Version -> CID -> ByteString -> ByteString Source #

data Builder #

Builders denote sequences of bytes. They are Monoids where mempty is the zero-length sequence and mappend is concatenation, which runs in O(1).

Instances

Instances details

Monoid Builder
Instance details Defined in Data.ByteString.Builder.Internal Methods mempty :: Builder # mappend :: Builder -> Builder -> Builder # mconcat :: [Builder] -> Builder #
Semigroup Builder
Instance details Defined in Data.ByteString.Builder.Internal Methods (<>) :: Builder -> Builder -> Builder # sconcat :: NonEmpty Builder -> Builder # stimes :: Integral b => b -> Builder -> Builder #
ToLogStr Builder
Instance details Defined in System.Log.FastLogger.LogStr Methods toLogStr :: Builder -> LogStr #

type DebugLogger = Builder -> IO () Source #

A type for debug logger.

bhow :: Show a => a -> Builder Source #

stdoutLogger :: DebugLogger Source #

dirDebugLogger :: Maybe FilePath -> CID -> IO (DebugLogger, IO ()) Source #

Encode

encodeVersionNegotiationPacket :: VersionNegotiationPacket -> IO ByteString Source #

This is not used internally.

encodeRetryPacket :: RetryPacket -> IO ByteString Source #

encodePlainPacket :: Connection -> SizedBuffer -> PlainPacket -> Maybe Int -> IO (Int, Int) Source #

Decode

decodePacket :: ByteString -> IO (PacketI, ByteString) Source #

decodePackets :: ByteString -> IO [PacketI] Source #

decodeCryptPackets :: ByteString -> IO [(CryptPacket, EncryptionLevel, Int)] Source #

decryptCrypt :: Connection -> Crypt -> EncryptionLevel -> IO (Maybe Plain) Source #

decodeStatelessResetToken :: ByteString -> Maybe StatelessResetToken Source #

Frame

encodeFrames :: [Frame] -> IO ByteString Source #

decodeFramesBuffer :: Buffer -> BufferSize -> IO (Maybe [Frame]) Source #

decodeFramesBS :: ByteString -> IO (Maybe [Frame]) Source #

countZero :: Ptr Word8 -> Ptr Word8 -> IO Int Source #

Header

isLong :: Word8 -> Bool Source #

isShort :: Flags Protected -> Bool Source #

protectFlags :: Flags Raw -> Word8 -> Flags Protected Source #

unprotectFlags :: Flags Protected -> Word8 -> Flags Raw Source #

encodeLongHeaderFlags :: Version -> LongHeaderPacketType -> Flags Raw -> Flags Raw -> Bool -> IO (Flags Raw) Source #

encodeShortHeaderFlags :: Flags Raw -> Flags Raw -> Bool -> Bool -> IO (Flags Raw) Source #

decodeLongHeaderPacketType :: Version -> Flags Protected -> LongHeaderPacketType Source #

encodePktNumLength :: Int -> Flags Raw Source #

decodePktNumLength :: Flags Raw -> Int Source #

versionNegotiationPacketType :: IO (Flags Raw) Source #

retryPacketType :: Version -> IO (Flags Raw) Source #

Token

data CryptoToken Source #

Constructors

CryptoToken
Fields tokenQUICVersion :: Version tokenLifeTime :: Word32 tokenCreatedTime :: TimeMicrosecond tokenCIDs :: Maybe (CID, CID, CID)

Instances

Instances details

Generic CryptoToken Source #
Instance details Defined in Network.QUIC.Packet.Token Associated Types type Rep CryptoToken :: Type -> Type # Methods from :: CryptoToken -> Rep CryptoToken x # to :: Rep CryptoToken x -> CryptoToken #
Serialise CryptoToken Source #
Instance details Defined in Network.QUIC.Packet.Token Methods encode :: CryptoToken -> Encoding # decode :: Decoder s CryptoToken # encodeList :: [CryptoToken] -> Encoding # decodeList :: Decoder s [CryptoToken] #
type Rep CryptoToken Source #
Instance details Defined in Network.QUIC.Packet.Token type Rep CryptoToken = D1 ('MetaData "CryptoToken" "Network.QUIC.Packet.Token" "quic-0.1.20-4xBoOzsr86T1PD98iEWMzj" 'False) (C1 ('MetaCons "CryptoToken" 'PrefixI 'True) ((S1 ('MetaSel ('Just "tokenQUICVersion") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Version) :: S1 ('MetaSel ('Just "tokenLifeTime") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Word32)) :: (S1 ('MetaSel ('Just "tokenCreatedTime") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 TimeMicrosecond) :*: S1 ('MetaSel ('Just "tokenCIDs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe (CID, CID, CID))))))

isRetryToken :: CryptoToken -> Bool Source #

generateToken :: Version -> Int -> IO CryptoToken Source #

generateRetryToken :: Version -> Int -> CID -> CID -> CID -> IO CryptoToken Source #

encryptToken :: TokenManager -> CryptoToken -> IO Token Source #

decryptToken :: TokenManager -> Token -> IO (Maybe CryptoToken) Source #

data Parameters Source #

QUIC transport parameters.

Constructors

Parameters

Instances

Instances details

Show Parameters Source #
Instance details Defined in Network.QUIC.Parameters Methods showsPrec :: Int -> Parameters -> ShowS # show :: Parameters -> String # showList :: [Parameters] -> ShowS #
Eq Parameters Source #
Instance details Defined in Network.QUIC.Parameters Methods (==) :: Parameters -> Parameters -> Bool # (/=) :: Parameters -> Parameters -> Bool #
Qlog (Parameters, String) Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: (Parameters, String) -> LogStr Source #

defaultParameters :: Parameters Source #

An example parameters obsoleted in the near future.

>>> defaultParameters
Parameters {originalDestinationConnectionId = Nothing, maxIdleTimeout = 30000, statelessResetToken = Nothing, maxUdpPayloadSize = 2048, initialMaxData = 1048576, initialMaxStreamDataBidiLocal = 262144, initialMaxStreamDataBidiRemote = 262144, initialMaxStreamDataUni = 262144, initialMaxStreamsBidi = 64, initialMaxStreamsUni = 3, ackDelayExponent = 3, maxAckDelay = 25, disableActiveMigration = False, preferredAddress = Nothing, activeConnectionIdLimit = 3, initialSourceConnectionId = Nothing, retrySourceConnectionId = Nothing, grease = Nothing, greaseQuicBit = True, versionInformation = Nothing}

baseParameters :: Parameters Source #

The default value for QUIC transport parameters.

encodeParameters :: Parameters -> ByteString Source #

decodeParameters :: ByteString -> Maybe Parameters Source #

data AuthCIDs Source #

Constructors

AuthCIDs
Fields initSrcCID :: Maybe CID origDstCID :: Maybe CID retrySrcCID :: Maybe CID

Instances

Instances details

Show AuthCIDs Source #
Instance details Defined in Network.QUIC.Parameters Methods showsPrec :: Int -> AuthCIDs -> ShowS # show :: AuthCIDs -> String # showList :: [AuthCIDs] -> ShowS #
Eq AuthCIDs Source #
Instance details Defined in Network.QUIC.Parameters Methods (==) :: AuthCIDs -> AuthCIDs -> Bool # (/=) :: AuthCIDs -> AuthCIDs -> Bool #

defaultAuthCIDs :: AuthCIDs Source #

setCIDsToParameters :: AuthCIDs -> Parameters -> Parameters Source #

getCIDsToParameters :: Parameters -> AuthCIDs Source #

type QLogger = QlogMsg -> IO () Source #

newQlogger :: TimeMicrosecond -> ByteString -> CID -> FastLogger -> IO QLogger Source #

class Qlog a where Source #

Methods

qlog :: a -> LogStr Source #

Instances

Instances details

Qlog Debug Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: Debug -> LogStr Source #
Qlog LR Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: LR -> LogStr Source #
Qlog SentPacket Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods qlog :: SentPacket -> LogStr Source #
Qlog Frame Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: Frame -> LogStr Source #
Qlog CryptPacket Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: CryptPacket -> LogStr Source #
Qlog Header Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: Header -> LogStr Source #
Qlog PlainPacket Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: PlainPacket -> LogStr Source #
Qlog RetryPacket Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: RetryPacket -> LogStr Source #
Qlog StatelessReset Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: StatelessReset -> LogStr Source #
Qlog VersionNegotiationPacket Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: VersionNegotiationPacket -> LogStr Source #
Qlog (Parameters, String) Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: (Parameters, String) -> LogStr Source #

class KeepQlog a where Source #

Methods

keepQlog :: a -> QLogger Source #

Instances

Instances details

KeepQlog Connection Source #
Instance details Defined in Network.QUIC.Connection.Types Methods keepQlog :: Connection -> QLogger Source #
KeepQlog LDCC Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods keepQlog :: LDCC -> QLogger Source #

qlogReceived :: (KeepQlog q, Qlog a) => q -> a -> TimeMicrosecond -> IO () Source #

qlogDropped :: (KeepQlog q, Qlog a) => q -> a -> IO () Source #

qlogRecvInitial :: KeepQlog q => q -> IO () Source #

qlogSentRetry :: KeepQlog q => q -> IO () Source #

qlogParamsSet :: KeepQlog q => q -> (Parameters, String) -> IO () Source #

qlogDebug :: KeepQlog q => q -> Debug -> IO () Source #

qlogCIDUpdate :: KeepQlog q => q -> LR -> IO () Source #

newtype Debug Source #

Constructors

Debug LogStr

Instances

Instances details

Show Debug Source #
Instance details Defined in Network.QUIC.Qlog Methods showsPrec :: Int -> Debug -> ShowS # show :: Debug -> String # showList :: [Debug] -> ShowS #
Qlog Debug Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: Debug -> LogStr Source #

data LR Source #

Constructors

Local CID
Remote CID

Instances

Instances details

Qlog LR Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: LR -> LogStr Source #

packetType :: Header -> LogStr Source #

sw :: Show a => a -> LogStr Source #

Types

data Stream Source #

An abstract data type for streams.

Instances

Instances details

Show Stream Source #
Instance details Defined in Network.QUIC.Stream.Types Methods showsPrec :: Int -> Stream -> ShowS # show :: Stream -> String # showList :: [Stream] -> ShowS #

streamId :: Stream -> StreamId Source #

Getting stream identifier.

streamConnection :: Stream -> Connection Source #

newStream :: Connection -> Int -> Int -> StreamId -> IO Stream Source #

data TxStreamData Source #

Constructors

TxStreamData Stream [StreamData] Length Fin

data StreamState Source #

Constructors

StreamState
Fields streamOffset :: Offset streamFin :: Fin

Instances

Instances details

Show StreamState Source #
Instance details Defined in Network.QUIC.Stream.Types Methods showsPrec :: Int -> StreamState -> ShowS # show :: StreamState -> String # showList :: [StreamState] -> ShowS #
Eq StreamState Source #
Instance details Defined in Network.QUIC.Stream.Types Methods (==) :: StreamState -> StreamState -> Bool # (/=) :: StreamState -> StreamState -> Bool #

data RecvStreamQ Source #

Constructors

RecvStreamQ
Fields recvStreamQ :: TQueue ByteString pendingData :: IORef (Maybe ByteString) endOfStream :: IORef Bool

data RxStreamData Source #

Constructors

RxStreamData
Fields rxstrmData :: StreamData rxstrmOff :: Offset rxstrmLen :: Length rxstrmFin :: Fin

Instances

Instances details

Show RxStreamData Source #
Instance details Defined in Network.QUIC.Stream.Types Methods showsPrec :: Int -> RxStreamData -> ShowS # show :: RxStreamData -> String # showList :: [RxStreamData] -> ShowS #
Eq RxStreamData Source #
Instance details Defined in Network.QUIC.Stream.Types Methods (==) :: RxStreamData -> RxStreamData -> Bool # (/=) :: RxStreamData -> RxStreamData -> Bool #

type Length = Int Source #

syncFinTx :: Stream -> IO () Source #

waitFinTx :: Stream -> IO () Source #

Misc

getTxStreamOffset :: Stream -> Int -> IO Offset Source #

isTxStreamClosed :: Stream -> IO Bool Source #

setTxStreamClosed :: Stream -> IO () Source #

getRxStreamOffset :: Stream -> Int -> IO Offset Source #

isRxStreamClosed :: Stream -> IO Bool Source #

setRxStreamClosed :: Stream -> IO () Source #

readStreamFlowTx :: Stream -> STM TxFlow Source #

addTxStreamData :: Stream -> Int -> STM () Source #

setTxMaxStreamData :: Stream -> Int -> IO () Source #

getRxMaxStreamData :: Stream -> IO Int Source #

updateStreamFlowRx :: Stream -> Int -> IO (Maybe Int) Source #

Reass

takeRecvStreamQwithSize :: Stream -> Int -> IO ByteString Source #

putRxStreamData :: Stream -> RxStreamData -> IO FlowCntl Source #

data FlowCntl Source #

Constructors

OverLimit
Duplicated
Reassembled

tryReassemble :: Stream -> RxStreamData -> (StreamData -> IO ()) -> IO () -> IO Bool Source #

Table

data StreamTable Source #

emptyStreamTable :: StreamTable Source #

lookupStream :: StreamId -> StreamTable -> Maybe Stream Source #

insertStream :: StreamId -> Stream -> StreamTable -> StreamTable Source #

deleteStream :: StreamId -> StreamTable -> StreamTable Source #

insertCryptoStreams :: Connection -> StreamTable -> IO StreamTable Source #

deleteCryptoStream :: EncryptionLevel -> StreamTable -> StreamTable Source #

lookupCryptoStream :: EncryptionLevel -> StreamTable -> Maybe Stream Source #

clientHandshaker :: QUICCallbacks -> ClientConfig -> Version -> AuthCIDs -> SessionEstablish -> Bool -> IO () Source #

serverHandshaker :: QUICCallbacks -> ServerConfig -> Version -> IO Parameters -> IO () Source #

type Bytes = ShortByteString Source #

All internal byte sequences. ByteString should be used for FFI related stuff.

type Close = IO () Source #

data Direction Source #

Constructors

Unidirectional
Bidirectional

Instances

Instances details

Show Direction Source #
Instance details Defined in Network.QUIC.Types.Frame Methods showsPrec :: Int -> Direction -> ShowS # show :: Direction -> String # showList :: [Direction] -> ShowS #
Eq Direction Source #
Instance details Defined in Network.QUIC.Types.Frame Methods (==) :: Direction -> Direction -> Bool # (/=) :: Direction -> Direction -> Bool #

data SizedBuffer Source #

Constructors

SizedBuffer Buffer BufferSize

type PacketNumber = Int Source #

type Range = Int Source #

type Gap = Int Source #

data AckInfo Source #

Constructors

AckInfo PacketNumber Range [(Gap, Range)]

Instances

Instances details

Show AckInfo Source #
Instance details Defined in Network.QUIC.Types.Ack Methods showsPrec :: Int -> AckInfo -> ShowS # show :: AckInfo -> String # showList :: [AckInfo] -> ShowS #
Eq AckInfo Source #
Instance details Defined in Network.QUIC.Types.Ack Methods (==) :: AckInfo -> AckInfo -> Bool # (/=) :: AckInfo -> AckInfo -> Bool #

ackInfo0 :: AckInfo Source #

toAckInfo :: [PacketNumber] -> AckInfo Source #

>>> toAckInfo [9]
AckInfo 9 0 []
>>> toAckInfo [9,8,7]
AckInfo 9 2 []
>>> toAckInfo [8,7,3,2]
AckInfo 8 1 [(2,1)]
>>> toAckInfo [9,8,7,5,4]
AckInfo 9 2 [(0,1)]

fromAckInfo :: AckInfo -> [PacketNumber] Source #

>>> fromAckInfo $ AckInfo 9 0 []
[9]
>>> fromAckInfo $ AckInfo 9 2 []
[7,8,9]
>>> fromAckInfo $ AckInfo 8 1 [(2,1)]
[2,3,7,8]
>>> fromAckInfo $ AckInfo 9 2 [(0,1)]
[4,5,7,8,9]

fromAckInfoWithMin :: AckInfo -> PacketNumber -> [PacketNumber] Source #

>>> fromAckInfoWithMin (AckInfo 9 0 []) 1
[9]
>>> fromAckInfoWithMin (AckInfo 9 2 []) 8
[8,9]
>>> fromAckInfoWithMin (AckInfo 8 1 [(2,1)]) 3
[3,7,8]
>>> fromAckInfoWithMin (AckInfo 9 2 [(0,1)]) 8
[8,9]

fromAckInfoToPred :: AckInfo -> PacketNumber -> Bool Source #

newtype PeerPacketNumbers Source #

Constructors

PeerPacketNumbers IntSet

Instances

Instances details

Show PeerPacketNumbers Source #
Instance details Defined in Network.QUIC.Types.Ack Methods showsPrec :: Int -> PeerPacketNumbers -> ShowS # show :: PeerPacketNumbers -> String # showList :: [PeerPacketNumbers] -> ShowS #
Eq PeerPacketNumbers Source #
Instance details Defined in Network.QUIC.Types.Ack Methods (==) :: PeerPacketNumbers -> PeerPacketNumbers -> Bool # (/=) :: PeerPacketNumbers -> PeerPacketNumbers -> Bool #

emptyPeerPacketNumbers :: PeerPacketNumbers Source #

newtype CID Source #

A type for conneciton ID.

Constructors

CID Bytes

Instances

Instances details

Generic CID Source #
Instance details Defined in Network.QUIC.Types.CID Associated Types type Rep CID :: Type -> Type # Methods from :: CID -> Rep CID x # to :: Rep CID x -> CID #
Show CID Source #
Instance details Defined in Network.QUIC.Types.CID Methods showsPrec :: Int -> CID -> ShowS # show :: CID -> String # showList :: [CID] -> ShowS #
Eq CID Source #
Instance details Defined in Network.QUIC.Types.CID Methods (==) :: CID -> CID -> Bool # (/=) :: CID -> CID -> Bool #
Ord CID Source #
Instance details Defined in Network.QUIC.Types.CID Methods compare :: CID -> CID -> Ordering # (<) :: CID -> CID -> Bool # (<=) :: CID -> CID -> Bool # (>) :: CID -> CID -> Bool # (>=) :: CID -> CID -> Bool # max :: CID -> CID -> CID # min :: CID -> CID -> CID #
Serialise CID Source #
Instance details Defined in Network.QUIC.Types.CID Methods encode :: CID -> Encoding # decode :: Decoder s CID # encodeList :: [CID] -> Encoding # decodeList :: Decoder s [CID] #
type Rep CID Source #
Instance details Defined in Network.QUIC.Types.CID type Rep CID = D1 ('MetaData "CID" "Network.QUIC.Types.CID" "quic-0.1.20-4xBoOzsr86T1PD98iEWMzj" 'True) (C1 ('MetaCons "CID" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bytes)))

myCIDLength :: Int Source #

newCID :: IO CID Source #

fromCID :: CID -> ByteString Source #

Converting a connection ID.

toCID :: ByteString -> CID Source #

makeCID :: ShortByteString -> CID Source #

unpackCID :: CID -> (ShortByteString, Word8) Source #

newtype StatelessResetToken Source #

Constructors

StatelessResetToken Bytes

Instances

Instances details

Show StatelessResetToken Source #
Instance details Defined in Network.QUIC.Types.CID Methods showsPrec :: Int -> StatelessResetToken -> ShowS # show :: StatelessResetToken -> String # showList :: [StatelessResetToken] -> ShowS #
Eq StatelessResetToken Source #
Instance details Defined in Network.QUIC.Types.CID Methods (==) :: StatelessResetToken -> StatelessResetToken -> Bool # (/=) :: StatelessResetToken -> StatelessResetToken -> Bool #
Ord StatelessResetToken Source #
Instance details Defined in Network.QUIC.Types.CID Methods compare :: StatelessResetToken -> StatelessResetToken -> Ordering # (<) :: StatelessResetToken -> StatelessResetToken -> Bool # (<=) :: StatelessResetToken -> StatelessResetToken -> Bool # (>) :: StatelessResetToken -> StatelessResetToken -> Bool # (>=) :: StatelessResetToken -> StatelessResetToken -> Bool # max :: StatelessResetToken -> StatelessResetToken -> StatelessResetToken # min :: StatelessResetToken -> StatelessResetToken -> StatelessResetToken #

newStatelessResetToken :: IO StatelessResetToken Source #

newtype PathData Source #

Constructors

PathData Bytes

Instances

Instances details

Show PathData Source #
Instance details Defined in Network.QUIC.Types.CID Methods showsPrec :: Int -> PathData -> ShowS # show :: PathData -> String # showList :: [PathData] -> ShowS #
Eq PathData Source #
Instance details Defined in Network.QUIC.Types.CID Methods (==) :: PathData -> PathData -> Bool # (/=) :: PathData -> PathData -> Bool #

newPathData :: IO PathData Source #

data CIDInfo Source #

Constructors

CIDInfo
Fields cidInfoSeq :: Int cidInfoCID :: CID cidInfoSRT :: StatelessResetToken

Instances

Instances details

Show CIDInfo Source #
Instance details Defined in Network.QUIC.Types.CID Methods showsPrec :: Int -> CIDInfo -> ShowS # show :: CIDInfo -> String # showList :: [CIDInfo] -> ShowS #
Eq CIDInfo Source #
Instance details Defined in Network.QUIC.Types.CID Methods (==) :: CIDInfo -> CIDInfo -> Bool # (/=) :: CIDInfo -> CIDInfo -> Bool #
Ord CIDInfo Source #
Instance details Defined in Network.QUIC.Types.CID Methods compare :: CIDInfo -> CIDInfo -> Ordering # (<) :: CIDInfo -> CIDInfo -> Bool # (<=) :: CIDInfo -> CIDInfo -> Bool # (>) :: CIDInfo -> CIDInfo -> Bool # (>=) :: CIDInfo -> CIDInfo -> Bool # max :: CIDInfo -> CIDInfo -> CIDInfo # min :: CIDInfo -> CIDInfo -> CIDInfo #

maximumUdpPayloadSize :: Int Source #

defaultQUICPacketSize :: Int Source #

defaultQUICPacketSizeForIPv4 :: Int Source #

defaultQUICPacketSizeForIPv6 :: Int Source #

maximumQUICHeaderSize :: Int Source #

idleTimeout :: Microseconds Source #

newtype TransportError Source #

Transport errors of QUIC.

Constructors

TransportError Int

Instances

Instances details

Show TransportError Source #
Instance details Defined in Network.QUIC.Types.Error Methods showsPrec :: Int -> TransportError -> ShowS # show :: TransportError -> String # showList :: [TransportError] -> ShowS #
Eq TransportError Source #
Instance details Defined in Network.QUIC.Types.Error Methods (==) :: TransportError -> TransportError -> Bool # (/=) :: TransportError -> TransportError -> Bool #

pattern NoError :: TransportError Source #

pattern InternalError :: TransportError Source #

pattern ConnectionRefused :: TransportError Source #

pattern FlowControlError :: TransportError Source #

pattern StreamLimitError :: TransportError Source #

pattern StreamStateError :: TransportError Source #

pattern FinalSizeError :: TransportError Source #

pattern FrameEncodingError :: TransportError Source #

pattern TransportParameterError :: TransportError Source #

pattern ConnectionIdLimitError :: TransportError Source #

pattern ProtocolViolation :: TransportError Source #

pattern InvalidToken :: TransportError Source #

pattern ApplicationError :: TransportError Source #

pattern CryptoBufferExceeded :: TransportError Source #

pattern KeyUpdateError :: TransportError Source #

pattern AeadLimitReached :: TransportError Source #

pattern NoViablePath :: TransportError Source #

pattern VersionNegotiationError :: TransportError Source #

cryptoError :: AlertDescription -> TransportError Source #

Converting a TLS alert to a corresponding transport error.

newtype ApplicationProtocolError Source #

Application protocol errors of QUIC.

Constructors

ApplicationProtocolError Int

Instances

Instances details

Show ApplicationProtocolError Source #
Instance details Defined in Network.QUIC.Types.Error Methods showsPrec :: Int -> ApplicationProtocolError -> ShowS # show :: ApplicationProtocolError -> String # showList :: [ApplicationProtocolError] -> ShowS #
Eq ApplicationProtocolError Source #
Instance details Defined in Network.QUIC.Types.Error Methods (==) :: ApplicationProtocolError -> ApplicationProtocolError -> Bool # (/=) :: ApplicationProtocolError -> ApplicationProtocolError -> Bool #

data QUICException Source #

User level exceptions for QUIC.

Instances

Instances details

Exception QUICException Source #
Instance details Defined in Network.QUIC.Types.Exception Methods toException :: QUICException -> SomeException # fromException :: SomeException -> Maybe QUICException # displayException :: QUICException -> String #
Show QUICException Source #
Instance details Defined in Network.QUIC.Types.Exception Methods showsPrec :: Int -> QUICException -> ShowS # show :: QUICException -> String # showList :: [QUICException] -> ShowS #

data InternalControl Source #

Constructors

MustNotReached
ExitConnection
WrongTransportParameter
WrongVersionInformation
BreakForever

Instances

Instances details

Exception InternalControl Source #
Instance details Defined in Network.QUIC.Types.Exception Methods toException :: InternalControl -> SomeException # fromException :: SomeException -> Maybe InternalControl # displayException :: InternalControl -> String #
Show InternalControl Source #
Instance details Defined in Network.QUIC.Types.Exception Methods showsPrec :: Int -> InternalControl -> ShowS # show :: InternalControl -> String # showList :: [InternalControl] -> ShowS #
Eq InternalControl Source #
Instance details Defined in Network.QUIC.Types.Exception Methods (==) :: InternalControl -> InternalControl -> Bool # (/=) :: InternalControl -> InternalControl -> Bool #

newtype NextVersion Source #

Constructors

NextVersion VersionInfo

Instances

Instances details

Exception NextVersion Source #
Instance details Defined in Network.QUIC.Types.Exception Methods toException :: NextVersion -> SomeException # fromException :: SomeException -> Maybe NextVersion # displayException :: NextVersion -> String #
Show NextVersion Source #
Instance details Defined in Network.QUIC.Types.Exception Methods showsPrec :: Int -> NextVersion -> ShowS # show :: NextVersion -> String # showList :: [NextVersion] -> ShowS #

data Abort Source #

Constructors

Abort ApplicationProtocolError ReasonPhrase
VerNego VersionInfo

Instances

Instances details

Exception Abort Source #
Instance details Defined in Network.QUIC.Types.Exception Methods toException :: Abort -> SomeException # fromException :: SomeException -> Maybe Abort # displayException :: Abort -> String #
Show Abort Source #
Instance details Defined in Network.QUIC.Types.Exception Methods showsPrec :: Int -> Abort -> ShowS # show :: Abort -> String # showList :: [Abort] -> ShowS #

type FrameType = Int Source #

data Direction Source #

Constructors

Unidirectional
Bidirectional

Instances

Instances details

Show Direction Source #
Instance details Defined in Network.QUIC.Types.Frame Methods showsPrec :: Int -> Direction -> ShowS # show :: Direction -> String # showList :: [Direction] -> ShowS #
Eq Direction Source #
Instance details Defined in Network.QUIC.Types.Frame Methods (==) :: Direction -> Direction -> Bool # (/=) :: Direction -> Direction -> Bool #

type ReasonPhrase = ShortByteString Source #

type SeqNum = Int Source #

data Frame Source #

Instances

Instances details

Show Frame Source #
Instance details Defined in Network.QUIC.Types.Frame Methods showsPrec :: Int -> Frame -> ShowS # show :: Frame -> String # showList :: [Frame] -> ShowS #
Eq Frame Source #
Instance details Defined in Network.QUIC.Types.Frame Methods (==) :: Frame -> Frame -> Bool # (/=) :: Frame -> Frame -> Bool #
Qlog Frame Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: Frame -> LogStr Source #

type StreamId = Int Source #

Stream identifier. This should be 62-bit interger. On 32-bit machines, the total number of stream identifiers is limited.

isClientInitiatedBidirectional :: StreamId -> Bool Source #

Checking if a stream is client-initiated bidirectional.

isServerInitiatedBidirectional :: StreamId -> Bool Source #

Checking if a stream is server-initiated bidirectional.

isClientInitiatedUnidirectional :: StreamId -> Bool Source #

Checking if a stream is client-initiated unidirectional.

isServerInitiatedUnidirectional :: StreamId -> Bool Source #

Checking if a stream is server-initiated unidirectional.

isClientInitiated :: StreamId -> Bool Source #

isServerInitiated :: StreamId -> Bool Source #

isBidirectional :: StreamId -> Bool Source #

isUnidirectional :: StreamId -> Bool Source #

type Delay = Milliseconds Source #

type Fin = Bool Source #

type CryptoData = ByteString Source #

type StreamData = ByteString Source #

type Token = ByteString Source #

emptyToken :: Token Source #

ackEliciting :: Frame -> Bool Source #

pathValidating :: Frame -> Bool Source #

inFlight :: Frame -> Bool Source #

rateControled :: Frame -> Bool Source #

encodeInt :: Int64 -> ByteString Source #

>>> enc16 $ encodeInt 151288809941952652
"c2197c5eff14e88c"
>>> enc16 $ encodeInt 494878333
"9d7f3e7d"
>>> enc16 $ encodeInt 15293
"7bbd"
>>> enc16 $ encodeInt 37
"25"

encodeInt8 :: Int64 -> ByteString Source #

encodeInt' :: WriteBuffer -> Int64 -> IO () Source #

encodeInt'2 :: WriteBuffer -> Int64 -> IO () Source #

encodeInt'4 :: WriteBuffer -> Int64 -> IO () Source #

decodeInt :: ByteString -> Int64 Source #

>>> decodeInt (dec16 "c2197c5eff14e88c")
151288809941952652
>>> decodeInt (dec16 "9d7f3e7d")
494878333
>>> decodeInt (dec16 "7bbd")
15293
>>> decodeInt (dec16 "25")
37

decodeInt' :: ReadBuffer -> IO Int64 Source #

newtype Version Source #

QUIC version.

Constructors

Version Word32

Instances

Instances details

Generic Version Source #
Instance details Defined in Network.QUIC.Types.Packet Associated Types type Rep Version :: Type -> Type # Methods from :: Version -> Rep Version x # to :: Rep Version x -> Version #
Show Version Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> Version -> ShowS # show :: Version -> String # showList :: [Version] -> ShowS #
Eq Version Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: Version -> Version -> Bool # (/=) :: Version -> Version -> Bool #
Ord Version Source #
Instance details Defined in Network.QUIC.Types.Packet Methods compare :: Version -> Version -> Ordering # (<) :: Version -> Version -> Bool # (<=) :: Version -> Version -> Bool # (>) :: Version -> Version -> Bool # (>=) :: Version -> Version -> Bool # max :: Version -> Version -> Version # min :: Version -> Version -> Version #
Serialise Version Source #
Instance details Defined in Network.QUIC.Types.Packet Methods encode :: Version -> Encoding # decode :: Decoder s Version # encodeList :: [Version] -> Encoding # decodeList :: Decoder s [Version] #
type Rep Version Source #
Instance details Defined in Network.QUIC.Types.Packet type Rep Version = D1 ('MetaData "Version" "Network.QUIC.Types.Packet" "quic-0.1.20-4xBoOzsr86T1PD98iEWMzj" 'True) (C1 ('MetaCons "Version" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Word32)))

pattern Negotiation :: Version Source #

pattern Version1 :: Version Source #

pattern Version2 :: Version Source #

pattern Draft29 :: Version Source #

pattern GreasingVersion :: Version Source #

pattern GreasingVersion2 :: Version Source #

isGreasingVersion :: Version -> Bool Source #

data VersionInfo Source #

Constructors

VersionInfo
Fields chosenVersion :: Version otherVersions :: [Version]

Instances

Instances details

Show VersionInfo Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> VersionInfo -> ShowS # show :: VersionInfo -> String # showList :: [VersionInfo] -> ShowS #
Eq VersionInfo Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: VersionInfo -> VersionInfo -> Bool # (/=) :: VersionInfo -> VersionInfo -> Bool #

brokenVersionInfo :: VersionInfo Source #

extensionIDForTtransportParameter :: Version -> ExtensionID Source #

data PacketI Source #

Constructors

PacketIV VersionNegotiationPacket
PacketIR RetryPacket
PacketIC CryptPacket EncryptionLevel Int
PacketIB BrokenPacket

Instances

Instances details

Show PacketI Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> PacketI -> ShowS # show :: PacketI -> String # showList :: [PacketI] -> ShowS #
Eq PacketI Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: PacketI -> PacketI -> Bool # (/=) :: PacketI -> PacketI -> Bool #

data PacketO Source #

Constructors

PacketOV VersionNegotiationPacket
PacketOR RetryPacket
PacketOP PlainPacket

Instances

Instances details

Show PacketO Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> PacketO -> ShowS # show :: PacketO -> String # showList :: [PacketO] -> ShowS #
Eq PacketO Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: PacketO -> PacketO -> Bool # (/=) :: PacketO -> PacketO -> Bool #

data VersionNegotiationPacket Source #

Constructors

VersionNegotiationPacket CID CID [Version]

Instances

Instances details

Show VersionNegotiationPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> VersionNegotiationPacket -> ShowS # show :: VersionNegotiationPacket -> String # showList :: [VersionNegotiationPacket] -> ShowS #
Eq VersionNegotiationPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: VersionNegotiationPacket -> VersionNegotiationPacket -> Bool # (/=) :: VersionNegotiationPacket -> VersionNegotiationPacket -> Bool #
Qlog VersionNegotiationPacket Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: VersionNegotiationPacket -> LogStr Source #

data RetryPacket Source #

Constructors

RetryPacket Version CID CID Token (Either CID (ByteString, ByteString))

Instances

Instances details

Show RetryPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> RetryPacket -> ShowS # show :: RetryPacket -> String # showList :: [RetryPacket] -> ShowS #
Eq RetryPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: RetryPacket -> RetryPacket -> Bool # (/=) :: RetryPacket -> RetryPacket -> Bool #
Qlog RetryPacket Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: RetryPacket -> LogStr Source #

data BrokenPacket Source #

Constructors

BrokenPacket

Instances

Instances details

Show BrokenPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> BrokenPacket -> ShowS # show :: BrokenPacket -> String # showList :: [BrokenPacket] -> ShowS #
Eq BrokenPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: BrokenPacket -> BrokenPacket -> Bool # (/=) :: BrokenPacket -> BrokenPacket -> Bool #

data Header Source #

Constructors

Initial Version CID CID Token
RTT0 Version CID CID
Handshake Version CID CID
Short CID

Instances

headerMyCID :: Header -> CID Source #

headerPeerCID :: Header -> CID Source #

data PlainPacket Source #

Constructors

PlainPacket Header Plain

Instances

Instances details

Show PlainPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> PlainPacket -> ShowS # show :: PlainPacket -> String # showList :: [PlainPacket] -> ShowS #
Eq PlainPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: PlainPacket -> PlainPacket -> Bool # (/=) :: PlainPacket -> PlainPacket -> Bool #
Qlog PlainPacket Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: PlainPacket -> LogStr Source #

data CryptPacket Source #

Constructors

CryptPacket Header Crypt

Instances

Instances details

Show CryptPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> CryptPacket -> ShowS # show :: CryptPacket -> String # showList :: [CryptPacket] -> ShowS #
Eq CryptPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: CryptPacket -> CryptPacket -> Bool # (/=) :: CryptPacket -> CryptPacket -> Bool #
Qlog CryptPacket Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: CryptPacket -> LogStr Source #

data Plain Source #

Constructors

Plain
Fields plainFlags :: Flags Raw plainPacketNumber :: PacketNumber plainFrames :: [Frame] plainMarks :: Int

Instances

Instances details

Show Plain Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> Plain -> ShowS # show :: Plain -> String # showList :: [Plain] -> ShowS #
Eq Plain Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: Plain -> Plain -> Bool # (/=) :: Plain -> Plain -> Bool #

defaultPlainMarks :: Int Source #

setIllegalReservedBits :: Int -> Int Source #

setUnknownFrame :: Int -> Int Source #

setNoFrames :: Int -> Int Source #

setNoPaddings :: Int -> Int Source #

set4bytesPN :: Int -> Int Source #

isIllegalReservedBits :: Int -> Bool Source #

isUnknownFrame :: Int -> Bool Source #

isNoFrames :: Int -> Bool Source #

isNoPaddings :: Int -> Bool Source #

is4bytesPN :: Int -> Bool Source #

data MigrationInfo Source #

Constructors

MigrationInfo ListenSocket ClientSockAddr CID

Instances

Instances details

Show MigrationInfo Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> MigrationInfo -> ShowS # show :: MigrationInfo -> String # showList :: [MigrationInfo] -> ShowS #
Eq MigrationInfo Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: MigrationInfo -> MigrationInfo -> Bool # (/=) :: MigrationInfo -> MigrationInfo -> Bool #

data Crypt Source #

Constructors

Crypt
Fields cryptPktNumOffset :: Int cryptPacket :: ByteString cryptMarks :: Int cryptMigraionInfo :: Maybe MigrationInfo

Instances

Instances details

Show Crypt Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> Crypt -> ShowS # show :: Crypt -> String # showList :: [Crypt] -> ShowS #
Eq Crypt Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: Crypt -> Crypt -> Bool # (/=) :: Crypt -> Crypt -> Bool #

isCryptDelayed :: Crypt -> Bool Source #

setCryptDelayed :: Crypt -> Crypt Source #

data StatelessReset Source #

Constructors

StatelessReset

Instances

Instances details

Show StatelessReset Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> StatelessReset -> ShowS # show :: StatelessReset -> String # showList :: [StatelessReset] -> ShowS #
Eq StatelessReset Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: StatelessReset -> StatelessReset -> Bool # (/=) :: StatelessReset -> StatelessReset -> Bool #
Qlog StatelessReset Source #
Instance details Defined in Network.QUIC.Qlog Methods qlog :: StatelessReset -> LogStr Source #

data ReceivedPacket Source #

Constructors

ReceivedPacket
Fields rpCryptPacket :: CryptPacket rpTimeRecevied :: TimeMicrosecond rpReceivedBytes :: Int rpEncryptionLevel :: EncryptionLevel

Instances

Instances details

Show ReceivedPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> ReceivedPacket -> ShowS # show :: ReceivedPacket -> String # showList :: [ReceivedPacket] -> ShowS #
Eq ReceivedPacket Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: ReceivedPacket -> ReceivedPacket -> Bool # (/=) :: ReceivedPacket -> ReceivedPacket -> Bool #

mkReceivedPacket :: CryptPacket -> TimeMicrosecond -> Int -> EncryptionLevel -> ReceivedPacket Source #

data LongHeaderPacketType Source #

Constructors

InitialPacketType
RTT0PacketType
HandshakePacketType
RetryPacketType

Instances

Instances details

Show LongHeaderPacketType Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> LongHeaderPacketType -> ShowS # show :: LongHeaderPacketType -> String # showList :: [LongHeaderPacketType] -> ShowS #
Eq LongHeaderPacketType Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: LongHeaderPacketType -> LongHeaderPacketType -> Bool # (/=) :: LongHeaderPacketType -> LongHeaderPacketType -> Bool #

data EncryptionLevel Source #

Constructors

InitialLevel
RTT0Level
HandshakeLevel
RTT1Level

Instances

Instances details

Ix EncryptionLevel Source #
Instance details Defined in Network.QUIC.Types.Packet Methods range :: (EncryptionLevel, EncryptionLevel) -> [EncryptionLevel] # index :: (EncryptionLevel, EncryptionLevel) -> EncryptionLevel -> Int # unsafeIndex :: (EncryptionLevel, EncryptionLevel) -> EncryptionLevel -> Int # inRange :: (EncryptionLevel, EncryptionLevel) -> EncryptionLevel -> Bool # rangeSize :: (EncryptionLevel, EncryptionLevel) -> Int # unsafeRangeSize :: (EncryptionLevel, EncryptionLevel) -> Int #
Show EncryptionLevel Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> EncryptionLevel -> ShowS # show :: EncryptionLevel -> String # showList :: [EncryptionLevel] -> ShowS #
Eq EncryptionLevel Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: EncryptionLevel -> EncryptionLevel -> Bool # (/=) :: EncryptionLevel -> EncryptionLevel -> Bool #
Ord EncryptionLevel Source #
Instance details Defined in Network.QUIC.Types.Packet Methods compare :: EncryptionLevel -> EncryptionLevel -> Ordering # (<) :: EncryptionLevel -> EncryptionLevel -> Bool # (<=) :: EncryptionLevel -> EncryptionLevel -> Bool # (>) :: EncryptionLevel -> EncryptionLevel -> Bool # (>=) :: EncryptionLevel -> EncryptionLevel -> Bool # max :: EncryptionLevel -> EncryptionLevel -> EncryptionLevel # min :: EncryptionLevel -> EncryptionLevel -> EncryptionLevel #

packetEncryptionLevel :: Header -> EncryptionLevel Source #

newtype Flags a Source #

Constructors

Flags Word8

Instances

Instances details

Show (Flags a) Source #
Instance details Defined in Network.QUIC.Types.Packet Methods showsPrec :: Int -> Flags a -> ShowS # show :: Flags a -> String # showList :: [Flags a] -> ShowS #
Eq (Flags a) Source #
Instance details Defined in Network.QUIC.Types.Packet Methods (==) :: Flags a -> Flags a -> Bool # (/=) :: Flags a -> Flags a -> Bool #

data Protected Source #

data Raw Source #

type EncodedPacketNumber = Word32 Source #

newtype RecvQ Source #

Constructors

RecvQ (TQueue ReceivedPacket)

newRecvQ :: IO RecvQ Source #

readRecvQ :: RecvQ -> IO ReceivedPacket Source #

writeRecvQ :: RecvQ -> ReceivedPacket -> IO () Source #

prependRecvQ :: RecvQ -> ReceivedPacket -> STM () Source #

type SessionEstablish = SessionID -> SessionData -> IO (Maybe Ticket) Source #

data ResumptionInfo Source #

Information about resumption

Constructors

ResumptionInfo
Fields resumptionVersion :: Version resumptionSession :: Maybe (SessionID, SessionData) resumptionToken :: Token resumptionRetry :: Bool

Instances

Instances details

Generic ResumptionInfo Source #
Instance details Defined in Network.QUIC.Types.Resumption Associated Types type Rep ResumptionInfo :: Type -> Type # Methods from :: ResumptionInfo -> Rep ResumptionInfo x # to :: Rep ResumptionInfo x -> ResumptionInfo #
Show ResumptionInfo Source #
Instance details Defined in Network.QUIC.Types.Resumption Methods showsPrec :: Int -> ResumptionInfo -> ShowS # show :: ResumptionInfo -> String # showList :: [ResumptionInfo] -> ShowS #
Eq ResumptionInfo Source #
Instance details Defined in Network.QUIC.Types.Resumption Methods (==) :: ResumptionInfo -> ResumptionInfo -> Bool # (/=) :: ResumptionInfo -> ResumptionInfo -> Bool #
Serialise ResumptionInfo Source #
Instance details Defined in Network.QUIC.Types.Resumption Methods encode :: ResumptionInfo -> Encoding # decode :: Decoder s ResumptionInfo # encodeList :: [ResumptionInfo] -> Encoding # decodeList :: Decoder s [ResumptionInfo] #
type Rep ResumptionInfo Source #
Instance details Defined in Network.QUIC.Types.Resumption type Rep ResumptionInfo = D1 ('MetaData "ResumptionInfo" "Network.QUIC.Types.Resumption" "quic-0.1.20-4xBoOzsr86T1PD98iEWMzj" 'False) (C1 ('MetaCons "ResumptionInfo" 'PrefixI 'True) ((S1 ('MetaSel ('Just "resumptionVersion") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Version) :: S1 ('MetaSel ('Just "resumptionSession") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe (SessionID, SessionData)))) :: (S1 ('MetaSel ('Just "resumptionToken") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Token) :*: S1 ('MetaSel ('Just "resumptionRetry") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Bool))))

defaultResumptionInfo :: ResumptionInfo Source #

is0RTTPossible :: ResumptionInfo -> Bool Source #

Is 0RTT possible?

isResumptionPossible :: ResumptionInfo -> Bool Source #

Is resumption possible?

get0RTTCipher :: ResumptionInfo -> Maybe CipherID Source #

newtype Milliseconds Source #

Constructors

Milliseconds Int64

Instances

Instances details

Bits Milliseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods (.&.) :: Milliseconds -> Milliseconds -> Milliseconds # (.\|.) :: Milliseconds -> Milliseconds -> Milliseconds # xor :: Milliseconds -> Milliseconds -> Milliseconds # complement :: Milliseconds -> Milliseconds # shift :: Milliseconds -> Int -> Milliseconds # rotate :: Milliseconds -> Int -> Milliseconds # zeroBits :: Milliseconds # bit :: Int -> Milliseconds # setBit :: Milliseconds -> Int -> Milliseconds # clearBit :: Milliseconds -> Int -> Milliseconds # complementBit :: Milliseconds -> Int -> Milliseconds # testBit :: Milliseconds -> Int -> Bool # bitSizeMaybe :: Milliseconds -> Maybe Int # bitSize :: Milliseconds -> Int # isSigned :: Milliseconds -> Bool # shiftL :: Milliseconds -> Int -> Milliseconds # unsafeShiftL :: Milliseconds -> Int -> Milliseconds # shiftR :: Milliseconds -> Int -> Milliseconds # unsafeShiftR :: Milliseconds -> Int -> Milliseconds # rotateL :: Milliseconds -> Int -> Milliseconds # rotateR :: Milliseconds -> Int -> Milliseconds # popCount :: Milliseconds -> Int #
Num Milliseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods (+) :: Milliseconds -> Milliseconds -> Milliseconds # (-) :: Milliseconds -> Milliseconds -> Milliseconds # (*) :: Milliseconds -> Milliseconds -> Milliseconds # negate :: Milliseconds -> Milliseconds # abs :: Milliseconds -> Milliseconds # signum :: Milliseconds -> Milliseconds # fromInteger :: Integer -> Milliseconds #
Show Milliseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods showsPrec :: Int -> Milliseconds -> ShowS # show :: Milliseconds -> String # showList :: [Milliseconds] -> ShowS #
Eq Milliseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods (==) :: Milliseconds -> Milliseconds -> Bool # (/=) :: Milliseconds -> Milliseconds -> Bool #
Ord Milliseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods compare :: Milliseconds -> Milliseconds -> Ordering # (<) :: Milliseconds -> Milliseconds -> Bool # (<=) :: Milliseconds -> Milliseconds -> Bool # (>) :: Milliseconds -> Milliseconds -> Bool # (>=) :: Milliseconds -> Milliseconds -> Bool # max :: Milliseconds -> Milliseconds -> Milliseconds # min :: Milliseconds -> Milliseconds -> Milliseconds #

newtype Microseconds Source #

Constructors

Microseconds Int

Instances

Instances details

Bits Microseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods (.&.) :: Microseconds -> Microseconds -> Microseconds # (.\|.) :: Microseconds -> Microseconds -> Microseconds # xor :: Microseconds -> Microseconds -> Microseconds # complement :: Microseconds -> Microseconds # shift :: Microseconds -> Int -> Microseconds # rotate :: Microseconds -> Int -> Microseconds # zeroBits :: Microseconds # bit :: Int -> Microseconds # setBit :: Microseconds -> Int -> Microseconds # clearBit :: Microseconds -> Int -> Microseconds # complementBit :: Microseconds -> Int -> Microseconds # testBit :: Microseconds -> Int -> Bool # bitSizeMaybe :: Microseconds -> Maybe Int # bitSize :: Microseconds -> Int # isSigned :: Microseconds -> Bool # shiftL :: Microseconds -> Int -> Microseconds # unsafeShiftL :: Microseconds -> Int -> Microseconds # shiftR :: Microseconds -> Int -> Microseconds # unsafeShiftR :: Microseconds -> Int -> Microseconds # rotateL :: Microseconds -> Int -> Microseconds # rotateR :: Microseconds -> Int -> Microseconds # popCount :: Microseconds -> Int #
Num Microseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods (+) :: Microseconds -> Microseconds -> Microseconds # (-) :: Microseconds -> Microseconds -> Microseconds # (*) :: Microseconds -> Microseconds -> Microseconds # negate :: Microseconds -> Microseconds # abs :: Microseconds -> Microseconds # signum :: Microseconds -> Microseconds # fromInteger :: Integer -> Microseconds #
Show Microseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods showsPrec :: Int -> Microseconds -> ShowS # show :: Microseconds -> String # showList :: [Microseconds] -> ShowS #
Eq Microseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods (==) :: Microseconds -> Microseconds -> Bool # (/=) :: Microseconds -> Microseconds -> Bool #
Ord Microseconds Source #
Instance details Defined in Network.QUIC.Types.Time Methods compare :: Microseconds -> Microseconds -> Ordering # (<) :: Microseconds -> Microseconds -> Bool # (<=) :: Microseconds -> Microseconds -> Bool # (>) :: Microseconds -> Microseconds -> Bool # (>=) :: Microseconds -> Microseconds -> Bool # max :: Microseconds -> Microseconds -> Microseconds # min :: Microseconds -> Microseconds -> Microseconds #

milliToMicro :: Milliseconds -> Microseconds Source #

microToMilli :: Microseconds -> Milliseconds Source #

type TimeMicrosecond = UnixTime Source #

timeMicrosecond0 :: UnixTime Source #

getTimeMicrosecond :: IO TimeMicrosecond Source #

getElapsedTimeMicrosecond :: TimeMicrosecond -> IO Microseconds Source #

elapsedTimeMicrosecond :: UnixTime -> UnixTime -> Microseconds Source #

getTimeoutInMicrosecond :: TimeMicrosecond -> IO Microseconds Source #

getPastTimeMicrosecond :: Microseconds -> IO TimeMicrosecond Source #

getFutureTimeMicrosecond :: Microseconds -> IO TimeMicrosecond Source #

addMicroseconds :: TimeMicrosecond -> Microseconds -> TimeMicrosecond Source #

fromRight :: b -> Either a b -> b Source #

dec16 :: ByteString -> ByteString Source #

enc16 :: ByteString -> ByteString Source #

dec16s :: ShortByteString -> ShortByteString Source #

enc16s :: ShortByteString -> ShortByteString Source #

shortToString :: ShortByteString -> String Source #

getRandomOneByte :: IO Word8 Source #

getRandomBytes :: Int -> IO ShortByteString Source #

totalLen :: [ByteString] -> Int Source #

sum' :: (Functor f, Foldable f) => f Int -> Int Source #

withByteString :: ByteString -> (Ptr Word8 -> IO a) -> IO a Source #

shortpack :: String -> ShortByteString Source #

ignore :: SomeException -> IO () Source #

checkWindowOpenSTM :: LDCC -> Int -> STM () Source #

takePingSTM :: LDCC -> STM EncryptionLevel Source #

speedup :: LDCC -> EncryptionLevel -> LogStr -> IO () Source #

resender :: LDCC -> IO () Source #

onPacketSent :: LDCC -> SentPacket -> IO () Source #

onPacketReceived :: LDCC -> EncryptionLevel -> PacketNumber -> IO () Source #

onAckReceived :: LDCC -> EncryptionLevel -> AckInfo -> Microseconds -> IO () Source #

onPacketNumberSpaceDiscarded :: LDCC -> EncryptionLevel -> IO () Source #

setInitialCongestionWindow :: LDCC -> Int -> IO () Source #

getPreviousRTT1PPNs :: LDCC -> IO PeerPacketNumbers Source #

setPreviousRTT1PPNs :: LDCC -> PeerPacketNumbers -> IO () Source #

getSpeedingUp :: LDCC -> IO Bool Source #

getPacketNumberSpaceDiscarded :: LDCC -> EncryptionLevel -> IO Bool Source #

getAndSetPacketNumberSpaceDiscarded :: LDCC -> EncryptionLevel -> IO Bool Source #

setMaxAckDaley :: LDCC -> Microseconds -> IO () Source #

getPeerPacketNumbers :: LDCC -> EncryptionLevel -> IO PeerPacketNumbers Source #

fromPeerPacketNumbers :: PeerPacketNumbers -> [PacketNumber] Source #

nullPeerPacketNumbers :: PeerPacketNumbers -> Bool Source #

findDuration :: Seq SentPacket -> PacketNumber -> Maybe UnixDiffTime Source #

getPTO :: LDCC -> IO Microseconds Source #

releaseByRetry :: LDCC -> IO (Seq PlainPacket) Source #

releaseOldest :: LDCC -> EncryptionLevel -> IO (Maybe SentPacket) Source #

beforeAntiAmp :: LDCC -> IO () Source #

ldccTimer :: LDCC -> IO () Source #

data SentPacket Source #

Instances

Instances details

Show SentPacket Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods showsPrec :: Int -> SentPacket -> ShowS # show :: SentPacket -> String # showList :: [SentPacket] -> ShowS #
Eq SentPacket Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods (==) :: SentPacket -> SentPacket -> Bool # (/=) :: SentPacket -> SentPacket -> Bool #
Ord SentPacket Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods compare :: SentPacket -> SentPacket -> Ordering # (<) :: SentPacket -> SentPacket -> Bool # (<=) :: SentPacket -> SentPacket -> Bool # (>) :: SentPacket -> SentPacket -> Bool # (>=) :: SentPacket -> SentPacket -> Bool # max :: SentPacket -> SentPacket -> SentPacket # min :: SentPacket -> SentPacket -> SentPacket #
Qlog SentPacket Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods qlog :: SentPacket -> LogStr Source #

spPlainPacket :: SentPacket -> PlainPacket Source #

spTimeSent :: SentPacket -> TimeMicrosecond Source #

spSentBytes :: SentPacket -> Int Source #

spEncryptionLevel :: SentPacket -> EncryptionLevel Source #

spPacketNumber :: SentPacket -> PacketNumber Source #

spPeerPacketNumbers :: SentPacket -> PeerPacketNumbers Source #

spAckEliciting :: SentPacket -> Bool Source #

mkSentPacket :: PacketNumber -> EncryptionLevel -> PlainPacket -> PeerPacketNumbers -> Bool -> SentPacket Source #

fixSentPacket :: SentPacket -> Int -> Int -> SentPacket Source #

data LDCC Source #

Instances

Instances details

Connector LDCC Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods getRole :: LDCC -> Role Source # getEncryptionLevel :: LDCC -> IO EncryptionLevel Source # getMaxPacketSize :: LDCC -> IO Int Source # getConnectionState :: LDCC -> IO ConnectionState Source # getPacketNumber :: LDCC -> IO PacketNumber Source # getAlive :: LDCC -> IO Bool Source #
KeepQlog LDCC Source #
Instance details Defined in Network.QUIC.Recovery.Types Methods keepQlog :: LDCC -> QLogger Source #

newLDCC :: ConnState -> QLogger -> (PlainPacket -> IO ()) -> IO LDCC Source #

qlogSent :: (KeepQlog q, Qlog pkt) => q -> pkt -> TimeMicrosecond -> IO () Source #

data ConnectionControl Source #

How to control a connection.

Constructors

ChangeServerCID
ChangeClientCID
NATRebinding
ActiveMigration

Instances

Instances details

Show ConnectionControl Source #
Instance details Defined in Network.QUIC.Client.Reader Methods showsPrec :: Int -> ConnectionControl -> ShowS # show :: ConnectionControl -> String # showList :: [ConnectionControl] -> ShowS #
Eq ConnectionControl Source #
Instance details Defined in Network.QUIC.Client.Reader Methods (==) :: ConnectionControl -> ConnectionControl -> Bool # (/=) :: ConnectionControl -> ConnectionControl -> Bool #

controlConnection :: Connection -> ConnectionControl -> IO Bool Source #

windowsThreadBlockHack :: IO a -> IO a Source #

QRecvInitial
QSentRetry
QSent LogStr TimeMicrosecond
QReceived LogStr TimeMicrosecond
QDropped LogStr TimeMicrosecond
QMetricsUpdated LogStr TimeMicrosecond
QPacketLost LogStr TimeMicrosecond
QCongestionStateUpdated LogStr TimeMicrosecond
QLossTimerUpdated LogStr TimeMicrosecond
QDebug LogStr TimeMicrosecond
QParamsSet LogStr TimeMicrosecond
QCIDUpdate LogStr TimeMicrosecond

ConnectionIsClosed
TransportErrorIsReceived TransportError ReasonPhrase
TransportErrorIsSent TransportError ReasonPhrase
ApplicationProtocolErrorIsReceived ApplicationProtocolError ReasonPhrase
ApplicationProtocolErrorIsSent ApplicationProtocolError ReasonPhrase
ConnectionIsTimeout String
ConnectionIsReset
StreamIsClosed
HandshakeFailed AlertDescription
VersionIsUnknown Word32
NoVersionIsSpecified
VersionNegotiationFailed
BadThingHappen SomeException

Padding Int
Ping
Ack AckInfo Delay
ResetStream StreamId ApplicationProtocolError Int
StopSending StreamId ApplicationProtocolError
CryptoF Offset CryptoData
NewToken Token
StreamF StreamId Offset [StreamData] Fin
MaxData Int
MaxStreamData StreamId Int
MaxStreams Direction Int
DataBlocked Int
StreamDataBlocked StreamId Int
StreamsBlocked Direction Int
NewConnectionID CIDInfo SeqNum
RetireConnectionID SeqNum
PathChallenge PathData
PathResponse PathData
ConnectionClose TransportError FrameType ReasonPhrase
ConnectionCloseApp ApplicationProtocolError ReasonPhrase
HandshakeDone
UnknownFrame Int