http://tools.ietf.org/html/rfc6555
"""
- def __init__(self, addrinfo, io_loop, connect, source_ip=None):
+ def __init__(self, addrinfo, io_loop, connect):
self.io_loop = io_loop
self.connect = connect
self.last_error = None
self.remaining = len(addrinfo)
self.primary_addrs, self.secondary_addrs = self.split(addrinfo)
- self.source_ip = source_ip
@staticmethod
def split(addrinfo):
self.future.set_exception(self.last_error or
IOError("connection failed"))
return
- future = self.connect(af, addr, source_ip=self.source_ip)
+ future = self.connect(af, addr)
future.add_done_callback(functools.partial(self.on_connect_done,
addrs, af, addr))
fu.set_exception(e)
return fu
else:
- return stream.connect(addr, source_ip=source_ip)
+ return stream.connect(addr)