sys_fs_cgroup.c 171 KB

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