sugarlabs/sugar-toolkit-gtk3
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Retry connections when TP connection attempts fail

Browse Source
This commit is contained in:
Dan Williams 2007-05-24 16:40:14 -04:00
parent cb84d5f8fd
commit c1346a5303
1 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
services/presence/server_plugin.py
View File

@ -58,6 +58,7 @@ _OBJ_PATH_PREFIX = "/org/freedesktop/Telepathy/Connection/gabble/jabber/"
_logger = logging.getLogger('s-p-s.server_plugin') _logger = logging.getLogger('s-p-s.server_plugin')
_RECONNECT_TIMEOUT = 5000
def _buddy_icon_save_cb(buf, data): def _buddy_icon_save_cb(buf, data):
data[0] += buf data[0] += buf
@ -349,6 +350,9 @@ class ServerPlugin(gobject.GObject):
_logger.debug('Connect() succeeded') _logger.debug('Connect() succeeded')
def connect_error(e): def connect_error(e):
_logger.debug('Connect() failed: %s', e) _logger.debug('Connect() failed: %s', e)
if not self._reconnect_id:
self._reconnect_id = gobject.timeout_add(_RECONNECT_TIMEOUT,
self._reconnect_cb)
self._conn[CONN_INTERFACE].Connect(reply_handler=connect_reply, self._conn[CONN_INTERFACE].Connect(reply_handler=connect_reply,
error_handler=connect_error) error_handler=connect_error)
@ -648,15 +652,9 @@ class ServerPlugin(gobject.GObject):
return handle return handle
return None return None
def _start_helper(self):
"""Helper so start() doesn't have to return False"""
self.start()
return False
def _reconnect_cb(self): def _reconnect_cb(self):
"""Schedule a reconnection attempt""" """Attempt to reconnect to the server"""
gobject.idle_add(self._start_helper) self.start()
self._reconnect_id = 0
return False return False
def _handle_connection_status_change(self, status, reason): def _handle_connection_status_change(self, status, reason):
@ -684,8 +682,8 @@ class ServerPlugin(gobject.GObject):
# If disconnected and no network connection, do nothing here # If disconnected and no network connection, do nothing here
# and let the IP4AddressMonitor address-changed signal handle # and let the IP4AddressMonitor address-changed signal handle
# reconnection # reconnection
if self._ip4am.props.address: if self._ip4am.props.address and not self._reconnect_id:
self._reconnect_id = gobject.timeout_add(5000, self._reconnect_id = gobject.timeout_add(_RECONNECT_TIMEOUT,
self._reconnect_cb) self._reconnect_cb)
self.emit('status', self._conn_status, int(reason)) self.emit('status', self._conn_status, int(reason))