X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=bfile%2Fcommit.c;h=171591373a17d1dbd1f437e98152909a4319d74c;hb=6c9fcd3b5d3108702fa1ffc92dab4ab6060f9a19;hp=875a27dcdc2ed3d44591d329e415898b08b525e9;hpb=2e4e9c6def27f1e1463dcb6f205fab6a98054f38;p=idzebra-moved-to-github.git diff --git a/bfile/commit.c b/bfile/commit.c index 875a27d..1715913 100644 --- a/bfile/commit.c +++ b/bfile/commit.c @@ -1,6 +1,6 @@ -/* $Id: commit.c,v 1.17 2004-08-04 08:35:22 adam Exp $ - Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002,2003,2004 - Index Data Aps +/* $Id: commit.c,v 1.23 2005-01-15 19:38:17 adam Exp $ + Copyright (C) 1995-2005 + Index Data ApS This file is part of the Zebra server. @@ -21,12 +21,11 @@ Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA */ - #include #include #include -#include +#include "mfile.h" #include "cfile.h" #define CF_OPTIMIZE_COMMIT 0 @@ -35,7 +34,7 @@ void cf_unlink (CFile cf) { if (cf->bucket_in_memory) { - logf (LOG_FATAL, "Cannot unlink potential dirty cache"); + yaz_log (YLOG_FATAL, "Cannot unlink potential dirty cache"); exit (1); } cf->head.state = 0; @@ -97,7 +96,7 @@ static void map_cache_flush (struct map_cache *m_p) if (!mf_read (m_p->cf->block_mf, m_p->map[i].from, 0, 0, m_p->buf + i * m_p->cf->head.block_size)) { - logf (LOG_FATAL, "read commit block at position %d", + yaz_log (YLOG_FATAL, "read commit block at position %d", m_p->map[i].from); exit (1); } @@ -137,7 +136,8 @@ static void map_cache_add (struct map_cache *m_p, int from, int to) static void cf_commit_hash (CFile cf) { - int i, bucket_no; + int i; + zint bucket_no; int hash_bytes; struct CFile_ph_bucket *p; #if CF_OPTIMIZE_COMMIT @@ -149,13 +149,13 @@ static void cf_commit_hash (CFile cf) #endif p = (struct CFile_ph_bucket *) xmalloc (sizeof(*p)); - hash_bytes = cf->head.hash_size * sizeof(int); + hash_bytes = cf->head.hash_size * sizeof(zint); bucket_no = cf->head.first_bucket; for (; bucket_no < cf->head.next_bucket; bucket_no++) { if (!mf_read (cf->hash_mf, bucket_no, 0, 0, p)) { - logf (LOG_FATAL, "read commit hash"); + yaz_log (YLOG_FATAL, "read commit hash"); exit (1); } for (i = 0; ivno[i]; i++) @@ -165,7 +165,7 @@ static void cf_commit_hash (CFile cf) #else if (!mf_read (cf->block_mf, p->vno[i], 0, 0, cf->iobuf)) { - logf (LOG_FATAL, "read commit block"); + yaz_log (YLOG_FATAL, "read commit block"); exit (1); } mf_write (cf->rmf, p->no[i], 0, 0, cf->iobuf); @@ -181,7 +181,7 @@ static void cf_commit_hash (CFile cf) static void cf_commit_flat (CFile cf) { zint *fp; - int hno; + zint hno; int i; zint vno = 0; @@ -196,15 +196,16 @@ static void cf_commit_flat (CFile cf) fp = (zint *) xmalloc (HASH_BSIZE); for (hno = cf->head.next_bucket; hno < cf->head.flat_bucket; hno++) { - for (i = 0; i < (int) (HASH_BSIZE/sizeof(int)); i++) + for (i = 0; i < (int) (HASH_BSIZE/sizeof(zint)); i++) fp[i] = 0; if (!mf_read (cf->hash_mf, hno, 0, 0, fp) && hno != cf->head.flat_bucket-1) { - logf (LOG_FATAL, "read index block hno=%d (" ZINT_FORMAT "-" ZINT_FORMAT ") commit", + yaz_log (YLOG_FATAL, "read index block hno=" ZINT_FORMAT + " (" ZINT_FORMAT "-" ZINT_FORMAT ") commit", hno, cf->head.next_bucket, cf->head.flat_bucket-1); } - for (i = 0; i < (int) (HASH_BSIZE/sizeof(int)); i++) + for (i = 0; i < (int) (HASH_BSIZE/sizeof(zint)); i++) { if (fp[i]) { @@ -213,7 +214,7 @@ static void cf_commit_flat (CFile cf) #else if (!mf_read (cf->block_mf, fp[i], 0, 0, cf->iobuf)) { - logf (LOG_FATAL, "read data block hno=%d (" ZINT_FORMAT "-" ZINT_FORMAT ") " + yaz_log (YLOG_FATAL, "read data block hno=" ZINT_FORMAT " (" ZINT_FORMAT "-" ZINT_FORMAT ") " "i=%d commit block at " ZINT_FORMAT " (->" ZINT_FORMAT")", hno, cf->head.next_bucket, cf->head.flat_bucket-1, i, fp[i], vno); @@ -237,7 +238,7 @@ void cf_commit (CFile cf) if (cf->bucket_in_memory) { - logf (LOG_FATAL, "Cannot commit potential dirty cache"); + yaz_log (YLOG_FATAL, "Cannot commit potential dirty cache"); exit (1); } if (cf->head.state == 1)