Gecko [ www.thearyasamaj.org ]

Name	Size	Permission
help	[ DIR ]	drwxr-xr-x
images	[ DIR ]	drwxr-xr-x
lang	[ DIR ]	drwxr-xr-x
CHANGELOG	109 B	-rw-r--r--
cluster-cron-lib.pl	4.76 KB	-rwxr-xr-x
cron.pl	658 B	-rwxr-xr-x
delete.cgi	346 B	-rwxr-xr-x
delete_jobs.cgi	409 B	-rwxr-xr-x
edit.cgi	2.25 KB	-rwxr-xr-x
exec.cgi	1.18 KB	-rwxr-xr-x
index.cgi	1.92 KB	-rwxr-xr-x
log_parser.pl	879 B	-rwxr-xr-x
module.info	250 B	-rw-r--r--
module.info.af	0 B	-rw-r--r--
module.info.af.auto	151 B	-rw-r--r--
module.info.ar	0 B	-rw-r--r--
module.info.ar.auto	212 B	-rw-r--r--
module.info.be	0 B	-rw-r--r--
module.info.be.auto	221 B	-rw-r--r--
module.info.bg	0 B	-rw-r--r--
module.info.bg.auto	216 B	-rw-r--r--
module.info.ca	133 B	-rw-r--r--
module.info.ca.auto	29 B	-rw-r--r--
module.info.cs	30 B	-rw-r--r--
module.info.cs.auto	127 B	-rw-r--r--
module.info.da	0 B	-rw-r--r--
module.info.da.auto	133 B	-rw-r--r--
module.info.de	130 B	-rw-r--r--
module.info.de.auto	29 B	-rw-r--r--
module.info.el	0 B	-rw-r--r--
module.info.el.auto	284 B	-rw-r--r--
module.info.es	33 B	-rw-r--r--
module.info.es.auto	130 B	-rw-r--r--
module.info.eu	0 B	-rw-r--r--
module.info.eu.auto	154 B	-rw-r--r--
module.info.fa	0 B	-rw-r--r--
module.info.fa.auto	200 B	-rw-r--r--
module.info.fi	0 B	-rw-r--r--
module.info.fi.auto	152 B	-rw-r--r--
module.info.fr	38 B	-rw-r--r--
module.info.fr.auto	130 B	-rw-r--r--
module.info.he	0 B	-rw-r--r--
module.info.he.auto	182 B	-rw-r--r--
module.info.hr	0 B	-rw-r--r--
module.info.hr.auto	154 B	-rw-r--r--
module.info.hu	40 B	-rw-r--r--
module.info.hu.auto	131 B	-rw-r--r--
module.info.it	0 B	-rw-r--r--
module.info.it.auto	154 B	-rw-r--r--
module.info.ja	0 B	-rw-r--r--
module.info.ja.auto	199 B	-rw-r--r--
module.info.ko	0 B	-rw-r--r--
module.info.ko.auto	174 B	-rw-r--r--
module.info.lt	0 B	-rw-r--r--
module.info.lt.auto	159 B	-rw-r--r--
module.info.lv	0 B	-rw-r--r--
module.info.lv.auto	155 B	-rw-r--r--
module.info.ms	112 B	-rw-r--r--
module.info.ms.auto	29 B	-rw-r--r--
module.info.mt	0 B	-rw-r--r--
module.info.mt.auto	150 B	-rw-r--r--
module.info.nl	40 B	-rw-r--r--
module.info.nl.auto	124 B	-rw-r--r--
module.info.no	29 B	-rw-r--r--
module.info.no.auto	109 B	-rw-r--r--
module.info.pl	153 B	-rw-r--r--
module.info.pl.auto	29 B	-rw-r--r--
module.info.pt	0 B	-rw-r--r--
module.info.pt.auto	160 B	-rw-r--r--
module.info.pt_BR	0 B	-rw-r--r--
module.info.pt_BR.auto	169 B	-rw-r--r--
module.info.ro	0 B	-rw-r--r--
module.info.ro.auto	143 B	-rw-r--r--
module.info.ru	0 B	-rw-r--r--
module.info.ru.auto	284 B	-rw-r--r--
module.info.sk	0 B	-rw-r--r--
module.info.sk.auto	164 B	-rw-r--r--
module.info.sl	0 B	-rw-r--r--
module.info.sl.auto	145 B	-rw-r--r--
module.info.sv	0 B	-rw-r--r--
module.info.sv.auto	134 B	-rw-r--r--
module.info.th	0 B	-rw-r--r--
module.info.th.auto	272 B	-rw-r--r--
module.info.tr	0 B	-rw-r--r--
module.info.tr.auto	162 B	-rw-r--r--
module.info.uk	0 B	-rw-r--r--
module.info.uk.auto	215 B	-rw-r--r--
module.info.ur	0 B	-rw-r--r--
module.info.ur.auto	211 B	-rw-r--r--
module.info.vi	0 B	-rw-r--r--
module.info.vi.auto	162 B	-rw-r--r--
module.info.zh	0 B	-rw-r--r--
module.info.zh.auto	127 B	-rw-r--r--
module.info.zh_TW	0 B	-rw-r--r--
module.info.zh_TW.auto	136 B	-rw-r--r--
save.cgi	1.82 KB	-rwxr-xr-x
uninstall.pl	233 B	-rwxr-xr-x

