bfile/commit.c

   1 /*
   2  * Copyright (C) 1995, Index Data I/S
   3  * All rights reserved.
   4  * Sebastian Hammer, Adam Dickmeiss
   5  *
   6  * $Log: commit.c,v $
   7  * Revision 1.7  1996-02-07 10:08:46  adam
   8  * Work on flat shadow (not finished yet).
   9  *
  10  * Revision 1.6  1995/12/15  12:36:53  adam
  11  * Moved hash file information to union.
  12  * Renamed commit files.
  13  *
  14  * Revision 1.5  1995/12/12  15:57:55  adam
  15  * Implemented mf_unlink. cf_unlink uses mf_unlink.
  16  *
  17  * Revision 1.4  1995/12/11  09:03:55  adam
  18  * New function: cf_unlink.
  19  * New member of commit file head: state (0) deleted, (1) hash file.
  20  *
  21  * Revision 1.3  1995/12/01  16:24:29  adam
  22  * Commit files use separate meta file area.
  23  *
  24  * Revision 1.2  1995/12/01  11:37:24  adam
  25  * Cached/commit files implemented as meta-files.
  26  *
  27  * Revision 1.1  1995/11/30  08:33:13  adam
  28  * Started work on commit facility.
  29  *
  30  */
  31
  32 #include <assert.h>
  33 #include <stdlib.h>
  34
  35 #include <alexutil.h>
  36 #include <mfile.h>
  37 #include "cfile.h"
  38
  39 void cf_unlink (CFile cf)
  40 {
  41     if (cf->bucket_in_memory)
  42     {
  43         logf (LOG_FATAL, "Cannot unlink potential dirty cache");
  44         exit (1);
  45     }
  46     cf->head.state = 0;
  47     cf->dirty = 1;
  48     mf_unlink (cf->block_mf);
  49     mf_unlink (cf->hash_mf);
  50 }
  51
  52 void cf_commit (CFile cf)
  53 {
  54     int i, bucket_no;
  55     int hash_bytes;
  56     struct CFile_ph_bucket *p;
  57
  58     if (cf->bucket_in_memory)
  59     {
  60         logf (LOG_FATAL, "Cannot commit potential dirty cache");
  61         exit (1);
  62     }
  63     p = xmalloc (sizeof(*p));
  64     hash_bytes = cf->head.hash_size * sizeof(int);
  65     bucket_no = (hash_bytes+sizeof(cf->head))/HASH_BSIZE + 2;
  66     for (; bucket_no < cf->head.next_bucket; bucket_no++)
  67     {
  68         if (!mf_read (cf->hash_mf, bucket_no, 0, 0, p))
  69         {
  70             logf (LOG_FATAL, "read commit hash");
  71             exit (1);
  72         }
  73         for (i = 0; i<HASH_BUCKET && p->vno[i]; i++)
  74         {
  75             if (!mf_read (cf->block_mf, p->vno[i], 0, 0, cf->iobuf))
  76             {
  77                 logf (LOG_FATAL, "read commit block");
  78                 exit (1);
  79             }
  80             mf_write (cf->rmf, p->no[i], 0, 0, cf->iobuf);
  81         }
  82     }
  83     xfree (p);
  84 }
  85