Indy TCP Server mehrfache Strings im Buffer

[Neutral General]

Das verstehe ich nicht. Wer programmiert denn den Client zu deinem Server?
Der Server bestimmt das Format der Daten die er entgegen nimmt, es sei denn du willst einen Server für ein schon vorhandenes Protokoll erstellen.

[Grizu]

Der client ist ein externes Gerät (Sprich kein PC) der auf einem TCP Port verbindet und [STX][ETX] gerahmt Daten sendet.

[Neutral General]

ja gut, dann musst du wirklich Byte für Byte lesen bis ein ETX kommt.

[Grizu]

bin das jetzt mal angegangen.
Aber er wirft eine Exception wenn ich versuche ein gelesenes byte in ein anders array zu schreiben

Delphi-Quellcode:

var
  LLine : String;
  b : Byte;
  a, i, i1 : integer;
  TBuffer, TBuff : TiDBytes;

Begin
if rdt_server.active then begin
 try
    AContext.Connection.IOHandler.ReadBytes(TBuffer, -1, False);
    //i := AContext.Connection.IOHandler.RecvBufferSize;
    i := SizeOf(TBuffer);
    a := 0;
    i1 := 0;
    edit1.Text := inttostr(i);
    while i > 1 do begin
     b := TBuffer[i1];
     edit2.Text := inttostr(b);
      if b <> 3 then begin
      edit3.Text := 'XXXXXXXXX';
        TBuff[i1] := b; // HIER BRICHT ER AB!!
        edit3.Text := 'AAAAAAAAA';
        i1 := i1 + 1;
        i := i - 1;
        a:= a + 1;
      end;
      if b = 3 then begin

         LLine := IdGlobal.BytesToString(TBuff, 0, a, nil);
         mbo_rdt_rec.Lines.Add(LLine);
         pnl_rdt_last_record.Caption := LLine;

      end;

    end;

[Grizu]

Habs selber gefunden......

[CarlAshnikov]

Mit Waitfor kann man auf einen bestimmten string im Inputbuffer warten.

Delphi-Quellcode:

var
  lText: string;
begin
  lText := AContext.Connection.IOHandler.Waitfor(chr(3));
end;

[Grizu]

Das ist auch eine sehr gute Idee, muss ich mal probieren.
Ich habe es folgendermaßen gelöst und das ganze in einen eigenen Thread gepackt:

Delphi-Quellcode:

procedure rdt_rec_decoding.Execute;
  var
  s : String;
  b : Byte;
  a,i, i1 : integer;

begin
 NameThreadForDebugging('rdt_data_receive');
try
    a := 0;
    a := Length(BBuffer);
    i1 := 0;
    s := '';
    for i := 1 to a do begin
     b := BBuffer[i1];
     if b <> 3 then begin
             if b = 2 then begin
             i1 := i1 + 1;
             end else begin
             s := s + Chr(b);
             i1 := i1 + 1;
             end;

     end;
     if b = 3 then begin
     ddata := s;
     if s <> '' then begin
         Synchronize(UpdateLastRecord);
         Synchronize(UpdateRecordbox);
     end;
     end;

    end;