Subversion Repositories havirt

sub getClusterStats {

   my $return = {};

   foreach my $node (sort keys %{ $main::statusDB->{'node'} } ) {

      $return->{'nodes'}->{$node}->{'node_memory'} = $main::statusDB->{'node'}->{$node}->{'memory'};

      $return->{'nodes'}->{$node}->{'node_vcpu'} = $main::statusDB->{'node'}->{$node}->{'cpu_count'};

      $return->{'nodes'}->{$node}->{'node_maintenance'} = $main::statusDB->{'node'}->{$node}->{'maintenance'};

      $return->{'nodes'}->{$node}->{'domain_memory'} = 0;

      $return->{'nodes'}->{$node}->{'domain_vcpu'} = 0;

      $return->{'nodes'}->{$node}->{'domain_count'} = 0;

      foreach my $domain ( keys %{ $main::statusDB->{'nodePopulation'}->{$node}->{'running'} } ) {

         $return->{'nodes'}->{$node}->{'domain_memory'} += $main::statusDB->{'virt'}->{$domain}->{'memory'};

         $return->{'nodes'}->{$node}->{'domain_vcpu'} += $main::statusDB->{'virt'}->{$domain}->{'vcpu'};

         $return->{'nodes'}->{$node}->{'domain_count'}++;

         $return->{'nodes'}->{$node}->{'domains'}->{$domain}->{'memory'} = $main::statusDB->{'virt'}->{$domain}->{'memory'};

         $return->{'nodes'}->{$node}->{'domains'}->{$domain}->{'vcpu'} = $main::statusDB->{'virt'}->{$domain}->{'vcpu'};

      }

      if ( ! $main::statusDB->{'node'}->{$node}->{'maintenance'} ) { # do not include node resources if maintenance set

         $return->{'total_memory'} += $return->{'nodes'}->{$node}->{'node_memory'};

         $return->{'total_vcpu'} += $return->{'nodes'}->{$node}->{'node_vcpu'};

      }

      $return->{'total_count'} += $return->{'nodes'}->{$node}->{'domain_count'};

      $return->{'domain_memory'} += $return->{'nodes'}->{$node}->{'domain_memory'};

      $return->{'domain_vcpu'} += $return->{'nodes'}->{$node}->{'domain_vcpu'};

   }

   return $return;

}

# Creates a balance report to show the user what went on

# $cluster is a hash created by sub getClusterStats, and possibly modified by

# the calling process

sub showBalanceReport {

   my $cluster = shift;

   my $variance = 0;

   my $count = 0;

   my @header = ('Node','Threads','Memory(G)','Domains','vcpu_alloc','mem_alloc(G)', 'vcpu%', 'mem%', 'Status', 'StdDev' );

   my @data;

   foreach my $node ( sort keys %{ $cluster->{'nodes'} } ) {

      # get standard deviation

      my $stddev = $cluster->{'nodes'}->{$node}->{'node_maintenance'} ? 0 : 

                   (

                      ( $cluster->{'nodes'}->{$node}->{'domain_memory'} / $cluster->{'nodes'}->{$node}->{'node_memory'} * 100 ) - 

                      ( $cluster->{'domain_memory'} / $cluster->{'total_memory'} * 100 )

                   ) ** 2;

      push @data, [

         $node, 

         $cluster->{'nodes'}->{$node}->{'node_vcpu'},

         sprintf( '%d', $cluster->{'nodes'}->{$node}->{'node_memory'}/1024/1024 ),

         $cluster->{'nodes'}->{$node}->{'domain_count'},

         $cluster->{'nodes'}->{$node}->{'domain_vcpu'},

         $cluster->{'nodes'}->{$node}->{'domain_memory'}/1024/1024,

         sprintf( '%2.0f%%', $cluster->{'nodes'}->{$node}->{'domain_vcpu'} / $cluster->{'nodes'}->{$node}->{'node_vcpu'} * 100 ),

         sprintf( '%2.0f%%', $cluster->{'nodes'}->{$node}->{'domain_memory'} / $cluster->{'nodes'}->{$node}->{'node_memory'} * 100 ),

         $cluster->{'nodes'}->{$node}->{'node_maintenance'} ? 'Maintenance' : '',

         sprintf( "%d", $stddev )

      ];

      $variance += $stddev;

      $count++;

   }

   push @data, [

         'All', 

         $cluster->{'total_vcpu'},

         sprintf( '%d', $cluster->{'total_memory'}/1024/1024 ),

         $cluster->{'total_count'},

         $cluster->{'domain_vcpu'},

         $cluster->{'domain_memory'}/1024/1024,

         sprintf( '%2.0f%%', $cluster->{'domain_vcpu'} / $cluster->{'total_vcpu'} * 100 ),

         sprintf( '%2.0f%%', $cluster->{'domain_memory'} / $cluster->{'total_memory'} * 100 ),

         ''

      ];

   return &main::report( \@header, \@data ),sprintf( "%d", $variance / $count );

}

# attempt to balance the domains on the active (maintenance = false) nodes

# basically, we take what is currently working, and calculate the variance

# of it (see https://en.wikipedia.org/wiki/Standard_deviation). If that is

# over about a 10, we move things around, if possible, then check our variance

# again.

   &main::readDB();

   # get the current cluster status

   my $cluster = &getClusterStats();

   # for development, turn on verbose

   $main::config->{'flags'}->{'verbose'} = 1;

   # show user what it looks like at first

   if ( $main::config->{'flags'}->{'verbose'} ) {

      print "Starting Status\n\n";

      my ($report, $variance) =  &showBalanceReport( $cluster) ;

      print $report;

      print "Variance is $variance\n";

   }

   die;

   #die Dumper( $cluster ) . "\n";