add xen support to libvirt vm discovery

git-svn-id: http://www.observium.org/svn/observer/trunk@2111 61d68cd4-352d-0410-923a-c4978735b2b8
This commit is contained in:
Tom Laermans
2011-04-20 16:48:33 +00:00
parent 30b2918858
commit 2b9cad302d
5 changed files with 103 additions and 87 deletions

View File

@@ -20,9 +20,9 @@ else if ($vm['vmwVmGuestOS'] == "")
if ($vm['vmwVmMemSize'] >= 1024)
{
echo("<td class=list>" . $vm['vmwVmMemSize']/1024 . " GB</td>");
echo("<td class=list>" . sprintf("%.2f",$vm['vmwVmMemSize']/1024) . " GB</td>");
} else {
echo("<td class=list>" . $vm['vmwVmMemSize'] . " MB</td>");
echo("<td class=list>" . sprintf("%.2f",$vm['vmwVmMemSize']) . " MB</td>");
}
echo('<td class="list">' . $vm['vmwVmCpus'] . " CPU</td>");

View File

@@ -54,7 +54,7 @@ foreach ($datas as $type)
echo('<span class="pagemenu-selected">');
}
echo("<a href='".$config['base_url']."/device/".$device['device_id']."/health/" . $type . ($_GET['optb'] ? "/" . $_GET['optb'] : ''). "/'> " . $type_text[$type] ."</a>");
echo("<a href='device/".$device['device_id']."/health/" . $type . ($_GET['optb'] ? "/" . $_GET['optb'] : ''). "/'> " . $type_text[$type] ."</a>");
if ($_GET['opta'] == $type) { echo("</span>"); }
$sep = " | ";
}

View File

@@ -131,7 +131,6 @@ $config['enable_inventory'] = 1; # Enable Inventory
$config['enable_pseudowires'] = 1; # Enable Pseudowires
$config['enable_vrfs'] = 1; # Enable VRFs
$config['enable_printers'] = 0; # Enable Printer support
$config['enable_libvirt'] = 0; # Enable Libvirt VM support
### Ports extension modules
@@ -218,6 +217,11 @@ $config['syslog_filter'] = array("last message repeated", "Connection from UDP:
"ipSystemStatsTable node ipSystemStatsOutFragOKs not implemented",
"diskio.c: don't know how to handle"); ## Ignore some crappy stuff from SNMP daemon
### Virtualization
$config['enable_libvirt'] = 0; # Enable Libvirt VM support
$config['libvirt_protocols'] = array("qemu+ssh","xen+ssh"); # Mechanisms used, add or remove if not using this on any of your machines.
### LDAP Authentication
$config['auth_ldap_version'] = 3; # v2 or v3

View File

