From 1bca2f606b69eca3d1d84fdb1e5a35e93cd83511 Mon Sep 17 00:00:00 2001
From: Alexander Schlemmer <alexander.schlemmer@ds.mpg.de>
Date: Fri, 11 Jan 2019 15:39:21 +0100
Subject: [PATCH] FIX: bug that caused a remote end closed without response
---
src/caosdb/connection/connection.py | 21 ++++++++++++++++-----
1 file changed, 16 insertions(+), 5 deletions(-)
diff --git a/src/caosdb/connection/connection.py b/src/caosdb/connection/connection.py
index 0d4e3107..33ea8002 100644
--- a/src/caosdb/connection/connection.py
+++ b/src/caosdb/connection/connection.py
@@ -112,6 +112,11 @@ class _DefaultCaosDBServerConnection(CaosDBServerConnection):
if headers is None:
headers = {}
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,
headers=headers, body=body)
except SocketError as socket_err:
@@ -167,11 +172,17 @@ class _DefaultCaosDBServerConnection(CaosDBServerConnection):
socket_proxy = None
if "socket_proxy" in config:
socket_proxy = config["socket_proxy"]
- self._http_con = StreamingHTTPSConnection(
- host=host,
- timeout=int(config.get("timeout")),
- context=context,
- socket_proxy=socket_proxy)
+
+ self.setup_fields = {
+ "host": host,
+ "timeout": int(config.get("timeout")),
+ "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):
--
GitLab