removed useless 'use_tls' variable
This commit is contained in:
parent
3c6b07353d
commit
9506970042
@ -69,10 +69,8 @@ class XMLStream(object):
|
|||||||
self.__stanza_extension = {}
|
self.__stanza_extension = {}
|
||||||
self.__handlers = []
|
self.__handlers = []
|
||||||
|
|
||||||
self.__tls_socket = None
|
|
||||||
self.filesocket = None
|
self.filesocket = None
|
||||||
self.use_ssl = False
|
self.use_ssl = False
|
||||||
self.use_tls = False
|
|
||||||
self.ca_certs=None
|
self.ca_certs=None
|
||||||
|
|
||||||
self.keep_alive = DEFAULT_KEEPALIVE
|
self.keep_alive = DEFAULT_KEEPALIVE
|
||||||
@ -103,11 +101,11 @@ class XMLStream(object):
|
|||||||
def setFileSocket(self, filesocket):
|
def setFileSocket(self, filesocket):
|
||||||
self.filesocket = filesocket
|
self.filesocket = filesocket
|
||||||
|
|
||||||
def connect(self, host='', port=0, use_ssl=None, use_tls=None):
|
def connect(self, host='', port=0, use_ssl=None):
|
||||||
"Establish a socket connection to the given XMPP server."
|
"Establish a socket connection to the given XMPP server."
|
||||||
|
|
||||||
if not self.state.transition('disconnected','connected',
|
if not self.state.transition('disconnected','connected',
|
||||||
func=self.connectTCP, args=[host, port, use_ssl, use_tls] ):
|
func=self.connectTCP, args=[host, port, use_ssl] ):
|
||||||
|
|
||||||
if self.state['connected']: logging.debug('Already connected')
|
if self.state['connected']: logging.debug('Already connected')
|
||||||
else: logging.warning("Connection failed" )
|
else: logging.warning("Connection failed" )
|
||||||
@ -119,7 +117,7 @@ class XMLStream(object):
|
|||||||
# TODO currently a caller can't distinguish between "connection failed" and
|
# TODO currently a caller can't distinguish between "connection failed" and
|
||||||
# "we're already trying to connect from another thread"
|
# "we're already trying to connect from another thread"
|
||||||
|
|
||||||
def connectTCP(self, host='', port=0, use_ssl=None, use_tls=None, reattempt=True):
|
def connectTCP(self, host='', port=0, use_ssl=None, reattempt=True):
|
||||||
"Connect and create socket"
|
"Connect and create socket"
|
||||||
|
|
||||||
# Note that this is thread-safe by merit of being called solely from connect() which
|
# Note that this is thread-safe by merit of being called solely from connect() which
|
||||||
@ -133,14 +131,11 @@ class XMLStream(object):
|
|||||||
self.address = (host, int(port))
|
self.address = (host, int(port))
|
||||||
if use_ssl is not None:
|
if use_ssl is not None:
|
||||||
self.use_ssl = use_ssl
|
self.use_ssl = use_ssl
|
||||||
if use_tls is not None:
|
|
||||||
# TODO this variable doesn't seem to be used for anything!
|
|
||||||
self.use_tls = use_tls
|
|
||||||
if sys.version_info < (3, 0):
|
if sys.version_info < (3, 0):
|
||||||
self.socket = filesocket.Socket26(socket.AF_INET, socket.SOCK_STREAM)
|
self.socket = filesocket.Socket26(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
else:
|
else:
|
||||||
self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
self.socket.settimeout(None) #10)
|
self.socket.settimeout(None)
|
||||||
|
|
||||||
if self.use_ssl and self.ssl_support:
|
if self.use_ssl and self.ssl_support:
|
||||||
logging.debug("Socket Wrapped for SSL")
|
logging.debug("Socket Wrapped for SSL")
|
||||||
|
Loading…
x
Reference in New Issue
Block a user