]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/inspircd.cpp
Add a progress meter for loading of core commands, fix broken implementation for...
[user/henk/code/inspircd.git] / src / inspircd.cpp
index 14bff2bef9eb8f4ac16cd4246f65e4d994c73b57..069c8634d0c86ee8de854e916aac5326ccedac91 100644 (file)
@@ -78,13 +78,13 @@ void InspIRCd::Cleanup()
        std::vector<std::string> mymodnames;
        int MyModCount = this->GetModuleCount();
 
-       for (unsigned int i = 0; i < stats->BoundPortCount; i++)
+       for (unsigned int i = 0; i < Config->ports.size(); i++)
        {
                /* This calls the constructor and closes the listening socket */
-               delete Config->openSockfd[i];
-               Config->openSockfd[i] = NULL;
+               delete Config->ports[i];
        }
-       stats->BoundPortCount = 0;
+
+       Config->ports.clear();
 
        /* Close all client sockets, or the new process inherits them */
        for (std::vector<userrec*>::const_iterator i = this->local_users.begin(); i != this->local_users.end(); i++)
@@ -126,25 +126,7 @@ void InspIRCd::Restart(const std::string &reason)
        /* Figure out our filename (if theyve renamed it, we're boned) */
        std::string me = Config->MyDir + "/inspircd";
 
