From 48e477893fdc3cd87b46e445b1e3e2d1395c4b94 Mon Sep 17 00:00:00 2001 From: brain Date: Wed, 14 Dec 2005 16:07:04 +0000 Subject: Removed depreciated docs git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@2420 e03df62e-2008-0410-955e-edbf42e46eb7 --- docs/module-doc/classserverrec.html | 1447 ----------------------------------- 1 file changed, 1447 deletions(-) delete mode 100644 docs/module-doc/classserverrec.html (limited to 'docs/module-doc/classserverrec.html') diff --git a/docs/module-doc/classserverrec.html b/docs/module-doc/classserverrec.html deleted file mode 100644 index 87775403b..000000000 --- a/docs/module-doc/classserverrec.html +++ /dev/null @@ -1,1447 +0,0 @@ - - -InspIRCd: serverrec class Reference - - - -
Main Page | Namespace List | Class Hierarchy | Alphabetical List | Compound List | File List | Namespace Members | Compound Members | File Members
-

serverrec Class Reference

A class that defines the local server or a remote server. -More... -

-#include <servers.h> -

-Inheritance diagram for serverrec:

Inheritance graph
- - - - - -
[legend]
Collaboration diagram for serverrec:

Collaboration graph
- - - -
[legend]
List of all members. - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -

Public Member Functions

 serverrec ()
 Constructor.

 serverrec (char *n, long ver, bool jupe)
 Constructor which initialises some of the main variables.

 ~serverrec ()
 Destructor.

bool CreateListener (char *host, int p)
 Create a listening socket on 'host' using port number 'p'.

bool BeginLink (char *targethost, int port, char *password, char *servername, int myport)
 Begin an outbound link to another ircd at targethost.

bool MeshCookie (char *targethost, int port, unsigned long cookie, char *servername)
 Begin an outbound mesh link to another ircd on a network you are already an authenticated member of.

void TerminateLink (char *targethost)
 Terminate a link to 'targethost' by calling the ircd_connector::CloseConnection method.

bool SendPacket (char *message, const char *host)
 Send a message to a server by name, if the server is unavailable directly route the packet via another server If the server still cannot be reached after attempting to route the message remotely, returns false.

bool RecvPacket (std::deque< std::string > &messages, char *host, std::deque< std::string > &sums)
 Returns the next available packet and returns true if data is available.

ircd_connector * FindHost (std::string host)
 Find the ircd_connector oject related to a certain servername given in 'host'.

bool AddIncoming (int fd, char *targethost, int sourceport)
 Add an incoming connection to the connection pool.

void FlushWriteBuffers ()
 Flushes all data waiting to be written for all of this server's connections.


Public Attributes

char name [MAXBUF]
 server name

long pingtime
 last ping response (ms)

long usercount_i
 invisible users on server

long usercount
 non-invisible users on server

long opercount
 opers on server

int hops_away
 number of hops away (for quick access)

long version
 ircd version

bool jupiter
 is a JUPE server (faked to enforce a server ban)

char description [MAXBUF]
 Description of the server.

char nickserv [NICKMAX]
 Holds nickserv's name on U:lined (services) servers (this is a kludge for ircservices which ASSUMES things :/).

bool sync_soon
std::vector< ircd_connector > connectors
 With a serverrec, this is a list of all established server connections.

-

Detailed Description

-A class that defines the local server or a remote server. -

- -

-Definition at line 30 of file servers.h.

Constructor & Destructor Documentation

-

- - - - -
- - - - - - - - - -
serverrec::serverrec (   ) 
-
- - - - - -
-   - - -

-Constructor. -

- -

-Definition at line 46 of file servers.cpp. -

-References connectors, connection::fd, hops_away, jupiter, connection::lastping, name, nickserv, opercount, pingtime, connection::signon, sync_soon, TIME, usercount, usercount_i, and version. -

-

00047 {
-00048         strlcpy(name,"",256);
-00049         pingtime = 0;
-00050         lastping = TIME;
-00051         usercount_i = usercount = opercount = version = 0;
-00052         hops_away = 1;
-00053         signon = TIME;
-00054         jupiter = false;
-00055         fd = 0;
-00056         sync_soon = false;
-00057         strlcpy(nickserv,"",NICKMAX);
-00058         connectors.clear();
-00059 }
-
-

