ircd: support restarting ssld processes

[solanum.git] / modules / m_rehash.c

diff --git a/modules/m_rehash.c b/modules/m_rehash.c
index 60d5a187adbffc0f086f050cd3400e332f3dd707..dae84c2c847f713817435dbd842314cc90bf9625 100644 (file)
--- a/modules/m_rehash.c
+++ b/modules/m_rehash.c
@@ -28,11 +28,10 @@
 #include "client.h"
 #include "channel.h"
 #include "common.h"
-#include "irc_string.h"
+#include "match.h"
 #include "ircd.h"
 #include "s_serv.h"
 #include "numeric.h"
-#include "res.h"
 #include "s_conf.h"
 #include "s_newconf.h"
 #include "logger.h"
@@ -44,6 +43,8 @@
 #include "reject.h"
 #include "hash.h"
 #include "cache.h"
+#include "irc_radixtree.h"
+#include "sslproc.h"
 
 static int mo_rehash(struct Client *, struct Client *, int, const char **);
 static int me_rehash(struct Client *, struct Client *, int, const char **);
@@ -67,6 +68,8 @@ rehash_bans_loc(struct Client *source_p)
 {
        sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is rehashing bans",
                                get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
        rehash_bans(0);
 }
@@ -74,11 +77,22 @@ rehash_bans_loc(struct Client *source_p)
 static void
 rehash_dns(struct Client *source_p)
 {
-       sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is rehashing DNS", 
+       sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is rehashing DNS",
                             get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
        /* reread /etc/resolv.conf and reopen res socket */
-       restart_resolver();
+       restart_authd();
+}
+
+static void
+rehash_ssld(struct Client *source_p)
+{
+       sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is restarting ssld",
+                               get_oper_name(source_p));
+
+       restart_ssld();
 }
 
 static void
@@ -87,9 +101,10 @@ rehash_motd(struct Client *source_p)
        sendto_realops_snomask(SNO_GENERAL, L_ALL,
                             "%s is forcing re-reading of MOTD file",
                             get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
-       free_cachefile(user_motd);
-       user_motd = cache_file(MPATH, "ircd.motd", 0);
+       cache_user_motd();
 }
 
 static void
