74 |
|
|
75 |
warn "info ",dump $info; |
warn "info ",dump $info; |
76 |
|
|
77 |
warn "load status ", dump( $lorry->get_from_all ); |
warn "load status ", dump( $lorry->get_from_all ),$/; |
78 |
|
|
79 |
our $out; |
our $out; |
80 |
our $repl = 1; |
our $repl = 1; |
93 |
duration 'dump'; |
duration 'dump'; |
94 |
} elsif ( $cmd =~ m{^x} ) { |
} elsif ( $cmd =~ m{^x} ) { |
95 |
$repl = 0; |
$repl = 0; |
96 |
|
} elsif ( $cmd =~ m{^r} ) { |
97 |
|
$lorry->restart_nodes; |
98 |
|
} elsif ( $cmd =~ m{^i} ) { |
99 |
|
$lorry->send_to_all({ info => 1 }); |
100 |
|
my $info = $lorry->get_from_all; |
101 |
|
foreach my $port ( keys %$info ) { |
102 |
|
warn "[$port] $lorry->{port_on_host}->{$port} ", dump( $info->{$port} ), "\n"; |
103 |
|
} |
104 |
|
} elsif ( $cmd =~ m{^sh\s+(.+)} ) { |
105 |
|
$lorry->send_to_all({ sh => $1 }); |
106 |
|
my $sh = $lorry->get_from_all; |
107 |
|
foreach my $port ( keys %$sh ) { |
108 |
|
warn "[$port] $1\n$sh->{$port}->{sh}\n"; |
109 |
|
} |
110 |
} else { |
} else { |
111 |
warn "unknown $cmd\n"; |
warn "UNKNOWN $cmd\n" if $cmd; |
112 |
} |
} |
113 |
} |
} |
114 |
|
|