#include <stdio.h>
#include <windows.h>
#define MAX_THREADS 2
typedef struct DatosServidor { SOCKET conn_socket;
} DATOS_SERVIDOR;
DWORD WINAPI MyThreadFunction( LPVOID lpParam );
void ErrorHandler(char *NameFunction);
int main(int argc, char *argv[]){
//Necesarias para crear los hilos
DWORD dwThreadIdArray[MAX_THREADS];
HANDLE hThreadArray[MAX_THREADS];
int i;
//Necesarias para crear el servidor
DATOS_SERVIDOR datos;
WSADATA wsaData;
struct sockaddr_in server;
struct hostent *hp;
int resp;
//Inicializamos la DLL de sockets
resp=WSAStartup(MAKEWORD(1,0),&wsaData);
if(resp){ printf("Error al inicializar socket\n"); getchar();
return resp;
}
//Obtenemos la IP que usará nuestro servidor...
// en este caso localhost indica nuestra propia máquina...
hp=(struct hostent *)gethostbyname("localhost");
if(!hp){ printf("No se ha encontrado servidor...\n"); getchar();
WSACleanup();
return WSAGetLastError();
}
// Creamos el socket...
datos.conn_socket=socket(AF_INET,SOCK_STREAM, 0);
if(datos.conn_socket==INVALID_SOCKET) { printf("Error al crear socket\n"); getchar();
WSACleanup();
return WSAGetLastError();
}
memset(&server, 0, sizeof(server)) ;
memcpy(&server.sin_addr, hp->h_addr, hp->h_length);
server.sin_family = hp->h_addrtype;
server.sin_port = htons(6000);
// Asociamos ip y puerto al socket
resp=bind(datos.conn_socket, (struct sockaddr *)&server, sizeof(server));
if(resp==SOCKET_ERROR){ printf("Error al asociar puerto e ip al socket\n"); closesocket(datos.conn_socket);
WSACleanup();
getchar();
return WSAGetLastError();
}
if(listen(datos.conn_socket, 1)==SOCKET_ERROR){ printf("Error al habilitar conexiones entrantes\n"); closesocket(datos.conn_socket);
WSACleanup();
getchar();
return WSAGetLastError();
}
printf("Esperando conexiones entrantes... \n");
for(i=0; i<MAX_THREADS; i++ )
{ // Creo el hilo para iniciar la ejecución en su función
hThreadArray[i] = CreateThread(
NULL, // default security attributes
0, // use default stack size
MyThreadFunction, // thread function name
&datos, // argument to thread function
0, // use default creation flags
&dwThreadIdArray[i]); // returns the thread identifier
// Compruebo el valor de retorno
// Si CreateThread falla, termino la ejecución
// Esto limpiará automáticamente los hilos y la memoria
if (hThreadArray[i] == NULL)
{ ErrorHandler("CreateThread"); getchar();
return 3;
}
} // Fin del bucle de creacion de hilos
// Espero a que terminen todos los hilos
WaitForMultipleObjects(MAX_THREADS, hThreadArray, TRUE, INFINITE);
// Como no vamos a aceptar más conexiones cerramos el socket escucha
closesocket(datos.conn_socket);
// Cerramos liberia winsock
WSACleanup();
// Cierro todos los handles de los hilos
for(i=0; i<MAX_THREADS; i++)
{ CloseHandle(hThreadArray[i]);
}
printf("Fin de recepcion de mensajes"); getchar();
return (EXIT_SUCCESS);
}
DWORD WINAPI MyThreadFunction( LPVOID lpParam )
{ char RecvBuff[100];
SOCKET comm_socket;
DATOS_SERVIDOR *datos;
struct sockaddr_in client;
int stsize;
datos=(DATOS_SERVIDOR*)lpParam;
// Aceptamos conexiones entrantes
stsize=sizeof(struct sockaddr);
comm_socket=accept(datos->conn_socket,(struct sockaddr *)&client,&stsize);
if(comm_socket==INVALID_SOCKET){ printf("Error al aceptar conexión entrante\n"); getchar();
return WSAGetLastError();
}
printf("Conexion entrante desde: %s\n", inet_ntoa(client.sin_addr));
printf("Recibiendo Mensajes... \n"); recv (comm_socket, RecvBuff, sizeof(RecvBuff), 0);
printf("Datos recibidos: %s \n", RecvBuff);
// Cerramos el socket de la comunicacion
closesocket(comm_socket);
return 0;
}
void ErrorHandler(char *NameFunction)
{ LPVOID lpMsgBuf;
DWORD dw = GetLastError();
// Recupero el mensaje de error del sistema para el último error ocurrido
FormatMessage(
FORMAT_MESSAGE_ALLOCATE_BUFFER |
FORMAT_MESSAGE_FROM_SYSTEM |
FORMAT_MESSAGE_IGNORE_INSERTS,
NULL,
dw,
MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
(LPTSTR) &lpMsgBuf,
0, NULL );
// Muestro el mensaje de error
printf("Error: %s failed with error %d: %s",NameFunction, dw, lpMsgBuf);
// Libero la memoria allocada
LocalFree(lpMsgBuf);
}
