From c2887c085767e977b7b8fbc941dad36bb9abdd14 Mon Sep 17 00:00:00 2001
From: bagyenda <>
Date: Wed, 11 Feb 2009 04:16:27 +0000
Subject: [PATCH] *** empty log message ***

---
 mbuni/extras/pgsql-queue/mms_pgsql_queue.c | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/mbuni/extras/pgsql-queue/mms_pgsql_queue.c b/mbuni/extras/pgsql-queue/mms_pgsql_queue.c
index 1612838..7b2cbbd 100644
--- a/mbuni/extras/pgsql-queue/mms_pgsql_queue.c
+++ b/mbuni/extras/pgsql-queue/mms_pgsql_queue.c
@@ -1151,8 +1151,12 @@ static void pgq_queue_run(char *dir,
 	  if (*rstop)
 	       break;
 	  gwthread_sleep(sleepsecs);
-	  if  (gwlist_len(items_list) > MAX_QLEN * num_threads)
+	  if  (gwlist_len(items_list) > MAX_QLEN * num_threads) {
+	       mms_warning(0,  "pgsql_queue", NULL, 
+			   "Queue [%s] large [%d entries]. Will wait a little to see if it clears",
+			   dir, (int)gwlist_len(items_list));
 	       goto l1; /* don't allow too many pending requests in the waiting queue. */
+	  }
      } while (1);
      
      mms_info(0,  "pgsql_queue", NULL, "Queue runner on [%s] shutdown, started...", dir);