- - - - -
- - - - - - - - - - - - - - - - - - - - - - - - - -
serverrec::serverrec ( char *  n,
long  ver,
bool  jupe
) 
-
- - - - - -
-   - - -

-Constructor which initialises some of the main variables. -

- -

-Definition at line 66 of file servers.cpp. -

-References connectors, connection::fd, hops_away, jupiter, connection::lastping, name, nickserv, opercount, connection::signon, sync_soon, TIME, usercount, usercount_i, and version. -

-

00067 {
-00068         strlcpy(name,n,256);
-00069         lastping = TIME;
-00070         usercount_i = usercount = opercount = 0;
-00071         version = ver;
-00072         hops_away = 1;
-00073         signon = TIME;
-00074         jupiter = jupe;
-00075         fd = 0;
-00076         sync_soon = false;
-00077         strlcpy(nickserv,"",NICKMAX);
-00078         connectors.clear();
-00079 }
-
-

- - - - -
- - - - - - - - - -
serverrec::~serverrec (   ) 
-
- - - - - -
-   - - -

-Destructor. -

- -

-Definition at line 62 of file servers.cpp. -

-

00063 {
-00064 }
-
-

Member Function Documentation

-

- - - - -
- - - - - - - - - - - - - - - - - - - - - - - - - -
bool serverrec::AddIncoming ( int  fd,
char *  targethost,
int  sourceport
) 
-
- - - - - -
-   - - -

-Add an incoming connection to the connection pool. -

-(reserved for core use) -

-Definition at line 212 of file servers.cpp. -

-References connectors, DEBUG, ircd_connector::SetDescriptor(), ircd_connector::SetHostAndPort(), ircd_connector::SetServerName(), ircd_connector::SetState(), and STATE_NOAUTH_INBOUND. -

-

00213 {
-00214         ircd_connector connector;
-00215 
-00216         // targethost has been turned into an ip...
-00217         // we dont want this as the server name.
-00218         connector.SetServerName(targethost);
-00219         connector.SetDescriptor(newfd);
-00220         connector.SetState(STATE_NOAUTH_INBOUND);
-00221         int flags = fcntl(newfd, F_GETFL, 0);
-00222         fcntl(newfd, F_SETFL, flags | O_NONBLOCK);
-00223         int sendbuf = 32768;
-00224         int recvbuf = 32768;
-00225         setsockopt(newfd,SOL_SOCKET,SO_SNDBUF,(const void *)&sendbuf,sizeof(sendbuf));
-00226         setsockopt(newfd,SOL_SOCKET,SO_RCVBUF,(const void *)&recvbuf,sizeof(sendbuf));
-00227         connector.SetHostAndPort(targethost, sourceport);
-00228         connector.SetState(STATE_NOAUTH_INBOUND);
-00229         log(DEBUG,"serverrec::AddIncoming() Added connection: %s:%d",targethost,sourceport);
-00230         this->connectors.push_back(connector);
-00231         return true;
-00232 }
-
-

- - - - -
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
bool serverrec::BeginLink ( char *  targethost,
int  port,
char *  password,
char *  servername,
int  myport
) 
-
- - - - - -
-   - - -

-Begin an outbound link to another ircd at targethost. -

- -

-Definition at line 142 of file servers.cpp. -

-References connectors, connection::fd, FindHost(), ircd_connector::MakeOutboundConnection(), SendPacket(), ircd_connector::SetHostAndPort(), ircd_connector::SetServerName(), ircd_connector::SetState(), STATE_DISCONNECTED, and STATE_NOAUTH_OUTBOUND. -

-

