Programming

#define _REENTRANT
----- HEADER FILES -----------
/* the TCP port that I will be listening for my clients*/
#define TCP_PORT   6500
void *process_clnt(void *);
main()
{
   int 	sockfd, newsockfd, clilen;
   struct sockaddr_in cli_addr, serv_addr;
   thread_t chld_thr;

   if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
	fprintf(stderr,"my_daemon: can't open stream socket\n"), exit(0);
   memset((char *) &serv_addr, 0, sizeof(serv_addr));
   serv_addr.sin_family = AF_INET;
   serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
   serv_addr.sin_port = htons(TCP_PORT);	
   if(bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
		fprintf(stderr,"server: can't bind local address\n"), exit(0);
   thr_setconcurrency(5);
   listen(sockfd, NULL);

   for(;;){
	clilen = sizeof(cli_addr);
	newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
	if(newsockfd < 0)
		fprintf(stderr,"server: accept error\n"), exit(0);
	/* create a new thread to process the incomming client request */
	thr_create(NULL, 0, process_clnt, (void *) newsockfd, THR_DETACHED, &chld_thr);
   }
   return(0);
}

void *process_clnt(void *arg)
{
   int 	mysocfd = (int) arg;
   char 	data[100];
   /* read from the given socket */
   read(mysocfd, data, data_size);
   /* DO SOME PROCESSING */

   /* This is the place I want to have a TCP connection to vendor server to get the result */
       ----------------------
       ----------------------
   write(mysockfd,result,result_size); /* send back result to my client */
   close(mysocfd);
   thr_exit((void *)0);
}