don;t try to refresh the cache during FT
This commit is contained in:
parent
09d9b2b2c4
commit
f82af54d0c
|
@ -424,6 +424,17 @@ class Connection:
|
||||||
if self.files_props.has_key(sid):
|
if self.files_props.has_key(sid):
|
||||||
file_props = self.files_props[sid]
|
file_props = self.files_props[sid]
|
||||||
file_props['fast'] = streamhosts
|
file_props['fast'] = streamhosts
|
||||||
|
if file_props['type'] == 's':
|
||||||
|
# only psi do this
|
||||||
|
|
||||||
|
if file_props.has_key('streamhosts'):
|
||||||
|
file_props['streamhosts'].extend(streamhosts)
|
||||||
|
else:
|
||||||
|
file_props['streamhosts'] = streamhosts
|
||||||
|
if not gajim.socks5queue.get_file_props(self.name, sid):
|
||||||
|
gajim.socks5queue.add_file_props(self.name, file_props)
|
||||||
|
gajim.socks5queue.connect_to_hosts(self.name, sid,
|
||||||
|
self.send_success_connect_reply, None)
|
||||||
raise common.xmpp.NodeProcessed
|
raise common.xmpp.NodeProcessed
|
||||||
fast = None
|
fast = None
|
||||||
try:
|
try:
|
||||||
|
@ -636,8 +647,9 @@ class Connection:
|
||||||
iq = common.xmpp.Protocol(name = 'iq', to = proxy, typ = 'get')
|
iq = common.xmpp.Protocol(name = 'iq', to = proxy, typ = 'get')
|
||||||
query = iq.setTag('query')
|
query = iq.setTag('query')
|
||||||
query.setNamespace(common.xmpp.NS_BYTESTREAM)
|
query.setNamespace(common.xmpp.NS_BYTESTREAM)
|
||||||
self.to_be_sent.append(iq)
|
# FIXME bad logic - this should be somewhere else!
|
||||||
|
# this line should be put somewhere else
|
||||||
|
# self.to_be_sent.append(iq)
|
||||||
# ensure that we don;t return empty vars
|
# ensure that we don;t return empty vars
|
||||||
if None not in (host, port, jid) or '' not in (host, port, jid):
|
if None not in (host, port, jid) or '' not in (host, port, jid):
|
||||||
return (host, port, jid)
|
return (host, port, jid)
|
||||||
|
@ -656,7 +668,7 @@ class Connection:
|
||||||
if sender is None:
|
if sender is None:
|
||||||
sender = file_props['sender']
|
sender = file_props['sender']
|
||||||
proxyhosts = []
|
proxyhosts = []
|
||||||
if proxy:
|
if fast and proxy:
|
||||||
proxies = map(lambda e:e.strip(), proxy.split(','))
|
proxies = map(lambda e:e.strip(), proxy.split(','))
|
||||||
for proxy in proxies:
|
for proxy in proxies:
|
||||||
(host, _port, jid) = self.get_cached_proxies(proxy)
|
(host, _port, jid) = self.get_cached_proxies(proxy)
|
||||||
|
|
|
@ -58,7 +58,6 @@ class SocksQueue:
|
||||||
self.on_success = on_success
|
self.on_success = on_success
|
||||||
self.on_failure = on_failure
|
self.on_failure = on_failure
|
||||||
if not self.files_props.has_key(account):
|
if not self.files_props.has_key(account):
|
||||||
print '\n\nFIXME '
|
|
||||||
pass
|
pass
|
||||||
# FIXME ---- show error dialog
|
# FIXME ---- show error dialog
|
||||||
else:
|
else:
|
||||||
|
@ -141,10 +140,10 @@ class SocksQueue:
|
||||||
if file_props is None or \
|
if file_props is None or \
|
||||||
file_props.has_key('sid') is False:
|
file_props.has_key('sid') is False:
|
||||||
return
|
return
|
||||||
id = file_props['sid']
|
_id = file_props['sid']
|
||||||
if not self.files_props.has_key(account):
|
if not self.files_props.has_key(account):
|
||||||
self.files_props[account] = {}
|
self.files_props[account] = {}
|
||||||
self.files_props[account][id] = file_props
|
self.files_props[account][_id] = file_props
|
||||||
|
|
||||||
def get_file_props(self, account, sid):
|
def get_file_props(self, account, sid):
|
||||||
''' get fil_prop by account name and session id '''
|
''' get fil_prop by account name and session id '''
|
||||||
|
@ -484,10 +483,13 @@ class Socks5:
|
||||||
''' Parse the initial message and create a list of auth
|
''' Parse the initial message and create a list of auth
|
||||||
mechanisms '''
|
mechanisms '''
|
||||||
auth_mechanisms = []
|
auth_mechanisms = []
|
||||||
|
try:
|
||||||
ver, num_auth = struct.unpack('!BB', buff[:2])
|
ver, num_auth = struct.unpack('!BB', buff[:2])
|
||||||
for i in range(num_auth):
|
for i in range(num_auth):
|
||||||
mechanism, = struct.unpack('!B', buff[1 + i])
|
mechanism, = struct.unpack('!B', buff[1 + i])
|
||||||
auth_mechanisms.append(mechanism)
|
auth_mechanisms.append(mechanism)
|
||||||
|
except:
|
||||||
|
return None
|
||||||
return auth_mechanisms
|
return auth_mechanisms
|
||||||
def _get_auth_response(self):
|
def _get_auth_response(self):
|
||||||
''' socks version(5), number of extra auth methods (we send
|
''' socks version(5), number of extra auth methods (we send
|
||||||
|
|
Loading…
Reference in New Issue