/include /src/Varios /Utilities/Jrntests Program, working with cyclic journal (eterbug #4090)

Utilities/JrnTests/Jrntest.cc

+/* This file is part of the UniSet project
+ * Copyright (c) 2002 Free Software Foundation, Inc.
+ * Copyright (c) 2002 Ivan Donchevskiy
+ *
+ * This program 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 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+ */
+// --------------------------------------------------------------------------
+/*! \file
+ *  \author Ivan Donchevskiy
+ *  \date   $Date: 2009/07/14 16:59:00 $
+ *  \version $Id: Jrn.h,v 1.0 2009/07/14 16:59:00 vpashka Exp $
+ */
+// --------------------------------------------------------------------------
+
+#include "stdio.h"
+#include "string.h"
+#include "Jrn.h"
+
+char* itoa(int val, int base)
+{
+	
+	static char buf[32] = {0};
+	
+	int i = 30;
+	
+	for(; val && i ; --i, val /= base)
+	
+		buf[i] = "0123456789abcdef"[val % base];
+	
+	return &buf[i+1];
+	
+}
+
+
+void testTable(void)
+{
+	char *chr=new char[2];
+	char *val=new char[2];
+	StorageTable *t;
+	t = new StorageTable("table.test", 6000, 0);
+	int i;
+	printf("testTable\nsize = %d\n",t->size);
+	for(i=0;i<t->size+5;i++)
+	{
+		chr[0]=i%256;
+		if(t->AddRow(chr,chr)==1) printf("elem number %d - no space in StorageTable\n",i);
+	}
+	printf("elements with values=keys added\n");
+	for(i=40;i<60;i++)
+	{
+		chr[0]=i%256;
+		t->DelRow(chr);
+	}
+	printf("elements with keys from 40 to 60 deleted\n");
+	for(i=30;i<50;i++)
+	{
+		chr[0]=i;
+		val[0]=i+40;
+		t->AddRow(chr,val);
+	}
+	printf("elements with keys from 30 to 50 with values=key+40 added\nvalues from keys 25-59\n");
+	for(i=25;i<60;i++)
+	{
+		chr[0]=i;
+		if(t->FindKeyValue(chr,val)!=0) printf("%d, ",val[0]);
+	}
+	printf("\n");
+}
+
+void testJournal1(void)
+{
+	CycleJournal *j;
+	int i;
+	char *str=new char[6];
+	printf("journal test 1\n");
+	j = new CycleJournal("journal.test",2000000,0);
+	printf("size = %d\n",j->size);
+	for(i=1;i<30000;i++)
+	{
+		str = itoa(i,10);
+		j->AddRow(str);
+	}
+	printf("\n20 elements from 10-th:\n");
+	j->ViewRows(10,20);
+	printf("\n20 elements from 10-th after deleting first 20:\n");
+	for(i=0;i<20;i++)
+	{
+		j->DelRow(i);
+	}
+	j->ViewRows(10,20);
+	printf("\nfirst 20 after adding 10 elements\n");
+	for(i=1;i<11;i++)
+	{
+		str = itoa(i,10);
+		j->AddRow(str);
+	}
+	j->ViewRows(0,20);
+	printf("\nthe same after reopen:\n");
+	delete j;
+	j = new CycleJournal("journal.test",2000000,0);
+	j->ViewRows(0,20);
+	printf("\n");
+}
+
+void testJournal2(void)
+{
+	CycleJournal *j;
+	int i,k;
+	char *str=new char[4];
+	j = new CycleJournal("journal.test",2000000,0);
+	printf("journal test 2 - checking number of iterations to find head/tail\n");
+	printf("size = %d\n\n",j->size);
+	printf("iterations = %d\n",j->iter);
+	for(i=0;i<20;i++)
+	{
+		for(k=0;k<1000;k++)
+		{
+			str = itoa(k,10);
+			j->AddRow(str);
+		}
+		delete j;
+		j = new CycleJournal("journal.test",2000000,0);
+		printf("iterations = %d\n",j->iter);
+	}
+	printf("\n");
+}
+
+
+int main(void)
+{
+	testTable();
+
+	testJournal1();
+
+	testJournal2();
+
+	return 0;
+}
\ No newline at end of file

include/Jrn.h

+/* This file is part of the UniSet project
+ * Copyright (c) 2002 Free Software Foundation, Inc.
+ * Copyright (c) 2002 Ivan Donchevskiy
+ *
+ * This program 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 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+ */
+// --------------------------------------------------------------------------
+/*! \file
+ *  \author Ivan Donchevskiy
+ *  \date   $Date: 2009/07/14 16:59:00 $
+ *  \version $Id: Jrn.h,v 1.0 2009/07/14 16:59:00 vpashka Exp $
+ */
+// --------------------------------------------------------------------------
+
+#include "stdio.h"
+#include "string.h"
+
+#define str_size 80
+#define key_size 20
+#define val_size 40
+
+struct StorageTableElem
+{
+	char key[key_size];
+	char value[val_size];
+} __attribute__((__packed__));
+
+struct CycleJournalElem
+{
+        char str[str_size];
+	int status;
+} __attribute__((__packed__));
+
+class StorageTable
+{
+	FILE *file;
+	int seekpos;
+	public:
+		int size;
+		StorageTable();
+		StorageTable(const char* name, int sz, int seek);
+		~StorageTable();
+		int AddRow(char* key, char* val);
+		int DelRow(char* key);
+		char* FindKeyValue(char* key, char* val);
+};
+
+class CycleJournal
+{
+	FILE *file;
+	int seekpos;
+	int head,tail;
+	public:
+		int size, iter;
+		CycleJournal();
+		CycleJournal(const char* name, int sz, int seek);
+		~CycleJournal();
+		int AddRow(char* str);
+		int DelRow(int row);
+		int DelAllRows(void);
+		int ViewRows(int beg, int num);
+};

src/Various/Jrn.cc

+/* This file is part of the UniSet project
+ * Copyright (c) 2002 Free Software Foundation, Inc.
+ * Copyright (c) 2002 Ivan Donchevskiy
+ *
+ * This program 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 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+ */
+// --------------------------------------------------------------------------
+/*! \file
+ *  \author Ivan Donchevskiy
+ *  \date   $Date: 2009/07/14 16:59:00 $
+ *  \version $Id: Jrn.h,v 1.0 2009/07/14 16:59:00 vpashka Exp $
+ */
+// --------------------------------------------------------------------------
+
+#include "stdio.h"
+#include "string.h"
+#include "Jrn.h"
+
+StorageTable::StorageTable()
+{
+	file = fopen("tbl", "r+");
+	if(file==NULL)
+	{
+		file = fopen("tbl","w");
+		StorageTableElem *t = new StorageTableElem();
+		for(int i=0;i<100;i++) fwrite(t,sizeof(*t),1,file);
+		fclose(file);
+		file = fopen("tbl","r+");
+	}
+	size=100;
+	seekpos=0;
+}
+
+StorageTable::StorageTable(const char* name, int sz, int seek)
+{
+	file = fopen(name, "r+");
+	size=sz/sizeof(StorageTableElem);
+	if(file==NULL)
+	{
+		file = fopen(name,"w");
+		StorageTableElem *t = new StorageTableElem();
+		for(int i=0;i<size;i++) fwrite(t,sizeof(*t),1,file);
+		fclose(file);
+		file = fopen(name,"r+");
+		seekpos=0;
+	}
+	else seekpos=seek;
+}
+
+StorageTable::~StorageTable()
+{
+	fclose(file);
+}
+
+int StorageTable::AddRow(char* key, char* value)
+{
+	StorageTableElem *tbl = new StorageTableElem();
+	int i;
+	if(file!=NULL)
+	{
+		fseek(file,seekpos,0);
+		for(i=0;i<size;i++)
+		{
+			fread(tbl,sizeof(*tbl),1,file);
+			if(!strcmp(tbl->key,key))
+			{
+				strcpy(tbl->value,value);
+				fseek(file,seekpos+i*sizeof(*tbl),0);
+				fwrite(tbl,sizeof(*tbl),1,file);
+				return 0;
+			}
+		}
+		fseek(file,seekpos,0);
+		for(i=0;i<size;i++)
+		{
+			fread(tbl,sizeof(*tbl),1,file);
+			if(*(tbl->key)==0)
+			{
+				strcpy(tbl->key,key);
+				strcpy(tbl->value,value);
+				fseek(file,seekpos+i*sizeof(*tbl),0);
+				fwrite(tbl,sizeof(*tbl),1,file);
+				return 0;
+			}	
+		}
+	}
+	return 1;
+}
+
+int StorageTable::DelRow(char* key)
+{
+	StorageTableElem *tbl = new StorageTableElem();
+	int i;
+	if(file!=NULL)
+	{
+		fseek(file,seekpos,0);
+		for(i=0;i<size;i++)
+		{
+			fread(tbl,(key_size+val_size),1,file);
+			if(!strcmp(tbl->key,key))
+			{
+				tbl->key[0]=0;
+				fseek(file,seekpos+i*(key_size+val_size),0);
+				fwrite(tbl,(key_size+val_size),1,file);
+				return 0;
+			}
+		}
+	}
+	return 1;
+}
+
+char* StorageTable::FindKeyValue(char* key, char* val)
+{
+	StorageTableElem *tbl = new StorageTableElem();
+	int i;
+	if(file!=NULL)
+	{
+		fseek(file,seekpos,0);
+		for(i=0;i<size;i++)
+		{
+			fread(tbl,(key_size+val_size),1,file);
+			if(!strcmp(tbl->key,key))
+			{
+				strcpy(val,tbl->value);
+				return val;
+			}
+		}
+	}
+	return 0;
+}
+
+CycleJournal::CycleJournal()
+{
+	CycleJournalElem *jrn = new CycleJournalElem();
+	file = fopen("jrn", "r+");
+	size=100;
+	seekpos=0;
+	int l=-1,r=size,mid;
+	iter=0;
+	if(file==NULL)
+	{
+		file = fopen("jrn","w");
+		CycleJournalElem *t = new CycleJournalElem();
+		for(int i=0;i<100;i++) fwrite(t,sizeof(*t),1,file);
+		fclose(file);
+		file = fopen("jrn","r+");
+		head=-1;
+		tail=-1;
+	}
+	else
+	{
+		fseek(file,seekpos,0);
+		fread(jrn,sizeof(*jrn),1,file);
+		if(jrn->status==0)
+		{
+			head=-1;
+			tail=-1;
+		}
+		else if((jrn->status==1)||(jrn->status==6))
+		{
+			head=0;
+			while(r - l > 1)
+			{
+				mid = (l+r)/2;
+				fseek(file,seekpos+mid*sizeof(*jrn),0);
+				fread(jrn,sizeof(*jrn),1,file);
+				iter++;
+				if(jrn->status==0)
+					r = mid;
+				else l=mid;
+			}
+			if(r<size)
+			{
+				fseek(file,seekpos+r*sizeof(*jrn),0);
+				fread(jrn,sizeof(*jrn),1,file);
+				tail=r-1;
+			}
+			else tail=size-1;
+		}
+		else if((jrn->status==2)||(jrn->status==3))
+		{
+			while((jrn->status!=1)&&(jrn->status!=6)&&(r - l > 1))
+			{
+				mid = (l+r)/2;
+				fseek(file,seekpos+mid*sizeof(*jrn),0);
+				fread(jrn,sizeof(*jrn),1,file);
+				iter++;
+				if((jrn->status==2)||(jrn->status==3))
+					l = mid;
+				else if((jrn->status==4)||(jrn->status==5))
+					r = mid;
+				else 
+				{
+					r=mid;
+					break;
+				}
+			}
+			if(r<size)
+				head=r;
+			else head=size-1;
+			tail=head-1;
+			if(tail<0) tail=size-1;
+		}
+		else
+		{
+			while((jrn->status!=1)&&(jrn->status!=6)&&(r - l > 1))
+			{
+				mid = (l+r)/2;
+				fseek(file,seekpos+mid*sizeof(*jrn),0);
+				fread(jrn,sizeof(*jrn),1,file);
+				iter++;
+				if((jrn->status==2)||(jrn->status==3))
+					r = mid;
+				else if((jrn->status==4)||(jrn->status==5))
+					l = mid;
+				else 
+				{
+					r=mid;
+					break;
+				}
+			}
+			if(r<size)
+				head=r;
+			else head=size-1;
+			tail=head-1;
+			if(tail<0) tail=size-1;
+		}
+	}
+}
+
+CycleJournal::CycleJournal(const char* name, int sz, int seek)
+{
+	CycleJournalElem *jrn = new CycleJournalElem();
+	file = fopen(name, "r+");
+	size=sz/sizeof(CycleJournalElem);
+	int l=-1,r=size,mid;
+	iter=0;
+	if(file==NULL)
+	{
+		file = fopen(name,"w");
+		CycleJournalElem *t = new CycleJournalElem();
+		for(int i=0;i<size;i++) fwrite(t,sizeof(*t),1,file);
+		fclose(file);
+		file = fopen(name,"r+");
+		seekpos=0;
+		head=-1;
+		tail=-1;
+	}
+	else 
+	{
+		seekpos=seek;
+		fseek(file,seekpos,0);
+		fread(jrn,sizeof(*jrn),1,file);
+		if(jrn->status==0)
+		{
+			head=-1;
+			tail=-1;
+		}
+		else if((jrn->status==1)||(jrn->status==6))
+		{
+			head=0;
+			while(r - l > 1)
+			{
+				mid = (l+r)/2;
+				fseek(file,seekpos+mid*sizeof(*jrn),0);
+				fread(jrn,sizeof(*jrn),1,file);
+				iter++;
+				if(jrn->status==0)
+					r = mid;
+				else l=mid;
+			}
+			if(r<size)
+			{
+				fseek(file,seekpos+r*sizeof(*jrn),0);
+				fread(jrn,sizeof(*jrn),1,file);
+				tail=r-1;
+			}
+			else tail=size-1;
+		}
+		else if((jrn->status==2)||(jrn->status==3))
+		{
+			while((jrn->status!=1)&&(jrn->status!=6)&&(r - l > 1))
+			{
+				mid = (l+r)/2;
+				fseek(file,seekpos+mid*sizeof(*jrn),0);
+				fread(jrn,sizeof(*jrn),1,file);
+				iter++;
+				if((jrn->status==2)||(jrn->status==3))
+					l = mid;
+				else if((jrn->status==4)||(jrn->status==5))
+					r = mid;
+				else 
+				{
+					r=mid;
+					break;
+				}
+			}
+			if(r<size)
+				head=r;
+			else head=size-1;
+			tail=head-1;
+			if(tail<0) tail=size-1;
+		}
+		else
+		{
+			while((jrn->status!=1)&&(jrn->status!=6)&&(r - l > 1))
+			{
+				mid = (l+r)/2;
+				fseek(file,seekpos+mid*sizeof(*jrn),0);
+				fread(jrn,sizeof(*jrn),1,file);
+				iter++;
+				if((jrn->status==2)||(jrn->status==3))
+					r = mid;
+				else if((jrn->status==4)||(jrn->status==5))
+					l = mid;
+				else 
+				{
+					r=mid;
+					break;
+				}
+			}
+			if(r<size)
+				head=r;
+			else head=size-1;
+			tail=head-1;
+			if(tail<0) tail=size-1;
+		}
+	}
+}
+
+CycleJournal::~CycleJournal()
+{
+	fclose(file);
+}
+
+int CycleJournal::AddRow(char* str)
+{
+	CycleJournalElem *jrn = new CycleJournalElem();
+	int i;
+	if(file!=NULL)
+	{
+		if(head==-1)
+		{
+			fseek(file,seekpos,0);
+			strcpy(jrn->str,str);
+			jrn->status=1;
+			fwrite(jrn,sizeof(*jrn),1,file);
+			head=0;
+			tail=0;
+			return 0;
+		}
+		if(head==tail)
+		{
+			fseek(file,seekpos+sizeof(*jrn),0);
+			strcpy(jrn->str,str);
+			jrn->status=2;
+			fwrite(jrn,sizeof(*jrn),1,file);
+			tail=1;
+			return 0;
+		}
+		fseek(file,seekpos+tail*sizeof(*jrn),0);
+		fread(jrn,sizeof(*jrn),1,file);
+		if((jrn->status==2)||(jrn->status==3))
+			i=2;
+		else i=4;
+		if(tail==size-1)
+		{
+			fseek(file,seekpos,0);
+			tail=0;
+			if(i==2) i=4;
+			else i=2;
+		}
+		else tail++;
+		fread(jrn,sizeof(*jrn),1,file);
+		if(jrn->status==0)
+		{
+			fseek(file,seekpos+tail*sizeof(*jrn),0);
+			strcpy(jrn->str,str);
+			jrn->status=2;
+			fwrite(jrn,sizeof(*jrn),1,file);
+			return 0;
+		}
+		else
+		{
+			head++;
+			if(head>=size) head=0;
+			fseek(file,seekpos+tail*sizeof(*jrn),0);
+			strcpy(jrn->str,str);
+			jrn->status=i;
+			if(tail==0) fseek(file,seekpos,0);
+			fwrite(jrn,sizeof(*jrn),1,file);
+			fseek(file,seekpos+head*sizeof(*jrn),0);
+			fread(jrn,sizeof(*jrn),1,file);
+			if((jrn->status==3)||(jrn->status==5)) jrn->status=6;
+			else jrn->status=1;
+			fseek(file,seekpos+head*sizeof(*jrn),0);
+			fwrite(jrn,sizeof(*jrn),1,file);
+			return 0;
+		}
+	}
+	return 1;
+}
+
+int CycleJournal::DelRow(int row)
+{
+	CycleJournalElem *jrn = new CycleJournalElem(); 
+	int i=(head+row)%size,j;
+	if( row >= size ) return 1;
+	if(file!=NULL)
+	{
+		fseek(file,seekpos+i*sizeof(*jrn),0);
+		fread(jrn,sizeof(*jrn),1,file);
+		if(jrn->status==1)
+		{
+			jrn->status=6;
+			fseek(file,seekpos+i*sizeof(*jrn),0);
+			fwrite(jrn,sizeof(*jrn),1,file);
+			return 0;
+		}
+		if(jrn->status==2) j=3;
+		else if(jrn->status==4) j=5;
+		else return 1;
+		fseek(file,seekpos+i*sizeof(*jrn),0);
+		jrn->status=j;
+		fwrite(jrn,sizeof(*jrn),1,file);
+	}
+	return 1;
+}
+
+int CycleJournal::DelAllRows()
+{
+	CycleJournalElem *jrn = new CycleJournalElem(); 
+	int i;
+	if(file!=NULL)
+	{
+		fseek(file,seekpos,0);
+		if((tail>head)&&(tail!=size-1))
+		{
+			i=1;
+			while(i!=0)
+			{
+				fread(jrn,sizeof(*jrn),1,file);
+				jrn->status=0;
+				fseek(file,seekpos+i*sizeof(*jrn),0);
+				fwrite(jrn,sizeof(*jrn),1,file);
+				i=jrn->status;
+			}
+		}
+		for(i=0;i<size;i++)
+		{
+			fread(jrn,sizeof(*jrn),1,file);
+			if(jrn->status!=0)
+			{
+				jrn->status=0;
+				fseek(file,seekpos+i*sizeof(*jrn),0);
+				fwrite(jrn,sizeof(*jrn),1,file);
+			}
+		}
+	}
+	return 1;
+}
+
+int CycleJournal::ViewRows(int beg, int num)
+{
+	CycleJournalElem *jrn = new CycleJournalElem(); 
+	int i,j=(head+beg)%size,n=num;
+	if(num==0) n=size;
+	if(num>size) n=size;
+	if(file!=NULL)
+	{
+		fseek(file,seekpos+j*sizeof(*jrn),0);
+		for(i=0;i<n;i++)
+		{
+			if(j==size)
+			{
+				j=0;
+				fseek(file,seekpos,0);
+			}
+			fread(jrn,sizeof(*jrn),1,file);
+			if((jrn->status!=0)&&(jrn->status!=3)&&(jrn->status!=5)&&(jrn->status!=6))
+			{
+				printf("%s\n",jrn->str);
+			}
+			j++;
+		}
+		return 0;
+	}
+	return 1;
+}
+