ebpf_vfs.c 107 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437
  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 stats vector used to read data from control table.
  842. * @param maps_per_core do I need to read all cores?
  843. */
  844. static void ebpf_vfs_read_global_table(netdata_idx_t *stats, int maps_per_core)
  845. {
  846. netdata_idx_t res[NETDATA_VFS_COUNTER];
  847. ebpf_read_global_table_stats(res,
  848. vfs_hash_values,
  849. vfs_maps[NETDATA_VFS_ALL].map_fd,
  850. maps_per_core,
  851. NETDATA_KEY_CALLS_VFS_WRITE,
  852. NETDATA_VFS_COUNTER);
  853. ebpf_read_global_table_stats(stats,
  854. vfs_hash_values,
  855. vfs_maps[NETDATA_VFS_CTRL].map_fd,
  856. maps_per_core,
  857. NETDATA_CONTROLLER_PID_TABLE_ADD,
  858. NETDATA_CONTROLLER_END);
  859. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK].ncall = res[NETDATA_KEY_CALLS_VFS_UNLINK];
  860. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].ncall = res[NETDATA_KEY_CALLS_VFS_READ] +
  861. res[NETDATA_KEY_CALLS_VFS_READV];
  862. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].ncall = res[NETDATA_KEY_CALLS_VFS_WRITE] +
  863. res[NETDATA_KEY_CALLS_VFS_WRITEV];
  864. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC].ncall = res[NETDATA_KEY_CALLS_VFS_FSYNC];
  865. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN].ncall = res[NETDATA_KEY_CALLS_VFS_OPEN];
  866. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE].ncall = res[NETDATA_KEY_CALLS_VFS_CREATE];
  867. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK].nerr = res[NETDATA_KEY_ERROR_VFS_UNLINK];
  868. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].nerr = res[NETDATA_KEY_ERROR_VFS_READ] +
  869. res[NETDATA_KEY_ERROR_VFS_READV];
  870. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].nerr = res[NETDATA_KEY_ERROR_VFS_WRITE] +
  871. res[NETDATA_KEY_ERROR_VFS_WRITEV];
  872. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC].nerr = res[NETDATA_KEY_ERROR_VFS_FSYNC];
  873. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN].nerr = res[NETDATA_KEY_ERROR_VFS_OPEN];
  874. vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE].nerr = res[NETDATA_KEY_ERROR_VFS_CREATE];
  875. vfs_aggregated_data[NETDATA_KEY_PUBLISH_VFS_WRITE].bytes = (uint64_t)res[NETDATA_KEY_BYTES_VFS_WRITE] +
  876. (uint64_t)res[NETDATA_KEY_BYTES_VFS_WRITEV];
  877. vfs_aggregated_data[NETDATA_KEY_PUBLISH_VFS_READ].bytes = (uint64_t)res[NETDATA_KEY_BYTES_VFS_READ] +
  878. (uint64_t)res[NETDATA_KEY_BYTES_VFS_READV];
  879. }
  880. /**
  881. * Sum PIDs
  882. *
  883. * Sum values for all targets.
  884. *
  885. * @param swap output structure
  886. * @param root link list with structure to be used
  887. */
  888. static void ebpf_vfs_sum_pids(netdata_publish_vfs_t *vfs, struct ebpf_pid_on_target *root)
  889. {
  890. netdata_publish_vfs_t accumulator;
  891. memset(&accumulator, 0, sizeof(accumulator));
  892. while (root) {
  893. int32_t pid = root->pid;
  894. netdata_publish_vfs_t *w = vfs_pid[pid];
  895. if (w) {
  896. accumulator.write_call += w->write_call;
  897. accumulator.writev_call += w->writev_call;
  898. accumulator.read_call += w->read_call;
  899. accumulator.readv_call += w->readv_call;
  900. accumulator.unlink_call += w->unlink_call;
  901. accumulator.fsync_call += w->fsync_call;
  902. accumulator.open_call += w->open_call;
  903. accumulator.create_call += w->create_call;
  904. accumulator.write_bytes += w->write_bytes;
  905. accumulator.writev_bytes += w->writev_bytes;
  906. accumulator.read_bytes += w->read_bytes;
  907. accumulator.readv_bytes += w->readv_bytes;
  908. accumulator.write_err += w->write_err;
  909. accumulator.writev_err += w->writev_err;
  910. accumulator.read_err += w->read_err;
  911. accumulator.readv_err += w->readv_err;
  912. accumulator.unlink_err += w->unlink_err;
  913. accumulator.fsync_err += w->fsync_err;
  914. accumulator.open_err += w->open_err;
  915. accumulator.create_err += w->create_err;
  916. }
  917. root = root->next;
  918. }
  919. // These conditions were added, because we are using incremental algorithm
  920. vfs->write_call = (accumulator.write_call >= vfs->write_call) ? accumulator.write_call : vfs->write_call;
  921. vfs->writev_call = (accumulator.writev_call >= vfs->writev_call) ? accumulator.writev_call : vfs->writev_call;
  922. vfs->read_call = (accumulator.read_call >= vfs->read_call) ? accumulator.read_call : vfs->read_call;
  923. vfs->readv_call = (accumulator.readv_call >= vfs->readv_call) ? accumulator.readv_call : vfs->readv_call;
  924. vfs->unlink_call = (accumulator.unlink_call >= vfs->unlink_call) ? accumulator.unlink_call : vfs->unlink_call;
  925. vfs->fsync_call = (accumulator.fsync_call >= vfs->fsync_call) ? accumulator.fsync_call : vfs->fsync_call;
  926. vfs->open_call = (accumulator.open_call >= vfs->open_call) ? accumulator.open_call : vfs->open_call;
  927. vfs->create_call = (accumulator.create_call >= vfs->create_call) ? accumulator.create_call : vfs->create_call;
  928. vfs->write_bytes = (accumulator.write_bytes >= vfs->write_bytes) ? accumulator.write_bytes : vfs->write_bytes;
  929. vfs->writev_bytes = (accumulator.writev_bytes >= vfs->writev_bytes) ? accumulator.writev_bytes : vfs->writev_bytes;
  930. vfs->read_bytes = (accumulator.read_bytes >= vfs->read_bytes) ? accumulator.read_bytes : vfs->read_bytes;
  931. vfs->readv_bytes = (accumulator.readv_bytes >= vfs->readv_bytes) ? accumulator.readv_bytes : vfs->readv_bytes;
  932. vfs->write_err = (accumulator.write_err >= vfs->write_err) ? accumulator.write_err : vfs->write_err;
  933. vfs->writev_err = (accumulator.writev_err >= vfs->writev_err) ? accumulator.writev_err : vfs->writev_err;
  934. vfs->read_err = (accumulator.read_err >= vfs->read_err) ? accumulator.read_err : vfs->read_err;
  935. vfs->readv_err = (accumulator.readv_err >= vfs->readv_err) ? accumulator.readv_err : vfs->readv_err;
  936. vfs->unlink_err = (accumulator.unlink_err >= vfs->unlink_err) ? accumulator.unlink_err : vfs->unlink_err;
  937. vfs->fsync_err = (accumulator.fsync_err >= vfs->fsync_err) ? accumulator.fsync_err : vfs->fsync_err;
  938. vfs->open_err = (accumulator.open_err >= vfs->open_err) ? accumulator.open_err : vfs->open_err;
  939. vfs->create_err = (accumulator.create_err >= vfs->create_err) ? accumulator.create_err : vfs->create_err;
  940. }
  941. /**
  942. * Send data to Netdata calling auxiliary functions.
  943. *
  944. * @param em the structure with thread information
  945. * @param root the target list.
  946. */
  947. void ebpf_vfs_send_apps_data(ebpf_module_t *em, struct ebpf_target *root)
  948. {
  949. struct ebpf_target *w;
  950. for (w = root; w; w = w->next) {
  951. if (unlikely(w->exposed && w->processes)) {
  952. ebpf_vfs_sum_pids(&w->vfs, w->root_pid);
  953. }
  954. }
  955. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_FILE_DELETED);
  956. for (w = root; w; w = w->next) {
  957. if (unlikely(w->exposed && w->processes)) {
  958. write_chart_dimension(w->name, w->vfs.unlink_call);
  959. }
  960. }
  961. write_end_chart();
  962. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS);
  963. for (w = root; w; w = w->next) {
  964. if (unlikely(w->exposed && w->processes)) {
  965. write_chart_dimension(w->name, w->vfs.write_call + w->vfs.writev_call);
  966. }
  967. }
  968. write_end_chart();
  969. if (em->mode < MODE_ENTRY) {
  970. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR);
  971. for (w = root; w; w = w->next) {
  972. if (unlikely(w->exposed && w->processes)) {
  973. write_chart_dimension(w->name, w->vfs.write_err + w->vfs.writev_err);
  974. }
  975. }
  976. write_end_chart();
  977. }
  978. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_CALLS);
  979. for (w = root; w; w = w->next) {
  980. if (unlikely(w->exposed && w->processes)) {
  981. write_chart_dimension(w->name, w->vfs.read_call + w->vfs.readv_call);
  982. }
  983. }
  984. write_end_chart();
  985. if (em->mode < MODE_ENTRY) {
  986. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR);
  987. for (w = root; w; w = w->next) {
  988. if (unlikely(w->exposed && w->processes)) {
  989. write_chart_dimension(w->name, w->vfs.read_err + w->vfs.readv_err);
  990. }
  991. }
  992. write_end_chart();
  993. }
  994. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES);
  995. for (w = root; w; w = w->next) {
  996. if (unlikely(w->exposed && w->processes)) {
  997. write_chart_dimension(w->name, w->vfs.write_bytes + w->vfs.writev_bytes);
  998. }
  999. }
  1000. write_end_chart();
  1001. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_BYTES);
  1002. for (w = root; w; w = w->next) {
  1003. if (unlikely(w->exposed && w->processes)) {
  1004. write_chart_dimension(w->name, w->vfs.read_bytes + w->vfs.readv_bytes);
  1005. }
  1006. }
  1007. write_end_chart();
  1008. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_FSYNC);
  1009. for (w = root; w; w = w->next) {
  1010. if (unlikely(w->exposed && w->processes)) {
  1011. write_chart_dimension(w->name, w->vfs.fsync_call);
  1012. }
  1013. }
  1014. write_end_chart();
  1015. if (em->mode < MODE_ENTRY) {
  1016. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR);
  1017. for (w = root; w; w = w->next) {
  1018. if (unlikely(w->exposed && w->processes)) {
  1019. write_chart_dimension(w->name, w->vfs.fsync_err);
  1020. }
  1021. }
  1022. write_end_chart();
  1023. }
  1024. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_OPEN);
  1025. for (w = root; w; w = w->next) {
  1026. if (unlikely(w->exposed && w->processes)) {
  1027. write_chart_dimension(w->name, w->vfs.open_call);
  1028. }
  1029. }
  1030. write_end_chart();
  1031. if (em->mode < MODE_ENTRY) {
  1032. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR);
  1033. for (w = root; w; w = w->next) {
  1034. if (unlikely(w->exposed && w->processes)) {
  1035. write_chart_dimension(w->name, w->vfs.open_err);
  1036. }
  1037. }
  1038. write_end_chart();
  1039. }
  1040. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_CREATE);
  1041. for (w = root; w; w = w->next) {
  1042. if (unlikely(w->exposed && w->processes)) {
  1043. write_chart_dimension(w->name, w->vfs.create_call);
  1044. }
  1045. }
  1046. write_end_chart();
  1047. if (em->mode < MODE_ENTRY) {
  1048. write_begin_chart(NETDATA_APPS_FAMILY, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR);
  1049. for (w = root; w; w = w->next) {
  1050. if (unlikely(w->exposed && w->processes)) {
  1051. write_chart_dimension(w->name, w->vfs.create_err);
  1052. }
  1053. }
  1054. write_end_chart();
  1055. }
  1056. }
  1057. /**
  1058. * Apps Accumulator
  1059. *
  1060. * Sum all values read from kernel and store in the first address.
  1061. *
  1062. * @param out the vector with read values.
  1063. */
  1064. static void vfs_apps_accumulator(netdata_publish_vfs_t *out, int maps_per_core)
  1065. {
  1066. int i, end = (maps_per_core) ? ebpf_nprocs : 1;
  1067. netdata_publish_vfs_t *total = &out[0];
  1068. for (i = 1; i < end; i++) {
  1069. netdata_publish_vfs_t *w = &out[i];
  1070. total->write_call += w->write_call;
  1071. total->writev_call += w->writev_call;
  1072. total->read_call += w->read_call;
  1073. total->readv_call += w->readv_call;
  1074. total->unlink_call += w->unlink_call;
  1075. total->write_bytes += w->write_bytes;
  1076. total->writev_bytes += w->writev_bytes;
  1077. total->read_bytes += w->read_bytes;
  1078. total->readv_bytes += w->readv_bytes;
  1079. total->write_err += w->write_err;
  1080. total->writev_err += w->writev_err;
  1081. total->read_err += w->read_err;
  1082. total->readv_err += w->readv_err;
  1083. total->unlink_err += w->unlink_err;
  1084. }
  1085. }
  1086. /**
  1087. * Fill PID
  1088. *
  1089. * Fill PID structures
  1090. *
  1091. * @param current_pid pid that we are collecting data
  1092. * @param out values read from hash tables;
  1093. */
  1094. static void vfs_fill_pid(uint32_t current_pid, netdata_publish_vfs_t *publish)
  1095. {
  1096. netdata_publish_vfs_t *curr = vfs_pid[current_pid];
  1097. if (!curr) {
  1098. curr = ebpf_vfs_get();
  1099. vfs_pid[current_pid] = curr;
  1100. }
  1101. memcpy(curr, &publish[0], sizeof(netdata_publish_vfs_t));
  1102. }
  1103. /**
  1104. * Read the hash table and store data to allocated vectors.
  1105. */
  1106. static void ebpf_vfs_read_apps(int maps_per_core)
  1107. {
  1108. struct ebpf_pid_stat *pids = ebpf_root_of_pids;
  1109. netdata_publish_vfs_t *vv = vfs_vector;
  1110. int fd = vfs_maps[NETDATA_VFS_PID].map_fd;
  1111. size_t length = sizeof(netdata_publish_vfs_t);
  1112. if (maps_per_core)
  1113. length *= ebpf_nprocs;
  1114. while (pids) {
  1115. uint32_t key = pids->pid;
  1116. if (bpf_map_lookup_elem(fd, &key, vv)) {
  1117. pids = pids->next;
  1118. continue;
  1119. }
  1120. vfs_apps_accumulator(vv, maps_per_core);
  1121. vfs_fill_pid(key, vv);
  1122. // We are cleaning to avoid passing data read from one process to other.
  1123. memset(vv, 0, length);
  1124. pids = pids->next;
  1125. }
  1126. }
  1127. /**
  1128. * Update cgroup
  1129. *
  1130. * Update cgroup data based in PID.
  1131. *
  1132. * @param maps_per_core do I need to read all cores?
  1133. */
  1134. static void read_update_vfs_cgroup(int maps_per_core)
  1135. {
  1136. ebpf_cgroup_target_t *ect ;
  1137. netdata_publish_vfs_t *vv = vfs_vector;
  1138. int fd = vfs_maps[NETDATA_VFS_PID].map_fd;
  1139. size_t length = sizeof(netdata_publish_vfs_t);
  1140. if (maps_per_core)
  1141. length *= ebpf_nprocs;
  1142. pthread_mutex_lock(&mutex_cgroup_shm);
  1143. for (ect = ebpf_cgroup_pids; ect; ect = ect->next) {
  1144. struct pid_on_target2 *pids;
  1145. for (pids = ect->pids; pids; pids = pids->next) {
  1146. int pid = pids->pid;
  1147. netdata_publish_vfs_t *out = &pids->vfs;
  1148. if (likely(vfs_pid) && vfs_pid[pid]) {
  1149. netdata_publish_vfs_t *in = vfs_pid[pid];
  1150. memcpy(out, in, sizeof(netdata_publish_vfs_t));
  1151. } else {
  1152. memset(vv, 0, length);
  1153. if (!bpf_map_lookup_elem(fd, &pid, vv)) {
  1154. vfs_apps_accumulator(vv, maps_per_core);
  1155. memcpy(out, vv, sizeof(netdata_publish_vfs_t));
  1156. }
  1157. }
  1158. }
  1159. }
  1160. pthread_mutex_unlock(&mutex_cgroup_shm);
  1161. }
  1162. /**
  1163. * Sum PIDs
  1164. *
  1165. * Sum values for all targets.
  1166. *
  1167. * @param vfs structure used to store data
  1168. * @param pids input data
  1169. */
  1170. static void ebpf_vfs_sum_cgroup_pids(netdata_publish_vfs_t *vfs, struct pid_on_target2 *pids)
  1171. {
  1172. netdata_publish_vfs_t accumulator;
  1173. memset(&accumulator, 0, sizeof(accumulator));
  1174. while (pids) {
  1175. netdata_publish_vfs_t *w = &pids->vfs;
  1176. accumulator.write_call += w->write_call;
  1177. accumulator.writev_call += w->writev_call;
  1178. accumulator.read_call += w->read_call;
  1179. accumulator.readv_call += w->readv_call;
  1180. accumulator.unlink_call += w->unlink_call;
  1181. accumulator.fsync_call += w->fsync_call;
  1182. accumulator.open_call += w->open_call;
  1183. accumulator.create_call += w->create_call;
  1184. accumulator.write_bytes += w->write_bytes;
  1185. accumulator.writev_bytes += w->writev_bytes;
  1186. accumulator.read_bytes += w->read_bytes;
  1187. accumulator.readv_bytes += w->readv_bytes;
  1188. accumulator.write_err += w->write_err;
  1189. accumulator.writev_err += w->writev_err;
  1190. accumulator.read_err += w->read_err;
  1191. accumulator.readv_err += w->readv_err;
  1192. accumulator.unlink_err += w->unlink_err;
  1193. accumulator.fsync_err += w->fsync_err;
  1194. accumulator.open_err += w->open_err;
  1195. accumulator.create_err += w->create_err;
  1196. pids = pids->next;
  1197. }
  1198. // These conditions were added, because we are using incremental algorithm
  1199. vfs->write_call = (accumulator.write_call >= vfs->write_call) ? accumulator.write_call : vfs->write_call;
  1200. vfs->writev_call = (accumulator.writev_call >= vfs->writev_call) ? accumulator.writev_call : vfs->writev_call;
  1201. vfs->read_call = (accumulator.read_call >= vfs->read_call) ? accumulator.read_call : vfs->read_call;
  1202. vfs->readv_call = (accumulator.readv_call >= vfs->readv_call) ? accumulator.readv_call : vfs->readv_call;
  1203. vfs->unlink_call = (accumulator.unlink_call >= vfs->unlink_call) ? accumulator.unlink_call : vfs->unlink_call;
  1204. vfs->fsync_call = (accumulator.fsync_call >= vfs->fsync_call) ? accumulator.fsync_call : vfs->fsync_call;
  1205. vfs->open_call = (accumulator.open_call >= vfs->open_call) ? accumulator.open_call : vfs->open_call;
  1206. vfs->create_call = (accumulator.create_call >= vfs->create_call) ? accumulator.create_call : vfs->create_call;
  1207. vfs->write_bytes = (accumulator.write_bytes >= vfs->write_bytes) ? accumulator.write_bytes : vfs->write_bytes;
  1208. vfs->writev_bytes = (accumulator.writev_bytes >= vfs->writev_bytes) ? accumulator.writev_bytes : vfs->writev_bytes;
  1209. vfs->read_bytes = (accumulator.read_bytes >= vfs->read_bytes) ? accumulator.read_bytes : vfs->read_bytes;
  1210. vfs->readv_bytes = (accumulator.readv_bytes >= vfs->readv_bytes) ? accumulator.readv_bytes : vfs->readv_bytes;
  1211. vfs->write_err = (accumulator.write_err >= vfs->write_err) ? accumulator.write_err : vfs->write_err;
  1212. vfs->writev_err = (accumulator.writev_err >= vfs->writev_err) ? accumulator.writev_err : vfs->writev_err;
  1213. vfs->read_err = (accumulator.read_err >= vfs->read_err) ? accumulator.read_err : vfs->read_err;
  1214. vfs->readv_err = (accumulator.readv_err >= vfs->readv_err) ? accumulator.readv_err : vfs->readv_err;
  1215. vfs->unlink_err = (accumulator.unlink_err >= vfs->unlink_err) ? accumulator.unlink_err : vfs->unlink_err;
  1216. vfs->fsync_err = (accumulator.fsync_err >= vfs->fsync_err) ? accumulator.fsync_err : vfs->fsync_err;
  1217. vfs->open_err = (accumulator.open_err >= vfs->open_err) ? accumulator.open_err : vfs->open_err;
  1218. vfs->create_err = (accumulator.create_err >= vfs->create_err) ? accumulator.create_err : vfs->create_err;
  1219. }
  1220. /**
  1221. * Create specific VFS charts
  1222. *
  1223. * Create charts for cgroup/application.
  1224. *
  1225. * @param type the chart type.
  1226. * @param em the main thread structure.
  1227. */
  1228. static void ebpf_create_specific_vfs_charts(char *type, ebpf_module_t *em)
  1229. {
  1230. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_FILE_DELETED,"Files deleted",
  1231. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_UNLINK_CONTEXT,
  1232. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5500,
  1233. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK],
  1234. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1235. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS, "Write to disk",
  1236. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_WRITE_CONTEXT,
  1237. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5501,
  1238. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1239. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1240. if (em->mode < MODE_ENTRY) {
  1241. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR, "Fails to write",
  1242. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_WRITE_ERROR_CONTEXT,
  1243. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5502,
  1244. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1245. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1246. }
  1247. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS, "Read from disk",
  1248. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_READ_CONTEXT,
  1249. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5503,
  1250. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1251. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1252. if (em->mode < MODE_ENTRY) {
  1253. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR, "Fails to read",
  1254. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_READ_ERROR_CONTEXT,
  1255. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5504,
  1256. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1257. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1258. }
  1259. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES, "Bytes written on disk",
  1260. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_WRITE_BYTES_CONTEXT,
  1261. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5505,
  1262. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1263. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1264. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_BYTES, "Bytes read from disk",
  1265. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_READ_BYTES_CONTEXT,
  1266. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5506,
  1267. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1268. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1269. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_FSYNC, "Calls for <code>vfs_fsync</code>",
  1270. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_FSYNC_CONTEXT,
  1271. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5507,
  1272. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC],
  1273. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1274. if (em->mode < MODE_ENTRY) {
  1275. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR, "Sync error",
  1276. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_FSYNC_ERROR_CONTEXT,
  1277. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5508,
  1278. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC],
  1279. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1280. }
  1281. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_OPEN, "Calls for <code>vfs_open</code>",
  1282. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_OPEN_CONTEXT,
  1283. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5509,
  1284. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN],
  1285. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1286. if (em->mode < MODE_ENTRY) {
  1287. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR, "Open error",
  1288. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_OPEN_ERROR_CONTEXT,
  1289. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5510,
  1290. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN],
  1291. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1292. }
  1293. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_CREATE, "Calls for <code>vfs_create</code>",
  1294. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_CREATE_CONTEXT,
  1295. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5511,
  1296. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  1297. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1298. if (em->mode < MODE_ENTRY) {
  1299. ebpf_create_chart(type, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR, "Create error",
  1300. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP, NETDATA_CGROUP_VFS_CREATE_ERROR_CONTEXT,
  1301. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5512,
  1302. ebpf_create_global_dimension, &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  1303. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1304. }
  1305. }
  1306. /**
  1307. * Obsolete specific VFS charts
  1308. *
  1309. * Obsolete charts for cgroup/application.
  1310. *
  1311. * @param type the chart type.
  1312. * @param em the main thread structure.
  1313. */
  1314. static void ebpf_obsolete_specific_vfs_charts(char *type, ebpf_module_t *em)
  1315. {
  1316. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_FILE_DELETED, "Files deleted",
  1317. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1318. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_UNLINK_CONTEXT,
  1319. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5500, em->update_every);
  1320. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS, "Write to disk",
  1321. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1322. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_WRITE_CONTEXT,
  1323. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5501, em->update_every);
  1324. if (em->mode < MODE_ENTRY) {
  1325. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR, "Fails to write",
  1326. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1327. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_WRITE_ERROR_CONTEXT,
  1328. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5502, em->update_every);
  1329. }
  1330. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS, "Read from disk",
  1331. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1332. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_READ_CONTEXT,
  1333. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5503, em->update_every);
  1334. if (em->mode < MODE_ENTRY) {
  1335. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR, "Fails to read",
  1336. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1337. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_READ_ERROR_CONTEXT,
  1338. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5504, em->update_every);
  1339. }
  1340. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES, "Bytes written on disk",
  1341. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_GROUP,
  1342. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_WRITE_BYTES_CONTEXT,
  1343. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5505, em->update_every);
  1344. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_READ_BYTES, "Bytes read from disk",
  1345. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_GROUP,
  1346. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_READ_BYTES_CONTEXT,
  1347. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5506, em->update_every);
  1348. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_FSYNC, "Calls for <code>vfs_fsync</code>",
  1349. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1350. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_FSYNC_CONTEXT,
  1351. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5507, em->update_every);
  1352. if (em->mode < MODE_ENTRY) {
  1353. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR, "Sync error",
  1354. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1355. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_FSYNC_ERROR_CONTEXT,
  1356. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5508, em->update_every);
  1357. }
  1358. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_OPEN, "Calls for <code>vfs_open</code>",
  1359. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1360. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_OPEN_CONTEXT,
  1361. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5509, em->update_every);
  1362. if (em->mode < MODE_ENTRY) {
  1363. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR, "Open error",
  1364. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1365. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_OPEN_ERROR_CONTEXT,
  1366. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5510, em->update_every);
  1367. }
  1368. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_CREATE, "Calls for <code>vfs_create</code>",
  1369. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1370. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_CREATE_CONTEXT,
  1371. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5511, em->update_every);
  1372. if (em->mode < MODE_ENTRY) {
  1373. ebpf_write_chart_obsolete(type, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR, "Create error",
  1374. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_GROUP,
  1375. NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_VFS_CREATE_ERROR_CONTEXT,
  1376. NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5512, em->update_every);
  1377. }
  1378. }
  1379. /*
  1380. * Send specific VFS data
  1381. *
  1382. * Send data for specific cgroup/apps.
  1383. *
  1384. * @param type chart type
  1385. * @param values structure with values that will be sent to netdata
  1386. */
  1387. static void ebpf_send_specific_vfs_data(char *type, netdata_publish_vfs_t *values, ebpf_module_t *em)
  1388. {
  1389. write_begin_chart(type, NETDATA_SYSCALL_APPS_FILE_DELETED);
  1390. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK].name, (long long)values->unlink_call);
  1391. write_end_chart();
  1392. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS);
  1393. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].name,
  1394. (long long)values->write_call + (long long)values->writev_call);
  1395. write_end_chart();
  1396. if (em->mode < MODE_ENTRY) {
  1397. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR);
  1398. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].name,
  1399. (long long)values->write_err + (long long)values->writev_err);
  1400. write_end_chart();
  1401. }
  1402. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS);
  1403. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].name,
  1404. (long long)values->read_call + (long long)values->readv_call);
  1405. write_end_chart();
  1406. if (em->mode < MODE_ENTRY) {
  1407. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR);
  1408. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].name,
  1409. (long long)values->read_err + (long long)values->readv_err);
  1410. write_end_chart();
  1411. }
  1412. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES);
  1413. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_WRITE].name,
  1414. (long long)values->write_bytes + (long long)values->writev_bytes);
  1415. write_end_chart();
  1416. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_READ_BYTES);
  1417. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ].name,
  1418. (long long)values->read_bytes + (long long)values->readv_bytes);
  1419. write_end_chart();
  1420. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_FSYNC);
  1421. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC].name,
  1422. (long long)values->fsync_call);
  1423. write_end_chart();
  1424. if (em->mode < MODE_ENTRY) {
  1425. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR);
  1426. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC].name,
  1427. (long long)values->fsync_err);
  1428. write_end_chart();
  1429. }
  1430. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_OPEN);
  1431. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN].name,
  1432. (long long)values->open_call);
  1433. write_end_chart();
  1434. if (em->mode < MODE_ENTRY) {
  1435. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR);
  1436. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN].name,
  1437. (long long)values->open_err);
  1438. write_end_chart();
  1439. }
  1440. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_CREATE);
  1441. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE].name,
  1442. (long long)values->create_call);
  1443. write_end_chart();
  1444. if (em->mode < MODE_ENTRY) {
  1445. write_begin_chart(type, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR);
  1446. write_chart_dimension(vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE].name,
  1447. (long long)values->create_err);
  1448. write_end_chart();
  1449. }
  1450. }
  1451. /**
  1452. * Create Systemd Socket Charts
  1453. *
  1454. * Create charts when systemd is enabled
  1455. *
  1456. * @param em the main collector structure
  1457. **/
  1458. static void ebpf_create_systemd_vfs_charts(ebpf_module_t *em)
  1459. {
  1460. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_FILE_DELETED, "Files deleted",
  1461. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1462. NETDATA_EBPF_CHART_TYPE_STACKED, 20065,
  1463. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_UNLINK_CONTEXT,
  1464. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1465. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS, "Write to disk",
  1466. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1467. NETDATA_EBPF_CHART_TYPE_STACKED, 20066,
  1468. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_WRITE_CONTEXT,
  1469. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1470. if (em->mode < MODE_ENTRY) {
  1471. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR, "Fails to write",
  1472. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1473. NETDATA_EBPF_CHART_TYPE_STACKED, 20067,
  1474. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1475. NETDATA_SYSTEMD_VFS_WRITE_ERROR_CONTEXT,
  1476. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1477. }
  1478. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_READ_CALLS, "Read from disk",
  1479. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1480. NETDATA_EBPF_CHART_TYPE_STACKED, 20068,
  1481. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_READ_CONTEXT,
  1482. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1483. if (em->mode < MODE_ENTRY) {
  1484. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR, "Fails to read",
  1485. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1486. NETDATA_EBPF_CHART_TYPE_STACKED, 20069,
  1487. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1488. NETDATA_SYSTEMD_VFS_READ_ERROR_CONTEXT,
  1489. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1490. }
  1491. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES, "Bytes written on disk",
  1492. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_CGROUP_GROUP,
  1493. NETDATA_EBPF_CHART_TYPE_STACKED, 20070,
  1494. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_WRITE_BYTES_CONTEXT,
  1495. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1496. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_READ_BYTES, "Bytes read from disk",
  1497. EBPF_COMMON_DIMENSION_BYTES, NETDATA_VFS_CGROUP_GROUP,
  1498. NETDATA_EBPF_CHART_TYPE_STACKED, 20071,
  1499. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_READ_BYTES_CONTEXT,
  1500. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1501. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_FSYNC, "Calls to <code>vfs_fsync</code>",
  1502. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1503. NETDATA_EBPF_CHART_TYPE_STACKED, 20072,
  1504. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_FSYNC_CONTEXT,
  1505. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1506. if (em->mode < MODE_ENTRY) {
  1507. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR, "Sync error",
  1508. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1509. NETDATA_EBPF_CHART_TYPE_STACKED, 20073,
  1510. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_FSYNC_ERROR_CONTEXT,
  1511. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1512. }
  1513. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_OPEN, "Calls to <code>vfs_open</code>",
  1514. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1515. NETDATA_EBPF_CHART_TYPE_STACKED, 20074,
  1516. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_OPEN_CONTEXT,
  1517. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1518. if (em->mode < MODE_ENTRY) {
  1519. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR, "Open error",
  1520. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1521. NETDATA_EBPF_CHART_TYPE_STACKED, 20075,
  1522. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_OPEN_ERROR_CONTEXT,
  1523. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1524. }
  1525. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_CREATE, "Calls to <code>vfs_create</code>",
  1526. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1527. NETDATA_EBPF_CHART_TYPE_STACKED, 20076,
  1528. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_CREATE_CONTEXT,
  1529. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1530. if (em->mode < MODE_ENTRY) {
  1531. ebpf_create_charts_on_systemd(NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR, "Create error",
  1532. EBPF_COMMON_DIMENSION_CALL, NETDATA_VFS_CGROUP_GROUP,
  1533. NETDATA_EBPF_CHART_TYPE_STACKED, 20077,
  1534. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], NETDATA_SYSTEMD_VFS_CREATE_ERROR_CONTEXT,
  1535. NETDATA_EBPF_MODULE_NAME_VFS, em->update_every);
  1536. }
  1537. }
  1538. /**
  1539. * Send Systemd charts
  1540. *
  1541. * Send collected data to Netdata.
  1542. *
  1543. * @param em the main collector structure
  1544. */
  1545. static void ebpf_send_systemd_vfs_charts(ebpf_module_t *em)
  1546. {
  1547. ebpf_cgroup_target_t *ect;
  1548. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_FILE_DELETED);
  1549. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1550. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1551. write_chart_dimension(ect->name, ect->publish_systemd_vfs.unlink_call);
  1552. }
  1553. }
  1554. write_end_chart();
  1555. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS);
  1556. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1557. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1558. write_chart_dimension(ect->name, ect->publish_systemd_vfs.write_call +
  1559. ect->publish_systemd_vfs.writev_call);
  1560. }
  1561. }
  1562. write_end_chart();
  1563. if (em->mode < MODE_ENTRY) {
  1564. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR);
  1565. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1566. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1567. write_chart_dimension(ect->name, ect->publish_systemd_vfs.write_err +
  1568. ect->publish_systemd_vfs.writev_err);
  1569. }
  1570. }
  1571. write_end_chart();
  1572. }
  1573. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_CALLS);
  1574. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1575. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1576. write_chart_dimension(ect->name, ect->publish_systemd_vfs.read_call +
  1577. ect->publish_systemd_vfs.readv_call);
  1578. }
  1579. }
  1580. write_end_chart();
  1581. if (em->mode < MODE_ENTRY) {
  1582. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR);
  1583. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1584. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1585. write_chart_dimension(ect->name, ect->publish_systemd_vfs.read_err +
  1586. ect->publish_systemd_vfs.readv_err);
  1587. }
  1588. }
  1589. write_end_chart();
  1590. }
  1591. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES);
  1592. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1593. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1594. write_chart_dimension(ect->name, ect->publish_systemd_vfs.write_bytes +
  1595. ect->publish_systemd_vfs.writev_bytes);
  1596. }
  1597. }
  1598. write_end_chart();
  1599. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_READ_BYTES);
  1600. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1601. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1602. write_chart_dimension(ect->name, ect->publish_systemd_vfs.read_bytes +
  1603. ect->publish_systemd_vfs.readv_bytes);
  1604. }
  1605. }
  1606. write_end_chart();
  1607. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_FSYNC);
  1608. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1609. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1610. write_chart_dimension(ect->name, ect->publish_systemd_vfs.fsync_call);
  1611. }
  1612. }
  1613. write_end_chart();
  1614. if (em->mode < MODE_ENTRY) {
  1615. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR);
  1616. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1617. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1618. write_chart_dimension(ect->name, ect->publish_systemd_vfs.fsync_err);
  1619. }
  1620. }
  1621. write_end_chart();
  1622. }
  1623. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_OPEN);
  1624. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1625. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1626. write_chart_dimension(ect->name, ect->publish_systemd_vfs.open_call);
  1627. }
  1628. }
  1629. write_end_chart();
  1630. if (em->mode < MODE_ENTRY) {
  1631. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR);
  1632. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1633. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1634. write_chart_dimension(ect->name, ect->publish_systemd_vfs.open_err);
  1635. }
  1636. }
  1637. write_end_chart();
  1638. }
  1639. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_CREATE);
  1640. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1641. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1642. write_chart_dimension(ect->name, ect->publish_systemd_vfs.create_call);
  1643. }
  1644. }
  1645. write_end_chart();
  1646. if (em->mode < MODE_ENTRY) {
  1647. write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR);
  1648. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1649. if (unlikely(ect->systemd) && unlikely(ect->updated)) {
  1650. write_chart_dimension(ect->name, ect->publish_systemd_vfs.create_err);
  1651. }
  1652. }
  1653. write_end_chart();
  1654. }
  1655. }
  1656. /**
  1657. * Send data to Netdata calling auxiliary functions.
  1658. *
  1659. * @param em the main collector structure
  1660. */
  1661. static void ebpf_vfs_send_cgroup_data(ebpf_module_t *em)
  1662. {
  1663. if (!ebpf_cgroup_pids)
  1664. return;
  1665. pthread_mutex_lock(&mutex_cgroup_shm);
  1666. ebpf_cgroup_target_t *ect;
  1667. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1668. ebpf_vfs_sum_cgroup_pids(&ect->publish_systemd_vfs, ect->pids);
  1669. }
  1670. int has_systemd = shm_ebpf_cgroup.header->systemd_enabled;
  1671. if (has_systemd) {
  1672. if (send_cgroup_chart) {
  1673. ebpf_create_systemd_vfs_charts(em);
  1674. }
  1675. ebpf_send_systemd_vfs_charts(em);
  1676. }
  1677. for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) {
  1678. if (ect->systemd)
  1679. continue;
  1680. if (!(ect->flags & NETDATA_EBPF_CGROUP_HAS_VFS_CHART) && ect->updated) {
  1681. ebpf_create_specific_vfs_charts(ect->name, em);
  1682. ect->flags |= NETDATA_EBPF_CGROUP_HAS_VFS_CHART;
  1683. }
  1684. if (ect->flags & NETDATA_EBPF_CGROUP_HAS_VFS_CHART) {
  1685. if (ect->updated) {
  1686. ebpf_send_specific_vfs_data(ect->name, &ect->publish_systemd_vfs, em);
  1687. } else {
  1688. ebpf_obsolete_specific_vfs_charts(ect->name, em);
  1689. ect->flags &= ~NETDATA_EBPF_CGROUP_HAS_VFS_CHART;
  1690. }
  1691. }
  1692. }
  1693. pthread_mutex_unlock(&mutex_cgroup_shm);
  1694. }
  1695. /**
  1696. * Main loop for this collector.
  1697. *
  1698. * @param step the number of microseconds used with heart beat
  1699. * @param em the structure with thread information
  1700. */
  1701. static void vfs_collector(ebpf_module_t *em)
  1702. {
  1703. int cgroups = em->cgroup_charts;
  1704. heartbeat_t hb;
  1705. heartbeat_init(&hb);
  1706. int update_every = em->update_every;
  1707. int counter = update_every - 1;
  1708. int maps_per_core = em->maps_per_core;
  1709. uint32_t running_time = 0;
  1710. uint32_t lifetime = em->lifetime;
  1711. netdata_idx_t *stats = em->hash_table_stats;
  1712. memset(stats, 0, sizeof(em->hash_table_stats));
  1713. while (!ebpf_exit_plugin && running_time < lifetime) {
  1714. (void)heartbeat_next(&hb, USEC_PER_SEC);
  1715. if (ebpf_exit_plugin || ++counter != update_every)
  1716. continue;
  1717. counter = 0;
  1718. netdata_apps_integration_flags_t apps = em->apps_charts;
  1719. ebpf_vfs_read_global_table(stats, maps_per_core);
  1720. pthread_mutex_lock(&collect_data_mutex);
  1721. if (apps)
  1722. ebpf_vfs_read_apps(maps_per_core);
  1723. if (cgroups)
  1724. read_update_vfs_cgroup(maps_per_core);
  1725. pthread_mutex_lock(&lock);
  1726. #ifdef NETDATA_DEV_MODE
  1727. if (ebpf_aral_vfs_pid)
  1728. ebpf_send_data_aral_chart(ebpf_aral_vfs_pid, em);
  1729. #endif
  1730. ebpf_vfs_send_data(em);
  1731. fflush(stdout);
  1732. if (apps & NETDATA_EBPF_APPS_FLAG_CHART_CREATED)
  1733. ebpf_vfs_send_apps_data(em, apps_groups_root_target);
  1734. if (cgroups)
  1735. ebpf_vfs_send_cgroup_data(em);
  1736. pthread_mutex_unlock(&lock);
  1737. pthread_mutex_unlock(&collect_data_mutex);
  1738. pthread_mutex_lock(&ebpf_exit_cleanup);
  1739. if (running_time && !em->running_time)
  1740. running_time = update_every;
  1741. else
  1742. running_time += update_every;
  1743. em->running_time = running_time;
  1744. pthread_mutex_unlock(&ebpf_exit_cleanup);
  1745. }
  1746. }
  1747. /*****************************************************************
  1748. *
  1749. * FUNCTIONS TO CREATE CHARTS
  1750. *
  1751. *****************************************************************/
  1752. /**
  1753. * Create IO chart
  1754. *
  1755. * @param family the chart family
  1756. * @param name the chart name
  1757. * @param axis the axis label
  1758. * @param web the group name used to attach the chart on dashboard
  1759. * @param order the order number of the specified chart
  1760. * @param algorithm the algorithm used to make the charts.
  1761. * @param update_every value to overwrite the update frequency set by the server.
  1762. */
  1763. static void ebpf_create_io_chart(char *family, char *name, char *axis, char *web,
  1764. int order, int algorithm, int update_every)
  1765. {
  1766. printf("CHART %s.%s '' 'Bytes written and read' '%s' '%s' '' line %d %d '' 'ebpf.plugin' 'filesystem'\n",
  1767. family,
  1768. name,
  1769. axis,
  1770. web,
  1771. order,
  1772. update_every);
  1773. printf("DIMENSION %s %s %s 1 1\n",
  1774. vfs_id_names[NETDATA_KEY_PUBLISH_VFS_READ],
  1775. vfs_dimension_names[NETDATA_KEY_PUBLISH_VFS_READ],
  1776. ebpf_algorithms[algorithm]);
  1777. printf("DIMENSION %s %s %s -1 1\n",
  1778. vfs_id_names[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1779. vfs_dimension_names[NETDATA_KEY_PUBLISH_VFS_WRITE],
  1780. ebpf_algorithms[algorithm]);
  1781. }
  1782. /**
  1783. * Create global charts
  1784. *
  1785. * Call ebpf_create_chart to create the charts for the collector.
  1786. *
  1787. * @param em a pointer to the structure with the default values.
  1788. */
  1789. static void ebpf_create_global_charts(ebpf_module_t *em)
  1790. {
  1791. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1792. NETDATA_VFS_FILE_CLEAN_COUNT,
  1793. "Remove files",
  1794. EBPF_COMMON_DIMENSION_CALL,
  1795. NETDATA_VFS_GROUP,
  1796. NULL,
  1797. NETDATA_EBPF_CHART_TYPE_LINE,
  1798. NETDATA_CHART_PRIO_FILESYSTEM_VFS_CLEAN,
  1799. ebpf_create_global_dimension,
  1800. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_UNLINK],
  1801. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1802. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1803. NETDATA_VFS_FILE_IO_COUNT,
  1804. "Calls to IO",
  1805. EBPF_COMMON_DIMENSION_CALL,
  1806. NETDATA_VFS_GROUP,
  1807. NULL,
  1808. NETDATA_EBPF_CHART_TYPE_LINE,
  1809. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_COUNT,
  1810. ebpf_create_global_dimension,
  1811. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1812. 2, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1813. ebpf_create_io_chart(NETDATA_FILESYSTEM_FAMILY,
  1814. NETDATA_VFS_IO_FILE_BYTES, EBPF_COMMON_DIMENSION_BYTES,
  1815. NETDATA_VFS_GROUP,
  1816. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_BYTES,
  1817. NETDATA_EBPF_INCREMENTAL_IDX, em->update_every);
  1818. if (em->mode < MODE_ENTRY) {
  1819. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1820. NETDATA_VFS_FILE_ERR_COUNT,
  1821. "Fails to write or read",
  1822. EBPF_COMMON_DIMENSION_CALL,
  1823. NETDATA_VFS_GROUP,
  1824. NULL,
  1825. NETDATA_EBPF_CHART_TYPE_LINE,
  1826. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EBYTES,
  1827. ebpf_create_global_dimension,
  1828. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_READ],
  1829. 2, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1830. }
  1831. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1832. NETDATA_VFS_FSYNC,
  1833. "Calls for <code>vfs_fsync</code>",
  1834. EBPF_COMMON_DIMENSION_CALL,
  1835. NETDATA_VFS_GROUP,
  1836. NULL,
  1837. NETDATA_EBPF_CHART_TYPE_LINE,
  1838. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_FSYNC,
  1839. ebpf_create_global_dimension,
  1840. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC],
  1841. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1842. if (em->mode < MODE_ENTRY) {
  1843. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1844. NETDATA_VFS_FSYNC_ERR,
  1845. "Fails to synchronize",
  1846. EBPF_COMMON_DIMENSION_CALL,
  1847. NETDATA_VFS_GROUP,
  1848. NULL,
  1849. NETDATA_EBPF_CHART_TYPE_LINE,
  1850. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EFSYNC,
  1851. ebpf_create_global_dimension,
  1852. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_FSYNC],
  1853. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1854. }
  1855. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1856. NETDATA_VFS_OPEN,
  1857. "Calls for <code>vfs_open</code>",
  1858. EBPF_COMMON_DIMENSION_CALL,
  1859. NETDATA_VFS_GROUP,
  1860. NULL,
  1861. NETDATA_EBPF_CHART_TYPE_LINE,
  1862. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_OPEN,
  1863. ebpf_create_global_dimension,
  1864. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN],
  1865. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1866. if (em->mode < MODE_ENTRY) {
  1867. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1868. NETDATA_VFS_OPEN_ERR,
  1869. "Fails to open a file",
  1870. EBPF_COMMON_DIMENSION_CALL,
  1871. NETDATA_VFS_GROUP,
  1872. NULL,
  1873. NETDATA_EBPF_CHART_TYPE_LINE,
  1874. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_EOPEN,
  1875. ebpf_create_global_dimension,
  1876. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_OPEN],
  1877. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1878. }
  1879. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1880. NETDATA_VFS_CREATE,
  1881. "Calls for <code>vfs_create</code>",
  1882. EBPF_COMMON_DIMENSION_CALL,
  1883. NETDATA_VFS_GROUP,
  1884. NULL,
  1885. NETDATA_EBPF_CHART_TYPE_LINE,
  1886. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_CREATE,
  1887. ebpf_create_global_dimension,
  1888. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  1889. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1890. if (em->mode < MODE_ENTRY) {
  1891. ebpf_create_chart(NETDATA_FILESYSTEM_FAMILY,
  1892. NETDATA_VFS_CREATE_ERR,
  1893. "Fails to create a file.",
  1894. EBPF_COMMON_DIMENSION_CALL,
  1895. NETDATA_VFS_GROUP,
  1896. NULL,
  1897. NETDATA_EBPF_CHART_TYPE_LINE,
  1898. NETDATA_CHART_PRIO_FILESYSTEM_VFS_IO_ECREATE,
  1899. ebpf_create_global_dimension,
  1900. &vfs_publish_aggregated[NETDATA_KEY_PUBLISH_VFS_CREATE],
  1901. 1, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1902. }
  1903. fflush(stdout);
  1904. }
  1905. /**
  1906. * Create process apps charts
  1907. *
  1908. * Call ebpf_create_chart to create the charts on apps submenu.
  1909. *
  1910. * @param em a pointer to the structure with the default values.
  1911. * @param ptr a pointer for the targets.
  1912. **/
  1913. void ebpf_vfs_create_apps_charts(struct ebpf_module *em, void *ptr)
  1914. {
  1915. struct ebpf_target *root = ptr;
  1916. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_FILE_DELETED,
  1917. "Files deleted",
  1918. EBPF_COMMON_DIMENSION_CALL,
  1919. NETDATA_VFS_GROUP,
  1920. NETDATA_EBPF_CHART_TYPE_STACKED,
  1921. 20065,
  1922. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1923. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1924. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS,
  1925. "Write to disk",
  1926. EBPF_COMMON_DIMENSION_CALL,
  1927. NETDATA_VFS_GROUP,
  1928. NETDATA_EBPF_CHART_TYPE_STACKED,
  1929. 20066,
  1930. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1931. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1932. if (em->mode < MODE_ENTRY) {
  1933. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_WRITE_CALLS_ERROR,
  1934. "Fails to write",
  1935. EBPF_COMMON_DIMENSION_CALL,
  1936. NETDATA_VFS_GROUP,
  1937. NETDATA_EBPF_CHART_TYPE_STACKED,
  1938. 20067,
  1939. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1940. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1941. }
  1942. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_READ_CALLS,
  1943. "Read from disk",
  1944. EBPF_COMMON_DIMENSION_CALL,
  1945. NETDATA_VFS_GROUP,
  1946. NETDATA_EBPF_CHART_TYPE_STACKED,
  1947. 20068,
  1948. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1949. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1950. if (em->mode < MODE_ENTRY) {
  1951. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_READ_CALLS_ERROR,
  1952. "Fails to read",
  1953. EBPF_COMMON_DIMENSION_CALL,
  1954. NETDATA_VFS_GROUP,
  1955. NETDATA_EBPF_CHART_TYPE_STACKED,
  1956. 20069,
  1957. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1958. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1959. }
  1960. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_WRITE_BYTES,
  1961. "Bytes written on disk", EBPF_COMMON_DIMENSION_BYTES,
  1962. NETDATA_VFS_GROUP,
  1963. NETDATA_EBPF_CHART_TYPE_STACKED,
  1964. 20070,
  1965. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1966. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1967. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_READ_BYTES,
  1968. "Bytes read from disk", EBPF_COMMON_DIMENSION_BYTES,
  1969. NETDATA_VFS_GROUP,
  1970. NETDATA_EBPF_CHART_TYPE_STACKED,
  1971. 20071,
  1972. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1973. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1974. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_FSYNC,
  1975. "Calls for <code>vfs_fsync</code>", EBPF_COMMON_DIMENSION_CALL,
  1976. NETDATA_VFS_GROUP,
  1977. NETDATA_EBPF_CHART_TYPE_STACKED,
  1978. 20072,
  1979. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1980. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1981. if (em->mode < MODE_ENTRY) {
  1982. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_FSYNC_CALLS_ERROR,
  1983. "Sync error",
  1984. EBPF_COMMON_DIMENSION_CALL,
  1985. NETDATA_VFS_GROUP,
  1986. NETDATA_EBPF_CHART_TYPE_STACKED,
  1987. 20073,
  1988. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1989. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1990. }
  1991. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_OPEN,
  1992. "Calls for <code>vfs_open</code>", EBPF_COMMON_DIMENSION_CALL,
  1993. NETDATA_VFS_GROUP,
  1994. NETDATA_EBPF_CHART_TYPE_STACKED,
  1995. 20074,
  1996. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  1997. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  1998. if (em->mode < MODE_ENTRY) {
  1999. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_OPEN_CALLS_ERROR,
  2000. "Open error",
  2001. EBPF_COMMON_DIMENSION_CALL,
  2002. NETDATA_VFS_GROUP,
  2003. NETDATA_EBPF_CHART_TYPE_STACKED,
  2004. 20075,
  2005. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  2006. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  2007. }
  2008. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_CREATE,
  2009. "Calls for <code>vfs_create</code>", EBPF_COMMON_DIMENSION_CALL,
  2010. NETDATA_VFS_GROUP,
  2011. NETDATA_EBPF_CHART_TYPE_STACKED,
  2012. 20076,
  2013. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  2014. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  2015. if (em->mode < MODE_ENTRY) {
  2016. ebpf_create_charts_on_apps(NETDATA_SYSCALL_APPS_VFS_CREATE_CALLS_ERROR,
  2017. "Create error",
  2018. EBPF_COMMON_DIMENSION_CALL,
  2019. NETDATA_VFS_GROUP,
  2020. NETDATA_EBPF_CHART_TYPE_STACKED,
  2021. 20077,
  2022. ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX],
  2023. root, em->update_every, NETDATA_EBPF_MODULE_NAME_VFS);
  2024. }
  2025. em->apps_charts |= NETDATA_EBPF_APPS_FLAG_CHART_CREATED;
  2026. }
  2027. /*****************************************************************
  2028. *
  2029. * FUNCTIONS TO START THREAD
  2030. *
  2031. *****************************************************************/
  2032. /**
  2033. * Allocate vectors used with this thread.
  2034. * We are not testing the return, because callocz does this and shutdown the software
  2035. * case it was not possible to allocate.
  2036. *
  2037. * @param apps is apps enabled?
  2038. */
  2039. static void ebpf_vfs_allocate_global_vectors(int apps)
  2040. {
  2041. if (apps) {
  2042. ebpf_vfs_aral_init();
  2043. vfs_pid = callocz((size_t)pid_max, sizeof(netdata_publish_vfs_t *));
  2044. vfs_vector = callocz(ebpf_nprocs, sizeof(netdata_publish_vfs_t));
  2045. }
  2046. memset(vfs_aggregated_data, 0, sizeof(vfs_aggregated_data));
  2047. memset(vfs_publish_aggregated, 0, sizeof(vfs_publish_aggregated));
  2048. vfs_hash_values = callocz(ebpf_nprocs, sizeof(netdata_idx_t));
  2049. }
  2050. /*****************************************************************
  2051. *
  2052. * EBPF VFS THREAD
  2053. *
  2054. *****************************************************************/
  2055. /*
  2056. * Load BPF
  2057. *
  2058. * Load BPF files.
  2059. *
  2060. * @param em the structure with configuration
  2061. */
  2062. static int ebpf_vfs_load_bpf(ebpf_module_t *em)
  2063. {
  2064. #ifdef LIBBPF_MAJOR_VERSION
  2065. ebpf_define_map_type(em->maps, em->maps_per_core, running_on_kernel);
  2066. #endif
  2067. int ret = 0;
  2068. ebpf_adjust_apps_cgroup(em, em->targets[NETDATA_EBPF_VFS_WRITE].mode);
  2069. if (em->load & EBPF_LOAD_LEGACY) {
  2070. em->probe_links = ebpf_load_program(ebpf_plugin_dir, em, running_on_kernel, isrh, &em->objects);
  2071. if (!em->probe_links) {
  2072. ret = -1;
  2073. }
  2074. }
  2075. #ifdef LIBBPF_MAJOR_VERSION
  2076. else {
  2077. vfs_bpf_obj = vfs_bpf__open();
  2078. if (!vfs_bpf_obj)
  2079. ret = -1;
  2080. else
  2081. ret = ebpf_vfs_load_and_attach(vfs_bpf_obj, em);
  2082. }
  2083. #endif
  2084. return ret;
  2085. }
  2086. /**
  2087. * Process thread
  2088. *
  2089. * Thread used to generate process charts.
  2090. *
  2091. * @param ptr a pointer to `struct ebpf_module`
  2092. *
  2093. * @return It always return NULL
  2094. */
  2095. void *ebpf_vfs_thread(void *ptr)
  2096. {
  2097. netdata_thread_cleanup_push(ebpf_vfs_exit, ptr);
  2098. ebpf_module_t *em = (ebpf_module_t *)ptr;
  2099. em->maps = vfs_maps;
  2100. ebpf_update_pid_table(&vfs_maps[NETDATA_VFS_PID], em);
  2101. ebpf_vfs_allocate_global_vectors(em->apps_charts);
  2102. #ifdef LIBBPF_MAJOR_VERSION
  2103. ebpf_adjust_thread_load(em, default_btf);
  2104. #endif
  2105. if (ebpf_vfs_load_bpf(em)) {
  2106. goto endvfs;
  2107. }
  2108. int algorithms[NETDATA_KEY_PUBLISH_VFS_END] = {
  2109. NETDATA_EBPF_INCREMENTAL_IDX, NETDATA_EBPF_INCREMENTAL_IDX,NETDATA_EBPF_INCREMENTAL_IDX,
  2110. NETDATA_EBPF_INCREMENTAL_IDX, NETDATA_EBPF_INCREMENTAL_IDX,NETDATA_EBPF_INCREMENTAL_IDX
  2111. };
  2112. ebpf_global_labels(vfs_aggregated_data, vfs_publish_aggregated, vfs_dimension_names,
  2113. vfs_id_names, algorithms, NETDATA_KEY_PUBLISH_VFS_END);
  2114. pthread_mutex_lock(&lock);
  2115. ebpf_create_global_charts(em);
  2116. ebpf_update_stats(&plugin_statistics, em);
  2117. ebpf_update_kernel_memory_with_vector(&plugin_statistics, em->maps, EBPF_ACTION_STAT_ADD);
  2118. #ifdef NETDATA_DEV_MODE
  2119. if (ebpf_aral_vfs_pid)
  2120. vfs_disable_priority = ebpf_statistic_create_aral_chart(NETDATA_EBPF_VFS_ARAL_NAME, em);
  2121. #endif
  2122. pthread_mutex_unlock(&lock);
  2123. vfs_collector(em);
  2124. endvfs:
  2125. ebpf_update_disabled_plugin_stats(em);
  2126. netdata_thread_cleanup_pop(1);
  2127. return NULL;
  2128. }