testing tweaks, fix for schema

funcname, run_after is not the right index anymore :)

lib/SchwartzMan.pm

@@ -51,7 +51,7 @@ sub new {
 
     $self->{batch_fetch_limit} = MIN_BATCH_SIZE;
     $self->{batch_run_sleep} = 1;
-    $self->{queue_watermark_depth} = 5; # FIXME: Example :P
+    $self->{queue_watermark_depth} = 4000; # FIXME: Example :P
 
     return $self;
 }
@@ -199,6 +199,7 @@ sub work {
                 unless $self->{batch_fetch_limit} <= MIN_BATCH_SIZE;
         }
 
+        DEBUG && print STDERR "Sent, sleeping\n";
         # Sleep for configured amount of time.
         # TODO: Use the select microsleep hack?
         sleep $self->{batch_run_sleep};

schema.sql

@@ -6,6 +6,6 @@ CREATE TABLE `job` (
     `run_after`   INT UNSIGNED NOT NULL,
     `coalesce`    VARCHAR(255) NULL,
     PRIMARY KEY (jobid),
-    INDEX (funcname, run_after),
+    INDEX (run_after),
     UNIQUE (funcname, uniqkey)
 ) ENGINE=InnoDB;

sm_inject

@@ -8,14 +8,15 @@ use lib "$Bin/lib";
 use Getopt::Long;
 use SchwartzMan::Client;
 
-my %o = ();
+my %o = (loops => 1);
 
 # TODO: Doesn't support specifying multiple DB's yet. YAML config or whatever?
 # TODO: Uhh... require a control manager or do our own fork management?
 GetOptions(\%o,
     'dsn=s',
     'username=s',
     'password=s',
+    'loops=i',
     );
 
 die "Need dsn" unless $o{dsn};
@@ -28,5 +29,7 @@ sub run {
         pass => $o{password}, }},
         );
 
-    $client->insert_job(funcname => 'foo', arg => 'hello: ' . time());
+    for (my $i = 0; $i < $o{loops} $i++) {
+        $client->insert_job(funcname => 'foo', arg => 'hello: ' . time());
+    }
 }