mirror of
https://github.com/inspircd/inspircd.git
synced 2025-03-10 02:59:01 -04:00
956328e807
git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@1565 e03df62e-2008-0410-955e-edbf42e46eb7
576 lines
53 KiB
HTML
576 lines
53 KiB
HTML
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
|
|
<html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1">
|
|
<title>InspIRCd: servers.cpp Source File</title>
|
|
<link href="inspircd.doxygen.css" rel="stylesheet" type="text/css">
|
|
</head><body>
|
|
<!-- Generated by Doxygen 1.3.3 -->
|
|
<div class="qindex"><a class="qindex" href="main.html">Main Page</a> | <a class="qindex" href="namespaces.html">Namespace List</a> | <a class="qindex" href="hierarchy.html">Class Hierarchy</a> | <a class="qindex" href="classes.html">Alphabetical List</a> | <a class="qindex" href="annotated.html">Compound List</a> | <a class="qindex" href="files.html">File List</a> | <a class="qindex" href="namespacemembers.html">Namespace Members</a> | <a class="qindex" href="functions.html">Compound Members</a> | <a class="qindex" href="globals.html">File Members</a></div>
|
|
<h1>servers.cpp</h1><a href="servers_8cpp.html">Go to the documentation of this file.</a><div class="fragment"><pre>00001 <span class="comment">/* +------------------------------------+</span>
|
|
00002 <span class="comment"> * | Inspire Internet Relay Chat Daemon |</span>
|
|
00003 <span class="comment"> * +------------------------------------+</span>
|
|
00004 <span class="comment"> *</span>
|
|
00005 <span class="comment"> * Inspire is copyright (C) 2002-2004 ChatSpike-Dev.</span>
|
|
00006 <span class="comment"> * E-mail:</span>
|
|
00007 <span class="comment"> * <brain@chatspike.net></span>
|
|
00008 <span class="comment"> * <Craig@chatspike.net></span>
|
|
00009 <span class="comment"> * </span>
|
|
00010 <span class="comment"> * Written by Craig Edwards, Craig McLure, and others.</span>
|
|
00011 <span class="comment"> * This program is free but copyrighted software; see</span>
|
|
00012 <span class="comment"> * the file COPYING for details.</span>
|
|
00013 <span class="comment"> *</span>
|
|
00014 <span class="comment"> * ---------------------------------------------------</span>
|
|
00015 <span class="comment"> */</span>
|
|
00016
|
|
00017 <span class="keyword">using</span> <span class="keyword">namespace </span>std;
|
|
00018
|
|
00019 <span class="preprocessor">#include "inspircd_config.h"</span>
|
|
00020 <span class="preprocessor">#include "<a class="code" href="servers_8h.html">servers.h</a>"</span>
|
|
00021 <span class="preprocessor">#include "inspircd.h"</span>
|
|
00022 <span class="preprocessor">#include <unistd.h></span>
|
|
00023 <span class="preprocessor">#include <fcntl.h></span>
|
|
00024 <span class="preprocessor">#include <poll.h></span>
|
|
00025 <span class="preprocessor">#include <sys/errno.h></span>
|
|
00026 <span class="preprocessor">#include <sys/ioctl.h></span>
|
|
00027 <span class="preprocessor">#include <sys/utsname.h></span>
|
|
00028 <span class="preprocessor">#include <vector></span>
|
|
00029 <span class="preprocessor">#include <string></span>
|
|
00030 <span class="preprocessor">#include <deque></span>
|
|
00031 <span class="preprocessor">#include <sstream></span>
|
|
00032 <span class="preprocessor">#include <map></span>
|
|
00033 <span class="preprocessor">#include "inspstring.h"</span>
|
|
00034 <span class="preprocessor">#include "helperfuncs.h"</span>
|
|
00035 <span class="preprocessor">#include "<a class="code" href="connection_8h.html">connection.h</a>"</span>
|
|
00036
|
|
<a name="l00037"></a><a class="code" href="servers_8cpp.html#a0">00037</a> <span class="keyword">extern</span> time_t <a class="code" href="channels_8cpp.html#a36">TIME</a>;
|
|
<a name="l00038"></a><a class="code" href="servers_8cpp.html#a1">00038</a> <span class="keyword">extern</span> <span class="keywordtype">int</span> <a class="code" href="servers_8cpp.html#a1">MaxConn</a>;
|
|
00039
|
|
<a name="l00040"></a><a class="code" href="servers_8cpp.html#a2">00040</a> <span class="keyword">extern</span> <a class="code" href="classserverrec.html">serverrec</a>* <a class="code" href="channels_8cpp.html#a34">me</a>[32];
|
|
00041
|
|
<a name="l00042"></a><a class="code" href="servers_8cpp.html#a3">00042</a> <span class="keyword">extern</span> <span class="keywordtype">bool</span> <a class="code" href="servers_8cpp.html#a3">has_been_netsplit</a>;
|
|
00043
|
|
<a name="l00044"></a><a class="code" href="servers_8cpp.html#a4">00044</a> std::deque<std::string> <a class="code" href="servers_8cpp.html#a4">xsums</a>;
|
|
00045
|
|
<a name="l00046"></a><a class="code" href="classserverrec.html#a0">00046</a> <a class="code" href="classserverrec.html#a0">serverrec::serverrec</a>()
|
|
00047 {
|
|
00048 strlcpy(<a class="code" href="classserverrec.html#o0">name</a>,<span class="stringliteral">""</span>,256);
|
|
00049 <a class="code" href="classserverrec.html#o1">pingtime</a> = 0;
|
|
00050 <a class="code" href="classconnection.html#o10">lastping</a> = <a class="code" href="channels_8cpp.html#a36">TIME</a>;
|
|
00051 <a class="code" href="classserverrec.html#o2">usercount_i</a> = <a class="code" href="classserverrec.html#o3">usercount</a> = <a class="code" href="classserverrec.html#o4">opercount</a> = <a class="code" href="classserverrec.html#o6">version</a> = 0;
|
|
00052 <a class="code" href="classserverrec.html#o5">hops_away</a> = 1;
|
|
00053 <a class="code" href="classconnection.html#o11">signon</a> = <a class="code" href="channels_8cpp.html#a36">TIME</a>;
|
|
00054 <a class="code" href="classserverrec.html#o7">jupiter</a> = <span class="keyword">false</span>;
|
|
00055 <a class="code" href="classconnection.html#o0">fd</a> = 0;
|
|
00056 <a class="code" href="classserverrec.html#o10">sync_soon</a> = <span class="keyword">false</span>;
|
|
00057 strlcpy(<a class="code" href="classserverrec.html#o9">nickserv</a>,<span class="stringliteral">""</span>,NICKMAX);
|
|
00058 <a class="code" href="classserverrec.html#o11">connectors</a>.clear();
|
|
00059 }
|
|
00060
|
|
00061
|
|
<a name="l00062"></a><a class="code" href="classserverrec.html#a2">00062</a> <a class="code" href="classserverrec.html#a2">serverrec::~serverrec</a>()
|
|
00063 {
|
|
00064 }
|
|
00065
|
|
<a name="l00066"></a><a class="code" href="classserverrec.html#a1">00066</a> <a class="code" href="classserverrec.html#a0">serverrec::serverrec</a>(<span class="keywordtype">char</span>* n, <span class="keywordtype">long</span> ver, <span class="keywordtype">bool</span> jupe)
|
|
00067 {
|
|
00068 strlcpy(<a class="code" href="classserverrec.html#o0">name</a>,n,256);
|
|
00069 <a class="code" href="classconnection.html#o10">lastping</a> = <a class="code" href="channels_8cpp.html#a36">TIME</a>;
|
|
00070 <a class="code" href="classserverrec.html#o2">usercount_i</a> = <a class="code" href="classserverrec.html#o3">usercount</a> = <a class="code" href="classserverrec.html#o4">opercount</a> = 0;
|
|
00071 <a class="code" href="classserverrec.html#o6">version</a> = ver;
|
|
00072 <a class="code" href="classserverrec.html#o5">hops_away</a> = 1;
|
|
00073 <a class="code" href="classconnection.html#o11">signon</a> = <a class="code" href="channels_8cpp.html#a36">TIME</a>;
|
|
00074 <a class="code" href="classserverrec.html#o7">jupiter</a> = jupe;
|
|
00075 <a class="code" href="classconnection.html#o0">fd</a> = 0;
|
|
00076 <a class="code" href="classserverrec.html#o10">sync_soon</a> = <span class="keyword">false</span>;
|
|
00077 strlcpy(<a class="code" href="classserverrec.html#o9">nickserv</a>,<span class="stringliteral">""</span>,NICKMAX);
|
|
00078 <a class="code" href="classserverrec.html#o11">connectors</a>.clear();
|
|
00079 }
|
|
00080
|
|
<a name="l00081"></a><a class="code" href="classserverrec.html#a3">00081</a> <span class="keywordtype">bool</span> <a class="code" href="classserverrec.html#a3">serverrec::CreateListener</a>(<span class="keywordtype">char</span>* newhost, <span class="keywordtype">int</span> p)
|
|
00082 {
|
|
00083 sockaddr_in host_address;
|
|
00084 <span class="keywordtype">int</span> flags;
|
|
00085 in_addr addy;
|
|
00086 <span class="keywordtype">int</span> on = 0;
|
|
00087 <span class="keyword">struct </span>linger linger = { 0 };
|
|
00088
|
|
00089 this-><a class="code" href="classconnection.html#o8">port</a> = p;
|
|
00090
|
|
00091 <a class="code" href="classconnection.html#o0">fd</a> = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
|
|
00092 <span class="keywordflow">if</span> (<a class="code" href="classconnection.html#o0">fd</a> <= 0)
|
|
00093 {
|
|
00094 <span class="keywordflow">return</span> <span class="keyword">false</span>;
|
|
00095 }
|
|
00096
|
|
00097 setsockopt(<a class="code" href="classconnection.html#o0">fd</a>,SOL_SOCKET,SO_REUSEADDR,(<span class="keyword">const</span> <span class="keywordtype">char</span>*)&on,<span class="keyword">sizeof</span>(on));
|
|
00098 linger.l_onoff = 1;
|
|
00099 linger.l_linger = 1;
|
|
00100 setsockopt(<a class="code" href="classconnection.html#o0">fd</a>,SOL_SOCKET,SO_LINGER,(<span class="keyword">const</span> <span class="keywordtype">char</span>*)&linger,<span class="keyword">sizeof</span>(linger));
|
|
00101
|
|
00102 <span class="comment">// attempt to increase socket sendq and recvq as high as its possible</span>
|
|
00103 <span class="comment">// to get them on linux.</span>
|
|
00104 <span class="keywordtype">int</span> sendbuf = 32768;
|
|
00105 <span class="keywordtype">int</span> recvbuf = 32768;
|
|
00106 setsockopt(<a class="code" href="classconnection.html#o0">fd</a>,SOL_SOCKET,SO_SNDBUF,(<span class="keyword">const</span> <span class="keywordtype">void</span> *)&sendbuf,<span class="keyword">sizeof</span>(sendbuf));
|
|
00107 setsockopt(<a class="code" href="classconnection.html#o0">fd</a>,SOL_SOCKET,SO_RCVBUF,(<span class="keyword">const</span> <span class="keywordtype">void</span> *)&recvbuf,<span class="keyword">sizeof</span>(sendbuf));
|
|
00108
|
|
00109 memset((<span class="keywordtype">void</span>*)&host_address, 0, <span class="keyword">sizeof</span>(host_address));
|
|
00110
|
|
00111 host_address.sin_family = AF_INET;
|
|
00112
|
|
00113 <span class="keywordflow">if</span> (!strcmp(newhost,<span class="stringliteral">""</span>))
|
|
00114 {
|
|
00115 host_address.sin_addr.s_addr = htonl(INADDR_ANY);
|
|
00116 }
|
|
00117 <span class="keywordflow">else</span>
|
|
00118 {
|
|
00119 inet_aton(newhost,&addy);
|
|
00120 host_address.sin_addr = addy;
|
|
00121 }
|
|
00122
|
|
00123 host_address.sin_port = htons(p);
|
|
00124
|
|
00125 <span class="keywordflow">if</span> (bind(<a class="code" href="classconnection.html#o0">fd</a>,(sockaddr*)&host_address,<span class="keyword">sizeof</span>(host_address))<0)
|
|
00126 {
|
|
00127 <span class="keywordflow">return</span> <span class="keyword">false</span>;
|
|
00128 }
|
|
00129
|
|
00130 <span class="comment">// make the socket non-blocking</span>
|
|
00131 flags = fcntl(<a class="code" href="classconnection.html#o0">fd</a>, F_GETFL, 0);
|
|
00132 fcntl(<a class="code" href="classconnection.html#o0">fd</a>, F_SETFL, flags | O_NONBLOCK);
|
|
00133
|
|
00134 this-><a class="code" href="classconnection.html#o8">port</a> = p;
|
|
00135
|
|
00136 listen(this->fd, <a class="code" href="servers_8cpp.html#a1">MaxConn</a>);
|
|
00137
|
|
00138 <span class="keywordflow">return</span> <span class="keyword">true</span>;
|
|
00139 }
|
|
00140
|
|
00141
|
|
<a name="l00142"></a><a class="code" href="classserverrec.html#a4">00142</a> <span class="keywordtype">bool</span> <a class="code" href="classserverrec.html#a4">serverrec::BeginLink</a>(<span class="keywordtype">char</span>* targethost, <span class="keywordtype">int</span> newport, <span class="keywordtype">char</span>* password, <span class="keywordtype">char</span>* servername, <span class="keywordtype">int</span> myport)
|
|
00143 {
|
|
00144 <span class="keywordtype">char</span> connect[MAXBUF];
|
|
00145
|
|
00146 <a class="code" href="classircd__connector.html">ircd_connector</a> connector;
|
|
00147 <a class="code" href="classircd__connector.html">ircd_connector</a> *cn = this-><a class="code" href="classserverrec.html#a9">FindHost</a>(servername);
|
|
00148
|
|
00149
|
|
00150 <span class="keywordflow">if</span> (cn)
|
|
00151 {
|
|
00152 WriteOpers(<span class="stringliteral">"CONNECT aborted: Server %s already exists"</span>,servername);
|
|
00153 <span class="keywordflow">return</span> <span class="keyword">false</span>;
|
|
00154 }
|
|
00155
|
|
00156
|
|
00157 <span class="keywordflow">if</span> (this-><a class="code" href="classconnection.html#o0">fd</a>)
|
|
00158 {
|
|
00159 <span class="keywordflow">if</span> (connector.<a class="code" href="classircd__connector.html#a1">MakeOutboundConnection</a>(targethost,newport))
|
|
00160 {
|
|
00161 <span class="comment">// targethost has been turned into an ip...</span>
|
|
00162 <span class="comment">// we dont want this as the server name.</span>
|
|
00163 connector.<a class="code" href="classircd__connector.html#a3">SetServerName</a>(servername);
|
|
00164 snprintf(connect,MAXBUF,<span class="stringliteral">"S %s %s %lu %s :%s"</span>,getservername().c_str(),password,(<span class="keywordtype">unsigned</span> <span class="keywordtype">long</span>)myport,GetRevision().c_str(),getserverdesc().c_str());
|
|
00165 connector.<a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a4">STATE_NOAUTH_OUTBOUND</a>);
|
|
00166 connector.<a class="code" href="classircd__connector.html#a13">SetHostAndPort</a>(targethost, newport);
|
|
00167 this-><a class="code" href="classserverrec.html#o11">connectors</a>.push_back(connector);
|
|
00168 <span class="comment">// this packet isn't actually sent until the socket connects -- the STATE_NOAUTH_OUTBOUND state</span>
|
|
00169 <span class="comment">// queues outbound data until the socket is polled as writeable (e.g. the connection is established)</span>
|
|
00170 <span class="keywordflow">return</span> this-><a class="code" href="classserverrec.html#a7">SendPacket</a>(connect, servername);
|
|
00171 }
|
|
00172 <span class="keywordflow">else</span>
|
|
00173 {
|
|
00174 connector.<a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>);
|
|
00175 WriteOpers(<span class="stringliteral">"Could not create outbound connection to %s:%d"</span>,targethost,newport);
|
|
00176 }
|
|
00177 }
|
|
00178 <span class="keywordflow">return</span> <span class="keyword">false</span>;
|
|
00179 }
|
|
00180
|
|
00181
|
|
<a name="l00182"></a><a class="code" href="classserverrec.html#a5">00182</a> <span class="keywordtype">bool</span> <a class="code" href="classserverrec.html#a5">serverrec::MeshCookie</a>(<span class="keywordtype">char</span>* targethost, <span class="keywordtype">int</span> newport, <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> cookie, <span class="keywordtype">char</span>* servername)
|
|
00183 {
|
|
00184 <span class="keywordtype">char</span> connect[MAXBUF];
|
|
00185
|
|
00186 <a class="code" href="classircd__connector.html">ircd_connector</a> connector;
|
|
00187
|
|
00188 WriteOpers(<span class="stringliteral">"Establishing meshed link to %s:%d"</span>,servername,newport);
|
|
00189
|
|
00190 <span class="keywordflow">if</span> (this-><a class="code" href="classconnection.html#o0">fd</a>)
|
|
00191 {
|
|
00192 <span class="keywordflow">if</span> (connector.<a class="code" href="classircd__connector.html#a1">MakeOutboundConnection</a>(targethost,newport))
|
|
00193 {
|
|
00194 <span class="comment">// targethost has been turned into an ip...</span>
|
|
00195 <span class="comment">// we dont want this as the server name.</span>
|
|
00196 connector.<a class="code" href="classircd__connector.html#a3">SetServerName</a>(servername);
|
|
00197 snprintf(connect,MAXBUF,<span class="stringliteral">"- %lu %s :%s"</span>,cookie,getservername().c_str(),getserverdesc().c_str());
|
|
00198 connector.<a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a4">STATE_NOAUTH_OUTBOUND</a>);
|
|
00199 connector.<a class="code" href="classircd__connector.html#a13">SetHostAndPort</a>(targethost, newport);
|
|
00200 this-><a class="code" href="classserverrec.html#o11">connectors</a>.push_back(connector);
|
|
00201 <span class="keywordflow">return</span> this-><a class="code" href="classserverrec.html#a7">SendPacket</a>(connect, servername);
|
|
00202 }
|
|
00203 <span class="keywordflow">else</span>
|
|
00204 {
|
|
00205 connector.<a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a0">STATE_DISCONNECTED</a>);
|
|
00206 WriteOpers(<span class="stringliteral">"Could not create outbound connection to %s:%d"</span>,targethost,newport);
|
|
00207 }
|
|
00208 }
|
|
00209 <span class="keywordflow">return</span> <span class="keyword">false</span>;
|
|
00210 }
|
|
00211
|
|
<a name="l00212"></a><a class="code" href="classserverrec.html#a10">00212</a> <span class="keywordtype">bool</span> <a class="code" href="classserverrec.html#a10">serverrec::AddIncoming</a>(<span class="keywordtype">int</span> newfd, <span class="keywordtype">char</span>* targethost, <span class="keywordtype">int</span> sourceport)
|
|
00213 {
|
|
00214 <a class="code" href="classircd__connector.html">ircd_connector</a> connector;
|
|
00215
|
|
00216 <span class="comment">// targethost has been turned into an ip...</span>
|
|
00217 <span class="comment">// we dont want this as the server name.</span>
|
|
00218 connector.<a class="code" href="classircd__connector.html#a3">SetServerName</a>(targethost);
|
|
00219 connector.<a class="code" href="classircd__connector.html#a5">SetDescriptor</a>(newfd);
|
|
00220 connector.<a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a3">STATE_NOAUTH_INBOUND</a>);
|
|
00221 <span class="keywordtype">int</span> flags = fcntl(newfd, F_GETFL, 0);
|
|
00222 fcntl(newfd, F_SETFL, flags | O_NONBLOCK);
|
|
00223 <span class="keywordtype">int</span> sendbuf = 32768;
|
|
00224 <span class="keywordtype">int</span> recvbuf = 32768;
|
|
00225 setsockopt(newfd,SOL_SOCKET,SO_SNDBUF,(<span class="keyword">const</span> <span class="keywordtype">void</span> *)&sendbuf,<span class="keyword">sizeof</span>(sendbuf));
|
|
00226 setsockopt(newfd,SOL_SOCKET,SO_RCVBUF,(<span class="keyword">const</span> <span class="keywordtype">void</span> *)&recvbuf,<span class="keyword">sizeof</span>(sendbuf));
|
|
00227 connector.<a class="code" href="classircd__connector.html#a13">SetHostAndPort</a>(targethost, sourceport);
|
|
00228 connector.<a class="code" href="classircd__connector.html#a7">SetState</a>(<a class="code" href="connection_8h.html#a3">STATE_NOAUTH_INBOUND</a>);
|
|
00229 log(<a class="code" href="modules_8h.html#a0">DEBUG</a>,<span class="stringliteral">"serverrec::AddIncoming() Added connection: %s:%d"</span>,targethost,sourceport);
|
|
00230 this-><a class="code" href="classserverrec.html#o11">connectors</a>.push_back(connector);
|
|
00231 <span class="keywordflow">return</span> <span class="keyword">true</span>;
|
|
00232 }
|
|
00233
|
|
<a name="l00234"></a><a class="code" href="classserverrec.html#a6">00234</a> <span class="keywordtype">void</span> <a class="code" href="classserverrec.html#a6">serverrec::TerminateLink</a>(<span class="keywordtype">char</span>* targethost)
|
|
00235 {
|
|
00236 <span class="comment">// this locates the targethost in the serverrec::connectors vector of the class,</span>
|
|
00237 <span class="comment">// and terminates it by sending it an SQUIT token and closing its descriptor.</span>
|
|
00238 <span class="comment">// TerminateLink with a null string causes a terminate of ALL links</span>
|
|
00239 }
|
|
00240
|
|
00241 <span class="comment">// Returns a pointer to the connector for 'host'</span>
|
|
<a name="l00242"></a><a class="code" href="classserverrec.html#a9">00242</a> <a class="code" href="classircd__connector.html">ircd_connector</a>* <a class="code" href="classserverrec.html#a9">serverrec::FindHost</a>(std::string findhost)
|
|
00243 {
|
|
00244 <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++)
|
|
00245 {
|
|
00246 <span class="keywordflow">if</span> (this-><a class="code" href="classserverrec.html#o11">connectors</a>[i].GetServerName() == findhost)
|
|
00247 {
|
|
00248 <span class="keywordflow">return</span> &this-><a class="code" href="classserverrec.html#o11">connectors</a>[i];
|
|
00249 }
|
|
00250 }
|
|
00251 <span class="keywordflow">return</span> NULL;
|
|
00252 }
|
|
00253
|
|
00254
|
|
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="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 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">// 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 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>
|
|
</body>
|
|
</html>
|