def _on_timeout(self):
self._timeout = None
self._run_callback(HTTPResponse(self.request, 599,
+ request_time=time.time() - self.start_time,
error=HTTPError(599, "Timeout")))
self.stream.close()
yield
except Exception, e:
logging.warning("uncaught exception", exc_info=True)
- self._run_callback(HTTPResponse(self.request, 599, error=e))
+ self._run_callback(HTTPResponse(self.request, 599, error=e,
+ request_time=time.time() - self.start_time,
+ ))
def _on_close(self):
self._run_callback(HTTPResponse(
self.request, 599,
+ request_time=time.time() - self.start_time,
error=HTTPError(599, "Connection closed")))
def _on_headers(self, data):
return
response = HTTPResponse(original_request,
self.code, headers=self.headers,
+ request_time=time.time() - self.start_time,
buffer=buffer,
effective_url=self.request.url)
self._run_callback(response)
self.assertEqual(response.code, 200)
self.assertEqual(response.headers["Content-Type"], "text/plain")
self.assertEqual(response.body, b("Hello world!"))
+ self.assertEqual(int(response.request_time), 0)
response = self.fetch("/hello?name=Ben")
self.assertEqual(response.body, b("Hello Ben!"))
connect_timeout=0.1)
response = self.wait()
self.assertEqual(response.code, 599)
+ self.assertEqual(int(response.request_time * 10), 1)
self.assertEqual(str(response.error), "HTTP 599: Timeout")
def test_request_timeout(self):
response = self.fetch('/hang', request_timeout=0.1)
self.assertEqual(response.code, 599)
+ self.assertEqual(int(response.request_time * 10), 1)
self.assertEqual(str(response.error), "HTTP 599: Timeout")
def test_ipv6(self):