~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transport/sftp.py

  • Committer: Alexander Belchenko
  • Date: 2006-06-29 08:41:31 UTC
  • mto: (1860.1.1 win32.installer)
  • mto: This revision was merged to the branch mainline in revision 1906.
  • Revision ID: bialix@ukr.net-20060629084131-3ea4d44e3204e36f
win32 installer for bzr.dev.0.9

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
1
# Copyright (C) 2005 Robey Pointer <robey@lag.net>
2
2
# Copyright (C) 2005, 2006 Canonical Ltd
3
 
#
 
3
 
4
4
# This program is free software; you can redistribute it and/or modify
5
5
# it under the terms of the GNU General Public License as published by
6
6
# the Free Software Foundation; either version 2 of the License, or
7
7
# (at your option) any later version.
8
 
#
 
8
 
9
9
# This program is distributed in the hope that it will be useful,
10
10
# but WITHOUT ANY WARRANTY; without even the implied warranty of
11
11
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12
12
# GNU General Public License for more details.
13
 
#
 
13
 
14
14
# You should have received a copy of the GNU General Public License
15
15
# along with this program; if not, write to the Free Software
16
16
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
17
17
 
18
18
"""Implementation of Transport over SFTP, using paramiko."""
19
19
 
20
 
# TODO: Remove the transport-based lock_read and lock_write methods.  They'll
21
 
# then raise TransportNotPossible, which will break remote access to any
22
 
# formats which rely on OS-level locks.  That should be fine as those formats
23
 
# are pretty old, but these combinations may have to be removed from the test
24
 
# suite.  Those formats all date back to 0.7; so we should be able to remove
25
 
# these methods when we officially drop support for those formats.
26
 
 
27
20
import errno
 
21
import getpass
28
22
import os
29
23
import random
 
24
import re
30
25
import select
31
26
import socket
32
27
import stat
 
28
import subprocess
33
29
import sys
34
30
import time
35
31
import urllib
36
32
import urlparse
37
33
import weakref
38
34
 
39
 
from bzrlib import (
40
 
    errors,
41
 
    urlutils,
42
 
    )
43
 
from bzrlib.errors import (FileExists,
44
 
                           NoSuchFile, PathNotChild,
 
35
from bzrlib.config import config_dir, ensure_config_dir_exists
 
36
from bzrlib.errors import (ConnectionError,
 
37
                           FileExists, 
 
38
                           TransportNotPossible, NoSuchFile, PathNotChild,
45
39
                           TransportError,
46
 
                           LockError,
 
40
                           LockError, 
47
41
                           PathError,
48
42
                           ParamikoNotPresent,
49
43
                           )
50
 
from bzrlib.osutils import pathjoin, fancy_rename, getcwd
51
 
from bzrlib.trace import mutter, warning
 
44
from bzrlib.osutils import pathjoin, fancy_rename
 
45
from bzrlib.trace import mutter, warning, error
52
46
from bzrlib.transport import (
53
47
    register_urlparse_netloc_protocol,
54
48
    Server,
55
49
    split_url,
56
 
    ssh,
57
50
    Transport,
58
51
    )
 
52
import bzrlib.ui
 
53
import bzrlib.urlutils as urlutils
59
54
 
60
55
try:
61
56
    import paramiko
67
62
                               CMD_HANDLE, CMD_OPEN)
68
63
    from paramiko.sftp_attr import SFTPAttributes
69
64
    from paramiko.sftp_file import SFTPFile
 
65
    from paramiko.sftp_client import SFTPClient
70
66
 
71
67
 
72
68
register_urlparse_netloc_protocol('sftp')
73
69
 
74
70
 
 
71
def _ignore_sigint():
 
72
    # TODO: This should possibly ignore SIGHUP as well, but bzr currently
 
73
    # doesn't handle it itself.
 
74
    # <https://launchpad.net/products/bzr/+bug/41433/+index>
 
75
    import signal
 
76
    signal.signal(signal.SIGINT, signal.SIG_IGN)
 
77
    
 
78
 
 
79
def os_specific_subprocess_params():
 
80
    """Get O/S specific subprocess parameters."""
 
81
    if sys.platform == 'win32':
 
82
        # setting the process group and closing fds is not supported on 
 
83
        # win32
 
84
        return {}
 
85
    else:
 
86
        # We close fds other than the pipes as the child process does not need 
 
87
        # them to be open.
 
88
        #
 
89
        # We also set the child process to ignore SIGINT.  Normally the signal
 
90
        # would be sent to every process in the foreground process group, but
 
91
        # this causes it to be seen only by bzr and not by ssh.  Python will
 
92
        # generate a KeyboardInterrupt in bzr, and we will then have a chance
 
93
        # to release locks or do other cleanup over ssh before the connection
 
94
        # goes away.  
 
95
        # <https://launchpad.net/products/bzr/+bug/5987>
 
96
        #
 
97
        # Running it in a separate process group is not good because then it
 
98
        # can't get non-echoed input of a password or passphrase.
 
99
        # <https://launchpad.net/products/bzr/+bug/40508>
 
100
        return {'preexec_fn': _ignore_sigint,
 
101
                'close_fds': True,
 
102
                }
 
103
 
 
104
 
 
105
# don't use prefetch unless paramiko version >= 1.5.2 (there were bugs earlier)
 
106
_default_do_prefetch = False
 
107
if getattr(paramiko, '__version_info__', (0, 0, 0)) >= (1, 5, 5):
 
108
    _default_do_prefetch = True
 
109
 
 
110
 
 
111
_ssh_vendor = None
 
112
def _get_ssh_vendor():
 
113
    """Find out what version of SSH is on the system."""
 
114
    global _ssh_vendor
 
115
    if _ssh_vendor is not None:
 
116
        return _ssh_vendor
 
117
 
 
118
    _ssh_vendor = 'none'
 
119
 
 
120
    if 'BZR_SSH' in os.environ:
 
121
        _ssh_vendor = os.environ['BZR_SSH']
 
122
        if _ssh_vendor == 'paramiko':
 
123
            _ssh_vendor = 'none'
 
124
        return _ssh_vendor
 
125
 
 
126
    try:
 
127
        p = subprocess.Popen(['ssh', '-V'],
 
128
                             stdin=subprocess.PIPE,
 
129
                             stdout=subprocess.PIPE,
 
130
                             stderr=subprocess.PIPE,
 
131
                             **os_specific_subprocess_params())
 
132
        returncode = p.returncode
 
133
        stdout, stderr = p.communicate()
 
134
    except OSError:
 
135
        returncode = -1
 
136
        stdout = stderr = ''
 
137
    if 'OpenSSH' in stderr:
 
138
        mutter('ssh implementation is OpenSSH')
 
139
        _ssh_vendor = 'openssh'
 
140
    elif 'SSH Secure Shell' in stderr:
 
141
        mutter('ssh implementation is SSH Corp.')
 
142
        _ssh_vendor = 'ssh'
 
143
 
 
144
    if _ssh_vendor != 'none':
 
145
        return _ssh_vendor
 
146
 
 
147
    # XXX: 20051123 jamesh
 
148
    # A check for putty's plink or lsh would go here.
 
149
 
 
150
    mutter('falling back to paramiko implementation')
 
151
    return _ssh_vendor
 
152
 
 
153
 
 
154
class SFTPSubprocess:
 
155
    """A socket-like object that talks to an ssh subprocess via pipes."""
 
156
    def __init__(self, hostname, vendor, port=None, user=None):
 
157
        assert vendor in ['openssh', 'ssh']
 
158
        if vendor == 'openssh':
 
