....................................../////.===Shadow-Here===./////................................................ > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < > < ------------------------------------------------------------------------------------------------------------------- /////////////////////////////////////////////////////////////////////////////////////////////////////////////////// RIFF¤ WEBPVP8 ˜ ðÑ *ôô>‘HŸK¥¤"§£±¨àð enü¹%½_F‘åè¿2ºQú³íªú`N¿­3ÿƒügµJžaÿ¯ÿ°~¼ÎùnúîÞÖô•òíôÁÉß®Sm¥Ü/ ‡ó˜f£Ùà<˜„xëJ¢Ù€SO3x<ªÔ©4¿+ç¶A`q@Ì“Úñè™ÍÿJÌ´ª-˜ÆtÊÛL]Ïq*‘Ý”ì#ŸÌÏãY]@ê`¿ /ªfkØB4·®£ó z—Üw¥Pxù–ÞLШKÇN¾AkÙTf½è'‰g gÆv›Øuh~ a˜Z— ïj*á¥t d£“uÒ ¨`K˜¹ßþ]b>˜]_ÏÔ6W—è2r4x•íÖ…"ƒÖNîä!¦å Ú}ýxGøÌ —@ ;ÆÚŠ=ɾ1ý8lªË¥ô ^yf®Œ¢u&2©nÙÇ›ñÂñŒ³ aPo['½»øFùà­+4ê“$!lövlüÞ=;N®3ð‚õ›DÉKòÞ>ÄÍ ¥ˆuߤ#ˆ$6ù™¥îŠ‡y’ÍB¼ çxÛ;X"WL£R÷͝*ó-¶Zu}º.s¸sšXqù–DþÿvªhüïwyŸ ¯é³lÀ:KCûÄ£Ëá\…­ ~—ýóî ¼ûûÜTÓüÇy…ŽÆvc»¾×U ñ¸žþоP÷¦ó:Ò¨¨5;Ð#&#ÖúñläÿÁœ GxÉ­/ñ‡áQðìYÉtÒwŽ¼GÔ´zàÒò ð*ëzƒ•4~H]Ø‹f ñÓÈñ`NåWçs'ÆÏW^ø¹!XžµmQ5ÃËoLœÎ: ÞËÍ¥J ù…î èo£ßPÎñ¶ž8.Œ]ʵ~5›ÙË-ù*8ÙÖß±~ ©¹rÓê‚j¶d¸{^Q'˜±Crß ÚH—#¥¥QlÀ×ëã‡DÜ«èî þ&Çæžî;ŽÏºò6ÒLÃXy&ZŒ'j‚¢Ù€IßÚù+–MGi‰*jE€‘JcÜ ÓÌ EÏÚj]o˜ Þr <¾U ûŪæÍ/šÝH¥˜b”¼ ÁñßX GP›ï2›4WŠÏà×£…íÓk†¦H·ÅíMh–*nó÷à]ÁjCº€b7<ب‹¨5車bp2:Á[UªM„QŒçiNMa#<5›áËó¸HýÊ"…×Éw¹¦ì2º–x<›»a±¸3Weü®FÝ⑱ö–î–³|LPÈ~çð~Çå‡|º kD¢µÏàÆAI %1À% ¹Ò – ”ϝS¦‰4&¶£°à Öý”û_Ò Áw°A«Å€?mÇÛgHÉ/8)á¾ÛìáöŽP í¨PŸNÙµº¦‡§Ùš"ÿ«>+ªÕ`Ê÷‡‚ß Õû˜þãÇ-PÍ.¾XV‘€ dÜ"þ4¹ ±Oú‘©t¥¦FªÄÃÄ•b‚znýu½—#cDs˜ÃiÑOˆñ×QO=*IAÊ,¶ŽZƒ;‡wøXè%EÐk:F±Ú” .Ѽ+Áu&Ç`."pÈÉw o&¿dE6‘’EqTuK@Ì¥ã™À(Êk(h‰,H}RÀIXÛš3µ1©_OqÚÒJAñ$ÊÙÜ;D3çŒ[þùœh¬Ã³™ö6ç†NY".Ú‰ï[ªŸŒ '²Ð öø_¨ÂÉ9u鶳ÒŠõTàîMØ#û¯gN‡bÙ놚X„ö …ÉeüÌ^J ‹€.œ$Æ)βÄeæW#óüßĺŸ€ ÀzwV 9oä»f4V*uB «Ë†¹ì¯žR霓æHXa=&“I4K;¯ç‹h×·"UŠ~<•â•ªVêª&ÍSÃÆÅ?ÔqÎ*mTM ˜›µwêd#[C¡©§‘D<©àb†–ÁœøvH/,í:¯( ²£|4-„Æövv„Yͼ™^Á$ˆ„¢Û[6yB.åH*V¨æ?$=˜Ñ€•î¦ñ·­(VlŸ‘ nÀt8W÷´Bûba?q9ú¶Xƒl«ÿ\ù¶’þòUÐj/õ¢Ìµ³g$ƒÎR!¸»|Oߍë’BhîÚÑ¢ñåŒJ„®„£2Ð3•ô02Nt…!£Í]Ïc½Qÿ?ˆ<&ÃA¾Ú,JˆijÌ#5yz„‰Î|ÊŽ5QÏ:‹ÐaóVÔxW—CpeÏzÐïíçôÿÅ_[hãsÐ_/ŽTÝ?BîˆííV$<¿i>²F¬_Eß¿ †bÊŒº­ÿ®Z H“C}”¬,Mp ý/Bá£w>˜YV°aƒúh+cŠ- r/[%|üUMHäQ°X»|û/@|°¥Ð !BÔ Ç¢Ä©š+Õì D«7ìN¶ŽðÔ " ƶ’ÖçtA‰Û×}{tþz­¾GÍ›k¹OEJR$ Â׃ «ëÁ"oÉôž$oUK(Ä)Ãz³Ê-‹êN[Ò3Œñbï8P 4ƒ×q¢bo|?<ÛX¬òÄÍ°L–±›(™ûG?ýË©ÚÄ–ÂDØÐ_Ç¡ô ¾–ÄÏø ×e8Ë©$ÄF¹Å‹ì[©óìl:F¾f´‹‹Xì²ï®\¬ôùƒ ÿat¥óèÒùHß0äe‚;ü×h:ÆWðHž=Ã8骣"kœ'Y?³}Tûè€>?0l›e1Lòñ„aæKÆw…hÖŠùW…ÈÆÄ0ši·›[pcwËþñiêíY/~-Á5˜!¿†A›™Mÿþ(±“t@â“ö2­´TG5yé]çå僳 .·ÍïçÝ7UÚ±Ð/Nè»,_Ï ùdj7\ï Wì4›„»c¸àešg#ÒÊ⥭áØo5‘?ÌdÝô¯ ¹kzsƒ=´#ëÉK›Ø´±-¥eW?‡çßtòTã…$Ý+qÿ±ƒ÷_3Ô¥í÷:æ–ž<·Ö‡‰Å¢ š‡%Ô—utÌÈìðžgÖÀz²À—ï÷Óîäõ{K'´È÷³yaÏÁjƒô}ž§®æÊydÕÈë5¯èˆõvÕ©ã*çD„ “z„Ó‡^^xÂ3M§A´JG‚öï 3W'ˆ.OvXè¡ÊÕª?5º7†˜(˜Ç¶#çê’¶!ÌdZK§æ 0fãaN]òY³RV ™î$®K2R¨`W!1Ôó\;Ý ýB%qæK•&ÓÈe9È0êI±žeŸß -ú@žQr¦ ö4»M¼Áè¹µmw 9 EÆE_°2ó„ŸXKWÁ×Hóì^´²GѝF©óäR†¦‰ç"V»eØ<3ùd3ÿÚ¤Žú“Gi" —‘_ÙËÎ~Üö¯¥½Î»üŸEÚŽåmÞþí ;ÞólËΦMzA"Âf(´òá;Éï(/7½ûñÌ­cïÕçлþÝz¾-ÍvÑ“pH­–ðÓj$¸Äû¤‚‘ãUBË-n“2åPkS5&‹Â|+g^œ®Ì͆d!OïäîU«c;{Û!ÅŽ«ëZ9Ókóˆ]¯ƒ›né `ÇÒ+tÆš (ØKá¾—=3œ®•vuMñg²\ï Ec€ 05±d™‡×iÇ×›UúvÌ¢£Èþ¡ÕØô¶ßÎA"ß±#Ö²ˆÊŸ¦*Ä~ij|àø.-¼'»Ú¥£h ofº¦‡VsR=N½„Î v˜Z*SÌ{=jÑB‹tê…;’HžH¯8–îDù8ñ¢|Q•bÛçš–‹m³“ê¨ åÏ^m¬Žãþ©ïêO‡½6] µÆ„Ooòü ²x}N¦Ë3ïé¿»€›HA˜m%çÞ/¿í7Fø“‹léUk)É°Œµ8Q8›:ÀŠeT*šõ~ôڝG6 ¢}`ùH­–”¡k ‰P1>š†®9z11!X wKfmÁ¦xÑ,N1Q”–æB¶M…ÒÃv6SMˆhU¬ÊPŽï‘öj=·CŒ¯u¹ƒVIЃsx4’ömÛýc塶7ßŠß 57^\wÒÐÆ k§h,Œý î«q^R½3]J¸ÇðN ‚çU¬ôº^Áì} ³f©Õœ§ˆã:FÄÈ‚é(€™?àýÓüè1Gô£¼éj‚OÅñ  #>×—ßtà 0G¥Åa뀐kßhc™À_ÉñÞ#±)GD" YîäË-ÿÙ̪ ¹™a¯´¢E\ÝÒö‚;™„ë]_ p8‰o¡ñ+^÷ 3‘'dT4œŽ ðVë½° :¬víÑ«£tßÚS-3¶“þ2 †üüʨòrš¹M{É_¤`Û¨0ìjœøJ‡:÷ÃáZ˜†@GP&œÑDGÏs¡þ¦þDGú‘1Yá9Ôþ¼ ûø…§÷8&–ÜÑnÄ_m®^üÆ`;ÉVÁJ£?â€-ßê}suÍ2sõA NÌúA磸‘îÿÚ»ƒìö·á¿±tÑÐ"Tÿü˜[@/äj¬€uüªìù¥Ý˜á8Ý´sõj 8@rˆð äþZÇD®ÿUÏ2ùôõrBzÆÏÞž>Ì™xœ“ wiÎ×7_… ¸ \#€MɁV¶¥üÕÿPÔ9Z‡ø§É8#H:ƒ5ÀÝå9ÍIŒ5åKÙŠ÷qÄ>1AÈøžj"µÂд/ªnÀ qªã}"iŸBå˜ÓÛŽ¦…&ݧ;G@—³b¯“•"´4í¨ôM¨åñC‹ïùÉó¯ÓsSH2Ý@ßáM‡ˆKÀªÛUeø/4\gnm¥‹ŸŒ qÄ b9ÞwÒNÏ_4Ég³ú=܆‚´ •â¥õeíþkjz>éÚyU«Íӝ݃6"8/ø{=Ô¢»G¥ äUw°W«,ô—¿ãㆅү¢³xŠUû™yŒ (øSópÐ 9\åTâ»—*oG$/×ÍT†Y¿1¤Þ¢_‡ ¼ „±ÍçèSaÓ 3ÛMÁBkxs‰’R/¡¤ˆÙçª(*õ„üXÌ´ƒ E§´¬EF"Ù”R/ÐNyÆÂ^°?™6¡œïJ·±$§?º>ÖüœcNÌù¯G ‹ñ2ŠBB„^·úìaz¨k:#¨Æ¨8LÎõލ£^§S&cŒÐU€ü(‡F±Š¼&P>8ÙÁ ‰ p5?0ÊƃZl¸aô š¼¡}gÿ¶zÆC²¹¬ÎÖG*HB¡O<º2#ñŒAƒ–¡B˜´É$¥›É:FÀÔx¾u?XÜÏÓvN©RS{2ʈãk9rmP¼Qq̳ è¼ÐFׄ^¡Öì fE“F4A…!ì/…¦Lƒ… … $%´¾yã@CI¬ á—3PþBÏNÿ<ý°4Ü ËÃ#ØÍ~âW«rEñw‹eùMMHß²`¬Öó½íf³:‹k˜¯÷}Z!ã¿<¥,\#öµÀ¯aÒNÆIé,Ћ–lŽ#Àæ9ÀÒS·I’½-Ïp Äz¤Š Â* ­íÄ9­< h>׍3ZkËU¹§˜ŒŠ±f­’¤º³Q ÏB?‹#µíÃ¥®@(Gs«†vI¥Mµ‹Á©e~2ú³ÁP4ìÕi‚²Ê^ö@-DþÓàlÜOÍ]n"µã:žpsŽ¢:! Aõ.ç~ÓBûH÷JCÌ]õVƒd «ú´QÙEA–¯¯Œ!.ˆˆëQ±ù œ·Ì!Õâ )ùL„ÅÀlÚè5@B…o´Æ¸XÓ&Û…O«˜”_#‡ƒ„ûÈt!¤ÁÏ›ÎÝŠ?c9 â\>lÓÁVÄÑ™£eØY]:fÝ–—ù+p{™ðè û³”g±OƒÚSù£áÁÊ„ä,ï7š²G ÕÌBk)~ÑiCµ|h#u¤¶îK¨² #²vݯGãeÖ϶ú…¾múÀ¶þÔñ‚Š9'^($¤§ò “š½{éúp÷J›ušS¹áªCÂubÃH9™D™/ZöØÁ‡¦ÝÙŸ·kð*_”.C‹{áXó€‡c¡c€§/šò/&éš÷,àéJþ‰X›fµ“C¨œ®r¬"kL‰Â_q…Z–.ÉL~O µ›zn‚¹À¦Öª7\àHµšÖ %»ÇníV[¥*Õ;ƒ#½¾HK-ÖIÊdÏEÚ#=o÷Óò³´Š: Ç?{¾+9›–‘OEáU·S€˜j"ÄaÜ ŒÛWt› á–c#a»pÔZÞdŽtWê=9éöÊ¢µ~ ë ;Öe‡Œ®:bî3±ýê¢wà¼îpêñ¹¾4 zc¾ðÖÿzdêŒÑÒŝÀ‰s6¤í³ÎÙB¿OZ”+F¤á‡3@Ñëäg©·Ž ˆèª<ù@É{&S„œÕúÀA)‰h:YÀ5^ÂÓŒ°õäU\ ùËÍû#²?Xe¬tu‰^zÒÔãë¼ÛWtEtû …‚g¶Úüâî*moGè¨7%u!]PhÏd™Ý%Îx: VÒ¦ôÊD3ÀŽKÛËãvÆî…N¯ä>Eró–ð`5 Œ%u5XkñÌ*NU%¶áœÊ:Qÿú»“úzyÏ6å-၇¾ ´ ÒÊ]y žO‘w2Äøæ…H’²f±ÎÇ.ª|¥'gîV•Ü .̘¯€šòü¤U~Ù†*¢!?ò wý,}´°ÔÞnïoKq5µb!áÓ3"vAßH¡³¡·G(ÐÎ0Îò¼MG!/ài®@—¬04*`…«é8ªøøló“ˆÊ”èù¤…ßÊoÿé'ËuÌÖ5×È¡§ˆˆfŽë9}hìâ_!!¯  B&Ëö¶‰ÀAÙNVŸ Wh›¸®XÑJì¨ú“¿÷3uj²˜¨ÍÎìë±aúŠÝå¯ð*Ó¨ôJ“yºØ)m°WýOè68†ŸÏ2—‰Ïüꪫٚ¥‹l1 ø ÏÄFjêµvÌbü¦èÝx:X±¢H=MÐß—,ˆÉÇ´(9ú¾^ÅÚ4¿m‡$âX‘å%(AlZo@½¨UOÌÕ”1ø¸jÎÀÃÃ_ µ‘Ü.œº¦Ut: Æï’!=¯uwû#,“pþÇúŒø(é@?³ü¥‘Mo §—s@Œ#)§ŒùkL}NOÆêA›¸~r½¼ÙA—HJ«eˆÖ´*¡ÓpÌŸö.m<-"³ûÈ$¬_6­åf£ïÚâj1y§ÕJ½@dÞÁr&Í\Z%D£Íñ·AZ Û³øüd/ªAi†/Й~  ‡âĮҮÏh§°b—›Û«mJžòG'[ÈYýŒ¦9psl ýÁ ®±f¦x,‰½tN ‚Xª9 ÙÖH.«Lo0×?͹m¡å†Ѽ+›2ƒF ±Ê8 7Hցϓ²Æ–m9…òŸï]Â1äN†VLâCˆU .ÿ‰Ts +ÅÎx(%¦u]6AF Š ØF鈄‘ |¢¶c±soŒ/t[a¾–û:s·`i햍ê›ËchÈ…8ßÀUÜewŒðNOƒõD%q#éû\9¤x¹&UE×G¥ Í—™$ð E6-‡¼!ýpãÔM˜ Âsìe¯ñµK¢Ç¡ùôléœ4Ö£”À Š®Ðc ^¨À}ÙËŸ§›ºê{ÊuÉC ×Sr€¤’fÉ*j!úÓ’Gsùìoîßîn%ò· àc Wp÷$¨˜)û»H ×8ŽÒ€Zj¤3ÀÙºY'Ql¦py{-6íÔCeiØp‘‡XÊîÆUߢ܂ž£Xé¼Y8þ©ëgñß}é.ÎógÒ„ÃØËø¯»™§Xýy M%@NŠ À(~áÐvu7&•,Ù˜ó€uP‡^^®=_E„jt’ 403WebShell
403Webshell
Server IP : 107.180.102.13  /  Your IP : 216.73.216.161
Web Server : Apache
System : Linux ip-107-180-102-13.ip.secureserver.net 3.10.0-1160.119.1.el7.tuxcare.els25.x86_64 #1 SMP Wed Oct 1 17:37:27 UTC 2025 x86_64
User : nobody ( 99)
PHP Version : 7.3.33
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : ON  |  Sudo : ON  |  Pkexec : ON
Directory :  /lib/fm-agent/plugins/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /lib/fm-agent/plugins/disk.py
import agent_util
import sys
import os
import platform
from agent_util import float

