
    \j                     
   d dl Zd dlmc mZ d dlZd dlZej                  j                  d ej                  j                  d             d dlZd dlmZ d dlmZmZ d dlmZ d dlmZ d Zedk(  r ej.                  e       yy)	    Nzextra/py-libp2p)new_host)ResourceManagerResourceLimits)info_from_p2p_addr)	Multiaddrc            
        K   t        d      } t        |       }t        d|      }t        d      }|j                  t	        d      g      4 d {    |j                         d   }t        t	        | d	|j                         j                                      }|j                  g       4 d {    t        d
       t        d      D ]  }	 t        d|dz           |j                  |       d {    |j                  |j                                d {    |j                  |j                                d {    t        j                  d       d {    t        d|j                           d d d       d {    d d d       d {    y 7 R7 7 7 7 e7 J# t         $ r}t        d|dz    d|        Y d }~ Qd }~ww xY w7 M# 1 d {  7  sw Y   ]xY w7 T# 1 d {  7  sw Y   y xY ww)N   )max_connectionsT)enable_quicresource_manager)r   z/ip4/127.0.0.1/udp/0/quic-v1)listen_addrsr   z/p2p/zStarting connection loop...
   zConnection attempt    g?zTracked connections: zFailed on attempt z: )r   r   r   runr   	get_addrsr   get_idprettyprintrangeconnect
disconnecttriosleep_current_connections	Exception)limitsrmhost1host2listen_addrinfo1ies           >/Users/sumanjeet/code/ipfs-lite/py-ipfs-lite/test_quic_leak.pyreproduce_leakr%      s    A.F		 B E E yyy1O'P&QyR  oo'*"9}E%,,.BWBWBYAZ-[#\]99"9- 	 	/02Y /Aw78--...  **5<<>:::**5<<>::: **S/)) 1"2I2I1JKL	 		  	 / ;: * ! .q1ugRs;<#	 	 	 		   s  AHF%HAG66F(7G6:G%F2:F*
;&F2!F,
"&F2F.
	F2%F0
&F2GG6GG6HG4 H(G6*F2,F2.F20F22	G	;G	GG	GG6G1	%G(&G1	-G64H6H<G?=HH__main__)builtins@py_builtins_pytest.assertion.rewrite	assertionrewrite
@pytest_arsysospathinsertabspathr   libp2pr   libp2p.rcmgr.managerr   r   libp2p.peer.peerinfor   	multiaddrr   r%   __name__r        r$   <module>r9      sa      
 	 277??#45 6   @ 3 'R zDHH^ r8   