¿procesos que charlan entre ellos usando tuberias con nombre?

[[escafandra]]

No creo que estés usando el método adecuado. Es mejor que la comunicación sea síncrona y ten en cuenta que los paquetes se pueden unir o separar. No tengo ahora tiempo de realizar un ejemplo. Puedes, también, usar la API TransmitFile

Te dejo un fragmento de código funcional para recibir ficheros por esta vía, previamente debes haber comunicado el tamaño del fichero y nombre a transferir (SizeFile y lpPathName):

Código PHP:

  int  Size = 1024*10;
  BYTE *Buffer = (BYTE*)VirtualAlloc(0, Size, MEM_COMMIT, PAGE_READWRITE);
  UINT  Len = 0;
  int   nBytes = 0;
  HANDLE hFile = CreateFile(lpPathName, GENERIC_WRITE, 0, NULL, OPEN_ALWAYS, FILE_FLAG_WRITE_THROUGH, 0);
  if(hFile != INVALID_HANDLE_VALUE){
    do {
      Len = Recv(Sock, Buffer, Size, 0, 10000);
      if(Len == -1) break;
      _lwrite((int)hFile, Buffer, Len);
      nBytes += Len;
    } while (nBytes != FileSize)
    CloseHandle(hFile);
  }
  VirtualFree(Buffer, 0, MEM_RELEASE); 


Saludos.

[[escafandra]]

Bueno, te he preparado un rápido ejemplo sobre el chat que te envié antes y sin usar componentes de VCL. Sokets "a pelo".

En el chat, si el cliente envía "Envia Fichero" (sin acento para no confundir caracteres), el servidor envía un fichero llamado Prueba0.bmp que es un bmp grande. El cliente lo recibe y lo guarda como Prueba.bmp. A continuación el server recibe la palabra y sigue la comunicación...

Te expongo las funciones que envían y reciben el fichero:

TransmitFile.h

Código PHP:

#ifndef TRANSMIT_FILE_H
#define TRANSMIT_FILE_H

void TransmitFile(SOCKET Sock, char* lpPathName);
void ReceiveFile(SOCKET Sock, char* lpPathName, int FileSize);
void ReceiveFile(SOCKET Sock);

#endif 


TransmitFile.cpp

Código PHP:

#include <windows.h>
#include <winsock2.h>
#include <Mswsock.h>

#include "TrasmitFile.h"

struct TFileData{
  char FilePath[MAX_PATH*2];
  int FileSize;
};

void TransmitFile(SOCKET Sock, char* lpPathName)
{
  if(Sock == INVALID_SOCKET || !lpPathName) return;
  if(!*lpPathName) return;

  char Msg[10];
  HFILE hFile = _lopen(lpPathName, OF_READ);
  if(hFile == -1) return;
  int FileSize = GetFileSize((HANDLE)hFile, 0);
  TFileData FileData;
  strcpy(FileData.FilePath, lpPathName);
  FileData.FileSize = FileSize;
  send(Sock, (char*)&FileData, sizeof(TFileData), 0);
  recv(Sock, Msg, sizeof(Msg),0);
  if(!strncmp(Msg, "Ok", 2)){
    TransmitFile(Sock, (HANDLE)hFile, FileSize, 0,0,0,0);
  }
  _lclose(hFile);
}

void ReceiveFile(SOCKET Sock)
{
  TFileData FileData;
  recv(Sock, (char*)&FileData, sizeof(FileData),0);
  send(Sock, "Ok", 2, 0);
  ReceiveFile(Sock, "Prueba.bmp", FileData.FileSize);

}

void ReceiveFile(SOCKET Sock, char* lpPathName, int FileSize)
{
  int  Size = 1024*10;
  BYTE *Buffer = (BYTE*)VirtualAlloc(0, Size, MEM_COMMIT, PAGE_READWRITE);
  UINT  Len = 0;
  int   nBytes = 0;
  HANDLE hFile = CreateFile(lpPathName, GENERIC_WRITE, 0, NULL, OPEN_ALWAYS, FILE_FLAG_WRITE_THROUGH, 0);
  if(hFile != INVALID_HANDLE_VALUE){
    do {
      Len = recv(Sock, Buffer, Size, 0);
      if(Len == -1) break;
      _lwrite((int)hFile, Buffer, Len);
      nBytes += Len;
    } while (nBytes != FileSize);
    CloseHandle(hFile);
  }
  VirtualFree(Buffer, 0, MEM_RELEASE);
} 


