From c16167025c379ede4f4fe5dcfbf5cfad99ec29b9 Mon Sep 17 00:00:00 2001 From: Dimitur Kirov Date: Mon, 20 Mar 2006 22:09:16 +0000 Subject: [PATCH] disconnect pending proxy resolve actions when account is disconnected from server --- src/common/connection.py | 2 ++ src/common/proxy65_manager.py | 24 ++++++++++++++++-------- 2 files changed, 18 insertions(+), 8 deletions(-) diff --git a/src/common/connection.py b/src/common/connection.py index 7cff6c434..c17e2a617 100644 --- a/src/common/connection.py +++ b/src/common/connection.py @@ -138,6 +138,7 @@ class Connection(ConnectionHandlers): self.old_show = STATUS_LIST[self.connected] self.connected = 0 self.dispatch('STATUS', 'offline') + gajim.proxy65_manager.disconnect(self.connection) self.connection = None if not self.on_purpose: if gajim.config.get_per('accounts', self.name, 'autoreconnect'): @@ -561,6 +562,7 @@ class Connection(ConnectionHandlers): def _on_disconnected(self): ''' called when a disconnect request has completed successfully''' self.dispatch('STATUS', 'offline') + gajim.proxy65_manager.disconnect(self.connection) self.connection = None def get_status(self): diff --git a/src/common/proxy65_manager.py b/src/common/proxy65_manager.py index 12e94c9ea..37387def9 100644 --- a/src/common/proxy65_manager.py +++ b/src/common/proxy65_manager.py @@ -54,8 +54,8 @@ class Proxy65Manager: # resolving this proxy is already started or completed return - def diconnect(self, connection): - for resolver in self.proxies: + def disconnect(self, connection): + for resolver in self.proxies.values(): resolver.disconnect(connection) def resolve_result(self, proxy, query): @@ -103,8 +103,11 @@ class ProxyResolver: query.setAttr('sid', self.sid) activate = query.setTag('activate') # activate.setData(self.jid + "/" + self.sid) - self.active_connection.send(iq) - self.state = S_ACTIVATED + if self.active_connection: + self.active_connection.send(iq) + self.state = S_ACTIVATED + else: + self.state = S_INITIAL def keep_conf(self): self.state = S_FINISHED @@ -119,11 +122,15 @@ class ProxyResolver: if self.host_tester: self.host_tester.disconnect() self.host_tester = None - if self.connections.has_key(connection): + try: self.connections.remove(connection) - if self.state == S_STARTED: - self.state = S_INITIAL - self.try_next_connection() + except ValueError: + pass + if self.state != S_FINISHED and connection == \ + self.active_connection: + self.active_connection = None + self.state = S_INITIAL + self.try_next_connection() def try_next_connection(self): ''' try to resolve proxy with the next possible connection ''' @@ -149,6 +156,7 @@ class ProxyResolver: def __init__(self, proxy): self.proxy = proxy self.state = S_INITIAL + self.active_connection = None self.connections = [] self.host_tester = None self.jid = None