Added docs for base: BoolSet

git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@1565 e03df62e-2008-0410-955e-edbf42e46eb7

1 files changed, 272 insertions, 229 deletions

diff --git a/docs/module-doc/classserverrec.html b/docs/module-doc/classserverrec.html
index 4eab4d420..87775403b 100644
--- a/docs/module-doc/classserverrec.html
+++ b/docs/module-doc/classserverrec.html
@@ -384,7 +384,7 @@ Begin an outbound link to another ircd at targethost.
 <p>
 Definition at line <a class="el" href="servers_8cpp-source.html#l00142">142</a> of file <a class="el" href="servers_8cpp-source.html">servers.cpp</a>.
 <p>
-References <a class="el" href="servers_8h-source.html#l00081">connectors</a>, <a class="el" href="connection_8h-source.html#l00301">connection::fd</a>, <a class="el" href="servers_8cpp-source.html#l00242">FindHost()</a>, <a class="el" href="classircd__connector.html#a1">ircd_connector::MakeOutboundConnection()</a>, <a class="el" href="servers_8cpp-source.html#l00336">SendPacket()</a>, <a class="el" href="classircd__connector.html#a13">ircd_connector::SetHostAndPort()</a>, <a class="el" href="classircd__connector.html#a3">ircd_connector::SetServerName()</a>, <a class="el" href="classircd__connector.html#a7">ircd_connector::SetState()</a>, <a class="el" href="connection_8h-source.html#l00035">STATE_DISCONNECTED</a>, and <a class="el" href="connection_8h-source.html#l00039">STATE_NOAUTH_OUTBOUND</a>.
+References <a class="el" href="servers_8h-source.html#l00081">connectors</a>, <a class="el" href="connection_8h-source.html#l00301">connection::fd</a>, <a class="el" href="servers_8cpp-source.html#l00242">FindHost()</a>, <a class="el" href="classircd__connector.html#a1">ircd_connector::MakeOutboundConnection()</a>, <a class="el" href="servers_8cpp-source.html#l00350">SendPacket()</a>, <a class="el" href="classircd__connector.html#a13">ircd_connector::SetHostAndPort()</a>, <a class="el" href="classircd__connector.html#a3">ircd_connector::SetServerName()</a>, <a class="el" href="classircd__connector.html#a7">ircd_connector::SetState()</a>, <a class="el" href="connection_8h-source.html#l00035">STATE_DISCONNECTED</a>, and <a class="el" href="connection_8h-source.html#l00039">STATE_NOAUTH_OUTBOUND</a>.
 <p>
 <div class="fragment"><pre>00143 {
 00144         <span class="keywordtype">char</span> connect[MAXBUF];
@@ -564,7 +564,7 @@ Definition at line <a class="el" href="servers_8cpp-source.html#l00242">242</a>
 <p>
 References <a class="el" href="servers_8h-source.html#l00081">connectors</a>.
 <p>
-Referenced by <a class="el" href="servers_8cpp-source.html#l00142">BeginLink()</a>, <a class="el" href="servers_8cpp-source.html#l00256">IsRoutable()</a>, and <a class="el" href="servers_8cpp-source.html#l00336">SendPacket()</a>.
+Referenced by <a class="el" href="servers_8cpp-source.html#l00142">BeginLink()</a>, and <a class="el" href="servers_8cpp-source.html#l00350">SendPacket()</a>.
 <p>
 <div class="fragment"><pre>00243 {
 00244         <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>.size(); i++)
@@ -608,60 +608,84 @@ Flushes all data waiting to be written for all of this server's connections.
 <p>
 
 <p>
-Definition at line <a class="el" href="servers_8cpp-source.html#l00284">284</a> of file <a class="el" href="servers_8cpp-source.html">servers.cpp</a>.
+Definition at line <a class="el" href="servers_8cpp-source.html#l00274">274</a> of file <a class="el" href="servers_8cpp-source.html">servers.cpp</a>.
 <p>
 References <a class="el" href="servers_8h-source.html#l00081">connectors</a>, <a class="el" href="servers_8cpp-source.html#l00042">has_been_netsplit</a>, <a class="el" href="servers_8cpp-source.html#l00256">IsRoutable()</a>, <a class="el" href="connection_8h-source.html#l00035">STATE_DISCONNECTED</a>, <a class="el" href="connection_8h-source.html#l00038">STATE_NOAUTH_INBOUND</a>, <a class="el" href="connection_8h-source.html#l00039">STATE_NOAUTH_OUTBOUND</a>, and <a class="el" href="channels_8cpp-source.html#l00101">TIME</a>.
 <p>
-<div class="fragment"><pre>00285 {
-00286         <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>.size(); i++)
-00287         {
-00288                 <span class="comment">// don't try and ping a NOAUTH_OUTBOUND state, its not authed yet!</span>
-00289                 <span class="keywordflow">if</span> ((this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].GetState() == <a class="code" href="connection_8h.html#a4">STATE_NOAUTH_OUTBOUND</a>) &amp;&amp; (<a class="code" href="channels_8cpp.html#a36">TIME</a> &gt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].age+30))
+<div class="fragment"><pre>00275 {
+00276         <span class="keywordtype">char</span> buffer[MAXBUF];
+00277         <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>.size(); i++)
+00278         {
+00279                 <span class="comment">// don't try and ping a NOAUTH_OUTBOUND state, its not authed yet!</span>
+00280                 <span class="keywordflow">if</span> ((this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].GetState() == <a class="code" href="connection_8h.html#a4">STATE_NOAUTH_OUTBOUND</a>) &amp;&amp; (<a class="code" href="channels_8cpp.html#a36">TIME</a> &gt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].age+30))
+00281                 {
+00282                         <span class="comment">// however if we reach this timer its connected timed out :)</span>
+00283                         WriteOpers(<span class="stringliteral">"*** Connection to %s timed out"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00284                         snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00285                         NetSendToAllExcept(this-&gt;connectors[i].GetServerName().c_str(),buffer);
+00286                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
+00287                         <span class="keywordflow">return</span>;
+00288                 }
+00289                 <span class="keywordflow">if</span> ((this-&gt;connectors[i].GetState() == <a class="code" href="connection_8h.html#a3">STATE_NOAUTH_INBOUND</a>) &amp;&amp; (<a class="code" href="channels_8cpp.html#a36">TIME</a> &gt; this-&gt;connectors[i].age+30))
 00290                 {
-00291                         <span class="comment">// however if we reach this timer its connected timed out :)</span>
-00292                         WriteOpers(<span class="stringliteral">"*** Connection to %s timed out"</span>,this-&gt;connectors[i].GetServerName().c_str());
-00293                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
-00294                         <span class="keywordflow">return</span>;
-00295                 }
-00296                 <span class="keywordflow">else</span> <span class="keywordflow">if</span> ((this-&gt;connectors[i].GetState() == <a class="code" href="connection_8h.html#a3">STATE_NOAUTH_INBOUND</a>) &amp;&amp; (<a class="code" href="channels_8cpp.html#a36">TIME</a> &gt; this-&gt;connectors[i].age+30))
-00297                 {
-00298                         WriteOpers(<span class="stringliteral">"*** Connection from %s timed out"</span>,this-&gt;connectors[i].GetServerName().c_str());
-00299                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
-00300                         <span class="keywordflow">return</span>;
-00301                 }
-00302                 <span class="keywordflow">else</span> <span class="keywordflow">if</span> (this-&gt;connectors[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>)
-00303                 {
-00304                         <span class="keywordflow">if</span> (!this-&gt;connectors[i].CheckPing())
-00305                         {
-00306                                 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s: Ping timeout"</span>,this-&gt;connectors[i].GetServerName().c_str());
-00307                                 this-&gt;connectors[i].CloseConnection();
-00308                                 this-&gt;connectors[i].SetState(STATE_DISCONNECTED);
-00309                                 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
-00310                                 {
-00311                                         WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
-00312                                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
-00313                                 }
-00314                                 <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
-00315                         }
-00316                 }
-00317                 <span class="keywordflow">if</span> (this-&gt;connectors[i].HasBufferedOutput())
-00318                 {
-00319                         <span class="keywordflow">if</span> (!this-&gt;connectors[i].FlushWriteBuf())
-00320                         {
-00321                                 <span class="comment">// if we're here the write() caused an error, we cannot proceed</span>
-00322                                 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,this-&gt;connectors[i].GetServerName().c_str(),this-&gt;connectors[i].GetWriteError().c_str());
-00323                                 this-&gt;connectors[i].CloseConnection();
-00324                                 this-&gt;connectors[i].SetState(STATE_DISCONNECTED);
-00325                                 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
-00326                                 {
-00327                                         WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
-00328                                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
-00329                                 }
-00330                                 <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
-00331                         }
-00332                 }
-00333         }
-00334 }
+00291                         WriteOpers(<span class="stringliteral">"*** Connection from %s timed out"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00292                         snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00293                         NetSendToAllExcept(this-&gt;connectors[i].GetServerName().c_str(),buffer);
+00294                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
+00295                         <span class="keywordflow">return</span>;
+00296                 }
+00297                 <span class="keywordflow">if</span> (this-&gt;connectors[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>)
+00298                 {
+00299                         <span class="keywordflow">if</span> (!this-&gt;connectors[i].CheckPing())
+00300                         {
+00301                                 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s: Ping timeout"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00302                                 this-&gt;connectors[i].CloseConnection();
+00303                                 this-&gt;connectors[i].SetState(STATE_DISCONNECTED);
+00304                                 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
+00305                                 {
+00306                                         WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
+00307                                         snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00308                                         NetSendToAllExcept(this-&gt;connectors[i].GetServerName().c_str(),buffer);
+00309                                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
+00310                                 }
+00311                                 <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
+00312                         }
+00313                 }
+00314                 <span class="keywordflow">if</span> ((this-&gt;connectors[i].GetWriteError() !=<span class="stringliteral">""</span>) &amp;&amp; (this-&gt;connectors[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>))
+00315                 {
+00316                         <span class="comment">// if we're here the write() caused an error, we cannot proceed</span>
+00317                         WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,this-&gt;connectors[i].GetServerName().c_str(),this-&gt;connectors[i].GetWriteError().c_str());
+00318                         this-&gt;connectors[i].CloseConnection();
+00319                         this-&gt;connectors[i].SetState(STATE_DISCONNECTED);
+00320                         <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
+00321                         {
+00322                                 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
+00323                                 snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00324                                 NetSendToAllExcept(this-&gt;connectors[i].GetServerName().c_str(),buffer);
+00325                                 DoSplit(this-&gt;connectors[i].GetServerName().c_str());
+00326                         }
+00327                         <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
+00328                 }
+00329                 <span class="keywordflow">if</span> ((this-&gt;connectors[i].HasBufferedOutput()) &amp;&amp; (this-&gt;connectors[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>))
+00330                 {
+00331                         <span class="keywordflow">if</span> (!this-&gt;connectors[i].FlushWriteBuf())
+00332                         {
+00333                                 <span class="comment">// if we're here the write() caused an error, we cannot proceed</span>
+00334                                 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,this-&gt;connectors[i].GetServerName().c_str(),this-&gt;connectors[i].GetWriteError().c_str());
+00335                                 this-&gt;connectors[i].CloseConnection();
+00336                                 this-&gt;connectors[i].SetState(STATE_DISCONNECTED);
+00337                                 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
+00338                                 {
+00339                                         WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
+00340                                         snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00341                                         NetSendToAllExcept(this-&gt;connectors[i].GetServerName().c_str(),buffer);
+00342                                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
+00343                                 }
+00344                                 <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
+00345                         }
+00346                 }
+00347         }
+00348 }
 </pre></div>    </td>
   </tr>
 </table>
