]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/inspircd.cpp
Decide that it wasn't quite appropriate :(
[user/henk/code/inspircd.git] / src / inspircd.cpp
index 4b390eeb06316a06b062552f4e878883448c068d..ee30ba4e9e9c7951f469ba22a3227b7a0868f00a 100644 (file)
@@ -21,11 +21,9 @@ using namespace std;
 #include "inspircd_config.h"
 #include "inspircd.h"
 #include "inspircd_io.h"
-#include <unistd.h>
 #include <fcntl.h>
 #include <sys/errno.h>
 #include <sys/ioctl.h>
-#include <sys/utsname.h>
 #include <time.h>
 #include <string>
 #ifdef GCC3
@@ -116,6 +114,16 @@ const char* FindServerNamePtr(std::string servername)
        return FindServerNamePtr(servername);
 }
 
+bool FindServerName(std::string servername)
+{
+       for (servernamelist::iterator a = servernames.begin(); a < servernames.end(); a++)
+       {
+               if (*a == servername)
+                       return true;
+       }
+       return false;
+}
+
 std::string InspIRCd::GetRevision()
 {
        /* w00t got me to replace a bunch of strtok_r
@@ -127,6 +135,8 @@ std::string InspIRCd::GetRevision()
         * into the same variable twice, the first word
         * is discarded, and the second one returned.
         */
+
+       /* XXX - this revision ID is NOT bumping automatically -- w00t */
        std::stringstream Revision("$Revision$");
        std::string single;
        Revision >> single >> single;
@@ -376,9 +386,9 @@ void InspIRCd::BuildISupport()
 {
         // the neatest way to construct the initial 005 numeric, considering the number of configure constants to go in it...
        std::stringstream v;
-       v << "WALLCHOPS MODES=" << MAXMODES << " CHANTYPES=# PREFIX=(ohv)@%+ MAP SAFELIST MAXCHANNELS=" << MAXCHANS << " MAXBANS=60 NICKLEN=" << NICKMAX-1;
-       v << " CASEMAPPING=rfc1459 STATUSMSG=@+ CHARSET=ascii TOPICLEN=" << MAXTOPIC << " KICKLEN=" << MAXKICK << " MAXTARGETS=" << Config->MaxTargets << " AWAYLEN=";
-       v << MAXAWAY << " CHANMODES=b,k,l,psmnti NETWORK=" << Config->Network;
+       v << "WALLCHOPS WALLVOICES MODES=" << MAXMODES << " CHANTYPES=# PREFIX=(ohv)@%+ MAP MAXCHANNELS=" << MAXCHANS << " MAXBANS=60 VBANLIST NICKLEN=" << NICKMAX-1;
+       v << " CASEMAPPING=rfc1459 STATUSMSG=@%+ CHARSET=ascii TOPICLEN=" << MAXTOPIC << " KICKLEN=" << MAXKICK << " MAXTARGETS=" << Config->MaxTargets << " AWAYLEN=";
+       v << MAXAWAY << " CHANMODES=b,k,l,psmnti FNC NETWORK=" << Config->Network << " MAXPARA=32";
        Config->data005 = v.str();
        FOREACH_MOD(I_On005Numeric,On005Numeric(Config->data005));
 }
@@ -451,12 +461,14 @@ bool InspIRCd::LoadModule(const char* filename)
 #endif
        std::string filename_str = filename;
 #ifndef STATIC_LINK
+#ifndef IS_CYGWIN
        if (!DirValid(modfile))
        {
                log(DEFAULT,"Module %s is not within the modules directory.",modfile);
                snprintf(MODERR,MAXBUF,"Module %s is not within the modules directory.",modfile);
                return false;
        }
+#endif
 #endif
        log(DEBUG,"Loading module: %s",modfile);
 #ifndef STATIC_LINK
@@ -478,38 +490,46 @@ bool InspIRCd::LoadModule(const char* filename)
                 {
                         log(DEFAULT,"Unable to load %s: %s",modfile,factory[MODCOUNT+1]->LastError());
                        snprintf(MODERR,MAXBUF,"Loader/Linker error: %s",factory[MODCOUNT+1]->LastError());
-                       MODCOUNT--;
                        return false;
                 }
-                if (factory[MODCOUNT+1]->factory)
-                {
-                       Module* m = factory[MODCOUNT+1]->factory->CreateModule(MyServer);
-                        modules[MODCOUNT+1] = m;
-                        /* save the module and the module's classfactory, if
-                         * this isnt done, random crashes can occur :/ */
-                        Config->module_names.push_back(filename);
-
-                       char* x = &Config->implement_lists[MODCOUNT+1][0];
-                       for(int t = 0; t < 255; t++)
-                               x[t] = 0;
+               try
+               {
+                       if (factory[MODCOUNT+1]->factory)
+                       {
+                               Module* m = factory[MODCOUNT+1]->factory->CreateModule(MyServer);
+                               modules[MODCOUNT+1] = m;
+                               /* save the module and the module's classfactory, if
+                                * this isnt done, random crashes can occur :/ */
+                               Config->module_names.push_back(filename);
+
+                               char* x = &Config->implement_lists[MODCOUNT+1][0];
+                               for(int t = 0; t < 255; t++)
+                                       x[t] = 0;
 
-                       modules[MODCOUNT+1]->Implements(x);
+                               modules[MODCOUNT+1]->Implements(x);
 
-                       for(int t = 0; t < 255; t++)
-                       {
-                               Config->global_implementation[t] += Config->implement_lists[MODCOUNT+1][t];
-                               if (Config->implement_lists[MODCOUNT+1][t])
+                               for(int t = 0; t < 255; t++)
                                {
-                                       log(DEBUG,"Add global implementation: %d %d => %d",MODCOUNT+1,t,Config->global_implementation[t]);
+                                       Config->global_implementation[t] += Config->implement_lists[MODCOUNT+1][t];
+                                       if (Config->implement_lists[MODCOUNT+1][t])
+                                       {
+                                               log(DEBUG,"Add global implementation: %d %d => %d",MODCOUNT+1,t,Config->global_implementation[t]);
+                                       }
                                }
-                       }
-                }
-               else
-                {
-                        log(DEFAULT,"Unable to load %s",modfile);
-                       snprintf(MODERR,MAXBUF,"Factory function failed!");
+                       }
+                       else
+                       {
+                                       log(DEFAULT,"Unable to load %s",modfile);
+                               snprintf(MODERR,MAXBUF,"Factory function failed!");
+                               return false;
+                       }
+               }
+               catch (ModuleException& modexcept)
+               {
+                       log(DEFAULT,"Unable to load %s: ",modfile,modexcept.GetReason());
+                       snprintf(MODERR,MAXBUF,"Factory function threw an exception: %s",modexcept.GetReason());
                        return false;
-                }
+               }
 #ifndef STATIC_LINK
         }
         else
