module Network.HTTP2.H2.Config where
import Data.IORef
import Foreign.Marshal.Alloc (free, mallocBytes)
import Network.Socket
import Network.Socket.ByteString (sendAll)
import qualified System.TimeManager as T
import Network.HPACK
import Network.HTTP2.H2.File
import Network.HTTP2.H2.ReadN
import Network.HTTP2.H2.Types
allocSimpleConfig :: Socket -> BufferSize -> IO Config
allocSimpleConfig :: Socket -> Int -> IO Config
allocSimpleConfig Socket
s Int
bufsiz = do
Ptr Word8
buf <- forall a. Int -> IO (Ptr a)
mallocBytes Int
bufsiz
IORef (Maybe ByteString)
ref <- forall a. a -> IO (IORef a)
newIORef forall a. Maybe a
Nothing
Manager
timmgr <- Int -> IO Manager
T.initialize forall a b. (a -> b) -> a -> b
$ Int
30 forall a. Num a => a -> a -> a
* Int
1000000
SockAddr
mysa <- Socket -> IO SockAddr
getSocketName Socket
s
SockAddr
peersa <- Socket -> IO SockAddr
getPeerName Socket
s
let config :: Config
config =
Config
{ confWriteBuffer :: Ptr Word8
confWriteBuffer = Ptr Word8
buf
, confBufferSize :: Int
confBufferSize = Int
bufsiz
, confSendAll :: ByteString -> IO ()
confSendAll = Socket -> ByteString -> IO ()
sendAll Socket
s
, confReadN :: Int -> IO ByteString
confReadN = Socket -> IORef (Maybe ByteString) -> Int -> IO ByteString
defaultReadN Socket
s IORef (Maybe ByteString)
ref
, confPositionReadMaker :: PositionReadMaker
confPositionReadMaker = PositionReadMaker
defaultPositionReadMaker
, confTimeoutManager :: Manager
confTimeoutManager = Manager
timmgr
, confMySockAddr :: SockAddr
confMySockAddr = SockAddr
mysa
, confPeerSockAddr :: SockAddr
confPeerSockAddr = SockAddr
peersa
}
forall (m :: * -> *) a. Monad m => a -> m a
return Config
config
freeSimpleConfig :: Config -> IO ()
freeSimpleConfig :: Config -> IO ()
freeSimpleConfig Config
conf = do
forall a. Ptr a -> IO ()
free forall a b. (a -> b) -> a -> b
$ Config -> Ptr Word8
confWriteBuffer Config
conf
Manager -> IO ()
T.killManager forall a b. (a -> b) -> a -> b
$ Config -> Manager
confTimeoutManager Config
conf