Code Editor : cluster-cron-lib.pl

# cluster-cron-lib.pl
# XXX environment variables??
#	XXX create script to run, which sets vars and includes input as << ?

BEGIN { push(@INC, ".."); };
use WebminCore;
&init_config();
&foreign_require("cron", "cron-lib.pl");
&foreign_require("servers", "servers-lib.pl");

$cluster_cron_cmd = "$module_config_directory/cron.pl";
$jobs_directory = "$module_config_directory/jobs";

# list_cluster_jobs()
# Returns an array of cron jobs that are run on multiple servers
sub list_cluster_jobs
{
local @rv;
foreach $j (&cron::list_cron_jobs()) {
	if ($j->{'user'} eq 'root' &&
	    $j->{'command'} =~ /^$cluster_cron_cmd\s+(\S+)$/) {
		$j->{'cluster_id'} = $1;
		&read_file("$jobs_directory/$1", $j) || next;
		push(@rv, $j);
		}
	}
return @rv;
}

# create_cluster_job(&job)
# Create a new cluster cron job
sub create_cluster_job
{
mkdir($jobs_directory, 0700);
&lock_file("$jobs_directory/$_[0]->{'cluster_id'}");
&write_file("$jobs_directory/$_[0]->{'cluster_id'}", &cluster_params($_[0]));
&unlock_file("$jobs_directory/$_[0]->{'cluster_id'}");
&lock_file("$cron::config{'cron_dir'}/$_[0]->{'user'}");
&cron::create_cron_job($_[0]);
&unlock_file("$cron::config{'cron_dir'}/$_[0]->{'user'}");
}

# modify_cluster_job(&job)
# Update an existing cluster cron job
sub modify_cluster_job
{
&lock_file("$jobs_directory/$_[0]->{'cluster_id'}");
&write_file("$jobs_directory/$_[0]->{'cluster_id'}", &cluster_params($_[0]));
&unlock_file("$jobs_directory/$_[0]->{'cluster_id'}");
&lock_file($_[0]->{'file'});
&cron::change_cron_job($_[0]);
&unlock_file($_[0]->{'file'});
}

# delete_cluster_job(&job)
sub delete_cluster_job
{
&lock_file("$jobs_directory/$_[0]->{'cluster_id'}");
unlink("$jobs_directory/$_[0]->{'cluster_id'}");
&unlock_file("$jobs_directory/$_[0]->{'cluster_id'}");
&lock_file($_[0]->{'file'});
&cron::delete_cron_job($_[0]);
&unlock_file($_[0]->{'file'});
}

