ó ½-'Nc@súddlZddlmZddlmZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZd e fd „ƒYZd efd „ƒYZd e fd„ƒYZdefd„ƒYZde fd„ƒYZdS(iÿÿÿÿN(t maybeDeferred(t log_failure(t RemoteObject(tComponentProtocoltComponentProtocolFactorytRemoteComponentConnector(t MonitorPlugin(t UserChanges(t UserProvidert UserMonitorcBsqeZdZdZdZdZd d„Zd„Zd„Z d„Z d d„Z e Z d d „Z d d „ZRS( s< A plugin which monitors the system user databases. tusersit usermonitorcCs.|dkrtƒ}n||_d|_dS(N(tNoneRt _providert_port(tselftprovider((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyt__init__s   cCstt|ƒj|ƒ|jd|jdƒtd|ƒ}tjj |j j j |j dƒ}|j jj||ƒ|_dS(NR tobjects.sock(tsuperR tregistertcall_on_acceptedt_run_detect_changesR tUserMonitorProtocolFactorytostpathtjointregistrytconfigt sockets_pathtnametreactort listen_unixR(RRtfactorytsocket((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyRs cCs&|jr"|jjƒd|_ndS(s,Stop listening for incoming AMP connections.N(Rt stopListeningR (R((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pytstop(s  cCstt|ƒjƒ|jƒS(s"Resynchronize user and group data.(RR t_resynchronizeR(R((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR%.scCs|jjjd|j|ƒS(NR (Rtbrokertcall_if_acceptedR(Rt operation_id((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pytrun3s csÉddlm}|ˆjjˆjjƒ‰tˆjjdtƒr[tˆjgˆƒ}njd„}‡fd†}ˆj ƒ}|j |ƒ|j |ƒ|j ˆjˆƒ|j ‡‡fd†ƒ|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ÿÿÿÿ(tRemoteUserManagerConnectort monitor_onlycSs |jƒS(N(tget_locked_usernames(t user_manager((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR,Kscsˆjƒ|S(N(t disconnect(tlocked_usernames(tuser_manager_connector(sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR.Ns csˆjgˆƒS(N(t_detect_changes(tf(R(R(sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pytVs( tlandscape.manager.usermanagerR*RRRtgetattrtFalseRR1tconnectt addCallbackt addErrback(RR(R*tresultR,R.((R0RR(sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR9s     cs¥‡fd†}d„}||j_t|j|jƒ‰ˆjƒ}|r¡d|d<|rh||dtmessageR:((R<sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR1Ys       N(t__name__t __module__t__doc__t persist_namet run_intervalRR RRR$R%R)tdetect_changesRR1(((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyR s     tUserMonitorProtocolcBseZdZdgZRS(sDL{AMP}-based protocol for calling L{UserMonitor}'s methods remotely.RL(RGRHRItmethods(((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyRMqsRcBseZeZRS((RGRHRMtprotocol(((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyRwstRemoteUserMonitorcBseZdZRS(s"A connected remote L{UserMonitor}.(RGRHRI(((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyRP|stRemoteUserMonitorConnectorcBseZeZeZeZRS((RGRHRR!RPtremoteR t component(((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyRQ€s(Rttwisted.internet.deferRtlandscape.lib.logRtlandscape.lib.ampRt landscape.ampRRRtlandscape.monitor.pluginRtlandscape.user.changesRtlandscape.user.providerRR RMRRPRQ(((sA/usr/lib/python2.7/dist-packages/landscape/monitor/usermonitor.pyts b