Method Execute

Parallel/MPI/Testing/Cxx/TestProcess.cxx:47–75

}

void MyProcess::Execute()
{
  // multiprocess logic
  int numProcs = this->Controller->GetNumberOfProcesses();
  int me = this->Controller->GetLocalProcessId();

  std::cout << "numProcs=" << numProcs << " me=" << me << std::endl;
  std::cout << "executable=" << this->Argv[0] << std::endl;
  std::cout << "argc=" << this->Argc << std::endl;

  const int MY_RETURN_VALUE_MESSAGE = 0x11;

  if (me == 0)
  {
    // root node
    this->ReturnValue = 0;
    int i = 1;
    while (i < numProcs)
    {
      this->Controller->Send(&this->ReturnValue, 1, i, MY_RETURN_VALUE_MESSAGE);
      ++i;
    }
  }
  else
  {
    // satellites
    this->Controller->Receive(&this->ReturnValue, 1, 0, MY_RETURN_VALUE_MESSAGE);
  }
}

}