ParallelDomainProblem.h 11.1 KB
Newer Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
// ============================================================================
// ==                                                                        ==
// == AMDiS - Adaptive multidimensional simulations                          ==
// ==                                                                        ==
// ============================================================================
// ==                                                                        ==
// ==  crystal growth group                                                  ==
// ==                                                                        ==
// ==  Stiftung caesar                                                       ==
// ==  Ludwig-Erhard-Allee 2                                                 ==
// ==  53175 Bonn                                                            ==
// ==  germany                                                               ==
// ==                                                                        ==
// ============================================================================
// ==                                                                        ==
// ==  http://www.caesar.de/cg/AMDiS                                         ==
// ==                                                                        ==
// ============================================================================

20
/** \file ParallelDomain.h */
21

22
23
#ifndef AMDIS_PARALLELDOMAIN_H
#define AMDIS_PARALLELDOMAIN_H
24
25

#include <map>
26
#include <set>
27
28
29
30
#include <vector>

#include "ProblemTimeInterface.h"
#include "ProblemIterationInterface.h"
31
#include "FiniteElemSpace.h"
32
#include "AdaptInfo.h"
Thomas Witkowski's avatar
Thomas Witkowski committed
33
#include "InteriorBoundary.h"
34
35
#include "AMDiS_fwd.h"

36
37
#include "petsc.h"
#include "petscsys.h"
38
#include "petscao.h"
39
40
41
42
43
44
#include "mpi.h"

namespace AMDiS {

