[mpich-commits] [mpich] MPICH primary repository branch, 3.2.x, created. v3.2-5-g88557f9
Service Account
noreply at mpich.org
Fri Aug 19 16:57:56 CDT 2016
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, 3.2.x has been created
at 88557f903875b4f2a44283a343eee4ac045aeb2a (commit)
- Log -----------------------------------------------------------------
http://git.mpich.org/mpich.git/commitdiff/88557f903875b4f2a44283a343eee4ac045aeb2a
commit 88557f903875b4f2a44283a343eee4ac045aeb2a
Author: Ken Raffenetti <raffenet at mcs.anl.gov>
Date: Thu Aug 18 12:04:51 2016 -0500
hcoll: Add reference to internal requests
Signed-off-by: Tomislav Janjusic <tomislavj at mellanox.com>
diff --git a/src/mpid/common/hcoll/hcoll_rte.c b/src/mpid/common/hcoll/hcoll_rte.c
index e0d2136..123a71f 100644
--- a/src/mpid/common/hcoll/hcoll_rte.c
+++ b/src/mpid/common/hcoll/hcoll_rte.c
@@ -364,6 +364,7 @@ static void *get_coll_handle(void)
{
MPID_Request *req;
req = MPID_Request_create();
+ MPIR_Request_add_ref(req);
req->kind = MPID_COLL_REQUEST;
return (void *) req;
}
http://git.mpich.org/mpich.git/commitdiff/ca5e6a6befeeffbc8347da7b32058d5210911161
commit ca5e6a6befeeffbc8347da7b32058d5210911161
Author: Ken Raffenetti <raffenet at mcs.anl.gov>
Date: Thu Aug 18 12:03:51 2016 -0500
hcoll: Use MPIU_Assert
Signed-off-by: Tomislav Janjusic <tomislavj at mellanox.com>
diff --git a/src/mpid/common/hcoll/hcoll_rte.c b/src/mpid/common/hcoll/hcoll_rte.c
index 996cf7f..e0d2136 100644
--- a/src/mpid/common/hcoll/hcoll_rte.c
+++ b/src/mpid/common/hcoll/hcoll_rte.c
@@ -1,6 +1,5 @@
#include "hcoll.h"
#include "hcoll/api/hcoll_dte.h"
-#include <assert.h>
static int recv_nb(dte_data_representation_t data,
uint32_t count,
@@ -54,7 +53,7 @@ static void progress(void)
* error codes. The progress function pointer right now
* expects that the function returns void. */
ret = hcoll_do_progress(&made_progress);
- assert(ret == MPI_SUCCESS);
+ MPIU_Assert(ret == MPI_SUCCESS);
}
}
http://git.mpich.org/mpich.git/commitdiff/5fe0a4918ac41e7e5f9035ac561e7034902fefb0
commit 5fe0a4918ac41e7e5f9035ac561e7034902fefb0
Author: Ken Raffenetti <raffenet at mcs.anl.gov>
Date: Tue Aug 16 15:53:58 2016 -0500
hcoll: Fix usage of progress hook
MPICH progress hooks now take a made_progress parameter. We just set
it to true for now for correctness purposes.
Signed-off-by: Tomislav Janjusic <tomislavj at mellanox.com>
diff --git a/src/mpid/common/hcoll/hcoll_init.c b/src/mpid/common/hcoll/hcoll_init.c
index c04704a..daa0caa 100644
--- a/src/mpid/common/hcoll/hcoll_init.c
+++ b/src/mpid/common/hcoll/hcoll_init.c
@@ -226,8 +226,7 @@ int hcoll_comm_destroy(MPID_Comm * comm_ptr, void *param)
int hcoll_do_progress(int *made_progress)
{
- if (made_progress)
- *made_progress = 0;
+ *made_progress = 1;
hcoll_progress_fn();
return MPI_SUCCESS;
diff --git a/src/mpid/common/hcoll/hcoll_rte.c b/src/mpid/common/hcoll/hcoll_rte.c
index 82fa961..996cf7f 100644
--- a/src/mpid/common/hcoll/hcoll_rte.c
+++ b/src/mpid/common/hcoll/hcoll_rte.c
@@ -44,6 +44,7 @@ static int world_rank(rte_grp_handle_t grp_h, rte_ec_handle_t ec);
static void progress(void)
{
int ret;
+ int made_progress;
if (0 == world_comm_destroying) {
MPID_Progress_test();
@@ -52,7 +53,7 @@ static void progress(void)
/* FIXME: The hcoll library needs to be updated to return
* error codes. The progress function pointer right now
* expects that the function returns void. */
- ret = hcoll_do_progress();
+ ret = hcoll_do_progress(&made_progress);
assert(ret == MPI_SUCCESS);
}
}
http://git.mpich.org/mpich.git/commitdiff/d20930987ec9d4aee5830fbf89f72af6e02807d3
commit d20930987ec9d4aee5830fbf89f72af6e02807d3
Author: Ken Raffenetti <raffenet at mcs.anl.gov>
Date: Thu Aug 18 11:43:09 2016 -0500
hcoll: Remove unused function
Signed-off-by: Tomislav Janjusic <tomislavj at mellanox.com>
diff --git a/src/mpid/common/hcoll/hcoll_rte.c b/src/mpid/common/hcoll/hcoll_rte.c
index e7288a4..82fa961 100644
--- a/src/mpid/common/hcoll/hcoll_rte.c
+++ b/src/mpid/common/hcoll/hcoll_rte.c
@@ -23,8 +23,6 @@ static int ec_handle_compare(rte_ec_handle_t handle_1,
static int get_ec_handles(int num_ec,
int *ec_indexes, rte_grp_handle_t, rte_ec_handle_t * ec_handles);
-static int get_my_ec(rte_grp_handle_t, rte_ec_handle_t * ec_handle);
-
static int group_size(rte_grp_handle_t group);
static int my_rank(rte_grp_handle_t grp_h);
static int ec_on_local_node(rte_ec_handle_t ec, rte_grp_handle_t group);
@@ -294,21 +292,6 @@ static int get_ec_handles(int num_ec,
}
#undef FUNCNAME
-#define FUNCNAME get_my_ec
-#undef FCNAME
-#define FCNAME MPL_QUOTE(FUNCNAME)
-static int get_my_ec(rte_grp_handle_t grp_h, rte_ec_handle_t * ec_handle)
-{
- MPID_Comm *comm;
- comm = (MPID_Comm *) grp_h;
- int my_rank = MPIR_Comm_rank(comm);
- ec_handle->handle = (void *) (comm->vcrt->vcr_table[my_rank]);
- ec_handle->rank = my_rank;
- return HCOLL_SUCCESS;
-}
-
-
-#undef FUNCNAME
#define FUNCNAME group_size
#undef FCNAME
#define FCNAME MPL_QUOTE(FUNCNAME)
http://git.mpich.org/mpich.git/commitdiff/1db759cd3878fbf0b531a7ce630093ba789e9bd6
commit 1db759cd3878fbf0b531a7ce630093ba789e9bd6
Author: Ken Raffenetti <raffenet at mcs.anl.gov>
Date: Thu Aug 18 11:41:44 2016 -0500
hcoll: Fix ec_handles
The glue code used to rely on access to VCs, which are no longer exposed
to the upper layers. This commit hacks in access to them again to get hcoll
working. We will add a new device interface to not be CH3 specific.
Signed-off-by: Tomislav Janjusic <tomislavj at mellanox.com>
diff --git a/src/mpid/common/hcoll/hcoll_rte.c b/src/mpid/common/hcoll/hcoll_rte.c
index ea543fe..e7288a4 100644
--- a/src/mpid/common/hcoll/hcoll_rte.c
+++ b/src/mpid/common/hcoll/hcoll_rte.c
@@ -288,7 +288,7 @@ static int get_ec_handles(int num_ec,
comm = (MPID_Comm *) grp_h;
for (i = 0; i < num_ec; i++) {
ec_handles[i].rank = ec_indexes[i];
- ec_handles[i].handle = (void *) (comm->vcrt->vcr_table[ec_indexes[i]]);
+ ec_handles[i].handle = (void *) (comm->dev.vcrt->vcr_table[ec_indexes[i]]);
}
return HCOLL_SUCCESS;
}
@@ -430,5 +430,5 @@ static void coll_handle_complete(void *handle)
#define FCNAME MPL_QUOTE(FUNCNAME)
static int world_rank(rte_grp_handle_t grp_h, rte_ec_handle_t ec)
{
- return (MPIR_Process.comm_world->rank);
+ return ((struct MPIDI_VC *)ec.handle)->pg_rank;
}
-----------------------------------------------------------------------
hooks/post-receive
--
MPICH primary repository
More information about the commits
mailing list