code: def _disconnect_locked(self):
      
      self._connected = False
      self._connect_cond.notify_all()
      self._telnet = None
      _LOGGER.warning("Disconnected")
docs: Closes the current connection. Assume self._lock is held.