Commit 5c6c69ff authored by Shane Snyder's avatar Shane Snyder
Browse files

possible bug fix in double group example

parent 2839fcaa
......@@ -177,6 +177,11 @@ int main(int argc, char *argv[])
DEBUG("%d:%d: ping complete\n", grp_id, srank);
HG_Destroy(h);
DEBUG("%d:%d: enter barrier\n", grp_id, srank);
hret = ssg_barrier_margo(src_group);
DIE_IF(hret != HG_SUCCESS, "barrier");
DEBUG("%d:%d: leave barrier\n", grp_id, srank);
if (srank == 0) {
for (i = 0; i < ssg_get_count(sink_group); i++) {
DEBUG("%d:%d: sending shutdown to %d\n", grp_id, srank, i);
......@@ -189,6 +194,7 @@ int main(int argc, char *argv[])
}
}
hret = ssg_barrier_margo(src_group);
DIE_IF(hret != HG_SUCCESS, "barrier");
}
DEBUG("%d:%d cleaning up\n", grp_id, srank);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment