X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Flibvirt.c;h=6f9e5f126d497b44ef2c42e2cd437cae3f5a1b49;hb=b6837fb99c8aead728c74b85f15178f5fee37482;hp=5acff29a578cd609dff2ba7de65bab1e13c4fc3b;hpb=5e700757575fa6606cf201947cb0efb57ce12e6d;p=collectd.git diff --git a/src/libvirt.c b/src/libvirt.c index 5acff29a..6f9e5f12 100644 --- a/src/libvirt.c +++ b/src/libvirt.c @@ -24,6 +24,7 @@ #include "plugin.h" #include "configfile.h" #include "utils_ignorelist.h" +#include "utils_complain.h" #include #include @@ -49,6 +50,8 @@ static const char *config_keys[] = { /* Connection. */ static virConnectPtr conn = 0; +static char *conn_string = NULL; +static c_complain_t conn_complain = C_COMPLAIN_INIT_STATIC; /* Seconds between list refreshes, 0 disables completely. */ static int interval = 60; @@ -153,15 +156,13 @@ lv_config (const char *key, const char *value) il_interface_devices = ignorelist_create (1); if (strcasecmp (key, "Connection") == 0) { - if (conn != 0) { - ERROR ("Connection may only be given once in config file"); - return 1; - } - conn = virConnectOpenReadOnly (value); - if (!conn) { - VIRT_ERROR (NULL, "connection failed"); + char *tmp = strdup (value); + if (tmp == NULL) { + ERROR ("libvirt plugin: Connection strdup failed."); return 1; } + sfree (conn_string); + conn_string = tmp; return 0; } @@ -253,19 +254,29 @@ lv_read (void) int i; if (conn == NULL) { - ERROR ("libvirt plugin: Not connected. Use Connection in " - "config file to supply connection URI. For more information " - "see "); - return -1; + /* `conn_string == NULL' is acceptable. */ + conn = virConnectOpenReadOnly (conn_string); + if (conn == NULL) { + c_complain (LOG_ERR, &conn_complain, + "libvirt plugin: Unable to connect: " + "virConnectOpenReadOnly failed."); + return -1; + } } + c_release (LOG_NOTICE, &conn_complain, + "libvirt plugin: Connection established."); time (&t); /* Need to refresh domain or device lists? */ if ((last_refresh == (time_t) 0) || ((interval > 0) && ((last_refresh + interval) <= t))) { - if (refresh_lists () != 0) + if (refresh_lists () != 0) { + if (conn != NULL) + virConnectClose (conn); + conn = NULL; return -1; + } last_refresh = t; }