ViewVC Help
View File | Revision Log | Show Annotations | View Changeset | Root Listing
root/svn/ircd-hybrid/trunk/src/ircd.c
Revision: 4325
Committed: Fri Aug 1 18:06:07 2014 UTC (11 years ago) by michael
Content type: text/x-csrc
File size: 16929 byte(s)
Log Message:
- Moved all ip caching related code to ipcache.c

File Contents

# Content
1 /*
2 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3 *
4 * Copyright (c) 1997-2014 ircd-hybrid development team
5 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
19 * USA
20 */
21
22 /*! \file ircd.c
23 * \brief Starts up and runs the ircd.
24 * \version $Id$
25 */
26
27 #include "stdinc.h"
28 #include "user.h"
29 #include "list.h"
30 #include "ircd.h"
31 #include "channel.h"
32 #include "client.h"
33 #include "event.h"
34 #include "fdlist.h"
35 #include "hash.h"
36 #include "irc_string.h"
37 #include "ircd_signal.h"
38 #include "gline.h"
39 #include "motd.h"
40 #include "conf.h"
41 #include "hostmask.h"
42 #include "parse.h"
43 #include "res.h"
44 #include "restart.h"
45 #include "rng_mt.h"
46 #include "auth.h"
47 #include "s_bsd.h"
48 #include "log.h"
49 #include "server.h" /* try_connections */
50 #include "send.h"
51 #include "whowas.h"
52 #include "modules.h"
53 #include "memory.h"
54 #include "mempool.h"
55 #include "ircd_getopt.h"
56 #include "watch.h"
57 #include "conf_db.h"
58 #include "conf_class.h"
59 #include "ipcache.h"
60
61
62 #ifdef HAVE_LIBGEOIP
63 GeoIP *geoip_ctx;
64 #endif
65
66 struct ServerStatistics ServerStats;
67 struct timeval SystemTime;
68 struct Client me; /* That's me */
69 struct LocalUser meLocalUser; /* That's also part of me */
70
71 const char *logFileName = LPATH;
72 const char *pidFileName = PPATH;
73
74 char **myargv;
75
76 int dorehash = 0;
77 int doremotd = 0;
78
79 /* Set to zero because it should be initialized later using
80 * initialize_server_capabs
81 */
82 unsigned int default_server_capabs;
83 unsigned int splitmode;
84 unsigned int splitchecking;
85 unsigned int split_users;
86 unsigned int split_servers;
87
88 static struct event event_cleanup_glines =
89 {
90 .name = "cleanup_glines",
91 .handler = cleanup_glines,
92 .when = CLEANUP_GLINES_TIME
93 };
94
95 static struct event event_cleanup_tklines =
96 {
97 .name = "cleanup_tklines",
98 .handler = cleanup_tklines,
99 .when = CLEANUP_TKLINES_TIME
100 };
101
102 static struct event event_try_connections =
103 {
104 .name = "try_connections",
105 .handler = try_connections,
106 .when = STARTUP_CONNECTIONS_TIME
107 };
108
109 static struct event event_comm_checktimeouts =
110 {
111 .name = "comm_checktimeouts",
112 .handler = comm_checktimeouts,
113 .when = 1
114 };
115
116 static struct event event_save_all_databases =
117 {
118 .name = "save_all_databases",
119 .handler = save_all_databases,
120 .when = DATABASE_UPDATE_TIMEOUT
121 };
122
123 struct event event_write_links_file =
124 {
125 .name = "write_links_file",
126 .handler = write_links_file,
127 };
128
129
130 /*
131 * print_startup - print startup information
132 */
133 static void
134 print_startup(int pid)
135 {
136 printf("ircd: version %s(%s)\n", ircd_version, serno);
137 printf("ircd: pid %d\n", pid);
138 printf("ircd: running in %s mode from %s\n", !server_state.foreground ? "background"
139 : "foreground", ConfigFileEntry.dpath);
140 }
141
142 static void
143 make_daemon(void)
144 {
145 int pid;
146
147 if ((pid = fork()) < 0)
148 {
149 perror("fork");
150 exit(EXIT_FAILURE);
151 }
152 else if (pid > 0)
153 {
154 print_startup(pid);
155 exit(EXIT_SUCCESS);
156 }
157
158 setsid();
159 }
160
161 static int printVersion = 0;
162
163 static struct lgetopt myopts[] =
164 {
165 {"configfile", &ConfigFileEntry.configfile,
166 STRING, "File to use for ircd.conf"},
167 {"glinefile", &ConfigFileEntry.glinefile,
168 STRING, "File to use for gline database"},
169 {"klinefile", &ConfigFileEntry.klinefile,
170 STRING, "File to use for kline database"},
171 {"dlinefile", &ConfigFileEntry.dlinefile,
172 STRING, "File to use for dline database"},
173 {"xlinefile", &ConfigFileEntry.xlinefile,
174 STRING, "File to use for xline database"},
175 {"resvfile", &ConfigFileEntry.resvfile,
176 STRING, "File to use for resv database"},
177 {"logfile", &logFileName,
178 STRING, "File to use for ircd.log"},
179 {"pidfile", &pidFileName,
180 STRING, "File to use for process ID"},
181 {"foreground", &server_state.foreground,
182 YESNO, "Run in foreground (don't detach)"},
183 {"version", &printVersion,
184 YESNO, "Print version and exit"},
185 {"help", NULL, USAGE, "Print this text"},
186 {NULL, NULL, STRING, NULL},
187 };
188
189 void
190 set_time(void)
191 {
192 struct timeval newtime = { .tv_sec = 0, .tv_usec = 0 };
193
194 if (gettimeofday(&newtime, NULL) == -1)
195 {
196 ilog(LOG_TYPE_IRCD, "Clock Failure (%s), TS can be corrupted",
197 strerror(errno));
198 sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
199 "Clock Failure (%s), TS can be corrupted",
200 strerror(errno));
201 server_die("Clock Failure", 1);
202 }
203
204 if (newtime.tv_sec < CurrentTime)
205 {
206 ilog(LOG_TYPE_IRCD, "System clock is running backwards - (%lu < %lu)",
207 (unsigned long)newtime.tv_sec, (unsigned long)CurrentTime);
208 sendto_realops_flags(UMODE_DEBUG, L_ALL, SEND_NOTICE,
209 "System clock is running backwards - (%lu < %lu)",
210 (unsigned long)newtime.tv_sec,
211 (unsigned long)CurrentTime);
212 set_back_events(CurrentTime - newtime.tv_sec);
213 }
214
215 SystemTime.tv_sec = newtime.tv_sec;
216 SystemTime.tv_usec = newtime.tv_usec;
217 }
218
219 static void
220 io_loop(void)
221 {
222 while (1)
223 {
224 if (listing_client_list.head)
225 {
226 dlink_node *ptr = NULL, *ptr_next = NULL;
227 DLINK_FOREACH_SAFE(ptr, ptr_next, listing_client_list.head)
228 safe_list_channels(ptr->data, 0);
229 }
230
231 /* Run pending events */
232 event_run();
233
234 comm_select();
235 exit_aborted_clients();
236 free_exited_clients();
237
238 /* Check to see whether we have to rehash the configuration .. */
239 if (dorehash)
240 {
241 rehash(1);
242 dorehash = 0;
243 }
244
245 if (doremotd)
246 {
247 motd_recache();
248 sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
249 "Got signal SIGUSR1, reloading motd file(s)");
250 doremotd = 0;
251 }
252 }
253 }
254
255 /* initalialize_global_set_options()
256 *
257 * inputs - none
258 * output - none
259 * side effects - This sets all global set options needed
260 */
261 static void
262 initialize_global_set_options(void)
263 {
264 GlobalSetOptions.autoconn = 1;
265 GlobalSetOptions.spam_time = MIN_JOIN_LEAVE_TIME;
266 GlobalSetOptions.spam_num = MAX_JOIN_LEAVE_COUNT;
267
268 if (ConfigFileEntry.default_floodcount)
269 GlobalSetOptions.floodcount = ConfigFileEntry.default_floodcount;
270 else
271 GlobalSetOptions.floodcount = 10;
272
273 /* XXX I have no idea what to try here - Dianora */
274 GlobalSetOptions.joinfloodcount = 16;
275 GlobalSetOptions.joinfloodtime = 8;
276
277 split_servers = ConfigChannel.default_split_server_count;
278 split_users = ConfigChannel.default_split_user_count;
279
280 if (split_users && split_servers && (ConfigChannel.no_create_on_split ||
281 ConfigChannel.no_join_on_split))
282 {
283 splitmode = 1;
284 splitchecking = 1;
285 }
286
287 GlobalSetOptions.ident_timeout = IDENT_TIMEOUT;
288 }
289
290 /* initialize_server_capabs()
291 *
292 * inputs - none
293 * output - none
294 */
295 static void
296 initialize_server_capabs(void)
297 {
298 add_capability("QS", CAP_QS, 1);
299 add_capability("EOB", CAP_EOB, 1);
300 add_capability("TS6", CAP_TS6, 0);
301 add_capability("CLUSTER", CAP_CLUSTER, 1);
302 add_capability("SVS", CAP_SVS, 1);
303 add_capability("CHW", CAP_CHW, 1);
304 add_capability("HOPS", CAP_HOPS, 1);
305 }
306
307 /* write_pidfile()
308 *
309 * inputs - filename+path of pid file
310 * output - NONE
311 * side effects - write the pid of the ircd to filename
312 */
313 static void
314 write_pidfile(const char *filename)
315 {
316 FILE *fb;
317
318 if ((fb = fopen(filename, "w")))
319 {
320 char buff[IRCD_BUFSIZE];
321 unsigned int pid = (unsigned int)getpid();
322
323 snprintf(buff, sizeof(buff), "%u\n", pid);
324
325 if ((fputs(buff, fb) == -1))
326 ilog(LOG_TYPE_IRCD, "Error writing %u to pid file %s (%s)",
327 pid, filename, strerror(errno));
328
329 fclose(fb);
330 }
331 else
332 {
333 ilog(LOG_TYPE_IRCD, "Error opening pid file %s", filename);
334 }
335 }
336
337 /* check_pidfile()
338 *
339 * inputs - filename+path of pid file
340 * output - none
341 * side effects - reads pid from pidfile and checks if ircd is in process
342 * list. if it is, gracefully exits
343 * -kre
344 */
345 static void
346 check_pidfile(const char *filename)
347 {
348 FILE *fb;
349 char buff[IRCD_BUFSIZE];
350 pid_t pidfromfile;
351
352 /* Don't do logging here, since we don't have log() initialised */
353 if ((fb = fopen(filename, "r")))
354 {
355 if (fgets(buff, 20, fb) == NULL)
356 {
357 /* log(L_ERROR, "Error reading from pid file %s (%s)", filename,
358 * strerror(errno));
359 */
360 }
361 else
362 {
363 pidfromfile = atoi(buff);
364
365 if (!kill(pidfromfile, 0))
366 {
367 /* log(L_ERROR, "Server is already running"); */
368 printf("ircd: daemon is already running\n");
369 exit(-1);
370 }
371 }
372
373 fclose(fb);
374 }
375 else if (errno != ENOENT)
376 {
377 /* log(L_ERROR, "Error opening pid file %s", filename); */
378 }
379 }
380
381 /* setup_corefile()
382 *
383 * inputs - nothing
384 * output - nothing
385 * side effects - setups corefile to system limits.
386 * -kre
387 */
388 static void
389 setup_corefile(void)
390 {
391 #ifdef HAVE_SYS_RESOURCE_H
392 struct rlimit rlim; /* resource limits */
393
394 /* Set corefilesize to maximum */
395 if (!getrlimit(RLIMIT_CORE, &rlim))
396 {
397 rlim.rlim_cur = rlim.rlim_max;
398 setrlimit(RLIMIT_CORE, &rlim);
399 }
400 #endif
401 }
402
403 #ifdef HAVE_LIBCRYPTO
404 static int
405 always_accept_verify_cb(int preverify_ok, X509_STORE_CTX *x509_ctx)
406 {
407 return 1;
408 }
409 #endif
410
411 /* init_ssl()
412 *
413 * inputs - nothing
414 * output - nothing
415 * side effects - setups SSL context.
416 */
417 static void
418 ssl_init(void)
419 {
420 #ifdef HAVE_LIBCRYPTO
421 const unsigned char session_id[] = "ircd-hybrid";
422
423 SSL_load_error_strings();
424 SSLeay_add_ssl_algorithms();
425
426 if ((ServerInfo.server_ctx = SSL_CTX_new(SSLv23_server_method())) == NULL)
427 {
428 const char *s = ERR_lib_error_string(ERR_get_error());
429
430 fprintf(stderr, "ERROR: Could not initialize the SSL Server context -- %s\n", s);
431 ilog(LOG_TYPE_IRCD, "ERROR: Could not initialize the SSL Server context -- %s\n", s);
432 }
433
434 SSL_CTX_set_options(ServerInfo.server_ctx, SSL_OP_NO_SSLv2|SSL_OP_NO_SSLv3);
435 SSL_CTX_set_options(ServerInfo.server_ctx, SSL_OP_SINGLE_DH_USE);
436 SSL_CTX_set_verify(ServerInfo.server_ctx, SSL_VERIFY_PEER|SSL_VERIFY_CLIENT_ONCE,
437 always_accept_verify_cb);
438 SSL_CTX_set_session_id_context(ServerInfo.server_ctx, session_id, sizeof(session_id) - 1);
439
440 #if OPENSSL_VERSION_NUMBER >= 0x1000005FL && !defined(OPENSSL_NO_ECDH)
441 {
442 EC_KEY *key = EC_KEY_new_by_curve_name(NID_X9_62_prime256v1);
443
444 if (key)
445 {
446 SSL_CTX_set_tmp_ecdh(ServerInfo.server_ctx, key);
447 EC_KEY_free(key);
448 }
449 }
450
451 SSL_CTX_set_options(ServerInfo.server_ctx, SSL_OP_SINGLE_ECDH_USE);
452 #endif
453
454 if ((ServerInfo.client_ctx = SSL_CTX_new(SSLv23_client_method())) == NULL)
455 {
456 const char *s = ERR_lib_error_string(ERR_get_error());
457
458 fprintf(stderr, "ERROR: Could not initialize the SSL Client context -- %s\n", s);
459 ilog(LOG_TYPE_IRCD, "ERROR: Could not initialize the SSL Client context -- %s\n", s);
460 }
461
462 SSL_CTX_set_options(ServerInfo.client_ctx, SSL_OP_NO_SSLv2|SSL_OP_NO_SSLv3);
463 SSL_CTX_set_options(ServerInfo.client_ctx, SSL_OP_SINGLE_DH_USE);
464 SSL_CTX_set_verify(ServerInfo.client_ctx, SSL_VERIFY_PEER|SSL_VERIFY_CLIENT_ONCE,
465 always_accept_verify_cb);
466 #endif /* HAVE_LIBCRYPTO */
467 }
468
469 int
470 main(int argc, char *argv[])
471 {
472 /* Check to see if the user is running us as root, which is a nono */
473 if (geteuid() == 0)
474 {
475 fprintf(stderr, "ERROR: This server won't run as root/superuser\n");
476 return -1;
477 }
478
479 /* Setup corefile size immediately after boot -kre */
480 setup_corefile();
481
482 /* save server boot time right away, so getrusage works correctly */
483 set_time();
484
485 /* It ain't random, but it ought to be a little harder to guess */
486 init_genrand(SystemTime.tv_sec ^ (SystemTime.tv_usec | (getpid() << 20)));
487
488 me.localClient = &meLocalUser;
489 dlinkAdd(&me, &me.node, &global_client_list); /* Pointer to beginning
490 of Client list */
491 ConfigLoggingEntry.use_logging = 1;
492 ConfigFileEntry.dpath = DPATH;
493 ConfigFileEntry.spath = SPATH;
494 ConfigFileEntry.mpath = MPATH;
495 ConfigFileEntry.configfile = CPATH; /* Server configuration file */
496 ConfigFileEntry.klinefile = KPATH; /* Server kline file */
497 ConfigFileEntry.glinefile = GPATH; /* Server gline file */
498 ConfigFileEntry.xlinefile = XPATH; /* Server xline file */
499 ConfigFileEntry.dlinefile = DLPATH; /* dline file */
500 ConfigFileEntry.resvfile = RESVPATH; /* resv file */
501
502 myargv = argv;
503 umask(077); /* better safe than sorry --SRB */
504
505 parseargs(&argc, &argv, myopts);
506
507 if (printVersion)
508 {
509 printf("ircd: version %s(%s)\n", ircd_version, serno);
510 exit(EXIT_SUCCESS);
511 }
512
513 if (chdir(ConfigFileEntry.dpath))
514 {
515 perror("chdir");
516 exit(EXIT_FAILURE);
517 }
518
519 ssl_init();
520
521 if (!server_state.foreground)
522 {
523 make_daemon();
524 close_standard_fds(); /* this needs to be before init_netio()! */
525 }
526 else
527 print_startup(getpid());
528
529 setup_signals();
530
531 /* We need this to initialise the fd array before anything else */
532 fdlist_init();
533 log_set_file(LOG_TYPE_IRCD, 0, logFileName);
534 check_can_use_v6();
535 init_netio(); /* This needs to be setup early ! -- adrian */
536
537 /* Check if there is pidfile and daemon already running */
538 check_pidfile(pidFileName);
539
540 mp_pool_init();
541 init_dlink_nodes();
542 init_isupport();
543 dbuf_init();
544 hash_init();
545 ipcache_init();
546 init_host_hash(); /* Host-hashtable. */
547 client_init();
548 class_init();
549 whowas_init();
550 watch_init();
551 auth_init(); /* Initialise the auth code */
552 init_resolver(); /* Needs to be setup before the io loop */
553 modules_init();
554 read_conf_files(1); /* cold start init conf files */
555 init_uid();
556 initialize_server_capabs(); /* Set up default_server_capabs */
557 initialize_global_set_options();
558 channel_init();
559 read_links_file();
560 motd_init();
561 #ifdef HAVE_LIBGEOIP
562 geoip_ctx = GeoIP_new(GEOIP_MEMORY_CACHE);
563 #endif
564
565 if (EmptyString(ServerInfo.sid))
566 {
567 ilog(LOG_TYPE_IRCD, "ERROR: No server id specified in serverinfo block.");
568 exit(EXIT_FAILURE);
569 }
570
571 strlcpy(me.id, ServerInfo.sid, sizeof(me.id));
572
573 if (EmptyString(ServerInfo.name))
574 {
575 ilog(LOG_TYPE_IRCD, "ERROR: No server name specified in serverinfo block.");
576 exit(EXIT_FAILURE);
577 }
578
579 strlcpy(me.name, ServerInfo.name, sizeof(me.name));
580
581 /* serverinfo{} description must exist. If not, error out.*/
582 if (EmptyString(ServerInfo.description))
583 {
584 ilog(LOG_TYPE_IRCD, "ERROR: No server description specified in serverinfo block.");
585 exit(EXIT_FAILURE);
586 }
587
588 strlcpy(me.info, ServerInfo.description, sizeof(me.info));
589
590 me.from = &me;
591 me.servptr = &me;
592 me.localClient->lasttime = CurrentTime;
593 me.localClient->since = CurrentTime;
594 me.localClient->firsttime = CurrentTime;
595
596 SetMe(&me);
597 make_server(&me);
598
599 hash_add_id(&me);
600 hash_add_client(&me);
601
602 dlinkAdd(&me, make_dlink_node(), &global_server_list);
603
604 load_kline_database();
605 load_dline_database();
606 load_gline_database();
607 load_xline_database();
608 load_resv_database();
609
610 if (chdir(MODPATH))
611 {
612 ilog(LOG_TYPE_IRCD, "Could not load core modules. Terminating!");
613 exit(EXIT_FAILURE);
614 }
615
616 load_all_modules(1);
617 load_conf_modules();
618 load_core_modules(1);
619
620 /* Go back to DPATH after checking to see if we can chdir to MODPATH */
621 if (chdir(ConfigFileEntry.dpath))
622 {
623 perror("chdir");
624 exit(EXIT_FAILURE);
625 }
626
627 /*
628 * assemble_umode_buffer() has to be called after
629 * reading conf/loading modules.
630 */
631 assemble_umode_buffer();
632
633 write_pidfile(pidFileName);
634
635 ilog(LOG_TYPE_IRCD, "Server Ready");
636
637 event_addish(&event_cleanup_glines, NULL);
638 event_addish(&event_cleanup_tklines, NULL);
639
640 /* We want try_connections to be called as soon as possible now! -- adrian */
641 /* No, 'cause after a restart it would cause all sorts of nick collides */
642 event_addish(&event_try_connections, NULL);
643
644 /* Setup the timeout check. I'll shift it later :) -- adrian */
645 event_addish(&event_comm_checktimeouts, NULL);
646
647 event_addish(&event_save_all_databases, NULL);
648
649 if (ConfigServerHide.links_delay > 0)
650 {
651 event_write_links_file.when = ConfigServerHide.links_delay;
652 event_addish(&event_write_links_file, NULL);
653 }
654 else
655 ConfigServerHide.links_disabled = 1;
656
657 if (splitmode)
658 event_addish(&splitmode_event, NULL);
659
660 io_loop();
661 return 0;
662 }

Properties

Name Value
svn:eol-style native
svn:keywords Id Revision