Changeset 1185 for XIOS/dev/branch_yushan_merged/extern/src_ep_dev/ep_message.cpp

Timestamp:

06/26/17 18:36:56 (7 years ago)

Author:

yushan

Message:

save dev. recv_test OK

File:

• XIOS/dev/branch_yushan_merged/extern/src_ep_dev/ep_message.cpp (modified) (2 diffs)

XIOS/dev/branch_yushan_merged/extern/src_ep_dev/ep_message.cpp

@@ -77 +77 @@
              
         msg_block->ep_src  = get_ep_rank(comm, src_loc,  src_mpi);        //printf("myRank = %d, msg_block->ep_src = %d\n",  myRank, msg_block->ep_src);
-
-        //printf("myRank = %d, probed one message, ep_src = %d, ep_dest = %d, tag = %d, message = %d\n", myRank, msg_block->ep_src, msg_block->ep_dest, msg_block->ep_tag, msg_block->mpi_message);
+        int dest_mpi = comm.ep_comm_ptr->size_rank_info[2].first;
+        int ep_dest = get_ep_rank(comm, dest_loc, dest_mpi);
+        printf("myRank = %d, probed one message, ep_src = %d, ep_dest = %d, tag = %d, message = %d\n", myRank, msg_block->ep_src, ep_dest, msg_block->ep_tag, msg_block->mpi_message);
         msg_block->mpi_status = new ::MPI_Status(status);
 
@@ -89 +90 @@
           #pragma omp flush
           ptr_comm_target->ep_comm_ptr->message_queue->push_back(*msg_block);  
-          // printf("myRank = %d, push_back OK, ep_src = %d, ep_tag = %d, mpi_status = %p (%p)\n", myRank, 
-          //                                                                                   ptr_comm_target->ep_comm_ptr->message_queue->back().ep_src,
-          //                                                                                   ptr_comm_target->ep_comm_ptr->message_queue->back().ep_tag,
-          //                                                                                   msg_block->mpi_status, &status);
+          printf("myRank = %d, push_back OK, ep_src = %d, ep_tag = %d, dest = %d(%d)\n", myRank, 
+                                                                                             ptr_comm_target->ep_comm_ptr->message_queue->back().ep_src,
+                                                                                             ptr_comm_target->ep_comm_ptr->message_queue->back().ep_tag,
+                                                                                             ep_dest, dest_loc);
     
           #pragma omp flush