import json

NETWORK_FS = ["ncpfs", "nfs", "ntfs", "smb", "vfat", "smb2", "cifs", "nfs4"]

# Timeout after 10 seconds, so we don't get hung on remote filesystems
TIMEOUT_LIMIT = 10


def get_findmnt_cmd(extra_args=""):
    timeout = ""
    if agent_util.which("timeout"):
        timeout = "timeout %s " % TIMEOUT_LIMIT
    return "%sfindmnt --fstab --df --bytes --raw --evaluate --all %s" % (
        timeout,
        extra_args,
    )


def get_df_cmd(extra_arg=""):
    timeout = ""
    if agent_util.which("timeout"):
        timeout = "timeout %s " % TIMEOUT_LIMIT

    df_cmd = "df -PkT"
    if "vmware" in sys.platform:
        df_cmd = "df -kT"
    elif "sunos" in sys.platform:
        df_cmd = "df -kt"
    elif "darwin" in sys.platform or "aix" in sys.platform or "freebsd" in sys.platform:
        df_cmd = "df -Pk"

    return "%s%s %s" % (timeout, df_cmd, extra_arg)


def get_idf_cmd(extra_arg=""):
    timeout = ""
    if agent_util.which("timeout"):
        timeout = "timeout %s " % TIMEOUT_LIMIT

    idf_cmd = "df -iPT"
    if "sunos" in sys.platform or "vmware" in sys.platform:
        idf_cmd = "df -iT"
    elif "aix" == sys.platform:
        idf_cmd = "df -ik"
    elif "darwin" == sys.platform or "freebsd" in sys.platform:
        idf_cmd = "df -Pik"

    return "%s%s %s" % (timeout, idf_cmd, extra_arg)