159
            args = ['ssh',
 
160
                    '-oForwardX11=no', '-oForwardAgent=no',
 
161
                    '-oClearAllForwardings=yes', '-oProtocol=2',
 
162
                    '-oNoHostAuthenticationForLocalhost=yes']
 
163
            if port is not None:
 
164
                args.extend(['-p', str(port)])
 
165
            if user is not None:
 
166
                args.extend(['-l', user])
 
167
            args.extend(['-s', hostname, 'sftp'])
 
168
        elif vendor == 'ssh':
 
169
            args = ['ssh', '-x']
 
170
            if port is not None:
 
171
                args.extend(['-p', str(port)])
 
172
            if user is not None:
 
173
                args.extend(['-l', user])
 
174
            args.extend(['-s', 'sftp', hostname])
 
175
 
 
176
        self.proc = subprocess.Popen(args,
 
177
                                     stdin=subprocess.PIPE,
 
178
                                     stdout=subprocess.PIPE,
 
179
                                     **os_specific_subprocess_params())
 
180
 
 
181
    def send(self, data):
 
182
        return os.write(self.proc.stdin.fileno(), data)
 
183
 
 
184
    def recv_ready(self):
 
185
        # TODO: jam 20051215 this function is necessary to support the
 
186
        # pipelined() function. In reality, it probably should use
 
187
        # poll() or select() to actually return if there is data
 
188
        # available, otherwise we probably don't get any benefit
 
189
        return True
 
190
 
 
191
    def recv(self, count):
 
192
        return os.read(self.proc.stdout.fileno(), count)
 
193
 
 
194
    def close(self):
 
195
        self.proc.stdin.close()
 
196
        self.proc.stdout.close()
 
197
        self.proc.wait()
 
198
 
 
199
 
 
200
class LoopbackSFTP(object):
 
201
    """Simple wrapper for a socket that pretends to be a paramiko Channel."""
 
202
 
 
203
    def __init__(self, sock):
 
204
        self.__socket = sock
 
205
 
 
206
    def send(self, data):
 
207
        return self.__socket.send(data)
 
208
 
 
209
    def recv(self, n):
 
210
        return self.__socket.recv(n)
 
211
 
 
212
    def recv_ready(self):
 
213
        return True
 
214
 
 
215
    def close(self):
 
216
        self.__socket.close()
 
217
 
 
218
 
 
219
SYSTEM_HOSTKEYS = {}
 
220
BZR_HOSTKEYS = {}
 
221
 
75
222
# This is a weakref dictionary, so that we can reuse connections
76
223
# that are still active. Long term, it might be nice to have some
77
224
# sort of expiration policy, such as disconnect if inactive for
78
225
# X seconds. But that requires a lot more fanciness.
79
226
_connected_hosts = weakref.WeakValueDictionary()
80
227
 
81
 
 
82
 
_paramiko_version = getattr(paramiko, '__version_info__', (0, 0, 0))
83
 
# don't use prefetch unless paramiko version >= 1.5.5 (there were bugs earlier)
84
 
_default_do_prefetch = (_paramiko_version >= (1, 5, 5))
85
 
 
86
 
 
87
228
def clear_connection_cache():
88
229
    """Remove all hosts from the SFTP connection cache.
89
230
 
92
233
    _connected_hosts.clear()
93
234
 
94
235
 
 
236
def load_host_keys():
 
237
    """
 
