[svn:p5ee] r10229 - p5ee/trunk/App-WorkQueue/lib/App/WorkQueue

[spadkins]

Author: spadkins
Date: Mon Nov 12 08:24:39 2007
New Revision: 10229

Modified:
   p5ee/trunk/App-WorkQueue/lib/App/WorkQueue/Repository.pm

Log:
attempt to fix our num_workers / async_events discrepancy, take 36

Modified: p5ee/trunk/App-WorkQueue/lib/App/WorkQueue/Repository.pm
==============================================================================
--- p5ee/trunk/App-WorkQueue/lib/App/WorkQueue/Repository.pm    (original)
+++ p5ee/trunk/App-WorkQueue/lib/App/WorkQueue/Repository.pm    Mon Nov 12 
08:24:39 2007
@@ -324,17 +324,21 @@
         }
     }
     if ($release_without_acquire) {
+        $context->log("NOTE: release.release_without_acquire is true : 
subrequest_id[" . $entry->{subrequest_id} . "]\n");
         $resource_counts->{total}{$resource_key}--;
     }
-    ### TODO: figure out why $released is ever false, causing constraint issues
+    ### TODO: figure out how to maintain numbers when $released is false, 
causing constraint issues
     my $released = $self->_release_in_mem($entry, $columns, $values);
     if ($released) {
         $resource_counts->{buffer}{$resource_key}-- if 
($release_without_acquire);
         $self->_maintain_queue_buffers(undef,$entry,$columns,$values);
+        $context->log("NOTE: release._release_in_mem succeeded : 
subrequest_id[" . $entry->{subrequest_id} . "]\n");
     }
     else {
         $released = $self->_release_in_db($entry,$columns,$values);
-        $resource_counts->{total}{$resource_key}-- if 
(!$release_without_acquire);
+        $self->_release_resources($entry) if (!$release_without_acquire);
+        #$resource_counts->{total}{$resource_key}-- if 
(!$release_without_acquire);
+        $context->log("NOTE: release._release_in_db : subrequest_id[" . 
$entry->{subrequest_id} . "]\n");
     }
     $self->print() if ($self->{verbose});
     &App::sub_exit($released) if ($App::trace);