Lines Matching refs:user

40     "user. This server runs as a daemon on the user's home host, and only "
48 "[+?Job requests are accepted from user processes on the local host and "
52 "ENVIRONMENT) are set to match requesting user values. \bstdin\b is set "
226 * accept a new user connection
231 user(void* handle, int fd, Cs_id_t* id, int clone, char** argv)
240 state.con[fd].info.user.fds[0] = fd;
241 state.con[fd].info.user.fds[1] = -1;
242 state.con[fd].info.user.fds[2] = -1;
246 state.con[fd].info.user.flags = USER_IDENT;
247 state.con[fd].info.user.home = 0;
248 state.con[fd].info.user.pump = 0;
249 state.con[fd].info.user.expr = 0;
400 * <s> is the job exit code and user,sys times
410 jp->user += strelapsed(s, &t, CO_QUANT);
462 state.con[n].info.user.flags = 0;
469 state.con[n].info.user.flags = USER_IDENT;
470 state.con[n].info.user.home = 0;
471 state.con[n].info.user.pump = 0;
477 state.con[n].info.user.pid = id.pid;
478 for (i = 0; i < elementsof(state.con[n].info.user.fds); i++)
481 state.con[n].info.user.fds[i] = fds[i];
497 state.con[fd].info.user.attr.label[0] = 0;
524 state.con[fd].info.user.flags &= ~USER_IDENT;
526 state.con[fd].info.user.flags |= USER_DUP;
528 (state.con[fd].info.user.home = sp)->home++;
530 state.con[fd].info.user.pump = strdup(s + sizeof(CO_OPT_INDIRECT));
535 if (state.indirect.con && (state.con[fd].info.user.flags & (USER_IDENT|USER_INIT)) == USER_IDENT)
537 state.con[fd].info.user.flags |= USER_INIT;
540 if (x) state.con[fd].info.user.expr = strdup(x);
541 attributes(x, &state.con[fd].info.user.attr, NiL);
542 state.con[fd].info.user.attr.set &= ~SETLABEL;
545 if (!state.con[fd].info.user.pump ||
546 (state.con[fd].info.user.fds[1] = csopen(state.con[fd].info.user.pump, 0)) < 0 ||
547 cswrite(state.con[fd].info.user.fds[1], "#00001\n", 7) != 7)
554 nonblocking(state.con[fd].info.user.fds[1]);
555 state.con[state.con[fd].info.user.fds[1]].type = UOUT;
557 if (state.con[fd].info.user.flags & USER_DUP) state.con[fd].info.user.fds[2] = state.con[fd].info.user.fds[1];
558 else if ((state.con[fd].info.user.fds[2] = csopen(state.con[fd].info.user.pump, 0)) < 0 ||
559 cswrite(state.con[fd].info.user.fds[2], "#00002\n", 7) != 7)
564 else state.con[state.con[fd].info.user.fds[2]].type = UERR;
566 else if (!fstat(state.con[fd].info.user.fds[1], &st) && !fstat(state.con[fd].info.user.fds[2], &ts) && st.st_ino == ts.st_ino && st.st_dev == ts.st_dev)
568 drop(state.con[fd].info.user.fds[2]);
569 state.con[fd].info.user.fds[2] = state.con[fd].info.user.fds[1];
571 if (state.con[fd].info.user.flags & USER_IDENT)
578 if (cswrite(state.con[fd].info.user.fds[0], state.buf, i) != i)
584 state.con[fd].info.user.running = 0;
585 state.con[fd].info.user.total = 0;
620 if (*(s = state.con[jp->fd].info.user.attr.label))
673 if (!(state.home = state.con[fd].info.user.home))
705 error(ERROR_OUTPUT|2, state.con[fd].info.user.fds[2], "%c: unknown op", i);
712 cswrite(state.con[fd].info.user.fds[0], state.buf, n);
843 sfsprintf(s = state.buf, state.buflen, "%s/local/%s/user", t, CO_ID);
962 csserve(NiL, state.service, init, NiL, user, service, NiL, wakeup);