Функция приема сообщения int MPI_Recv

source, int tag, MPI_Comm comm, MPI_Status *status)
buf – буфер для

приема сообщения,
count – количество элементов в сообщении,
type – тип элементов сообщения,
source– ранг процесса, от которого д.б. выполнен прием сообщения,
tag– тэг сообщения, которое д.б. принято процессом,
comm - коммуникатор, в рамках которого выполняется операция,
status - указатель на переменную с результатами выполнения операции приема.

Лекция 12. И.Г. Захарова, кафедра ПО

сообщения.
При нехватке памяти часть сообщения будет потеряна. В коде завершения

функции будет зафиксирована ошибка переполнения.
Типы элементов передаваемого и принимаемого сообщения должны совпадать.
Для приема сообщения
от любого процесса-отправителя параметру source устанавливается значение MPI_ANY_SOURCE,
с любым тэгом параметру tag устанавливается значение MPI_ANY_TAG.

Лекция 12. И.Г. Захарова, кафедра ПО

«джокеры»

– ранг процесса-отправителя принятого сообщения,
status.MPI_TAG –тэг принятого сообщения.
Функция
MPI_Get_count(MPI_Status*status,

MPI_Datatypetype, int *count)
возвращает в переменной count количество элементов типа type в принятом сообщении.

Лекция 12. И.Г. Захарова, кафедра ПО

начала отправки сообщения.
?Вызов MPI_Recv не обязан согласовываться со временем вызова

соответствующей функции MPI_Recv
Функция MPI_Recv – блокирующая для процесса-получателя, его выполнение приостанавливается до завершения работы функции ? если ожидаемое для приема сообщение будет отсутствовать, выполнение параллельной программы будет блокировано.
По завершении MPI_Recv в buf будет размещено принятое сообщение.

Лекция 12. И.Г. Захарова, кафедра ПО

вычислений) до момента завершения работы вызванных функций.
Все рассмотренные функции для

парных операций передачи и приема являются блокирующими.
Если вычисления (др. операции) не зависят от передаваемых данных, то блокировка не нужна.

Лекция 12. И.Г. Захарова, кафедра ПО

процессов для совмещения процессов передачи сообщений и вычислений.
Минус – более

сложны для использования.
Плюс – могут уменьшить потери эффективности параллельных вычислений из-за медленных коммуникационных операций.

Лекция 12. И.Г. Захарова, кафедра ПО

MPI_Request*request);
int MPI_Issend(void*buf, int count, MPI_Datatypetype, int dest,int tag, MPI_Commcomm, MPI_Request*request);
int

MPI_Ibsend(void*buf, int count, MPI_Datatypetype, int dest,int tag, MPI_Commcomm, MPI_Request*request);
int MPI_Irsend(void*buf, int count, MPI_Datatypetype, int dest, int tag, MPI_Commcomm, MPI_Request*request);
int MPI_Irecv(void*buf, int count, MPI_Datatypetype, int source, int tag, MPI_Commcomm, MPI_Request*request);

Лекция 12. И.Г. Захарова, кафедра ПО

может использоваться для проверки в неблокирующей функции
int MPI_Test( MPI_Request*request, int

*flag, MPI_status*status),
request-дескриптор операции, определенный при вызове неблокирующей функции,
flag-результат проверки(true, если операция завершена),
status-результат выполнения операции (только для завершенной операции)

Лекция 12. И.Г. Захарова, кафедра ПО

type, dest, tag, comm, &request);
…
do
{
…
MPI_Test(&request,&flag,&status);
}
while(!flag);

Лекция 12. И.Г. Захарова,

кафедра ПО

может быть
Один или несколько процессов
Все процессы
Один и тот же процесс

может принадлежать нескольким группам
Коммуникатор – объект, объединяющий
Группу процессов
Контекст – параметры, использующиеся при передаче данных

Лекция 12. И.Г. Захарова, кафедра ПО

одного коммуникатора.
Коллективные операции – одновременно для всех процессов коммуникатора.
Операции на

разных коммуникаторах – независимы и не влияют друг на друга ?
Создание коммуникаторов
Сужает область действия коллективных операций.
Устраняет взаимовлияние выполняемых частей программы

Лекция 12. И.Г. Захарова, кафедра ПО

связанная с коммуникатором по умолчанию – MPI_COMM_WORLD.
Для каждого процесса определен

коммуникатор MPI_COMM_SELF, включающий этот процесс.
Можно использовать пустую группу MPI_GROUP_EMPTY

Лекция 12. И.Г. Захарова, кафедра ПО

– коммуникатор,
group – группа, связанная с коммуникатором.

Лекция 12. И.Г. Захарова,

кафедра ПО

*ranks,MPI_Group *newgroup)
oldgroup – существующая группа,
newgroup – созданная группа,
n –

количество элементов в массиве ranks ,
ranks – массив, хранящий ранги процессов, вошедших в новую группу.

Лекция 12. И.Г. Захарова, кафедра ПО

