diff -Nru paramiko-1.7.4/debian/changelog paramiko-1.7.6/debian/changelog --- paramiko-1.7.4/debian/changelog 2010-01-05 06:37:24.000000000 +0000 +++ paramiko-1.7.6/debian/changelog 2010-01-05 06:37:24.000000000 +0000 @@ -1,3 +1,22 @@ +paramiko (1.7.6-2) unstable; urgency=low + + * debian/control: Fix last remaining lintian warning + + -- Jeremy T. Bouse Wed, 16 Dec 2009 08:15:36 -0500 + +paramiko (1.7.6-1) unstable; urgency=low + + * Imported Upstream version 1.7.6 (Closes: #543784) + * Fix formatting error for __all__ in paramiko/__init__.py (Closes: + #494836) + * Update debian/watch syntax + * Package build clean-up + * Include docs/ contents with build (LP: #364998) + * Update Build-Depends + * debian/control: Update Vcs-* entries + + -- Jeremy T. Bouse Tue, 15 Dec 2009 09:46:29 -0500 + paramiko (1.7.4-0.1) unstable; urgency=medium * NMU. diff -Nru paramiko-1.7.4/debian/compat paramiko-1.7.6/debian/compat --- paramiko-1.7.4/debian/compat 2010-01-05 06:37:24.000000000 +0000 +++ paramiko-1.7.6/debian/compat 2010-01-05 06:37:24.000000000 +0000 @@ -1 +1 @@ -4 +7 diff -Nru paramiko-1.7.4/debian/control paramiko-1.7.6/debian/control --- paramiko-1.7.4/debian/control 2010-01-05 06:37:24.000000000 +0000 +++ paramiko-1.7.6/debian/control 2010-01-05 06:37:24.000000000 +0000 @@ -3,17 +3,20 @@ Priority: optional Maintainer: Jeremy T. Bouse Uploaders: Guido Guenther -Build-Depends: cdbs (>= 0.4.43), debhelper (>= 5.0.37.2), python-all-dev (>= 2.3.5-11), python-support (>= 0.3) -Standards-Version: 3.7.3 +Build-Depends: cdbs (>= 0.4.49), debhelper (>= 7), python-all-dev (>= 2.3.5-11), python-support (>= 0.5.3) +Standards-Version: 3.8.3 +Homepage: http://www.lag.net/paramiko/ +Vcs-Git: git://git.debian.org/collab-maint/paramiko.git +Vcs-Browser: http://git.debian.org/?p=collab-maint/paramiko.git Package: python-paramiko Architecture: all -Depends: ${python:Depends}, python-crypto +Depends: ${misc:Depends}, ${python:Depends}, python-crypto Provides: ${python:Provides} Replaces: python2.3-paramiko (<< 1.5-1.1), python2.4-paramiko (<< 1.5-1.1) Conflicts: python2.3-paramiko (<< 1.5-1.1), python2.4-paramiko (<< 1.5-1.1) -Description: Make ssh v2 connections with python +Description: Make ssh v2 connections with Python This is a library for making SSH2 connections (client or server). Emphasis is on using SSH2 as an alternative to SSL for making secure - connections between python scripts. All major ciphers and hash methods + connections between Python scripts. All major ciphers and hash methods are supported. SFTP client and server mode are both supported too. diff -Nru paramiko-1.7.4/debian/docs paramiko-1.7.6/debian/docs --- paramiko-1.7.4/debian/docs 2010-01-05 06:37:24.000000000 +0000 +++ paramiko-1.7.6/debian/docs 2010-01-05 06:37:24.000000000 +0000 @@ -1 +1,2 @@ README +docs diff -Nru paramiko-1.7.4/debian/pyversions paramiko-1.7.6/debian/pyversions --- paramiko-1.7.4/debian/pyversions 1970-01-01 01:00:00.000000000 +0100 +++ paramiko-1.7.6/debian/pyversions 2010-01-05 06:37:24.000000000 +0000 @@ -0,0 +1 @@ +2.2- diff -Nru paramiko-1.7.4/debian/rules paramiko-1.7.6/debian/rules --- paramiko-1.7.4/debian/rules 2010-01-05 06:37:24.000000000 +0000 +++ paramiko-1.7.6/debian/rules 2010-01-05 06:37:24.000000000 +0000 @@ -4,8 +4,8 @@ include /usr/share/cdbs/1/rules/buildcore.mk include /usr/share/cdbs/1/rules/debhelper.mk -include /usr/share/cdbs/1/rules/simple-patchsys.mk include /usr/share/cdbs/1/class/python-distutils.mk +include /usr/share/cdbs/1/rules/simple-patchsys.mk clean:: rm -rf build diff -Nru paramiko-1.7.4/debian/watch paramiko-1.7.6/debian/watch --- paramiko-1.7.4/debian/watch 2010-01-05 06:37:24.000000000 +0000 +++ paramiko-1.7.6/debian/watch 2010-01-05 06:37:24.000000000 +0000 @@ -1,2 +1,2 @@ -version=2 -http://www.lag.net/paramiko/download/paramiko-(.*)\.zip debian uupdate +version=3 +http://www.lag.net/paramiko/download/paramiko-(.*)\.tar.gz debian uupdate diff -Nru paramiko-1.7.4/demos/demo.py paramiko-1.7.6/demos/demo.py --- paramiko-1.7.4/demos/demo.py 2007-02-12 17:55:56.000000000 +0000 +++ paramiko-1.7.6/demos/demo.py 2009-07-20 03:38:35.000000000 +0100 @@ -1,6 +1,6 @@ #!/usr/bin/env python -# Copyright (C) 2003-2007 Robey Pointer +# Copyright (C) 2003-2007 Robey Pointer # # This file is part of paramiko. # diff -Nru paramiko-1.7.4/demos/demo_server.py paramiko-1.7.6/demos/demo_server.py --- paramiko-1.7.4/demos/demo_server.py 2007-02-12 17:55:40.000000000 +0000 +++ paramiko-1.7.6/demos/demo_server.py 2009-07-20 03:38:35.000000000 +0100 @@ -1,6 +1,6 @@ #!/usr/bin/env python -# Copyright (C) 2003-2007 Robey Pointer +# Copyright (C) 2003-2007 Robey Pointer # # This file is part of paramiko. # diff -Nru paramiko-1.7.4/demos/demo_sftp.py paramiko-1.7.6/demos/demo_sftp.py --- paramiko-1.7.4/demos/demo_sftp.py 2008-02-17 15:28:12.000000000 +0000 +++ paramiko-1.7.6/demos/demo_sftp.py 2009-07-20 03:38:35.000000000 +0100 @@ -1,6 +1,6 @@ #!/usr/bin/env python -# Copyright (C) 2003-2007 Robey Pointer +# Copyright (C) 2003-2007 Robey Pointer # # This file is part of paramiko. # diff -Nru paramiko-1.7.4/demos/demo_simple.py paramiko-1.7.6/demos/demo_simple.py --- paramiko-1.7.4/demos/demo_simple.py 2008-02-17 15:27:58.000000000 +0000 +++ paramiko-1.7.6/demos/demo_simple.py 2009-07-20 03:38:35.000000000 +0100 @@ -1,6 +1,6 @@ #!/usr/bin/env python -# Copyright (C) 2003-2007 Robey Pointer +# Copyright (C) 2003-2007 Robey Pointer # # This file is part of paramiko. # @@ -59,43 +59,26 @@ password = getpass.getpass('Password for %s@%s: ' % (username, hostname)) -# get host key, if we know one -hostkeytype = None -hostkey = None +# now, connect and use paramiko Client to negotiate SSH2 across the connection try: - host_keys = paramiko.util.load_host_keys(os.path.expanduser('~/.ssh/known_hosts')) -except IOError: - try: - # try ~/ssh/ too, because windows can't have a folder named ~/.ssh/ - host_keys = paramiko.util.load_host_keys(os.path.expanduser('~/ssh/known_hosts')) - except IOError: - print '*** Unable to open host keys file' - host_keys = {} - -if host_keys.has_key(hostname): - hostkeytype = host_keys[hostname].keys()[0] - hostkey = host_keys[hostname][hostkeytype] - print 'Using host key of type %s' % hostkeytype - - -# now, connect and use paramiko Transport to negotiate SSH2 across the connection -try: - t = paramiko.Transport((hostname, port)) - t.connect(username=username, password=password, hostkey=hostkey) - chan = t.open_session() - chan.get_pty() - chan.invoke_shell() + client = paramiko.SSHClient() + client.load_system_host_keys() + client.set_missing_host_key_policy(paramiko.WarningPolicy) + print '*** Connecting...' + client.connect(hostname, port, username, password) + chan = client.invoke_shell() + print repr(client.get_transport()) print '*** Here we go!' print interactive.interactive_shell(chan) chan.close() - t.close() + client.close() except Exception, e: print '*** Caught exception: %s: %s' % (e.__class__, e) traceback.print_exc() try: - t.close() + client.close() except: pass sys.exit(1) diff -Nru paramiko-1.7.4/demos/forward.py paramiko-1.7.6/demos/forward.py --- paramiko-1.7.4/demos/forward.py 2008-02-18 23:45:24.000000000 +0000 +++ paramiko-1.7.6/demos/forward.py 2009-07-20 03:38:35.000000000 +0100 @@ -1,6 +1,6 @@ #!/usr/bin/env python -# Copyright (C) 2003-2007 Robey Pointer +# Copyright (C) 2003-2007 Robey Pointer # # This file is part of paramiko. # diff -Nru paramiko-1.7.4/demos/interactive.py paramiko-1.7.6/demos/interactive.py --- paramiko-1.7.4/demos/interactive.py 2007-02-12 17:56:10.000000000 +0000 +++ paramiko-1.7.6/demos/interactive.py 2009-07-20 03:38:35.000000000 +0100 @@ -1,4 +1,4 @@ -# Copyright (C) 2003-2007 Robey Pointer +# Copyright (C) 2003-2007 Robey Pointer # # This file is part of paramiko. # diff -Nru paramiko-1.7.4/demos/rforward.py paramiko-1.7.6/demos/rforward.py --- paramiko-1.7.4/demos/rforward.py 2008-02-19 20:57:24.000000000 +0000 +++ paramiko-1.7.6/demos/rforward.py 2009-07-20 03:38:35.000000000 +0100 @@ -1,6 +1,6 @@ #!/usr/bin/env python -# Copyright (C) 2008 Robey Pointer +# Copyright (C) 2008 Robey Pointer # # This file is part of paramiko. # diff -Nru paramiko-1.7.4/docs/api-objects.txt paramiko-1.7.6/docs/api-objects.txt --- paramiko-1.7.4/docs/api-objects.txt 2008-07-06 17:30:38.000000000 +0100 +++ paramiko-1.7.6/docs/api-objects.txt 2009-11-02 06:14:21.000000000 +0000 @@ -1,4 +1,5 @@ paramiko paramiko-module.html +paramiko.__package__ paramiko-module.html#__package__ paramiko.__license__ paramiko-module.html#__license__ paramiko.__version_info__ paramiko-module.html#__version_info__ paramiko.__author__ paramiko-module.html#__author__ @@ -7,6 +8,7 @@ paramiko.agent.SSH2_AGENT_IDENTITIES_ANSWER paramiko.agent-module.html#SSH2_AGENT_IDENTITIES_ANSWER paramiko.agent.SSH2_AGENTC_REQUEST_IDENTITIES paramiko.agent-module.html#SSH2_AGENTC_REQUEST_IDENTITIES paramiko.agent.SSH2_AGENTC_SIGN_REQUEST paramiko.agent-module.html#SSH2_AGENTC_SIGN_REQUEST +paramiko.agent.__package__ paramiko.agent-module.html#__package__ paramiko.agent.SSH2_AGENT_SIGN_RESPONSE paramiko.agent-module.html#SSH2_AGENT_SIGN_RESPONSE paramiko.auth_handler paramiko.auth_handler-module.html paramiko.auth_handler.AUTH_SUCCESSFUL paramiko.auth_handler-module.html#AUTH_SUCCESSFUL @@ -26,7 +28,7 @@ paramiko.auth_handler.MSG_CHANNEL_SUCCESS paramiko.auth_handler-module.html#MSG_CHANNEL_SUCCESS paramiko.auth_handler.MSG_USERAUTH_FAILURE paramiko.auth_handler-module.html#MSG_USERAUTH_FAILURE paramiko.auth_handler.MSG_REQUEST_FAILURE paramiko.auth_handler-module.html#MSG_REQUEST_FAILURE -paramiko.auth_handler.randpool paramiko.auth_handler-module.html#randpool +paramiko.auth_handler.__package__ paramiko.auth_handler-module.html#__package__ paramiko.auth_handler.MSG_CHANNEL_DATA paramiko.auth_handler-module.html#MSG_CHANNEL_DATA paramiko.auth_handler.AUTH_PARTIALLY_SUCCESSFUL paramiko.auth_handler-module.html#AUTH_PARTIALLY_SUCCESSFUL paramiko.auth_handler.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.auth_handler-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED @@ -54,12 +56,15 @@ paramiko.auth_handler.MSG_CHANNEL_EXTENDED_DATA paramiko.auth_handler-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.auth_handler.MSG_CHANNEL_CLOSE paramiko.auth_handler-module.html#MSG_CHANNEL_CLOSE paramiko.auth_handler.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.auth_handler-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.auth_handler.randpool paramiko.auth_handler-module.html#randpool paramiko.auth_handler.MSG_CHANNEL_OPEN_SUCCESS paramiko.auth_handler-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.auth_handler.MSG_CHANNEL_EOF paramiko.auth_handler-module.html#MSG_CHANNEL_EOF paramiko.auth_handler.MSG_USERAUTH_SUCCESS paramiko.auth_handler-module.html#MSG_USERAUTH_SUCCESS paramiko.auth_handler.CONNECTION_FAILED_CODE paramiko.auth_handler-module.html#CONNECTION_FAILED_CODE paramiko.ber paramiko.ber-module.html +paramiko.ber.__package__ paramiko.ber-module.html#__package__ paramiko.buffered_pipe paramiko.buffered_pipe-module.html +paramiko.buffered_pipe.__package__ paramiko.buffered_pipe-module.html#__package__ paramiko.channel paramiko.channel-module.html paramiko.channel.AUTH_SUCCESSFUL paramiko.channel-module.html#AUTH_SUCCESSFUL paramiko.channel.MSG_KEXINIT paramiko.channel-module.html#MSG_KEXINIT @@ -78,7 +83,7 @@ paramiko.channel.MSG_USERAUTH_FAILURE paramiko.channel-module.html#MSG_USERAUTH_FAILURE paramiko.channel.MSG_REQUEST_FAILURE paramiko.channel-module.html#MSG_REQUEST_FAILURE paramiko.channel.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.channel-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED -paramiko.channel.randpool paramiko.channel-module.html#randpool +paramiko.channel.__package__ paramiko.channel-module.html#__package__ paramiko.channel.MSG_CHANNEL_DATA paramiko.channel-module.html#MSG_CHANNEL_DATA paramiko.channel.CRITICAL paramiko.channel-module.html#CRITICAL paramiko.channel.MSG_IGNORE paramiko.channel-module.html#MSG_IGNORE @@ -107,6 +112,7 @@ paramiko.channel.MSG_CHANNEL_EXTENDED_DATA paramiko.channel-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.channel.MSG_CHANNEL_CLOSE paramiko.channel-module.html#MSG_CHANNEL_CLOSE paramiko.channel.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.channel-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.channel.randpool paramiko.channel-module.html#randpool paramiko.channel.MSG_CHANNEL_OPEN_SUCCESS paramiko.channel-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.channel.MSG_CHANNEL_EOF paramiko.channel-module.html#MSG_CHANNEL_EOF paramiko.channel.MSG_USERAUTH_SUCCESS paramiko.channel-module.html#MSG_USERAUTH_SUCCESS @@ -120,9 +126,11 @@ paramiko.client.MSG_REQUEST_FAILURE paramiko.client-module.html#MSG_REQUEST_FAILURE paramiko.client.MSG_CHANNEL_OPEN paramiko.client-module.html#MSG_CHANNEL_OPEN paramiko.client.MSG_SERVICE_REQUEST paramiko.client-module.html#MSG_SERVICE_REQUEST +paramiko.client.__package__ paramiko.client-module.html#__package__ paramiko.client.MSG_DISCONNECT paramiko.client-module.html#MSG_DISCONNECT paramiko.client.DISCONNECT_NO_MORE_AUTH_METHODS_AVAILABLE paramiko.client-module.html#DISCONNECT_NO_MORE_AUTH_METHODS_AVAILABLE paramiko.client.MSG_SERVICE_ACCEPT paramiko.client-module.html#MSG_SERVICE_ACCEPT +paramiko.client.SSH_PORT paramiko.client-module.html#SSH_PORT paramiko.client.MSG_IGNORE paramiko.client-module.html#MSG_IGNORE paramiko.client.WARNING paramiko.client-module.html#WARNING paramiko.client.MSG_GLOBAL_REQUEST paramiko.client-module.html#MSG_GLOBAL_REQUEST @@ -178,7 +186,7 @@ paramiko.common.MSG_CHANNEL_SUCCESS paramiko.common-module.html#MSG_CHANNEL_SUCCESS paramiko.common.MSG_USERAUTH_FAILURE paramiko.common-module.html#MSG_USERAUTH_FAILURE paramiko.common.MSG_REQUEST_FAILURE paramiko.common-module.html#MSG_REQUEST_FAILURE -paramiko.common.randpool paramiko.common-module.html#randpool +paramiko.common.__package__ paramiko.common-module.html#__package__ paramiko.common.MSG_CHANNEL_DATA paramiko.common-module.html#MSG_CHANNEL_DATA paramiko.common.CRITICAL paramiko.common-module.html#CRITICAL paramiko.common.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.common-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED @@ -207,12 +215,15 @@ paramiko.common.MSG_CHANNEL_EXTENDED_DATA paramiko.common-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.common.MSG_CHANNEL_CLOSE paramiko.common-module.html#MSG_CHANNEL_CLOSE paramiko.common.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.common-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.common.randpool paramiko.common-module.html#randpool paramiko.common.MSG_CHANNEL_OPEN_SUCCESS paramiko.common-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.common.MSG_CHANNEL_EOF paramiko.common-module.html#MSG_CHANNEL_EOF paramiko.common.MSG_USERAUTH_SUCCESS paramiko.common-module.html#MSG_USERAUTH_SUCCESS paramiko.common.CONNECTION_FAILED_CODE paramiko.common-module.html#CONNECTION_FAILED_CODE paramiko.compress paramiko.compress-module.html +paramiko.compress.__package__ paramiko.compress-module.html#__package__ paramiko.config paramiko.config-module.html +paramiko.config.__package__ paramiko.config-module.html#__package__ paramiko.dsskey paramiko.dsskey-module.html paramiko.dsskey.AUTH_SUCCESSFUL paramiko.dsskey-module.html#AUTH_SUCCESSFUL paramiko.dsskey.MSG_KEXINIT paramiko.dsskey-module.html#MSG_KEXINIT @@ -231,7 +242,7 @@ paramiko.dsskey.MSG_USERAUTH_INFO_RESPONSE paramiko.dsskey-module.html#MSG_USERAUTH_INFO_RESPONSE paramiko.dsskey.MSG_CHANNEL_SUCCESS paramiko.dsskey-module.html#MSG_CHANNEL_SUCCESS paramiko.dsskey.MSG_USERAUTH_FAILURE paramiko.dsskey-module.html#MSG_USERAUTH_FAILURE -paramiko.dsskey.randpool paramiko.dsskey-module.html#randpool +paramiko.dsskey.__package__ paramiko.dsskey-module.html#__package__ paramiko.dsskey.MSG_CHANNEL_DATA paramiko.dsskey-module.html#MSG_CHANNEL_DATA paramiko.dsskey.CRITICAL paramiko.dsskey-module.html#CRITICAL paramiko.dsskey.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.dsskey-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED @@ -259,11 +270,13 @@ paramiko.dsskey.MSG_CHANNEL_EXTENDED_DATA paramiko.dsskey-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.dsskey.MSG_CHANNEL_CLOSE paramiko.dsskey-module.html#MSG_CHANNEL_CLOSE paramiko.dsskey.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.dsskey-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.dsskey.randpool paramiko.dsskey-module.html#randpool paramiko.dsskey.MSG_CHANNEL_OPEN_SUCCESS paramiko.dsskey-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.dsskey.MSG_CHANNEL_EOF paramiko.dsskey-module.html#MSG_CHANNEL_EOF paramiko.dsskey.MSG_USERAUTH_SUCCESS paramiko.dsskey-module.html#MSG_USERAUTH_SUCCESS paramiko.dsskey.CONNECTION_FAILED_CODE paramiko.dsskey-module.html#CONNECTION_FAILED_CODE paramiko.file paramiko.file-module.html +paramiko.file.__package__ paramiko.file-module.html#__package__ paramiko.hostkeys paramiko.hostkeys-module.html paramiko.hostkeys.AUTH_SUCCESSFUL paramiko.hostkeys-module.html#AUTH_SUCCESSFUL paramiko.hostkeys.MSG_KEXINIT paramiko.hostkeys-module.html#MSG_KEXINIT @@ -281,7 +294,7 @@ paramiko.hostkeys.MSG_USERAUTH_INFO_RESPONSE paramiko.hostkeys-module.html#MSG_USERAUTH_INFO_RESPONSE paramiko.hostkeys.MSG_CHANNEL_SUCCESS paramiko.hostkeys-module.html#MSG_CHANNEL_SUCCESS paramiko.hostkeys.MSG_USERAUTH_FAILURE paramiko.hostkeys-module.html#MSG_USERAUTH_FAILURE -paramiko.hostkeys.randpool paramiko.hostkeys-module.html#randpool +paramiko.hostkeys.__package__ paramiko.hostkeys-module.html#__package__ paramiko.hostkeys.MSG_CHANNEL_DATA paramiko.hostkeys-module.html#MSG_CHANNEL_DATA paramiko.hostkeys.CRITICAL paramiko.hostkeys-module.html#CRITICAL paramiko.hostkeys.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.hostkeys-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED @@ -311,6 +324,7 @@ paramiko.hostkeys.MSG_CHANNEL_EXTENDED_DATA paramiko.hostkeys-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.hostkeys.MSG_CHANNEL_CLOSE paramiko.hostkeys-module.html#MSG_CHANNEL_CLOSE paramiko.hostkeys.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.hostkeys-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.hostkeys.randpool paramiko.hostkeys-module.html#randpool paramiko.hostkeys.MSG_CHANNEL_OPEN_SUCCESS paramiko.hostkeys-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.hostkeys.MSG_CHANNEL_EOF paramiko.hostkeys-module.html#MSG_CHANNEL_EOF paramiko.hostkeys.CONNECTION_FAILED_CODE paramiko.hostkeys-module.html#CONNECTION_FAILED_CODE @@ -332,7 +346,7 @@ paramiko.kex_gex.MSG_CHANNEL_SUCCESS paramiko.kex_gex-module.html#MSG_CHANNEL_SUCCESS paramiko.kex_gex.MSG_USERAUTH_FAILURE paramiko.kex_gex-module.html#MSG_USERAUTH_FAILURE paramiko.kex_gex.MSG_REQUEST_FAILURE paramiko.kex_gex-module.html#MSG_REQUEST_FAILURE -paramiko.kex_gex.randpool paramiko.kex_gex-module.html#randpool +paramiko.kex_gex.__package__ paramiko.kex_gex-module.html#__package__ paramiko.kex_gex.MSG_CHANNEL_DATA paramiko.kex_gex-module.html#MSG_CHANNEL_DATA paramiko.kex_gex.CRITICAL paramiko.kex_gex-module.html#CRITICAL paramiko.kex_gex._MSG_KEXDH_GEX_REQUEST_OLD paramiko.kex_gex-module.html#_MSG_KEXDH_GEX_REQUEST_OLD @@ -365,6 +379,7 @@ paramiko.kex_gex.MSG_CHANNEL_EXTENDED_DATA paramiko.kex_gex-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.kex_gex.MSG_CHANNEL_CLOSE paramiko.kex_gex-module.html#MSG_CHANNEL_CLOSE paramiko.kex_gex.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.kex_gex-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.kex_gex.randpool paramiko.kex_gex-module.html#randpool paramiko.kex_gex.MSG_CHANNEL_OPEN_SUCCESS paramiko.kex_gex-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.kex_gex.MSG_CHANNEL_EOF paramiko.kex_gex-module.html#MSG_CHANNEL_EOF paramiko.kex_gex.MSG_USERAUTH_SUCCESS paramiko.kex_gex-module.html#MSG_USERAUTH_SUCCESS @@ -389,7 +404,7 @@ paramiko.kex_group1.MSG_CHANNEL_SUCCESS paramiko.kex_group1-module.html#MSG_CHANNEL_SUCCESS paramiko.kex_group1.MSG_USERAUTH_FAILURE paramiko.kex_group1-module.html#MSG_USERAUTH_FAILURE paramiko.kex_group1.MSG_REQUEST_FAILURE paramiko.kex_group1-module.html#MSG_REQUEST_FAILURE -paramiko.kex_group1.randpool paramiko.kex_group1-module.html#randpool +paramiko.kex_group1.__package__ paramiko.kex_group1-module.html#__package__ paramiko.kex_group1.MSG_CHANNEL_DATA paramiko.kex_group1-module.html#MSG_CHANNEL_DATA paramiko.kex_group1.CRITICAL paramiko.kex_group1-module.html#CRITICAL paramiko.kex_group1.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.kex_group1-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED @@ -419,6 +434,7 @@ paramiko.kex_group1.MSG_CHANNEL_EXTENDED_DATA paramiko.kex_group1-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.kex_group1.MSG_CHANNEL_CLOSE paramiko.kex_group1-module.html#MSG_CHANNEL_CLOSE paramiko.kex_group1.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.kex_group1-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.kex_group1.randpool paramiko.kex_group1-module.html#randpool paramiko.kex_group1.MSG_CHANNEL_OPEN_SUCCESS paramiko.kex_group1-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.kex_group1.MSG_CHANNEL_EOF paramiko.kex_group1-module.html#MSG_CHANNEL_EOF paramiko.kex_group1.MSG_USERAUTH_SUCCESS paramiko.kex_group1-module.html#MSG_USERAUTH_SUCCESS @@ -427,11 +443,13 @@ paramiko.logging22.INFO paramiko.logging22-module.html#INFO paramiko.logging22.WARNING paramiko.logging22-module.html#WARNING paramiko.logging22._logger paramiko.logging22-module.html#_logger +paramiko.logging22.__package__ paramiko.logging22-module.html#__package__ paramiko.logging22.getLogger paramiko.logging22-module.html#getLogger paramiko.logging22.CRITICAL paramiko.logging22-module.html#CRITICAL paramiko.logging22.ERROR paramiko.logging22-module.html#ERROR paramiko.logging22.DEBUG paramiko.logging22-module.html#DEBUG paramiko.message paramiko.message-module.html +paramiko.message.__package__ paramiko.message-module.html#__package__ paramiko.packet paramiko.packet-module.html paramiko.packet.AUTH_SUCCESSFUL paramiko.packet-module.html#AUTH_SUCCESSFUL paramiko.packet.MSG_KEXINIT paramiko.packet-module.html#MSG_KEXINIT @@ -452,7 +470,7 @@ paramiko.packet.MSG_USERAUTH_FAILURE paramiko.packet-module.html#MSG_USERAUTH_FAILURE paramiko.packet.compute_hmac paramiko.packet-module.html#compute_hmac paramiko.packet.MSG_REQUEST_FAILURE paramiko.packet-module.html#MSG_REQUEST_FAILURE -paramiko.packet.randpool paramiko.packet-module.html#randpool +paramiko.packet.__package__ paramiko.packet-module.html#__package__ paramiko.packet.MSG_CHANNEL_DATA paramiko.packet-module.html#MSG_CHANNEL_DATA paramiko.packet.CRITICAL paramiko.packet-module.html#CRITICAL paramiko.packet.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.packet-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED @@ -480,12 +498,14 @@ paramiko.packet.MSG_CHANNEL_EXTENDED_DATA paramiko.packet-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.packet.MSG_CHANNEL_CLOSE paramiko.packet-module.html#MSG_CHANNEL_CLOSE paramiko.packet.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.packet-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.packet.randpool paramiko.packet-module.html#randpool paramiko.packet.MSG_CHANNEL_OPEN_SUCCESS paramiko.packet-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.packet.MSG_CHANNEL_EOF paramiko.packet-module.html#MSG_CHANNEL_EOF paramiko.packet.MSG_USERAUTH_SUCCESS paramiko.packet-module.html#MSG_USERAUTH_SUCCESS paramiko.packet.CONNECTION_FAILED_CODE paramiko.packet-module.html#CONNECTION_FAILED_CODE paramiko.pipe paramiko.pipe-module.html paramiko.pipe.make_or_pipe paramiko.pipe-module.html#make_or_pipe +paramiko.pipe.__package__ paramiko.pipe-module.html#__package__ paramiko.pipe.make_pipe paramiko.pipe-module.html#make_pipe paramiko.pkey paramiko.pkey-module.html paramiko.pkey.AUTH_SUCCESSFUL paramiko.pkey-module.html#AUTH_SUCCESSFUL @@ -537,19 +557,25 @@ paramiko.pkey.MSG_CHANNEL_EOF paramiko.pkey-module.html#MSG_CHANNEL_EOF paramiko.pkey.MSG_USERAUTH_SUCCESS paramiko.pkey-module.html#MSG_USERAUTH_SUCCESS paramiko.pkey.CONNECTION_FAILED_CODE paramiko.pkey-module.html#CONNECTION_FAILED_CODE +paramiko.pkey.__package__ paramiko.pkey-module.html#__package__ paramiko.primes paramiko.primes-module.html paramiko.primes._roll_random paramiko.primes-module.html#_roll_random paramiko.primes._generate_prime paramiko.primes-module.html#_generate_prime +paramiko.primes.__package__ paramiko.primes-module.html#__package__ paramiko.resource paramiko.resource-module.html paramiko.resource.ResourceManager paramiko.resource-module.html#ResourceManager +paramiko.resource.__package__ paramiko.resource-module.html#__package__ paramiko.rng paramiko.rng-module.html paramiko.rng.rng_device paramiko.rng-module.html#rng_device +paramiko.rng.__package__ paramiko.rng-module.html#__package__ paramiko.rng._strxor paramiko.rng-module.html#_strxor paramiko.rng_posix paramiko.rng_posix-module.html +paramiko.rng_posix.__package__ paramiko.rng_posix-module.html#__package__ paramiko.rng_posix.open_rng_device paramiko.rng_posix-module.html#open_rng_device paramiko.rng_win32 paramiko.rng_win32-module.html paramiko.rng_win32._winrandom paramiko.rng_win32-module.html#_winrandom paramiko.rng_win32._open_winrandom paramiko.rng_win32-module.html#_open_winrandom +paramiko.rng_win32.__package__ paramiko.rng_win32-module.html#__package__ paramiko.rng_win32.open_rng_device paramiko.rng_win32-module.html#open_rng_device paramiko.rng_win32._open_urandom paramiko.rng_win32-module.html#_open_urandom paramiko.rsakey paramiko.rsakey-module.html @@ -602,6 +628,7 @@ paramiko.rsakey.MSG_CHANNEL_EOF paramiko.rsakey-module.html#MSG_CHANNEL_EOF paramiko.rsakey.MSG_USERAUTH_SUCCESS paramiko.rsakey-module.html#MSG_USERAUTH_SUCCESS paramiko.rsakey.CONNECTION_FAILED_CODE paramiko.rsakey-module.html#CONNECTION_FAILED_CODE +paramiko.rsakey.__package__ paramiko.rsakey-module.html#__package__ paramiko.server paramiko.server-module.html paramiko.server.AUTH_SUCCESSFUL paramiko.server-module.html#AUTH_SUCCESSFUL paramiko.server.MSG_KEXINIT paramiko.server-module.html#MSG_KEXINIT @@ -620,7 +647,7 @@ paramiko.server.MSG_CHANNEL_SUCCESS paramiko.server-module.html#MSG_CHANNEL_SUCCESS paramiko.server.MSG_USERAUTH_FAILURE paramiko.server-module.html#MSG_USERAUTH_FAILURE paramiko.server.MSG_REQUEST_FAILURE paramiko.server-module.html#MSG_REQUEST_FAILURE -paramiko.server.randpool paramiko.server-module.html#randpool +paramiko.server.__package__ paramiko.server-module.html#__package__ paramiko.server.MSG_CHANNEL_DATA paramiko.server-module.html#MSG_CHANNEL_DATA paramiko.server.CRITICAL paramiko.server-module.html#CRITICAL paramiko.server.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.server-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED @@ -648,6 +675,7 @@ paramiko.server.MSG_CHANNEL_EXTENDED_DATA paramiko.server-module.html#MSG_CHANNEL_EXTENDED_DATA paramiko.server.MSG_CHANNEL_CLOSE paramiko.server-module.html#MSG_CHANNEL_CLOSE paramiko.server.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.server-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER +paramiko.server.randpool paramiko.server-module.html#randpool paramiko.server.MSG_CHANNEL_OPEN_SUCCESS paramiko.server-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.server.MSG_CHANNEL_EOF paramiko.server-module.html#MSG_CHANNEL_EOF paramiko.server.MSG_USERAUTH_SUCCESS paramiko.server-module.html#MSG_USERAUTH_SUCCESS @@ -673,6 +701,7 @@ paramiko.sftp.SFTP_BAD_MESSAGE paramiko.sftp-module.html#SFTP_BAD_MESSAGE paramiko.sftp.PY22 paramiko.sftp-module.html#PY22 paramiko.sftp.CMD_READLINK paramiko.sftp-module.html#CMD_READLINK +paramiko.sftp.__package__ paramiko.sftp-module.html#__package__ paramiko.sftp.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp.MSG_NEWKEYS paramiko.sftp-module.html#MSG_NEWKEYS paramiko.sftp.MSG_USERAUTH_SUCCESS paramiko.sftp-module.html#MSG_USERAUTH_SUCCESS @@ -768,6 +797,7 @@ paramiko.sftp_attr.SFTP_BAD_MESSAGE paramiko.sftp_attr-module.html#SFTP_BAD_MESSAGE paramiko.sftp_attr.PY22 paramiko.sftp_attr-module.html#PY22 paramiko.sftp_attr.CMD_READLINK paramiko.sftp_attr-module.html#CMD_READLINK +paramiko.sftp_attr.__package__ paramiko.sftp_attr-module.html#__package__ paramiko.sftp_attr.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_attr-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_attr.MSG_NEWKEYS paramiko.sftp_attr-module.html#MSG_NEWKEYS paramiko.sftp_attr.MSG_USERAUTH_SUCCESS paramiko.sftp_attr-module.html#MSG_USERAUTH_SUCCESS @@ -863,6 +893,7 @@ paramiko.sftp_client.SFTP_BAD_MESSAGE paramiko.sftp_client-module.html#SFTP_BAD_MESSAGE paramiko.sftp_client.PY22 paramiko.sftp_client-module.html#PY22 paramiko.sftp_client.CMD_READLINK paramiko.sftp_client-module.html#CMD_READLINK +paramiko.sftp_client.__package__ paramiko.sftp_client-module.html#__package__ paramiko.sftp_client.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_client-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_client.MSG_NEWKEYS paramiko.sftp_client-module.html#MSG_NEWKEYS paramiko.sftp_client.MSG_USERAUTH_SUCCESS paramiko.sftp_client-module.html#MSG_USERAUTH_SUCCESS @@ -958,6 +989,7 @@ paramiko.sftp_file.SFTP_BAD_MESSAGE paramiko.sftp_file-module.html#SFTP_BAD_MESSAGE paramiko.sftp_file.PY22 paramiko.sftp_file-module.html#PY22 paramiko.sftp_file.CMD_READLINK paramiko.sftp_file-module.html#CMD_READLINK +paramiko.sftp_file.__package__ paramiko.sftp_file-module.html#__package__ paramiko.sftp_file.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_file-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_file.MSG_NEWKEYS paramiko.sftp_file-module.html#MSG_NEWKEYS paramiko.sftp_file.MSG_USERAUTH_SUCCESS paramiko.sftp_file-module.html#MSG_USERAUTH_SUCCESS @@ -1051,6 +1083,7 @@ paramiko.sftp_handle.SFTP_BAD_MESSAGE paramiko.sftp_handle-module.html#SFTP_BAD_MESSAGE paramiko.sftp_handle.PY22 paramiko.sftp_handle-module.html#PY22 paramiko.sftp_handle.CMD_READLINK paramiko.sftp_handle-module.html#CMD_READLINK +paramiko.sftp_handle.__package__ paramiko.sftp_handle-module.html#__package__ paramiko.sftp_handle.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_handle-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_handle.MSG_NEWKEYS paramiko.sftp_handle-module.html#MSG_NEWKEYS paramiko.sftp_handle.MSG_USERAUTH_SUCCESS paramiko.sftp_handle-module.html#MSG_USERAUTH_SUCCESS @@ -1145,6 +1178,7 @@ paramiko.sftp_server.SFTP_BAD_MESSAGE paramiko.sftp_server-module.html#SFTP_BAD_MESSAGE paramiko.sftp_server.PY22 paramiko.sftp_server-module.html#PY22 paramiko.sftp_server.CMD_READLINK paramiko.sftp_server-module.html#CMD_READLINK +paramiko.sftp_server.__package__ paramiko.sftp_server-module.html#__package__ paramiko.sftp_server.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_server-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_server.MSG_NEWKEYS paramiko.sftp_server-module.html#MSG_NEWKEYS paramiko.sftp_server.MSG_USERAUTH_SUCCESS paramiko.sftp_server-module.html#MSG_USERAUTH_SUCCESS @@ -1240,6 +1274,7 @@ paramiko.sftp_si.SFTP_BAD_MESSAGE paramiko.sftp_si-module.html#SFTP_BAD_MESSAGE paramiko.sftp_si.PY22 paramiko.sftp_si-module.html#PY22 paramiko.sftp_si.CMD_READLINK paramiko.sftp_si-module.html#CMD_READLINK +paramiko.sftp_si.__package__ paramiko.sftp_si-module.html#__package__ paramiko.sftp_si.DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_si-module.html#DISCONNECT_AUTH_CANCELLED_BY_USER paramiko.sftp_si.MSG_NEWKEYS paramiko.sftp_si-module.html#MSG_NEWKEYS paramiko.sftp_si.MSG_USERAUTH_SUCCESS paramiko.sftp_si-module.html#MSG_USERAUTH_SUCCESS @@ -1314,6 +1349,7 @@ paramiko.sftp_si.MSG_CHANNEL_CLOSE paramiko.sftp_si-module.html#MSG_CHANNEL_CLOSE paramiko.sftp_si.MSG_CHANNEL_OPEN_SUCCESS paramiko.sftp_si-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.ssh_exception paramiko.ssh_exception-module.html +paramiko.ssh_exception.__package__ paramiko.ssh_exception-module.html#__package__ paramiko.transport paramiko.transport-module.html paramiko.transport.MSG_NAMES paramiko.transport-module.html#MSG_NAMES paramiko.transport.DISCONNECT_NO_MORE_AUTH_METHODS_AVAILABLE paramiko.transport-module.html#DISCONNECT_NO_MORE_AUTH_METHODS_AVAILABLE @@ -1337,7 +1373,6 @@ paramiko.transport.MSG_CHANNEL_EOF paramiko.transport-module.html#MSG_CHANNEL_EOF paramiko.transport.AUTH_FAILED paramiko.transport-module.html#AUTH_FAILED paramiko.transport.MSG_USERAUTH_PK_OK paramiko.transport-module.html#MSG_USERAUTH_PK_OK -paramiko.transport.MSG_REQUEST_SUCCESS paramiko.transport-module.html#MSG_REQUEST_SUCCESS paramiko.transport.AUTH_SUCCESSFUL paramiko.transport-module.html#AUTH_SUCCESSFUL paramiko.transport.MSG_CHANNEL_WINDOW_ADJUST paramiko.transport-module.html#MSG_CHANNEL_WINDOW_ADJUST paramiko.transport.MSG_CHANNEL_REQUEST paramiko.transport-module.html#MSG_CHANNEL_REQUEST @@ -1357,14 +1392,16 @@ paramiko.transport.MSG_CHANNEL_OPEN paramiko.transport-module.html#MSG_CHANNEL_OPEN paramiko.transport.MSG_USERAUTH_INFO_RESPONSE paramiko.transport-module.html#MSG_USERAUTH_INFO_RESPONSE paramiko.transport.MSG_REQUEST_FAILURE paramiko.transport-module.html#MSG_REQUEST_FAILURE +paramiko.transport.__package__ paramiko.transport-module.html#__package__ paramiko.transport.AUTH_PARTIALLY_SUCCESSFUL paramiko.transport-module.html#AUTH_PARTIALLY_SUCCESSFUL paramiko.transport.OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.transport-module.html#OPEN_FAILED_ADMINISTRATIVELY_PROHIBITED paramiko.transport.MSG_CHANNEL_FAILURE paramiko.transport-module.html#MSG_CHANNEL_FAILURE -paramiko.transport.MSG_CHANNEL_CLOSE paramiko.transport-module.html#MSG_CHANNEL_CLOSE +paramiko.transport.MSG_REQUEST_SUCCESS paramiko.transport-module.html#MSG_REQUEST_SUCCESS paramiko.transport.OPEN_FAILED_CONNECT_FAILED paramiko.transport-module.html#OPEN_FAILED_CONNECT_FAILED paramiko.transport.MSG_USERAUTH_REQUEST paramiko.transport-module.html#MSG_USERAUTH_REQUEST paramiko.transport._join_lingering_threads paramiko.transport-module.html#_join_lingering_threads paramiko.transport.MSG_SERVICE_REQUEST paramiko.transport-module.html#MSG_SERVICE_REQUEST +paramiko.transport.MSG_CHANNEL_CLOSE paramiko.transport-module.html#MSG_CHANNEL_CLOSE paramiko.transport.MSG_CHANNEL_OPEN_SUCCESS paramiko.transport-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.util paramiko.util-module.html paramiko.util.AUTH_SUCCESSFUL paramiko.util-module.html#AUTH_SUCCESSFUL @@ -1373,7 +1410,7 @@ paramiko.util.MSG_CHANNEL_WINDOW_ADJUST paramiko.util-module.html#MSG_CHANNEL_WINDOW_ADJUST paramiko.util.MSG_CHANNEL_REQUEST paramiko.util-module.html#MSG_CHANNEL_REQUEST paramiko.util.MSG_NAMES paramiko.util-module.html#MSG_NAMES -paramiko.util.log_to_file paramiko.util-module.html#log_to_file +paramiko.util.get_thread_id paramiko.util-module.html#get_thread_id paramiko.util.lookup_ssh_host_config paramiko.util-module.html#lookup_ssh_host_config paramiko.util.MSG_CHANNEL_OPEN paramiko.util-module.html#MSG_CHANNEL_OPEN paramiko.util.tb_strings paramiko.util-module.html#tb_strings @@ -1382,7 +1419,6 @@ paramiko.util.MSG_DISCONNECT paramiko.util-module.html#MSG_DISCONNECT paramiko.util.DISCONNECT_NO_MORE_AUTH_METHODS_AVAILABLE paramiko.util-module.html#DISCONNECT_NO_MORE_AUTH_METHODS_AVAILABLE paramiko.util.MSG_SERVICE_ACCEPT paramiko.util-module.html#MSG_SERVICE_ACCEPT -paramiko.util.get_thread_id paramiko.util-module.html#get_thread_id paramiko.util.MSG_IGNORE paramiko.util-module.html#MSG_IGNORE paramiko.util._g_thread_lock paramiko.util-module.html#_g_thread_lock paramiko.util.deflate_long paramiko.util-module.html#deflate_long @@ -1393,7 +1429,7 @@ paramiko.util.MSG_USERAUTH_FAILURE paramiko.util-module.html#MSG_USERAUTH_FAILURE paramiko.util.MSG_REQUEST_FAILURE paramiko.util-module.html#MSG_REQUEST_FAILURE paramiko.util.inflate_long paramiko.util-module.html#inflate_long -paramiko.util._g_thread_ids paramiko.util-module.html#_g_thread_ids +paramiko.util.__package__ paramiko.util-module.html#__package__ paramiko.util._g_thread_counter paramiko.util-module.html#_g_thread_counter paramiko.util.MSG_CHANNEL_DATA paramiko.util-module.html#MSG_CHANNEL_DATA paramiko.util.CRITICAL paramiko.util-module.html#CRITICAL @@ -1404,6 +1440,7 @@ paramiko.util.unhexify paramiko.util-module.html#unhexify paramiko.util.MSG_CHANNEL_OPEN_FAILURE paramiko.util-module.html#MSG_CHANNEL_OPEN_FAILURE paramiko.util.MSG_USERAUTH_INFO_REQUEST paramiko.util-module.html#MSG_USERAUTH_INFO_REQUEST +paramiko.util.log_to_file paramiko.util-module.html#log_to_file paramiko.util.MSG_DEBUG paramiko.util-module.html#MSG_DEBUG paramiko.util.MSG_CHANNEL_FAILURE paramiko.util-module.html#MSG_CHANNEL_FAILURE paramiko.util.OPEN_SUCCEEDED paramiko.util-module.html#OPEN_SUCCEEDED @@ -1436,15 +1473,17 @@ paramiko.util.randpool paramiko.util-module.html#randpool paramiko.util.MSG_CHANNEL_OPEN_SUCCESS paramiko.util-module.html#MSG_CHANNEL_OPEN_SUCCESS paramiko.util.MSG_CHANNEL_EOF paramiko.util-module.html#MSG_CHANNEL_EOF +paramiko.util._g_thread_ids paramiko.util-module.html#_g_thread_ids paramiko.util.MSG_USERAUTH_SUCCESS paramiko.util-module.html#MSG_USERAUTH_SUCCESS paramiko.util.CONNECTION_FAILED_CODE paramiko.util-module.html#CONNECTION_FAILED_CODE paramiko.win_pageant paramiko.win_pageant-module.html paramiko.win_pageant.win32con_WM_COPYDATA paramiko.win_pageant-module.html#win32con_WM_COPYDATA paramiko.win_pageant._AGENT_MAX_MSGLEN paramiko.win_pageant-module.html#_AGENT_MAX_MSGLEN paramiko.win_pageant._query_pageant paramiko.win_pageant-module.html#_query_pageant -paramiko.win_pageant._has_win32all paramiko.win_pageant-module.html#_has_win32all +paramiko.win_pageant.__package__ paramiko.win_pageant-module.html#__package__ paramiko.win_pageant._AGENT_COPYDATA_ID paramiko.win_pageant-module.html#_AGENT_COPYDATA_ID paramiko.win_pageant._get_pageant_window_object paramiko.win_pageant-module.html#_get_pageant_window_object +paramiko.win_pageant._has_win32all paramiko.win_pageant-module.html#_has_win32all paramiko.win_pageant._has_ctypes paramiko.win_pageant-module.html#_has_ctypes paramiko.win_pageant.can_talk_to_agent paramiko.win_pageant-module.html#can_talk_to_agent paramiko.Agent paramiko.Agent-class.html @@ -1481,10 +1520,10 @@ paramiko.BadAuthenticationType.allowed_types paramiko.BadAuthenticationType-class.html#allowed_types paramiko.BadAuthenticationType.__init__ paramiko.BadAuthenticationType-class.html#__init__ paramiko.BadHostKeyException paramiko.BadHostKeyException-class.html -paramiko.BadHostKeyException.hostname paramiko.BadHostKeyException-class.html#hostname paramiko.BadHostKeyException.expected_key paramiko.BadHostKeyException-class.html#expected_key -paramiko.BadHostKeyException.key paramiko.BadHostKeyException-class.html#key paramiko.BadHostKeyException.__init__ paramiko.BadHostKeyException-class.html#__init__ +paramiko.BadHostKeyException.hostname paramiko.BadHostKeyException-class.html#hostname +paramiko.BadHostKeyException.key paramiko.BadHostKeyException-class.html#key paramiko.BufferedFile paramiko.BufferedFile-class.html paramiko.BufferedFile.xreadlines paramiko.BufferedFile-class.html#xreadlines paramiko.BufferedFile.readlines paramiko.BufferedFile-class.html#readlines @@ -1533,6 +1572,7 @@ paramiko.Channel.__init__ paramiko.Channel-class.html#__init__ paramiko.Channel._set_closed paramiko.Channel-class.html#_set_closed paramiko.Channel.exit_status_ready paramiko.Channel-class.html#exit_status_ready +paramiko.Channel.request_x11 paramiko.Channel-class.html#request_x11 paramiko.Channel.recv_ready paramiko.Channel-class.html#recv_ready paramiko.Channel._feed_extended paramiko.Channel-class.html#_feed_extended paramiko.Channel.shutdown_write paramiko.Channel-class.html#shutdown_write @@ -1548,7 +1588,7 @@ paramiko.Channel._request_success paramiko.Channel-class.html#_request_success paramiko.Channel._send_eof paramiko.Channel-class.html#_send_eof paramiko.Channel._window_adjust paramiko.Channel-class.html#_window_adjust -paramiko.Channel.request_x11 paramiko.Channel-class.html#request_x11 +paramiko.Channel._event_pending paramiko.Channel-class.html#_event_pending paramiko.Channel.__del__ paramiko.Channel-class.html#__del__ paramiko.Channel._check_add_window paramiko.Channel-class.html#_check_add_window paramiko.Channel.invoke_subsystem paramiko.Channel-class.html#invoke_subsystem @@ -1736,12 +1776,12 @@ paramiko.SFTPAttributes.FLAG_PERMISSIONS paramiko.SFTPAttributes-class.html#FLAG_PERMISSIONS paramiko.SFTPAttributes._unpack paramiko.SFTPAttributes-class.html#_unpack paramiko.SFTPAttributes.from_stat paramiko.SFTPAttributes-class.html#from_stat -paramiko.SFTPAttributes._from_msg paramiko.SFTPAttributes-class.html#_from_msg -paramiko.SFTPAttributes._rwx paramiko.SFTPAttributes-class.html#_rwx paramiko.SFTPAttributes.FLAG_UIDGID paramiko.SFTPAttributes-class.html#FLAG_UIDGID +paramiko.SFTPAttributes._rwx paramiko.SFTPAttributes-class.html#_rwx paramiko.SFTPAttributes._debug_str paramiko.SFTPAttributes-class.html#_debug_str paramiko.SFTPAttributes.FLAG_SIZE paramiko.SFTPAttributes-class.html#FLAG_SIZE paramiko.SFTPAttributes.__repr__ paramiko.SFTPAttributes-class.html#__repr__ +paramiko.SFTPAttributes._from_msg paramiko.SFTPAttributes-class.html#_from_msg paramiko.SFTPClient paramiko.SFTPClient-class.html paramiko.SFTPClient.rename paramiko.SFTPClient-class.html#rename paramiko.SFTPClient._request paramiko.SFTPClient-class.html#_request @@ -1831,16 +1871,16 @@ paramiko.SFTPFile.settimeout paramiko.SFTPFile-class.html#settimeout paramiko.SFTPFile._prefetch_thread paramiko.SFTPFile-class.html#_prefetch_thread paramiko.SFTPHandle paramiko.SFTPHandle-class.html -paramiko.SFTPHandle._get_next_files paramiko.SFTPHandle-class.html#_get_next_files -paramiko.SFTPHandle.stat paramiko.SFTPHandle-class.html#stat -paramiko.SFTPHandle.read paramiko.SFTPHandle-class.html#read +paramiko.SFTPHandle._set_files paramiko.SFTPHandle-class.html#_set_files +paramiko.SFTPHandle.close paramiko.SFTPHandle-class.html#close +paramiko.SFTPHandle.__init__ paramiko.SFTPHandle-class.html#__init__ paramiko.SFTPHandle.write paramiko.SFTPHandle-class.html#write paramiko.SFTPHandle._get_name paramiko.SFTPHandle-class.html#_get_name paramiko.SFTPHandle.chattr paramiko.SFTPHandle-class.html#chattr -paramiko.SFTPHandle._set_files paramiko.SFTPHandle-class.html#_set_files paramiko.SFTPHandle._set_name paramiko.SFTPHandle-class.html#_set_name -paramiko.SFTPHandle.close paramiko.SFTPHandle-class.html#close -paramiko.SFTPHandle.__init__ paramiko.SFTPHandle-class.html#__init__ +paramiko.SFTPHandle.stat paramiko.SFTPHandle-class.html#stat +paramiko.SFTPHandle.read paramiko.SFTPHandle-class.html#read +paramiko.SFTPHandle._get_next_files paramiko.SFTPHandle-class.html#_get_next_files paramiko.SFTPServer paramiko.SFTPServer-class.html paramiko.SFTPServer.start_subsystem paramiko.SFTPServer-class.html#start_subsystem paramiko.SFTPServer._send_handle_response paramiko.SFTPServer-class.html#_send_handle_response @@ -2167,6 +2207,10 @@ paramiko.transport.ChannelMap.put paramiko.transport.ChannelMap-class.html#put paramiko.transport.ChannelMap.__len__ paramiko.transport.ChannelMap-class.html#__len__ paramiko.transport.ChannelMap.delete paramiko.transport.ChannelMap-class.html#delete +paramiko.util.Counter paramiko.util.Counter-class.html +paramiko.util.Counter.__call__ paramiko.util.Counter-class.html#__call__ +paramiko.util.Counter.new paramiko.util.Counter-class.html#new +paramiko.util.Counter.__init__ paramiko.util.Counter-class.html#__init__ paramiko.util.PFilter paramiko.util.PFilter-class.html paramiko.util.PFilter.filter paramiko.util.PFilter-class.html#filter paramiko.util.enumerate paramiko.util.enumerate-class.html diff -Nru paramiko-1.7.4/docs/bug-index.html paramiko-1.7.6/docs/bug-index.html --- paramiko-1.7.4/docs/bug-index.html 2008-07-06 17:30:24.000000000 +0100 +++ paramiko-1.7.6/docs/bug-index.html 2009-11-02 06:14:14.000000000 +0000 @@ -85,7 +85,7 @@ @@ -4674,15 +4676,15 @@ (in paramiko.sftp) - + - @@ -4690,7 +4692,7 @@ (in paramiko.sftp_client) - @@ -4698,143 +4700,144 @@ (in paramiko.sftp_file) - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - - + + - - + + - - + + + + + + + - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - + - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - + + - + - - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - + - - + - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - + + - + - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
- Generated by Epydoc 3.0.1 on Sun Jul 6 18:30:25 2008 + Generated by Epydoc 3.0.1 on Sun Nov 1 22:14:14 2009 -
  • paramiko.rng_posix.error -
  • paramiko.rng_win32.error
    • +
  • paramiko.rng_posix.error +
    • @@ -191,6 +191,9 @@
  • paramiko.transport.ChannelMap
    • +
  • paramiko.util.Counter: + Stateful counter for CTR mode crypto +
  • paramiko.logging22.Formatter
  • paramiko.kex_gex.KexGex @@ -346,7 +349,7 @@ - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - - + +
    - Generated by Epydoc 3.0.1 on Sun Jul 6 18:30:25 2008 + Generated by Epydoc 3.0.1 on Sun Nov 1 22:14:14 2009
    - Generated by Epydoc 3.0.1 on Sun Jul 6 18:30:25 2008 + Generated by Epydoc 3.0.1 on Sun Nov 1 22:14:14 2009 (in paramiko.sftp_client) CMD_READLINK
    (in paramiko.sftp_server)    		CRITICAL
    -(in paramiko.auth_handler)    		Counter
    +(in paramiko.util)
    CMD_EXTENDED
    (in paramiko.sftp_file)    		 CMD_READLINK
    (in paramiko.sftp_si)    		CRITICAL
    -(in paramiko.channel)    		CRITICAL
    +(in paramiko.auth_handler)
    CMD_EXTENDED
    (in paramiko.sftp_handle)    		 CMD_REALPATH
    (in paramiko.sftp)    		CRITICAL
    -(in paramiko.client)    		CRITICAL
    +(in paramiko.channel)
    CMD_EXTENDED
    (in paramiko.sftp_server)    		 CMD_REALPATH
    (in paramiko.sftp_attr)    		CRITICAL
    -(in paramiko.common)    		CRITICAL
    +(in paramiko.client)
    CMD_EXTENDED
    (in paramiko.sftp_si)    		 CMD_REALPATH
    (in paramiko.sftp_client)    		CRITICAL
    -(in paramiko.dsskey)    		CRITICAL
    +(in paramiko.common)
    CMD_EXTENDED_REPLY
    (in paramiko.sftp)    		 CMD_REALPATH
    (in paramiko.sftp_file)    		CRITICAL
    -(in paramiko.hostkeys)    		CRITICAL
    +(in paramiko.dsskey)
    CMD_EXTENDED_REPLY
    (in paramiko.sftp_attr)    		 CMD_REALPATH
    (in paramiko.sftp_handle)    		CRITICAL
    -(in paramiko.kex_gex)    		CRITICAL
    +(in paramiko.hostkeys)
    CMD_EXTENDED_REPLY
    (in paramiko.sftp_client)    		 CMD_REALPATH
    (in paramiko.sftp_server)    		CRITICAL
    -(in paramiko.kex_group1)    		CRITICAL
    +(in paramiko.kex_gex)
    CMD_EXTENDED_REPLY
    (in paramiko.sftp_file)    		 CMD_REALPATH
    (in paramiko.sftp_si)    		CRITICAL
    -(in paramiko.logging22)    		CRITICAL
    +(in paramiko.kex_group1)
    CMD_EXTENDED_REPLY
    (in paramiko.sftp_handle)    		 CMD_REMOVE
    (in paramiko.sftp)    		CRITICAL
    -(in paramiko.packet)    		CRITICAL
    +(in paramiko.logging22)
    CMD_EXTENDED_REPLY
    (in paramiko.sftp_server)    		 CMD_REMOVE
    (in paramiko.sftp_attr)    		CRITICAL
    -(in paramiko.pkey)    		CRITICAL
    +(in paramiko.packet)
    CMD_EXTENDED_REPLY
    (in paramiko.sftp_si)    		 CMD_REMOVE
    (in paramiko.sftp_client)    		CRITICAL
    -(in paramiko.rsakey)    		CRITICAL
    +(in paramiko.pkey)
    CMD_FSETSTAT
    (in paramiko.sftp)    		 CMD_REMOVE
    (in paramiko.sftp_file)    		CRITICAL
    -(in paramiko.server)    		CRITICAL
    +(in paramiko.rsakey)
    CMD_FSETSTAT
    (in paramiko.sftp_attr)    		 CMD_REMOVE
    (in paramiko.sftp_handle)    		CRITICAL
    -(in paramiko.sftp)    		CRITICAL
    +(in paramiko.server)
    CMD_FSETSTAT
    (in paramiko.sftp_client)    		 CMD_REMOVE
    (in paramiko.sftp_server)    		CRITICAL
    -(in paramiko.sftp_attr)    		CRITICAL
    +(in paramiko.sftp)
    CMD_FSETSTAT
    (in paramiko.sftp_file)    		 CMD_REMOVE
    (in paramiko.sftp_si)    		CRITICAL
    -(in paramiko.sftp_client)    		CRITICAL
    +(in paramiko.sftp_attr)
    CMD_FSETSTAT
    (in paramiko.sftp_handle)    		 CMD_RENAME
    (in paramiko.sftp)    		CRITICAL
    -(in paramiko.sftp_file)    		CRITICAL
    +(in paramiko.sftp_client)
    CMD_FSETSTAT
    (in paramiko.sftp_server)    		 CMD_RENAME
    (in paramiko.sftp_attr)    		CRITICAL
    -(in paramiko.sftp_handle)    		CRITICAL
    +(in paramiko.sftp_file)
    CMD_FSETSTAT
    (in paramiko.sftp_si)    		 CMD_RENAME
    (in paramiko.sftp_client)    		CRITICAL
    -(in paramiko.sftp_server)    		CRITICAL
    +(in paramiko.sftp_handle)
    CMD_FSTAT
    (in paramiko.sftp)    		 CMD_RENAME
    (in paramiko.sftp_file)    		CRITICAL
    -(in paramiko.sftp_si)    		CRITICAL
    +(in paramiko.sftp_server)
    CMD_FSTAT
    (in paramiko.sftp_attr)    		 CMD_RENAME
    (in paramiko.sftp_handle)    		CRITICAL
    -(in paramiko.transport)    		CRITICAL
    +(in paramiko.sftp_si)
    CMD_FSTAT
    (in paramiko.sftp_client)    		 CMD_RENAME
    (in paramiko.sftp_server)    		CRITICAL
    -(in paramiko.util)    		CRITICAL
    +(in paramiko.transport)
    CMD_FSTAT
    (in paramiko.sftp_file)    		 CMD_RENAME
    (in paramiko.sftp_si)    		 CRITICAL
    +(in paramiko.util)
    CMD_FSTAT
    @@ -3692,15 +3693,16 @@ (in KexGex)    		 NeedRekeyException
    (in paramiko.packet)    		normalize()
    -(in SFTPClient)    		next()
    +(in BufferedFile)
    name
    (in KexGroup1)    		next()
    -(in BufferedFile)    		 new()
    +(in Counter)    		normalize()
    +(in SFTPClient)
    • SFTP_FLAG_TRUNC
    (in paramiko.sftp_file)    		SSHClient
    -(in paramiko)    		SSH_PORT
    +(in paramiko.client)
    SFTP_BAD_MESSAGE
    (in paramiko.sftp_attr)    		 SFTP_FLAG_TRUNC
    (in paramiko.sftp_handle)    		SSHConfig
    +    		SSHClient
    (in paramiko)
    SFTP_FLAG_TRUNC
    (in paramiko.sftp_server)    		SSHException
    +    		SSHConfig
    (in paramiko)
    SFTP_FLAG_TRUNC
    (in paramiko.sftp_si)    		start_client()
    -(in Transport)    		SSHException
    +(in paramiko)
    SFTP_BAD_MESSAGE
    (in paramiko.sftp_handle)    		 SFTP_FLAG_WRITE
    (in paramiko.sftp)    		start_kex()
    -(in KexGex)    		start_client()
    +(in Transport)
    SFTP_BAD_MESSAGE
    (in paramiko.sftp_server)    		 SFTP_FLAG_WRITE
    (in paramiko.sftp_attr)    		start_kex()
    -(in KexGroup1)    		start_kex()
    +(in KexGex)
    SFTP_BAD_MESSAGE
    (in paramiko.sftp_si)    		 SFTP_FLAG_WRITE
    (in paramiko.sftp_client)    		start_server()
    -(in Transport)    		start_kex()
    +(in KexGroup1)
    sftp_client
    (in paramiko)    		 SFTP_FLAG_WRITE
    (in paramiko.sftp_file)    		start_subsystem()
    -(in SFTPServer)    		start_server()
    +(in Transport)
    SFTP_CONNECTION_LOST
    (in paramiko.sftp)    		 SFTP_FLAG_WRITE
    (in paramiko.sftp_handle)    		start_subsystem()
    -(in SubsystemHandler)    		start_subsystem()
    +(in SFTPServer)
    SFTP_CONNECTION_LOST
    (in paramiko.sftp_attr)    		 SFTP_FLAG_WRITE
    (in paramiko.sftp_server)    		stat()
    -(in SFTPClient)    		start_subsystem()
    +(in SubsystemHandler)
    SFTP_CONNECTION_LOST
    (in paramiko.sftp_client)    		 SFTP_FLAG_WRITE
    (in paramiko.sftp_si)    		stat()
    -(in SFTPFile)    		stat()
    +(in SFTPClient)
    SFTP_CONNECTION_LOST
    (in paramiko.sftp_file)    		 sftp_handle
    (in paramiko)    		stat()
    -(in SFTPHandle)    		stat()
    +(in SFTPFile)
    SFTP_CONNECTION_LOST
    (in paramiko.sftp_handle)    		 SFTP_NO_CONNECTION
    (in paramiko.sftp)    		stat()
    -(in SFTPServerInterface)    		stat()
    +(in SFTPHandle)
    SFTP_CONNECTION_LOST
    (in paramiko.sftp_server)    		 SFTP_NO_CONNECTION
    (in paramiko.sftp_attr)    		stir()
    -(in StrongLockingRandomPool)    		stat()
    +(in SFTPServerInterface)
    SFTP_CONNECTION_LOST
    (in paramiko.sftp_si)    		 SFTP_NO_CONNECTION
    (in paramiko.sftp_client)    		stop_thread()
    -(in Transport)    		stir()
    +(in StrongLockingRandomPool)
    SFTP_DESC
    (in paramiko.sftp)    		 SFTP_NO_CONNECTION
    (in paramiko.sftp_file)    		StreamHandler
    -(in paramiko.logging22)    		stop_thread()
    +(in Transport)
    SFTP_DESC
    (in paramiko.sftp_attr)    		 SFTP_NO_CONNECTION
    (in paramiko.sftp_handle)    		StrongLockingRandomPool
    -(in paramiko.rng)    		StreamHandler
    +(in paramiko.logging22)
    SFTP_DESC
    (in paramiko.sftp_client)    		 SFTP_NO_CONNECTION
    (in paramiko.sftp_server)    		SubsystemHandler
    -(in paramiko)    		StrongLockingRandomPool
    +(in paramiko.rng)
    SFTP_DESC
    (in paramiko.sftp_file)    		 SFTP_NO_CONNECTION
    (in paramiko.sftp_si)    		symlink()
    -(in SFTPClient)    		SubsystemHandler
    +(in paramiko)
    SFTP_DESC
    (in paramiko.sftp_handle)    		 SFTP_NO_SUCH_FILE
    (in paramiko.sftp)    		symlink()
    -(in SFTPServerInterface)    		symlink()
    +(in SFTPClient)
    SFTP_DESC
    (in paramiko.sftp_server)    		 SFTP_NO_SUCH_FILE
    (in paramiko.sftp_attr)    		 symlink()
    +(in SFTPServerInterface)
    SFTP_DESC
    @@ -5044,331 +5047,441 @@
    __author__
    (in paramiko)    		__init__()
    -(in Formatter)    		_CLIENT_ID
    -(in Transport)    		__iter__()
    +(in BufferedFile)    		__str__()
    +(in PKey)
    __call__()
    (in ZlibCompressor)    		__init__()
    -(in StreamHandler)    		_compression_info
    -(in Transport)    		__iter__()
    +(in enumerate)    		__str__()
    +(in RSAKey)
    __call__()
    (in ZlibDecompressor)    		__init__()
    -(in logger)    		_DEFAULT_BUFSIZE
    -(in BufferedFile)    		__len__()
    +(in BufferedPipe)    		__str__()
    +(in SFTPAttributes)
    __call__()
    +(in Counter)    		__len__()
    +(in ChannelMap)    		__str__()
    +(in BER)
    __cmp__()
    (in PKey)    		__init__()
    -(in OrPipe)    		_g_thread_counter
    -(in paramiko.util)    		__license__
    +(in paramiko)    		__version__
    +(in paramiko)
    __del__()
    (in BufferedFile)    		__init__()
    -(in PosixPipe)    		_g_thread_ids
    -(in paramiko.util)    		__package__
    +(in paramiko)    		__version_info__
    +(in paramiko)
    __del__()
    (in Channel)    		__init__()
    -(in WindowsPipe)    		_g_thread_lock
    -(in paramiko.util)    		__package__
    +(in paramiko.agent)    		_active_threads
    +(in paramiko.transport)
    __del__()
    (in SFTPFile)    		__init__()
    -(in ModulusPack)    		_get_ciphers()
    -(in SecurityOptions)    		__package__
    +(in paramiko.auth_handler)    		_AGENT_COPYDATA_ID
    +(in paramiko.win_pageant)
    __getitem__()
    (in HostKeys)    		__init__()
    -(in StrongLockingRandomPool)    		_get_compression()
    -(in SecurityOptions)    		__package__
    +(in paramiko.ber)    		_AGENT_MAX_MSGLEN
    +(in paramiko.win_pageant)
    __hash__()
    (in DSSKey)    		__init__()
    -(in PartialAuthentication)    		_get_digests()
    -(in SecurityOptions)    		__package__
    +(in paramiko.buffered_pipe)    		_channel_handler_table
    +(in Transport)
    __hash__()
    (in RSAKey)    		__init__()
    -(in ChannelMap)    		_get_kex()
    -(in SecurityOptions)    		__package__
    +(in paramiko.channel)    		_cipher_info
    +(in Transport)
    __init__()
    (in Agent)    		__init__()
    -(in enumerate)    		_get_key_types()
    -(in SecurityOptions)    		__package__
    +(in paramiko.client)    		_CIPHER_TABLE
    +(in PKey)
    __init__()
    (in AgentKey)    		__init__()
    -(in PageantConnection)    		_handler_table
    +    		__package__
    +(in paramiko.common)    		_CLIENT_ID
    (in Transport)
    __init__()
    (in BadAuthenticationType)    		__iter__()
    -(in BufferedFile)    		_has_ctypes
    -(in paramiko.win_pageant)    		__package__
    +(in paramiko.compress)    		_compression_info
    +(in Transport)
    __init__()
    (in BadHostKeyException)    		__iter__()
    -(in enumerate)    		_has_win32all
    -(in paramiko.win_pageant)    		__package__
    +(in paramiko.config)    		_DEFAULT_BUFSIZE
    +(in BufferedFile)
    __init__()
    (in BufferedFile)    		__len__()
    -(in BufferedPipe)    		_hash_class
    -(in paramiko.sftp_server)    		__package__
    +(in paramiko.dsskey)    		_g_thread_counter
    +(in paramiko.util)
    __init__()
    (in Channel)    		__len__()
    -(in ChannelMap)    		_kex_info
    -(in Transport)    		__package__
    +(in paramiko.file)    		_g_thread_ids
    +(in paramiko.util)
    __init__()
    (in ChannelException)    		__license__
    -(in paramiko)    		_key_info
    -(in Transport)    		__package__
    +(in paramiko.hostkeys)    		_g_thread_lock
    +(in paramiko.util)
    __init__()
    (in DSSKey)    		__repr__()
    -(in Channel)    		_logger
    -(in paramiko.logging22)    		__package__
    +(in paramiko.kex_gex)    		_get_ciphers()
    +(in SecurityOptions)
    __init__()
    (in HostKeys)    		__repr__()
    -(in Message)    		_mac_info
    -(in Transport)    		__package__
    +(in paramiko.kex_group1)    		_get_compression()
    +(in SecurityOptions)
    __init__()
    (in Message)    		__repr__()
    -(in SFTPAttributes)    		_modulus_pack
    -(in Transport)    		__package__
    +(in paramiko.logging22)    		_get_digests()
    +(in SecurityOptions)
    __init__()
    (in PKey)    		__repr__()
    +    		__package__
    +(in paramiko.message)    		_get_kex()
    (in SecurityOptions)    		_MSG_KEXDH_GEX_GROUP
    -(in paramiko.kex_gex)
    __init__()
    (in RSAKey)    		__repr__()
    -(in Transport)    		_MSG_KEXDH_GEX_INIT
    -(in paramiko.kex_gex)    		__package__
    +(in paramiko.packet)    		_get_key_types()
    +(in SecurityOptions)
    __init__()
    (in SFTPAttributes)    		__repr__()
    -(in BER)    		_MSG_KEXDH_GEX_REPLY
    -(in paramiko.kex_gex)    		__package__
    +(in paramiko.pipe)    		_handler_table
    +(in Transport)
    __init__()
    (in SFTPClient)    		__repr__()
    -(in HostKeyEntry)    		_MSG_KEXDH_GEX_REQUEST
    -(in paramiko.kex_gex)    		__package__
    +(in paramiko.pkey)    		_has_ctypes
    +(in paramiko.win_pageant)
    __init__()
    (in SFTPFile)    		__setitem__()
    -(in HostKeys)    		_MSG_KEXDH_GEX_REQUEST_OLD
    -(in paramiko.kex_gex)    		__package__
    +(in paramiko.primes)    		_has_win32all
    +(in paramiko.win_pageant)
    __init__()
    (in SFTPHandle)    		__str__()
    -(in AgentKey)    		_MSG_KEXDH_INIT
    -(in paramiko.kex_group1)    		__package__
    +(in paramiko.resource)    		_hash_class
    +(in paramiko.sftp_server)
    __init__()
    (in SFTPServer)    		__str__()
    -(in BadAuthenticationType)    		_MSG_KEXDH_REPLY
    -(in paramiko.kex_group1)    		__package__
    +(in paramiko.rng)    		_kex_info
    +(in Transport)
    __init__()
    (in SFTPServerInterface)    		__str__()
    -(in DSSKey)    		_pfilter
    -(in paramiko.util)    		__package__
    +(in paramiko.rng_posix)    		_key_info
    +(in Transport)
    __init__()
    (in SSHClient)    		__str__()
    -(in Message)    		_preferred_ciphers
    -(in Transport)    		__package__
    +(in paramiko.rng_win32)    		_logger
    +(in paramiko.logging22)
    __init__()
    (in SSHConfig)    		__str__()
    -(in PKey)    		_preferred_compression
    +    		__package__
    +(in paramiko.rsakey)    		_mac_info
    (in Transport)
    __init__()
    (in SecurityOptions)    		__str__()
    -(in RSAKey)    		_preferred_kex
    +    		__package__
    +(in paramiko.server)    		_modulus_pack
    (in Transport)
    __init__()
    (in SubsystemHandler)    		__str__()
    -(in SFTPAttributes)    		_preferred_keys
    -(in Transport)    		__package__
    +(in paramiko.sftp)    		_MSG_KEXDH_GEX_GROUP
    +(in paramiko.kex_gex)
    __init__()
    (in Transport)    		__str__()
    -(in BER)    		_preferred_macs
    -(in Transport)    		__package__
    +(in paramiko.sftp_attr)    		_MSG_KEXDH_GEX_INIT
    +(in paramiko.kex_gex)
    __init__()
    (in BER)    		__version__
    -(in paramiko)    		_PROTO_ID
    -(in Transport)    		__package__
    +(in paramiko.sftp_client)    		_MSG_KEXDH_GEX_REPLY
    +(in paramiko.kex_gex)
    __init__()
    (in BufferedPipe)    		__version_info__
    -(in paramiko)    		_set_ciphers()
    -(in SecurityOptions)    		__package__
    +(in paramiko.sftp_file)    		_MSG_KEXDH_GEX_REQUEST
    +(in paramiko.kex_gex)
    __init__()
    (in ChannelStderrFile)    		_active_threads
    -(in paramiko.transport)    		_set_compression()
    -(in SecurityOptions)    		__package__
    +(in paramiko.sftp_handle)    		_MSG_KEXDH_GEX_REQUEST_OLD
    +(in paramiko.kex_gex)
    __init__()
    (in ZlibCompressor)    		_AGENT_COPYDATA_ID
    -(in paramiko.win_pageant)    		_set_digests()
    -(in SecurityOptions)    		__package__
    +(in paramiko.sftp_server)    		_MSG_KEXDH_INIT
    +(in paramiko.kex_group1)
    __init__()
    (in ZlibDecompressor)    		_AGENT_MAX_MSGLEN
    -(in paramiko.win_pageant)    		_set_kex()
    -(in SecurityOptions)    		__package__
    +(in paramiko.sftp_si)    		_MSG_KEXDH_REPLY
    +(in paramiko.kex_group1)
    __init__()
    (in HostKeyEntry)    		_channel_handler_table
    -(in Transport)    		_set_key_types()
    -(in SecurityOptions)    		__package__
    +(in paramiko.ssh_exception)    		_pfilter
    +(in paramiko.util)
    __init__()
    (in KexGex)    		_cipher_info
    +    		__package__
    +(in paramiko.transport)    		_preferred_ciphers
    (in Transport)    		_VERSION
    -(in paramiko.sftp)
    __init__()
    (in KexGroup1)    		_CIPHER_TABLE
    -(in PKey)    		__package__
    +(in paramiko.util)    		_preferred_compression
    +(in Transport)
    __init__()
    +(in Formatter)    		__package__
    +(in paramiko.win_pageant)    		_preferred_kex
    +(in Transport)
    __init__()
    +(in StreamHandler)    		__repr__()
    +(in Channel)    		_preferred_keys
    +(in Transport)
    __init__()
    +(in logger)    		__repr__()
    +(in Message)    		_preferred_macs
    +(in Transport)
    __init__()
    +(in OrPipe)    		__repr__()
    +(in SFTPAttributes)    		_PROTO_ID
    +(in Transport)
    __init__()
    +(in PosixPipe)    		__repr__()
    +(in SecurityOptions)    		_set_ciphers()
    +(in SecurityOptions)
    __init__()
    +(in WindowsPipe)    		__repr__()
    +(in Transport)    		_set_compression()
    +(in SecurityOptions)
    __init__()
    +(in ModulusPack)    		__repr__()
    +(in BER)    		_set_digests()
    +(in SecurityOptions)
    __init__()
    +(in StrongLockingRandomPool)    		__repr__()
    +(in HostKeyEntry)    		_set_kex()
    +(in SecurityOptions)
    __init__()
    +(in PartialAuthentication)    		__setitem__()
    +(in HostKeys)    		_set_key_types()
    +(in SecurityOptions)
    __init__()
    +(in ChannelMap)    		__str__()
    +(in AgentKey)    		_VERSION
    +(in paramiko.sftp)
    __init__()
    +(in Counter)    		__str__()
    +(in BadAuthenticationType)    		 _winrandom
    (in paramiko.rng_win32)
    __init__()
    +(in enumerate)    		__str__()
    +(in DSSKey)    		 
    __init__()
    +(in PageantConnection)    		__str__()
    +(in Message)    		 
    @@ -5398,7 +5511,7 @@ @@ -374,7 +377,7 @@
    - Generated by Epydoc 3.0.1 on Sun Jul 6 18:30:25 2008 + Generated by Epydoc 3.0.1 on Sun Nov 1 22:14:14 2009
    - Generated by Epydoc 3.0.1 on Sun Jul 6 18:30:25 2008 + Generated by Epydoc 3.0.1 on Sun Nov 1 22:14:14 2009
    - Generated by Epydoc 3.0.1 on Sun Jul 6 18:30:28 2008 + Generated by Epydoc 3.0.1 on Sun Nov 1 22:14:15 2009

    Inherited from object: __delattr__, + __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, - __setattr__ + __setattr__, + __sizeof__, + __subclasshook__

    + + +
    - Generated by Epydoc 3.0.1 on Sun Jul 6 18:30:28 2008 + Generated by Epydoc 3.0.1 on Sun Nov 1 22:14:15 2009 SSH2_AGENT_SIGN_RESPONSE = 14
    +   + + __package__ = 'paramiko' +
    - Generated by Epydoc 3.0.1 on Sun Jul 6 18:30:26 2008 + Generated by Epydoc 3.0.1 on Sun Nov 1 22:14:15 2009 Source Code for Module paramiko.agent 
       1  # Copyright (C) 2003-2007  John Rochester <john@jrochester.org> 
-  2  # 
-  3  # This file is part of paramiko. 
-  4  # 
-  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
-  6  # terms of the GNU Lesser General Public License as published by the Free 
-  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
-  8  # any later version. 
-  9  # 
- 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
- 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
- 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
- 13  # details. 
- 14  # 
- 15  # You should have received a copy of the GNU Lesser General Public License 
- 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
- 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
- 18   
+  2  # 
+  3  # This file is part of paramiko. 
+  4  # 
+  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
+  6  # terms of the GNU Lesser General Public License as published by the Free 
+  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
+  8  # any later version. 
+  9  # 
+ 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
+ 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
+ 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
+ 13  # details. 
+ 14  # 
+ 15  # You should have received a copy of the GNU Lesser General Public License 
+ 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
+ 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
+ 18   
  19  """ 
  20  SSH Agent interface for Unix clients. 
  21  """ 
@@ -119,7 +119,7 @@
 paramiko.Transport.connect" class="py-name" href="#" onclick="return doclink('link-14', 'connect', 'link-14');">connect(os.environ['SSH_AUTH_SOCK']) 
  63              except: 
  64                  # probably a dangling env var: the ssh agent is gone 
- 65                  return 
+ 65                  return 
  66              self.conn = conn 
  67          elif sys.platform == 'win32': 
  68              import win_pageant 
@@ -129,7 +129,7 @@
  72                  return 
  73          else: 
  74              # no agent support 
- 75              return 
+ 75              return 
  76               
  77          ptype, result = self._send_message(chr(SSH2_AGENTC_REQUEST_IDENTITIES)) 
  78          if ptype != SSH2_AGENT_IDENTITIES_ANSWER: 
@@ -255,7 +255,7 @@
 
@@ -158,7 +163,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:33 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:20 2009
     
     
       __delattr__,
       __getattribute__,
       __getitem__,
+      __getslice__,
       __reduce__,
       __repr__,
       __setattr__,
       __setstate__,
-      __str__
+      __str__,
+      __unicode__
       
    
     
    Inherited from object:
+      __format__,
       __hash__,
-      __reduce_ex__
+      __reduce_ex__,
+      __sizeof__,
+      __subclasshook__
       
    
         		
   
    
+  
+
+    
@@ -502,7 +509,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:28 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:16 2009
     
     
       
        
     
+        __package__ = 'paramiko'
+    
    
+       
+    
         randpool = StrongLockingRandomPool()
     
   
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:26 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:15 2009
     
     
       
 
    Source Code for Module paramiko.auth_handler
    
 
    -  1  # Copyright (C) 2003-2007  Robey Pointer <robey@lag.net> 
-  2  # 
-  3  # This file is part of paramiko. 
-  4  # 
-  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
-  6  # terms of the GNU Lesser General Public License as published by the Free 
-  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
-  8  # any later version. 
-  9  # 
- 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
- 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
- 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
- 13  # details. 
- 14  # 
- 15  # You should have received a copy of the GNU Lesser General Public License 
- 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
- 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
- 18   
+  1  # Copyright (C) 2003-2007  Robey Pointer <robeypointer@gmail.com> 
+  2  # 
+  3  # This file is part of paramiko. 
+  4  # 
+  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
+  6  # terms of the GNU Lesser General Public License as published by the Free 
+  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
+  8  # any later version. 
+  9  # 
+ 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
+ 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
+ 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
+ 13  # details. 
+ 14  # 
+ 15  # You should have received a copy of the GNU Lesser General Public License 
+ 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
+ 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
+ 18   
  19  """ 
  20  L{AuthHandler} 
  21  """ 
@@ -80,7 +80,7 @@
  24  import weakref 
  25   
  26  # this helps freezing utils 
- 27  import encodings.utf_8 
+ 27  import encodings.utf_8 
  28   
  29  from paramiko.common import * 
  30  from paramiko import util 
@@ -106,7 +106,7 @@
  50          self.interactive_handler = None 
  51          self.submethods = None 
  52          # for server mode: 
- 53          self.auth_username = None 
+ 53          self.auth_username = None 
  54          self.auth_fail_count = 0 
  55           
 
     56 -    def is_authenticated(self): 
@@ -173,7 +173,7 @@
 
    115   
 116   
 117      ###  internals... 
-118   
+118   
 119   
 
    120 -    def _request_auth(self): 
 
    121          m = Message() 
@@ -372,8 +372,8 @@
 168              if e is None: 
 169                  e = AuthenticationException('Authentication failed.') 
 170              # this is horrible.  python Exception isn't yet descended from 
-171              # object, so type(e) won't work. :( 
-172              if issubclass(e.__class__, PartialAuthentication): 
+171              # object, so type(e) won't work. :( 
+172              if issubclass(e.__class__, PartialAuthentication): 
 173                  return e.allowed_types 
 174              raise e 
@@ -383,7 +383,7 @@
 
    178          service = m.get_string() 
 179          if self.transport.server_mode and (service == 'ssh-userauth'): 
 180              # accepted 
-181              m = Message() 
+181              m = Message() 
 182              m.add_byte(chr(184              self.transport._send_message(m) 
 185              return 
 186          # dunno this one 
-187          self._disconnect_service_not_available() 
+187          self._disconnect_service_not_available() 
 
    188   
 
    189 -    def _parse_service_accept(self, m): 
 
    190          service = m.get_string() 
@@ -535,7 +535,7 @@
 
    221   
 
    222 -    def _send_auth_result(self, username, method, result): 
 
    223          # okay, send result 
-224          m = Message() 
+224          m = Message() 
 225          if result == 243   
 
    244 -    def _interactive_query(self, q): 
 
    245          # make interactive query instead of response 
-246          m = Message() 
+246          m = Message() 
 247          m.add_byte(chr(
    257 -    def _parse_userauth_request(self, m): 
 
    258          if not self.transport.server_mode: 
 259              # er, uh... what? 
-260              m = Message() 
+260              m = Message() 
 261              m.add_byte(chr(265              return 
 266          if self.authenticated: 
 267              # ignore 
-268              return 
+268              return 
 269          username = m.get_string() 
 270          service = m.get_string() 
 271          method = m.get_string() 
@@ -827,12 +827,12 @@
 288                  password = password.decode('UTF-8') 
 289              except UnicodeError: 
 290                  # some clients/servers expect non-utf-8 passwords! 
-291                  # in this case, just return the raw byte string. 
-292                  pass 
+291                  # in this case, just return the raw byte string. 
+292                  pass 
 293              if changereq: 
 294                  # always treated as failure, since we don't support changing passwords, but collect 
-295                  # the list of valid auth types from the callback anyway 
-296                  self.transport._log(295                  # the list of valid auth types from the callback anyway 
+296                  self.transport._log(318                  self._disconnect_no_more_auth() 
 319                  return 
 320              # first check if this key is okay... if not, we can skip the verify 
-321              result = self.transport.server_object.check_auth_publickey(username, key) 
+321              result = self.transport.server_object.check_auth_publickey(username, key) 
 322              if result != AUTH_FAILED: 
 323                  # key is okay, verify it 
-324                  if not sig_attached: 
+324                  if not sig_attached: 
 325                      # client wants to know if this key is acceptable, before it 
-326                      # signs anything...  send special "ok" message 
-327                      m = Message() 
+326                      # signs anything...  send special "ok" message 
+327                      m = Message() 
 328                      m.add_byte(chr(341              result = self.transport.server_object.check_auth_interactive(username, submethods) 
 342              if isinstance(result, InteractiveQuery): 
 343                  # make interactive query instead of response 
-344                  self._interactive_query(result) 
+344                  self._interactive_query(result) 
 345                  return 
 346          else: 
 347              result = self.transport.server_object.check_auth_none(username) 
 348          # okay, send result 
-349          self._send_auth_result(username, method, result) 
+349          self._send_auth_result(username, method, result) 
 
    350   
 
    351 -    def _parse_userauth_success(self, m): 
 
    352          self.transport._log(DEBUG, 'Methods: ' + str(authlist)) 
 364              self.transport.saved_exception = PartialAuthentication(authlist) 
 365          elif self.auth_method not in authlist: 
-366              self.transport._log(INFO, 'Authentication type (%s) not permitted.' % self.auth_method) 
+366              self.transport._log(DEBUG, 'Authentication type (%s) not permitted.' % self.auth_method) 
 367              self.transport._log(INFO, 'Auth banner: ' + banner) 
 
    380          # who cares. 
-381       
+381       
 
    382 -    def _parse_userauth_info_request(self, m): 
 
    383          if self.auth_method != 'keyboard-interactive': 
 384              raise SSHException('Illegal info request from server') 
@@ -1284,7 +1284,7 @@
 408          result = self.transport.server_object.check_auth_interactive_response(responses) 
 409          if isinstance(type(result), InteractiveQuery): 
 410              # make interactive query instead of response 
-411              self._interactive_query(result) 
+411              self._interactive_query(result) 
 412              return 
 413          self._send_auth_result(self.auth_username, 'keyboard-interactive', result) 
 
    414           
@@ -1492,7 +1492,7 @@
 
@@ -199,7 +202,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:36 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:20 2009
     
     
       
     
    Inherited from object:
       __delattr__,
+      __format__,
       __getattribute__,
       __hash__,
       __init__,
@@ -111,7 +112,9 @@
       __reduce_ex__,
       __repr__,
       __setattr__,
-      __str__
+      __sizeof__,
+      __str__,
+      __subclasshook__
       
    
         		
   
    
@@ -269,7 +274,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:28 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:16 2009
     
     
       __delattr__,
       __getattribute__,
       __getitem__,
+      __getslice__,
       __reduce__,
       __repr__,
       __setattr__,
-      __setstate__
+      __setstate__,
+      __unicode__
       
    
     
    Inherited from object:
+      __format__,
       __hash__,
-      __reduce_ex__
+      __reduce_ex__,
+      __sizeof__,
+      __subclasshook__
       
    
         		
   
    
@@ -241,7 +246,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:28 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:16 2009
     
     
       __delattr__,
       __getattribute__,
       __getitem__,
+      __getslice__,
       __reduce__,
       __repr__,
       __setattr__,
       __setstate__,
-      __str__
+      __str__,
+      __unicode__
       
    
     
    Inherited from object:
+      __format__,
       __hash__,
-      __reduce_ex__
+      __reduce_ex__,
+      __sizeof__,
+      __subclasshook__
       
    
         		
   
    
@@ -372,7 +375,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:28 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:16 2009
     
     
       
     
    Inherited from object:
       __delattr__,
+      __format__,
       __getattribute__,
       __hash__,
       __new__,
       __reduce__,
       __reduce_ex__,
-      __setattr__
+      __setattr__,
+      __sizeof__,
+      __subclasshook__
       
    
         		
   
    
@@ -143,7 +148,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:30 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:17 2009
     
     
       __delattr__,
       __getattribute__,
       __getitem__,
+      __getslice__,
       __reduce__,
       __repr__,
       __setattr__,
       __setstate__,
-      __str__
+      __str__,
+      __unicode__
       
    
     
    Inherited from object:
+      __format__,
       __hash__,
-      __reduce_ex__
+      __reduce_ex__,
+      __sizeof__,
+      __subclasshook__
       
    
         		
   
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:30 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:17 2009
     
     
       
   
    
 
    
+
+
+
+
+  
+
+
+    
+  
+
    
+    Variables
    
+       
+    
+        __package__ = 'paramiko'
+    
    
 
 
@@ -104,7 +120,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:26 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:15 2009
     
     
       
 
    Source Code for Module paramiko.ber
    
 
    -  1  # Copyright (C) 2003-2007  Robey Pointer <robey@lag.net> 
-  2  # 
-  3  # This file is part of paramiko. 
-  4  # 
-  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
-  6  # terms of the GNU Lesser General Public License as published by the Free 
-  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
-  8  # any later version. 
-  9  # 
- 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
- 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
- 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
- 13  # details. 
- 14  # 
- 15  # You should have received a copy of the GNU Lesser General Public License 
- 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
- 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
- 18   
+  1  # Copyright (C) 2003-2007  Robey Pointer <robeypointer@gmail.com> 
+  2  # 
+  3  # This file is part of paramiko. 
+  4  # 
+  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
+  6  # terms of the GNU Lesser General Public License as published by the Free 
+  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
+  8  # any later version. 
+  9  # 
+ 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
+ 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
+ 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
+ 13  # details. 
+ 14  # 
+ 15  # You should have received a copy of the GNU Lesser General Public License 
+ 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
+ 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
+ 18   
  19   
  20  import util 
  21   
@@ -105,7 +105,7 @@
  49          self.idx += 1 
  50          if (ident & 31) == 31: 
  51              # identifier > 30 
- 52              ident = 0 
+ 52              ident = 0 
  53              while self.idx < len(self.content): 
  54                  t = ord(self.content[self.idx]) 
  55                  self.idx += 1 
@@ -115,31 +115,31 @@
  59          if self.idx >= len(self.content): 
  60              return None 
  61          # now fetch length 
- 62          size = ord(self.content[self.idx]) 
+ 62          size = ord(self.content[self.idx]) 
  63          self.idx += 1 
  64          if size & 0x80: 
  65              # more complimicated... 
- 66              # FIXME: theoretically should handle indefinite-length (0x80) 
- 67              t = size & 0x7f 
+ 66              # FIXME: theoretically should handle indefinite-length (0x80) 
+ 67              t = size & 0x7f 
  68              if self.idx + t > len(self.content): 
  69                  return None 
  70              size = util.inflate_long(self.content[self.idx : self.idx + t], True) 
  71              self.idx += t 
  72          if self.idx + size > len(self.content): 
  73              # can't fit 
- 74              return None 
+ 74              return None 
  75          data = self.content[self.idx : self.idx + size] 
  76          self.idx += size 
  77          # now switch on id 
- 78          if ident == 0x30: 
+ 78          if ident == 0x30: 
  79              # sequence 
- 80              return self.decode_sequence(data) 
+ 80              return self.decode_sequence(data) 
  81          elif ident == 2: 
  82              # int 
- 83              return util.inflate_long(data) 
+ 83              return util.inflate_long(data) 
  84          else: 
  85              # 1: boolean (00 false, otherwise true) 
- 86              raise BERException('Unknown ber encoding type %d (robey is lazy)' % ident) 
+ 86              raise BERException('Unknown ber encoding type %d (robey is lazy)' % ident) 
  87   
 
     88 -    def decode_sequence(data): 
 
     89          out = [] 
@@ -154,7 +154,7 @@
  98   
 
     99 -    def encode_tlv(self, ident, val): 
 
    100          # no need to support ident > 31 here 
-101          self.content += chr(ident) 
+101          self.content += chr(ident) 
 102          if len(val) > 0x7f: 
 103              lenstr = util.deflate_long(len(val)) 
 104              self.content += chr(0x80 + len(lenstr)) + lenstr 
@@ -216,7 +216,7 @@
 
@@ -831,7 +834,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:36 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:19 2009
     
     
       
     
    Inherited from object:
       __delattr__,
+      __format__,
       __getattribute__,
       __hash__,
       __new__,
@@ -338,7 +339,9 @@
       __reduce_ex__,
       __repr__,
       __setattr__,
-      __str__
+      __sizeof__,
+      __str__,
+      __subclasshook__
       
    
         		
   
    
@@ -491,7 +494,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:28 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:16 2009
     
     
       
     
    Inherited from object:
       __delattr__,
+      __format__,
       __getattribute__,
       __hash__,
       __new__,
@@ -226,7 +227,9 @@
       __reduce_ex__,
       __repr__,
       __setattr__,
-      __str__
+      __sizeof__,
+      __str__,
+      __subclasshook__
       
    
         		
   
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:30 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:17 2009
     
     
       
   
    
 
    
+
+
+
+
+  
+
+
+    
+  
+
    
+    Variables
    
+       
+    
+        __package__ = 'paramiko'
+    
    
 
 
@@ -114,7 +130,7 @@
 
    
@@ -122,11 +127,11 @@
     
    Inherited from exceptions.EnvironmentError:
       errno,
       filename,
-      message,
       strerror
       
    Inherited from exceptions.BaseException:
-      args
+      args,
+      message
       
    Inherited from object:
       __class__
@@ -160,7 +165,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:26 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:15 2009
     
     
       __delattr__,
       __getattribute__,
       __getitem__,
+      __getslice__,
       __repr__,
       __setattr__,
-      __setstate__
+      __setstate__,
+      __unicode__
       
    
     
    Inherited from object:
+      __format__,
       __hash__,
-      __reduce_ex__
+      __reduce_ex__,
+      __sizeof__,
+      __subclasshook__
       
    
         		
   
    
     
     
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:30 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:17 2009
     
     
       
 
    Source Code for Module paramiko.buffered_pipe
    
 
    -  1  # Copyright (C) 2006-2007  Robey Pointer <robey@lag.net> 
-  2  # 
-  3  # This file is part of paramiko. 
-  4  # 
-  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
-  6  # terms of the GNU Lesser General Public License as published by the Free 
-  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
-  8  # any later version. 
-  9  # 
- 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
- 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
- 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
- 13  # details. 
- 14  # 
- 15  # You should have received a copy of the GNU Lesser General Public License 
- 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
- 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
- 18   
+  1  # Copyright (C) 2006-2007  Robey Pointer <robeypointer@gmail.com> 
+  2  # 
+  3  # This file is part of paramiko. 
+  4  # 
+  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
+  6  # terms of the GNU Lesser General Public License as published by the Free 
+  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
+  8  # any later version. 
+  9  # 
+ 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
+ 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
+ 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
+ 13  # details. 
+ 14  # 
+ 15  # You should have received a copy of the GNU Lesser General Public License 
+ 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
+ 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
+ 18   
  19  """ 
  20  Attempt to generalize the "feeder" part of a Channel: an object which can be 
  21  read from and closed, but is reading from a buffer fed by another thread.  The 
@@ -191,11 +191,11 @@
 128                  if self._closed: 
 129                      return out 
 130                  # should we block? 
-131                  if timeout == 0.0: 
+131                  if timeout == 0.0: 
 132                      raise PipeTimeout() 
 133                  # loop here in case we get woken up but a different thread has 
-134                  # grabbed everything in the buffer. 
-135                  while (len(self._buffer) == 0) and not self._closed: 
+134                  # grabbed everything in the buffer. 
+135                  while (len(self._buffer) == 0) and not self._closed: 
 136                      then = time.time() 
 137                      self._cv.wait(timeout) 
 138                      if timeout is not None: 
@@ -204,7 +204,7 @@
 141                              raise PipeTimeout() 
 142   
 143              # something's in the buffer and we have the lock! 
-144              if len(self._buffer) <= nbytes: 
+144              if len(self._buffer) <= nbytes: 
 145                  out = self._buffer.tostring() 
 146                  del self._buffer[:] 
 147                  if (self._event is not None) and not self._closed: 
@@ -301,7 +301,7 @@
 
@@ -232,7 +235,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:37 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:18 2009
     
     
       
     
    Inherited from object:
       __delattr__,
+      __format__,
       __getattribute__,
       __hash__,
       __new__,
       __reduce__,
       __reduce_ex__,
       __setattr__,
-      __str__
+      __sizeof__,
+      __str__,
+      __subclasshook__
       
    
         		
   
    
@@ -1973,7 +1976,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:30 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:17 2009
     
     
       
     
    Inherited from object:
       __delattr__,
+      __format__,
       __getattribute__,
       __hash__,
       __new__,
       __reduce__,
       __reduce_ex__,
       __setattr__,
-      __str__
+      __sizeof__,
+      __str__,
+      __subclasshook__
       
    
         		
   
    
@@ -223,7 +228,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:28 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:16 2009
     
     
       __delattr__,
       __getattribute__,
       __getitem__,
+      __getslice__,
       __reduce__,
       __repr__,
       __setattr__,
       __setstate__,
-      __str__
+      __str__,
+      __unicode__
       
    
     
    Inherited from object:
+      __format__,
       __hash__,
-      __reduce_ex__
+      __reduce_ex__,
+      __sizeof__,
+      __subclasshook__
       
    
         		
   
    
+  
+
+    
@@ -525,7 +532,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:28 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:16 2009
     
     
       
        
     
+        __package__ = 'paramiko'
+    
    
+       
+    
         randpool = StrongLockingRandomPool()
     
   
    
+  
+
+    
@@ -928,7 +943,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:26 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:15 2009
     
     
       
 
    Source Code for Module paramiko.channel
    
 
    -   1  # Copyright (C) 2003-2007  Robey Pointer <robey@lag.net> 
-   2  # 
-   3  # This file is part of paramiko. 
-   4  # 
-   5  # Paramiko is free software; you can redistribute it and/or modify it under the 
-   6  # terms of the GNU Lesser General Public License as published by the Free 
-   7  # Software Foundation; either version 2.1 of the License, or (at your option) 
-   8  # any later version. 
-   9  # 
-  10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
-  11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
-  12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
-  13  # details. 
-  14  # 
-  15  # You should have received a copy of the GNU Lesser General Public License 
-  16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
-  17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
-  18   
+   1  # Copyright (C) 2003-2007  Robey Pointer <robeypointer@gmail.com> 
+   2  # 
+   3  # This file is part of paramiko. 
+   4  # 
+   5  # Paramiko is free software; you can redistribute it and/or modify it under the 
+   6  # terms of the GNU Lesser General Public License as published by the Free 
+   7  # Software Foundation; either version 2.1 of the License, or (at your option) 
+   8  # any later version. 
+   9  # 
+  10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
+  11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
+  12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
+  13  # details. 
+  14  # 
+  15  # You should have received a copy of the GNU Lesser General Public License 
+  16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
+  17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
+  18   
   19  """ 
   20  Abstraction for an SSH2 channel. 
   21  """ 
@@ -94,7 +94,7 @@
   37   
   38   
   39  # lower bound on the max packet size we'll accept from the remote host 
-  40  MIN_PACKET_SIZE = 1024 
+  40  MIN_PACKET_SIZE = 1024 
   41   
   42   
 
      43 -class Channel (object): 
@@ -147,13 +147,14 @@
   90          self.logger = util.get_logger('paramiko.transport') 
   91          self._pipe = None 
   92          self.event = threading.Event() 
-  93          self.combine_stderr = False 
-  94          self.exit_status = -1 
-  95          self.origin_addr = None 
-
      96       
-
      97 -    def __del__(self): 
-
      98          try: 
-  99              self.  93          self.event_ready = False 
+  94          self.combine_stderr = False 
+  95          self.exit_status = -1 
+  96          self.origin_addr = None 
+
      97       
+
      98 -    def __del__(self): 
+
      99          try: 
+ 100              self.close() 
- 100          except: 
- 101              pass 
-
     102           
-
     103 -    def __repr__(self): 
-
     104          """ 
- 105          Return a string representation of this object, for debugging. 
- 106   
- 107          @rtype: str 
- 108          """ 
- 109          out = '<paramiko.Channel %d' % self.chanid 
- 110          if self.closed: 
- 111              out += ' (closed)' 
- 112          elif self.active: 
- 113              if self.eof_received: 
- 114                  out += ' (EOF received)' 
- 115              if self.eof_sent: 
- 116                  out += ' (EOF sent)' 
- 117              out += ' (open) window=%d' % (self.out_window_size) 
- 118              if len(self.in_buffer) > 0: 
- 119                  out += ' in-buffer=%d' % (len(self.in_buffer),) 
- 120          out += ' -> ' + repr(self.transport) 
- 121          out += '>' 
- 122          return out 
-
     123   
-
     124 -    def get_pty(self, term='vt100', width=80, height=24): 
-
     125          """ 
- 126          Request a pseudo-terminal from the server.  This is usually used right 
- 127          after creating a client channel, to ask the server to provide some 
- 128          basic terminal semantics for a shell invoked with L{invoke_shell}. 
- 129          It isn't necessary (or desirable) to call this method if you're going 
- 130          to exectue a single command with L{exec_command}. 
- 131   
- 132          @param term: the terminal type to emulate (for example, C{'vt100'}) 
- 133          @type term: str 
- 134          @param width: width (in characters) of the terminal screen 
- 135          @type width: int 
- 136          @param height: height (in characters) of the terminal screen 
- 137          @type height: int 
- 138           
- 139          @raise SSHException: if the request was rejected or the channel was 
- 140              closed 
- 141          """ 
- 142          if self.closed or self.eof_received or self.eof_sent or not self.active: 
- 143              raise SSHException('Channel is not open') 
- 144          m = Message() 
- 145          m.add_byte(chr( 101          except: 
+ 102              pass 
+
     103           
+
     104 -    def __repr__(self): 
+
     105          """ 
+ 106          Return a string representation of this object, for debugging. 
+ 107   
+ 108          @rtype: str 
+ 109          """ 
+ 110          out = '<paramiko.Channel %d' % self.chanid 
+ 111          if self.closed: 
+ 112              out += ' (closed)' 
+ 113          elif self.active: 
+ 114              if self.eof_received: 
+ 115                  out += ' (EOF received)' 
+ 116              if self.eof_sent: 
+ 117                  out += ' (EOF sent)' 
+ 118              out += ' (open) window=%d' % (self.out_window_size) 
+ 119              if len(self.in_buffer) > 0: 
+ 120                  out += ' in-buffer=%d' % (len(self.in_buffer),) 
+ 121          out += ' -> ' + repr(self.transport) 
+ 122          out += '>' 
+ 123          return out 
+
     124   
+
     125 -    def get_pty(self, term='vt100', width=80, height=24): 
+
     126          """ 
+ 127          Request a pseudo-terminal from the server.  This is usually used right 
+ 128          after creating a client channel, to ask the server to provide some 
+ 129          basic terminal semantics for a shell invoked with L{invoke_shell}. 
+ 130          It isn't necessary (or desirable) to call this method if you're going 
+ 131          to exectue a single command with L{exec_command}. 
+ 132   
+ 133          @param term: the terminal type to emulate (for example, C{'vt100'}) 
+ 134          @type term: str 
+ 135          @param width: width (in characters) of the terminal screen 
+ 136          @type width: int 
+ 137          @param height: height (in characters) of the terminal screen 
+ 138          @type height: int 
+ 139           
+ 140          @raise SSHException: if the request was rejected or the channel was 
+ 141              closed 
+ 142          """ 
+ 143          if self.closed or self.eof_received or self.eof_sent or not self.active: 
+ 144              raise SSHException('Channel is not open') 
+ 145          m = Message() 
+ 146          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
- 146          m.add_int(self.remote_chanid) 
- 147          m.add_string('pty-req') 
- 148          m.add_boolean(True) 
- 149          m.add_string(term) 
- 150          m.add_int(width) 
- 151          m.add_int(height) 
- 152          # pixel height, width (usually useless) 
- 153          m.add_int(0).add_int(0) 
- 154          m.add_string('') 
- 155          self.event.clear() 
- 156          self.transport._send_user_message(m) 
- 157          self._wait_for_event() 
-
     158   
-
     159 -    def invoke_shell(self): 
-
     160          """ 
- 161          Request an interactive shell session on this channel.  If the server 
- 162          allows it, the channel will then be directly connected to the stdin, 
- 163          stdout, and stderr of the shell. 
- 164           
- 165          Normally you would call L{get_pty} before this, in which case the 
- 166          shell will operate through the pty, and the channel will be connected 
- 167          to the stdin and stdout of the pty. 
- 168           
- 169          When the shell exits, the channel will be closed and can't be reused. 
- 170          You must open a new channel if you wish to open another shell. 
- 171           
- 172          @raise SSHException: if the request was rejected or the channel was 
- 173              closed 
- 174          """ 
- 175          if self.closed or self.eof_received or self.eof_sent or not self.active: 
- 176              raise SSHException('Channel is not open') 
- 177          m = Message() 
- 178          m.add_byte(chr( 147          m.add_int(self.remote_chanid) 
+ 148          m.add_string('pty-req') 
+ 149          m.add_boolean(True) 
+ 150          m.add_string(term) 
+ 151          m.add_int(width) 
+ 152          m.add_int(height) 
+ 153          # pixel height, width (usually useless) 
+ 154          m.add_int(0).add_int(0) 
+ 155          m.add_string('') 
+ 156          self._event_pending() 
+ 157          self.transport._send_user_message(m) 
+ 158          self._wait_for_event() 
+
     159   
+
     160 -    def invoke_shell(self): 
+
     161          """ 
+ 162          Request an interactive shell session on this channel.  If the server 
+ 163          allows it, the channel will then be directly connected to the stdin, 
+ 164          stdout, and stderr of the shell. 
+ 165           
+ 166          Normally you would call L{get_pty} before this, in which case the 
+ 167          shell will operate through the pty, and the channel will be connected 
+ 168          to the stdin and stdout of the pty. 
+ 169           
+ 170          When the shell exits, the channel will be closed and can't be reused. 
+ 171          You must open a new channel if you wish to open another shell. 
+ 172           
+ 173          @raise SSHException: if the request was rejected or the channel was 
+ 174              closed 
+ 175          """ 
+ 176          if self.closed or self.eof_received or self.eof_sent or not self.active: 
+ 177              raise SSHException('Channel is not open') 
+ 178          m = Message() 
+ 179          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
- 179          m.add_int(self.remote_chanid) 
- 180          m.add_string('shell') 
- 181          m.add_boolean(1) 
- 182          self.event.clear() 
- 183          self.transport._send_user_message(m) 
- 184          self._wait_for_event() 
-
     185   
-
     186 -    def exec_command(self, command): 
-
     187          """ 
- 188          Execute a command on the server.  If the server allows it, the channel 
- 189          will then be directly connected to the stdin, stdout, and stderr of 
- 190          the command being executed. 
- 191           
- 192          When the command finishes executing, the channel will be closed and 
- 193          can't be reused.  You must open a new channel if you wish to execute 
- 194          another command. 
- 195   
- 196          @param command: a shell command to execute. 
- 197          @type command: str 
- 198   
- 199          @raise SSHException: if the request was rejected or the channel was 
- 200              closed 
- 201          """ 
- 202          if self.closed or self.eof_received or self.eof_sent or not self.active: 
- 203              raise SSHException('Channel is not open') 
- 204          m = Message() 
- 205          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
+ 180          m.add_int(self.remote_chanid) 
+ 181          m.add_string('shell') 
+ 182          m.add_boolean(1) 
+ 183          self._event_pending() 
+ 184          self.transport._send_user_message(m) 
+ 185          self._wait_for_event() 
+
     186   
+
     187 -    def exec_command(self, command): 
+
     188          """ 
+ 189          Execute a command on the server.  If the server allows it, the channel 
+ 190          will then be directly connected to the stdin, stdout, and stderr of 
+ 191          the command being executed. 
+ 192           
+ 193          When the command finishes executing, the channel will be closed and 
+ 194          can't be reused.  You must open a new channel if you wish to execute 
+ 195          another command. 
+ 196   
+ 197          @param command: a shell command to execute. 
+ 198          @type command: str 
+ 199   
+ 200          @raise SSHException: if the request was rejected or the channel was 
+ 201              closed 
+ 202          """ 
+ 203          if self.closed or self.eof_received or self.eof_sent or not self.active: 
+ 204              raise SSHException('Channel is not open') 
+ 205          m = Message() 
+ 206          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
- 206          m.add_int(self.remote_chanid) 
- 207          m.add_string('exec') 
- 208          m.add_boolean(True) 
- 209          m.add_string(command) 
- 210          self.event.clear() 
- 211          self.transport._send_user_message(m) 
- 212          self._wait_for_event() 
-
     213   
-
     214 -    def invoke_subsystem(self, subsystem): 
-
     215          """ 
- 216          Request a subsystem on the server (for example, C{sftp}).  If the 
- 217          server allows it, the channel will then be directly connected to the 
- 218          requested subsystem. 
- 219           
- 220          When the subsystem finishes, the channel will be closed and can't be 
- 221          reused. 
- 222   
- 223          @param subsystem: name of the subsystem being requested. 
- 224          @type subsystem: str 
- 225   
- 226          @raise SSHException: if the request was rejected or the channel was 
- 227              closed 
- 228          """ 
- 229          if self.closed or self.eof_received or self.eof_sent or not self.active: 
- 230              raise SSHException('Channel is not open') 
- 231          m = Message() 
- 232          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
+ 207          m.add_int(self.remote_chanid) 
+ 208          m.add_string('exec') 
+ 209          m.add_boolean(True) 
+ 210          m.add_string(command) 
+ 211          self._event_pending() 
+ 212          self.transport._send_user_message(m) 
+ 213          self._wait_for_event() 
+
     214   
+
     215 -    def invoke_subsystem(self, subsystem): 
+
     216          """ 
+ 217          Request a subsystem on the server (for example, C{sftp}).  If the 
+ 218          server allows it, the channel will then be directly connected to the 
+ 219          requested subsystem. 
+ 220           
+ 221          When the subsystem finishes, the channel will be closed and can't be 
+ 222          reused. 
+ 223   
+ 224          @param subsystem: name of the subsystem being requested. 
+ 225          @type subsystem: str 
+ 226   
+ 227          @raise SSHException: if the request was rejected or the channel was 
+ 228              closed 
+ 229          """ 
+ 230          if self.closed or self.eof_received or self.eof_sent or not self.active: 
+ 231              raise SSHException('Channel is not open') 
+ 232          m = Message() 
+ 233          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
- 233          m.add_int(self.remote_chanid) 
- 234          m.add_string('subsystem') 
- 235          m.add_boolean(True) 
- 236          m.add_string(subsystem) 
- 237          self.event.clear() 
- 238          self.transport._send_user_message(m) 
- 239          self._wait_for_event() 
-
     240   
-
     241 -    def resize_pty(self, width=80, height=24): 
-
     242          """ 
- 243          Resize the pseudo-terminal.  This can be used to change the width and 
- 244          height of the terminal emulation created in a previous L{get_pty} call. 
- 245   
- 246          @param width: new width (in characters) of the terminal screen 
- 247          @type width: int 
- 248          @param height: new height (in characters) of the terminal screen 
- 249          @type height: int 
- 250   
- 251          @raise SSHException: if the request was rejected or the channel was 
- 252              closed 
- 253          """ 
- 254          if self.closed or self.eof_received or self.eof_sent or not self.active: 
- 255              raise SSHException('Channel is not open') 
- 256          m = Message() 
- 257          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
+ 234          m.add_int(self.remote_chanid) 
+ 235          m.add_string('subsystem') 
+ 236          m.add_boolean(True) 
+ 237          m.add_string(subsystem) 
+ 238          self._event_pending() 
+ 239          self.transport._send_user_message(m) 
+ 240          self._wait_for_event() 
+
     241   
+
     242 -    def resize_pty(self, width=80, height=24): 
+
     243          """ 
+ 244          Resize the pseudo-terminal.  This can be used to change the width and 
+ 245          height of the terminal emulation created in a previous L{get_pty} call. 
+ 246   
+ 247          @param width: new width (in characters) of the terminal screen 
+ 248          @type width: int 
+ 249          @param height: new height (in characters) of the terminal screen 
+ 250          @type height: int 
+ 251   
+ 252          @raise SSHException: if the request was rejected or the channel was 
+ 253              closed 
+ 254          """ 
+ 255          if self.closed or self.eof_received or self.eof_sent or not self.active: 
+ 256              raise SSHException('Channel is not open') 
+ 257          m = Message() 
+ 258          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
- 258          m.add_int(self.remote_chanid) 
- 259          m.add_string('window-change') 
- 260          m.add_boolean(True) 
- 261          m.add_int(width) 
- 262          m.add_int(height) 
- 263          m.add_int(0).add_int(0) 
- 264          self.event.clear() 
- 265          self.transport._send_user_message(m) 
- 266          self._wait_for_event() 
-
     267   
-
     268 -    def exit_status_ready(self): 
-
     269          """ 
- 270          Return true if the remote process has exited and returned an exit 
- 271          status. You may use this to poll the process status if you don't 
- 272          want to block in L{recv_exit_status}. Note that the server may not 
- 273          return an exit status in some cases (like bad servers). 
- 274           
- 275          @return: True if L{recv_exit_status} will return immediately 
- 276          @rtype: bool 
- 277          @since: 1.7.3 
- 278          """ 
- 279          return self.closed or self.status_event.isSet() 
-
     280           
-
     281 -    def recv_exit_status(self): 
-
     282          """ 
- 283          Return the exit status from the process on the server.  This is 
- 284          mostly useful for retrieving the reults of an L{exec_command}. 
- 285          If the command hasn't finished yet, this method will wait until 
- 286          it does, or until the channel is closed.  If no exit status is 
- 287          provided by the server, -1 is returned. 
- 288           
- 289          @return: the exit code of the process on the server. 
- 290          @rtype: int 
- 291           
- 292          @since: 1.2 
- 293          """ 
- 294          while True: 
- 295              if self.closed or self.status_event.isSet(): 
- 296                  break 
- 297              self.status_event.wait(0.1) 
- 298          return self.exit_status 
-
     299   
-
     300 -    def send_exit_status(self, status): 
-
     301          """ 
- 302          Send the exit status of an executed command to the client.  (This 
- 303          really only makes sense in server mode.)  Many clients expect to 
- 304          get some sort of status code back from an executed command after 
- 305          it completes. 
- 306           
- 307          @param status: the exit code of the process 
- 308          @type status: int 
- 309           
- 310          @since: 1.2 
- 311          """ 
- 312          # in many cases, the channel will not still be open here. 
- 313          # that's fine. 
- 314          m = Message() 
- 315          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
+ 259          m.add_int(self.remote_chanid) 
+ 260          m.add_string('window-change') 
+ 261          m.add_boolean(True) 
+ 262          m.add_int(width) 
+ 263          m.add_int(height) 
+ 264          m.add_int(0).add_int(0) 
+ 265          self._event_pending() 
+ 266          self.transport._send_user_message(m) 
+ 267          self._wait_for_event() 
+
     268   
+
     269 -    def exit_status_ready(self): 
+
     270          """ 
+ 271          Return true if the remote process has exited and returned an exit 
+ 272          status. You may use this to poll the process status if you don't 
+ 273          want to block in L{recv_exit_status}. Note that the server may not 
+ 274          return an exit status in some cases (like bad servers). 
+ 275           
+ 276          @return: True if L{recv_exit_status} will return immediately 
+ 277          @rtype: bool 
+ 278          @since: 1.7.3 
+ 279          """ 
+ 280          return self.closed or self.status_event.isSet() 
+
     281           
+
     282 -    def recv_exit_status(self): 
+
     283          """ 
+ 284          Return the exit status from the process on the server.  This is 
+ 285          mostly useful for retrieving the reults of an L{exec_command}. 
+ 286          If the command hasn't finished yet, this method will wait until 
+ 287          it does, or until the channel is closed.  If no exit status is 
+ 288          provided by the server, -1 is returned. 
+ 289           
+ 290          @return: the exit code of the process on the server. 
+ 291          @rtype: int 
+ 292           
+ 293          @since: 1.2 
+ 294          """ 
+ 295          self.status_event.wait() 
+ 296          assert self.status_event.isSet() 
+ 297          return self.exit_status 
+
     298   
+
     299 -    def send_exit_status(self, status): 
+
     300          """ 
+ 301          Send the exit status of an executed command to the client.  (This 
+ 302          really only makes sense in server mode.)  Many clients expect to 
+ 303          get some sort of status code back from an executed command after 
+ 304          it completes. 
+ 305           
+ 306          @param status: the exit code of the process 
+ 307          @type status: int 
+ 308           
+ 309          @since: 1.2 
+ 310          """ 
+ 311          # in many cases, the channel will not still be open here. 
+ 312          # that's fine. 
+ 313          m = Message() 
+ 314          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
- 316          m.add_int(self.remote_chanid) 
- 317          m.add_string('exit-status') 
- 318          m.add_boolean(False) 
- 319          m.add_int(status) 
- 320          self.transport._send_user_message(m) 
-
     321       
-
     322 -    def request_x11(self, screen_number=0, auth_protocol=None, auth_cookie=None, 
- 323                      single_connection=False, handler=None): 
-
     324          """ 
- 325          Request an x11 session on this channel.  If the server allows it, 
- 326          further x11 requests can be made from the server to the client, 
- 327          when an x11 application is run in a shell session. 
- 328           
- 329          From RFC4254:: 
- 330   
- 331              It is RECOMMENDED that the 'x11 authentication cookie' that is 
- 332              sent be a fake, random cookie, and that the cookie be checked and 
- 333              replaced by the real cookie when a connection request is received. 
- 334           
- 335          If you omit the auth_cookie, a new secure random 128-bit value will be 
- 336          generated, used, and returned.  You will need to use this value to 
- 337          verify incoming x11 requests and replace them with the actual local 
- 338          x11 cookie (which requires some knoweldge of the x11 protocol). 
- 339           
- 340          If a handler is passed in, the handler is called from another thread 
- 341          whenever a new x11 connection arrives.  The default handler queues up 
- 342          incoming x11 connections, which may be retrieved using 
- 343          L{Transport.accept}.  The handler's calling signature is:: 
- 344           
- 345              handler(channel: Channel, (address: str, port: int)) 
- 346           
- 347          @param screen_number: the x11 screen number (0, 10, etc) 
- 348          @type screen_number: int 
- 349          @param auth_protocol: the name of the X11 authentication method used; 
- 350              if none is given, C{"MIT-MAGIC-COOKIE-1"} is used 
- 351          @type auth_protocol: str 
- 352          @param auth_cookie: hexadecimal string containing the x11 auth cookie; 
- 353              if none is given, a secure random 128-bit value is generated 
- 354          @type auth_cookie: str 
- 355          @param single_connection: if True, only a single x11 connection will be 
- 356              forwarded (by default, any number of x11 connections can arrive 
- 357              over this session) 
- 358          @type single_connection: bool 
- 359          @param handler: an optional handler to use for incoming X11 connections 
- 360          @type handler: function 
- 361          @return: the auth_cookie used 
- 362          """ 
- 363          if self.closed or self.eof_received or self.eof_sent or not self.active: 
- 364              raise SSHException('Channel is not open') 
- 365          if auth_protocol is None: 
- 366              auth_protocol = 'MIT-MAGIC-COOKIE-1' 
- 367          if auth_cookie is None: 
- 368              auth_cookie = binascii.hexlify(self.transport.MSG_CHANNEL_REQUEST)) 
+ 315          m.add_int(self.remote_chanid) 
+ 316          m.add_string('exit-status') 
+ 317          m.add_boolean(False) 
+ 318          m.add_int(status) 
+ 319          self.transport._send_user_message(m) 
+
     320       
+
     321 -    def request_x11(self, screen_number=0, auth_protocol=None, auth_cookie=None, 
+ 322                      single_connection=False, handler=None): 
+
     323          """ 
+ 324          Request an x11 session on this channel.  If the server allows it, 
+ 325          further x11 requests can be made from the server to the client, 
+ 326          when an x11 application is run in a shell session. 
+ 327           
+ 328          From RFC4254:: 
+ 329   
+ 330              It is RECOMMENDED that the 'x11 authentication cookie' that is 
+ 331              sent be a fake, random cookie, and that the cookie be checked and 
+ 332              replaced by the real cookie when a connection request is received. 
+ 333           
+ 334          If you omit the auth_cookie, a new secure random 128-bit value will be 
+ 335          generated, used, and returned.  You will need to use this value to 
+ 336          verify incoming x11 requests and replace them with the actual local 
+ 337          x11 cookie (which requires some knoweldge of the x11 protocol). 
+ 338           
+ 339          If a handler is passed in, the handler is called from another thread 
+ 340          whenever a new x11 connection arrives.  The default handler queues up 
+ 341          incoming x11 connections, which may be retrieved using 
+ 342          L{Transport.accept}.  The handler's calling signature is:: 
+ 343           
+ 344              handler(channel: Channel, (address: str, port: int)) 
+ 345           
+ 346          @param screen_number: the x11 screen number (0, 10, etc) 
+ 347          @type screen_number: int 
+ 348          @param auth_protocol: the name of the X11 authentication method used; 
+ 349              if none is given, C{"MIT-MAGIC-COOKIE-1"} is used 
+ 350          @type auth_protocol: str 
+ 351          @param auth_cookie: hexadecimal string containing the x11 auth cookie; 
+ 352              if none is given, a secure random 128-bit value is generated 
+ 353          @type auth_cookie: str 
+ 354          @param single_connection: if True, only a single x11 connection will be 
+ 355              forwarded (by default, any number of x11 connections can arrive 
+ 356              over this session) 
+ 357          @type single_connection: bool 
+ 358          @param handler: an optional handler to use for incoming X11 connections 
+ 359          @type handler: function 
+ 360          @return: the auth_cookie used 
+ 361          """ 
+ 362          if self.closed or self.eof_received or self.eof_sent or not self.active: 
+ 363              raise SSHException('Channel is not open') 
+ 364          if auth_protocol is None: 
+ 365              auth_protocol = 'MIT-MAGIC-COOKIE-1' 
+ 366          if auth_cookie is None: 
+ 367              auth_cookie = binascii.hexlify(self.transport.randpool.get_bytes(16)) 
- 369   
- 370          m = Message() 
- 371          m.add_byte(chr(randpool.get_bytes(16)) 
+ 368   
+ 369          m = Message() 
+ 370          m.add_byte(chr(MSG_CHANNEL_REQUEST)) 
- 372          m.add_int(self.remote_chanid) 
- 373          m.add_string('x11-req') 
- 374          m.add_boolean(True) 
- 375          m.add_boolean(single_connection) 
- 376          m.add_string(auth_protocol) 
- 377          m.add_string(auth_cookie) 
- 378          m.add_int(screen_number) 
- 379          self.event.clear() 
- 380          self.transport._send_user_message(m) 
- 381          self._wait_for_event() 
- 382          self.transport._set_x11_handler(handler) 
- 383          return auth_cookie 
-
     384   
-
     385 -    def get_transport(self): 
-
     386          """ 
- 387          Return the L{Transport} associated with this channel. 
- 388   
- 389          @return: the L{Transport} that was used to create this channel. 
- 390          @rtype: L{Transport} 
- 391          """ 
- 392          return self.transport 
-
     393   
-
     394 -    def set_name(self, name): 
-
     395          """ 
- 396          Set a name for this channel.  Currently it's only used to set the name 
- 397          of the channel in logfile entries.  The name can be fetched with the 
- 398          L{get_name} method. 
- 399   
- 400          @param name: new channel name 
- 401          @type name: str 
- 402          """ 
- 403          self._name = name 
-
     404   
-
     405 -    def get_name(self): 
-
     406          """ 
- 407          Get the name of this channel that was previously set by L{set_name}. 
- 408   
- 409          @return: the name of this channel. 
- 410          @rtype: str 
- 411          """ 
- 412          return self._name 
-
     413   
-
     414 -    def get_id(self): 
-
     415          """ 
- 416          Return the ID # for this channel.  The channel ID is unique across 
- 417          a L{Transport} and usually a small number.  It's also the number 
- 418          passed to L{ServerInterface.check_channel_request} when determining 
- 419          whether to accept a channel request in server mode. 
- 420   
- 421          @return: the ID of this channel. 
- 422          @rtype: int 
- 423          """ 
- 424          return self.chanid 
-
     425       
-
     426 -    def set_combine_stderr(self, combine): 
-
     427          """ 
- 428          Set whether stderr should be combined into stdout on this channel. 
- 429          The default is C{False}, but in some cases it may be convenient to 
- 430          have both streams combined. 
- 431           
- 432          If this is C{False}, and L{exec_command} is called (or C{invoke_shell} 
- 433          with no pty), output to stderr will not show up through the L{recv} 
- 434          and L{recv_ready} calls.  You will have to use L{recv_stderr} and 
- 435          L{recv_stderr_ready} to get stderr output. 
- 436           
- 437          If this is C{True}, data will never show up via L{recv_stderr} or 
- 438          L{recv_stderr_ready}. 
- 439           
- 440          @param combine: C{True} if stderr output should be combined into 
- 441              stdout on this channel. 
- 442          @type combine: bool 
- 443          @return: previous setting. 
- 444          @rtype: bool 
- 445           
- 446          @since: 1.1 
- 447          """ 
- 448          data = '' 
- 449          self.lock.acquire() 
- 450          try: 
- 451              old = self.combine_stderr 
- 452              self.combine_stderr = combine 
- 453              if combine and not old: 
- 454                  # copy old stderr buffer into primary buffer 
- 455                  data = self.in_stderr_buffer.empty() 
- 456          finally: 
- 457              self.lock.release() 
- 458          if len(data) > 0: 
- 459              self._feed(data) 
- 460          return old 
-
     461   
- 462       
- 463      ###  socket API 
- 464   
- 465   
-
     466 -    def settimeout(self, timeout): 
-
     467          """ 
- 468          Set a timeout on blocking read/write operations.  The C{timeout} 
- 469          argument can be a nonnegative float expressing seconds, or C{None}.  If 
- 470          a float is given, subsequent channel read/write operations will raise 
- 471          a timeout exception if the timeout period value has elapsed before the 
- 472          operation has completed.  Setting a timeout of C{None} disables 
- 473          timeouts on socket operations. 
- 474   
- 475          C{chan.settimeout(0.0)} is equivalent to C{chan.setblocking(0)}; 
- 476          C{chan.settimeout(None)} is equivalent to C{chan.setblocking(1)}. 
- 477   
- 478          @param timeout: seconds to wait for a pending read/write operation 
- 479              before raising C{socket.timeout}, or C{None} for no timeout. 
- 480          @type timeout: float 
- 481          """ 
- 482          self.timeout = timeout 
-
     483   
-
     484 -    def gettimeout(self): 
-
     485          """ 
- 486          Returns the timeout in seconds (as a float) associated with socket 
- 487          operations, or C{None} if no timeout is set.  This reflects the last 
- 488          call to L{setblocking} or L{settimeout}. 
- 489   
- 490          @return: timeout in seconds, or C{None}. 
- 491          @rtype: float 
- 492          """ 
- 493          return self.timeout 
-
     494   
-
     495 -    def setblocking(self, blocking): 
-
     496          """ 
- 497          Set blocking or non-blocking mode of the channel: if C{blocking} is 0, 
- 498          the channel is set to non-blocking mode; otherwise it's set to blocking 
- 499          mode. Initially all channels are in blocking mode. 
- 500   
- 501          In non-blocking mode, if a L{recv} call doesn't find any data, or if a 
- 502          L{send} call can't immediately dispose of the data, an error exception 
- 503          is raised. In blocking mode, the calls block until they can proceed. An 
- 504          EOF condition is considered "immediate data" for L{recv}, so if the 
- 505          channel is closed in the read direction, it will never block. 
- 506   
- 507          C{chan.setblocking(0)} is equivalent to C{chan.settimeout(0)}; 
- 508          C{chan.setblocking(1)} is equivalent to C{chan.settimeout(None)}. 
- 509   
- 510          @param blocking: 0 to set non-blocking mode; non-0 to set blocking 
- 511              mode. 
- 512          @type blocking: int 
- 513          """ 
- 514          if blocking: 
- 515              self.settimeout(None) 
- 516          else: 
- 517              self.settimeout(0.0) 
-
     518   
-
     519 -    def getpeername(self): 
-
     520          """ 
- 521          Return the address of the remote side of this Channel, if possible. 
- 522          This is just a wrapper around C{'getpeername'} on the Transport, used 
- 523          to provide enough of a socket-like interface to allow asyncore to work. 
- 524          (asyncore likes to call C{'getpeername'}.) 
- 525   
- 526          @return: the address if the remote host, if known 
- 527          @rtype: tuple(str, int) 
- 528          """ 
- 529          return self.transport.getpeername() 
-
     530   
-
     531 -    def close(self): 
-
     532          """ 
- 533          Close the channel.  All future read/write operations on the channel 
- 534          will fail.  The remote end will receive no more data (after queued data 
- 535          is flushed).  Channels are automatically closed when their L{Transport} 
- 536          is closed or when they are garbage collected. 
- 537          """ 
- 538          self.lock.acquire() 
- 539          try: 
- 540              # only close the pipe when the user explicitly closes the channel. 
- 541              # otherwise they will get unpleasant surprises.  (and do it before 
- 542              # checking self.closed, since the remote host may have already 
- 543              # closed the connection.) 
- 544              if self._pipe is not None: 
- 545                  self._pipe.MSG_CHANNEL_REQUEST)) 
+ 371          m.add_int(self.remote_chanid) 
+ 372          m.add_string('x11-req') 
+ 373          m.add_boolean(True) 
+ 374          m.add_boolean(single_connection) 
+ 375          m.add_string(auth_protocol) 
+ 376          m.add_string(auth_cookie) 
+ 377          m.add_int(screen_number) 
+ 378          self._event_pending() 
+ 379          self.transport._send_user_message(m) 
+ 380          self._wait_for_event() 
+ 381          self.transport._set_x11_handler(handler) 
+ 382          return auth_cookie 
+
     383   
+
     384 -    def get_transport(self): 
+
     385          """ 
+ 386          Return the L{Transport} associated with this channel. 
+ 387   
+ 388          @return: the L{Transport} that was used to create this channel. 
+ 389          @rtype: L{Transport} 
+ 390          """ 
+ 391          return self.transport 
+
     392   
+
     393 -    def set_name(self, name): 
+
     394          """ 
+ 395          Set a name for this channel.  Currently it's only used to set the name 
+ 396          of the channel in logfile entries.  The name can be fetched with the 
+ 397          L{get_name} method. 
+ 398   
+ 399          @param name: new channel name 
+ 400          @type name: str 
+ 401          """ 
+ 402          self._name = name 
+
     403   
+
     404 -    def get_name(self): 
+
     405          """ 
+ 406          Get the name of this channel that was previously set by L{set_name}. 
+ 407   
+ 408          @return: the name of this channel. 
+ 409          @rtype: str 
+ 410          """ 
+ 411          return self._name 
+
     412   
+
     413 -    def get_id(self): 
+
     414          """ 
+ 415          Return the ID # for this channel.  The channel ID is unique across 
+ 416          a L{Transport} and usually a small number.  It's also the number 
+ 417          passed to L{ServerInterface.check_channel_request} when determining 
+ 418          whether to accept a channel request in server mode. 
+ 419   
+ 420          @return: the ID of this channel. 
+ 421          @rtype: int 
+ 422          """ 
+ 423          return self.chanid 
+
     424       
+
     425 -    def set_combine_stderr(self, combine): 
+
     426          """ 
+ 427          Set whether stderr should be combined into stdout on this channel. 
+ 428          The default is C{False}, but in some cases it may be convenient to 
+ 429          have both streams combined. 
+ 430           
+ 431          If this is C{False}, and L{exec_command} is called (or C{invoke_shell} 
+ 432          with no pty), output to stderr will not show up through the L{recv} 
+ 433          and L{recv_ready} calls.  You will have to use L{recv_stderr} and 
+ 434          L{recv_stderr_ready} to get stderr output. 
+ 435           
+ 436          If this is C{True}, data will never show up via L{recv_stderr} or 
+ 437          L{recv_stderr_ready}. 
+ 438           
+ 439          @param combine: C{True} if stderr output should be combined into 
+ 440              stdout on this channel. 
+ 441          @type combine: bool 
+ 442          @return: previous setting. 
+ 443          @rtype: bool 
+ 444           
+ 445          @since: 1.1 
+ 446          """ 
+ 447          data = '' 
+ 448          self.lock.acquire() 
+ 449          try: 
+ 450              old = self.combine_stderr 
+ 451              self.combine_stderr = combine 
+ 452              if combine and not old: 
+ 453                  # copy old stderr buffer into primary buffer 
+ 454                  data = self.in_stderr_buffer.empty() 
+ 455          finally: 
+ 456              self.lock.release() 
+ 457          if len(data) > 0: 
+ 458              self._feed(data) 
+ 459          return old 
+
     460   
+ 461       
+ 462      ###  socket API 
+ 463   
+ 464   
+
     465 -    def settimeout(self, timeout): 
+
     466          """ 
+ 467          Set a timeout on blocking read/write operations.  The C{timeout} 
+ 468          argument can be a nonnegative float expressing seconds, or C{None}.  If 
+ 469          a float is given, subsequent channel read/write operations will raise 
+ 470          a timeout exception if the timeout period value has elapsed before the 
+ 471          operation has completed.  Setting a timeout of C{None} disables 
+ 472          timeouts on socket operations. 
+ 473   
+ 474          C{chan.settimeout(0.0)} is equivalent to C{chan.setblocking(0)}; 
+ 475          C{chan.settimeout(None)} is equivalent to C{chan.setblocking(1)}. 
+ 476   
+ 477          @param timeout: seconds to wait for a pending read/write operation 
+ 478              before raising C{socket.timeout}, or C{None} for no timeout. 
+ 479          @type timeout: float 
+ 480          """ 
+ 481          self.timeout = timeout 
+
     482   
+
     483 -    def gettimeout(self): 
+
     484          """ 
+ 485          Returns the timeout in seconds (as a float) associated with socket 
+ 486          operations, or C{None} if no timeout is set.  This reflects the last 
+ 487          call to L{setblocking} or L{settimeout}. 
+ 488   
+ 489          @return: timeout in seconds, or C{None}. 
+ 490          @rtype: float 
+ 491          """ 
+ 492          return self.timeout 
+
     493   
+
     494 -    def setblocking(self, blocking): 
+
     495          """ 
+ 496          Set blocking or non-blocking mode of the channel: if C{blocking} is 0, 
+ 497          the channel is set to non-blocking mode; otherwise it's set to blocking 
+ 498          mode. Initially all channels are in blocking mode. 
+ 499   
+ 500          In non-blocking mode, if a L{recv} call doesn't find any data, or if a 
+ 501          L{send} call can't immediately dispose of the data, an error exception 
+ 502          is raised. In blocking mode, the calls block until they can proceed. An 
+ 503          EOF condition is considered "immediate data" for L{recv}, so if the 
+ 504          channel is closed in the read direction, it will never block. 
+ 505   
+ 506          C{chan.setblocking(0)} is equivalent to C{chan.settimeout(0)}; 
+ 507          C{chan.setblocking(1)} is equivalent to C{chan.settimeout(None)}. 
+ 508   
+ 509          @param blocking: 0 to set non-blocking mode; non-0 to set blocking 
+ 510              mode. 
+ 511          @type blocking: int 
+ 512          """ 
+ 513          if blocking: 
+ 514              self.settimeout(None) 
+ 515          else: 
+ 516              self.settimeout(0.0) 
+
     517   
+
     518 -    def getpeername(self): 
+
     519          """ 
+ 520          Return the address of the remote side of this Channel, if possible. 
+ 521          This is just a wrapper around C{'getpeername'} on the Transport, used 
+ 522          to provide enough of a socket-like interface to allow asyncore to work. 
+ 523          (asyncore likes to call C{'getpeername'}.) 
+ 524   
+ 525          @return: the address if the remote host, if known 
+ 526          @rtype: tuple(str, int) 
+ 527          """ 
+ 528          return self.transport.getpeername() 
+
     529   
+
     530 -    def close(self): 
+
     531          """ 
+ 532          Close the channel.  All future read/write operations on the channel 
+ 533          will fail.  The remote end will receive no more data (after queued data 
+ 534          is flushed).  Channels are automatically closed when their L{Transport} 
+ 535          is closed or when they are garbage collected. 
+ 536          """ 
+ 537          self.lock.acquire() 
+ 538          try: 
+ 539              # only close the pipe when the user explicitly closes the channel. 
+ 540              # otherwise they will get unpleasant surprises.  (and do it before 
+ 541              # checking self.closed, since the remote host may have already 
+ 542              # closed the connection.) 
+ 543              if self._pipe is not None: 
+ 544                  self._pipe.close() 
- 546                  self._pipe = None 
- 547   
- 548              if not self.active or self.closed: 
- 549                  return 
- 550              msgs = self._close_internal() 
- 551          finally: 
- 552              self.lock.release() 
- 553          for m in msgs: 
- 554              if m is not None: 
- 555                  self.transport._send_user_message(m) 
-
     556   
-
     557 -    def recv_ready(self): 
-
     558          """ 
- 559          Returns true if data is buffered and ready to be read from this 
- 560          channel.  A C{False} result does not mean that the channel has closed; 
- 561          it means you may need to wait before more data arrives. 
- 562           
- 563          @return: C{True} if a L{recv} call on this channel would immediately 
- 564              return at least one byte; C{False} otherwise. 
- 565          @rtype: boolean 
- 566          """ 
- 567          return self.in_buffer.read_ready() 
-
     568   
-
     569 -    def recv(self, nbytes): 
-
     570          """ 
- 571          Receive data from the channel.  The return value is a string 
- 572          representing the data received.  The maximum amount of data to be 
- 573          received at once is specified by C{nbytes}.  If a string of length zero 
- 574          is returned, the channel stream has closed. 
- 575   
- 576          @param nbytes: maximum number of bytes to read. 
- 577          @type nbytes: int 
- 578          @return: data. 
- 579          @rtype: str 
- 580           
- 581          @raise socket.timeout: if no data is ready before the timeout set by 
- 582              L{settimeout}. 
- 583          """ 
- 584          try: 
- 585              out = self.in_buffer.close() 
+ 545                  self._pipe = None 
+ 546   
+ 547              if not self.active or self.closed: 
+ 548                  return 
+ 549              msgs = self._close_internal() 
+ 550          finally: 
+ 551              self.lock.release() 
+ 552          for m in msgs: 
+ 553              if m is not None: 
+ 554                  self.transport._send_user_message(m) 
+
     555   
+
     556 -    def recv_ready(self): 
+
     557          """ 
+ 558          Returns true if data is buffered and ready to be read from this 
+ 559          channel.  A C{False} result does not mean that the channel has closed; 
+ 560          it means you may need to wait before more data arrives. 
+ 561           
+ 562          @return: C{True} if a L{recv} call on this channel would immediately 
+ 563              return at least one byte; C{False} otherwise. 
+ 564          @rtype: boolean 
+ 565          """ 
+ 566          return self.in_buffer.read_ready() 
+
     567   
+
     568 -    def recv(self, nbytes): 
+
     569          """ 
+ 570          Receive data from the channel.  The return value is a string 
+ 571          representing the data received.  The maximum amount of data to be 
+ 572          received at once is specified by C{nbytes}.  If a string of length zero 
+ 573          is returned, the channel stream has closed. 
+ 574   
+ 575          @param nbytes: maximum number of bytes to read. 
+ 576          @type nbytes: int 
+ 577          @return: data. 
+ 578          @rtype: str 
+ 579           
+ 580          @raise socket.timeout: if no data is ready before the timeout set by 
+ 581              L{settimeout}. 
+ 582          """ 
+ 583          try: 
+ 584              out = self.in_buffer.read(nbytes, self.timeout) 
- 586          except PipeTimeout, e: 
- 587              raise socket.timeout() 
- 588   
- 589          ack = self._check_add_window(len(out)) 
- 590          # no need to hold the channel lock when sending this 
- 591          if ack > 0: 
- 592              m = Message() 
- 593              m.add_byte(chr(read(nbytes, self.timeout) 
+ 585          except PipeTimeout, e: 
+ 586              raise socket.timeout() 
+ 587   
+ 588          ack = self._check_add_window(len(out)) 
+ 589          # no need to hold the channel lock when sending this 
+ 590          if ack > 0: 
+ 591              m = Message() 
+ 592              m.add_byte(chr(MSG_CHANNEL_WINDOW_ADJUST)) 
- 594              m.add_int(self.remote_chanid) 
- 595              m.add_int(ack) 
- 596              self.transport._send_user_message(m) 
- 597   
- 598          return out 
-
     599   
-
     600 -    def recv_stderr_ready(self): 
-
     601          """ 
- 602          Returns true if data is buffered and ready to be read from this 
- 603          channel's stderr stream.  Only channels using L{exec_command} or 
- 604          L{invoke_shell} without a pty will ever have data on the stderr 
- 605          stream. 
- 606           
- 607          @return: C{True} if a L{recv_stderr} call on this channel would 
- 608              immediately return at least one byte; C{False} otherwise. 
- 609          @rtype: boolean 
- 610           
- 611          @since: 1.1 
- 612          """ 
- 613          return self.in_stderr_buffer.read_ready() 
-
     614   
-
     615 -    def recv_stderr(self, nbytes): 
-
     616          """ 
- 617          Receive data from the channel's stderr stream.  Only channels using 
- 618          L{exec_command} or L{invoke_shell} without a pty will ever have data 
- 619          on the stderr stream.  The return value is a string representing the 
- 620          data received.  The maximum amount of data to be received at once is 
- 621          specified by C{nbytes}.  If a string of length zero is returned, the 
- 622          channel stream has closed. 
- 623   
- 624          @param nbytes: maximum number of bytes to read. 
- 625          @type nbytes: int 
- 626          @return: data. 
- 627          @rtype: str 
- 628           
- 629          @raise socket.timeout: if no data is ready before the timeout set by 
- 630              L{settimeout}. 
- 631           
- 632          @since: 1.1 
- 633          """ 
- 634          try: 
- 635              out = self.in_stderr_buffer.MSG_CHANNEL_WINDOW_ADJUST)) 
+ 593              m.add_int(self.remote_chanid) 
+ 594              m.add_int(ack) 
+ 595              self.transport._send_user_message(m) 
+ 596   
+ 597          return out 
+
     598   
+
     599 -    def recv_stderr_ready(self): 
+
     600          """ 
+ 601          Returns true if data is buffered and ready to be read from this 
+ 602          channel's stderr stream.  Only channels using L{exec_command} or 
+ 603          L{invoke_shell} without a pty will ever have data on the stderr 
+ 604          stream. 
+ 605           
+ 606          @return: C{True} if a L{recv_stderr} call on this channel would 
+ 607              immediately return at least one byte; C{False} otherwise. 
+ 608          @rtype: boolean 
+ 609           
+ 610          @since: 1.1 
+ 611          """ 
+ 612          return self.in_stderr_buffer.read_ready() 
+
     613   
+
     614 -    def recv_stderr(self, nbytes): 
+
     615          """ 
+ 616          Receive data from the channel's stderr stream.  Only channels using 
+ 617          L{exec_command} or L{invoke_shell} without a pty will ever have data 
+ 618          on the stderr stream.  The return value is a string representing the 
+ 619          data received.  The maximum amount of data to be received at once is 
+ 620          specified by C{nbytes}.  If a string of length zero is returned, the 
+ 621          channel stream has closed. 
+ 622   
+ 623          @param nbytes: maximum number of bytes to read. 
+ 624          @type nbytes: int 
+ 625          @return: data. 
+ 626          @rtype: str 
+ 627           
+ 628          @raise socket.timeout: if no data is ready before the timeout set by 
+ 629              L{settimeout}. 
+ 630           
+ 631          @since: 1.1 
+ 632          """ 
+ 633          try: 
+ 634              out = self.in_stderr_buffer.read(nbytes, self.timeout) 
- 636          except PipeTimeout, e: 
- 637              raise socket.timeout() 
- 638               
- 639          ack = self._check_add_window(len(out)) 
- 640          # no need to hold the channel lock when sending this 
- 641          if ack > 0: 
- 642              m = Message() 
- 643              m.add_byte(chr(read(nbytes, self.timeout) 
+ 635          except PipeTimeout, e: 
+ 636              raise socket.timeout() 
+ 637               
+ 638          ack = self._check_add_window(len(out)) 
+ 639          # no need to hold the channel lock when sending this 
+ 640          if ack > 0: 
+ 641              m = Message() 
+ 642              m.add_byte(chr(MSG_CHANNEL_WINDOW_ADJUST)) 
- 644              m.add_int(self.remote_chanid) 
- 645              m.add_int(ack) 
- 646              self.transport._send_user_message(m) 
- 647   
- 648          return out 
-
     649   
-
     650 -    def send_ready(self): 
-
     651          """ 
- 652          Returns true if data can be written to this channel without blocking. 
- 653          This means the channel is either closed (so any write attempt would 
- 654          return immediately) or there is at least one byte of space in the  
- 655          outbound buffer. If there is at least one byte of space in the 
- 656          outbound buffer, a L{send} call will succeed immediately and return 
- 657          the number of bytes actually written. 
- 658           
- 659          @return: C{True} if a L{send} call on this channel would immediately 
- 660              succeed or fail 
- 661          @rtype: boolean 
- 662          """ 
- 663          self.lock.acquire() 
- 664          try: 
- 665              if self.closed or self.eof_sent: 
- 666                  return True 
- 667              return self.out_window_size > 0 
- 668          finally: 
- 669              self.lock.release() 
-
     670       
-
     671 -    def send(self, s): 
-
     672          """ 
- 673          Send data to the channel.  Returns the number of bytes sent, or 0 if 
- 674          the channel stream is closed.  Applications are responsible for 
- 675          checking that all data has been sent: if only some of the data was 
- 676          transmitted, the application needs to attempt delivery of the remaining 
- 677          data. 
- 678   
- 679          @param s: data to send 
- 680          @type s: str 
- 681          @return: number of bytes actually sent 
- 682          @rtype: int 
- 683   
- 684          @raise socket.timeout: if no data could be sent before the timeout set 
- 685              by L{settimeout}. 
- 686          """ 
- 687          size = len(s) 
- 688          self.lock.acquire() 
- 689          try: 
- 690              size = self._wait_for_send_window(size) 
- 691              if size == 0: 
- 692                  # eof or similar 
- 693                  return 0 
- 694              m = Message() 
- 695              m.add_byte(chr(MSG_CHANNEL_WINDOW_ADJUST)) 
+ 643              m.add_int(self.remote_chanid) 
+ 644              m.add_int(ack) 
+ 645              self.transport._send_user_message(m) 
+ 646   
+ 647          return out 
+
     648   
+
     649 -    def send_ready(self): 
+
     650          """ 
+ 651          Returns true if data can be written to this channel without blocking. 
+ 652          This means the channel is either closed (so any write attempt would 
+ 653          return immediately) or there is at least one byte of space in the  
+ 654          outbound buffer. If there is at least one byte of space in the 
+ 655          outbound buffer, a L{send} call will succeed immediately and return 
+ 656          the number of bytes actually written. 
+ 657           
+ 658          @return: C{True} if a L{send} call on this channel would immediately 
+ 659              succeed or fail 
+ 660          @rtype: boolean 
+ 661          """ 
+ 662          self.lock.acquire() 
+ 663          try: 
+ 664              if self.closed or self.eof_sent: 
+ 665                  return True 
+ 666              return self.out_window_size > 0 
+ 667          finally: 
+ 668              self.lock.release() 
+
     669       
+
     670 -    def send(self, s): 
+
     671          """ 
+ 672          Send data to the channel.  Returns the number of bytes sent, or 0 if 
+ 673          the channel stream is closed.  Applications are responsible for 
+ 674          checking that all data has been sent: if only some of the data was 
+ 675          transmitted, the application needs to attempt delivery of the remaining 
+ 676          data. 
+ 677   
+ 678          @param s: data to send 
+ 679          @type s: str 
+ 680          @return: number of bytes actually sent 
+ 681          @rtype: int 
+ 682   
+ 683          @raise socket.timeout: if no data could be sent before the timeout set 
+ 684              by L{settimeout}. 
+ 685          """ 
+ 686          size = len(s) 
+ 687          self.lock.acquire() 
+ 688          try: 
+ 689              size = self._wait_for_send_window(size) 
+ 690              if size == 0: 
+ 691                  # eof or similar 
+ 692                  return 0 
+ 693              m = Message() 
+ 694              m.add_byte(chr(MSG_CHANNEL_DATA)) 
- 696              m.add_int(self.remote_chanid) 
- 697              m.add_string(s[:size]) 
- 698          finally: 
- 699              self.lock.release() 
- 700          # Note: We release self.lock before calling _send_user_message. 
- 701          # Otherwise, we can deadlock during re-keying. 
- 702          self.transport._send_user_message(m) 
- 703          return size 
-
     704   
-
     705 -    def send_stderr(self, s): 
-
     706          """ 
- 707          Send data to the channel on the "stderr" stream.  This is normally 
- 708          only used by servers to send output from shell commands -- clients 
- 709          won't use this.  Returns the number of bytes sent, or 0 if the channel 
- 710          stream is closed.  Applications are responsible for checking that all 
- 711          data has been sent: if only some of the data was transmitted, the 
- 712          application needs to attempt delivery of the remaining data. 
- 713           
- 714          @param s: data to send. 
- 715          @type s: str 
- 716          @return: number of bytes actually sent. 
- 717          @rtype: int 
- 718           
- 719          @raise socket.timeout: if no data could be sent before the timeout set 
- 720              by L{settimeout}. 
- 721           
- 722          @since: 1.1 
- 723          """ 
- 724          size = len(s) 
- 725          self.lock.acquire() 
- 726          try: 
- 727              size = self._wait_for_send_window(size) 
- 728              if size == 0: 
- 729                  # eof or similar 
- 730                  return 0 
- 731              m = Message() 
- 732              m.add_byte(chr(MSG_CHANNEL_DATA)) 
+ 695              m.add_int(self.remote_chanid) 
+ 696              m.add_string(s[:size]) 
+ 697          finally: 
+ 698              self.lock.release() 
+ 699          # Note: We release self.lock before calling _send_user_message. 
+ 700          # Otherwise, we can deadlock during re-keying. 
+ 701          self.transport._send_user_message(m) 
+ 702          return size 
+
     703   
+
     704 -    def send_stderr(self, s): 
+
     705          """ 
+ 706          Send data to the channel on the "stderr" stream.  This is normally 
+ 707          only used by servers to send output from shell commands -- clients 
+ 708          won't use this.  Returns the number of bytes sent, or 0 if the channel 
+ 709          stream is closed.  Applications are responsible for checking that all 
+ 710          data has been sent: if only some of the data was transmitted, the 
+ 711          application needs to attempt delivery of the remaining data. 
+ 712           
+ 713          @param s: data to send. 
+ 714          @type s: str 
+ 715          @return: number of bytes actually sent. 
+ 716          @rtype: int 
+ 717           
+ 718          @raise socket.timeout: if no data could be sent before the timeout set 
+ 719              by L{settimeout}. 
+ 720           
+ 721          @since: 1.1 
+ 722          """ 
+ 723          size = len(s) 
+ 724          self.lock.acquire() 
+ 725          try: 
+ 726              size = self._wait_for_send_window(size) 
+ 727              if size == 0: 
+ 728                  # eof or similar 
+ 729                  return 0 
+ 730              m = Message() 
+ 731              m.add_byte(chr(MSG_CHANNEL_EXTENDED_DATA)) 
- 733              m.add_int(self.remote_chanid) 
- 734              m.add_int(1) 
- 735              m.add_string(s[:size]) 
- 736          finally: 
- 737              self.lock.release() 
- 738          # Note: We release self.lock before calling _send_user_message. 
- 739          # Otherwise, we can deadlock during re-keying. 
- 740          self.transport._send_user_message(m) 
- 741          return size 
-
     742   
-
     743 -    def sendall(self, s): 
-
     744          """ 
- 745          Send data to the channel, without allowing partial results.  Unlike 
- 746          L{send}, this method continues to send data from the given string until 
- 747          either all data has been sent or an error occurs.  Nothing is returned. 
- 748   
- 749          @param s: data to send. 
- 750          @type s: str 
- 751   
- 752          @raise socket.timeout: if sending stalled for longer than the timeout 
- 753              set by L{settimeout}. 
- 754          @raise socket.error: if an error occured before the entire string was 
- 755              sent. 
- 756           
- 757          @note: If the channel is closed while only part of the data hase been 
- 758              sent, there is no way to determine how much data (if any) was sent. 
- 759              This is irritating, but identically follows python's API. 
- 760          """ 
- 761          while s: 
- 762              if self.closed: 
- 763                  # this doesn't seem useful, but it is the documented behavior of Socket 
- 764                  raise socket.error('Socket is closed') 
- 765              sent = self.send(s) 
- 766              s = s[sent:] 
- 767          return None 
-
     768   
-
     769 -    def sendall_stderr(self, s): 
-
     770          """ 
- 771          Send data to the channel's "stderr" stream, without allowing partial 
- 772          results.  Unlike L{send_stderr}, this method continues to send data 
- 773          from the given string until all data has been sent or an error occurs. 
- 774          Nothing is returned. 
- 775           
- 776          @param s: data to send to the client as "stderr" output. 
- 777          @type s: str 
- 778           
- 779          @raise socket.timeout: if sending stalled for longer than the timeout 
- 780              set by L{settimeout}. 
- 781          @raise socket.error: if an error occured before the entire string was 
- 782              sent. 
- 783               
- 784          @since: 1.1 
- 785          """ 
- 786          while s: 
- 787              if self.closed: 
- 788                  raise socket.error('Socket is closed') 
- 789              sent = self.send_stderr(s) 
- 790              s = s[sent:] 
- 791          return None 
-
     792   
-
     793 -    def makefile(self, *params): 
-
     794          """ 
- 795          Return a file-like object associated with this channel.  The optional 
- 796          C{mode} and C{bufsize} arguments are interpreted the same way as by 
- 797          the built-in C{file()} function in python. 
- 798   
- 799          @return: object which can be used for python file I/O. 
- 800          @rtype: L{ChannelFile} 
- 801          """ 
- 802          return ChannelFile(*([self] + list(params))) 
-
     803   
-
     804 -    def makefile_stderr(self, *params): 
-
     805          """ 
- 806          Return a file-like object associated with this channel's stderr 
- 807          stream.   Only channels using L{exec_command} or L{invoke_shell} 
- 808          without a pty will ever have data on the stderr stream. 
- 809           
- 810          The optional C{mode} and C{bufsize} arguments are interpreted the 
- 811          same way as by the built-in C{file()} function in python.  For a 
- 812          client, it only makes sense to open this file for reading.  For a 
- 813          server, it only makes sense to open this file for writing. 
- 814           
- 815          @return: object which can be used for python file I/O. 
- 816          @rtype: L{ChannelFile} 
- 817   
- 818          @since: 1.1 
- 819          """ 
- 820          return ChannelStderrFile(*([self] + list(params))) 
-
     821           
-
     822 -    def fileno(self): 
-
     823          """ 
- 824          Returns an OS-level file descriptor which can be used for polling, but 
- 825          but I{not} for reading or writing.  This is primaily to allow python's 
- 826          C{select} module to work. 
- 827   
- 828          The first time C{fileno} is called on a channel, a pipe is created to 
- 829          simulate real OS-level file descriptor (FD) behavior.  Because of this, 
- 830          two OS-level FDs are created, which will use up FDs faster than normal. 
- 831          (You won't notice this effect unless you have hundreds of channels 
- 832          open at the same time.) 
- 833   
- 834          @return: an OS-level file descriptor 
- 835          @rtype: int 
- 836           
- 837          @warning: This method causes channel reads to be slightly less 
- 838              efficient. 
- 839          """ 
- 840          self.lock.acquire() 
- 841          try: 
- 842              if self._pipe is not None: 
- 843                  return self._pipe.MSG_CHANNEL_EXTENDED_DATA)) 
+ 732              m.add_int(self.remote_chanid) 
+ 733              m.add_int(1) 
+ 734              m.add_string(s[:size]) 
+ 735          finally: 
+ 736              self.lock.release() 
+ 737          # Note: We release self.lock before calling _send_user_message. 
+ 738          # Otherwise, we can deadlock during re-keying. 
+ 739          self.transport._send_user_message(m) 
+ 740          return size 
+
     741   
+
     742 -    def sendall(self, s): 
+
     743          """ 
+ 744          Send data to the channel, without allowing partial results.  Unlike 
+ 745          L{send}, this method continues to send data from the given string until 
+ 746          either all data has been sent or an error occurs.  Nothing is returned. 
+ 747   
+ 748          @param s: data to send. 
+ 749          @type s: str 
+ 750   
+ 751          @raise socket.timeout: if sending stalled for longer than the timeout 
+ 752              set by L{settimeout}. 
+ 753          @raise socket.error: if an error occured before the entire string was 
+ 754              sent. 
+ 755           
+ 756          @note: If the channel is closed while only part of the data hase been 
+ 757              sent, there is no way to determine how much data (if any) was sent. 
+ 758              This is irritating, but identically follows python's API. 
+ 759          """ 
+ 760          while s: 
+ 761              if self.closed: 
+ 762                  # this doesn't seem useful, but it is the documented behavior of Socket 
+ 763                  raise socket.error('Socket is closed') 
+ 764              sent = self.send(s) 
+ 765              s = s[sent:] 
+ 766          return None 
+
     767   
+
     768 -    def sendall_stderr(self, s): 
+
     769          """ 
+ 770          Send data to the channel's "stderr" stream, without allowing partial 
+ 771          results.  Unlike L{send_stderr}, this method continues to send data 
+ 772          from the given string until all data has been sent or an error occurs. 
+ 773          Nothing is returned. 
+ 774           
+ 775          @param s: data to send to the client as "stderr" output. 
+ 776          @type s: str 
+ 777           
+ 778          @raise socket.timeout: if sending stalled for longer than the timeout 
+ 779              set by L{settimeout}. 
+ 780          @raise socket.error: if an error occured before the entire string was 
+ 781              sent. 
+ 782               
+ 783          @since: 1.1 
+ 784          """ 
+ 785          while s: 
+ 786              if self.closed: 
+ 787                  raise socket.error('Socket is closed') 
+ 788              sent = self.send_stderr(s) 
+ 789              s = s[sent:] 
+ 790          return None 
+
     791   
+
     792 -    def makefile(self, *params): 
+
     793          """ 
+ 794          Return a file-like object associated with this channel.  The optional 
+ 795          C{mode} and C{bufsize} arguments are interpreted the same way as by 
+ 796          the built-in C{file()} function in python. 
+ 797   
+ 798          @return: object which can be used for python file I/O. 
+ 799          @rtype: L{ChannelFile} 
+ 800          """ 
+ 801          return ChannelFile(*([self] + list(params))) 
+
     802   
+
     803 -    def makefile_stderr(self, *params): 
+
     804          """ 
+ 805          Return a file-like object associated with this channel's stderr 
+ 806          stream.   Only channels using L{exec_command} or L{invoke_shell} 
+ 807          without a pty will ever have data on the stderr stream. 
+ 808           
+ 809          The optional C{mode} and C{bufsize} arguments are interpreted the 
+ 810          same way as by the built-in C{file()} function in python.  For a 
+ 811          client, it only makes sense to open this file for reading.  For a 
+ 812          server, it only makes sense to open this file for writing. 
+ 813           
+ 814          @return: object which can be used for python file I/O. 
+ 815          @rtype: L{ChannelFile} 
+ 816   
+ 817          @since: 1.1 
+ 818          """ 
+ 819          return ChannelStderrFile(*([self] + list(params))) 
+
     820           
+
     821 -    def fileno(self): 
+
     822          """ 
+ 823          Returns an OS-level file descriptor which can be used for polling, but 
+ 824          but I{not} for reading or writing.  This is primaily to allow python's 
+ 825          C{select} module to work. 
+ 826   
+ 827          The first time C{fileno} is called on a channel, a pipe is created to 
+ 828          simulate real OS-level file descriptor (FD) behavior.  Because of this, 
+ 829          two OS-level FDs are created, which will use up FDs faster than normal. 
+ 830          (You won't notice this effect unless you have hundreds of channels 
+ 831          open at the same time.) 
+ 832   
+ 833          @return: an OS-level file descriptor 
+ 834          @rtype: int 
+ 835           
+ 836          @warning: This method causes channel reads to be slightly less 
+ 837              efficient. 
+ 838          """ 
+ 839          self.lock.acquire() 
+ 840          try: 
+ 841              if self._pipe is not None: 
+ 842                  return self._pipe.fileno() 
- 844              # create the pipe and feed in any existing data 
- 845              self._pipe = pipe.make_pipe() 
- 846              p1, p2 = pipe.make_or_pipe(self._pipe) 
- 847              self.in_buffer.set_event(p1) 
- 848              self.in_stderr_buffer.set_event(p2) 
- 849              return self._pipe.fileno() 
+ 843              # create the pipe and feed in any existing data 
+ 844              self._pipe = pipe.make_pipe() 
+ 845              p1, p2 = pipe.make_or_pipe(self._pipe) 
+ 846              self.in_buffer.set_event(p1) 
+ 847              self.in_stderr_buffer.set_event(p2) 
+ 848              return self._pipe.fileno() 
- 850          finally: 
- 851              self.lock.release() 
-
     852   
-
     853 -    def shutdown(self, how): 
-
     854          """ 
- 855          Shut down one or both halves of the connection.  If C{how} is 0, 
- 856          further receives are disallowed.  If C{how} is 1, further sends 
- 857          are disallowed.  If C{how} is 2, further sends and receives are 
- 858          disallowed.  This closes the stream in one or both directions. 
- 859   
- 860          @param how: 0 (stop receiving), 1 (stop sending), or 2 (stop 
- 861              receiving and sending). 
- 862          @type how: int 
- 863          """ 
- 864          if (how == 0) or (how == 2): 
- 865              # feign "read" shutdown 
- 866              self.eof_received = 1 
- 867          if (how == 1) or (how == 2): 
- 868              self.lock.acquire() 
- 869              try: 
- 870                  m = self._send_eof() 
- 871              finally: 
- 872                  self.lock.release() 
- 873              if m is not None: 
- 874                  self.transport._send_user_message(m) 
-
     875       
-
     876 -    def shutdown_read(self): 
-
     877          """ 
- 878          Shutdown the receiving side of this socket, closing the stream in 
- 879          the incoming direction.  After this call, future reads on this 
- 880          channel will fail instantly.  This is a convenience method, equivalent 
- 881          to C{shutdown(0)}, for people who don't make it a habit to 
- 882          memorize unix constants from the 1970s. 
- 883           
- 884          @since: 1.2 
- 885          """ 
- 886          self.shutdown(0) 
-
     887       
-
     888 -    def shutdown_write(self): 
-
     889          """ 
- 890          Shutdown the sending side of this socket, closing the stream in 
- 891          the outgoing direction.  After this call, future writes on this 
- 892          channel will fail instantly.  This is a convenience method, equivalent 
- 893          to C{shutdown(1)}, for people who don't make it a habit to 
- 894          memorize unix constants from the 1970s. 
- 895           
- 896          @since: 1.2 
- 897          """ 
- 898          self.shutdown(1) 
-
     899   
- 900   
- 901      ###  calls from Transport 
- 902   
- 903   
-
     904 -    def _set_transport(self, transport): 
-
     907   
-
     908 -    def _set_window(self, window_size, max_packet_size): 
-
     909          self.in_window_size = window_size 
- 910          self.in_max_packet_size = max_packet_size 
- 911          # threshold of bytes we receive before we bother to send a window update 
- 912          self.in_window_threshold = window_size // 10 
- 913          self.in_window_sofar = 0 
- 914          self._log(fileno() 
+ 849          finally: 
+ 850              self.lock.release() 
+
     851   
+
     852 -    def shutdown(self, how): 
+
     853          """ 
+ 854          Shut down one or both halves of the connection.  If C{how} is 0, 
+ 855          further receives are disallowed.  If C{how} is 1, further sends 
+ 856          are disallowed.  If C{how} is 2, further sends and receives are 
+ 857          disallowed.  This closes the stream in one or both directions. 
+ 858   
+ 859          @param how: 0 (stop receiving), 1 (stop sending), or 2 (stop 
+ 860              receiving and sending). 
+ 861          @type how: int 
+ 862          """ 
+ 863          if (how == 0) or (how == 2): 
+ 864              # feign "read" shutdown 
+ 865              self.eof_received = 1 
+ 866          if (how == 1) or (how == 2): 
+ 867              self.lock.acquire() 
+ 868              try: 
+ 869                  m = self._send_eof() 
+ 870              finally: 
+ 871                  self.lock.release() 
+ 872              if m is not None: 
+ 873                  self.transport._send_user_message(m) 
+
     874       
+
     875 -    def shutdown_read(self): 
+
     876          """ 
+ 877          Shutdown the receiving side of this socket, closing the stream in 
+ 878          the incoming direction.  After this call, future reads on this 
+ 879          channel will fail instantly.  This is a convenience method, equivalent 
+ 880          to C{shutdown(0)}, for people who don't make it a habit to 
+ 881          memorize unix constants from the 1970s. 
+ 882           
+ 883          @since: 1.2 
+ 884          """ 
+ 885          self.shutdown(0) 
+
     886       
+
     887 -    def shutdown_write(self): 
+
     888          """ 
+ 889          Shutdown the sending side of this socket, closing the stream in 
+ 890          the outgoing direction.  After this call, future writes on this 
+ 891          channel will fail instantly.  This is a convenience method, equivalent 
+ 892          to C{shutdown(1)}, for people who don't make it a habit to 
+ 893          memorize unix constants from the 1970s. 
+ 894           
+ 895          @since: 1.2 
+ 896          """ 
+ 897          self.shutdown(1) 
+
     898   
+ 899   
+ 900      ###  calls from Transport 
+ 901   
+ 902   
+
     903 -    def _set_transport(self, transport): 
+
     906   
+
     907 -    def _set_window(self, window_size, max_packet_size): 
+
     908          self.in_window_size = window_size 
+ 909          self.in_max_packet_size = max_packet_size 
+ 910          # threshold of bytes we receive before we bother to send a window update 
+ 911          self.in_window_threshold = window_size // 10 
+ 912          self.in_window_sofar = 0 
+ 913          self._log(DEBUG, 'Max packet in: %d bytes' % max_packet_size) 
-
     915           
-
     916 -    def _set_remote_channel(self, chanid, window_size, max_packet_size): 
-
     917          self.remote_chanid = chanid 
- 918          self.out_window_size = window_size 
- 919          self.out_max_packet_size = max(max_packet_size, MIN_PACKET_SIZE) 
- 920          self.active = 1 
- 921          self._log(DEBUG, 'Max packet in: %d bytes' % max_packet_size) 
+
     914           
+
     915 -    def _set_remote_channel(self, chanid, window_size, max_packet_size): 
+
     916          self.remote_chanid = chanid 
+ 917          self.out_window_size = window_size 
+ 918          self.out_max_packet_size = max(max_packet_size, MIN_PACKET_SIZE) 
+ 919          self.active = 1 
+ 920          self._log(DEBUG, 'Max packet out: %d bytes' % max_packet_size) 
-
     922   
-
     923 -    def _request_success(self, m): 
-
     924          self._log(DEBUG, 'Max packet out: %d bytes' % max_packet_size) 
+
     921           
+
     922 -    def _request_success(self, m): 
+
     923          self._log(DEBUG, 'Sesch channel %d request ok' % self.chanid) 
- 925          self.event.DEBUG, 'Sesch channel %d request ok' % self.chanid) 
+ 924          self.event_ready = True 
+ 925          self.event.set() 
+paramiko.pipe.WindowsPipe.set" class="py-name" href="#" onclick="return doclink('link-171', 'set', 'link-171');">set() 
  926          return 
 
     927   
 
     928 -    def _request_failed(self, m): 
@@ -1351,21 +1333,21 @@
  933              self.lock.release() 
  934          for m in msgs: 
  935              if m is not None: 
- 936                  self.transport._send_user_message(m) 
+ 936                  self.transport._send_user_message(m) 
 
     937   
 
     938 -    def _feed(self, m): 
 
     939          if type(m) is str: 
  940              # passed from _feed_extended 
- 941              s = m 
+ 941              s = m 
  942          else: 
- 943              s = m.get_string() 
- 944          self.in_buffer.feed(s) 
+ 943              s = m.get_string() 
+ 944          self.in_buffer.feed(s) 
 
     945   
 
     946 -    def _feed_extended(self, m): 
-
     947          code = m.get_int() 
- 948          s = m.get_string() 
+
     947          code = m.get_int() 
+ 948          s = m.get_string() 
  949          if code != 1: 
- 950              self._log( 950              self._log(ERROR, 'unknown extended_data type %d; discarding' % code) 
+paramiko.util.ERROR" class="py-name" href="#" onclick="return doclink('link-177', 'ERROR', 'link-177');">ERROR, 'unknown extended_data type %d; discarding' % code) 
  951              return 
  952          if self.combine_stderr: 
  953              self._feed(s) 
  954          else: 
- 955              self.in_stderr_buffer.feed(s) 
+ 955              self.in_stderr_buffer.feed(s) 
 
     956           
 
     957 -    def _window_adjust(self, m): 
-
     958          nbytes = m.get_int() 
+
     958          nbytes = m.get_int() 
  959          self.lock.acquire() 
  960          try: 
  961              if self.ultra_debug: 
- 962                  self._log( 962                  self._log(DEBUG, 'window up %d' % nbytes) 
+paramiko.util.DEBUG" class="py-name" href="#" onclick="return doclink('link-180', 'DEBUG', 'link-167');">DEBUG, 'window up %d' % nbytes) 
  963              self.out_window_size += nbytes 
  964              self.out_buffer_cv.notifyAll() 
  965          finally: 
  966              self.lock.release() 
 
     967   
 
     968 -    def _handle_request(self, m): 
-
     969          key = m.get_string() 
- 970          want_reply = m.get_boolean() 
- 971          server = self.transport.server_object 
+
     969          key = m.get_string() 
+ 970          want_reply = m.get_boolean() 
+ 971          server = self.transport.server_object 
  972          ok = False 
  973          if key == 'exit-status': 
- 974              self.exit_status = m.get_int() 
- 975              self.status_event. 974              self.exit_status = m.get_int() 
+ 975              self.status_event.set() 
+paramiko.pipe.WindowsPipe.set" class="py-name" href="#" onclick="return doclink('link-186', 'set', 'link-171');">set() 
  976              ok = True 
  977          elif key == 'xon-xoff': 
  978              # ignore 
- 979              ok = True 
+ 979              ok = True 
  980          elif key == 'pty-req': 
- 981              term = m.get_string() 
- 982              width = m.get_int() 
- 983              height = m.get_int() 
- 984              pixelwidth = m.get_int() 
- 985              pixelheight = m.get_int() 
- 986              modes = m.get_string() 
- 987              if server is None: 
+ 981              term = m.get_string() 
+ 982              width = m.get_int() 
+ 983              height = m.get_int() 
+ 984              pixelwidth = m.get_int() 
+ 985              pixelheight = m.get_int() 
+ 986              modes = m.get_string() 
+ 987              if server is None: 
  988                  ok = False 
  989              else: 
- 990                  ok = server.check_channel_pty_request(self, term, width, height, pixelwidth, 
+ 990                  ok = server.check_channel_pty_request(self, term, width, height, pixelwidth, 
  991                                                        pixelheight, modes) 
  992          elif key == 'shell': 
- 993              if server is None: 
+ 993              if server is None: 
  994                  ok = False 
  995              else: 
- 996                  ok = server.check_channel_shell_request(self) 
+ 996                  ok = server.check_channel_shell_request(self) 
  997          elif key == 'exec': 
- 998              cmd = m.get_string() 
- 999              if server is None: 
+ 998              cmd = m.get_string() 
+ 999              if server is None: 
 1000                  ok = False 
 1001              else: 
-1002                  ok = server.check_channel_exec_request(self, cmd) 
+1002                  ok = server.check_channel_exec_request(self, cmd) 
 1003          elif key == 'subsystem': 
-1004              name = m.get_string() 
-1005              if server is None: 
+1004              name = m.get_string() 
+1005              if server is None: 
 1006                  ok = False 
 1007              else: 
-1008                  ok = server.check_channel_subsystem_request(self, name) 
+1008                  ok = server.check_channel_subsystem_request(self, name) 
 1009          elif key == 'window-change': 
-1010              width = m.get_int() 
-1011              height = m.get_int() 
-1012              pixelwidth = m.get_int() 
-1013              pixelheight = m.get_int() 
-1014              if server is None: 
+1010              width = m.get_int() 
+1011              height = m.get_int() 
+1012              pixelwidth = m.get_int() 
+1013              pixelheight = m.get_int() 
+1014              if server is None: 
 1015                  ok = False 
 1016              else: 
-1017                  ok = server.check_channel_window_change_request(self, width, height, pixelwidth, 
+1017                  ok = server.check_channel_window_change_request(self, width, height, pixelwidth, 
 1018                                                                  pixelheight) 
 1019          elif key == 'x11-req': 
-1020              single_connection = m.get_boolean() 
-1021              auth_proto = m.get_string() 
-1022              auth_cookie = m.get_string() 
-1023              screen_number = m.get_int() 
-1024              if server is None: 
+1020              single_connection = m.get_boolean() 
+1021              auth_proto = m.get_string() 
+1022              auth_cookie = m.get_string() 
+1023              screen_number = m.get_int() 
+1024              if server is None: 
 1025                  ok = False 
 1026              else: 
-1027                  ok = server.check_channel_x11_request(self, single_connection, 
+1027                  ok = server.check_channel_x11_request(self, single_connection, 
 1028                                                        auth_proto, auth_cookie, screen_number) 
 1029          else: 
-1030              self._log(1030              self._log(DEBUG, 'Unhandled channel request "%s"' % key) 
+paramiko.util.DEBUG" class="py-name" href="#" onclick="return doclink('link-223', 'DEBUG', 'link-167');">DEBUG, 'Unhandled channel request "%s"' % key) 
 1031              ok = False 
 1032          if want_reply: 
-1033              m = Message() 
+1033              m = Message() 
 1034              if ok: 
-1035                  m.add_byte(chr(1035                  m.add_byte(chr(MSG_CHANNEL_SUCCESS)) 
+paramiko.util.MSG_CHANNEL_SUCCESS" class="py-name" href="#" onclick="return doclink('link-226', 'MSG_CHANNEL_SUCCESS', 'link-226');">MSG_CHANNEL_SUCCESS)) 
 1036              else: 
-1037                  m.add_byte(chr(1037                  m.add_byte(chr(MSG_CHANNEL_FAILURE)) 
-1038              m.add_int(self.remote_chanid) 
-1039              self.transport._send_user_message(m) 
+paramiko.util.MSG_CHANNEL_FAILURE" class="py-name" href="#" onclick="return doclink('link-228', 'MSG_CHANNEL_FAILURE', 'link-228');">MSG_CHANNEL_FAILURE)) 
+1038              m.add_int(self.remote_chanid) 
+1039              self.transport._send_user_message(m) 
 
    1040   
 
    1041 -    def _handle_eof(self, m): 
 
    1042          self.lock.acquire() 
 1043          try: 
 1044              if not self.eof_received: 
 1045                  self.eof_received = True 
-1046                  self.in_buffer.1046                  self.in_buffer.close() 
-1047                  self.in_stderr_buffer.close() 
+1047                  self.in_stderr_buffer.close() 
+paramiko.win_pageant.PageantConnection.close" class="py-name" href="#" onclick="return doclink('link-232', 'close', 'link-26');">close() 
 1048                  if self._pipe is not None: 
-1049                      self._pipe.set_forever() 
+1049                      self._pipe.set_forever() 
 1050          finally: 
 1051              self.lock.release() 
-1052          self._log(1052          self._log(DEBUG, 'EOF received (%s)', self._name) 
+paramiko.util.DEBUG" class="py-name" href="#" onclick="return doclink('link-234', 'DEBUG', 'link-167');">DEBUG, 'EOF received (%s)', self._name) 
 
    1053   
 
    1054 -    def _handle_close(self, m): 
 
    1055          self.lock.acquire() 
 1056          try: 
 1057              msgs = self._close_internal() 
-1058              self.transport._unlink_channel(self.chanid) 
+1058              self.transport._unlink_channel(self.chanid) 
 1059          finally: 
 1060              self.lock.release() 
 1061          for m in msgs: 
 1062              if m is not None: 
-1063                  self.transport._send_user_message(m) 
+1063                  self.transport._send_user_message(m) 
 
    1064   
 1065   
 1066      ###  internals... 
-1067   
+1067   
 1068   
 
    1069 -    def _log(self, level, msg, *args): 
-
    1070          self.logger.log(level, "[chan " + self._name + "] " + msg, *args) 
+
    1070          self.logger.log(level, "[chan " + self._name + "] " + msg, *args) 
 
    1071   
-
    1072 -    def _wait_for_event(self): 
-
    1073          while True: 
-1074              self.event.wait(0.1) 
-1075              if self.event.isSet(): 
-1076                  return 
-1077              if self.closed: 
-1078                  e = self.transport.get_exception() 
-1079                  if e is None: 
-1080                      e = SSHException('Channel closed.') 
-1081                  raise e 
-1082          return 
-
    1083   
-
    1084 -    def _set_closed(self): 
-
    1085          # you are holding the lock. 
-1086          self.closed = True 
-1087          self.in_buffer.
    1072 -    def _event_pending(self): 
+
    1073          self.event.clear() 
+1074          self.event_ready = False 
+
    1075   
+
    1076 -    def _wait_for_event(self): 
+
    1077          self.event.wait() 
+1078          assert self.event.isSet() 
+1079          if self.event_ready: 
+1080              return 
+1081          e = self.transport.get_exception() 
+1082          if e is None: 
+1083              e = SSHException('Channel closed.') 
+1084          raise e 
+
    1085   
+
    1086 -    def _set_closed(self): 
+
    1087          # you are holding the lock. 
+1088          self.closed = True 
+1089          self.in_buffer.close() 
-1088          self.in_stderr_buffer.close() 
+1090          self.in_stderr_buffer.close() 
-1089          self.out_buffer_cv.notifyAll() 
-1090          if self._pipe is not None: 
-1091              self._pipe.set_forever() 
-
    1092   
-
    1093 -    def _send_eof(self): 
-
    1094          # you are holding the lock. 
-1095          if self.eof_sent: 
-1096              return None 
-1097          m = Message() 
-1098          m.add_byte(chr(close() 
+1091          self.out_buffer_cv.notifyAll() 
+1092          # Notify any waiters that we are closed 
+1093          self.event.set() 
+1094          self.status_event.set() 
+1095          if self._pipe is not None: 
+1096              self._pipe.set_forever() 
+
    1097   
+
    1098 -    def _send_eof(self): 
+
    1099          # you are holding the lock. 
+1100          if self.eof_sent: 
+1101              return None 
+1102          m = Message() 
+1103          m.add_byte(chr(MSG_CHANNEL_EOF)) 
-1099          m.add_int(self.remote_chanid) 
-1100          self.eof_sent = True 
-1101          self._log(MSG_CHANNEL_EOF)) 
+1104          m.add_int(self.remote_chanid) 
+1105          self.eof_sent = True 
+1106          self._log(DEBUG, 'EOF sent (%s)', self._name) 
-1102          return m 
-
    1103   
-
    1104 -    def _close_internal(self): 
-
    1105          # you are holding the lock. 
-1106          if not self.active or self.closed: 
-1107              return None, None 
-1108          m1 = self._send_eof() 
-1109          m2 = Message() 
-1110          m2.add_byte(chr(DEBUG, 'EOF sent (%s)', self._name) 
+1107          return m 
+
    1108   
+
    1109 -    def _close_internal(self): 
+
    1110          # you are holding the lock. 
+1111          if not self.active or self.closed: 
+1112              return None, None 
+1113          m1 = self._send_eof() 
+1114          m2 = Message() 
+1115          m2.add_byte(chr(MSG_CHANNEL_CLOSE)) 
-1111          m2.add_int(self.remote_chanid) 
-1112          self._set_closed() 
-1113          # can't unlink from the Transport yet -- the remote side may still 
-1114          # try to send meta-data (exit-status, etc) 
-1115          return m1, m2 
-
    1116   
-1127   
-
    1128 -    def _check_add_window(self, n): 
-
    1129          self.lock.acquire() 
-1130          try: 
-1131              if self.closed or self.eof_received or not self.active: 
-1132                  return 0 
-1133              if self.ultra_debug: 
-1134                  self._log(MSG_CHANNEL_CLOSE)) 
+1116          m2.add_int(self.remote_chanid) 
+1117          self._set_closed() 
+1118          # can't unlink from the Transport yet -- the remote side may still 
+1119          # try to send meta-data (exit-status, etc) 
+1120          return m1, m2 
+
    1121   
+1132   
+
    1133 -    def _check_add_window(self, n): 
+
    1134          self.lock.acquire() 
+1135          try: 
+1136              if self.closed or self.eof_received or not self.active: 
+1137                  return 0 
+1138              if self.ultra_debug: 
+1139                  self._log(DEBUG, 'addwindow %d' % n) 
-1135              self.in_window_sofar += n 
-1136              if self.in_window_sofar <= self.in_window_threshold: 
-1137                  return 0 
-1138              if self.ultra_debug: 
-1139                  self._log(DEBUG, 'addwindow %d' % n) 
+1140              self.in_window_sofar += n 
+1141              if self.in_window_sofar <= self.in_window_threshold: 
+1142                  return 0 
+1143              if self.ultra_debug: 
+1144                  self._log(DEBUG, 'addwindow send %d' % self.in_window_sofar) 
-1140              out = self.in_window_sofar 
-1141              self.in_window_sofar = 0 
-1142              return out 
-1143          finally: 
-1144              self.lock.release() 
-
    1145   
-
    1146 -    def _wait_for_send_window(self, size): 
-
    1147          """ 
-1148          (You are already holding the lock.) 
-1149          Wait for the send window to open up, and allocate up to C{size} bytes 
-1150          for transmission.  If no space opens up before the timeout, a timeout 
-1151          exception is raised.  Returns the number of bytes available to send 
-1152          (may be less than requested). 
-1153          """ 
-1154          # you are already holding the lock 
-1155          if self.closed or self.eof_sent: 
-1156              return 0 
-1157          if self.out_window_size == 0: 
-1158              # should we block? 
-1159              if self.timeout == 0.0: 
-1160                  raise socket.timeout() 
-1161              # loop here in case we get woken up but a different thread has filled the buffer 
-1162              timeout = self.timeout 
-1163              while self.out_window_size == 0: 
-1164                  if self.closed or self.eof_sent: 
-1165                      return 0 
-1166                  then = time.time() 
-1167                  self.out_buffer_cv.wait(timeout) 
-1168                  if timeout != None: 
-1169                      timeout -= time.time() - then 
-1170                      if timeout <= 0.0: 
-1171                          raise socket.timeout() 
-1172          # we have some window to squeeze into 
-1173          if self.closed or self.eof_sent: 
-1174              return 0 
-1175          if self.out_window_size < size: 
-1176              size = self.out_window_size 
-1177          if self.out_max_packet_size - 64 < size: 
-1178              size = self.out_max_packet_size - 64 
-1179          self.out_window_size -= size 
-1180          if self.ultra_debug: 
-1181              self._log(DEBUG, 'addwindow send %d' % self.in_window_sofar) 
+1145              out = self.in_window_sofar 
+1146              self.in_window_sofar = 0 
+1147              return out 
+1148          finally: 
+1149              self.lock.release() 
+
    1150   
+
    1151 -    def _wait_for_send_window(self, size): 
+
    1152          """ 
+1153          (You are already holding the lock.) 
+1154          Wait for the send window to open up, and allocate up to C{size} bytes 
+1155          for transmission.  If no space opens up before the timeout, a timeout 
+1156          exception is raised.  Returns the number of bytes available to send 
+1157          (may be less than requested). 
+1158          """ 
+1159          # you are already holding the lock 
+1160          if self.closed or self.eof_sent: 
+1161              return 0 
+1162          if self.out_window_size == 0: 
+1163              # should we block? 
+1164              if self.timeout == 0.0: 
+1165                  raise socket.timeout() 
+1166              # loop here in case we get woken up but a different thread has filled the buffer 
+1167              timeout = self.timeout 
+1168              while self.out_window_size == 0: 
+1169                  if self.closed or self.eof_sent: 
+1170                      return 0 
+1171                  then = time.time() 
+1172                  self.out_buffer_cv.wait(timeout) 
+1173                  if timeout != None: 
+1174                      timeout -= time.time() - then 
+1175                      if timeout <= 0.0: 
+1176                          raise socket.timeout() 
+1177          # we have some window to squeeze into 
+1178          if self.closed or self.eof_sent: 
+1179              return 0 
+1180          if self.out_window_size < size: 
+1181              size = self.out_window_size 
+1182          if self.out_max_packet_size - 64 < size: 
+1183              size = self.out_max_packet_size - 64 
+1184          self.out_window_size -= size 
+1185          if self.ultra_debug: 
+1186              self._log(DEBUG, 'window down to %d' % self.out_window_size) 
-1182          return size 
-
    1183           
-1184   
-
    1185 -class ChannelFile (BufferedFile): 
-
    1186      """ 
-1187      A file-like wrapper around L{Channel}.  A ChannelFile is created by calling 
-1188      L{Channel.makefile}. 
-1189   
-1190      @bug: To correctly emulate the file object created from a socket's 
-1191          C{makefile} method, a L{Channel} and its C{ChannelFile} should be able 
-1192          to be closed or garbage-collected independently.  Currently, closing 
-1193          the C{ChannelFile} does nothing but flush the buffer. 
-1194      """ 
-1195   
-
    1196 -    def __init__(self, channel, mode = 'r', bufsize = -1): 
-
    1197          self.channel = channel 
-1198          BufferedFile.DEBUG, 'window down to %d' % self.out_window_size) 
+1187          return size 
+
    1188           
+1189   
+
    1190 -class ChannelFile (BufferedFile): 
+
    1191      """ 
+1192      A file-like wrapper around L{Channel}.  A ChannelFile is created by calling 
+1193      L{Channel.makefile}. 
+1194   
+1195      @bug: To correctly emulate the file object created from a socket's 
+1196          C{makefile} method, a L{Channel} and its C{ChannelFile} should be able 
+1197          to be closed or garbage-collected independently.  Currently, closing 
+1198          the C{ChannelFile} does nothing but flush the buffer. 
+1199      """ 
+1200   
+
    1201 -    def __init__(self, channel, mode = 'r', bufsize = -1): 
+
    1202          self.channel = channel 
+1203          BufferedFile.__init__(self) 
-1199          self._set_mode(mode, bufsize) 
-
    1200   
-
    1201 -    def __repr__(self): 
-
    1202          """ 
-1203          Returns a string representation of this object, for debugging. 
-1204   
-1205          @rtype: str 
-1206          """ 
-1207          return '<paramiko.ChannelFile from ' + repr(self.channel) + '>' 
-
    1208   
-
    1209 -    def _read(self, size): 
-
    1210          return self.channel.recv(size) 
-
    1211   
-
    1212 -    def _write(self, data): 
-
    1213          self.channel.sendall(data) 
-1214          return len(data) 
-
    1215   
-1216   
-
    1217 -class ChannelStderrFile (ChannelFile): 
-
    1218 -    def __init__(self, channel, mode = 'r', bufsize = -1): 
-
    1219          ChannelFile.__init__(self) 
+1204          self._set_mode(mode, bufsize) 
+
    1205   
+
    1206 -    def __repr__(self): 
+
    1207          """ 
+1208          Returns a string representation of this object, for debugging. 
+1209   
+1210          @rtype: str 
+1211          """ 
+1212          return '<paramiko.ChannelFile from ' + repr(self.channel) + '>' 
+
    1213   
+
    1214 -    def _read(self, size): 
+
    1215          return self.channel.recv(size) 
+
    1216   
+
    1217 -    def _write(self, data): 
+
    1218          self.channel.sendall(data) 
+1219          return len(data) 
+
    1220   
+1221   
+
    1222 -class ChannelStderrFile (ChannelFile): 
+
    1223 -    def __init__(self, channel, mode = 'r', bufsize = -1): 
+
    1224          ChannelFile.__init__(self, channel, mode, bufsize) 
-
    1220   
-
    1221 -    def _read(self, size): 
-
    1222          return self.channel.recv_stderr(size) 
-
    1223       
-
    1224 -    def _write(self, data): 
-
    1225          self.channel.sendall_stderr(data) 
-1226          return len(data) 
-
    1227   
-1228   
-1229  # vim: set shiftwidth=4 expandtab : 
-1230   
+
+
+
+
+
+  
+  
+      
+
+  
+      
+
+  
+      
+
+  
+      
+
+      
+  
+
       Home      Trees      Indices      Help   
    
+
+  
+    
+    
+  
+
    
+      
+        Package paramiko ::
+        Module util ::
+        Class Counter
+      
+    
+      
+        
+        
+      
    [frames] | no frames]
    
+    
    
+
+
    Class Counter
    source code
    
+
    +object --+
+         |
+        Counter
+
    
+
+
    
+
    Stateful counter for CTR mode crypto
    
+
+
+
+
+
+  
+
+
+    
+  
+
+    
+  
+  
+    
+  
+
    
+    Instance Methods
    
+       
+    
+      
+        
+          
+          
+        
+      
    __init__(self,
+        nbits,
+        initial_value=1,
+        overflow=0)
    
+      x.__init__(...) initializes x; see x.__class__.__doc__ for signature    		
+            source code
+            
+          
    
+      
+    
    
+       
+    
+      
+        
+          
+          
+        
+      
    __call__(self)
    
+      Increament the counter and return the new value    		
+            source code
+            
+          
    
+      
+    
    
+    
    Inherited from object:
+      __delattr__,
+      __format__,
+      __getattribute__,
+      __hash__,
+      __new__,
+      __reduce__,
+      __reduce_ex__,
+      __repr__,
+      __setattr__,
+      __sizeof__,
+      __str__,
+      __subclasshook__
+      
    
+    
    
+
+
+
+
+  
+
+
+    
+  
+
    
+    Class Methods
    
+       
+    
+      
+        
+          
+          
+        
+      
    new(cls,
+        nbits,
+        initial_value=1,
+        overflow=0)
+            source code
+            
+          
    
+      
+    
    
+
+
+
+
+  
+
+  
+    
+  
+
    
+    Properties
    
+    
    Inherited from object:
+      __class__
+      
    
+    
    
+
+
+
+
+  
+
+
    
+    Method Details
    
+
+
    
+
+
    
+  
+  
+  
    
+  
    __init__(self,
+        nbits,
+        initial_value=1,
+        overflow=0)
+    
    (Constructor)
+  
    
+      		source code 
+    
    
+  
+  
    x.__init__(...) initializes x; see x.__class__.__doc__ for 
+  signature
    
+  
    
+    
    Overrides:
+        object.__init__
+        
    (inherited documentation)
    
+    
+  
    
+
    
+
    
+
    
+
+
+  
+  
+      
+
+  
+      
+
+  
+      
+
+  
+      
+
+      
+  
+
       Home      Trees      Indices      Help   
    
+
+  
+    
+    
+  
+
    
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:17 2009
+    
+      http://epydoc.sourceforge.net
+    
    
+
+
+
+
diff -Nru paramiko-1.7.4/docs/paramiko.util.enumerate-class.html paramiko-1.7.6/docs/paramiko.util.enumerate-class.html
--- paramiko-1.7.4/docs/paramiko.util.enumerate-class.html	2008-07-06 17:30:30.000000000 +0100
+++ paramiko-1.7.6/docs/paramiko.util.enumerate-class.html	2009-11-02 06:14:17.000000000 +0000
@@ -123,7 +123,7 @@
 
+
+    
+  
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:31 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:17 2009
     
     
       PFilter
     
   
    
+       
+    
+        Counter
    
+      Stateful counter for CTR mode crypto
+    
    
 
    
 
 
@@ -761,6 +769,13 @@
     
    		
        
     
+        __package__ = 'paramiko'
+    
    
+       
+    
         randpool = StrongLockingRandomPool()
     
   
    
@@ -146,7 +149,7 @@
 
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:28 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:15 2009
     
     
       
     
    Inherited from object:
       __delattr__,
+      __format__,
       __getattribute__,
       __hash__,
       __init__,
@@ -99,7 +100,9 @@
       __reduce_ex__,
       __repr__,
       __setattr__,
-      __str__
+      __sizeof__,
+      __str__,
+      __subclasshook__
       
    
         		
   
    
   
    
     
-    Generated by Epydoc 3.0.1 on Sun Jul  6 18:30:31 2008
+    Generated by Epydoc 3.0.1 on Sun Nov  1 22:14:17 2009
     
     
       
 
    Source Code for Module paramiko.util
    
 
    -  1  # Copyright (C) 2003-2007  Robey Pointer <robey@lag.net> 
-  2  # 
-  3  # This file is part of paramiko. 
-  4  # 
-  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
-  6  # terms of the GNU Lesser General Public License as published by the Free 
-  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
-  8  # any later version. 
-  9  # 
- 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
- 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
- 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
- 13  # details. 
- 14  # 
- 15  # You should have received a copy of the GNU Lesser General Public License 
- 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
- 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
- 18   
+  1  # Copyright (C) 2003-2007  Robey Pointer <robeypointer@gmail.com> 
+  2  # 
+  3  # This file is part of paramiko. 
+  4  # 
+  5  # Paramiko is free software; you can redistribute it and/or modify it under the 
+  6  # terms of the GNU Lesser General Public License as published by the Free 
+  7  # Software Foundation; either version 2.1 of the License, or (at your option) 
+  8  # any later version. 
+  9  # 
+ 10  # Paramiko is distrubuted in the hope that it will be useful, but WITHOUT ANY 
+ 11  # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 
+ 12  # A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more 
+ 13  # details. 
+ 14  # 
+ 15  # You should have received a copy of the GNU Lesser General Public License 
+ 16  # along with Paramiko; if not, write to the Free Software Foundation, Inc., 
+ 17  # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA. 
+ 18   
  19  """ 
  20  Useful functions used by the rest of paramiko. 
  21  """ 
  22   
  23  from __future__ import generators 
  24   
- 25  from binascii import hexlify, unhexlify 
- 26  import sys 
- 27  import struct 
- 28  import traceback 
- 29  import threading 
- 30   
- 31  from paramiko.common import * 
- 32  from paramiko.config import SSHConfig 
- 33   
+ 25  import array 
+ 26  from binascii import hexlify, unhexlify 
+ 27  import sys 
+ 28  import struct 
+ 29  import traceback 
+ 30  import threading 
+ 31   
+ 32  from paramiko.common import * 
+ 33  from paramiko.config import SSHConfig 
  34   
- 35  # Change by RogerB - python < 2.3 doesn't have enumerate so we implement it 
- 36  if sys.version_info < (2,3): 
-
     37 -    class enumerate: 
-
     38 -        def __init__ (self, sequence): 
-
     39              self.sequence = sequence 
-
     40 -        def __iter__ (self): 
-
     41              count = 0 
- 42              for item in self.sequence: 
- 43                  yield (count, item) 
- 44                  count += 1 
-
     45   
- 46   
-
     47 -def inflate_long(s, always_positive=False): 
-
     48      "turns a normalized byte string into a long-int (adapted from Crypto.Util.number)" 
- 49      out = 0L 
- 50      negative = 0 
- 51      if not always_positive and (len(s) > 0) and (ord(s[0]) >= 0x80): 
- 52          negative = 1 
- 53      if len(s) % 4: 
- 54          filler = '\x00' 
- 55          if negative: 
- 56              filler = '\xff' 
- 57          s = filler * (4 - len(s) % 4) + s 
- 58      for i in range(0, len(s), 4): 
- 59          out = (out << 32) + struct.unpack('>I', s[i:i+4])[0] 
- 60      if negative: 
- 61          out -= (1L << (8 * len(s))) 
- 62      return out 
-
     63   
-
     64 -def deflate_long(n, add_sign_padding=True): 
-
     65      "turns a long-int into a normalized byte string (adapted from Crypto.Util.number)" 
- 66      # after much testing, this algorithm was deemed to be the fastest 
- 67      s = '' 
- 68      n = long(n) 
- 69      while (n != 0) and (n != -1): 
- 70          s = struct.pack('>I', n & 0xffffffffL) + s 
- 71          n = n >> 32 
- 72      # strip off leading zeros, FFs 
- 73      for i in enumerate(s): 
- 74          if (n == 0) and (i[1] != '\000'): 
- 75              break 
- 76          if (n == -1) and (i[1] != '\xff'): 
- 77              break 
- 78      else: 
- 79          # degenerate case, n was either 0 or -1 
- 80          i = (0,) 
- 81          if n == 0: 
- 82              s = '\000' 
- 83          else: 
- 84              s = '\xff' 
- 85      s = s[i[0]:] 
- 86      if add_sign_padding: 
- 87          if (n == 0) and (ord(s[0]) >= 0x80): 
- 88              s = '\x00' + s 
- 89          if (n == -1) and (ord(s[0]) < 0x80): 
- 90              s = '\xff' + s 
- 91      return s 
-
     92   
-
     93 -def format_binary_weird(data): 
-
     94      out = '' 
- 95      for i in enumerate(data): 
- 96          out += '%02X' % ord(i[1]) 
- 97          if i[0] % 2: 
- 98              out += ' ' 
- 99          if i[0] % 16 == 15: 
-100              out += '\n' 
-101      return out 
-
    102   
-
    103 -def format_binary(data, prefix=''): 
-
    104      x = 0 
-105      out = [] 
-106      while len(data) > x + 16: 
-107          out.append(format_binary_line(data[x:x+16])) 
-108          x += 16 
-109      if x < len(data): 
-110          out.append(format_binary_line(data[x:])) 
-111      return [prefix + x for x in out] 
-
    112   
-
    113 -def format_binary_line(data): 
-
    114      left = ' '.join(['%02X' % ord(c) for c in data]) 
-115      right = ''.join([('.%c..' % c)[(ord(c)+63)//95] for c in data]) 
-116      return '%-50s %s' % (left, right) 
-
    117   
-
    118 -def hexify(s): 
-
    119      return hexlify(s).upper() 
-
    120   
-
    121 -def unhexify(s): 
-
    122      return unhexlify(s) 
-
    123   
-
    124 -def safe_string(s): 
-
    125      out = '' 
-126      for c in s: 
-127          if (ord(c) >= 32) and (ord(c) <= 127): 
-128              out += c 
-129          else: 
-130              out += '%%%02X' % ord(c) 
-131      return out 
-
    132   
-133  # ''.join([['%%%02X' % ord(c), c][(ord(c) >= 32) and (ord(c) <= 127)] for c in s]) 
-134   
-
    135 -def bit_length(n): 
-
    136      norm = deflate_long(n, 0) 
-137      hbyte = ord(norm[0]) 
-138      bitlen = len(norm) * 8 
-139      while not (hbyte & 0x80): 
-140          hbyte <<= 1 
-141          bitlen -= 1 
-142      return bitlen 
-
    143   
-
    144 -def tb_strings(): 
-
    145      return ''.join(traceback.format_exception(*sys.exc_info())).split('\n') 
+ 35   
+ 36  # Change by RogerB - python < 2.3 doesn't have enumerate so we implement it 
+ 37  if sys.version_info < (2,3): 
+
     38 -    class enumerate: 
+
     39 -        def __init__ (self, sequence): 
+
     40              self.sequence = sequence 
+
     41 -        def __iter__ (self): 
+
     42              count = 0 
+ 43              for item in self.sequence: 
+ 44                  yield (count, item) 
+ 45                  count += 1 
+
     46   
+ 47   
+
     48 -def inflate_long(s, always_positive=False): 
+
     49      "turns a normalized byte string into a long-int (adapted from Crypto.Util.number)" 
+ 50      out = 0L 
+ 51      negative = 0 
+ 52      if not always_positive and (len(s) > 0) and (ord(s[0]) >= 0x80): 
+ 53          negative = 1 
+ 54      if len(s) % 4: 
+ 55          filler = '\x00' 
+ 56          if negative: 
+ 57              filler = '\xff' 
+ 58          s = filler * (4 - len(s) % 4) + s 
+ 59      for i in range(0, len(s), 4): 
+ 60          out = (out << 32) + struct.unpack('>I', s[i:i+4])[0] 
+ 61      if negative: 
+ 62          out -= (1L << (8 * len(s))) 
+ 63      return out 
+
     64   
+
     65 -def deflate_long(n, add_sign_padding=True): 
+
     66      "turns a long-int into a normalized byte string (adapted from Crypto.Util.number)" 
+ 67      # after much testing, this algorithm was deemed to be the fastest 
+ 68      s = '' 
+ 69      n = long(n) 
+ 70      while (n != 0) and (n != -1): 
+ 71          s = struct.pack('>I', n & 0xffffffffL) + s 
+ 72          n = n >> 32 
+ 73      # strip off leading zeros, FFs 
+ 74      for i in enumerate(s): 
+ 75          if (n == 0) and (i[1] != '\000'): 
+ 76              break 
+ 77          if (n == -1) and (i[1] != '\xff'): 
+ 78              break 
+ 79      else: 
+ 80          # degenerate case, n was either 0 or -1 
+ 81          i = (0,) 
+ 82          if n == 0: 
+ 83              s = '\000' 
+ 84          else: 
+ 85              s = '\xff' 
+ 86      s = s[i[0]:] 
+ 87      if add_sign_padding: 
+ 88          if (n == 0) and (ord(s[0]) >= 0x80): 
+ 89              s = '\x00' + s 
+ 90          if (n == -1) and (ord(s[0]) < 0x80): 
+ 91              s = '\xff' + s 
+ 92      return s 
+
     93   
+
     94 -def format_binary_weird(data): 
+
     95      out = '' 
+ 96      for i in enumerate(data): 
+ 97          out += '%02X' % ord(i[1]) 
+ 98          if i[0] % 2: 
+ 99              out += ' ' 
+100          if i[0] % 16 == 15: 
+101              out += '\n' 
+102      return out 
+
    103   
+
    104 -def format_binary(data, prefix=''): 
+
    105      x = 0 
+106      out = [] 
+107      while len(data) > x + 16: 
+108          out.append(format_binary_line(data[x:x+16])) 
+109          x += 16 
+110      if x < len(data): 
+111          out.append(format_binary_line(data[x:])) 
+112      return [prefix + x for x in out] 
+
    113   
+
    114 -def format_binary_line(data): 
+
    115      left = ' '.join(['%02X' % ord(c) for c in data]) 
+116      right = ''.join([('.%c..' % c)[(ord(c)+63)//95] for c in data]) 
+117      return '%-50s %s' % (left, right) 
+
    118   
+
    119 -def hexify(s): 
+
    120      return hexlify(s).upper() 
+
    121   
+
    122 -def unhexify(s): 
+
    123      return unhexlify(s) 
+
    124   
+
    125 -def safe_string(s): 
+
    126      out = '' 
+127      for c in s: 
+128          if (ord(c) >= 32) and (ord(c) <= 127): 
+129              out += c 
+130          else: 
+131              out += '%%%02X' % ord(c) 
+132      return out 
+
    133   
+134  # ''.join([['%%%02X' % ord(c), c][(ord(c) >= 32) and (ord(c) <= 127)] for c in s]) 
+135   
+
    136 -def bit_length(n): 
+
    137      norm = deflate_long(n, 0) 
+138      hbyte = ord(norm[0]) 
+139      if hbyte == 0: 
+140          return 1 
+141      bitlen = len(norm) * 8 
+142      while not (hbyte & 0x80): 
+143          hbyte <<= 1 
+144          bitlen -= 1 
+145      return bitlen 
 
    146   
-
    147 -def generate_key_bytes(hashclass, salt, key, nbytes): 
-
    148      """ 
-149      Given a password, passphrase, or other human-source key, scramble it 
-150      through a secure hash into some keyworthy bytes.  This specific algorithm 
-151      is used for encrypting/decrypting private key files. 
-152   
-153      @param hashclass: class from L{Crypto.Hash} that can be used as a secure 
-154          hashing function (like C{MD5} or C{SHA}). 
-155      @type hashclass: L{Crypto.Hash} 
-156      @param salt: data to salt the hash with. 
-157      @type salt: string 
-158      @param key: human-entered password or passphrase. 
-159      @type key: string 
-160      @param nbytes: number of bytes to generate. 
-161      @type nbytes: int 
-162      @return: key data 
-163      @rtype: string 
-164      """ 
-165      keydata = '' 
-166      digest = '' 
-167      if len(salt) > 8: 
-168          salt = salt[:8] 
-169      while nbytes > 0: 
-170          hash_obj = hashclass.new() 
-171          if len(digest) > 0: 
-172              hash_obj.update(digest) 
-173          hash_obj.update(key) 
-174          hash_obj.update(salt) 
-175          digest = hash_obj.digest() 
-176          size = min(nbytes, len(digest)) 
-177          keydata += digest[:size] 
-178          nbytes -= size 
-179      return keydata 
-
    180   
-
    181 -def load_host_keys(filename): 
-
    182      """ 
-183      Read a file of known SSH host keys, in the format used by openssh, and 
-184      return a compound dict of C{hostname -> keytype ->} L{PKey <paramiko.pkey.PKey>}. 
-185      The hostname may be an IP address or DNS name.  The keytype will be either 
-186      C{"ssh-rsa"} or C{"ssh-dss"}. 
-187       
-188      This type of file unfortunately doesn't exist on Windows, but on posix, 
-189      it will usually be stored in C{os.path.expanduser("~/.ssh/known_hosts")}. 
-190       
-191      Since 1.5.3, this is just a wrapper around L{HostKeys}. 
-192   
-193      @param filename: name of the file to read host keys from 
-194      @type filename: str 
-195      @return: dict of host keys, indexed by hostname and then keytype 
-196      @rtype: dict(hostname, dict(keytype, L{PKey <paramiko.pkey.PKey>})) 
-197      """ 
-198      from paramiko.hostkeys import HostKeys 
-199      return HostKeys(filename) 
-
    200   
-
    201 -def parse_ssh_config(file_obj): 
-
    202      """ 
-203      Provided only as a backward-compatible wrapper around L{SSHConfig}. 
-204      """ 
-205      config = SSHConfig() 
-206      config.parse(file_obj) 
-207      return config 
-
    208   
-
    209 -def lookup_ssh_host_config(hostname, config): 
-
    210      """ 
-211      Provided only as a backward-compatible wrapper around L{SSHConfig}. 
-212      """ 
-213      return config.lookup(hostname) 
-
    214   
-
    215 -def mod_inverse(x, m): 
-
    216      # it's crazy how small python can make this function. 
-217      u1, u2, u3 = 1, 0, m 
-218      v1, v2, v3 = 0, 1, x 
-219   
-220      while v3 > 0: 
-221          q = u3 // v3 
-222          u1, v1 = v1, u1 - v1 * q 
-223          u2, v2 = v2, u2 - v2 * q 
-224          u3, v3 = v3, u3 - v3 * q 
-225      if u2 < 0: 
-226          u2 += m 
-227      return u2 
-
    228   
-229  _g_thread_ids = {} 
-230  _g_thread_counter = 0 
-231  _g_thread_lock = threading.Lock() 
-
    232 -def get_thread_id(): 
-
    233      global _g_thread_ids, _g_thread_counter, _g_thread_lock 
-234      tid = id(threading.currentThread()) 
-235      try: 
-236          return _g_thread_ids[tid] 
-237      except KeyError: 
-238          _g_thread_lock.acquire() 
-239          try: 
-240              _g_thread_counter += 1 
-241              ret = _g_thread_ids[tid] = _g_thread_counter 
-242          finally: 
-243              _g_thread_lock.release() 
-244          return ret 
-
    245   
-
    246 -def log_to_file(filename, level=
    147 -def tb_strings(): 
+
    148      return ''.join(traceback.format_exception(*sys.exc_info())).split('\n') 
+
    149   
+
    150 -def generate_key_bytes(hashclass, salt, key, nbytes): 
+
    151      """ 
+152      Given a password, passphrase, or other human-source key, scramble it 
+153      through a secure hash into some keyworthy bytes.  This specific algorithm 
+154      is used for encrypting/decrypting private key files. 
+155   
+156      @param hashclass: class from L{Crypto.Hash} that can be used as a secure 
+157          hashing function (like C{MD5} or C{SHA}). 
+158      @type hashclass: L{Crypto.Hash} 
+159      @param salt: data to salt the hash with. 
+160      @type salt: string 
+161      @param key: human-entered password or passphrase. 
+162      @type key: string 
+163      @param nbytes: number of bytes to generate. 
+164      @type nbytes: int 
+165      @return: key data 
+166      @rtype: string 
+167      """ 
+168      keydata = '' 
+169      digest = '' 
+170      if len(salt) > 8: 
+171          salt = salt[:8] 
+172      while nbytes > 0: 
+173          hash_obj = hashclass.new() 
+174          if len(digest) > 0: 
+175              hash_obj.update(digest) 
+176          hash_obj.update(key) 
+177          hash_obj.update(salt) 
+178          digest = hash_obj.digest() 
+179          size = min(nbytes, len(digest)) 
+180          keydata += digest[:size] 
+181          nbytes -= size 
+182      return keydata 
+
    183   
+
    184 -def load_host_keys(filename): 
+
    185      """ 
+186      Read a file of known SSH host keys, in the format used by openssh, and 
+187      return a compound dict of C{hostname -> keytype ->} L{PKey <paramiko.pkey.PKey>}. 
+188      The hostname may be an IP address or DNS name.  The keytype will be either 
+189      C{"ssh-rsa"} or C{"ssh-dss"}. 
+190   
+191      This type of file unfortunately doesn't exist on Windows, but on posix, 
+192      it will usually be stored in C{os.path.expanduser("~/.ssh/known_hosts")}. 
+193   
+194      Since 1.5.3, this is just a wrapper around L{HostKeys}. 
+195   
+196      @param filename: name of the file to read host keys from 
+197      @type filename: str 
+198      @return: dict of host keys, indexed by hostname and then keytype 
+199      @rtype: dict(hostname, dict(keytype, L{PKey <paramiko.pkey.PKey>})) 
+200      """ 
+201      from paramiko.hostkeys import HostKeys 
+202      return HostKeys(filename) 
+
    203   
+
    204 -def parse_ssh_config(file_obj): 
+
    205      """ 
+206      Provided only as a backward-compatible wrapper around L{SSHConfig}. 
+207      """ 
+208      config = SSHConfig() 
+209      config.parse(file_obj) 
+210      return config 
+
    211   
+
    212 -def lookup_ssh_host_config(hostname, config): 
+
    213      """ 
+214      Provided only as a backward-compatible wrapper around L{SSHConfig}. 
+215      """ 
+216      return config.lookup(hostname) 
+
    217   
+
    218 -def mod_inverse(x, m): 
+
    219      # it's crazy how small python can make this function. 
+220      u1, u2, u3 = 1, 0, m 
+221      v1, v2, v3 = 0, 1, x 
+222   
+223      while v3 > 0: 
+224          q = u3 // v3 
+225          u1, v1 = v1, u1 - v1 * q 
+226          u2, v2 = v2, u2 - v2 * q 
+227          u3, v3 = v3, u3 - v3 * q 
+228      if u2 < 0: 
+229          u2 += m 
+230      return u2 
+
    231   
+232  _g_thread_ids = {} 
+233  _g_thread_counter = 0 
+234  _g_thread_lock = threading.Lock() 
+
    235 -def get_thread_id(): 
+
    236      global _g_thread_ids, _g_thread_counter, _g_thread_lock 
+237      tid = id(threading.currentThread()) 
+238      try: 
+239          return _g_thread_ids[tid] 
+240      except KeyError: 
+241          _g_thread_lock.acquire() 
+242          try: 
+243              _g_thread_counter += 1 
+244              ret = _g_thread_ids[tid] = _g_thread_counter 
+245          finally: 
+246              _g_thread_lock.release() 
+247          return ret 
+
    248   
+
    249 -def log_to_file(filename, level=DEBUG): 
-
    247      "send paramiko logs to a logfile, if they're not already going somewhere" 
-248      l = logging.getLogger("paramiko") 
-249      if len(l.handlers) > 0: 
-250          return 
-251      l.setLevel(level) 
-252      f = open(filename, 'w') 
-253      lh = logging.StreamHandler(f) 
-254      lh.setFormatter(logging.Formatter('%(levelname)-.3s [%(asctime)s.%(msecs)03d] thr=%(_threadid)-3d %(name)s: %(message)s', 
-255                                        '%Y%m%d-%H:%M:%S')) 
-256      l.addHandler(lh) 
-
    257   
-258  # make only one filter object, so it doesn't get applied more than once 
-
    259 -class PFilter (object): 
-
    260 -    def filter(self, record): 
-
    261          record._threadid = get_thread_id() 
-262          return True 
-
    263  _pfilter = PFilter() 
-264   
-
    265 -def get_logger(name): 
-
    266      l = logging.getLogger(name) 
-267      l.addFilter(_pfilter) 
-268      return l 
-
    269