123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956 |
- // SPDX-License-Identifier: GPL-3.0-or-later
- #include "plugin_proc.h"
- #define PLUGIN_PROC_MODULE_NETDEV_NAME "/proc/net/dev"
- #define CONFIG_SECTION_PLUGIN_PROC_NETDEV "plugin:" PLUGIN_PROC_CONFIG_NAME ":" PLUGIN_PROC_MODULE_NETDEV_NAME
- #define RRDFUNCTIONS_NETDEV_HELP "View network interface statistics"
- #define STATE_LENGTH_MAX 32
- #define READ_RETRY_PERIOD 60 // seconds
- void cgroup_netdev_reset_all(void);
- void cgroup_netdev_release(const DICTIONARY_ITEM *link);
- const void *cgroup_netdev_dup(const DICTIONARY_ITEM *link);
- void cgroup_netdev_add_bandwidth(const DICTIONARY_ITEM *link, NETDATA_DOUBLE received, NETDATA_DOUBLE sent);
- enum {
- NETDEV_DUPLEX_UNKNOWN,
- NETDEV_DUPLEX_HALF,
- NETDEV_DUPLEX_FULL
- };
- static const char *get_duplex_string(int duplex)
- {
- switch (duplex) {
- case NETDEV_DUPLEX_FULL:
- return "full";
- case NETDEV_DUPLEX_HALF:
- return "half";
- default:
- return "unknown";
- }
- }
- enum {
- NETDEV_OPERSTATE_UNKNOWN,
- NETDEV_OPERSTATE_NOTPRESENT,
- NETDEV_OPERSTATE_DOWN,
- NETDEV_OPERSTATE_LOWERLAYERDOWN,
- NETDEV_OPERSTATE_TESTING,
- NETDEV_OPERSTATE_DORMANT,
- NETDEV_OPERSTATE_UP
- };
- static inline int get_operstate(char *operstate)
- {
- // As defined in https://www.kernel.org/doc/Documentation/ABI/testing/sysfs-class-net
- if (!strcmp(operstate, "up"))
- return NETDEV_OPERSTATE_UP;
- if (!strcmp(operstate, "down"))
- return NETDEV_OPERSTATE_DOWN;
- if (!strcmp(operstate, "notpresent"))
- return NETDEV_OPERSTATE_NOTPRESENT;
- if (!strcmp(operstate, "lowerlayerdown"))
- return NETDEV_OPERSTATE_LOWERLAYERDOWN;
- if (!strcmp(operstate, "testing"))
- return NETDEV_OPERSTATE_TESTING;
- if (!strcmp(operstate, "dormant"))
- return NETDEV_OPERSTATE_DORMANT;
- return NETDEV_OPERSTATE_UNKNOWN;
- }
- static const char *get_operstate_string(int operstate)
- {
- switch (operstate) {
- case NETDEV_OPERSTATE_UP:
- return "up";
- case NETDEV_OPERSTATE_DOWN:
- return "down";
- case NETDEV_OPERSTATE_NOTPRESENT:
- return "notpresent";
- case NETDEV_OPERSTATE_LOWERLAYERDOWN:
- return "lowerlayerdown";
- case NETDEV_OPERSTATE_TESTING:
- return "testing";
- case NETDEV_OPERSTATE_DORMANT:
- return "dormant";
- default:
- return "unknown";
- }
- }
- // ----------------------------------------------------------------------------
- // netdev list
- static struct netdev {
- char *name;
- uint32_t hash;
- size_t len;
- // flags
- int virtual;
- int configured;
- int enabled;
- int updated;
- bool function_ready;
- time_t discover_time;
-
- int carrier_file_exists;
- time_t carrier_file_lost_time;
- int duplex_file_exists;
- time_t duplex_file_lost_time;
- int speed_file_exists;
- time_t speed_file_lost_time;
- int do_bandwidth;
- int do_packets;
- int do_errors;
- int do_drops;
- int do_fifo;
- int do_compressed;
- int do_events;
- int do_speed;
- int do_duplex;
- int do_operstate;
- int do_carrier;
- int do_mtu;
- const char *chart_type_net_bytes;
- const char *chart_type_net_packets;
- const char *chart_type_net_errors;
- const char *chart_type_net_fifo;
- const char *chart_type_net_events;
- const char *chart_type_net_drops;
- const char *chart_type_net_compressed;
- const char *chart_type_net_speed;
- const char *chart_type_net_duplex;
- const char *chart_type_net_operstate;
- const char *chart_type_net_carrier;
- const char *chart_type_net_mtu;
- const char *chart_id_net_bytes;
- const char *chart_id_net_packets;
- const char *chart_id_net_errors;
- const char *chart_id_net_fifo;
- const char *chart_id_net_events;
- const char *chart_id_net_drops;
- const char *chart_id_net_compressed;
- const char *chart_id_net_speed;
- const char *chart_id_net_duplex;
- const char *chart_id_net_operstate;
- const char *chart_id_net_carrier;
- const char *chart_id_net_mtu;
- const char *chart_ctx_net_bytes;
- const char *chart_ctx_net_packets;
- const char *chart_ctx_net_errors;
- const char *chart_ctx_net_fifo;
- const char *chart_ctx_net_events;
- const char *chart_ctx_net_drops;
- const char *chart_ctx_net_compressed;
- const char *chart_ctx_net_speed;
- const char *chart_ctx_net_duplex;
- const char *chart_ctx_net_operstate;
- const char *chart_ctx_net_carrier;
- const char *chart_ctx_net_mtu;
- const char *chart_family;
- RRDLABELS *chart_labels;
- int flipped;
- unsigned long priority;
- // data collected
- kernel_uint_t rbytes;
- kernel_uint_t rpackets;
- kernel_uint_t rerrors;
- kernel_uint_t rdrops;
- kernel_uint_t rfifo;
- kernel_uint_t rframe;
- kernel_uint_t rcompressed;
- kernel_uint_t rmulticast;
- kernel_uint_t tbytes;
- kernel_uint_t tpackets;
- kernel_uint_t terrors;
- kernel_uint_t tdrops;
- kernel_uint_t tfifo;
- kernel_uint_t tcollisions;
- kernel_uint_t tcarrier;
- kernel_uint_t tcompressed;
- kernel_uint_t speed;
- kernel_uint_t duplex;
- kernel_uint_t operstate;
- unsigned long long carrier;
- unsigned long long mtu;
- // charts
- RRDSET *st_bandwidth;
- RRDSET *st_packets;
- RRDSET *st_errors;
- RRDSET *st_drops;
- RRDSET *st_fifo;
- RRDSET *st_compressed;
- RRDSET *st_events;
- RRDSET *st_speed;
- RRDSET *st_duplex;
- RRDSET *st_operstate;
- RRDSET *st_carrier;
- RRDSET *st_mtu;
- // dimensions
- RRDDIM *rd_rbytes;
- RRDDIM *rd_rpackets;
- RRDDIM *rd_rerrors;
- RRDDIM *rd_rdrops;
- RRDDIM *rd_rfifo;
- RRDDIM *rd_rframe;
- RRDDIM *rd_rcompressed;
- RRDDIM *rd_rmulticast;
- RRDDIM *rd_tbytes;
- RRDDIM *rd_tpackets;
- RRDDIM *rd_terrors;
- RRDDIM *rd_tdrops;
- RRDDIM *rd_tfifo;
- RRDDIM *rd_tcollisions;
- RRDDIM *rd_tcarrier;
- RRDDIM *rd_tcompressed;
- RRDDIM *rd_speed;
- RRDDIM *rd_duplex_full;
- RRDDIM *rd_duplex_half;
- RRDDIM *rd_duplex_unknown;
- RRDDIM *rd_operstate_unknown;
- RRDDIM *rd_operstate_notpresent;
- RRDDIM *rd_operstate_down;
- RRDDIM *rd_operstate_lowerlayerdown;
- RRDDIM *rd_operstate_testing;
- RRDDIM *rd_operstate_dormant;
- RRDDIM *rd_operstate_up;
- RRDDIM *rd_carrier_up;
- RRDDIM *rd_carrier_down;
- RRDDIM *rd_mtu;
- char *filename_speed;
- const RRDSETVAR_ACQUIRED *chart_var_speed;
- char *filename_duplex;
- char *filename_operstate;
- char *filename_carrier;
- char *filename_mtu;
- const DICTIONARY_ITEM *cgroup_netdev_link;
- struct netdev *next;
- } *netdev_root = NULL, *netdev_last_used = NULL;
- static size_t netdev_added = 0, netdev_found = 0;
- // ----------------------------------------------------------------------------
- static void netdev_charts_release(struct netdev *d) {
- if(d->st_bandwidth) rrdset_is_obsolete___safe_from_collector_thread(d->st_bandwidth);
- if(d->st_packets) rrdset_is_obsolete___safe_from_collector_thread(d->st_packets);
- if(d->st_errors) rrdset_is_obsolete___safe_from_collector_thread(d->st_errors);
- if(d->st_drops) rrdset_is_obsolete___safe_from_collector_thread(d->st_drops);
- if(d->st_fifo) rrdset_is_obsolete___safe_from_collector_thread(d->st_fifo);
- if(d->st_compressed) rrdset_is_obsolete___safe_from_collector_thread(d->st_compressed);
- if(d->st_events) rrdset_is_obsolete___safe_from_collector_thread(d->st_events);
- if(d->st_speed) rrdset_is_obsolete___safe_from_collector_thread(d->st_speed);
- if(d->st_duplex) rrdset_is_obsolete___safe_from_collector_thread(d->st_duplex);
- if(d->st_operstate) rrdset_is_obsolete___safe_from_collector_thread(d->st_operstate);
- if(d->st_carrier) rrdset_is_obsolete___safe_from_collector_thread(d->st_carrier);
- if(d->st_mtu) rrdset_is_obsolete___safe_from_collector_thread(d->st_mtu);
- d->st_bandwidth = NULL;
- d->st_compressed = NULL;
- d->st_drops = NULL;
- d->st_errors = NULL;
- d->st_events = NULL;
- d->st_fifo = NULL;
- d->st_packets = NULL;
- d->st_speed = NULL;
- d->st_duplex = NULL;
- d->st_operstate = NULL;
- d->st_carrier = NULL;
- d->st_mtu = NULL;
- d->rd_rbytes = NULL;
- d->rd_rpackets = NULL;
- d->rd_rerrors = NULL;
- d->rd_rdrops = NULL;
- d->rd_rfifo = NULL;
- d->rd_rframe = NULL;
- d->rd_rcompressed = NULL;
- d->rd_rmulticast = NULL;
- d->rd_tbytes = NULL;
- d->rd_tpackets = NULL;
- d->rd_terrors = NULL;
- d->rd_tdrops = NULL;
- d->rd_tfifo = NULL;
- d->rd_tcollisions = NULL;
- d->rd_tcarrier = NULL;
- d->rd_tcompressed = NULL;
- d->rd_speed = NULL;
- d->rd_duplex_full = NULL;
- d->rd_duplex_half = NULL;
- d->rd_duplex_unknown = NULL;
- d->rd_carrier_up = NULL;
- d->rd_carrier_down = NULL;
- d->rd_mtu = NULL;
- d->rd_operstate_unknown = NULL;
- d->rd_operstate_notpresent = NULL;
- d->rd_operstate_down = NULL;
- d->rd_operstate_lowerlayerdown = NULL;
- d->rd_operstate_testing = NULL;
- d->rd_operstate_dormant = NULL;
- d->rd_operstate_up = NULL;
- d->chart_var_speed = NULL;
- }
- static void netdev_free_chart_strings(struct netdev *d) {
- freez((void *)d->chart_type_net_bytes);
- freez((void *)d->chart_type_net_compressed);
- freez((void *)d->chart_type_net_drops);
- freez((void *)d->chart_type_net_errors);
- freez((void *)d->chart_type_net_events);
- freez((void *)d->chart_type_net_fifo);
- freez((void *)d->chart_type_net_packets);
- freez((void *)d->chart_type_net_speed);
- freez((void *)d->chart_type_net_duplex);
- freez((void *)d->chart_type_net_operstate);
- freez((void *)d->chart_type_net_carrier);
- freez((void *)d->chart_type_net_mtu);
- freez((void *)d->chart_id_net_bytes);
- freez((void *)d->chart_id_net_compressed);
- freez((void *)d->chart_id_net_drops);
- freez((void *)d->chart_id_net_errors);
- freez((void *)d->chart_id_net_events);
- freez((void *)d->chart_id_net_fifo);
- freez((void *)d->chart_id_net_packets);
- freez((void *)d->chart_id_net_speed);
- freez((void *)d->chart_id_net_duplex);
- freez((void *)d->chart_id_net_operstate);
- freez((void *)d->chart_id_net_carrier);
- freez((void *)d->chart_id_net_mtu);
- freez((void *)d->chart_ctx_net_bytes);
- freez((void *)d->chart_ctx_net_compressed);
- freez((void *)d->chart_ctx_net_drops);
- freez((void *)d->chart_ctx_net_errors);
- freez((void *)d->chart_ctx_net_events);
- freez((void *)d->chart_ctx_net_fifo);
- freez((void *)d->chart_ctx_net_packets);
- freez((void *)d->chart_ctx_net_speed);
- freez((void *)d->chart_ctx_net_duplex);
- freez((void *)d->chart_ctx_net_operstate);
- freez((void *)d->chart_ctx_net_carrier);
- freez((void *)d->chart_ctx_net_mtu);
- freez((void *)d->chart_family);
- }
- static void netdev_free(struct netdev *d) {
- netdev_charts_release(d);
- netdev_free_chart_strings(d);
- rrdlabels_destroy(d->chart_labels);
- cgroup_netdev_release(d->cgroup_netdev_link);
- freez((void *)d->name);
- freez((void *)d->filename_speed);
- freez((void *)d->filename_duplex);
- freez((void *)d->filename_operstate);
- freez((void *)d->filename_carrier);
- freez((void *)d->filename_mtu);
- freez((void *)d);
- netdev_added--;
- }
- // ----------------------------------------------------------------------------
- // netdev renames
- static struct netdev_rename {
- const char *host_device;
- uint32_t hash;
- const char *container_device;
- const char *container_name;
- const char *ctx_prefix;
- RRDLABELS *chart_labels;
- int processed;
- const DICTIONARY_ITEM *cgroup_netdev_link;
- struct netdev_rename *next;
- } *netdev_rename_root = NULL;
- static int netdev_pending_renames = 0;
- static netdata_mutex_t netdev_rename_mutex = NETDATA_MUTEX_INITIALIZER;
- static netdata_mutex_t netdev_dev_mutex = NETDATA_MUTEX_INITIALIZER;
- static struct netdev_rename *netdev_rename_find(const char *host_device, uint32_t hash) {
- struct netdev_rename *r;
- for(r = netdev_rename_root; r ; r = r->next)
- if(r->hash == hash && !strcmp(host_device, r->host_device))
- return r;
- return NULL;
- }
- // other threads can call this function to register a rename to a netdev
- void netdev_rename_device_add(
- const char *host_device,
- const char *container_device,
- const char *container_name,
- RRDLABELS *labels,
- const char *ctx_prefix,
- const DICTIONARY_ITEM *cgroup_netdev_link)
- {
- netdata_mutex_lock(&netdev_rename_mutex);
- uint32_t hash = simple_hash(host_device);
- struct netdev_rename *r = netdev_rename_find(host_device, hash);
- if(!r) {
- r = callocz(1, sizeof(struct netdev_rename));
- r->host_device = strdupz(host_device);
- r->container_device = strdupz(container_device);
- r->container_name = strdupz(container_name);
- r->ctx_prefix = strdupz(ctx_prefix);
- r->chart_labels = rrdlabels_create();
- rrdlabels_migrate_to_these(r->chart_labels, labels);
- r->hash = hash;
- r->next = netdev_rename_root;
- r->processed = 0;
- r->cgroup_netdev_link = cgroup_netdev_link;
- netdev_rename_root = r;
- netdev_pending_renames++;
- collector_info("CGROUP: registered network interface rename for '%s' as '%s' under '%s'", r->host_device, r->container_device, r->container_name);
- }
- else {
- if(strcmp(r->container_device, container_device) != 0 || strcmp(r->container_name, container_name) != 0) {
- freez((void *) r->container_device);
- freez((void *) r->container_name);
- r->container_device = strdupz(container_device);
- r->container_name = strdupz(container_name);
- rrdlabels_migrate_to_these(r->chart_labels, labels);
-
- r->processed = 0;
- r->cgroup_netdev_link = cgroup_netdev_link;
- netdev_pending_renames++;
- collector_info("CGROUP: altered network interface rename for '%s' as '%s' under '%s'", r->host_device, r->container_device, r->container_name);
- }
- }
- netdata_mutex_unlock(&netdev_rename_mutex);
- }
- // other threads can call this function to delete a rename to a netdev
- void netdev_rename_device_del(const char *host_device) {
- netdata_mutex_lock(&netdev_rename_mutex);
- struct netdev_rename *r, *last = NULL;
- uint32_t hash = simple_hash(host_device);
- for(r = netdev_rename_root; r ; last = r, r = r->next) {
- if (r->hash == hash && !strcmp(host_device, r->host_device)) {
- if (netdev_rename_root == r)
- netdev_rename_root = r->next;
- else if (last)
- last->next = r->next;
- if(!r->processed)
- netdev_pending_renames--;
- collector_info("CGROUP: unregistered network interface rename for '%s' as '%s' under '%s'", r->host_device, r->container_device, r->container_name);
- freez((void *) r->host_device);
- freez((void *) r->container_name);
- freez((void *) r->container_device);
- freez((void *) r->ctx_prefix);
- rrdlabels_destroy(r->chart_labels);
- cgroup_netdev_release(r->cgroup_netdev_link);
- freez((void *) r);
- break;
- }
- }
- netdata_mutex_unlock(&netdev_rename_mutex);
- }
- static inline void netdev_rename_cgroup(struct netdev *d, struct netdev_rename *r) {
- collector_info("CGROUP: renaming network interface '%s' as '%s' under '%s'", r->host_device, r->container_device, r->container_name);
- netdev_charts_release(d);
- netdev_free_chart_strings(d);
- d->cgroup_netdev_link = cgroup_netdev_dup(r->cgroup_netdev_link);
- char buffer[RRD_ID_LENGTH_MAX + 1];
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "cgroup_%s", r->container_name);
- d->chart_type_net_bytes = strdupz(buffer);
- d->chart_type_net_compressed = strdupz(buffer);
- d->chart_type_net_drops = strdupz(buffer);
- d->chart_type_net_errors = strdupz(buffer);
- d->chart_type_net_events = strdupz(buffer);
- d->chart_type_net_fifo = strdupz(buffer);
- d->chart_type_net_packets = strdupz(buffer);
- d->chart_type_net_speed = strdupz(buffer);
- d->chart_type_net_duplex = strdupz(buffer);
- d->chart_type_net_operstate = strdupz(buffer);
- d->chart_type_net_carrier = strdupz(buffer);
- d->chart_type_net_mtu = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_%s", r->container_device);
- d->chart_id_net_bytes = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_compressed_%s", r->container_device);
- d->chart_id_net_compressed = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_drops_%s", r->container_device);
- d->chart_id_net_drops = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_errors_%s", r->container_device);
- d->chart_id_net_errors = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_events_%s", r->container_device);
- d->chart_id_net_events = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_fifo_%s", r->container_device);
- d->chart_id_net_fifo = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_packets_%s", r->container_device);
- d->chart_id_net_packets = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_speed_%s", r->container_device);
- d->chart_id_net_speed = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_duplex_%s", r->container_device);
- d->chart_id_net_duplex = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_operstate_%s", r->container_device);
- d->chart_id_net_operstate = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_carrier_%s", r->container_device);
- d->chart_id_net_carrier = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "net_mtu_%s", r->container_device);
- d->chart_id_net_mtu = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_net", r->ctx_prefix);
- d->chart_ctx_net_bytes = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_compressed", r->ctx_prefix);
- d->chart_ctx_net_compressed = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_drops", r->ctx_prefix);
- d->chart_ctx_net_drops = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_errors", r->ctx_prefix);
- d->chart_ctx_net_errors = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_events", r->ctx_prefix);
- d->chart_ctx_net_events = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_fifo", r->ctx_prefix);
- d->chart_ctx_net_fifo = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_packets", r->ctx_prefix);
- d->chart_ctx_net_packets = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_speed", r->ctx_prefix);
- d->chart_ctx_net_speed = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_duplex", r->ctx_prefix);
- d->chart_ctx_net_duplex = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_operstate", r->ctx_prefix);
- d->chart_ctx_net_operstate = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_carrier", r->ctx_prefix);
- d->chart_ctx_net_carrier = strdupz(buffer);
- snprintfz(buffer, RRD_ID_LENGTH_MAX, "%scgroup.net_mtu", r->ctx_prefix);
- d->chart_ctx_net_mtu = strdupz(buffer);
- d->chart_family = strdupz("net");
- rrdlabels_copy(d->chart_labels, r->chart_labels);
- rrdlabels_add(d->chart_labels, "container_device", r->container_device, RRDLABEL_SRC_AUTO);
- d->priority = NETDATA_CHART_PRIO_CGROUP_NET_IFACE;
- d->flipped = 1;
- }
- static inline void netdev_rename(struct netdev *d) {
- struct netdev_rename *r = netdev_rename_find(d->name, d->hash);
- if(unlikely(r && !r->processed)) {
- netdev_rename_cgroup(d, r);
- r->processed = 1;
- d->discover_time = 0;
- netdev_pending_renames--;
- }
- }
- static inline void netdev_rename_lock(struct netdev *d) {
- netdata_mutex_lock(&netdev_rename_mutex);
- netdev_rename(d);
- netdata_mutex_unlock(&netdev_rename_mutex);
- }
- static inline void netdev_rename_all_lock(void) {
- netdata_mutex_lock(&netdev_rename_mutex);
- struct netdev *d;
- for(d = netdev_root; d ; d = d->next)
- netdev_rename(d);
- netdev_pending_renames = 0;
- netdata_mutex_unlock(&netdev_rename_mutex);
- }
- // ----------------------------------------------------------------------------
- int netdev_function_net_interfaces(BUFFER *wb, int timeout __maybe_unused, const char *function __maybe_unused,
- void *collector_data __maybe_unused,
- rrd_function_result_callback_t result_cb, void *result_cb_data,
- rrd_function_is_cancelled_cb_t is_cancelled_cb, void *is_cancelled_cb_data,
- rrd_function_register_canceller_cb_t register_canceller_cb __maybe_unused,
- void *register_canceller_cb_data __maybe_unused) {
- buffer_flush(wb);
- wb->content_type = CT_APPLICATION_JSON;
- buffer_json_initialize(wb, "\"", "\"", 0, true, BUFFER_JSON_OPTIONS_DEFAULT);
- buffer_json_member_add_string(wb, "hostname", rrdhost_hostname(localhost));
- buffer_json_member_add_uint64(wb, "status", HTTP_RESP_OK);
- buffer_json_member_add_string(wb, "type", "table");
- buffer_json_member_add_time_t(wb, "update_every", 1);
- buffer_json_member_add_string(wb, "help", RRDFUNCTIONS_NETDEV_HELP);
- buffer_json_member_add_array(wb, "data");
- double max_traffic_rx = 0.0;
- double max_traffic_tx = 0.0;
- double max_traffic = 0.0;
- double max_packets_rx = 0.0;
- double max_packets_tx = 0.0;
- double max_mcast_rx = 0.0;
- double max_drops_rx = 0.0;
- double max_drops_tx = 0.0;
- netdata_mutex_lock(&netdev_dev_mutex);
- RRDDIM *rd = NULL;
- for (struct netdev *d = netdev_root; d != netdev_last_used; d = d->next) {
- if (unlikely(!d->function_ready))
- continue;
- buffer_json_add_array_item_array(wb);
- buffer_json_add_array_item_string(wb, d->name);
- buffer_json_add_array_item_string(wb, d->virtual ? "virtual" : "physical");
- buffer_json_add_array_item_string(wb, d->flipped ? "cgroup" : "host");
- buffer_json_add_array_item_string(wb, d->carrier == 1 ? "up" : "down");
- buffer_json_add_array_item_string(wb, get_operstate_string(d->operstate));
- buffer_json_add_array_item_string(wb, get_duplex_string(d->duplex));
- buffer_json_add_array_item_double(wb, d->speed > 0 ? d->speed : NAN);
- buffer_json_add_array_item_double(wb, d->mtu > 0 ? d->mtu : NAN);
- rd = d->flipped ? d->rd_tbytes : d->rd_rbytes;
- double traffic_rx = rrddim_get_last_stored_value(rd, &max_traffic_rx, 1000.0);
- rd = d->flipped ? d->rd_rbytes : d->rd_tbytes;
- double traffic_tx = rrddim_get_last_stored_value(rd, &max_traffic_tx, 1000.0);
- rd = d->flipped ? d->rd_tpackets : d->rd_rpackets;
- double packets_rx = rrddim_get_last_stored_value(rd, &max_packets_rx, 1000.0);
- rd = d->flipped ? d->rd_rpackets : d->rd_tpackets;
- double packets_tx = rrddim_get_last_stored_value(rd, &max_packets_tx, 1000.0);
- double mcast_rx = rrddim_get_last_stored_value(d->rd_rmulticast, &max_mcast_rx, 1000.0);
- rd = d->flipped ? d->rd_tdrops : d->rd_rdrops;
- double drops_rx = rrddim_get_last_stored_value(rd, &max_drops_rx, 1.0);
- rd = d->flipped ? d->rd_rdrops : d->rd_tdrops;
- double drops_tx = rrddim_get_last_stored_value(rd, &max_drops_tx, 1.0);
- // FIXME: "traffic" (total) is needed only for default_sorting
- // can be removed when default_sorting will accept multiple columns (sum)
- double traffic = NAN;
- if (!isnan(traffic_rx) && !isnan(traffic_tx)) {
- traffic = traffic_rx + traffic_tx;
- max_traffic = MAX(max_traffic, traffic);
- }
- buffer_json_add_array_item_double(wb, traffic_rx);
- buffer_json_add_array_item_double(wb, traffic_tx);
- buffer_json_add_array_item_double(wb, traffic);
- buffer_json_add_array_item_double(wb, packets_rx);
- buffer_json_add_array_item_double(wb, packets_tx);
- buffer_json_add_array_item_double(wb, mcast_rx);
- buffer_json_add_array_item_double(wb, drops_rx);
- buffer_json_add_array_item_double(wb, drops_tx);
- buffer_json_add_array_item_object(wb);
- {
- buffer_json_member_add_string(wb, "severity", drops_rx + drops_tx > 0 ? "warning" : "normal");
- }
- buffer_json_object_close(wb);
- buffer_json_array_close(wb);
- }
- netdata_mutex_unlock(&netdev_dev_mutex);
- buffer_json_array_close(wb); // data
- buffer_json_member_add_object(wb, "columns");
- {
- size_t field_id = 0;
- buffer_rrdf_table_add_field(wb, field_id++, "Interface", "Network Interface Name",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY | RRDF_FIELD_OPTS_STICKY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Type", "Network Interface Type",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "UsedBy", "Indicates whether the network interface is used by a cgroup or by the host system",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "PhState", "Current Physical State",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "OpState", "Current Operational State",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Duplex", "Current Duplex Mode",
- RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
- 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Speed", "Current Link Speed",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
- 0, "Mbit", NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "MTU", "Maximum Transmission Unit",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
- 0, "Octets", NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
- RRDF_FIELD_OPTS_UNIQUE_KEY,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "In", "Traffic Received",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "Mbit", max_traffic_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Out", "Traffic Sent",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "Mbit", max_traffic_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "Total", "Traffic Received and Sent",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "Mbit", max_traffic, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_NONE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "PktsIn", "Received Packets",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "Kpps", max_packets_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "PktsOut", "Sent Packets",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "Kpps", max_packets_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "McastIn", "Multicast Received Packets",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "Kpps", max_mcast_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_NONE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "DropsIn", "Dropped Inbound Packets",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "Drops", max_drops_rx, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(wb, field_id++, "DropsOut", "Dropped Outbound Packets",
- RRDF_FIELD_TYPE_BAR_WITH_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
- 2, "Drops", max_drops_tx, RRDF_FIELD_SORT_DESCENDING, NULL,
- RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_VISIBLE,
- NULL);
- buffer_rrdf_table_add_field(
- wb, field_id++,
- "rowOptions", "rowOptions",
- RRDF_FIELD_TYPE_NONE,
- RRDR_FIELD_VISUAL_ROW_OPTIONS,
- RRDF_FIELD_TRANSFORM_NONE, 0, NULL, NAN,
- RRDF_FIELD_SORT_FIXED,
- NULL,
- RRDF_FIELD_SUMMARY_COUNT,
- RRDF_FIELD_FILTER_NONE,
- RRDF_FIELD_OPTS_DUMMY,
- NULL);
- }
- buffer_json_object_close(wb); // columns
- buffer_json_member_add_string(wb, "default_sort_column", "Total");
- buffer_json_member_add_object(wb, "charts");
- {
- buffer_json_member_add_object(wb, "Traffic");
- {
- buffer_json_member_add_string(wb, "name", "Traffic");
- buffer_json_member_add_string(wb, "type", "stacked-bar");
- buffer_json_member_add_array(wb, "columns");
- {
- buffer_json_add_array_item_string(wb, "In");
- buffer_json_add_array_item_string(wb, "Out");
- }
- buffer_json_array_close(wb);
- }
- buffer_json_object_close(wb);
- buffer_json_member_add_object(wb, "Packets");
- {
- buffer_json_member_add_string(wb, "name", "Packets");
- buffer_json_member_add_string(wb, "type", "stacked-bar");
- buffer_json_member_add_array(wb, "columns");
- {
- buffer_json_add_array_item_string(wb, "PktsIn");
- buffer_json_add_array_item_string(wb, "PktsOut");
- }
- buffer_json_array_close(wb);
- }
- buffer_json_object_close(wb);
- }
- buffer_json_object_close(wb); // charts
- buffer_json_member_add_array(wb, "default_charts");
- {
- buffer_json_add_array_item_array(wb);
- buffer_json_add_array_item_string(wb, "Traffic");
- buffer_json_add_array_item_string(wb, "Interface");
- buffer_json_array_close(wb);
- buffer_json_add_array_item_array(wb);
- buffer_json_add_array_item_string(wb, "Traffic");
- buffer_json_add_array_item_string(wb, "Type");
- buffer_json_array_close(wb);
- }
- buffer_json_array_close(wb);
- buffer_json_member_add_object(wb, "group_by");
- {
- buffer_json_member_add_object(wb, "Type");
- {
- buffer_json_member_add_string(wb, "name", "Type");
- buffer_json_member_add_array(wb, "columns");
- {
- buffer_json_add_array_item_string(wb, "Type");
- }
- buffer_json_array_close(wb);
- }
- buffer_json_object_close(wb);
- buffer_json_member_add_object(wb, "UsedBy");
- {
- buffer_json_member_add_string(wb, "name", "UsedBy");
- buffer_json_member_add_array(wb, "columns");
- {
- buffer_json_add_array_item_string(wb, "UsedBy");
- }
- buffer_json_array_close(wb);
- }
- buffer_json_object_close(wb);
- }
- buffer_json_object_close(wb); // group_by
- buffer_json_member_add_time_t(wb, "expires", now_realtime_sec() + 1);
- buffer_json_finalize(wb);
- int response = HTTP_RESP_OK;
- if(is_cancelled_cb && is_cancelled_cb(is_cancelled_cb_data)) {
- buffer_flush(wb);
- response = HTTP_RESP_CLIENT_CLOSED_REQUEST;
- }
- if(result_cb)
- result_cb(wb, response, result_cb_data);
- return response;
- }
- // netdev data collection
- static void netdev_cleanup() {
- if(likely(netdev_found == netdev_added)) return;
- netdev_added = 0;
- struct netdev *d = netdev_root, *last = NULL;
- while(d) {
- if(unlikely(!d->updated)) {
- // collector_info("Removing network device '%s', linked after '%s'", d->name, last?last->name:"ROOT");
- if(netdev_last_used == d)
- netdev_last_used = last;
- struct netdev *t = d;
- if(d == netdev_root || !last)
- netdev_root = d = d->next;
- else
- last->next = d = d->next;
- t->next = NULL;
- netdev_free(t);
- }
- else {
- netdev_added++;
- last = d;
- d->updated = 0;
- d = d->next;
- }
- }
- }
- static struct netdev *get_netdev(const char *name) {
- struct netdev *d;
- uint32_t hash = simple_hash(name);
- // search it, from the last position to the end
- for(d = netdev_last_used ; d ; d = d->next) {
- if(unlikely(hash == d->hash && !strcmp(name, d->name))) {
- netdev_last_used = d->next;
- return d;
- }
- }
- // search it from the beginning to the last position we used
- for(d = netdev_root ; d != netdev_last_used ; d = d->next) {
- if(unlikely(hash == d->hash && !strcmp(name, d->name))) {
- netdev_last_used = d->next;
- return d;
- }
- }
- // create a new one
- d = callocz(1, sizeof(struct netdev));
- d->name = strdupz(name);
- d->hash = simple_hash(d->name);
- d->len = strlen(d->name);
- d->chart_labels = rrdlabels_create();
- d->function_ready = false;
- d->chart_type_net_bytes = strdupz("net");
- d->chart_type_net_compressed = strdupz("net_compressed");
- d->chart_type_net_drops = strdupz("net_drops");
- d->chart_type_net_errors = strdupz("net_errors");
- d->chart_type_net_events = strdupz("net_events");
- d->chart_type_net_fifo = strdupz("net_fifo");
- d->chart_type_net_packets = strdupz("net_packets");
- d->chart_type_net_speed = strdupz("net_speed");
- d->chart_type_net_duplex = strdupz("net_duplex");
- d->chart_type_net_operstate = strdupz("net_operstate");
- d->chart_type_net_carrier = strdupz("net_carrier");
- d->chart_type_net_mtu = strdupz("net_mtu");
- d->chart_id_net_bytes = strdupz(d->name);
- d->chart_id_net_compressed = strdupz(d->name);
- d->chart_id_net_drops = strdupz(d->name);
- d->chart_id_net_errors = strdupz(d->name);
- d->chart_id_net_events = strdupz(d->name);
- d->chart_id_net_fifo = strdupz(d->name);
- d->chart_id_net_packets = strdupz(d->name);
- d->chart_id_net_speed = strdupz(d->name);
- d->chart_id_net_duplex = strdupz(d->name);
- d->chart_id_net_operstate = strdupz(d->name);
- d->chart_id_net_carrier = strdupz(d->name);
- d->chart_id_net_mtu = strdupz(d->name);
- d->chart_ctx_net_bytes = strdupz("net.net");
- d->chart_ctx_net_compressed = strdupz("net.compressed");
- d->chart_ctx_net_drops = strdupz("net.drops");
- d->chart_ctx_net_errors = strdupz("net.errors");
- d->chart_ctx_net_events = strdupz("net.events");
- d->chart_ctx_net_fifo = strdupz("net.fifo");
- d->chart_ctx_net_packets = strdupz("net.packets");
- d->chart_ctx_net_speed = strdupz("net.speed");
- d->chart_ctx_net_duplex = strdupz("net.duplex");
- d->chart_ctx_net_operstate = strdupz("net.operstate");
- d->chart_ctx_net_carrier = strdupz("net.carrier");
- d->chart_ctx_net_mtu = strdupz("net.mtu");
- d->chart_family = strdupz(d->name);
- d->priority = NETDATA_CHART_PRIO_FIRST_NET_IFACE;
- netdev_rename_lock(d);
- netdev_added++;
- // link it to the end
- if(netdev_root) {
- struct netdev *e;
- for(e = netdev_root; e->next ; e = e->next) ;
- e->next = d;
- }
- else
- netdev_root = d;
- return d;
- }
- #define NETDEV_VIRTUAL_COLLECT_DELAY 15 // 1 full run of the cgroups discovery thread (10 secs by default)
- int do_proc_net_dev(int update_every, usec_t dt) {
- (void)dt;
- static SIMPLE_PATTERN *disabled_list = NULL;
- static procfile *ff = NULL;
- static int enable_new_interfaces = -1;
- static int do_bandwidth = -1, do_packets = -1, do_errors = -1, do_drops = -1, do_fifo = -1, do_compressed = -1,
- do_events = -1, do_speed = -1, do_duplex = -1, do_operstate = -1, do_carrier = -1, do_mtu = -1;
- static char *path_to_sys_devices_virtual_net = NULL, *path_to_sys_class_net_speed = NULL,
- *proc_net_dev_filename = NULL;
- static char *path_to_sys_class_net_duplex = NULL;
- static char *path_to_sys_class_net_operstate = NULL;
- static char *path_to_sys_class_net_carrier = NULL;
- static char *path_to_sys_class_net_mtu = NULL;
- if(unlikely(enable_new_interfaces == -1)) {
- char filename[FILENAME_MAX + 1];
- snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, (*netdata_configured_host_prefix)?"/proc/1/net/dev":"/proc/net/dev");
- proc_net_dev_filename = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "filename to monitor", filename);
- snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/devices/virtual/net/%s");
- path_to_sys_devices_virtual_net = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get virtual interfaces", filename);
- snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/speed");
- path_to_sys_class_net_speed = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device speed", filename);
- snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/duplex");
- path_to_sys_class_net_duplex = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device duplex", filename);
- snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/operstate");
- path_to_sys_class_net_operstate = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device operstate", filename);
- snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/carrier");
- path_to_sys_class_net_carrier = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device carrier", filename);
- snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/sys/class/net/%s/mtu");
- path_to_sys_class_net_mtu = config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "path to get net device mtu", filename);
- enable_new_interfaces = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "enable new interfaces detected at runtime", CONFIG_BOOLEAN_AUTO);
- do_bandwidth = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "bandwidth for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_packets = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "packets for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_errors = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "errors for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_drops = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "drops for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_fifo = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "fifo for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_compressed = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "compressed packets for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_events = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "frames, collisions, carrier counters for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_speed = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "speed for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_duplex = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "duplex for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_operstate = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "operstate for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_carrier = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "carrier for all interfaces", CONFIG_BOOLEAN_AUTO);
- do_mtu = config_get_boolean_ondemand(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "mtu for all interfaces", CONFIG_BOOLEAN_AUTO);
- disabled_list = simple_pattern_create(
- config_get(CONFIG_SECTION_PLUGIN_PROC_NETDEV, "disable by default interfaces matching",
- "lo fireqos* *-ifb fwpr* fwbr* fwln*"), NULL, SIMPLE_PATTERN_EXACT, true);
- }
- if(unlikely(!ff)) {
- ff = procfile_open(proc_net_dev_filename, " \t,|", PROCFILE_FLAG_DEFAULT);
- if(unlikely(!ff)) return 1;
- }
- ff = procfile_readall(ff);
- if(unlikely(!ff)) return 0; // we return 0, so that we will retry to open it next time
- // rename all the devices, if we have pending renames
- if(unlikely(netdev_pending_renames))
- netdev_rename_all_lock();
- netdev_found = 0;
- kernel_uint_t system_rbytes = 0;
- kernel_uint_t system_tbytes = 0;
- time_t now = now_realtime_sec();
- size_t lines = procfile_lines(ff), l;
- for(l = 2; l < lines ;l++) {
- // require 17 words on each line
- if(unlikely(procfile_linewords(ff, l) < 17)) continue;
- char *name = procfile_lineword(ff, l, 0);
- size_t len = strlen(name);
- if(name[len - 1] == ':') name[len - 1] = '\0';
- struct netdev *d = get_netdev(name);
- d->updated = 1;
- netdev_found++;
- if(unlikely(!d->configured)) {
- // this is the first time we see this interface
- // remember we configured it
- d->configured = 1;
- d->discover_time = now;
- d->enabled = enable_new_interfaces;
- if(d->enabled)
- d->enabled = !simple_pattern_matches(disabled_list, d->name);
- char buf[FILENAME_MAX + 1];
- snprintfz(buf, FILENAME_MAX, path_to_sys_devices_virtual_net, d->name);
- d->virtual = likely(access(buf, R_OK) == 0) ? 1 : 0;
- // At least on Proxmox inside LXC: eth0 is virtual.
- // Virtual interfaces are not taken into account in system.net calculations
- if (inside_lxc_container && d->virtual && strncmp(d->name, "eth", 3) == 0)
- d->virtual = 0;
- if (d->virtual)
- rrdlabels_add(d->chart_labels, "interface_type", "virtual", RRDLABEL_SRC_AUTO);
- else
- rrdlabels_add(d->chart_labels, "interface_type", "real", RRDLABEL_SRC_AUTO);
- rrdlabels_add(d->chart_labels, "device", name, RRDLABEL_SRC_AUTO);
- if(likely(!d->virtual)) {
- // set the filename to get the interface speed
- snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_speed, d->name);
- d->filename_speed = strdupz(buf);
- snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_duplex, d->name);
- d->filename_duplex = strdupz(buf);
- }
- snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_operstate, d->name);
- d->filename_operstate = strdupz(buf);
- snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_carrier, d->name);
- d->filename_carrier = strdupz(buf);
- snprintfz(buf, FILENAME_MAX, path_to_sys_class_net_mtu, d->name);
- d->filename_mtu = strdupz(buf);
- snprintfz(buf, FILENAME_MAX, "plugin:proc:/proc/net/dev:%s", d->name);
- if (config_exists(buf, "enabled"))
- d->enabled = config_get_boolean_ondemand(buf, "enabled", d->enabled);
- if (config_exists(buf, "virtual"))
- d->virtual = config_get_boolean(buf, "virtual", d->virtual);
- if(d->enabled == CONFIG_BOOLEAN_NO)
- continue;
- d->do_bandwidth = do_bandwidth;
- d->do_packets = do_packets;
- d->do_errors = do_errors;
- d->do_drops = do_drops;
- d->do_fifo = do_fifo;
- d->do_compressed = do_compressed;
- d->do_events = do_events;
- d->do_speed = do_speed;
- d->do_duplex = do_duplex;
- d->do_operstate = do_operstate;
- d->do_carrier = do_carrier;
- d->do_mtu = do_mtu;
- if (config_exists(buf, "bandwidth"))
- d->do_bandwidth = config_get_boolean_ondemand(buf, "bandwidth", do_bandwidth);
- if (config_exists(buf, "packets"))
- d->do_packets = config_get_boolean_ondemand(buf, "packets", do_packets);
- if (config_exists(buf, "errors"))
- d->do_errors = config_get_boolean_ondemand(buf, "errors", do_errors);
- if (config_exists(buf, "drops"))
- d->do_drops = config_get_boolean_ondemand(buf, "drops", do_drops);
- if (config_exists(buf, "fifo"))
- d->do_fifo = config_get_boolean_ondemand(buf, "fifo", do_fifo);
- if (config_exists(buf, "compressed"))
- d->do_compressed = config_get_boolean_ondemand(buf, "compressed", do_compressed);
- if (config_exists(buf, "events"))
- d->do_events = config_get_boolean_ondemand(buf, "events", do_events);
- if (config_exists(buf, "speed"))
- d->do_speed = config_get_boolean_ondemand(buf, "speed", do_speed);
- if (config_exists(buf, "duplex"))
- d->do_duplex = config_get_boolean_ondemand(buf, "duplex", do_duplex);
- if (config_exists(buf, "operstate"))
- d->do_operstate = config_get_boolean_ondemand(buf, "operstate", do_operstate);
- if (config_exists(buf, "carrier"))
- d->do_carrier = config_get_boolean_ondemand(buf, "carrier", do_carrier);
- if (config_exists(buf, "mtu"))
- d->do_mtu = config_get_boolean_ondemand(buf, "mtu", do_mtu);
- }
- if(unlikely(!d->enabled))
- continue;
- // See https://github.com/netdata/netdata/issues/15206
- // This is necessary to prevent the creation of charts for virtual interfaces that will later be
- // recreated as container interfaces (create container) or
- // rediscovered and recreated only to be deleted almost immediately (stop/remove container)
- if (d->virtual && (now - d->discover_time < NETDEV_VIRTUAL_COLLECT_DELAY)) {
- continue;
- }
- if(likely(d->do_bandwidth != CONFIG_BOOLEAN_NO || !d->virtual)) {
- d->rbytes = str2kernel_uint_t(procfile_lineword(ff, l, 1));
- d->tbytes = str2kernel_uint_t(procfile_lineword(ff, l, 9));
- if(likely(!d->virtual)) {
- system_rbytes += d->rbytes;
- system_tbytes += d->tbytes;
- }
- }
- if(likely(d->do_packets != CONFIG_BOOLEAN_NO)) {
- d->rpackets = str2kernel_uint_t(procfile_lineword(ff, l, 2));
- d->rmulticast = str2kernel_uint_t(procfile_lineword(ff, l, 8));
- d->tpackets = str2kernel_uint_t(procfile_lineword(ff, l, 10));
- }
- if(likely(d->do_errors != CONFIG_BOOLEAN_NO)) {
- d->rerrors = str2kernel_uint_t(procfile_lineword(ff, l, 3));
- d->terrors = str2kernel_uint_t(procfile_lineword(ff, l, 11));
- }
- if(likely(d->do_drops != CONFIG_BOOLEAN_NO)) {
- d->rdrops = str2kernel_uint_t(procfile_lineword(ff, l, 4));
- d->tdrops = str2kernel_uint_t(procfile_lineword(ff, l, 12));
- }
- if(likely(d->do_fifo != CONFIG_BOOLEAN_NO)) {
- d->rfifo = str2kernel_uint_t(procfile_lineword(ff, l, 5));
- d->tfifo = str2kernel_uint_t(procfile_lineword(ff, l, 13));
- }
- if(likely(d->do_compressed != CONFIG_BOOLEAN_NO)) {
- d->rcompressed = str2kernel_uint_t(procfile_lineword(ff, l, 7));
- d->tcompressed = str2kernel_uint_t(procfile_lineword(ff, l, 16));
- }
- if(likely(d->do_events != CONFIG_BOOLEAN_NO)) {
- d->rframe = str2kernel_uint_t(procfile_lineword(ff, l, 6));
- d->tcollisions = str2kernel_uint_t(procfile_lineword(ff, l, 14));
- d->tcarrier = str2kernel_uint_t(procfile_lineword(ff, l, 15));
- }
- if ((d->do_carrier != CONFIG_BOOLEAN_NO ||
- d->do_duplex != CONFIG_BOOLEAN_NO ||
- d->do_speed != CONFIG_BOOLEAN_NO) &&
- d->filename_carrier &&
- (d->carrier_file_exists ||
- now_monotonic_sec() - d->carrier_file_lost_time > READ_RETRY_PERIOD)) {
- if (read_single_number_file(d->filename_carrier, &d->carrier)) {
- if (d->carrier_file_exists)
- collector_error(
- "Cannot refresh interface %s carrier state by reading '%s'. Next update is in %d seconds.",
- d->name,
- d->filename_carrier,
- READ_RETRY_PERIOD);
- d->carrier_file_exists = 0;
- d->carrier_file_lost_time = now_monotonic_sec();
- } else {
- d->carrier_file_exists = 1;
- d->carrier_file_lost_time = 0;
- }
- }
- if (d->do_duplex != CONFIG_BOOLEAN_NO &&
- d->filename_duplex &&
- (d->carrier || d->carrier_file_exists) &&
- (d->duplex_file_exists ||
- now_monotonic_sec() - d->duplex_file_lost_time > READ_RETRY_PERIOD)) {
- char buffer[STATE_LENGTH_MAX + 1];
- if (read_file(d->filename_duplex, buffer, STATE_LENGTH_MAX)) {
- if (d->duplex_file_exists)
- collector_error("Cannot refresh interface %s duplex state by reading '%s'.", d->name, d->filename_duplex);
- d->duplex_file_exists = 0;
- d->duplex_file_lost_time = now_monotonic_sec();
- d->duplex = NETDEV_DUPLEX_UNKNOWN;
- } else {
- // values can be unknown, half or full -- just check the first letter for speed
- if (buffer[0] == 'f')
- d->duplex = NETDEV_DUPLEX_FULL;
- else if (buffer[0] == 'h')
- d->duplex = NETDEV_DUPLEX_HALF;
- else
- d->duplex = NETDEV_DUPLEX_UNKNOWN;
- d->duplex_file_exists = 1;
- d->duplex_file_lost_time = 0;
- }
- } else {
- d->duplex = NETDEV_DUPLEX_UNKNOWN;
- }
- if(d->do_operstate != CONFIG_BOOLEAN_NO && d->filename_operstate) {
- char buffer[STATE_LENGTH_MAX + 1], *trimmed_buffer;
- if (read_file(d->filename_operstate, buffer, STATE_LENGTH_MAX)) {
- collector_error(
- "Cannot refresh %s operstate by reading '%s'. Will not update its status anymore.",
- d->name, d->filename_operstate);
- freez(d->filename_operstate);
- d->filename_operstate = NULL;
- } else {
- trimmed_buffer = trim(buffer);
- d->operstate = get_operstate(trimmed_buffer);
- }
- }
- if (d->do_mtu != CONFIG_BOOLEAN_NO && d->filename_mtu) {
- if (read_single_number_file(d->filename_mtu, &d->mtu)) {
- collector_error(
- "Cannot refresh mtu for interface %s by reading '%s'. Stop updating it.", d->name, d->filename_mtu);
- freez(d->filename_mtu);
- d->filename_mtu = NULL;
- }
- }
- //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"
- // , d->name, d->speed
- // , d->rbytes, d->tbytes
- // , d->rpackets, d->tpackets, d->rmulticast
- // , d->rerrors, d->terrors
- // , d->rdrops, d->tdrops
- // , d->rfifo, d->tfifo
- // , d->rcompressed, d->tcompressed
- // , d->rframe, d->tcollisions, d->tcarrier
- // );
- if(unlikely(d->do_bandwidth == CONFIG_BOOLEAN_AUTO &&
- (d->rbytes || d->tbytes || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
- d->do_bandwidth = CONFIG_BOOLEAN_YES;
- if(d->do_bandwidth == CONFIG_BOOLEAN_YES) {
- if(unlikely(!d->st_bandwidth)) {
- d->st_bandwidth = rrdset_create_localhost(
- d->chart_type_net_bytes
- , d->chart_id_net_bytes
- , NULL
- , d->chart_family
- , d->chart_ctx_net_bytes
- , "Bandwidth"
- , "kilobits/s"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority
- , update_every
- , RRDSET_TYPE_AREA
- );
- rrdset_update_rrdlabels(d->st_bandwidth, d->chart_labels);
- d->rd_rbytes = rrddim_add(d->st_bandwidth, "received", NULL, 8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
- d->rd_tbytes = rrddim_add(d->st_bandwidth, "sent", NULL, -8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
- if(d->flipped) {
- // flip receive/transmit
- RRDDIM *td = d->rd_rbytes;
- d->rd_rbytes = d->rd_tbytes;
- d->rd_tbytes = td;
- }
- }
- rrddim_set_by_pointer(d->st_bandwidth, d->rd_rbytes, (collected_number)d->rbytes);
- rrddim_set_by_pointer(d->st_bandwidth, d->rd_tbytes, (collected_number)d->tbytes);
- rrdset_done(d->st_bandwidth);
- if(d->cgroup_netdev_link)
- cgroup_netdev_add_bandwidth(d->cgroup_netdev_link,
- d->flipped ? d->rd_tbytes->collector.last_stored_value : -d->rd_rbytes->collector.last_stored_value,
- d->flipped ? -d->rd_rbytes->collector.last_stored_value : d->rd_tbytes->collector.last_stored_value);
- // update the interface speed
- if(d->filename_speed) {
- if(unlikely(!d->chart_var_speed)) {
- d->chart_var_speed =
- rrdsetvar_custom_chart_variable_add_and_acquire(d->st_bandwidth, "nic_speed_max");
- if(!d->chart_var_speed) {
- collector_error(
- "Cannot create interface %s chart variable 'nic_speed_max'. Will not update its speed anymore.",
- d->name);
- freez(d->filename_speed);
- d->filename_speed = NULL;
- }
- }
- if (d->filename_speed && d->chart_var_speed) {
- int ret = 0;
- if ((d->carrier || d->carrier_file_exists) &&
- (d->speed_file_exists || now_monotonic_sec() - d->speed_file_lost_time > READ_RETRY_PERIOD)) {
- ret = read_single_number_file(d->filename_speed, (unsigned long long *) &d->speed);
- } else {
- d->speed = 0; // TODO: this is wrong, shouldn't use 0 value, but NULL.
- }
- if(ret) {
- if (d->speed_file_exists)
- collector_error("Cannot refresh interface %s speed by reading '%s'.", d->name, d->filename_speed);
- d->speed_file_exists = 0;
- d->speed_file_lost_time = now_monotonic_sec();
- }
- else {
- if(d->do_speed != CONFIG_BOOLEAN_NO) {
- if(unlikely(!d->st_speed)) {
- d->st_speed = rrdset_create_localhost(
- d->chart_type_net_speed
- , d->chart_id_net_speed
- , NULL
- , d->chart_family
- , d->chart_ctx_net_speed
- , "Interface Speed"
- , "kilobits/s"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 7
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_speed, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_speed, d->chart_labels);
- d->rd_speed = rrddim_add(d->st_speed, "speed", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- }
- rrddim_set_by_pointer(d->st_speed, d->rd_speed, (collected_number)d->speed * KILOBITS_IN_A_MEGABIT);
- rrdset_done(d->st_speed);
- }
- rrdsetvar_custom_chart_variable_set(
- d->st_bandwidth, d->chart_var_speed, (NETDATA_DOUBLE)d->speed * KILOBITS_IN_A_MEGABIT);
- if (d->speed) {
- d->speed_file_exists = 1;
- d->speed_file_lost_time = 0;
- }
- }
- }
- }
- }
- if(d->do_duplex != CONFIG_BOOLEAN_NO && d->filename_duplex) {
- if(unlikely(!d->st_duplex)) {
- d->st_duplex = rrdset_create_localhost(
- d->chart_type_net_duplex
- , d->chart_id_net_duplex
- , NULL
- , d->chart_family
- , d->chart_ctx_net_duplex
- , "Interface Duplex State"
- , "state"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 8
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_duplex, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_duplex, d->chart_labels);
- d->rd_duplex_full = rrddim_add(d->st_duplex, "full", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_duplex_half = rrddim_add(d->st_duplex, "half", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_duplex_unknown = rrddim_add(d->st_duplex, "unknown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- }
- rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_full, (collected_number)(d->duplex == NETDEV_DUPLEX_FULL));
- rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_half, (collected_number)(d->duplex == NETDEV_DUPLEX_HALF));
- rrddim_set_by_pointer(d->st_duplex, d->rd_duplex_unknown, (collected_number)(d->duplex == NETDEV_DUPLEX_UNKNOWN));
- rrdset_done(d->st_duplex);
- }
- if(d->do_operstate != CONFIG_BOOLEAN_NO && d->filename_operstate) {
- if(unlikely(!d->st_operstate)) {
- d->st_operstate = rrdset_create_localhost(
- d->chart_type_net_operstate
- , d->chart_id_net_operstate
- , NULL
- , d->chart_family
- , d->chart_ctx_net_operstate
- , "Interface Operational State"
- , "state"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 9
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_operstate, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_operstate, d->chart_labels);
- d->rd_operstate_up = rrddim_add(d->st_operstate, "up", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_operstate_down = rrddim_add(d->st_operstate, "down", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_operstate_notpresent = rrddim_add(d->st_operstate, "notpresent", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_operstate_lowerlayerdown = rrddim_add(d->st_operstate, "lowerlayerdown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_operstate_testing = rrddim_add(d->st_operstate, "testing", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_operstate_dormant = rrddim_add(d->st_operstate, "dormant", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_operstate_unknown = rrddim_add(d->st_operstate, "unknown", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- }
- rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_up, (collected_number)(d->operstate == NETDEV_OPERSTATE_UP));
- rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_down, (collected_number)(d->operstate == NETDEV_OPERSTATE_DOWN));
- rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_notpresent, (collected_number)(d->operstate == NETDEV_OPERSTATE_NOTPRESENT));
- rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_lowerlayerdown, (collected_number)(d->operstate == NETDEV_OPERSTATE_LOWERLAYERDOWN));
- rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_testing, (collected_number)(d->operstate == NETDEV_OPERSTATE_TESTING));
- rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_dormant, (collected_number)(d->operstate == NETDEV_OPERSTATE_DORMANT));
- rrddim_set_by_pointer(d->st_operstate, d->rd_operstate_unknown, (collected_number)(d->operstate == NETDEV_OPERSTATE_UNKNOWN));
- rrdset_done(d->st_operstate);
- }
- if(d->do_carrier != CONFIG_BOOLEAN_NO && d->carrier_file_exists) {
- if(unlikely(!d->st_carrier)) {
- d->st_carrier = rrdset_create_localhost(
- d->chart_type_net_carrier
- , d->chart_id_net_carrier
- , NULL
- , d->chart_family
- , d->chart_ctx_net_carrier
- , "Interface Physical Link State"
- , "state"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 10
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_carrier, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_carrier, d->chart_labels);
- d->rd_carrier_up = rrddim_add(d->st_carrier, "up", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- d->rd_carrier_down = rrddim_add(d->st_carrier, "down", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- }
- rrddim_set_by_pointer(d->st_carrier, d->rd_carrier_up, (collected_number)(d->carrier == 1));
- rrddim_set_by_pointer(d->st_carrier, d->rd_carrier_down, (collected_number)(d->carrier != 1));
- rrdset_done(d->st_carrier);
- }
- if(d->do_mtu != CONFIG_BOOLEAN_NO && d->filename_mtu) {
- if(unlikely(!d->st_mtu)) {
- d->st_mtu = rrdset_create_localhost(
- d->chart_type_net_mtu
- , d->chart_id_net_mtu
- , NULL
- , d->chart_family
- , d->chart_ctx_net_mtu
- , "Interface MTU"
- , "octets"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 11
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_mtu, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_mtu, d->chart_labels);
- d->rd_mtu = rrddim_add(d->st_mtu, "mtu", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
- }
- rrddim_set_by_pointer(d->st_mtu, d->rd_mtu, (collected_number)d->mtu);
- rrdset_done(d->st_mtu);
- }
- if(unlikely(d->do_packets == CONFIG_BOOLEAN_AUTO &&
- (d->rpackets || d->tpackets || d->rmulticast || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
- d->do_packets = CONFIG_BOOLEAN_YES;
- if(d->do_packets == CONFIG_BOOLEAN_YES) {
- if(unlikely(!d->st_packets)) {
- d->st_packets = rrdset_create_localhost(
- d->chart_type_net_packets
- , d->chart_id_net_packets
- , NULL
- , d->chart_family
- , d->chart_ctx_net_packets
- , "Packets"
- , "packets/s"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 1
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_packets, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_packets, d->chart_labels);
- d->rd_rpackets = rrddim_add(d->st_packets, "received", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
- d->rd_tpackets = rrddim_add(d->st_packets, "sent", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
- d->rd_rmulticast = rrddim_add(d->st_packets, "multicast", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
- if(d->flipped) {
- // flip receive/transmit
- RRDDIM *td = d->rd_rpackets;
- d->rd_rpackets = d->rd_tpackets;
- d->rd_tpackets = td;
- }
- }
- rrddim_set_by_pointer(d->st_packets, d->rd_rpackets, (collected_number)d->rpackets);
- rrddim_set_by_pointer(d->st_packets, d->rd_tpackets, (collected_number)d->tpackets);
- rrddim_set_by_pointer(d->st_packets, d->rd_rmulticast, (collected_number)d->rmulticast);
- rrdset_done(d->st_packets);
- }
- if(unlikely(d->do_errors == CONFIG_BOOLEAN_AUTO &&
- (d->rerrors || d->terrors || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
- d->do_errors = CONFIG_BOOLEAN_YES;
- if(d->do_errors == CONFIG_BOOLEAN_YES) {
- if(unlikely(!d->st_errors)) {
- d->st_errors = rrdset_create_localhost(
- d->chart_type_net_errors
- , d->chart_id_net_errors
- , NULL
- , d->chart_family
- , d->chart_ctx_net_errors
- , "Interface Errors"
- , "errors/s"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 2
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_errors, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_errors, d->chart_labels);
- d->rd_rerrors = rrddim_add(d->st_errors, "inbound", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
- d->rd_terrors = rrddim_add(d->st_errors, "outbound", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
- if(d->flipped) {
- // flip receive/transmit
- RRDDIM *td = d->rd_rerrors;
- d->rd_rerrors = d->rd_terrors;
- d->rd_terrors = td;
- }
- }
- rrddim_set_by_pointer(d->st_errors, d->rd_rerrors, (collected_number)d->rerrors);
- rrddim_set_by_pointer(d->st_errors, d->rd_terrors, (collected_number)d->terrors);
- rrdset_done(d->st_errors);
- }
- if(unlikely(d->do_drops == CONFIG_BOOLEAN_AUTO &&
- (d->rdrops || d->tdrops || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
- d->do_drops = CONFIG_BOOLEAN_YES;
- if(d->do_drops == CONFIG_BOOLEAN_YES) {
- if(unlikely(!d->st_drops)) {
- d->st_drops = rrdset_create_localhost(
- d->chart_type_net_drops
- , d->chart_id_net_drops
- , NULL
- , d->chart_family
- , d->chart_ctx_net_drops
- , "Interface Drops"
- , "drops/s"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 3
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_drops, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_drops, d->chart_labels);
- d->rd_rdrops = rrddim_add(d->st_drops, "inbound", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
- d->rd_tdrops = rrddim_add(d->st_drops, "outbound", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
- if(d->flipped) {
- // flip receive/transmit
- RRDDIM *td = d->rd_rdrops;
- d->rd_rdrops = d->rd_tdrops;
- d->rd_tdrops = td;
- }
- }
- rrddim_set_by_pointer(d->st_drops, d->rd_rdrops, (collected_number)d->rdrops);
- rrddim_set_by_pointer(d->st_drops, d->rd_tdrops, (collected_number)d->tdrops);
- rrdset_done(d->st_drops);
- }
- if(unlikely(d->do_fifo == CONFIG_BOOLEAN_AUTO &&
- (d->rfifo || d->tfifo || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
- d->do_fifo = CONFIG_BOOLEAN_YES;
- if(d->do_fifo == CONFIG_BOOLEAN_YES) {
- if(unlikely(!d->st_fifo)) {
- d->st_fifo = rrdset_create_localhost(
- d->chart_type_net_fifo
- , d->chart_id_net_fifo
- , NULL
- , d->chart_family
- , d->chart_ctx_net_fifo
- , "Interface FIFO Buffer Errors"
- , "errors"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 4
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_fifo, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_fifo, d->chart_labels);
- d->rd_rfifo = rrddim_add(d->st_fifo, "receive", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
- d->rd_tfifo = rrddim_add(d->st_fifo, "transmit", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
- if(d->flipped) {
- // flip receive/transmit
- RRDDIM *td = d->rd_rfifo;
- d->rd_rfifo = d->rd_tfifo;
- d->rd_tfifo = td;
- }
- }
- rrddim_set_by_pointer(d->st_fifo, d->rd_rfifo, (collected_number)d->rfifo);
- rrddim_set_by_pointer(d->st_fifo, d->rd_tfifo, (collected_number)d->tfifo);
- rrdset_done(d->st_fifo);
- }
- if(unlikely(d->do_compressed == CONFIG_BOOLEAN_AUTO &&
- (d->rcompressed || d->tcompressed || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
- d->do_compressed = CONFIG_BOOLEAN_YES;
- if(d->do_compressed == CONFIG_BOOLEAN_YES) {
- if(unlikely(!d->st_compressed)) {
- d->st_compressed = rrdset_create_localhost(
- d->chart_type_net_compressed
- , d->chart_id_net_compressed
- , NULL
- , d->chart_family
- , d->chart_ctx_net_compressed
- , "Compressed Packets"
- , "packets/s"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 5
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_compressed, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_compressed, d->chart_labels);
- d->rd_rcompressed = rrddim_add(d->st_compressed, "received", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
- d->rd_tcompressed = rrddim_add(d->st_compressed, "sent", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
- if(d->flipped) {
- // flip receive/transmit
- RRDDIM *td = d->rd_rcompressed;
- d->rd_rcompressed = d->rd_tcompressed;
- d->rd_tcompressed = td;
- }
- }
- rrddim_set_by_pointer(d->st_compressed, d->rd_rcompressed, (collected_number)d->rcompressed);
- rrddim_set_by_pointer(d->st_compressed, d->rd_tcompressed, (collected_number)d->tcompressed);
- rrdset_done(d->st_compressed);
- }
- if(unlikely(d->do_events == CONFIG_BOOLEAN_AUTO &&
- (d->rframe || d->tcollisions || d->tcarrier || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES)))
- d->do_events = CONFIG_BOOLEAN_YES;
- if(d->do_events == CONFIG_BOOLEAN_YES) {
- if(unlikely(!d->st_events)) {
- d->st_events = rrdset_create_localhost(
- d->chart_type_net_events
- , d->chart_id_net_events
- , NULL
- , d->chart_family
- , d->chart_ctx_net_events
- , "Network Interface Events"
- , "events/s"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , d->priority + 6
- , update_every
- , RRDSET_TYPE_LINE
- );
- rrdset_flag_set(d->st_events, RRDSET_FLAG_DETAIL);
- rrdset_update_rrdlabels(d->st_events, d->chart_labels);
- d->rd_rframe = rrddim_add(d->st_events, "frames", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
- d->rd_tcollisions = rrddim_add(d->st_events, "collisions", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
- d->rd_tcarrier = rrddim_add(d->st_events, "carrier", NULL, -1, 1, RRD_ALGORITHM_INCREMENTAL);
- }
- rrddim_set_by_pointer(d->st_events, d->rd_rframe, (collected_number)d->rframe);
- rrddim_set_by_pointer(d->st_events, d->rd_tcollisions, (collected_number)d->tcollisions);
- rrddim_set_by_pointer(d->st_events, d->rd_tcarrier, (collected_number)d->tcarrier);
- rrdset_done(d->st_events);
- }
- d->function_ready = true;
- }
- if(do_bandwidth == CONFIG_BOOLEAN_YES || (do_bandwidth == CONFIG_BOOLEAN_AUTO &&
- (system_rbytes || system_tbytes ||
- netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
- do_bandwidth = CONFIG_BOOLEAN_YES;
- static RRDSET *st_system_net = NULL;
- static RRDDIM *rd_in = NULL, *rd_out = NULL;
- if(unlikely(!st_system_net)) {
- st_system_net = rrdset_create_localhost(
- "system"
- , "net"
- , NULL
- , "network"
- , NULL
- , "Physical Network Interfaces Aggregated Bandwidth"
- , "kilobits/s"
- , PLUGIN_PROC_NAME
- , PLUGIN_PROC_MODULE_NETDEV_NAME
- , NETDATA_CHART_PRIO_SYSTEM_NET
- , update_every
- , RRDSET_TYPE_AREA
- );
- rd_in = rrddim_add(st_system_net, "InOctets", "received", 8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
- rd_out = rrddim_add(st_system_net, "OutOctets", "sent", -8, BITS_IN_A_KILOBIT, RRD_ALGORITHM_INCREMENTAL);
- }
- rrddim_set_by_pointer(st_system_net, rd_in, (collected_number)system_rbytes);
- rrddim_set_by_pointer(st_system_net, rd_out, (collected_number)system_tbytes);
- rrdset_done(st_system_net);
- }
- netdev_cleanup();
- return 0;
- }
- static void netdev_main_cleanup(void *ptr)
- {
- UNUSED(ptr);
- collector_info("cleaning up...");
- worker_unregister();
- }
- void *netdev_main(void *ptr)
- {
- worker_register("NETDEV");
- worker_register_job_name(0, "netdev");
- netdata_thread_cleanup_push(netdev_main_cleanup, ptr);
- rrd_collector_started();
- rrd_function_add(localhost, NULL, "network-interfaces", 10, RRDFUNCTIONS_NETDEV_HELP, true, netdev_function_net_interfaces, NULL);
- usec_t step = localhost->rrd_update_every * USEC_PER_SEC;
- heartbeat_t hb;
- heartbeat_init(&hb);
- while (service_running(SERVICE_COLLECTORS)) {
- worker_is_idle();
- usec_t hb_dt = heartbeat_next(&hb, step);
- if (unlikely(!service_running(SERVICE_COLLECTORS)))
- break;
- cgroup_netdev_reset_all();
- worker_is_busy(0);
- netdata_mutex_lock(&netdev_dev_mutex);
- if(do_proc_net_dev(localhost->rrd_update_every, hb_dt))
- break;
- netdata_mutex_unlock(&netdev_dev_mutex);
- }
- netdata_thread_cleanup_pop(1);
- return NULL;
- }
|