4 * (c) Copyright 1989 by the Massachusetts Institute of Technology.
5 * For copying and distribution information, please see the file
9 #include <mit-copyright.h>
19 #include <moira_site.h>
22 #define min(x,y) ((x) < (y) ? (x) : (y))
23 char *whoami = "sync";
25 char *malloc(), *strsave();
43 struct member *members;
55 if (!strcmp(argv[1], "-db")) {
56 strncpy(db, argv[2], sizeof(db)-1);
61 fprintf(stderr, "usage: %s [-db sms] outfile\n", whoami);
65 dbase_fd = open(argv[1], O_RDWR|O_CREAT|O_TRUNC, 0660);
67 perror("opening file %s", argv[1]);
72 initialize_sms_error_table();
73 initialize_pt_error_table();
74 Initdb(); /* Initialize prdb */
76 users = create_hash(10000);
77 groups = create_hash(15000);
80 ## set lockmode session where level = table
96 ## int uid, id, status;
98 struct prentry tentry;
102 fprintf(stderr, "Doing users: %s", ctime(&t));
104 ## range of u is users
105 ## retrieve (login = u.#login, uid = u.#uid, id = u.users_id)
106 ## where u.#uid > 0 and (u.#status = 1 or u.#status = 2) {
107 lowercase(strtrim(login));
112 status = CreateEntry(0,login,&uid,1/*idflag*/,0/*gflag*/,
113 SYSADMINID/*oid*/, SYSADMINID/*cid*/);
115 fprintf(stderr, "Error adding user %s uid %d: %s\n",
116 login, uid, error_message(status));
118 u = (struct entry *)malloc(sizeof(struct entry));
121 hash_store(users, id, u);
132 struct prentry gentry, uentry;
135 struct bucket **p, *b;
139 ## int gid, id, lid, hide;
142 fprintf(stderr, "Doing groups: %s", ctime(&t));
144 ## range of l is list
145 ## range of m is imembers
146 /* get lock records */
147 ## retrieve (name = l.modtime) where l.list_id = 0
148 ## retrieve (name = users.modtime) where users.users_id = 0
150 ## retrieve (name = l.#name, gid = l.#gid, lid = l.list_id, hide = l.hidden)
151 ## where l.group != 0 and l.active != 0 and l.#gid > 0 {
152 lowercase(strtrim(name));
153 sprintf(namebuf, "system:%s", name);
156 if (FindByID(0, aid))
159 status = CreateEntry(0,namebuf,&aid,1/*idflag*/,PRGRP/*gflag*/,
160 SYSADMINID/*oid*/, SYSADMINID/*cid*/);
162 fprintf(stderr, "Error adding group %s id %d: %s\n",
163 namebuf, aid, error_message(status));
165 g = (struct entry *)malloc(sizeof(struct entry));
168 hash_store(groups, lid, g);
172 /* Set modes on hidden lists (S----) */
173 if (hide && (status==0 || status==PRIDEXIST)) {
174 pos = FindByID(0, aid);
175 status = pr_Read(0, 0, pos, &gentry, sizeof(gentry));
177 gentry.flags = htonl(PRGRP|PRACCESS|PRP_STATUS_ANY);
178 status = pr_Write(0, 0, pos, &gentry, sizeof(gentry));
182 "Error setting flags on group %s: %s\n",
183 namebuf, error_message(status));
188 fprintf(stderr, "Doing members: %s", ctime(&t));
190 ## retrieve (lid = m.list_id, id = m.member_id)
191 ## where m.member_type = "USER" {
192 if ((u = (struct entry *)hash_lookup(users, id)) &&
193 (g = (struct entry *)hash_lookup(groups, lid))) {
194 m = (struct member *)malloc(sizeof(struct member));
197 m->unext = u->members;
198 m->gnext = g->members;
199 u->members = g->members = m;
203 for (p = &(users->data[users->size - 1]); p >= users->data; p--) {
204 for (b = *p; b; b = b->next) {
205 if ((u = (struct entry *)b->data)->members == 0)
207 pos = FindByID(0, u->id);
208 pr_Read(0, 0, pos, &uentry, sizeof(uentry));
209 for (t=0, m=u->members; m && t<PRSIZE; m=m->unext, t++)
210 uentry.entries[t] = htonl(m->group->id);
211 uentry.count = htonl(t);
212 pr_Write(0, 0, pos, &uentry, sizeof(uentry));
214 pr_ReadEntry(0, 0, pos, &uentry);
216 AddToEntry(0, &uentry, pos, m->group->id);
222 for (p = &(groups->data[groups->size - 1]); p >= groups->data; p--) {
223 for (b = *p; b; b = b->next) {
224 if ((g = (struct entry *)b->data)->members == 0)
226 pos = FindByID(0, g->id);
227 pr_Read(0, 0, pos, &gentry, sizeof(gentry));
228 for (t=0, m=g->members; m && t<PRSIZE; m=m->gnext, t++)
229 gentry.entries[t] = htonl(m->user->id);
230 gentry.count = htonl(t);
231 pr_Write(0, 0, pos, &gentry, sizeof(gentry));
233 pr_ReadEntry(0, 0, pos, &gentry);
235 AddToEntry(0, &gentry, pos, m->user->id);
243 fprintf(stderr, "Done (%d users, %d groups, %d members): %s",
244 ucount, gcount, mcount, ctime(&t));
250 * ingerr: (supposedly) called when Ingres indicates an error.
251 * I have not yet been able to get this to work to intercept a
252 * database open error.
254 #define INGRES_DEADLOCK 4700
256 static int ingerr(num)
263 case INGRES_DEADLOCK:
264 ingres_errno = MR_DEADLOCK;
267 ingres_errno = MR_INGRES_ERR;
269 com_err(whoami, MR_INGRES_ERR, " code %d\n", *num);