Searched defs:con (Results 1 - 13 of 13) sorted by relevance

/ast/src/cmd/cs/
H A Dcss.c76 register Connection_t* con; local
79 if (!(con = newof(0, Connection_t, 1, 0)))
81 fp->data = con;
82 con->id = *ip;
90 register Connection_t* con; local
99 if (con = (Connection_t*)fp->data)
101 if (con->service)
103 free(con);
107 con = (Connection_t*)fp->data;
110 if (con
177 Connection_t* con; local
[all...]
H A Dtst.c49 register Connection_t* con; local
54 if (!(con = newof(0, Connection_t, 1, 0)))
56 fp->data = con;
57 con->id = *ip;
58 con->args = 0;
67 con->args = strdup(sfstruse(sp));
76 register Connection_t* con; local
82 if (con = (Connection_t*)fp->data)
84 if (con->args)
85 free(con
[all...]
H A Dfs_env.c71 Connection_t con[1]; member in struct:__anon78
88 state->con[fd].state = CON;
103 state->con[fd].id = *id;
104 state->con[fd].state = CMD;
116 register Connection_t* con; local
130 con = state->con + fd;
131 message((-1, "fd=%d state=%s", fd, state_name[con->state]));
132 switch (con->state)
168 con
[all...]
H A Ddbm.c97 Con_t* con; /* connections */ member in struct:__anon76
111 if (!(state->con = newof(0, Con_t, state->conmax, 0)))
112 error(3, "out of space [con]");
132 cp = state->con + fd;
160 cp = state->con + fd;
H A Dmbb.c181 dump(Css_t* css, register Connection_t* con, int log, Cssdisc_t* disc) argument
188 n = state->logs[log].offset - con->blocked[log];
191 if (sfseek(state->logs[log].sp, con->blocked[log], SEEK_SET) != con->blocked[log])
192 error(ERROR_SYSTEM|3, "%s: cannot seek to %I*d", state->logs[log].name, sizeof(con->blocked[log]), con->blocked[log]);
193 message((-1, "[%d] %s reserve n %I*d offset %I*d", __LINE__, state->logs[log].name, sizeof(n), n, sizeof(con->blocked[log]), con->blocked[log]));
195 error(ERROR_SYSTEM|3, "%s: cannot reserve %d at %I*d", state->logs[log].name, sizeof(n), n, sizeof(con->blocked[log]), con
236 drop(Css_t* css, Connection_t* con, Cssdisc_t* disc) argument
261 register Connection_t* con; local
283 register Connection_t* con; local
[all...]
/ast/src/lib/libcs/
H A Dcsserve.c38 int (*con)(void*, int, Csid_t*, int, char**); member in struct:Server_s
49 return (*server->con)(server->handle, fp->fd, ip, 0, av) ? -1 : fp->fd;
141 csserve(Cs_t* state, void* handle, const char* path, void* (*init)(void*, int), int (*done)(void*, int), int (*con)(void*, int, Csid_t*, int, char**), int (*rd)(void*, int), int (*wr)(void*, int), int (*to)(void*)) argument
145 if (!con && !rd)
153 server->con = con;
154 if (server->con)
204 _cs_serve(void* handle, const char* path, void* (*init)(void*, int), int (*done)(void*, int), int (*con)(void*, int, Csid_t*, int, char**), int (*rd)(void*, int), int (*wr)(void*, int), int (*to)(void*)) argument
206 csserve(&cs, handle, path, init, done, con, rd, wr, to);
/ast/src/cmd/coshell/
H A Dshell.c206 Connection_t* con; local
223 con = state.con;
227 error(ERROR_OUTPUT|2, con[fd].info.user.fds[2], "invalid exec message");
238 if (state.running >= (state.perserver + state.jobwait) || con[fd].info.user.running >= state.peruser)
241 if (!jp) attributes(att, &attr, &con[fd].info.user.attr);
243 else if (!(sp = search((flags & CO_LOCAL) ? DEF|JOB : JOB, att, &attr, &con[fd].info.user.attr)))
245 if (s = con[fd].info.user.expr)
247 if (att) error(ERROR_OUTPUT|2, con[fd].info.user.fds[2], "%s && %s: invalid host", s, att);
248 else error(ERROR_OUTPUT|2, con[f
[all...]
H A Dcommand.c71 if (state.indirect.con)
74 fds[n].fd = state.indirect.con;
186 if (state.indirect.con)
368 register Connection_t* con; local
380 con = state.con;
392 error(ERROR_OUTPUT|2, con[fd].info.user.fds[2], "%s: invalid host name", s);
402 if (!(sp = search(GET, s, NiL, NiL))) error(ERROR_OUTPUT|2, con[fd].info.user.fds[2], "%s: not found", s);
403 else if (!sp->fd) error(ERROR_OUTPUT|2, con[fd].info.user.fds[2], "%s: host not open", s);
404 else shellclose(sp, con[f
[all...]
H A Devent.c260 log(State_t* state, Connection_t* con, int type, const char* format, ...) argument
274 sfprintf(state->logf, "%s (%03d) %c %s\n", fmttime("%K", time(NiL)), con ? con->fd : 0, type, s);
275 if (con && type != 'R' && type != 'S')
277 if (type != 'L' || !con->quiet)
280 con->code |= 1;
282 con->code |= 2;
295 register Connection_t* con; local
297 if (!(con = newof(0, Connection_t, 1, 0)))
299 fp->data = con;
347 post(State_t* state, Connection_t* con, const char* name, int id) argument
389 info(State_t* state, Connection_t* con, Css_t* css) argument
416 apply(State_t* state, Connection_t* con, int id, int index, datum key, datum val, Data_t* dat) argument
546 request(State_t* state, Connection_t* con, int id, int index, char** a, unsigned long older, unsigned long newer) argument
613 date(State_t* state, Connection_t* con, const char* s) argument
649 register Connection_t* con; local
959 Connection_t* con = (Connection_t*)obj; local
[all...]
H A Dservice.h38 int fd; /* con USER fd */ \
63 int fd; /* con SHELL fd */ \
271 int con; member in struct:__anon65
289 Connection_t* con; member in struct:__anon66
/ast/src/lib/libdss/
H A Ddsstags.c80 Cxconstraint_t* con; local
88 if (!(con = cxconstraint(NiL, data, state->disc)))
94 ((Cxvariable_t*)fp->prev->data)->format.constraint = con;
598 Cxconstraint_t* con; local
600 if (!(con = (Cxconstraint_t*)fp->prev->data) && !(fp->prev->data = con = newof(0, Cxconstraint_t, 1, 0)))
606 return con;
613 Cxconstraint_t* con; local
615 if (!(con = constraint_def(tag, fp, disc)))
617 if (con
635 Cxconstraint_t* con; local
652 Cxconstraint_t* con; local
674 Cxconstraint_t* con; local
700 Cxconstraint_t* con; local
726 Cxconstraint_t* con; local
[all...]
/ast/src/lib/libast/regex/
H A Dregcomp.c2868 con(Cenv_t* env) function
2877 if (!(f = con(env)))
2900 if (!(e = con(env)))
/ast/src/cmd/at/
H A Datd.c165 Connection_t con[1]; /* user connections */ member in struct:__anon39
170 Connection_t* con; member in struct:__anon41
484 register Connection_t* con = state->con + fp->fd; local
487 con->id = *id;
488 return con->fd = fp->fd;
739 Connection_t* con = ((Visit_t*)handle)->con; local
753 error(ERROR_OUTPUT|0, con->fd, "%-3s %5lu %3d %3d %3d %3d %3d %2d.%02d %5.5s%s", que->name, que->total, que->pending, que->running, que->nproc, que->peruser, que->nice, que->load / 100, que->load % 100, fmtelapsed(que->wait, 1), s);
781 command(register State_t* state, Connection_t* con, registe argument
1277 register Connection_t* con = state->con + fp->fd; local
[all...]

Completed in 34 milliseconds