Lines Matching refs:con
43 switch (state.con[fd].type)
46 if (state.con[fd].info.user.running)
55 for (i = 0; i < elementsof(state.con[fd].info.user.fds); i++)
56 if ((n = state.con[fd].info.user.fds[i]) != fd && n >= 0 && state.con[n].type)
59 state.con[n].type = 0;
61 if (sp = state.con[fd].info.user.home)
63 if (state.con[fd].info.user.pump)
64 free(state.con[fd].info.user.pump);
65 if (state.con[fd].info.user.expr)
66 free(state.con[fd].info.user.expr);
69 if (tp = state.con[fd].info.pass.serialize)
71 state.con[fd].info.pass.serialize = 0;
72 cswrite(state.con[fd].info.pass.fd, sfstrbase(tp), sfstrtell(tp));
75 if ((jp = state.con[fd].info.pass.job) && jp->pid)
87 sp = state.con[fd].info.shell;
92 state.con[fd].type = 0;
93 state.con[fd].error = 0;
134 error(ERROR_OUTPUT|2, state.con[jp->fd].info.user.fds[2], "%s: job=%d pid=%d %s", sp->name, jp - state.job, jp->pid, state.migrate);
139 error(ERROR_OUTPUT|2, state.con[jp->fd].info.user.fds[2], "out of space");
146 error(ERROR_OUTPUT|2, state.con[jp->fd].info.user.fds[2], "%s: job=%d pid=%d stopped", sp->name, jp - state.job, jp->pid);
149 error(ERROR_OUTPUT|2, state.con[jp->fd].info.user.fds[2], "%s: job=%d pid=%d is a hog", sp->name, jp - state.job, jp->pid);
160 error(ERROR_OUTPUT|2, state.con[jp->fd].info.user.fds[2], "job %d pid %d restarted on %s", jp - state.job, jp->pid, sp->name);
163 error(ERROR_OUTPUT|2, state.con[jp->fd].info.user.fds[2], "job %d pid %d is no longer hogging %s", jp - state.job, jp->pid, sp->name);
172 if (state.running < (state.perserver + state.jobwait) && state.con[jp->fd].info.user.running < (state.peruser + 1) && (sp == &state.wait || sp->running < ((state.perhost ? state.perhost : sp->cpu * state.percpu) + 1)))
243 state.con[jp->fd].info.user.running--;
258 if (cswrite(state.con[jp->fd].info.user.fds[0], buf, n) != n)