Hans.Tcp.State

Tcp State

class HasTcpState state where

Minimal complete definition

tcpState

Methods

tcpState :: Getting r state TcpState

Instances

HasTcpState TcpState

Methods

tcpState :: Getting r TcpState TcpState

HasTcpState NetworkStack

Methods

tcpState :: Getting r NetworkStack TcpState

data TcpState

Instances

HasTcpState TcpState

Methods

tcpState :: Getting r TcpState TcpState

newTcpState :: Config -> IO TcpState

Responder Interaction

tcpQueue :: HasTcpState state => Getting r state (BoundedChan TcpResponderRequest)

data TcpResponderRequest

Requests that can be made to the responder thread.

Constructors

SendSegment !(RouteInfo Addr) !Addr !TcpHeader !ByteString

SendWithTcb !Tcb !TcpHeader !ByteString

Listen Sockets

incrSynBacklog :: HasTcpState state => state -> IO ()

Yield back an entry in the Syn backlog.

decrSynBacklog :: HasTcpState state => state -> IO Bool

Returns True when there is space in the Syn backlog, and False if the connection should be rejected.

registerListening :: HasTcpState state => state -> ListenTcb -> IO Bool

Register a new listening socket.

lookupListening :: HasTcpState state => state -> Addr -> TcpPort -> IO (Maybe ListenTcb)

Lookup a socket in the Listen state.

deleteListening :: HasTcpState state => state -> ListenTcb -> IO ()

Remove a listening socket.

Active Sockets

data Key

Instances

Eq Key

Methods

(==) :: Key -> Key -> Bool

(/=) :: Key -> Key -> Bool

Ord Key

Methods

compare :: Key -> Key -> Ordering

(<) :: Key -> Key -> Bool

(<=) :: Key -> Key -> Bool

(>) :: Key -> Key -> Bool

(>=) :: Key -> Key -> Bool

max :: Key -> Key -> Key

min :: Key -> Key -> Key

Show Key

Methods

showsPrec :: Int -> Key -> ShowS

show :: Key -> String

showList :: [Key] -> ShowS

Generic Key

Associated Types

type Rep Key :: * -> *

Methods

from :: Key -> Rep Key x

to :: Rep Key x -> Key

Hashable Key

Methods

hashWithSalt :: Int -> Key -> Int

hash :: Key -> Int

type Rep Key

type Rep Key = D1 (MetaData "Key" "Hans.Tcp.State" "hans-3.0.2-GPIpvDF0acQKMmo8PFxkX0" False) (C1 (MetaCons "Key" PrefixI False) ((:*:) ((:*:) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedUnpack) (Rec0 Addr)) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedUnpack) (Rec0 TcpPort))) ((:*:) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedUnpack) (Rec0 Addr)) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedUnpack) (Rec0 TcpPort)))))

tcbKey :: Getting r Tcb Key

tcpActive :: HasTcpState state => Getting r state (HashTable Key Tcb)

lookupActive :: HasTcpState state => state -> Addr -> TcpPort -> Addr -> TcpPort -> IO (Maybe Tcb)

Lookup an active socket.

registerActive :: HasTcpState state => state -> Tcb -> IO Bool

Register a new active socket.

closeActive :: HasTcpState state => state -> Tcb -> IO ()

Delete the Tcb, and notify any waiting processes.

deleteActive :: HasTcpState state => state -> Tcb -> IO ()

Delete an active connection from the tcp state.

TimeWait Sockets

registerTimeWait :: (HasConfig state, HasTcpState state) => state -> TimeWaitTcb -> IO ()

Register a socket in the TimeWait state. If the heap was empty, fork off a thread to reap its contents after the timeWaitTimeout.

NOTE: this doesn't remove the original socket from the Active set.

lookupTimeWait :: HasTcpState state => state -> Addr -> TcpPort -> Addr -> TcpPort -> IO (Maybe TimeWaitTcb)

Lookup a socket in the TimeWait state.

resetTimeWait :: (HasConfig state, HasTcpState state) => state -> TimeWaitTcb -> IO ()

Reset the timer associated with a TimeWaitTcb.

deleteTimeWait :: HasTcpState state => state -> TimeWaitTcb -> IO ()

Delete an entry from the TimeWait heap.

Port Management

nextTcpPort :: HasTcpState state => state -> Addr -> Addr -> TcpPort -> IO (Maybe TcpPort)

Pick a fresh port for a connection.

Sequence Numbers

nextIss :: HasTcpState state => state -> Addr -> TcpPort -> Addr -> TcpPort -> IO TcpSeqNum