  class ParMetisPartitioner;

45
  class ParallelDomainBase : public ProblemIterationInterface,
46
47
                                    public ProblemTimeInterface
  {
Thomas Witkowski's avatar
Thomas Witkowski committed
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
  private:
    /// Defines type for a vector of DOFs.
    typedef std::vector<const DegreeOfFreedom*> DofContainer;

    /// Defines a mapping type from DOFs to rank numbers.
    typedef std::map<const DegreeOfFreedom*, int> DofToRank;

    /// Defines a mapping type from DOFs to a set of rank numbers.
    typedef std::map<const DegreeOfFreedom*, std::set<int> > DofToPartitions;

    /// Defines a mapping type from rank numbers to sets of DOFs.
    typedef std::map<int, DofContainer> RankToDofContainer;

    /// Defines a mapping type from DOF indices to DOF indices.
    typedef std::map<DegreeOfFreedom, DegreeOfFreedom> DofMapping;

    /// Defines a mapping type from DOF indices to boolean values.
    typedef std::map<DegreeOfFreedom, bool> DofToBool;

67
  public:
68
    ParallelDomainBase(const std::string& name,
Thomas Witkowski's avatar
Thomas Witkowski committed
69
70
71
72
		       ProblemIterationInterface *iterationIF,
		       ProblemTimeInterface *timeIF,
		       FiniteElemSpace *feSpace,
		       RefinementManager *refineManager);
73

74
    virtual ~ParallelDomainBase() {}
75

76
    virtual void initParallelization(AdaptInfo *adaptInfo);
77

78
79
80
81
82
83
84
85
86
    void exitParallelization(AdaptInfo *adaptInfo);

    /** \brief
     * Test, if the mesh consists of macro elements only. The mesh partitioning of
     * the parallelization works for macro meshes only and would fail, if the mesh
     * is already refined in some way. Therefore, this function will exit the program
     * if it finds a non macro element in the mesh.
     */
    void testForMacroMesh();
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

    /// Set for each element on the partitioning level the number of leaf elements.
    double setElemWeights(AdaptInfo *adaptInfo);

    void partitionMesh(AdaptInfo *adaptInfo);

    virtual void setTime(AdaptInfo *adaptInfo) {}

    virtual void initTimestep(AdaptInfo *adaptInfo) {}

    virtual void closeTimestep(AdaptInfo *adaptInfo) {}

    virtual void solveInitialProblem(AdaptInfo *adaptInfo) {}
  
    virtual void transferInitialSolution(AdaptInfo *adaptInfo) {}

103
104
    virtual void beginIteration(AdaptInfo *adaptInfo) 
    {
105
106
107
      iterationIF->beginIteration(adaptInfo);
    }

108
109
    virtual Flag oneIteration(AdaptInfo *adaptInfo, Flag toDo = FULL_ITERATION) 
    {
110
111
112
      ERROR_EXIT("Not implemented!\n");
      return 0;
    }
113

114
115
    virtual void endIteration(AdaptInfo *adaptInfo) 
    {
116
117
      iterationIF->endIteration(adaptInfo);
    }
118

119
120
121
122
    virtual int getNumProblems() 
    {
      return 0;
    }
123

124
125
    inline virtual const std::string& getName() 
    { 
126
127
128
      return name; 
    }

129
    /// Returns \ref nRankDOFs, the number of DOFs in the rank mesh.
130
131
    int getNumberRankDOFs() 
    {
132
133
134
      return nRankDOFs;
    }

135
136
    void fillPetscMatrix(DOFMatrix *mat, DOFVector<double> *vec);

137
138
    void solvePetscMatrix(DOFVector<double> *vec);

139
140
141
142
    virtual ProblemStatBase *getProblem(int number = 0) 
    {
      return NULL;
    }
143
144
145
146

    virtual void serialize(std::ostream&) {}

    virtual void deserialize(std::istream&) {}
147
148
149


  protected:
150
151
152
153
    /** \brief
     * Determine the interior boundaries, i.e. boundaries between ranks, and store
     * all information about them in \ref interiorBoundary.
     */
Thomas Witkowski's avatar
Thomas Witkowski committed
154
155
    void createInteriorBoundaryInfo(DofContainer& rankDOFs,
				    DofToRank& boundaryDOFs);
156
157
158
159

    /// Removes all macro elements from the mesh that are not part of ranks partition.
    void removeMacroElements();

160
161
162
163

    /** \brief
     * Creates from a macro mesh a correct local and global DOF index numbering.
     *
Thomas Witkowski's avatar
Thomas Witkowski committed
164
     * \param[out] rankDOFs      Returns all DOFs from the macro mesh, which are owned
165
     *                           by the rank after partitioning the macro mesh.
Thomas Witkowski's avatar
Thomas Witkowski committed
166
     * \param[out] boundaryDOFs  Returns all DOFs from the macro mesh, which lies at
167
168
     *                           an interior boundary of the rank. This object maps
     *                           each such DOF to the rank that owns this DOF.
Thomas Witkowski's avatar
Thomas Witkowski committed
169
170
     * \param[out] nRankDOFs     Number of DOFs owned by rank.
     * \param[out] nOverallDOFs  Number of all DOFs in macro mesh.
171
     */
Thomas Witkowski's avatar
Thomas Witkowski committed
172
173
    void createLocalGlobalNumbering(DofContainer& rankDOFs,
				    DofToRank& boundaryDOFs,
174
175
176
177
				    int& nRankDOFs, 
				    int& nOverallDOFs);

    void updateLocalGlobalNumbering(int& nRankDOFs, int& nOverallDOFs);
178

Thomas Witkowski's avatar
Thomas Witkowski committed
179
180
181
    void addAllVertexDOFs(Element *el, int ithEdge, DofContainer& dofs);

    void addAllEdgeDOFs(Element *el, int ithEdge, DofContainer& dofs);
Thomas Witkowski's avatar
Thomas Witkowski committed
182

183
184
    /** \brief
     * This function traverses the whole mesh, i.e. before it is really partitioned,
Thomas Witkowski's avatar
Thomas Witkowski committed
185
186
187
     * and collects information about which DOF corresponds to which rank. Can only
     * be used, if \ref partitionVec is set correctly. This is only the case, when
     * the macro mesh is partitioned.
188
     *
Thomas Witkowski's avatar
Thomas Witkowski committed
189
     * \param[out] partionDOFs   Stores to each DOF pointer the set of ranks the DOF is
190
     *                           part of.
Thomas Witkowski's avatar
Thomas Witkowski committed
191
192
     * \param[out] rankDOFs      Stores all rank DOFs.
     * \param[out] boundaryDOFs  Stores all DOFs in ranks partition that are on an 
193
194
     *                           interior boundary but correspond to another rank.
     */
Thomas Witkowski's avatar
Thomas Witkowski committed
195
196
197
    void createDOFMemberInfo(DofToPartitions& partitionDOFs,
			     DofContainer& rankDOFs,
			     DofToRank& boundaryDOFs);
Thomas Witkowski's avatar
Thomas Witkowski committed
198

199
     
Thomas Witkowski's avatar
Thomas Witkowski committed
200
201
202
203
204
205
206
    /** \brief
     * This function is used for debugging only. It traverses all interior boundaries
     * and compares the dof indices on them with the dof indices of the boundarys
     * neighbours. The function fails, when dof indices on an interior boundary does
     * not fit together.
     */
    void testInteriorBoundary();
207

208
  protected:
209
210
211
212
213
214
    ///
    ProblemIterationInterface *iterationIF;

    ///
    ProblemTimeInterface *timeIF;

215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
    /// The rank of the current process.
    int mpiRank;

    /// Overall number of processes.
    int mpiSize;

    /** \brief
     * MPI communicator collected all processes, which should
     * be used for calculation. The Debug procces is not included
     * in this communicator.
     */
    MPI::Intracomm mpiComm;

    /// Name of the problem (as used in the init files)
    std::string name;

231
232
233
    /// Finite element space of the problem.
    FiniteElemSpace *feSpace;

234
235
236
    /// Mesh of the problem.
    Mesh *mesh;

237
238
239
    /// Info level.
    int info;

240
241
242
    /// Refinement manager for the mesh.
    RefinementManager *refinementManager;

243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
    /// Pointer to the paritioner which is used to devide a mesh into partitions.
    ParMetisPartitioner *partitioner;

    /// Weights for the elements, i.e., the number of leaf elements within this element.
    std::map<int, double> elemWeights;

    /// Is true, if the mesh was not partitioned before, otherwise it's false.
    bool initialPartitionMesh;

    /** \brief
     * Stores to every coarse element index the number of the partition it 
     * corresponds to.
     */
    std::map<int, int> partitionVec;

    /** \brief
     * Stores an old partitioning of elements. To every element index the number
     * of the parition it corresponds to is stored.
     */
    std::map<int, int> oldPartitionVec;    
263

264
265
266
267
    Mat petscMatrix;

    Vec petscRhsVec;
    
268
    Vec petscSolVec;
269

270
271
    /// Number of DOFs in the rank mesh.
    int nRankDOFs;
Thomas Witkowski's avatar
Thomas Witkowski committed
272

273
274
275
276
    /** \brief
     * Set of all interior boundary DOFs in ranks partition. The object maps to
     * each such DOF to the number of the rank that owns this DOF.
     */
Thomas Witkowski's avatar
Thomas Witkowski committed
277
    DofToRank boundaryDOFs;
278

Thomas Witkowski's avatar
Thomas Witkowski committed
279
    /** \brief 
Thomas Witkowski's avatar
Thomas Witkowski committed
280
281
282
283
284
285
286
287
288
289
290
291
     * Defines the interior boundaries of the domain that result from partitioning
     * the whole mesh. Contains only the boundaries, which are owned by the rank, i.e.,
     * the object gives for every neighbour rank i the boundaries this rank owns and 
     * shares with rank i.
     */
    InteriorBoundary myIntBoundary;
    
    /** \brief
     * Defines the interior boundaries of the domain that result from partitioning
     * the whole mesh. Contains only the boundaries, which are not owned by the rank,
     * i.e., the object gives for every neighbour rank i the boundaries that are
     * owned by rank i and are shared with this rank.
Thomas Witkowski's avatar
Thomas Witkowski committed
292
     */
Thomas Witkowski's avatar
Thomas Witkowski committed
293
    InteriorBoundary otherIntBoundary;
Thomas Witkowski's avatar
Thomas Witkowski committed
294

295
296
297
298
    /** \brief
     * This map contains for each rank the list of dofs the current rank must send
     * to exchange solution dofs at the interior boundaries.
     */
Thomas Witkowski's avatar
Thomas Witkowski committed
299
    RankToDofContainer sendDofs;
300
301
302
303
304

    /** \brief
     * This map contains for each rank the list of dofs from which the current rank 
     * must receive solution values of dofs at the interior boundaries.
     */
Thomas Witkowski's avatar
Thomas Witkowski committed
305
    RankToDofContainer recvDofs;
306
307

    /// Maps local to global dof indices.
Thomas Witkowski's avatar
Thomas Witkowski committed
308
    DofMapping mapLocalGlobalDOFs;
309
310

    /// Maps global to local dof indices.
Thomas Witkowski's avatar
Thomas Witkowski committed
311
    DofMapping mapGlobalLocalDOFs;
312
313
314
315
316
317

    /** \brief
     * Maps all DOFs in ranks partition to a bool value. If it is true, the DOF is
     * owned by the rank. Otherwise, its an interior boundary DOF that is owned by
     * another rank.
     */
Thomas Witkowski's avatar
Thomas Witkowski committed
318
    DofToBool isRankDOF;
319
320
  };

321
  class ParallelDomainScal : public ParallelDomainBase
322
323
  {
  public:
324
    ParallelDomainScal(const std::string& name,
325
326
327
			      ProblemScal *problem,
			      ProblemInstatScal *problemInstat);

328
329
    void initParallelization(AdaptInfo *adaptInfo);

330
331
332
    virtual Flag oneIteration(AdaptInfo *adaptInfo, Flag toDo = FULL_ITERATION);

  protected:
333
334
    /// Starts the solution of the linear system using Petsc.
    void solve();
335

336
337
338
  protected:
    /// Pointer to the stationary problem.
    ProblemScal *probScal;
339
340
341
  };
}

342
#endif // AMDIS_PARALLELDOMAIN_H