proc_net_dev.c 74 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786
  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(BUFFER *wb, const char *function __maybe_unused) {
  412. buffer_flush(wb);
  413. wb->content_type = CT_APPLICATION_JSON;
  414. buffer_json_initialize(wb, "\"", "\"", 0, true, BUFFER_JSON_OPTIONS_DEFAULT);
  415. buffer_json_member_add_string(wb, "hostname", rrdhost_hostname(localhost));
  416. buffer_json_member_add_uint64(wb, "status", HTTP_RESP_OK);
  417. buffer_json_member_add_string(wb, "type", "table");
  418. buffer_json_member_add_time_t(wb, "update_every", 1);
  419. buffer_json_member_add_string(wb, "help", RRDFUNCTIONS_NETDEV_HELP);
  420. buffer_json_member_add_array(wb, "data");
  421. double max_traffic_rx = 0.0;
  422. double max_traffic_tx = 0.0;
  423. double max_traffic = 0.0;
  424. double max_packets_rx = 0.0;
  425. double max_packets_tx = 0.0;
  426. double max_mcast_rx = 0.0;
  427. double max_drops_rx = 0.0;
  428. double max_drops_tx = 0.0;
  429. netdata_mutex_lock(&netdev_mutex);
  430. RRDDIM *rd = NULL;
  431. for (struct netdev *d = netdev_root; d ; d = d->next) {
  432. if (unlikely(!d->function_ready))
  433. continue;
  434. buffer_json_add_array_item_array(wb);
  435. buffer_json_add_array_item_string(wb, d->name);
  436. buffer_json_add_array_item_string(wb, d->virtual ? "virtual" : "physical");
  437. buffer_json_add_array_item_string(wb, d->flipped ? "cgroup" : "host");
  438. buffer_json_add_array_item_string(wb, d->carrier == 1 ? "up" : "down");
  439. buffer_json_add_array_item_string(wb, get_operstate_string(d->operstate));
  440. buffer_json_add_array_item_string(wb, get_duplex_string(d->duplex));
  441. buffer_json_add_array_item_double(wb, d->speed > 0 ? d->speed : NAN);
  442. buffer_json_add_array_item_double(wb, d->mtu > 0 ? d->mtu : NAN);
  443. rd = d->flipped ? d->rd_tbytes : d->rd_rbytes;
  444. double traffic_rx = rrddim_get_last_stored_value(rd, &max_traffic_rx, 1000.0);
  445. rd = d->flipped ? d->rd_rbytes : d->rd_tbytes;
  446. double traffic_tx = rrddim_get_last_stored_value(rd, &max_traffic_tx, 1000.0);
  447. rd = d->flipped ? d->rd_tpackets : d->rd_rpackets;
  448. double packets_rx = rrddim_get_last_stored_value(rd, &max_packets_rx, 1000.0);
  449. rd = d->flipped ? d->rd_rpackets : d->rd_tpackets;
  450. double packets_tx = rrddim_get_last_stored_value(rd, &max_packets_tx, 1000.0);
  451. double mcast_rx = rrddim_get_last_stored_value(d->rd_rmulticast, &max_mcast_rx, 1000.0);
  452. rd = d->flipped ? d->rd_tdrops : d->rd_rdrops;
  453. double drops_rx = rrddim_get_last_stored_value(rd, &max_drops_rx, 1.0);
  454. rd = d->flipped ? d->rd_rdrops : d->rd_tdrops;
  455. double drops_tx = rrddim_get_last_stored_value(rd, &max_drops_tx, 1.0);
  456. // FIXME: "traffic" (total) is needed only for default_sorting
  457. // can be removed when default_sorting will accept multiple columns (sum)
  458. double traffic = NAN;
  459. if (!isnan(traffic_rx) && !isnan(traffic_tx)) {
  460. traffic = traffic_rx + traffic_tx;
  461. max_traffic = MAX(max_traffic, traffic);
  462. }
  463. buffer_json_add_array_item_double(wb, traffic_rx);
  464. buffer_json_add_array_item_double(wb, traffic_tx);
  465. buffer_json_add_array_item_double(wb, traffic);
  466. buffer_json_add_array_item_double(wb, packets_rx);
  467. buffer_json_add_array_item_double(wb, packets_tx);
  468. buffer_json_add_array_item_double(wb, mcast_rx);
  469. buffer_json_add_array_item_double(wb, drops_rx);
  470. buffer_json_add_array_item_double(wb, drops_tx);
  471. buffer_json_add_array_item_object(wb);
  472. {
  473. buffer_json_member_add_string(wb, "severity", drops_rx + drops_tx > 0 ? "warning" : "normal");
  474. }
  475. buffer_json_object_close(wb);
  476. buffer_json_array_close(wb);
  477. }
  478. netdata_mutex_unlock(&netdev_mutex);
  479. buffer_json_array_close(wb); // data
  480. buffer_json_member_add_object(wb, "columns");
  481. {
  482. size_t field_id = 0;
  483. buffer_rrdf_table_add_field(wb, field_id++, "Interface", "Network Interface Name",
  484. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  485. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  486. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  487. RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY | RRDF_FIELD_OPTS_STICKY,
  488. NULL);
  489. buffer_rrdf_table_add_field(wb, field_id++, "Type", "Network Interface Type",
  490. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  491. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  492. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  493. RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
  494. NULL);
  495. buffer_rrdf_table_add_field(wb, field_id++, "UsedBy", "Indicates whether the network interface is used by a cgroup or by the host system",
  496. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  497. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  498. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  499. RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
  500. NULL);
  501. buffer_rrdf_table_add_field(wb, field_id++, "PhState", "Current Physical State",
  502. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  503. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  504. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  505. RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
  506. NULL);
  507. buffer_rrdf_table_add_field(wb, field_id++, "OpState", "Current Operational State",
  508. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  509. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  510. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  511. RRDF_FIELD_OPTS_UNIQUE_KEY,
  512. NULL);
  513. buffer_rrdf_table_add_field(wb, field_id++, "Duplex", "Current Duplex Mode",
  514. RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
  515. 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
  516. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  517. RRDF_FIELD_OPTS_UNIQUE_KEY,
  518. NULL);
  519. buffer_rrdf_table_add_field(wb, field_id++, "Speed", "Current Link Speed",
  520. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
  521. 0, "Mbit", NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
  522. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  523. RRDF_FIELD_OPTS_UNIQUE_KEY,
  524. NULL);
  525. buffer_rrdf_table_add_field(wb, field_id++, "MTU", "Maximum Transmission Unit",
  526. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
  527. 0, "Octets", NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
  528. RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
  529. RRDF_FIELD_OPTS_UNIQUE_KEY,
  530. NULL);
  531. buffer_rrdf_table_add_field(wb, field_id++, "In", "Traffic Received",
  532. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  533. 2, "Mbit", max_traffic_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
  534. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  535. RRDF_FIELD_OPTS_VISIBLE,
  536. NULL);
  537. buffer_rrdf_table_add_field(wb, field_id++, "Out", "Traffic Sent",
  538. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  539. 2, "Mbit", max_traffic_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
  540. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  541. RRDF_FIELD_OPTS_VISIBLE,
  542. NULL);
  543. buffer_rrdf_table_add_field(wb, field_id++, "Total", "Traffic Received and Sent",
  544. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  545. 2, "Mbit", max_traffic, RRDF_FIELD_SORT_DESCENDING, NULL,
  546. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  547. RRDF_FIELD_OPTS_NONE,
  548. NULL);
  549. buffer_rrdf_table_add_field(wb, field_id++, "PktsIn", "Received Packets",
  550. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  551. 2, "Kpps", max_packets_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
  552. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  553. RRDF_FIELD_OPTS_VISIBLE,
  554. NULL);
  555. buffer_rrdf_table_add_field(wb, field_id++, "PktsOut", "Sent Packets",
  556. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  557. 2, "Kpps", max_packets_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
  558. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  559. RRDF_FIELD_OPTS_VISIBLE,
  560. NULL);
  561. buffer_rrdf_table_add_field(wb, field_id++, "McastIn", "Multicast Received Packets",
  562. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  563. 2, "Kpps", max_mcast_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
  564. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  565. RRDF_FIELD_OPTS_NONE,
  566. NULL);
  567. buffer_rrdf_table_add_field(wb, field_id++, "DropsIn", "Dropped Inbound Packets",
  568. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  569. 2, "Drops", max_drops_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
  570. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  571. RRDF_FIELD_OPTS_VISIBLE,
  572. NULL);
  573. buffer_rrdf_table_add_field(wb, field_id++, "DropsOut", "Dropped Outbound Packets",
  574. RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
  575. 2, "Drops", max_drops_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
  576. RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
  577. RRDF_FIELD_OPTS_VISIBLE,
  578. NULL);
  579. buffer_rrdf_table_add_field(
  580. wb, field_id++,
  581. "rowOptions", "rowOptions",
  582. RRDF_FIELD_TYPE_NONE,
  583. RRDR_FIELD_VISUAL_ROW_OPTIONS,
  584. RRDF_FIELD_TRANSFORM_NONE, 0, NULL, NAN,
  585. RRDF_FIELD_SORT_FIXED,
  586. NULL,
  587. RRDF_FIELD_SUMMARY_COUNT,
  588. RRDF_FIELD_FILTER_NONE,
  589. RRDF_FIELD_OPTS_DUMMY,
  590. NULL);
  591. }
  592. buffer_json_object_close(wb); // columns
  593. buffer_json_member_add_string(wb, "default_sort_column", "Total");
  594. buffer_json_member_add_object(wb, "charts");
  595. {
  596. buffer_json_member_add_object(wb, "Traffic");
  597. {
  598. buffer_json_member_add_string(wb, "name", "Traffic");
  599. buffer_json_member_add_string(wb, "type", "stacked-bar");
  600. buffer_json_member_add_array(wb, "columns");
  601. {
  602. buffer_json_add_array_item_string(wb, "In");
  603. buffer_json_add_array_item_string(wb, "Out");
  604. }
  605. buffer_json_array_close(wb);
  606. }
  607. buffer_json_object_close(wb);
  608. buffer_json_member_add_object(wb, "Packets");
  609. {
  610. buffer_json_member_add_string(wb, "name", "Packets");
  611. buffer_json_member_add_string(wb, "type", "stacked-bar");
  612. buffer_json_member_add_array(wb, "columns");
  613. {
  614. buffer_json_add_array_item_string(wb, "PktsIn");
  615. buffer_json_add_array_item_string(wb, "PktsOut");
  616. }
  617. buffer_json_array_close(wb);
  618. }
  619. buffer_json_object_close(wb);
  620. }
  621. buffer_json_object_close(wb); // charts
  622. buffer_json_member_add_array(wb, "default_charts");
  623. {
  624. buffer_json_add_array_item_array(wb);
  625. buffer_json_add_array_item_string(wb, "Traffic");
  626. buffer_json_add_array_item_string(wb, "Interface");
  627. buffer_json_array_close(wb);
  628. buffer_json_add_array_item_array(wb);
  629. buffer_json_add_array_item_string(wb, "Traffic");
  630. buffer_json_add_array_item_string(wb, "Type");
  631. buffer_json_array_close(wb);
  632. }
  633. buffer_json_array_close(wb);
  634. buffer_json_member_add_object(wb, "group_by");
  635. {
  636. buffer_json_member_add_object(wb, "Type");
  637. {
  638. buffer_json_member_add_string(wb, "name", "Type");
  639. buffer_json_member_add_array(wb, "columns");
  640. {
  641. buffer_json_add_array_item_string(wb, "Type");
  642. }
  643. buffer_json_array_close(wb);
  644. }
  645. buffer_json_object_close(wb);
  646. buffer_json_member_add_object(wb, "UsedBy");
  647. {
  648. buffer_json_member_add_string(wb, "name", "UsedBy");
  649. buffer_json_member_add_array(wb, "columns");
  650. {
  651. buffer_json_add_array_item_string(wb, "UsedBy");
  652. }
  653. buffer_json_array_close(wb);
  654. }
  655. buffer_json_object_close(wb);
  656. }
  657. buffer_json_object_close(wb); // group_by
  658. buffer_json_member_add_time_t(wb, "expires", now_realtime_sec() + 1);
  659. buffer_json_finalize(wb);
  660. return HTTP_RESP_OK;
  661. }
  662. // netdev data collection
  663. static void netdev_cleanup() {
  664. struct netdev *d = netdev_root;
  665. while(d) {
  666. if(unlikely(!d->updated)) {
  667. struct netdev *next = d->next; // keep the next, to continue;
  668. DOUBLE_LINKED_LIST_REMOVE_ITEM_UNSAFE(netdev_root, d, prev, next);
  669. netdev_free(d);
  670. d = next;
  671. continue;
  672. }
  673. d->updated = false;
  674. d = d->next;
  675. }
  676. }
  677. static struct netdev *get_netdev(const char *name) {
  678. struct netdev *d;
  679. uint32_t hash = simple_hash(name);
  680. // search it, from the last position to the end
  681. for(d = netdev_root ; d ; d = d->next) {
  682. if(unlikely(hash == d->hash && !strcmp(name, d->name)))
  683. return d;
  684. }
  685. // create a new one
  686. d = callocz(1, sizeof(struct netdev));
  687. d->name = strdupz(name);
  688. d->hash = simple_hash(d->name);
  689. d->len = strlen(d->name);
  690. d->chart_labels = rrdlabels_create();
  691. d->function_ready = false;
  692. d->double_linked = false;
  693. d->chart_type_net_bytes = strdupz("net");
  694. d->chart_type_net_compressed = strdupz("net_compressed");
  695. d->chart_type_net_drops = strdupz("net_drops");
  696. d->chart_type_net_errors = strdupz("net_errors");
  697. d->chart_type_net_events = strdupz("net_events");
  698. d->chart_type_net_fifo = strdupz("net_fifo");
  699. d->chart_type_net_packets = strdupz("net_packets");
  700. d->chart_type_net_speed = strdupz("net_speed");
  701. d->chart_type_net_duplex = strdupz("net_duplex");
  702. d->chart_type_net_operstate = strdupz("net_operstate");
  703. d->chart_type_net_carrier = strdupz("net_carrier");
  704. d->chart_type_net_mtu = strdupz("net_mtu");
  705. d->chart_id_net_bytes = strdupz(d->name);
  706. d->chart_id_net_compressed = strdupz(d->name);
  707. d->chart_id_net_drops = strdupz(d->name);
  708. d->chart_id_net_errors = strdupz(d->name);
  709. d->chart_id_net_events = strdupz(d->name);
  710. d->chart_id_net_fifo = strdupz(d->name);
  711. d->chart_id_net_packets = strdupz(d->name);
  712. d->chart_id_net_speed = strdupz(d->name);
  713. d->chart_id_net_duplex = strdupz(d->name);
  714. d->chart_id_net_operstate = strdupz(d->name);
  715. d->chart_id_net_carrier = strdupz(d->name);
  716. d->chart_id_net_mtu = strdupz(d->name);
  717. d->chart_ctx_net_bytes = strdupz("net.net");
  718. d->chart_ctx_net_compressed = strdupz("net.compressed");
  719. d->chart_ctx_net_drops = strdupz("net.drops");
  720. d->chart_ctx_net_errors = strdupz("net.errors");
  721. d->chart_ctx_net_events = strdupz("net.events");
  722. d->chart_ctx_net_fifo = strdupz("net.fifo");
  723. d->chart_ctx_net_packets = strdupz("net.packets");
  724. d->chart_ctx_net_speed = strdupz("net.speed");
  725. d->chart_ctx_net_duplex = strdupz("net.duplex");
  726. d->chart_ctx_net_operstate = strdupz("net.operstate");
  727. d->chart_ctx_net_carrier = strdupz("net.carrier");
  728. d->chart_ctx_net_mtu = strdupz("net.mtu");
  729. d->chart_family = strdupz(d->name);
  730. d->priority = NETDATA_CHART_PRIO_FIRST_NET_IFACE;
  731. DOUBLE_LINKED_LIST_APPEND_ITEM_UNSAFE(netdev_root, d, prev, next);
  732. return d;
  733. }
  734. static bool is_iface_double_linked(struct netdev *d) {
  735. char filename[FILENAME_MAX + 1];
  736. unsigned long long iflink = 0;
  737. unsigned long long ifindex = 0;
  738. snprintfz(filename, FILENAME_MAX, "%s/sys/class/net/%s/iflink", netdata_configured_host_prefix, d->name);
  739. if (read_single_number_file(filename, &iflink))
  740. return false;
  741. snprintfz(filename, FILENAME_MAX, "%s/sys/class/net/%s/ifindex", netdata_configured_host_prefix, d->name);
  742. if (read_single_number_file(filename, &ifindex))
  743. return false;
  744. return iflink != ifindex;
  745. }
  746. int do_proc_net_dev(int update_every, usec_t dt) {
  747. (void)dt;
  748. static SIMPLE_PATTERN *disabled_list = NULL;
  749. static procfile *ff = NULL;
  750. static int enable_new_interfaces = -1;
  751. static int do_bandwidth = -1, do_packets = -1, do_errors = -1, do_drops = -1, do_fifo = -1, do_compressed = -1,
  752. do_events = -1, do_speed = -1, do_duplex = -1, do_operstate = -1, do_carrier = -1, do_mtu = -1;
  753. static char *path_to_sys_devices_virtual_net = NULL, *path_to_sys_class_net_speed = NULL,
  754. *proc_net_dev_filename = NULL;
  755. static char *path_to_sys_class_net_duplex = NULL;
  756. static char *path_to_sys_class_net_operstate = NULL;
  757. static char *path_to_sys_class_net_carrier = NULL;
  758. static char *path_to_sys_class_net_mtu = NULL;
  759. if(unlikely(enable_new_interfaces == -1)) {
  760. char filename[FILENAME_MAX + 1];
  761. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, (*netdata_configured_host_prefix)?"/proc/1/net/dev":"/proc/net/dev");
  762. proc_net_dev_filename = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "filename to monitor", filename);
  763. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/devices/virtual/net/%s");
  764. path_to_sys_devices_virtual_net = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get virtual interfaces", filename);
  765. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/speed");
  766. path_to_sys_class_net_speed = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device speed", filename);
  767. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/duplex");
  768. path_to_sys_class_net_duplex = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device duplex", filename);
  769. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/operstate");
  770. path_to_sys_class_net_operstate = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device operstate", filename);
  771. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/carrier");
  772. path_to_sys_class_net_carrier = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device carrier", filename);
  773. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/mtu");
  774. path_to_sys_class_net_mtu = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device mtu", filename);
  775. enable_new_interfaces = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "enable new interfaces detected at runtime", CONFIG_BOOLEAN_AUTO);
  776. do_bandwidth = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "bandwidth for all interfaces", CONFIG_BOOLEAN_AUTO);
  777. do_packets = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "packets for all interfaces", CONFIG_BOOLEAN_AUTO);
  778. do_errors = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "errors for all interfaces", CONFIG_BOOLEAN_AUTO);
  779. do_drops = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "drops for all interfaces", CONFIG_BOOLEAN_AUTO);
  780. do_fifo = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "fifo for all interfaces", CONFIG_BOOLEAN_AUTO);
  781. do_compressed = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "compressed packets for all interfaces", CONFIG_BOOLEAN_AUTO);
  782. do_events = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "frames, collisions, carrier counters for all interfaces", CONFIG_BOOLEAN_AUTO);
  783. do_speed = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "speed for all interfaces", CONFIG_BOOLEAN_AUTO);
  784. do_duplex = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "duplex for all interfaces", CONFIG_BOOLEAN_AUTO);
  785. do_operstate = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "operstate for all interfaces", CONFIG_BOOLEAN_AUTO);
  786. do_carrier = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "carrier for all interfaces", CONFIG_BOOLEAN_AUTO);
  787. do_mtu = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "mtu for all interfaces", CONFIG_BOOLEAN_AUTO);
  788. disabled_list = simple_pattern_create(
  789. config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "disable by default interfaces matching",
  790. "lo fireqos* *-ifb fwpr* fwbr* fwln*"), NULL, SIMPLE_PATTERN_EXACT, true);
  791. netdev_renames_init();
  792. }
  793. if(unlikely(!ff)) {
  794. ff = procfile_open(proc_net_dev_filename, " \t,|", PROCFILE_FLAG_DEFAULT);
  795. if(unlikely(!ff)) return 1;
  796. }
  797. ff = procfile_readall(ff);
  798. if(unlikely(!ff)) return 0; // we return 0, so that we will retry to open it next time
  799. kernel_uint_t system_rbytes = 0;
  800. kernel_uint_t system_tbytes = 0;
  801. time_t now = now_realtime_sec();
  802. size_t lines = procfile_lines(ff), l;
  803. for(l = 2; l < lines ;l++) {
  804. // require 17 words on each line
  805. if(unlikely(procfile_linewords(ff, l) < 17)) continue;
  806. char *name = procfile_lineword(ff, l, 0);
  807. size_t len = strlen(name);
  808. if(name[len - 1] == ':') name[len - 1] = '\0';
  809. struct netdev *d = get_netdev(name);
  810. d->updated = true;
  811. if(unlikely(!d->configured)) {
  812. // the first time we see this interface
  813. // remember we configured it
  814. d->configured = true;
  815. d->discover_time = now;
  816. d->enabled = enable_new_interfaces;
  817. if(d->enabled)
  818. d->enabled = !simple_pattern_matches(disabled_list, d->name);
  819. char buf[FILENAME_MAX + 1];
  820. snprintfz(buf, FILENAME_MAX, path_to_sys_devices_virtual_net, d->name);
  821. d->virtual = likely(access(buf, R_OK) == 0) ? true : false;
  822. // At least on Proxmox inside LXC: eth0 is virtual.
  823. // Virtual interfaces are not taken into account in system.net calculations
  824. if (inside_lxc_container && d->virtual && strncmp(d->name, "eth", 3) == 0)
  825. d->virtual = false;
  826. if (d->virtual)
  827. rrdlabels_add(d->chart_labels, "interface_type", "virtual", RRDLABEL_SRC_AUTO);
  828. else
  829. rrdlabels_add(d->chart_labels, "interface_type", "real", RRDLABEL_SRC_AUTO);
  830. rrdlabels_add(d->chart_labels, "device", name, RRDLABEL_SRC_AUTO);
  831. if(likely(!d->virtual)) {
  832. // set the filename to get the interface speed
  833. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_speed, d->name);
  834. d->filename_speed = strdupz(buf);
  835. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_duplex, d->name);
  836. d->filename_duplex = strdupz(buf);
  837. }
  838. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_operstate, d->name);
  839. d->filename_operstate = strdupz(buf);
  840. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_carrier, d->name);
  841. d->filename_carrier = strdupz(buf);
  842. snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_mtu, d->name);
  843. d->filename_mtu = strdupz(buf);
  844. snprintfz(buf, FILENAME_MAX, "plugin:proc:/proc/net/dev:%s", d->name);
  845. if (config_exists(buf, "enabled"))
  846. d->enabled = config_get_boolean_ondemand(buf, "enabled", d->enabled);
  847. if (config_exists(buf, "virtual"))
  848. d->virtual = config_get_boolean(buf, "virtual", d->virtual);
  849. if(d->enabled == CONFIG_BOOLEAN_NO)
  850. continue;
  851. d->double_linked = is_iface_double_linked(d);
  852. d->do_bandwidth = do_bandwidth;
  853. d->do_packets = do_packets;
  854. d->do_errors = do_errors;
  855. d->do_drops = do_drops;
  856. d->do_fifo = do_fifo;
  857. d->do_compressed = do_compressed;
  858. d->do_events = do_events;
  859. d->do_speed = do_speed;
  860. d->do_duplex = do_duplex;
  861. d->do_operstate = do_operstate;
  862. d->do_carrier = do_carrier;
  863. d->do_mtu = do_mtu;
  864. if (config_exists(buf, "bandwidth"))
  865. d->do_bandwidth = config_get_boolean_ondemand(buf, "bandwidth", do_bandwidth);
  866. if (config_exists(buf, "packets"))
  867. d->do_packets = config_get_boolean_ondemand(buf, "packets", do_packets);
  868. if (config_exists(buf, "errors"))
  869. d->do_errors = config_get_boolean_ondemand(buf, "errors", do_errors);
  870. if (config_exists(buf, "drops"))
  871. d->do_drops = config_get_boolean_ondemand(buf, "drops", do_drops);
  872. if (config_exists(buf, "fifo"))
  873. d->do_fifo = config_get_boolean_ondemand(buf, "fifo", do_fifo);
  874. if (config_exists(buf, "compressed"))
  875. d->do_compressed = config_get_boolean_ondemand(buf, "compressed", do_compressed);
  876. if (config_exists(buf, "events"))
  877. d->do_events = config_get_boolean_ondemand(buf, "events", do_events);
  878. if (config_exists(buf, "speed"))
  879. d->do_speed = config_get_boolean_ondemand(buf, "speed", do_speed);
  880. if (config_exists(buf, "duplex"))
  881. d->do_duplex = config_get_boolean_ondemand(buf, "duplex", do_duplex);
  882. if (config_exists(buf, "operstate"))
  883. d->do_operstate = config_get_boolean_ondemand(buf, "operstate", do_operstate);
  884. if (config_exists(buf, "carrier"))
  885. d->do_carrier = config_get_boolean_ondemand(buf, "carrier", do_carrier);
  886. if (config_exists(buf, "mtu"))
  887. d->do_mtu = config_get_boolean_ondemand(buf, "mtu", do_mtu);
  888. }
  889. if(unlikely(!d->enabled))
  890. continue;
  891. if(!d->cgroup_netdev_link)
  892. netdev_rename_this_device(d);
  893. // See https://github.com/netdata/netdata/issues/15206
  894. // This is necessary to prevent the creation of charts for virtual interfaces that will later be
  895. // recreated as container interfaces (create container) or
  896. // rediscovered and recreated only to be deleted almost immediately (stop/remove container)
  897. if (d->double_linked && d->virtual && (now - d->discover_time < double_linked_device_collect_delay_secs))
  898. continue;
  899. if(likely(d->do_bandwidth != CONFIG_BOOLEAN_NO || !d->virtual)) {
  900. d->rbytes = str2kernel_uint_t(procfile_lineword(ff, l, 1));
  901. d->tbytes = str2kernel_uint_t(procfile_lineword(ff, l, 9));
  902. if(likely(!d->virtual)) {
  903. system_rbytes += d->rbytes;
  904. system_tbytes += d->tbytes;
  905. }
  906. }
  907. if(likely(d->do_packets != CONFIG_BOOLEAN_NO)) {
  908. d->rpackets = str2kernel_uint_t(procfile_lineword(ff, l, 2));
  909. d->rmulticast = str2kernel_uint_t(procfile_lineword(ff, l, 8));
  910. d->tpackets = str2kernel_uint_t(procfile_lineword(ff, l, 10));
  911. }
  912. if(likely(d->do_errors != CONFIG_BOOLEAN_NO)) {
  913. d->rerrors = str2kernel_uint_t(procfile_lineword(ff, l, 3));
  914. d->terrors = str2kernel_uint_t(procfile_lineword(ff, l, 11));
  915. }
  916. if(likely(d->do_drops != CONFIG_BOOLEAN_NO)) {
  917. d->rdrops = str2kernel_uint_t(procfile_lineword(ff, l, 4));
  918. d->tdrops = str2kernel_uint_t(procfile_lineword(ff, l, 12));
  919. }
  920. if(likely(d->do_fifo != CONFIG_BOOLEAN_NO)) {
  921. d->rfifo = str2kernel_uint_t(procfile_lineword(ff, l, 5));
  922. d->tfifo = str2kernel_uint_t(procfile_lineword(ff, l, 13));
  923. }
  924. if(likely(d->do_compressed != CONFIG_BOOLEAN_NO)) {
  925. d->rcompressed = str2kernel_uint_t(procfile_lineword(ff, l, 7));
  926. d->tcompressed = str2kernel_uint_t(procfile_lineword(ff, l, 16));
  927. }
  928. if(likely(d->do_events != CONFIG_BOOLEAN_NO)) {
  929. d->rframe = str2kernel_uint_t(procfile_lineword(ff, l, 6));
  930. d->tcollisions = str2kernel_uint_t(procfile_lineword(ff, l, 14));
  931. d->tcarrier = str2kernel_uint_t(procfile_lineword(ff, l, 15));
  932. }
  933. if ((d->do_carrier != CONFIG_BOOLEAN_NO ||
  934. d->do_duplex != CONFIG_BOOLEAN_NO ||
  935. d->do_speed != CONFIG_BOOLEAN_NO) &&
  936. d->filename_carrier &&
  937. (d->carrier_file_exists ||
  938. now_monotonic_sec() - d->carrier_file_lost_time > READ_RETRY_PERIOD)) {
  939. if (read_single_number_file(d->filename_carrier, &d->carrier)) {
  940. if (d->carrier_file_exists)
  941. collector_error(
  942. "Cannot refresh interface %s carrier state by reading '%s'. Next update is in %d seconds.",
  943. d->name,
  944. d->filename_carrier,
  945. READ_RETRY_PERIOD);
  946. d->carrier_file_exists = 0;
  947. d->carrier_file_lost_time = now_monotonic_sec();
  948. } else {
  949. d->carrier_file_exists = 1;
  950. d->carrier_file_lost_time = 0;
  951. }
  952. }
  953. if (d->do_duplex != CONFIG_BOOLEAN_NO &&
  954. d->filename_duplex &&
  955. (d->carrier || d->carrier_file_exists) &&
  956. (d->duplex_file_exists ||
  957. now_monotonic_sec() - d->duplex_file_lost_time > READ_RETRY_PERIOD)) {
  958. char buffer[STATE_LENGTH_MAX + 1];
  959. if (read_file(d->filename_duplex, buffer, STATE_LENGTH_MAX)) {
  960. if (d->duplex_file_exists)
  961. collector_error("Cannot refresh interface %s duplex state by reading '%s'.", d->name, d->filename_duplex);
  962. d->duplex_file_exists = 0;
  963. d->duplex_file_lost_time = now_monotonic_sec();
  964. d->duplex = NETDEV_DUPLEX_UNKNOWN;
  965. } else {
  966. // values can be unknown, half or full -- just check the first letter for speed
  967. if (buffer[0] == 'f')
  968. d->duplex = NETDEV_DUPLEX_FULL;
  969. else if (buffer[0] == 'h')
  970. d->duplex = NETDEV_DUPLEX_HALF;
  971. else
  972. d->duplex = NETDEV_DUPLEX_UNKNOWN;
  973. d->duplex_file_exists = 1;
  974. d->duplex_file_lost_time = 0;
  975. }
  976. } else {
  977. d->duplex = NETDEV_DUPLEX_UNKNOWN;
  978. }
  979. if(d->do_operstate != CONFIG_BOOLEAN_NO && d->filename_operstate) {
  980. char buffer[STATE_LENGTH_MAX + 1], *trimmed_buffer;
  981. if (read_file(d->filename_operstate, buffer, STATE_LENGTH_MAX)) {
  982. collector_error(
  983. "Cannot refresh %s operstate by reading '%s'. Will not update its status anymore.",
  984. d->name, d->filename_operstate);
  985. freez(d->filename_operstate);
  986. d->filename_operstate = NULL;
  987. } else {
  988. trimmed_buffer = trim(buffer);
  989. d->operstate = get_operstate(trimmed_buffer);
  990. }
  991. }
  992. if (d->do_mtu != CONFIG_BOOLEAN_NO && d->filename_mtu) {
  993. if (read_single_number_file(d->filename_mtu, &d->mtu)) {
  994. collector_error(
  995. "Cannot refresh mtu for interface %s by reading '%s'. Stop updating it.", d->name, d->filename_mtu);
  996. freez(d->filename_mtu);
  997. d->filename_mtu = NULL;
  998. }
  999. }
  1000. //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"
  1001. // , d->name, d->speed
  1002. // , d->rbytes, d->tbytes
  1003. // , d->rpackets, d->tpackets, d->rmulticast
  1004. // , d->rerrors, d->terrors
  1005. // , d->rdrops, d->tdrops
  1006. // , d->rfifo, d->tfifo
  1007. // , d->rcompressed, d->tcompressed
  1008. // , d->rframe, d->tcollisions, d->tcarrier
  1009. // );
  1010. if(unlikely(d->do_bandwidth == CONFIG_BOOLEAN_AUTO &&
  1011. (d->rbytes || d->tbytes || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1012. d->do_bandwidth = CONFIG_BOOLEAN_YES;
  1013. if(d->do_bandwidth == CONFIG_BOOLEAN_YES) {
  1014. if(unlikely(!d->st_bandwidth)) {
  1015. d->st_bandwidth = rrdset_create_localhost(
  1016. d->chart_type_net_bytes
  1017. , d->chart_id_net_bytes
  1018. , NULL
  1019. , d->chart_family
  1020. , d->chart_ctx_net_bytes
  1021. , "Bandwidth"
  1022. , "kilobits/s"
  1023. , PLUGIN_PROC_NAME
  1024. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1025. , d->priority
  1026. , update_every
  1027. , RRDSET_TYPE_AREA
  1028. );
  1029. rrdset_update_rrdlabels(d->st_bandwidth, d->chart_labels);
  1030. d->rd_rbytes = rrddim_add(d->st_bandwidth, "received", NULL, 8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1031. d->rd_tbytes = rrddim_add(d->st_bandwidth, "sent", NULL, -8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1032. if(d->flipped) {
  1033. // flip receive/transmit
  1034. RRDDIM *td = d->rd_rbytes;
  1035. d->rd_rbytes = d->rd_tbytes;
  1036. d->rd_tbytes = td;
  1037. }
  1038. }
  1039. rrddim_set_by_pointer(d->st_bandwidth, d->rd_rbytes, (collected_number)d->rbytes);
  1040. rrddim_set_by_pointer(d->st_bandwidth, d->rd_tbytes, (collected_number)d->tbytes);
  1041. rrdset_done(d->st_bandwidth);
  1042. if(d->cgroup_netdev_link)
  1043. cgroup_netdev_add_bandwidth(d->cgroup_netdev_link,
  1044. d->flipped ? d->rd_tbytes->collector.last_stored_value : -d->rd_rbytes->collector.last_stored_value,
  1045. d->flipped ? -d->rd_rbytes->collector.last_stored_value : d->rd_tbytes->collector.last_stored_value);
  1046. // update the interface speed
  1047. if(d->filename_speed) {
  1048. if(unlikely(!d->chart_var_speed)) {
  1049. d->chart_var_speed =
  1050. rrdsetvar_custom_chart_variable_add_and_acquire(d->st_bandwidth, "nic_speed_max");
  1051. if(!d->chart_var_speed) {
  1052. collector_error(
  1053. "Cannot create interface %s chart variable 'nic_speed_max'. Will not update its speed anymore.",
  1054. d->name);
  1055. freez(d->filename_speed);
  1056. d->filename_speed = NULL;
  1057. }
  1058. }
  1059. if (d->filename_speed && d->chart_var_speed) {
  1060. int ret = 0;
  1061. if ((d->carrier || d->carrier_file_exists) &&
  1062. (d->speed_file_exists || now_monotonic_sec() - d->speed_file_lost_time > READ_RETRY_PERIOD)) {
  1063. ret = read_single_number_file(d->filename_speed, (unsigned long long *) &d->speed);
  1064. } else {
  1065. d->speed = 0; // TODO: this is wrong, shouldn't use 0 value, but NULL.
  1066. }
  1067. if(ret) {
  1068. if (d->speed_file_exists)
  1069. collector_error("Cannot refresh interface %s speed by reading '%s'.", d->name, d->filename_speed);
  1070. d->speed_file_exists = 0;
  1071. d->speed_file_lost_time = now_monotonic_sec();
  1072. }
  1073. else {
  1074. if(d->do_speed != CONFIG_BOOLEAN_NO) {
  1075. if(unlikely(!d->st_speed)) {
  1076. d->st_speed = rrdset_create_localhost(
  1077. d->chart_type_net_speed
  1078. , d->chart_id_net_speed
  1079. , NULL
  1080. , d->chart_family
  1081. , d->chart_ctx_net_speed
  1082. , "Interface Speed"
  1083. , "kilobits/s"
  1084. , PLUGIN_PROC_NAME
  1085. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1086. , d->priority + 7
  1087. , update_every
  1088. , RRDSET_TYPE_LINE
  1089. );
  1090. rrdset_flag_set(d->st_speed, RRDSET_FLAG_DETAIL);
  1091. rrdset_update_rrdlabels(d->st_speed, d->chart_labels);
  1092. d->rd_speed = rrddim_add(d->st_speed, "speed", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1093. }
  1094. rrddim_set_by_pointer(d->st_speed, d->rd_speed, (collected_number)d->speed * KILOBITS_IN_A_MEGABIT);
  1095. rrdset_done(d->st_speed);
  1096. }
  1097. rrdsetvar_custom_chart_variable_set(
  1098. d->st_bandwidth, d->chart_var_speed, (NETDATA_DOUBLE)d->speed * KILOBITS_IN_A_MEGABIT);
  1099. if (d->speed) {
  1100. d->speed_file_exists = 1;
  1101. d->speed_file_lost_time = 0;
  1102. }
  1103. }
  1104. }
  1105. }
  1106. }
  1107. if(d->do_duplex != CONFIG_BOOLEAN_NO && d->filename_duplex) {
  1108. if(unlikely(!d->st_duplex)) {
  1109. d->st_duplex = rrdset_create_localhost(
  1110. d->chart_type_net_duplex
  1111. , d->chart_id_net_duplex
  1112. , NULL
  1113. , d->chart_family
  1114. , d->chart_ctx_net_duplex
  1115. , "Interface Duplex State"
  1116. , "state"
  1117. , PLUGIN_PROC_NAME
  1118. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1119. , d->priority + 8
  1120. , update_every
  1121. , RRDSET_TYPE_LINE
  1122. );
  1123. rrdset_flag_set(d->st_duplex, RRDSET_FLAG_DETAIL);
  1124. rrdset_update_rrdlabels(d->st_duplex, d->chart_labels);
  1125. d->rd_duplex_full = rrddim_add(d->st_duplex, "full", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1126. d->rd_duplex_half = rrddim_add(d->st_duplex, "half", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1127. d->rd_duplex_unknown = rrddim_add(d->st_duplex, "unknown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1128. }
  1129. rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_full, (collected_number)(d->duplex == NETDEV_DUPLEX_FULL));
  1130. rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_half, (collected_number)(d->duplex == NETDEV_DUPLEX_HALF));
  1131. rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_unknown, (collected_number)(d->duplex == NETDEV_DUPLEX_UNKNOWN));
  1132. rrdset_done(d->st_duplex);
  1133. }
  1134. if(d->do_operstate != CONFIG_BOOLEAN_NO && d->filename_operstate) {
  1135. if(unlikely(!d->st_operstate)) {
  1136. d->st_operstate = rrdset_create_localhost(
  1137. d->chart_type_net_operstate
  1138. , d->chart_id_net_operstate
  1139. , NULL
  1140. , d->chart_family
  1141. , d->chart_ctx_net_operstate
  1142. , "Interface Operational State"
  1143. , "state"
  1144. , PLUGIN_PROC_NAME
  1145. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1146. , d->priority + 9
  1147. , update_every
  1148. , RRDSET_TYPE_LINE
  1149. );
  1150. rrdset_flag_set(d->st_operstate, RRDSET_FLAG_DETAIL);
  1151. rrdset_update_rrdlabels(d->st_operstate, d->chart_labels);
  1152. d->rd_operstate_up = rrddim_add(d->st_operstate, "up", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1153. d->rd_operstate_down = rrddim_add(d->st_operstate, "down", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1154. d->rd_operstate_notpresent = rrddim_add(d->st_operstate, "notpresent", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1155. d->rd_operstate_lowerlayerdown = rrddim_add(d->st_operstate, "lowerlayerdown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1156. d->rd_operstate_testing = rrddim_add(d->st_operstate, "testing", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1157. d->rd_operstate_dormant = rrddim_add(d->st_operstate, "dormant", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1158. d->rd_operstate_unknown = rrddim_add(d->st_operstate, "unknown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1159. }
  1160. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_up, (collected_number)(d->operstate == NETDEV_OPERSTATE_UP));
  1161. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_down, (collected_number)(d->operstate == NETDEV_OPERSTATE_DOWN));
  1162. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_notpresent, (collected_number)(d->operstate == NETDEV_OPERSTATE_NOTPRESENT));
  1163. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_lowerlayerdown, (collected_number)(d->operstate == NETDEV_OPERSTATE_LOWERLAYERDOWN));
  1164. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_testing, (collected_number)(d->operstate == NETDEV_OPERSTATE_TESTING));
  1165. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_dormant, (collected_number)(d->operstate == NETDEV_OPERSTATE_DORMANT));
  1166. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_unknown, (collected_number)(d->operstate == NETDEV_OPERSTATE_UNKNOWN));
  1167. rrdset_done(d->st_operstate);
  1168. }
  1169. if(d->do_carrier != CONFIG_BOOLEAN_NO && d->carrier_file_exists) {
  1170. if(unlikely(!d->st_carrier)) {
  1171. d->st_carrier = rrdset_create_localhost(
  1172. d->chart_type_net_carrier
  1173. , d->chart_id_net_carrier
  1174. , NULL
  1175. , d->chart_family
  1176. , d->chart_ctx_net_carrier
  1177. , "Interface Physical Link State"
  1178. , "state"
  1179. , PLUGIN_PROC_NAME
  1180. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1181. , d->priority + 10
  1182. , update_every
  1183. , RRDSET_TYPE_LINE
  1184. );
  1185. rrdset_flag_set(d->st_carrier, RRDSET_FLAG_DETAIL);
  1186. rrdset_update_rrdlabels(d->st_carrier, d->chart_labels);
  1187. d->rd_carrier_up = rrddim_add(d->st_carrier, "up", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1188. d->rd_carrier_down = rrddim_add(d->st_carrier, "down", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1189. }
  1190. rrddim_set_by_pointer(d->st_carrier, d->rd_carrier_up, (collected_number)(d->carrier == 1));
  1191. rrddim_set_by_pointer(d->st_carrier, d->rd_carrier_down, (collected_number)(d->carrier != 1));
  1192. rrdset_done(d->st_carrier);
  1193. }
  1194. if(d->do_mtu != CONFIG_BOOLEAN_NO && d->filename_mtu) {
  1195. if(unlikely(!d->st_mtu)) {
  1196. d->st_mtu = rrdset_create_localhost(
  1197. d->chart_type_net_mtu
  1198. , d->chart_id_net_mtu
  1199. , NULL
  1200. , d->chart_family
  1201. , d->chart_ctx_net_mtu
  1202. , "Interface MTU"
  1203. , "octets"
  1204. , PLUGIN_PROC_NAME
  1205. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1206. , d->priority + 11
  1207. , update_every
  1208. , RRDSET_TYPE_LINE
  1209. );
  1210. rrdset_flag_set(d->st_mtu, RRDSET_FLAG_DETAIL);
  1211. rrdset_update_rrdlabels(d->st_mtu, d->chart_labels);
  1212. d->rd_mtu = rrddim_add(d->st_mtu, "mtu", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  1213. }
  1214. rrddim_set_by_pointer(d->st_mtu, d->rd_mtu, (collected_number)d->mtu);
  1215. rrdset_done(d->st_mtu);
  1216. }
  1217. if(unlikely(d->do_packets == CONFIG_BOOLEAN_AUTO &&
  1218. (d->rpackets || d->tpackets || d->rmulticast || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1219. d->do_packets = CONFIG_BOOLEAN_YES;
  1220. if(d->do_packets == CONFIG_BOOLEAN_YES) {
  1221. if(unlikely(!d->st_packets)) {
  1222. d->st_packets = rrdset_create_localhost(
  1223. d->chart_type_net_packets
  1224. , d->chart_id_net_packets
  1225. , NULL
  1226. , d->chart_family
  1227. , d->chart_ctx_net_packets
  1228. , "Packets"
  1229. , "packets/s"
  1230. , PLUGIN_PROC_NAME
  1231. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1232. , d->priority + 1
  1233. , update_every
  1234. , RRDSET_TYPE_LINE
  1235. );
  1236. rrdset_flag_set(d->st_packets, RRDSET_FLAG_DETAIL);
  1237. rrdset_update_rrdlabels(d->st_packets, d->chart_labels);
  1238. d->rd_rpackets = rrddim_add(d->st_packets, "received", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1239. d->rd_tpackets = rrddim_add(d->st_packets, "sent", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1240. d->rd_rmulticast = rrddim_add(d->st_packets, "multicast", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1241. if(d->flipped) {
  1242. // flip receive/transmit
  1243. RRDDIM *td = d->rd_rpackets;
  1244. d->rd_rpackets = d->rd_tpackets;
  1245. d->rd_tpackets = td;
  1246. }
  1247. }
  1248. rrddim_set_by_pointer(d->st_packets, d->rd_rpackets, (collected_number)d->rpackets);
  1249. rrddim_set_by_pointer(d->st_packets, d->rd_tpackets, (collected_number)d->tpackets);
  1250. rrddim_set_by_pointer(d->st_packets, d->rd_rmulticast, (collected_number)d->rmulticast);
  1251. rrdset_done(d->st_packets);
  1252. }
  1253. if(unlikely(d->do_errors == CONFIG_BOOLEAN_AUTO &&
  1254. (d->rerrors || d->terrors || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1255. d->do_errors = CONFIG_BOOLEAN_YES;
  1256. if(d->do_errors == CONFIG_BOOLEAN_YES) {
  1257. if(unlikely(!d->st_errors)) {
  1258. d->st_errors = rrdset_create_localhost(
  1259. d->chart_type_net_errors
  1260. , d->chart_id_net_errors
  1261. , NULL
  1262. , d->chart_family
  1263. , d->chart_ctx_net_errors
  1264. , "Interface Errors"
  1265. , "errors/s"
  1266. , PLUGIN_PROC_NAME
  1267. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1268. , d->priority + 2
  1269. , update_every
  1270. , RRDSET_TYPE_LINE
  1271. );
  1272. rrdset_flag_set(d->st_errors, RRDSET_FLAG_DETAIL);
  1273. rrdset_update_rrdlabels(d->st_errors, d->chart_labels);
  1274. d->rd_rerrors = rrddim_add(d->st_errors, "inbound", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1275. d->rd_terrors = rrddim_add(d->st_errors, "outbound", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1276. if(d->flipped) {
  1277. // flip receive/transmit
  1278. RRDDIM *td = d->rd_rerrors;
  1279. d->rd_rerrors = d->rd_terrors;
  1280. d->rd_terrors = td;
  1281. }
  1282. }
  1283. rrddim_set_by_pointer(d->st_errors, d->rd_rerrors, (collected_number)d->rerrors);
  1284. rrddim_set_by_pointer(d->st_errors, d->rd_terrors, (collected_number)d->terrors);
  1285. rrdset_done(d->st_errors);
  1286. }
  1287. if(unlikely(d->do_drops == CONFIG_BOOLEAN_AUTO &&
  1288. (d->rdrops || d->tdrops || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1289. d->do_drops = CONFIG_BOOLEAN_YES;
  1290. if(d->do_drops == CONFIG_BOOLEAN_YES) {
  1291. if(unlikely(!d->st_drops)) {
  1292. d->st_drops = rrdset_create_localhost(
  1293. d->chart_type_net_drops
  1294. , d->chart_id_net_drops
  1295. , NULL
  1296. , d->chart_family
  1297. , d->chart_ctx_net_drops
  1298. , "Interface Drops"
  1299. , "drops/s"
  1300. , PLUGIN_PROC_NAME
  1301. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1302. , d->priority + 3
  1303. , update_every
  1304. , RRDSET_TYPE_LINE
  1305. );
  1306. rrdset_flag_set(d->st_drops, RRDSET_FLAG_DETAIL);
  1307. rrdset_update_rrdlabels(d->st_drops, d->chart_labels);
  1308. d->rd_rdrops = rrddim_add(d->st_drops, "inbound", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1309. d->rd_tdrops = rrddim_add(d->st_drops, "outbound", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1310. if(d->flipped) {
  1311. // flip receive/transmit
  1312. RRDDIM *td = d->rd_rdrops;
  1313. d->rd_rdrops = d->rd_tdrops;
  1314. d->rd_tdrops = td;
  1315. }
  1316. }
  1317. rrddim_set_by_pointer(d->st_drops, d->rd_rdrops, (collected_number)d->rdrops);
  1318. rrddim_set_by_pointer(d->st_drops, d->rd_tdrops, (collected_number)d->tdrops);
  1319. rrdset_done(d->st_drops);
  1320. }
  1321. if(unlikely(d->do_fifo == CONFIG_BOOLEAN_AUTO &&
  1322. (d->rfifo || d->tfifo || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1323. d->do_fifo = CONFIG_BOOLEAN_YES;
  1324. if(d->do_fifo == CONFIG_BOOLEAN_YES) {
  1325. if(unlikely(!d->st_fifo)) {
  1326. d->st_fifo = rrdset_create_localhost(
  1327. d->chart_type_net_fifo
  1328. , d->chart_id_net_fifo
  1329. , NULL
  1330. , d->chart_family
  1331. , d->chart_ctx_net_fifo
  1332. , "Interface FIFO Buffer Errors"
  1333. , "errors"
  1334. , PLUGIN_PROC_NAME
  1335. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1336. , d->priority + 4
  1337. , update_every
  1338. , RRDSET_TYPE_LINE
  1339. );
  1340. rrdset_flag_set(d->st_fifo, RRDSET_FLAG_DETAIL);
  1341. rrdset_update_rrdlabels(d->st_fifo, d->chart_labels);
  1342. d->rd_rfifo = rrddim_add(d->st_fifo, "receive", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1343. d->rd_tfifo = rrddim_add(d->st_fifo, "transmit", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1344. if(d->flipped) {
  1345. // flip receive/transmit
  1346. RRDDIM *td = d->rd_rfifo;
  1347. d->rd_rfifo = d->rd_tfifo;
  1348. d->rd_tfifo = td;
  1349. }
  1350. }
  1351. rrddim_set_by_pointer(d->st_fifo, d->rd_rfifo, (collected_number)d->rfifo);
  1352. rrddim_set_by_pointer(d->st_fifo, d->rd_tfifo, (collected_number)d->tfifo);
  1353. rrdset_done(d->st_fifo);
  1354. }
  1355. if(unlikely(d->do_compressed == CONFIG_BOOLEAN_AUTO &&
  1356. (d->rcompressed || d->tcompressed || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1357. d->do_compressed = CONFIG_BOOLEAN_YES;
  1358. if(d->do_compressed == CONFIG_BOOLEAN_YES) {
  1359. if(unlikely(!d->st_compressed)) {
  1360. d->st_compressed = rrdset_create_localhost(
  1361. d->chart_type_net_compressed
  1362. , d->chart_id_net_compressed
  1363. , NULL
  1364. , d->chart_family
  1365. , d->chart_ctx_net_compressed
  1366. , "Compressed Packets"
  1367. , "packets/s"
  1368. , PLUGIN_PROC_NAME
  1369. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1370. , d->priority + 5
  1371. , update_every
  1372. , RRDSET_TYPE_LINE
  1373. );
  1374. rrdset_flag_set(d->st_compressed, RRDSET_FLAG_DETAIL);
  1375. rrdset_update_rrdlabels(d->st_compressed, d->chart_labels);
  1376. d->rd_rcompressed = rrddim_add(d->st_compressed, "received", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1377. d->rd_tcompressed = rrddim_add(d->st_compressed, "sent", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1378. if(d->flipped) {
  1379. // flip receive/transmit
  1380. RRDDIM *td = d->rd_rcompressed;
  1381. d->rd_rcompressed = d->rd_tcompressed;
  1382. d->rd_tcompressed = td;
  1383. }
  1384. }
  1385. rrddim_set_by_pointer(d->st_compressed, d->rd_rcompressed, (collected_number)d->rcompressed);
  1386. rrddim_set_by_pointer(d->st_compressed, d->rd_tcompressed, (collected_number)d->tcompressed);
  1387. rrdset_done(d->st_compressed);
  1388. }
  1389. if(unlikely(d->do_events == CONFIG_BOOLEAN_AUTO &&
  1390. (d->rframe || d->tcollisions || d->tcarrier || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1391. d->do_events = CONFIG_BOOLEAN_YES;
  1392. if(d->do_events == CONFIG_BOOLEAN_YES) {
  1393. if(unlikely(!d->st_events)) {
  1394. d->st_events = rrdset_create_localhost(
  1395. d->chart_type_net_events
  1396. , d->chart_id_net_events
  1397. , NULL
  1398. , d->chart_family
  1399. , d->chart_ctx_net_events
  1400. , "Network Interface Events"
  1401. , "events/s"
  1402. , PLUGIN_PROC_NAME
  1403. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1404. , d->priority + 6
  1405. , update_every
  1406. , RRDSET_TYPE_LINE
  1407. );
  1408. rrdset_flag_set(d->st_events, RRDSET_FLAG_DETAIL);
  1409. rrdset_update_rrdlabels(d->st_events, d->chart_labels);
  1410. d->rd_rframe = rrddim_add(d->st_events, "frames", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1411. d->rd_tcollisions = rrddim_add(d->st_events, "collisions", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1412. d->rd_tcarrier = rrddim_add(d->st_events, "carrier", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1413. }
  1414. rrddim_set_by_pointer(d->st_events, d->rd_rframe, (collected_number)d->rframe);
  1415. rrddim_set_by_pointer(d->st_events, d->rd_tcollisions, (collected_number)d->tcollisions);
  1416. rrddim_set_by_pointer(d->st_events, d->rd_tcarrier, (collected_number)d->tcarrier);
  1417. rrdset_done(d->st_events);
  1418. }
  1419. d->function_ready = true;
  1420. }
  1421. if(do_bandwidth == CONFIG_BOOLEAN_YES || (do_bandwidth == CONFIG_BOOLEAN_AUTO &&
  1422. (system_rbytes || system_tbytes ||
  1423. netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
  1424. do_bandwidth = CONFIG_BOOLEAN_YES;
  1425. static RRDSET *st_system_net = NULL;
  1426. static RRDDIM *rd_in = NULL, *rd_out = NULL;
  1427. if(unlikely(!st_system_net)) {
  1428. st_system_net = rrdset_create_localhost(
  1429. "system"
  1430. , "net"
  1431. , NULL
  1432. , "network"
  1433. , NULL
  1434. , "Physical Network Interfaces Aggregated Bandwidth"
  1435. , "kilobits/s"
  1436. , PLUGIN_PROC_NAME
  1437. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1438. , NETDATA_CHART_PRIO_SYSTEM_NET
  1439. , update_every
  1440. , RRDSET_TYPE_AREA
  1441. );
  1442. rd_in = rrddim_add(st_system_net, "InOctets", "received", 8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1443. rd_out = rrddim_add(st_system_net, "OutOctets", "sent", -8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1444. }
  1445. rrddim_set_by_pointer(st_system_net, rd_in, (collected_number)system_rbytes);
  1446. rrddim_set_by_pointer(st_system_net, rd_out, (collected_number)system_tbytes);
  1447. rrdset_done(st_system_net);
  1448. }
  1449. netdev_cleanup();
  1450. return 0;
  1451. }
  1452. static void netdev_main_cleanup(void *ptr)
  1453. {
  1454. UNUSED(ptr);
  1455. collector_info("cleaning up...");
  1456. worker_unregister();
  1457. }
  1458. void *netdev_main(void *ptr)
  1459. {
  1460. worker_register("NETDEV");
  1461. worker_register_job_name(0, "netdev");
  1462. if (getenv("KUBERNETES_SERVICE_HOST") != NULL && getenv("KUBERNETES_SERVICE_PORT") != NULL)
  1463. double_linked_device_collect_delay_secs = 300;
  1464. rrd_function_add_inline(localhost, NULL, "network-interfaces", 10,
  1465. RRDFUNCTIONS_PRIORITY_DEFAULT, RRDFUNCTIONS_NETDEV_HELP,
  1466. "top", HTTP_ACCESS_ANY, netdev_function_net_interfaces);
  1467. netdata_thread_cleanup_push(netdev_main_cleanup, ptr) {
  1468. usec_t step = localhost->rrd_update_every * USEC_PER_SEC;
  1469. heartbeat_t hb;
  1470. heartbeat_init(&hb);
  1471. while (service_running(SERVICE_COLLECTORS)) {
  1472. worker_is_idle();
  1473. usec_t hb_dt = heartbeat_next(&hb, step);
  1474. if (unlikely(!service_running(SERVICE_COLLECTORS)))
  1475. break;
  1476. cgroup_netdev_reset_all();
  1477. worker_is_busy(0);
  1478. netdata_mutex_lock(&netdev_mutex);
  1479. if (do_proc_net_dev(localhost->rrd_update_every, hb_dt))
  1480. break;
  1481. netdata_mutex_unlock(&netdev_mutex);
  1482. }
  1483. }
  1484. netdata_thread_cleanup_pop(1);
  1485. return NULL;
  1486. }