Method wait_for_terminate

src/tests/process_tests.cpp:2106–2122

  {
  public:
    Future<Nothing> wait_for_terminate(Promise<Nothing>&& p)
    {
      p.set(Nothing()); // Notify that we're inside the function.

      Time start = Clock::now();

      while (Clock::now() - start < process::TEST_AWAIT_TIMEOUT) {
        if (eventCount<TerminateEvent>() == 1 &&
            eventCount<DispatchEvent>() == 1) {
          return Nothing();
        }

        os::sleep(Milliseconds(1));
      }

      return Failure("Timed out waiting for terminate and dispatch");
    }
  };

  PID<TestProcess> process = spawn(new TestProcess(), true);