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

Требования к приему сообщения

Буфер памяти должен быть достаточным для приема сообщения.
При

Требования к приему сообщения

Параметр status позволяет определить для принятого сообщения:
status.MPI_SOURCE –

Требования к приему сообщения

Прием сообщения м.б. инициирован
до момента,
в момент,
после момента начала

Неблокирующее выполнение передачи данных

Блокирующие функции - приостанавливают выполнение процессов (например, вычислений)

Неблокирующее выполнение передачи данных

Неблокирующие функции обмена данными выполняются без блокировки процессов

Неблокирующие функции

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

Параметры функций

request - определяется функцией перед завершением выполнения и может

Пример

Условная схема вычислений и выполнения неблокирующей операции передачи сообщения:
MPI_Isend(buf, count, type,

Управление группами процессов и коммуникаторами

На основе групп создаются коммуникаторы
В группе может

Выполнение операций передачи данных

Парные операции – только для процессов из одного

Управление группами

Группа создается только из уже существующих групп.
Исходной м.б. группа, связанная

Получение группы, связанной с существующим коммуникатором:

int MPI_Comm_group(MPI_Comm comm, MPI_Group *group)
comm –

Создание новой группы на основе существующей (1)

int MPI_Group_incl(MPI_Group oldgroup,int n,int *ranks,MPI_Group

Создание новой группы на основе существующей (2)

int MPI_Group_excl(MPI_Group oldgroup,int n,int *ranks,MPI_Group

Пример: создание двух непересекающихся групп

…
size1=size/2;
for(i=1; i<=size1; i++)
{
ranks[i]=i-1;
}
MPI_Group_incl(group, size1, ranks, group1);
MPI_Group_excl(group,

Операции над группами

На основе существующих групп group1 и group2 может быть

Пример

В группу gr1 входят процессы 0, 1, 2, 4, 5
В группу

Получение информации о группе

Количество процессов в группе:
int MPI_Group_size(MPI_Group group, int *size)
group

Удаление группы

После завершения использования группы ее надо удалить с помощью функции:
int

Операции над коммуникаторами

Создание нового коммуникатора
путем дублирования имеющегося:
int MPI_Comm_dup(MPI_Comm oldcom, MPI_Comm *newcom);
из

Операции над коммуникаторами

Одновременное создание нескольких новых коммуникаторов:
int MPI_Comm_split(MPI_Comm oldcom, int split,

Операция – коллективная ?
Вызов функции MPI_Comm_split должен быть выполнен в каждом

Пример

MPI_Comm comm;
int rank, row;
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
row = rank / q;
MPI_Comm_split(MPI_COMM_WORLD, row, rank,

Виртуальные топологии

Под топологией вычислительной системы понимают структуру узлов сети и линий

Парные операции передачи данных могут быть выполнены между любыми процессами коммуникатора.

Пример - топология некоторого графа

Функция для создания коммуникатора с топологией типа

Пример

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