~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transport/ssh.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2007-12-18 23:41:30 UTC
  • mfrom: (3099.3.7 graph_optimization)
  • Revision ID: pqm@pqm.ubuntu.com-20071218234130-061grgxsaf1g7bao
(jam) Implement ParentProviders.get_parent_map() and deprecate
        get_parents()

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006-2011 Robey Pointer <robey@lag.net>
 
1
# Copyright (C) 2005 Robey Pointer <robey@lag.net>
2
2
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
3
3
#
4
4
# This program is free software; you can redistribute it and/or modify
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
 
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
16
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
17
17
 
18
18
"""Foundation SSH support for SFTP and smart server."""
19
19
 
20
 
from __future__ import absolute_import
21
 
 
22
20
import errno
23
21
import getpass
24
 
import logging
25
22
import os
26
23
import socket
27
24
import subprocess
28
25
import sys
29
 
from binascii import hexlify
30
26
 
31
27
from bzrlib import (
32
28
    config,
97
93
            try:
98
94
                vendor = self._ssh_vendors[vendor_name]
99
95
            except KeyError:
100
 
                vendor = self._get_vendor_from_path(vendor_name)
101
 
                if vendor is None:
102
 
                    raise errors.UnknownSSH(vendor_name)
103
 
                vendor.executable_path = vendor_name
 
96
                raise errors.UnknownSSH(vendor_name)
104
97
            return vendor
105
98
        return None
106
99
 
116
109
            stdout = stderr = ''
117
110
        return stdout + stderr
118
111
 
119
 
    def _get_vendor_by_version_string(self, version, progname):
 
112
    def _get_vendor_by_version_string(self, version, args):
120
113
        """Return the vendor or None based on output from the subprocess.
121
114
 
122
115
        :param version: The output of 'ssh -V' like command.
129
122
        elif 'SSH Secure Shell' in version:
130
123
            trace.mutter('ssh implementation is SSH Corp.')
131
124
            vendor = SSHCorpSubprocessVendor()
132
 
        elif 'lsh' in version:
133
 
            trace.mutter('ssh implementation is GNU lsh.')
134
 
            vendor = LSHSubprocessVendor()
135
 
        # As plink user prompts are not handled currently, don't auto-detect
136
 
        # it by inspection below, but keep this vendor detection for if a path
137
 
        # is given in BZR_SSH. See https://bugs.launchpad.net/bugs/414743
138
 
        elif 'plink' in version and progname == 'plink':
 
125
        elif 'plink' in version and args[0] == 'plink':
139
126
            # Checking if "plink" was the executed argument as Windows
140
 
            # sometimes reports 'ssh -V' incorrectly with 'plink' in its
 
127
            # sometimes reports 'ssh -V' incorrectly with 'plink' in it's
141
128
            # version.  See https://bugs.launchpad.net/bzr/+bug/107155
142
129
            trace.mutter("ssh implementation is Putty's plink.")
143
130
            vendor = PLinkSubprocessVendor()
145
132
 
146
133
    def _get_vendor_by_inspection(self):
147
134
        """Return the vendor or None by checking for known SSH implementations."""
148
 
        version = self._get_ssh_version_string(['ssh', '-V'])
149
 
        return self._get_vendor_by_version_string(version, "ssh")
150
 
 
151
 
    def _get_vendor_from_path(self, path):
152
 
        """Return the vendor or None using the program at the given path"""
153
 
        version = self._get_ssh_version_string([path, '-V'])
154
 
        return self._get_vendor_by_version_string(version, 
155
 
            os.path.splitext(os.path.basename(path))[0])
 
135
        # detection of plink vendor is disabled because of bug #107593
 
136
        # https://bugs.launchpad.net/bzr/+bug/107593
 
137
        # who want plink should explicitly enable it with BZR_SSH environment
 
138
        # variable.
 
139
        #~for args in (['ssh', '-V'], ['plink', '-V']):
 
140
        for args in (['ssh', '-V'],):
 
141
            version = self._get_ssh_version_string(args)
 
142
            vendor = self._get_vendor_by_version_string(version, args)
 
143
            if vendor is not None:
 
144
                return vendor
 
145
        return None
156
146
 
157
147
    def get_vendor(self, environment=None):
158
148
        """Find out what version of SSH is on the system.
179
169
register_ssh_vendor = _ssh_vendor_manager.register_vendor
180
170
 
181
171
 
182
 
def _ignore_signals():
 
172
def _ignore_sigint():
183
173
    # TODO: This should possibly ignore SIGHUP as well, but bzr currently
184
174
    # doesn't handle it itself.
185
175
    # <https://launchpad.net/products/bzr/+bug/41433/+index>
186
176
    import signal
187
177
    signal.signal(signal.SIGINT, signal.SIG_IGN)
188
 
    # GZ 2010-02-19: Perhaps make this check if breakin is installed instead
189
 
    if signal.getsignal(signal.SIGQUIT) != signal.SIG_DFL:
190
 
        signal.signal(signal.SIGQUIT, signal.SIG_IGN)
191
 
 
192
 
 
193
 
class SocketAsChannelAdapter(object):
 
178
 
 
179
 
 
180
class LoopbackSFTP(object):
194
181
    """Simple wrapper for a socket that pretends to be a paramiko Channel."""
195
182
 
196
183
    def __init__(self, sock):
197
184
        self.__socket = sock
198
185
 
199
 
    def get_name(self):
200
 
        return "bzr SocketAsChannelAdapter"
201
 
 
202
186
    def send(self, data):
203
187
        return self.__socket.send(data)
204
188
 
205
189
    def recv(self, n):
206
 
        try:
207
 
            return self.__socket.recv(n)
208
 
        except socket.error, e:
209
 
            if e.args[0] in (errno.EPIPE, errno.ECONNRESET, errno.ECONNABORTED,
210
 
                             errno.EBADF):
211
 
                # Connection has closed.  Paramiko expects an empty string in
212
 
                # this case, not an exception.
213
 
                return ''
214
 
            raise
 
190
        return self.__socket.recv(n)
215
191
 
216
192
    def recv_ready(self):
217
 
        # TODO: jam 20051215 this function is necessary to support the
218
 
        # pipelined() function. In reality, it probably should use
219
 
        # poll() or select() to actually return if there is data
220
 
        # available, otherwise we probably don't get any benefit
221
193
        return True
222
194
 
223
195
    def close(self):
229
201
 
230
202
    def connect_sftp(self, username, password, host, port):
231
203
        """Make an SSH connection, and return an SFTPClient.
232
 
 
 
204
        
233
205
        :param username: an ascii string
234
206
        :param password: an ascii string
235
207
        :param host: a host name as an ascii string
244
216
 
245
217
    def connect_ssh(self, username, password, host, port, command):
246
218
        """Make an SSH connection.
247
 
 
248
 
        :returns: an SSHConnection.
 
219
        
 
220
        :returns: something with a `close` method, and a `get_filelike_channels`
 
221
            method that returns a pair of (read, write) filelike objects.
249
222
        """
250
223
        raise NotImplementedError(self.connect_ssh)
251
224
 
269
242
            sock.connect((host, port))
270
243
        except socket.error, e:
271
244
            self._raise_connection_error(host, port=port, orig_error=e)
272
 
        return SFTPClient(SocketAsChannelAdapter(sock))
 
245
        return SFTPClient(LoopbackSFTP(sock))
273
246
 
274
247
register_ssh_vendor('loopback', LoopbackVendor())
275
248
 
276
249
 
 
250
class _ParamikoSSHConnection(object):
 
251
    def __init__(self, channel):
 
252
        self.channel = channel
 
253
 
 
254
    def get_filelike_channels(self):
 
255
        return self.channel.makefile('rb'), self.channel.makefile('wb')
 
256
 
 
257
    def close(self):
 
258
        return self.channel.close()
 
259
 
 
260
 
277
261
class ParamikoVendor(SSHVendor):
278
262
    """Vendor that uses paramiko."""
279
263
 
280
 
    def _hexify(self, s):
281
 
        return hexlify(s).upper()
282
 
 
283
264
    def _connect(self, username, password, host, port):
284
265
        global SYSTEM_HOSTKEYS, BZR_HOSTKEYS
285
266
 
293
274
            self._raise_connection_error(host, port=port, orig_error=e)
294
275
 
295
276
        server_key = t.get_remote_server_key()
296
 
        server_key_hex = self._hexify(server_key.get_fingerprint())
 
277
        server_key_hex = paramiko.util.hexify(server_key.get_fingerprint())
297
278
        keytype = server_key.get_name()
298
279
        if host in SYSTEM_HOSTKEYS and keytype in SYSTEM_HOSTKEYS[host]:
299
280
            our_server_key = SYSTEM_HOSTKEYS[host][keytype]
300
 
            our_server_key_hex = self._hexify(our_server_key.get_fingerprint())
 
281
            our_server_key_hex = paramiko.util.hexify(
 
282
                our_server_key.get_fingerprint())
301
283
        elif host in BZR_HOSTKEYS and keytype in BZR_HOSTKEYS[host]:
302
284
            our_server_key = BZR_HOSTKEYS[host][keytype]
303
 
            our_server_key_hex = self._hexify(our_server_key.get_fingerprint())
 
285
            our_server_key_hex = paramiko.util.hexify(
 
286
                our_server_key.get_fingerprint())
304
287
        else:
305
288
            trace.warning('Adding %s host key for %s: %s'
306
289
                          % (keytype, host, server_key_hex))
310
293
            else:
311
294
                BZR_HOSTKEYS.setdefault(host, {})[keytype] = server_key
312
295
            our_server_key = server_key
313
 
            our_server_key_hex = self._hexify(our_server_key.get_fingerprint())
 
296
            our_server_key_hex = paramiko.util.hexify(
 
297
                our_server_key.get_fingerprint())
314
298
            save_host_keys()
315
299
        if server_key != our_server_key:
316
300
            filename1 = os.path.expanduser('~/.ssh/known_hosts')
342
326
            self._raise_connection_error(host, port=port, orig_error=e,
343
327
                                         msg='Unable to invoke remote bzr')
344
328
 
345
 
_ssh_connection_errors = (EOFError, OSError, IOError, socket.error)
346
329
if paramiko is not None:
347
330
    vendor = ParamikoVendor()
348
331
    register_ssh_vendor('paramiko', vendor)
349
332
    register_ssh_vendor('none', vendor)
350
333
    register_default_ssh_vendor(vendor)
351
 
    _ssh_connection_errors += (paramiko.SSHException,)
 
334
    _sftp_connection_errors = (EOFError, paramiko.SSHException)
352
335
    del vendor
 
336
else:
 
337
    _sftp_connection_errors = (EOFError,)
353
338
 
354
339
 
355
340
class SubprocessVendor(SSHVendor):
356
341
    """Abstract base class for vendors that use pipes to a subprocess."""
357
342
 
358
 
    # In general stderr should be inherited from the parent process so prompts
359
 
    # are visible on the terminal. This can be overriden to another file for
360
 
    # tests, but beware of using PIPE which may hang due to not being read.
361
 
    _stderr_target = None
362
 
 
363
343
    def _connect(self, argv):
364
 
        # Attempt to make a socketpair to use as stdin/stdout for the SSH
365
 
        # subprocess.  We prefer sockets to pipes because they support
366
 
        # non-blocking short reads, allowing us to optimistically read 64k (or
367
 
        # whatever) chunks.
368
 
        try:
369
 
            my_sock, subproc_sock = socket.socketpair()
370
 
            osutils.set_fd_cloexec(my_sock)
371
 
        except (AttributeError, socket.error):
372
 
            # This platform doesn't support socketpair(), so just use ordinary
373
 
            # pipes instead.
374
 
            stdin = stdout = subprocess.PIPE
375
 
            my_sock, subproc_sock = None, None
376
 
        else:
377
 
            stdin = stdout = subproc_sock
378
 
        proc = subprocess.Popen(argv, stdin=stdin, stdout=stdout,
379
 
                                stderr=self._stderr_target,
 
344
        proc = subprocess.Popen(argv,
 
345
                                stdin=subprocess.PIPE,
 
346
                                stdout=subprocess.PIPE,
380
347
                                **os_specific_subprocess_params())
381
 
        if subproc_sock is not None:
382
 
            subproc_sock.close()
383
 
        return SSHSubprocessConnection(proc, sock=my_sock)
 
348
        return SSHSubprocess(proc)
384
349
 
385
350
    def connect_sftp(self, username, password, host, port):
386
351
        try:
387
352
            argv = self._get_vendor_specific_argv(username, host, port,
388
353
                                                  subsystem='sftp')
389
354
            sock = self._connect(argv)
390
 
            return SFTPClient(SocketAsChannelAdapter(sock))
391
 
        except _ssh_connection_errors, e:
 
355
            return SFTPClient(sock)
 
356
        except _sftp_connection_errors, e:
 
357
            self._raise_connection_error(host, port=port, orig_error=e)
 
358
        except (OSError, IOError), e:
 
359
            # If the machine is fast enough, ssh can actually exit
 
360
            # before we try and send it the sftp request, which
 
361
            # raises a Broken Pipe
 
362
            if e.errno not in (errno.EPIPE,):
 
363
                raise
392
364
            self._raise_connection_error(host, port=port, orig_error=e)
393
365
 
394
366
    def connect_ssh(self, username, password, host, port, command):
396
368
            argv = self._get_vendor_specific_argv(username, host, port,
397
369
                                                  command=command)
398
370
            return self._connect(argv)
399
 
        except _ssh_connection_errors, e:
 
371
        except (EOFError), e:
 
372
            self._raise_connection_error(host, port=port, orig_error=e)
 
373
        except (OSError, IOError), e:
 
374
            # If the machine is fast enough, ssh can actually exit
 
375
            # before we try and send it the sftp request, which
 
376
            # raises a Broken Pipe
 
377
            if e.errno not in (errno.EPIPE,):
 
378
                raise
400
379
            self._raise_connection_error(host, port=port, orig_error=e)
401
380
 
402
381
    def _get_vendor_specific_argv(self, username, host, port, subsystem=None,
403
382
                                  command=None):
404
383
        """Returns the argument list to run the subprocess with.
405
 
 
 
384
        
406
385
        Exactly one of 'subsystem' and 'command' must be specified.
407
386
        """
408
387
        raise NotImplementedError(self._get_vendor_specific_argv)
411
390
class OpenSSHSubprocessVendor(SubprocessVendor):
412
391
    """SSH vendor that uses the 'ssh' executable from OpenSSH."""
413
392
 
414
 
    executable_path = 'ssh'
415
 
 
416
393
    def _get_vendor_specific_argv(self, username, host, port, subsystem=None,
417
394
                                  command=None):
418
 
        args = [self.executable_path,
 
395
        assert subsystem is not None or command is not None, (
 
396
            'Must specify a command or subsystem')
 
397
        if subsystem is not None:
 
398
            assert command is None, (
 
399
                'subsystem and command are mutually exclusive')
 
400
        args = ['ssh',
419
401
                '-oForwardX11=no', '-oForwardAgent=no',
420
 
                '-oClearAllForwardings=yes',
 
402
                '-oClearAllForwardings=yes', '-oProtocol=2',
421
403
                '-oNoHostAuthenticationForLocalhost=yes']
422
404
        if port is not None:
423
405
            args.extend(['-p', str(port)])
435
417
class SSHCorpSubprocessVendor(SubprocessVendor):
436
418
    """SSH vendor that uses the 'ssh' executable from SSH Corporation."""
437
419
 
438
 
    executable_path = 'ssh'
439
 
 
440
420
    def _get_vendor_specific_argv(self, username, host, port, subsystem=None,
441
421
                                  command=None):
442
 
        args = [self.executable_path, '-x']
 
422
        assert subsystem is not None or command is not None, (
 
423
            'Must specify a command or subsystem')
 
424
        if subsystem is not None:
 
425
            assert command is None, (
 
426
                'subsystem and command are mutually exclusive')
 
427
        args = ['ssh', '-x']
443
428
        if port is not None:
444
429
            args.extend(['-p', str(port)])
445
430
        if username is not None:
450
435
            args.extend([host] + command)
451
436
        return args
452
437
 
453
 
register_ssh_vendor('sshcorp', SSHCorpSubprocessVendor())
454
 
 
455
 
 
456
 
class LSHSubprocessVendor(SubprocessVendor):
457
 
    """SSH vendor that uses the 'lsh' executable from GNU"""
458
 
 
459
 
    executable_path = 'lsh'
460
 
 
461
 
    def _get_vendor_specific_argv(self, username, host, port, subsystem=None,
462
 
                                  command=None):
463
 
        args = [self.executable_path]
464
 
        if port is not None:
465
 
            args.extend(['-p', str(port)])
466
 
        if username is not None:
467
 
            args.extend(['-l', username])
468
 
        if subsystem is not None:
469
 
            args.extend(['--subsystem', subsystem, host])
470
 
        else:
471
 
            args.extend([host] + command)
472
 
        return args
473
 
 
474
 
register_ssh_vendor('lsh', LSHSubprocessVendor())
 
438
register_ssh_vendor('ssh', SSHCorpSubprocessVendor())
475
439
 
476
440
 
477
441
class PLinkSubprocessVendor(SubprocessVendor):
478
442
    """SSH vendor that uses the 'plink' executable from Putty."""
479
443
 
480
 
    executable_path = 'plink'
481
 
 
482
444
    def _get_vendor_specific_argv(self, username, host, port, subsystem=None,
483
445
                                  command=None):
484
 
        args = [self.executable_path, '-x', '-a', '-ssh', '-2', '-batch']
 
446
        assert subsystem is not None or command is not None, (
 
447
            'Must specify a command or subsystem')
 
448
        if subsystem is not None:
 
449
            assert command is None, (
 
450
                'subsystem and command are mutually exclusive')
 
451
        args = ['plink', '-x', '-a', '-ssh', '-2']
485
452
        if port is not None:
486
453
            args.extend(['-P', str(port)])
487
454
        if username is not None:
496
463
 
497
464
 
498
465
def _paramiko_auth(username, password, host, port, paramiko_transport):
 
466
    # paramiko requires a username, but it might be none if nothing was supplied
 
467
    # use the local username, just in case.
 
468
    # We don't override username, because if we aren't using paramiko,
 
469
    # the username might be specified in ~/.ssh/config and we don't want to
 
470
    # force it to something else
 
471
    # Also, it would mess up the self.relpath() functionality
499
472
    auth = config.AuthenticationConfig()
500
 
    # paramiko requires a username, but it might be none if nothing was
501
 
    # supplied.  If so, use the local username.
502
473
    if username is None:
503
 
        username = auth.get_user('ssh', host, port=port,
504
 
                                 default=getpass.getuser())
 
474
        username = auth.get_user('ssh', host, port=port)
 
475
        if username is None:
 
476
            # Default to local user
 
477
            username = getpass.getuser()
 
478
 
505
479
    if _use_ssh_agent:
506
480
        agent = paramiko.Agent()
507
481
        for key in agent.get_keys():
508
482
            trace.mutter('Trying SSH agent key %s'
509
 
                         % self._hexify(key.get_fingerprint()))
 
483
                         % paramiko.util.hexify(key.get_fingerprint()))
510
484
            try:
511
485
                paramiko_transport.auth_publickey(username, key)
512
486
                return
519
493
    if _try_pkey_auth(paramiko_transport, paramiko.DSSKey, username, 'id_dsa'):
520
494
        return
521
495
 
522
 
    # If we have gotten this far, we are about to try for passwords, do an
523
 
    # auth_none check to see if it is even supported.
524
 
    supported_auth_types = []
525
 
    try:
526
 
        # Note that with paramiko <1.7.5 this logs an INFO message:
527
 
        #    Authentication type (none) not permitted.
528
 
        # So we explicitly disable the logging level for this action
529
 
        old_level = paramiko_transport.logger.level
530
 
        paramiko_transport.logger.setLevel(logging.WARNING)
531
 
        try:
532
 
            paramiko_transport.auth_none(username)
533
 
        finally:
534
 
            paramiko_transport.logger.setLevel(old_level)
535
 
    except paramiko.BadAuthenticationType, e:
536
 
        # Supported methods are in the exception
537
 
        supported_auth_types = e.allowed_types
538
 
    except paramiko.SSHException, e:
539
 
        # Don't know what happened, but just ignore it
540
 
        pass
541
 
    # We treat 'keyboard-interactive' and 'password' auth methods identically,
542
 
    # because Paramiko's auth_password method will automatically try
543
 
    # 'keyboard-interactive' auth (using the password as the response) if
544
 
    # 'password' auth is not available.  Apparently some Debian and Gentoo
545
 
    # OpenSSH servers require this.
546
 
    # XXX: It's possible for a server to require keyboard-interactive auth that
547
 
    # requires something other than a single password, but we currently don't
548
 
    # support that.
549
 
    if ('password' not in supported_auth_types and
550
 
        'keyboard-interactive' not in supported_auth_types):
551
 
        raise errors.ConnectionError('Unable to authenticate to SSH host as'
552
 
            '\n  %s@%s\nsupported auth types: %s'
553
 
            % (username, host, supported_auth_types))
554
 
 
555
496
    if password:
556
497
        try:
557
498
            paramiko_transport.auth_password(username, password)
561
502
 
562
503
    # give up and ask for a password
563
504
    password = auth.get_password('ssh', host, username, port=port)
564
 
    # get_password can still return None, which means we should not prompt
565
 
    if password is not None:
566
 
        try:
567
 
            paramiko_transport.auth_password(username, password)
568
 
        except paramiko.SSHException, e:
569
 
            raise errors.ConnectionError(
570
 
                'Unable to authenticate to SSH host as'
571
 
                '\n  %s@%s\n' % (username, host), e)
572
 
    else:
573
 
        raise errors.ConnectionError('Unable to authenticate to SSH host as'
574
 
                                     '  %s@%s' % (username, host))
 
505
    try:
 
506
        paramiko_transport.auth_password(username, password)
 
507
    except paramiko.SSHException, e:
 
508
        raise errors.ConnectionError(
 
509
            'Unable to authenticate to SSH host as %s@%s' % (username, host), e)
575
510
 
576
511
 
577
512
def _try_pkey_auth(paramiko_transport, pkey_class, username, filename):
582
517
        return True
583
518
    except paramiko.PasswordRequiredException:
584
519
        password = ui.ui_factory.get_password(
585
 
            prompt=u'SSH %(filename)s password',
586
 
            filename=filename.decode(osutils._fs_enc))
 
520
            prompt='SSH %(filename)s password', filename=filename)
587
521
        try:
588
522
            key = pkey_class.from_private_key_file(filename, password)
589
523
            paramiko_transport.auth_publickey(username, key)
640
574
def os_specific_subprocess_params():
641
575
    """Get O/S specific subprocess parameters."""
642
576
    if sys.platform == 'win32':
643
 
        # setting the process group and closing fds is not supported on
 
577
        # setting the process group and closing fds is not supported on 
644
578
        # win32
645
579
        return {}
646
580
    else:
647
 
        # We close fds other than the pipes as the child process does not need
 
581
        # We close fds other than the pipes as the child process does not need 
648
582
        # them to be open.
649
583
        #
650
584
        # We also set the child process to ignore SIGINT.  Normally the signal
652
586
        # this causes it to be seen only by bzr and not by ssh.  Python will
653
587
        # generate a KeyboardInterrupt in bzr, and we will then have a chance
654
588
        # to release locks or do other cleanup over ssh before the connection
655
 
        # goes away.
 
589
        # goes away.  
656
590
        # <https://launchpad.net/products/bzr/+bug/5987>
657
591
        #
658
592
        # Running it in a separate process group is not good because then it
659
593
        # can't get non-echoed input of a password or passphrase.
660
594
        # <https://launchpad.net/products/bzr/+bug/40508>
661
 
        return {'preexec_fn': _ignore_signals,
 
595
        return {'preexec_fn': _ignore_sigint,
662
596
                'close_fds': True,
663
597
                }
664
598
 
665
 
import weakref
666
 
_subproc_weakrefs = set()
667
 
 
668
 
def _close_ssh_proc(proc, sock):
669
 
    """Carefully close stdin/stdout and reap the SSH process.
670
 
 
671
 
    If the pipes are already closed and/or the process has already been
672
 
    wait()ed on, that's ok, and no error is raised.  The goal is to do our best
673
 
    to clean up (whether or not a clean up was already tried).
674
 
    """
675
 
    funcs = []
676
 
    for closeable in (proc.stdin, proc.stdout, sock):
677
 
        # We expect that either proc (a subprocess.Popen) will have stdin and
678
 
        # stdout streams to close, or that we will have been passed a socket to
679
 
        # close, with the option not in use being None.
680
 
        if closeable is not None:
681
 
            funcs.append(closeable.close)
682
 
    funcs.append(proc.wait)
683
 
    for func in funcs:
684
 
        try:
685
 
            func()
686
 
        except OSError:
687
 
            # It's ok for the pipe to already be closed, or the process to
688
 
            # already be finished.
689
 
            continue
690
 
 
691
 
 
692
 
class SSHConnection(object):
693
 
    """Abstract base class for SSH connections."""
694
 
 
695
 
    def get_sock_or_pipes(self):
696
 
        """Returns a (kind, io_object) pair.
697
 
 
698
 
        If kind == 'socket', then io_object is a socket.
699
 
 
700
 
        If kind == 'pipes', then io_object is a pair of file-like objects
701
 
        (read_from, write_to).
702
 
        """
703
 
        raise NotImplementedError(self.get_sock_or_pipes)
704
 
 
705
 
    def close(self):
706
 
        raise NotImplementedError(self.close)
707
 
 
708
 
 
709
 
class SSHSubprocessConnection(SSHConnection):
710
 
    """A connection to an ssh subprocess via pipes or a socket.
711
 
 
712
 
    This class is also socket-like enough to be used with
713
 
    SocketAsChannelAdapter (it has 'send' and 'recv' methods).
714
 
    """
715
 
 
716
 
    def __init__(self, proc, sock=None):
717
 
        """Constructor.
718
 
 
719
 
        :param proc: a subprocess.Popen
720
 
        :param sock: if proc.stdin/out is a socket from a socketpair, then sock
721
 
            should bzrlib's half of that socketpair.  If not passed, proc's
722
 
            stdin/out is assumed to be ordinary pipes.
723
 
        """
 
599
 
 
600
class SSHSubprocess(object):
 
601
    """A socket-like object that talks to an ssh subprocess via pipes."""
 
602
 
 
603
    def __init__(self, proc):
724
604
        self.proc = proc
725
 
        self._sock = sock
726
 
        # Add a weakref to proc that will attempt to do the same as self.close
727
 
        # to avoid leaving processes lingering indefinitely.
728
 
        def terminate(ref):
729
 
            _subproc_weakrefs.remove(ref)
730
 
            _close_ssh_proc(proc, sock)
731
 
        _subproc_weakrefs.add(weakref.ref(self, terminate))
732
605
 
733
606
    def send(self, data):
734
 
        if self._sock is not None:
735
 
            return self._sock.send(data)
736
 
        else:
737
 
            return os.write(self.proc.stdin.fileno(), data)
 
607
        return os.write(self.proc.stdin.fileno(), data)
 
608
 
 
609
    def recv_ready(self):
 
610
        # TODO: jam 20051215 this function is necessary to support the
 
611
        # pipelined() function. In reality, it probably should use
 
612
        # poll() or select() to actually return if there is data
 
613
        # available, otherwise we probably don't get any benefit
 
614
        return True
738
615
 
739
616
    def recv(self, count):
740
 
        if self._sock is not None:
741
 
            return self._sock.recv(count)
742
 
        else:
743
 
            return os.read(self.proc.stdout.fileno(), count)
744
 
 
745
 
    def close(self):
746
 
        _close_ssh_proc(self.proc, self._sock)
747
 
 
748
 
    def get_sock_or_pipes(self):
749
 
        if self._sock is not None:
750
 
            return 'socket', self._sock
751
 
        else:
752
 
            return 'pipes', (self.proc.stdout, self.proc.stdin)
753
 
 
754
 
 
755
 
class _ParamikoSSHConnection(SSHConnection):
756
 
    """An SSH connection via paramiko."""
757
 
 
758
 
    def __init__(self, channel):
759
 
        self.channel = channel
760
 
 
761
 
    def get_sock_or_pipes(self):
762
 
        return ('socket', self.channel)
763
 
 
764
 
    def close(self):
765
 
        return self.channel.close()
766
 
 
 
617
        return os.read(self.proc.stdout.fileno(), count)
 
618
 
 
619
    def close(self):
 
620
        self.proc.stdin.close()
 
621
        self.proc.stdout.close()
 
622
        self.proc.wait()
 
623
 
 
624
    def get_filelike_channels(self):
 
625
        return (self.proc.stdout, self.proc.stdin)
767
626