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);
 }
 

Reply via email to