summaryrefslogtreecommitdiff
path: root/louloulibs/network/dns_handler.cpp
diff options
context:
space:
mode:
authorlouiz’ <louiz@louiz.org>2016-07-28 10:34:01 +0200
committerlouiz’ <louiz@louiz.org>2016-07-28 10:34:01 +0200
commit11a1c0cc99af9629302184fac2b7adf3ac48516b (patch)
tree6d85e7ca57a110eff3678e8e37626f2052d6fc02 /louloulibs/network/dns_handler.cpp
parentde0eff6e944db11ae3552e0cd2c191997eebaa2f (diff)
downloadbiboumi-11a1c0cc99af9629302184fac2b7adf3ac48516b.tar.gz
biboumi-11a1c0cc99af9629302184fac2b7adf3ac48516b.tar.bz2
biboumi-11a1c0cc99af9629302184fac2b7adf3ac48516b.tar.xz
biboumi-11a1c0cc99af9629302184fac2b7adf3ac48516b.zip
Always remove all the DNS sockets on an c-ares event
Because c-ares may close one of its socket, even if it’s not the one that has the event. Otherwise we may not know when a socket has been removed from our poller (automatically, when close()ed) and this leads to bugs.
Diffstat (limited to 'louloulibs/network/dns_handler.cpp')
-rw-r--r--louloulibs/network/dns_handler.cpp11
1 files changed, 10 insertions, 1 deletions
diff --git a/louloulibs/network/dns_handler.cpp b/louloulibs/network/dns_handler.cpp
index 5e19f8c..e267944 100644
--- a/louloulibs/network/dns_handler.cpp
+++ b/louloulibs/network/dns_handler.cpp
@@ -37,6 +37,7 @@ ares_channel& DNSHandler::get_channel()
void DNSHandler::destroy()
{
+ this->remove_all_sockets_from_poller();
this->socket_handlers.clear();
::ares_destroy(this->channel);
::ares_library_cleanup();
@@ -95,7 +96,7 @@ void DNSHandler::watch_dns_sockets(std::shared_ptr<Poller>& poller)
if (it == this->socket_handlers.end())
{
this->socket_handlers.emplace(this->socket_handlers.begin(),
- std::make_unique<DNSSocketHandler>(poller, i));
+ std::make_unique<DNSSocketHandler>(poller, *this, i));
it = this->socket_handlers.begin();
}
poller->add_socket_handler(it->get());
@@ -122,4 +123,12 @@ void DNSHandler::watch_dns_sockets(std::shared_ptr<Poller>& poller)
}
}
+void DNSHandler::remove_all_sockets_from_poller()
+{
+ for (const auto& socket_handler: this->socket_handlers)
+ {
+ socket_handler->remove_from_poller();
+ }
+}
+
#endif /* CARES_FOUND */