#!/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;
}