sys_fs_cgroup.c 143 KB

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