17 |
sub code { |
sub code { |
18 |
my ( $self, $code ) = @_; |
my ( $self, $code ) = @_; |
19 |
|
|
20 |
warn "XX code $code"; |
#warn "XX code $code"; |
21 |
|
|
22 |
undef $out; |
undef $out; |
23 |
|
|
34 |
sub on_shard { |
sub on_shard { |
35 |
my ( $self, $data ) = @_; |
my ( $self, $data ) = @_; |
36 |
|
|
37 |
|
die "data not ARRAY but ", ref $data unless ref $data eq 'ARRAY'; |
38 |
|
|
39 |
warn "XX data ",dump $data; |
warn "XX data ",dump $data; |
40 |
|
|
41 |
my $affected = 0; |
my $affected = 0; |
49 |
eval { $coderef->( $data->[$pos] ) }; |
eval { $coderef->( $data->[$pos] ) }; |
50 |
|
|
51 |
if ( $@ ) { |
if ( $@ ) { |
52 |
warn "ABORT $pos $@\n"; |
warn "ABORT at $pos error $@\n"; |
53 |
last; |
last; |
54 |
} else { |
} else { |
55 |
$affected++; |
$affected++; |