Merge branch 'temp-branch'

KVServer.c

@@ -91,10 +91,10 @@ void *worker(void *args) {
 
                 if (flag & EPOLLIN) {
                     /* Parse the actual message from client */
-                    struct message *requestMessage= malloc(sizeof(struct message));
-                    int readlength=read(events[i].data.fd  , requestMessage, sizeof(struct message));              
+                    struct message *requestMessage= malloc(sizeof(struct message));    
                     memset(requestMessage->key, 0, 256);           
                     memset(requestMessage->value, 0, 256);
+                    int readlength=read(events[i].data.fd  , requestMessage, sizeof(struct message));          
                     if DEBUG printf("[%s][EVENT][EPOLLIN] \n", name);
                     switch(requestMessage->status) {
                         case STATUS_GET:
@@ -104,8 +104,8 @@ void *worker(void *args) {
                                 requestMessage->status = 200;
                             } else {
                                 status = file_get(requestMessage->key, requestMessage->value);
-                                cache_put(requestMessage->key, requestMessage->value);
                                 if(status) {
+                                    cache_put(requestMessage->key, requestMessage->value);
                                     requestMessage->status = 200;
                                 } else {
                                     requestMessage->status = 240;

StorageHandler.c

@@ -24,9 +24,11 @@ int readercount = 0;
 unsigned modulus( unsigned char *num, size_t size, unsigned divisor) {
   unsigned rem = 0;
   
- while(size>0)
+  int i=0;
+ while(i<divisor)
  {
-     rem+=num[size--]%divisor;
+     rem+=num[i]%divisor;
+     i++;
  }
   return rem%divisor;
 }
@@ -59,13 +61,17 @@ void file_del( char *key)
 {   
     int offset;
     int index=modulus(key,256,setSize);
+    char fkey[256];
+    char fval[256];
     sem_wait(&mutex[index]);
 
     offset = file_search(key, NULL, index);
     if(offset >= 0) {
         lseek(fds[index], offset, SEEK_SET);
-        write(fds[index], 0, 256);
-        write(fds[index], 0, 256);
+        memset(fkey, 0, 256);
+        memset(fval, 0, 256);
+        write(fds[index], fkey, 256);
+        write(fds[index], fval, 256);
     }
     
     sem_post(&mutex[index]);