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,[EMAIL PROTECTED],[EMAIL
PROTECTED]);
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
