39 |
my $info; |
my $info; |
40 |
sub info { |
sub info { |
41 |
my $port = shift; |
my $port = shift; |
42 |
push @{ $info->{$port} }, [ @_ ]; |
push @{ $info->{node}->{$port} }, [ @_ ]; |
43 |
} |
} |
44 |
|
|
45 |
sub fork_ssh { |
sub fork_ssh { |
109 |
warn "<<<< ", dump($data), $/; |
warn "<<<< ", dump($data), $/; |
110 |
|
|
111 |
if ( my $path = $data->{shard} ) { |
if ( my $path = $data->{shard} ) { |
112 |
push @{ $info->{shard}->{ $data->{port} } }, $path; |
$info->{shard}->{ $path } = $data->{port}; |
113 |
|
# FIXME will need push for multiple copies of shards |
114 |
} |
} |
115 |
|
|
116 |
if ( my $repl = $data->{repl} ) { |
if ( my $repl = $data->{repl} ) { |