#include <sys/stat.h>
#include <sys/time.h>
-#define NFS_DIR "/u1/sms/dcm/nfs"
#define min(x,y) ((x) < (y) ? (x) : (y))
char *whoami = "nfs.gen";
char *malloc(), *strsave();
char *ingres_date_and_time(), *ingres_time(), *ingres_date();
+char nfs_dir[64];
main(argc, argv)
int argc;
}
IIseterr(ingerr);
+ initialize_sms_error_table();
+ sprintf(nfs_dir, "%s/nfs", DCM_DIR);
+
## ingres sms
## set lockmode session where level = table
}
if (argc == 2) {
- sprintf(cmd, "cd %s; cp /u1/sms/bin/install_* .; tar cf %s .", NFS_DIR, argv[1]);
+ sprintf(cmd, "cd %s; cp %s/nfs/* .; tar cf %s .",
+ nfs_dir, SMS_DIR, argv[1]);
if (system(cmd))
exit(SMS_TAR_FAIL);
}
int do_lists(lists)
struct save_queue *lists;
##{
- struct save_queue *sq, *members;
char file[64], *u;
struct hash *users, *do_everyone();
struct stat sb;
## char *listname, *lsname, lname[33], uname[9], *filetime;
## int uid, id, flag1, flag2, flag3, flag4;
- sprintf(file, "%s/list-", NFS_DIR);
+ sprintf(file, "%s/list-", nfs_dir);
if (stat(file, &sb) == 0) {
filetime = ingres_date_and_time(sb.st_mtime);
## retrieve (flag1 = int4(interval("min", tblstats.modtime - filetime)))
## retrieve (flag2 = int4(interval("min", tblstats.modtime - filetime)))
## where tblstats.table = "list"
## retrieve (flag3 = int4(interval("min", tblstats.modtime - filetime)))
-## where tblstats.table = "members"
+## where tblstats.table = "imembers"
## retrieve (flag4 = int4(interval("min", tblstats.modtime - filetime)))
## where tblstats.table = "serverhosts"
if (flag1 < 0 && flag2 < 0 && flag3 < 0 && flag4 < 0) {
/* now do each of the lists used by an NFS server */
## range of l is list
## range of l1 is list
-## range of m is members
+## range of m is imembers
## range of u is users
while (sq_get_data(lists, &listname)) {
if (strlen(listname) == 0)
continue;
- sprintf(file, "%s/list-%s", NFS_DIR, listname);
+ sprintf(file, "%s/list-%s", nfs_dir, listname);
fd = fopen(file, "w");
if (!fd) {
fprintf(stderr, "cannot open %s for output\n", file);
exit(SMS_OCONFIG);
}
- sq = sq_create();
- sq_save_data(sq, listname);
- members = sq_create();
- while (sq_get_data(sq, &lsname)) {
-## repeat retrieve (lname = trim(l.name))
-## where m.list_id = l1.list_id and l1.name = @lsname and
-## m.member_type = "LIST" and m.member_id = l.list_id {
- sq_save_unique_string(sq, strsave(lname));
-## }
-## repeat retrieve (id = m.member_id)
-## where m.list_id = l1.list_id and l1.name = @lsname and
-## m.member_type = "USER" {
- if (u = hash_lookup(users, id)) {
- sq_save_unique_data(members, u);
- }
-## }
- }
- while (sq_get_data(members, &lsname))
- fprintf(fd, "%s\n", lsname);
-/* test to see if this speeds things up; don't free anything!
- sq_destroy(members);
- sq_destroy(sq);
- */ if (fclose(fd)) {
+## repeat retrieve (id = m.member_id)
+## where m.list_id = l1.list_id and l1.name = @listname and
+## m.member_type = "USER" {
+ if (u = hash_lookup(users, id))
+ fprintf(fd, "%s\n", u);
+## }
+ if (fclose(fd)) {
fprintf(stderr, "error closing %s\n", file);
exit(SMS_CCONFIG);
}
struct save_queue *sq;
fprintf(stderr, "Building the list of everybody\n");
- sprintf(buf, "%s/list-", NFS_DIR);
+ sprintf(buf, "%s/list-", nfs_dir);
fd = fopen(buf, "w");
if (!fd) {
fprintf(stderr, "cannot open %s for output\n", buf);
hash_store(groups, lid, strsave(buf));
## }
- /* get special cases: lists that aren't groups themselves but are
- * members of groups. */
- sq = sq_create();
-## range of m is members
-## retrieve (gid = list.#gid, lid = l.list_id)
-## where l.active != 0 and list.active != 0 and m.member_type = "LIST" and
-## m.member_id = l.list_id and m.list_id = list.list_id and
-## list.group != 0 {
- if (l = hash_lookup(groups, lid)) {
- sprintf(buf, "%s:%d", l, gid);
- free(l);
- } else {
- sprintf(buf, ":%d", gid);
- }
- hash_store(groups, lid, strsave(buf));
- sq_save_data(sq, lid);
-## }
-
- while (sq_get_data(sq, &id)) {
-## repeat retrieve (lid = l.list_id) where l.active != 0 and
-## m.member_type = "LIST" and m.member_id = l.list_id and
-## m.list_id = @id {
- if (l = hash_lookup(groups, lid)) {
- sprintf(buf, "%s%s", l, hash_lookup(groups, id));
- free(l);
- l = strsave(buf);
- } else {
- l = hash_lookup(groups, id);
- }
- hash_store(groups, lid, l);
- sq_save_unique_data(sq, lid);
-## }
- }
- sq_destroy(sq);
-
/* now do grplists */
users = create_hash(10000);
## range of u is users
hash_store(users, id, u);
## }
-## repeat retrieve (lid = m.list_id, id = m.member_id)
-## where m.member_type = "USER" {
+## range of m is imembers
+## retrieve (lid = m.list_id, id = m.member_id) where m.member_type = "USER" {
if ((u = (struct user *) hash_lookup(users, id)) &&
(hash_lookup(groups, lid) != NULL)) {
g = (struct grp *) malloc(sizeof(struct grp));
i++;
strcat(buf, l);
}
- /* should free stuff here... */
+ /* should free stuff here...
if (i > 1) {
remove_duplicate_groups(buf);
- }
+ } */
b->data = strsave(buf);
fprintf(fd, "%s\n", buf);
}
struct save_queue *sq;
/*
- sprintf(file, "%s/list-", NFS_DIR);
+ sprintf(file, "%s/list-", nfs_dir);
if (stat(file, &sb) == 0) {
filetime = ingres_date_and_time(sb.st_mtime);
# retrieve (flag1 = int4(interval("min", tblstats.modtime - filetime)))
fprintf(stderr, "Building machine files\n");
-## begin transaction
## range of s is serverhosts
## range of m is machine
## range of n is nfsphys
## range of f is filesys
## range of u is users
## range of l is list
+
+/* acquire locks on users, lists, machines & filesystems */
+## begin transaction
+## retrieve (listname = u.modtime) where u.users_id = 0
+## retrieve (listname = l.modtime) where l.list_id = 0
+## retrieve (listname = m.modtime) where m.mach_id = 0
+## retrieve (listname = f.modtime) where f.filsys_id = 0
+
while (sq_get_data(machs, &machname)) {
## repeat retrieve (listname = trim(s.value3))
## where s.mach_id = m.mach_id and m.name = @machname
strtrim(machname);
- sprintf(f1, "%s/list-%s", NFS_DIR, listname);
- sprintf(f2, "%s/%s.cred", NFS_DIR, machname);
+ sprintf(f1, "%s/list-%s", nfs_dir, listname);
+ sprintf(f2, "%s/%s.cred", nfs_dir, machname);
unlink(f2); /* ignore errors on this unlink */
if (link(f1, f2)) {
fprintf(stderr, "Cannot link %s to %s\n", f1, f2);
## repeat retrieve (id = n.nfsphys_id) where n.mach_id = m.mach_id and
## m.#name = @machname and n.#device = @device
while (cp = index(device, '/')) *cp = '@';
- sprintf(file, "%s/%s.%s.quotas", NFS_DIR, machname, device);
+ sprintf(file, "%s/%s.%s.quotas", nfs_dir, machname, device);
fd = fopen(file, "w");
if (!fd) {
fprintf(stderr, "cannot open %s for output\n", file);
}
prevuid = -1;
quotasum = 0;
-## repeat retrieve (uid = u.#uid, quota = q.#quota)
-## where q.users_id = u.users_id and q.filsys_id = f.filsys_id and
-## f.phys_id = @id and u.status != 0 sort by #uid {
+## repeat retrieve (uid = u.#uid, quota = q.#quota, flag1=q.filsys_id)
+## where q.users_id = u.users_id and q.phys_id = @id and
+## u.status != 0 sort by #uid {
if (uid != prevuid) {
if (quotasum)
fprintf(fd, "%d %d\n", prevuid, quotasum);
fprintf(stderr, "error closing %s", file);
exit(SMS_CCONFIG);
}
- sprintf(file, "%s/%s.%s.dirs", NFS_DIR, machname, device);
+ sprintf(file, "%s/%s.%s.dirs", nfs_dir, machname, device);
fd = fopen(file, "w");
if (!fd) {
fprintf(stderr, "cannot open %s for output\n", file);
andersk / moira.git / blobdiff