
    ye                         d dl Z d dlZ d dlmZ d dlmZ eZd dlZ ej        ddg          d             Z	d Z
d	 Zd
 ZdS )    N)require_zmq_4)recv_monitor_messagezmqasyncio)paramsc                 R    | j         dk    rt          j        j        S t          j        S )Nr   )paramr   r   Context)request
event_loops     6lib/python3.11/site-packages/zmq/tests/test_monitor.pyr
   r
      s"    }	!!{""{    c                   K    |t           j                  } |t           j                  }|                    d           |                    dt           j        t           j        z  t           j        z              |t           j                  }|	                    d           d|_
        |	                    d           t          |          }t          | t           j        j                  r| d{V }|d         t           j        k    rD|d         dk    sJ t          |          }t          | t           j        j                  r| d{V }|d         t           j        k    sJ |d         dk    sJ |                                 t          |          }t          | t           j        j                  r| d{V }|d         t           j        k    sJ dS )z&Test monitoring interface for sockets.ztcp://127.0.0.1:6666zinproc://monitor.repr   Neventendpoints   tcp://127.0.0.1:6666)r   REPREQbindmonitorEVENT_CONNECT_DELAYEDEVENT_CONNECTEDEVENT_MONITOR_STOPPEDPAIRconnectlingerr   
isinstancer   r
   disable_monitor)contextsockets_reps_reqs_eventms         r   test_monitorr$      s     F37OOEF37OOE	JJ%&&&	MM!C$77#:SS  
 fSXGOO*+++GN	MM()))W%%A'3;.// GGGGGGzS...} 77777 ))gs{233 	AW:,,,,,Z=33333 
W%%A'3;.// GGGGGGW:2222222r   c                   K    |t           j                  }|                                }|                    |           |                                }||u sJ |                                 t          |          }t          | t           j        j                  r| d {V }|d         t           j	        k    sJ |
                                 |
                                 d S )Nr   )r   PULLget_monitor_socketappendr   r   r   r   r
   r   close)r   r   socketssr#   m2evts          r   test_monitor_repeatr.   9   s      sxA	ANN1	
				B7777
q
!
!C'3;.// iiiiiiw<344444GGIIIGGIIIIIr   c                 ~  K    |t           j                  } |t           j                  }|                    d           |                                }d|_        |                    |           |                    d           t          |          }t          | t           j
        j                  r| d{V }|d         t           j        k    rD|d         dk    sJ t          |          }t          | t           j
        j                  r| d{V }|d         t           j        k    sJ |d         dk    sJ dS )z!Test connected monitoring socket.ztcp://127.0.0.1:6667r   Nr   r   s   tcp://127.0.0.1:6667)r   r   r   r   r'   r   r(   r   r   r   r   r
   r   r   )r   r   r*   r    r!   r"   r#   s          r   test_monitor_connectedr0   H   s<     F37OOEF37OOE	JJ%&&& &&((GGNNN7	MM()))W%%A'3;.// GGGGGGzS...} 77777 ))gs{233 	AW:,,,,,Z=3333333r   )r   zmq.asyncio	zmq.testsr   zmq.utils.monitorr   
pytestmarkpytestfixturer
   r$   r.   r0    r   r   <module>r8      s    


     # # # # # # 2 2 2 2 2 2
  y)***  +*!3 !3 !3H  4 4 4 4 4r   