238
    Load system host keys (probably doesn't work on windows) and any
 
239
    "discovered" keys from previous sessions.
 
240
    """
 
241
    global SYSTEM_HOSTKEYS, BZR_HOSTKEYS
 
242
    try:
 
243
        SYSTEM_HOSTKEYS = paramiko.util.load_host_keys(os.path.expanduser('~/.ssh/known_hosts'))
 
244
    except Exception, e:
 
245
        mutter('failed to load system host keys: ' + str(e))
 
246
    bzr_hostkey_path = pathjoin(config_dir(), 'ssh_host_keys')
 
247
    try:
 
248
        BZR_HOSTKEYS = paramiko.util.load_host_keys(bzr_hostkey_path)
 
249
    except Exception, e:
 
250
        mutter('failed to load bzr host keys: ' + str(e))
 
251
        save_host_keys()
 
252
 
 
253
 
 
254
def save_host_keys():
 
255
    """
 
256
    Save "discovered" host keys in $(config)/ssh_host_keys/.
 
257
    """
 
258
    global SYSTEM_HOSTKEYS, BZR_HOSTKEYS
 
259
    bzr_hostkey_path = pathjoin(config_dir(), 'ssh_host_keys')
 
260
    ensure_config_dir_exists()
 
261
 
 
262
    try:
 
263
        f = open(bzr_hostkey_path, 'w')
 
264
        f.write('# SSH host keys collected by bzr\n')
 
265
        for hostname, keys in BZR_HOSTKEYS.iteritems():
 
266
            for keytype, key in keys.iteritems():
 
267
                f.write('%s %s %s\n' % (hostname, keytype, key.get_base64()))
 
268
        f.close()
 
269
    except IOError, e:
 
270
        mutter('failed to save bzr host keys: ' + str(e))
 
271
 
 
272
 
95
273
class SFTPLock(object):
96
 
    """This fakes a lock in a remote location.
97
 
    
98
 
    A present lock is indicated just by the existence of a file.  This
99
 
    doesn't work well on all transports and they are only used in 
100
 
    deprecated storage formats.
101
 
    """
102
 
    
 
274
    """This fakes a lock in a remote location."""
103
275
    __slots__ = ['path', 'lock_path', 'lock_file', 'transport']
104
 
 
105
276
    def __init__(self, path, transport):
106
277
        assert isinstance(transport, SFTPTransport)
107
278
 
134
305
            pass
135
306
 
136
307
 
137
 
class SFTPUrlHandling(Transport):
138
 
    """Mix-in that does common handling of SSH/SFTP URLs."""
 
308
class SFTPTransport (Transport):
 
309
    """
 
310
    Transport implementation for SFTP access.
 
311
    """
 
312
    _do_prefetch = _default_do_prefetch
139
313
 
140
 
    def __init__(self, base):
 
314
    def __init__(self, base, clone_from=None):
 
315
        assert base.startswith('sftp://')
141
316
        self._parse_url(base)
142
 
        base = self._unparse_url(self._path)
 
317
        base = self._unparse_url()
143
318
        if base[-1] != '/':
144
319
            base += '/'
145
 
        super(SFTPUrlHandling, self).__init__(base)
146
 
 
147
 
    def _parse_url(self, url):
148
 
        (self._scheme,
149
 
         self._username, self._password,
150
 
         self._host, self._port, self._path) = self._split_url(url)
151
 
 
152
 
    def _unparse_url(self, path):
153
 
        """Return a URL for a path relative to this transport.
154
 
        """
155
 
        path = urllib.quote(path)
156
 
        # handle homedir paths
157
 
        if not path.startswith('/'):
158
 
            path = "/~/" + path
159
 
        netloc = urllib.quote(self._host)
160
 
        if self._username is not None:
161
 
            netloc = '%s@%s' % (urllib.quote(self._username), netloc)
162
 
        if self._port is not None:
163
 
            netloc = '%s:%d' % (netloc, self._port)
164
 
        return urlparse.urlunparse((self._scheme, netloc, path, '', '', ''))
165
 
 
166
 
    def _split_url(self, url):
167
 
        (scheme, username, password, host, port, path) = split_url(url)
168
 
        ## assert scheme == 'sftp'
169
 
 
170
 
        # the initial slash should be removed from the path, and treated
171
 
        # as a homedir relative path (the path begins with a double slash
172
 
        # if it is absolute).
173
 
        # see draft-ietf-secsh-scp-sftp-ssh-uri-03.txt
174
 
        # RBC 20060118 we are not using this as its too user hostile. instead
175
 
        # we are following lftp and using /~/foo to mean '~/foo'.
176
 
        # handle homedir paths
177
 
        if path.startswith('/~/'):
178
 
            path = path[3:]
179
 
        elif path == '/~':
180
 
            path = ''
181
 
        return (scheme, username, password, host, port, path)
182
 
 
183
 
    def abspath(self, relpath):
184
 
        """Return the full url to the given relative path.
185
 
        
186
 
        @param relpath: the relative path or path components
187
 
        @type relpath: str or list
188
 
        """
189
 
        return self._unparse_url(self._remote_path(relpath))
190
 
    
191
 
    def _remote_path(self, relpath):
192
 
        """Return the path to be passed along the sftp protocol for relpath.
193
 
        
194
 
        :param relpath: is a urlencoded string.
195
 
        """
196
 
        return self._combine_paths(self._path, relpath)
197
 
 
198
 
 
199
 
class SFTPTransport(SFTPUrlHandling):
200
 
    """Transport implementation for SFTP access."""
201
 
 
202
 
    _do_prefetch = _default_do_prefetch
203
 
    # TODO: jam 20060717 Conceivably these could be configurable, either
204
 
    #       by auto-tuning at run-time, or by a configuration (per host??)
205
 
    #       but the performance curve is pretty flat, so just going with
206
 
    #       reasonable defaults.
207
 
    _max_readv_combine = 200
208
 
    # Having to round trip to the server means waiting for a response,
209
 
    # so it is better to download extra bytes.
210
 
    # 8KiB had good performance for both local and remote network operations
211
 
    _bytes_to_read_before_seek = 8192
212
 
 
213
 
    # The sftp spec says that implementations SHOULD allow reads
214
 
    # to be at least 32K. paramiko.readv() does an async request
215
 
    # for the chunks. So we need to keep it within a single request
216
 
    # size for paramiko <= 1.6.1. paramiko 1.6.2 will probably chop
217
 
    # up the request itself, rather than us having to worry about it
218
 
    _max_request_size = 32768
219
 
 
220
 
    def __init__(self, base, clone_from=None):
221
320
        super(SFTPTransport, self).__init__(base)
222
321
        if clone_from is None:
223
322
            self._sftp_connect()
243
342
        else:
244
343
            return SFTPTransport(self.abspath(offset), self)
245
344
 
 
345
    def abspath(self, relpath):
 
346
        """
 
347
        Return the full url to the given relative path.
 
348
        
 
349
        @param relpath: the relative path or path components
 
350
        @type relpath: str or list
 
351
        """
 
352
        return self._unparse_url(self._remote_path(relpath))
 
353
    
246
354
    def _remote_path(self, relpath):
247
355
        """Return the path to be passed along the sftp protocol for relpath.
248
356
        
249
357
        relpath is a urlencoded string.
250
 
 
251
 
        :return: a path prefixed with / for regular abspath-based urls, or a
252
 
            path that does not begin with / for urls which begin with /~/.
253
358
        """
254
 
        # how does this work? 
255
 
        # it processes relpath with respect to 
256
 
        # our state:
257
 
        # firstly we create a path to evaluate: 
258
 
        # if relpath is an abspath or homedir path, its the entire thing
259
 
        # otherwise we join our base with relpath
260
 
        # then we eliminate all empty segments (double //'s) outside the first
261
 
        # two elements of the list. This avoids problems with trailing 
262
 
        # slashes, or other abnormalities.
263
 
        # finally we evaluate the entire path in a single pass
264
 
        # '.'s are stripped,
265
 
        # '..' result in popping the left most already 
266
 
        # processed path (which can never be empty because of the check for
267
 
        # abspath and homedir meaning that its not, or that we've used our
268
 
        # path. If the pop would pop the root, we ignore it.
269
 
 
270
 
        # Specific case examinations:
271
 
        # remove the special casefor ~: if the current root is ~/ popping of it
272
 
        # = / thus our seed for a ~ based path is ['', '~']
273
 
        # and if we end up with [''] then we had basically ('', '..') (which is
274
 
        # '/..' so we append '' if the length is one, and assert that the first
275
 
        # element is still ''. Lastly, if we end with ['', '~'] as a prefix for
276
 
        # the output, we've got a homedir path, so we strip that prefix before
277
 
        # '/' joining the resulting list.
278
 
        #
279
 
        # case one: '/' -> ['', ''] cannot shrink
280
 
        # case two: '/' + '../foo' -> ['', 'foo'] (take '', '', '..', 'foo')
281
 
        #           and pop the second '' for the '..', append 'foo'
282
 
        # case three: '/~/' -> ['', '~', ''] 
283
 
        # case four: '/~/' + '../foo' -> ['', '~', '', '..', 'foo'],
284
 
        #           and we want to get '/foo' - the empty path in the middle
285
 
        #           needs to be stripped, then normal path manipulation will 
286
 
        #           work.
287
 
        # case five: '/..' ['', '..'], we want ['', '']
288
 
        #            stripping '' outside the first two is ok
289
 
        #            ignore .. if its too high up
290
 
        #
291
 
        # lastly this code is possibly reusable by FTP, but not reusable by
292
 
        # local paths: ~ is resolvable correctly, nor by HTTP or the smart
293
 
        # server: ~ is resolved remotely.
294
 
        # 
295
 
        # however, a version of this that acts on self.base is possible to be
296
 
        # written which manipulates the URL in canonical form, and would be
297
 
        # reusable for all transports, if a flag for allowing ~/ at all was
298
 
        # provided.
 
359
        # FIXME: share the common code across transports
299
360
        assert isinstance(relpath, basestring)
300
 
        relpath = urlutils.unescape(relpath)
301
 
 
302
 
        # case 1)
303
 
        if relpath.startswith('/'):
304
 
            # abspath - normal split is fine.
305
 
            current_path = relpath.split('/')
306
 
        elif relpath.startswith('~/'):
307
 
            # root is homedir based: normal split and prefix '' to remote the
308
 
            # special case
309
 
            current_path = [''].extend(relpath.split('/'))
310
 
        else:
311
 
            # root is from the current directory:
312
 
            if self._path.startswith('/'):
313
 
                # abspath, take the regular split
314
 
                current_path = []
315
 
            else:
316
 
                # homedir based, add the '', '~' not present in self._path
317
 
                current_path = ['', '~']
318
 
            # add our current dir
319
 
            current_path.extend(self._path.split('/'))
320
 
            # add the users relpath
321
 
            current_path.extend(relpath.split('/'))
322
 
        # strip '' segments that are not in the first one - the leading /.
323
 
        to_process = current_path[:1]
324
 
        for segment in current_path[1:]:
325
 
            if segment != '':
326
 
                to_process.append(segment)
327
 
 
328
 
        # process '.' and '..' segments into output_path.
329
 
        output_path = []
330
 
        for segment in to_process:
331
 
            if segment == '..':
332
 
                # directory pop. Remove a directory 
333
 
                # as long as we are not at the root
334
 
                if len(output_path) > 1:
335
 
                    output_path.pop()
336
 
                # else: pass
337
 
                # cannot pop beyond the root, so do nothing
338
 
            elif segment == '.':
339
 
                continue # strip the '.' from the output.
340
 
            else:
341
 
                # this will append '' to output_path for the root elements,
342
 
                # which is appropriate: its why we strip '' in the first pass.
343
 
                output_path.append(segment)
344
 
 
345
 
        # check output special cases:
346
 
        if output_path == ['']:
347
 
            # [''] -> ['', '']
348
 
            output_path = ['', '']
349
 
        elif output_path[:2] == ['', '~']:
350
 
            # ['', '~', ...] -> ...
351
 
            output_path = output_path[2:]
352
 
        path = '/'.join(output_path)
 
361
        relpath = urlutils.unescape(relpath).split('/')
 
362
        basepath = self._path.split('/')
 
363
        if len(basepath) > 0 and basepath[-1] == '':
 
364
            basepath = basepath[:-1]
 
365
 
 
366
        for p in relpath:
 
367
            if p == '..':
 
368
                if len(basepath) == 0:
 
369
                    # In most filesystems, a request for the parent
 
370
                    # of root, just returns root.
 
371
                    continue
 
372
                basepath.pop()
 
373
            elif p == '.':
 
374
                continue # No-op
 
375
            else:
 
376
                basepath.append(p)
 
377
 
 
378
        path = '/'.join(basepath)
353
379
        return path
354
380
 
355
381
    def relpath(self, abspath):
356
 
        scheme, username, password, host, port, path = self._split_url(abspath)
 
382
        username, password, host, port, path = self._split_url(abspath)
357
383
        error = []
358
384
        if (username != self._username):
359
385
            error.append('username mismatch')
394
420
        except (IOError, paramiko.SSHException), e:
395
421
            self._translate_io_exception(e, path, ': error retrieving')
396
422
 
397
 
    def readv(self, relpath, offsets):
398
 
        """See Transport.readv()"""
399
 
        # We overload the default readv() because we want to use a file
400
 
        # that does not have prefetch enabled.
401
 
        # Also, if we have a new paramiko, it implements an async readv()
402
 
        if not offsets:
403
 
            return
404
 
 
405
 
        try:
406
 
            path = self._remote_path(relpath)
407
 
            fp = self._sftp.file(path, mode='rb')
408
 
            readv = getattr(fp, 'readv', None)
409
 
            if readv:
410
 
                return self._sftp_readv(fp, offsets, relpath)
411
 
            mutter('seek and read %s offsets', len(offsets))
412
 
            return self._seek_and_read(fp, offsets, relpath)
413
 
        except (IOError, paramiko.SSHException), e:
414
 
            self._translate_io_exception(e, path, ': error retrieving')
415
 
 
416
 
    def _sftp_readv(self, fp, offsets, relpath='<unknown>'):
417
 
        """Use the readv() member of fp to do async readv.
418
 
 
419
 
        And then read them using paramiko.readv(). paramiko.readv()
420
 
        does not support ranges > 64K, so it caps the request size, and
421
 
        just reads until it gets all the stuff it wants
422
 
        """
423
 
        offsets = list(offsets)
424
 
        sorted_offsets = sorted(offsets)
425
 
 
426
 
        # The algorithm works as follows:
427
 
        # 1) Coalesce nearby reads into a single chunk
428
 
        #    This generates a list of combined regions, the total size
429
 
        #    and the size of the sub regions. This coalescing step is limited
430
 
        #    in the number of nearby chunks to combine, and is allowed to
431
 
        #    skip small breaks in the requests. Limiting it makes sure that
432
 
        #    we can start yielding some data earlier, and skipping means we
433
 
        #    make fewer requests. (Beneficial even when using async)
434
 
        # 2) Break up this combined regions into chunks that are smaller
435
 
        #    than 64KiB. Technically the limit is 65536, but we are a
436
 
        #    little bit conservative. This is because sftp has a maximum
437
 
        #    return chunk size of 64KiB (max size of an unsigned short)
438
 
        # 3) Issue a readv() to paramiko to create an async request for
439
 
        #    all of this data
440
 
        # 4) Read in the data as it comes back, until we've read one
441
 
        #    continuous section as determined in step 1
442
 
        # 5) Break up the full sections into hunks for the original requested
443
 
        #    offsets. And put them in a cache
444
 
        # 6) Check if the next request is in the cache, and if it is, remove
445
 
        #    it from the cache, and yield its data. Continue until no more
446
 
        #    entries are in the cache.
447
 
        # 7) loop back to step 4 until all data has been read
448
 
        #
449
 
        # TODO: jam 20060725 This could be optimized one step further, by
450
 
        #       attempting to yield whatever data we have read, even before
451
 
        #       the first coallesced section has been fully processed.
452
 
 
453
 
        # When coalescing for use with readv(), we don't really need to
454
 
        # use any fudge factor, because the requests are made asynchronously
455
 
        coalesced = list(self._coalesce_offsets(sorted_offsets,
456
 
                               limit=self._max_readv_combine,
457
 
                               fudge_factor=0,
458
 
                               ))
459
 
        requests = []
460
 
        for c_offset in coalesced:
461
 
            start = c_offset.start
462
 
            size = c_offset.length
463
 
 
464
 
            # We need to break this up into multiple requests
465
 
            while size > 0:
466
 
                next_size = min(size, self._max_request_size)
467
 
                requests.append((start, next_size))
468
 
                size -= next_size
469
 
                start += next_size
470
 
 
471
 
        mutter('SFTP.readv() %s offsets => %s coalesced => %s requests',
472
 
                len(offsets), len(coalesced), len(requests))
473
 
 
474
 
        # Queue the current read until we have read the full coalesced section
475
 
        cur_data = []
476
 
        cur_data_len = 0
477
 
        cur_coalesced_stack = iter(coalesced)
478
 
        cur_coalesced = cur_coalesced_stack.next()
479
 
 
480
 
        # Cache the results, but only until they have been fulfilled
481
 
        data_map = {}
482
 
        # turn the list of offsets into a stack
483
 
        offset_stack = iter(offsets)
484
 
        cur_offset_and_size = offset_stack.next()
485
 
 
486
 
        for data in fp.readv(requests):
487
 
            cur_data += data
488
 
            cur_data_len += len(data)
489
 
 
490
 
            if cur_data_len < cur_coalesced.length:
491
 
                continue
492
 
            assert cur_data_len == cur_coalesced.length, \
493
 
                "Somehow we read too much: %s != %s" % (cur_data_len,
494
 
                                                        cur_coalesced.length)
495
 
            all_data = ''.join(cur_data)
496
 
            cur_data = []
497
 
            cur_data_len = 0
498
 
 
499
 
            for suboffset, subsize in cur_coalesced.ranges:
500
 
                key = (cur_coalesced.start+suboffset, subsize)
501
 
                data_map[key] = all_data[suboffset:suboffset+subsize]
502
 
 
503
 
            # Now that we've read some data, see if we can yield anything back
504
 
            while cur_offset_and_size in data_map:
505
 
                this_data = data_map.pop(cur_offset_and_size)
506
 
                yield cur_offset_and_size[0], this_data
507
 
                cur_offset_and_size = offset_stack.next()
508
 
 
509
 
            # We read a coalesced entry, so mark it as done
510
 
            cur_coalesced = None
511
 
            # Now that we've read all of the data for this coalesced section
512
 
            # on to the next
513
 
            cur_coalesced = cur_coalesced_stack.next()
514
 
 
515
 
        if cur_coalesced is not None:
516
 
            raise errors.ShortReadvError(relpath, cur_coalesced.start,
517
 
                cur_coalesced.length, len(data))
518
 
 
519
 
    def put_file(self, relpath, f, mode=None):
520
 
        """
521
 
        Copy the file-like object into the location.
 
423
    def get_partial(self, relpath, start, length=None):
 
424
        """
 
425
        Get just part of a file.
 
426
 
 
427
        :param relpath: Path to the file, relative to base
 
428
        :param start: The starting position to read from
 
429
        :param length: The length to read. A length of None indicates
 
430
                       read to the end of the file.
 
431
        :return: A file-like object containing at least the specified bytes.
 
432
                 Some implementations may return objects which can be read
 
433
                 past this length, but this is not guaranteed.
 
434
        """
 
435
        # TODO: implement get_partial_multi to help with knit support
 
436
        f = self.get(relpath)
 
437
        f.seek(start)
 
438
        if self._do_prefetch and hasattr(f, 'prefetch'):
 
439
            f.prefetch()
 
440
        return f
 
441
 
 
442
    def put(self, relpath, f, mode=None):
 
443
        """
 
444
        Copy the file-like or string object into the location.
522
445
 
523
446
        :param relpath: Location to put the contents, relative to base.
524
 
        :param f:       File-like object.
 
447
        :param f:       File-like or string object.
525
448
        :param mode: The final mode for the file
526
449
        """
527
450
        final_path = self._remote_path(relpath)
539
462
                self._pump(f, fout)
540
463
            except (IOError, paramiko.SSHException), e:
541
464
                self._translate_io_exception(e, tmp_abspath)
542
 
            # XXX: This doesn't truly help like we would like it to.
543
 
            #      The problem is that openssh strips sticky bits. So while we
544
 
            #      can properly set group write permission, we lose the group
545
 
            #      sticky bit. So it is probably best to stop chmodding, and
546
 
            #      just tell users that they need to set the umask correctly.
547
 
            #      The attr.st_mode = mode, in _sftp_open_exclusive
548
 
            #      will handle when the user wants the final mode to be more 
549
 
            #      restrictive. And then we avoid a round trip. Unless 
550
 
            #      paramiko decides to expose an async chmod()
551
 
 
552
 
            # This is designed to chmod() right before we close.
553
 
            # Because we set_pipelined() earlier, theoretically we might 
554
 
            # avoid the round trip for fout.close()
555
465
            if mode is not None:
556
466
                self._sftp.chmod(tmp_abspath, mode)
557
467
            fout.close()
575
485
            # raise the original with its traceback if we can.
576
486
            raise
577
487
 
578
 
    def _put_non_atomic_helper(self, relpath, writer, mode=None,
579
 
                               create_parent_dir=False,
580
 
                               dir_mode=None):
581
 
        abspath = self._remote_path(relpath)
582
 
 
583
 
        # TODO: jam 20060816 paramiko doesn't publicly expose a way to
584
 
        #       set the file mode at create time. If it does, use it.
585
 
        #       But for now, we just chmod later anyway.
586
 
 
587
 
        def _open_and_write_file():
588
 
            """Try to open the target file, raise error on failure"""
589
 
            fout = None
590
 
            try:
591
 
                try:
592
 
                    fout = self._sftp.file(abspath, mode='wb')
593
 
                    fout.set_pipelined(True)
594
 
                    writer(fout)
595
 
                except (paramiko.SSHException, IOError), e:
596
 
                    self._translate_io_exception(e, abspath,
597
 
                                                 ': unable to open')
598
 
 
599
 
                # This is designed to chmod() right before we close.
600
 
                # Because we set_pipelined() earlier, theoretically we might 
601
 
                # avoid the round trip for fout.close()
602
 
                if mode is not None:
603
 
                    self._sftp.chmod(abspath, mode)
604
 
            finally:
605
 
                if fout is not None:
606
 
                    fout.close()
607
 
 
608
 
        if not create_parent_dir:
609
 
            _open_and_write_file()
610
 
            return
611
 
 
612
 
        # Try error handling to create the parent directory if we need to
613
 
        try:
614
 
            _open_and_write_file()
615
 
        except NoSuchFile:
616
 
            # Try to create the parent directory, and then go back to
617
 
            # writing the file
618
 
            parent_dir = os.path.dirname(abspath)
619
 
            self._mkdir(parent_dir, dir_mode)
620
 
            _open_and_write_file()
621
 
 
622
 
    def put_file_non_atomic(self, relpath, f, mode=None,
623
 
                            create_parent_dir=False,
624
 
                            dir_mode=None):
625
 
        """Copy the file-like object into the target location.
626
 
 
627
 
        This function is not strictly safe to use. It is only meant to
628
 
        be used when you already know that the target does not exist.
629
 
        It is not safe, because it will open and truncate the remote
630
 
        file. So there may be a time when the file has invalid contents.
631
 
 
632
 
        :param relpath: The remote location to put the contents.
633
 
        :param f:       File-like object.
634
 
        :param mode:    Possible access permissions for new file.
635
 
                        None means do not set remote permissions.
636
 
        :param create_parent_dir: If we cannot create the target file because
637
 
                        the parent directory does not exist, go ahead and
638
 
                        create it, and then try again.
639
 
        """
640
 
        def writer(fout):
641
 
            self._pump(f, fout)
642
 
        self._put_non_atomic_helper(relpath, writer, mode=mode,
643
 
                                    create_parent_dir=create_parent_dir,
644
 
                                    dir_mode=dir_mode)
645
 
 
646
 
    def put_bytes_non_atomic(self, relpath, bytes, mode=None,
647
 
                             create_parent_dir=False,
648
 
                             dir_mode=None):
649
 
        def writer(fout):
650
 
            fout.write(bytes)
651
 
        self._put_non_atomic_helper(relpath, writer, mode=mode,
652
 
                                    create_parent_dir=create_parent_dir,
653
 
                                    dir_mode=dir_mode)
654
 
 
655
488
    def iter_files_recursive(self):
656
489
        """Walk the relative paths of all files in this transport."""
657
490
        queue = list(self.list_dir('.'))
658
491
        while queue:
659
 
            relpath = queue.pop(0)
 
492
            relpath = urllib.quote(queue.pop(0))
660
493
            st = self.stat(relpath)
661
494
            if stat.S_ISDIR(st.st_mode):
662
495
                for i, basename in enumerate(self.list_dir(relpath)):
664
497
            else:
665
498
                yield relpath
666
499
 
667
 
    def _mkdir(self, abspath, mode=None):
668
 
        if mode is None:
669
 
            local_mode = 0777
670
 
        else:
671
 
            local_mode = mode
672
 
        try:
673
 
            self._sftp.mkdir(abspath, local_mode)
674
 
            if mode is not None:
675
 
                self._sftp.chmod(abspath, mode=mode)
676
 
        except (paramiko.SSHException, IOError), e:
677
 
            self._translate_io_exception(e, abspath, ': unable to mkdir',
678
 
                failure_exc=FileExists)
679
 
 
680
500
    def mkdir(self, relpath, mode=None):
681
501
        """Create a directory at the given path."""
682
 
        self._mkdir(self._remote_path(relpath), mode=mode)
 
502
        try:
 
503
            path = self._remote_path(relpath)
 
504
            # In the paramiko documentation, it says that passing a mode flag 
 
505
            # will filtered against the server umask.
 
506
            # StubSFTPServer does not do this, which would be nice, because it is
 
507
            # what we really want :)
 
508
            # However, real servers do use umask, so we really should do it that way
 
509
            self._sftp.mkdir(path)
 
510
            if mode is not None:
 
511
                self._sftp.chmod(path, mode=mode)
 
512
        except (paramiko.SSHException, IOError), e:
 
513
            self._translate_io_exception(e, path, ': unable to mkdir',
 
514
                failure_exc=FileExists)
683
515
 
684
516
    def _translate_io_exception(self, e, path, more_info='', 
685
517
                                failure_exc=PathError):
697
529
        """
698
530
        # paramiko seems to generate detailless errors.
699
531
        self._translate_error(e, path, raise_generic=False)
700
 
        if getattr(e, 'args', None) is not None:
 
532
        if hasattr(e, 'args'):
701
533
            if (e.args == ('No such file or directory',) or
702
534
                e.args == ('No such file',)):
703
535
                raise NoSuchFile(path, str(e) + more_info)
707
539
            if (e.args == ('Failure',)):
708
540
                raise failure_exc(path, str(e) + more_info)
709
541
            mutter('Raising exception with args %s', e.args)
710
 
        if getattr(e, 'errno', None) is not None:
 
542
        if hasattr(e, 'errno'):
711
543
            mutter('Raising exception with errno %s', e.errno)
712
544
        raise e
713
545
 
714
 
    def append_file(self, relpath, f, mode=None):
 
546
    def append(self, relpath, f, mode=None):
715
547
        """
716
548
        Append the text in the file-like object into the final
717
549
        location.
771
603
        Return a list of all files at the given location.
772
604
        """
773
605
        # does anything actually use this?
774
 
        # -- Unknown
775
 
        # This is at least used by copy_tree for remote upgrades.
776
 
        # -- David Allouche 2006-08-11
777
606
        path = self._remote_path(relpath)
778
607
        try:
779
 
            entries = self._sftp.listdir(path)
 
608
            return self._sftp.listdir(path)
780
609
        except (IOError, paramiko.SSHException), e:
781
610
            self._translate_io_exception(e, path, ': failed to list_dir')
782
 
        return [urlutils.escape(entry) for entry in entries]
783
611
 
784
612
    def rmdir(self, relpath):
785
613
        """See Transport.rmdir."""
823
651
        # that we have taken the lock.
824
652
        return SFTPLock(relpath, self)
825
653
 
 
654
    def _unparse_url(self, path=None):
 
655
        if path is None:
 
656
            path = self._path
 
657
        path = urllib.quote(path)
 
658
        # handle homedir paths
 
659
        if not path.startswith('/'):
 
660
            path = "/~/" + path
 
661
        netloc = urllib.quote(self._host)
 
662
        if self._username is not None:
 
663
            netloc = '%s@%s' % (urllib.quote(self._username), netloc)
 
664
        if self._port is not None:
 
665
            netloc = '%s:%d' % (netloc, self._port)
 
666
        return urlparse.urlunparse(('sftp', netloc, path, '', '', ''))
 
667
 
 
668
    def _split_url(self, url):
 
669
        (scheme, username, password, host, port, path) = split_url(url)
 
670
        assert scheme == 'sftp'
 
671
 
 
672
        # the initial slash should be removed from the path, and treated
 
673
        # as a homedir relative path (the path begins with a double slash
 
674
        # if it is absolute).
 
675
        # see draft-ietf-secsh-scp-sftp-ssh-uri-03.txt
 
676
        # RBC 20060118 we are not using this as its too user hostile. instead
 
677
        # we are following lftp and using /~/foo to mean '~/foo'.
 
678
        # handle homedir paths
 
679
        if path.startswith('/~/'):
 
680
            path = path[3:]
 
681
        elif path == '/~':
 
682
            path = ''
 
683
        return (username, password, host, port, path)
 
684
 
 
685
    def _parse_url(self, url):
 
686
        (self._username, self._password,
 
687
         self._host, self._port, self._path) = self._split_url(url)
 
688
 
826
689
    def _sftp_connect(self):
827
690
        """Connect to the remote sftp server.
828
691
        After this, self._sftp should have a valid connection (or
830
693
 
831
694
        TODO: Raise a more reasonable ConnectionFailed exception
832
695
        """
833
 
        self._sftp = _sftp_connect(self._host, self._port, self._username,
834
 
                self._password)
 
696
        global _connected_hosts
 
697
 
 
698
        idx = (self._host, self._port, self._username)
 
699
        try:
 
700
            self._sftp = _connected_hosts[idx]
 
701
            return
 
702
        except KeyError:
 
703
            pass
 
704
        
 
705
        vendor = _get_ssh_vendor()
 
706
        if vendor == 'loopback':
 
707
            sock = socket.socket()
 
708
            try:
 
709
                sock.connect((self._host, self._port))
 
710
            except socket.error, e:
 
711
                raise ConnectionError('Unable to connect to SSH host %s:%s: %s'
 
712
                                      % (self._host, self._port, e))
 
713
            self._sftp = SFTPClient(LoopbackSFTP(sock))
 
714
        elif vendor != 'none':
 
715
            sock = SFTPSubprocess(self._host, vendor, self._port,
 
716
                                  self._username)
 
717
            self._sftp = SFTPClient(sock)
 
718
        else:
 
719
            self._paramiko_connect()
 
720
 
 
721
        _connected_hosts[idx] = self._sftp
 
722
 
 
723
    def _paramiko_connect(self):
 
724
        global SYSTEM_HOSTKEYS, BZR_HOSTKEYS
 
725
        
 
726
        load_host_keys()
 
727
 
 
728
        try:
 
729
            t = paramiko.Transport((self._host, self._port or 22))
 
730
            t.set_log_channel('bzr.paramiko')
 
731
            t.start_client()
 
732
        except paramiko.SSHException, e:
 
733
            raise ConnectionError('Unable to reach SSH host %s:%s: %s' 
 
734
                                  % (self._host, self._port, e))
 
735
            
 
736
        server_key = t.get_remote_server_key()
 
737
        server_key_hex = paramiko.util.hexify(server_key.get_fingerprint())
 
738
        keytype = server_key.get_name()
 
739
        if SYSTEM_HOSTKEYS.has_key(self._host) and SYSTEM_HOSTKEYS[self._host].has_key(keytype):
 
740
            our_server_key = SYSTEM_HOSTKEYS[self._host][keytype]
 
741
            our_server_key_hex = paramiko.util.hexify(our_server_key.get_fingerprint())
 
742
        elif BZR_HOSTKEYS.has_key(self._host) and BZR_HOSTKEYS[self._host].has_key(keytype):
 
743
            our_server_key = BZR_HOSTKEYS[self._host][keytype]
 
744
            our_server_key_hex = paramiko.util.hexify(our_server_key.get_fingerprint())
 
745
        else:
 
746
            warning('Adding %s host key for %s: %s' % (keytype, self._host, server_key_hex))
 
747
            if not BZR_HOSTKEYS.has_key(self._host):
 
748
                BZR_HOSTKEYS[self._host] = {}
 
749
            BZR_HOSTKEYS[self._host][keytype] = server_key
 
750
            our_server_key = server_key
 
751
            our_server_key_hex = paramiko.util.hexify(our_server_key.get_fingerprint())
 
752
            save_host_keys()
 
753
        if server_key != our_server_key:
 
754
            filename1 = os.path.expanduser('~/.ssh/known_hosts')
 
755
            filename2 = pathjoin(config_dir(), 'ssh_host_keys')
 
756
            raise TransportError('Host keys for %s do not match!  %s != %s' % \
 
757
                (self._host, our_server_key_hex, server_key_hex),
 
758
                ['Try editing %s or %s' % (filename1, filename2)])
 
759
 
 
760
        self._sftp_auth(t)
 
761
        
 
762
        try:
 
763
            self._sftp = t.open_sftp_client()
 
764
        except paramiko.SSHException, e:
 
765
            raise ConnectionError('Unable to start sftp client %s:%d' %
 
766
                                  (self._host, self._port), e)
 
767
 
 
768
    def _sftp_auth(self, transport):
 
769
        # paramiko requires a username, but it might be none if nothing was supplied
 
770
        # use the local username, just in case.
 
771
        # We don't override self._username, because if we aren't using paramiko,
 
772
        # the username might be specified in ~/.ssh/config and we don't want to
 
773
        # force it to something else
 
774
        # Also, it would mess up the self.relpath() functionality
 
775
        username = self._username or getpass.getuser()
 
776
 
 
777
        # Paramiko tries to open a socket.AF_UNIX in order to connect
 
778
        # to ssh-agent. That attribute doesn't exist on win32 (it does in cygwin)
 
779
        # so we get an AttributeError exception. For now, just don't try to
 
780
        # connect to an agent if we are on win32
 
781
        if sys.platform != 'win32':
 
782
            agent = paramiko.Agent()
 
783
            for key in agent.get_keys():
 
784
                mutter('Trying SSH agent key %s' % paramiko.util.hexify(key.get_fingerprint()))
 
785
                try:
 
786
                    transport.auth_publickey(username, key)
 
787
                    return
 
788
                except paramiko.SSHException, e:
 
789
                    pass
 
790
        
 
791
        # okay, try finding id_rsa or id_dss?  (posix only)
 
792
        if self._try_pkey_auth(transport, paramiko.RSAKey, username, 'id_rsa'):
 
793
            return
 
794
        if self._try_pkey_auth(transport, paramiko.DSSKey, username, 'id_dsa'):
 
795
            return
 
796
 
 
797
        if self._password:
 
798
            try:
 
799
                transport.auth_password(username, self._password)
 
800
                return
 
801
            except paramiko.SSHException, e:
 
802
                pass
 
803
 
 
804
            # FIXME: Don't keep a password held in memory if you can help it
 
805
            #self._password = None
 
806
 
 
807
        # give up and ask for a password
 
808
        password = bzrlib.ui.ui_factory.get_password(
 
809
                prompt='SSH %(user)s@%(host)s password',
 
810
                user=username, host=self._host)
 
811
        try:
 
812
            transport.auth_password(username, password)
 
813
        except paramiko.SSHException, e:
 
814
            raise ConnectionError('Unable to authenticate to SSH host as %s@%s' %
 
815
                                  (username, self._host), e)
 
816
 
 
817
    def _try_pkey_auth(self, transport, pkey_class, username, filename):
 
818
        filename = os.path.expanduser('~/.ssh/' + filename)
 
819
        try:
 
820
            key = pkey_class.from_private_key_file(filename)
 
821
            transport.auth_publickey(username, key)
 
822
            return True
 
823
        except paramiko.PasswordRequiredException:
 
824
            password = bzrlib.ui.ui_factory.get_password(
 
825
                    prompt='SSH %(filename)s password',
 
826
                    filename=filename)
 
827
            try:
 
828
                key = pkey_class.from_private_key_file(filename, password)
 
829
                transport.auth_publickey(username, key)
 
830
                return True
 
831
            except paramiko.SSHException:
 
832
                mutter('SSH authentication via %s key failed.' % (os.path.basename(filename),))
 
833
        except paramiko.SSHException:
 
834
            mutter('SSH authentication via %s key failed.' % (os.path.basename(filename),))
 
835
        except IOError:
 
836
            pass
 
837
        return False
835
838
 
836
839
    def _sftp_open_exclusive(self, abspath, mode=None):
837
840
        """Open a remote path exclusively.
847
850
        :param abspath: The remote absolute path where the file should be opened
848
851
        :param mode: The mode permissions bits for the new file
849
852
        """
850
 
        # TODO: jam 20060816 Paramiko >= 1.6.2 (probably earlier) supports
851
 
        #       using the 'x' flag to indicate SFTP_FLAG_EXCL.
852
 
        #       However, there is no way to set the permission mode at open 
853
 
        #       time using the sftp_client.file() functionality.
854
853
        path = self._sftp._adjust_cwd(abspath)
855
 
        # mutter('sftp abspath %s => %s', abspath, path)
856
854
        attr = SFTPAttributes()
857
855
        if mode is not None:
858
856
            attr.st_mode = mode
868
866
            self._translate_io_exception(e, abspath, ': unable to open',
869
867
                failure_exc=FileExists)
870
868
 
871
 
    def _can_roundtrip_unix_modebits(self):
872
 
        if sys.platform == 'win32':
873
 
            # anyone else?
874
 
            return False
875
 
        else:
876
 
            return True
877
869
 
878
870
# ------------- server test implementation --------------
 
871
import socket
879
872
import threading
880
873
 
881
874
from bzrlib.tests.stub_sftp import StubServer, StubSFTPServer
944
937
                        x)
945
938
 
946
939
 
947
 
class SocketDelay(object):
948
 
    """A socket decorator to make TCP appear slower.
949
 
 
950
 
    This changes recv, send, and sendall to add a fixed latency to each python
951
 
    call if a new roundtrip is detected. That is, when a recv is called and the
952
 
    flag new_roundtrip is set, latency is charged. Every send and send_all
953
 
    sets this flag.
954
 
 
955
 
    In addition every send, sendall and recv sleeps a bit per character send to
956
 
    simulate bandwidth.
957
 
 
958
 
    Not all methods are implemented, this is deliberate as this class is not a
959
 
    replacement for the builtin sockets layer. fileno is not implemented to
960
 
    prevent the proxy being bypassed. 
961
 
    """
962
 
 
963
 
    simulated_time = 0
964
 
    _proxied_arguments = dict.fromkeys([
965
 
        "close", "getpeername", "getsockname", "getsockopt", "gettimeout",
966
 
        "setblocking", "setsockopt", "settimeout", "shutdown"])
967
 
 
968
 
    def __init__(self, sock, latency, bandwidth=1.0, 
969
 
                 really_sleep=True):
970
 
        """ 
971
 
        :param bandwith: simulated bandwith (MegaBit)
972
 
        :param really_sleep: If set to false, the SocketDelay will just
973
 
        increase a counter, instead of calling time.sleep. This is useful for
974
 
        unittesting the SocketDelay.
975
 
        """
976
 
        self.sock = sock
977
 
        self.latency = latency
978
 
        self.really_sleep = really_sleep
979
 
        self.time_per_byte = 1 / (bandwidth / 8.0 * 1024 * 1024) 
980
 
        self.new_roundtrip = False
981
 
 
982
 
    def sleep(self, s):
983
 
        if self.really_sleep:
984
 
            time.sleep(s)
985
 
        else:
986
 
            SocketDelay.simulated_time += s
987
 
 
988
 
    def __getattr__(self, attr):
989
 
        if attr in SocketDelay._proxied_arguments:
990
 
            return getattr(self.sock, attr)
991
 
        raise AttributeError("'SocketDelay' object has no attribute %r" %
992
 
                             attr)
993
 
 
994
 
    def dup(self):
995
 
        return SocketDelay(self.sock.dup(), self.latency, self.time_per_byte,
996
 
                           self._sleep)
997
 
 
998
 
    def recv(self, *args):
999
 
        data = self.sock.recv(*args)
1000
 
        if data and self.new_roundtrip:
1001
 
            self.new_roundtrip = False
1002
 
            self.sleep(self.latency)
1003
 
        self.sleep(len(data) * self.time_per_byte)
1004
 
        return data
1005
 
 
1006
 
    def sendall(self, data, flags=0):
1007
 
        if not self.new_roundtrip:
1008
 
            self.new_roundtrip = True
1009
 
            self.sleep(self.latency)
1010
 
        self.sleep(len(data) * self.time_per_byte)
1011
 
        return self.sock.sendall(data, flags)
1012
 
 
1013
 
    def send(self, data, flags=0):
1014
 
        if not self.new_roundtrip:
1015
 
            self.new_roundtrip = True
1016
 
            self.sleep(self.latency)
1017
 
        bytes_sent = self.sock.send(data, flags)
1018
 
        self.sleep(bytes_sent * self.time_per_byte)
1019
 
        return bytes_sent
1020
 
 
1021
 
 
1022
940
class SFTPServer(Server):
1023
941
    """Common code for SFTP server facilities."""
1024
942
 
1025
 
    def __init__(self, server_interface=StubServer):
 
943
    def __init__(self):
1026
944
        self._original_vendor = None
1027
945
        self._homedir = None
1028
946
        self._server_homedir = None
1029
947
        self._listener = None
1030
948
        self._root = None
1031
 
        self._vendor = ssh.ParamikoVendor()
1032
 
        self._server_interface = server_interface
 
949
        self._vendor = 'none'
1033
950
        # sftp server logs
1034
951
        self.logs = []
1035
 
        self.add_latency = 0
1036
952
 
1037
953
    def _get_sftp_url(self, path):
1038
954
        """Calculate an sftp url to this server for path."""
1042
958
        """StubServer uses this to log when a new server is created."""
1043
959
        self.logs.append(message)
1044
960
 
1045
 
    def _run_server_entry(self, sock):
1046
 
        """Entry point for all implementations of _run_server.
1047
 
        
1048
 
        If self.add_latency is > 0.000001 then sock is given a latency adding
1049
 
        decorator.
1050
 
        """
1051
 
        if self.add_latency > 0.000001:
1052
 
            sock = SocketDelay(sock, self.add_latency)
1053
 
        return self._run_server(sock)
1054
 
 
1055
961
    def _run_server(self, s):
1056
962
        ssh_server = paramiko.Transport(s)
1057
 
        key_file = pathjoin(self._homedir, 'test_rsa.key')
 
963
        key_file = os.path.join(self._homedir, 'test_rsa.key')
1058
964
        f = open(key_file, 'w')
1059
965
        f.write(STUB_SERVER_KEY)
1060
966
        f.close()
1061
967
        host_key = paramiko.RSAKey.from_private_key_file(key_file)
1062
968
        ssh_server.add_server_key(host_key)
1063
 
        server = self._server_interface(self)
 
969
        server = StubServer(self)
1064
970
        ssh_server.set_subsystem_handler('sftp', paramiko.SFTPServer,
1065
971
                                         StubSFTPServer, root=self._root,
1066
972
                                         home=self._server_homedir)
1069
975
        event.wait(5.0)
1070
976
    
1071
977
    def setUp(self):
1072
 
        self._original_vendor = ssh._ssh_vendor
1073
 
        ssh._ssh_vendor = self._vendor
1074
 
        if sys.platform == 'win32':
1075
 
            # Win32 needs to use the UNICODE api
1076
 
            self._homedir = getcwd()
1077
 
        else:
1078
 
            # But Linux SFTP servers should just deal in bytestreams
1079
 
            self._homedir = os.getcwd()
 
978
        global _ssh_vendor
 
979
        self._original_vendor = _ssh_vendor
 
980
        _ssh_vendor = self._vendor
 
981
        self._homedir = os.getcwd()
1080
982
        if self._server_homedir is None:
1081
983
            self._server_homedir = self._homedir
1082
984
        self._root = '/'
1083
 
        if sys.platform == 'win32':
1084
 
            self._root = ''
1085
 
        self._listener = SocketListener(self._run_server_entry)
 
985
        # FIXME WINDOWS: _root should be _server_homedir[0]:/
 
986
        self._listener = SocketListener(self._run_server)
1086
987
        self._listener.setDaemon(True)
1087
988
        self._listener.start()
1088
989
 
1089
990
    def tearDown(self):
1090
991
        """See bzrlib.transport.Server.tearDown."""
 
992
        global _ssh_vendor
1091
993
        self._listener.stop()
1092
 
        ssh._ssh_vendor = self._original_vendor
 
994
        _ssh_vendor = self._original_vendor
1093
995
 
1094
996
    def get_bogus_url(self):
1095
997
        """See bzrlib.transport.Server.get_bogus_url."""
1096
 
        # this is chosen to try to prevent trouble with proxies, wierd dns, etc
1097
 
        # we bind a random socket, so that we get a guaranteed unused port
1098
 
        # we just never listen on that port
1099
 
        s = socket.socket()
1100
 
        s.bind(('localhost', 0))
1101
 
        return 'sftp://%s:%s/' % s.getsockname()
 
998
        # this is chosen to try to prevent trouble with proxies, wierd dns,
 
999
        # etc
 
1000
        return 'sftp://127.0.0.1:1/'
 
1001
 
1102
1002
 
1103
1003
 
1104
1004
class SFTPFullAbsoluteServer(SFTPServer):
1114
1014
 
1115
1015
    def __init__(self):
1116
1016
        super(SFTPServerWithoutSSH, self).__init__()
1117
 
        self._vendor = ssh.LoopbackVendor()
 
1017
        self._vendor = 'loopback'
1118
1018
 
1119
1019
    def _run_server(self, sock):
1120
 
        # Re-import these as locals, so that they're still accessible during
1121
 
        # interpreter shutdown (when all module globals get set to None, leading
1122
 
        # to confusing errors like "'NoneType' object has no attribute 'error'".
1123
1020
        class FakeChannel(object):
1124
1021
            def get_transport(self):
1125
1022
                return self
1153
1050
 
1154
1051
    def get_url(self):
1155
1052
        """See bzrlib.transport.Server.get_url."""
1156
 
        if sys.platform == 'win32':
1157
 
            return self._get_sftp_url(urlutils.escape(self._homedir))
1158
 
        else:
1159
 
            return self._get_sftp_url(urlutils.escape(self._homedir[1:]))
 
1053
        return self._get_sftp_url(urlutils.escape(self._homedir[1:]))
1160
1054
 
1161
1055
 
1162
1056
class SFTPHomeDirServer(SFTPServerWithoutSSH):
1175
1069
        super(SFTPSiblingAbsoluteServer, self).setUp()
1176
1070
 
1177
1071
 
1178
 
def _sftp_connect(host, port, username, password):
1179
 
    """Connect to the remote sftp server.
1180
 
 
1181
 
    :raises: a TransportError 'could not connect'.
1182
 
 
1183
 
    :returns: an paramiko.sftp_client.SFTPClient
1184
 
 
1185
 
    TODO: Raise a more reasonable ConnectionFailed exception
1186
 
    """
1187
 
    idx = (host, port, username)
1188
 
    try:
1189
 
        return _connected_hosts[idx]
1190
 
    except KeyError:
1191
 
        pass
1192
 
    
1193
 
    sftp = _sftp_connect_uncached(host, port, username, password)
1194
 
    _connected_hosts[idx] = sftp
1195
 
    return sftp
1196
 
 
1197
 
def _sftp_connect_uncached(host, port, username, password):
1198
 
    vendor = ssh._get_ssh_vendor()
1199
 
    sftp = vendor.connect_sftp(username, password, host, port)
1200
 
    return sftp
1201
 
 
1202
 
 
1203
1072
def get_test_permutations():
1204
1073
    """Return the permutations to be used in testing."""
1205
1074
    return [(SFTPTransport, SFTPAbsoluteServer),