WHERE users_id = :user;
if (dbms_errno)
return mr_errcode;
- if (!strcmp(strtrim(potype), "POP"))
+ if (!strcmp(strtrim(potype), "POP") ||
+ (!strcmp(strtrim(potype), "SPLIT") && id))
set_pop_usage(id, -1);
if (!strcmp(argv[1], "POP"))
WHERE users_id = :user;
set_pop_usage(id, 1);
}
- else if (!strcmp(argv[1], "SMTP"))
+ else if (!strcmp(argv[1], "SMTP") || !strcmp(argv[1], "SPLIT"))
{
if (strchr(box, '/') || strchr(box, '|'))
return MR_BAD_CHAR;
id = add_string(box);
else if (status)
return status;
- EXEC SQL UPDATE users SET potype = 'SMTP', box_id = :id
+
+ /* If going from SMTP or NONE to SPLIT, make sure we have a valid
+ * POP or IMAP box.
+ */
+ if ((!strcmp(potype, "SMTP") || !strcmp(potype, "NONE")) &&
+ !strcmp(argv[1], "SPLIT"))
+ {
+ status = set_pobox_pop(q, argv, cl);
+ if (status)
+ return status;
+ }
+ strlcpy(potype, argv[1], sizeof(potype));
+ EXEC SQL UPDATE users SET potype = :potype, box_id = :id
WHERE users_id = :user;
}
else if (!strcmp(argv[1], "IMAP"))
if (sqlca.sqlerrd[2] == 0)
return MR_MACHINE;
EXEC SQL UPDATE users SET potype = 'POP' WHERE users_id = :id;
- if (strcmp(strtrim(type), "POP"))
+ if (!strcmp(strtrim(type), "POP"))
set_pop_usage(mid, 1);
}
else
* how many different ancestors a member is allowed to have.
*/
-#define MAXLISTDEPTH 1024
+#define MAXLISTDEPTH 2048
int add_member_to_list(struct query *q, char **argv, client *cl)
{
{
EXEC SQL INSERT INTO imembers
(list_id, member_type, member_id, tag, direct, ref_count)
- VALUES (:lid, :mtype, :mid, :tag, 1, 1);
+ VALUES (:lid, :mtype, :mid, :tag, 1, :ref);
}
else
{
EXEC SQL INSERT INTO imembers
(list_id, member_type, member_id, tag, direct, ref_count)
- VALUES (:lid, :mtype, :mid, :tag, 0, 1);
+ VALUES (:lid, :mtype, :mid, :tag, 0, :ref);
}
iargv[0] = (char *)lid;
iargv[1] = mtype;
return MR_SUCCESS;
}
+int tag_member_of_list(struct query *q, char **argv, client *cl)
+{
+ EXEC SQL BEGIN DECLARE SECTION;
+ int lid, mid, cnt, tag;
+ char *mtype;
+ EXEC SQL END DECLARE SECTION;
+ char *iargv[3];
+
+ lid = *(int *)argv[0];
+ mtype = argv[1];
+ mid = *(int *)argv[2];
+ tag = *(int *)argv[3];
+
+ EXEC SQL SELECT COUNT(member_id) INTO :cnt FROM imembers
+ WHERE member_id = :mid AND member_type = :mtype AND
+ list_id = :lid;
+ if (dbms_errno)
+ return mr_errcode;
+ if (cnt == 0)
+ return MR_NO_MATCH;
+
+ incremental_clear_before();
+ EXEC SQL UPDATE imembers SET tag = :tag WHERE list_id = :lid
+ AND member_type = :mtype AND member_id = :mid;
+ if (dbms_errno)
+ return mr_errcode;
+
+ iargv[0] = (char *)lid;
+ iargv[1] = mtype;
+ iargv[2] = (char *)mid;
+ incremental_after(IMEMBERS_TABLE, 0, iargv);
+
+ return MR_SUCCESS;
+}
/* Don't allow someone to add someone to a list which is the acl of a
* query unless they're on the list acl, even if they're on the amtl
int acl_access_check(int list_id, client *cl)
{
EXEC SQL BEGIN DECLARE SECTION;
- int c1, c2, lid = list_id, acl_id;
- char acl_type[LIST_ACL_TYPE_SIZE];
+ int c1, c2, lid = list_id, acl_id, memacl_id;
+ char acl_type[LIST_ACL_TYPE_SIZE], memacl_type[LIST_ACL_TYPE_SIZE];
EXEC SQL END DECLARE SECTION;
/* Check if the list is directly a capacl */
if (cl->proxy_id)
return 1;
- EXEC SQL SELECT acl_type, acl_id INTO :acl_type, :acl_id
+ EXEC SQL SELECT acl_type, acl_id, memacl_type, memacl_id
+ INTO :acl_type, :acl_id, :memacl_type, :memacl_id
FROM list WHERE list_id=:lid;
- return !find_member(acl_type, acl_id, cl);
+
+ if (!find_member(acl_type, acl_id, cl))
+ {
+ if (!find_member(memacl_type, memacl_id, cl))
+ return 1;
+ }
+
+ return 0;
}
char *rargv[2];
int found = 0;
EXEC SQL BEGIN DECLARE SECTION;
- char name[LIST_NAME_SIZE], *type = atype;
+ char name[MAX_FIELD_WIDTH], *type = atype;
int id = aid;
EXEC SQL END DECLARE SECTION;
rargv[0] = "LIST";
EXEC SQL DECLARE csr113 CURSOR FOR
SELECT name FROM list
- WHERE acl_type = :type AND acl_id = :id;
+ WHERE (acl_type = :type AND acl_id = :id)
+ OR (memacl_type = :type AND memacl_id = :id);
if (dbms_errno)
return mr_errcode;
EXEC SQL OPEN csr113;
SELECT name FROM machine m, hostaccess ha
WHERE m.mach_id = ha.mach_id AND ha.acl_type = :type
AND ha.acl_id = :id;
- if (dbms_errno)
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL OPEN csr115;
+ if (dbms_errno)
+ return mr_errcode;
+ while (1)
+ {
+ EXEC SQL FETCH csr115 INTO :name;
+ if (sqlca.sqlcode)
+ break;
+ (*action)(2, rargv, actarg);
+ found++;
+ }
+ EXEC SQL CLOSE csr115;
+
+ rargv[0] = "MACHINE";
+ EXEC SQL DECLARE csr115a CURSOR FOR
+ SELECT name FROM machine m
+ WHERE m.owner_type = :type
+ AND m.owner_id = :id;
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL OPEN csr115a;
+ if (dbms_errno)
+ return mr_errcode;
+ while (1)
+ {
+ EXEC SQL FETCH csr115a INTO :name;
+ if (sqlca.sqlcode)
+ break;
+ (*action)(2, rargv, actarg);
+ found++;
+ }
+ EXEC SQL CLOSE csr115a;
+
+ rargv[0] = "ZEPHYR";
+ EXEC SQL DECLARE csr116 CURSOR FOR
+ SELECT class FROM zephyr z
+ WHERE z.xmt_type = :type AND z.xmt_id = :id
+ OR z.sub_type = :type AND z.sub_id = :id
+ OR z.iws_type = :type AND z.iws_id = :id
+ OR z.iui_type = :type AND z.iui_id = :id
+ OR z.owner_type = :type AND z.owner_id = :id;
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL OPEN csr116;
+ if (dbms_errno)
+ return mr_errcode;
+ while (1)
+ {
+ EXEC SQL FETCH csr116 INTO :name;
+ if (sqlca.sqlcode)
+ break;
+ (*action)(2, rargv, actarg);
+ found++;
+ }
+ EXEC SQL CLOSE csr116;
+
+ if (!found)
+ return MR_NO_MATCH;
+ return MR_SUCCESS;
+}
+
+/* ghbo_internal */
+int ghbo_internal(char *atype, int aid,
+ int (*action)(int, char *[], void *), void *actarg)
+{
+ char *rargv[1];
+ int found = 0;
+ EXEC SQL BEGIN DECLARE SECTION;
+ char name[MACHINE_NAME_SIZE], *type = atype;
+ int id = aid;
+ EXEC SQL END DECLARE SECTION;
+
+ rargv[0] = name;
+ EXEC SQL DECLARE csr115b CURSOR FOR
+ SELECT name FROM machine m
+ WHERE m.owner_type = :type
+ AND m.owner_id = :id;
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL OPEN csr115b;
+ if (dbms_errno)
+ return mr_errcode;
+ while (1)
+ {
+ EXEC SQL FETCH csr115b INTO :name;
+ if (sqlca.sqlcode)
+ break;
+ (*action)(1, rargv, actarg);
+ found++;
+ }
+ EXEC SQL CLOSE csr115b;
+
+ if (!found)
+ return MR_NO_MATCH;
+ return MR_SUCCESS;
+}
+
+/* get_host_by_owner - like gaus but limited to hosts */
+int get_host_by_owner(struct query *q, char *argv[], client *cl,
+ int (*action)(int, char *[], void *), void *actarg)
+{
+ int found = 0;
+ EXEC SQL BEGIN DECLARE SECTION;
+ char *atype;
+ int aid, listid, id;
+ EXEC SQL END DECLARE SECTION;
+ struct save_queue *sq;
+
+ atype = argv[0];
+ aid = *(int *)argv[1];
+ if (!strcmp(atype, "LIST") || !strcmp(atype, "USER") ||
+ !strcmp(atype, "KERBEROS"))
+ return ghbo_internal(atype, aid, action, actarg);
+
+ sq = sq_create();
+ if (!strcmp(atype, "RLIST"))
+ {
+ sq_save_data(sq, (void *)aid);
+ /* get all the list_id's of containing lists */
+ EXEC SQL DECLARE csr107q CURSOR FOR
+ SELECT list_id FROM imembers
+ WHERE member_type = 'LIST' AND member_id = :aid;
+ if (dbms_errno)
return mr_errcode;
- EXEC SQL OPEN csr115;
- if (dbms_errno)
+ EXEC SQL OPEN csr107q;
+ if (dbms_errno)
return mr_errcode;
- while (1)
- {
- EXEC SQL FETCH csr115 INTO :name;
- if (sqlca.sqlcode)
- break;
- (*action)(2, rargv, actarg);
+ while (1)
+ {
+ EXEC SQL FETCH csr107q INTO :listid;
+ if (sqlca.sqlcode)
+ break;
+ sq_save_unique_data(sq, (void *)listid);
+ }
+ EXEC SQL CLOSE csr107q;
+ /* now process each one */
+ while (sq_get_data(sq, &id))
+ {
+ if (ghbo_internal("LIST", id, action, actarg) == MR_SUCCESS)
+ found++;
+ }
+ }
+
+ if (!strcmp(atype, "RUSER"))
+ {
+ EXEC SQL DECLARE csr108q CURSOR FOR
+ SELECT list_id FROM imembers
+ WHERE member_type = 'USER' AND member_id = :aid;
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL OPEN csr108q;
+ if (dbms_errno)
+ return mr_errcode;
+ while (1)
+ {
+ EXEC SQL FETCH csr108q INTO :listid;
+ if (sqlca.sqlcode)
+ break;
+ sq_save_data(sq, (void *)listid);
+ }
+ EXEC SQL CLOSE csr108q;
+ /* now process each one */
+ while (sq_get_data(sq, &id))
+ {
+ if (ghbo_internal("LIST", id, action, actarg) == MR_SUCCESS)
+ found++;
+ }
+ if (ghbo_internal("USER", aid, action, actarg) == MR_SUCCESS)
found++;
- }
- EXEC SQL CLOSE csr115;
-
- rargv[0] = "ZEPHYR";
- EXEC SQL DECLARE csr116 CURSOR FOR
- SELECT class FROM zephyr z
- WHERE z.xmt_type = :type AND z.xmt_id = :id
- OR z.sub_type = :type AND z.sub_id = :id
- OR z.iws_type = :type AND z.iws_id = :id
- OR z.iui_type = :type AND z.iui_id = :id;
- if (dbms_errno)
- return mr_errcode;
- EXEC SQL OPEN csr116;
- if (dbms_errno)
- return mr_errcode;
- while (1)
- {
- EXEC SQL FETCH csr116 INTO :name;
- if (sqlca.sqlcode)
- break;
- (*action)(2, rargv, actarg);
+ }
+
+ if (!strcmp(atype, "RKERBEROS"))
+ {
+ EXEC SQL DECLARE csr109q CURSOR FOR
+ SELECT list_id FROM imembers
+ WHERE member_type = 'KERBEROS' AND member_id = :aid;
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL OPEN csr109q;
+ if (dbms_errno)
+ return mr_errcode;
+ while (1)
+ {
+ EXEC SQL FETCH csr109q INTO :listid;
+ if (sqlca.sqlcode)
+ break;
+ sq_save_data(sq, (void *)listid);
+ }
+ EXEC SQL CLOSE csr109q;
+ /* now process each one */
+ while (sq_get_data(sq, &id))
+ {
+ if (ghbo_internal("LIST", id, action, actarg) == MR_SUCCESS)
+ found++;
+ }
+ if (ghbo_internal("KERBEROS", aid, action, actarg) == MR_SUCCESS)
found++;
- }
- EXEC SQL CLOSE csr116;
+ }
- if (!found)
- return MR_NO_MATCH;
- return MR_SUCCESS;
+ sq_destroy(sq);
+ if (dbms_errno)
+ return mr_errcode;
+ if (!found)
+ return MR_NO_MATCH;
+ return MR_SUCCESS;
}
-
/* get_lists_of_member - given a type and a name, return the name and flags
* of all of the lists of the given member. The member_type is one of
* "LIST", "USER", "STRING", "RLIST", "RUSER", or "RSTRING" in argv[0],
/* register_user - change user's login name and allocate a pobox, group,
* filesystem, and quota for them. The user's status must start out as 0,
- * and is left as 2. Arguments are: user's UID, new login name, and user's
- * type for filesystem allocation (MR_FS_STUDENT, MR_FS_FACULTY,
- * MR_FS_STAFF, MR_FS_MISC).
+ * and is left as 2. Arguments are: user's UID, new login name, and
+ * pobox type ("POP" = POP, "IMAP" or numeric = IMAP)
*/
int register_user(struct query *q, char **argv, client *cl)
EXEC SQL BEGIN DECLARE SECTION;
char *login, *entity;
char directory[FILESYS_NAME_SIZE], machname[MACHINE_NAME_SIZE];
- int who, rowcount, mid, uid, users_id, utype, list_id;
- int ostatus, nstatus, fsidval;
- static int m_id = 0, def_quota = 0;
+ char dir[NFSPHYS_DIR_SIZE], *potype;
+ int who, rowcount, mid, uid, users_id;
+ int ostatus, nstatus, fsidval, popid;
+ int npid, tmp;
+ int po_exists = 0;
+ static int m_id, def_quota, def_imap_quota, list_id;
EXEC SQL END DECLARE SECTION;
char buffer[256], *aargv[3];
+ if (!m_id)
+ {
+ EXEC SQL SELECT list_id INTO :list_id FROM list
+ WHERE name = 'wheel';
+
+ EXEC SQL SELECT mach_id INTO :m_id FROM machine
+ WHERE name = 'ATHENA.MIT.EDU';
+
+ EXEC SQL SELECT value INTO :def_quota FROM numvalues
+ WHERE name = 'def_quota';
+ if (sqlca.sqlerrd[2] != 1)
+ return MR_NO_QUOTA;
+
+ EXEC SQL SELECT value INTO :def_imap_quota FROM numvalues
+ WHERE name = 'def_imap_quota';
+ if (sqlca.sqlerrd[2] != 1)
+ return MR_NO_QUOTA;
+ }
+
entity = cl->entity;
who = cl->client_id;
uid = atoi(argv[0]);
login = argv[1];
- utype = atoi(argv[2]);
+ potype = argv[2];
/* find user */
EXEC SQL SELECT users_id, status INTO :users_id, :ostatus
return mr_errcode;
if (rowcount > 0)
return MR_IN_USE;
+ EXEC SQL SELECT COUNT(label) INTO :rowcount
+ FROM filesys WHERE label = :login || '.po';
+ if (dbms_errno)
+ return mr_errcode;
+ if (rowcount > 0)
+ {
+ EXEC SQL SELECT owner INTO :tmp FROM filesys
+ WHERE label = :login || '.po';
+ if (dbms_errno)
+ return mr_errcode;
+ if ((ostatus == 0) || (tmp != users_id))
+ return MR_IN_USE;
+ else
+ po_exists = 1;
+ }
EXEC SQL SELECT COUNT(name) INTO :rowcount FROM alias
- WHERE name = :login AND type = 'FILESYS';
+ WHERE ( name = :login OR name = :login || '.po' )
+ AND type = 'FILESYS';
if (dbms_errno)
return mr_errcode;
if (rowcount > 0)
return MR_IN_USE;
com_err(whoami, 0, "login name OK");
- /* choose place for pobox, put in mid */
- EXEC SQL DECLARE csr130 CURSOR FOR
- SELECT sh.mach_id, m.name FROM serverhosts sh, machine m
- WHERE sh.service = 'POP' AND sh.mach_id = m.mach_id
- AND sh.value2 - sh.value1 = (SELECT MAX(value2 - value1) FROM serverhosts
- WHERE service = 'POP');
+ EXEC SQL SELECT COUNT(potype) INTO :rowcount FROM users WHERE
+ login = :login AND potype = 'POP';
if (dbms_errno)
return mr_errcode;
- EXEC SQL OPEN csr130;
- if (dbms_errno)
- return mr_errcode;
- EXEC SQL FETCH csr130 INTO :mid, :machname;
- if (sqlca.sqlerrd[2] == 0)
- {
- EXEC SQL CLOSE csr130;
- if (dbms_errno)
- return mr_errcode;
- return MR_NO_POBOX;
- }
- else
+ if (rowcount > 0)
+ po_exists = 1;
+
+ /* choose type and location for pobox */
+ if (!po_exists)
{
- EXEC SQL CLOSE csr130;
- if (dbms_errno)
- return mr_errcode;
- }
+ if (!strcmp(potype, "POP"))
+ {
+ EXEC SQL DECLARE csr130 CURSOR FOR
+ SELECT sh.mach_id, m.name FROM serverhosts sh, machine m
+ WHERE sh.service = 'POP' AND sh.mach_id = m.mach_id
+ AND sh.value2 - sh.value1 =
+ (SELECT MAX(value2 - value1) FROM serverhosts WHERE service = 'POP');
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL OPEN csr130;
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL FETCH csr130 INTO :popid, :machname;
+ if (sqlca.sqlerrd[2] == 0)
+ {
+ EXEC SQL CLOSE csr130;
+ if (dbms_errno)
+ return mr_errcode;
+ return MR_NO_POBOX;
+ }
+ else
+ {
+ EXEC SQL CLOSE csr130;
+ if (dbms_errno)
+ return mr_errcode;
+ }
+
+ EXEC SQL UPDATE users SET potype = 'POP', pop_id = :popid
+ WHERE users_id = :users_id;
+ com_err(whoami, 0, "pobox set to POP:%s", strtrim(machname));
+ }
+ else
+ {
+ /* Select all IMAP nfsphys entries in order of increasing
+ * (allocated - partsize). The partitions will almost always be
+ * overallocated, but we choose the one that is the least
+ * overallocated.
+ */
+ potype = "IMAP";
+
+ EXEC SQL DECLARE csr_rusr_imap CURSOR FOR
+ SELECT np.allocated - np.partsize, np.nfsphys_id, np.mach_id,
+ np.dir, m.name FROM serverhosts sh, nfsphys np, machine m
+ WHERE sh.service = 'POSTOFFICE' AND sh.mach_id = np.mach_id
+ AND m.mach_id = np.mach_id
+ ORDER BY 1;
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL OPEN csr_rusr_imap;
+ if (dbms_errno)
+ return mr_errcode;
+ EXEC SQL FETCH csr_rusr_imap INTO :tmp, :npid, :mid, :dir, :machname;
+ if (sqlca.sqlerrd[2] == 0)
+ {
+ EXEC SQL CLOSE csr_rusr_imap;
+ if (dbms_errno)
+ return mr_errcode;
+ return MR_NO_POBOX;
+ }
+ else
+ {
+ EXEC SQL CLOSE csr_rusr_imap;
+ if (dbms_errno)
+ return mr_errcode;
+ }
+
+ /* create filesystem */
+ if (set_next_object_id("filsys_id", FILESYS_TABLE, 0))
+ return MR_NO_ID;
+ incremental_clear_before();
+
+ EXEC SQL SELECT value INTO :popid FROM numvalues
+ WHERE numvalues.name = 'filsys_id';
+ EXEC SQL INSERT INTO filesys
+ (filsys_id, phys_id, label, type, mach_id, name,
+ mount, rwaccess, comments, owner, owners, createflg,
+ lockertype, modtime, modby, modwith)
+ VALUES
+ (:popid, :npid, :login || '.po', 'IMAP', :mid, :dir,
+ CHR(0), 'w', 'IMAP box', :users_id, :list_id, 1,
+ 'USER', SYSDATE, :who, :entity);
+
+ if (dbms_errno)
+ return mr_errcode;
+ if (sqlca.sqlerrd[2] != 1)
+ return MR_INTERNAL;
+ sprintf(buffer, "fs.filsys_id = %d", popid);
+ incremental_after(FILESYS_TABLE, buffer, 0);
+
+ /* set quota */
+ incremental_clear_before();
+ EXEC SQL INSERT INTO quota
+ (entity_id, filsys_id, type, quota, phys_id, modtime, modby, modwith)
+ VALUES (:users_id, :popid, 'USER', :def_imap_quota, :npid,
+ SYSDATE, :who, :entity);
+ if (dbms_errno)
+ return mr_errcode;
+ if (sqlca.sqlerrd[2] != 1)
+ return MR_INTERNAL;
+ aargv[0] = login;
+ aargv[1] = "USER";
+ aargv[2] = login;
+ sprintf(buffer, "q.entity_id = %d and q.filsys_id = %d and "
+ "q.type = 'USER'", users_id, popid);
+ incremental_after(QUOTA_TABLE, buffer, aargv);
+ if (dbms_errno)
+ return mr_errcode;
+
+ EXEC SQL UPDATE nfsphys SET allocated = allocated + :def_imap_quota
+ WHERE nfsphys_id = :npid;
+
+ EXEC SQL UPDATE users SET potype = 'IMAP', imap_id = :popid
+ WHERE users_id = :users_id;
+ com_err(whoami, 0, "pobox set to IMAP:%s:%s", strtrim(machname),
+ strtrim(dir));
+ }
+ }
+
/* change login name, set pobox */
sprintf(buffer, "u.users_id = %d", users_id);
incremental_before(USERS_TABLE, buffer, 0);
if (ostatus == 5 || ostatus == 6)
nstatus = 1;
EXEC SQL UPDATE users SET login = :login, status = :nstatus,
- modtime = SYSDATE, modby = :who, modwith = :entity, potype = 'POP',
- pop_id = :mid, pmodtime = SYSDATE, pmodby = :who, pmodwith = :entity
+ modtime = SYSDATE, modby = :who, modwith = :entity,
+ pmodtime = SYSDATE, pmodby = :who, pmodwith = :entity
WHERE users_id = :users_id;
if (dbms_errno)
return mr_errcode;
if (sqlca.sqlerrd[2] != 1)
return MR_INTERNAL;
- set_pop_usage(mid, 1);
- com_err(whoami, 0, "set login name to %s and pobox to %s", login,
- strtrim(machname));
+
+ /* Only update usage count if we created a POP pobox. */
+ if (!strcmp(potype, "POP") && !po_exists)
+ set_pop_usage(mid, 1);
+
+ com_err(whoami, 0, "set login name to %s", login);
incremental_after(USERS_TABLE, buffer, 0);
- if (m_id == 0)
- {
- /* Cell Name (I know, it shouldn't be hard coded...) */
- strcpy(machname, "ATHENA.MIT.EDU");
- EXEC SQL SELECT mach_id INTO :m_id FROM machine
- WHERE name = :machname;
- }
-
- EXEC SQL SELECT list_id INTO :list_id FROM list
- WHERE name = 'wheel';
-
/* create filesystem */
if (set_next_object_id("filsys_id", FILESYS_TABLE, 0))
return MR_NO_ID;
incremental_after(FILESYS_TABLE, buffer, 0);
/* set quota */
- if (def_quota == 0)
- {
- EXEC SQL SELECT value INTO :def_quota FROM numvalues
- WHERE name = 'def_quota';
- if (dbms_errno)
- return mr_errcode;
- if (sqlca.sqlerrd[2] != 1)
- return MR_NO_QUOTA;
- }
incremental_clear_before();
EXEC SQL INSERT INTO quota
(entity_id, filsys_id, type, quota, phys_id, modtime, modby, modwith)
if (dbms_errno)
return mr_errcode;
- cache_entry(login, USERS_TABLE, users_id);
-
EXEC SQL UPDATE tblstats SET updates = updates + 1, modtime = SYSDATE
WHERE table_name = 'users';
EXEC SQL UPDATE tblstats SET appends = appends + 1, modtime = SYSDATE
return MR_SUCCESS;
}
-
-
/** set_pop_usage - incr/decr usage count for pop server in serverhosts talbe
**
** Inputs:
return MR_SUCCESS;
}
+
+int do_user_reservation(struct query *q, char *argv[], client *cl)
+{
+ EXEC SQL BEGIN DECLARE SECTION;
+ char resv[USERS_RESERVATIONS_SIZE];
+ char *trans, name[ALIAS_NAME_SIZE];
+ int uid;
+ EXEC SQL END DECLARE SECTION;
+
+ uid = *(int *)argv[0];
+ trans = argv[1];
+
+ EXEC SQL SELECT UPPER(name) INTO :name FROM alias
+ WHERE type = 'RESERVE' AND LOWER(trans) = LOWER(:trans);
+ if (dbms_errno)
+ return mr_errcode;
+ if (sqlca.sqlerrd[2] != 1)
+ return MR_STRING;
+ name[1] = '\0';
+
+ EXEC SQL SELECT reservations INTO :resv FROM users
+ WHERE users_id = :uid;
+ if (dbms_errno)
+ return mr_errcode;
+ strtrim(resv);
+
+ if (!strcmp(q->shortname, "aurv"))
+ {
+ if (strchr(resv, *name))
+ return MR_EXISTS;
+ if (strlen(resv) == USERS_RESERVATIONS_SIZE - 1)
+ return MR_ARG_TOO_LONG;
+
+ strcat(resv, name);
+ }
+ else
+ {
+ char *p = strchr(resv, *name);
+ if (!p)
+ return MR_NO_MATCH;
+ memmove(p, p + 1, strlen(p));
+ }
+
+ EXEC SQL UPDATE users SET reservations = NVL(:resv, CHR(0))
+ WHERE users_id = :uid;
+ if (dbms_errno)
+ return mr_errcode;
+
+ EXEC SQL UPDATE tblstats SET updates = updates + 1, modtime = SYSDATE
+ WHERE table_name = 'users';
+ return set_modtime_by_id(q, argv, cl);
+}
+
+int get_user_reservations(struct query *q, char **argv, client *cl,
+ int (*action)(int, char *[], void *), void *actarg)
+{
+ EXEC SQL BEGIN DECLARE SECTION;
+ char resv[USERS_RESERVATIONS_SIZE], *p;
+ char trans[ALIAS_TRANS_SIZE], name[2] = { 0, 0 };
+ int uid;
+ EXEC SQL END DECLARE SECTION;
+ char *targv[1];
+
+ uid = *(int *)argv[0];
+
+ EXEC SQL SELECT reservations INTO :resv FROM users
+ WHERE users_id = :uid;
+ if (dbms_errno)
+ return mr_errcode;
+
+ targv[0] = trans;
+ p = resv;
+ while (*p && !isspace(*p))
+ {
+ name[0] = toupper(*p);
+ EXEC SQL SELECT trans INTO :trans FROM alias
+ WHERE type = 'RESERVE' AND UPPER(name) = :name;
+ if (dbms_errno)
+ return mr_errcode;
+ if (sqlca.sqlerrd[2] != 1)
+ sprintf(trans, "Unknown (%s)", name);
+ (*action)(1, targv, actarg);
+ p++;
+ }
+ return MR_SUCCESS;
+}
+
+int get_user_by_reservation(struct query *q, char **argv, client *cl,
+ int (*action)(int, char *[], void *), void *actarg)
+{
+ EXEC SQL BEGIN DECLARE SECTION;
+ char resv[USERS_RESERVATIONS_SIZE], login[USERS_LOGIN_SIZE];
+ char *trans, name[ALIAS_NAME_SIZE];
+ int uid;
+ EXEC SQL END DECLARE SECTION;
+ char *targv[1];
+
+ trans = argv[0];
+
+ EXEC SQL SELECT UPPER(name) INTO :name FROM alias
+ WHERE type = 'RESERVE' AND LOWER(trans) = LOWER(:trans);
+ if (dbms_errno)
+ return mr_errcode;
+ if (sqlca.sqlerrd[2] != 1)
+ return MR_STRING;
+ name[1] = '\0';
+
+ EXEC SQL DECLARE csr_gubr CURSOR FOR
+ SELECT login FROM users WHERE reservations LIKE '%' || :name || '%';
+ EXEC SQL OPEN csr_gubr;
+ if (dbms_errno)
+ return mr_errcode;
+
+ targv[0] = login;
+ while (1)
+ {
+ EXEC SQL FETCH csr_gubr INTO :login;
+ if (sqlca.sqlcode)
+ break;
+ (*action)(1, targv, actarg);
+ }
+ EXEC SQL CLOSE csr_gubr;
+
+ return MR_SUCCESS;
+}
+
+int update_container(struct query *q, char *argv[], client *cl)
+{
+ EXEC SQL BEGIN DECLARE SECTION;
+ int cnt_id, acl_id, memacl_id, who;
+ char name[CONTAINERS_NAME_SIZE], newchildname[CONTAINERS_NAME_SIZE];
+ char* newname, *entity, *description, *location, *contact, *acl_type, *memacl_type;
+ EXEC SQL END DECLARE SECTION;
+ char* tmpchar;
+ int cnt, childid;
+ char childname[CONTAINERS_NAME_SIZE];
+
+ cnt_id = *(int *)argv[0];
+ newname = argv[1];
+ description = argv[2];
+ location = argv[3];
+ contact = argv[4];
+ acl_type = argv[5];
+ acl_id = *(int *)argv[6];
+ memacl_type = argv[7];
+ memacl_id = *(int *)argv[8];
+ entity = cl->entity;
+ who = cl->client_id;
+
+ EXEC SQL SELECT name INTO :name
+ FROM containers
+ WHERE cnt_id = :cnt_id;
+
+ /* trim off the trailing spaces */
+ strcpy(name, strtrim(name));
+
+ /* if we are renaming the container */
+ if (strcmp(name, newname))
+ {
+ /* make sure that only the name part of the name has been changed */
+ tmpchar = strrchr(name, '/');
+ /* not a top-level name */
+ if (tmpchar)
+ {
+ cnt = tmpchar - name + 1;
+ /* the parent part of the old and new name should be identical */
+ if (strncmp(name, newname, cnt))
+ return MR_NEW_CONTAINER_NAME;
+ }
+ /* top level name, new name should be a top level name too */
+ else
+ {
+ if (strrchr(newname, '/'))
+ return MR_NEW_CONTAINER_NAME;
+ }
+
+ /* update the name for this container */
+ EXEC SQL UPDATE containers
+ SET name = :newname
+ WHERE cnt_id = :cnt_id;
+
+ if (dbms_errno)
+ return mr_errcode;
+
+ /* get names for its child containers */
+ EXEC SQL DECLARE csr_ucon CURSOR FOR
+ SELECT name, cnt_id FROM containers WHERE name LIKE :name || '/' || '%';
+
+ EXEC SQL OPEN csr_ucon;
+ if (dbms_errno)
+ return mr_errcode;
+
+ while (1)
+ {
+ EXEC SQL FETCH csr_ucon INTO :childname, :childid;
+ if (sqlca.sqlcode)
+ break;
+
+ strcpy(childname, strtrim(childname));
+ /* concatenate the new parent name with the existing sub-container name
+ * we get the sub-containers new name */
+ tmpchar = childname + strlen(name);
+ strcpy(newchildname, newname);
+ strcat(newchildname, tmpchar);
+
+ /* update the name */
+ EXEC SQL UPDATE containers
+ SET name = :newchildname, modtime = SYSDATE, modby = :who, modwith = :entity
+ WHERE cnt_id = :childid;
+
+ if (sqlca.sqlcode)
+ break;
+ }
+
+ EXEC SQL CLOSE csr_ucon;
+ if (dbms_errno)
+ return mr_errcode;
+ }
+
+ /* update the remaining fields */
+ EXEC SQL UPDATE containers
+ SET description = NVL(:description, CHR(0)), location = NVL(:location, CHR(0)),
+ contact = NVL(:contact, CHR(0)), acl_type = :acl_type, acl_id = :acl_id,
+ memacl_type = :memacl_type, memacl_id = :memacl_id,
+ modtime = SYSDATE, modby = :who, modwith = :entity
+ WHERE cnt_id = :cnt_id;
+
+ if (dbms_errno)
+ return mr_errcode;
+
+ return MR_SUCCESS;
+}
+
+int get_machines_of_container(struct query *q, char *argv[], client *cl,
+ int (*action)(int, char *[], void *), void *actarg)
+{
+ EXEC SQL BEGIN DECLARE SECTION;
+ int cnt_id, isrecursive;
+ char machinename[MACHINE_NAME_SIZE], containername[CONTAINERS_NAME_SIZE];
+ char *qs;
+ EXEC SQL END DECLARE SECTION;
+
+ char querystring[512], tmp [256];
+ char *rargv[2];
+ int found = 0;
+
+ rargv[0] = machinename;
+ rargv[1] = containername;
+
+ cnt_id = *(int *)argv[0];
+ isrecursive = *(int *)argv[1];
+
+ /* get the container name */
+
+ EXEC SQL SELECT name INTO :containername
+ FROM containers
+ WHERE cnt_id = :cnt_id;
+
+ /* trim off the trailing spaces */
+ strcpy(containername, strtrim(containername));
+
+ strcpy(querystring, "SELECT a.name, b.name FROM machine a, containers b, mcntmap c ");
+ strcat(querystring, "WHERE a.mach_id = c.mach_id AND b.cnt_id = c.cnt_id ");
+
+ if (!isrecursive)
+ sprintf(tmp, "AND b.cnt_id = %d ", cnt_id);
+ else
+ sprintf(tmp, "AND (b.cnt_id = %d OR b.name LIKE '%s/%%') ", cnt_id, containername);
+
+ strcat(querystring, tmp);
+ strcat(querystring, "ORDER BY b.name, a.name");
+
+ qs = querystring;
+
+ EXEC SQL PREPARE stmt FROM :qs;
+ if (sqlca.sqlcode)
+ return MR_INTERNAL;
+ EXEC SQL DECLARE curs_gmnm CURSOR FOR stmt;
+ EXEC SQL OPEN curs_gmnm;
+
+ while (1)
+ {
+ EXEC SQL FETCH curs_gmnm INTO :machinename, :containername;
+ if (sqlca.sqlcode)
+ break;
+ (*action)(2, rargv, actarg);
+ found++;
+ }
+
+ EXEC SQL CLOSE curs_gmnm;
+ if (!found)
+ return MR_NO_MATCH;
+ return MR_SUCCESS;
+}
+
+int get_subcontainers_of_container(struct query *q, char *argv[], client *cl,
+ int (*action)(int, char *[], void *), void *actarg)
+{
+ EXEC SQL BEGIN DECLARE SECTION;
+ int cnt_id, isrecursive;
+ char containername[CONTAINERS_NAME_SIZE], subcontainername[CONTAINERS_NAME_SIZE];
+ char *qs;
+ EXEC SQL END DECLARE SECTION;
+
+ char querystring[512], tmp [256];
+ char *rargv[1];
+ int found = 0;
+
+ rargv[0] = subcontainername;
+
+ cnt_id = *(int *)argv[0];
+ isrecursive = *(int *)argv[1];
+
+ /* get the container name */
+
+ EXEC SQL SELECT name INTO :containername
+ FROM containers
+ WHERE cnt_id = :cnt_id;
+
+ /* trim off the trailing spaces */
+ strcpy(containername, strtrim(containername));
+
+ strcpy(querystring, "SELECT name FROM containers ");
+
+ if (!isrecursive)
+ sprintf(tmp, "WHERE name LIKE '%s/%%' and name NOT LIKE '%s/%%/%%' ", containername,
+ containername);
+ else
+ sprintf(tmp, "WHERE name LIKE '%s/%%' ", containername);
+
+ strcat(querystring, tmp);
+ strcat(querystring, "ORDER BY name");
+
+ qs = querystring;
+
+ EXEC SQL PREPARE stmt FROM :qs;
+ if (sqlca.sqlcode)
+ return MR_INTERNAL;
+ EXEC SQL DECLARE curs_gsoc CURSOR FOR stmt;
+ EXEC SQL OPEN curs_gsoc;
+
+ while (1)
+ {
+ EXEC SQL FETCH curs_gsoc INTO :subcontainername;
+ if (sqlca.sqlcode)
+ break;
+ (*action)(1, rargv, actarg);
+ found++;
+ }
+
+ EXEC SQL CLOSE curs_gsoc;
+ if (!found)
+ return MR_NO_MATCH;
+ return MR_SUCCESS;
+}
andersk / moira.git / blobdiff