Usa la API TransmitFile, que usa socket, puedes sustituirla por una función equivalente a bajo nivel.

PD/ Borro el anterior chat porque este es idéntico, añadiendo la nueva funcionalidad

Saludos.

[aguml]

Amigo he estado haciendo pruebas con la api que comentas pero claro, tu usas un tipo SOCKET y yo intento hacer lo mismo con un TSocketServer y un TSocketClient y la verdad es que todo lo que pruebo acaba retornandome false en TransmitFile. He probado esto:

Código PHP:

bool transmitido;
if(IsServer){
   transmitido = TransmitFile((unsigned int)ServerSocket->Socket->Connections[0]->Handle, (HANDLE)hFile, tamanio, 0,0,0,0);
}else{
   transmitido = TransmitFile((unsigned int)ClientSocket->Socket->Handle, (HANDLE)hFile, tamanio, 0,0,0,0);
} 


y esto:

Código PHP:

bool transmitido;
if(IsServer){
   transmitido =  TransmitFile((unsigned  int)ServerSocket->Socket->Handle,  (HANDLE)hFile, tamanio, 0,0,0,0);
}else{
   transmitido = TransmitFile((unsigned int)ClientSocket->Socket->Handle, (HANDLE)hFile, tamanio, 0,0,0,0);
} 


y tambien esto:

Código PHP:

bool transmitido;
if(IsServer){
   transmitido =  TransmitFile((unsigned  int)ServerSocket->Handle,  (HANDLE)hFile, tamanio, 0,0,0,0);
}else{
   transmitido = TransmitFile((unsigned int)ClientSocket->Handle, (HANDLE)hFile, tamanio, 0,0,0,0);
} 


y en todos los casos retorna como false y en el receptor no hay señales de que se reciba algo. Son asincronicos y no se si esto tiene que ver.

[[escafandra]]

Para poder usar la API de winsocket desde los componentes VCL TServerSocket y TClientSocket, debes usar ServerSocket->Socket->SocketHandle o ClientSocket->Socket->SocketHandle


Saludos.

[aguml]

Bueno amigo, he estado viendo el modo en que me indicabas y he modificado mi funcion para que use lo que me indicabas, o sea, uso TransmitFile y una funcion propia llamada ReceiveFile. El problema es que el archivo que recibo es corrupto porque termina la funcion de recepcion pero no recibo todos los bytes. He comprobado que en la funcion ReceiveFile salgo del bucle con el break en vez de salir porque nBytes sea igual a FileSize. Lo que pienso es que se pueden estar perdiendo bytes por el camino pero no tengo ni idea ya que uso TransmitFile y no se como funciona esta por dentro. Adjunto el proyecto por si quereis mirarlo a ver que puede estar pasando.

[[escafandra]]

Tienes un eror de concepto. Cuando esperas recibir el archivo y se dispara el evento SocketRead, en tu código, primero lees cosas (estructura del archivo, MD5...) con lo que estás perdiendo datos, pues en ese momento ya estás recibiendo los primeros bloques del archivo. Fíjate en este cambio que realizo en tu código y verás que ya funciona. Seguramente este error lo tenías en otras formas de leer tu archivo:

Código PHP:

