Duda sobre WM_COPYDATA y C

[aguml]

Ahora si entiendo mejor. En realidad tú código es más de lo que necesito creo yo. Realmente la idea es que un cliente se conecte al servidor y luego obtenga el tiempo inicial y cuando se vaya a salir del proceso calcule el lapso de tiempo transcurrido y lo envie al servidor, no necesita ni enviar más nada ni recibir por lo que el servidor tampoco necesita esperar más nada después de recibir el valor ya que sabe que después de eso el cliente se cerrará. No se si me entiendes, no habrá más comunicación con ese cliente y este se cerrará si o si.
Lo que no veo en tu código del server es como sales del bucle infinito que pusiste para los hilos ya que no veo ningún break. En mi caso tenia que especificar el número de hilos para que WaitForMultipleObjects supiese cuando terminar y tu no lo usas por lo que jamás se saldría a no ser que cierre el programa servidor. Nunca se ejecutaría lo que está después del bucle y no veo la manera de conseguirlo sin hacer lo que yo hice de indicar el número de hilos a WaitForMultipleObjects.

[aguml]

Ahora mismo lo tengo asi y sigo teniendo algunas dudas sobre todo en como colocar el bucle del cliente ya que hice algo que creo que no es del todo correcto pero no se seguro. Ademas he colocado un comentario en la zona donde se asignan los parametros para el server en el codigo del cliente que me gustaria que me pudieses solventar.
Aqui el codigo del servidor:

Código PHP:

#include <stdio.h>
#include <string.h>
#include <windows.h>

#define MAX_THREADS 2

