-/* Copyright (c) 2010. The SimGrid Team.
+/* Copyright (c) 2010, 2013-2014. The SimGrid Team.
* All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
- * under the terms of the license (GNU LGPL) which comes with this package. */
+ * under the terms of the license (GNU LGPL) which comes with this package. */
#include "private.h"
MPI_Group group;
int i, count;
- count = smpi_process_count();
+ count = SIMIX_process_count();
group = xbt_new(s_smpi_mpi_group_t, 1);
group->size = size;
group->rank_to_index_map = xbt_new(int, size);
MPI_Group smpi_group_copy(MPI_Group origin)
{
- MPI_Group group;
+ MPI_Group group=origin;
int i, count;
if(origin!= smpi_comm_group(MPI_COMM_WORLD)
&& origin != MPI_GROUP_NULL
void smpi_group_destroy(MPI_Group group)
{
- XBT_VERB("trying to free group %p, refcount = %d", group, group->refcount);
if(group!= smpi_comm_group(MPI_COMM_WORLD)
&& group != MPI_GROUP_NULL
&& group != smpi_comm_group(MPI_COMM_SELF)
void smpi_group_set_mapping(MPI_Group group, int index, int rank)
{
- if (rank < group->size && index < smpi_process_count()) {
+ if (rank < group->size && index < SIMIX_process_count()) {
group->rank_to_index_map[rank] = index;
if(index!=MPI_UNDEFINED)group->index_to_rank_map[index] = rank;
}
int smpi_group_rank(MPI_Group group, int index)
{
int rank = MPI_UNDEFINED;
-
- if (index < smpi_process_count()) {
- rank = group->index_to_rank_map[index];
- }
+ rank = group->index_to_rank_map[index];
return rank;
}
{
group->refcount--;
if (group->refcount <= 0) {
- XBT_VERB("freeing group %p", group);
xbt_free(group->rank_to_index_map);
xbt_free(group->index_to_rank_map);
xbt_free(group);
}
return result;
}
+
+int smpi_group_incl(MPI_Group group, int n, int* ranks, MPI_Group* newgroup)
+{
+ int i=0, index=0;
+ if (n == 0) {
+ *newgroup = MPI_GROUP_EMPTY;
+ } else if (n == smpi_group_size(group)) {
+ *newgroup = group;
+ if(group!= smpi_comm_group(MPI_COMM_WORLD)
+ && group != MPI_GROUP_NULL
+ && group != smpi_comm_group(MPI_COMM_SELF)
+ && group != MPI_GROUP_EMPTY)
+ smpi_group_use(group);
+ } else {
+ *newgroup = smpi_group_new(n);
+ for (i = 0; i < n; i++) {
+ index = smpi_group_index(group, ranks[i]);
+ smpi_group_set_mapping(*newgroup, index, i);
+ }
+ }
+ return MPI_SUCCESS;
+}