class DiskDFParser:
    def __init__(self, log, config):
        self.log = log
        self.device_ignore_list = (
            "tmpfs",
            "devtmpfs",
            "none",
            "proc",
            "swap",
            "devices",
            "cgroup",
            "/dev/loop",
        )
        self.mountpoint_excludes = ()

        cfg_device_list = config.get("device_ignore_list", None)
        if cfg_device_list is not None:
            self.device_ignore_list = self.parse_ignore_list(cfg_device_list)

        if "aix" in sys.platform or "sunos" in sys.platform:
            self.device_ignore_list = self.device_ignore_list + (
                "/proc",
                "/swap",
                "/ahafs",
            )

        if "darwin" == sys.platform:
            self.mountpoint_excludes = ("/Library/Developer/CoreSimulator/Volumes",)
            mpe = config.get("mountpoint_excludes", None)
            if mpe is not None:
                self.mountpoint_excludes = self.parse_ignore_list(mpe)

    def __str__(self):
        return "Disk df parser"

    def parse_ignore_list(self, device_list):
        try:
            dl_type = type(device_list)
            if type(tuple) == dl_type:
                return device_list
            if type("") == dl_type:
                if "(" in device_list and ")" in device_list:
                    device_list_items = (
                        device_list.replace("(", "").replace(")", "").split(",")
                    )
                    items = [d.strip().strip('"') for d in device_list_items]
                    return tuple(items)
        except:
            self.log.error("Error parsing device list {}".format(device_list))

        return ()

    def parse_df_output(self, output):
        outlines = output.splitlines()

        headers = self.build_header_data(outlines[0])
        df_table = {}
        for df_line in outlines[1:]:
            df_line = df_line.strip().split()
            mount_point = None
            mount_point_idx = headers.get("mounted on", None)
            if mount_point_idx:
                mount_point = " ".join(df_line[mount_point_idx:])
            if not mount_point:
                self.log.warning("No mount point in {}".format(df_line))
                continue
            df_table[mount_point] = {}
            for entry in headers.keys():
                val = df_line[headers[entry]]
                if "mounted on" == entry:
                    val = mount_point

                df_table[mount_point][entry] = val

        return df_table

    def build_header_data(self, header_line):
        hdr_idx = 0
        headers = {}
        for hdr in header_line.split():
            #
            # For lines that end with 'Mounted on' - skip the last split
            #
            hdr = hdr.lower()

            if "on" == hdr:
                continue
            if "mounted" == hdr:
                hdr = "mounted on"
            if hdr in ["iuse%", "%iused"]:
                hdr = "iuse_pct"
            elif hdr in ["available", "avail"]:
                hdr = "available"
            headers[hdr] = hdr_idx
            hdr_idx += 1

        return headers

    def get_device_data(self, output, key_map, custom_network_fs):
        df_table = self.parse_df_output(output)
        devices = []
        max_disk = {}
        for mountpoint_table in df_table.values():
            try:
                device_key = key_map.get("device")
                device = mountpoint_table[device_key]
                fs_type_key = key_map.get("fs_type")
                filesystem = mountpoint_table.get(fs_type_key, "")
                skip_device = False
                for test_device in self.device_ignore_list:
                    if device.startswith(test_device) or filesystem.startswith(
                        test_device
                    ):
                        self.log.debug("Skipping metadata for device %s" % device)
                        skip_device = True
                        break
                if skip_device:
                    continue

                mounted_key = key_map.get("mountpoint")
                mounted = mountpoint_table.get(mounted_key, None)
                if not mounted:
                    continue

                skip_mp = False
                for mp in self.mountpoint_excludes:
                    if mounted.startswith(mp):
                        self.log.debug("Skipping mountpoint {}".format(mounted))
                        skip_mp = True
                        break
                if skip_mp:
                    continue

                desc = "%s mounted at %s" % (device, mounted)
                devices.append(
                    {
                        "device": device,
                        "mountpoint": mounted,
                        "filesystem": filesystem,
                        "resource": desc,
                        "is_network": filesystem in NETWORK_FS
                        or filesystem in custom_network_fs,
                    }
                )
                available_key = key_map.get("available")
                available = mountpoint_table.get(available_key, None)
                if available is not None:
                    max_disk[desc] = available
            except:
                self.log.error("Unable to parse df output")
                continue

        return devices, max_disk


