summaryrefslogtreecommitdiffstats
path: root/external_libs/python/zmq/error.py
diff options
context:
space:
mode:
Diffstat (limited to 'external_libs/python/zmq/error.py')
-rw-r--r--external_libs/python/zmq/error.py164
1 files changed, 0 insertions, 164 deletions
diff --git a/external_libs/python/zmq/error.py b/external_libs/python/zmq/error.py
deleted file mode 100644
index 48cdaafa..00000000
--- a/external_libs/python/zmq/error.py
+++ /dev/null
@@ -1,164 +0,0 @@
-"""0MQ Error classes and functions."""
-
-# Copyright (C) PyZMQ Developers
-# Distributed under the terms of the Modified BSD License.
-
-
-class ZMQBaseError(Exception):
- """Base exception class for 0MQ errors in Python."""
- pass
-
-class ZMQError(ZMQBaseError):
- """Wrap an errno style error.
-
- Parameters
- ----------
- errno : int
- The ZMQ errno or None. If None, then ``zmq_errno()`` is called and
- used.
- msg : string
- Description of the error or None.
- """
- errno = None
-
- def __init__(self, errno=None, msg=None):
- """Wrap an errno style error.
-
- Parameters
- ----------
- errno : int
- The ZMQ errno or None. If None, then ``zmq_errno()`` is called and
- used.
- msg : string
- Description of the error or None.
- """
- from zmq.backend import strerror, zmq_errno
- if errno is None:
- errno = zmq_errno()
- if isinstance(errno, int):
- self.errno = errno
- if msg is None:
- self.strerror = strerror(errno)
- else:
- self.strerror = msg
- else:
- if msg is None:
- self.strerror = str(errno)
- else:
- self.strerror = msg
- # flush signals, because there could be a SIGINT
- # waiting to pounce, resulting in uncaught exceptions.
- # Doing this here means getting SIGINT during a blocking
- # libzmq call will raise a *catchable* KeyboardInterrupt
- # PyErr_CheckSignals()
-
- def __str__(self):
- return self.strerror
-
- def __repr__(self):
- return "ZMQError('%s')"%self.strerror
-
-
-class ZMQBindError(ZMQBaseError):
- """An error for ``Socket.bind_to_random_port()``.
-
- See Also
- --------
- .Socket.bind_to_random_port
- """
- pass
-
-
-class NotDone(ZMQBaseError):
- """Raised when timeout is reached while waiting for 0MQ to finish with a Message
-
- See Also
- --------
- .MessageTracker.wait : object for tracking when ZeroMQ is done
- """
- pass
-
-
-class ContextTerminated(ZMQError):
- """Wrapper for zmq.ETERM
-
- .. versionadded:: 13.0
- """
- pass
-
-
-class Again(ZMQError):
- """Wrapper for zmq.EAGAIN
-
- .. versionadded:: 13.0
- """
- pass
-
-
-def _check_rc(rc, errno=None):
- """internal utility for checking zmq return condition
-
- and raising the appropriate Exception class
- """
- if rc < 0:
- from zmq.backend import zmq_errno
- if errno is None:
- errno = zmq_errno()
- from zmq import EAGAIN, ETERM
- if errno == EAGAIN:
- raise Again(errno)
- elif errno == ETERM:
- raise ContextTerminated(errno)
- else:
- raise ZMQError(errno)
-
-_zmq_version_info = None
-_zmq_version = None
-
-class ZMQVersionError(NotImplementedError):
- """Raised when a feature is not provided by the linked version of libzmq.
-
- .. versionadded:: 14.2
- """
- min_version = None
- def __init__(self, min_version, msg='Feature'):
- global _zmq_version
- if _zmq_version is None:
- from zmq import zmq_version
- _zmq_version = zmq_version()
- self.msg = msg
- self.min_version = min_version
- self.version = _zmq_version
-
- def __repr__(self):
- return "ZMQVersionError('%s')" % str(self)
-
- def __str__(self):
- return "%s requires libzmq >= %s, have %s" % (self.msg, self.min_version, self.version)
-
-
-def _check_version(min_version_info, msg='Feature'):
- """Check for libzmq
-
- raises ZMQVersionError if current zmq version is not at least min_version
-
- min_version_info is a tuple of integers, and will be compared against zmq.zmq_version_info().
- """
- global _zmq_version_info
- if _zmq_version_info is None:
- from zmq import zmq_version_info
- _zmq_version_info = zmq_version_info()
- if _zmq_version_info < min_version_info:
- min_version = '.'.join(str(v) for v in min_version_info)
- raise ZMQVersionError(min_version, msg)
-
-
-__all__ = [
- 'ZMQBaseError',
- 'ZMQBindError',
- 'ZMQError',
- 'NotDone',
- 'ContextTerminated',
- 'Again',
- 'ZMQVersionError',
-]