ExaFMM 1
Fast-multipole Method for exascale systems
unit_test/unpartition.cxx
Go to the documentation of this file.
00001 /*
00002 Copyright (C) 2011 by Rio Yokota, Simon Layton, Lorena Barba
00003 
00004 Permission is hereby granted, free of charge, to any person obtaining a copy
00005 of this software and associated documentation files (the "Software"), to deal
00006 in the Software without restriction, including without limitation the rights
00007 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
00008 copies of the Software, and to permit persons to whom the Software is
00009 furnished to do so, subject to the following conditions:
00010 
00011 The above copyright notice and this permission notice shall be included in
00012 all copies or substantial portions of the Software.
00013 
00014 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
00015 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
00016 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
00017 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
00018 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
00019 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
00020 THE SOFTWARE.
00021 */
00022 #include "parallelfmm.h"
00023 #ifdef VTK
00024 #include "vtk.h"
00025 #endif
00026 
00027 int main() {
00028   const int numBodies = 10000;
00029   const int numTarget = 100;
00030   IMAGES = 0;
00031   THETA = 1 / sqrtf(4);
00032   Bodies bodies(numBodies);
00033   Bodies jbodies;
00034   Cells cells, jcells;
00035   ParallelFMM<Laplace> FMM;
00036   FMM.initialize();
00037   if( MPIRANK == 0 ) FMM.printNow = true;
00038 
00039   FMM.startTimer("Set bodies   ");
00040   FMM.random(bodies,MPIRANK+1);
00041   Bodies bodies2 = bodies;
00042   FMM.stopTimer("Set bodies   ",FMM.printNow);
00043 
00044   FMM.startTimer("Set domain   ");
00045   FMM.setGlobDomain(bodies2);
00046   FMM.stopTimer("Set domain   ",FMM.printNow);
00047 
00048 #ifndef VTK
00049   if( IMAGES != 0 ) {
00050     FMM.startTimer("Set periodic ");
00051     jbodies = FMM.periodicBodies(bodies2);
00052     FMM.stopTimer("Set periodic ",FMM.printNow);
00053     FMM.eraseTimer("Set periodic ");
00054   } else {
00055     jbodies = bodies2;
00056   }
00057 
00058   FMM.startTimer("Direct sum   ");
00059   bodies2.resize(numTarget);
00060   for( int i=0; i!=MPISIZE; ++i ) {
00061     FMM.shiftBodies(jbodies);
00062     FMM.evalP2P(bodies2,jbodies);
00063     if(FMM.printNow) std::cout << "Direct loop   : " << i+1 << "/" << MPISIZE << std::endl;
00064   }
00065   FMM.stopTimer("Direct sum   ",FMM.printNow);
00066   FMM.eraseTimer("Direct sum   ");
00067 #endif
00068 
00069   FMM.initTarget(bodies);
00070 
00071   FMM.octsection(bodies);
00072 
00073 #ifdef TOPDOWN
00074   FMM.topdown(bodies,cells);
00075 #else
00076   FMM.bottomup(bodies,cells);
00077 #endif
00078 
00079   FMM.commBodies(cells);
00080 
00081   jbodies = bodies;
00082   jcells = cells;
00083   FMM.commCells(jbodies,jcells);
00084 
00085   FMM.startTimer("Downward     ");
00086   FMM.downward(cells,jcells);
00087   FMM.stopTimer("Downward     ",FMM.printNow);
00088   FMM.eraseTimer("Downward     ");
00089 
00090   FMM.unpartition(bodies);
00091 
00092   FMM.startTimer("Unsort bodies");
00093   std::sort(bodies.begin(),bodies.end());
00094   FMM.stopTimer("Unsort bodies",FMM.printNow);
00095   FMM.eraseTimer("Unsort bodies");
00096   if(FMM.printNow) FMM.writeTime();
00097   if(FMM.printNow) FMM.writeTime();
00098 
00099   real diff1 = 0, norm1 = 0, diff2 = 0, norm2 = 0, diff3 = 0, norm3 = 0, diff4 = 0, norm4 = 0;
00100   bodies.resize(numTarget);
00101   FMM.evalError(bodies,bodies2,diff1,norm1,diff2,norm2);
00102   MPI_Datatype MPI_TYPE = FMM.getType(diff1);
00103   MPI_Reduce(&diff1,&diff3,1,MPI_TYPE,MPI_SUM,0,MPI_COMM_WORLD);
00104   MPI_Reduce(&norm1,&norm3,1,MPI_TYPE,MPI_SUM,0,MPI_COMM_WORLD);
00105   MPI_Reduce(&diff2,&diff4,1,MPI_TYPE,MPI_SUM,0,MPI_COMM_WORLD);
00106   MPI_Reduce(&norm2,&norm4,1,MPI_TYPE,MPI_SUM,0,MPI_COMM_WORLD);
00107   if(FMM.printNow) FMM.printError(diff3,norm3,diff4,norm4);
00108 
00109 #ifdef VTK
00110   for( B_iter B=jbodies.begin(); B!=jbodies.end(); ++B ) B->ICELL = 0;
00111   for( C_iter C=jcells.begin(); C!=jcells.end(); ++C ) {
00112     Body body;
00113     body.ICELL = 1;
00114     body.X     = C->X;
00115     body.SRC   = 0;
00116     jbodies.push_back(body);
00117   }
00118 
00119   int Ncell = 0;
00120   vtkPlot vtk;
00121   if( MPIRANK == 0 ) {
00122     vtk.setDomain(FMM.getR0(),FMM.getX0());
00123     vtk.setGroupOfPoints(jbodies,Ncell);
00124   }
00125   for( int i=1; i!=MPISIZE; ++i ) {
00126     FMM.shiftBodies(jbodies);
00127     if( MPIRANK == 0 ) {
00128       vtk.setGroupOfPoints(jbodies,Ncell);
00129     }
00130   }
00131   if( MPIRANK == 0 ) {
00132     vtk.plot(Ncell);
00133   }
00134 #endif
00135   FMM.finalize();
00136 }
 All Classes Files Functions Variables Typedefs Enumerations Enumerator Friends Defines