self.set_state("UP")
async def check_timestamp(self):
- http = tornado.httpclient.AsyncHTTPClient()
-
try:
- response = await http.fetch(self.url + ".timestamp",
+ response = await self.backend.http_client.fetch(self.url + ".timestamp",
headers={ "Pragma" : "no-cache" })
except tornado.httpclient.HTTPError as e:
logging.warning("Error getting timestamp from %s: %s" % (self.hostname, e))
if not self.enabled:
return
- http = tornado.httpclient.AsyncHTTPClient()
-
try:
- response = await http.fetch(self.url + ".filelist",
+ response = await self.backend.http_client.fetch(self.url + ".filelist",
headers={ "Pragma" : "no-cache" })
except tornado.httpclient.HTTPError as e:
logging.warning("Error getting filelist from %s: %s" % (self.hostname, e))