Merge pull request #1843 from xinity/mysql-galera-stats

mysql plugin: add support for Galera statistics

diff --combined src/mysql.c
index 1bc0fdf,20c9004..177563c
--- 1/src/mysql.c
--- 2/src/mysql.c
+++ b/src/mysql.c
@@@ -54,6 -54,7 +54,7 @@@ struct mysql_database_s /* {{{ *
        _Bool master_stats;
        _Bool slave_stats;
        _Bool innodb_stats;
+       _Bool wsrep_stats;
  
        _Bool slave_notif;
        _Bool slave_io_running;
@@@ -104,6 -105,7 +105,6 @@@ static int mysql_config_database (oconf
  {
        mysql_database_t *db;
        int status = 0;
 -      int i;
  
        if ((ci->values_num != 1)
            || (ci->values[0].type != OCONFIG_TYPE_STRING))
@@@ -143,7 -145,7 +144,7 @@@
        assert (db->instance != NULL);
  
        /* Fill the `mysql_database_t' structure.. */
 -      for (i = 0; i < ci->children_num; i++)
 +      for (int i = 0; i < ci->children_num; i++)
        {
                oconfig_item_t *child = ci->children + i;
  
@@@ -178,6 -180,8 +179,8 @@@
                        status = cf_util_get_boolean (child, &db->slave_notif);
                else if (strcasecmp ("InnodbStats", child->key) == 0)
                        status = cf_util_get_boolean (child, &db->innodb_stats);
+               else if (strcasecmp ("WsrepStats", child->key) == 0)
+                       status = cf_util_get_boolean (child, &db->wsrep_stats);
                else
                {
                        WARNING ("mysql plugin: Option `%s' not allowed here.", child->key);
@@@ -221,11 -225,13 +224,11 @@@
  
  static int mysql_config (oconfig_item_t *ci) /* {{{ */
  {
 -      int i;
 -
        if (ci == NULL)
                return (EINVAL);
  
        /* Fill the `mysql_database_t' structure.. */
 -      for (i = 0; i < ci->children_num; i++)
 +      for (int i = 0; i < ci->children_num; i++)
        {
                oconfig_item_t *child = ci->children + i;
  
@@@ -682,6 -688,93 +685,93 @@@ static int mysql_read_innodb_stats (mys
        return (0);
  }
  
+ static int mysql_read_wsrep_stats (mysql_database_t *db, MYSQL *con)
+ {
+       MYSQL_RES *res;
+       MYSQL_ROW  row;
+ 
+       const char *query;
+       struct {
+               const char *key;
+               const char *type;
+               int ds_type;
+       } metrics[] = {
+ 
+               { "wsrep_apply_oooe",                "operations",   DS_TYPE_DERIVE },
+               { "wsrep_apply_oool",                "operations",   DS_TYPE_DERIVE },
+               { "wsrep_causal_reads",              "operations",   DS_TYPE_DERIVE },
+               { "wsrep_commit_oooe",               "operations",   DS_TYPE_DERIVE },
+               { "wsrep_commit_oool",               "operations",   DS_TYPE_DERIVE },
+               { "wsrep_flow_control_recv",         "operations",   DS_TYPE_DERIVE },
+               { "wsrep_flow_control_sent",         "operations",   DS_TYPE_DERIVE },
+               { "wsrep_flow_control_paused",       "operations",   DS_TYPE_DERIVE },
+               { "wsrep_local_bf_aborts",           "operations",   DS_TYPE_DERIVE },
+               { "wsrep_local_cert_failures",       "operations",   DS_TYPE_DERIVE },
+               { "wsrep_local_commits",             "operations",   DS_TYPE_DERIVE },
+               { "wsrep_local_replays",             "operations",   DS_TYPE_DERIVE },
+               { "wsrep_received",                  "operations",   DS_TYPE_DERIVE },
+               { "wsrep_replicated",                "operations",   DS_TYPE_DERIVE },
+ 
+               { "wsrep_received_bytes",            "total_bytes",  DS_TYPE_DERIVE },
+               { "wsrep_replicated_bytes",          "total_bytes",  DS_TYPE_DERIVE },
+ 
+               { "wsrep_apply_window",              "gauge",        DS_TYPE_GAUGE },
+               { "wsrep_commit_window",             "gauge",        DS_TYPE_GAUGE },
+ 
+               { "wsrep_cluster_size",              "gauge",        DS_TYPE_GAUGE },
+               { "wsrep_cert_deps_distance",        "gauge",        DS_TYPE_GAUGE },
+ 
+               { "wsrep_local_recv_queue",          "queue_length", DS_TYPE_GAUGE },
+               { "wsrep_local_send_queue",          "queue_length", DS_TYPE_GAUGE },
+ 
+               { NULL,                              NULL,           0}
+ 
+       };
+ 
+       query = "SHOW GLOBAL STATUS LIKE 'wsrep_%'";
+ 
+       res = exec_query (con, query);
+       if (res == NULL)
+               return (-1);
+ 
+       row = mysql_fetch_row (res);
+       if (row == NULL)
+       {
+               ERROR ("mysql plugin: Failed to get wsrep statistics: "
+                       "`%s' did not return any rows.", query);
+               mysql_free_result (res);
+               return (-1);
+       }
+ 
+       while ((row = mysql_fetch_row (res)))
+       {
+               int i;
+               char *key;
+               unsigned long long val;
+ 
+               key = row[0];
+               val = atoll (row[1]);
+ 
+               for (i = 0; metrics[i].key != NULL && strcmp(metrics[i].key, key) != 0; i++)
+                       ;
+ 
+               if (metrics[i].key == NULL)
+                       continue;
+ 
+               switch (metrics[i].ds_type) {
+                       case DS_TYPE_GAUGE:
+                               gauge_submit(metrics[i].type, key, (gauge_t)val, db);
+                               break;
+                       case DS_TYPE_DERIVE:
+                               derive_submit(metrics[i].type, key, (derive_t)val, db);
+                               break;
+               }
+       }
+ 
+       mysql_free_result(res);
+       return (0);
+ } /* mysql_read_wsrep_stats */
+ 
  static int mysql_read (user_data_t *ud)
  {
        mysql_database_t *db;
@@@ -950,6 -1043,9 +1040,9 @@@
        if ((db->slave_stats) || (db->slave_notif))
                mysql_read_slave_stats (db, con);
  
+       if (db->wsrep_stats)
+               mysql_read_wsrep_stats (db, con);
+ 
        return (0);
  } /* int mysql_read */