/ast/src/lib/libcs/ |
H A D | cspipe.c | 34 csprotect(&cs); 51 return cspipe(&cs, fds);
|
H A D | csdata.c | 24 * cs library data 33 Cs_t cs = { "libcs:cs", &disc }; variable
|
H A D | csfree.c | 25 * free cs state context 33 if (!state || state == &cs)
|
H A D | msgread.c | 28 #include <cs.h> 42 if ((n = cspeek(&cs, fd, buf, MSG_SIZE_SIZE)) >= 0) o = 0; 45 n = csread(&cs, fd, buf, MSG_SIZE_SIZE, CS_EXACT); 50 if (n <= MSG_SIZE_SIZE || n > siz || csread(&cs, fd, buf + o, n - o, CS_EXACT) != n - o) return -1;
|
H A D | csalloc.c | 25 * allocate cs state context 37 state->id = cs.id; 38 state->disc = disc ? disc : cs.disc;
|
H A D | cscontrol.c | 50 return cscontrol(&cs, fd);
|
H A D | csfull.c | 45 return csfull(&cs, addr);
|
H A D | csntoa.c | 52 return csntoa(&cs, addr);
|
H A D | csping.c | 50 return csping(&cs, name);
|
H A D | csvar.c | 25 * run time cs var support 44 { /* CS_VAR_LOCAL */ "CS_MOUNT_LOCAL", "/tmp/cs" }, 46 { /* CS_VAR_SHARE */ "CS_MOUNT_SHARE", "share/lib/cs" }, 70 return csvar(&cs, index, trust);
|
H A D | SERVICE.mk | 12 SERVICEDIR = $(LIBDIR)/cs
|
H A D | csclient.c | 61 csclient(Cs_t* cs, int fd, const char* service, const char* prompt, char** argv, unsigned int flags) argument 74 if (fd < 0 && (fd = csopen(cs, service, CS_OPEN_TEST)) < 0) 114 while (cspoll(cs, fds, elementsof(fds), timeout) > 0) 200 return csclient(&cs, fd, service, prompt, argv, flags);
|
H A D | cswrite.c | 55 return cswrite(&cs, fd, buf, n);
|
/ast/src/lib/libcoshell/ |
H A D | coclose.c | 48 register Coshell_t* cs; local 81 cs = state.coshells; 83 while (cs) 85 if (cs == co) 87 cs = cs->next; 89 ps->next = cs; 91 state.coshells = cs; 95 ps = cs; 96 cs [all...] |
H A D | coexec.c | 34 service(register Coshell_t* co, Coservice_t* cs, Cojob_t* cj, int flags, Sfio_t* sp) argument 47 for (a = cs->argv; *a; a++) 51 errormsg(state.lib, ERROR_LIBRARY|2, "service %s:%s", cs->path, s); 55 errormsg(state.lib, ERROR_LIBRARY|ERROR_SYSTEM|2, "%s: cannot allocate service pipe", cs->name); 65 cs->fd = fds[1]; 70 if (!(proc = procopen(cs->path, cs->argv, NiL, ops, PROC_DAEMON|PROC_IGNORE))) 72 errormsg(state.lib, ERROR_LIBRARY|ERROR_SYSTEM|2, "%s: cannot connect to %s service", cs->path, cs->name); 77 fcntl(cs 106 request(register Coshell_t* co, Cojob_t* cj, Coservice_t* cs, const char* action, int flags) argument 153 register Coservice_t* cs; local [all...] |
H A D | coopen.c | 98 Coservice_t* cs; local 108 if (((Namval_t*)p)->value == CO_SERVICE && v && (cs = vmnewof(co->vm, 0, Coservice_t, 1, 2 * strlen(v)))) 110 a = cs->argv; 111 *a++ = s = cs->path = cs->name = (char*)(cs + 1); 123 cs->path = s + 8; 125 cs->db = s + 6; 127 cs->db = s + 3; 128 else if (a < &cs [all...] |
H A D | cowait.c | 133 register Coservice_t* cs; local 195 for (cs = co->service; cs; cs = cs->next) 196 if (cs->pid && kill(cs->pid, 0)) 198 cs->pid = 0; 199 close(cs->fd); 200 cs [all...] |
/ast/src/lib/libvcodex/Vchuff/ |
H A D | vchcode.c | 94 reg ssize_t n, k, nl, cs; local 104 cs = maxs+2; 105 cs = cs < 2 ? 1 : cs < 4 ? 2 : cs < 8 ? 3 : cs < 16 ? 4 : cs < 32 ? 5 : 6; 118 { if((n + cs) > VC_BITSIZE) 120 vcioaddb(&io, b, n, (((Vcbit_t)len[k]) << (VC_BITSIZE-cs)), c 139 ssize_t i, n, k, nl, cs; local [all...] |
/ast/src/cmd/3d/ |
H A D | peek.c | 26 #include <cs.h> 38 n = cspeek(&cs, fd, buf, siz); 41 cspeek(&cs, -1, NiL, 0);
|
H A D | license.c | 49 if ((fd = cslocal(&cs, service)) < 0) 56 if (cswrite(&cs, fd, svc, n) != n) 68 if (csrecv(&cs, fd, NiL, &lic, 1) != 1) 75 if (cswrite(&cs, lic, msg, len) != len)
|
/ast/src/cmd/cs/vcs_src/ |
H A D | mnt_imount.h | 21 #include <cs.h>
|
/ast/src/cmd/tests/vmalloc/ |
H A D | talign.c | 25 static Void_t* alignmem(Vmalloc_t* vm, Void_t* ca, size_t cs, size_t ns, Vmdisc_t* dc) argument 27 static Void_t* alignmem(vm, ca, cs, ns, dc) 30 size_t cs;
|
/ast/src/cmd/cs/ |
H A D | cs.c | 25 * cs - connect stream control 29 "[-?\n@(#)$Id: cs (AT&T Research) 2006-06-11 $\n]" 31 "[+NAME?cs - connect stream control]" 86 " \b../share/lib/cs/local\b on \b$PATH\b. Each line in the \blocal\b" 108 " [+../share/lib/cs/local?Local host info list on \b$PATH\b.]" 117 #include <cs.h> 154 , cs.host 155 , cs.user 156 , (cs.flags & CS_ADDR_LOCAL) ? "LOCAL:" : "" 157 , (cs [all...] |
/ast/src/cmd/coshell/ |
H A D | job.c | 80 jp->lost = cs.time + UPDATE; 115 if (sp->update <= cs.time && sp->errors < ERRORS) update(sp); 116 if (jp->lost && jp->lost < cs.time) 127 if (!jp->busy && state.grace) jp->busy = cs.time + state.grace; 128 else if (jp->busy < cs.time) 175 else if (cs.time > jp->start + LOST) 177 message((-4, "jobcheck: %s: possibly hung %s", sp->name, fmtelapsed(cs.time - sp->start, 1))); 235 state.real += cs.time - state.clock; 249 jp->shell->update = cs.time + state.disable;
|
H A D | shell.c | 114 sp->start = cs.time; 115 if (sp->update > cs.time + UPDATE) 116 sp->update = cs.time + UPDATE; 121 sp->override = cs.time + (sp->home ? HOME : OVERRIDE); 164 sp->stat.up = sp->start - cs.time; 165 sp->update = cs.time + FORGET; 192 sp->start = cs.time; 236 if (cs.time > state.access) info(SET, NiL); 290 state.clock = cs.time; 302 jp->start = cs [all...] |