<?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>Blaze/ByteString/Builder/HTTP.hs</title>
<link type='text/css' rel='stylesheet' href='hscolour.css' />
</head>
<body>
<pre><a name="line-1"></a><span class='hs-comment'>{-# LANGUAGE BangPatterns, CPP, MagicHash, OverloadedStrings, MonoPatBinds #-}</span>
<a name="line-2"></a><span class='hs-comment'>-- | Support for HTTP response encoding.</span>
<a name="line-3"></a><span class='hs-comment'>--</span>
<a name="line-4"></a><span class='hs-comment'>-- TODO: Improve documentation.</span>
<a name="line-5"></a><span class='hs-keyword'>module</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> <span class='hs-layout'>(</span>
<a name="line-6"></a> <span class='hs-comment'>-- * Chunked HTTP transfer encoding</span>
<a name="line-7"></a> <span class='hs-varid'>chunkedTransferEncoding</span>
<a name="line-8"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>chunkedTransferTerminator</span>
<a name="line-9"></a> <span class='hs-layout'>)</span> <span class='hs-keyword'>where</span>
<a name="line-10"></a>
<a name="line-11"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Monoid</span>
<a name="line-12"></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-13"></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-varop'>.</span><span class='hs-conid'>Char8</span> <span class='hs-conid'>()</span>
<a name="line-14"></a>
<a name="line-15"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Foreign</span>
<a name="line-16"></a>
<a name="line-17"></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'>Internal</span>
<a name="line-18"></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'>Internal</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span>
<a name="line-19"></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'>Internal</span><span class='hs-varop'>.</span><span class='hs-conid'>UncheckedShifts</span>
<a name="line-20"></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'>ByteString</span> <span class='hs-layout'>(</span><span class='hs-varid'>copyByteString</span><span class='hs-layout'>)</span>
<a name="line-21"></a>
<a name="line-22"></a><span class='hs-keyword'>import</span> <span class='hs-keyword'>qualified</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-keyword'>as</span> <span class='hs-conid'>Char8</span>
<a name="line-23"></a>
<a name="line-24"></a><span class='hs-comment'>-- only required by test-code</span>
<a name="line-25"></a><span class='hs-comment'>-- import qualified Data.ByteString.Lazy as L</span>
<a name="line-26"></a><span class='hs-comment'>-- import qualified Blaze.ByteString.Builder.ByteString as B</span>
<a name="line-27"></a><span class='hs-comment'>-- import Data.ByteString.Char8 ()</span>
<a name="line-28"></a>
<a name="line-29"></a>
<a name="line-30"></a><a name="writeCRLF"></a><span class='hs-comment'>-- | Write a CRLF sequence.</span>
<a name="line-31"></a><span class='hs-definition'>writeCRLF</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Write</span>
<a name="line-32"></a><span class='hs-definition'>writeCRLF</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Char8</span><span class='hs-varop'>.</span><span class='hs-varid'>writeChar</span> <span class='hs-chr'>'\r'</span> <span class='hs-varop'>`mappend`</span> <span class='hs-conid'>Char8</span><span class='hs-varop'>.</span><span class='hs-varid'>writeChar</span> <span class='hs-chr'>'\n'</span>
<a name="line-33"></a><span class='hs-comment'>{-# INLINE writeCRLF #-}</span>
<a name="line-34"></a>
<a name="line-35"></a><a name="execWrite"></a><span class='hs-comment'>-- | Execute a write</span>
<a name="line-36"></a><span class='hs-comment'>{-# INLINE execWrite #-}</span>
<a name="line-37"></a><span class='hs-definition'>execWrite</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Write</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Ptr</span> <span class='hs-conid'>Word8</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-38"></a><span class='hs-definition'>execWrite</span> <span class='hs-varid'>w</span> <span class='hs-varid'>op</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-39"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>runWriteIO</span> <span class='hs-layout'>(</span><span class='hs-varid'>runWrite</span> <span class='hs-varid'>w</span><span class='hs-layout'>)</span> <span class='hs-varid'>op</span>
<a name="line-40"></a> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-41"></a>
<a name="line-42"></a>
<a name="line-43"></a><span class='hs-comment'>------------------------------------------------------------------------------</span>
<a name="line-44"></a><span class='hs-comment'>-- Hex Encoding Infrastructure</span>
<a name="line-45"></a><span class='hs-comment'>------------------------------------------------------------------------------</span>
<a name="line-46"></a>
<a name="line-47"></a><span class='hs-comment'>{-
<a name="line-48"></a>pokeWord16Hex :: Word16 -> Ptr Word8 -> IO ()
<a name="line-49"></a>pokeWord16Hex x op = do
<a name="line-50"></a> pokeNibble 0 12
<a name="line-51"></a> pokeNibble 1 8
<a name="line-52"></a> pokeNibble 2 4
<a name="line-53"></a> pokeNibble 3 0
<a name="line-54"></a> where
<a name="line-55"></a> pokeNibble off s
<a name="line-56"></a> | n < 10 = pokeWord8 off (fromIntegral $ 48 + n)
<a name="line-57"></a> | otherwise = pokeWord8 off (fromIntegral $ 55 + n)
<a name="line-58"></a> where
<a name="line-59"></a> n = shiftr_w16 x s .&. 0xF
<a name="line-60"></a>
<a name="line-61"></a> pokeWord8 :: Int -> Word8 -> IO ()
<a name="line-62"></a> pokeWord8 off = poke (op `plusPtr` off)
<a name="line-63"></a>
<a name="line-64"></a>writeWord16Hex :: Word16 -> Write
<a name="line-65"></a>writeWord16Hex = exactWrite 4 . pokeWord16Hex
<a name="line-66"></a>
<a name="line-67"></a>-}</span>
<a name="line-68"></a>
<a name="line-69"></a><a name="pokeWord32HexN"></a><span class='hs-definition'>pokeWord32HexN</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Word32</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Ptr</span> <span class='hs-conid'>Word8</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-70"></a><span class='hs-definition'>pokeWord32HexN</span> <span class='hs-varid'>n0</span> <span class='hs-varid'>w0</span> <span class='hs-varid'>op0</span> <span class='hs-keyglyph'>=</span>
<a name="line-71"></a> <span class='hs-varid'>go</span> <span class='hs-varid'>w0</span> <span class='hs-layout'>(</span><span class='hs-varid'>op0</span> <span class='hs-varop'>`plusPtr`</span> <span class='hs-layout'>(</span><span class='hs-varid'>n0</span> <span class='hs-comment'>-</span> <span class='hs-num'>1</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-72"></a> <span class='hs-keyword'>where</span>
<a name="line-73"></a> <span class='hs-varid'>go</span> <span class='hs-varop'>!</span><span class='hs-varid'>w</span> <span class='hs-varop'>!</span><span class='hs-varid'>op</span>
<a name="line-74"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>op</span> <span class='hs-varop'><</span> <span class='hs-varid'>op0</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-75"></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-76"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>nibble</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Word8</span>
<a name="line-77"></a> <span class='hs-varid'>nibble</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>w</span> <span class='hs-varop'>.&.</span> <span class='hs-num'>0xF</span>
<a name="line-78"></a> <span class='hs-varid'>hex</span> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>nibble</span> <span class='hs-varop'><</span> <span class='hs-num'>10</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>48</span> <span class='hs-varop'>+</span> <span class='hs-varid'>nibble</span>
<a name="line-79"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>55</span> <span class='hs-varop'>+</span> <span class='hs-varid'>nibble</span>
<a name="line-80"></a> <span class='hs-varid'>poke</span> <span class='hs-varid'>op</span> <span class='hs-varid'>hex</span>
<a name="line-81"></a> <span class='hs-varid'>go</span> <span class='hs-layout'>(</span><span class='hs-varid'>w</span> <span class='hs-varop'>`shiftr_w32`</span> <span class='hs-num'>4</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>op</span> <span class='hs-varop'>`plusPtr`</span> <span class='hs-layout'>(</span><span class='hs-comment'>-</span><span class='hs-num'>1</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-82"></a><span class='hs-comment'>{-# INLINE pokeWord32HexN #-}</span>
<a name="line-83"></a>
<a name="line-84"></a><a name="iterationsUntilZero"></a><span class='hs-definition'>iterationsUntilZero</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Integral</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=></span> <span class='hs-layout'>(</span><span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span>
<a name="line-85"></a><span class='hs-definition'>iterationsUntilZero</span> <span class='hs-varid'>f</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>go</span> <span class='hs-num'>0</span>
<a name="line-86"></a> <span class='hs-keyword'>where</span>
<a name="line-87"></a> <span class='hs-varid'>go</span> <span class='hs-varop'>!</span><span class='hs-varid'>count</span> <span class='hs-num'>0</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>count</span>
<a name="line-88"></a> <span class='hs-varid'>go</span> <span class='hs-varop'>!</span><span class='hs-varid'>count</span> <span class='hs-varop'>!</span><span class='hs-varid'>x</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>go</span> <span class='hs-layout'>(</span><span class='hs-varid'>count</span><span class='hs-varop'>+</span><span class='hs-num'>1</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>f</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-89"></a><span class='hs-comment'>{-# INLINE iterationsUntilZero #-}</span>
<a name="line-90"></a>
<a name="line-91"></a><a name="word32HexLength"></a><span class='hs-comment'>-- | Length of the hex-string required to encode the given 'Word32'.</span>
<a name="line-92"></a><span class='hs-definition'>word32HexLength</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Word32</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span>
<a name="line-93"></a><span class='hs-definition'>word32HexLength</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>max</span> <span class='hs-num'>1</span> <span class='hs-varop'>.</span> <span class='hs-varid'>iterationsUntilZero</span> <span class='hs-layout'>(</span><span class='hs-varop'>`shiftr_w32`</span> <span class='hs-num'>4</span><span class='hs-layout'>)</span>
<a name="line-94"></a><span class='hs-comment'>{-# INLINE word32HexLength #-}</span>
<a name="line-95"></a>
<a name="line-96"></a><a name="writeWord32Hex"></a><span class='hs-definition'>writeWord32Hex</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Word32</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Write</span>
<a name="line-97"></a><span class='hs-definition'>writeWord32Hex</span> <span class='hs-varid'>w</span> <span class='hs-keyglyph'>=</span>
<a name="line-98"></a> <span class='hs-varid'>boundedWrite</span> <span class='hs-layout'>(</span><span class='hs-num'>2</span> <span class='hs-varop'>*</span> <span class='hs-varid'>sizeOf</span> <span class='hs-varid'>w</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>writeN</span> <span class='hs-varid'>len</span> <span class='hs-varop'>$</span> <span class='hs-varid'>pokeWord32HexN</span> <span class='hs-varid'>len</span> <span class='hs-varid'>w</span><span class='hs-layout'>)</span>
<a name="line-99"></a> <span class='hs-keyword'>where</span>
<a name="line-100"></a> <span class='hs-varid'>len</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>word32HexLength</span> <span class='hs-varid'>w</span>
<a name="line-101"></a><span class='hs-comment'>{-# INLINE writeWord32Hex #-}</span>
<a name="line-102"></a>
<a name="line-103"></a><span class='hs-comment'>{-
<a name="line-104"></a>test = flip (toLazyByteStringWith 32 32 32) L.empty
<a name="line-105"></a> $ chunkedTransferEncoding
<a name="line-106"></a> $ mconcat $ map oneLine [0..16] ++
<a name="line-107"></a> [B.insertByteString "hello"] ++
<a name="line-108"></a> map oneLine [0,1] ++
<a name="line-109"></a> [B.insertByteString ""] ++
<a name="line-110"></a> map oneLine [0..16]
<a name="line-111"></a>
<a name="line-112"></a> where
<a name="line-113"></a> oneLine x = fromWriteSingleton writeWord32Hex x `mappend` Char8.fromChar ' '
<a name="line-114"></a>
<a name="line-115"></a>test = print $ toLazyByteString
<a name="line-116"></a> $ chunkedTransferEncoding body `mappend` chunkedTransferTerminator
<a name="line-117"></a>
<a name="line-118"></a>body = copyByteString "maa" `mappend` copyByteString "foo" `mappend` copyByteString "bar"
<a name="line-119"></a>-}</span>
<a name="line-120"></a>
<a name="line-121"></a><span class='hs-comment'>------------------------------------------------------------------------------</span>
<a name="line-122"></a><span class='hs-comment'>-- Chunked transfer encoding</span>
<a name="line-123"></a><span class='hs-comment'>------------------------------------------------------------------------------</span>
<a name="line-124"></a>
<a name="line-125"></a><a name="chunkedTransferEncoding"></a><span class='hs-comment'>-- | Transform a builder such that it uses chunked HTTP transfer encoding.</span>
<a name="line-126"></a><span class='hs-definition'>chunkedTransferEncoding</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Builder</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Builder</span>
<a name="line-127"></a><span class='hs-definition'>chunkedTransferEncoding</span> <span class='hs-layout'>(</span><span class='hs-conid'>Builder</span> <span class='hs-varid'>b</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span>
<a name="line-128"></a> <span class='hs-varid'>fromBuildStepCont</span> <span class='hs-varid'>transferEncodingStep</span>
<a name="line-129"></a> <span class='hs-keyword'>where</span>
<a name="line-130"></a> <span class='hs-varid'>finalStep</span> <span class='hs-varop'>!</span><span class='hs-layout'>(</span><span class='hs-conid'>BufRange</span> <span class='hs-varid'>op</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-varop'>$</span> <span class='hs-conid'>Done</span> <span class='hs-varid'>op</span> <span class='hs-conid'>()</span>
<a name="line-131"></a>
<a name="line-132"></a> <span class='hs-varid'>transferEncodingStep</span> <span class='hs-varid'>k</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>go</span> <span class='hs-layout'>(</span><span class='hs-varid'>b</span> <span class='hs-layout'>(</span><span class='hs-varid'>buildStep</span> <span class='hs-varid'>finalStep</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-133"></a> <span class='hs-keyword'>where</span>
<a name="line-134"></a> <span class='hs-varid'>go</span> <span class='hs-varid'>innerStep</span> <span class='hs-varop'>!</span><span class='hs-layout'>(</span><span class='hs-conid'>BufRange</span> <span class='hs-varid'>op</span> <span class='hs-varid'>ope</span><span class='hs-layout'>)</span>
<a name="line-135"></a> <span class='hs-comment'>-- FIXME: Assert that outRemaining < maxBound :: Word32</span>
<a name="line-136"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>outRemaining</span> <span class='hs-varop'><</span> <span class='hs-varid'>minimalBufferSize</span> <span class='hs-keyglyph'>=</span>
<a name="line-137"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$</span> <span class='hs-varid'>bufferFull</span> <span class='hs-varid'>minimalBufferSize</span> <span class='hs-varid'>op</span> <span class='hs-layout'>(</span><span class='hs-varid'>go</span> <span class='hs-varid'>innerStep</span><span class='hs-layout'>)</span>
<a name="line-138"></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-139"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>brInner</span><span class='hs-keyglyph'>@</span><span class='hs-layout'>(</span><span class='hs-conid'>BufRange</span> <span class='hs-varid'>opInner</span> <span class='hs-keyword'>_</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>BufRange</span>
<a name="line-140"></a> <span class='hs-layout'>(</span><span class='hs-varid'>op</span> <span class='hs-varop'>`plusPtr`</span> <span class='hs-layout'>(</span><span class='hs-varid'>chunkSizeLength</span> <span class='hs-varop'>+</span> <span class='hs-num'>2</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span> <span class='hs-comment'>-- leave space for chunk header</span>
<a name="line-141"></a> <span class='hs-layout'>(</span><span class='hs-varid'>ope</span> <span class='hs-varop'>`plusPtr`</span> <span class='hs-layout'>(</span><span class='hs-comment'>-</span><span class='hs-varid'>maxAfterBufferOverhead</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span> <span class='hs-comment'>-- leave space at end of data</span>
<a name="line-142"></a>
<a name="line-143"></a> <span class='hs-comment'>-- wraps the chunk, if it is non-empty, and returns the</span>
<a name="line-144"></a> <span class='hs-comment'>-- signal constructed with the correct end-of-data pointer</span>
<a name="line-145"></a> <span class='hs-comment'>{-# INLINE wrapChunk #-}</span>
<a name="line-146"></a> <span class='hs-varid'>wrapChunk</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Ptr</span> <span class='hs-conid'>Word8</span> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-conid'>Ptr</span> <span class='hs-conid'>Word8</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>BuildSignal</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-147"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>BuildSignal</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-148"></a> <span class='hs-varid'>wrapChunk</span> <span class='hs-varop'>!</span><span class='hs-varid'>opInner'</span> <span class='hs-varid'>mkSignal</span>
<a name="line-149"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>opInner'</span> <span class='hs-varop'>==</span> <span class='hs-varid'>opInner</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>mkSignal</span> <span class='hs-varid'>op</span>
<a name="line-150"></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-151"></a> <span class='hs-varid'>pokeWord32HexN</span> <span class='hs-varid'>chunkSizeLength</span>
<a name="line-152"></a> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-varop'>$</span> <span class='hs-varid'>opInner'</span> <span class='hs-varop'>`minusPtr`</span> <span class='hs-varid'>opInner</span><span class='hs-layout'>)</span>
<a name="line-153"></a> <span class='hs-varid'>op</span>
<a name="line-154"></a> <span class='hs-varid'>execWrite</span> <span class='hs-varid'>writeCRLF</span> <span class='hs-layout'>(</span><span class='hs-varid'>opInner</span> <span class='hs-varop'>`plusPtr`</span> <span class='hs-layout'>(</span><span class='hs-comment'>-</span><span class='hs-num'>2</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-155"></a> <span class='hs-varid'>execWrite</span> <span class='hs-varid'>writeCRLF</span> <span class='hs-varid'>opInner'</span>
<a name="line-156"></a> <span class='hs-varid'>mkSignal</span> <span class='hs-layout'>(</span><span class='hs-varid'>opInner'</span> <span class='hs-varop'>`plusPtr`</span> <span class='hs-num'>2</span><span class='hs-layout'>)</span>
<a name="line-157"></a>
<a name="line-158"></a> <span class='hs-comment'>-- execute inner builder with reduced boundaries</span>
<a name="line-159"></a> <span class='hs-varid'>signal</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>runBuildStep</span> <span class='hs-varid'>innerStep</span> <span class='hs-varid'>brInner</span>
<a name="line-160"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>signal</span> <span class='hs-keyword'>of</span>
<a name="line-161"></a> <span class='hs-conid'>Done</span> <span class='hs-varid'>opInner'</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span>
<a name="line-162"></a> <span class='hs-varid'>wrapChunk</span> <span class='hs-varid'>opInner'</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>op'</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-163"></a> <span class='hs-keyword'>let</span> <span class='hs-varop'>!</span><span class='hs-varid'>br'</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>BufRange</span> <span class='hs-varid'>op'</span> <span class='hs-varid'>ope</span>
<a name="line-164"></a> <span class='hs-varid'>k</span> <span class='hs-varid'>br'</span>
<a name="line-165"></a>
<a name="line-166"></a> <span class='hs-conid'>BufferFull</span> <span class='hs-varid'>minRequiredSize</span> <span class='hs-varid'>opInner'</span> <span class='hs-varid'>nextInnerStep</span> <span class='hs-keyglyph'>-></span>
<a name="line-167"></a> <span class='hs-varid'>wrapChunk</span> <span class='hs-varid'>opInner'</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>op'</span> <span class='hs-keyglyph'>-></span>
<a name="line-168"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$!</span> <span class='hs-varid'>bufferFull</span>
<a name="line-169"></a> <span class='hs-layout'>(</span><span class='hs-varid'>minRequiredSize</span> <span class='hs-varop'>+</span> <span class='hs-varid'>maxEncodingOverhead</span><span class='hs-layout'>)</span>
<a name="line-170"></a> <span class='hs-varid'>op'</span>
<a name="line-171"></a> <span class='hs-layout'>(</span><span class='hs-varid'>go</span> <span class='hs-varid'>nextInnerStep</span><span class='hs-layout'>)</span>
<a name="line-172"></a>
<a name="line-173"></a> <span class='hs-conid'>InsertByteString</span> <span class='hs-varid'>opInner'</span> <span class='hs-varid'>bs</span> <span class='hs-varid'>nextInnerStep</span>
<a name="line-174"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>null</span> <span class='hs-varid'>bs</span> <span class='hs-keyglyph'>-></span> <span class='hs-comment'>-- flush</span>
<a name="line-175"></a> <span class='hs-varid'>wrapChunk</span> <span class='hs-varid'>opInner'</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>op'</span> <span class='hs-keyglyph'>-></span>
<a name="line-176"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$!</span> <span class='hs-varid'>insertByteString</span>
<a name="line-177"></a> <span class='hs-varid'>op'</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>empty</span>
<a name="line-178"></a> <span class='hs-layout'>(</span><span class='hs-varid'>go</span> <span class='hs-varid'>nextInnerStep</span><span class='hs-layout'>)</span>
<a name="line-179"></a>
<a name="line-180"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>-></span> <span class='hs-comment'>-- insert non-empty bytestring</span>
<a name="line-181"></a> <span class='hs-varid'>wrapChunk</span> <span class='hs-varid'>opInner'</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>op'</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-182"></a> <span class='hs-comment'>-- add header for inserted bytestring</span>
<a name="line-183"></a> <span class='hs-comment'>-- FIXME: assert(S.length bs < maxBound :: Word32)</span>
<a name="line-184"></a> <span class='hs-varop'>!</span><span class='hs-varid'>op''</span> <span class='hs-keyglyph'><-</span> <span class='hs-layout'>(</span><span class='hs-varop'>`runWriteIO`</span> <span class='hs-varid'>op'</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span> <span class='hs-varid'>runWrite</span> <span class='hs-varop'>$</span>
<a name="line-185"></a> <span class='hs-varid'>writeWord32Hex</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-varop'>$</span> <span class='hs-conid'>S</span><span class='hs-varop'>.</span><span class='hs-varid'>length</span> <span class='hs-varid'>bs</span><span class='hs-layout'>)</span>
<a name="line-186"></a> <span class='hs-varop'>`mappend`</span> <span class='hs-varid'>writeCRLF</span>
<a name="line-187"></a> <span class='hs-comment'>-- insert bytestring and write CRLF in next buildstep</span>
<a name="line-188"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>$!</span> <span class='hs-conid'>InsertByteString</span>
<a name="line-189"></a> <span class='hs-varid'>op''</span> <span class='hs-varid'>bs</span>
<a name="line-190"></a> <span class='hs-layout'>(</span><span class='hs-varid'>unBuilder</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromWrite</span> <span class='hs-varid'>writeCRLF</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span>
<a name="line-191"></a> <span class='hs-varid'>buildStep</span> <span class='hs-varop'>$</span> <span class='hs-varid'>go</span> <span class='hs-varid'>nextInnerStep</span><span class='hs-layout'>)</span>
<a name="line-192"></a>
<a name="line-193"></a> <span class='hs-keyword'>where</span>
<a name="line-194"></a> <span class='hs-comment'>-- minimal size guaranteed for actual data no need to require more</span>
<a name="line-195"></a> <span class='hs-comment'>-- than 1 byte to guarantee progress the larger sizes will be</span>
<a name="line-196"></a> <span class='hs-comment'>-- hopefully provided by the driver or requested by the wrapped</span>
<a name="line-197"></a> <span class='hs-comment'>-- builders.</span>
<a name="line-198"></a> <span class='hs-varid'>minimalChunkSize</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>1</span>
<a name="line-199"></a>
<a name="line-200"></a> <span class='hs-comment'>-- overhead computation</span>
<a name="line-201"></a> <span class='hs-varid'>maxBeforeBufferOverhead</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>sizeOf</span> <span class='hs-layout'>(</span><span class='hs-varid'>undefined</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span><span class='hs-layout'>)</span> <span class='hs-varop'>+</span> <span class='hs-num'>2</span> <span class='hs-comment'>-- max chunk size and CRLF after header</span>
<a name="line-202"></a> <span class='hs-varid'>maxAfterBufferOverhead</span> <span class='hs-keyglyph'>=</span> <span class='hs-num'>2</span> <span class='hs-varop'>+</span> <span class='hs-comment'>-- CRLF after data</span>
<a name="line-203"></a> <span class='hs-varid'>sizeOf</span> <span class='hs-layout'>(</span><span class='hs-varid'>undefined</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span><span class='hs-layout'>)</span> <span class='hs-varop'>+</span> <span class='hs-num'>2</span> <span class='hs-comment'>-- max bytestring size, CRLF after header</span>
<a name="line-204"></a>
<a name="line-205"></a> <span class='hs-varid'>maxEncodingOverhead</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>maxBeforeBufferOverhead</span> <span class='hs-varop'>+</span> <span class='hs-varid'>maxAfterBufferOverhead</span>
<a name="line-206"></a>
<a name="line-207"></a> <span class='hs-varid'>minimalBufferSize</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>minimalChunkSize</span> <span class='hs-varop'>+</span> <span class='hs-varid'>maxEncodingOverhead</span>
<a name="line-208"></a>
<a name="line-209"></a> <span class='hs-comment'>-- remaining and required space computation</span>
<a name="line-210"></a> <span class='hs-varid'>outRemaining</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span>
<a name="line-211"></a> <span class='hs-varid'>outRemaining</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>ope</span> <span class='hs-varop'>`minusPtr`</span> <span class='hs-varid'>op</span>
<a name="line-212"></a> <span class='hs-varid'>chunkSizeLength</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>word32HexLength</span> <span class='hs-varop'>$</span> <span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>outRemaining</span>
<a name="line-213"></a>
<a name="line-214"></a>
<a name="line-215"></a><a name="chunkedTransferTerminator"></a><span class='hs-comment'>-- | The zero-length chunk '0\r\n\r\n' signaling the termination of the data transfer.</span>
<a name="line-216"></a><span class='hs-definition'>chunkedTransferTerminator</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Builder</span>
<a name="line-217"></a><span class='hs-definition'>chunkedTransferTerminator</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>copyByteString</span> <span class='hs-str'>"0\r\n\r\n"</span>
<a name="line-218"></a>
<a name="line-219"></a>
</pre></body>
</html>
