o
    US`c<  ã                   @   s@   d dl Z d dlZd dlmZ dd„ Zdd„ Zdd„ Zd	d
„ ZdS )é    N)ÚFakeNetc                  C   s   t ƒ } |  ¡  | S ©N)r   Úenable)Úfn© r   úB/usr/local/lib/python3.10/dist-packages/trio/tests/test_fakenet.pyr      s   r   c                  Ã   sð   t ƒ  tjjtjjd} tjjtjjd}|  d¡I d H  |  ¡ \}}|dks*J ‚|dks0J ‚| d|  ¡ ¡I d H  |  d¡I d H \}}|dksKJ ‚|| ¡ ksSJ ‚|  d| ¡ ¡I d H  | d¡I d H \}}|dksnJ ‚||  ¡ ksvJ ‚d S )N©Útype©ú	127.0.0.1r   r   r   ó   xyzé
   s   abc)r   ÚtrioÚsocketÚ
SOCK_DGRAMÚbindÚgetsocknameÚsendtoÚrecvfrom)Ús1Ús2ÚipÚportÚdataÚaddrr   r   r   Útest_basic_udp   s    €r   c                  Ã   sj   t ƒ  tjjtjjd} tjjtjjd}|  d¡I d H  | d|  ¡ ¡I d H  |  d¡I d H \}}d S )Nr   r
   r   r   )r   r   r   r   r   r   r   r   )r   r   r   r   r   r   r   Útest_msg_trunc    s   €r   c                   Ã   sB   t ƒ  t t¡ tj ¡  W d   ƒ d S 1 sw   Y  d S r   )r   ÚpytestZraisesÚNotImplementedErrorr   r   r   r   r   r   Útest_basic_tcp)   s
   €"ÿr   )r   r   Ztrio.testing._fake_netr   r   r   r   r   r   r   r   r   Ú<module>   s    	