self._result = {'error': None}
self._usable = True
self._session = None
- self._socket = None
self.get_headers = {'Accept': 'application/octet-stream'}
self.get_headers.update(headers)
self.put_headers = headers
if hasattr(socket, 'TCP_KEEPIDLE'):
s.setsockopt(socket.IPPROTO_TCP, socket.TCP_KEEPIDLE, 75)
s.setsockopt(socket.IPPROTO_TCP, socket.TCP_KEEPINTVL, 75)
- self._socket = s
return s
def get(self, locator, method="GET", timeout=None):
curl.perform()
except Exception as e:
raise arvados.errors.HttpError(0, str(e))
- finally:
- if self._socket:
- self._socket.close()
- self._socket = None
self._result = {
'status_code': curl.getinfo(pycurl.RESPONSE_CODE),
'body': response_body.getvalue(),
curl.perform()
except Exception as e:
raise arvados.errors.HttpError(0, str(e))
- finally:
- if self._socket:
- self._socket.close()
- self._socket = None
self._result = {
'status_code': curl.getinfo(pycurl.RESPONSE_CODE),
'body': response_body.getvalue(),