Fixed some channel pointer stuff (eeeky)

[user/henk/code/inspircd.git] / src / connection.cpp

diff --git a/src/connection.cpp b/src/connection.cpp
index bd959500488cd1861499f2950ea92da55e8b254d..61c3c5bfedd130baf796dc1ac36010be7a103d28 100644 (file)
--- a/src/connection.cpp
+++ b/src/connection.cpp
@@ -12,11 +12,14 @@
 
 using namespace std;
 
+
 extern std::vector<Module*> modules;
 extern std::vector<ircd_module*> factory;
 
 extern int MODCOUNT;
 
+
+
 connection::connection()
 {
        fd = 0;
@@ -140,6 +143,7 @@ bool ircd_connector::MakeOutboundConnection(char* host, int port)
                if(connect(this->fd, (sockaddr*)&this->addr,sizeof(this->addr)))
                {
                        WriteOpers("connect() failed for %s",host);
+                       RemoveServer(this->servername.c_str());
                        return false;
                }
                int flags = fcntl(this->fd, F_GETFL, 0);
@@ -153,6 +157,7 @@ bool ircd_connector::MakeOutboundConnection(char* host, int port)
        else
        {
                WriteOpers("socket() failed!");
+               RemoveServer(this->servername.c_str());
        }
 
        return false;
@@ -164,6 +169,15 @@ bool connection::BeginLink(char* targethost, int port, char* password, char* ser
        char connect[MAXBUF];
        
        ircd_connector connector;
+       ircd_connector *cn = this->FindHost(servername);
+
+
+       if (cn)
+       {
+               WriteOpers("CONNECT aborted: Server %s already exists",servername);
+               return false;
+       }
+
        
        if (this->fd)
        {
@@ -172,7 +186,7 @@ bool connection::BeginLink(char* targethost, int port, char* password, char* ser
                        // targethost has been turned into an ip...
                        // we dont want this as the server name.
                        connector.SetServerName(servername);
-                       sprintf(connect,"S %s %s %d :%s",getservername().c_str(),password,myport,getserverdesc().c_str());
+                       sprintf(connect,"S %s %s %d %d :%s",getservername().c_str(),password,myport,GetRevision(),getserverdesc().c_str());
                        connector.SetState(STATE_NOAUTH_OUTBOUND);
                        connector.SetHostAndPort(targethost, port);
                        this->connectors.push_back(connector);
@@ -320,6 +334,9 @@ void ircd_connector::SetDescriptor(int fd)
 
 bool connection::SendPacket(char *message, const char* host)
 {
+       if ((!message) || (!host))
+               return true;
+
        ircd_connector* cn = this->FindHost(host);
        
        if (!strchr(message,'\n'))
@@ -334,19 +351,23 @@ bool connection::SendPacket(char *message, const char* host)
                if (cn->GetState() == STATE_DISCONNECTED)
                {
                        log(DEBUG,"Main route to %s is down, seeking alternative",host);
-                       // this route is down, we must re-route the packet through an available point in the mesh.
-                       for (int k = 0; k < this->connectors.size(); k++)
+                       // fix: can only route one hop to avoid a loop
+                       if (strncat(message,"R ",2))
                        {
-                               // search for another point in the mesh which can 'reach' where we want to go
-                               for (int m = 0; m < this->connectors[k].routes.size(); m++)
+                               // this route is down, we must re-route the packet through an available point in the mesh.
+                               for (int k = 0; k < this->connectors.size(); k++)
                                {
-                                       if (!strcasecmp(this->connectors[k].routes[m].c_str(),host))
+                                       // search for another point in the mesh which can 'reach' where we want to go
+                                       for (int m = 0; m < this->connectors[k].routes.size(); m++)
                                        {
-                                               log(DEBUG,"Found alternative route for packet: %s",this->connectors[k].GetServerName().c_str());
-                                               char buffer[MAXBUF];
-                                               snprintf(buffer,MAXBUF,"R %s %s",host,message);
-                                               this->SendPacket(buffer,this->connectors[k].GetServerName().c_str());
-                                               return true;
+                                               if (!strcasecmp(this->connectors[k].routes[m].c_str(),host))
+                                               {
+                                                       log(DEBUG,"Found alternative route for packet: %s",this->connectors[k].GetServerName().c_str());
+                                                       char buffer[MAXBUF];
+                                                       snprintf(buffer,MAXBUF,"R %s %s",host,message);
+                                                       this->SendPacket(buffer,this->connectors[k].GetServerName().c_str());
+                                                       return true;
+                                               }
                                        }
                                }
                        }
@@ -366,8 +387,7 @@ bool connection::SendPacket(char *message, const char* host)
                        cn->CloseConnection();
                        cn->SetState(STATE_DISCONNECTED);
                        // retry the packet along a new route so either arrival OR failure are gauranteed (bugfix)
-                       this->SendPacket(message,host);
-                       return false;
+                       return this->SendPacket(message,host);
                }
                return true;
        }