sys_fs_cgroup.c 155 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736
  1. // SPDX-License-Identifier: GPL-3.0-or-later
  2. #include "sys_fs_cgroup.h"
  3. #define PLUGIN_CGROUPS_NAME "cgroups.plugin"
  4. #define PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME "systemd"
  5. #define PLUGIN_CGROUPS_MODULE_CGROUPS_NAME "/sys/fs/cgroup"
  6. // ----------------------------------------------------------------------------
  7. // cgroup globals
  8. static long system_page_size = 4096; // system will be queried via sysconf() in configuration()
  9. static int cgroup_enable_cpuacct_stat = CONFIG_BOOLEAN_AUTO;
  10. static int cgroup_enable_cpuacct_usage = CONFIG_BOOLEAN_AUTO;
  11. static int cgroup_enable_memory = CONFIG_BOOLEAN_AUTO;
  12. static int cgroup_enable_detailed_memory = CONFIG_BOOLEAN_AUTO;
  13. static int cgroup_enable_memory_failcnt = CONFIG_BOOLEAN_AUTO;
  14. static int cgroup_enable_swap = CONFIG_BOOLEAN_AUTO;
  15. static int cgroup_enable_blkio_io = CONFIG_BOOLEAN_AUTO;
  16. static int cgroup_enable_blkio_ops = CONFIG_BOOLEAN_AUTO;
  17. static int cgroup_enable_blkio_throttle_io = CONFIG_BOOLEAN_AUTO;
  18. static int cgroup_enable_blkio_throttle_ops = CONFIG_BOOLEAN_AUTO;
  19. static int cgroup_enable_blkio_merged_ops = CONFIG_BOOLEAN_AUTO;
  20. static int cgroup_enable_blkio_queued_ops = CONFIG_BOOLEAN_AUTO;
  21. static int cgroup_enable_pressure_cpu = CONFIG_BOOLEAN_AUTO;
  22. static int cgroup_enable_pressure_io_some = CONFIG_BOOLEAN_AUTO;
  23. static int cgroup_enable_pressure_io_full = CONFIG_BOOLEAN_AUTO;
  24. static int cgroup_enable_pressure_memory_some = CONFIG_BOOLEAN_AUTO;
  25. static int cgroup_enable_pressure_memory_full = CONFIG_BOOLEAN_AUTO;
  26. static int cgroup_enable_systemd_services = CONFIG_BOOLEAN_YES;
  27. static int cgroup_enable_systemd_services_detailed_memory = CONFIG_BOOLEAN_NO;
  28. static int cgroup_used_memory_without_cache = CONFIG_BOOLEAN_YES;
  29. static int cgroup_use_unified_cgroups = CONFIG_BOOLEAN_NO;
  30. static int cgroup_unified_exist = CONFIG_BOOLEAN_AUTO;
  31. static int cgroup_search_in_devices = 1;
  32. static int cgroup_enable_new_cgroups_detected_at_runtime = 1;
  33. static int cgroup_check_for_new_every = 10;
  34. static int cgroup_update_every = 1;
  35. static int cgroup_containers_chart_priority = NETDATA_CHART_PRIO_CGROUPS_CONTAINERS;
  36. static int cgroup_recheck_zero_blkio_every_iterations = 10;
  37. static int cgroup_recheck_zero_mem_failcnt_every_iterations = 10;
  38. static int cgroup_recheck_zero_mem_detailed_every_iterations = 10;
  39. static char *cgroup_cpuacct_base = NULL;
  40. static char *cgroup_cpuset_base = NULL;
  41. static char *cgroup_blkio_base = NULL;
  42. static char *cgroup_memory_base = NULL;
  43. static char *cgroup_devices_base = NULL;
  44. static char *cgroup_unified_base = NULL;
  45. static int cgroup_root_count = 0;
  46. static int cgroup_root_max = 1000;
  47. static int cgroup_max_depth = 0;
  48. static SIMPLE_PATTERN *enabled_cgroup_patterns = NULL;
  49. static SIMPLE_PATTERN *enabled_cgroup_paths = NULL;
  50. static SIMPLE_PATTERN *enabled_cgroup_renames = NULL;
  51. static SIMPLE_PATTERN *systemd_services_cgroups = NULL;
  52. static char *cgroups_rename_script = NULL;
  53. static char *cgroups_network_interface_script = NULL;
  54. static int cgroups_check = 0;
  55. static uint32_t Read_hash = 0;
  56. static uint32_t Write_hash = 0;
  57. static uint32_t user_hash = 0;
  58. static uint32_t system_hash = 0;
  59. void read_cgroup_plugin_configuration() {
  60. system_page_size = sysconf(_SC_PAGESIZE);
  61. Read_hash = simple_hash("Read");
  62. Write_hash = simple_hash("Write");
  63. user_hash = simple_hash("user");
  64. system_hash = simple_hash("system");
  65. cgroup_update_every = (int)config_get_number("plugin:cgroups", "update every", localhost->rrd_update_every);
  66. if(cgroup_update_every < localhost->rrd_update_every)
  67. cgroup_update_every = localhost->rrd_update_every;
  68. cgroup_check_for_new_every = (int)config_get_number("plugin:cgroups", "check for new cgroups every", (long long)cgroup_check_for_new_every * (long long)cgroup_update_every);
  69. if(cgroup_check_for_new_every < cgroup_update_every)
  70. cgroup_check_for_new_every = cgroup_update_every;
  71. cgroup_use_unified_cgroups = config_get_boolean_ondemand("plugin:cgroups", "use unified cgroups", cgroup_use_unified_cgroups);
  72. cgroup_containers_chart_priority = (int)config_get_number("plugin:cgroups", "containers priority", cgroup_containers_chart_priority);
  73. if(cgroup_containers_chart_priority < 1)
  74. cgroup_containers_chart_priority = NETDATA_CHART_PRIO_CGROUPS_CONTAINERS;
  75. cgroup_enable_cpuacct_stat = config_get_boolean_ondemand("plugin:cgroups", "enable cpuacct stat (total CPU)", cgroup_enable_cpuacct_stat);
  76. cgroup_enable_cpuacct_usage = config_get_boolean_ondemand("plugin:cgroups", "enable cpuacct usage (per core CPU)", cgroup_enable_cpuacct_usage);
  77. cgroup_enable_memory = config_get_boolean_ondemand("plugin:cgroups", "enable memory (used mem including cache)", cgroup_enable_memory);
  78. cgroup_enable_detailed_memory = config_get_boolean_ondemand("plugin:cgroups", "enable detailed memory", cgroup_enable_detailed_memory);
  79. cgroup_enable_memory_failcnt = config_get_boolean_ondemand("plugin:cgroups", "enable memory limits fail count", cgroup_enable_memory_failcnt);
  80. cgroup_enable_swap = config_get_boolean_ondemand("plugin:cgroups", "enable swap memory", cgroup_enable_swap);
  81. cgroup_enable_blkio_io = config_get_boolean_ondemand("plugin:cgroups", "enable blkio bandwidth", cgroup_enable_blkio_io);
  82. cgroup_enable_blkio_ops = config_get_boolean_ondemand("plugin:cgroups", "enable blkio operations", cgroup_enable_blkio_ops);
  83. cgroup_enable_blkio_throttle_io = config_get_boolean_ondemand("plugin:cgroups", "enable blkio throttle bandwidth", cgroup_enable_blkio_throttle_io);
  84. cgroup_enable_blkio_throttle_ops = config_get_boolean_ondemand("plugin:cgroups", "enable blkio throttle operations", cgroup_enable_blkio_throttle_ops);
  85. cgroup_enable_blkio_queued_ops = config_get_boolean_ondemand("plugin:cgroups", "enable blkio queued operations", cgroup_enable_blkio_queued_ops);
  86. cgroup_enable_blkio_merged_ops = config_get_boolean_ondemand("plugin:cgroups", "enable blkio merged operations", cgroup_enable_blkio_merged_ops);
  87. cgroup_enable_pressure_cpu = config_get_boolean_ondemand("plugin:cgroups", "enable cpu pressure", cgroup_enable_pressure_cpu);
  88. cgroup_enable_pressure_io_some = config_get_boolean_ondemand("plugin:cgroups", "enable io some pressure", cgroup_enable_pressure_io_some);
  89. cgroup_enable_pressure_io_full = config_get_boolean_ondemand("plugin:cgroups", "enable io full pressure", cgroup_enable_pressure_io_full);
  90. cgroup_enable_pressure_memory_some = config_get_boolean_ondemand("plugin:cgroups", "enable memory some pressure", cgroup_enable_pressure_memory_some);
  91. cgroup_enable_pressure_memory_full = config_get_boolean_ondemand("plugin:cgroups", "enable memory full pressure", cgroup_enable_pressure_memory_full);
  92. cgroup_recheck_zero_blkio_every_iterations = (int)config_get_number("plugin:cgroups", "recheck zero blkio every iterations", cgroup_recheck_zero_blkio_every_iterations);
  93. cgroup_recheck_zero_mem_failcnt_every_iterations = (int)config_get_number("plugin:cgroups", "recheck zero memory failcnt every iterations", cgroup_recheck_zero_mem_failcnt_every_iterations);
  94. cgroup_recheck_zero_mem_detailed_every_iterations = (int)config_get_number("plugin:cgroups", "recheck zero detailed memory every iterations", cgroup_recheck_zero_mem_detailed_every_iterations);
  95. cgroup_enable_systemd_services = config_get_boolean("plugin:cgroups", "enable systemd services", cgroup_enable_systemd_services);
  96. cgroup_enable_systemd_services_detailed_memory = config_get_boolean("plugin:cgroups", "enable systemd services detailed memory", cgroup_enable_systemd_services_detailed_memory);
  97. cgroup_used_memory_without_cache = config_get_boolean("plugin:cgroups", "report used memory without cache", cgroup_used_memory_without_cache);
  98. char filename[FILENAME_MAX + 1], *s;
  99. struct mountinfo *mi, *root = mountinfo_read(0);
  100. if(!cgroup_use_unified_cgroups) {
  101. // cgroup v1 does not have pressure metrics
  102. cgroup_enable_pressure_cpu =
  103. cgroup_enable_pressure_io_some =
  104. cgroup_enable_pressure_io_full =
  105. cgroup_enable_pressure_memory_some =
  106. cgroup_enable_pressure_memory_full = CONFIG_BOOLEAN_NO;
  107. mi = mountinfo_find_by_filesystem_super_option(root, "cgroup", "cpuacct");
  108. if(!mi) mi = mountinfo_find_by_filesystem_mount_source(root, "cgroup", "cpuacct");
  109. if(!mi) {
  110. error("CGROUP: cannot find cpuacct mountinfo. Assuming default: /sys/fs/cgroup/cpuacct");
  111. s = "/sys/fs/cgroup/cpuacct";
  112. }
  113. else s = mi->mount_point;
  114. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, s);
  115. cgroup_cpuacct_base = config_get("plugin:cgroups", "path to /sys/fs/cgroup/cpuacct", filename);
  116. mi = mountinfo_find_by_filesystem_super_option(root, "cgroup", "cpuset");
  117. if(!mi) mi = mountinfo_find_by_filesystem_mount_source(root, "cgroup", "cpuset");
  118. if(!mi) {
  119. error("CGROUP: cannot find cpuset mountinfo. Assuming default: /sys/fs/cgroup/cpuset");
  120. s = "/sys/fs/cgroup/cpuset";
  121. }
  122. else s = mi->mount_point;
  123. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, s);
  124. cgroup_cpuset_base = config_get("plugin:cgroups", "path to /sys/fs/cgroup/cpuset", filename);
  125. mi = mountinfo_find_by_filesystem_super_option(root, "cgroup", "blkio");
  126. if(!mi) mi = mountinfo_find_by_filesystem_mount_source(root, "cgroup", "blkio");
  127. if(!mi) {
  128. error("CGROUP: cannot find blkio mountinfo. Assuming default: /sys/fs/cgroup/blkio");
  129. s = "/sys/fs/cgroup/blkio";
  130. }
  131. else s = mi->mount_point;
  132. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, s);
  133. cgroup_blkio_base = config_get("plugin:cgroups", "path to /sys/fs/cgroup/blkio", filename);
  134. mi = mountinfo_find_by_filesystem_super_option(root, "cgroup", "memory");
  135. if(!mi) mi = mountinfo_find_by_filesystem_mount_source(root, "cgroup", "memory");
  136. if(!mi) {
  137. error("CGROUP: cannot find memory mountinfo. Assuming default: /sys/fs/cgroup/memory");
  138. s = "/sys/fs/cgroup/memory";
  139. }
  140. else s = mi->mount_point;
  141. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, s);
  142. cgroup_memory_base = config_get("plugin:cgroups", "path to /sys/fs/cgroup/memory", filename);
  143. mi = mountinfo_find_by_filesystem_super_option(root, "cgroup", "devices");
  144. if(!mi) mi = mountinfo_find_by_filesystem_mount_source(root, "cgroup", "devices");
  145. if(!mi) {
  146. error("CGROUP: cannot find devices mountinfo. Assuming default: /sys/fs/cgroup/devices");
  147. s = "/sys/fs/cgroup/devices";
  148. }
  149. else s = mi->mount_point;
  150. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, s);
  151. cgroup_devices_base = config_get("plugin:cgroups", "path to /sys/fs/cgroup/devices", filename);
  152. }
  153. else {
  154. //cgroup_enable_cpuacct_stat =
  155. cgroup_enable_cpuacct_usage =
  156. //cgroup_enable_memory =
  157. //cgroup_enable_detailed_memory =
  158. cgroup_enable_memory_failcnt =
  159. //cgroup_enable_swap =
  160. //cgroup_enable_blkio_io =
  161. //cgroup_enable_blkio_ops =
  162. cgroup_enable_blkio_throttle_io =
  163. cgroup_enable_blkio_throttle_ops =
  164. cgroup_enable_blkio_merged_ops =
  165. cgroup_enable_blkio_queued_ops = CONFIG_BOOLEAN_NO;
  166. cgroup_search_in_devices = 0;
  167. cgroup_enable_systemd_services_detailed_memory = CONFIG_BOOLEAN_NO;
  168. cgroup_used_memory_without_cache = CONFIG_BOOLEAN_NO; //unified cgroups use different values
  169. //TODO: can there be more than 1 cgroup2 mount point?
  170. mi = mountinfo_find_by_filesystem_super_option(root, "cgroup2", "rw"); //there is no cgroup2 specific super option - for now use 'rw' option
  171. if(mi) debug(D_CGROUP, "found unified cgroup root using super options, with path: '%s'", mi->mount_point);
  172. if(!mi) {
  173. mi = mountinfo_find_by_filesystem_mount_source(root, "cgroup2", "cgroup");
  174. if(mi) debug(D_CGROUP, "found unified cgroup root using mountsource info, with path: '%s'", mi->mount_point);
  175. }
  176. if(!mi) {
  177. error("CGROUP: cannot find cgroup2 mountinfo. Assuming default: /sys/fs/cgroup");
  178. s = "/sys/fs/cgroup";
  179. }
  180. else s = mi->mount_point;
  181. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, s);
  182. cgroup_unified_base = config_get("plugin:cgroups", "path to unified cgroups", filename);
  183. debug(D_CGROUP, "using cgroup root: '%s'", cgroup_unified_base);
  184. }
  185. cgroup_root_max = (int)config_get_number("plugin:cgroups", "max cgroups to allow", cgroup_root_max);
  186. cgroup_max_depth = (int)config_get_number("plugin:cgroups", "max cgroups depth to monitor", cgroup_max_depth);
  187. cgroup_enable_new_cgroups_detected_at_runtime = config_get_boolean("plugin:cgroups", "enable new cgroups detected at run time", cgroup_enable_new_cgroups_detected_at_runtime);
  188. enabled_cgroup_patterns = simple_pattern_create(
  189. config_get("plugin:cgroups", "enable by default cgroups matching",
  190. // ----------------------------------------------------------------
  191. " !*/init.scope " // ignore init.scope
  192. " !/system.slice/run-*.scope " // ignore system.slice/run-XXXX.scope
  193. " *.scope " // we need all other *.scope for sure
  194. // ----------------------------------------------------------------
  195. " /machine.slice/*.service " // #3367 systemd-nspawn
  196. // ----------------------------------------------------------------
  197. " !*/vcpu* " // libvirtd adds these sub-cgroups
  198. " !*/emulator " // libvirtd adds these sub-cgroups
  199. " !*.mount "
  200. " !*.partition "
  201. " !*.service "
  202. " !*.socket "
  203. " !*.slice "
  204. " !*.swap "
  205. " !*.user "
  206. " !/ "
  207. " !/docker "
  208. " !/libvirt "
  209. " !/lxc "
  210. " !/lxc/*/* " // #1397 #2649
  211. " !/lxc.monitor "
  212. " !/lxc.pivot "
  213. " !/lxc.payload "
  214. " !/machine "
  215. " !/qemu "
  216. " !/system "
  217. " !/systemd "
  218. " !/user "
  219. " * " // enable anything else
  220. ), NULL, SIMPLE_PATTERN_EXACT);
  221. enabled_cgroup_paths = simple_pattern_create(
  222. config_get("plugin:cgroups", "search for cgroups in subpaths matching",
  223. " !*/init.scope " // ignore init.scope
  224. " !*-qemu " // #345
  225. " !*.libvirt-qemu " // #3010
  226. " !/init.scope "
  227. " !/system "
  228. " !/systemd "
  229. " !/user "
  230. " !/user.slice "
  231. " !/lxc/*/* " // #2161 #2649
  232. " !/lxc.monitor "
  233. " !/lxc.payload/*/* "
  234. " * "
  235. ), NULL, SIMPLE_PATTERN_EXACT);
  236. snprintfz(filename, FILENAME_MAX, "%s/cgroup-name.sh", netdata_configured_primary_plugins_dir);
  237. cgroups_rename_script = config_get("plugin:cgroups", "script to get cgroup names", filename);
  238. snprintfz(filename, FILENAME_MAX, "%s/cgroup-network", netdata_configured_primary_plugins_dir);
  239. cgroups_network_interface_script = config_get("plugin:cgroups", "script to get cgroup network interfaces", filename);
  240. enabled_cgroup_renames = simple_pattern_create(
  241. config_get("plugin:cgroups", "run script to rename cgroups matching",
  242. " !/ "
  243. " !*.mount "
  244. " !*.socket "
  245. " !*.partition "
  246. " /machine.slice/*.service " // #3367 systemd-nspawn
  247. " !*.service "
  248. " !*.slice "
  249. " !*.swap "
  250. " !*.user "
  251. " !init.scope "
  252. " !*.scope/vcpu* " // libvirtd adds these sub-cgroups
  253. " !*.scope/emulator " // libvirtd adds these sub-cgroups
  254. " *.scope "
  255. " *docker* "
  256. " *lxc* "
  257. " *qemu* "
  258. " *kubepods* " // #3396 kubernetes
  259. " *.libvirt-qemu " // #3010
  260. " * "
  261. ), NULL, SIMPLE_PATTERN_EXACT);
  262. if(cgroup_enable_systemd_services) {
  263. systemd_services_cgroups = simple_pattern_create(
  264. config_get("plugin:cgroups", "cgroups to match as systemd services",
  265. " !/system.slice/*/*.service "
  266. " /system.slice/*.service "
  267. ), NULL, SIMPLE_PATTERN_EXACT);
  268. }
  269. mountinfo_free_all(root);
  270. }
  271. // ----------------------------------------------------------------------------
  272. // cgroup objects
  273. struct blkio {
  274. int updated;
  275. int enabled; // CONFIG_BOOLEAN_YES or CONFIG_BOOLEAN_AUTO
  276. int delay_counter;
  277. char *filename;
  278. unsigned long long Read;
  279. unsigned long long Write;
  280. /*
  281. unsigned long long Sync;
  282. unsigned long long Async;
  283. unsigned long long Total;
  284. */
  285. };
  286. // https://www.kernel.org/doc/Documentation/cgroup-v1/memory.txt
  287. struct memory {
  288. ARL_BASE *arl_base;
  289. ARL_ENTRY *arl_dirty;
  290. ARL_ENTRY *arl_swap;
  291. int updated_detailed;
  292. int updated_usage_in_bytes;
  293. int updated_msw_usage_in_bytes;
  294. int updated_failcnt;
  295. int enabled_detailed; // CONFIG_BOOLEAN_YES or CONFIG_BOOLEAN_AUTO
  296. int enabled_usage_in_bytes; // CONFIG_BOOLEAN_YES or CONFIG_BOOLEAN_AUTO
  297. int enabled_msw_usage_in_bytes; // CONFIG_BOOLEAN_YES or CONFIG_BOOLEAN_AUTO
  298. int enabled_failcnt; // CONFIG_BOOLEAN_YES or CONFIG_BOOLEAN_AUTO
  299. int delay_counter_detailed;
  300. int delay_counter_failcnt;
  301. char *filename_detailed;
  302. char *filename_usage_in_bytes;
  303. char *filename_msw_usage_in_bytes;
  304. char *filename_failcnt;
  305. int detailed_has_dirty;
  306. int detailed_has_swap;
  307. // detailed metrics
  308. /*
  309. unsigned long long cache;
  310. unsigned long long rss;
  311. unsigned long long rss_huge;
  312. unsigned long long mapped_file;
  313. unsigned long long writeback;
  314. unsigned long long dirty;
  315. unsigned long long swap;
  316. unsigned long long pgpgin;
  317. unsigned long long pgpgout;
  318. unsigned long long pgfault;
  319. unsigned long long pgmajfault;
  320. unsigned long long inactive_anon;
  321. unsigned long long active_anon;
  322. unsigned long long inactive_file;
  323. unsigned long long active_file;
  324. unsigned long long unevictable;
  325. unsigned long long hierarchical_memory_limit;
  326. */
  327. //unified cgroups metrics
  328. unsigned long long anon;
  329. unsigned long long kernel_stack;
  330. unsigned long long slab;
  331. unsigned long long sock;
  332. unsigned long long shmem;
  333. unsigned long long anon_thp;
  334. //unsigned long long file_writeback;
  335. //unsigned long long file_dirty;
  336. //unsigned long long file;
  337. unsigned long long total_cache;
  338. unsigned long long total_rss;
  339. unsigned long long total_rss_huge;
  340. unsigned long long total_mapped_file;
  341. unsigned long long total_writeback;
  342. unsigned long long total_dirty;
  343. unsigned long long total_swap;
  344. unsigned long long total_pgpgin;
  345. unsigned long long total_pgpgout;
  346. unsigned long long total_pgfault;
  347. unsigned long long total_pgmajfault;
  348. /*
  349. unsigned long long total_inactive_anon;
  350. unsigned long long total_active_anon;
  351. unsigned long long total_inactive_file;
  352. unsigned long long total_active_file;
  353. unsigned long long total_unevictable;
  354. */
  355. // single file metrics
  356. unsigned long long usage_in_bytes;
  357. unsigned long long msw_usage_in_bytes;
  358. unsigned long long failcnt;
  359. };
  360. // https://www.kernel.org/doc/Documentation/cgroup-v1/cpuacct.txt
  361. struct cpuacct_stat {
  362. int updated;
  363. int enabled; // CONFIG_BOOLEAN_YES or CONFIG_BOOLEAN_AUTO
  364. char *filename;
  365. unsigned long long user;
  366. unsigned long long system;
  367. };
  368. // https://www.kernel.org/doc/Documentation/cgroup-v1/cpuacct.txt
  369. struct cpuacct_usage {
  370. int updated;
  371. int enabled; // CONFIG_BOOLEAN_YES or CONFIG_BOOLEAN_AUTO
  372. char *filename;
  373. unsigned int cpus;
  374. unsigned long long *cpu_percpu;
  375. };
  376. struct cgroup_network_interface {
  377. const char *host_device;
  378. const char *container_device;
  379. struct cgroup_network_interface *next;
  380. };
  381. #define CGROUP_OPTIONS_DISABLED_DUPLICATE 0x00000001
  382. #define CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE 0x00000002
  383. #define CGROUP_OPTIONS_IS_UNIFIED 0x00000004
  384. struct cgroup {
  385. uint32_t options;
  386. char available; // found in the filesystem
  387. char enabled; // enabled in the config
  388. char pending_renames;
  389. char *id;
  390. uint32_t hash;
  391. char *chart_id;
  392. uint32_t hash_chart;
  393. char *chart_title;
  394. struct cpuacct_stat cpuacct_stat;
  395. struct cpuacct_usage cpuacct_usage;
  396. struct memory memory;
  397. struct blkio io_service_bytes; // bytes
  398. struct blkio io_serviced; // operations
  399. struct blkio throttle_io_service_bytes; // bytes
  400. struct blkio throttle_io_serviced; // operations
  401. struct blkio io_merged; // operations
  402. struct blkio io_queued; // operations
  403. struct cgroup_network_interface *interfaces;
  404. struct pressure cpu_pressure;
  405. struct pressure io_pressure;
  406. struct pressure memory_pressure;
  407. // per cgroup charts
  408. RRDSET *st_cpu;
  409. RRDSET *st_cpu_limit;
  410. RRDSET *st_cpu_per_core;
  411. RRDSET *st_mem;
  412. RRDSET *st_writeback;
  413. RRDSET *st_mem_activity;
  414. RRDSET *st_pgfaults;
  415. RRDSET *st_mem_usage;
  416. RRDSET *st_mem_usage_limit;
  417. RRDSET *st_mem_failcnt;
  418. RRDSET *st_io;
  419. RRDSET *st_serviced_ops;
  420. RRDSET *st_throttle_io;
  421. RRDSET *st_throttle_serviced_ops;
  422. RRDSET *st_queued_ops;
  423. RRDSET *st_merged_ops;
  424. // per cgroup chart variables
  425. char *filename_cpuset_cpus;
  426. unsigned long long cpuset_cpus;
  427. char *filename_cpu_cfs_period;
  428. unsigned long long cpu_cfs_period;
  429. char *filename_cpu_cfs_quota;
  430. unsigned long long cpu_cfs_quota;
  431. RRDSETVAR *chart_var_cpu_limit;
  432. calculated_number prev_cpu_usage;
  433. char *filename_memory_limit;
  434. unsigned long long memory_limit;
  435. RRDSETVAR *chart_var_memory_limit;
  436. char *filename_memoryswap_limit;
  437. unsigned long long memoryswap_limit;
  438. RRDSETVAR *chart_var_memoryswap_limit;
  439. // services
  440. RRDDIM *rd_cpu;
  441. RRDDIM *rd_mem_usage;
  442. RRDDIM *rd_mem_failcnt;
  443. RRDDIM *rd_swap_usage;
  444. RRDDIM *rd_mem_detailed_cache;
  445. RRDDIM *rd_mem_detailed_rss;
  446. RRDDIM *rd_mem_detailed_mapped;
  447. RRDDIM *rd_mem_detailed_writeback;
  448. RRDDIM *rd_mem_detailed_pgpgin;
  449. RRDDIM *rd_mem_detailed_pgpgout;
  450. RRDDIM *rd_mem_detailed_pgfault;
  451. RRDDIM *rd_mem_detailed_pgmajfault;
  452. RRDDIM *rd_io_service_bytes_read;
  453. RRDDIM *rd_io_serviced_read;
  454. RRDDIM *rd_throttle_io_read;
  455. RRDDIM *rd_throttle_io_serviced_read;
  456. RRDDIM *rd_io_queued_read;
  457. RRDDIM *rd_io_merged_read;
  458. RRDDIM *rd_io_service_bytes_write;
  459. RRDDIM *rd_io_serviced_write;
  460. RRDDIM *rd_throttle_io_write;
  461. RRDDIM *rd_throttle_io_serviced_write;
  462. RRDDIM *rd_io_queued_write;
  463. RRDDIM *rd_io_merged_write;
  464. struct cgroup *next;
  465. } *cgroup_root = NULL;
  466. // ----------------------------------------------------------------------------
  467. // read values from /sys
  468. static inline void cgroup_read_cpuacct_stat(struct cpuacct_stat *cp) {
  469. static procfile *ff = NULL;
  470. if(likely(cp->filename)) {
  471. ff = procfile_reopen(ff, cp->filename, NULL, PROCFILE_FLAG_DEFAULT);
  472. if(unlikely(!ff)) {
  473. cp->updated = 0;
  474. cgroups_check = 1;
  475. return;
  476. }
  477. ff = procfile_readall(ff);
  478. if(unlikely(!ff)) {
  479. cp->updated = 0;
  480. cgroups_check = 1;
  481. return;
  482. }
  483. unsigned long i, lines = procfile_lines(ff);
  484. if(unlikely(lines < 1)) {
  485. error("CGROUP: file '%s' should have 1+ lines.", cp->filename);
  486. cp->updated = 0;
  487. return;
  488. }
  489. for(i = 0; i < lines ; i++) {
  490. char *s = procfile_lineword(ff, i, 0);
  491. uint32_t hash = simple_hash(s);
  492. if(unlikely(hash == user_hash && !strcmp(s, "user")))
  493. cp->user = str2ull(procfile_lineword(ff, i, 1));
  494. else if(unlikely(hash == system_hash && !strcmp(s, "system")))
  495. cp->system = str2ull(procfile_lineword(ff, i, 1));
  496. }
  497. cp->updated = 1;
  498. if(unlikely(cp->enabled == CONFIG_BOOLEAN_AUTO &&
  499. (cp->user || cp->system || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  500. cp->enabled = CONFIG_BOOLEAN_YES;
  501. }
  502. }
  503. static inline void cgroup2_read_cpuacct_stat(struct cpuacct_stat *cp) {
  504. static procfile *ff = NULL;
  505. if(likely(cp->filename)) {
  506. ff = procfile_reopen(ff, cp->filename, NULL, PROCFILE_FLAG_DEFAULT);
  507. if(unlikely(!ff)) {
  508. cp->updated = 0;
  509. cgroups_check = 1;
  510. return;
  511. }
  512. ff = procfile_readall(ff);
  513. if(unlikely(!ff)) {
  514. cp->updated = 0;
  515. cgroups_check = 1;
  516. return;
  517. }
  518. unsigned long lines = procfile_lines(ff);
  519. if(unlikely(lines < 3)) {
  520. error("CGROUP: file '%s' should have 3+ lines.", cp->filename);
  521. cp->updated = 0;
  522. return;
  523. }
  524. cp->user = str2ull(procfile_lineword(ff, 1, 1));
  525. cp->system = str2ull(procfile_lineword(ff, 2, 1));
  526. cp->updated = 1;
  527. if(unlikely(cp->enabled == CONFIG_BOOLEAN_AUTO &&
  528. (cp->user || cp->system || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  529. cp->enabled = CONFIG_BOOLEAN_YES;
  530. }
  531. }
  532. static inline void cgroup_read_cpuacct_usage(struct cpuacct_usage *ca) {
  533. static procfile *ff = NULL;
  534. if(likely(ca->filename)) {
  535. ff = procfile_reopen(ff, ca->filename, NULL, PROCFILE_FLAG_DEFAULT);
  536. if(unlikely(!ff)) {
  537. ca->updated = 0;
  538. cgroups_check = 1;
  539. return;
  540. }
  541. ff = procfile_readall(ff);
  542. if(unlikely(!ff)) {
  543. ca->updated = 0;
  544. cgroups_check = 1;
  545. return;
  546. }
  547. if(unlikely(procfile_lines(ff) < 1)) {
  548. error("CGROUP: file '%s' should have 1+ lines but has %zu.", ca->filename, procfile_lines(ff));
  549. ca->updated = 0;
  550. return;
  551. }
  552. unsigned long i = procfile_linewords(ff, 0);
  553. if(unlikely(i == 0)) {
  554. ca->updated = 0;
  555. return;
  556. }
  557. // we may have 1 more CPU reported
  558. while(i > 0) {
  559. char *s = procfile_lineword(ff, 0, i - 1);
  560. if(!*s) i--;
  561. else break;
  562. }
  563. if(unlikely(i != ca->cpus)) {
  564. freez(ca->cpu_percpu);
  565. ca->cpu_percpu = mallocz(sizeof(unsigned long long) * i);
  566. ca->cpus = (unsigned int)i;
  567. }
  568. unsigned long long total = 0;
  569. for(i = 0; i < ca->cpus ;i++) {
  570. unsigned long long n = str2ull(procfile_lineword(ff, 0, i));
  571. ca->cpu_percpu[i] = n;
  572. total += n;
  573. }
  574. ca->updated = 1;
  575. if(unlikely(ca->enabled == CONFIG_BOOLEAN_AUTO &&
  576. (total || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  577. ca->enabled = CONFIG_BOOLEAN_YES;
  578. }
  579. }
  580. static inline void cgroup_read_blkio(struct blkio *io) {
  581. if(unlikely(io->enabled == CONFIG_BOOLEAN_AUTO && io->delay_counter > 0)) {
  582. io->delay_counter--;
  583. return;
  584. }
  585. if(likely(io->filename)) {
  586. static procfile *ff = NULL;
  587. ff = procfile_reopen(ff, io->filename, NULL, PROCFILE_FLAG_DEFAULT);
  588. if(unlikely(!ff)) {
  589. io->updated = 0;
  590. cgroups_check = 1;
  591. return;
  592. }
  593. ff = procfile_readall(ff);
  594. if(unlikely(!ff)) {
  595. io->updated = 0;
  596. cgroups_check = 1;
  597. return;
  598. }
  599. unsigned long i, lines = procfile_lines(ff);
  600. if(unlikely(lines < 1)) {
  601. error("CGROUP: file '%s' should have 1+ lines.", io->filename);
  602. io->updated = 0;
  603. return;
  604. }
  605. io->Read = 0;
  606. io->Write = 0;
  607. /*
  608. io->Sync = 0;
  609. io->Async = 0;
  610. io->Total = 0;
  611. */
  612. for(i = 0; i < lines ; i++) {
  613. char *s = procfile_lineword(ff, i, 1);
  614. uint32_t hash = simple_hash(s);
  615. if(unlikely(hash == Read_hash && !strcmp(s, "Read")))
  616. io->Read += str2ull(procfile_lineword(ff, i, 2));
  617. else if(unlikely(hash == Write_hash && !strcmp(s, "Write")))
  618. io->Write += str2ull(procfile_lineword(ff, i, 2));
  619. /*
  620. else if(unlikely(hash == Sync_hash && !strcmp(s, "Sync")))
  621. io->Sync += str2ull(procfile_lineword(ff, i, 2));
  622. else if(unlikely(hash == Async_hash && !strcmp(s, "Async")))
  623. io->Async += str2ull(procfile_lineword(ff, i, 2));
  624. else if(unlikely(hash == Total_hash && !strcmp(s, "Total")))
  625. io->Total += str2ull(procfile_lineword(ff, i, 2));
  626. */
  627. }
  628. io->updated = 1;
  629. if(unlikely(io->enabled == CONFIG_BOOLEAN_AUTO)) {
  630. if(unlikely(io->Read || io->Write || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))
  631. io->enabled = CONFIG_BOOLEAN_YES;
  632. else
  633. io->delay_counter = cgroup_recheck_zero_blkio_every_iterations;
  634. }
  635. }
  636. }
  637. static inline void cgroup2_read_blkio(struct blkio *io, unsigned int word_offset) {
  638. if(unlikely(io->enabled == CONFIG_BOOLEAN_AUTO && io->delay_counter > 0)) {
  639. io->delay_counter--;
  640. return;
  641. }
  642. if(likely(io->filename)) {
  643. static procfile *ff = NULL;
  644. ff = procfile_reopen(ff, io->filename, NULL, PROCFILE_FLAG_DEFAULT);
  645. if(unlikely(!ff)) {
  646. io->updated = 0;
  647. cgroups_check = 1;
  648. return;
  649. }
  650. ff = procfile_readall(ff);
  651. if(unlikely(!ff)) {
  652. io->updated = 0;
  653. cgroups_check = 1;
  654. return;
  655. }
  656. unsigned long i, lines = procfile_lines(ff);
  657. if (unlikely(lines < 1)) {
  658. error("CGROUP: file '%s' should have 1+ lines.", io->filename);
  659. io->updated = 0;
  660. return;
  661. }
  662. io->Read = 0;
  663. io->Write = 0;
  664. for (i = 0; i < lines; i++) {
  665. io->Read += str2ull(procfile_lineword(ff, i, 2 + word_offset));
  666. io->Write += str2ull(procfile_lineword(ff, i, 4 + word_offset));
  667. }
  668. io->updated = 1;
  669. if(unlikely(io->enabled == CONFIG_BOOLEAN_AUTO)) {
  670. if(unlikely(io->Read || io->Write || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))
  671. io->enabled = CONFIG_BOOLEAN_YES;
  672. else
  673. io->delay_counter = cgroup_recheck_zero_blkio_every_iterations;
  674. }
  675. }
  676. }
  677. static inline void cgroup2_read_pressure(struct pressure *res) {
  678. static procfile *ff = NULL;
  679. if (likely(res->filename)) {
  680. ff = procfile_reopen(ff, res->filename, " =", PROCFILE_FLAG_DEFAULT);
  681. if (unlikely(!ff)) {
  682. res->updated = 0;
  683. cgroups_check = 1;
  684. return;
  685. }
  686. ff = procfile_readall(ff);
  687. if (unlikely(!ff)) {
  688. res->updated = 0;
  689. cgroups_check = 1;
  690. return;
  691. }
  692. size_t lines = procfile_lines(ff);
  693. if (lines < 1) {
  694. error("CGROUP: file '%s' should have 1+ lines.", res->filename);
  695. res->updated = 0;
  696. return;
  697. }
  698. res->some.value10 = strtod(procfile_lineword(ff, 0, 2), NULL);
  699. res->some.value60 = strtod(procfile_lineword(ff, 0, 4), NULL);
  700. res->some.value300 = strtod(procfile_lineword(ff, 0, 6), NULL);
  701. if (lines > 2) {
  702. res->full.value10 = strtod(procfile_lineword(ff, 1, 2), NULL);
  703. res->full.value60 = strtod(procfile_lineword(ff, 1, 4), NULL);
  704. res->full.value300 = strtod(procfile_lineword(ff, 1, 6), NULL);
  705. }
  706. res->updated = 1;
  707. if (unlikely(res->some.enabled == CONFIG_BOOLEAN_AUTO)) {
  708. res->some.enabled = CONFIG_BOOLEAN_YES;
  709. if (lines > 2) {
  710. res->full.enabled = CONFIG_BOOLEAN_YES;
  711. } else {
  712. res->full.enabled = CONFIG_BOOLEAN_NO;
  713. }
  714. }
  715. }
  716. }
  717. static inline void cgroup_read_memory(struct memory *mem, char parent_cg_is_unified) {
  718. static procfile *ff = NULL;
  719. // read detailed ram usage
  720. if(likely(mem->filename_detailed)) {
  721. if(unlikely(mem->enabled_detailed == CONFIG_BOOLEAN_AUTO && mem->delay_counter_detailed > 0)) {
  722. mem->delay_counter_detailed--;
  723. goto memory_next;
  724. }
  725. ff = procfile_reopen(ff, mem->filename_detailed, NULL, PROCFILE_FLAG_DEFAULT);
  726. if(unlikely(!ff)) {
  727. mem->updated_detailed = 0;
  728. cgroups_check = 1;
  729. goto memory_next;
  730. }
  731. ff = procfile_readall(ff);
  732. if(unlikely(!ff)) {
  733. mem->updated_detailed = 0;
  734. cgroups_check = 1;
  735. goto memory_next;
  736. }
  737. unsigned long i, lines = procfile_lines(ff);
  738. if(unlikely(lines < 1)) {
  739. error("CGROUP: file '%s' should have 1+ lines.", mem->filename_detailed);
  740. mem->updated_detailed = 0;
  741. goto memory_next;
  742. }
  743. if(unlikely(!mem->arl_base)) {
  744. if(parent_cg_is_unified == 0){
  745. mem->arl_base = arl_create("cgroup/memory", NULL, 60);
  746. arl_expect(mem->arl_base, "total_cache", &mem->total_cache);
  747. arl_expect(mem->arl_base, "total_rss", &mem->total_rss);
  748. arl_expect(mem->arl_base, "total_rss_huge", &mem->total_rss_huge);
  749. arl_expect(mem->arl_base, "total_mapped_file", &mem->total_mapped_file);
  750. arl_expect(mem->arl_base, "total_writeback", &mem->total_writeback);
  751. mem->arl_dirty = arl_expect(mem->arl_base, "total_dirty", &mem->total_dirty);
  752. mem->arl_swap = arl_expect(mem->arl_base, "total_swap", &mem->total_swap);
  753. arl_expect(mem->arl_base, "total_pgpgin", &mem->total_pgpgin);
  754. arl_expect(mem->arl_base, "total_pgpgout", &mem->total_pgpgout);
  755. arl_expect(mem->arl_base, "total_pgfault", &mem->total_pgfault);
  756. arl_expect(mem->arl_base, "total_pgmajfault", &mem->total_pgmajfault);
  757. } else {
  758. mem->arl_base = arl_create("cgroup/memory", NULL, 60);
  759. arl_expect(mem->arl_base, "anon", &mem->anon);
  760. arl_expect(mem->arl_base, "kernel_stack", &mem->kernel_stack);
  761. arl_expect(mem->arl_base, "slab", &mem->slab);
  762. arl_expect(mem->arl_base, "sock", &mem->sock);
  763. arl_expect(mem->arl_base, "anon_thp", &mem->anon_thp);
  764. arl_expect(mem->arl_base, "file", &mem->total_mapped_file);
  765. arl_expect(mem->arl_base, "file_writeback", &mem->total_writeback);
  766. mem->arl_dirty = arl_expect(mem->arl_base, "file_dirty", &mem->total_dirty);
  767. arl_expect(mem->arl_base, "pgfault", &mem->total_pgfault);
  768. arl_expect(mem->arl_base, "pgmajfault", &mem->total_pgmajfault);
  769. }
  770. }
  771. arl_begin(mem->arl_base);
  772. for(i = 0; i < lines ; i++) {
  773. if(arl_check(mem->arl_base,
  774. procfile_lineword(ff, i, 0),
  775. procfile_lineword(ff, i, 1))) break;
  776. }
  777. if(unlikely(mem->arl_dirty->flags & ARL_ENTRY_FLAG_FOUND))
  778. mem->detailed_has_dirty = 1;
  779. if(unlikely(parent_cg_is_unified == 0 && mem->arl_swap->flags & ARL_ENTRY_FLAG_FOUND))
  780. mem->detailed_has_swap = 1;
  781. // fprintf(stderr, "READ: '%s', cache: %llu, rss: %llu, rss_huge: %llu, mapped_file: %llu, writeback: %llu, dirty: %llu, swap: %llu, pgpgin: %llu, pgpgout: %llu, pgfault: %llu, pgmajfault: %llu, inactive_anon: %llu, active_anon: %llu, inactive_file: %llu, active_file: %llu, unevictable: %llu, hierarchical_memory_limit: %llu, total_cache: %llu, total_rss: %llu, total_rss_huge: %llu, total_mapped_file: %llu, total_writeback: %llu, total_dirty: %llu, total_swap: %llu, total_pgpgin: %llu, total_pgpgout: %llu, total_pgfault: %llu, total_pgmajfault: %llu, total_inactive_anon: %llu, total_active_anon: %llu, total_inactive_file: %llu, total_active_file: %llu, total_unevictable: %llu\n", mem->filename, mem->cache, mem->rss, mem->rss_huge, mem->mapped_file, mem->writeback, mem->dirty, mem->swap, mem->pgpgin, mem->pgpgout, mem->pgfault, mem->pgmajfault, mem->inactive_anon, mem->active_anon, mem->inactive_file, mem->active_file, mem->unevictable, mem->hierarchical_memory_limit, mem->total_cache, mem->total_rss, mem->total_rss_huge, mem->total_mapped_file, mem->total_writeback, mem->total_dirty, mem->total_swap, mem->total_pgpgin, mem->total_pgpgout, mem->total_pgfault, mem->total_pgmajfault, mem->total_inactive_anon, mem->total_active_anon, mem->total_inactive_file, mem->total_active_file, mem->total_unevictable);
  782. mem->updated_detailed = 1;
  783. if(unlikely(mem->enabled_detailed == CONFIG_BOOLEAN_AUTO)) {
  784. if(( (!parent_cg_is_unified) && ( mem->total_cache || mem->total_dirty || mem->total_rss || mem->total_rss_huge || mem->total_mapped_file || mem->total_writeback
  785. || mem->total_swap || mem->total_pgpgin || mem->total_pgpgout || mem->total_pgfault || mem->total_pgmajfault))
  786. || (parent_cg_is_unified && ( mem->anon || mem->total_dirty || mem->kernel_stack || mem->slab || mem->sock || mem->total_writeback
  787. || mem->anon_thp || mem->total_pgfault || mem->total_pgmajfault))
  788. || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)
  789. mem->enabled_detailed = CONFIG_BOOLEAN_YES;
  790. else
  791. mem->delay_counter_detailed = cgroup_recheck_zero_mem_detailed_every_iterations;
  792. }
  793. }
  794. memory_next:
  795. // read usage_in_bytes
  796. if(likely(mem->filename_usage_in_bytes)) {
  797. mem->updated_usage_in_bytes = !read_single_number_file(mem->filename_usage_in_bytes, &mem->usage_in_bytes);
  798. if(unlikely(mem->updated_usage_in_bytes && mem->enabled_usage_in_bytes == CONFIG_BOOLEAN_AUTO &&
  799. (mem->usage_in_bytes || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  800. mem->enabled_usage_in_bytes = CONFIG_BOOLEAN_YES;
  801. }
  802. // read msw_usage_in_bytes
  803. if(likely(mem->filename_msw_usage_in_bytes)) {
  804. mem->updated_msw_usage_in_bytes = !read_single_number_file(mem->filename_msw_usage_in_bytes, &mem->msw_usage_in_bytes);
  805. if(unlikely(mem->updated_msw_usage_in_bytes && mem->enabled_msw_usage_in_bytes == CONFIG_BOOLEAN_AUTO &&
  806. (mem->msw_usage_in_bytes || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  807. mem->enabled_msw_usage_in_bytes = CONFIG_BOOLEAN_YES;
  808. }
  809. // read failcnt
  810. if(likely(mem->filename_failcnt)) {
  811. if(unlikely(mem->enabled_failcnt == CONFIG_BOOLEAN_AUTO && mem->delay_counter_failcnt > 0)) {
  812. mem->updated_failcnt = 0;
  813. mem->delay_counter_failcnt--;
  814. }
  815. else {
  816. mem->updated_failcnt = !read_single_number_file(mem->filename_failcnt, &mem->failcnt);
  817. if(unlikely(mem->updated_failcnt && mem->enabled_failcnt == CONFIG_BOOLEAN_AUTO)) {
  818. if(unlikely(mem->failcnt || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))
  819. mem->enabled_failcnt = CONFIG_BOOLEAN_YES;
  820. else
  821. mem->delay_counter_failcnt = cgroup_recheck_zero_mem_failcnt_every_iterations;
  822. }
  823. }
  824. }
  825. }
  826. static inline void cgroup_read(struct cgroup *cg) {
  827. debug(D_CGROUP, "reading metrics for cgroups '%s'", cg->id);
  828. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  829. cgroup_read_cpuacct_stat(&cg->cpuacct_stat);
  830. cgroup_read_cpuacct_usage(&cg->cpuacct_usage);
  831. cgroup_read_memory(&cg->memory, 0);
  832. cgroup_read_blkio(&cg->io_service_bytes);
  833. cgroup_read_blkio(&cg->io_serviced);
  834. cgroup_read_blkio(&cg->throttle_io_service_bytes);
  835. cgroup_read_blkio(&cg->throttle_io_serviced);
  836. cgroup_read_blkio(&cg->io_merged);
  837. cgroup_read_blkio(&cg->io_queued);
  838. }
  839. else {
  840. //TODO: io_service_bytes and io_serviced use same file merge into 1 function
  841. cgroup2_read_blkio(&cg->io_service_bytes, 0);
  842. cgroup2_read_blkio(&cg->io_serviced, 4);
  843. cgroup2_read_cpuacct_stat(&cg->cpuacct_stat);
  844. cgroup2_read_pressure(&cg->cpu_pressure);
  845. cgroup2_read_pressure(&cg->io_pressure);
  846. cgroup2_read_pressure(&cg->memory_pressure);
  847. cgroup_read_memory(&cg->memory, 1);
  848. }
  849. }
  850. static inline void read_all_cgroups(struct cgroup *root) {
  851. debug(D_CGROUP, "reading metrics for all cgroups");
  852. struct cgroup *cg;
  853. for(cg = root; cg ; cg = cg->next)
  854. if(cg->enabled && cg->available && !cg->pending_renames)
  855. cgroup_read(cg);
  856. }
  857. // ----------------------------------------------------------------------------
  858. // cgroup network interfaces
  859. #define CGROUP_NETWORK_INTERFACE_MAX_LINE 2048
  860. static inline void read_cgroup_network_interfaces(struct cgroup *cg) {
  861. debug(D_CGROUP, "looking for the network interfaces of cgroup '%s' with chart id '%s' and title '%s'", cg->id, cg->chart_id, cg->chart_title);
  862. pid_t cgroup_pid;
  863. char command[CGROUP_NETWORK_INTERFACE_MAX_LINE + 1];
  864. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  865. snprintfz(command, CGROUP_NETWORK_INTERFACE_MAX_LINE, "exec %s --cgroup '%s%s'", cgroups_network_interface_script, cgroup_cpuacct_base, cg->id);
  866. }
  867. else {
  868. snprintfz(command, CGROUP_NETWORK_INTERFACE_MAX_LINE, "exec %s --cgroup '%s%s'", cgroups_network_interface_script, cgroup_unified_base, cg->id);
  869. }
  870. debug(D_CGROUP, "executing command '%s' for cgroup '%s'", command, cg->id);
  871. FILE *fp = mypopen(command, &cgroup_pid);
  872. if(!fp) {
  873. error("CGROUP: cannot popen(\"%s\", \"r\").", command);
  874. return;
  875. }
  876. char *s;
  877. char buffer[CGROUP_NETWORK_INTERFACE_MAX_LINE + 1];
  878. while((s = fgets(buffer, CGROUP_NETWORK_INTERFACE_MAX_LINE, fp))) {
  879. trim(s);
  880. if(*s && *s != '\n') {
  881. char *t = s;
  882. while(*t && *t != ' ') t++;
  883. if(*t == ' ') {
  884. *t = '\0';
  885. t++;
  886. }
  887. if(!*s) {
  888. error("CGROUP: empty host interface returned by script");
  889. continue;
  890. }
  891. if(!*t) {
  892. error("CGROUP: empty guest interface returned by script");
  893. continue;
  894. }
  895. struct cgroup_network_interface *i = callocz(1, sizeof(struct cgroup_network_interface));
  896. i->host_device = strdupz(s);
  897. i->container_device = strdupz(t);
  898. i->next = cg->interfaces;
  899. cg->interfaces = i;
  900. info("CGROUP: cgroup '%s' has network interface '%s' as '%s'", cg->id, i->host_device, i->container_device);
  901. // register a device rename to proc_net_dev.c
  902. netdev_rename_device_add(i->host_device, i->container_device, cg->chart_id);
  903. }
  904. }
  905. mypclose(fp, cgroup_pid);
  906. // debug(D_CGROUP, "closed command for cgroup '%s'", cg->id);
  907. }
  908. static inline void free_cgroup_network_interfaces(struct cgroup *cg) {
  909. while(cg->interfaces) {
  910. struct cgroup_network_interface *i = cg->interfaces;
  911. cg->interfaces = i->next;
  912. // delete the registration of proc_net_dev rename
  913. netdev_rename_device_del(i->host_device);
  914. freez((void *)i->host_device);
  915. freez((void *)i->container_device);
  916. freez((void *)i);
  917. }
  918. }
  919. // ----------------------------------------------------------------------------
  920. // add/remove/find cgroup objects
  921. #define CGROUP_CHARTID_LINE_MAX 1024
  922. static inline char *cgroup_title_strdupz(const char *s) {
  923. if(!s || !*s) s = "/";
  924. if(*s == '/' && s[1] != '\0') s++;
  925. char *r = strdupz(s);
  926. netdata_fix_chart_name(r);
  927. return r;
  928. }
  929. static inline char *cgroup_chart_id_strdupz(const char *s) {
  930. if(!s || !*s) s = "/";
  931. if(*s == '/' && s[1] != '\0') s++;
  932. char *r = strdupz(s);
  933. netdata_fix_chart_id(r);
  934. return r;
  935. }
  936. static inline void cgroup_get_chart_name(struct cgroup *cg) {
  937. debug(D_CGROUP, "looking for the name of cgroup '%s' with chart id '%s' and title '%s'", cg->id, cg->chart_id, cg->chart_title);
  938. pid_t cgroup_pid;
  939. char command[CGROUP_CHARTID_LINE_MAX + 1];
  940. snprintfz(command, CGROUP_CHARTID_LINE_MAX, "exec %s '%s'", cgroups_rename_script, cg->chart_id);
  941. debug(D_CGROUP, "executing command \"%s\" for cgroup '%s'", command, cg->chart_id);
  942. FILE *fp = mypopen(command, &cgroup_pid);
  943. if(fp) {
  944. // debug(D_CGROUP, "reading from command '%s' for cgroup '%s'", command, cg->id);
  945. char buffer[CGROUP_CHARTID_LINE_MAX + 1];
  946. char *s = fgets(buffer, CGROUP_CHARTID_LINE_MAX, fp);
  947. // debug(D_CGROUP, "closing command for cgroup '%s'", cg->id);
  948. int name_error = mypclose(fp, cgroup_pid);
  949. // debug(D_CGROUP, "closed command for cgroup '%s'", cg->id);
  950. if(s && *s && *s != '\n') {
  951. debug(D_CGROUP, "cgroup '%s' should be renamed to '%s'", cg->chart_id, s);
  952. s = trim(s);
  953. if (s) {
  954. if(likely(name_error==0))
  955. cg->pending_renames = 0;
  956. else if (unlikely(name_error==3)) {
  957. debug(D_CGROUP, "cgroup '%s' disabled based due to rename command output", cg->chart_id);
  958. cg->enabled = 0;
  959. }
  960. if(likely(cg->pending_renames < 2)) {
  961. freez(cg->chart_title);
  962. cg->chart_title = cgroup_title_strdupz(s);
  963. freez(cg->chart_id);
  964. cg->chart_id = cgroup_chart_id_strdupz(s);
  965. cg->hash_chart = simple_hash(cg->chart_id);
  966. }
  967. }
  968. }
  969. }
  970. else
  971. error("CGROUP: cannot popen(\"%s\", \"r\").", command);
  972. }
  973. static inline struct cgroup *cgroup_add(const char *id) {
  974. if(!id || !*id) id = "/";
  975. debug(D_CGROUP, "adding to list, cgroup with id '%s'", id);
  976. if(cgroup_root_count >= cgroup_root_max) {
  977. info("CGROUP: maximum number of cgroups reached (%d). Not adding cgroup '%s'", cgroup_root_count, id);
  978. return NULL;
  979. }
  980. int def = simple_pattern_matches(enabled_cgroup_patterns, id)?cgroup_enable_new_cgroups_detected_at_runtime:0;
  981. struct cgroup *cg = callocz(1, sizeof(struct cgroup));
  982. cg->id = strdupz(id);
  983. cg->hash = simple_hash(cg->id);
  984. cg->chart_title = cgroup_title_strdupz(id);
  985. cg->chart_id = cgroup_chart_id_strdupz(id);
  986. cg->hash_chart = simple_hash(cg->chart_id);
  987. if(cgroup_use_unified_cgroups) cg->options |= CGROUP_OPTIONS_IS_UNIFIED;
  988. if(!cgroup_root)
  989. cgroup_root = cg;
  990. else {
  991. // append it
  992. struct cgroup *e;
  993. for(e = cgroup_root; e->next ;e = e->next) ;
  994. e->next = cg;
  995. }
  996. cgroup_root_count++;
  997. // fix the chart_id and title by calling the external script
  998. if(simple_pattern_matches(enabled_cgroup_renames, cg->id)) {
  999. cg->pending_renames = 2;
  1000. cgroup_get_chart_name(cg);
  1001. debug(D_CGROUP, "cgroup '%s' renamed to '%s' (title: '%s')", cg->id, cg->chart_id, cg->chart_title);
  1002. }
  1003. else
  1004. debug(D_CGROUP, "cgroup '%s' will not be renamed - it matches the list of disabled cgroup renames (will be shown as '%s')", cg->id, cg->chart_id);
  1005. int user_configurable = 1;
  1006. // check if this cgroup should be a systemd service
  1007. if(cgroup_enable_systemd_services) {
  1008. if(simple_pattern_matches(systemd_services_cgroups, cg->id) ||
  1009. simple_pattern_matches(systemd_services_cgroups, cg->chart_id)) {
  1010. debug(D_CGROUP, "cgroup '%s' with chart id '%s' (title: '%s') matches systemd services cgroups", cg->id, cg->chart_id, cg->chart_title);
  1011. char buffer[CGROUP_CHARTID_LINE_MAX + 1];
  1012. cg->options |= CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE;
  1013. strncpy(buffer, cg->id, CGROUP_CHARTID_LINE_MAX);
  1014. char *s = buffer;
  1015. //freez(cg->chart_id);
  1016. //cg->chart_id = cgroup_chart_id_strdupz(s);
  1017. //cg->hash_chart = simple_hash(cg->chart_id);
  1018. // skip to the last slash
  1019. size_t len = strlen(s);
  1020. while(len--) if(unlikely(s[len] == '/')) break;
  1021. if(len) s = &s[len + 1];
  1022. // remove extension
  1023. len = strlen(s);
  1024. while(len--) if(unlikely(s[len] == '.')) break;
  1025. if(len) s[len] = '\0';
  1026. freez(cg->chart_title);
  1027. cg->chart_title = cgroup_title_strdupz(s);
  1028. cg->enabled = 1;
  1029. user_configurable = 0;
  1030. debug(D_CGROUP, "cgroup '%s' renamed to '%s' (title: '%s')", cg->id, cg->chart_id, cg->chart_title);
  1031. }
  1032. else
  1033. debug(D_CGROUP, "cgroup '%s' with chart id '%s' (title: '%s') does not match systemd services groups", cg->id, cg->chart_id, cg->chart_title);
  1034. }
  1035. if(user_configurable) {
  1036. // allow the user to enable/disable this individualy
  1037. char option[FILENAME_MAX + 1];
  1038. snprintfz(option, FILENAME_MAX, "enable cgroup %s", cg->chart_title);
  1039. cg->enabled = (char) config_get_boolean("plugin:cgroups", option, def);
  1040. }
  1041. // detect duplicate cgroups
  1042. if(cg->enabled) {
  1043. struct cgroup *t;
  1044. for (t = cgroup_root; t; t = t->next) {
  1045. if (t != cg && t->enabled && t->hash_chart == cg->hash_chart && !strcmp(t->chart_id, cg->chart_id)) {
  1046. if (!strncmp(t->chart_id, "/system.slice/", 14) && !strncmp(cg->chart_id, "/init.scope/system.slice/", 25)) {
  1047. error("CGROUP: chart id '%s' already exists with id '%s' and is enabled. Swapping them by enabling cgroup with id '%s' and disabling cgroup with id '%s'.",
  1048. cg->chart_id, t->id, cg->id, t->id);
  1049. debug(D_CGROUP, "Control group with chart id '%s' already exists with id '%s' and is enabled. Swapping them by enabling cgroup with id '%s' and disabling cgroup with id '%s'.",
  1050. cg->chart_id, t->id, cg->id, t->id);
  1051. t->enabled = 0;
  1052. t->options |= CGROUP_OPTIONS_DISABLED_DUPLICATE;
  1053. }
  1054. else {
  1055. error("CGROUP: chart id '%s' already exists with id '%s' and is enabled and available. Disabling cgroup with id '%s'.",
  1056. cg->chart_id, t->id, cg->id);
  1057. debug(D_CGROUP, "Control group with chart id '%s' already exists with id '%s' and is enabled and available. Disabling cgroup with id '%s'.",
  1058. cg->chart_id, t->id, cg->id);
  1059. cg->enabled = 0;
  1060. cg->options |= CGROUP_OPTIONS_DISABLED_DUPLICATE;
  1061. }
  1062. break;
  1063. }
  1064. }
  1065. }
  1066. if(cg->enabled && !cg->pending_renames && !(cg->options & CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE))
  1067. read_cgroup_network_interfaces(cg);
  1068. debug(D_CGROUP, "ADDED CGROUP: '%s' with chart id '%s' and title '%s' as %s (default was %s)", cg->id, cg->chart_id, cg->chart_title, (cg->enabled)?"enabled":"disabled", (def)?"enabled":"disabled");
  1069. return cg;
  1070. }
  1071. static inline void free_pressure(struct pressure *res) {
  1072. if (res->some.st) rrdset_is_obsolete(res->some.st);
  1073. if (res->full.st) rrdset_is_obsolete(res->full.st);
  1074. freez(res->filename);
  1075. }
  1076. static inline void cgroup_free(struct cgroup *cg) {
  1077. debug(D_CGROUP, "Removing cgroup '%s' with chart id '%s' (was %s and %s)", cg->id, cg->chart_id, (cg->enabled)?"enabled":"disabled", (cg->available)?"available":"not available");
  1078. if(cg->st_cpu) rrdset_is_obsolete(cg->st_cpu);
  1079. if(cg->st_cpu_limit) rrdset_is_obsolete(cg->st_cpu_limit);
  1080. if(cg->st_cpu_per_core) rrdset_is_obsolete(cg->st_cpu_per_core);
  1081. if(cg->st_mem) rrdset_is_obsolete(cg->st_mem);
  1082. if(cg->st_writeback) rrdset_is_obsolete(cg->st_writeback);
  1083. if(cg->st_mem_activity) rrdset_is_obsolete(cg->st_mem_activity);
  1084. if(cg->st_pgfaults) rrdset_is_obsolete(cg->st_pgfaults);
  1085. if(cg->st_mem_usage) rrdset_is_obsolete(cg->st_mem_usage);
  1086. if(cg->st_mem_usage_limit) rrdset_is_obsolete(cg->st_mem_usage_limit);
  1087. if(cg->st_mem_failcnt) rrdset_is_obsolete(cg->st_mem_failcnt);
  1088. if(cg->st_io) rrdset_is_obsolete(cg->st_io);
  1089. if(cg->st_serviced_ops) rrdset_is_obsolete(cg->st_serviced_ops);
  1090. if(cg->st_throttle_io) rrdset_is_obsolete(cg->st_throttle_io);
  1091. if(cg->st_throttle_serviced_ops) rrdset_is_obsolete(cg->st_throttle_serviced_ops);
  1092. if(cg->st_queued_ops) rrdset_is_obsolete(cg->st_queued_ops);
  1093. if(cg->st_merged_ops) rrdset_is_obsolete(cg->st_merged_ops);
  1094. freez(cg->filename_cpuset_cpus);
  1095. freez(cg->filename_cpu_cfs_period);
  1096. freez(cg->filename_cpu_cfs_quota);
  1097. freez(cg->filename_memory_limit);
  1098. freez(cg->filename_memoryswap_limit);
  1099. free_cgroup_network_interfaces(cg);
  1100. freez(cg->cpuacct_usage.cpu_percpu);
  1101. freez(cg->cpuacct_stat.filename);
  1102. freez(cg->cpuacct_usage.filename);
  1103. arl_free(cg->memory.arl_base);
  1104. freez(cg->memory.filename_detailed);
  1105. freez(cg->memory.filename_failcnt);
  1106. freez(cg->memory.filename_usage_in_bytes);
  1107. freez(cg->memory.filename_msw_usage_in_bytes);
  1108. freez(cg->io_service_bytes.filename);
  1109. freez(cg->io_serviced.filename);
  1110. freez(cg->throttle_io_service_bytes.filename);
  1111. freez(cg->throttle_io_serviced.filename);
  1112. freez(cg->io_merged.filename);
  1113. freez(cg->io_queued.filename);
  1114. free_pressure(&cg->cpu_pressure);
  1115. free_pressure(&cg->io_pressure);
  1116. free_pressure(&cg->memory_pressure);
  1117. freez(cg->id);
  1118. freez(cg->chart_id);
  1119. freez(cg->chart_title);
  1120. freez(cg);
  1121. cgroup_root_count--;
  1122. }
  1123. // find if a given cgroup exists
  1124. static inline struct cgroup *cgroup_find(const char *id) {
  1125. debug(D_CGROUP, "searching for cgroup '%s'", id);
  1126. uint32_t hash = simple_hash(id);
  1127. struct cgroup *cg;
  1128. for(cg = cgroup_root; cg ; cg = cg->next) {
  1129. if(hash == cg->hash && strcmp(id, cg->id) == 0)
  1130. break;
  1131. }
  1132. debug(D_CGROUP, "cgroup '%s' %s in memory", id, (cg)?"found":"not found");
  1133. return cg;
  1134. }
  1135. // ----------------------------------------------------------------------------
  1136. // detect running cgroups
  1137. // callback for find_file_in_subdirs()
  1138. static inline void found_subdir_in_dir(const char *dir) {
  1139. debug(D_CGROUP, "examining cgroup dir '%s'", dir);
  1140. struct cgroup *cg = cgroup_find(dir);
  1141. if(!cg) {
  1142. if(*dir && cgroup_max_depth > 0) {
  1143. int depth = 0;
  1144. const char *s;
  1145. for(s = dir; *s ;s++)
  1146. if(unlikely(*s == '/'))
  1147. depth++;
  1148. if(depth > cgroup_max_depth) {
  1149. info("CGROUP: '%s' is too deep (%d, while max is %d)", dir, depth, cgroup_max_depth);
  1150. return;
  1151. }
  1152. }
  1153. // debug(D_CGROUP, "will add dir '%s' as cgroup", dir);
  1154. cg = cgroup_add(dir);
  1155. }
  1156. if(cg) {
  1157. // delay renaming of the cgroup and looking for network interfaces to deal with the docker lag when starting the container
  1158. if(unlikely(cg->pending_renames == 1)) {
  1159. // fix the chart_id and title by calling the external script
  1160. if(simple_pattern_matches(enabled_cgroup_renames, cg->id)) {
  1161. cgroup_get_chart_name(cg);
  1162. cg->pending_renames = 0;
  1163. if(cg->enabled && !(cg->options & CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE))
  1164. read_cgroup_network_interfaces(cg);
  1165. debug(D_CGROUP, "cgroup '%s' renamed to '%s' (title: '%s')", cg->id, cg->chart_id, cg->chart_title);
  1166. }
  1167. else
  1168. debug(D_CGROUP, "cgroup '%s' will not be renamed - it matches the list of disabled cgroup renames (will be shown as '%s')", cg->id, cg->chart_id);
  1169. }
  1170. cg->available = 1;
  1171. }
  1172. }
  1173. static inline int find_dir_in_subdirs(const char *base, const char *this, void (*callback)(const char *)) {
  1174. if(!this) this = base;
  1175. debug(D_CGROUP, "searching for directories in '%s' (base '%s')", this?this:"", base);
  1176. size_t dirlen = strlen(this), baselen = strlen(base);
  1177. int ret = -1;
  1178. int enabled = -1;
  1179. const char *relative_path = &this[baselen];
  1180. if(!*relative_path) relative_path = "/";
  1181. DIR *dir = opendir(this);
  1182. if(!dir) {
  1183. error("CGROUP: cannot read directory '%s'", base);
  1184. return ret;
  1185. }
  1186. ret = 1;
  1187. callback(relative_path);
  1188. struct dirent *de = NULL;
  1189. while((de = readdir(dir))) {
  1190. if(de->d_type == DT_DIR
  1191. && (
  1192. (de->d_name[0] == '.' && de->d_name[1] == '\0')
  1193. || (de->d_name[0] == '.' && de->d_name[1] == '.' && de->d_name[2] == '\0')
  1194. ))
  1195. continue;
  1196. if(de->d_type == DT_DIR) {
  1197. if(enabled == -1) {
  1198. const char *r = relative_path;
  1199. if(*r == '\0') r = "/";
  1200. // do not decent in directories we are not interested
  1201. int def = simple_pattern_matches(enabled_cgroup_paths, r);
  1202. // we check for this option here
  1203. // so that the config will not have settings
  1204. // for leaf directories
  1205. char option[FILENAME_MAX + 1];
  1206. snprintfz(option, FILENAME_MAX, "search for cgroups under %s", r);
  1207. option[FILENAME_MAX] = '\0';
  1208. enabled = config_get_boolean("plugin:cgroups", option, def);
  1209. }
  1210. if(enabled) {
  1211. char *s = mallocz(dirlen + strlen(de->d_name) + 2);
  1212. strcpy(s, this);
  1213. strcat(s, "/");
  1214. strcat(s, de->d_name);
  1215. int ret2 = find_dir_in_subdirs(base, s, callback);
  1216. if(ret2 > 0) ret += ret2;
  1217. freez(s);
  1218. }
  1219. }
  1220. }
  1221. closedir(dir);
  1222. return ret;
  1223. }
  1224. static inline void mark_all_cgroups_as_not_available() {
  1225. debug(D_CGROUP, "marking all cgroups as not available");
  1226. struct cgroup *cg;
  1227. // mark all as not available
  1228. for(cg = cgroup_root; cg ; cg = cg->next) {
  1229. cg->available = 0;
  1230. }
  1231. }
  1232. static inline void cleanup_all_cgroups() {
  1233. struct cgroup *cg = cgroup_root, *last = NULL;
  1234. for(; cg ;) {
  1235. if(!cg->available) {
  1236. // enable the first duplicate cgroup
  1237. {
  1238. struct cgroup *t;
  1239. for(t = cgroup_root; t ; t = t->next) {
  1240. if(t != cg && t->available && !t->enabled && t->options & CGROUP_OPTIONS_DISABLED_DUPLICATE && t->hash_chart == cg->hash_chart && !strcmp(t->chart_id, cg->chart_id)) {
  1241. debug(D_CGROUP, "Enabling duplicate of cgroup '%s' with id '%s', because the original with id '%s' stopped.", t->chart_id, t->id, cg->id);
  1242. t->enabled = 1;
  1243. t->options &= ~CGROUP_OPTIONS_DISABLED_DUPLICATE;
  1244. break;
  1245. }
  1246. }
  1247. }
  1248. if(!last)
  1249. cgroup_root = cg->next;
  1250. else
  1251. last->next = cg->next;
  1252. cgroup_free(cg);
  1253. if(!last)
  1254. cg = cgroup_root;
  1255. else
  1256. cg = last->next;
  1257. }
  1258. else {
  1259. last = cg;
  1260. cg = cg->next;
  1261. }
  1262. }
  1263. }
  1264. static inline void find_all_cgroups() {
  1265. debug(D_CGROUP, "searching for cgroups");
  1266. mark_all_cgroups_as_not_available();
  1267. if(!cgroup_use_unified_cgroups) {
  1268. if(cgroup_enable_cpuacct_stat || cgroup_enable_cpuacct_usage) {
  1269. if(find_dir_in_subdirs(cgroup_cpuacct_base, NULL, found_subdir_in_dir) == -1) {
  1270. cgroup_enable_cpuacct_stat =
  1271. cgroup_enable_cpuacct_usage = CONFIG_BOOLEAN_NO;
  1272. error("CGROUP: disabled cpu statistics.");
  1273. }
  1274. }
  1275. if(cgroup_enable_blkio_io || cgroup_enable_blkio_ops || cgroup_enable_blkio_throttle_io || cgroup_enable_blkio_throttle_ops || cgroup_enable_blkio_merged_ops || cgroup_enable_blkio_queued_ops) {
  1276. if(find_dir_in_subdirs(cgroup_blkio_base, NULL, found_subdir_in_dir) == -1) {
  1277. cgroup_enable_blkio_io =
  1278. cgroup_enable_blkio_ops =
  1279. cgroup_enable_blkio_throttle_io =
  1280. cgroup_enable_blkio_throttle_ops =
  1281. cgroup_enable_blkio_merged_ops =
  1282. cgroup_enable_blkio_queued_ops = CONFIG_BOOLEAN_NO;
  1283. error("CGROUP: disabled blkio statistics.");
  1284. }
  1285. }
  1286. if(cgroup_enable_memory || cgroup_enable_detailed_memory || cgroup_enable_swap || cgroup_enable_memory_failcnt) {
  1287. if(find_dir_in_subdirs(cgroup_memory_base, NULL, found_subdir_in_dir) == -1) {
  1288. cgroup_enable_memory =
  1289. cgroup_enable_detailed_memory =
  1290. cgroup_enable_swap =
  1291. cgroup_enable_memory_failcnt = CONFIG_BOOLEAN_NO;
  1292. error("CGROUP: disabled memory statistics.");
  1293. }
  1294. }
  1295. if(cgroup_search_in_devices) {
  1296. if(find_dir_in_subdirs(cgroup_devices_base, NULL, found_subdir_in_dir) == -1) {
  1297. cgroup_search_in_devices = 0;
  1298. error("CGROUP: disabled devices statistics.");
  1299. }
  1300. }
  1301. }
  1302. else {
  1303. if (find_dir_in_subdirs(cgroup_unified_base, NULL, found_subdir_in_dir) == -1) {
  1304. cgroup_unified_exist = CONFIG_BOOLEAN_NO;
  1305. error("CGROUP: disabled unified cgroups statistics.");
  1306. }
  1307. }
  1308. // remove any non-existing cgroups
  1309. cleanup_all_cgroups();
  1310. struct cgroup *cg;
  1311. struct stat buf;
  1312. for(cg = cgroup_root; cg ; cg = cg->next) {
  1313. // fprintf(stderr, " >>> CGROUP '%s' (%u - %s) with name '%s'\n", cg->id, cg->hash, cg->available?"available":"stopped", cg->name);
  1314. if(unlikely(cg->pending_renames))
  1315. cg->pending_renames--;
  1316. if(unlikely(!cg->available || cg->pending_renames))
  1317. continue;
  1318. debug(D_CGROUP, "checking paths for cgroup '%s'", cg->id);
  1319. // check for newly added cgroups
  1320. // and update the filenames they read
  1321. char filename[FILENAME_MAX + 1];
  1322. if(!cgroup_use_unified_cgroups) {
  1323. if(unlikely(cgroup_enable_cpuacct_stat && !cg->cpuacct_stat.filename)) {
  1324. snprintfz(filename, FILENAME_MAX, "%s%s/cpuacct.stat", cgroup_cpuacct_base, cg->id);
  1325. if(likely(stat(filename, &buf) != -1)) {
  1326. cg->cpuacct_stat.filename = strdupz(filename);
  1327. cg->cpuacct_stat.enabled = cgroup_enable_cpuacct_stat;
  1328. snprintfz(filename, FILENAME_MAX, "%s%s/cpuset.cpus", cgroup_cpuset_base, cg->id);
  1329. cg->filename_cpuset_cpus = strdupz(filename);
  1330. snprintfz(filename, FILENAME_MAX, "%s%s/cpu.cfs_period_us", cgroup_cpuacct_base, cg->id);
  1331. cg->filename_cpu_cfs_period = strdupz(filename);
  1332. snprintfz(filename, FILENAME_MAX, "%s%s/cpu.cfs_quota_us", cgroup_cpuacct_base, cg->id);
  1333. cg->filename_cpu_cfs_quota = strdupz(filename);
  1334. debug(D_CGROUP, "cpuacct.stat filename for cgroup '%s': '%s'", cg->id, cg->cpuacct_stat.filename);
  1335. }
  1336. else
  1337. debug(D_CGROUP, "cpuacct.stat file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1338. }
  1339. if(unlikely(cgroup_enable_cpuacct_usage && !cg->cpuacct_usage.filename && !(cg->options & CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE))) {
  1340. snprintfz(filename, FILENAME_MAX, "%s%s/cpuacct.usage_percpu", cgroup_cpuacct_base, cg->id);
  1341. if(likely(stat(filename, &buf) != -1)) {
  1342. cg->cpuacct_usage.filename = strdupz(filename);
  1343. cg->cpuacct_usage.enabled = cgroup_enable_cpuacct_usage;
  1344. debug(D_CGROUP, "cpuacct.usage_percpu filename for cgroup '%s': '%s'", cg->id, cg->cpuacct_usage.filename);
  1345. }
  1346. else
  1347. debug(D_CGROUP, "cpuacct.usage_percpu file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1348. }
  1349. if(unlikely((cgroup_enable_detailed_memory || cgroup_used_memory_without_cache) && !cg->memory.filename_detailed && (cgroup_used_memory_without_cache || cgroup_enable_systemd_services_detailed_memory || !(cg->options & CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE)))) {
  1350. snprintfz(filename, FILENAME_MAX, "%s%s/memory.stat", cgroup_memory_base, cg->id);
  1351. if(likely(stat(filename, &buf) != -1)) {
  1352. cg->memory.filename_detailed = strdupz(filename);
  1353. cg->memory.enabled_detailed = (cgroup_enable_detailed_memory == CONFIG_BOOLEAN_YES)?CONFIG_BOOLEAN_YES:CONFIG_BOOLEAN_AUTO;
  1354. debug(D_CGROUP, "memory.stat filename for cgroup '%s': '%s'", cg->id, cg->memory.filename_detailed);
  1355. }
  1356. else
  1357. debug(D_CGROUP, "memory.stat file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1358. }
  1359. if(unlikely(cgroup_enable_memory && !cg->memory.filename_usage_in_bytes)) {
  1360. snprintfz(filename, FILENAME_MAX, "%s%s/memory.usage_in_bytes", cgroup_memory_base, cg->id);
  1361. if(likely(stat(filename, &buf) != -1)) {
  1362. cg->memory.filename_usage_in_bytes = strdupz(filename);
  1363. cg->memory.enabled_usage_in_bytes = cgroup_enable_memory;
  1364. debug(D_CGROUP, "memory.usage_in_bytes filename for cgroup '%s': '%s'", cg->id, cg->memory.filename_usage_in_bytes);
  1365. snprintfz(filename, FILENAME_MAX, "%s%s/memory.limit_in_bytes", cgroup_memory_base, cg->id);
  1366. cg->filename_memory_limit = strdupz(filename);
  1367. }
  1368. else
  1369. debug(D_CGROUP, "memory.usage_in_bytes file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1370. }
  1371. if(unlikely(cgroup_enable_swap && !cg->memory.filename_msw_usage_in_bytes)) {
  1372. snprintfz(filename, FILENAME_MAX, "%s%s/memory.memsw.usage_in_bytes", cgroup_memory_base, cg->id);
  1373. if(likely(stat(filename, &buf) != -1)) {
  1374. cg->memory.filename_msw_usage_in_bytes = strdupz(filename);
  1375. cg->memory.enabled_msw_usage_in_bytes = cgroup_enable_swap;
  1376. snprintfz(filename, FILENAME_MAX, "%s%s/memory.memsw.limit_in_bytes", cgroup_memory_base, cg->id);
  1377. cg->filename_memoryswap_limit = strdupz(filename);
  1378. debug(D_CGROUP, "memory.msw_usage_in_bytes filename for cgroup '%s': '%s'", cg->id, cg->memory.filename_msw_usage_in_bytes);
  1379. }
  1380. else
  1381. debug(D_CGROUP, "memory.msw_usage_in_bytes file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1382. }
  1383. if(unlikely(cgroup_enable_memory_failcnt && !cg->memory.filename_failcnt)) {
  1384. snprintfz(filename, FILENAME_MAX, "%s%s/memory.failcnt", cgroup_memory_base, cg->id);
  1385. if(likely(stat(filename, &buf) != -1)) {
  1386. cg->memory.filename_failcnt = strdupz(filename);
  1387. cg->memory.enabled_failcnt = cgroup_enable_memory_failcnt;
  1388. debug(D_CGROUP, "memory.failcnt filename for cgroup '%s': '%s'", cg->id, cg->memory.filename_failcnt);
  1389. }
  1390. else
  1391. debug(D_CGROUP, "memory.failcnt file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1392. }
  1393. if(unlikely(cgroup_enable_blkio_io && !cg->io_service_bytes.filename)) {
  1394. snprintfz(filename, FILENAME_MAX, "%s%s/blkio.io_service_bytes", cgroup_blkio_base, cg->id);
  1395. if(likely(stat(filename, &buf) != -1)) {
  1396. cg->io_service_bytes.filename = strdupz(filename);
  1397. cg->io_service_bytes.enabled = cgroup_enable_blkio_io;
  1398. debug(D_CGROUP, "io_service_bytes filename for cgroup '%s': '%s'", cg->id, cg->io_service_bytes.filename);
  1399. }
  1400. else
  1401. debug(D_CGROUP, "io_service_bytes file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1402. }
  1403. if(unlikely(cgroup_enable_blkio_ops && !cg->io_serviced.filename)) {
  1404. snprintfz(filename, FILENAME_MAX, "%s%s/blkio.io_serviced", cgroup_blkio_base, cg->id);
  1405. if(likely(stat(filename, &buf) != -1)) {
  1406. cg->io_serviced.filename = strdupz(filename);
  1407. cg->io_serviced.enabled = cgroup_enable_blkio_ops;
  1408. debug(D_CGROUP, "io_serviced filename for cgroup '%s': '%s'", cg->id, cg->io_serviced.filename);
  1409. }
  1410. else
  1411. debug(D_CGROUP, "io_serviced file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1412. }
  1413. if(unlikely(cgroup_enable_blkio_throttle_io && !cg->throttle_io_service_bytes.filename)) {
  1414. snprintfz(filename, FILENAME_MAX, "%s%s/blkio.throttle.io_service_bytes", cgroup_blkio_base, cg->id);
  1415. if(likely(stat(filename, &buf) != -1)) {
  1416. cg->throttle_io_service_bytes.filename = strdupz(filename);
  1417. cg->throttle_io_service_bytes.enabled = cgroup_enable_blkio_throttle_io;
  1418. debug(D_CGROUP, "throttle_io_service_bytes filename for cgroup '%s': '%s'", cg->id, cg->throttle_io_service_bytes.filename);
  1419. }
  1420. else
  1421. debug(D_CGROUP, "throttle_io_service_bytes file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1422. }
  1423. if(unlikely(cgroup_enable_blkio_throttle_ops && !cg->throttle_io_serviced.filename)) {
  1424. snprintfz(filename, FILENAME_MAX, "%s%s/blkio.throttle.io_serviced", cgroup_blkio_base, cg->id);
  1425. if(likely(stat(filename, &buf) != -1)) {
  1426. cg->throttle_io_serviced.filename = strdupz(filename);
  1427. cg->throttle_io_serviced.enabled = cgroup_enable_blkio_throttle_ops;
  1428. debug(D_CGROUP, "throttle_io_serviced filename for cgroup '%s': '%s'", cg->id, cg->throttle_io_serviced.filename);
  1429. }
  1430. else
  1431. debug(D_CGROUP, "throttle_io_serviced file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1432. }
  1433. if(unlikely(cgroup_enable_blkio_merged_ops && !cg->io_merged.filename)) {
  1434. snprintfz(filename, FILENAME_MAX, "%s%s/blkio.io_merged", cgroup_blkio_base, cg->id);
  1435. if(likely(stat(filename, &buf) != -1)) {
  1436. cg->io_merged.filename = strdupz(filename);
  1437. cg->io_merged.enabled = cgroup_enable_blkio_merged_ops;
  1438. debug(D_CGROUP, "io_merged filename for cgroup '%s': '%s'", cg->id, cg->io_merged.filename);
  1439. }
  1440. else
  1441. debug(D_CGROUP, "io_merged file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1442. }
  1443. if(unlikely(cgroup_enable_blkio_queued_ops && !cg->io_queued.filename)) {
  1444. snprintfz(filename, FILENAME_MAX, "%s%s/blkio.io_queued", cgroup_blkio_base, cg->id);
  1445. if(likely(stat(filename, &buf) != -1)) {
  1446. cg->io_queued.filename = strdupz(filename);
  1447. cg->io_queued.enabled = cgroup_enable_blkio_queued_ops;
  1448. debug(D_CGROUP, "io_queued filename for cgroup '%s': '%s'", cg->id, cg->io_queued.filename);
  1449. }
  1450. else
  1451. debug(D_CGROUP, "io_queued file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1452. }
  1453. }
  1454. else if(likely(cgroup_unified_exist)) {
  1455. if(unlikely(cgroup_enable_blkio_io && !cg->io_service_bytes.filename)) {
  1456. snprintfz(filename, FILENAME_MAX, "%s%s/io.stat", cgroup_unified_base, cg->id);
  1457. if(likely(stat(filename, &buf) != -1)) {
  1458. cg->io_service_bytes.filename = strdupz(filename);
  1459. cg->io_service_bytes.enabled = cgroup_enable_blkio_io;
  1460. debug(D_CGROUP, "io.stat filename for unified cgroup '%s': '%s'", cg->id, cg->io_service_bytes.filename);
  1461. } else
  1462. debug(D_CGROUP, "io.stat file for unified cgroup '%s': '%s' does not exist.", cg->id, filename);
  1463. }
  1464. if (unlikely(cgroup_enable_blkio_ops && !cg->io_serviced.filename)) {
  1465. snprintfz(filename, FILENAME_MAX, "%s%s/io.stat", cgroup_unified_base, cg->id);
  1466. if (likely(stat(filename, &buf) != -1)) {
  1467. cg->io_serviced.filename = strdupz(filename);
  1468. cg->io_serviced.enabled = cgroup_enable_blkio_ops;
  1469. debug(D_CGROUP, "io.stat filename for unified cgroup '%s': '%s'", cg->id, cg->io_service_bytes.filename);
  1470. } else
  1471. debug(D_CGROUP, "io.stat file for unified cgroup '%s': '%s' does not exist.", cg->id, filename);
  1472. }
  1473. if(unlikely(cgroup_enable_cpuacct_stat && !cg->cpuacct_stat.filename)) {
  1474. snprintfz(filename, FILENAME_MAX, "%s%s/cpu.stat", cgroup_unified_base, cg->id);
  1475. if(likely(stat(filename, &buf) != -1)) {
  1476. cg->cpuacct_stat.filename = strdupz(filename);
  1477. cg->cpuacct_stat.enabled = cgroup_enable_cpuacct_stat;
  1478. cg->filename_cpuset_cpus = NULL;
  1479. cg->filename_cpu_cfs_period = NULL;
  1480. snprintfz(filename, FILENAME_MAX, "%s%s/cpu.max", cgroup_unified_base, cg->id);
  1481. cg->filename_cpu_cfs_quota = strdupz(filename);
  1482. debug(D_CGROUP, "cpu.stat filename for unified cgroup '%s': '%s'", cg->id, cg->cpuacct_stat.filename);
  1483. }
  1484. else
  1485. debug(D_CGROUP, "cpu.stat file for unified cgroup '%s': '%s' does not exist.", cg->id, filename);
  1486. }
  1487. if(unlikely((cgroup_enable_detailed_memory || cgroup_used_memory_without_cache) && !cg->memory.filename_detailed && (cgroup_used_memory_without_cache || cgroup_enable_systemd_services_detailed_memory || !(cg->options & CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE)))) {
  1488. snprintfz(filename, FILENAME_MAX, "%s%s/memory.stat", cgroup_unified_base, cg->id);
  1489. if(likely(stat(filename, &buf) != -1)) {
  1490. cg->memory.filename_detailed = strdupz(filename);
  1491. cg->memory.enabled_detailed = (cgroup_enable_detailed_memory == CONFIG_BOOLEAN_YES)?CONFIG_BOOLEAN_YES:CONFIG_BOOLEAN_AUTO;
  1492. debug(D_CGROUP, "memory.stat filename for cgroup '%s': '%s'", cg->id, cg->memory.filename_detailed);
  1493. }
  1494. else
  1495. debug(D_CGROUP, "memory.stat file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1496. }
  1497. if(unlikely(cgroup_enable_memory && !cg->memory.filename_usage_in_bytes)) {
  1498. snprintfz(filename, FILENAME_MAX, "%s%s/memory.current", cgroup_unified_base, cg->id);
  1499. if(likely(stat(filename, &buf) != -1)) {
  1500. cg->memory.filename_usage_in_bytes = strdupz(filename);
  1501. cg->memory.enabled_usage_in_bytes = cgroup_enable_memory;
  1502. debug(D_CGROUP, "memory.current filename for cgroup '%s': '%s'", cg->id, cg->memory.filename_usage_in_bytes);
  1503. snprintfz(filename, FILENAME_MAX, "%s%s/memory.max", cgroup_unified_base, cg->id);
  1504. cg->filename_memory_limit = strdupz(filename);
  1505. }
  1506. else
  1507. debug(D_CGROUP, "memory.current file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1508. }
  1509. if(unlikely(cgroup_enable_swap && !cg->memory.filename_msw_usage_in_bytes)) {
  1510. snprintfz(filename, FILENAME_MAX, "%s%s/memory.swap.current", cgroup_unified_base, cg->id);
  1511. if(likely(stat(filename, &buf) != -1)) {
  1512. cg->memory.filename_msw_usage_in_bytes = strdupz(filename);
  1513. cg->memory.enabled_msw_usage_in_bytes = cgroup_enable_swap;
  1514. snprintfz(filename, FILENAME_MAX, "%s%s/memory.swap.max", cgroup_unified_base, cg->id);
  1515. cg->filename_memoryswap_limit = strdupz(filename);
  1516. debug(D_CGROUP, "memory.swap.current filename for cgroup '%s': '%s'", cg->id, cg->memory.filename_msw_usage_in_bytes);
  1517. }
  1518. else
  1519. debug(D_CGROUP, "memory.swap file for cgroup '%s': '%s' does not exist.", cg->id, filename);
  1520. }
  1521. if (unlikely(cgroup_enable_pressure_cpu && !cg->cpu_pressure.filename)) {
  1522. snprintfz(filename, FILENAME_MAX, "%s%s/cpu.pressure", cgroup_unified_base, cg->id);
  1523. if (likely(stat(filename, &buf) != -1)) {
  1524. cg->cpu_pressure.filename = strdupz(filename);
  1525. cg->cpu_pressure.some.enabled = cgroup_enable_pressure_cpu;
  1526. cg->cpu_pressure.full.enabled = CONFIG_BOOLEAN_NO;
  1527. debug(D_CGROUP, "cpu.pressure filename for cgroup '%s': '%s'", cg->id, cg->cpu_pressure.filename);
  1528. } else {
  1529. debug(D_CGROUP, "cpu.pressure file for cgroup '%s': '%s' does not exist", cg->id, filename);
  1530. }
  1531. }
  1532. if (unlikely((cgroup_enable_pressure_io_some || cgroup_enable_pressure_io_full) && !cg->io_pressure.filename)) {
  1533. snprintfz(filename, FILENAME_MAX, "%s%s/io.pressure", cgroup_unified_base, cg->id);
  1534. if (likely(stat(filename, &buf) != -1)) {
  1535. cg->io_pressure.filename = strdupz(filename);
  1536. cg->io_pressure.some.enabled = cgroup_enable_pressure_io_some;
  1537. cg->io_pressure.full.enabled = cgroup_enable_pressure_io_full;
  1538. debug(D_CGROUP, "io.pressure filename for cgroup '%s': '%s'", cg->id, cg->io_pressure.filename);
  1539. } else {
  1540. debug(D_CGROUP, "io.pressure file for cgroup '%s': '%s' does not exist", cg->id, filename);
  1541. }
  1542. }
  1543. if (unlikely((cgroup_enable_pressure_memory_some || cgroup_enable_pressure_memory_full) && !cg->memory_pressure.filename)) {
  1544. snprintfz(filename, FILENAME_MAX, "%s%s/memory.pressure", cgroup_unified_base, cg->id);
  1545. if (likely(stat(filename, &buf) != -1)) {
  1546. cg->memory_pressure.filename = strdupz(filename);
  1547. cg->memory_pressure.some.enabled = cgroup_enable_pressure_memory_some;
  1548. cg->memory_pressure.full.enabled = cgroup_enable_pressure_memory_full;
  1549. debug(D_CGROUP, "memory.pressure filename for cgroup '%s': '%s'", cg->id, cg->memory_pressure.filename);
  1550. } else {
  1551. debug(D_CGROUP, "memory.pressure file for cgroup '%s': '%s' does not exist", cg->id, filename);
  1552. }
  1553. }
  1554. }
  1555. }
  1556. debug(D_CGROUP, "done searching for cgroups");
  1557. }
  1558. // ----------------------------------------------------------------------------
  1559. // generate charts
  1560. #define CHART_TITLE_MAX 300
  1561. void update_systemd_services_charts(
  1562. int update_every
  1563. , int do_cpu
  1564. , int do_mem_usage
  1565. , int do_mem_detailed
  1566. , int do_mem_failcnt
  1567. , int do_swap_usage
  1568. , int do_io
  1569. , int do_io_ops
  1570. , int do_throttle_io
  1571. , int do_throttle_ops
  1572. , int do_queued_ops
  1573. , int do_merged_ops
  1574. ) {
  1575. static RRDSET
  1576. *st_cpu = NULL,
  1577. *st_mem_usage = NULL,
  1578. *st_mem_failcnt = NULL,
  1579. *st_swap_usage = NULL,
  1580. *st_mem_detailed_cache = NULL,
  1581. *st_mem_detailed_rss = NULL,
  1582. *st_mem_detailed_mapped = NULL,
  1583. *st_mem_detailed_writeback = NULL,
  1584. *st_mem_detailed_pgfault = NULL,
  1585. *st_mem_detailed_pgmajfault = NULL,
  1586. *st_mem_detailed_pgpgin = NULL,
  1587. *st_mem_detailed_pgpgout = NULL,
  1588. *st_io_read = NULL,
  1589. *st_io_serviced_read = NULL,
  1590. *st_throttle_io_read = NULL,
  1591. *st_throttle_ops_read = NULL,
  1592. *st_queued_ops_read = NULL,
  1593. *st_merged_ops_read = NULL,
  1594. *st_io_write = NULL,
  1595. *st_io_serviced_write = NULL,
  1596. *st_throttle_io_write = NULL,
  1597. *st_throttle_ops_write = NULL,
  1598. *st_queued_ops_write = NULL,
  1599. *st_merged_ops_write = NULL;
  1600. // create the charts
  1601. if(likely(do_cpu)) {
  1602. if(unlikely(!st_cpu)) {
  1603. char title[CHART_TITLE_MAX + 1];
  1604. snprintfz(title, CHART_TITLE_MAX, "Systemd Services CPU utilization (%d%% = %d core%s)", (processors * 100), processors, (processors > 1) ? "s" : "");
  1605. st_cpu = rrdset_create_localhost(
  1606. "services"
  1607. , "cpu"
  1608. , NULL
  1609. , "cpu"
  1610. , "services.cpu"
  1611. , title
  1612. , "percentage"
  1613. , PLUGIN_CGROUPS_NAME
  1614. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1615. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD
  1616. , update_every
  1617. , RRDSET_TYPE_STACKED
  1618. );
  1619. }
  1620. else
  1621. rrdset_next(st_cpu);
  1622. }
  1623. if(likely(do_mem_usage)) {
  1624. if(unlikely(!st_mem_usage)) {
  1625. st_mem_usage = rrdset_create_localhost(
  1626. "services"
  1627. , "mem_usage"
  1628. , NULL
  1629. , "mem"
  1630. , "services.mem_usage"
  1631. , (cgroup_used_memory_without_cache) ? "Systemd Services Used Memory without Cache"
  1632. : "Systemd Services Used Memory"
  1633. , "MiB"
  1634. , PLUGIN_CGROUPS_NAME
  1635. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1636. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 10
  1637. , update_every
  1638. , RRDSET_TYPE_STACKED
  1639. );
  1640. }
  1641. else
  1642. rrdset_next(st_mem_usage);
  1643. }
  1644. if(likely(do_mem_detailed)) {
  1645. if(unlikely(!st_mem_detailed_rss)) {
  1646. st_mem_detailed_rss = rrdset_create_localhost(
  1647. "services"
  1648. , "mem_rss"
  1649. , NULL
  1650. , "mem"
  1651. , "services.mem_rss"
  1652. , "Systemd Services RSS Memory"
  1653. , "MiB"
  1654. , PLUGIN_CGROUPS_NAME
  1655. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1656. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 20
  1657. , update_every
  1658. , RRDSET_TYPE_STACKED
  1659. );
  1660. }
  1661. else
  1662. rrdset_next(st_mem_detailed_rss);
  1663. if(unlikely(!st_mem_detailed_mapped)) {
  1664. st_mem_detailed_mapped = rrdset_create_localhost(
  1665. "services"
  1666. , "mem_mapped"
  1667. , NULL
  1668. , "mem"
  1669. , "services.mem_mapped"
  1670. , "Systemd Services Mapped Memory"
  1671. , "MiB"
  1672. , PLUGIN_CGROUPS_NAME
  1673. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1674. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 30
  1675. , update_every
  1676. , RRDSET_TYPE_STACKED
  1677. );
  1678. }
  1679. else
  1680. rrdset_next(st_mem_detailed_mapped);
  1681. if(unlikely(!st_mem_detailed_cache)) {
  1682. st_mem_detailed_cache = rrdset_create_localhost(
  1683. "services"
  1684. , "mem_cache"
  1685. , NULL
  1686. , "mem"
  1687. , "services.mem_cache"
  1688. , "Systemd Services Cache Memory"
  1689. , "MiB"
  1690. , PLUGIN_CGROUPS_NAME
  1691. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1692. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 40
  1693. , update_every
  1694. , RRDSET_TYPE_STACKED
  1695. );
  1696. }
  1697. else
  1698. rrdset_next(st_mem_detailed_cache);
  1699. if(unlikely(!st_mem_detailed_writeback)) {
  1700. st_mem_detailed_writeback = rrdset_create_localhost(
  1701. "services"
  1702. , "mem_writeback"
  1703. , NULL
  1704. , "mem"
  1705. , "services.mem_writeback"
  1706. , "Systemd Services Writeback Memory"
  1707. , "MiB"
  1708. , PLUGIN_CGROUPS_NAME
  1709. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1710. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 50
  1711. , update_every
  1712. , RRDSET_TYPE_STACKED
  1713. );
  1714. }
  1715. else
  1716. rrdset_next(st_mem_detailed_writeback);
  1717. if(unlikely(!st_mem_detailed_pgfault)) {
  1718. st_mem_detailed_pgfault = rrdset_create_localhost(
  1719. "services"
  1720. , "mem_pgfault"
  1721. , NULL
  1722. , "mem"
  1723. , "services.mem_pgfault"
  1724. , "Systemd Services Memory Minor Page Faults"
  1725. , "MiB/s"
  1726. , PLUGIN_CGROUPS_NAME
  1727. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1728. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 60
  1729. , update_every
  1730. , RRDSET_TYPE_STACKED
  1731. );
  1732. }
  1733. else
  1734. rrdset_next(st_mem_detailed_pgfault);
  1735. if(unlikely(!st_mem_detailed_pgmajfault)) {
  1736. st_mem_detailed_pgmajfault = rrdset_create_localhost(
  1737. "services"
  1738. , "mem_pgmajfault"
  1739. , NULL
  1740. , "mem"
  1741. , "services.mem_pgmajfault"
  1742. , "Systemd Services Memory Major Page Faults"
  1743. , "MiB/s"
  1744. , PLUGIN_CGROUPS_NAME
  1745. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1746. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 70
  1747. , update_every
  1748. , RRDSET_TYPE_STACKED
  1749. );
  1750. }
  1751. else
  1752. rrdset_next(st_mem_detailed_pgmajfault);
  1753. if(unlikely(!st_mem_detailed_pgpgin)) {
  1754. st_mem_detailed_pgpgin = rrdset_create_localhost(
  1755. "services"
  1756. , "mem_pgpgin"
  1757. , NULL
  1758. , "mem"
  1759. , "services.mem_pgpgin"
  1760. , "Systemd Services Memory Charging Activity"
  1761. , "MiB/s"
  1762. , PLUGIN_CGROUPS_NAME
  1763. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1764. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 80
  1765. , update_every
  1766. , RRDSET_TYPE_STACKED
  1767. );
  1768. }
  1769. else
  1770. rrdset_next(st_mem_detailed_pgpgin);
  1771. if(unlikely(!st_mem_detailed_pgpgout)) {
  1772. st_mem_detailed_pgpgout = rrdset_create_localhost(
  1773. "services"
  1774. , "mem_pgpgout"
  1775. , NULL
  1776. , "mem"
  1777. , "services.mem_pgpgout"
  1778. , "Systemd Services Memory Uncharging Activity"
  1779. , "MiB/s"
  1780. , PLUGIN_CGROUPS_NAME
  1781. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1782. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 90
  1783. , update_every
  1784. , RRDSET_TYPE_STACKED
  1785. );
  1786. }
  1787. else
  1788. rrdset_next(st_mem_detailed_pgpgout);
  1789. }
  1790. if(likely(do_mem_failcnt)) {
  1791. if(unlikely(!st_mem_failcnt)) {
  1792. st_mem_failcnt = rrdset_create_localhost(
  1793. "services"
  1794. , "mem_failcnt"
  1795. , NULL
  1796. , "mem"
  1797. , "services.mem_failcnt"
  1798. , "Systemd Services Memory Limit Failures"
  1799. , "failures"
  1800. , PLUGIN_CGROUPS_NAME
  1801. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1802. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 110
  1803. , update_every
  1804. , RRDSET_TYPE_STACKED
  1805. );
  1806. }
  1807. else
  1808. rrdset_next(st_mem_failcnt);
  1809. }
  1810. if(likely(do_swap_usage)) {
  1811. if(unlikely(!st_swap_usage)) {
  1812. st_swap_usage = rrdset_create_localhost(
  1813. "services"
  1814. , "swap_usage"
  1815. , NULL
  1816. , "swap"
  1817. , "services.swap_usage"
  1818. , "Systemd Services Swap Memory Used"
  1819. , "MiB"
  1820. , PLUGIN_CGROUPS_NAME
  1821. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1822. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 100
  1823. , update_every
  1824. , RRDSET_TYPE_STACKED
  1825. );
  1826. }
  1827. else
  1828. rrdset_next(st_swap_usage);
  1829. }
  1830. if(likely(do_io)) {
  1831. if(unlikely(!st_io_read)) {
  1832. st_io_read = rrdset_create_localhost(
  1833. "services"
  1834. , "io_read"
  1835. , NULL
  1836. , "disk"
  1837. , "services.io_read"
  1838. , "Systemd Services Disk Read Bandwidth"
  1839. , "KiB/s"
  1840. , PLUGIN_CGROUPS_NAME
  1841. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1842. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 120
  1843. , update_every
  1844. , RRDSET_TYPE_STACKED
  1845. );
  1846. }
  1847. else
  1848. rrdset_next(st_io_read);
  1849. if(unlikely(!st_io_write)) {
  1850. st_io_write = rrdset_create_localhost(
  1851. "services"
  1852. , "io_write"
  1853. , NULL
  1854. , "disk"
  1855. , "services.io_write"
  1856. , "Systemd Services Disk Write Bandwidth"
  1857. , "KiB/s"
  1858. , PLUGIN_CGROUPS_NAME
  1859. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1860. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 130
  1861. , update_every
  1862. , RRDSET_TYPE_STACKED
  1863. );
  1864. }
  1865. else
  1866. rrdset_next(st_io_write);
  1867. }
  1868. if(likely(do_io_ops)) {
  1869. if(unlikely(!st_io_serviced_read)) {
  1870. st_io_serviced_read = rrdset_create_localhost(
  1871. "services"
  1872. , "io_ops_read"
  1873. , NULL
  1874. , "disk"
  1875. , "services.io_ops_read"
  1876. , "Systemd Services Disk Read Operations"
  1877. , "operations/s"
  1878. , PLUGIN_CGROUPS_NAME
  1879. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1880. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 140
  1881. , update_every
  1882. , RRDSET_TYPE_STACKED
  1883. );
  1884. }
  1885. else
  1886. rrdset_next(st_io_serviced_read);
  1887. if(unlikely(!st_io_serviced_write)) {
  1888. st_io_serviced_write = rrdset_create_localhost(
  1889. "services"
  1890. , "io_ops_write"
  1891. , NULL
  1892. , "disk"
  1893. , "services.io_ops_write"
  1894. , "Systemd Services Disk Write Operations"
  1895. , "operations/s"
  1896. , PLUGIN_CGROUPS_NAME
  1897. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1898. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 150
  1899. , update_every
  1900. , RRDSET_TYPE_STACKED
  1901. );
  1902. }
  1903. else
  1904. rrdset_next(st_io_serviced_write);
  1905. }
  1906. if(likely(do_throttle_io)) {
  1907. if(unlikely(!st_throttle_io_read)) {
  1908. st_throttle_io_read = rrdset_create_localhost(
  1909. "services"
  1910. , "throttle_io_read"
  1911. , NULL
  1912. , "disk"
  1913. , "services.throttle_io_read"
  1914. , "Systemd Services Throttle Disk Read Bandwidth"
  1915. , "KiB/s"
  1916. , PLUGIN_CGROUPS_NAME
  1917. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1918. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 160
  1919. , update_every
  1920. , RRDSET_TYPE_STACKED
  1921. );
  1922. }
  1923. else
  1924. rrdset_next(st_throttle_io_read);
  1925. if(unlikely(!st_throttle_io_write)) {
  1926. st_throttle_io_write = rrdset_create_localhost(
  1927. "services"
  1928. , "throttle_io_write"
  1929. , NULL
  1930. , "disk"
  1931. , "services.throttle_io_write"
  1932. , "Systemd Services Throttle Disk Write Bandwidth"
  1933. , "KiB/s"
  1934. , PLUGIN_CGROUPS_NAME
  1935. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1936. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 170
  1937. , update_every
  1938. , RRDSET_TYPE_STACKED
  1939. );
  1940. }
  1941. else
  1942. rrdset_next(st_throttle_io_write);
  1943. }
  1944. if(likely(do_throttle_ops)) {
  1945. if(unlikely(!st_throttle_ops_read)) {
  1946. st_throttle_ops_read = rrdset_create_localhost(
  1947. "services"
  1948. , "throttle_io_ops_read"
  1949. , NULL
  1950. , "disk"
  1951. , "services.throttle_io_ops_read"
  1952. , "Systemd Services Throttle Disk Read Operations"
  1953. , "operations/s"
  1954. , PLUGIN_CGROUPS_NAME
  1955. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1956. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 180
  1957. , update_every
  1958. , RRDSET_TYPE_STACKED
  1959. );
  1960. }
  1961. else
  1962. rrdset_next(st_throttle_ops_read);
  1963. if(unlikely(!st_throttle_ops_write)) {
  1964. st_throttle_ops_write = rrdset_create_localhost(
  1965. "services"
  1966. , "throttle_io_ops_write"
  1967. , NULL
  1968. , "disk"
  1969. , "services.throttle_io_ops_write"
  1970. , "Systemd Services Throttle Disk Write Operations"
  1971. , "operations/s"
  1972. , PLUGIN_CGROUPS_NAME
  1973. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1974. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 190
  1975. , update_every
  1976. , RRDSET_TYPE_STACKED
  1977. );
  1978. }
  1979. else
  1980. rrdset_next(st_throttle_ops_write);
  1981. }
  1982. if(likely(do_queued_ops)) {
  1983. if(unlikely(!st_queued_ops_read)) {
  1984. st_queued_ops_read = rrdset_create_localhost(
  1985. "services"
  1986. , "queued_io_ops_read"
  1987. , NULL
  1988. , "disk"
  1989. , "services.queued_io_ops_read"
  1990. , "Systemd Services Queued Disk Read Operations"
  1991. , "operations/s"
  1992. , PLUGIN_CGROUPS_NAME
  1993. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  1994. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 200
  1995. , update_every
  1996. , RRDSET_TYPE_STACKED
  1997. );
  1998. }
  1999. else
  2000. rrdset_next(st_queued_ops_read);
  2001. if(unlikely(!st_queued_ops_write)) {
  2002. st_queued_ops_write = rrdset_create_localhost(
  2003. "services"
  2004. , "queued_io_ops_write"
  2005. , NULL
  2006. , "disk"
  2007. , "services.queued_io_ops_write"
  2008. , "Systemd Services Queued Disk Write Operations"
  2009. , "operations/s"
  2010. , PLUGIN_CGROUPS_NAME
  2011. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  2012. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 210
  2013. , update_every
  2014. , RRDSET_TYPE_STACKED
  2015. );
  2016. }
  2017. else
  2018. rrdset_next(st_queued_ops_write);
  2019. }
  2020. if(likely(do_merged_ops)) {
  2021. if(unlikely(!st_merged_ops_read)) {
  2022. st_merged_ops_read = rrdset_create_localhost(
  2023. "services"
  2024. , "merged_io_ops_read"
  2025. , NULL
  2026. , "disk"
  2027. , "services.merged_io_ops_read"
  2028. , "Systemd Services Merged Disk Read Operations"
  2029. , "operations/s"
  2030. , PLUGIN_CGROUPS_NAME
  2031. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  2032. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 220
  2033. , update_every
  2034. , RRDSET_TYPE_STACKED
  2035. );
  2036. }
  2037. else
  2038. rrdset_next(st_merged_ops_read);
  2039. if(unlikely(!st_merged_ops_write)) {
  2040. st_merged_ops_write = rrdset_create_localhost(
  2041. "services"
  2042. , "merged_io_ops_write"
  2043. , NULL
  2044. , "disk"
  2045. , "services.merged_io_ops_write"
  2046. , "Systemd Services Merged Disk Write Operations"
  2047. , "operations/s"
  2048. , PLUGIN_CGROUPS_NAME
  2049. , PLUGIN_CGROUPS_MODULE_SYSTEMD_NAME
  2050. , NETDATA_CHART_PRIO_CGROUPS_SYSTEMD + 230
  2051. , update_every
  2052. , RRDSET_TYPE_STACKED
  2053. );
  2054. }
  2055. else
  2056. rrdset_next(st_merged_ops_write);
  2057. }
  2058. // update the values
  2059. struct cgroup *cg;
  2060. for(cg = cgroup_root; cg ; cg = cg->next) {
  2061. if(unlikely(!cg->available || !cg->enabled || cg->pending_renames || !(cg->options & CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE)))
  2062. continue;
  2063. if(likely(do_cpu && cg->cpuacct_stat.updated)) {
  2064. if(unlikely(!cg->rd_cpu)){
  2065. if (!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  2066. cg->rd_cpu = rrddim_add(st_cpu, cg->chart_id, cg->chart_title, 100, system_hz, RRD_ALGORITHM_INCREMENTAL);
  2067. } else {
  2068. cg->rd_cpu = rrddim_add(st_cpu, cg->chart_id, cg->chart_title, 100, 1000000, RRD_ALGORITHM_INCREMENTAL);
  2069. }
  2070. }
  2071. rrddim_set_by_pointer(st_cpu, cg->rd_cpu, cg->cpuacct_stat.user + cg->cpuacct_stat.system);
  2072. }
  2073. if(likely(do_mem_usage && cg->memory.updated_usage_in_bytes)) {
  2074. if(unlikely(!cg->rd_mem_usage))
  2075. cg->rd_mem_usage = rrddim_add(st_mem_usage, cg->chart_id, cg->chart_title, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2076. rrddim_set_by_pointer(st_mem_usage, cg->rd_mem_usage, cg->memory.usage_in_bytes - ((cgroup_used_memory_without_cache)?cg->memory.total_cache:0));
  2077. }
  2078. if(likely(do_mem_detailed && cg->memory.updated_detailed)) {
  2079. if(unlikely(!cg->rd_mem_detailed_rss))
  2080. cg->rd_mem_detailed_rss = rrddim_add(st_mem_detailed_rss, cg->chart_id, cg->chart_title, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2081. rrddim_set_by_pointer(st_mem_detailed_rss, cg->rd_mem_detailed_rss, cg->memory.total_rss + cg->memory.total_rss_huge);
  2082. if(unlikely(!cg->rd_mem_detailed_mapped))
  2083. cg->rd_mem_detailed_mapped = rrddim_add(st_mem_detailed_mapped, cg->chart_id, cg->chart_title, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2084. rrddim_set_by_pointer(st_mem_detailed_mapped, cg->rd_mem_detailed_mapped, cg->memory.total_mapped_file);
  2085. if(unlikely(!cg->rd_mem_detailed_cache))
  2086. cg->rd_mem_detailed_cache = rrddim_add(st_mem_detailed_cache, cg->chart_id, cg->chart_title, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2087. rrddim_set_by_pointer(st_mem_detailed_cache, cg->rd_mem_detailed_cache, cg->memory.total_cache);
  2088. if(unlikely(!cg->rd_mem_detailed_writeback))
  2089. cg->rd_mem_detailed_writeback = rrddim_add(st_mem_detailed_writeback, cg->chart_id, cg->chart_title, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2090. rrddim_set_by_pointer(st_mem_detailed_writeback, cg->rd_mem_detailed_writeback, cg->memory.total_writeback);
  2091. if(unlikely(!cg->rd_mem_detailed_pgfault))
  2092. cg->rd_mem_detailed_pgfault = rrddim_add(st_mem_detailed_pgfault, cg->chart_id, cg->chart_title, system_page_size, 1024 * 1024, RRD_ALGORITHM_INCREMENTAL);
  2093. rrddim_set_by_pointer(st_mem_detailed_pgfault, cg->rd_mem_detailed_pgfault, cg->memory.total_pgfault);
  2094. if(unlikely(!cg->rd_mem_detailed_pgmajfault))
  2095. cg->rd_mem_detailed_pgmajfault = rrddim_add(st_mem_detailed_pgmajfault, cg->chart_id, cg->chart_title, system_page_size, 1024 * 1024, RRD_ALGORITHM_INCREMENTAL);
  2096. rrddim_set_by_pointer(st_mem_detailed_pgmajfault, cg->rd_mem_detailed_pgmajfault, cg->memory.total_pgmajfault);
  2097. if(unlikely(!cg->rd_mem_detailed_pgpgin))
  2098. cg->rd_mem_detailed_pgpgin = rrddim_add(st_mem_detailed_pgpgin, cg->chart_id, cg->chart_title, system_page_size, 1024 * 1024, RRD_ALGORITHM_INCREMENTAL);
  2099. rrddim_set_by_pointer(st_mem_detailed_pgpgin, cg->rd_mem_detailed_pgpgin, cg->memory.total_pgpgin);
  2100. if(unlikely(!cg->rd_mem_detailed_pgpgout))
  2101. cg->rd_mem_detailed_pgpgout = rrddim_add(st_mem_detailed_pgpgout, cg->chart_id, cg->chart_title, system_page_size, 1024 * 1024, RRD_ALGORITHM_INCREMENTAL);
  2102. rrddim_set_by_pointer(st_mem_detailed_pgpgout, cg->rd_mem_detailed_pgpgout, cg->memory.total_pgpgout);
  2103. }
  2104. if(likely(do_mem_failcnt && cg->memory.updated_failcnt)) {
  2105. if(unlikely(!cg->rd_mem_failcnt))
  2106. cg->rd_mem_failcnt = rrddim_add(st_mem_failcnt, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2107. rrddim_set_by_pointer(st_mem_failcnt, cg->rd_mem_failcnt, cg->memory.failcnt);
  2108. }
  2109. if(likely(do_swap_usage && cg->memory.updated_msw_usage_in_bytes)) {
  2110. if(unlikely(!cg->rd_swap_usage))
  2111. cg->rd_swap_usage = rrddim_add(st_swap_usage, cg->chart_id, cg->chart_title, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2112. rrddim_set_by_pointer(st_swap_usage, cg->rd_swap_usage, cg->memory.msw_usage_in_bytes);
  2113. }
  2114. if(likely(do_io && cg->io_service_bytes.updated)) {
  2115. if(unlikely(!cg->rd_io_service_bytes_read))
  2116. cg->rd_io_service_bytes_read = rrddim_add(st_io_read, cg->chart_id, cg->chart_title, 1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2117. rrddim_set_by_pointer(st_io_read, cg->rd_io_service_bytes_read, cg->io_service_bytes.Read);
  2118. if(unlikely(!cg->rd_io_service_bytes_write))
  2119. cg->rd_io_service_bytes_write = rrddim_add(st_io_write, cg->chart_id, cg->chart_title, 1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2120. rrddim_set_by_pointer(st_io_write, cg->rd_io_service_bytes_write, cg->io_service_bytes.Write);
  2121. }
  2122. if(likely(do_io_ops && cg->io_serviced.updated)) {
  2123. if(unlikely(!cg->rd_io_serviced_read))
  2124. cg->rd_io_serviced_read = rrddim_add(st_io_serviced_read, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2125. rrddim_set_by_pointer(st_io_serviced_read, cg->rd_io_serviced_read, cg->io_serviced.Read);
  2126. if(unlikely(!cg->rd_io_serviced_write))
  2127. cg->rd_io_serviced_write = rrddim_add(st_io_serviced_write, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2128. rrddim_set_by_pointer(st_io_serviced_write, cg->rd_io_serviced_write, cg->io_serviced.Write);
  2129. }
  2130. if(likely(do_throttle_io && cg->throttle_io_service_bytes.updated)) {
  2131. if(unlikely(!cg->rd_throttle_io_read))
  2132. cg->rd_throttle_io_read = rrddim_add(st_throttle_io_read, cg->chart_id, cg->chart_title, 1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2133. rrddim_set_by_pointer(st_throttle_io_read, cg->rd_throttle_io_read, cg->throttle_io_service_bytes.Read);
  2134. if(unlikely(!cg->rd_throttle_io_write))
  2135. cg->rd_throttle_io_write = rrddim_add(st_throttle_io_write, cg->chart_id, cg->chart_title, 1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2136. rrddim_set_by_pointer(st_throttle_io_write, cg->rd_throttle_io_write, cg->throttle_io_service_bytes.Write);
  2137. }
  2138. if(likely(do_throttle_ops && cg->throttle_io_serviced.updated)) {
  2139. if(unlikely(!cg->rd_throttle_io_serviced_read))
  2140. cg->rd_throttle_io_serviced_read = rrddim_add(st_throttle_ops_read, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2141. rrddim_set_by_pointer(st_throttle_ops_read, cg->rd_throttle_io_serviced_read, cg->throttle_io_serviced.Read);
  2142. if(unlikely(!cg->rd_throttle_io_serviced_write))
  2143. cg->rd_throttle_io_serviced_write = rrddim_add(st_throttle_ops_write, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2144. rrddim_set_by_pointer(st_throttle_ops_write, cg->rd_throttle_io_serviced_write, cg->throttle_io_serviced.Write);
  2145. }
  2146. if(likely(do_queued_ops && cg->io_queued.updated)) {
  2147. if(unlikely(!cg->rd_io_queued_read))
  2148. cg->rd_io_queued_read = rrddim_add(st_queued_ops_read, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2149. rrddim_set_by_pointer(st_queued_ops_read, cg->rd_io_queued_read, cg->io_queued.Read);
  2150. if(unlikely(!cg->rd_io_queued_write))
  2151. cg->rd_io_queued_write = rrddim_add(st_queued_ops_write, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2152. rrddim_set_by_pointer(st_queued_ops_write, cg->rd_io_queued_write, cg->io_queued.Write);
  2153. }
  2154. if(likely(do_merged_ops && cg->io_merged.updated)) {
  2155. if(unlikely(!cg->rd_io_merged_read))
  2156. cg->rd_io_merged_read = rrddim_add(st_merged_ops_read, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2157. rrddim_set_by_pointer(st_merged_ops_read, cg->rd_io_merged_read, cg->io_merged.Read);
  2158. if(unlikely(!cg->rd_io_merged_write))
  2159. cg->rd_io_merged_write = rrddim_add(st_merged_ops_write, cg->chart_id, cg->chart_title, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2160. rrddim_set_by_pointer(st_merged_ops_write, cg->rd_io_merged_write, cg->io_merged.Write);
  2161. }
  2162. }
  2163. // complete the iteration
  2164. if(likely(do_cpu))
  2165. rrdset_done(st_cpu);
  2166. if(likely(do_mem_usage))
  2167. rrdset_done(st_mem_usage);
  2168. if(unlikely(do_mem_detailed)) {
  2169. rrdset_done(st_mem_detailed_cache);
  2170. rrdset_done(st_mem_detailed_rss);
  2171. rrdset_done(st_mem_detailed_mapped);
  2172. rrdset_done(st_mem_detailed_writeback);
  2173. rrdset_done(st_mem_detailed_pgfault);
  2174. rrdset_done(st_mem_detailed_pgmajfault);
  2175. rrdset_done(st_mem_detailed_pgpgin);
  2176. rrdset_done(st_mem_detailed_pgpgout);
  2177. }
  2178. if(likely(do_mem_failcnt))
  2179. rrdset_done(st_mem_failcnt);
  2180. if(likely(do_swap_usage))
  2181. rrdset_done(st_swap_usage);
  2182. if(likely(do_io)) {
  2183. rrdset_done(st_io_read);
  2184. rrdset_done(st_io_write);
  2185. }
  2186. if(likely(do_io_ops)) {
  2187. rrdset_done(st_io_serviced_read);
  2188. rrdset_done(st_io_serviced_write);
  2189. }
  2190. if(likely(do_throttle_io)) {
  2191. rrdset_done(st_throttle_io_read);
  2192. rrdset_done(st_throttle_io_write);
  2193. }
  2194. if(likely(do_throttle_ops)) {
  2195. rrdset_done(st_throttle_ops_read);
  2196. rrdset_done(st_throttle_ops_write);
  2197. }
  2198. if(likely(do_queued_ops)) {
  2199. rrdset_done(st_queued_ops_read);
  2200. rrdset_done(st_queued_ops_write);
  2201. }
  2202. if(likely(do_merged_ops)) {
  2203. rrdset_done(st_merged_ops_read);
  2204. rrdset_done(st_merged_ops_write);
  2205. }
  2206. }
  2207. static inline char *cgroup_chart_type(char *buffer, const char *id, size_t len) {
  2208. if(buffer[0]) return buffer;
  2209. if(id[0] == '\0' || (id[0] == '/' && id[1] == '\0'))
  2210. strncpy(buffer, "cgroup_root", len);
  2211. else
  2212. snprintfz(buffer, len, "cgroup_%s", id);
  2213. netdata_fix_chart_id(buffer);
  2214. return buffer;
  2215. }
  2216. static inline unsigned long long cpuset_str2ull(char **s) {
  2217. unsigned long long n = 0;
  2218. char c;
  2219. for(c = **s; c >= '0' && c <= '9' ; c = *(++*s)) {
  2220. n *= 10;
  2221. n += c - '0';
  2222. }
  2223. return n;
  2224. }
  2225. static inline void update_cpu_limits(char **filename, unsigned long long *value, struct cgroup *cg) {
  2226. if(*filename) {
  2227. int ret = -1;
  2228. if(value == &cg->cpuset_cpus) {
  2229. static char *buf = NULL;
  2230. static size_t buf_size = 0;
  2231. if(!buf) {
  2232. buf_size = 100U + 6 * get_system_cpus(); // taken from kernel/cgroup/cpuset.c
  2233. buf = mallocz(buf_size + 1);
  2234. }
  2235. ret = read_file(*filename, buf, buf_size);
  2236. if(!ret) {
  2237. char *s = buf;
  2238. unsigned long long ncpus = 0;
  2239. // parse the cpuset string and calculate the number of cpus the cgroup is allowed to use
  2240. while(*s) {
  2241. unsigned long long n = cpuset_str2ull(&s);
  2242. if(*s == ',') {
  2243. s++;
  2244. ncpus++;
  2245. continue;
  2246. }
  2247. if(*s == '-') {
  2248. s++;
  2249. unsigned long long m = cpuset_str2ull(&s);
  2250. ncpus += m - n + 1; // calculate the number of cpus in the region
  2251. }
  2252. s++;
  2253. }
  2254. if(likely(ncpus)) *value = ncpus;
  2255. }
  2256. }
  2257. else if(value == &cg->cpu_cfs_period) {
  2258. ret = read_single_number_file(*filename, value);
  2259. }
  2260. else if(value == &cg->cpu_cfs_quota) {
  2261. ret = read_single_number_file(*filename, value);
  2262. }
  2263. else ret = -1;
  2264. if(ret) {
  2265. error("Cannot refresh cgroup %s cpu limit by reading '%s'. Will not update its limit anymore.", cg->id, *filename);
  2266. freez(*filename);
  2267. *filename = NULL;
  2268. }
  2269. }
  2270. }
  2271. static inline void update_cpu_limits2(struct cgroup *cg) {
  2272. if(cg->filename_cpu_cfs_quota){
  2273. static procfile *ff = NULL;
  2274. ff = procfile_reopen(ff, cg->filename_cpu_cfs_quota, NULL, PROCFILE_FLAG_DEFAULT);
  2275. if(unlikely(!ff)) {
  2276. goto cpu_limits2_err;
  2277. }
  2278. ff = procfile_readall(ff);
  2279. if(unlikely(!ff)) {
  2280. goto cpu_limits2_err;
  2281. }
  2282. unsigned long lines = procfile_lines(ff);
  2283. if (unlikely(lines < 1)) {
  2284. error("CGROUP: file '%s' should have 1 lines.", cg->filename_cpu_cfs_quota);
  2285. return;
  2286. }
  2287. cg->cpu_cfs_period = str2ull(procfile_lineword(ff, 0, 1));
  2288. cg->cpuset_cpus = get_system_cpus();
  2289. char *s = "max\n\0";
  2290. if(strsame(s, procfile_lineword(ff, 0, 0)) == 0){
  2291. cg->cpu_cfs_quota = cg->cpu_cfs_period * cg->cpuset_cpus;
  2292. } else {
  2293. cg->cpu_cfs_quota = str2ull(procfile_lineword(ff, 0, 0));
  2294. }
  2295. debug(D_CGROUP, "CPU limits values: %llu %llu %llu", cg->cpu_cfs_period, cg->cpuset_cpus, cg->cpu_cfs_quota);
  2296. return;
  2297. cpu_limits2_err:
  2298. error("Cannot refresh cgroup %s cpu limit by reading '%s'. Will not update its limit anymore.", cg->id, cg->filename_cpu_cfs_quota);
  2299. freez(cg->filename_cpu_cfs_quota);
  2300. cg->filename_cpu_cfs_quota = NULL;
  2301. }
  2302. }
  2303. static inline int update_memory_limits(char **filename, RRDSETVAR **chart_var, unsigned long long *value, const char *chart_var_name, struct cgroup *cg) {
  2304. if(*filename) {
  2305. if(unlikely(!*chart_var)) {
  2306. *chart_var = rrdsetvar_custom_chart_variable_create(cg->st_mem_usage, chart_var_name);
  2307. if(!*chart_var) {
  2308. error("Cannot create cgroup %s chart variable '%s'. Will not update its limit anymore.", cg->id, chart_var_name);
  2309. freez(*filename);
  2310. *filename = NULL;
  2311. }
  2312. }
  2313. if(*filename && *chart_var) {
  2314. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  2315. if(read_single_number_file(*filename, value)) {
  2316. error("Cannot refresh cgroup %s memory limit by reading '%s'. Will not update its limit anymore.", cg->id, *filename);
  2317. freez(*filename);
  2318. *filename = NULL;
  2319. }
  2320. else {
  2321. rrdsetvar_custom_chart_variable_set(*chart_var, (calculated_number)(*value / (1024 * 1024)));
  2322. return 1;
  2323. }
  2324. } else {
  2325. char buffer[30 + 1];
  2326. int ret = read_file(*filename, buffer, 30);
  2327. if(ret) {
  2328. error("Cannot refresh cgroup %s memory limit by reading '%s'. Will not update its limit anymore.", cg->id, *filename);
  2329. freez(*filename);
  2330. *filename = NULL;
  2331. return 0;
  2332. }
  2333. char *s = "max\n\0";
  2334. if(strsame(s, buffer) == 0){
  2335. *value = UINT64_MAX;
  2336. rrdsetvar_custom_chart_variable_set(*chart_var, (calculated_number)(*value / (1024 * 1024)));
  2337. return 1;
  2338. }
  2339. *value = str2ull(buffer);
  2340. rrdsetvar_custom_chart_variable_set(*chart_var, (calculated_number)(*value / (1024 * 1024)));
  2341. return 1;
  2342. }
  2343. }
  2344. }
  2345. return 0;
  2346. }
  2347. void update_cgroup_charts(int update_every) {
  2348. debug(D_CGROUP, "updating cgroups charts");
  2349. char type[RRD_ID_LENGTH_MAX + 1];
  2350. char title[CHART_TITLE_MAX + 1];
  2351. int services_do_cpu = 0,
  2352. services_do_mem_usage = 0,
  2353. services_do_mem_detailed = 0,
  2354. services_do_mem_failcnt = 0,
  2355. services_do_swap_usage = 0,
  2356. services_do_io = 0,
  2357. services_do_io_ops = 0,
  2358. services_do_throttle_io = 0,
  2359. services_do_throttle_ops = 0,
  2360. services_do_queued_ops = 0,
  2361. services_do_merged_ops = 0;
  2362. struct cgroup *cg;
  2363. for(cg = cgroup_root; cg ; cg = cg->next) {
  2364. if(unlikely(!cg->available || !cg->enabled || cg->pending_renames))
  2365. continue;
  2366. if(likely(cgroup_enable_systemd_services && cg->options & CGROUP_OPTIONS_SYSTEM_SLICE_SERVICE)) {
  2367. if(cg->cpuacct_stat.updated && cg->cpuacct_stat.enabled == CONFIG_BOOLEAN_YES) services_do_cpu++;
  2368. if(cgroup_enable_systemd_services_detailed_memory && cg->memory.updated_detailed && cg->memory.enabled_detailed) services_do_mem_detailed++;
  2369. if(cg->memory.updated_usage_in_bytes && cg->memory.enabled_usage_in_bytes == CONFIG_BOOLEAN_YES) services_do_mem_usage++;
  2370. if(cg->memory.updated_failcnt && cg->memory.enabled_failcnt == CONFIG_BOOLEAN_YES) services_do_mem_failcnt++;
  2371. if(cg->memory.updated_msw_usage_in_bytes && cg->memory.enabled_msw_usage_in_bytes == CONFIG_BOOLEAN_YES) services_do_swap_usage++;
  2372. if(cg->io_service_bytes.updated && cg->io_service_bytes.enabled == CONFIG_BOOLEAN_YES) services_do_io++;
  2373. if(cg->io_serviced.updated && cg->io_serviced.enabled == CONFIG_BOOLEAN_YES) services_do_io_ops++;
  2374. if(cg->throttle_io_service_bytes.updated && cg->throttle_io_service_bytes.enabled == CONFIG_BOOLEAN_YES) services_do_throttle_io++;
  2375. if(cg->throttle_io_serviced.updated && cg->throttle_io_serviced.enabled == CONFIG_BOOLEAN_YES) services_do_throttle_ops++;
  2376. if(cg->io_queued.updated && cg->io_queued.enabled == CONFIG_BOOLEAN_YES) services_do_queued_ops++;
  2377. if(cg->io_merged.updated && cg->io_merged.enabled == CONFIG_BOOLEAN_YES) services_do_merged_ops++;
  2378. continue;
  2379. }
  2380. type[0] = '\0';
  2381. if(likely(cg->cpuacct_stat.updated && cg->cpuacct_stat.enabled == CONFIG_BOOLEAN_YES)) {
  2382. if(unlikely(!cg->st_cpu)) {
  2383. snprintfz(title, CHART_TITLE_MAX, "CPU Usage (%d%% = %d core%s) for cgroup %s", (processors * 100), processors, (processors > 1) ? "s" : "", cg->chart_title);
  2384. cg->st_cpu = rrdset_create_localhost(
  2385. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2386. , "cpu"
  2387. , NULL
  2388. , "cpu"
  2389. , "cgroup.cpu"
  2390. , title
  2391. , "percentage"
  2392. , PLUGIN_CGROUPS_NAME
  2393. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2394. , cgroup_containers_chart_priority
  2395. , update_every
  2396. , RRDSET_TYPE_STACKED
  2397. );
  2398. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  2399. rrddim_add(cg->st_cpu, "user", NULL, 100, system_hz, RRD_ALGORITHM_INCREMENTAL);
  2400. rrddim_add(cg->st_cpu, "system", NULL, 100, system_hz, RRD_ALGORITHM_INCREMENTAL);
  2401. }
  2402. else {
  2403. rrddim_add(cg->st_cpu, "user", NULL, 100, 1000000, RRD_ALGORITHM_INCREMENTAL);
  2404. rrddim_add(cg->st_cpu, "system", NULL, 100, 1000000, RRD_ALGORITHM_INCREMENTAL);
  2405. }
  2406. }
  2407. else
  2408. rrdset_next(cg->st_cpu);
  2409. rrddim_set(cg->st_cpu, "user", cg->cpuacct_stat.user);
  2410. rrddim_set(cg->st_cpu, "system", cg->cpuacct_stat.system);
  2411. rrdset_done(cg->st_cpu);
  2412. if(likely(cg->filename_cpuset_cpus || cg->filename_cpu_cfs_period || cg->filename_cpu_cfs_quota)) {
  2413. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  2414. update_cpu_limits(&cg->filename_cpuset_cpus, &cg->cpuset_cpus, cg);
  2415. update_cpu_limits(&cg->filename_cpu_cfs_period, &cg->cpu_cfs_period, cg);
  2416. update_cpu_limits(&cg->filename_cpu_cfs_quota, &cg->cpu_cfs_quota, cg);
  2417. } else {
  2418. update_cpu_limits2(cg);
  2419. }
  2420. if(unlikely(!cg->chart_var_cpu_limit)) {
  2421. cg->chart_var_cpu_limit = rrdsetvar_custom_chart_variable_create(cg->st_cpu, "cpu_limit");
  2422. if(!cg->chart_var_cpu_limit) {
  2423. error("Cannot create cgroup %s chart variable 'cpu_limit'. Will not update its limit anymore.", cg->id);
  2424. if(cg->filename_cpuset_cpus) freez(cg->filename_cpuset_cpus);
  2425. cg->filename_cpuset_cpus = NULL;
  2426. if(cg->filename_cpu_cfs_period) freez(cg->filename_cpu_cfs_period);
  2427. cg->filename_cpu_cfs_period = NULL;
  2428. if(cg->filename_cpu_cfs_quota) freez(cg->filename_cpu_cfs_quota);
  2429. cg->filename_cpu_cfs_quota = NULL;
  2430. }
  2431. }
  2432. else {
  2433. calculated_number value = 0, quota = 0;
  2434. if(likely( ((!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) && (cg->filename_cpuset_cpus || (cg->filename_cpu_cfs_period && cg->filename_cpu_cfs_quota)))
  2435. || ((cg->options & CGROUP_OPTIONS_IS_UNIFIED) && cg->filename_cpu_cfs_quota))) {
  2436. if(unlikely(cg->cpu_cfs_quota > 0))
  2437. quota = (calculated_number)cg->cpu_cfs_quota / (calculated_number)cg->cpu_cfs_period;
  2438. if(unlikely(quota > 0 && quota < cg->cpuset_cpus))
  2439. value = quota * 100;
  2440. else
  2441. value = (calculated_number)cg->cpuset_cpus * 100;
  2442. }
  2443. if(likely(value)) {
  2444. rrdsetvar_custom_chart_variable_set(cg->chart_var_cpu_limit, value);
  2445. if(unlikely(!cg->st_cpu_limit)) {
  2446. snprintfz(title, CHART_TITLE_MAX, "CPU Usage within the limits for cgroup %s", cg->chart_title);
  2447. cg->st_cpu_limit = rrdset_create_localhost(
  2448. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2449. , "cpu_limit"
  2450. , NULL
  2451. , "cpu"
  2452. , "cgroup.cpu_limit"
  2453. , title
  2454. , "percentage"
  2455. , PLUGIN_CGROUPS_NAME
  2456. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2457. , cgroup_containers_chart_priority - 1
  2458. , update_every
  2459. , RRDSET_TYPE_LINE
  2460. );
  2461. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED))
  2462. rrddim_add(cg->st_cpu_limit, "used", NULL, 1, system_hz, RRD_ALGORITHM_ABSOLUTE);
  2463. else
  2464. rrddim_add(cg->st_cpu_limit, "used", NULL, 1, 1000000, RRD_ALGORITHM_ABSOLUTE);
  2465. }
  2466. else
  2467. rrdset_next(cg->st_cpu_limit);
  2468. calculated_number cpu_usage = 0;
  2469. cpu_usage = (calculated_number)(cg->cpuacct_stat.user + cg->cpuacct_stat.system) * 100;
  2470. calculated_number cpu_used = 100 * (cpu_usage - cg->prev_cpu_usage) / (value * update_every);
  2471. rrdset_isnot_obsolete(cg->st_cpu_limit);
  2472. rrddim_set(cg->st_cpu_limit, "used", (cpu_used > 0)?cpu_used:0);
  2473. cg->prev_cpu_usage = cpu_usage;
  2474. rrdset_done(cg->st_cpu_limit);
  2475. }
  2476. else {
  2477. rrdsetvar_custom_chart_variable_set(cg->chart_var_cpu_limit, NAN);
  2478. if(unlikely(cg->st_cpu_limit)) {
  2479. rrdset_is_obsolete(cg->st_cpu_limit);
  2480. cg->st_cpu_limit = NULL;
  2481. }
  2482. }
  2483. }
  2484. }
  2485. }
  2486. if(likely(cg->cpuacct_usage.updated && cg->cpuacct_usage.enabled == CONFIG_BOOLEAN_YES)) {
  2487. char id[RRD_ID_LENGTH_MAX + 1];
  2488. unsigned int i;
  2489. if(unlikely(!cg->st_cpu_per_core)) {
  2490. snprintfz(title, CHART_TITLE_MAX, "CPU Usage (%d%% = %d core%s) Per Core for cgroup %s", (processors * 100), processors, (processors > 1) ? "s" : "", cg->chart_title);
  2491. cg->st_cpu_per_core = rrdset_create_localhost(
  2492. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2493. , "cpu_per_core"
  2494. , NULL
  2495. , "cpu"
  2496. , "cgroup.cpu_per_core"
  2497. , title
  2498. , "percentage"
  2499. , PLUGIN_CGROUPS_NAME
  2500. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2501. , cgroup_containers_chart_priority + 100
  2502. , update_every
  2503. , RRDSET_TYPE_STACKED
  2504. );
  2505. for(i = 0; i < cg->cpuacct_usage.cpus; i++) {
  2506. snprintfz(id, RRD_ID_LENGTH_MAX, "cpu%u", i);
  2507. rrddim_add(cg->st_cpu_per_core, id, NULL, 100, 1000000000, RRD_ALGORITHM_INCREMENTAL);
  2508. }
  2509. }
  2510. else
  2511. rrdset_next(cg->st_cpu_per_core);
  2512. for(i = 0; i < cg->cpuacct_usage.cpus ;i++) {
  2513. snprintfz(id, RRD_ID_LENGTH_MAX, "cpu%u", i);
  2514. rrddim_set(cg->st_cpu_per_core, id, cg->cpuacct_usage.cpu_percpu[i]);
  2515. }
  2516. rrdset_done(cg->st_cpu_per_core);
  2517. }
  2518. if(likely(cg->memory.updated_detailed && cg->memory.enabled_detailed == CONFIG_BOOLEAN_YES)) {
  2519. if(unlikely(!cg->st_mem)) {
  2520. snprintfz(title, CHART_TITLE_MAX, "Memory Usage for cgroup %s", cg->chart_title);
  2521. cg->st_mem = rrdset_create_localhost(
  2522. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2523. , "mem"
  2524. , NULL
  2525. , "mem"
  2526. , "cgroup.mem"
  2527. , title
  2528. , "MiB"
  2529. , PLUGIN_CGROUPS_NAME
  2530. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2531. , cgroup_containers_chart_priority + 210
  2532. , update_every
  2533. , RRDSET_TYPE_STACKED
  2534. );
  2535. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  2536. rrddim_add(cg->st_mem, "cache", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2537. rrddim_add(cg->st_mem, "rss", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2538. if(cg->memory.detailed_has_swap)
  2539. rrddim_add(cg->st_mem, "swap", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2540. rrddim_add(cg->st_mem, "rss_huge", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2541. rrddim_add(cg->st_mem, "mapped_file", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2542. } else {
  2543. rrddim_add(cg->st_mem, "anon", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2544. rrddim_add(cg->st_mem, "kernel_stack", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2545. rrddim_add(cg->st_mem, "slab", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2546. rrddim_add(cg->st_mem, "sock", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2547. rrddim_add(cg->st_mem, "anon_thp", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2548. rrddim_add(cg->st_mem, "file", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2549. }
  2550. }
  2551. else
  2552. rrdset_next(cg->st_mem);
  2553. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  2554. rrddim_set(cg->st_mem, "cache", cg->memory.total_cache);
  2555. rrddim_set(cg->st_mem, "rss", (cg->memory.total_rss > cg->memory.total_rss_huge)?(cg->memory.total_rss - cg->memory.total_rss_huge):0);
  2556. if(cg->memory.detailed_has_swap)
  2557. rrddim_set(cg->st_mem, "swap", cg->memory.total_swap);
  2558. rrddim_set(cg->st_mem, "rss_huge", cg->memory.total_rss_huge);
  2559. rrddim_set(cg->st_mem, "mapped_file", cg->memory.total_mapped_file);
  2560. } else {
  2561. rrddim_set(cg->st_mem, "anon", cg->memory.anon);
  2562. rrddim_set(cg->st_mem, "kernel_stack", cg->memory.kernel_stack);
  2563. rrddim_set(cg->st_mem, "slab", cg->memory.slab);
  2564. rrddim_set(cg->st_mem, "sock", cg->memory.sock);
  2565. rrddim_set(cg->st_mem, "anon_thp", cg->memory.anon_thp);
  2566. rrddim_set(cg->st_mem, "file", cg->memory.total_mapped_file);
  2567. }
  2568. rrdset_done(cg->st_mem);
  2569. if(unlikely(!cg->st_writeback)) {
  2570. snprintfz(title, CHART_TITLE_MAX, "Writeback Memory for cgroup %s", cg->chart_title);
  2571. cg->st_writeback = rrdset_create_localhost(
  2572. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2573. , "writeback"
  2574. , NULL
  2575. , "mem"
  2576. , "cgroup.writeback"
  2577. , title
  2578. , "MiB"
  2579. , PLUGIN_CGROUPS_NAME
  2580. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2581. , cgroup_containers_chart_priority + 300
  2582. , update_every
  2583. , RRDSET_TYPE_AREA
  2584. );
  2585. if(cg->memory.detailed_has_dirty)
  2586. rrddim_add(cg->st_writeback, "dirty", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2587. rrddim_add(cg->st_writeback, "writeback", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2588. }
  2589. else
  2590. rrdset_next(cg->st_writeback);
  2591. if(cg->memory.detailed_has_dirty)
  2592. rrddim_set(cg->st_writeback, "dirty", cg->memory.total_dirty);
  2593. rrddim_set(cg->st_writeback, "writeback", cg->memory.total_writeback);
  2594. rrdset_done(cg->st_writeback);
  2595. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  2596. if(unlikely(!cg->st_mem_activity)) {
  2597. snprintfz(title, CHART_TITLE_MAX, "Memory Activity for cgroup %s", cg->chart_title);
  2598. cg->st_mem_activity = rrdset_create_localhost(
  2599. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2600. , "mem_activity"
  2601. , NULL
  2602. , "mem"
  2603. , "cgroup.mem_activity"
  2604. , title
  2605. , "MiB/s"
  2606. , PLUGIN_CGROUPS_NAME
  2607. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2608. , cgroup_containers_chart_priority + 400
  2609. , update_every
  2610. , RRDSET_TYPE_LINE
  2611. );
  2612. rrddim_add(cg->st_mem_activity, "pgpgin", "in", system_page_size, 1024 * 1024, RRD_ALGORITHM_INCREMENTAL);
  2613. rrddim_add(cg->st_mem_activity, "pgpgout", "out", -system_page_size, 1024 * 1024, RRD_ALGORITHM_INCREMENTAL);
  2614. }
  2615. else
  2616. rrdset_next(cg->st_mem_activity);
  2617. rrddim_set(cg->st_mem_activity, "pgpgin", cg->memory.total_pgpgin);
  2618. rrddim_set(cg->st_mem_activity, "pgpgout", cg->memory.total_pgpgout);
  2619. rrdset_done(cg->st_mem_activity);
  2620. }
  2621. if(unlikely(!cg->st_pgfaults)) {
  2622. snprintfz(title, CHART_TITLE_MAX, "Memory Page Faults for cgroup %s", cg->chart_title);
  2623. cg->st_pgfaults = rrdset_create_localhost(
  2624. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2625. , "pgfaults"
  2626. , NULL
  2627. , "mem"
  2628. , "cgroup.pgfaults"
  2629. , title
  2630. , "MiB/s"
  2631. , PLUGIN_CGROUPS_NAME
  2632. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2633. , cgroup_containers_chart_priority + 500
  2634. , update_every
  2635. , RRDSET_TYPE_LINE
  2636. );
  2637. rrddim_add(cg->st_pgfaults, "pgfault", NULL, system_page_size, 1024 * 1024, RRD_ALGORITHM_INCREMENTAL);
  2638. rrddim_add(cg->st_pgfaults, "pgmajfault", "swap", -system_page_size, 1024 * 1024, RRD_ALGORITHM_INCREMENTAL);
  2639. }
  2640. else
  2641. rrdset_next(cg->st_pgfaults);
  2642. rrddim_set(cg->st_pgfaults, "pgfault", cg->memory.total_pgfault);
  2643. rrddim_set(cg->st_pgfaults, "pgmajfault", cg->memory.total_pgmajfault);
  2644. rrdset_done(cg->st_pgfaults);
  2645. }
  2646. if(likely(cg->memory.updated_usage_in_bytes && cg->memory.enabled_usage_in_bytes == CONFIG_BOOLEAN_YES)) {
  2647. if(unlikely(!cg->st_mem_usage)) {
  2648. snprintfz(title, CHART_TITLE_MAX, "Used Memory %sfor cgroup %s", (cgroup_used_memory_without_cache && cg->memory.updated_detailed)?"without Cache ":"", cg->chart_title);
  2649. cg->st_mem_usage = rrdset_create_localhost(
  2650. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2651. , "mem_usage"
  2652. , NULL
  2653. , "mem"
  2654. , "cgroup.mem_usage"
  2655. , title
  2656. , "MiB"
  2657. , PLUGIN_CGROUPS_NAME
  2658. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2659. , cgroup_containers_chart_priority + 200
  2660. , update_every
  2661. , RRDSET_TYPE_STACKED
  2662. );
  2663. rrddim_add(cg->st_mem_usage, "ram", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2664. rrddim_add(cg->st_mem_usage, "swap", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2665. }
  2666. else
  2667. rrdset_next(cg->st_mem_usage);
  2668. rrddim_set(cg->st_mem_usage, "ram", cg->memory.usage_in_bytes - ((cgroup_used_memory_without_cache)?cg->memory.total_cache:0));
  2669. if(!(cg->options & CGROUP_OPTIONS_IS_UNIFIED)) {
  2670. rrddim_set(cg->st_mem_usage, "swap", (cg->memory.msw_usage_in_bytes > cg->memory.usage_in_bytes)?cg->memory.msw_usage_in_bytes - cg->memory.usage_in_bytes:0);
  2671. } else {
  2672. rrddim_set(cg->st_mem_usage, "swap", cg->memory.msw_usage_in_bytes);
  2673. }
  2674. rrdset_done(cg->st_mem_usage);
  2675. if (likely(update_memory_limits(&cg->filename_memory_limit, &cg->chart_var_memory_limit, &cg->memory_limit, "memory_limit", cg))) {
  2676. static unsigned long long ram_total = 0;
  2677. if(unlikely(!ram_total)) {
  2678. procfile *ff = NULL;
  2679. char filename[FILENAME_MAX + 1];
  2680. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/proc/meminfo");
  2681. ff = procfile_open(config_get("plugin:cgroups", "meminfo filename to monitor", filename), " \t:", PROCFILE_FLAG_DEFAULT);
  2682. if(likely(ff))
  2683. ff = procfile_readall(ff);
  2684. if(likely(ff && procfile_lines(ff) && !strncmp(procfile_word(ff, 0), "MemTotal", 8)))
  2685. ram_total = str2ull(procfile_word(ff, 1)) * 1024;
  2686. else {
  2687. error("Cannot read file %s. Will not update cgroup %s RAM limit anymore.", filename, cg->id);
  2688. freez(cg->filename_memory_limit);
  2689. cg->filename_memory_limit = NULL;
  2690. }
  2691. procfile_close(ff);
  2692. }
  2693. if(likely(ram_total)) {
  2694. unsigned long long memory_limit = ram_total;
  2695. if(unlikely(cg->memory_limit < ram_total))
  2696. memory_limit = cg->memory_limit;
  2697. if(unlikely(!cg->st_mem_usage_limit)) {
  2698. snprintfz(title, CHART_TITLE_MAX, "Used RAM without Cache within the limits for cgroup %s", cg->chart_title);
  2699. cg->st_mem_usage_limit = rrdset_create_localhost(
  2700. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2701. , "mem_usage_limit"
  2702. , NULL
  2703. , "mem"
  2704. , "cgroup.mem_usage_limit"
  2705. , title
  2706. , "MiB"
  2707. , PLUGIN_CGROUPS_NAME
  2708. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2709. , cgroup_containers_chart_priority + 199
  2710. , update_every
  2711. , RRDSET_TYPE_STACKED
  2712. );
  2713. rrddim_add(cg->st_mem_usage_limit, "available", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2714. rrddim_add(cg->st_mem_usage_limit, "used", NULL, 1, 1024 * 1024, RRD_ALGORITHM_ABSOLUTE);
  2715. }
  2716. else
  2717. rrdset_next(cg->st_mem_usage_limit);
  2718. rrdset_isnot_obsolete(cg->st_mem_usage_limit);
  2719. rrddim_set(cg->st_mem_usage_limit, "available", memory_limit - (cg->memory.usage_in_bytes - ((cgroup_used_memory_without_cache)?cg->memory.total_cache:0)));
  2720. rrddim_set(cg->st_mem_usage_limit, "used", cg->memory.usage_in_bytes - ((cgroup_used_memory_without_cache)?cg->memory.total_cache:0));
  2721. rrdset_done(cg->st_mem_usage_limit);
  2722. }
  2723. }
  2724. else {
  2725. if(unlikely(cg->st_mem_usage_limit)) {
  2726. rrdset_is_obsolete(cg->st_mem_usage_limit);
  2727. cg->st_mem_usage_limit = NULL;
  2728. }
  2729. }
  2730. update_memory_limits(&cg->filename_memoryswap_limit, &cg->chart_var_memoryswap_limit, &cg->memoryswap_limit, "memory_and_swap_limit", cg);
  2731. }
  2732. if(likely(cg->memory.updated_failcnt && cg->memory.enabled_failcnt == CONFIG_BOOLEAN_YES)) {
  2733. if(unlikely(!cg->st_mem_failcnt)) {
  2734. snprintfz(title, CHART_TITLE_MAX, "Memory Limit Failures for cgroup %s", cg->chart_title);
  2735. cg->st_mem_failcnt = rrdset_create_localhost(
  2736. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2737. , "mem_failcnt"
  2738. , NULL
  2739. , "mem"
  2740. , "cgroup.mem_failcnt"
  2741. , title
  2742. , "count"
  2743. , PLUGIN_CGROUPS_NAME
  2744. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2745. , cgroup_containers_chart_priority + 250
  2746. , update_every
  2747. , RRDSET_TYPE_LINE
  2748. );
  2749. rrddim_add(cg->st_mem_failcnt, "failures", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2750. }
  2751. else
  2752. rrdset_next(cg->st_mem_failcnt);
  2753. rrddim_set(cg->st_mem_failcnt, "failures", cg->memory.failcnt);
  2754. rrdset_done(cg->st_mem_failcnt);
  2755. }
  2756. if(likely(cg->io_service_bytes.updated && cg->io_service_bytes.enabled == CONFIG_BOOLEAN_YES)) {
  2757. if(unlikely(!cg->st_io)) {
  2758. snprintfz(title, CHART_TITLE_MAX, "I/O Bandwidth (all disks) for cgroup %s", cg->chart_title);
  2759. cg->st_io = rrdset_create_localhost(
  2760. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2761. , "io"
  2762. , NULL
  2763. , "disk"
  2764. , "cgroup.io"
  2765. , title
  2766. , "KiB/s"
  2767. , PLUGIN_CGROUPS_NAME
  2768. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2769. , cgroup_containers_chart_priority + 1200
  2770. , update_every
  2771. , RRDSET_TYPE_AREA
  2772. );
  2773. rrddim_add(cg->st_io, "read", NULL, 1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2774. rrddim_add(cg->st_io, "write", NULL, -1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2775. }
  2776. else
  2777. rrdset_next(cg->st_io);
  2778. rrddim_set(cg->st_io, "read", cg->io_service_bytes.Read);
  2779. rrddim_set(cg->st_io, "write", cg->io_service_bytes.Write);
  2780. rrdset_done(cg->st_io);
  2781. }
  2782. if(likely(cg->io_serviced.updated && cg->io_serviced.enabled == CONFIG_BOOLEAN_YES)) {
  2783. if(unlikely(!cg->st_serviced_ops)) {
  2784. snprintfz(title, CHART_TITLE_MAX, "Serviced I/O Operations (all disks) for cgroup %s", cg->chart_title);
  2785. cg->st_serviced_ops = rrdset_create_localhost(
  2786. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2787. , "serviced_ops"
  2788. , NULL
  2789. , "disk"
  2790. , "cgroup.serviced_ops"
  2791. , title
  2792. , "operations/s"
  2793. , PLUGIN_CGROUPS_NAME
  2794. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2795. , cgroup_containers_chart_priority + 1200
  2796. , update_every
  2797. , RRDSET_TYPE_LINE
  2798. );
  2799. rrddim_add(cg->st_serviced_ops, "read", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2800. rrddim_add(cg->st_serviced_ops, "write", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  2801. }
  2802. else
  2803. rrdset_next(cg->st_serviced_ops);
  2804. rrddim_set(cg->st_serviced_ops, "read", cg->io_serviced.Read);
  2805. rrddim_set(cg->st_serviced_ops, "write", cg->io_serviced.Write);
  2806. rrdset_done(cg->st_serviced_ops);
  2807. }
  2808. if(likely(cg->throttle_io_service_bytes.updated && cg->throttle_io_service_bytes.enabled == CONFIG_BOOLEAN_YES)) {
  2809. if(unlikely(!cg->st_throttle_io)) {
  2810. snprintfz(title, CHART_TITLE_MAX, "Throttle I/O Bandwidth (all disks) for cgroup %s", cg->chart_title);
  2811. cg->st_throttle_io = rrdset_create_localhost(
  2812. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2813. , "throttle_io"
  2814. , NULL
  2815. , "disk"
  2816. , "cgroup.throttle_io"
  2817. , title
  2818. , "KiB/s"
  2819. , PLUGIN_CGROUPS_NAME
  2820. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2821. , cgroup_containers_chart_priority + 1200
  2822. , update_every
  2823. , RRDSET_TYPE_AREA
  2824. );
  2825. rrddim_add(cg->st_throttle_io, "read", NULL, 1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2826. rrddim_add(cg->st_throttle_io, "write", NULL, -1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2827. }
  2828. else
  2829. rrdset_next(cg->st_throttle_io);
  2830. rrddim_set(cg->st_throttle_io, "read", cg->throttle_io_service_bytes.Read);
  2831. rrddim_set(cg->st_throttle_io, "write", cg->throttle_io_service_bytes.Write);
  2832. rrdset_done(cg->st_throttle_io);
  2833. }
  2834. if(likely(cg->throttle_io_serviced.updated && cg->throttle_io_serviced.enabled == CONFIG_BOOLEAN_YES)) {
  2835. if(unlikely(!cg->st_throttle_serviced_ops)) {
  2836. snprintfz(title, CHART_TITLE_MAX, "Throttle Serviced I/O Operations (all disks) for cgroup %s", cg->chart_title);
  2837. cg->st_throttle_serviced_ops = rrdset_create_localhost(
  2838. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2839. , "throttle_serviced_ops"
  2840. , NULL
  2841. , "disk"
  2842. , "cgroup.throttle_serviced_ops"
  2843. , title
  2844. , "operations/s"
  2845. , PLUGIN_CGROUPS_NAME
  2846. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2847. , cgroup_containers_chart_priority + 1200
  2848. , update_every
  2849. , RRDSET_TYPE_LINE
  2850. );
  2851. rrddim_add(cg->st_throttle_serviced_ops, "read", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  2852. rrddim_add(cg->st_throttle_serviced_ops, "write", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  2853. }
  2854. else
  2855. rrdset_next(cg->st_throttle_serviced_ops);
  2856. rrddim_set(cg->st_throttle_serviced_ops, "read", cg->throttle_io_serviced.Read);
  2857. rrddim_set(cg->st_throttle_serviced_ops, "write", cg->throttle_io_serviced.Write);
  2858. rrdset_done(cg->st_throttle_serviced_ops);
  2859. }
  2860. if(likely(cg->io_queued.updated && cg->io_queued.enabled == CONFIG_BOOLEAN_YES)) {
  2861. if(unlikely(!cg->st_queued_ops)) {
  2862. snprintfz(title, CHART_TITLE_MAX, "Queued I/O Operations (all disks) for cgroup %s", cg->chart_title);
  2863. cg->st_queued_ops = rrdset_create_localhost(
  2864. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2865. , "queued_ops"
  2866. , NULL
  2867. , "disk"
  2868. , "cgroup.queued_ops"
  2869. , title
  2870. , "operations"
  2871. , PLUGIN_CGROUPS_NAME
  2872. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2873. , cgroup_containers_chart_priority + 2000
  2874. , update_every
  2875. , RRDSET_TYPE_LINE
  2876. );
  2877. rrddim_add(cg->st_queued_ops, "read", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  2878. rrddim_add(cg->st_queued_ops, "write", NULL, -1, 1, RRD_ALGORITHM_ABSOLUTE);
  2879. }
  2880. else
  2881. rrdset_next(cg->st_queued_ops);
  2882. rrddim_set(cg->st_queued_ops, "read", cg->io_queued.Read);
  2883. rrddim_set(cg->st_queued_ops, "write", cg->io_queued.Write);
  2884. rrdset_done(cg->st_queued_ops);
  2885. }
  2886. if(likely(cg->io_merged.updated && cg->io_merged.enabled == CONFIG_BOOLEAN_YES)) {
  2887. if(unlikely(!cg->st_merged_ops)) {
  2888. snprintfz(title, CHART_TITLE_MAX, "Merged I/O Operations (all disks) for cgroup %s", cg->chart_title);
  2889. cg->st_merged_ops = rrdset_create_localhost(
  2890. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2891. , "merged_ops"
  2892. , NULL
  2893. , "disk"
  2894. , "cgroup.merged_ops"
  2895. , title
  2896. , "operations/s"
  2897. , PLUGIN_CGROUPS_NAME
  2898. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2899. , cgroup_containers_chart_priority + 2100
  2900. , update_every
  2901. , RRDSET_TYPE_LINE
  2902. );
  2903. rrddim_add(cg->st_merged_ops, "read", NULL, 1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2904. rrddim_add(cg->st_merged_ops, "write", NULL, -1, 1024, RRD_ALGORITHM_INCREMENTAL);
  2905. }
  2906. else
  2907. rrdset_next(cg->st_merged_ops);
  2908. rrddim_set(cg->st_merged_ops, "read", cg->io_merged.Read);
  2909. rrddim_set(cg->st_merged_ops, "write", cg->io_merged.Write);
  2910. rrdset_done(cg->st_merged_ops);
  2911. }
  2912. if (cg->options & CGROUP_OPTIONS_IS_UNIFIED) {
  2913. struct pressure *res = &cg->cpu_pressure;
  2914. if (likely(res->updated && res->some.enabled)) {
  2915. if (unlikely(!res->some.st)) {
  2916. RRDSET *chart;
  2917. snprintfz(title, CHART_TITLE_MAX, "CPU pressure for cgroup %s", cg->chart_title);
  2918. chart = res->some.st = rrdset_create_localhost(
  2919. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2920. , "cpu_pressure"
  2921. , NULL
  2922. , "cpu"
  2923. , "cgroup.cpu_pressure"
  2924. , title
  2925. , "percentage"
  2926. , PLUGIN_CGROUPS_NAME
  2927. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2928. , cgroup_containers_chart_priority + 2200
  2929. , update_every,
  2930. RRDSET_TYPE_LINE);
  2931. res->some.rd10 = rrddim_add(chart, "some 10", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2932. res->some.rd60 = rrddim_add(chart, "some 60", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2933. res->some.rd300 = rrddim_add(chart, "some 300", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2934. } else {
  2935. rrdset_next(res->some.st);
  2936. }
  2937. update_pressure_chart(&res->some);
  2938. }
  2939. res = &cg->memory_pressure;
  2940. if (likely(res->updated && res->some.enabled)) {
  2941. if (unlikely(!res->some.st)) {
  2942. RRDSET *chart;
  2943. snprintfz(title, CHART_TITLE_MAX, "Memory pressure for cgroup %s", cg->chart_title);
  2944. chart = res->some.st = rrdset_create_localhost(
  2945. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2946. , "mem_pressure"
  2947. , NULL
  2948. , "mem"
  2949. , "cgroup.memory_pressure"
  2950. , title
  2951. , "percentage"
  2952. , PLUGIN_CGROUPS_NAME
  2953. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2954. , cgroup_containers_chart_priority + 2300
  2955. , update_every,
  2956. RRDSET_TYPE_LINE);
  2957. res->some.rd10 = rrddim_add(chart, "some 10", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2958. res->some.rd60 = rrddim_add(chart, "some 60", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2959. res->some.rd300 = rrddim_add(chart, "some 300", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2960. } else {
  2961. rrdset_next(res->some.st);
  2962. }
  2963. update_pressure_chart(&res->some);
  2964. }
  2965. if (likely(res->updated && res->full.enabled)) {
  2966. if (unlikely(!res->full.st)) {
  2967. RRDSET *chart;
  2968. snprintfz(title, CHART_TITLE_MAX, "Memory full pressure for cgroup %s", cg->chart_title);
  2969. chart = res->full.st = rrdset_create_localhost(
  2970. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2971. , "mem_full_pressure"
  2972. , NULL
  2973. , "mem"
  2974. , "cgroup.memory_full_pressure"
  2975. , title
  2976. , "percentage"
  2977. , PLUGIN_CGROUPS_NAME
  2978. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  2979. , cgroup_containers_chart_priority + 2350
  2980. , update_every,
  2981. RRDSET_TYPE_LINE);
  2982. res->full.rd10 = rrddim_add(chart, "full 10", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2983. res->full.rd60 = rrddim_add(chart, "full 60", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2984. res->full.rd300 = rrddim_add(chart, "full 300", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  2985. } else {
  2986. rrdset_next(res->full.st);
  2987. }
  2988. update_pressure_chart(&res->full);
  2989. }
  2990. res = &cg->io_pressure;
  2991. if (likely(res->updated && res->some.enabled)) {
  2992. if (unlikely(!res->some.st)) {
  2993. RRDSET *chart;
  2994. snprintfz(title, CHART_TITLE_MAX, "I/O pressure for cgroup %s", cg->chart_title);
  2995. chart = res->some.st = rrdset_create_localhost(
  2996. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  2997. , "io_pressure"
  2998. , NULL
  2999. , "disk"
  3000. , "cgroup.io_pressure"
  3001. , title
  3002. , "percentage"
  3003. , PLUGIN_CGROUPS_NAME
  3004. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  3005. , cgroup_containers_chart_priority + 2400
  3006. , update_every,
  3007. RRDSET_TYPE_LINE);
  3008. res->some.rd10 = rrddim_add(chart, "some 10", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  3009. res->some.rd60 = rrddim_add(chart, "some 60", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  3010. res->some.rd300 = rrddim_add(chart, "some 300", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  3011. } else {
  3012. rrdset_next(res->some.st);
  3013. }
  3014. update_pressure_chart(&res->some);
  3015. }
  3016. if (likely(res->updated && res->full.enabled)) {
  3017. if (unlikely(!res->full.st)) {
  3018. RRDSET *chart;
  3019. snprintfz(title, CHART_TITLE_MAX, "I/O full pressure for cgroup %s", cg->chart_title);
  3020. chart = res->full.st = rrdset_create_localhost(
  3021. cgroup_chart_type(type, cg->chart_id, RRD_ID_LENGTH_MAX)
  3022. , "io_full_pressure"
  3023. , NULL
  3024. , "disk"
  3025. , "cgroup.io_full_pressure"
  3026. , title
  3027. , "percentage"
  3028. , PLUGIN_CGROUPS_NAME
  3029. , PLUGIN_CGROUPS_MODULE_CGROUPS_NAME
  3030. , cgroup_containers_chart_priority + 2450
  3031. , update_every,
  3032. RRDSET_TYPE_LINE);
  3033. res->full.rd10 = rrddim_add(chart, "full 10", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  3034. res->full.rd60 = rrddim_add(chart, "full 60", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  3035. res->full.rd300 = rrddim_add(chart, "full 300", NULL, 1, 100, RRD_ALGORITHM_ABSOLUTE);
  3036. } else {
  3037. rrdset_next(res->full.st);
  3038. }
  3039. update_pressure_chart(&res->full);
  3040. }
  3041. }
  3042. }
  3043. if(likely(cgroup_enable_systemd_services))
  3044. update_systemd_services_charts(update_every, services_do_cpu, services_do_mem_usage, services_do_mem_detailed
  3045. , services_do_mem_failcnt, services_do_swap_usage, services_do_io
  3046. , services_do_io_ops, services_do_throttle_io, services_do_throttle_ops
  3047. , services_do_queued_ops, services_do_merged_ops
  3048. );
  3049. debug(D_CGROUP, "done updating cgroups charts");
  3050. }
  3051. // ----------------------------------------------------------------------------
  3052. // cgroups main
  3053. static void cgroup_main_cleanup(void *ptr) {
  3054. struct netdata_static_thread *static_thread = (struct netdata_static_thread *)ptr;
  3055. static_thread->enabled = NETDATA_MAIN_THREAD_EXITING;
  3056. info("cleaning up...");
  3057. static_thread->enabled = NETDATA_MAIN_THREAD_EXITED;
  3058. }
  3059. void *cgroups_main(void *ptr) {
  3060. netdata_thread_cleanup_push(cgroup_main_cleanup, ptr);
  3061. struct rusage thread;
  3062. // when ZERO, attempt to do it
  3063. int vdo_cpu_netdata = config_get_boolean("plugin:cgroups", "cgroups plugin resource charts", 1);
  3064. read_cgroup_plugin_configuration();
  3065. RRDSET *stcpu_thread = NULL;
  3066. heartbeat_t hb;
  3067. heartbeat_init(&hb);
  3068. usec_t step = cgroup_update_every * USEC_PER_SEC;
  3069. usec_t find_every = cgroup_check_for_new_every * USEC_PER_SEC, find_dt = 0;
  3070. while(!netdata_exit) {
  3071. usec_t hb_dt = heartbeat_next(&hb, step);
  3072. if(unlikely(netdata_exit)) break;
  3073. // BEGIN -- the job to be done
  3074. find_dt += hb_dt;
  3075. if(unlikely(find_dt >= find_every || cgroups_check)) {
  3076. find_all_cgroups();
  3077. find_dt = 0;
  3078. cgroups_check = 0;
  3079. }
  3080. read_all_cgroups(cgroup_root);
  3081. update_cgroup_charts(cgroup_update_every);
  3082. // END -- the job is done
  3083. // --------------------------------------------------------------------
  3084. if(vdo_cpu_netdata) {
  3085. getrusage(RUSAGE_THREAD, &thread);
  3086. if(unlikely(!stcpu_thread)) {
  3087. stcpu_thread = rrdset_create_localhost(
  3088. "netdata"
  3089. , "plugin_cgroups_cpu"
  3090. , NULL
  3091. , "cgroups"
  3092. , NULL
  3093. , "NetData CGroups Plugin CPU usage"
  3094. , "milliseconds/s"
  3095. , PLUGIN_CGROUPS_NAME
  3096. , "stats"
  3097. , 132000
  3098. , cgroup_update_every
  3099. , RRDSET_TYPE_STACKED
  3100. );
  3101. rrddim_add(stcpu_thread, "user", NULL, 1, 1000, RRD_ALGORITHM_INCREMENTAL);
  3102. rrddim_add(stcpu_thread, "system", NULL, 1, 1000, RRD_ALGORITHM_INCREMENTAL);
  3103. }
  3104. else
  3105. rrdset_next(stcpu_thread);
  3106. rrddim_set(stcpu_thread, "user" , thread.ru_utime.tv_sec * 1000000ULL + thread.ru_utime.tv_usec);
  3107. rrddim_set(stcpu_thread, "system", thread.ru_stime.tv_sec * 1000000ULL + thread.ru_stime.tv_usec);
  3108. rrdset_done(stcpu_thread);
  3109. }
  3110. }
  3111. netdata_thread_cleanup_pop(1);
  3112. return NULL;
  3113. }