Пользовательские типы данных MPI. Безопасно ли то, что я делаю?
-
19-09-2019 - |
Вопрос
Впервые использую MPI вне некоторых простых приложений для практики, и что-то идет не так.
У меня есть класс, определенный со следующими членами (методы опущены для удобства чтения и экономии места на экране):
class particle
{
public:
double _lastUpdate;
float _x, _y, _xvel, _yvel;
bool _isStatic;
bool _isForeign;
float _size;
private:
int _isStaticInt; // integer copy of _isStatic to be sent over MPI ( since there's no MPI_BOOL :C )
};
Я хочу пересылать наборы частиц между процессами, отправляя значения некоторых ключевых членов каждой частицы и копируя остальные на месте.Для этой цели я определяю тип данных MPI как таковой;как видите, члены _lastUpdate, _isStatic и _isForeign не включены:
MPI_Datatype types[] = { MPI_FLOAT, MPI_FLOAT, MPI_FLOAT, MPI_FLOAT, MPI_INTEGER, MPI_FLOAT };
std::vector<int> len(6, 1);
std::vector<MPI_Aint> disp(6, 0);
particle temp;
MPI_Aint base;
MPI_Address(&temp, &base);
MPI_Address(&temp._x, &disp[0]);
MPI_Address(&temp._y, &disp[1]);
MPI_Address(&temp._xvel, &disp[2]);
MPI_Address(&temp._yvel, &disp[3]);
MPI_Address(&temp._isStaticInt, &disp[4]);
MPI_Address(&temp._size, &disp[5]);
for (int i=0; i<6; ++i)
{
disp[i] = disp[i] - base;
}
MPI_Type_struct(6, &len[0], &disp[0], types, &_particleType);
MPI_Type_commit(&_particleType);
Вот как я отправляю частицы;«части» — это вектор частиц*, который содержит указатели на объекты частиц, которые я хочу отправить, а «размер» — это parts.size().
std::vector<int> len(size, 1);
std::vector<MPI_Aint> disp(size, 0);
MPI_Aint base;
MPI_Address(parts[0], &base); // datatype begins at the first selected object
for (int select = 1; select < size; ++select)
{
MPI_Address(parts[select], &disp[select]);
disp[select] = disp[select] - base;
}
MPI_Type_hindexed(size, &len[0], &disp[0], _particleType, &_sendType);
MPI_Type_commit(&_sendType);
MPI_Request payload_req;
MPI_Isend(parts[0], 1, _sendType, ngb, 0, _cartesian_comm, &payload_req);
Получение происходит аналогично, только в этом случае «части» — это вектор частиц*, указывающий на ранее созданные «пустые» объекты-частицы, члены которых должны быть заполнены полученными нами данными:
std::vector<int> len(size, 1);
std::vector<MPI_Aint> disp(size, 0);
MPI_Aint base;
MPI_Address(parts[0], &base); // datatype begins at the first newly inserted object
for (int part = 1; part < size; ++part)
{
MPI_Address(parts[part], &disp[part]);
disp[part] = disp[part] - base;
}
MPI_Type_hindexed(size, &len[0], &disp[0], _particleType, &_recvType);
MPI_Type_commit(&_recvType);
MPI_Status status;
MPI_Recv(parts[0], size, _particleType, ngb, 0, _cartesian_comm, &status);
Проблема в том, что все полученные частицы, кроме первой, имеют в своих членах «пустые» значения по умолчанию.Раньше я написал небольшое тестовое приложение, которое делало нечто подобное, и оно работало безупречно, хотя и передавало лишь несколько простых значений.Это наводит меня на мысль, что если не существует ошибки в кодировании, которую я здесь не заметил (вполне возможно), то такой трюк с типами данных не гарантированно сработает, а то немногое, что работает, работает только случайно.
Может ли кто-нибудь подтвердить/опровергнуть, безопасен ли этот тип манипуляций с памятью и на него следует полагаться?
Решение
Неважно, кажется, просто набрав вопрос, я понял, в чем дело.
Команда приема должна быть:
MPI_Recv(parts[0], 1, _recvType, ngb, 0, _cartesian_comm, &status);