ó ÍÿŠTc@sldZddlZddlZddlZddlZddlZddlZddlmZm Z m Z ddl m Z m Z ddlmZddlmZmZddlmZddlmZdd lmZmZdd lmZdd lmZmZdd lm Z dd l!m"Z"ddl#m$Z$m%Z%m&Z&ddl'm(Z(ddl)m*Z*m+Z+m,Z,ddl-m.Z.dZ/dZ0dZ1dZ2de3fd„ƒYZ4de3fd„ƒYZ5de3fd„ƒYZ6de7fd„ƒYZ8de8fd„ƒYZ9de8fd „ƒYZ:d!e8fd"„ƒYZ;d#efd$„ƒYZ<d%e7fd&„ƒYZ=d'efd(„ƒYZ>d)„Z?d*efd+„ƒYZ@e$e&d,d-d.d/ƒe&d0d-d.d/ƒe&d1d-d.d/ƒe&d2d-d.d/ƒe&d3d-d.d/ƒe&d4d-d.d/ƒe&d5d-d.d6ƒe&d7d-d.d/ƒe&d8d-d.d/ƒe%d9d-d.d:ƒg ƒZAd;„ZBejCdd<„ZEdS(=s”See L{WatchDog}. The WatchDog must run as root, because it spawns the Landscape Manager. The main C{landscape-client} program uses this watchdog. iÿÿÿÿN(twarningtinfoterror(t setrlimitt RLIMIT_NOFILE(treactor(tDeferredtsucceed(tProcessProtocol(tProcessExitedAlready(tServicet Application(tstartApplication(t init_loggingt Configuration(tgather_results(t log_failure(t BootstrapListt BootstrapFiletBootstrapDirectory(t rotate_logs(tRemoteBrokerConnectortRemoteMonitorConnectortRemoteManagerConnector(tLandscapeReactori iit DaemonErrorcBseZdZRS(s(One of the daemons could not be started.(t__name__t __module__t__doc__(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR)st TimeoutErrorcBseZdZRS(sSomething took too long.(RRR(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR-stExecutableNotFoundErrorcBseZdZRS(sAn executable was not found.(RRR(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR1stDaemoncBs›eZdZdZdZdZdZee dd„Z d„Z d„Z d„Z d„Zd „Zd „Zd „Zd „Zd „Zd„Zd„ZRS(sqA Landscape daemon which can be started and tracked. This class should be subclassed to specify individual daemon. @cvar program: The name of the executable program that will start this daemon. @cvar username: The name of the user to switch to, by default. @cvar service: The DBus service name that the program will be expected to listen on. @cvar max_retries: The maximum number of retries before giving up when trying to connect to the watched daemon. @cvar factor: The factor by which the delay between subsequent connection attempts will increase. @param connector: The L{ComponentConnector} of the daemon. @param reactor: The reactor used to spawn the process and schedule timed calls. @param verbose: Optionally, report more information when running this program. Defaults to False. t landscapeigš™™™™™ñ?c Cs'||_||_tjjƒ|_tjƒ}|dkrÛtj|j ƒ}|j }|j }||krx||_ n d|_ |tjƒkrŸ||_n d|_|j|jd<|j |jd<|j |jd°scSstS(N(tFalse(tx((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRf²s(R$tconnectt max_retriestfactorR:t addCallbackt addErrback(R<ReROtkwargsR`t connected((ReR<s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyt_connect_and_callŸs   cCs |jdƒS(Ntexit(Rp(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyt request_exitµscCs |jdƒS(Ntping(Rp(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyt is_running¸scCs |jstdƒS|jjƒS(sN Return a Deferred which will fire when the process has died. N(R7RR1twait(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRu¾s  cCs |jstdƒS|jjƒS(s¶ Wait for the process to die for C{GRACEFUL_WAIT_PERIOD}. If it hasn't died by that point, send it a SIGTERM. If it doesn't die for C{SIGKILL_DELAY}, N(R7RR1t wait_or_die(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRvÆs  cCs t|_dS(s£Called by the watchdog when starting to shut us down. It will prevent our L{WatchedProcessProtocol} to restart the process when it exits. N(RgR;(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pytprepare_for_shutdownÐscCs|jS(s>Return a boolean indicating if the daemon should be restarted.(R;(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyt allow_restartØscCs|jjƒdS(N(R7R(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRÜsN(RRRR-RjRkR1RZRRgRDRNR^RVRpRrRtRuRvRwRxR(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR5s$        tBrokercBseZdZRS(slandscape-broker(RRRK(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRyàstMonitorcBseZdZRS(slandscape-monitor(RRRK(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRzästManagercBseZdZdZRS(slandscape-managertroot(RRRKR-(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR{èsRWcBsqeZdZeZd„Zd„Zed„Zd„Zd„Z d„Z d„Z d„Z d „Z d „ZRS( su A process-watching protocol which sends any of its output to the log file and restarts it when it dies. cCs(||_d|_d|_d|_dS(N(tdaemonR1t _wait_resultt_delayed_really_killt_delayed_terminate(R<R}((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRDõs   cCs|jƒ|jƒS(N(t _terminateRu(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR_ûs cCs|jdk r{|r/td|jjfƒny|jjtjƒWntk rYq{Xt j t |j ƒ}||_ ndS(Ns%s didn't exit. Sending SIGTERM(t transportR1RR}RKt signalProcesstsignaltSIGTERMR Rt callLatert SIGKILL_DELAYt _really_killR(R<twarntdelayed((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRÿs cCsLy|jjtjƒWntk r*nXtd|jjƒd|_ dS(Ns %s didn't die. Sending SIGKILL.( R‚RƒR„tSIGKILLR RR}RKR1R(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRˆ s  cCsA|jdk r=y|jjtjƒWq=tk r9q=XndS(N(R‚R1RƒR„tSIGUSR1R (R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRs  cCs/|jjdkrtdƒStƒ|_|jS(N(R‚tpidR1RRR~(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRus  cCs(tjt|jdtƒ|_|jƒS(NR‰(RR†tGRACEFUL_WAIT_PERIODRR:R€Ru(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRv#s cCstjj|ƒdS(N(RHtstdouttwrite(R<tdata((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyt outReceived(scCstjj|ƒdS(N(RHtstderrR(R<R‘((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyt errReceived,scCs’|jdk r|jjƒn|jdk rM|jjƒrM|jjƒn|jdk ro|jjdƒn|jjƒrŽ|jj ƒndS(s"The process has ended; restart it.N( RR1tcancelR€tactiveR~tcallbackR}RxR^(R<treason((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyt processEnded/s(RRRRgt_killedRDR_RRˆRRuRvR’R”R™(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRWís        tWatchDogcBskeZdZeed d d d d d„Zd„Zd„Zd„Z d„Z d„Z d„Z d„Z RS( sj The Landscape WatchDog starts all other landscape daemons and ensures that they are working. c sÉtƒ}|dkr'tttg}n|dkrft|krftt||ƒd|d|jƒ}n|dkr¥t|kr¥tt||ƒd|d|jƒ}n|dkrät|krätt||ƒd|d|jƒ}n|ˆ_ |ˆ_ |ˆ_ t dˆj ˆj ˆj gƒˆ_ ˆˆ_dˆ_tˆ_tjtj‡‡fd†ƒ|dk r¼|jdkr¼dt|jƒdt|jƒg} xˆj D]} | | _q¦Wniˆ_dS(NR>R?csˆjˆjƒS(N(tcallFromThreadt_notify_rotate_logs(R„tframe(R<R(s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRf^sis--cloness--start-clones-over(RR1RyRzR{RR?RRtbrokertmonitortmanagertfiltertdaemonsRt _checkingRgt _stoppingR„RŒtcloneststrtstart_clones_overRZt_ping_failures( R<RR>R?RŸR R¡tenabled_daemonstlandscape_reactorRZR}((R<Rs6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRDBs>     $   cCsbg}x=|jD]2}|jƒ}|j|d„ƒ|j|ƒqWd„}t|ƒj|ƒS(s6Return a list of any daemons that are already running.cSs ||fS(N((Rttd((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRfpscSs%g|D]}|dr|d^qS(Nii((trRh((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pytgot_all_resultsss(R£RtRlRXR(R<tresultsR}tresultR®((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyt check_runninghs  cCs,x|jD]}|jƒq W|jƒdS(sm Start all daemons. The broker will be started first, and no other daemons will be started before it is running and responding to DBUS messages. @return: A deferred which fires when all services have successfully started. If a daemon could not be started, the deferred will fail with L{DaemonError}. N(R£R^tstart_monitoring(R<R}((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR^ws cCs|jjd|jƒ|_dS(s;Start monitoring processes which have already been started.iN(RR†t_checkR¤(R<((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR²…scsÁ| r°ˆj r°tdˆjfƒˆˆjkrDdˆjˆ||_td|j d|d|jƒƒ|_d|_dS(NR>R?Rªi(R6R›R}RÆtwatchdogt exit_code(R<R?((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRDòs  cs3tjˆƒtjdˆjjdˆjjƒˆjjdkrÕtt ˆjjdˆjjdfƒddl m }d|_ xQt ˆjjƒD]:}d |}tjdˆjj|dˆjj|ƒq”Wntdƒ}|j‡fd †ƒ‡fd †}‡fd †}|j|ƒ|j|ƒ|S( Nt data_pathtlog_diriidiÈiÿÿÿÿ(tMethodCallSenderi,s -clone-%dcs ˆjjƒS(N(RØR±(t_(R<(s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRfscs_|r>tddjd„|Dƒƒƒdˆ_tjƒdSˆjƒtdƒˆjjƒS(Ns4ERROR: The following daemons are already running: %ss, css|]}|jVqdS(N(RK(t.0Rh((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pys sisWatchdog watching for daemons.( RRJRÙRtcrasht _daemonizeRRØR^(trunning_daemons(R<(s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pytstart_if_not_runnings    cs$t|dƒdˆ_tjƒdS(NsUnknown error occurred!i(RRÙRRß(tfailure(R<(s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pytdies  (R t startServicetbootstrap_listt bootstrapR6RÚRÛR¦RRtlandscape.lib.ampRÜttimeoutRÍRR1RlRm(R<RÜRÔtsuffixR°RâRä((R<s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRåùs(         cCsa|jjr]tƒ|jjr]t|jjdƒ}|jttjƒƒƒ|j ƒq]ndS(Ntw( R6R}RÖtpid_fileRËRR§R&tgetpidRÒ(R<tstream((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRà&s   csVtdƒtjˆƒtjtjtjƒˆjjƒ}|j‡fd†ƒ|S(NsStopping client...cs ˆjƒS(N(t _remove_pid(R­(R<(s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRf7s( RR t stopServiceR„tSIGINTtSIG_IGNRØRrRµ(R<tdone((R<s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRð.s   cCs~|jj}|dk rztj|tjƒrzt|ƒ}|jƒ}|jƒ|t tj ƒƒkrztj |ƒqzndS(N( R6RìR1R&taccesstW_OKRËtreadRÒR§Rítunlink(R<RìRîR((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRï:s !   (RRRDRåRàRðRï(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyR×ðs   -  s $data_pathR R|iís$data_path/packages$data_path/package/hash-ids$data_path/package/binariess$data_path/package/upgrade-tools$data_path/messagess$data_path/socketsiès$data_path/custom-graph-scriptss$log_dirs$data_path/package/databasei¤cCsFx?tjjƒD].}|jdƒs1|dkrtj|=qqWdS(sHUnset dangerous environment variables. In particular unset all variables beginning with DEBIAN_ or DEBCONF_, to avoid any problems when landscape-client is invoked from its postinst script. Some environment variables may be set which would affect *other* maintainer scripts which landscape-client invokes. tDEBIAN_tDEBCONF_tLANDSCAPE_ATTACHMENTStMAILN(RøRù(RúRû(R&R'tkeyst startswith(tkey((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pytclean_environmentUs cCsôtƒtƒ}|j|ƒytjdƒj}Wntk rStjdƒnXt j ƒd|fkr|tjdƒnt |dƒt dƒ}t |ƒ}|j|ƒ|d krÍddlm}n|jdt|tƒ|jƒ|jS( sStart the watchdog. This is the topmost function that kicks off the Landscape client. It cleans up the environment, loads the configuration, and starts the reactor. @param args: Command line arguments, including the program name as the first element. @param reactor: The reactor to use. If none is specified, the global reactor is used. @raise SystemExit: if command line arguments are bad, or when landscape- client is not running as 'root' or 'landscape'. R s#The 'landscape' user doesn't exist!is:landscape-client can only be run as 'root' or 'landscape'.RØslandscape-clientiÿÿÿÿ(RN(RÿR¼tloadR+R,R.tKeyErrorRHRqR&R*R R R×tsetServiceParentR1ttwisted.internetRR†R RgtrunRÙ(RORR?t landscape_uidt applicationtwatchdog_service((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pyRcs$         (FRR&RÐRHR+R„RStloggingRRRtresourceRRRRttwisted.internet.deferRRttwisted.internet.protocolRttwisted.internet.errorR ttwisted.application.serviceR R ttwisted.application.appR tlandscape.deploymentR Rtlandscape.lib.twisted_utilRtlandscape.lib.logRtlandscape.lib.bootstrapRRRt landscape.logRtlandscape.broker.ampRRRtlandscape.reactorRRŽRURTR‡t ExceptionRRRtobjectRRyRzR{RWR›R¼RÖR×RæRÿRIR1R(((s6/usr/lib/python2.7/dist-packages/landscape/watchdog.pytsl      «OŒ T