| 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 m Z m Z d d l m Z m Z d d l m
Z
d d l m Z m
Z
d d l m Z d d l m Z m Z d d l m Z 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 d „ Z d S( iÿÿÿÿN( t succeedt Deferred( t lock_patht LockError( t log_failure( t LSB_RELEASE_FILENAMEt parse_lsb_release( t LandscapeReactor( t
Configurationt init_logging( t PackageStoret InvalidHashIdDb( t RemoteBrokerConnectort PackageTaskErrorc B s e Z d Z RS( s6 Raised 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
s t PackageTaskHandlerConfigurationc B sY e Z d Z e d „ ƒ Z e d „ ƒ Z e d „ ƒ Z e d „ ƒ Z e d „ ƒ Z RS( s5 Specialized configuration for L{PackageTaskHandler}s.c C s t j j | j d ƒ S( s& Get the path to the package directory.t package( t ost patht joint data_path( t self( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt package_directory s c C s t j j | j d ƒ S( s8 Get the path to the SQlite file for the L{PackageStore}.t database( R R R R ( R ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt store_filename s c C s t j j | j d ƒ S( s? Get the path to the directory holding the stock hash-id stores.s hash-id( R R R R ( R ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt hash_id_directory! s c C s t j j | j d ƒ S( s& Get the path to the update-stamp file.s update-stamp( R R R R ( R ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt update_stamp_filename& s c C s t j j | j d ƒ S( sh Get the path to the stamp marking when the last time we checked for
changes in the packages was.t detect_package_changes_timestamp( R R R R ( R ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt detect_package_changes_stamp+ s ( R R R t propertyR R R R R ( ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR s t LazyRemoteBrokerc B s e Z d Z d „ Z d „ Z RS( s Wrapper 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).
c C s | | _ d | _ d S( N( t
_connectort Nonet _remote( R t connector( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt __init__C s c s/ ˆ j r t ˆ j ˆ ƒ S‡ ‡ f d † } | S( Nc s4 ‡ ‡ ‡ ‡ f d † } ˆ j j ƒ } | j | ƒ S( Nc s" | ˆ _ t ˆ j ˆ ƒ ˆ ˆ Ž S( N( R# t getattr( t remote( R t argst kwargst method( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt got_connectionN s ( R! t connectt addCallback( R( R) R+ t result( R R* ( R( R) sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt wrapperL s ( R# R& ( R R* R/ ( ( R R* sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt __getattr__G s ( R R R R% R0 ( ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR 2 s t PackageTaskHandlerc B s€ e Z e Z d Z e Z e Z d Z d „ Z
d „ Z d „ Z d d „ Z d „ Z d „ Z e d „ ƒ Z d „ Z d
„ Z RS( t defaults* /var/lib/apt/periodic/update-success-stampc C s1 | | _ | | _ | | _ | | _ d | _ d S( Ni ( t _storet _facadet _brokert _configt _count( R t
package_storet package_facadet
remote_brokert config( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR% d s
c C s
| j ƒ S( N( t handle_tasks( R ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt runk s c C s
| j d ƒ 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< n s c C sŠ | d k r( | j ƒ | j d 7_ n | j j | j ƒ } | r| | j | ƒ } | j | j d | ƒ| j | j
ƒ | St d ƒ Sd S( s@ Pick the next task from the queue and pass it to C{handle_task}.i t last_taskN( R" t removeR7 R3 t
get_next_taskt
queue_namet handle_taskR- R> t
addErrbackt _handle_task_failureR ( R R. R? t task( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR> x s
c C s | j t ƒ d S( s@ Gracefully handle a L{PackageTaskError} and stop handling tasks.N( t trapR
( R t failure( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRE s c C s
t d ƒ S( s Handle 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( R R" ( R RF ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRC ‘ s c C s | j S( sX
Return the number of tasks that have been successfully handled so far.
( R7 ( R ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt handled_tasks_countŸ s c s, ‡ f d † } ˆ j ƒ } | j | ƒ | S( sS
Attach the appropriate pre-canned hash=>id database to our store.
c sq | d k r d St j j | ƒ s& d Sy ˆ j j | ƒ Wn0 t k
rl t j d | ƒ t j | ƒ d SXd S( Ns Invalid hash=>id database %s(
R" R R t existsR3 t add_hash_id_dbR t loggingt warningR@ ( t hash_id_db_filename( R ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt use_it« s
( t _determine_hash_id_db_filenameR- ( R RO R. ( ( R sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt use_hash_id_db¦ s
c s/ ‡ f d † } ˆ j j ƒ } | 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.
c só d } | d k r' t j | d ƒ d Sy t ˆ j ƒ } Wn+ t k
rg } t j | t | ƒ ƒ d SXy | d } Wn* t k
r¢ t j | d ˆ j ƒ d SXˆ j j ƒ } | sÍ t j | d ƒ d St
j j ˆ j
j d | | | f ƒ S( Ns5 Couldn't determine which hash=>id database to use: %ss server UUID not availables code-names missing code-name key in %ss unknown dpkg architectures %s_%s_%s( R" RL RM R t lsb_release_filenamet IOErrort strt KeyErrorR4 t get_archR R R R6 R ( t server_uuidRM t lsb_release_infot errort codenamet arch( R ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt got_server_uuidÌ s*
( R5 t get_server_uuidR- ( R R\ R. ( ( R sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRP Å s
N( R R R t config_factoryRB R RR R
t package_store_classt update_notifier_stampR% R= R< R" R> RE RC R RI RQ RP ( ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyR1 X s
c
s ˆ d k r t ƒ ‰ n | j ƒ } | j | ƒ x< | j | j g D]( } t j j | ƒ sD t j | ƒ qD qD W| j
} t j j | j | d ƒ } y t | ƒ Wn6 t
k
rÛ | j rÈ t ƒ ‚ n t d | ƒ ‚ n Xt j d | j ƒ } t | d j d „ | Dƒ ƒ ƒ t j d ƒ | j | j ƒ } d d l m } | ƒ }
‡ ‡ f d † ‰ ‡ f d
† } t ˆ | d t ƒ‰ t ˆ ƒ } | | |
| | ƒ ‰ t ƒ ‰ ˆ j ‡ f d † ƒ ˆ j ‡ f d
† ƒ ˆ j | ƒ ˆ j ‡ f d † ƒ ˆ j ƒ ˆ S( Ns .locks$ error: package %s is already runnings [A-Z][a-z]+t -c s s | ] } | j ƒ Vq d S( N( t lower( t .0t word( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pys <genexpr> s i iÿÿÿÿ( t AptFacadec s! ˆ j ƒ ˆ j d ˆ j ƒ d S( Ni ( t
disconnectt
call_latert stop( ( R$ t reactor( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt finish s
c s t | ƒ ˆ ƒ d S( N( R ( RH ( Rj ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt got_error s
t retry_on_reconnectc s
ˆ j ƒ S( N( R= ( t x( t handler( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt <lambda>! s c s ˆ ƒ S( N( ( Rm ( Rj ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRo " s c s
ˆ j d ƒ S( N( t callbackR" ( ( R. ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyRo $ s (! R" R R^ t loadR R R R t isdirt mkdirRB R R R t quiett
SystemExitt ret findallR R t umaskR_ R t landscape.package.facadeRe R t TrueR R R- RD t call_when_runningR= (
t clsR( Ri R; t directoryt program_namet
lock_filenamet wordsR8 Re R9 Rk R' ( ( Ri R. R$ Rn Rj sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt run_task_handlerð sF
( R Rv RL t twisted.internet.deferR R t landscape.lib.lockR R t landscape.lib.logR t landscape.lib.lsb_releaseR R t landscape.reactorR t landscape.deploymentR R t landscape.package.storeR
R t landscape.broker.ampR t ExceptionR
R t objectR R1 R" R ( ( ( sA /usr/lib/python2.7/dist-packages/landscape/package/taskhandler.pyt <module> s &˜