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 login, CHAR(uid), shell, last, first, middle,
130 CHAR(status), clearid, type
131 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
133 FROM users WHERE :qual;
135 } else if (!strcmp(table, "machine")) {
136 EXEC SQL SELECT name, type INTO :barg0, :barg1 FROM machine
139 } else if (!strcmp(table, "cluster")) {
140 EXEC SQL SELECT name, description, location
141 INTO :barg0, :barg1, :barg2
142 FROM cluster 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 label, type, CHAR(mach_id), name, mount, access,
155 comments, CHAR(owner), CHAR(owners), CHAR(createflg), lockertype
156 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
157 :barg7, :barg8, :barg9, :barg10
158 FROM filesys WHERE :qual;
161 id_to_name(id, "MACHINE", &name);
164 id_to_name(id, "USER", &name);
167 id_to_name(id, "LIST", &name);
171 } else if (!strcmp(table, "quota")) {
173 strcpy(barg1, argv[1]);
175 sprintf(buffer, "%s and filesys.filsys_id = quota.filsys_id", qual);
177 EXEC SQL SELECT CHAR(quota.quota), filesys.name INTO :barg3, :barg4
178 FROM quota, filesys WHERE :qual;
180 } else if (!strcmp(table, "list")) {
181 EXEC SQL SELECT name, CHAR(active), CHAR(publicflg), CHAR(hidden),
182 CHAR(maillist), CHAR(grouplist), CHAR(gid), acl_type,
183 CHAR(acl_id), description
184 INTO :barg0, :barg1, :barg2, :barg3, :barg4, :barg5, :barg6,
185 :barg7, :barg8, :barg9
186 FROM list WHERE :qual;
188 } else if (!strcmp(table, "members")) {
190 EXEC SQL SELECT CHAR(grouplist) INTO :barg3 FROM list
193 id_to_name(id, "LIST", &name);
195 strcpy(barg1, argv[1]);
197 if (!strcmp(barg1, "USER")) {
198 id_to_name(id, barg1, &name);
199 } else if (!strcmp(barg1, "LIST")) {
200 id_to_name(id, barg1, &name);
201 } else if (!strcmp(barg1, "STRING")) {
202 id_to_name(id, barg1, &name);
203 } else if (!strcmp(barg1, "KERBEROS")) {
204 id_to_name(id, "STRING", &name);
210 com_err(whoami, 0, "unknown table in incremental_before"); */
214 incremental_clear_before()
219 incremental_clear_after()
221 incremental_after("clear", 0);
226 incremental_after(table, qual, argv)
228 EXEC SQL BEGIN DECLARE SECTION;
230 EXEC SQL END DECLARE SECTION;
233 char buffer[2048], *name;
234 EXEC SQL BEGIN DECLARE SECTION;
236 EXEC SQL END DECLARE SECTION;
240 if (!strcmp(table, "users")) {
241 EXEC SQL SELECT login, CHAR(uid), shell, last, first, middle,
242 CHAR(status), clearid, type
243 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5,
244 :aarg6, :aarg7, :aarg8
245 FROM users WHERE :qual;
247 } else if (!strcmp(table, "machine")) {
248 EXEC SQL SELECT name, type INTO :aarg0, :aarg1
249 FROM machine WHERE :qual;
251 } else if (!strcmp(table, "cluster")) {
252 EXEC SQL SELECT name, description, location
253 INTO :aarg0, :aarg1, :aarg2
254 FROM cluster WHERE :qual;
256 } else if (!strcmp(table, "mcmap")) {
257 strcpy(aarg0, argv[0]);
258 strcpy(aarg1, argv[1]);
260 } else if (!strcmp(table, "svc")) {
261 strcpy(aarg0, argv[0]);
262 strcpy(aarg1, argv[1]);
263 strcpy(aarg2, argv[2]);
265 } else if (!strcmp(table, "filesys")) {
266 EXEC SQL SELECT CHAR(label), type, CHAR(mach_id), name, mount, access,
267 comments, CHAR(owner), CHAR(owners), CHAR(createflg), lockertype
268 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5, :aarg6,
269 :aarg7, :aarg8, :aarg9, :aarg10
270 FROM filesys fs WHERE :qual;
273 id_to_name(id, "MACHINE", &name);
276 id_to_name(id, "USER", &name);
279 id_to_name(id, "LIST", &name);
283 } else if (!strcmp(table, "quota")) {
285 strcpy(aarg1, argv[1]);
287 sprintf(buffer, "%s and filesys.filsys_id = quota.filsys_id", qual);
289 EXEC SQL SELECT CHAR(quota.quota), filesys.name INTO :aarg3, :aarg4
290 FROM quota, filesys WHERE :qual;
292 } else if (!strcmp(table, "list")) {
293 EXEC SQL SELECT name, CHAR(active), CHAR(publicflg), CHAR(hidden),
294 CHAR(maillist), CHAR(grouplist), CHAR(gid), acl_type,
295 CHAR(acl_id), description
296 INTO :aarg0, :aarg1, :aarg2, :aarg3, :aarg4, :aarg5, :aarg6,
297 :aarg7, :aarg8, :aarg9
298 FROM list WHERE :qual;
300 } else if (!strcmp(table, "members")) {
302 EXEC SQL SELECT CHAR(grouplist) INTO :aarg3 FROM list
305 id_to_name(id, "LIST", &name);
307 strcpy(aarg1, argv[1]);
309 if (!strcmp(aarg1, "USER")) {
310 id_to_name(id, aarg1, &name);
311 } else if (!strcmp(aarg1, "LIST")) {
312 id_to_name(id, aarg1, &name);
313 } else if (!strcmp(aarg1, "STRING")) {
314 id_to_name(id, aarg1, &name);
315 } else if (!strcmp(aarg1, "KERBEROS")) {
316 id_to_name(id, "STRING", &name);
321 } else if (!strcmp(table, "clear")) {
325 com_err(whoami, 0, "unknown table in incremental_after"); */
327 iu = (struct iupdate *) malloc(sizeof(struct iupdate));
328 iu->table = strsave(table);
329 iu->beforec = beforec;
330 iu->before = copy_argv(before, beforec);
332 iu->after = copy_argv(after, afterc);
333 sq_save_data(incremental_sq, iu);
336 sprintf(buffer, "INCREMENTAL(%s, [", table);
337 for (i = 0; i < beforec; i++) {
339 strcat(buffer, strtrim(before[0]));
341 strcat(buffer, ", ");
342 strcat(buffer, strtrim(before[i]));
345 strcat(buffer, "], [");
346 for (i = 0; i < afterc; i++) {
348 strcat(buffer, strtrim(after[0]));
350 strcat(buffer, ", ");
351 strcat(buffer, strtrim(after[i]));
354 strcat(buffer, "])");
355 com_err(whoami, 0, buffer);
360 /* Called when the current transaction is committed to start any queued
361 * incremental updates. This caches the update table the first time it
366 struct inc_cache *next;
374 static int inited = 0;
375 static struct inc_cache *cache;
377 EXEC SQL BEGIN DECLARE SECTION;
378 char tab[17], serv[17];
379 EXEC SQL END DECLARE SECTION;
385 EXEC SQL DECLARE inc CURSOR FOR SELECT tablename, service FROM incremental;
388 EXEC SQL FETCH inc INTO :tab, :serv;
389 if (sqlca.sqlcode != 0) break;
390 c = (struct inc_cache *)malloc(sizeof(struct inc_cache));
392 c->table = strsave(strtrim(tab));
393 c->service = strsave(strtrim(serv));
399 while (sq_remove_data(incremental_sq, &iu)) {
400 for (c = cache; c; c = c->next) {
401 if (!strcmp(c->table, iu->table)) {
402 iu->service = c->service;
403 sq_save_data(incremental_exec, iu);
407 if (inc_running == 0)
415 char *argv[MAXARGC * 2 + 4], cafter[3], cbefore[3], prog[BUFSIZ];
418 if (incremental_exec == NULL)
421 if (sq_empty(incremental_exec) ||
422 (inc_running && now - inc_started < INC_TIMEOUT))
426 com_err(whoami, 0, "incremental timeout on pid %d", inc_pid);
428 sq_remove_data(incremental_exec, &iu);
430 sprintf(cbefore, "%d", iu->beforec);
432 sprintf(cafter, "%d", iu->afterc);
434 for (i = 0; i < iu->beforec; i++)
435 argv[4 + i] = iu->before[i];
436 for (i = 0; i < iu->afterc; i++)
437 argv[4 + iu->beforec + i] = iu->after[i];
439 sprintf(prog, "%s/%s.incr", BIN_DIR, iu->service);
441 com_err(whoami, 0, "forking %s", prog);
444 argv[4 + iu->beforec + iu->afterc] = 0;
451 com_err(whoami, 0, "Failed to start incremental update");
458 free_argv(iu->before, iu->beforec);
459 free_argv(iu->after, iu->afterc);
466 /* Called when the current transaction is aborted to throw away any queued
467 * incremental updates
474 while (sq_get_data(incremental_sq, &iu)) {
475 free_argv(iu->before, iu->beforec);
476 free_argv(iu->after, iu->afterc);
480 sq_destroy(incremental_sq);
481 incremental_sq = sq_create();
485 char **copy_argv(argv, argc)
489 char **ret = (char **)malloc(sizeof(char *) * argc);
491 ret[argc] = strsave(strtrim(argv[argc]));
495 free_argv(argv, argc)