"README" did not exist on "e1647e16248eb235284f84eceb9351d20db29fbc"
Newer
Older
* $Id: dbck.c,v 0.19 1993/10/18 12:29:14 ceder Exp $
* Copyright (C) 1991 Lysator Academic Computer Association.
*
* This file is part of the LysKOM server.
*
* LysKOM is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 1, or (at your option)
* any later version.
*
* LysKOM is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* for more details.
*
* You should have received a copy of the GNU General Public License
* along with LysKOM; see the file COPYING. If not, write to
* Lysator, c/o ISY, Linkoping University, S-581 83 Linkoping, SWEDEN,
* or the Free Software Foundation, Inc., 675 Mass Ave, Cambridge,
* MA 02139, USA.
*
* Please mail bug reports to bug-lyskom@lysator.liu.se.
*/
/*
* dbck.c - A simple database checker and corrector.
*
* Author: Per Cederqvist.
*/
static char *rcsid = "$Id: dbck.c,v 0.19 1993/10/18 12:29:14 ceder Exp $";
#ifdef HAVE_STDLIB_H
# include <stdlib.h>
#endif
#include <time.h>
#include <sys/types.h>
#include "s-string.h"
#include "kom-types.h"
#include "tmp-limits.h"
#include "log.h"
#include "server/smalloc.h"
#include "cache.h"
#include "config.h"
#include "debug.h"
/* This is set to TRUE if init_cache finds out that the last part of the
database is missing. */
Bool truncated_texts = FALSE;
char datafilename[1024]; /* Full pathname to the database file */
char backupfilename[1024]; /* Full pathname to the backup file */
char textfilename[1024];
char textbackupfilename[1024]; /* unshrinked text-file. */
static const char *dbase_dir = NULL; /* Directory where database resides */
#define TEXTBACKUPFILE_NAME "db/backup-texts"
int vflag=0; /* Verbose - list statistics also. */
int iflag=0; /* Interactive - prompt user and repair. */
int rflag=0; /* Repair simple error without confirmation. */
int gflag=0; /* Garbage collect text-file. */
int sflag=0; /* Statistic flag. */
int modifications = 0;
typedef struct {
int created_confs;
} Person_scratchpad;
static const Person_scratchpad EMPTY_PERSON_SCRATCHPAD = { 0 };
static Person_scratchpad *person_scratchpad[MAX_CONF];
#ifdef DEBUG
int buglevel = 0;
#endif
extern void
log (const char * format, ...)
{
va_list AP;
va_start(AP, format);
vfprintf(stdout, format, AP);
va_end(AP);
}
#else
extern void
log (format, a, b, c, d, e, f, g)
const char * format;
int a, b, c, d, e, f, g;
{
fprintf(stdout, format, a, b, c, d, e, f, g);
}
#endif
extern void
restart_kom (const char * format, ...)
{
va_list AP;
va_start(AP, format);
vfprintf(stdout, format, AP);
va_end(AP);
exit(1);
}
extern void
restart_kom (format, a, b, c, d, e, f, g)
const char * format;
int a, b, c, d, e, f, g;
{
fprintf(stdout, format, a, b, c, d, e, f, g);
exit(1);
}
#endif
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
static Person_scratchpad *
alloc_person_scratchpad(void)
{
Person_scratchpad *p;
p = smalloc(sizeof(Person_scratchpad));
*p = EMPTY_PERSON_SCRATCHPAD;
return p;
}
static Bool
is_comment_to(Text_no comment,
Text_stat *parent)
{
int i;
for ( i = 0; i < parent->no_of_misc; i++ )
{
switch( parent->misc_items[ i ].type )
{
case comm_in:
if ( parent->misc_items[ i ].datum.commented_in == comment )
return TRUE;
break;
default:
break;
}
}
return FALSE;
}
static Bool
is_commented_in(Text_no parent,
Text_stat *child)
{
int i;
for ( i = 0; i < child->no_of_misc; i++ )
{
switch( child->misc_items[ i ].type )
{
case comm_to:
if ( child->misc_items[ i ].datum.comment_to == parent )
return TRUE;
break;
default:
break;
}
}
return FALSE;
}
static Bool
is_footnote_to(Text_no footnote,
Text_stat *parent)
{
int i;
for ( i = 0; i < parent->no_of_misc; i++ )
{
switch( parent->misc_items[ i ].type )
{
case footn_in:
if ( parent->misc_items[ i ].datum.footnoted_in == footnote )
return TRUE;
break;
default:
break;
}
}
return FALSE;
}
static Bool
is_footnoted_in(Text_no parent,
Text_stat *child)
{
int i;
for ( i = 0; i < child->no_of_misc; i++ )
{
switch( child->misc_items[ i ].type )
{
case footn_to:
if ( child->misc_items[ i ].datum.footnote_to == parent )
return TRUE;
break;
default:
break;
}
}
return FALSE;
}
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
locate_member(Pers_no pers_no,
Conference * conf_c)
{
Member * member;
int i;
for(member = conf_c->members.members, i = conf_c->members.no_of_members;
i > 0; i--, member++)
{
if ( member->member == pers_no )
{
return member;
}
}
return NULL;
}
/*
* Delete a misc_info.
* If it is a recpt, cc_recpt, comm_to or footn_to delete any
* loc_no, rec_time, sent_by or sent_at that might follow it.
*
* Note that the Misc_info is not reallocated.
*/
static void
delete_misc (Text_stat *tstat,
Misc_info *misc) /* Pointer to first misc_item to delete. */
{
int del = 1; /* Number of items to delete. */
/* Always delete at least one item. */
Bool ready;
/* Check range of misc */
if (misc < tstat->misc_items
|| misc >= tstat->misc_items + tstat->no_of_misc )
{
restart_kom("delete_misc() - misc out of range");
}
ready = FALSE;
while (ready == FALSE
&& misc + del < tstat->misc_items + tstat->no_of_misc )
{
switch ( misc[ del ].type )
{
case loc_no:
case rec_time:
case sent_by:
case sent_at:
del++;
break;
case recpt:
case cc_recpt:
case footn_to:
case footn_in:
case comm_to:
case comm_in:
ready = TRUE;
break;
#ifndef COMPILE_CHECKS
default:
restart_kom("delete_misc() - illegal misc found.\n");
#endif
}
}
tstat->no_of_misc -= del;
/* Move items beyond the deleted ones. */
while ( misc < tstat->misc_items + tstat->no_of_misc )
{
misc[ 0 ] = misc[ del ];
misc++;
}
}
static int
confirm(char *question)
{
if ( iflag )
{
fputs(question, stdout);
fputs(" (y/n) ", stdout);
while(1)
switch(getchar())
{
case 'y':
case 'Y':
return 1;
case 'n':
case 'N':
case EOF:
return 0;
default:
break;
}
}
else
return 0;
}
static long
check_misc_infos(Text_no tno,
Text_stat *tstat)
{
const Misc_info * misc = tstat->misc_items;
Misc_info * previous;
Misc_info_group group;
Conference *c;
Text_stat *t;
long error=0;
while (previous = (Misc_info *)misc,
group = parse_next_misc(&misc,
tstat->misc_items + tstat->no_of_misc),
group.type != m_end_of_list && group.type != m_error )
{
switch ( group.type )
{
case m_recpt:
c = cached_get_conf_stat (group.recipient);
if ( c == NULL && group.recipient == 0 )
{
log ("Conference 0 is recipient to text %lu.\n", (unsigned long)tno);
if (rflag || confirm("Repair by deleting misc_item? "))
{
delete_misc(tstat, previous);
mark_text_as_changed(tno);
modifications++;
log("Repaired: Conference 0 is no longer a recipient.\n");
misc = previous;
}
else
error++;
break;
}
if ( c == NULL )
break;
/* Check loc_no */
if ( group.local_no < c->texts.first_local_no )
{
log("Text %lu: Recipient %lu<%lu> loc_no is less than %lu\n",
(unsigned long)tno, (unsigned long)group.recipient,
(unsigned long)group.local_no,
(unsigned long)c->texts.first_local_no);
error++;
}
else if ( c->texts.first_local_no + c->texts.no_of_texts - 1
< group.local_no )
{
(unsigned long)tno, (unsigned long)group.recipient,
(unsigned long)group.local_no,
(unsigned long)(c->texts.first_local_no
+ c->texts.no_of_texts - 1));
error++;
}
else if ( c->texts.texts[group.local_no
- c->texts.first_local_no] != tno )
{
(unsigned long)tno, (unsigned long)group.recipient,
(unsigned long)group.local_no,
(unsigned long)c->texts.texts[group.local_no
- c->texts.first_local_no]);
error++;
}
break;
case m_cc_recpt:
c = cached_get_conf_stat (group.cc_recipient);
if ( c == NULL && group.cc_recipient == 0 )
{
log ("Conference 0 is cc_recipient to text %lu.\n",
(unsigned long)tno);
if (rflag || confirm("Repair by deleting misc_item? "))
{
delete_misc(tstat, previous);
mark_text_as_changed(tno);
modifications++;
misc = previous;
}
else
error++;
break;
}
if ( c == NULL )
break;
/* Check loc_no */
if ( group.local_no < c->texts.first_local_no )
{
log("Text %lu: CC_Recipient %lu<%lu> is less than %lu\n",
(unsigned long)tno, (unsigned long)group.cc_recipient,
(unsigned long)group.local_no,
(unsigned long)c->texts.first_local_no);
error++;
}
else if ( c->texts.first_local_no + c->texts.no_of_texts - 1
< group.local_no )
{
(unsigned long)tno, (unsigned long)group.cc_recipient,
(unsigned long)group.local_no,
(unsigned long)(c->texts.first_local_no
+ c->texts.no_of_texts - 1));
error++;
}
else if ( c->texts.texts[group.local_no
- c->texts.first_local_no] != tno )
{
(unsigned long)tno, (unsigned long)group.cc_recipient,
(unsigned long)group.local_no,
(unsigned long)c->texts.texts[group.local_no
- c->texts.first_local_no]);
error++;
}
break;
case m_comm_to:
t = cached_get_text_stat(group.comment_to);
if ( t == NULL )
{
log("Text %lu is a comment to %lu, which doesn't exist.\n",
(unsigned long)tno, (unsigned long)group.comment_to);
if (rflag || confirm("Repair by deleting misc_item? "))
{
delete_misc(tstat, previous);
mark_text_as_changed(tno);
modifications++;
log("Repaired: Comment-link deleted.\n");
misc = previous;
}
else
error++;
error++;
}
else if (!is_comment_to(tno, t))
{
log("Text %lu is a comment to %lu, but not the reverse.\n",
(unsigned long)tno, (unsigned long)group.comment_to);
error++;
}
break;
case m_comm_in:
t = cached_get_text_stat(group.commented_in);
if ( t == NULL )
{
log("Text %lu is commented in %lu, which doesn't exist.\n",
(unsigned long)tno, (unsigned long)group.commented_in);
if (rflag || confirm("Repair by deleting misc_item? "))
{
delete_misc(tstat, previous);
mark_text_as_changed(tno);
modifications++;
log("Repaired: Comment-link deleted.\n");
misc = previous;
}
else
error++;
}
else if (!is_commented_in(tno, t))
{
log("Text %lu is a comment to %lu, but not the reverse.\n",
(unsigned long)tno, (unsigned long)group.commented_in);
error++;
}
break;
case m_footn_to:
t = cached_get_text_stat(group.footnote_to);
if ( t == NULL )
{
log("Text %lu is a footnote to %lu, which doesn't exist.\n",
(unsigned long)tno, (unsigned long)group.footnote_to);
if (rflag || confirm("Repair by deleting misc_item? "))
{
delete_misc(tstat, previous);
mark_text_as_changed(tno);
modifications++;
log("Repaired: Footnote-link deleted.\n");
misc = previous;
}
else
error++;
}
else if (!is_footnote_to(tno, t))
{
log("Text %lu is a footnote to %lu, but not the reverse.\n",
(unsigned long)tno, (unsigned long)group.footnote_to);
error++;
}
break;
case m_footn_in:
t = cached_get_text_stat(group.footnoted_in);
if ( t == NULL )
{
log("Text %lu is footnoted in %lu, which doesn't exist.\n",
(unsigned long)tno, (unsigned long)group.footnoted_in);
if (rflag || confirm("Repair by deleting misc_item? "))
{
delete_misc(tstat, previous);
mark_text_as_changed(tno);
modifications++;
log("Repaired: Footnote-link deleted.\n");
misc = previous;
}
else
error++;
}
else if (!is_footnoted_in(tno, t))
{
log("Text %lu is a footnot to %lu, but not the reverse.\n",
(unsigned long)tno, (unsigned long)group.footnoted_in);
error++;
}
break;
default:
log("check_misc_infos(): parse_next_misc returned type %lu\n",
(unsigned long)group.type);
break;
}
}
if ( group.type == m_error )
{
log("Text %lu has a bad misc_info_list.\n", (unsigned long)tno);
error++;
}
return error;
}
static long
check_texts(void)
{
Text_no ct = 0;
Text_stat *ctp=NULL;
long errors = 0;
Text_no number_of_texts = 0;
unsigned long bytes=0;
unsigned long max_bytes=0;
while ( (ct = traverse_text(ct)) != 0 )
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
{
number_of_texts++;
ctp = cached_get_text_stat( ct );
if ( ctp == NULL )
{
log("Text %lu nonexistent.\n", ct);
errors++;
}
else
{
bytes += ctp->no_of_chars;
if ( ctp->no_of_chars > max_bytes )
{
max_bytes = ctp->no_of_chars;
max_text = ct;
}
/* no_of_marks is not yet checked. */
errors += check_misc_infos(ct, ctp);
}
}
if (vflag)
{
if ( number_of_texts == 0 )
log("WARNING: No texts found.\n");
else
{
log("Total of %lu texts (total %lu bytes, avg. %lu bytes/text).\n",
(unsigned long)number_of_texts,
(unsigned long)bytes,
(unsigned long)(bytes/number_of_texts));
(unsigned long)max_text, (unsigned long)max_bytes);
}
}
return errors;
}
static Bool
adjust_text_list(Text_list *text_list)
{
unsigned long zeroes;
unsigned long i;
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
for (zeroes = 0;
zeroes < text_list->no_of_texts && text_list->texts[ zeroes ] == 0;
zeroes++)
;
if ( zeroes > 0 )
{
text_list->no_of_texts -= zeroes;
text_list->first_local_no += zeroes;
for ( i = 0; i < text_list->no_of_texts; i++)
text_list->texts[ i ] = text_list->texts[ i + zeroes ];
text_list->texts = srealloc(text_list->texts,
(text_list->no_of_texts
* sizeof(Text_no)));
}
return zeroes > 0;
}
static int
check_created_texts(Pers_no pno,
Text_list *created)
{
unsigned long i;
Text_stat *t;
int error=0;
for ( i=0; i < created->no_of_texts; i++ )
{
if (created->texts[i] != 0)
{
t = cached_get_text_stat(created->texts[i]);
if ( t != NULL && t->author != pno)
{
log("Person %lu is author of text %lu whose author is %lu.\n",
(unsigned long)pno, (unsigned long)created->texts[i],
(unsigned long)t->author);
error++;
}
if ( t == NULL )
{
log("Person %lu is author of text %lu, which doesn't exist.\n",
(unsigned long)pno, (unsigned long)created->texts[i]);
if ( rflag ||
confirm("Repair by setting to text_no to 0 in local map"))
{
created->texts[i] = 0;
mark_person_as_changed(pno);
modifications++;
log("Repaired: created_texts corrected.\n");
}
else
error++;
}
}
}
if ( created->no_of_texts > 0 && created->texts[0] == 0 )
{
log("Person %lu has a bad created_texts array. Starts with a 0.\n",
(unsigned long)pno);
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
if ( rflag || confirm ("Repair by adjusting created_texts"))
{
adjust_text_list(created);
mark_person_as_changed(pno);
modifications++;
log("Repaired: created_texts adjusted.\n");
}
else
error++;
}
return error;
}
static int
check_membership(Pers_no pno,
const Membership *mship)
{
int error=0;
Conference *conf;
int i;
Local_text_no last=0;
conf = cached_get_conf_stat(mship->conf_no);
if ( conf == NULL )
{
log("Person %lu is a member in the non-existing conference %lu.\n",
(unsigned long)pno, (unsigned long)mship->conf_no);
error++;
}
else
{
/* Check read texts */
if ( mship->last_text_read >
conf->texts.first_local_no + conf->texts.no_of_texts - 1)
{
log("Person %lu %s %lu in conf %lu, which only has %lu texts.\n",
(unsigned long)pno,
(unsigned long)mship->last_text_read,
(unsigned long)mship->conf_no,
(unsigned long)(conf->texts.first_local_no
+ conf->texts.no_of_texts - 1));
error++;
}
for ( last = i = 0; i < mship->no_of_read; i++)
{
if ( mship->read_texts[i] <= last )
{
(unsigned long)pno, (unsigned long)mship->conf_no,
(unsigned long)mship->read_texts[i], (unsigned long)i, (unsigned long)last);
error++;
}
last = mship->read_texts[i];
}
/* Check that he is a member */
if ( locate_member(pno, conf) == NULL )
{
log("Person %lu is a member in %lu in which he isn't a member.\n",
(unsigned long)pno, (unsigned long)mship->conf_no);
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
error++;
}
}
return error;
}
static int
check_membership_list(Pers_no pno,
const Membership_list *mlist)
{
int errors=0;
int i;
for (i = 0; i < mlist->no_of_confs; i++)
errors += check_membership(pno, &mlist->confs[i]);
return errors;
}
static int
check_persons(void)
{
Pers_no cp = 0;
Person *pstat=NULL;
Conference *cstat=NULL;
long errors = 0;
Pers_no number_of_persons=0;
while ( (cp = traverse_person(cp)) != 0 )
{
number_of_persons++;
pstat = cached_get_person_stat (cp);
cstat = cached_get_conf_stat (cp);
if ( pstat == NULL )
{
log("Person %lu nonexistent.\n", (unsigned long)cp);
log("Person %lu has no conference.\n", (unsigned long)cp);
errors++;
}
else if (!cstat->type.letter_box)
{
log("Person %lu's conference is not a letter_box.\n",
(unsigned long)cp);
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
errors++;
}
else
{
errors += (check_created_texts(cp, &pstat->created_texts)
+ check_membership_list(cp, &pstat->conferences));
}
}
if (vflag)
log("Total of %lu persons.\n", number_of_persons);
return errors;
}
static Bool
is_recipient(Conf_no conf_no,
Text_stat * t_stat)
{
int i;
for ( i = 0; i < t_stat->no_of_misc; i++ )
{
switch( t_stat->misc_items[ i ].type )
{
case recpt:
if ( t_stat->misc_items[ i ].datum.recipient == conf_no )
{
return TRUE;
}
break;
case cc_recpt:
if ( t_stat->misc_items[ i ].datum.cc_recipient == conf_no )
{
return TRUE;
}
break;
case rec_time:
case comm_to:
case comm_in:
case footn_to:
case footn_in:
case sent_by:
case sent_at:
case loc_no:
break;
#ifndef COMPILE_CHECKS
default:
restart_kom("is_recipient(): illegal misc_item\n");
#endif
}
}
return FALSE;
}
static int
check_texts_in_conf(Conf_no cc,
Text_list *tlist)
{
unsigned long i;
Text_stat *t;
int error=0;
for ( i=0; i < tlist->no_of_texts; i++ )
{
if (tlist->texts[i] != 0)
{
t = cached_get_text_stat(tlist->texts[i]);
if ( t == NULL )
{
log("Text %lu<%lu> in conference %lu is non-existent.\n",
(unsigned long)tlist->texts[i],
(unsigned long)i + tlist->first_local_no,
(unsigned long)cc);
if (rflag
|| confirm("Repair by setting Text_no to 0 in the map?") )
{
tlist->texts[i]=0;
mark_conference_as_changed(cc);
modifications++;
log("Repaired: %lu is no longer a recipient.\n",
(unsigned long)cc);
}
else
error++;
}
else
{
if ( !is_recipient(cc, t) )
{
(unsigned long)tlist->texts[i],
(unsigned long)i + tlist->first_local_no,
(unsigned long)cc,
if (confirm("Repair by setting Text_no to 0 in the map?") )
{
tlist->texts[i]=0;
mark_conference_as_changed(cc);
modifications++;
log("Repaired: %lu is no longer a recipient.\n",
(unsigned long)cc);
}
else
error++;
}
}
}
}
if ( tlist->no_of_texts > 0 && tlist->texts[0] == 0 )
{
log("Conference %lu has a bad Text_list. Starts with a 0.\n",
(unsigned long)cc);
if ( rflag || confirm ("Repair by adjusting text_list"))
{
adjust_text_list(tlist);
mark_conference_as_changed(cc);
modifications++;
log("Repaired: text_list adjusted.\n");
}
else
error++;
}
return error;
}
locate_membership(Conf_no conf_no,
Person * pers_p)
{
Membership * confp;
int i;
for(confp = pers_p->conferences.confs, i = pers_p->conferences.no_of_confs;
i > 0; i--, confp++)
{
if ( confp->conf_no == conf_no )
{
return confp;
}
}
return NULL;
}