def _transform_tornado_request(self, request):
if isinstance(request, HTTPRequest):
raise ValueError('param tRequest should be \
HTTPRequest instance from tornado package.')
host, port = get_host_and_port(request.url)
if re.match(r'^\[.*\]$', host):
# raw ipv6 addresses in urls are enclosed in brackets
host = host[1:-1]
self.parsed_hostname = host # save final host for _on_connect
if request.allow_ipv6 is False:
af = AF_INET
else:
af = AF_UNSPEC
ssl_options = self._get_ssl_options(self.parsed.scheme)
timeout = min(self.request.connect_timeout, self.request.request_timeout)
if timeout:
self._timeout = self.io_loop.add_timeout(
self.start_time + timeout,
stack_context.wrap(functools.partial(self._on_timeout, "while connecting")))
评论列表
文章目录