
    Efe                     R    d dl mZ d dlZd dlmZmZmZmZ d dlmZ  G d de      Z	y)    )ThreadN)AgainContextTerminatedZMQErrorstrerror)BaseZMQTestCasec                   $    e Zd Zd Zd Zd Zd Zy)TestZMQErrorc                 ^    t        d      D ]  }t        |      }t        |t              rJ  y)z'test that strerror gets the right type.
   N)ranger   
isinstancestr)selfies      6/usr/lib/python3/dist-packages/zmq/tests/test_error.pytest_strerrorzTestZMQError.test_strerror   s.    r 	&AAa%%%	&    c                     t        d      D ]7  }t        |      }|j                  |k(  sJ t        |      t	        |      k(  r7J  y )Nr   )r   r   errnor   r   )r   r   r   s      r   test_zmqerrorzTestZMQError.test_zmqerror   sF    2Y 	-EA77e###q6Xe_,,,	-r   c                 F   | j                   j                  t        j                        }| j	                  t
        |j                  t        j                         | j                  t        j                  |j                  t        j                         |j                          y )N)contextsocketzmqREPassertRaisesr   recvNOBLOCKassertRaisesErrnoEAGAINclose)r   ss     r   
test_againzTestZMQError.test_again   s[    LL(%5szz1663;;?		r   c                    | j                   j                  t        j                        }t	        | j                   j
                        }|j                          | j                  t        |j                  t        j                         | j                  t        j                  |j                  t        j                         |j                          |j                          y )N)target)r   r   r   r   r   termstartr   r   r   r    r!   TERMr#   join)r   r$   ts      r   atest_ctxtermzTestZMQError.atest_ctxterm   s    LL($,,++,		+QVVS[[Asxx=			r   N)__name__
__module____qualname__r   r   r%   r-    r   r   r
   r
      s    &-r   r
   )
	threadingr   r   r   r   r   r   	zmq.testsr   r
   r1   r   r   <module>r4      s"     
 < < %? r   