114 |
Sack::Merge->clean; |
Sack::Merge->clean; |
115 |
delete( $info->{view} ); |
delete( $info->{view} ); |
116 |
delete( $info->{merge} ); |
delete( $info->{merge} ); |
117 |
|
delete( $info->{shard} ); |
118 |
to_all { code => $code, view => $path }; |
to_all { code => $code, view => $path }; |
119 |
}; |
}; |
120 |
|
|
326 |
my $added = Sack::Merge->add( $data->{out} ) if defined $data->{out}; |
my $added = Sack::Merge->add( $data->{out} ) if defined $data->{out}; |
327 |
$info->{merge}->{ $data->{view} }->{ $data->{port} } = $added; |
$info->{merge}->{ $data->{view} }->{ $data->{port} } = $added; |
328 |
$info->{view }->{ $data->{view} }->{ $data->{port} } = $data->{on_shard}; |
$info->{view }->{ $data->{view} }->{ $data->{port} } = $data->{on_shard}; |
329 |
|
# refresh shard allocation |
330 |
|
$info->{shard}->{ $_ } = $data->{port} foreach keys %{ $data->{on_shard} }; |
331 |
} elsif ( exists $data->{port} ) { |
} elsif ( exists $data->{port} ) { |
332 |
push @responses, $data; |
push @responses, $data; |
333 |
warn "# ",dump($data),$/; |
warn "# ",dump($data),$/; |