ó ‚•oTc@syddlZdefd„ƒYZdefd„ƒYZdefd„ƒYZd„Zd d „Zd „Zd „ZdS( iÿÿÿÿNt ServerAdaptercBsheZd d d„Zd„Zd„Zd„Zde_d„Zd„Z d„Z de _d „Z RS( cCs1||_||_||_d|_t|_dS(N(tbust httpservert bind_addrtNonet interrupttFalsetrunning(tselfRRR((s,/var/www/SABnzbd/cherrypy/process/servers.pyt__init__s     cCs0|jjd|jƒ|jjd|jƒdS(Ntstarttstop(Rt subscribeR R (R((s,/var/www/SABnzbd/cherrypy/process/servers.pyR scCs0|jjd|jƒ|jjd|jƒdS(NR R (Rt unsubscribeR R (R((s,/var/www/SABnzbd/cherrypy/process/servers.pyR scCs*|jdkrd}nAt|jtƒrL|j\}}d||f}n d|j}|jrz|jjd|ƒdSd|_|js›t dƒ‚nt|jtƒr½t |jŒnddl }|j d|j ƒ}|jd|jƒƒ|jƒ|jƒt|_|jjd |ƒdS( Nsunknown interface (dynamic?)s%s:%sssocket file: %ssAlready serving on %ss No HTTP server has been created.iÿÿÿÿttargets HTTPServer s Serving on %s(RRt isinstancettupleRRtlogRRt ValueErrortwait_for_free_portt threadingtThreadt_start_http_threadtsetNametgetNameR twaittTrue(Rton_whatthosttportRtt((s,/var/www/SABnzbd/cherrypy/process/servers.pyR #s*         iKcCsÝy|jjƒWnÅtk rL}|jjdƒ||_|jjƒntk r‡}|jjdƒ||_|jjƒ‚nRddl}|j ƒd|_|jjddt ddƒ|jjƒ‚nXdS( Ns' hit: shutting down HTTP servers,SystemExit raised: shutting down HTTP serveriÿÿÿÿis#Error in HTTP server: shutting downt tracebacktleveli(( RR tKeyboardInterruptRRRtexitt SystemExittsystexc_infoR(RtexcR$((s,/var/www/SABnzbd/cherrypy/process/servers.pyRCs$      cCssx;t|jdtƒs=|jr-|j‚ntjdƒqWt|jtƒro|j\}}t ||ƒndS(Ntreadygš™™™™™¹?( tgetattrRRRttimetsleepRRRtwait_for_occupied_port(RRR((s,/var/www/SABnzbd/cherrypy/process/servers.pyR]s  cCsv|jr[|jjƒt|jtƒr8t|jŒnt|_|jj d|jƒn|jj d|jƒdS(NsHTTP Server %s shut downs HTTP Server %s already shut down( RRR RRRRRRR(R((s,/var/www/SABnzbd/cherrypy/process/servers.pyR is   icCs|jƒ|jƒdS(N(R R (R((s,/var/www/SABnzbd/cherrypy/process/servers.pytrestartws N( t__name__t __module__RR R R R tpriorityRRR R,(((s,/var/www/SABnzbd/cherrypy/process/servers.pyRs      tFlupFCGIServercBs#eZd„Zd„Zd„ZRS(cOsg|jddƒdkrHddl}t|jdƒsHtdƒ‚qHn||_||_t|_dS(Nt bindAddressiÿÿÿÿtfromfds{Dynamic FCGI server not available on this platform. You must use a static or external one by providing a legal bindAddress.( tgetRtsocketthasattrRtargstkwargsRR'(RR6R7R4((s,/var/www/SABnzbd/cherrypy/process/servers.pyR €s   cCs]ddlm}||j|jŽ|_d„|j_g|j_t|_|jj ƒdS(Niÿÿÿÿ(t WSGIServercSsdS(N(R(((s,/var/www/SABnzbd/cherrypy/process/servers.pyt›s( tflup.server.fcgiR8R6R7t fcgiservert_installSignalHandlerst_oldSIGsRR'trun(RR8((s,/var/www/SABnzbd/cherrypy/process/servers.pyR Œs    cCs1t|j_|jjj|jj_t|_dS(N(RR;t _keepGoingt _threadPoolt _idleCounttmaxSpareR'(R((s,/var/www/SABnzbd/cherrypy/process/servers.pyR  s (R-R.R R R (((s,/var/www/SABnzbd/cherrypy/process/servers.pyR0}s tFlupSCGIServercBs#eZd„Zd„Zd„ZRS(cOs||_||_t|_dS(N(R6R7RR'(RR6R7((s,/var/www/SABnzbd/cherrypy/process/servers.pyR ¬s  cCs]ddlm}||j|jŽ|_d„|j_g|j_t|_|jj ƒdS(Niÿÿÿÿ(R8cSsdS(N(R(((s,/var/www/SABnzbd/cherrypy/process/servers.pyR9Às( tflup.server.scgiR8R6R7t scgiserverR<R=RR'R>(RR8((s,/var/www/SABnzbd/cherrypy/process/servers.pyR ±s    cCs(t|_t|j_d|jj_dS(Ni(RR'RER?R@RB(R((s,/var/www/SABnzbd/cherrypy/process/servers.pyR Ås  (R-R.R R R (((s,/var/www/SABnzbd/cherrypy/process/servers.pyRC©s  cCs$|dkrdS|dkr dS|S(Ns0.0.0.0s 127.0.0.1s::s::1((t server_host((s,/var/www/SABnzbd/cherrypy/process/servers.pyt client_hostÎs   gð?c Cs|stdƒ‚nt|ƒ}t|ƒ}ddl}xÐ|j|||j|jƒD]°}|\}}}}} d} ye|j|||ƒ} | j|ƒ| j ||fƒ| j ƒt dt |ƒt |ƒfƒ‚WqX|j k r| r| j ƒqqXXqXWdS(Ns*Host values of '' or None are not allowed.iÿÿÿÿsTPort %s is in use on %s; perhaps the previous httpserver did not shut down properly.(RRGtintR4t getaddrinfot AF_UNSPECt SOCK_STREAMRt settimeouttconnecttclosetIOErrortreprterror( RRttimeoutR4trestaftsocktypetprotot canonnametsats((s,/var/www/SABnzbd/cherrypy/process/servers.pyt check_portØs&      cCs‚|stdƒ‚nxPtdƒD]B}yt||ddƒWntk r_tjdƒq"XdSq"Wtd||fƒ‚dS(Ns*Host values of '' or None are not allowed.i2RRgš™™™™™¹?sPort %r not free on %r(RtxrangeRZROR)R*(RRttrial((s,/var/www/SABnzbd/cherrypy/process/servers.pyRõs cCsy|stdƒ‚nxGtdƒD]9}yt||ƒWntk rMdSXtjdƒq"Wtd||fƒ‚dS(Ns*Host values of '' or None are not allowed.i2gš™™™™™¹?sPort %r not bound on %r(RR[RZROR)R*(RRR\((s,/var/www/SABnzbd/cherrypy/process/servers.pyR+s ( R)tobjectRR0RCRGRZRR+(((s,/var/www/SABnzbd/cherrypy/process/servers.pyts w,%