CLASSE DE GESTION DE PROCESSUS

#include "Process.hh"

/*!
** Exemple d'utilisation de la classe Sys::Process.
*/

namespace
{
  /*!
  ** Lance un simple "ls -la" et attends la fin de l'execution
  */
  void testLs()
  {
    Sys::Process process;
    process.setExecutable("ls");
    process.addArg("-la");
    process.setWorkingDirectory(".");

    std::cout << "Test script shell command: "
              << process.commandLine() << std::endl;

    process.run();
    int status = process.wait();
    std::cout << "Finish with status " << status << std::endl;
  }

  /*!
  ** Lance une commande de shell script (bash), et attend la fin
  ** de son exécution.
  */
  void testShellScript()
  {
    Sys::Process process;
    process.setExecutable("/bin/bash");
    process.addArg("-c").addArg("ls -laph --color | cat -ne");
    process.setWorkingDirectory(".");

    std::cout << "Test script shell command: "
              << process.commandLine() << std::endl;

    process.run();
    int status = process.wait();
    std::cout << "Finish with status " << status << std::endl;
  }


  /*!
  ** On exécute un ls -lph --color, et on met
  ** le résultat de l'exécution du process dans un buffer.
  ** Le buffer peut être un std::ostringstream qui peut ensuite
  ** être convertie en std::string, ou std::ofstream (l'écriture
  ** se fait alors directement dans un fichier).
  */
  void testLsWriteIntoBuffer()
  {
    Sys::Process process;
    process.setExecutable("ls");
    process.addArg("-lph").addArg("--color");
    process.setWorkingDirectory(".");

    std::ostringstream buff;
    process.setProcessOutput(buff);

    std::cout << "Test script shell command: "
              << process.commandLine() << std::endl;

    process.run();
    int status = process.wait();
    std::cout << "Finish with status " << status
              << ", result is: " << buff.str() << std::endl;
  }

  /*!
  ** On lance un processus très long (un sleep de 180 secondes).
  ** On attends une seconde, et on tue le processus car celui-ci
  ** met trop de temps à se terminer.
  */
  void testTerminateInfiniteLoop()
  {
    Sys::Process process;
    process.setExecutable("/bin/sh");
    process.addArg("-c").addArg("sleep 180");

    std::cout << "Test script shell command: "
              << process.commandLine() << std::endl;

    process.run();
    int status;
    process.timedWait(1, status);
    process.terminate();
    std::cout << "Finish with status " << status << std::endl;
  }

  /*!
  ** On lance un processus très long (un sleep de 15 secondes).
  ** Toute les 5 secondes on demande à l'utilisateur quoi faire.
  ** Celui-ci peut choisir d'attendre ou de tuer le processus.
  */
  void testTerminateInfiniteLoopWithChoice()
  {
    Sys::Process process;
    process.setExecutable("/bin/sh");
    process.addArg("-c").addArg("sleep 15");
    process.setNiceness(20); // Low priority, not mandatory

    std::cout << "Test script shell command: "
              << process.commandLine() << std::endl;

    process.run();

    int status;
    while (!process.timedWait(5, status))
    {
      std::cout << "The process is not responding\n"
        "1) Kill it\n2) Wait for it" << std::endl;
      int choice;
      std::cin >> choice;
      switch (choice)
      {
        case 1:
          std::cout << "Kill process" << std::endl;
          process.terminate();
          std::cout << "Aborted with status " << status << std::endl;
          return;
        case 2:
          std::cout << "Waiting for process" << std::endl;
          break;
        default:
          std::cout << "Unknow choice, waiting for process" << std::endl;
      }
    }

    std::cout << "Finish with status " << status << std::endl;
  }

  /*!
  ** On lance un processus très long (un cat de fichier assorti de sleeps
  ** pour ralentir volontairement le processus).
  ** On provoque l'arrêt de la tâche volontairement au bout de 2 secondes.
  ** Le buffer est alors rempli avec ce qui a pu être mis avant la fin du
  ** décompte.
  */
  void testTerminateInfiniteLoopWithOutputInBuffer()
  {
    Sys::Process process;
    process.setExecutable("/bin/sh");
    process.addArg("-c").addArg("for i in $(seq 1 5); do cat *.cc; sleep 1; done");
    process.setNiceness(20); // Low priority, not mandatory

    std::ostringstream buff;
    process.setProcessOutput(buff);

    std::cout << "Test script shell command: "
              << process.commandLine() << std::endl;

    process.run();
    int status = process.timedWait(2, status);
    process.terminate();
    std::cout << "Finish with status " << status << ", buff is: "
              << buff.str() << std::endl;
  }
} //namespace

int main()
{
  testLs();
  testLsWriteIntoBuffer();
  testShellScript();
  testTerminateInfiniteLoop();
  testTerminateInfiniteLoopWithChoice();
  testTerminateInfiniteLoopWithOutputInBuffer();

  return 0;
}