@@ -718,7 +742,7 @@ Begin an outbound mesh link to another ircd on a network you are already an auth
 <p>
 Definition at line <a class="el" href="servers_8cpp-source.html#l00182">182</a> of file <a class="el" href="servers_8cpp-source.html">servers.cpp</a>.
 <p>
-References <a class="el" href="servers_8h-source.html#l00081">connectors</a>, <a class="el" href="connection_8h-source.html#l00301">connection::fd</a>, <a class="el" href="classircd__connector.html#a1">ircd_connector::MakeOutboundConnection()</a>, <a class="el" href="servers_8cpp-source.html#l00336">SendPacket()</a>, <a class="el" href="classircd__connector.html#a13">ircd_connector::SetHostAndPort()</a>, <a class="el" href="classircd__connector.html#a3">ircd_connector::SetServerName()</a>, <a class="el" href="classircd__connector.html#a7">ircd_connector::SetState()</a>, <a class="el" href="connection_8h-source.html#l00035">STATE_DISCONNECTED</a>, and <a class="el" href="connection_8h-source.html#l00039">STATE_NOAUTH_OUTBOUND</a>.
+References <a class="el" href="servers_8h-source.html#l00081">connectors</a>, <a class="el" href="connection_8h-source.html#l00301">connection::fd</a>, <a class="el" href="classircd__connector.html#a1">ircd_connector::MakeOutboundConnection()</a>, <a class="el" href="servers_8cpp-source.html#l00350">SendPacket()</a>, <a class="el" href="classircd__connector.html#a13">ircd_connector::SetHostAndPort()</a>, <a class="el" href="classircd__connector.html#a3">ircd_connector::SetServerName()</a>, <a class="el" href="classircd__connector.html#a7">ircd_connector::SetState()</a>, <a class="el" href="connection_8h-source.html#l00035">STATE_DISCONNECTED</a>, and <a class="el" href="connection_8h-source.html#l00039">STATE_NOAUTH_OUTBOUND</a>.
 <p>
 <div class="fragment"><pre>00183 {
 00184         <span class="keywordtype">char</span> connect[MAXBUF];
@@ -796,107 +820,126 @@ Returns the next available packet and returns true if data is available.
 <p>
 Writes the servername the data came from to 'host'. If no data is available this function returns false. This function will automatically close broken links and reroute pathways, generating split messages on the network. 
 <p>
-Definition at line <a class="el" href="servers_8cpp-source.html#l00431">431</a> of file <a class="el" href="servers_8cpp-source.html">servers.cpp</a>.
-<p>
-References <a class="el" href="servers_8cpp-source.html#l00411">already_have_sum()</a>, <a class="el" href="servers_8h-source.html#l00081">connectors</a>, <a class="el" href="modules_8h-source.html#l00023">DEBUG</a>, <a class="el" href="servers_8cpp-source.html#l00042">has_been_netsplit</a>, <a class="el" href="servers_8cpp-source.html#l00256">IsRoutable()</a>, and <a class="el" href="connection_8h-source.html#l00035">STATE_DISCONNECTED</a>.
-<p>
-<div class="fragment"><pre>00432 {
-00433         <span class="keywordtype">char</span> data[65536];
-00434         memset(data, 0, 65536);
-00435         <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>.size(); i++)
-00436         {
-00437                 <span class="keywordflow">if</span> (this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>)
-00438                 {
-00439                         <span class="comment">// returns false if the packet could not be sent (e.g. target host down)</span>
-00440                         <span class="keywordtype">int</span> rcvsize = 0;
-00441 
-00442                         <span class="comment">// check if theres any data on this socket</span>
-00443                         <span class="comment">// if not, continue onwards to the next.</span>
-00444                         pollfd polls;
-00445                         polls.fd = this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].GetDescriptor();
-00446                         polls.events = POLLIN;
-00447                         <span class="keywordtype">int</span> ret = poll(&amp;polls,1,1);
-00448                         <span class="keywordflow">if</span> (ret &lt;= 0) <span class="keywordflow">continue</span>;
-00449 
-00450                         rcvsize = recv(this-&gt;connectors[i].GetDescriptor(),data,65000,0);
-00451                         data[rcvsize] = <span class="charliteral">'\0'</span>;
-00452                         <span class="keywordflow">if</span> (rcvsize == -1)
-00453                         {
-00454                                 <span class="keywordflow">if</span> (errno != EAGAIN)
-00455                                 {
-00456                                         log(DEBUG,<span class="stringliteral">"recv() failed for serverrec::RecvPacket(): %s"</span>,strerror(errno));
-00457                                         log(DEBUG,<span class="stringliteral">"Disabling connector: %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
-00458                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection();
-00459                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(STATE_DISCONNECTED);
-00460                                         <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
-00461                                         {
-00462                                                 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
-00463                                                 DoSplit(this-&gt;connectors[i].GetServerName().c_str());
-00464                                         }
-00465                                         <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
-00466                                 }
-00467                         }
-00468                         <span class="keywordtype">int</span> pushed = 0;
-00469                         <span class="keywordflow">if</span> (rcvsize &gt; 0)
-00470                         {
-00471                                 <span class="keywordflow">if</span> (!this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].AddBuffer(data))
-00472                                 {
-00473                                         WriteOpers(<span class="stringliteral">"*** Read buffer for %s exceeds maximum, closing connection!"</span>,this-&gt;connectors[i].GetServerName().c_str());
-00474                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection();
-00475                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(STATE_DISCONNECTED);
-00476                                         <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
-00477                                         {
-00478                                                 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
-00479                                                 DoSplit(this-&gt;connectors[i].GetServerName().c_str());
-00480                                         }
-00481                                         <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
-00482                                 }
-00483                                 <span class="keywordflow">if</span> (this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].BufferIsComplete())
+Definition at line <a class="el" href="servers_8cpp-source.html#l00445">445</a> of file <a class="el" href="servers_8cpp-source.html">servers.cpp</a>.
+<p>
+References <a class="el" href="servers_8cpp-source.html#l00425">already_have_sum()</a>, <a class="el" href="servers_8h-source.html#l00081">connectors</a>, <a class="el" href="modules_8h-source.html#l00023">DEBUG</a>, <a class="el" href="servers_8cpp-source.html#l00042">has_been_netsplit</a>, <a class="el" href="servers_8cpp-source.html#l00256">IsRoutable()</a>, and <a class="el" href="connection_8h-source.html#l00035">STATE_DISCONNECTED</a>.
+<p>
+<div class="fragment"><pre>00446 {
+00447         <span class="keywordtype">char</span> data[65536],buffer[MAXBUF];
+00448         memset(data, 0, 65536);
+00449         <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>.size(); i++)
+00450         {
+00451                 <span class="keywordflow">if</span> (this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>)
+00452                 {
+00453                         <span class="comment">// returns false if the packet could not be sent (e.g. target host down)</span>
+00454                         <span class="keywordtype">int</span> rcvsize = 0;
+00455 
+00456                         <span class="comment">// check if theres any data on this socket</span>
+00457                         <span class="comment">// if not, continue onwards to the next.</span>
+00458                         pollfd polls;
+00459                         polls.fd = this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].GetDescriptor();
+00460                         polls.events = POLLIN;
+00461                         <span class="keywordtype">int</span> ret = poll(&amp;polls,1,1);
+00462                         <span class="keywordflow">if</span> (ret &lt;= 0) <span class="keywordflow">continue</span>;
+00463 
+00464                         rcvsize = recv(this-&gt;connectors[i].GetDescriptor(),data,65000,0);
+00465                         data[rcvsize] = <span class="charliteral">'\0'</span>;
+00466                         <span class="keywordflow">if</span> (rcvsize == 0)
+00467                         {
+00468                                 log(DEBUG,<span class="stringliteral">"recv() failed for serverrec::RecvPacket(): EOF"</span>);
+00469                                 log(DEBUG,<span class="stringliteral">"Disabling connector: %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00470                                 this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection();
+00471                                 this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(STATE_DISCONNECTED);
+00472                                 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
+00473                                 {
+00474                                         WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting (EOF)"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00475                                         snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00476                                         NetSendToAllExcept(this-&gt;connectors[i].GetServerName().c_str(),buffer);
+00477                                         DoSplit(this-&gt;connectors[i].GetServerName().c_str());
+00478                                 }
+00479                                 <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
+00480                         }
+00481                         <span class="keywordflow">if</span> (rcvsize == -1)
+00482                         {
+00483                                 <span class="keywordflow">if</span> (errno != EAGAIN)
 00484                                 {
-00485                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].ResetPing();
-00486                                         <span class="keywordflow">while</span> (this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].BufferIsComplete())
-00487                                         {
-00488                                                 std::string text = this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].GetBuffer();
-00489                                                 <span class="keywordflow">if</span> (text != <span class="stringliteral">""</span>)
-00490                                                 {
-00491                                                         <span class="keywordflow">if</span> ((text[0] == <span class="charliteral">':'</span>) &amp;&amp; (text.find(<span class="stringliteral">" "</span>) != std::string::npos))
-00492                                                         {
-00493                                                                 std::string orig = text;
-00494                                                                 log(DEBUG,<span class="stringliteral">"Original: %s"</span>,text.c_str());
-00495                                                                 std::string sum = text.substr(1,text.find(<span class="stringliteral">" "</span>)-1);
-00496                                                                 text = text.substr(text.find(<span class="stringliteral">" "</span>)+1,text.length());
-00497                                                                 std::string possible_token = text.substr(1,text.find(<span class="stringliteral">" "</span>)-1);
-00498                                                                 <span class="keywordflow">if</span> (possible_token.length() &gt; 1)
-00499                                                                 {
-00500                                                                         sums.push_back(<span class="stringliteral">"*"</span>);
-00501                                                                         text = orig;
-00502                                                                         log(DEBUG,<span class="stringliteral">"Non-mesh, non-tokenized string passed up the chain"</span>);
-00503                                                                 }
-00504                                                                 <span class="keywordflow">else</span>
-00505                                                                 {
-00506                                                                         log(DEBUG,<span class="stringliteral">"Packet sum: '%s'"</span>,sum.c_str());
-00507                                                                         <span class="keywordflow">if</span> ((<a class="code" href="servers_8cpp.html#a6">already_have_sum</a>(sum)) &amp;&amp; (sum != <span class="stringliteral">"*"</span>))
-00508                                                                         {
-00509                                                                                 <span class="comment">// we don't accept dupes</span>
-00510                                                                                 <span class="keywordflow">continue</span>;
-00511                                                                         }
-00512                                                                         sums.push_back(sum.c_str());
-00513                                                                 }
-00514                                                         }
-00515                                                         <span class="keywordflow">else</span> sums.push_back(<span class="stringliteral">"*"</span>);
-00516                                                         messages.push_back(text.c_str());
-00517                                                         strlcpy(recvhost,this-&gt;connectors[i].GetServerName().c_str(),160);
-00518                                                         log(DEBUG,<span class="stringliteral">"serverrec::RecvPacket() %d:%s-&gt;%s"</span>,pushed++,recvhost,text.c_str());
-00519                                                 }
-00520                                         }
-00521                                         <span class="keywordflow">return</span> <span class="keyword">true</span>;
-00522                                 }
-00523                         }
-00524                 }
-00525         }
-00526         <span class="comment">// nothing new yet -- message and host will be undefined</span>
-00527         <span class="keywordflow">return</span> <span class="keyword">false</span>;
-00528 }
+00485                                         log(DEBUG,<span class="stringliteral">"recv() failed for serverrec::RecvPacket(): %s"</span>,strerror(errno));
+00486                                         log(DEBUG,<span class="stringliteral">"Disabling connector: %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00487                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection();
+00488                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(STATE_DISCONNECTED);
+00489                                         <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
+00490                                         {
+00491                                                 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
+00492                                                 snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00493                                                 NetSendToAllExcept(this-&gt;connectors[i].GetServerName().c_str(),buffer);
+00494                                                 DoSplit(this-&gt;connectors[i].GetServerName().c_str());
+00495                                         }
+00496                                         <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
+00497                                 }
+00498                         }
+00499                         <span class="keywordtype">int</span> pushed = 0;
+00500                         <span class="keywordflow">if</span> (rcvsize &gt; 0)
+00501                         {
+00502                                 <span class="keywordflow">if</span> (!this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].AddBuffer(data))
+00503                                 {
+00504                                         WriteOpers(<span class="stringliteral">"*** Read buffer for %s exceeds maximum, closing connection!"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00505                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection();
+00506                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(STATE_DISCONNECTED);
+00507                                         <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this-&gt;connectors[i].GetServerName()))
+00508                                         {
+00509                                                 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this-&gt;connectors[i].GetServerName().c_str());
+00510                                                 snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,this-&gt;connectors[i].GetServerName().c_str());
+00511                                                 NetSendToAllExcept(this-&gt;connectors[i].GetServerName().c_str(),buffer);
+00512                                                 DoSplit(this-&gt;connectors[i].GetServerName().c_str());
+00513                                         }
+00514                                         <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a> = <span class="keyword">true</span>;
+00515                                 }
+00516                                 <span class="keywordflow">if</span> (this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].BufferIsComplete())
+00517                                 {
+00518                                         this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].ResetPing();
+00519                                         <span class="keywordflow">while</span> (this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].BufferIsComplete())
+00520                                         {
+00521                                                 std::string text = this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[i].GetBuffer();
+00522                                                 <span class="keywordflow">if</span> (text != <span class="stringliteral">""</span>)
+00523                                                 {
+00524                                                         <span class="keywordflow">if</span> ((text[0] == <span class="charliteral">':'</span>) &amp;&amp; (text.find(<span class="stringliteral">" "</span>) != std::string::npos))
+00525                                                         {
+00526                                                                 std::string orig = text;
+00527                                                                 log(DEBUG,<span class="stringliteral">"Original: %s"</span>,text.c_str());
+00528                                                                 std::string sum = text.substr(1,text.find(<span class="stringliteral">" "</span>)-1);
+00529                                                                 text = text.substr(text.find(<span class="stringliteral">" "</span>)+1,text.length());
+00530                                                                 std::string possible_token = text.substr(1,text.find(<span class="stringliteral">" "</span>)-1);
+00531                                                                 <span class="keywordflow">if</span> (possible_token.length() &gt; 1)
+00532                                                                 {
+00533                                                                         sums.push_back(<span class="stringliteral">"*"</span>);
+00534                                                                         text = orig;
+00535                                                                         log(DEBUG,<span class="stringliteral">"Non-mesh, non-tokenized string passed up the chain"</span>);
+00536                                                                 }
+00537                                                                 <span class="keywordflow">else</span>
+00538                                                                 {
+00539                                                                         log(DEBUG,<span class="stringliteral">"Packet sum: '%s'"</span>,sum.c_str());
+00540                                                                         <span class="keywordflow">if</span> ((<a class="code" href="servers_8cpp.html#a6">already_have_sum</a>(sum)) &amp;&amp; (sum != <span class="stringliteral">"*"</span>))
+00541                                                                         {
+00542                                                                                 <span class="comment">// we don't accept dupes</span>
+00543                                                                                 <span class="keywordflow">continue</span>;
+00544                                                                         }
+00545                                                                         sums.push_back(sum.c_str());
+00546                                                                 }
+00547                                                         }
+00548                                                         <span class="keywordflow">else</span> sums.push_back(<span class="stringliteral">"*"</span>);
+00549                                                         messages.push_back(text.c_str());
+00550                                                         strlcpy(recvhost,this-&gt;connectors[i].GetServerName().c_str(),160);
+00551                                                         log(DEBUG,<span class="stringliteral">"serverrec::RecvPacket() %d:%s-&gt;%s"</span>,pushed++,recvhost,text.c_str());
+00552                                                 }
+00553                                         }
+00554                                         <span class="keywordflow">return</span> <span class="keyword">true</span>;
+00555                                 }
+00556                         }
+00557                 }
+00558         }
+00559         <span class="comment">// nothing new yet -- message and host will be undefined</span>
+00560         <span class="keywordflow">return</span> <span class="keyword">false</span>;
+00561 }
 </pre></div>    </td>
   </tr>
 </table>
