| 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 @ sœ d d l m Z d d l m Z d d l 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 S( iÿÿÿÿ( t
maybeDeferred( t log_failure( t ComponentPublishert ComponentConnectort remote( t
MonitorPlugin( t UserChanges( t UserProvidert UserMonitorc B sw e Z d Z d Z d Z d Z d d „ Z d „ Z d „ Z d „ Z
e d d „ ƒ Z e Z
d d „ Z d d
„ Z RS( s<
A plugin which monitors the system user databases.
t usersi t usermonitorc C s. | d k r t ƒ } n | | _ d | _ d S( N( t NoneR t _providert
_publisher( t selft provider( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyt __init__ s c C s^ t t | ƒ j | ƒ | j d | j d ƒ t | | j j | j j ƒ | _
| j
j ƒ d S( NR ( t superR t registert call_on_acceptedt _run_detect_changesR R t registryt reactort configR
t start( R R ( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR s
c C s& | j r" | j j ƒ d | _ n d S( s, Stop listening for incoming AMP connections.N( R
t stopR ( R ( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR # s
c C s t t | ƒ j ƒ | j ƒ S( s" Resynchronize user and group data.( R R t _resynchronizeR ( R ( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR ) s c C s | j j j d | j | ƒ S( NR ( R t brokert call_if_acceptedR ( R t operation_id( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyt detect_changes. s c sÉ d d l m } | ˆ j j ˆ j j ƒ ‰ t ˆ j j d t ƒ r[ t ˆ j g ˆ ƒ } nj d „ } ‡ f d † } ˆ j ƒ } | j
| ƒ | j
| ƒ | j
ˆ j ˆ ƒ | j ‡ ‡ f d † ƒ | S( sä
If changes are detected an C{urgent-exchange} is fired to send
updates to the server immediately.
@param operation_id: When present it will be included in the
C{operation-id} field.
iÿÿÿÿ( t RemoteUserManagerConnectort monitor_onlyc S s
| j ƒ S( N( t get_locked_usernames( t user_manager( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR! G s c s ˆ j ƒ | S( N( t
disconnect( t locked_usernames( t user_manager_connector( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR# J s
c s ˆ j g ˆ ƒ S( N( t _detect_changes( t f( R R ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyt <lambda>R s ( t landscape.manager.usermanagerR R R R t getattrt FalseR R& t connectt addCallbackt
addErrback( R R R t resultR! R# ( ( R% R R sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR 5 s
c s¥ ‡ f d † } d „ } | | j _ t | j | j ƒ ‰ ˆ j ƒ } | r¡ d | d <| rh | | d <n | j j j | d t ƒ} | j | ƒ | j
| ƒ | Sd S( Nc s ˆ j ƒ | S( N( t snapshot( R/ ( t changes( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyt update_snapshotW s
c S s t | d ƒ d S( Ns5 Error occured calling send_message in _detect_changes( R ( R/ ( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyt log_error[ s R t types operation-idt urgent( R t locked_usersR t _persistt create_diffR R t send_messaget TrueR- R. ( R R6 R R2 R3 t messageR/ ( ( R1 sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR& U s
N( t __name__t
__module__t __doc__t persist_namet run_intervalt nameR R R R R R R t runR R& ( ( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR s t RemoteUserMonitorConnectorc B s e Z e Z RS( ( R< R= R t component( ( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyRC m s N( t twisted.internet.deferR t landscape.lib.logR t
landscape.ampR R R t landscape.monitor.pluginR t landscape.user.changesR t landscape.user.providerR R RC ( ( ( sA /usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyt <module> s b