Duda sobre WM_COPYDATA y C

[[escafandra]]

Para contestar a tu duda sobre WM_COPYDATA en "C" te muestro este ejemplo de una aplicación sin ventana visible que se manda a sí misma un mensaje WM_COPYDATA y lo responde. Está escrita en C

Código PHP:

#include <windows.h>
#pragma hdrstop

//---------------------------------------------------------------------------
LRESULT  __stdcall WindowProc(HWND hWnd, UINT uMsg, WPARAM wParam, LPARAM lParam)
{
  if(uMsg == WM_COPYDATA){
    PCOPYDATASTRUCT Data =  (PCOPYDATASTRUCT)lParam;
    MessageBox(hWnd, (PCHAR)Data->lpData, "Mensaje recibido", 0);
  }

  return DefWindowProc(hWnd, uMsg, wParam, lParam);
}

char Name[] = "Hide";
#pragma argsused
WINAPI WinMain(HINSTANCE hInstance, HINSTANCE hPrevInstance, LPSTR lpCmdLine, int nCmdShow)
{
  HWND Handle;
  MSG message;
  WNDCLASS WinClass = {0,(WNDPROC)WindowProc,0,0,0,0,0,0,"", Name};
  COPYDATASTRUCT Data = {0};
  char *MSG = "Hola";
  Data.lpData = MSG;
  Data.cbData = strlen(MSG) + 1;

  RegisterClass(&WinClass);
  Handle = CreateWindow(Name, "", 0,0,0,0,0, HWND_DESKTOP, (HMENU)0, 0, NULL);
  SendMessage(Handle, WM_COPYDATA, 0, (LPARAM)&Data);
  while(GetMessage(&message, NULL, 0, 0)){
    TranslateMessage(&message);
    DispatchMessage(&message);
  }

  return 0;
} 


Saludos.

[aguml]

Muy interesante ¿y que hay que cambiar para que la ventana no sea invisible?
Otra cosa, si quisiera enviar el mensaje a otra ventana ¿solo necesito el handle de esa ventana?
Me interesa mucho lo que dices de sockets a bajo nivel ¿no tienes ningún texto donde se explique con ejemplos y cosas así?
Y sobre lo de la memoria compartida tengo mucha curiosidad de ver como se hace eso porque no tengo ni idea.

[[escafandra]]

Empezado por aguml

Muy interesante ¿y que hay que cambiar para que la ventana no sea invisible?

Estudia la API CreateWindow y los estilos: window styles.

Empezado por aguml

Otra cosa, si quisiera enviar el mensaje a otra ventana ¿solo necesito el handle de esa ventana?

Si, y que la ventana receptora trate el mensaje WM_COPYDATA

Empezado por aguml

Me interesa mucho lo que dices de sockets a bajo nivel ¿no tienes ningún texto donde se explique con ejemplos y cosas así?

Winsock Functions y recuerda este hilo donde te puse este ejemplo.

Empezado por aguml

Y sobre lo de la memoria compartida tengo mucha curiosidad de ver como se hace eso porque no tengo ni idea.

En el hilo que mencioné antes ya te di un enlace sobre los archivos de memoria compartida, aunque en la actualidad está roto. Aquí lo tienes en C++.


Saludos.

[aguml]

Muchas gracias por toda la información. Sobre sockets en Windows encontré esto: http://www.programacionenc.net/index.php?option=com_content&view=article&id=73:sockets-en-windows&catid=37rogramacion-cc&Itemid=55
Tengo algunas dudas sobre el ejemplo que pones de sockets:
- Por lo que he leído accept espera a que se conecte un cliente pero, si son por ejemplo 2 clientes ¿como seria?
- Si cliente y servidor están en la misma máquina ¿se usaría AF_UNIX? Eso es lo que entendí.
- ¿Cómo sería para que fuesen a sincrónicos?

[[escafandra]]

Empezado por aguml

Tengo algunas dudas sobre el ejemplo que pones de sockets:
- Por lo que he leído accept espera a que se conecte un cliente pero, si son por ejemplo 2 clientes ¿como seria?

La función accept devuelve un socket de comunicación que usaremos para comunicarnos con ese cliente. para poder aceptar otro cliente debemos volver a ejecutar accept, para que esto ocurra y podamos trabajar con varios clientes, se usan hilos de forma que se crea un hilo nuevo por cada cliente aceptado, cada hilo usará el socket proporcionado por accept

Empezado por aguml

- Si cliente y servidor están en la misma máquina ¿se usaría AF_UNIX? Eso es lo que entendí.

Puedes usar siempre AF_INET, lo importante es si usarás un protocolo TCP (SOCK_STREAM) o UDP (SOCK_DGRAM) revisa la forma de crear un socket.

