Author: spadkins
Date: Wed Dec 12 11:49:59 2007
New Revision: 10420
Modified:
p5ee/trunk/App-WorkQueue/lib/App/WorkQueue/Repository.pm
Log:
added trigger_event_loop_extension call to push, release, and unacquire
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 Dec 12
11:49:59 2007
@@ -214,6 +214,7 @@
$self->_update_ref($entry, $columns, $values, 1);
$self->_maintain_queue_buffers("push",$entry);
$self->print() if ($self->{verbose});
+ $self->{context}->trigger_event_loop_extension();
&App::sub_exit() if ($App::trace);
}
@@ -335,6 +336,7 @@
#$resource_counts->{total}{$resource_key}-- if
(!$release_without_acquire);
}
$self->print() if ($self->{verbose});
+ $self->{context}->trigger_event_loop_extension();
&App::sub_exit($released) if ($App::trace);
return($released);
}
@@ -422,6 +424,7 @@
my ($self, $entry) = @_;
$self->_unacquire_in_mem($entry);
$self->_maintain_queue_buffers("unacquire",$entry);
+ $self->{context}->trigger_event_loop_extension();
&App::sub_exit() if ($App::trace);
}