@@ -939,85 +982,85 @@ Send a message to a server by name, if the server is unavailable directly route
 <p>
 
 <p>
-Definition at line <a class="el" href="servers_8cpp-source.html#l00336">336</a> of file <a class="el" href="servers_8cpp-source.html">servers.cpp</a>.
+Definition at line <a class="el" href="servers_8cpp-source.html#l00350">350</a> of file <a class="el" href="servers_8cpp-source.html">servers.cpp</a>.
 <p>
 References <a class="el" href="classircd__connector.html#a21">ircd_connector::AddWriteBuf()</a>, <a class="el" href="classircd__connector.html#a14">ircd_connector::CloseConnection()</a>, <a class="el" href="servers_8h-source.html#l00081">connectors</a>, <a class="el" href="modules_8h-source.html#l00023">DEBUG</a>, <a class="el" href="servers_8cpp-source.html#l00242">FindHost()</a>, <a class="el" href="classircd__connector.html#a22">ircd_connector::FlushWriteBuf()</a>, <a class="el" href="classircd__connector.html#a2">ircd_connector::GetServerName()</a>, <a class="el" href="classircd__connector.html#a6">ircd_connector::GetState()</a>, <a class="el" href="classircd__connector.html#a24">ircd_connector::GetWriteError()</a>, <a class="el" href="classircd__connector.html#a7">ircd_connector::SetState()</a>, and <a class="el" href="connection_8h-source.html#l00035">STATE_DISCONNECTED</a>.
 <p>
 Referenced by <a class="el" href="servers_8cpp-source.html#l00142">BeginLink()</a>, and <a class="el" href="servers_8cpp-source.html#l00182">MeshCookie()</a>.
 <p>
