diff options
author | danieldg <danieldg@e03df62e-2008-0410-955e-edbf42e46eb7> | 2009-10-18 17:58:41 +0000 |
---|---|---|
committer | danieldg <danieldg@e03df62e-2008-0410-955e-edbf42e46eb7> | 2009-10-18 17:58:41 +0000 |
commit | 4fca1ffbc43dd0eda8e6df665dac0fa83512daf8 (patch) | |
tree | 06787715deb971b657d4580394818dd02ea13fa6 /src/modules/m_spanningtree | |
parent | fa452641bf37077fcda964d59e404a76e1fb13e5 (diff) |
More classbase cleanup, hold ConfigTag reference in Autoconnect/Link
git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@11906 e03df62e-2008-0410-955e-edbf42e46eb7
Diffstat (limited to 'src/modules/m_spanningtree')
-rw-r--r-- | src/modules/m_spanningtree/link.h | 4 | ||||
-rw-r--r-- | src/modules/m_spanningtree/utils.cpp | 119 |
2 files changed, 43 insertions, 80 deletions
diff --git a/src/modules/m_spanningtree/link.h b/src/modules/m_spanningtree/link.h index ae7655ebb..484569892 100644 --- a/src/modules/m_spanningtree/link.h +++ b/src/modules/m_spanningtree/link.h @@ -17,6 +17,7 @@ class Link : public refcountbase { public: + reference<ConfigTag> tag; irc::string Name; std::string IPAddr; int Port; @@ -29,16 +30,19 @@ class Link : public refcountbase int Timeout; std::string Bind; bool Hidden; + Link(ConfigTag* Tag) : tag(tag) {} }; class Autoconnect : public refcountbase { public: + reference<ConfigTag> tag; std::vector<std::string> servers; unsigned long Period; time_t NextConnectTime; /** Negative == inactive */ int position; + Autoconnect(ConfigTag* Tag) : tag(tag) {} }; diff --git a/src/modules/m_spanningtree/utils.cpp b/src/modules/m_spanningtree/utils.cpp index c4d5755e6..b8560aaba 100644 --- a/src/modules/m_spanningtree/utils.cpp +++ b/src/modules/m_spanningtree/utils.cpp @@ -23,8 +23,6 @@ #include "treesocket.h" #include "resolvers.h" -/* $ModDep: m_spanningtree/resolvers.h m_spanningtree/main.h m_spanningtree/utils.h m_spanningtree/treeserver.h m_spanningtree/link.h m_spanningtree/treesocket.h */ - /* Create server sockets off a listener. */ void ServerSocketListener::OnAcceptReady(int newsock) { @@ -342,34 +340,19 @@ void SpanningTreeUtilities::RefreshIPCache() continue; } - ValidIPs.push_back(L->IPAddr); - if (L->AllowMask.length()) ValidIPs.push_back(L->AllowMask); - /* Needs resolving */ - bool ipvalid = true; - QueryType start_type = DNS_QUERY_A; - start_type = DNS_QUERY_AAAA; - if (strchr(L->IPAddr.c_str(),':')) - { - in6_addr n; - if (inet_pton(AF_INET6, L->IPAddr.c_str(), &n) < 1) - ipvalid = false; - } + irc::sockets::sockaddrs dummy; + bool ipvalid = irc::sockets::aptosa(L->IPAddr, L->Port, &dummy); + if (ipvalid) + ValidIPs.push_back(L->IPAddr); else { - in_addr n; - if (inet_aton(L->IPAddr.c_str(),&n) < 1) - ipvalid = false; - } - - if (!ipvalid) - { try { bool cached; - SecurityIPResolver* sr = new SecurityIPResolver(Creator, this, L->IPAddr, L, cached, start_type); + SecurityIPResolver* sr = new SecurityIPResolver(Creator, this, L->IPAddr, L, cached, DNS_QUERY_AAAA); ServerInstance->AddResolver(sr, cached); } catch (...) @@ -385,12 +368,15 @@ void SpanningTreeUtilities::ReadConfiguration(bool rebind) if (rebind) { - for (int j = 0; j < Conf.Enumerate("bind"); j++) + for (int j = 0; ; j++) { - std::string Type = Conf.ReadValue("bind","type",j); - std::string IP = Conf.ReadValue("bind","address",j); - std::string Port = Conf.ReadValue("bind","port",j); - std::string ssl = Conf.ReadValue("bind","ssl",j); + ConfigTag* tag = ServerInstance->Config->ConfValue("bind", j); + if (!tag) + break; + std::string Type = tag->getString("type"); + std::string IP = tag->getString("address"); + std::string Port = tag->getString("port"); + std::string ssl = tag->getString("ssl"); if (Type == "servers") { irc::portparser portrange(Port, false); @@ -431,22 +417,24 @@ void SpanningTreeUtilities::ReadConfiguration(bool rebind) AutoconnectBlocks.clear(); LinkBlocks.clear(); ValidIPs.clear(); - for (int j = 0; j < Conf.Enumerate("link"); ++j) + for (int j = 0;; ++j) { - reference<Link> L = new Link; - std::string Allow = Conf.ReadValue("link", "allowmask", j); - L->Name = (Conf.ReadValue("link", "name", j)).c_str(); - L->AllowMask = Allow; - L->IPAddr = Conf.ReadValue("link", "ipaddr", j); - L->Port = Conf.ReadInteger("link", "port", j, true); - L->SendPass = Conf.ReadValue("link", "sendpass", j); - L->RecvPass = Conf.ReadValue("link", "recvpass", j); - L->Fingerprint = Conf.ReadValue("link", "fingerprint", j); - L->HiddenFromStats = Conf.ReadFlag("link", "statshidden", j); - L->Timeout = Conf.ReadInteger("link", "timeout", j, true); - L->Hook = Conf.ReadValue("link", "ssl", j); - L->Bind = Conf.ReadValue("link", "bind", j); - L->Hidden = Conf.ReadFlag("link", "hidden", j); + ConfigTag* tag = ServerInstance->Config->ConfValue("link", j); + if (!tag) + break; + reference<Link> L = new Link(tag); + L->Name = tag->getString("name").c_str(); + L->AllowMask = tag->getString("allowmask"); + L->IPAddr = tag->getString("ipaddr"); + L->Port = tag->getInt("port"); + L->SendPass = tag->getString("sendpass"); + L->RecvPass = tag->getString("recvpass"); + L->Fingerprint = tag->getString("fingerprint"); + L->HiddenFromStats = tag->getBool("statshidden"); + L->Timeout = tag->getInt("timeout"); + L->Hook = tag->getString("ssl"); + L->Bind = tag->getString("bind"); + L->Hidden = tag->getBool("hidden"); if (L->Name.find('.') == std::string::npos) throw CoreException("The link name '"+assign(L->Name)+"' is invalid and must contain at least one '.' character"); @@ -456,40 +444,7 @@ void SpanningTreeUtilities::ReadConfiguration(bool rebind) if ((!L->IPAddr.empty()) && (!L->RecvPass.empty()) && (!L->SendPass.empty()) && (!L->Name.empty()) && (L->Port)) { - if (Allow.length()) - ValidIPs.push_back(Allow); - ValidIPs.push_back(L->IPAddr); - - /* Needs resolving */ - bool ipvalid = true; - QueryType start_type = DNS_QUERY_A; - start_type = DNS_QUERY_AAAA; - if (strchr(L->IPAddr.c_str(),':')) - { - in6_addr n; - if (inet_pton(AF_INET6, L->IPAddr.c_str(), &n) < 1) - ipvalid = false; - } - else - { - in_addr n; - if (inet_aton(L->IPAddr.c_str(),&n) < 1) - ipvalid = false; - } - - if (!ipvalid) - { - try - { - bool cached; - SecurityIPResolver* sr = new SecurityIPResolver(Creator, this, L->IPAddr, L, cached, start_type); - ServerInstance->AddResolver(sr, cached); - } - catch (...) - { - } - } } else { @@ -524,14 +479,16 @@ void SpanningTreeUtilities::ReadConfiguration(bool rebind) LinkBlocks.push_back(L); } - for (int j = 0; j < Conf.Enumerate("autoconnect"); ++j) + for (int j = 0;; ++j) { - reference<Autoconnect> A = new Autoconnect; - A->Period = Conf.ReadInteger("autoconnect", "period", j, true); + ConfigTag* tag = ServerInstance->Config->ConfValue("autoconnect", j); + if (!tag) + break; + reference<Autoconnect> A = new Autoconnect(tag); + A->Period = tag->getInt("period"); A->NextConnectTime = ServerInstance->Time() + A->Period; A->position = -1; - std::string servers = Conf.ReadValue("autoconnect", "server", j); - irc::spacesepstream ss(servers); + irc::spacesepstream ss(tag->getString("server")); std::string server; while (ss.GetToken(server)) { @@ -550,6 +507,8 @@ void SpanningTreeUtilities::ReadConfiguration(bool rebind) AutoconnectBlocks.push_back(A); } + + RefreshIPCache(); } Link* SpanningTreeUtilities::FindLink(const std::string& name) |