Презентация на тему ANY_SOURCE и ANY_TAG

структура, содержащая 3 поля:

Status.MPI_SOURCE // номер процесса-отправителя

Status.MPI_TAG

// идентификатор сообщения

Status.MPI_ERROR // код ошибки

При пересылке можно использовать специальное значение MPI_PROC_NULL для несуществующего процесса. На самом деле приема/пересылки при работе с таким процессом не происходит. Пример:

next = myrank + 1; // а если next == size?
if (next == size) next = MPI_PROC_NULL; // !!!

о его атрибутах.

MPI_Probe (MPI_ANY_SOURCE, tag, MPI_COMM_WORLD, &Status);

// записывает в структуру Status параметры принимаемого сообщения

int count;
MPI_Get_Count (&Status, MPI_INT, &count); // по значению полей Status, определяет число принятых (вызов после MPI_Recv) или принимаемых (вызов после MPI_Probe) элементов соответствующего сообщения

Сообщение не принимается! Если сразу после MPI_Probe и вызвать MPI_Recv, то примется то же самое сообщение.

// работа процессов останавливается, пока все

не выполнят эту операцию

Пересылка всем от одного:

MPI_Bcast (array, 100, MPI_INT, 0, MPI_COMM_WORLD);
// пересылка от процесса 0 всем остальным (включая сам процесс 0) 100 элементов типа int массива array

Этот вызов должен быть во всех процессах!

10, MPI_INT, 0, MPI_COMM_WORLD); // сбор информации
процесс 0

собирает в массив buf по 10 элементов массивов array из каждого процесса (включая сам процесс 0).
Записи размещаются в порядке возраст. номеров процессов.

Этот вызов должен быть во всех процессах!

MPI_Scatter (array, 10, MPI_INT, buf, 10, MPI_INT, 0, MPI_COMM_WORLD); // рассылка информации
процесс 0 рассылает по 10 элементов массива array в массивы buf всех процессов (включая сам процесс 0). Array делится на равные части, i-я часть посылается (i-1)-у процессу.

Этот вызов должен быть во всех процессах!