[svn:p5ee] r10446 - in p5ee/trunk/App-WorkQueue/lib/App: . WorkQueue

Author: spadkins
Date: Thu Dec 20 13:22:01 2007
New Revision: 10446

Modified:
   p5ee/trunk/App-WorkQueue/lib/App/WorkQueue.pm
   p5ee/trunk/App-WorkQueue/lib/App/WorkQueue/Repository.pm

Log:
more logging

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	Thu Dec 20 13:22:01 2007
@[EMAIL PROTECTED]
 -1735,6 +1735,7 @[EMAIL PROTECTED]
 sub _maintain_queue_buffers {
     &App::sub_entry if ($App::trace);
     my ($self, $op, $entry, $columns, $values) = @[EMAIL PROTECTED]
    my $context = $self->{context};
 
     $op ||= "";
     my $BUFFER_SIZE = $self->{BUFFER_SIZE};
@[EMAIL PROTECTED]
 -1744,6 +1745,7 @[EMAIL PROTECTED]
         my $resource_counts = $self->_resource_counts();
 
         if ($op eq "push") {
+            $context->log("WQ: _maintain_queue_buffers : entry push
begin\n");
             $resource_counts->{total}{$resource_key}++;
             if ($resource_counts->{buffer}{$resource_key} < $BUFFER_SIZE)
{
                 $resource_counts->{buffer}{$resource_key}++;
@[EMAIL PROTECTED]
 -1752,35 +1754,48 @[EMAIL PROTECTED]
             else {
                 $self->_push_in_mem($entry,1); # release lowest
             }
+            $context->log("WQ: _maintain_queue_buffers : entry push
end\n");
         }
         elsif ($op eq "acquire") {
+            $context->log("WQ: _maintain_queue_buffers : entry acquire
begin\n");
             $resource_counts->{total}{$resource_key}--;
             $resource_counts->{buffer}{$resource_key}--;
+            $context->log("WQ: _maintain_queue_buffers : entry acquire
end\n");
         }
         elsif ($op eq "release") {
+            $context->log("WQ: _maintain_queue_buffers : entry release
begin\n");
             $self->_release_in_mem($entry, $columns, $values);
+            $context->log("WQ: _maintain_queue_buffers : entry release
end\n");
         }
         elsif ($op eq "unacquire") {
+            $context->log("WQ: _maintain_queue_buffers : entry unacquire
begin\n");
             $resource_counts->{total}{$resource_key}++;
             $resource_counts->{buffer}{$resource_key}++;
+            $context->log("WQ: _maintain_queue_buffers : entry unacquire
end\n");
         }
+        $context->log("WQ: _maintain_queue_buffers : entry call
_refill_buffer begin\n");
         my $num_total       = $resource_counts->{total}{$resource_key};
         my $num_in_buffer   = $resource_counts->{buffer}{$resource_key};
         if ($num_total > $num_in_buffer && $num_in_buffer < $BUFFER_SIZE)
{
             my $num_added = $self->_refill_buffer($resource_key);
             $resource_counts->{buffer}{$resource_key} += $num_added;
         }
+        $context->log("WQ: _maintain_queue_buffers : entry call
_refill_buffer end\n");
     }
     else {
+        $context->log("WQ: _maintain_queue_buffers : no entry foreach
resource_count key begin\n");
         my $resource_counts = $self->_resource_counts();
         foreach my $resource_key (keys %{$resource_counts->{total}}) {
+            $context->log("WQ: _maintain_queue_buffers : no entry
_refill_buffer begin\n");
             my $num_total       =
$resource_counts->{total}{$resource_key};
             my $num_in_buffer   =
$resource_counts->{buffer}{$resource_key};
             if ($num_total > $num_in_buffer && $num_in_buffer <
$BUFFER_SIZE) {
                 my $num_added = $self->_refill_buffer($resource_key);
                 $resource_counts->{buffer}{$resource_key} += $num_added;
             }
+            $context->log("WQ: _maintain_queue_buffers : no entry
_refill_buffer end\n");
         }
+        $context->log("WQ: _maintain_queue_buffers : no entry foreach
resource_count key end\n");
     }
 
     &App::sub_exit() if ($App::trace);

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	Thu Dec 20
13:22:01 2007
@[EMAIL PROTECTED]
 -103,7 +103,7 @[EMAIL PROTECTED]
     $context->log({level=>3},"[$self->{name}] _refresh_queue\n");
     $self->_refresh_status_counts();
     $self->_refresh_resource_counts();
-    $self->_maintain_queue_buffers();
+    #$self->_maintain_queue_buffers();
     &App::sub_exit() if ($App::trace);
 }