void __fastcall TChatForm::SocketRead(TCustomWinSocket *Socket)
{
  if(recvFile == true && recvStructFile == true)
  {
           //Aqui recibimos el archivo
           int recibidos = ReceiveFile(Socket->SocketHandle, NewPath.c_str(), archivo.size);

           RichEdit1->SelStart = RichEdit1->Text.Length();
           RichEdit1->SelLength = 0;
           RichEdit1->SelAttributes->Color = clPurple;
           RichEdit1->Lines->Add("Finalizó la recepcion del archivo.");

           recvFile = false;
           recvStructFile = false;
           archivo.end = true;
           if(recibidos != archivo.size)
           {
                RichEdit1->SelStart = RichEdit1->Text.Length();
                RichEdit1->SelLength = 0;
                RichEdit1->SelAttributes->Color = clPurple;
                RichEdit1->Lines->Add("El archivo está corrupto. El tamaño del archivo enviado y del recibido son diferentes.");
           }else{
                RichEdit1->SelStart = RichEdit1->Text.Length();
                RichEdit1->SelLength = 0;
                RichEdit1->SelAttributes->Color = clPurple;
                RichEdit1->Lines->Add("Archivo recibido correctamente.");
           }
           Edit1->Enabled = true;
           ButtonSendFile->Enabled = true;
           TrackBarMiliseconds->Enabled = true;
           CheckBoxListen->Enabled = true;
           ButtonExit->Enabled = true;
           ButtonDisconnect->Enabled = true;

           //Calculo el MD5 del archivo recibido y lo comparo con el del archivo enviado
           char md5[33];

           memset(md5, 0, sizeof(md5));
           strcpy(md5, ObtenerMD5(NewPath.c_str()).c_str());
           
           if(strncmp(md5, archivo.MD5, 32) == 0)
           {
                RichEdit1->SelStart = RichEdit1->Text.Length();
                RichEdit1->SelLength = 0;
                RichEdit1->SelAttributes->Color = clPurple;
                RichEdit1->Lines->Add(AnsiString().sprintf("Los MD5 coinciden. MD5: %s", md5));
           }else{
                RichEdit1->SelStart = RichEdit1->Text.Length();
                RichEdit1->SelLength = 0;
                RichEdit1->SelAttributes->Color = clRed;
                RichEdit1->Lines->Add(AnsiString().sprintf("Los MD5 no coinciden. MD5 del enviado: %s | MD5 del recibido: %s", archivo.MD5, md5));
           }

           SetForegroundWindow(ChatForm->Handle);
  }


  // Cuando el servidor envia datos al ciente y este los ha de procesar
  char flagFile[SIZEFLAG] = {"\n\n_File_\n\n\0"};
  unsigned char *buffer;
  int size,lenBuff;
  lenBuff = Socket->ReceiveLength();
  buffer = new unsigned char[lenBuff];
  memset(buffer,0,sizeof(buffer));

  size = Socket->ReceiveBuf(buffer,lenBuff);
  if(strcmp(buffer, flagFile) == 0)
  {
        recvFile = true;
        RichEdit1->SelStart = RichEdit1->Text.Length();
        RichEdit1->SelLength = 0;
        RichEdit1->SelAttributes->Color = clPurple;
        RichEdit1->Lines->Add("Recibiendo archivo. Espera a que termine y no cierres la aplicación.");
        Edit1->Enabled = false;
        ButtonSendFile->Enabled = false;
        TrackBarMiliseconds->Enabled = false;
        CheckBoxListen->Enabled = false;
        ButtonExit->Enabled = false;
        ButtonDisconnect->Enabled = false;
  }
  else if(recvFile == true && size == sizeof(archivo) )
  {
        memcpy(archivo.name, buffer, sizeof(archivo.name));
        memcpy(&archivo.size, buffer + sizeof(archivo.name), sizeof(archivo.size));
        memcpy(&archivo.blocks, buffer + sizeof(archivo.name) + sizeof(archivo.size), sizeof(archivo.blocks));
        memcpy(&archivo.end, buffer + sizeof(archivo.name) + sizeof(archivo.size) + sizeof(archivo.blocks), sizeof(archivo.end));
        memcpy(&archivo.MD5, buffer + sizeof(archivo.name) + sizeof(archivo.size) + sizeof(archivo.blocks) + sizeof(archivo.end), sizeof(archivo.MD5));

        if(archivo.end == false)
        {
           NewPath = ExtractFilePath(Application->ExeName) +"_"+ archivo.name;

           if(FileExists(NewPath))
                DeleteFile(NewPath);
           recvStructFile = true;
        }
  } else{
     //Si no es una imagen mostramos el mensaje enviado
     RichEdit1->SelStart = RichEdit1->Text.Length();
     RichEdit1->SelLength = 0;
     RichEdit1->SelAttributes->Color = clGreen;
     RichEdit1->Lines->Add(Socket->RemoteHost + ": " + AnsiString((char*)buffer).SubString(1,size) );  // Añadir los datos al memo de recepción
  }
  delete [] buffer;
} 


