Changeset 1146 for XIOS/dev/branch_yushan_merged/extern
- Timestamp:
- 05/24/17 16:59:40 (7 years ago)
- Location:
- XIOS/dev/branch_yushan_merged/extern
- Files:
-
- 6 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/branch_yushan_merged/extern/remap/src/clipper.cpp
r919 r1146 1047 1047 1048 1048 //create a new edge array ... 1049 TEdge *edges = new TEdge [highI+1];1049 TEdge *edges = new TEdge[highI+1]; 1050 1050 1051 1051 bool IsFlat = true; … … 4274 4274 { 4275 4275 //The equation of a line in general form (Ax + By + C = 0) 4276 //given 2 points (x ¹,y¹) & (x²,y²) is ...4277 //(y ¹ - y²)x + (x² - x¹)y + (y² - y¹)x¹ - (x² - x¹)y¹= 04278 //A = (y ¹ - y²); B = (x² - x¹); C = (y² - y¹)x¹ - (x² - x¹)y¹4279 //perpendicular distance of point (x ³,y³) = (Ax³ + By³ + C)/Sqrt(A² + B²)4276 //given 2 points (x,y) & (x,y) is ... 4277 //(y - y)x + (x - x)y + (y - y)x - (x - x)y = 0 4278 //A = (y - y); B = (x - x); C = (y - y)x - (x - x)y 4279 //perpendicular distance of point (x,y) = (Ax + By + C)/Sqrt(A + B) 4280 4280 //see http://en.wikipedia.org/wiki/Perpendicular_distance 4281 4281 double A = double(ln1.Y - ln2.Y); -
XIOS/dev/branch_yushan_merged/extern/remap/src/mapper.cpp
r1141 r1146 548 548 } 549 549 550 MPI_Waitall(nbSendRequest, sendRequest, status); 550 551 MPI_Waitall(nbRecvRequest, recvRequest, status); 551 MPI_Waitall(nbSendRequest, sendRequest, status);552 552 553 553 for (int rank = 0; rank < mpiSize; rank++) … … 620 620 } 621 621 622 MPI_Waitall(nbSendRequest, sendRequest, status); 622 623 MPI_Waitall(nbRecvRequest, recvRequest, status); 623 MPI_Waitall(nbSendRequest, sendRequest, status); 624 624 625 625 int nbNeighbourNodes = 0; 626 626 for (int rank = 0; rank < mpiSize; rank++) … … 803 803 } 804 804 } 805 805 806 MPI_Waitall(nbSendRequest, sendRequest, status); 806 807 MPI_Waitall(nbRecvRequest, recvRequest, status); 807 MPI_Waitall(nbSendRequest, sendRequest, status);808 808 809 char **sendBuffer2 = new char*[mpiSize]; 809 810 char **recvBuffer2 = new char*[mpiSize]; … … 886 887 } 887 888 } 888 889 890 MPI_Waitall(nbSendRequest, sendRequest, status); 889 891 MPI_Waitall(nbRecvRequest, recvRequest, status); 890 MPI_Waitall(nbSendRequest, sendRequest, status);892 891 893 892 894 delete [] sendRequest; -
XIOS/dev/branch_yushan_merged/extern/remap/src/timerRemap.cpp
r694 r1146 9 9 using namespace std; 10 10 11 map<string,CTimer*> CTimer::allTimer;11 map<string,CTimer*> *CTimer::allTimer = 0; 12 12 13 13 CTimer::CTimer(const string& name_) : name(name_) … … 55 55 CTimer& CTimer::get(const string name) 56 56 { 57 if(allTimer == 0) allTimer = new map<string,CTimer*>; 57 58 map<string,CTimer*>::iterator it; 58 it= allTimer.find(name);59 if (it== allTimer.end()) it=allTimer.insert(pair<string,CTimer*>(name,new CTimer(name))).first;59 it=(*allTimer).find(name); 60 if (it==(*allTimer).end()) it=(*allTimer).insert(pair<string,CTimer*>(name,new CTimer(name))).first; 60 61 return *(it->second); 61 62 } -
XIOS/dev/branch_yushan_merged/extern/remap/src/timerRemap.hpp
r694 r1146 26 26 double getCumulatedTime(void); 27 27 void print(void); 28 static map<string,CTimer*> allTimer; 28 //static map<string,CTimer*> allTimer; 29 static map<string,CTimer*> *allTimer; 30 #pragma omp threadprivate(allTimer) 31 29 32 static double getTime(void); 30 33 static CTimer& get(string name); -
XIOS/dev/branch_yushan_merged/extern/src_ep_dev/ep_alltoall.cpp
r1134 r1146 10 10 int MPI_Alltoall(const void *sendbuf, int sendcount, MPI_Datatype sendtype, void *recvbuf, int recvcount, MPI_Datatype recvtype, MPI_Comm comm) 11 11 { 12 assert(static_cast< ::MPI_Datatype>(sendtype) == static_cast< ::MPI_Datatype>(recvtype)); 12 13 ::MPI_Aint typesize, llb; 13 14 ::MPI_Type_get_extent(static_cast< ::MPI_Datatype>(sendtype), &llb, &typesize); 15 16 int ep_size; 17 MPI_Comm_size(comm, &ep_size); 14 18 15 for(int i=0; i< comm.ep_comm_ptr->size_rank_info[0].second; i++)19 for(int i=0; i<ep_size; i++) 16 20 { 17 MPI_Gather( (char*)sendbuf+i*sendcount*typesize, sendcount, sendtype, recvbuf, recvcount, recvtype, i, comm);21 MPI_Gather(sendbuf+i*sendcount*typesize, sendcount, sendtype, recvbuf, recvcount, recvtype, i, comm); 18 22 } 19 23 -
XIOS/dev/branch_yushan_merged/extern/src_ep_dev/ep_wait.cpp
r1138 r1146 86 86 87 87 int finished = 0; 88 boolfinished_index[count];88 int finished_index[count]; 89 89 90 90 for(int i=0; i<count; i++) … … 97 97 for(int i=0; i<count; i++) 98 98 { 99 //MPI_Test(&array_of_requests[i], &finished_index[i], &array_of_statuses[i]); 99 100 if(finished_index[i] == false) // this request has not been tested. 100 101 { … … 102 103 { 103 104 MPI_Wait(&array_of_requests[i], &array_of_statuses[i]); 104 if(array_of_requests[i].type == 3)105 {106 //int check_count;107 //MPI_Get_count(&array_of_statuses[i], array_of_requests[i].ep_datatype, &check_count);108 //check_sum_recv(array_of_requests[i].buf, count, array_of_requests[i].ep_datatype, array_of_requests[i].ep_src, array_of_requests[i].ep_tag, array_of_requests[i].comm, 2);109 }110 105 finished++; 111 106 finished_index[i] = true;
Note: See TracChangeset
for help on using the changeset viewer.