projects
/
APKPM.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
5c5f86e
)
remove poll_ZTE* and return stats only
author
Dobrica Pavlinusic
<dpavlin@rot13.org>
Mon, 20 Jun 2011 20:38:37 +0000
(22:38 +0200)
committer
Dobrica Pavlinusic
<dpavlin@rot13.org>
Mon, 20 Jun 2011 20:38:37 +0000
(22:38 +0200)
lib/APKPM/Poll.pm
patch
|
blob
|
history
diff --git
a/lib/APKPM/Poll.pm
b/lib/APKPM/Poll.pm
index
e006e93
..
bfb533f
100644
(file)
--- a/
lib/APKPM/Poll.pm
+++ b/
lib/APKPM/Poll.pm
@@
-32,10
+32,6
@@
sub poll_prefix : Job : Encode(e_json) {
my $taskset = $self->gc->new_task_set;
my $results;
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]} }
while (my ($username,$ip) = each %$ip_username) {
$taskset->add_task('poll_ip_username', "$ip $username", {
on_complete => sub { push @$results, ${$_[0]} }
@@
-64,7
+60,7
@@
sub poll_prefix : Job : Encode(e_json) {
$self->do_background_json('Store_insert', { _table => 'poll', %$poll });
warn "# results = ", dump $results;
$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) {
}
sub poll_ip_username : Job : Decode(d_array) : Encode(e_json) {