From: Mike Rylander <mrylander@gmail.com>
Date: Tue, 24 Oct 2017 20:45:09 +0000 (-0400)
Subject: LP#1729610: Add some debug/internal logging to backlog queue
X-Git-Tag: osrf_rel_3_1_0-beta~7
X-Git-Url: http://git.equinoxoli.org/?p=opensrf-equinox.git;a=commitdiff_plain;h=a9da9c7b25ef90276d41ba84ba8ccf0ea856da1b

LP#1729610: Add some debug/internal logging to backlog queue

Signed-off-by: Mike Rylander <mrylander@gmail.com>
Signed-off-by: Galen Charlton <gmc@equinoxinitiative.org>
Signed-off-by: Bill Erickson <berickxx@gmail.com>
Signed-off-by: Mike Rylander <mrylander@gmail.com>
---

diff --git a/src/perl/lib/OpenSRF/Server.pm b/src/perl/lib/OpenSRF/Server.pm
index 0eaac40..0d31fcf 100644
--- a/src/perl/lib/OpenSRF/Server.pm
+++ b/src/perl/lib/OpenSRF/Server.pm
@@ -169,6 +169,9 @@ sub run {
         $from_network = $wait_time = -1 if (!$msg);
         $msg ||= $self->{osrf_handle}->process($wait_time);
 
+        !$from_network and $chatty and $logger->debug("server: attempting to process previously queued message");
+        $from_network and $chatty and $logger->internal("server: no queued messages, processing due to network or signal");
+
         # we woke up for any reason, reset the wait time to allow
         # for idle maintenance as necessary
         $wait_time = 1;
@@ -198,11 +201,15 @@ sub run {
                     "in the OpenSRF configuration if this message occurs frequently");
 
                 if ($from_network) {
+                    $chatty and $logger->debug("server: queuing new message");
                     push @max_children_msg_queue, $msg;
                 } else {
+                    $chatty and $logger->debug("server: re-queuing old message");
                     unshift @max_children_msg_queue, $msg;
                 }
 
+                $logger->warn("server: backlog queue size is now ". scalar(@max_children_msg_queue));
+
                 if (@max_children_msg_queue < $self->{max_backlog_queue}) {
                     # We still have room on the queue. Set the wait time to
                     # 1s, waiting for a drone to be freed up and reprocess