
    ytf[                     >    d dl Z d dlZd dlZd dlmZ  G d de      Zy)    N)BaseZMQTestCasec                   *     e Zd Z fdZd Zd Z xZS )TestDraftSocketsc                 l    t         j                  st        j                  d       t        |           y )Nzdraft api unavailable)zmq	DRAFT_APIpytestskipsupersetUp)self	__class__s    ^/var/www/html/software/conda/envs/higlass/lib/python3.12/site-packages/zmq/tests/test_draft.pyr   zTestDraftSockets.setUp   s     }}KK/0    c                 4   | j                  t        j                  t        j                        \  }}|j	                  d       | j                  |d      }|j                  J |j	                  d|j                         | j                  |      }|dk(  sJ y )Ns   requestF)copys   reply)
routing_id)create_bound_pairr   CLIENTSERVERsendrecvr   )r   clientservermsgreplys        r   test_client_serverz#TestDraftSockets.test_client_server   s~    //

CJJGJiiUi+~~)))H8		&!   r   c                 J   | j                  t        j                  t        j                        \  }}d|_        d}|j                  |       d}t               }t               }t        d      D ]g  }t        |      j                  d      }|j                  |       |j                  ||       	 |j                         }	|j                  |	       |dz  }i t!        |j#                  |            d	k\  sJ y # t        j                  $ r t        j                  d       Y w xY w)
N   mygroupr   
   ascii)group   g?   )r   r   DISHRADIOrcvtimeojoinsetrangestrencodeaddr   r   Againtimesleeplenintersection)
r   dishradior#   received_countreceivedsentir   recvds
             r   test_radio_dishz TestDraftSockets.test_radio_dish   s    ,,SXXsyyAe		%5ur 
	$Aa&--(CHHSMJJs%J($		 U#!#
	$ 8((./1444 99  

3 s   /C77(D"!D")__name__
__module____qualname__r   r   r;   __classcell__)r   s   @r   r   r      s    
!5r   r   )r0   r	   r   	zmq.testsr   r    r   r   <module>rB      s      
 %#5 #5r   