PNG  IHDR;IDATxܻn0K )(pA 7LeG{ §㻢|ذaÆ 6lذaÆ 6lذaÆ 6lom$^yذag5bÆ 6lذaÆ 6lذa{ 6lذaÆ `}HFkm,mӪôô! x|'ܢ˟;E:9&ᶒ}{v]n&6 h_tڠ͵-ҫZ;Z$.Pkž)!o>}leQfJTu іچ\X=8Rن4`Vwl>nG^is"ms$ui?wbs[m6K4O.4%/bC%t Mז -lG6mrz2s%9s@-k9=)kB5\+͂Zsٲ Rn~GRC wIcIn7jJhۛNCS|j08yiHKֶۛkɈ+;SzL/F*\Ԕ#"5m2[S=gnaPeғL lذaÆ 6l^ḵaÆ 6lذaÆ 6lذa; _ذaÆ 6lذaÆ 6lذaÆ RIENDB`  4h^c@sKdZddlZddlZddlZddlZddlZddlZyddlZWnek rwdZnXddl m Z ddl m Z ddl mZddl mZdddYZd ejfd YZd ejfd YZd ejfdYZdZdZedkrGejddndS(s(Test suite for supervisor.socket_manageriN(tDummySocketConfig(t DummyLogger(tUnixStreamSocketConfig(tInetStreamSocketConfigt TestObjectcBs#eZdZdZdZRS(cCs d|_dS(Ni(tvalue(tself((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt__init__scCs|jS(N(R(R((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pytgetValuescCs ||_dS(N(R(Rtval((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pytsetValues(t__name__t __module__RRR (((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyRs  t ProxyTestcBs>eZdZdZdZdZdZdZRS(cCs t|_dS(N(tFalseton_deleteCalled(R((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pytsetUp!scCsddlm}|S(Ni(tProxy(tsupervisor.socket_managerR(RR((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt_getTargetClass$scOs|j||S(N(R(Rtargstkw((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt_makeOne(scCs t|_dS(N(tTrueR(R((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pytsetOnDeleteCalled+scCs,|jt}|jd|jdS(Ni(RRt assertEqualR(Rtproxy((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_proxy_getattr.scCsR|jtd|j}|jd|jd}t|j|jdS(Nt on_deletei( RRRRRtNonet gc_collectt assertTrueR(RR((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_on_delete2s (R R RRRRRR (((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyR s      tReferenceCounterTestcBsGeZdZdZdZdZdZdZdZRS(cCs t|_dS(N(Rtrunning(R((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyR;scCs t|_dS(N(RR"(R((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pytstart>scCs t|_dS(N(RR"(R((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pytstopAscCsddlm}|S(Ni(tReferenceCounter(RR%(RR%((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyRDscOs|j||S(N(R(RRR((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyRHscCs|jd|jd|j}|j|j|j|j|j|jd|j|j|j|j|jd|j|j |j|j|jd|j|j |j|j|jd|jdS(Nton_zerot on_non_zeroiii( RR$R#t assertFalseR"t incrementRRt get_countt decrement(Rtctr((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_incr_and_decrKs    cCs5|jd|jd|j}|jt|jdS(NR&R'(RR$R#t assertRaisest ExceptionR+(RR,((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_decr_at_zero_raises_error[s( R R RR#R$RRR-R0(((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyR!9s      tSocketManagerTestcBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZRS(cCs tdS(N(R(R((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttearDownascCsddlm}|S(Ni(t SocketManager(RR3(RR3((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyRdscOs|j||S(N(R(RRR((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyRhscCsTtd}|j|}d|jt||jf}|jt||dS(Nis<%s at %s for %s>(RRt __class__tidturlRtrepr(Rtconft sock_managertexpected((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt test_reprks  cCs5td}|j|}|j||jdS(Ni(RRRtconfig(RR8R9((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_get_configrs cCsWtdd}|j|}|j|j||j}|j|jddS(Nt localhostias 127.0.0.1(s 127.0.0.1ia(RRRt socket_configt get_sockett getsockname(RR8R9tsock((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_tcp_w_hostnamews  cCsWtdd}|j|}|j|j||j}|j|jddS(Ns 127.0.0.1ia(s 127.0.0.1ia(RRRR?R@RA(RR8R9RB((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt test_tcp_w_ip~s  cCsytj\}}t|}|j|}|j|j||j}|j|j|d}t j |dS(N( ttempfiletmkstempRRRR?R@RARtostclose(Rttf_fdttf_nameR8R9RB((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt test_unixs  c Cstd}|j|}|j|j|j}|j|jt|j}|j}t|j}|j|||j |||j d|j |j|j|j|j j d}t|j|j|j|j j d}t|j|j|j|j j |j}|j|jt|j}|j||~t|j|j|j|j j dS(Ni(RRR(t is_preparedR@RR5t_gettassertNotEqualRtget_socket_ref_counttsockett close_calledRR( RR8R9RBtsock_idtsock2tsock2_idtsock3tsock3_id((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_socket_lifecycles:    cCstd}t}|j|d|}|j}|jt|jd|jdt||jd~t|jt|jd|jdt||jddS(NitloggersCreating socket %siisClosing socket %s( RRRR@RtlentdataR7R(RR8RXR9RB((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt test_loggings   !cCstd}|j|}|j}|j|j|j|j|j|j|j|j t j |j|j dS(Ni( RRR@RRLR(t bind_calledt listen_calledRtlisten_backlogRPt SOMAXCONNRQ(RR8R9RB((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_prepare_sockets  cCsVtdd}|j|}|j}|j|}|jtj|j~dS(Ns 127.0.0.1ia(RRR@R.RPterror(RR8R9RBt sock_manager2((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_tcp_socket_already_takens  cCs5td}|j|}|jtj|jdS(Ns/notthere/foo.sock(RRR.RPRaR@(RR8R9((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyttest_unix_bad_socks cCsztdd}|j|}|j|jy|j|jWn*tk ru}|j|jddnXdS(Ns 127.0.0.1iaisSocket has not been prepared( RRR(RLt_closetfailR/RR(RR8R9te((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt#test_close_requires_prepared_sockets (R R R2RRR;R=RCRDRKRWR[R`RcRdRh(((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyR1_s        +   cCs1tdk r-tjtjtjndS(N(t__pypy__Rtgctcollect(((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyRs   cCstjtjtS(N(tunittestt findTestCasestsystmodulesR (((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyt test_suitest__main__t defaultTestRp((t__doc__RjRnRGRlRPRERit ImportErrorRtsupervisor.tests.baseRRtsupervisor.datatypesRRRtTestCaseR R!R1RRpR tmain(((sH/usr/lib/python2.7/site-packages/supervisor/tests/test_socket_manager.pyts,         &