Pipe EOF abfragen oder so :)

[blablab]

Hallo!

Ich starte mit CreateProcess ein Programm. Mit CreatePipe erstelle ich eine Pipe, und lese in einem extra Thread via ReadFile permanent die Ausgaben des Programms aus.
Mein Problem ist nun, dass wenn das gestartete Programm vom benutzer beendet wird, bekomme ich das nicht mit und ReadFile blockiert dann einfach.

Ich müsste nun irgendwie mitbekommen, dass das Programm beendet wurde. Ich müsste also entweder direkt erfahren, dass das Programm beendet wurde (GetExitCodeProcess liefert bei mir aber irgendwie immer STILL_ACTIVE) oder ich müsste zumindest einen Fehler bei ReadFile bekommen, das blockiert aber einfach nur...

Ich komm hier einfach nicht weiter. Könnt ihr mir bitte weiterhelfen?

Grüße
blablab

[Klaus01]

Prüfst Du denn nirgendwo in Deinem Thread ob der Process noch existiert?

Delphi-Quellcode:

while WaitForSingleObject(ProcessInfo.hProcess, 100) = WAIT_TIMEOUT do
  begin
    readBytes := HandleStreamOut.Read(Buffer, SizeOf(Buffer));
     ...
  end;

Grüße
Klaus

[blablab]

Bis jetzt sieht die Execute-Methode meines Threads so aus:

Delphi-Quellcode:

if CreateProcess(name, comLine, nil, nil, true, CREATE_NEW_CONSOLE, nil, nil, StartupInfo, ProcessInfo) then begin
   Sleep(100);
   if InstallHook(ProcessInfo.dwThreadId) then begin
      while True do begin
{1}      if WaitForSingleObject(ProcessInfo.hProcess, 10) <> WAIT_TIMEOUT then Exit;
         GetExitCodeProcess(ProcessInfo.hProcess, ExitCode);
{2}      if ExitCode <> STILL_ACTIVE then Exit;
         bool := ReadFile(PipeOutputRead, buf[1], BUF_SIZE, BytesRead, nil);
{3}      if not bool then Exit;
{4}      if bytesRead = 0 then Exit;

         PipeBufferBearbeiten(buf, BytesRead);
      end;
   end;
end;

Wenn ich nun die Anwendung, die mit CreateProcess gestartet wird schließe, wird weiterhin die while-Schleife ausgeführt. Irgendwann blockiert ReadFile soviel ich weiß. Bei allen 4 if-Bedingungen wird niemals das Exit aufgerufen. Langsam gehen mir die Ideen aus...

[blablab]

Ich glaub, ich hab jetzt ne Ahnung wieso das nicht geht. {3} und {4} gehen leider nicht, weil ReadFile einfach blockiert statt einen Fehler zurückzuliefern sobald das Programm beendet wurde.
Und {1} und {2} funktionieren prinzipiell, allerdings muss bei beiden länger gewartet werden. Also muss ich bei WaitForSingleObject() die TimeOut-Zeit hochsetzten oder vor GetExitCodeProcess() ein Sleep() setzen, dann gehts (jedenfalls meistens...).
Denn ich vermute es ist vereinfacht so:
ReadFile() benötigt im Normalfall angenommen 1ms. Wenn ich dann bei {1} oder {2} 99ms warte, dann führt der Thread beim Beenden des Programms zu 1% gerade das ReadFile aus und zu 99% {1} oder {2}. Somit wird es zu 1% blockiert und funktioniert zu 99%.

Ich versteh nur nicht wieso das ReadFile blockiert, das ist doch beschissen :!:

[himitsu]

Wo kommt PipeOutputRead her?

Und entweder synchron lesen und BytesRead auswerten
oder assynchron lesen, Overlapped verwenden und ReadByte ignorieren.
> siehe ReadFile


Ansonsten könnte man einfach mal gucken, wie es Andere machen
CreateProcess hStdOutput

[blablab]

