vector_mpi.hh

Go to the documentation of this file.

/*!
 *
 * Copyright (C) 2015 Technical University of Liberec.  All rights reserved.
 *
 * This program is free software; you can redistribute it and/or modify it under
 * the terms of the GNU General Public License version 3 as published by the
 * Free Software Foundation. (http://www.gnu.org/licenses/gpl-3.0.en.html)
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
 *
 *
 * @file    vector_mpi.hh
 * @brief
 */
 
#ifndef VECTOR_MPI_HH_
#define VECTOR_MPI_HH_
 
#include <vector>
#include <memory>
#include "system/system.hh"
#include "system/global_defs.h"
#include "system/index_types.hh"
 
#include <petscvec.h>
#include <armadillo>
 
/**
 * Auxiliary class for output elementwise concentration vectors
 * in convection transport, sorptions, dual porosity etc.
 *
 * Stores data in two formats:
 *  - shared pointer to std::vector of double
 *  - pointer to PETSC vector that use same data
 *
 * Allows the following functionalities:
 *  - access to local part
 *  - return shared pointer to std::vector of double
 *  - return pointer to PETSC vector
 */
class VectorMPI {
public:
    typedef typename std::vector<double> VectorData;
    typedef typename std::shared_ptr< VectorData > VectorDataPtr;
 
    VectorMPI(MPI_Comm comm = PETSC_COMM_SELF);
 
    /// Create shared pointer and PETSC vector with given size. COLLECTIVE.
    VectorMPI(unsigned int local_size, MPI_Comm comm = PETSC_COMM_WORLD);
    
    /// Create PETSc vector with ghost values whose indices are specified in @p ghost_idx.
    VectorMPI(unsigned int local_size, std::vector<LongIdx> &ghost_idx);
 
    /**
     * Helper method creating VectorMPI of given size with serial Petsc communicator.
     *
     * Method is used for better readability of code.
     */
    static VectorMPI sequential(unsigned int size);
 
    /**
     * Resize the vector to given local size. Operation is allowed only if this object is
     * a unique vector object pointing to the actual data.
     */
    void resize(unsigned int local_size);
    
    /**
     * Resize the vector to given local size with ghost values. Indices of ghost values are in ghost_idx.
     */
    void resize(unsigned int local_size, std::vector<LongIdx> &ghost_idx);
 
    /// Getter for shared pointer of output data.
    ///VectorDataPtr data_ptr()
    //{   return data_ptr_;}
 
    /// Getter for PETSC vector of output data (e.g. can be used by scatters).
    Vec &petsc_vec()
    {   return data_petsc_;}
 
    void zero_entries()
    {   chkerr(VecZeroEntries( data_petsc_ ));}
 
    //VectorData &data()
    //{
    //    ASSERT(data_ptr_);
    //    return *data_ptr_;
    //}
    
    //const VectorData &data() const
    //{
    //    ASSERT(data_ptr_);
    //    return *data_ptr_;
    //}
 
    /// Return size of output data.
    unsigned int size() const
    {
        ASSERT_PTR(data_ptr_).error("Uninitialized data vector.\n");
        return data_ptr_->size();
    }
 
    /// Return value on given position
    inline double get(unsigned int pos) const {
        ASSERT_PTR(data_ptr_).error("Uninitialized data vector.\n");
        return (*data_ptr_)[pos];
    }
 
    /// Set value on given position
    inline void set(unsigned int pos, double val) {
        ASSERT_PTR(data_ptr_).error("Uninitialized data vector.\n");
        ASSERT_LT(pos, data_ptr_->size()).error("Given 'pos' out of vector size!\n");
        (*data_ptr_)[pos] = val;
    }
 
    /// Normalize value on given position
    inline void normalize(unsigned int pos, double divisor) {
        ASSERT_PTR(data_ptr_).error("Uninitialized data vector.\n");
        ASSERT_LT(pos, data_ptr_->size()).error("Given 'pos' out of vector size!\n");
        (*data_ptr_)[pos] /= divisor;
    }
 
    /// Add value to item on given position
    inline void add(unsigned int pos, double val) {
        ASSERT_PTR(data_ptr_).error("Uninitialized data vector.\n");
        ASSERT_LT(pos, data_ptr_->size()).error("Given 'pos' out of vector size!\n");
        (*data_ptr_)[pos] += val;
    }
 
    /// Add value to item on given global position
    inline void add_global(unsigned int pos, double val) {
        ASSERT_PTR(data_ptr_).error("Uninitialized data vector.\n");
        VecSetValue(data_petsc_, pos, val, ADD_VALUES);
    }
 
 
    /// For the current vector, it creates the same parallel structure as the @p other vector has.
    /**
     * FIXME: it does not take care of ghost values, so it cannot be used in that situation.
     */
    void duplicate_from(VectorMPI other);
 
    /// Swaps the current vector data with the other vector data.
    /**
     * FIXME: it does not take care of ghost values, so it cannot be used
     */
    void swap(VectorMPI &other);
 
    /// Copies data from the @p other vector.
    /// Both vector must have the same communicator and distribution.
    void copy_from(const VectorMPI &other);
 
    
    /// local_to_ghost_{begin,end} updates the ghost values on neighbouring processors from local values
    void local_to_ghost_begin()
    {   VecGhostUpdateBegin(data_petsc_, INSERT_VALUES, SCATTER_FORWARD);}
    
    /// local_to_ghost_{begin,end} updates the ghost values on neighbouring processors from local values
    void local_to_ghost_end()
    {   VecGhostUpdateEnd(data_petsc_, INSERT_VALUES, SCATTER_FORWARD);}
    
    /// ghost_to_local_{begin,end} updates the local values by adding ghost values from neighbouring processors
    void ghost_to_local_begin()
    {   VecGhostUpdateBegin(data_petsc_, ADD_VALUES, SCATTER_REVERSE);}
    
    /// ghost_to_local_{begin,end} updates the local values by adding ghost values from neighbouring processors
    void ghost_to_local_end()
    {   VecGhostUpdateEnd(data_petsc_, ADD_VALUES, SCATTER_REVERSE);}
 
    /// Destructor.
    ~VectorMPI();
 
    /**
     * Access to the vector element on local index @p idx.
     */
//    inline double &operator[](unsigned int idx)
//    {
//        ASSERT(data_ptr_);
//        ASSERT(idx < data_ptr_->size()) (idx) (data_ptr_->size());
//        return (*data_ptr_)[idx];
//    }
    
    /**
     * Access to the vector element on local index @p idx (const version).
     */
//    inline double &operator[](unsigned int idx) const
//    {
//        ASSERT(data_ptr_);
//        ASSERT(idx < data_ptr_->size()) (idx) (data_ptr_->size());
//        return (*data_ptr_)[idx];
//    }
 
    /**
     * Access to the vector elements on local indices @p idx.
     */
    arma::vec get_subvec(const LocDofVec& loc_indices);
 
    /**
     * Access to the vector elements on local indices @p idx (const version).
     */
    arma::vec get_subvec(const LocDofVec& loc_indices) const;
 
    /**
     * Set some vector elements on local indices @p idx.
     */
    void set_subvec(const LocDofVec& loc_indices, const arma::vec& values);
private:
 
    /// shared pointer to vector of data
    VectorDataPtr data_ptr_;
    /// stored vector of data in PETSC format
    Vec data_petsc_;
    /// communicator
    MPI_Comm communicator_;
};
 
 
#endif /* VECTOR_MPI_HH_ */