Saludos.

[[escafandra]]

Aprovecho para mostrarte como obtener el Hash MD5 de un archivo con la API de Windows tal y como lo utilicé en este ejemplo para cazar un virus: TerminateMD5_Process, a la caza de un virus...

Código PHP:

//---------------------------------------------------------------------------
#define MD5LEN  16
#define BUFSIZE 1024
typedef CHAR TMD5[33];


void GetMD5FromFile(CHAR* FileName, CHAR *MD5)
{
  HANDLE hFile = 0;
  HCRYPTPROV hProv = 0;
  HCRYPTHASH hHash = 0;
  BYTE Hash[MD5LEN];
  DWORD bHash = 0;
  DWORD bRead = 0;
  BYTE* Buffer = (BYTE*)VirtualAlloc(0, BUFSIZE, MEM_COMMIT, PAGE_READWRITE);
  hFile = CreateFile(FileName, GENERIC_READ, FILE_SHARE_READ, NULL, OPEN_EXISTING, FILE_FLAG_SEQUENTIAL_SCAN, 

NULL);
  if(hFile != INVALID_HANDLE_VALUE){
    if(CryptAcquireContext(&hProv, NULL, NULL, PROV_RSA_FULL, CRYPT_VERIFYCONTEXT)){
      if(CryptCreateHash(hProv, CALG_MD5, 0, 0, &hHash)){
        while (1) {
          ReadFile(hFile, Buffer, BUFSIZE, &bRead, NULL);
          if(!bRead) break;
          CryptHashData(hHash, Buffer, bRead, 0);
        }
        bHash = MD5LEN;
        if(CryptGetHashParam(hHash, HP_HASHVAL, Hash, &bHash, 0)){
          for(int i=0; i<2*MD5LEN; i++){
            MD5[i] = (0x0F & Hash[i/2] >> 4*((i+1)%2)) + 48;
            if(MD5[i] > '9') MD5[i] += 7;
          }
          MD5[32] = 0;
        }
      }
      CryptDestroyHash(hHash);
    }
    CryptReleaseContext(hProv, 0);
  }
  CloseHandle(hFile);
  VirtualFree(Buffer, 0, MEM_RELEASE);
} 


Saludos.

[[escafandra]]

Un detalle más que olvidé al publicar la solución a tu problema es que ha añadido un guión bajo al nombre del archivo recibido puesto que se escribe en el mismo path que el original y puede ocurrir una doble apertura del mismo:

Código PHP:

NewPath = ExtractFilePath(Application->ExeName) +"_"+ archivo.name; 


Saludos.

[aguml]

estos dias no voy a poder tocar el pc porque voy a estar fuera y la verdad es que no veo el cambio que realizaste en el codigo a simple vista. ¿Podrias explicar que cambiaste y cual era el problema? Sobre lo del md5... Sabia que python lo ponia muy facil pero no sabia que la api de windows ya lo tenia y la verdad es que es de gran utilidad. Muchisimas gracias por todo.

[[escafandra]]

Puse delante de todo, el código que lee el fichero, antes de las lecturas del flag y cabeceras. Viendo que esas variables eran globales, me salté su lectura, puesto que en el anterior evento ya se han leído.

El oroblema es que si lees del socket datos, cuando esperas un fichero, no se vuelven a leer después y pierdes esa información, que es del propio fichero.

Debes organizar un poco codo el código.


Saludos.