SumElVect

Author: Dima Perov

.travis.yml

@@ -14,7 +14,6 @@ before_install:
 
 install:
   - sudo apt-get install libcr-dev mpich2 mpich2-doc
-  - sudo apt-get install libopencv-*
 
 script:
   - mkdir build
@@ -23,4 +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
+  - mpirun -np 4 ./modules/task_1/Perov_Dima_task1_SumElVect/Perov_Dima_task1_SumElVect 10000

appveyor.yml

@@ -46,5 +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   
+  - cmd: mpiexec.exe -np 4 modules\task_1\Perov_Dima_task1_SumElVect\%configuration%\Perov_Dima_task1_SumElVect.exe 10000   
 

modules/task_1/Perov_Dima_task1_SumElVect/main.cpp

@@ -1,59 +1,108 @@
 #include <iostream>
 #include <mpi.h>
-
-const int SIZE = 10000;
+#include <string>
+#include <ctime>
 
 using namespace std;
 
 int main(int argc, char *argv[])
 {
-	double myVector[SIZE];
-	int myId, numProcs;
-	double startTime = 0;
-	double endTime;
+	srand(time(0));
 
-	for (int i = 0; i < SIZE; i++) {
-		myVector[i] = 1;
-	}
+	double* myVector;
+	int size;
+	
+	string sizeStr;
+	sizeStr = argv[1];
+	size = atoi(sizeStr.c_str()); 
 
-	int flag; // Ôëàã èíöèàëèçàöèè
-	MPI_Status status;
+	myVector = new double[size];
+	
+	
+  
+
+	// for parallel block
+	double myResult = 0;  
+	double startTime = 0;
+	double endTime;
+	double myTime = 0;
 	double mySum = 0;
-	double myResult = 0;
+	int remainderDiv = 0;
+	int flag;
+	int myId, numProcs;
 
-	MPI_Init(&argc, &argv); // Èíöèàëèçèðóåì MPI-îêðóæåíèå
-	MPI_Initialized(&flag); // Ïðîâåðêà
+	// 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";
 	}
 
-	// Îïèñàíèå êîììóíèêàòîðà
-	// Êîììóíèêàòîð óïðàâëÿåò ãðóïïàìè ïàðàëëåëüíûõ ïðîöåcñîâ
-	MPI_Comm_size(MPI_COMM_WORLD, &numProcs); // Îïðåäåëåíèå êîëè÷åñòâî ïðîöåññîâ â ãðóïïå
-	MPI_Comm_rank(MPI_COMM_WORLD, &myId); // Îïðåäåëåíèå ðàíãà ïðîöåññà â ãðóïïå
+   
+	// 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) { 
-	startTime = MPI_Wtime();
+		
+		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 / numProcs * myId], SIZE / numProcs, MPI_DOUBLE, 0, MPI_COMM_WORLD);
-
-	for (int i = SIZE / numProcs * myId; i < SIZE / numProcs + SIZE / numProcs * myId; i++) {
+	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) {
-		cout << "Result: " << myResult << endl;
+	     remainderDiv = size % numProcs;
+		 if (remainderDiv) {
+			for (int i = 0; i < remainderDiv; i++)
+				myResult += myVector[size - remainderDiv  + i];
+		 }
+
+		//Parallel Results 
 		endTime = MPI_Wtime();
-		cout << "Time: " << (endTime - startTime) << " sec" << endl;
-		//system("pause");
+		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;
 }