RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-16 07:17:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reuse connection objects.

Browse Source 
Signed-off-by: Zack Cerza <zack.cerza@inktank.com>
This commit is contained in:
Zack Cerza 2013-10-02 11:26:07 -05:00
parent f77ee6e0ef
commit cf68a3ac3a
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
teuthology/report.py
View File

@ -140,9 +140,8 @@ class ResultsPoster(object):
jobs=len(jobs),
))
if jobs:
h = httplib2.Http()
run_json = json.dumps({'name': run_name})
resp, content = h.request(
resp, content = self.http.request(
"{base}/runs/".format(base=self.base_uri, name=run_name),
'POST',
run_json,
@ -162,8 +161,7 @@ class ResultsPoster(object):
def post_job(self, run_name, job_id):
job_json = self.serializer.json_for_job(run_name, job_id)
h = httplib2.Http()
resp, content = h.request(
resp, content = self.http.request(
"{base}/runs/{name}/".format(base=self.base_uri, name=run_name,),
'POST',
job_json,
@ -175,7 +173,7 @@ class ResultsPoster(object):
message = ''
if message.endswith('already exists'):
resp, content = h.request(
resp, content = self.http.request(
"{base}/runs/{name}/".format(
base=self.base_uri,
name=run_name,),
@ -208,6 +206,13 @@ class ResultsPoster(object):
if os.path.exists(self.last_run_file):
os.remove(self.last_run_file)
@property
def http(self):
if hasattr(self, '__http'):
return self.__http
self.__http = httplib2.Http()
return self.__http
def parse_args():
parser = argparse.ArgumentParser(