job queue

client.c

@@ -59,6 +59,7 @@ void sendXML(int sockfd,char *msg){
 	}
 	
 	toXML(encodedXML,key,value,msgtype,"");
+	
 	write(sockfd,strcat(encodedXML,delim),strlen(encodedXML));
 	char buf[256];
 	read(sockfd,buf,256);
@@ -114,8 +115,10 @@ int main(int argc, char *argv[])
 		sendXML(sockfd,line);
 	}
 	
-	while(1);
 	fclose(fp);
+	
+	while(1);
+	
 	//exit(0);
 
     return 0;

client.c~

@@ -59,6 +59,7 @@ void sendXML(int sockfd,char *msg){
 	}
 	
 	toXML(encodedXML,key,value,msgtype,"");
+	
 	write(sockfd,strcat(encodedXML,delim),strlen(encodedXML));
 	char buf[256];
 	read(sockfd,buf,256);
@@ -114,8 +115,10 @@ int main(int argc, char *argv[])
 		sendXML(sockfd,line);
 	}
 	
-	while(1);
 	fclose(fp);
+	
+	while(1);
+	
 	//exit(0);
 
     return 0;

server.c

@@ -12,7 +12,16 @@
 #include<unistd.h>
 #include<strings.h>
 #include<string.h>
-void dostuff(int); /* function prototype */
+#include<pthread.h>	
+#include "toxml.h"
+#include "jobs.h"
+
+jobs_queue *job_head=NULL;
+jobs_queue *job_tail=NULL;
+
+pthread_mutex_t job_q_lock;
+
+void *serve(void*); /* function prototype */
 void error(char *msg)
 {
     perror(msg);
@@ -23,7 +32,7 @@ int main(int argc, char *argv[])
 {
      int sockfd, newsockfd, portno, clilen, pid;
      struct sockaddr_in serv_addr, cli_addr;
-
+	 pthread_mutex_init(&job_q_lock,NULL);
      sockfd = socket(AF_INET, SOCK_STREAM, 0);
      if (sockfd < 0) 
         error("ERROR opening socket");
@@ -39,37 +48,81 @@ int main(int argc, char *argv[])
      while (1) {
          newsockfd = accept(sockfd, 
                (struct sockaddr *) &cli_addr, &clilen);
-         if (newsockfd < 0) 
+         /*if (newsockfd < 0) 
              error("ERROR on accept");
          pid = fork();
          if (pid < 0)
              error("ERROR on fork");
          if (pid == 0)  {
              close(sockfd);
-             dostuff(newsockfd);
+             serve(newsockfd);
              exit(0);
          }
-         else close(newsockfd);
+         else close(newsockfd);*/
+         pthread_t thr;
+         int *arg;
+         arg=malloc(sizeof(*arg));
+         *arg=newsockfd;
+         pthread_create(&thr,NULL,serve,arg);
      } /* end of while */
      return 0; /* we never get here */
 }
 
-/******** DOSTUFF() *********************
+/******** serve() *********************
  There is a separate instance of this function 
  for each connection.  It handles all communication
  once a connnection has been established.
  *****************************************/
-void dostuff (int sock)
+void *	serve (void* socket)
 {
+
+   int sock;
    int n;
-   char buffer[256];
-      
+   long tid=pthread_self();
+   sock=*((int*) socket);
+   char buffer[300000];
+     
    while(1){
-   bzero(buffer,256);
-   n = read(sock,buffer,255);
+   //zeroing all the value in buffer
+   bzero(buffer,300000);
+   
+   //reading the socket
+   n = read(sock,buffer,300000);
    if (n < 0) error("ERROR reading from socket");
-   printf("Here is the message:\n %s\n",buffer);
-   n = write(sock,"I got your message\n",19);
+   else if (n==0) {
+   	printf("Client has been closed,Killing the thread\n");
+   	pthread_cancel(tid);
+   }
+   else{
+   //Creating a structure to add in linked list of job queue
+   jobs_queue *job=(jobs_queue *)malloc((sizeof(jobs_queue)));
+   job->fd=sock;
+   job->next=NULL;
+   strcpy(job->xml,buffer);
+   
+   //Adding to the chain in Job Queue
+   pthread_mutex_lock(&job_q_lock);
+   if(job_head==NULL){
+   		job_head=job;
+   		job_tail=job;
+   }
+   else{
+   		job_tail->next=job;
+   		job_tail=job;
+   }
+   pthread_mutex_unlock(&job_q_lock);
+   //Printing the linked list
+   jobs_queue *p=job_head;
+   while(p!=NULL){
+   	printf("%d ",p->fd);
+   	p=p->next;
+   }
+   printf("\n");
+   
+   
+   //Acknowledging the client to send next data
+   n = write(sock,"ACK\n",4);
    if (n < 0) error("ERROR writing to socket");
    }
+   }
 }

server.c~

@@ -12,7 +12,16 @@
 #include<unistd.h>
 #include<strings.h>
 #include<string.h>
-void dostuff(int); /* function prototype */
+#include<pthread.h>	
+#include "toxml.h"
+#include "jobs.h"
+
+jobs_queue *job_head=NULL;
+jobs_queue *job_tail=NULL;
+
+pthread_mutex_t job_q_lock;
+
+void *serve(void*); /* function prototype */
 void error(char *msg)
 {
     perror(msg);
@@ -23,7 +32,7 @@ int main(int argc, char *argv[])
 {
      int sockfd, newsockfd, portno, clilen, pid;
      struct sockaddr_in serv_addr, cli_addr;
-
+	 pthread_mutex_init(&job_q_lock,NULL);
      sockfd = socket(AF_INET, SOCK_STREAM, 0);
      if (sockfd < 0) 
         error("ERROR opening socket");
@@ -39,37 +48,81 @@ int main(int argc, char *argv[])
      while (1) {
          newsockfd = accept(sockfd, 
                (struct sockaddr *) &cli_addr, &clilen);
-         if (newsockfd < 0) 
+         /*if (newsockfd < 0) 
              error("ERROR on accept");
          pid = fork();
          if (pid < 0)
              error("ERROR on fork");
          if (pid == 0)  {
              close(sockfd);
-             dostuff(newsockfd);
+             serve(newsockfd);
              exit(0);
          }
-         else close(newsockfd);
+         else close(newsockfd);*/
+         pthread_t thr;
+         int *arg;
+         arg=malloc(sizeof(*arg));
+         *arg=newsockfd;
+         pthread_create(&thr,NULL,serve,arg);
      } /* end of while */
      return 0; /* we never get here */
 }
 
-/******** DOSTUFF() *********************
+/******** serve() *********************
  There is a separate instance of this function 
  for each connection.  It handles all communication
  once a connnection has been established.
  *****************************************/
-void dostuff (int sock)
+void *	serve (void* socket)
 {
+
+   int sock;
    int n;
-   char buffer[256];
-      
+   long tid=pthread_self();
+   sock=*((int*) socket);
+   char buffer[300000];
+     
    while(1){
-   bzero(buffer,256);
-   n = read(sock,buffer,255);
+   //zeroing all the value in buffer
+   bzero(buffer,300000);
+   
+   //reading the socket
+   n = read(sock,buffer,300000);
    if (n < 0) error("ERROR reading from socket");
-   printf("Here is the message:\n %s\n",buffer);
-   n = write(sock,"I got your message\n",19);
+   else if (n==0) {
+   	printf("Client has been closed,Killing the thread\n");
+   	pthread_cancel(tid);
+   }
+   else{
+   //Creating a structure to add in linked list of job queue
+   jobs_queue *job=(jobs_queue *)malloc((sizeof(jobs_queue)));
+   job->fd=sock;
+   job->next=NULL;
+   strcpy(job->xml,buffer);
+   
+   //Adding to the chain in Job Queue
+   pthread_mutex_lock(&job_q_lock);
+   if(job_head==NULL){
+   		job_head=job;
+   		job_tail=job;
+   }
+   else{
+   		job_tail->next=job;
+   		job_tail=job;
+   }
+   pthread_mutex_unlock(&job_q_lock);
+   //Printing the linked list
+   /*jobs_queue *p=job_head;
+   while(p!=NULL){
+   	printf("%d ",p->fd);
+   	p=p->next;
+   }
+   printf("\n");
+   */
+   
+   //Acknowledging the client to send next data
+   n = write(sock,"ACK\n",4);
    if (n < 0) error("ERROR writing to socket");
    }
+   }
 }