-       char* argv[10];
-       int endp = 2;
-       argv[0] = Config->argv[0];
-       argv[1] = "--restart";
-       if (Config->forcedebug)
-               argv[endp++] = "--debug";
-       if (Config->nofork)
-               argv[endp++] = "--nofork";
-       if (!Config->writelog)
-               argv[endp++] = "--nolog";
-       if (*this->LogFileName)
-       {
-               argv[endp++] = "--logfile";
-               argv[endp++] = this->LogFileName;
-       }
-
-       argv[endp] = NULL;
-
-       if (execv(me.c_str(), argv) == -1)
+       if (execv(me.c_str(), Config->argv) == -1)
        {
                /* Will raise a SIGABRT if not trapped */
                throw CoreException(std::string("Failed to execv()! error: ") + strerror(errno));
@@ -161,7 +143,7 @@ void InspIRCd::Start()
 
 void InspIRCd::Rehash(int status)
 {
-       SI->WriteOpers("*** Rehashing config file %s due to SIGHUP",ServerConfig::CleanFilename(CONFIG_FILE));
+       SI->WriteOpers("*** Rehashing config file %s due to SIGHUP",ServerConfig::CleanFilename(SI->ConfigFileName));
        SI->CloseLog();
        SI->OpenLog(SI->Config->argv, SI->Config->argc);
        SI->RehashUsersAndChans();
@@ -227,6 +209,8 @@ void InspIRCd::QuickExit(int status)
 
 bool InspIRCd::DaemonSeed()
 {
+       signal(SIGTERM, InspIRCd::QuickExit);
+
        int childpid;
        if ((childpid = fork ()) < 0)
                return false;
@@ -239,7 +223,6 @@ bool InspIRCd::DaemonSeed()
                 * if the child pid is still around. If theyre not,
                 * they threw an error and we should give up.
                 */
-               signal(SIGTERM, InspIRCd::QuickExit);
                while (kill(childpid, 0) != -1)
                        sleep(1);
                exit(0);
@@ -248,6 +231,8 @@ bool InspIRCd::DaemonSeed()
        umask (007);
        printf("InspIRCd Process ID: \033[1;32m%lu\033[0m\n",(unsigned long)getpid());
 
+       signal(SIGTERM, InspIRCd::Exit);
+
        rlimit rl;
        if (getrlimit(RLIMIT_CORE, &rl) == -1)
        {
@@ -270,8 +255,8 @@ void InspIRCd::WritePID(const std::string &filename)
        if (*(fname.begin()) != '/')
        {
                std::string::size_type pos;
-               std::string confpath = CONFIG_FILE;
-               if ((pos = confpath.find("/inspircd.conf")) != std::string::npos)
+               std::string confpath = this->ConfigFileName;
+               if ((pos = confpath.rfind("/")) != std::string::npos)
                {
                        /* Leaves us with just the path */
                        fname = confpath.substr(0, pos) + std::string("/") + fname;
@@ -301,7 +286,7 @@ InspIRCd::InspIRCd(int argc, char** argv)
 {
        int found_ports = 0;
        FailedPortList pl;
-       int do_nofork = 0, do_debug = 0, do_nolog = 0, do_restart = 0;    /* flag variables */
+       int do_version = 0, do_nofork = 0, do_debug = 0, do_nolog = 0, do_root = 0;    /* flag variables */
        char c = 0;
 
        modules.resize(255);
@@ -320,29 +305,23 @@ InspIRCd::InspIRCd(int argc, char** argv)
        this->Config->opertypes.clear();
        this->Config->operclass.clear();
        this->SNO = new SnomaskManager(this);
-       this->Start();
        this->TIME = this->OLDTIME = this->startup_time = time(NULL);
        this->time_delta = 0;
        this->next_call = this->TIME + 3;
        srand(this->TIME);
 
-       if (!ServerConfig::FileExists(CONFIG_FILE))
-       {
-               printf("ERROR: Cannot open config file: %s\nExiting...\n",CONFIG_FILE);
-               this->Log(DEFAULT,"main: no config");
-               printf("ERROR: Your config file is missing, this IRCd will self destruct in 10 seconds!\n");
-               Exit(EXIT_STATUS_CONFIG);
-       }
-
        *this->LogFileName = 0;
+       strlcpy(this->ConfigFileName, CONFIG_FILE, MAXBUF);
 
        struct option longopts[] =
        {
                { "nofork",     no_argument,            &do_nofork,     1       },
                { "logfile",    required_argument,      NULL,           'f'     },
+               { "config",     required_argument,      NULL,           'c'     },
                { "debug",      no_argument,            &do_debug,      1       },
                { "nolog",      no_argument,            &do_nolog,      1       },
-               { "restart",    no_argument,            &do_restart,    1       },
+               { "runasroot",  no_argument,            &do_root,       1       },
+               { "version",    no_argument,            &do_version,    1       },
                { 0, 0, 0, 0 }
        };
 
@@ -355,17 +334,37 @@ InspIRCd::InspIRCd(int argc, char** argv)
                                strlcpy(LogFileName, optarg, MAXBUF);
                                printf("LOG: Setting logfile to %s\n", LogFileName);
                        break;
+                       case 'c':
+                               /* Config filename was set */
+                               strlcpy(ConfigFileName, optarg, MAXBUF);
+                               printf("CONFIG: Setting config file to %s\n", ConfigFileName);
+                       break;
                        case 0:
                                /* getopt_long_only() set an int variable, just keep going */
                        break;
                        default:
                                /* Unknown parameter! DANGER, INTRUDER.... err.... yeah. */
-                               printf("Usage: %s [--nofork] [--nolog] [--debug] [--logfile <filename>] [--restart]\n", argv[0]);
+                               printf("Usage: %s [--nofork] [--nolog] [--debug] [--logfile <filename>] [--runasroot] [--version] [--config <config>]\n", argv[0]);
                                Exit(EXIT_STATUS_ARGV);
                        break;
                }
        }
 
+       if (do_version)
+       {
+               printf("\n%s r%s\n", VERSION, REVISION);
+               Exit(EXIT_STATUS_NOERROR);
+       }
+
+       if (!ServerConfig::FileExists(this->ConfigFileName))
+       {
+               printf("ERROR: Cannot open config file: %s\nExiting...\n", this->ConfigFileName);
+               this->Log(DEFAULT,"Unable to open config file %s", this->ConfigFileName);
+               Exit(EXIT_STATUS_CONFIG);
+       }
+
+       this->Start();
+
        /* Set the finished argument values */
        Config->nofork = do_nofork;
        Config->forcedebug = do_debug;
@@ -374,25 +373,29 @@ InspIRCd::InspIRCd(int argc, char** argv)
        strlcpy(Config->MyExecutable,argv[0],MAXBUF);
 
        this->OpenLog(argv, argc);
+
        this->stats = new serverstats();
        this->Timers = new TimerManager(this);
        this->Parser = new CommandParser(this);
        this->XLines = new XLineManager(this);
        Config->ClearStack();
        Config->Read(true, NULL);
-       this->CheckRoot();
-       this->Modes = new ModeParser(this);
-       this->AddServerName(Config->ServerName);
-       CheckDie();
-       InitializeDisabledCommands(Config->DisabledCommands, this);
-       stats->BoundPortCount = BindPorts(true, found_ports, pl);
 
-       for(int t = 0; t < 255; t++)
-               Config->global_implementation[t] = 0;
-
-       memset(&Config->implement_lists,0,sizeof(Config->implement_lists));
+       if (!do_root)
+               this->CheckRoot();
+       else
+       {
+               printf("* WARNING * WARNING * WARNING * WARNING * WARNING * \n\n");
+               printf("YOU ARE RUNNING INSPIRCD AS ROOT. THIS IS UNSUPPORTED\n");
+               printf("AND IF YOU ARE HACKED, CRACKED, SPINDLED OR MUTILATED\n");
+               printf("OR ANYTHING ELSE UNEXPECTED HAPPENS TO YOU OR YOUR\n");
+               printf("SERVER, THEN IT IS YOUR OWN FAULT. IF YOU DID NOT MEAN\n");
+               printf("TO START INSPIRCD AS ROOT, HIT CTRL+C NOW AND RESTART\n");
+               printf("THE PROGRAM AS A NORMAL USER. YOU HAVE BEEN WARNED!\n");
+               printf("\nInspIRCd starting in 20 seconds, ctrl+c to abort...\n");
+               sleep(20);
+       }
 
-       printf("\n");
        this->SetSignals();
 
        if (!Config->nofork)
@@ -405,30 +408,44 @@ InspIRCd::InspIRCd(int argc, char** argv)
                }
        }
 
-       /* Because of limitations in kqueue on freebsd, we must fork BEFORE we
+
+        /* Because of limitations in kqueue on freebsd, we must fork BEFORE we
         * initialize the socket engine.
         */
        SocketEngineFactory* SEF = new SocketEngineFactory();
        SE = SEF->Create(this);
        delete SEF;
 
+       this->Modes = new ModeParser(this);
+       this->AddServerName(Config->ServerName);
+       CheckDie();
+       int bounditems = BindPorts(true, found_ports, pl);
+
+       for(int t = 0; t < 255; t++)
+               Config->global_implementation[t] = 0;
+
+       memset(&Config->implement_lists,0,sizeof(Config->implement_lists));
+
+       printf("\n");
+
        this->Res = new DNS(this);
 
        this->LoadAllModules();
        /* Just in case no modules were loaded - fix for bug #101 */
        this->BuildISupport();
+       InitializeDisabledCommands(Config->DisabledCommands, this);
 
-       if ((stats->BoundPortCount == 0) && (found_ports > 0))
+       if ((Config->ports.size() == 0) && (found_ports > 0))
        {
                printf("\nERROR: I couldn't bind any ports! Are you sure you didn't start InspIRCd twice?\n");
                Log(DEFAULT,"ERROR: I couldn't bind any ports! Are you sure you didn't start InspIRCd twice?");
                Exit(EXIT_STATUS_BIND);
        }
 
-       if (stats->BoundPortCount != (unsigned int)found_ports)
+       if (Config->ports.size() != (unsigned int)found_ports)
        {
-               printf("\nWARNING: Not all your client ports could be bound --\nstarting anyway with %ld of %d client ports bound.\n\n", stats->BoundPortCount, found_ports);
-               printf("The following port%s failed to bind:\n", found_ports - stats->BoundPortCount != 1 ? "s" : "");
+               printf("\nWARNING: Not all your client ports could be bound --\nstarting anyway with %d of %d client ports bound.\n\n", bounditems, found_ports);
+               printf("The following port(s) failed to bind:\n");
                int j = 1;
                for (FailedPortList::iterator i = pl.begin(); i != pl.end(); i++, j++)
                {
@@ -436,30 +453,31 @@ InspIRCd::InspIRCd(int argc, char** argv)
                }
        }
 
-       /* Add the listening sockets used for client inbound connections
-        * to the socket engine
-        */
-       for (unsigned long count = 0; count < stats->BoundPortCount; count++)
+       if (!Config->nofork)
        {
-               if (!SE->AddFd(Config->openSockfd[count]))
+               if (kill(getppid(), SIGTERM) == -1)
                {
-                       printf("\nEH? Could not add listener to socketengine. You screwed up, aborting.\n");
-                       Log(DEFAULT,"EH? Could not add listener to socketengine. You screwed up, aborting.");
-                       Exit(EXIT_STATUS_INTERNAL);
+                       printf("Error killing parent process: %s\n",strerror(errno));
+                       Log(DEFAULT,"Error killing parent process: %s",strerror(errno));
                }
        }
 
-       if (!Config->nofork && !do_restart)
+       if (isatty(0) && isatty(1) && isatty(2))
        {
-               if (kill(getppid(), SIGTERM) == -1)
+               /* We didn't start from a TTY, we must have started from a background process -
+                * e.g. we are restarting, or being launched by cron. Dont kill parent, and dont
+                * close stdin/stdout
+                */
+               if (!do_nofork)
                {
-                       printf("Error killing parent process: %s\n",strerror(errno));
-                       Log(DEFAULT,"Error killing parent process: %s",strerror(errno));
+                       fclose(stdin);
+                       fclose(stderr);
+                       fclose(stdout);
+               }
+               else
+               {
+                       Log(DEFAULT,"Keeping pseudo-tty open as we are running in the foreground.");
                }
-
-               fclose(stdin);
-               fclose(stderr);
-               fclose(stdout);
        }
 
        printf("\nInspIRCd is now running!\n");
@@ -472,6 +490,7 @@ std::string InspIRCd::GetVersionString()
 {
        char versiondata[MAXBUF];
        char dnsengine[] = "singlethread-object";
+
        if (*Config->CustomVersion)
        {
                snprintf(versiondata,MAXBUF,"%s %s :%s",VERSION,Config->ServerName,Config->CustomVersion);
@@ -612,9 +631,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 WALLVOICES MODES=" << MAXMODES << " CHANTYPES=# PREFIX=" << this->Modes->BuildPrefixes() << " MAP MAXCHANNELS=" << Config->MaxChans << " MAXBANS=60 VBANLIST NICKLEN=" << NICKMAX-1;
+       v << "WALLCHOPS WALLVOICES MODES=" << MAXMODES-1 << " CHANTYPES=# PREFIX=" << this->Modes->BuildPrefixes() << " MAP MAXCHANNELS=" << Config->MaxChans << " MAXBANS=60 VBANLIST NICKLEN=" << NICKMAX-1;
        v << " CASEMAPPING=rfc1459 STATUSMSG=@%+ CHARSET=ascii TOPICLEN=" << MAXTOPIC << " KICKLEN=" << MAXKICK << " MAXTARGETS=" << Config->MaxTargets << " AWAYLEN=";
-       v << MAXAWAY << " CHANMODES=" << this->Modes->ChanModes() << " FNC NETWORK=" << Config->Network << " MAXPARA=32";
+       v << MAXAWAY << " CHANMODES=" << this->Modes->ChanModes() << " FNC NETWORK=" << Config->Network << " MAXPARA=32 ELIST=MU";
        Config->data005 = v.str();
        FOREACH_MOD_I(this,I_On005Numeric,On005Numeric(Config->data005));
        Config->Update005();
@@ -794,7 +813,7 @@ bool InspIRCd::LoadModule(const char* filename)
                }
                catch (CoreException& modexcept)
                {
-                       this->Log(DEFAULT,"Unable to load %s: ",modfile,modexcept.GetReason());
+                       this->Log(DEFAULT,"Unable to load %s: %s",modfile,modexcept.GetReason());
                        snprintf(MODERR,MAXBUF,"Factory function of %s threw an exception: %s", modexcept.GetSource(), modexcept.GetReason());
                        return false;
                }
@@ -889,29 +908,16 @@ void InspIRCd::DoOneIteration(bool process_module_sockets)
        /* if any users was quit, take them out */
        GlobalCulls.Apply();
 
-}
-
-bool InspIRCd::IsIdent(const char* n)
-{
-       if (!n || !*n)
-               return false;
-
-       for (char* i = (char*)n; *i; i++)
+       /* If any inspsockets closed, remove them */
+       for (std::map<InspSocket*,InspSocket*>::iterator x = SocketCull.begin(); x != SocketCull.end(); ++x)
        {
-               if ((*i >= 'A') && (*i <= '}'))
-               {
-                       continue;
-               }
-               if (((*i >= '0') && (*i <= '9')) || (*i == '-') || (*i == '.'))
-               {
-                       continue;
-               }
-               return false;
+               SE->DelFd(x->second);
+               x->second->Close();
+               delete x->second;
        }
-       return true;
+       SocketCull.clear();
 }
 
-
 int InspIRCd::Run()
 {
        while (true)