<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<html>
<head>
<!-- Generated by HsColour, http://www.cs.york.ac.uk/fp/darcs/hscolour/ -->
<title>Network/Wai/Handler/Warp.hs</title>
<link type='text/css' rel='stylesheet' href='hscolour.css' />
</head>
<body>
<pre><a name="line-1"></a><span class='hs-comment'>{-# LANGUAGE DeriveDataTypeable #-}</span>
<a name="line-2"></a><span class='hs-comment'>{-# LANGUAGE FlexibleContexts #-}</span>
<a name="line-3"></a><span class='hs-comment'>{-# LANGUAGE OverloadedStrings #-}</span>
<a name="line-4"></a><span class='hs-comment'>{-# LANGUAGE CPP #-}</span>
<a name="line-5"></a><span class='hs-comment'>{-# LANGUAGE BangPatterns #-}</span>
<a name="line-6"></a><span class='hs-comment'>---------------------------------------------------------</span>
<a name="line-7"></a><span class='hs-comment'>--</span>
<a name="line-8"></a><span class='hs-comment'>-- Module : Network.Wai.Handler.Warp</span>
<a name="line-9"></a><span class='hs-comment'>-- Copyright : Michael Snoyman</span>
<a name="line-10"></a><span class='hs-comment'>-- License : BSD3</span>
<a name="line-11"></a><span class='hs-comment'>--</span>
<a name="line-12"></a><span class='hs-comment'>-- Maintainer : Michael Snoyman <michael@snoyman.com></span>
<a name="line-13"></a><span class='hs-comment'>-- Stability : Stable</span>
<a name="line-14"></a><span class='hs-comment'>-- Portability : portable</span>
<a name="line-15"></a><span class='hs-comment'>--</span>
<a name="line-16"></a><span class='hs-comment'>-- A fast, light-weight HTTP server handler for WAI.</span>
<a name="line-17"></a><span class='hs-comment'>--</span>
<a name="line-18"></a><span class='hs-comment'>---------------------------------------------------------</span>
<a name="line-19"></a>
<a name="line-20"></a><span class='hs-comment'>-- | A fast, light-weight HTTP server handler for WAI. Some random notes (a FAQ, if you will):</span>
<a name="line-21"></a><span class='hs-comment'>--</span>
<a name="line-22"></a><span class='hs-comment'>-- * When a 'ResponseFile' indicates a file which does not exist, an exception</span>
<a name="line-23"></a><span class='hs-comment'>-- is thrown. This will close the connection to the client as well. You should</span>
<a name="line-24"></a><span class='hs-comment'>-- handle file existance checks at the application level.</span>
<a name="line-25"></a><span class='hs-keyword'>module</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Wai</span><span class='hs-varop'>.</span><span class='hs-conid'>Handler</span><span class='hs-varop'>.</span><span class='hs-conid'>Warp</span>
<a name="line-26"></a> <span class='hs-layout'>(</span> <span class='hs-comment'>-- * Run a Warp server</span>
<a name="line-27"></a> <span class='hs-varid'>run</span>
<a name="line-28"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>runSettings</span>
<a name="line-29"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>runSettingsSocket</span>
<a name="line-30"></a> <span class='hs-comment'>-- * Settings</span>
<a name="line-31"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>Settings</span>
<a name="line-32"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>defaultSettings</span>
<a name="line-33"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsPort</span>
<a name="line-34"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsHost</span>
<a name="line-35"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsOnException</span>
<a name="line-36"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsTimeout</span>
<a name="line-37"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsIntercept</span>
<a name="line-38"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsManager</span>
<a name="line-39"></a> <span class='hs-comment'>-- * Datatypes</span>
<a name="line-40"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>Port</span>
<a name="line-41"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>InvalidRequest</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-42"></a> <span class='hs-comment'>-- * Internal</span>
<a name="line-43"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>Manager</span>
<a name="line-44"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>withManager</span>
<a name="line-45"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>parseRequest</span>
<a name="line-46"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sendResponse</span>
<a name="line-47"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>registerKillThread</span>
<a name="line-48"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>bindPort</span>
<a name="line-49"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>enumSocket</span>
<a name="line-50"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>pause</span>
<a name="line-51"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>resume</span>
<a name="line-52"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>cancel</span>
<a name="line-53"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>register</span>
<a name="line-54"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>initialize</span>
<a name="line-55"></a><span class='hs-cpp'>#if TEST</span>
<a name="line-56"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>takeHeaders</span>
<a name="line-57"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>readInt</span>
<a name="line-58"></a><span class='hs-cpp'>#endif</span>
<a name="line-59"></a> <span class='hs-layout'>)</span> <span class='hs-keyword'>where</span>
<a name="line-60"></a>
<a name="line-61"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Prelude</span> <span class='hs-varid'>hiding</span> <span class='hs-layout'>(</span><span class='hs-varid'>catch</span><span class='hs-layout'>,</span> <span class='hs-varid'>lines</span><span class='hs-layout'>)</span>
<a name="line-62"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Wai</span>
<a name="line-63"></a>
<a name="line-64"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-layout'>(</span><span class='hs-conid'>ByteString</span><span class='hs-layout'>)</span>
<a name="line-65"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>S</span>
<a name="line-66"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>Unsafe</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>SU</span>
<a name="line-67"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>Char8</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>B</span>
<a name="line-68"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>Lazy</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>L</span>
<a name="line-69"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span> <span class='hs-layout'>(</span><span class='hs-varid'>sClose</span><span class='hs-layout'>,</span> <span class='hs-conid'>Socket</span><span class='hs-layout'>)</span>
<a name="line-70"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Socket</span>
<a name="line-71"></a> <span class='hs-layout'>(</span> <span class='hs-varid'>accept</span><span class='hs-layout'>,</span> <span class='hs-conid'>Family</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-72"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>SocketType</span> <span class='hs-layout'>(</span><span class='hs-conid'>Stream</span><span class='hs-layout'>)</span><span class='hs-layout'>,</span> <span class='hs-varid'>listen</span><span class='hs-layout'>,</span> <span class='hs-varid'>bindSocket</span><span class='hs-layout'>,</span> <span class='hs-varid'>setSocketOption</span><span class='hs-layout'>,</span> <span class='hs-varid'>maxListenQueue</span>
<a name="line-73"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>SockAddr</span><span class='hs-layout'>,</span> <span class='hs-conid'>SocketOption</span> <span class='hs-layout'>(</span><span class='hs-conid'>ReuseAddr</span><span class='hs-layout'>)</span>
<a name="line-74"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>AddrInfo</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span><span class='hs-layout'>,</span> <span class='hs-conid'>AddrInfoFlag</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span><span class='hs-layout'>,</span> <span class='hs-varid'>defaultHints</span><span class='hs-layout'>,</span> <span class='hs-varid'>getAddrInfo</span>
<a name="line-75"></a> <span class='hs-layout'>)</span>
<a name="line-76"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Socket</span>
<a name="line-77"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Socket</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>Sock</span>
<a name="line-78"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Exception</span>
<a name="line-79"></a> <span class='hs-layout'>(</span> <span class='hs-varid'>bracket</span><span class='hs-layout'>,</span> <span class='hs-varid'>finally</span><span class='hs-layout'>,</span> <span class='hs-conid'>Exception</span><span class='hs-layout'>,</span> <span class='hs-conid'>SomeException</span><span class='hs-layout'>,</span> <span class='hs-varid'>catch</span>
<a name="line-80"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>fromException</span><span class='hs-layout'>,</span> <span class='hs-conid'>AsyncException</span> <span class='hs-layout'>(</span><span class='hs-conid'>ThreadKilled</span><span class='hs-layout'>)</span>
<a name="line-81"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>bracketOnError</span>
<a name="line-82"></a> <span class='hs-layout'>)</span>
<a name="line-83"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Concurrent</span> <span class='hs-layout'>(</span><span class='hs-varid'>forkIO</span><span class='hs-layout'>)</span>
<a name="line-84"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Char</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>C</span>
<a name="line-85"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Maybe</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromMaybe</span><span class='hs-layout'>)</span>
<a name="line-86"></a>
<a name="line-87"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Typeable</span> <span class='hs-layout'>(</span><span class='hs-conid'>Typeable</span><span class='hs-layout'>)</span>
<a name="line-88"></a>
<a name="line-89"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Enumerator</span> <span class='hs-layout'>(</span><span class='hs-layout'>(</span><span class='hs-varop'>$$</span><span class='hs-layout'>)</span><span class='hs-layout'>,</span> <span class='hs-layout'>(</span><span class='hs-varop'>>>==</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-90"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Enumerator</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>E</span>
<a name="line-91"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Enumerator</span><span class='hs-varop'>.</span><span class='hs-conid'>List</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>EL</span>
<a name="line-92"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Enumerator</span><span class='hs-varop'>.</span><span class='hs-conid'>Binary</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>EB</span>
<a name="line-93"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Blaze</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>Builder</span><span class='hs-varop'>.</span><span class='hs-conid'>Enumerator</span> <span class='hs-layout'>(</span><span class='hs-varid'>builderToByteString</span><span class='hs-layout'>)</span>
<a name="line-94"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Blaze</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>Builder</span><span class='hs-varop'>.</span><span class='hs-conid'>HTTP</span>
<a name="line-95"></a> <span class='hs-layout'>(</span><span class='hs-varid'>chunkedTransferEncoding</span><span class='hs-layout'>,</span> <span class='hs-varid'>chunkedTransferTerminator</span><span class='hs-layout'>)</span>
<a name="line-96"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Blaze</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>Builder</span>
<a name="line-97"></a> <span class='hs-layout'>(</span><span class='hs-varid'>copyByteString</span><span class='hs-layout'>,</span> <span class='hs-conid'>Builder</span><span class='hs-layout'>,</span> <span class='hs-varid'>toLazyByteString</span><span class='hs-layout'>,</span> <span class='hs-varid'>toByteStringIO</span><span class='hs-layout'>)</span>
<a name="line-98"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Blaze</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>Builder</span><span class='hs-varop'>.</span><span class='hs-conid'>Char8</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromChar</span><span class='hs-layout'>,</span> <span class='hs-varid'>fromShow</span><span class='hs-layout'>)</span>
<a name="line-99"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Monoid</span> <span class='hs-layout'>(</span><span class='hs-varid'>mappend</span><span class='hs-layout'>,</span> <span class='hs-varid'>mconcat</span><span class='hs-layout'>)</span>
<a name="line-100"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Sendfile</span>
<a name="line-101"></a>
<a name="line-102"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>System</span><span class='hs-varop'>.</span><span class='hs-conid'>PosixCompat</span><span class='hs-varop'>.</span><span class='hs-conid'>Files</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>P</span>
<a name="line-103"></a>
<a name="line-104"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Monad</span><span class='hs-varop'>.</span><span class='hs-conid'>IO</span><span class='hs-varop'>.</span><span class='hs-conid'>Class</span> <span class='hs-layout'>(</span><span class='hs-varid'>liftIO</span><span class='hs-layout'>)</span>
<a name="line-105"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Timeout</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>T</span>
<a name="line-106"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Timeout</span> <span class='hs-layout'>(</span><span class='hs-conid'>Manager</span><span class='hs-layout'>,</span> <span class='hs-varid'>registerKillThread</span><span class='hs-layout'>,</span> <span class='hs-varid'>pause</span><span class='hs-layout'>,</span> <span class='hs-varid'>resume</span><span class='hs-layout'>)</span>
<a name="line-107"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Word</span> <span class='hs-layout'>(</span><span class='hs-conid'>Word8</span><span class='hs-layout'>)</span>
<a name="line-108"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>List</span> <span class='hs-layout'>(</span><span class='hs-varid'>foldl'</span><span class='hs-layout'>)</span>
<a name="line-109"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Monad</span> <span class='hs-layout'>(</span><span class='hs-varid'>forever</span><span class='hs-layout'>)</span>
<a name="line-110"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>HTTP</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>H</span>
<a name="line-111"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>CaseInsensitive</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>CI</span>
<a name="line-112"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>System</span><span class='hs-varop'>.</span><span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-varid'>hPutStrLn</span><span class='hs-layout'>,</span> <span class='hs-varid'>stderr</span><span class='hs-layout'>)</span>
<a name="line-113"></a>
<a name="line-114"></a><span class='hs-cpp'>#if WINDOWS</span>
<a name="line-115"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Concurrent</span> <span class='hs-layout'>(</span><span class='hs-varid'>threadDelay</span><span class='hs-layout'>)</span>
<a name="line-116"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Concurrent</span><span class='hs-varop'>.</span><span class='hs-conid'>MVar</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>MV</span>
<a name="line-117"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Socket</span> <span class='hs-layout'>(</span><span class='hs-varid'>withSocketsDo</span><span class='hs-layout'>)</span>
<a name="line-118"></a><span class='hs-cpp'>#endif</span>
<a name="line-119"></a>
<a name="line-120"></a><span class='hs-cpp'>#ifndef MEGA</span>
<a name="line-121"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Version</span> <span class='hs-layout'>(</span><span class='hs-varid'>showVersion</span><span class='hs-layout'>)</span>
<a name="line-122"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</span> <span class='hs-conid'>Paths_warp</span>
<a name="line-123"></a><a name="warpVersion"></a><span class='hs-definition'>warpVersion</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>showVersion</span> <span class='hs-conid'>Paths_warp</span><span class='hs-varop'>.</span><span class='hs-varid'>version</span>
<a name="line-124"></a><span class='hs-cpp'>#else</span>
<a name="line-125"></a><span class='hs-definition'>warpVersion</span> <span class='hs-keyglyph'>=</span> <span class='hs-str'>"0.4.6"</span>
<a name="line-126"></a><span class='hs-cpp'>#endif</span>
<a name="line-127"></a><span class='hs-definition'>warpVersion</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>String</span>
<a name="line-128"></a>
<a name="line-129"></a><a name="bindPort"></a><span class='hs-definition'>bindPort</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Socket</span>
<a name="line-130"></a><span class='hs-definition'>bindPort</span> <span class='hs-varid'>p</span> <span class='hs-varid'>s</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-131"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>hints</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>defaultHints</span> <span class='hs-layout'>{</span> <span class='hs-varid'>addrFlags</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>AI_PASSIVE</span>
<a name="line-132"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>AI_NUMERICSERV</span>
<a name="line-133"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>AI_NUMERICHOST</span><span class='hs-keyglyph'>]</span>
<a name="line-134"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>addrSocketType</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Stream</span> <span class='hs-layout'>}</span>
<a name="line-135"></a> <span class='hs-varid'>host</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>if</span> <span class='hs-varid'>s</span> <span class='hs-varop'>==</span> <span class='hs-str'>"*"</span> <span class='hs-keyword'>then</span> <span class='hs-conid'>Nothing</span> <span class='hs-keyword'>else</span> <span class='hs-conid'>Just</span> <span class='hs-varid'>s</span>
<a name="line-136"></a> <span class='hs-varid'>port</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Just</span> <span class='hs-varop'>.</span> <span class='hs-varid'>show</span> <span class='hs-varop'>$</span> <span class='hs-varid'>p</span>
<a name="line-137"></a> <span class='hs-varid'>addrs</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getAddrInfo</span> <span class='hs-layout'>(</span><span class='hs-conid'>Just</span> <span class='hs-varid'>hints</span><span class='hs-layout'>)</span> <span class='hs-varid'>host</span> <span class='hs-varid'>port</span>
<a name="line-138"></a> <span class='hs-comment'>-- Choose an IPv6 socket if exists. This ensures the socket can</span>
<a name="line-139"></a> <span class='hs-comment'>-- handle both IPv4 and IPv6 if v6only is false.</span>
<a name="line-140"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>addrs'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>filter</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>x</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>addrFamily</span> <span class='hs-varid'>x</span> <span class='hs-varop'>==</span> <span class='hs-conid'>AF_INET6</span><span class='hs-layout'>)</span> <span class='hs-varid'>addrs</span>
<a name="line-141"></a> <span class='hs-varid'>addr</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>if</span> <span class='hs-varid'>null</span> <span class='hs-varid'>addrs'</span> <span class='hs-keyword'>then</span> <span class='hs-varid'>head</span> <span class='hs-varid'>addrs</span> <span class='hs-keyword'>else</span> <span class='hs-varid'>head</span> <span class='hs-varid'>addrs'</span>
<a name="line-142"></a> <span class='hs-varid'>bracketOnError</span>
<a name="line-143"></a> <span class='hs-layout'>(</span><span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Socket</span><span class='hs-varop'>.</span><span class='hs-varid'>socket</span> <span class='hs-layout'>(</span><span class='hs-varid'>addrFamily</span> <span class='hs-varid'>addr</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>addrSocketType</span> <span class='hs-varid'>addr</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>addrProtocol</span> <span class='hs-varid'>addr</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-144"></a> <span class='hs-layout'>(</span><span class='hs-varid'>sClose</span><span class='hs-layout'>)</span>
<a name="line-145"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>sock</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-146"></a> <span class='hs-varid'>setSocketOption</span> <span class='hs-varid'>sock</span> <span class='hs-conid'>ReuseAddr</span> <span class='hs-num'>1</span>
<a name="line-147"></a> <span class='hs-varid'>bindSocket</span> <span class='hs-varid'>sock</span> <span class='hs-layout'>(</span><span class='hs-varid'>addrAddress</span> <span class='hs-varid'>addr</span><span class='hs-layout'>)</span>
<a name="line-148"></a> <span class='hs-varid'>listen</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>maxListenQueue</span>
<a name="line-149"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>sock</span>
<a name="line-150"></a> <span class='hs-layout'>)</span>
<a name="line-151"></a>
<a name="line-152"></a><a name="run"></a><span class='hs-comment'>-- | Run an 'Application' on the given port. This calls 'runSettings' with</span>
<a name="line-153"></a><span class='hs-comment'>-- 'defaultSettings'.</span>
<a name="line-154"></a><span class='hs-definition'>run</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Port</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Application</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-155"></a><span class='hs-definition'>run</span> <span class='hs-varid'>p</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>runSettings</span> <span class='hs-varid'>defaultSettings</span> <span class='hs-layout'>{</span> <span class='hs-varid'>settingsPort</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>p</span> <span class='hs-layout'>}</span>
<a name="line-156"></a>
<a name="line-157"></a><a name="runSettings"></a><span class='hs-comment'>-- | Run a Warp server with the given settings.</span>
<a name="line-158"></a><span class='hs-definition'>runSettings</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Settings</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Application</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-159"></a><span class='hs-cpp'>#if WINDOWS</span>
<a name="line-160"></a><span class='hs-definition'>runSettings</span> <span class='hs-varid'>set</span> <span class='hs-varid'>app</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>withSocketsDo</span> <span class='hs-varop'>$</span> <span class='hs-keyword'>do</span>
<a name="line-161"></a> <span class='hs-varid'>var</span> <span class='hs-keyglyph'><-</span> <span class='hs-conid'>MV</span><span class='hs-varop'>.</span><span class='hs-varid'>newMVar</span> <span class='hs-conid'>Nothing</span>
<a name="line-162"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>clean</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>MV</span><span class='hs-varop'>.</span><span class='hs-varid'>modifyMVar_</span> <span class='hs-varid'>var</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>s</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>maybe</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span> <span class='hs-varid'>sClose</span> <span class='hs-varid'>s</span> <span class='hs-varop'>>></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Nothing</span>
<a name="line-163"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>forkIO</span> <span class='hs-varop'>$</span> <span class='hs-varid'>bracket</span>
<a name="line-164"></a> <span class='hs-layout'>(</span><span class='hs-varid'>bindPort</span> <span class='hs-layout'>(</span><span class='hs-varid'>settingsPort</span> <span class='hs-varid'>set</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>settingsHost</span> <span class='hs-varid'>set</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-165"></a> <span class='hs-layout'>(</span><span class='hs-varid'>const</span> <span class='hs-varid'>clean</span><span class='hs-layout'>)</span>
<a name="line-166"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>s</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-167"></a> <span class='hs-conid'>MV</span><span class='hs-varop'>.</span><span class='hs-varid'>modifyMVar_</span> <span class='hs-varid'>var</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Just</span> <span class='hs-varid'>s</span><span class='hs-layout'>)</span>
<a name="line-168"></a> <span class='hs-varid'>runSettingsSocket</span> <span class='hs-varid'>set</span> <span class='hs-varid'>s</span> <span class='hs-varid'>app</span><span class='hs-layout'>)</span>
<a name="line-169"></a> <span class='hs-varid'>forever</span> <span class='hs-layout'>(</span><span class='hs-varid'>threadDelay</span> <span class='hs-varid'>maxBound</span><span class='hs-layout'>)</span> <span class='hs-varop'>`finally`</span> <span class='hs-varid'>clean</span>
<a name="line-170"></a><span class='hs-cpp'>#else</span>
<a name="line-171"></a><span class='hs-definition'>runSettings</span> <span class='hs-varid'>set</span> <span class='hs-keyglyph'>=</span>
<a name="line-172"></a> <span class='hs-varid'>bracket</span>
<a name="line-173"></a> <span class='hs-layout'>(</span><span class='hs-varid'>bindPort</span> <span class='hs-layout'>(</span><span class='hs-varid'>settingsPort</span> <span class='hs-varid'>set</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>settingsHost</span> <span class='hs-varid'>set</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-174"></a> <span class='hs-varid'>sClose</span> <span class='hs-varop'>.</span>
<a name="line-175"></a> <span class='hs-layout'>(</span><span class='hs-varid'>flip</span> <span class='hs-layout'>(</span><span class='hs-varid'>runSettingsSocket</span> <span class='hs-varid'>set</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-176"></a><span class='hs-cpp'>#endif</span>
<a name="line-177"></a>
<a name="line-178"></a><a name="Port"></a><span class='hs-keyword'>type</span> <span class='hs-conid'>Port</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Int</span>
<a name="line-179"></a>
<a name="line-180"></a><a name="runSettingsSocket"></a><span class='hs-comment'>-- | Same as 'runSettings', but uses a user-supplied socket instead of opening</span>
<a name="line-181"></a><span class='hs-comment'>-- one. This allows the user to provide, for example, Unix named socket, which</span>
<a name="line-182"></a><span class='hs-comment'>-- can be used when reverse HTTP proxying into your application.</span>
<a name="line-183"></a><span class='hs-comment'>--</span>
<a name="line-184"></a><span class='hs-comment'>-- Note that the 'settingsPort' will still be passed to 'Application's via the</span>
<a name="line-185"></a><span class='hs-comment'>-- 'serverPort' record.</span>
<a name="line-186"></a><span class='hs-definition'>runSettingsSocket</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Settings</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Socket</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Application</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-187"></a><span class='hs-definition'>runSettingsSocket</span> <span class='hs-varid'>set</span> <span class='hs-varid'>socket</span> <span class='hs-varid'>app</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-188"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>onE</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>settingsOnException</span> <span class='hs-varid'>set</span>
<a name="line-189"></a> <span class='hs-varid'>port</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>settingsPort</span> <span class='hs-varid'>set</span>
<a name="line-190"></a> <span class='hs-varid'>tm</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>maybe</span> <span class='hs-layout'>(</span><span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>initialize</span> <span class='hs-varop'>$</span> <span class='hs-varid'>settingsTimeout</span> <span class='hs-varid'>set</span> <span class='hs-varop'>*</span> <span class='hs-num'>1000000</span><span class='hs-layout'>)</span> <span class='hs-varid'>return</span>
<a name="line-191"></a> <span class='hs-varop'>$</span> <span class='hs-varid'>settingsManager</span> <span class='hs-varid'>set</span>
<a name="line-192"></a> <span class='hs-varid'>forever</span> <span class='hs-varop'>$</span> <span class='hs-keyword'>do</span>
<a name="line-193"></a> <span class='hs-layout'>(</span><span class='hs-varid'>conn</span><span class='hs-layout'>,</span> <span class='hs-varid'>sa</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>accept</span> <span class='hs-varid'>socket</span>
<a name="line-194"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>forkIO</span> <span class='hs-varop'>$</span> <span class='hs-keyword'>do</span>
<a name="line-195"></a> <span class='hs-varid'>th</span> <span class='hs-keyglyph'><-</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>registerKillThread</span> <span class='hs-varid'>tm</span>
<a name="line-196"></a> <span class='hs-varid'>serveConnection</span> <span class='hs-varid'>set</span> <span class='hs-varid'>th</span> <span class='hs-varid'>onE</span> <span class='hs-varid'>port</span> <span class='hs-varid'>app</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>sa</span>
<a name="line-197"></a> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>cancel</span> <span class='hs-varid'>th</span>
<a name="line-198"></a> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-199"></a>
<a name="line-200"></a><a name="serveConnection"></a><span class='hs-definition'>serveConnection</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Settings</span>
<a name="line-201"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-conid'>Handle</span>
<a name="line-202"></a> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-conid'>SomeException</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-203"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Port</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Application</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Socket</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>SockAddr</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-204"></a><span class='hs-definition'>serveConnection</span> <span class='hs-varid'>settings</span> <span class='hs-varid'>th</span> <span class='hs-varid'>onException</span> <span class='hs-varid'>port</span> <span class='hs-varid'>app</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>remoteHost'</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-205"></a> <span class='hs-varid'>catch</span>
<a name="line-206"></a> <span class='hs-layout'>(</span><span class='hs-varid'>finally</span>
<a name="line-207"></a> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>run_</span> <span class='hs-varop'>$</span> <span class='hs-varid'>fromClient</span> <span class='hs-varop'>$$</span> <span class='hs-varid'>serveConnection'</span><span class='hs-layout'>)</span>
<a name="line-208"></a> <span class='hs-layout'>(</span><span class='hs-varid'>sClose</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-209"></a> <span class='hs-varid'>onException</span>
<a name="line-210"></a> <span class='hs-keyword'>where</span>
<a name="line-211"></a> <span class='hs-varid'>fromClient</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>enumSocket</span> <span class='hs-varid'>th</span> <span class='hs-varid'>bytesPerRead</span> <span class='hs-varid'>conn</span>
<a name="line-212"></a> <span class='hs-varid'>serveConnection'</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-213"></a> <span class='hs-layout'>(</span><span class='hs-varid'>len</span><span class='hs-layout'>,</span> <span class='hs-varid'>env</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>parseRequest</span> <span class='hs-varid'>port</span> <span class='hs-varid'>remoteHost'</span>
<a name="line-214"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>settingsIntercept</span> <span class='hs-varid'>settings</span> <span class='hs-varid'>env</span> <span class='hs-keyword'>of</span>
<a name="line-215"></a> <span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-216"></a> <span class='hs-comment'>-- Let the application run for as long as it wants</span>
<a name="line-217"></a> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>pause</span> <span class='hs-varid'>th</span>
<a name="line-218"></a> <span class='hs-varid'>res</span> <span class='hs-keyglyph'><-</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>joinI</span> <span class='hs-varop'>$</span> <span class='hs-conid'>EB</span><span class='hs-varop'>.</span><span class='hs-varid'>isolate</span> <span class='hs-varid'>len</span> <span class='hs-varop'>$$</span> <span class='hs-varid'>app</span> <span class='hs-varid'>env</span>
<a name="line-219"></a> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>resume</span> <span class='hs-varid'>th</span>
<a name="line-220"></a> <span class='hs-varid'>keepAlive</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-varid'>sendResponse</span> <span class='hs-varid'>th</span> <span class='hs-varid'>env</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>res</span>
<a name="line-221"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>keepAlive</span> <span class='hs-keyword'>then</span> <span class='hs-varid'>serveConnection'</span> <span class='hs-keyword'>else</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-222"></a> <span class='hs-conid'>Just</span> <span class='hs-varid'>intercept</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-223"></a> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>pause</span> <span class='hs-varid'>th</span>
<a name="line-224"></a> <span class='hs-varid'>intercept</span> <span class='hs-varid'>conn</span>
<a name="line-225"></a>
<a name="line-226"></a><a name="parseRequest"></a><span class='hs-definition'>parseRequest</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Port</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>SockAddr</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Iteratee</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Integer</span><span class='hs-layout'>,</span> <span class='hs-conid'>Request</span><span class='hs-layout'>)</span>
<a name="line-227"></a><span class='hs-definition'>parseRequest</span> <span class='hs-varid'>port</span> <span class='hs-varid'>remoteHost'</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-228"></a> <span class='hs-varid'>headers'</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>takeHeaders</span>
<a name="line-229"></a> <span class='hs-varid'>parseRequest'</span> <span class='hs-varid'>port</span> <span class='hs-varid'>headers'</span> <span class='hs-varid'>remoteHost'</span>
<a name="line-230"></a>
<a name="line-231"></a><a name="bytesPerRead"></a><span class='hs-comment'>-- FIXME come up with good values here</span>
<a name="line-232"></a><span class='hs-definition'>bytesPerRead</span><span class='hs-layout'>,</span> <span class='hs-varid'>maxTotalHeaderLength</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span>
<a name="line-233"></a><span class='hs-definition'>bytesPerRead</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>4096</span>
<a name="line-234"></a><a name="maxTotalHeaderLength"></a><span class='hs-definition'>maxTotalHeaderLength</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>50</span> <span class='hs-varop'>*</span> <span class='hs-num'>1024</span>
<a name="line-235"></a>
<a name="line-236"></a><a name="InvalidRequest"></a><span class='hs-keyword'>data</span> <span class='hs-conid'>InvalidRequest</span> <span class='hs-keyglyph'>=</span>
<a name="line-237"></a> <span class='hs-conid'>NotEnoughLines</span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>String</span><span class='hs-keyglyph'>]</span>
<a name="line-238"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>BadFirstLine</span> <span class='hs-conid'>String</span>
<a name="line-239"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>NonHttp</span>
<a name="line-240"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>IncompleteHeaders</span>
<a name="line-241"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>ConnectionClosedByPeer</span>
<a name="line-242"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>OverLargeHeader</span>
<a name="line-243"></a> <span class='hs-keyword'>deriving</span> <span class='hs-layout'>(</span><span class='hs-conid'>Show</span><span class='hs-layout'>,</span> <span class='hs-conid'>Typeable</span><span class='hs-layout'>,</span> <span class='hs-conid'>Eq</span><span class='hs-layout'>)</span>
<a name="line-244"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>Exception</span> <span class='hs-conid'>InvalidRequest</span>
<a name="line-245"></a>
<a name="line-246"></a><a name="parseRequest'"></a><span class='hs-comment'>-- | Parse a set of header lines and body into a 'Request'.</span>
<a name="line-247"></a><span class='hs-definition'>parseRequest'</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Port</span>
<a name="line-248"></a> <span class='hs-keyglyph'>-></span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span>
<a name="line-249"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>SockAddr</span>
<a name="line-250"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Iteratee</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Integer</span><span class='hs-layout'>,</span> <span class='hs-conid'>Request</span><span class='hs-layout'>)</span>
<a name="line-251"></a><span class='hs-definition'>parseRequest'</span> <span class='hs-keyword'>_</span> <span class='hs-conid'>[]</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>throwError</span> <span class='hs-varop'>$</span> <span class='hs-conid'>NotEnoughLines</span> <span class='hs-conid'>[]</span>
<a name="line-252"></a><span class='hs-definition'>parseRequest'</span> <span class='hs-varid'>port</span> <span class='hs-layout'>(</span><span class='hs-varid'>firstLine</span><span class='hs-conop'>:</span><span class='hs-varid'>otherLines</span><span class='hs-layout'>)</span> <span class='hs-varid'>remoteHost'</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-253"></a> <span class='hs-layout'>(</span><span class='hs-varid'>method</span><span class='hs-layout'>,</span> <span class='hs-varid'>rpath'</span><span class='hs-layout'>,</span> <span class='hs-varid'>gets</span><span class='hs-layout'>,</span> <span class='hs-varid'>httpversion</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>parseFirst</span> <span class='hs-varid'>firstLine</span>
<a name="line-254"></a> <span class='hs-keyword'>let</span> <span class='hs-layout'>(</span><span class='hs-varid'>host'</span><span class='hs-layout'>,</span><span class='hs-varid'>rpath</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span>
<a name="line-255"></a> <span class='hs-keyword'>if</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>null</span> <span class='hs-varid'>rpath'</span>
<a name="line-256"></a> <span class='hs-keyword'>then</span> <span class='hs-layout'>(</span><span class='hs-str'>""</span><span class='hs-layout'>,</span><span class='hs-str'>"/"</span><span class='hs-layout'>)</span>
<a name="line-257"></a> <span class='hs-keyword'>else</span> <span class='hs-keyword'>if</span> <span class='hs-str'>"http://"</span> <span class='hs-varop'>`</span><span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>isPrefixOf</span><span class='hs-varop'>`</span> <span class='hs-varid'>rpath'</span>
<a name="line-258"></a> <span class='hs-keyword'>then</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>breakByte</span> <span class='hs-num'>47</span> <span class='hs-varop'>$</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>drop</span> <span class='hs-num'>7</span> <span class='hs-varid'>rpath'</span> <span class='hs-comment'>-- '/'</span>
<a name="line-259"></a> <span class='hs-keyword'>else</span> <span class='hs-layout'>(</span><span class='hs-str'>""</span><span class='hs-layout'>,</span> <span class='hs-varid'>rpath'</span><span class='hs-layout'>)</span>
<a name="line-260"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>heads</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>map</span> <span class='hs-varid'>parseHeaderNoAttr</span> <span class='hs-varid'>otherLines</span>
<a name="line-261"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>host</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>fromMaybe</span> <span class='hs-varid'>host'</span> <span class='hs-varop'>$</span> <span class='hs-varid'>lookup</span> <span class='hs-str'>"host"</span> <span class='hs-varid'>heads</span>
<a name="line-262"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>len</span> <span class='hs-keyglyph'>=</span>
<a name="line-263"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>lookup</span> <span class='hs-str'>"content-length"</span> <span class='hs-varid'>heads</span> <span class='hs-keyword'>of</span>
<a name="line-264"></a> <span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span> <span class='hs-num'>0</span>
<a name="line-265"></a> <span class='hs-conid'>Just</span> <span class='hs-varid'>bs</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>fromIntegral</span> <span class='hs-varop'>$</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>foldl'</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>i</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>i</span> <span class='hs-varop'>*</span> <span class='hs-num'>10</span> <span class='hs-varop'>+</span> <span class='hs-conid'>C</span><span class='hs-varop'>.</span><span class='hs-varid'>digitToInt</span> <span class='hs-varid'>c</span><span class='hs-layout'>)</span> <span class='hs-num'>0</span> <span class='hs-varop'>$</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>takeWhile</span> <span class='hs-conid'>C</span><span class='hs-varop'>.</span><span class='hs-varid'>isDigit</span> <span class='hs-varid'>bs</span>
<a name="line-266"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>serverName'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>takeUntil</span> <span class='hs-num'>58</span> <span class='hs-varid'>host</span> <span class='hs-comment'>-- ':'</span>
<a name="line-267"></a> <span class='hs-comment'>-- FIXME isolate takes an Integer instead of Int or Int64. If this is a</span>
<a name="line-268"></a> <span class='hs-comment'>-- performance penalty, we may need our own version.</span>
<a name="line-269"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>len</span><span class='hs-layout'>,</span> <span class='hs-conid'>Request</span>
<a name="line-270"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>requestMethod</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>method</span>
<a name="line-271"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>httpVersion</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>httpversion</span>
<a name="line-272"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>pathInfo</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>decodePathSegments</span> <span class='hs-varid'>rpath</span>
<a name="line-273"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>rawPathInfo</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>rpath</span>
<a name="line-274"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>rawQueryString</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>gets</span>
<a name="line-275"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>queryString</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>parseQuery</span> <span class='hs-varid'>gets</span>
<a name="line-276"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>serverName</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>serverName'</span>
<a name="line-277"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>serverPort</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>port</span>
<a name="line-278"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>requestHeaders</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>heads</span>
<a name="line-279"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>isSecure</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>False</span>
<a name="line-280"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>remoteHost</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>remoteHost'</span>
<a name="line-281"></a> <span class='hs-layout'>}</span><span class='hs-layout'>)</span>
<a name="line-282"></a>
<a name="line-283"></a>
<a name="line-284"></a><a name="takeUntil"></a><span class='hs-definition'>takeUntil</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Word8</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ByteString</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ByteString</span>
<a name="line-285"></a><span class='hs-definition'>takeUntil</span> <span class='hs-varid'>c</span> <span class='hs-varid'>bs</span> <span class='hs-keyglyph'>=</span>
<a name="line-286"></a> <span class='hs-keyword'>case</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>elemIndex</span> <span class='hs-varid'>c</span> <span class='hs-varid'>bs</span> <span class='hs-keyword'>of</span>
<a name="line-287"></a> <span class='hs-conid'>Just</span> <span class='hs-varop'>!</span><span class='hs-varid'>idx</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>SU</span><span class='hs-varop'>.</span><span class='hs-varid'>unsafeTake</span> <span class='hs-varid'>idx</span> <span class='hs-varid'>bs</span>
<a name="line-288"></a> <span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>bs</span>
<a name="line-289"></a><span class='hs-comment'>{-# INLINE takeUntil #-}</span>
<a name="line-290"></a>
<a name="line-291"></a><a name="parseFirst"></a><span class='hs-definition'>parseFirst</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>ByteString</span>
<a name="line-292"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Iteratee</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>ByteString</span><span class='hs-layout'>,</span> <span class='hs-conid'>ByteString</span><span class='hs-layout'>,</span> <span class='hs-conid'>ByteString</span><span class='hs-layout'>,</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>HttpVersion</span><span class='hs-layout'>)</span>
<a name="line-293"></a><span class='hs-definition'>parseFirst</span> <span class='hs-varid'>s</span> <span class='hs-keyglyph'>=</span>
<a name="line-294"></a> <span class='hs-keyword'>case</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>split</span> <span class='hs-num'>32</span> <span class='hs-varid'>s</span> <span class='hs-keyword'>of</span> <span class='hs-comment'>-- ' '</span>
<a name="line-295"></a> <span class='hs-keyglyph'>[</span><span class='hs-varid'>method</span><span class='hs-layout'>,</span> <span class='hs-varid'>query</span><span class='hs-layout'>,</span> <span class='hs-varid'>http'</span><span class='hs-keyglyph'>]</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-296"></a> <span class='hs-keyword'>let</span> <span class='hs-layout'>(</span><span class='hs-varid'>hfirst</span><span class='hs-layout'>,</span> <span class='hs-varid'>hsecond</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>splitAt</span> <span class='hs-num'>5</span> <span class='hs-varid'>http'</span>
<a name="line-297"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>hfirst</span> <span class='hs-varop'>==</span> <span class='hs-str'>"HTTP/"</span>
<a name="line-298"></a> <span class='hs-keyword'>then</span> <span class='hs-keyword'>let</span> <span class='hs-layout'>(</span><span class='hs-varid'>rpath</span><span class='hs-layout'>,</span> <span class='hs-varid'>qstring</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>breakByte</span> <span class='hs-num'>63</span> <span class='hs-varid'>query</span> <span class='hs-comment'>-- '?'</span>
<a name="line-299"></a> <span class='hs-varid'>hv</span> <span class='hs-keyglyph'>=</span>
<a name="line-300"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>hsecond</span> <span class='hs-keyword'>of</span>
<a name="line-301"></a> <span class='hs-str'>"1.1"</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>http11</span>
<a name="line-302"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>http10</span>
<a name="line-303"></a> <span class='hs-keyword'>in</span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>method</span><span class='hs-layout'>,</span> <span class='hs-varid'>rpath</span><span class='hs-layout'>,</span> <span class='hs-varid'>qstring</span><span class='hs-layout'>,</span> <span class='hs-varid'>hv</span><span class='hs-layout'>)</span>
<a name="line-304"></a> <span class='hs-keyword'>else</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>throwError</span> <span class='hs-conid'>NonHttp</span>
<a name="line-305"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>throwError</span> <span class='hs-varop'>$</span> <span class='hs-conid'>BadFirstLine</span> <span class='hs-varop'>$</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>unpack</span> <span class='hs-varid'>s</span>
<a name="line-306"></a><span class='hs-comment'>{-# INLINE parseFirst #-}</span> <span class='hs-comment'>-- FIXME is this inline necessary? the function is only called from one place and not exported</span>
<a name="line-307"></a>
<a name="line-308"></a><a name="httpBuilder"></a><span class='hs-definition'>httpBuilder</span><span class='hs-layout'>,</span> <span class='hs-varid'>spaceBuilder</span><span class='hs-layout'>,</span> <span class='hs-varid'>newlineBuilder</span><span class='hs-layout'>,</span> <span class='hs-varid'>transferEncodingBuilder</span>
<a name="line-309"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>colonSpaceBuilder</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Builder</span>
<a name="line-310"></a><span class='hs-definition'>httpBuilder</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>copyByteString</span> <span class='hs-str'>"HTTP/"</span>
<a name="line-311"></a><a name="spaceBuilder"></a><span class='hs-definition'>spaceBuilder</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>fromChar</span> <span class='hs-chr'>' '</span>
<a name="line-312"></a><a name="newlineBuilder"></a><span class='hs-definition'>newlineBuilder</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>copyByteString</span> <span class='hs-str'>"\r\n"</span>
<a name="line-313"></a><a name="transferEncodingBuilder"></a><span class='hs-definition'>transferEncodingBuilder</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>copyByteString</span> <span class='hs-str'>"Transfer-Encoding: chunked\r\n\r\n"</span>
<a name="line-314"></a><a name="colonSpaceBuilder"></a><span class='hs-definition'>colonSpaceBuilder</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>copyByteString</span> <span class='hs-str'>": "</span>
<a name="line-315"></a>
<a name="line-316"></a><a name="headers"></a><span class='hs-definition'>headers</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>HttpVersion</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>Status</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>ResponseHeaders</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Builder</span>
<a name="line-317"></a><a name="!"></a><span class='hs-definition'>headers</span> <span class='hs-varop'>!</span><span class='hs-varid'>httpversion</span> <span class='hs-varop'>!</span><span class='hs-varid'>status</span> <span class='hs-varop'>!</span><span class='hs-varid'>responseHeaders</span> <span class='hs-varop'>!</span><span class='hs-varid'>isChunked'</span> <span class='hs-keyglyph'>=</span> <span class='hs-comment'>{-# SCC "headers" #-}</span>
<a name="line-318"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>start</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>httpBuilder</span>
<a name="line-319"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-layout'>(</span><span class='hs-varid'>copyByteString</span> <span class='hs-varop'>$</span>
<a name="line-320"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>httpversion</span> <span class='hs-keyword'>of</span>
<a name="line-321"></a> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>HttpVersion</span> <span class='hs-num'>1</span> <span class='hs-num'>1</span> <span class='hs-keyglyph'>-></span> <span class='hs-str'>"1.1"</span>
<a name="line-322"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-str'>"1.0"</span><span class='hs-layout'>)</span>
<a name="line-323"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>spaceBuilder</span>
<a name="line-324"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>fromShow</span> <span class='hs-layout'>(</span><span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>statusCode</span> <span class='hs-varid'>status</span><span class='hs-layout'>)</span>
<a name="line-325"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>spaceBuilder</span>
<a name="line-326"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>copyByteString</span> <span class='hs-layout'>(</span><span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>statusMessage</span> <span class='hs-varid'>status</span><span class='hs-layout'>)</span>
<a name="line-327"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>newlineBuilder</span>
<a name="line-328"></a> <span class='hs-varop'>!</span><span class='hs-varid'>start'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>foldl'</span> <span class='hs-varid'>responseHeaderToBuilder</span> <span class='hs-varid'>start</span> <span class='hs-layout'>(</span><span class='hs-varid'>serverHeader</span> <span class='hs-varid'>responseHeaders</span><span class='hs-layout'>)</span>
<a name="line-329"></a> <span class='hs-varop'>!</span><span class='hs-varid'>end</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>if</span> <span class='hs-varid'>isChunked'</span>
<a name="line-330"></a> <span class='hs-keyword'>then</span> <span class='hs-varid'>transferEncodingBuilder</span>
<a name="line-331"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>newlineBuilder</span>
<a name="line-332"></a> <span class='hs-keyword'>in</span> <span class='hs-varid'>start'</span> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>end</span>
<a name="line-333"></a>
<a name="line-334"></a><a name="responseHeaderToBuilder"></a><span class='hs-definition'>responseHeaderToBuilder</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Builder</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>Header</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Builder</span>
<a name="line-335"></a><span class='hs-definition'>responseHeaderToBuilder</span> <span class='hs-varid'>b</span> <span class='hs-layout'>(</span><span class='hs-varid'>x</span><span class='hs-layout'>,</span> <span class='hs-varid'>y</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>b</span>
<a name="line-336"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>copyByteString</span> <span class='hs-layout'>(</span><span class='hs-conid'>CI</span><span class='hs-varop'>.</span><span class='hs-varid'>original</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-337"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>colonSpaceBuilder</span>
<a name="line-338"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>copyByteString</span> <span class='hs-varid'>y</span>
<a name="line-339"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>newlineBuilder</span>
<a name="line-340"></a>
<a name="line-341"></a><a name="checkPersist"></a><span class='hs-definition'>checkPersist</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Request</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span>
<a name="line-342"></a><span class='hs-definition'>checkPersist</span> <span class='hs-varid'>req</span>
<a name="line-343"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>ver</span> <span class='hs-varop'>==</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>http11</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>checkPersist11</span> <span class='hs-varid'>conn</span>
<a name="line-344"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>checkPersist10</span> <span class='hs-varid'>conn</span>
<a name="line-345"></a> <span class='hs-keyword'>where</span>
<a name="line-346"></a> <span class='hs-varid'>ver</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>httpVersion</span> <span class='hs-varid'>req</span>
<a name="line-347"></a> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>lookup</span> <span class='hs-str'>"connection"</span> <span class='hs-varop'>$</span> <span class='hs-varid'>requestHeaders</span> <span class='hs-varid'>req</span>
<a name="line-348"></a> <span class='hs-varid'>checkPersist11</span> <span class='hs-layout'>(</span><span class='hs-conid'>Just</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-349"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>CI</span><span class='hs-varop'>.</span><span class='hs-varid'>foldCase</span> <span class='hs-varid'>x</span> <span class='hs-varop'>==</span> <span class='hs-str'>"close"</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>False</span>
<a name="line-350"></a> <span class='hs-varid'>checkPersist11</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>True</span>
<a name="line-351"></a> <span class='hs-varid'>checkPersist10</span> <span class='hs-layout'>(</span><span class='hs-conid'>Just</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-352"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>CI</span><span class='hs-varop'>.</span><span class='hs-varid'>foldCase</span> <span class='hs-varid'>x</span> <span class='hs-varop'>==</span> <span class='hs-str'>"keep-alive"</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>True</span>
<a name="line-353"></a> <span class='hs-varid'>checkPersist10</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>False</span>
<a name="line-354"></a>
<a name="line-355"></a><a name="isChunked"></a><span class='hs-definition'>isChunked</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>HttpVersion</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span>
<a name="line-356"></a><span class='hs-definition'>isChunked</span> <span class='hs-keyglyph'>=</span> <span class='hs-layout'>(</span><span class='hs-varop'>==</span><span class='hs-layout'>)</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>http11</span>
<a name="line-357"></a>
<a name="line-358"></a><a name="hasBody"></a><span class='hs-definition'>hasBody</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>Status</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Request</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span>
<a name="line-359"></a><span class='hs-definition'>hasBody</span> <span class='hs-varid'>s</span> <span class='hs-varid'>req</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>s</span> <span class='hs-varop'>/=</span> <span class='hs-layout'>(</span><span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>Status</span> <span class='hs-num'>204</span> <span class='hs-str'>""</span><span class='hs-layout'>)</span> <span class='hs-varop'>&&</span> <span class='hs-varid'>s</span> <span class='hs-varop'>/=</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>status304</span> <span class='hs-varop'>&&</span>
<a name="line-360"></a> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-varid'>statusCode</span> <span class='hs-varid'>s</span> <span class='hs-varop'>>=</span> <span class='hs-num'>200</span> <span class='hs-varop'>&&</span> <span class='hs-varid'>requestMethod</span> <span class='hs-varid'>req</span> <span class='hs-varop'>/=</span> <span class='hs-str'>"HEAD"</span>
<a name="line-361"></a>
<a name="line-362"></a><a name="sendResponse"></a><span class='hs-definition'>sendResponse</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-conid'>Handle</span>
<a name="line-363"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Request</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Socket</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Response</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Bool</span>
<a name="line-364"></a><span class='hs-definition'>sendResponse</span> <span class='hs-varid'>th</span> <span class='hs-varid'>req</span> <span class='hs-varid'>socket</span> <span class='hs-varid'>r</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>sendResponse'</span> <span class='hs-varid'>r</span>
<a name="line-365"></a> <span class='hs-keyword'>where</span>
<a name="line-366"></a> <span class='hs-varid'>version</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>httpVersion</span> <span class='hs-varid'>req</span>
<a name="line-367"></a> <span class='hs-varid'>isPersist</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>checkPersist</span> <span class='hs-varid'>req</span>
<a name="line-368"></a> <span class='hs-varid'>isChunked'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>isChunked</span> <span class='hs-varid'>version</span>
<a name="line-369"></a> <span class='hs-varid'>needsChunked</span> <span class='hs-varid'>hs</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>isChunked'</span> <span class='hs-varop'>&&</span> <span class='hs-varid'>not</span> <span class='hs-layout'>(</span><span class='hs-varid'>hasLength</span> <span class='hs-varid'>hs</span><span class='hs-layout'>)</span>
<a name="line-370"></a> <span class='hs-varid'>isKeepAlive</span> <span class='hs-varid'>hs</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>isPersist</span> <span class='hs-varop'>&&</span> <span class='hs-layout'>(</span><span class='hs-varid'>isChunked'</span> <span class='hs-varop'>||</span> <span class='hs-varid'>hasLength</span> <span class='hs-varid'>hs</span><span class='hs-layout'>)</span>
<a name="line-371"></a> <span class='hs-varid'>hasLength</span> <span class='hs-varid'>hs</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>lookup</span> <span class='hs-str'>"content-length"</span> <span class='hs-varid'>hs</span> <span class='hs-varop'>/=</span> <span class='hs-conid'>Nothing</span>
<a name="line-372"></a>
<a name="line-373"></a> <span class='hs-varid'>sendResponse'</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Response</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Bool</span>
<a name="line-374"></a> <span class='hs-varid'>sendResponse'</span> <span class='hs-layout'>(</span><span class='hs-conid'>ResponseFile</span> <span class='hs-varid'>s</span> <span class='hs-varid'>hs</span> <span class='hs-varid'>fp</span> <span class='hs-varid'>mpart</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-375"></a> <span class='hs-layout'>(</span><span class='hs-varid'>lengthyHeaders</span><span class='hs-layout'>,</span> <span class='hs-varid'>cl</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'><-</span>
<a name="line-376"></a> <span class='hs-keyword'>case</span> <span class='hs-layout'>(</span><span class='hs-varid'>readInt</span> <span class='hs-varop'>`fmap`</span> <span class='hs-varid'>lookup</span> <span class='hs-str'>"content-length"</span> <span class='hs-varid'>hs</span><span class='hs-layout'>,</span> <span class='hs-varid'>mpart</span><span class='hs-layout'>)</span> <span class='hs-keyword'>of</span>
<a name="line-377"></a> <span class='hs-layout'>(</span><span class='hs-conid'>Just</span> <span class='hs-varid'>cl</span><span class='hs-layout'>,</span> <span class='hs-keyword'>_</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>hs</span><span class='hs-layout'>,</span> <span class='hs-varid'>cl</span><span class='hs-layout'>)</span>
<a name="line-378"></a> <span class='hs-layout'>(</span><span class='hs-conid'>Nothing</span><span class='hs-layout'>,</span> <span class='hs-conid'>Nothing</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-379"></a> <span class='hs-varid'>cl</span> <span class='hs-keyglyph'><-</span> <span class='hs-conid'>P</span><span class='hs-varop'>.</span><span class='hs-varid'>fileSize</span> <span class='hs-varop'>`fmap`</span> <span class='hs-conid'>P</span><span class='hs-varop'>.</span><span class='hs-varid'>getFileStatus</span> <span class='hs-varid'>fp</span>
<a name="line-380"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-varid'>addClToHeaders</span> <span class='hs-varid'>cl</span>
<a name="line-381"></a> <span class='hs-layout'>(</span><span class='hs-conid'>Nothing</span><span class='hs-layout'>,</span> <span class='hs-conid'>Just</span> <span class='hs-varid'>part</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-382"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>cl</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>filePartByteCount</span> <span class='hs-varid'>part</span>
<a name="line-383"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-varid'>addClToHeaders</span> <span class='hs-varid'>cl</span>
<a name="line-384"></a> <span class='hs-conid'>Sock</span><span class='hs-varop'>.</span><span class='hs-varid'>sendMany</span> <span class='hs-varid'>socket</span> <span class='hs-varop'>$</span> <span class='hs-conid'>L</span><span class='hs-varop'>.</span><span class='hs-varid'>toChunks</span> <span class='hs-varop'>$</span> <span class='hs-varid'>toLazyByteString</span> <span class='hs-varop'>$</span>
<a name="line-385"></a> <span class='hs-varid'>headers</span> <span class='hs-varid'>version</span> <span class='hs-varid'>s</span> <span class='hs-varid'>lengthyHeaders</span> <span class='hs-conid'>False</span>
<a name="line-386"></a>
<a name="line-387"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>not</span> <span class='hs-layout'>(</span><span class='hs-varid'>hasBody</span> <span class='hs-varid'>s</span> <span class='hs-varid'>req</span><span class='hs-layout'>)</span> <span class='hs-keyword'>then</span> <span class='hs-varid'>return</span> <span class='hs-varid'>isPersist</span> <span class='hs-keyword'>else</span> <span class='hs-keyword'>do</span>
<a name="line-388"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mpart</span> <span class='hs-keyword'>of</span>
<a name="line-389"></a> <span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>sendfile</span> <span class='hs-varid'>socket</span> <span class='hs-varid'>fp</span> <span class='hs-conid'>PartOfFile</span> <span class='hs-layout'>{</span>
<a name="line-390"></a> <span class='hs-varid'>rangeOffset</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>0</span>
<a name="line-391"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>rangeLength</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>cl</span>
<a name="line-392"></a> <span class='hs-layout'>}</span> <span class='hs-layout'>(</span><span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>tickle</span> <span class='hs-varid'>th</span><span class='hs-layout'>)</span>
<a name="line-393"></a> <span class='hs-conid'>Just</span> <span class='hs-varid'>part</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>sendfile</span> <span class='hs-varid'>socket</span> <span class='hs-varid'>fp</span> <span class='hs-conid'>PartOfFile</span> <span class='hs-layout'>{</span>
<a name="line-394"></a> <span class='hs-varid'>rangeOffset</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>filePartOffset</span> <span class='hs-varid'>part</span>
<a name="line-395"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>rangeLength</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>filePartByteCount</span> <span class='hs-varid'>part</span>
<a name="line-396"></a> <span class='hs-layout'>}</span> <span class='hs-layout'>(</span><span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>tickle</span> <span class='hs-varid'>th</span><span class='hs-layout'>)</span>
<a name="line-397"></a> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>tickle</span> <span class='hs-varid'>th</span>
<a name="line-398"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>isPersist</span>
<a name="line-399"></a> <span class='hs-keyword'>where</span>
<a name="line-400"></a> <span class='hs-varid'>addClToHeaders</span> <span class='hs-varid'>cl</span> <span class='hs-keyglyph'>=</span> <span class='hs-layout'>(</span><span class='hs-layout'>(</span><span class='hs-str'>"Content-Length"</span><span class='hs-layout'>,</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>pack</span> <span class='hs-varop'>$</span> <span class='hs-varid'>show</span> <span class='hs-varid'>cl</span><span class='hs-layout'>)</span><span class='hs-conop'>:</span><span class='hs-varid'>hs</span><span class='hs-layout'>,</span> <span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>cl</span><span class='hs-layout'>)</span>
<a name="line-401"></a>
<a name="line-402"></a> <span class='hs-varid'>sendResponse'</span> <span class='hs-layout'>(</span><span class='hs-conid'>ResponseBuilder</span> <span class='hs-varid'>s</span> <span class='hs-varid'>hs</span> <span class='hs-varid'>b</span><span class='hs-layout'>)</span>
<a name="line-403"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>hasBody</span> <span class='hs-varid'>s</span> <span class='hs-varid'>req</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-404"></a> <span class='hs-varid'>toByteStringIO</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>bs</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-405"></a> <span class='hs-conid'>Sock</span><span class='hs-varop'>.</span><span class='hs-varid'>sendAll</span> <span class='hs-varid'>socket</span> <span class='hs-varid'>bs</span>
<a name="line-406"></a> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>tickle</span> <span class='hs-varid'>th</span><span class='hs-layout'>)</span> <span class='hs-varid'>body</span>
<a name="line-407"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>isKeepAlive</span> <span class='hs-varid'>hs</span><span class='hs-layout'>)</span>
<a name="line-408"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-409"></a> <span class='hs-conid'>Sock</span><span class='hs-varop'>.</span><span class='hs-varid'>sendMany</span> <span class='hs-varid'>socket</span>
<a name="line-410"></a> <span class='hs-varop'>$</span> <span class='hs-conid'>L</span><span class='hs-varop'>.</span><span class='hs-varid'>toChunks</span>
<a name="line-411"></a> <span class='hs-varop'>$</span> <span class='hs-varid'>toLazyByteString</span>
<a name="line-412"></a> <span class='hs-varop'>$</span> <span class='hs-varid'>headers'</span> <span class='hs-conid'>False</span>
<a name="line-413"></a> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>tickle</span> <span class='hs-varid'>th</span>
<a name="line-414"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>isPersist</span>
<a name="line-415"></a> <span class='hs-keyword'>where</span>
<a name="line-416"></a> <span class='hs-varid'>headers'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>headers</span> <span class='hs-varid'>version</span> <span class='hs-varid'>s</span> <span class='hs-varid'>hs</span>
<a name="line-417"></a> <span class='hs-varid'>needsChunked'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>needsChunked</span> <span class='hs-varid'>hs</span>
<a name="line-418"></a> <span class='hs-varid'>body</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>if</span> <span class='hs-varid'>needsChunked'</span>
<a name="line-419"></a> <span class='hs-keyword'>then</span> <span class='hs-layout'>(</span><span class='hs-varid'>headers'</span> <span class='hs-varid'>needsChunked'</span><span class='hs-layout'>)</span>
<a name="line-420"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>chunkedTransferEncoding</span> <span class='hs-varid'>b</span>
<a name="line-421"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>chunkedTransferTerminator</span>
<a name="line-422"></a> <span class='hs-keyword'>else</span> <span class='hs-layout'>(</span><span class='hs-varid'>headers'</span> <span class='hs-conid'>False</span><span class='hs-layout'>)</span> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>b</span>
<a name="line-423"></a>
<a name="line-424"></a> <span class='hs-varid'>sendResponse'</span> <span class='hs-layout'>(</span><span class='hs-conid'>ResponseEnumerator</span> <span class='hs-varid'>res</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>res</span> <span class='hs-varid'>enumResponse</span>
<a name="line-425"></a> <span class='hs-keyword'>where</span>
<a name="line-426"></a> <span class='hs-varid'>enumResponse</span> <span class='hs-varid'>s</span> <span class='hs-varid'>hs</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>response</span> <span class='hs-conid'>True</span>
<a name="line-427"></a> <span class='hs-keyword'>where</span>
<a name="line-428"></a> <span class='hs-varid'>headers'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>headers</span> <span class='hs-varid'>version</span> <span class='hs-varid'>s</span> <span class='hs-varid'>hs</span>
<a name="line-429"></a> <span class='hs-comment'>-- FIXME perhaps alloca a buffer per thread and reuse that in all functiosn below. Should lessen greatly the GC burden (I hope)</span>
<a name="line-430"></a> <span class='hs-varid'>response</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>not</span> <span class='hs-layout'>(</span><span class='hs-varid'>hasBody</span> <span class='hs-varid'>s</span> <span class='hs-varid'>req</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-431"></a> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Sock</span><span class='hs-varop'>.</span><span class='hs-varid'>sendMany</span> <span class='hs-varid'>socket</span>
<a name="line-432"></a> <span class='hs-varop'>$</span> <span class='hs-conid'>L</span><span class='hs-varop'>.</span><span class='hs-varid'>toChunks</span> <span class='hs-varop'>$</span> <span class='hs-varid'>toLazyByteString</span>
<a name="line-433"></a> <span class='hs-varop'>$</span> <span class='hs-varid'>headers'</span> <span class='hs-conid'>False</span>
<a name="line-434"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>checkPersist</span> <span class='hs-varid'>req</span><span class='hs-layout'>)</span>
<a name="line-435"></a> <span class='hs-varid'>response</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>chunk'</span>
<a name="line-436"></a> <span class='hs-varop'>$</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>enumList</span> <span class='hs-num'>1</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>headers'</span> <span class='hs-varid'>needsChunked'</span><span class='hs-keyglyph'>]</span>
<a name="line-437"></a> <span class='hs-varop'>$$</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>joinI</span> <span class='hs-varop'>$</span> <span class='hs-varid'>builderToByteString</span> <span class='hs-comment'>-- FIXME unsafeBuilderToByteString</span>
<a name="line-438"></a> <span class='hs-varop'>$$</span> <span class='hs-layout'>(</span><span class='hs-varid'>iterSocket</span> <span class='hs-varid'>th</span> <span class='hs-varid'>socket</span> <span class='hs-varop'>>></span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>isKeepAlive</span> <span class='hs-varid'>hs</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-439"></a> <span class='hs-keyword'>where</span>
<a name="line-440"></a> <span class='hs-varid'>needsChunked'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>needsChunked</span> <span class='hs-varid'>hs</span>
<a name="line-441"></a> <span class='hs-varid'>chunk'</span> <span class='hs-varid'>i</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>if</span> <span class='hs-varid'>needsChunked'</span>
<a name="line-442"></a> <span class='hs-keyword'>then</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>joinI</span> <span class='hs-varop'>$</span> <span class='hs-varid'>chunk</span> <span class='hs-varop'>$$</span> <span class='hs-varid'>i</span>
<a name="line-443"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>i</span>
<a name="line-444"></a> <span class='hs-varid'>chunk</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Enumeratee</span> <span class='hs-conid'>Builder</span> <span class='hs-conid'>Builder</span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Bool</span>
<a name="line-445"></a> <span class='hs-varid'>chunk</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>checkDone</span> <span class='hs-varop'>$</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>continue</span> <span class='hs-varop'>.</span> <span class='hs-varid'>step</span>
<a name="line-446"></a> <span class='hs-varid'>step</span> <span class='hs-varid'>k</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>EOF</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>k</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>chunkedTransferTerminator</span><span class='hs-keyglyph'>]</span><span class='hs-layout'>)</span> <span class='hs-varop'>>>==</span> <span class='hs-varid'>return</span>
<a name="line-447"></a> <span class='hs-varid'>step</span> <span class='hs-varid'>k</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-conid'>[]</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>continue</span> <span class='hs-varop'>$</span> <span class='hs-varid'>step</span> <span class='hs-varid'>k</span>
<a name="line-448"></a> <span class='hs-varid'>step</span> <span class='hs-varid'>k</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>x</span><span class='hs-keyglyph'>]</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>k</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>chunkedTransferEncoding</span> <span class='hs-varid'>x</span><span class='hs-keyglyph'>]</span><span class='hs-layout'>)</span> <span class='hs-varop'>>>==</span> <span class='hs-varid'>chunk</span>
<a name="line-449"></a> <span class='hs-varid'>step</span> <span class='hs-varid'>k</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>k</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>chunkedTransferEncoding</span> <span class='hs-varop'>$</span> <span class='hs-varid'>mconcat</span> <span class='hs-varid'>xs</span><span class='hs-keyglyph'>]</span><span class='hs-layout'>)</span> <span class='hs-varop'>>>==</span> <span class='hs-varid'>chunk</span>
<a name="line-450"></a>
<a name="line-451"></a><a name="parseHeaderNoAttr"></a><span class='hs-definition'>parseHeaderNoAttr</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>ByteString</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>Header</span>
<a name="line-452"></a><span class='hs-definition'>parseHeaderNoAttr</span> <span class='hs-varid'>s</span> <span class='hs-keyglyph'>=</span>
<a name="line-453"></a> <span class='hs-keyword'>let</span> <span class='hs-layout'>(</span><span class='hs-varid'>k</span><span class='hs-layout'>,</span> <span class='hs-varid'>rest</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>breakByte</span> <span class='hs-num'>58</span> <span class='hs-varid'>s</span> <span class='hs-comment'>-- ':'</span>
<a name="line-454"></a> <span class='hs-varid'>restLen</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>length</span> <span class='hs-varid'>rest</span>
<a name="line-455"></a> <span class='hs-comment'>-- FIXME check for colon without following space?</span>
<a name="line-456"></a> <span class='hs-varid'>rest'</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>if</span> <span class='hs-varid'>restLen</span> <span class='hs-varop'>></span> <span class='hs-num'>1</span> <span class='hs-varop'>&&</span> <span class='hs-conid'>SU</span><span class='hs-varop'>.</span><span class='hs-varid'>unsafeTake</span> <span class='hs-num'>2</span> <span class='hs-varid'>rest</span> <span class='hs-varop'>==</span> <span class='hs-str'>": "</span>
<a name="line-457"></a> <span class='hs-keyword'>then</span> <span class='hs-conid'>SU</span><span class='hs-varop'>.</span><span class='hs-varid'>unsafeDrop</span> <span class='hs-num'>2</span> <span class='hs-varid'>rest</span>
<a name="line-458"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>rest</span>
<a name="line-459"></a> <span class='hs-keyword'>in</span> <span class='hs-layout'>(</span><span class='hs-conid'>CI</span><span class='hs-varop'>.</span><span class='hs-varid'>mk</span> <span class='hs-varid'>k</span><span class='hs-layout'>,</span> <span class='hs-varid'>rest'</span><span class='hs-layout'>)</span>
<a name="line-460"></a>
<a name="line-461"></a><a name="enumSocket"></a><span class='hs-definition'>enumSocket</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-conid'>Handle</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Socket</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Enumerator</span> <span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-varid'>a</span>
<a name="line-462"></a><span class='hs-definition'>enumSocket</span> <span class='hs-varid'>th</span> <span class='hs-varid'>len</span> <span class='hs-varid'>socket</span> <span class='hs-keyglyph'>=</span>
<a name="line-463"></a> <span class='hs-varid'>inner</span>
<a name="line-464"></a> <span class='hs-keyword'>where</span>
<a name="line-465"></a> <span class='hs-varid'>inner</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Continue</span> <span class='hs-varid'>k</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-466"></a> <span class='hs-varid'>bs</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Sock</span><span class='hs-varop'>.</span><span class='hs-varid'>recv</span> <span class='hs-varid'>socket</span> <span class='hs-varid'>len</span>
<a name="line-467"></a> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>tickle</span> <span class='hs-varid'>th</span>
<a name="line-468"></a> <span class='hs-keyword'>if</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>null</span> <span class='hs-varid'>bs</span>
<a name="line-469"></a> <span class='hs-keyword'>then</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>continue</span> <span class='hs-varid'>k</span>
<a name="line-470"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>k</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>bs</span><span class='hs-keyglyph'>]</span><span class='hs-layout'>)</span> <span class='hs-varop'>>>==</span> <span class='hs-varid'>inner</span>
<a name="line-471"></a> <span class='hs-varid'>inner</span> <span class='hs-varid'>step</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>returnI</span> <span class='hs-varid'>step</span>
<a name="line-472"></a><span class='hs-comment'>------ The functions below are not warp-specific and could be split out into a</span>
<a name="line-473"></a><span class='hs-comment'>--separate package.</span>
<a name="line-474"></a>
<a name="line-475"></a><a name="iterSocket"></a><span class='hs-definition'>iterSocket</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-conid'>Handle</span>
<a name="line-476"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Socket</span>
<a name="line-477"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Iteratee</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-478"></a><span class='hs-definition'>iterSocket</span> <span class='hs-varid'>th</span> <span class='hs-varid'>sock</span> <span class='hs-keyglyph'>=</span>
<a name="line-479"></a> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>continue</span> <span class='hs-varid'>step</span>
<a name="line-480"></a> <span class='hs-keyword'>where</span>
<a name="line-481"></a> <span class='hs-comment'>-- We pause timeouts before passing control back to user code. This ensures</span>
<a name="line-482"></a> <span class='hs-comment'>-- that a timeout will only ever be executed when Warp is in control. We</span>
<a name="line-483"></a> <span class='hs-comment'>-- also make sure to resume the timeout after the completion of user code</span>
<a name="line-484"></a> <span class='hs-comment'>-- so that we can kill idle connections.</span>
<a name="line-485"></a> <span class='hs-varid'>step</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>EOF</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>liftIO</span> <span class='hs-layout'>(</span><span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>resume</span> <span class='hs-varid'>th</span><span class='hs-layout'>)</span> <span class='hs-varop'>>></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>yield</span> <span class='hs-conid'>()</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>EOF</span>
<a name="line-486"></a> <span class='hs-varid'>step</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-conid'>[]</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>continue</span> <span class='hs-varid'>step</span>
<a name="line-487"></a> <span class='hs-varid'>step</span> <span class='hs-layout'>(</span><span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-488"></a> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>resume</span> <span class='hs-varid'>th</span>
<a name="line-489"></a> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>Sock</span><span class='hs-varop'>.</span><span class='hs-varid'>sendMany</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>xs</span>
<a name="line-490"></a> <span class='hs-varid'>liftIO</span> <span class='hs-varop'>$</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>pause</span> <span class='hs-varid'>th</span>
<a name="line-491"></a> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>continue</span> <span class='hs-varid'>step</span>
<a name="line-492"></a>
<a name="line-493"></a><a name="Settings"></a><span class='hs-comment'>-- | Various Warp server settings. This is purposely kept as an abstract data</span>
<a name="line-494"></a><a name="Settings"></a><span class='hs-comment'>-- type so that new settings can be added without breaking backwards</span>
<a name="line-495"></a><a name="Settings"></a><span class='hs-comment'>-- compatibility. In order to create a 'Settings' value, use 'defaultSettings'</span>
<a name="line-496"></a><a name="Settings"></a><span class='hs-comment'>-- and record syntax to modify individual records. For example:</span>
<a name="line-497"></a><a name="Settings"></a><span class='hs-comment'>--</span>
<a name="line-498"></a><a name="Settings"></a><span class='hs-comment'>-- > defaultSettings { settingsTimeout = 20 }</span>
<a name="line-499"></a><a name="Settings"></a><span class='hs-keyword'>data</span> <span class='hs-conid'>Settings</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Settings</span>
<a name="line-500"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>settingsPort</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span> <span class='hs-comment'>-- ^ Port to listen on. Default value: 3000</span>
<a name="line-501"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsHost</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>String</span> <span class='hs-comment'>-- ^ Host to bind to, or * for all. Default value: *</span>
<a name="line-502"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsOnException</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>SomeException</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span> <span class='hs-comment'>-- ^ 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.</span>
<a name="line-503"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsTimeout</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span> <span class='hs-comment'>-- ^ Timeout value in seconds. Default value: 30</span>
<a name="line-504"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsIntercept</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Request</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Maybe</span> <span class='hs-layout'>(</span><span class='hs-conid'>Socket</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Iteratee</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-505"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsManager</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Maybe</span> <span class='hs-conid'>Manager</span> <span class='hs-comment'>-- ^ Use an existing timeout manager instead of spawning a new one. If used, 'settingsTimeout' is ignored. Default is 'Nothing'</span>
<a name="line-506"></a> <span class='hs-layout'>}</span>
<a name="line-507"></a>
<a name="line-508"></a><a name="defaultSettings"></a><span class='hs-comment'>-- | The default settings for the Warp server. See the individual settings for</span>
<a name="line-509"></a><span class='hs-comment'>-- the default value.</span>
<a name="line-510"></a><span class='hs-definition'>defaultSettings</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Settings</span>
<a name="line-511"></a><span class='hs-definition'>defaultSettings</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Settings</span>
<a name="line-512"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>settingsPort</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>3000</span>
<a name="line-513"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsHost</span> <span class='hs-keyglyph'>=</span> <span class='hs-str'>"*"</span>
<a name="line-514"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsOnException</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>e</span> <span class='hs-keyglyph'>-></span>
<a name="line-515"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>fromException</span> <span class='hs-varid'>e</span> <span class='hs-keyword'>of</span>
<a name="line-516"></a> <span class='hs-conid'>Just</span> <span class='hs-varid'>x</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>go</span> <span class='hs-varid'>x</span>
<a name="line-517"></a> <span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span>
<a name="line-518"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>go'</span> <span class='hs-varop'>$</span> <span class='hs-varid'>fromException</span> <span class='hs-varid'>e</span>
<a name="line-519"></a> <span class='hs-keyword'>then</span> <span class='hs-varid'>hPutStrLn</span> <span class='hs-varid'>stderr</span> <span class='hs-varop'>$</span> <span class='hs-varid'>show</span> <span class='hs-varid'>e</span>
<a name="line-520"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-521"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsTimeout</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>30</span>
<a name="line-522"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsIntercept</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>const</span> <span class='hs-conid'>Nothing</span>
<a name="line-523"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>settingsManager</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Nothing</span>
<a name="line-524"></a> <span class='hs-layout'>}</span>
<a name="line-525"></a> <span class='hs-keyword'>where</span>
<a name="line-526"></a> <span class='hs-varid'>go</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>InvalidRequest</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-527"></a> <span class='hs-varid'>go</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-528"></a> <span class='hs-varid'>go'</span> <span class='hs-layout'>(</span><span class='hs-conid'>Just</span> <span class='hs-conid'>ThreadKilled</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>False</span>
<a name="line-529"></a> <span class='hs-varid'>go'</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>True</span>
<a name="line-530"></a>
<a name="line-531"></a><a name="takeHeaders"></a><span class='hs-definition'>takeHeaders</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Iteratee</span> <span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span>
<a name="line-532"></a><span class='hs-definition'>takeHeaders</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-533"></a> <span class='hs-varop'>!</span><span class='hs-varid'>x</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>forceHead</span> <span class='hs-conid'>ConnectionClosedByPeer</span>
<a name="line-534"></a> <span class='hs-varid'>takeHeaders'</span> <span class='hs-num'>0</span> <span class='hs-varid'>id</span> <span class='hs-varid'>id</span> <span class='hs-varid'>x</span>
<a name="line-535"></a>
<a name="line-536"></a><span class='hs-comment'>{-# INLINE takeHeaders #-}</span>
<a name="line-537"></a>
<a name="line-538"></a><a name="takeHeaders'"></a><span class='hs-definition'>takeHeaders'</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span>
<a name="line-539"></a> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span><span class='hs-layout'>)</span>
<a name="line-540"></a> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span><span class='hs-layout'>)</span>
<a name="line-541"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ByteString</span>
<a name="line-542"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Iteratee</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span>
<a name="line-543"></a><span class='hs-definition'>takeHeaders'</span> <span class='hs-varop'>!</span><span class='hs-varid'>len</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>len</span> <span class='hs-varop'>></span> <span class='hs-varid'>maxTotalHeaderLength</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>throwError</span> <span class='hs-conid'>OverLargeHeader</span>
<a name="line-544"></a><span class='hs-definition'>takeHeaders'</span> <span class='hs-varop'>!</span><span class='hs-varid'>len</span> <span class='hs-varop'>!</span><span class='hs-varid'>lines</span> <span class='hs-varop'>!</span><span class='hs-varid'>prepend</span> <span class='hs-varop'>!</span><span class='hs-varid'>bs</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-545"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>bsLen</span> <span class='hs-keyglyph'>=</span> <span class='hs-comment'>{-# SCC "takeHeaders'.bsLen" #-}</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>length</span> <span class='hs-varid'>bs</span>
<a name="line-546"></a> <span class='hs-varop'>!</span><span class='hs-varid'>mnl</span> <span class='hs-keyglyph'>=</span> <span class='hs-comment'>{-# SCC "takeHeaders'.mnl" #-}</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>elemIndex</span> <span class='hs-num'>10</span> <span class='hs-varid'>bs</span>
<a name="line-547"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mnl</span> <span class='hs-keyword'>of</span>
<a name="line-548"></a> <span class='hs-comment'>-- no newline. prepend entire bs to next line</span>
<a name="line-549"></a> <span class='hs-varop'>!</span><span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span> <span class='hs-comment'>{-# SCC "takeHeaders'.noNewline" #-}</span> <span class='hs-keyword'>do</span>
<a name="line-550"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>len'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>len</span> <span class='hs-varop'>+</span> <span class='hs-varid'>bsLen</span>
<a name="line-551"></a> <span class='hs-varop'>!</span><span class='hs-varid'>more</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>forceHead</span> <span class='hs-conid'>IncompleteHeaders</span>
<a name="line-552"></a> <span class='hs-varid'>takeHeaders'</span> <span class='hs-varid'>len'</span> <span class='hs-varid'>lines</span> <span class='hs-layout'>(</span><span class='hs-varid'>prepend</span> <span class='hs-varop'>.</span> <span class='hs-layout'>(</span><span class='hs-conop'>:</span><span class='hs-layout'>)</span> <span class='hs-varid'>bs</span><span class='hs-layout'>)</span> <span class='hs-varid'>more</span>
<a name="line-553"></a> <span class='hs-conid'>Just</span> <span class='hs-varop'>!</span><span class='hs-varid'>nl</span> <span class='hs-keyglyph'>-></span> <span class='hs-comment'>{-# SCC "takeHeaders'.newline" #-}</span> <span class='hs-keyword'>do</span>
<a name="line-554"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>end</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>nl</span>
<a name="line-555"></a> <span class='hs-varop'>!</span><span class='hs-varid'>start</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>nl</span> <span class='hs-varop'>+</span> <span class='hs-num'>1</span>
<a name="line-556"></a> <span class='hs-varop'>!</span><span class='hs-varid'>line</span> <span class='hs-keyglyph'>=</span> <span class='hs-comment'>{-# SCC "takeHeaders'.line" #-}</span>
<a name="line-557"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>end</span> <span class='hs-varop'>></span> <span class='hs-num'>0</span>
<a name="line-558"></a> <span class='hs-comment'>-- line data included in this chunk</span>
<a name="line-559"></a> <span class='hs-keyword'>then</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>concat</span> <span class='hs-varop'>$!</span> <span class='hs-varid'>prepend</span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>SU</span><span class='hs-varop'>.</span><span class='hs-varid'>unsafeTake</span> <span class='hs-layout'>(</span><span class='hs-varid'>checkCR</span> <span class='hs-varid'>bs</span> <span class='hs-varid'>end</span><span class='hs-layout'>)</span> <span class='hs-varid'>bs</span><span class='hs-keyglyph'>]</span>
<a name="line-560"></a> <span class='hs-comment'>--then S.concat $! prepend [SU.unsafeTake (end-1) bs]</span>
<a name="line-561"></a> <span class='hs-comment'>-- no line data in this chunk (all in prepend, or empty line)</span>
<a name="line-562"></a> <span class='hs-keyword'>else</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>concat</span> <span class='hs-varop'>$!</span> <span class='hs-varid'>prepend</span> <span class='hs-conid'>[]</span>
<a name="line-563"></a> <span class='hs-keyword'>if</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>null</span> <span class='hs-varid'>line</span>
<a name="line-564"></a> <span class='hs-comment'>-- no more headers</span>
<a name="line-565"></a> <span class='hs-keyword'>then</span> <span class='hs-comment'>{-# SCC "takeHeaders'.noMoreHeaders" #-}</span> <span class='hs-keyword'>do</span>
<a name="line-566"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>lines'</span> <span class='hs-keyglyph'>=</span> <span class='hs-comment'>{-# SCC "takeHeaders'.noMoreHeaders.lines'" #-}</span> <span class='hs-varid'>lines</span> <span class='hs-conid'>[]</span>
<a name="line-567"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>start</span> <span class='hs-varop'><</span> <span class='hs-varid'>bsLen</span>
<a name="line-568"></a> <span class='hs-keyword'>then</span> <span class='hs-comment'>{-# SCC "takeHeaders'.noMoreHeaders.yield" #-}</span> <span class='hs-keyword'>do</span>
<a name="line-569"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>rest</span> <span class='hs-keyglyph'>=</span> <span class='hs-comment'>{-# SCC "takeHeaders'.noMoreHeaders.yield.rest" #-}</span> <span class='hs-conid'>SU</span><span class='hs-varop'>.</span><span class='hs-varid'>unsafeDrop</span> <span class='hs-varid'>start</span> <span class='hs-varid'>bs</span>
<a name="line-570"></a> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>yield</span> <span class='hs-varid'>lines'</span> <span class='hs-varop'>$!</span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Chunks</span> <span class='hs-keyglyph'>[</span><span class='hs-varid'>rest</span><span class='hs-keyglyph'>]</span>
<a name="line-571"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>return</span> <span class='hs-varid'>lines'</span>
<a name="line-572"></a>
<a name="line-573"></a> <span class='hs-comment'>-- more headers</span>
<a name="line-574"></a> <span class='hs-keyword'>else</span> <span class='hs-comment'>{-# SCC "takeHeaders'.moreHeaders" #-}</span> <span class='hs-keyword'>do</span>
<a name="line-575"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>len'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>len</span> <span class='hs-varop'>+</span> <span class='hs-varid'>start</span>
<a name="line-576"></a> <span class='hs-varop'>!</span><span class='hs-varid'>lines'</span> <span class='hs-keyglyph'>=</span> <span class='hs-comment'>{-# SCC "takeHeaders.lines'" #-}</span> <span class='hs-varid'>lines</span> <span class='hs-varop'>.</span> <span class='hs-layout'>(</span><span class='hs-conop'>:</span><span class='hs-layout'>)</span> <span class='hs-varid'>line</span>
<a name="line-577"></a> <span class='hs-varop'>!</span><span class='hs-varid'>more</span> <span class='hs-keyglyph'><-</span> <span class='hs-comment'>{-# SCC "takeHeaders'.more" #-}</span>
<a name="line-578"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>start</span> <span class='hs-varop'><</span> <span class='hs-varid'>bsLen</span>
<a name="line-579"></a> <span class='hs-keyword'>then</span> <span class='hs-varid'>return</span> <span class='hs-varop'>$!</span> <span class='hs-conid'>SU</span><span class='hs-varop'>.</span><span class='hs-varid'>unsafeDrop</span> <span class='hs-varid'>start</span> <span class='hs-varid'>bs</span>
<a name="line-580"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>forceHead</span> <span class='hs-conid'>IncompleteHeaders</span>
<a name="line-581"></a> <span class='hs-comment'>{-# SCC "takeHeaders'.takeMore" #-}</span> <span class='hs-varid'>takeHeaders'</span> <span class='hs-varid'>len'</span> <span class='hs-varid'>lines'</span> <span class='hs-varid'>id</span> <span class='hs-varid'>more</span>
<a name="line-582"></a><span class='hs-comment'>{-# INLINE takeHeaders' #-}</span>
<a name="line-583"></a>
<a name="line-584"></a><a name="forceHead"></a><span class='hs-definition'>forceHead</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>InvalidRequest</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-conid'>Iteratee</span> <span class='hs-conid'>ByteString</span> <span class='hs-conid'>IO</span> <span class='hs-conid'>ByteString</span>
<a name="line-585"></a><span class='hs-definition'>forceHead</span> <span class='hs-varid'>err</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-586"></a> <span class='hs-varop'>!</span><span class='hs-varid'>mx</span> <span class='hs-keyglyph'><-</span> <span class='hs-conid'>EL</span><span class='hs-varop'>.</span><span class='hs-varid'>head</span>
<a name="line-587"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>mx</span> <span class='hs-keyword'>of</span>
<a name="line-588"></a> <span class='hs-varop'>!</span><span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>E</span><span class='hs-varop'>.</span><span class='hs-varid'>throwError</span> <span class='hs-varid'>err</span>
<a name="line-589"></a> <span class='hs-conid'>Just</span> <span class='hs-varop'>!</span><span class='hs-varid'>x</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>x</span>
<a name="line-590"></a><span class='hs-comment'>{-# INLINE forceHead #-}</span>
<a name="line-591"></a>
<a name="line-592"></a><a name="checkCR"></a><span class='hs-definition'>checkCR</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>ByteString</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span>
<a name="line-593"></a><span class='hs-definition'>checkCR</span> <span class='hs-varid'>bs</span> <span class='hs-varid'>pos</span> <span class='hs-keyglyph'>=</span>
<a name="line-594"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>p</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>pos</span> <span class='hs-comment'>-</span> <span class='hs-num'>1</span>
<a name="line-595"></a> <span class='hs-keyword'>in</span> <span class='hs-keyword'>if</span> <span class='hs-chr'>'\r'</span> <span class='hs-varop'>==</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>index</span> <span class='hs-varid'>bs</span> <span class='hs-varid'>p</span>
<a name="line-596"></a> <span class='hs-keyword'>then</span> <span class='hs-varid'>p</span>
<a name="line-597"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>pos</span>
<a name="line-598"></a><span class='hs-comment'>{-# INLINE checkCR #-}</span>
<a name="line-599"></a>
<a name="line-600"></a><a name="readInt"></a><span class='hs-comment'>-- Note: This function produces garbage on invalid input. But serving an</span>
<a name="line-601"></a><span class='hs-comment'>-- invalid content-length is a bad idea, mkay?</span>
<a name="line-602"></a><span class='hs-definition'>readInt</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Integer</span>
<a name="line-603"></a><span class='hs-definition'>readInt</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>foldl'</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>x</span> <span class='hs-varid'>w</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>x</span> <span class='hs-varop'>*</span> <span class='hs-num'>10</span> <span class='hs-varop'>+</span> <span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>w</span> <span class='hs-comment'>-</span> <span class='hs-num'>48</span><span class='hs-layout'>)</span> <span class='hs-num'>0</span>
<a name="line-604"></a>
<a name="line-605"></a><a name="withManager"></a><span class='hs-comment'>-- | Call the inner function with a timeout manager.</span>
<a name="line-606"></a><span class='hs-definition'>withManager</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span> <span class='hs-comment'>-- ^ timeout in microseconds</span>
<a name="line-607"></a> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-conid'>Manager</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-608"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-varid'>a</span>
<a name="line-609"></a><span class='hs-definition'>withManager</span> <span class='hs-varid'>timeout</span> <span class='hs-varid'>f</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-610"></a> <span class='hs-comment'>-- FIXME when stopManager is available, use it</span>
<a name="line-611"></a> <span class='hs-varid'>man</span> <span class='hs-keyglyph'><-</span> <span class='hs-conid'>T</span><span class='hs-varop'>.</span><span class='hs-varid'>initialize</span> <span class='hs-varid'>timeout</span>
<a name="line-612"></a> <span class='hs-varid'>f</span> <span class='hs-varid'>man</span>
<a name="line-613"></a>
<a name="line-614"></a><a name="serverHeader"></a><span class='hs-definition'>serverHeader</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>RequestHeaders</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>H</span><span class='hs-varop'>.</span><span class='hs-conid'>RequestHeaders</span>
<a name="line-615"></a><span class='hs-definition'>serverHeader</span> <span class='hs-varid'>hdrs</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>case</span> <span class='hs-varid'>lookup</span> <span class='hs-varid'>key</span> <span class='hs-varid'>hdrs</span> <span class='hs-keyword'>of</span>
<a name="line-616"></a> <span class='hs-conid'>Nothing</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>server</span> <span class='hs-conop'>:</span> <span class='hs-varid'>hdrs</span>
<a name="line-617"></a> <span class='hs-conid'>Just</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>hdrs</span>
<a name="line-618"></a> <span class='hs-keyword'>where</span>
<a name="line-619"></a> <span class='hs-varid'>key</span> <span class='hs-keyglyph'>=</span> <span class='hs-str'>"Server"</span>
<a name="line-620"></a> <span class='hs-varid'>ver</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>pack</span> <span class='hs-varop'>$</span> <span class='hs-str'>"Warp/"</span> <span class='hs-varop'>++</span> <span class='hs-varid'>warpVersion</span>
<a name="line-621"></a> <span class='hs-varid'>server</span> <span class='hs-keyglyph'>=</span> <span class='hs-layout'>(</span><span class='hs-varid'>key</span><span class='hs-layout'>,</span> <span class='hs-varid'>ver</span><span class='hs-layout'>)</span>
</pre></body>
</html>
