[svn:p5ee] r10579 - in p5ee/trunk/App-WorkQueue/lib/App: . WorkQueue

Author: spadkins
Date: Thu Jan 17 07:36:38 2008
New Revision: 10579

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

Log:
added some logging messages to track down why some subrequests run with a status of W instead of R

Modified: p5ee/trunk/App-WorkQueue/lib/App/WorkQueue.pm
==============================================================================
--- p5ee/trunk/App-WorkQueue/lib/App/WorkQueue.pm	(original)
+++ p5ee/trunk/App-WorkQueue/lib/App/WorkQueue.pm	Thu Jan 17 07:36:38 2008
@@ -641,14 +641,13 @@
         for ($e = 0; $e <= $#$data; $e++) {
             $ent = $data->[$e];
             if ($self->_hash_to_key($ent) eq $entry_key) {
-                ### TODO: Rare occasions we get here, and have not called _release_resources, why?
                 if ($ent->{$status_attrib} eq $STATUS_ACQUIRED) {
                     $self->_release_resources($ent);
                 }
                 else {
                     ### We only expect to get here via cancels, so we don't want to release_resources
                     #$self->_release_resources($ent);
-                    $context->log("WorkQueue: _release_in_mem: release with $ent->{$status_attrib} not equal $STATUS_ACQUIRED\n");
+                    $context->log("WQ: _release_in_mem: release with $ent->{$status_attrib} not equal $STATUS_ACQUIRED : actual/group data_source[$entry->{actual_data_source}/$entry->{group_data_source}]\n");
                 }
                 my $released = $self->update($ent,\@columns,\@values);
                 if (!$released) {

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	Thu Jan 17 07:36:38 2008
@@ -476,6 +476,10 @@
         #}
         $acquired = $db->update($self->{table}, $params, $columns, $values);
         $self->_update_ref($entry, $columns, $values) if ($acquired);
+        if (!$acquired) {
+            my $context = $self->{context};
+            $context->log("WQR: _acquire_entry: ACQUIRE FAIL: last SQL[$db->{sql}]\n");
+        }
     }
     else {
         ### THIS SHOULD NEVER HAPPEN