| Server IP : 61.19.30.66 / Your IP : 216.73.216.15 Web Server : Apache/2.2.22 (Ubuntu) System : Linux klw 3.11.0-15-generic #25~precise1-Ubuntu SMP Thu Jan 30 17:39:31 UTC 2014 x86_64 User : www-data ( 33) PHP Version : 5.3.10-1ubuntu3.48 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : ON | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /usr/lib/python2.7/dist-packages/landscape/package/ |
Upload File : |
}9Rc @ s d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z d d l
m Z d d l m
Z
m Z m Z m Z m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m Z m Z m Z m Z d d l m Z d d
l! m" Z" d d l# m$ Z$ d e% f d
YZ& d e f d YZ' d e( f d YZ) d e f d YZ* d Z+ d Z, d S( iN( t
maybeDeferredt succeed( t reactor( t SUCCESS_RESULTt ERROR_RESULTt DEPENDENCY_ERROR_RESULTt
POLICY_STRICTt POLICY_ALLOW_INSTALLSt POLICY_ALLOW_ALL_CHANGESt UNKNOWN_PACKAGE_DATA_TIMEOUT( t create_file( t log_failure( t find_reporter_command( t PackageTaskHandlert PackageTaskHandlerConfigurationt PackageTaskErrort run_task_handler( t FAILED( t ShutdownProcessProtocol( t REBOOT_REQUIRED_FILENAMEt UnknownPackageDatac B s e Z d Z RS( 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.pyR s t PackageChangerConfigurationc B s e Z d Z e d Z RS( s< Specialized configuration for the Landscape package-changer.c C s t j j | j d S( s@ The path to the directory we store server-generated packages in.t binaries( t ost patht joint package_directory( t self( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt
binaries_path# s ( R R R t propertyR ( ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR s t ChangePackagesResultc B s e Z d Z d Z RS( 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 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.
c C s( d | _ d | _ g | _ g | _ d S( N( t Nonet codet textt installst removals( R ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt __init__4 s ( R R R R' ( ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR! ) s t PackageChangerc B s e Z d Z e Z d Z e d e d Z d Z
d Z d Z d Z
d Z d Z d d Z e d d d d e d
Z d Z d Z d
Z d Z d Z d Z e d Z d Z e d Z RS( s% Install, remove and upgrade packages.t changerc C si t t | j | | | | | | _ | d k rS d d l m } | | _ n | | _ | | _ d S( Ni( t LandscapeReactor( t superR( R' t _process_factoryR" t landscape.reactorR* t _landscape_reactort reboot_required_filename( R t storet facadet remotet configt process_factoryt landscape_reactorR/ R* ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR' B s c s_ j s# t j d t d S j } | j f d | j f d | S( sV
Handle our tasks and spawn the reporter if package data has changed.
s- The package-reporter hasn't run yet, exiting.c s
j S( N( t handle_tasks( t x( R ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt <lambda>W s c s
j S( N( t run_package_reporter( R7 ( R ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR8 X s N( t update_stamp_existst loggingt warningR R" t use_hash_id_dbt addCallback( R t result( ( R s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt runN s
c C s | j d k r d St j d k rZ t j t j d j t j t j d j
n t } | j j
d k r | d | j j
7} n t j | d S( sX
Run the L{PackageReporter} if there were successfully completed tasks.
i Nt landscapes -c %s( t handled_tasks_countR t getuidt setgidt grpt getgrnamt gr_gidt setuidt pwdt getpwnamt pw_uidR t _configR3 R" t system( R t command( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR9 [ s c C s_ | j } | d d k r> t | j | } | j | j | S| d d k r[ | j | Sd S( sl
@param task: A L{PackageTask} carrying a message of
type C{"change-packages"}.
t types change-packagess change-package-locksN( t dataR t handle_change_packagest
addErrbackt unknown_package_data_errort handle_change_package_locks( R t taskt messageR? ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt handle_taskk s c C s | j t t j d | j j d | j t j t k rz i d d 6| j d d 6t
d 6d d 6} | 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.
s2 Package data not yet synchronized with server (%r)i s change-packages-resultRO s operation-ids result-codes5 Package data has changed. Please retry the operation.s result-textN( t trapR R; R< t valuet argst timestampt timeR RP R t _brokert send_messageR ( R t failureRU RV ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyRS w s
c C s+ t j j | j j p* t j j | j S( sT
Return a boolean indicating if the update-stamp stamp file exists.
( R R t existsRL t update_stamp_filenamet update_notifier_stamp( R ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR: s c C sS | j j } x3 t j | D]" } t j t j j | | q W| j j d S( s/ Remove any binaries and its associated channel.N( RL R R t listdirt removeR R t _facadet clear_channels( R R t existing_deb_path( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt _clear_binaries s c C s | j j } | j | r i } xJ | D]B \ } } } t t j j | d | t j | | | | <q) W| j j
| | j j | | j j
d t n | j j d S( s Initialize the Apt channels as needed.
@param binaries: A possibly empty list of 3-tuples of the form
(hash, id, deb), holding the hash, the id and the content of
additional Debian packages that should be loaded in the channels.
s %d.debt force_reload_binariesN( RL R Rh R
R R R t base64t decodestringt _storet set_hash_idsRe t add_channel_deb_dirt reload_channelst Truet ensure_channels_reloaded( R R R t hash_idst hasht idt deb( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt
init_channels s
c C s | r | j j n | r, | j j n x | j j | f | j j | f | j j | f | j j | f g D] \ } } xr | D]j } | j j | }
|
d k r t
| n | j j |
} | d k r t
|
n | | q Wqo Wd S( 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 hold: A list of package ids to be marked for holding.
@param remove_hold: A list of package ids to be marked to have a hold
removed.
@param reset: If C{True} all existing marks will be reset.
N( Re t reset_markst mark_global_upgradet mark_installt mark_removet mark_holdt mark_remove_holdRl t get_id_hashR" R t get_package_by_hash( R t upgradet installRd t holdt remove_holdt resett
mark_functiont mark_idst mark_idRs t package( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt
mark_packages s"
c
C s} d d l m } m } t } d } xQ| j d k rx| d 7} y | j j | _ Wn| k
r } t | _ | j
d | _ q( | k
rk} x | j D]z } | j j | } | j
j | } | d k r t | n | j j | r| j j | q | j j | q W| d k r_| j | | r_| j d | j d | j d t qut | _ q( Xt | _ q( W| S( st Perform 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( t DependencyErrort TransactionErrori i R Rd R N( t landscape.package.facadeR R R! R# R" Re t perform_changesR$ R RZ t packagest get_package_hashRl t get_hash_idR t is_package_installedR& t appendR% t may_complement_changesR t FalseR R (
R t policyR R R? t countt exceptionR Rs Rt ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt change_packages s2
c C s: | t k r t S| t k r6 | j r6 | j r6 t Sn t S( sa Decide 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.
( R Rp R R% R& R ( R R? R ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR s c
C s | j | j d d | j d | j d t d | j d d
d | j d d d | j d d d | j d d | j | j d t } | j | j d
o t j j | j
} | } | j d | | d | } | r | j
| j n | S( s$ Handle a C{change-packages} message.R R s upgrade-allR Rd R R s remove-holdR s reboot-if-necessaryt stop_exchanger( ( ( ( ( N( Rv t getR R R R Rh R R R` R/ t _send_responseR" R> t
_reboot_later( R RV R? t needs_rebootR t deferred( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyRQ s
c C s | j j d | j d S( Ni ( R. t
call_latert _run_reboot( R R? ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR 9 s c C sz t } d } | j | j | j j | j | | j j t d d d | d g } | j j | d d | | j S( sU
Create a C{ShutdownProcessProtocol} and return its result deferred.
t nows Reboot failed.s /sbin/shutdowns -rs! Landscape is rebooting the systemRZ (
R t set_timeoutR. R? R> t _log_rebootRR R R, t spawnProcess( R t protocolt minutesRZ ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR < s c C s t j d | d S( s Log the reboot.s/ Landscape is rebooting the system in %s minutesN( R; R< ( R R? R ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR K s c s i d d 6| j d d 6} | j | d <| j rC | j | d <n | j rb t | j | d <n | j r t | j | d <n t j d j j | t
} | r t j d | j f d
n | S( s?
Create a response and dispatch to the broker.
s change-packages-resultRO s operation-ids result-codes result-texts must-installs must-removesB Queuing response with change package results to exchange urgently.s* stopping exchanger due to imminent reboot.c s
j j S( N( R] R ( t _( R ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR8 f s ( R R# R$ R% t sortedR& R; t infoR] R^ Rp R> ( R t
reboot_resultRV t package_change_resultR t responseR ( ( R s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR P s
c C sE i d d 6| j d d 6t d 6d d 6d d 6} | j j | t S( sc Handle a C{change-package-locks} message.
Package locks aren't supported anymore.
s operation-resultRO s operation-idt statuss* This client doesn't support package locks.s result-texti s result-code( R R R] R^ Rp ( R RV R ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyRT i s
c C s t S( N( t find_changer_command( ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt find_commandw s N( ( ( ( ( ( R R R R t config_factoryt
queue_nameR R" R R' R@ R9 RW RS R: Rh Rv R Rp R R R RQ R R R R RT t staticmethodR ( ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR( ; s0
/ c C s8 t j j t j j t j d } t j j | d S( Ni s landscape-package-changer( R R t dirnamet abspatht syst argvR ( R ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyR | s %c C s2 t j t j k r% t j n t t | S( N( R t getpgrpt getpidt setsidR R( ( RZ ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt main s
(- R; Rj R\ R R RI RE t twisted.internet.deferR R t twisted.internetR t landscape.constantsR R R R R R R t landscape.lib.fsR
t landscape.lib.logR t landscape.package.reporterR t landscape.package.taskhandlerR
R R R t landscape.manager.managerR t! landscape.manager.shutdownmanagerR t landscape.monitor.rebootrequiredR t ExceptionR R t objectR! R( R R ( ( ( s= /usr/lib/python2.7/dist-packages/landscape/package/changer.pyt <module> s. 4" B