6 * Copyright (C) 1987 by the Massachusetts Institute of Technology
9 * Revision 1.11 1987-08-19 22:03:52 wesommer
10 * Added the trigger_dcm function, which fires off a DCM to do the
13 * Revision 1.10 87/08/19 18:39:04 wesommer
14 * Added list_users query.
16 * Revision 1.9 87/08/04 02:41:22 wesommer
19 * Revision 1.8 87/07/16 15:43:19 wesommer
20 * Fixed bug where the argv was not copied to private storage
21 * (it got changed out from under us before it got sent..).
23 * Revision 1.7 87/07/14 00:39:01 wesommer
26 * Revision 1.6 87/06/30 20:04:43 wesommer
27 * Free returned tuples when possible.
29 * Revision 1.5 87/06/26 10:55:53 wesommer
30 * Added sms_access, now paiys attention to return code from
31 * sms_process_query, sms_check_access.
33 * Revision 1.4 87/06/21 16:42:00 wesommer
34 * Performance work, rearrangement of include files.
36 * Revision 1.3 87/06/04 01:35:01 wesommer
37 * Added a working query request handler.
39 * Revision 1.2 87/06/03 16:07:50 wesommer
42 * Revision 1.1 87/06/02 20:07:10 wesommer
48 static char *rcsid_sms_scall_c = "$Header$";
54 #include "sms_server.h"
58 extern char *malloc();
61 extern void clist_delete(), do_auth(), do_shutdown();
65 * Welcome to the (finite state) machine (highest level).
72 if (OP_STATUS(cp->pending_op) == OP_CANCELLED) {
73 com_err(whoami, 0, "Closed connection (now %d client%s)",
82 /* Start recieving next request */
83 initialize_operation(cp->pending_op, sms_start_recv,
84 (char *)&cp->args, (int (*)())NULL);
85 queue_operation(cp->con, CON_INPUT, cp->pending_op);
86 cp->action = CL_RECEIVE;
89 /* Data is here. Process it & start it heading back */
90 do_call(cp); /* This may block for a while. */
91 sms_destroy_reply(cp->args);
93 initialize_operation(cp->pending_op, sms_start_send,
94 (char *)&cp->reply, (int (*)())NULL);
95 queue_operation(cp->con, CON_OUTPUT, cp->pending_op);
101 char *procnames[] = {
115 cl->reply.sms_argc = 0;
116 cl->reply.sms_status = 0;
117 if (((pn = cl->args->sms_procno) < 0) ||
118 (pn > SMS_MAX_PROC)) {
119 com_err(whoami, 0, "procno out of range");
120 cl->reply.sms_status = SMS_UNKNOWN_PROC;
123 if (log_flags & LOG_ARGS)
124 log_args(procnames[pn], cl->args->sms_argc,
126 else if (log_flags & LOG_REQUESTS)
127 com_err(whoami, 0, "%s", procnames[pn]);
131 cl->reply.sms_status = 0;
159 register returned_tuples *temp;
160 for (temp=cp->first; temp && OP_DONE(temp->op); ) {
161 register returned_tuples *t1=temp;
163 if (t1 == cp->last) cp->last = NULL;
165 sms_destroy_reply(t1->retval);
168 register sms_params *p = t1->retval;
169 if (p->sms_flattened)
170 free(p->sms_flattened);
176 delete_operation(t1->op);
182 retr_callback(argc, argv, p_cp)
184 register char **argv;
187 register client *cp = (client *)p_cp;
189 * This takes too much advantage of the fact that
190 * serialization of the data happens during the queue operation.
192 sms_params *arg_tmp = (sms_params *)db_alloc(sizeof(sms_params));
193 returned_tuples *tp = (returned_tuples *)
194 db_alloc(sizeof(returned_tuples));
195 register char **nargv = (char **)malloc(argc * sizeof(char *));
198 OPERATION op_tmp = create_operation();
200 if (log_flags & LOG_RESP)
201 log_args("return: ", argc, argv);
204 tp->retval = arg_tmp;
207 arg_tmp->sms_status = SMS_MORE_DATA;
208 arg_tmp->sms_argc = argc;
209 arg_tmp->sms_argv = nargv;
210 for (i = 0; i < argc; i++) {
211 register int len = strlen(argv[i]) + 1;
212 nargv[i] = malloc(len);
213 bcopy(argv[i], nargv[i], len);
215 arg_tmp->sms_flattened = (char *)NULL;
216 arg_tmp->sms_argl = (int *)NULL;
222 cp->last = cp->first = tp;
225 reset_operation(op_tmp);
226 initialize_operation(op_tmp, sms_start_send, (char *)arg_tmp,
228 queue_operation(cp->con, CON_OUTPUT, op_tmp);
231 list_users(callbk, callarg)
239 extern client **clients;
240 extern char *inet_ntoa();
245 for (i = 0; i < nclients; i++) {
246 register client *cl = clients[i];
248 argv[0] = cl->clname;
249 else argv[0] = "unauthenticated";
251 argv[1] = inet_ntoa(cl->haddr.sin_addr);
253 sprintf(buf, "port %d", ntohs(cl->haddr.sin_port));
254 argv[3] = ctime(&cl->last_time_used);
255 cp = index(argv[3], '\n');
258 sprintf(buf1, "[#%d]", cl->id);
259 (*callbk)(5, argv, callarg);
267 register char *queryname;
269 cl->reply.sms_argc = 0;
270 cl->reply.sms_status = 0;
272 queryname = cl->args->sms_argv[0];
274 if (strcmp(queryname, "_list_users") == 0)
275 cl->reply.sms_status = list_users(retr_callback, (char *)cl);
277 cl->reply.sms_status =
278 sms_process_query(cl,
279 cl->args->sms_argv[0],
280 cl->args->sms_argc-1,
281 cl->args->sms_argv+1,
285 if (log_flags & LOG_RES)
286 com_err(whoami, 0, "Query complete.");
292 cl->reply.sms_argc = 0;
294 cl->reply.sms_status =
296 cl->args->sms_argv[0],
297 cl->args->sms_argc-1,
298 cl->args->sms_argv+1);
300 com_err(whoami, 0, "Access check complete.");
303 struct query pseudo_query = {
313 cl->reply.sms_argc = 0;
315 if (cl->reply.sms_status = check_query_access(&pseudo_query, 0, cl) )
321 execl("/u1/sms/bin/dcm", "dcm", 0);
325 cl->reply.sms_status = errno;