1 files changed, 59 insertions, 11 deletions
diff --git a/Swiften/FileTransfer/SOCKS5BytestreamProxiesManager.cpp b/Swiften/FileTransfer/SOCKS5BytestreamProxiesManager.cpp
index 2956ff7..1036e12 100644
--- a/Swiften/FileTransfer/SOCKS5BytestreamProxiesManager.cpp
+++ b/Swiften/FileTransfer/SOCKS5BytestreamProxiesManager.cpp
@@ -33,10 +33,17 @@ SOCKS5BytestreamProxiesManager::SOCKS5BytestreamProxiesManager(ConnectionFactory
 SOCKS5BytestreamProxiesManager::~SOCKS5BytestreamProxiesManager() {
        if (proxyFinder_) {
                proxyFinder_->stop();
        }
+        foreach (const ProxySessionsMap::value_type& sessionsForID, proxySessions_) {
+                foreach (const ProxyJIDClientSessionVector::value_type& session, sessionsForID.second) {
+                        session.second->onSessionReady.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionReady, this,sessionsForID.first, session.first, session.second, _1));
+                        session.second->onFinished.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, sessionsForID.first, session.first, session.second, _1));
+                }
+        }
 }
 void SOCKS5BytestreamProxiesManager::addS5BProxy(S5BProxyRequest::ref proxy) {
        if (proxy) {
                SWIFT_LOG_ASSERT(HostAddress(proxy->getStreamHost().get().host).isValid(), warning) << std::endl;
@@ -54,20 +61,23 @@ const boost::optional<std::vector<S5BProxyRequest::ref> >& SOCKS5BytestreamProxi
        return localS5BProxies_;
 }
 void SOCKS5BytestreamProxiesManager::connectToProxies(const std::string& sessionID) {
        SWIFT_LOG(debug) << "session ID: " << sessionID << std::endl;
-        ProxyJIDClientSessionMap clientSessions;
+        ProxyJIDClientSessionVector clientSessions;
        if (localS5BProxies_) {
                foreach(S5BProxyRequest::ref proxy, localS5BProxies_.get()) {
                        boost::shared_ptr<Connection> conn = connectionFactory_->createConnection();
                        HostAddressPort addressPort = HostAddressPort(proxy->getStreamHost().get().host, proxy->getStreamHost().get().port);
                        SWIFT_LOG_ASSERT(addressPort.isValid(), warning) << std::endl;
                        boost::shared_ptr<SOCKS5BytestreamClientSession> session = boost::make_shared<SOCKS5BytestreamClientSession>(conn, addressPort, sessionID, timerFactory_);
-                        clientSessions[proxy->getStreamHost().get().jid] = session;
+                        JID proxyJid = proxy->getStreamHost().get().jid;
+                        clientSessions.push_back(std::pair<JID, boost::shared_ptr<SOCKS5BytestreamClientSession> >(proxyJid, session));
+                        session->onSessionReady.connect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionReady, this,sessionID, proxyJid, session, _1));
+                        session->onFinished.connect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, sessionID, proxyJid, session, _1));
                        session->start();
                }
        }
        proxySessions_[sessionID] = clientSessions;
@@ -76,21 +86,22 @@ void SOCKS5BytestreamProxiesManager::connectToProxies(const std::string& session
 boost::shared_ptr<SOCKS5BytestreamClientSession> SOCKS5BytestreamProxiesManager::getProxySessionAndCloseOthers(const JID& proxyJID, const std::string& sessionID) {
        // checking parameters
        if (proxySessions_.find(sessionID) == proxySessions_.end()) {
                return boost::shared_ptr<SOCKS5BytestreamClientSession>();
        }
-        if (proxySessions_[sessionID].find(proxyJID) == proxySessions_[sessionID].end()) {
-                return boost::shared_ptr<SOCKS5BytestreamClientSession>();
-        }
        // get active session
-        boost::shared_ptr<SOCKS5BytestreamClientSession> activeSession = proxySessions_[sessionID][proxyJID];
+        boost::shared_ptr<SOCKS5BytestreamClientSession> activeSession;
-        proxySessions_[sessionID].erase(proxyJID);
+        for (ProxyJIDClientSessionVector::iterator i = proxySessions_[sessionID].begin(); i != proxySessions_[sessionID].end(); i++) {
+                i->second->onSessionReady.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionReady, this,sessionID, proxyJID, i->second, _1));
-        // close other sessions
+                i->second->onFinished.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, sessionID, proxyJID, i->second, _1));
-        foreach(const ProxyJIDClientSessionMap::value_type& myPair, proxySessions_[sessionID]) {
+                if (i->first == proxyJID && !activeSession) {
-                myPair.second->stop();
+                        activeSession = i->second;
+                }
+                else {
+                        i->second->stop();
+                }
        }
        proxySessions_.erase(sessionID);
        return activeSession;
@@ -148,6 +159,43 @@ void SOCKS5BytestreamProxiesManager::queryForProxies() {
        proxyFinder_->onProxyFound.connect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxyFound, this, _1));
        proxyFinder_->start();
 }
+void SOCKS5BytestreamProxiesManager::handleProxySessionReady(const std::string& sessionID, const JID& jid, boost::shared_ptr<SOCKS5BytestreamClientSession> session, bool error) {
+        session->onSessionReady.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, boost::cref(sessionID), boost::cref(jid), session, _1));
+        if (!error) {
+                // The SOCKS5 bytestream session to the proxy succeeded; stop and remove other sessions.
+                if (proxySessions_.find(sessionID) != proxySessions_.end()) {
+                        for (ProxyJIDClientSessionVector::iterator i = proxySessions_[sessionID].begin(); i != proxySessions_[sessionID].end();) {
+                                if ((i->first == jid) && (i->second != session)) {
+                                        i->second->stop();
+                                        i = proxySessions_[sessionID].erase(i);
+                                }
+                                else {
+                                        i++;
+                                }
+                        }
+                }
+        }
+}
+void SOCKS5BytestreamProxiesManager::handleProxySessionFinished(const std::string& sessionID, const JID& jid, boost::shared_ptr<SOCKS5BytestreamClientSession> session, boost::optional<FileTransferError> error) {
+        session->onFinished.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, sessionID, jid, session, _1));
+        if (error.is_initialized()) {
+                // The SOCKS5 bytestream session to the proxy failed; remove it.
+                if (proxySessions_.find(sessionID) != proxySessions_.end()) {
+                        for (ProxyJIDClientSessionVector::iterator i = proxySessions_[sessionID].begin(); i != proxySessions_[sessionID].end();) {
+                                if ((i->first == jid) && (i->second == session)) {
+                                        i->second->stop();
+                                        i = proxySessions_[sessionID].erase(i);
+                                        break;
+                                }
+                                else {
+                                        i++;
+                                }
+                        }
+                }
+        }
+}
 }

diff --git a/Swiften/FileTransfer/SOCKS5BytestreamProxiesManager.cpp b/Swiften/FileTransfer/SOCKS5BytestreamProxiesManager.cpp index 2956ff7..1036e12 100644 --- a/Swiften/FileTransfer/SOCKS5BytestreamProxiesManager.cpp +++ b/Swiften/FileTransfer/SOCKS5BytestreamProxiesManager.cpp
@@ -33,10 +33,17 @@ SOCKS5BytestreamProxiesManager::SOCKS5BytestreamProxiesManager(ConnectionFactory
33		33
34	SOCKS5BytestreamProxiesManager::~SOCKS5BytestreamProxiesManager() {	34	SOCKS5BytestreamProxiesManager::~SOCKS5BytestreamProxiesManager() {
35	if (proxyFinder_) {	35	if (proxyFinder_) {
36	proxyFinder_->stop();	36	proxyFinder_->stop();
37	}	37	}
		38
		39	foreach (const ProxySessionsMap::value_type& sessionsForID, proxySessions_) {
		40	foreach (const ProxyJIDClientSessionVector::value_type& session, sessionsForID.second) {
		41	session.second->onSessionReady.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionReady, this,sessionsForID.first, session.first, session.second, _1));
		42	session.second->onFinished.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, sessionsForID.first, session.first, session.second, _1));
		43	}
		44	}
