1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:

procedure TTcpServerClass.TcpServerExecute(AThread: TIdPeerThread);
var
  _MStream: TMemoryStream;
  _HandleMsg: THandleMsg;
  _HandleStream: THandleMsgStream;
  _iMsgType, _iTSize: integer;
begin

  // prüfen ob daten im buffer sind
  if not AThread.Connection.Socket.Readable(0) then Exit;

......................                    

1:

if not AThread.Connected then exit;                    

1:

if not AThread.Connected then exit;                    

1:

if not AThread.Connection.Connected then exit;                    

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:

procedure TTcpServerClass.TcpServerExecute(AThread: TIdPeerThread);
var
  _MStream: TMemoryStream;
  _HandleMsg: THandleMsg;
  _HandleStream: THandleMsgStream;
  _iMsgType, _iTSize: integer;
begin

  // prüfen ob daten im buffer sind
  if not AThread.Connection.Socket.Readable(0) then Exit;

  //
  if not AThread.Connection.Connected then exit;

  // Init
  _MStream      := NIL;
  _HandleMsg    := NIL;

  try
   // lesen der grösse
   _iTSize:= AThread.Connection.ReadInteger;

   // erzeugen eines memory streams
   _MStream := TMemoryStream.Create;

   // schreiben in den memory stream (minus der ersten 4 byte)
   AThread.Connection.ReadStream(_MStream, _iTSize-4, False);

   // prüfen auf gesamtgrösse(minus der ersten 4 byte)
   if (_iTSize-4)<>(_MStream.Size) then
    HandleMsg(Self, ERROR_TOTAL_SIZE_MISS_MATCH, msgError);