ó úR‹_c@ s¿ddlmZmZddlZddlZddlZddljZddlm Z ddlm Z ddl m Z ddl Z ddlmZdefd„ƒYZd efd „ƒYZd ejfd „ƒYZd efd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZejjeƒd„Zdefd„ƒYZ defd„ƒYZ!e"dkr»ej#ƒndS(iÿÿÿÿ(tprint_functiontdivisionN(tPY3(tDEFAULT_SOCKET_TIMEOUT(tsocket(t StreamServertSimpleStreamServercB seZd„ZRS(c C sê|jƒ}zÌ|jƒ}|s%dSy|jddƒ\}}}Wn%tk rktd|fƒ‚nX|dkrˆ|jdƒnO|d krÊ|jdƒx3trÆ|jd ƒ}|s¤Pq¤q¤Wn |jd ƒWd|jƒXdS( Nt is Failed to parse request line: %rs/pingsHTTP/1.0 200 OK PONGs/longs/shortthelloisHTTP/1.0 404 WTF? (s/longs/short( tmakefiletreadlinetsplitt ExceptiontprinttsendalltTruetrecvtclose( tselft client_sockett_addresstfdt request_linet_methodtpatht_resttdata((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pythandles(        (t__name__t __module__R(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRstSettingscB sbeZeZeZeZeZe d„ƒZ e Z e d„ƒZ e d„ƒZ e d„ƒZRS(cC s)|jƒ}|jƒ}|j|ƒdS(N(R treadt assertFalse(tinsttconntresult((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytassertAcceptedConnectionError0s  cC sQ|jƒy|jƒWn2tjk rL}|jdtjkrM‚qMnXdS(Ni(t assert500t send_requestRterrortargst greentesttCONN_ABORTED_ERRORS(R!tex((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt assert5038s  cC s-|jtjƒ|jddƒWdQXdS(Nttimeoutg{®Gáz„?(t assertRaisesRR-tassertRequestSucceeded(R!((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytassertPoolFullCscC s|jd|jƒƒ|S(Ntspawn(t setdefaultt get_spawn(R!tkwargs((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytfill_default_server_argsHs(RRRt ServerClassRtServerSubClassRt restartabletclose_socket_detectedt staticmethodR$R%R,R0R5(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR*s tTestCasecB seZejZeZdZd„Zd„Z d„Z e dd„Z de dd„Z d„Zd„Zd „Zd „Zd „Zd „Ze d „Zd„Zd„Zd„Zd„Zd„Zed„ƒZd„Zd„Zd„Zd„Zd„Z RS(cC s5t|ddƒdk r1|jjƒd|_ndS(Ntserver(tgetattrtNoneR<tstop(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytcleanupSs cC s7tjƒ}|jdƒ|jdƒ|j|ƒ|S(Ns 127.0.0.1ii(s 127.0.0.1i(Rtbindtlistent_close_on_teardown(Rtsock((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt get_listenerXs     cC sy|jj}|stj}n|dkr6tj}ny|jjj}Wntk retj}nX||jj |fS(Ns::( R<t server_hostR)tDEFAULT_LOCAL_HOST_ADDRtDEFAULT_LOCAL_HOST_ADDR6RtfamilytAttributeErrortAF_INETt server_port(RRFRI((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytget_server_host_port_family_s      ic C sÈ|jƒ\}}}tjd|ƒ}y|j||fƒWntk r^|jƒ‚nXtr|i|d6dd6}n i|d6}|j|}trª||_n|jj|ƒ|jƒ|S(NRIt bufferingtrwbtmodetbufsize( RMRtconnectR RRR t_sockt settimeout( RR-RQRFRLRIRDR4trconn((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR ns      t/cC s@|jd|d|ƒ}|jd|jdƒƒ|jƒ|S(NR-RQsGET %s HTTP/1.0 slatin-1(R twritetencodetflush(RturlR-RQR"((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR&‡s cC sa|jtjƒ}|jƒ}|jƒWdQX|j}|j|jdtj tj fƒdS(Ni( R.RR'R Rt exceptiontassertInR(terrnot ECONNREFUSEDt EADDRNOTAVAIL(RtexcR"R+((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytassertConnectionRefuseds   cC s|jj|ƒdS(N(RR%(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR%•scC s|jj|ƒdS(N(RR,(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR,˜scC s|jj|ƒdS(N(RR$(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR$›scC s|jj|ƒdS(N(RR0(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR0žscC s²|jƒ}|jdƒ|jƒd}y7x0tr^|jjdƒ}|sQPn||7}q/WWn"tjk r„|j|ƒdSX|j |j dƒt |ƒƒ|j ƒdS(NsGET / HTTP/1.0 tis"HTTP/1.0 500 Internal Server Error( R RWRYRRSRRR-R t assertTruet startswithtreprR(RR"R#R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytassertNotAccepted¡s     cC sZ|jd|ƒ}|jdƒ|jƒ}|jƒ|jdƒsVtt|ƒƒ‚dS(NR-sGET /ping HTTP/1.0 s PONG(R RWRRtendswithtAssertionErrorRe(RR-R"R#((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR/²s    cC s%|jjƒ|jƒ|jƒdS(N(R<tstartR/(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt start_server¹s  cC s|jjƒ|jƒdS(N(R<R?Ra(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt stop_server¾s cC sdS(N((Rt_msg((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytreport_netstatÂscC s|jtjdfƒS(Ni(R7R)tDEFAULT_BIND_ADDR(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt_create_serverÇscC s-|jƒ|_|jjƒtjdƒdS(Ng{®Gáz„?(RoR<Ritgeventtsleep(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt init_serverÊs cC s |jjS(N(R<R(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRÏscC s~zS|jtjdfd„ƒ|_|jjƒ|jƒ|jƒ|jtƒWd|jj ƒddl }|j ƒXdS(NicS sdS(N(R>(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytÕRbiÿÿÿÿ( R6R)RnR<Ritexpect_one_errorR%t assert_errort TypeErrorR?tgctcollect(RRw((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt_test_invalid_callbackÓs!     cC s|jj||ƒS(N(RR5(RR4((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR5ãscO s|jj||j|ƒŽS(N(RR6R5(RR(R4((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR6æs cO s|jj||j|ƒŽS(N(RR7R5(RR(R4((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR7ês cC sdS(N(R>(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR3îsN(!RRR)t LARGE_TIMEOUTt __timeout__RR>R<R@RERMt_DEFAULT_SOCKET_TIMEOUTR R&RaR%R,R$R0RfR/RjRkRmRoRrtpropertyRRyR5R6R7R3(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR;Ms4                    tTestDefaultSpawncB s°eZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z e j e j ƒd„ƒZd „Zd „Zd „Zd „Zed „ƒZ d„Zd„ZRS(cC stjS(N(RpR1(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR3óscC sœ|jdƒ|jƒ|jdƒ|r|jjr|jjƒ|jdƒ|jƒ|jjƒ|jdƒ|jƒn|j ƒ|jdƒdS(Ns before starts after startsafter stop_acceptingsafter start_acceptings after stop( RmRjRR8R<tstop_acceptingRftstart_acceptingR/Rk(RR8((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt_test_server_start_stopös          c C sBt|_|jtƒ$|j|jƒdddtƒWdQXdS(NtbacklogiR(tFalsetswitch_expectedR.RvR6RE(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt'test_backlog_is_not_accepted_for_sockets cC s?|jtjdfddƒ|_|jƒ|jdtƒdS(NiR‚iR8(R7R)RnR<RaRRƒ(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt$test_backlog_is_accepted_for_address s! cC s&|j|jƒƒ|_|jƒdS(N(R7RER<Rf(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttest_subclass_just_createscC s6|j|jƒƒ|_|jƒ|jdtƒdS(NR8(R7RER<RfRR(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttest_subclass_with_sockets cC s9|jtjdfƒ|_|jƒ|jdtƒdS(NiR8(R7R)RnR<RaRR(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttest_subclass_with_addresss cC s|jƒdS(N(Ry(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttest_invalid_callbackscC svtj|jjƒ}zEtjdƒ|jƒ|jjƒ|jj sOt‚|j ƒWd|j ƒ|j ƒXdS(Ng{®Gáz„?( RpR1R<t serve_foreverRqR/R?tstartedRhRatkilltget(Rtg((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt_test_serve_forever!s    cC s=|jdƒ|_|jj s%t‚|jƒ|jƒdS(Ns 127.0.0.1i(s 127.0.0.1i(R7R<RŒRhRaR(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttest_serve_forever.s cC se|jtjdfƒ|_|jƒ|jj s8t‚|jjƒ|jjsWt‚|jƒdS(Ni( R7R)RnR<RaRŒRhRiR(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttest_serve_forever_after_start4s   c C sø|jtjdfd„ƒ|_|jjƒ|jƒ}tjjdƒœz‰y:|j ƒ}|r‰|j dƒs‰t t |ƒƒ‚nWnHt jk rÔ}|jddkrµqÕ|jdtjkrÎqÕ‚nXWd|jƒXWdQX|jƒdS(NicW sgS(N((R(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRs=Rbis"HTTP/1.0 500 Internal Server ErroriE'(R6R)RnR<RiR&RptTimeoutt_start_new_or_dummyRRdRhReRR'R(R]t ECONNRESETRRk(RR"R#R+((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt!test_server_closes_client_sockets<s"!   ( cC s-|jƒ|_|jjƒtjdƒdS(Ng{®Gáz„?(RoR<RiRpRq(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRrRs cC s |jjS(N(R<R(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRWsc sf|jƒ|j|jjƒtdƒ‰‡fd†|j_|jƒ|jƒ|jtˆƒdS(Nttest_error_in_spawnc stjƒjˆƒS(N(Rpt getcurrenttthrow(R((R'(sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRs_Rb( RrRcR<RŒt ExpectedErrort_spawnRtR$Ru(R((R'sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR—[s    cC s×|jƒ|jƒ|jdt|jƒƒ|jj|jjƒ|jdt|jƒƒ|jdt|jƒƒ|jj|jƒ|jdt|jƒƒd„}|jj|ƒ|jdt|jƒƒdS(NtServershandle=t.test_server_repr_when_handle_is_instancemethodcS sdS(N((((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRqsshandle=(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR3©scC s|jƒdS(N(Ry(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRŠ¬scC sed„}|jjtjdf|ddƒ|_|jjƒ|jƒ|jƒ|j t dƒdS(NcW stjdƒdS(Ni(RpRq(t_args((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRq°siR1s?Impossible to call blocking function in the event loop callback( RR6R)RnR>R<RiRtR%RuRh(RRq((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttest_assertion_in_blocking_func¯s  '   (RRR3RŠR¯(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR­§s  RšcB seZRS((RR(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRš¹stTestSSLSocketNotAllowedcB s;eZeZd„Zejeedƒdƒd„ƒZ RS(cC stjS(N(RpR1(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR3ÂstsslsUses socket.sslcC siddlm}ddlm}|ƒ}|jdƒ|jdƒ||ƒ}|jt|j|ƒdS(Niÿÿÿÿ(R±(Rs0.0.0.0ii(s0.0.0.0i(t gevent.socketR±RRARBR.RvR7(RR±tgsockettlistener((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttestÅs    ( RRRƒR„R3tunittestt skipUnlessthasattrRRµ(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR°¾s cC stjjtjj||ƒƒS(N(tosRtabspathtjoin(tnamethere((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt_fileÏstBadWrapExceptioncB seZRS((RR(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR¿ÓstTestSSLGetCertificatecB s,eZd„Zd„Zd„Zd„ZRS(cC s.|jtjdfdtdƒdtdƒƒS(Nitkeyfiles server.keytcertfiles server.crt(R7R)RnR¾(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRoÙs cC stjS(N(RpR1(R((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyR3ÞscC sxddlm}m}|j|jdƒƒ|j|jdƒƒ|jƒ|jƒ\}}}|j||fƒdS(Niÿÿÿÿ(tmonkeyR±R±R(RpRÃR±R tis_module_patchedRrRMtget_server_certificate(RRÃR±RFRLt_family((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyttest_certificateás  cC sL|jƒd„}||j_|jtƒ|jjddƒWdQXdS(Nc[ s tƒ‚dS(N(R¿(t_client_sockett _wrap_args((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pytbad_wrapõs(RrR<t wrap_socketR.R¿t_handleR>(RRÊ((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyt(test_wrap_socket_and_handle_wrap_failureîs    (RRRoR3RÇRÍ(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyRÀ×s   t__main__($t __future__RRR¶R]R¹tgevent.testingttestingR)RRR|RpRt gevent.serverRRtobjectRR;R~R R¢R­R RšR°Rtdirnamet__file__R¾t BaseExceptionR¿RÀRtmain(((sR/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__server.pyts.    #¤†*+