|
Packit |
1c1d7e |
/******************************************************************************
|
|
Packit |
1c1d7e |
*
|
|
Packit |
1c1d7e |
*
|
|
Packit |
1c1d7e |
*
|
|
Packit |
1c1d7e |
*
|
|
Packit |
1c1d7e |
* Copyright (C) 1997-2015 by Dimitri van Heesch.
|
|
Packit |
1c1d7e |
*
|
|
Packit |
1c1d7e |
* Permission to use, copy, modify, and distribute this software and its
|
|
Packit |
1c1d7e |
* documentation under the terms of the GNU General Public License is hereby
|
|
Packit |
1c1d7e |
* granted. No representations are made about the suitability of this software
|
|
Packit |
1c1d7e |
* for any purpose. It is provided "as is" without express or implied warranty.
|
|
Packit |
1c1d7e |
* See the GNU General Public License for more details.
|
|
Packit |
1c1d7e |
*
|
|
Packit |
1c1d7e |
* Documents produced by Doxygen are derivative works derived from the
|
|
Packit |
1c1d7e |
* input used in their production; they are not affected by this license.
|
|
Packit |
1c1d7e |
*
|
|
Packit |
1c1d7e |
*/
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
#include "store.h"
|
|
Packit |
1c1d7e |
#include "portable.h"
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
#include <stdio.h>
|
|
Packit |
1c1d7e |
#include <stdlib.h>
|
|
Packit |
1c1d7e |
#include <errno.h>
|
|
Packit |
1c1d7e |
#include <string.h>
|
|
Packit |
1c1d7e |
#include <assert.h>
|
|
Packit |
1c1d7e |
#include <ctype.h>
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
#define BLOCK_SIZE 512 // should be >8 and a power of 2
|
|
Packit |
1c1d7e |
#define BLOCK_POINTER_SIZE sizeof(portable_off_t)
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
#define ASSERTS_ENABLED
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
#ifdef ASSERTS_ENABLED
|
|
Packit |
1c1d7e |
#define STORE_ASSERT(x) assert(x)
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
#define STORE_ASSERT(x)
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
// Decide to use ftell or keep track of the current file pointer ourselves.
|
|
Packit |
1c1d7e |
// Since valgrind shows that calling ftell has the unwanted side-effect of
|
|
Packit |
1c1d7e |
// writing some uninitialized bytes (!) it might be better (and faster) to keep track
|
|
Packit |
1c1d7e |
// of the current pointer ourselves.
|
|
Packit |
1c1d7e |
#define USE_FTELL 0
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
//------------------------------------------------------------------------------------
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
Store::Store()
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
m_file = 0;
|
|
Packit |
1c1d7e |
m_front = 0;
|
|
Packit |
1c1d7e |
m_cur = 0;
|
|
Packit |
1c1d7e |
m_head = 0;
|
|
Packit |
1c1d7e |
m_state = Init;
|
|
Packit |
1c1d7e |
m_reads = 0;
|
|
Packit |
1c1d7e |
m_writes = 0;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
Store::~Store()
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
if (m_file) fclose(m_file);
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
// clean up free list
|
|
Packit |
1c1d7e |
while (m_head)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
Node *node = m_head;
|
|
Packit |
1c1d7e |
m_head = node->next;
|
|
Packit |
1c1d7e |
delete node;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
int Store::open(const char *name)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
int i;
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_state==Init);
|
|
Packit |
1c1d7e |
if (m_file) return 0; // already open
|
|
Packit |
1c1d7e |
m_file = portable_fopen(name,"w+b");
|
|
Packit |
1c1d7e |
if (m_file==0) return -1;
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
// first block serves as header, so offset=0 can be used as the end of the list.
|
|
Packit |
1c1d7e |
for (i=0;i
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fputc('D',m_file);
|
|
Packit |
1c1d7e |
fputc('O',m_file);
|
|
Packit |
1c1d7e |
fputc('X',m_file);
|
|
Packit |
1c1d7e |
fputc('Y',m_file);
|
|
Packit |
1c1d7e |
fputc('G',m_file);
|
|
Packit |
1c1d7e |
fputc('E',m_file);
|
|
Packit |
1c1d7e |
fputc('N',m_file);
|
|
Packit |
1c1d7e |
fputc(0,m_file);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_front = BLOCK_SIZE;
|
|
Packit |
1c1d7e |
m_cur = BLOCK_SIZE;
|
|
Packit |
1c1d7e |
m_head = 0;
|
|
Packit |
1c1d7e |
m_state = Reading;
|
|
Packit |
1c1d7e |
return 0;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
void Store::close()
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
if (m_file) fclose(m_file);
|
|
Packit |
1c1d7e |
m_file=0;
|
|
Packit |
1c1d7e |
m_state = Init;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
portable_off_t Store::alloc()
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_state==Reading);
|
|
Packit |
1c1d7e |
m_state=Writing;
|
|
Packit |
1c1d7e |
portable_off_t pos;
|
|
Packit |
1c1d7e |
if (m_head==0) // allocate new block
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
//printf("alloc: new block, pos=%lld\n",(long long)m_front);
|
|
Packit |
1c1d7e |
if (portable_fseek(m_file,0,SEEK_END)==-1) // go to end of the file
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Store::alloc: Error seeking to end of file: %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
#if USE_FTELL
|
|
Packit |
1c1d7e |
pos = portable_ftell(m_file);
|
|
Packit |
1c1d7e |
STORE_ASSERT( (pos & (BLOCK_SIZE-1))==0 );
|
|
Packit |
1c1d7e |
m_front = pos + BLOCK_SIZE; // move front to end of this block
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
m_cur = m_front;
|
|
Packit |
1c1d7e |
pos = m_cur;
|
|
Packit |
1c1d7e |
STORE_ASSERT( (pos & (BLOCK_SIZE-1))==0 );
|
|
Packit |
1c1d7e |
m_front = pos + BLOCK_SIZE;
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
else // reuse freed block
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
//printf("alloc: reuse block: pos=%lld\n",(long long)m_head->pos);
|
|
Packit |
1c1d7e |
Node *node = m_head;
|
|
Packit |
1c1d7e |
pos = node->pos;
|
|
Packit |
1c1d7e |
// point head to next free item
|
|
Packit |
1c1d7e |
m_head = node->next;
|
|
Packit |
1c1d7e |
delete node;
|
|
Packit |
1c1d7e |
// move to start of the block
|
|
Packit |
1c1d7e |
if (portable_fseek(m_file,pos,SEEK_SET)==-1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Store::alloc: Error seeking to position %d: %s\n",
|
|
Packit |
1c1d7e |
(int)pos,strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur = pos;
|
|
Packit |
1c1d7e |
STORE_ASSERT( (pos & (BLOCK_SIZE-1))==0 );
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
//printf("%x: Store::alloc\n",(int)pos);
|
|
Packit |
1c1d7e |
return pos;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
int Store::write(const char *buf,uint size)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_state==Writing);
|
|
Packit |
1c1d7e |
//printf("%x: Store::write\n",(int)portable_ftell(m_file));
|
|
Packit |
1c1d7e |
do
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
#if USE_FTELL
|
|
Packit |
1c1d7e |
portable_off_t curPos = portable_ftell(m_file);
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
portable_off_t curPos = m_cur;
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
int bytesInBlock = (int)(BLOCK_SIZE - BLOCK_POINTER_SIZE - (curPos & (BLOCK_SIZE-1)));
|
|
Packit |
1c1d7e |
int bytesLeft = bytesInBlock<(int)size ? (int)size-bytesInBlock : 0;
|
|
Packit |
1c1d7e |
int numBytes = size - bytesLeft;
|
|
Packit |
1c1d7e |
STORE_ASSERT(bytesInBlock>=0);
|
|
Packit |
1c1d7e |
STORE_ASSERT(numBytes<=(int)(BLOCK_SIZE-BLOCK_POINTER_SIZE));
|
|
Packit |
1c1d7e |
if (numBytes>0)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
if ((int)fwrite(buf,1,numBytes,m_file)!=numBytes)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Error writing: %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur+=numBytes;
|
|
Packit |
1c1d7e |
m_writes++;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
if (bytesLeft>0) // still more bytes to write
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
#if USE_FTELL
|
|
Packit |
1c1d7e |
STORE_ASSERT(((portable_ftell(m_file)+BLOCK_POINTER_SIZE)&(BLOCK_SIZE-1))==0);
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
STORE_ASSERT(((m_cur+BLOCK_POINTER_SIZE)&(BLOCK_SIZE-1))==0);
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
// allocate new block
|
|
Packit |
1c1d7e |
if (m_head==0) // no free blocks to reuse
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
//printf("%x: Store::write: new: pos=%x\n",(int)m_front,(int)portable_ftell(m_file));
|
|
Packit |
1c1d7e |
// write pointer to next block
|
|
Packit |
1c1d7e |
if (fwrite(&m_front,BLOCK_POINTER_SIZE,1,m_file)!=1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Error writing to store: %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur+=BLOCK_POINTER_SIZE;
|
|
Packit |
1c1d7e |
#if USE_FTELL
|
|
Packit |
1c1d7e |
STORE_ASSERT(portable_ftell(m_file)==(curPos&~(BLOCK_SIZE-1))+BLOCK_SIZE);
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_cur==(curPos&~(BLOCK_SIZE-1))+BLOCK_SIZE);
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
// move to next block
|
|
Packit |
1c1d7e |
if (portable_fseek(m_file,0,SEEK_END)==-1) // go to end of the file
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Store::alloc: Error seeking to end of file: %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur=m_front;
|
|
Packit |
1c1d7e |
#if USE_FTELL
|
|
Packit |
1c1d7e |
STORE_ASSERT(portable_ftell(m_file)==m_front);
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_cur==m_front);
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
// move front to the next of the block
|
|
Packit |
1c1d7e |
m_front+=BLOCK_SIZE;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
else // reuse block from the free list
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
// write pointer to next block
|
|
Packit |
1c1d7e |
if (fwrite(&m_head->pos,BLOCK_POINTER_SIZE,1,m_file)!=1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Error writing to store: %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
Node *node = m_head;
|
|
Packit |
1c1d7e |
portable_off_t pos = node->pos;
|
|
Packit |
1c1d7e |
// point head to next free item
|
|
Packit |
1c1d7e |
m_head = node->next;
|
|
Packit |
1c1d7e |
delete node;
|
|
Packit |
1c1d7e |
// move to start of the block
|
|
Packit |
1c1d7e |
if (portable_fseek(m_file,pos,SEEK_SET)==-1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Store::write: Error seeking to position %d: %s\n",
|
|
Packit |
1c1d7e |
(int)pos,strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur = pos;
|
|
Packit |
1c1d7e |
//printf("%x: Store::write: reuse\n",(int)pos);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
size-=numBytes;
|
|
Packit |
1c1d7e |
buf+=numBytes;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
while (size>0);
|
|
Packit |
1c1d7e |
return size;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
void Store::end()
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_state==Writing);
|
|
Packit |
1c1d7e |
#if USE_FTELL
|
|
Packit |
1c1d7e |
portable_off_t curPos = portable_ftell(m_file);
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
portable_off_t curPos = m_cur;
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
int bytesInBlock = (int)(BLOCK_SIZE - (curPos & (BLOCK_SIZE-1)));
|
|
Packit |
1c1d7e |
//printf("%x: Store::end erasing %x bytes\n",(int)curPos&~(BLOCK_SIZE-1),bytesInBlock);
|
|
Packit |
1c1d7e |
//printf("end: bytesInBlock=%x\n",bytesInBlock);
|
|
Packit |
1c1d7e |
// zero out rest of the block
|
|
Packit |
1c1d7e |
int i;
|
|
Packit |
1c1d7e |
for (i=0;i
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fputc(0,m_file);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_state=Reading;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
void Store::release(portable_off_t pos)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_state==Reading);
|
|
Packit |
1c1d7e |
//printf("release: block pos=%lld\n",(long long)pos);
|
|
Packit |
1c1d7e |
STORE_ASSERT(pos>0 && (pos & (BLOCK_SIZE-1))==0);
|
|
Packit |
1c1d7e |
// goto end of the block
|
|
Packit |
1c1d7e |
portable_off_t cur = pos, next;
|
|
Packit |
1c1d7e |
while (1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
// add new node to the free list
|
|
Packit |
1c1d7e |
Node *node = new Node;
|
|
Packit |
1c1d7e |
node->next = m_head;
|
|
Packit |
1c1d7e |
node->pos = cur;
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
m_head = node;
|
|
Packit |
1c1d7e |
// goto the end of cur block
|
|
Packit |
1c1d7e |
if (portable_fseek(m_file,cur+BLOCK_SIZE-BLOCK_POINTER_SIZE,SEEK_SET)==-1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Store::release: Error seeking to position %d: %s\n",
|
|
Packit |
1c1d7e |
(int)(cur+BLOCK_SIZE-BLOCK_POINTER_SIZE),strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
// read pointer to next block
|
|
Packit |
1c1d7e |
if (fread(&next,BLOCK_POINTER_SIZE,1,m_file)!=1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Store::release: Error reading from store: %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur = cur+BLOCK_SIZE;
|
|
Packit |
1c1d7e |
if (next==0) break; // found end of list -> cur is last element
|
|
Packit |
1c1d7e |
STORE_ASSERT((next & (BLOCK_SIZE-1))==0);
|
|
Packit |
1c1d7e |
cur = next;
|
|
Packit |
1c1d7e |
//printf("%x: Store::release\n",(int)cur);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
void Store::seek(portable_off_t pos)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_state==Reading);
|
|
Packit |
1c1d7e |
//printf("%x: Store::seek\n",(int)pos);
|
|
Packit |
1c1d7e |
if (portable_fseek(m_file,pos,SEEK_SET)==-1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Store::seek: Error seeking to position %d: %s\n",
|
|
Packit |
1c1d7e |
(int)pos,strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur = pos;
|
|
Packit |
1c1d7e |
STORE_ASSERT((pos&(BLOCK_SIZE-1))==0);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
int Store::read(char *buf,uint size)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
STORE_ASSERT(m_state==Reading);
|
|
Packit |
1c1d7e |
//printf("%x: Store::read total=%d\n",(int)portable_ftell(m_file),size);
|
|
Packit |
1c1d7e |
do
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
#if USE_FTELL
|
|
Packit |
1c1d7e |
portable_off_t curPos = portable_ftell(m_file);
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
portable_off_t curPos = m_cur;
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
int bytesInBlock = (int)(BLOCK_SIZE - BLOCK_POINTER_SIZE - (curPos & (BLOCK_SIZE-1)));
|
|
Packit |
1c1d7e |
int bytesLeft = bytesInBlock<(int)size ? (int)size-bytesInBlock : 0;
|
|
Packit |
1c1d7e |
int numBytes = size - bytesLeft;
|
|
Packit |
1c1d7e |
//printf(" Store::read: pos=%x num=%d left=%d\n",(int)curPos,numBytes,bytesLeft);
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
if (numBytes>0)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
//printf("%x: Store::read: %d out of %d bytes\n",(int)portable_ftell(m_file),numBytes,size);
|
|
Packit |
1c1d7e |
if ((int)fread(buf,1,numBytes,m_file)!=numBytes)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Error reading from store: %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur+=numBytes;
|
|
Packit |
1c1d7e |
m_reads++;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
if (bytesLeft>0)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
portable_off_t newPos;
|
|
Packit |
1c1d7e |
// read offset of the next block
|
|
Packit |
1c1d7e |
#if USE_FTELL
|
|
Packit |
1c1d7e |
STORE_ASSERT(((portable_ftell(m_file)+BLOCK_POINTER_SIZE)&(BLOCK_SIZE-1))==0);
|
|
Packit |
1c1d7e |
#else
|
|
Packit |
1c1d7e |
STORE_ASSERT(((m_cur+BLOCK_POINTER_SIZE)&(BLOCK_SIZE-1))==0);
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
if (fread((char *)&newPos,BLOCK_POINTER_SIZE,1,m_file)!=1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Error reading from store: %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
//printf("%x: Store::read: continue in next block, %d bytes to go\n",(int)newPos,bytesLeft);
|
|
Packit |
1c1d7e |
//printf(" Store::read: next block=%x\n",(int)newPos);
|
|
Packit |
1c1d7e |
STORE_ASSERT(newPos!=0);
|
|
Packit |
1c1d7e |
STORE_ASSERT((newPos&(BLOCK_SIZE-1))==0);
|
|
Packit |
1c1d7e |
curPos = newPos;
|
|
Packit |
1c1d7e |
// move to next block
|
|
Packit |
1c1d7e |
if (portable_fseek(m_file,curPos,SEEK_SET)==-1)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
fprintf(stderr,"Store::read: Error seeking to position %d: %s\n",
|
|
Packit |
1c1d7e |
(int)curPos,strerror(errno));
|
|
Packit |
1c1d7e |
exit(1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
m_cur = curPos;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
size-=numBytes;
|
|
Packit |
1c1d7e |
buf+=numBytes;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
while (size>0);
|
|
Packit |
1c1d7e |
return size;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
void Store::printFreeList()
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
printf("FreeList: ");
|
|
Packit |
1c1d7e |
while (m_head)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
portable_off_t pos = m_head->pos;
|
|
Packit |
1c1d7e |
printf("%x ",(int)pos);
|
|
Packit |
1c1d7e |
m_head = m_head->next;
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
printf("\n");
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
void Store::printStats()
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
printf("ObjStore: block size %d bytes, total size %ld blocks, wrote %d blocks, read %d blocks\n",
|
|
Packit |
1c1d7e |
BLOCK_SIZE,(long)(m_front/BLOCK_SIZE),m_reads,m_writes);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
void Store::dumpBlock(portable_off_t s,portable_off_t e)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
portable_fseek(m_file,s,SEEK_SET);
|
|
Packit |
1c1d7e |
int size = (int)(e-s);
|
|
Packit |
1c1d7e |
uchar *buf = new uchar[size];
|
|
Packit |
1c1d7e |
if (fread(buf,size,1,m_file)==(size_t)size)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
int i,j;
|
|
Packit |
1c1d7e |
for (i=0;i
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
printf("%08x: ",(int)s+i);
|
|
Packit |
1c1d7e |
for (j=i;j
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
printf("%02x ",buf[i+j]);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
printf(" ");
|
|
Packit |
1c1d7e |
for (j=i;j
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
printf("%c",(buf[i+j]>=32 && buf[i+j]<128)?buf[i+j]:'.');
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
printf("\n");
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
delete[] buf;
|
|
Packit |
1c1d7e |
portable_fseek(m_file,m_cur,SEEK_SET);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
#ifdef STORE_TEST
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
int main()
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
printf("sizeof(portable_off_t)=%d\n",(int)sizeof(portable_off_t));
|
|
Packit |
1c1d7e |
Store s;
|
|
Packit |
1c1d7e |
if (s.open("test.db")==0)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
const char *str1 = "This is a test message... ";
|
|
Packit |
1c1d7e |
const char *str2 = "Another message. ";
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
int i,j;
|
|
Packit |
1c1d7e |
for (j=0;j<5;j++)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
char buf[100];
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
portable_off_t handle = s.alloc();
|
|
Packit |
1c1d7e |
for (i=0;i<1000000000;i++)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
s.write(str1,strlen(str1)+1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
s.end();
|
|
Packit |
1c1d7e |
portable_off_t handle2 = s.alloc();
|
|
Packit |
1c1d7e |
for (i=0;i<10;i++)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
s.write(str2,strlen(str2)+1);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
s.end();
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
s.seek(handle);
|
|
Packit |
1c1d7e |
for (i=0;i<3;i++)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
s.read(buf,strlen(str1)+1);
|
|
Packit |
1c1d7e |
printf("i=%d Read: %s\n",i,buf);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
s.release(handle);
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
s.seek(handle2);
|
|
Packit |
1c1d7e |
for (i=0;i<3;i++)
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
s.read(buf,strlen(str2)+1);
|
|
Packit |
1c1d7e |
printf("i=%d Read: %s\n",i,buf);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
s.release(handle2);
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
s.close();
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
else
|
|
Packit |
1c1d7e |
{
|
|
Packit |
1c1d7e |
printf("Open failed! %s\n",strerror(errno));
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
}
|
|
Packit |
1c1d7e |
|
|
Packit |
1c1d7e |
#endif
|
|
Packit |
1c1d7e |
|