ó Xé?_c@s`dZddlZddlZddlZddlZddlZddlZddlZej ƒZ de fd„ƒYZ de fd„ƒYZeƒZejƒe_ejƒe_ejƒe_ejƒe_ejƒe_yddlZWnek rdZn.XyejdƒZWnek r<d ZnXd e fd „ƒYZeƒZdS( sˆ An implementation of the Web Site Process Bus. This module is completely standalone, depending only on the stdlib. Web Site Process Bus -------------------- A Bus object is used to contain and manage site-wide behavior: daemonization, HTTP server start/stop, process reload, signal handling, drop privileges, PID file management, logging for all of these, and many more. In addition, a Bus object provides a place for each web framework to register code that runs in response to site-wide events (like process start and stop), or which controls or otherwise interacts with the site-wide components mentioned above. For example, a framework which uses file-based templates would add known template filenames to an autoreload component. Ideally, a Bus object will be flexible enough to be useful in a variety of invocation scenarios: 1. The deployer starts a site from the command line via a framework-neutral deployment script; applications from multiple frameworks are mixed in a single site. Command-line arguments and configuration files are used to define site-wide components such as the HTTP server, WSGI component graph, autoreload behavior, signal handling, etc. 2. The deployer starts a site via some other process, such as Apache; applications from multiple frameworks are mixed in a single site. Autoreload and signal handling (from Python at least) are disabled. 3. The deployer starts a site via a framework-specific mechanism; for example, when running tests, exploring tutorials, or deploying single applications from a single framework. The framework controls which site-wide components are enabled as it sees fit. The Bus object in this package uses topic-based publish-subscribe messaging to accomplish all this. A few topic channels are built in ('start', 'stop', 'exit', 'graceful', 'log', and 'main'). Frameworks and site containers are free to define their own. If a message is sent to a channel that has not been defined or has no listeners, there is no effect. In general, there should only ever be a single Bus object per process. Frameworks and site containers share a single Bus object by publishing messages and subscribing listeners. The Bus object works as a finite state machine which models the current state of the process. Bus methods move it from one state to another; those methods then publish to subscribed listeners on the channel for the new state.:: O | V STOPPING --> STOPPED --> EXITING -> X A A | | \___ | | \ | | V V STARTED <-- STARTING iÿÿÿÿNtChannelFailurescBsMeZdZdZd„Zd„Zd„Zd„ZeZd„Z e Z RS(sKException raised when errors occur in a listener during Bus.publish(). s cOs#tj|||Žtƒ|_dS(N(t Exceptiont__init__tlistt _exceptions(tselftargstkwargs((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyRVscCs|jjtjƒdƒdS(s%Append the current exception to self.iN(Rtappendtsystexc_info(R((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pythandle_exception\scCs|jS(s*Return a list of seen exception instances.(R(R((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyt get_instances`scCs%tt|jƒƒ}|jj|ƒS(N(tmaptreprR t delimitertjoin(Rtexception_strings((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyt__str__dscCs t|jƒS(N(tboolR(R((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyt__bool__js( t__name__t __module__t__doc__RRR R Rt__repr__Rt __nonzero__(((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyRPs     t _StateEnumcBs'eZdefd„ƒYZd„ZRS(tStatecBseZdZd„ZRS(cCs d|jS(Ns states.%s(tname(R((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyRvsN(RRtNoneRR(((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyRsscCs5t||jƒr||_ntj|||ƒdS(N(t isinstanceRRtobjectt __setattr__(Rtkeytvalue((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR ys (RRRRR (((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyRqsit SC_OPEN_MAXitBuscBsÔeZdZeZejZeZeZ d„Z dd„Z d„Z d„Zd„Zd„Zd„Zd„Zd „Zd d „Zd dd „Zd „Zd„Zd„Zddd„Zdded„ZRS(ssProcess state-machine and messenger for HTTP site deployment. All listeners for a given channel are guaranteed to be called even if others at the same channel fail. Each failure is logged, but execution proceeds on to the next listener. The only way to stop all processing from inside a listener is to raise SystemExit and stop the whole server. cCsMt|_tj|_tgdD]}|tƒf^qƒ|_i|_dS(Ntstarttstoptexittgracefultlogtmain(sstartsstopsexitsgracefulslogsmain( tFalsetexecvtstatestSTOPPEDtstatetdicttsett listenerst _priorities(Rtchannel((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR s   %cCsn||jkr"tƒ|j|ÄsiiR)sError in %r listener %rtleveli(t traceback(R2RR3tsortt TypeErrorRtKeyboardInterruptt SystemExitR R tcodeR R)tTrue( RR4RRtexctoutputtlistenertitemsR5te((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pytpublish¹s: 0       cCs:|jtjkr6tjd|jtƒ|jƒndS(s7An atexit handler which asserts the Bus is not running.sÀThe main thread is exiting, but the Bus is in the %r state; shutting it down automatically now. You must either call bus.block() after start(), or call bus.exit() before the main thread exits.N(R/R-tEXITINGtwarningstwarntRuntimeWarningR'(R((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyt _clean_exitàs cCsÁtj|jƒtj|_|jdƒy*|jdƒtj|_|jdƒWngt t fk ro‚nN|jddddt ƒt j ƒd}y|jƒWnnX|‚nXd S( sStart all services.s Bus STARTINGR%s Bus STARTEDs-Shutting down due to error in start listener:R?i(R@iN(tatexittregisterRQR-tSTARTINGR/R)RLtSTARTEDRCRDRFR R R'(Rte_info((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR%ês$      cCs„|j}yA|jƒtj|_|jdƒ|jdƒ|jdƒWntjdƒnX|tjkr€tjdƒndS(s2Stop all services and prepare to exit the process.s Bus EXITINGR's Bus EXITEDiFN( R/R&R-RMR)RLtost_exitRT(Rt exitstate((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR's     cCst|_|jƒdS(sÊRestart the process (may close connections). This method does not restart the process from the calling thread; instead, it stops the bus and asks the main thread to call execv. N(RFR,R'(R((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pytrestarts cCs|jdƒ|jdƒdS(sAdvise all services to reload.s Bus gracefulR(N(R)RL(R((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR(%s gš™™™™™¹?cCsAy |jtjd|ddƒWnXttfk rP|jdƒ|jƒn+tk rz|jdƒ|jƒ‚nX|jdƒxœtj ƒD]Ž}|tj ƒkr•|j ƒr•t |tj ƒ r•ttjdƒrê|j}n |jƒ}|s#|jd|jƒƒ|jƒq#q•q•W|jr=|jƒnd S( sºWait for the EXITING state, KeyboardInterrupt or SystemExit. This function is intended to be called only by the main thread. After waiting for the EXITING state, it also waits for all threads to terminate, and then calls os.execv if self.execv is True. This design allows another thread to call bus.restart, yet have the main thread perform the actual execv call (required on some platforms). tintervalR4R*s%Keyboard Interrupt: shutting down buss$SystemExit raised: shutting down buss)Waiting for child threads to terminate...tdaemonsWaiting for thread %s.N(twaitR-RMRCtIOErrorR)R'RDt threadingt enumeratet currentThreadtisAliveRt _MainThreadthasattrtThreadR\tisDaemontgetNameRR,t _do_execv(RR[tttd((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pytblock*s,            cs|t|ttfƒr|‰n |g‰‡‡‡‡fd†}ytjdj|ƒWnttfk rpnX|ƒdS(s=Poll for the given state(s) at intervals; publish to channel.cs4x-ˆjˆkr/tjˆƒˆjˆƒqWdS(N(R/ttimetsleepRL((R4R[RR-(s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyt_waitcs tpsycoN(RttupleRR tmodulest cannotcompiletKeyErrortAttributeError(RR/R[R4Rn((R4R[RR-s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR]\s   cCsÌtj}|jddj|ƒƒtjd dkrPddlm}|‚nx|jdtjƒtjdkr’g|D]}d |^qy}nt j t ƒ|j rµ|j ƒnt jtj|ƒd S( sÀRe-execute the current process. This must be called from the main thread, because certain platforms (OS X) don't allow execv to be called in a child thread very well. sRe-spawning %st itjavaiÿÿÿÿ(t SystemRestartitwin32s"%s"N(R targvR)Rtplatformt_systemrestartRwtinsertt executableRWtchdirt _startup_cwdtmax_cloexec_filest _set_cloexecR,(RRRwtarg((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyRhus      cCsnxgtd|jƒD]S}ytj|tjƒ}Wntk rHqnXtj|tj|tjBƒqWdS(sÞSet the CLOEXEC flag on all open files (except stdin/out/err). If self.max_cloexec_files is an integer (the default), then on platforms which support it, it represents the max open files setting for the operating system. This function will be called just before the process is restarted via os.execv() to prevent open files from persisting into the new process. Set self.max_cloexec_files to 0 to disable this behavior. iN(trangeR€tfcntltF_GETFDR^tF_SETFDt FD_CLOEXEC(Rtfdtflags((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR‹s  cCsCtj|_|jdƒ|jdƒtj|_|jdƒdS(sStop all services.s Bus STOPPINGR&s Bus STOPPEDN(R-tSTOPPINGR/R)RLR.(R((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR&s     cs“|dkrd}n|dkr*i}n|f|}‡fd†}tjd|d|d|ƒ}|jd|jƒƒ|jƒˆjƒ|S(s?Start 'func' in a new thread T, then start self (and return T).cs!ˆjtjƒ|||ŽdS(N(R]R-RU(tfunctatkw(R(s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyt _callback­sttargetRRs Bus Callback N((RR_RetsetNameRgR%(RR‹RRRŽRi((Rs~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pytstart_with_callback¥s       ticCsF|r/|ddjtjtjƒŒƒ7}n|jd||ƒdS(s>Log the given message. Append the last traceback if requested.s R’R)N(Rt _tracebacktformat_exceptionR R RL(RtmsgR?R@((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR)¸s)N(RRRR-R.R/R+R,t max_filesR€RRR9R<RLRQR%R'RZR(RkR]RhRR&R‘R)(((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyR$s*     '    2   (RRRRWR R_RlR@R“RNtgetcwdRRRRRR-RR.RTRURŠRMR„t ImportErrorR–tsysconfRtR$tbus(((s~/local/mnt/workspace/CRMBuilds/Saipan.LA.2.0-00145-STD.PROD-1_20200821_083004/b/common/sectools/ext/cherrypy/process/wspbus.pyt=s6        !     ÿ/