Zoltan2_TpetraCrsGraphAdapter.hpp

Go to the documentation of this file.

// @HEADER
// *****************************************************************************
//   Zoltan2: A package of combinatorial algorithms for scientific computing
//
// Copyright 2012 NTESS and the Zoltan2 contributors.
// SPDX-License-Identifier: BSD-3-Clause
// *****************************************************************************
// @HEADER

 
#ifndef _ZOLTAN2_TPETRACRSGRAPHADAPTER_HPP_
#define _ZOLTAN2_TPETRACRSGRAPHADAPTER_HPP_
 
#include <Zoltan2_PartitioningHelpers.hpp>
#include <Zoltan2_StridedData.hpp>
#include <Zoltan2_TpetraRowGraphAdapter.hpp>
#include <Zoltan2_XpetraTraits.hpp>
#include <string>
 
namespace Zoltan2 {

 
template <typename User, typename UserCoord = User>
class TpetraCrsGraphAdapter : public TpetraRowGraphAdapter<User, UserCoord> {
 
public:
#ifndef DOXYGEN_SHOULD_SKIP_THIS
  using scalar_t = typename InputTraits<User>::scalar_t;
  using offset_t = typename InputTraits<User>::offset_t;
  using lno_t = typename InputTraits<User>::lno_t;
  using gno_t = typename InputTraits<User>::gno_t;
  using part_t = typename InputTraits<User>::part_t;
  using node_t = typename InputTraits<User>::node_t;
  using user_t = User;
  using userCoord_t = UserCoord;
 
  using Base = GraphAdapter<User, UserCoord>;
  using RowGraph = TpetraRowGraphAdapter<User, UserCoord>;
#endif

 
  TpetraCrsGraphAdapter(const RCP<const User> &graph, int nVtxWeights = 0,
                        int nEdgeWeights = 0);
 
  void init(const RCP<const User> &graph);

  RCP<const User> getUserGraph() const { return this->graph_; }
 
  template <typename Adapter>
  void applyPartitioningSolution(
      const User &in, User *&out,
      const PartitioningSolution<Adapter> &solution) const;
 
  template <typename Adapter>
  void applyPartitioningSolution(
      const User &in, RCP<User> &out,
      const PartitioningSolution<Adapter> &solution) const;
};

// Definitions
 
template <typename User, typename UserCoord>
typename TpetraCrsGraphAdapter<User, UserCoord>::Base::IdsDeviceView
getColIds(const RCP<const User> &inmatrix) {
  auto colIdsDevice = inmatrix->getLocalIndicesDevice();
 
  auto colIdsGlobalDevice =
    typename TpetraCrsGraphAdapter<User, UserCoord>::Base::IdsDeviceView("colIdsGlobalDevice", colIdsDevice.extent(0));
  auto colMap = inmatrix->getColMap();
  auto lclColMap = colMap->getLocalMap();
 
  // Convert to global IDs using Tpetra::Map
  Kokkos::parallel_for("colIdsGlobalDevice",
                       Kokkos::RangePolicy<typename User::node_type::execution_space>(
                                                                                      0, colIdsGlobalDevice.extent(0)),
                       KOKKOS_LAMBDA(const int i) {
    colIdsGlobalDevice(i) =
      lclColMap.getGlobalElement(colIdsDevice(i));
  });
 
  return colIdsGlobalDevice;
}
 
 
template <typename User, typename UserCoord>
void TpetraCrsGraphAdapter<User, UserCoord>::init(const RCP<const User> &graph) {
  auto colIdsDevice = graph->getLocalIndicesDevice();
 
  auto colIdsGlobalDevice =
    typename TpetraCrsGraphAdapter<User, UserCoord>::Base::IdsDeviceView("colIdsGlobalDevice", colIdsDevice.extent(0));
  auto colMap = graph->getColMap();
  auto lclColMap = colMap->getLocalMap();
 
  // Convert to global IDs using Tpetra::Map
  Kokkos::parallel_for("colIdsGlobalDevice",
                       Kokkos::RangePolicy<typename User::node_type::execution_space>(
                                                                                      0, colIdsGlobalDevice.extent(0)),
                       KOKKOS_LAMBDA(const int i) {
    colIdsGlobalDevice(i) =
      lclColMap.getGlobalElement(colIdsDevice(i));
  });
 
  this->adjIdsDevice_ = colIdsGlobalDevice;
  this->offsDevice_ = graph->getLocalRowPtrsDevice();
}
 
template <typename User, typename UserCoord>
TpetraCrsGraphAdapter<User, UserCoord>::TpetraCrsGraphAdapter(
    const RCP<const User> &graph, int nVtxWgts, int nEdgeWgts)
    : TpetraRowGraphAdapter<User>(nVtxWgts, nEdgeWgts, graph) {
 
  this->init(graph);
 
  if (this->nWeightsPerVertex_ > 0) {
 
    this->vertexWeightsDevice_ = typename Base::WeightsDeviceView(
        "vertexWeightsDevice_", graph->getLocalNumRows(),
        this->nWeightsPerVertex_);
 
    this->vertexDegreeWeightsHost_ = typename Base::VtxDegreeHostView(
        "vertexDegreeWeightsHost_", this->nWeightsPerVertex_);
 
    for (int i = 0; i < this->nWeightsPerVertex_; ++i) {
      this->vertexDegreeWeightsHost_(i) = false;
    }
  }
 
  if (this->nWeightsPerEdge_) {
    this->edgeWeightsDevice_ = typename Base::WeightsDeviceView(
        "nWeightsPerEdge_", graph->getLocalNumRows(), this->nWeightsPerEdge_);
  }
}

template <typename User, typename UserCoord>
template <typename Adapter>
void TpetraCrsGraphAdapter<User, UserCoord>::applyPartitioningSolution(
    const User &in, User *&out,
    const PartitioningSolution<Adapter> &solution) const {
  TpetraRowGraphAdapter<User, UserCoord>::applyPartitioningSolution(in, out,
                                                                    solution);
}

template <typename User, typename UserCoord>
template <typename Adapter>
void TpetraCrsGraphAdapter<User, UserCoord>::applyPartitioningSolution(
    const User &in, RCP<User> &out,
    const PartitioningSolution<Adapter> &solution) const {
  TpetraRowGraphAdapter<User, UserCoord>::applyPartitioningSolution(in, out,
                                                                    solution);
}
 
} // namespace Zoltan2
 
#endif