Empezado por aguml

- ¿Cómo sería para que fuesen a sincrónicos?

Para establecer al socket como no bloqueante se usa la función ioctlsocket
También puedes usar un tipo bloqueante con un TimeOut con la función select


Saludos.

[aguml]

Ok muchas gracias. Voy a leer y a probar y ya cuento como me fue.

[aguml]

Ando bastante liado con todo esto y por ahora tengo este codigo aunque falta por dejarlo como quiero pero poco a poco:

Código PHP:

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

#define MAX_THREADS 2

DWORD WINAPI MyThreadFunction( LPVOID lpParam );
void ErrorHandler(LPTSTR lpszFunction);

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

    DWORD   dwThreadIdArray[MAX_THREADS];
    HANDLE  hThreadArray[MAX_THREADS];
    int i;

    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
            0,                      // 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");
           ExitProcess(3);
        }
    } // Fin del bucle de creacion de hilos

    // Espero a que terminen todos los hilos
    WaitForMultipleObjects(MAX_THREADS, hThreadArray, TRUE, INFINITE);

    // 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 ) 
{ 
    HANDLE hStdout;

    WSADATA wsaData;
    SOCKET conn_socket,comm_socket;
    SOCKET comunicacion;
    struct sockaddr_in server;
    struct sockaddr_in client;
    struct hostent *hp;
    int resp,stsize;
    char RecvBuff[100];

    //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...
    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)) ;
    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(conn_socket, (struct sockaddr *)&server, sizeof(server));
    if(resp==SOCKET_ERROR){
        printf("Error al asociar puerto e ip al socket\n");
        closesocket(conn_socket);
        WSACleanup();
        getchar();
        return WSAGetLastError();
    }

    if(listen(conn_socket, 1)==SOCKET_ERROR){
        printf("Error al habilitar conexiones entrantes\n");
        closesocket(conn_socket);
        WSACleanup();
        getchar();
        return WSAGetLastError();
    }
              
    // Aceptamos conexiones entrantes
    printf("Esperando conexiones entrantes... \n");
    stsize=sizeof(struct sockaddr);
    comm_socket=accept(conn_socket,(struct sockaddr *)&client,&stsize);
    if(comm_socket==INVALID_SOCKET){
        printf("Error al aceptar conexión entrante\n");
        closesocket(conn_socket);
        WSACleanup();
        getchar();
        return WSAGetLastError();
    }
    printf("Conexion entrante desde: %s\n", inet_ntoa(client.sin_addr));
              
    // Como no vamos a aceptar más conexiones cerramos el socket escucha
    closesocket(conn_socket);

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

    // Cerramos liberia winsock
    WSACleanup();
    return 0; 
}

void ErrorHandler(char *lpszFunction) 
{
    // Retrieve the system error message for the last-error code.

    LPVOID lpMsgBuf;
    LPVOID lpDisplayBuf;
    DWORD dw = GetLastError(); 

    FormatMessage(
        FORMAT_MESSAGE_ALLOCATE_BUFFER | 
        FORMAT_MESSAGE_FROM_SYSTEM |
        FORMAT_MESSAGE_IGNORE_INSERTS,
        NULL,
        dw,
        MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
        (LPTSTR) &lpMsgBuf,
        0, NULL );

    // Display the error message.

    lpDisplayBuf = (LPVOID)LocalAlloc(LMEM_ZEROINIT, 
        (lstrlen((LPCTSTR) lpMsgBuf) + lstrlen((LPCTSTR) lpszFunction) + 40) * sizeof(TCHAR)); 
    printf("%s failed with error %d: %s",lpszFunction, dw, lpMsgBuf);
    MessageBox(NULL, (LPCTSTR) lpDisplayBuf, TEXT("Error"), MB_OK); 

    // Free error-handling buffer allocations.

    LocalFree(lpMsgBuf);
    LocalFree(lpDisplayBuf);
} 


La idea es que ambos procesos se conecten al servidor y envien la cadena con el pid y el tiempo de ejecucion pero me sale lo siguiente en la consola:

Esperando conexiones entrantes...
Error al asociar puerto e ip al socket
Conexion entrante desde: 127.0.0.1
Recibiendo Mensajes...
Datos recibidos: El proceso con PID: 3748 ha funcionado durante 500 milisegundos.

Y se queda esperando en:

Código PHP:

WaitForMultipleObjects(MAX_THREADS, hThreadArray, TRUE, INFINITE); 


Si pongo que se cree un solo hilo va bien pero la idea de usar hilos es para que pueda conectar alguno mas jejeje.
¿Me pueden explicar porque me falla y que debo cambiar?