ó sÁìVc@sÜddlZddlZddlZddlZddlZddlZddlmZddlm Z dZ de fd„ƒYZ de fd„ƒYZ d e fd „ƒYZd e fd „ƒYZd „Zd„ZdS(iÿÿÿÿN(tutil(t string_typesit BaseSocketcBsDeZdd„Zd„Zd„Zed„Zd„Zd„Z RS(cCs||_||_||_|dkrBtj|jtjƒ}ntj||jtjƒ}|j|d|dk ƒ|_ dS(Ntbound( tlogtconftcfg_addrtNonetsockettFAMILYt SOCK_STREAMtfromfdt set_optionstsock(tselftaddressRRtfdR ((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyt__init__s    cCsd|jjƒS(Ns (R tfileno(Rtname((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyt__str__!scCst|j|ƒS(N(tgetattrR (RR((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyt __getattr__$scCsr|jtjtjdƒ|s/|j|ƒn|jdƒt|dƒr[|jtƒn|j |j j ƒ|S(Niitset_inheritable( t setsockoptRt SOL_SOCKETt SO_REUSEADDRtbindt setblockingthasattrRtTruetlistenRtbacklog(RR R((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR 's cCs|j|jƒdS(N(RR(RR ((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR4scCsMy|jjƒWn/tjk rB}|jjdt|ƒƒnX|`dS(NsError while closing socket %s(R tcloseRterrorRtinfotstr(Rte((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR!7s N( t__name__t __module__RRRRtFalseR RR!(((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyRs    t TCPSocketcBs&eZejZd„Zed„ZRS(cCsC|jjrd}nd}|jjƒ}d||d|dfS(Nthttpsthttps %s://%s:%dii(Rtis_sslR t getsockname(Rtschemetaddr((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyRCs   cCs5|jtjtjdƒtt|ƒj|d|ƒS(NiR(RRt IPPROTO_TCPt TCP_NODELAYtsuperR)R (RR R((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR Ls(R&R'RtAF_INETR RR(R (((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR)?s  t TCP6SocketcBseZejZd„ZRS(cCs)|jjƒ\}}}}d||fS(Nshttp://[%s]:%d(R R-(Rthosttporttfltsc((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyRUs(R&R'RtAF_INET6R R(((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR4Qs t UnixSocketcBs8eZejZdd„Zd„Zd„Zd„Z RS(cCs»|dkr†ytj|ƒ}Wn/tk rP}|jdtjkrƒ‚qƒq†Xtj|jƒrstj |ƒq†t d|ƒ‚ntj ƒ|_ t t|ƒj|||d|ƒdS(Nis%r is not a socketR(RtoststattOSErrortargsterrnotENOENTtS_ISSOCKtst_modetremovet ValueErrortgetpidtparentR2R:R(RR/RRRtstR%((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR^s  cCs d|jS(Nsunix:%s(R(R((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyRmscCsXtj|jjƒ}|j|jƒtj|j|jj|jjƒtj|ƒdS(N( R;tumaskRRRRtchowntuidtgid(RR t old_umask((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyRps"cCs?tt|ƒjƒ|jtjƒkr;tj|jƒndS(N(R2R:R!RFR;REtunlinkR(R((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR!wsN( R&R'RtAF_UNIXR RRRRR!(((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyR:Zs     cCs`t|tƒr4tj|dƒr+t}q\t}n(t|tƒrLt}ntd|ƒ‚|S(Nis Unable to create socket from: %r( t isinstancettupleRtis_ipv6R4R)RR:t TypeError(R/t sock_type((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyt _sock_type}s   c CsQg}dtjkrØttjjdƒƒtjƒkrØxItttjjddƒƒƒD]&}|t}yÿtj|tj tj ƒ}|j ƒ}t |t ƒrÕ|jdƒrÕ|jt|||d|ƒƒn”t|ƒdkrd|dkr|jtd|||d|ƒƒnLt|ƒd krid |dkri|jtd |d ||d|ƒƒnWq[tjk r€q[Xq[Wtjd=tjd=|rØ|jd d jg|D]}t |ƒ^qµƒƒ|Sn|j}|jrtjj|jƒ rtd|jƒ‚n|jrKtjj|jƒ rKtd|jƒ‚ndtjkrtjjdƒjd ƒ} x¡t| ƒD]“\}}t|ƒ}||} t | ƒ} y#|j| | ||d|ƒƒWq‚tjk r} | j!dt"j#kr|jdƒq‚q‚Xq‚W|Sx-|D]%} t | ƒ} d}xËtdƒD]½}y| | ||ƒ}Wntjk r} | j!dt"j%kr©|jdt | ƒƒn| j!dt"j&krØ|jdt | ƒƒn|dkr|jdƒt'j(dƒqqIXPqIW|dkr<|jdt | ƒƒt)j*dƒn|j|ƒq$W|S(s Create a new socket for the given address. If the address is a tuple, a TCP socket is created. If it is a string, a Unix socket is created. Otherwise a TypeError is raised. t LISTEN_PIDt LISTEN_FDSit/Rit.s%s:%sit:s[%s]:%ssSocket activation sockets: %st,scertfile "%s" does not existskeyfile "%s" does not existt GUNICORN_FDs+GUNICORN_FD should refer to an open socket.isConnection in use: %ssInvalid address: %ssRetrying in 1 second.isCan't connect to %sN(+R;tenvirontinttgetREtrangetSD_LISTEN_FDS_STARTRR RNR R-ROR$t startswithtappendR:tlenR)R4R"tdebugtjoinRtcertfiletpathtexistsRDtkeyfiletpoptsplitt enumerateRTR>R?tENOTCONNRt EADDRINUSEt EADDRNOTAVAILttimetsleeptsystexit( RRt listenerstiRR tsocknametltladdrtfdsR/RSR%((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pytcreate_socketsŠsz $(  "" " )    #      (R?R;RR<RrRptgunicornRt gunicorn.sixRR`tobjectRR)R4R:RTRz(((s]/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/sock.pyts      , #