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$";
17 #include <mit-copyright.h>
20 #include "mr_server.h"
21 EXEC SQL INCLUDE sqlca;
32 EXEC SQL WHENEVER SQLERROR CALL ingerr;
34 /* structures to save before args */
35 static char beforeb[MAXARGC][ARGLEN];
36 static char *before[MAXARGC];
37 EXEC SQL BEGIN DECLARE SECTION;
38 char *barg0, *barg1, *barg2, *barg3, *barg4;
39 char *barg5, *barg6, *barg7, *barg8, *barg9;
40 char *barg10, *barg11, *barg12, *barg13, *barg14;
41 EXEC SQL END DECLARE SECTION;
43 static char *beforetable;
45 /* structures to save after args */
46 static char afterb[MAXARGC][ARGLEN];
47 static char *after[MAXARGC];
48 EXEC SQL BEGIN DECLARE SECTION;
49 char *aarg0, *aarg1, *aarg2, *aarg3, *aarg4;
50 char *aarg5, *aarg6, *aarg7, *aarg8, *aarg9;
51 char *aarg10, *aarg11, *aarg12, *aarg13, *aarg14;
52 EXEC SQL END DECLARE SECTION;
55 /* structures to save entire sets of incremental changes */
56 struct save_queue *incremental_sq = NULL;
57 struct save_queue *incremental_exec = NULL;
72 for (i = 0; i < MAXARGC; i++) {
73 before[i] = &beforeb[i][0];
74 after[i] = &afterb[i][0];
106 if (incremental_sq == NULL)
107 incremental_sq = sq_create();
108 if (incremental_exec == NULL)
109 incremental_exec = sq_create();
113 incremental_before(table, qual, argv)
115 EXEC SQL BEGIN DECLARE SECTION;
117 EXEC SQL END DECLARE SECTION;
120 EXEC SQL BEGIN DECLARE SECTION;
122 EXEC SQL END DECLARE SECTION;
124 char buffer[512], *name;
128 if (!strcmp(table, "users")) {
129 EXEC SQL SELECT u.login, CHAR(u.uid), u.shell, u.last, u.first, u.middle,
130 CHAR(u.status), u.clearid, u.type
131 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
133 FROM users u WHERE :qual;
135 } else if (!strcmp(table, "machine")) {
136 EXEC SQL SELECT m.name, m.type INTO :barg0, :barg1 FROM machine m
139 } else if (!strcmp(table, "cluster")) {
140 EXEC SQL SELECT c.name, c.description, c.location
141 INTO :barg0, :barg1, :barg2
142 FROM cluster c WHERE :qual;
144 } else if (!strcmp(table, "mcmap")) {
145 strcpy(barg0, argv[0]);
146 strcpy(barg1, argv[1]);
148 } else if (!strcmp(table, "svc")) {
149 strcpy(barg0, argv[0]);
150 strcpy(barg1, argv[1]);
151 strcpy(barg2, argv[2]);
153 } else if (!strcmp(table, "filesys")) {
154 EXEC SQL SELECT fs.label, fs.type, CHAR(fs.mach_id), fs.name,
155 fs.mount, fs.access, fs.comments, CHAR(fs.owner), CHAR(fs.owners),
156 CHAR(fs.createflg), fs.lockertype
157 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
158 :barg7, :barg8, :barg9, :barg10
159 FROM filesys fs WHERE :qual;
162 id_to_name(id, "MACHINE", &name);
165 id_to_name(id, "USER", &name);
168 id_to_name(id, "LIST", &name);
172 } else if (!strcmp(table, "quota")) {
174 strcpy(barg1, argv[1]);
176 sprintf(buffer, "%s AND fs.filsys_id = q.filsys_id", qual);
178 EXEC SQL SELECT CHAR(q.quota), fs.name INTO :barg3, :barg4
179 FROM quota q, filesys fs WHERE :qual;
181 } else if (!strcmp(table, "list")) {
182 EXEC SQL SELECT l.name, CHAR(l.active), CHAR(l.publicflg),
183 CHAR(l.hidden), CHAR(l.maillist), CHAR(l.grouplist), CHAR(l.gid),
184 l.acl_type, CHAR(l.acl_id), l.description
185 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
186 :barg7, :barg8, :barg9
187 FROM list l WHERE :qual;
189 } else if (!strcmp(table, "members")) {
191 EXEC SQL SELECT CHAR(grouplist) INTO :barg3 FROM list
194 id_to_name(id, "LIST", &name);
196 strcpy(barg1, argv[1]);
198 if (!strcmp(barg1, "USER")) {
199 id_to_name(id, barg1, &name);
200 } else if (!strcmp(barg1, "LIST")) {
201 id_to_name(id, barg1, &name);
202 } else if (!strcmp(barg1, "STRING")) {
203 id_to_name(id, barg1, &name);
204 } else if (!strcmp(barg1, "KERBEROS")) {
205 id_to_name(id, "STRING", &name);
211 com_err(whoami, 0, "unknown table in incremental_before"); */
215 incremental_clear_before()
220 incremental_clear_after()
222 incremental_after("clear", 0);
227 incremental_after(table, qual, argv)
229 EXEC SQL BEGIN DECLARE SECTION;
231 EXEC SQL END DECLARE SECTION;
234 char buffer[2048], *name;
235 EXEC SQL BEGIN DECLARE SECTION;
237 EXEC SQL END DECLARE SECTION;
241 if (!strcmp(table, "users")) {
242 EXEC SQL SELECT u.login, CHAR(u.uid), u.shell, u.last, u.first,
243 u.middle, CHAR(u.status), u.clearid, u.type
244 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5,
245 :aarg6, :aarg7, :aarg8
246 FROM users u WHERE :qual;
248 } else if (!strcmp(table, "machine")) {
249 EXEC SQL SELECT m.name, m.type INTO :aarg0, :aarg1
250 FROM machine m WHERE :qual;
252 } else if (!strcmp(table, "cluster")) {
253 EXEC SQL SELECT c.name, c.description, c.location
254 INTO :aarg0, :aarg1, :aarg2
255 FROM cluster c WHERE :qual;
257 } else if (!strcmp(table, "mcmap")) {
258 strcpy(aarg0, argv[0]);
259 strcpy(aarg1, argv[1]);
261 } else if (!strcmp(table, "svc")) {
262 strcpy(aarg0, argv[0]);
263 strcpy(aarg1, argv[1]);
264 strcpy(aarg2, argv[2]);
266 } else if (!strcmp(table, "filesys")) {
267 EXEC SQL SELECT CHAR(fs.label), fs.type, CHAR(fs.mach_id), fs.name,
268 fs.mount, fs.access, fs.comments, CHAR(fs.owner), CHAR(fs.owners),
269 CHAR(fs.createflg), fs.lockertype
270 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5, :aarg6,
271 :aarg7, :aarg8, :aarg9, :aarg10
272 FROM filesys fs WHERE :qual;
275 id_to_name(id, "MACHINE", &name);
278 id_to_name(id, "USER", &name);
281 id_to_name(id, "LIST", &name);
285 } else if (!strcmp(table, "quota")) {
287 strcpy(aarg1, argv[1]);
289 sprintf(buffer, "%s and fs.filsys_id = q.filsys_id", qual);
291 EXEC SQL SELECT CHAR(q.quota), fs.name INTO :aarg3, :aarg4
292 FROM quota q, filesys fs WHERE :qual;
294 } else if (!strcmp(table, "list")) {
295 EXEC SQL SELECT l.name, CHAR(l.active), CHAR(l.publicflg),
296 CHAR(l.hidden), CHAR(l.maillist), CHAR(l.grouplist), CHAR(l.gid),
297 l.acl_type, CHAR(l.acl_id), l.description
298 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5, :aarg6,
299 :aarg7, :aarg8, :aarg9
300 FROM list l WHERE :qual;
302 } else if (!strcmp(table, "members")) {
304 EXEC SQL SELECT CHAR(grouplist) INTO :aarg3 FROM list
307 id_to_name(id, "LIST", &name);
309 strcpy(aarg1, argv[1]);
311 if (!strcmp(aarg1, "USER")) {
312 id_to_name(id, aarg1, &name);
313 } else if (!strcmp(aarg1, "LIST")) {
314 id_to_name(id, aarg1, &name);
315 } else if (!strcmp(aarg1, "STRING")) {
316 id_to_name(id, aarg1, &name);
317 } else if (!strcmp(aarg1, "KERBEROS")) {
318 id_to_name(id, "STRING", &name);
323 } else if (!strcmp(table, "clear")) {
327 com_err(whoami, 0, "unknown table in incremental_after"); */
329 iu = (struct iupdate *) malloc(sizeof(struct iupdate));
330 iu->table = strsave(table);
331 iu->beforec = beforec;
332 iu->before = copy_argv(before, beforec);
334 iu->after = copy_argv(after, afterc);
335 sq_save_data(incremental_sq, iu);
338 sprintf(buffer, "INCREMENTAL(%s, [", table);
339 for (i = 0; i < beforec; i++) {
341 strcat(buffer, strtrim(before[0]));
343 strcat(buffer, ", ");
344 strcat(buffer, strtrim(before[i]));
347 strcat(buffer, "], [");
348 for (i = 0; i < afterc; i++) {
350 strcat(buffer, strtrim(after[0]));
352 strcat(buffer, ", ");
353 strcat(buffer, strtrim(after[i]));
356 strcat(buffer, "])");
357 com_err(whoami, 0, buffer);
362 /* Called when the current transaction is committed to start any queued
363 * incremental updates. This caches the update table the first time it
368 struct inc_cache *next;
376 static int inited = 0;
377 static struct inc_cache *cache;
379 EXEC SQL BEGIN DECLARE SECTION;
380 char tab[17], serv[17];
381 EXEC SQL END DECLARE SECTION;
387 EXEC SQL DECLARE inc CURSOR FOR SELECT tablename, service FROM incremental;
390 EXEC SQL FETCH inc INTO :tab, :serv;
391 if (sqlca.sqlcode != 0) break;
392 c = (struct inc_cache *)malloc(sizeof(struct inc_cache));
394 c->table = strsave(strtrim(tab));
395 c->service = strsave(strtrim(serv));
399 EXEC SQL COMMIT WORK;
402 while (sq_remove_data(incremental_sq, &iu)) {
403 for (c = cache; c; c = c->next) {
404 if (!strcmp(c->table, iu->table)) {
405 iu->service = c->service;
406 sq_save_data(incremental_exec, iu);
410 if (inc_running == 0)
418 char *argv[MAXARGC * 2 + 4], cafter[3], cbefore[3], prog[BUFSIZ];
421 if (incremental_exec == NULL)
424 if (sq_empty(incremental_exec) ||
425 (inc_running && now - inc_started < INC_TIMEOUT))
429 com_err(whoami, 0, "incremental timeout on pid %d", inc_pid);
431 sq_remove_data(incremental_exec, &iu);
433 sprintf(cbefore, "%d", iu->beforec);
435 sprintf(cafter, "%d", iu->afterc);
437 for (i = 0; i < iu->beforec; i++)
438 argv[4 + i] = iu->before[i];
439 for (i = 0; i < iu->afterc; i++)
440 argv[4 + iu->beforec + i] = iu->after[i];
442 sprintf(prog, "%s/%s.incr", BIN_DIR, iu->service);
444 com_err(whoami, 0, "forking %s", prog);
447 argv[4 + iu->beforec + iu->afterc] = 0;
454 com_err(whoami, 0, "Failed to start incremental update");
461 free_argv(iu->before, iu->beforec);
462 free_argv(iu->after, iu->afterc);
469 /* Called when the current transaction is aborted to throw away any queued
470 * incremental updates
477 while (sq_get_data(incremental_sq, &iu)) {
478 free_argv(iu->before, iu->beforec);
479 free_argv(iu->after, iu->afterc);
483 sq_destroy(incremental_sq);
484 incremental_sq = sq_create();
488 char **copy_argv(argv, argc)
492 char **ret = (char **)malloc(sizeof(char *) * argc);
494 ret[argc] = strsave(strtrim(argv[argc]));
498 free_argv(argv, argc)