ó úR‹_c@sídZddlmZddlmZddlZejddkrXedƒeZ ndefd „ƒYZ ddlZe e_ddl j Z dd l mZejƒdd l mZdd lmZydd lmZWn!ek rdd lmZnXddlmZddlZddlZddlZe e_dZe jr]ed9Znd„Zd„Zd„Z d„Z!d„Z"e j#dƒe j$e j%o«e j&dƒde j'fd„ƒYƒƒZ(e)dkrée j*ƒndS(sjThis test checks that underlying socket instances (gevent.socket.socket._sock) are not leaked by the hub. iÿÿÿÿ(tprint_function(tsocketNiiRtSocketcBseZdZRS(s"Something we can have a weakref to(t__name__t __module__t__doc__(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pyR%s(tmonkey(tflaky(tpformat(tstart_new_thread(tsleepgš™™™™™¹?icCsPtjƒ}|jtƒ|jtjtjdƒ|jdƒ|jdƒ|S(Nis 127.0.0.1ii(s 127.0.0.1i(Rt settimeouttSOCKET_TIMEOUTt setsockoptt SOL_SOCKETt SO_REUSEADDRtbindtlisten(ts((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pyt init_server?s     cCs‡y|jƒ\}}Wn$tjk r<|r5‚q=dSnX|jdƒ}|dksjtt|ƒƒ‚|jdƒ}|jƒdS(Nidthellotbye(tacceptRttimeouttrecvtAssertionErrortreprtsendtclose(Rtraise_on_timeouttconnt_tres((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pythandle_requestHscCsitjƒ}|jd|fƒ|jdƒ}|jdƒ}|dks[tt|ƒƒ‚|jƒdS(Ns 127.0.0.1RidR(RtconnectRRRRR(tportRR ((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pyt make_requestZs  cCs¥tƒ}tt||fƒ|rE|jƒd}tt|fƒntdtƒtj|j ƒ}|j ƒt j r¡ytdtƒWq¡t k rq¡Xn|S(Nigš™™™™™¹?(RR R!t getsocknameR$R R tweakreftreft_sockRt greentesttWINt Exception(t run_clientRR#tw((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pytrun_interactiongs    cCs·td|ƒ}tjr%tjƒn|ƒr³tttj|ƒƒƒƒxWtj|ƒƒD]C}tt|ƒƒx*tj|ƒD]}tdt|ƒƒqƒWq]Wtdƒ‚ndS(NR,t-sserver should be dead by now( R.R)tPYPYtgctcollecttprintRt get_referrersR(R,R-txty((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pyt run_and_check~s   sCOften fail with timeouts or force closed connections; not sure why.s8Often fail with force closed connections; not sure why. tTestcBsGeZejZejejƒd„ƒZ ejejƒd„ƒZ RS(cCsttƒttƒdS(N(R7tTrue(tself((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pyttest_clean_exit–s cCsttƒttƒdS(N(R7tFalse(R:((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pyttest_timeout_exit›s ( RRR)t LARGE_TIMEOUTt __timeout__Rtreraises_flaky_timeoutRRR;R=(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pyR8s t__main__(+Rt __future__Rt_socketRtc_sockettsyst version_infot __import__Rtgevent.testingttestingR)tgeventRt patch_allRtpprintRtthreadR t ImportErrort_threadttimeR R&R1t _realsocketR t RUNNING_ON_CIRR!R$R.R7tskipOnCItskipIftRUN_LEAKCHECKStPY3tTestCaseR8Rtmain(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__refcount.pytsL