X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Flibvirt.c;h=cfabaaa235d6efe81da7896e4c51185d6afa08a3;hb=282c39de93158c8fbdc9640d0a39963602f57f4c;hp=2aa0a7ade3c974b17f96d3fd312798e5814be141;hpb=4935921cf780cd6bc25df54cf16f0bdd9bd6d443;p=collectd.git diff --git a/src/libvirt.c b/src/libvirt.c index 2aa0a7ad..cfabaaa2 100644 --- a/src/libvirt.c +++ b/src/libvirt.c @@ -141,8 +141,6 @@ init_value_list (value_list_t *vl, virDomainPtr dom) const char *name; char uuid[VIR_UUID_STRING_BUFLEN]; - vl->interval = interval_g; - sstrncpy (vl->plugin, "libvirt", sizeof (vl->plugin)); vl->host[0] = '\0'; @@ -180,6 +178,25 @@ init_value_list (value_list_t *vl, virDomainPtr dom) } /* void init_value_list */ static void +memory_submit (gauge_t memory, virDomainPtr dom) +{ + value_t values[1]; + value_list_t vl = VALUE_LIST_INIT; + + init_value_list (&vl, dom); + + values[0].gauge = memory; + + vl.values = values; + vl.values_len = 1; + + sstrncpy (vl.type, "memory", sizeof (vl.type)); + sstrncpy (vl.type_instance, "total", sizeof (vl.type_instance)); + + plugin_dispatch_values (&vl); +} + +static void cpu_submit (unsigned long long cpu_time, virDomainPtr dom, const char *type) { @@ -409,7 +426,7 @@ lv_read (void) interface_devices[i].path); #endif - /* Get CPU usage, VCPU usage for each domain. */ + /* Get CPU usage, memory, VCPU usage for each domain. */ for (i = 0; i < nr_domains; ++i) { virDomainInfo info; virVcpuInfoPtr vinfo = NULL; @@ -425,6 +442,7 @@ lv_read (void) } cpu_submit (info.cpuTime, domains[i], "virt_cpu_total"); + memory_submit ((gauge_t) info.memory * 1024, domains[i]); vinfo = malloc (info.nrVirtCpu * sizeof (vinfo[0])); if (vinfo == NULL) { @@ -658,7 +676,7 @@ refresh_lists (void) ignore_device_match (il_interface_devices, name, address) != 0)) goto cont3; - add_interface_device (dom, path, address, j+1); + add_interface_device (dom, path, address, j+1); cont3: if (path) xmlFree (path); if (address) xmlFree (address); @@ -779,10 +797,10 @@ add_interface_device (virDomainPtr dom, const char *path, const char *address, u address_copy = strdup (address); if (!address_copy) { - sfree(path_copy) - return -1; - } - + sfree(path_copy); + return -1; + } + snprintf(number_string, sizeof (number_string), "interface-%u", number); if (interface_devices) @@ -829,7 +847,7 @@ lv_shutdown (void) free_domains (); if (conn != NULL) - virConnectClose (conn); + virConnectClose (conn); conn = NULL; ignorelist_free (il_domains); @@ -846,8 +864,8 @@ void module_register (void) { plugin_register_config ("libvirt", - lv_config, - config_keys, NR_CONFIG_KEYS); + lv_config, + config_keys, NR_CONFIG_KEYS); plugin_register_init ("libvirt", lv_init); plugin_register_read ("libvirt", lv_read); plugin_register_shutdown ("libvirt", lv_shutdown);