/usr/share/doc/libghc-network-doc/html/src/Network-Socket-ByteString.html is in libghc-network-doc 2.6.3.1-3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 | <?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://code.haskell.org/~malcolm/hscolour/ -->
<title>dist-ghc/build/Network/Socket/ByteString.hs</title>
<link type='text/css' rel='stylesheet' href='hscolour.css' />
</head>
<body>
<pre><a name="line-1"></a><span class='hs-comment'>{-# LINE 1 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-2"></a><span class='hs-comment'>{-# LANGUAGE CPP, ForeignFunctionInterface #-}</span>
<a name="line-3"></a><span class='hs-comment'>{-# LINE 2 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-4"></a>
<a name="line-5"></a>
<a name="line-6"></a><span class='hs-comment'>{-# LINE 4 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-7"></a>
<a name="line-8"></a><span class='hs-comment'>-- |</span>
<a name="line-9"></a><span class='hs-comment'>-- Module : Network.Socket.ByteString</span>
<a name="line-10"></a><span class='hs-comment'>-- Copyright : (c) Johan Tibell 2007-2010</span>
<a name="line-11"></a><span class='hs-comment'>-- License : BSD-style</span>
<a name="line-12"></a><span class='hs-comment'>--</span>
<a name="line-13"></a><span class='hs-comment'>-- Maintainer : johan.tibell@gmail.com</span>
<a name="line-14"></a><span class='hs-comment'>-- Stability : stable</span>
<a name="line-15"></a><span class='hs-comment'>-- Portability : portable</span>
<a name="line-16"></a><span class='hs-comment'>--</span>
<a name="line-17"></a><span class='hs-comment'>-- This module provides access to the BSD /socket/ interface. This</span>
<a name="line-18"></a><span class='hs-comment'>-- module is generally more efficient than the 'String' based network</span>
<a name="line-19"></a><span class='hs-comment'>-- functions in 'Network.Socket'. For detailed documentation, consult</span>
<a name="line-20"></a><span class='hs-comment'>-- your favorite POSIX socket reference. All functions communicate</span>
<a name="line-21"></a><span class='hs-comment'>-- failures by converting the error number to 'System.IO.IOError'.</span>
<a name="line-22"></a><span class='hs-comment'>--</span>
<a name="line-23"></a><span class='hs-comment'>-- This module is made to be imported with 'Network.Socket' like so:</span>
<a name="line-24"></a><span class='hs-comment'>--</span>
<a name="line-25"></a><span class='hs-comment'>-- > import Network.Socket hiding (send, sendTo, recv, recvFrom)</span>
<a name="line-26"></a><span class='hs-comment'>-- > import Network.Socket.ByteString</span>
<a name="line-27"></a><span class='hs-comment'>--</span>
<a name="line-28"></a><span class='hs-keyword'>module</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Socket</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span>
<a name="line-29"></a> <span class='hs-layout'>(</span>
<a name="line-30"></a> <span class='hs-comment'>-- * Send data to a socket</span>
<a name="line-31"></a> <span class='hs-varid'>send</span>
<a name="line-32"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sendAll</span>
<a name="line-33"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sendTo</span>
<a name="line-34"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sendAllTo</span>
<a name="line-35"></a>
<a name="line-36"></a> <span class='hs-comment'>-- ** Vectored I/O</span>
<a name="line-37"></a> <span class='hs-comment'>-- $vectored</span>
<a name="line-38"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sendMany</span>
<a name="line-39"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>sendManyTo</span>
<a name="line-40"></a>
<a name="line-41"></a> <span class='hs-comment'>-- * Receive data from a socket</span>
<a name="line-42"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>recv</span>
<a name="line-43"></a> <span class='hs-layout'>,</span> <span class='hs-varid'>recvFrom</span>
<a name="line-44"></a>
<a name="line-45"></a> <span class='hs-comment'>-- * Example</span>
<a name="line-46"></a> <span class='hs-comment'>-- $example</span>
<a name="line-47"></a> <span class='hs-layout'>)</span> <span class='hs-keyword'>where</span>
<a name="line-48"></a>
<a name="line-49"></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'>when</span><span class='hs-layout'>)</span>
<a name="line-50"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Data</span><span class='hs-varop'>.</span><span class='hs-conid'>ByteString</span> <span class='hs-layout'>(</span><span class='hs-conid'>ByteString</span><span class='hs-layout'>)</span>
<a name="line-51"></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'>Internal</span> <span class='hs-layout'>(</span><span class='hs-varid'>createAndTrim</span><span class='hs-layout'>)</span>
<a name="line-52"></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'>Unsafe</span> <span class='hs-layout'>(</span><span class='hs-varid'>unsafeUseAsCStringLen</span><span class='hs-layout'>)</span>
<a name="line-53"></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-54"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Foreign</span><span class='hs-varop'>.</span><span class='hs-conid'>Marshal</span><span class='hs-varop'>.</span><span class='hs-conid'>Alloc</span> <span class='hs-layout'>(</span><span class='hs-varid'>allocaBytes</span><span class='hs-layout'>)</span>
<a name="line-55"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Foreign</span><span class='hs-varop'>.</span><span class='hs-conid'>Ptr</span> <span class='hs-layout'>(</span><span class='hs-conid'>Ptr</span><span class='hs-layout'>,</span> <span class='hs-varid'>castPtr</span><span class='hs-layout'>)</span>
<a name="line-56"></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'>sendBuf</span><span class='hs-layout'>,</span> <span class='hs-varid'>sendBufTo</span><span class='hs-layout'>,</span> <span class='hs-varid'>recvBufFrom</span><span class='hs-layout'>)</span>
<a name="line-57"></a>
<a name="line-58"></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'>B</span>
<a name="line-59"></a>
<a name="line-60"></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-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>Internal</span>
<a name="line-61"></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-varop'>.</span><span class='hs-conid'>Internal</span>
<a name="line-62"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Network</span><span class='hs-varop'>.</span><span class='hs-conid'>Socket</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span>
<a name="line-63"></a>
<a name="line-64"></a>
<a name="line-65"></a><span class='hs-comment'>{-# LINE 62 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-66"></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'>zipWithM_</span><span class='hs-layout'>)</span>
<a name="line-67"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Foreign</span><span class='hs-varop'>.</span><span class='hs-conid'>Marshal</span><span class='hs-varop'>.</span><span class='hs-conid'>Array</span> <span class='hs-layout'>(</span><span class='hs-varid'>allocaArray</span><span class='hs-layout'>)</span>
<a name="line-68"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Foreign</span><span class='hs-varop'>.</span><span class='hs-conid'>Marshal</span><span class='hs-varop'>.</span><span class='hs-conid'>Utils</span> <span class='hs-layout'>(</span><span class='hs-varid'>with</span><span class='hs-layout'>)</span>
<a name="line-69"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Foreign</span><span class='hs-varop'>.</span><span class='hs-conid'>Ptr</span> <span class='hs-layout'>(</span><span class='hs-varid'>plusPtr</span><span class='hs-layout'>)</span>
<a name="line-70"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Foreign</span><span class='hs-varop'>.</span><span class='hs-conid'>Storable</span> <span class='hs-layout'>(</span><span class='hs-conid'>Storable</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-71"></a><span class='hs-keyword'>import</span> <span class='hs-conid'>Foreign</span><span class='hs-varop'>.</span><span class='hs-conid'>C</span><span class='hs-varop'>.</span><span class='hs-conid'>Types</span> <span class='hs-layout'>(</span><span class='hs-conid'>CChar</span><span class='hs-layout'>,</span> <span class='hs-conid'>CSize</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span><span class='hs-layout'>,</span> <span class='hs-conid'>CInt</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-72"></a>
<a name="line-73"></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-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>IOVec</span> <span class='hs-layout'>(</span><span class='hs-conid'>IOVec</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-74"></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-varop'>.</span><span class='hs-conid'>ByteString</span><span class='hs-varop'>.</span><span class='hs-conid'>MsgHdr</span> <span class='hs-layout'>(</span><span class='hs-conid'>MsgHdr</span><span class='hs-layout'>(</span><span class='hs-keyglyph'>..</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-75"></a>
<a name="line-76"></a>
<a name="line-77"></a><span class='hs-comment'>{-# LINE 75 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-78"></a>
<a name="line-79"></a>
<a name="line-80"></a><span class='hs-comment'>{-# LINE 77 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-81"></a><span class='hs-keyword'>foreign</span> <span class='hs-keyword'>import</span> <span class='hs-conid'>CALLCONV</span> <span class='hs-keyword'>unsafe</span> <span class='hs-str'>"recv"</span>
<a name="line-82"></a> <span class='hs-varid'>c_recv</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>CInt</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Ptr</span> <span class='hs-conid'>CChar</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>CSize</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>CInt</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>CInt</span>
<a name="line-83"></a>
<a name="line-84"></a><span class='hs-comment'>{-# LINE 80 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-85"></a>
<a name="line-86"></a><span class='hs-comment'>-- ----------------------------------------------------------------------------</span>
<a name="line-87"></a><span class='hs-comment'>-- Sending</span>
<a name="line-88"></a>
<a name="line-89"></a><a name="send"></a><span class='hs-comment'>-- | Send data to the socket. The socket must be connected to a</span>
<a name="line-90"></a><span class='hs-comment'>-- remote socket. Returns the number of bytes sent. Applications are</span>
<a name="line-91"></a><span class='hs-comment'>-- responsible for ensuring that all data has been sent.</span>
<a name="line-92"></a><span class='hs-comment'>--</span>
<a name="line-93"></a><span class='hs-comment'>-- Sending data to closed socket may lead to undefined behaviour.</span>
<a name="line-94"></a><span class='hs-definition'>send</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-comment'>-- ^ Connected socket</span>
<a name="line-95"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ByteString</span> <span class='hs-comment'>-- ^ Data to send</span>
<a name="line-96"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Int</span> <span class='hs-comment'>-- ^ Number of bytes sent</span>
<a name="line-97"></a><span class='hs-definition'>send</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>xs</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>unsafeUseAsCStringLen</span> <span class='hs-varid'>xs</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-layout'>(</span><span class='hs-varid'>str</span><span class='hs-layout'>,</span> <span class='hs-varid'>len</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span>
<a name="line-98"></a> <span class='hs-varid'>sendBuf</span> <span class='hs-varid'>sock</span> <span class='hs-layout'>(</span><span class='hs-varid'>castPtr</span> <span class='hs-varid'>str</span><span class='hs-layout'>)</span> <span class='hs-varid'>len</span>
<a name="line-99"></a>
<a name="line-100"></a><a name="sendAll"></a><span class='hs-comment'>-- | Send data to the socket. The socket must be connected to a</span>
<a name="line-101"></a><span class='hs-comment'>-- remote socket. Unlike 'send', this function continues to send data</span>
<a name="line-102"></a><span class='hs-comment'>-- until either all data has been sent or an error occurs. On error,</span>
<a name="line-103"></a><span class='hs-comment'>-- an exception is raised, and there is no way to determine how much</span>
<a name="line-104"></a><span class='hs-comment'>-- data, if any, was successfully sent.</span>
<a name="line-105"></a><span class='hs-comment'>--</span>
<a name="line-106"></a><span class='hs-comment'>-- Sending data to closed socket may lead to undefined behaviour.</span>
<a name="line-107"></a><span class='hs-definition'>sendAll</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-comment'>-- ^ Connected socket</span>
<a name="line-108"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ByteString</span> <span class='hs-comment'>-- ^ Data to send</span>
<a name="line-109"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-110"></a><span class='hs-definition'>sendAll</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>bs</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-111"></a> <span class='hs-varid'>sent</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>send</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>bs</span>
<a name="line-112"></a> <span class='hs-varid'>when</span> <span class='hs-layout'>(</span><span class='hs-varid'>sent</span> <span class='hs-varop'><</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>length</span> <span class='hs-varid'>bs</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span> <span class='hs-varid'>sendAll</span> <span class='hs-varid'>sock</span> <span class='hs-layout'>(</span><span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>drop</span> <span class='hs-varid'>sent</span> <span class='hs-varid'>bs</span><span class='hs-layout'>)</span>
<a name="line-113"></a>
<a name="line-114"></a><a name="sendTo"></a><span class='hs-comment'>-- | Send data to the socket. The recipient can be specified</span>
<a name="line-115"></a><span class='hs-comment'>-- explicitly, so the socket need not be in a connected state.</span>
<a name="line-116"></a><span class='hs-comment'>-- Returns the number of bytes sent. Applications are responsible for</span>
<a name="line-117"></a><span class='hs-comment'>-- ensuring that all data has been sent.</span>
<a name="line-118"></a><span class='hs-comment'>--</span>
<a name="line-119"></a><span class='hs-comment'>-- Sending data to closed socket may lead to undefined behaviour.</span>
<a name="line-120"></a><span class='hs-definition'>sendTo</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-comment'>-- ^ Socket</span>
<a name="line-121"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ByteString</span> <span class='hs-comment'>-- ^ Data to send</span>
<a name="line-122"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>SockAddr</span> <span class='hs-comment'>-- ^ Recipient address</span>
<a name="line-123"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>Int</span> <span class='hs-comment'>-- ^ Number of bytes sent</span>
<a name="line-124"></a><span class='hs-definition'>sendTo</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>xs</span> <span class='hs-varid'>addr</span> <span class='hs-keyglyph'>=</span>
<a name="line-125"></a> <span class='hs-varid'>unsafeUseAsCStringLen</span> <span class='hs-varid'>xs</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-layout'>(</span><span class='hs-varid'>str</span><span class='hs-layout'>,</span> <span class='hs-varid'>len</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-varid'>sendBufTo</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>str</span> <span class='hs-varid'>len</span> <span class='hs-varid'>addr</span>
<a name="line-126"></a>
<a name="line-127"></a><a name="sendAllTo"></a><span class='hs-comment'>-- | Send data to the socket. The recipient can be specified</span>
<a name="line-128"></a><span class='hs-comment'>-- explicitly, so the socket need not be in a connected state. Unlike</span>
<a name="line-129"></a><span class='hs-comment'>-- 'sendTo', this function continues to send data until either all</span>
<a name="line-130"></a><span class='hs-comment'>-- data has been sent or an error occurs. On error, an exception is</span>
<a name="line-131"></a><span class='hs-comment'>-- raised, and there is no way to determine how much data, if any, was</span>
<a name="line-132"></a><span class='hs-comment'>-- successfully sent.</span>
<a name="line-133"></a><span class='hs-comment'>--</span>
<a name="line-134"></a><span class='hs-comment'>-- Sending data to closed socket may lead to undefined behaviour.</span>
<a name="line-135"></a><span class='hs-definition'>sendAllTo</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-comment'>-- ^ Socket</span>
<a name="line-136"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>ByteString</span> <span class='hs-comment'>-- ^ Data to send</span>
<a name="line-137"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>SockAddr</span> <span class='hs-comment'>-- ^ Recipient address</span>
<a name="line-138"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-139"></a><span class='hs-definition'>sendAllTo</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>xs</span> <span class='hs-varid'>addr</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-140"></a> <span class='hs-varid'>sent</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>sendTo</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>xs</span> <span class='hs-varid'>addr</span>
<a name="line-141"></a> <span class='hs-varid'>when</span> <span class='hs-layout'>(</span><span class='hs-varid'>sent</span> <span class='hs-varop'><</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>length</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span> <span class='hs-varid'>sendAllTo</span> <span class='hs-varid'>sock</span> <span class='hs-layout'>(</span><span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>drop</span> <span class='hs-varid'>sent</span> <span class='hs-varid'>xs</span><span class='hs-layout'>)</span> <span class='hs-varid'>addr</span>
<a name="line-142"></a>
<a name="line-143"></a><span class='hs-comment'>-- ----------------------------------------------------------------------------</span>
<a name="line-144"></a><span class='hs-comment'>-- ** Vectored I/O</span>
<a name="line-145"></a>
<a name="line-146"></a><span class='hs-comment'>-- $vectored</span>
<a name="line-147"></a><span class='hs-comment'>--</span>
<a name="line-148"></a><span class='hs-comment'>-- Vectored I\/O, also known as scatter\/gather I\/O, allows multiple</span>
<a name="line-149"></a><span class='hs-comment'>-- data segments to be sent using a single system call, without first</span>
<a name="line-150"></a><span class='hs-comment'>-- concatenating the segments. For example, given a list of</span>
<a name="line-151"></a><span class='hs-comment'>-- @ByteString@s, @xs@,</span>
<a name="line-152"></a><span class='hs-comment'>--</span>
<a name="line-153"></a><span class='hs-comment'>-- > sendMany sock xs</span>
<a name="line-154"></a><span class='hs-comment'>--</span>
<a name="line-155"></a><span class='hs-comment'>-- is equivalent to</span>
<a name="line-156"></a><span class='hs-comment'>--</span>
<a name="line-157"></a><span class='hs-comment'>-- > sendAll sock (concat xs)</span>
<a name="line-158"></a><span class='hs-comment'>--</span>
<a name="line-159"></a><span class='hs-comment'>-- but potentially more efficient.</span>
<a name="line-160"></a><span class='hs-comment'>--</span>
<a name="line-161"></a><span class='hs-comment'>-- Vectored I\/O are often useful when implementing network protocols</span>
<a name="line-162"></a><span class='hs-comment'>-- that, for example, group data into segments consisting of one or</span>
<a name="line-163"></a><span class='hs-comment'>-- more fixed-length headers followed by a variable-length body.</span>
<a name="line-164"></a>
<a name="line-165"></a><a name="sendMany"></a><span class='hs-comment'>-- | Send data to the socket. The socket must be in a connected</span>
<a name="line-166"></a><span class='hs-comment'>-- state. The data is sent as if the parts have been concatenated.</span>
<a name="line-167"></a><span class='hs-comment'>-- This function continues to send data until either all data has been</span>
<a name="line-168"></a><span class='hs-comment'>-- sent or an error occurs. On error, an exception is raised, and</span>
<a name="line-169"></a><span class='hs-comment'>-- there is no way to determine how much data, if any, was</span>
<a name="line-170"></a><span class='hs-comment'>-- successfully sent.</span>
<a name="line-171"></a><span class='hs-comment'>--</span>
<a name="line-172"></a><span class='hs-comment'>-- Sending data to closed socket may lead to undefined behaviour.</span>
<a name="line-173"></a><span class='hs-definition'>sendMany</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-comment'>-- ^ Connected socket</span>
<a name="line-174"></a> <span class='hs-keyglyph'>-></span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span> <span class='hs-comment'>-- ^ Data to send</span>
<a name="line-175"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-176"></a>
<a name="line-177"></a><span class='hs-comment'>{-# LINE 172 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-178"></a><span class='hs-definition'>sendMany</span> <span class='hs-varid'>sock</span><span class='hs-keyglyph'>@</span><span class='hs-layout'>(</span><span class='hs-conid'>MkSocket</span> <span class='hs-varid'>fd</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span><span class='hs-layout'>)</span> <span class='hs-varid'>cs</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-179"></a> <span class='hs-varid'>sent</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>sendManyInner</span>
<a name="line-180"></a> <span class='hs-varid'>when</span> <span class='hs-layout'>(</span><span class='hs-varid'>sent</span> <span class='hs-varop'><</span> <span class='hs-varid'>totalLength</span> <span class='hs-varid'>cs</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span> <span class='hs-varid'>sendMany</span> <span class='hs-varid'>sock</span> <span class='hs-layout'>(</span><span class='hs-varid'>remainingChunks</span> <span class='hs-varid'>sent</span> <span class='hs-varid'>cs</span><span class='hs-layout'>)</span>
<a name="line-181"></a> <span class='hs-keyword'>where</span>
<a name="line-182"></a> <span class='hs-varid'>sendManyInner</span> <span class='hs-keyglyph'>=</span>
<a name="line-183"></a> <span class='hs-varid'>liftM</span> <span class='hs-varid'>fromIntegral</span> <span class='hs-varop'>.</span> <span class='hs-varid'>withIOVec</span> <span class='hs-varid'>cs</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-layout'>(</span><span class='hs-varid'>iovsPtr</span><span class='hs-layout'>,</span> <span class='hs-varid'>iovsLen</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span>
<a name="line-184"></a> <span class='hs-varid'>throwSocketErrorWaitWrite</span> <span class='hs-varid'>sock</span> <span class='hs-str'>"writev"</span> <span class='hs-varop'>$</span>
<a name="line-185"></a> <span class='hs-varid'>c_writev</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>fd</span><span class='hs-layout'>)</span> <span class='hs-varid'>iovsPtr</span>
<a name="line-186"></a> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-layout'>(</span><span class='hs-varid'>min</span> <span class='hs-varid'>iovsLen</span> <span class='hs-layout'>(</span><span class='hs-num'>1024</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-187"></a><span class='hs-comment'>{-# LINE 181 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-188"></a>
<a name="line-189"></a><span class='hs-comment'>{-# LINE 184 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-190"></a>
<a name="line-191"></a><a name="sendManyTo"></a><span class='hs-comment'>-- | Send data to the socket. The recipient can be specified</span>
<a name="line-192"></a><span class='hs-comment'>-- explicitly, so the socket need not be in a connected state. The</span>
<a name="line-193"></a><span class='hs-comment'>-- data is sent as if the parts have been concatenated. This function</span>
<a name="line-194"></a><span class='hs-comment'>-- continues to send data until either all data has been sent or an</span>
<a name="line-195"></a><span class='hs-comment'>-- error occurs. On error, an exception is raised, and there is no</span>
<a name="line-196"></a><span class='hs-comment'>-- way to determine how much data, if any, was successfully sent.</span>
<a name="line-197"></a><span class='hs-comment'>--</span>
<a name="line-198"></a><span class='hs-comment'>-- Sending data to closed socket may lead to undefined behaviour.</span>
<a name="line-199"></a><span class='hs-definition'>sendManyTo</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-comment'>-- ^ Socket</span>
<a name="line-200"></a> <span class='hs-keyglyph'>-></span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span> <span class='hs-comment'>-- ^ Data to send</span>
<a name="line-201"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>SockAddr</span> <span class='hs-comment'>-- ^ Recipient address</span>
<a name="line-202"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>()</span>
<a name="line-203"></a>
<a name="line-204"></a><span class='hs-comment'>{-# LINE 198 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-205"></a><span class='hs-definition'>sendManyTo</span> <span class='hs-varid'>sock</span><span class='hs-keyglyph'>@</span><span class='hs-layout'>(</span><span class='hs-conid'>MkSocket</span> <span class='hs-varid'>fd</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span> <span class='hs-keyword'>_</span><span class='hs-layout'>)</span> <span class='hs-varid'>cs</span> <span class='hs-varid'>addr</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>do</span>
<a name="line-206"></a> <span class='hs-varid'>sent</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>liftM</span> <span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>sendManyToInner</span>
<a name="line-207"></a> <span class='hs-varid'>when</span> <span class='hs-layout'>(</span><span class='hs-varid'>sent</span> <span class='hs-varop'><</span> <span class='hs-varid'>totalLength</span> <span class='hs-varid'>cs</span><span class='hs-layout'>)</span> <span class='hs-varop'>$</span> <span class='hs-varid'>sendManyTo</span> <span class='hs-varid'>sock</span> <span class='hs-layout'>(</span><span class='hs-varid'>remainingChunks</span> <span class='hs-varid'>sent</span> <span class='hs-varid'>cs</span><span class='hs-layout'>)</span> <span class='hs-varid'>addr</span>
<a name="line-208"></a> <span class='hs-keyword'>where</span>
<a name="line-209"></a> <span class='hs-varid'>sendManyToInner</span> <span class='hs-keyglyph'>=</span>
<a name="line-210"></a> <span class='hs-varid'>withSockAddr</span> <span class='hs-varid'>addr</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>addrPtr</span> <span class='hs-varid'>addrSize</span> <span class='hs-keyglyph'>-></span>
<a name="line-211"></a> <span class='hs-varid'>withIOVec</span> <span class='hs-varid'>cs</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-layout'>(</span><span class='hs-varid'>iovsPtr</span><span class='hs-layout'>,</span> <span class='hs-varid'>iovsLen</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-212"></a> <span class='hs-keyword'>let</span> <span class='hs-varid'>msgHdr</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>MsgHdr</span>
<a name="line-213"></a> <span class='hs-varid'>addrPtr</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>addrSize</span><span class='hs-layout'>)</span>
<a name="line-214"></a> <span class='hs-varid'>iovsPtr</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>iovsLen</span><span class='hs-layout'>)</span>
<a name="line-215"></a> <span class='hs-varid'>with</span> <span class='hs-varid'>msgHdr</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>msgHdrPtr</span> <span class='hs-keyglyph'>-></span>
<a name="line-216"></a> <span class='hs-varid'>throwSocketErrorWaitWrite</span> <span class='hs-varid'>sock</span> <span class='hs-str'>"sendmsg"</span> <span class='hs-varop'>$</span>
<a name="line-217"></a> <span class='hs-varid'>c_sendmsg</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>fd</span><span class='hs-layout'>)</span> <span class='hs-varid'>msgHdrPtr</span> <span class='hs-num'>0</span>
<a name="line-218"></a>
<a name="line-219"></a><span class='hs-comment'>{-# LINE 214 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-220"></a>
<a name="line-221"></a><span class='hs-comment'>-- ----------------------------------------------------------------------------</span>
<a name="line-222"></a><span class='hs-comment'>-- Receiving</span>
<a name="line-223"></a>
<a name="line-224"></a><a name="recv"></a><span class='hs-comment'>-- | Receive data from the socket. The socket must be in a connected</span>
<a name="line-225"></a><span class='hs-comment'>-- state. This function may return fewer bytes than specified. If</span>
<a name="line-226"></a><span class='hs-comment'>-- the message is longer than the specified length, it may be</span>
<a name="line-227"></a><span class='hs-comment'>-- discarded depending on the type of socket. This function may block</span>
<a name="line-228"></a><span class='hs-comment'>-- until a message arrives.</span>
<a name="line-229"></a><span class='hs-comment'>--</span>
<a name="line-230"></a><span class='hs-comment'>-- Considering hardware and network realities, the maximum number of bytes to</span>
<a name="line-231"></a><span class='hs-comment'>-- receive should be a small power of 2, e.g., 4096.</span>
<a name="line-232"></a><span class='hs-comment'>--</span>
<a name="line-233"></a><span class='hs-comment'>-- For TCP sockets, a zero length return value means the peer has</span>
<a name="line-234"></a><span class='hs-comment'>-- closed its half side of the connection.</span>
<a name="line-235"></a><span class='hs-comment'>--</span>
<a name="line-236"></a><span class='hs-comment'>-- Receiving data from closed socket may lead to undefined behaviour.</span>
<a name="line-237"></a><span class='hs-definition'>recv</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-comment'>-- ^ Connected socket</span>
<a name="line-238"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-comment'>-- ^ Maximum number of bytes to receive</span>
<a name="line-239"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-conid'>ByteString</span> <span class='hs-comment'>-- ^ Data received</span>
<a name="line-240"></a><span class='hs-definition'>recv</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>nbytes</span>
<a name="line-241"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>nbytes</span> <span class='hs-varop'><</span> <span class='hs-num'>0</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>ioError</span> <span class='hs-layout'>(</span><span class='hs-varid'>mkInvalidRecvArgError</span> <span class='hs-str'>"Network.Socket.ByteString.recv"</span><span class='hs-layout'>)</span>
<a name="line-242"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>createAndTrim</span> <span class='hs-varid'>nbytes</span> <span class='hs-varop'>$</span> <span class='hs-varid'>recvInner</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>nbytes</span>
<a name="line-243"></a>
<a name="line-244"></a><a name="recvInner"></a><span class='hs-definition'>recvInner</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</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'>Int</span>
<a name="line-245"></a><span class='hs-definition'>recvInner</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>nbytes</span> <span class='hs-varid'>ptr</span> <span class='hs-keyglyph'>=</span>
<a name="line-246"></a> <span class='hs-varid'>fmap</span> <span class='hs-varid'>fromIntegral</span> <span class='hs-varop'>$</span>
<a name="line-247"></a>
<a name="line-248"></a><span class='hs-comment'>{-# LINE 245 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-249"></a> <span class='hs-varid'>throwSocketErrorWaitRead</span> <span class='hs-varid'>sock</span> <span class='hs-str'>"recv"</span> <span class='hs-varop'>$</span>
<a name="line-250"></a> <span class='hs-varid'>c_recv</span> <span class='hs-varid'>s</span> <span class='hs-layout'>(</span><span class='hs-varid'>castPtr</span> <span class='hs-varid'>ptr</span><span class='hs-layout'>)</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>nbytes</span><span class='hs-layout'>)</span> <span class='hs-num'>0</span>
<a name="line-251"></a>
<a name="line-252"></a><span class='hs-comment'>{-# LINE 248 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-253"></a> <span class='hs-keyword'>where</span>
<a name="line-254"></a> <span class='hs-varid'>s</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>sockFd</span> <span class='hs-varid'>sock</span>
<a name="line-255"></a>
<a name="line-256"></a><a name="recvFrom"></a><span class='hs-comment'>-- | Receive data from the socket. The socket need not be in a</span>
<a name="line-257"></a><span class='hs-comment'>-- connected state. Returns @(bytes, address)@ where @bytes@ is a</span>
<a name="line-258"></a><span class='hs-comment'>-- 'ByteString' representing the data received and @address@ is a</span>
<a name="line-259"></a><span class='hs-comment'>-- 'SockAddr' representing the address of the sending socket.</span>
<a name="line-260"></a><span class='hs-comment'>--</span>
<a name="line-261"></a><span class='hs-comment'>-- Receiving data from closed socket may lead to undefined behaviour.</span>
<a name="line-262"></a><span class='hs-definition'>recvFrom</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Socket</span> <span class='hs-comment'>-- ^ Socket</span>
<a name="line-263"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span> <span class='hs-comment'>-- ^ Maximum number of bytes to receive</span>
<a name="line-264"></a> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-layout'>(</span><span class='hs-conid'>ByteString</span><span class='hs-layout'>,</span> <span class='hs-conid'>SockAddr</span><span class='hs-layout'>)</span> <span class='hs-comment'>-- ^ Data received and sender address</span>
<a name="line-265"></a><span class='hs-definition'>recvFrom</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>nbytes</span> <span class='hs-keyglyph'>=</span>
<a name="line-266"></a> <span class='hs-varid'>allocaBytes</span> <span class='hs-varid'>nbytes</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>ptr</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-267"></a> <span class='hs-layout'>(</span><span class='hs-varid'>len</span><span class='hs-layout'>,</span> <span class='hs-varid'>sockaddr</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'><-</span> <span class='hs-varid'>recvBufFrom</span> <span class='hs-varid'>sock</span> <span class='hs-varid'>ptr</span> <span class='hs-varid'>nbytes</span>
<a name="line-268"></a> <span class='hs-varid'>str</span> <span class='hs-keyglyph'><-</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>packCStringLen</span> <span class='hs-layout'>(</span><span class='hs-varid'>ptr</span><span class='hs-layout'>,</span> <span class='hs-varid'>len</span><span class='hs-layout'>)</span>
<a name="line-269"></a> <span class='hs-varid'>return</span> <span class='hs-layout'>(</span><span class='hs-varid'>str</span><span class='hs-layout'>,</span> <span class='hs-varid'>sockaddr</span><span class='hs-layout'>)</span>
<a name="line-270"></a>
<a name="line-271"></a><span class='hs-comment'>-- ----------------------------------------------------------------------------</span>
<a name="line-272"></a><span class='hs-comment'>-- Not exported</span>
<a name="line-273"></a>
<a name="line-274"></a>
<a name="line-275"></a><a name="remainingChunks"></a><span class='hs-comment'>{-# LINE 270 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-276"></a><span class='hs-comment'>-- | Suppose we try to transmit a list of chunks @cs@ via a gathering write</span>
<a name="line-277"></a><span class='hs-comment'>-- operation and find that @n@ bytes were sent. Then @remainingChunks n cs@ is</span>
<a name="line-278"></a><span class='hs-comment'>-- list of chunks remaining to be sent.</span>
<a name="line-279"></a><span class='hs-definition'>remainingChunks</span> <span class='hs-keyglyph'>::</span> <span class='hs-conid'>Int</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span>
<a name="line-280"></a><span class='hs-definition'>remainingChunks</span> <span class='hs-keyword'>_</span> <span class='hs-conid'>[]</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>[]</span>
<a name="line-281"></a><span class='hs-definition'>remainingChunks</span> <span class='hs-varid'>i</span> <span class='hs-layout'>(</span><span class='hs-varid'>x</span><span class='hs-conop'>:</span><span class='hs-varid'>xs</span><span class='hs-layout'>)</span>
<a name="line-282"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>i</span> <span class='hs-varop'><</span> <span class='hs-varid'>len</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>drop</span> <span class='hs-varid'>i</span> <span class='hs-varid'>x</span> <span class='hs-conop'>:</span> <span class='hs-varid'>xs</span>
<a name="line-283"></a> <span class='hs-keyglyph'>|</span> <span class='hs-varid'>otherwise</span> <span class='hs-keyglyph'>=</span> <span class='hs-keyword'>let</span> <span class='hs-varid'>i'</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>i</span> <span class='hs-comment'>-</span> <span class='hs-varid'>len</span> <span class='hs-keyword'>in</span> <span class='hs-varid'>i'</span> <span class='hs-varop'>`seq`</span> <span class='hs-varid'>remainingChunks</span> <span class='hs-varid'>i'</span> <span class='hs-varid'>xs</span>
<a name="line-284"></a> <span class='hs-keyword'>where</span>
<a name="line-285"></a> <span class='hs-varid'>len</span> <span class='hs-keyglyph'>=</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>length</span> <span class='hs-varid'>x</span>
<a name="line-286"></a>
<a name="line-287"></a><a name="totalLength"></a><span class='hs-comment'>-- | @totalLength cs@ is the sum of the lengths of the chunks in the list @cs@.</span>
<a name="line-288"></a><span class='hs-definition'>totalLength</span> <span class='hs-keyglyph'>::</span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>Int</span>
<a name="line-289"></a><span class='hs-definition'>totalLength</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>sum</span> <span class='hs-varop'>.</span> <span class='hs-varid'>map</span> <span class='hs-conid'>B</span><span class='hs-varop'>.</span><span class='hs-varid'>length</span>
<a name="line-290"></a>
<a name="line-291"></a><a name="withIOVec"></a><span class='hs-comment'>-- | @withIOVec cs f@ executes the computation @f@, passing as argument a pair</span>
<a name="line-292"></a><span class='hs-comment'>-- consisting of a pointer to a temporarily allocated array of pointers to</span>
<a name="line-293"></a><span class='hs-comment'>-- 'IOVec' made from @cs@ and the number of pointers (@length cs@).</span>
<a name="line-294"></a><span class='hs-comment'>-- /Unix only/.</span>
<a name="line-295"></a><span class='hs-definition'>withIOVec</span> <span class='hs-keyglyph'>::</span> <span class='hs-keyglyph'>[</span><span class='hs-conid'>ByteString</span><span class='hs-keyglyph'>]</span> <span class='hs-keyglyph'>-></span> <span class='hs-layout'>(</span><span class='hs-layout'>(</span><span class='hs-conid'>Ptr</span> <span class='hs-conid'>IOVec</span><span class='hs-layout'>,</span> <span class='hs-conid'>Int</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-varid'>a</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span> <span class='hs-conid'>IO</span> <span class='hs-varid'>a</span>
<a name="line-296"></a><span class='hs-definition'>withIOVec</span> <span class='hs-varid'>cs</span> <span class='hs-varid'>f</span> <span class='hs-keyglyph'>=</span>
<a name="line-297"></a> <span class='hs-varid'>allocaArray</span> <span class='hs-varid'>csLen</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-varid'>aPtr</span> <span class='hs-keyglyph'>-></span> <span class='hs-keyword'>do</span>
<a name="line-298"></a> <span class='hs-varid'>zipWithM_</span> <span class='hs-varid'>pokeIov</span> <span class='hs-layout'>(</span><span class='hs-varid'>ptrs</span> <span class='hs-varid'>aPtr</span><span class='hs-layout'>)</span> <span class='hs-varid'>cs</span>
<a name="line-299"></a> <span class='hs-varid'>f</span> <span class='hs-layout'>(</span><span class='hs-varid'>aPtr</span><span class='hs-layout'>,</span> <span class='hs-varid'>csLen</span><span class='hs-layout'>)</span>
<a name="line-300"></a> <span class='hs-keyword'>where</span>
<a name="line-301"></a> <span class='hs-varid'>csLen</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>length</span> <span class='hs-varid'>cs</span>
<a name="line-302"></a> <span class='hs-varid'>ptrs</span> <span class='hs-keyglyph'>=</span> <span class='hs-varid'>iterate</span> <span class='hs-layout'>(</span><span class='hs-varop'>`plusPtr`</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'>IOVec</span><span class='hs-layout'>)</span><span class='hs-layout'>)</span>
<a name="line-303"></a> <span class='hs-varid'>pokeIov</span> <span class='hs-varid'>ptr</span> <span class='hs-varid'>s</span> <span class='hs-keyglyph'>=</span>
<a name="line-304"></a> <span class='hs-varid'>unsafeUseAsCStringLen</span> <span class='hs-varid'>s</span> <span class='hs-varop'>$</span> <span class='hs-keyglyph'>\</span><span class='hs-layout'>(</span><span class='hs-varid'>sPtr</span><span class='hs-layout'>,</span> <span class='hs-varid'>sLen</span><span class='hs-layout'>)</span> <span class='hs-keyglyph'>-></span>
<a name="line-305"></a> <span class='hs-varid'>poke</span> <span class='hs-varid'>ptr</span> <span class='hs-varop'>$</span> <span class='hs-conid'>IOVec</span> <span class='hs-varid'>sPtr</span> <span class='hs-layout'>(</span><span class='hs-varid'>fromIntegral</span> <span class='hs-varid'>sLen</span><span class='hs-layout'>)</span>
<a name="line-306"></a>
<a name="line-307"></a><span class='hs-comment'>{-# LINE 301 "Network/Socket/ByteString.hsc" #-}</span>
<a name="line-308"></a>
<a name="line-309"></a><span class='hs-comment'>-- ---------------------------------------------------------------------</span>
<a name="line-310"></a><span class='hs-comment'>-- Example</span>
<a name="line-311"></a>
<a name="line-312"></a><span class='hs-comment'>-- $example</span>
<a name="line-313"></a><span class='hs-comment'>--</span>
<a name="line-314"></a><span class='hs-comment'>-- Here are two minimal example programs using the TCP/IP protocol: a</span>
<a name="line-315"></a><span class='hs-comment'>-- server that echoes all data that it receives back (servicing only</span>
<a name="line-316"></a><span class='hs-comment'>-- one client) and a client using it.</span>
<a name="line-317"></a><span class='hs-comment'>--</span>
<a name="line-318"></a><span class='hs-comment'>-- > -- Echo server program</span>
<a name="line-319"></a><span class='hs-comment'>-- > module Main where</span>
<a name="line-320"></a><span class='hs-comment'>-- ></span>
<a name="line-321"></a><span class='hs-comment'>-- > import Control.Monad (unless)</span>
<a name="line-322"></a><span class='hs-comment'>-- > import Network.Socket hiding (recv)</span>
<a name="line-323"></a><span class='hs-comment'>-- > import qualified Data.ByteString as S</span>
<a name="line-324"></a><span class='hs-comment'>-- > import Network.Socket.ByteString (recv, sendAll)</span>
<a name="line-325"></a><span class='hs-comment'>-- ></span>
<a name="line-326"></a><span class='hs-comment'>-- > main :: IO ()</span>
<a name="line-327"></a><span class='hs-comment'>-- > main = withSocketsDo $</span>
<a name="line-328"></a><span class='hs-comment'>-- > do addrinfos <- getAddrInfo</span>
<a name="line-329"></a><span class='hs-comment'>-- > (Just (defaultHints {addrFlags = [AI_PASSIVE]}))</span>
<a name="line-330"></a><span class='hs-comment'>-- > Nothing (Just "3000")</span>
<a name="line-331"></a><span class='hs-comment'>-- > let serveraddr = head addrinfos</span>
<a name="line-332"></a><span class='hs-comment'>-- > sock <- socket (addrFamily serveraddr) Stream defaultProtocol</span>
<a name="line-333"></a><span class='hs-comment'>-- > bind sock (addrAddress serveraddr)</span>
<a name="line-334"></a><span class='hs-comment'>-- > listen sock 1</span>
<a name="line-335"></a><span class='hs-comment'>-- > (conn, _) <- accept sock</span>
<a name="line-336"></a><span class='hs-comment'>-- > talk conn</span>
<a name="line-337"></a><span class='hs-comment'>-- > close conn</span>
<a name="line-338"></a><span class='hs-comment'>-- > close sock</span>
<a name="line-339"></a><span class='hs-comment'>-- ></span>
<a name="line-340"></a><span class='hs-comment'>-- > where</span>
<a name="line-341"></a><span class='hs-comment'>-- > talk :: Socket -> IO ()</span>
<a name="line-342"></a><span class='hs-comment'>-- > talk conn =</span>
<a name="line-343"></a><span class='hs-comment'>-- > do msg <- recv conn 1024</span>
<a name="line-344"></a><span class='hs-comment'>-- > unless (S.null msg) $ sendAll conn msg >> talk conn</span>
<a name="line-345"></a><span class='hs-comment'>--</span>
<a name="line-346"></a><span class='hs-comment'>-- > -- Echo client program</span>
<a name="line-347"></a><span class='hs-comment'>-- > module Main where</span>
<a name="line-348"></a><span class='hs-comment'>-- ></span>
<a name="line-349"></a><span class='hs-comment'>-- > import Network.Socket hiding (recv)</span>
<a name="line-350"></a><span class='hs-comment'>-- > import Network.Socket.ByteString (recv, sendAll)</span>
<a name="line-351"></a><span class='hs-comment'>-- > import qualified Data.ByteString.Char8 as C</span>
<a name="line-352"></a><span class='hs-comment'>-- ></span>
<a name="line-353"></a><span class='hs-comment'>-- > main :: IO ()</span>
<a name="line-354"></a><span class='hs-comment'>-- > main = withSocketsDo $</span>
<a name="line-355"></a><span class='hs-comment'>-- > do addrinfos <- getAddrInfo Nothing (Just "") (Just "3000")</span>
<a name="line-356"></a><span class='hs-comment'>-- > let serveraddr = head addrinfos</span>
<a name="line-357"></a><span class='hs-comment'>-- > sock <- socket (addrFamily serveraddr) Stream defaultProtocol</span>
<a name="line-358"></a><span class='hs-comment'>-- > connect sock (addrAddress serveraddr)</span>
<a name="line-359"></a><span class='hs-comment'>-- > sendAll sock $ C.pack "Hello, world!"</span>
<a name="line-360"></a><span class='hs-comment'>-- > msg <- recv sock 1024</span>
<a name="line-361"></a><span class='hs-comment'>-- > close sock</span>
<a name="line-362"></a><span class='hs-comment'>-- > putStr "Received "</span>
<a name="line-363"></a><span class='hs-comment'>-- > C.putStrLn msg</span>
</pre></body>
</html>
|