hwelte
/
mbuni
1
0
Fork 0
Code Releases Activity

*** empty log message ***

This commit is contained in:
bagyenda 2009-02-11 04:16:27 +00:00
parent b00dcbe383
commit c2887c0857
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
mbuni/extras/pgsql-queue/mms_pgsql_queue.c
View File

@ -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);