parent
94488fa2ea
commit
098714b3c4
@ -95,7 +95,7 @@ class ClientXMPP(BaseXMPP):
|
|||||||
self.bound = False
|
self.bound = False
|
||||||
self.bindfail = False
|
self.bindfail = False
|
||||||
|
|
||||||
self.add_event_handler('connected', self._handle_connected)
|
self.add_event_handler('connected', self._reset_connection_state)
|
||||||
self.add_event_handler('session_bind', self._handle_session_bind)
|
self.add_event_handler('session_bind', self._handle_session_bind)
|
||||||
|
|
||||||
self.register_stanza(StreamFeatures)
|
self.register_stanza(StreamFeatures)
|
||||||
@ -253,7 +253,7 @@ class ClientXMPP(BaseXMPP):
|
|||||||
self._handle_roster(response)
|
self._handle_roster(response)
|
||||||
return response
|
return response
|
||||||
|
|
||||||
def _handle_connected(self, event=None):
|
def _reset_connection_state(self, event=None):
|
||||||
#TODO: Use stream state here
|
#TODO: Use stream state here
|
||||||
self.authenticated = False
|
self.authenticated = False
|
||||||
self.sessionstarted = False
|
self.sessionstarted = False
|
||||||
|
@ -335,7 +335,7 @@ class XMLStream(object):
|
|||||||
#: ``_xmpp-client._tcp`` service.
|
#: ``_xmpp-client._tcp`` service.
|
||||||
self.dns_service = None
|
self.dns_service = None
|
||||||
|
|
||||||
self.add_event_handler('connected', self._handle_connected)
|
self.add_event_handler('connected', self._session_timeout_check)
|
||||||
self.add_event_handler('disconnected', self._remove_schedules)
|
self.add_event_handler('disconnected', self._remove_schedules)
|
||||||
self.add_event_handler('session_start', self._start_keepalive)
|
self.add_event_handler('session_start', self._start_keepalive)
|
||||||
self.add_event_handler('session_start', self._cert_expiration)
|
self.add_event_handler('session_start', self._cert_expiration)
|
||||||
@ -630,7 +630,7 @@ class XMLStream(object):
|
|||||||
serr.errno, serr.strerror)
|
serr.errno, serr.strerror)
|
||||||
return False
|
return False
|
||||||
|
|
||||||
def _handle_connected(self, event=None):
|
def _session_timeout_check(self, event=None):
|
||||||
"""
|
"""
|
||||||
Add check to ensure that a session is established within
|
Add check to ensure that a session is established within
|
||||||
a reasonable amount of time.
|
a reasonable amount of time.
|
||||||
|
Loading…
x
Reference in New Issue
Block a user