Changeset 1517 for XIOS/dev/branch_openmp/extern/ep_dev/ep_create.cpp
- Timestamp:
- 06/01/18 15:24:53 (6 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/branch_openmp/extern/ep_dev/ep_create.cpp
r1511 r1517 41 41 42 42 out_comm_hdls = new MPI_Comm[num_ep]; 43 #ifdef _showinfo 44 printf("new out_comm_hdls = %p\n", out_comm_hdls); 45 #endif 43 46 47 ::MPI_Comm *parent_comm = new ::MPI_Comm; 48 ::MPI_Comm_dup(to_mpi_comm(base_comm_ptr), parent_comm); 49 50 #ifdef _showinfo 51 printf("new out_comm_hdls->mpi_comm = %p\n", parent_comm); 52 #endif 53 44 54 for (int idx = 0; idx < num_ep; ++idx) 45 55 { 56 46 57 out_comm_hdls[idx] = new ep_comm; 58 #ifdef _showinfo 59 printf("new out_comm_hdls[%d] = %p\n", idx, out_comm_hdls[idx]); 60 #endif 61 47 62 out_comm_hdls[idx]->is_ep = true; 48 63 out_comm_hdls[idx]->is_intercomm = false; 64 49 65 out_comm_hdls[idx]->ep_comm_ptr = new ep_communicator; 50 *(static_cast< ::MPI_Comm*>(out_comm_hdls[idx]->mpi_comm)) = *(static_cast< ::MPI_Comm*>(base_comm_ptr)); 66 #ifdef _showinfo 67 printf("new out_comm_hdls[%d]->ep_comm_ptr = %p\n", idx, out_comm_hdls[idx]->ep_comm_ptr); 68 #endif 69 70 71 out_comm_hdls[idx]->mpi_comm = parent_comm; 51 72 out_comm_hdls[idx]->ep_comm_ptr->comm_list = out_comm_hdls; 52 73 out_comm_hdls[idx]->ep_comm_ptr->comm_label = 0; … … 62 83 63 84 out_comm_hdls[0]->ep_barrier = new ep_barrier(num_ep); 85 #ifdef _showinfo 86 printf("new out_comm_hdls[0]->ep_barrier = %p\n", out_comm_hdls[0]->ep_barrier); 87 #endif 88 64 89 out_comm_hdls[0]->my_buffer = new BUFFER; 90 #ifdef _showinfo 91 printf("new out_comm_hdls[0]->my_buffer = %p\n", out_comm_hdls[0]->my_buffer); 92 #endif 65 93 66 94 out_comm_hdls[0]->ep_rank_map = new EP_RANK_MAP; 67 95 #ifdef _showinfo 96 printf("new out_comm_hdls[0]->ep_rank_map = %p\n", out_comm_hdls[0]->ep_rank_map); 97 #endif 68 98 69 99 for (int i = 1; i < num_ep; i++) … … 82 112 83 113 out_comm_hdls[i]->ep_comm_ptr->message_queue = new Message_list; 114 #ifdef _showinfo 115 printf("new out_comm_hdls[%d]->ep_comm_ptr->message_queue = %p\n", i, out_comm_hdls[i]->ep_comm_ptr->message_queue); 116 #endif 117 84 118 } 85 119 … … 91 125 for(int j=0; j<recv_num_ep[i]; j++) 92 126 { 93 //out_comm_hdls[0]->rank_map->at(ind) = make_pair(j, i);94 127 out_comm_hdls[0]->ep_rank_map->insert(std::pair< int, std::pair<int,int> >(ind, j, i)); 95 128 ind++;
Note: See TracChangeset
for help on using the changeset viewer.