inv_omp.cpp

Go to the documentation of this file.

#include "inv_omp.h"
#include "../utils/message.h"

namespace ut = utils;

/* ------------------------------------------------------------------ */

void InvOMP::execute_impl(const Vec<ShPtr<Processor>> &procs)
{
  #ifdef _OPENMP
  ut::log(
    "Max number of threads = " + std::to_string(omp_get_max_threads()));
  #endif

  Str error_msg;

  #pragma omp parallel
  {
    while (error_msg.empty())
    {
      try
      {
        bool finish_loop = true;

        for (const auto &p : procs)
        {
          /* NOTE:
            Exit the while loop when all the processors have finished
            thier computation.
          */
          finish_loop &= p->run();
        }

        if (finish_loop) break;
      }
      // NOTE: Exception must be caught in the same scope.
      catch (std::runtime_error &e)
      {
        #pragma omp critical (inv_omp)
        {
          /* NOTE:
            Older error messages might be overwritten by newer one.
          */
          error_msg = e.what();
        }

        break;
      }
    }
  }

  if (!error_msg.empty())
  {
    throw std::runtime_error(error_msg);
  }
}