Delphi-PRAXiS - Warten bis ein Process wieder ready ist

Delphi-PRAXiS (https://www.delphipraxis.net/forum.php)

- Win32/Win64 API (native code) (https://www.delphipraxis.net/17-win32-win64-api-native-code/)

- - Warten bis ein Process wieder ready ist (https://www.delphipraxis.net/101233-warten-bis-ein-process-wieder-ready-ist.html)

Warten bis ein Process wieder ready ist

Hallo miteinander

Ich bin auf der suche nach einer möglichkeit zu prüffen ob meine cmd process immernoch arbeitet oder nicht.

Wundert euch nicht über sonderheitem im Code, ich hatte bisher das so realisiert das man beim aufruf ein Endzeichen mitgeben kann sowie ein timer, Es war bisher so das ich gewartet habe bis entweder das zeichen kommt oder der Timer ableuft und dann das nächste comando der konsole übergeben habe. nun waitforsingleObject wartet bis der process beendet wird, aber ich will ihn ja garnicht beenden sondern ein weiteres commando später absetzen. also wirklich so arbeiten wie die Konsole...

Die version hier funktioniert gut solange man in etwa abschätzen kann wielange der computer braucht um den befehl auszuführen sowie man einen rückgabewert hat. Mein problem ist nun das ich keinen output kriege und nicht weis wielange er braucht bis er fertig ist aber dennoch bemerken muss wann er fertig ist. wisst ihr also wie ich den process fragen kann ob er noch beschäftigt ist oder nicht ?

bin wirklich kurz vor dem verzweifeln..

danke schonmal im voraus und liebe grüsse

Severin

Delphi-Quellcode:

			procedure TConsoleThread.RC_Run(Command: string);

const bufsize=1024; // 1KByte buffer

var

  buf: array [0..bufsize-1] of char;

  si: tSTARTUPINFO;

  sa: tSECURITYATTRIBUTES;

//  sd: tSECURITYDESCRIPTOR;

  pi: tPROCESSINFORMATION;

  newstdin, newstdout, read_stdout, write_stdin: tHandle;

  bread, avail: dword;

  OffTime : Integer;

  ConsoleCommand, StringOffTime: string;

  CommandTypePos,OffCharPos : Integer;

begin

    //Initialisierung ProcessInfo

  FillChar(pi, SizeOf(TProcessInformation), 0);

    //Initialisierung SecurityAttr

  FillChar(sa, SizeOf(TSecurityAttributes), 0);

  sa.nLength := SizeOf(sa);

  sa.bInheritHandle := true;

  sa.lpSecurityDescriptor := nil;

    // create pipe A

  if not CreatePipe(newstdin, write_stdin, @sa, 0) then

  begin

      TriggerConsoleOut('Error creating Pipe A');

      exit;

  end;

    // create Pipe B

  if not CreatePipe(read_stdout, newstdout, @sa, 0) then begin

    TriggerConsoleOut('Error creating Pipe B');

    CloseHandle(newstdin);

    CloseHandle(write_stdin);

    exit;

  end;

    // Conf. si

  GetStartupInfo(si);

  si.dwFlags:=STARTF_USESTDHANDLES or STARTF_USESHOWWINDOW;

  si.wShowWindow:=SW_HIDE;

  si.hStdOutput:=newstdout;

  si.hStdError:=newstdout;

  si.hStdInput:=newstdin;

    // Create Process

  if not CreateProcess(pchar(command), pchar('/a'), nil, nil, true,

    CREATE_NEW_CONSOLE, nil, nil, si, pi) then

  begin

    TriggerConsoleOut('Error creating process: '+command);

    CloseHandle(newstdin);

    CloseHandle(newstdout);

    CloseHandle(read_stdout);

    CloseHandle(write_stdin);

    exit;

  end;

    // Loop principal

  fillchar(buf, sizeof(buf), 0);

  FRC_End:=false;

//  FRC_SendBuf:='';

  repeat

    if FInQueue.count > 0 then

    begin

      if Length(FRC_SendBuf) = 0 then

      begin

        waitforsingleobject(pi.hProcess,100); //<----- hier müsste man warten bis die Konsole ready ist hier wäre //sonst eine boolean variable die auf true geht sobald der timer ableuft oder das endzeichen kommt.

          if pos('#',FInQueue[0])<> 0 then             

          begin                                       

            CommandTypePos := pos('#1',FInQueue[0]);

            OffCharPos := pos('#2',FInQueue[0]);

            OffTime:= 20000;

            FCommandType:= copy(FInQueue[0],CommandTypePos+2,OffCharPos - (CommandTypePos + 2));

            FOffChar:=copy(FInQueue[0],OffCharPos+2,(length(FInQueue[0])+1)-(OffCharPos+2));

            ConsoleCommand := copy(FInQueue[0],1,(CommandTypePos-1));

            FTimer.Interval := OffTime;

            FTimer.Enabled:= true;

            FRC_SendBuf := '';

            FRC_SendBuf := ConsoleCommand+ CRLF;//FInQueue[0];

            FInQueue.Delete(0);

            modlogger.AddToLog('der Console Kommando Queue wurde folgendes kommando zur verarbeitung hinausgenommen.' +

                             FRC_SendBuf, ModDebug);

            FReady:= False;

          end

          else

          begin

            FOffChar := '';

            FTimer.Interval := 20000;

            FTimer.Enabled:= true;

            FRC_SendBuf := '';

            FRC_SendBuf :=FInQueue[0]+ CRLF;

            FInQueue.count;

            FInQueue.Delete(0);

            FReady:= False;

          end;

      end;

    end;

    OffTime := OffTime;

    application.processmessages;

  //    Application.HandleMessage;

    GetExitCodeProcess(pi.hProcess, FRC_ExitCode);

    if (FRC_ExitCode <> STILL_ACTIVE) then FRC_End:=True;

    PeekNamedPipe(read_stdout, @buf, bufsize, @bread, @avail, nil);

      // Comprobamos texto de salida

    if (bread<>0) then begin

      fillchar(buf, bufsize, 0);

      if (avail > bufsize) then

        while (bread >= bufsize) do begin

          ReadFile(read_stdout, buf, bufsize, bread, nil);

          SplitLines(buf);

          fillchar(buf, bufsize, 0);

        end

      else begin

        ReadFile(read_stdout, buf, bufsize, bread, nil);

        SplitLines(buf);

      end;

    end;

      // Eingabe text

   while (Length(FRC_SendBuf) > 0) do

   begin      

     WriteFile(write_stdin, FRC_SendBuf[1], 1, bread, nil);

     Delete(FRC_SendBuf, 1, 1);

   end;

  until FRC_End or Terminated;

    // Close

  CloseHandle(pi.hThread);

  CloseHandle(pi.hProcess);

  CloseHandle(newstdin);

  CloseHandle(newstdout);

  CloseHandle(read_stdout);

  CloseHandle(write_stdin);

  Terminate;

end;