sys_fs_cgroup.c 142 KB

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