fopr_Wilson_eo_impl.cpp

Go to the documentation of this file.

#include "fopr_Wilson_eo_impl.h"

#include "threadManager_OpenMP.h"


const std::string Fopr_Wilson_eo::Fopr_Wilson_eo_impl::class_name
  = "Fopr_Wilson_eo_impl";

//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::init(const std::string repr)
{
  m_repr = repr;

  m_vl = CommonParameters::Vlevel();

  m_Nc  = CommonParameters::Nc();
  m_Nd  = CommonParameters::Nd();
  m_Nvc = 2 * m_Nc;
  m_Ndf = 2 * m_Nc * m_Nc;
  int Nvcd = m_Nvc * m_Nd;

  m_Nvol  = CommonParameters::Nvol();
  m_Nvol2 = m_Nvol / 2;
  m_Ndim  = CommonParameters::Ndim();

  m_Nx = CommonParameters::Nx();
  m_Ny = CommonParameters::Ny();
  m_Nz = CommonParameters::Nz();
  m_Nt = CommonParameters::Nt();

  if ((m_Nx % 2) != 0) {
    vout.crucial(m_vl, "%s: Nx must be even.\n", class_name.c_str());
    exit(EXIT_FAILURE);
  }
  m_Nx2 = m_Nx / 2;

  if ((m_Ny % 2) != 0) {
    vout.crucial(m_vl, "%s: Ny must be even.\n", class_name.c_str());
    exit(EXIT_FAILURE);
  }

  m_Nvol = CommonParameters::Nvol();
  m_Ndim = CommonParameters::Ndim();
  m_boundary.resize(m_Ndim);
  m_boundary2.resize(m_Ndim);

  m_Leo.resize(m_Ny * m_Nz * m_Nt);

  for (int t = 0; t < m_Nt; ++t) {
    for (int z = 0; z < m_Nz; ++z) {
      for (int y = 0; y < m_Ny; ++y) {
        int t2 = Communicator::ipe(3) * m_Nt + t;
        int z2 = Communicator::ipe(2) * m_Nz + z;
        int y2 = Communicator::ipe(1) * m_Ny + y;
        m_Leo[y + m_Ny * (z + m_Nz * t)] = (y2 + z2 + t2) % 2;
      }
    }
  }

  m_Ueo = new Field_G(m_Nvol, m_Ndim);

  if (m_repr == "Dirac") {
    m_gm5      = &Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5_dirac;
    m_gm5_self = &Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5_self_dirac;
    m_mult_tp  = &Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_tp_dirac;
    m_mult_tm  = &Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_tm_dirac;
  } else if (m_repr == "Chiral") {
    m_gm5      = &Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5_chiral;
    m_gm5_self = &Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5_self_chiral;
    m_mult_tp  = &Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_tp_chiral;
    m_mult_tm  = &Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_tm_chiral;
  } else {
    vout.crucial(m_vl, "%s: input repr is undefined.\n",
                 class_name.c_str());
    exit(EXIT_FAILURE);
  }

  int Nvx = m_Nvc * 2 * (m_Ny / 2) * m_Nz * m_Nt;
  vcp1_xp = new double[Nvx];
  vcp2_xp = new double[Nvx];
  vcp1_xm = new double[Nvx];
  vcp2_xm = new double[Nvx];

  int Nvy = m_Nvc * 2 * m_Nx2 * m_Nz * m_Nt;
  vcp1_yp = new double[Nvy];
  vcp2_yp = new double[Nvy];
  vcp1_ym = new double[Nvy];
  vcp2_ym = new double[Nvy];

  int Nvz = m_Nvc * 2 * m_Nx2 * m_Ny * m_Nt;
  vcp1_zp = new double[Nvz];
  vcp2_zp = new double[Nvz];
  vcp1_zm = new double[Nvz];
  vcp2_zm = new double[Nvz];

  int Nvt = m_Nvc * 2 * m_Nx2 * m_Ny * m_Nz;
  vcp1_tp = new double[Nvt];
  vcp2_tp = new double[Nvt];
  vcp1_tm = new double[Nvt];
  vcp2_tm = new double[Nvt];

  int buf_size[m_Ndim];
  buf_size[0] = sizeof(double) * m_Nvc * 2 * (m_Ny / 2) * m_Nz * m_Nt;
  buf_size[1] = sizeof(double) * m_Nvc * 2 * m_Nx2 * m_Nz * m_Nt;
  buf_size[2] = sizeof(double) * m_Nvc * 2 * m_Nx2 * m_Ny * m_Nt;
  buf_size[3] = sizeof(double) * m_Nvc * 2 * m_Nx2 * m_Ny * m_Nz;

  m_fw_send.resize(m_Ndim);
  m_fw_recv.resize(m_Ndim);
  m_bw_send.resize(m_Ndim);
  m_bw_recv.resize(m_Ndim);

  m_npe.resize(m_Ndim);
  m_npe[0] = CommonParameters::NPEx();
  m_npe[1] = CommonParameters::NPEy();
  m_npe[2] = CommonParameters::NPEz();
  m_npe[3] = CommonParameters::NPEt();

  vout.general(m_vl, "communication setup start.\n");
  Communicator::sync();

  for (int imu = 0; imu < m_Ndim; ++imu) {
    // forward
    m_fw_send[imu] = Communicator::send_init(buf_size[imu], imu, +1);
    m_fw_recv[imu] = Communicator::recv_init(buf_size[imu], imu, -1);

    // backward
    m_bw_send[imu] = Communicator::send_init(buf_size[imu], imu, -1);
    m_bw_recv[imu] = Communicator::recv_init(buf_size[imu], imu, +1);

    vout.paranoiac(m_vl, "pointer to m_fw_send[%d] = %x.\n",
                   imu, m_fw_send[imu]->ptr());
    vout.paranoiac(m_vl, "pointer to m_fw_recv[%d] = %x.\n",
                   imu, m_fw_recv[imu]->ptr());
    vout.paranoiac(m_vl, "pointer to m_bw_send[%d] = %x.\n",
                   imu, m_bw_send[imu]->ptr());
    vout.paranoiac(m_vl, "pointer to m_bw_recv[%d] = %x.\n",
                   imu, m_bw_recv[imu]->ptr());
  }
  vout.general(m_vl, "communication setup end.\n");


  m_v1.reset(Nvcd, m_Nvol2, 1);
  m_v2.reset(Nvcd, m_Nvol2, 1);
  m_w1.reset(Nvcd, m_Nvol2, 1);
  m_w2.reset(Nvcd, m_Nvol2, 1);

  setup_thread();
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::tidyup()
{
  delete m_Ueo;

  delete[]  vcp1_xp;
  delete[]  vcp2_xp;
  delete[]  vcp1_xm;
  delete[]  vcp2_xm;

  delete[]  vcp1_yp;
  delete[]  vcp2_yp;
  delete[]  vcp1_ym;
  delete[]  vcp2_ym;

  delete[]  vcp1_zp;
  delete[]  vcp2_zp;
  delete[]  vcp1_zm;
  delete[]  vcp2_zm;

  delete[]  vcp1_tp;
  delete[]  vcp2_tp;
  delete[]  vcp1_tm;
  delete[]  vcp2_tm;
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::set_parameters(
  const double kappa,
  const std::vector<int> bc)
{
  //- print input parameters
  vout.general(m_vl, "Parameters of Fopr_Wilson_eo(impl):\n");
  vout.general(m_vl, "  kappa = %8.4f\n", kappa);
  for (int mu = 0; mu < m_Ndim; ++mu) {
    vout.general(m_vl, "  boundary[%d] = %2d\n", mu, bc[mu]);
  }

  //- range check
  // NB. kappa = 0 is allowed.
  assert(bc.size() == m_Ndim);

  //- store values
  m_kappa = kappa;

  // m_boundary.resize(m_Ndim);  // already resized in init.
  for (int mu = 0; mu < m_Ndim; ++mu) {
    m_boundary[mu] = bc[mu];
  }

  // boundary condition for each node:
  for (int idir = 0; idir < m_Ndim; ++idir) {
    m_boundary2[idir] = 1.0;
    if (Communicator::ipe(idir) == 0) m_boundary2[idir] = m_boundary[idir];
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::set_config(Field *U)
{
  int Ndim = CommonParameters::Ndim();
  int Nvol = CommonParameters::Nvol();

  m_index.convertField(*m_Ueo, *U);

  m_U = m_Ueo;
}


//====================================================================
double Fopr_Wilson_eo::Fopr_Wilson_eo_impl::flop_count()
{
  // The following counting explicitly depends on the implementation
  // and to be recalculated when the code is modified.
  // Present counting is based on rev.1107. [24 Aug 2014 H.Matsufuru]

  int    Lvol = CommonParameters::Lvol();
  double flop_site, flop;

  if (m_repr == "Dirac") {
    flop_site = static_cast<double>(
      m_Nc * m_Nd * (6 * (4 * m_Nc + 2) + 2 * (4 * m_Nc + 1)));
  } else if (m_repr == "Chiral") {
    flop_site = static_cast<double>(
      m_Nc * m_Nd * 8 * (4 * m_Nc + 2));
  } else {
    vout.crucial(m_vl, "%s: input repr is undefined.\n",
                 class_name.c_str());
    exit(EXIT_FAILURE);
  }

  flop = flop_site * static_cast<double>(Lvol / 2);

  return flop;
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::prePropD(Field& Be, Field& bo,
                                                   const Field& b)
{
  int Nin = b.nin();
  int Nex = b.nex();

  Field be(Nin, m_Nvol2, Nex);

  m_index.convertField(be, b, 0);
  m_index.convertField(bo, b, 1);

  Be.reset(Nin, m_Nvol2, Nex);

  //  Be = be - (Field)Meo(bo, 0);
  Field_F v1(m_Nvol2, Nex);
  copy(Be, be);
  Meo(v1, bo, 0);
  axpy(Be, -1.0, v1);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::postPropD(Field& x,
                                                    const Field& xe, const Field& bo)
{
  int Nin = xe.nin();
  int Nex = xe.nex();

  Field xo(Nin, m_Nvol2, Nex);

  //  xo = bo - (Field)Meo(xe, 1);
  Field_F v1(m_Nvol2, Nex);

  copy(xo, bo);
  Meo(v1, xe, 1);
  axpy(xo, -1.0, v1);

  x.reset(Nin, m_Nvol2 * 2, Nex);
  m_index.reverseField(x, xe, 0);
  m_index.reverseField(x, xo, 1);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::prePropDag(Field& Be,
                                                     Field& bo, const Field& b)
{
  int Nin = b.nin();
  int Nex = b.nex();

  Field be(Nin, m_Nvol2, Nex);

  m_index.convertField(be, b, 0);
  m_index.convertField(bo, b, 1);

  Be.reset(Nin, m_Nvol2, Nex);

  //  Be = be - (Field)Mdageo(bo, 0);
  Field_F v1(m_Nvol2, Nex);
  copy(Be, be);
  Mdageo(v1, bo, 0);
  axpy(Be, -1.0, v1);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::postPropDag(Field& x,
                                                      const Field& xe, const Field& bo)
{
  int Nin = xe.nin();
  int Nex = xe.nex();

  Field xo(Nin, m_Nvol2, Nex);

  //  xo = bo - (Field)Mdageo(xe, 1);
  Field_F v1(m_Nvol2, Nex);

  copy(xo, bo);
  Mdageo(v1, xe, 1);
  axpy(xo, -1.0, v1);

  x.reset(Nin, m_Nvol2 * 2, Nex);
  m_index.reverseField(x, xe, 0);
  m_index.reverseField(x, xo, 1);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::D(Field& v, const Field& f)
{
  assert(f.nex() == 1);

  Meo(m_v1, f, 1);
  Meo(v, m_v1, 0);
  aypx(-1.0, v, f);
#pragma omp barrier
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::Ddag(Field& v, const Field& f)
{
  Mdageo(m_v1, f, 1);
  Mdageo(v, m_v1, 0);
  aypx(-1.0, v, f);
#pragma omp barrier
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::DdagD(Field& v, const Field& f)
{
  D(m_w1, f);
  Ddag(v, m_w1);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::DDdag(Field& v, const Field& f)
{
  Ddag(m_w1, f);
  D(v, m_w1);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::H(Field& v, const Field& f)
{
  D(v, f);
  mult_gm5(v);
#pragma omp barrier
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::MeoMoe(Field& v, const Field& f)
{
  Meo(m_w1, f, 1);
  Meo(m_w2, m_w1, 0);
  axpy(v, -1.0, m_w2);
#pragma omp barrier
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::Meo(Field& w,
                                              const Field& f, const int ieo)
{
#pragma omp barrier

  //  clear_impl(w);  //  w = 0.0;
  w.set(0.0);  //  w = 0.0;

  //  for (int mu = 0; mu < m_Ndim; ++mu) {
  //    mult_p(mu, w, f, ieo);
  //    mult_m(mu, w, f, ieo);
  //  }

  mult_xp(w, f, ieo);
  mult_xm(w, f, ieo);

  mult_yp(w, f, ieo);
  mult_ym(w, f, ieo);

  mult_zp(w, f, ieo);
  mult_zm(w, f, ieo);

  (this->*m_mult_tp)(w, f, ieo);
  (this->*m_mult_tm)(w, f, ieo);

  scal(w, -m_kappa);   //  w *= -m_kappa;  using Field function.
  //  scal_impl(w, -m_kappa);   //  w *= -m_kappa;

  ThreadManager_OpenMP::sync_barrier_all();
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::Mdageo(Field& w,
                                                 const Field& f, const int ieo)
{
  //  Field_F v(m_Nvol2, f.nex());
  //  mult_gm5(v, (Field)f);
  //  Meo_gm5(w, v, ieo);

  mult_gm5(m_v2, f);
  Meo(w, m_v2, ieo);
  mult_gm5(w);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::Meo_gm5(Field& v,
                                                  const Field& f, const int ieo)
{
  Meo(v, f, ieo);
  mult_gm5(v);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_gm5(Field& w, const Field& f)
{
  (this->*m_gm5)(w, f);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_gm5(Field& w)
{
  (this->*m_gm5_self)(w);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5_dirac(Field& w,
                                                    const Field& f)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    gm5_dirac_thread(i, v2, v1);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5_chiral(Field& w,
                                                     const Field& f)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    gm5_chiral_thread(i, v2, v1);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5_self_dirac(Field& w)
{
  double *wp = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    gm5_dirac_thread(i, wp);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5_self_chiral(Field& w)
{
  double *wp = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    gm5_chiral_thread(i, wp);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::gm5p(const int mu, Field& w,
                                               const Field& f)
{
  // this function is probably not to be used.
  // determines  \gamma_5 * (1 - \gamma_\mu) v(x+\hat{x})
  exit(EXIT_FAILURE);
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_p(int mu,
                                                 Field_F& w, const Field_F& f,
                                                 const int ieo)
{
  if (mu == 0) {
    mult_xp(w, f, ieo);
  } else if (mu == 1) {
    mult_yp(w, f, ieo);
  } else if (mu == 2) {
    mult_zp(w, f, ieo);
  } else if (mu == 3) {
    mult_tp_dirac(w, f, ieo);
  } else {
    vout.crucial(m_vl, "%s: illegal value of mu: %d",
                 class_name.c_str(), mu);
    exit(EXIT_FAILURE);
  }
}


//=====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_m(int mu,
                                                 Field_F& w, const Field_F& f,
                                                 const int ieo)
{
  if (mu == 0) {
    mult_xm(w, f, ieo);
  } else if (mu == 1) {
    mult_ym(w, f, ieo);
  } else if (mu == 2) {
    mult_zm(w, f, ieo);
  } else if (mu == 3) {
    mult_tm_dirac(w, f, ieo);
  } else {
    vout.crucial(m_vl, "%s: illegal value of mu: %d",
                 class_name.c_str(), mu);
    exit(EXIT_FAILURE);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::clear_impl(Field& w)
{
  double *wp = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    clear_thread(i, wp);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::scal_impl(Field& w, double a)
{
  double *wp = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    scal_thread(i, wp, a);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_xp(Field& w,
                                                  const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_xp1_thread(i, vcp1_xp, v1, ieo);
  }
#pragma omp barrier

  /*
#pragma omp master
 {
  int Nv = m_Nvc * 2 * (m_Ny/2) * m_Nz * m_Nt;
  Communicator::exchange(Nv, vcp2_xp, vcp1_xp, 0, 1, 1);
 }

#pragma omp barrier
  */
  for (int i = is; i < is + ns; ++i) {
    mult_xpb_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_xp2_thread(i, v2, vcp2_xp, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_xm(Field& w,
                                                  const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_xm1_thread(i, vcp1_xm, v1, ieo);
  }

#pragma omp barrier

  /*
#pragma omp master
  {
  int Nv = m_Nvc * 2 * (m_Ny/2) * m_Nz * m_Nt;
  Communicator::exchange(Nv, vcp2_xm, vcp1_xm, 0, -1, 2);
  }

#pragma omp barrier
  */
  for (int i = is; i < is + ns; ++i) {
    mult_xmb_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_xm2_thread(i, v2, vcp2_xm, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_yp(Field& w,
                                                  const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_yp1_thread(i, vcp1_yp, v1, ieo);
  }

#pragma omp barrier

  /*
#pragma omp master
 {
  int Nv = m_Nvc * 2 * m_Nx2 * m_Nz * m_Nt;
  Communicator::exchange(Nv, vcp2_yp, vcp1_yp, 1, 1, 3);
 }

#pragma omp barrier
  */
  for (int i = is; i < is + ns; ++i) {
    mult_ypb_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_yp2_thread(i, v2, vcp2_yp, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_ym(Field& w,
                                                  const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_ym1_thread(i, vcp1_ym, v1, ieo);
  }

#pragma omp barrier

  /*
#pragma omp master
  {
  int Nv = m_Nvc * 2 * m_Nx2 * m_Nz * m_Nt;
  Communicator::exchange(Nv, vcp2_ym, vcp1_ym, 1, -1, 4);
  }
#pragma omp barrier
  */

  for (int i = is; i < is + ns; ++i) {
    mult_ymb_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_ym2_thread(i, v2, vcp2_ym, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_zp(Field& w,
                                                  const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_zp1_thread(i, vcp1_zp, v1, ieo);
  }

#pragma omp barrier

  /*
#pragma omp master
 {
  int Nv = m_Nvc * 2 * m_Nx2 * m_Ny * m_Nt;
  Communicator::exchange(Nv, vcp2_zp, vcp1_zp, 2, 1, 5);
 }

#pragma omp barrier
  */
  for (int i = is; i < is + ns; ++i) {
    mult_zpb_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_zp2_thread(i, v2, vcp2_zp, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_zm(Field& w,
                                                  const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_zm1_thread(i, vcp1_zm, v1, ieo);
  }

#pragma omp barrier

  /*
#pragma omp master
  {
  int Nv = m_Nvc * 2 * m_Nx2 * m_Ny * m_Nt;
  Communicator::exchange(Nv, vcp2_zm, vcp1_zm, 2, -1, 6);
  }

#pragma omp barrier
  */
  for (int i = is; i < is + ns; ++i) {
    mult_zmb_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_zm2_thread(i, v2, vcp2_zm, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_tp_dirac(Field& w,
                                                        const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_tp1_dirac_thread(i, vcp1_tp, v1, ieo);
  }

#pragma omp barrier

#pragma omp master
  {
    int Nv = m_Nvc * 2 * m_Nx2 * m_Ny * m_Nz;
    Communicator::exchange(Nv, vcp2_tp, vcp1_tp, 3, 1, 7);
  }

#pragma omp barrier

  for (int i = is; i < is + ns; ++i) {
    mult_tpb_dirac_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_tp2_dirac_thread(i, v2, vcp2_tp, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_tm_dirac(Field& w,
                                                        const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_tm1_dirac_thread(i, vcp1_tm, v1, ieo);
  }

#pragma omp barrier

#pragma omp master
  {
    int Nv = m_Nvc * 2 * m_Nx2 * m_Ny * m_Nz;
    Communicator::exchange(Nv, vcp2_tm, vcp1_tm, 3, -1, 8);
  }

#pragma omp barrier

  for (int i = is; i < is + ns; ++i) {
    mult_tmb_dirac_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_tm2_dirac_thread(i, v2, vcp2_tm, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_tp_chiral(Field& w,
                                                         const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_tp1_chiral_thread(i, vcp1_tp, v1, ieo);
  }

#pragma omp barrier

  /*
#pragma omp master
 {
  int Nv = m_Nvc * 2 * m_Nx2 * m_Ny * m_Nz;
  Communicator::exchange(Nv, vcp2_tp, vcp1_tp, 3, 1, 7);
 }

#pragma omp barrier
  */
  for (int i = is; i < is + ns; ++i) {
    mult_tpb_chiral_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_tp2_chiral_thread(i, v2, vcp2_tp, ieo);
  }
}


//====================================================================
void Fopr_Wilson_eo::Fopr_Wilson_eo_impl::mult_tm_chiral(Field& w,
                                                         const Field& f, const int ieo)
{
  const double *v1 = f.ptr(0);
  double       *v2 = w.ptr(0);

  int nth = ThreadManager_OpenMP::get_num_threads();
  int ith = ThreadManager_OpenMP::get_thread_id();

  int is = m_Ntask * ith / nth;
  int ns = m_Ntask * (ith + 1) / nth - is;

  for (int i = is; i < is + ns; ++i) {
    mult_tm1_chiral_thread(i, vcp1_tm, v1, ieo);
  }

#pragma omp barrier

  /*
#pragma omp master
  {
  int Nv = m_Nvc * 2 * m_Nx2 * m_Ny * m_Nz;
  Communicator::exchange(Nv, vcp2_tm, vcp1_tm, 3, -1, 8);
  }

#pragma omp barrier
  */
  for (int i = is; i < is + ns; ++i) {
    mult_tmb_chiral_thread(i, v2, v1, ieo);
  }

  for (int i = is; i < is + ns; ++i) {
    mult_tm2_chiral_thread(i, v2, vcp2_tm, ieo);
  }
}


//====================================================================
//============================================================END=====