sub cluster_params
{
local %rv;
foreach $k (keys %{$_[0]}) {
	$rv{$k} = $_[0]->{$k} if ($k =~ /^cluster_/);
	}
return \%rv;
}

# run_cluster_job(&job, &callback)
# Runs a cluster cron job on all configured servers, and for each result calls
# the callback function with parameters 0/1, a server object, and the output
# or error message
sub run_cluster_job
{
local @rv;
local $func = $_[1];

# Work out which servers to run on
local @servers = &servers::list_servers_sorted();
local @groups = &servers::list_all_groups(\@servers);
local @run;
foreach $s (split(/\s+/, $_[0]->{'cluster_server'})) {
	if ($s =~ /^group_(.*)$/) {
		# All members of a group
		($group) = grep { $_->{'name'} eq $1 } @groups;
		foreach $m (@{$group->{'members'}}) {
			push(@run, grep { $_->{'host'} eq $m && $_->{'user'} }
					@servers);
			}
		}
	elsif ($s eq '*') {
		# This server
		push(@run, ( { 'desc' => $text{'edit_this'} } ));
		}
	elsif ($s eq 'ALL') {
		# All servers with users
		push(@run, grep { $_->{'user'} } @servers);
		}
	else {
		# A single remote server
		push(@run, grep { $_->{'host'} eq $s } @servers);
		}
	}
@run = &unique(@run);

# Setup error handler for down hosts
sub inst_error
{
$inst_error_msg = join("", @_);
}
&remote_error_setup(\&inst_error);

# Create a local temp file containing input
local $ltemp = &transname();
open(TEMP, ">$ltemp");
local $inp = $_[0]->{'cluster_input'};
$inp =~ s/\\%/\0/g;
@lines = split(/%/, $inp);
foreach $l (@lines) {
	$l =~ s/\0/%/g;
	print TEMP $l,"\n";
	}
close(TEMP);

# Run one each one in parallel and display the output
$p = 0;
foreach $s (@run) {
	local ($rh = "READ$p", $wh = "WRITE$p");
	pipe($rh, $wh);
	select($wh); $| = 1; select(STDOUT);
	if (!fork()) {
		# Run the command in a subprocess
		close($rh);

&remote_foreign_require($s->{'host'}, "webmin",
					"webmin-lib.pl");
		if ($inst_error_msg) {
			# Failed to contact host ..
			print $wh &serialise_variable([ 0, $inst_error_msg ]);
			exit;
			}

# Send any input to a temp file
		local $rtemp = &remote_write($s->{'host'}, $ltemp);

# Run the command and capture output
		local $q = quotemeta($_[0]->{'cluster_command'});
		local $rv;
		if ($_[0]->{'cluster_user'} eq 'root') {
			$rv = &remote_eval($s->{'host'}, "webmin",
			    "\$x=&backquote_command('($_[0]->{'cluster_command'}) <$rtemp 2>&1')");
			}
		else {
			$q = quotemeta($q);
			$rv = &remote_eval($s->{'host'}, "webmin",
			    "\$x=&backquote_command(&command_as_user('$_[0]->{'cluster_user'}', 0, '$_[0]->{'cluster_command'}').' <$rtemp 2>&1')");
			}
		&remote_eval($s->{'host'}, "webmin", "unlink('$rtemp')");

print $wh &serialise_variable([ 1, $rv ]);
		close($wh);
		exit;
		}
	close($wh);
	$p++;
	}

# Get back all the results
$p = 0;
foreach $s (@run) {
	local $rh = "READ$p";
	local $line = <$rh>;
	close($rh);
	local $rv = &unserialise_variable($line);

if (!$line) {
		&$func(0, $s, "Unknown reason");
		}
	else {
		&$func($rv->[0], $s, $rv->[1]);
		}
	$p++;
	}
unlink($ltemp);
return @run;
}

${this.title}

Code Editor : cluster-cron-lib.pl