projects
/
APKPM.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
modify schema for new CPE stats
[APKPM.git]
/
lib
/
APKPM.pm
diff --git
a/lib/APKPM.pm
b/lib/APKPM.pm
index
8f9c992
..
05f5c6b
100644
(file)
--- a/
lib/APKPM.pm
+++ b/
lib/APKPM.pm
@@
-19,9
+19,9
@@
sub process_name {
return "$orig ($job_name)";
}
return "$orig ($job_name)";
}
-sub
poll : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json
) {
+sub
search : Job : Encode(e_json) : MinProcesses(0
) {
my ( $self, $job, $workload ) = @_;
my ( $self, $job, $workload ) = @_;
- warn "#
poll
$job ", dump($workload);
+ warn "#
search
$job ", dump($workload);
my $res = { workload => $workload };
my $res = { workload => $workload };
@@
-29,7
+29,7
@@
sub poll : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
$taskset->add_task('LDAP_search', $workload, {
on_complete => sub { $res->{ldap} = $self->d_json( ${$_[0]} ) }
});
$taskset->add_task('LDAP_search', $workload, {
on_complete => sub { $res->{ldap} = $self->d_json( ${$_[0]} ) }
});
- $taskset->add_task('CRM_
username
', $workload, {
+ $taskset->add_task('CRM_
search
', $workload, {
on_complete => sub { $res->{crm} = $self->d_json( ${$_[0]} ) }
});
warn "# wait";
on_complete => sub { $res->{crm} = $self->d_json( ${$_[0]} ) }
});
warn "# wait";
@@
-37,4
+37,5
@@
sub poll : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
return $res;
}
return $res;
}
+
1;
1;