Skip to content

Commit

Permalink
fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
Robadob committed Jul 21, 2023
1 parent 2475c17 commit dc399c0
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/flamegpu/simulation/CUDAEnsemble.cu
Original file line number Diff line number Diff line change
Expand Up @@ -219,13 +219,13 @@ unsigned int CUDAEnsemble::simulate(const RunPlanVector& plans) {
unsigned int err_count = 0;
if (config.mpi) {
#ifdef FLAMEGPU_ENABLE_MPI
const MPI_DATATYPE MPI_ERROR_DETAIL = detail::AbstractSimRunner::createErrorDetailMPIDatatype();
const MPI_Datatype MPI_ERROR_DETAIL = detail::AbstractSimRunner::createErrorDetailMPIDatatype();
// Setup MPISimRunners
detail::MPISimRunner** runners = static_cast<detail::MPISimRunner**>(malloc(sizeof(detail::MPISimRunner*) * TOTAL_RUNNERS));
std::vector<std::atomic<unsigned int>> err_cts(TOTAL_RUNNERS);
std::vector<std::atomic<unsigned int>> next_runs(TOTAL_RUNNERS);
for (unsigned int i = 0; i < TOTAL_RUNNERS; ++i) {
std::atomic_init(&err_ct[i], UINT_MAX);
std::atomic_init(&err_cts[i], UINT_MAX);
std::atomic_init(&next_runs[i], detail::MPISimRunner::Signal::RequestJob);
}
{
Expand Down Expand Up @@ -298,7 +298,7 @@ unsigned int CUDAEnsemble::simulate(const RunPlanVector& plans) {
unsigned int run_id = r.load();
if (run_id == detail::MPISimRunner::Signal::RunFailed) {
// Fetch error detail
AbstractSimRunner::ErrorDetail e_detail;
detail::AbstractSimRunner::ErrorDetail e_detail;
{
// log_export_mutex is treated as our protection for race conditions on err_detail
std::lock_guard<std::mutex> lck(log_export_queue_mutex);
Expand Down Expand Up @@ -393,7 +393,7 @@ unsigned int CUDAEnsemble::simulate(const RunPlanVector& plans) {
0, // int destination
EnvelopeTag::ReportError, // int tag
MPI_COMM_WORLD); // MPI_Comm communicator
runner_status = detail::MPISimRunner::Signal::RequestJob
runner_status = detail::MPISimRunner::Signal::RequestJob;
}
if (runner_status == detail::MPISimRunner::Signal::RequestJob) {
mpi_request_job:
Expand Down

0 comments on commit dc399c0

Please sign in to comment.