<|hFddlZddlmZddlmZddlmZdZGddejZe dk(rejyy)N)socket)servercl|jdr |jdr|jy)Ni)recvclose)sock_s ^/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__socket_close.pyreadallr s& ))D/  ))D/JJLcReZdZdZdZdZdZejddZ y)TestFctjtjt|_|jj yN)r StreamServer greentestDEFAULT_BIND_ADDR_TUPLEr startselfs r setUpz Test.setUps,)))*K*KWU  r c8|jjyr)rstoprs r tearDownz Test.tearDowns r ctjtjtj}|jtj |j jftj|jd} tjd|j|jd|j|j||j!|j"d|j%|j&tj(|j!|j&j*tj,|j/y#|j/wxYw)NMbP?g?)timeout)rAF_INET SOCK_STREAMconnectrDEFAULT_CONNECT_HOSTr server_portgeventspawnrsleeprjoin assertTrueready assertEqualvalueassertIsInstance exceptionerrorerrnoEBADFkillrrreceivers r test_recv_closedzTest.test_recv_closeds}}V^^V-?-?@ i44dkk6M6MNO<< 2.  LL  JJL MM#M & OOHNN,h 7   X^^T 2  ! !("4"4fll C   X//55v|| D MMOHMMOs CE++E=zSometimes randomly times outcLtjtjtj}|jtj |j jftj|jd} tjd|jt|jd|jt|jd|j|jy#|j|jwxYw)Nrr)rrr r!rr"rr#r$r%rr& assertRaisesAssertionErrorr1rr2s r test_recv_twicezTest.test_recv_twice+s}}V^^V-?-?@ i44dkk6M6MNO<< 2.  LL    ndii <   ndii < MMO JJL MMO JJLs AD"D#N) __name__ __module__ __qualname__ error_fatalrrr4rskipOnLibuvOnCIr8r r rrs8K "Y=> ? r r__main__) r$rrgevent.testingtestingrr TestCaserr9mainr>r r rDsD "  '9  'T zINNr