[svn:p5ee] r10147 - p5ee/trunk/App-Context/lib/App/Context/POE

[email protected] Thu, 1 Nov 2007 06:07:38 -0700 (PDT)
Newsgroups perl.cvs.p5ee
Message-ID <[email protected]>
Author: spadkins
Date: Thu Nov  1 06:07:36 2007
New Revision: 10147

Modified:
   p5ee/trunk/App-Context/lib/App/Context/POE/ClusterController.pm
   p5ee/trunk/App-Context/lib/App/Context/POE/ClusterNode.pm

Log:
cosmetic changes mostly to the state view (added system load, estimated load, node up time and node last update time, request priority)

Modified: p5ee/trunk/App-Context/lib/App/Context/POE/ClusterController.pm
==============================================================================
--- p5ee/trunk/App-Context/lib/App/Context/POE/ClusterController.pm	(original)
+++ p5ee/trunk/App-Context/lib/App/Context/POE/ClusterController.pm	Thu Nov  1 06:07:36 2007
@@ -217,7 +217,7 @@
     my ($self, $kernel, $args) = @_[OBJECT, KERNEL, ARG0];
     my ($node, $sys_info) = @$args;
     $self->log("POE: poe_receive_node_status ($node) - " .
-               "load=$sys_info->{load}, " .
+               "load=$sys_info->{system_load}, " .
                "memfree=$sys_info->{memfree}/$sys_info->{memtotal} " .
                "swapfree=$sys_info->{swapfree}/$sys_info->{swaptotal}\n") if $self->{options}{poe_trace};
     $self->set_node_up($node, $sys_info);
@@ -267,15 +267,17 @@
     my ($memfree, $memtotal, $swapfree, $swaptotal);
     foreach my $node (sort keys %{$self->{node}}) {
         next if ($node eq "ALL");
-        $state .= sprintf("   %-16s %4s : %3d/%3d max : [Load:%4.1f][Mem:%5.1f%%/%7d][Swap:%5.1f%%/%7d] : [%19s]\n", $node,
+        $state .= sprintf("   %-16s %4s : %3d/%3d max : [Load:%4.1f][System Load:%4.1f][Mem:%5.1f%%/%7d][Swap:%5.1f%%/%7d] : [Up:%19s][Last:%19s]\n", $node,
             $self->{node}{$node}{up} ? "UP" : "down",
             $self->{node}{$node}{num_async_events} || 0,
             $self->{node}{$node}{max_async_events} || 0,
             $self->{node}{$node}{load} || 0,
+            $self->{node}{$node}{system_load} || 0,
             $self->{node}{$node}{memtotal} ? 100*($self->{node}{$node}{memtotal} - $self->{node}{$node}{memfree})/$self->{node}{$node}{memtotal} : 0,
             $self->{node}{$node}{memtotal} || 0,
             $self->{node}{$node}{swaptotal} ? 100*($self->{node}{$node}{swaptotal} - $self->{node}{$node}{swapfree})/$self->{node}{$node}{swaptotal} : 0,
             $self->{node}{$node}{swaptotal} || 0,
+            $self->{node}{$node}{up_datetime},
             $self->{node}{$node}{datetime});
     }
 
@@ -290,7 +292,7 @@
     my ($self, $node, $sys_info) = @_;
     my ($retval);
     if (!$self->{node}{$node}{up}) {
-        $self->{node}{$node}{datetime} = time2str("%Y-%m-%d %H:%M:%S", time());
+        $self->{node}{$node}{up_datetime} = time2str("%Y-%m-%d %H:%M:%S", time());
         if ($self->{node}{$node}{up}) {
             $retval = "ok";
         }
@@ -301,6 +303,7 @@
         }
     }
     if ($sys_info) {
+        $self->{node}{$node}{datetime} = time2str("%Y-%m-%d %H:%M:%S", time());
         foreach my $sys_var (keys %$sys_info) {
             $self->{node}{$node}{$sys_var} = $sys_info->{$sys_var};
         }

Modified: p5ee/trunk/App-Context/lib/App/Context/POE/ClusterNode.pm
==============================================================================
--- p5ee/trunk/App-Context/lib/App/Context/POE/ClusterNode.pm	(original)
+++ p5ee/trunk/App-Context/lib/App/Context/POE/ClusterNode.pm	Thu Nov  1 06:07:36 2007
@@ -196,10 +196,12 @@
     my $memfree = $sys_info->{memfree} + $sys_info->{buffers} + $sys_info->{cached};
     my $s_info = {
         load => $sys_info->{load},
+        system_load => $sys_info->{load},
         memfree => $memfree,
         memtotal => $sys_info->{memtotal},
         swapfree => $sys_info->{swapfree},
         swaptotal => $sys_info->{swaptotal},
+        max_async_events => $self->{max_async_events}
     };
 
     if ($self->{controller_up}) {