From: rettenbe <rettenbe@594d385d-05f5-0310-b6e9-bd551577e9d8>
Date: Mon, 25 May 2009 06:35:47 +0000 (+0000)
Subject: * checkin of new plugin load_reporter, again
X-Git-Url: https://git.tokkee.org/?a=commitdiff_plain;h=2d9ac44cf31fe6593694e3d405ee9852274825fa;p=gosa.git

* checkin of new plugin load_reporter, again


git-svn-id: https://oss.gonicus.de/repositories/gosa/trunk@13663 594d385d-05f5-0310-b6e9-bd551577e9d8
---

diff --git a/gosa-si/client/events/load_reporter.pm b/gosa-si/client/events/load_reporter.pm
index e69de29bb..63b5e6194 100644
--- a/gosa-si/client/events/load_reporter.pm
+++ b/gosa-si/client/events/load_reporter.pm
@@ -0,0 +1,96 @@
+package load_reporter;
+use Exporter;
+@ISA = qw(Exporter);
+my @events = (
+    "get_events",
+    "get_terminal_server",
+	"get_load",
+	"report_load",
+	"set_terminal_server",
+    );
+@EXPORT = @events;
+
+use strict;
+use warnings;
+use GOSA::GosaSupportDaemon;
+use Data::Dumper;
+
+BEGIN {}
+END {}
+
+my $ts_load_file;
+my $waiting_for_ts_info;
+my %cfg_defaults = (
+		"client" => {
+		"ts-load-file" => [\$ts_load_file, "/var/run/gosa-si-client-ts-load.txt"],
+		"waiting-for-ts-info" => [\$waiting_for_ts_info, 5],
+		},
+		);
+&GOSA::GosaSupportDaemon::read_configfile($main::cfg_file, %cfg_defaults);
+
+
+### FUNCTIONS #################################################################
+sub get_events { return \@events; }
+
+sub get_terminal_server 
+{
+	my ($content, $poe_kernel) = @_ ;
+
+	# Create message
+	my $msg_hash = &create_xml_hash("get_terminal_server", $main::client_address, $main::server_address);
+	&add_content2xml_hash($msg_hash, "macaddress", $main::client_mac_address);
+	my $msg = &create_xml_string($msg_hash);
+	
+	$poe_kernel->delay_set('trigger_set_terminal_server', $waiting_for_ts_info);
+	&main::daemon_log("INFO: Start obtaining terminal server load information. Set waiting time to '$waiting_for_ts_info' sec.", 5);
+	return $msg;
+}
+
+sub get_load 
+{
+	my ($msg, $msg_hash) = @_ ;	
+	my $source = @{$msg_hash->{'source'}}[0];
+	my $target = @{$msg_hash->{'target'}}[0];
+	my $out_msg;
+
+
+	my $file = "/proc/loadavg";
+	if ((not -f $file) || (not -r $file)) { return }
+	open(FHD, "<$file");
+	my $line = <FHD>;
+	close(FHD);
+	chomp($line);
+
+	$out_msg = &create_xml_string(&create_xml_hash("report_load", $target, $source, $line));
+
+	return $out_msg;
+}
+
+sub report_load
+{
+	my ($msg, $msg_hash) = @_ ;
+	my $source = @{$msg_hash->{'source'}}[0];
+	my $load = @{$msg_hash->{'report_load'}}[0];
+
+	$main::terminal_server_hash->{$source} = $load;
+
+	return;
+}
+
+sub set_terminal_server
+{
+	my $file_content = "";
+	while (my ($ts, $load) = each %$main::terminal_server_hash)
+	{
+		$file_content .= "$ts $load\n";
+	}
+	open(FHD, ">$ts_load_file.part");
+	printf FHD $file_content;
+	close FHD;
+
+	system("mv $ts_load_file.part $ts_load_file");
+	&main::daemon_log("INFO: Wrote terminal server load information to $ts_load_file", 5);
+	return;
+}
+
+1;