ó ½-'Nc@s^ddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z mZmZmZmZddlmZddlmZddlmZmZmZmZddlmZdefd „ƒYZd efd „ƒYZd e fd „ƒYZ!defd„ƒYZ"d„Z#d„Z$dS(iÿÿÿÿN(t maybeDeferredtsucceed(tSUCCESS_RESULTt ERROR_RESULTtDEPENDENCY_ERROR_RESULTt POLICY_STRICTtPOLICY_ALLOW_INSTALLStPOLICY_ALLOW_ALL_CHANGEStUNKNOWN_PACKAGE_DATA_TIMEOUT(t create_file(tfind_reporter_command(tPackageTaskHandlertPackageTaskHandlerConfigurationtPackageTaskErrortrun_task_handler(t SUCCEEDEDtUnknownPackageDatacBseZdZRS(s(Raised when an ID or a hash isn't known.(t__name__t __module__t__doc__(((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyRstPackageChangerConfigurationcBseZdZed„ƒZRS(s<Specialized configuration for the Landscape package-changer.cCstjj|jdƒS(s@The path to the directory we store server-generated packages in.tbinaries(tostpathtjointpackage_directory(tself((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyt binaries_paths(RRRtpropertyR(((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyRstChangePackagesResultcBseZdZd„ZRS(s‹Value object to hold the results of change packages operation. @ivar code: The result code of the requested changes. @ivar text: The output from Smart. @ivar installs: Possible additional packages that need to be installed in order to fulfill the request. @ivar removals: Possible additional packages that need to be removed in order to fulfill the request. cCs(d|_d|_g|_g|_dS(N(tNonetcodettexttinstallstremovals(R((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyt__init__0s   (RRRR#(((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR%s tPackageChangercBs›eZdZeZdZd„Zd„Zd„Zd„Z d„Z dd„Z e dde d„Zd „Zd „Zd „Zd „Zed „ƒZRS(s%Install, remove and upgrade packages.tchangercs_ˆjƒs#tjdƒtdƒSˆjƒ}|j‡fd†ƒ|j‡fd†ƒ|S(sV Handle our tasks and spawn the reporter if package data has changed. s-The package-reporter hasn't run yet, exiting.cs ˆjƒS(N(t handle_tasks(tx(R(s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pytGscs ˆjƒS(N(trun_package_reporter(R'(R(s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR(HsN(tsmart_update_stamp_existstloggingtwarningRRtuse_hash_id_dbt addCallback(Rtresult((Rs=/usr/lib/python2.7/dist-packages/landscape/package/changer.pytrun>s    cCsª|jdkrdS|jjƒtjƒdkrgtjtjdƒjƒtj t j dƒj ƒnt ƒ}|jjdk r™|d|jj7}ntj|ƒdS(sX Run the L{PackageReporter} if there were successfully completed tasks. iNt landscapes -c %s(thandled_tasks_countt_facadetdeinitRtgetuidtsetgidtgrptgetgrnamtgr_gidtsetuidtpwdtgetpwnamtpw_uidR t_configtconfigRtsystem(Rtcommand((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR)Ks  cCs_|j}|ddkr>t|j|ƒ}|j|j|ƒS|ddkr[|j|ƒSdS(sl @param task: A L{PackageTask} carrying a message of type C{"change-packages"}. ttypeschange-packagesschange-package-locksN(tdataRthandle_change_packagest addErrbacktunknown_package_data_errorthandle_change_package_locks(RttasktmessageR/((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyt handle_task_s  cCs‡|jtƒtjd|jjdƒ|jtjƒtkrzidd6|j dd6t d6dd6}|j j |ƒSt ƒ‚d S( s}Handle L{UnknownPackageData} data errors. If the task is older than L{UNKNOWN_PACKAGE_DATA_TIMEOUT} seconds, a message is sent to the server to notify the failure of the associated activity and the task will be removed from the queue. Otherwise a L{PackageTaskError} is raised and the task will be picked up again at the next run. s2Package data not yet synchronized with server (%r)ischange-packages-resultRBs operation-ids result-codes5Package data has changed. Please retry the operation.s result-textN(ttrapRR+R,tvaluetargst timestampttimeRRCRt_brokert send_messageR (RtfailureRHRI((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyRFks    cCstjj|jjƒS(sT Return a boolean indicating if the smart-update stamp file exists. (RRtexistsR>tsmart_update_stamp_filename(R((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR*‚scCsÏ|jj}x3tj|ƒD]"}tjtjj||ƒƒqW|r¾i}xJ|D]B\}}}ttjj|d|ƒtj |ƒƒ|||RRtlistdirtremoveRRR tbase64t decodestringt_storet set_hash_idsR3tadd_channel_deb_dirtensure_channels_reloaded(RRRtexisting_deb_paththash_idsthashtidtdeb((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyt init_channelsˆs  c Cs|r|jjƒn|rUx6|jjƒD]"}|jr,|jj|ƒq,q,Wnx§||jjf||jjfgD]\}}xr|D]j}|jj|ƒ} | dkrÀt |ƒ‚n|jj | ƒ}|dkrít | ƒ‚n||ƒqWqzWdS(s`Mark packages for upgrade, installation or removal. @param upgrade: If C{True} mark all installed packages for upgrade. @param install: A list of package ids to be marked for installation. @param remove: A list of package ids to be marked for removal. @param reset: If C{True} all existing marks will be reset. N( R3t reset_markst get_packagest installedt mark_upgradet mark_installt mark_removeRYt get_id_hashRRtget_package_by_hash( RtupgradetinstallRVtresettpackagetidst mark_funcR`R_((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyt mark_packages s     c Cs€ddlm}m}m}tƒ}d}xN|jdkr{|d7}y|jjƒ|_ Wn||fk r‘}t |_|j d|_ q.|k rn}x||j D]q}|jj |ƒ} |jj| ƒ} | dkrït| ƒ‚n|jr |jj| ƒqª|jj| ƒqªW|dkrb|j||ƒrb|jd|jd|jdtƒqxt|_q.Xt|_q.W|S( stPerform the requested changes. @param policy: A value indicating what to do in case additional changes beside the ones explicitly requested are needed in order to fulfill the request (see L{complement_changes}). @return: A L{ChangePackagesResult} holding the details about the outcome of the requested changes. iÿÿÿÿ(tDependencyErrortTransactionErrort SmartErroriiRlRVRmN(tlandscape.package.facadeRrRsRtRRRR3tperform_changesR RRMtpackagestget_package_hashRYt get_hash_idRReR"tappendR!tmay_complement_changesRqtFalseRR( RtpolicyRrRsRtR/tcountt exceptionRnR_R`((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pytchange_packages»s2        cCs:|tkrtS|tkr6|jr6|j r6tSntS(saDecide whether or not we should complement the given changes. @param result: A L{PackagesResultObject} holding the details about the missing dependencies needed to complement the given changes. @param policy: It can be one of the following values: - L{POLICY_STRICT}, no additional packages will be marked. - L{POLICY_ALLOW_INSTALLS}, if only additional installs are missing they will be marked for installation. @return: A boolean indicating whether the given policy allows to complement the changes and retry. (RtTrueRR!R"R|(RR/R}((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR{ës  cCs |j|jddƒƒ|j|jdtƒ|jddƒ|jddƒƒ|j|jdtƒƒ}idd6|jdƒd6}|j|d <|jr®|j|d s$       4" ü