proc_net_dev.c 79 KB

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