Tc@sddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z mZmZmZmZmZmZddlmZddlmZddlmZddlmZmZmZmZdd lm Z dd l!m"Z"dd l#m$Z$d e%fd YZ&defdYZ'de(fdYZ)defdYZ*dZ+dZ,dS(iN(t maybeDeferredtsucceed(treactor(tSUCCESS_RESULTt ERROR_RESULTtDEPENDENCY_ERROR_RESULTt POLICY_STRICTtPOLICY_ALLOW_INSTALLStPOLICY_ALLOW_ALL_CHANGEStUNKNOWN_PACKAGE_DATA_TIMEOUT(t create_file(t log_failure(tfind_reporter_command(tPackageTaskHandlertPackageTaskHandlerConfigurationtPackageTaskErrortrun_task_handler(tFAILED(tShutdownProcessProtocol(tREBOOT_REQUIRED_FILENAMEtUnknownPackageDatacBseZdZRS(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.pyRstPackageChangerConfigurationcBseZdZedZRS(s<Specialized configuration for the Landscape package-changer.cCstjj|jdS(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_path#s(RRRtpropertyR(((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR stChangePackagesResultcBseZdZdZRS(sValue object to hold the results of change packages operation. @ivar code: The result code of the requested changes. @ivar text: The output from Apt. @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__4s   (RRRR'(((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR!)s tPackageChangercBseZdZeZdZededZ dZ dZ dZ dZ dZdZdd Zedddded Zd Zd Zd ZdZdZdZedZdZedZRS(s%Install, remove and upgrade packages.tchangerc Csitt|j||||||_|dkrSddlm}||_n ||_||_dS(Ni(tLandscapeReactor( tsuperR(R't_process_factoryR"tlandscape.reactorR*t_landscape_reactortreboot_required_filename( Rtstoretfacadetremotetconfigtprocess_factorytlandscape_reactorR/R*((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR'Bs   csujs#tjdtdSj}|jfd|jfd|jfd|S(sV Handle our tasks and spawn the reporter if package data has changed. s-The package-reporter hasn't run yet, exiting.cs jS(N(tget_session_id(tx(R(s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pytWscs jS(N(t handle_tasks(R7(R(s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR8Xscs jS(N(trun_package_reporter(R7(R(s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR8YsN(tupdate_stamp_existstloggingtwarningRR"tuse_hash_id_dbt addCallback(Rtresult((Rs=/usr/lib/python2.7/dist-packages/landscape/package/changer.pytrunNs    cCs|jdkrdStjdkrZtjtjdjtjtj dj nt }|j j dk r|d|j j 7}ntj|dS(sX Run the L{PackageReporter} if there were successfully completed tasks. iNt landscapes -c %s(thandled_tasks_countRtgetuidtsetgidtgrptgetgrnamtgr_gidtsetuidtpwdtgetpwnamtpw_uidR t_configR3R"tsystem(Rtcommand((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR:\s 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_taskls  cCs|jttjd|jjd|jtjtkridd6|j dd6t d6dd6}|j j ||j Std 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-resultRPs operation-ids result-codes5Package data has changed. Please retry the operation.s result-textN(ttrapRR<R=tvaluetargst timestampttimeR RQRt_brokert send_messaget _session_idR(RtfailureRVRW((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyRTxs    cCs+tjj|jjp*tjj|jS(sT Return a boolean indicating if the update-stamp stamp file exists. (RRtexistsRMtupdate_stamp_filenametupdate_notifier_stamp(R((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyR;scCsS|jj}x3tj|D]"}tjtjj||qW|jjdS(s/Remove any binaries and its associated channel.N( RMRRtlistdirtremoveRRt_facadetclear_channels(RRtexisting_deb_path((s=/usr/lib/python2.7/dist-packages/landscape/package/changer.pyt_clear_binariess  cCs|jj}|j|ri}xJ|D]B\}}}ttjj|d|tj||||s.       4" C