Lines Matching refs:coshell

42 #define RUNNING		005		/* job action sent to coshell	*/
79 Cojob_t* cojob; /* coshell job info */
627 * send a job to the coshell for execution
682 if (!state.coshell)
696 if (!(state.coshell = coopen(getval(CO_ENV_SHELL, VAL_PRIMARY), flags, sfstruse(sp))))
697 error(ERROR_SYSTEM|3, "coshell open error");
710 coexport(state.coshell, p->rule->name, sfstruse(exp));
716 coexport(state.coshell, p->rule->name, sfstruse(exp));
760 if (!(job->cojob = coexec(state.coshell, t, job->flags, state.tmpfile, NiL, sfstruse(att))))
761 error(3, "%s: cannot send action to coshell", job->target->name);
924 return !state.coshell || cojobs(state.coshell) < state.jobs;
1031 else if (!state.coshell || cojobs(state.coshell) < state.jobs)
1043 cokill(state.coshell, job->cojob, 0);
1116 if (!state.coshell || !copending(state.coshell))
1162 if ((cojob = cowait(state.coshell, check ? (Cojob_t*)state.coshell : (Cojob_t*)0, -1)) && (job = (Joblist_t*)cojob->local))
1219 if (!copending(state.coshell))
1225 error(3, "lost contact with coshell");
1328 if (state.coshell && cokill(state.coshell, NiL, SIGTERM))
1329 error(2, "coshell job kill error");
1333 * complete all jobs and drop the coshell
1339 if (state.coshell)
1342 message((-1, "jobs %d user %s sys %s", state.coshell->total, fmtelapsed(state.coshell->user, CO_QUANT), fmtelapsed(state.coshell->sys, CO_QUANT)));
1343 coclose(state.coshell);
1344 state.coshell = 0;
1395 if (state.coshell && (action && !(r->property & P_make) || (flags & CO_FOREGROUND)))
1402 while ((cozombie(state.coshell) || cojobs(state.coshell) > n) && block(0));
1647 return state.coshell ? cosync(state.coshell, file, fd, mode) : 0;
1664 if (state.coshell && error_info.trace <= level)
1692 sfprintf(sfstderr, "JOB STATUS TARGET tot=%d pend=%d done=%d\n", state.coshell->total, copending(state.coshell), cozombie(state.coshell));