Author: spadkins
Date: Wed Nov 14 12:19:42 2007
New Revision: 10249
Modified:
p5ee/trunk/App-WorkQueue/lib/App/WorkQueue.pm
p5ee/trunk/App-WorkQueue/lib/App/WorkQueue/Repository.pm
Log:
more logging, this time for our acquire bug
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 Wed Nov 14 12:19:42 2007
@@ -890,6 +890,9 @@
&App::sub_entry if ($App::trace);
my ($self, $entry, $columns, $values, $one_way, $raw) = @_;
+ my $context = $self->{context};
+ $context->log("NOTE: _update_ref : subrequest_id[" .
$entry->{subrequest_id} . "]\n");
+
my $status_attrib = $self->{status_attrib};
if ($self->{type} eq "ARRAY") {
my $colidx = $self->_colidx();
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 Wed Nov 14
12:19:42 2007
@@ -504,6 +504,10 @@
CORE::push(@$values, $self->{client_id});
}
$acquired = $db->update($self->{table}, $params, $columns, $values);
+ if ($acquired) {
+ my $context = $self->{context};
+ $context->log("NOTE: _acquire_entry : subrequest_id[" .
$entry->{subrequest_id} . "]\n");
+ }
$self->_update_ref($entry, $columns, $values) if ($acquired);
}
else {
