|
@@ -1753,11 +1753,19 @@ class ChattoAdapter(BasePlatformAdapter):
|
|
|
delay,
|
|
delay,
|
|
|
)
|
|
)
|
|
|
except Exception as exc:
|
|
except Exception as exc:
|
|
|
- logger.warning(
|
|
|
|
|
- "Chatto: unexpected realtime error: %s, reconnecting in %.1fs",
|
|
|
|
|
- exc,
|
|
|
|
|
- delay,
|
|
|
|
|
- )
|
|
|
|
|
|
|
+ cause = exc.__cause__
|
|
|
|
|
+ if cause is not None and "ParseFromString" in str(type(cause).__name__):
|
|
|
|
|
+ logger.warning(
|
|
|
|
|
+ "Chatto: realtime wire corruption (%s), reconnecting in %.1fs",
|
|
|
|
|
+ cause,
|
|
|
|
|
+ delay,
|
|
|
|
|
+ )
|
|
|
|
|
+ else:
|
|
|
|
|
+ logger.warning(
|
|
|
|
|
+ "Chatto: unexpected realtime error: %s, reconnecting in %.1fs",
|
|
|
|
|
+ exc,
|
|
|
|
|
+ delay,
|
|
|
|
|
+ )
|
|
|
|
|
|
|
|
if self._closing:
|
|
if self._closing:
|
|
|
return
|
|
return
|