]> git.netwichtig.de Git - user/henk/code/inspircd.git/blob - src/inspircd.cpp
Make BindPorts return size_t instead of int.
[user/henk/code/inspircd.git] / src / inspircd.cpp
1 /*
2  * InspIRCd -- Internet Relay Chat Daemon
3  *
4  *   Copyright (C) 2012 William Pitcock <nenolod@dereferenced.org>
5  *   Copyright (C) 2009-2010 Daniel De Graaf <danieldg@inspircd.org>
6  *   Copyright (C) 2003-2008 Craig Edwards <craigedwards@brainbox.cc>
7  *   Copyright (C) 2008 Uli Schlachter <psychon@znc.in>
8  *   Copyright (C) 2006-2008 Robin Burchell <robin+git@viroteck.net>
9  *   Copyright (C) 2006-2007 Oliver Lupton <oliverlupton@gmail.com>
10  *   Copyright (C) 2007 Dennis Friis <peavey@inspircd.org>
11  *   Copyright (C) 2007 Burlex <???@???>
12  *   Copyright (C) 2003 Craig McLure <craig@chatspike.net>
13  *   Copyright (C) 2003 randomdan <???@???>
14  *
15  * This file is part of InspIRCd.  InspIRCd is free software: you can
16  * redistribute it and/or modify it under the terms of the GNU General Public
17  * License as published by the Free Software Foundation, version 2.
18  *
19  * This program is distributed in the hope that it will be useful, but WITHOUT
20  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
21  * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
22  * details.
23  *
24  * You should have received a copy of the GNU General Public License
25  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
26  */
27
28
29 #include "inspircd.h"
30 #include <signal.h>
31
32 #ifndef _WIN32
33         #include <unistd.h>
34         #include <sys/resource.h>
35         #include <dlfcn.h>
36         #include <getopt.h>
37         #include <pwd.h> // setuid
38         #include <grp.h> // setgid
39 #else
40         WORD g_wOriginalColors;
41         WORD g_wBackgroundColor;
42         HANDLE g_hStdout;
43 #endif
44
45 #include <fstream>
46 #include <iostream>
47 #include "xline.h"
48 #include "exitcodes.h"
49
50 InspIRCd* ServerInstance = NULL;
51
52 /** Seperate from the other casemap tables so that code *can* still exclusively rely on RFC casemapping
53  * if it must.
54  *
55  * This is provided as a pointer so that modules can change it to their custom mapping tables,
56  * e.g. for national character support.
57  */
58 unsigned const char *national_case_insensitive_map = rfc_case_insensitive_map;
59
60
61 /* Moved from exitcodes.h -- due to duplicate symbols -- Burlex
62  * XXX this is a bit ugly. -- w00t
63  */
64 const char* ExitCodes[] =
65 {
66                 "No error",                                                             // 0
67                 "DIE command",                                                  // 1
68                 "Config file error",                                    // 2
69                 "Logfile error",                                                // 3
70                 "POSIX fork failed",                                    // 4
71                 "Bad commandline parameters",                   // 5
72                 "Can't write PID file",                                 // 6
73                 "SocketEngine could not initialize",    // 7
74                 "Refusing to start up as root",                 // 8
75                 "Couldn't load module on startup",              // 9
76                 "Received SIGTERM"                                              // 10
77 };
78
79 namespace
80 {
81         void VoidSignalHandler(int);
82
83         // Warns a user running as root that they probably shouldn't.
84         void CheckRoot()
85         {
86 #ifndef _WIN32
87                 if (getegid() != 0 && geteuid() != 0)
88                         return;
89
90                 std::cout << con_red << "Warning!" << con_reset << " You have started as root. Running as root is generally not required" << std::endl
91                         << "and may allow an attacker to gain access to your system if they find a way to" << std::endl
92                         << "exploit your IRC server." << std::endl
93                         << std::endl;
94                 if (isatty(fileno(stdout)))
95                 {
96                         std::cout << "InspIRCd will start in 30 seconds. If you are sure that you need to run as root" << std::endl
97                                 << "then you can pass the " << con_bright << "--runasroot" << con_reset << " option to disable this wait." << std::endl;
98                         sleep(30);
99                 }
100                 else
101                 {
102                         std::cout << "If you are sure that you need to run as root then you can pass the " << con_bright << "--runasroot" << con_reset << std::endl
103                                 << "option to disable this error." << std::endl;
104                                 ServerInstance->Exit(EXIT_STATUS_ROOT);
105                 }
106 #endif
107         }
108
109         // Collects performance statistics for the STATS command.
110         void CollectStats()
111         {
112 #ifndef _WIN32
113                 static rusage ru;
114                 if (getrusage(RUSAGE_SELF, &ru) == -1)
115                         return; // Should never happen.
116
117                 ServerInstance->stats.LastSampled.tv_sec = ServerInstance->Time();
118                 ServerInstance->stats.LastSampled.tv_nsec = ServerInstance->Time_ns();
119                 ServerInstance->stats.LastCPU = ru.ru_utime;
120 #else
121                 if (!QueryPerformanceCounter(&ServerInstance->stats.LastSampled))
122                         return; // Should never happen.
123
124                 FILETIME CreationTime;
125                 FILETIME ExitTime;
126                 FILETIME KernelTime;
127                 FILETIME UserTime;
128                 GetProcessTimes(GetCurrentProcess(), &CreationTime, &ExitTime, &KernelTime, &UserTime);
129
130                 ServerInstance->stats.LastCPU.dwHighDateTime = KernelTime.dwHighDateTime + UserTime.dwHighDateTime;
131                 ServerInstance->stats.LastCPU.dwLowDateTime = KernelTime.dwLowDateTime + UserTime.dwLowDateTime;
132 #endif
133         }
134
135         // Deletes a pointer and then zeroes it.
136         template<typename T>
137         void DeleteZero(T*& pr)
138         {
139                 T* p = pr;
140                 pr = NULL;
141                 delete p;
142         }
143
144         // Drops to the unprivileged user/group specified in <security:runas{user,group}>.
145         void DropRoot()
146         {
147 #ifndef _WIN32
148                 ConfigTag* security = ServerInstance->Config->ConfValue("security");
149
150                 const std::string SetGroup = security->getString("runasgroup");
151                 if (!SetGroup.empty())
152                 {
153                         errno = 0;
154                         if (setgroups(0, NULL) == -1)
155                         {
156                                 ServerInstance->Logs->Log("STARTUP", LOG_DEFAULT, "setgroups() failed (wtf?): %s", strerror(errno));
157                                 exit(EXIT_STATUS_CONFIG);
158                         }
159
160                         struct group* g = getgrnam(SetGroup.c_str());
161                         if (!g)
162                         {
163                                 ServerInstance->Logs->Log("STARTUP", LOG_DEFAULT, "getgrnam(%s) failed (wrong group?): %s", SetGroup.c_str(), strerror(errno));
164                                 exit(EXIT_STATUS_CONFIG);
165                         }
166
167                         if (setgid(g->gr_gid) == -1)
168                         {
169                                 ServerInstance->Logs->Log("STARTUP", LOG_DEFAULT, "setgid(%d) failed (wrong group?): %s", g->gr_gid, strerror(errno));
170                                 exit(EXIT_STATUS_CONFIG);
171                         }
172                 }
173
174                 const std::string SetUser = security->getString("runasuser");
175                 if (!SetUser.empty())
176                 {
177                         errno = 0;
178                         struct passwd* u = getpwnam(SetUser.c_str());
179                         if (!u)
180                         {
181                                 ServerInstance->Logs->Log("STARTUP", LOG_DEFAULT, "getpwnam(%s) failed (wrong user?): %s", SetUser.c_str(), strerror(errno));
182                                 exit(EXIT_STATUS_CONFIG);
183                         }
184
185                         if (setuid(u->pw_uid) == -1)
186                         {
187                                 ServerInstance->Logs->Log("STARTUP", LOG_DEFAULT, "setuid(%d) failed (wrong user?): %s", u->pw_uid, strerror(errno));
188                                 exit(EXIT_STATUS_CONFIG);
189                         }
190                 }
191 #endif
192         }
193
194         // Expands a path relative to the current working directory.
195         std::string ExpandPath(const char* path)
196         {
197 #ifdef _WIN32
198                 TCHAR configPath[MAX_PATH + 1];
199                 if (GetFullPathName(path, MAX_PATH, configPath, NULL) > 0)
200                         return configPath;
201 #else
202                 char configPath[PATH_MAX + 1];
203                 if (realpath(path, configPath))
204                         return configPath;
205 #endif
206                 return path;
207         }
208
209         // Locates a config file on the file system.
210         bool FindConfigFile(std::string& path)
211         {
212                 if (FileSystem::FileExists(path))
213                         return true;
214
215 #ifdef _WIN32
216                 // Windows hides file extensions by default so try appending .txt to the path
217                 // to help users who have that feature enabled and can't create .conf files.
218                 const std::string txtpath = path + ".txt";
219                 if (FileSystem::FileExists(txtpath))
220                 {
221                         path.assign(txtpath);
222                         return true;
223                 }
224 #endif
225                 return false;
226         }
227
228         // Attempts to fork into the background.
229         void ForkIntoBackground()
230         {
231 #ifndef _WIN32
232                 // We use VoidSignalHandler whilst forking to avoid breaking daemon scripts
233                 // if the parent process exits with SIGTERM (15) instead of EXIT_STATUS_NOERROR (0).
234                 signal(SIGTERM, VoidSignalHandler);
235
236                 errno = 0;
237                 int childpid = fork();
238                 if (childpid < 0)
239                 {
240                         ServerInstance->Logs->Log("STARTUP", LOG_DEFAULT, "fork() failed: %s", strerror(errno));
241                         std::cout << con_red << "Error:" << con_reset << " unable to fork into background: " << strerror(errno);
242                         ServerInstance->Exit(EXIT_STATUS_FORK);
243                 }
244                 else if (childpid > 0)
245                 {
246                         // Wait until the child process kills the parent so that the shell prompt
247                         // doesnt display over the output. Sending a kill with a signal of 0 just
248                         // checks that the child pid is still running. If it is not then an error
249                         // happened and the parent should exit.
250                         while (kill(childpid, 0) != -1)
251                                 sleep(1);
252                         exit(EXIT_STATUS_NOERROR);
253                 }
254                 else
255                 {
256                         setsid();
257                         signal(SIGTERM, InspIRCd::SetSignal);
258                         SocketEngine::RecoverFromFork();
259                 }
260 #endif
261         }
262
263         // Increase the size of a core dump file to improve debugging problems.
264         void IncreaseCoreDumpSize()
265         {
266 #ifndef _WIN32
267                 errno = 0;
268                 rlimit rl;
269                 if (getrlimit(RLIMIT_CORE, &rl) == -1)
270                 {
271                         ServerInstance->Logs->Log("STARTUP", LOG_DEFAULT, "Unable to increase core dump size: getrlimit(RLIMIT_CORE) failed: %s", strerror(errno));
272                         return;
273                 }
274
275                 rl.rlim_cur = rl.rlim_max;
276                 if (setrlimit(RLIMIT_CORE, &rl) == -1)
277                         ServerInstance->Logs->Log("STARTUP", LOG_DEFAULT, "Unable to increase core dump size: setrlimit(RLIMIT_CORE) failed: %s", strerror(errno));
278 #endif
279         }
280
281         // Parses the command line options.
282         void ParseOptions()
283         {
284                 int do_debug = 0, do_nofork = 0,    do_nolog = 0;
285                 int do_nopid = 0, do_runasroot = 0, do_version = 0;
286                 struct option longopts[] =
287                 {
288                         { "config",    required_argument, NULL,          'c' },
289                         { "debug",     no_argument,       &do_debug,     1 },
290                         { "nofork",    no_argument,       &do_nofork,    1 },
291                         { "nolog",     no_argument,       &do_nolog,     1 },
292                         { "nopid",     no_argument,       &do_nopid,     1 },
293                         { "runasroot", no_argument,       &do_runasroot, 1 },
294                         { "version",   no_argument,       &do_version,   1 },
295                         { 0, 0, 0, 0 }
296                 };
297
298                 char** argv = ServerInstance->Config->cmdline.argv;
299                 int ret;
300                 while ((ret = getopt_long(ServerInstance->Config->cmdline.argc, argv, ":c:", longopts, NULL)) != -1)
301                 {
302                         switch (ret)
303                         {
304                                 case 0:
305                                         // A long option was specified.
306                                         break;
307
308                                 case 'c':
309                                         // The -c option was specified.
310                                         ServerInstance->ConfigFileName = ExpandPath(optarg);
311                                         break;
312
313                                 default:
314                                         // An unknown option was specified.
315                                         std::cout << con_red << "Error:" <<  con_reset << " unknown option '" << argv[optind - 1] << "'." << std::endl
316                                                 << con_bright << "Usage: " << con_reset << argv[0] << " [--config <file>] [--debug] [--nofork] [--nolog]" << std::endl
317                                                 << std::string(strlen(argv[0]) + 8, ' ') << "[--nopid] [--runasroot] [--version]" << std::endl;
318                                         ServerInstance->Exit(EXIT_STATUS_ARGV);
319                                         break;
320                         }
321                 }
322
323                 if (do_version)
324                 {
325                         std::cout << std::endl << INSPIRCD_VERSION << std::endl;
326                         ServerInstance->Exit(EXIT_STATUS_NOERROR);
327                 }
328
329                 // Store the relevant parsed arguments
330                 ServerInstance->Config->cmdline.forcedebug = !!do_debug;
331                 ServerInstance->Config->cmdline.nofork = !!do_nofork;
332                 ServerInstance->Config->cmdline.runasroot = !!do_runasroot;
333                 ServerInstance->Config->cmdline.writelog = !do_nolog;
334                 ServerInstance->Config->cmdline.writepid = !do_nopid;
335         }
336         // Seeds the random number generator if applicable.
337         void SeedRng(timespec ts)
338         {
339 #if defined _WIN32
340                 srand(ts.tv_nsec ^ ts.tv_sec);
341 #elif !defined HAS_ARC4RANDOM_BUF
342                 srandom(ts.tv_nsec ^ ts.tv_sec);
343 #endif
344         }
345
346         // Sets handlers for various process signals.
347         void SetSignals()
348         {
349 #ifndef _WIN32
350                 signal(SIGALRM, SIG_IGN);
351                 signal(SIGCHLD, SIG_IGN);
352                 signal(SIGHUP, InspIRCd::SetSignal);
353                 signal(SIGPIPE, SIG_IGN);
354                 signal(SIGUSR1, SIG_IGN);
355                 signal(SIGUSR2, SIG_IGN);
356                 signal(SIGXFSZ, SIG_IGN);
357 #endif
358                 signal(SIGTERM, InspIRCd::SetSignal);
359         }
360
361         // Required for returning the proper value of EXIT_SUCCESS for the parent process.
362         void VoidSignalHandler(int)
363         {
364                 exit(EXIT_STATUS_NOERROR);
365         }
366 }
367
368 void InspIRCd::Cleanup()
369 {
370         // Close all listening sockets
371         for (unsigned int i = 0; i < ports.size(); i++)
372         {
373                 ports[i]->cull();
374                 delete ports[i];
375         }
376         ports.clear();
377
378         // Tell modules that we're shutting down.
379         const std::string quitmsg = "Server shutting down";
380         FOREACH_MOD(OnShutdown, (quitmsg));
381
382         // Disconnect all local users
383         const UserManager::LocalList& list = Users.GetLocalUsers();
384         while (!list.empty())
385                 ServerInstance->Users.QuitUser(list.front(), quitmsg);
386
387         GlobalCulls.Apply();
388         Modules->UnloadAll();
389
390         /* Delete objects dynamically allocated in constructor (destructor would be more appropriate, but we're likely exiting) */
391         /* Must be deleted before modes as it decrements modelines */
392         if (FakeClient)
393         {
394                 delete FakeClient->server;
395                 FakeClient->cull();
396         }
397         DeleteZero(this->FakeClient);
398         DeleteZero(this->XLines);
399         DeleteZero(this->Config);
400         SocketEngine::Deinit();
401         Logs->CloseLogs();
402 }
403
404 void InspIRCd::WritePID(const std::string& filename, bool exitonfail)
405 {
406 #ifndef _WIN32
407         if (!ServerInstance->Config->cmdline.writepid)
408         {
409                 this->Logs->Log("STARTUP", LOG_DEFAULT, "--nopid specified on command line; PID file not written.");
410                 return;
411         }
412
413         std::string fname = ServerInstance->Config->Paths.PrependData(filename.empty() ? "inspircd.pid" : filename);
414         std::ofstream outfile(fname.c_str());
415         if (outfile.is_open())
416         {
417                 outfile << getpid();
418                 outfile.close();
419         }
420         else
421         {
422                 if (exitonfail)
423                         std::cout << "Failed to write PID-file '" << fname << "', exiting." << std::endl;
424                 this->Logs->Log("STARTUP", LOG_DEFAULT, "Failed to write PID-file '%s'%s", fname.c_str(), (exitonfail ? ", exiting." : ""));
425                 if (exitonfail)
426                         Exit(EXIT_STATUS_PID);
427         }
428 #endif
429 }
430
431 InspIRCd::InspIRCd(int argc, char** argv)
432         : FakeClient(NULL)
433         , ConfigFileName(INSPIRCD_CONFIG_PATH "/inspircd.conf")
434         , ConfigThread(NULL)
435         , Config(NULL)
436         , XLines(NULL)
437         , PI(&DefaultProtocolInterface)
438         , GenRandom(&DefaultGenRandom)
439         , IsChannel(&DefaultIsChannel)
440         , IsNick(&DefaultIsNick)
441         , IsIdent(&DefaultIsIdent)
442 {
443         ServerInstance = this;
444
445         UpdateTime();
446         this->startup_time = TIME.tv_sec;
447
448         IncreaseCoreDumpSize();
449         SeedRng(TIME);
450         SocketEngine::Init();
451
452         this->Config = new ServerConfig;
453         dynamic_reference_base::reset_all();
454         this->XLines = new XLineManager;
455
456         this->Config->cmdline.argv = argv;
457         this->Config->cmdline.argc = argc;
458
459 #ifdef _WIN32
460         // Initialize the console values
461         g_hStdout = GetStdHandle(STD_OUTPUT_HANDLE);
462         CONSOLE_SCREEN_BUFFER_INFO bufinf;
463         if(GetConsoleScreenBufferInfo(g_hStdout, &bufinf))
464         {
465                 g_wOriginalColors = bufinf.wAttributes & 0x00FF;
466                 g_wBackgroundColor = bufinf.wAttributes & 0x00F0;
467         }
468         else
469         {
470                 g_wOriginalColors = FOREGROUND_RED|FOREGROUND_BLUE|FOREGROUND_GREEN;
471                 g_wBackgroundColor = 0;
472         }
473 #endif
474
475         {
476                 ServiceProvider* provs[] =
477                 {
478                         &rfcevents.numeric, &rfcevents.join, &rfcevents.part, &rfcevents.kick, &rfcevents.quit, &rfcevents.nick,
479                         &rfcevents.mode, &rfcevents.topic, &rfcevents.privmsg, &rfcevents.invite, &rfcevents.ping, &rfcevents.pong,
480                         &rfcevents.error
481                 };
482                 Modules.AddServices(provs, sizeof(provs)/sizeof(provs[0]));
483         }
484
485         std::cout << con_green << "InspIRCd - Internet Relay Chat Daemon" << con_reset << std::endl
486                 << "See " << con_green << "/INFO" << con_reset << " for contributors & authors" << std::endl
487                 << std::endl;
488
489         ParseOptions();
490         if (Config->cmdline.forcedebug)
491         {
492                 FileWriter* fw = new FileWriter(stdout, 1);
493                 FileLogStream* fls = new FileLogStream(LOG_RAWIO, fw);
494                 Logs->AddLogTypes("*", fls, true);
495         }
496
497         if (!FindConfigFile(ConfigFileName))
498         {
499                 this->Logs->Log("STARTUP", LOG_DEFAULT, "Unable to open config file %s", ConfigFileName.c_str());
500                 std::cout << "ERROR: Cannot open config file: " << ConfigFileName << std::endl << "Exiting..." << std::endl;
501                 Exit(EXIT_STATUS_CONFIG);
502         }
503
504         SetSignals();
505         if (!Config->cmdline.runasroot)
506                 CheckRoot();
507         if (!Config->cmdline.nofork)
508                 ForkIntoBackground();
509
510         std::cout << "InspIRCd Process ID: " << con_green << getpid() << con_reset << std::endl;
511
512         /* During startup we read the configuration now, not in
513          * a seperate thread
514          */
515         this->Config->Read();
516         this->Config->Apply(NULL, "");
517         Logs->OpenFileLogs();
518
519         // If we don't have a SID, generate one based on the server name and the server description
520         if (Config->sid.empty())
521                 Config->sid = UIDGenerator::GenerateSID(Config->ServerName, Config->ServerDesc);
522
523         // Initialize the UID generator with our sid
524         this->UIDGen.init(Config->sid);
525
526         // Create the server user for this server
527         this->FakeClient = new FakeUser(Config->sid, Config->ServerName, Config->ServerDesc);
528
529         // This is needed as all new XLines are marked pending until ApplyLines() is called
530         this->XLines->ApplyLines();
531
532         FailedPortList pl;
533         size_t bounditems = BindPorts(pl);
534
535         std::cout << std::endl;
536
537         this->Modules->LoadAll();
538
539         // Build ISupport as ModuleManager::LoadAll() does not do it
540         this->ISupport.Build();
541
542         if (!pl.empty())
543         {
544                 std::cout << std::endl << "WARNING: Not all your client ports could be bound -- " << std::endl << "starting anyway with " << bounditems
545                         << " of " << (bounditems + pl.size()) << " client ports bound." << std::endl << std::endl;
546                 std::cout << "The following port(s) failed to bind:" << std::endl << std::endl;
547                 int j = 1;
548                 for (FailedPortList::iterator i = pl.begin(); i != pl.end(); i++, j++)
549                 {
550                         std::cout << j << ".\tAddress: " << i->first.str() << " \tReason: " << strerror(i->second) << std::endl;
551                 }
552
553                 std::cout << std::endl << "Hint: Try using a public IP instead of blank or *" << std::endl;
554         }
555
556         std::cout << "InspIRCd is now running as '" << Config->ServerName << "'[" << Config->GetSID() << "] with " << SocketEngine::GetMaxFds() << " max open sockets" << std::endl;
557
558 #ifndef _WIN32
559         if (!Config->cmdline.nofork)
560         {
561                 if (kill(getppid(), SIGTERM) == -1)
562                 {
563                         std::cout << "Error killing parent process: " << strerror(errno) << std::endl;
564                         Logs->Log("STARTUP", LOG_DEFAULT, "Error killing parent process: %s",strerror(errno));
565                 }
566         }
567
568         /* Explicitly shut down stdio's stdin/stdout/stderr.
569          *
570          * The previous logic here was to only do this if stdio was connected to a controlling
571          * terminal.  However, we must do this always to avoid information leaks and other
572          * problems related to stdio.
573          *
574          * The only exception is if we are in debug mode.
575          *
576          *    -- nenolod
577          */
578         if ((!Config->cmdline.nofork) && (!Config->cmdline.forcedebug))
579         {
580                 int fd = open("/dev/null", O_RDWR);
581
582                 fclose(stdin);
583                 fclose(stderr);
584                 fclose(stdout);
585
586                 if (dup2(fd, STDIN_FILENO) < 0)
587                         Logs->Log("STARTUP", LOG_DEFAULT, "Failed to dup /dev/null to stdin.");
588                 if (dup2(fd, STDOUT_FILENO) < 0)
589                         Logs->Log("STARTUP", LOG_DEFAULT, "Failed to dup /dev/null to stdout.");
590                 if (dup2(fd, STDERR_FILENO) < 0)
591                         Logs->Log("STARTUP", LOG_DEFAULT, "Failed to dup /dev/null to stderr.");
592                 close(fd);
593         }
594         else
595         {
596                 Logs->Log("STARTUP", LOG_DEFAULT, "Keeping pseudo-tty open as we are running in the foreground.");
597         }
598 #else
599         /* Set win32 service as running, if we are running as a service */
600         SetServiceRunning();
601
602         // Handle forking
603         if(!Config->cmdline.nofork)
604         {
605                 FreeConsole();
606         }
607
608         QueryPerformanceFrequency(&stats.QPFrequency);
609 #endif
610
611         WritePID(Config->PID);
612         DropRoot();
613
614         Logs->Log("STARTUP", LOG_DEFAULT, "Startup complete as '%s'[%s], %lu max open sockets", Config->ServerName.c_str(),Config->GetSID().c_str(), SocketEngine::GetMaxFds());
615 }
616
617 void InspIRCd::UpdateTime()
618 {
619 #if defined HAS_CLOCK_GETTIME
620         clock_gettime(CLOCK_REALTIME, &TIME);
621 #elif defined _WIN32
622         SYSTEMTIME st;
623         GetSystemTime(&st);
624
625         TIME.tv_sec = time(NULL);
626         TIME.tv_nsec = st.wMilliseconds;
627 #else
628         struct timeval tv;
629         gettimeofday(&tv, NULL);
630
631         TIME.tv_sec = tv.tv_sec;
632         TIME.tv_nsec = tv.tv_usec * 1000;
633 #endif
634 }
635
636 void InspIRCd::Run()
637 {
638         UpdateTime();
639         time_t OLDTIME = TIME.tv_sec;
640
641         while (true)
642         {
643                 /* Check if there is a config thread which has finished executing but has not yet been freed */
644                 if (this->ConfigThread && this->ConfigThread->IsDone())
645                 {
646                         /* Rehash has completed */
647                         this->Logs->Log("CONFIG", LOG_DEBUG, "Detected ConfigThread exiting, tidying up...");
648
649                         this->ConfigThread->Finish();
650
651                         ConfigThread->join();
652                         delete ConfigThread;
653                         ConfigThread = NULL;
654                 }
655
656                 UpdateTime();
657
658                 /* Run background module timers every few seconds
659                  * (the docs say modules shouldnt rely on accurate
660                  * timing using this event, so we dont have to
661                  * time this exactly).
662                  */
663                 if (TIME.tv_sec != OLDTIME)
664                 {
665                         CollectStats();
666
667                         if (Config->TimeSkipWarn)
668                         {
669                                 time_t timediff = TIME.tv_sec - OLDTIME;
670
671                                 if (timediff > Config->TimeSkipWarn)
672                                         SNO->WriteToSnoMask('a', "\002Performance warning!\002 Server clock jumped forwards by %lu seconds!", timediff);
673
674                                 else if (timediff < -Config->TimeSkipWarn)
675                                         SNO->WriteToSnoMask('a', "\002Performance warning!\002 Server clock jumped backwards by %lu seconds!", labs(timediff));
676                         }
677
678                         OLDTIME = TIME.tv_sec;
679
680                         if ((TIME.tv_sec % 3600) == 0)
681                                 FOREACH_MOD(OnGarbageCollect, ());
682
683                         Timers.TickTimers(TIME.tv_sec);
684                         Users->DoBackgroundUserStuff();
685
686                         if ((TIME.tv_sec % 5) == 0)
687                         {
688                                 FOREACH_MOD(OnBackgroundTimer, (TIME.tv_sec));
689                                 SNO->FlushSnotices();
690                         }
691                 }
692
693                 /* Call the socket engine to wait on the active
694                  * file descriptors. The socket engine has everything's
695                  * descriptors in its list... dns, modules, users,
696                  * servers... so its nice and easy, just one call.
697                  * This will cause any read or write events to be
698                  * dispatched to their handlers.
699                  */
700                 SocketEngine::DispatchTrialWrites();
701                 SocketEngine::DispatchEvents();
702
703                 /* if any users were quit, take them out */
704                 GlobalCulls.Apply();
705                 AtomicActions.Run();
706
707                 if (s_signal)
708                 {
709                         this->SignalHandler(s_signal);
710                         s_signal = 0;
711                 }
712         }
713 }
714
715 sig_atomic_t InspIRCd::s_signal = 0;
716
717 void InspIRCd::SetSignal(int signal)
718 {
719         s_signal = signal;
720 }
721
722 /* On posix systems, the flow of the program starts right here, with
723  * ENTRYPOINT being a #define that defines main(). On Windows, ENTRYPOINT
724  * defines smain() and the real main() is in the service code under
725  * win32service.cpp. This allows the service control manager to control
726  * the process where we are running as a windows service.
727  */
728 ENTRYPOINT
729 {
730         new InspIRCd(argc, argv);
731         ServerInstance->Run();
732         delete ServerInstance;
733         return 0;
734 }