constructor TMYT.Create(id: integer);

begin

inherited create(true);

FreeOnTerminate := true;

indexF:=id;

WriteBlock := 0;

  lastEndPosition:=0;

  WriteBlockIn:=1;

  Sleep(50);

  GeneralForm.ClientSettings.max_buffer_size := 65000;

  fs:=TFileStream.Create('1.txt',fmOpenRead);

  FullBufferSize := FS.Size;

  CountSection := (FullBufferSize div GeneralForm.ClientSettings.max_buffer_size)+1;

  GUID := Client.ClientModule.ServerMethodsClient.AddNewFileTransfer(FullBufferSize);

  EventsForm.EventItem[indexF].ProgressBar.Max := CountSection;

  MS := TMemoryStream.Create;

  BufferSize := GeneralForm.ClientSettings.max_buffer_size;

  BB := 0;

  Resume;

end;

 

procedure TMYT.DoWork;

label m1;

begin

try

    if (FullBufferSize<=0) then exit;

    m1:

      EventsForm.EventItem[indexF].ProgressPosition := BB;

      if FullBufferSize<BufferSize then

        BufferSize := FullBufferSize;

      Buffer := nil;

      SetLength(Buffer, BufferSize);

      FS.Position := lastEndPosition;

      FS.ReadBuffer(Buffer, BufferSize);

      MS.Clear;

      MS.WriteBuffer(Buffer, BufferSize);

      MS.Position := 0;

      if Client.ClientModule.ServerMethodsClient.WriteFileOnServer(MS,GUID,BufferSize) then

        lastEndPosition := FS.Position

          else

            goto m1;

      FullBufferSize:=FullBufferSize - GeneralForm.ClientSettings.max_buffer_size;

    inc(BB);

  if (FullBufferSize<=0) then

    begin

      client.ClientModule.ServerMethodsClient.SetEndFile(GUID);

      Terminate;

      MS.Free;

      FS.Free;

    end;

 

except

end;

end;

 

procedure TMYT.Execute;

  begin

    inherited;

    while not Terminated do

      begin

        Sleep(10);

        Synchronize(DoWork);

      end;

  end;

var

  FS:TFileStream;

  MS:TMemoryStream;

  Buffer:TBytes;

  GUID:string;

  CountSection:int64;

  FullBufferSize:int64;

  BufferSize:int64;

  I:Integer;

begin

try

  fs:=TFileStream.Create('1.txt',fmOpenRead);

  FullBufferSize := FS.Size;

  CountSection := (FullBufferSize div GeneralForm.ClientSettings.max_buffer_size)+1;

  GUID := Client.ClientModule.ServerMethodsClient.AddNewFileTransfer(FullBufferSize);//<-Создаем кэш на сервере

  MS := TMemoryStream.Create;

  BufferSize := GeneralForm.ClientSettings.max_buffer_size;//<-максимальные размер буфера

  for I := 0 to CountSection do

    begin

      if FullBufferSize<=0 then Break;

      if FullBufferSize<BufferSize then

        BufferSize := FullBufferSize;

      Buffer := nil;

      SetLength(Buffer, BufferSize);

      FS.ReadBuffer(Buffer, BufferSize);

      MS.Clear;

      MS.WriteBuffer(Buffer, BufferSize);

      MS.Position := 0;

      Client.ClientModule.ServerMethodsClient.WriteFileOnServer(MS,GUID,BufferSize);//<-отправка буфера

      FullBufferSize:=FullBufferSize - GeneralForm.ClientSettings.max_buffer_size;

    end;

  client.ClientModule.ServerMethodsClient.SetEndFile(GUID);//говорим серверу что файл закончен

  MS.Destroy;

  FS.Destroy;