From 6ca201d0b48f4273e24dd7bff17c4a46eeaddf39 Mon Sep 17 00:00:00 2001 From: Tobias Markmann Date: Tue, 21 Jul 2015 18:30:15 +0200 Subject: Explicitly disconnect from remaining resources in destructors Explicitly disconnect from remaining resources in the ChainedConnected and ClientSessionStanzaChannel destructors, so the event loop will not call the signal handler methods on a freed object. Test-Information: Repeating the test case of creating a Swift::Client instance, connecting it and then deleting it after a random time below one second. On Mac OS X 10.9.5 running this test case causes two ASAN heap-use-after-free errors and with this patch the errors are gone. Change-Id: I3e48150c3633f4076ca9172aad9e85ba389df950 diff --git a/Swiften/Client/ClientSessionStanzaChannel.cpp b/Swiften/Client/ClientSessionStanzaChannel.cpp index 3d7b9f7..3dc8c59 100644 --- a/Swiften/Client/ClientSessionStanzaChannel.cpp +++ b/Swiften/Client/ClientSessionStanzaChannel.cpp @@ -1,16 +1,27 @@ /* - * Copyright (c) 2010 Isode Limited. + * Copyright (c) 2010-2015 Isode Limited. * All rights reserved. * See the COPYING file for more information. */ #include -#include #include +#include + namespace Swift { +ClientSessionStanzaChannel::~ClientSessionStanzaChannel() { + if (session) { + session->onFinished.disconnect(boost::bind(&ClientSessionStanzaChannel::handleSessionFinished, this, _1)); + session->onStanzaReceived.disconnect(boost::bind(&ClientSessionStanzaChannel::handleStanza, this, _1)); + session->onStanzaAcked.disconnect(boost::bind(&ClientSessionStanzaChannel::handleStanzaAcked, this, _1)); + session->onInitialized.disconnect(boost::bind(&ClientSessionStanzaChannel::handleSessionInitialized, this)); + session.reset(); + } +} + void ClientSessionStanzaChannel::setSession(boost::shared_ptr session) { assert(!this->session); this->session = session; diff --git a/Swiften/Client/ClientSessionStanzaChannel.h b/Swiften/Client/ClientSessionStanzaChannel.h index 1104416..0ffcd9d 100644 --- a/Swiften/Client/ClientSessionStanzaChannel.h +++ b/Swiften/Client/ClientSessionStanzaChannel.h @@ -12,8 +12,8 @@ #include #include #include -#include #include +#include #include namespace Swift { @@ -22,6 +22,8 @@ namespace Swift { */ class SWIFTEN_API ClientSessionStanzaChannel : public StanzaChannel { public: + virtual ~ClientSessionStanzaChannel(); + void setSession(boost::shared_ptr session); void sendIQ(boost::shared_ptr iq); diff --git a/Swiften/Network/ChainedConnector.cpp b/Swiften/Network/ChainedConnector.cpp index ac48d20..3cc4057 100644 --- a/Swiften/Network/ChainedConnector.cpp +++ b/Swiften/Network/ChainedConnector.cpp @@ -1,18 +1,19 @@ /* - * Copyright (c) 2011 Isode Limited. + * Copyright (c) 2011-2015 Isode Limited. * All rights reserved. * See the COPYING file for more information. */ #include -#include #include +#include + #include #include -#include #include +#include using namespace Swift; @@ -32,6 +33,14 @@ ChainedConnector::ChainedConnector( timeoutMilliseconds(0) { } +ChainedConnector::~ChainedConnector() { + if (currentConnector) { + currentConnector->onConnectFinished.disconnect(boost::bind(&ChainedConnector::handleConnectorFinished, this, _1, _2)); + currentConnector->stop(); + currentConnector.reset(); + } +} + void ChainedConnector::setTimeoutMilliseconds(int milliseconds) { timeoutMilliseconds = milliseconds; } diff --git a/Swiften/Network/ChainedConnector.h b/Swiften/Network/ChainedConnector.h index 77fa6fd..9bcc961 100644 --- a/Swiften/Network/ChainedConnector.h +++ b/Swiften/Network/ChainedConnector.h @@ -1,20 +1,21 @@ /* - * Copyright (c) 2011 Isode Limited. + * Copyright (c) 2011-2015 Isode Limited. * All rights reserved. * See the COPYING file for more information. */ #pragma once +#include #include #include -#include -#include + #include +#include #include -#include #include +#include namespace Swift { class Connection; @@ -26,6 +27,7 @@ namespace Swift { class SWIFTEN_API ChainedConnector { public: ChainedConnector(const std::string& hostname, int port, const boost::optional& serviceLookupPrefix, DomainNameResolver*, const std::vector&, TimerFactory*); + ~ChainedConnector(); void setTimeoutMilliseconds(int milliseconds); void start(); -- cgit v0.10.2-6-g49f6