| commit | 43477aa9f88b4b6a4e223eafb46f2ef7b78a1b1a | [log] [tgz] |
|---|---|---|
| author | 侯锐 <hourui@qianmi.com> | Tue Jul 24 11:30:55 2018 +0800 |
| committer | 侯锐 <hourui@qianmi.com> | Tue Jul 24 11:30:55 2018 +0800 |
| tree | b678a6653e46d3fc08f7185a08e1816c0102ba05 | |
| parent | be133e74e29197e77e5127da624da5d70b5029ed [diff] |
对每个连接的读操作做错误捕获
diff --git a/dubbo/connection/connections.py b/dubbo/connection/connections.py index 5b022e3..ebeebe1 100644 --- a/dubbo/connection/connections.py +++ b/dubbo/connection/connections.py
@@ -292,7 +292,10 @@ logger.exception(e) break for conn in readable: - conn.read(self._callback) + try: + conn.read(self._callback) + except Exception as e: + logger.exception(e) def _new_connection(self, host): ip, port = host.split(':')