/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to breezy/smart/medium.py

  • Committer: Jelmer Vernooij
  • Date: 2017-05-22 00:56:52 UTC
  • mfrom: (6621.2.26 py3_pokes)
  • Revision ID: jelmer@jelmer.uk-20170522005652-yjahcr9hwmjkno7n
Merge Python3 porting work ('py3 pokes')

Show diffs side-by-side

added added

removed removed

Lines of Context:
breezy/smart/medium.py
32
32
import time
33
33
 
34
34
import breezy
35
 
from breezy.lazy_import import lazy_import
 
35
from ..lazy_import import lazy_import
36
36
lazy_import(globals(), """
37
37
import select
38
38
import socket
51
51
from breezy.smart import client, protocol, request, signals, vfs
52
52
from breezy.transport import ssh
53
53
""")
54
 
from breezy import osutils
 
54
from .. import osutils
55
55
 
56
56
# Throughout this module buffer size parameters are either limited to be at
57
57
# most _MAX_READ_SIZE, or are ignored and _MAX_READ_SIZE is used instead.
233
233
            while not self.finished:
234
234
                server_protocol = self._build_protocol()
235
235
                self._serve_one_request(server_protocol)
236
 
        except errors.ConnectionTimeout, e:
 
236
        except errors.ConnectionTimeout as e:
237
237
            trace.note('%s' % (e,))
238
238
            trace.log_exception_quietly()
239
239
            self._disconnect_client()
240
240
            # We reported it, no reason to make a big fuss.
241
241
            return
242
 
        except Exception, e:
 
242
        except Exception as e:
243
243
            stderr.write("%s terminating on exception %s\n" % (self, e))
244
244
            raise
245
245
        self._disconnect_client()
329
329
            self._serve_one_request_unguarded(protocol)
330
330
        except KeyboardInterrupt:
331
331
            raise
332
 
        except Exception, e:
 
332
        except Exception as e:
333
333
            self.terminate_due_to_error()
334
334
 
335
335
    def terminate_due_to_error(self):
804
804
                client_protocol = protocol.SmartClientRequestProtocolOne(medium_request)
805
805
                client_protocol.query_version()
806
806
                self._done_hello = True
807
 
            except errors.SmartProtocolError, e:
 
807
            except errors.SmartProtocolError as e:
808
808
                # Cache the error, just like we would cache a successful
809
809
                # result.
810
810
                self._protocol_version_error = e
907
907
        """See SmartClientStreamMedium.accept_bytes."""
908
908
        try:
909
909
            self._writeable_pipe.write(bytes)
910
 
        except IOError, e:
 
910
        except IOError as e:
911
911
            if e.errno in (errno.EINVAL, errno.EPIPE):
912
912
                raise errors.ConnectionReset(
913
913
                    "Error trying to write to subprocess", e)
1105
1105
        try:
1106
1106
            sockaddrs = socket.getaddrinfo(self._host, port, socket.AF_UNSPEC,
1107
1107
                socket.SOCK_STREAM, 0, 0)
1108
 
        except socket.gaierror, (err_num, err_msg):
 
1108
        except socket.gaierror as xxx_todo_changeme:
 
1109
            (err_num, err_msg) = xxx_todo_changeme.args
1109
1110
            raise errors.ConnectionError("failed to lookup %s:%d: %s" %
1110
1111
                    (self._host, port, err_msg))
1111
1112
        # Initialize err in case there are no addresses returned:
1116
1117
                self._socket.setsockopt(socket.IPPROTO_TCP,
1117
1118
                                        socket.TCP_NODELAY, 1)
1118
1119
                self._socket.connect(sockaddr)
1119
 
            except socket.error, err:
 
1120
            except socket.error as err:
1120
1121
                if self._socket is not None:
1121
1122
                    self._socket.close()
1122
1123
                self._socket = None
1125
1126
        if self._socket is None:
1126
1127
            # socket errors either have a (string) or (errno, string) as their
1127
1128
            # args.
1128
 
            if type(err.args) is str:
 
1129
            if isinstance(err.args, str):
1129
1130
                err_msg = err.args
1130
1131
            else:
1131
1132
                err_msg = err.args[1]