@@ -579,7 +599,6 @@ int InspIRCd::Run()
        userrec* cu = NULL;
        InspSocket* s = NULL;
        InspSocket* s_del = NULL;
-       char* target;
        unsigned int numberactive;
         sockaddr_in sock_us;     // our port number
        socklen_t uslen;         // length of our port number
@@ -618,22 +637,40 @@ int InspIRCd::Run()
                 * timing using this event, so we dont have to
                 * time this exactly).
                 */
-               if (((TIME % 8) == 0) && (!expire_run))
+               if (((TIME % 5) == 0) && (!expire_run))
                {
                        expire_lines();
                        FOREACH_MOD(I_OnBackgroundTimer,OnBackgroundTimer(TIME));
+                       TickMissedTimers(TIME);
                        expire_run = true;
                        continue;
                }
-               else if ((TIME % 8) == 1)
+               else if ((TIME % 5) == 1)
                {
                        expire_run = false;
                }
                
                /* Once a second, do the background processing */
                if (TIME != OLDTIME)
+               {
+                       if (TIME < OLDTIME)
+                               WriteOpers("*** \002EH?!\002 -- Time is flowing BACKWARDS in this dimension! Clock drifted backwards %d secs.",abs(OLDTIME-TIME));
                        DoBackgroundUserStuff(TIME);
 
+                       /*
+                        * Trigger all InspTimers that are pending
+                        */
+               }
+
+               /* Process timeouts on module sockets each time around
+                * the loop. There shouldnt be many module sockets, at
+                * most, 20 or so, so this won't be much of a performance
+                * hit at all.
+                */
+               DoSocketTimeouts(TIME);
+
+               TickTimers(TIME);
+
                /* Call the socket engine to wait on the active
                 * file descriptors. The socket engine has everything's
                 * descriptors in its list... dns, modules, users,
@@ -714,7 +751,6 @@ int InspIRCd::Run()
                                        {
                                                in_port = ntohs(sock_us.sin_port);
                                                log(DEBUG,"Accepted socket %d",incomingSockfd);
-                                               target = (char*)inet_ntoa(client.sin_addr);
                                                /* Years and years ago, we used to resolve here
                                                 * using gethostbyaddr(). That is sucky and we
                                                 * don't do that any more...
@@ -722,10 +758,17 @@ int InspIRCd::Run()
                                                NonBlocking(incomingSockfd);
                                                if (Config->GetIOHook(in_port))
                                                {
-                                                       Config->GetIOHook(in_port)->OnRawSocketAccept(incomingSockfd, target, in_port);
+                                                       try
+                                                       {
+                                                               Config->GetIOHook(in_port)->OnRawSocketAccept(incomingSockfd, (char*)inet_ntoa(client.sin_addr), in_port);
+                                                       }
+                                                       catch (ModuleException& modexcept)
+                                                       {
+                                                               log(DEBUG,"Module exception cought: %s",modexcept.GetReason()); \
+                                                       }
                                                }
                                                stats->statsAccept++;
-                                               AddClient(incomingSockfd, target, in_port, false, target);
+                                               AddClient(incomingSockfd, in_port, false, client.sin_addr);
                                                log(DEBUG,"Adding client on port %lu fd=%lu",(unsigned long)in_port,(unsigned long)incomingSockfd);
                                        }
                                        else