copyleftie
/
gajim-plural
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

drop connection after certain time of 

inactivity
set timout on connect attempts
transleted russian comment
This commit is contained in:
Dimitur Kirov 2006-09-20 11:01:47 +00:00
parent a393f121be
commit 57779a6ad3
2 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/common/xmpp/session.py
View File

@ -183,7 +183,7 @@ class Session:
if self.sendbuffer: if self.sendbuffer:
try: try:
# LOCK_QUEUE # LOCK_QUEUE
sent=self._send(self.sendbuffer) # âÌÏËÉÒÕÀÝÁÑ ÛÔÕÞËÁ! sent=self._send(self.sendbuffer) # blocking socket
except: except:
# UNLOCK_QUEUE # UNLOCK_QUEUE
self.set_socket_state(SOCKET_DEAD) self.set_socket_state(SOCKET_DEAD)

25
src/common/zeroconf/client_zeroconf.py
View File

@ -29,6 +29,12 @@ DATA_RECEIVED='DATA RECEIVED'
DATA_SENT='DATA SENT' DATA_SENT='DATA SENT'
TYPE_SERVER, TYPE_CLIENT = range(2) TYPE_SERVER, TYPE_CLIENT = range(2)
# wait XX sec to establish a connection
CONNECT_TIMEOUT_SECONDS = 30
# after XX sec with no activity, close the stream
ACTIVITY_TIMEOUT_SECONDS = 180
class ZeroconfListener(IdleObject): class ZeroconfListener(IdleObject):
def __init__(self, port, conn_holder): def __init__(self, port, conn_holder):
''' handle all incomming connections on ('0.0.0.0', port)''' ''' handle all incomming connections on ('0.0.0.0', port)'''
@ -85,8 +91,6 @@ class ZeroconfListener(IdleObject):
_sock[0].setblocking(False) _sock[0].setblocking(False)
return _sock return _sock
class P2PClient(IdleObject): class P2PClient(IdleObject):
def __init__(self, _sock, host, port, conn_holder, messagequeue = [], to = None): def __init__(self, _sock, host, port, conn_holder, messagequeue = [], to = None):
self._owner = self self._owner = self
@ -101,7 +105,10 @@ class P2PClient(IdleObject):
self.Server = host self.Server = host
self.DBG = 'client' self.DBG = 'client'
self.Connection = None self.Connection = None
debug = ['always', 'nodebuilder'] if gajim.verbose:
debug = ['always', 'nodebuilder']
else:
debug = []
self._DEBUG = Debug.Debug(debug) self._DEBUG = Debug.Debug(debug)
self.DEBUG = self._DEBUG.Show self.DEBUG = self._DEBUG.Show
self.debug_flags = self._DEBUG.debug_flags self.debug_flags = self._DEBUG.debug_flags
@ -230,8 +237,14 @@ class P2PConnection(IdleObject, PlugIn):
self._sock.setblocking(False) self._sock.setblocking(False)
self.fd = self._sock.fileno() self.fd = self._sock.fileno()
gajim.idlequeue.plug_idle(self, True, False) gajim.idlequeue.plug_idle(self, True, False)
self.set_timeout(CONNECT_TIMEOUT_SECONDS)
self.do_connect() self.do_connect()
def set_timeout(self, timeout):
gajim.idlequeue.remove_timeout(self.fd)
if self.state >= 0:
gajim.idlequeue.set_read_timeout(self.fd, timeout)
def plugin(self, owner): def plugin(self, owner):
self.onreceive(owner._on_receive_document_attrs) self.onreceive(owner._on_receive_document_attrs)
self._plug_idle() self._plug_idle()
@ -272,9 +285,7 @@ class P2PConnection(IdleObject, PlugIn):
self._plug_idle() self._plug_idle()
def read_timeout(self): def read_timeout(self):
gajim.idlequeue.remove_timeout(self.fd) self.pollend()
# no activity for foo seconds
# self.pollend()
def do_connect(self): def do_connect(self):
@ -337,6 +348,7 @@ class P2PConnection(IdleObject, PlugIn):
if self.state < 0: if self.state < 0:
return return
if self.on_receive: if self.on_receive:
self.set_timeout(ACTIVITY_TIMEOUT_SECONDS)
if received.strip(): if received.strip():
self.DEBUG(received, 'got') self.DEBUG(received, 'got')
if hasattr(self._owner, 'Dispatcher'): if hasattr(self._owner, 'Dispatcher'):
@ -403,6 +415,7 @@ class P2PConnection(IdleObject, PlugIn):
return return
self._on_send_failure() self._on_send_failure()
return return
self.set_timeout(ACTIVITY_TIMEOUT_SECONDS)
return True return True
def _plug_idle(self): def _plug_idle(self):