serverTCP.c: (C version. It works fine)
------------
Code:
#include <stdio.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#define MAX_DATA_LENGTH 65000
struct ThreadArgs
{
int sClient;
};
void *ThreadMain(void *arg); /* Main program of a thread */
int main()
{
int ret;
unsigned int iPort, iAddrLen;
int sListen, sClient;
struct sockaddr_in addr, remote_addr;
pthread_t threadID;
struct ThreadArgs *threadArgs;
iPort = 5772;
sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
if (sListen < 0)
{
printf("Error: Call to socket(AF_INET, SOCK_STREAM, IPPROTO_IP); has failed.\n");
exit(1);
}
addr.sin_family = AF_INET;
addr.sin_port = htons(iPort);
addr.sin_addr.s_addr = htonl(INADDR_ANY);
ret = bind(sListen, (struct sockaddr *) &addr, sizeof(addr));
if(ret < 0)
{
printf("Error: Call to bind(sListen, (struct sockaddr *) &addr, sizeof(addr)); has failed.\n");
exit(1);
}
ret = listen(sListen, 10);
if(ret < 0)
{
printf("Error: Call to listen(sListen, 10); has failed.\n");
exit(1);
}
for(;;)
{
printf("Waiting for connection from a client...\n");
iAddrLen = sizeof(remote_addr);
sClient = accept(sListen, (struct sockaddr *) &remote_addr, &iAddrLen);
if(sClient < 0)
{
printf("Error: Call to accept(sListen, (struct sockaddr *) remote_addr, sizeof(remote_addr)); has failed.\n");
exit(1);
}
printf("%s has connected.\n\n", inet_ntoa(remote_addr.sin_addr));
if ((threadArgs = (struct ThreadArgs *) malloc(sizeof(struct ThreadArgs))) == NULL)
{
printf("Error: malloc() for threadArgs has failed.\n");
exit(1);
}
threadArgs -> sClient = sClient;
if (pthread_create(&threadID, NULL, ThreadMain, (void *)threadArgs) != 0)
{
printf("Error: pthread_create() has failed.\n");
exit(1);
}
}
}
void *ThreadMain(void *threadArgs)
{
int sClient;
int ret;
char data_in[MAX_DATA_LENGTH];
pthread_detach(pthread_self() ) ;
sClient = ((struct ThreadArgs *) threadArgs) -> sClient;
free(threadArgs);
ret = 1;
while (ret != 0)
{
printf("Waiting to receive client data.\n");
ret = recv(sClient, data_in, MAX_DATA_LENGTH, 0);
if (ret < 0)
{
printf("Error: Call to recv(sClient, frame_in, sizeof(frame_in), 0); has failed.\n");
exit(1);
}
printf("Received data from client %d\n\n", sClient);
}
close(sClient);
return NULL;
}