-<div class="fragment"><pre>00337 {
-00338         <span class="keywordflow">if</span> ((!message) || (!sendhost))
-00339                 <span class="keywordflow">return</span> <span class="keyword">true</span>;
-00340 
-00341         <a class="code" href="classircd__connector.html">ircd_connector</a>* cn = this-&gt;<a class="code" href="classserverrec.html#a9">FindHost</a>(sendhost);
-00342 
-00343         <span class="keywordflow">if</span> (!strchr(message,<span class="charliteral">'\n'</span>))
-00344         {
-00345                 strlcat(message,<span class="stringliteral">"\n"</span>,MAXBUF);
-00346         }
-00347 
-00348         <span class="keywordflow">if</span> (cn)
-00349         {
-00350                 log(DEBUG,<span class="stringliteral">"main: serverrec::SendPacket() sent '%s' to %s"</span>,message,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str());
-00351 
-00352                 <span class="keywordflow">if</span> (cn-&gt;<a class="code" href="classircd__connector.html#a6">GetState</a>() == <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>)
-00353                 {
-00354                         <span class="comment">// fix: can only route one hop to avoid a loop</span>
-00355                         <span class="keywordflow">if</span> (strncmp(message,<span class="stringliteral">"R "</span>,2))
-00356                         {
-00357                                 log(DEBUG,<span class="stringliteral">"Not a double reroute"</span>);
-00358                                 <span class="comment">// this route is down, we must re-route the packet through an available point in the mesh.</span>
-00359                                 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> k = 0; k &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>.size(); k++)
-00360                                 {
-00361                                         log(DEBUG,<span class="stringliteral">"Check connector %d: %s"</span>,k,this-&gt;connectors[k].GetServerName().c_str());
-00362                                         <span class="comment">// search for another point in the mesh which can 'reach' where we want to go</span>
-00363                                         <span class="keywordflow">for</span> (<span class="keywordtype">int</span> m = 0; m &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[k].routes.size(); m++)
-00364                                         {
-00365                                                 <span class="keywordflow">if</span> (!strcasecmp(this-&gt;connectors[k].routes[m].c_str(),sendhost))
-00366                                                 {
-00367                                                         log(DEBUG,<span class="stringliteral">"Found alternative route for packet: %s"</span>,this-&gt;connectors[k].GetServerName().c_str());
-00368                                                         <span class="keywordtype">char</span> buffer[MAXBUF];
-00369                                                         snprintf(buffer,MAXBUF,<span class="stringliteral">"R %s %s"</span>,sendhost,message);
-00370                                                         this-&gt;<a class="code" href="classserverrec.html#a7">SendPacket</a>(buffer,this-&gt;connectors[k].GetServerName().c_str());
-00371                                                         <span class="keywordflow">return</span> <span class="keyword">true</span>;
-00372                                                 }
-00373                                         }
-00374                                 }
-00375                         }
-00376                         <span class="keywordtype">char</span> buffer[MAXBUF];
-00377                         snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,sendhost);
-00378                         WriteOpers(<span class="stringliteral">"*** All connections to %s lost."</span>,sendhost);
-00379                         NetSendToAllExcept(sendhost,buffer);
-00380                         DoSplit(sendhost);
-00381                         <span class="keywordflow">return</span> <span class="keyword">false</span>;
-00382                 }
-00383 
-00384                 <span class="comment">// returns false if the packet could not be sent (e.g. target host down)</span>
-00385                 <span class="keywordflow">if</span> (!cn-&gt;<a class="code" href="classircd__connector.html#a21">AddWriteBuf</a>(message))
-00386                 {
-00387                         <span class="comment">// if we're here, there was an error pending, and the send cannot proceed</span>
-00388                         log(DEBUG,<span class="stringliteral">"cn-&gt;AddWriteBuf() failed for serverrec::SendPacket(): %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str());
-00389                         log(DEBUG,<span class="stringliteral">"Disabling connector: %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str());
-00390                         cn-&gt;<a class="code" href="classircd__connector.html#a14">CloseConnection</a>();
-00391                         cn-&gt;<a class="code" href="classircd__connector.html#a7">SetState</a>(STATE_DISCONNECTED);
-00392                         WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str(),cn-&gt;<a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str());
-00393                         <span class="comment">// retry the packet along a new route so either arrival OR failure are gauranteed (bugfix)</span>
-00394                         <span class="keywordflow">return</span> this-&gt;<a class="code" href="classserverrec.html#a7">SendPacket</a>(message,sendhost);
-00395                 }
-00396                 <span class="keywordflow">if</span> (!cn-&gt;<a class="code" href="classircd__connector.html#a22">FlushWriteBuf</a>())
-00397                 {
-00398                         <span class="comment">// if we're here the write() caused an error, we cannot proceed</span>
-00399                         log(DEBUG,<span class="stringliteral">"cn-&gt;FlushWriteBuf() failed for serverrec::SendPacket(): %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str());
-00400                         log(DEBUG,<span class="stringliteral">"Disabling connector: %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str());
-00401                         cn-&gt;<a class="code" href="classircd__connector.html#a14">CloseConnection</a>();
-00402                         cn-&gt;<a class="code" href="classircd__connector.html#a7">SetState</a>(STATE_DISCONNECTED);
-00403                         WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str(),cn-&gt;<a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str());
-00404                         <span class="comment">// retry the packet along a new route so either arrival OR failure are gauranteed</span>
-00405                         <span class="keywordflow">return</span> this-&gt;<a class="code" href="classserverrec.html#a7">SendPacket</a>(message,sendhost);
-00406                 }
-00407                 <span class="keywordflow">return</span> <span class="keyword">true</span>;
-00408         }
-00409 }
+<div class="fragment"><pre>00351 {
+00352         <span class="keywordflow">if</span> ((!message) || (!sendhost))
+00353                 <span class="keywordflow">return</span> <span class="keyword">true</span>;
+00354 
+00355         <a class="code" href="classircd__connector.html">ircd_connector</a>* cn = this-&gt;<a class="code" href="classserverrec.html#a9">FindHost</a>(sendhost);
+00356 
+00357         <span class="keywordflow">if</span> (!strchr(message,<span class="charliteral">'\n'</span>))
+00358         {
+00359                 strlcat(message,<span class="stringliteral">"\n"</span>,MAXBUF);
+00360         }
+00361 
+00362         <span class="keywordflow">if</span> (cn)
+00363         {
+00364                 log(DEBUG,<span class="stringliteral">"main: serverrec::SendPacket() sent '%s' to %s"</span>,message,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str());
+00365 
+00366                 <span class="keywordflow">if</span> (cn-&gt;<a class="code" href="classircd__connector.html#a6">GetState</a>() == <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>)
+00367                 {
+00368                         <span class="comment">// fix: can only route one hop to avoid a loop</span>
+00369                         <span class="keywordflow">if</span> (strncmp(message,<span class="stringliteral">"R "</span>,2))
+00370                         {
+00371                                 log(DEBUG,<span class="stringliteral">"Not a double reroute"</span>);
+00372                                 <span class="comment">// this route is down, we must re-route the packet through an available point in the mesh.</span>
+00373                                 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> k = 0; k &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>.size(); k++)
+00374                                 {
+00375                                         log(DEBUG,<span class="stringliteral">"Check connector %d: %s"</span>,k,this-&gt;connectors[k].GetServerName().c_str());
+00376                                         <span class="comment">// search for another point in the mesh which can 'reach' where we want to go</span>
+00377                                         <span class="keywordflow">for</span> (<span class="keywordtype">int</span> m = 0; m &lt; this-&gt;<a class="code" href="classserverrec.html#o11">connectors</a>[k].routes.size(); m++)
+00378                                         {
+00379                                                 <span class="keywordflow">if</span> (!strcasecmp(this-&gt;connectors[k].routes[m].c_str(),sendhost))
+00380                                                 {
+00381                                                         log(DEBUG,<span class="stringliteral">"Found alternative route for packet: %s"</span>,this-&gt;connectors[k].GetServerName().c_str());
+00382                                                         <span class="keywordtype">char</span> buffer[MAXBUF];
+00383                                                         snprintf(buffer,MAXBUF,<span class="stringliteral">"R %s %s"</span>,sendhost,message);
+00384                                                         this-&gt;<a class="code" href="classserverrec.html#a7">SendPacket</a>(buffer,this-&gt;connectors[k].GetServerName().c_str());
+00385                                                         <span class="keywordflow">return</span> <span class="keyword">true</span>;
+00386                                                 }
+00387                                         }
+00388                                 }
+00389                         }
+00390                         <span class="keywordtype">char</span> buffer[MAXBUF];
+00391                         snprintf(buffer,MAXBUF,<span class="stringliteral">"&amp; %s"</span>,sendhost);
+00392                         WriteOpers(<span class="stringliteral">"*** All connections to %s lost."</span>,sendhost);
+00393                         NetSendToAllExcept(sendhost,buffer);
+00394                         DoSplit(sendhost);
+00395                         <span class="keywordflow">return</span> <span class="keyword">false</span>;
+00396                 }
+00397 
+00398                 <span class="comment">// returns false if the packet could not be sent (e.g. target host down)</span>
+00399                 <span class="keywordflow">if</span> (!cn-&gt;<a class="code" href="classircd__connector.html#a21">AddWriteBuf</a>(message))
+00400                 {
+00401                         <span class="comment">// if we're here, there was an error pending, and the send cannot proceed</span>
+00402                         log(DEBUG,<span class="stringliteral">"cn-&gt;AddWriteBuf() failed for serverrec::SendPacket(): %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str());
+00403                         log(DEBUG,<span class="stringliteral">"Disabling connector: %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str());
+00404                         cn-&gt;<a class="code" href="classircd__connector.html#a14">CloseConnection</a>();
+00405                         cn-&gt;<a class="code" href="classircd__connector.html#a7">SetState</a>(STATE_DISCONNECTED);
+00406                         WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str(),cn-&gt;<a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str());
+00407                         <span class="comment">// retry the packet along a new route so either arrival OR failure are gauranteed (bugfix)</span>
+00408                         <span class="keywordflow">return</span> this-&gt;<a class="code" href="classserverrec.html#a7">SendPacket</a>(message,sendhost);
+00409                 }
+00410                 <span class="keywordflow">if</span> (!cn-&gt;<a class="code" href="classircd__connector.html#a22">FlushWriteBuf</a>())
+00411                 {
+00412                         <span class="comment">// if we're here the write() caused an error, we cannot proceed</span>
+00413                         log(DEBUG,<span class="stringliteral">"cn-&gt;FlushWriteBuf() failed for serverrec::SendPacket(): %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str());
+00414                         log(DEBUG,<span class="stringliteral">"Disabling connector: %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str());
+00415                         cn-&gt;<a class="code" href="classircd__connector.html#a14">CloseConnection</a>();
+00416                         cn-&gt;<a class="code" href="classircd__connector.html#a7">SetState</a>(STATE_DISCONNECTED);
+00417                         WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,cn-&gt;<a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str(),cn-&gt;<a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str());
+00418                         <span class="comment">// retry the packet along a new route so either arrival OR failure are gauranteed</span>
+00419                         <span class="keywordflow">return</span> this-&gt;<a class="code" href="classserverrec.html#a7">SendPacket</a>(message,sendhost);
+00420                 }
+00421                 <span class="keywordflow">return</span> <span class="keyword">true</span>;
+00422         }
+00423 }
 </pre></div>    </td>
   </tr>
 </table>
@@ -1087,7 +1130,7 @@ With a serverrec, this is a list of all established server connections.
 <p>
 Definition at line <a class="el" href="servers_8h-source.html#l00081">81</a> of file <a class="el" href="servers_8h-source.html">servers.h</a>.
 <p>
-Referenced by <a class="el" href="servers_8cpp-source.html#l00212">AddIncoming()</a>, <a class="el" href="servers_8cpp-source.html#l00142">BeginLink()</a>, <a class="el" href="servers_8cpp-source.html#l00242">FindHost()</a>, <a class="el" href="servers_8cpp-source.html#l00284">FlushWriteBuffers()</a>, <a class="el" href="servers_8cpp-source.html#l00256">IsRoutable()</a>, <a class="el" href="servers_8cpp-source.html#l00182">MeshCookie()</a>, <a class="el" href="servers_8cpp-source.html#l00431">RecvPacket()</a>, <a class="el" href="servers_8cpp-source.html#l00336">SendPacket()</a>, and <a class="el" href="servers_8cpp-source.html#l00046">serverrec()</a>.    </td>
+Referenced by <a class="el" href="servers_8cpp-source.html#l00212">AddIncoming()</a>, <a class="el" href="servers_8cpp-source.html#l00142">BeginLink()</a>, <a class="el" href="servers_8cpp-source.html#l00242">FindHost()</a>, <a class="el" href="servers_8cpp-source.html#l00274">FlushWriteBuffers()</a>, <a class="el" href="servers_8cpp-source.html#l00256">IsRoutable()</a>, <a class="el" href="servers_8cpp-source.html#l00182">MeshCookie()</a>, <a class="el" href="servers_8cpp-source.html#l00445">RecvPacket()</a>, <a class="el" href="servers_8cpp-source.html#l00350">SendPacket()</a>, and <a class="el" href="servers_8cpp-source.html#l00046">serverrec()</a>.    </td>
   </tr>
 </table>
 <a name="o8" doxytag="serverrec::description"></a><p>
@@ -1396,7 +1439,7 @@ Referenced by <a class="el" href="servers_8cpp-source.html#l00046">serverrec()</
 </table>
 <hr>The documentation for this class was generated from the following files:<ul>
 <li><a class="el" href="servers_8h-source.html">servers.h</a><li><a class="el" href="servers_8cpp-source.html">servers.cpp</a></ul>
-<hr size="1"><address style="align: right;"><small>Generated on Wed May 25 22:03:25 2005 for InspIRCd by
+<hr size="1"><address style="align: right;"><small>Generated on Mon May 30 05:17:37 2005 for InspIRCd by
 <a href="http://www.doxygen.org/index.html">
 <img src="doxygen.png" alt="doxygen" align="middle" border=0 > 
 </a>1.3.3 </small></address>