- Timestamp:
- 05/16/17 17:54:30 (7 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/branch_yushan_merged/src/client_client_dht_template.hpp
r941 r1134 13 13 #include "xios_spl.hpp" 14 14 #include "array_new.hpp" 15 #include "mpi .hpp"15 #include "mpi_std.hpp" 16 16 #include "policy.hpp" 17 17 #include <boost/unordered_map.hpp> … … 40 40 public: 41 41 CClientClientDHTTemplate(const Index2InfoTypeMap& indexInfoInitMap, 42 const MPI_Comm& clientIntraComm);42 const ep_lib::MPI_Comm& clientIntraComm); 43 43 44 44 CClientClientDHTTemplate(const Index2VectorInfoTypeMap& indexInfoInitMap, 45 const MPI_Comm& clientIntraComm);45 const ep_lib::MPI_Comm& clientIntraComm); 46 46 47 47 void computeIndexInfoMapping(const CArray<size_t,1>& indices); … … 55 55 56 56 protected: 57 CClientClientDHTTemplate(const MPI_Comm& clientIntraComm);57 CClientClientDHTTemplate(const ep_lib::MPI_Comm& clientIntraComm); 58 58 59 59 protected: … … 62 62 // Redistribute index and info among clients 63 63 void computeDistributedIndex(const Index2InfoTypeMap& indexInfoInitMap, 64 const MPI_Comm& intraCommLevel,64 const ep_lib::MPI_Comm& intraCommLevel, 65 65 int level); 66 66 67 67 void computeDistributedIndex(const Index2VectorInfoTypeMap& indexInfoInitMap, 68 const MPI_Comm& intraCommLevel,68 const ep_lib::MPI_Comm& intraCommLevel, 69 69 int level); 70 70 … … 73 73 74 74 void computeIndexInfoMappingLevel(const CArray<size_t,1>& indices, 75 const MPI_Comm& intraCommLevel,75 const ep_lib::MPI_Comm& intraCommLevel, 76 76 int level); 77 77 … … 85 85 // Send information to clients 86 86 void sendInfoToClients(int clientDestRank, unsigned char* info, int infoSize, 87 const MPI_Comm& clientIntraComm,88 std::vector< MPI_Request>& requestSendInfo);87 const ep_lib::MPI_Comm& clientIntraComm, 88 std::vector<ep_lib::MPI_Request>& requestSendInfo); 89 89 90 90 void recvInfoFromClients(int clientSrcRank, unsigned char* info, int infoSize, 91 const MPI_Comm& clientIntraComm,92 std::vector< MPI_Request>& requestRecvInfo);91 const ep_lib::MPI_Comm& clientIntraComm, 92 std::vector<ep_lib::MPI_Request>& requestRecvInfo); 93 93 94 94 // Send global index to clients 95 95 void sendIndexToClients(int clientDestRank, size_t* indices, size_t indiceSize, 96 const MPI_Comm& clientIntraComm,97 std::vector< MPI_Request>& requestSendIndexGlobal);96 const ep_lib::MPI_Comm& clientIntraComm, 97 std::vector<ep_lib::MPI_Request>& requestSendIndexGlobal); 98 98 99 99 void recvIndexFromClients(int clientSrcRank, size_t* indices, size_t indiceSize, 100 const MPI_Comm& clientIntraComm,101 std::vector< MPI_Request>& requestRecvIndex);100 const ep_lib::MPI_Comm& clientIntraComm, 101 std::vector<ep_lib::MPI_Request>& requestRecvIndex); 102 102 103 103 void sendRecvOnReturn(const std::vector<int>& sendNbRank, std::vector<int>& sendNbElements,
Note: See TracChangeset
for help on using the changeset viewer.