#!/usr/bin/perl -w ############################################################################################################# # # # Developed by Ingard Mevåg @ Oslo University College, spring 2007 # # ingard [at] mevaag [dot] no # # # # This work is licensed under the Creative Commons Attribution-Noncommercial-Share Alike 3.0 License. # # To view a copy of this license, visit http://creativecommons.org/licenses/by-nc-sa/3.0/ or send a letter # # to Creative Commons, 171 Second Street, Suite 300, San Francisco, California, 94105, USA. # # # ############################################################################################################# use strict; # http://search.cpan.org/~rjray/RPC-XML-0.59/lib/RPC/XML/Client.pm require RPC::XML; require RPC::XML::Client; # for debug purposes #use Data::Dumper; ##### CONFIG ###### my %xenhosts = ("192.0.2.10" => {"port" => "9363"}, "192.0.2.11" => {"port" => "9363"}, "192.0.2.12" => {"port" => "9363"}, "192.0.2.13" => {"port" => "9363"}); ##### CONFIG END ### ##### STATIC VARS ##### my %host_info; ####################### sub apiconnect { foreach my $xenhost (keys %xenhosts) { my $xen = RPC::XML::Client->new("http://$xenhost:$xenhosts{$xenhost}{'port'}"); my $session = $xen->simple_request("session.login_with_password", "user",""); if (! $session) { print "Can't connect to $xenhost :(\n"; $xenhosts{$xenhost} = {'xen' => $xen, 'session' => ""}; } else { $xenhosts{$xenhost} = {'xen' => $xen, 'session' => $session->{'Value'}}; print "Connected successfully to $xenhost..\n"; } } } sub validate_response { my ($result_ref) = @_; if ($result_ref->{'Status'} eq "Success") { return $result_ref->{'Value'}; } else { # status = Failure ! # die ("xmlrpc failed! ErrorDescription: $result_ref->{'ErrorDescription'}[1] -> $result_ref->{'ErrorDescription'}[0]"); print "xmlrpc failed! ErrorDescription: $result_ref->{'ErrorDescription'}[1] -> $result_ref->{'ErrorDescription'}[0]\n"; } } sub get_host_cpu_utilisation { my ($xen, $session, $host_name, $host_ref) = @_; my $host_cpu_ref = validate_response($xen->simple_request("host.get_host_CPUs", $session, $host_ref)); foreach (@$host_cpu_ref) { my $host_cpu_utilisation = validate_response($xen->simple_request("host_cpu.get_utilisation", $session, $_)); $host_info{$host_name}{'cpus'}{$_} = $host_cpu_utilisation; print " CPUiNFO: $host_cpu_utilisation\n"; } } sub get_host_pif_utilisation { my ($xen, $session, $host_name, $host_ref) = @_; # This method isnt implemented yet it seems so using PIF.get_all for now.. # This will break when xen is made cluster aware.. # my $host_pif_ref = validate_response($xen->simple_request("host.get_PIFs", $session, $host_ref)); my $host_pif_ref = validate_response($xen->simple_request("PIF.get_all", $session)); foreach (@$host_pif_ref) { my $host_pif_device = validate_response($xen->simple_request("PIF.get_device", $session, $_)); my $host_pif_metrics_ref = validate_response($xen->simple_request("PIF.get_metrics", $session, $_)); # Whats the best solution performancewise? # Collecting stats from get_records, or pulling individually? # my $host_pif_record = validate_response($xen->simple_request("PIF_metrics.get_record", $session, $host_pif_metrics_ref)); # my $host_pif_io_read = $host_pif_record->{'io_read_kbs'}; # my $host_pif_io_write = $host_pif_record->{'io_write_kbs'}; my $host_pif_io_read = validate_response($xen->simple_request("PIF_metrics.get_io_read_kbs", $session, $host_pif_metrics_ref)); my $host_pif_io_write = validate_response($xen->simple_request("PIF_metrics.get_io_write_kbs", $session, $host_pif_metrics_ref)); $host_info{$host_name}{'pifs'}{$host_pif_device} = {'read' => $host_pif_io_read, 'write' => $host_pif_io_write}; print " PiFiNFO: $host_pif_device READ: $host_pif_io_read - WRITE: $host_pif_io_write\n"; # $host_info{$host_name}{'pifs'}{$host_pif_device}{'read'} = $host_pif_io_read; # $host_info{$host_name}{'pifs'}{$host_pif_device}{'write'} = $host_pif_io_write; } } sub get_host_mem_utilisation { my ($xen, $session, $host_name, $host_ref) = @_; my $host_metrics_ref = validate_response($xen->simple_request("host.get_metrics", $session, $host_ref)); my $host_mem_total = validate_response($xen->simple_request("host_metrics.get_memory_total", $session, $host_metrics_ref)) / 1024 / 1024; my $host_mem_free = validate_response($xen->simple_request("host_metrics.get_memory_free", $session, $host_metrics_ref)) / 1024 / 1024; $host_info{$host_name}{'memory'} = {'total' => $host_mem_total, 'free' => $host_mem_free}; print " MEMiNFO: Total: $host_mem_total MB - Free: $host_mem_free MB\n"; } sub get_vm_mem_info { my ($xen, $session, $host_name, $vm_ref, $vm_name_label) = @_; my $vm_mem_stat_max = validate_response($xen->simple_request("VM.get_memory_static_max",$session,$vm_ref)); my $vm_mem_stat_min = validate_response($xen->simple_request("VM.get_memory_static_min",$session,$vm_ref)); my $vm_mem_dyn_max = validate_response($xen->simple_request("VM.get_memory_dynamic_max",$session,$vm_ref)); my $vm_mem_dyn_min = validate_response($xen->simple_request("VM.get_memory_dynamic_min",$session,$vm_ref)); # not implemented yet.. We'll do this at the same time as getting cpu utilisation # in the get_vm_metrics sub instead.. #my $vm_metrics_ref = validate_response($xen->simple_request("VM.get_metrics",$session,$vm_ref)); #my $vm_mem_actual = validate_response($xen->simple_request("VM_metrics.get_memory_actual",$session,$vm_metrics_ref)); $host_info{$host_name}{'vms'}{$vm_name_label}{'memory'} = {'static_max' => $vm_mem_stat_max, 'static_min' => $vm_mem_stat_min, 'dynamic_max' => $vm_mem_dyn_max, 'dynamic_min' => $vm_mem_dyn_min}; # xm list uses the dynamic min var as far as i can tell.. or? # Lets print the memactual info instead of this... I'll do that in the get_vm_metrics sub instead.. # print " |- MEMiNFO: Dynamic Min: $vm_mem_dyn_min - Actually in use: $vm_mem_actual\n"; } sub get_vm_metrics { my ($xen, $session, $host_name, $vm_ref, $vm_name_label) = @_; my $vm_metrics_ref = validate_response($xen->simple_request("VM.get_metrics",$session,$vm_ref)); my %vm_vcpu_utilisation = %{validate_response($xen->simple_request("VM_metrics.get_vcpus_utilisation",$session,$vm_metrics_ref))}; for my $tempcpu (keys %vm_vcpu_utilisation) { print " |- CPUiNFO: $tempcpu - $vm_vcpu_utilisation{$tempcpu}\n"; $host_info{$host_name}{'vms'}{$vm_name_label}{'vcpus'} = {$tempcpu => $vm_vcpu_utilisation{$tempcpu}}; } my $vm_mem_actual = validate_response($xen->simple_request("VM_metrics.get_memory_actual",$session,$vm_metrics_ref)) / 1024 / 1024; $host_info{$host_name}{'vms'}{$vm_name_label}{'memory'}{'actual'} = "$vm_mem_actual"; print " |- MEMiNFO: Actually in use: $vm_mem_actual MB\n"; } sub get_vm_vif_utilisation { my ($xen, $session, $host_name, $vm_ref, $vm_name_label) = @_; my $vm_vifs = validate_response($xen->simple_request("VM.get_VIFs",$session,$vm_ref)); foreach (@$vm_vifs) { my $vif_device = validate_response($xen->simple_request("VIF.get_device",$session,$_)); my $vif_io_read = validate_response($xen->simple_request("VIF_metrics.get_io_read_kbs", $session, $_)); my $vif_io_write = validate_response($xen->simple_request("VIF_metrics.get_io_write_kbs", $session, $_)); $host_info{$host_name}{'vms'}{$vm_name_label}{'vifs'}{$vif_device} = {'read' => $vif_io_read, 'write' => $vif_io_write}; print " |- ViFiNFO: $vif_device READ: $vif_io_read - WRITE: $vif_io_write\n"; } } sub get_vm_vbd_utilisation { my ($xen, $session, $host_name, $vm_ref, $vm_name_label) = @_; my $vm_vbds = validate_response($xen->simple_request("VM.get_VBDs",$session,$vm_ref)); foreach (@$vm_vbds) { my $vbd_device = validate_response($xen->simple_request("VBD.get_device",$session,$_)); my $vbd_io_read = validate_response($xen->simple_request("VBD_metrics.get_io_read_kbs", $session, $_)); my $vbd_io_write = validate_response($xen->simple_request("VBD_metrics.get_io_write_kbs", $session, $_)); $host_info{$host_name}{'vms'}{$vm_name_label}{'vbds'}{$vbd_device} = {'read' => $vbd_io_read, 'write' => $vbd_io_write}; print " |- VBDiNFO: $vbd_device READ: $vbd_io_read - WRITE: $vbd_io_write\n"; } } sub get_vm_type { my ($xen, $session, $host_name, $vm_ref, $vm_name_label) = @_; # not running response through validate_response() here to stop it from crashing.. # # api docs says if this (following) field is set, its a HVM domain. my $vm_bootloader_results = $xen->simple_request("VM.get_HVM_boot_policy",$session,$vm_ref); if ("$vm_bootloader_results->{'Status'}" eq "Success") { if ("$vm_bootloader_results->{'Value'}" ne "") { $host_info{$host_name}{'vms'}{$vm_name_label}{'type'} = "HVM"; } else { $host_info{$host_name}{'vms'}{$vm_name_label}{'type'} = "PV"; } } else { # However, xen 3.0.4 doest support this part
/* Copyright 2017 Fred Sundvik
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "lcd_keyframes.h"
#include <string.h>
#include "action_util.h"
#include "led.h"
#include "resources/resources.h"
bool lcd_keyframe_display_layer_text(keyframe_animation_t* animation, visualizer_state_t* state) {
(void)animation;
gdispClear(White);
gdispDrawString(0, 10, state->layer_text, state->font_dejavusansbold12, Black);
return false;
}
static void format_layer_bitmap_string(uint16_t default_layer, uint16_t layer, char* buffer) {
for (int i=0; i<16;i++)
{
uint32_t mask = (1u << i);
if (default_layer & mask) {
if (layer & mask) {
*buffer = 'B';
} else {
*buffer = 'D';
}
} else if (layer & mask) {
*buffer = '1';
} else {
*buffer = '0';
}
++buffer;
if (i==3 || i==7 || i==11) {
*buffer = ' ';
++buffer;
}
}
*buffer = 0;
}
bool lcd_keyframe_display_layer_bitmap(keyframe_animation_t* animation, visualizer_state_t* state) {
(void)animation;
const char* layer_help = "1=On D=Default B=Both";
char layer_buffer[16 + 4]; // 3 spaces and one null terminator
gdispClear(White);
gdispDrawString(0, 0, layer_help, state->font_fixed5x8, Black);
format_layer_bitmap_string(state->status.default_layer, state->status.layer, layer_buffer);
gdispDrawString(0, 10, layer_buffer, state->font_fixed5x8, Black);
format_layer_bitmap_string(state->status.default_layer >> 16, state->status.layer >> 16, layer_buffer);
gdispDrawString(0, 20, layer_buffer, state->font_fixed5x8, Black);
return false;
}
static void format_mods_bitmap_string(uint8_t mods, char* buffer) {
*buffer = ' ';
++buffer;
for (int i = 0; i<8; i++)
{
uint32_t mask = (1u << i);
if (mods & mask) {
*buffer = '1';
} else {
*buffer = '0';
}
++buffer;
if (i==3) {
*buffer = ' ';
++buffer;
}
}
*buffer = 0;
}
bool lcd_keyframe_display_mods_bitmap(keyframe_animation_t* animation, visualizer_state_t* state) {
(void)animation;
const char* title = "Modifier states";
const char* mods_header = " CSAG CSAG ";
char status_buffer[12];
gdispClear(White);
gdispDrawString(0, 0, title, state->font_fixed5x8, Black);
gdispDrawString(0, 10, mods_header, state->font_fixed5x8, Black);
format_mods_bitmap_string(state->status.mods, status_buffer);
gdispDrawString(0, 20, status_buffer, state->font_fixed5x8, Black);
return false;
}
#define LED_STATE_STRING_SIZE sizeof("NUM CAPS SCRL COMP KANA")
static void get_led_state_string(char* output, visualizer_state_t* state) {
uint8_t pos = 0;
if (state->status.leds & (1u << USB_LED_NUM_LOCK)) {
memcpy(output + pos, "NUM ", 4);
pos += 4;
}
if (state->status.leds & (1u << USB_LED_CAPS_LOCK)) {
memcpy(output + pos, "CAPS ", 5);
pos += 5;
}
if (state->status.leds & (1u << USB_LED_SCROLL_LOCK)) {
memcpy(output + pos, "SCRL ", 5);
pos += 5;
}
if (state->status.leds & (1u << USB_LED_COMPOSE)) {
memcpy(output + pos, "COMP ", 5);
pos += 5;
}
if (state->status.leds & (1u << USB_LED_KANA)) {
memcpy(output + pos, "KANA", 4);
pos += 4;
}
output[pos] = 0;
}
bool lcd_keyframe_display_led_states(keyframe_animation_t* animation, visualizer_state_t* state)
{
(void)animation;
char output[LED_STATE_STRING_SIZE];
get_led_state_string(output, state);
gdispClear(White);
gdispDrawString(0, 10, output, state->font_dejavusansbold12, Black);
return false;
}
bool lcd_keyframe_display_layer_and_led_states(keyframe_animation_t* animation, visualizer_state_t* state) {
(void)animation;
gdispClear(White);
uint8_t y = 10;
if (state->status.leds) {
char output[LED_STATE_STRING_SIZE];
get_led_state_string(output, state);
gdispDrawString(0, 1, output, state->font_dejavusansbold12, Black);
y = 17;
}
gdispDrawString(0, y, state->layer_text, state->font_dejavusansbold12, Black);
return false;
}
bool lcd_keyframe_draw_logo(keyframe_animation_t* animation, visualizer_state_t* state) {
(void)state;
(void)animation;
// Read the uGFX documentation for information how to use the displays
// http://wiki.ugfx.org/index.php/Main_Page
gdispClear(White);
// You can use static variables for things that can't be found in the animation
// or state structs, here we use the image
//gdispGBlitArea is a tricky function to use since it supports blitting part of the image
// if you have full screen image, then just use LCD_WIDTH and LCD_HEIGHT for both source and target dimensions
gdispGBlitArea(GDISP, 0, 0, LCD_WIDTH, LCD_HEIGHT, 0, 0, LCD_WIDTH, (pixel_t*)resource_lcd_logo);
return false;
}
bool lcd_keyframe_disable(keyframe_animation_t* animation, visualizer_state_t* state) {
(void)animation;
(void)state;
gdispSetPowerMode(powerOff);
return false;
}
bool lcd_keyframe_enable(keyframe_animation_t* animation, visualizer_state_t* state) {
(void)animation;
(void)state;
gdispSetPowerMode(powerOn);
return false;
}