(topology)
| 205 | |
| 206 | |
| 207 | def _get_executors(topology): |
| 208 | executors = [] |
| 209 | for server in topology._servers.values(): |
| 210 | # Some MockMonitor do not have an _executor. |
| 211 | if hasattr(server._monitor, "_executor"): |
| 212 | executors.append(server._monitor._executor) |
| 213 | if hasattr(server._monitor, "_rtt_monitor"): |
| 214 | executors.append(server._monitor._rtt_monitor._executor) |
| 215 | executors.append(topology._Topology__events_executor) |
| 216 | if topology._srv_monitor: |
| 217 | executors.append(topology._srv_monitor._executor) |
| 218 | |
| 219 | return [e for e in executors if e is not None] |
| 220 | |
| 221 | |
| 222 | def print_running_topology(topology): |
no test coverage detected