Group::Group()
{
- m_size=0; /* size */
- m_rank_to_index_map=nullptr; /* m_rank_to_index_map */
- m_index_to_rank_map=nullptr; /* m_index_to_rank_map */
- m_refcount=1; /* m_refcount: start > 0 so that this group never gets freed */
+ _size=0; /* size */
+ _rank_to_index_map=nullptr; /* _rank_to_index_map */
+ _index_to_rank_map=nullptr; /* _index_to_rank_map */
+ _refcount=1; /* _refcount: start > 0 so that this group never gets freed */
}
-Group::Group(int n) : m_size(n)
+Group::Group(int n) : _size(n)
{
int i;
- m_rank_to_index_map = xbt_new(int, m_size);
- m_index_to_rank_map = xbt_dict_new_homogeneous(xbt_free_f);
- m_refcount = 1;
- for (i = 0; i < m_size; i++) {
- m_rank_to_index_map[i] = MPI_UNDEFINED;
+ _rank_to_index_map = xbt_new(int, _size);
+ _index_to_rank_map = xbt_dict_new_homogeneous(xbt_free_f);
+ _refcount = 1;
+ for (i = 0; i < _size; i++) {
+ _rank_to_index_map[i] = MPI_UNDEFINED;
}
}
if(origin != MPI_GROUP_NULL
&& origin != MPI_GROUP_EMPTY)
{
- m_size = origin->size();
- m_rank_to_index_map = xbt_new(int, m_size);
- m_index_to_rank_map = xbt_dict_new_homogeneous(xbt_free_f);
- m_refcount = 1;
- for (i = 0; i < m_size; i++) {
- m_rank_to_index_map[i] = origin->m_rank_to_index_map[i];
+ _size = origin->size();
+ _rank_to_index_map = xbt_new(int, _size);
+ _index_to_rank_map = xbt_dict_new_homogeneous(xbt_free_f);
+ _refcount = 1;
+ for (i = 0; i < _size; i++) {
+ _rank_to_index_map[i] = origin->_rank_to_index_map[i];
}
- xbt_dict_foreach(origin->m_index_to_rank_map, cursor, key, ptr_rank) {
+ xbt_dict_foreach(origin->_index_to_rank_map, cursor, key, ptr_rank) {
int * cp = static_cast<int*>(xbt_malloc(sizeof(int)));
*cp=*reinterpret_cast<int*>(ptr_rank);
- xbt_dict_set(m_index_to_rank_map, key, cp, nullptr);
+ xbt_dict_set(_index_to_rank_map, key, cp, nullptr);
}
}
}
Group::~Group()
{
- xbt_free(m_rank_to_index_map);
- xbt_dict_free(&m_index_to_rank_map);
+ xbt_free(_rank_to_index_map);
+ xbt_dict_free(&_index_to_rank_map);
}
void Group::destroy()
{
int * val_rank;
- if (rank < m_size) {
- m_rank_to_index_map[rank] = index;
+ if (rank < _size) {
+ _rank_to_index_map[rank] = index;
if (index!=MPI_UNDEFINED ) {
val_rank = static_cast<int *>(xbt_malloc(sizeof(int)));
*val_rank = rank;
char * key = bprintf("%d", index);
- xbt_dict_set(m_index_to_rank_map, key, val_rank, nullptr);
+ xbt_dict_set(_index_to_rank_map, key, val_rank, nullptr);
xbt_free(key);
}
}
{
int index = MPI_UNDEFINED;
- if (0 <= rank && rank < m_size) {
- index = m_rank_to_index_map[rank];
+ if (0 <= rank && rank < _size) {
+ index = _rank_to_index_map[rank];
}
return index;
}
if (this==MPI_GROUP_EMPTY)
return MPI_UNDEFINED;
char * key = bprintf("%d", index);
- ptr_rank = static_cast<int*>(xbt_dict_get_or_null(m_index_to_rank_map, key));
+ ptr_rank = static_cast<int*>(xbt_dict_get_or_null(_index_to_rank_map, key));
xbt_free(key);
if (ptr_rank==nullptr)
int Group::use()
{
- m_refcount++;
- return m_refcount;
+ _refcount++;
+ return _refcount;
}
int Group::unuse()
{
- m_refcount--;
- if (m_refcount <= 0) {
+ _refcount--;
+ if (_refcount <= 0) {
delete this;
return 0;
}
- return m_refcount;
+ return _refcount;
}
int Group::size()
{
- return m_size;
+ return _size;
}
int Group::compare(MPI_Group group2)
int sz;
result = MPI_IDENT;
- if (m_size != group2->size()) {
+ if (_size != group2->size()) {
result = MPI_UNEQUAL;
} else {
sz = group2->size();
int index=0;
if (n == 0) {
*newgroup = MPI_GROUP_EMPTY;
- } else if (n == m_size) {
+ } else if (n == _size) {
*newgroup = this;
if(this!= MPI_COMM_WORLD->group()
&& this != MPI_COMM_SELF->group()
int Group::group_union(MPI_Group group2, MPI_Group* newgroup)
{
- int size1 = m_size;
+ int size1 = _size;
int size2 = group2->size();
for (int i = 0; i < size2; i++) {
int proc2 = group2->index(i);
int Group::difference(MPI_Group group2, MPI_Group* newgroup)
{
- int newsize = m_size;
- int size2 = m_size;
+ int newsize = _size;
+ int size2 = _size;
for (int i = 0; i < size2; i++) {
int proc1 = this->index(i);
int proc2 = group2->rank(proc1);
}
int Group::excl(int n, int *ranks, MPI_Group * newgroup){
- int oldsize = m_size;
+ int oldsize = _size;
int newsize = oldsize - n;
*newgroup = new simgrid::smpi::Group(newsize);
- int* to_exclude=xbt_new0(int, m_size);
+ int* to_exclude=xbt_new0(int, _size);
for (int i = 0; i < oldsize; i++)
to_exclude[i]=0;
for (int i = 0; i < n; i++)
int newsize = 0;
for (int i = 0; i < n; i++) {
for (int rank = ranges[i][0]; /* First */
- rank >= 0 && rank < m_size; /* Last */
+ rank >= 0 && rank < _size; /* Last */
) {
newsize++;
if(rank == ranges[i][1]){/*already last ?*/
int j = 0;
for (int i = 0; i < n; i++) {
for (int rank = ranges[i][0]; /* First */
- rank >= 0 && rank < m_size; /* Last */
+ rank >= 0 && rank < _size; /* Last */
) {
int index = this->index(rank);
(*newgroup)->set_mapping(index, j);
}
int Group::range_excl(int n, int ranges[][3], MPI_Group * newgroup){
- int newsize = m_size;
+ int newsize = _size;
for (int i = 0; i < n; i++) {
for (int rank = ranges[i][0]; /* First */
- rank >= 0 && rank < m_size; /* Last */
+ rank >= 0 && rank < _size; /* Last */
) {
newsize--;
if(rank == ranges[i][1]){/*already last ?*/
while (newrank < newsize) {
int add = 1;
for (int i = 0; i < n; i++) {
- for (int rank = ranges[i][0]; rank >= 0 && rank < m_size;) {
+ for (int rank = ranges[i][0]; rank >= 0 && rank < _size;) {
if(rank==oldrank){
add = 0;
break;
