mirror of
https://github.com/webmin/webmin.git
synced 2025-07-23 00:30:33 +00:00
98 lines
2.5 KiB
Perl
Executable File
98 lines
2.5 KiB
Perl
Executable File
#!/usr/local/bin/perl
|
|
# cluster.cgi
|
|
# Optionally copy to and run the configuration on all managed hosts
|
|
|
|
require './cfengine-lib.pl';
|
|
&foreign_require("servers", "servers-lib.pl");
|
|
&ReadParse();
|
|
&ui_print_header(undef, $text{'cluster_title'}, "");
|
|
$| = 1;
|
|
|
|
# Build options string
|
|
$args .= " -v" if ($in{'verbose'});
|
|
$args .= " --dry-run" if ($in{'dry'});
|
|
$args .= " -i" if ($in{'noifc'});
|
|
$args .= " -m" if ($in{'nomnt'});
|
|
$args .= " -s" if ($in{'nocmd'});
|
|
$args .= " -t" if ($in{'notidy'});
|
|
$args .= " -X" if ($in{'nolinks'});
|
|
|
|
# Setup error handler for down hosts
|
|
sub run_error
|
|
{
|
|
$run_error_msg = join("", @_);
|
|
}
|
|
&remote_error_setup(\&run_error);
|
|
|
|
# Run on all hosts
|
|
print "<b>$text{'cluster_header'}</b><p>\n";
|
|
@hosts = &list_cfengine_hosts();
|
|
@servers = &list_servers();
|
|
$p = 0;
|
|
foreach $h (@hosts) {
|
|
local ($s) = grep { $_->{'id'} == $h->{'id'} } @servers;
|
|
|
|
local ($rh = "READ$p", $wh = "WRITE$p");
|
|
pipe($rh, $wh);
|
|
if (!fork()) {
|
|
close($rh);
|
|
&remote_foreign_require($s->{'host'}, "cfengine",
|
|
"cfengine-lib.pl");
|
|
if ($run_error_msg) {
|
|
# Host is down
|
|
print $wh &serialise_variable([ 0, $run_error_msg ]);
|
|
exit;
|
|
}
|
|
local $rconf = &remote_eval($s->{'host'}, "cfengine",
|
|
"\$cfengine_conf");
|
|
|
|
# Copy the config if requested and if not local
|
|
if ($in{'copy'} && $s->{'id'}) {
|
|
$lst = [ stat($cfengine_conf) ];
|
|
$rst = &remote_eval($s->{'host'}, "cfengine",
|
|
'[ stat($cfengine_conf) ]');
|
|
if ($lst->[1] != $rst->[1] ||
|
|
$lst->[7] != $rst->[7] ||
|
|
$lst->[9] != $rst->[9]) {
|
|
&remote_write($s->{'host'}, $cfengine_conf, $rconf);
|
|
}
|
|
}
|
|
|
|
# Execute code to run cfengine
|
|
$out = &remote_eval($s->{'host'}, "cfengine",
|
|
"\$ENV{'CFINPUTS'} = \$config{'cfengine_dir'}; `\$config{'cfengine'} -f \$cfengine_conf $args 2>&1 </dev/null`");
|
|
print $wh &serialise_variable([ 1, $out ]);
|
|
close($wh);
|
|
exit;
|
|
}
|
|
close($wh);
|
|
$p++;
|
|
}
|
|
|
|
# Read back the results
|
|
$p = 0;
|
|
foreach $h (@hosts) {
|
|
local ($s) = grep { $_->{'id'} == $h->{'id'} } @servers;
|
|
local $d = $s->{'desc'} ? $s->{'desc'} : $s->{'host'};
|
|
local $rh = "READ$p";
|
|
local $line = <$rh>;
|
|
local $rv = &unserialise_variable($line);
|
|
close($rh);
|
|
|
|
print &ui_hr();
|
|
if ($rv && $rv->[0]) {
|
|
# Run ok! Show the output
|
|
print "<font size=+1>",&text('cluster_success', $d),"</font><br>\n";
|
|
print "<font size=-1><pre>$rv->[1]</pre></font>\n";
|
|
}
|
|
else {
|
|
# Something went wrong
|
|
print &text('cluster_failed', $d, $rv->[1]),"<br>\n";
|
|
}
|
|
$p++;
|
|
}
|
|
|
|
&remote_finished();
|
|
&ui_print_footer("list_hosts.cgi", $text{'hosts_return'});
|
|
|