(name)
| 89 | |
| 90 | @contextmanager |
| 91 | def _zmq_catch_error(name): |
| 92 | try: |
| 93 | yield |
| 94 | except zmq.ContextTerminated: |
| 95 | logger.info("[{}] Context terminated.".format(name)) |
| 96 | raise DataFlowTerminated() |
| 97 | except zmq.ZMQError as e: |
| 98 | if e.errno == errno.ENOTSOCK: # socket closed |
| 99 | logger.info("[{}] Socket closed.".format(name)) |
| 100 | raise DataFlowTerminated() |
| 101 | else: |
| 102 | raise |
| 103 | except Exception: |
| 104 | raise |
| 105 | |
| 106 | |
| 107 | class _MultiProcessZMQDataFlow(DataFlow): |
no test coverage detected