X?_c@sdZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z ddlm Z m Z mZejZdefdYZdefdYZyddlZddlZWnek rd\ZZnXd efd YZd efd YZd efdYZde fdYZdeejfdYZdefdYZdefdYZdefdYZ dS(s2Site services for use with a Web Site Process Bus.iN(t basestringt get_daemontget_thread_ident(tntobtTimertSetDaemonPropertyt SimplePlugincBs/eZdZdZdZdZdZRS(sCPlugin base class which auto-subscribes methods for known channels.cCs ||_dS(N(tbus(tselfR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyt__init__(scCsOxH|jjD]:}t||d}|dk r |jj||q q WdS(s>Register this object as a (multi-channel) listener on the bus.N(Rt listenerstgetattrtNonet subscribe(Rtchanneltmethod((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR +s cCsOxH|jjD]:}t||d}|dk r |jj||q q WdS(s0Unregister this object as a listener on the bus.N(RR R R t unsubscribe(RRR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR3s N(t__name__t __module__t__doc__R RR R R(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR s   t SignalHandlercBseZdZiZiZxLeejD]8\ZZ ej dr+ej d r+eee ` if the process is daemonized, but :func:`bus.exit()` if the process is attached to a TTY. This is because Unix window managers tend to send SIGHUP to terminal windows when the user closes them. Feel free to add signals which are not available on every platform. The :class:`SignalHandler` will ignore errors raised from attempting to register handlers for unknown signals. tSIGtSIG_cCs||_i|jjd6|jd6|jjd6|_tjd dkr|jd=|jj|jd<|jjd|j|jd`_ cCs8tj||t|_||_||_||_dS(N(RR tFalset finalizedtuidtgidtumask(RRRKRIRJ((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR s    cCs|jS(N(t_uid(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyt_get_uidscCsl|dk r_tdkr7|jjdddd}q_t|tr_tj|d}q_n||_dS(Ns'pwd module not available; ignoring uid.R-ii(R tpwdRR#R7RtgetpwnamRL(Rtval((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyt_set_uids   tdocs/The uid under which to run. Availability: Unix.cCs|jS(N(t_gid(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyt_get_gidscCsl|dk r_tdkr7|jjdddd}q_t|tr_tj|d}q_n||_dS(Ns'grp module not available; ignoring gid.R-ii(R tgrpRR#R7RtgetgrnamRS(RRP((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyt_set_gids   s/The gid under which to run. Availability: Unix.cCs|jS(N(t_umask(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyt _get_umaskscCsW|dk rJy tjWqJtk rF|jjdddd}qJXn||_dS(Ns-umask function not available; ignoring umask.R-i(R R=RKtAttributeErrorRR#RX(RRP((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyt _set_umasks    sThe default permission mode for newly created files and directories. Usually expressed in octal format, for example, ``0644``. Availability: Unix, Windows. cCsd}|jrM|jdko-|jdks|jjd|qn|jdkr|jdkrtswtr|jjdddqn|jjd||jdk rtj |jtj gn|jdk rtj |jn|jjd||jrG|j dk r|jjd|j qnW|j dkro|jjd ddn/tj |j }|jjd ||j ft |_dS( NcSsZd\}}tr.tjtjd}ntrPtjtjd}n||fS(s+Return the current (uid, gid) if available.iN(NN(R RNtgetpwuidR=tgetuidRUtgetgrgidtgetgid(tnametgroup((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyt current_ids s  s"Already running as uid: %r gid: %rsuid/gid not setR-isStarted as uid: %r gid: %rsRunning as uid: %r gid: %rsumask already set to: %03os umask not setsumask old: %03o, new: %03o(RHRIR RJRR#RNRUR=tsetgidt setgroupstsetuidRKR3(RRbt old_umask((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pytstart s0     iMN(RRRR R RMRQtpropertyRIRTRWRJRYR[RKRgtpriority(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRFs$          ,t DaemonizercBs2eZdZddddZdZde_RS(sDaemonize the running script. Use this with a Web Site Process Bus via:: Daemonizer(bus).subscribe() When this component finishes, the process is completely decoupled from the parent environment. Please note that when this component is used, the return code from the parent process will still be 0 if a startup error occurs in the forked children. Errors in the initial daemonizing process still return proper exit codes. Therefore, if you use this plugin to daemonize, don't use the return code as an accurate indicator of whether the process fully started. In fact, that return code only indicates if the process succesfully finished the first fork. s /dev/nullcCs8tj||||_||_||_t|_dS(N(RR R?tstdouttstderrRGRH(RRR?RkRl((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR Js    cCsW|jr|jjdntjdkrQ|jjdtjddntjjtj jy<t j }|dkrn|jjdt j dWnHt k rtjd}tjdtjd|j|jfnXt jy<t j }|dkr7|jjd t j dnWnHt k rtjd}tjd tjd|j|jfnXt jd t jdt|jd }t|jd }t|j d }t j|jtjjt j|jtjjt j|jtj j|jjdt jt|_dS(NsAlready deamonized.isHThere are %r active threads. Daemonizing now may cause strange failures.R-iis Forking once.s%s: fork #1 failed: (%d) %s sForking twice.s%s: fork #2 failed: (%d) %s t/trsa+sDaemonized to PID: %s(RHRR#t threadingt activeCountt enumerateR!RktflushRlR=tforkt_exittOSErrortexc_infoRtargvterrnotstrerrortsetsidtchdirRKtopenR?tdup2R@tgetpidR3(Rtpidtexctsitsotse((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRgRsJ        "     "  iA(RRRR RgRi(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRj8s   CtPIDFilecBs2eZdZdZdZde_dZRS(s!Maintain a PID file via a WSPBus.cCs&tj||||_t|_dS(N(RR tpidfileRGRH(RRR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR s cCstj}|jr5|jjd||jfnLt|jdjtd|d|jjd||jft |_dS(NsPID %r already written to %r.twbs%s tutf8sPID %r written to %r.( R=R~RHRR#RR|twriteRR3(RR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRgs    &iFcCsRy+tj|j|jjd|jWn ttfk rGnnXdS(NsPID file removed: %r.(R=tremoveRRR#tKeyboardInterruptt SystemExit(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs(RRRR RgRiR(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs    tPerpetualTimercBs eZdZdZdZRS(sA responsive subclass of threading.Timer whose run() method repeats. Use this timer only when you really need a very interruptible timer; this checks its 'finished' condition up to 20 times a second, which can results in pretty high CPU usage cOs2|jdd|_tt|j||dS(s:Override parent constructor to allow 'bus' to be provided.RN(tpopR RtsuperRR (Rtargstkwargs((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR scCsxtr|jj|j|jjr/dSy|j|j|jWqtk r|j r|j j d|jdddtnqXqWdS(Ns,Error in perpetual timer thread function %r.R-i(R.( R3tfinishedtwaittintervaltisSettfunctionRRt ExceptionRR#(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pytruns    (RRRR R(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs tBackgroundTaskcBs2eZdZgiddZdZdZRS(sA subclass of threading.Thread whose run() method repeats. Use this class for most repeating tasks. It uses time.sleep() to wait for each interval, which isn't very responsive; that is, even if you call self.cancel(), you'll have to wait until the sleep() call finishes before the thread stops. To compensate, it defaults to being daemonic, which means it won't delay stopping the whole process. cCsStjj|||_||_||_||_t|_||_ t |_ dS(N( RotThreadR RRRRRGtrunningRR3tdaemon(RRRRRR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR s      cCs t|_dS(N(RGR(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pytcancelscCst|_x|jrtj|j|js2dSy|j|j|jWq tk r|j r|j j d|jdddtnq Xq WdS(Ns,Error in background task thread function %r.R-i(R.( R3RttimetsleepRRRRRRR#(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs      N(RRRR R RR(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs  tMonitorcBsSeZdZdZdZdZdddZdZde_ dZ dZ RS(sAWSPBus listener to periodically run a callback in its own thread.i<cCs8tj||||_||_d|_||_dS(N(RR tcallbackt frequencyR tthreadR`(RRRRR`((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR s    cCs|jdkr|jp!|jj}|jdkrt|j|jd|j|_|jj ||jj |jj d|q|jj d|ndS(s0Start our callback in its own background thread.iRsStarted monitor thread %r.s"Monitor thread %r already started.N( RR`t __class__RRR RRRtsetNameRgR#(Rt threadname((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRgs iFcCs|jdkr5|jjd|jp.|jjn|jtjk r|jj }|jj t |js|jjd||jj n|jjd|nd|_dS(s+Stop our callback's background task thread.sNo thread running for %s.s Joining %rsStopped thread %r.N( RR RR#R`RRRot currentThreadtgetNameRRtjoin(RR`((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pytstop!s  cCs|j|jdS(s:Stop the callback's background task thread and restart it.N(RRg(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR0s N( RRRR RRRR RgRiRR(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs  t AutoreloadercBsSeZdZdZdZdZdddZdZde_ dZ dZ RS( sQMonitor which re-executes the process when files change. This :ref:`plugin` restarts the process (via :func:`os.execv`) if any of the files it monitors change (or is deleted). By default, the autoreloader monitors all imported modules; you can add to the set by adding to ``autoreload.files``:: cherrypy.engine.autoreload.files.add(myFile) If there are imported files you do *not* wish to monitor, you can adjust the ``match`` attribute, a regular expression. For example, to stop monitoring cherrypy itself:: cherrypy.engine.autoreload.match = r'^(?!cherrypy).+' Like all :class:`Monitor` plugins, the autoreload plugin takes a ``frequency`` argument. The default is 1 second; that is, the autoreloader will examine files once each second. is.*cCs;i|_t|_||_tj|||j|dS(N(tmtimestsettfilestmatchRR R(RRRR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR Us   cCs,|jdkri|_ntj|dS(s2Start our own background task thread for self.run.N(RR RRRg(R((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRg[s iFcCst}xttjjD]\}}tj|j|rt|drpt|jdrp|jj }nUt |dd}|dk rt j j| rt j jt j jt|}n|j|qqW|S(s1Return a Set of sys.modules filenames to monitor.t __loader__tarchivet__file__N(RtlistR!tmodulesR(treRthasattrRRR R R=tpathtisabstnormpathRt_module__file__basetadd(RRRCtmtf((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pytsysfilesbs " cCs$x|j|jBD]}|r|jdr<|d }n|jj|d}|dkrcqnytj|j}Wnt k rd}nX||jkr||j|eZdZdZdZdZdZdZeZ RS(sManager for HTTP request threads. If you have control over thread creation and destruction, publish to the 'acquire_thread' and 'release_thread' channels (for each thread). This will register/unregister the current thread and publish to 'start_thread' and 'stop_thread' listeners in the bus as needed. If threads are created and destroyed by code you do not control (e.g., Apache), then, at the beginning of every HTTP request, publish to 'acquire_thread' only. You should not publish to 'release_thread' in this case, since you do not know whether the thread will be re-used or not. The bus will call 'stop_thread' listeners for you when it stops. cCsi|_tj|||jjjdt|jjjdt|jjjdt|jjjdtdS(Ntacquire_threadt start_threadtrelease_threadt stop_thread(tthreadsRR RR t setdefaultR(RR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyR s  cCsRt}||jkrNt|jd}||j|<|jjd|ndS(sRun 'start_thread' listeners for the current thread. If the current thread has already been seen, any 'start_thread' listeners will not be run again. iRN(RRtlenRR<(Rt thread_identti((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs   cCsDt}|jj|d}|dk r@|jjd|ndS(s;Release the current thread and run 'stop_thread' listeners.RN(RRRR RR<(RRR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs  cCsDx0|jjD]\}}|jjd|qW|jjdS(s8Release all threads and run all 'stop_thread' listeners.RN(RR(RR<tclear(RRR((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRsN( RRRR RR RRRR(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyRs    (NN(!RR=RR2R0R!RRotcherrypy._cpcompatRRRRRRtgetcwdRtobjectRRRNRUt ImportErrorR RFRjRRRRRRR(((s/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/plugins.pyts0         q`*9a