ViewVC Help
View File | Revision Log | Show Annotations | View Changeset | Root Listing
root/svn/ircd-hybrid/trunk/src/ircd.c
(Generate patch)

Comparing ircd-hybrid/trunk/src/ircd.c (file contents):
Revision 3065 by michael, Thu Feb 27 19:03:46 2014 UTC vs.
Revision 4565 by michael, Sun Aug 24 10:27:40 2014 UTC

# Line 15 | Line 15
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
18 > *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
19   *  USA
20   */
21  
# Line 25 | Line 25
25   */
26  
27   #include "stdinc.h"
28 < #include "s_user.h"
28 > #include "user.h"
29   #include "list.h"
30   #include "ircd.h"
31   #include "channel.h"
32 #include "channel_mode.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 "s_gline.h"
38 > #include "gline.h"
39   #include "motd.h"
40   #include "conf.h"
41   #include "hostmask.h"
43 #include "numeric.h"
44 #include "packet.h"
42   #include "parse.h"
43 < #include "irc_res.h"
43 > #include "res.h"
44   #include "restart.h"
45   #include "rng_mt.h"
46 < #include "s_auth.h"
46 > #include "auth.h"
47   #include "s_bsd.h"
48   #include "log.h"
49 < #include "s_misc.h"
53 < #include "s_serv.h"      /* try_connections */
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"
59 #include "hook.h"
55   #include "ircd_getopt.h"
61 #include "supported.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  
71 /* /quote set variables */
72 struct SetOptions GlobalSetOptions;
73 struct Counter Count;
74 struct ServerState_t server_state;
66   struct ServerStatistics ServerStats;
67   struct timeval SystemTime;
68   struct Client me;             /* That's me */
# Line 88 | Line 79 | int doremotd = 0;
79   /* Set to zero because it should be initialized later using
80   * initialize_server_capabs
81   */
82 < int default_server_capabs = 0;
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 < /* Do klines the same way hybrid-6 did them, i.e. at the
89 < * top of the next io_loop instead of in the same loop as
90 < * the klines are being applied.
91 < *
92 < * This should fix strange CPU starvation as very indirectly reported.
93 < * (Why do you people not email bug reports? WHY? WHY?)
94 < *
95 < * - Dianora
96 < */
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 < int rehashed_klines = 0;
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   /*
# Line 116 | Line 136 | print_startup(int pid)
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);
139 >         : "foreground", ConfigGeneral.dpath);
140   }
141  
142   static void
# Line 140 | Line 160 | make_daemon(void)
160  
161   static int printVersion = 0;
162  
163 < static struct lgetopt myopts[] = {
164 <  {"configfile", &ConfigFileEntry.configfile,
163 > static struct lgetopt myopts[] =
164 > {
165 >  {"configfile", &ConfigGeneral.configfile,
166     STRING, "File to use for ircd.conf"},
167 <  {"glinefile",  &ConfigFileEntry.glinefile,
167 >  {"glinefile",  &ConfigGeneral.glinefile,
168     STRING, "File to use for gline database"},
169 <  {"klinefile",  &ConfigFileEntry.klinefile,
169 >  {"klinefile",  &ConfigGeneral.klinefile,
170     STRING, "File to use for kline database"},
171 <  {"dlinefile",  &ConfigFileEntry.dlinefile,
171 >  {"dlinefile",  &ConfigGeneral.dlinefile,
172     STRING, "File to use for dline database"},
173 <  {"xlinefile",  &ConfigFileEntry.xlinefile,
173 >  {"xlinefile",  &ConfigGeneral.xlinefile,
174     STRING, "File to use for xline database"},
175 <  {"resvfile",  &ConfigFileEntry.resvfile,
175 >  {"resvfile",  &ConfigGeneral.resvfile,
176     STRING, "File to use for resv database"},
177    {"logfile",    &logFileName,
178     STRING, "File to use for ircd.log"},
# Line 177 | Line 198 | set_time(void)
198      sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
199                           "Clock Failure (%s), TS can be corrupted",
200                           strerror(errno));
201 <    restart("Clock Failure");
201 >    server_die("Clock Failure", 1);
202    }
203  
204    if (newtime.tv_sec < CurrentTime)
# Line 198 | Line 219 | set_time(void)
219   static void
220   io_loop(void)
221   {
222 <  while (1 == 1)
222 >  while (1)
223    {
203    /*
204     * Maybe we want a flags word?
205     * ie. if (REHASHED_KLINES(global_flags))
206     * SET_REHASHED_KLINES(global_flags)
207     * CLEAR_REHASHED_KLINES(global_flags)
208     *
209     * - Dianora
210     */
211    if (rehashed_klines)
212    {
213      check_conf_klines();
214      rehashed_klines = 0;
215    }
216
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 <      {
222 <        struct Client *client_p = ptr->data;
223 <        assert(client_p->localClient->list_task);
224 <        safe_list_channels(client_p, client_p->localClient->list_task, 0);
225 <      }
228 >        safe_list_channels(ptr->data, 0);
229      }
230  
231 <    /* Run pending events, then get the number of seconds to the next
232 <     * event
230 <     */
231 <    while (eventNextTime() <= CurrentTime)
232 <      eventRun();
231 >    /* Run pending events */
232 >    event_run();
233  
234      comm_select();
235      exit_aborted_clients();
# Line 241 | Line 241 | io_loop(void)
241        rehash(1);
242        dorehash = 0;
243      }
244 +
245      if (doremotd)
246      {
247        motd_recache();
# Line 260 | Line 261 | io_loop(void)
261   static void
262   initialize_global_set_options(void)
263   {
263  memset(&GlobalSetOptions, 0, sizeof(GlobalSetOptions));
264
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;
268 >  if (ConfigGeneral.default_floodcount)
269 >    GlobalSetOptions.floodcount = ConfigGeneral.default_floodcount;
270    else
271      GlobalSetOptions.floodcount = 10;
272  
# Line 286 | Line 285 | initialize_global_set_options(void)
285    }
286  
287    GlobalSetOptions.ident_timeout = IDENT_TIMEOUT;
289  /* End of global set options */
288   }
289  
290   /* initialize_server_capabs()
# Line 302 | Line 300 | initialize_server_capabs(void)
300    add_capability("TS6", CAP_TS6, 0);
301    add_capability("CLUSTER", CAP_CLUSTER, 1);
302    add_capability("SVS", CAP_SVS, 1);
303 < #ifdef HALFOPS
303 >  add_capability("CHW", CAP_CHW, 1);
304    add_capability("HOPS", CAP_HOPS, 1);
307 #endif
305   }
306  
307   /* write_pidfile()
# Line 426 | Line 423 | ssl_init(void)
423    SSL_load_error_strings();
424    SSLeay_add_ssl_algorithms();
425  
426 <  if ((ServerInfo.server_ctx = SSL_CTX_new(SSLv23_server_method())) == NULL)
426 >  if ((ConfigServerInfo.server_ctx = SSL_CTX_new(SSLv23_server_method())) == NULL)
427    {
428 <    const char *s;
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",
434 <            s = ERR_lib_error_string(ERR_get_error()));
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 +    exit(EXIT_FAILURE);
433    }
434  
435 <  SSL_CTX_set_options(ServerInfo.server_ctx, SSL_OP_NO_SSLv2|SSL_OP_NO_SSLv3|SSL_OP_NO_TLSv1);
436 <  SSL_CTX_set_options(ServerInfo.server_ctx, SSL_OP_TLS_ROLLBACK_BUG|SSL_OP_ALL);
437 <  SSL_CTX_set_verify(ServerInfo.server_ctx, SSL_VERIFY_PEER|SSL_VERIFY_CLIENT_ONCE,
435 >  SSL_CTX_set_options(ConfigServerInfo.server_ctx, SSL_OP_NO_SSLv2|SSL_OP_NO_SSLv3);
436 >  SSL_CTX_set_options(ConfigServerInfo.server_ctx, SSL_OP_SINGLE_DH_USE);
437 >  SSL_CTX_set_verify(ConfigServerInfo.server_ctx, SSL_VERIFY_PEER|SSL_VERIFY_CLIENT_ONCE,
438                       always_accept_verify_cb);
439 <  SSL_CTX_set_session_id_context(ServerInfo.server_ctx, session_id, sizeof(session_id) - 1);
439 >  SSL_CTX_set_session_id_context(ConfigServerInfo.server_ctx, session_id, sizeof(session_id) - 1);
440  
441 <  if ((ServerInfo.client_ctx = SSL_CTX_new(SSLv23_client_method())) == NULL)
441 > #if OPENSSL_VERSION_NUMBER >= 0x1000005FL && !defined(OPENSSL_NO_ECDH)
442    {
443 <    const char *s;
443 >    EC_KEY *key = EC_KEY_new_by_curve_name(NID_X9_62_prime256v1);
444 >
445 >    if (key)
446 >    {
447 >      SSL_CTX_set_tmp_ecdh(ConfigServerInfo.server_ctx, key);
448 >      EC_KEY_free(key);
449 >    }
450 >  }
451  
452 <    fprintf(stderr, "ERROR: Could not initialize the SSL Client context -- %s\n",
453 <            s = ERR_lib_error_string(ERR_get_error()));
452 >  SSL_CTX_set_options(ConfigServerInfo.server_ctx, SSL_OP_SINGLE_ECDH_USE);
453 > #endif
454 >
455 >  if ((ConfigServerInfo.client_ctx = SSL_CTX_new(SSLv23_client_method())) == NULL)
456 >  {
457 >    const char *s = ERR_lib_error_string(ERR_get_error());
458 >
459 >    fprintf(stderr, "ERROR: Could not initialize the SSL Client context -- %s\n", s);
460      ilog(LOG_TYPE_IRCD, "ERROR: Could not initialize the SSL Client context -- %s\n", s);
461 +    exit(EXIT_FAILURE);
462    }
463  
464 <  SSL_CTX_set_options(ServerInfo.client_ctx, SSL_OP_NO_SSLv2|SSL_OP_NO_SSLv3|SSL_OP_NO_TLSv1);
465 <  SSL_CTX_set_options(ServerInfo.client_ctx, SSL_OP_TLS_ROLLBACK_BUG|SSL_OP_ALL);
466 <  SSL_CTX_set_verify(ServerInfo.client_ctx, SSL_VERIFY_PEER|SSL_VERIFY_CLIENT_ONCE,
464 >  SSL_CTX_set_options(ConfigServerInfo.client_ctx, SSL_OP_NO_SSLv2|SSL_OP_NO_SSLv3);
465 >  SSL_CTX_set_options(ConfigServerInfo.client_ctx, SSL_OP_SINGLE_DH_USE);
466 >  SSL_CTX_set_verify(ConfigServerInfo.client_ctx, SSL_VERIFY_PEER|SSL_VERIFY_CLIENT_ONCE,
467                       always_accept_verify_cb);
468   #endif /* HAVE_LIBCRYPTO */
469   }
# Line 463 | Line 474 | main(int argc, char *argv[])
474    /* Check to see if the user is running us as root, which is a nono */
475    if (geteuid() == 0)
476    {
477 <    fprintf(stderr, "Don't run ircd as root!!!\n");
477 >    fprintf(stderr, "ERROR: This server won't run as root/superuser\n");
478      return -1;
479    }
480  
# Line 479 | Line 490 | main(int argc, char *argv[])
490    me.localClient = &meLocalUser;
491    dlinkAdd(&me, &me.node, &global_client_list);  /* Pointer to beginning
492                                                     of Client list */
493 <  /* Initialise the channel capability usage counts... */
494 <  init_chcap_usage_counts();
495 <
496 <  ConfigFileEntry.dpath      = DPATH;
497 <  ConfigFileEntry.configfile = CPATH;    /* Server configuration file */
498 <  ConfigFileEntry.klinefile  = KPATH;    /* Server kline file         */
499 <  ConfigFileEntry.glinefile  = GPATH;    /* Server gline file         */
500 <  ConfigFileEntry.xlinefile  = XPATH;    /* Server xline file         */
501 <  ConfigFileEntry.dlinefile  = DLPATH;   /* dline file                */
502 <  ConfigFileEntry.resvfile   = RESVPATH; /* resv file                 */
493 >  ConfigLog.use_logging = 1;
494 >  ConfigGeneral.dpath      = DPATH;
495 >  ConfigGeneral.spath      = SPATH;
496 >  ConfigGeneral.mpath      = MPATH;
497 >  ConfigGeneral.configfile = CPATH;    /* Server configuration file */
498 >  ConfigGeneral.klinefile  = KPATH;    /* Server kline file         */
499 >  ConfigGeneral.glinefile  = GPATH;    /* Server gline file         */
500 >  ConfigGeneral.xlinefile  = XPATH;    /* Server xline file         */
501 >  ConfigGeneral.dlinefile  = DLPATH;   /* dline file                */
502 >  ConfigGeneral.resvfile   = RESVPATH; /* resv file                 */
503  
504    myargv = argv;
505    umask(077);                /* better safe than sorry --SRB */
# Line 501 | Line 512 | main(int argc, char *argv[])
512      exit(EXIT_SUCCESS);
513    }
514  
515 <  if (chdir(ConfigFileEntry.dpath))
515 >  if (chdir(ConfigGeneral.dpath))
516    {
517      perror("chdir");
518      exit(EXIT_FAILURE);
# Line 519 | Line 530 | main(int argc, char *argv[])
530  
531    setup_signals();
532  
522  /* Init the event subsystem */
523  eventInit();
524
533    /* We need this to initialise the fd array before anything else */
534    fdlist_init();
535    log_set_file(LOG_TYPE_IRCD, 0, logFileName);
536 <  check_can_use_v6();
536 >
537    init_netio();         /* This needs to be setup early ! -- adrian */
538  
539    /* Check if there is pidfile and daemon already running */
# Line 536 | Line 544 | main(int argc, char *argv[])
544    init_isupport();
545    dbuf_init();
546    hash_init();
547 <  init_ip_hash_table();      /* client host ip hash table */
547 >  ipcache_init();
548    init_host_hash();          /* Host-hashtable. */
549    client_init();
550    class_init();
# Line 556 | Line 564 | main(int argc, char *argv[])
564    geoip_ctx = GeoIP_new(GEOIP_MEMORY_CACHE);
565   #endif
566  
567 <  if (EmptyString(ServerInfo.sid))
567 >  if (EmptyString(ConfigServerInfo.sid))
568    {
569      ilog(LOG_TYPE_IRCD, "ERROR: No server id specified in serverinfo block.");
570      exit(EXIT_FAILURE);
571    }
572  
573 <  strlcpy(me.id, ServerInfo.sid, sizeof(me.id));
573 >  strlcpy(me.id, ConfigServerInfo.sid, sizeof(me.id));
574  
575 <  if (EmptyString(ServerInfo.name))
575 >  if (EmptyString(ConfigServerInfo.name))
576    {
577      ilog(LOG_TYPE_IRCD, "ERROR: No server name specified in serverinfo block.");
578      exit(EXIT_FAILURE);
579    }
580  
581 <  strlcpy(me.name, ServerInfo.name, sizeof(me.name));
581 >  strlcpy(me.name, ConfigServerInfo.name, sizeof(me.name));
582  
583    /* serverinfo{} description must exist.  If not, error out.*/
584 <  if (EmptyString(ServerInfo.description))
584 >  if (EmptyString(ConfigServerInfo.description))
585    {
586      ilog(LOG_TYPE_IRCD, "ERROR: No server description specified in serverinfo block.");
587      exit(EXIT_FAILURE);
588    }
589  
590 <  strlcpy(me.info, ServerInfo.description, sizeof(me.info));
590 >  strlcpy(me.info, ConfigServerInfo.description, sizeof(me.info));
591  
592    me.from                   = &me;
593    me.servptr                = &me;
# Line 593 | Line 601 | main(int argc, char *argv[])
601    hash_add_id(&me);
602    hash_add_client(&me);
603  
604 <  /* add ourselves to global_serv_list */
597 <  dlinkAdd(&me, make_dlink_node(), &global_serv_list);
604 >  dlinkAdd(&me, make_dlink_node(), &global_server_list);
605  
606    load_kline_database();
607    load_dline_database();
# Line 613 | Line 620 | main(int argc, char *argv[])
620    load_core_modules(1);
621  
622    /* Go back to DPATH after checking to see if we can chdir to MODPATH */
623 <  if (chdir(ConfigFileEntry.dpath))
623 >  if (chdir(ConfigGeneral.dpath))
624    {
625      perror("chdir");
626      exit(EXIT_FAILURE);
# Line 629 | Line 636 | main(int argc, char *argv[])
636  
637    ilog(LOG_TYPE_IRCD, "Server Ready");
638  
639 <  eventAddIsh("cleanup_glines", cleanup_glines, NULL, CLEANUP_GLINES_TIME);
640 <  eventAddIsh("cleanup_tklines", cleanup_tklines, NULL, CLEANUP_TKLINES_TIME);
639 >  event_addish(&event_cleanup_glines, NULL);
640 >  event_addish(&event_cleanup_tklines, NULL);
641  
642    /* We want try_connections to be called as soon as possible now! -- adrian */
643    /* No, 'cause after a restart it would cause all sorts of nick collides */
644 <  eventAddIsh("try_connections", try_connections, NULL, STARTUP_CONNECTIONS_TIME);
644 >  event_addish(&event_try_connections, NULL);
645  
646    /* Setup the timeout check. I'll shift it later :)  -- adrian */
647 <  eventAddIsh("comm_checktimeouts", comm_checktimeouts, NULL, 1);
647 >  event_add(&event_comm_checktimeouts, NULL);
648  
649 <  eventAddIsh("save_all_databases", save_all_databases, NULL, DATABASE_UPDATE_TIMEOUT);
649 >  event_addish(&event_save_all_databases, NULL);
650  
651    if (ConfigServerHide.links_delay > 0)
652 <    eventAddIsh("write_links_file", write_links_file, NULL, ConfigServerHide.links_delay);
652 >  {
653 >    event_write_links_file.when = ConfigServerHide.links_delay;
654 >    event_addish(&event_write_links_file, NULL);
655 >  }
656    else
657      ConfigServerHide.links_disabled = 1;
658  
659    if (splitmode)
660 <    eventAddIsh("check_splitmode", check_splitmode, NULL, 60);
660 >    event_addish(&splitmode_event, NULL);
661  
662    io_loop();
663    return 0;

Diff Legend

Removed lines
+ Added lines
< Changed lines (old)
> Changed lines (new)