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]+)$/) {
lmpx.com only provides a reader for public news (NNTP) servers. It is not
affiliated with the servers or forums shown here and is not responsible for
the content of articles, which is written by their respective authors.