Skip to content
Snippets Groups Projects
Commit 53553e5a authored by inso's avatar inso
Browse files

Workaround to asyncio ssl errors

parent bb53809f
No related branches found
No related tags found
No related merge requests found
...@@ -248,6 +248,9 @@ class BmaConnector: ...@@ -248,6 +248,9 @@ class BmaConnector:
ValueError, jsonschema.ValidationError) as e: ValueError, jsonschema.ValidationError) as e:
self._logger.debug(str(e)) self._logger.debug(str(e))
tries += 1 tries += 1
except AttributeError as e:
if ("feed_appdata", "do_handshake") in str(e):
self._logger.debug(str(e))
raise NoPeerAvailable("", len(endpoints)) raise NoPeerAvailable("", len(endpoints))
async def get(self, currency, request, req_args={}, verify=True): async def get(self, currency, request, req_args={}, verify=True):
......
...@@ -126,6 +126,11 @@ class NodeConnector(QObject): ...@@ -126,6 +126,11 @@ class NodeConnector(QObject):
pass pass
else: else:
raise raise
except AttributeError as e:
if ("feed_appdata", "do_handshake") in str(e):
self._logger.debug(str(e))
else:
raise
async def init_session(self): async def init_session(self):
if not self.session: if not self.session:
...@@ -197,6 +202,11 @@ class NodeConnector(QObject): ...@@ -197,6 +202,11 @@ class NodeConnector(QObject):
pass pass
else: else:
raise raise
except AttributeError as e:
if ("feed_appdata", "do_handshake") in str(e):
self._logger.debug(str(e))
else:
raise
finally: finally:
self._connected['block'] = False self._connected['block'] = False
self._ws_tasks['block'] = None self._ws_tasks['block'] = None
...@@ -335,6 +345,11 @@ class NodeConnector(QObject): ...@@ -335,6 +345,11 @@ class NodeConnector(QObject):
pass pass
else: else:
raise raise
except AttributeError as e:
if ("feed_appdata", "do_handshake") in str(e):
self._logger.debug(str(e))
else:
raise
finally: finally:
self._connected['peer'] = False self._connected['peer'] = False
self._ws_tasks['peer'] = None self._ws_tasks['peer'] = None
...@@ -364,6 +379,9 @@ class NodeConnector(QObject): ...@@ -364,6 +379,9 @@ class NodeConnector(QObject):
break break
self.refresh_peer_data(leaf_data['leaf']['value']) self.refresh_peer_data(leaf_data['leaf']['value'])
except (AttributeError, ValueError) as e: except (AttributeError, ValueError) as e:
if ("feed_appdata", "do_handshake") in str(e):
self._logger.debug(str(e))
else:
self._logger.debug("Incorrect peer data in {leaf} : {err}".format(leaf=leaf_hash, err=str(e))) self._logger.debug("Incorrect peer data in {leaf} : {err}".format(leaf=leaf_hash, err=str(e)))
self.handle_failure() self.handle_failure()
except errors.DuniterError as e: except errors.DuniterError as e:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment