Форум программистов, компьютерный форум, киберфорум
Наши страницы
С++ для начинающих
Войти
Регистрация
Восстановить пароль
 
Марауль
0 / 0 / 1
Регистрация: 15.12.2015
Сообщений: 16
1

MPI. Отправка/приём сообщений по тегам

06.07.2018, 13:09. Просмотров 312. Ответов 1

Здравствуйте!
Я написал простой код. Его суть заключается в следующем:
Мастер выводит свой ранг и заранее приготовленное сообщение. Затем он посылает это сообщение рабочим, которые после его получения отправляют ему свой ранг. Получив ранги, мастер выводит на экран текст, содержащий ранг процесса, который получил сообщение, и само сообщение.

Собственно, сам код:
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
#include "stdafx.h"
#include <iostream>
#include <stddef.h>
#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include "mpi.h"
 
using namespace std;
 
 
int main(int argc, char *argv[])
{   
    char MessageText[] = "Hello!";
    int BufSize = strlen(MessageText);
 
    int NumProc;
    int ProcRank;
    int RankBuf;
    int Tag_1 = 40, Tag_2 = 41;
 
    MPI_Status Status;
 
 
 
    MPI_Init(&argc, &argv);
    MPI_Comm_size(MPI_COMM_WORLD, &NumProc);
    MPI_Comm_rank(MPI_COMM_WORLD, &ProcRank);
 
    if (ProcRank == 0)
    {
        cout << "Message from process " << ProcRank << ": " << MessageText << endl;
        for (int i = 1; i < NumProc; i++)
        {
            MPI_Send(MessageText, BufSize, MPI_CHAR, i, Tag_1, MPI_COMM_WORLD);
        }
        for (int i = 1; i < NumProc; i++)
        {
            MPI_Recv(&RankBuf, 1, MPI_INT, i, MPI_ANY_TAG, MPI_COMM_WORLD, &Status);
                cout << "Message from process " << RankBuf << ": " << MessageText << endl;
        }
    }
    else
    {
            MPI_Recv(MessageText, BufSize, MPI_CHAR, 0, Tag_1, MPI_COMM_WORLD, &Status);
            MPI_Send(&ProcRank, 1, MPI_INT, 0, Tag_1, MPI_COMM_WORLD);
    }
 
    MPI_Finalize();
 
    return 0;
}
Теперь мне нужно использовать теги, чтобы задать свой порядок отправки/получения сообщений процессами. В коде уже используется один тег, но я хочу хотя бы два.

Я не нашёл ни одного подробного примера с использованием тегов, на этом почему-то особо не заморачиваются.

Поэтому вопрос: как вообще работают теги? Мне ясно, что теги позволяют идентифицировать сообщения, чтобы процессы не принимали что попало. Но это ведь не всё! Как с их помощью можно задаётся, например, порядок получения сообщений? Как они вообще устроены? Как переписать мой код, чтобы было явно видно работу тегов?
0
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
06.07.2018, 13:09
Ответы с готовыми решениями:

Отправка и обработка пользовательских сообщений
Задача стоит в том, чтобы выйти из CALLBACK'а с помощью сообщения. Дело в том что вызов...

отправка сообщений по TCP на одном компьютере
Добрый день. Хочу сделать что то типа соединения клиент-сервер но на одном компьютере. ...

Приём сообщений методом POST
Некоторый клиент должен присылать PHP скрипту бинарный файл. Для этого он присылает http сообщение...

[Решено] STM32F4 приём CAN сообщений
На F4Dyscovery принимаю CAN сообщения. Иногда часть сообщений пропускаю. Переписал код так: void...

Приём сообщений от сервера в фоне
Привет, нужна помощь в структуре. Первый раз работаю с подключением. В общем к делу: 1.Отправляю...

1
Марауль
0 / 0 / 1
Регистрация: 15.12.2015
Сообщений: 16
06.07.2018, 17:35  [ТС] 2
короче чёто намутил, заработали отправка и получение со вторым тегом.
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
#include "stdafx.h"
#include <iostream>
#include <stddef.h>
#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include "mpi.h"
 
