2003-01-26 23:52:48 +00:00
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
< html > < head > < meta http-equiv = "Content-Type" content = "text/html;charset=iso-8859-1" >
2005-03-25 03:51:56 +00:00
< title > InspIRCd: servers.cpp Source File< / title >
2005-05-13 15:52:30 +00:00
< link href = "inspircd.doxygen.css" rel = "stylesheet" type = "text/css" >
2003-01-26 23:52:48 +00:00
< / head > < body >
2005-03-25 03:51:56 +00:00
<!-- Generated by Doxygen 1.3.3 -->
2005-05-15 17:05:15 +00:00
< 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 >
2005-03-25 03:51:56 +00:00
< 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
2005-05-24 02:34:33 +00:00
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 > std::deque< std::string> < a class = "code" href = "servers_8cpp.html#a2" > xsums< / a > ;
00041
< a name = "l00042" > < / a > < a class = "code" href = "classserverrec.html#a0" > 00042< / a > < a class = "code" href = "classserverrec.html#a0" > serverrec::serverrec< / a > ()
2005-05-15 17:05:15 +00:00
00043 {
2005-05-24 02:34:33 +00:00
00044 strlcpy(< a class = "code" href = "classserverrec.html#o0" > name< / a > ,< span class = "stringliteral" > ""< / span > ,256);
00045 < a class = "code" href = "classserverrec.html#o1" > pingtime< / a > = 0;
00046 < a class = "code" href = "classconnection.html#o10" > lastping< / a > = < a class = "code" href = "channels_8cpp.html#a36" > TIME< / a > ;
00047 < 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;
00048 < a class = "code" href = "classserverrec.html#o5" > hops_away< / a > = 1;
00049 < a class = "code" href = "classconnection.html#o11" > signon< / a > = < a class = "code" href = "channels_8cpp.html#a36" > TIME< / a > ;
00050 < a class = "code" href = "classserverrec.html#o7" > jupiter< / a > = < span class = "keyword" > false< / span > ;
00051 < a class = "code" href = "classconnection.html#o0" > fd< / a > = 0;
00052 < a class = "code" href = "classserverrec.html#o10" > sync_soon< / a > = < span class = "keyword" > false< / span > ;
00053 strlcpy(< a class = "code" href = "classserverrec.html#o9" > nickserv< / a > ,< span class = "stringliteral" > ""< / span > ,NICKMAX);
00054 < a class = "code" href = "classserverrec.html#o11" > connectors< / a > .clear();
00055 }
00056
00057
< a name = "l00058" > < / a > < a class = "code" href = "classserverrec.html#a2" > 00058< / a > < a class = "code" href = "classserverrec.html#a2" > serverrec::~serverrec< / a > ()
00059 {
00060 }
00061
< a name = "l00062" > < / a > < a class = "code" href = "classserverrec.html#a1" > 00062< / 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)
00063 {
00064 strlcpy(< a class = "code" href = "classserverrec.html#o0" > name< / a > ,n,256);
00065 < a class = "code" href = "classconnection.html#o10" > lastping< / a > = < a class = "code" href = "channels_8cpp.html#a36" > TIME< / a > ;
00066 < 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;
00067 < a class = "code" href = "classserverrec.html#o6" > version< / a > = ver;
00068 < a class = "code" href = "classserverrec.html#o5" > hops_away< / a > = 1;
00069 < a class = "code" href = "classconnection.html#o11" > signon< / a > = < a class = "code" href = "channels_8cpp.html#a36" > TIME< / a > ;
00070 < a class = "code" href = "classserverrec.html#o7" > jupiter< / a > = jupe;
00071 < a class = "code" href = "classconnection.html#o0" > fd< / a > = 0;
00072 < a class = "code" href = "classserverrec.html#o10" > sync_soon< / a > = < span class = "keyword" > false< / span > ;
00073 strlcpy(< a class = "code" href = "classserverrec.html#o9" > nickserv< / a > ,< span class = "stringliteral" > ""< / span > ,NICKMAX);
00074 < a class = "code" href = "classserverrec.html#o11" > connectors< / a > .clear();
00075 }
00076
< a name = "l00077" > < / a > < a class = "code" href = "classserverrec.html#a3" > 00077< / 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)
00078 {
00079 sockaddr_in host_address;
00080 < span class = "keywordtype" > int< / span > flags;
00081 in_addr addy;
00082 < span class = "keywordtype" > int< / span > on = 0;
00083 < span class = "keyword" > struct < / span > linger linger = { 0 };
00084
00085 this-> < a class = "code" href = "classconnection.html#o8" > port< / a > = p;
00086
00087 < a class = "code" href = "classconnection.html#o0" > fd< / a > = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
00088 < span class = "keywordflow" > if< / span > (< a class = "code" href = "classconnection.html#o0" > fd< / a > < = 0)
00089 {
00090 < span class = "keywordflow" > return< / span > < span class = "keyword" > false< / span > ;
00091 }
00092
00093 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));
00094 linger.l_onoff = 1;
00095 linger.l_linger = 1;
00096 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));
00097
00098 < span class = "comment" > // attempt to increase socket sendq and recvq as high as its possible< / span >
00099 < span class = "comment" > // to get them on linux.< / span >
00100 < span class = "keywordtype" > int< / span > sendbuf = 32768;
00101 < span class = "keywordtype" > int< / span > recvbuf = 32768;
00102 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));
00103 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));
00104
00105 memset((< span class = "keywordtype" > void< / span > *)& host_address, 0, < span class = "keyword" > sizeof< / span > (host_address));
00106
00107 host_address.sin_family = AF_INET;
00108
00109 < span class = "keywordflow" > if< / span > (!strcmp(newhost,< span class = "stringliteral" > ""< / span > ))
00110 {
00111 host_address.sin_addr.s_addr = htonl(INADDR_ANY);
00112 }
00113 < span class = "keywordflow" > else< / span >
00114 {
00115 inet_aton(newhost,& addy);
00116 host_address.sin_addr = addy;
00117 }
00118
00119 host_address.sin_port = htons(p);
00120
00121 < 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)
00122 {
00123 < span class = "keywordflow" > return< / span > < span class = "keyword" > false< / span > ;
00124 }
00125
00126 < span class = "comment" > // make the socket non-blocking< / span >
00127 flags = fcntl(< a class = "code" href = "classconnection.html#o0" > fd< / a > , F_GETFL, 0);
00128 fcntl(< a class = "code" href = "classconnection.html#o0" > fd< / a > , F_SETFL, flags | O_NONBLOCK);
00129
00130 this-> < a class = "code" href = "classconnection.html#o8" > port< / a > = p;
00131
00132 listen(this-> fd, < a class = "code" href = "servers_8cpp.html#a1" > MaxConn< / a > );
00133
00134 < span class = "keywordflow" > return< / span > < span class = "keyword" > true< / span > ;
00135 }
00136
00137
< a name = "l00138" > < / a > < a class = "code" href = "classserverrec.html#a4" > 00138< / 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)
00139 {
00140 < span class = "keywordtype" > char< / span > connect[MAXBUF];
00141
00142 < a class = "code" href = "classircd__connector.html" > ircd_connector< / a > connector;
00143 < a class = "code" href = "classircd__connector.html" > ircd_connector< / a > *cn = this-> < a class = "code" href = "classserverrec.html#a9" > FindHost< / a > (servername);
00144
00145
00146 < span class = "keywordflow" > if< / span > (cn)
00147 {
00148 WriteOpers(< span class = "stringliteral" > "CONNECT aborted: Server %s already exists"< / span > ,servername);
00149 < span class = "keywordflow" > return< / span > < span class = "keyword" > false< / span > ;
00150 }
00151
00152
00153 < span class = "keywordflow" > if< / span > (this-> < a class = "code" href = "classconnection.html#o0" > fd< / a > )
00154 {
00155 < span class = "keywordflow" > if< / span > (connector.< a class = "code" href = "classircd__connector.html#a1" > MakeOutboundConnection< / a > (targethost,newport))
00156 {
00157 < span class = "comment" > // targethost has been turned into an ip...< / span >
00158 < span class = "comment" > // we dont want this as the server name.< / span >
00159 connector.< a class = "code" href = "classircd__connector.html#a3" > SetServerName< / a > (servername);
00160 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());
00161 connector.< a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a4" > STATE_NOAUTH_OUTBOUND< / a > );
00162 connector.< a class = "code" href = "classircd__connector.html#a13" > SetHostAndPort< / a > (targethost, newport);
00163 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > .push_back(connector);
00164 < span class = "keywordflow" > return< / span > this-> < a class = "code" href = "classserverrec.html#a7" > SendPacket< / a > (connect, servername);
00165 }
00166 < span class = "keywordflow" > else< / span >
00167 {
00168 connector.< a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a0" > STATE_DISCONNECTED< / a > );
00169 WriteOpers(< span class = "stringliteral" > "Could not create outbound connection to %s:%d"< / span > ,targethost,newport);
00170 }
00171 }
00172 < span class = "keywordflow" > return< / span > < span class = "keyword" > false< / span > ;
00173 }
00174
00175
< a name = "l00176" > < / a > < a class = "code" href = "classserverrec.html#a5" > 00176< / 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)
00177 {
00178 < span class = "keywordtype" > char< / span > connect[MAXBUF];
00179
00180 < a class = "code" href = "classircd__connector.html" > ircd_connector< / a > connector;
00181
00182 WriteOpers(< span class = "stringliteral" > "Establishing meshed link to %s:%d"< / span > ,servername,newport);
00183
00184 < span class = "keywordflow" > if< / span > (this-> < a class = "code" href = "classconnection.html#o0" > fd< / a > )
00185 {
00186 < span class = "keywordflow" > if< / span > (connector.< a class = "code" href = "classircd__connector.html#a1" > MakeOutboundConnection< / a > (targethost,newport))
00187 {
00188 < span class = "comment" > // targethost has been turned into an ip...< / span >
00189 < span class = "comment" > // we dont want this as the server name.< / span >
00190 connector.< a class = "code" href = "classircd__connector.html#a3" > SetServerName< / a > (servername);
00191 snprintf(connect,MAXBUF,< span class = "stringliteral" > "- %lu %s :%s"< / span > ,cookie,getservername().c_str(),getserverdesc().c_str());
00192 connector.< a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a4" > STATE_NOAUTH_OUTBOUND< / a > );
00193 connector.< a class = "code" href = "classircd__connector.html#a13" > SetHostAndPort< / a > (targethost, newport);
00194 connector.< a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a1" > STATE_CONNECTED< / a > );
00195 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > .push_back(connector);
00196 < span class = "keywordflow" > return< / span > this-> < a class = "code" href = "classserverrec.html#a7" > SendPacket< / a > (connect, servername);
00197 }
00198 < span class = "keywordflow" > else< / span >
00199 {
00200 connector.< a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a0" > STATE_DISCONNECTED< / a > );
00201 WriteOpers(< span class = "stringliteral" > "Could not create outbound connection to %s:%d"< / span > ,targethost,newport);
00202 }
00203 }
00204 < span class = "keywordflow" > return< / span > < span class = "keyword" > false< / span > ;
00205 }
00206
< a name = "l00207" > < / a > < a class = "code" href = "classserverrec.html#a10" > 00207< / 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)
00208 {
00209 < a class = "code" href = "classircd__connector.html" > ircd_connector< / a > connector;
00210
00211 < span class = "comment" > // targethost has been turned into an ip...< / span >
00212 < span class = "comment" > // we dont want this as the server name.< / span >
00213 connector.< a class = "code" href = "classircd__connector.html#a3" > SetServerName< / a > (targethost);
00214 connector.< a class = "code" href = "classircd__connector.html#a5" > SetDescriptor< / a > (newfd);
00215 connector.< a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a3" > STATE_NOAUTH_INBOUND< / a > );
00216 < span class = "keywordtype" > int< / span > flags = fcntl(newfd, F_GETFL, 0);
00217 fcntl(newfd, F_SETFL, flags | O_NONBLOCK);
00218 < span class = "keywordtype" > int< / span > sendbuf = 32768;
00219 < span class = "keywordtype" > int< / span > recvbuf = 32768;
00220 setsockopt(newfd,SOL_SOCKET,SO_SNDBUF,(< span class = "keyword" > const< / span > < span class = "keywordtype" > void< / span > *)& sendbuf,< span class = "keyword" > sizeof< / span > (sendbuf));
00221 setsockopt(newfd,SOL_SOCKET,SO_RCVBUF,(< span class = "keyword" > const< / span > < span class = "keywordtype" > void< / span > *)& recvbuf,< span class = "keyword" > sizeof< / span > (sendbuf));
00222 connector.< a class = "code" href = "classircd__connector.html#a13" > SetHostAndPort< / a > (targethost, sourceport);
00223 connector.< a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a3" > STATE_NOAUTH_INBOUND< / a > );
00224 log(< a class = "code" href = "modules_8h.html#a0" > DEBUG< / a > ,< span class = "stringliteral" > "serverrec::AddIncoming() Added connection: %s:%d"< / span > ,targethost,sourceport);
00225 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > .push_back(connector);
00226 < span class = "keywordflow" > return< / span > < span class = "keyword" > true< / span > ;
00227 }
00228
< a name = "l00229" > < / a > < a class = "code" href = "classserverrec.html#a6" > 00229< / a > < span class = "keywordtype" > void< / span > < a class = "code" href = "classserverrec.html#a6" > serverrec::TerminateLink< / a > (< span class = "keywordtype" > char< / span > * targethost)
00230 {
00231 < span class = "comment" > // this locates the targethost in the serverrec::connectors vector of the class,< / span >
00232 < span class = "comment" > // and terminates it by sending it an SQUIT token and closing its descriptor.< / span >
00233 < span class = "comment" > // TerminateLink with a null string causes a terminate of ALL links< / span >
00234 }
00235
00236 < span class = "comment" > // Returns a pointer to the connector for 'host'< / span >
< a name = "l00237" > < / a > < a class = "code" href = "classserverrec.html#a9" > 00237< / a > < a class = "code" href = "classircd__connector.html" > ircd_connector< / a > * < a class = "code" href = "classserverrec.html#a9" > serverrec::FindHost< / a > (std::string findhost)
00238 {
00239 < 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++)
00240 {
00241 < span class = "keywordflow" > if< / span > (this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].GetServerName() == findhost)
00242 {
00243 < span class = "keywordflow" > return< / span > & this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i];
00244 }
00245 }
00246 < span class = "keywordflow" > return< / span > NULL;
00247 }
00248
< a name = "l00249" > < / a > < a class = "code" href = "classserverrec.html#a11" > 00249< / a > < span class = "keywordtype" > void< / span > < a class = "code" href = "classserverrec.html#a11" > serverrec::FlushWriteBuffers< / a > ()
00250 {
00251 < 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++)
00252 {
00253 < 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 > )
00254 {
00255 < span class = "keywordflow" > if< / span > (!this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].CheckPing())
00256 {
00257 WriteOpers(< span class = "stringliteral" > "*** Lost single connection to %s: Ping timeout"< / span > ,this-> connectors[i].GetServerName().c_str());
00258 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].CloseConnection();
00259 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].SetState(< a class = "code" href = "connection_8h.html#a0" > STATE_DISCONNECTED< / a > );
00260 }
00261 }
00262 < span class = "keywordflow" > if< / span > (this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].HasBufferedOutput())
00263 {
00264 < span class = "keywordflow" > if< / span > (!this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].FlushWriteBuf())
00265 {
00266 < span class = "comment" > // if we're here the write() caused an error, we cannot proceed< / span >
00267 WriteOpers(< span class = "stringliteral" > "*** Lost single connection to %s, link inactive and retrying: %s"< / span > ,this-> connectors[i].GetServerName().c_str(),this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].GetWriteError().c_str());
00268 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].CloseConnection();
00269 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].SetState(< a class = "code" href = "connection_8h.html#a0" > STATE_DISCONNECTED< / a > );
00270 }
00271 }
00272 }
00273 }
00274
< a name = "l00275" > < / a > < a class = "code" href = "classserverrec.html#a7" > 00275< / 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)
00276 {
00277 < span class = "keywordflow" > if< / span > ((!message) || (!sendhost))
00278 < span class = "keywordflow" > return< / span > < span class = "keyword" > true< / span > ;
00279
00280 < a class = "code" href = "classircd__connector.html" > ircd_connector< / a > * cn = this-> < a class = "code" href = "classserverrec.html#a9" > FindHost< / a > (sendhost);
00281
00282 < span class = "keywordflow" > if< / span > (!strchr(message,< span class = "charliteral" > '\n'< / span > ))
00283 {
00284 strlcat(message,< span class = "stringliteral" > "\n"< / span > ,MAXBUF);
00285 }
00286
00287 < span class = "keywordflow" > if< / span > (cn)
00288 {
00289 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());
00290
00291 < 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 > )
00292 {
00293 < span class = "comment" > // fix: can only route one hop to avoid a loop< / span >
00294 < span class = "keywordflow" > if< / span > (strncmp(message,< span class = "stringliteral" > "R "< / span > ,2))
00295 {
00296 log(< a class = "code" href = "modules_8h.html#a0" > DEBUG< / a > ,< span class = "stringliteral" > "Not a double reroute"< / span > );
00297 < span class = "comment" > // this route is down, we must re-route the packet through an available point in the mesh.< / span >
00298 < 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++)
00299 {
00300 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());
00301 < span class = "comment" > // search for another point in the mesh which can 'reach' where we want to go< / span >
00302 < 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++)
00303 {
00304 < span class = "keywordflow" > if< / span > (!strcasecmp(this-> connectors[k].routes[m].c_str(),sendhost))
00305 {
00306 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());
00307 < span class = "keywordtype" > char< / span > buffer[MAXBUF];
00308 snprintf(buffer,MAXBUF,< span class = "stringliteral" > "R %s %s"< / span > ,sendhost,message);
00309 this-> < a class = "code" href = "classserverrec.html#a7" > SendPacket< / a > (buffer,this-> connectors[k].GetServerName().c_str());
00310 < span class = "keywordflow" > return< / span > < span class = "keyword" > true< / span > ;
00311 }
00312 }
00313 }
00314 }
00315 < span class = "keywordtype" > char< / span > buffer[MAXBUF];
00316 snprintf(buffer,MAXBUF,< span class = "stringliteral" > "& %s"< / span > ,sendhost);
00317 WriteOpers(< span class = "stringliteral" > "*** All connections to %s lost."< / span > ,sendhost);
00318 NetSendToAllExcept(sendhost,buffer);
00319 DoSplit(sendhost);
00320 < span class = "keywordflow" > return< / span > < span class = "keyword" > false< / span > ;
00321 }
00322
00323 < span class = "comment" > // returns false if the packet could not be sent (e.g. target host down)< / span >
00324 < span class = "keywordflow" > if< / span > (!cn-> < a class = "code" href = "classircd__connector.html#a21" > AddWriteBuf< / a > (message))
00325 {
00326 < span class = "comment" > // if we're here, there was an error pending, and the send cannot proceed< / span >
00327 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());
00328 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());
00329 cn-> < a class = "code" href = "classircd__connector.html#a14" > CloseConnection< / a > ();
00330 cn-> < a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a0" > STATE_DISCONNECTED< / a > );
00331 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());
00332 < span class = "comment" > // retry the packet along a new route so either arrival OR failure are gauranteed (bugfix)< / span >
00333 < span class = "keywordflow" > return< / span > this-> < a class = "code" href = "classserverrec.html#a7" > SendPacket< / a > (message,sendhost);
00334 }
00335 < span class = "keywordflow" > if< / span > (!cn-> < a class = "code" href = "classircd__connector.html#a22" > FlushWriteBuf< / a > ())
00336 {
00337 < span class = "comment" > // if we're here the write() caused an error, we cannot proceed< / span >
00338 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());
00339 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());
00340 cn-> < a class = "code" href = "classircd__connector.html#a14" > CloseConnection< / a > ();
00341 cn-> < a class = "code" href = "classircd__connector.html#a7" > SetState< / a > (< a class = "code" href = "connection_8h.html#a0" > STATE_DISCONNECTED< / a > );
00342 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());
00343 < span class = "comment" > // retry the packet along a new route so either arrival OR failure are gauranteed< / span >
00344 < span class = "keywordflow" > return< / span > this-> < a class = "code" href = "classserverrec.html#a7" > SendPacket< / a > (message,sendhost);
00345 }
00346 < span class = "keywordflow" > return< / span > < span class = "keyword" > true< / span > ;
00347 }
00348 }
00349
< a name = "l00350" > < / a > < a class = "code" href = "servers_8cpp.html#a3" > 00350< / a > < span class = "keywordtype" > bool< / span > < a class = "code" href = "servers_8cpp.html#a3" > already_have_sum< / a > (std::string sum)
00351 {
00352 < span class = "keywordflow" > for< / span > (< span class = "keywordtype" > int< / span > i = 0; i < < a class = "code" href = "servers_8cpp.html#a2" > xsums< / a > .size(); i++)
00353 {
00354 < span class = "keywordflow" > if< / span > (< a class = "code" href = "servers_8cpp.html#a2" > xsums< / a > [i] == sum)
00355 {
00356 < span class = "keywordflow" > return< / span > < span class = "keyword" > true< / span > ;
00357 }
00358 }
00359 < span class = "keywordflow" > if< / span > (< a class = "code" href = "servers_8cpp.html#a2" > xsums< / a > .size() > = 128)
00360 {
00361 < a class = "code" href = "servers_8cpp.html#a2" > xsums< / a > .pop_front();
00362 }
00363 < a class = "code" href = "servers_8cpp.html#a2" > xsums< / a > .push_back(sum);
00364 < span class = "keywordflow" > return< / span > < span class = "keyword" > false< / span > ;
00365 }
00366
00367 < span class = "comment" > // receives a packet from any where there is data waiting, first come, first served< / span >
00368 < span class = "comment" > // fills the message and host values with the host where the data came from.< / span >
00369
< a name = "l00370" > < / a > < a class = "code" href = "classserverrec.html#a8" > 00370< / 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)
00371 {
00372 < span class = "keywordtype" > char< / span > data[65536];
00373 memset(data, 0, 65536);
00374 < 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++)
00375 {
00376 < 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 > )
00377 {
00378 < span class = "comment" > // returns false if the packet could not be sent (e.g. target host down)< / span >
00379 < span class = "keywordtype" > int< / span > rcvsize = 0;
00380
00381 < span class = "comment" > // check if theres any data on this socket< / span >
00382 < span class = "comment" > // if not, continue onwards to the next.< / span >
00383 pollfd polls;
00384 polls.fd = this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].GetDescriptor();
00385 polls.events = POLLIN;
00386 < span class = "keywordtype" > int< / span > ret = poll(& polls,1,1);
00387 < span class = "keywordflow" > if< / span > (ret < = 0) < span class = "keywordflow" > continue< / span > ;
00388
00389 rcvsize = recv(this-> connectors[i].GetDescriptor(),data,65000,0);
00390 data[rcvsize] = < span class = "charliteral" > '\0'< / span > ;
00391 < span class = "keywordflow" > if< / span > (rcvsize == -1)
00392 {
00393 < span class = "keywordflow" > if< / span > (errno != EAGAIN)
00394 {
00395 log(< a class = "code" href = "modules_8h.html#a0" > DEBUG< / a > ,< span class = "stringliteral" > "recv() failed for serverrec::RecvPacket(): %s"< / span > ,strerror(errno));
00396 log(< a class = "code" href = "modules_8h.html#a0" > DEBUG< / a > ,< span class = "stringliteral" > "Disabling connector: %s"< / span > ,this-> connectors[i].GetServerName().c_str());
00397 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].CloseConnection();
00398 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].SetState(< a class = "code" href = "connection_8h.html#a0" > STATE_DISCONNECTED< / a > );
00399 }
00400 }
00401 < span class = "keywordtype" > int< / span > pushed = 0;
00402 < span class = "keywordflow" > if< / span > (rcvsize > 0)
00403 {
00404 < span class = "keywordflow" > if< / span > (!this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].AddBuffer(data))
00405 {
00406 WriteOpers(< span class = "stringliteral" > "*** Read buffer for %s exceeds maximum, closing connection!"< / span > ,this-> connectors[i].GetServerName().c_str());
00407 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].CloseConnection();
00408 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].SetState(< a class = "code" href = "connection_8h.html#a0" > STATE_DISCONNECTED< / a > );
00409 }
00410 < span class = "keywordflow" > if< / span > (this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].BufferIsComplete())
00411 {
00412 this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].ResetPing();
00413 < span class = "keywordflow" > while< / span > (this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].BufferIsComplete())
00414 {
00415 std::string text = this-> < a class = "code" href = "classserverrec.html#o11" > connectors< / a > [i].GetBuffer();
00416 < span class = "keywordflow" > if< / span > (text != < span class = "stringliteral" > ""< / span > )
00417 {
00418 < span class = "keywordflow" > if< / span > ((text[0] == < span class = "charliteral" > ':'< / span > ) & & (text.find(< span class = "stringliteral" > " "< / span > ) != std::string::npos))
00419 {
00420 std::string orig = text;
00421 log(< a class = "code" href = "modules_8h.html#a0" > DEBUG< / a > ,< span class = "stringliteral" > "Original: %s"< / span > ,text.c_str());
00422 std::string sum = text.substr(1,text.find(< span class = "stringliteral" > " "< / span > )-1);
00423 text = text.substr(text.find(< span class = "stringliteral" > " "< / span > )+1,text.length());
00424 std::string possible_token = text.substr(1,text.find(< span class = "stringliteral" > " "< / span > )-1);
00425 < span class = "keywordflow" > if< / span > (possible_token.length() > 1)
00426 {
00427 sums.push_back(< span class = "stringliteral" > "*"< / span > );
00428 text = orig;
00429 log(< a class = "code" href = "modules_8h.html#a0" > DEBUG< / a > ,< span class = "stringliteral" > "Non-mesh, non-tokenized string passed up the chain"< / span > );
00430 }
00431 < span class = "keywordflow" > else< / span >
00432 {
00433 log(< a class = "code" href = "modules_8h.html#a0" > DEBUG< / a > ,< span class = "stringliteral" > "Packet sum: '%s'"< / span > ,sum.c_str());
00434 < span class = "keywordflow" > if< / span > ((< a class = "code" href = "servers_8cpp.html#a3" > already_have_sum< / a > (sum)) & & (sum != < span class = "stringliteral" > "*"< / span > ))
00435 {
00436 < span class = "comment" > // we don't accept dupes< / span >
00437 < span class = "keywordflow" > continue< / span > ;
00438 }
00439 sums.push_back(sum.c_str());
00440 }
00441 }
00442 < span class = "keywordflow" > else< / span > sums.push_back(< span class = "stringliteral" > "*"< / span > );
00443 messages.push_back(text.c_str());
00444 strlcpy(recvhost,this-> connectors[i].GetServerName().c_str(),160);
00445 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());
00446 }
00447 }
00448 < span class = "keywordflow" > return< / span > < span class = "keyword" > true< / span > ;
00449 }
00450 }
00451 }
00452 }
00453 < span class = "comment" > // nothing new yet -- message and host will be undefined< / span >
00454 < span class = "keywordflow" > return< / span > < span class = "keyword" > false< / span > ;
00455 }
00456
< / pre > < / div > < hr size = "1" > < address style = "align: right;" > < small > Generated on Tue May 24 02:30:06 2005 for InspIRCd by
2003-01-26 23:52:48 +00:00
< a href = "http://www.doxygen.org/index.html" >
2005-03-25 03:51:56 +00:00
< img src = "doxygen.png" alt = "doxygen" align = "middle" border = 0 >
< / a > 1.3.3 < / small > < / address >
2003-01-26 23:52:48 +00:00
< / body >
< / html >
