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;
159 } else if (!strcmp(table, "quota")) {
161 strcpy(barg1, argv[1]);
163 sprintf(buffer, "%s and fs.filsys_id = q.filsys_id", qual);
165 EXEC SQL SELECT q.quota, fs.name INTO :barg3, :barg4
166 FROM quota q, filesys fs WHERE :qual;
168 } else if (!strcmp(table, "list")) {
169 EXEC SQL SELECT name, CHAR(active), CHAR(publicflg), CHAR(hidden),
170 CHAR(maillist), CHAR(grouplist), CHAR(gid), acl_type,
171 CHAR(acl_id), description
172 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
173 :barg7, :barg8, :barg9
174 FROM list WHERE :qual;
176 } else if (!strcmp(table, "members")) {
178 EXEC SQL SELECT CHAR(grouplist) INTO :barg3 FROM list
181 id_to_name(id, "LIST", &name);
183 strcpy(barg1, argv[1]);
185 if (!strcmp(barg1, "USER")) {
186 id_to_name(id, barg1, &name);
187 } else if (!strcmp(barg1, "LIST")) {
188 id_to_name(id, barg1, &name);
189 } else if (!strcmp(barg1, "STRING")) {
190 id_to_name(id, barg1, &name);
191 } else if (!strcmp(barg1, "KERBEROS")) {
192 id_to_name(id, "STRING", &name);
198 com_err(whoami, 0, "unknown table in incremental_before"); */
202 incremental_clear_before()
207 incremental_clear_after()
209 incremental_after("clear", 0);
214 incremental_after(table, qual, argv)
216 EXEC SQL BEGIN DECLARE SECTION;
218 EXEC SQL END DECLARE SECTION;
221 char buffer[2048], *name;
222 EXEC SQL BEGIN DECLARE SECTION;
224 EXEC SQL END DECLARE SECTION;
228 if (!strcmp(table, "users")) {
229 EXEC SQL SELECT login, CHAR(uid), shell, last, first, middle,
230 CHAR(status), clearid, type
231 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5,
232 :aarg6, :aarg7, :aarg8
233 FROM users WHERE :qual;
235 } else if (!strcmp(table, "machine")) {
236 EXEC SQL SELECT name, type INTO :aarg0, :aarg1
237 FROM machine WHERE :qual;
239 } else if (!strcmp(table, "cluster")) {
240 EXEC SQL SELECT name, description, location
241 INTO :aarg0, :aarg1, :aarg2
242 FROM cluster WHERE :qual;
244 } else if (!strcmp(table, "mcmap")) {
245 strcpy(aarg0, argv[0]);
246 strcpy(aarg1, argv[1]);
248 } else if (!strcmp(table, "svc")) {
249 strcpy(aarg0, argv[0]);
250 strcpy(aarg1, argv[1]);
251 strcpy(aarg2, argv[2]);
253 } else if (!strcmp(table, "filesys")) {
254 EXEC SQL SELECT CHAR(label), type, CHAR(mach_id), name, mount, access,
255 comments, CHAR(owner), CHAR(owners), CHAR(createflg), lockertype
256 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5, :aarg6,
257 :aarg7, :aarg8, :aarg9, :aarg10
258 FROM filesys fs WHERE :qual;
260 } else if (!strcmp(table, "quota")) {
262 strcpy(aarg1, argv[1]);
264 sprintf(buffer, "%s and fs.filsys_id = q.filsys_id", qual);
266 EXEC SQL SELECT CHAR(q.quota), fs.name INTO :aarg3, :aarg4
267 FROM quota q, filesys fs WHERE :qual;
269 } else if (!strcmp(table, "list")) {
270 EXEC SQL SELECT name, CHAR(active), CHAR(publicflg), CHAR(hidden),
271 CHAR(maillist), CHAR(grouplist), CHAR(gid), acl_type,
272 CHAR(acl_id), description
273 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5, :aarg6,
274 :aarg7, :aarg8, :aarg9
275 FROM list WHERE :qual;
277 } else if (!strcmp(table, "members")) {
279 EXEC SQL SELECT CHAR(grouplist) INTO :aarg3 FROM list
282 id_to_name(id, "LIST", &name);
284 strcpy(aarg1, argv[1]);
286 if (!strcmp(aarg1, "USER")) {
287 id_to_name(id, aarg1, &name);
288 } else if (!strcmp(aarg1, "LIST")) {
289 id_to_name(id, aarg1, &name);
290 } else if (!strcmp(aarg1, "STRING")) {
291 id_to_name(id, aarg1, &name);
292 } else if (!strcmp(aarg1, "KERBEROS")) {
293 id_to_name(id, "STRING", &name);
298 } else if (!strcmp(table, "clear")) {
302 com_err(whoami, 0, "unknown table in incremental_after"); */
304 iu = (struct iupdate *) malloc(sizeof(struct iupdate));
305 iu->table = strsave(table);
306 iu->beforec = beforec;
307 iu->before = copy_argv(before, beforec);
309 iu->after = copy_argv(after, afterc);
310 sq_save_data(incremental_sq, iu);
313 sprintf(buffer, "INCREMENTAL(%s, [", table);
314 for (i = 0; i < beforec; i++) {
316 strcat(buffer, strtrim(before[0]));
318 strcat(buffer, ", ");
319 strcat(buffer, strtrim(before[i]));
322 strcat(buffer, "], [");
323 for (i = 0; i < afterc; i++) {
325 strcat(buffer, strtrim(after[0]));
327 strcat(buffer, ", ");
328 strcat(buffer, strtrim(after[i]));
331 strcat(buffer, "])");
332 com_err(whoami, 0, buffer);
337 /* Called when the current transaction is committed to start any queued
338 * incremental updates. This caches the update table the first time it
343 struct inc_cache *next;
351 static int inited = 0;
352 static struct inc_cache *cache;
354 EXEC SQL BEGIN DECLARE SECTION;
355 char tab[17], serv[17];
356 EXEC SQL END DECLARE SECTION;
362 EXEC SQL DECLARE inc CURSOR FOR SELECT tablename, service FROM incremental;
365 EXEC SQL FETCH inc INTO :tab, :serv;
366 if (sqlca.sqlcode != 0) break;
367 c = (struct inc_cache *)malloc(sizeof(struct inc_cache));
369 c->table = strsave(strtrim(tab));
370 c->service = strsave(strtrim(serv));
376 while (sq_remove_data(incremental_sq, &iu)) {
377 for (c = cache; c; c = c->next) {
378 if (!strcmp(c->table, iu->table)) {
379 iu->service = c->service;
380 sq_save_data(incremental_exec, iu);
384 if (inc_running == 0)
392 char *argv[MAXARGC * 2 + 4], cafter[3], cbefore[3], prog[BUFSIZ];
395 if (incremental_exec == NULL)
398 if (sq_empty(incremental_exec) ||
399 (inc_running && now - inc_started < INC_TIMEOUT))
403 com_err(whoami, 0, "incremental timeout on pid %d", inc_pid);
405 sq_remove_data(incremental_exec, &iu);
407 sprintf(cbefore, "%d", iu->beforec);
409 sprintf(cafter, "%d", iu->afterc);
411 for (i = 0; i < iu->beforec; i++)
412 argv[4 + i] = iu->before[i];
413 for (i = 0; i < iu->afterc; i++)
414 argv[4 + iu->beforec + i] = iu->after[i];
416 sprintf(prog, "%s/%s.incr", BIN_DIR, iu->service);
418 com_err(whoami, 0, "forking %s", prog);
421 argv[4 + iu->beforec + iu->afterc] = 0;
428 com_err(whoami, 0, "Failed to start incremental update");
435 free_argv(iu->before, iu->beforec);
436 free_argv(iu->after, iu->afterc);
443 /* Called when the current transaction is aborted to throw away any queued
444 * incremental updates
451 while (sq_get_data(incremental_sq, &iu)) {
452 free_argv(iu->before, iu->beforec);
453 free_argv(iu->after, iu->afterc);
457 sq_destroy(incremental_sq);
458 incremental_sq = sq_create();
462 char **copy_argv(argv, argc)
466 char **ret = (char **)malloc(sizeof(char *) * argc);
468 ret[argc] = strsave(strtrim(argv[argc]));
472 free_argv(argv, argc)