ó ½-'Nc@s*ddlZddlZddlZddlmZmZddlmZmZddl m Z ddl m Z m Z ddlmZddlmZmZddlmZmZdd lmZd efd „ƒYZd efd „ƒYZdefd„ƒYZdefd„ƒYZdd„ZdS(iÿÿÿÿN(tsucceedtDeferred(t lock_patht LockError(t log_failure(tLSB_RELEASE_FILENAMEtparse_lsb_release(tTwistedReactor(t Configurationt init_logging(t PackageStoretInvalidHashIdDb(tRemoteBrokerConnectortPackageTaskErrorcBseZdZRS(s6Raised when a task hasn't been successfully completed.(t__name__t __module__t__doc__(((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR stPackageTaskHandlerConfigurationcBsJeZdZed„ƒZed„ƒZed„ƒZed„ƒZRS(s5Specialized configuration for L{PackageTaskHandler}s.cCstjj|jdƒS(s&Get the path to the package directory.tpackage(tostpathtjoint data_path(tself((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytpackage_directoryscCstjj|jdƒS(s8Get the path to the SQlite file for the L{PackageStore}.tdatabase(RRRR(R((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytstore_filenamescCstjj|jdƒS(s?Get the path to the directory holding the stock hash-id stores.shash-id(RRRR(R((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pythash_id_directory!scCstjj|jdƒS(s,Get the path to the smart-update stamp file.ssmart-update-stamp(RRRR(R((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytsmart_update_stamp_filename&s(RRRtpropertyRRRR(((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRs tLazyRemoteBrokercBs eZdZd„Zd„ZRS(sWrapper class around L{RemoteBroker} providing lazy initialization. This class is a wrapper around a regular L{RemoteBroker}. It connects to the remote broker object only when one of its attributes is first accessed. @param connector: The L{RemoteBrokerConnector} which will be used to connect to the broker. @note: This behaviour is needed in particular by the ReleaseUpgrader and the PackageChanger, because if the they connect early and the landscape-client package gets upgraded while they run, they will lose the connection and will not be able to reconnect for a potentially long window of time (till the new landscape-client package version is fully configured and the service is started again). cCs||_d|_dS(N(t _connectortNonet_remote(Rt connector((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt__init__=s cs/ˆjrtˆjˆƒS‡‡fd†}|S(Ncs4‡‡‡‡fd†}ˆjjƒ}|j|ƒS(Ncs"|ˆ_tˆjˆƒˆˆŽS(N(R!tgetattr(tremote(Rtargstkwargstmethod(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytgot_connectionHs (Rtconnectt addCallback(R&R'R)tresult(RR((R&R'sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytwrapperFs(R!R$(RR(R-((RR(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt __getattr__As  (RRRR#R.(((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR,s tPackageTaskHandlercBsteZeZdZeZd„Zd„Zd„Z d d„Z d„Z d„Z ed„ƒZd„Zd „ZRS( tdefaultcCs1||_||_||_||_d|_dS(Ni(t_storet_facadet_brokert_configt_count(Rt package_storetpackage_facadet remote_brokertconfig((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR#Ys     cCs |jƒS(N(t handle_tasks(R((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytrun`scCs |jdƒS(s¼Handle the tasks in the queue. The tasks will be handed over one by one to L{handle_task} until the queue is empty or a task fails. @see: L{handle_tasks} N(t_handle_next_taskR (R((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR:cscCsŠ|dk r(|jƒ|jd7_n|jj|jƒ}|r||j|ƒ}|j|jd|ƒ|j |j ƒ|St dƒSdS(s@Pick the next task from the queue and pass it to C{handle_task}.it last_taskN( R tremoveR5R1t get_next_taskt queue_namet handle_taskR+R<t addErrbackt_handle_task_failureR(RR,R=ttask((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR<ms  cCs|jtƒdS(s@Gracefully handle a L{PackageTaskError} and stop handling tasks.N(ttrapR (Rtfailure((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRC‚scCs tdƒS(sHandle a single task. Sub-classes must override this method in order to trigger task-specific actions. This method must return a L{Deferred} firing the task result. If the deferred is successful the task will be removed from the queue and the next one will be picked. If the task can't be completed, this method must raise a L{PackageTaskError}, in this case the handler will stop processing tasks and the failed task won't be removed from the queue. N(RR (RRD((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRA†s cCs|jS(sX Return the number of tasks that have been successfully handled so far. (R5(R((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pythandled_tasks_count”scs,‡fd†}ˆjƒ}|j|ƒ|S(sS Attach the appropriate pre-canned hash=>id database to our store. csq|dkrdStjj|ƒs&dSyˆjj|ƒWn0tk rltjd|ƒtj |ƒdSXdS(NsInvalid hash=>id database %s( R RRtexistsR1tadd_hash_id_dbR tloggingtwarningR>(thash_id_db_filename(R(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytuse_it s    (t_determine_hash_id_db_filenameR+(RRMR,((RsA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytuse_hash_id_db›s  cs/‡fd†}ˆjjƒ}|j|ƒ|S(s§Build up the filename of the hash=>id database to use. @return: a deferred resulting in the filename to use or C{None} in case of errors. csùd}|dkr'tj|dƒdSytˆjƒ}Wn+tk rg}tj|t|ƒƒdSXy|d}Wn*tk r¢tj|dˆjƒdSXˆjj ƒ}|dkrÓtj|dƒdSt j j ˆj jd|||fƒS(Ns5Couldn't determine which hash=>id database to use: %ssserver UUID not availables code-namesmissing code-name key in %ssunknown dpkg architectures%s_%s_%s(R RJRKRtlsb_release_filenametIOErrortstrtKeyErrorR2tget_archRRRR4R(t server_uuidRKtlsb_release_infoterrortcodenametarch(R(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytgot_server_uuidÁs*     (R3tget_server_uuidR+(RRZR,((RsA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRNºs N(RRRtconfig_factoryR@RRPR#R;R:R R<RCRARRGRORN(((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR/Rs      c sˆdkrtƒ‰n|jƒ}|j|ƒx<|j|jgD](}tjj|ƒsDtj |ƒqDqDW|j }tjj |j|dƒ}yt |ƒWn6t k rÛ|jrÈtƒ‚ntd|ƒ‚nXtjd|jƒ}t|dj d„|Dƒƒƒtjdƒddlm}t|jƒ} |ƒ} ‡‡fd †‰‡fd †} tˆ|d tƒ‰tˆƒ} || | | |ƒ‰tƒ‰ˆj‡fd †ƒˆj‡fd †ƒˆj| ƒˆj‡fd†ƒˆj ƒˆS(Ns.locks$error: package %s is already runnings [A-Z][a-z]+t-css|]}|jƒVqdS(N(tlower(t.0tword((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pys þsiiÿÿÿÿ(t SmartFacadecs$ˆjƒˆjdˆjjƒdS(Ni(t disconnectt call_latert_reactortstop((R"treactor(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytfinish s cst|ƒˆƒdS(N(R(RF(Rg(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt got_errors tretry_on_reconnectcs ˆjƒS(N(R;(tx(thandler(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytscsˆƒS(N((Rj(Rg(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRlscs ˆjdƒS(N(tcallbackR ((R,(sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRls(!R RR\tloadRRRRtisdirtmkdirR@RRRtquiett SystemExittretfindallRR tumasktlandscape.package.facadeRaR RR tTrueRRR+RBtcall_when_runningR;( tclsR&RfR9t directoryt program_namet lock_filenametwordsRaR6R7RhR%((RfR,R"RkRgsA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pytrun_task_handleråsF                ( RRsRJttwisted.internet.deferRRtlandscape.lib.lockRRtlandscape.lib.logRtlandscape.lib.lsb_releaseRRtlandscape.reactorRtlandscape.deploymentRR tlandscape.package.storeR R tlandscape.broker.ampR t ExceptionR RtobjectRR/R R~(((sA/usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyts   &“