00143 {
-00144         char connect[MAXBUF];
-00145 
-00146         ircd_connector connector;
-00147         ircd_connector *cn = this->FindHost(servername);
-00148 
-00149 
-00150         if (cn)
-00151         {
-00152                 WriteOpers("CONNECT aborted: Server %s already exists",servername);
-00153                 return false;
-00154         }
-00155 
-00156 
-00157         if (this->fd)
-00158         {
-00159                 if (connector.MakeOutboundConnection(targethost,newport))
-00160                 {
-00161                         // targethost has been turned into an ip...
-00162                         // we dont want this as the server name.
-00163                         connector.SetServerName(servername);
-00164                         snprintf(connect,MAXBUF,"S %s %s %lu %s :%s",getservername().c_str(),password,(unsigned long)myport,GetRevision().c_str(),getserverdesc().c_str());
-00165                         connector.SetState(STATE_NOAUTH_OUTBOUND);
-00166                         connector.SetHostAndPort(targethost, newport);
-00167                         this->connectors.push_back(connector);
-00168                         // this packet isn't actually sent until the socket connects -- the STATE_NOAUTH_OUTBOUND state
-00169                         // queues outbound data until the socket is polled as writeable (e.g. the connection is established)
-00170                         return this->SendPacket(connect, servername);
-00171                 }
-00172                 else
-00173                 {
-00174                         connector.SetState(STATE_DISCONNECTED);
-00175                         WriteOpers("Could not create outbound connection to %s:%d",targethost,newport);
-00176                 }
-00177         }
-00178         return false;
-00179 }
-
-

- - - - -
- - - - - - - - - - - - - - - - - - - -
bool serverrec::CreateListener ( char *  host,
int  p
) 
-
- - - - - -
-   - - -

-Create a listening socket on 'host' using port number 'p'. -

- -

-Definition at line 81 of file servers.cpp. -

-References connection::fd, MaxConn, and connection::port. -

-

00082 {
-00083         sockaddr_in host_address;
-00084         int flags;
-00085         in_addr addy;
-00086         int on = 0;
-00087         struct linger linger = { 0 };
-00088 
-00089         this->port = p;
-00090 
-00091         fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
-00092         if (fd <= 0)
-00093         {
-00094                 return false;
-00095         }
-00096 
-00097         setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,(const char*)&on,sizeof(on));
-00098         linger.l_onoff = 1;
-00099         linger.l_linger = 1;
-00100         setsockopt(fd,SOL_SOCKET,SO_LINGER,(const char*)&linger,sizeof(linger));
-00101 
-00102         // attempt to increase socket sendq and recvq as high as its possible
-00103         // to get them on linux.
-00104         int sendbuf = 32768;
-00105         int recvbuf = 32768;
-00106         setsockopt(fd,SOL_SOCKET,SO_SNDBUF,(const void *)&sendbuf,sizeof(sendbuf));
-00107         setsockopt(fd,SOL_SOCKET,SO_RCVBUF,(const void *)&recvbuf,sizeof(sendbuf));
-00108 
-00109         memset((void*)&host_address, 0, sizeof(host_address));
-00110 
-00111         host_address.sin_family = AF_INET;
-00112 
-00113         if (!strcmp(newhost,""))
-00114         {
-00115                 host_address.sin_addr.s_addr = htonl(INADDR_ANY);
-00116         }
-00117         else
-00118         {
-00119                 inet_aton(newhost,&addy);
-00120                 host_address.sin_addr = addy;
-00121         }
-00122 
-00123         host_address.sin_port = htons(p);
-00124 
-00125         if (bind(fd,(sockaddr*)&host_address,sizeof(host_address))<0)
-00126         {
-00127                 return false;
-00128         }
-00129 
-00130         // make the socket non-blocking
-00131         flags = fcntl(fd, F_GETFL, 0);
-00132         fcntl(fd, F_SETFL, flags | O_NONBLOCK);
-00133 
-00134         this->port = p;
-00135 
-00136         listen(this->fd, MaxConn);
-00137 
-00138         return true;
-00139 }
-
-

- - - - -
- - - - - - - - - - -
ircd_connector * serverrec::FindHost ( std::string  host  ) 
-
- - - - - -
-   - - -

-Find the ircd_connector oject related to a certain servername given in 'host'. -

- -

-Definition at line 242 of file servers.cpp. -

-References connectors. -

-Referenced by BeginLink(), and SendPacket(). -

-

