o tf@sdZddlmZddlmZGdddeZGdddeZGdd d eZGd d d eZ Gd d d eZ GdddeZ Gdddee Z d ddZdadaGdddeZ d!d"ddZgdZdS)#z 0MQ Error classes and functions.) annotations)EINTRc@eZdZdZdS) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N__name__ __module__ __qualname____doc__r r R/var/www/html/software/conda/envs/catlas/lib/python3.10/site-packages/zmq/error.pyr rc@s>eZdZUdZdZded<ddddZdd d Zdd dZdS)ZMQErrorzWrap an errno style error. Parameters ---------- errno : int The ZMQ errno or None. If None, then ``zmq_errno()`` is called and used. msg : str Description of the error or None. N int | Noneerrnomsg str | NonecCsnddlm}m}|dur|}t|tr'||_|dur"|||_dS||_dS|dur2t||_dS||_dS)aWrap 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. r)strerror zmq_errnoN) zmq.backendrr isinstanceintrstr)selfrrrrr r r __init__s    zZMQError.__init__returnrcCs|jSN)rrr r r __str__<szZMQError.__str__cCs|jjdt|dS)Nz('z')) __class__rrrr r r __repr__?szZMQError.__repr__)NN)rrrr)rr) rrr r r__annotations__rrr r r r r rs   rc@r) ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nrr r r r r"Cr r"c@r)NotDonezRaised when timeout is reached while waiting for 0MQ to finish with a Message See Also -------- .MessageTracker.wait : object for tracking when ZeroMQ is done Nrr r r r r#Lr r#c"eZdZdZdfdd ZZS)ContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 ignoredcddlm}t|dS)Nr)ETERM)zmqr(superr)rrrr(rr r r[ zContextTerminated.__init__r&r&rrr r r __classcell__r r r+r r%Ur%cr$)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 r&cr')Nr)EAGAIN)r)r2r*r)rrrr2r+r r rgr,zAgain.__init__r-r.r r r+r r1ar0r1cs2eZdZdZeZdfdd ZfddZZS)InterruptedSystemCallzWrapper for EINTR This exception should be caught internally in pyzmq to retry system calls, and not propagate to the user. .. versionadded:: 14.7 r&csttdSr)r*rr)rrrr+r r rxszInterruptedSystemCall.__init__cst}|dS)NzB: This call should have been retried. Please report this to pyzmq.)r*r)rsr+r r r{s zInterruptedSystemCall.__str__r-) rrr r rrrrr/r r r+r r3ms r3NTcCs~|dkr=|durddlm}|}|dkr|sdSddlm}m}|tkr)t|||kr1t|||kr9t|t |dS)zhinternal utility for checking zmq return condition and raising the appropriate Exception class Nr)r)r2r() rrr)r2r(rr3r1r%r)rcrZerror_without_errnorr2r(r r r _check_rcs  r7c@s0eZdZdZdZd dddZd d Zd d ZdS)ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 NFeature min_versionrrcCs0tdur ddlm}|a||_||_t|_dS)Nr) zmq_version) _zmq_versionr)r;rr:version)rr:rr;r r r rs   zZMQVersionError.__init__cCs dt|S)NzZMQVersionError('%s')rrr r r r s zZMQVersionError.__repr__cCs|jd|jd|jS)Nz requires libzmq >= z, have )rr:r=rr r r rszZMQVersionError.__str__r9)r:rrr)rrr r r:rr rr r r r r8s   r8r9min_version_info3tuple[int] | tuple[int, int] | tuple[int, int, int]rrcCsDtdur ddlm}|at|kr ddd|D}t||dS)zCheck 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(). Nr)zmq_version_info.css|]}t|VqdSrr>).0vr r r sz!_check_version..)_zmq_version_infor)rBjoinr8)r@rrBr:r r r _check_versions  rI)rr"rr#r%r3r1r8)NTr?)r@rArr)r __future__rrr Exceptionrrr"r#r%r1InterruptedErrorr3r7rGr<NotImplementedErrorr8rI__all__r r r r s"  5