remove all process limits from code

[APKPM.git] / lib / APKPM / Store.pm

diff --git a/lib/APKPM/Store.pm b/lib/APKPM/Store.pm
index 04a2371..c617b5e 100644 (file)
--- a/lib/APKPM/Store.pm
+++ b/lib/APKPM/Store.pm
@@ -35,7 +35,7 @@ sub pg_insert {
        $sth->execute( map { $h->{$_} } @c );
 }
 
-sub ADSL : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
+sub ADSL : Job : Decode(d_json) {
        my ( $self, $job, $workload ) = @_;
 
        my $h = $workload->{ADSL} || die "no ADSL in ",dump $workload;
@@ -48,19 +48,24 @@ sub ADSL : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
        $self->pg_insert(adsl => $h)
 }
 
-sub ping : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
+sub ping : Job : Decode(d_json) {
        my ( $self, $job, $workload ) = @_;
 
        $self->pg_insert(ping => $workload);
 }
 
-sub voice : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
+sub voice : Job : Decode(d_json) {
        my ( $self, $job, $workload ) = @_;
        $self->pg_insert(voice => $workload);
 }
 
+sub insert_table : Job : Decode(d_json) {
+       my ( $self, $job, $workload ) = @_;
+       my $table = delete $workload->{_table} || die "no _table";
+       $self->pg_insert($table => $workload);
+}
 
-sub sql : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
+sub sql : Job : Encode(e_json) {
        my ( $self, $job, $workload ) = @_;
 
        my $sth = $self->dbh->prepare($workload);