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
@[EMAIL PROTECTED]
-16,6 +16,9 @[EMAIL PROTECTED]
use App::Service;
@[EMAIL PROTECTED]
= ( "App::Service" );
+use Data::Dumper;
+$Data::Dumper::Terse = 1;
+
use strict;
my $verbose = $App::options{verbose};
@[EMAIL PROTECTED]
-497,9 +500,6 @[EMAIL PROTECTED]
}
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);
}
}
}
@[EMAIL PROTECTED]
-512,8 +512,12 @[EMAIL PROTECTED]
$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;
@[EMAIL PROTECTED]
-521,15 +525,14 @[EMAIL PROTECTED]
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
@[EMAIL PROTECTED]
-478,7 +478,7 @[EMAIL PROTECTED]
$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 {
|
