Обмен сообщениями в MPI презентация

процесса процесс-отправитель (источник) и процесс-получатель (адресат).
2) Коллективный обмен: участвуют все процессы коммуникатора.

не будет завершена.
Для функции посылки сообщения блокируется, пока все посылаемые данные не будут помещены в буфер (какой – то промежуточный буфер или непосредственно буфер приема).
Для функции приема сообщения блокируется выполнение других операций, пока все данные не будут помещены в буфер приема.
функции без блокировки (асинхронные):

соответ-
ствующих операций обмена. Для опроса завершенности операции (и за-
вершения) вводятся дополнительные операции.

инициализации и завершения передачи сообщения.
Каждый из этих режимов передачи сообщения имеется в блокирующей и неблокирующей формах:

Стандартная передача считается выполненной и завершается, как только сообщение отправлено, независимо от того, дошло оно до адресата или нет. Передача сообщения может начаться, даже если еще не начат его прием.
MPI_Send блокирующая стандартная,
MPI_Isend неблокирующая стандартная.

прием сообщения. Процесс – получатель после приема посылает уведомление процессу – отправителю (адресату), что сообщение получено.
MPI_Issend неблокирующая синхронная,
MPI_Ssend блокирующая синхронная.

Буферизованная передача завершается сразу же, сообщение копируется в системный буфер, где и ожидает своей очереди на пересылку. Завершается буферизованная передача независимо от того, выполнен прием сообщения или нет.
MPI_Bsend блокирующая буферизованная,
MPI_Ibsend неблокирующая буферизованная.

прием сообщения, а завершается сразу, независимо от того, принято сообщение или нет. Если прием не зарегистрирован, ре-зультат этой операции не определен.
MPI_Rsend блокирующая «по готовности»,
MPI_Irsend неблокирующая «по готовности».

Прием сообщения от всех перечисленных выше функций передачи можно осуществить с помощью двух функций:
MPI_Recv блокирующий стандартный;
MPI_Irecv неблокирующий стандартный.

(буква I в имени от immediately – немедленно)

dest, int tag, MPI_Comm comm)

Входные параметры:
buf – начальный адрес буфера передачи
count – количество элементов в буфере передачи
datatype – тип элементов в буфере передачи (тип MPI)
dest – номер (ранг) процесса – получателя
tag – номер (тег) передаваемого сообщения
comm – идентификатор коммуникатора
Выходной параметр:
error – код ошибки

datatype, int dest, int tag, MPI_Comm comm)

Блокирующая передача сообщения «по готовности»:
int MPI_Rsend(void *buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm)

Передача «по готовности» должна начинаться, если уже зарегистрирован соответствующий прием. Если прием не зарегистрирован, результат выполнения операции не определен.

dest, int tag, MPI_Comm comm)
Для выполнения буферизованного обмена необходимо заранее создать буфер достаточного размера с помощью вызова функции MPI_Buffer_attach:
int MPI_Buffer_attach(void *buf, int bufsize)
Входной параметр:
bufsize – размер создаваемого буфера
Выходные параметры:
buf – создаваемый буфер
error – код ошибки

используется функцией MPI_Bsend.
После завершения работы с буфером его необходимо отключить с помощью вызова функции MPI_Buffer_detach:
int MPI_Buffer_detach(void* buf, int bufsize)
В результате выполнения вызова возвращается адрес buf и размер отключаемого буфера bufsize.

Функции MPI_Send, MPI_Ssend, MPI_Bsend и MPI_Rsend имеют одинаковые параметры.

int tag, MPI_Comm comm, MPI_Status *status)
Входные параметры:
count – количество элементов в буфере приема
datatype – тип элементов в буфере приема
source – номер (ранг) процесса - отправителя
tag – номер (тег) принимаемого сообщения
comm – идентификатор коммуникатора
status – статус (информация о полученном
сообщении)
Выходные параметры:
buf – начальный адрес буфера приема
error – код ошибки

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

параметры:
status – статус (информация о полученном сообщении)
datatype – тип данных, в единицах которого требуется
получить размер сообщения
Выходные параметры:
count – количество полученных элементов
error – код ошибки

*status)
Входные параметры:
source – номер (ранг) процесса - отправителя
tag – номер (тег) принимаемого сообщения
comm – идентификатор коммуникатора
Выходные параметры:
status – статус, который содержит необходимую информацию
error – код ошибки.

*flag, MPI_Status *status)
Входные параметры:
source – номер (ранг) процесса – отправителя
tag – номер (тег) принимаемого сообщения
comm – идентификатор коммуникатора
Выходные параметры:
flag = true, если сообщение уже поступило и может быть
принято
status – статус, который содержит необходимую информацию
error – код ошибки.

и прием сообщений. Буферы передачи и приема должны быть различны, типы пересылаемых и принимаемых данных могут быть различны. Прием и передача используют один и тот же коммуникатор.

int MPI_Sendrecv(void *sendbuf, int sendcount, MPI_Datatype sendtype, int dest, int sendtag, void *recvbuf, int recvcount, MPI_Datatype recvtype, int source, int recvtag, MPI_Comm comm,MPI_Status *status)

буфере передачи
sendtype – тип элементов в буфере передачи
dest – номер (ранг) процесса – получателя
sendtag – номер (тег) передаваемого сообщения
recvcount – количество элементов в буфере приема
recvtype – тип элементов в буфере приема
source – номер (ранг) процесса - отправителя
recvtag – номер (тег) принимаемого сообщения
comm – идентификатор коммуникатора
Выходные параметры:
recvbuf – начальный адрес буфера приема
status – статус (информация о полученном сообщении)
error – код ошибки.

int dest, int sendtag, int source, int recvtag, MPI_Comm comm, MPI_Status *status)

– номер (ранг) процесса - получателя
sendtag – номер (тег) передаваемого сообщения
source – номер (ранг) процесса - отправителя
recvtag – номер (тег) принимаемого сообщения
comm – идентификатор коммуникатора
Выходные параметры:
status – статус (информация о полученном сообщении)
error – код ошибки
buf – (входной и выходной) начальный адрес буфера приема и передачи

обладает в MPI каждое посылаемое сообщение?
Как, не принимая сообщение, определить атрибуты сообщения?
Что означает блокирующий обмен сообщениями?
Что означает асинхронный обмен сообщениями?
Можно ли сообщение, отправленное с помощью блокирующей операции посылки, принять неблокирующей операцией приема?
Что гарантирует блокировка при передаче/приеме сообщений?

качестве тегов при посылке различных сообщений в программе использовать одно и тоже число?
Как можно принять любое сообщение от любого процесса?
Как принимающий процесс может определить длину полученного сообщения?
Можно ли при посылке сообщения использовать константы MPI_ANY_TAG, MPI_ANY_SOURCE?
Может ли размер буфера приема быть меньше буфера посылки?
Как избежать тупиковые ситуации при использовании функций обмена?