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
e9cb12d
..
05f5c6b
100644
(file)
--- a/
lib/APKPM.pm
+++ b/
lib/APKPM.pm
@@
-19,7
+19,7
@@
sub process_name {
return "$orig ($job_name)";
}
return "$orig ($job_name)";
}
-sub search : Job :
MinProcesses(1) : MaxProcesses(5) : Encode(e_json
) {
+sub search : Job :
Encode(e_json) : MinProcesses(0
) {
my ( $self, $job, $workload ) = @_;
warn "# search $job ", dump($workload);
my ( $self, $job, $workload ) = @_;
warn "# search $job ", dump($workload);
@@
-29,7
+29,7
@@
sub search : 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 search : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
return $res;
}
return $res;
}
+
1;
1;