src/ovs_stats.c

   1 /*
   2  * collectd - src/ovs_stats.c
   3  *
   4  * Copyright(c) 2016 Intel Corporation. All rights reserved.
   5  *
   6  * Permission is hereby granted, free of charge, to any person obtaining a copy
   7  * of
   8  * this software and associated documentation files (the "Software"), to deal in
   9  * the Software without restriction, including without limitation the rights to
  10  * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies
  11  * of the Software, and to permit persons to whom the Software is furnished to
  12  * do
  13  * so, subject to the following conditions:
  14  *
  15  * The above copyright notice and this permission notice shall be included in
  16  * all
  17  * copies or substantial portions of the Software.
  18  *
  19  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  20  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  21  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  22  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  23  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  24  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  25  * SOFTWARE.
  26  *
  27  * Authors:
  28  *   Taras Chornyi <tarasx.chornyi@intel.com>
  29  */
  30
  31 #include "utils/common/common.h"
  32
  33 #include "utils/ovs/ovs.h" /* OvS helpers */
  34
  35 /* Plugin name */
  36 static const char plugin_name[] = "ovs_stats";
  37
  38 typedef enum iface_counter {
  39   not_supported = -1,
  40   collisions,
  41   rx_bytes,
  42   rx_crc_err,
  43   rx_dropped,
  44   rx_errors,
  45   rx_frame_err,
  46   rx_over_err,
  47   rx_packets,
  48   tx_bytes,
  49   tx_dropped,
  50   tx_errors,
  51   tx_packets,
  52   rx_1_to_64_packets,
  53   rx_65_to_127_packets,
  54   rx_128_to_255_packets,
  55   rx_256_to_511_packets,
  56   rx_512_to_1023_packets,
  57   rx_1024_to_1522_packets,
  58   rx_1523_to_max_packets,
  59   tx_1_to_64_packets,
  60   tx_65_to_127_packets,
  61   tx_128_to_255_packets,
  62   tx_256_to_511_packets,
  63   tx_512_to_1023_packets,
  64   tx_1024_to_1522_packets,
  65   tx_1523_to_max_packets,
  66   rx_multicast_packets,
  67   tx_multicast_packets,
  68   rx_broadcast_packets,
  69   tx_broadcast_packets,
  70   rx_undersized_errors,
  71   rx_oversize_errors,
  72   rx_fragmented_errors,
  73   rx_jabber_errors,
  74   rx_error_bytes,
  75   rx_l3_l4_xsum_error,
  76   rx_management_dropped,
  77   rx_mbuf_allocation_errors,
  78   rx_total_bytes,
  79   rx_total_missed_packets,
  80   rx_undersize_errors,
  81   rx_management_packets,
  82   tx_management_packets,
  83   rx_good_bytes,
  84   tx_good_bytes,
  85   rx_good_packets,
  86   tx_good_packets,
  87   rx_total_packets,
  88   tx_total_packets,
  89   __iface_counter_max
  90 } iface_counter;
  91
  92 #define IFACE_COUNTER_MAX (__iface_counter_max - 1)
  93 #define IFACE_COUNTER_COUNT (__iface_counter_max)
  94 #define PORT_NAME_SIZE_MAX 255
  95 #define UUID_SIZE 64
  96
  97 typedef struct interface_s {
  98   char name[PORT_NAME_SIZE_MAX];      /* Interface name */
  99   char iface_uuid[UUID_SIZE];         /* Interface table uuid */
 100   char ex_iface_id[UUID_SIZE];        /* External iface id */
 101   char ex_vm_id[UUID_SIZE];           /* External vm id */
 102   int64_t stats[IFACE_COUNTER_COUNT]; /* Statistics for interface */
 103   struct interface_s *next;           /* Next interface for associated port */
 104 } interface_list_t;
 105
 106 typedef struct port_s {
 107   char name[PORT_NAME_SIZE_MAX]; /* Port name */
 108   char port_uuid[UUID_SIZE];     /* Port table _uuid */
 109   struct bridge_list_s *br;      /* Pointer to bridge */
 110   struct interface_s *iface;     /* Pointer to first interface */
 111   struct port_s *next;           /* Next port */
 112 } port_list_t;
 113
 114 typedef struct bridge_list_s {
 115   char *name;                 /* Bridge name */
 116   struct bridge_list_s *next; /* Next bridge*/
 117 } bridge_list_t;
 118
 119 #define cnt_str(x) [x] = #x
 120
 121 static const char *const iface_counter_table[IFACE_COUNTER_COUNT] = {
 122     cnt_str(collisions),
 123     cnt_str(rx_bytes),
 124     cnt_str(rx_crc_err),
 125     cnt_str(rx_dropped),
 126     cnt_str(rx_errors),
 127     cnt_str(rx_frame_err),
 128     cnt_str(rx_over_err),
 129     cnt_str(rx_packets),
 130     cnt_str(tx_bytes),
 131     cnt_str(tx_dropped),
 132     cnt_str(tx_errors),
 133     cnt_str(tx_packets),
 134     cnt_str(rx_1_to_64_packets),
 135     cnt_str(rx_65_to_127_packets),
 136     cnt_str(rx_128_to_255_packets),
 137     cnt_str(rx_256_to_511_packets),
 138     cnt_str(rx_512_to_1023_packets),
 139     cnt_str(rx_1024_to_1522_packets),
 140     cnt_str(rx_1523_to_max_packets),
 141     cnt_str(tx_1_to_64_packets),
 142     cnt_str(tx_65_to_127_packets),
 143     cnt_str(tx_128_to_255_packets),
 144     cnt_str(tx_256_to_511_packets),
 145     cnt_str(tx_512_to_1023_packets),
 146     cnt_str(tx_1024_to_1522_packets),
 147     cnt_str(tx_1523_to_max_packets),
 148     cnt_str(rx_multicast_packets),
 149     cnt_str(tx_multicast_packets),
 150     cnt_str(rx_broadcast_packets),
 151     cnt_str(tx_broadcast_packets),
 152     cnt_str(rx_undersized_errors),
 153     cnt_str(rx_oversize_errors),
 154     cnt_str(rx_fragmented_errors),
 155     cnt_str(rx_jabber_errors),
 156     cnt_str(rx_error_bytes),
 157     cnt_str(rx_l3_l4_xsum_error),
 158     cnt_str(rx_management_dropped),
 159     cnt_str(rx_mbuf_allocation_errors),
 160     cnt_str(rx_total_bytes),
 161     cnt_str(rx_total_missed_packets),
 162     cnt_str(rx_undersize_errors),
 163     cnt_str(rx_management_packets),
 164     cnt_str(tx_management_packets),
 165     cnt_str(rx_good_bytes),
 166     cnt_str(tx_good_bytes),
 167     cnt_str(rx_good_packets),
 168     cnt_str(tx_good_packets),
 169     cnt_str(rx_total_packets),
 170     cnt_str(tx_total_packets),
 171 };
 172
 173 #undef cnt_str
 174
 175 /* Entry into the list of network bridges */
 176 static bridge_list_t *g_bridge_list_head;
 177
 178 /* Entry into the list of monitored network bridges */
 179 static bridge_list_t *g_monitored_bridge_list_head;
 180
 181 /* entry into the list of network bridges */
 182 static port_list_t *g_port_list_head;
 183
 184 /* lock for statistics cache */
 185 static pthread_mutex_t g_stats_lock;
 186
 187 /* OvS DB socket */
 188 static ovs_db_t *g_ovs_db;
 189
 190 /* OVS stats configuration data */
 191 struct ovs_stats_config_s {
 192   char ovs_db_node[OVS_DB_ADDR_NODE_SIZE];    /* OVS DB node */
 193   char ovs_db_serv[OVS_DB_ADDR_SERVICE_SIZE]; /* OVS DB service */
 194   char ovs_db_unix[OVS_DB_ADDR_UNIX_SIZE];    /* OVS DB unix socket path */
 195 };
 196 typedef struct ovs_stats_config_s ovs_stats_config_t;
 197
 198 static ovs_stats_config_t ovs_stats_cfg = {
 199     .ovs_db_node = "localhost", /* use default OVS DB node */
 200     .ovs_db_serv = "6640",      /* use default OVS DB service */
 201 };
 202
 203 /* flag indicating whether or not to publish individual interface statistics */
 204 static bool interface_stats = false;
 205
 206 static iface_counter ovs_stats_counter_name_to_type(const char *counter) {
 207   iface_counter index = not_supported;
 208
 209   if (counter == NULL)
 210     return not_supported;
 211
 212   for (int i = 0; i < IFACE_COUNTER_COUNT; i++) {
 213     if (strncmp(iface_counter_table[i], counter,
 214                 strlen(iface_counter_table[i])) == 0) {
 215       index = i;
 216       break;
 217     }
 218   }
 219   return index;
 220 }
 221
 222 static void ovs_stats_submit_one(const char *dev, const char *type,
 223                                  const char *type_instance, derive_t value,
 224                                  meta_data_t *meta) {
 225   /* if counter is less than 0 - skip it*/
 226   if (value < 0)
 227     return;
 228   value_list_t vl = VALUE_LIST_INIT;
 229
 230   vl.values = &(value_t){.derive = value};
 231   vl.values_len = 1;
 232   vl.meta = meta;
 233
 234   sstrncpy(vl.plugin, plugin_name, sizeof(vl.plugin));
 235   sstrncpy(vl.plugin_instance, dev, sizeof(vl.plugin_instance));
 236   sstrncpy(vl.type, type, sizeof(vl.type));
 237
 238   if (type_instance != NULL)
 239     sstrncpy(vl.type_instance, type_instance, sizeof(vl.type_instance));
 240
 241   plugin_dispatch_values(&vl);
 242 }
 243
 244 static void ovs_stats_submit_two(const char *dev, const char *type,
 245                                  const char *type_instance, derive_t rx,
 246                                  derive_t tx, meta_data_t *meta) {
 247   /* if counter is less than 0 - skip it*/
 248   if (rx < 0 || tx < 0)
 249     return;
 250   value_list_t vl = VALUE_LIST_INIT;
 251   value_t values[] = {{.derive = rx}, {.derive = tx}};
 252
 253   vl.values = values;
 254   vl.values_len = STATIC_ARRAY_SIZE(values);
 255   vl.meta = meta;
 256
 257   sstrncpy(vl.plugin, plugin_name, sizeof(vl.plugin));
 258   sstrncpy(vl.plugin_instance, dev, sizeof(vl.plugin_instance));
 259   sstrncpy(vl.type, type, sizeof(vl.type));
 260
 261   if (type_instance != NULL)
 262     sstrncpy(vl.type_instance, type_instance, sizeof(vl.type_instance));
 263
 264   plugin_dispatch_values(&vl);
 265 }
 266
 267 static void ovs_stats_submit_interfaces(port_list_t *port) {
 268   char devname[PORT_NAME_SIZE_MAX * 2];
 269
 270   bridge_list_t *bridge = port->br;
 271   for (interface_list_t *iface = port->iface; iface != NULL;
 272        iface = iface->next) {
 273     meta_data_t *meta = meta_data_create();
 274     if (meta != NULL) {
 275       meta_data_add_string(meta, "uuid", iface->iface_uuid);
 276
 277       if (strlen(iface->ex_vm_id))
 278         meta_data_add_string(meta, "vm-uuid", iface->ex_vm_id);
 279
 280       if (strlen(iface->ex_iface_id))
 281         meta_data_add_string(meta, "iface-id", iface->ex_iface_id);
 282     }
 283     strjoin(devname, sizeof(devname),
 284             (char *[]){
 285                 bridge->name, port->name, iface->name,
 286             },
 287             3, ".");
 288     ovs_stats_submit_one(devname, "if_collisions", NULL,
 289                          iface->stats[collisions], meta);
 290     ovs_stats_submit_two(devname, "if_dropped", NULL, iface->stats[rx_dropped],
 291                          iface->stats[tx_dropped], meta);
 292     ovs_stats_submit_two(devname, "if_errors", NULL, iface->stats[rx_errors],
 293                          iface->stats[tx_errors], meta);
 294     ovs_stats_submit_two(devname, "if_packets", NULL, iface->stats[rx_packets],
 295                          iface->stats[tx_packets], meta);
 296     ovs_stats_submit_one(devname, "if_rx_errors", "crc",
 297                          iface->stats[rx_crc_err], meta);
 298     ovs_stats_submit_one(devname, "if_rx_errors", "frame",
 299                          iface->stats[rx_frame_err], meta);
 300     ovs_stats_submit_one(devname, "if_rx_errors", "over",
 301                          iface->stats[rx_over_err], meta);
 302     ovs_stats_submit_one(devname, "if_rx_octets", NULL, iface->stats[rx_bytes],
 303                          meta);
 304     ovs_stats_submit_one(devname, "if_tx_octets", NULL, iface->stats[tx_bytes],
 305                          meta);
 306     ovs_stats_submit_two(devname, "if_packets", "1_to_64_packets",
 307                          iface->stats[rx_1_to_64_packets],
 308                          iface->stats[tx_1_to_64_packets], meta);
 309     ovs_stats_submit_two(devname, "if_packets", "65_to_127_packets",
 310                          iface->stats[rx_65_to_127_packets],
 311                          iface->stats[tx_65_to_127_packets], meta);
 312     ovs_stats_submit_two(devname, "if_packets", "128_to_255_packets",
 313                          iface->stats[rx_128_to_255_packets],
 314                          iface->stats[tx_128_to_255_packets], meta);
 315     ovs_stats_submit_two(devname, "if_packets", "256_to_511_packets",
 316                          iface->stats[rx_256_to_511_packets],
 317                          iface->stats[tx_256_to_511_packets], meta);
 318     ovs_stats_submit_two(devname, "if_packets", "512_to_1023_packets",
 319                          iface->stats[rx_512_to_1023_packets],
 320                          iface->stats[tx_512_to_1023_packets], meta);
 321     ovs_stats_submit_two(devname, "if_packets", "1024_to_1522_packets",
 322                          iface->stats[rx_1024_to_1522_packets],
 323                          iface->stats[tx_1024_to_1522_packets], meta);
 324     ovs_stats_submit_two(devname, "if_packets", "1523_to_max_packets",
 325                          iface->stats[rx_1523_to_max_packets],
 326                          iface->stats[tx_1523_to_max_packets], meta);
 327     ovs_stats_submit_two(devname, "if_packets", "broadcast_packets",
 328                          iface->stats[rx_broadcast_packets],
 329                          iface->stats[tx_broadcast_packets], meta);
 330     ovs_stats_submit_one(devname, "if_rx_errors", "rx_undersized_errors",
 331                          iface->stats[rx_undersized_errors], meta);
 332     ovs_stats_submit_one(devname, "if_rx_errors", "rx_oversize_errors",
 333                          iface->stats[rx_oversize_errors], meta);
 334     ovs_stats_submit_one(devname, "if_rx_errors", "rx_fragmented_errors",
 335                          iface->stats[rx_fragmented_errors], meta);
 336     ovs_stats_submit_one(devname, "if_rx_errors", "rx_jabber_errors",
 337                          iface->stats[rx_jabber_errors], meta);
 338     ovs_stats_submit_one(devname, "if_rx_octets", "rx_error_bytes",
 339                          iface->stats[rx_error_bytes], meta);
 340     ovs_stats_submit_one(devname, "if_errors", "rx_l3_l4_xsum_error",
 341                          iface->stats[rx_l3_l4_xsum_error], meta);
 342     ovs_stats_submit_one(devname, "if_dropped", "rx_management_dropped",
 343                          iface->stats[rx_management_dropped], meta);
 344     ovs_stats_submit_one(devname, "if_errors", "rx_mbuf_allocation_errors",
 345                          iface->stats[rx_mbuf_allocation_errors], meta);
 346     ovs_stats_submit_one(devname, "if_octets", "rx_total_bytes",
 347                          iface->stats[rx_total_bytes], meta);
 348     ovs_stats_submit_one(devname, "if_packets", "rx_total_missed_packets",
 349                          iface->stats[rx_total_missed_packets], meta);
 350     ovs_stats_submit_one(devname, "if_rx_errors", "rx_undersize_errors",
 351                          iface->stats[rx_undersize_errors], meta);
 352     ovs_stats_submit_two(devname, "if_packets", "management_packets",
 353                          iface->stats[rx_management_packets],
 354                          iface->stats[tx_management_packets], meta);
 355     ovs_stats_submit_two(devname, "if_packets", "multicast_packets",
 356                          iface->stats[rx_multicast_packets],
 357                          iface->stats[tx_multicast_packets], meta);
 358     ovs_stats_submit_two(devname, "if_octets", "good_bytes",
 359                          iface->stats[rx_good_bytes],
 360                          iface->stats[tx_good_bytes], meta);
 361     ovs_stats_submit_two(devname, "if_packets", "good_packets",
 362                          iface->stats[rx_good_packets],
 363                          iface->stats[tx_good_packets], meta);
 364     ovs_stats_submit_two(devname, "if_packets", "total_packets",
 365                          iface->stats[rx_total_packets],
 366                          iface->stats[tx_total_packets], meta);
 367
 368     meta_data_destroy(meta);
 369   }
 370 }
 371
 372 static int ovs_stats_get_port_stat_value(port_list_t *port,
 373                                          iface_counter index) {
 374   if (port == NULL)
 375     return 0;
 376
 377   int value = 0;
 378
 379   for (interface_list_t *iface = port->iface; iface != NULL;
 380        iface = iface->next) {
 381     value = value + iface->stats[index];
 382   }
 383
 384   return value;
 385 }
 386
 387 static void ovs_stats_submit_port(port_list_t *port) {
 388   char devname[PORT_NAME_SIZE_MAX * 2];
 389
 390   meta_data_t *meta = meta_data_create();
 391   if (meta != NULL) {
 392     char key_str[DATA_MAX_NAME_LEN];
 393     int i = 0;
 394
 395     for (interface_list_t *iface = port->iface; iface != NULL;
 396          iface = iface->next) {
 397       snprintf(key_str, sizeof(key_str), "uuid%d", i);
 398       meta_data_add_string(meta, key_str, iface->iface_uuid);
 399
 400       if (strlen(iface->ex_vm_id)) {
 401         snprintf(key_str, sizeof(key_str), "vm-uuid%d", i);
 402         meta_data_add_string(meta, key_str, iface->ex_vm_id);
 403       }
 404
 405       if (strlen(iface->ex_iface_id)) {
 406         snprintf(key_str, sizeof(key_str), "iface-id%d", i);
 407         meta_data_add_string(meta, key_str, iface->ex_iface_id);
 408       }
 409
 410       i++;
 411     }
 412   }
 413   bridge_list_t *bridge = port->br;
 414   snprintf(devname, sizeof(devname), "%s.%s", bridge->name, port->name);
 415   ovs_stats_submit_one(devname, "if_collisions", NULL,
 416                        ovs_stats_get_port_stat_value(port, collisions), meta);
 417   ovs_stats_submit_two(devname, "if_dropped", NULL,
 418                        ovs_stats_get_port_stat_value(port, rx_dropped),
 419                        ovs_stats_get_port_stat_value(port, tx_dropped), meta);
 420   ovs_stats_submit_two(devname, "if_errors", NULL,
 421                        ovs_stats_get_port_stat_value(port, rx_errors),
 422                        ovs_stats_get_port_stat_value(port, tx_errors), meta);
 423   ovs_stats_submit_two(devname, "if_packets", NULL,
 424                        ovs_stats_get_port_stat_value(port, rx_packets),
 425                        ovs_stats_get_port_stat_value(port, tx_packets), meta);
 426   ovs_stats_submit_one(devname, "if_rx_errors", "crc",
 427                        ovs_stats_get_port_stat_value(port, rx_crc_err), meta);
 428   ovs_stats_submit_one(devname, "if_rx_errors", "frame",
 429                        ovs_stats_get_port_stat_value(port, rx_frame_err), meta);
 430   ovs_stats_submit_one(devname, "if_rx_errors", "over",
 431                        ovs_stats_get_port_stat_value(port, rx_over_err), meta);
 432   ovs_stats_submit_one(devname, "if_rx_octets", NULL,
 433                        ovs_stats_get_port_stat_value(port, rx_bytes), meta);
 434   ovs_stats_submit_one(devname, "if_tx_octets", NULL,
 435                        ovs_stats_get_port_stat_value(port, tx_bytes), meta);
 436   ovs_stats_submit_two(devname, "if_packets", "1_to_64_packets",
 437                        ovs_stats_get_port_stat_value(port, rx_1_to_64_packets),
 438                        ovs_stats_get_port_stat_value(port, tx_1_to_64_packets),
 439                        meta);
 440   ovs_stats_submit_two(
 441       devname, "if_packets", "65_to_127_packets",
 442       ovs_stats_get_port_stat_value(port, rx_65_to_127_packets),
 443       ovs_stats_get_port_stat_value(port, tx_65_to_127_packets), meta);
 444   ovs_stats_submit_two(
 445       devname, "if_packets", "128_to_255_packets",
 446       ovs_stats_get_port_stat_value(port, rx_128_to_255_packets),
 447       ovs_stats_get_port_stat_value(port, tx_128_to_255_packets), meta);
 448   ovs_stats_submit_two(
 449       devname, "if_packets", "256_to_511_packets",
 450       ovs_stats_get_port_stat_value(port, rx_256_to_511_packets),
 451       ovs_stats_get_port_stat_value(port, tx_256_to_511_packets), meta);
 452   ovs_stats_submit_two(
 453       devname, "if_packets", "512_to_1023_packets",
 454       ovs_stats_get_port_stat_value(port, rx_512_to_1023_packets),
 455       ovs_stats_get_port_stat_value(port, tx_512_to_1023_packets), meta);
 456   ovs_stats_submit_two(
 457       devname, "if_packets", "1024_to_1522_packets",
 458       ovs_stats_get_port_stat_value(port, rx_1024_to_1522_packets),
 459       ovs_stats_get_port_stat_value(port, tx_1024_to_1522_packets), meta);
 460   ovs_stats_submit_two(
 461       devname, "if_packets", "1523_to_max_packets",
 462       ovs_stats_get_port_stat_value(port, rx_1523_to_max_packets),
 463       ovs_stats_get_port_stat_value(port, tx_1523_to_max_packets), meta);
 464   ovs_stats_submit_two(
 465       devname, "if_packets", "broadcast_packets",
 466       ovs_stats_get_port_stat_value(port, rx_broadcast_packets),
 467       ovs_stats_get_port_stat_value(port, tx_broadcast_packets), meta);
 468   ovs_stats_submit_one(
 469       devname, "if_rx_errors", "rx_undersized_errors",
 470       ovs_stats_get_port_stat_value(port, rx_undersized_errors), meta);
 471   ovs_stats_submit_one(devname, "if_rx_errors", "rx_oversize_errors",
 472                        ovs_stats_get_port_stat_value(port, rx_oversize_errors),
 473                        meta);
 474   ovs_stats_submit_one(
 475       devname, "if_rx_errors", "rx_fragmented_errors",
 476       ovs_stats_get_port_stat_value(port, rx_fragmented_errors), meta);
 477   ovs_stats_submit_one(devname, "if_rx_errors", "rx_jabber_errors",
 478                        ovs_stats_get_port_stat_value(port, rx_jabber_errors),
 479                        meta);
 480   ovs_stats_submit_one(devname, "if_rx_octets", "rx_error_bytes",
 481                        ovs_stats_get_port_stat_value(port, rx_error_bytes),
 482                        meta);
 483   ovs_stats_submit_one(devname, "if_errors", "rx_l3_l4_xsum_error",
 484                        ovs_stats_get_port_stat_value(port, rx_l3_l4_xsum_error),
 485                        meta);
 486   ovs_stats_submit_one(
 487       devname, "if_dropped", "rx_management_dropped",
 488       ovs_stats_get_port_stat_value(port, rx_management_dropped), meta);
 489   ovs_stats_submit_one(
 490       devname, "if_errors", "rx_mbuf_allocation_errors",
 491       ovs_stats_get_port_stat_value(port, rx_mbuf_allocation_errors), meta);
 492   ovs_stats_submit_one(devname, "if_octets", "rx_total_bytes",
 493                        ovs_stats_get_port_stat_value(port, rx_total_bytes),
 494                        meta);
 495   ovs_stats_submit_one(
 496       devname, "if_packets", "rx_total_missed_packets",
 497       ovs_stats_get_port_stat_value(port, rx_total_missed_packets), meta);
 498   ovs_stats_submit_one(devname, "if_rx_errors", "rx_undersize_errors",
 499                        ovs_stats_get_port_stat_value(port, rx_undersize_errors),
 500                        meta);
 501   ovs_stats_submit_two(
 502       devname, "if_packets", "management_packets",
 503       ovs_stats_get_port_stat_value(port, rx_management_packets),
 504       ovs_stats_get_port_stat_value(port, tx_management_packets), meta);
 505   ovs_stats_submit_two(
 506       devname, "if_packets", "multicast_packets",
 507       ovs_stats_get_port_stat_value(port, rx_multicast_packets),
 508       ovs_stats_get_port_stat_value(port, tx_multicast_packets), meta);
 509   ovs_stats_submit_two(devname, "if_octets", "good_bytes",
 510                        ovs_stats_get_port_stat_value(port, rx_good_bytes),
 511                        ovs_stats_get_port_stat_value(port, tx_good_bytes),
 512                        meta);
 513   ovs_stats_submit_two(devname, "if_packets", "good_packets",
 514                        ovs_stats_get_port_stat_value(port, rx_good_packets),
 515                        ovs_stats_get_port_stat_value(port, tx_good_packets),
 516                        meta);
 517   ovs_stats_submit_two(devname, "if_packets", "total_packets",
 518                        ovs_stats_get_port_stat_value(port, rx_total_packets),
 519                        ovs_stats_get_port_stat_value(port, tx_total_packets),
 520                        meta);
 521
 522   meta_data_destroy(meta);
 523 }
 524
 525 static port_list_t *ovs_stats_get_port(const char *uuid) {
 526   if (uuid == NULL)
 527     return NULL;
 528
 529   for (port_list_t *port = g_port_list_head; port != NULL; port = port->next) {
 530     if (strncmp(port->port_uuid, uuid, strlen(port->port_uuid)) == 0)
 531       return port;
 532   }
 533   return NULL;
 534 }
 535
 536 static port_list_t *ovs_stats_get_port_by_interface_uuid(const char *uuid) {
 537   if (uuid == NULL)
 538     return NULL;
 539
 540   for (port_list_t *port = g_port_list_head; port != NULL; port = port->next) {
 541     for (interface_list_t *iface = port->iface; iface != NULL;
 542          iface = iface->next) {
 543       if (strncmp(iface->iface_uuid, uuid, strlen(uuid)) == 0)
 544         return port;
 545     }
 546   }
 547   return NULL;
 548 }
 549
 550 static interface_list_t *ovs_stats_get_port_interface(port_list_t *port,
 551                                                       const char *uuid) {
 552   if (port == NULL || uuid == NULL)
 553     return NULL;
 554
 555   for (interface_list_t *iface = port->iface; iface != NULL;
 556        iface = iface->next) {
 557     if (strncmp(iface->iface_uuid, uuid, strlen(uuid)) == 0)
 558       return iface;
 559   }
 560   return NULL;
 561 }
 562
 563 static interface_list_t *ovs_stats_get_interface(const char *uuid) {
 564   if (uuid == NULL)
 565     return NULL;
 566
 567   for (port_list_t *port = g_port_list_head; port != NULL; port = port->next) {
 568     for (interface_list_t *iface = port->iface; iface != NULL;
 569          iface = iface->next) {
 570       if (strncmp(iface->iface_uuid, uuid, strlen(uuid)) == 0)
 571         return iface;
 572     }
 573   }
 574   return NULL;
 575 }
 576
 577 static interface_list_t *ovs_stats_new_port_interface(port_list_t *port,
 578                                                       const char *uuid) {
 579   if (uuid == NULL)
 580     return NULL;
 581
 582   interface_list_t *iface = ovs_stats_get_port_interface(port, uuid);
 583
 584   if (iface == NULL) {
 585     iface = calloc(1, sizeof(*iface));
 586     if (iface == NULL) {
 587       ERROR("%s: Error allocating interface", plugin_name);
 588       return NULL;
 589     }
 590     memset(iface->stats, -1, sizeof(int64_t[IFACE_COUNTER_COUNT]));
 591     sstrncpy(iface->iface_uuid, uuid, sizeof(iface->iface_uuid));
 592     interface_list_t *iface_head = port->iface;
 593     iface->next = iface_head;
 594     port->iface = iface;
 595   }
 596   return iface;
 597 }
 598
 599 /* Create or get port by port uuid */
 600 static port_list_t *ovs_stats_new_port(bridge_list_t *bridge,
 601                                        const char *uuid) {
 602   if (uuid == NULL)
 603     return NULL;
 604
 605   port_list_t *port = ovs_stats_get_port(uuid);
 606
 607   if (port == NULL) {
 608     port = calloc(1, sizeof(*port));
 609     if (port == NULL) {
 610       ERROR("%s: Error allocating port", plugin_name);
 611       return NULL;
 612     }
 613     sstrncpy(port->port_uuid, uuid, sizeof(port->port_uuid));
 614     port->next = g_port_list_head;
 615     g_port_list_head = port;
 616   }
 617   if (bridge != NULL) {
 618     port->br = bridge;
 619   }
 620   return port;
 621 }
 622
 623 /* Get bridge by name*/
 624 static bridge_list_t *ovs_stats_get_bridge(bridge_list_t *head,
 625                                            const char *name) {
 626   if (name == NULL)
 627     return NULL;
 628
 629   for (bridge_list_t *bridge = head; bridge != NULL; bridge = bridge->next) {
 630     if ((strncmp(bridge->name, name, strlen(bridge->name)) == 0) &&
 631         strlen(name) == strlen(bridge->name))
 632       return bridge;
 633   }
 634   return NULL;
 635 }
 636
 637 /* Check if bridge is configured to be monitored in config file */
 638 static int ovs_stats_is_monitored_bridge(const char *br_name) {
 639   /* if no bridges are configured, return true */
 640   if (g_monitored_bridge_list_head == NULL)
 641     return 1;
 642
 643   /* check if given bridge exists */
 644   if (ovs_stats_get_bridge(g_monitored_bridge_list_head, br_name) != NULL)
 645     return 1;
 646
 647   return 0;
 648 }
 649
 650 /* Delete bridge */
 651 static int ovs_stats_del_bridge(yajl_val bridge) {
 652   const char *old[] = {"old", NULL};
 653   const char *name[] = {"name", NULL};
 654
 655   if (!bridge || !YAJL_IS_OBJECT(bridge)) {
 656     WARNING("%s: Incorrect data for deleting bridge", plugin_name);
 657     return 0;
 658   }
 659
 660   yajl_val row = yajl_tree_get(bridge, old, yajl_t_object);
 661   if (!row || !YAJL_IS_OBJECT(row))
 662     return 0;
 663
 664   yajl_val br_name = yajl_tree_get(row, name, yajl_t_string);
 665   if (!br_name || !YAJL_IS_STRING(br_name))
 666     return 0;
 667
 668   bridge_list_t *prev_br = g_bridge_list_head;
 669   for (bridge_list_t *br = g_bridge_list_head; br != NULL;
 670        prev_br = br, br = br->next) {
 671     if ((strncmp(br->name, br_name->u.string, strlen(br->name)) == 0) &&
 672         strlen(br->name) == strlen(br_name->u.string)) {
 673       if (br == g_bridge_list_head)
 674         g_bridge_list_head = br->next;
 675       else
 676         prev_br->next = br->next;
 677       sfree(br->name);
 678       sfree(br);
 679       break;
 680     }
 681   }
 682   return 0;
 683 }
 684
 685 /* Update Bridge. Create bridge ports*/
 686 static int ovs_stats_update_bridge(yajl_val bridge) {
 687   const char *new[] = {"new", NULL};
 688   const char *name[] = {"name", NULL};
 689   const char *ports[] = {"ports", NULL};
 690
 691   if (!bridge || !YAJL_IS_OBJECT(bridge))
 692     goto failure;
 693
 694   yajl_val row = yajl_tree_get(bridge, new, yajl_t_object);
 695   if (!row || !YAJL_IS_OBJECT(row))
 696     return 0;
 697
 698   yajl_val br_name = yajl_tree_get(row, name, yajl_t_string);
 699   if (!br_name || !YAJL_IS_STRING(br_name))
 700     return 0;
 701
 702   if (!ovs_stats_is_monitored_bridge(YAJL_GET_STRING(br_name)))
 703     return 0;
 704
 705   bridge_list_t *br =
 706       ovs_stats_get_bridge(g_bridge_list_head, YAJL_GET_STRING(br_name));
 707   if (br == NULL) {
 708     br = calloc(1, sizeof(*br));
 709     if (br == NULL) {
 710       ERROR("%s: calloc(%zu) failed.", plugin_name, sizeof(*br));
 711       return -1;
 712     }
 713
 714     char *tmp = YAJL_GET_STRING(br_name);
 715     if (tmp != NULL)
 716       br->name = strdup(tmp);
 717
 718     if (br->name == NULL) {
 719       sfree(br);
 720       ERROR("%s: strdup failed.", plugin_name);
 721       return -1;
 722     }
 723
 724     br->next = g_bridge_list_head;
 725     g_bridge_list_head = br;
 726   }
 727
 728   yajl_val br_ports = yajl_tree_get(row, ports, yajl_t_array);
 729   if (!br_ports || !YAJL_IS_ARRAY(br_ports))
 730     return 0;
 731
 732   char *tmp = YAJL_GET_STRING(br_ports->u.array.values[0]);
 733   if (tmp != NULL && strcmp("set", tmp) == 0) {
 734     yajl_val *array = YAJL_GET_ARRAY(br_ports)->values;
 735     size_t array_len = YAJL_GET_ARRAY(br_ports)->len;
 736     if (array != NULL && array_len > 0 && YAJL_IS_ARRAY(array[1])) {
 737       if (YAJL_GET_ARRAY(array[1]) == NULL)
 738         goto failure;
 739
 740       yajl_val *ports_arr = YAJL_GET_ARRAY(array[1])->values;
 741       size_t ports_num = YAJL_GET_ARRAY(array[1])->len;
 742       for (size_t i = 0; i < ports_num && ports_arr != NULL; i++) {
 743         tmp = YAJL_GET_STRING(ports_arr[i]->u.array.values[1]);
 744         if (tmp != NULL)
 745           ovs_stats_new_port(br, tmp);
 746         else
 747           goto failure;
 748       }
 749     }
 750   } else {
 751     ovs_stats_new_port(br, YAJL_GET_STRING(br_ports->u.array.values[1]));
 752   }
 753
 754   return 0;
 755
 756 failure:
 757   ERROR("Incorrect JSON Bridge data");
 758   return -1;
 759 }
 760
 761 /* Handle JSON with Bridge Table change event */
 762 static void ovs_stats_bridge_table_change_cb(yajl_val jupdates) {
 763   /* Bridge Table update example JSON data
 764     {
 765       "Bridge": {
 766         "bb1f8965-5775-46d9-b820-236ca8edbedc": {
 767           "new": {
 768             "name": "br0",
 769             "ports": [
 770               "set",
 771               [
 772                 [
 773                   "uuid",
 774                   "117f1a07-7ef0-458a-865c-ec7fbb85bc01"
 775                 ],
 776                 [
 777                   "uuid",
 778                   "12fd8bdc-e950-4281-aaa9-46e185658f79"
 779                 ]
 780               ]
 781             ]
 782           }
 783         }
 784       }
 785     }
 786    */
 787   const char *path[] = {"Bridge", NULL};
 788   yajl_val bridges = yajl_tree_get(jupdates, path, yajl_t_object);
 789
 790   if (!bridges || !YAJL_IS_OBJECT(bridges))
 791     return;
 792
 793   pthread_mutex_lock(&g_stats_lock);
 794   for (size_t i = 0; i < YAJL_GET_OBJECT(bridges)->len; i++) {
 795     yajl_val bridge = YAJL_GET_OBJECT(bridges)->values[i];
 796     ovs_stats_update_bridge(bridge);
 797   }
 798   pthread_mutex_unlock(&g_stats_lock);
 799 }
 800
 801 /* Handle Bridge Table delete event */
 802 static void ovs_stats_bridge_table_delete_cb(yajl_val jupdates) {
 803   const char *path[] = {"Bridge", NULL};
 804   yajl_val bridges = yajl_tree_get(jupdates, path, yajl_t_object);
 805   if (!bridges || !YAJL_IS_OBJECT(bridges))
 806     return;
 807
 808   pthread_mutex_lock(&g_stats_lock);
 809   for (size_t i = 0; i < YAJL_GET_OBJECT(bridges)->len; i++) {
 810     yajl_val bridge = YAJL_GET_OBJECT(bridges)->values[i];
 811     ovs_stats_del_bridge(bridge);
 812   }
 813   pthread_mutex_unlock(&g_stats_lock);
 814 }
 815
 816 /* Handle JSON with Bridge table initial values */
 817 static void ovs_stats_bridge_table_result_cb(yajl_val jresult,
 818                                              yajl_val jerror) {
 819   if (YAJL_IS_NULL(jerror))
 820     ovs_stats_bridge_table_change_cb(jresult);
 821   else
 822     ERROR("%s: Error received from OvSDB. Table: Bridge", plugin_name);
 823   return;
 824 }
 825
 826 /* Update port name and interface UUID(s)*/
 827 static int ovs_stats_update_port(const char *uuid, yajl_val port) {
 828   const char *new[] = {"new", NULL};
 829   const char *name[] = {"name", NULL};
 830
 831   if (!port || !YAJL_IS_OBJECT(port)) {
 832     ERROR("Incorrect JSON Port data");
 833     return -1;
 834   }
 835
 836   yajl_val row = yajl_tree_get(port, new, yajl_t_object);
 837   if (!row || !YAJL_IS_OBJECT(row))
 838     return 0;
 839
 840   yajl_val port_name = yajl_tree_get(row, name, yajl_t_string);
 841   if (!port_name || !YAJL_IS_STRING(port_name))
 842     return 0;
 843
 844   /* Create or get port by port uuid */
 845   port_list_t *portentry = ovs_stats_new_port(NULL, uuid);
 846   if (!portentry)
 847     return 0;
 848
 849   sstrncpy(portentry->name, YAJL_GET_STRING(port_name),
 850            sizeof(portentry->name));
 851
 852   yajl_val ifaces_root = ovs_utils_get_value_by_key(row, "interfaces");
 853   char *ifaces_root_key =
 854       YAJL_GET_STRING(YAJL_GET_ARRAY(ifaces_root)->values[0]);
 855
 856   if (strcmp("set", ifaces_root_key) == 0) {
 857     // ifaces_root is ["set", [[ "uuid", "<some_uuid>" ], [ "uuid",
 858     // "<another_uuid>" ], ... ]]
 859     yajl_val ifaces_list = YAJL_GET_ARRAY(ifaces_root)->values[1];
 860
 861     // ifaces_list is [[ "uuid", "<some_uuid>" ], [ "uuid",
 862     // "<another_uuid>" ], ... ]]
 863     for (size_t i = 0; i < YAJL_GET_ARRAY(ifaces_list)->len; i++) {
 864       yajl_val iface_tuple = YAJL_GET_ARRAY(ifaces_list)->values[i];
 865
 866       // iface_tuple is [ "uuid", "<some_uuid>" ]
 867       char *iface_uuid_str =
 868           YAJL_GET_STRING(YAJL_GET_ARRAY(iface_tuple)->values[1]);
 869
 870       // Also checks if interface already registered
 871       ovs_stats_new_port_interface(portentry, iface_uuid_str);
 872     }
 873   } else {
 874     // ifaces_root is [ "uuid", "<some_uuid>" ]
 875     char *iface_uuid_str =
 876         YAJL_GET_STRING(YAJL_GET_ARRAY(ifaces_root)->values[1]);
 877
 878     // Also checks if interface already registered
 879     ovs_stats_new_port_interface(portentry, iface_uuid_str);
 880   }
 881
 882   return 0;
 883 }
 884
 885 /* Delete port from global port list */
 886 static int ovs_stats_del_port(const char *uuid) {
 887   port_list_t *prev_port = g_port_list_head;
 888   for (port_list_t *port = g_port_list_head; port != NULL;
 889        prev_port = port, port = port->next) {
 890     if (strncmp(port->port_uuid, uuid, strlen(port->port_uuid)) == 0) {
 891       if (port == g_port_list_head)
 892         g_port_list_head = port->next;
 893       else
 894         prev_port->next = port->next;
 895
 896       for (interface_list_t *iface = port->iface; iface != NULL;
 897            iface = port->iface) {
 898         interface_list_t *del = iface;
 899         port->iface = iface->next;
 900         sfree(del);
 901       }
 902
 903       sfree(port);
 904       break;
 905     }
 906   }
 907   return 0;
 908 }
 909
 910 /* Handle JSON with Port Table change event */
 911 static void ovs_stats_port_table_change_cb(yajl_val jupdates) {
 912   /* Port Table update example JSON data
 913     {
 914       "Port": {
 915         "ab107d6f-28a1-4257-b1cc-5b742821db8a": {
 916           "new": {
 917             "name": "br1",
 918             "interfaces": [
 919               "uuid",
 920               "33a289a0-1d34-4e46-a3c2-3e4066fbecc6"
 921             ]
 922           }
 923         }
 924       }
 925     }
 926    */
 927   const char *path[] = {"Port", NULL};
 928   yajl_val ports = yajl_tree_get(jupdates, path, yajl_t_object);
 929   if (!ports || !YAJL_IS_OBJECT(ports))
 930     return;
 931
 932   pthread_mutex_lock(&g_stats_lock);
 933   for (size_t i = 0; i < YAJL_GET_OBJECT(ports)->len; i++) {
 934     yajl_val port = YAJL_GET_OBJECT(ports)->values[i];
 935     ovs_stats_update_port(YAJL_GET_OBJECT(ports)->keys[i], port);
 936   }
 937   pthread_mutex_unlock(&g_stats_lock);
 938   return;
 939 }
 940
 941 /* Handle JSON with Port table initial values */
 942 static void ovs_stats_port_table_result_cb(yajl_val jresult, yajl_val jerror) {
 943   if (YAJL_IS_NULL(jerror))
 944     ovs_stats_port_table_change_cb(jresult);
 945   else
 946     ERROR("%s: Error received from OvSDB. Table: Port", plugin_name);
 947   return;
 948 }
 949
 950 /* Handle Port Table delete event */
 951 static void ovs_stats_port_table_delete_cb(yajl_val jupdates) {
 952   const char *path[] = {"Port", NULL};
 953   yajl_val ports = yajl_tree_get(jupdates, path, yajl_t_object);
 954   if (!ports || !YAJL_IS_OBJECT(ports))
 955     return;
 956
 957   pthread_mutex_lock(&g_stats_lock);
 958   for (size_t i = 0; i < YAJL_GET_OBJECT(ports)->len; i++) {
 959     ovs_stats_del_port(YAJL_GET_OBJECT(ports)->keys[i]);
 960   }
 961   pthread_mutex_unlock(&g_stats_lock);
 962   return;
 963 }
 964
 965 /* Update interface statistics */
 966 static int ovs_stats_update_iface_stats(interface_list_t *iface,
 967                                         yajl_val stats) {
 968
 969   if (!stats || !YAJL_IS_ARRAY(stats))
 970     return 0;
 971
 972   for (size_t i = 0; i < YAJL_GET_ARRAY(stats)->len; i++) {
 973     yajl_val stat = YAJL_GET_ARRAY(stats)->values[i];
 974     if (!YAJL_IS_ARRAY(stat))
 975       return -1;
 976
 977     char *counter_name = YAJL_GET_STRING(YAJL_GET_ARRAY(stat)->values[0]);
 978     iface_counter counter_index = ovs_stats_counter_name_to_type(counter_name);
 979     int64_t counter_value = YAJL_GET_INTEGER(YAJL_GET_ARRAY(stat)->values[1]);
 980     if (counter_index == not_supported)
 981       continue;
 982
 983     iface->stats[counter_index] = counter_value;
 984   }
 985
 986   return 0;
 987 }
 988
 989 /* Update interface external_ids */
 990 static int ovs_stats_update_iface_ext_ids(interface_list_t *iface,
 991                                           yajl_val ext_ids) {
 992
 993   if (!ext_ids || !YAJL_IS_ARRAY(ext_ids))
 994     return 0;
 995
 996   for (size_t i = 0; i < YAJL_GET_ARRAY(ext_ids)->len; i++) {
 997     yajl_val ext_id = YAJL_GET_ARRAY(ext_ids)->values[i];
 998     if (!YAJL_IS_ARRAY(ext_id))
 999       return -1;
1000
1001     char *key = YAJL_GET_STRING(YAJL_GET_ARRAY(ext_id)->values[0]);
1002     char *value = YAJL_GET_STRING(YAJL_GET_ARRAY(ext_id)->values[1]);
1003     if (key && value) {
1004       if (strncmp(key, "iface-id", strlen(key)) == 0) {
1005         sstrncpy(iface->ex_iface_id, value, sizeof(iface->ex_iface_id));
1006       } else if (strncmp(key, "vm-uuid", strlen(key)) == 0) {
1007         sstrncpy(iface->ex_vm_id, value, sizeof(iface->ex_vm_id));
1008       }
1009     }
1010   }
1011
1012   return 0;
1013 }
1014
1015 /* Get interface statistic and external_ids */
1016 static int ovs_stats_update_iface(yajl_val iface_obj) {
1017   if (!iface_obj || !YAJL_IS_OBJECT(iface_obj)) {
1018     ERROR("ovs_stats plugin: incorrect JSON interface data");
1019     return -1;
1020   }
1021
1022   yajl_val row = ovs_utils_get_value_by_key(iface_obj, "new");
1023   if (!row || !YAJL_IS_OBJECT(row))
1024     return 0;
1025
1026   yajl_val iface_name = ovs_utils_get_value_by_key(row, "name");
1027   if (!iface_name || !YAJL_IS_STRING(iface_name))
1028     return 0;
1029
1030   yajl_val iface_uuid = ovs_utils_get_value_by_key(row, "_uuid");
1031   if (!iface_uuid || !YAJL_IS_ARRAY(iface_uuid) ||
1032       YAJL_GET_ARRAY(iface_uuid)->len != 2)
1033     return 0;
1034
1035   char *iface_uuid_str = YAJL_GET_STRING(YAJL_GET_ARRAY(iface_uuid)->values[1]);
1036   if (iface_uuid_str == NULL) {
1037     ERROR("ovs_stats plugin: incorrect JSON interface data");
1038     return -1;
1039   }
1040
1041   interface_list_t *iface = ovs_stats_get_interface(iface_uuid_str);
1042   if (iface == NULL)
1043     return 0;
1044
1045   sstrncpy(iface->name, YAJL_GET_STRING(iface_name), sizeof(iface->name));
1046
1047   yajl_val iface_stats = ovs_utils_get_value_by_key(row, "statistics");
1048   yajl_val iface_ext_ids = ovs_utils_get_value_by_key(row, "external_ids");
1049
1050   /*
1051    * {
1052         "statistics": [
1053           "map",
1054           [
1055             [
1056               "collisions",
1057               0
1058             ],
1059             . . .
1060             [
1061               "tx_packets",
1062               0
1063             ]
1064           ]
1065         ]
1066       }
1067    Check that statistics is an array with 2 elements
1068    */
1069
1070   if (iface_stats && YAJL_IS_ARRAY(iface_stats) &&
1071       YAJL_GET_ARRAY(iface_stats)->len == 2)
1072     ovs_stats_update_iface_stats(iface, YAJL_GET_ARRAY(iface_stats)->values[1]);
1073
1074   if (iface_ext_ids && YAJL_IS_ARRAY(iface_ext_ids))
1075     ovs_stats_update_iface_ext_ids(iface,
1076                                    YAJL_GET_ARRAY(iface_ext_ids)->values[1]);
1077
1078   return 0;
1079 }
1080
1081 /* Delete interface */
1082 static int ovs_stats_del_interface(const char *uuid) {
1083   port_list_t *port = ovs_stats_get_port_by_interface_uuid(uuid);
1084
1085   if (port == NULL)
1086     return 0;
1087
1088   interface_list_t *prev_iface = NULL;
1089
1090   for (interface_list_t *iface = port->iface; iface != NULL;
1091        iface = port->iface) {
1092     if (strncmp(iface->iface_uuid, uuid, strlen(iface->iface_uuid))) {
1093
1094       interface_list_t *del = iface;
1095
1096       if (prev_iface == NULL)
1097         port->iface = iface->next;
1098       else
1099         prev_iface->next = iface->next;
1100
1101       sfree(del);
1102       break;
1103     } else {
1104       prev_iface = iface;
1105     }
1106   }
1107
1108   return 0;
1109 }
1110
1111 /* Handle JSON with Interface Table change event */
1112 static void ovs_stats_interface_table_change_cb(yajl_val jupdates) {
1113   /* Interface Table update example JSON data
1114     {
1115       "Interface": {
1116         "33a289a0-1d34-4e46-a3c2-3e4066fbecc6": {
1117           "new": {
1118             "name": "br1",
1119             "statistics": [
1120               "map",
1121               [
1122                 [
1123                   "collisions",
1124                   0
1125                 ],
1126                 [
1127                   "rx_bytes",
1128                   0
1129                 ],
1130                . . .
1131                 [
1132                   "tx_packets",
1133                   12617
1134                 ]
1135               ]
1136             ],
1137             "_uuid": [
1138               "uuid",
1139               "33a289a0-1d34-4e46-a3c2-3e4066fbecc6"
1140             ]
1141             "external_ids": [
1142                 "map",
1143                 [
1144                   [
1145                     "attached-mac",
1146                     "fa:16:3e:7c:1c:4b"
1147                   ],
1148                   [
1149                     "iface-id",
1150                     "a61b7e2b-6951-488a-b4c6-6e91343960b2"
1151                   ],
1152                   [
1153                     "iface-status",
1154                     "active"
1155                   ]
1156                 ]
1157               ]
1158           }
1159         }
1160       }
1161     }
1162    */
1163   const char *path[] = {"Interface", NULL};
1164   yajl_val interfaces = yajl_tree_get(jupdates, path, yajl_t_object);
1165   if (!interfaces || !YAJL_IS_OBJECT(interfaces))
1166     return;
1167
1168   pthread_mutex_lock(&g_stats_lock);
1169   for (size_t i = 0; i < YAJL_GET_OBJECT(interfaces)->len; i++) {
1170     ovs_stats_update_iface(YAJL_GET_OBJECT(interfaces)->values[i]);
1171   }
1172   pthread_mutex_unlock(&g_stats_lock);
1173
1174   return;
1175 }
1176
1177 /* Handle JSON with Interface table initial values */
1178 static void ovs_stats_interface_table_result_cb(yajl_val jresult,
1179                                                 yajl_val jerror) {
1180   if (YAJL_IS_NULL(jerror))
1181     ovs_stats_interface_table_change_cb(jresult);
1182   else
1183     ERROR("%s: Error received from OvSDB. Table: Interface", plugin_name);
1184   return;
1185 }
1186
1187 /* Handle Interface Table delete event */
1188 static void ovs_stats_interface_table_delete_cb(yajl_val jupdates) {
1189   const char *path[] = {"Interface", NULL};
1190   yajl_val interfaces = yajl_tree_get(jupdates, path, yajl_t_object);
1191   if (!interfaces || !YAJL_IS_OBJECT(interfaces))
1192     return;
1193
1194   pthread_mutex_lock(&g_stats_lock);
1195   for (size_t i = 0; i < YAJL_GET_OBJECT(interfaces)->len; i++) {
1196     ovs_stats_del_interface(YAJL_GET_OBJECT(interfaces)->keys[i]);
1197   }
1198   pthread_mutex_unlock(&g_stats_lock);
1199
1200   return;
1201 }
1202
1203 /* Setup OVS DB table callbacks  */
1204 static void ovs_stats_initialize(ovs_db_t *pdb) {
1205   const char *bridge_columns[] = {"name", "ports", NULL};
1206   const char *port_columns[] = {"name", "interfaces", NULL};
1207   const char *interface_columns[] = {"name", "statistics", "_uuid",
1208                                      "external_ids", NULL};
1209
1210   /* subscribe to a tables */
1211   ovs_db_table_cb_register(
1212       pdb, "Bridge", bridge_columns, ovs_stats_bridge_table_change_cb,
1213       ovs_stats_bridge_table_result_cb,
1214       OVS_DB_TABLE_CB_FLAG_INITIAL | OVS_DB_TABLE_CB_FLAG_INSERT |
1215           OVS_DB_TABLE_CB_FLAG_MODIFY);
1216
1217   ovs_db_table_cb_register(pdb, "Bridge", bridge_columns,
1218                            ovs_stats_bridge_table_delete_cb, NULL,
1219                            OVS_DB_TABLE_CB_FLAG_DELETE);
1220
1221   ovs_db_table_cb_register(
1222       pdb, "Port", port_columns, ovs_stats_port_table_change_cb,
1223       ovs_stats_port_table_result_cb,
1224       OVS_DB_TABLE_CB_FLAG_INITIAL | OVS_DB_TABLE_CB_FLAG_INSERT |
1225           OVS_DB_TABLE_CB_FLAG_MODIFY);
1226
1227   ovs_db_table_cb_register(pdb, "Port", port_columns,
1228                            ovs_stats_port_table_delete_cb, NULL,
1229                            OVS_DB_TABLE_CB_FLAG_DELETE);
1230
1231   ovs_db_table_cb_register(
1232       pdb, "Interface", interface_columns, ovs_stats_interface_table_change_cb,
1233       ovs_stats_interface_table_result_cb,
1234       OVS_DB_TABLE_CB_FLAG_INITIAL | OVS_DB_TABLE_CB_FLAG_INSERT |
1235           OVS_DB_TABLE_CB_FLAG_MODIFY);
1236
1237   ovs_db_table_cb_register(pdb, "Interface", interface_columns,
1238                            ovs_stats_interface_table_delete_cb, NULL,
1239                            OVS_DB_TABLE_CB_FLAG_DELETE);
1240 }
1241
1242 /* Delete all ports from port list */
1243 static void ovs_stats_free_port_list(port_list_t *head) {
1244   for (port_list_t *i = head; i != NULL;) {
1245     port_list_t *del = i;
1246
1247     for (interface_list_t *iface = i->iface; iface != NULL; iface = i->iface) {
1248       interface_list_t *del2 = iface;
1249       i->iface = iface->next;
1250       sfree(del2);
1251     }
1252
1253     i = i->next;
1254     sfree(del);
1255   }
1256 }
1257
1258 /* Delete all bridges from bridge list */
1259 static void ovs_stats_free_bridge_list(bridge_list_t *head) {
1260   for (bridge_list_t *i = head; i != NULL;) {
1261     bridge_list_t *del = i;
1262     i = i->next;
1263     sfree(del->name);
1264     sfree(del);
1265   }
1266 }
1267
1268 /* Handle OVSDB lost connection callback */
1269 static void ovs_stats_conn_terminate() {
1270   WARNING("Lost connection to OVSDB server");
1271   pthread_mutex_lock(&g_stats_lock);
1272   ovs_stats_free_bridge_list(g_bridge_list_head);
1273   g_bridge_list_head = NULL;
1274   ovs_stats_free_port_list(g_port_list_head);
1275   g_port_list_head = NULL;
1276   pthread_mutex_unlock(&g_stats_lock);
1277 }
1278
1279 /* Parse plugin configuration file and store the config
1280  * in allocated memory. Returns negative value in case of error.
1281  */
1282 static int ovs_stats_plugin_config(oconfig_item_t *ci) {
1283   bridge_list_t *bridge;
1284
1285   for (int i = 0; i < ci->children_num; i++) {
1286     oconfig_item_t *child = ci->children + i;
1287     if (strcasecmp("Address", child->key) == 0) {
1288       if (cf_util_get_string_buffer(child, ovs_stats_cfg.ovs_db_node,
1289                                     OVS_DB_ADDR_NODE_SIZE) != 0) {
1290         ERROR("%s: parse '%s' option failed", plugin_name, child->key);
1291         return -1;
1292       }
1293     } else if (strcasecmp("Port", child->key) == 0) {
1294       if (cf_util_get_string_buffer(child, ovs_stats_cfg.ovs_db_serv,
1295                                     OVS_DB_ADDR_SERVICE_SIZE) != 0) {
1296         ERROR("%s: parse '%s' option failed", plugin_name, child->key);
1297         return -1;
1298       }
1299     } else if (strcasecmp("Socket", child->key) == 0) {
1300       if (cf_util_get_string_buffer(child, ovs_stats_cfg.ovs_db_unix,
1301                                     OVS_DB_ADDR_UNIX_SIZE) != 0) {
1302         ERROR("%s: parse '%s' option failed", plugin_name, child->key);
1303         return -1;
1304       }
1305     } else if (strcasecmp("Bridges", child->key) == 0) {
1306       for (int j = 0; j < child->values_num; j++) {
1307         /* check value type */
1308         if (child->values[j].type != OCONFIG_TYPE_STRING) {
1309           ERROR("%s: Wrong bridge name [idx=%d]. "
1310                 "Bridge name should be string",
1311                 plugin_name, j);
1312           goto cleanup_fail;
1313         }
1314         /* get value */
1315         char const *br_name = child->values[j].value.string;
1316         if ((bridge = ovs_stats_get_bridge(g_monitored_bridge_list_head,
1317                                            br_name)) == NULL) {
1318           if ((bridge = calloc(1, sizeof(*bridge))) == NULL) {
1319             ERROR("%s: Error allocating memory for bridge", plugin_name);
1320             goto cleanup_fail;
1321           } else {
1322             char *br_name_dup = strdup(br_name);
1323             if (br_name_dup == NULL) {
1324               ERROR("%s: strdup() copy bridge name fail", plugin_name);
1325               sfree(bridge);
1326               goto cleanup_fail;
1327             }
1328
1329             pthread_mutex_lock(&g_stats_lock);
1330             /* store bridge name */
1331             bridge->name = br_name_dup;
1332             bridge->next = g_monitored_bridge_list_head;
1333             g_monitored_bridge_list_head = bridge;
1334             pthread_mutex_unlock(&g_stats_lock);
1335             DEBUG("%s: found monitored interface \"%s\"", plugin_name, br_name);
1336           }
1337         }
1338       }
1339     } else if (strcasecmp("InterfaceStats", child->key) == 0) {
1340       if (cf_util_get_boolean(child, &interface_stats) != 0) {
1341         ERROR("%s: parse '%s' option failed", plugin_name, child->key);
1342         return -1;
1343       }
1344     } else {
1345       WARNING("%s: option '%s' not allowed here", plugin_name, child->key);
1346       goto cleanup_fail;
1347     }
1348   }
1349   return 0;
1350
1351 cleanup_fail:
1352   ovs_stats_free_bridge_list(g_monitored_bridge_list_head);
1353   return -1;
1354 }
1355
1356 /* Initialize OvS Stats plugin*/
1357 static int ovs_stats_plugin_init(void) {
1358   ovs_db_callback_t cb = {.post_conn_init = ovs_stats_initialize,
1359                           .post_conn_terminate = ovs_stats_conn_terminate};
1360
1361   INFO("%s: Connecting to OVS DB using address=%s, service=%s, unix=%s",
1362        plugin_name, ovs_stats_cfg.ovs_db_node, ovs_stats_cfg.ovs_db_serv,
1363        ovs_stats_cfg.ovs_db_unix);
1364   /* connect to OvS DB */
1365   if ((g_ovs_db =
1366            ovs_db_init(ovs_stats_cfg.ovs_db_node, ovs_stats_cfg.ovs_db_serv,
1367                        ovs_stats_cfg.ovs_db_unix, &cb)) == NULL) {
1368     ERROR("%s: plugin: failed to connect to OvS DB server", plugin_name);
1369     return -1;
1370   }
1371   int err = pthread_mutex_init(&g_stats_lock, NULL);
1372   if (err < 0) {
1373     ERROR("%s: plugin: failed to initialize cache lock", plugin_name);
1374     ovs_db_destroy(g_ovs_db);
1375     return -1;
1376   }
1377   return 0;
1378 }
1379
1380 /* OvS stats read callback. Read bridge/port information and submit it*/
1381 static int ovs_stats_plugin_read(__attribute__((unused)) user_data_t *ud) {
1382   pthread_mutex_lock(&g_stats_lock);
1383   for (port_list_t *port = g_port_list_head; port != NULL; port = port->next) {
1384     if (strlen(port->name) == 0)
1385       /* Skip port w/o name. This is possible when read callback
1386        * is called after Interface Table update callback but before
1387        * Port table Update callback. Will add this port on next read */
1388       continue;
1389
1390     /* Skip port if it has no bridge */
1391     if (!port->br)
1392       continue;
1393
1394     ovs_stats_submit_port(port);
1395
1396     if (interface_stats)
1397       ovs_stats_submit_interfaces(port);
1398   }
1399   pthread_mutex_unlock(&g_stats_lock);
1400   return 0;
1401 }
1402
1403 /* Shutdown OvS Stats plugin */
1404 static int ovs_stats_plugin_shutdown(void) {
1405   DEBUG("OvS Statistics plugin shutting down");
1406   ovs_db_destroy(g_ovs_db);
1407   pthread_mutex_lock(&g_stats_lock);
1408   ovs_stats_free_bridge_list(g_bridge_list_head);
1409   ovs_stats_free_bridge_list(g_monitored_bridge_list_head);
1410   ovs_stats_free_port_list(g_port_list_head);
1411   pthread_mutex_unlock(&g_stats_lock);
1412   pthread_mutex_destroy(&g_stats_lock);
1413   return 0;
1414 }
1415
1416 /* Register OvS Stats plugin callbacks */
1417 void module_register(void) {
1418   plugin_register_complex_config(plugin_name, ovs_stats_plugin_config);
1419   plugin_register_init(plugin_name, ovs_stats_plugin_init);
1420   plugin_register_complex_read(NULL, plugin_name, ovs_stats_plugin_read, 0,
1421                                NULL);
1422   plugin_register_shutdown(plugin_name, ovs_stats_plugin_shutdown);
1423 }