6 * Copyright (C) 1989 by the Massachusetts Institute of Technology
7 * For copying and distribution information, please see the file
13 static char *rcsid_increment_dc = "$Header$";
16 #include <mit-copyright.h>
19 #include "mr_server.h"
20 EXEC SQL INCLUDE sqlca;
31 EXEC SQL WHENEVER SQLERROR CALL ingerr;
33 /* structures to save before args */
34 static char beforeb[MAXARGC][ARGLEN];
35 static char *before[MAXARGC];
36 EXEC SQL BEGIN DECLARE SECTION;
37 char *barg0, *barg1, *barg2, *barg3, *barg4;
38 char *barg5, *barg6, *barg7, *barg8, *barg9;
39 char *barg10, *barg11, *barg12, *barg13, *barg14;
40 EXEC SQL END DECLARE SECTION;
42 static char *beforetable;
44 /* structures to save after args */
45 static char afterb[MAXARGC][ARGLEN];
46 static char *after[MAXARGC];
47 EXEC SQL BEGIN DECLARE SECTION;
48 char *aarg0, *aarg1, *aarg2, *aarg3, *aarg4;
49 char *aarg5, *aarg6, *aarg7, *aarg8, *aarg9;
50 char *aarg10, *aarg11, *aarg12, *aarg13, *aarg14;
51 EXEC SQL END DECLARE SECTION;
54 /* structures to save entire sets of incremental changes */
55 struct save_queue *incremental_sq = NULL;
56 struct save_queue *incremental_exec = NULL;
71 for (i = 0; i < MAXARGC; i++) {
72 before[i] = &beforeb[i][0];
73 after[i] = &afterb[i][0];
105 if (incremental_sq == NULL)
106 incremental_sq = sq_create();
107 if (incremental_exec == NULL)
108 incremental_exec = sq_create();
112 incremental_before(table, qual, argv)
114 EXEC SQL BEGIN DECLARE SECTION;
116 EXEC SQL END DECLARE SECTION;
119 EXEC SQL BEGIN DECLARE SECTION;
121 EXEC SQL END DECLARE SECTION;
123 char buffer[512], *name;
127 if (!strcmp(table, "users")) {
128 EXEC SQL SELECT login, CHAR(uid), shell, last, first, middle,
129 CHAR(status), clearid, type
130 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
132 FROM users WHERE :qual;
134 } else if (!strcmp(table, "machine")) {
135 EXEC SQL SELECT name, type INTO :barg0, :barg1 FROM machine
138 } else if (!strcmp(table, "cluster")) {
139 EXEC SQL SELECT name, description, location
140 INTO :barg0, :barg1, :barg2
141 FROM cluster WHERE :qual;
143 } else if (!strcmp(table, "mcmap")) {
144 strcpy(barg0, argv[0]);
145 strcpy(barg1, argv[1]);
147 } else if (!strcmp(table, "svc")) {
148 strcpy(barg0, argv[0]);
149 strcpy(barg1, argv[1]);
150 strcpy(barg2, argv[2]);
152 } else if (!strcmp(table, "filesys")) {
153 EXEC SQL SELECT label, type, CHAR(mach_id), name, mount, access,
154 comments, CHAR(owner), CHAR(owners), CHAR(createflg), lockertype
155 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
156 :barg7, :barg8, :barg9, :barg10
157 FROM filesys WHERE :qual;
160 id_to_name(id, "MACHINE", &name);
163 id_to_name(id, "USER", &name);
166 id_to_name(id, "LIST", &name);
170 } else if (!strcmp(table, "quota")) {
172 strcpy(barg1, argv[1]);
174 sprintf(buffer, "%s and fs.filsys_id = q.filsys_id", qual);
176 EXEC SQL SELECT q.quota, fs.name INTO :barg3, :barg4
177 FROM quota q, filesys fs WHERE :qual;
179 } else if (!strcmp(table, "list")) {
180 EXEC SQL SELECT name, CHAR(active), CHAR(publicflg), CHAR(hidden),
181 CHAR(maillist), CHAR(grouplist), CHAR(gid), acl_type,
182 CHAR(acl_id), description
183 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
184 :barg7, :barg8, :barg9
185 FROM list WHERE :qual;
187 } else if (!strcmp(table, "members")) {
189 EXEC SQL SELECT CHAR(grouplist) INTO :barg3 FROM list
192 id_to_name(id, "LIST", &name);
194 strcpy(barg1, argv[1]);
196 if (!strcmp(barg1, "USER")) {
197 id_to_name(id, barg1, &name);
198 } else if (!strcmp(barg1, "LIST")) {
199 id_to_name(id, barg1, &name);
200 } else if (!strcmp(barg1, "STRING")) {
201 id_to_name(id, barg1, &name);
202 } else if (!strcmp(barg1, "KERBEROS")) {
203 id_to_name(id, "STRING", &name);
209 com_err(whoami, 0, "unknown table in incremental_before"); */
213 incremental_clear_before()
218 incremental_clear_after()
220 incremental_after("clear", 0);
225 incremental_after(table, qual, argv)
227 EXEC SQL BEGIN DECLARE SECTION;
229 EXEC SQL END DECLARE SECTION;
232 char buffer[2048], *name;
233 EXEC SQL BEGIN DECLARE SECTION;
235 EXEC SQL END DECLARE SECTION;
239 if (!strcmp(table, "users")) {
240 EXEC SQL SELECT login, CHAR(uid), shell, last, first, middle,
241 CHAR(status), clearid, type
242 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5,
243 :aarg6, :aarg7, :aarg8
244 FROM users WHERE :qual;
246 } else if (!strcmp(table, "machine")) {
247 EXEC SQL SELECT name, type INTO :aarg0, :aarg1
248 FROM machine WHERE :qual;
250 } else if (!strcmp(table, "cluster")) {
251 EXEC SQL SELECT name, description, location
252 INTO :aarg0, :aarg1, :aarg2
253 FROM cluster WHERE :qual;
255 } else if (!strcmp(table, "mcmap")) {
256 strcpy(aarg0, argv[0]);
257 strcpy(aarg1, argv[1]);
259 } else if (!strcmp(table, "svc")) {
260 strcpy(aarg0, argv[0]);
261 strcpy(aarg1, argv[1]);
262 strcpy(aarg2, argv[2]);
264 } else if (!strcmp(table, "filesys")) {
265 EXEC SQL SELECT CHAR(label), type, CHAR(mach_id), name, mount, access,
266 comments, CHAR(owner), CHAR(owners), CHAR(createflg), lockertype
267 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5, :aarg6,
268 :aarg7, :aarg8, :aarg9, :aarg10
269 FROM filesys fs WHERE :qual;
272 id_to_name(id, "MACHINE", &name);
275 id_to_name(id, "USER", &name);
278 id_to_name(id, "LIST", &name);
282 } else if (!strcmp(table, "quota")) {
284 strcpy(aarg1, argv[1]);
286 sprintf(buffer, "%s and fs.filsys_id = q.filsys_id", qual);
288 EXEC SQL SELECT CHAR(q.quota), fs.name INTO :aarg3, :aarg4
289 FROM quota q, filesys fs WHERE :qual;
291 } else if (!strcmp(table, "list")) {
292 EXEC SQL SELECT name, CHAR(active), CHAR(publicflg), CHAR(hidden),
293 CHAR(maillist), CHAR(grouplist), CHAR(gid), acl_type,
294 CHAR(acl_id), description
295 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5, :aarg6,
296 :aarg7, :aarg8, :aarg9
297 FROM list WHERE :qual;
299 } else if (!strcmp(table, "members")) {
301 EXEC SQL SELECT CHAR(grouplist) INTO :aarg3 FROM list
304 id_to_name(id, "LIST", &name);
306 strcpy(aarg1, argv[1]);
308 if (!strcmp(aarg1, "USER")) {
309 id_to_name(id, aarg1, &name);
310 } else if (!strcmp(aarg1, "LIST")) {
311 id_to_name(id, aarg1, &name);
312 } else if (!strcmp(aarg1, "STRING")) {
313 id_to_name(id, aarg1, &name);
314 } else if (!strcmp(aarg1, "KERBEROS")) {
315 id_to_name(id, "STRING", &name);
320 } else if (!strcmp(table, "clear")) {
324 com_err(whoami, 0, "unknown table in incremental_after"); */
326 iu = (struct iupdate *) malloc(sizeof(struct iupdate));
327 iu->table = strsave(table);
328 iu->beforec = beforec;
329 iu->before = copy_argv(before, beforec);
331 iu->after = copy_argv(after, afterc);
332 sq_save_data(incremental_sq, iu);
335 sprintf(buffer, "INCREMENTAL(%s, [", table);
336 for (i = 0; i < beforec; i++) {
338 strcat(buffer, strtrim(before[0]));
340 strcat(buffer, ", ");
341 strcat(buffer, strtrim(before[i]));
344 strcat(buffer, "], [");
345 for (i = 0; i < afterc; i++) {
347 strcat(buffer, strtrim(after[0]));
349 strcat(buffer, ", ");
350 strcat(buffer, strtrim(after[i]));
353 strcat(buffer, "])");
354 com_err(whoami, 0, buffer);
359 /* Called when the current transaction is committed to start any queued
360 * incremental updates. This caches the update table the first time it
365 struct inc_cache *next;
373 static int inited = 0;
374 static struct inc_cache *cache;
376 EXEC SQL BEGIN DECLARE SECTION;
377 char tab[17], serv[17];
378 EXEC SQL END DECLARE SECTION;
384 EXEC SQL DECLARE inc CURSOR FOR SELECT tablename, service FROM incremental;
387 EXEC SQL FETCH inc INTO :tab, :serv;
388 if (sqlca.sqlcode != 0) break;
389 c = (struct inc_cache *)malloc(sizeof(struct inc_cache));
391 c->table = strsave(strtrim(tab));
392 c->service = strsave(strtrim(serv));
398 while (sq_remove_data(incremental_sq, &iu)) {
399 for (c = cache; c; c = c->next) {
400 if (!strcmp(c->table, iu->table)) {
401 iu->service = c->service;
402 sq_save_data(incremental_exec, iu);
406 if (inc_running == 0)
414 char *argv[MAXARGC * 2 + 4], cafter[3], cbefore[3], prog[BUFSIZ];
417 if (incremental_exec == NULL)
420 if (sq_empty(incremental_exec) ||
421 (inc_running && now - inc_started < INC_TIMEOUT))
425 com_err(whoami, 0, "incremental timeout on pid %d", inc_pid);
427 sq_remove_data(incremental_exec, &iu);
429 sprintf(cbefore, "%d", iu->beforec);
431 sprintf(cafter, "%d", iu->afterc);
433 for (i = 0; i < iu->beforec; i++)
434 argv[4 + i] = iu->before[i];
435 for (i = 0; i < iu->afterc; i++)
436 argv[4 + iu->beforec + i] = iu->after[i];
438 sprintf(prog, "%s/%s.incr", BIN_DIR, iu->service);
440 com_err(whoami, 0, "forking %s", prog);
443 argv[4 + iu->beforec + iu->afterc] = 0;
450 com_err(whoami, 0, "Failed to start incremental update");
457 free_argv(iu->before, iu->beforec);
458 free_argv(iu->after, iu->afterc);
465 /* Called when the current transaction is aborted to throw away any queued
466 * incremental updates
473 while (sq_get_data(incremental_sq, &iu)) {
474 free_argv(iu->before, iu->beforec);
475 free_argv(iu->after, iu->afterc);
479 sq_destroy(incremental_sq);
480 incremental_sq = sq_create();
484 char **copy_argv(argv, argc)
488 char **ret = (char **)malloc(sizeof(char *) * argc);
490 ret[argc] = strsave(strtrim(argv[argc]));
494 free_argv(argv, argc)