Probelm in order to handle data from multiple client in a mutithreaded program

HI,

This is how my server program looks like. Same in the client side i have created 2 threads one is responsible for reading the data where as the other for writing of the data.


#include
#include
#include
#include

#pragma comment(lib, "Ws2_32.lib")

#define MYPORT 3490
#define BACKLOG 10

void clientthread(SOCKET *);

SOCKET sockfd, new_fd;
WSADATA wsaData;

SOCKET arr[BACKLOG];
HANDLE hSem=NULL;

int main(void)
{
struct sockaddr_in my_addr;
struct sockaddr_in their_addr;
int sin_size, thread[10], yes=1, x = BACKLOG;
int thread_hndl_count = 0, thread_hndl_count_wait;

if (WSAStartup(MAKEWORD(1, 1), &wsaData) != 0)
{
fprintf(stderr, "WSAStartup failed.\n");
exit(1);
}

if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
printf("Error in socket creation\n");
exit(1);
}

if (setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,(const char*)&yes,sizeof(yes)) == -1)
{
printf("Error in socket setting up socket\n");
exit(1);
}

my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(MYPORT);
my_addr.sin_addr.s_addr = INADDR_ANY;
memset(&(my_addr.sin_zero), '\0', 8);

if (bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr)) == -1)
{
printf("Error in socket binding\n");
exit(1);
}

if (listen(sockfd, BACKLOG) == -1)
{
printf("Error in socket listen\n");
exit(1);
}

sin_size = sizeof(struct sockaddr_in);
while(x > 0)
{
if ((new_fd = accept(sockfd, (struct sockaddr *)&their_addr,&sin_size)) == -1)
{
printf("Error in socket accept");
}
else
{
printf("Server got connection from %s\n",inet_ntoa(their_addr.sin_addr));
arr[thread_hndl_count] = new_fd;
thread_hndl_count++;
printf("Creating the child thread..%d\n",x);
thread[x] = _beginthread( clientthread, 0, &new_fd );
}
x--;
}
printf("Executing statement next to thread creationing\n");
/*
for(thread_hndl_count_wait = 0; thread_hndl_count >= 0; thread_hndl_count--)
{
printf("Executing For loop next to threading\n");
if(thread[thread_hndl_count] != 0)
{
WaitForSingleObject(thread[thread_hndl_count],INFINITE);
}
}*/
Sleep(INFINITE);
closesocket(sockfd);
return 0;
}

void clientthread(SOCKET *client_fd)
{
int maxm_bytes = 50, numbytes = 0, count;
char *Initial_msg= "Initial server confirmation to new client\n";
char *Rcv_buf= (char *) malloc (50);

if (send((SOCKET)*client_fd, Initial_msg, maxm_bytes , 0) == -1)
{
perror("Error in sending\n");
}
else
{
printf("Initial message successfully sent from server and now waiting to receive from the clients\n");
}

while(1)
{
numbytes = recv(*client_fd, Rcv_buf, maxm_bytes , 0);
if(( numbytes == -1 )|| ( numbytes == 0 ))
{
printf("Some one hung up the socket, %d\n", *client_fd);
for(count= 0; count< BACKLOG; count++)
{
if((arr[count] == *client_fd))
{
arr[count] = 0;
closesocket(*client_fd);
}
printf("Terminating child thread\n");
_endthread();
}
}
else
{
printf("Received data from socket %d is %s\n", *client_fd, Rcv_buf);
for(count= 0; count< BACKLOG; count++)
{
if((arr[count] != 0) && (arr[count] != *client_fd))
{
printf("Data to be sent is %d\n", arr[count]);
if (send(arr[count], Rcv_buf, maxm_bytes , 0) == -1)
{
perror("Error in sending\n");
}
}
}
}
}
}