Author: spadkins
Date: Mon Mar 10 06:05:05 2008
New Revision: 10900
Modified:
p5ee/trunk/App-WorkQueue/lib/App/WorkQueue.pm
p5ee/trunk/App-WorkQueue/lib/App/WorkQueue/Repository.pm
Log:
changes to the debugging when acquisition fails
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 Mon Mar 10 06:05:05 2008
@@ -16,6 +16,9 @@
use App::Service;
@ISA = ( "App::Service" );
+use Data::Dumper;
+$Data::Dumper::Terse = 1;
+
use strict;
my $verbose = $App::options{verbose};
@@ -497,9 +500,6 @@
}
else {
$self->_release_resources($entry);
- # the following line appears to have been a bug.
- #$self->_maintain_queue_buffers("release",$entry);
- #$self->_maintain_queue_buffers("unacquire",$entry);
}
}
}
@@ -512,8 +512,12 @@
$context->log({level=>1}, "$self->{name} : Empty entry
[$e]\n");
}
elsif ($self->_acquire_resources($e)) {
+ my $dump_entry = "";
+ $dump_entry .= "e (pristine) : " . Dumper($e);
$entry = $e;
$acquired = $self->_acquire_entry($entry);
+ $dump_entry .= "entry (after _acquire_entry) : " .
Dumper($entry);
+ $dump_entry .= "acquired[$acquired]\n";
if ($acquired) {
$context->log({level=>3}, "$self->{name} :
Acquired[M]: [" . join("|", $e->{shop_request_id}, $e->{subrequest_id}). "]\n");
last;
@@ -521,15 +525,14 @@
else {
### THIS SHOULD NEVER HAPPEN, SOMEDAY FIGURE OUT WHY
$self->_release_resources($entry);
+ $dump_entry .= "entry (after _release_resources) : " .
Dumper($entry);
if ($self->can("_db")) {
### TODO: this is a debugging hack that shouldn't
stay in it
my $db = $self->_db();
- $context->log({level=>1}, "$self->{name} :
Acquisition failed : [$entry->{shop_request_id}|$entry->{subrequest_id}] : last
sql stmt[$db->{sql}]\n");
+ $dump_entry .= "last sql stmt[$db->{sql}]\n";
+ $context->log({level=>1}, "$self->{name} :
Acquisition failed : $dump_entry\n");
}
$entry = undef;
- # the following line appears to have been a bug
- #$self->_maintain_queue_buffers("release",$entry);
- #$self->_maintain_queue_buffers("unacquire",$entry);
}
}
}
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 Mar 10
06:05:05 2008
@@ -478,7 +478,7 @@
$self->_update_ref($entry, $columns, $values) if ($acquired);
if (!$acquired) {
my $context = $self->{context};
- $context->log({level=>1},"$self->{name} : Acquire fail: last
SQL[$db->{sql}]\n");
+ $context->log({level=>3},"$self->{name} : Acquire fail: last
SQL[$db->{sql}]\n");
}
}
else {
