version 1.19, 1999/12/18 21:56:07 |
version 1.20, 1999/12/18 21:58:07 |
|
|
ClientData gn; |
ClientData gn; |
{ |
{ |
cmd = (ClientData) Var_Subst((char *) cmd, (GNode *) gn, FALSE); |
cmd = (ClientData) Var_Subst((char *) cmd, (GNode *) gn, FALSE); |
(void) Lst_AtEnd(postCommands->commands, cmd); |
Lst_AtEnd(postCommands->commands, cmd); |
return(0); |
return(0); |
} |
} |
|
|
|
|
WSTOPSIG(*status)); |
WSTOPSIG(*status)); |
} |
} |
job->flags |= JOB_RESUME; |
job->flags |= JOB_RESUME; |
(void)Lst_AtEnd(stoppedJobs, (ClientData)job); |
Lst_AtEnd(stoppedJobs, (ClientData)job); |
#ifdef REMOTE |
#ifdef REMOTE |
if (job->flags & JOB_REMIGRATE) |
if (job->flags & JOB_REMIGRATE) |
JobRestart(job); |
JobRestart(job); |
|
|
* Now the job is actually running, add it to the table. |
* Now the job is actually running, add it to the table. |
*/ |
*/ |
nJobs += 1; |
nJobs += 1; |
(void) Lst_AtEnd(jobs, (ClientData)job); |
Lst_AtEnd(jobs, (ClientData)job); |
if (nJobs == maxJobs) { |
if (nJobs == maxJobs) { |
jobFull = TRUE; |
jobFull = TRUE; |
} |
} |
|
|
(void) fprintf(stdout, "*** holding\n"); |
(void) fprintf(stdout, "*** holding\n"); |
(void) fflush(stdout); |
(void) fflush(stdout); |
} |
} |
(void)Lst_AtFront(stoppedJobs, (ClientData)job); |
Lst_AtFront(stoppedJobs, (ClientData)job); |
jobFull = TRUE; |
jobFull = TRUE; |
if (DEBUG(JOB)) { |
if (DEBUG(JOB)) { |
(void) fprintf(stdout, "Job queue is full.\n"); |
(void) fprintf(stdout, "Job queue is full.\n"); |
|
|
} |
} |
#endif |
#endif |
|
|
(void)Lst_AtEnd(jobs, (ClientData)job); |
Lst_AtEnd(jobs, (ClientData)job); |
nJobs += 1; |
nJobs += 1; |
if (nJobs == maxJobs) { |
if (nJobs == maxJobs) { |
jobFull = TRUE; |
jobFull = TRUE; |
|
|
(void) fprintf(stdout, "holding\n"); |
(void) fprintf(stdout, "holding\n"); |
(void) fflush(stdout); |
(void) fflush(stdout); |
} |
} |
(void)Lst_AtFront(stoppedJobs, (ClientData)job); |
Lst_AtFront(stoppedJobs, (ClientData)job); |
jobFull = TRUE; |
jobFull = TRUE; |
if (DEBUG(JOB)) { |
if (DEBUG(JOB)) { |
(void) fprintf(stdout, "Job queue is full.\n"); |
(void) fprintf(stdout, "Job queue is full.\n"); |
|
|
(void) fprintf(stdout, "table full\n"); |
(void) fprintf(stdout, "table full\n"); |
(void) fflush(stdout); |
(void) fflush(stdout); |
} |
} |
(void) Lst_AtFront(stoppedJobs, (ClientData)job); |
Lst_AtFront(stoppedJobs, (ClientData)job); |
jobFull = TRUE; |
jobFull = TRUE; |
if (DEBUG(JOB)) { |
if (DEBUG(JOB)) { |
(void) fprintf(stdout, "Job queue is full.\n"); |
(void) fprintf(stdout, "Job queue is full.\n"); |
|
|
(void) fflush(stdout); |
(void) fflush(stdout); |
} |
} |
job->flags |= JOB_RESTART; |
job->flags |= JOB_RESTART; |
(void) Lst_AtEnd(stoppedJobs, (ClientData)job); |
Lst_AtEnd(stoppedJobs, (ClientData)job); |
} else { |
} else { |
if ((nLocal >= maxLocal) && local) { |
if ((nLocal >= maxLocal) && local) { |
/* |
/* |
|
|
} |
} |
} else { |
} else { |
job = (Job *) Lst_Datum(jnode); |
job = (Job *) Lst_Datum(jnode); |
(void) Lst_Remove(jobs, jnode); |
Lst_Remove(jobs, jnode); |
nJobs -= 1; |
nJobs -= 1; |
if (jobFull && DEBUG(JOB)) { |
if (jobFull && DEBUG(JOB)) { |
(void) fprintf(stdout, "Job queue is no longer full.\n"); |
(void) fprintf(stdout, "Job queue is no longer full.\n"); |