38	}	45	}
39		46
40	void SOCKS5BytestreamProxiesManager::addS5BProxy(S5BProxyRequest::ref proxy) {	47	void SOCKS5BytestreamProxiesManager::addS5BProxy(S5BProxyRequest::ref proxy) {
41	if (proxy) {	48	if (proxy) {
42	SWIFT_LOG_ASSERT(HostAddress(proxy->getStreamHost().get().host).isValid(), warning) << std::endl;	49	SWIFT_LOG_ASSERT(HostAddress(proxy->getStreamHost().get().host).isValid(), warning) << std::endl;
@@ -54,20 +61,23 @@ const boost::optional<std::vector<S5BProxyRequest::ref> >& SOCKS5BytestreamProxi
54	return localS5BProxies_;	61	return localS5BProxies_;
55	}	62	}
56		63
57	void SOCKS5BytestreamProxiesManager::connectToProxies(const std::string& sessionID) {	64	void SOCKS5BytestreamProxiesManager::connectToProxies(const std::string& sessionID) {
58	SWIFT_LOG(debug) << "session ID: " << sessionID << std::endl;	65	SWIFT_LOG(debug) << "session ID: " << sessionID << std::endl;
59	ProxyJIDClientSessionMap clientSessions;	66	ProxyJIDClientSessionVector clientSessions;
60		67
61	if (localS5BProxies_) {	68	if (localS5BProxies_) {
62	foreach(S5BProxyRequest::ref proxy, localS5BProxies_.get()) {	69	foreach(S5BProxyRequest::ref proxy, localS5BProxies_.get()) {
63	boost::shared_ptr<Connection> conn = connectionFactory_->createConnection();	70	boost::shared_ptr<Connection> conn = connectionFactory_->createConnection();
64		71
65	HostAddressPort addressPort = HostAddressPort(proxy->getStreamHost().get().host, proxy->getStreamHost().get().port);	72	HostAddressPort addressPort = HostAddressPort(proxy->getStreamHost().get().host, proxy->getStreamHost().get().port);
66	SWIFT_LOG_ASSERT(addressPort.isValid(), warning) << std::endl;	73	SWIFT_LOG_ASSERT(addressPort.isValid(), warning) << std::endl;
67	boost::shared_ptr<SOCKS5BytestreamClientSession> session = boost::make_shared<SOCKS5BytestreamClientSession>(conn, addressPort, sessionID, timerFactory_);	74	boost::shared_ptr<SOCKS5BytestreamClientSession> session = boost::make_shared<SOCKS5BytestreamClientSession>(conn, addressPort, sessionID, timerFactory_);
68	clientSessions[proxy->getStreamHost().get().jid] = session;	75	JID proxyJid = proxy->getStreamHost().get().jid;
		76	clientSessions.push_back(std::pair<JID, boost::shared_ptr<SOCKS5BytestreamClientSession> >(proxyJid, session));
		77	session->onSessionReady.connect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionReady, this,sessionID, proxyJid, session, _1));
		78	session->onFinished.connect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, sessionID, proxyJid, session, _1));
69	session->start();	79	session->start();
70	}	80	}
71	}	81	}
72		82
73	proxySessions_[sessionID] = clientSessions;	83	proxySessions_[sessionID] = clientSessions;
@@ -76,21 +86,22 @@ void SOCKS5BytestreamProxiesManager::connectToProxies(const std::string& session
76	boost::shared_ptr<SOCKS5BytestreamClientSession> SOCKS5BytestreamProxiesManager::getProxySessionAndCloseOthers(const JID& proxyJID, const std::string& sessionID) {	86	boost::shared_ptr<SOCKS5BytestreamClientSession> SOCKS5BytestreamProxiesManager::getProxySessionAndCloseOthers(const JID& proxyJID, const std::string& sessionID) {
77	// checking parameters	87	// checking parameters
78	if (proxySessions_.find(sessionID) == proxySessions_.end()) {	88	if (proxySessions_.find(sessionID) == proxySessions_.end()) {
79	return boost::shared_ptr<SOCKS5BytestreamClientSession>();	89	return boost::shared_ptr<SOCKS5BytestreamClientSession>();
80	}	90	}
81	if (proxySessions_[sessionID].find(proxyJID) == proxySessions_[sessionID].end()) {
82	return boost::shared_ptr<SOCKS5BytestreamClientSession>();
83	}
84		91
85	// get active session	92	// get active session
86	boost::shared_ptr<SOCKS5BytestreamClientSession> activeSession = proxySessions_[sessionID][proxyJID];	93	boost::shared_ptr<SOCKS5BytestreamClientSession> activeSession;
87	proxySessions_[sessionID].erase(proxyJID);	94	for (ProxyJIDClientSessionVector::iterator i = proxySessions_[sessionID].begin(); i != proxySessions_[sessionID].end(); i++) {
88		95	i->second->onSessionReady.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionReady, this,sessionID, proxyJID, i->second, _1));
89	// close other sessions	96	i->second->onFinished.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, sessionID, proxyJID, i->second, _1));
90	foreach(const ProxyJIDClientSessionMap::value_type& myPair, proxySessions_[sessionID]) {	97	if (i->first == proxyJID && !activeSession) {
91	myPair.second->stop();	98	activeSession = i->second;
		99	}
		100	else {
		101	i->second->stop();
		102	}
92	}	103	}
93		104
94	proxySessions_.erase(sessionID);	105	proxySessions_.erase(sessionID);
95		106
96	return activeSession;	107	return activeSession;
@@ -148,6 +159,43 @@ void SOCKS5BytestreamProxiesManager::queryForProxies() {
148		159
149	proxyFinder_->onProxyFound.connect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxyFound, this, _1));	160	proxyFinder_->onProxyFound.connect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxyFound, this, _1));
150	proxyFinder_->start();	161	proxyFinder_->start();
151	}	162	}
152		163
		164	void SOCKS5BytestreamProxiesManager::handleProxySessionReady(const std::string& sessionID, const JID& jid, boost::shared_ptr<SOCKS5BytestreamClientSession> session, bool error) {
		165	session->onSessionReady.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, boost::cref(sessionID), boost::cref(jid), session, _1));
		166	if (!error) {
		167	// The SOCKS5 bytestream session to the proxy succeeded; stop and remove other sessions.
		168	if (proxySessions_.find(sessionID) != proxySessions_.end()) {
		169	for (ProxyJIDClientSessionVector::iterator i = proxySessions_[sessionID].begin(); i != proxySessions_[sessionID].end();) {
		170	if ((i->first == jid) && (i->second != session)) {
		171	i->second->stop();
		172	i = proxySessions_[sessionID].erase(i);
		173	}
		174	else {
		175	i++;
		176	}
		177	}
		178	}
		179	}
		180	}
		181
		182	void SOCKS5BytestreamProxiesManager::handleProxySessionFinished(const std::string& sessionID, const JID& jid, boost::shared_ptr<SOCKS5BytestreamClientSession> session, boost::optional<FileTransferError> error) {
		183	session->onFinished.disconnect(boost::bind(&SOCKS5BytestreamProxiesManager::handleProxySessionFinished, this, sessionID, jid, session, _1));
		184	if (error.is_initialized()) {
		185	// The SOCKS5 bytestream session to the proxy failed; remove it.
		186	if (proxySessions_.find(sessionID) != proxySessions_.end()) {
		187	for (ProxyJIDClientSessionVector::iterator i = proxySessions_[sessionID].begin(); i != proxySessions_[sessionID].end();) {
		188	if ((i->first == jid) && (i->second == session)) {
		189	i->second->stop();
		190	i = proxySessions_[sessionID].erase(i);
		191	break;
		192	}
		193	else {
		194	i++;
		195	}
		196	}
		197	}
		198	}
		199	}
		200
153	}	201	}