Skip to content
Snippets Groups Projects
Commit 1bca2f60 authored by Alexander Schlemmer's avatar Alexander Schlemmer
Browse files

FIX: bug that caused a remote end closed without response

parent 834bbf96
No related branches found
No related tags found
No related merge requests found
...@@ -112,6 +112,11 @@ class _DefaultCaosDBServerConnection(CaosDBServerConnection): ...@@ -112,6 +112,11 @@ class _DefaultCaosDBServerConnection(CaosDBServerConnection):
if headers is None: if headers is None:
headers = {} headers = {}
try: try:
self._http_con = StreamingHTTPSConnection(
host=self.setup_fields["host"],
timeout=self.setup_fields["timeout"],
context=self.setup_fields["context"],
socket_proxy=self.setup_fields["socket_proxy"])
self._http_con.request(method=method, url=self._base_path + path, self._http_con.request(method=method, url=self._base_path + path,
headers=headers, body=body) headers=headers, body=body)
except SocketError as socket_err: except SocketError as socket_err:
...@@ -167,11 +172,17 @@ class _DefaultCaosDBServerConnection(CaosDBServerConnection): ...@@ -167,11 +172,17 @@ class _DefaultCaosDBServerConnection(CaosDBServerConnection):
socket_proxy = None socket_proxy = None
if "socket_proxy" in config: if "socket_proxy" in config:
socket_proxy = config["socket_proxy"] socket_proxy = config["socket_proxy"]
self._http_con = StreamingHTTPSConnection(
host=host, self.setup_fields = {
timeout=int(config.get("timeout")), "host": host,
context=context, "timeout": int(config.get("timeout")),
socket_proxy=socket_proxy) "context": context,
"socket_proxy": socket_proxy}
# self._http_con = StreamingHTTPSConnection(
# host=host,
# timeout=int(config.get("timeout")),
# context=context,
# socket_proxy=socket_proxy)
def _make_conf(*conf): def _make_conf(*conf):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment