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

[spadkins]

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
@@ -1735,6 +1735,7 @@
 sub _maintain_queue_buffers {
     &App::sub_entry if ($App::trace);
     my ($self, $op, $entry, $columns, $values) = @_;
+    my $context = $self->{context};
 
     $op ||= "";
     my $BUFFER_SIZE = $self->{BUFFER_SIZE};
@@ -1744,6 +1745,7 @@
         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}++;
@@ -1752,35 +1754,48 @@
             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
@@ -103,7 +103,7 @@
     $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);
 }