<?xml version="1.0" encoding="iso-8859-1"?>
<!DOCTYPE html
PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html>
<head>
<title>read (Rumai::IXP::Agent::FidStream)</title>
<meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1" />
<link rel="stylesheet" href="../../../../.././rdoc-style.css" type="text/css" media="screen" />
</head>
<body class="standalone-code">
<pre><span class="ruby-comment cmt"># File lib/rumai/ixp/transport.rb, line 222</span>
<span class="ruby-keyword kw">def</span> <span class="ruby-identifier">read</span> <span class="ruby-identifier">aPartial</span> = <span class="ruby-keyword kw">false</span>
<span class="ruby-identifier">raise</span> <span class="ruby-value str">'cannot read from a closed stream'</span> <span class="ruby-keyword kw">if</span> <span class="ruby-ivar">@closed</span>
<span class="ruby-identifier">content</span> = <span class="ruby-value str">''</span>
<span class="ruby-keyword kw">begin</span>
<span class="ruby-identifier">req</span> = <span class="ruby-constant">Tread</span>.<span class="ruby-identifier">new</span>(
<span class="ruby-identifier">:fid</span> =<span class="ruby-operator">></span> <span class="ruby-ivar">@fid</span>,
<span class="ruby-identifier">:offset</span> =<span class="ruby-operator">></span> <span class="ruby-ivar">@pos</span>,
<span class="ruby-identifier">:count</span> =<span class="ruby-operator">></span> <span class="ruby-ivar">@msize</span>
)
<span class="ruby-identifier">rsp</span> = <span class="ruby-ivar">@agent</span>.<span class="ruby-identifier">talk</span>(<span class="ruby-identifier">req</span>)
<span class="ruby-identifier">content</span> <span class="ruby-operator"><<</span> <span class="ruby-identifier">rsp</span>.<span class="ruby-identifier">data</span>
<span class="ruby-identifier">count</span> = <span class="ruby-identifier">rsp</span>.<span class="ruby-identifier">count</span>
<span class="ruby-ivar">@pos</span> <span class="ruby-operator">+=</span> <span class="ruby-identifier">count</span>
<span class="ruby-keyword kw">end</span> <span class="ruby-keyword kw">until</span> <span class="ruby-ivar">@eof</span> = <span class="ruby-identifier">count</span>.<span class="ruby-identifier">zero?</span> <span class="ruby-keyword kw">or</span> <span class="ruby-identifier">aPartial</span>
<span class="ruby-comment cmt"># the content of a directory is a sequence</span>
<span class="ruby-comment cmt"># of Stat for all files in that directory</span>
<span class="ruby-keyword kw">if</span> <span class="ruby-ivar">@stat</span>.<span class="ruby-identifier">directory?</span>
<span class="ruby-identifier">buffer</span> = <span class="ruby-constant">StringIO</span>.<span class="ruby-identifier">new</span>(<span class="ruby-identifier">content</span>)
<span class="ruby-identifier">content</span> = []
<span class="ruby-keyword kw">until</span> <span class="ruby-identifier">buffer</span>.<span class="ruby-identifier">eof?</span>
<span class="ruby-identifier">content</span> <span class="ruby-operator"><<</span> <span class="ruby-constant">Stat</span>.<span class="ruby-identifier">from_9p</span>(<span class="ruby-identifier">buffer</span>)
<span class="ruby-keyword kw">end</span>
<span class="ruby-keyword kw">end</span>
<span class="ruby-identifier">content</span>
<span class="ruby-keyword kw">end</span></pre>
</body>
</html>