proc_net_dev.c 75 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798
  1. // SPDX-License-Identifier: GPL-3.0-or-later
  2. #include "plugin_proc.h"
  3. #include "proc_net_dev_renames.h"
  4. #define PLUGIN_PROC_MODULE_NETDEV_NAME "/proc/net/dev"
  5. #define CONFIG_SECTION_PLUGIN_PROC_NETDEV "plugin:" PLUGIN_PROC_CONFIG_NAME ":" PLUGIN_PROC_MODULE_NETDEV_NAME
  6. #define RRDFUNCTIONS_NETDEV_HELP "View network interface statistics"
  7. #define STATE_LENGTH_MAX 32
  8. #define READ_RETRY_PERIOD 60 // seconds
  9. time_t double_linked_device_collect_delay_secs = 120;
  10. enum {
  11. NETDEV_DUPLEX_UNKNOWN,
  12. NETDEV_DUPLEX_HALF,
  13. NETDEV_DUPLEX_FULL
  14. };
  15. static const char *get_duplex_string(int duplex) {
  16. switch (duplex) {
  17. case NETDEV_DUPLEX_FULL:
  18. return "full";
  19. case NETDEV_DUPLEX_HALF:
  20. return "half";
  21. default:
  22. return "unknown";
  23. }
  24. }
  25. enum {
  26. NETDEV_OPERSTATE_UNKNOWN,
  27. NETDEV_OPERSTATE_NOTPRESENT,
  28. NETDEV_OPERSTATE_DOWN,
  29. NETDEV_OPERSTATE_LOWERLAYERDOWN,
  30. NETDEV_OPERSTATE_TESTING,
  31. NETDEV_OPERSTATE_DORMANT,
  32. NETDEV_OPERSTATE_UP
  33. };
  34. static inline int get_operstate(char *operstate) {
  35. // As defined in https://www.kernel.org/doc/Documentation/ABI/testing/sysfs-class-net
  36. if (!strcmp(operstate, "up"))
  37. return NETDEV_OPERSTATE_UP;
  38. if (!strcmp(operstate, "down"))
  39. return NETDEV_OPERSTATE_DOWN;
  40. if (!strcmp(operstate, "notpresent"))
  41. return NETDEV_OPERSTATE_NOTPRESENT;
  42. if (!strcmp(operstate, "lowerlayerdown"))
  43. return NETDEV_OPERSTATE_LOWERLAYERDOWN;
  44. if (!strcmp(operstate, "testing"))
  45. return NETDEV_OPERSTATE_TESTING;
  46. if (!strcmp(operstate, "dormant"))
  47. return NETDEV_OPERSTATE_DORMANT;
  48. return NETDEV_OPERSTATE_UNKNOWN;
  49. }
  50. static const char *get_operstate_string(int operstate) {
  51. switch (operstate) {
  52. case NETDEV_OPERSTATE_UP:
  53. return "up";
  54. case NETDEV_OPERSTATE_DOWN:
  55. return "down";
  56. case NETDEV_OPERSTATE_NOTPRESENT:
  57. return "notpresent";
  58. case NETDEV_OPERSTATE_LOWERLAYERDOWN:
  59. return "lowerlayerdown";
  60. case NETDEV_OPERSTATE_TESTING:
  61. return "testing";
  62. case NETDEV_OPERSTATE_DORMANT:
  63. return "dormant";
  64. default:
  65. return "unknown";
  66. }
  67. }
  68. // ----------------------------------------------------------------------------
  69. // netdev list
  70. static struct netdev {
  71. char *name;
  72. uint32_t hash;
  73. size_t len;
  74. // flags
  75. bool virtual;
  76. bool configured;
  77. int enabled;
  78. bool updated;
  79. bool function_ready;
  80. bool double_linked; // iflink != ifindex
  81. time_t discover_time;
  82. int carrier_file_exists;
  83. time_t carrier_file_lost_time;
  84. int duplex_file_exists;
  85. time_t duplex_file_lost_time;
  86. int speed_file_exists;
  87. time_t speed_file_lost_time;
  88. int do_bandwidth;
  89. int do_packets;
  90. int do_errors;
  91. int do_drops;
  92. int do_fifo;
  93. int do_compressed;
  94. int do_events;
  95. int do_speed;
  96. int do_duplex;
  97. int do_operstate;
  98. int do_carrier;
  99. int do_mtu;
  100. const char *chart_type_net_bytes;
  101. const char *chart_type_net_packets;
  102. const char *chart_type_net_errors;
  103. const char *chart_type_net_fifo;
  104. const char *chart_type_net_events;
  105. const char *chart_type_net_drops;
  106. const char *chart_type_net_compressed;
  107. const char *chart_type_net_speed;
  108. const char *chart_type_net_duplex;
  109. const char *chart_type_net_operstate;
  110. const char *chart_type_net_carrier;
  111. const char *chart_type_net_mtu;
  112. const char *chart_id_net_bytes;
  113. const char *chart_id_net_packets;
  114. const char *chart_id_net_errors;
  115. const char *chart_id_net_fifo;
  116. const char *chart_id_net_events;
  117. const char *chart_id_net_drops;
  118. const char *chart_id_net_compressed;
  119. const char *chart_id_net_speed;
  120. const char *chart_id_net_duplex;
  121. const char *chart_id_net_operstate;
  122. const char *chart_id_net_carrier;
  123. const char *chart_id_net_mtu;
  124. const char *chart_ctx_net_bytes;
  125. const char *chart_ctx_net_packets;
  126. const char *chart_ctx_net_errors;
  127. const char *chart_ctx_net_fifo;
  128. const char *chart_ctx_net_events;
  129. const char *chart_ctx_net_drops;
  130. const char *chart_ctx_net_compressed;
  131. const char *chart_ctx_net_speed;
  132. const char *chart_ctx_net_duplex;
  133. const char *chart_ctx_net_operstate;
  134. const char *chart_ctx_net_carrier;
  135. const char *chart_ctx_net_mtu;
  136. const char *chart_family;
  137. RRDLABELS *chart_labels;
  138. int flipped;
  139. unsigned long priority;
  140. // data collected
  141. kernel_uint_t rbytes;
  142. kernel_uint_t rpackets;
  143. kernel_uint_t rerrors;
  144. kernel_uint_t rdrops;
  145. kernel_uint_t rfifo;
  146. kernel_uint_t rframe;
  147. kernel_uint_t rcompressed;
  148. kernel_uint_t rmulticast;
  149. kernel_uint_t tbytes;
  150. kernel_uint_t tpackets;
  151. kernel_uint_t terrors;
  152. kernel_uint_t tdrops;
  153. kernel_uint_t tfifo;
  154. kernel_uint_t tcollisions;
  155. kernel_uint_t tcarrier;
  156. kernel_uint_t tcompressed;
  157. kernel_uint_t speed;
  158. kernel_uint_t duplex;
  159. kernel_uint_t operstate;
  160. unsigned long long carrier;
  161. unsigned long long mtu;
  162. // charts
  163. RRDSET *st_bandwidth;
  164. RRDSET *st_packets;
  165. RRDSET *st_errors;
  166. RRDSET *st_drops;
  167. RRDSET *st_fifo;
  168. RRDSET *st_compressed;
  169. RRDSET *st_events;
  170. RRDSET *st_speed;
  171. RRDSET *st_duplex;
  172. RRDSET *st_operstate;
  173. RRDSET *st_carrier;
  174. RRDSET *st_mtu;
  175. // dimensions
  176. RRDDIM *rd_rbytes;
  177. RRDDIM *rd_rpackets;
  178. RRDDIM *rd_rerrors;
  179. RRDDIM *rd_rdrops;
  180. RRDDIM *rd_rfifo;
  181. RRDDIM *rd_rframe;
  182. RRDDIM *rd_rcompressed;
  183. RRDDIM *rd_rmulticast;
  184. RRDDIM *rd_tbytes;
  185. RRDDIM *rd_tpackets;
  186. RRDDIM *rd_terrors;
  187. RRDDIM *rd_tdrops;
  188. RRDDIM *rd_tfifo;
  189. RRDDIM *rd_tcollisions;
  190. RRDDIM *rd_tcarrier;
  191. RRDDIM *rd_tcompressed;
  192. RRDDIM *rd_speed;
  193. RRDDIM *rd_duplex_full;
  194. RRDDIM *rd_duplex_half;
  195. RRDDIM *rd_duplex_unknown;
  196. RRDDIM *rd_operstate_unknown;
  197. RRDDIM *rd_operstate_notpresent;
  198. RRDDIM *rd_operstate_down;
  199. RRDDIM *rd_operstate_lowerlayerdown;
  200. RRDDIM *rd_operstate_testing;
  201. RRDDIM *rd_operstate_dormant;
  202. RRDDIM *rd_operstate_up;
  203. RRDDIM *rd_carrier_up;
  204. RRDDIM *rd_carrier_down;
  205. RRDDIM *rd_mtu;
  206. char *filename_speed;
  207. const RRDSETVAR_ACQUIRED *chart_var_speed;
  208. char *filename_duplex;
  209. char *filename_operstate;
  210. char *filename_carrier;
  211. char *filename_mtu;
  212. const DICTIONARY_ITEM *cgroup_netdev_link;
  213. struct netdev *prev, *next;
  214. } *netdev_root = NULL;
  215. // ----------------------------------------------------------------------------
  216. static void netdev_charts_release(struct netdev *d) {
  217. if(d->st_bandwidth) rrdset_is_obsolete___safe_from_collector_thread(d->st_bandwidth);
  218. if(d->st_packets) rrdset_is_obsolete___safe_from_collector_thread(d->st_packets);
  219. if(d->st_errors) rrdset_is_obsolete___safe_from_collector_thread(d->st_errors);
  220. if(d->st_drops) rrdset_is_obsolete___safe_from_collector_thread(d->st_drops);
  221. if(d->st_fifo) rrdset_is_obsolete___safe_from_collector_thread(d->st_fifo);
  222. if(d->st_compressed) rrdset_is_obsolete___safe_from_collector_thread(d->st_compressed);
  223. if(d->st_events) rrdset_is_obsolete___safe_from_collector_thread(d->st_events);
  224. if(d->st_speed) rrdset_is_obsolete___safe_from_collector_thread(d->st_speed);
  225. if(d->st_duplex) rrdset_is_obsolete___safe_from_collector_thread(d->st_duplex);
  226. if(d->st_operstate) rrdset_is_obsolete___safe_from_collector_thread(d->st_operstate);
  227. if(d->st_carrier) rrdset_is_obsolete___safe_from_collector_thread(d->st_carrier);
  228. if(d->st_mtu) rrdset_is_obsolete___safe_from_collector_thread(d->st_mtu);
  229. d->st_bandwidth = NULL;
  230. d->st_compressed = NULL;
  231. d->st_drops = NULL;
  232. d->st_errors = NULL;
  233. d->st_events = NULL;
  234. d->st_fifo = NULL;
  235. d->st_packets = NULL;
  236. d->st_speed = NULL;
  237. d->st_duplex = NULL;
  238. d->st_operstate = NULL;
  239. d->st_carrier = NULL;
  240. d->st_mtu = NULL;
  241. d->rd_rbytes = NULL;
  242. d->rd_rpackets = NULL;
  243. d->rd_rerrors = NULL;
  244. d->rd_rdrops = NULL;
  245. d->rd_rfifo = NULL;
  246. d->rd_rframe = NULL;
  247. d->rd_rcompressed = NULL;
  248. d->rd_rmulticast = NULL;
  249. d->rd_tbytes = NULL;
  250. d->rd_tpackets = NULL;
  251. d->rd_terrors = NULL;
  252. d->rd_tdrops = NULL;
  253. d->rd_tfifo = NULL;
  254. d->rd_tcollisions = NULL;
  255. d->rd_tcarrier = NULL;
  256. d->rd_tcompressed = NULL;
  257. d->rd_speed = NULL;
  258. d->rd_duplex_full = NULL;
  259. d->rd_duplex_half = NULL;
  260. d->rd_duplex_unknown = NULL;
  261. d->rd_carrier_up = NULL;
  262. d->rd_carrier_down = NULL;
  263. d->rd_mtu = NULL;
  264. d->rd_operstate_unknown = NULL;
  265. d->rd_operstate_notpresent = NULL;
  266. d->rd_operstate_down = NULL;
  267. d->rd_operstate_lowerlayerdown = NULL;
  268. d->rd_operstate_testing = NULL;
  269. d->rd_operstate_dormant = NULL;
  270. d->rd_operstate_up = NULL;
  271. d->chart_var_speed = NULL;
  272. }
  273. static void netdev_free_chart_strings(struct netdev *d) {
  274. freez((void *)d->chart_type_net_bytes);
  275. freez((void *)d->chart_type_net_compressed);
  276. freez((void *)d->chart_type_net_drops);
  277. freez((void *)d->chart_type_net_errors);
  278. freez((void *)d->chart_type_net_events);
  279. freez((void *)d->chart_type_net_fifo);
  280. freez((void *)d->chart_type_net_packets);
  281. freez((void *)d->chart_type_net_speed);
  282. freez((void *)d->chart_type_net_duplex);
  283. freez((void *)d->chart_type_net_operstate);
  284. freez((void *)d->chart_type_net_carrier);
  285. freez((void *)d->chart_type_net_mtu);
  286. freez((void *)d->chart_id_net_bytes);
  287. freez((void *)d->chart_id_net_compressed);
  288. freez((void *)d->chart_id_net_drops);
  289. freez((void *)d->chart_id_net_errors);
  290. freez((void *)d->chart_id_net_events);
  291. freez((void *)d->chart_id_net_fifo);
  292. freez((void *)d->chart_id_net_packets);
  293. freez((void *)d->chart_id_net_speed);
  294. freez((void *)d->chart_id_net_duplex);
  295. freez((void *)d->chart_id_net_operstate);
  296. freez((void *)d->chart_id_net_carrier);
  297. freez((void *)d->chart_id_net_mtu);
  298. freez((void *)d->chart_ctx_net_bytes);
  299. freez((void *)d->chart_ctx_net_compressed);
  300. freez((void *)d->chart_ctx_net_drops);
  301. freez((void *)d->chart_ctx_net_errors);
  302. freez((void *)d->chart_ctx_net_events);
  303. freez((void *)d->chart_ctx_net_fifo);
  304. freez((void *)d->chart_ctx_net_packets);
  305. freez((void *)d->chart_ctx_net_speed);
  306. freez((void *)d->chart_ctx_net_duplex);
  307. freez((void *)d->chart_ctx_net_operstate);
  308. freez((void *)d->chart_ctx_net_carrier);
  309. freez((void *)d->chart_ctx_net_mtu);
  310. freez((void *)d->chart_family);
  311. }
  312. static void netdev_free(struct netdev *d) {
  313. netdev_charts_release(d);
  314. netdev_free_chart_strings(d);
  315. rrdlabels_destroy(d->chart_labels);
  316. cgroup_netdev_release(d->cgroup_netdev_link);
  317. freez((void *)d->name);
  318. freez((void *)d->filename_speed);
  319. freez((void *)d->filename_duplex);
  320. freez((void *)d->filename_operstate);
  321. freez((void *)d->filename_carrier);
  322. freez((void *)d->filename_mtu);
  323. freez((void *)d);
  324. }
  325. static netdata_mutex_t netdev_mutex = NETDATA_MUTEX_INITIALIZER;
  326. // ----------------------------------------------------------------------------
  327. static inline void netdev_rename(struct netdev *d, struct rename_task *r) {
  328. collector_info("CGROUP: renaming network interface '%s' as '%s' under '%s'", d->name, r->container_device, r->container_name);
  329. netdev_charts_release(d);
  330. netdev_free_chart_strings(d);
  331. cgroup_netdev_release(d->cgroup_netdev_link);
  332. d->cgroup_netdev_link = cgroup_netdev_dup(r->cgroup_netdev_link);
  333. d->discover_time = 0;
  334. char buffer[RRD_ID_LENGTH_MAX + 1];
  335. snprintfz(buffer, RRD_ID_LENGTH_MAX, "cgroup_%s", r->container_name);
  336. d->chart_type_net_bytes = strdupz(buffer);
  337. d->chart_type_net_compressed = strdupz(buffer);
  338. d->chart_type_net_drops = strdupz(buffer);
  339. d->chart_type_net_errors = strdupz(buffer);
  340. d->chart_type_net_events = strdupz(buffer);
  341. d->chart_type_net_fifo = strdupz(buffer);
  342. d->chart_type_net_packets = strdupz(buffer);
  343. d->chart_type_net_speed = strdupz(buffer);
  344. d->chart_type_net_duplex = strdupz(buffer);
  345. d->chart_type_net_operstate = strdupz(buffer);
  346. d->chart_type_net_carrier = strdupz(buffer);
  347. d->chart_type_net_mtu = strdupz(buffer);
  348. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_%s", r->container_device);
  349. d->chart_id_net_bytes = strdupz(buffer);
  350. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_compressed_%s", r->container_device);
  351. d->chart_id_net_compressed = strdupz(buffer);
  352. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_drops_%s", r->container_device);
  353. d->chart_id_net_drops = strdupz(buffer);
  354. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_errors_%s", r->container_device);
  355. d->chart_id_net_errors = strdupz(buffer);
  356. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_events_%s", r->container_device);
  357. d->chart_id_net_events = strdupz(buffer);
  358. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_fifo_%s", r->container_device);
  359. d->chart_id_net_fifo = strdupz(buffer);
  360. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_packets_%s", r->container_device);
  361. d->chart_id_net_packets = strdupz(buffer);
  362. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_speed_%s", r->container_device);
  363. d->chart_id_net_speed = strdupz(buffer);
  364. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_duplex_%s", r->container_device);
  365. d->chart_id_net_duplex = strdupz(buffer);
  366. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_operstate_%s", r->container_device);
  367. d->chart_id_net_operstate = strdupz(buffer);
  368. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_carrier_%s", r->container_device);
  369. d->chart_id_net_carrier = strdupz(buffer);
  370. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_mtu_%s", r->container_device);
  371. d->chart_id_net_mtu = strdupz(buffer);
  372. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_net", r->ctx_prefix);
  373. d->chart_ctx_net_bytes = strdupz(buffer);
  374. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_compressed", r->ctx_prefix);
  375. d->chart_ctx_net_compressed = strdupz(buffer);
  376. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_drops", r->ctx_prefix);
  377. d->chart_ctx_net_drops = strdupz(buffer);
  378. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_errors", r->ctx_prefix);
  379. d->chart_ctx_net_errors = strdupz(buffer);
  380. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_events", r->ctx_prefix);
  381. d->chart_ctx_net_events = strdupz(buffer);
  382. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_fifo", r->ctx_prefix);
  383. d->chart_ctx_net_fifo = strdupz(buffer);
  384. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_packets", r->ctx_prefix);
  385. d->chart_ctx_net_packets = strdupz(buffer);
  386. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_speed", r->ctx_prefix);
  387. d->chart_ctx_net_speed = strdupz(buffer);
  388. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_duplex", r->ctx_prefix);
  389. d->chart_ctx_net_duplex = strdupz(buffer);
  390. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_operstate", r->ctx_prefix);
  391. d->chart_ctx_net_operstate = strdupz(buffer);
  392. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_carrier", r->ctx_prefix);
  393. d->chart_ctx_net_carrier = strdupz(buffer);
  394. snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_mtu", r->ctx_prefix);
  395. d->chart_ctx_net_mtu = strdupz(buffer);
  396. d->chart_family = strdupz("net");
  397. rrdlabels_copy(d->chart_labels, r->chart_labels);
  398. rrdlabels_add(d->chart_labels, "container_device", r->container_device, RRDLABEL_SRC_AUTO);
  399. d->priority = NETDATA_CHART_PRIO_CGROUP_NET_IFACE;
  400. d->flipped = 1;
  401. }
  402. static void netdev_rename_this_device(struct netdev *d) {
  403. const DICTIONARY_ITEM *item = dictionary_get_and_acquire_item(netdev_renames, d->name);
  404. if(item) {
  405. struct rename_task *r = dictionary_acquired_item_value(item);
  406. netdev_rename(d, r);
  407. dictionary_acquired_item_release(netdev_renames, item);
  408. }
  409. }
  410. // ----------------------------------------------------------------------------
  411. int netdev_function_net_interfaces(uuid_t *transaction __maybe_unused, BUFFER *wb,
  412. usec_t *stop_monotonic_ut __maybe_unused, const char *function __maybe_unused,
  413. void *collector_data __maybe_unused,
  414. rrd_function_result_callback_t result_cb, void *result_cb_data,
  415. rrd_function_progress_cb_t progress_cb __maybe_unused, void *progress_cb_data __maybe_unused,
  416. rrd_function_is_cancelled_cb_t is_cancelled_cb, void *is_cancelled_cb_data,
  417. rrd_function_register_canceller_cb_t register_canceller_cb __maybe_unused,
  418. void *register_canceller_cb_data __maybe_unused,
  419. rrd_function_register_progresser_cb_t register_progresser_cb __maybe_unused,
  420. void *register_progresser_cb_data __maybe_unused) {
  421. buffer_flush(wb);
  422. wb->content_type = CT_APPLICATION_JSON;
  423. buffer_json_initialize(wb, "\"", "\"", 0, true, BUFFER_JSON_OPTIONS_DEFAULT);
  424. buffer_json_member_add_string(wb, "hostname", rrdhost_hostname(localhost));
  425. buffer_json_member_add_uint64(wb, "status", HTTP_RESP_OK);
  426. buffer_json_member_add_string(wb, "type", "table");
  427. buffer_json_member_add_time_t(wb, "update_every", 1);
  428. buffer_json_member_add_string(wb, "help", RRDFUNCTIONS_NETDEV_HELP);
  429. buffer_json_member_add_array(wb, "data");
  430. double max_traffic_rx = 0.0;
  431. double max_traffic_tx = 0.0;
  432. double max_traffic = 0.0;
  433. double max_packets_rx = 0.0;
  434. double max_packets_tx = 0.0;
  435. double max_mcast_rx = 0.0;
  436. double max_drops_rx = 0.0;
  437. double max_drops_tx = 0.0;
  438. netdata_mutex_lock(&netdev_mutex);
  439. RRDDIM *rd = NULL;
  440. for (struct netdev *d = netdev_root; d ; d = d->next) {
  441. if (unlikely(!d->function_ready))
  442. continue;
  443. buffer_json_add_array_item_array(wb);
  444. buffer_json_add_array_item_string(wb, d->name);
  445. buffer_json_add_array_item_string(wb, d->virtual ? "virtual" : "physical");
  446. buffer_json_add_array_item_string(wb, d->flipped ? "cgroup" : "host");
  447. buffer_json_add_array_item_string(wb, d->carrier == 1 ? "up" : "down");
  448. buffer_json_add_array_item_string(wb, get_operstate_string(d->operstate));
  449. buffer_json_add_array_item_string(wb, get_duplex_string(d->duplex));
  450. buffer_json_add_array_item_double(wb, d->speed > 0 ? d->speed : NAN);
  451. buffer_json_add_array_item_double(wb, d->mtu > 0 ? d->mtu : NAN);
  452. rd = d->flipped ? d->rd_tbytes : d->rd_rbytes;
  453. double traffic_rx = rrddim_get_last_stored_value(rd, &max_traffic_rx, 1000.0);
  454. rd = d->flipped ? d->rd_rbytes : d->rd_tbytes;
  455. double traffic_tx = rrddim_get_last_stored_value(rd, &max_traffic_tx, 1000.0);
  456. rd = d->flipped ? d->rd_tpackets : d->rd_rpackets;
  457. double packets_rx = rrddim_get_last_stored_value(rd, &max_packets_rx, 1000.0);
  458. rd = d->flipped ? d->rd_rpackets : d->rd_tpackets;
  459. double packets_tx = rrddim_get_last_stored_value(rd, &max_packets_tx, 1000.0);
  460. double mcast_rx = rrddim_get_last_stored_value(d->rd_rmulticast, &max_mcast_rx, 1000.0);
  461. rd = d->flipped ? d->rd_tdrops : d->rd_rdrops;
  462. double drops_rx = rrddim_get_last_stored_value(rd, &max_drops_rx, 1.0);
  463. rd = d->flipped ? d->rd_rdrops : d->rd_tdrops;
  464. double drops_tx = rrddim_get_last_stored_value(rd, &max_drops_tx, 1.0);
  465. // FIXME: "traffic" (total) is needed only for default_sorting
  466. // can be removed when default_sorting will accept multiple columns (sum)
  467. double traffic = NAN;
  468. if (!isnan(traffic_rx) && !isnan(traffic_tx)) {
  469. traffic = traffic_rx + traffic_tx;
  470. max_traffic = MAX(max_traffic, traffic);
  471. }
  472. buffer_json_add_array_item_double(wb, traffic_rx);
  473. buffer_json_add_array_item_double(wb, traffic_tx);
  474. buffer_json_add_array_item_double(wb, traffic);
  475. buffer_json_add_array_item_double(wb, packets_rx);
  476. buffer_json_add_array_item_double(wb, packets_tx);
  477. buffer_json_add_array_item_double(wb, mcast_rx);
  478. buffer_json_add_array_item_double(wb, drops_rx);
  479. buffer_json_add_array_item_double(wb, drops_tx);
  480. buffer_json_add_array_item_object(wb);
  481. {
  482. buffer_json_member_add_string(wb, "severity", drops_rx + drops_tx > 0 ? "warning" : "normal");
  483. }
  484. buffer_json_object_close(wb);
  485. buffer_json_array_close(wb);
  486. }
  487. netdata_mutex_unlock(&netdev_mutex);
  488. buffer_json_array_close(wb); // data
  489. buffer_json_member_add_object(wb, "columns");
  490. {
  491. size_t field_id = 0;
  492. buffer_rrdf_table_add_field(wb, field_id++, "Interface", "Network Interface Name",
  493. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  494. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  495. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  496. RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY | RRDF_FIELD_OPTS_STICKY,
  497. NULL);
  498. buffer_rrdf_table_add_field(wb, field_id++, "Type", "Network Interface Type",
  499. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  500. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  501. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  502. RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
  503. NULL);
  504. buffer_rrdf_table_add_field(wb, field_id++, "UsedBy", "Indicates whether the network interface is used by a cgroup or by the host system",
  505. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  506. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  507. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  508. RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
  509. NULL);
  510. buffer_rrdf_table_add_field(wb, field_id++, "PhState", "Current Physical State",
  511. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  512. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  513. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  514. RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
  515. NULL);
  516. buffer_rrdf_table_add_field(wb, field_id++, "OpState", "Current Operational State",
  517. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  518. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  519. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  520. RRDF_FIELD_OPTS_UNIQUE_KEY,
  521. NULL);
  522. buffer_rrdf_table_add_field(wb, field_id++, "Duplex", "Current Duplex Mode",
  523. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  524. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  525. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  526. RRDF_FIELD_OPTS_UNIQUE_KEY,
  527. NULL);
  528. buffer_rrdf_table_add_field(wb, field_id++, "Speed", "Current Link Speed",
  529. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
  530. 0, "Mbit", NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
  531. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  532. RRDF_FIELD_OPTS_UNIQUE_KEY,
  533. NULL);
  534. buffer_rrdf_table_add_field(wb, field_id++, "MTU", "Maximum Transmission Unit",
  535. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
  536. 0, "Octets", NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
  537. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  538. RRDF_FIELD_OPTS_UNIQUE_KEY,
  539. NULL);
  540. buffer_rrdf_table_add_field(wb, field_id++, "In", "Traffic Received",
  541. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  542. 2, "Mbit", max_traffic_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
  543. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  544. RRDF_FIELD_OPTS_VISIBLE,
  545. NULL);
  546. buffer_rrdf_table_add_field(wb, field_id++, "Out", "Traffic Sent",
  547. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  548. 2, "Mbit", max_traffic_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
  549. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  550. RRDF_FIELD_OPTS_VISIBLE,
  551. NULL);
  552. buffer_rrdf_table_add_field(wb, field_id++, "Total", "Traffic Received and Sent",
  553. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  554. 2, "Mbit", max_traffic, RRDF_FIELD_SORT_DESCENDING, NULL,
  555. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  556. RRDF_FIELD_OPTS_NONE,
  557. NULL);
  558. buffer_rrdf_table_add_field(wb, field_id++, "PktsIn", "Received Packets",
  559. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  560. 2, "Kpps", max_packets_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
  561. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  562. RRDF_FIELD_OPTS_VISIBLE,
  563. NULL);
  564. buffer_rrdf_table_add_field(wb, field_id++, "PktsOut", "Sent Packets",
  565. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  566. 2, "Kpps", max_packets_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
  567. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  568. RRDF_FIELD_OPTS_VISIBLE,
  569. NULL);
  570. buffer_rrdf_table_add_field(wb, field_id++, "McastIn", "Multicast Received Packets",
  571. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  572. 2, "Kpps", max_mcast_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
  573. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  574. RRDF_FIELD_OPTS_NONE,
  575. NULL);
  576. buffer_rrdf_table_add_field(wb, field_id++, "DropsIn", "Dropped Inbound Packets",
  577. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  578. 2, "Drops", max_drops_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
  579. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  580. RRDF_FIELD_OPTS_VISIBLE,
  581. NULL);
  582. buffer_rrdf_table_add_field(wb, field_id++, "DropsOut", "Dropped Outbound Packets",
  583. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  584. 2, "Drops", max_drops_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
  585. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  586. RRDF_FIELD_OPTS_VISIBLE,
  587. NULL);
  588. buffer_rrdf_table_add_field(
  589. wb, field_id++,
  590. "rowOptions", "rowOptions",
  591. RRDF_FIELD_TYPE_NONE,
  592. RRDR_FIELD_VISUAL_ROW_OPTIONS,
  593. RRDF_FIELD_TRANSFORM_NONE, 0, NULL, NAN,
  594. RRDF_FIELD_SORT_FIXED,
  595. NULL,
  596. RRDF_FIELD_SUMMARY_COUNT,
  597. RRDF_FIELD_FILTER_NONE,
  598. RRDF_FIELD_OPTS_DUMMY,
  599. NULL);
  600. }
  601. buffer_json_object_close(wb); // columns
  602. buffer_json_member_add_string(wb, "default_sort_column", "Total");
  603. buffer_json_member_add_object(wb, "charts");
  604. {
  605. buffer_json_member_add_object(wb, "Traffic");
  606. {
  607. buffer_json_member_add_string(wb, "name", "Traffic");
  608. buffer_json_member_add_string(wb, "type", "stacked-bar");
  609. buffer_json_member_add_array(wb, "columns");
  610. {
  611. buffer_json_add_array_item_string(wb, "In");
  612. buffer_json_add_array_item_string(wb, "Out");
  613. }
  614. buffer_json_array_close(wb);
  615. }
  616. buffer_json_object_close(wb);
  617. buffer_json_member_add_object(wb, "Packets");
  618. {
  619. buffer_json_member_add_string(wb, "name", "Packets");
  620. buffer_json_member_add_string(wb, "type", "stacked-bar");
  621. buffer_json_member_add_array(wb, "columns");
  622. {
  623. buffer_json_add_array_item_string(wb, "PktsIn");
  624. buffer_json_add_array_item_string(wb, "PktsOut");
  625. }
  626. buffer_json_array_close(wb);
  627. }
  628. buffer_json_object_close(wb);
  629. }
  630. buffer_json_object_close(wb); // charts
  631. buffer_json_member_add_array(wb, "default_charts");
  632. {
  633. buffer_json_add_array_item_array(wb);
  634. buffer_json_add_array_item_string(wb, "Traffic");
  635. buffer_json_add_array_item_string(wb, "Interface");
  636. buffer_json_array_close(wb);
  637. buffer_json_add_array_item_array(wb);
  638. buffer_json_add_array_item_string(wb, "Traffic");
  639. buffer_json_add_array_item_string(wb, "Type");
  640. buffer_json_array_close(wb);
  641. }
  642. buffer_json_array_close(wb);
  643. buffer_json_member_add_object(wb, "group_by");
  644. {
  645. buffer_json_member_add_object(wb, "Type");
  646. {
  647. buffer_json_member_add_string(wb, "name", "Type");
  648. buffer_json_member_add_array(wb, "columns");
  649. {
  650. buffer_json_add_array_item_string(wb, "Type");
  651. }
  652. buffer_json_array_close(wb);
  653. }
  654. buffer_json_object_close(wb);
  655. buffer_json_member_add_object(wb, "UsedBy");
  656. {
  657. buffer_json_member_add_string(wb, "name", "UsedBy");
  658. buffer_json_member_add_array(wb, "columns");
  659. {
  660. buffer_json_add_array_item_string(wb, "UsedBy");
  661. }
  662. buffer_json_array_close(wb);
  663. }
  664. buffer_json_object_close(wb);
  665. }
  666. buffer_json_object_close(wb); // group_by
  667. buffer_json_member_add_time_t(wb, "expires", now_realtime_sec() + 1);
  668. buffer_json_finalize(wb);
  669. return HTTP_RESP_OK;
  670. }
  671. // netdev data collection
  672. static void netdev_cleanup() {
  673. struct netdev *d = netdev_root;
  674. while(d) {
  675. if(unlikely(!d->updated)) {
  676. struct netdev *next = d->next; // keep the next, to continue;
  677. DOUBLE_LINKED_LIST_REMOVE_ITEM_UNSAFE(netdev_root, d, prev, next);
  678. netdev_free(d);
  679. d = next;
  680. continue;
  681. }
  682. d->updated = false;
  683. d = d->next;
  684. }
  685. }
  686. static struct netdev *get_netdev(const char *name) {
  687. struct netdev *d;
  688. uint32_t hash = simple_hash(name);
  689. // search it, from the last position to the end
  690. for(d = netdev_root ; d ; d = d->next) {
  691. if(unlikely(hash == d->hash && !strcmp(name, d->name)))
  692. return d;
  693. }
  694. // create a new one
  695. d = callocz(1, sizeof(struct netdev));
  696. d->name = strdupz(name);
  697. d->hash = simple_hash(d->name);
  698. d->len = strlen(d->name);
  699. d->chart_labels = rrdlabels_create();
  700. d->function_ready = false;
  701. d->double_linked = false;
  702. d->chart_type_net_bytes = strdupz("net");
  703. d->chart_type_net_compressed = strdupz("net_compressed");
  704. d->chart_type_net_drops = strdupz("net_drops");
  705. d->chart_type_net_errors = strdupz("net_errors");
  706. d->chart_type_net_events = strdupz("net_events");
  707. d->chart_type_net_fifo = strdupz("net_fifo");
  708. d->chart_type_net_packets = strdupz("net_packets");
  709. d->chart_type_net_speed = strdupz("net_speed");
  710. d->chart_type_net_duplex = strdupz("net_duplex");
  711. d->chart_type_net_operstate = strdupz("net_operstate");
  712. d->chart_type_net_carrier = strdupz("net_carrier");
  713. d->chart_type_net_mtu = strdupz("net_mtu");
  714. d->chart_id_net_bytes = strdupz(d->name);
  715. d->chart_id_net_compressed = strdupz(d->name);
  716. d->chart_id_net_drops = strdupz(d->name);
  717. d->chart_id_net_errors = strdupz(d->name);
  718. d->chart_id_net_events = strdupz(d->name);
  719. d->chart_id_net_fifo = strdupz(d->name);
  720. d->chart_id_net_packets = strdupz(d->name);
  721. d->chart_id_net_speed = strdupz(d->name);
  722. d->chart_id_net_duplex = strdupz(d->name);
  723. d->chart_id_net_operstate = strdupz(d->name);
  724. d->chart_id_net_carrier = strdupz(d->name);
  725. d->chart_id_net_mtu = strdupz(d->name);
  726. d->chart_ctx_net_bytes = strdupz("net.net");
  727. d->chart_ctx_net_compressed = strdupz("net.compressed");
  728. d->chart_ctx_net_drops = strdupz("net.drops");
  729. d->chart_ctx_net_errors = strdupz("net.errors");
  730. d->chart_ctx_net_events = strdupz("net.events");
  731. d->chart_ctx_net_fifo = strdupz("net.fifo");
  732. d->chart_ctx_net_packets = strdupz("net.packets");
  733. d->chart_ctx_net_speed = strdupz("net.speed");
  734. d->chart_ctx_net_duplex = strdupz("net.duplex");
  735. d->chart_ctx_net_operstate = strdupz("net.operstate");
  736. d->chart_ctx_net_carrier = strdupz("net.carrier");
  737. d->chart_ctx_net_mtu = strdupz("net.mtu");
  738. d->chart_family = strdupz(d->name);
  739. d->priority = NETDATA_CHART_PRIO_FIRST_NET_IFACE;
  740. DOUBLE_LINKED_LIST_APPEND_ITEM_UNSAFE(netdev_root, d, prev, next);
  741. return d;
  742. }
  743. static bool is_iface_double_linked(struct netdev *d) {
  744. char filename[FILENAME_MAX + 1];
  745. unsigned long long iflink = 0;
  746. unsigned long long ifindex = 0;
  747. snprintfz(filename, FILENAME_MAX, "%s/sys/class/net/%s/iflink", netdata_configured_host_prefix, d->name);
  748. if (read_single_number_file(filename, &iflink))
  749. return false;
  750. snprintfz(filename, FILENAME_MAX, "%s/sys/class/net/%s/ifindex", netdata_configured_host_prefix, d->name);
  751. if (read_single_number_file(filename, &ifindex))
  752. return false;
  753. return iflink != ifindex;
  754. }
  755. int do_proc_net_dev(int update_every, usec_t dt) {
  756. (void)dt;
  757. static SIMPLE_PATTERN *disabled_list = NULL;
  758. static procfile *ff = NULL;
  759. static int enable_new_interfaces = -1;
  760. static int do_bandwidth = -1, do_packets = -1, do_errors = -1, do_drops = -1, do_fifo = -1, do_compressed = -1,
  761. do_events = -1, do_speed = -1, do_duplex = -1, do_operstate = -1, do_carrier = -1, do_mtu = -1;
  762. static char *path_to_sys_devices_virtual_net = NULL, *path_to_sys_class_net_speed = NULL,
  763. *proc_net_dev_filename = NULL;
  764. static char *path_to_sys_class_net_duplex = NULL;
  765. static char *path_to_sys_class_net_operstate = NULL;
  766. static char *path_to_sys_class_net_carrier = NULL;
  767. static char *path_to_sys_class_net_mtu = NULL;
  768. if(unlikely(enable_new_interfaces == -1)) {
  769. char filename[FILENAME_MAX + 1];
  770. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, (*netdata_configured_host_prefix)?"/proc/1/net/dev":"/proc/net/dev");
  771. proc_net_dev_filename = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "filename to monitor", filename);
  772. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/devices/virtual/net/%s");
  773. path_to_sys_devices_virtual_net = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get virtual interfaces", filename);
  774. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/speed");
  775. path_to_sys_class_net_speed = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device speed", filename);
  776. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/duplex");
  777. path_to_sys_class_net_duplex = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device duplex", filename);
  778. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/operstate");
  779. path_to_sys_class_net_operstate = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device operstate", filename);
  780. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/carrier");
  781. path_to_sys_class_net_carrier = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device carrier", filename);
  782. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/mtu");
  783. path_to_sys_class_net_mtu = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device mtu", filename);
  784. enable_new_interfaces = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "enable new interfaces detected at runtime", CONFIG_BOOLEAN_AUTO);
  785. do_bandwidth = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "bandwidth for all interfaces", CONFIG_BOOLEAN_AUTO);
  786. do_packets = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "packets for all interfaces", CONFIG_BOOLEAN_AUTO);
  787. do_errors = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "errors for all interfaces", CONFIG_BOOLEAN_AUTO);
  788. do_drops = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "drops for all interfaces", CONFIG_BOOLEAN_AUTO);
  789. do_fifo = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "fifo for all interfaces", CONFIG_BOOLEAN_AUTO);
  790. do_compressed = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "compressed packets for all interfaces", CONFIG_BOOLEAN_AUTO);
  791. do_events = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "frames, collisions, carrier counters for all interfaces", CONFIG_BOOLEAN_AUTO);
  792. do_speed = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "speed for all interfaces", CONFIG_BOOLEAN_AUTO);
  793. do_duplex = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "duplex for all interfaces", CONFIG_BOOLEAN_AUTO);
  794. do_operstate = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "operstate for all interfaces", CONFIG_BOOLEAN_AUTO);
  795. do_carrier = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "carrier for all interfaces", CONFIG_BOOLEAN_AUTO);
  796. do_mtu = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "mtu for all interfaces", CONFIG_BOOLEAN_AUTO);
  797. disabled_list = simple_pattern_create(
  798. config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "disable by default interfaces matching",
  799. "lo fireqos* *-ifb fwpr* fwbr* fwln*"), NULL, SIMPLE_PATTERN_EXACT, true);
  800. netdev_renames_init();
  801. }
  802. if(unlikely(!ff)) {
  803. ff = procfile_open(proc_net_dev_filename, " \t,|", PROCFILE_FLAG_DEFAULT);
  804. if(unlikely(!ff)) return 1;
  805. }
  806. ff = procfile_readall(ff);
  807. if(unlikely(!ff)) return 0; // we return 0, so that we will retry to open it next time
  808. kernel_uint_t system_rbytes = 0;
  809. kernel_uint_t system_tbytes = 0;
  810. time_t now = now_realtime_sec();
  811. size_t lines = procfile_lines(ff), l;
  812. for(l = 2; l < lines ;l++) {
  813. // require 17 words on each line
  814. if(unlikely(procfile_linewords(ff, l) < 17)) continue;
  815. char *name = procfile_lineword(ff, l, 0);
  816. size_t len = strlen(name);
  817. if(name[len - 1] == ':') name[len - 1] = '\0';
  818. struct netdev *d = get_netdev(name);
  819. d->updated = true;
  820. if(unlikely(!d->configured)) {
  821. // the first time we see this interface
  822. // remember we configured it
  823. d->configured = true;
  824. d->discover_time = now;
  825. d->enabled = enable_new_interfaces;
  826. if(d->enabled)
  827. d->enabled = !simple_pattern_matches(disabled_list, d->name);
  828. char buf[FILENAME_MAX + 1];
  829. snprintfz(buf, FILENAME_MAX, path_to_sys_devices_virtual_net, d->name);
  830. d->virtual = likely(access(buf, R_OK) == 0) ? true : false;
  831. // At least on Proxmox inside LXC: eth0 is virtual.
  832. // Virtual interfaces are not taken into account in system.net calculations
  833. if (inside_lxc_container && d->virtual && strncmp(d->name, "eth", 3) == 0)
  834. d->virtual = false;
  835. if (d->virtual)
  836. rrdlabels_add(d->chart_labels, "interface_type", "virtual", RRDLABEL_SRC_AUTO);
  837. else
  838. rrdlabels_add(d->chart_labels, "interface_type", "real", RRDLABEL_SRC_AUTO);
  839. rrdlabels_add(d->chart_labels, "device", name, RRDLABEL_SRC_AUTO);
  840. if(likely(!d->virtual)) {
  841. // set the filename to get the interface speed
  842. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_speed, d->name);
  843. d->filename_speed = strdupz(buf);
  844. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_duplex, d->name);
  845. d->filename_duplex = strdupz(buf);
  846. }
  847. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_operstate, d->name);
  848. d->filename_operstate = strdupz(buf);
  849. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_carrier, d->name);
  850. d->filename_carrier = strdupz(buf);
  851. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_mtu, d->name);
  852. d->filename_mtu = strdupz(buf);
  853. snprintfz(buf, FILENAME_MAX, "plugin:proc:/proc/net/dev:%s", d->name);
  854. if (config_exists(buf, "enabled"))
  855. d->enabled = config_get_boolean_ondemand(buf, "enabled", d->enabled);
  856. if (config_exists(buf, "virtual"))
  857. d->virtual = config_get_boolean(buf, "virtual", d->virtual);
  858. if(d->enabled == CONFIG_BOOLEAN_NO)
  859. continue;
  860. d->double_linked = is_iface_double_linked(d);
  861. d->do_bandwidth = do_bandwidth;
  862. d->do_packets = do_packets;
  863. d->do_errors = do_errors;
  864. d->do_drops = do_drops;
  865. d->do_fifo = do_fifo;
  866. d->do_compressed = do_compressed;
  867. d->do_events = do_events;
  868. d->do_speed = do_speed;
  869. d->do_duplex = do_duplex;
  870. d->do_operstate = do_operstate;
  871. d->do_carrier = do_carrier;
  872. d->do_mtu = do_mtu;
  873. if (config_exists(buf, "bandwidth"))
  874. d->do_bandwidth = config_get_boolean_ondemand(buf, "bandwidth", do_bandwidth);
  875. if (config_exists(buf, "packets"))
  876. d->do_packets = config_get_boolean_ondemand(buf, "packets", do_packets);
  877. if (config_exists(buf, "errors"))
  878. d->do_errors = config_get_boolean_ondemand(buf, "errors", do_errors);
  879. if (config_exists(buf, "drops"))
  880. d->do_drops = config_get_boolean_ondemand(buf, "drops", do_drops);
  881. if (config_exists(buf, "fifo"))
  882. d->do_fifo = config_get_boolean_ondemand(buf, "fifo", do_fifo);
  883. if (config_exists(buf, "compressed"))
  884. d->do_compressed = config_get_boolean_ondemand(buf, "compressed", do_compressed);
  885. if (config_exists(buf, "events"))
  886. d->do_events = config_get_boolean_ondemand(buf, "events", do_events);
  887. if (config_exists(buf, "speed"))
  888. d->do_speed = config_get_boolean_ondemand(buf, "speed", do_speed);
  889. if (config_exists(buf, "duplex"))
  890. d->do_duplex = config_get_boolean_ondemand(buf, "duplex", do_duplex);
  891. if (config_exists(buf, "operstate"))
  892. d->do_operstate = config_get_boolean_ondemand(buf, "operstate", do_operstate);
  893. if (config_exists(buf, "carrier"))
  894. d->do_carrier = config_get_boolean_ondemand(buf, "carrier", do_carrier);
  895. if (config_exists(buf, "mtu"))
  896. d->do_mtu = config_get_boolean_ondemand(buf, "mtu", do_mtu);
  897. }
  898. if(unlikely(!d->enabled))
  899. continue;
  900. if(!d->cgroup_netdev_link)
  901. netdev_rename_this_device(d);
  902. // See https://github.com/netdata/netdata/issues/15206
  903. // This is necessary to prevent the creation of charts for virtual interfaces that will later be
  904. // recreated as container interfaces (create container) or
  905. // rediscovered and recreated only to be deleted almost immediately (stop/remove container)
  906. if (d->double_linked && d->virtual && (now - d->discover_time < double_linked_device_collect_delay_secs))
  907. continue;
  908. if(likely(d->do_bandwidth != CONFIG_BOOLEAN_NO || !d->virtual)) {
  909. d->rbytes = str2kernel_uint_t(procfile_lineword(ff, l, 1));
  910. d->tbytes = str2kernel_uint_t(procfile_lineword(ff, l, 9));
  911. if(likely(!d->virtual)) {
  912. system_rbytes += d->rbytes;
  913. system_tbytes += d->tbytes;
  914. }
  915. }
  916. if(likely(d->do_packets != CONFIG_BOOLEAN_NO)) {
  917. d->rpackets = str2kernel_uint_t(procfile_lineword(ff, l, 2));
  918. d->rmulticast = str2kernel_uint_t(procfile_lineword(ff, l, 8));
  919. d->tpackets = str2kernel_uint_t(procfile_lineword(ff, l, 10));
  920. }
  921. if(likely(d->do_errors != CONFIG_BOOLEAN_NO)) {
  922. d->rerrors = str2kernel_uint_t(procfile_lineword(ff, l, 3));
  923. d->terrors = str2kernel_uint_t(procfile_lineword(ff, l, 11));
  924. }
  925. if(likely(d->do_drops != CONFIG_BOOLEAN_NO)) {
  926. d->rdrops = str2kernel_uint_t(procfile_lineword(ff, l, 4));
  927. d->tdrops = str2kernel_uint_t(procfile_lineword(ff, l, 12));
  928. }
  929. if(likely(d->do_fifo != CONFIG_BOOLEAN_NO)) {
  930. d->rfifo = str2kernel_uint_t(procfile_lineword(ff, l, 5));
  931. d->tfifo = str2kernel_uint_t(procfile_lineword(ff, l, 13));
  932. }
  933. if(likely(d->do_compressed != CONFIG_BOOLEAN_NO)) {
  934. d->rcompressed = str2kernel_uint_t(procfile_lineword(ff, l, 7));
  935. d->tcompressed = str2kernel_uint_t(procfile_lineword(ff, l, 16));
  936. }
  937. if(likely(d->do_events != CONFIG_BOOLEAN_NO)) {
  938. d->rframe = str2kernel_uint_t(procfile_lineword(ff, l, 6));
  939. d->tcollisions = str2kernel_uint_t(procfile_lineword(ff, l, 14));
  940. d->tcarrier = str2kernel_uint_t(procfile_lineword(ff, l, 15));
  941. }
  942. if ((d->do_carrier != CONFIG_BOOLEAN_NO ||
  943. d->do_duplex != CONFIG_BOOLEAN_NO ||
  944. d->do_speed != CONFIG_BOOLEAN_NO) &&
  945. d->filename_carrier &&
  946. (d->carrier_file_exists ||
  947. now_monotonic_sec() - d->carrier_file_lost_time > READ_RETRY_PERIOD)) {
  948. if (read_single_number_file(d->filename_carrier, &d->carrier)) {
  949. if (d->carrier_file_exists)
  950. collector_error(
  951. "Cannot refresh interface %s carrier state by reading '%s'. Next update is in %d seconds.",
  952. d->name,
  953. d->filename_carrier,
  954. READ_RETRY_PERIOD);
  955. d->carrier_file_exists = 0;
  956. d->carrier_file_lost_time = now_monotonic_sec();
  957. } else {
  958. d->carrier_file_exists = 1;
  959. d->carrier_file_lost_time = 0;
  960. }
  961. }
  962. if (d->do_duplex != CONFIG_BOOLEAN_NO &&
  963. d->filename_duplex &&
  964. (d->carrier || d->carrier_file_exists) &&
  965. (d->duplex_file_exists ||
  966. now_monotonic_sec() - d->duplex_file_lost_time > READ_RETRY_PERIOD)) {
  967. char buffer[STATE_LENGTH_MAX + 1];
  968. if (read_file(d->filename_duplex, buffer, STATE_LENGTH_MAX)) {
  969. if (d->duplex_file_exists)
  970. collector_error("Cannot refresh interface %s duplex state by reading '%s'.", d->name, d->filename_duplex);
  971. d->duplex_file_exists = 0;
  972. d->duplex_file_lost_time = now_monotonic_sec();
  973. d->duplex = NETDEV_DUPLEX_UNKNOWN;
  974. } else {
  975. // values can be unknown, half or full -- just check the first letter for speed
  976. if (buffer[0] == 'f')
  977. d->duplex = NETDEV_DUPLEX_FULL;
  978. else if (buffer[0] == 'h')
  979. d->duplex = NETDEV_DUPLEX_HALF;
  980. else
  981. d->duplex = NETDEV_DUPLEX_UNKNOWN;
  982. d->duplex_file_exists = 1;
  983. d->duplex_file_lost_time = 0;
  984. }
  985. } else {
  986. d->duplex = NETDEV_DUPLEX_UNKNOWN;
  987. }
  988. if(d->do_operstate != CONFIG_BOOLEAN_NO && d->filename_operstate) {
  989. char buffer[STATE_LENGTH_MAX + 1], *trimmed_buffer;
  990. if (read_file(d->filename_operstate, buffer, STATE_LENGTH_MAX)) {
  991. collector_error(
  992. "Cannot refresh %s operstate by reading '%s'. Will not update its status anymore.",
  993. d->name, d->filename_operstate);
  994. freez(d->filename_operstate);
  995. d->filename_operstate = NULL;
  996. } else {
  997. trimmed_buffer = trim(buffer);
  998. d->operstate = get_operstate(trimmed_buffer);
  999. }
  1000. }
  1001. if (d->do_mtu != CONFIG_BOOLEAN_NO && d->filename_mtu) {
  1002. if (read_single_number_file(d->filename_mtu, &d->mtu)) {
  1003. collector_error(
  1004. "Cannot refresh mtu for interface %s by reading '%s'. Stop updating it.", d->name, d->filename_mtu);
  1005. freez(d->filename_mtu);
  1006. d->filename_mtu = NULL;
  1007. }
  1008. }
  1009. //collector_info("PROC_NET_DEV: %s speed %zu, bytes %zu/%zu, packets %zu/%zu/%zu, errors %zu/%zu, drops %zu/%zu, fifo %zu/%zu, compressed %zu/%zu, rframe %zu, tcollisions %zu, tcarrier %zu"
  1010. // , d->name, d->speed
  1011. // , d->rbytes, d->tbytes
  1012. // , d->rpackets, d->tpackets, d->rmulticast
  1013. // , d->rerrors, d->terrors
  1014. // , d->rdrops, d->tdrops
  1015. // , d->rfifo, d->tfifo
  1016. // , d->rcompressed, d->tcompressed
  1017. // , d->rframe, d->tcollisions, d->tcarrier
  1018. // );
  1019. if(unlikely(d->do_bandwidth == CONFIG_BOOLEAN_AUTO &&
  1020. (d->rbytes || d->tbytes || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1021. d->do_bandwidth = CONFIG_BOOLEAN_YES;
  1022. if(d->do_bandwidth == CONFIG_BOOLEAN_YES) {
  1023. if(unlikely(!d->st_bandwidth)) {
  1024. d->st_bandwidth = rrdset_create_localhost(
  1025. d->chart_type_net_bytes
  1026. , d->chart_id_net_bytes
  1027. , NULL
  1028. , d->chart_family
  1029. , d->chart_ctx_net_bytes
  1030. , "Bandwidth"
  1031. , "kilobits/s"
  1032. , PLUGIN_PROC_NAME
  1033. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1034. , d->priority
  1035. , update_every
  1036. , RRDSET_TYPE_AREA
  1037. );
  1038. rrdset_update_rrdlabels(d->st_bandwidth, d->chart_labels);
  1039. d->rd_rbytes = rrddim_add(d->st_bandwidth, "received", NULL, 8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1040. d->rd_tbytes = rrddim_add(d->st_bandwidth, "sent", NULL, -8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1041. if(d->flipped) {
  1042. // flip receive/transmit
  1043. RRDDIM *td = d->rd_rbytes;
  1044. d->rd_rbytes = d->rd_tbytes;
  1045. d->rd_tbytes = td;
  1046. }
  1047. }
  1048. rrddim_set_by_pointer(d->st_bandwidth, d->rd_rbytes, (collected_number)d->rbytes);
  1049. rrddim_set_by_pointer(d->st_bandwidth, d->rd_tbytes, (collected_number)d->tbytes);
  1050. rrdset_done(d->st_bandwidth);
  1051. if(d->cgroup_netdev_link)
  1052. cgroup_netdev_add_bandwidth(d->cgroup_netdev_link,
  1053. d->flipped ? d->rd_tbytes->collector.last_stored_value : -d->rd_rbytes->collector.last_stored_value,
  1054. d->flipped ? -d->rd_rbytes->collector.last_stored_value : d->rd_tbytes->collector.last_stored_value);
  1055. // update the interface speed
  1056. if(d->filename_speed) {
  1057. if(unlikely(!d->chart_var_speed)) {
  1058. d->chart_var_speed =
  1059. rrdsetvar_custom_chart_variable_add_and_acquire(d->st_bandwidth, "nic_speed_max");
  1060. if(!d->chart_var_speed) {
  1061. collector_error(
  1062. "Cannot create interface %s chart variable 'nic_speed_max'. Will not update its speed anymore.",
  1063. d->name);
  1064. freez(d->filename_speed);
  1065. d->filename_speed = NULL;
  1066. }
  1067. }
  1068. if (d->filename_speed && d->chart_var_speed) {
  1069. int ret = 0;
  1070. if ((d->carrier || d->carrier_file_exists) &&
  1071. (d->speed_file_exists || now_monotonic_sec() - d->speed_file_lost_time > READ_RETRY_PERIOD)) {
  1072. ret = read_single_number_file(d->filename_speed, (unsigned long long *) &d->speed);
  1073. } else {
  1074. d->speed = 0; // TODO: this is wrong, shouldn't use 0 value, but NULL.
  1075. }
  1076. if(ret) {
  1077. if (d->speed_file_exists)
  1078. collector_error("Cannot refresh interface %s speed by reading '%s'.", d->name, d->filename_speed);
  1079. d->speed_file_exists = 0;
  1080. d->speed_file_lost_time = now_monotonic_sec();
  1081. }
  1082. else {
  1083. if(d->do_speed != CONFIG_BOOLEAN_NO) {
  1084. if(unlikely(!d->st_speed)) {
  1085. d->st_speed = rrdset_create_localhost(
  1086. d->chart_type_net_speed
  1087. , d->chart_id_net_speed
  1088. , NULL
  1089. , d->chart_family
  1090. , d->chart_ctx_net_speed
  1091. , "Interface Speed"
  1092. , "kilobits/s"
  1093. , PLUGIN_PROC_NAME
  1094. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1095. , d->priority + 7
  1096. , update_every
  1097. , RRDSET_TYPE_LINE
  1098. );
  1099. rrdset_flag_set(d->st_speed, RRDSET_FLAG_DETAIL);
  1100. rrdset_update_rrdlabels(d->st_speed, d->chart_labels);
  1101. d->rd_speed = rrddim_add(d->st_speed, "speed", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1102. }
  1103. rrddim_set_by_pointer(d->st_speed, d->rd_speed, (collected_number)d->speed * KILOBITS_IN_A_MEGABIT);
  1104. rrdset_done(d->st_speed);
  1105. }
  1106. rrdsetvar_custom_chart_variable_set(
  1107. d->st_bandwidth, d->chart_var_speed, (NETDATA_DOUBLE)d->speed * KILOBITS_IN_A_MEGABIT);
  1108. if (d->speed) {
  1109. d->speed_file_exists = 1;
  1110. d->speed_file_lost_time = 0;
  1111. }
  1112. }
  1113. }
  1114. }
  1115. }
  1116. if(d->do_duplex != CONFIG_BOOLEAN_NO && d->filename_duplex) {
  1117. if(unlikely(!d->st_duplex)) {
  1118. d->st_duplex = rrdset_create_localhost(
  1119. d->chart_type_net_duplex
  1120. , d->chart_id_net_duplex
  1121. , NULL
  1122. , d->chart_family
  1123. , d->chart_ctx_net_duplex
  1124. , "Interface Duplex State"
  1125. , "state"
  1126. , PLUGIN_PROC_NAME
  1127. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1128. , d->priority + 8
  1129. , update_every
  1130. , RRDSET_TYPE_LINE
  1131. );
  1132. rrdset_flag_set(d->st_duplex, RRDSET_FLAG_DETAIL);
  1133. rrdset_update_rrdlabels(d->st_duplex, d->chart_labels);
  1134. d->rd_duplex_full = rrddim_add(d->st_duplex, "full", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1135. d->rd_duplex_half = rrddim_add(d->st_duplex, "half", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1136. d->rd_duplex_unknown = rrddim_add(d->st_duplex, "unknown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1137. }
  1138. rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_full, (collected_number)(d->duplex == NETDEV_DUPLEX_FULL));
  1139. rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_half, (collected_number)(d->duplex == NETDEV_DUPLEX_HALF));
  1140. rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_unknown, (collected_number)(d->duplex == NETDEV_DUPLEX_UNKNOWN));
  1141. rrdset_done(d->st_duplex);
  1142. }
  1143. if(d->do_operstate != CONFIG_BOOLEAN_NO && d->filename_operstate) {
  1144. if(unlikely(!d->st_operstate)) {
  1145. d->st_operstate = rrdset_create_localhost(
  1146. d->chart_type_net_operstate
  1147. , d->chart_id_net_operstate
  1148. , NULL
  1149. , d->chart_family
  1150. , d->chart_ctx_net_operstate
  1151. , "Interface Operational State"
  1152. , "state"
  1153. , PLUGIN_PROC_NAME
  1154. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1155. , d->priority + 9
  1156. , update_every
  1157. , RRDSET_TYPE_LINE
  1158. );
  1159. rrdset_flag_set(d->st_operstate, RRDSET_FLAG_DETAIL);
  1160. rrdset_update_rrdlabels(d->st_operstate, d->chart_labels);
  1161. d->rd_operstate_up = rrddim_add(d->st_operstate, "up", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1162. d->rd_operstate_down = rrddim_add(d->st_operstate, "down", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1163. d->rd_operstate_notpresent = rrddim_add(d->st_operstate, "notpresent", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1164. d->rd_operstate_lowerlayerdown = rrddim_add(d->st_operstate, "lowerlayerdown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1165. d->rd_operstate_testing = rrddim_add(d->st_operstate, "testing", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1166. d->rd_operstate_dormant = rrddim_add(d->st_operstate, "dormant", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1167. d->rd_operstate_unknown = rrddim_add(d->st_operstate, "unknown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1168. }
  1169. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_up, (collected_number)(d->operstate == NETDEV_OPERSTATE_UP));
  1170. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_down, (collected_number)(d->operstate == NETDEV_OPERSTATE_DOWN));
  1171. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_notpresent, (collected_number)(d->operstate == NETDEV_OPERSTATE_NOTPRESENT));
  1172. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_lowerlayerdown, (collected_number)(d->operstate == NETDEV_OPERSTATE_LOWERLAYERDOWN));
  1173. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_testing, (collected_number)(d->operstate == NETDEV_OPERSTATE_TESTING));
  1174. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_dormant, (collected_number)(d->operstate == NETDEV_OPERSTATE_DORMANT));
  1175. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_unknown, (collected_number)(d->operstate == NETDEV_OPERSTATE_UNKNOWN));
  1176. rrdset_done(d->st_operstate);
  1177. }
  1178. if(d->do_carrier != CONFIG_BOOLEAN_NO && d->carrier_file_exists) {
  1179. if(unlikely(!d->st_carrier)) {
  1180. d->st_carrier = rrdset_create_localhost(
  1181. d->chart_type_net_carrier
  1182. , d->chart_id_net_carrier
  1183. , NULL
  1184. , d->chart_family
  1185. , d->chart_ctx_net_carrier
  1186. , "Interface Physical Link State"
  1187. , "state"
  1188. , PLUGIN_PROC_NAME
  1189. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1190. , d->priority + 10
  1191. , update_every
  1192. , RRDSET_TYPE_LINE
  1193. );
  1194. rrdset_flag_set(d->st_carrier, RRDSET_FLAG_DETAIL);
  1195. rrdset_update_rrdlabels(d->st_carrier, d->chart_labels);
  1196. d->rd_carrier_up = rrddim_add(d->st_carrier, "up", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1197. d->rd_carrier_down = rrddim_add(d->st_carrier, "down", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1198. }
  1199. rrddim_set_by_pointer(d->st_carrier, d->rd_carrier_up, (collected_number)(d->carrier == 1));
  1200. rrddim_set_by_pointer(d->st_carrier, d->rd_carrier_down, (collected_number)(d->carrier != 1));
  1201. rrdset_done(d->st_carrier);
  1202. }
  1203. if(d->do_mtu != CONFIG_BOOLEAN_NO && d->filename_mtu) {
  1204. if(unlikely(!d->st_mtu)) {
  1205. d->st_mtu = rrdset_create_localhost(
  1206. d->chart_type_net_mtu
  1207. , d->chart_id_net_mtu
  1208. , NULL
  1209. , d->chart_family
  1210. , d->chart_ctx_net_mtu
  1211. , "Interface MTU"
  1212. , "octets"
  1213. , PLUGIN_PROC_NAME
  1214. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1215. , d->priority + 11
  1216. , update_every
  1217. , RRDSET_TYPE_LINE
  1218. );
  1219. rrdset_flag_set(d->st_mtu, RRDSET_FLAG_DETAIL);
  1220. rrdset_update_rrdlabels(d->st_mtu, d->chart_labels);
  1221. d->rd_mtu = rrddim_add(d->st_mtu, "mtu", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1222. }
  1223. rrddim_set_by_pointer(d->st_mtu, d->rd_mtu, (collected_number)d->mtu);
  1224. rrdset_done(d->st_mtu);
  1225. }
  1226. if(unlikely(d->do_packets == CONFIG_BOOLEAN_AUTO &&
  1227. (d->rpackets || d->tpackets || d->rmulticast || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1228. d->do_packets = CONFIG_BOOLEAN_YES;
  1229. if(d->do_packets == CONFIG_BOOLEAN_YES) {
  1230. if(unlikely(!d->st_packets)) {
  1231. d->st_packets = rrdset_create_localhost(
  1232. d->chart_type_net_packets
  1233. , d->chart_id_net_packets
  1234. , NULL
  1235. , d->chart_family
  1236. , d->chart_ctx_net_packets
  1237. , "Packets"
  1238. , "packets/s"
  1239. , PLUGIN_PROC_NAME
  1240. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1241. , d->priority + 1
  1242. , update_every
  1243. , RRDSET_TYPE_LINE
  1244. );
  1245. rrdset_flag_set(d->st_packets, RRDSET_FLAG_DETAIL);
  1246. rrdset_update_rrdlabels(d->st_packets, d->chart_labels);
  1247. d->rd_rpackets = rrddim_add(d->st_packets, "received", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1248. d->rd_tpackets = rrddim_add(d->st_packets, "sent", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1249. d->rd_rmulticast = rrddim_add(d->st_packets, "multicast", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1250. if(d->flipped) {
  1251. // flip receive/transmit
  1252. RRDDIM *td = d->rd_rpackets;
  1253. d->rd_rpackets = d->rd_tpackets;
  1254. d->rd_tpackets = td;
  1255. }
  1256. }
  1257. rrddim_set_by_pointer(d->st_packets, d->rd_rpackets, (collected_number)d->rpackets);
  1258. rrddim_set_by_pointer(d->st_packets, d->rd_tpackets, (collected_number)d->tpackets);
  1259. rrddim_set_by_pointer(d->st_packets, d->rd_rmulticast, (collected_number)d->rmulticast);
  1260. rrdset_done(d->st_packets);
  1261. }
  1262. if(unlikely(d->do_errors == CONFIG_BOOLEAN_AUTO &&
  1263. (d->rerrors || d->terrors || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1264. d->do_errors = CONFIG_BOOLEAN_YES;
  1265. if(d->do_errors == CONFIG_BOOLEAN_YES) {
  1266. if(unlikely(!d->st_errors)) {
  1267. d->st_errors = rrdset_create_localhost(
  1268. d->chart_type_net_errors
  1269. , d->chart_id_net_errors
  1270. , NULL
  1271. , d->chart_family
  1272. , d->chart_ctx_net_errors
  1273. , "Interface Errors"
  1274. , "errors/s"
  1275. , PLUGIN_PROC_NAME
  1276. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1277. , d->priority + 2
  1278. , update_every
  1279. , RRDSET_TYPE_LINE
  1280. );
  1281. rrdset_flag_set(d->st_errors, RRDSET_FLAG_DETAIL);
  1282. rrdset_update_rrdlabels(d->st_errors, d->chart_labels);
  1283. d->rd_rerrors = rrddim_add(d->st_errors, "inbound", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1284. d->rd_terrors = rrddim_add(d->st_errors, "outbound", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1285. if(d->flipped) {
  1286. // flip receive/transmit
  1287. RRDDIM *td = d->rd_rerrors;
  1288. d->rd_rerrors = d->rd_terrors;
  1289. d->rd_terrors = td;
  1290. }
  1291. }
  1292. rrddim_set_by_pointer(d->st_errors, d->rd_rerrors, (collected_number)d->rerrors);
  1293. rrddim_set_by_pointer(d->st_errors, d->rd_terrors, (collected_number)d->terrors);
  1294. rrdset_done(d->st_errors);
  1295. }
  1296. if(unlikely(d->do_drops == CONFIG_BOOLEAN_AUTO &&
  1297. (d->rdrops || d->tdrops || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1298. d->do_drops = CONFIG_BOOLEAN_YES;
  1299. if(d->do_drops == CONFIG_BOOLEAN_YES) {
  1300. if(unlikely(!d->st_drops)) {
  1301. d->st_drops = rrdset_create_localhost(
  1302. d->chart_type_net_drops
  1303. , d->chart_id_net_drops
  1304. , NULL
  1305. , d->chart_family
  1306. , d->chart_ctx_net_drops
  1307. , "Interface Drops"
  1308. , "drops/s"
  1309. , PLUGIN_PROC_NAME
  1310. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1311. , d->priority + 3
  1312. , update_every
  1313. , RRDSET_TYPE_LINE
  1314. );
  1315. rrdset_flag_set(d->st_drops, RRDSET_FLAG_DETAIL);
  1316. rrdset_update_rrdlabels(d->st_drops, d->chart_labels);
  1317. d->rd_rdrops = rrddim_add(d->st_drops, "inbound", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1318. d->rd_tdrops = rrddim_add(d->st_drops, "outbound", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1319. if(d->flipped) {
  1320. // flip receive/transmit
  1321. RRDDIM *td = d->rd_rdrops;
  1322. d->rd_rdrops = d->rd_tdrops;
  1323. d->rd_tdrops = td;
  1324. }
  1325. }
  1326. rrddim_set_by_pointer(d->st_drops, d->rd_rdrops, (collected_number)d->rdrops);
  1327. rrddim_set_by_pointer(d->st_drops, d->rd_tdrops, (collected_number)d->tdrops);
  1328. rrdset_done(d->st_drops);
  1329. }
  1330. if(unlikely(d->do_fifo == CONFIG_BOOLEAN_AUTO &&
  1331. (d->rfifo || d->tfifo || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1332. d->do_fifo = CONFIG_BOOLEAN_YES;
  1333. if(d->do_fifo == CONFIG_BOOLEAN_YES) {
  1334. if(unlikely(!d->st_fifo)) {
  1335. d->st_fifo = rrdset_create_localhost(
  1336. d->chart_type_net_fifo
  1337. , d->chart_id_net_fifo
  1338. , NULL
  1339. , d->chart_family
  1340. , d->chart_ctx_net_fifo
  1341. , "Interface FIFO Buffer Errors"
  1342. , "errors"
  1343. , PLUGIN_PROC_NAME
  1344. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1345. , d->priority + 4
  1346. , update_every
  1347. , RRDSET_TYPE_LINE
  1348. );
  1349. rrdset_flag_set(d->st_fifo, RRDSET_FLAG_DETAIL);
  1350. rrdset_update_rrdlabels(d->st_fifo, d->chart_labels);
  1351. d->rd_rfifo = rrddim_add(d->st_fifo, "receive", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1352. d->rd_tfifo = rrddim_add(d->st_fifo, "transmit", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1353. if(d->flipped) {
  1354. // flip receive/transmit
  1355. RRDDIM *td = d->rd_rfifo;
  1356. d->rd_rfifo = d->rd_tfifo;
  1357. d->rd_tfifo = td;
  1358. }
  1359. }
  1360. rrddim_set_by_pointer(d->st_fifo, d->rd_rfifo, (collected_number)d->rfifo);
  1361. rrddim_set_by_pointer(d->st_fifo, d->rd_tfifo, (collected_number)d->tfifo);
  1362. rrdset_done(d->st_fifo);
  1363. }
  1364. if(unlikely(d->do_compressed == CONFIG_BOOLEAN_AUTO &&
  1365. (d->rcompressed || d->tcompressed || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1366. d->do_compressed = CONFIG_BOOLEAN_YES;
  1367. if(d->do_compressed == CONFIG_BOOLEAN_YES) {
  1368. if(unlikely(!d->st_compressed)) {
  1369. d->st_compressed = rrdset_create_localhost(
  1370. d->chart_type_net_compressed
  1371. , d->chart_id_net_compressed
  1372. , NULL
  1373. , d->chart_family
  1374. , d->chart_ctx_net_compressed
  1375. , "Compressed Packets"
  1376. , "packets/s"
  1377. , PLUGIN_PROC_NAME
  1378. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1379. , d->priority + 5
  1380. , update_every
  1381. , RRDSET_TYPE_LINE
  1382. );
  1383. rrdset_flag_set(d->st_compressed, RRDSET_FLAG_DETAIL);
  1384. rrdset_update_rrdlabels(d->st_compressed, d->chart_labels);
  1385. d->rd_rcompressed = rrddim_add(d->st_compressed, "received", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1386. d->rd_tcompressed = rrddim_add(d->st_compressed, "sent", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1387. if(d->flipped) {
  1388. // flip receive/transmit
  1389. RRDDIM *td = d->rd_rcompressed;
  1390. d->rd_rcompressed = d->rd_tcompressed;
  1391. d->rd_tcompressed = td;
  1392. }
  1393. }
  1394. rrddim_set_by_pointer(d->st_compressed, d->rd_rcompressed, (collected_number)d->rcompressed);
  1395. rrddim_set_by_pointer(d->st_compressed, d->rd_tcompressed, (collected_number)d->tcompressed);
  1396. rrdset_done(d->st_compressed);
  1397. }
  1398. if(unlikely(d->do_events == CONFIG_BOOLEAN_AUTO &&
  1399. (d->rframe || d->tcollisions || d->tcarrier || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1400. d->do_events = CONFIG_BOOLEAN_YES;
  1401. if(d->do_events == CONFIG_BOOLEAN_YES) {
  1402. if(unlikely(!d->st_events)) {
  1403. d->st_events = rrdset_create_localhost(
  1404. d->chart_type_net_events
  1405. , d->chart_id_net_events
  1406. , NULL
  1407. , d->chart_family
  1408. , d->chart_ctx_net_events
  1409. , "Network Interface Events"
  1410. , "events/s"
  1411. , PLUGIN_PROC_NAME
  1412. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1413. , d->priority + 6
  1414. , update_every
  1415. , RRDSET_TYPE_LINE
  1416. );
  1417. rrdset_flag_set(d->st_events, RRDSET_FLAG_DETAIL);
  1418. rrdset_update_rrdlabels(d->st_events, d->chart_labels);
  1419. d->rd_rframe = rrddim_add(d->st_events, "frames", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1420. d->rd_tcollisions = rrddim_add(d->st_events, "collisions", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1421. d->rd_tcarrier = rrddim_add(d->st_events, "carrier", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1422. }
  1423. rrddim_set_by_pointer(d->st_events, d->rd_rframe, (collected_number)d->rframe);
  1424. rrddim_set_by_pointer(d->st_events, d->rd_tcollisions, (collected_number)d->tcollisions);
  1425. rrddim_set_by_pointer(d->st_events, d->rd_tcarrier, (collected_number)d->tcarrier);
  1426. rrdset_done(d->st_events);
  1427. }
  1428. d->function_ready = true;
  1429. }
  1430. if(do_bandwidth == CONFIG_BOOLEAN_YES || (do_bandwidth == CONFIG_BOOLEAN_AUTO &&
  1431. (system_rbytes || system_tbytes ||
  1432. netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
  1433. do_bandwidth = CONFIG_BOOLEAN_YES;
  1434. static RRDSET *st_system_net = NULL;
  1435. static RRDDIM *rd_in = NULL, *rd_out = NULL;
  1436. if(unlikely(!st_system_net)) {
  1437. st_system_net = rrdset_create_localhost(
  1438. "system"
  1439. , "net"
  1440. , NULL
  1441. , "network"
  1442. , NULL
  1443. , "Physical Network Interfaces Aggregated Bandwidth"
  1444. , "kilobits/s"
  1445. , PLUGIN_PROC_NAME
  1446. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1447. , NETDATA_CHART_PRIO_SYSTEM_NET
  1448. , update_every
  1449. , RRDSET_TYPE_AREA
  1450. );
  1451. rd_in = rrddim_add(st_system_net, "InOctets", "received", 8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1452. rd_out = rrddim_add(st_system_net, "OutOctets", "sent", -8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1453. }
  1454. rrddim_set_by_pointer(st_system_net, rd_in, (collected_number)system_rbytes);
  1455. rrddim_set_by_pointer(st_system_net, rd_out, (collected_number)system_tbytes);
  1456. rrdset_done(st_system_net);
  1457. }
  1458. netdev_cleanup();
  1459. return 0;
  1460. }
  1461. static void netdev_main_cleanup(void *ptr)
  1462. {
  1463. UNUSED(ptr);
  1464. collector_info("cleaning up...");
  1465. worker_unregister();
  1466. }
  1467. void *netdev_main(void *ptr)
  1468. {
  1469. worker_register("NETDEV");
  1470. worker_register_job_name(0, "netdev");
  1471. if (getenv("KUBERNETES_SERVICE_HOST") != NULL && getenv("KUBERNETES_SERVICE_PORT") != NULL) {
  1472. double_linked_device_collect_delay_secs = 300;
  1473. }
  1474. netdata_thread_cleanup_push(netdev_main_cleanup, ptr) {
  1475. rrd_collector_started();
  1476. rrd_function_add(localhost, NULL, "network-interfaces", 10, RRDFUNCTIONS_PRIORITY_DEFAULT, RRDFUNCTIONS_NETDEV_HELP,
  1477. "top", HTTP_ACCESS_ANY,
  1478. true, netdev_function_net_interfaces, NULL);
  1479. usec_t step = localhost->rrd_update_every * USEC_PER_SEC;
  1480. heartbeat_t hb;
  1481. heartbeat_init(&hb);
  1482. while (service_running(SERVICE_COLLECTORS)) {
  1483. worker_is_idle();
  1484. usec_t hb_dt = heartbeat_next(&hb, step);
  1485. if (unlikely(!service_running(SERVICE_COLLECTORS)))
  1486. break;
  1487. cgroup_netdev_reset_all();
  1488. worker_is_busy(0);
  1489. netdata_mutex_lock(&netdev_mutex);
  1490. if (do_proc_net_dev(localhost->rrd_update_every, hb_dt))
  1491. break;
  1492. netdata_mutex_unlock(&netdev_mutex);
  1493. }
  1494. }
  1495. netdata_thread_cleanup_pop(1);
  1496. return NULL;
  1497. }