temp Code

KVClient.c

@@ -47,7 +47,7 @@ struct message *request(char status,char* key,char* value)
     {
         requestMessage->value[strlen(requestMessage->value)]='\0';
     }
-    printf("[Message Generated at Client]\n[[Status:%c]\n[Key:%s]\n[Value:%s]]",requestMessage->status,requestMessage->key,requestMessage->value);
+    printf("\n[Message Generated at Client]\n[[Status:%c]\n[Key:%s]\n[Value:%s]]",requestMessage->status,requestMessage->key,requestMessage->value);
     return requestMessage;
 }
  struct message* requestMessage;
@@ -58,10 +58,10 @@ void func(int sockfd,struct message* requestMessage)
     for (;;) { 
         bzero(buff, sizeof(buff)); 
        
-        if(n==0)
+        if(1)
         {
             n++;
-            printf("[Message sent to server]\n[[Status:%c]\n[Key:%s]\n[Value:%s]]",requestMessage->status,requestMessage->key,requestMessage->value);
+            printf("[Message sent to server]\n[[Status:%c]\n[Key:%s]\n[Value:%s]]\n",requestMessage->status,requestMessage->key,requestMessage->value);
             write(sockfd, requestMessage, sizeof(struct message)); 
         }
           

KVServer.c

@@ -108,7 +108,7 @@ void *worker(void *args) {
                 read(read_pipe, newfd, sizeof(newfd));
                 printf("\nread %d\n", *newfd);
                 ev.data.fd=*newfd;
-                ev.events = EPOLLIN|EPOLLET;
+                ev.events = EPOLLIN;
                 if (epoll_ctl(epollfd, EPOLL_CTL_ADD, *newfd,  &ev) == -1) {
                     perror("epoll_ctl: read_pipe");
                     exit(EXIT_FAILURE);
@@ -122,14 +122,12 @@ void *worker(void *args) {
                 int readlength=read(events[i].data.fd  , requestMessage, sizeof(struct message)); 
                 if(requestMessage->status ==EOF)
                 {
-                   ev.data.fd=events[i].data.fd;
-                   ev.events = EPOLLIN|EPOLLET;
-                   epoll_ctl( epollfd, EPOLL_CTL_DEL, events[i].data.fd , &ev );
+                   epoll_ctl( epollfd, EPOLL_CTL_DEL, events[i].data.fd , NULL );
                    close(events[i].data.fd);
                 }
                 else
                 {
-                    printf("[Message Received from client]\n[[Status:%c][Key:%s][Value:%s]]",requestMessage->status,requestMessage->key,requestMessage->value);               
+                    printf("\n[Message Received from client]\n[[Status:%c][Key:%s][Value:%s]]",requestMessage->status,requestMessage->key,requestMessage->value);               
                     fflush(stdout);
                 }
                 
@@ -173,6 +171,8 @@ int main (int argc, int argv) {
     serv_addr.sin_family = AF_INET;
     serv_addr.sin_port = htons(portno);
     serv_addr.sin_addr.s_addr = INADDR_ANY;
+    int option =1;
+    setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option));
     if (bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0) {
         perror("ERROR on binding");
         exit(1);