DWORD WINAPI ThClient(SOCKET *Sock);
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
    WSADATA wsaData;
    struct sockaddr_in server,client;
    struct hostent *hp;
    int resp;
    SOCKET Sock_c;  //Socket del cliente
    SOCKET Sock_e;  //Socket de escucha del servidor
    DWORD Port=6000;
    int stsize;

    //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...
    Sock_e=socket(AF_INET,SOCK_STREAM, 0);
    if(Sock_e==INVALID_SOCKET) {
        printf("Error al crear socket\n");
        getchar();
        WSACleanup();
        return WSAGetLastError();
    }

    memset(&server, 0, sizeof(server)) ;
    server.sin_family = AF_INET;
    server.sin_addr.s_addr = INADDR_ANY;
    server.sin_port = htons(Port);

    // Asociamos ip y puerto al socket
    resp=bind(Sock_e, (struct sockaddr *)&server, sizeof(server));
    if(resp==SOCKET_ERROR){
        printf("Error al asociar puerto e ip al socket\n");
        closesocket(Sock_e);
        WSACleanup();
        getchar();
        return WSAGetLastError();
    }

    if(listen(Sock_e, 1)==SOCKET_ERROR){
        printf("Error al habilitar conexiones entrantes\n");
        closesocket(Sock_e);
        WSACleanup();
        getchar();
        return WSAGetLastError();
    }

    printf("Esperando conexiones entrantes... \n");

    for(i=0; i<MAX_THREADS; i++ )
    {
        // Aceptamos conexiones entrantes
        stsize=sizeof(struct sockaddr);
        Sock_c=accept(Sock_e,(struct sockaddr *)&client,&stsize);
        if(Sock_c==INVALID_SOCKET){
            printf("Error al aceptar conexión entrante\n");
            getchar();
            return WSAGetLastError();
        }
        //printf("Conexion entrante desde: %s\n", inet_ntoa(client.sin_addr));

        // Creo el hilo para iniciar la ejecución en su función
        hThreadArray[i] = CreateThread( 
            NULL,                              // default security attributes
            0,                                 // use default stack size
            (LPTHREAD_START_ROUTINE)ThClient,  // thread function name
            &Sock_c,                      // 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(Sock_e);

    // 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 ThClient(SOCKET *Sock)
{
    char RecvBuff[100];

    memset(RecvBuff,0,sizeof(RecvBuff));
    recv (*Sock, RecvBuff, sizeof(RecvBuff), 0);

    if(strlen(RecvBuff)==0)
        printf("El cliente se ha cerrado antes de enviar los datos\n");
    else
        printf("%s\n", RecvBuff);

    memset(RecvBuff,0,sizeof(RecvBuff));
    recv (*Sock, RecvBuff, sizeof(RecvBuff), 0);

    if(strlen(RecvBuff)==0)
        printf("El cliente se ha cerrado antes de enviar los datos\n");
    else
        printf("Datos recibidos: %s \n", RecvBuff);

    // Cerramos el socket de la comunicacion
    closesocket(*Sock);

    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);
} 


Aqui el codigo del cliente:

Código PHP:

#include <stdio.h>
#include <stdlib.h>
#include <windows.h>

int main(int argc, char *argv[]){

    WSADATA wsaData;
    SOCKET conn_socket;
    struct sockaddr_in server;
    struct hostent *host;
    DWORD Port = 6000;
    int resp,salida;
    unsigned long inicio,fin,lapso;
    char SendBuff[100];
    HWND windowHandle;
    DWORD processID;

    //Inicializamos la DLL de sockets
    resp=WSAStartup(MAKEWORD(1,0),&wsaData);
    if(resp){
        printf("Error al inicializar socket\n");
        getchar();
        return -1;
    }

    //Obtenemos la IP del servidor... en este caso
    // localhost indica nuestra propia máquina...
    host=(struct hostent *)gethostbyname("localhost");

    if(!host){
        printf("No se ha encontrado servidor...\n");
        getchar();
        WSACleanup();
        return WSAGetLastError();
    }

    // Creamos el socket...
    conn_socket=socket(AF_INET,SOCK_STREAM, 0);
    if(conn_socket==INVALID_SOCKET) {
        printf("Error al crear socket\n");
        getchar();
        WSACleanup();
        return WSAGetLastError();
    }

    memset(&server, 0, sizeof(server)) ;
    server.sin_family = AF_INET;
    server.sin_port   = htons(Port);
    //La siguiente linea, si no fuesen cliente y servidor en el mismo equipo
    //¿Tendria que darle la direccion ip del servidor?
    //Es que ahora mismo apunta a localhost del cliente ¿no?
    server.sin_addr   = *((struct in_addr *)host->h_addr);

    // Nos conectamos con el servidor...
    printf("Conectando con el servidor\n");
    while(connect(conn_socket,(struct sockaddr *)&server,sizeof(server))==SOCKET_ERROR)
        Sleep(10);

    processID = GetCurrentProcessId();
    printf("Conexion establecida con: %s con proceso con PID %lu\n", inet_ntoa(server.sin_addr),processID);
    sprintf(SendBuff,"Conexion establecida con: %s con proceso con PID: %lu.",inet_ntoa(*((struct in_addr *)host->h_addr)),processID);
    send(conn_socket,SendBuff,sizeof(SendBuff),0);

    //Obtengo el tiempo en el que inicia el proceso
    inicio=GetTickCount();

    //Esto lo pongo para tener una salida del proceso aleatoria
    //No es necesaria para nada pero al menos asi consigo simular
    //que el proceso hace algo mas a parte de comunicarse
    srand(time(NULL));
    do{
        salida = rand()%1000;
        Sleep(10);
    }while(salida != 0);

    //Obtengo el tiempo en que termina el proceso
    fin=GetTickCount();

    //Obtengo el lapso de tiempo transcurrido
    lapso=fin-inicio;

    //Enviamos el lapso de tiempo que transcurrio...
    printf("Enviando lapso de tiempo... \n");
    sprintf(SendBuff,"El proceso con PID: %lu ha funcionado durante %lu milisegundos.",processID,lapso);
    send(conn_socket,SendBuff,sizeof(SendBuff),0);
    printf("Lapso enviado: %lu milisegundos\n", lapso);

    // Cerramos el socket y liberamos la DLL de sockets
    closesocket(conn_socket);
    WSACleanup();
    getchar();
    return EXIT_SUCCESS;
} 


[[escafandra]]

Para que el cliente no termine si no conecta con el servidor y continúe intentando la conexión, debe contener un bucle y quedaría algo como esto:

Código PHP:

#include <windows.h>
#include <winsock2.h>
#include <stdio.h>
#include <stdlib.h>

int main(int argc, char *argv[]){
  WSADATA wsaData;
  SOCKET conn_socket;
  struct sockaddr_in server;
  struct hostent *host;
  char ServerAdr[] = "localhost";   // Nombre de la Máquina del Server
  DWORD Port = 6000;
  int resp, salida;
  unsigned long inicio,fin,lapso;
  char SendBuff[100];
  HWND windowHandle;
  DWORD processID;
  BOOL Salir = false;
  int Result = EXIT_SUCCESS;

  //Obtengo el tiempo en el que inicia el proceso
  inicio = GetTickCount();

  //Inicializamos la DLL de sockets
  resp = WSAStartup(MAKEWORD(1,0),&wsaData);
  if(resp){
    printf("Error al inicializar socket\n");
    getchar();
    return -1;
  }

  // Bucle cliente principal
  while(!Salir){
    // Creamos el socket...
    conn_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if(conn_socket == INVALID_SOCKET) {
      printf("Error al crear socket\n");
      Result = WSAGetLastError();
      break;
    }
    else{
      //Dirección IP del servidor y Puerto
      // localhost indica nuestra propia máquina...
      host = (struct hostent *)gethostbyname(ServerAdr);
      if(!host){
        printf("No se ha encontrado servidor...\n");
        Result = WSAGetLastError();
        break;
      }
      else{
        server.sin_family = AF_INET;
        server.sin_port   = htons(Port);
        server.sin_addr   = *((struct in_addr *)host->h_addr);
        ZeroMemory(server.sin_zero, 8);

        // Nos conectamos con el servidor...
        if(connect(conn_socket, (struct sockaddr *)&server,sizeof(server)) == SOCKET_ERROR)
          printf("Fallo al conectarse con el servidor\n");
        else{
          // Aquí debería empezar un bucle de comunicación con el servidor según tu propio protocolo
          printf("Conexion establecida con: %s\n", inet_ntoa(server.sin_addr));
          //Esto lo pongo para tener una salida del proceso aleatoria
          //No es necesaria para nada pero al menos asi consigo simular
          //que el proceso hace algo mas a parte de comunicarse
          srand(time(NULL));
          do{
            salida = rand()%1000;
            Sleep(10);
          }while(salida != 0);

          //Obtengo el tiempo en que termina el proceso
          fin = GetTickCount();

          //Obtengo el lapso de tiempo transcurrido
          lapso = fin-inicio;
          processID = GetCurrentProcessId();

          //Enviamos el lapso de tiempo que transcurrio...
          printf("Enviando lapso de tiempo... \n");
          sprintf(SendBuff,"El proceso con PID: %lu ha funcionado durante %lu milisegundos.",processID,lapso);
          send(conn_socket,SendBuff,sizeof(SendBuff),0);
          printf("Lapso enviado: %lu milisegundos\n", lapso);
          Salir = true;
          // Cerramos el socket y liberamos la DLL de sockets
          closesocket(conn_socket);
        }// conect
      }// host
    }// socket
  }//while
  WSACleanup();
  getchar();
  return Result;
} 


Se pueden simplificar esos mensajes y salidas de error.

Saludos.

[aguml]

me gusta como queda. En cuanto pueda lo pruebo y te cuento pero tiene muy buena pinta. Por otro lado se te olvidó el tema de la duda que comentaba en mi codigo del cliente:

Código PHP:

    //La siguiente linea, si no fuesen cliente y servidor en el mismo equipo
    //¿Tendria que darle la direccion ip del servidor?
    //Es que ahora mismo apunta a localhost del cliente ¿no?
    server.sin_addr   = *((struct in_addr *)host->h_addr); 


Por último comentar que me parece increible que C estandar no tenga soporte con una libreria propia y estandar para poder portar a otras plataformas sin tener que estar currandoselo en multiples plataformas a la vez ni con macros ni con nada por el estilo. Creo que deberia ser de lo proximo que añadan.

[[escafandra]]

Empezado por aguml

me gusta como queda. En cuanto pueda lo pruebo y te cuento pero tiene muy buena pinta. Por otro lado se te olvidó el tema de la duda que comentaba en mi codigo del cliente:

Código PHP:

    //La siguiente linea, si no fuesen cliente y servidor en el mismo equipo
    //¿Tendria que darle la direccion ip del servidor?
    //Es que ahora mismo apunta a localhost del cliente ¿no?
    server.sin_addr   = *((struct in_addr *)host->h_addr); 


Por último comentar que me parece increible que C estandar no tenga soporte con una libreria propia y estandar para poder portar a otras plataformas sin tener que estar currandoselo en multiples plataformas a la vez ni con macros ni con nada por el estilo. Creo que deberia ser de lo proximo que añadan.

Si te contesté... es aquí donde colocas la dirección del servidor (ServerAdr):

Código PHP:

//Dirección IP del servidor y Puerto
// localhost indica nuestra propia máquina...
host = (struct hostent *)gethostbyname(ServerAdr); 


Las funciones para sockets con casi idénticas en linux y son un estándar, date cuenta que la comunicación por esta vía es independiente del S.O. En delphi se usan igual.

Saludos.

[aguml]

Una duda más. Cuando en el cliente indicó el puerto ¿es el puerto del servidor? ¿y como indicaría cual es el puerto del cliente? O sea me refiero a si es el mismo puerto tanto para cliente como para servidor o no tiene porque ser el mismo para ambos.

[[escafandra]]

El puerto debe ser el mismo para cliente y servidor. Eso no quita para que puedan escribirse app que sean al mismo tiempo clientes y servidores en hilos separados, en ese caso debe haber dos puertos diferentes. Este caso es más típico de protocolo UDP pues no requiere conexión previa.


Saludos.