Revision 4ab1af1a snf-common/synnefo/lib/quotaholder/http.py
| b/snf-common/synnefo/lib/quotaholder/http.py | ||
|---|---|---|
| 32 | 32 |
# or implied, of GRNET S.A. |
| 33 | 33 |
|
| 34 | 34 |
from synnefo.lib.commissioning import Callpoint, CallError |
| 35 |
from synnefo.lib.pool.http import get_http_connection
|
|
| 35 |
from synnefo.lib.pool.http import PooledHTTPConnection
|
|
| 36 | 36 |
from .api import QuotaholderAPI |
| 37 | 37 |
|
| 38 | 38 |
from json import loads as json_loads, dumps as json_dumps |
| ... | ... | |
| 70 | 70 |
|
| 71 | 71 |
logger.debug("%s %s\n%s\n<<<\n", method, path, json_data[:128])
|
| 72 | 72 |
headers = {'X-Auth-Token': self._token}
|
| 73 |
conn = get_http_connection(scheme=self._scheme, netloc=self._netloc,
|
|
| 74 |
pool_size=self._poolsize)
|
|
| 75 |
try:
|
|
| 73 |
with PooledHTTPConnection(scheme=self._scheme,
|
|
| 74 |
netloc=self._netloc,
|
|
| 75 |
size=self._poolsize) as conn:
|
|
| 76 | 76 |
conn.request(method, path, body=json_data, headers=headers) |
| 77 | 77 |
resp = conn.getresponse() |
| 78 |
finally: |
|
| 79 |
conn.close() |
|
| 78 |
body = resp.read() |
|
| 80 | 79 |
|
| 81 | 80 |
logger.debug(">>>\nStatus: %s", resp.status)
|
| 82 |
|
|
| 83 |
body = resp.read() |
|
| 84 | 81 |
logger.debug("\n%s\n<<<\n", body[:128] if body else None)
|
| 85 | 82 |
|
| 86 | 83 |
status = int(resp.status) |
Also available in: Unified diff