Форум программистов, компьютерный форум CyberForum.ru

С++ для начинающих

Войти
Регистрация
Восстановить пароль
 
Рейтинг: Рейтинг темы: голосов - 13, средняя оценка - 5.00
nelson1992
3 / 3 / 0
Регистрация: 21.10.2009
Сообщений: 77
#1

Параллельное программирование - C++

28.11.2011, 00:56. Просмотров 1648. Ответов 1
Метки нет (Все метки)

У меня есть задание:

Коллективные операции. Работа имитирует реальный поиск в параллельной базе данных. Некоторое множество записей (ключ, данные) распределено по машинам коллектива. Пользователь за головной машиной (№0) вводит некоторый ключ. Головная машина рсапространяет этот ключ в коллективе, после чего все машины ищут у себя записи с таким ключом. Все машины уведомляют головную о количестве найденных ими записей. Головная машина выделяет буфер нужной длины, собирает ото всех машин результаты поиска и выводит на печать. Используемые функции: MPI_Gather, MPI_Gatherv.

Вот программа, она не моя, нашел в интернете, но она не работает, наверное что-то не доделано...помогите кто может...

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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
#include <stdio.h>
#include <stdlib.h>
#include <alloc.h>
#include <conio.h>
#include <string.h>
#include "mpi.h"
 
 
int main(int argc, char *argv[])
{ 
  MPI_Comm comm = MPI_COMM_WORLD;
  MPI_Status status;
  char *rcharbuf,*sbuf,st[128], s[30][20],data[100][20];
  int bufsize,*displs, *rbuf,i, j, mype,npes,cnt, n, buf[1],code[100], k[1] ;
  double a,b;
  FILE *fp;
  MPI_Init(&argc, &argv);
  MPI_Comm_size(comm, &npes);
  MPI_Comm_rank(comm, &mype);
 
  sprintf(st,"data_%d.txt",mype);
  fp = fopen(st, "rt");
  if (fp == NULL) {
    printf("[%d] Cant open file\n", mype);
    MPI_Abort(comm, 0);
  }
 
n=0; 
 
  while (!feof(fp)){
     fscanf(fp,"%d" "%s" ,&code[n], data[n]);
//      printf("[%d]%d" "%s" ,mype, code[n], data[n]);
   n++; 
 
 }
 fclose(fp);
  if (mype==0) {
 
  printf("В коллективе %d PC\n",npes);
  printf("\nВведите ключ для поиска даннbIх\n");
  scanf("%d", &buf[0]);
 
}   
 
  printf("я [%d]й, в базе n=%d  записей\n", mype, n);
 
 
 
MPI_Bcast(&buf[0],1,MPI_INT,0,comm);
 
sbuf=malloc(n);
cnt=0;
for (i=0; i<n; i++ ){                              
    if (code[i]==buf[0]){
          strcpy(sbuf+cnt, data[i]);
          cnt+=strlen(data[i])+1;
        printf("\n%d нашёл соответствие: %s ",mype,data[i]);
    }
}
 
//   printf("cnt=%d\n", cnt);
 
rbuf=malloc(n);
 
MPI_Gather(&cnt,1,MPI_INT,rbuf,1,MPI_INT,0,comm);
 
displs=malloc(npes);
 
if (mype == 0) {
  displs[0]=0;
 
  for (i=1; i<npes; i++){
//    printf("%d\n", rbuf[i]);
    displs[i]=displs[i-1]+rbuf[i-1];
  }
 
   bufsize=displs[npes-1] + rbuf[npes-1];
//   printf("bufsize=%d\n", bufsize);
   rcharbuf=malloc(bufsize);
}
 
 
MPI_Gatherv(sbuf, cnt, MPI_CHAR, rcharbuf, rbuf, displs,MPI_CHAR, 0,comm);
 
 
if (mype == 0 ) {
printf("\n%d-й принял данные:\n");
 i = 0;
 while (i < bufsize){
   printf("%s\n",rcharbuf+i);
   i += strlen(rcharbuf+i)+1;
  }
  getch();  
}
 
 
MPI_Finalize();
 
return(0);
}
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
28.11.2011, 00:56
Здравствуйте! Я подобрал для вас темы с ответами на вопрос Параллельное программирование (C++):

Параллельное программирование - C++
Как составить параллельную программу вычисления среднего арифметического элементов вектора?

Параллельное программирование на C++ - C++
Вот например происходит какое то действие, это действие длится 5 минут. И вот я запускаю это действие и жду, жду, жду, и тут мне надоело...

Параллельное программирование - C++
Подскажите учебник с помощью которого можно научиться параллельному программированию

Параллельное программирование - C++
Всем доброго времени суток! Не нашла на сайте ни одной темы с параллельным программированием. Хотела узнать есть ли здесь люди знакомые с...

Параллельное программирование - C++
Нужно написать простейшую программу для кластера. Читал про MPI, но там тоже есть выбор: из boost-а, OpenMPI, OpenMP, который...

параллельное программирование - C++
Подскажите, пожалуйста! Возвожу положительные числа в степень, а выдается отрицательный результат. Как быть? #include &lt;iostream&gt; ...

Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
niXman
Эксперт C++
3134 / 1446 / 49
Регистрация: 09.08.2009
Сообщений: 3,441
Записей в блоге: 2
28.11.2011, 12:14 #2
Цитата Сообщение от nelson1992 Посмотреть сообщение
она не работает
что конкретно не работает?
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
28.11.2011, 12:14
Привет! Вот еще темы с ответами:

параллельное программирование - C++
Клиент серверное приложение. Суть - в реализации обычного чата. Оба устройства коннекятся через клиент-серверный сокет. Всё работает ок. Но...

Параллельное программирование в С++ - C++
Здравствуйте! я новичок в параллельном программировании. Помогите пожалуйста с задачкой!! Есть одна глобальная переменная, которая должна...

Параллельное программирование - C++
Подскажите, пожалуйста, как в PUTTY начать редактировать файл?

Параллельное программирование - C++
Кто-нибудь использовал в своей жизни? Если да, то какой? И были ли положительные результаты в плане ускорения? О, да... Может, кто CUDA...


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

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

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