/* This file is part of the Zebra server.
- Copyright (C) 1994-2010 Index Data
+ Copyright (C) Index Data
Zebra 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
* ref_count (2 bytes)
* block (500 bytes)
*
- * Format of subsequent blocks
+ * Format of subsequent blocks
* next (8 bytes)
* block (502 bytes)
*
* (length, data) - pairs
* length = 0 if same as previous
*/
+#if HAVE_CONFIG_H
+#include <config.h>
+#endif
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
/* the list of blocks can all be removed (ref == 0) */
first = 0;
}
-
+
if (bf_write(p->data_BFile[dst_type], freeblock, 0, sizeof(freeblock),
&p->head.block_free[dst_type]))
{
cptr = p->tmp_buf + no_written;
}
block_prev = block_free;
- no_written += CAST_ZINT_TO_INT(p->head.block_size[dst_type])
+ no_written += CAST_ZINT_TO_INT(p->head.block_size[dst_type])
- sizeof(zint);
p->head.block_used[dst_type]++;
}
}
if (rw)
{
- if (recindex_write_head(p->recindex,
+ if (recindex_write_head(p->recindex,
&p->head, sizeof(p->head)) != ZEBRA_OK)
ret = ZEBRA_FAIL;
}
}
if (i == 0)
{
- rec_encode_zint(rec_sysno_to_int(rec->sysno),
+ rec_encode_zint(rec_sysno_to_int(rec->sysno),
(unsigned char *) *out_buf + *out_offset, &len);
(*out_offset) += len;
}
#endif
break;
case REC_COMPRESS_BZIP2:
-#if HAVE_BZLIB_H
+#if HAVE_BZLIB_H
csize = out_offset + (out_offset >> 6) + 620;
rec_tmp_expand(p, csize);
#ifdef BZ_CONFIG_ERROR
- i = BZ2_bzBuffToBuffCompress
+ i = BZ2_bzBuffToBuffCompress
#else
- i = bzBuffToBuffCompress
+ i = bzBuffToBuffCompress
#endif
(p->tmp_buf+sizeof(zint)+sizeof(short)+
sizeof(char),
case REC_COMPRESS_NONE:
break;
}
- if (!csize)
+ if (!csize)
{
/* either no compression or compression not supported ... */
csize = out_offset;
memcpy(p->tmp_buf + sizeof(zint), &ref_count, sizeof(ref_count));
memcpy(p->tmp_buf + sizeof(zint)+sizeof(short),
&compression_method, sizeof(compression_method));
-
+
/* -------- compression */
if (rec_write_tmp_buf(p, csize + sizeof(short) + sizeof(char), sysnos)
!= ZEBRA_OK)
{
struct record_cache_entry *e = p->record_cache + i;
rec_free(&e->rec);
- }
+ }
/* i still being used ... */
for (j = 0; j<saveCount; j++, i++)
memcpy(p->record_cache+j, p->record_cache+i,
freeblock = entry.next / 8;
assert(freeblock > 0);
-
+
rec_tmp_expand(p, entry.size);
cptr = p->tmp_buf;
zint tmp;
cptr += p->head.block_size[dst_type] - sizeof(freeblock);
-
+
memcpy(&tmp, cptr, sizeof(tmp));
r = bf_read(p->data_BFile[dst_type], freeblock, 0, 0, cptr);
if (r < 0)
(const Bytef *) in_buf, in_size);
if (i == Z_OK)
{
- bz_size = destLen;
+ bz_size = destLen;
break;
}
yaz_log(YLOG_LOG, "failed");
return rec_get(p, rec_sysno_to_ext(1));
}
+Record rec_get_next(Records p, Record rec)
+{
+ Record next = 0;
+ zint next_sysno_int = rec_sysno_to_int(rec->sysno);
+
+ while (!next)
+ {
+ ++next_sysno_int;
+ if (next_sysno_int == p->head.index_last)
+ break;
+ next = rec_get(p, rec_sysno_to_ext(next_sysno_int));
+ }
+ return next;
+}
+
static Record rec_new_int(Records p)
{
int i;
{
int i;
zint total_bytes = 0;
-
+
yaz_log (YLOG_LOG,
"Total records %8" ZINT_FORMAT0,
records->head.no_records);