<?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/TCP.hs</title>
<link type='text/css' rel='stylesheet' href='hscolour.css' />
</head>
<body>
<pre><a name="line-1"></a><span class='hs-comment'>{-# LANGUAGE TypeSynonymInstances #-}</span>
<a name="line-2"></a><span class='hs-comment'>-----------------------------------------------------------------------------</span>
<a name="line-3"></a><span class='hs-comment'>-- |</span>
<a name="line-4"></a><span class='hs-comment'>-- Module : Network.TCP</span>
<a name="line-5"></a><span class='hs-comment'>-- Copyright : (c) Warrick Gray 2002, Bjorn Bringert 2003-2004, Simon Foster 2004</span>
<a name="line-6"></a><span class='hs-comment'>-- License : BSD</span>
<a name="line-7"></a><span class='hs-comment'>--</span>
<a name="line-8"></a><span class='hs-comment'>-- Maintainer : Sigbjorn Finne <sigbjorn.finne@gmail.com></span>
<a name="line-9"></a><span class='hs-comment'>-- Stability : experimental</span>
<a name="line-10"></a><span class='hs-comment'>-- Portability : non-portable (not tested)</span>
<a name="line-11"></a><span class='hs-comment'>--</span>
<a name="line-12"></a><span class='hs-comment'>-- Some utility functions for working with the Haskell @network@ package. Mostly</span>
<a name="line-13"></a><span class='hs-comment'>-- for internal use by the @Network.HTTP@ code, but </span>
<a name="line-14"></a><span class='hs-comment'>-- </span>
<a name="line-15"></a><span class='hs-comment'>-----------------------------------------------------------------------------</span>
<a name="line-16"></a><span class='hs-keyword'>module</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>TCP</span>
<a name="line-17"></a> <span class='hs-layout'>(</span> <span class='hs-conid'>Connection</span>
<a name="line-18"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>openTCPPort</span>
<a name="line-19"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>isConnectedTo</span>
<a name="line-20"></a>
<a name="line-21"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>openTCPConnection</span>
<a name="line-22"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>socketConnection</span>
<a name="line-23"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>isTCPConnectedTo</span>
<a name="line-24"></a>
<a name="line-25"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>HandleStream</span>
<a name="line-26"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>HStream</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-27"></a>
<a name="line-28"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>StreamHooks</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-29"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>nullHooks</span>
<a name="line-30"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>setStreamHooks</span>
<a name="line-31"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>getStreamHooks</span>
<a name="line-32"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hstreamToConnection</span>
<a name="line-33"></a>
<a name="line-34"></a> <span class='hs-layout'>)</span> <span class='hs-keyword'>where</span>
<a name="line-35"></a>
<a name="line-36"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>BSD</span> <span class='hs-layout'>(</span><span class='hs-varid'>getHostByName</span><span class='hs-layout'>,</span> <span class='hs-varid'>hostAddresses</span><span class='hs-layout'>)</span>
<a name="line-37"></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-38"></a> <span class='hs-layout'>(</span> <span class='hs-conid'>Socket</span><span class='hs-layout'>,</span> <span class='hs-conid'>SockAddr</span><span class='hs-layout'>(</span><span class='hs-conid'>SockAddrInet</span><span class='hs-layout'>)</span><span class='hs-layout'>,</span> <span class='hs-conid'>SocketOption</span><span class='hs-layout'>(</span><span class='hs-conid'>KeepAlive</span><span class='hs-layout'>)</span>
<a name="line-39"></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'>inet_addr</span><span class='hs-layout'>,</span> <span class='hs-varid'>connect</span>
<a name="line-40"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>shutdown</span><span class='hs-layout'>,</span> <span class='hs-conid'>ShutdownCmd</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-41"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sClose</span><span class='hs-layout'>,</span> <span class='hs-varid'>setSocketOption</span><span class='hs-layout'>,</span> <span class='hs-varid'>getPeerName</span>
<a name="line-42"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>socket</span><span class='hs-layout'>,</span> <span class='hs-conid'>Family</span><span class='hs-layout'>(</span><span class='hs-conid'>AF_INET</span><span class='hs-layout'>)</span>
<a name="line-43"></a> <span class='hs-layout'>)</span>
<a name="line-44"></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'>Stream</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>Stream</span>
<a name="line-45"></a> <span class='hs-layout'>(</span> <span class='hs-conid'>Stream</span><span class='hs-layout'>(</span><span class='hs-varid'>readBlock</span><span class='hs-layout'>,</span> <span class='hs-varid'>readLine</span><span class='hs-layout'>,</span> <span class='hs-varid'>writeBlock</span><span class='hs-layout'>,</span> <span class='hs-varid'>close</span><span class='hs-layout'>,</span> <span class='hs-varid'>closeOnEnd</span><span class='hs-layout'>)</span> <span class='hs-layout'>)</span>
<a name="line-46"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Stream</span>
<a name="line-47"></a> <span class='hs-layout'>(</span> <span class='hs-conid'>ConnError</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span>
<a name="line-48"></a> <span class='hs-layout'>,</span> <span class='hs-conid'>Result</span>
<a name="line-49"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>failWith</span>
<a name="line-50"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>failMisc</span>
<a name="line-51"></a> <span class='hs-layout'>)</span>
<a name="line-52"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>BufferType</span>
<a name="line-53"></a>
<a name="line-54"></a><span class='hs-keyword'>import</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'>Base</span> <span class='hs-layout'>(</span> <span class='hs-varid'>catchIO</span> <span class='hs-layout'>)</span>
<a name="line-55"></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'>socketToHandle</span> <span class='hs-layout'>)</span>
<a name="line-56"></a>
<a name="line-57"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>Char</span> <span class='hs-layout'>(</span> <span class='hs-varid'>toLower</span> <span class='hs-layout'>)</span>
<a name="line-58"></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-59"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Control</span><span class='hs-varop'>.</span><span class='hs-conid'>Concurrent</span>
<a name="line-60"></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'>liftM</span><span class='hs-layout'>,</span> <span class='hs-varid'>when</span> <span class='hs-layout'>)</span>
<a name="line-61"></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-conid'>Handle</span><span class='hs-layout'>,</span> <span class='hs-varid'>hFlush</span><span class='hs-layout'>,</span> <span class='hs-conid'>IOMode</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'>hClose</span> <span class='hs-layout'>)</span>
<a name="line-62"></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-varop'>.</span><span class='hs-conid'>Error</span> <span class='hs-layout'>(</span> <span class='hs-varid'>isEOFError</span> <span class='hs-layout'>)</span>
<a name="line-63"></a>
<a name="line-64"></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'>Strict</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-varop'>.</span><span class='hs-conid'>Lazy</span> <span class='hs-keyword'>as</span> <span class='hs-conid'>Lazy</span>
<a name="line-66"></a>
<a name="line-67"></a><span class='hs-comment'>-----------------------------------------------------------------</span>
<a name="line-68"></a><span class='hs-comment'>------------------ TCP Connections ------------------------------</span>
<a name="line-69"></a><span class='hs-comment'>-----------------------------------------------------------------</span>
<a name="line-70"></a>
<a name="line-71"></a><a name="Connection"></a><span class='hs-comment'>-- | The 'Connection' newtype is a wrapper that allows us to make</span>
<a name="line-72"></a><a name="Connection"></a><span class='hs-comment'>-- connections an instance of the Stream class, without GHC extensions.</span>
<a name="line-73"></a><a name="Connection"></a><span class='hs-comment'>-- While this looks sort of like a generic reference to the transport</span>
<a name="line-74"></a><a name="Connection"></a><span class='hs-comment'>-- layer it is actually TCP specific, which can be seen in the</span>
<a name="line-75"></a><a name="Connection"></a><span class='hs-comment'>-- implementation of the 'Stream Connection' instance.</span>
<a name="line-76"></a><a name="Connection"></a><span class='hs-keyword'>newtype</span> <span class='hs-conid'>Connection</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Connection</span> <span class='hs-layout'>(</span><span class='hs-conid'>HandleStream</span> <span class='hs-conid'>String</span><span class='hs-layout'>)</span>
<a name="line-77"></a>
<a name="line-78"></a><a name="HandleStream"></a><span class='hs-keyword'>newtype</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>HandleStream</span> <span class='hs-layout'>{</span><span class='hs-varid'>getRef</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>MVar</span> <span class='hs-layout'>(</span><span class='hs-conid'>Conn</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span><span class='hs-layout'>}</span>
<a name="line-79"></a>
<a name="line-80"></a><a name="Conn"></a><span class='hs-keyword'>data</span> <span class='hs-conid'>Conn</span> <span class='hs-varid'>a</span>
<a name="line-81"></a> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>MkConn</span> <span class='hs-layout'>{</span> <span class='hs-varid'>connSock</span> <span class='hs-keyglyph'>::</span> <span class='hs-varop'>!</span> <span class='hs-conid'>Socket</span>
<a name="line-82"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connHandle</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Handle</span>
<a name="line-83"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connBuffer</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>BufferOp</span> <span class='hs-varid'>a</span>
<a name="line-84"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connInput</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Maybe</span> <span class='hs-varid'>a</span>
<a name="line-85"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connHost</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>String</span>
<a name="line-86"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connHooks</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Maybe</span> <span class='hs-layout'>(</span><span class='hs-conid'>StreamHooks</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-87"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connCloseEOF</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Bool</span> <span class='hs-comment'>-- True => close socket upon reaching end-of-stream.</span>
<a name="line-88"></a> <span class='hs-layout'>}</span>
<a name="line-89"></a> <span class='hs-keyglyph'>|</span> <span class='hs-conid'>ConnClosed</span>
<a name="line-90"></a> <span class='hs-keyword'>deriving</span><span class='hs-layout'>(</span><span class='hs-conid'>Eq</span><span class='hs-layout'>)</span>
<a name="line-91"></a>
<a name="line-92"></a><a name="hstreamToConnection"></a><span class='hs-definition'>hstreamToConnection</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Connection</span>
<a name="line-93"></a><span class='hs-definition'>hstreamToConnection</span> <span class='hs-varid'>h</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Connection</span> <span class='hs-varid'>h</span>
<a name="line-94"></a>
<a name="line-95"></a><a name="connHooks'"></a><span class='hs-definition'>connHooks'</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Conn</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Maybe</span> <span class='hs-layout'>(</span><span class='hs-conid'>StreamHooks</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-96"></a><span class='hs-definition'>connHooks'</span> <span class='hs-conid'>ConnClosed</span><span class='hs-layout'>{</span><span class='hs-layout'>}</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Nothing</span>
<a name="line-97"></a><span class='hs-definition'>connHooks'</span> <span class='hs-varid'>x</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>connHooks</span> <span class='hs-varid'>x</span>
<a name="line-98"></a>
<a name="line-99"></a><a name="StreamHooks"></a><span class='hs-comment'>-- all of these are post-op hooks</span>
<a name="line-100"></a><a name="StreamHooks"></a><span class='hs-keyword'>data</span> <span class='hs-conid'>StreamHooks</span> <span class='hs-varid'>ty</span>
<a name="line-101"></a> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>StreamHooks</span>
<a name="line-102"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>hook_readLine</span> <span class='hs-keyglyph'>::</span> <span class='hs-layout'>(</span><span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>String</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Result</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-103"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hook_readBlock</span> <span class='hs-keyglyph'>::</span> <span class='hs-layout'>(</span><span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>String</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Result</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-104"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hook_writeBlock</span> <span class='hs-keyglyph'>::</span> <span class='hs-layout'>(</span><span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>String</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Result</span> <span class='hs-conid'>()</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-105"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hook_close</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-106"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hook_name</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>String</span> <span class='hs-comment'>-- hack alert: name of the hook itself.</span>
<a name="line-107"></a> <span class='hs-layout'>}</span>
<a name="line-108"></a>
<a name="line-109"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>Eq</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>Eq</span> <span class='hs-layout'>(</span><span class='hs-conid'>StreamHooks</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span> <span class='hs-keyword'>where</span>
<a name="line-110"></a> <span class='hs-layout'>(</span><span class='hs-varop'>==</span><span class='hs-layout'>)</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>True</span>
<a name="line-111"></a>
<a name="line-112"></a><a name="nullHooks"></a><span class='hs-definition'>nullHooks</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>StreamHooks</span> <span class='hs-varid'>ty</span>
<a name="line-113"></a><span class='hs-definition'>nullHooks</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>StreamHooks</span>
<a name="line-114"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>hook_readLine</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyglyph'>\</span> <span class='hs-keyword'>_</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-115"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hook_readBlock</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyglyph'>\</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'>return</span> <span class='hs-conid'>()</span>
<a name="line-116"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hook_writeBlock</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyglyph'>\</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'>return</span> <span class='hs-conid'>()</span>
<a name="line-117"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hook_close</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-118"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>hook_name</span> <span class='hs-keyglyph'>=</span> <span class='hs-str'>""</span>
<a name="line-119"></a> <span class='hs-layout'>}</span>
<a name="line-120"></a>
<a name="line-121"></a><a name="setStreamHooks"></a><span class='hs-definition'>setStreamHooks</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>StreamHooks</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-122"></a><span class='hs-definition'>setStreamHooks</span> <span class='hs-varid'>h</span> <span class='hs-varid'>sh</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>modifyMVar_</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>h</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>c</span><span class='hs-layout'>{</span><span class='hs-varid'>connHooks</span><span class='hs-keyglyph'>=</span><span class='hs-conid'>Just</span> <span class='hs-varid'>sh</span><span class='hs-layout'>}</span><span class='hs-layout'>)</span>
<a name="line-123"></a>
<a name="line-124"></a><a name="getStreamHooks"></a><span class='hs-definition'>getStreamHooks</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Maybe</span> <span class='hs-layout'>(</span><span class='hs-conid'>StreamHooks</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-125"></a><span class='hs-definition'>getStreamHooks</span> <span class='hs-varid'>h</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>readMVar</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>h</span><span class='hs-layout'>)</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>return</span><span class='hs-varop'>.</span><span class='hs-varid'>connHooks</span>
<a name="line-126"></a>
<a name="line-127"></a><a name="HStream"></a><span class='hs-comment'>-- | @HStream@ overloads the use of 'HandleStream's, letting you</span>
<a name="line-128"></a><a name="HStream"></a><span class='hs-comment'>-- overload the handle operations over the type that is communicated</span>
<a name="line-129"></a><a name="HStream"></a><span class='hs-comment'>-- across the handle. It comes in handy for @Network.HTTP@ 'Request'</span>
<a name="line-130"></a><a name="HStream"></a><span class='hs-comment'>-- and 'Response's as the payload representation isn't fixed, but overloaded.</span>
<a name="line-131"></a><a name="HStream"></a><span class='hs-comment'>--</span>
<a name="line-132"></a><a name="HStream"></a><span class='hs-comment'>-- The library comes with instances for @ByteString@s and @String@, but</span>
<a name="line-133"></a><a name="HStream"></a><span class='hs-comment'>-- should you want to plug in your own payload representation, defining</span>
<a name="line-134"></a><a name="HStream"></a><span class='hs-comment'>-- your own @HStream@ instance _should_ be all that it takes.</span>
<a name="line-135"></a><a name="HStream"></a><span class='hs-comment'>-- </span>
<a name="line-136"></a><a name="HStream"></a><span class='hs-keyword'>class</span> <span class='hs-conid'>BufferType</span> <span class='hs-varid'>bufType</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>bufType</span> <span class='hs-keyword'>where</span>
<a name="line-137"></a> <span class='hs-varid'>openStream</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufType</span><span class='hs-layout'>)</span>
<a name="line-138"></a> <span class='hs-varid'>openSocketStream</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Socket</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufType</span><span class='hs-layout'>)</span>
<a name="line-139"></a> <span class='hs-varid'>readLine</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufType</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-varid'>bufType</span><span class='hs-layout'>)</span>
<a name="line-140"></a> <span class='hs-varid'>readBlock</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufType</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-varid'>bufType</span><span class='hs-layout'>)</span>
<a name="line-141"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufType</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>bufType</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-142"></a> <span class='hs-varid'>close</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufType</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-143"></a> <span class='hs-varid'>closeQuick</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufType</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-144"></a> <span class='hs-varid'>closeOnEnd</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>bufType</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-145"></a>
<a name="line-146"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>HStream</span> <span class='hs-conid'>Strict</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-keyword'>where</span>
<a name="line-147"></a> <span class='hs-varid'>openStream</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>openTCPConnection</span>
<a name="line-148"></a> <span class='hs-varid'>openSocketStream</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>socketConnection</span>
<a name="line-149"></a> <span class='hs-varid'>readBlock</span> <span class='hs-varid'>c</span> <span class='hs-varid'>n</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>readBlockBS</span> <span class='hs-varid'>c</span> <span class='hs-varid'>n</span>
<a name="line-150"></a> <span class='hs-varid'>readLine</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>readLineBS</span> <span class='hs-varid'>c</span>
<a name="line-151"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>c</span> <span class='hs-varid'>str</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>writeBlockBS</span> <span class='hs-varid'>c</span> <span class='hs-varid'>str</span>
<a name="line-152"></a> <span class='hs-varid'>close</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeIt</span> <span class='hs-varid'>c</span> <span class='hs-conid'>Strict</span><span class='hs-varop'>.</span><span class='hs-varid'>null</span> <span class='hs-conid'>True</span>
<a name="line-153"></a> <span class='hs-varid'>closeQuick</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeIt</span> <span class='hs-varid'>c</span> <span class='hs-conid'>Strict</span><span class='hs-varop'>.</span><span class='hs-varid'>null</span> <span class='hs-conid'>False</span>
<a name="line-154"></a> <span class='hs-varid'>closeOnEnd</span> <span class='hs-varid'>c</span> <span class='hs-varid'>f</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeEOF</span> <span class='hs-varid'>c</span> <span class='hs-varid'>f</span>
<a name="line-155"></a>
<a name="line-156"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>HStream</span> <span class='hs-conid'>Lazy</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-keyword'>where</span>
<a name="line-157"></a> <span class='hs-varid'>openStream</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyglyph'>\</span> <span class='hs-varid'>a</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>openTCPConnection_</span> <span class='hs-varid'>a</span> <span class='hs-varid'>b</span> <span class='hs-conid'>True</span>
<a name="line-158"></a> <span class='hs-varid'>openSocketStream</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyglyph'>\</span> <span class='hs-varid'>a</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>socketConnection_</span> <span class='hs-varid'>a</span> <span class='hs-varid'>b</span> <span class='hs-conid'>True</span>
<a name="line-159"></a> <span class='hs-varid'>readBlock</span> <span class='hs-varid'>c</span> <span class='hs-varid'>n</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>readBlockBS</span> <span class='hs-varid'>c</span> <span class='hs-varid'>n</span>
<a name="line-160"></a> <span class='hs-varid'>readLine</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>readLineBS</span> <span class='hs-varid'>c</span>
<a name="line-161"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>c</span> <span class='hs-varid'>str</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>writeBlockBS</span> <span class='hs-varid'>c</span> <span class='hs-varid'>str</span>
<a name="line-162"></a> <span class='hs-varid'>close</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeIt</span> <span class='hs-varid'>c</span> <span class='hs-conid'>Lazy</span><span class='hs-varop'>.</span><span class='hs-varid'>null</span> <span class='hs-conid'>True</span>
<a name="line-163"></a> <span class='hs-varid'>closeQuick</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeIt</span> <span class='hs-varid'>c</span> <span class='hs-conid'>Lazy</span><span class='hs-varop'>.</span><span class='hs-varid'>null</span> <span class='hs-conid'>False</span>
<a name="line-164"></a> <span class='hs-varid'>closeOnEnd</span> <span class='hs-varid'>c</span> <span class='hs-varid'>f</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeEOF</span> <span class='hs-varid'>c</span> <span class='hs-varid'>f</span>
<a name="line-165"></a>
<a name="line-166"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>Stream</span><span class='hs-varop'>.</span><span class='hs-conid'>Stream</span> <span class='hs-conid'>Connection</span> <span class='hs-keyword'>where</span>
<a name="line-167"></a> <span class='hs-varid'>readBlock</span> <span class='hs-layout'>(</span><span class='hs-conid'>Connection</span> <span class='hs-varid'>c</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>TCP</span><span class='hs-varop'>.</span><span class='hs-varid'>readBlock</span> <span class='hs-varid'>c</span>
<a name="line-168"></a> <span class='hs-varid'>readLine</span> <span class='hs-layout'>(</span><span class='hs-conid'>Connection</span> <span class='hs-varid'>c</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>TCP</span><span class='hs-varop'>.</span><span class='hs-varid'>readLine</span> <span class='hs-varid'>c</span>
<a name="line-169"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-layout'>(</span><span class='hs-conid'>Connection</span> <span class='hs-varid'>c</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>TCP</span><span class='hs-varop'>.</span><span class='hs-varid'>writeBlock</span> <span class='hs-varid'>c</span>
<a name="line-170"></a> <span class='hs-varid'>close</span> <span class='hs-layout'>(</span><span class='hs-conid'>Connection</span> <span class='hs-varid'>c</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>TCP</span><span class='hs-varop'>.</span><span class='hs-varid'>close</span> <span class='hs-varid'>c</span>
<a name="line-171"></a> <span class='hs-varid'>closeOnEnd</span> <span class='hs-layout'>(</span><span class='hs-conid'>Connection</span> <span class='hs-varid'>c</span><span class='hs-layout'>)</span> <span class='hs-varid'>f</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>TCP</span><span class='hs-varop'>.</span><span class='hs-varid'>closeEOF</span> <span class='hs-varid'>c</span> <span class='hs-varid'>f</span>
<a name="line-172"></a>
<a name="line-173"></a><span class='hs-keyword'>instance</span> <span class='hs-conid'>HStream</span> <span class='hs-conid'>String</span> <span class='hs-keyword'>where</span>
<a name="line-174"></a> <span class='hs-varid'>openStream</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>openTCPConnection</span>
<a name="line-175"></a> <span class='hs-varid'>openSocketStream</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>socketConnection</span>
<a name="line-176"></a> <span class='hs-varid'>readBlock</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>n</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>readBlockBS</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>n</span>
<a name="line-177"></a>
<a name="line-178"></a> <span class='hs-comment'>-- This function uses a buffer, at this time the buffer is just 1000 characters.</span>
<a name="line-179"></a> <span class='hs-comment'>-- (however many bytes this is is left to the user to decypher)</span>
<a name="line-180"></a> <span class='hs-varid'>readLine</span> <span class='hs-varid'>ref</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>readLineBS</span> <span class='hs-varid'>ref</span>
<a name="line-181"></a> <span class='hs-comment'>-- The 'Connection' object allows no outward buffering, </span>
<a name="line-182"></a> <span class='hs-comment'>-- since in general messages are serialised in their entirety.</span>
<a name="line-183"></a> <span class='hs-varid'>writeBlock</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>str</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>writeBlockBS</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>str</span> <span class='hs-comment'>-- (stringToBuf str)</span>
<a name="line-184"></a>
<a name="line-185"></a> <span class='hs-comment'>-- Closes a Connection. Connection will no longer</span>
<a name="line-186"></a> <span class='hs-comment'>-- allow any of the other Stream functions. Notice that a Connection may close</span>
<a name="line-187"></a> <span class='hs-comment'>-- at any time before a call to this function. This function is idempotent.</span>
<a name="line-188"></a> <span class='hs-comment'>-- (I think the behaviour here is TCP specific)</span>
<a name="line-189"></a> <span class='hs-varid'>close</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeIt</span> <span class='hs-varid'>c</span> <span class='hs-varid'>null</span> <span class='hs-conid'>True</span>
<a name="line-190"></a>
<a name="line-191"></a> <span class='hs-comment'>-- Closes a Connection without munching the rest of the stream.</span>
<a name="line-192"></a> <span class='hs-varid'>closeQuick</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeIt</span> <span class='hs-varid'>c</span> <span class='hs-varid'>null</span> <span class='hs-conid'>False</span>
<a name="line-193"></a>
<a name="line-194"></a> <span class='hs-varid'>closeOnEnd</span> <span class='hs-varid'>c</span> <span class='hs-varid'>f</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>closeEOF</span> <span class='hs-varid'>c</span> <span class='hs-varid'>f</span>
<a name="line-195"></a>
<a name="line-196"></a><a name="openTCPPort"></a><span class='hs-comment'>-- | @openTCPPort uri port@ establishes a connection to a remote</span>
<a name="line-197"></a><span class='hs-comment'>-- host, using 'getHostByName' which possibly queries the DNS system, hence </span>
<a name="line-198"></a><span class='hs-comment'>-- may trigger a network connection.</span>
<a name="line-199"></a><span class='hs-definition'>openTCPPort</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Connection</span>
<a name="line-200"></a><span class='hs-definition'>openTCPPort</span> <span class='hs-varid'>uri</span> <span class='hs-varid'>port</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>openTCPConnection</span> <span class='hs-varid'>uri</span> <span class='hs-varid'>port</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>return</span><span class='hs-varop'>.</span><span class='hs-conid'>Connection</span>
<a name="line-201"></a>
<a name="line-202"></a><a name="openTCPConnection"></a><span class='hs-comment'>-- Add a "persistent" option? Current persistent is default.</span>
<a name="line-203"></a><span class='hs-comment'>-- Use "Result" type for synchronous exception reporting?</span>
<a name="line-204"></a><span class='hs-definition'>openTCPConnection</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>BufferType</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span>
<a name="line-205"></a><span class='hs-definition'>openTCPConnection</span> <span class='hs-varid'>uri</span> <span class='hs-varid'>port</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>openTCPConnection_</span> <span class='hs-varid'>uri</span> <span class='hs-varid'>port</span> <span class='hs-conid'>False</span>
<a name="line-206"></a>
<a name="line-207"></a><a name="openTCPConnection_"></a><span class='hs-definition'>openTCPConnection_</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>BufferType</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>String</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span>
<a name="line-208"></a><span class='hs-definition'>openTCPConnection_</span> <span class='hs-varid'>uri</span> <span class='hs-varid'>port</span> <span class='hs-varid'>stashInput</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-209"></a> <span class='hs-varid'>s</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>socket</span> <span class='hs-conid'>AF_INET</span> <span class='hs-conid'>Stream</span> <span class='hs-num'>6</span>
<a name="line-210"></a> <span class='hs-varid'>setSocketOption</span> <span class='hs-varid'>s</span> <span class='hs-conid'>KeepAlive</span> <span class='hs-num'>1</span>
<a name="line-211"></a> <span class='hs-varid'>hostA</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getHostAddr</span> <span class='hs-varid'>uri</span>
<a name="line-212"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>SockAddrInet</span> <span class='hs-layout'>(</span><span class='hs-varid'>toEnum</span> <span class='hs-varid'>port</span><span class='hs-layout'>)</span> <span class='hs-varid'>hostA</span>
<a name="line-213"></a> <span class='hs-varid'>catchIO</span> <span class='hs-layout'>(</span><span class='hs-varid'>connect</span> <span class='hs-varid'>s</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span><span class='hs-varid'>e</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>sClose</span> <span class='hs-varid'>s</span> <span class='hs-varop'>>></span> <span class='hs-varid'>ioError</span> <span class='hs-varid'>e</span><span class='hs-layout'>)</span>
<a name="line-214"></a> <span class='hs-varid'>socketConnection_</span> <span class='hs-varid'>uri</span> <span class='hs-varid'>s</span> <span class='hs-varid'>stashInput</span>
<a name="line-215"></a> <span class='hs-keyword'>where</span>
<a name="line-216"></a> <span class='hs-varid'>getHostAddr</span> <span class='hs-varid'>h</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-217"></a> <span class='hs-varid'>catchIO</span> <span class='hs-layout'>(</span><span class='hs-varid'>inet_addr</span> <span class='hs-varid'>uri</span><span class='hs-layout'>)</span> <span class='hs-comment'>-- handles ascii IP numbers</span>
<a name="line-218"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-219"></a> <span class='hs-varid'>host</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>getHostByName_safe</span> <span class='hs-varid'>uri</span>
<a name="line-220"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>hostAddresses</span> <span class='hs-varid'>host</span> <span class='hs-keyword'>of</span>
<a name="line-221"></a> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>fail</span> <span class='hs-layout'>(</span><span class='hs-str'>"openTCPConnection: no addresses in host entry for "</span> <span class='hs-varop'>++</span> <span class='hs-varid'>show</span> <span class='hs-varid'>h</span><span class='hs-layout'>)</span>
<a name="line-222"></a> <span class='hs-layout'>(</span><span class='hs-varid'>ha</span><span class='hs-conop'>:</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-varid'>ha</span><span class='hs-layout'>)</span>
<a name="line-223"></a>
<a name="line-224"></a> <span class='hs-varid'>getHostByName_safe</span> <span class='hs-varid'>h</span> <span class='hs-keyglyph'>=</span>
<a name="line-225"></a> <span class='hs-varid'>catchIO</span> <span class='hs-layout'>(</span><span class='hs-varid'>getHostByName</span> <span class='hs-varid'>h</span><span class='hs-layout'>)</span>
<a name="line-226"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>fail</span> <span class='hs-layout'>(</span><span class='hs-str'>"openTCPConnection: host lookup failure for "</span> <span class='hs-varop'>++</span> <span class='hs-varid'>show</span> <span class='hs-varid'>h</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-227"></a>
<a name="line-228"></a><a name="socketConnection"></a><span class='hs-comment'>-- | @socketConnection@, like @openConnection@ but using a pre-existing 'Socket'.</span>
<a name="line-229"></a><span class='hs-definition'>socketConnection</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>BufferType</span> <span class='hs-varid'>ty</span>
<a name="line-230"></a> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>String</span>
<a name="line-231"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Socket</span>
<a name="line-232"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span>
<a name="line-233"></a><span class='hs-definition'>socketConnection</span> <span class='hs-varid'>hst</span> <span class='hs-varid'>sock</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>socketConnection_</span> <span class='hs-varid'>hst</span> <span class='hs-varid'>sock</span> <span class='hs-conid'>False</span>
<a name="line-234"></a>
<a name="line-235"></a><a name="socketConnection_"></a><span class='hs-comment'>-- Internal function used to control the on-demand streaming of input</span>
<a name="line-236"></a><span class='hs-comment'>-- for /lazy/ streams.</span>
<a name="line-237"></a><span class='hs-definition'>socketConnection_</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>BufferType</span> <span class='hs-varid'>ty</span>
<a name="line-238"></a> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>String</span>
<a name="line-239"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Socket</span>
<a name="line-240"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span>
<a name="line-241"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span><span class='hs-layout'>)</span>
<a name="line-242"></a><span class='hs-definition'>socketConnection_</span> <span class='hs-varid'>hst</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>stashInput</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-243"></a> <span class='hs-varid'>h</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>socketToHandle</span> <span class='hs-varid'>sock</span> <span class='hs-conid'>ReadWriteMode</span>
<a name="line-244"></a> <span class='hs-varid'>mb</span> <span class='hs-keyglyph'><-</span> <span class='hs-keyword'>case</span> <span class='hs-varid'>stashInput</span> <span class='hs-keyword'>of</span> <span class='hs-layout'>{</span> <span class='hs-conid'>True</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>liftM</span> <span class='hs-conid'>Just</span> <span class='hs-varop'>$</span> <span class='hs-varid'>buf_hGetContents</span> <span class='hs-varid'>bufferOps</span> <span class='hs-varid'>h</span><span class='hs-layout'>;</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>Nothing</span> <span class='hs-layout'>}</span>
<a name="line-245"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>MkConn</span>
<a name="line-246"></a> <span class='hs-layout'>{</span> <span class='hs-varid'>connSock</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>sock</span>
<a name="line-247"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connHandle</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>h</span>
<a name="line-248"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connBuffer</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>bufferOps</span>
<a name="line-249"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connInput</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>mb</span>
<a name="line-250"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connHost</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>hst</span>
<a name="line-251"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connHooks</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>Nothing</span>
<a name="line-252"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>connCloseEOF</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>False</span>
<a name="line-253"></a> <span class='hs-layout'>}</span>
<a name="line-254"></a> <span class='hs-varid'>v</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>newMVar</span> <span class='hs-varid'>conn</span>
<a name="line-255"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-conid'>HandleStream</span> <span class='hs-varid'>v</span><span class='hs-layout'>)</span>
<a name="line-256"></a>
<a name="line-257"></a><a name="closeConnection"></a><span class='hs-definition'>closeConnection</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Bool</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-258"></a><span class='hs-definition'>closeConnection</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>readL</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-259"></a> <span class='hs-comment'>-- won't hold onto the lock for the duration</span>
<a name="line-260"></a> <span class='hs-comment'>-- we are draining it...ToDo: have Connection</span>
<a name="line-261"></a> <span class='hs-comment'>-- into a shutting-down state so that other</span>
<a name="line-262"></a> <span class='hs-comment'>-- threads will simply back off if/when attempting</span>
<a name="line-263"></a> <span class='hs-comment'>-- to also close it.</span>
<a name="line-264"></a> <span class='hs-varid'>c</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readMVar</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>ref</span><span class='hs-layout'>)</span>
<a name="line-265"></a> <span class='hs-varid'>closeConn</span> <span class='hs-varid'>c</span> <span class='hs-varop'>`catchIO`</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-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-266"></a> <span class='hs-varid'>modifyMVar_</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>ref</span><span class='hs-layout'>)</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-conid'>ConnClosed</span><span class='hs-layout'>)</span>
<a name="line-267"></a> <span class='hs-keyword'>where</span>
<a name="line-268"></a> <span class='hs-comment'>-- Be kind to peer & close gracefully.</span>
<a name="line-269"></a> <span class='hs-varid'>closeConn</span> <span class='hs-conid'>ConnClosed</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span>
<a name="line-270"></a> <span class='hs-varid'>closeConn</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-271"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>sk</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>connSock</span> <span class='hs-varid'>conn</span>
<a name="line-272"></a> <span class='hs-varid'>hFlush</span> <span class='hs-layout'>(</span><span class='hs-varid'>connHandle</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span>
<a name="line-273"></a> <span class='hs-varid'>shutdown</span> <span class='hs-varid'>sk</span> <span class='hs-conid'>ShutdownSend</span>
<a name="line-274"></a> <span class='hs-varid'>suck</span> <span class='hs-varid'>readL</span>
<a name="line-275"></a> <span class='hs-varid'>hClose</span> <span class='hs-layout'>(</span><span class='hs-varid'>connHandle</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span>
<a name="line-276"></a> <span class='hs-varid'>shutdown</span> <span class='hs-varid'>sk</span> <span class='hs-conid'>ShutdownReceive</span>
<a name="line-277"></a> <span class='hs-varid'>sClose</span> <span class='hs-varid'>sk</span>
<a name="line-278"></a>
<a name="line-279"></a> <span class='hs-varid'>suck</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Bool</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-280"></a> <span class='hs-varid'>suck</span> <span class='hs-varid'>rd</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-281"></a> <span class='hs-varid'>f</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>rd</span>
<a name="line-282"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>f</span> <span class='hs-keyword'>then</span> <span class='hs-varid'>return</span> <span class='hs-conid'>()</span> <span class='hs-keyword'>else</span> <span class='hs-varid'>suck</span> <span class='hs-varid'>rd</span>
<a name="line-283"></a>
<a name="line-284"></a><a name="isConnectedTo"></a><span class='hs-comment'>-- | Checks both that the underlying Socket is connected</span>
<a name="line-285"></a><span class='hs-comment'>-- and that the connection peer matches the given</span>
<a name="line-286"></a><span class='hs-comment'>-- host name (which is recorded locally).</span>
<a name="line-287"></a><span class='hs-definition'>isConnectedTo</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Connection</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'>Bool</span>
<a name="line-288"></a><span class='hs-definition'>isConnectedTo</span> <span class='hs-layout'>(</span><span class='hs-conid'>Connection</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varid'>name</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-289"></a> <span class='hs-varid'>v</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readMVar</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span>
<a name="line-290"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>v</span> <span class='hs-keyword'>of</span>
<a name="line-291"></a> <span class='hs-conid'>ConnClosed</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>print</span> <span class='hs-str'>"aa"</span> <span class='hs-varop'>>></span> <span class='hs-varid'>return</span> <span class='hs-conid'>False</span>
<a name="line-292"></a> <span class='hs-keyword'>_</span>
<a name="line-293"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>map</span> <span class='hs-varid'>toLower</span> <span class='hs-layout'>(</span><span class='hs-varid'>connHost</span> <span class='hs-varid'>v</span><span class='hs-layout'>)</span> <span class='hs-varop'>==</span> <span class='hs-varid'>map</span> <span class='hs-varid'>toLower</span> <span class='hs-varid'>name</span> <span class='hs-keyglyph'>-></span>
<a name="line-294"></a> <span class='hs-varid'>catch</span> <span class='hs-layout'>(</span><span class='hs-varid'>getPeerName</span> <span class='hs-layout'>(</span><span class='hs-varid'>connSock</span> <span class='hs-varid'>v</span><span class='hs-layout'>)</span> <span class='hs-varop'>>></span> <span class='hs-varid'>return</span> <span class='hs-conid'>True</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>const</span> <span class='hs-varop'>$</span> <span class='hs-varid'>return</span> <span class='hs-conid'>False</span><span class='hs-layout'>)</span>
<a name="line-295"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>False</span>
<a name="line-296"></a>
<a name="line-297"></a><a name="isTCPConnectedTo"></a><span class='hs-definition'>isTCPConnectedTo</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</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'>Bool</span>
<a name="line-298"></a><span class='hs-definition'>isTCPConnectedTo</span> <span class='hs-varid'>conn</span> <span class='hs-varid'>name</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-299"></a> <span class='hs-varid'>v</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readMVar</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span>
<a name="line-300"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>v</span> <span class='hs-keyword'>of</span>
<a name="line-301"></a> <span class='hs-conid'>ConnClosed</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>False</span>
<a name="line-302"></a> <span class='hs-keyword'>_</span>
<a name="line-303"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>map</span> <span class='hs-varid'>toLower</span> <span class='hs-layout'>(</span><span class='hs-varid'>connHost</span> <span class='hs-varid'>v</span><span class='hs-layout'>)</span> <span class='hs-varop'>==</span> <span class='hs-varid'>map</span> <span class='hs-varid'>toLower</span> <span class='hs-varid'>name</span> <span class='hs-keyglyph'>-></span>
<a name="line-304"></a> <span class='hs-varid'>catch</span> <span class='hs-layout'>(</span><span class='hs-varid'>getPeerName</span> <span class='hs-layout'>(</span><span class='hs-varid'>connSock</span> <span class='hs-varid'>v</span><span class='hs-layout'>)</span> <span class='hs-varop'>>></span> <span class='hs-varid'>return</span> <span class='hs-conid'>True</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>const</span> <span class='hs-varop'>$</span> <span class='hs-varid'>return</span> <span class='hs-conid'>False</span><span class='hs-layout'>)</span>
<a name="line-305"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>False</span>
<a name="line-306"></a>
<a name="line-307"></a><a name="readBlockBS"></a><span class='hs-definition'>readBlockBS</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-308"></a><span class='hs-definition'>readBlockBS</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>n</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>onNonClosedDo</span> <span class='hs-varid'>ref</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-309"></a> <span class='hs-varid'>x</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>bufferGetBlock</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>n</span>
<a name="line-310"></a> <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>
<a name="line-311"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>h</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>hook_readBlock</span> <span class='hs-varid'>h</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_toStr</span> <span class='hs-varop'>$</span> <span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varid'>n</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-312"></a> <span class='hs-layout'>(</span><span class='hs-varid'>connHooks'</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span>
<a name="line-313"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>x</span>
<a name="line-314"></a>
<a name="line-315"></a><a name="readLineBS"></a><span class='hs-comment'>-- This function uses a buffer, at this time the buffer is just 1000 characters.</span>
<a name="line-316"></a><span class='hs-comment'>-- (however many bytes this is is left for the user to decipher)</span>
<a name="line-317"></a><span class='hs-definition'>readLineBS</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-318"></a><span class='hs-definition'>readLineBS</span> <span class='hs-varid'>ref</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>onNonClosedDo</span> <span class='hs-varid'>ref</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-319"></a> <span class='hs-varid'>x</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>bufferReadLine</span> <span class='hs-varid'>ref</span>
<a name="line-320"></a> <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>
<a name="line-321"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>h</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>hook_readLine</span> <span class='hs-varid'>h</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_toStr</span> <span class='hs-varop'>$</span> <span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-322"></a> <span class='hs-layout'>(</span><span class='hs-varid'>connHooks'</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span>
<a name="line-323"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>x</span>
<a name="line-324"></a>
<a name="line-325"></a><a name="writeBlockBS"></a><span class='hs-comment'>-- The 'Connection' object allows no outward buffering, </span>
<a name="line-326"></a><span class='hs-comment'>-- since in general messages are serialised in their entirety.</span>
<a name="line-327"></a><span class='hs-definition'>writeBlockBS</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-328"></a><span class='hs-definition'>writeBlockBS</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>onNonClosedDo</span> <span class='hs-varid'>ref</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-329"></a> <span class='hs-varid'>x</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>bufferPutBlock</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>connHandle</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varid'>b</span>
<a name="line-330"></a> <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>
<a name="line-331"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>h</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>hook_writeBlock</span> <span class='hs-varid'>h</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_toStr</span> <span class='hs-varop'>$</span> <span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varid'>b</span> <span class='hs-varid'>x</span><span class='hs-layout'>)</span>
<a name="line-332"></a> <span class='hs-layout'>(</span><span class='hs-varid'>connHooks'</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span>
<a name="line-333"></a> <span class='hs-varid'>return</span> <span class='hs-varid'>x</span>
<a name="line-334"></a>
<a name="line-335"></a><a name="closeIt"></a><span class='hs-definition'>closeIt</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-336"></a><span class='hs-definition'>closeIt</span> <span class='hs-varid'>c</span> <span class='hs-varid'>p</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-337"></a> <span class='hs-varid'>closeConnection</span> <span class='hs-varid'>c</span> <span class='hs-layout'>(</span><span class='hs-keyword'>if</span> <span class='hs-varid'>b</span>
<a name="line-338"></a> <span class='hs-keyword'>then</span> <span class='hs-varid'>readLineBS</span> <span class='hs-varid'>c</span> <span class='hs-varop'>>>=</span> <span class='hs-keyglyph'>\</span> <span class='hs-varid'>x</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>case</span> <span class='hs-varid'>x</span> <span class='hs-keyword'>of</span> <span class='hs-layout'>{</span> <span class='hs-conid'>Right</span> <span class='hs-varid'>xs</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>p</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span><span class='hs-layout'>;</span> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-conid'>True</span><span class='hs-layout'>}</span>
<a name="line-339"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>return</span> <span class='hs-conid'>True</span><span class='hs-layout'>)</span>
<a name="line-340"></a> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readMVar</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>c</span><span class='hs-layout'>)</span>
<a name="line-341"></a> <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>
<a name="line-342"></a> <span class='hs-layout'>(</span><span class='hs-varid'>hook_close</span><span class='hs-layout'>)</span>
<a name="line-343"></a> <span class='hs-layout'>(</span><span class='hs-varid'>connHooks'</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span>
<a name="line-344"></a>
<a name="line-345"></a><a name="closeEOF"></a><span class='hs-definition'>closeEOF</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>ty</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Bool</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-346"></a><span class='hs-definition'>closeEOF</span> <span class='hs-varid'>c</span> <span class='hs-varid'>flg</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>modifyMVar_</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>c</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>co</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>co</span><span class='hs-layout'>{</span><span class='hs-varid'>connCloseEOF</span><span class='hs-keyglyph'>=</span><span class='hs-varid'>flg</span><span class='hs-layout'>}</span><span class='hs-layout'>)</span>
<a name="line-347"></a>
<a name="line-348"></a><a name="bufferGetBlock"></a><span class='hs-definition'>bufferGetBlock</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-349"></a><span class='hs-definition'>bufferGetBlock</span> <span class='hs-varid'>ref</span> <span class='hs-varid'>n</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>onNonClosedDo</span> <span class='hs-varid'>ref</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-350"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>connInput</span> <span class='hs-varid'>conn</span> <span class='hs-keyword'>of</span>
<a name="line-351"></a> <span class='hs-conid'>Just</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-352"></a> <span class='hs-keyword'>let</span> <span class='hs-layout'>(</span><span class='hs-varid'>a</span><span class='hs-layout'>,</span><span class='hs-varid'>b</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>buf_splitAt</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varid'>n</span> <span class='hs-varid'>c</span>
<a name="line-353"></a> <span class='hs-varid'>modifyMVar_</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>ref</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>co</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>co</span><span class='hs-layout'>{</span><span class='hs-varid'>connInput</span><span class='hs-keyglyph'>=</span><span class='hs-conid'>Just</span> <span class='hs-varid'>b</span><span class='hs-layout'>}</span><span class='hs-layout'>)</span>
<a name="line-354"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-355"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-356"></a> <span class='hs-conid'>Prelude</span><span class='hs-varop'>.</span><span class='hs-varid'>catch</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_hGet</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>connHandle</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varid'>n</span> <span class='hs-varop'>>>=</span> <span class='hs-varid'>return</span><span class='hs-varop'>.</span><span class='hs-varid'>return</span><span class='hs-layout'>)</span>
<a name="line-357"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>e</span> <span class='hs-keyglyph'>-></span>
<a name="line-358"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>isEOFError</span> <span class='hs-varid'>e</span>
<a name="line-359"></a> <span class='hs-keyword'>then</span> <span class='hs-keyword'>do</span>
<a name="line-360"></a> <span class='hs-varid'>when</span> <span class='hs-layout'>(</span><span class='hs-varid'>connCloseEOF</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span> <span class='hs-varid'>catch</span> <span class='hs-layout'>(</span><span class='hs-varid'>closeQuick</span> <span class='hs-varid'>ref</span><span class='hs-layout'>)</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-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-361"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_empty</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-362"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>failMisc</span> <span class='hs-layout'>(</span><span class='hs-varid'>show</span> <span class='hs-varid'>e</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-363"></a>
<a name="line-364"></a><a name="bufferPutBlock"></a><span class='hs-definition'>bufferPutBlock</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>BufferOp</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Handle</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-365"></a><span class='hs-definition'>bufferPutBlock</span> <span class='hs-varid'>ops</span> <span class='hs-varid'>h</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>=</span>
<a name="line-366"></a> <span class='hs-conid'>Prelude</span><span class='hs-varop'>.</span><span class='hs-varid'>catch</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_hPut</span> <span class='hs-varid'>ops</span> <span class='hs-varid'>h</span> <span class='hs-varid'>b</span> <span class='hs-varop'>>></span> <span class='hs-varid'>hFlush</span> <span class='hs-varid'>h</span> <span class='hs-varop'>>></span> <span class='hs-varid'>return</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-layout'>)</span>
<a name="line-367"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>e</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>failMisc</span> <span class='hs-layout'>(</span><span class='hs-varid'>show</span> <span class='hs-varid'>e</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-368"></a>
<a name="line-369"></a><a name="bufferReadLine"></a><span class='hs-definition'>bufferReadLine</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>=></span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span>
<a name="line-370"></a><span class='hs-definition'>bufferReadLine</span> <span class='hs-varid'>ref</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>onNonClosedDo</span> <span class='hs-varid'>ref</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span> <span class='hs-varid'>conn</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-371"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>connInput</span> <span class='hs-varid'>conn</span> <span class='hs-keyword'>of</span>
<a name="line-372"></a> <span class='hs-conid'>Just</span> <span class='hs-varid'>c</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-373"></a> <span class='hs-keyword'>let</span> <span class='hs-layout'>(</span><span class='hs-varid'>a</span><span class='hs-layout'>,</span><span class='hs-varid'>b0</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>buf_span</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varop'>/=</span><span class='hs-chr'>'\n'</span><span class='hs-layout'>)</span> <span class='hs-varid'>c</span>
<a name="line-374"></a> <span class='hs-keyword'>let</span> <span class='hs-layout'>(</span><span class='hs-varid'>newl</span><span class='hs-layout'>,</span><span class='hs-varid'>b1</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>buf_splitAt</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-num'>1</span> <span class='hs-varid'>b0</span>
<a name="line-375"></a> <span class='hs-varid'>modifyMVar_</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>ref</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>co</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>return</span> <span class='hs-varid'>co</span><span class='hs-layout'>{</span><span class='hs-varid'>connInput</span><span class='hs-keyglyph'>=</span><span class='hs-conid'>Just</span> <span class='hs-varid'>b1</span><span class='hs-layout'>}</span><span class='hs-layout'>)</span>
<a name="line-376"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_append</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varid'>a</span> <span class='hs-varid'>newl</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-377"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Prelude</span><span class='hs-varop'>.</span><span class='hs-varid'>catch</span>
<a name="line-378"></a> <span class='hs-layout'>(</span><span class='hs-varid'>buf_hGetLine</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>connHandle</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varop'>>>=</span>
<a name="line-379"></a> <span class='hs-varid'>return</span> <span class='hs-varop'>.</span> <span class='hs-varid'>return</span> <span class='hs-varop'>.</span> <span class='hs-varid'>appendNL</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-380"></a> <span class='hs-layout'>(</span><span class='hs-keyglyph'>\</span> <span class='hs-varid'>e</span> <span class='hs-keyglyph'>-></span>
<a name="line-381"></a> <span class='hs-keyword'>if</span> <span class='hs-varid'>isEOFError</span> <span class='hs-varid'>e</span>
<a name="line-382"></a> <span class='hs-keyword'>then</span> <span class='hs-keyword'>do</span>
<a name="line-383"></a> <span class='hs-varid'>when</span> <span class='hs-layout'>(</span><span class='hs-varid'>connCloseEOF</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span> <span class='hs-varid'>catch</span> <span class='hs-layout'>(</span><span class='hs-varid'>closeQuick</span> <span class='hs-varid'>ref</span><span class='hs-layout'>)</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-conid'>()</span><span class='hs-layout'>)</span>
<a name="line-384"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>buf_empty</span> <span class='hs-layout'>(</span><span class='hs-varid'>connBuffer</span> <span class='hs-varid'>conn</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-385"></a> <span class='hs-keyword'>else</span> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>failMisc</span> <span class='hs-layout'>(</span><span class='hs-varid'>show</span> <span class='hs-varid'>e</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-386"></a> <span class='hs-keyword'>where</span>
<a name="line-387"></a> <span class='hs-comment'>-- yes, this s**ks.. _may_ have to be addressed if perf</span>
<a name="line-388"></a> <span class='hs-comment'>-- suggests worthiness.</span>
<a name="line-389"></a> <span class='hs-varid'>appendNL</span> <span class='hs-varid'>ops</span> <span class='hs-varid'>b</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>buf_snoc</span> <span class='hs-varid'>ops</span> <span class='hs-varid'>b</span> <span class='hs-varid'>nl</span>
<a name="line-390"></a>
<a name="line-391"></a> <span class='hs-varid'>nl</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Word8</span>
<a name="line-392"></a> <span class='hs-varid'>nl</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>fromIntegral</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromEnum</span> <span class='hs-chr'>'\n'</span><span class='hs-layout'>)</span>
<a name="line-393"></a>
<a name="line-394"></a><a name="onNonClosedDo"></a><span class='hs-definition'>onNonClosedDo</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>HandleStream</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-conid'>Conn</span> <span class='hs-varid'>a</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-varid'>b</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>Result</span> <span class='hs-varid'>b</span><span class='hs-layout'>)</span>
<a name="line-395"></a><span class='hs-definition'>onNonClosedDo</span> <span class='hs-varid'>h</span> <span class='hs-varid'>act</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-396"></a> <span class='hs-varid'>x</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>readMVar</span> <span class='hs-layout'>(</span><span class='hs-varid'>getRef</span> <span class='hs-varid'>h</span><span class='hs-layout'>)</span>
<a name="line-397"></a> <span class='hs-keyword'>case</span> <span class='hs-varid'>x</span> <span class='hs-keyword'>of</span>
<a name="line-398"></a> <span class='hs-conid'>ConnClosed</span><span class='hs-layout'>{</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'>failWith</span> <span class='hs-conid'>ErrorClosed</span><span class='hs-layout'>)</span>
<a name="line-399"></a> <span class='hs-keyword'>_</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>act</span> <span class='hs-varid'>x</span>
<a name="line-400"></a>
</pre></body>
</html>
