(self, host)
| 4191 | pass |
| 4192 | |
| 4193 | def on_down(self, host): |
| 4194 | |
| 4195 | conn = self._connection |
| 4196 | if conn and conn.endpoint == host.endpoint and \ |
| 4197 | self._reconnection_handler is None: |
| 4198 | log.debug("[control connection] Control connection host (%s) is " |
| 4199 | "considered down, starting reconnection", host) |
| 4200 | # this will result in a task being submitted to the executor to reconnect |
| 4201 | self.reconnect() |
| 4202 | |
| 4203 | def on_add(self, host, refresh_nodes=True): |
| 4204 | if refresh_nodes: |