Method CheckThreadStatus

examples/extended/parallel/MPI/source/src/G4MPImanager.cc:445–479

====================================================================

// ====================================================================
G4bool G4MPImanager::CheckThreadStatus()
{
  unsigned buff;
  unsigned qstatus = 0;

  if (is_master_) {
    qstatus = (thread_id_ != 0);
    // get slave status
    for (G4int islave = 1; islave < size_; islave++) {
      MPI_Request request;
      MPI_Irecv(&buff, 1, MPI_UNSIGNED, islave, kTAG_G4STATUS, COMM_G4COMMAND_, &request);
      int flag = 0;
      while (!flag) {
        MPI_Test(&request, &flag, MPI_STATUS_IGNORE);
        ::Wait(1000);
      }

      qstatus |= buff;
    }
  }
  else {
    buff = (thread_id_ != 0);
    MPI_Send(&buff, 1, MPI_UNSIGNED, kRANK_MASTER, kTAG_G4STATUS, COMM_G4COMMAND_);
  }

  // broadcast
  buff = qstatus;  // for master
  MPI_Bcast(&buff, 1, MPI_UNSIGNED, kRANK_MASTER, COMM_G4COMMAND_);
  qstatus = buff;  // for slave

  if (qstatus != 0)
    return true;
  else
    return false;
}

// --------------------------------------------------------------------------
void G4MPImanager::ExecuteThreadCommand(const G4String& command)