version 1.79, 2007/09/18 07:45:25 |
version 1.80, 2007/09/18 08:27:22 |
|
|
(void)fflush(stdout); |
(void)fflush(stdout); |
} |
} |
if (nLocal >= maxLocal && !(job->flags & JOB_SPECIAL)) { |
if (nLocal >= maxLocal && !(job->flags & JOB_SPECIAL)) { |
/* |
/* |
* Can't be exported and not allowed to run locally -- put |
* Can't be exported and not allowed to run locally -- |
* it back on the hold queue and mark the table full |
* put it back on the hold queue and mark the table |
*/ |
* full |
if (DEBUG(JOB)) { |
*/ |
(void)fprintf(stdout, "holding\n"); |
if (DEBUG(JOB)) { |
(void)fflush(stdout); |
(void)fprintf(stdout, "holding\n"); |
} |
(void)fflush(stdout); |
Lst_AtFront(&stoppedJobs, job); |
} |
jobFull = true; |
Lst_AtFront(&stoppedJobs, job); |
if (DEBUG(JOB)) { |
jobFull = true; |
(void)fprintf(stdout, "Job queue is full.\n"); |
if (DEBUG(JOB)) { |
(void)fflush(stdout); |
(void)fprintf(stdout, "Job queue is full.\n"); |
} |
(void)fflush(stdout); |
return; |
} |
|
return; |
} else { |
} else { |
/* |
/* |
* Job may be run locally. |
* Job may be run locally. |
*/ |
*/ |
if (DEBUG(JOB)) { |
if (DEBUG(JOB)) { |
(void)fprintf(stdout, "running locally\n"); |
(void)fprintf(stdout, "running locally\n"); |
(void)fflush(stdout); |
(void)fflush(stdout); |
} |
} |
} |
} |
JobExec(job, argv); |
JobExec(job, argv); |
} else { |
} else { |