@@ -53,7 +53,6 @@ if ($cdp_array)
$remote_interface_id = @mysql_result(mysql_query("SELECT interface_id FROM `ports` WHERE (`ifDescr` = '$if' OR `ifName`='$if') AND `device_id` = '".$remote_device_id."'"),0);
} else { $remote_interface_id = "0"; }
if ($interface['interface_id'] && $cdp['cdpCacheDeviceId'] && $cdp['cdpCacheDevicePort'])
{
discover_link($interface['interface_id'], 'cdp', $remote_interface_id, $cdp['cdpCacheDeviceId'], $cdp['cdpCacheDevicePort'], $cdp['cdpCachePlatform'], $cdp['cdpCacheVersion']);

View File

@@ -10,97 +10,110 @@ if ($config['enable_libvirt'] == '1' && $device['os'] == "linux" )
echo("Libvirt VM: ");
# FIXME should support other methods here too (tls etc), and other hypervisors, like xen, too!
$method = 'qemu+ssh';
$ok = 0;
if (strstr($method,'ssh'))
foreach ($config['libvirt_protocols'] as $method)
{
# Check if we are using SSH if we can log in without password - without blocking the discovery
# Also automatically add the host key so discovery doesn't block on the yes/no question, and run echo so we don't get stuck in a remote shell ;-)
exec('ssh -o "StrictHostKeyChecking no" -o "PreferredAuthentications publickey" -o "IdentitiesOnly yes" ' . $device['hostname'] . ' echo', $out, $ret);
if ($ret != 255) { $ok = 1; }
}
else
{
$ok = 1;
}
if ($ok)
{
# Fetch virtual machine list
unset($domlist);
exec($config['virsh'] . ' -c '.$method.'://' . $device['hostname'] . '/system list',$domlist);
foreach ($domlist as $dom)
if (strstr($method,'qemu'))
{
list($dom_id,) = explode(' ',trim($dom),2);
$uri = $method.'://' . $device['hostname'] . '/system';
}
else
{
$uri = $method.'://' . $device['hostname'];
}
$ok = 0;
if (is_numeric($dom_id))
if (strstr($method,'ssh'))
{
# Check if we are using SSH if we can log in without password - without blocking the discovery
# Also automatically add the host key so discovery doesn't block on the yes/no question, and run echo so we don't get stuck in a remote shell ;-)
exec('ssh -o "StrictHostKeyChecking no" -o "PreferredAuthentications publickey" -o "IdentitiesOnly yes" ' . $device['hostname'] . ' echo', $out, $ret);
if ($ret != 255) { $ok = 1; }
}
else
{
$ok = 1;
}
if ($ok)
{
# Fetch virtual machine list
unset($domlist);
exec($config['virsh'] . ' -c '.$uri.' list',$domlist);
foreach ($domlist as $dom)
{
# Fetch the Virtual Machine information.
unset($vm_info_array);
exec($config['virsh'] . ' -c '.$method.'://' . $device['hostname'] . '/system dumpxml ' . $dom_id,$vm_info_array);
list($dom_id,) = explode(' ',trim($dom),2);
# <domain type='kvm' id='3'>
# <name>moo.example.com</name>
# <uuid>48cf6378-6fd5-4610-0611-63dd4b31cfd6</uuid>
# <memory>1048576</memory>
# <currentMemory>1048576</currentMemory>
# <vcpu>8</vcpu>
# <os>
# <type arch='x86_64' machine='pc-0.12'>hvm</type>
# <boot dev='hd'/>
# </os>
# <features>
# <acpi/>
# (...)
# Convert array to string
unset($vm_info_xml);
foreach ($vm_info_array as $line) { $vm_info_xml .= $line; }
$xml = simplexml_load_string('<?xml version="1.0"?> ' . $vm_info_xml);
if ($debug) { print_r($xml); }
$vmwVmDisplayName = $xml->name;
$vmwVmGuestOS = ''; # libvirt does not supply this
$vmwVmMemSize = $xml->currentMemory / 1024;
exec($config['virsh'] . ' -c '.$method.'://' . $device['hostname'] . '/system domstate ' . $dom_id,$vm_state);
$vmwVmState = ucfirst($vm_state[0]);
$vmwVmCpus = $xml->vcpu;
# Check whether the Virtual Machine is already known for this host.
$result = mysql_query("SELECT * FROM vminfo WHERE device_id = '" . $device["device_id"] . "' AND vmwVmVMID = '" . $dom_id . "' AND vm_type='libvirt'");
if (mysql_num_rows($result) == 0)
if (is_numeric($dom_id))
{
mysql_query("INSERT INTO vminfo (device_id, vm_type, vmwVmVMID, vmwVmDisplayName, vmwVmGuestOS, vmwVmMemSize, vmwVmCpus, vmwVmState) VALUES (" . $device["device_id"] . ", 'libvirt',
'" . $dom_id . "', '" . mres($vmwVmDisplayName) . "', '" . mres($vmwVmGuestOS) . "', '" . $vmwVmMemSize . "', '" . $vmwVmCpus . "', '" . mres($vmwVmState) . "')");
echo("+");
log_event("Virtual Machine added: $vmwVmDisplayName ($vmwVmMemSize MB)", $device, 'vm', mysql_insert_id());
} else {
$row = mysql_fetch_assoc($result);
if ($row['vmwVmState'] != $vmwVmState
|| $row['vmwVmDisplayName'] != $vmwVmDisplayName
|| $row['vmwVmCpus'] != $vmwVmCpus
|| $row['vmwVmGuestOS'] != $vmwVmGuestOS
|| $row['vmwVmMemSize'] != $vmwVmMemSize)
{
mysql_query("UPDATE vminfo SET vmwVmState='" . mres($vmwVmState) . "', vmwVmGuestOS='" . mres($vmwVmGuestOS) . "', vmwVmDisplayName='". mres($vmwVmDisplayName) . "',
vmwVmMemSize='" . mres($vmwVmMemSize) . "', vmwVmCpus='" . mres($vmwVmCpus) . "' WHERE device_id='" . $device["device_id"] . "' AND vm_type='libvirt' AND vmwVmVMID='" . $dom_id . "'");
echo("U");
# FIXME eventlog
}
else
{
echo(".");
}
}
# Fetch the Virtual Machine information.
unset($vm_info_array);
exec($config['virsh'] . ' -c '.$uri.' dumpxml ' . $dom_id,$vm_info_array);
# Save the discovered Virtual Machine.
$libvirt_vmlist[] = $dom_id;
# <domain type='kvm' id='3'>
# <name>moo.example.com</name>
# <uuid>48cf6378-6fd5-4610-0611-63dd4b31cfd6</uuid>
# <memory>1048576</memory>
# <currentMemory>1048576</currentMemory>
# <vcpu>8</vcpu>
# <os>
# <type arch='x86_64' machine='pc-0.12'>hvm</type>
# <boot dev='hd'/>
# </os>
# <features>
# <acpi/>
# (...)
# Convert array to string
unset($vm_info_xml);
foreach ($vm_info_array as $line) { $vm_info_xml .= $line; }
$xml = simplexml_load_string('<?xml version="1.0"?> ' . $vm_info_xml);
if ($debug) { print_r($xml); }
$vmwVmDisplayName = $xml->name;
$vmwVmGuestOS = ''; # libvirt does not supply this
$vmwVmMemSize = $xml->currentMemory / 1024;
exec($config['virsh'] . ' -c '.$uri.' domstate ' . $dom_id,$vm_state);
$vmwVmState = ucfirst($vm_state[0]);
$vmwVmCpus = $xml->vcpu;
# Check whether the Virtual Machine is already known for this host.
$result = mysql_query("SELECT * FROM vminfo WHERE device_id = '" . $device["device_id"] . "' AND vmwVmVMID = '" . $dom_id . "' AND vm_type='libvirt'");
if (mysql_num_rows($result) == 0)
{
mysql_query("INSERT INTO vminfo (device_id, vm_type, vmwVmVMID, vmwVmDisplayName, vmwVmGuestOS, vmwVmMemSize, vmwVmCpus, vmwVmState) VALUES (" . $device["device_id"] . ", 'libvirt',
'" . $dom_id . "', '" . mres($vmwVmDisplayName) . "', '" . mres($vmwVmGuestOS) . "', '" . $vmwVmMemSize . "', '" . $vmwVmCpus . "', '" . mres($vmwVmState) . "')");
echo("+");
log_event("Virtual Machine added: $vmwVmDisplayName ($vmwVmMemSize MB)", $device, 'vm', mysql_insert_id());
} else {
$row = mysql_fetch_assoc($result);
if ($row['vmwVmState'] != $vmwVmState
|| $row['vmwVmDisplayName'] != $vmwVmDisplayName
|| $row['vmwVmCpus'] != $vmwVmCpus
|| $row['vmwVmGuestOS'] != $vmwVmGuestOS
|| $row['vmwVmMemSize'] != $vmwVmMemSize)
{
mysql_query("UPDATE vminfo SET vmwVmState='" . mres($vmwVmState) . "', vmwVmGuestOS='" . mres($vmwVmGuestOS) . "', vmwVmDisplayName='". mres($vmwVmDisplayName) . "',
vmwVmMemSize='" . mres($vmwVmMemSize) . "', vmwVmCpus='" . mres($vmwVmCpus) . "' WHERE device_id='" . $device["device_id"] . "' AND vm_type='libvirt' AND vmwVmVMID='" . $dom_id . "'");
echo("U");
# FIXME eventlog
}
else
{
echo(".");
}
}
# Save the discovered Virtual Machine.
$libvirt_vmlist[] = $dom_id;
}
}
}
# If we found VMs, don't cycle the other protocols anymore.
if (count($libvirt_vmlist)) { break; }
}
# Get a list of all the known Virtual Machines for this host.