*ranks,MPI_Group *newgroup)
oldgroup – существующая группа,
newgroup – созданная группа,
n –

количество элементов в массиве ranks ,
ranks – массив, хранящий ранги процессов, которые будут исключены из новой группы.

Лекция 12. И.Г. Захарова, кафедра ПО

group1);
MPI_Group_excl(group, size1, ranks, group2);
Лекция 12. И.Г. Захарова, кафедра ПО

быть создана новая группа newgroup
Объединение:
int MPI_Group_union(MPI_Group group1, MPI_Group group2,MPI_Group

*newgroup);
Пересечение:
int MPI_Group_intersection( MPI_Group group1, MPI_Group group2, MPI_Group *newgroup);
Разность:
int MPI_Group_difference( MPI_Group group1, MPI_Group group2, MPI_Group *newgroup);

Лекция 12. И.Г. Захарова, кафедра ПО

группу gr2 - процессы 0, 2, 3
Нумерация задана в

группе, соответствующей MPI_COMM_WORLD
После вызовов
MPI_Group_intersection(gr1, gr2, *newgr1);
MPI_Group_union(gr1, gr2, *newgr2);
MPI_Group_difference(gr1, gr2, *newgr3);
В группе newgr1 процессы 0, 2
В группе newgr2 процессы 0, 1, 2, 4, 5, 3
В группе newgr3 процессы 1, 4, 5
Порядок нумерации процессов в новых группах соответствует порядку их перечисления

Лекция 12. И.Г. Захарова, кафедра ПО

*size)
group – группа,
size– количество процессов.
Ранг текущего процесса в группе:
int MPI_Group_rank(MPI_Group

group, int *rank)
group – группа,
rank– ранг процесса в группе.

Лекция 12. И.Г. Захарова, кафедра ПО

функции:
int MPI_Group_free(MPI_Group group)
group – группа.

Удаление группы не затрагивает коммуникаторы, в

которых она используется.

Лекция 12. И.Г. Захарова, кафедра ПО

*newcom);
из подмножества процессов (группы) имеющегося:
int MPI_Comm_create(MPI_Comm oldcom, MPI_Group group,

MPI_Comm *newcom);
Операция создания коммуникаторов является коллективной ? должна выполняться всеми процессами исходного коммуникатора

Лекция 12. И.Г. Захарова, кафедра ПО

split, int key, MPI_Comm *newcom);
split– в один коммуникатор попадают процессы

с одним значением этого параметра,
key– процессы с бОльшим значением параметра получат бОльший ранг в группе (при равных значениях порядок выбирает система)
Удаление коммуникатора:
int MPI_Comm_free(MPI_Comm *com);

Лекция 12. И.Г. Захарова, кафедра ПО

каждом процессе коммуникатора oldcom.
Процессы разделяются на непересекающиеся группы с одинаковыми

значениями параметра split.
На основе сформированных групп создается набор коммуникаторов.
Порядок нумерации процессов соответствует порядку значений параметра key (процесс с бОльшим значением параметра key будет иметь бОльший ранг).

Лекция 12. И.Г. Захарова, кафедра ПО

rank, &comm);
При q=3, общем числе процессов = 9 получим:
Процессы с

рангами (0, 1, 2) – первый коммуникатор.
Процессы с рангами (3, 4, 5) – второй коммуникатор.
И т.д.

Лекция 12. И.Г. Захарова, кафедра ПО

линий связи между этими узлами.
Топология может быть представлена в

виде графа, в котором
вершины есть процессоры (процессы) системы,
дуги соответствуют имеющимся линиям (каналам) связи.

Лекция 12. И.Г. Захарова, кафедра ПО

коммуникатора.
В коллективной операции принимают участие все процессы коммуникатора.
Следовательно,

логическая топология линий связи между процессами в параллельной программе имеет структуру полного графа.
Можно организовать логическое представление любой необходимой виртуальной топологии независимо от физической сети - с помощью дополнительной адресации процессов.

Лекция 12. И.Г. Захарова, кафедра ПО

типа граф:
int MPI_Graph_create(MPI_Comm oldcomm, int nnodes, int *index, int

*edges, int reorder, MPI_Comm* graphcomm)
oldcomm-исходныйкоммуникатор,
nnodes-количество вершин графа,
index-количество исходящих дуг для каждой вершины,
edges-последовательный список дуг графа,
reorder-параметр допустимости изменения нумерации процессов,
graphcomm–создаваемый коммуникатор с топологией типа граф.
Операция создания топологии является коллективной и должна выполняться всеми процессами исходного коммуникатора

Лекция 12. И.Г. Захарова, кафедра ПО

программу код:
...
int index[] = { 4,1,1,1,1 };
int edges[] =

{ 1,2,3,4,0,0,0,0 };
MPI_CommStarComm;
MPI_Graph_create(MPI_COMM_WORLD, 5, index, edges, 1,&StarComm);
...

Лекция 12. И.Г. Захарова, кафедра ПО