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
@[EMAIL PROTECTED]
-890,6 +890,9 @[EMAIL PROTECTED]
&App::sub_entry if ($App::trace);
my ($self, $entry, $columns, $values, $one_way, $raw) = @[EMAIL PROTECTED]
+ 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
@[EMAIL PROTECTED]
-504,6 +504,10 @[EMAIL PROTECTED]
CORE::push(@[EMAIL PROTECTED]
$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 {
|
