From: Dobrica Pavlinusic Date: Tue, 5 Jul 2011 19:00:35 +0000 (+0200) Subject: setup min_processes to 0 for all workers X-Git-Url: http://git.rot13.org/?a=commitdiff_plain;h=7224ccda02112ee59b29ee508e8eaf8d97426430;p=APKPM.git setup min_processes to 0 for all workers --- diff --git a/lib/APKPM.pm b/lib/APKPM.pm index 1ede1a4..05f5c6b 100644 --- a/lib/APKPM.pm +++ b/lib/APKPM.pm @@ -19,7 +19,7 @@ sub process_name { return "$orig ($job_name)"; } -sub search : Job : Encode(e_json) { +sub search : Job : Encode(e_json) : MinProcesses(0) { my ( $self, $job, $workload ) = @_; warn "# search $job ", dump($workload); diff --git a/lib/APKPM/LDAP.pm b/lib/APKPM/LDAP.pm index 29308d1..3002d5f 100644 --- a/lib/APKPM/LDAP.pm +++ b/lib/APKPM/LDAP.pm @@ -19,7 +19,7 @@ sub process_name { return "$orig ($job_name)"; } -sub search : Job : Encode(e_json) { +sub search : Job : Encode(e_json) : MinProcesses(0) { my ( $self, $job, $workload ) = @_; my $filter = diff --git a/lib/APKPM/Store.pm b/lib/APKPM/Store.pm index e801108..054e53c 100644 --- a/lib/APKPM/Store.pm +++ b/lib/APKPM/Store.pm @@ -35,13 +35,13 @@ sub pg_insert { $sth->execute( map { $h->{$_} } @c ); } -sub insert : Job : Decode(d_json) { +sub insert : Job : Decode(d_json) : MinProcesses(0) { my ( $self, $job, $workload ) = @_; my $table = delete $workload->{_table} || die "no _table"; $self->pg_insert($table => $workload); } -sub sql : Job : Encode(e_json) { +sub sql : Job : Encode(e_json) : MinProcesses(0) { my ( $self, $job, $workload ) = @_; my $sth = $self->dbh->prepare($workload); diff --git a/lib/APKPM/VOICE.pm b/lib/APKPM/VOICE.pm index b17ecdd..64b90b5 100644 --- a/lib/APKPM/VOICE.pm +++ b/lib/APKPM/VOICE.pm @@ -14,7 +14,7 @@ use H1::VOICE; sub prefix { 'VOICE_' } -sub info : Job : Encode(e_json) { +sub info : Job : Encode(e_json) : MinProcesses(0) { my ( $self, $job, $workload ) = @_; warn "# workload = ", dump $workload;