Restore win32 dir from Branch-5.2 and update it

[bacula/bacula] / bacula / src / dird / jobq.c

diff --git a/bacula/src/dird/jobq.c b/bacula/src/dird/jobq.c
index 6363d9a98d3719a89ff9e25558d6bd14e2cdad42..4ba28a5f7921028c29c730c5330107f20424a681 100644 (file)
--- a/bacula/src/dird/jobq.c
+++ b/bacula/src/dird/jobq.c
@@ -864,10 +864,13 @@ bool inc_read_store(JCR *jcr)
    P(rstore_mutex);
    int num = jcr->rstore->getNumConcurrentJobs();
    int numread = jcr->rstore->getNumConcurrentReadJobs();
+   int maxread = jcr->rstore->MaxConcurrentReadJobs;
    if (num < jcr->rstore->MaxConcurrentJobs &&
        (jcr->getJobType() == JT_RESTORE ||
-        numread == 0 ||
-        numread < jcr->rstore->MaxConcurrentReadJobs)) {
+        numread == 0     ||
+        maxread == 0     ||     /* No limit set */
+        numread < maxread))     /* Below the limit */
+   {
       num++;
       numread++;
       jcr->rstore->setNumConcurrentReadJobs(numread);