Author: spadkins
Date: Fri Aug 11 16:13:19 2006
New Revision: 6785
Modified:
p5ee/trunk/App-Context/lib/App/Context/ClusterController.pm
Log:
clean up a redefinition of a variable in a scope
Modified: p5ee/trunk/App-Context/lib/App/Context/ClusterController.pm
==============================================================================
--- p5ee/trunk/App-Context/lib/App/Context/ClusterController.pm (original)
+++ p5ee/trunk/App-Context/lib/App/Context/ClusterController.pm Fri Aug 11
16:13:19 2006
@@ -53,7 +53,6 @@
sub dispatch_events_begin {
my ($self) = @_;
$self->log({level=>2},"Starting Cluster Controller on
$self->{host}:$self->{port}\n");
- # nothing special yet
}
sub dispatch_events_end {
@@ -78,6 +77,7 @@
$args = $self->{rpc_serializer}->serialize($event->{args});
}
my $response = $self->send_message($node_host, $node_port,
"ASYNC-EVENT:$event->{service_type}:$event->{name}:$event->{method}:$args", 1,
undef, 1);
+ #print "$response = send_message($node_host, $node_port,
ASYNC-EVENT:$event->{service_type}:$event->{name}:$event->{method}:$args\n";
if ($response =~ /^ASYNC-EVENT-TOKEN:(.+)/) {
my $runtime_event_token = $1;
my $destination = $event->{destination} || "local";
@@ -340,18 +340,18 @@
my $startup = $options->{startup};
+ my ($node, $msg, $host, $port, $cmd);
if ($startup eq "1") {
$self->read_node_file();
}
else {
- foreach my $node (split(/,/,$startup)) {
+ foreach $node (split(/,/,$startup)) {
$self->{node}{$node} = {};
}
}
- my ($msg, $host, $port, $cmd);
my $cmd_fmt = $self->{options}{"app.context.node_start_cmd"} || "ssh -f
{host} mvnode --port={port}";
- foreach my $node (keys %{$self->{node}}) {
+ foreach $node (keys %{$self->{node}}) {
$msg = $self->send_message($node, undef, "CONTROLLER-UP:", 0, undef,
1);
if ($msg =~ /ERROR:/) {
if ($node =~ /^([^:]+):([0-9]+)$/) {
