ncclient:NETCONF Python client

logger = logging.getLogger('ncclient.transport.ssh')

BUF_SIZE = 4096

TICK = 0.1

def default_unknown_host_cb(host, fingerprint):

        self._connected = True # there was no error authenticating

        c = self._channel = self._transport.open_session()

        self._post_connect()

            for cls in (paramiko.RSAKey, paramiko.DSSKey):

                try:

                    key = cls.from_private_key_file(key_filename, password)

                              (hexlify(key.get_fingerprint()), key_filename))

                    self._transport.auth_publickey(username, key)

                    return

        if allow_agent:

            for key in paramiko.Agent().get_keys():

                try:

                                 hexlify(key.get_fingerprint()))

                    self._transport.auth_publickey(username, key)

                    return

        keyfiles = []

        if look_for_keys:

            if os.path.isfile(rsa_key):

                keyfiles.append((paramiko.RSAKey, rsa_key))

            if os.path.isfile(dsa_key):

                keyfiles.append((paramiko.DSSKey, dsa_key))

            # look in ~/ssh/ for windows users:

            if os.path.isfile(rsa_key):

                keyfiles.append((paramiko.RSAKey, rsa_key))

            if os.path.isfile(dsa_key):

        for cls, filename in keyfiles:

            try:

                key = cls.from_private_key_file(filename, password)

                          (hexlify(key.get_fingerprint()), filename))

                self._transport.auth_publickey(username, key)

                return

            # need pep-3134 to do this right

            raise AuthenticationError(repr(saved_exception))

    def run(self):

        chan = self._channel

                    else:

                        raise SessionCloseError(self._buffer.getvalue())

                if not q.empty() and chan.send_ready():

                    data = q.get() + MSG_DELIM

                    while data:

                        n = chan.send(data)

                            raise SessionCloseError(self._buffer.getvalue(), data)

                        data = data[n:]

        except Exception as e:

            self.close()

            self._dispatch_error(e)