Merge pull request #14 from diper1998/branchOfDiper

Перов Дима. Задача 1. Сумма элементов вектора.

Author: Nesterov Alexander

.travis.yml

@@ -22,3 +22,4 @@ script:
   - make -j4
 
   - mpirun -np 4 ./modules/test_task/test_task
+  - mpirun -np 4 ./modules/task_1/Perov_Dima_task1_SumElVect/Perov_Dima_task1_SumElVect 10000

appveyor.yml

@@ -46,3 +46,5 @@ build_script:
   - cmd: msbuild ALL_BUILD.vcxproj
 
   - cmd: mpiexec.exe -np 4 modules\test_task\%configuration%\test_task.exe
+  - cmd: mpiexec.exe -np 4 modules\task_1\Perov_Dima_task1_SumElVect\%configuration%\Perov_Dima_task1_SumElVect.exe 10000   
+

modules/task_1/CMakeLists.txt

@@ -1 +1,2 @@
 message(STATUS "Task 1")
+add_subdirectory( Perov_Dima_task1_SumElVect )

modules/task_1/Perov_Dima_task1_SumElVect/CMakeLists.txt

@@ -0,0 +1,10 @@
+project( Perov_Dima_task1_SumElVect )
+ message( STATUS "-- " ${PROJECT_NAME} )
+add_executable( ${PROJECT_NAME} main.cpp )
+ if( MPI_COMPILE_FLAGS )
+    set_target_properties( ${PROJECT_NAME} PROPERTIES COMPILE_FLAGS "${MPI_COMPILE_FLAGS}" )
+endif( MPI_COMPILE_FLAGS )
+ if( MPI_LINK_FLAGS )
+  set_target_properties( ${PROJECT_NAME} PROPERTIES LINK_FLAGS "${MPI_LINK_FLAGS}" )
+endif( MPI_LINK_FLAGS )
+ target_link_libraries( ${PROJECT_NAME} ${MPI_LIBRARIES} )

modules/task_1/Perov_Dima_task1_SumElVect/main.cpp

@@ -0,0 +1,104 @@
+#include <iostream>
+#include <mpi.h>
+#include <string>
+#include <ctime>
+#include <cstdlib>
+#include <assert.h>
+
+using namespace std;
+
+int main(int argc, char *argv[])
+{
+	srand((int)time(0));
+
+	double* myVector;
+	int size;
+	
+	string sizeStr;
+	sizeStr = argv[1];
+	size = atoi(sizeStr.c_str()); 
+
+	myVector = new double[size];
+	
+	// for parallel block
+	double myResult = 0;  
+	double startTime = 0;
+	double endTime;
+	double myTime = 0;
+	double mySum = 0;
+	int remainderDiv = 0;
+	int flag;
+	int myId, numProcs;
+
+	// for line block
+	double myResult_ = 0; 
+	double startTime_ = 0;
+	double endTime_ = 0;
+	double myTime_ = 0;
+	
+	// Initialize the MPI environment
+
+	MPI_Init(&argc, &argv); 
+	MPI_Initialized(&flag); // check
+	if (!flag) {
+		std::cout << "Error: MPI_Init";
+	}
+
+	// Description of the communicator
+	// communicator manages groups of parallel processes
+	MPI_Comm_size(MPI_COMM_WORLD, &numProcs); // determining the number of processes in a group
+	MPI_Comm_rank(MPI_COMM_WORLD, &myId); // determining the rank of a process in a group
+	
+	if (myId == 0) { 
+		
+		for (int i = 0; i < size; i++) {
+			myVector[i] = (double)(rand()%5) / ((double)(rand()%10) + 1);
+		}
+		//*LINE BLOCK*
+		startTime_ = MPI_Wtime();
+	    for (int i = 0; i < size; i++) {
+			myResult_ += myVector[i];
+		}
+	    endTime_ = MPI_Wtime();
+		cout << endl << "*LINE*" << endl;
+		cout << "Result: " << myResult_ << endl;
+		myTime_ = endTime_ - startTime_;
+		cout << "Time: " << myTime_ << " sec" << endl;
+		//*END
+
+		//*PARALLEL BLOCK*
+	startTime = MPI_Wtime(); // started counting time in 0 proccess
+	
+	}
+
+	MPI_Bcast(myVector, size , MPI_DOUBLE, 0, MPI_COMM_WORLD);
+	
+	for (int i = size / numProcs * myId; i < size / numProcs + size / numProcs * myId; i++) {
+		mySum += myVector[i];
+	}
+
+	MPI_Reduce(&mySum, &myResult, 1, MPI_DOUBLE, MPI_SUM, 0, MPI_COMM_WORLD);
+    
+	if (myId == 0) {
+	     remainderDiv = size % numProcs;
+		 if (remainderDiv) {
+			for (int i = 0; i < remainderDiv; i++)
+				myResult += myVector[size - remainderDiv  + i];
+		 }
+
+		//Parallel Results 
+		endTime = MPI_Wtime();
+		cout << endl <<"*PARALLEL*" << endl;
+		cout << "Result: " << myResult << endl;
+		myTime = endTime - startTime;
+		cout << "Time: " << myTime << " sec" << endl << endl;
+	}
+	
+
+	MPI_Finalize();
+	//*END PARALLEL BLOCK*
+	
+	delete[]myVector;
+
+	return 0;
+}