Commit 5f4708dd authored by Samarth Joshi's avatar Samarth Joshi

Bugfix Makefile

parent 5b79a48a
test:tessdfs 1:test
2:asdsad 2:test
3:ssadasd 3:test
4:ssdasd 4:test
5:asdasd 5:test
6:asdasdasd 6:test
7:asdasdas 7:test
8:asdasdasd 8:test
9:asdasd 9:test
10:asdasd 10:tet
11:sdsadas 11:test
12:sdasd
13:sadasd
asdasd:sadasd
3:sadasd
4:asdas
5:asda
6:sadas
7:sadasd
8:asdasd
9:sadsd
10:asdsa
11:sadds
12:dssad
...@@ -103,6 +103,7 @@ void *worker(void *args) { ...@@ -103,6 +103,7 @@ void *worker(void *args) {
requestMessage->status = 200; requestMessage->status = 200;
} else { } else {
status = file_get(requestMessage->key, requestMessage->value); status = file_get(requestMessage->key, requestMessage->value);
cache_put(requestMessage->key, requestMessage->value);
if(status) { if(status) {
requestMessage->status = 200; requestMessage->status = 200;
} else { } else {
......
No preview for this file type
...@@ -37,6 +37,9 @@ void file_del( char *key) ...@@ -37,6 +37,9 @@ void file_del( char *key)
int length=0; int length=0;
sem_wait(&mutex[index]); sem_wait(&mutex[index]);
char blankspace[512]; char blankspace[512];
char ch;
int k=-1;
lseek(fds[index], 0, SEEK_SET);
memset(blankspace,0,512); memset(blankspace,0,512);
char *line; char *line;
char temp[514]; char temp[514];
...@@ -52,12 +55,13 @@ void file_del( char *key) ...@@ -52,12 +55,13 @@ void file_del( char *key)
if(strcmp(key,fkey)==0){ if(strcmp(key,fkey)==0){
lseek(fds[index],position,SEEK_SET); lseek(fds[index],position,SEEK_SET);
write(fds[index],blankspace,strlen(temp)); write(fds[index],blankspace,strlen(temp));
puts(temp);
break; break;
} }
position=ftell(fp); position=ftell(fp);
} }
printf("length %d",length);
sem_post(&mutex[index]); sem_post(&mutex[index]);
} }
...@@ -66,7 +70,9 @@ int file_get(char *key, char *value) ...@@ -66,7 +70,9 @@ int file_get(char *key, char *value)
/* Gets the value stored at offset */ /* Gets the value stored at offset */
/* Does not depend on key argument */ /* Does not depend on key argument */
int found =0; int found =0;
int index=modulus(key,256,setSize); int index=modulus(key,256,setSize);
lseek(fds[index],0,SEEK_SET);
sem_wait(&readerLocks[index]); sem_wait(&readerLocks[index]);
readCounters[index]+=1; readCounters[index]+=1;
if(readCounters[index]==1) if(readCounters[index]==1)
...@@ -103,6 +109,7 @@ off_t file_put(char *key,char *value) ...@@ -103,6 +109,7 @@ off_t file_put(char *key,char *value)
if not present then search for empty line and insert there! if not present then search for empty line and insert there!
*/ */
unsigned int index=modulus(key,256,setSize); unsigned int index=modulus(key,256,setSize);
lseek(fds[index],0,SEEK_SET);
off_t position; off_t position;
//sem_wait(&mutex[index]); //sem_wait(&mutex[index]);
printf("[Write to File: %d]\n",index); printf("[Write to File: %d]\n",index);
...@@ -128,7 +135,7 @@ off_t file_put(char *key,char *value) ...@@ -128,7 +135,7 @@ off_t file_put(char *key,char *value)
printf("value:(%s)(%s)\n",fvalue,value); printf("value:(%s)(%s)\n",fvalue,value);
fflush(stdout); fflush(stdout);
fseek(fp,position,SEEK_SET); fseek(fp,position,SEEK_SET);
snprintf(lin, sizeof(lin),"%s:%s\n",key,value); snprintf(lin, strlen(key)+strlen(value)+2,"%s:%s\n",key,value);
if(fputs(lin,fp)<0) if(fputs(lin,fp)<0)
printf("\n[unable to perform file_put]\n"); printf("\n[unable to perform file_put]\n");
return 0; return 0;
...@@ -172,5 +179,5 @@ int storage_init() ...@@ -172,5 +179,5 @@ int storage_init()
sem_init(&mutex[i],0,1); sem_init(&mutex[i],0,1);
readCounters[i]=0; readCounters[i]=0;
} }
return 0;
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment