X-Git-Url: http://git.rot13.org/?a=blobdiff_plain;f=lib%2FAPKPM.pm;h=05f5c6ba2bf5db6d15b6957a74d3f1b3d01a8854;hb=HEAD;hp=e9cb12d012dcea52398faa62eee009613976643c;hpb=1d051970a06f4afc43874510bdf18272e3bf4692;p=APKPM.git diff --git a/lib/APKPM.pm b/lib/APKPM.pm index e9cb12d..05f5c6b 100644 --- a/lib/APKPM.pm +++ b/lib/APKPM.pm @@ -19,7 +19,7 @@ sub process_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); @@ -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('CRM_username', $workload, { + $taskset->add_task('CRM_search', $workload, { 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; } + 1;