ó ½-'Nc@srddlZddlZddlmZddlmZddlmZddlm Z de fd„ƒYZ dS(iÿÿÿÿN(tgetProcessOutput(t PackageStore(tfind_reporter_command(t MonitorPlugintPackageMonitorcBsbeZdZd d„Zd„Zd„Zd„Zd„Zd„Z d„Z d„Z d „Z RS( icCsDtt|ƒjƒ|r+t|ƒ|_n d|_tƒ|_dS(N(tsuperRt__init__Rt_package_storetNoneRt_reporter_command(tselftpackage_store_filename((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyRs  cCs¸|j|_tt|ƒj|ƒ|jsXtjj|jjdƒ}t |ƒ|_n|j d|j ƒ|j j d|jƒ|j j d|jƒ|jd|jƒ|jƒdS(Nspackage/databases package-idst resynchronizesserver-uuid-changedtpackages(tconfigRRtregisterRtostpathtjoint data_pathRtregister_messaget!_enqueue_message_as_reporter_tasktreactortcall_ont_resynchronizet_server_uuid_changedtcall_on_acceptedtspawn_reportertrun(R tregistrytfilename((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyRs       cCs!|jjd|ƒ|jƒdS(Ntreporter(Rtadd_taskR(R tmessage((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR(scCs&|jjjƒ}|j|jƒ|S(N(Rtbrokertget_accepted_message_typest addCallbackt_got_message_types(R tresult((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR,scCsd|kr|jƒndS(NR (R(R t message_types((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR%1s c Csodg}|jjr1|jd|jjgƒnt|jd|dtjddddƒ}|j|jƒ|S(Ns--quiets-ctargstenvterrortooiR( RtextendRR RtenvironRR$t_got_reporter_output(R R(R&((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR5s    cCs|rtjd|ƒndS(NsPackage reporter output: %s(tloggingtwarning(R toutput((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR-CscCs6|jjdidd6ƒ}|jjd|fƒdS(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. RR ttypet except_tasksN(RR t clear_tasks(R ttask((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyRGs cCs |dk r|jjƒndS(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(RRtclear_hash_ids(R told_uuidtnew_uuid((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyRWs N( t__name__t __module__t run_intervalRRRRRR%RR-RR(((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyR s        ( R.Rttwisted.internet.utilsRtlandscape.package.storeRtlandscape.package.reporterRtlandscape.monitor.pluginRR(((sD/usr/lib/python2.7/dist-packages/landscape/monitor/packagemonitor.pyts