## char qual[256];
build_qual(q->qual, q->argc, argv, qual);
+## range of u is users
## retrieve (id = u.users_id) where qual
## inquire_equel(rowcount = "rowcount")
if (rowcount != 1 || id != cl->users_id)
return(status);
/* if amtl or dmfl and list is public allow client to add or delete self */
- if ((!strcmp("amtl", q->shortname) || !strcmp("dmfl", q->shortname)) &&
- (flags && !strcmp("USER", argv[1]))) {
+ if (((!strcmp("amtl", q->shortname) && flags) ||
+ (!strcmp("dmfl", q->shortname))) &&
+ (!strcmp("USER", argv[1]))) {
if (*(int *)argv[2] == client_id) return(SMS_SUCCESS);
/* if update_list, don't allow them to change the GID */
} else if (!strcmp("ulis", q->shortname)) {
if (!flags)
return(SMS_SUCCESS);
+
/* parse client structure */
if ((status = get_client(cl, &client_type, &client_id)) != SMS_SUCCESS)
return(status);
if (users_id == cl->users_id)
return(SMS_SUCCESS);
if ((status = get_client(cl, &client_type, &client_id)) != SMS_SUCCESS)
- return(status);
+ return(status);
status = find_member("LIST", list_id, client_type, client_id, 0);
if (status)
return(SMS_SUCCESS);
- return(SMS_PERM);
+ else
+ return(SMS_PERM);
##}
/* For now, only allow users to be deleted if their status is 0 */
## repeat retrieve (flag = u.status) where u.users_id = @id
- if (flag != 0)
+ if (flag != 0 && flag != 4)
return(SMS_IN_USE);
## repeat delete nfsquota where nfsquota.users_id = @id
-## repeat retrieve (flag = any(members.member_id where members.member_id=@id
-## and members.member_type = "USER"))
+## repeat delete krbmap where krbmap.users_id = @id
+## repeat retrieve (flag = any(imembers.member_id where imembers.member_id=@id
+## and imembers.member_type = "USER"))
if (flag)
return(SMS_IN_USE);
## repeat retrieve (flag = any(filesys.label where filesys.owner=@id))
## hostaccess.acl_type = "USER"))
if (flag)
return(SMS_IN_USE);
- else
- return(SMS_SUCCESS);
+ if (ingres_errno)
+ return(sms_errcode);
+ return(SMS_SUCCESS);
##}
user = *(int *)argv[0];
## repeat retrieve (type = u.potype, id = u.pop_id)
## where u.users_id = @user
+ if (ingres_errno) return(sms_errcode);
if (!strcmp(strtrim(type), "POP"))
set_pop_usage(id, -1);
## repeat retrieve (flag = any(printcap.mach_id where printcap.mach_id=@id))
if (flag)
return(SMS_IN_USE);
+## repeat retrieve (flag = any(palladium.mach_id where palladium.mach_id=@id))
+ if (flag)
+ return(SMS_IN_USE);
## repeat delete mcmap where mcmap.mach_id = @id
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
##}
## repeat retrieve (flag = any(svc.clu_id where svc.clu_id=@id))
if (flag)
return(SMS_IN_USE);
- else
- return(SMS_SUCCESS);
+ if (ingres_errno)
+ return(sms_errcode);
+ return(SMS_SUCCESS);
##}
if (set_next_object_id("gid", "list"))
return(SMS_INGRES_ERR);
## repeat retrieve (ngid = values.value) where values.name = "gid"
+ if (ingres_errno) return(sms_errcode);
sprintf(argv[idx], "%d", ngid);
} else {
strcpy(argv[idx], "-1");
## int flag, id;
id = *(int *)argv[0];
-## repeat retrieve (flag = any(members.member_id where members.member_id=@id
-## and members.member_type = "LIST"))
+## repeat retrieve (flag = any(imembers.member_id where imembers.member_id=@id
+## and imembers.member_type = "LIST"))
if (flag)
return(SMS_IN_USE);
-## repeat retrieve (flag = any(members.member_id where members.list_id=@id))
+## repeat retrieve (flag = any(imembers.member_id where imembers.list_id=@id))
if (flag)
return(SMS_IN_USE);
## repeat retrieve (flag = any(filesys.label where filesys.owners=@id))
## zephyr.iui_type = "LIST" and zephyr.iui_id = @id))
if (flag)
return(SMS_IN_USE);
- else
- return(SMS_SUCCESS);
+ if (ingres_errno)
+ return(sms_errcode);
+ return(SMS_SUCCESS);
##}
## repeat retrieve (flag = servers.inprogress) where servers.#name = @name
if (flag)
return(SMS_IN_USE);
- else
- return(SMS_SUCCESS);
+ if (ingres_errno)
+ return(sms_errcode);
+ return(SMS_SUCCESS);
##}
## where serverhosts.service=uppercase(@name) and serverhosts.mach_id=@id
if (flag)
return(SMS_IN_USE);
- else
- return(SMS_SUCCESS);
+ if (ingres_errno)
+ return(sms_errcode);
+ return(SMS_SUCCESS);
##}
status = check_nfs(mach_id, name, access);
fid = *(int *)argv[0];
## replace nfsquota (phys_id = var_phys_id) where nfsquota.filsys_id = fid
+ if (ingres_errno) return(sms_errcode);
return(status);
} else
return(SMS_SUCCESS);
char *name;
char *access;
##{
-## char dir[32];
+## char dir[81];
char caccess;
register int status;
register char *cp1;
## endretrieve
}
## }
-
+ if (ingres_errno)
+ return(sms_errcode);
return(status);
##}
## repeat delete q where q.filsys_id = @id
## repeat delete fsgroup where fsgroup.filsys_id = @id
## repeat delete fsgroup where fsgroup.group_id = @id
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
##}
## repeat retrieve (exists = any(filesys.label where filesys.phys_id = @id))
if (exists)
return(SMS_IN_USE);
+ if (ingres_errno)
+ return(sms_errcode);
return(SMS_SUCCESS);
##}
## q.filsys_id = @fs
## repeat replace nfsphys (allocated = nfsphys.allocated - @quota)
## where nfsphys.nfsphys_id = filesys.#phys_id and filesys.filsys_id = @fs
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
##}
##}
+/* setup add_kerberos_user_mapping: add the string to the string
+ * table if necessary.
+ */
+
+setup_akum(q, argv, cl)
+struct query *q;
+char **argv;
+client *cl;
+##{
+## int id, rowcount;
+## char *name;
+
+ name = argv[1];
+## range of s is strings
+## repeat retrieve (id = s.string_id) where s.string = @name
+## inquire_equel (rowcount = "rowcount")
+ if (rowcount == 0) {
+ if (q->type != APPEND) return(SMS_STRING);
+## range of v is values
+## retrieve (id = v.value) where v.#name = "strings_id"
+ id++;
+## replace v (value = id) where v.#name = "strings_id"
+## append to strings (string_id = id, string = name)
+ }
+ if (ingres_errno) return(sms_errcode);
+ *(int *)argv[1] = id;
+ return(SMS_SUCCESS);
+##}
+
+
\f
/* FOLLOWUP ROUTINES */
## int who;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
table = q->rtable;
name = argv[0];
## int who, id;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
table = q->rtable;
id_name = q->validate->object_id;
## char *entity;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
users_id = *(int *)argv[0];
## repeat replace u (fmodtime = "now", fmodby = @who, fmodwith = @entity)
## char *entity;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
users_id = *(int *)argv[0];
## repeat replace users (pmodtime = "now", pmodby = @who, pmodwith = @entity)
## int who;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
table = q->rtable;
name = argv[0];
## int who, id;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
id = *(int *)argv[0];
## range of m is machine
## int who, id;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
id = *(int *)argv[0];
## range of c is cluster
## int who, id;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
serv = argv[0];
id = *(int *)argv[1];
## int who, id;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
id = *(int *)argv[0];
dir = argv[1];
## int who;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
label = argv[0];
if (!strcmp(q->shortname, "ufil"))
## int who;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
class = argv[0];
while (sq_get_data(sq, &argv)) {
id = atoi(argv[i]);
free(argv[i]);
- argv[i] = malloc(9);
+ argv[i] = malloc(256);
name = argv[i];
-## repeat retrieve (name = users.login) where users.users_id = @id
+ if (id > 0)
+## repeat retrieve (name = users.login) where users.users_id = @id
+ else {
+ id = -id;
+## repeat retrieve (name = strings.string) where strings.string_id = @id
+ id = -id;
+ }
## inquire_equel(rowcount = "rowcount")
if (rowcount != 1) {
sprintf(argv[i], "#%d", id);
free(argv);
}
sq_destroy(sq);
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
##}
## char fullname[129];
login = argv[0];
- who = cl->users_id;
+ who = cl->client_id;
entity = cl->entity;
/* build fullname */
if (!strcmp(q->shortname, "gpob")) {
sid = atoi(argv[4]);
free(argv[4]);
- argv[4] = malloc(9);
+ argv[4] = malloc(256);
name = argv[4];
-## repeat retrieve (name = users.login) where users.users_id = @sid
+ if (sid > 0)
+## repeat retrieve (name = users.login) where users.users_id = @sid
+ else {
+ sid = -sid;
+## repeat retrieve (name = strings.string)
+## where strings.string_id = @sid
+ sid = -sid;
+ }
## inquire_equel(rowcount = "rowcount")
if (rowcount != 1)
sprintf(name, "#%d", sid);
/* free saved data */
free(argv[0]);
free(argv[1]);
+ free(argv[4]);
free(argv);
}
id = atoi(argv[i = q->vcnt - 2]);
free(argv[i]);
- name = argv[i] = malloc(9);
-## repeat retrieve (name = users.login) where users.users_id = @id
+ name = argv[i] = malloc(256);
+ if (id > 0)
+## repeat retrieve (name = users.login) where users.users_id = @id
+ else {
+ id = -id;
+## repeat retrieve (name = strings.string) where strings.string_id = @id
+ id = -id;
+ }
## inquire_equel(rowcount = "rowcount")
if (rowcount != 1)
sprintf(argv[i], "#%d", id);
##}
-/** followup_amtl - followup for amtl and dmfl; when adding a list
- ** member to a maillist, make member list a maillist also
- ** unless list is a user-group.
- ** Then set_list_modtime_by_id.
- **
- ** Inputs:
- ** argv[0] - list_id
- ** argv[1] - member_type
- ** argv[2] - member_id
- **
- **/
+/* followup_gnfq: Fix the directory name & modby fields
+ * argv[0] = filsys_id
+ * argv[2] = ascii(quota)
+ */
-followup_amtl(q, argv, cl)
+followup_gnfq(q, sq, v, action, actarg, cl)
struct query *q;
- char *argv[];
+ register struct save_queue *sq;
+ struct validate *v;
+ register int (*action)();
+ register int actarg;
client *cl;
##{
-## int list_id;
-## int member_id;
-## int exists, who;
-## char *entity;
-
- list_id = *(int *)argv[0];
- entity = cl->entity;
- who = cl->users_id;
-
-## range of l is list
-## repeat replace l (modtime = "now", modby = @who, modwith = @entity)
-## where l.#list_id = @list_id
-
- /* if query is not amtl or if member_type is not LIST then return */
- if (bcmp(q->shortname, "amtl", 4) || bcmp(argv[1], "LIST", 4))
- return(SMS_SUCCESS);
-
- member_id = *(int *)argv[2];
+ register int j;
+ char **argv, *malloc();
+## int id, rowcount;
+## char *name, *label;
- /* is parent list a mailing list? */
-## repeat retrieve (exists = l.maillist) where l.#list_id=@list_id
- if (!exists)
- return(SMS_SUCCESS);
+ while (sq_get_data(sq, &argv)) {
+ id = atoi(argv[3]);
+ free(argv[3]);
+ argv[3] = malloc(256);
+ name = argv[3];
+ if (id == 0) {
+ label = argv[0];
+## repeat retrieve (name = filesys.#name) where filesys.#label = @label
+ } else {
+## repeat retrieve (name = nfsphys.dir) where nfsphys.nfsphys_id = @id
+ }
+## inquire_equel(rowcount = "rowcount")
+ if (rowcount != 1) {
+ sprintf(argv[3], "#%d", id);
+ }
- /* list is not a user-group; add list to maillist table */
-## repeat replace l (maillist = 1) where l.#list_id = @member_id
+ id = atoi(argv[6]);
+ free(argv[6]);
+ argv[6] = malloc(256);
+ name = argv[6];
+ if (id > 0)
+## repeat retrieve (name = users.login) where users.users_id = @id
+ else {
+ id = -id;
+## repeat retrieve (name = strings.string) where strings.string_id = @id
+ id = -id;
+ }
+## inquire_equel(rowcount = "rowcount")
+ if (rowcount != 1) {
+ sprintf(argv[6], "#%d", id);
+ }
+ (*action)(q->vcnt, argv, actarg);
+ for (j = 0; j < q->vcnt; j++)
+ free(argv[j]);
+ free(argv);
+ }
+ sq_destroy(sq);
return(SMS_SUCCESS);
##}
fs = *(int *)argv[0];
user = *(int *)argv[1];
quota = atoi(argv[2]);
- who = cl->users_id;
+ who = cl->client_id;
entity = cl->entity;
## repeat replace nq (modtime = "now", modby = @who, modwith = @entity)
## where nq.filsys_id = @fs and nq.users_id = @user
## repeat replace nfsphys (allocated = nfsphys.allocated + @quota)
## where nfsphys.nfsphys_id = filesys.#phys_id and filesys.filsys_id = @fs
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
##}
id = atoi(argv[i = q->vcnt - 2]);
free(argv[i]);
- name = argv[i] = malloc(9);
-## repeat retrieve (name = users.login) where users.users_id = @id
+ name = argv[i] = malloc(256);
+ if (id > 0)
+## repeat retrieve (name = users.login) where users.users_id = @id
+ else {
+ id = -id;
+## repeat retrieve (name = strings.string) where strings.string_id = @id
+ id = -id;
+ }
## inquire_equel(rowcount = "rowcount")
if (rowcount != 1)
sprintf(argv[i], "#%d", id);
id = atoi(argv[4]);
free(argv[4]);
- name = argv[4] = malloc(9);
-## repeat retrieve (name = users.login) where users.users_id = @id
+ name = argv[4] = malloc(256);
+ if (id > 0)
+## repeat retrieve (name = users.login) where users.users_id = @id
+ else {
+ id = -id;
+## repeat retrieve (name = strings.string) where strings.string_id = @id
+ id = -id;
+ }
## inquire_equel(rowcount = "rowcount")
if (rowcount != 1)
sprintf(argv[4], "#%d", id);
## repeat retrieve (id = users.pop_id, potype = users.#potype)
## where users.users_id = @user
+ if (ingres_errno) return(sms_errcode);
if (!strcmp(strtrim(potype), "POP"))
set_pop_usage(id, -1);
## where users.users_id = @user
set_pop_usage(id, 1);
} else if (!strcmp(argv[1], "SMTP")) {
+ if (index(box, '/') || index(box, '|'))
+ return(SMS_BAD_CHAR);
## range of s is strings
## repeat retrieve (id = s.string_id) where s.string = @box
## inquire_equel (rowcount = "rowcount")
set_pobox_modtime(q, argv, cl);
## repeat replace tblstats (updates = tblstats.updates + 1, modtime = "now")
## where tblstats.#table = "users"
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
##}
char *argv[13], *malloc(), *realloc();
## char *name, acl_type[9], listname[33], active[5], public[5], hidden[5];
## char maillist[5], group[5], gid[6], acl_name[33], desc[256], modtime[27];
-## char modby[9], modwith[9];
+## char modby[256], modwith[9];
## int id, rowcount, acl_id, hid, modby_id;
int returned;
struct save_queue *sq, *sq_create();
sq_save_data(sq, id);
rowcount++;
## }
+ if (ingres_errno) return(sms_errcode);
if (rowcount == 0)
return(SMS_NO_MATCH);
## desc = l.#desc, modtime = l.#modtime, modby_id = l.#modby,
## modwith =l.#modwith)
## where l.list_id = @id
+ if (ingres_errno) return(sms_errcode);
if (atoi(gid) == -1)
argv[6] = UNIQUE_GID;
} else
strcpy(acl_name, "???");
-## repeat retrieve (modby = users.login) where users.users_id = @modby_id
+ if (modby_id > 0)
+## repeat retrieve (modby = users.login) where users.users_id = @modby_id
+ else {
+ modby_id = -modby_id;
+## repeat retrieve (modby = strings.string)
+## where strings.string_id = @modby_id
+ modby_id = -modby_id;
+ }
## inquire_equel(rowcount = "rowcount")
if (rowcount != 1)
- sprintf(modby, "#%d", id);
+ sprintf(modby, "#%d", modby_id);
+ if (ingres_errno) return(sms_errcode);
sms_trim_args(q->vcnt, argv);
returned++;
}
sq_destroy(sq);
+ if (ingres_errno) return(sms_errcode);
## repeat replace tblstats (retrieves = tblstats.retrieves + 1)
## where tblstats.#table = "list"
##}
+/* Add_member_to_list: do list flattening as we go! MAXLISTDEPTH is
+ * how many different ancestors a member is allowed to have.
+ */
+
+#define MAXLISTDEPTH 100
+
+int add_member_to_list(q, argv, cl)
+ struct query *q;
+ char **argv;
+ client *cl;
+##{
+## int id, lid, mid, exists, error, who;
+## char *mtype, dtype[9], buf[256], *entity;
+ int ancestors[MAXLISTDEPTH], acount, a;
+ int descendants[MAXLISTDEPTH], dcount, d;
+ char *dtypes[MAXLISTDEPTH];
+ char *iargv[3];
+
+## range of m is imembers
+ lid = *(int *)argv[0];
+ mtype = argv[1];
+ mid = *(int *)argv[2];
+## repeat retrieve (exists = any(m.list_id where m.list_id=@lid and
+## m.member_id = @mid and m.member_type = @mtype
+## and m.direct = 1))
+ if (exists)
+ return(SMS_EXISTS);
+ if (!strcasecmp(mtype, "STRING")) {
+## repeat retrieve (buf = strings.string) where strings.string_id = @mid
+ if (index(buf, '/') || index(buf, '|'))
+ return(SMS_BAD_CHAR);
+ }
+
+ ancestors[0] = lid;
+ acount = 1;
+## repeat retrieve (id = m.list_id)
+## where m.member_id = @lid and m.member_type = "LIST" {
+ ancestors[acount++] = id;
+ if (acount >= MAXLISTDEPTH) {
+## endretrieve
+ }
+## }
+ if (ingres_errno) return(sms_errcode);
+ if (acount >= MAXLISTDEPTH) {
+ return(SMS_INTERNAL);
+ }
+ descendants[0] = mid;
+ dtypes[0] = mtype;
+ dcount = 1;
+ error = 0;
+ if (!strcmp(mtype, "LIST")) {
+## repeat retrieve (id = m.member_id, dtype = m.member_type)
+## where m.list_id = @mid {
+ switch (dtype[0]) {
+ case 'L':
+ dtypes[dcount] = "LIST";
+ break;
+ case 'U':
+ dtypes[dcount] = "USER";
+ break;
+ case 'S':
+ dtypes[dcount] = "STRING";
+ break;
+ case 'K':
+ dtypes[dcount] = "KERBEROS";
+ break;
+ default:
+ error++;
+## endretrieve
+ }
+ descendants[dcount++] = id;
+ if (dcount >= MAXLISTDEPTH) {
+ error++;
+## endretrieve
+ }
+## }
+ if (ingres_errno) return(sms_errcode);
+ if (error)
+ return(SMS_INTERNAL);
+ }
+ for (a = 0; a < acount; a++) {
+ lid = ancestors[a];
+ for (d = 0; d < dcount; d++) {
+ mid = descendants[d];
+ mtype = dtypes[d];
+ if (mid == lid && !strcmp(mtype, "LIST")) {
+ return(SMS_LISTLOOP);
+ }
+## repeat retrieve (exists = any(m.ref_count where m.list_id = @lid
+## and m.member_id = @mid
+## and m.member_type = @mtype))
+ if (exists) {
+ if (a == 0 && d == 0)
+## replace m (ref_count = m.ref_count+1, direct = 1)
+## where m.list_id = lid and m.member_id = mid and
+## m.member_type = mtype
+ else
+## replace m (ref_count = m.ref_count+1)
+## where m.list_id = lid and m.member_id = mid and
+## m.member_type = mtype
+ } else {
+ incremental_clear_before();
+ if (a == 0 && d == 0)
+## append imembers (list_id=lid, member_id = mid, direct = 1,
+## member_type=mtype, ref_count = 1)
+ else
+## append imembers (list_id=lid, member_id = mid,
+## member_type=mtype, ref_count = 1)
+ iargv[0] = (char *)lid;
+ iargv[1] = mtype;
+ iargv[2] = (char *)mid;
+ incremental_after("members", 0, iargv);
+ }
+ }
+ }
+ lid = *(int *)argv[0];
+ entity = cl->entity;
+ who = cl->client_id;
+## repeat replace list (modtime = "now", modby = @who, modwith = @entity)
+## where list.#list_id = @lid
+ if (ingres_errno) return(sms_errcode);
+ return(SMS_SUCCESS);
+##}
+
+
+/* Delete_member_from_list: do list flattening as we go!
+ */
+
+int delete_member_from_list(q, argv, cl)
+ struct query *q;
+ char **argv;
+ client *cl;
+##{
+## int id, lid, mid, cnt, exists, error, who;
+## char *mtype, dtype[9], *entity;
+ int ancestors[MAXLISTDEPTH], acount, a;
+ int descendants[MAXLISTDEPTH], dcount, d;
+ char *dtypes[MAXLISTDEPTH];
+ char *iargv[3];
+
+## range of m is imembers
+ lid = *(int *)argv[0];
+ mtype = argv[1];
+ mid = *(int *)argv[2];
+## repeat retrieve (exists = any(m.list_id where m.list_id=@lid and
+## m.member_id = @mid and m.member_type = @mtype
+## and m.direct = 1))
+ if (ingres_errno) return(sms_errcode);
+ if (!exists)
+ return(SMS_NO_MATCH);
+ ancestors[0] = lid;
+ acount = 1;
+## repeat retrieve (id = m.list_id)
+## where m.member_id = @lid and m.member_type = "LIST" {
+ ancestors[acount++] = id;
+ if (acount >= MAXLISTDEPTH)
+## endretrieve
+## }
+ if (ingres_errno) return(sms_errcode);
+ if (acount >= MAXLISTDEPTH)
+ return(SMS_INTERNAL);
+ descendants[0] = mid;
+ dtypes[0] = mtype;
+ dcount = 1;
+ error = 0;
+ if (!strcmp(mtype, "LIST")) {
+## repeat retrieve (id = m.member_id, dtype = m.member_type)
+## where m.list_id = @mid {
+ switch (dtype[0]) {
+ case 'L':
+ dtypes[dcount] = "LIST";
+ break;
+ case 'U':
+ dtypes[dcount] = "USER";
+ break;
+ case 'S':
+ dtypes[dcount] = "STRING";
+ break;
+ case 'K':
+ dtypes[dcount] = "KERBEROS";
+ break;
+ default:
+ error++;
+## endretrieve
+ }
+ descendants[dcount++] = id;
+ if (dcount >= MAXLISTDEPTH)
+## endretrieve
+## }
+ if (ingres_errno) return(sms_errcode);
+ if (error)
+ return(SMS_INTERNAL);
+ }
+ for (a = 0; a < acount; a++) {
+ lid = ancestors[a];
+ for (d = 0; d < dcount; d++) {
+ mid = descendants[d];
+ mtype = dtypes[d];
+ if (mid == lid && !strcmp(mtype, "LIST")) {
+ return(SMS_LISTLOOP);
+ }
+## repeat retrieve (cnt = m.ref_count)
+## where m.list_id = @lid and m.member_id = @mid
+## and m.member_type = @mtype
+ if (cnt <= 1) {
+ iargv[0] = (char *)lid;
+ iargv[1] = mtype;
+ iargv[2] = (char *)mid;
+ incremental_before("members", 0, iargv);
+## delete m where m.list_id = lid and m.member_id = mid and
+## m.member_type = mtype
+ incremental_clear_after();
+ } else if (a == 0 && d == 0) {
+## replace m (ref_count = m.ref_count-1, direct = 0)
+## where m.list_id = lid and m.member_id = mid and
+## m.member_type = mtype
+ } else {
+## replace m (ref_count = m.ref_count-1)
+## where m.list_id = lid and m.member_id = mid and
+## m.member_type = mtype
+ }
+ }
+ }
+ lid = *(int *)argv[0];
+ entity = cl->entity;
+ who = cl->client_id;
+## repeat replace list (modtime = "now", modby = @who, modwith = @entity)
+## where list.#list_id = @lid
+ if (ingres_errno) return(sms_errcode);
+ return(SMS_SUCCESS);
+##}
+
+
/* get_ace_use - given a type and a name, return a type and a name.
* The ace_type is one of "LIST", "USER", "RLIST", or "RUSER" in argv[0],
* and argv[1] will contain the ID of the entity in question. The R*
## int aid, listid, id;
struct save_queue *sq, *sq_create();
+## range of m is imembers
atype = argv[0];
aid = *(int *)argv[1];
if (!strcmp(atype, "LIST") || !strcmp(atype, "USER") ||
if (!strcmp(atype, "RLIST")) {
sq_save_data(sq, aid);
/* get all the list_id's of containing lists */
-## range of m is members
- while (sq_get_data(sq, &id)) {
-## repeat retrieve (listid = m.list_id)
+## range of m is imembers
+## repeat retrieve (listid = m.list_id)
## where m.member_type = "LIST" and m.member_id = @id {
- sq_save_unique_data(sq, listid);
-## }
- }
+ sq_save_unique_data(sq, listid);
+## }
/* now process each one */
while (sq_get_data(sq, &id)) {
if (get_ace_internal("LIST", id, action, actarg) == SMS_SUCCESS)
}
if (!strcmp(atype, "RUSER")) {
-## range of m is members
## repeat retrieve (listid = m.list_id)
## where m.member_type = "USER" and m.member_id = @aid {
sq_save_data(sq, listid);
## }
- /* get all the list_id's of containing lists */
- while (sq_get_data(sq, &id)) {
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "LIST" and m.member_id = @id {
- sq_save_unique_data(sq, listid);
-## }
- }
/* now process each one */
while (sq_get_data(sq, &id)) {
if (get_ace_internal("LIST", id, action, actarg) == SMS_SUCCESS)
}
if (!strcmp(atype, "RKERBERO")) {
-## range of m is members
## repeat retrieve (listid = m.list_id)
## where m.member_type = "KERBEROS" and m.member_id = @aid {
sq_save_data(sq, listid);
## }
- /* get all the list_id's of containing lists */
- while (sq_get_data(sq, &id)) {
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "LIST" and m.member_id = @id {
- sq_save_unique_data(sq, listid);
-## }
- }
/* now process each one */
while (sq_get_data(sq, &id)) {
if (get_ace_internal("LIST", id, action, actarg) == SMS_SUCCESS)
}
sq_destroy(sq);
+ if (ingres_errno) return(sms_errcode);
if (!found) return(SMS_NO_MATCH);
return(SMS_SUCCESS);
##}
int (*action)();
int actarg;
##{
- int found = 0;
+ int found = 0, direct = 1;
+ char *rargv[6];
## char *atype;
## int aid, listid, id;
- struct save_queue *sq, *sq_create();
+## char name[33], active[5], public[5], hidden[5], maillist[5], group[5];
atype = argv[0];
aid = *(int *)argv[1];
- if (!strcmp(atype, "LIST") ||
- !strcmp(atype, "USER") ||
- !strcmp(atype, "STRING") ||
- !strcmp(atype, "KERBEROS")) {
- return(glom_internal(atype, aid, action, actarg));
- }
-
- sq = sq_create();
if (!strcmp(atype, "RLIST")) {
- sq_save_data(sq, aid);
- /* get all the list_id's of containing lists */
-## range of m is members
- while (sq_get_data(sq, &id)) {
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "LIST" and m.member_id = @id {
- sq_save_unique_data(sq, listid);
-## }
- }
- /* now process each one */
- while (sq_get_data(sq, &id)) {
- if (glom_internal("LIST", id, action, actarg) == SMS_SUCCESS)
- found++;
- }
+ atype = "LIST";
+ direct = 0;
}
-
if (!strcmp(atype, "RUSER")) {
-## range of m is members
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "USER" and m.member_id = @aid {
- sq_save_data(sq, listid);
-## }
- /* get all the list_id's of containing lists */
- while (sq_get_data(sq, &id)) {
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "LIST" and m.member_id = @id {
- sq_save_unique_data(sq, listid);
-## }
- }
- /* now process each one */
- while (sq_get_data(sq, &id)) {
- if (glom_internal("LIST", id, action, actarg) == SMS_SUCCESS)
- found++;
- }
- if (glom_internal("USER", aid, action, actarg) == SMS_SUCCESS)
- found++;
+ atype = "USER";
+ direct = 0;
}
-
if (!strcmp(atype, "RSTRING")) {
-## range of m is members
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "STRING" and m.member_id = @aid {
- sq_save_data(sq, listid);
-## }
- /* get all the list_id's of containing lists */
- while (sq_get_data(sq, &id)) {
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "LIST" and m.member_id = @id {
- sq_save_unique_data(sq, listid);
-## }
- }
- /* now process each one */
- while (sq_get_data(sq, &id)) {
- if (glom_internal("LIST", id, action, actarg) == SMS_SUCCESS)
- found++;
- }
- if (glom_internal("STRING", aid, action, actarg) == SMS_SUCCESS)
- found++;
+ atype = "STRING";
+ direct = 0;
}
-
- if (!strcmp(atype, "RKERBERO")) {
-## range of m is members
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "KERBEROS" and m.member_id = @aid {
- sq_save_data(sq, listid);
-## }
- /* get all the list_id's of containing lists */
- while (sq_get_data(sq, &id)) {
-## repeat retrieve (listid = m.list_id)
-## where m.member_type = "LIST" and m.member_id = @id {
- sq_save_unique_data(sq, listid);
-## }
- }
- /* now process each one */
- while (sq_get_data(sq, &id)) {
- if (glom_internal("LIST", id, action, actarg) == SMS_SUCCESS)
- found++;
- }
- if (glom_internal("KERBEROS", aid, action, actarg) == SMS_SUCCESS)
- found++;
+ if (!strcmp(atype, "RKERBEROS")) {
+ atype = "KERBEROS";
+ direct = 0;
}
-## repeat replace tblstats (retrieves = tblstats.retrieves + 1)
-## where tblstats.#table = "members"
- sq_destroy(sq);
- if (!found) return(SMS_NO_MATCH);
- return(SMS_SUCCESS);
-##}
-
-
-/* This looks up a single list, user, or string as a member. atype must be
- * "USER", "LIST", or "STRING" and aid is the ID of the corresponding object.
- * This is used by get_lists_of_members above.
- */
-
-##glom_internal(atype, aid, action, actarg)
-## char *atype;
-## int aid;
- int (*action)();
- int actarg;
-##{
- char *rargv[6];
- int found = 0;
-## char name[33], active[5], public[5], hidden[5], maillist[5], group[5];
-
rargv[0] = name;
rargv[1] = active;
rargv[2] = public;
rargv[3] = hidden;
rargv[4] = maillist;
rargv[5] = group;
-## repeat retrieve (name = list.#name, active = text(list.#active),
+ if (direct) {
+## repeat retrieve (name = list.#name, active = text(list.#active),
+## public = text(list.#public), hidden = text(list.#hidden),
+## maillist = text(list.#maillist), group = text(list.#group))
+## where list.list_id = m.list_id and m.direct = 1 and
+## m.member_type = @atype and m.member_id = @aid {
+ (*action)(6, rargv, actarg);
+ found++;
+## }
+ } else {
+## repeat retrieve (name = list.#name, active = text(list.#active),
## public = text(list.#public), hidden = text(list.#hidden),
## maillist = text(list.#maillist), group = text(list.#group))
## where list.list_id = m.list_id and
## m.member_type = @atype and m.member_id = @aid {
(*action)(6, rargv, actarg);
found++;
-## }
+## }
+ }
+ if (ingres_errno) return(sms_errcode);
if (!found) return(SMS_NO_MATCH);
return(SMS_SUCCESS);
##}
targv[0] = "USER";
targv[1] = member_name;
-## range of m is members
+## range of m is imembers
## repeat retrieve (member_name = users.login)
## where m.#list_id = @list_id and m.member_type = "USER"
-## and m.member_id = users.users_id
+## and m.member_id = users.users_id and m.direct = 1
## sort by #member_name
## {
(*action)(2, targv, actarg);
## }
+ if (ingres_errno) return(sms_errcode);
targv[0] = "LIST";
## repeat retrieve (member_name = list.name)
## where m.#list_id = @list_id and m.member_type = "LIST"
-## and m.member_id = list.#list_id
+## and m.member_id = list.#list_id and m.direct = 1
## sort by #member_name
## {
(*action)(2, targv, actarg);
## }
+ if (ingres_errno) return(sms_errcode);
targv[0] = "STRING";
## repeat retrieve (member_name = strings.string)
## where m.#list_id = @list_id and m.member_type = "STRING"
-## and m.member_id = strings.string_id
+## and m.member_id = strings.string_id and m.direct = 1
## sort by #member_name
## {
(*action)(2, targv, actarg);
## }
+ if (ingres_errno) return(sms_errcode);
targv[0] = "KERBEROS";
## repeat retrieve (member_name = strings.string)
## where m.#list_id = @list_id and m.member_type = "KERBEROS"
-## and m.member_id = strings.string_id
+## and m.member_id = strings.string_id and m.direct = 1
## sort by #member_name
## {
(*action)(2, targv, actarg);
## }
+ if (ingres_errno) return(sms_errcode);
-## repeat replace tblstats (retrieves = tblstats.retrieves + 1)
-## where tblstats.#table = "members"
return(SMS_SUCCESS);
##}
list = *(int *)argv[0];
rargv[0] = countbuf;
-## repeat retrieve (ct = count(members.list_id where members.list_id = @list))
+## repeat retrieve (ct = count(imembers.list_id
+## where imembers.list_id = @list and
+## imembers.direct = 1))
+ if (ingres_errno) return(sms_errcode);
sprintf(countbuf, "%d", ct);
(*action)(1, rargv, actarg);
-## repeat replace tblstats (retrieves = tblstats.retrieves + 1)
-## where tblstats.#table = "members"
return(SMS_SUCCESS);
##}
## retrieve (name = rvar.rfield) where qual {
(*action)(1, rargv, actarg);
## }
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount")
## repeat replace tblstats (retrieves = tblstats.retrieves + 1)
## where tblstats.#table = @rtbl
## retrieve (sname = sh.service, mname = machine.name) where qual {
(*action)(2, rargv, actarg);
## }
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount")
## repeat replace tblstats (retrieves = tblstats.retrieves + 1)
## where tblstats.#table = "serverhosts"
## char *login, dir[65], *entity, *directory, machname[33];
## int who, rowcount, mid, uid, users_id, flag, utype, nid, list_id, quota;
## int size, alloc, pid, m_id;
+ char buffer[256], *aargv[3];
int maxsize;
entity = cl->entity;
- who = cl->users_id;
+ who = cl->client_id;
uid = atoi(argv[0]);
login = argv[1];
/* find user */
## repeat retrieve (users_id = u.#users_id)
-## where u.#uid = @uid and u.status = 0
+## where u.#uid = @uid and (u.status = 0 or u.status = 5)
## inquire_equel(rowcount = "rowcount");
if (rowcount == 0)
return(SMS_NO_MATCH);
return(SMS_NOT_UNIQUE);
/* check new login name */
-## repeat retrieve (flag = any(u.#login where u.#login = @login))
+## repeat retrieve (flag = any(u.#login where u.#login = @login and
+## u.#users_id != users_id))
if (ingres_errno) return(sms_errcode);
if (flag) return(SMS_IN_USE);
## repeat retrieve (flag = any(l.#name where l.#name = @login))
## repeat retrieve (mid = sh.mach_id, machname = m.name)
## where sh.service = "POP" and m.mach_id = sh.mach_id and
## sh.value2 - sh.value1 = max(sh.value2-sh.value1 where sh.service="POP")
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount");
if (rowcount == 0)
return(SMS_NO_POBOX);
/* change login name, set pobox */
+ sprintf(buffer, "u.users_id = %d", users_id);
+ incremental_before("users", buffer, 0);
## repeat replace u (#login = @login, status = 2, modtime = "now",
## modby = @who, modwith = @entity, potype="POP",
## pop_id = @mid, pmodtime="now", pmodby=@who,
## pmodwith=@entity)
## where u.#users_id = @users_id
## inquire_equel(rowcount = "rowcount");
+ if (ingres_errno) return(sms_errcode);
if (rowcount != 1)
return(SMS_INTERNAL);
set_pop_usage(mid, 1);
com_err(whoami, 0, "set login name to %s and pobox to %s", login,
- trim(machname));
+ strtrim(machname));
+ incremental_after("users", buffer, 0);
/* create group list */
if (set_next_object_id("gid", "list"))
if (set_next_object_id("list_id", "list"))
return(SMS_NO_ID);
## repeat retrieve (list_id = values.value) where values.name = "list_id"
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount");
if (rowcount != 1)
return(SMS_INTERNAL);
+ incremental_clear_before();
## repeat append list (name = @login, #list_id = @list_id, active = 1,
## public = 0, hidden = 0, maillist = 0, group = 1,
## #gid = values.value, desc = "User Group",
## acl_type = "USER", acl_id = @users_id, modtime = "now",
## modby = @who, modwith = @entity)
## where values.name = "gid"
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount");
if (rowcount != 1)
return(SMS_INTERNAL);
-## repeat append members (#list_id = @list_id, member_type = "USER",
-## member_id = @users_id)
+ sprintf(buffer, "l.list_id = %d", list_id);
+ incremental_after("list", buffer, 0);
+ aargv[0] = (char *) list_id;
+ aargv[1] = "USER";
+ aargv[2] = (char *) users_id;
+ incremental_clear_before();
+## repeat append imembers (#list_id = @list_id, member_type = "USER",
+## member_id = @users_id, ref_count = 1, direct = 1)
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount");
if (rowcount != 1)
return(SMS_INTERNAL);
+ incremental_after("members", 0, aargv);
com_err(whoami, 0, "group list created");
/* decide where to put filesystem */
m_id = mid;
}
## }
+ if (ingres_errno) return(sms_errcode);
if (maxsize == 0)
return(SMS_NO_FILESYS);
/* create filesystem */
if (set_next_object_id("filsys_id", "filesys"))
return(SMS_NO_ID);
+ incremental_clear_before();
## repeat append filesys (filsys_id = values.value, phys_id = @pid,
## label = @login, type = "NFS", mach_id = @m_id,
## name = @directory + "/" + @login,
## lockertype = "HOMEDIR", modtime = "now",
## modby = @who, modwith = @entity)
## where values.name = "filsys_id"
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount");
if (rowcount != 1)
return(SMS_INTERNAL);
+ incremental_after("filesys",
+ "fs.filsys_id = values.value and values.name = \"filsys_id\"",
+ 0);
com_err(whoami, 0, "filesys created on mach %d in %s/%s", m_id,
directory, login);
/* set quota */
## repeat retrieve (quota = values.value) where values.name = "def_quota"
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount");
if (rowcount != 1)
return(SMS_NO_QUOTA);
+ incremental_clear_before();
## repeat append nfsquota (#users_id = @users_id, filsys_id = values.value,
## #quota = @quota, phys_id = @pid, modtime = "now",
## modby = @who, modwith = @entity)
## where values.name = "filsys_id"
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount");
if (rowcount != 1)
return(SMS_INTERNAL);
## repeat replace nfsphys (allocated = nfsphys.allocated + @quota)
## where nfsphys.nfsphys_id = filesys.#phys_id and
## filesys.filsys_id = values.value and values.name = "filsys_id"
+ if (ingres_errno) return(sms_errcode);
## inquire_equel(rowcount = "rowcount");
if (rowcount != 1)
return(SMS_INTERNAL);
+ aargv[0] = login;
+ aargv[1] = login;
+ sprintf(buffer, "nq.users_id = %d and nq.filsys_id = values.value and values.name = \"filsys_id\"", users_id);
+ incremental_after("nfsquota", buffer, aargv);
com_err(whoami, 0, "quota of %d assigned", quota);
+ if (ingres_errno) return(sms_errcode);
## repeat replace tblstats (updates = tblstats.updates + 1, modtime = "now")
## where tblstats.table = "users"
## repeat replace tblstats (appends = tblstats.appends + 1, modtime = "now")
## where tblstats.table = "list" or tblstats.table = "filesys" or
## tblstats.table = "nfsquota"
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
##}
## repeat replace sh (value1 = sh.value1 + @n)
## where sh.service = "POP" and sh.#mach_id = @mach_id
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
##}
vo++;
}
+ if (ingres_errno) return(sms_errcode);
return(SMS_SUCCESS);
}
##}
-/* This looks up a login name and returns the SMS internal ID. It is used
- * by authenticate to put the users_id in the client structure.
- */
-
-int get_users_id(name)
-char *name;
-##{
-## int id, rowcount;
-## char *login;
-
- login = name;
-
-## range of u is users
-## repeat retrieve (id = u.#users_id) where u.#login = @login
-## inquire_equel (rowcount = "rowcount")
-
- if (rowcount == 1)
- return(id);
- else
- return(0);
-##}
-
-
/* Check the database at startup time. For now this just resets the
* inprogress flags that the DCM uses.
*/
andersk / moira.git / blobdiff