6 * Copyright (C) 1987 by the Massachusetts Institute of Technology
7 * For copying and distribution information, please see the file
13 static char *rcsid_sms_scall_c = "$Header$";
16 #include <mit-copyright.h>
20 #include "sms_server.h"
24 extern char *malloc();
27 extern void clist_delete(), do_auth(), do_shutdown();
31 * Welcome to the (finite state) machine (highest level).
38 if (OP_STATUS(cp->pending_op) == OP_CANCELLED) {
39 com_err(whoami, 0, "Closed connection (now %d client%s, %d new queries, %d old)",
50 /* Start recieving next request */
51 initialize_operation(cp->pending_op, sms_start_recv,
52 (char *)&cp->args, (int (*)())NULL);
53 queue_operation(cp->con, CON_INPUT, cp->pending_op);
54 cp->action = CL_RECEIVE;
57 /* Data is here. Process it & start it heading back */
58 do_call(cp); /* This may block for a while. */
59 sms_destroy_reply(cp->args);
61 initialize_operation(cp->pending_op, sms_start_send,
62 (char *)&cp->reply, (int (*)())NULL);
63 queue_operation(cp->con, CON_OUTPUT, cp->pending_op);
83 cl->reply.sms_argc = 0;
84 cl->reply.sms_status = 0;
85 cl->reply.sms_version_no = cl->args->sms_version_no;
86 if (((pn = cl->args->sms_procno) < 0) ||
87 (pn > SMS_MAX_PROC)) {
88 com_err(whoami, 0, "procno out of range");
89 cl->reply.sms_status = SMS_UNKNOWN_PROC;
92 if (log_flags & LOG_ARGS)
93 log_args(procnames[pn], cl->args->sms_version_no,
94 cl->args->sms_argc, cl->args->sms_argv);
95 else if (log_flags & LOG_REQUESTS)
96 com_err(whoami, 0, "%s", procnames[pn]);
100 cl->reply.sms_status = 0;
120 trigger_dcm(0, 0, cl);
128 register returned_tuples *temp;
129 for (temp=cp->first; temp && OP_DONE(temp->op); ) {
130 register returned_tuples *t1=temp;
132 if (t1 == cp->last) cp->last = NULL;
134 sms_destroy_reply(t1->retval);
137 register sms_params *p = t1->retval;
138 if (p->sms_flattened)
139 free(p->sms_flattened);
145 delete_operation(t1->op);
151 retr_callback(argc, argv, p_cp)
153 register char **argv;
156 register client *cp = (client *)p_cp;
158 * This takes too much advantage of the fact that
159 * serialization of the data happens during the queue operation.
161 sms_params *arg_tmp = (sms_params *)db_alloc(sizeof(sms_params));
162 returned_tuples *tp = (returned_tuples *)
163 db_alloc(sizeof(returned_tuples));
164 register char **nargv = (char **)malloc(argc * sizeof(char *));
167 OPERATION op_tmp = create_operation();
169 if (sms_trim_args(argc, argv) == SMS_NO_MEM) {
170 com_err(whoami, SMS_NO_MEM, "while trimming args");
172 if (log_flags & LOG_RESP)
173 log_args("return: ", cp->args->sms_version_no, argc, argv);
176 tp->retval = arg_tmp;
179 arg_tmp->sms_status = SMS_MORE_DATA;
180 arg_tmp->sms_version_no = cp->args->sms_version_no;
181 arg_tmp->sms_argc = argc;
182 arg_tmp->sms_argv = nargv;
183 for (i = 0; i < argc; i++) {
184 register int len = strlen(argv[i]) + 1;
185 nargv[i] = malloc(len);
186 bcopy(argv[i], nargv[i], len);
188 arg_tmp->sms_flattened = (char *)NULL;
189 arg_tmp->sms_argl = (int *)NULL;
195 cp->last = cp->first = tp;
198 reset_operation(op_tmp);
199 initialize_operation(op_tmp, sms_start_send, (char *)arg_tmp,
201 queue_operation(cp->con, CON_OUTPUT, op_tmp);
204 list_users(callbk, callarg)
212 extern client **clients;
213 extern char *inet_ntoa();
218 for (i = 0; i < nclients; i++) {
219 register client *cl = clients[i];
221 argv[0] = cl->clname;
222 else argv[0] = "unauthenticated";
224 argv[1] = inet_ntoa(cl->haddr.sin_addr);
226 sprintf(buf, "port %d", ntohs(cl->haddr.sin_port));
227 argv[3] = ctime(&cl->last_time_used);
228 cp = index(argv[3], '\n');
231 sprintf(buf1, "[#%d]", cl->id);
232 (*callbk)(5, argv, callarg);
240 register char *queryname;
242 cl->reply.sms_argc = 0;
243 cl->reply.sms_status = 0;
245 queryname = cl->args->sms_argv[0];
247 if (cl->args->sms_version_no == SMS_VERSION_2)
252 if (strcmp(queryname, "_list_users") == 0)
253 cl->reply.sms_status = list_users(retr_callback, (char *)cl);
255 cl->reply.sms_status =
256 sms_process_query(cl,
257 cl->args->sms_argv[0],
258 cl->args->sms_argc-1,
259 cl->args->sms_argv+1,
263 if (log_flags & LOG_RES)
264 com_err(whoami, 0, "Query complete.");
270 cl->reply.sms_argc = 0;
272 cl->reply.sms_status =
274 cl->args->sms_argv[0],
275 cl->args->sms_argc-1,
276 cl->args->sms_argv+1);
278 com_err(whoami, 0, "Access check complete.");
282 /* trigger_dcm is also used as a followup routine to the
283 * set_server_host_override query, hence the two dummy arguments.
286 struct query pseudo_query = {
291 trigger_dcm(dummy0, dummy1, cl)
297 cl->reply.sms_argc = 0;
299 if (cl->reply.sms_status = check_query_access(&pseudo_query, 0, cl) )
300 return(cl->reply.sms_status);
305 execl("/u1/sms/bin/startdcm", "startdcm", 0);
309 cl->reply.sms_status = errno;