Skip to content
Snippets Groups Projects
Commit 69fe399d authored by Adrien Béraud's avatar Adrien Béraud
Browse files

proxy server: cancelListen on destroy

parent a60dde2e
Branches
Tags
No related merge requests found
...@@ -273,6 +273,25 @@ DhtProxyServer::io_context() const ...@@ -273,6 +273,25 @@ DhtProxyServer::io_context() const
DhtProxyServer::~DhtProxyServer() DhtProxyServer::~DhtProxyServer()
{ {
if (dht_) {
std::lock_guard<std::mutex> lock(lockListener_);
for (auto& l : listeners_) {
dht_->cancelListen(l.second.hash, std::move(l.second.token));
if (l.second.response)
l.second.response->done();
}
for (auto& lm: pushListeners_) {
for (auto& ls: lm.second.listeners)
for (auto& l : ls.second) {
if (l.expireNotifyTimer)
l.expireNotifyTimer->cancel();
if (l.expireTimer)
l.expireTimer->cancel();
dht_->cancelListen(ls.first, std::move(l.internalToken));
}
}
pushListeners_.clear();
}
if (logger_) if (logger_)
logger_->d("[proxy:server] closing http server"); logger_->d("[proxy:server] closing http server");
if (httpServer_) if (httpServer_)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment