ebpf_vfs.c 106 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440
  1. // SPDX-License-Identifier: GPL-3.0-or-later
  2. #include <sys/resource.h>
  3. #include "ebpf.h"
  4. #include "ebpf_vfs.h"
  5. static char *vfs_dimension_names[NETDATA_KEY_PUBLISH_VFS_END] = { "delete", "read", "write",
  6. "fsync", "open", "create" };
  7. static char *vfs_id_names[NETDATA_KEY_PUBLISH_VFS_END] = { "vfs_unlink", "vfs_read", "vfs_write",
  8. "vfs_fsync", "vfs_open", "vfs_create"};
  9. static netdata_idx_t *vfs_hash_values = NULL;
  10. static netdata_syscall_stat_t vfs_aggregated_data[NETDATA_KEY_PUBLISH_VFS_END];
  11. static netdata_publish_syscall_t vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_END];
  12. netdata_publish_vfs_t *vfs_vector = NULL;
  13. static ebpf_local_maps_t vfs_maps[] = {{.name = "tbl_vfs_pid", .internal_input = ND_EBPF_DEFAULT_PID_SIZE,
  14. .user_input = 0, .type = NETDATA_EBPF_MAP_RESIZABLE | NETDATA_EBPF_MAP_PID,
  15. .map_fd = ND_EBPF_MAP_FD_NOT_INITIALIZED,
  16. #ifdef LIBBPF_MAJOR_VERSION
  17. .map_type = BPF_MAP_TYPE_PERCPU_HASH
  18. #endif
  19. },
  20. {.name = "tbl_vfs_stats", .internal_input = NETDATA_VFS_COUNTER,
  21. .user_input = 0, .type = NETDATA_EBPF_MAP_STATIC,
  22. .map_fd = ND_EBPF_MAP_FD_NOT_INITIALIZED,
  23. #ifdef LIBBPF_MAJOR_VERSION
  24. .map_type = BPF_MAP_TYPE_PERCPU_ARRAY
  25. #endif
  26. },
  27. {.name = "vfs_ctrl", .internal_input = NETDATA_CONTROLLER_END,
  28. .user_input = 0,
  29. .type = NETDATA_EBPF_MAP_CONTROLLER,
  30. .map_fd = ND_EBPF_MAP_FD_NOT_INITIALIZED,
  31. #ifdef LIBBPF_MAJOR_VERSION
  32. .map_type = BPF_MAP_TYPE_PERCPU_ARRAY
  33. #endif
  34. },
  35. {.name = NULL, .internal_input = 0, .user_input = 0,
  36. #ifdef LIBBPF_MAJOR_VERSION
  37. .map_type = BPF_MAP_TYPE_PERCPU_ARRAY
  38. #endif
  39. }};
  40. struct config vfs_config = { .first_section = NULL,
  41. .last_section = NULL,
  42. .mutex = NETDATA_MUTEX_INITIALIZER,
  43. .index = { .avl_tree = { .root = NULL, .compar = appconfig_section_compare },
  44. .rwlock = AVL_LOCK_INITIALIZER } };
  45. netdata_ebpf_targets_t vfs_targets[] = { {.name = "vfs_write", .mode = EBPF_LOAD_TRAMPOLINE},
  46. {.name = "vfs_writev", .mode = EBPF_LOAD_TRAMPOLINE},
  47. {.name = "vfs_read", .mode = EBPF_LOAD_TRAMPOLINE},
  48. {.name = "vfs_readv", .mode = EBPF_LOAD_TRAMPOLINE},
  49. {.name = "vfs_unlink", .mode = EBPF_LOAD_TRAMPOLINE},
  50. {.name = "vfs_fsync", .mode = EBPF_LOAD_TRAMPOLINE},
  51. {.name = "vfs_open", .mode = EBPF_LOAD_TRAMPOLINE},
  52. {.name = "vfs_create", .mode = EBPF_LOAD_TRAMPOLINE},
  53. {.name = "release_task", .mode = EBPF_LOAD_TRAMPOLINE},
  54. {.name = NULL, .mode = EBPF_LOAD_TRAMPOLINE}};
  55. #ifdef NETDATA_DEV_MODE
  56. int vfs_disable_priority;
  57. #endif
  58. #ifdef LIBBPF_MAJOR_VERSION
  59. /**
  60. * Disable probe
  61. *
  62. * Disable all probes to use exclusively another method.
  63. *
  64. * @param obj is the main structure for bpf objects
  65. */
  66. static void ebpf_vfs_disable_probes(struct vfs_bpf *obj)
  67. {
  68. bpf_program__set_autoload(obj->progs.netdata_vfs_write_kprobe, false);
  69. bpf_program__set_autoload(obj->progs.netdata_vfs_write_kretprobe, false);
  70. bpf_program__set_autoload(obj->progs.netdata_vfs_writev_kprobe, false);
  71. bpf_program__set_autoload(obj->progs.netdata_vfs_writev_kretprobe, false);
  72. bpf_program__set_autoload(obj->progs.netdata_vfs_read_kprobe, false);
  73. bpf_program__set_autoload(obj->progs.netdata_vfs_read_kretprobe, false);
  74. bpf_program__set_autoload(obj->progs.netdata_vfs_readv_kprobe, false);
  75. bpf_program__set_autoload(obj->progs.netdata_vfs_readv_kretprobe, false);
  76. bpf_program__set_autoload(obj->progs.netdata_vfs_unlink_kprobe, false);
  77. bpf_program__set_autoload(obj->progs.netdata_vfs_unlink_kretprobe, false);
  78. bpf_program__set_autoload(obj->progs.netdata_vfs_fsync_kprobe, false);
  79. bpf_program__set_autoload(obj->progs.netdata_vfs_fsync_kretprobe, false);
  80. bpf_program__set_autoload(obj->progs.netdata_vfs_open_kprobe, false);
  81. bpf_program__set_autoload(obj->progs.netdata_vfs_open_kretprobe, false);
  82. bpf_program__set_autoload(obj->progs.netdata_vfs_create_kprobe, false);
  83. bpf_program__set_autoload(obj->progs.netdata_vfs_create_kretprobe, false);
  84. bpf_program__set_autoload(obj->progs.netdata_vfs_release_task_kprobe, false);
  85. }
  86. /*
  87. * Disable trampoline
  88. *
  89. * Disable all trampoline to use exclusively another method.
  90. *
  91. * @param obj is the main structure for bpf objects.
  92. */
  93. static void ebpf_vfs_disable_trampoline(struct vfs_bpf *obj)
  94. {
  95. bpf_program__set_autoload(obj->progs.netdata_vfs_write_fentry, false);
  96. bpf_program__set_autoload(obj->progs.netdata_vfs_write_fexit, false);
  97. bpf_program__set_autoload(obj->progs.netdata_vfs_writev_fentry, false);
  98. bpf_program__set_autoload(obj->progs.netdata_vfs_writev_fexit, false);
  99. bpf_program__set_autoload(obj->progs.netdata_vfs_read_fentry, false);
  100. bpf_program__set_autoload(obj->progs.netdata_vfs_read_fexit, false);
  101. bpf_program__set_autoload(obj->progs.netdata_vfs_readv_fentry, false);
  102. bpf_program__set_autoload(obj->progs.netdata_vfs_readv_fexit, false);
  103. bpf_program__set_autoload(obj->progs.netdata_vfs_unlink_fentry, false);
  104. bpf_program__set_autoload(obj->progs.netdata_vfs_fsync_fentry, false);
  105. bpf_program__set_autoload(obj->progs.netdata_vfs_fsync_fexit, false);
  106. bpf_program__set_autoload(obj->progs.netdata_vfs_open_fentry, false);
  107. bpf_program__set_autoload(obj->progs.netdata_vfs_open_fexit, false);
  108. bpf_program__set_autoload(obj->progs.netdata_vfs_create_fentry, false);
  109. bpf_program__set_autoload(obj->progs.netdata_vfs_release_task_fentry, false);
  110. }
  111. /**
  112. * Set trampoline target
  113. *
  114. * Set the targets we will monitor.
  115. *
  116. * @param obj is the main structure for bpf objects.
  117. */
  118. static void ebpf_vfs_set_trampoline_target(struct vfs_bpf *obj)
  119. {
  120. bpf_program__set_attach_target(obj->progs.netdata_vfs_write_fentry, 0, vfs_targets[NETDATA_EBPF_VFS_WRITE].name);
  121. bpf_program__set_attach_target(obj->progs.netdata_vfs_write_fexit, 0, vfs_targets[NETDATA_EBPF_VFS_WRITE].name);
  122. bpf_program__set_attach_target(obj->progs.netdata_vfs_writev_fentry, 0, vfs_targets[NETDATA_EBPF_VFS_WRITEV].name);
  123. bpf_program__set_attach_target(obj->progs.netdata_vfs_writev_fexit, 0, vfs_targets[NETDATA_EBPF_VFS_WRITEV].name);
  124. bpf_program__set_attach_target(obj->progs.netdata_vfs_read_fentry, 0, vfs_targets[NETDATA_EBPF_VFS_READ].name);
  125. bpf_program__set_attach_target(obj->progs.netdata_vfs_read_fexit, 0, vfs_targets[NETDATA_EBPF_VFS_READ].name);
  126. bpf_program__set_attach_target(obj->progs.netdata_vfs_readv_fentry, 0, vfs_targets[NETDATA_EBPF_VFS_READV].name);
  127. bpf_program__set_attach_target(obj->progs.netdata_vfs_readv_fexit, 0, vfs_targets[NETDATA_EBPF_VFS_READV].name);
  128. bpf_program__set_attach_target(obj->progs.netdata_vfs_unlink_fentry, 0, vfs_targets[NETDATA_EBPF_VFS_UNLINK].name);
  129. bpf_program__set_attach_target(obj->progs.netdata_vfs_fsync_fentry, 0, vfs_targets[NETDATA_EBPF_VFS_FSYNC].name);
  130. bpf_program__set_attach_target(obj->progs.netdata_vfs_fsync_fexit, 0, vfs_targets[NETDATA_EBPF_VFS_FSYNC].name);
  131. bpf_program__set_attach_target(obj->progs.netdata_vfs_open_fentry, 0, vfs_targets[NETDATA_EBPF_VFS_OPEN].name);
  132. bpf_program__set_attach_target(obj->progs.netdata_vfs_open_fexit, 0, vfs_targets[NETDATA_EBPF_VFS_OPEN].name);
  133. bpf_program__set_attach_target(obj->progs.netdata_vfs_create_fentry, 0, vfs_targets[NETDATA_EBPF_VFS_CREATE].name);
  134. bpf_program__set_attach_target(obj->progs.netdata_vfs_release_task_fentry, 0, EBPF_COMMON_FNCT_CLEAN_UP);
  135. }
  136. /**
  137. * Attach Probe
  138. *
  139. * Attach probes to target
  140. *
  141. * @param obj is the main structure for bpf objects.
  142. *
  143. * @return It returns 0 on success and -1 otherwise.
  144. */
  145. static int ebpf_vfs_attach_probe(struct vfs_bpf *obj)
  146. {
  147. obj->links.netdata_vfs_write_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_write_kprobe, false,
  148. vfs_targets[NETDATA_EBPF_VFS_WRITE].name);
  149. int ret = libbpf_get_error(obj->links.netdata_vfs_write_kprobe);
  150. if (ret)
  151. return -1;
  152. obj->links.netdata_vfs_write_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_write_kretprobe, true,
  153. vfs_targets[NETDATA_EBPF_VFS_WRITE].name);
  154. ret = libbpf_get_error(obj->links.netdata_vfs_write_kretprobe);
  155. if (ret)
  156. return -1;
  157. obj->links.netdata_vfs_writev_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_writev_kprobe, false,
  158. vfs_targets[NETDATA_EBPF_VFS_WRITEV].name);
  159. ret = libbpf_get_error(obj->links.netdata_vfs_writev_kprobe);
  160. if (ret)
  161. return -1;
  162. obj->links.netdata_vfs_writev_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_writev_kretprobe, true,
  163. vfs_targets[NETDATA_EBPF_VFS_WRITEV].name);
  164. ret = libbpf_get_error(obj->links.netdata_vfs_writev_kretprobe);
  165. if (ret)
  166. return -1;
  167. obj->links.netdata_vfs_read_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_read_kprobe, false,
  168. vfs_targets[NETDATA_EBPF_VFS_READ].name);
  169. ret = libbpf_get_error(obj->links.netdata_vfs_read_kprobe);
  170. if (ret)
  171. return -1;
  172. obj->links.netdata_vfs_read_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_read_kretprobe, true,
  173. vfs_targets[NETDATA_EBPF_VFS_READ].name);
  174. ret = libbpf_get_error(obj->links.netdata_vfs_read_kretprobe);
  175. if (ret)
  176. return -1;
  177. obj->links.netdata_vfs_readv_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_readv_kprobe, false,
  178. vfs_targets[NETDATA_EBPF_VFS_READV].name);
  179. ret = libbpf_get_error(obj->links.netdata_vfs_readv_kprobe);
  180. if (ret)
  181. return -1;
  182. obj->links.netdata_vfs_readv_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_readv_kretprobe, true,
  183. vfs_targets[NETDATA_EBPF_VFS_READV].name);
  184. ret = libbpf_get_error(obj->links.netdata_vfs_readv_kretprobe);
  185. if (ret)
  186. return -1;
  187. obj->links.netdata_vfs_unlink_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_unlink_kprobe, false,
  188. vfs_targets[NETDATA_EBPF_VFS_UNLINK].name);
  189. ret = libbpf_get_error(obj->links.netdata_vfs_unlink_kprobe);
  190. if (ret)
  191. return -1;
  192. obj->links.netdata_vfs_unlink_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_unlink_kretprobe, true,
  193. vfs_targets[NETDATA_EBPF_VFS_UNLINK].name);
  194. ret = libbpf_get_error(obj->links.netdata_vfs_unlink_kretprobe);
  195. if (ret)
  196. return -1;
  197. obj->links.netdata_vfs_fsync_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_fsync_kprobe, false,
  198. vfs_targets[NETDATA_EBPF_VFS_FSYNC].name);
  199. ret = libbpf_get_error(obj->links.netdata_vfs_fsync_kprobe);
  200. if (ret)
  201. return -1;
  202. obj->links.netdata_vfs_fsync_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_fsync_kretprobe, true,
  203. vfs_targets[NETDATA_EBPF_VFS_FSYNC].name);
  204. ret = libbpf_get_error(obj->links.netdata_vfs_fsync_kretprobe);
  205. if (ret)
  206. return -1;
  207. obj->links.netdata_vfs_open_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_open_kprobe, false,
  208. vfs_targets[NETDATA_EBPF_VFS_OPEN].name);
  209. ret = libbpf_get_error(obj->links.netdata_vfs_open_kprobe);
  210. if (ret)
  211. return -1;
  212. obj->links.netdata_vfs_open_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_open_kretprobe, true,
  213. vfs_targets[NETDATA_EBPF_VFS_OPEN].name);
  214. ret = libbpf_get_error(obj->links.netdata_vfs_open_kretprobe);
  215. if (ret)
  216. return -1;
  217. obj->links.netdata_vfs_create_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_create_kprobe, false,
  218. vfs_targets[NETDATA_EBPF_VFS_CREATE].name);
  219. ret = libbpf_get_error(obj->links.netdata_vfs_create_kprobe);
  220. if (ret)
  221. return -1;
  222. obj->links.netdata_vfs_create_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_create_kretprobe, true,
  223. vfs_targets[NETDATA_EBPF_VFS_CREATE].name);
  224. ret = libbpf_get_error(obj->links.netdata_vfs_create_kretprobe);
  225. if (ret)
  226. return -1;
  227. obj->links.netdata_vfs_fsync_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_fsync_kprobe, false,
  228. vfs_targets[NETDATA_EBPF_VFS_FSYNC].name);
  229. ret = libbpf_get_error(obj->links.netdata_vfs_fsync_kprobe);
  230. if (ret)
  231. return -1;
  232. obj->links.netdata_vfs_fsync_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_fsync_kretprobe, true,
  233. vfs_targets[NETDATA_EBPF_VFS_FSYNC].name);
  234. ret = libbpf_get_error(obj->links.netdata_vfs_fsync_kretprobe);
  235. if (ret)
  236. return -1;
  237. obj->links.netdata_vfs_open_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_open_kprobe, false,
  238. vfs_targets[NETDATA_EBPF_VFS_OPEN].name);
  239. ret = libbpf_get_error(obj->links.netdata_vfs_open_kprobe);
  240. if (ret)
  241. return -1;
  242. obj->links.netdata_vfs_open_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_open_kretprobe, true,
  243. vfs_targets[NETDATA_EBPF_VFS_OPEN].name);
  244. ret = libbpf_get_error(obj->links.netdata_vfs_open_kretprobe);
  245. if (ret)
  246. return -1;
  247. obj->links.netdata_vfs_create_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_create_kprobe, false,
  248. vfs_targets[NETDATA_EBPF_VFS_CREATE].name);
  249. ret = libbpf_get_error(obj->links.netdata_vfs_create_kprobe);
  250. if (ret)
  251. return -1;
  252. obj->links.netdata_vfs_create_kretprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_create_kretprobe, true,
  253. vfs_targets[NETDATA_EBPF_VFS_CREATE].name);
  254. ret = libbpf_get_error(obj->links.netdata_vfs_create_kretprobe);
  255. if (ret)
  256. return -1;
  257. obj->links.netdata_vfs_release_task_kprobe = bpf_program__attach_kprobe(obj->progs.netdata_vfs_release_task_fentry,
  258. true,
  259. EBPF_COMMON_FNCT_CLEAN_UP);
  260. ret = libbpf_get_error(obj->links.netdata_vfs_release_task_kprobe);
  261. if (ret)
  262. return -1;
  263. return 0;
  264. }
  265. /**
  266. * Adjust Size
  267. *
  268. * Resize maps according input from users.
  269. *
  270. * @param obj is the main structure for bpf objects.
  271. * @param em structure with configuration
  272. */
  273. static void ebpf_vfs_adjust_map(struct vfs_bpf *obj, ebpf_module_t *em)
  274. {
  275. ebpf_update_map_size(obj->maps.tbl_vfs_pid, &vfs_maps[NETDATA_VFS_PID],
  276. em, bpf_map__name(obj->maps.tbl_vfs_pid));
  277. ebpf_update_map_type(obj->maps.tbl_vfs_pid, &vfs_maps[NETDATA_VFS_PID]);
  278. ebpf_update_map_type(obj->maps.tbl_vfs_stats, &vfs_maps[NETDATA_VFS_ALL]);
  279. ebpf_update_map_type(obj->maps.vfs_ctrl, &vfs_maps[NETDATA_VFS_CTRL]);
  280. }
  281. /**
  282. * Set hash tables
  283. *
  284. * Set the values for maps according the value given by kernel.
  285. *
  286. * @param obj is the main structure for bpf objects.
  287. */
  288. static void ebpf_vfs_set_hash_tables(struct vfs_bpf *obj)
  289. {
  290. vfs_maps[NETDATA_VFS_ALL].map_fd = bpf_map__fd(obj->maps.tbl_vfs_stats);
  291. vfs_maps[NETDATA_VFS_PID].map_fd = bpf_map__fd(obj->maps.tbl_vfs_pid);
  292. vfs_maps[NETDATA_VFS_CTRL].map_fd = bpf_map__fd(obj->maps.vfs_ctrl);
  293. }
  294. /**
  295. * Disable Release Task
  296. *
  297. * Disable release task when apps is not enabled.
  298. *
  299. * @param obj is the main structure for bpf objects.
  300. */
  301. static void ebpf_vfs_disable_release_task(struct vfs_bpf *obj)
  302. {
  303. bpf_program__set_autoload(obj->progs.netdata_vfs_release_task_fentry, false);
  304. bpf_program__set_autoload(obj->progs.netdata_vfs_release_task_kprobe, false);
  305. }
  306. /**
  307. * Load and attach
  308. *
  309. * Load and attach the eBPF code in kernel.
  310. *
  311. * @param obj is the main structure for bpf objects.
  312. * @param em structure with configuration
  313. *
  314. * @return it returns 0 on success and -1 otherwise
  315. */
  316. static inline int ebpf_vfs_load_and_attach(struct vfs_bpf *obj, ebpf_module_t *em)
  317. {
  318. netdata_ebpf_targets_t *mt = em->targets;
  319. netdata_ebpf_program_loaded_t test = mt[NETDATA_EBPF_VFS_WRITE].mode;
  320. if (test == EBPF_LOAD_TRAMPOLINE) {
  321. ebpf_vfs_disable_probes(obj);
  322. ebpf_vfs_set_trampoline_target(obj);
  323. } else {
  324. ebpf_vfs_disable_trampoline(obj);
  325. }
  326. ebpf_vfs_adjust_map(obj, em);
  327. if (!em->apps_charts && !em->cgroup_charts)
  328. ebpf_vfs_disable_release_task(obj);
  329. int ret = vfs_bpf__load(obj);
  330. if (ret) {
  331. return ret;
  332. }
  333. ret = (test == EBPF_LOAD_TRAMPOLINE) ? vfs_bpf__attach(obj) : ebpf_vfs_attach_probe(obj);
  334. if (!ret) {
  335. ebpf_vfs_set_hash_tables(obj);
  336. ebpf_update_controller(vfs_maps[NETDATA_VFS_CTRL].map_fd, em);
  337. }
  338. return ret;
  339. }
  340. #endif
  341. /*****************************************************************
  342. *
  343. * FUNCTIONS TO CLOSE THE THREAD
  344. *
  345. *****************************************************************/
  346. static void ebpf_obsolete_specific_vfs_charts(char *type, ebpf_module_t *em);
  347. /**
  348. * Obsolete services
  349. *
  350. * Obsolete all service charts created
  351. *
  352. * @param em a pointer to `struct ebpf_module`
  353. */
  354. static void ebpf_obsolete_vfs_services(ebpf_module_t *em)
  355. {
  356. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  357. NETDATA_SYSCALL_APPS_FILE_DELETED,
  358. "Files deleted",
  359. EBPF_COMMON_DIMENSION_CALL,
  360. NETDATA_VFS_CGROUP_GROUP,
  361. NETDATA_EBPF_CHART_TYPE_STACKED,
  362. NULL,
  363. 20065,
  364. em->update_every);
  365. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  366. NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS,
  367. "Write to disk",
  368. EBPF_COMMON_DIMENSION_CALL,
  369. NETDATA_VFS_CGROUP_GROUP,
  370. NETDATA_EBPF_CHART_TYPE_STACKED,
  371. NULL,
  372. 20066,
  373. em->update_every);
  374. if (em->mode < MODE_ENTRY) {
  375. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  376. NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR,
  377. "Fails to write",
  378. EBPF_COMMON_DIMENSION_CALL,
  379. NETDATA_VFS_CGROUP_GROUP,
  380. NETDATA_EBPF_CHART_TYPE_STACKED,
  381. NULL,
  382. 20067,
  383. em->update_every);
  384. }
  385. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  386. NETDATA_SYSCALL_APPS_VFS_READ_CALLS,
  387. "Read from disk",
  388. EBPF_COMMON_DIMENSION_CALL,
  389. NETDATA_VFS_CGROUP_GROUP,
  390. NETDATA_EBPF_CHART_TYPE_STACKED,
  391. NULL,
  392. 20068,
  393. em->update_every);
  394. if (em->mode < MODE_ENTRY) {
  395. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  396. NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR,
  397. "Fails to read",
  398. EBPF_COMMON_DIMENSION_CALL,
  399. NETDATA_VFS_CGROUP_GROUP,
  400. NETDATA_EBPF_CHART_TYPE_STACKED,
  401. NULL,
  402. 20069,
  403. em->update_every);
  404. }
  405. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  406. NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES,
  407. "Bytes written on disk",
  408. EBPF_COMMON_DIMENSION_BYTES,
  409. NETDATA_VFS_CGROUP_GROUP,
  410. NETDATA_EBPF_CHART_TYPE_STACKED,
  411. NULL,
  412. 20070,
  413. em->update_every);
  414. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  415. NETDATA_SYSCALL_APPS_VFS_READ_BYTES,
  416. "Bytes read from disk",
  417. EBPF_COMMON_DIMENSION_BYTES,
  418. NETDATA_VFS_CGROUP_GROUP,
  419. NETDATA_EBPF_CHART_TYPE_STACKED,
  420. NULL,
  421. 20071,
  422. em->update_every);
  423. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  424. NETDATA_SYSCALL_APPS_VFS_FSYNC,
  425. "Calls to <code>vfs_fsync</code>",
  426. EBPF_COMMON_DIMENSION_CALL,
  427. NETDATA_VFS_CGROUP_GROUP,
  428. NETDATA_EBPF_CHART_TYPE_STACKED,
  429. NULL,
  430. 20072,
  431. em->update_every);
  432. if (em->mode < MODE_ENTRY) {
  433. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  434. NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR,
  435. "Sync error",
  436. EBPF_COMMON_DIMENSION_CALL,
  437. NETDATA_VFS_CGROUP_GROUP,
  438. NETDATA_EBPF_CHART_TYPE_STACKED,
  439. NULL,
  440. 20073,
  441. em->update_every);
  442. }
  443. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  444. NETDATA_SYSCALL_APPS_VFS_OPEN,
  445. "Calls to <code>vfs_open</code>",
  446. EBPF_COMMON_DIMENSION_CALL,
  447. NETDATA_VFS_CGROUP_GROUP,
  448. NETDATA_EBPF_CHART_TYPE_STACKED,
  449. NULL,
  450. 20074,
  451. em->update_every);
  452. if (em->mode < MODE_ENTRY) {
  453. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  454. NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR,
  455. "Open error",
  456. EBPF_COMMON_DIMENSION_CALL,
  457. NETDATA_VFS_CGROUP_GROUP,
  458. NETDATA_EBPF_CHART_TYPE_STACKED,
  459. NULL,
  460. 20075,
  461. em->update_every);
  462. }
  463. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  464. NETDATA_SYSCALL_APPS_VFS_CREATE,
  465. "Calls to <code>vfs_create</code>",
  466. EBPF_COMMON_DIMENSION_CALL,
  467. NETDATA_VFS_CGROUP_GROUP,
  468. NETDATA_EBPF_CHART_TYPE_STACKED,
  469. NULL,
  470. 20076,
  471. em->update_every);
  472. if (em->mode < MODE_ENTRY) {
  473. ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY,
  474. NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR,
  475. "Create error",
  476. EBPF_COMMON_DIMENSION_CALL,
  477. NETDATA_VFS_CGROUP_GROUP,
  478. NETDATA_EBPF_CHART_TYPE_STACKED,
  479. NULL,
  480. 20077,
  481. em->update_every);
  482. }
  483. }
  484. /**
  485. * Obsolete cgroup chart
  486. *
  487. * Send obsolete for all charts created before to close.
  488. *
  489. * @param em a pointer to `struct ebpf_module`
  490. */
  491. static inline void ebpf_obsolete_vfs_cgroup_charts(ebpf_module_t *em) {
  492. pthread_mutex_lock(&mutex_cgroup_shm);
  493. ebpf_obsolete_vfs_services(em);
  494. ebpf_cgroup_target_t *ect;
  495. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  496. if (ect->systemd)
  497. continue;
  498. ebpf_obsolete_specific_vfs_charts(ect->name, em);
  499. }
  500. pthread_mutex_unlock(&mutex_cgroup_shm);
  501. }
  502. /**
  503. * Obsolette apps charts
  504. *
  505. * Obsolete apps charts.
  506. *
  507. * @param em a pointer to the structure with the default values.
  508. */
  509. void ebpf_obsolete_vfs_apps_charts(struct ebpf_module *em)
  510. {
  511. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  512. NETDATA_SYSCALL_APPS_FILE_DELETED,
  513. "Files deleted",
  514. EBPF_COMMON_DIMENSION_CALL,
  515. NETDATA_VFS_GROUP,
  516. NETDATA_EBPF_CHART_TYPE_STACKED,
  517. NULL,
  518. 20065,
  519. em->update_every);
  520. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  521. NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS,
  522. "Write to disk",
  523. EBPF_COMMON_DIMENSION_CALL,
  524. NETDATA_VFS_GROUP,
  525. NETDATA_EBPF_CHART_TYPE_STACKED,
  526. NULL,
  527. 20066,
  528. em->update_every);
  529. if (em->mode < MODE_ENTRY) {
  530. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  531. NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR,
  532. "Fails to write",
  533. EBPF_COMMON_DIMENSION_CALL,
  534. NETDATA_VFS_GROUP,
  535. NETDATA_EBPF_CHART_TYPE_STACKED,
  536. NULL,
  537. 20067,
  538. em->update_every);
  539. }
  540. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  541. NETDATA_SYSCALL_APPS_VFS_READ_CALLS,
  542. "Read from disk",
  543. EBPF_COMMON_DIMENSION_CALL,
  544. NETDATA_VFS_GROUP,
  545. NETDATA_EBPF_CHART_TYPE_STACKED,
  546. NULL,
  547. 20068,
  548. em->update_every);
  549. if (em->mode < MODE_ENTRY) {
  550. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  551. NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR,
  552. "Fails to read",
  553. EBPF_COMMON_DIMENSION_CALL,
  554. NETDATA_VFS_GROUP,
  555. NETDATA_EBPF_CHART_TYPE_STACKED,
  556. NULL,
  557. 20069,
  558. em->update_every);
  559. }
  560. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  561. NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES,
  562. "Bytes written on disk",
  563. EBPF_COMMON_DIMENSION_BYTES,
  564. NETDATA_VFS_GROUP,
  565. NETDATA_EBPF_CHART_TYPE_STACKED,
  566. NULL,
  567. 20070,
  568. em->update_every);
  569. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  570. NETDATA_SYSCALL_APPS_VFS_READ_BYTES,
  571. "Bytes read from disk",
  572. EBPF_COMMON_DIMENSION_BYTES,
  573. NETDATA_VFS_GROUP,
  574. NETDATA_EBPF_CHART_TYPE_STACKED,
  575. NULL,
  576. 20071,
  577. em->update_every);
  578. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  579. NETDATA_SYSCALL_APPS_VFS_FSYNC,
  580. "Calls for <code>vfs_fsync</code>",
  581. EBPF_COMMON_DIMENSION_CALL,
  582. NETDATA_VFS_GROUP,
  583. NETDATA_EBPF_CHART_TYPE_STACKED,
  584. NULL,
  585. 20072,
  586. em->update_every);
  587. if (em->mode < MODE_ENTRY) {
  588. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  589. NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR,
  590. "Sync error",
  591. EBPF_COMMON_DIMENSION_CALL,
  592. NETDATA_VFS_GROUP,
  593. NETDATA_EBPF_CHART_TYPE_STACKED,
  594. NULL,
  595. 20073,
  596. em->update_every);
  597. }
  598. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  599. NETDATA_SYSCALL_APPS_VFS_OPEN,
  600. "Calls for <code>vfs_open</code>",
  601. EBPF_COMMON_DIMENSION_CALL,
  602. NETDATA_VFS_GROUP,
  603. NETDATA_EBPF_CHART_TYPE_STACKED,
  604. NULL,
  605. 20074,
  606. em->update_every);
  607. if (em->mode < MODE_ENTRY) {
  608. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  609. NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR,
  610. "Open error",
  611. EBPF_COMMON_DIMENSION_CALL,
  612. NETDATA_VFS_GROUP,
  613. NETDATA_EBPF_CHART_TYPE_STACKED,
  614. NULL,
  615. 20075,
  616. em->update_every);
  617. }
  618. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  619. NETDATA_SYSCALL_APPS_VFS_CREATE,
  620. "Calls for <code>vfs_create</code>",
  621. EBPF_COMMON_DIMENSION_CALL,
  622. NETDATA_VFS_GROUP,
  623. NETDATA_EBPF_CHART_TYPE_STACKED,
  624. NULL,
  625. 20076,
  626. em->update_every);
  627. if (em->mode < MODE_ENTRY) {
  628. ebpf_write_chart_obsolete(NETDATA_APPS_FAMILY,
  629. NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR,
  630. "Create error",
  631. EBPF_COMMON_DIMENSION_CALL,
  632. NETDATA_VFS_GROUP,
  633. NETDATA_EBPF_CHART_TYPE_STACKED,
  634. NULL,
  635. 20077,
  636. em->update_every);
  637. }
  638. }
  639. /**
  640. * Obsolete global
  641. *
  642. * Obsolete global charts created by thread.
  643. *
  644. * @param em a pointer to `struct ebpf_module`
  645. */
  646. static void ebpf_obsolete_vfs_global(ebpf_module_t *em)
  647. {
  648. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  649. NETDATA_VFS_FILE_CLEAN_COUNT,
  650. "Remove files",
  651. EBPF_COMMON_DIMENSION_CALL,
  652. NETDATA_VFS_GROUP,
  653. NETDATA_EBPF_CHART_TYPE_LINE,
  654. NULL,
  655. NETDATA_CHART_PRIO_FILESYSTEM_VFS_CLEAN,
  656. em->update_every);
  657. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  658. NETDATA_VFS_FILE_IO_COUNT,
  659. "Calls to IO",
  660. EBPF_COMMON_DIMENSION_CALL,
  661. NETDATA_VFS_GROUP,
  662. NETDATA_EBPF_CHART_TYPE_LINE,
  663. NULL,
  664. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_COUNT,
  665. em->update_every);
  666. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  667. NETDATA_VFS_IO_FILE_BYTES,
  668. "Bytes written and read",
  669. EBPF_COMMON_DIMENSION_BYTES,
  670. NETDATA_VFS_GROUP,
  671. NETDATA_EBPF_CHART_TYPE_LINE,
  672. NULL,
  673. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_BYTES,
  674. em->update_every);
  675. if (em->mode < MODE_ENTRY) {
  676. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  677. NETDATA_VFS_FILE_ERR_COUNT,
  678. "Fails to write or read",
  679. EBPF_COMMON_DIMENSION_CALL,
  680. NETDATA_VFS_GROUP,
  681. NETDATA_EBPF_CHART_TYPE_LINE,
  682. NULL,
  683. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EBYTES,
  684. em->update_every);
  685. }
  686. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  687. NETDATA_VFS_FSYNC,
  688. "Calls for <code>vfs_fsync</code>",
  689. EBPF_COMMON_DIMENSION_CALL,
  690. NETDATA_VFS_GROUP,
  691. NETDATA_EBPF_CHART_TYPE_LINE,
  692. NULL,
  693. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_FSYNC,
  694. em->update_every);
  695. if (em->mode < MODE_ENTRY) {
  696. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  697. NETDATA_VFS_FSYNC_ERR,
  698. "Fails to synchronize",
  699. EBPF_COMMON_DIMENSION_CALL,
  700. NETDATA_VFS_GROUP,
  701. NETDATA_EBPF_CHART_TYPE_LINE,
  702. NULL,
  703. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EFSYNC,
  704. em->update_every);
  705. }
  706. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  707. NETDATA_VFS_OPEN,
  708. "Calls for <code>vfs_open</code>",
  709. EBPF_COMMON_DIMENSION_CALL,
  710. NETDATA_VFS_GROUP,
  711. NETDATA_EBPF_CHART_TYPE_LINE,
  712. NULL,
  713. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_OPEN,
  714. em->update_every);
  715. if (em->mode < MODE_ENTRY) {
  716. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  717. NETDATA_VFS_OPEN_ERR,
  718. "Fails to open a file",
  719. EBPF_COMMON_DIMENSION_CALL,
  720. NETDATA_VFS_GROUP,
  721. NETDATA_EBPF_CHART_TYPE_LINE,
  722. NULL,
  723. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EOPEN,
  724. em->update_every);
  725. }
  726. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  727. NETDATA_VFS_CREATE,
  728. "Calls for <code>vfs_create</code>",
  729. EBPF_COMMON_DIMENSION_CALL,
  730. NETDATA_VFS_GROUP,
  731. NETDATA_EBPF_CHART_TYPE_LINE,
  732. NULL,
  733. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_CREATE,
  734. em->update_every);
  735. if (em->mode < MODE_ENTRY) {
  736. ebpf_write_chart_obsolete(NETDATA_FILESYSTEM_FAMILY,
  737. NETDATA_VFS_CREATE_ERR,
  738. "Fails to create a file.",
  739. EBPF_COMMON_DIMENSION_CALL,
  740. NETDATA_VFS_GROUP,
  741. NETDATA_EBPF_CHART_TYPE_LINE,
  742. NULL,
  743. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_ECREATE,
  744. em->update_every);
  745. }
  746. }
  747. /**
  748. * Exit
  749. *
  750. * Cancel thread and exit.
  751. *
  752. * @param ptr thread data.
  753. **/
  754. static void ebpf_vfs_exit(void *ptr)
  755. {
  756. ebpf_module_t *em = (ebpf_module_t *)ptr;
  757. if (em->enabled == NETDATA_THREAD_EBPF_FUNCTION_RUNNING) {
  758. pthread_mutex_lock(&lock);
  759. if (em->cgroup_charts) {
  760. ebpf_obsolete_vfs_cgroup_charts(em);
  761. fflush(stdout);
  762. }
  763. if (em->apps_charts & NETDATA_EBPF_APPS_FLAG_CHART_CREATED) {
  764. ebpf_obsolete_vfs_apps_charts(em);
  765. }
  766. ebpf_obsolete_vfs_global(em);
  767. #ifdef NETDATA_DEV_MODE
  768. if (ebpf_aral_vfs_pid)
  769. ebpf_statistic_obsolete_aral_chart(em, vfs_disable_priority);
  770. #endif
  771. fflush(stdout);
  772. pthread_mutex_unlock(&lock);
  773. }
  774. ebpf_update_kernel_memory_with_vector(&plugin_statistics, em->maps, EBPF_ACTION_STAT_REMOVE);
  775. #ifdef LIBBPF_MAJOR_VERSION
  776. if (vfs_bpf_obj) {
  777. vfs_bpf__destroy(vfs_bpf_obj);
  778. vfs_bpf_obj = NULL;
  779. }
  780. #endif
  781. if (em->objects) {
  782. ebpf_unload_legacy_code(em->objects, em->probe_links);
  783. em->objects = NULL;
  784. em->probe_links = NULL;
  785. }
  786. pthread_mutex_lock(&ebpf_exit_cleanup);
  787. em->enabled = NETDATA_THREAD_EBPF_STOPPED;
  788. ebpf_update_stats(&plugin_statistics, em);
  789. pthread_mutex_unlock(&ebpf_exit_cleanup);
  790. }
  791. /*****************************************************************
  792. *
  793. * FUNCTIONS WITH THE MAIN LOOP
  794. *
  795. *****************************************************************/
  796. /**
  797. * Send data to Netdata calling auxiliary functions.
  798. *
  799. * @param em the structure with thread information
  800. */
  801. static void ebpf_vfs_send_data(ebpf_module_t *em)
  802. {
  803. netdata_publish_vfs_common_t pvc;
  804. pvc.write = (long)vfs_aggregated_data[NETDATA_KEY_PUBLISH_VFS_WRITE].bytes;
  805. pvc.read = (long)vfs_aggregated_data[NETDATA_KEY_PUBLISH_VFS_READ].bytes;
  806. write_count_chart(NETDATA_VFS_FILE_CLEAN_COUNT, NETDATA_FILESYSTEM_FAMILY,
  807. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK], 1);
  808. write_count_chart(NETDATA_VFS_FILE_IO_COUNT, NETDATA_FILESYSTEM_FAMILY,
  809. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ], 2);
  810. if (em->mode < MODE_ENTRY) {
  811. write_err_chart(NETDATA_VFS_FILE_ERR_COUNT, NETDATA_FILESYSTEM_FAMILY,
  812. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ], 2);
  813. }
  814. write_io_chart(NETDATA_VFS_IO_FILE_BYTES, NETDATA_FILESYSTEM_FAMILY, vfs_id_names[NETDATA_KEY_PUBLISH_VFS_WRITE],
  815. (long long)pvc.write, vfs_id_names[NETDATA_KEY_PUBLISH_VFS_READ], (long long)pvc.read);
  816. write_count_chart(NETDATA_VFS_FSYNC, NETDATA_FILESYSTEM_FAMILY,
  817. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC], 1);
  818. if (em->mode < MODE_ENTRY) {
  819. write_err_chart(NETDATA_VFS_FSYNC_ERR, NETDATA_FILESYSTEM_FAMILY,
  820. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC], 1);
  821. }
  822. write_count_chart(NETDATA_VFS_OPEN, NETDATA_FILESYSTEM_FAMILY,
  823. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN], 1);
  824. if (em->mode < MODE_ENTRY) {
  825. write_err_chart(NETDATA_VFS_OPEN_ERR, NETDATA_FILESYSTEM_FAMILY,
  826. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN], 1);
  827. }
  828. write_count_chart(NETDATA_VFS_CREATE, NETDATA_FILESYSTEM_FAMILY,
  829. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE], 1);
  830. if (em->mode < MODE_ENTRY) {
  831. write_err_chart(
  832. NETDATA_VFS_CREATE_ERR,
  833. NETDATA_FILESYSTEM_FAMILY,
  834. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  835. 1);
  836. }
  837. }
  838. /**
  839. * Read the hash table and store data to allocated vectors.
  840. *
  841. * @param maps_per_core do I need to read all cores?
  842. */
  843. static void ebpf_vfs_read_global_table(int maps_per_core)
  844. {
  845. uint64_t idx;
  846. netdata_idx_t res[NETDATA_VFS_COUNTER];
  847. netdata_idx_t *val = vfs_hash_values;
  848. size_t length = sizeof(netdata_idx_t);
  849. if (maps_per_core)
  850. length *= ebpf_nprocs;
  851. int fd = vfs_maps[NETDATA_VFS_ALL].map_fd;
  852. for (idx = 0; idx < NETDATA_VFS_COUNTER; idx++) {
  853. uint64_t total = 0;
  854. if (!bpf_map_lookup_elem(fd, &idx, val)) {
  855. int i;
  856. int end = (maps_per_core) ? ebpf_nprocs : 1;
  857. for (i = 0; i < end; i++)
  858. total += val[i];
  859. }
  860. res[idx] = total;
  861. memset(val, 0, length);
  862. }
  863. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK].ncall = res[NETDATA_KEY_CALLS_VFS_UNLINK];
  864. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].ncall = res[NETDATA_KEY_CALLS_VFS_READ] +
  865. res[NETDATA_KEY_CALLS_VFS_READV];
  866. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].ncall = res[NETDATA_KEY_CALLS_VFS_WRITE] +
  867. res[NETDATA_KEY_CALLS_VFS_WRITEV];
  868. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC].ncall = res[NETDATA_KEY_CALLS_VFS_FSYNC];
  869. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN].ncall = res[NETDATA_KEY_CALLS_VFS_OPEN];
  870. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE].ncall = res[NETDATA_KEY_CALLS_VFS_CREATE];
  871. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK].nerr = res[NETDATA_KEY_ERROR_VFS_UNLINK];
  872. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].nerr = res[NETDATA_KEY_ERROR_VFS_READ] +
  873. res[NETDATA_KEY_ERROR_VFS_READV];
  874. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].nerr = res[NETDATA_KEY_ERROR_VFS_WRITE] +
  875. res[NETDATA_KEY_ERROR_VFS_WRITEV];
  876. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC].nerr = res[NETDATA_KEY_ERROR_VFS_FSYNC];
  877. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN].nerr = res[NETDATA_KEY_ERROR_VFS_OPEN];
  878. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE].nerr = res[NETDATA_KEY_ERROR_VFS_CREATE];
  879. vfs_aggregated_data[NETDATA_KEY_PUBLISH_VFS_WRITE].bytes = (uint64_t)res[NETDATA_KEY_BYTES_VFS_WRITE] +
  880. (uint64_t)res[NETDATA_KEY_BYTES_VFS_WRITEV];
  881. vfs_aggregated_data[NETDATA_KEY_PUBLISH_VFS_READ].bytes = (uint64_t)res[NETDATA_KEY_BYTES_VFS_READ] +
  882. (uint64_t)res[NETDATA_KEY_BYTES_VFS_READV];
  883. }
  884. /**
  885. * Sum PIDs
  886. *
  887. * Sum values for all targets.
  888. *
  889. * @param swap output structure
  890. * @param root link list with structure to be used
  891. */
  892. static void ebpf_vfs_sum_pids(netdata_publish_vfs_t *vfs, struct ebpf_pid_on_target *root)
  893. {
  894. netdata_publish_vfs_t accumulator;
  895. memset(&accumulator, 0, sizeof(accumulator));
  896. while (root) {
  897. int32_t pid = root->pid;
  898. netdata_publish_vfs_t *w = vfs_pid[pid];
  899. if (w) {
  900. accumulator.write_call += w->write_call;
  901. accumulator.writev_call += w->writev_call;
  902. accumulator.read_call += w->read_call;
  903. accumulator.readv_call += w->readv_call;
  904. accumulator.unlink_call += w->unlink_call;
  905. accumulator.fsync_call += w->fsync_call;
  906. accumulator.open_call += w->open_call;
  907. accumulator.create_call += w->create_call;
  908. accumulator.write_bytes += w->write_bytes;
  909. accumulator.writev_bytes += w->writev_bytes;
  910. accumulator.read_bytes += w->read_bytes;
  911. accumulator.readv_bytes += w->readv_bytes;
  912. accumulator.write_err += w->write_err;
  913. accumulator.writev_err += w->writev_err;
  914. accumulator.read_err += w->read_err;
  915. accumulator.readv_err += w->readv_err;
  916. accumulator.unlink_err += w->unlink_err;
  917. accumulator.fsync_err += w->fsync_err;
  918. accumulator.open_err += w->open_err;
  919. accumulator.create_err += w->create_err;
  920. }
  921. root = root->next;
  922. }
  923. // These conditions were added, because we are using incremental algorithm
  924. vfs->write_call = (accumulator.write_call >= vfs->write_call) ? accumulator.write_call : vfs->write_call;
  925. vfs->writev_call = (accumulator.writev_call >= vfs->writev_call) ? accumulator.writev_call : vfs->writev_call;
  926. vfs->read_call = (accumulator.read_call >= vfs->read_call) ? accumulator.read_call : vfs->read_call;
  927. vfs->readv_call = (accumulator.readv_call >= vfs->readv_call) ? accumulator.readv_call : vfs->readv_call;
  928. vfs->unlink_call = (accumulator.unlink_call >= vfs->unlink_call) ? accumulator.unlink_call : vfs->unlink_call;
  929. vfs->fsync_call = (accumulator.fsync_call >= vfs->fsync_call) ? accumulator.fsync_call : vfs->fsync_call;
  930. vfs->open_call = (accumulator.open_call >= vfs->open_call) ? accumulator.open_call : vfs->open_call;
  931. vfs->create_call = (accumulator.create_call >= vfs->create_call) ? accumulator.create_call : vfs->create_call;
  932. vfs->write_bytes = (accumulator.write_bytes >= vfs->write_bytes) ? accumulator.write_bytes : vfs->write_bytes;
  933. vfs->writev_bytes = (accumulator.writev_bytes >= vfs->writev_bytes) ? accumulator.writev_bytes : vfs->writev_bytes;
  934. vfs->read_bytes = (accumulator.read_bytes >= vfs->read_bytes) ? accumulator.read_bytes : vfs->read_bytes;
  935. vfs->readv_bytes = (accumulator.readv_bytes >= vfs->readv_bytes) ? accumulator.readv_bytes : vfs->readv_bytes;
  936. vfs->write_err = (accumulator.write_err >= vfs->write_err) ? accumulator.write_err : vfs->write_err;
  937. vfs->writev_err = (accumulator.writev_err >= vfs->writev_err) ? accumulator.writev_err : vfs->writev_err;
  938. vfs->read_err = (accumulator.read_err >= vfs->read_err) ? accumulator.read_err : vfs->read_err;
  939. vfs->readv_err = (accumulator.readv_err >= vfs->readv_err) ? accumulator.readv_err : vfs->readv_err;
  940. vfs->unlink_err = (accumulator.unlink_err >= vfs->unlink_err) ? accumulator.unlink_err : vfs->unlink_err;
  941. vfs->fsync_err = (accumulator.fsync_err >= vfs->fsync_err) ? accumulator.fsync_err : vfs->fsync_err;
  942. vfs->open_err = (accumulator.open_err >= vfs->open_err) ? accumulator.open_err : vfs->open_err;
  943. vfs->create_err = (accumulator.create_err >= vfs->create_err) ? accumulator.create_err : vfs->create_err;
  944. }
  945. /**
  946. * Send data to Netdata calling auxiliary functions.
  947. *
  948. * @param em the structure with thread information
  949. * @param root the target list.
  950. */
  951. void ebpf_vfs_send_apps_data(ebpf_module_t *em, struct ebpf_target *root)
  952. {
  953. struct ebpf_target *w;
  954. for (w = root; w; w = w->next) {
  955. if (unlikely(w->exposed && w->processes)) {
  956. ebpf_vfs_sum_pids(&w->vfs, w->root_pid);
  957. }
  958. }
  959. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_FILE_DELETED);
  960. for (w = root; w; w = w->next) {
  961. if (unlikely(w->exposed && w->processes)) {
  962. write_chart_dimension(w->name, w->vfs.unlink_call);
  963. }
  964. }
  965. write_end_chart();
  966. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS);
  967. for (w = root; w; w = w->next) {
  968. if (unlikely(w->exposed && w->processes)) {
  969. write_chart_dimension(w->name, w->vfs.write_call + w->vfs.writev_call);
  970. }
  971. }
  972. write_end_chart();
  973. if (em->mode < MODE_ENTRY) {
  974. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR);
  975. for (w = root; w; w = w->next) {
  976. if (unlikely(w->exposed && w->processes)) {
  977. write_chart_dimension(w->name, w->vfs.write_err + w->vfs.writev_err);
  978. }
  979. }
  980. write_end_chart();
  981. }
  982. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_CALLS);
  983. for (w = root; w; w = w->next) {
  984. if (unlikely(w->exposed && w->processes)) {
  985. write_chart_dimension(w->name, w->vfs.read_call + w->vfs.readv_call);
  986. }
  987. }
  988. write_end_chart();
  989. if (em->mode < MODE_ENTRY) {
  990. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR);
  991. for (w = root; w; w = w->next) {
  992. if (unlikely(w->exposed && w->processes)) {
  993. write_chart_dimension(w->name, w->vfs.read_err + w->vfs.readv_err);
  994. }
  995. }
  996. write_end_chart();
  997. }
  998. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES);
  999. for (w = root; w; w = w->next) {
  1000. if (unlikely(w->exposed && w->processes)) {
  1001. write_chart_dimension(w->name, w->vfs.write_bytes + w->vfs.writev_bytes);
  1002. }
  1003. }
  1004. write_end_chart();
  1005. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_BYTES);
  1006. for (w = root; w; w = w->next) {
  1007. if (unlikely(w->exposed && w->processes)) {
  1008. write_chart_dimension(w->name, w->vfs.read_bytes + w->vfs.readv_bytes);
  1009. }
  1010. }
  1011. write_end_chart();
  1012. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_FSYNC);
  1013. for (w = root; w; w = w->next) {
  1014. if (unlikely(w->exposed && w->processes)) {
  1015. write_chart_dimension(w->name, w->vfs.fsync_call);
  1016. }
  1017. }
  1018. write_end_chart();
  1019. if (em->mode < MODE_ENTRY) {
  1020. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR);
  1021. for (w = root; w; w = w->next) {
  1022. if (unlikely(w->exposed && w->processes)) {
  1023. write_chart_dimension(w->name, w->vfs.fsync_err);
  1024. }
  1025. }
  1026. write_end_chart();
  1027. }
  1028. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_OPEN);
  1029. for (w = root; w; w = w->next) {
  1030. if (unlikely(w->exposed && w->processes)) {
  1031. write_chart_dimension(w->name, w->vfs.open_call);
  1032. }
  1033. }
  1034. write_end_chart();
  1035. if (em->mode < MODE_ENTRY) {
  1036. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR);
  1037. for (w = root; w; w = w->next) {
  1038. if (unlikely(w->exposed && w->processes)) {
  1039. write_chart_dimension(w->name, w->vfs.open_err);
  1040. }
  1041. }
  1042. write_end_chart();
  1043. }
  1044. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_CREATE);
  1045. for (w = root; w; w = w->next) {
  1046. if (unlikely(w->exposed && w->processes)) {
  1047. write_chart_dimension(w->name, w->vfs.create_call);
  1048. }
  1049. }
  1050. write_end_chart();
  1051. if (em->mode < MODE_ENTRY) {
  1052. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR);
  1053. for (w = root; w; w = w->next) {
  1054. if (unlikely(w->exposed && w->processes)) {
  1055. write_chart_dimension(w->name, w->vfs.create_err);
  1056. }
  1057. }
  1058. write_end_chart();
  1059. }
  1060. }
  1061. /**
  1062. * Apps Accumulator
  1063. *
  1064. * Sum all values read from kernel and store in the first address.
  1065. *
  1066. * @param out the vector with read values.
  1067. */
  1068. static void vfs_apps_accumulator(netdata_publish_vfs_t *out, int maps_per_core)
  1069. {
  1070. int i, end = (maps_per_core) ? ebpf_nprocs : 1;
  1071. netdata_publish_vfs_t *total = &out[0];
  1072. for (i = 1; i < end; i++) {
  1073. netdata_publish_vfs_t *w = &out[i];
  1074. total->write_call += w->write_call;
  1075. total->writev_call += w->writev_call;
  1076. total->read_call += w->read_call;
  1077. total->readv_call += w->readv_call;
  1078. total->unlink_call += w->unlink_call;
  1079. total->write_bytes += w->write_bytes;
  1080. total->writev_bytes += w->writev_bytes;
  1081. total->read_bytes += w->read_bytes;
  1082. total->readv_bytes += w->readv_bytes;
  1083. total->write_err += w->write_err;
  1084. total->writev_err += w->writev_err;
  1085. total->read_err += w->read_err;
  1086. total->readv_err += w->readv_err;
  1087. total->unlink_err += w->unlink_err;
  1088. }
  1089. }
  1090. /**
  1091. * Fill PID
  1092. *
  1093. * Fill PID structures
  1094. *
  1095. * @param current_pid pid that we are collecting data
  1096. * @param out values read from hash tables;
  1097. */
  1098. static void vfs_fill_pid(uint32_t current_pid, netdata_publish_vfs_t *publish)
  1099. {
  1100. netdata_publish_vfs_t *curr = vfs_pid[current_pid];
  1101. if (!curr) {
  1102. curr = ebpf_vfs_get();
  1103. vfs_pid[current_pid] = curr;
  1104. }
  1105. memcpy(curr, &publish[0], sizeof(netdata_publish_vfs_t));
  1106. }
  1107. /**
  1108. * Read the hash table and store data to allocated vectors.
  1109. */
  1110. static void ebpf_vfs_read_apps(int maps_per_core)
  1111. {
  1112. struct ebpf_pid_stat *pids = ebpf_root_of_pids;
  1113. netdata_publish_vfs_t *vv = vfs_vector;
  1114. int fd = vfs_maps[NETDATA_VFS_PID].map_fd;
  1115. size_t length = sizeof(netdata_publish_vfs_t);
  1116. if (maps_per_core)
  1117. length *= ebpf_nprocs;
  1118. while (pids) {
  1119. uint32_t key = pids->pid;
  1120. if (bpf_map_lookup_elem(fd, &key, vv)) {
  1121. pids = pids->next;
  1122. continue;
  1123. }
  1124. vfs_apps_accumulator(vv, maps_per_core);
  1125. vfs_fill_pid(key, vv);
  1126. // We are cleaning to avoid passing data read from one process to other.
  1127. memset(vv, 0, length);
  1128. pids = pids->next;
  1129. }
  1130. }
  1131. /**
  1132. * Update cgroup
  1133. *
  1134. * Update cgroup data based in PID.
  1135. *
  1136. * @param maps_per_core do I need to read all cores?
  1137. */
  1138. static void read_update_vfs_cgroup(int maps_per_core)
  1139. {
  1140. ebpf_cgroup_target_t *ect ;
  1141. netdata_publish_vfs_t *vv = vfs_vector;
  1142. int fd = vfs_maps[NETDATA_VFS_PID].map_fd;
  1143. size_t length = sizeof(netdata_publish_vfs_t);
  1144. if (maps_per_core)
  1145. length *= ebpf_nprocs;
  1146. pthread_mutex_lock(&mutex_cgroup_shm);
  1147. for (ect = ebpf_cgroup_pids; ect; ect = ect->next) {
  1148. struct pid_on_target2 *pids;
  1149. for (pids = ect->pids; pids; pids = pids->next) {
  1150. int pid = pids->pid;
  1151. netdata_publish_vfs_t *out = &pids->vfs;
  1152. if (likely(vfs_pid) && vfs_pid[pid]) {
  1153. netdata_publish_vfs_t *in = vfs_pid[pid];
  1154. memcpy(out, in, sizeof(netdata_publish_vfs_t));
  1155. } else {
  1156. memset(vv, 0, length);
  1157. if (!bpf_map_lookup_elem(fd, &pid, vv)) {
  1158. vfs_apps_accumulator(vv, maps_per_core);
  1159. memcpy(out, vv, sizeof(netdata_publish_vfs_t));
  1160. }
  1161. }
  1162. }
  1163. }
  1164. pthread_mutex_unlock(&mutex_cgroup_shm);
  1165. }
  1166. /**
  1167. * Sum PIDs
  1168. *
  1169. * Sum values for all targets.
  1170. *
  1171. * @param vfs structure used to store data
  1172. * @param pids input data
  1173. */
  1174. static void ebpf_vfs_sum_cgroup_pids(netdata_publish_vfs_t *vfs, struct pid_on_target2 *pids)
  1175. {
  1176. netdata_publish_vfs_t accumulator;
  1177. memset(&accumulator, 0, sizeof(accumulator));
  1178. while (pids) {
  1179. netdata_publish_vfs_t *w = &pids->vfs;
  1180. accumulator.write_call += w->write_call;
  1181. accumulator.writev_call += w->writev_call;
  1182. accumulator.read_call += w->read_call;
  1183. accumulator.readv_call += w->readv_call;
  1184. accumulator.unlink_call += w->unlink_call;
  1185. accumulator.fsync_call += w->fsync_call;
  1186. accumulator.open_call += w->open_call;
  1187. accumulator.create_call += w->create_call;
  1188. accumulator.write_bytes += w->write_bytes;
  1189. accumulator.writev_bytes += w->writev_bytes;
  1190. accumulator.read_bytes += w->read_bytes;
  1191. accumulator.readv_bytes += w->readv_bytes;
  1192. accumulator.write_err += w->write_err;
  1193. accumulator.writev_err += w->writev_err;
  1194. accumulator.read_err += w->read_err;
  1195. accumulator.readv_err += w->readv_err;
  1196. accumulator.unlink_err += w->unlink_err;
  1197. accumulator.fsync_err += w->fsync_err;
  1198. accumulator.open_err += w->open_err;
  1199. accumulator.create_err += w->create_err;
  1200. pids = pids->next;
  1201. }
  1202. // These conditions were added, because we are using incremental algorithm
  1203. vfs->write_call = (accumulator.write_call >= vfs->write_call) ? accumulator.write_call : vfs->write_call;
  1204. vfs->writev_call = (accumulator.writev_call >= vfs->writev_call) ? accumulator.writev_call : vfs->writev_call;
  1205. vfs->read_call = (accumulator.read_call >= vfs->read_call) ? accumulator.read_call : vfs->read_call;
  1206. vfs->readv_call = (accumulator.readv_call >= vfs->readv_call) ? accumulator.readv_call : vfs->readv_call;
  1207. vfs->unlink_call = (accumulator.unlink_call >= vfs->unlink_call) ? accumulator.unlink_call : vfs->unlink_call;
  1208. vfs->fsync_call = (accumulator.fsync_call >= vfs->fsync_call) ? accumulator.fsync_call : vfs->fsync_call;
  1209. vfs->open_call = (accumulator.open_call >= vfs->open_call) ? accumulator.open_call : vfs->open_call;
  1210. vfs->create_call = (accumulator.create_call >= vfs->create_call) ? accumulator.create_call : vfs->create_call;
  1211. vfs->write_bytes = (accumulator.write_bytes >= vfs->write_bytes) ? accumulator.write_bytes : vfs->write_bytes;
  1212. vfs->writev_bytes = (accumulator.writev_bytes >= vfs->writev_bytes) ? accumulator.writev_bytes : vfs->writev_bytes;
  1213. vfs->read_bytes = (accumulator.read_bytes >= vfs->read_bytes) ? accumulator.read_bytes : vfs->read_bytes;
  1214. vfs->readv_bytes = (accumulator.readv_bytes >= vfs->readv_bytes) ? accumulator.readv_bytes : vfs->readv_bytes;
  1215. vfs->write_err = (accumulator.write_err >= vfs->write_err) ? accumulator.write_err : vfs->write_err;
  1216. vfs->writev_err = (accumulator.writev_err >= vfs->writev_err) ? accumulator.writev_err : vfs->writev_err;
  1217. vfs->read_err = (accumulator.read_err >= vfs->read_err) ? accumulator.read_err : vfs->read_err;
  1218. vfs->readv_err = (accumulator.readv_err >= vfs->readv_err) ? accumulator.readv_err : vfs->readv_err;
  1219. vfs->unlink_err = (accumulator.unlink_err >= vfs->unlink_err) ? accumulator.unlink_err : vfs->unlink_err;
  1220. vfs->fsync_err = (accumulator.fsync_err >= vfs->fsync_err) ? accumulator.fsync_err : vfs->fsync_err;
  1221. vfs->open_err = (accumulator.open_err >= vfs->open_err) ? accumulator.open_err : vfs->open_err;
  1222. vfs->create_err = (accumulator.create_err >= vfs->create_err) ? accumulator.create_err : vfs->create_err;
  1223. }
  1224. /**
  1225. * Create specific VFS charts
  1226. *
  1227. * Create charts for cgroup/application.
  1228. *
  1229. * @param type the chart type.
  1230. * @param em the main thread structure.
  1231. */
  1232. static void ebpf_create_specific_vfs_charts(char *type, ebpf_module_t *em)
  1233. {
  1234. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_FILE_DELETED,"Files deleted",
  1235. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_UNLINK_CONTEXT,
  1236. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5500,
  1237. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK],
  1238. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1239. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS, "Write to disk",
  1240. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_WRITE_CONTEXT,
  1241. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5501,
  1242. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1243. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1244. if (em->mode < MODE_ENTRY) {
  1245. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR, "Fails to write",
  1246. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_WRITE_ERROR_CONTEXT,
  1247. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5502,
  1248. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1249. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1250. }
  1251. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS, "Read from disk",
  1252. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_READ_CONTEXT,
  1253. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5503,
  1254. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1255. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1256. if (em->mode < MODE_ENTRY) {
  1257. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR, "Fails to read",
  1258. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_READ_ERROR_CONTEXT,
  1259. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5504,
  1260. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1261. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1262. }
  1263. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES, "Bytes written on disk",
  1264. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_WRITE_BYTES_CONTEXT,
  1265. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5505,
  1266. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1267. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1268. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_BYTES, "Bytes read from disk",
  1269. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_READ_BYTES_CONTEXT,
  1270. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5506,
  1271. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1272. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1273. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_FSYNC, "Calls for <code>vfs_fsync</code>",
  1274. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_FSYNC_CONTEXT,
  1275. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5507,
  1276. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC],
  1277. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1278. if (em->mode < MODE_ENTRY) {
  1279. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR, "Sync error",
  1280. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_FSYNC_ERROR_CONTEXT,
  1281. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5508,
  1282. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC],
  1283. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1284. }
  1285. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_OPEN, "Calls for <code>vfs_open</code>",
  1286. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_OPEN_CONTEXT,
  1287. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5509,
  1288. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN],
  1289. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1290. if (em->mode < MODE_ENTRY) {
  1291. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR, "Open error",
  1292. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_OPEN_ERROR_CONTEXT,
  1293. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5510,
  1294. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN],
  1295. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1296. }
  1297. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_CREATE, "Calls for <code>vfs_create</code>",
  1298. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_CREATE_CONTEXT,
  1299. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5511,
  1300. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  1301. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1302. if (em->mode < MODE_ENTRY) {
  1303. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR, "Create error",
  1304. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_CREATE_ERROR_CONTEXT,
  1305. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5512,
  1306. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  1307. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1308. }
  1309. }
  1310. /**
  1311. * Obsolete specific VFS charts
  1312. *
  1313. * Obsolete charts for cgroup/application.
  1314. *
  1315. * @param type the chart type.
  1316. * @param em the main thread structure.
  1317. */
  1318. static void ebpf_obsolete_specific_vfs_charts(char *type, ebpf_module_t *em)
  1319. {
  1320. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_FILE_DELETED, "Files deleted",
  1321. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1322. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_UNLINK_CONTEXT,
  1323. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5500, em->update_every);
  1324. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS, "Write to disk",
  1325. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1326. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_WRITE_CONTEXT,
  1327. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5501, em->update_every);
  1328. if (em->mode < MODE_ENTRY) {
  1329. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR, "Fails to write",
  1330. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1331. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_WRITE_ERROR_CONTEXT,
  1332. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5502, em->update_every);
  1333. }
  1334. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS, "Read from disk",
  1335. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1336. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_READ_CONTEXT,
  1337. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5503, em->update_every);
  1338. if (em->mode < MODE_ENTRY) {
  1339. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR, "Fails to read",
  1340. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1341. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_READ_ERROR_CONTEXT,
  1342. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5504, em->update_every);
  1343. }
  1344. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES, "Bytes written on disk",
  1345. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_GROUP,
  1346. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_WRITE_BYTES_CONTEXT,
  1347. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5505, em->update_every);
  1348. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_READ_BYTES, "Bytes read from disk",
  1349. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_GROUP,
  1350. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_READ_BYTES_CONTEXT,
  1351. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5506, em->update_every);
  1352. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_FSYNC, "Calls for <code>vfs_fsync</code>",
  1353. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1354. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_FSYNC_CONTEXT,
  1355. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5507, em->update_every);
  1356. if (em->mode < MODE_ENTRY) {
  1357. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR, "Sync error",
  1358. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1359. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_FSYNC_ERROR_CONTEXT,
  1360. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5508, em->update_every);
  1361. }
  1362. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_OPEN, "Calls for <code>vfs_open</code>",
  1363. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1364. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_OPEN_CONTEXT,
  1365. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5509, em->update_every);
  1366. if (em->mode < MODE_ENTRY) {
  1367. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR, "Open error",
  1368. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1369. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_OPEN_ERROR_CONTEXT,
  1370. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5510, em->update_every);
  1371. }
  1372. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_CREATE, "Calls for <code>vfs_create</code>",
  1373. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1374. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_CREATE_CONTEXT,
  1375. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5511, em->update_every);
  1376. if (em->mode < MODE_ENTRY) {
  1377. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR, "Create error",
  1378. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1379. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_CREATE_ERROR_CONTEXT,
  1380. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5512, em->update_every);
  1381. }
  1382. }
  1383. /*
  1384. * Send specific VFS data
  1385. *
  1386. * Send data for specific cgroup/apps.
  1387. *
  1388. * @param type chart type
  1389. * @param values structure with values that will be sent to netdata
  1390. */
  1391. static void ebpf_send_specific_vfs_data(char *type, netdata_publish_vfs_t *values, ebpf_module_t *em)
  1392. {
  1393. write_begin_chart(type, NETDATA_SYSCALL_APPS_FILE_DELETED);
  1394. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK].name, (long long)values->unlink_call);
  1395. write_end_chart();
  1396. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS);
  1397. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].name,
  1398. (long long)values->write_call + (long long)values->writev_call);
  1399. write_end_chart();
  1400. if (em->mode < MODE_ENTRY) {
  1401. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR);
  1402. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].name,
  1403. (long long)values->write_err + (long long)values->writev_err);
  1404. write_end_chart();
  1405. }
  1406. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS);
  1407. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].name,
  1408. (long long)values->read_call + (long long)values->readv_call);
  1409. write_end_chart();
  1410. if (em->mode < MODE_ENTRY) {
  1411. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR);
  1412. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].name,
  1413. (long long)values->read_err + (long long)values->readv_err);
  1414. write_end_chart();
  1415. }
  1416. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES);
  1417. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].name,
  1418. (long long)values->write_bytes + (long long)values->writev_bytes);
  1419. write_end_chart();
  1420. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_BYTES);
  1421. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].name,
  1422. (long long)values->read_bytes + (long long)values->readv_bytes);
  1423. write_end_chart();
  1424. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_FSYNC);
  1425. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC].name,
  1426. (long long)values->fsync_call);
  1427. write_end_chart();
  1428. if (em->mode < MODE_ENTRY) {
  1429. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR);
  1430. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC].name,
  1431. (long long)values->fsync_err);
  1432. write_end_chart();
  1433. }
  1434. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_OPEN);
  1435. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN].name,
  1436. (long long)values->open_call);
  1437. write_end_chart();
  1438. if (em->mode < MODE_ENTRY) {
  1439. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR);
  1440. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN].name,
  1441. (long long)values->open_err);
  1442. write_end_chart();
  1443. }
  1444. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_CREATE);
  1445. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE].name,
  1446. (long long)values->create_call);
  1447. write_end_chart();
  1448. if (em->mode < MODE_ENTRY) {
  1449. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR);
  1450. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE].name,
  1451. (long long)values->create_err);
  1452. write_end_chart();
  1453. }
  1454. }
  1455. /**
  1456. * Create Systemd Socket Charts
  1457. *
  1458. * Create charts when systemd is enabled
  1459. *
  1460. * @param em the main collector structure
  1461. **/
  1462. static void ebpf_create_systemd_vfs_charts(ebpf_module_t *em)
  1463. {
  1464. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_FILE_DELETED, "Files deleted",
  1465. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1466. NETDATA_EBPF_CHART_TYPE_STACKED, 20065,
  1467. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_UNLINK_CONTEXT,
  1468. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1469. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS, "Write to disk",
  1470. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1471. NETDATA_EBPF_CHART_TYPE_STACKED, 20066,
  1472. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_WRITE_CONTEXT,
  1473. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1474. if (em->mode < MODE_ENTRY) {
  1475. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR, "Fails to write",
  1476. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1477. NETDATA_EBPF_CHART_TYPE_STACKED, 20067,
  1478. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1479. NETDATA_SYSTEMD_VFS_WRITE_ERROR_CONTEXT,
  1480. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1481. }
  1482. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_READ_CALLS, "Read from disk",
  1483. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1484. NETDATA_EBPF_CHART_TYPE_STACKED, 20068,
  1485. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_READ_CONTEXT,
  1486. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1487. if (em->mode < MODE_ENTRY) {
  1488. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR, "Fails to read",
  1489. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1490. NETDATA_EBPF_CHART_TYPE_STACKED, 20069,
  1491. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1492. NETDATA_SYSTEMD_VFS_READ_ERROR_CONTEXT,
  1493. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1494. }
  1495. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES, "Bytes written on disk",
  1496. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_CGROUP_GROUP,
  1497. NETDATA_EBPF_CHART_TYPE_STACKED, 20070,
  1498. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_WRITE_BYTES_CONTEXT,
  1499. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1500. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_READ_BYTES, "Bytes read from disk",
  1501. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_CGROUP_GROUP,
  1502. NETDATA_EBPF_CHART_TYPE_STACKED, 20071,
  1503. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_READ_BYTES_CONTEXT,
  1504. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1505. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_FSYNC, "Calls to <code>vfs_fsync</code>",
  1506. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1507. NETDATA_EBPF_CHART_TYPE_STACKED, 20072,
  1508. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_FSYNC_CONTEXT,
  1509. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1510. if (em->mode < MODE_ENTRY) {
  1511. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR, "Sync error",
  1512. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1513. NETDATA_EBPF_CHART_TYPE_STACKED, 20073,
  1514. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_FSYNC_ERROR_CONTEXT,
  1515. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1516. }
  1517. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_OPEN, "Calls to <code>vfs_open</code>",
  1518. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1519. NETDATA_EBPF_CHART_TYPE_STACKED, 20074,
  1520. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_OPEN_CONTEXT,
  1521. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1522. if (em->mode < MODE_ENTRY) {
  1523. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR, "Open error",
  1524. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1525. NETDATA_EBPF_CHART_TYPE_STACKED, 20075,
  1526. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_OPEN_ERROR_CONTEXT,
  1527. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1528. }
  1529. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_CREATE, "Calls to <code>vfs_create</code>",
  1530. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1531. NETDATA_EBPF_CHART_TYPE_STACKED, 20076,
  1532. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_CREATE_CONTEXT,
  1533. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1534. if (em->mode < MODE_ENTRY) {
  1535. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR, "Create error",
  1536. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1537. NETDATA_EBPF_CHART_TYPE_STACKED, 20077,
  1538. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_CREATE_ERROR_CONTEXT,
  1539. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1540. }
  1541. }
  1542. /**
  1543. * Send Systemd charts
  1544. *
  1545. * Send collected data to Netdata.
  1546. *
  1547. * @param em the main collector structure
  1548. */
  1549. static void ebpf_send_systemd_vfs_charts(ebpf_module_t *em)
  1550. {
  1551. ebpf_cgroup_target_t *ect;
  1552. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_FILE_DELETED);
  1553. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1554. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1555. write_chart_dimension(ect->name, ect->publish_systemd_vfs.unlink_call);
  1556. }
  1557. }
  1558. write_end_chart();
  1559. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS);
  1560. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1561. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1562. write_chart_dimension(ect->name, ect->publish_systemd_vfs.write_call +
  1563. ect->publish_systemd_vfs.writev_call);
  1564. }
  1565. }
  1566. write_end_chart();
  1567. if (em->mode < MODE_ENTRY) {
  1568. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR);
  1569. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1570. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1571. write_chart_dimension(ect->name, ect->publish_systemd_vfs.write_err +
  1572. ect->publish_systemd_vfs.writev_err);
  1573. }
  1574. }
  1575. write_end_chart();
  1576. }
  1577. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_CALLS);
  1578. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1579. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1580. write_chart_dimension(ect->name, ect->publish_systemd_vfs.read_call +
  1581. ect->publish_systemd_vfs.readv_call);
  1582. }
  1583. }
  1584. write_end_chart();
  1585. if (em->mode < MODE_ENTRY) {
  1586. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR);
  1587. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1588. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1589. write_chart_dimension(ect->name, ect->publish_systemd_vfs.read_err +
  1590. ect->publish_systemd_vfs.readv_err);
  1591. }
  1592. }
  1593. write_end_chart();
  1594. }
  1595. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES);
  1596. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1597. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1598. write_chart_dimension(ect->name, ect->publish_systemd_vfs.write_bytes +
  1599. ect->publish_systemd_vfs.writev_bytes);
  1600. }
  1601. }
  1602. write_end_chart();
  1603. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_BYTES);
  1604. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1605. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1606. write_chart_dimension(ect->name, ect->publish_systemd_vfs.read_bytes +
  1607. ect->publish_systemd_vfs.readv_bytes);
  1608. }
  1609. }
  1610. write_end_chart();
  1611. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_FSYNC);
  1612. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1613. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1614. write_chart_dimension(ect->name, ect->publish_systemd_vfs.fsync_call);
  1615. }
  1616. }
  1617. write_end_chart();
  1618. if (em->mode < MODE_ENTRY) {
  1619. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR);
  1620. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1621. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1622. write_chart_dimension(ect->name, ect->publish_systemd_vfs.fsync_err);
  1623. }
  1624. }
  1625. write_end_chart();
  1626. }
  1627. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_OPEN);
  1628. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1629. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1630. write_chart_dimension(ect->name, ect->publish_systemd_vfs.open_call);
  1631. }
  1632. }
  1633. write_end_chart();
  1634. if (em->mode < MODE_ENTRY) {
  1635. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR);
  1636. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1637. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1638. write_chart_dimension(ect->name, ect->publish_systemd_vfs.open_err);
  1639. }
  1640. }
  1641. write_end_chart();
  1642. }
  1643. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_CREATE);
  1644. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1645. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1646. write_chart_dimension(ect->name, ect->publish_systemd_vfs.create_call);
  1647. }
  1648. }
  1649. write_end_chart();
  1650. if (em->mode < MODE_ENTRY) {
  1651. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR);
  1652. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1653. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1654. write_chart_dimension(ect->name, ect->publish_systemd_vfs.create_err);
  1655. }
  1656. }
  1657. write_end_chart();
  1658. }
  1659. }
  1660. /**
  1661. * Send data to Netdata calling auxiliary functions.
  1662. *
  1663. * @param em the main collector structure
  1664. */
  1665. static void ebpf_vfs_send_cgroup_data(ebpf_module_t *em)
  1666. {
  1667. if (!ebpf_cgroup_pids)
  1668. return;
  1669. pthread_mutex_lock(&mutex_cgroup_shm);
  1670. ebpf_cgroup_target_t *ect;
  1671. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1672. ebpf_vfs_sum_cgroup_pids(&ect->publish_systemd_vfs, ect->pids);
  1673. }
  1674. int has_systemd = shm_ebpf_cgroup.header->systemd_enabled;
  1675. if (has_systemd) {
  1676. if (send_cgroup_chart) {
  1677. ebpf_create_systemd_vfs_charts(em);
  1678. }
  1679. ebpf_send_systemd_vfs_charts(em);
  1680. }
  1681. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1682. if (ect->systemd)
  1683. continue;
  1684. if (!(ect->flags & NETDATA_EBPF_CGROUP_HAS_VFS_CHART) && ect->updated) {
  1685. ebpf_create_specific_vfs_charts(ect->name, em);
  1686. ect->flags |= NETDATA_EBPF_CGROUP_HAS_VFS_CHART;
  1687. }
  1688. if (ect->flags & NETDATA_EBPF_CGROUP_HAS_VFS_CHART) {
  1689. if (ect->updated) {
  1690. ebpf_send_specific_vfs_data(ect->name, &ect->publish_systemd_vfs, em);
  1691. } else {
  1692. ebpf_obsolete_specific_vfs_charts(ect->name, em);
  1693. ect->flags &= ~NETDATA_EBPF_CGROUP_HAS_VFS_CHART;
  1694. }
  1695. }
  1696. }
  1697. pthread_mutex_unlock(&mutex_cgroup_shm);
  1698. }
  1699. /**
  1700. * Main loop for this collector.
  1701. *
  1702. * @param step the number of microseconds used with heart beat
  1703. * @param em the structure with thread information
  1704. */
  1705. static void vfs_collector(ebpf_module_t *em)
  1706. {
  1707. int cgroups = em->cgroup_charts;
  1708. heartbeat_t hb;
  1709. heartbeat_init(&hb);
  1710. int update_every = em->update_every;
  1711. int counter = update_every - 1;
  1712. int maps_per_core = em->maps_per_core;
  1713. uint32_t running_time = 0;
  1714. uint32_t lifetime = em->lifetime;
  1715. while (!ebpf_exit_plugin && running_time < lifetime) {
  1716. (void)heartbeat_next(&hb, USEC_PER_SEC);
  1717. if (ebpf_exit_plugin || ++counter != update_every)
  1718. continue;
  1719. counter = 0;
  1720. netdata_apps_integration_flags_t apps = em->apps_charts;
  1721. ebpf_vfs_read_global_table(maps_per_core);
  1722. pthread_mutex_lock(&collect_data_mutex);
  1723. if (apps)
  1724. ebpf_vfs_read_apps(maps_per_core);
  1725. if (cgroups)
  1726. read_update_vfs_cgroup(maps_per_core);
  1727. pthread_mutex_lock(&lock);
  1728. #ifdef NETDATA_DEV_MODE
  1729. if (ebpf_aral_vfs_pid)
  1730. ebpf_send_data_aral_chart(ebpf_aral_vfs_pid, em);
  1731. #endif
  1732. ebpf_vfs_send_data(em);
  1733. fflush(stdout);
  1734. if (apps & NETDATA_EBPF_APPS_FLAG_CHART_CREATED)
  1735. ebpf_vfs_send_apps_data(em, apps_groups_root_target);
  1736. if (cgroups)
  1737. ebpf_vfs_send_cgroup_data(em);
  1738. pthread_mutex_unlock(&lock);
  1739. pthread_mutex_unlock(&collect_data_mutex);
  1740. pthread_mutex_lock(&ebpf_exit_cleanup);
  1741. if (running_time && !em->running_time)
  1742. running_time = update_every;
  1743. else
  1744. running_time += update_every;
  1745. em->running_time = running_time;
  1746. pthread_mutex_unlock(&ebpf_exit_cleanup);
  1747. }
  1748. }
  1749. /*****************************************************************
  1750. *
  1751. * FUNCTIONS TO CREATE CHARTS
  1752. *
  1753. *****************************************************************/
  1754. /**
  1755. * Create IO chart
  1756. *
  1757. * @param family the chart family
  1758. * @param name the chart name
  1759. * @param axis the axis label
  1760. * @param web the group name used to attach the chart on dashboard
  1761. * @param order the order number of the specified chart
  1762. * @param algorithm the algorithm used to make the charts.
  1763. * @param update_every value to overwrite the update frequency set by the server.
  1764. */
  1765. static void ebpf_create_io_chart(char *family, char *name, char *axis, char *web,
  1766. int order, int algorithm, int update_every)
  1767. {
  1768. printf("CHART %s.%s '' 'Bytes written and read' '%s' '%s' '' line %d %d '' 'ebpf.plugin' 'filesystem'\n",
  1769. family,
  1770. name,
  1771. axis,
  1772. web,
  1773. order,
  1774. update_every);
  1775. printf("DIMENSION %s %s %s 1 1\n",
  1776. vfs_id_names[NETDATA_KEY_PUBLISH_VFS_READ],
  1777. vfs_dimension_names[NETDATA_KEY_PUBLISH_VFS_READ],
  1778. ebpf_algorithms[algorithm]);
  1779. printf("DIMENSION %s %s %s -1 1\n",
  1780. vfs_id_names[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1781. vfs_dimension_names[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1782. ebpf_algorithms[algorithm]);
  1783. }
  1784. /**
  1785. * Create global charts
  1786. *
  1787. * Call ebpf_create_chart to create the charts for the collector.
  1788. *
  1789. * @param em a pointer to the structure with the default values.
  1790. */
  1791. static void ebpf_create_global_charts(ebpf_module_t *em)
  1792. {
  1793. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1794. NETDATA_VFS_FILE_CLEAN_COUNT,
  1795. "Remove files",
  1796. EBPF_COMMON_DIMENSION_CALL,
  1797. NETDATA_VFS_GROUP,
  1798. NULL,
  1799. NETDATA_EBPF_CHART_TYPE_LINE,
  1800. NETDATA_CHART_PRIO_FILESYSTEM_VFS_CLEAN,
  1801. ebpf_create_global_dimension,
  1802. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK],
  1803. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1804. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1805. NETDATA_VFS_FILE_IO_COUNT,
  1806. "Calls to IO",
  1807. EBPF_COMMON_DIMENSION_CALL,
  1808. NETDATA_VFS_GROUP,
  1809. NULL,
  1810. NETDATA_EBPF_CHART_TYPE_LINE,
  1811. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_COUNT,
  1812. ebpf_create_global_dimension,
  1813. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1814. 2, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1815. ebpf_create_io_chart(NETDATA_FILESYSTEM_FAMILY,
  1816. NETDATA_VFS_IO_FILE_BYTES, EBPF_COMMON_DIMENSION_BYTES,
  1817. NETDATA_VFS_GROUP,
  1818. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_BYTES,
  1819. NETDATA_EBPF_INCREMENTAL_IDX, em->update_every);
  1820. if (em->mode < MODE_ENTRY) {
  1821. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1822. NETDATA_VFS_FILE_ERR_COUNT,
  1823. "Fails to write or read",
  1824. EBPF_COMMON_DIMENSION_CALL,
  1825. NETDATA_VFS_GROUP,
  1826. NULL,
  1827. NETDATA_EBPF_CHART_TYPE_LINE,
  1828. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EBYTES,
  1829. ebpf_create_global_dimension,
  1830. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1831. 2, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1832. }
  1833. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1834. NETDATA_VFS_FSYNC,
  1835. "Calls for <code>vfs_fsync</code>",
  1836. EBPF_COMMON_DIMENSION_CALL,
  1837. NETDATA_VFS_GROUP,
  1838. NULL,
  1839. NETDATA_EBPF_CHART_TYPE_LINE,
  1840. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_FSYNC,
  1841. ebpf_create_global_dimension,
  1842. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC],
  1843. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1844. if (em->mode < MODE_ENTRY) {
  1845. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1846. NETDATA_VFS_FSYNC_ERR,
  1847. "Fails to synchronize",
  1848. EBPF_COMMON_DIMENSION_CALL,
  1849. NETDATA_VFS_GROUP,
  1850. NULL,
  1851. NETDATA_EBPF_CHART_TYPE_LINE,
  1852. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EFSYNC,
  1853. ebpf_create_global_dimension,
  1854. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC],
  1855. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1856. }
  1857. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1858. NETDATA_VFS_OPEN,
  1859. "Calls for <code>vfs_open</code>",
  1860. EBPF_COMMON_DIMENSION_CALL,
  1861. NETDATA_VFS_GROUP,
  1862. NULL,
  1863. NETDATA_EBPF_CHART_TYPE_LINE,
  1864. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_OPEN,
  1865. ebpf_create_global_dimension,
  1866. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN],
  1867. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1868. if (em->mode < MODE_ENTRY) {
  1869. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1870. NETDATA_VFS_OPEN_ERR,
  1871. "Fails to open a file",
  1872. EBPF_COMMON_DIMENSION_CALL,
  1873. NETDATA_VFS_GROUP,
  1874. NULL,
  1875. NETDATA_EBPF_CHART_TYPE_LINE,
  1876. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EOPEN,
  1877. ebpf_create_global_dimension,
  1878. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN],
  1879. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1880. }
  1881. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1882. NETDATA_VFS_CREATE,
  1883. "Calls for <code>vfs_create</code>",
  1884. EBPF_COMMON_DIMENSION_CALL,
  1885. NETDATA_VFS_GROUP,
  1886. NULL,
  1887. NETDATA_EBPF_CHART_TYPE_LINE,
  1888. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_CREATE,
  1889. ebpf_create_global_dimension,
  1890. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  1891. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1892. if (em->mode < MODE_ENTRY) {
  1893. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1894. NETDATA_VFS_CREATE_ERR,
  1895. "Fails to create a file.",
  1896. EBPF_COMMON_DIMENSION_CALL,
  1897. NETDATA_VFS_GROUP,
  1898. NULL,
  1899. NETDATA_EBPF_CHART_TYPE_LINE,
  1900. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_ECREATE,
  1901. ebpf_create_global_dimension,
  1902. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  1903. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1904. }
  1905. fflush(stdout);
  1906. }
  1907. /**
  1908. * Create process apps charts
  1909. *
  1910. * Call ebpf_create_chart to create the charts on apps submenu.
  1911. *
  1912. * @param em a pointer to the structure with the default values.
  1913. * @param ptr a pointer for the targets.
  1914. **/
  1915. void ebpf_vfs_create_apps_charts(struct ebpf_module *em, void *ptr)
  1916. {
  1917. struct ebpf_target *root = ptr;
  1918. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_FILE_DELETED,
  1919. "Files deleted",
  1920. EBPF_COMMON_DIMENSION_CALL,
  1921. NETDATA_VFS_GROUP,
  1922. NETDATA_EBPF_CHART_TYPE_STACKED,
  1923. 20065,
  1924. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1925. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1926. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS,
  1927. "Write to disk",
  1928. EBPF_COMMON_DIMENSION_CALL,
  1929. NETDATA_VFS_GROUP,
  1930. NETDATA_EBPF_CHART_TYPE_STACKED,
  1931. 20066,
  1932. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1933. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1934. if (em->mode < MODE_ENTRY) {
  1935. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR,
  1936. "Fails to write",
  1937. EBPF_COMMON_DIMENSION_CALL,
  1938. NETDATA_VFS_GROUP,
  1939. NETDATA_EBPF_CHART_TYPE_STACKED,
  1940. 20067,
  1941. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1942. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1943. }
  1944. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_READ_CALLS,
  1945. "Read from disk",
  1946. EBPF_COMMON_DIMENSION_CALL,
  1947. NETDATA_VFS_GROUP,
  1948. NETDATA_EBPF_CHART_TYPE_STACKED,
  1949. 20068,
  1950. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1951. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1952. if (em->mode < MODE_ENTRY) {
  1953. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR,
  1954. "Fails to read",
  1955. EBPF_COMMON_DIMENSION_CALL,
  1956. NETDATA_VFS_GROUP,
  1957. NETDATA_EBPF_CHART_TYPE_STACKED,
  1958. 20069,
  1959. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1960. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1961. }
  1962. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES,
  1963. "Bytes written on disk", EBPF_COMMON_DIMENSION_BYTES,
  1964. NETDATA_VFS_GROUP,
  1965. NETDATA_EBPF_CHART_TYPE_STACKED,
  1966. 20070,
  1967. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1968. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1969. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_READ_BYTES,
  1970. "Bytes read from disk", EBPF_COMMON_DIMENSION_BYTES,
  1971. NETDATA_VFS_GROUP,
  1972. NETDATA_EBPF_CHART_TYPE_STACKED,
  1973. 20071,
  1974. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1975. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1976. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_FSYNC,
  1977. "Calls for <code>vfs_fsync</code>", EBPF_COMMON_DIMENSION_CALL,
  1978. NETDATA_VFS_GROUP,
  1979. NETDATA_EBPF_CHART_TYPE_STACKED,
  1980. 20072,
  1981. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1982. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1983. if (em->mode < MODE_ENTRY) {
  1984. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR,
  1985. "Sync error",
  1986. EBPF_COMMON_DIMENSION_CALL,
  1987. NETDATA_VFS_GROUP,
  1988. NETDATA_EBPF_CHART_TYPE_STACKED,
  1989. 20073,
  1990. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1991. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1992. }
  1993. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_OPEN,
  1994. "Calls for <code>vfs_open</code>", EBPF_COMMON_DIMENSION_CALL,
  1995. NETDATA_VFS_GROUP,
  1996. NETDATA_EBPF_CHART_TYPE_STACKED,
  1997. 20074,
  1998. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1999. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  2000. if (em->mode < MODE_ENTRY) {
  2001. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR,
  2002. "Open error",
  2003. EBPF_COMMON_DIMENSION_CALL,
  2004. NETDATA_VFS_GROUP,
  2005. NETDATA_EBPF_CHART_TYPE_STACKED,
  2006. 20075,
  2007. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  2008. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  2009. }
  2010. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_CREATE,
  2011. "Calls for <code>vfs_create</code>", EBPF_COMMON_DIMENSION_CALL,
  2012. NETDATA_VFS_GROUP,
  2013. NETDATA_EBPF_CHART_TYPE_STACKED,
  2014. 20076,
  2015. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  2016. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  2017. if (em->mode < MODE_ENTRY) {
  2018. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR,
  2019. "Create error",
  2020. EBPF_COMMON_DIMENSION_CALL,
  2021. NETDATA_VFS_GROUP,
  2022. NETDATA_EBPF_CHART_TYPE_STACKED,
  2023. 20077,
  2024. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  2025. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  2026. }
  2027. em->apps_charts |= NETDATA_EBPF_APPS_FLAG_CHART_CREATED;
  2028. }
  2029. /*****************************************************************
  2030. *
  2031. * FUNCTIONS TO START THREAD
  2032. *
  2033. *****************************************************************/
  2034. /**
  2035. * Allocate vectors used with this thread.
  2036. * We are not testing the return, because callocz does this and shutdown the software
  2037. * case it was not possible to allocate.
  2038. *
  2039. * @param apps is apps enabled?
  2040. */
  2041. static void ebpf_vfs_allocate_global_vectors(int apps)
  2042. {
  2043. if (apps) {
  2044. ebpf_vfs_aral_init();
  2045. vfs_pid = callocz((size_t)pid_max, sizeof(netdata_publish_vfs_t *));
  2046. vfs_vector = callocz(ebpf_nprocs, sizeof(netdata_publish_vfs_t));
  2047. }
  2048. memset(vfs_aggregated_data, 0, sizeof(vfs_aggregated_data));
  2049. memset(vfs_publish_aggregated, 0, sizeof(vfs_publish_aggregated));
  2050. vfs_hash_values = callocz(ebpf_nprocs, sizeof(netdata_idx_t));
  2051. }
  2052. /*****************************************************************
  2053. *
  2054. * EBPF VFS THREAD
  2055. *
  2056. *****************************************************************/
  2057. /*
  2058. * Load BPF
  2059. *
  2060. * Load BPF files.
  2061. *
  2062. * @param em the structure with configuration
  2063. */
  2064. static int ebpf_vfs_load_bpf(ebpf_module_t *em)
  2065. {
  2066. #ifdef LIBBPF_MAJOR_VERSION
  2067. ebpf_define_map_type(em->maps, em->maps_per_core, running_on_kernel);
  2068. #endif
  2069. int ret = 0;
  2070. ebpf_adjust_apps_cgroup(em, em->targets[NETDATA_EBPF_VFS_WRITE].mode);
  2071. if (em->load & EBPF_LOAD_LEGACY) {
  2072. em->probe_links = ebpf_load_program(ebpf_plugin_dir, em, running_on_kernel, isrh, &em->objects);
  2073. if (!em->probe_links) {
  2074. ret = -1;
  2075. }
  2076. }
  2077. #ifdef LIBBPF_MAJOR_VERSION
  2078. else {
  2079. vfs_bpf_obj = vfs_bpf__open();
  2080. if (!vfs_bpf_obj)
  2081. ret = -1;
  2082. else
  2083. ret = ebpf_vfs_load_and_attach(vfs_bpf_obj, em);
  2084. }
  2085. #endif
  2086. return ret;
  2087. }
  2088. /**
  2089. * Process thread
  2090. *
  2091. * Thread used to generate process charts.
  2092. *
  2093. * @param ptr a pointer to `struct ebpf_module`
  2094. *
  2095. * @return It always return NULL
  2096. */
  2097. void *ebpf_vfs_thread(void *ptr)
  2098. {
  2099. netdata_thread_cleanup_push(ebpf_vfs_exit, ptr);
  2100. ebpf_module_t *em = (ebpf_module_t *)ptr;
  2101. em->maps = vfs_maps;
  2102. ebpf_update_pid_table(&vfs_maps[NETDATA_VFS_PID], em);
  2103. ebpf_vfs_allocate_global_vectors(em->apps_charts);
  2104. #ifdef LIBBPF_MAJOR_VERSION
  2105. ebpf_adjust_thread_load(em, default_btf);
  2106. #endif
  2107. if (ebpf_vfs_load_bpf(em)) {
  2108. goto endvfs;
  2109. }
  2110. int algorithms[NETDATA_KEY_PUBLISH_VFS_END] = {
  2111. NETDATA_EBPF_INCREMENTAL_IDX, NETDATA_EBPF_INCREMENTAL_IDX,NETDATA_EBPF_INCREMENTAL_IDX,
  2112. NETDATA_EBPF_INCREMENTAL_IDX, NETDATA_EBPF_INCREMENTAL_IDX,NETDATA_EBPF_INCREMENTAL_IDX
  2113. };
  2114. ebpf_global_labels(vfs_aggregated_data, vfs_publish_aggregated, vfs_dimension_names,
  2115. vfs_id_names, algorithms, NETDATA_KEY_PUBLISH_VFS_END);
  2116. pthread_mutex_lock(&lock);
  2117. ebpf_create_global_charts(em);
  2118. ebpf_update_stats(&plugin_statistics, em);
  2119. ebpf_update_kernel_memory_with_vector(&plugin_statistics, em->maps, EBPF_ACTION_STAT_ADD);
  2120. #ifdef NETDATA_DEV_MODE
  2121. if (ebpf_aral_vfs_pid)
  2122. vfs_disable_priority = ebpf_statistic_create_aral_chart(NETDATA_EBPF_VFS_ARAL_NAME, em);
  2123. #endif
  2124. pthread_mutex_unlock(&lock);
  2125. vfs_collector(em);
  2126. endvfs:
  2127. ebpf_update_disabled_plugin_stats(em);
  2128. netdata_thread_cleanup_pop(1);
  2129. return NULL;
  2130. }