PipeOutputRead erstelle ich mit CreatePipe. Ist also eine anonyme Pipe und soviel ich weiß geht das nur synchron. Und BytesRead auswerten geht ja nicht, wenn ReadFile einfach blockiert und ich somit kein BytesRead zurückgeliefert bekomm. Außerdem prüfe ich bei {4} ja schon BytesRead, aber das hat je nicht geholfen...
Extra eine named Pipe zu machen nur damit es asynchron ist, hab ich mir auch schon überlegt, aber das ist da glaub Overkill (hab noch nie ne named Pipe gemacht...).

[himitsu]

Zitat:

Zitat von blablab (Beitrag 1062566)

und soviel ich weiß geht das nur synchron.

Dann brauchst du aber keine Overlapptstruktur.

PS: Synchrones Lesen wartet so lange, bis Daten eingetroffen sind.
Ist die Gegenseite weg, sendet sie kein Daten und man wartet ewig.

[blablab]

Stimmt, das war n Fehler in meinem Quelltext. Ich hab das mal ausprobiert, aber da die Pipe sowieso synchron ist, wird Overlapped einfach ignoriert.

[himitsu]

Ich glaub da täuschst du dich etwas.

Delphi-Quellcode:

var h: THandle;
  w: Cardinal;
  o: TOverlapped;
  a, b, c, d: AnsiString;
begin
  a := '1234567890';
  h := CreateFile('a.aaa', GENERIC_WRITE, 0, nil, CREATE_ALWAYS, 0, 0);
  if (h = INVALID_HANDLE_VALUE)
      or not WriteFile(h, a[1], 10, w, nil)
      or (W <> 10) then
    RaiseLastOSError;
  CloseHandle(h);

  SetLength(b, 5);
  h := CreateFile('a.aaa', GENERIC_READ, 0, nil, OPEN_EXISTING, 0, 0);
  if (h = INVALID_HANDLE_VALUE)
      or not ReadFile(h, b[1], 5, w, nil)
      or (w <> 5) then
    RaiseLastOSError;
  CloseHandle(h);

  SetLength(c, 5);
  h := CreateFile('a.aaa', GENERIC_READ, 0, nil, OPEN_EXISTING, 0, 0);
  if (h = INVALID_HANDLE_VALUE)
      or (SetFilePointer(h, 2, nil, FILE_BEGIN) <> 2)
      or not ReadFile(h, c[1], 5, w, nil)
      or (w <> 5) then
    RaiseLastOSError;
  CloseHandle(h);

  FillChar(o, SizeOf(o), 0);
  o.Offset := 3;
  SetLength(d, 5);
  h := CreateFile('a.aaa', GENERIC_READ, 0, nil, OPEN_EXISTING, 0, 0);
  if (h = INVALID_HANDLE_VALUE)
      or not ReadFile(h, d[1], 5, w, @o)
      or (w <> 5) then
    RaiseLastOSError;
  CloseHandle(h);

  DeleteFile('a.aaa');

  ShowMessage(Format('b:%d  c:%d  c:%d', [Pos(b, a)-1, Pos(c, a)-1, Pos(d, a)-1]));
end;

würde Overlappt ignoriert, dann müßte

Delphi-Quellcode:

b:0  c:2  c:0

rauskommen und nicht

Delphi-Quellcode:

b:0  c:2  c:3

.

Man kann das Overlappt auch synchron verwenden, wobei hier der Offset genutzt wird.

Ohne Overlappt wird die aktuelle Dateiposition verwendet und diese dabei verschoben/erhöht.
Mit Overlappt wird das dort enthaltene Offset verwendet und der Positionszeiger nicht verschoben.


Ausnahme sind Pipes/Handles, welche keinen Datenzeiger unterstützen, sondern nur eine sequentielle Übertragung.

[blablab]

Stimmt auch wieder :D Allerding hatte ich als Offset 0 angegeben, da mir das mit dem Offset ja auch nicht wirklich weiterhilft...

Danke dass du dir so viel Mühe gibst! Aber du brauchst mir eigentlich nix beweisen, wenn du nur schreibst, dass er den Offset nicht ignoriert, dann glaub ich dir das einfach :wink: