fmm_cheb.txx 41 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092
  1. /**
  2. * \file fmm_cheb.txx
  3. * \author Dhairya Malhotra, dhairya.malhotra@gmail.com
  4. * \date 3-07-2011
  5. * \brief This file contains the implementation of the FMM_Cheb class.
  6. */
  7. #include <omp.h>
  8. #include <sstream>
  9. #include <iostream>
  10. #include <cstdlib>
  11. #include <cmath>
  12. #ifdef PVFMM_HAVE_SYS_STAT_H
  13. #include <sys/stat.h>
  14. #endif
  15. #include <dtypes.h>
  16. #include <parUtils.h>
  17. #include <cheb_utils.hpp>
  18. #include <mem_mgr.hpp>
  19. #include <profile.hpp>
  20. namespace pvfmm{
  21. template <class FMMNode>
  22. FMM_Cheb<FMMNode>::~FMM_Cheb() {
  23. if(this->mat!=NULL){
  24. int rank;
  25. MPI_Comm_rank(this->comm,&rank);
  26. if(!rank){
  27. FILE* f=fopen(this->mat_fname.c_str(),"r");
  28. if(f==NULL) { //File does not exists.
  29. { // Delete easy to compute matrices.
  30. Mat_Type type=W_Type;
  31. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  32. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  33. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  34. M.Resize(0,0);
  35. }
  36. type=V_Type;
  37. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  38. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  39. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  40. M.Resize(0,0);
  41. }
  42. type=V1_Type;
  43. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  44. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  45. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  46. M.Resize(0,0);
  47. }
  48. type=U2U_Type;
  49. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  50. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  51. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  52. M.Resize(0,0);
  53. }
  54. type=D2D_Type;
  55. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  56. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  57. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  58. M.Resize(0,0);
  59. }
  60. type=D2T_Type;
  61. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  62. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  63. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  64. M.Resize(0,0);
  65. }
  66. }
  67. this->mat->Save2File(this->mat_fname.c_str());
  68. }else fclose(f);
  69. }
  70. }
  71. }
  72. template <class FMMNode>
  73. void FMM_Cheb<FMMNode>::Initialize(int mult_order, int cheb_deg_, const MPI_Comm& comm_, const Kernel<Real_t>* kernel_){
  74. Profile::Tic("InitFMM_Cheb",&comm_,true);{
  75. int rank;
  76. MPI_Comm_rank(comm_,&rank);
  77. int dim=3; //Only supporting 3D
  78. cheb_deg=cheb_deg_;
  79. if(this->mat_fname.size()==0){
  80. std::stringstream st;
  81. st<<PVFMM_PRECOMP_DATA_PATH;
  82. if(!st.str().size()){ // look in PVFMM_DIR
  83. char* pvfmm_dir = getenv ("PVFMM_DIR");
  84. if(pvfmm_dir) st<<pvfmm_dir;
  85. }
  86. #ifndef STAT_MACROS_BROKEN
  87. if(st.str().size()){ // check if the path is a directory
  88. struct stat stat_buff;
  89. if(stat(st.str().c_str(), &stat_buff) || !S_ISDIR(stat_buff.st_mode)){
  90. std::cout<<"error: path not found: "<<st.str()<<'\n';
  91. exit(0);
  92. }
  93. }
  94. #endif
  95. if(st.str().size()) st<<'/';
  96. st<<"Precomp_"<<kernel_->ker_name.c_str()<<"_q"<<cheb_deg<<"_m"<<mult_order;
  97. if(sizeof(Real_t)==8) st<<"";
  98. else if(sizeof(Real_t)==4) st<<"_f";
  99. else st<<"_t"<<sizeof(Real_t);
  100. st<<".data";
  101. this->mat_fname=st.str();
  102. }
  103. if(!rank){
  104. FILE* f=fopen(this->mat_fname.c_str(),"r");
  105. if(f==NULL) { //File does not exists.
  106. std::cout<<"Could not find precomputed data file for "<<kernel_->ker_name.c_str()<<" kernel with q="<<cheb_deg<<" and m="<<mult_order<<".\n";
  107. std::cout<<"This data will be computed and stored for future use at:\n"<<this->mat_fname<<'\n';
  108. std::cout<<"This may take a while...\n";
  109. }else fclose(f);
  110. }
  111. //this->mat->LoadFile(this->mat_fname.c_str(), this->comm);
  112. FMM_Pts<FMMNode>::Initialize(mult_order, comm_, kernel_);
  113. this->mat->RelativeTrgCoord()=cheb_nodes<Real_t>(ChebDeg(),dim);
  114. Profile::Tic("PrecompD2T",&this->comm,false,4);
  115. this->PrecompAll(D2T_Type);
  116. Profile::Toc();
  117. //Volume solver.
  118. Profile::Tic("PrecompS2M",&this->comm,false,4);
  119. this->PrecompAll(S2U_Type);
  120. Profile::Toc();
  121. Profile::Tic("PrecompX",&this->comm,false,4);
  122. this->PrecompAll(X_Type);
  123. Profile::Toc();
  124. Profile::Tic("PrecompW",&this->comm,false,4);
  125. this->PrecompAll(W_Type);
  126. Profile::Toc();
  127. Profile::Tic("PrecompU0",&this->comm,false,4);
  128. this->PrecompAll(U0_Type);
  129. Profile::Toc();
  130. Profile::Tic("PrecompU1",&this->comm,false,4);
  131. this->PrecompAll(U1_Type);
  132. Profile::Toc();
  133. Profile::Tic("PrecompU2",&this->comm,false,4);
  134. this->PrecompAll(U2_Type);
  135. Profile::Toc();
  136. Profile::Tic("Save2File",&this->comm,false,4);
  137. if(!rank){
  138. FILE* f=fopen(this->mat_fname.c_str(),"r");
  139. if(f==NULL) { //File does not exists.
  140. { // Delete easy to compute matrices.
  141. Mat_Type type=W_Type;
  142. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  143. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  144. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  145. M.Resize(0,0);
  146. }
  147. type=V_Type;
  148. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  149. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  150. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  151. M.Resize(0,0);
  152. }
  153. type=V1_Type;
  154. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  155. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  156. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  157. M.Resize(0,0);
  158. }
  159. type=U2U_Type;
  160. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  161. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  162. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  163. M.Resize(0,0);
  164. }
  165. type=D2D_Type;
  166. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  167. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  168. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  169. M.Resize(0,0);
  170. }
  171. type=D2T_Type;
  172. for(int l=-BC_LEVELS;l<MAX_DEPTH;l++)
  173. for(size_t indx=0;indx<this->interac_list.ListCount(type);indx++){
  174. Matrix<Real_t>& M=this->mat->Mat(l, type, indx);
  175. M.Resize(0,0);
  176. }
  177. }
  178. this->mat->Save2File(this->mat_fname.c_str());
  179. }else fclose(f);
  180. }
  181. Profile::Toc();
  182. Profile::Tic("Recompute",&this->comm,false,4);
  183. { // Recompute matrices.
  184. this->PrecompAll(W_Type);
  185. this->PrecompAll(V_Type);
  186. this->PrecompAll(V1_Type);
  187. this->PrecompAll(U2U_Type);
  188. this->PrecompAll(D2D_Type);
  189. this->PrecompAll(D2T_Type);
  190. }
  191. Profile::Toc();
  192. }Profile::Toc();
  193. }
  194. template <class Real_t>
  195. Permutation<Real_t> cheb_perm(size_t q, size_t p_indx, const Permutation<Real_t>& ker_perm, const Vector<Real_t>* scal_exp=NULL){
  196. int dim=3; //Only supporting 3D
  197. int dof=ker_perm.Dim();
  198. int coeff_cnt=((q+1)*(q+2)*(q+3))/6;
  199. int n3=pvfmm::pow<unsigned int>(q+1,dim);
  200. Permutation<Real_t> P0(n3*dof);
  201. if(scal_exp && p_indx==Scaling){ // Set level-by-level scaling
  202. assert(dof==scal_exp->Dim());
  203. Vector<Real_t> scal(scal_exp->Dim());
  204. for(size_t i=0;i<scal.Dim();i++){
  205. scal[i]=pvfmm::pow<Real_t>(2.0,(*scal_exp)[i]);
  206. }
  207. for(int j=0;j<dof;j++){
  208. for(int i=0;i<n3;i++){
  209. P0.scal[j*n3+i]*=scal[j];
  210. }
  211. }
  212. }
  213. { // Set P0.scal
  214. for(int j=0;j<dof;j++){
  215. for(int i=0;i<n3;i++){
  216. P0.scal[j*n3+i]*=ker_perm.scal[j];
  217. }
  218. }
  219. }
  220. if(p_indx==ReflecX || p_indx==ReflecY || p_indx==ReflecZ){
  221. for(int j=0;j<dof;j++)
  222. for(int i=0;i<n3;i++){
  223. size_t x[3]={i%(q+1), (i/(q+1))%(q+1), i/(q+1)/(q+1)};
  224. P0.scal[i+n3*j]*=(x[p_indx-ReflecX]%2?-1.0:1.0);
  225. }
  226. }
  227. { // Set P0.perm
  228. int indx[3]={0,1,2};
  229. if(p_indx==SwapXY) {indx[0]=1; indx[1]=0; indx[2]=2;}
  230. if(p_indx==SwapXZ) {indx[0]=2; indx[1]=1; indx[2]=0;}
  231. for(int j=0;j<dof;j++)
  232. for(int i=0;i<n3;i++){
  233. size_t x[3]={i%(q+1), (i/(q+1))%(q+1), i/(q+1)/(q+1)};
  234. P0.perm[i+n3*j]=x[indx[0]]+(x[indx[1]]+x[indx[2]]*(q+1))*(q+1)
  235. +n3*ker_perm.perm[j];
  236. }
  237. }
  238. std::vector<size_t> coeff_map(n3*dof,0);
  239. {
  240. int indx=0;
  241. for(int j=0;j<dof;j++)
  242. for(int i=0;i<n3;i++){
  243. size_t x[3]={i%(q+1), (i/(q+1))%(q+1), i/(q+1)/(q+1)};
  244. if(x[0]+x[1]+x[2]<=q){
  245. coeff_map[i+n3*j]=indx;
  246. indx++;
  247. }
  248. }
  249. }
  250. Permutation<Real_t> P=Permutation<Real_t>(coeff_cnt*dof);
  251. {
  252. int indx=0;
  253. for(int j=0;j<dof;j++)
  254. for(int i=0;i<n3;i++){
  255. size_t x[3]={i%(q+1), (i/(q+1))%(q+1), i/(q+1)/(q+1)};
  256. if(x[0]+x[1]+x[2]<=q){
  257. P.perm[indx]=coeff_map[P0.perm[i+n3*j]];
  258. P.scal[indx]= P0.scal[i+n3*j] ;
  259. indx++;
  260. }
  261. }
  262. }
  263. return P;
  264. }
  265. template <class FMMNode>
  266. Permutation<typename FMMNode::Real_t>& FMM_Cheb<FMMNode>::PrecompPerm(Mat_Type type, Perm_Type perm_indx){
  267. //int dim=3; //Only supporting 3D
  268. Real_t eps=1e-10;
  269. //Check if the matrix already exists.
  270. Permutation<Real_t>& P_ = FMM_Pts<FMMNode>::PrecompPerm(type, perm_indx);
  271. if(P_.Dim()!=0) return P_;
  272. size_t q=cheb_deg;
  273. size_t m=this->MultipoleOrder();
  274. size_t p_indx=perm_indx % C_Perm;
  275. //Compute the matrix.
  276. Permutation<Real_t> P;
  277. switch (type){
  278. case S2U_Type:
  279. {
  280. Vector<Real_t> scal_exp;
  281. Permutation<Real_t> ker_perm;
  282. if(perm_indx<C_Perm){
  283. ker_perm=this->kernel->k_s2m->perm_vec[0 +p_indx];
  284. scal_exp=this->kernel->k_s2m->src_scal;
  285. for(size_t i=0;i<scal_exp.Dim();i++) scal_exp[i]-=COORD_DIM;
  286. P=cheb_perm(q, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  287. }else{
  288. ker_perm=this->kernel->k_m2m->perm_vec[0 +p_indx];
  289. scal_exp=this->kernel->k_m2m->src_scal;
  290. for(size_t i=0;i<scal_exp.Dim();i++) scal_exp[i]=-scal_exp[i];
  291. // Check that target perm for the two kernels agree.
  292. Permutation<Real_t> ker_perm0=this->kernel->k_s2m->perm_vec[C_Perm+p_indx];
  293. Permutation<Real_t> ker_perm1=this->kernel->k_m2m->perm_vec[C_Perm+p_indx];
  294. assert(ker_perm0.Dim()==ker_perm1.Dim());
  295. if(ker_perm0.Dim()>0 && pvfmm::fabs<Real_t>(ker_perm0.scal[0]-ker_perm1.scal[0])>eps){
  296. for(size_t i=0;i<ker_perm0.Dim();i++){
  297. ker_perm0.scal[i]*=-1.0;
  298. }
  299. for(size_t i=0;i<ker_perm.Dim();i++){
  300. ker_perm.scal[i]*=-1.0;
  301. }
  302. }
  303. for(size_t i=0;i<ker_perm0.Dim();i++){
  304. assert( (ker_perm0.perm[i]-ker_perm1.perm[i])== 0);
  305. assert(pvfmm::fabs<Real_t>(ker_perm0.scal[i]-ker_perm1.scal[i])<eps);
  306. }
  307. Real_t s=0;
  308. // Check that target scaling for the two kernels agree.
  309. const Vector<Real_t>& scal_exp0=this->kernel->k_s2m->trg_scal;
  310. const Vector<Real_t>& scal_exp1=this->kernel->k_m2m->trg_scal;
  311. assert(scal_exp0.Dim()>0 && scal_exp0.Dim()==scal_exp1.Dim());
  312. if(scal_exp0.Dim()>0){
  313. s=(scal_exp0[0]-scal_exp1[0]);
  314. for(size_t i=1;i<scal_exp0.Dim();i++){
  315. assert(pvfmm::fabs<Real_t>(s-(scal_exp0[i]-scal_exp1[i]))<eps);
  316. // In general this is not necessary, but to allow this, we must
  317. // also change src_scal accordingly.
  318. }
  319. }
  320. // Apply the difference in scaling of the two kernels.
  321. for(size_t i=0;i<scal_exp.Dim();i++) scal_exp[i]+=s;
  322. P=equiv_surf_perm(m, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  323. }
  324. break;
  325. }
  326. case D2T_Type:
  327. {
  328. Vector<Real_t> scal_exp;
  329. Permutation<Real_t> ker_perm;
  330. if(perm_indx<C_Perm){ // Source permutation
  331. ker_perm=this->kernel->k_l2l->perm_vec[C_Perm+p_indx];
  332. scal_exp=this->kernel->k_l2l->trg_scal;
  333. for(size_t i=0;i<scal_exp.Dim();i++) scal_exp[i]=-scal_exp[i];
  334. // Check that source perm for the two kernels agree.
  335. Permutation<Real_t> ker_perm0=this->kernel->k_l2t->perm_vec[0 +p_indx];
  336. Permutation<Real_t> ker_perm1=this->kernel->k_l2l->perm_vec[0 +p_indx];
  337. assert(ker_perm0.Dim()==ker_perm1.Dim());
  338. if(ker_perm0.Dim()>0 && pvfmm::fabs<Real_t>(ker_perm0.scal[0]-ker_perm1.scal[0])>eps){
  339. for(size_t i=0;i<ker_perm0.Dim();i++){
  340. ker_perm0.scal[i]*=-1.0;
  341. }
  342. for(size_t i=0;i<ker_perm.Dim();i++){
  343. ker_perm.scal[i]*=-1.0;
  344. }
  345. }
  346. for(size_t i=0;i<ker_perm0.Dim();i++){
  347. assert( (ker_perm0.perm[i]-ker_perm1.perm[i])== 0);
  348. assert(pvfmm::fabs<Real_t>(ker_perm0.scal[i]-ker_perm1.scal[i])<eps);
  349. }
  350. Real_t s=0;
  351. // Check that source scaling for the two kernels agree.
  352. const Vector<Real_t>& scal_exp0=this->kernel->k_l2t->src_scal;
  353. const Vector<Real_t>& scal_exp1=this->kernel->k_l2l->src_scal;
  354. assert(scal_exp0.Dim()>0 && scal_exp0.Dim()==scal_exp1.Dim());
  355. if(scal_exp0.Dim()>0){
  356. s=(scal_exp0[0]-scal_exp1[0]);
  357. for(size_t i=1;i<scal_exp0.Dim();i++){
  358. assert(pvfmm::fabs<Real_t>(s-(scal_exp0[i]-scal_exp1[i]))<eps);
  359. // In general this is not necessary, but to allow this, we must
  360. // also change trg_scal accordingly.
  361. }
  362. }
  363. // Apply the difference in scaling of the two kernels.
  364. for(size_t i=0;i<scal_exp.Dim();i++) scal_exp[i]+=s;
  365. P=equiv_surf_perm(m, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  366. }else{ // Target permutation
  367. ker_perm=this->kernel->k_l2t->perm_vec[C_Perm+p_indx];
  368. scal_exp=this->kernel->k_l2t->trg_scal;
  369. P=cheb_perm(q, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  370. }
  371. break;
  372. }
  373. case U0_Type:
  374. {
  375. Vector<Real_t> scal_exp;
  376. Permutation<Real_t> ker_perm;
  377. if(perm_indx<C_Perm){
  378. ker_perm=this->kernel->k_s2t->perm_vec[0 +p_indx];
  379. scal_exp=this->kernel->k_s2t->src_scal;
  380. for(size_t i=0;i<scal_exp.Dim();i++) scal_exp[i]-=COORD_DIM;
  381. }else{
  382. ker_perm=this->kernel->k_s2t->perm_vec[C_Perm+p_indx];
  383. scal_exp=this->kernel->k_s2t->trg_scal;
  384. }
  385. P=cheb_perm(q, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  386. break;
  387. }
  388. case U1_Type:
  389. {
  390. P=PrecompPerm(U0_Type, perm_indx);
  391. break;
  392. }
  393. case U2_Type:
  394. {
  395. P=PrecompPerm(U0_Type, perm_indx);
  396. break;
  397. }
  398. case W_Type:
  399. {
  400. Vector<Real_t> scal_exp;
  401. Permutation<Real_t> ker_perm;
  402. if(perm_indx<C_Perm){ // Source permutation
  403. ker_perm=this->kernel->k_m2t->perm_vec[0 +p_indx];
  404. scal_exp=this->kernel->k_m2t->src_scal;
  405. P=equiv_surf_perm(m, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  406. }else{ // Target permutation
  407. ker_perm=this->kernel->k_m2t->perm_vec[C_Perm+p_indx];
  408. scal_exp=this->kernel->k_m2t->trg_scal;
  409. P=cheb_perm(q, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  410. }
  411. break;
  412. }
  413. case X_Type:
  414. {
  415. Vector<Real_t> scal_exp;
  416. Permutation<Real_t> ker_perm;
  417. if(perm_indx<C_Perm){
  418. ker_perm=this->kernel->k_s2l->perm_vec[0 +p_indx];
  419. scal_exp=this->kernel->k_s2l->src_scal;
  420. for(size_t i=0;i<scal_exp.Dim();i++) scal_exp[i]-=COORD_DIM;
  421. P=cheb_perm(q, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  422. }else{
  423. ker_perm=this->kernel->k_s2l->perm_vec[C_Perm+p_indx];
  424. scal_exp=this->kernel->k_s2l->trg_scal;
  425. P=equiv_surf_perm(m, p_indx, ker_perm, (this->ScaleInvar()?&scal_exp:NULL));
  426. }
  427. break;
  428. }
  429. default:
  430. return FMM_Pts<FMMNode>::PrecompPerm(type, perm_indx);
  431. break;
  432. }
  433. //Save the matrix for future use.
  434. #pragma omp critical (PRECOMP_MATRIX_PTS)
  435. if(P_.Dim()==0){ P_=P;}
  436. return P_;
  437. }
  438. template <class FMMNode>
  439. Matrix<typename FMMNode::Real_t>& FMM_Cheb<FMMNode>::Precomp(int level, Mat_Type type, size_t mat_indx){
  440. if(this->ScaleInvar()) level=0;
  441. //Check if the matrix already exists.
  442. //Compute matrix from symmetry class (if possible).
  443. Matrix<Real_t>& M_ = this->mat->Mat(level, type, mat_indx);
  444. if(M_.Dim(0)!=0 && M_.Dim(1)!=0) return M_;
  445. else{ //Compute matrix from symmetry class (if possible).
  446. size_t class_indx = this->interac_list.InteracClass(type, mat_indx);
  447. if(class_indx!=mat_indx){
  448. Matrix<Real_t>& M0 = this->Precomp(level, type, class_indx);
  449. Permutation<Real_t>& Pr = this->interac_list.Perm_R(level, type, mat_indx);
  450. Permutation<Real_t>& Pc = this->interac_list.Perm_C(level, type, mat_indx);
  451. if(Pr.Dim()>0 && Pc.Dim()>0 && M0.Dim(0)>0 && M0.Dim(1)>0) return M_;
  452. }
  453. }
  454. int myrank, np;
  455. MPI_Comm_rank(this->comm, &myrank);
  456. MPI_Comm_size(this->comm,&np);
  457. size_t progress=0, class_count=0;
  458. { // Determine precomputation progress.
  459. size_t mat_cnt=this->interac_list.ListCount((Mat_Type)type);
  460. for(size_t i=0; i<mat_cnt; i++){
  461. size_t indx=this->interac_list.InteracClass((Mat_Type)type,i);
  462. if(indx==i){
  463. class_count++;
  464. if(i<mat_indx) progress++;
  465. }
  466. }
  467. }
  468. //Compute the matrix.
  469. Matrix<Real_t> M;
  470. int n_src=((cheb_deg+1)*(cheb_deg+2)*(cheb_deg+3))/6;
  471. switch (type){
  472. case S2U_Type:
  473. {
  474. if(this->MultipoleOrder()==0) break;
  475. Real_t r=pvfmm::pow<Real_t>(0.5,level);
  476. Real_t c[3]={0,0,0};
  477. // Coord of upward check surface
  478. std::vector<Real_t> uc_coord=u_check_surf(this->MultipoleOrder(),c,level);
  479. size_t n_uc=uc_coord.size()/3;
  480. // Evaluate potential at check surface.
  481. Matrix<Real_t> M_s2c(n_src*this->kernel->k_s2m->ker_dim[0],n_uc*this->kernel->k_s2m->ker_dim[1]); //source 2 check
  482. Matrix<Real_t> M_s2c_local(n_src*this->kernel->k_s2m->ker_dim[0],n_uc*this->kernel->k_s2m->ker_dim[1]);
  483. {
  484. M_s2c.SetZero();
  485. M_s2c_local.SetZero();
  486. size_t cnt_done=0;
  487. #pragma omp parallel for schedule(dynamic)
  488. for(size_t i=myrank;i<n_uc;i+=np){
  489. std::vector<Real_t> M_=cheb_integ(cheb_deg, &uc_coord[i*3], r, *this->kernel->k_s2m);
  490. #ifdef __VERBOSE__
  491. #pragma omp critical
  492. if(!myrank){
  493. cnt_done++;
  494. std::cout<<"\r Progress: "<<(100*progress*n_uc+100*cnt_done*np)/(class_count*n_uc)<<"% "<<std::flush;
  495. }
  496. #endif
  497. for(int k=0; k<this->kernel->k_s2m->ker_dim[1]; k++)
  498. for(size_t j=0; j<(size_t)M_s2c.Dim(0); j++)
  499. M_s2c_local[j][i*this->kernel->k_s2m->ker_dim[1]+k] = M_[j+k*M_s2c.Dim(0)];
  500. }
  501. if(!myrank) std::cout<<"\r \r"<<std::flush;
  502. MPI_Allreduce(M_s2c_local[0], M_s2c[0], M_s2c.Dim(0)*M_s2c.Dim(1), par::Mpi_datatype<Real_t>::value(), par::Mpi_datatype<Real_t>::sum(), this->comm);
  503. }
  504. Matrix<Real_t>& M_c2e0 = this->Precomp(level, UC2UE0_Type, 0);
  505. Matrix<Real_t>& M_c2e1 = this->Precomp(level, UC2UE1_Type, 0);
  506. M=(M_s2c*M_c2e0)*M_c2e1;
  507. break;
  508. }
  509. case D2T_Type:
  510. {
  511. if(this->MultipoleOrder()==0) break;
  512. Matrix<Real_t>& M_s2t=FMM_Pts<FMMNode>::Precomp(level, type, mat_indx);
  513. int n_trg=M_s2t.Dim(1)/this->kernel->k_l2t->ker_dim[1];
  514. // Compute Chebyshev approx from target potential.
  515. M.Resize(M_s2t.Dim(0), n_src*this->kernel->k_l2t->ker_dim [1]);
  516. #pragma omp parallel for schedule(dynamic)
  517. for(size_t j=0; j<(size_t)M_s2t.Dim(0); j++){
  518. Matrix<Real_t> M_trg(n_trg,this->kernel->k_l2t->ker_dim[1],M_s2t[j],false);
  519. M_trg=M_trg.Transpose();
  520. cheb_approx<Real_t,Real_t>(M_s2t[j],cheb_deg,this->kernel->k_l2t->ker_dim[1],M[j]);
  521. }
  522. #pragma omp critical (PRECOMP_MATRIX_PTS)
  523. {
  524. M_s2t.Resize(0,0);
  525. }
  526. break;
  527. }
  528. case U0_Type:
  529. {
  530. // Coord of target points
  531. Real_t s=pvfmm::pow<Real_t>(0.5,level);
  532. int* coord=this->interac_list.RelativeCoord(type,mat_indx);
  533. Real_t coord_diff[3]={(Real_t)((coord[0]-1)*s*0.5),(Real_t)((coord[1]-1.0)*s*0.5),(Real_t)((coord[2]-1.0)*s*0.5)};
  534. std::vector<Real_t>& rel_trg_coord = this->mat->RelativeTrgCoord();
  535. size_t n_trg = rel_trg_coord.size()/3;
  536. std::vector<Real_t> trg_coord(n_trg*3);
  537. for(size_t j=0;j<n_trg;j++){
  538. trg_coord[j*3+0]=rel_trg_coord[j*3+0]*s-coord_diff[0];
  539. trg_coord[j*3+1]=rel_trg_coord[j*3+1]*s-coord_diff[1];
  540. trg_coord[j*3+2]=rel_trg_coord[j*3+2]*s-coord_diff[2];
  541. }
  542. // Evaluate potential at target points.
  543. Matrix<Real_t> M_s2t(n_src*this->kernel->k_s2t->ker_dim [0], n_trg*this->kernel->k_s2t->ker_dim [1]);
  544. Matrix<Real_t> M_s2t_local(n_src*this->kernel->k_s2t->ker_dim [0], n_trg*this->kernel->k_s2t->ker_dim [1]);
  545. {
  546. M_s2t.SetZero();
  547. M_s2t_local.SetZero();
  548. size_t cnt_done=0;
  549. #pragma omp parallel for schedule(dynamic)
  550. for(size_t i=myrank;i<n_trg;i+=np){
  551. std::vector<Real_t> s2t=cheb_integ(cheb_deg, &trg_coord[i*3], (Real_t)(s*2.0), *this->kernel->k_s2t);
  552. #ifdef __VERBOSE__
  553. #pragma omp critical
  554. if(!myrank){
  555. cnt_done++;
  556. std::cout<<"\r Progress: "<<(100*progress*n_trg+100*cnt_done*np)/(class_count*n_trg)<<"% "<<std::flush;
  557. }
  558. #endif
  559. for(int k=0; k<this->kernel->k_s2t->ker_dim[1]; k++)
  560. for(size_t j=0; j<(size_t)M_s2t.Dim(0); j++)
  561. M_s2t_local[j][i*this->kernel->k_s2t->ker_dim[1]+k] = s2t[j+k*M_s2t.Dim(0)];
  562. }
  563. if(!myrank) std::cout<<"\r \r"<<std::flush;
  564. MPI_Allreduce(M_s2t_local[0], M_s2t[0], M_s2t.Dim(0)*M_s2t.Dim(1), par::Mpi_datatype<Real_t>::value(), par::Mpi_datatype<Real_t>::sum(), this->comm);
  565. }
  566. // Compute Chebyshev approx from target potential.
  567. M.Resize(M_s2t.Dim(0), n_src*this->kernel->k_s2t->ker_dim [1]);
  568. #pragma omp parallel for schedule(dynamic)
  569. for(size_t j=0; j<(size_t)M_s2t.Dim(0); j++){
  570. Matrix<Real_t> M_trg(n_trg,this->kernel->k_s2t->ker_dim[1],M_s2t[j],false);
  571. M_trg=M_trg.Transpose();
  572. cheb_approx<Real_t,Real_t>(M_s2t[j],cheb_deg,this->kernel->k_s2t->ker_dim[1],M[j]);
  573. }
  574. break;
  575. }
  576. case U1_Type:
  577. {
  578. // Coord of target points
  579. Real_t s=pvfmm::pow<Real_t>(0.5,level);
  580. int* coord=this->interac_list.RelativeCoord(type,mat_indx);
  581. Real_t coord_diff[3]={coord[0]*s,coord[1]*s,coord[2]*s};
  582. std::vector<Real_t>& rel_trg_coord = this->mat->RelativeTrgCoord();
  583. size_t n_trg = rel_trg_coord.size()/3;
  584. std::vector<Real_t> trg_coord(n_trg*3);
  585. for(size_t j=0;j<n_trg;j++){
  586. trg_coord[j*3+0]=rel_trg_coord[j*3+0]*s-coord_diff[0];
  587. trg_coord[j*3+1]=rel_trg_coord[j*3+1]*s-coord_diff[1];
  588. trg_coord[j*3+2]=rel_trg_coord[j*3+2]*s-coord_diff[2];
  589. }
  590. // Evaluate potential at target points.
  591. Matrix<Real_t> M_s2t(n_src*this->kernel->k_s2t->ker_dim [0], n_trg*this->kernel->k_s2t->ker_dim [1]);
  592. Matrix<Real_t> M_s2t_local(n_src*this->kernel->k_s2t->ker_dim [0], n_trg*this->kernel->k_s2t->ker_dim [1]);
  593. {
  594. M_s2t.SetZero();
  595. M_s2t_local.SetZero();
  596. size_t cnt_done=0;
  597. #pragma omp parallel for schedule(dynamic)
  598. for(size_t i=myrank;i<n_trg;i+=np){
  599. std::vector<Real_t> s2t=cheb_integ(cheb_deg, &trg_coord[i*3], s, *this->kernel->k_s2t);
  600. #ifdef __VERBOSE__
  601. #pragma omp critical
  602. if(!myrank){
  603. cnt_done++;
  604. std::cout<<"\r Progress: "<<(100*progress*n_trg+100*cnt_done*np)/(class_count*n_trg)<<"% "<<std::flush;
  605. }
  606. #endif
  607. for(int k=0; k<this->kernel->k_s2t->ker_dim[1]; k++)
  608. for(size_t j=0; j<(size_t)M_s2t.Dim(0); j++)
  609. M_s2t_local[j][i*this->kernel->k_s2t->ker_dim[1]+k] = s2t[j+k*M_s2t.Dim(0)];
  610. }
  611. if(!myrank) std::cout<<"\r \r"<<std::flush;
  612. MPI_Allreduce(M_s2t_local[0], M_s2t[0], M_s2t.Dim(0)*M_s2t.Dim(1), par::Mpi_datatype<Real_t>::value(), par::Mpi_datatype<Real_t>::sum(), this->comm);
  613. }
  614. // Compute Chebyshev approx from target potential.
  615. M.Resize(M_s2t.Dim(0), n_src*this->kernel->k_s2t->ker_dim [1]);
  616. #pragma omp parallel for schedule(dynamic)
  617. for(size_t j=0; j<(size_t)M_s2t.Dim(0); j++){
  618. Matrix<Real_t> M_trg(n_trg,this->kernel->k_s2t->ker_dim[1],M_s2t[j],false);
  619. M_trg=M_trg.Transpose();
  620. cheb_approx<Real_t,Real_t>(M_s2t[j],cheb_deg,this->kernel->k_s2t->ker_dim[1],M[j]);
  621. }
  622. break;
  623. }
  624. case U2_Type:
  625. {
  626. // Coord of target points
  627. Real_t s=pvfmm::pow<Real_t>(0.5,level);
  628. int* coord=this->interac_list.RelativeCoord(type,mat_indx);
  629. Real_t coord_diff[3]={(Real_t)((coord[0]+1)*s*0.25),(Real_t)((coord[1]+1)*s*0.25),(Real_t)((coord[2]+1)*s*0.25)};
  630. std::vector<Real_t>& rel_trg_coord = this->mat->RelativeTrgCoord();
  631. size_t n_trg = rel_trg_coord.size()/3;
  632. std::vector<Real_t> trg_coord(n_trg*3);
  633. for(size_t j=0;j<n_trg;j++){
  634. trg_coord[j*3+0]=rel_trg_coord[j*3+0]*s-coord_diff[0];
  635. trg_coord[j*3+1]=rel_trg_coord[j*3+1]*s-coord_diff[1];
  636. trg_coord[j*3+2]=rel_trg_coord[j*3+2]*s-coord_diff[2];
  637. }
  638. // Evaluate potential at target points.
  639. Matrix<Real_t> M_s2t(n_src*this->kernel->k_s2t->ker_dim [0], n_trg*this->kernel->k_s2t->ker_dim [1]);
  640. Matrix<Real_t> M_s2t_local(n_src*this->kernel->k_s2t->ker_dim [0], n_trg*this->kernel->k_s2t->ker_dim [1]);
  641. {
  642. M_s2t.SetZero();
  643. M_s2t_local.SetZero();
  644. size_t cnt_done=0;
  645. #pragma omp parallel for schedule(dynamic)
  646. for(size_t i=myrank;i<n_trg;i+=np){
  647. std::vector<Real_t> s2t=cheb_integ(cheb_deg, &trg_coord[i*3], (Real_t)(s*0.5), *this->kernel->k_s2t);
  648. #ifdef __VERBOSE__
  649. #pragma omp critical
  650. if(!myrank){
  651. cnt_done++;
  652. std::cout<<"\r Progress: "<<(100*progress*n_trg+100*cnt_done*np)/(class_count*n_trg)<<"% "<<std::flush;
  653. }
  654. #endif
  655. for(int k=0; k<this->kernel->k_s2t->ker_dim[1]; k++)
  656. for(size_t j=0; j<(size_t)M_s2t.Dim(0); j++)
  657. M_s2t_local[j][i*this->kernel->k_s2t->ker_dim[1]+k] = s2t[j+k*M_s2t.Dim(0)];
  658. }
  659. if(!myrank) std::cout<<"\r \r"<<std::flush;
  660. MPI_Allreduce(M_s2t_local[0], M_s2t[0], M_s2t.Dim(0)*M_s2t.Dim(1), par::Mpi_datatype<Real_t>::value(), par::Mpi_datatype<Real_t>::sum(), this->comm);
  661. }
  662. // Compute Chebyshev approx from target potential.
  663. M.Resize(M_s2t.Dim(0), n_src*this->kernel->k_s2t->ker_dim [1]);
  664. #pragma omp parallel for schedule(dynamic)
  665. for(size_t j=0; j<(size_t)M_s2t.Dim(0); j++){
  666. Matrix<Real_t> M_trg(n_trg,this->kernel->k_s2t->ker_dim[1],M_s2t[j],false);
  667. M_trg=M_trg.Transpose();
  668. cheb_approx<Real_t,Real_t>(M_s2t[j],cheb_deg,this->kernel->k_s2t->ker_dim[1],M[j]);
  669. }
  670. break;
  671. }
  672. case W_Type:
  673. {
  674. if(this->MultipoleOrder()==0) break;
  675. Matrix<Real_t>& M_s2t=FMM_Pts<FMMNode>::Precomp(level, type, mat_indx);
  676. int n_trg=M_s2t.Dim(1)/this->kernel->k_m2t->ker_dim[1];
  677. // Compute Chebyshev approx from target potential.
  678. M.Resize(M_s2t.Dim(0), n_src*this->kernel->k_m2t->ker_dim [1]);
  679. #pragma omp parallel for schedule(dynamic)
  680. for(size_t j=0; j<(size_t)M_s2t.Dim(0); j++){
  681. Matrix<Real_t> M_trg(n_trg,this->kernel->k_m2t->ker_dim[1],M_s2t[j],false);
  682. M_trg=M_trg.Transpose();
  683. cheb_approx<Real_t,Real_t>(M_s2t[j],cheb_deg,this->kernel->k_m2t->ker_dim[1],M[j]);
  684. }
  685. #pragma omp critical (PRECOMP_MATRIX_PTS)
  686. {
  687. M_s2t.Resize(0,0);
  688. }
  689. break;
  690. }
  691. case X_Type:
  692. {
  693. if(this->MultipoleOrder()==0) break;
  694. // Coord of target points
  695. Real_t s=pvfmm::pow<Real_t>(0.5,level-1);
  696. int* coord=this->interac_list.RelativeCoord(type,mat_indx);
  697. Real_t c[3]={-(Real_t)((coord[0]-1)*s*0.25),-(Real_t)((coord[1]-1)*s*0.25),-(Real_t)((coord[2]-1)*s*0.25)};
  698. std::vector<Real_t> trg_coord=d_check_surf(this->MultipoleOrder(),c,level);
  699. size_t n_trg=trg_coord.size()/3;
  700. // Evaluate potential at target points.
  701. Matrix<Real_t> M_xs2c(n_src*this->kernel->k_s2l->ker_dim[0], n_trg*this->kernel->k_s2l->ker_dim[1]);
  702. Matrix<Real_t> M_xs2c_local(n_src*this->kernel->k_s2l->ker_dim[0], n_trg*this->kernel->k_s2l->ker_dim[1]);
  703. {
  704. M_xs2c.SetZero();
  705. M_xs2c_local.SetZero();
  706. size_t cnt_done=0;
  707. #pragma omp parallel for schedule(dynamic)
  708. for(size_t i=myrank;i<n_trg;i+=np){
  709. std::vector<Real_t> M_=cheb_integ(cheb_deg, &trg_coord[i*3], s, *this->kernel->k_s2l);
  710. #ifdef __VERBOSE__
  711. #pragma omp critical
  712. if(!myrank){
  713. cnt_done++;
  714. std::cout<<"\r Progress: "<<(100*progress*n_trg+100*cnt_done*np)/(class_count*n_trg)<<"% "<<std::flush;
  715. }
  716. #endif
  717. for(int k=0; k<this->kernel->k_s2l->ker_dim[1]; k++)
  718. for(size_t j=0; j<(size_t)M_xs2c.Dim(0); j++)
  719. M_xs2c_local[j][i*this->kernel->k_s2l->ker_dim[1]+k] = M_[j+k*M_xs2c.Dim(0)];
  720. }
  721. if(!myrank) std::cout<<"\r \r"<<std::flush;
  722. MPI_Allreduce(M_xs2c_local[0], M_xs2c[0], M_xs2c.Dim(0)*M_xs2c.Dim(1), par::Mpi_datatype<Real_t>::value(), par::Mpi_datatype<Real_t>::sum(), this->comm);
  723. }
  724. M=M_xs2c;
  725. break;
  726. }
  727. default:
  728. {
  729. return FMM_Pts<FMMNode>::Precomp(level, type, mat_indx);
  730. break;
  731. }
  732. }
  733. //Save the matrix for future use.
  734. #pragma omp critical (PRECOMP_MATRIX_PTS)
  735. if(M_.Dim(0)==0 && M_.Dim(1)==0){ M_=M;}
  736. return M_;
  737. }
  738. template <class FMMNode>
  739. void FMM_Cheb<FMMNode>::CollectNodeData(FMMTree_t* tree, std::vector<FMMNode*>& node, std::vector<Matrix<Real_t> >& buff, std::vector<Vector<FMMNode_t*> >& n_list, std::vector<std::vector<Vector<Real_t>* > > vec_list){
  740. if(vec_list.size()<6) vec_list.resize(6);
  741. size_t n_coeff=(cheb_deg+1)*(cheb_deg+2)*(cheb_deg+3)/6;
  742. if(node.size()==0) return;
  743. {// 4. cheb_in
  744. int indx=4;
  745. size_t vec_sz=this->kernel->ker_dim[0]*n_coeff;
  746. for(size_t i=0;i<node.size();i++){
  747. if(node[i]->IsLeaf()){
  748. Vector<Real_t>& data_vec=node[i]->ChebData();
  749. if(data_vec.Dim()!=vec_sz) data_vec.ReInit(vec_sz);
  750. vec_list[indx].push_back(&data_vec);
  751. }else{
  752. node[i]->ChebData().ReInit(0);
  753. }
  754. }
  755. }
  756. {// 5. cheb_out
  757. int indx=5;
  758. size_t vec_sz=this->kernel->ker_dim[1]*n_coeff;
  759. for(size_t i=0;i<node.size();i++){
  760. if(node[i]->IsLeaf() && !node[i]->IsGhost()){
  761. Vector<Real_t>& data_vec=((FMMData*)node[i]->FMMData())->cheb_out;
  762. if(data_vec.Dim()!=vec_sz) data_vec.ReInit(vec_sz);
  763. vec_list[indx].push_back(&data_vec);
  764. }else{
  765. ((FMMData*)node[i]->FMMData())->cheb_out.ReInit(0);
  766. }
  767. }
  768. }
  769. { // Set pt_cnt
  770. size_t m=this->MultipoleOrder();
  771. size_t Nsrf=(6*(m-1)*(m-1)+2);
  772. #pragma omp parallel for
  773. for(size_t i=0;i<node.size();i++){
  774. node[i]->pt_cnt[0]+=2*Nsrf;
  775. node[i]->pt_cnt[1]+=2*Nsrf;
  776. }
  777. }
  778. FMM_Pts<FMMNode_t>::CollectNodeData(tree, node, buff, n_list, vec_list);
  779. }
  780. template <class FMMNode>
  781. void FMM_Cheb<FMMNode>::Source2UpSetup(SetupData<Real_t>& setup_data, FMMTree_t* tree, std::vector<Matrix<Real_t> >& buff, std::vector<Vector<FMMNode_t*> >& n_list, int level, bool device){
  782. if(!this->MultipoleOrder()) return;
  783. FMM_Pts<FMMNode>::Source2UpSetup(setup_data, tree, buff, n_list, level, device);
  784. { // Set setup_data
  785. setup_data.level=level;
  786. setup_data.kernel=this->kernel->k_s2m;
  787. setup_data.interac_type.resize(1);
  788. setup_data.interac_type[0]=S2U_Type;
  789. setup_data. input_data=&buff[4];
  790. setup_data.output_data=&buff[0];
  791. Vector<FMMNode_t*>& nodes_in =n_list[4];
  792. Vector<FMMNode_t*>& nodes_out=n_list[0];
  793. setup_data.nodes_in .clear();
  794. setup_data.nodes_out.clear();
  795. for(size_t i=0;i<nodes_in .Dim();i++) if(nodes_in [i]->Depth()==level || level==-1) setup_data.nodes_in .push_back(nodes_in [i]);
  796. for(size_t i=0;i<nodes_out.Dim();i++) if(nodes_out[i]->Depth()==level || level==-1) setup_data.nodes_out.push_back(nodes_out[i]);
  797. }
  798. std::vector<void*>& nodes_in =setup_data.nodes_in ;
  799. std::vector<void*>& nodes_out=setup_data.nodes_out;
  800. std::vector<Vector<Real_t>*>& input_vector=setup_data. input_vector; input_vector.clear();
  801. std::vector<Vector<Real_t>*>& output_vector=setup_data.output_vector; output_vector.clear();
  802. for(size_t i=0;i<nodes_in .size();i++) input_vector.push_back(&( ((FMMNode*)nodes_in [i]) )->ChebData() );
  803. for(size_t i=0;i<nodes_out.size();i++) output_vector.push_back(&((FMMData*)((FMMNode*)nodes_out[i])->FMMData())->upward_equiv);
  804. this->SetupInterac(setup_data,device);
  805. }
  806. template <class FMMNode>
  807. void FMM_Cheb<FMMNode>::Source2Up (SetupData<Real_t>& setup_data, bool device){
  808. if(!this->MultipoleOrder()) return;
  809. //Add Source2Up contribution.
  810. FMM_Pts<FMMNode>::Source2Up(setup_data, device);
  811. this->EvalList(setup_data, device);
  812. }
  813. template <class FMMNode>
  814. void FMM_Cheb<FMMNode>::X_ListSetup(SetupData<Real_t>& setup_data, FMMTree_t* tree, std::vector<Matrix<Real_t> >& buff, std::vector<Vector<FMMNode_t*> >& n_list, int level, bool device){
  815. if(!this->MultipoleOrder()) return;
  816. FMM_Pts<FMMNode>::X_ListSetup(setup_data, tree, buff, n_list, level, device);
  817. { // Set setup_data
  818. setup_data.level=level;
  819. setup_data.kernel=this->kernel->k_s2l;
  820. setup_data.interac_type.resize(1);
  821. setup_data.interac_type[0]=X_Type;
  822. setup_data. input_data=&buff[4];
  823. setup_data.output_data=&buff[1];
  824. Vector<FMMNode_t*>& nodes_in =n_list[4];
  825. Vector<FMMNode_t*>& nodes_out=n_list[1];
  826. setup_data.nodes_in .clear();
  827. setup_data.nodes_out.clear();
  828. for(size_t i=0;i<nodes_in .Dim();i++) if(nodes_in [i]->Depth()==level-1 || level==-1) setup_data.nodes_in .push_back(nodes_in [i]);
  829. for(size_t i=0;i<nodes_out.Dim();i++) if(nodes_out[i]->Depth()==level || level==-1) setup_data.nodes_out.push_back(nodes_out[i]);
  830. }
  831. std::vector<void*>& nodes_in =setup_data.nodes_in ;
  832. std::vector<void*>& nodes_out=setup_data.nodes_out;
  833. std::vector<Vector<Real_t>*>& input_vector=setup_data. input_vector; input_vector.clear();
  834. std::vector<Vector<Real_t>*>& output_vector=setup_data.output_vector; output_vector.clear();
  835. for(size_t i=0;i<nodes_in .size();i++) input_vector.push_back(&( ((FMMNode*)nodes_in [i]) )->ChebData() );
  836. for(size_t i=0;i<nodes_out.size();i++) output_vector.push_back(&((FMMData*)((FMMNode*)nodes_out[i])->FMMData())->dnward_equiv);
  837. this->SetupInterac(setup_data,device);
  838. { // Resize device buffer
  839. size_t n=setup_data.output_data->Dim(0)*setup_data.output_data->Dim(1)*sizeof(Real_t);
  840. if(this->dev_buffer.Dim()<n) this->dev_buffer.ReInit(n);
  841. }
  842. }
  843. template <class FMMNode>
  844. void FMM_Cheb<FMMNode>::X_List (SetupData<Real_t>& setup_data, bool device){
  845. if(!this->MultipoleOrder()) return;
  846. //Add X_List contribution.
  847. FMM_Pts<FMMNode>::X_List(setup_data, device);
  848. this->EvalList(setup_data, device);
  849. }
  850. template <class FMMNode>
  851. void FMM_Cheb<FMMNode>::W_ListSetup(SetupData<Real_t>& setup_data, FMMTree_t* tree, std::vector<Matrix<Real_t> >& buff, std::vector<Vector<FMMNode_t*> >& n_list, int level, bool device){
  852. if(!this->MultipoleOrder()) return;
  853. { // Set setup_data
  854. setup_data.level=level;
  855. setup_data.kernel=this->kernel->k_m2t;
  856. setup_data.interac_type.resize(1);
  857. setup_data.interac_type[0]=W_Type;
  858. setup_data. input_data=&buff[0];
  859. setup_data.output_data=&buff[5];
  860. Vector<FMMNode_t*>& nodes_in =n_list[0];
  861. Vector<FMMNode_t*>& nodes_out=n_list[5];
  862. setup_data.nodes_in .clear();
  863. setup_data.nodes_out.clear();
  864. for(size_t i=0;i<nodes_in .Dim();i++) if(nodes_in [i]->Depth()==level+1 || level==-1) setup_data.nodes_in .push_back(nodes_in [i]);
  865. for(size_t i=0;i<nodes_out.Dim();i++) if(nodes_out[i]->Depth()==level || level==-1) setup_data.nodes_out.push_back(nodes_out[i]);
  866. }
  867. std::vector<void*>& nodes_in =setup_data.nodes_in ;
  868. std::vector<void*>& nodes_out=setup_data.nodes_out;
  869. std::vector<Vector<Real_t>*>& input_vector=setup_data. input_vector; input_vector.clear();
  870. std::vector<Vector<Real_t>*>& output_vector=setup_data.output_vector; output_vector.clear();
  871. for(size_t i=0;i<nodes_in .size();i++) input_vector.push_back(&((FMMData*)((FMMNode*)nodes_in [i])->FMMData())->upward_equiv);
  872. for(size_t i=0;i<nodes_out.size();i++) output_vector.push_back(&((FMMData*)((FMMNode*)nodes_out[i])->FMMData())->cheb_out );
  873. this->SetupInterac(setup_data,device);
  874. { // Resize device buffer
  875. size_t n=setup_data.output_data->Dim(0)*setup_data.output_data->Dim(1)*sizeof(Real_t);
  876. if(this->dev_buffer.Dim()<n) this->dev_buffer.ReInit(n);
  877. }
  878. }
  879. template <class FMMNode>
  880. void FMM_Cheb<FMMNode>::W_List (SetupData<Real_t>& setup_data, bool device){
  881. if(!this->MultipoleOrder()) return;
  882. //Add W_List contribution.
  883. this->EvalList(setup_data, device);
  884. }
  885. template <class FMMNode>
  886. void FMM_Cheb<FMMNode>::U_ListSetup(SetupData<Real_t>& setup_data, FMMTree_t* tree, std::vector<Matrix<Real_t> >& buff, std::vector<Vector<FMMNode_t*> >& n_list, int level, bool device){
  887. FMM_Pts<FMMNode>::U_ListSetup(setup_data, tree, buff, n_list, level, device);
  888. { // Set setup_data
  889. setup_data.level=level;
  890. setup_data.kernel=this->kernel->k_s2t;
  891. setup_data.interac_type.resize(3);
  892. setup_data.interac_type[0]=U0_Type;
  893. setup_data.interac_type[1]=U1_Type;
  894. setup_data.interac_type[2]=U2_Type;
  895. setup_data. input_data=&buff[4];
  896. setup_data.output_data=&buff[5];
  897. Vector<FMMNode_t*>& nodes_in =n_list[4];
  898. Vector<FMMNode_t*>& nodes_out=n_list[5];
  899. setup_data.nodes_in .clear();
  900. setup_data.nodes_out.clear();
  901. for(size_t i=0;i<nodes_in .Dim();i++) if((level-1<=nodes_in [i]->Depth() && nodes_in [i]->Depth()<=level+1) || level==-1) setup_data.nodes_in .push_back(nodes_in [i]);
  902. for(size_t i=0;i<nodes_out.Dim();i++) if(( nodes_out[i]->Depth()==level ) || level==-1) setup_data.nodes_out.push_back(nodes_out[i]);
  903. }
  904. std::vector<void*>& nodes_in =setup_data.nodes_in ;
  905. std::vector<void*>& nodes_out=setup_data.nodes_out;
  906. std::vector<Vector<Real_t>*>& input_vector=setup_data. input_vector; input_vector.clear();
  907. std::vector<Vector<Real_t>*>& output_vector=setup_data.output_vector; output_vector.clear();
  908. for(size_t i=0;i<nodes_in .size();i++) input_vector.push_back(&( ((FMMNode*)nodes_in [i]) )->ChebData());
  909. for(size_t i=0;i<nodes_out.size();i++) output_vector.push_back(&((FMMData*)((FMMNode*)nodes_out[i])->FMMData())->cheb_out );
  910. this->SetupInterac(setup_data,device);
  911. { // Resize device buffer
  912. size_t n=setup_data.output_data->Dim(0)*setup_data.output_data->Dim(1)*sizeof(Real_t);
  913. if(this->dev_buffer.Dim()<n) this->dev_buffer.ReInit(n);
  914. }
  915. }
  916. template <class FMMNode>
  917. void FMM_Cheb<FMMNode>::U_List (SetupData<Real_t>& setup_data, bool device){
  918. //Add U_List contribution.
  919. FMM_Pts<FMMNode>::U_List(setup_data, device);
  920. this->EvalList(setup_data, device);
  921. }
  922. template <class FMMNode>
  923. void FMM_Cheb<FMMNode>::Down2TargetSetup(SetupData<Real_t>& setup_data, FMMTree_t* tree, std::vector<Matrix<Real_t> >& buff, std::vector<Vector<FMMNode_t*> >& n_list, int level, bool device){
  924. if(!this->MultipoleOrder()) return;
  925. { // Set setup_data
  926. setup_data.level=level;
  927. setup_data.kernel=this->kernel->k_l2t;
  928. setup_data.interac_type.resize(1);
  929. setup_data.interac_type[0]=D2T_Type;
  930. setup_data. input_data=&buff[1];
  931. setup_data.output_data=&buff[5];
  932. Vector<FMMNode_t*>& nodes_in =n_list[1];
  933. Vector<FMMNode_t*>& nodes_out=n_list[5];
  934. setup_data.nodes_in .clear();
  935. setup_data.nodes_out.clear();
  936. for(size_t i=0;i<nodes_in .Dim();i++) if(nodes_in [i]->Depth()==level || level==-1) setup_data.nodes_in .push_back(nodes_in [i]);
  937. for(size_t i=0;i<nodes_out.Dim();i++) if(nodes_out[i]->Depth()==level || level==-1) setup_data.nodes_out.push_back(nodes_out[i]);
  938. }
  939. std::vector<void*>& nodes_in =setup_data.nodes_in ;
  940. std::vector<void*>& nodes_out=setup_data.nodes_out;
  941. std::vector<Vector<Real_t>*>& input_vector=setup_data. input_vector; input_vector.clear();
  942. std::vector<Vector<Real_t>*>& output_vector=setup_data.output_vector; output_vector.clear();
  943. for(size_t i=0;i<nodes_in .size();i++) input_vector.push_back(&((FMMData*)((FMMNode*)nodes_in [i])->FMMData())->dnward_equiv);
  944. for(size_t i=0;i<nodes_out.size();i++) output_vector.push_back(&((FMMData*)((FMMNode*)nodes_out[i])->FMMData())->cheb_out );
  945. this->SetupInterac(setup_data,device);
  946. }
  947. template <class FMMNode>
  948. void FMM_Cheb<FMMNode>::Down2Target (SetupData<Real_t>& setup_data, bool device){
  949. if(!this->MultipoleOrder()) return;
  950. //Add Down2Target contribution.
  951. this->EvalList(setup_data, device);
  952. }
  953. template <class FMMNode>
  954. void FMM_Cheb<FMMNode>::PostProcessing(std::vector<FMMNode_t*>& nodes){
  955. size_t n=nodes.size();
  956. #pragma omp parallel
  957. {
  958. int omp_p=omp_get_num_threads();
  959. int pid = omp_get_thread_num();
  960. size_t a=(pid*n)/omp_p;
  961. size_t b=((pid+1)*n)/omp_p;
  962. //For each node, compute interaction from point sources.
  963. for(size_t i=a;i<b;i++){
  964. Vector<Real_t>& trg_coord=nodes[i]->trg_coord;
  965. Vector<Real_t>& trg_value=nodes[i]->trg_value;
  966. Vector<Real_t>& cheb_out =((FMMData*)nodes[i]->FMMData())->cheb_out;
  967. //Initialize target potential.
  968. size_t trg_cnt=trg_coord.Dim()/COORD_DIM;
  969. //trg_value.assign(trg_cnt*dof*this->kernel->ker_dim[1],0);
  970. //Sample local expansion at target points.
  971. if(trg_cnt>0 && cheb_out.Dim()>0){
  972. Real_t* c=nodes[i]->Coord();
  973. Real_t scale=pvfmm::pow<Real_t>(2.0,nodes[i]->Depth()+1);
  974. std::vector<Real_t> rel_coord(COORD_DIM*trg_cnt);
  975. for(size_t j=0;j<trg_cnt;j++) for(int k=0;k<COORD_DIM;k++)
  976. rel_coord[j*COORD_DIM+k]=(trg_coord[j*COORD_DIM+k]-c[k])*scale-1.0;
  977. cheb_eval(cheb_out, cheb_deg, rel_coord, trg_value);
  978. }
  979. }
  980. }
  981. }
  982. }//end namespace