From a9da9c7b25ef90276d41ba84ba8ccf0ea856da1b Mon Sep 17 00:00:00 2001 From: Mike Rylander Date: Tue, 24 Oct 2017 16:45:09 -0400 Subject: [PATCH] LP#1729610: Add some debug/internal logging to backlog queue Signed-off-by: Mike Rylander Signed-off-by: Galen Charlton Signed-off-by: Bill Erickson Signed-off-by: Mike Rylander --- src/perl/lib/OpenSRF/Server.pm | 7 +++++++ 1 file changed, 7 insertions(+) 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 -- 2.43.2