-- Hoogle documentation, generated by Haddock -- See Hoogle, http://www.haskell.org/hoogle/ -- | A fast, light-weight web server for WAI applications. -- -- HTTP/1.0, HTTP/1.1 and HTTP/2 are supported. For HTTP/2, Warp supports -- direct and ALPN (in TLS) but not upgrade. API docs and the README are -- available at http://www.stackage.org/package/warp. @package warp @version 3.3.21 module Network.Wai.Handler.Warp.Internal -- | Various Warp server settings. This is purposely kept as an abstract -- data type so that new settings can be added without breaking backwards -- compatibility. In order to create a Settings value, use -- defaultSettings and the various 'set' functions to modify -- individual fields. For example: -- --
-- setTimeout 20 defaultSettings --data Settings Settings :: Port -> HostPreference -> (Maybe Request -> SomeException -> IO ()) -> (SomeException -> Response) -> (SockAddr -> IO Bool) -> (SockAddr -> IO ()) -> Int -> Maybe Manager -> Int -> Int -> IO () -> (((forall a. IO a -> IO a) -> IO ()) -> IO ()) -> Bool -> (IO () -> IO ()) -> ByteString -> Maybe Int -> ProxyProtocol -> Int -> Bool -> (Request -> Status -> Maybe Integer -> IO ()) -> (Request -> ByteString -> Integer -> IO ()) -> Maybe Int -> Int -> Int -> Int -> Maybe ByteString -> Settings -- | Port to listen on. Default value: 3000 [settingsPort] :: Settings -> Port -- | Default value: HostIPv4 [settingsHost] :: Settings -> HostPreference -- | What to do with exceptions thrown by either the application or server. -- Default: ignore server-generated exceptions (see -- InvalidRequest) and print application-generated applications to -- stderr. [settingsOnException] :: Settings -> Maybe Request -> SomeException -> IO () -- | A function to create Response when an exception occurs. -- -- Default: 500, text/plain, "Something went wrong" -- -- Since 2.0.3 [settingsOnExceptionResponse] :: Settings -> SomeException -> Response -- | What to do when a connection is open. When False is returned, -- the connection is closed immediately. Otherwise, the connection is -- going on. Default: always returns True. [settingsOnOpen] :: Settings -> SockAddr -> IO Bool -- | What to do when a connection is close. Default: do nothing. [settingsOnClose] :: Settings -> SockAddr -> IO () -- | Timeout value in seconds. Default value: 30 [settingsTimeout] :: Settings -> Int -- | Use an existing timeout manager instead of spawning a new one. If -- used, settingsTimeout is ignored. Default is Nothing [settingsManager] :: Settings -> Maybe Manager -- | Cache duration time of file descriptors in seconds. 0 means that the -- cache mechanism is not used. Default value: 0 [settingsFdCacheDuration] :: Settings -> Int -- | Cache duration time of file information in seconds. 0 means that the -- cache mechanism is not used. Default value: 0 [settingsFileInfoCacheDuration] :: Settings -> Int -- | Code to run after the listening socket is ready but before entering -- the main event loop. Useful for signaling to tests that they can start -- running, or to drop permissions after binding to a restricted port. -- -- Default: do nothing. -- -- Since 1.3.6 [settingsBeforeMainLoop] :: Settings -> IO () -- | Code to fork a new thread to accept a connection. -- -- This may be useful if you need OS bound threads, or if you wish to -- develop an alternative threading model. -- -- Default: defaultFork -- -- Since 3.0.4 [settingsFork] :: Settings -> ((forall a. IO a -> IO a) -> IO ()) -> IO () -- | Perform no parsing on the rawPathInfo. -- -- This is useful for writing HTTP proxies. -- -- Default: False -- -- Since 2.0.3 [settingsNoParsePath] :: Settings -> Bool -- | An action to install a handler (e.g. Unix signal handler) to close a -- listen socket. The first argument is an action to close the listen -- socket. -- -- Default: no action -- -- Since 3.0.1 [settingsInstallShutdownHandler] :: Settings -> IO () -> IO () -- | Default server name if application does not set one. -- -- Since 3.0.2 [settingsServerName] :: Settings -> ByteString -- | See setMaximumBodyFlush. -- -- Since 3.0.3 [settingsMaximumBodyFlush] :: Settings -> Maybe Int -- | Specify usage of the PROXY protocol. -- -- Since 3.0.5 [settingsProxyProtocol] :: Settings -> ProxyProtocol -- | Size of bytes read to prevent Slowloris protection. Default value: -- 2048 -- -- Since 3.1.2 [settingsSlowlorisSize] :: Settings -> Int -- | Whether to enable HTTP2 ALPN/upgrades. Default: True -- -- Since 3.1.7 [settingsHTTP2Enabled] :: Settings -> Bool -- | A log function. Default: no action. -- -- Since 3.1.10 [settingsLogger] :: Settings -> Request -> Status -> Maybe Integer -> IO () -- | A HTTP/2 server push log function. Default: no action. -- -- Since 3.2.7 [settingsServerPushLogger] :: Settings -> Request -> ByteString -> Integer -> IO () -- | An optional timeout to limit the time (in seconds) waiting for a -- graceful shutdown of the web server. -- -- Since 3.2.8 [settingsGracefulShutdownTimeout] :: Settings -> Maybe Int -- | A timeout to limit the time (in milliseconds) waiting for FIN for -- HTTP/1.x. 0 means uses immediate close. Default: 0. -- -- Since 3.3.5 [settingsGracefulCloseTimeout1] :: Settings -> Int -- | A timeout to limit the time (in milliseconds) waiting for FIN for -- HTTP/2. 0 means uses immediate close. Default: 2000. -- -- Since 3.3.5 [settingsGracefulCloseTimeout2] :: Settings -> Int -- | Determines the maximum header size that Warp will tolerate when using -- HTTP/1.x. -- -- Since 3.3.8 [settingsMaxTotalHeaderLength] :: Settings -> Int -- | Specify the header value of Alternative Services (AltSvc:). -- -- Default: Nothing -- -- Since 3.3.11 [settingsAltSvc] :: Settings -> Maybe ByteString -- | Specify usage of the PROXY protocol. data ProxyProtocol -- | See setProxyProtocolNone. ProxyProtocolNone :: ProxyProtocol -- | See setProxyProtocolRequired. ProxyProtocolRequired :: ProxyProtocol -- | See setProxyProtocolOptional. ProxyProtocolOptional :: ProxyProtocol -- | The connection setup action would be expensive. A good example is -- initialization of TLS. So, this converts the connection setup action -- to the connection maker which will be executed after forking a new -- worker thread. Then this calls runSettingsConnectionMaker with -- the connection maker. This allows the expensive computations to be -- performed in a separate worker thread instead of the main server loop. -- -- Since 1.3.5 runSettingsConnection :: Settings -> IO (Connection, SockAddr) -> Application -> IO () -- | This modifies the connection maker so that it returns TCP for -- Transport (i.e. plain HTTP) then calls -- runSettingsConnectionMakerSecure. runSettingsConnectionMaker :: Settings -> IO (IO Connection, SockAddr) -> Application -> IO () -- | The core run function which takes Settings, a connection maker -- and Application. The connection maker can return a connection -- of either plain HTTP or HTTP over TLS. -- -- Since 2.1.4 runSettingsConnectionMakerSecure :: Settings -> IO (IO (Connection, Transport), SockAddr) -> Application -> IO () -- | What kind of transport is used for this connection? data Transport -- | Plain channel: TCP TCP :: Transport -- | Encrypted channel: TLS or SSL TLS :: Int -> Int -> Maybe ByteString -> Word16 -> Maybe CertificateChain -> Transport [tlsMajorVersion] :: Transport -> Int [tlsMinorVersion] :: Transport -> Int -- | The result of Application Layer Protocol Negociation in RFC 7301 [tlsNegotiatedProtocol] :: Transport -> Maybe ByteString [tlsChiperID] :: Transport -> Word16 [tlsClientCertificate] :: Transport -> Maybe CertificateChain QUIC :: Maybe ByteString -> Word16 -> Maybe CertificateChain -> Transport [quicNegotiatedProtocol] :: Transport -> Maybe ByteString [quicChiperID] :: Transport -> Word16 [quicClientCertificate] :: Transport -> Maybe CertificateChain -- | Data type to manipulate IO actions for connections. This is used to -- abstract IO actions for plain HTTP and HTTP over TLS. data Connection Connection :: ([ByteString] -> IO ()) -> (ByteString -> IO ()) -> SendFile -> IO () -> IO () -> Recv -> RecvBuf -> Buffer -> BufSize -> IORef Bool -> Connection -- | This is not used at this moment. [connSendMany] :: Connection -> [ByteString] -> IO () -- | The sending function. [connSendAll] :: Connection -> ByteString -> IO () -- | The sending function for files in HTTP/1.1. [connSendFile] :: Connection -> SendFile -- | The connection closing function. Warp guarantees it will only be -- called once. Other functions (like connRecv) may be called -- after connClose is called. [connClose] :: Connection -> IO () -- | Free any buffers allocated. Warp guarantees it will only be called -- once, and no other functions will be called after it. [connFree] :: Connection -> IO () -- | The connection receiving function. This returns "" for EOF. [connRecv] :: Connection -> Recv -- | The connection receiving function. This tries to fill the buffer. This -- returns when the buffer is filled or reaches EOF. [connRecvBuf] :: Connection -> RecvBuf -- | The write buffer. [connWriteBuffer] :: Connection -> Buffer -- | The size of the write buffer. [connBufferSize] :: Connection -> BufSize -- | Is this connection HTTP/2? [connHTTP2] :: Connection -> IORef Bool -- | Creating Connection for plain HTTP based on a given socket. socketConnection :: Settings -> Socket -> IO Connection -- | Type for the action to receive input data type Recv = IO ByteString -- | Type for the action to receive input data with a buffer. The result -- boolean indicates whether or not the buffer is fully filled. type RecvBuf = Buffer -> BufSize -> IO Bool -- | This function returns a receiving function based on two receiving -- functions. The returned function efficiently manages received data -- which is initialized by the first argument. The returned function may -- allocate a byte string with malloc(). makePlainReceiveN :: Socket -> ByteString -> IO (BufSize -> IO ByteString) -- | Type for buffer type Buffer = Ptr Word8 -- | Type for buffer size type BufSize = Int -- | The default size of the write buffer: 16384 (2^14 = 1024 * 16). This -- is the maximum size of TLS record. This is also the maximum size of -- HTTP/2 frame payload (excluding frame header). bufferSize :: BufSize -- | Allocating a buffer with malloc(). allocateBuffer :: Int -> IO Buffer -- | Releasing a buffer with free(). freeBuffer :: Buffer -> IO () -- | Copying the bytestring to the buffer. This function returns the point -- where the next copy should start. copy :: Buffer -> ByteString -> IO Buffer -- | Data type to abstract file identifiers. On Unix, a file descriptor -- would be specified to make use of the file descriptor cache. -- -- Since: 3.1.0 data FileId FileId :: FilePath -> Maybe Fd -> FileId [fileIdPath] :: FileId -> FilePath [fileIdFd] :: FileId -> Maybe Fd -- | fileid, offset, length, hook action, HTTP headers -- -- Since: 3.1.0 type SendFile = FileId -> Integer -> Integer -> IO () -> [ByteString] -> IO () -- | Function to send a file based on sendfile() for Linux/Mac/FreeBSD. -- This makes use of the file descriptor cache. For other OSes, this is -- identical to readSendFile. -- -- Since: 3.1.0 sendFile :: Socket -> Buffer -> BufSize -> (ByteString -> IO ()) -> SendFile -- | Function to send a file based on pread()/send() for Unix. This makes -- use of the file descriptor cache. For Windows, this is emulated by -- Handle. -- -- Since: 3.1.0 readSendFile :: Buffer -> BufSize -> (ByteString -> IO ()) -> SendFile -- | The version of Warp. warpVersion :: String data InternalInfo InternalInfo :: Manager -> IO GMTDate -> (FilePath -> IO (Maybe Fd, Refresh)) -> (FilePath -> IO FileInfo) -> InternalInfo [timeoutManager] :: InternalInfo -> Manager [getDate] :: InternalInfo -> IO GMTDate [getFd] :: InternalInfo -> FilePath -> IO (Maybe Fd, Refresh) [getFileInfo] :: InternalInfo -> FilePath -> IO FileInfo -- | The type for header value used with HeaderName. type HeaderValue = ByteString -- | Array for a set of HTTP headers. type IndexedHeader = Array Int (Maybe HeaderValue) -- | The size for IndexedHeader for HTTP Request. From 0 to this -- corresponds to "Content-Length", "Transfer-Encoding", "Expect", -- "Connection", "Range", "Host", "If-Modified-Since", -- "If-Unmodified-Since" and "If-Range". requestMaxIndex :: Int -- | Creating MutableFdCache and executing the action in the second -- argument. The first argument is a cache duration in second. withFdCache :: Int -> ((FilePath -> IO (Maybe Fd, Refresh)) -> IO a) -> IO a data Fd -- | An action to activate a Fd cache entry. type Refresh = IO () openFile :: FilePath -> IO Fd closeFile :: Fd -> IO () setFileCloseOnExec :: Fd -> IO () -- | File information. data FileInfo FileInfo :: !FilePath -> !Integer -> HTTPDate -> ByteString -> FileInfo [fileInfoName] :: FileInfo -> !FilePath [fileInfoSize] :: FileInfo -> !Integer -- | Modification time [fileInfoTime] :: FileInfo -> HTTPDate -- | Modification time in the GMT format [fileInfoDate] :: FileInfo -> ByteString -- | Creating a file information cache and executing the action in the -- second argument. The first argument is a cache duration in second. withFileInfoCache :: Int -> ((FilePath -> IO FileInfo) -> IO a) -> IO a -- | Getting the file information corresponding to the file. getInfo :: FilePath -> IO FileInfo -- | Creating DateCache and executing the action. withDateCache :: (IO GMTDate -> IO a) -> IO a -- | The type of the Date header value. type GMTDate = ByteString -- | Type for input streaming. data Source -- | Receiving a HTTP request from Connection and parsing its header -- to create Request. recvRequest :: Bool -> Settings -> Connection -> InternalInfo -> Handle -> SockAddr -> Source -> Transport -> IO (Request, Maybe (IORef Int), IndexedHeader, IO ByteString) -- | Sending a HTTP response to Connection according to -- Response. -- -- Applications/middlewares MUST provide a proper ResponseHeaders. -- so that inconsistency does not happen. No header is deleted by this -- function. -- -- Especially, Applications/middlewares MUST provide a proper -- Content-Type. They MUST NOT provide Content-Length, Content-Range, and -- Transfer-Encoding because they are inserted, when necessary, -- regardless they already exist. This function does not insert -- Content-Encoding. It's middleware's responsibility. -- -- The Date and Server header is added if not exist in HTTP response -- header. -- -- There are three basic APIs to create Response: -- --
-- setTimeout 20 defaultSettings --data Settings -- | The default settings for the Warp server. See the individual settings -- for the default value. defaultSettings :: Settings -- | Port to listen on. Default value: 3000 -- -- Since 2.1.0 setPort :: Port -> Settings -> Settings -- | Interface to bind to. Default value: HostIPv4 -- -- Since 2.1.0 setHost :: HostPreference -> Settings -> Settings -- | What to do with exceptions thrown by either the application or server. -- Default: defaultOnException -- -- Since 2.1.0 setOnException :: (Maybe Request -> SomeException -> IO ()) -> Settings -> Settings -- | A function to create a Response when an exception occurs. -- Default: defaultOnExceptionResponse -- -- Note that an application can handle its own exceptions without -- interfering with Warp: -- --
-- myApp :: Application -- myApp request respond = innerApp `catch` onError -- where -- onError = respond . response500 request -- -- response500 :: Request -> SomeException -> Response -- response500 req someEx = responseLBS status500 -- ... ---- -- Since 2.1.0 setOnExceptionResponse :: (SomeException -> Response) -> Settings -> Settings -- | What to do when a connection is opened. When False is returned, -- the connection is closed immediately. Otherwise, the connection is -- going on. Default: always returns True. -- -- Since 2.1.0 setOnOpen :: (SockAddr -> IO Bool) -> Settings -> Settings -- | What to do when a connection is closed. Default: do nothing. -- -- Since 2.1.0 setOnClose :: (SockAddr -> IO ()) -> Settings -> Settings -- | "Slow-loris" timeout lower-bound value in seconds. Connections where -- network progress is made less frequently than this may be closed. In -- practice many connections may be allowed to go without progress for up -- to twice this amount of time. Note that this timeout is not applied to -- application code, only network progress. -- -- Default value: 30 -- -- Since 2.1.0 setTimeout :: Int -> Settings -> Settings -- | Use an existing timeout manager instead of spawning a new one. If -- used, settingsTimeout is ignored. -- -- Since 2.1.0 setManager :: Manager -> Settings -> Settings -- | Cache duration time of file descriptors in seconds. 0 means that the -- cache mechanism is not used. -- -- The FD cache is an optimization that is useful for servers dealing -- with static files. However, if files are being modified, it can cause -- incorrect results in some cases. Therefore, we disable it by default. -- If you know that your files will be static or you prefer performance -- to file consistency, it's recommended to turn this on; a reasonable -- value for those cases is 10. Enabling this cache results in drastic -- performance improvement for file transfers. -- -- Default value: 0, was previously 10 -- -- Since 3.0.13 setFdCacheDuration :: Int -> Settings -> Settings -- | Cache duration time of file information in seconds. 0 means that the -- cache mechanism is not used. -- -- The file information cache is an optimization that is useful for -- servers dealing with static files. However, if files are being -- modified, it can cause incorrect results in some cases. Therefore, we -- disable it by default. If you know that your files will be static or -- you prefer performance to file consistency, it's recommended to turn -- this on; a reasonable value for those cases is 10. Enabling this cache -- results in drastic performance improvement for file transfers. -- -- Default value: 0 setFileInfoCacheDuration :: Int -> Settings -> Settings -- | Code to run after the listening socket is ready but before entering -- the main event loop. Useful for signaling to tests that they can start -- running, or to drop permissions after binding to a restricted port. -- -- Default: do nothing. -- -- Since 2.1.0 setBeforeMainLoop :: IO () -> Settings -> Settings -- | Perform no parsing on the rawPathInfo. -- -- This is useful for writing HTTP proxies. -- -- Default: False -- -- Since 2.1.0 setNoParsePath :: Bool -> Settings -> Settings -- | A code to install shutdown handler. -- -- For instance, this code should set up a UNIX signal handler. The -- handler should call the first argument, which closes the listen -- socket, at shutdown. -- -- Example usage: -- --
-- settings :: IO () -> Settings -- settings shutdownAction = setInstallShutdownHandler shutdownHandler defaultSettings -- where -- shutdownHandler closeSocket = -- void $ installHandler sigTERM (Catch $ shutdownAction >> closeSocket) Nothing ---- -- Note that by default, the graceful shutdown mode lasts indefinitely -- (see setGracefulShutdownTimeout). If you install a signal -- handler as above, upon receiving that signal, the custom shutdown -- action will run and all outstanding requests will be handled. -- -- You may instead prefer to do one or both of the following: -- --