ó ¨œž[c@`sŒdZddlmZmZmZddlZddlZddlZddlm Z ddl m Z d„Z de j fd„ƒYZ dS( sDLowest-common-denominator implementations of platform functionality.i(tabsolute_importtdivisiontprint_functionN(t interface(terrno_from_exceptioncC`sUxDtdƒD]6}y|jƒWntk rAtjdƒq XPq W|jƒdS(Ni gü©ñÒMbP?(trangetclosetIOErrorttimetsleep(tfti((s6lib/python2.7/site-packages/tornado/platform/common.pyt try_close s tWakercB`sDeZdZd„Zd„Zd„Zd„Zd„Zd„ZRS(sÓCreate an OS independent asynchronous pipe. For use on platforms that don't have os.pipe() (or where pipes cannot be passed to select()), but do have sockets. This includes Windows and Jython. cC`s§ddlm}tjƒ|_||jjƒƒ|jjtjtjdƒd}xè|d7}tjƒ}||jƒƒ|jdƒ|j dƒ|j ƒ}y|jj |ƒPWqWtj k r:}t tdƒ sòt|ƒtjkrø‚n|dkr-|jƒ|jjƒtj dƒ‚n|jƒqWXqWW|jƒ\|_}||jjƒƒ|jjdƒ|jjdƒ|jƒ|jjƒ|_dS( Ni(tset_close_execis 127.0.0.1t WSAEADDRINUSEi sCannot bind trigger!(s 127.0.0.1i(tautoRtsockettwritertfilenot setsockoptt IPPROTO_TCPt TCP_NODELAYtbindtlistent getsocknametconnectterrorthasattrterrnoRRRtaccepttreadert setblockingt reader_fd(tselfRtcounttatconnect_addresstdetailtaddr((s6lib/python2.7/site-packages/tornado/platform/common.pyt__init__"s<        cC`s |jjƒS(N(RR(R"((s6lib/python2.7/site-packages/tornado/platform/common.pyRZscC`s |jjƒS(N(RR(R"((s6lib/python2.7/site-packages/tornado/platform/common.pyt write_fileno]scC`s8y|jjdƒWnttjtfk r3nXdS(Ntx(RtsendRRRt ValueError(R"((s6lib/python2.7/site-packages/tornado/platform/common.pytwake`scC`sNy-x&tr+|jjdƒ}|sPqqWWnttjfk rInXdS(Ni(tTrueRtrecvRRR(R"tresult((s6lib/python2.7/site-packages/tornado/platform/common.pytconsumefs  cC`s|jjƒt|jƒdS(N(RRR R(R"((s6lib/python2.7/site-packages/tornado/platform/common.pyRos ( t__name__t __module__t__doc__R(RR)R-R1R(((s6lib/python2.7/site-packages/tornado/platform/common.pyR s 8    (R4t __future__RRRRRRttornado.platformRt tornado.utilRR R (((s6lib/python2.7/site-packages/tornado/platform/common.pyts