pvfmm.hpp 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221
  1. /**
  2. * \file pvfmm.hpp
  3. * \author Dhairya Malhotra, dhairya.malhotra@gmail.com
  4. * \date 1-2-2014
  5. * \brief This file contains wrapper functions for PvFMM.
  6. */
  7. #include <mpi.h>
  8. #include <vector>
  9. #include <cstdlib>
  10. #include <cmath>
  11. #include <pvfmm_common.hpp>
  12. #include <cheb_node.hpp>
  13. #include <mpi_node.hpp>
  14. #include <fmm_tree.hpp>
  15. #include <fmm_node.hpp>
  16. #include <fmm_cheb.hpp>
  17. #include <fmm_pts.hpp>
  18. #include <vector.hpp>
  19. #include <parUtils.h>
  20. #ifndef _PVFMM_HPP_
  21. #define _PVFMM_HPP_
  22. namespace pvfmm{
  23. typedef FMM_Node<Cheb_Node<double> > ChebFMM_Node;
  24. typedef FMM_Cheb<ChebFMM_Node> ChebFMM;
  25. typedef FMM_Tree<ChebFMM> ChebFMM_Tree;
  26. typedef ChebFMM_Node::NodeData ChebFMM_Data;
  27. typedef void (*ChebFn)(const double* , int , double*);
  28. ChebFMM_Tree* ChebFMM_CreateTree(int cheb_deg, int data_dim, ChebFn fn_ptr, std::vector<double>& trg_coord, MPI_Comm& comm,
  29. double tol=1e-6, int max_pts=100, BoundaryType bndry=FreeSpace, int init_depth=0){
  30. int np, myrank;
  31. MPI_Comm_size(comm, &np);
  32. MPI_Comm_rank(comm, &myrank);
  33. ChebFMM_Data tree_data;
  34. tree_data.cheb_deg=cheb_deg;
  35. tree_data.data_dof=data_dim;
  36. tree_data.input_fn=fn_ptr;
  37. tree_data.tol=tol;
  38. bool adap=true;
  39. tree_data.dim=COORD_DIM;
  40. tree_data.max_depth=MAX_DEPTH;
  41. tree_data.max_pts=max_pts;
  42. { // Set points for initial tree.
  43. std::vector<double> coord;
  44. size_t N=pow(8.0,init_depth);
  45. N=(N<np?np:N)*max_pts;
  46. size_t NN=ceil(pow((double)N,1.0/3.0));
  47. size_t N_total=NN*NN*NN;
  48. size_t start= myrank *N_total/np;
  49. size_t end =(myrank+1)*N_total/np;
  50. for(size_t i=start;i<end;i++){
  51. coord.push_back(((double)((i/ 1 )%NN)+0.5)/NN);
  52. coord.push_back(((double)((i/ NN )%NN)+0.5)/NN);
  53. coord.push_back(((double)((i/(NN*NN))%NN)+0.5)/NN);
  54. }
  55. tree_data.pt_coord=coord;
  56. }
  57. // Set target points.
  58. tree_data.trg_coord=trg_coord;
  59. ChebFMM_Tree* tree=new ChebFMM_Tree(comm);
  60. tree->Initialize(&tree_data);
  61. tree->InitFMM_Tree(adap,bndry);
  62. return tree;
  63. }
  64. void ChebFMM_Evaluate(ChebFMM_Tree* tree, std::vector<double>& trg_val, size_t loc_size=0){
  65. tree->RunFMM();
  66. Vector<double> trg_value;
  67. Vector<size_t> trg_scatter;
  68. {// Collect data from each node to trg_value and trg_scatter.
  69. std::vector<double> trg_value_;
  70. std::vector<size_t> trg_scatter_;
  71. std::vector<ChebFMM_Node*>& nodes=tree->GetNodeList();
  72. for(size_t i=0;i<nodes.size();i++){
  73. if(nodes[i]->IsLeaf() && !nodes[i]->IsGhost()){
  74. Vector<double>& trg_value=nodes[i]->trg_value;
  75. Vector<size_t>& trg_scatter=nodes[i]->trg_scatter;
  76. for(size_t j=0;j<trg_value.Dim();j++) trg_value_.push_back(trg_value[j]);
  77. for(size_t j=0;j<trg_scatter.Dim();j++) trg_scatter_.push_back(trg_scatter[j]);
  78. }
  79. }
  80. trg_value=trg_value_;
  81. trg_scatter=trg_scatter_;
  82. }
  83. par::ScatterReverse(trg_value,trg_scatter,*tree->Comm(),loc_size);
  84. trg_val.assign(&trg_value[0],&trg_value[0]+trg_value.Dim());;
  85. }
  86. typedef FMM_Node<MPI_Node<double> > PtFMM_Node;
  87. typedef FMM_Pts<PtFMM_Node> PtFMM;
  88. typedef FMM_Tree<PtFMM> PtFMM_Tree;
  89. typedef PtFMM_Node::NodeData PtFMM_Data;
  90. PtFMM_Tree* PtFMM_CreateTree(std::vector<double>& src_coord, std::vector<double>& src_value,
  91. std::vector<double>& surf_coord, std::vector<double>& surf_value,
  92. std::vector<double>& trg_coord, MPI_Comm& comm, int max_pts=100,
  93. BoundaryType bndry=FreeSpace, int init_depth=0){
  94. int np, myrank;
  95. MPI_Comm_size(comm, &np);
  96. MPI_Comm_rank(comm, &myrank);
  97. PtFMM_Data tree_data;
  98. bool adap=true;
  99. tree_data.dim=COORD_DIM;
  100. tree_data.max_depth=MAX_DEPTH;
  101. tree_data.max_pts=max_pts;
  102. // Set source points.
  103. tree_data. src_coord= src_coord;
  104. tree_data. src_value= src_value;
  105. tree_data.surf_coord=surf_coord;
  106. tree_data.surf_value=surf_value;
  107. // Set target points.
  108. tree_data.trg_coord=trg_coord;
  109. tree_data. pt_coord=trg_coord;
  110. PtFMM_Tree* tree=new PtFMM_Tree(comm);
  111. tree->Initialize(&tree_data);
  112. tree->InitFMM_Tree(adap,bndry);
  113. return tree;
  114. }
  115. PtFMM_Tree* PtFMM_CreateTree(std::vector<double>& src_coord, std::vector<double>& src_value,
  116. std::vector<double>& trg_coord, MPI_Comm& comm, int max_pts=100,
  117. BoundaryType bndry=FreeSpace, int init_depth=0){
  118. std::vector<double> surf_coord;
  119. std::vector<double> surf_value;
  120. return PtFMM_CreateTree(src_coord, src_value, surf_coord,surf_value, trg_coord, comm, max_pts, bndry, init_depth);
  121. }
  122. void PtFMM_Evaluate(PtFMM_Tree* tree, std::vector<double>& trg_val, size_t loc_size=0, std::vector<double>* src_val=NULL, std::vector<double>* surf_val=NULL){
  123. if(src_val){
  124. std::vector<size_t> src_scatter_;
  125. std::vector<PtFMM_Node*>& nodes=tree->GetNodeList();
  126. for(size_t i=0;i<nodes.size();i++){
  127. if(nodes[i]->IsLeaf() && !nodes[i]->IsGhost()){
  128. Vector<size_t>& src_scatter=nodes[i]->src_scatter;
  129. for(size_t j=0;j<src_scatter.Dim();j++) src_scatter_.push_back(src_scatter[j]);
  130. }
  131. }
  132. Vector<double> src_value=*src_val;
  133. Vector<size_t> src_scatter=src_scatter_;
  134. par::ScatterForward(src_value,src_scatter,*tree->Comm());
  135. size_t indx=0;
  136. for(size_t i=0;i<nodes.size();i++){
  137. if(nodes[i]->IsLeaf() && !nodes[i]->IsGhost()){
  138. Vector<double>& src_value_=nodes[i]->src_value;
  139. for(size_t j=0;j<src_value_.Dim();j++){
  140. src_value_[j]=src_value[indx];
  141. indx++;
  142. }
  143. }
  144. }
  145. }
  146. if(surf_val){
  147. std::vector<size_t> surf_scatter_;
  148. std::vector<PtFMM_Node*>& nodes=tree->GetNodeList();
  149. for(size_t i=0;i<nodes.size();i++){
  150. if(nodes[i]->IsLeaf() && !nodes[i]->IsGhost()){
  151. Vector<size_t>& surf_scatter=nodes[i]->surf_scatter;
  152. for(size_t j=0;j<surf_scatter.Dim();j++) surf_scatter_.push_back(surf_scatter[j]);
  153. }
  154. }
  155. Vector<double> surf_value=*surf_val;
  156. Vector<size_t> surf_scatter=surf_scatter_;
  157. par::ScatterForward(surf_value,surf_scatter,*tree->Comm());
  158. size_t indx=0;
  159. for(size_t i=0;i<nodes.size();i++){
  160. if(nodes[i]->IsLeaf() && !nodes[i]->IsGhost()){
  161. Vector<double>& surf_value_=nodes[i]->surf_value;
  162. for(size_t j=0;j<surf_value_.Dim();j++){
  163. surf_value_[j]=surf_value[indx];
  164. indx++;
  165. }
  166. }
  167. }
  168. }
  169. tree->RunFMM();
  170. Vector<double> trg_value;
  171. Vector<size_t> trg_scatter;
  172. {
  173. std::vector<double> trg_value_;
  174. std::vector<size_t> trg_scatter_;
  175. std::vector<PtFMM_Node*>& nodes=tree->GetNodeList();
  176. for(size_t i=0;i<nodes.size();i++){
  177. if(nodes[i]->IsLeaf() && !nodes[i]->IsGhost()){
  178. Vector<double>& trg_value=nodes[i]->trg_value;
  179. Vector<size_t>& trg_scatter=nodes[i]->trg_scatter;
  180. for(size_t j=0;j<trg_value.Dim();j++) trg_value_.push_back(trg_value[j]);
  181. for(size_t j=0;j<trg_scatter.Dim();j++) trg_scatter_.push_back(trg_scatter[j]);
  182. }
  183. }
  184. trg_value=trg_value_;
  185. trg_scatter=trg_scatter_;
  186. }
  187. par::ScatterReverse(trg_value,trg_scatter,*tree->Comm(),loc_size);
  188. trg_val.assign(&trg_value[0],&trg_value[0]+trg_value.Dim());;
  189. }
  190. }//end namespace
  191. #endif //_PVFMM_HPP_