00243 {
-00244         for (int i = 0; i < this->connectors.size(); i++)
-00245         {
-00246                 if (this->connectors[i].GetServerName() == findhost)
-00247                 {
-00248                         return &this->connectors[i];
-00249                 }
-00250         }
-00251         return NULL;
-00252 }
-
-

- - - - -
- - - - - - - - - -
void serverrec::FlushWriteBuffers (   ) 
-
- - - - - -
-   - - -

-Flushes all data waiting to be written for all of this server's connections. -

- -

-Definition at line 274 of file servers.cpp. -

-References connectors, has_been_netsplit, IsRoutable(), STATE_DISCONNECTED, STATE_NOAUTH_INBOUND, STATE_NOAUTH_OUTBOUND, and TIME. -

-

00275 {
-00276         char buffer[MAXBUF];
-00277         for (int i = 0; i < this->connectors.size(); i++)
-00278         {
-00279                 // don't try and ping a NOAUTH_OUTBOUND state, its not authed yet!
-00280                 if ((this->connectors[i].GetState() == STATE_NOAUTH_OUTBOUND) && (TIME > this->connectors[i].age+30))
-00281                 {
-00282                         // however if we reach this timer its connected timed out :)
-00283                         WriteOpers("*** Connection to %s timed out",this->connectors[i].GetServerName().c_str());
-00284                         snprintf(buffer,MAXBUF,"& %s",this->connectors[i].GetServerName().c_str());
-00285                         NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer);
-00286                         DoSplit(this->connectors[i].GetServerName().c_str());
-00287                         return;
-00288                 }
-00289                 if ((this->connectors[i].GetState() == STATE_NOAUTH_INBOUND) && (TIME > this->connectors[i].age+30))
-00290                 {
-00291                         WriteOpers("*** Connection from %s timed out",this->connectors[i].GetServerName().c_str());
-00292                         snprintf(buffer,MAXBUF,"& %s",this->connectors[i].GetServerName().c_str());
-00293                         NetSendToAllExcept(this->connectors[i].GetServerName().c_str(),buffer);
-00294                         DoSplit(this->connectors[i].GetServerName().c_str());
-00295                         return;
-00296                 }
-00297                 if (this->connectors[i].GetState() != STATE_DISCONNECTED)
-00298                 {
-00299                         if (!this->connectors[i].CheckPing())
-00300                         {
-00301                                 WriteOpers("*** Lost single connection to %s: Ping timeout",this->connectors[i].GetServerName().c_str());
-00302                                 this->connectors[i].CloseConnection();
-00303                                 this->connectors[i].SetState(STATE_DISCONNECTED);
-00304                                 if (!IsRoutable(this->connectors[i].GetServerName()))
-00305                                 {
-00306                                         WriteOpers("*** Server %s is no longer routable, disconnecting.",this->connectors[i].GetServerName().c_str());
-00307                                         snprintf(buffer,MAXBUF,"& %s",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                                 has_been_netsplit = true;
-00312                         }
-00313                 }
-00314                 if ((this->connectors[i].GetWriteError() !="") && (this->connectors[i].GetState() != STATE_DISCONNECTED))
-00315                 {
-00316                         // if we're here the write() caused an error, we cannot proceed
-00317                         WriteOpers("*** Lost single connection to %s, link inactive and retrying: %s",this->connectors[i].GetServerName().c_str(),this->connectors[i].GetWriteError().c_str());
-00318                         this->connectors[i].CloseConnection();
-00319                         this->connectors[i].SetState(STATE_DISCONNECTED);
-00320                         if (!IsRoutable(this->connectors[i].GetServerName()))
-00321                         {
-00322                                 WriteOpers("*** Server %s is no longer routable, disconnecting.",this->connectors[i].GetServerName().c_str());
-00323                                 snprintf(buffer,MAXBUF,"& %s",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                         has_been_netsplit = true;
-00328                 }
-00329                 if ((this->connectors[i].HasBufferedOutput()) && (this->connectors[i].GetState() != STATE_DISCONNECTED))
-00330                 {
-00331                         if (!this->connectors[i].FlushWriteBuf())
-00332                         {
-00333                                 // if we're here the write() caused an error, we cannot proceed
-00334                                 WriteOpers("*** Lost single connection to %s, link inactive and retrying: %s",this->connectors[i].GetServerName().c_str(),this->connectors[i].GetWriteError().c_str());
-00335                                 this->connectors[i].CloseConnection();
-00336                                 this->connectors[i].SetState(STATE_DISCONNECTED);
-00337                                 if (!IsRoutable(this->connectors[i].GetServerName()))
-00338                                 {
-00339                                         WriteOpers("*** Server %s is no longer routable, disconnecting.",this->connectors[i].GetServerName().c_str());
-00340                                         snprintf(buffer,MAXBUF,"& %s",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                                 has_been_netsplit = true;
-00345                         }
-00346                 }
-00347         }
-00348 }
-
-

- - - - -
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
bool serverrec::MeshCookie ( char *  targethost,
int  port,
unsigned long  cookie,
char *  servername
) 
-
- - - - - -
-   - - -

-Begin an outbound mesh link to another ircd on a network you are already an authenticated member of. -

- -

-Definition at line 182 of file servers.cpp. -

-References connectors, connection::fd, ircd_connector::MakeOutboundConnection(), SendPacket(), ircd_connector::SetHostAndPort(), ircd_connector::SetServerName(), ircd_connector::SetState(), STATE_DISCONNECTED, and STATE_NOAUTH_OUTBOUND. -

-

00183 {
-00184         char connect[MAXBUF];
-00185 
-00186         ircd_connector connector;
-00187 
-00188         WriteOpers("Establishing meshed link to %s:%d",servername,newport);
-00189 
-00190         if (this->fd)
-00191         {
-00192                 if (connector.MakeOutboundConnection(targethost,newport))
-00193                 {
-00194                         // targethost has been turned into an ip...
-00195                         // we dont want this as the server name.
-00196                         connector.SetServerName(servername);
-00197                         snprintf(connect,MAXBUF,"- %lu %s :%s",cookie,getservername().c_str(),getserverdesc().c_str());
-00198                         connector.SetState(STATE_NOAUTH_OUTBOUND);
-00199                         connector.SetHostAndPort(targethost, newport);
-00200                         this->connectors.push_back(connector);
-00201                         return this->SendPacket(connect, servername);
-00202                 }
-00203                 else
-00204                 {
-00205                         connector.SetState(STATE_DISCONNECTED);
-00206                         WriteOpers("Could not create outbound connection to %s:%d",targethost,newport);
-00207                 }
-00208         }
-00209         return false;
-00210 }
-
-

- - - - -
- - - - - - - - - - - - - - - - - - - - - - - - - -
bool serverrec::RecvPacket ( std::deque< std::string > &  messages,
char *  host,
std::deque< std::string > &  sums
) 
-
- - - - - -
-   - - -

-Returns the next available packet and returns true if data is available. -

-Writes the servername the data came from to 'host'. If no data is available this function returns false. This function will automatically close broken links and reroute pathways, generating split messages on the network. -

-Definition at line 445 of file servers.cpp. -

-References already_have_sum(), connectors, DEBUG, has_been_netsplit, IsRoutable(), and STATE_DISCONNECTED. -

-

00446 {
-00447         char data[65536],buffer[MAXBUF];
-00448         memset(data, 0, 65536);
-00449         for (int i = 0; i < this->connectors.size(); i++)
-00450         {
-00451                 if (this->connectors[i].GetState() != STATE_DISCONNECTED)
-00452                 {
-00453                         // returns false if the packet could not be sent (e.g. target host down)
-00454                         int rcvsize = 0;
-00455 
-00456                         // check if theres any data on this socket
-00457                         // if not, continue onwards to the next.
-00458                         pollfd polls;
-00459                         polls.fd = this->connectors[i].GetDescriptor();
-00460                         polls.events = POLLIN;
-00461                         int ret = poll(&polls,1,1);
-00462                         if (ret <= 0) continue;
-00463 
-00464                         rcvsize = recv(this->connectors[i].GetDescriptor(),data,65000,0);
-00465                         data[rcvsize] = '\0';
-00466                         if (rcvsize == 0)
-00467                         {
-00468                                 log(DEBUG,"recv() failed for serverrec::RecvPacket(): EOF");
-00469                                 log(DEBUG,"Disabling connector: %s",this->connectors[i].GetServerName().c_str());
-00470                                 this->connectors[i].CloseConnection();
-00471                                 this->connectors[i].SetState(STATE_DISCONNECTED);
-00472                                 if (!IsRoutable(this->connectors[i].GetServerName()))
-00473                                 {
-00474                                         WriteOpers("*** Server %s is no longer routable, disconnecting (EOF)",this->connectors[i].GetServerName().c_str());
-00475                                         snprintf(buffer,MAXBUF,"& %s",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                                 has_been_netsplit = true;
-00480                         }
-00481                         if (rcvsize == -1)
-00482                         {
-00483                                 if (errno != EAGAIN)
-00484                                 {
-00485                                         log(DEBUG,"recv() failed for serverrec::RecvPacket(): %s",strerror(errno));
-00486                                         log(DEBUG,"Disabling connector: %s",this->connectors[i].GetServerName().c_str());
-00487                                         this->connectors[i].CloseConnection();
-00488                                         this->connectors[i].SetState(STATE_DISCONNECTED);
-00489                                         if (!IsRoutable(this->connectors[i].GetServerName()))
-00490                                         {
-00491                                                 WriteOpers("*** Server %s is no longer routable, disconnecting.",this->connectors[i].GetServerName().c_str());
-00492                                                 snprintf(buffer,MAXBUF,"& %s",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                                         has_been_netsplit = true;
-00497                                 }
-00498                         }
-00499                         int pushed = 0;
-00500                         if (rcvsize > 0)
-00501                         {
-00502                                 if (!this->connectors[i].AddBuffer(data))
-00503                                 {
-00504                                         WriteOpers("*** Read buffer for %s exceeds maximum, closing connection!",this->connectors[i].GetServerName().c_str());
-00505                                         this->connectors[i].CloseConnection();
-00506                                         this->connectors[i].SetState(STATE_DISCONNECTED);
-00507                                         if (!IsRoutable(this->connectors[i].GetServerName()))
-00508                                         {
-00509                                                 WriteOpers("*** Server %s is no longer routable, disconnecting.",this->connectors[i].GetServerName().c_str());
-00510                                                 snprintf(buffer,MAXBUF,"& %s",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                                         has_been_netsplit = true;
-00515                                 }
-00516                                 if (this->connectors[i].BufferIsComplete())
-00517                                 {
-00518                                         this->connectors[i].ResetPing();
-00519                                         while (this->connectors[i].BufferIsComplete())
-00520                                         {
-00521                                                 std::string text = this->connectors[i].GetBuffer();
-00522                                                 if (text != "")
-00523                                                 {
-00524                                                         if ((text[0] == ':') && (text.find(" ") != std::string::npos))
-00525                                                         {
-00526                                                                 std::string orig = text;
-00527                                                                 log(DEBUG,"Original: %s",text.c_str());
-00528                                                                 std::string sum = text.substr(1,text.find(" ")-1);
-00529                                                                 text = text.substr(text.find(" ")+1,text.length());
-00530                                                                 std::string possible_token = text.substr(1,text.find(" ")-1);
-00531                                                                 if (possible_token.length() > 1)
-00532                                                                 {
-00533                                                                         sums.push_back("*");
-00534                                                                         text = orig;
-00535                                                                         log(DEBUG,"Non-mesh, non-tokenized string passed up the chain");
-00536                                                                 }
-00537                                                                 else
-00538                                                                 {
-00539                                                                         log(DEBUG,"Packet sum: '%s'",sum.c_str());
-00540                                                                         if ((already_have_sum(sum)) && (sum != "*"))
-00541                                                                         {
-00542                                                                                 // we don't accept dupes
-00543                                                                                 continue;
-00544                                                                         }
-00545                                                                         sums.push_back(sum.c_str());
-00546                                                                 }
-00547                                                         }
-00548                                                         else sums.push_back("*");
-00549                                                         messages.push_back(text.c_str());
-00550                                                         strlcpy(recvhost,this->connectors[i].GetServerName().c_str(),160);
-00551                                                         log(DEBUG,"serverrec::RecvPacket() %d:%s->%s",pushed++,recvhost,text.c_str());
-00552                                                 }
-00553                                         }
-00554                                         return true;
-00555                                 }
-00556                         }
-00557                 }
-00558         }
-00559         // nothing new yet -- message and host will be undefined
-00560         return false;
-00561 }
-
-

- - - - -
- - - - - - - - - - - - - - - - - - - -
bool serverrec::SendPacket ( char *  message,
const char *  host
) 
-
- - - - - -
-   - - -

-Send a message to a server by name, if the server is unavailable directly route the packet via another server If the server still cannot be reached after attempting to route the message remotely, returns false. -

- -

-Definition at line 350 of file servers.cpp. -

-References ircd_connector::AddWriteBuf(), ircd_connector::CloseConnection(), connectors, DEBUG, FindHost(), ircd_connector::FlushWriteBuf(), ircd_connector::GetServerName(), ircd_connector::GetState(), ircd_connector::GetWriteError(), ircd_connector::SetState(), and STATE_DISCONNECTED. -

-Referenced by BeginLink(), and MeshCookie(). -

-

00351 {
-00352         if ((!message) || (!sendhost))
-00353                 return true;
-00354 
-00355         ircd_connector* cn = this->FindHost(sendhost);
-00356 
-00357         if (!strchr(message,'\n'))
-00358         {
-00359                 strlcat(message,"\n",MAXBUF);
-00360         }
-00361 
-00362         if (cn)
-00363         {
-00364                 log(DEBUG,"main: serverrec::SendPacket() sent '%s' to %s",message,cn->GetServerName().c_str());
-00365 
-00366                 if (cn->GetState() == STATE_DISCONNECTED)
-00367                 {
-00368                         // fix: can only route one hop to avoid a loop
-00369                         if (strncmp(message,"R ",2))
-00370                         {
-00371                                 log(DEBUG,"Not a double reroute");
-00372                                 // this route is down, we must re-route the packet through an available point in the mesh.
-00373                                 for (int k = 0; k < this->connectors.size(); k++)
-00374                                 {
-00375                                         log(DEBUG,"Check connector %d: %s",k,this->connectors[k].GetServerName().c_str());
-00376                                         // search for another point in the mesh which can 'reach' where we want to go
-00377                                         for (int m = 0; m < this->connectors[k].routes.size(); m++)
-00378                                         {
-00379                                                 if (!strcasecmp(this->connectors[k].routes[m].c_str(),sendhost))
-00380                                                 {
-00381                                                         log(DEBUG,"Found alternative route for packet: %s",this->connectors[k].GetServerName().c_str());
-00382                                                         char buffer[MAXBUF];
-00383                                                         snprintf(buffer,MAXBUF,"R %s %s",sendhost,message);
-00384                                                         this->SendPacket(buffer,this->connectors[k].GetServerName().c_str());
-00385                                                         return true;
-00386                                                 }
-00387                                         }
-00388                                 }
-00389                         }
-00390                         char buffer[MAXBUF];
-00391                         snprintf(buffer,MAXBUF,"& %s",sendhost);
-00392                         WriteOpers("*** All connections to %s lost.",sendhost);
-00393                         NetSendToAllExcept(sendhost,buffer);
-00394                         DoSplit(sendhost);
-00395                         return false;
-00396                 }
-00397 
-00398                 // returns false if the packet could not be sent (e.g. target host down)
-00399                 if (!cn->AddWriteBuf(message))
-00400                 {
-00401                         // if we're here, there was an error pending, and the send cannot proceed
-00402                         log(DEBUG,"cn->AddWriteBuf() failed for serverrec::SendPacket(): %s",cn->GetWriteError().c_str());
-00403                         log(DEBUG,"Disabling connector: %s",cn->GetServerName().c_str());
-00404                         cn->CloseConnection();
-00405                         cn->SetState(STATE_DISCONNECTED);
-00406                         WriteOpers("*** Lost single connection to %s, link inactive and retrying: %s",cn->GetServerName().c_str(),cn->GetWriteError().c_str());
-00407                         // retry the packet along a new route so either arrival OR failure are gauranteed (bugfix)
-00408                         return this->SendPacket(message,sendhost);
-00409                 }
-00410                 if (!cn->FlushWriteBuf())
-00411                 {
-00412                         // if we're here the write() caused an error, we cannot proceed
-00413                         log(DEBUG,"cn->FlushWriteBuf() failed for serverrec::SendPacket(): %s",cn->GetWriteError().c_str());
-00414                         log(DEBUG,"Disabling connector: %s",cn->GetServerName().c_str());
-00415                         cn->CloseConnection();
-00416                         cn->SetState(STATE_DISCONNECTED);
-00417                         WriteOpers("*** Lost single connection to %s, link inactive and retrying: %s",cn->GetServerName().c_str(),cn->GetWriteError().c_str());
-00418                         // retry the packet along a new route so either arrival OR failure are gauranteed
-00419                         return this->SendPacket(message,sendhost);
-00420                 }
-00421                 return true;
-00422         }
-00423 }
-
-

- - - - -
- - - - - - - - - - -
void serverrec::TerminateLink ( char *  targethost  ) 
-
- - - - - -
-   - - -

-Terminate a link to 'targethost' by calling the ircd_connector::CloseConnection method. -

- -

-Definition at line 234 of file servers.cpp. -

-

00235 {
-00236         // this locates the targethost in the serverrec::connectors vector of the class,
-00237        // and terminates it by sending it an SQUIT token and closing its descriptor.
-00238         // TerminateLink with a null string causes a terminate of ALL links
-00239 }
-
-

Member Data Documentation

-

- - - - -
- - -
std::vector<ircd_connector> serverrec::connectors -
-
- - - - - -
-   - - -

-With a serverrec, this is a list of all established server connections. -

- -

-Definition at line 81 of file servers.h. -

-Referenced by AddIncoming(), BeginLink(), FindHost(), FlushWriteBuffers(), IsRoutable(), MeshCookie(), RecvPacket(), SendPacket(), and serverrec().

-

- - - - -
- - -
char serverrec::description[MAXBUF] -
-
- - - - - -
-   - - -

-Description of the server. -

- -

-Definition at line 61 of file servers.h.

-

- - - - -
- - -
int serverrec::hops_away -
-
- - - - - -
-   - - -

-number of hops away (for quick access) -

- -

-Definition at line 51 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
bool serverrec::jupiter -
-
- - - - - -
-   - - -

-is a JUPE server (faked to enforce a server ban) -

- -

-Definition at line 57 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
char serverrec::name[MAXBUF] -
-
- - - - - -
-   - - -

-server name -

- -

-Definition at line 36 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
char serverrec::nickserv[NICKMAX] -
-
- - - - - -
-   - - -

-Holds nickserv's name on U:lined (services) servers (this is a kludge for ircservices which ASSUMES things :/). -

- -

-Definition at line 65 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
long serverrec::opercount -
-
- - - - - -
-   - - -

-opers on server -

- -

-Definition at line 48 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
long serverrec::pingtime -
-
- - - - - -
-   - - -

-last ping response (ms) -

- -

-Definition at line 39 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
bool serverrec::sync_soon -
-
- - - - - -
-   - - -

- -

-Definition at line 67 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
long serverrec::usercount -
-
- - - - - -
-   - - -

-non-invisible users on server -

- -

-Definition at line 45 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
long serverrec::usercount_i -
-
- - - - - -
-   - - -

-invisible users on server -

- -

-Definition at line 42 of file servers.h. -

-Referenced by serverrec().

-

- - - - -
- - -
long serverrec::version -
-
- - - - - -
-   - - -

-ircd version -

- -

-Definition at line 54 of file servers.h. -

-Referenced by serverrec().

-

The documentation for this class was generated from the following files: -
Generated on Mon May 30 05:17:37 2005 for InspIRCd by - -doxygen -1.3.3
- - -- cgit v1.2.3