| 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/monitor/ |
Upload File : |
ó
}9Rc @ sr d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d e f d „ ƒ YZ
d S( iÿÿÿÿN( t getProcessOutput( t PackageStore( t find_reporter_command( t
MonitorPlugint PackageMonitorc B sk e Z d Z d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d
„ Z
RS( i c C sD t t | ƒ j ƒ | r+ t | ƒ | _ n d | _ t ƒ | _ d S( N( t superR t __init__R t _package_storet NoneR t _reporter_command( t selft package_store_filename( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR s
c C së | j | _ | j j | _ | j j r? | j j r? d | _ n t t | ƒ j | ƒ | j s‹ t j
j | j j d ƒ } t
| ƒ | _ n | j d | j ƒ | j j d | j ƒ | j j d | j ƒ | j d | j ƒ | j ƒ d S( Ni< s package/databases package-idst
resynchronizes server-uuid-changedt packages( t configt package_monitor_intervalt run_intervalt clonest is_cloneR R t registerR t ost patht joint data_pathR t register_messaget! _enqueue_message_as_reporter_taskt reactort call_ont _resynchronizet _server_uuid_changedt call_on_acceptedt spawn_reportert run( R
t registryt filename( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR s
c C s! | j j d | ƒ | j ƒ d S( Nt reporter( R t add_taskR ( R
t message( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR , s c C s& | j j j ƒ } | j | j ƒ | S( N( R! t brokert get_accepted_message_typest addCallbackt _got_message_types( R
t result( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR 0 s c C s d | k r | j ƒ n d S( NR
( R ( R
t
message_types( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR) 5 s c sC d t f d „ ƒ Y} t ˆ d d
ƒ d
k rì d d l m } m } d d l m } | ƒ } | ƒ } | j | d ˆ j j
d ˆ j j g ƒ | | j ƒ } | | | ˆ j
j | ƒ ˆ _ t j j ˆ j j d d
ƒ ˆ j _ t ˆ _ n ˆ j rd d l m } | d
ƒ St ˆ _ ˆ j j ƒ }
‡ f d † } |
j | ƒ S( s Run a fake-reporter in-process.t
FakeFacadec B s e Z d Z d „ Z RS( s‘
A fake facade to workaround the issue that the AptFacade
essentially allows only once instance per process.
c S so t j ƒ d } i d d 6d d 6d d 6j | ƒ } | rC | } n( | d d k rk | j d ƒ rk d } n | S(
Niÿÿÿÿt i386t pentiumt i86pct amd64t x86_64i t it 86( R t unamet gett endswith( R
t archR* ( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyt get_archB s
( t __name__t
__module__t __doc__R8 ( ( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR, < s t _fake_reporteriÿÿÿÿ( t FakeReportert PackageReporterConfiguration( t FakePackageStores -ds -lt packaget database( t succeedc s
t ˆ _ | S( N( t Falset _fake_reporter_running( t passthrough( R
( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyt donee s N( t objectt getattrR t landscape.package.reporterR= R> t landscape.package.storeR? t loadR R t log_dirt store_filenameR! R& R< R R R t master_data_patht global_store_filenameRC RD t twisted.internet.deferRB t TrueR t addBoth( R
t argsR, R= R> R? t package_facadet package_configt
package_storeRB R* RF ( ( R
sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyt _run_fake_reporter9 s,
c
C s³ d g } | j j r1 | j d | j j g ƒ n t j j ƒ } | j j d k rx | j j rk | j | ƒ Sd | d <n t | j d | d | d d d
d ƒ} | j | j ƒ | S( Ns --quiets -ci t 1t FAKE_GLOBAL_PACKAGE_STORERS t envt errortooi R (
R t extendR t environt copyR R RW R R R R( t _got_reporter_output( R
RS RZ R* ( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR k s
c C s | r t j d | ƒ n d S( Ns Package reporter output:
%s( t loggingt warning( R
t output( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR_ € s c C s6 | j j d i d d 6ƒ } | j j d | f ƒ d S( s:
Remove all tasks *except* the resynchronize task. This is
because if we clear all tasks, then add the resynchronize,
it's possible that the reporter may be running a task at this
time and when it finishes, it will unknowningly remove the
resynchronize task because sqlite resets its serial primary
keys when you delete an entire table. This problem is avoided
by adding the task first and removing them all *except* the
resynchronize task and not causing sqlite to reset the serial
key.
R# R t typet except_tasksN( R R$ t clear_tasks( R
t task( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR „ s c C s | d k r | j j ƒ n d S( sµ Called when the broker sends a server-uuid-changed event.
The package hash=>id map is server-specific, so when we change
servers, we should reset this map.
N( R R t clear_hash_ids( R
t old_uuidt new_uuid( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR ” s N( R9 R: R R R R R R R) RW R R_ R R ( ( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR s 2 ( R` R t twisted.internet.utilsR RJ R RI R t landscape.monitor.pluginR R ( ( ( sD /usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyt <module> s