proc_net_dev.c 55 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386
  1. // SPDX-License-Identifier: GPL-3.0-or-later
  2. #include "plugin_proc.h"
  3. #define PLUGIN_PROC_MODULE_NETDEV_NAME "/proc/net/dev"
  4. #define CONFIG_SECTION_PLUGIN_PROC_NETDEV "plugin:" PLUGIN_PROC_CONFIG_NAME ":" PLUGIN_PROC_MODULE_NETDEV_NAME
  5. #define STATE_LENGTH_MAX 32
  6. // As defined in https://www.kernel.org/doc/Documentation/ABI/testing/sysfs-class-net
  7. const char *operstate_names[] = { "unknown", "notpresent", "down", "lowerlayerdown", "testing", "dormant", "up" };
  8. static inline int get_operstate(char *operstate)
  9. {
  10. int i;
  11. for (i = 0; i < (int) (sizeof(operstate_names) / sizeof(char *)); i++) {
  12. if (!strcmp(operstate, operstate_names[i])) {
  13. return i;
  14. }
  15. }
  16. return 0;
  17. }
  18. // ----------------------------------------------------------------------------
  19. // netdev list
  20. static struct netdev {
  21. char *name;
  22. uint32_t hash;
  23. size_t len;
  24. // flags
  25. int virtual;
  26. int configured;
  27. int enabled;
  28. int updated;
  29. int do_bandwidth;
  30. int do_packets;
  31. int do_errors;
  32. int do_drops;
  33. int do_fifo;
  34. int do_compressed;
  35. int do_events;
  36. int do_speed;
  37. int do_duplex;
  38. int do_operstate;
  39. int do_carrier;
  40. int do_mtu;
  41. const char *chart_type_net_bytes;
  42. const char *chart_type_net_packets;
  43. const char *chart_type_net_errors;
  44. const char *chart_type_net_fifo;
  45. const char *chart_type_net_events;
  46. const char *chart_type_net_drops;
  47. const char *chart_type_net_compressed;
  48. const char *chart_type_net_speed;
  49. const char *chart_type_net_duplex;
  50. const char *chart_type_net_operstate;
  51. const char *chart_type_net_carrier;
  52. const char *chart_type_net_mtu;
  53. const char *chart_id_net_bytes;
  54. const char *chart_id_net_packets;
  55. const char *chart_id_net_errors;
  56. const char *chart_id_net_fifo;
  57. const char *chart_id_net_events;
  58. const char *chart_id_net_drops;
  59. const char *chart_id_net_compressed;
  60. const char *chart_id_net_speed;
  61. const char *chart_id_net_duplex;
  62. const char *chart_id_net_operstate;
  63. const char *chart_id_net_carrier;
  64. const char *chart_id_net_mtu;
  65. const char *chart_ctx_net_bytes;
  66. const char *chart_ctx_net_packets;
  67. const char *chart_ctx_net_errors;
  68. const char *chart_ctx_net_fifo;
  69. const char *chart_ctx_net_events;
  70. const char *chart_ctx_net_drops;
  71. const char *chart_ctx_net_compressed;
  72. const char *chart_ctx_net_speed;
  73. const char *chart_ctx_net_duplex;
  74. const char *chart_ctx_net_operstate;
  75. const char *chart_ctx_net_carrier;
  76. const char *chart_ctx_net_mtu;
  77. const char *chart_family;
  78. struct label *chart_labels;
  79. int flipped;
  80. unsigned long priority;
  81. // data collected
  82. kernel_uint_t rbytes;
  83. kernel_uint_t rpackets;
  84. kernel_uint_t rerrors;
  85. kernel_uint_t rdrops;
  86. kernel_uint_t rfifo;
  87. kernel_uint_t rframe;
  88. kernel_uint_t rcompressed;
  89. kernel_uint_t rmulticast;
  90. kernel_uint_t tbytes;
  91. kernel_uint_t tpackets;
  92. kernel_uint_t terrors;
  93. kernel_uint_t tdrops;
  94. kernel_uint_t tfifo;
  95. kernel_uint_t tcollisions;
  96. kernel_uint_t tcarrier;
  97. kernel_uint_t tcompressed;
  98. kernel_uint_t speed;
  99. kernel_uint_t duplex;
  100. kernel_uint_t operstate;
  101. unsigned long long carrier;
  102. unsigned long long mtu;
  103. // charts
  104. RRDSET *st_bandwidth;
  105. RRDSET *st_packets;
  106. RRDSET *st_errors;
  107. RRDSET *st_drops;
  108. RRDSET *st_fifo;
  109. RRDSET *st_compressed;
  110. RRDSET *st_events;
  111. RRDSET *st_speed;
  112. RRDSET *st_duplex;
  113. RRDSET *st_operstate;
  114. RRDSET *st_carrier;
  115. RRDSET *st_mtu;
  116. // dimensions
  117. RRDDIM *rd_rbytes;
  118. RRDDIM *rd_rpackets;
  119. RRDDIM *rd_rerrors;
  120. RRDDIM *rd_rdrops;
  121. RRDDIM *rd_rfifo;
  122. RRDDIM *rd_rframe;
  123. RRDDIM *rd_rcompressed;
  124. RRDDIM *rd_rmulticast;
  125. RRDDIM *rd_tbytes;
  126. RRDDIM *rd_tpackets;
  127. RRDDIM *rd_terrors;
  128. RRDDIM *rd_tdrops;
  129. RRDDIM *rd_tfifo;
  130. RRDDIM *rd_tcollisions;
  131. RRDDIM *rd_tcarrier;
  132. RRDDIM *rd_tcompressed;
  133. RRDDIM *rd_speed;
  134. RRDDIM *rd_duplex;
  135. RRDDIM *rd_operstate;
  136. RRDDIM *rd_carrier;
  137. RRDDIM *rd_mtu;
  138. char *filename_speed;
  139. RRDSETVAR *chart_var_speed;
  140. char *filename_duplex;
  141. char *filename_operstate;
  142. char *filename_carrier;
  143. char *filename_mtu;
  144. struct netdev *next;
  145. } *netdev_root = NULL, *netdev_last_used = NULL;
  146. static size_t netdev_added = 0, netdev_found = 0;
  147. // ----------------------------------------------------------------------------
  148. static void netdev_charts_release(struct netdev *d) {
  149. if(d->st_bandwidth) rrdset_is_obsolete(d->st_bandwidth);
  150. if(d->st_packets) rrdset_is_obsolete(d->st_packets);
  151. if(d->st_errors) rrdset_is_obsolete(d->st_errors);
  152. if(d->st_drops) rrdset_is_obsolete(d->st_drops);
  153. if(d->st_fifo) rrdset_is_obsolete(d->st_fifo);
  154. if(d->st_compressed) rrdset_is_obsolete(d->st_compressed);
  155. if(d->st_events) rrdset_is_obsolete(d->st_events);
  156. if(d->st_speed) rrdset_is_obsolete(d->st_speed);
  157. if(d->st_duplex) rrdset_is_obsolete(d->st_duplex);
  158. if(d->st_operstate) rrdset_is_obsolete(d->st_operstate);
  159. if(d->st_carrier) rrdset_is_obsolete(d->st_carrier);
  160. if(d->st_mtu) rrdset_is_obsolete(d->st_mtu);
  161. d->st_bandwidth = NULL;
  162. d->st_compressed = NULL;
  163. d->st_drops = NULL;
  164. d->st_errors = NULL;
  165. d->st_events = NULL;
  166. d->st_fifo = NULL;
  167. d->st_packets = NULL;
  168. d->st_speed = NULL;
  169. d->st_duplex = NULL;
  170. d->st_operstate = NULL;
  171. d->st_carrier = NULL;
  172. d->st_mtu = NULL;
  173. d->rd_rbytes = NULL;
  174. d->rd_rpackets = NULL;
  175. d->rd_rerrors = NULL;
  176. d->rd_rdrops = NULL;
  177. d->rd_rfifo = NULL;
  178. d->rd_rframe = NULL;
  179. d->rd_rcompressed = NULL;
  180. d->rd_rmulticast = NULL;
  181. d->rd_tbytes = NULL;
  182. d->rd_tpackets = NULL;
  183. d->rd_terrors = NULL;
  184. d->rd_tdrops = NULL;
  185. d->rd_tfifo = NULL;
  186. d->rd_tcollisions = NULL;
  187. d->rd_tcarrier = NULL;
  188. d->rd_tcompressed = NULL;
  189. d->rd_speed = NULL;
  190. d->rd_duplex = NULL;
  191. d->rd_operstate = NULL;
  192. d->rd_carrier = NULL;
  193. d->rd_mtu = NULL;
  194. d->chart_var_speed = NULL;
  195. }
  196. static void netdev_free_chart_strings(struct netdev *d) {
  197. freez((void *)d->chart_type_net_bytes);
  198. freez((void *)d->chart_type_net_compressed);
  199. freez((void *)d->chart_type_net_drops);
  200. freez((void *)d->chart_type_net_errors);
  201. freez((void *)d->chart_type_net_events);
  202. freez((void *)d->chart_type_net_fifo);
  203. freez((void *)d->chart_type_net_packets);
  204. freez((void *)d->chart_type_net_speed);
  205. freez((void *)d->chart_type_net_duplex);
  206. freez((void *)d->chart_type_net_operstate);
  207. freez((void *)d->chart_type_net_carrier);
  208. freez((void *)d->chart_type_net_mtu);
  209. freez((void *)d->chart_id_net_bytes);
  210. freez((void *)d->chart_id_net_compressed);
  211. freez((void *)d->chart_id_net_drops);
  212. freez((void *)d->chart_id_net_errors);
  213. freez((void *)d->chart_id_net_events);
  214. freez((void *)d->chart_id_net_fifo);
  215. freez((void *)d->chart_id_net_packets);
  216. freez((void *)d->chart_id_net_speed);
  217. freez((void *)d->chart_id_net_duplex);
  218. freez((void *)d->chart_id_net_operstate);
  219. freez((void *)d->chart_id_net_carrier);
  220. freez((void *)d->chart_id_net_mtu);
  221. freez((void *)d->chart_ctx_net_bytes);
  222. freez((void *)d->chart_ctx_net_compressed);
  223. freez((void *)d->chart_ctx_net_drops);
  224. freez((void *)d->chart_ctx_net_errors);
  225. freez((void *)d->chart_ctx_net_events);
  226. freez((void *)d->chart_ctx_net_fifo);
  227. freez((void *)d->chart_ctx_net_packets);
  228. freez((void *)d->chart_ctx_net_speed);
  229. freez((void *)d->chart_ctx_net_duplex);
  230. freez((void *)d->chart_ctx_net_operstate);
  231. freez((void *)d->chart_ctx_net_carrier);
  232. freez((void *)d->chart_ctx_net_mtu);
  233. freez((void *)d->chart_family);
  234. }
  235. static void netdev_free(struct netdev *d) {
  236. netdev_charts_release(d);
  237. netdev_free_chart_strings(d);
  238. free_label_list(d->chart_labels);
  239. freez((void *)d->name);
  240. freez((void *)d->filename_speed);
  241. freez((void *)d->filename_duplex);
  242. freez((void *)d->filename_operstate);
  243. freez((void *)d->filename_carrier);
  244. freez((void *)d->filename_mtu);
  245. freez((void *)d);
  246. netdev_added--;
  247. }
  248. // ----------------------------------------------------------------------------
  249. // netdev renames
  250. static struct netdev_rename {
  251. const char *host_device;
  252. uint32_t hash;
  253. const char *container_device;
  254. const char *container_name;
  255. struct label *chart_labels;
  256. int processed;
  257. struct netdev_rename *next;
  258. } *netdev_rename_root = NULL;
  259. static int netdev_pending_renames = 0;
  260. static netdata_mutex_t netdev_rename_mutex = NETDATA_MUTEX_INITIALIZER;
  261. static struct netdev_rename *netdev_rename_find(const char *host_device, uint32_t hash) {
  262. struct netdev_rename *r;
  263. for(r = netdev_rename_root; r ; r = r->next)
  264. if(r->hash == hash && !strcmp(host_device, r->host_device))
  265. return r;
  266. return NULL;
  267. }
  268. // other threads can call this function to register a rename to a netdev
  269. void netdev_rename_device_add(
  270. const char *host_device, const char *container_device, const char *container_name, struct label *labels)
  271. {
  272. netdata_mutex_lock(&netdev_rename_mutex);
  273. uint32_t hash = simple_hash(host_device);
  274. struct netdev_rename *r = netdev_rename_find(host_device, hash);
  275. if(!r) {
  276. r = callocz(1, sizeof(struct netdev_rename));
  277. r->host_device = strdupz(host_device);
  278. r->container_device = strdupz(container_device);
  279. r->container_name = strdupz(container_name);
  280. update_label_list(&r->chart_labels, labels);
  281. r->hash = hash;
  282. r->next = netdev_rename_root;
  283. r->processed = 0;
  284. netdev_rename_root = r;
  285. netdev_pending_renames++;
  286. info("CGROUP: registered network interface rename for '%s' as '%s' under '%s'", r->host_device, r->container_device, r->container_name);
  287. }
  288. else {
  289. if(strcmp(r->container_device, container_device) != 0 || strcmp(r->container_name, container_name) != 0) {
  290. freez((void *) r->container_device);
  291. freez((void *) r->container_name);
  292. r->container_device = strdupz(container_device);
  293. r->container_name = strdupz(container_name);
  294. update_label_list(&r->chart_labels, labels);
  295. r->processed = 0;
  296. netdev_pending_renames++;
  297. info("CGROUP: altered network interface rename for '%s' as '%s' under '%s'", r->host_device, r->container_device, r->container_name);
  298. }
  299. }
  300. netdata_mutex_unlock(&netdev_rename_mutex);
  301. }
  302. // other threads can call this function to delete a rename to a netdev
  303. void netdev_rename_device_del(const char *host_device) {
  304. netdata_mutex_lock(&netdev_rename_mutex);
  305. struct netdev_rename *r, *last = NULL;
  306. uint32_t hash = simple_hash(host_device);
  307. for(r = netdev_rename_root; r ; last = r, r = r->next) {
  308. if (r->hash == hash && !strcmp(host_device, r->host_device)) {
  309. if (netdev_rename_root == r)
  310. netdev_rename_root = r->next;
  311. else if (last)
  312. last->next = r->next;
  313. if(!r->processed)
  314. netdev_pending_renames--;
  315. info("CGROUP: unregistered network interface rename for '%s' as '%s' under '%s'", r->host_device, r->container_device, r->container_name);
  316. freez((void *) r->host_device);
  317. freez((void *) r->container_name);
  318. freez((void *) r->container_device);
  319. free_label_list(r->chart_labels);
  320. freez((void *) r);
  321. break;
  322. }
  323. }
  324. netdata_mutex_unlock(&netdev_rename_mutex);
  325. }
  326. static inline void netdev_rename_cgroup(struct netdev *d, struct netdev_rename *r) {
  327. info("CGROUP: renaming network interface '%s' as '%s' under '%s'", r->host_device, r->container_device, r->container_name);
  328. netdev_charts_release(d);
  329. netdev_free_chart_strings(d);
  330. char buffer[RRD_ID_LENGTH_MAX + 1];
  331. snprintfz(buffer, RRD_ID_LENGTH_MAX, "cgroup_%s", r->container_name);
  332. d->chart_type_net_bytes = strdupz(buffer);
  333. d->chart_type_net_compressed = strdupz(buffer);
  334. d->chart_type_net_drops = strdupz(buffer);
  335. d->chart_type_net_errors = strdupz(buffer);
  336. d->chart_type_net_events = strdupz(buffer);
  337. d->chart_type_net_fifo = strdupz(buffer);
  338. d->chart_type_net_packets = strdupz(buffer);
  339. d->chart_type_net_speed = strdupz(buffer);
  340. d->chart_type_net_duplex = strdupz(buffer);
  341. d->chart_type_net_operstate = strdupz(buffer);
  342. d->chart_type_net_carrier = strdupz(buffer);
  343. d->chart_type_net_mtu = strdupz(buffer);
  344. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_%s", r->container_device);
  345. d->chart_id_net_bytes = strdupz(buffer);
  346. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_compressed_%s", r->container_device);
  347. d->chart_id_net_compressed = strdupz(buffer);
  348. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_drops_%s", r->container_device);
  349. d->chart_id_net_drops = strdupz(buffer);
  350. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_errors_%s", r->container_device);
  351. d->chart_id_net_errors = strdupz(buffer);
  352. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_events_%s", r->container_device);
  353. d->chart_id_net_events = strdupz(buffer);
  354. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_fifo_%s", r->container_device);
  355. d->chart_id_net_fifo = strdupz(buffer);
  356. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_packets_%s", r->container_device);
  357. d->chart_id_net_packets = strdupz(buffer);
  358. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_speed_%s", r->container_device);
  359. d->chart_id_net_speed = strdupz(buffer);
  360. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_duplex_%s", r->container_device);
  361. d->chart_id_net_duplex = strdupz(buffer);
  362. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_operstate_%s", r->container_device);
  363. d->chart_id_net_operstate = strdupz(buffer);
  364. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_carrier_%s", r->container_device);
  365. d->chart_id_net_carrier = strdupz(buffer);
  366. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_mtu_%s", r->container_device);
  367. d->chart_id_net_mtu = strdupz(buffer);
  368. d->chart_ctx_net_bytes = strdupz("cgroup.net_net");
  369. d->chart_ctx_net_compressed = strdupz("cgroup.net_compressed");
  370. d->chart_ctx_net_drops = strdupz("cgroup.net_drops");
  371. d->chart_ctx_net_errors = strdupz("cgroup.net_errors");
  372. d->chart_ctx_net_events = strdupz("cgroup.net_events");
  373. d->chart_ctx_net_fifo = strdupz("cgroup.net_fifo");
  374. d->chart_ctx_net_packets = strdupz("cgroup.net_packets");
  375. d->chart_ctx_net_speed = strdupz("cgroup.net_speed");
  376. d->chart_ctx_net_duplex = strdupz("cgroup.net_duplex");
  377. d->chart_ctx_net_operstate = strdupz("cgroup.net_operstate");
  378. d->chart_ctx_net_carrier = strdupz("cgroup.net_carrier");
  379. d->chart_ctx_net_mtu = strdupz("cgroup.net_mtu");
  380. snprintfz(buffer, RRD_ID_LENGTH_MAX, "net %s", r->container_device);
  381. d->chart_family = strdupz(buffer);
  382. update_label_list(&d->chart_labels, r->chart_labels);
  383. d->priority = NETDATA_CHART_PRIO_CGROUP_NET_IFACE;
  384. d->flipped = 1;
  385. }
  386. static inline void netdev_rename(struct netdev *d) {
  387. struct netdev_rename *r = netdev_rename_find(d->name, d->hash);
  388. if(unlikely(r && !r->processed)) {
  389. netdev_rename_cgroup(d, r);
  390. r->processed = 1;
  391. netdev_pending_renames--;
  392. }
  393. }
  394. static inline void netdev_rename_lock(struct netdev *d) {
  395. netdata_mutex_lock(&netdev_rename_mutex);
  396. netdev_rename(d);
  397. netdata_mutex_unlock(&netdev_rename_mutex);
  398. }
  399. static inline void netdev_rename_all_lock(void) {
  400. netdata_mutex_lock(&netdev_rename_mutex);
  401. struct netdev *d;
  402. for(d = netdev_root; d ; d = d->next)
  403. netdev_rename(d);
  404. netdev_pending_renames = 0;
  405. netdata_mutex_unlock(&netdev_rename_mutex);
  406. }
  407. // ----------------------------------------------------------------------------
  408. // netdev data collection
  409. static void netdev_cleanup() {
  410. if(likely(netdev_found == netdev_added)) return;
  411. netdev_added = 0;
  412. struct netdev *d = netdev_root, *last = NULL;
  413. while(d) {
  414. if(unlikely(!d->updated)) {
  415. // info("Removing network device '%s', linked after '%s'", d->name, last?last->name:"ROOT");
  416. if(netdev_last_used == d)
  417. netdev_last_used = last;
  418. struct netdev *t = d;
  419. if(d == netdev_root || !last)
  420. netdev_root = d = d->next;
  421. else
  422. last->next = d = d->next;
  423. t->next = NULL;
  424. netdev_free(t);
  425. }
  426. else {
  427. netdev_added++;
  428. last = d;
  429. d->updated = 0;
  430. d = d->next;
  431. }
  432. }
  433. }
  434. static struct netdev *get_netdev(const char *name) {
  435. struct netdev *d;
  436. uint32_t hash = simple_hash(name);
  437. // search it, from the last position to the end
  438. for(d = netdev_last_used ; d ; d = d->next) {
  439. if(unlikely(hash == d->hash && !strcmp(name, d->name))) {
  440. netdev_last_used = d->next;
  441. return d;
  442. }
  443. }
  444. // search it from the beginning to the last position we used
  445. for(d = netdev_root ; d != netdev_last_used ; d = d->next) {
  446. if(unlikely(hash == d->hash && !strcmp(name, d->name))) {
  447. netdev_last_used = d->next;
  448. return d;
  449. }
  450. }
  451. // create a new one
  452. d = callocz(1, sizeof(struct netdev));
  453. d->name = strdupz(name);
  454. d->hash = simple_hash(d->name);
  455. d->len = strlen(d->name);
  456. d->chart_type_net_bytes = strdupz("net");
  457. d->chart_type_net_compressed = strdupz("net_compressed");
  458. d->chart_type_net_drops = strdupz("net_drops");
  459. d->chart_type_net_errors = strdupz("net_errors");
  460. d->chart_type_net_events = strdupz("net_events");
  461. d->chart_type_net_fifo = strdupz("net_fifo");
  462. d->chart_type_net_packets = strdupz("net_packets");
  463. d->chart_type_net_speed = strdupz("net_speed");
  464. d->chart_type_net_duplex = strdupz("net_duplex");
  465. d->chart_type_net_operstate = strdupz("net_operstate");
  466. d->chart_type_net_carrier = strdupz("net_carrier");
  467. d->chart_type_net_mtu = strdupz("net_mtu");
  468. d->chart_id_net_bytes = strdupz(d->name);
  469. d->chart_id_net_compressed = strdupz(d->name);
  470. d->chart_id_net_drops = strdupz(d->name);
  471. d->chart_id_net_errors = strdupz(d->name);
  472. d->chart_id_net_events = strdupz(d->name);
  473. d->chart_id_net_fifo = strdupz(d->name);
  474. d->chart_id_net_packets = strdupz(d->name);
  475. d->chart_id_net_speed = strdupz(d->name);
  476. d->chart_id_net_duplex = strdupz(d->name);
  477. d->chart_id_net_operstate = strdupz(d->name);
  478. d->chart_id_net_carrier = strdupz(d->name);
  479. d->chart_id_net_mtu = strdupz(d->name);
  480. d->chart_ctx_net_bytes = strdupz("net.net");
  481. d->chart_ctx_net_compressed = strdupz("net.compressed");
  482. d->chart_ctx_net_drops = strdupz("net.drops");
  483. d->chart_ctx_net_errors = strdupz("net.errors");
  484. d->chart_ctx_net_events = strdupz("net.events");
  485. d->chart_ctx_net_fifo = strdupz("net.fifo");
  486. d->chart_ctx_net_packets = strdupz("net.packets");
  487. d->chart_ctx_net_speed = strdupz("net.speed");
  488. d->chart_ctx_net_duplex = strdupz("net.duplex");
  489. d->chart_ctx_net_operstate = strdupz("net.operstate");
  490. d->chart_ctx_net_carrier = strdupz("net.carrier");
  491. d->chart_ctx_net_mtu = strdupz("net.mtu");
  492. d->chart_family = strdupz(d->name);
  493. d->priority = NETDATA_CHART_PRIO_FIRST_NET_IFACE;
  494. netdev_rename_lock(d);
  495. netdev_added++;
  496. // link it to the end
  497. if(netdev_root) {
  498. struct netdev *e;
  499. for(e = netdev_root; e->next ; e = e->next) ;
  500. e->next = d;
  501. }
  502. else
  503. netdev_root = d;
  504. return d;
  505. }
  506. int do_proc_net_dev(int update_every, usec_t dt) {
  507. (void)dt;
  508. static SIMPLE_PATTERN *disabled_list = NULL;
  509. static procfile *ff = NULL;
  510. static int enable_new_interfaces = -1;
  511. static int do_bandwidth = -1, do_packets = -1, do_errors = -1, do_drops = -1, do_fifo = -1, do_compressed = -1,
  512. do_events = -1, do_speed = -1, do_duplex = -1, do_operstate = -1, do_carrier = -1, do_mtu = -1;
  513. static char *path_to_sys_devices_virtual_net = NULL, *path_to_sys_class_net_speed = NULL,
  514. *proc_net_dev_filename = NULL;
  515. static char *path_to_sys_class_net_duplex = NULL;
  516. static char *path_to_sys_class_net_operstate = NULL;
  517. static char *path_to_sys_class_net_carrier = NULL;
  518. static char *path_to_sys_class_net_mtu = NULL;
  519. if(unlikely(enable_new_interfaces == -1)) {
  520. char filename[FILENAME_MAX + 1];
  521. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, (*netdata_configured_host_prefix)?"/proc/1/net/dev":"/proc/net/dev");
  522. proc_net_dev_filename = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "filename to monitor", filename);
  523. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/devices/virtual/net/%s");
  524. path_to_sys_devices_virtual_net = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get virtual interfaces", filename);
  525. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/speed");
  526. path_to_sys_class_net_speed = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device speed", filename);
  527. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/duplex");
  528. path_to_sys_class_net_duplex = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device duplex", filename);
  529. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/operstate");
  530. path_to_sys_class_net_operstate = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device operstate", filename);
  531. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/carrier");
  532. path_to_sys_class_net_carrier = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device carrier", filename);
  533. snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/mtu");
  534. path_to_sys_class_net_mtu = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device mtu", filename);
  535. enable_new_interfaces = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "enable new interfaces detected at runtime", CONFIG_BOOLEAN_AUTO);
  536. do_bandwidth = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "bandwidth for all interfaces", CONFIG_BOOLEAN_AUTO);
  537. do_packets = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "packets for all interfaces", CONFIG_BOOLEAN_AUTO);
  538. do_errors = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "errors for all interfaces", CONFIG_BOOLEAN_AUTO);
  539. do_drops = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "drops for all interfaces", CONFIG_BOOLEAN_AUTO);
  540. do_fifo = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "fifo for all interfaces", CONFIG_BOOLEAN_AUTO);
  541. do_compressed = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "compressed packets for all interfaces", CONFIG_BOOLEAN_AUTO);
  542. do_events = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "frames, collisions, carrier counters for all interfaces", CONFIG_BOOLEAN_AUTO);
  543. do_speed = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "speed for all interfaces", CONFIG_BOOLEAN_AUTO);
  544. do_duplex = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "duplex for all interfaces", CONFIG_BOOLEAN_AUTO);
  545. do_operstate = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "operstate for all interfaces", CONFIG_BOOLEAN_AUTO);
  546. do_carrier = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "carrier for all interfaces", CONFIG_BOOLEAN_AUTO);
  547. do_mtu = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "mtu for all interfaces", CONFIG_BOOLEAN_AUTO);
  548. disabled_list = simple_pattern_create(config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "disable by default interfaces matching", "lo fireqos* *-ifb"), NULL, SIMPLE_PATTERN_EXACT);
  549. }
  550. if(unlikely(!ff)) {
  551. ff = procfile_open(proc_net_dev_filename, " \t,|", PROCFILE_FLAG_DEFAULT);
  552. if(unlikely(!ff)) return 1;
  553. }
  554. ff = procfile_readall(ff);
  555. if(unlikely(!ff)) return 0; // we return 0, so that we will retry to open it next time
  556. // rename all the devices, if we have pending renames
  557. if(unlikely(netdev_pending_renames))
  558. netdev_rename_all_lock();
  559. netdev_found = 0;
  560. kernel_uint_t system_rbytes = 0;
  561. kernel_uint_t system_tbytes = 0;
  562. size_t lines = procfile_lines(ff), l;
  563. for(l = 2; l < lines ;l++) {
  564. // require 17 words on each line
  565. if(unlikely(procfile_linewords(ff, l) < 17)) continue;
  566. char *name = procfile_lineword(ff, l, 0);
  567. size_t len = strlen(name);
  568. if(name[len - 1] == ':') name[len - 1] = '\0';
  569. struct netdev *d = get_netdev(name);
  570. d->updated = 1;
  571. netdev_found++;
  572. if(unlikely(!d->configured)) {
  573. // this is the first time we see this interface
  574. // remember we configured it
  575. d->configured = 1;
  576. d->enabled = enable_new_interfaces;
  577. if(d->enabled)
  578. d->enabled = !simple_pattern_matches(disabled_list, d->name);
  579. char buffer[FILENAME_MAX + 1];
  580. snprintfz(buffer, FILENAME_MAX, path_to_sys_devices_virtual_net, d->name);
  581. if(likely(access(buffer, R_OK) == 0)) {
  582. d->virtual = 1;
  583. }
  584. else
  585. d->virtual = 0;
  586. if(likely(!d->virtual)) {
  587. // set the filename to get the interface speed
  588. snprintfz(buffer, FILENAME_MAX, path_to_sys_class_net_speed, d->name);
  589. d->filename_speed = strdupz(buffer);
  590. snprintfz(buffer, FILENAME_MAX, path_to_sys_class_net_duplex, d->name);
  591. d->filename_duplex = strdupz(buffer);
  592. }
  593. snprintfz(buffer, FILENAME_MAX, path_to_sys_class_net_operstate, d->name);
  594. d->filename_operstate = strdupz(buffer);
  595. snprintfz(buffer, FILENAME_MAX, path_to_sys_class_net_carrier, d->name);
  596. d->filename_carrier = strdupz(buffer);
  597. snprintfz(buffer, FILENAME_MAX, path_to_sys_class_net_mtu, d->name);
  598. d->filename_mtu = strdupz(buffer);
  599. snprintfz(buffer, FILENAME_MAX, "plugin:proc:/proc/net/dev:%s", d->name);
  600. d->enabled = config_get_boolean_ondemand(buffer, "enabled", d->enabled);
  601. d->virtual = config_get_boolean(buffer, "virtual", d->virtual);
  602. if(d->enabled == CONFIG_BOOLEAN_NO)
  603. continue;
  604. d->do_bandwidth = config_get_boolean_ondemand(buffer, "bandwidth", do_bandwidth);
  605. d->do_packets = config_get_boolean_ondemand(buffer, "packets", do_packets);
  606. d->do_errors = config_get_boolean_ondemand(buffer, "errors", do_errors);
  607. d->do_drops = config_get_boolean_ondemand(buffer, "drops", do_drops);
  608. d->do_fifo = config_get_boolean_ondemand(buffer, "fifo", do_fifo);
  609. d->do_compressed = config_get_boolean_ondemand(buffer, "compressed", do_compressed);
  610. d->do_events = config_get_boolean_ondemand(buffer, "events", do_events);
  611. d->do_speed = config_get_boolean_ondemand(buffer, "speed", do_speed);
  612. d->do_duplex = config_get_boolean_ondemand(buffer, "duplex", do_duplex);
  613. d->do_operstate = config_get_boolean_ondemand(buffer, "operstate", do_operstate);
  614. d->do_carrier = config_get_boolean_ondemand(buffer, "carrier", do_carrier);
  615. d->do_mtu = config_get_boolean_ondemand(buffer, "mtu", do_mtu);
  616. }
  617. if(unlikely(!d->enabled))
  618. continue;
  619. if(likely(d->do_bandwidth != CONFIG_BOOLEAN_NO || !d->virtual)) {
  620. d->rbytes = str2kernel_uint_t(procfile_lineword(ff, l, 1));
  621. d->tbytes = str2kernel_uint_t(procfile_lineword(ff, l, 9));
  622. if(likely(!d->virtual)) {
  623. system_rbytes += d->rbytes;
  624. system_tbytes += d->tbytes;
  625. }
  626. }
  627. if(likely(d->do_packets != CONFIG_BOOLEAN_NO)) {
  628. d->rpackets = str2kernel_uint_t(procfile_lineword(ff, l, 2));
  629. d->rmulticast = str2kernel_uint_t(procfile_lineword(ff, l, 8));
  630. d->tpackets = str2kernel_uint_t(procfile_lineword(ff, l, 10));
  631. }
  632. if(likely(d->do_errors != CONFIG_BOOLEAN_NO)) {
  633. d->rerrors = str2kernel_uint_t(procfile_lineword(ff, l, 3));
  634. d->terrors = str2kernel_uint_t(procfile_lineword(ff, l, 11));
  635. }
  636. if(likely(d->do_drops != CONFIG_BOOLEAN_NO)) {
  637. d->rdrops = str2kernel_uint_t(procfile_lineword(ff, l, 4));
  638. d->tdrops = str2kernel_uint_t(procfile_lineword(ff, l, 12));
  639. }
  640. if(likely(d->do_fifo != CONFIG_BOOLEAN_NO)) {
  641. d->rfifo = str2kernel_uint_t(procfile_lineword(ff, l, 5));
  642. d->tfifo = str2kernel_uint_t(procfile_lineword(ff, l, 13));
  643. }
  644. if(likely(d->do_compressed != CONFIG_BOOLEAN_NO)) {
  645. d->rcompressed = str2kernel_uint_t(procfile_lineword(ff, l, 7));
  646. d->tcompressed = str2kernel_uint_t(procfile_lineword(ff, l, 16));
  647. }
  648. if(likely(d->do_events != CONFIG_BOOLEAN_NO)) {
  649. d->rframe = str2kernel_uint_t(procfile_lineword(ff, l, 6));
  650. d->tcollisions = str2kernel_uint_t(procfile_lineword(ff, l, 14));
  651. d->tcarrier = str2kernel_uint_t(procfile_lineword(ff, l, 15));
  652. }
  653. if (d->do_duplex != CONFIG_BOOLEAN_NO && d->filename_duplex) {
  654. char buffer[STATE_LENGTH_MAX + 1];
  655. if (read_file(d->filename_duplex, buffer, STATE_LENGTH_MAX)) {
  656. error("Cannot refresh interface %s duplex state by reading '%s'. I will stop updating it.", d->name, d->filename_duplex);
  657. freez(d->filename_duplex);
  658. d->filename_duplex = NULL;
  659. } else {
  660. // values can be unknown, half or full -- just check the first letter for speed
  661. if (buffer[0] == 'f')
  662. d->duplex = 2;
  663. else if (buffer[0] == 'h')
  664. d->duplex = 1;
  665. else
  666. d->duplex = 0;
  667. }
  668. }
  669. if(d->do_operstate != CONFIG_BOOLEAN_NO && d->filename_operstate) {
  670. char buffer[STATE_LENGTH_MAX + 1], *trimmed_buffer;
  671. if (read_file(d->filename_operstate, buffer, STATE_LENGTH_MAX)) {
  672. error(
  673. "Cannot refresh %s operstate by reading '%s'. Will not update its status anymore.",
  674. d->name, d->filename_operstate);
  675. freez(d->filename_operstate);
  676. d->filename_operstate = NULL;
  677. } else {
  678. trimmed_buffer = trim(buffer);
  679. d->operstate = get_operstate(trimmed_buffer);
  680. }
  681. }
  682. if (d->do_carrier != CONFIG_BOOLEAN_NO && d->filename_carrier) {
  683. if (read_single_number_file(d->filename_carrier, &d->carrier)) {
  684. error("Cannot refresh interface %s carrier state by reading '%s'. Stop updating it.", d->name, d->filename_carrier);
  685. freez(d->filename_carrier);
  686. d->filename_carrier = NULL;
  687. }
  688. }
  689. if (d->do_mtu != CONFIG_BOOLEAN_NO && d->filename_mtu) {
  690. if (read_single_number_file(d->filename_mtu, &d->mtu)) {
  691. error("Cannot refresh mtu for interface %s by reading '%s'. Stop updating it.", d->name, d->filename_carrier);
  692. freez(d->filename_carrier);
  693. d->filename_carrier = NULL;
  694. }
  695. }
  696. //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"
  697. // , d->name, d->speed
  698. // , d->rbytes, d->tbytes
  699. // , d->rpackets, d->tpackets, d->rmulticast
  700. // , d->rerrors, d->terrors
  701. // , d->rdrops, d->tdrops
  702. // , d->rfifo, d->tfifo
  703. // , d->rcompressed, d->tcompressed
  704. // , d->rframe, d->tcollisions, d->tcarrier
  705. // );
  706. // --------------------------------------------------------------------
  707. if(unlikely(d->do_bandwidth == CONFIG_BOOLEAN_AUTO &&
  708. (d->rbytes || d->tbytes || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  709. d->do_bandwidth = CONFIG_BOOLEAN_YES;
  710. if(d->do_bandwidth == CONFIG_BOOLEAN_YES) {
  711. if(unlikely(!d->st_bandwidth)) {
  712. d->st_bandwidth = rrdset_create_localhost(
  713. d->chart_type_net_bytes
  714. , d->chart_id_net_bytes
  715. , NULL
  716. , d->chart_family
  717. , d->chart_ctx_net_bytes
  718. , "Bandwidth"
  719. , "kilobits/s"
  720. , PLUGIN_PROC_NAME
  721. , PLUGIN_PROC_MODULE_NETDEV_NAME
  722. , d->priority
  723. , update_every
  724. , RRDSET_TYPE_AREA
  725. );
  726. rrdset_update_labels(d->st_bandwidth, d->chart_labels);
  727. d->rd_rbytes = rrddim_add(d->st_bandwidth, "received", NULL, 8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  728. d->rd_tbytes = rrddim_add(d->st_bandwidth, "sent", NULL, -8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  729. if(d->flipped) {
  730. // flip receive/transmit
  731. RRDDIM *td = d->rd_rbytes;
  732. d->rd_rbytes = d->rd_tbytes;
  733. d->rd_tbytes = td;
  734. }
  735. }
  736. else rrdset_next(d->st_bandwidth);
  737. rrddim_set_by_pointer(d->st_bandwidth, d->rd_rbytes, (collected_number)d->rbytes);
  738. rrddim_set_by_pointer(d->st_bandwidth, d->rd_tbytes, (collected_number)d->tbytes);
  739. rrdset_done(d->st_bandwidth);
  740. // update the interface speed
  741. if(d->filename_speed) {
  742. if(unlikely(!d->chart_var_speed)) {
  743. d->chart_var_speed = rrdsetvar_custom_chart_variable_create(d->st_bandwidth, "nic_speed_max");
  744. if(!d->chart_var_speed) {
  745. error("Cannot create interface %s chart variable 'nic_speed_max'. Will not update its speed anymore.", d->name);
  746. freez(d->filename_speed);
  747. d->filename_speed = NULL;
  748. }
  749. }
  750. if(d->filename_speed && d->chart_var_speed) {
  751. if(read_single_number_file(d->filename_speed, (unsigned long long *) &d->speed)) {
  752. error("Cannot refresh interface %s speed by reading '%s'. Will not update its speed anymore.", d->name, d->filename_speed);
  753. freez(d->filename_speed);
  754. d->filename_speed = NULL;
  755. }
  756. else {
  757. rrdsetvar_custom_chart_variable_set(d->chart_var_speed, (calculated_number) d->speed * KILOBITS_IN_A_MEGABIT);
  758. if(d->do_speed != CONFIG_BOOLEAN_NO) {
  759. if(unlikely(!d->st_speed)) {
  760. d->st_speed = rrdset_create_localhost(
  761. d->chart_type_net_speed
  762. , d->chart_id_net_speed
  763. , NULL
  764. , d->chart_family
  765. , d->chart_ctx_net_speed
  766. , "Interface Speed"
  767. , "kilobits/s"
  768. , PLUGIN_PROC_NAME
  769. , PLUGIN_PROC_MODULE_NETDEV_NAME
  770. , d->priority + 7
  771. , update_every
  772. , RRDSET_TYPE_LINE
  773. );
  774. rrdset_flag_set(d->st_speed, RRDSET_FLAG_DETAIL);
  775. rrdset_update_labels(d->st_speed, d->chart_labels);
  776. d->rd_speed = rrddim_add(d->st_speed, "speed", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  777. }
  778. else rrdset_next(d->st_speed);
  779. rrddim_set_by_pointer(d->st_speed, d->rd_speed, (collected_number)d->speed * KILOBITS_IN_A_MEGABIT);
  780. rrdset_done(d->st_speed);
  781. }
  782. }
  783. }
  784. }
  785. }
  786. // --------------------------------------------------------------------
  787. if(d->do_duplex != CONFIG_BOOLEAN_NO && d->filename_duplex) {
  788. if(unlikely(!d->st_duplex)) {
  789. d->st_duplex = rrdset_create_localhost(
  790. d->chart_type_net_duplex
  791. , d->chart_id_net_duplex
  792. , NULL
  793. , d->chart_family
  794. , d->chart_ctx_net_duplex
  795. , "Interface Duplex State"
  796. , "state"
  797. , PLUGIN_PROC_NAME
  798. , PLUGIN_PROC_MODULE_NETDEV_NAME
  799. , d->priority + 8
  800. , update_every
  801. , RRDSET_TYPE_LINE
  802. );
  803. rrdset_flag_set(d->st_duplex, RRDSET_FLAG_DETAIL);
  804. rrdset_update_labels(d->st_duplex, d->chart_labels);
  805. d->rd_duplex = rrddim_add(d->st_duplex, "duplex", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  806. }
  807. else rrdset_next(d->st_duplex);
  808. rrddim_set_by_pointer(d->st_duplex, d->rd_duplex, (collected_number)d->duplex);
  809. rrdset_done(d->st_duplex);
  810. }
  811. // --------------------------------------------------------------------
  812. if(d->do_operstate != CONFIG_BOOLEAN_NO && d->filename_operstate) {
  813. if(unlikely(!d->st_operstate)) {
  814. d->st_operstate = rrdset_create_localhost(
  815. d->chart_type_net_operstate
  816. , d->chart_id_net_operstate
  817. , NULL
  818. , d->chart_family
  819. , d->chart_ctx_net_operstate
  820. , "Interface Operational State"
  821. , "state"
  822. , PLUGIN_PROC_NAME
  823. , PLUGIN_PROC_MODULE_NETDEV_NAME
  824. , d->priority + 9
  825. , update_every
  826. , RRDSET_TYPE_LINE
  827. );
  828. rrdset_flag_set(d->st_operstate, RRDSET_FLAG_DETAIL);
  829. rrdset_update_labels(d->st_operstate, d->chart_labels);
  830. d->rd_operstate = rrddim_add(d->st_operstate, "state", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  831. }
  832. else rrdset_next(d->st_operstate);
  833. rrddim_set_by_pointer(d->st_operstate, d->rd_operstate, (collected_number)d->operstate);
  834. rrdset_done(d->st_operstate);
  835. }
  836. // --------------------------------------------------------------------
  837. if(d->do_carrier != CONFIG_BOOLEAN_NO && d->filename_carrier) {
  838. if(unlikely(!d->st_carrier)) {
  839. d->st_carrier = rrdset_create_localhost(
  840. d->chart_type_net_carrier
  841. , d->chart_id_net_carrier
  842. , NULL
  843. , d->chart_family
  844. , d->chart_ctx_net_carrier
  845. , "Interface Physical Link State"
  846. , "state"
  847. , PLUGIN_PROC_NAME
  848. , PLUGIN_PROC_MODULE_NETDEV_NAME
  849. , d->priority + 10
  850. , update_every
  851. , RRDSET_TYPE_LINE
  852. );
  853. rrdset_flag_set(d->st_carrier, RRDSET_FLAG_DETAIL);
  854. rrdset_update_labels(d->st_carrier, d->chart_labels);
  855. d->rd_carrier = rrddim_add(d->st_carrier, "carrier", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  856. }
  857. else rrdset_next(d->st_carrier);
  858. rrddim_set_by_pointer(d->st_carrier, d->rd_carrier, (collected_number)d->carrier);
  859. rrdset_done(d->st_carrier);
  860. }
  861. // --------------------------------------------------------------------
  862. if(d->do_mtu != CONFIG_BOOLEAN_NO && d->filename_mtu) {
  863. if(unlikely(!d->st_mtu)) {
  864. d->st_mtu = rrdset_create_localhost(
  865. d->chart_type_net_mtu
  866. , d->chart_id_net_mtu
  867. , NULL
  868. , d->chart_family
  869. , d->chart_ctx_net_mtu
  870. , "Interface MTU"
  871. , "octets"
  872. , PLUGIN_PROC_NAME
  873. , PLUGIN_PROC_MODULE_NETDEV_NAME
  874. , d->priority + 11
  875. , update_every
  876. , RRDSET_TYPE_LINE
  877. );
  878. rrdset_flag_set(d->st_mtu, RRDSET_FLAG_DETAIL);
  879. rrdset_update_labels(d->st_mtu, d->chart_labels);
  880. d->rd_mtu = rrddim_add(d->st_mtu, "mtu", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  881. }
  882. else rrdset_next(d->st_mtu);
  883. rrddim_set_by_pointer(d->st_mtu, d->rd_mtu, (collected_number)d->mtu);
  884. rrdset_done(d->st_mtu);
  885. }
  886. // --------------------------------------------------------------------
  887. if(unlikely(d->do_packets == CONFIG_BOOLEAN_AUTO &&
  888. (d->rpackets || d->tpackets || d->rmulticast || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  889. d->do_packets = CONFIG_BOOLEAN_YES;
  890. if(d->do_packets == CONFIG_BOOLEAN_YES) {
  891. if(unlikely(!d->st_packets)) {
  892. d->st_packets = rrdset_create_localhost(
  893. d->chart_type_net_packets
  894. , d->chart_id_net_packets
  895. , NULL
  896. , d->chart_family
  897. , d->chart_ctx_net_packets
  898. , "Packets"
  899. , "packets/s"
  900. , PLUGIN_PROC_NAME
  901. , PLUGIN_PROC_MODULE_NETDEV_NAME
  902. , d->priority + 1
  903. , update_every
  904. , RRDSET_TYPE_LINE
  905. );
  906. rrdset_flag_set(d->st_packets, RRDSET_FLAG_DETAIL);
  907. rrdset_update_labels(d->st_packets, d->chart_labels);
  908. d->rd_rpackets = rrddim_add(d->st_packets, "received", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  909. d->rd_tpackets = rrddim_add(d->st_packets, "sent", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  910. d->rd_rmulticast = rrddim_add(d->st_packets, "multicast", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  911. if(d->flipped) {
  912. // flip receive/transmit
  913. RRDDIM *td = d->rd_rpackets;
  914. d->rd_rpackets = d->rd_tpackets;
  915. d->rd_tpackets = td;
  916. }
  917. }
  918. else rrdset_next(d->st_packets);
  919. rrddim_set_by_pointer(d->st_packets, d->rd_rpackets, (collected_number)d->rpackets);
  920. rrddim_set_by_pointer(d->st_packets, d->rd_tpackets, (collected_number)d->tpackets);
  921. rrddim_set_by_pointer(d->st_packets, d->rd_rmulticast, (collected_number)d->rmulticast);
  922. rrdset_done(d->st_packets);
  923. }
  924. // --------------------------------------------------------------------
  925. if(unlikely(d->do_errors == CONFIG_BOOLEAN_AUTO &&
  926. (d->rerrors || d->terrors || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  927. d->do_errors = CONFIG_BOOLEAN_YES;
  928. if(d->do_errors == CONFIG_BOOLEAN_YES) {
  929. if(unlikely(!d->st_errors)) {
  930. d->st_errors = rrdset_create_localhost(
  931. d->chart_type_net_errors
  932. , d->chart_id_net_errors
  933. , NULL
  934. , d->chart_family
  935. , d->chart_ctx_net_errors
  936. , "Interface Errors"
  937. , "errors/s"
  938. , PLUGIN_PROC_NAME
  939. , PLUGIN_PROC_MODULE_NETDEV_NAME
  940. , d->priority + 2
  941. , update_every
  942. , RRDSET_TYPE_LINE
  943. );
  944. rrdset_flag_set(d->st_errors, RRDSET_FLAG_DETAIL);
  945. rrdset_update_labels(d->st_errors, d->chart_labels);
  946. d->rd_rerrors = rrddim_add(d->st_errors, "inbound", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  947. d->rd_terrors = rrddim_add(d->st_errors, "outbound", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  948. if(d->flipped) {
  949. // flip receive/transmit
  950. RRDDIM *td = d->rd_rerrors;
  951. d->rd_rerrors = d->rd_terrors;
  952. d->rd_terrors = td;
  953. }
  954. }
  955. else rrdset_next(d->st_errors);
  956. rrddim_set_by_pointer(d->st_errors, d->rd_rerrors, (collected_number)d->rerrors);
  957. rrddim_set_by_pointer(d->st_errors, d->rd_terrors, (collected_number)d->terrors);
  958. rrdset_done(d->st_errors);
  959. }
  960. // --------------------------------------------------------------------
  961. if(unlikely(d->do_drops == CONFIG_BOOLEAN_AUTO &&
  962. (d->rdrops || d->tdrops || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  963. d->do_drops = CONFIG_BOOLEAN_YES;
  964. if(d->do_drops == CONFIG_BOOLEAN_YES) {
  965. if(unlikely(!d->st_drops)) {
  966. d->st_drops = rrdset_create_localhost(
  967. d->chart_type_net_drops
  968. , d->chart_id_net_drops
  969. , NULL
  970. , d->chart_family
  971. , d->chart_ctx_net_drops
  972. , "Interface Drops"
  973. , "drops/s"
  974. , PLUGIN_PROC_NAME
  975. , PLUGIN_PROC_MODULE_NETDEV_NAME
  976. , d->priority + 3
  977. , update_every
  978. , RRDSET_TYPE_LINE
  979. );
  980. rrdset_flag_set(d->st_drops, RRDSET_FLAG_DETAIL);
  981. rrdset_update_labels(d->st_drops, d->chart_labels);
  982. d->rd_rdrops = rrddim_add(d->st_drops, "inbound", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  983. d->rd_tdrops = rrddim_add(d->st_drops, "outbound", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  984. if(d->flipped) {
  985. // flip receive/transmit
  986. RRDDIM *td = d->rd_rdrops;
  987. d->rd_rdrops = d->rd_tdrops;
  988. d->rd_tdrops = td;
  989. }
  990. }
  991. else rrdset_next(d->st_drops);
  992. rrddim_set_by_pointer(d->st_drops, d->rd_rdrops, (collected_number)d->rdrops);
  993. rrddim_set_by_pointer(d->st_drops, d->rd_tdrops, (collected_number)d->tdrops);
  994. rrdset_done(d->st_drops);
  995. }
  996. // --------------------------------------------------------------------
  997. if(unlikely(d->do_fifo == CONFIG_BOOLEAN_AUTO &&
  998. (d->rfifo || d->tfifo || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  999. d->do_fifo = CONFIG_BOOLEAN_YES;
  1000. if(d->do_fifo == CONFIG_BOOLEAN_YES) {
  1001. if(unlikely(!d->st_fifo)) {
  1002. d->st_fifo = rrdset_create_localhost(
  1003. d->chart_type_net_fifo
  1004. , d->chart_id_net_fifo
  1005. , NULL
  1006. , d->chart_family
  1007. , d->chart_ctx_net_fifo
  1008. , "Interface FIFO Buffer Errors"
  1009. , "errors"
  1010. , PLUGIN_PROC_NAME
  1011. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1012. , d->priority + 4
  1013. , update_every
  1014. , RRDSET_TYPE_LINE
  1015. );
  1016. rrdset_flag_set(d->st_fifo, RRDSET_FLAG_DETAIL);
  1017. rrdset_update_labels(d->st_fifo, d->chart_labels);
  1018. d->rd_rfifo = rrddim_add(d->st_fifo, "receive", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1019. d->rd_tfifo = rrddim_add(d->st_fifo, "transmit", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1020. if(d->flipped) {
  1021. // flip receive/transmit
  1022. RRDDIM *td = d->rd_rfifo;
  1023. d->rd_rfifo = d->rd_tfifo;
  1024. d->rd_tfifo = td;
  1025. }
  1026. }
  1027. else rrdset_next(d->st_fifo);
  1028. rrddim_set_by_pointer(d->st_fifo, d->rd_rfifo, (collected_number)d->rfifo);
  1029. rrddim_set_by_pointer(d->st_fifo, d->rd_tfifo, (collected_number)d->tfifo);
  1030. rrdset_done(d->st_fifo);
  1031. }
  1032. // --------------------------------------------------------------------
  1033. if(unlikely(d->do_compressed == CONFIG_BOOLEAN_AUTO &&
  1034. (d->rcompressed || d->tcompressed || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1035. d->do_compressed = CONFIG_BOOLEAN_YES;
  1036. if(d->do_compressed == CONFIG_BOOLEAN_YES) {
  1037. if(unlikely(!d->st_compressed)) {
  1038. d->st_compressed = rrdset_create_localhost(
  1039. d->chart_type_net_compressed
  1040. , d->chart_id_net_compressed
  1041. , NULL
  1042. , d->chart_family
  1043. , d->chart_ctx_net_compressed
  1044. , "Compressed Packets"
  1045. , "packets/s"
  1046. , PLUGIN_PROC_NAME
  1047. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1048. , d->priority + 5
  1049. , update_every
  1050. , RRDSET_TYPE_LINE
  1051. );
  1052. rrdset_flag_set(d->st_compressed, RRDSET_FLAG_DETAIL);
  1053. rrdset_update_labels(d->st_compressed, d->chart_labels);
  1054. d->rd_rcompressed = rrddim_add(d->st_compressed, "received", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1055. d->rd_tcompressed = rrddim_add(d->st_compressed, "sent", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1056. if(d->flipped) {
  1057. // flip receive/transmit
  1058. RRDDIM *td = d->rd_rcompressed;
  1059. d->rd_rcompressed = d->rd_tcompressed;
  1060. d->rd_tcompressed = td;
  1061. }
  1062. }
  1063. else rrdset_next(d->st_compressed);
  1064. rrddim_set_by_pointer(d->st_compressed, d->rd_rcompressed, (collected_number)d->rcompressed);
  1065. rrddim_set_by_pointer(d->st_compressed, d->rd_tcompressed, (collected_number)d->tcompressed);
  1066. rrdset_done(d->st_compressed);
  1067. }
  1068. // --------------------------------------------------------------------
  1069. if(unlikely(d->do_events == CONFIG_BOOLEAN_AUTO &&
  1070. (d->rframe || d->tcollisions || d->tcarrier || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
  1071. d->do_events = CONFIG_BOOLEAN_YES;
  1072. if(d->do_events == CONFIG_BOOLEAN_YES) {
  1073. if(unlikely(!d->st_events)) {
  1074. d->st_events = rrdset_create_localhost(
  1075. d->chart_type_net_events
  1076. , d->chart_id_net_events
  1077. , NULL
  1078. , d->chart_family
  1079. , d->chart_ctx_net_events
  1080. , "Network Interface Events"
  1081. , "events/s"
  1082. , PLUGIN_PROC_NAME
  1083. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1084. , d->priority + 6
  1085. , update_every
  1086. , RRDSET_TYPE_LINE
  1087. );
  1088. rrdset_flag_set(d->st_events, RRDSET_FLAG_DETAIL);
  1089. rrdset_update_labels(d->st_events, d->chart_labels);
  1090. d->rd_rframe = rrddim_add(d->st_events, "frames", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  1091. d->rd_tcollisions = rrddim_add(d->st_events, "collisions", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1092. d->rd_tcarrier = rrddim_add(d->st_events, "carrier", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
  1093. }
  1094. else rrdset_next(d->st_events);
  1095. rrddim_set_by_pointer(d->st_events, d->rd_rframe, (collected_number)d->rframe);
  1096. rrddim_set_by_pointer(d->st_events, d->rd_tcollisions, (collected_number)d->tcollisions);
  1097. rrddim_set_by_pointer(d->st_events, d->rd_tcarrier, (collected_number)d->tcarrier);
  1098. rrdset_done(d->st_events);
  1099. }
  1100. }
  1101. if(do_bandwidth == CONFIG_BOOLEAN_YES || (do_bandwidth == CONFIG_BOOLEAN_AUTO &&
  1102. (system_rbytes || system_tbytes ||
  1103. netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
  1104. do_bandwidth = CONFIG_BOOLEAN_YES;
  1105. static RRDSET *st_system_net = NULL;
  1106. static RRDDIM *rd_in = NULL, *rd_out = NULL;
  1107. if(unlikely(!st_system_net)) {
  1108. st_system_net = rrdset_create_localhost(
  1109. "system"
  1110. , "net"
  1111. , NULL
  1112. , "network"
  1113. , NULL
  1114. , "Physical Network Interfaces Aggregated Bandwidth"
  1115. , "kilobits/s"
  1116. , PLUGIN_PROC_NAME
  1117. , PLUGIN_PROC_MODULE_NETDEV_NAME
  1118. , NETDATA_CHART_PRIO_SYSTEM_NET
  1119. , update_every
  1120. , RRDSET_TYPE_AREA
  1121. );
  1122. rd_in = rrddim_add(st_system_net, "InOctets", "received", 8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1123. rd_out = rrddim_add(st_system_net, "OutOctets", "sent", -8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
  1124. }
  1125. else
  1126. rrdset_next(st_system_net);
  1127. rrddim_set_by_pointer(st_system_net, rd_in, (collected_number)system_rbytes);
  1128. rrddim_set_by_pointer(st_system_net, rd_out, (collected_number)system_tbytes);
  1129. rrdset_done(st_system_net);
  1130. }
  1131. netdev_cleanup();
  1132. return 0;
  1133. }