ó ŒwÛjc@s6dZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z mZmZyddlZWnek rÛeZnXe jjdƒdZe jjZeedƒZe jedƒZeedƒo:ejd kZe jed ƒZd „ZejZd d „Z er´de j!e j"fd„ƒYZ#de j!e j$fd„ƒYZ%nej&d„ƒZ'd„Z(e jedƒde j)fd„ƒYƒZ*de j)fd„ƒYZ+d„Z,e-dkr2e,ƒndS(s! Test suite for SocketServer.py. iÿÿÿÿN(t reap_childrent reap_threadstverbosetnetworks hello world tAF_UNIXsrequires Unix socketstforktos2srequires forkingcCs#ttdƒrtj|ƒndS(s7Call signal.alarm when it exists (i.e. not on Windows).talarmN(thasattrtsignalR(tn((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt signal_alarm#sicCsNt|ggg|ƒ\}}}||kr:|j|ƒStd|f‚dS(Nstimed out on %r(t _real_selecttrecvt RuntimeError(tsockR ttimeouttrtwtx((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pytreceive+s!  tForkingUnixStreamServercBseZRS((t__name__t __module__(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyR3stForkingUnixDatagramServercBseZRS((RR(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyR7sccsitjƒ}|dkr(tjdƒndVtj|dƒ\}}|j||ƒ|jd|ƒdS(NiiHiiH(tosRt_exittNonetwaitpidt assertEqual(ttestcasetpidtpid2tstatus((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pytsimple_subprocess<s  cCso|jƒt|dƒrkx?|jjƒD].}ytj|dƒWq)tk rVq)Xq)W|jjƒndS(Ntactive_childreni(t server_closeRR#tcopyRRtChildProcessErrortclear(tserverR((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt close_serverHs  s!Threading required for this test.tSocketServerTestcBs.eZdZd„Zd„Zd„Zd„Zed„ƒZd„Z d„Z d„Z d „Z e d „ƒZed „ƒZed „ƒZee d „ƒƒZd„Zd„Ze d„ƒZejd„ƒZd„Zed„ƒZed„ƒZee d„ƒƒZed„ƒZd„ZRS(sTest all socket servers.cCs0|jtdƒtdƒd|_g|_dS(Nii<(t addCleanupR t port_seedt test_files(tself((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pytsetUpZs  cCs[|jƒtƒx9|jD].}ytj|ƒWqtjk rHqXqWg|j(dS(N(t doCleanupsRR-Rtremoveterror(R.tfn((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttearDown`s cCs|tjkrtdfSd}tjdkr7d}ntjddd|ƒ}tjdkré|ddkr{|d }n|dtjtj fkr¤|d}ntjd krÎ|j tjtj ƒ}qé|j tj tjƒ}n|j j |ƒ|SdS( NiRs\sockettprefixs unix_socket.tdirit:it/( tsockettAF_INETtHOSTRRtnamettempfiletmktemptseptaltseptreplaceR-tappend(R.tprotoR6R3((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pytpickaddrks     cCsid|fd„ƒY}d|fd„ƒY}tr:dGHn|||ƒ}|j|j|jjƒƒ|S(NtMyServercBseZd„ZRS(cSs|j|ƒt|ƒ‚dS(N(t close_requestR)(R.trequesttclient_address((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt handle_error†s  (RRRI(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyRE…st MyHandlercBseZd„ZRS(cSs#|jjƒ}|jj|ƒdS(N(trfiletreadlinetwfiletwrite(R.tline((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pythandleŒs(RRRP(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyRJ‹sscreating server(RRtserver_addressR9t getsockname(R.taddrtsvrclsthdlrbaseRERJR(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt make_server„sc Cs'|j|j|jƒ||ƒ}|j}trJdGHdG|GHdG|GHntjdd|d|jdidd 6ƒ}t|_ |j ƒtr—d GHnx6t d ƒD](}tr¼d G|GHn||j|ƒq¤WtrÞd GHn|j ƒ|j ƒt|ƒ|jtj|jjƒtr#dGHndS(Nsserver createdsADDR =sCLASS =R<s %s servingttargettkwargsg{®Gáz„?t poll_intervalsserver runningis test clientswaiting for servertdone(RVRDtaddress_familyRQRt threadingtThreadt serve_forevertTruetdaemontstarttrangetshutdowntjoinR)t assertRaisesR9R2tfileno(R.RTRUttestfuncR(RSttti((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt run_server•s6             cCs’tj|tjƒ}|j|ƒ|jtƒt|dƒ}}x/|rsd|krst|dƒ}||7}qEW|j|tƒ|jƒdS(Nids (R9t SOCK_STREAMtconnecttsendalltTEST_STRRRtclose(R.RCRStstbuftdata((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pytstream_examine´s  cCs¶tj|tjƒ}trC|tjkrC|j|j|ƒƒn|jt|ƒt|dƒ}}x/|r—d|kr—t|dƒ}||7}qiW|j |tƒ|j ƒdS(Nids ( R9t SOCK_DGRAMtHAVE_UNIX_SOCKETSRtbindRDtsendtoRnRRRo(R.RCRSRpRqRr((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt dgram_examine¿scCs |jtjtj|jƒdS(N(Rjt SocketServert TCPServertStreamRequestHandlerRs(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_TCPServerËs cCs |jtjtj|jƒdS(N(RjRytThreadingTCPServerR{Rs(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_ThreadingTCPServerÐs cCs3t|ƒ!|jtjtj|jƒWdQXdS(N(R"RjRytForkingTCPServerR{Rs(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_ForkingTCPServerÕs  cCs |jtjtj|jƒdS(N(RjRytUnixStreamServerR{Rs(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_UnixStreamServerÜs cCs |jtjtj|jƒdS(N(RjRytThreadingUnixStreamServerR{Rs(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_ThreadingUnixStreamServerâs cCs0t|ƒ|jttj|jƒWdQXdS(N(R"RjRRyR{Rs(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_ForkingUnixStreamServerès  cCs |jtjtj|jƒdS(N(RjRyt UDPServertDatagramRequestHandlerRx(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_UDPServerðs cCs |jtjtj|jƒdS(N(RjRytThreadingUDPServerR‡Rx(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_ThreadingUDPServerõs cCs3t|ƒ!|jtjtj|jƒWdQXdS(N(R"RjRytForkingUDPServerR‡Rx(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_ForkingUDPServerús  c#sKtj‰dd‡fd†ƒY}|ƒt_z tjVWdˆt_XdS(s<Mocks the select.select() call to raise EINTR for first callt MockSelectcs eZd„Z‡fd†ZRS(cSs d|_dS(Ni(tcalled(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt__init__scsP|jd7_|jdkrBtjtjtjtjƒƒ‚n ˆ|ŒSdS(Ni(RŽtselectR2terrnotEINTRRtstrerror(R.targs(t old_select(sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt__call__ s$(RRRR–((R•(sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyRs N((R(R.R((R•sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pytmocked_select_modules    cCsJ|jƒ8}|jtjtj|jƒ}|j|jdƒWdQXdS(Ni(R—RjRyRzR{Rst assertGreaterRŽ(R.t mock_selectR((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_InterruptServerSelectCalls   cCs |jtjtj|jƒdS(N(RjRytUnixDatagramServerR‡Rx(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_UnixDatagramServer!s cCs |jtjtj|jƒdS(N(RjRytThreadingUnixDatagramServerR‡Rx(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt test_ThreadingUnixDatagramServer's cCs|jttj|jƒdS(N(RjRRyR‡Rx(R.((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_ForkingUnixDatagramServer-s c Csdtjfd„ƒY}dtjfd„ƒY}g}xmtdƒD]_}|tdf|ƒ}tjddd |jd id d 6ƒ}t|_ |j ||fƒqEWx(|D] \}}|j ƒ|j ƒq¯Wx(|D] \}}|j ƒt|ƒqÚWdS( NREcBseZRS((RR(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyRE8sRJcBseZRS((RR(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyRJ;siiR<sMyServer servingRWRXg{®Gáz„?RY(RyRzR{RbR;R\R]R^R_R`RBRaRcRdR)(R.RERJtthreadsRiRpRh((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt test_shutdown4s"     cCsJxCtdƒD]5}|jtƒtjtdftjƒWdQXq WdS(Niiÿÿÿÿ(RbRet OverflowErrorRyRzR;R{(R.Ri((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyttest_tcpserver_bind_leakNs(RRt__doc__R/R4RDRVRRjRsRxR|R~trequires_forkingR€trequires_unix_socketsR‚R„R…RˆRŠRŒt contextlibtcontextmanagerR—RšRœRžRŸR¡R£(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyR*Vs4        t MiscTestCasecBseZd„ZRS(cCsŽdtjfd„ƒY}|tdftjƒ}tj|jtjƒ}|j|jƒ|j ƒ|j ƒ|j |j dƒt |ƒdS(NREcBs eZd„ZdZd„ZRS(cSstS(N(tFalse(R.RGRH((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pytverify_request`sicSs&|jd7_tjj||ƒdS(Ni(tshutdown_calledRyRztshutdown_request(R.RG((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyR­ds(RRR«R¬R­(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyRE_s ii(RyRzR;R{R9R[RkRlRQRothandle_requestRR¬R)(R.RER(Rp((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt4test_shutdown_request_called_if_verify_request_false[s   (RRR¯(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyR©YscCs2tjƒrtjdƒ‚ntjjtƒdS(Ns"can't run when import lock is held(timpt lock_heldtunittesttSkipTestttestt test_supportt run_unittestR*(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pyt test_mainqs t__main__(.R¤R§R°RRR R9R‘R=R²Ryttest.test_supportR´RRRR\t ImportErrorRRµtrequiresRnR;RRut skipUnlessR¦R<t HAVE_FORKINGR¥R R Rt ForkingMixInRRR›RR¨R"R)tTestCaseR*R©R·R(((sŒ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_socketserver.pytsT                       ÿ