class DiskUsagePlugin(agent_util.Plugin):
    textkey = "disk"
    label = "Disk"
    darwin_fstype_excludes = "nullfs,nodev,devfs,autofs"

    # adding min for disk usage
    min_capacity = 0

    if "AIX" in os.uname():
        sys.platform = "aix"

    @classmethod
    def dump_disk_output(self, config, cmd, raw_output):
        if config.get("debug", False):
            self.log.debug("#####################################################")
            self.log.debug("Disk command '%s' output :" % cmd)
            self.log.debug(raw_output)
            self.log.debug("#####################################################")

    @classmethod
    def get_metadata(self, config):
        status = agent_util.SUPPORTED
        msg = None

        if not agent_util.which("df", exc=False):
            self.log.warning("df binary not found")
            status = agent_util.UNSUPPORTED

        if agent_util.SUPPORTED != status:
            return {}

        # See if there are custom DF flags specified in the config file
        extra_df_arg = self.gather_extra_df_arg(config=config)

        # See if the config file specifies to use findmnt to identify expected disks
        use_findmnt = config.get("use_findmnt") and agent_util.which("findmnt")
        extra_findmnt_arg = config.get("extra_findmnt_arg", "")

        custom_network_fs = config.get("network_fs", [])
        if custom_network_fs:
            custom_network_fs = custom_network_fs.split(",")

        table_keys = {
            "device": "filesystem",
            "fs_type": "type",
            "mountpoint": "mounted on",
            "available": "available",
        }

        if use_findmnt:
            table_keys = {
                "device": "source",
                "fs_type": "fstype",
                "mountpoint": "target",
                "available": "avail",
            }
            block_query = get_findmnt_cmd(extra_findmnt_arg)
            inode_query = block_query
        else:
            block_query = get_df_cmd(extra_df_arg)
            inode_query = get_idf_cmd(extra_df_arg)

        parser = DiskDFParser(self.log, config)
        ret_code, block_result = agent_util.execute_command(
            block_query, cache_timeout=agent_util.DEFAULT_CACHE_TIMEOUT
        )
        if 0 != ret_code:
            devices = []
            max_disk = {}
            msg = "Command exit status {}".format(ret_code)
            self.log.error("{} exit status {}".format(block_query, ret_code))
            status = agent_util.UNSUPPORTED
        else:
            self.dump_disk_output(config, block_query, block_result)
            devices, max_disk = parser.get_device_data(
                block_result, table_keys, custom_network_fs
            )

        inode_status = agent_util.SUPPORTED
        idevices = []
        imax_disk = {}
        inode_status_msg = None
        if "sunos" in sys.platform or "hp-ux" in sys.platform or "aix" in sys.platform:
            inode_status = agent_util.UNSUPPORTED
            inode_status_msg = "Unsupported on this platform"
        else:
            ret_code, inode_result = agent_util.execute_command(
                inode_query, cache_timeout=agent_util.DEFAULT_CACHE_TIMEOUT
            )
            if 0 != ret_code:
                inode_status_msg = "Command exit status {}".format(ret_code)
                self.log.error("{} exit status {}".format(inode_query, ret_code))
                inode_status = agent_util.UNSUPPORTED
            else:
                if not use_findmnt:
                    table_keys["available"] = "ifree"
                self.dump_disk_output(config, inode_query, inode_result)
                idevices, imax_disk = parser.get_device_data(
                    inode_result, table_keys, custom_network_fs
                )

        options_schema = {
            "device": "string",
            "mountpoint": "string",
            "filesystem": "string",
            "resource": "string",
            "is_network": "boolean",
        }
        data = {
            "usage.percent_used": {
                "label": "Percentage of disk used",
                "options": devices,
                "options_schema": options_schema,
                "status": status,
                "error_message": msg,
                "unit": "percent",
                "min_value": 0,
                "max_value": 100,
            },
            "usage.kb_available": {
                "label": "Disk space available",
                "options": devices,
                "options_schema": options_schema,
                "status": status,
                "error_message": msg,
                "unit": "kB",
                "min_value": 0,
                "max_value": max_disk,
            },
            "filesystem.mounted": {
                "label": "Filesystem mounted",
                "options": devices,
                "options_schema": options_schema,
                "status": status,
                "error_message": msg,
            },
            "inode.percent_used": {
                "label": "Inodes percent used",
                "options": idevices,
                "options_schema": options_schema,
                "status": inode_status,
                "error_message": inode_status_msg,
                "unit": "percent",
                "min_value": 0,
                "max_value": 100,
            },
            "inode.used": {
                "label": "Inode used",
                "options": idevices,
                "options_schema": options_schema,
                "status": inode_status,
                "error_message": inode_status_msg,
                "unit": "Inodes",
                "min_value": 0,
                "max_value": imax_disk,
            },
            "inode.available": {
                "label": "Inodes Available",
                "options": idevices,
                "options_schema": options_schema,
                "status": inode_status,
                "error_message": inode_status_msg,
                "unit": "Inodes",
                "min_value": 0,
                "max_value": imax_disk,
            },
        }

        # no inodes for vmware
        to_del = []
        if "vmware" in sys.platform:
            for k in data.keys():
                if "inode" in k:
                    to_del.append(k)

        for d in to_del:
            del data[d]

        return data

    def collect_vmware(self, textkey, mounted):
        ret, output = agent_util.execute_command(
            "stat -f %s" % mounted, cache_timeout=agent_util.DEFAULT_CACHE_TIMEOUT
        )
        # make sure it's mounted first
        if ret != 0 and textkey != "filesystem.mounted":
            self.log.error("Unable to find disk %s, is it mounted?!" % mounted)
            self.log.error(output)
            return None
        elif ret != 0 and textkey == "filesystem.mounted":
            return 0

        block_size = 0
        metrics = {}
        for line in output.split("\n"):
            l = str(line).strip().lower()
            if l.startswith("file:") or l.startswith("id:"):
                continue
            elif l.startswith("block size:"):
                block_size = l.split()[-1]
            if l.startswith("blocks:"):
                try:
                    btext, ttext, total_size, ftext, free_size, atext, avail_size = (
                        l.split()
                    )
                except:
                    self.log.error("Unable to parse disk output!")
                    self.log.error(output)
                    return None
                metrics["usage.percent_used"] = 100.0 - (
                    (float(free_size) / float(total_size)) * 100
                )
                metrics["usage.kb_available"] = float(free_size) * float(block_size)
        return metrics[str(textkey)]

    @classmethod
    def gather_extra_df_arg(self, config):
        extra_df_arg = config.get("extra_df_arg", "")
        if "darwin" in sys.platform:
            configKey = "ignore_fstypes"
            ignores = self.darwin_fstype_excludes
            if config.get(configKey, None):
                ignores = "{},{}".format(ignores, config.get(configKey))
            extra_df_arg = "{} -T no{}".format(extra_df_arg, ignores)

        return extra_df_arg

    def check(self, textkey, dev_mount, config):
        dev_mount = dev_mount.split()
        mounted = " ".join(dev_mount[3:])

        extra_df_arg = self.gather_extra_df_arg(config)

        if "vmware" in sys.platform:
            return self.collect_vmware(textkey, mounted)

        is_inode_query = False
        if textkey.startswith("i"):
            df_cmd = get_idf_cmd(extra_df_arg)
            is_inode_query = True
        else:
            df_cmd = get_df_cmd(extra_df_arg)

        rc, output = agent_util.execute_command(
            df_cmd, cache_timeout=agent_util.DEFAULT_CACHE_TIMEOUT
        )
        if 0 != rc:
            return None
        self.log.debug("%s output: %s" % (df_cmd, output))

        parser = DiskDFParser(self.log, config)
        df_data = parser.parse_df_output(output)
        mountpoint_data = df_data.get(mounted, None)
        if not mountpoint_data:
            self.log.error("Mountpoint %r not found" % mounted)
            if textkey == "filesystem.mounted":
                return False
            return None

        def convert_capacity_field(capacity):
            if capacity is None:
                return None
            if capacity == "-":
                return 0
            else:
                return int(capacity.rstrip("%"))

        if "filesystem.mounted" == textkey:
            return True
        if textkey in ["usage.percent_used", "inode.percent_used"]:
            key = "capacity"
            if is_inode_query:
                key = "iuse_pct"
            return convert_capacity_field(mountpoint_data.get(key, None))

        key = None
        if "inode.used" == textkey:
            key = "iused"
        elif "inode.available" == textkey:
            key = "ifree"
        elif "usage.kb_available" == textkey:
            key = "available"
        if not key:
            return None
        mv = mountpoint_data.get(key, None)
        if mv is None:
            return None
        if "-" == mv:
            return 0

        return int(mv)

Youez - 2016 - github.com/yon3zu
LinuXploit