diff options
Diffstat (limited to 'docs/module-doc/servers_8cpp-source.html')
| -rw-r--r-- | docs/module-doc/servers_8cpp-source.html | 573 |
1 files changed, 303 insertions, 270 deletions
diff --git a/docs/module-doc/servers_8cpp-source.html b/docs/module-doc/servers_8cpp-source.html index 7b6994181..297f887fa 100644 --- a/docs/module-doc/servers_8cpp-source.html +++ b/docs/module-doc/servers_8cpp-source.html @@ -262,279 +262,312 @@ 00255 <span class="comment">// Checks to see if we can still reach a server at all (e.g. is it in ANY routing table?)</span> <a name="l00256"></a><a class="code" href="servers_8cpp.html#a5">00256</a> <span class="keywordtype">bool</span> <a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(std::string servername) 00257 { -00258 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> x = 0; x < 32; x++) <span class="keywordflow">if</span> (<a class="code" href="channels_8cpp.html#a34">me</a>[x]) -00259 { -00260 <a class="code" href="classircd__connector.html">ircd_connector</a>* cn = <a class="code" href="channels_8cpp.html#a34">me</a>[x]-><a class="code" href="classserverrec.html#a9">FindHost</a>(servername.c_str()); -00261 <span class="keywordflow">if</span> (cn) -00262 { -00263 <span class="keywordflow">if</span> (cn-><a class="code" href="classircd__connector.html#a6">GetState</a>() == <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>) -00264 { -00265 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> k = 0; k < <a class="code" href="channels_8cpp.html#a34">me</a>[x]-><a class="code" href="classserverrec.html#o11">connectors</a>.size(); k++) -00266 { -00267 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> m = 0; m < <a class="code" href="channels_8cpp.html#a34">me</a>[x]-><a class="code" href="classserverrec.html#o11">connectors</a>[k].routes.size(); m++) -00268 { -00269 <span class="keywordflow">if</span> (!strcasecmp(<a class="code" href="channels_8cpp.html#a34">me</a>[x]->connectors[k].routes[m].c_str(),servername.c_str())) -00270 { -00271 <span class="keywordflow">return</span> <span class="keyword">true</span>; -00272 } -00273 } -00274 } -00275 <span class="keywordflow">return</span> <span class="keyword">false</span>; -00276 } -00277 <span class="keywordflow">else</span> <span class="keywordflow">return</span> <span class="keyword">true</span>; -00278 } -00279 } -00280 <span class="keywordflow">return</span> <span class="keyword">false</span>; -00281 } -00282 -00283 -<a name="l00284"></a><a class="code" href="classserverrec.html#a11">00284</a> <span class="keywordtype">void</span> <a class="code" href="classserverrec.html#a11">serverrec::FlushWriteBuffers</a>() -00285 { -00286 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < this-><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-><a class="code" href="classserverrec.html#o11">connectors</a>[i].GetState() == <a class="code" href="connection_8h.html#a4">STATE_NOAUTH_OUTBOUND</a>) && (<a class="code" href="channels_8cpp.html#a36">TIME</a> > this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].age+30)) +00258 <span class="keywordtype">int</span> c = 0; +00259 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> x = 0; x < 32; x++) +00260 <span class="keywordflow">if</span> (<a class="code" href="channels_8cpp.html#a34">me</a>[x]) +00261 { +00262 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < <a class="code" href="channels_8cpp.html#a34">me</a>[x]-><a class="code" href="classserverrec.html#o11">connectors</a>.size(); i++) +00263 { +00264 <span class="keywordflow">if</span> ((<a class="code" href="channels_8cpp.html#a34">me</a>[x]-><a class="code" href="classserverrec.html#o11">connectors</a>[i].GetServerName() == servername) && (<a class="code" href="channels_8cpp.html#a34">me</a>[x]-><a class="code" href="classserverrec.html#o11">connectors</a>[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>)) +00265 { +00266 c++; +00267 } +00268 } +00269 } +00270 <span class="keywordflow">return</span> (c != 0); +00271 } +00272 +00273 +<a name="l00274"></a><a class="code" href="classserverrec.html#a11">00274</a> <span class="keywordtype">void</span> <a class="code" href="classserverrec.html#a11">serverrec::FlushWriteBuffers</a>() +00275 { +00276 <span class="keywordtype">char</span> buffer[MAXBUF]; +00277 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < this-><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-><a class="code" href="classserverrec.html#o11">connectors</a>[i].GetState() == <a class="code" href="connection_8h.html#a4">STATE_NOAUTH_OUTBOUND</a>) && (<a class="code" href="channels_8cpp.html#a36">TIME</a> > this-><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->connectors[i].GetServerName().c_str()); +00284 snprintf(buffer,MAXBUF,<span class="stringliteral">"& %s"</span>,this->connectors[i].GetServerName().c_str()); +00285 NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer); +00286 DoSplit(this->connectors[i].GetServerName().c_str()); +00287 <span class="keywordflow">return</span>; +00288 } +00289 <span class="keywordflow">if</span> ((this->connectors[i].GetState() == <a class="code" href="connection_8h.html#a3">STATE_NOAUTH_INBOUND</a>) && (<a class="code" href="channels_8cpp.html#a36">TIME</a> > this->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->connectors[i].GetServerName().c_str()); -00293 DoSplit(this->connectors[i].GetServerName().c_str()); -00294 <span class="keywordflow">return</span>; -00295 } -00296 <span class="keywordflow">else</span> <span class="keywordflow">if</span> ((this->connectors[i].GetState() == <a class="code" href="connection_8h.html#a3">STATE_NOAUTH_INBOUND</a>) && (<a class="code" href="channels_8cpp.html#a36">TIME</a> > this->connectors[i].age+30)) -00297 { -00298 WriteOpers(<span class="stringliteral">"*** Connection from %s timed out"</span>,this->connectors[i].GetServerName().c_str()); -00299 DoSplit(this->connectors[i].GetServerName().c_str()); -00300 <span class="keywordflow">return</span>; -00301 } -00302 <span class="keywordflow">else</span> <span class="keywordflow">if</span> (this->connectors[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>) -00303 { -00304 <span class="keywordflow">if</span> (!this->connectors[i].CheckPing()) -00305 { -00306 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s: Ping timeout"</span>,this->connectors[i].GetServerName().c_str()); -00307 this->connectors[i].CloseConnection(); -00308 this->connectors[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); -00309 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) -00310 { -00311 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); -00312 DoSplit(this->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->connectors[i].HasBufferedOutput()) -00318 { -00319 <span class="keywordflow">if</span> (!this->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->connectors[i].GetServerName().c_str(),this->connectors[i].GetWriteError().c_str()); -00323 this->connectors[i].CloseConnection(); -00324 this->connectors[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); -00325 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) -00326 { -00327 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); -00328 DoSplit(this->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 } -00335 -<a name="l00336"></a><a class="code" href="classserverrec.html#a7">00336</a> <span class="keywordtype">bool</span> <a class="code" href="classserverrec.html#a7">serverrec::SendPacket</a>(<span class="keywordtype">char</span> *message, <span class="keyword">const</span> <span class="keywordtype">char</span>* sendhost) -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-><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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"main: serverrec::SendPacket() sent '%s' to %s"</span>,message,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str()); -00351 -00352 <span class="keywordflow">if</span> (cn-><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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<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 < this-><a class="code" href="classserverrec.html#o11">connectors</a>.size(); k++) -00360 { -00361 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Check connector %d: %s"</span>,k,this->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 < this-><a class="code" href="classserverrec.html#o11">connectors</a>[k].routes.size(); m++) -00364 { -00365 <span class="keywordflow">if</span> (!strcasecmp(this->connectors[k].routes[m].c_str(),sendhost)) -00366 { -00367 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Found alternative route for packet: %s"</span>,this->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-><a class="code" href="classserverrec.html#a7">SendPacket</a>(buffer,this->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">"& %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-><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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"cn->AddWriteBuf() failed for serverrec::SendPacket(): %s"</span>,cn-><a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str()); -00389 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Disabling connector: %s"</span>,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str()); -00390 cn-><a class="code" href="classircd__connector.html#a14">CloseConnection</a>(); -00391 cn-><a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); -00392 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str(),cn-><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-><a class="code" href="classserverrec.html#a7">SendPacket</a>(message,sendhost); -00395 } -00396 <span class="keywordflow">if</span> (!cn-><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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"cn->FlushWriteBuf() failed for serverrec::SendPacket(): %s"</span>,cn-><a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str()); -00400 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Disabling connector: %s"</span>,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str()); -00401 cn-><a class="code" href="classircd__connector.html#a14">CloseConnection</a>(); -00402 cn-><a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); -00403 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str(),cn-><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-><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 } -00410 -<a name="l00411"></a><a class="code" href="servers_8cpp.html#a6">00411</a> <span class="keywordtype">bool</span> <a class="code" href="servers_8cpp.html#a6">already_have_sum</a>(std::string sum) -00412 { -00413 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < <a class="code" href="servers_8cpp.html#a4">xsums</a>.size(); i++) -00414 { -00415 <span class="keywordflow">if</span> (<a class="code" href="servers_8cpp.html#a4">xsums</a>[i] == sum) -00416 { -00417 <span class="keywordflow">return</span> <span class="keyword">true</span>; -00418 } -00419 } -00420 <span class="keywordflow">if</span> (<a class="code" href="servers_8cpp.html#a4">xsums</a>.size() >= 128) -00421 { -00422 <a class="code" href="servers_8cpp.html#a4">xsums</a>.pop_front(); -00423 } -00424 <a class="code" href="servers_8cpp.html#a4">xsums</a>.push_back(sum); -00425 <span class="keywordflow">return</span> <span class="keyword">false</span>; -00426 } -00427 -00428 <span class="comment">// receives a packet from any where there is data waiting, first come, first served</span> -00429 <span class="comment">// fills the message and host values with the host where the data came from.</span> -00430 -<a name="l00431"></a><a class="code" href="classserverrec.html#a8">00431</a> <span class="keywordtype">bool</span> <a class="code" href="classserverrec.html#a8">serverrec::RecvPacket</a>(std::deque<std::string> &messages, <span class="keywordtype">char</span>* recvhost,std::deque<std::string> &sums) -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 < this-><a class="code" href="classserverrec.html#o11">connectors</a>.size(); i++) -00436 { -00437 <span class="keywordflow">if</span> (this-><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; +00291 WriteOpers(<span class="stringliteral">"*** Connection from %s timed out"</span>,this->connectors[i].GetServerName().c_str()); +00292 snprintf(buffer,MAXBUF,<span class="stringliteral">"& %s"</span>,this->connectors[i].GetServerName().c_str()); +00293 NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer); +00294 DoSplit(this->connectors[i].GetServerName().c_str()); +00295 <span class="keywordflow">return</span>; +00296 } +00297 <span class="keywordflow">if</span> (this->connectors[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>) +00298 { +00299 <span class="keywordflow">if</span> (!this->connectors[i].CheckPing()) +00300 { +00301 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s: Ping timeout"</span>,this->connectors[i].GetServerName().c_str()); +00302 this->connectors[i].CloseConnection(); +00303 this->connectors[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); +00304 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) +00305 { +00306 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); +00307 snprintf(buffer,MAXBUF,<span class="stringliteral">"& %s"</span>,this->connectors[i].GetServerName().c_str()); +00308 NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer); +00309 DoSplit(this->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->connectors[i].GetWriteError() !=<span class="stringliteral">""</span>) && (this->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->connectors[i].GetServerName().c_str(),this->connectors[i].GetWriteError().c_str()); +00318 this->connectors[i].CloseConnection(); +00319 this->connectors[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); +00320 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) +00321 { +00322 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); +00323 snprintf(buffer,MAXBUF,<span class="stringliteral">"& %s"</span>,this->connectors[i].GetServerName().c_str()); +00324 NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer); +00325 DoSplit(this->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->connectors[i].HasBufferedOutput()) && (this->connectors[i].GetState() != <a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>)) +00330 { +00331 <span class="keywordflow">if</span> (!this->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->connectors[i].GetServerName().c_str(),this->connectors[i].GetWriteError().c_str()); +00335 this->connectors[i].CloseConnection(); +00336 this->connectors[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); +00337 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) +00338 { +00339 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); +00340 snprintf(buffer,MAXBUF,<span class="stringliteral">"& %s"</span>,this->connectors[i].GetServerName().c_str()); +00341 NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer); +00342 DoSplit(this->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 } +00349 +<a name="l00350"></a><a class="code" href="classserverrec.html#a7">00350</a> <span class="keywordtype">bool</span> <a class="code" href="classserverrec.html#a7">serverrec::SendPacket</a>(<span class="keywordtype">char</span> *message, <span class="keyword">const</span> <span class="keywordtype">char</span>* sendhost) +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-><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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"main: serverrec::SendPacket() sent '%s' to %s"</span>,message,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str()); +00365 +00366 <span class="keywordflow">if</span> (cn-><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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<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 < this-><a class="code" href="classserverrec.html#o11">connectors</a>.size(); k++) +00374 { +00375 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Check connector %d: %s"</span>,k,this->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 < this-><a class="code" href="classserverrec.html#o11">connectors</a>[k].routes.size(); m++) +00378 { +00379 <span class="keywordflow">if</span> (!strcasecmp(this->connectors[k].routes[m].c_str(),sendhost)) +00380 { +00381 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Found alternative route for packet: %s"</span>,this->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-><a class="code" href="classserverrec.html#a7">SendPacket</a>(buffer,this->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">"& %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-><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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"cn->AddWriteBuf() failed for serverrec::SendPacket(): %s"</span>,cn-><a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str()); +00403 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Disabling connector: %s"</span>,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str()); +00404 cn-><a class="code" href="classircd__connector.html#a14">CloseConnection</a>(); +00405 cn-><a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); +00406 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str(),cn-><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-><a class="code" href="classserverrec.html#a7">SendPacket</a>(message,sendhost); +00409 } +00410 <span class="keywordflow">if</span> (!cn-><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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"cn->FlushWriteBuf() failed for serverrec::SendPacket(): %s"</span>,cn-><a class="code" href="classircd__connector.html#a24">GetWriteError</a>().c_str()); +00414 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Disabling connector: %s"</span>,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str()); +00415 cn-><a class="code" href="classircd__connector.html#a14">CloseConnection</a>(); +00416 cn-><a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); +00417 WriteOpers(<span class="stringliteral">"*** Lost single connection to %s, link inactive and retrying: %s"</span>,cn-><a class="code" href="classircd__connector.html#a2">GetServerName</a>().c_str(),cn-><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-><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 } +00424 +<a name="l00425"></a><a class="code" href="servers_8cpp.html#a6">00425</a> <span class="keywordtype">bool</span> <a class="code" href="servers_8cpp.html#a6">already_have_sum</a>(std::string sum) +00426 { +00427 <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < <a class="code" href="servers_8cpp.html#a4">xsums</a>.size(); i++) +00428 { +00429 <span class="keywordflow">if</span> (<a class="code" href="servers_8cpp.html#a4">xsums</a>[i] == sum) +00430 { +00431 <span class="keywordflow">return</span> <span class="keyword">true</span>; +00432 } +00433 } +00434 <span class="keywordflow">if</span> (<a class="code" href="servers_8cpp.html#a4">xsums</a>.size() >= 128) +00435 { +00436 <a class="code" href="servers_8cpp.html#a4">xsums</a>.pop_front(); +00437 } +00438 <a class="code" href="servers_8cpp.html#a4">xsums</a>.push_back(sum); +00439 <span class="keywordflow">return</span> <span class="keyword">false</span>; +00440 } 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-><a class="code" href="classserverrec.html#o11">connectors</a>[i].GetDescriptor(); -00446 polls.events = POLLIN; -00447 <span class="keywordtype">int</span> ret = poll(&polls,1,1); -00448 <span class="keywordflow">if</span> (ret <= 0) <span class="keywordflow">continue</span>; -00449 -00450 rcvsize = recv(this->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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"recv() failed for serverrec::RecvPacket(): %s"</span>,strerror(errno)); -00457 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Disabling connector: %s"</span>,this->connectors[i].GetServerName().c_str()); -00458 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection(); -00459 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); -00460 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) -00461 { -00462 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); -00463 DoSplit(this->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 > 0) -00470 { -00471 <span class="keywordflow">if</span> (!this-><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->connectors[i].GetServerName().c_str()); -00474 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection(); -00475 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); -00476 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) -00477 { -00478 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); -00479 DoSplit(this->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-><a class="code" href="classserverrec.html#o11">connectors</a>[i].BufferIsComplete()) +00442 <span class="comment">// receives a packet from any where there is data waiting, first come, first served</span> +00443 <span class="comment">// fills the message and host values with the host where the data came from.</span> +00444 +<a name="l00445"></a><a class="code" href="classserverrec.html#a8">00445</a> <span class="keywordtype">bool</span> <a class="code" href="classserverrec.html#a8">serverrec::RecvPacket</a>(std::deque<std::string> &messages, <span class="keywordtype">char</span>* recvhost,std::deque<std::string> &sums) +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 < this-><a class="code" href="classserverrec.html#o11">connectors</a>.size(); i++) +00450 { +00451 <span class="keywordflow">if</span> (this-><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-><a class="code" href="classserverrec.html#o11">connectors</a>[i].GetDescriptor(); +00460 polls.events = POLLIN; +00461 <span class="keywordtype">int</span> ret = poll(&polls,1,1); +00462 <span class="keywordflow">if</span> (ret <= 0) <span class="keywordflow">continue</span>; +00463 +00464 rcvsize = recv(this->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(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"recv() failed for serverrec::RecvPacket(): EOF"</span>); +00469 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Disabling connector: %s"</span>,this->connectors[i].GetServerName().c_str()); +00470 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection(); +00471 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); +00472 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) +00473 { +00474 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting (EOF)"</span>,this->connectors[i].GetServerName().c_str()); +00475 snprintf(buffer,MAXBUF,<span class="stringliteral">"& %s"</span>,this->connectors[i].GetServerName().c_str()); +00476 NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer); +00477 DoSplit(this->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-><a class="code" href="classserverrec.html#o11">connectors</a>[i].ResetPing(); -00486 <span class="keywordflow">while</span> (this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].BufferIsComplete()) -00487 { -00488 std::string text = this-><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>) && (text.find(<span class="stringliteral">" "</span>) != std::string::npos)) -00492 { -00493 std::string orig = text; -00494 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<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() > 1) -00499 { -00500 sums.push_back(<span class="stringliteral">"*"</span>); -00501 text = orig; -00502 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Non-mesh, non-tokenized string passed up the chain"</span>); -00503 } -00504 <span class="keywordflow">else</span> -00505 { -00506 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<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)) && (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->connectors[i].GetServerName().c_str(),160); -00518 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"serverrec::RecvPacket() %d:%s->%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 } -00529 -</pre></div><hr size="1"><address style="align: right;"><small>Generated on Wed May 25 22:02:05 2005 for InspIRCd by +00485 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"recv() failed for serverrec::RecvPacket(): %s"</span>,strerror(errno)); +00486 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Disabling connector: %s"</span>,this->connectors[i].GetServerName().c_str()); +00487 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection(); +00488 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); +00489 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) +00490 { +00491 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); +00492 snprintf(buffer,MAXBUF,<span class="stringliteral">"& %s"</span>,this->connectors[i].GetServerName().c_str()); +00493 NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer); +00494 DoSplit(this->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 > 0) +00501 { +00502 <span class="keywordflow">if</span> (!this-><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->connectors[i].GetServerName().c_str()); +00505 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].CloseConnection(); +00506 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].SetState(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>); +00507 <span class="keywordflow">if</span> (!<a class="code" href="servers_8cpp.html#a5">IsRoutable</a>(this->connectors[i].GetServerName())) +00508 { +00509 WriteOpers(<span class="stringliteral">"*** Server %s is no longer routable, disconnecting."</span>,this->connectors[i].GetServerName().c_str()); +00510 snprintf(buffer,MAXBUF,<span class="stringliteral">"& %s"</span>,this->connectors[i].GetServerName().c_str()); +00511 NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer); +00512 DoSplit(this->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-><a class="code" href="classserverrec.html#o11">connectors</a>[i].BufferIsComplete()) +00517 { +00518 this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].ResetPing(); +00519 <span class="keywordflow">while</span> (this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].BufferIsComplete()) +00520 { +00521 std::string text = this-><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>) && (text.find(<span class="stringliteral">" "</span>) != std::string::npos)) +00525 { +00526 std::string orig = text; +00527 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<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() > 1) +00532 { +00533 sums.push_back(<span class="stringliteral">"*"</span>); +00534 text = orig; +00535 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"Non-mesh, non-tokenized string passed up the chain"</span>); +00536 } +00537 <span class="keywordflow">else</span> +00538 { +00539 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<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)) && (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->connectors[i].GetServerName().c_str(),160); +00551 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"serverrec::RecvPacket() %d:%s->%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 } +00562 +</pre></div><hr size="1"><address style="align: right;"><small>Generated on Mon May 30 05:15:21 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> |