Safe Haskell	None
Language	Haskell2010

Network.Control

Description

Common parts to control network protocols.

Synopsis

defaultMaxStreams :: Int
defaultMaxStreamData :: Int
defaultMaxData :: Int
data TxFlow = TxFlow {
- txfSent :: Int
- txfLimit :: Int
}
newTxFlow :: WindowSize -> TxFlow
txWindowSize :: TxFlow -> WindowSize
type WindowSize = Int
data RxFlow = RxFlow {
- rxfWindow :: WindowSize
- rxfConsumed :: Int
- rxfReceived :: Int
- rxfLimit :: Int
}
newRxFlow :: WindowSize -> RxFlow
data FlowControlType
- = FCTWindowUpdate
- | FCTMaxData
maybeOpenRxWindow :: Int -> FlowControlType -> RxFlow -> (RxFlow, Maybe Int)
checkRxLimit :: Int -> RxFlow -> (RxFlow, Bool)
data LRUCache k v
empty :: Int -> LRUCache k v
insert :: Ord k => k -> v -> LRUCache k v -> LRUCache k v
delete :: Ord k => k -> LRUCache k v -> LRUCache k v
lookup :: Ord k => k -> LRUCache k v -> Maybe v
data Rate
newRate :: IO Rate
getRate :: Rate -> IO Int
addRate :: Rate -> Int -> IO Int

Documentation

defaultMaxStreams :: Int Source #

Default max streams. (64)

defaultMaxStreamData :: Int Source #

Default max data of a stream. (256K bytes)

defaultMaxData :: Int Source #

Default max data of a connection. (1M bytes)

data TxFlow Source #

Flow for sending

Constructors

TxFlow
Fields txfSent :: Int txfLimit :: Int

Instances

Instances details

Show TxFlow Source #
Instance details Defined in Network.Control.Flow Methods showsPrec :: Int -> TxFlow -> ShowS show :: TxFlow -> String showList :: [TxFlow] -> ShowS

newTxFlow :: WindowSize -> TxFlow Source #

Creating TX flow with an initial window size.

txWindowSize :: TxFlow -> WindowSize Source #

txfLimit - txfSent.

type WindowSize = Int Source #

Window size.

data RxFlow Source #

Flow for receiving

Constructors

RxFlow
Fields rxfWindow :: WindowSize rxfConsumed :: Int rxfReceived :: Int rxfLimit :: Int

Instances

Instances details

Show RxFlow Source #
Instance details Defined in Network.Control.Flow Methods showsPrec :: Int -> RxFlow -> ShowS show :: RxFlow -> String showList :: [RxFlow] -> ShowS

newRxFlow :: WindowSize -> RxFlow Source #

Creating RX flow with an initial window size.

data FlowControlType Source #

The representation of window size update.

Constructors

FCTWindowUpdate	HTTP/2 style
FCTMaxData	QUIC style

maybeOpenRxWindow Source #

Arguments

:: Int	The consumed size.
-> FlowControlType
-> RxFlow
-> (RxFlow, Maybe Int)	`Just` if the size should be informed to the peer.

When an application consumed received data, this function should be called to update rxfConsumed. If the window size is less than the half of the initial window. the representation of window size update is returned.

checkRxLimit Source #

Arguments

:: Int	The size of received data.
-> RxFlow
-> (RxFlow, Bool)	Acceptable if `True`.

Checking if received data is acceptable against the current window.

data LRUCache k v Source #

Sized cache based on least recently used.

empty Source #

Arguments

:: Int	The size of `LRUCache`.
-> LRUCache k v

Empty LRUCache.

insert :: Ord k => k -> v -> LRUCache k v -> LRUCache k v Source #

Inserting.

delete :: Ord k => k -> LRUCache k v -> LRUCache k v Source #

Deleting.

lookup :: Ord k => k -> LRUCache k v -> Maybe v Source #

Looking up.

data Rate Source #

Type for rating.

newRate :: IO Rate Source #

Creating a new Rate.

getRate :: Rate -> IO Int Source #

Getting the current rate. If one or more seconds have passed since the previous call, the counter is re-initialized with 1 and it is returned. Otherwise, incremented counter number is returned.

addRate :: Rate -> Int -> IO Int Source #

Getting the current rate. If one or more seconds have passed since the previous call, the counter is re-initialized with the second argument and it is returned. Otherwise, increased counter number is returned.