a  ze@sddlZddlZddlZddlZddlmZddlmZddlm Z ddZ Gddde j Z Gd d d e ejZeeed d Gd dde ejZedkredS)N) socket_helper)utils) functionalcCstddSN)asyncioZset_event_loop_policyrrQ/opt/bitninja-python-dojo/embedded/lib/python3.9/test/test_asyncio/test_server.pytearDownModule sr c@seZdZddZddZdS)BaseStartServercCstdSr)NotImplementedErrorselfrrrnew_loopszBaseStartServer.new_loopc sdddfddfdd}dd }|t0|jtj|tjd |jd d Wdn1sn0Y| |j |j d  | tjP|fd d|jWdn1s0YWdn1s0Y|j d|j|j| |td |jWdn1sz0YdS)N1111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111 cs\tdD]}tdrq(qt|d||||d| dS)N g?) rangetimesleep is_serving RuntimeError settimeoutconnectsendrecv_allclose)sockaddri) HELLO_MSGsrvrrclients      z3BaseStartServer.test_start_server_1..clientcs:|IdH|d||IdHdSN1readlinecancelwriterZ wait_closedreaderwriter main_taskrrserve%s  z2BaseStartServer.test_start_server_1..servec sJ|4IdH$|IdHWdIdHqF1IdHs<0YdSr) serve_foreverr#rrrmain,sz1BaseStartServer.test_start_server_1..mainrFloop start_servingcs |Srrrr r$rr:z5BaseStartServer.test_start_server_1..r is closed) assertWarnsDeprecationWarningr5run_until_completerZ start_serverrZHOSTv4 assertFalser create_tasksockets getsockname assertRaisesCancelledErrorZ tcp_client assertEqual assertIsNone_sockets_waitersassertRaisesRegexrr1)r r0r3r)r"r r$r/r#rtest_start_server_1s(    &J  z#BaseStartServer.test_start_server_1N)__name__ __module__ __qualname__rrJrrrrr sr c@s"eZdZddZejddZdS)SelectorStartServerTestscCstSr)rZSelectorEventLoopr rrrrIsz!SelectorStartServerTests.new_loopc sdddtfddfdd}fdd }tFt,jtj |jd d }Wdn1s0Yj || tj P fd d jWdn1s0YWdn1s0Y|jd|j|j|td j|Wdn1st0YWdn1s0YdS)Nrrrcs>|dd||||d|dS)Nrrr)rwaitrrrr)rr )r"startedrrr$Qs      zASelectorStartServerTests.test_start_unix_server_1..clientcs:|IdH|d||IdHdSr%r'r+r.rrr0Ys  z@SelectorStartServerTests.test_start_unix_server_1..servec s||4IdHV||IdH||IdHWdIdHqx1IdHsn0YdSr)r?rr6Z assertTruesetr1r2)r rPrrr3`s z?SelectorStartServerTests.test_start_unix_server_1..mainFr4cs |Srrr7r8rrr9pr:zCSelectorStartServerTests.test_start_unix_server_1..rr;) threadingEvent test_utilsZunix_socket_pathr<r=r5r>rZstart_unix_serverr@rCrDZ unix_clientrErArFrGrHr?rrIrr1)r r0r3r#r)r"r r$r/r rPrtest_start_unix_server_1Ls(      &J  z1SelectorStartServerTests.test_start_unix_server_1N)rKrLrMrrZskip_unless_bind_unix_socketrUrrrrrNGsrNProactorEventLoopz Windows onlyc@seZdZddZdS)ProactorStartServerTestscCstSr)rrVr rrrrsz!ProactorStartServerTests.new_loopN)rKrLrMrrrrrrW}srW__main__)rrrRZunittestZ test.supportrZtest.test_asynciorrTrZ func_testsr ZFunctionalTestCaseMixinr ZTestCaserNZ skipUnlesshasattrrWrKr3rrrrs   86