1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:
34:
35:
36:
37:
38:
39:
40:
41:
42:
43:
44:
45:
46:
47:
48:
49:
50:
51:
52:
53:
54:
55:
56:
57:
58:
59:
60:
61:
62:
63:
64:
65:
66:
67:
68:
69:
70:
71:
72:
73:
74:
75:
76:
77:
78:
79:
80:
81:
82:
83:
84:
85:
86:
87:
88:
89:
90:
91:
92:
93:
94:

procedure TSimpleTCPServer.ServerExecute(AThread: TIdPeerThread);
var Command:Integer;
var Stream:TStream;
var TempFile:String;
var BytesToTransfer,BytesTransferred,BytesToRead:Int64;
begin
  if (not AThread.Terminated) and (AThread.Connection.Connected) then
  try
    //set nonstopping breakpoint to ignore following exceptions
    AThread.Connection.ReadBuffer(Command, SizeOf(Command));
    //set nonstopping breakpoint to handle following exceptions

    //bytes to read?
    AThread.Connection.ReadBuffer(BytesToRead, SizeOf(BytesToRead));

    //if datasize is large, create a file stream,
    // else create faster memory stream
    if BytesToRead>=FSizeForFileStream then
    begin
      TempFile:=GetTempFile;
      Stream:=TFileStream.Create(TempFile,fmCreate)
    end
    else
      Stream:=TMemoryStream.Create;

    try
      Stream.Size:=BytesToRead;
      Stream.Position:=0;

      //triggering initial OnProgress event
      BytesTransferred:=0;
      BytesToTransfer:=BytesToRead;
      FCS.Enter;
      try
        FConnection:=FConnections.ByThread(AThread);
        FBytesTransferred:=BytesTransferred;
        FBytesToTransfer:=BytesToTransfer;

        if Assigned(FOnProgress) then
        AThread.Synchronize(HandleProgress);
      finally
        FCS.Leave;
      end;

      //receive data
      While BytesToRead>=FBytesForProgress do
      begin
        AThread.Connection.ReadStream(Stream,FBytesForProgress);
        BytesToRead:=BytesToRead-FBytesForProgress;
        BytesTransferred:=BytesTransferred+FBytesForProgress;

        //triggering OnProgress event
        FCS.Enter;
        try
          FConnection:=FConnections.ByThread(AThread);
          FBytesTransferred:=BytesTransferred;
          FBytesToTransfer:=BytesToTransfer;

          if Assigned(FOnProgress) then
            AThread.Synchronize(HandleProgress);
        finally
          FCS.Leave;
        end;
      end;

      if BytesToRead>0 then
        AThread.Connection.ReadStream(Stream,BytesToRead);
      Stream.Position:=0;

      //Closing writestream, reopening as readstream
      if Stream is TFileStream then
      begin
        Stream.Free;
        Stream:=TFileStream.Create(TempFile,fmOpenRead);
      end;

      //commandprocessing
      FCS.Enter;
      try
        FCommand:=Command;
        FConnection:=FConnections.ByThread(AThread);
        FStream:=Stream;
        AThread.Synchronize(HandleProcessCommand);
      finally
        FCS.Leave;
      end;
    finally
      //FStream.Free;
    end;
  except
    AThread.Connection.Disconnect;
    AThread.Terminate;
  end;
end;