[mpich-commits] [mpich] MPICH primary repository branch, master, updated. v3.0.4-243-gc3a8a81

mysql vizuser noreply at mpich.org
Mon May 20 21:59:19 CDT 2013


This is an automated email from the git hooks/post-receive script. It was
generated because a ref change was pushed to the repository containing
the project "MPICH primary repository".

The branch, master has been updated
       via  c3a8a817c9611dffc5b4bbdbbe6ad09aa5af6342 (commit)
      from  e4fa6c06477c329c83d71479b667a70a6ef570dc (commit)

Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.

- Log -----------------------------------------------------------------
http://git.mpich.org/mpich.git/commitdiff/c3a8a817c9611dffc5b4bbdbbe6ad09aa5af6342

commit c3a8a817c9611dffc5b4bbdbbe6ad09aa5af6342
Author: Charles Archer <archerc at us.ibm.com>
Date:   Mon May 20 06:56:58 2013 -0400

    PAMID device code for local task detection

diff --git a/src/mpid/pamid/src/mpidi_util.c b/src/mpid/pamid/src/mpidi_util.c
index ee8eda9..2bd89db 100644
--- a/src/mpid/pamid/src/mpidi_util.c
+++ b/src/mpid/pamid/src/mpidi_util.c
@@ -1908,3 +1908,54 @@ void MPIDI_collsel_pami_tune_cleanup()
 }
 
 
+#undef FUNCNAME
+#define FUNCNAME MPID_Get_node_id
+#undef FCNAME
+#define FCNAME MPIDI_QUOTE(FUNCNAME)
+static int _g_max_node_id = -1;
+int MPID_Get_node_id(MPID_Comm *comm, int rank, MPID_Node_id_t *id_p)
+{
+  int mpi_errno = MPI_SUCCESS;
+  uint32_t node_id;
+  uint32_t offset;
+  uint32_t max_nodes;
+  if(!PAMIX_Extensions.is_local_task.node_info)
+    MPIU_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**notimpl");
+
+  pami_result_t rc = PAMIX_Extensions.is_local_task.node_info(comm->vcr[rank]->taskid,
+                                                              &node_id,&offset,&max_nodes);
+  if(rc != PAMI_SUCCESS)  MPIU_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**notimpl");
+  *id_p = node_id;
+
+  fn_fail:
+  return mpi_errno;
+}
+
+#undef FUNCNAME
+#define FUNCNAME MPID_Get_max_node_id
+#undef FCNAME
+#define FCNAME MPIDI_QUOTE(FUNCNAME)
+int MPID_Get_max_node_id(MPID_Comm *comm, MPID_Node_id_t *max_id_p)
+{
+  int mpi_errno = MPI_SUCCESS;
+  uint32_t node_id;
+  uint32_t offset;
+  uint32_t max_nodes;
+  if(_g_max_node_id == -1)
+  {
+    if(!PAMIX_Extensions.is_local_task.node_info)
+      MPIU_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**notimpl");
+
+    pami_result_t rc = PAMIX_Extensions.is_local_task.node_info(comm->vcr[0]->taskid,
+                                                                &node_id,&offset,&max_nodes);
+    if(rc != PAMI_SUCCESS)  MPIU_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**notimpl");
+    *max_id_p = max_nodes;
+    _g_max_node_id = max_nodes;
+  }
+  else
+    *max_id_p = _g_max_node_id;
+
+  fn_fail:
+  return mpi_errno;
+}
+#undef FUNCNAME

-----------------------------------------------------------------------

Summary of changes:
 src/mpid/pamid/src/mpidi_util.c |   51 +++++++++++++++++++++++++++++++++++++++
 1 files changed, 51 insertions(+), 0 deletions(-)


hooks/post-receive
-- 
MPICH primary repository


More information about the commits mailing list