@@ -98,6 +113,8 @@ rehash_omotd(struct Client *source_p)
        sendto_realops_snomask(SNO_GENERAL, L_ALL,
                             "%s is forcing re-reading of OPER MOTD file",
                             get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
        free_cachefile(oper_motd);
        oper_motd = cache_file(OPATH, "opers.motd", 0);
@@ -112,6 +129,8 @@ rehash_tklines(struct Client *source_p)
 
        sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is clearing temp klines",
                                get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
        for(i = 0; i < LAST_TEMP_TYPE; i++)
        {
@@ -134,6 +153,8 @@ rehash_tdlines(struct Client *source_p)
 
        sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is clearing temp dlines",
                                get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
        for(i = 0; i < LAST_TEMP_TYPE; i++)
        {
@@ -156,12 +177,14 @@ rehash_txlines(struct Client *source_p)
 
        sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is clearing temp xlines",
                                get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
        RB_DLINK_FOREACH_SAFE(ptr, next_ptr, xline_conf_list.head)
        {
                aconf = ptr->data;
 
-               if(!aconf->hold)
+               if(!aconf->hold || aconf->lifetime)
                        continue;
 
                free_conf(aconf);
@@ -173,30 +196,30 @@ static void
 rehash_tresvs(struct Client *source_p)
 {
        struct ConfItem *aconf;
+       struct irc_radixtree_iteration_state iter;
        rb_dlink_node *ptr;
        rb_dlink_node *next_ptr;
        int i;
 
        sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is clearing temp resvs",
                                get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
-       HASH_WALK_SAFE(i, R_MAX, ptr, next_ptr, resvTable)
+       IRC_RADIXTREE_FOREACH(aconf, &iter, resv_tree)
        {
-               aconf = ptr->data;
-
-               if(!aconf->hold)
+               if(!aconf->hold || aconf->lifetime)
                        continue;
 
+               irc_radixtree_delete(resv_tree, aconf->host);
                free_conf(aconf);
-               rb_dlinkDestroy(ptr, &resvTable[i]);
        }
-       HASH_WALK_END
 
        RB_DLINK_FOREACH_SAFE(ptr, next_ptr, resv_conf_list.head)
        {
                aconf = ptr->data;
 
-               if(!aconf->hold)
+               if(!aconf->hold || aconf->lifetime)
                        continue;
 
                free_conf(aconf);
@@ -209,16 +232,31 @@ rehash_rejectcache(struct Client *source_p)
 {
        sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is clearing reject cache",
                                get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
        flush_reject();
 
 }
 
+static void
+rehash_throttles(struct Client *source_p)
+{
+       sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s is clearing throttles",
+                               get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
+       flush_throttle();
+
+}
+
 static void
 rehash_help(struct Client *source_p)
 {
        sendto_realops_snomask(SNO_GENERAL, L_ALL,
-                            "%s is forcing re-reading of HELP files", 
+                            "%s is forcing re-reading of HELP files",
                             get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
        load_help();
 }
 
@@ -232,11 +270,13 @@ rehash_nickdelay(struct Client *source_p)
        sendto_realops_snomask(SNO_GENERAL, L_ALL,
                             "%s is clearing the nick delay table",
                             get_oper_name(source_p));
+       if (!MyConnect(source_p))
+               remote_rehash_oper_p = source_p;
 
        RB_DLINK_FOREACH_SAFE(ptr, safe_ptr, nd_list.head)
        {
                nd = ptr->data;
-       
+
                free_nd_entry(nd);
        }
 }
@@ -246,6 +286,7 @@ static struct hash_commands rehash_commands[] =
 {
        {"BANS",        rehash_bans_loc         },
        {"DNS",         rehash_dns              },
+       {"SSLD",        rehash_ssld             },
        {"MOTD",        rehash_motd             },
        {"OMOTD",       rehash_omotd            },
        {"TKLINES",     rehash_tklines          },
@@ -253,6 +294,7 @@ static struct hash_commands rehash_commands[] =
        {"TXLINES",     rehash_txlines          },
        {"TRESVS",      rehash_tresvs           },
        {"REJECTCACHE", rehash_rejectcache      },
+       {"THROTTLES",   rehash_throttles        },
        {"HELP",        rehash_help             },
        {"NICKDELAY",   rehash_nickdelay        },
        {NULL,          NULL                    }
@@ -274,9 +316,10 @@ do_rehash(struct Client *source_p, const char *type)
                        {
                                sendto_one(source_p, form_str(RPL_REHASHING), me.name,
                                           source_p->name, rehash_commands[x].cmd);
-                               rehash_commands[x].handler(source_p);
                                ilog(L_MAIN, "REHASH %s From %s[%s]", type,
                                     get_oper_name(source_p), source_p->sockhost);
+                               rehash_commands[x].handler(source_p);
+                               remote_rehash_oper_p = NULL;
                                return;
                        }
                }
@@ -286,8 +329,8 @@ do_rehash(struct Client *source_p, const char *type)
                for (x = 0; rehash_commands[x].cmd != NULL && rehash_commands[x].handler != NULL;
                     x++)
                {
-                       strlcat(cmdbuf, " ", sizeof(cmdbuf));
-                       strlcat(cmdbuf, rehash_commands[x].cmd, sizeof(cmdbuf));
+                       rb_strlcat(cmdbuf, " ", sizeof(cmdbuf));
+                       rb_strlcat(cmdbuf, rehash_commands[x].cmd, sizeof(cmdbuf));
                }
                sendto_one_notice(source_p, ":rehash one of:%s", cmdbuf);
        }
@@ -297,9 +340,12 @@ do_rehash(struct Client *source_p, const char *type)
                           ConfigFileEntry.configfile);
                sendto_realops_snomask(SNO_GENERAL, L_ALL,
                                     "%s is rehashing server config file", get_oper_name(source_p));
+               if (!MyConnect(source_p))
+                       remote_rehash_oper_p = source_p;
                ilog(L_MAIN, "REHASH From %s[%s]", get_oper_name(source_p),
                     source_p->sockhost);
                rehash(0);
+               remote_rehash_oper_p = NULL;
        }
 }