Protocolo envío de ficheros entre pcs

[Status Quo]

Hola de nuevo…
Me está agobiando la realización del programa.
Tengo que sincrozar los directorios que hay en un directorio de un servidor con los que hay en un cliente.
Para ello tengo que mandar (a trozos) los ficheros al cliente mediante un protocolo inventado por mi…
Al final he conseguido hacer esto…que…no hace una m…
No he descubierto como mandar al cliente los tozos de bytes con cabecera incluida…así que lo que hago es envíar un texto con la cabecera antes de eviar cada trozo…

El caso esque siempre me da error al volver a leer un trozo…del fichero en el servidor.
Comentando lo que está en negrita, consigo que no de error en el servidor. Pero si me lo da en el cliente (en negrita ) al intentar crear el fichero…

Me estoy deserperando. Por favor si no os importa echarle un vistazo al enjendro que he hecho y orientarme un poco.

Gracias

Función que manda ficheros al cliente:

procedure TForm1.ActualizarCliente(nombreFichero:string);
 var
  stream: TStream;
  leidos: Cardinal;
  trama:TMemoryStream;
  buf:pchar;
  nombFich:string;
  buffer:array[0..256] of byte;
  msjFICH:String;
  msjTRAMA:String;
  i:integer;
  PCliente:TPuntero;
  numFragm:integer;
  tam:integer;
  tipo: char;
begin

 

  stream:=TFileStream.Create('Maestro\'+ nombreFichero,fmOpenRead);
  tam :=(stream.Size);
  leidos:=stream.Read(buffer,SizeOf(buffer));
  ShowMessage('Pasa por las asig');
  tipo:='f';
  for i:=0 to MiLista.Count-1 do{Se recorren los clientes almacenados en la lista}
    begin
ShowMessage('Pasa por el for');
     PCliente:=MiLista.Items[i];
     msjFICH:=tipo+ formatFloat('0000',tam)+ formatFloat('00',length(nombreFichero))+ nombreFichero;
     PCliente^.Conexion.SendText(formatFloat('000',length(msjFICH)+3)+msjFICH);
    end;
  tipo:='t';
  repeat
    Application.ProcessMessages;
    trama:=TMemoryStream.Create;
    trama.WriteBuffer(buffer,leidos);

    ShowMessage('Pasa por el repeat');


    for i:=0 to MiLista.Count-1 do{Se recorren los clientes almacenados en la lista}
    begin
     PCliente:=MiLista.Items[i];


     msjTRAMA:=(tipo+ formatFloat('000',numFragm)+formatFloat('000',leidos));
     PCliente^.Conexion.SendText(formatFloat('000',length(msjTRAMA)+3)+msjTRAMA);

     ShowMessage('Pasa por el sendtext');
     PCliente^.Conexion.SendStream(trama);
         ShowMessage('Pasa por el sendstream');
    end;
     leidos:=stream.Read(buffer,SizeOf(buffer));//me da error
    ShowMessage('Pasa por leidos');
    trama.Position:=0;
    trama.Free;    until(leidos=0);
  stream.Position:=0;
  stream.Free;


end;




Cliente que recibe los ficheros del servidor

procedure TForm1.ClientSocket1Read(Sender: TObject;
  Socket: TCustomWinSocket);
var
  //longCab:integer;
  MsjLocal:String;
  tipo:char;
  NombFich:String;
  tamMsj:integer;
  tamFich:integer;
  tamNombreFich:integer;

  numFrag:integer;
  FragLeidos:integer;


  TamEntrante:Integer;
  TamRecibido:Integer;

  buffer:array[0..9999] of byte;
  FicheroStream: TFileStream;

begin


    ColaMsj:=ColaMsj+Socket.ReceiveText;


    while (length(ColaMsj)>=7) do//Para cojer tamaño mensaje y tipo
    begin
        memo1.Lines.Add('cola '+ColaMsj);
        tamMsj:=StrToInt(copy(ColaMsj,1,3));
        memo1.Lines.Add('tam: '+IntToStr(tamMsj));
        tipo:=ColaMsj[4];
        memo1.Lines.Add('tipo'+tipo);
        if (length(ColaMsj)>=tamMsj) then
         begin
          if tipo = 'f' then
           begin
             tamFich:=StrToInt(Copy(ColaMsj,5,4));
             memo1.Lines.Add('tamfich: '+IntToStr(tamFich));
             tamNombreFich:=StrToInt(Copy(ColaMsj,9,2));
             memo1.Lines.Add('tamnombrefich: '+IntToStr(tamNombreFich));
             NombFich:=Copy(ColaMsj,11,tamNombreFich);
             memo1.Lines.Add('Nombrefich: '+NombFich );

             msjLocal:=Copy(ColaMsj,1,tamMsj); // Cogemos el primer mensaje de la cola de mensajes
             delete(ColaMsj,1,tamMsj);         // quitamos el primer mensaje de la cola

           end
          else//Mensaje de trama
           begin
            numFrag:=StrToInt(Copy(ColaMsj,5,3));
            FragLeidos:=StrToInt(Copy(ColaMsj,8,3));

            msjLocal:=Copy(ColaMsj,1,tamMsj); // Cogemos el primer mensaje de la cola de mensajes
            delete(ColaMsj,1,tamMsj);         // quitamos el primer mensaje de la cola
           end;
          end;
       Sleep(1);


    FicheroStream := TFileStream.Create(NombFich, fmCREATE or fmOPENWRITE and fmsharedenywrite);
    TamEntrante:= Socket.ReceiveLength;
    while TamEntrante > 0 do
    begin
     TamRecibido:=Socket.ReceiveBuf(buffer,Sizeof(buffer));
      if TamRecibido > 0 then
      begin
        FicheroStream.Write(buffer,tamRecibido);
      end;
    end;
 end;
end;