Index: third_party/twisted_8_1/twisted/internet/error.py |
diff --git a/third_party/twisted_8_1/twisted/internet/error.py b/third_party/twisted_8_1/twisted/internet/error.py |
deleted file mode 100644 |
index 7c043f69e123e0792635f6b6cc6914d47f65bc72..0000000000000000000000000000000000000000 |
--- a/third_party/twisted_8_1/twisted/internet/error.py |
+++ /dev/null |
@@ -1,305 +0,0 @@ |
-# Copyright (c) 2001-2008 Twisted Matrix Laboratories. |
-# See LICENSE for details. |
- |
- |
-""" |
-Exceptions and errors for use in twisted.internet modules. |
- |
-Maintainer: U{Itamar Shtull-Trauring<mailto:twisted@itamarst.org>} |
-""" |
- |
-import socket |
- |
- |
-class BindError(Exception): |
- """An error occurred binding to an interface""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
-class CannotListenError(BindError): |
- """This gets raised by a call to startListening, when the object cannot start listening. |
- |
- @ivar interface: the interface I tried to listen on |
- @ivar port: the port I tried to listen on |
- @ivar socketError: the exception I got when I tried to listen |
- @type socketError: L{socket.error} |
- """ |
- def __init__(self, interface, port, socketError): |
- BindError.__init__(self, interface, port, socketError) |
- self.interface = interface |
- self.port = port |
- self.socketError = socketError |
- |
- def __str__(self): |
- iface = self.interface or 'any' |
- return "Couldn't listen on %s:%s: %s." % (iface, self.port, |
- self.socketError) |
- |
- |
-class MulticastJoinError(Exception): |
- """ |
- An attempt to join a multicast group failed. |
- """ |
- |
- |
-class MessageLengthError(Exception): |
- """Message is too long to send""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
- |
-class DNSLookupError(IOError): |
- """DNS lookup failed""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
- |
-class ConnectInProgressError(Exception): |
- """A connect operation was started and isn't done yet.""" |
- |
- |
-# connection errors |
- |
-class ConnectError(Exception): |
- """An error occurred while connecting""" |
- |
- def __init__(self, osError=None, string=""): |
- self.osError = osError |
- Exception.__init__(self, string) |
- |
- def __str__(self): |
- s = self.__doc__ or self.__class__.__name__ |
- if self.osError: |
- s = '%s: %s' % (s, self.osError) |
- if self[0]: |
- s = '%s: %s' % (s, self[0]) |
- s = '%s.' % s |
- return s |
- |
- |
-class ConnectBindError(ConnectError): |
- """Couldn't bind""" |
- |
- |
-class UnknownHostError(ConnectError): |
- """Hostname couldn't be looked up""" |
- |
- |
-class NoRouteError(ConnectError): |
- """No route to host""" |
- |
- |
-class ConnectionRefusedError(ConnectError): |
- """Connection was refused by other side""" |
- |
- |
-class TCPTimedOutError(ConnectError): |
- """TCP connection timed out""" |
- |
- |
-class BadFileError(ConnectError): |
- """File used for UNIX socket is no good""" |
- |
- |
-class ServiceNameUnknownError(ConnectError): |
- """Service name given as port is unknown""" |
- |
- |
-class UserError(ConnectError): |
- """User aborted connection""" |
- |
- |
-class TimeoutError(UserError): |
- """User timeout caused connection failure""" |
- |
-class SSLError(ConnectError): |
- """An SSL error occurred""" |
- |
-class VerifyError(Exception): |
- """Could not verify something that was supposed to be signed. |
- """ |
- |
-class PeerVerifyError(VerifyError): |
- """The peer rejected our verify error. |
- """ |
- |
-class CertificateError(Exception): |
- """ |
- We did not find a certificate where we expected to find one. |
- """ |
- |
-try: |
- import errno |
- errnoMapping = { |
- errno.ENETUNREACH: NoRouteError, |
- errno.ECONNREFUSED: ConnectionRefusedError, |
- errno.ETIMEDOUT: TCPTimedOutError, |
- } |
- if hasattr(errno, "WSAECONNREFUSED"): |
- errnoMapping[errno.WSAECONNREFUSED] = ConnectionRefusedError |
- errnoMapping[errno.WSAENETUNREACH] = NoRouteError |
-except ImportError: |
- errnoMapping = {} |
- |
-def getConnectError(e): |
- """Given a socket exception, return connection error.""" |
- try: |
- number, string = e |
- except ValueError: |
- return ConnectError(string=e) |
- |
- if hasattr(socket, 'gaierror') and isinstance(e, socket.gaierror): |
- # only works in 2.2 |
- klass = UnknownHostError |
- else: |
- klass = errnoMapping.get(number, ConnectError) |
- return klass(number, string) |
- |
- |
- |
-class ConnectionClosed(Exception): |
- """ |
- Connection was closed, whether cleanly or non-cleanly. |
- """ |
- |
- |
- |
-class ConnectionLost(ConnectionClosed): |
- """Connection to the other side was lost in a non-clean fashion""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
- |
- |
-class ConnectionDone(ConnectionClosed): |
- """Connection was closed cleanly""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
- |
-class ConnectionFdescWentAway(ConnectionLost): |
- """Uh""" #TODO |
- |
- |
-class AlreadyCalled(ValueError): |
- """Tried to cancel an already-called event""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
- |
-class AlreadyCancelled(ValueError): |
- """Tried to cancel an already-cancelled event""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
- |
- |
-class PotentialZombieWarning(Warning): |
- """ |
- Emitted when L{IReactorProcess.spawnProcess} is called in a way which may |
- result in termination of the created child process not being reported. |
- """ |
- MESSAGE = ( |
- "spawnProcess called, but the SIGCHLD handler is not " |
- "installed. This probably means you have not yet " |
- "called reactor.run, or called " |
- "reactor.run(installSignalHandler=0). You will probably " |
- "never see this process finish, and it may become a " |
- "zombie process.") |
- |
- |
- |
-class ProcessDone(ConnectionDone): |
- """A process has ended without apparent errors""" |
- |
- def __init__(self, status): |
- Exception.__init__(self, "process finished with exit code 0") |
- self.exitCode = 0 |
- self.signal = None |
- self.status = status |
- |
- |
-class ProcessTerminated(ConnectionLost): |
- """A process has ended with a probable error condition""" |
- |
- def __init__(self, exitCode=None, signal=None, status=None): |
- self.exitCode = exitCode |
- self.signal = signal |
- self.status = status |
- s = "process ended" |
- if exitCode is not None: s = s + " with exit code %s" % exitCode |
- if signal is not None: s = s + " by signal %s" % signal |
- Exception.__init__(self, s) |
- |
- |
-class ProcessExitedAlready(Exception): |
- """The process has already excited, and the operation requested can no longer be performed.""" |
- |
- |
-class NotConnectingError(RuntimeError): |
- """The Connector was not connecting when it was asked to stop connecting""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
-class NotListeningError(RuntimeError): |
- """The Port was not listening when it was asked to stop listening""" |
- |
- def __str__(self): |
- s = self.__doc__ |
- if self.args: |
- s = '%s: %s' % (s, ' '.join(self.args)) |
- s = '%s.' % s |
- return s |
- |
- |
-class ReactorNotRunning(RuntimeError): |
- """ |
- Error raised when trying to stop a reactor which is not running. |
- """ |
- |
- |
-class ReactorAlreadyRunning(RuntimeError): |
- """ |
- Error raised when trying to start the reactor multiple times. |
- """ |
- |