blame | history | raw
tzh
2024-08-22 c7d0944258c7d0943aa7b2211498fd612971ce27 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

ó 


R\¬Qc@sðdZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl    Z    ddl


Z


ddlZddlm Z mZmZyddlZWnek


rÛdZnXejjdƒdZejjZeedƒZeedƒo(ejdkZd    „ZejZd


d„Zerde


je


jfd „ƒYZ de


je


j!fd„ƒYZ"nej#d„ƒZ$e    j%edƒde    j&fd„ƒYƒZ'd„Z(e)dkrìe(ƒndS(s!


Test suite for SocketServer.py.


iÿÿÿÿN(t reap_childrentreap_threadstverbosetnetworkshello world


tAF_UNIXtforktos2cCs#ttdƒrtj|ƒndS(s7Call signal.alarm when it exists (i.e. not on Windows).talarmN(thasattrtsignalR(tn((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/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^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pytreceive(s! tForkingUnixStreamServercBseZRS((t__name__t


__module__(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyR0stForkingUnixDatagramServercBseZRS((RR(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyR4sccsitjƒ}|dkr(tjdƒndVtj|dƒ\}}|j||ƒ|jd|ƒdS(NiiHiiH(tosRt_exittNonetwaitpidtassertEqual(ttestcasetpidtpid2tstatus((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pytsimple_subprocess9ss!Threading required for this test.tSocketServerTestcBsòeZdZd„Zd„Zd„Zd„Zed„ƒZd„Z    d„Z


d„Zd    „Ze rud


„Zner¢d„Zd„Ze r¢d „Zq¢nd„Zd„Ze rÆd„Znejd„ƒZd„Zed„ƒZRS(sTest all socket servers.cCs tdƒd|_g|_dS(Ni<i(Rt    port_seedt


test_files(tself((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pytsetUpIs


    cCs[tdƒtƒx9|jD].}ytj|ƒWqtjk


rHqXqWg|j(dS(Ni(RRR%Rtremoveterror(R&tfn((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttearDownNs


cCs|tjkrtdfSd}tjdkr7d}ntjddd|ƒ}tjdkré|ddkr{|d    }n|dtjtj    fkr¤|d}ntjd


krÎ|j


tjtj    ƒ}qé|j


tj    tjƒ}n|jj|ƒ|SdS(NiRs\sockettprefixsunix_socket.tdirit:it/( tsockettAF_INETtHOSTRRtnamettempfiletmktemptseptaltseptreplaceR%tappend(R&tprotoR-R*((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pytpickaddrYs 


      cCsid|fd„ƒY}d|fd„ƒY}tr:dGHn|||ƒ}|j|j|jjƒƒ|S(NtMyServercBseZd„ZRS(cSs|j|ƒ|jƒ‚dS(N(t close_requesttserver_close(R&trequesttclient_address((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pythandle_errorts 


(RRRA(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyR<sst    MyHandlercBseZd„ZRS(cSs#|jjƒ}|jj|ƒdS(N(trfiletreadlinetwfiletwrite(R&tline((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pythandlezs(RRRH(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyRBysscreating server(RRtserver_addressR0tgetsockname(R&taddrtsvrclsthdlrbaseR<RBtserver((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pytmake_serverrsc    Cs|j|j|jƒ||ƒ}|j}trJdGHdG|GHdG|GHntjdd|d|jdidd    6ƒ}t|_    |j


ƒtr—d


GHnx6tdƒD](}tr¼dG|GHn||j|ƒq¤WtrÞd GHn|jƒ|j ƒtrdGHndS(Nsserver createdsADDR =sCLASS =R3s


%s servingttargettkwargsg{®Gáz„?t poll_intervalsserver runningistest clientswaiting for servertdone(ROR;taddress_familyRIRt    threadingtThreadt serve_forevertTruetdaemontstarttrangetshutdowntjoin(R&RLRMttestfuncRNRKttti((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyt


run_serverƒs2            


        


 


 


cCs’tj|tjƒ}|j|ƒ|jtƒt|dƒ}}x/|rsd|krst|dƒ}||7}qEW|j|tƒ|jƒdS(Nids


(R0tSOCK_STREAMtconnecttsendalltTEST_STRRRtclose(R&R:RKtstbuftdata((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pytstream_examine s  cCsˆtj|tjƒ}|jt|ƒt|dƒ}}x/|rid|krit|dƒ}||7}q;W|j|tƒ|jƒdS(Nids


(R0t


SOCK_DGRAMtsendtoReRRRf(R&R:RKRgRhRi((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyt dgram_examine«scCs |jtjtj|jƒdS(N(RatSocketServert    TCPServertStreamRequestHandlerRj(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_TCPServerµscCs |jtjtj|jƒdS(N(RaRntThreadingTCPServerRpRj(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_ThreadingTCPServerºscCs3t|ƒ!|jtjtj|jƒWdQXdS(N(R"RaRntForkingTCPServerRpRj(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_ForkingTCPServerÀs cCs |jtjtj|jƒdS(N(RaRntUnixStreamServerRpRj(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_UnixStreamServerÇscCs |jtjtj|jƒdS(N(RaRntThreadingUnixStreamServerRpRj(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_ThreadingUnixStreamServerÌscCs0t|ƒ|jttj|jƒWdQXdS(N(R"RaRRnRpRj(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_ForkingUnixStreamServerÒs     cCs |jtjtj|jƒdS(N(RaRnt    UDPServertDatagramRequestHandlerRm(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_UDPServerØscCs |jtjtj|jƒdS(N(RaRntThreadingUDPServerR|Rm(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_ThreadingUDPServerÝscCs3t|ƒ!|jtjtj|jƒWdQXdS(N(R"RaRntForkingUDPServerR|Rm(R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/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^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyt__init__ïscsP|jd7_|jdkrBtjtjtjtjƒƒ‚n


ˆ|ŒSdS(Ni(RƒtselectR)terrnotEINTRRtstrerror(R&targs(t


old_select(s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyt__call__òs$(RRR„R‹((RŠ(s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyR‚îs    N((R…(R&R‚((RŠs^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pytmocked_select_moduleés     cCsJ|jƒ8}|jtjtj|jƒ}|j|jdƒWdQXdS(Ni(RŒRaRnRoRpRjt assertGreaterRƒ(R&tmock_selectR((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyttest_InterruptServerSelectCalls


c


Csødtjfd„ƒY}dtjfd„ƒY}g}xmtdƒD]_}|tdf|ƒ}tjddd    |jd


idd6ƒ}t|_    |j


||fƒqEWx(|D] \}}|jƒ|jƒq¯Wx|D]\}}|j ƒqÚWdS( NR<cBseZRS((RR(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyR<!sRBcBseZRS((RR(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyRB$siiR3sMyServer servingRPRQg{®Gáz„?RR(RnRoRpR[R2RURVRWRXRYR9RZR\R](R&R<RBtthreadsR`RgR_((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyt test_shutdowns             


(RRt__doc__R'R+R;RORRaRjRmRqRstHAVE_FORKINGRutHAVE_UNIX_SOCKETSRwRyRzR}RRt


contextlibtcontextmanagerRŒRR‘(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyR#Es0                        


                            cCs2tjƒrtjdƒ‚ntjjtƒdS(Ns"can't run when import lock is held(timpt    lock_heldtunittesttSkipTestttestttest_supporttrun_unittestR#(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyt    test_main7st__main__(*R’R•R—RR…R    R0R†R4R™Rnttest.test_supportR›RRRRUtImportErrorRRœtrequiresReR2RR”R3R“RRRtForkingMixInRvRtUnixDatagramServerRR–R"t


skipUnlesstTestCaseR#RžR(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_socketserver.pyt<module>sH 


                ñ