ó ÍÿŠTc@s»ddlZddlZddlZddlmZddlmZddlmZddl m Z y#ddl m Z e e dƒZWnek r eZnXde fd „ƒYZdS( iÿÿÿÿN(tthreads(t Accumulator(tCoverageMonitor(t MonitorPlugin(tRadostget_cluster_statst CephUsagecBsƒeZdZdZdZdZddejd„Zd„Z d„Z e d„Z e d „Z d „Zd „Zd „Zd „ZRS(s Plugin that captures Ceph usage information. This only works if the client runs on one of the Ceph monitor nodes, and noops otherwise. The plugin requires the 'python-ceph' package to be installed, which is the case on a standard "ceph" charm deployment. The landscape-client charm should join a ceph-client relation with the ceph charm, which will crete a keyring and config file for the landscape-client to consume in /ceph-client/ceph.landscape-client.conf. It contains the following: [global] auth supported = cephx keyring = mon host = :6789 The configured keyring can be generated with: ceph-authtool --create-keyring --name=client.landscape-client --add-key= s ceph-usagetstorageii<cCsLt|_t|_||_||_g|_d|_||_ d|_ dS(N( tTruetactivet has_radost _has_radost _intervalt_monitor_intervalt_ceph_usage_pointstNonet _ceph_ring_idt _create_timet _ceph_config(tselftintervaltmonitor_intervalt create_time((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyt__init__/s       cCsêtt|ƒj|ƒtjj|jjjddƒ|_ t |j |j ƒ|_ t|j ddd|jƒ|_|jjj|j |jƒ|jjj|j|jjƒ|jjjd|jjddƒ|jd |jtƒdS( Ns ceph-clientsceph.landscape-client.confgš™™™™™é?sCeph usage snapshotRtstoptpriorityiÐs ceph-usage(tsuperRtregistertostpathtjointregistrytconfigt data_pathRRt_persistR t _accumulateRRt_monitortreactort call_everytrunR tlogtcall_ontcall_on_acceptedt send_messageR(RR((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyR:s   "cCs;|j}|j}g|_idd6|d6gd6|d6S(Ns ceph-usagettypesring-ids ceph-usagess data-points(RR(Rt ceph_pointstring_id((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pytcreate_messageKs    cCsF|jƒ}|drB|drB|jjj||jd|ƒndS(Nsring-ids data-pointsturgent(R/RtbrokerR+t _session_id(RR0tmessage((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyR+Ts  cCs |jjjd|j|ƒdS(Ns ceph-usage(RR1tcall_if_acceptedR+(RR0((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pytexchangeZs cCsC|jƒsdS|jjƒtj|jƒ}|j|jƒ|S(N(t _should_runR$tpingRt deferToThreadt_perform_rados_callt addCallbackt _handle_usage(Rtdeferred((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyR'^s   cCs]|js tS|js0tjdƒt|_tS|jdksUtjj |jƒ rYtSt S(s.Returns whether or not this plugin should run.sGThis machine does not appear to be a Ceph machine. Deactivating plugin.N( R tFalseR tloggingtinfoRRRRtexistsR(R((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyR6gs    %cCsatd|jddƒC}|jƒ}|jdkrWt|jƒdƒ}||_nWdQX|S(sThe actual Rados interaction.tconffiletrados_idslandscape-clientsutf-8N(RRRRRtunicodetget_fsid(Rtclustert cluster_statstfsid((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyR9ys  c CsÀd d dg}t|jƒƒ}g}xH|D]@\}}||d}|j||d|ƒ}|j|ƒq.Wt|ƒs‚d S|d g} | jd „|Dƒƒ|jjt| ƒƒd S(s†A method to use as callback to the rados interaction. Parses the output and stores the usage data in an accumulator. ttotaltkbtavailtkb_availtusedtkb_usedisusage.%sNicss|]}t|dƒVqdS(iN(tint(t.0t step_value((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pys ˜s(RHRI(RJRK(RLRM(RNRR#tappendtalltextendRttuple( RRFt names_mapt timestampt step_valuestnametkeytvalueRPtpoint((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyR;…s  Ni(t__name__t __module__t__doc__t persist_nametscopeRt run_intervalttimeRRR/R=R+R5R'R6R9R;(((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyRs     (R>RbRttwisted.internetRtlandscape.accumulateRtlandscape.lib.monitorRtlandscape.monitor.pluginRtradosRthasattrR t ImportErrorR=R(((s?/usr/lib/python2.7/dist-packages/landscape/monitor/cephusage.pyts