my $taskset = $self->gc->new_task_set;
my $results;
- $taskset->add_task('poll_' . $_, "start", {
- on_complete => sub { push @$results, ${$_[0]} }
- }) foreach ( 'ZTEDSLAM', 'ZTEMSAN' );
-
while (my ($username,$ip) = each %$ip_username) {
$taskset->add_task('poll_ip_username', "$ip $username", {
on_complete => sub { push @$results, ${$_[0]} }
$self->do_background_json('Store_insert', { _table => 'poll', %$poll });
warn "# results = ", dump $results;
- return $results;
+ return $poll;
}
sub poll_ip_username : Job : Decode(d_array) : Encode(e_json) {