using namespace std;
 
 
int main(int argc, char *argv[])
{   
    char MessageText_M[] = "Hello, boss!";
    char MessageText_1[] = "Hello! Nice to see you here!";
    char MessageText_2[] = "Hello! What do you think?";
 
    char Message[] = "EchoTest";
    int BufSize = strlen(Message);
 
    int NumProc;
    int ProcRank;
    int RankBuf;
    int Tag_1 = 40, Tag_2 = 41;
 
    MPI_Status Status;
 
 
 
    MPI_Init(&argc, &argv);
    MPI_Comm_size(MPI_COMM_WORLD, &NumProc);
    MPI_Comm_rank(MPI_COMM_WORLD, &ProcRank);
 
    if (ProcRank == 0)
    {
        cout << endl << "Message from master-process " << ProcRank << ": " << MessageText_M << endl << endl;
        for (int i = 1; i < NumProc; i++)
        {   
            MPI_Send(Message, BufSize, MPI_CHAR, i, Tag_1, MPI_COMM_WORLD);
            MPI_Send(Message, BufSize, MPI_CHAR, i, Tag_2, MPI_COMM_WORLD);
        }
        for (int i = 1; i < NumProc; i++)
        {
            MPI_Recv(&RankBuf, 1, MPI_INT, i, Tag_1, MPI_COMM_WORLD, &Status);
                cout << "Message from process " << RankBuf << ": " << MessageText_1 << endl;
            MPI_Recv(&RankBuf, 1, MPI_INT, i, Tag_2, MPI_COMM_WORLD, &Status);
                cout << "Message from process " << RankBuf << ": " << MessageText_2 << endl;
        }
    }
    else
    {
            MPI_Recv(Message, BufSize, MPI_CHAR, 0, Tag_1, MPI_COMM_WORLD, &Status);
            MPI_Send(&ProcRank, 1, MPI_INT, 0, Tag_1, MPI_COMM_WORLD);
 
            MPI_Recv(Message, BufSize, MPI_CHAR, 0, Tag_2, MPI_COMM_WORLD, &Status);
            MPI_Send(&ProcRank, 1, MPI_INT, 0, Tag_2, MPI_COMM_WORLD);
    }
 
    MPI_Finalize();
 
    return 0;
}
Результат на картинке во вложении. Как сделать так, чтобы каждый процесс получал только одно сообщение, чтобы процесс-мастер распечатывал сообщение по одному тегу процесса-рабочего, а не по двум?

В коде процесса-мастера я пробовал сделать отправку сообщений через цикл while, чтобы каждый новый i-й процесс получал только одно сообщение вместо двух:
C++
1
2
3
4
5
6
7
8
9
int i = 1;
{
   while (i < NumProc)
   MPI_Send(Message, BufSize, MPI_CHAR, i, Tag_1, MPI_COMM_WORLD); // отправили сообщение i-му процессу
   i++; //увеличили значение i, чтобы следующее сообщение отправлялось уже новому процессу
   if (i == NumProc) break; //делаем проверку и если что выходим из цикла, на случай превышения числа процессов
   MPI_Send(Message, BufSize, MPI_CHAR, i, Tag_2, MPI_COMM_WORLD); //отправили сообщение i-му процессу
   i++; //снова увеличили значение i, чтобы следующее сообщение снова отправлялось новому процессу
}
Но из этого ничего хорошего не вышло. Почему-то печатается только одно сообщение первого процесса и дальше программа просто не выполняется.

Что можно тут сделать?
0
Миниатюры
MPI. Отправка/приём сообщений по тегам  
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
06.07.2018, 17:35

Приём сообщений без перезагрузки страницы
Делаю чат, расскажите о http://jsfiddle.net/bv5Kq/13 Как мне реализовать это? Лист сообщений...

Отправка и приём данных
Tcp сокеты. У меня есть два массива байтов. Допустим я отправил один массив, а потом ещё один....

Отправка и приём данных на AJAX
Обьясните как работать с AJAX В простых примерах. Например Как отправить формой сообщение без...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
2
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2019, vBulletin Solutions, Inc.
Рейтинг@Mail.ru