ó ‚•oTc@s}ddlZddlZyeWn!ek rCddlmZnXddlZddlZddl Z ddl Z de fd„ƒYZ de fd„ƒYZ yddlZddlZWnek rÛd\ZZnXde fd„ƒYZd e fd „ƒYZd e fd „ƒYZd e jfd„ƒYZde fd„ƒYZdefd„ƒYZde fd„ƒYZdS(iÿÿÿÿN(tSett SimplePlugincBs#eZd„Zd„Zd„ZRS(cCs ||_dS(N(tbus(tselfR((s,/var/www/SABnzbd/cherrypy/process/plugins.pyt__init__scCsOxH|jjD]:}t||dƒ}|dk r |jj||ƒq q WdS(N(Rt listenerstgetattrtNonet subscribe(Rtchanneltmethod((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRs cCsOxH|jjD]:}t||dƒ}|dk r |jj||ƒq q WdS(N(RRRRt unsubscribe(RR R ((s,/var/www/SABnzbd/cherrypy/process/plugins.pyR s (t__name__t __module__RRR (((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRs  t SignalHandlercBs¢eZiZxLeeƒjƒD]8\ZZejdƒrejdƒ reeeR?(RRR5RaRb((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRs    cCs>|jr|jjdƒntjƒdkrQ|jjdtjƒddƒntjjƒtj jƒy<t j ƒ}|dkr‰n|jjdƒt j dƒWn:t k rã}tjdtjd|j|jfƒnXt jƒy<t j ƒ}|dkr)|jjd ƒt j dƒnWn:t k rf}tjd tjd|j|jfƒnXt jd ƒt jdƒt|jd ƒ}t|jd ƒ}t|j d dƒ}t j|jƒtjjƒƒt j|jƒtjjƒƒt j|jƒtj jƒƒ|jjdt jƒƒt|_dS(NsAlready deamonized.isHThere are %r active threads. Daemonizing now may cause strange failures.Riis Forking once.s%s: fork #1 failed: (%d) %s sForking twice.s%s: fork #2 failed: (%d) %s t/trsa+sDaemonized to PID: %s(R?RR!t threadingt activeCountt enumerateR4RatflushRbR2tforkt_exittOSErrorRtargvterrnotstrerrortsetsidtchdirRBtopenR5tdup2R6tgetpidR%(Rtpidtexctsitsotse((s,/var/www/SABnzbd/cherrypy/process/plugins.pyR] sF       "    "  iA(R R RR]R_(((s,/var/www/SABnzbd/cherrypy/process/plugins.pyR`òs  AtPIDFilecBs,eZd„Zd„Zde_d„ZRS(cCs&tj||ƒ||_t|_dS(N(RRtpidfileR>R?(RRRz((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRRs cCs~tjƒ}|jr5|jjd||jfƒnEt|jdƒjt|ƒƒ|jjd||jfƒt |_dS(NsPID %r already written to %r.twbsPID %r written to %r.( R2RsR?RR!RzRqtwritetstrR%(RRt((s,/var/www/SABnzbd/cherrypy/process/plugins.pyR]Ws    iFcCsRy+tj|jƒ|jjd|jƒWn ttfk rG‚nnXdS(NsPID file removed: %r.(R2tremoveRzRR!tKeyboardInterruptt SystemExit(R((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRas(R R RR]R_R(((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRyOs   tPerpetualTimercBseZd„ZRS(cCsMxFtrH|jj|jƒ|jjƒr/dS|j|j|jŽqWdS(N(R%tfinishedtwaittintervaltisSettfunctiontargstkwargs(R((s,/var/www/SABnzbd/cherrypy/process/plugins.pytrunns  (R R R‰(((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRkstMonitorcBs>eZdZdd„Zd„Zde_d„Zd„ZRS(i<cCs/tj||ƒ||_||_d|_dS(N(RRtcallbackt frequencyRtthread(RRR‹RŒ((s,/var/www/SABnzbd/cherrypy/process/plugins.pyR€s  cCs‘|jdkr|jj}|jdkrvt|j|jƒ|_|jj|ƒ|jjƒ|j j d|ƒq|j j d|ƒndS(NisStarted monitor thread %r.s"Monitor thread %r already started.( RŒt __class__R RRRR‹tsetNameR]RR!(Rt threadname((s,/var/www/SABnzbd/cherrypy/process/plugins.pyR]†s  iFcCsŽ|jdkr,|jjd|jjƒn^|jtjƒk r|jjƒ}|jj ƒ|jj ƒ|jjd|ƒnd|_dS(NsNo thread running for %s.sStopped thread %r.( RRRR!RŽR Ret currentThreadtgetNametcanceltjoin(RRW((s,/var/www/SABnzbd/cherrypy/process/plugins.pytstop“s  cCs|jƒ|jƒdS(N(R•R](R((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRŸs (R R RŒRR]R_R•R(((s,/var/www/SABnzbd/cherrypy/process/plugins.pyRŠvs    t AutoreloadercBs>eZdZdZddd„Zd„Zde_d„ZRS(is.*cCs;i|_tƒ|_||_tj|||j|ƒdS(N(tmtimestsettfilestmatchRŠRR‰(RRRŒRš((s,/var/www/SABnzbd/cherrypy/process/plugins.pyR«s   cCs,|jdkri|_ntj|ƒdS(N(RRR—RŠR](R((s,/var/www/SABnzbd/cherrypy/process/plugins.pyR]±s iFcCs±tƒ}x‡tjjƒD]v\}}tj|j|ƒrt|dƒrmt|jdƒrm|jj}qmnt |ddƒ}|j |ƒqqWx||j BD]}|r¡|j dƒrÉ|d }n|jj|dƒ}|dkrðq¡nytj|ƒj}Wntk rd}nX||jkr?||j|s,       c b] /;