Распараллеливание алгоритма сортировки массива, страница 3

// ======================== Сохранение результата ==============================

if (rank != 0) // Сохранение проводит нулевой комп

MPI_Send(x,rows,MPI_FLOAT,0,15,MPI_COMM_WORLD);

else

{

t_en = clock(); // Засекаем время

t_en = t_en - t_st;

fp = fopen("_x.txt","w"); // Открываем файл результата

fprintf(fp,"Time: %d.\n",t_en); // Пишем туда время

fprintf(fp,"%d\n",N); // и размерность

for (i = 0; i < rows; i++) // Сохраняем свои данные

fprintf(fp,"%f\n",x[i]);

for (rank_k = 1; rank_k < size; rank_k++)

{ // Принимаем данные от rank_k

rows_k = (int)(N/size); // и сохраняем

if (rank_k < N%size) rows_k++;

MPI_Recv(x,rows_k,MPI_FLOAT,rank_k,15,MPI_COMM_WORLD,&st);

for (i = 0; i < rows_k; i++)

fprintf(fp,"%f\n",x[i]);

}

fclose(fp); // Закрываем файл

}

free(x); // Чистим память

MPI_Finalize();

return 0; // Конец

}

//--------------------------------------------------------------------------4. Тестирование программы:

1 2 3