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

Fix a potential traceback in onreceive() of NonBlockingTransport. A few more codingstandards

This commit is contained in:
Stephan Erb 2009-01-10 16:44:11 +00:00
parent 6080bea672
commit c8dc8cd758
2 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -104,7 +104,7 @@ class NonBlockingBOSH(NonBlockingTransport):
self.after_init = True self.after_init = True
self.http_socks.append(self.get_new_http_socket()) self.http_socks.append(self.get_new_http_socket())
self.tcp_connecting_started() self._tcp_connecting_started()
self.http_socks[0].connect( self.http_socks[0].connect(
conn_5tuple = conn_5tuple, conn_5tuple = conn_5tuple,

14
src/common/xmpp/transports_nb.py
View File

@ -200,7 +200,7 @@ class NonBlockingTransport(PlugIn):
Do not confuse it with on_receive() method, which is the callback itself. Do not confuse it with on_receive() method, which is the callback itself.
''' '''
if not recv_handler: if not recv_handler:
if hasattr(self._owner, 'Dispatcher'): if hasattr(self, '_owner') and hasattr(self._owner, 'Dispatcher'):
self.on_receive = self._owner.Dispatcher.ProcessNonBlocking self.on_receive = self._owner.Dispatcher.ProcessNonBlocking
else: else:
log.warning('No Dispatcher plugged. Received data will not be processed') log.warning('No Dispatcher plugged. Received data will not be processed')
@ -208,7 +208,7 @@ class NonBlockingTransport(PlugIn):
return return
self.on_receive = recv_handler self.on_receive = recv_handler
def tcp_connecting_started(self): def _tcp_connecting_started(self):
self.set_state(CONNECTING) self.set_state(CONNECTING)
def read_timeout(self): def read_timeout(self):
@ -313,7 +313,7 @@ class NonBlockingTCP(NonBlockingTransport, IdleObject):
# connecting in progress # connecting in progress
log.info('After NB connect() of %s. "%s" raised => CONNECTING' % log.info('After NB connect() of %s. "%s" raised => CONNECTING' %
(id(self), errstr)) (id(self), errstr))
self.tcp_connecting_started() self._tcp_connecting_started()
return return
# if there was some other exception, call failure callback and unplug # if there was some other exception, call failure callback and unplug
@ -397,7 +397,8 @@ class NonBlockingTCP(NonBlockingTransport, IdleObject):
return return
self.set_state(DISCONNECTED) self.set_state(DISCONNECTED)
self.idlequeue.unplug_idle(self.fd) self.idlequeue.unplug_idle(self.fd)
if 'NonBlockingTLS' in self.__dict__: self.NonBlockingTLS.PlugOut() if 'NonBlockingTLS' in self.__dict__:
self.NonBlockingTLS.PlugOut()
try: try:
self._sock.shutdown(socket.SHUT_RDWR) self._sock.shutdown(socket.SHUT_RDWR)
self._sock.close() self._sock.close()
@ -513,7 +514,8 @@ class NonBlockingTCP(NonBlockingTransport, IdleObject):
exc_info=True) exc_info=True)
errnum, errstr = e.exc errnum, errstr = e.exc
if received == '': errstr = 'zero bytes on recv' if received == '':
errstr = 'zero bytes on recv'
if (self.ssl_lib is None and received == '') or \ if (self.ssl_lib is None and received == '') or \
(self.ssl_lib == tls_nb.PYSTDLIB and errnum == 8 ) or \ (self.ssl_lib == tls_nb.PYSTDLIB and errnum == 8 ) or \
@ -563,7 +565,7 @@ class NonBlockingHTTP(NonBlockingTCP):
def __init__(self, raise_event, on_disconnect, idlequeue, estabilish_tls, def __init__(self, raise_event, on_disconnect, idlequeue, estabilish_tls,
certs, on_http_request_possible, on_persistent_fallback, http_dict, certs, on_http_request_possible, on_persistent_fallback, http_dict,
proxy_dict = None): proxy_dict=None):
''' '''
:param on_http_request_possible: method to call when HTTP request to :param on_http_request_possible: method to call when HTTP request to
socket owned by transport is possible. socket owned by transport is possible.